最近抖音,小红书上面有个很火的天气推送的公众号，可以给自己爱的人进行定时推送. 效果如下，结合亲生经历给大家讲述一下操作流程。整个项目代码目前十分规整,项目代码整体400多行 ,就直接分享出来吧._把小红书内容推送到自己的公众号 csdn

最近抖音,小红书上面有个很火的天气推送的公众号，可以给自己爱的人进行定时推送.
效果如下，结合亲生经历给大家讲述一下操作流程。很简单，有点编程基础就可以.
网上看的相关介绍都是十分的简单,本着无偿分享的态度,重构了整个代码.
整个项目代码目前十分规整,项目代码整体400多行 ,就直接分享出来吧.

微信公众号平台

https://mp.weixin.qq.com/debug/cgi-bin/sandboxinfo?action=showinfo&t=sandbox/index
(用来创建测试公众及号, 需要自己和你的那位一起扫码关注)
(填写测试模板,我这里是6个板块)

小接口：

https://www.tianapi.com
(用来申请api接口)

Github：

https://github.com/
(用来自动运行任务,免费的服务器)

整个项目已经公布在github : https://github.com/linzixuan45/daily_publish

整个代码模板的效果如下

项目思路介绍,

创建一个测试的微信公众号平台,注册

获取测试号的appid 和 appsecret

自己扫码关注,女朋友也扫码关注, 如下图,扫码获得 微信号的编码.

新增测试模板并获取模板id

“”"
目前时间是：{{date_date.DATA}}
早安寄语：{{zaoan.DATA}}
今天是我们的第：{{love_days.DATA}}天
距离她的生日：{{birthday_left.DATA}}天
她所在的城市：{{weather_message0.DATA}}
他所在的城市：{{weather_message1.DATA}}
“”"

“”"
今日想对然然说的话：{{words.DATA}}
{{song_words.DATA}}
“”"
“”"
晚上好啊，悠然
目前的时间是：{{date_date.DATA}}
一个有趣的健康知识：{{health.DATA}}
晚安寄语：{{wanan.DATA}}
“”"
“”"
{{title.DATA}}
{{content.DATA}}
“”"

“”"
{{star.DATA}}
“”"

“”"
{{menses.DATA}}
“”"

在 https://www.tianapi.com 网址

注册以下接口, 也可以自己去创建新的接口，编写新的调用函数

保存自己的接口密钥key,如下图

整个项目代码如下:

import datetime
from datetime import date
import math
from wechatpy import WeChatClient
from wechatpy.client.api import WeChatMessage, WeChatTemplate
import requests
import random
import json
import time
1
2
3
4
5
6
7
8
9

以下代码完成月经提醒，关于月经周期的计算，完全参考这张图

