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:
cc
2025-01-09 11:36:16 +08:00
parent 3e617ad656
commit 38ba262d9c
4 changed files with 16 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
.idea/dataSources.xml generated
View File

@@ -1,21 +1,20 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<project version="4"> <project version="4">
<component name="DataSourceManagerImpl" format="xml" multifile-model="true"> <component name="DataSourceManagerImpl" format="xml" multifile-model="true">
<data-source source="LOCAL" name="@192.168.8.88" uuid="d0f6174d-14a9-4a99-9dfa-6f782ed4fa8d"> <data-source source="LOCAL" name="jd@192.168.8.88" uuid="31c422ff-86c8-4fe9-ba98-f496d4f1b534">
<driver-ref>mysql.8</driver-ref> <driver-ref>mysql.8</driver-ref>
<synchronize>true</synchronize> <synchronize>true</synchronize>
<imported>true</imported> <imported>true</imported>
<jdbc-driver>com.mysql.cj.jdbc.Driver</jdbc-driver> <jdbc-driver>com.mysql.cj.jdbc.Driver</jdbc-driver>
<jdbc-url>jdbc:mysql://192.168.8.88:3306/?characterEncoding=utf-8&amp;useSSL=true&amp;serverTimezone=GMT</jdbc-url> <jdbc-url>jdbc:mysql://192.168.8.88:3306/jd?characterEncoding=utf-8&amp;useSSL=true&amp;serverTimezone=GMT</jdbc-url>
<jdbc-additional-properties> <jdbc-additional-properties>
<property name="com.intellij.clouds.kubernetes.db.host.port" /> <property name="com.intellij.clouds.kubernetes.db.host.port" />
<property name="com.intellij.clouds.kubernetes.db.enabled" value="false" /> <property name="com.intellij.clouds.kubernetes.db.enabled" value="false" />
<property name="com.intellij.clouds.kubernetes.db.resource.type" value="Deployment" />
<property name="com.intellij.clouds.kubernetes.db.container.port" /> <property name="com.intellij.clouds.kubernetes.db.container.port" />
</jdbc-additional-properties> </jdbc-additional-properties>
<working-dir>$ProjectFileDir$</working-dir> <working-dir>$ProjectFileDir$</working-dir>
</data-source> </data-source>
<data-source source="LOCAL" name="7@192.168.8.88" uuid="02bd8878-dd85-4337-9b25-55ca707e2a81"> <data-source source="LOCAL" name="7@192.168.8.88" uuid="a384b02a-80ce-4ca4-b73c-1bd2b6e91838">
<driver-ref>redis</driver-ref> <driver-ref>redis</driver-ref>
<synchronize>true</synchronize> <synchronize>true</synchronize>
<jdbc-driver>jdbc.RedisDriver</jdbc-driver> <jdbc-driver>jdbc.RedisDriver</jdbc-driver>

8
src/main/java/cn/van/business/util/JDUtils.java
View File

@@ -784,7 +784,7 @@ public class JDUtils {
sendOrderToWxByOrderJDAdvanced(order,fromWxid); sendOrderToWxByOrderJDAdvanced(order,fromWxid);
} }
if (content.length() > 0) { if (content.length() > 0) {
wxUtil.sendTextMessage(WXUtil.super_admin_wxid, content.toString(), 1,fromWxid); wxUtil.sendTextMessage(WXUtil.default_super_admin_wxid, content.toString(), 1,fromWxid);
} }
} }
@@ -855,13 +855,13 @@ public class JDUtils {
for (String s : split) { for (String s : split) {
content.append("https://item.jd.com/").append(s).append(".html").append("\r\n"); content.append("https://item.jd.com/").append(s).append(".html").append("\r\n");
} }
wxUtil.sendTextMessage(WXUtil.super_admin_wxid, content.toString(), 1, fromWxid); wxUtil.sendTextMessage(WXUtil.default_super_admin_wxid, content.toString(), 1, fromWxid);
content = new StringBuilder(); content = new StringBuilder();
content.append("手机端").append("\r\n"); content.append("手机端").append("\r\n");
for (String s : split) { for (String s : split) {
content.append("https://item.m.jd.com/product/").append(s).append(".html").append("\r\n"); content.append("https://item.m.jd.com/product/").append(s).append(".html").append("\r\n");
} }
wxUtil.sendTextMessage(WXUtil.super_admin_wxid, content.toString(), 1, fromWxid); wxUtil.sendTextMessage(WXUtil.default_super_admin_wxid, content.toString(), 1, fromWxid);
content = new StringBuilder(); content = new StringBuilder();
@@ -882,7 +882,7 @@ public class JDUtils {
} }
} }
if (content.length() > 0) { if (content.length() > 0) {
wxUtil.sendTextMessage(WXUtil.super_admin_wxid, content.toString(), 1, fromWxid); wxUtil.sendTextMessage(WXUtil.default_super_admin_wxid, content.toString(), 1, fromWxid);
} }
} }
//public UnionOpenGoodsBigfieldQueryResponse getUnionOpenGoodsBigfieldQueryResponse(){ //public UnionOpenGoodsBigfieldQueryResponse getUnionOpenGoodsBigfieldQueryResponse(){

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

