yujian
2019-12-10 c8041ec0544bf122e6819e6bf698997ccbf30aaf
fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java
@@ -49,7 +49,6 @@
import com.yeshi.fanli.entity.system.SystemCoupon;
import com.yeshi.fanli.entity.system.SystemCoupon.CouponTypeEnum;
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
import com.yeshi.fanli.exception.user.UserInfoExtraException;
import com.yeshi.fanli.exception.user.UserSystemCouponException;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.common.JumpDetailV2Service;
@@ -155,6 +154,7 @@
   @Resource
   private UserOtherMsgNotificationService userOtherMsgNotificationService;
   @Lazy
   @Resource
   private CommonOrderCountService commonOrderCountService;
@@ -180,6 +180,7 @@
   @Resource(name = "producer")
   private Producer producer;
   
   @Lazy
   @Resource
   private UserVIPInfoService userVIPInfoService;
@@ -253,6 +254,8 @@
         } else {
            coupon = systemCouponService.getCouponByTypeAndPercent(couponType, percent);
         }
      } else if (couponType.equals(CouponTypeEnum.freeCouponGive.name())) {
         coupon = systemCouponService.getCouponByType(couponType);
      }
      if (coupon == null) {
@@ -305,23 +308,18 @@
      executor.execute(new Runnable() {
         @Override
         public void run() {
            UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
            // 添加一条消息
            if (userInfoExtra != null) {
               if (userInfoExtra.getCouponNews() == null) {
                  userInfoExtra.setCouponNews(1);
         public void run() {  // 福利中心红点
            UserInfoExtra extra = userInfoExtraService.getUserInfoExtra(uid);
            if (extra != null) {
               UserInfoExtra updateExtra =   new UserInfoExtra();
               updateExtra.setId(extra.getId());
               if (extra.getCouponNews() == null) {
                  updateExtra.setCouponNews(1);
               } else {
                  userInfoExtra.setCouponNews(userInfoExtra.getCouponNews() + 1);
                  updateExtra.setCouponNews(extra.getCouponNews() + 1);
               }
               try {
                  userInfoExtraService.saveUserInfoExtra(userInfoExtra);
               } catch (UserInfoExtraException e) {
                  e.printStackTrace();
               }
               userInfoExtraService.updateByPrimaryKeySelective(updateExtra);
            }
         }
      });
@@ -705,6 +703,26 @@
      return userSystemCouponMapper.countUsableByUid(uid, listCouponId);
   }
   @Override
   public long countGiveFreeCoupon(Long uid) {
      if (uid == null)
         return 0;
      List<SystemCoupon> couponList = systemCouponService.getGiveFreeCouponList();
      if (couponList == null || couponList.size() == 0)
         return 0;
      List<Long> listCouponId = new ArrayList<Long>();
      for (SystemCoupon systemCoupon : couponList) {
         listCouponId.add(systemCoupon.getId());
      }
      return userSystemCouponMapper.countUsableByUid(uid, listCouponId);
   }
   @Override
   public long countUsableRewardCoupon(Long uid) {
@@ -1599,13 +1617,16 @@
      if (userInfoExtra == null) {
         return;
      }
      UserInfoExtra extra = new UserInfoExtra();
      extra.setId(userInfoExtra.getId());
      Integer couponNews = userInfoExtra.getCouponNews();
      if (couponNews == null) {
         userInfoExtra.setCouponNews(num);
         extra.setCouponNews(num);
      } else {
         userInfoExtra.setCouponNews(couponNews + num);
         extra.setCouponNews(couponNews + num);
      }
      userInfoExtraService.saveUserInfoExtra(userInfoExtra);
      userInfoExtraService.saveUserInfoExtra(extra);
   }
   @Override
@@ -2452,34 +2473,16 @@
   }
   @Override
   public boolean getIncludeExchange(Long uid) {
   public boolean getValidRebateCoupon(Long uid) {
      // 过期券
      updateInvalidSate(uid);
      String percent = configService.get("exchange_rebate_percent");
      if (StringUtil.isNullOrEmpty(percent))
         percent = "35";
      List<UserSystemCoupon> listCoupon = userSystemCouponMapper.getIncludeExchange(uid, Integer.parseInt(percent),
            CouponTypeEnum.rebatePercentCoupon.name());
      List<UserSystemCouponVO> listCoupon = userSystemCouponMapper.getValidByUidAndType(uid, CouponTypeEnum.rebatePercentCoupon.name());
      if (listCoupon == null || listCoupon.size() == 0)
         return false;
      return true;
   }
   @Override
   public boolean getIncludeNotExchange(Long uid) {
      // 过期券
      updateInvalidSate(uid);
      String percent = configService.get("exchange_rebate_percent");
      if (StringUtil.isNullOrEmpty(percent))
         percent = "35";
      List<UserSystemCouponVO> listCoupon = userSystemCouponMapper.getIncludeNotExchange(uid,
            Integer.parseInt(percent), CouponTypeEnum.rebatePercentCoupon.name());
      if (listCoupon == null || listCoupon.size() == 0)
         return false;
      return true;
   }
   @Override
   public List<UserSystemCouponVO> listIncludeNotExchange(Long uid) throws Exception {
@@ -2489,12 +2492,8 @@
      // 退回券
      sendBackTimeOutCoupon(uid);
      String percent = configService.get("exchange_rebate_percent");
      if (StringUtil.isNullOrEmpty(percent))
         percent = "35";
      List<UserSystemCouponVO> listCoupon = userSystemCouponMapper.getIncludeNotExchange(uid,
            Integer.parseInt(percent), CouponTypeEnum.rebatePercentCoupon.name());
      List<UserSystemCouponVO> listCoupon = userSystemCouponMapper.getValidByUidAndType(uid, CouponTypeEnum.rebatePercentCoupon.name());
      if (listCoupon == null || listCoupon.size() == 0)
         return null;