Tips = {
    "卵巢周期": {
        "卵泡期": [
            "卵泡期由上次月经停止日开始至卵巢排卵日止，历时10～12天。在这一期中，此期卵泡的粒膜细胞在FSH和LH的作用下产生雌激素，在雌激素的作用下，子宫内膜迅速增殖，血管增生，腺体增宽加长，但不分泌。"],
        "排卵日": [""],
        "黄体期": ["黄体期主要是指女性在排卵期到月经来之前的一个特定阶段，在这段时间内就有可能形成黄体，"
                "同时会形成生理性的体温增高。排卵之后，卵子和卵泡液流出，卵泡腔下降、塌陷，与周围的结缔组织包绕，从而形成黄体。"
                "黄体能够分泌雌孕激素，如果患者没有怀孕，雌孕激素会迅速的下降，在维持14天左右体温也会下降，同时来月经。如果怀孕之后，"
                "黄体则继续起到分泌功能，能够分泌雌孕激素，促进并支持胚胎的发育。如果患者出现黄体功能不全，患者则会出现胚胎停止发育，甚至习惯性流产。"]
    },
    "子宫周期": {
        "经期": [""],
        "增长期": [""],
        "排卵日": [""],
        "分泌期": ["分泌期,也称为黄体期,是月经周期的一个阶段,指从排卵后到下一次来月经前这段时间。月经周期分为三个阶段:"
                   "卵泡期、黄体期、排卵期。首先卵泡发育阶段被称为卵泡增生,"
                   "而卵泡破裂的时期被称为排卵期,排卵后至下一次来月经前称为黄体期,这段时间的子宫内膜会发生分泌期的变化,因此也称为分泌期"]
    },
    "俗称": {
        "经期": ["在饮食方面，月经期间要避免进食辛辣、凉、冷、硬的食物,要注意下腹部的保暖"
                "因为寒冷有可能会导致痛经的发生,月经期间可以进行温和的运动，例如散步、快走等，但是要避免剧烈的运动"
                "月经期间一定要注意外阴的清洁，要每天清洗外阴，使用棉质透气的卫生巾，并且要及时更换卫生巾"],
        "安全期（排卵前安全期)": ["安全期避孕并非绝对安全，只是受孕机率小些。 安全期避孕并非绝对安全，只是受孕机率小些"
                                 "如果是在月经刚干净的三天内，一般这个时间段同房是不会怀孕的，也可以不带避孕套"],
        "排卵前期（排卵期，危险期）": ["在排卵期的时候白带会明显的增多，在这个时候一定要注意好个人的卫生，建议勤换内裤"
                                    "适当的用温盐水清洗一下外阴，同时在排卵期的时候，由于受孕概率比较高，这个时候也称之为危险期"],
        "排卵日": ["今天是排卵日哦"],
        "排卵后期（排卵期，危险期）": [
            "女性在排卵的时候可能会出现一个排卵期的出血，这种属于生理现象，不需要去过度的治疗，但是如果经常性地出现排卵期出血，那么可能是存在黄体功能不足，建议尽早的抽血查一下性激素水平"],
        "安全期（排卵后安全期）": ["女性在排卵日后五天一般就是到了安全期，因为在女性在排卵日的时候排卵比较多见，并且卵子排出后，它的存活期是48小时内，所以在排卵之后的五天，"
                                 "此时即便是有卵子已经排出，也已经死亡，在此期间进行同房，精子和卵子就不能够结合发育成受精卵，一般就不会导致女性怀孕。少数的情况下，"
                                 "若女性由于精神压力大劳累或者是等其他因素影响，导致排卵日检测的不准确，出现排卵日后延，卵子排出后仍在存活期，即排卵日后五天卵子在存活期，"
                                 "发生性生活后也有导致意外怀孕的，因此安全期和危险期只是个相对的日期，并不是绝对的准确。如果女性无怀孕欲望，最好全程戴避孕套，以免意外情况的发生。"]
    }
}


def diff_time(start, end):
    start = time.strptime(start, "%Y-%m-%d")
    end = time.strptime(end, "%Y-%m-%d")
    userStart = datetime.datetime(start[0], start[1], start[2])
    userEnd = datetime.datetime(end[0], end[1], end[2])
    return (userEnd - userStart).days


def menstrual_dict(period_per_classes):
    temp = 0
    temp_ls = []
    for value in period_per_classes:
        temp += value
        temp_ls.append(temp)

    name_dict = {
        "卵巢周期": {
            "卵泡期": [0, temp_ls[2]],
            "排卵日": [temp_ls[3], temp_ls[3]],
            "黄体期": [temp_ls[3] + 1, temp_ls[-1]]
        },
        "子宫周期": {
            "经期": [0, temp_ls[0]],
            "增长期": [temp_ls[0] + 1, temp_ls[2]],
            "排卵日": [temp_ls[3], temp_ls[3]],
            "分泌期": [temp_ls[3] + 1, temp_ls[-1]]
        },
        "俗称": {
            "经期": [0, temp_ls[0]],
            "安全期（排卵前安全期)": [temp_ls[0] + 1, temp_ls[1]],
            "排卵前期（排卵期，危险期）": [temp_ls[1] + 1, temp_ls[2]],
            "排卵日": [temp_ls[3], temp_ls[3]],
            "排卵后期（排卵期，危险期）": [temp_ls[3] + 1, temp_ls[4]],
            "安全期（排卵后安全期）": [temp_ls[4], temp_ls[-1]]
        }
    }
    return name_dict

