订单bug，分享爆款自购修改

admin

2019-07-11 3824cbcaec6e6c67418d5280a53e9c2fedeef6f9

 fanli/src/main/java/com/yeshi/fanli/service/impl/user/ExtractServiceImpl.java

@@ -28,6 +28,7 @@
import com.yeshi.fanli.dao.mybatis.UserInfoMapper;

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

import com.yeshi.fanli.dto.HongBao;

import com.yeshi.fanli.dto.money.ExtractOrderStatisticDTO;

import com.yeshi.fanli.entity.bus.user.AlipayTransferResultInfo;

import com.yeshi.fanli.entity.bus.user.Extract;

import com.yeshi.fanli.entity.bus.user.ExtractAuditRecord;

@@ -49,12 +50,14 @@
import com.yeshi.fanli.service.inter.hongbao.HongBaoV2Service;

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

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

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

import com.yeshi.fanli.service.inter.push.PushService;

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

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

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

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

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

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

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

import com.yeshi.fanli.util.CMQManager;

import com.yeshi.fanli.util.Constant;

@@ -128,6 +131,12 @@
   @Resource

   private UserMoneyDebtService userMoneyDebtService;



   @Resource

   private UserMoneyService userMoneyService;



   @Resource

   private OrderUserStatisticService orderUserStatisticService;



   @Transactional

   public Integer addExtract(Extract extract) {

      Integer integer = extract(extract);

@@ -169,8 +178,15 @@


      UserInfo user = find.getUserInfo();



      userInfoMapper.addHongBaoByUid(user.getId(), find.getMoney());

      UserMoneyDetail userMoneyDetail = null;

      try {

         userMoneyDetail = UserMoneyDetailFactory.createExtractReject(find);

      } catch (UserMoneyDetailException e1) {

         e1.printStackTrace();

      }



      // 增加资金

      userMoneyService.addUserMoney(user.getId(), find.getMoney(), userMoneyDetail);

      // 更新原来的状态

      Extract updateExtract = new Extract();

      updateExtract.setId(id);

@@ -207,16 +223,6 @@
      // 更新提现记录审核表

      extractAuditRecordMapper.updateByPrimaryKeySelective(auditRecord);

      // 新版资金详情

      try {

         UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createExtractReject(find);

         userMoneyDetailMapper.insert(userMoneyDetail);

      } catch (UserMoneyDetailException e2) {

         try {

            LogHelper.errorDetailInfo(e2);

         } catch (Exception e3) {

            e3.printStackTrace();

         }

      }



      try {

         userNotificationService.extractWrong(user.getId(), find,

@@ -254,24 +260,38 @@
         return 3;

      }



      // 有借贷关系

      boolean isHaveToReplay = userMoneyDebtService.isHaveDebtToRepay(extract.getUserInfo().getId());

      if (isHaveToReplay) {

         return 110;

      }



      Integer type = setExtractRecord(extract, maxCount, maxMoney);

      if (type != 0) {

         return type;

      }



      extractMapper.insertSelective(extract);



      ExtractAuditRecord auditRecord = new ExtractAuditRecord();

      auditRecord.setBeforeMoney(user.getMyHongBao());

      auditRecord.setExtract(extract);



      Date minTime = new Date(System.currentTimeMillis() - 1000 * 60 * 60 * 24 * 180L);

      // 统计数据

      int orderCount50More = orderUserStatisticService.countOrderCount100MoreByUidAndMinTime(user.getId(), minTime);



      BigDecimal weiQuanOrderFanAmount = orderUserStatisticService.sumWeiQuanOrderFanAmountByUid(user.getId(),

            minTime);

      int weiQuanOrderCount = orderUserStatisticService.countWeiQuanOrderByUid(user.getId(), minTime);

      auditRecord.setExtraInfoStr(new Gson()

            .toJson(new ExtractOrderStatisticDTO(orderCount50More, weiQuanOrderCount, weiQuanOrderFanAmount, 0)));

      extractAuditRecordMapper.insertSelective(auditRecord);



      // 减去账户资金

      userInfoMapper.subHongBaoByUid(extract.getUserInfo().getId(), extract.getMoney());



      // 新版资金详情

      UserMoneyDetail userMoneyDetail = null;

      try {

         UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createExtract(extract);

         userMoneyDetailMapper.insert(userMoneyDetail);

         userMoneyDetail = UserMoneyDetailFactory.createExtract(extract);

      } catch (UserMoneyDetailException e2) {

         try {

            LogHelper.errorDetailInfo(e2);

@@ -280,6 +300,9 @@
         }

      }



      // 减去账户资金

      userMoneyService.subUserMoney(extract.getUserInfo().getId(), extract.getMoney(), userMoneyDetail);



      userNotificationService.extractApply(extract.getUserInfo().getId());

      // 添加新版通知

      userMoneyMsgNotificationService.extractApplay(extract);

@@ -287,7 +310,8 @@
      if ("是".equals(autoExtract)) {

         LogHelper.userInfo("uid=" + user.getId() + ",提交转账申请!");

      } else {// 暂时不自动提现

         transfer(extract, null);

         // transfer(extract, null);

         ;

      }

      return null;

   }

@@ -428,12 +452,10 @@
         updateExtract.setReason(msg);

         extractMapper.updateByPrimaryKeySelective(updateExtract);



         userInfoMapper.addHongBaoByUid(user.getId(), extract.getMoney());



         UserMoneyDetail userMoneyDetail = null;

         // 新版资金详情

         try {

            UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createExtractReject(extract);

            userMoneyDetailMapper.insert(userMoneyDetail);

            userMoneyDetail = UserMoneyDetailFactory.createExtractReject(extract);

         } catch (UserMoneyDetailException e2) {

            try {

               LogHelper.errorDetailInfo(e2);

@@ -441,6 +463,8 @@
               e1.printStackTrace();

            }

         }

         // 增加资金

         userMoneyService.addUserMoney(user.getId(), extract.getMoney(), userMoneyDetail);



         try {



@@ -507,9 +531,14 @@
   @Transactional

   @Override

   public void checkExtract(Long uid) throws ExtractException {

      BigDecimal compensateMoney = extractMapper.computeCompensateByUid(uid);

      if (compensateMoney == null)

         compensateMoney = new BigDecimal(0);

      // 不判定到账红包问题

      Long count = hongBaoV2Mapper.countByUidAndState(uid, HongBao.STATE_YILINGQU);

      if (count == null || count == 0)

      if ((count == null || count == 0) && compensateMoney.compareTo(new BigDecimal(0)) == 0) {

         throw new ExtractException(1, "没有已到账的红包");

      }

      // 查询是否有欠账

      boolean isDebt = userMoneyDebtService.isHaveDebtToRepay(uid);

      if (isDebt)

@@ -538,10 +567,6 @@
      weiqaunMoney = weiqaunMoney.abs();



      BigDecimal balance = userInfoService.selectByPKey(uid).getMyHongBao();



      BigDecimal compensateMoney = extractMapper.computeCompensateByUid(uid);

      if (compensateMoney == null)

         compensateMoney = new BigDecimal(0);



      BigDecimal after = hongBaoMoney.subtract(extractMoney.add(weiqaunMoney).add(balance).add(compensateMoney));



@@ -709,7 +734,7 @@
   }



   @Override

   public double countTodayMoney(Long uid) {

      return extractMapper.countTodayMoney(uid);

   public BigDecimal sumTodayApplyMoney(Long uid,String day) {

      return extractMapper.sumToadyApplyByUid(uid,day);

   }

}