有赞订单解析，用户对应的直推表中累计消费、当月消费自字段处理

wisenergy-service/src/main/java/cn/wisenergy/service/app/impl/OrderServiceImpl.java

@@ -3,8 +3,10 @@ package cn.wisenergy.service.app.impl;
 import cn.wisenergy.common.constant.CommonAttributes;
 import cn.wisenergy.common.utils.R;
 import cn.wisenergy.mapper.OrderMapper;
+import cn.wisenergy.mapper.RecommendUserMapper;
 import cn.wisenergy.mapper.UsersMapper;
 import cn.wisenergy.model.app.OrderInfo;
+import cn.wisenergy.model.app.RecommendUser;
 import cn.wisenergy.model.dto.AccountInfoQuery;
 import cn.wisenergy.model.dto.OrderInfoQuery;
 import cn.wisenergy.service.app.OrderService;
@@ -48,6 +50,9 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, OrderInfo> implem
 
     @Autowired
     private UsersMapper usersMapper;
+
+    @Autowired
+    private RecommendUserMapper recommendUserMapper;
     //有赞客户端
     DefaultYZClient yzClient = new DefaultYZClient();
     SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@@ -136,6 +141,20 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, OrderInfo> implem
             orderInfo.setSuccessTime(youzanOrderInfo.getSuccessTime());
             //payment
             orderInfo.setPayment(new BigDecimal(payInfo.getPayment()));
+            //当前订单所对应的用户直推表当月消费  累计消费字段累加
+            RecommendUser recommendUserMapperByUserId = recommendUserMapper.getByUserId(userId);
+            if (null != recommendUserMapperByUserId){
+                //历史消费
+                BigDecimal historyCount = recommendUserMapperByUserId.getHistoryCount();
+
+                //当月消费
+                BigDecimal monthyCount = recommendUserMapperByUserId.getMonthyCount();
+
+                recommendUserMapperByUserId.setHistoryCount(historyCount.add(new BigDecimal(payInfo.getPayment())));
+                recommendUserMapperByUserId.setMonthyCount(monthyCount.add(new BigDecimal(payInfo.getPayment())));
+
+                recommendUserMapper.updateById(recommendUserMapperByUserId);
+            }
             //rebate_status  返佣状态
             orderInfo.setRebateStatus(0);
             //level_status  升级状态