微信聊天機器人-存儲好友分享消息

一、背景

    一般大公司都比較重視企業文化，和學習氛圍，這不我們的團隊也是如此，每個人每月微信分享必須超過5篇內容，一個是提高自己的閱讀量，另外還可以把有用的資源分享給其他人。開始記錄的一段時間還算比較順利，可是當大家的分享內容一多的時候，總是發生記漏的情況，后來我就萌生了一個想法，可不可以讓程序來記錄分享數據，這樣就不會發生錯誤了。正好這一段時間剛好在學習python，那就拿這個案例來練練手，網上搜索了一些資料，發現我的需求果然可以用程序來實現，那么還等什么直接開干吧

二、效果展示

1、自動回復

 

2、生成的excel效果展示

三、wxpy

wxpy
1、wxpy安裝比較簡單，直接使用pip命令行安裝即可：pip install wxpy

2、wxpy的幫助文檔還是比較詳細的，網上大多數的文章都是簡單的使用了下這個庫，沒有詳細的解釋，如果有時間，建議最好自己過一遍幫助文檔

3、使用起來也是相當簡單

3.1先導入wxpy模塊

 from wxpy import * 

3.2構造一個機器人對象(機器人對象可構造多個)

 bot = Bot() 

3.3發送消息給文件助手

 bot.file_helper.send('你好') 

3.4發送消息給好友

friend = bot.friends().search('朝十晚八')[0]
friend.send('你好')

3.5自動回復指定好友消息

@bot.register([Friend])
def auto_monitor_friend_all(msg):
    with cond :
        if msg.text.startswith(orderHeader) and msg.sender.name in destusers :
            print(u'收到一條好友指令消息：', msg.text)
            __dealwith_order(msg)
        else :
            print(u'收到一條好友消息', msg)
            if msg.type == PICTURE :
                image_cache = image_cache_path + '/' + msg.file_name
                msg.get_file(image_cache)
            tuling.do_reply(msg)

上述自動回復消息使用了圖靈機器人，使用時需要自己去這兒申請一個圖靈賬號，然后創建一個圖靈機器人，得到機器人的apikey，然后構造一個Tuling對象，使用該對象進程回復消息

tuling = Tuling(api_key='3d131c218dd44aa88def35ac37b5c9ab')

3.6自動添加好友

# 注冊好友請求類消息
@bot.register(msg_types = FRIENDS)
def auto_accept_friends(msg):
    with cond :
        # 接受好友 (msg.card 為該請求的用戶對象)
        new_friend = bot.accept_friend(msg.card)
        new_friend.send(u'圖靈接受了你的好友請求，我們可以開始聊天了')

3.7添加后台定時消息

wxpy構造的機器人對象屬於web方式連接，如果長時間沒有消息，可能會掉線，因此我們開啟一個后台線程，隔一段時間發送消息給自己。

def restartTimer() :
    global t
    if t.is_alive() :
        t.stop() 

    t = Timer.Timer(deamonMsg, timerInterval)
    t.setDaemon(True)
    t.start()

def deamonMsg() :
    with cond :
        msgCount = datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')
        print(u'發送消息給文件夾助手，保持連接活躍。消息內容：', msgCount)
        bot.file_helper.send(msgCount)

上述代碼中cond為線程同步條件變量，當使用bot對象發送消息時，需要對bot對象進行保護。

3.8處理消息指令，主要用於控制定時器

def __dealwith_order(msg) :
    orderstr = msg.text.lower()#不區分大小寫
    orderstr = orderstr[len(orderHeader):]
    if orderstr == "1" :
        bot.registered.enable(auto_accept_friends)
        msg.reply('自動接收好友請求已開啟')
    elif orderstr == "2" :
        bot.registered.disable(auto_accept_friends)
        msg.reply('自動接收好友請求已關閉')
    elif orderstr == "3" :
        if t.is_alive() :
            if t.is_pause() :
                msg.reply('后台線程已掛起')
            else :
                msg.reply('后台線程運行正常')
        else :
            msg.reply('后台線程已退出')
    elif orderstr == "4" :
        t.resume()
        msg.reply('后台線程已恢復')
    elif orderstr == "5" :
        t.pause()
        msg.reply('后台線程已掛起')
    elif orderstr == "6" :
        restartTimer() 
        msg.reply('后台線程已重啟')
    elif orderstr.startswith("7 ") :
        global timerInterval
        timerInterval = int(orderstr[2:].strip())
        restartTimer() 
        msg.reply('后台線程刷新間隔已修改：{0}'.format(timerInterval))
    else :
        msg.reply('指令：order+序號\n1、開啟自動接收好友請求\n2、關閉自動接收好友請求\n3、查看后台線程是否活躍\n4、恢復后台線程\n5、掛起后台線程\n6、重新啟動后台線程\n')

四、讀寫excel

1、使用pip命令安裝openpyxl：pip install openpyxl

