我们从Python开源项目中，提取了以下43个代码示例，用于说明如何使用itchat.send()。
def testcase1(): id='@5493580a22c9ba5db849ba33d0911d3d' content=datetime.datetime.now().strftime("%H:%M:%S") itchat.auto_login(hotReload=True) #itchat.auto_login() itchat.send(content,toUserName='filehelper') account=itchat.get_friends(u'wwwei') print account print type(account) for i in account: #print type(i) #print i if i[u'PYQuanPin']==u'????': print i['UserName'] #print i #itchat.send(content, toUserName=id) print 'done'
def text_reply(msg): #logger.info(json.dumps(msg).decode("unicode_escape")) if msg['isAt'] and myRobot.groupOnline: match = re.match("@\S+\s+?(.*)",msg['Content'],re.U) temp = match.group(1) if match else msg['Content'] logger.info(temp) reply = tuLing.reply(temp,msg["FromUserName"]) logger.info(u"%s group %s msg :[%s],reply:[%s]",msg["User"].get("NickName"),msg['ActualNickName'],msg["Text"],reply) itchat.send(u'@%s\u2005 ??: %s' % (msg['ActualNickName'], reply), msg['FromUserName'])
def stock(): time = datetime.datetime.now() # ?????? now = time.strftime('%H:%M:%S') data = ts.get_realtime_quotes(stock_symbol) # ?????? r1 = float(data['price']) r2 = str(stock_symbol) + ' ?????? ' + str(r1) content = now + '\n' + r2 itchat.send(content, toUserName='filehelper') print(content) # ????????????? if r1 <= float(price_low): itchat.send('????????', toUserName='filehelper') print('????????') elif r1 >= float(price_high): itchat.send('????????', toUserName='filehelper') print('????????') else: itchat.send('????', toUserName='filehelper') print('????') # ? 3 ?????
def stock(): time = datetime.datetime.now() # ?????? now = time.strftime('%H:%M:%S') data = ts.get_realtime_quotes(stock_symbol) # ?????? r1 = float(data['price']) r2 = str(stock_symbol) + ' ?????? ' + str(r1) content = now + '\n' + r2 itchat.send(content, toUserName='filehelper') print(content) # ????????????? if r1 <= float(price_low): itchat.send('????????', toUserName='filehelper') print('????????') elif r1 >= float(price_high): itchat.send('????????', toUserName='filehelper') print('????????') else: itchat.send('????', toUserName='filehelper') print('????') # ?????????
def process(self, msg, type): if type != TEXT: return groupName = msg['User']['NickName'] if any([ re.search(x, groupName) is not None for x in self.blacklist ]): return if re.search('^/', msg['Content']): return if self.isFromSelf(msg): # Stop processing if the message is from myself return self.updateGroupContentCache(msg, groupName) contentToPaiDui = list(self.WhatToPaiDui(groupName)) if len(contentToPaiDui) > 1: logging.error('Multiple duis detected.') if len(contentToPaiDui) != 0: # Pai dui! itchat.send(msg['Content'], msg['FromUserName']) logging.info('Pai Dui! {0}.'.format(msg['Content'])) # Update data structure to avoid Pai dui for multiple times. self.updateGroupContentCache({ 'Content': msg['Content'], 'FromSelf': True }, groupName)
def ch_reply(msg): chcont=msg['Content'] if chcont.find('<revokemsg><')>0: loc1=chcont.find('</oldmsgid><msgid>')+18 loc2=chcont.find('</msgid><replacemsg><![CDATA') messageid=chcont[loc1:loc2] print(messageid) try:#friend chat only oritun=IDandTUN[str(messageid)] orifun=IDandFUN[str(messageid)] fname=itchat.search_friends(userName=orifun) ##print(fname) itchat.send("[Autoreply] The message revoked by '"+fname['NickName']+"' just now is :"+IDandMESSAGE[messageid],oritun) itchat.send("[Autoreply] The message revoked by '"+fname['NickName']+"' just now is :"+IDandMESSAGE[messageid],orifun) except: print("-----Can't find original msg") #############----->Group Chat<-----#############
def group_reply(msg): if msg['isAt']: reply = talk(msg['Content'], md5(msg['ActualUserName'])) print( '------------------------------------------------------------------------------') print('%s????????%s' % (msg['ActualNickName'], msg['Content'].replace('\u2005',' '))) print('AI????%s?%s' % (msg['ActualNickName'], reply)) print( '------------------------------------------------------------------------------') itchat.send('@%s %s' % (msg['ActualNickName'], reply), msg['FromUserName']) else: print( '------------------------------------------------------------------------------') print('%s??????%s' % (msg['ActualNickName'], msg['Content'])) print( '------------------------------------------------------------------------------')
def handle_music_msg(text): menu = Music.get_menu(text) if not menu: itchat.send(u'??????', 'filehelper') ids = [menu['id']] url = Music.get_url(ids) if not url: itchat.send(u'????????', 'filehelper') name = '%s-%s' % (menu['name'], menu['singer']) msg = DownLoad.down(url, name) itchat.send(msg, 'filehelper') os.startfile('%s\music\%s' % (os.getcwd(), name + ".mp3")) itchat.send(u'????', 'filehelper') # ??????
def music_player(msg): if msg['ToUserName'] != 'filehelper': return if msg['Text'] == u'??': itchat.send(u'??macbook????', 'filehelper') if msg['Text'] == u'??': itchat.send(u'????', 'filehelper') else: itchat.send(u'????????', 'filehelper') #itchat.send(interact_select_song(msg['Text']), 'filehelper')
def text_reply(msg): match = re.search(u'?', msg['Text']).span() if match: itchat.send((u'??????????'), msg['FromUserName'])
def other_reply(msg): itchat.send((u'??????????'), msg['FromUserName'])
def send_messages_in_queue(self): while(True): (username, message) = self.send_msg_queue.get() itchat.send(message, toUserName = username) time.sleep(0.5)
def search_iphone(): # ??????????????????????? buyers_info = get_buyers_info() availability = r.get(current_config['IPHONE_MODELS_URL']).json() if availability['stores']: # ????????????????? for store, models in buyers_info.items(): # ???????????????? for model_number, buyers in models.items(): # ???????????? stock = availability['stores'][store][model_number] if stock['availability']['unlocked'] is True: for buyer in buyers: if cache.get(buyer['idcard']) is None: buyer['store'] = store with rabbit as mq: mq.send_message(exchange_name='iphone', queue_name='buyers', messages=buyer) # ??????????? msg = '[??] ??????????????{0}? ???{1}????{2}'.format(get_store_name(store), get_model_name(model_number), datetime.now()) logging.info(msg) logging.info('?????{}'.format(buyer)) logging.info('[??] ????????????????') itchat.send(msg, toUserName=wechat_user_name) # ????????????5??????? cache.set(key=buyer['idcard'], val='???', time=300) else: logging.info('[??] ????????')
def send_wechat(self,name,content,user): w_content=name+' '+content itchat.send(w_content,toUserName=user) time.sleep(1) itchat.send(w_content,toUserName='filehelper')
def warming(self, coin, up_price, down_price,user): url = 'https://www.jubi.com/api/v1/ticker/' while 1: time.sleep(5) try: data = requests.post(url, data={'coin': coin}).json() except Exception,e: print e print "time out. Retry" time.sleep(15) continue current = float(data['last']) if current >= up_price: print "Up to ", up_price print "current price ",current if self.send=='msn': self.send_text(coin,str(current)) if self.send=='wechat': self.send_wechat(coin,str(current),user) time.sleep(1200) if current <= down_price: print "Down to ", down_price print "current price ",current if self.send=='msn': self.send_text(coin,str(current)) if self.send=='wechat': self.send_wechat(coin,str(current),user) time.sleep(1200) #????????????
def push_wechat(name, real_price, real_percent, type): name=u'wwwei' itchat.auto_login(hotReload=True) account=itchat.get_friends(name) for i in account: if i[u'PYQuanPin']==name: toName=i['UserName'] content=name+' ' + str(real_price)+' '+ str(real_percent)+' percent '+ type itchat.send(content,toUserName=toName)
def text_reply(msg): # cont = alice.respond(msg['Text']) cont = requests.get('http://www.tuling123.com/openapi/api?key=?????&info=%s' % msg['Content']).content m = json.loads(cont) itchat.send(m['text'], msg['FromUserName']) if m['code'] == 200000: itchat.send(m['url'], msg['FromUserName']) if m['code'] == 302000: itchat.send(m['list'], msg['FromUserName']) if m['code'] == 308000: itchat.send(m['list'], msg['FromUserName'])
def snap(msg, toUserName, delay=5): res = itchat.send(msg=msg, toUserName=toUserName) msgID = res['MsgID'] time.sleep(delay) revoke_res = itchat.revoke(msgID, toUserName) print(revoke_res)
def send_msg(msg='Test Message', to_user_name=None): ''' send plain text message for options - msg: should be unicode if there's non-ascii words in msg - to_user_name: 'user_name' key of friend dict it is defined in components/messages.py ''' return itchat.send_msg(msg, to_user_name)
def send_file(file_dir, to_user_name=None, media_id=None): ''' send attachment for options - file_dir: dir for file ready for upload - media_id: media_id for file. - if set, file will not be uploaded twice - to_user_name: 'user_name' key of friend dict it is defined in components/messages.py ''' return itchat.send_file(file_dir, to_user_name)
def send_image(file_dir, to_user_name=None, media_id=None): ''' send image for options - file_dir: dir for file ready for upload - if it's a gif, name it like 'xx.gif' - media_id: media_id for file. - if set, file will not be uploaded twice - to_user_name: 'user_name' key of friend dict it is defined in components/messages.py ''' return itchat.send_image(file_dir, to_user_name, media_id)
def send_video(file_dir=None, to_user_name=None, media_id=None): ''' send video for options - file_dir: dir for file ready for upload - if media_id is set, it's unnecessary to set file_dir - media_id: media_id for file. - if set, file will not be uploaded twice - to_user_name: 'user_name' key of friend dict it is defined in components/messages.py ''' return itchat.send_video(file_dir, to_user_name)
def send_text(text): #send text msgs to 'filehelper' #??????????? try: itchat.send_msg(msg=text,toUserName='filehelper') return except (ConnectionError,NotImplementedError,KeyError): traceback.print_exc() print('\nConection error,failed to send the message!\n') return else: return
def send_img(filename): #send text imgs to 'filehelper' #??????? try: itchat.send_image(filename,toUserName='filehelper') return except (ConnectionError,NotImplementedError,KeyError): traceback.print_exc() print('\nConection error,failed to send the figure!\n') return else: return #============================================================================== # #==============================================================================
def t_send(self,msg,toUserName='filehelper'): try: itchat.send_msg(msg=msg,toUserName=toUserName) return except (ConnectionError,NotImplementedError,KeyError): traceback.print_exc() print('\nConection error,failed to send the message!\n') return else: return
def t_send_img(self,filename,toUserName='filehelper'): try: itchat.send_image(filename,toUserName=toUserName) return except (ConnectionError,NotImplementedError,KeyError): traceback.print_exc() print('\nConection error,failed to send the figure!\n') return else: return
def on_epoch_end(self, epoch, logs=None): for k in self.params['metrics']: if k in logs: self.mesg+=(k+': '+str(logs[k])[:5]+' ') self.logs_epochs.setdefault(k, []).append(logs[k]) #============================================================================== # except: # itchat.auto_login(hotReload=True,enableCmdQR=True) # itchat.dump_login_status() # self.t_send(self.mesg, toUserName='filehelper') #============================================================================== if epoch+1>=self.stopped_epoch: self.model.stop_training = True logs = logs or {} self.epoch.append(epoch) self.t_epochs.append(time.time()-self.t_s) if self.savelog: sio.savemat((self.fexten if self.fexten else self.validateTitle(self.localtime))+'_logs_batches'+'.mat',{'log':np.array(self.logs_batches)}) sio.savemat((self.fexten if self.fexten else self.validateTitle(self.localtime))+'_logs_epochs'+'.mat',{'log':np.array(self.logs_epochs)}) th.start_new_thread(self.get_fig,()) #============================================================================== # try: # itchat.send(self.mesg, toUserName='filehelper') # except: # traceback.print_exc() # return #============================================================================== self.t_send(self.mesg, toUserName='filehelper') return #============================================================================== # #==============================================================================
def group_reply_text(msg): source = msg['FromUserName'] if msg['Content'] == 'Hi': groups[source] = source else: if source in groups: for item in groups.keys(): if not item == source: itchat.send(' %s say:\n%s' % (msg['ActualNickName'], msg['Content']), item)
def download_png(msg): source = msg['FromUserName'] msg['Text'](msg['FileName']) itchat.send(msg['FileName'], source)
def __init__(self, send='wechat'): cfg = Toolkit.getUserData('data.cfg') self.public_key = cfg['public_key'] self.private_key = cfg['private_key'] self.send=send from_mail = cfg['from_mail'] password = cfg['password'] to_mail = cfg['to_mail'] smtp_server = 'smtp.qq.com' self.server = smtp_server self.username = from_mail.split("@")[0] self.from_mail = from_mail self.password = password self.to_mail = to_mail self.coin_list=['IFC','DOGE','EAC','DNC','MET','ZET','SKT','YTC','PLC','LKC', 'JBC','MRYC','GOOC','QEC','PEB','XRP','NXT','WDC','MAX','ZCC', 'HLB','RSS','PGC','RIO','XAS','TFC','BLK','FZ','ANS','XPM','VTC', 'KTC','VRC','XSGS','LSK','PPC','ETC','GAME','LTC','ETH','BTC'] # ??????????????? # ???????? if self.send == 'msn': try: self.smtp = smtplib.SMTP_SSL(port=465) self.smtp.connect(self.server) self.smtp.login(self.username, self.password) except smtplib.SMTPException, e: print e return 0 if send=='wechat': self.w_name=u'wwwei' #self.w_name1=u'wwwei' itchat.auto_login(hotReload=True) account=itchat.get_friends(self.w_name) for i in account: if i[u'PYQuanPin']==self.w_name: self.toName= i['UserName'] #print self.toName
def send_wechat(self,name,content): w_content=name+' '+content itchat.send(w_content,toUserName=self.toName) time.sleep(1) itchat.send(w_content,toUserName='filehelper')
def warming(self, coin, up_price, down_price): url = 'https://www.jubi.com/api/v1/ticker/' while 1: time.sleep(5) try: data = requests.post(url, data={'coin': coin}).json() except Exception,e: print e print "time out. Retry" time.sleep(15) continue current = float(data['last']) if current >= up_price: print "Up to ", up_price print "current price ",current if self.send=='msn': self.send_text(coin,str(current)) if self.send=='wechat': self.send_wechat(coin,str(current)) time.sleep(1200) if current <= down_price: print "Down to ", down_price print "current price ",current if self.send=='msn': self.send_text(coin,str(current)) if self.send=='wechat': self.send_wechat(coin,str(current)) time.sleep(1200) #????????????
def main(): #???? itchat.auto_login(hotReload=True) user_content = itchat.search_friends(name=u'????') userName = user_content[0]['UserName'] itchat.send(getWeather(101230201),toUserName = userName)#?? itchat.send(getWeather(101010100),toUserName = userName)#??
def DoutuEnd(destinationChatroomId): sleep(DoutuProcessor.doutuTimeInterval) itchat.send('???? ?????', destinationChatroomId)
def process(self, msg, type): if not self.isInitialized: logging.error('The forwarder was not properly initialized. Please send a message in the groups you want to connect and try again.') return shallSendObj = self.shallSend(msg) if not shallSendObj['shallSend']: return if type == TEXT: fromText = '[{0}]'.format(self.chatroomDisplayNames[shallSendObj['fromChatroom']]) destinationChatroomId = self.chatroomIds[not shallSendObj['fromChatroom']] content = '{0} {1}: {2}'.format(fromText, msg['ActualNickName'], msg['Content']) logging.info(content) itchat.send(content, destinationChatroomId) elif type == PICTURE: fn = msg['FileName'] newfn = os.path.join(self.fileFolder, fn) msg['Text'](fn) os.rename(fn, newfn) type = {'Picture': 'img', 'Video': 'vid'}.get(msg['Type'], 'fil') typeText = {'Picture': '??', 'Video': '??'}.get(msg['Type'], '??') fromText = '[{0}]'.format(self.chatroomDisplayNames[shallSendObj['fromChatroom']]) destinationChatroomId = self.chatroomIds[not shallSendObj['fromChatroom']] content = '{0} {1} ???{2}:'.format(fromText, self.nickNameLookup.lookupNickName(msg), typeText) itchat.send(content, destinationChatroomId) logging.info(content) itchat.send('@{0}@{1}'.format(type, newfn), destinationChatroomId) elif type == SHARING: fromText = '[{0}]'.format(self.chatroomDisplayNames[shallSendObj['fromChatroom']]) destinationChatroomId = self.chatroomIds[not shallSendObj['fromChatroom']] content = '{0} {1} ?????: {2} {3}'.format(fromText, self.nickNameLookup.lookupNickName(msg), msg['Text'], msg['Url']) logging.info(content) itchat.send(content, destinationChatroomId) else: logging.info('Unknown type encoutered.') pass
def process(self, msg, type): if type != TEXT: return groupName = msg['User']['NickName'] toSend = None if any([ re.search(x, groupName) is not None for x in self.blacklist ]): return if re.search(self.forceTriggerText, msg['Content']): currentTime = time() gaNextTime = self.forceTriggerNextTimestamp.get(groupName, 0) if currentTime < gaNextTime: logging.info("Don't force Ga because time {0} < NextTime {1} for group {2}.".format(currentTime, gaNextTime, groupName)) return; self.forceTriggerNextTimestamp[groupName] = currentTime + self.forceTriggerInterval toSend = self.forceTriggerGaText logging.info('{0} => {1}'.format(msg['Content'], toSend)) itchat.send(toSend, msg['FromUserName']) return if re.search(self.triggerText, msg['Content']): # Check the ga time if groupName not in GaTextHook.gaNumDict: GaTextHook.gaNumDict[groupName] = 0 GaTextHook.gaNumDict[groupName] += 1 self.gaColl.update({'GroupName': groupName}, {'$set': { 'CurrentGaNum': GaTextHook.gaNumDict[groupName] } }, upsert=True) if GaTextHook.gaNumDict[groupName] > self.gaNumMax: logging.info("Don't Ga because GaNum {0} exceeds max {1} for group {2}.".format(GaTextHook.gaNumDict[groupName], self.gaNumMax, groupName)) return toSend = '{0} x{1}'.format(self.gaText, GaTextHook.gaNumDict[groupName]) logging.info('{0} => {1}'.format(msg['Content'], toSend)) itchat.send(toSend, msg['FromUserName'])
def music_player(msg): if msg['ToUserName'] != 'filehelper': return if msg['Text'] == u'??': close_music() itchat.send(u'?????', 'filehelper') if msg['Text'] == u'??': itchat.send(HELP_MSG, 'filehelper') else: itchat.send(interact_select_song(msg['Text']), 'filehelper')
def wait_active(seconds,msg): global user_step time.sleep(seconds) user_step[msg['FromUserName']] /= 1000 #??????? back_re=random.randint(1,3) #????????? if back_re == 1: backword=u'???' if back_re == 2: backword=u'????' if back_re == 3: backword=u'?' itchat.send(backword, toUserName=msg['FromUserName']) return
def delay_reply(delay_time,words,msg): time.sleep(delay_time) itchat.send(words, toUserName=msg['FromUserName']) return ######################?????########################
def chgr_reply(msg): #print(msg) chcont=msg['Content'] if chcont.find('revokemsg')>0: loc1=max(chcont.find('/oldmsgid><msgid>')+26,chcont.find('</oldmsgid><msgid>')+18) loc2=max(chcont.find('</msgid><replacemsg><![CDATA'),chcont.find('</msgid><replacemsg><![CDATA')) messageid=chcont[loc1:loc2] print(messageid) chtext=msg['Text'] print(chtext) chlen=len(chtext) aname=chtext[:chlen-7] try: oritun=IDandTUN[str(messageid)] orifun=IDandFUN[str(messageid)] except: print('dont chehui twice') if (oritun==myusrname or orifun==myusrname)and (chtext.find('You')>0 or chtext.find('?')>0) or chtext=="You've recalled a message.": aname='myself' else: aname=aname + '[not me]' try: itchat.send("[Autoreply] The message revoked by '"+aname+"' just now is :"+IDandMESSAGE[str(messageid)],oritun) itchat.send("[Autoreply] The message revoked by '"+aname+"' just now is :"+IDandMESSAGE[str(messageid)],orifun) except: print("-----Can't find original msg")
def tick(): users = itchat.search_friends(name=u'xxx') # ????????? userName = users[0]['UserName'] meetDate = dt.date(2015,9,29) # ????????????? now = dt.datetime.now() # ????? nowDate = dt.date.today() # ????? passDates = (nowDate-meetDate).days # ??????????? itchat.send(u'????????%d??%s,??'%(passDates,random.sample(greetList,1)[0]),toUserName=userName) # ????????? nextTickTime = now + dt.timedelta(days=1) nextTickTime = nextTickTime.strftime("%Y-%m-%d 00:00:00") my_scheduler(nextTickTime)
def text_reply(msg): nickName = itchat.search_friends(userName=msg['FromUserName']).get('NickName', 'Unknown') logging.info('{}-{} send: {}'.format(nickName, msg['FromUserName'], msg['Content'])) if msg["FromUserName"] == itchat.get_friends()[0]["UserName"]: # dont replay self return # if invite if faq.invite_key in msg['Text'].upper(): # TODO Modify add_member_into_chatroom invite_friend = [{'UserName': msg['FromUserName']}] grouproom = itchat.search_chatrooms(name=faq.group_name) grouproom = grouproom and grouproom[0] or None result = itchat.add_member_into_chatroom(grouproom.get('UserName'), invite_friend, useInvitation=True) # invite success if result['BaseResponse']['Ret'] == 0: logging.info('invite user {}-{} successful'.format(nickName, msg['FromUserName'])) else: logging.error('invite user {}-{} failed'.format(nickName, msg['FromUserName'])) itchat.send(REPLAY_ERROR_TEXT, msg['FromUserName']) else: # else TuLing replay replay_text = tuling.replay_text(msg['Text'], msg['FromUserName']) or REPLAY_ERROR_TEXT logging.info('tuling replay user {}-{}: {}'.format(nickName, msg['FromUserName'], replay_text)) itchat.send(replay_text, msg['FromUserName']) # TODO can not return Bool return
def groupchat_reply(msg): groupNmae = itchat.search_chatrooms(userName=msg['FromUserName']).get('NickName') logging.info('group {}-{}: {}-{}: send {}'.format( groupNmae, msg['FromUserName'], msg['ActualNickName'], msg['ActualUserName'], msg['Content'])) if msg['Text'][0] == interpreter.PY_SYMBLOE: replay_text = interpreter.run_py_cmd(msg['Text'][1:]) elif msg['isAt']: replay_text = tuling.replay_text(msg['Text'], msg['ActualNickName']) or REPLAY_ERROR_TEXT else: replay_text = '' if replay_text: itchat.send(replay_text, msg['FromUserName'])
