Procházet zdrojové kódy

微信消息发送记录调整

dzx před 7 měsíci
rodič
revize
a01ca2e21f

+ 5 - 1
src/main/java/com/xjrsoft/module/organization/service/impl/WeChatServiceImgl.java

@@ -2,6 +2,7 @@ package com.xjrsoft.module.organization.service.impl;
 
 
 import cn.hutool.core.collection.CollUtil;
+import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.xjrsoft.common.enums.DeleteMark;
@@ -19,6 +20,7 @@ import com.xjrsoft.module.organization.service.IWeChatService;
 import com.xjrsoft.module.system.entity.WechatMessageSendLog;
 import com.xjrsoft.module.system.mapper.WechatMessageSendLogMapper;
 import lombok.AllArgsConstructor;
+import org.apache.skywalking.apm.toolkit.trace.ActiveSpan;
 import org.springframework.stereotype.Service;
 
 import java.util.*;
@@ -53,14 +55,16 @@ public class WeChatServiceImgl implements IWeChatService {
         object.put("url", dto.getUrl());
         object.put("client_msg_id", dto.getMsgId());
         object.put("data", dto.getContent());
+        ActiveSpan.tag("sendTemplateMessage-params", JSON.toJSONString(object));
         String result = weChatUtil.sendTemplateMessage(object);
-
+        ActiveSpan.tag("sendTemplateMessage-result", result);
         //新增微信模板消息发送记录
         wechatMessageSendLogMapper.insert(new WechatMessageSendLog(){{
             setOpenId(dto.getUserId());
             setTemplateId(dto.getTemplateId());
             setResult(result);
             setParams(object.toString());
+            setCreateDate(new Date());
         }});
     }