新增日志，添加告警提醒

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/mq/processor/AddMemberUnionRelateConsumerProcessor.java

 package com.gic.haoban.manage.service.mq.processor;
 
 import cn.hutool.crypto.SecureUtil;
+import cn.hutool.http.HttpUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.gic.commons.util.EntityUtil;
+import com.gic.dubbo.entity.ProviderLocalTag;
 import com.gic.haoban.manage.api.dto.ExternalUserDTO;
 import com.gic.haoban.manage.api.dto.MemberUnionidRelatedDTO;
 import com.gic.haoban.manage.api.dto.StaffClerkRelationDTO;
@@ -27,6 +29,8 @@ import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
+import java.util.HashMap;
+import java.util.Map;
 import java.util.Objects;
 
 /**
@@ -59,6 +63,9 @@ public class AddMemberUnionRelateConsumerProcessor extends AbstractConsumerProce
     @Autowired
     private MemberService memberService;
 
+    private static final String ALERT_URL = "https://oapi.dingtalk.com/robot/send?access_token=435c0ddaacda849e145b64cc3a83c37f742105d88cf27b719b2dbef167436ad4";
+
+
     @Override
     MemberUnionRelatedBO paramParse(String s) {
         return JSON.parseObject(s, MemberUnionRelatedBO.class);
@@ -67,6 +74,7 @@ public class AddMemberUnionRelateConsumerProcessor extends AbstractConsumerProce
     @Override
     void doProcess(MemberUnionRelatedBO bo) {
         String staffId = bo.getStaffId();
+        messageAlert(staffId);
         String wxEnterpriseId = bo.getWxEnterpriseId();
         String externalUserid = bo.getExternalUserid();
         String wxUserId = bo.getWxUserId();
@@ -140,6 +148,22 @@ public class AddMemberUnionRelateConsumerProcessor extends AbstractConsumerProce
         externalClerkRelatedService.insert(related);
     }
 
+    private void messageAlert(String staffId) {
+        ProviderLocalTag providerLocalTag = ProviderLocalTag.tag.get();
+        String traceId = providerLocalTag.traceId;
+        String traceUrl = "http://10.105.8.172:8780/damo-stats/mongodb/getLogMessagesView?trace_id=" + traceId;
+
+        Map<String, Object> map = new HashMap<>();
+        Map<String, Object> link = new HashMap<>();
+        map.put("msgtype", "link");
+        link.put("title", "存量会员关联提醒");
+        link.put("text", staffId);
+        link.put("messageUrl", traceUrl);
+        map.put("link", link);
+        String post = HttpUtil.post(ALERT_URL, JSONObject.toJSONString(map));
+        logger.info("alert:{}", post);
+    }
+
     private MemberUnionidRelatedDTO getAndMergeMemberUnion(MemberUnionRelatedBO bo) {
         // 查询自建
         ExternalUserDTO selfExternalUserDTO = getCorpSelfExternalUseridInfo(