main.py

from flask import Flask, request, Response

from pywchat import Sender
from methods import *
from config import WECOM_COMID, APP_SECRET, WECOM_AGENTID

app = Flask(__name__)
if __name__ == '__main__':
    @app.route('/wx', methods=['GET', 'POST'])
    def wechat_servant():
        print(request)

        if request.method == 'GET':
            print(1)

            return verify_url(request)

        elif request.method == 'POST':
            print(2)

            try:
                print(3)

                return Response(status=200)

            finally:
                print(4)

                try:
                    xml_dict = xml_parse(request)
                    print(6)

                    msg_type = find_key(xml_dict, 'MsgType')
                    print(7)

                    if msg_type in {'voice', 'text'}:
                        print(8)
                        if msg_type == 'voice':
                            input_file_path = msg_download(
                                find_key(xml_dict, 'MediaId'))
                            input_text = user_voice2_text(input_file_path)

                        else:
                            input_text = find_key(xml_dict, 'Content')
                            
                        output_text = communicate_with_chatgpt(input_text)
                        print(10)


                        output_file_path = chatgpt_response2_voice(output_text)
                        print(11)


                        send_app = Sender(
                            WECOM_COMID, APP_SECRET, WECOM_AGENTID)
                        user_name = find_key(xml_dict, 'FromUserName')
                        print(user_name)
                        send_app.send_voice(output_file_path + '.amr',  touser=user_name)
                        
                    elif msg_type == 'event':
                        print('收到事件类型消息')

                    elif msg_type == None:
                        raise Exception('返回的消息中没有消息类型')

                    else:
                        print('未添加处理的消息类型')

                    print(12)

                except Exception as e:
                    print(13)

                    print(e)
        else:            
            print('这家伙啥也没干')
        print('一次请求处理完毕')
    app.run(host='0.0.0.0', port=80, debug=True)