@@ -27,7 +27,7 @@ import java.util.*;
public class WXUtil { public class WXUtil {
private static final Logger logger = LoggerFactory.getLogger(WXUtil.class); private static final Logger logger = LoggerFactory.getLogger(WXUtil.class);
public static final String super_admin_wxid = "wxid_ytpc72mdoskt22"; public static final String default_super_admin_wxid = "wxid_ytpc72mdoskt22";
public static Map<String, SuperAdmin> super_admins = new HashMap<>(); public static Map<String, SuperAdmin> super_admins = new HashMap<>();
public static Map<String, String> jdidToWxidMap = new HashMap<>(); public static Map<String, String> jdidToWxidMap = new HashMap<>();
@@ -100,6 +100,7 @@ public class WXUtil {
this.env = env; this.env = env;
WX_BASE_URL = env.getProperty("config.WX_BASE_URL"); WX_BASE_URL = env.getProperty("config.WX_BASE_URL");
System.out.println("WX_BASE_URL:" + WX_BASE_URL); System.out.println("WX_BASE_URL:" + WX_BASE_URL);
initSuperAdmins();
} }
// 获取微信列表 // 获取微信列表

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

@@ -20,7 +20,6 @@ import java.util.Objects;
import java.util.regex.Matcher; import java.util.regex.Matcher;
import java.util.regex.Pattern; import java.util.regex.Pattern;
import static cn.van.business.util.WXUtil.super_admin_wxid;
import static cn.van.business.util.WXUtil.super_admins; import static cn.van.business.util.WXUtil.super_admins;
@@ -288,11 +287,13 @@ public class WxMessageConsumer {
} }
// 只处理超管的消息 // 只处理超管的消息
String fromWxid = innerData.getFromWxid(); String fromWxid = innerData.getFromWxid();
if (!Objects.equals(fromWxid, super_admins.get(super_admin_wxid).getWxid())) { WXUtil.SuperAdmin superAdmin = super_admins.get(fromWxid);
if (Util.isEmpty(superAdmin)){
logger.info("不是超管消息，不处理"); logger.info("不是超管消息，不处理");
return; return;
} }
String msg = innerData.getMsg(); String msg = innerData.getMsg();
//美团 20-7 + https://i.meituan.com/mttouch/page/account?userId=3822095266&token=AgHdIkm2tAGHc9SQSiG7M8xCx1LbTue9D2HPOAun2eYl3ou7BeEw1uGrGZH-DxmEiUgsbA1v9SM4DQAAAAC6HAAAz0rTXmkB_CIHin08hCu68mFv5k6nUc2q6_CfZqEdBcngRK_xD8Sx5fE4rfdq-yAJ, msgbase64=576O5ZuiIDIwLTcgKyBodHRwczovL2kubWVpdHVhbi5jb20vbXR0b3VjaC9wYWdlL2FjY291bnQ/dXNlcklkPTM4MjIwOTUyNjYmdG9rZW49QWdIZElrbTJ0QUdIYzlTUVNpRzdNOHhDeDFMYlR1ZTlEMkhQT0F1bjJlWWwzb3U3QmVFdzF1R3JHWkgtRHhtRWlVZ3NiQTF2OVNNNERRQUFBQUM2SEFBQXowclRYbWtCX0NJSGluMDhoQ3U2OG1GdjVrNm5VYzJxNl9DZlpxRWRCY25nUktfeEQ4U3g1ZkU0cmZkcS15QUo= //美团 20-7 + https://i.meituan.com/mttouch/page/account?userId=3822095266&token=AgHdIkm2tAGHc9SQSiG7M8xCx1LbTue9D2HPOAun2eYl3ou7BeEw1uGrGZH-DxmEiUgsbA1v9SM4DQAAAAC6HAAAz0rTXmkB_CIHin08hCu68mFv5k6nUc2q6_CfZqEdBcngRK_xD8Sx5fE4rfdq-yAJ, msgbase64=576O5ZuiIDIwLTcgKyBodHRwczovL2kubWVpdHVhbi5jb20vbXR0b3VjaC9wYWdlL2FjY291bnQ/dXNlcklkPTM4MjIwOTUyNjYmdG9rZW49QWdIZElrbTJ0QUdIYzlTUVNpRzdNOHhDeDFMYlR1ZTlEMkhQT0F1bjJlWWwzb3U3QmVFdzF1R3JHWkgtRHhtRWlVZ3NiQTF2OVNNNERRQUFBQUM2SEFBQXowclRYbWtCX0NJSGluMDhoQ3U2OG1GdjVrNm5VYzJxNl9DZlpxRWRCY25nUktfeEQ4U3g1ZkU0cmZkcS15QUo=
if (msg.startsWith("转链")) { if (msg.startsWith("转链")) {