From 62a447d89331aee1feae7724c7616aa1bb2cfe79 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 16 十月 2024 14:28:37 +0800
Subject: [PATCH] 将CMQ替换为rabbitmq

---
 fanli/src/main/java/com/yeshi/fanli/controller/client/v2/ShareControllerV2.java |   39 ++++++++++++++++++++++++++++-----------
 1 files changed, 28 insertions(+), 11 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/client/v2/ShareControllerV2.java b/fanli/src/main/java/com/yeshi/fanli/controller/client/v2/ShareControllerV2.java
index 8bbff8a..f8e13ff 100644
--- a/fanli/src/main/java/com/yeshi/fanli/controller/client/v2/ShareControllerV2.java
+++ b/fanli/src/main/java/com/yeshi/fanli/controller/client/v2/ShareControllerV2.java
@@ -26,6 +26,7 @@
 import com.yeshi.fanli.util.goods.douyin.DYUtil;
 import com.yeshi.fanli.util.goods.douyin.vo.DYConvertResult;
 import com.yeshi.fanli.util.goods.douyin.vo.DYGoodsDetail;
+import kafka.utils.Json;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Controller;
@@ -248,7 +249,7 @@
 
         // 鎷煎澶�
         if (goodsType == Constant.SOURCE_TYPE_PDD) {
-            createPDDShare(acceptData, uid, Long.parseLong(goodsId), source, needGoods, out);
+            createPDDShare(acceptData, uid, goodsId, source, needGoods, out);
             return;
         }
 
@@ -266,7 +267,12 @@
 
         // 鎶栭煶
         if (goodsType == Constant.SOURCE_TYPE_DY) {
-            createDYShare(acceptData, uid,Long.parseLong( goodsId), source, needGoods, out);
+            try {
+                createDYShare(acceptData, uid,Long.parseLong( goodsId), source, needGoods, out);
+            } catch (Exception e) {
+                out.print(JsonUtil.loadFalseResult("杞摼澶辫触"));
+                e.printStackTrace();
+            }
             return;
         }
 
@@ -351,6 +357,10 @@
             createTaoLijin(uid, goodsId, totalNum, relationId, acceptData, request, out);
             return;
         } else {// 鏅�氬垎浜垱寤�
+            if("鐚滀綘鍠滄".equalsIgnoreCase(source)){
+                out.print(JsonUtil.loadFalseResult(4, "鏆備笉鏀寔鍒嗕韩"));
+                return;
+            }
             createCommonTaoBaoShare(acceptData.getPlatform(), acceptData.getVersion(), goodsId, inviteCode, uid,
                     needGoods, relationId, acceptData, out);
             return;
@@ -945,7 +955,7 @@
      * @param source
      * @param out
      */
-    public void createPDDShare(AcceptData acceptData, Long uid, Long goodsId, String source, boolean needGoods,
+    public void createPDDShare(AcceptData acceptData, Long uid, String goodsId, String source, boolean needGoods,
                                PrintWriter out) {
 
         //鏌ヨ褰撳墠鐢ㄦ埛鏄惁鎺堟潈
@@ -1449,7 +1459,7 @@
      * @Description:
      */
     public void createDYShare(AcceptData acceptData, Long uid, Long goodsId, String source, boolean needGoods,
-                              PrintWriter out) {
+                              PrintWriter out) throws Exception {
         DYGoodsDetail goods = CSJCPSApiUtil.goodsDetail(goodsId);
         if (goods == null) {
             out.print(JsonUtil.loadFalseResult(1, "璇ュ晢鍝佸凡涓嬫灦"));
@@ -1459,11 +1469,12 @@
         SystemEnum system = SystemInfoUtil.getSystem(acceptData);
 
 
-        DYConvertResult convertResult = CSJCPSApiUtil.goodsConvert(goods.getDetail_url(), DYUtil.createShareExtraInfo(uid), "");
+        DYConvertResult convertResult   = CSJCPSApiUtil.goodsConvert(goods.getDetail_url(), DYUtil.createShareExtraInfo(uid), "");
+
 
         ShareInfoVO shareInfo = new ShareInfoVO();
-        shareInfo.setClickUrl(convertResult.getQrCode());
-        shareInfo.setWxErCode(convertResult.getQrCode());
+        shareInfo.setClickUrl(convertResult.getZlink());
+        shareInfo.setWxErCode(convertResult.getZlink());
         shareInfo.setCommentTexts(new ArrayList<>());
         shareInfo.setRule(configService.getValue(ConfigKeyEnum.shareRuleLinkDY.getKey(), system));
         shareInfo.setPictUrl(goods.getCover());
@@ -1623,7 +1634,7 @@
         }
 
         if (goodsType == Constant.SOURCE_TYPE_PDD) {
-            createPDDViewText(acceptData.getSystem(), goodsType, uid, template, Long.parseLong(goodsId), hasCoupon, out);
+            createPDDViewText(acceptData.getSystem(), goodsType, uid, template, goodsId, hasCoupon, out);
             return;
         }
 
@@ -1767,7 +1778,7 @@
      * @param hasCoupon
      * @param out
      */
-    private void createPDDViewText(SystemEnum system, Integer goodsType, Long uid, String template, Long goodsId, Boolean hasCoupon,
+    private void createPDDViewText(SystemEnum system, Integer goodsType, Long uid, String template, String goodsId, Boolean hasCoupon,
                                    PrintWriter out) {
         PDDGoodsDetail goods = pinDuoDuoCacheUtil.getGoodsInfo(goodsId);
         if (goods == null) {
@@ -1904,7 +1915,13 @@
             return;
         }
 
-        DYConvertResult convertResult = CSJCPSApiUtil.goodsConvert(goods.getDetail_url(),DYUtil.createShareExtraInfo(uid),"");
+        DYConvertResult convertResult = null;
+        try {
+            convertResult = CSJCPSApiUtil.goodsConvert(goods.getDetail_url(), DYUtil.createShareExtraInfo(uid),"");
+        } catch (Exception e) {
+            out.print(JsonUtil.loadFalseResult(2, "鍟嗗搧杞摼澶辫触"));
+            return;
+        }
 
 
         // 鐢熸垚鏅�氬垎浜唴瀹�
@@ -2222,7 +2239,7 @@
                 goodsDetail = GoodsDetailVOFactory.convertJDGoods(goods, paramsDTO);
             }
         } else if (goodsType == Constant.SOURCE_TYPE_PDD) {
-            PDDGoodsDetail goods = pinDuoDuoCacheUtil.getGoodsInfo(Long.parseLong(goodsId));
+            PDDGoodsDetail goods = pinDuoDuoCacheUtil.getGoodsInfo(goodsId);
             if (goods != null) {
                 goodsDetail = GoodsDetailVOFactory.convertPDDGoods(goods, paramsDTO);
             }

--
Gitblit v1.8.0