python实现定时发送qq消息

程序员文章站 2023-11-30 22:21:40

因为生活中老是忘记各种事情，刚好又在学python，便突发奇想通过python实现提醒任务的功能（尽管tim有定时功能），也可定时给好友、群、讨论组发送qq消息。其工作流程...

因为生活中老是忘记各种事情，刚好又在学python，便突发奇想通过python实现提醒任务的功能（尽管tim有定时功能），也可定时给好友、群、讨论组发送qq消息。其工作流程是：访问数据库提取最近计划——>根据数据内容（提醒时间、提醒对象、提醒内容）设置定时任务——>给特定qq好友发送消息。

1. 软件版本：

python实现定时发送qq消息

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-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消息的代码，以下是项目目录结构，其中一些没有出现的文件是自己测试所用，可以不用关心：

python实现定时发送qq消息