class Menses:

    def __init__(self, name, menses_period):
        self.menses_period = menses_period
        # 经期,安全期（排卵前安全期),排卵前期（排卵期，危险期）,排卵日,排卵后期（排卵期，危险期）,安全期（排卵后安全期）
        self.menstrual_classes_period = [4, 4, 5, 1, 4, 10]
        self.name = name

        menstrual_cycle = []
        pre_value = 0
        for value in self.menses_period:
            if pre_value != 0:
                menstrual_cycle.append(diff_time(pre_value[1], value[0]))
            pre_value = value

        self.out_message = self.own_sheet()
        self.ovulation_period_start = min(menstrual_cycle) - 18
        self.ovulation_period_end = max(menstrual_cycle) - 11

    def own_sheet(self):
        sheet = menstrual_dict(self.menstrual_classes_period)
        time_now = f"{time.gmtime()[0]}-{time.gmtime()[1]}-{time.gmtime()[2]}"
        last_menstrual_time = self.menses_period[-1][0]

        key_point = diff_time(last_menstrual_time, time_now)
        message = []
        for name in sheet.keys():
            for key, value in sheet[name].items():
                if key_point in range(value[0], value[1]):
                    message.append(key)

        message = list(set(message))
        tips_message = []
        for key, v in Tips.items():
            for key, value in v.items():
                if key in message:
                    tips_message.append(value)

        out_message = f"今天是{self.name}的"
        for key in message:
            if key == message[-1]:
                out_message += key
            else:
                out_message += key + ","
        out_message += "哦,以下是一些Tips："

        for key in tips_message:
            if key == message[-1]:
                out_message += str(key)
            else:
                out_message += str(key) + ","

        return out_message

    def __call__(self, *args, **kwargs):
        return self.out_message
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132

以下代码完成对api的调用

# -*- coding: utf-8 -*-
def song_word(key):
    url = f"http://api.tianapi.com/zmsc/index?key={key}"
    ret = requests.get(url)
    ret = ret.content.decode('utf8').replace("'", '"')
    data_json = json.loads(ret)
    message = f"今日宋词：{data_json['newslist'][0]['content']}" + '\n' + f"出自：{data_json['newslist'][0]['source']}"
    print(message)
    return message


def story(key):
    url = f"http://api.tianapi.com/story/index?key={key}"
    ret = requests.get(url)
    ret = ret.content.decode('utf8').replace("'", '"')
    data_json = json.loads(ret)
    title = data_json['newslist'][0]['title']
    content = data_json['newslist'][0]['content']
    print(title, content)
    return title, content


def star(key, star_name):
    url = f"http://api.tianapi.com/star/index?key={key}&astro={star_name}"
    ret = requests.get(url)
    ret = ret.content.decode('utf8').replace("'", '"')
    data_json = json.loads(ret)
    message = f"星座名称：{star_name}，"
    for i, news in enumerate(data_json['newslist'][:-1]):
        if i % 3 == 0:
            message += f"{news['type']}: {news['content']}, " + '\n'
        else:
            message += f"{news['type']}: {news['content']}, "
    last_message = f"{data_json['newslist'][-1]['type']}：{data_json['newslist'][-1]['content']}"
    print(message, last_message)
    return message, last_message


def health(key):
    url = f"http://api.tianapi.com/healthtip/index?key={key}"
    ret = requests.get(url)
    ret = ret.content.decode('utf8').replace("'", '"')
    data_json = json.loads(ret)
    msg = data_json['newslist'][-1]['content']
    print(msg)
    return msg


