推客分佣单入库

yanxuan-wx-store-sharer-biz/src/main/java/com/netease/yanxuan/wx/store/sharer/biz/service/impl/CommissionOrderServiceImpl.java

@@ -187,7 +187,14 @@ public class CommissionOrderServiceImpl implements ICommissionOrderService {
         if (null == detailVO) {
             return;
         }
-        SharerOrder sharerOrder = new SharerOrder();
+        LambdaQueryWrapper<SharerOrder> orderLqw = Wrappers.lambdaQuery();
+        orderLqw.eq(SharerOrder::getOrderId, detailVO.getOrder_id());
+        orderLqw.eq(SharerOrder::getSkuId, String.valueOf(detailVO.getSku_id()));
+        orderLqw.last("LIMIT 1");
+        SharerOrder sharerOrder = sharerOrderMapper.selectOne(orderLqw);
+        if(null == sharerOrder){
+            sharerOrder = new SharerOrder();
+        }
         sharerOrder.setOrderId(detailVO.getOrder_id());
         sharerOrder.setSkuId(String.valueOf(detailVO.getSku_id()));
         sharerOrder.setCommissionStatus(String.valueOf(detailVO.getStatus()));
@@ -201,9 +208,14 @@ public class CommissionOrderServiceImpl implements ICommissionOrderService {
         sharerOrder.setOrderCreateTime(getDate(detailVO.getCreate_time()));
         sharerOrder.setOrderUpdateTime(getDate(detailVO.getUpdate_time()));
         Date date = new Date();
-        sharerOrder.setCreateTime(date);
         sharerOrder.setUpdateTime(date);
+        if(null == sharerOrder.getId() || sharerOrder.getId() <= 0){
+            sharerOrder.setCreateTime(date);
             sharerOrderMapper.insert(sharerOrder);
+        }else{
+            sharerOrder.setUpdateTime(date);
+            sharerOrderMapper.updateById(sharerOrder);
+        }
         WeChatCommissionOrderDetailVO.OrderDetailVO orderDetail = detailVO.getOrder_detail();
         if (null == orderDetail) {
             log.info("[op:doSaveCommissionOrder] orderDetail is null");
@@ -222,6 +234,10 @@ public class CommissionOrderServiceImpl implements ICommissionOrderService {
      */
     private void doSaveCommissionOrderProduct(WeChatCommissionOrderDetailVO.OrderDetailVO detailVO,
                                               Long sharerOrderId) {
+        // 先删后增
+        LambdaQueryWrapper<SharerOrderProduct> delLqw = Wrappers.lambdaQuery();
+        delLqw.eq(SharerOrderProduct::getSharerOrderId, sharerOrderId);
+        sharerOrderProductMapper.delete(delLqw);
         WeChatCommissionOrderDetailVO.ProductInfoVO productInfo = detailVO.getProduct_info();
         if (null == productInfo) {
             log.info("[op:doSaveCommissionOrderProduct] productInfo is null");
@@ -245,6 +261,10 @@ public class CommissionOrderServiceImpl implements ICommissionOrderService {
      */
     private void doSaveCommissionOrderCommission(WeChatCommissionOrderDetailVO.CommissionInfoVO commissionInfo,
                                                  Long sharerOrderId) {
+        // 先删后增
+        LambdaQueryWrapper<SharerOrderCommission> delLqw = Wrappers.lambdaQuery();
+        delLqw.eq(SharerOrderCommission::getSharerOrderId, sharerOrderId);
+        sharerOrderCommissionMapper.delete(delLqw);
         if (null == commissionInfo) {
             log.info("[op:doSaveCommissionOrderCommission] commissionInfo is null");
             return;
@@ -277,6 +297,11 @@ public class CommissionOrderServiceImpl implements ICommissionOrderService {
      */
     private void doSaveCommissionOrderCommissionSharer(WeChatCommissionOrderDetailVO.SharerInfoVO sharerInfo,
                                                        Long sharerOrderId, Long sharerOrderCommissionId) {
+        // 先删后增
+        LambdaQueryWrapper<SharerOrderCommissionSharer> delLqw = Wrappers.lambdaQuery();
+        delLqw.eq(SharerOrderCommissionSharer::getSharerOrderId, sharerOrderId);
+        delLqw.eq(SharerOrderCommissionSharer::getSharerOrderCommissionId, sharerOrderCommissionId);
+        sharerOrderCommissionSharerMapper.delete(delLqw);
         if (null == sharerInfo) {
             log.info("[op:doSaveCommissionOrderCommissionSharer] sharerInfo is null");
             return;
@@ -300,6 +325,11 @@ public class CommissionOrderServiceImpl implements ICommissionOrderService {
      */
     private void doSaveCommissionOrderCommissionSubAgency(WeChatCommissionOrderDetailVO.AgencyInfoVO agencyInfo,
                                                           Long sharerOrderId, Long sharerOrderCommissionId) {
+        // 先删后增
+        LambdaQueryWrapper<SharerOrderCommissionSubAgency> delLqw = Wrappers.lambdaQuery();
+        delLqw.eq(SharerOrderCommissionSubAgency::getSharerOrderId, sharerOrderId);
+        delLqw.eq(SharerOrderCommissionSubAgency::getSharerOrderCommissionId, sharerOrderCommissionId);
+        sharerOrderCommissionSubAgencyMapper.delete(delLqw);
         if (null == agencyInfo) {
             log.info("[op:doSaveCommissionOrderCommissionSubAgency] agencyInfo is null");
             return;
@@ -323,6 +353,11 @@ public class CommissionOrderServiceImpl implements ICommissionOrderService {
      */
     private void doSaveCommissionOrderCommissionPromoterAgency(WeChatCommissionOrderDetailVO.AgencyInfoVO agencyInfo,
                                                                Long sharerOrderId, Long sharerOrderCommissionId) {
+        // 先删后增
+        LambdaQueryWrapper<SharerOrderCommissionPromoterAgency> delLqw = Wrappers.lambdaQuery();
+        delLqw.eq(SharerOrderCommissionPromoterAgency::getSharerOrderId, sharerOrderId);
+        delLqw.eq(SharerOrderCommissionPromoterAgency::getSharerOrderCommissionId, sharerOrderCommissionId);
+        sharerOrderCommissionPromoterAgencyMapper.delete(delLqw);
         if (null == agencyInfo) {
             log.info("[op:doSaveCommissionOrderCommissionPromoterAgency] agencyInfo is null");
             return;
@@ -346,6 +381,11 @@ public class CommissionOrderServiceImpl implements ICommissionOrderService {
      */
     private void doSaveCommissionOrderCommissionFinder(WeChatCommissionOrderDetailVO.FinderInfoVO finderInfo,
                                                        Long sharerOrderId, Long sharerOrderCommissionId) {
+        // 先删后增
+        LambdaQueryWrapper<SharerOrderCommissionFinder> delLqw = Wrappers.lambdaQuery();
+        delLqw.eq(SharerOrderCommissionFinder::getSharerOrderId, sharerOrderId);
+        delLqw.eq(SharerOrderCommissionFinder::getSharerOrderCommissionId, sharerOrderCommissionId);
+        sharerOrderCommissionFinderMapper.delete(delLqw);
         if (null == finderInfo) {
             log.info("[op:doSaveCommissionOrderCommissionFinder] finderInfo is null");
             return;
@@ -368,6 +408,11 @@ public class CommissionOrderServiceImpl implements ICommissionOrderService {
      */
     private void doSaveCommissionOrderCommissionTalent(WeChatCommissionOrderDetailVO.TalentInfoVO talentInfo,
                                                        Long sharerOrderId, Long sharerOrderCommissionId) {
+        // 先删后增
+        LambdaQueryWrapper<SharerOrderCommissionTalent> delLqw = Wrappers.lambdaQuery();
+        delLqw.eq(SharerOrderCommissionTalent::getSharerOrderId, sharerOrderId);
+        delLqw.eq(SharerOrderCommissionTalent::getSharerOrderCommissionId, sharerOrderCommissionId);
+        sharerOrderCommissionTalentMapper.delete(delLqw);
         if (null == talentInfo) {
             log.info("[op:doSaveCommissionOrderCommissionTalent] talentInfo is null");
             return;
@@ -391,6 +436,10 @@ public class CommissionOrderServiceImpl implements ICommissionOrderService {
      */
     private void doSaveCommissionOrderBuyer(WeChatCommissionOrderDetailVO.BuyerInfoVO buyerInfo,
                                             Long sharerOrderId) {
+        // 先删后增
+        LambdaQueryWrapper<SharerOrderBuyer> delLqw = Wrappers.lambdaQuery();
+        delLqw.eq(SharerOrderBuyer::getSharerOrderId, sharerOrderId);
+        sharerOrderBuyerMapper.delete(delLqw);
         if (null == buyerInfo) {
             log.info("[op:doSaveCommissionOrderBuyer] buyerInfo is null");
             return;