多线报来源
This commit is contained in:
Van0313
@@ -47,8 +47,7 @@ import java.util.stream.Stream;
|
||||
|
||||
import static cn.van.business.util.JDUtil.UserInteractionState.GiftMoneyStep.*;
|
||||
import static cn.van.business.util.JDUtil.UserInteractionState.ProcessState.INIT;
|
||||
import static cn.van.business.util.WXUtil.chatRoom_BY;
|
||||
import static cn.van.business.util.WXUtil.getSuperAdmins;
|
||||
import static cn.van.business.util.WXUtil.*;
|
||||
|
||||
/**
|
||||
* @author Leo
|
||||
@@ -79,15 +78,7 @@ public class JDUtil {
|
||||
private static final String INTERACTION_STATE_PREFIX = "interaction_state:";
|
||||
private static final long TIMEOUT_MINUTES = 10;
|
||||
private static final String WENAN_FANAN_LQD = "提供方法自己下单\n" + "全程都是自己的账号下单\n" + "标价就是下单的到手价\n" + "本人有耐心，会一步一步提供教程\n" + "以后有什么质量问题都是用自己的账号走京东售后\n" + "\n" + "更新\n" + "\n" + "用你自己的账号下单\n" + "官方店铺 提供方法自己下单\n" + "——————————————————————————————————————————\n" + "同行可长久合作，可提供神级家电线报\n" + "\n" + "配合家电线报可以自己下单，不用找代购和代下，订单和利润都掌握在自己手中。\n" + "\n" + "一次入会永久使用，包含家电帮，雷神价，韭菜帮，河南&湖南帮，各种暗号帮后返等内部独家家电线报\n" + "\n" + "JD采销采购不定时发放独家优惠券\n" + "\n" + "基本上你能看到的京东家电低价都是从这些渠道里面出来。\n" + "\n" + "2025年家电项目新方向，配合家电线报下单，秒省1K+。";
|
||||
private static final String WENAN_FANAN_HG = "手把手教你实现超值下单，无需依赖他人！全程使用个人专属账号操作，所见即所得，页面标价即为最终到手价。别担心操作难题，我会全程贴心指导，每一步都细致讲解，助你轻松下单。后续若出现任何质量问题，凭借个人账号就能直接对接JD官方售后，售后无忧。\n" +
|
||||
"更新\n" +
|
||||
"采用自主账号下单模式，官方店铺商品随心购，专业方法全程提供！\n" +
|
||||
"——————————————————————————————————————————\n" +
|
||||
"诚邀同行建立长期合作关系，海量独家家电优惠线报倾囊相授！\n" +
|
||||
"借助这些优质家电线报，无需寻求代购代下服务，自己就能轻松下单，订单信息与收益牢牢掌握在手中。\n" +
|
||||
"一次加入，终身受益！涵盖家电帮、雷神价、韭菜帮、河南 & 湖南帮等众多渠道，还有各类暗号帮后返等内部专属家电优惠信息一网打尽。\n" +
|
||||
"JD采销团队会不定时发放独家隐藏优惠券，市面上那些令人心动的JD家电低价好物，大多都源自这些渠道！\n" +
|
||||
"2025 年家电选购新趋势，依托线报下单，轻松省下千元开支，开启超值购物之旅！";
|
||||
private static final String WENAN_FANAN_HG = "手把手教你实现超值下单，无需依赖他人！全程使用个人专属账号操作，所见即所得，页面标价即为最终到手价。别担心操作难题，我会全程贴心指导，每一步都细致讲解，助你轻松下单。后续若出现任何质量问题，凭借个人账号就能直接对接JD官方售后，售后无忧。\n" + "更新\n" + "采用自主账号下单模式，官方店铺商品随心购，专业方法全程提供！\n" + "——————————————————————————————————————————\n" + "诚邀同行建立长期合作关系，海量独家家电优惠线报倾囊相授！\n" + "借助这些优质家电线报，无需寻求代购代下服务，自己就能轻松下单，订单信息与收益牢牢掌握在手中。\n" + "一次加入，终身受益！涵盖家电帮、雷神价、韭菜帮、河南 & 湖南帮等众多渠道，还有各类暗号帮后返等内部专属家电优惠信息一网打尽。\n" + "JD采销团队会不定时发放独家隐藏优惠券，市面上那些令人心动的JD家电低价好物，大多都源自这些渠道！\n" + "2025 年家电选购新趋势，依托线报下单，轻松省下千元开支，开启超值购物之旅！";
|
||||
private static final String WENAN_ZCXS = "\n" + "购买后，两小时内出库，物流会电话联系您，同时生成京东官方安装单。送装一体，无需担心。\n" + "\n" + "\n" + "1:全新正品，原包装未拆封(京东商城代购，就近直发)\n" + "2:可提供下单运单号与电子发票（发票在收到货后找我要）。\n" + "3:收货时查看是否有质量或运损问题。可拍照让京东免费申请换新。\n" + "4:下单后非质量问题不支持退款退货，强制退扣100元。\n" + "5:价格有浮动，不支持补差价，谢谢理解。\n" + "6:全国联保，全国统一安装标准。支持官方 400，服务号查询，假一赔十。\n";
|
||||
private static final String FANAN_COMMON = "\n复制到薇，依次领券，到J东APP结算\n" + "换新选生活电器-除螨仪，可免回收\n";
|
||||
/**
|
||||
@@ -173,11 +164,12 @@ public class JDUtil {
|
||||
// 具体逻辑
|
||||
}
|
||||
|
||||
public void cjwlm(String message) {
|
||||
logger.info("执行 cjwlm 方法，order: {}", message);
|
||||
public void xb(String message, String fromWxid) {
|
||||
logger.info("执行 线报处理 方法，order: {}", message);
|
||||
if (message.contains("https://u.jd")) {
|
||||
// 生成当前时间格式
|
||||
wxUtil.sendTextMessage(chatRoom_BY, " \n " + message, 1, chatRoom_BY, true);
|
||||
String chatRoomRemark = chatRoom_xb.get(fromWxid);
|
||||
|
||||
wxUtil.sendTextMessage(chatRoom_BY, "线报来源 \n " + chatRoomRemark + "\n\n " + message, 1, chatRoom_BY, true);
|
||||
|
||||
// 2. 生成推广内容
|
||||
HashMap<String, List<String>> contentResult = generatePromotionContent(message, true);
|
||||
@@ -187,18 +179,6 @@ public class JDUtil {
|
||||
wxUtil.sendTextMessage(chatRoom_BY, text, 1, chatRoom_BY, true);
|
||||
}
|
||||
|
||||
// 4. 发送图片（如果有）
|
||||
//List<String> images = contentResult.get("images");
|
||||
//if (images != null) {
|
||||
// for (String imageUrl : images) {
|
||||
// if (imageUrl != null) {
|
||||
// wxUtil.sendImageMessage(chatRoom_BY, imageUrl);
|
||||
// }
|
||||
// }
|
||||
//}
|
||||
//wxUtil.sendTextMessage(chatRoom_BY, "[爱心]---采集完成---[爱心]", 1, chatRoom_BY, true);
|
||||
|
||||
|
||||
}
|
||||
// 具体逻辑
|
||||
}
|
||||
@@ -777,8 +757,7 @@ public class JDUtil {
|
||||
String finalWenAn = cacheMap.get("finalWenAn" + wxid);
|
||||
|
||||
if (productDataJson == null || finalWenAn == null) {
|
||||
logger.error("数据丢失 - productData: {}, finalWenAn: {}",
|
||||
productDataJson != null, finalWenAn != null);
|
||||
logger.error("数据丢失 - productData: {}, finalWenAn: {}", productDataJson != null, finalWenAn != null);
|
||||
wxUtil.sendTextMessage(wxid, "数据丢失，请重新开始流程", 1, wxid, false);
|
||||
resetState(wxid, state);
|
||||
return;
|
||||
@@ -878,10 +857,7 @@ public class JDUtil {
|
||||
cacheMap.put("finalWenAn" + wxid, contentResult.get("finalWenAn").get(0));
|
||||
|
||||
state.setCurrentField("confirm");
|
||||
wxUtil.sendTextMessage(wxid,
|
||||
"检测到" + jsonObjectArr.size() + "个商品\n" +
|
||||
"是否需要开通礼金？\n回复 1 - 是\n回复 2 - 否",
|
||||
1, wxid, false);
|
||||
wxUtil.sendTextMessage(wxid, "检测到" + jsonObjectArr.size() + "个商品\n" + "是否需要开通礼金？\n回复 1 - 是\n回复 2 - 否", 1, wxid, false);
|
||||
} else {
|
||||
wxUtil.sendTextMessage(wxid, "未获取到商品数据，请检查链接格式", 1, wxid, false);
|
||||
state.reset();
|
||||
|
||||
@@ -38,10 +38,12 @@ public class WXUtil {
|
||||
public static Map<String, String> jdidToWxidMap = new HashMap<>();
|
||||
public static Map<String, String> jdidToRemarkMap = new HashMap<>();
|
||||
|
||||
public static List<String> chatRoomList = new ArrayList<>();
|
||||
//玩乐买
|
||||
public static String chatRoom_WLM = "23143922156@chatroom";
|
||||
//搬运群
|
||||
// 群聊管理白名单
|
||||
public static List<String> chatRoom_admin = new ArrayList<>();
|
||||
// 线报来源群
|
||||
public static Map<String, String> chatRoom_xb = new HashMap<>();
|
||||
|
||||
// 搬运群，对外带佣金，不带方案
|
||||
public static String chatRoom_BY = "50400969285@chatroom";
|
||||
/**
|
||||
* url http://127.0.0.1:7777/DaenWxHook/httpapi/
|
||||
@@ -162,15 +164,25 @@ public class WXUtil {
|
||||
jdidToRemarkMap.put(admin8.getUnionId(), admin8.getName());
|
||||
|
||||
|
||||
/* 内部管理群 */
|
||||
|
||||
// 方案
|
||||
chatRoomList.add("50400969285@chatroom");
|
||||
chatRoom_admin.add("50400969285@chatroom");
|
||||
// 闲鱼
|
||||
chatRoomList.add("50203565991@chatroom");
|
||||
chatRoom_admin.add("50203565991@chatroom");
|
||||
// 什么都发253|20:09:07|wxid_kr145nk7l0an31|收到群聊|群（49533691813@chatroom）wxid_cfmrk2upjtf322：1
|
||||
chatRoomList.add("49533691813@chatroom");
|
||||
//wxTsUtil.sendNotify("initSuperAdmins 初始化完成");
|
||||
//发送通知到微信
|
||||
chatRoom_admin.add("49533691813@chatroom");
|
||||
//群（44960628585@chatroom）wxid_ytpc72mdoskt22 方案交互群
|
||||
chatRoom_admin.add("44960628585@chatroom");
|
||||
|
||||
|
||||
/* 线报采集来源群 */
|
||||
// 玩了买
|
||||
chatRoom_xb.put("23143922156@chatroom", "玩乐买");
|
||||
// 舵手
|
||||
chatRoom_xb.put("44960628585@chatroom", "舵手");
|
||||
|
||||
//发送通知到微信
|
||||
sendTextMessage(default_super_admin_wxid, "Jarvis 重启完成 [亲亲][亲亲][亲亲] ", 1, default_super_admin_wxid, false);
|
||||
|
||||
}
|
||||
|
||||
@@ -274,12 +274,12 @@ public class WxMessageConsumer {
|
||||
String fromWxid = innerData.getFromWxid();
|
||||
String msg = innerData.getMsg();
|
||||
|
||||
if (chatRoom_WLM.equals(fromWxid)) {
|
||||
logger.info("玩了买线报群消息");
|
||||
jdUtils.cjwlm(msg);
|
||||
if (chatRoom_xb.containsKey(fromWxid)) {
|
||||
logger.info("线报群消息");
|
||||
jdUtils.xb(msg,fromWxid);
|
||||
return;
|
||||
}
|
||||
if (!chatRoomList.contains(fromWxid)) {
|
||||
if (!chatRoom_admin.contains(fromWxid)) {
|
||||
logger.info("不是白名单群聊，不处理");
|
||||
return;
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user