CC/Jarvis_java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
雷欧（林平凡）
2025-01-22 15:50:15 +08:00
parent c9215b2e70
commit cf28b6c8ea
2 changed files with 2 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/cn/van/business/util/WXUtil.java
View File

@@ -4,7 +4,6 @@ import cn.hutool.core.util.ObjectUtil;
import cn.hutool.http.HttpRequest; import cn.hutool.http.HttpRequest;
import cn.van.business.enums.WXReqType; import cn.van.business.enums.WXReqType;
import cn.van.business.mq.MessageProducerService; import cn.van.business.mq.MessageProducerService;
import cn.van.business.repository.OrderRowRepository;
import com.alibaba.fastjson2.JSON; import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject; import com.alibaba.fastjson2.JSONObject;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
@@ -13,12 +12,9 @@ import lombok.NoArgsConstructor;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy;
import org.springframework.core.env.Environment; import org.springframework.core.env.Environment;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.*; import java.util.*;
/** /**

3
src/main/java/cn/van/business/util/WxMessageConsumer.java
View File

@@ -6,6 +6,7 @@ import cn.van.business.model.wx.WxMessage;
import cn.van.business.repository.SettingRepository; import cn.van.business.repository.SettingRepository;
import cn.van.business.repository.WxMessageDataForChatRepository; import cn.van.business.repository.WxMessageDataForChatRepository;
import cn.van.business.repository.WxUserRepository; import cn.van.business.repository.WxUserRepository;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONArray; import com.alibaba.fastjson2.JSONArray;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@@ -245,7 +246,7 @@ public class WxMessageConsumer {
private void handlePrivateMessage(WxMessage wxMessage) throws Exception { private void handlePrivateMessage(WxMessage wxMessage) throws Exception {
Integer msgType = 1; Integer msgType = 1;
// 做业务处理 // 做业务处理
//logger.info("处理消息： {}", JSON.toJSONString(wxMessage)); logger.info("处理消息： {}", JSON.toJSONString(wxMessage));
/** /**
* { * {