From af66f9797b42ae81f831d1fbf91a59463a569956 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 17 十一月 2022 19:29:36 +0800
Subject: [PATCH] 拼多多接口修改

---
 fanli/src/main/java/com/yeshi/fanli/service/impl/order/CommonOrderServiceImpl.java |   44 ++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 44 insertions(+), 0 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/order/CommonOrderServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/order/CommonOrderServiceImpl.java
index 6b2f0e1..1ce05c2 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/order/CommonOrderServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/order/CommonOrderServiceImpl.java
@@ -7,7 +7,10 @@
 import javax.annotation.Resource;
 
 import com.yeshi.fanli.entity.SystemEnum;
+import com.yeshi.fanli.entity.dy.DYOrder;
 import com.yeshi.fanli.service.inter.order.pdd.PDDOrderService;
+import com.yeshi.fanli.util.goods.douyin.CSJCPSApiUtil;
+import com.yeshi.fanli.util.goods.douyin.vo.DYGoodsDetail;
 import org.apache.commons.beanutils.PropertyUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -1321,6 +1324,47 @@
         return commonOrderList;
     }
 
+    @Override
+    public List<CommonOrderAddResultDTO> addDYOrder(DYOrder order, Long uid) throws CommonOrderException {
+        List<CommonOrderAddResultDTO> commonOrderList = new ArrayList<>();
+
+            CommonOrder newCommonOrder = CommonOrderFactory.create(order);
+            CommonOrderGoods cog = new CommonOrderGoods();
+            cog.setGoodsId(order.getProduct_id());
+            cog.setGoodsType(Constant.SOURCE_TYPE_DY);
+            newCommonOrder.setCommonOrderGoods(cog);
+            newCommonOrder.setStateWholeOrder(newCommonOrder.getState());
+            // 璁㈠崟鍟嗗搧鎻掑叆
+            List<CommonOrderGoods> commonGoodsList = commonOrderGoodsMapper.listByGoodsIdAndGoodsType(cog.getGoodsId(),
+                    cog.getGoodsType());
+            if (commonGoodsList.size() <= 0)// 涓嶅瓨鍦ㄥ氨鎻掑叆鍟嗗搧
+            {
+                DYGoodsDetail goods = CSJCPSApiUtil.goodsDetail(Long.parseLong(order.getProduct_id()));
+                if (goods == null) {
+                    goods = new DYGoodsDetail();
+                    goods.setTitle(order.getProduct_name());
+                    goods.setPrice(0);
+                    goods.setProduct_id(Long.parseLong(order.getProduct_id()));
+                    goods.setCover(order.getProduct_img());
+                }
+
+                if (goods != null) {
+                    cog = CommonOrderGoodsFactory.create(goods);
+                }
+
+                cog.setCreateTime(new Date());
+                cog.setUpdateTime(new Date());
+                commonOrderGoodsMapper.insertSelective(cog);
+            } else {
+
+            }
+            newCommonOrder.setUserInfo(new UserInfo(uid));
+            commonOrderList.add(addCommonOrder(newCommonOrder));
+
+        addConfirmMQMsg(commonOrderList);
+        return commonOrderList;
+    }
+
     private boolean needUpdateCommonOrder(CommonOrder oldCommonOrder, CommonOrder newCommonOrder) {
         // 闈炰含涓滃凡缁忕粨绠楋紝宸茬粡澶辨晥锛岀姸鎬佹湭鏀瑰彉鐨勮鍗曚笉澶勭悊
         if ((oldCommonOrder.getState() == CommonOrder.STATE_JS

--
Gitblit v1.8.0