admin
2019-03-04 cdaacd7f7ba10c00696e14de498085af59caa402
fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java
@@ -28,6 +28,7 @@
import com.yeshi.fanli.entity.order.CommonOrder;
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;
@@ -49,7 +50,9 @@
import com.yeshi.fanli.service.inter.user.UserSystemCouponService;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.MoneyBigDecimalUtil;
import com.yeshi.fanli.util.RedisManager;
import com.yeshi.fanli.util.factory.UserMoneyDetailFactory;
import com.yeshi.fanli.util.taobao.TaoBaoUtil;
import com.yeshi.fanli.vo.msg.ClientTextStyleVO;
import com.yeshi.fanli.vo.order.CommonOrderVO;
import com.yeshi.fanli.vo.user.UserSystemCouponRecordVO;
@@ -62,6 +65,9 @@
   @Resource(name = "taskExecutor")
   private TaskExecutor executor;
   @Resource
   private RedisManager redisManager;
   
   @Resource
   private UserSystemCouponMapper userSystemCouponMapper;
@@ -111,9 +117,6 @@
   @Resource
   private UserOtherMsgNotificationService userOtherMsgNotificationService;
   
   // 券失效图片
   public final static String PIC_INVALID = "http://192.168.1.200/icon/mian_invalid.png";
   @Override
   public int insertSelective(UserSystemCoupon record) {
@@ -196,7 +199,13 @@
            UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
            // 添加一条消息
            if (userInfoExtra != null) {
               userInfoExtra.setCouponNews(userInfoExtra.getCouponNews() + 1);
               if (userInfoExtra.getCouponNews() == null) {
                  userInfoExtra.setCouponNews(1);
               } else {
                  userInfoExtra.setCouponNews(userInfoExtra.getCouponNews() + 1);
               }
               try {
                  userInfoExtraService.saveUserInfoExtra(userInfoExtra);
               } catch (UserInfoExtraException e) {
@@ -209,12 +218,12 @@
      
      // 消息推送
      try {
         if (coupon.getType() != CouponTypeEnum.welfareFreeCoupon) {
         if (coupon.getType() == CouponTypeEnum.welfareFreeCoupon) {
            userOtherMsgNotificationService.welfareCouponGet(userCoupon);
         } else if (coupon.getType() != CouponTypeEnum.freeCoupon) {
         } else if (coupon.getType() == CouponTypeEnum.freeCoupon) {
            userOtherMsgNotificationService.freeSheetCouponGet(userCoupon);
         } else if (coupon.getType() != CouponTypeEnum.rebatePercentCoupon) {
            userOtherMsgNotificationService.rewardCouponGet(userCoupon);
         } else if (coupon.getType() == CouponTypeEnum.rebatePercentCoupon) {
            userOtherMsgNotificationService.rewardCouponGet(userCoupon,coupon.getPercent().intValue());
         }
         
      } catch(Exception e) {
@@ -227,7 +236,7 @@
   }
   
   @Transactional
   @Override
   public List<UserSystemCouponVO> getUserCouponVOList(long start, int count, Long uid)
         throws UserSystemCouponException, Exception {
@@ -277,10 +286,14 @@
         userCouponVO.setCouponPicture(systemCoupon.getPicture());
         userCouponVO.setCouponEffect(systemCoupon.getEffect());
         userCouponVO.setCouponRule(systemCoupon.getRule());
         userCouponVO.setCouponPictureInvalid(systemCoupon.getPictureInvalid());
         // 使用状态
         Integer state = userCouponVO.getState();
         // 券类型
         CouponTypeEnum type = systemCoupon.getType();
         // 按钮跳转
         Map<String, Object> jumpBtn = null;
         
@@ -297,22 +310,21 @@
            }
            jumpBtn = new HashMap<String, Object>();
            Map<String, Object> jumpLink = new HashMap<String, Object>();
            
            UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
            
            // 邀请队员界面
            if (userInfoExtra != null && userInfoExtra.getInviteCode() != null
                  && userInfoExtra.getInviteCode().trim().length() > 0) {
               // 邀请激活成功界面
               jumpLink.put("url", configService.get("invite_activation_success_url") + "?alert=true");
            } else {
               // 激活邀请码界面
               jumpLink.put("url", configService.get("invite_activation_url"));
            }
            /*
             * Map<String, Object> jumpLink = new HashMap<String, Object>();
             *UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
             * if (userInfoExtra != null && userInfoExtra.getInviteCode() != null &&
             * userInfoExtra.getInviteCode().trim().length() > 0) { // 邀请激活成功界面
             * jumpLink.put("url", configService.get("invite_activation_success_url") +
             * "?alert=true"); } else { // 激活邀请码界面 jumpLink.put("url",
             * configService.get("invite_activation_url")); }
             *   jumpBtn.put("params", jumpLink);
             */
            
            jumpBtn.put("params", jumpLink);
            jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite_web"));
            jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite"));
         } else if (stateActivated == 1) {
            // 显示规则
@@ -321,7 +333,6 @@
            if (UserSystemCoupon.STATE_CAN_USE == state) {
               Map<String, Object> jumpLink = new HashMap<String, Object>();
               CouponTypeEnum type = systemCoupon.getType();
               if (CouponTypeEnum.freeCoupon == type || CouponTypeEnum.welfareFreeCoupon == type) {
                  // 免单券、 福利免单券
                  
@@ -334,7 +345,7 @@
               } else if (CouponTypeEnum.rebatePercentCoupon == type) {
                  // 返利奖励券- 跳转至订单到账界面
                  jumpLink.put("state", 2);
                  jumpLink.put("state", "2");
                  
                  jumpBtn = new HashMap<String, Object>();
                  jumpBtn.put("params", jumpLink);
@@ -350,8 +361,8 @@
         
         // 券失效图片替换
         if (UserSystemCoupon.STATE_END_USE == state || UserSystemCoupon.STATE_OVERDUE == state) {
            userCouponVO.setCouponPicture(PIC_INVALID);
         }
            userCouponVO.setCouponPicture(systemCoupon.getPictureInvalid());
         }
         
         userCouponVO.setJumpBtn(jumpBtn);
@@ -417,15 +428,8 @@
         userCouponVO.setCouponName(systemCoupon.getName());
         userCouponVO.setCouponEffect(systemCoupon.getEffect());
         userCouponVO.setCouponRule(systemCoupon.getRule());
         userCouponVO.setCouponPictureInvalid(systemCoupon.getPictureInvalid());
         Integer stateActivated = userCouponVO.getStateActivated();
         if (stateActivated == null || stateActivated == 0) {
            userCouponVO.setState(0);
            userCouponVO.setCouponEffect("待激活");
            userCouponVO.setCouponPicture(PIC_INVALID); // 未激活图片
         } else {
            userCouponVO.setCouponPicture(systemCoupon.getPicture());
         }
         int differentDays = 0;
         String couponTerm = "有效期:";
@@ -447,7 +451,23 @@
         // 剩余天数
         Map<String, Object> remainDays = new HashMap<String, Object>();
         remainDays.put("content", "还剩" + differentDays + "天过期");
         remainDays.put("fontColor", "#F14242");
         String  remainDaysFontColor = "";
         Integer stateActivated = userCouponVO.getStateActivated();
         if (stateActivated == null || stateActivated == 0) {
            userCouponVO.setState(0);
            userCouponVO.setCouponEffect("待激活");
            userCouponVO.setCouponPicture(systemCoupon.getPictureInvalid());
            remainDaysFontColor = "#CCCCCC";
         } else {
            userCouponVO.setCouponPicture(systemCoupon.getPicture());
            remainDaysFontColor = "#F14242";
         }
         remainDays.put("fontColor", remainDaysFontColor);
         userCouponVO.setRemainDays(remainDays);
      }
@@ -478,6 +498,7 @@
      return hasCoupon;
   }
   @Transactional
   @Override
   public List<UserSystemCouponVO> getOrderCouponList(Long uid) throws UserSystemCouponException, Exception {
      if (uid == null) {
@@ -498,10 +519,16 @@
      return getEnableListByCouponId(uid, 1, couponList);
   }
   @Transactional
   @Override
   public List<UserSystemCouponVO> getGoodsCouponList(Long uid) throws UserSystemCouponException, Exception {
   public List<UserSystemCouponVO> getGoodsCouponList(Long uid, Long auctionId) throws UserSystemCouponException, Exception {
      if (uid == null) {
         throw new UserSystemCouponException(1, "用户未登录");
      }
      if (auctionId == null) {
         throw new UserSystemCouponException(1, "商品ID为空");
      }
      
      // 更新过期券
@@ -515,9 +542,36 @@
         return null;
      }
      return getEnableListByCouponId(uid, null, couponList);
      List<UserSystemCouponVO> list = getEnableListByCouponId(uid, null, couponList);
      // 获取商品详情
      TaoBaoGoodsBrief taoBaoGoodsBrief = redisManager.getTaoBaoGoodsBrief(auctionId);
      if (taoBaoGoodsBrief != null) {
         BigDecimal quanPrice = TaoBaoUtil.getAfterUseCouplePrice(taoBaoGoodsBrief);
         // 券后价 大于10元 不能免单
         if (quanPrice.compareTo(new BigDecimal(10)) > 0) {
            if (list != null && list.size() > 0) {
               for (UserSystemCouponVO userCouponVO: list) {
                  // 显示不能使用
                  userCouponVO.setState(0);
                  userCouponVO.setCouponPicture(userCouponVO.getCouponPictureInvalid());
                  Map<String, Object> map = userCouponVO.getRemainDays();
                  if (map != null) {
                     map.put("fontColor", "#CCCCCC");
                  }
                  userCouponVO.setRemainDays(map);
               }
            }
         }
      }
      return list;
   }
   @Transactional
   @Override
   public void useGoodsCoupon(Long uid, Long id, Long goodId) throws UserSystemCouponException, Exception {
      if (uid == null) {
@@ -570,10 +624,10 @@
      
      // 消息推送
      try {
         if (baseCoupon.getType() != CouponTypeEnum.welfareFreeCoupon) {
            userOtherMsgNotificationService.welfareCouponUsing(userSystemCoupon);
         } else if (baseCoupon.getType() != CouponTypeEnum.freeCoupon) {
            userOtherMsgNotificationService.freeSheetCouponUsing(userSystemCoupon);
         if (baseCoupon.getType() == CouponTypeEnum.welfareFreeCoupon) {
            //userOtherMsgNotificationService.welfareCouponUsing(userSystemCoupon,order.get);
         } else if (baseCoupon.getType() == CouponTypeEnum.freeCoupon) {
            //userOtherMsgNotificationService.freeSheetCouponUsing(userSystemCoupon);
         }
         
      } catch(Exception e) {
@@ -688,7 +742,7 @@
         
         // 消息推送
         try {
            userOtherMsgNotificationService.rewardCouponUsed(userSystemCoupon);
            userOtherMsgNotificationService.rewardCouponUsed(userSystemCoupon, hongBao, money, orderNo);
         } catch(Exception e) {
            LogHelper.errorDetailInfo(e);
         }
@@ -755,8 +809,8 @@
      }
      userRecordVO.setCouponEffect("返利¥" + hongBao.setScale(2, BigDecimal.ROUND_DOWN) + "已返" + percent + "%");
      // 跳转福利中心
      JumpDetailV2 welfareCore = jumpDetailV2Service.getByTypeCache("welfareCore");
      // 资金明细
      JumpDetailV2 welfareCore = jumpDetailV2Service.getByTypeCache("capitalDetails");
      Map<String, Object> jumpWelfare = new HashMap<String, Object>();
      jumpWelfare.put("jumpDetail", welfareCore);
      Map<String, Object> jumpparms = new HashMap<String, Object>();
@@ -774,6 +828,7 @@
      return userRecordVO;
   }
   @Override
   public UserSystemCouponRecordVO getFreeCouponRecord(String orderNo) throws UserSystemCouponException, Exception {
@@ -975,7 +1030,7 @@
      return userRecordVO;
   }
   
   @Transactional
   @Override
   public void activatedWelfareFreeCoupon(Long uid) {
      if (uid == null) {
@@ -1014,6 +1069,7 @@
      }
   }
   
   @Transactional
   @Override
   public void updateStateByDrawback(String orderNo) throws Exception {
      
@@ -1032,9 +1088,10 @@
      userSystemCouponRecordService.updateByPrimaryKeySelective(record);
      
      // 券退回
      sendBackCoupon(record.getUserSystemCoupon());
      sendBackCoupon(record.getUserSystemCoupon(), record);
   }
   
   @Transactional
   @Override
   public void updateStateByArrivalAccount(String orderNo) throws Exception {
      
@@ -1051,8 +1108,16 @@
      record.setUpdateTime(new Date());
      record.setState(UserSystemCouponRecord.STATE_SUCCESS);
      userSystemCouponRecordService.updateByPrimaryKeySelective(record);
      // 消息推送
      if (CouponTypeEnum.welfareFreeCoupon.name().equals(record.getCouponType())) {
         userOtherMsgNotificationService.welfareCouponUsed(record.getUserSystemCoupon(), orderNo);
      } else if (CouponTypeEnum.freeCoupon.name().equals(record.getCouponType())) {
         userOtherMsgNotificationService.freeSheetCouponUsed(record.getUserSystemCoupon(), orderNo);
      }
   }
   @Transactional
   @Override
   public void updateCounponInvalid(Long uid) {
      List<UserSystemCoupon> list = userSystemCouponMapper.getCounponNowInvalid(uid);
@@ -1077,11 +1142,11 @@
         
         // 消息推送
         try {
            if (baseCoupon.getType() != CouponTypeEnum.welfareFreeCoupon) {
            if (baseCoupon.getType() == CouponTypeEnum.welfareFreeCoupon) {
               userOtherMsgNotificationService.welfareCouponAlreadyOutOfDate(userSystemCoupon);
            } else if (baseCoupon.getType() != CouponTypeEnum.freeCoupon) {
            } else if (baseCoupon.getType() == CouponTypeEnum.freeCoupon) {
               userOtherMsgNotificationService.freeSheetCouponAlreadyOutOfDate(userSystemCoupon);
            } else if (baseCoupon.getType() != CouponTypeEnum.rebatePercentCoupon) {
            } else if (baseCoupon.getType() == CouponTypeEnum.rebatePercentCoupon) {
               userOtherMsgNotificationService.rewardCouponAlreadyOutOfDate(userSystemCoupon);
            }
            
@@ -1095,6 +1160,7 @@
      }
   }
   
   @Transactional
   @Override
   public void  sendBackTimeOutCoupon(Long uid) {
      // 超过120秒 未被匹配的券
@@ -1140,6 +1206,7 @@
      }
   }
   
   @Transactional
   @Override
   public boolean updateCouponRecordUsed(Long uid, String orderNo, BigDecimal payment,
         Long auctionId) throws  Exception{
@@ -1184,7 +1251,7 @@
            userSystemCouponRecordService.updateByPrimaryKeySelective(record);
            
            // 退回券
            sendBackCoupon(userSystemCoupon);
            sendBackCoupon(userSystemCoupon, record);
            
         } else {
            // 免单匹配成功
@@ -1199,16 +1266,15 @@
            userSystemCoupon.setUpdateTime(new Date());
            userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);
            
            SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon();
            String couponType = record.getCouponType();
            if (couponType == null || couponType.trim().length() == 0) {
               throw new Exception("券类型未被记录");
            }
            
            SystemCoupon baseCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());
            if (baseCoupon == null) {
               // 券已使用
               userOtherMsgNotificationService.freeSheetCouponUsed(userSystemCoupon);
            } else    if (baseCoupon.getType() != CouponTypeEnum.welfareFreeCoupon) {
               userOtherMsgNotificationService.welfareCouponUsed(userSystemCoupon);
            } else if (baseCoupon.getType() != CouponTypeEnum.freeCoupon) {
               userOtherMsgNotificationService.freeSheetCouponUsed(userSystemCoupon);
             if (CouponTypeEnum.welfareFreeCoupon.name().equals(couponType)) {
               userOtherMsgNotificationService.welfareCouponUsing(userSystemCoupon,orderNo,payment);
            } else if (CouponTypeEnum.freeCoupon.name().equals(couponType)) {
               userOtherMsgNotificationService.freeSheetCouponUsing(userSystemCoupon, orderNo, payment);
            } 
         }
      }
@@ -1220,7 +1286,7 @@
    * 退回券 初始数据
    * @param userSystemCoupon
    */
   public void sendBackCoupon(UserSystemCoupon userSystemCoupon) throws Exception{
   public void sendBackCoupon(UserSystemCoupon userSystemCoupon, UserSystemCouponRecord record) throws Exception{
      int expiryDay = 15;
@@ -1249,6 +1315,13 @@
      userSystemCoupon.setUpdateTime(new Date());
      
      userSystemCouponMapper.updateByPrimaryKey(userSystemCoupon);
      if (CouponTypeEnum.welfareFreeCoupon.name().equals(record.getCouponType())) {
         userOtherMsgNotificationService.welfareCouponDrawBack(userSystemCoupon, record.getOrderNo());
      } else if (CouponTypeEnum.freeCoupon.name().equals(record.getCouponType())) {
         userOtherMsgNotificationService.freeSheetCouponDrawBack(userSystemCoupon, record.getOrderNo());
      }
   }