From 488eb5f64ca15837f6fb2a092461414916fc35bf Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=9B=B7=E6=AC=A7=EF=BC=88=E6=9E=97=E5=B9=B3=E5=87=A1?= =?UTF-8?q?=EF=BC=89?= Date: Fri, 15 Aug 2025 17:39:31 +0800 Subject: [PATCH] 1 --- .../controller/jd/JDInnerController.java | 9 +- .../van/business/util/JDProductService.java | 157 ++++++++++++++++-- 2 files changed, 143 insertions(+), 23 deletions(-) diff --git a/src/main/java/cn/van/business/controller/jd/JDInnerController.java b/src/main/java/cn/van/business/controller/jd/JDInnerController.java index f27481c..7aa2ee0 100644 --- a/src/main/java/cn/van/business/controller/jd/JDInnerController.java +++ b/src/main/java/cn/van/business/controller/jd/JDInnerController.java @@ -1,8 +1,7 @@ package cn.van.business.controller.jd; -import cn.van.business.controller.wx.WXListener; import cn.van.business.util.JDProductService; -import cn.van.business.util.JDUtil; +import com.alibaba.fastjson2.JSONArray; import lombok.extern.slf4j.Slf4j; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -12,8 +11,6 @@ import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; -import java.util.HashMap; -import java.util.List; import java.util.Map; /** @@ -42,13 +39,13 @@ public class JDInnerController { } @RequestMapping("/generatePromotionContent") - public HashMap> generatePromotionContent(@RequestBody Map requestBody) { + public JSONArray generatePromotionContent(@RequestBody Map requestBody) { String promotionContent = requestBody.get("promotionContent"); logger.info("generatePromotionContent message:{}", promotionContent); if (!checkSkey(skey)) { return null; } - return jdProductService.generatePromotionContent(promotionContent); + return jdProductService.generatePromotionContentAsJsonArray(promotionContent); } } diff --git a/src/main/java/cn/van/business/util/JDProductService.java b/src/main/java/cn/van/business/util/JDProductService.java index 215af6b..c4ba806 100644 --- a/src/main/java/cn/van/business/util/JDProductService.java +++ b/src/main/java/cn/van/business/util/JDProductService.java @@ -5,7 +5,10 @@ import cn.van.business.model.cj.XbMessageItem; import cn.van.business.repository.XbMessageItemRepository; import cn.van.business.repository.XbMessageRepository; import com.alibaba.fastjson2.JSON; +import com.alibaba.fastjson2.JSONArray; import com.alibaba.fastjson2.JSONObject; +import java.util.regex.Matcher; +import java.util.regex.Pattern; import com.jd.open.api.sdk.DefaultJdClient; import com.jd.open.api.sdk.JdClient; import com.jd.open.api.sdk.domain.kplunion.CouponService.request.get.CreateGiftCouponReq; @@ -127,23 +130,9 @@ public class JDProductService { itemMap.put("spuid", String.valueOf(productInfo.getData()[0].getSpuid())); itemMap.put("commission", String.valueOf(productInfo.getData()[0].getCommissionInfo().getCommission())); itemMap.put("commissionShare", String.valueOf(productInfo.getData()[0].getCommissionInfo().getCommissionShare())); - //for (HashMap.Entry entry : itemMap.entrySet()) { - //couponInfo.append(" ").append(entry.getKey()).append(": ").append(entry.getValue()).append("\n"); - //} + couponInfo.append("店铺： ").append(itemMap.get("shopName")).append("\n").append("标题： ").append(replaceAll).append("\n").append("自营 POP： ").append(itemMap.get("owner").equals("g") ? " 自营 " : " POP ").append("\n").append("佣金比例： ").append(itemMap.get("commissionShare")).append("\n").append("佣金： ").append(itemMap.get("commission")).append("\n"); - - //StringBuilder images = new StringBuilder(); - if (productInfo.getData()[0].getImageInfo() != null) { - //images.append(" ").append("图片信息：\n"); - //int index = 1; - - for (UrlInfo image : productInfo.getData()[0].getImageInfo().getImageList()) { - //images.append("图片 ").append(index++).append("\n").append(image.getUrl()).append("\n"); - imagesList.add(image.getUrl()); - } - } - //textList.add(String.valueOf(images)); resultList.add(itemMap); String title = ""; @@ -193,7 +182,7 @@ public class JDProductService { finallyMessage.put("urlList", urlList); } catch (Exception e) { - logger.error("处理商品链接时发生异常：{}", url, e); + log.error("处理商品链接时发生异常：{}", url, e); couponInfo.append(" 处理商品链接时发生异常：").append(url).append("\n"); textList.add(String.valueOf(couponInfo)); finallyMessage.put("text", textList); @@ -217,6 +206,140 @@ public class JDProductService { } + /** + * 生成转链和方案的方法（JSON数组格式） + * + * @param message 方案内容，包含商品链接 + * @return 处理后的方案，以标准JSON数组格式返回，每个商品及其文案为一个独立对象 + */ + public synchronized JSONArray generatePromotionContentAsJsonArray(String message) { + JSONArray resultArray = new JSONArray(); + + // 提取方案中的所有 u.jd.com 链接 + List urls = extractUJDUrls(message); + if (urls.isEmpty()) { + JSONObject errorObj = new JSONObject(); + errorObj.put("error", "方案中未找到有效的商品链接，请检查格式是否正确。"); + resultArray.add(errorObj); + return resultArray; + } + + String format = null; + DateFormat dateFormat = new SimpleDateFormat("yyyy年MM月dd日HH时mm分ss秒"); + + for (String url : urls) { + try { + // 新建格式好日期 + format = dateFormat.format(new Date()); + + // 查询商品信息 + GoodsQueryResult productInfo = queryProductInfoByUJDUrl(url); + if (productInfo == null || productInfo.getCode() != 200) { + JSONObject errorObj = new JSONObject(); + errorObj.put("url", url); + errorObj.put("error", "链接查询失败"); + resultArray.add(errorObj); + continue; + } + + long totalCount = productInfo.getTotalCount(); + if (totalCount == 0) { + JSONObject errorObj = new JSONObject(); + errorObj.put("url", url); + errorObj.put("error", "未找到商品信息"); + resultArray.add(errorObj); + continue; + } + + // 创建商品对象 + JSONObject productObj = new JSONObject(); + productObj.put("url", url); + + // 商品基本信息 + productObj.put("materialUrl", productInfo.getData()[0].getMaterialUrl()); + productObj.put("oriItemId", productInfo.getData()[0].getOriItemId()); + productObj.put("owner", productInfo.getData()[0].getOwner()); + productObj.put("shopId", String.valueOf(productInfo.getData()[0].getShopInfo().getShopId())); + productObj.put("shopName", productInfo.getData()[0].getShopInfo().getShopName()); + productObj.put("skuName", productInfo.getData()[0].getSkuName()); + String cleanSkuName = productInfo.getData()[0].getSkuName().replaceAll("以旧|政府|换新|领取|国家|补贴|15%|20%|国补|立减|【|】", ""); + productObj.put("cleanSkuName", cleanSkuName); + productObj.put("spuid", String.valueOf(productInfo.getData()[0].getSpuid())); + productObj.put("commission", String.valueOf(productInfo.getData()[0].getCommissionInfo().getCommission())); + productObj.put("commissionShare", String.valueOf(productInfo.getData()[0].getCommissionInfo().getCommissionShare())); + + // 图片信息 + JSONArray imageArray = new JSONArray(); + if (productInfo.getData()[0].getImageInfo() != null) { + for (UrlInfo image : productInfo.getData()[0].getImageInfo().getImageList()) { + imageArray.add(image.getUrl()); + } + } + productObj.put("images", imageArray); + + // 文案信息 + JSONArray wenanArray = new JSONArray(); + + String title = ""; + try { + if (!message.equals(url)) { + String[] lines = message.split("\\r?\\n"); + if (lines.length > 0) { + title = lines[0]; + // 有的换行了 + if (lines[1].length() > 3 && !lines[1].contains("u.jd")) { + title = title + lines[1]; + } + title = title.replaceAll("@|所有人", ""); + } + } + } catch (Exception e) { + log.error("文案首行异常", e); + } + + // 生成各种文案 + JSONObject wenan1 = new JSONObject(); + wenan1.put("type", "标价到手-方案1"); + wenan1.put("content", "(标价到手) " + title + cleanSkuName + "\n" + WENAN_FANAN_LQD.replaceAll("更新", format + "更新")); + wenanArray.add(wenan1); + + JSONObject wenan2 = new JSONObject(); + wenan2.put("type", "一键代下"); + wenan2.put("content", "(一键代下) " + title + cleanSkuName + "\n" + WENAN_ZCXS); + wenanArray.add(wenan2); + + JSONObject wenan3 = new JSONObject(); + wenan3.put("type", "标价到手-方案2"); + wenan3.put("content", "(标价到手) " + title + cleanSkuName + "\n" + WENAN_FANAN_HG.replaceAll("更新", format + "更新")); + wenanArray.add(wenan3); + + JSONObject wenan4 = new JSONObject(); + wenan4.put("type", "教你下单"); + wenan4.put("content", "【教你下单】 " + title + cleanSkuName + "\n" + WENAN_FANAN_BX.replaceAll("信息更新日期：", "信息更新日期：" + format)); + wenanArray.add(wenan4); + + productObj.put("wenan", wenanArray); + + // 添加通用文案 + JSONObject commonWenan = new JSONObject(); + commonWenan.put("type", "通用文案"); + commonWenan.put("content", format + FANAN_COMMON + message); + wenanArray.add(commonWenan); + + resultArray.add(productObj); + + } catch (Exception e) { + log.error("处理商品链接时发生异常：{}", url, e); + JSONObject errorObj = new JSONObject(); + errorObj.put("url", url); + errorObj.put("error", "处理商品链接时发生异常：" + e.getMessage()); + resultArray.add(errorObj); + } + } + + return resultArray; + } + /** * 查询商品信息 * @@ -394,7 +517,7 @@ public class JDProductService { public void saveGiftCouponToRedis(String skuId, String giftKey, String skuName, String owner) { String key = "gift_coupon:" + skuId; String hashKey = giftKey; - LocalDateTime expireTime = LocalDateTime.now().plus("g".equals(owner) ? 1 : 7, TimeUnit.DAYS.toChronoUnit()); + LocalDateTime expireTime = LocalDateTime.now().plus(owner.equals("g") ? 0 : 7, java.time.temporal.ChronoUnit.DAYS); Map data = new HashMap<>(); data.put("giftKey", giftKey);