添加正向代理

Dockerfile

@@ -1,5 +1,6 @@
 FROM python:3.11.4
 
+USER root
 ENV APP_HOME=/app
 RUN mkdir $APP_HOME
 WORKDIR $APP_HOME

apps/jqr/serializers.py

@@ -11,6 +11,7 @@ from apps.jqr.tasks import save_add_contact, delete_add_contact, edit_add_contac
 from apps.msg.models import TbMessage
 from apps.msg.pubsub import JQRMSGPubSub
 from apps.qc.choices import QcCorpInfoCallbackStatusChoices
+from apps.qc.models import QcQrcodes
 from libs.weworkapi.callback.WXBizMsgCrypt3 import WXBizMsgCrypt, Prpcrypt
 from utils.tools import sha1_encoder, get_attribute, camel_to_snake
 import xml.etree.cElementTree as ET
@@ -104,10 +105,17 @@ class WechatEncryptSerializer(serializers.Serializer):
         state = data.get('state')
         data['corpid'] = corp.corpid
         if state and state.startswith('mg') and '_' in state:
-            [_, _, qrcodeid] = state.split('_')
+            [_, uid, qrcodeid] = state.split('_')
             data['qrcodeid'] = qrcodeid
             data['agentid'] = corp.agentid
-            data['uid'] = corp.uid
+            data['uid'] = uid
+            qrcode = QcQrcodes.objects.filter(id=qrcodeid, uid=uid).first()
+            if not qrcode:
+                return
+            data['qrcodeid'] = qrcodeid
+            data['agentid'] = qrcode.agentid
+            data['uid'] = uid
+            data['corpid'] = qrcode.corpid
         # save_add_contact.delay(data, corp.to_dict(['corpid', 'appsecret']))
         JQREventNewUserCallbackPubSub.publish({
             'handler': f'{save_add_contact_by_channel.__module__}.{save_add_contact_by_channel.__name__}',
@@ -126,10 +134,17 @@ class WechatEncryptSerializer(serializers.Serializer):
         state = data.get('state')
         data['corpid'] = corp.corpid
         if state and state.startswith('mg') and '_' in state:
-            [_, _, qrcodeid] = state.split('_')
+            [_, uid, qrcodeid] = state.split('_')
             data['qrcodeid'] = qrcodeid
             data['agentid'] = corp.agentid
-            data['uid'] = corp.uid
+            data['uid'] = uid
+            qrcode = QcQrcodes.objects.filter(id=qrcodeid, uid=uid).first()
+            if not qrcode:
+                return
+            data['qrcodeid'] = qrcodeid
+            data['agentid'] = qrcode.agentid
+            data['uid'] = uid
+            data['corpid'] = qrcode.corpid
         # edit_add_contact.delay(data, corp.to_dict(['corpid', 'appsecret']))
         JQREventCallbackPubSub.publish({
             'handler': f'{edit_add_contact_by_channel.__module__}.{edit_add_contact_by_channel.__name__}',
@@ -148,10 +163,17 @@ class WechatEncryptSerializer(serializers.Serializer):
         state = data.get('state')
         data['corpid'] = corp.corpid
         if state and state.startswith('mg') and '_' in state:
-            [_, _, qrcodeid] = state.split('_')
+            [_, uid, qrcodeid] = state.split('_')
             data['qrcodeid'] = qrcodeid
             data['agentid'] = corp.agentid
-            data['uid'] = corp.uid
+            data['uid'] = uid
+            qrcode = QcQrcodes.objects.filter(id=qrcodeid, uid=uid).first()
+            if not qrcode:
+                return
+            data['qrcodeid'] = qrcodeid
+            data['agentid'] = qrcode.agentid
+            data['uid'] = uid
+            data['corpid'] = qrcode.corpid
         # save_add_contact.delay(data, corp.to_dict(['corpid', 'appsecret']))
         JQREventNewUserCallbackPubSub.publish({
             'handler': f'{save_add_contact_by_channel.__module__}.{save_add_contact_by_channel.__name__}',
@@ -170,8 +192,17 @@ class WechatEncryptSerializer(serializers.Serializer):
         state = data.get('state')
         data['corpid'] = corp.corpid
         if state and state.startswith('mg') and '_' in state:
+            [_, uid, qrcodeid] = state.split('_')
+            data['qrcodeid'] = qrcodeid
             data['agentid'] = corp.agentid
-            data['uid'] = corp.uid
+            data['uid'] = uid
+            qrcode = QcQrcodes.objects.filter(id=qrcodeid, uid=uid).first()
+            if not qrcode:
+                return
+            data['qrcodeid'] = qrcodeid
+            data['agentid'] = qrcode.agentid
+            data['uid'] = uid
+            data['corpid'] = qrcode.corpid
         # delete_add_contact.delay(data, corp.to_dict(['corpid', 'appsecret']))
         JQREventCallbackPubSub.publish({
             'handler': f'{delete_add_contact_by_channel.__module__}.{delete_add_contact_by_channel.__name__}',

docker-compose.yml

@@ -7,6 +7,7 @@ services:
       context: .
       dockerfile: ./Dockerfile
     command: ./start
+    restart: always
     environment:
       - api=true
     volumes:

start

@@ -1,4 +1,5 @@
 #!/bin/bash
 
 gunicorn -c yzk_wechat_event/gunicorn.conf.py yzk_wechat_event.wsgi:application &
+echo '121.41.112.68 qyapi.weixin.qq.com' >> /etc/hosts &
 tail -f logs/*.log