因为生活中老是忘记各种事情，刚好又在学python，便突发奇想通过python实现提醒任务的功能（尽管tim有定时功能），也可定时给好友、群、讨论组发送qq消息。其工作流程是：访问数据库提取最近计划——>根据数据内容（提醒时间、提醒对象、提醒内容）设置定时任务——>给特定qq好友发送消息。
1. 软件版本：
2.安装依赖环境
- pymysql安装：pip install pymysql
- qqbot安装：pip install qqbot
3.数据库操作
数据库操作非常简单，跟java类似，自己去菜鸟教程看一下基础语法就好了。
|
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
|
#coding: utf-8import pymysql #导入pymysql模块db = pymysql.connect("localhost","root","root","info_db" ) #数据库链接信息cursor = db.cursor()#插入任务def insertschedule(schedule): insertsql = "insert into dutyschedule_tb(worktime,name) values(%s,%s)" try: #这种查询语句可以防止sql注入 cursor.execute(insertsql,(schedule['worktime'],schedule['name'])) db.commit() except exception: db.rollback() raise exception#删除任务def deleteschedule(): deletesql = "" try: cursor.execute(deletesql) db.commit() except exception: db.rollback()def updateschedule(user): updatesql = "" try: cursor.execute(updatesql) db.commit() except exception: db.rollback()#获取下一个任务def findschedulebynewtime(): selectsql = "select * from dutyschedule_tb where now() <= date_format(worktime,'%y-%m-%d %h:%i:%s') order by worktime asc;" try: cursor.execute(selectsql) results = cursor.fetchone() schedule = {} schedule['worktime'] = results[1] schedule['name'] = results[2] schedule['content'] = results[3] return schedule except exception: return none |
4.配置qqbot登陆信息
也可以不配置，不配置的话就是每次扫码登陆，但这在linux系统下不好用，我按说明将配置改成了每次将登陆二维码发到固定qq邮箱。qqbot模块在github上，大家可以去看一下模块说明：
配置文件默认在用户目录下的.qqbot-tmp/v2.3.conf，linux下类似
|
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
|
{ # qqbot 的配置文件 # 使用 qqbot -u somebody 启动程序时，依次加载： # 根配置 -> 默认配置 -> 用户 somebody 的配置 -> 命令行参数配置 # 使用 qqbot 启动程序时，依次加载： # 根配置 -> 默认配置 -> 命令行参数配置 "fantasy" : { # 这是自己创建的用户自定义配置，可以在启动qqbot启动时选择加载哪个配置文件 # qqbot-term （http-api） 服务器端口号（该服务器监听 ip 为 127.0.0.1 ） # 设置为 0 则不会开启本服务器（此时 qq 命令和 http-api 接口都无法使用）。 "termserverport" : 8188, # 二维码 http 服务器 ip，请设置为公网 ip 或空字符串 "httpserverip" : "", # 二维码 http 服务器端口号 "httpserverport" : 8189, # 自动登录的 qq 号 "qq" : "你的qq", # 接收二维码图片的邮箱账号 "mailaccount" : "你的邮箱", # 该邮箱的 imap/smtp 服务授权码，一般在邮箱设置中有 "mailauthcode" : "你的授权码", # 是否以文本模式显示二维码 "cmdqrcode" : false, # 显示/关闭调试信息 "debug" : false, # qqbot 掉线后自动重启 "restartonoffline" : true, # 在后台运行 qqbot ( daemon 模式) "daemon": false, # 完成全部联系人列表获取之后才启动 qqbot "startafterfetch" : false, # 插件目录 "pluginpath" : ".", # 启动时需加载的插件 "plugins" : [], # 插件的配置（由用户自定义） "pluginsconf" : {}, }, # 用户 somebody 的配置，这是默认配置 "somebody" : { #这里的基本内容跟上面一样，就不贴出来了，太长了占地方 }, # 可以在 默认配置 中配置所有用户都通用的设置 "默认配置" : { "qq" : "", "pluginpath" : "", "plugins" : [ 'qqbot.plugins.sampleslots', 'qqbot.plugins.schedrestart', ], "pluginsconf" : { 'qqbot.plugins.schedrestart': '8:00', } }, # # 注意：根配置是固定的，用户无法修改（在本文件中修改根配置不会生效） # "根配置" : { # "termserverport" : 8188, # "httpserverip" : "", # "httpserverport" : 8189, # "qq" : "", # "mailaccount" : "", # "mailauthcode" : "", # "cmdqrcode" : false, # "debug" : false, # "restartonoffline" : false, # "daemon" : false, # "startafterfetch" : false, # "pluginpath" : "", # "plugins" : [], # "pluginsconf" : {} # },} |
5. 自定义功能
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
|
from qqbot import _bot as bot#登陆qq，使用配置文件为fantasybot.login(['-u','fantasy'])#自定义函数，用来进一步封装qqbot接口#获取所有好友列表def getbuddybyname(nickname): return bot.list('buddy',nickname)#获取所有群列表def getgroupbyname(groupname): return bot.list('group',groupname)#给备注（没用备注就是昵称）为nickname的好友发送content消息def sendtonickname(nickname,content): user = getbuddybyname(nickname) if user: bot.sendto(user[0],content) else: print("未找到联系人："+nickname) |
6.入口主程序
|
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
|
#coding: utf-8import timeimport schedimport datetimefrom dao.dutyscheduledao import *from utils.qqinterface import *#sched是python的定时任务模块schedule = sched.scheduler(time.time, time.sleep)#从数据库获取第一个任务newschedule = findschedulebynewtime()#返回距下次任务还有多少秒def getseconds(): #申明全局变量 global newschedule newschedule = findschedulebynewtime() if newschedule: return (newschedule['worktime'] - datetime.datetime.now()).total_seconds() else: print("所有任务执行完毕，退出程序……") exit()#发消息函数def sendto(): global newschedule sendtonickname(newschedule['name'],newschedule['content'])#中间函数，用于循环运行所有数据库未执行事件def perform(): sendto() #睡眠5秒，不然可能会重复发送消息 time.sleep(5) sleepsecond = getseconds() print("下次任务执行时间："+str(newschedule['worktime'])) #这次任务执行完后添加新任务 schedule.enter(sleepsecond,1,perform,())def run(): #1.获取数据库最近将执行任务的时间及姓名 #2.计算执行任务的时间与现在时间的差值（单位：秒） sleepsecond = getseconds() print("下次通知："+str(newschedule['worktime'])) #3.加入定时处理函数 schedule.enter(sleepsecond,1,perform,()) #4.执行定时任务 schedule.run()if __name__ == '__main__': run() |
7.其它
数据库结构：
|
1
2
3
4
5
6
7
8
9
10
|
drop database if exists info_db;create database info_db default character set utf8;use info_db;create table dutyschedule_tb( id int(11) auto_increment primary key, worktime timestamp not null, name varchar(10) not null, content varchar(100) not null)engine=innodb auto_increment=1 default charset=utf8; |
以上就是循环发送qq消息的代码，以下是项目目录结构，其中一些没有出现的文件是自己测试所用，可以不用关心：
效果图：
总结：基本功能完成了，但是操作不够友好，需要手动往数据库录入数据，之后准备做一个数据管理的前端配合使用，可以简化很多操作。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持服务器之家。
原文链接：https://blog.csdn.net/cx776474961/article/details/82755767
