blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
admin
2020-07-01 c54fb6a88876be994906d57d2d18e844686964d0 
 fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java


@@ -1,6 +1,7 @@


package com.yeshi.fanli.service.impl.user;







import java.math.BigDecimal;



import java.text.ParseException;



import java.text.SimpleDateFormat;



import java.util.ArrayList;



import java.util.Date;



@@ -73,6 +74,7 @@


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



import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;



import com.yeshi.fanli.service.inter.user.invite.UserInviteService;



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



import com.yeshi.fanli.util.Constant;



import com.yeshi.fanli.util.MoneyBigDecimalUtil;



import com.yeshi.fanli.util.RedisManager;



@@ -177,8 +179,8 @@


   @Resource



   private UserSystemCouponActivateService userSystemCouponActivateService;







   @Resource(name = "producer")



   private Producer producer;



   @Resource



   private RocketMQManager rocketMQManager;







   @Resource



   private UserInviteService userInviteService;



@@ -317,6 +319,96 @@


      return userSystemCoupon;



   }







	


   @Override



   @Transactional(rollbackFor = Exception.class)



   public UserSystemCoupon freeCouponWinBySystem(Long uid, CouponTypeEnum typeEnum, String source, int num, boolean notify,



         Integer expiryDay, Integer activated) throws UserSystemCouponException, Exception {



      if (typeEnum == null || uid == null || StringUtil.isNullOrEmpty(source) || num < 1) {



         throw new UserSystemCouponException(1, "参数不正确");



      }







      SystemCoupon coupon = systemCouponService.getCouponByType(typeEnum.name());



      if (coupon == null) {



         throw new UserSystemCouponException(1, "券类型不正确");



      }







      // 激活状态



      // 自购免单券、赠送免单券可直接使用



      if (coupon.getType() == CouponTypeEnum.freeCouponBuy || coupon.getType() == CouponTypeEnum.freeCouponGive) {



         activated = 1;



      }







      // 有效时长



      if (expiryDay == null) {



         if (activated == 0)



            expiryDay = coupon.getActivateDay();



         if (expiryDay == null || expiryDay == 0)



            expiryDay = coupon.getExpiryDay();



      }







      // 计算结束日期



      Date nowTime = new Date();



      String endDay = DateUtil.plusDay(expiryDay - 1, nowTime);



      SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");



      if (endDay != null && endDay.trim().length() > 0) {



         endDay += " 23:59:59";



      }



      Date endTime = format.parse(endDay);







      UserSystemCoupon userSystemCoupon = null;



      for (int i = 0; i < num; i++) {



         UserSystemCoupon userCoupon = new UserSystemCoupon();



         userCoupon.setUid(uid);



         userCoupon.setSource(source);



         userCoupon.setSystemCoupon(coupon);



         userCoupon.setState(UserSystemCoupon.STATE_CAN_USE);



         userCoupon.setStateActivated(activated);



         userCoupon.setStartTime(nowTime);



         userCoupon.setEndTime(endTime);



         userCoupon.setCreateTime(nowTime);



         userCoupon.setUpdateTime(nowTime);



         userSystemCouponMapper.insertSelective(userCoupon);



         // 需要激活券



         if (typeEnum == CouponTypeEnum.freeCoupon) {



            userSystemCouponActivateService.addActivateRecord(userCoupon.getId());



         }







         if (num == 1) {



            userSystemCoupon = userCoupon;



         }



      }







      executor.execute(new Runnable() {



         @Override



         public void run() {



            if (notify) { // 消息推送



               try {



                  userOtherMsgNotificationService.freeCouponWinMsg(uid, typeEnum.getDesc(), source, num, "成功获得",



                        nowTime, endTime);



               } catch (Exception e) {



                  e.printStackTrace();



               }



            }







            // 福利中心红点



            UserInfoExtra extra = userInfoExtraService.getUserInfoExtra(uid);



            if (extra != null) {



               UserInfoExtra updateExtra = new UserInfoExtra();



               updateExtra.setId(extra.getId());



               if (extra.getCouponNews() == null) {



                  updateExtra.setCouponNews(1);



               } else {



                  updateExtra.setCouponNews(extra.getCouponNews() + 1);



               }



               userInfoExtraService.updateByPrimaryKeySelective(updateExtra);



            }



         }



      });







      return userSystemCoupon;



   }



	


   @Override



   @Transactional(rollbackFor = Exception.class)



   public UserSystemCoupon rewardCouponWin(Long uid, String source, int num, boolean notify, BigDecimal percent)



