资金验证优化

admin

2020-08-26 26f7accb815f55f18f8eedfca4324700a96884ec

 fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderProcessServiceImpl.java

@@ -25,7 +25,6 @@
import com.google.gson.Gson;

import com.yeshi.fanli.dao.mybatis.HongBaoV2Mapper;

import com.yeshi.fanli.dao.mybatis.UserInfoMapper;

import com.yeshi.fanli.dao.mybatis.money.UserMoneyDetailMapper;

import com.yeshi.fanli.dao.mybatis.order.HongBaoOrderMapper;

import com.yeshi.fanli.dao.mybatis.order.OrderMapper;

import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoWeiQuanOrderMapper;

@@ -68,9 +67,7 @@
import com.yeshi.fanli.service.inter.elme.ElmeHongBaoOrderMapService;

import com.yeshi.fanli.service.inter.elme.ElmeOrderProcessService;

import com.yeshi.fanli.service.inter.elme.ElmeOrderService;

import com.yeshi.fanli.service.inter.hongbao.AccountDetailsHongBaoMapService;

import com.yeshi.fanli.service.inter.money.UserMoneyService;

import com.yeshi.fanli.service.inter.money.msg.UserMoneyMsgNotificationService;

import com.yeshi.fanli.service.inter.money.tb.TaoBaoWeiQuanDrawBackService;

import com.yeshi.fanli.service.inter.order.CommonOrderService;

import com.yeshi.fanli.service.inter.order.HongBaoV2Service;

@@ -83,7 +80,6 @@
import com.yeshi.fanli.service.inter.order.tb.TaoBaoOrderService;

import com.yeshi.fanli.service.inter.taobao.TaoBaoBuyRelationMapService;

import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionConfigService;

import com.yeshi.fanli.service.inter.user.UserSystemCouponService;

import com.yeshi.fanli.service.inter.user.tb.UserExtraTaoBaoInfoService;

import com.yeshi.fanli.service.manger.msg.RocketMQManager;

import com.yeshi.fanli.service.manger.order.HongBaoV2AddManager;

@@ -128,25 +124,13 @@
   private TaoBaoWeiQuanOrderMapper taoBaoWeiQuanOrderMapper;



   @Resource

   private AccountDetailsHongBaoMapService accountDetailsHongBaoMapService;



   @Resource

   private UserMoneyDetailMapper userMoneyDetailMapper;



   @Resource

   private HongBaoV2Mapper hongBaoV2Mapper;



   @Resource

   private UserMoneyMsgNotificationService userMoneyMsgNotificationService;



   @Resource

   private UserOrderMsgNotificationService userOrderMsgNotificationService;



   @Resource

   private UserExtraTaoBaoInfoService userExtraTaoBaoInfoService;



   @Resource

   private UserSystemCouponService userSystemCouponService;



   @Resource

   private UserMoneyService userMoneyService;

@@ -700,6 +684,18 @@
      } catch (OrderMoneySettleException e) {

         e.printStackTrace();

      }



      try {

         orderMoneySettleService.inviteSettleVipShop(uid, maxPreGetTime);

      } catch (OrderMoneySettleException e) {

         e.printStackTrace();

      }



      try {

         orderMoneySettleService.inviteSettleSuning(uid, maxPreGetTime);

      } catch (OrderMoneySettleException e) {

         e.printStackTrace();

      }

   }



   @Override

@@ -720,6 +716,18 @@


      try {

         orderMoneySettleService.shareSettlePDD(uid, maxPreGetTime);

      } catch (OrderMoneySettleException e) {

         e.printStackTrace();

      }



      try {

         orderMoneySettleService.shareSettleVipShop(uid, maxPreGetTime);

      } catch (OrderMoneySettleException e) {

         e.printStackTrace();

      }



      try {

         orderMoneySettleService.shareSettleSuning(uid, maxPreGetTime);

      } catch (OrderMoneySettleException e) {

         e.printStackTrace();

      }

@@ -939,7 +947,6 @@
    * @param jdOrder

    * @param uid

    */

   @Transactional

   private void processFanLiJDOrder(JDOrder jdOrder, Long uid) {

      int invalidCount = 0;

      BigDecimal totalMoney = new BigDecimal(0);

@@ -1015,11 +1022,9 @@


   /**

    * 处理京东分享订单

    * 
    * @param order

    * @param jdOrder

    * @param uid

    */

   @Transactional

   private void processShareJDOrder(JDOrder jdOrder, Long uid) {

      try {

         List<CommonOrderAddResultDTO> commonOrderList = commonOrderService.addJDOrder(jdOrder, uid);

@@ -1047,8 +1052,7 @@


   /**

    * 是否是分享赚订单

    * 
    * @param order

    * @param pddOrder

    * @return

    */

   private boolean isShareOrder(PDDOrder pddOrder) {

@@ -1086,11 +1090,9 @@


   /**

    * 处理拼多多自购返利订单

    * 
    * @param pddOrder

    * @param uid

    */

   @Transactional

   private void processFanLiPDDOrder(PDDOrder pddOrder, Long uid) {

      int orderState = 0;

      if (pddOrder.getOrderStatus() == -1 || pddOrder.getOrderStatus() == 8)

@@ -1157,11 +1159,9 @@


   /**

    * 处理拼多多分享订单

    * 
    * @param order

    * @param pddOrder

    * @param uid

    */

   @Transactional

   private void processSharePDDOrder(PDDOrder pddOrder, Long uid) {

      try {

         List<PDDOrder> pddOrderList = new ArrayList<>();

@@ -1220,11 +1220,9 @@


   /**

    * 处理京东返利订单

    * 
    * @param jdOrder

    * @param vipShopOrder

    * @param uid

    */

   @Transactional

   private void processFanLiVipShopOrder(VipShopOrder vipShopOrder, Long uid) {

      int invalidCount = 0;

      BigDecimal totalMoney = new BigDecimal(0);

@@ -1295,11 +1293,9 @@


   /**

    * 处理京东分享订单

    * 
    * @param order

    * @param jdOrder

    * @param uid

    */

   @Transactional

   private void processShareVipShopOrder(VipShopOrder jdOrder, Long uid) {

      try {

         List<CommonOrderAddResultDTO> commonOrderList = commonOrderService.addVipShopOrder(jdOrder, uid);

@@ -1351,12 +1347,10 @@
   }



   /**

    * 处理拼多多自购返利订单

    * 
    * @param pddOrder

    *  处理拼多多自购返利订单

    * @param suningOrder

    * @param uid

    */

   @Transactional

   private void processFanLiSuningOrder(SuningOrderInfo suningOrder, Long uid) {

      int orderState = 0;



@@ -1429,11 +1423,9 @@


   /**

    * 处理拼多多分享订单

    * 
    * @param order

    * @param suningOrder

    * @param uid

    */

   @Transactional

   private void processShareSuningOrder(SuningOrderInfo suningOrder, Long uid) {

      try {

         List<SuningOrderInfo> suningOrderList = new ArrayList<>();

@@ -1671,7 +1663,6 @@
    * @param sourceType

    * @param hongBaoType

    */

   @Transactional

   private void addHongBaoWithMQ(List<CommonOrderAddResultDTO> commonOrderList, String orderId, Long uid,

         int sourceType, int hongBaoType) {

      final List<CommonOrder> coList = convertCommonOrder(commonOrderList);