2、使用openpyxl.load_workbook加載excel文件，如果文件不存在則使用openpyxl.Workbook()構造工作簿，操作完成后使用工作簿save接口保存文件

if os.path.exists(fileName) :
    wbk = openpyxl.load_workbook(fileName)
    names = wbk.sheetnames
else :
    wbk = openpyxl.Workbook()
    sheet = wbk.active
    sheet.title = 'all'
    names.append('all')
    FixedSheetWidth(sheet)

3、修改列寬度和內容

headList = ['發送者', '群聊', '接受者', '發送時間', '接受時間','分享內容', '網址']

def GetCellKey(r, c) : 
    cell =  chr(ord('A') + c - 1) + str(r)
    return cell
    
def FixedSheetWidth(sheet) :
    for i in range(0, len(cwidth)):
        sheet.column_dimensions[chr(ord('A') + i)].width = cwidth[i]

def WriteSheetTitle(sheet) :
    i = 1
    for svalue in headList:
        sheet[GetCellKey(1, i)] = svalue
        sheet[GetCellKey(1, i)].font = openpyxl.styles.Font(bold = True)
        i = i + 1

4、添加行數據

def WriteSheetRow(wbk, sheet, rowValueList, rowIndex, isBold):
    i = 1
    for svalue in rowValueList :
        if isBold :
            sheet[GetCellKey(rowIndex, i)] = svalue
            sheet[GetCellKey(rowIndex, i)].font = openpyxl.styles.Font(bold = True)
        else:
            sheet[GetCellKey(rowIndex, i)] = svalue
        i = i + 1

    #寫入單獨已用戶名為標簽的sheet
    name = rowValueList[0]
    subsheet = None
    if name not in names :
        subsheet = wbk.create_sheet(name)
        WriteSheetTitle(subsheet)
        FixedSheetWidth(subsheet)
        names.append(name)
    else :
        subsheet = wbk[name]

    j = 1
    rowIndex = subsheet.max_row + 1
    for svalue in rowValueList:
        if isBold :
            subsheet[GetCellKey(rowIndex, j)] = svalue
        else:
            subsheet[GetCellKey(rowIndex, j)] = svalue
        j = j + 1

5、備份用於查看的文件

#備份文件
file2see = os.path.join(os.getcwd(), generateFileName(''))
if not os.path.exists(file2see) :
    shutil.copyfile(fileName, file2see)
else :
    if os.access(file2see, os.W_OK) :
        shutil.copyfile(fileName, file2see)

五、定時器

    定時器主要用於后台定時發送消息給機器人自己，保持自己在線狀態

　定時器對象使用python的線程對象thread.Thread作為父類，並添加了pause、is_pause、resume和stop接口，使定時器控制起來更方便

# -*- coding: UTF-8 -*-

import time
import threading

class Timer(threading.Thread):
    def __init__(self, fun, seconds):
        self.__runTime = seconds
        self.__runfun = fun
        self.__elapsed = 0.0 #流失的時間
        self.__flag = threading.Event()     # 用於暫停線程的標識
        self.__flag.set()       # 設置為True
        self.__running = threading.Event()      # 用於停止線程的標識
        self.__running.set()      # 將running設置為True
        threading.Thread.__init__(self)
        print("initialize Timer completed!")

    def run(self):
        while self.__running.isSet():
            self.__flag.wait()      # 為True時立即返回, 為False時阻塞直到內部的標識位為True后返回
            time.sleep(0.1) #100ms檢測一次退出狀態
            self.__elapsed = self.__elapsed + 0.1
            if self.__elapsed > self.__runTime :
                self.__elapsed = 0.0
                self.__runfun()

    def pause(self):
        self.__flag.clear()     # 設置為False, 讓線程阻塞

    def is_pause(self) :
        return  self.__flag.isSet() == False

    def resume(self):
        self.__flag.set()    # 設置為True, 讓線程停止阻塞

    def stop(self):
        self.__flag.set()       # 將線程從暫停狀態恢復, 如何已經暫停的話
        self.__running.clear()        # 設置為False
        self.__elapsed = 0.0

六、demo下載

　　需要全部代碼的到csdn直接下載：自動聊天機器人-存儲好友分享消息

七、參考文章

• 關於wxpy的小實驗（一）：實現登錄微信、消息接收、處理、回復和人臉檢測處理反饋
• 用python讀寫excel（xlrd、xlwt）
• python3 讀寫Excel

 

如果您覺得文章不錯，不妨給個打賞，寫作不易，感謝各位的支持。您的支持是我最大的動力，謝謝！！！ 

---

 

  

---

很重要--轉載聲明

1. 本站文章無特別說明，皆為原創，版權所有，轉載時請用鏈接的方式，給出原文出處。同時寫上原作者：朝十晚八 or Twowords
2. 如要轉載，請原文轉載，如在轉載時修改本文，請事先告知，謝絕在轉載時通過修改本文達到有利於轉載者的目的。 

---

奮斗中的無名小卒。。。