yujian
2019-02-28 70c9043f312a52a922cb15490d90a172b3515060
fanli/src/main/java/com/yeshi/fanli/service/impl/user/ExtractServiceImpl.java
@@ -24,6 +24,7 @@
import com.yeshi.fanli.dao.mybatis.ExtractAuditRecordMapper;
import com.yeshi.fanli.dao.mybatis.ExtractMapper;
import com.yeshi.fanli.dao.mybatis.ExtractRecordMapper;
import com.yeshi.fanli.dao.mybatis.HongBaoV2Mapper;
import com.yeshi.fanli.dao.mybatis.MoneyRecordMapper;
import com.yeshi.fanli.dao.mybatis.PayInfoMapper;
import com.yeshi.fanli.dao.mybatis.SystemMapper;
@@ -53,6 +54,7 @@
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.config.ConfigService;
import com.yeshi.fanli.service.inter.config.SystemConfigService;
import com.yeshi.fanli.service.inter.msg.UserMoneyMsgNotificationService;
import com.yeshi.fanli.service.inter.push.PushService;
import com.yeshi.fanli.service.inter.user.AccountDetailsService;
import com.yeshi.fanli.service.inter.user.AccountMessageService;
@@ -141,13 +143,19 @@
   private HongBaoMapper hongBaoMapper;
   @Resource
   private HongBaoV2Mapper hongBaoV2Mapper;
   @Resource
   private PushService pushService;
   @Resource
   private UserNotificationService userNotificationService;
   @Resource
   private UserMoneyDetailMapper userMoneyDetailMapper;
   @Resource
   private UserMoneyMsgNotificationService userMoneyMsgNotificationService;
   @Resource
   private AlipayAccountValidNormalHistoryMapper alipayAccountValidNormalHistoryMapper;
@@ -195,7 +203,7 @@
   @Transactional
   public synchronized void rejectExtract(long id, String reason, long extractTime, AdminUser admin)
         throws ObjectStateException, NotExistObjectException {
      Extract find = extractDao.find(Extract.class, id);
      Extract find = extractMapper.selectByPrimaryKey(id);
      if (find == null) {
         throw new NotExistObjectException("不存在该对象");
@@ -270,6 +278,9 @@
      } catch (Exception e) {
         e.printStackTrace();
      }
      // 新版通知
      userMoneyMsgNotificationService.extractFail(find, reason);
   }
   /**
@@ -312,7 +323,7 @@
      AccountDetails ad = AccountDetailsFactory.create("-" + extract.getMoney(), AccountDetailsFactory.TIXIAN, null,
            extract, user);
      accountDetailsMapper.insertSelective(ad);
      // 新版资金详情
      try {
         UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createExtract(extract);
@@ -325,9 +336,10 @@
            e1.printStackTrace();
         }
      }
      userNotificationService.extractApply(extract.getUserInfo().getId());
      // 添加新版通知
      userMoneyMsgNotificationService.extractApplay(extract);
      if ("是".equals(autoExtract)) {
         LogHelper.userInfo("uid=" + user.getId() + ",提交转账申请!");
@@ -478,7 +490,7 @@
         AccountDetails ad = AccountDetailsFactory.create("+" + extract.getMoney(), AccountDetailsFactory.HUIKUAN,
               null, extract, extract.getUserInfo());
         accountDetailsMapper.insertSelective(ad);
         // 新版资金详情
         try {
            UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createExtractReject(extract);
@@ -491,8 +503,6 @@
               e1.printStackTrace();
            }
         }
         try {
@@ -506,6 +516,8 @@
            e.printStackTrace();
         }
         // 新版提现
         userMoneyMsgNotificationService.extractFail(extract, null);
      }
   }
@@ -529,6 +541,7 @@
      Extract updateExtract = new Extract();
      updateExtract.setId(extract.getId());
      updateExtract.setState(Constant.EXTRACT_PASS);
      updateExtract.setReceiveTime(new Date());
      updateExtract.setReason("提现成功");
      extractMapper.updateByPrimaryKeySelective(updateExtract);
@@ -541,7 +554,8 @@
      } catch (Exception e) {
         e.printStackTrace();
      }
      // 新版通知
      userMoneyMsgNotificationService.extractSuccess(extract);
   }
   /**
@@ -554,8 +568,8 @@
   @Override
   public void checkExtract(String uid) throws ExtractException {
      int count = hongBaoMapper.getCountByUidAndState(Long.parseLong(uid), HongBao.STATE_YILINGQU);
      if (count == 0)
      Long count = hongBaoV2Mapper.countByUidAndState(Long.parseLong(uid), HongBao.STATE_YILINGQU);
      if (count == null || count == 0)
         throw new ExtractException(1, "没有已到账的红包");
      List<Integer> list = extractMapper.checkExtract(uid);
      if (list != null && list.size() > 0 && list.get(0) == 0)