黑松山资源网 Design By www.paidiu.com
因为生活中老是忘记各种事情,刚好又在学python,便突发奇想通过python实现提醒任务的功能(尽管TIM有定时功能),也可定时给好友、群、讨论组发送qq消息。其工作流程是:访问数据库提取最近计划——>根据数据内容(提醒时间、提醒对象、提醒内容)设置定时任务——>给特定qq好友发送消息。
1. 软件版本:
2.安装依赖环境
- pymysql安装:pip install pymysql
- qqbot安装:pip install qqbot
3.数据库操作
数据库操作非常简单,跟Java类似,自己去菜鸟教程看一下基础语法就好了。
#coding: utf-8 import 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
配置文件默认在用户目录下的.qqbot-tmp/v2.3.conf,linux下类似
{ # 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. 自定义功能
from qqbot import _bot as bot #登陆qq,使用配置文件为fantasy bot.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.入口主程序
#coding: utf-8 import time import sched import datetime from 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.其它
数据库结构:
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消息的代码,以下是项目目录结构,其中一些没有出现的文件是自己测试所用,可以不用关心:
效果图:
总结:基本功能完成了,但是操作不够友好,需要手动往数据库录入数据,之后准备做一个数据管理的前端配合使用,可以简化很多操作。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
黑松山资源网 Design By www.paidiu.com
广告合作:本站广告合作请联系QQ:858582 申请时备注:广告合作(否则不回)
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
黑松山资源网 Design By www.paidiu.com
暂无评论...
更新日志
2024年10月07日
2024年10月07日
- 群星.1991-音乐工厂1·皇后大道东【音乐工厂】【WAV+CUE】
- 群星.1992-音乐工厂2·首都【音乐工厂】【WAV+CUE】
- 群星.1994-音乐工厂3·儿童乐园【音乐工厂】【WAV+CUE】
- 胡鸿钧.2021-ex:CHANGE【星梦娱乐】【WAV+CUE】
- 班得瑞原装进口《第一张新世纪专辑:仙境》1CD[APE/CUE分轨][292.3MB]
- 伍佰《摇滚教父 伍佰黄金精选 2CD》[WAV+CUE][990MB]
- 班得瑞原装进口《第二张新世纪专辑:寂静山林》1CD[APE/CUE分轨][327.1MB]
- Beyond.1989-真的见证(2024环球MQA-UHQCD限量版)【环球】【WAV+CUE】
- 陈怡婷.2024-予你的心谁来赔【福茂】【FLAC分轨】
- 陈冠希.2003-HITS.OR.MISSES【英皇娱乐】【WAV+CUE】
- 班得瑞原装进口《第三张新世纪专辑:春野》1CD[APE/CUE分轨][278.9MB]
- 班得瑞原装进口《第四张新世纪专辑:蓝色天际》1CD[APE/CUE分轨][284.8MB]
- 班得瑞原装进口《第五张新世纪专辑:迷雾森林+EP》1CD[APE/CUE分轨][334.2MB]
- 田震.1997-顺其自然(日版)【红星生产社】【WAV+CUE】
- 小虫.1996-想得太美【滚石】【WAV+CUE】