itchat_qty.py的源码

zhgc

1. #coding=utf8
   
2. import MySQLdb,itchat,time,importlib,sys,threading
   
3. from threading import Timer
   
4. #reload(sys)
   
5. importlib.reload(sys)
   
6. #sys.setdefaultencoding('utf8')
   
7. 
   
8. db_config = {
   
9.   'host': '192.168.2.10',
   
10.   'user': 'root',
    
11.   'passwd': 'xxxxx',
    
12.   'db': 'crc',
    
13.   'charset': 'utf8'
    
14. }
    
15. 
    
16. db1=MySQLdb.connect(**db_config)
    
17. 
    
18. db2=MySQLdb.connect(**db_config)
    
19. 
    
20. db3=MySQLdb.connect(**db_config)
    
21. 
    
22. #db.ping(True)
    
23. 
    
24. itchat.auto_login(hotReload=True)
    
25. users = itchat.search_chatrooms(name='凤天办公室')
    
26. username=users[0]['UserName']
    
27. 
    
28. # 这里是我们在“1. 实现微信消息的获取”中已经用到过的同样的注册方法,isGroupChat=True
    
29. @itchat.msg_register(itchat.content.TEXT,isGroupChat=True)
    
30. 
    
31. #实时回复任务
    
32. def reply(msg):
    
33.     if(msg.isAt):
    
34.         try:
    
35.             db1.ping()
    
36.         except MySQLdb.Error as e:
    
37.             #这是防止db连接离线 报错为(2006, 'MySQL server has gone away')
    
38.             if (e and (e.args[0]==2006 or e.args[0]==2013 )):
    
39.                 db1.ping(True)
    
40.                 #print 'ping(true) connect'
    
41.             else:
    
42.                 #print "timer_MySQL Error :  %s" % e
    
43.                 print("e")
    
44.         try:
    
45.             cursor1 = db1.cursor()
    
46.             rooms=msg['User']['NickName']
    
47.             fromuser_name=msg['ActualNickName']
    
48.             mess=msg['Text']
    
49.             to_rooms_id = msg['User']['UserName']
    
50.             x='@x'
    
51.             cursor1.callproc('CRC_IN',(rooms,fromuser_name,mess,x))
    
52.             data1= cursor1.fetchone()
    
53.             mo_data=data1[0]
    
54.             mess_data ="来自群[%s]\r发送人[%s]\r消息内容:%s \r回复消息:%s"%(rooms,fromuser_name,mess,mo_data)
    
55.             print(mess_data)
    
56.             #回复群消息
    
57.             itchat.send(msg=mo_data, toUserName=to_rooms_id)
    
58.             #转发群消息至工作群
    
59.             itchat.send(msg=mess_data, toUserName=username)
    
60.             cursor1.close()
    
61.             db1.commit()
    
62.         except MySQLdb.Error as e:
    
63.             print("itchat_rooms_MySQL Error :  %s" % e)
    
64.             #itchat.send(msg="MySQL Error %d:  %s" % ( e.args[0], e.args[1] ), toUserName=username)
    
65.             #itchat.auto_login(hotReload=True)
    
66.             #users = itchat.search_chatrooms(name='凤天办公室')
    
67.             #username=users[0]['UserName']
    
68. 
    
69. #线程定时器执行函数
    
70. def auto_run():
    
71.     try:
    
72.         db2.ping()
    
73.     except MySQLdb.Error as e:
    
74.         if (e and (e.args[0]==2006 or e.args[0]==2013 )):
    
75.             db2.ping(True)
    
76.         else:
    
77.             print("timer_MySQL Error :  %s" % e)
    
78.     try:
    
79.             cursor2=db2.cursor()
    
80.             cursor2.execute("SELECT now()")
    
81.             data ="DB时间:%s" %cursor2.fetchone()
    
82.             cursor2.close()
    
83.             itchat.send(msg=data, toUserName=None)
    
84.             itchat.send(msg=data, toUserName=username)
    
85.             print('这次定时已经跑完 mess:%s'%data)
    
86.             t = Timer(28800, auto_run)
    
87.             t.start()
    
88.             db2.commit()
    
89.     except MySQLdb.Error as e:
    
90.         if (e and (e.args[0]==2006 or e.args[0]==2013 )):
    
91.             db2.ping(True)
    
92.         else:
    
93.             print("timer_MySQL Error :  %s" % e)   
    
94.         #itchat.auto_login(hotReload=True)
    
95.         #users = itchat.search_chatrooms(name='凤天办公室')
    
96.         #username=users[0]['UserName']
    
97. 
    
98. #线程循环查看系统有无信息需要回复
    
99. def thread_run():
    
100.     cursor3 = db3.cursor()  
     
101.     sql = "SELECT mess_id,chatrooms,fromusername,out_mess FROM r_message WHERE UPPER(send_flag) ='N' AND UPPER(EVENT)='Y' AND  out_mess IS NOT NULL"     
     
102.     while(True):
     
103.         try:
     
104.             #ab=time.strftime('%Y-%m-%d %H:%M:%S',time.localtime(time.time()))
     
105.             time.sleep(2)
     
106.             cursor3.execute(sql)
     
107.             # 获取所有记录列表
     
108.             results = cursor3.fetchall()
     
109.             #print 'count:',len(results)
     
110.             for row in results:
     
111.                 back_mess="任务已经处理\r\n任务单号:%s\r\n创建人员:%s\r\n回复信息:%s" % \
     
112.                       (row[0],row[2],row[3])
     
113.                 users_id1 = itchat.search_chatrooms(name=row[1])
     
114.                 usergroupname1=users_id1[0]['UserName']
     
115.                 itchat.send(msg=back_mess, toUserName=usergroupname1)
     
116.                 #转发群消息至工作群
     
117.                 itchat.send(msg=back_mess, toUserName=username)
     
118.                 print(back_mess)
     
119.                 sql_up="UPDATE r_message SET send_flag='Y',out_time=now() WHERE mess_id='%s'" % row[0]
     
120.                 cursor3.execute(sql_up)
     
121.                 db3.commit()
     
122.             db3.commit()
     
123.         except MySQLdb.Error as e:
     
124.             if (e and (e.args[0]==2006 or e.args[0]==2013 )):
     
125.                 db3.ping(True)
     
126.             else:
     
127.                 print("timer_MySQL Error :  %s" %e)
     
128.             #itchat.auto_login(hotReload=True)
     
129.             #users = itchat.search_chatrooms(name='凤天办公室')
     
130.              #username=users[0]['UserName']
     
131.     cursor3.close()
     
132. if __name__ == "__main__":
     
133.     ab=time.strftime('%Y-%m-%d %H:%M:%S',time.localtime(time.time()))
     
134.     print("start_time:",ab)
     
135. 
     
136.     auto_run()
     
137. 
     
138.     t =threading.Thread(target=thread_run)
     
139.     t.setDaemon(True)#设置线程为后台线程
     
140.     t.start()
     
141. 
     
142.     itchat.send(msg=ab, toUserName=None)
     
143.     itchat.run()
     
144. #db.close()
     

复制代码

zhgc

全飞鸿CRC系统v3版 2019-12-02
用时间比较长的版本