修改

apps/jqr/apps.py

@@ -8,6 +8,8 @@ class JqrConfig(AppConfig):
     name = 'apps.jqr'
 
     def ready(self):
+        from django.conf import settings
+        if not settings.DEBUG:
             from apps.jqr.pubsub import JQREventNewUserCallbackPubSub
             t = Thread(target=JQREventNewUserCallbackPubSub.event_callback_listener)
             t.start()

apps/jqr/tasks.py

@@ -6,6 +6,7 @@ from django.db.models import Count, Sum, When, Case, Value
 
 from apps.jqr.choices import JqrWechatbizuserinfoDeleteTypeChoices, JqrAddTypeChoices
 from apps.jqr.pubsub import JQRQrcodeCallbackPubSub
+from apps.jqr.utils import send_new_user_msg
 from apps.jqr.ws import WS
 from apps.qc.choices import QcWechatbizeventAddcontactIsDeleteChoices, QcQrcodesEditLogOperateTypeChoices, \
     QcQrcodesEditLogTypeChoices
@@ -79,6 +80,8 @@ def save_add_contact_by_channel(data, corpinfo, *args, **kwargs):
     edit_add_contact(data, corpinfo, *args, **kwargs)
     # 转化外部用户Id
     WS.transfer_external_userid_to_vid(corpid, userid, externaluserid)
+    # 发送新客欢迎
+    send_new_user_msg(corpid, userid, externaluserid)
 
 
 @shared_task(name='edit_add_contact', queue='contact')

apps/jqr/utils.py

@@ -91,7 +91,9 @@ def send_new_user_msg(corpid, userid, external_userid):
             logger.error(f'corpid: {corpid}, userid: {userid}, external_userid: {external_userid}, 发送新客欢迎失败')
             return
         status_code = WS.send_wx_work_msg(data)
-        return status_code == 200
+        success = status_code == 200
+        logger.info(
+            f'corpid: {corpid}, userid: {userid}, external_userid: {external_userid},发送新客欢迎消息成功状态:{success}')
     except Exception as e:
         logger.error(f'corpid: {corpid}, userid: {userid}, external_userid: {external_userid}, 发送新客欢迎失败: {e}')
         pass