孙永军 2 years ago
parent
commit
9a69c9b8c4

+ 6 - 1
src/main/java/com/sxtvs/open/api/clue/service/impl/ClueServiceImpl.java

@@ -18,6 +18,7 @@ import com.sxtvs.open.api.clue.entity.*;
 import com.sxtvs.open.api.clue.mapper.ClueMapper;
 import com.sxtvs.open.api.clue.service.IClueService;
 import com.sxtvs.open.core.advice.BizException;
+import com.sxtvs.open.core.sls.AliyunLogger;
 import jakarta.annotation.Resource;
 import org.apache.commons.lang3.tuple.ImmutablePair;
 import org.apache.commons.lang3.tuple.Pair;
@@ -54,6 +55,9 @@ public class ClueServiceImpl extends ServiceImpl<ClueMapper, Clue> implements IC
     @Resource
     private ObjectMapper objectMapper;
 
+    @Resource
+    private AliyunLogger logger;
+
     public IPage<Clue> cluePage(ClueDTO clueDTO){
 
         LambdaQueryWrapper<Clue> wrapper = Wrappers.lambdaQuery();
@@ -120,8 +124,9 @@ public class ClueServiceImpl extends ServiceImpl<ClueMapper, Clue> implements IC
                 HttpResponse resp = HttpRequest.post("https://api.weixin.qq.com/cgi-bin/message/custom/send?access_token=" + WxTokenCache.getInstance().getAccessToken())
                         .body(objectMapper.writeValueAsString(wxReply)).contentType("application/json;charset=UTF-8").execute();
                 System.out.println(resp.body());
+                logger.info("wx reply response ", resp.body());
             } catch (JsonProcessingException e) {
-                e.printStackTrace();
+                logger.error("wx reply error ", e);
             }
 
         }

+ 7 - 1
src/main/java/com/sxtvs/open/api/clue/service/impl/WxTokenCache.java

@@ -3,6 +3,9 @@ package com.sxtvs.open.api.clue.service.impl;
 import cn.hutool.http.HttpUtil;
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import com.sxtvs.open.core.sls.AliyunLogger;
+import jakarta.annotation.Resource;
+import org.springframework.beans.factory.annotation.Autowired;
 
 import static com.sxtvs.open.core.conf.Constant.weixinGZHAppid;
 import static com.sxtvs.open.core.conf.Constant.weixinGZHSecret;
@@ -12,6 +15,9 @@ public class WxTokenCache {
 
     private static WxTokenCache wxTokenCache;
 
+    @Resource
+    private AliyunLogger logger;
+
     private WxTokenCache(){
 
     }
@@ -30,7 +36,7 @@ public class WxTokenCache {
         try {
             this.accessToken = objectMapper.readTree(response).get("access_token").asText();
         } catch (JsonProcessingException e) {
-            e.printStackTrace();
+            logger.error("wx token error", e);
         }
     }