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

拼多多地址

Browse Source
This commit is contained in:
Leo
2025-04-07 10:38:02 +08:00
parent 4e058fd816
commit 109f1b382d
3 changed files with 177 additions and 143 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -3,14 +3,11 @@ package cn.van.business.util;
import cn.van.business.enums.FromType;
import cn.van.business.model.wx.WxMessage;
import cn.van.business.model.wx.WxMessageDataForChat;
import cn.van.business.model.wx.WxUser;
import cn.van.business.repository.SettingRepository;
import cn.van.business.repository.WxMessageDataForChatRepository;
import cn.van.business.repository.WxUserRepository;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -19,15 +16,11 @@ import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
import java.math.BigDecimal;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Objects;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import static cn.van.business.util.WXUtil.chatRoomList;
import static cn.van.business.util.WXUtil.super_admins;
import static cn.van.business.util.WXUtil.*;
/**
@@ -195,8 +188,6 @@ public class WxMessageConsumer {
// wxUtil.sendTextMessage(wxid, result, msgType, null);
//
//}
@Async("threadPoolTaskExecutor")
public void consume(WxMessage wxMessage) throws Exception {
//logger.info("接收到消息 : {}", wxMessage);
@@ -227,42 +218,43 @@ public class WxMessageConsumer {
*
* @param wxMessage
*/
private void handlePrivateMessage(WxMessage wxMessage) throws Exception {
logger.info("处理私聊消息： {}", JSON.toJSONString(wxMessage));
private void handlePrivateMessage(WxMessage wxMessage) throws Exception {
logger.info("处理私聊消息： {}", JSON.toJSONString(wxMessage));
WxMessage.DataSection data = wxMessage.getData();
WxMessage.DataSection.InnerData innerData = data.getData();
if (Util.isAnyEmpty(innerData.getMsg(), innerData.getFromWxid())) {
logger.info("消息内容为空，不处理");
return;
} else {
logger.info("消息内容：{}", innerData.getMsg());
WxMessage.DataSection data = wxMessage.getData();
WxMessage.DataSection.InnerData innerData = data.getData();
if (Util.isAnyEmpty(innerData.getMsg(), innerData.getFromWxid())) {
logger.info("消息内容为空，不处理");
return;
} else {
logger.info("消息内容：{}", innerData.getMsg());
}
String fromWxid = innerData.getFromWxid();
WXUtil.SuperAdmin superAdmin = super_admins.get(fromWxid);
if (Util.isEmpty(superAdmin)) {
logger.info("不是超管消息，不处理");
return;
}
String msg = innerData.getMsg();
if (msg.startsWith("京")) {
logger.info("消息以京开头，处理京东指令消息");
jdUtils.sendOrderToWxByOrderJD(msg.replace("京", ""), fromWxid);
return;
} else {
logger.info("消息不以京开头");
}
if (msg.startsWith("拼")) {
logger.info("消息以拼开头，处理拼多多指令消息");
jdUtils.sendOrderToWxByOrderPDD(msg.replace("拼", ""), fromWxid);
return;
}
logger.info("未命中前置指令，开始命中 Default 流程");
jdUtils.sendOrderToWxByOrderDefault(msg, fromWxid);
}
String fromWxid = innerData.getFromWxid();
WXUtil.SuperAdmin superAdmin = super_admins.get(fromWxid);
if (Util.isEmpty(superAdmin)) {
logger.info("不是超管消息，不处理");
return;
}
String msg = innerData.getMsg();
if (msg.startsWith("京")) {
logger.info("消息以京开头，处理京东指令消息");
jdUtils.sendOrderToWxByOrderJD(msg.replace("京", ""), fromWxid);
return;
} else {
logger.info("消息不以京开头");
}
if (msg.startsWith("拼")) {
logger.info("消息以拼开头，处理拼多多指令消息");
jdUtils.sendOrderToWxByOrderPDD(msg.replace("拼", ""), fromWxid);
return;
}
logger.info("未命中前置指令，开始命中 Default 流程");
jdUtils.sendOrderToWxByOrderDefault(msg, fromWxid);
}
private void handleGroupMessage (WxMessage wxMessage) {
private void handleGroupMessage(WxMessage wxMessage) {
logger.info("处理群聊消息： {}", JSON.toJSONString(wxMessage));
WxMessage.DataSection data = wxMessage.getData();
@@ -275,12 +267,18 @@ private void handlePrivateMessage(WxMessage wxMessage) throws Exception {
}
String fromWxid = innerData.getFromWxid();
if ( !chatRoomList.contains(fromWxid)) {
String msg = innerData.getMsg();
if (chatRoom_WLM.equals(fromWxid)) {
logger.info("玩了买线报群消息");
jdUtils.cjwlm(msg);
return;
}
if (!chatRoomList.contains(fromWxid)) {
logger.info("不是白名单群聊，不处理");
return;
}
String msg = innerData.getMsg();
if (msg.startsWith("拼")) {
logger.info("消息以拼开头，处理拼多多指令消息");
jdUtils.sendOrderToWxByOrderPDD(msg.replace("拼", ""), fromWxid);
@@ -318,105 +316,105 @@ private void handlePrivateMessage(WxMessage wxMessage) throws Exception {
* }
* }*/
}
//else if (msg.startsWith("美团 ")) {
// logger.info("处理美团的消息");
// msg = msg.substring(msg.indexOf("https://i.meituan.com/mttouch/page/account"));
// String[] all = msg.split("\\?");
//
// if (all.length == 2) {
// String wxid = null;
// if (wxMessage.getFromtype().equals(fromGR)) {
// wxid = wxMessage.getFromid();
// } else {
// wxid = wxMessage.getFromgid();
// }
// String httpData = all[1];
// String[] httpDataArr = httpData.split("&");
// if (httpDataArr.length == 2) {
// // 调用美团
// //String result = mt20(wxid, httpDataArr[0].split("=")[1], httpDataArr[1].split("=")[1]);
//
// //wxUtil.sendTextMessage(wxid, result, msgType, null);
// } else {
//
// wxUtil.sendTextMessage(wxid, "请检查提交的数据格式是否正确。", msgType, null);
// }
// }
//} else if ("余额".equals(msg)) {
// String wxid = null;
// if (wxMessageDataForChat.getFromtype() == 1) {
// wxid = wxMessageDataForChat.getFromwxid();
// } else if (wxMessageDataForChat.getFromtype() == 2) {
// wxid = wxMessageDataForChat.getFinalfromwxid();
// }
// WxUser wxUser = wxUserService.getOne(Wrappers.query(new WxUser()).eq("wxid", wxid));
// String result = "";
// if (Util.isNotEmpty(wxUser)) {
// result = "您的余额为：" + wxUser.getMoneyLeiji() + "元\r";
// result = result + " 您的消费次数为：" + wxUser.getCountXiaofei() + "次\r";
// result = result + " 您的充值次数为：" + wxUser.getCountChongzhi() + "次\r";
// result = result + " 您的累计充值为：" + wxUser.getMoneyLeiji() + "元";
// } else {
// result = "暂未查询到充值记录。\r";
// }
//
//
// wxUtil.sendTextMessage(wxid, result, msgType, null);
//} else if ("体验".equals(msg)) {
// String wxid = null;
// if (wxMessageDataForChat.getFromtype() == 1) {
// wxid = wxMessageDataForChat.getFromwxid();
// } else if (wxMessageDataForChat.getFromtype() == 2) {
// wxid = wxMessageDataForChat.getFinalfromwxid();
// }
// String result = "";
// if (heiMingDan(wxid)) {
// result = "黑名单！";
// } else {
// WxUser wxUser = wxUserService.getOne(Wrappers.query(new WxUser()).eq("wxid", wxid));
// if (isNew(wxUser.getIsnew())) {
// wxUser.setMoneyLeiji(wxUser.getMoneyLeiji().add(new BigDecimal(1)));
// wxUser.setMoneyShengyu(wxUser.getMoneyShengyu().add(new BigDecimal(1)));
// wxUser.setCountChongzhi(wxUser.getCountChongzhi().add(BigDecimal.ONE));
// wxUser.setIsnew(1);
// wxUserService.updateById(wxUser);
// result = "体验成功，您已成功充值" + 1.00 + "元，已成功存入账户。感谢您的使用。";
// } else {
// result = "您已体验过，请勿重复体验。";
// }
//
// }
//
// wxUtil.sendTextMessage(wxid, result, msgType, null);
//
//}// 用户返回用户菜单
//else if (order_caiDan.equals(msg)) {
// String wxid = null;
// if (wxMessageDataForChat.getFromtype() == 1) {
// wxid = wxMessageDataForChat.getFromwxid();
// } else if (wxMessageDataForChat.getFromtype() == 2) {
// wxid = wxMessageDataForChat.getFinalfromwxid();
// }
// String result = "";
// String puTong = getSetting(key_caiDan_user);
// String chaoJi = getSetting(key_caiDan_admin);
// if (isSuperAdminUser(wxid)) {
// result = "用户菜单：" + puTong + " 管理员菜单：" + chaoJi;
// } else {
// result = "用户菜单：" + puTong;
// }
//
// wxUtil.sendTextMessage(wxid, result, msgType, wxMessageDataForChat.getFromwxid());
//}
// wxMessageDataForChatService.save(wxMessageDataForChat);
//else if (msg.startsWith("美团 ")) {
// logger.info("处理美团的消息");
// msg = msg.substring(msg.indexOf("https://i.meituan.com/mttouch/page/account"));
// String[] all = msg.split("\\?");
//
// if (all.length == 2) {
// String wxid = null;
// if (wxMessage.getFromtype().equals(fromGR)) {
// wxid = wxMessage.getFromid();
// } else {
// wxid = wxMessage.getFromgid();
// }
// String httpData = all[1];
// String[] httpDataArr = httpData.split("&");
// if (httpDataArr.length == 2) {
// // 调用美团
// //String result = mt20(wxid, httpDataArr[0].split("=")[1], httpDataArr[1].split("=")[1]);
//
// //wxUtil.sendTextMessage(wxid, result, msgType, null);
// } else {
//
// wxUtil.sendTextMessage(wxid, "请检查提交的数据格式是否正确。", msgType, null);
// }
// }
//} else if ("余额".equals(msg)) {
// String wxid = null;
// if (wxMessageDataForChat.getFromtype() == 1) {
// wxid = wxMessageDataForChat.getFromwxid();
// } else if (wxMessageDataForChat.getFromtype() == 2) {
// wxid = wxMessageDataForChat.getFinalfromwxid();
// }
// WxUser wxUser = wxUserService.getOne(Wrappers.query(new WxUser()).eq("wxid", wxid));
// String result = "";
// if (Util.isNotEmpty(wxUser)) {
// result = "您的余额为：" + wxUser.getMoneyLeiji() + "元\r";
// result = result + " 您的消费次数为：" + wxUser.getCountXiaofei() + "次\r";
// result = result + " 您的充值次数为：" + wxUser.getCountChongzhi() + "次\r";
// result = result + " 您的累计充值为：" + wxUser.getMoneyLeiji() + "元";
// } else {
// result = "暂未查询到充值记录。\r";
// }
//
//
// wxUtil.sendTextMessage(wxid, result, msgType, null);
//} else if ("体验".equals(msg)) {
// String wxid = null;
// if (wxMessageDataForChat.getFromtype() == 1) {
// wxid = wxMessageDataForChat.getFromwxid();
// } else if (wxMessageDataForChat.getFromtype() == 2) {
// wxid = wxMessageDataForChat.getFinalfromwxid();
// }
// String result = "";
// if (heiMingDan(wxid)) {
// result = "黑名单！";
// } else {
// WxUser wxUser = wxUserService.getOne(Wrappers.query(new WxUser()).eq("wxid", wxid));
// if (isNew(wxUser.getIsnew())) {
// wxUser.setMoneyLeiji(wxUser.getMoneyLeiji().add(new BigDecimal(1)));
// wxUser.setMoneyShengyu(wxUser.getMoneyShengyu().add(new BigDecimal(1)));
// wxUser.setCountChongzhi(wxUser.getCountChongzhi().add(BigDecimal.ONE));
// wxUser.setIsnew(1);
// wxUserService.updateById(wxUser);
// result = "体验成功，您已成功充值" + 1.00 + "元，已成功存入账户。感谢您的使用。";
// } else {
// result = "您已体验过，请勿重复体验。";
// }
//
// }
//
// wxUtil.sendTextMessage(wxid, result, msgType, null);
//
//}// 用户返回用户菜单
//else if (order_caiDan.equals(msg)) {
// String wxid = null;
// if (wxMessageDataForChat.getFromtype() == 1) {
// wxid = wxMessageDataForChat.getFromwxid();
// } else if (wxMessageDataForChat.getFromtype() == 2) {
// wxid = wxMessageDataForChat.getFinalfromwxid();
// }
// String result = "";
// String puTong = getSetting(key_caiDan_user);
// String chaoJi = getSetting(key_caiDan_admin);
// if (isSuperAdminUser(wxid)) {
// result = "用户菜单：" + puTong + " 管理员菜单：" + chaoJi;
// } else {
// result = "用户菜单：" + puTong;
// }
//
// wxUtil.sendTextMessage(wxid, result, msgType, wxMessageDataForChat.getFromwxid());
//}
// wxMessageDataForChatService.save(wxMessageDataForChat);
/**
* @param wxMessage
* @return
* @throws
* @description 处理群聊消息
*/
/**
* @param wxMessage
* @return
* @throws
* @description 处理群聊消息
*/
// private void handleGroupMessage (WxMessage wxMessage){
// Integer msgType = 2;
// /**