graph TD
张三在公众号发送名字-->我每天下班后去后台收集名字-->我去内推的表格中查询张三的进度-->查询后在微信后台回复张三进度

graph TD
粉丝微信后台发送消息-->公众号转发粉丝消息-->是否内推{判断是否属于内推}--yes-->查找excel的内推进度-->组装msg话术并返回-->微信公众号转发回复消息-->粉丝微信收到回复内容

是否内推{判断是否属于内推}--no-->返回查无此人-->微信公众号转发回复消息

graph TD
解析粉丝微信后台发送消息-->建立微信公众号和本地服务器的通信-->通过本地服务器查找张三的进度并返回

1
2
3
4
5
6
[default]
authtoken=1659b9dad1633 //这里填你的隧道号 authtoken
clienttoken=
log=none                        
loglevel=ERROR                  
http_proxy=  

1
chmod a+x natapp

1
./natapp

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
# -*- coding:utf-8 -*-
from flask import Flask
from flask import request
import time
import SelectStudent
import xml.etree.ElementTree as ET
import hashlib
app = Flask(__name__)
@app.route("/")
def index():
    return "Hello World!"
@app.route("/wechat", methods=["GET","POST"])
def weixin():
    if request.method == "GET":     # 判断请求方式是GET请求
        my_signature = request.args.get('signature')     # 获取携带的signature参数
        my_timestamp = request.args.get('timestamp')     # 获取携带的timestamp参数
        my_nonce = request.args.get('nonce')        # 获取携带的nonce参数
        my_echostr = request.args.get('echostr')         # 获取携带的echostr参数
        token = "123456789"  # 一定要跟刚刚微信开发者设置中填写的token一致
        # 进行字典排序
        data = [token, my_timestamp, my_nonce]
        data.sort()
        # 拼接成字符串，进行hash加密时需要为字符串类型
        temp = ''.join(data)
        # 创建一个hash对象
        s = hashlib.sha1()
        # 对创建的hash对象更新需要加密的字符串
        s.update(temp.encode("utf-8"))
        # 加密处理
        mysignature = s.hexdigest()
        print("handle/GET func: mysignature, my_signature: ", mysignature, my_signature)
        # 加密后的字符串可与signature对比，标识该请求来源于微信
        if my_signature == mysignature:
            return my_echostr
        else:
            return ""
    else:
        # 解析xml
        xml = ET.fromstring(request.data)
        toUser = xml.find('ToUserName').text
        fromUser = xml.find('FromUserName').text
        msgType = xml.find("MsgType").text
        createTime = xml.find("CreateTime")
        # 判断类型并回复
        if msgType == "text":
            content = xml.find('Content').text
            print("content=",content)
            return reply_text(fromUser, toUser, SelectStudent.excel_reply(content))
        else:
            return reply_text(fromUser, toUser, "李梨同学目前只能接收文字哦")
        pass
def reply_text(to_user, from_user, content):
    """
    以文本类型的方式回复请求
    """
    return """
    <xml>
        <ToUserName><![CDATA[{}]]></ToUserName>
        <FromUserName><![CDATA[{}]]></FromUserName>
        <CreateTime>{}</CreateTime>
        <MsgType><![CDATA[text]]></MsgType>
        <Content><![CDATA[{}]]></Content>
    </xml>
    """.format(to_user, from_user, int(time.time() * 1000), content)
if __name__ == "__main__":
    app.run(host='0.0.0.0', port=80)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
import pandas as pd
def excel_reply(name):
    """关键字回复"""
    df = pd.read_excel('static/candidates2023.xlsx')
    df = df.applymap(lambda x: str(x).strip())#去除表格中的空格
    df_data = df[['候选人姓名', '简历筛选状态']]
    # 判断名字是否在内推的名单中
    if name in df["候选人姓名"].values:
        print("查找的候选人存在")
        # 通过名字查询候选人信息
        candidates = df[df_data["候选人姓名"] == name]
        if candidates['简历筛选状态'].values == "未通过":
            msg = name + "您好，您当前在航旅纵横校招内推的进度为未通过简历筛选，后续依然有招聘机会，期待您的继续关注！"
            return msg
        if candidates['简历筛选状态'].values == "通过":
            msg = name + "您好，您当前在航旅纵横校招内推的进度为通过简历筛选，请等待后续的流程通知！"
            return msg
        if candidates['简历筛选状态'].values == "已发送，待筛选":
            msg = name + "您好，您当前在航旅纵横校招内推的进度为正在业务部门进行筛选，请耐心等待！"
            return msg
        else:
            msg = "您查找的候选人" + name + "不存在，请确认" + name + "是否内推成功。\nPS:李梨同学目前只支持通过姓名查询哦！"
            return msg
    else:
        msg = "您查找的候选人"+name+"不存在，请确认"+name+"是否内推成功。\nPS:李梨同学目前只支持通过姓名查询哦！"
        return msg

相关文章