def night_msg(key):
    url = f"http://api.tianapi.com/wanan/index?key={key}"
    ret = requests.get(url)
    ret = ret.content.decode('utf8').replace("'", '"')
    data_json = json.loads(ret)
    msg = data_json['newslist'][-1]['content']
    print(msg)
    return msg


def morning_msg(key):
    url = f"http://api.tianapi.com/zaoan/index?key={key}"
    ret = requests.get(url)
    ret = ret.content.decode('utf8').replace("'", '"')
    data_json = json.loads(ret)
    msg = data_json['newslist'][-1]['content']
    print(msg)
    return msg


def get_words():
    words = requests.get("https://api.shadiao.pro/chp")
    if words.status_code != 200:
        return get_words()
    return words.json()['data']['text']


def get_random_color():
    return "#%06x" % random.randint(0, 0xFFFFFF)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78

以下代码完成对于指定时间点的运行调用

class WeMessage:
    def __init__(self, user0, user1, client_info, tiannapi_api):
        self.tianapi_api = tiannapi_api
        self.user0 = user0
        self.user1 = user1
        self.client_info = client_info
        self._init_user_info()
        self.start()

    def _init_user_info(self):

        self.now_time = time.strftime("%H:%M:%S", time.localtime())  # 现在的时间
        self.today = datetime.datetime.now()
        self.start_date = self.user0['START_DATE']
        self.city0 = self.user0['CITY']
        self.city1 = self.user1['CITY']
        self.birthday0 = self.user0['BIRTHDAY']
        self.birthday1 = self.user1['BIRTHDAY']

    def get_count(self):
        delta = self.today - datetime.datetime.strptime(self.start_date, "%Y-%m-%d")
        return delta.days

    def get_birthday(self, birthday):
        next = datetime.datetime.strptime(str(date.today().year) + "-" + birthday, "%Y-%m-%d")
        if next < datetime.datetime.now():
            next = next.replace(year=next.year + 1)
        return (next - self.today).days

    def get_weather(self, city):
        url = "http://autodev.openspeech.cn/csp/api/v2.1/weather?openId=aiuicus&clientType=android&sign=android&city=" + city

        res = requests.get(url).json()
        weather = res['data']['list'][0]
        weather_message = f"{weather['city']}, 天气：{weather['weather']}，" + f"温度：{math.floor(weather['temp'])}，" + f"湿度：{weather['humidity']}，" + f"风力等级：{weather['wind']}"
        return weather_message

    def send_daily_msg(self, wm, server_time):
        weather_message0 = self.get_weather(self.user0['CITY'])
        weather_message1 = self.get_weather(self.user1['CITY'])
        data0 = {
            "date_date": {"value": str(server_time)+'，今天也要加油哦!', "color": get_random_color()},
            "zaoan": {"value": morning_msg(self.tianapi_api), "color": get_random_color()},
            "weather_message0": {"value": weather_message0, "color": get_random_color()},
            "weather_message1": {"value": weather_message1},
            "love_days": {"value": self.get_count(), "color": "#%06x" % 0xFA8072},
            "birthday_left": {"value": self.get_birthday(self.user0['BIRTHDAY']), "color": "#%06x" % 0xFA8072},

        }
        data1 = {
            "words": {"value": get_words(), "color": get_random_color()},
            "song_words": {"value": song_word(self.tianapi_api), "color": get_random_color()},
        }
        for i in range(len(self.client_info['USER_ID'])):
            wm.send_template(self.client_info['USER_ID'][i], self.client_info['TEMPLATE_ID']['daily_id1'], data0)
            wm.send_template(self.client_info['USER_ID'][i], self.client_info['TEMPLATE_ID']['daily_id2'], data1)

    def send_star_msg(self, wm):
        star_message0, last_message0 = star(self.tianapi_api, self.user0['STAR'])
        star_message1, last_message1 = star(self.tianapi_api, self.user1['STAR'])
        star_0 = [{"star": {"value": star_message0, "color": "#%06x" % 0x8E236B}},
                  {"star": {"value": last_message0, "color": "#%06x" % 0x8E236B}}]
        star_1 = [{"star": {"value": star_message1, "color": "#%06x" % 0x8E236B}},
                  {"star": {"value": last_message1, "color": "#%06x" % 0x8E236B}}]
        for i in range(len(self.client_info['USER_ID'])):
            for value in [star_0, star_1]:
                for key_message in value:
                    wm.send_template(self.client_info['USER_ID'][i],
                                     self.client_info['TEMPLATE_ID']['star_id'],
                                     key_message)

    def send_menses_msg(self, wm):
        content = Menses(name=self.user0['NAME'], menses_period=self.user0['MENSES_PERIOD']).out_message
        wechat_max_index = 180
        times = int(len(content)/wechat_max_index)+1 \
            if int(len(content)/wechat_max_index) < len(content)/wechat_max_index else len(content)/wechat_max_index

        for j in range(times):
            temp_msg = content[j*wechat_max_index:(j+1)*wechat_max_index]
            send_msg = {"menses": {"value": temp_msg}}
            for i in range(len(self.client_info['USER_ID'])):
                wm.send_template(self.client_info['USER_ID'][i],
                                 self.client_info['TEMPLATE_ID']['menses_id'],
                                 send_msg)

    def send_night_msg(self, wm, server_time):
        msg0 = {
            "date_date": {'value': server_time, 'color': get_random_color()},
            'health': {'value': health(self.tianapi_api), 'color': get_random_color()},
            'wanan': {'value': night_msg(self.tianapi_api), 'color': get_random_color()}
        }

        title, content = story(self.tianapi_api)

        for i in range(len(self.client_info['USER_ID'])):
            wm.send_template(self.client_info['USER_ID'][i],
                             self.client_info['TEMPLATE_ID']['night_id'],
                             msg0)

        wechat_max_index = 180
        times = int(len(content)/wechat_max_index)+1 \
            if int(len(content)/wechat_max_index) < len(content)/wechat_max_index else len(content)/wechat_max_index

        for i in range(times):
            temp_msg = content[i*wechat_max_index:(i+1)*wechat_max_index]
            msg1 = {
                'title': {'value': title, "color": "#%06x" % 0xFA8072},
                'content': {'value': temp_msg}
            }
            for j in range(len(self.client_info['USER_ID'])):
                wm.send_template(self.client_info['USER_ID'][j],
                                 self.client_info['TEMPLATE_ID']['story_id'],
                                 msg1)

    def start(self):
        client = WeChatClient(self.client_info['APP_ID'], self.client_info['APP_SECRET'])
        wm = WeChatMessage(client)

        # server_time = str((int(self.now_time[:2]) + 8) % 24) + self.now_time[2:]  # Github 时间比国内早8小时
        server_time = self.now_time

        # 判断时间
        if "08:00:00" < server_time < "11:00:00":
            self.send_daily_msg(wm, server_time)
        if "11:00:00" < server_time < "14:00:00":
            self.send_star_msg(wm)
        if "18:00:00" < server_time < "21:00:00":
            self.send_menses_msg(wm)
        if "21:00:00" < server_time < "24:00:00":
            self.send_night_msg(wm, server_time)

        #self.send_daily_msg(wm, server_time)
        #self.send_star_msg(wm)
        #self.send_menses_msg(wm)
        #self.send_night_msg(wm, server_time)
        print(server_time)
        print("process have down")
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138

