修改

apps/jqr/serializers.py

@@ -45,6 +45,7 @@ class WechatPublicTokenSerializer(serializers.Serializer):
             return {}
         corp.callbackstatus = QcCorpInfoCallbackStatusChoices.VALIDATED
         corp.callback_validate_time = datetime.now()
+        corp.save()
         attrs['echostr'] = echostr.decode()
         return attrs
 

apps/jqr/utils.py

@@ -87,13 +87,14 @@ def send_new_user_msg(corpid, userid, external_userid):
     # 发送新客欢迎
     try:
         success, data = Http.get_new_user_msg(corpid, userid, external_userid)
+        logger.info(f'send new user msg http ---> success: {success}, data: {data}')
         if not success:
             logger.error(f'corpid: {corpid}, userid: {userid}, external_userid: {external_userid}, 发送新客欢迎失败')
             return
         status_code = WS.send_wx_work_msg(data)
         success = status_code == 200
         logger.info(
-            f'corpid: {corpid}, userid: {userid}, external_userid: {external_userid},发送新客欢迎消息成功状态:{success}')
+            f'corpid: {corpid}, userid: {userid}, external_userid: {external_userid},发送新客欢迎消息成功状态:{success}, status_code: {status_code}')
         return success
     except Exception as e:
         logger.error(f'corpid: {corpid}, userid: {userid}, external_userid: {external_userid}, 发送新客欢迎失败: {e}')

apps/jqr/ws.py

@@ -32,4 +32,6 @@ class WS:
     def send_wx_work_msg(cls, data):
         url = f'{cls.BASE_URL}/api/hook/websocket/sendwxworkmsg'
         response = requests.post(url, json=data)
+        print(response.text)
+        print(response.json())
         return response.status_code