@@ -550,27 +642,24 @@


   }







   @Override



   public List<UserSystemCouponVO> getEnableListByCouponId(Long uid, Integer activated, List<SystemCoupon> couponList)



         throws UserSystemCouponException, Exception {







   public List<UserSystemCouponVO> getEnableListByCouponId(Long uid, Integer activated, List<SystemCoupon> couponList) {



      List<Long> listCouponId = new ArrayList<Long>();



      for (SystemCoupon systemCoupon : couponList) {



         listCouponId.add(systemCoupon.getId());



      }







      List<UserSystemCouponVO> listVO = userSystemCouponMapper.getEnableListByCouponId(uid, activated, listCouponId);







      if (listVO == null || listVO.size() == 0) {



         return null;



      }







		


      SimpleDateFormat sdf = new SimpleDateFormat("yyyy.MM.dd");



      SimpleDateFormat sdf2 = new SimpleDateFormat("yyyy-MM-dd");



      for (UserSystemCouponVO userCouponVO : listVO) {







         SystemCoupon systemCoupon = userCouponVO.getSystemCoupon();



         if (systemCoupon == null) {



            continue; // 券信息不完整



         }







         for (SystemCoupon coupon : couponList) {



            if (coupon.getId().equals(systemCoupon.getId()) || coupon.getId() == systemCoupon.getId()) {



               systemCoupon = coupon;



@@ -596,11 +685,15 @@


         Date startTime = userCouponVO.getStartTime();



         Date endTime = userCouponVO.getEndTime();



         if (endTime != null && startTime != null) {



            SimpleDateFormat sdf = new SimpleDateFormat("yyyy.MM.dd");



				


            couponTerm = couponTerm + sdf.format(startTime) + "-" + sdf.format(endTime);







            SimpleDateFormat sdf2 = new SimpleDateFormat("yyyy-MM-dd");



            differentDays = DateUtil.daysBetween(sdf2.format(new Date()), sdf2.format(endTime)) + 1;



			


            try {



               differentDays = DateUtil.daysBetween(sdf2.format(new Date()), sdf2.format(endTime)) + 1;



            } catch (ParseException e) {



               e.printStackTrace();



            }



            if (differentDays < 0) {



               differentDays = 0;



            }



@@ -679,6 +772,24 @@






   @Transactional(rollbackFor = Exception.class)



   @Override



   public List<UserSystemCouponVO> getFreeCouponList(Long uid) {



      // 过期券



      updateInvalidSate(uid);







      // 退回券



      sendBackTimeOutCoupon(uid);







      // 商品相关的券



      List<SystemCoupon> couponList = systemCouponService.getGoodsCouponList();



      if (couponList == null || couponList.size() == 0) {



         return null;



      }



      return getEnableListByCouponId(uid, null, couponList);



   }







	


   @Transactional(rollbackFor = Exception.class)



   @Override



   public List<UserSystemCouponVO> getGoodsCouponList(Long uid, Long auctionId)



         throws UserSystemCouponException, Exception {







@@ -728,7 +839,7 @@






      return list;



   }







	


   @Override



   public long countUsableFreeCouponForBuy(Long uid) {



      if (uid == null)



@@ -1106,7 +1217,7 @@






      // 查询记录



      UserSystemCouponRecord record = userSystemCouponRecordService.getRecordByOrderNo(orderNo,



            UserSystemCouponRecord.STATE_SUCCESS);



            sourceType, UserSystemCouponRecord.STATE_SUCCESS);



      if (record == null) {



         throw new UserSystemCouponException(1, "没有使用券记录");



      }



@@ -1184,7 +1295,7 @@


      }







      // 查询记录



      UserSystemCouponRecord record = userSystemCouponRecordService.getRecordByOrderNo(orderNo, null);



      UserSystemCouponRecord record = userSystemCouponRecordService.getRecordByOrderNo(orderNo,sourceType, null);



      if (record == null) {



         throw new UserSystemCouponException(1, "没有使用券记录");



      }



@@ -1380,18 +1491,16 @@






   @Transactional(rollbackFor = Exception.class)



   @Override



   public void updateStateByDrawback(String orderNo) throws Exception {



   public void updateStateByDrawback(String orderNo, Integer sourceType) throws Exception {







      if (orderNo == null || orderNo.trim().length() == 0) {



         return;



      }







      UserSystemCouponRecord record = userSystemCouponRecordService.getRecordByOrderNo(orderNo, null);



      UserSystemCouponRecord record = userSystemCouponRecordService.getRecordByOrderNo(orderNo,sourceType, null);



      if (record == null) {



         return;



      }







      record.setOrderNo(orderNo);



      record.setUpdateTime(new Date());



      record.setState(UserSystemCouponRecord.STATE_FAIL_DRAWBACK);



      userSystemCouponRecordService.updateByPrimaryKeySelective(record);



@@ -1402,18 +1511,15 @@






   @Transactional(rollbackFor = Exception.class)



   @Override



   public void updateStateByArrivalAccount(String orderNo) throws Exception {







   public void updateStateByArrivalAccount(String orderNo, Integer sourceType) throws Exception {



      if (orderNo == null || orderNo.trim().length() == 0) {



         return;



      }







      UserSystemCouponRecord record = userSystemCouponRecordService.getRecordByOrderNo(orderNo, 2);



      UserSystemCouponRecord record = userSystemCouponRecordService.getRecordByOrderNo(orderNo,sourceType, 2);



      if (record == null) {



         return;



      }







      record.setOrderNo(orderNo);



      record.setUpdateTime(new Date());



      record.setState(UserSystemCouponRecord.STATE_SUCCESS);



      userSystemCouponRecordService.updateByPrimaryKeySelective(record);



@@ -1426,15 +1532,13 @@






   @Transactional(rollbackFor = Exception.class)



   @Override



   public boolean updateCouponRecordUsed(Long uid, String orderNo, BigDecimal payment, Long auctionId)



   public boolean updateCouponRecordUsed(Long uid, String orderNo, BigDecimal payment, Long gId,Integer sourceType)



         throws Exception {







      boolean isfree = false;







      if (uid == null || payment == null || auctionId == null || orderNo == null || orderNo.trim().length() == 0) {



      if (uid == null || payment == null || gId == null || orderNo == null || orderNo.trim().length() == 0) {



         throw new Exception("传递参数不能为空");



      }







		


      boolean isfree = false;



      // 查询等待匹配的券记录



      List<UserSystemCouponRecord> list = userSystemCouponRecordService.getRecordByState(uid,



            UserSystemCouponRecord.STATE_WAIT);



@@ -1448,7 +1552,11 @@






      for (UserSystemCouponRecord userSystemCouponRecord : list) {



         Long goodId = userSystemCouponRecord.getGoodId();



         if (auctionId.equals(goodId)) {



         Integer goodSource = userSystemCouponRecord.getGoodSource();



         if (goodSource == null)



            continue;



				


         if (gId.equals(goodId) && goodSource == sourceType) {



            matching = true; // 匹配成功



            record = userSystemCouponRecord;



            break;



@@ -1457,7 +1565,7 @@






      // 商品匹配成功



      if (matching) {







         record.setGoodSource(sourceType);



         record.setOrderNo(orderNo);



         record.setUpdateTime(new Date());







@@ -1547,62 +1655,6 @@


      }



   }







   @Override



   @Transactional(rollbackFor = Exception.class)



   public void exchangeCoupon(Long uid, String couponType, String source, BigDecimal percent)



         throws UserSystemCouponException, Exception {



      if (couponType == null || uid == null) {



         throw new UserSystemCouponException(1, "参数不正确");



      }







      SystemCoupon coupon = null;



      if (couponType.equals(CouponTypeEnum.rebatePercentCoupon.name())) {



         coupon = systemCouponService.getCouponByTypeAndPercent(couponType, percent);



      } else {



         coupon = systemCouponService.getCouponByType(couponType);



      }







      if (coupon == null) {



         throw new UserSystemCouponException(1, "券类型不正确");



      }







      int stateActivated = 1;



      if (couponType == CouponTypeEnum.freeCoupon.name()) {



         stateActivated = 0; //



      } else if (couponType == CouponTypeEnum.welfareFreeCoupon.name()



            && threeSaleSerivce.countFirstTeam(uid) <= 0) {



         stateActivated = 0; // 无下级队员 --待激活



      }







      Integer expiryDay = null;



      if (stateActivated == 0)



         expiryDay = coupon.getActivateDay();







      if (expiryDay == null || expiryDay == 0)



         expiryDay = coupon.getExpiryDay();







      // 计算结束日期：今天在内 减去一天



      String endDay = DateUtil.plusDay(expiryDay - 1, new Date());



      SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");



      if (endDay != null && endDay.trim().length() > 0) {



         endDay += " 23:59:59";



      }



      Date endTime = format.parse(endDay);







      UserSystemCoupon userCoupon = new UserSystemCoupon();



      userCoupon.setUid(uid);



      userCoupon.setSource(source);



      userCoupon.setSystemCoupon(coupon);



      userCoupon.setStateActivated(stateActivated);



      userCoupon.setStartTime(new Date());



      userCoupon.setEndTime(endTime);



      userCoupon.setGive(false);



      userCoupon.setCreateTime(new Date());



      userCoupon.setUpdateTime(new Date());



      userCoupon.setState(UserSystemCoupon.STATE_CAN_USE);







      insertSelective(userCoupon);



   }







   @Transactional(rollbackFor = Exception.class)



   @Override



@@ -1958,9 +2010,8 @@


      msg.setCouponType(type.name());



      Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.systemCouponDrawback, msg);



      // 延迟一分钟



      message.setStartDeliverTime(endTime.getTime() + 1000 * 60);



      try {



         producer.send(message);



         rocketMQManager.sendNormalMsg(message,1000 * 60L, null);



      } catch (Exception e) {



         throw new UserSystemCouponException(1, "创建赠送信息失败");



      }



@@ -2493,4 +2544,5 @@


      }



   }











}