以下部分填入个人信息

if __name__ == "__main__":
    """修改对应的user信息"""
    wechat_max_index = 180
    user0 = {
        "NAME": '悠然',
        'START_DATE': '2022-05-21',
        'CITY': '苏州',
        'BIRTHDAY': '11-8',
        'STAR': '天蝎座',
        'MENSES_PERIOD': [
            ("2022-5-30", "2022-6-5"),
            ("2022-6-27", "2022-7-8"),
            ("2022-7-30", "2022-8-5"),
            ("2022-9-2", "2022-9-8"),
            ("2022-9-26", None),
        ]  # 此项填入月经周期
    }  # 女生的信息

    user1 = {
        "NAME": '子轩',
        'STAR': '金牛座',
        'START_DATE': '2022-05-21',
        'CITY': '广州',
        'BIRTHDAY': '05-19',
    }  # 男生的信息

    """以下密钥均已做修改，无法使用，需自己去申请 """

    tianapi_api = '54601312395c6d7fe2d8ee6'  # 第三方接口的key
    """从微信公众平台获取的相关密钥"""
    client_info = {
        "APP_ID": 'wxaef9d01eca',
        "APP_SECRET": 'ef79f1e3eac60fa1502a',
        "USER_ID": ['omr1N5l9Kf3qrGs', 'omr1N5sAt5SgWK9aw'],
        "TEMPLATE_ID": {
            'daily_id1': 'Kyyl3f7JxD7R0qTY-4',
            'daily_id2': 'MJ0faGDTKS6awxQV6iNI',
            'star_id':   'vxbFxhPictedz-jEzE7yWLc',
            'menses_id': '2rTC0o4BDZHg-ds9c9U',
            'night_id':  'Z60JmU38hQTthRniuUi7T0',
            'story_id':  '5I4PnlOsv2KSkW7DB7K_SUi0',
        }
    }
    WeMessage(user0, user1, client_info, tianapi_api)

    '''以下是需要填到微信公众号测试平台的temp  获取到对应的id 后，填入上方 template——id'''
    """   daily_id1

    目前时间是：{{date_date.DATA}}
    早安寄语：{{zaoan.DATA}}
    今天是我们的第：{{love_days.DATA}}天
    距离她的生日：{{birthday_left.DATA}}天
    她所在的城市：{{weather_message0.DATA}}
    他所在的城市：{{weather_message1.DATA}}

    """

    """  daily_id2

    今日想对她说的话：{{words.DATA}}
    {{song_words.DATA}}

    """

    """  night_id

    晚上好啊，悠然
    目前的时间是：{{date_date.DATA}}
    一个有趣的健康知识：{{health.DATA}}
    晚安寄语：{{wanan.DATA}}

    """

    """  story_id

    {{title.DATA}}
    {{content.DATA}}

    """

    """  star_id

    {{star.DATA}}

    """

    """  menses_id

    {{menses.DATA}}

    """
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91

若想挂在github上面,需要自己去填写action文件, 源码如下 , yml文件

# This is a basic workflow to help you get started with Actions

name: daily wechat publish  # 指定工作流的名字

# Controls when the workflow will run
on:
  push:
  schedule:
  # 定时任务，在每天的5点推送天气信息到邮箱
    - cron: '00 2,4,12 * * *'

  pull_request:
    branches: [ "main" ]

  # Allows you to run this workflow manually from the Actions tab
  workflow_dispatch:

# A workflow run is made up of one or more jobs that can run sequentially or in parallel
jobs:
  # This workflow contains a single job called "build"
  build:
    # The type of runner that the job will run on
    runs-on: ubuntu-latest

    # Steps represent a sequence of tasks that will be executed as part of the job
    steps:
      # Checks-out your repository under $GITHUB_WORKSPACE, so your job can access it
      - uses: actions/checkout@v3

      # Runs a single command using the runners shell
      - name: install package
        run: |
             pip install wechatpy
             pip install requests

      - name: Run a one-line script
        run: python main.py

      # Runs a set of commands using the runners shell
      - name: Run a multi-line script
        run: |
          echo Add other actions to build,
          echo test, and deploy your project.

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45