Merge remote-tracking branch 'origin/div' into div

admin

2019-08-28 08d5529087390663115d326190635e4a4997acf2

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

@@ -310,6 +310,9 @@
         return null;

      }



      // 过期券

      updateInvalidSate(uid);

		
      // 退回券

      sendBackTimeOutCoupon(uid);

      

@@ -573,6 +576,9 @@
         throw new UserSystemCouponException(1, "用户未登录");

      }



      // 过期券

      updateInvalidSate(uid);

		
      // 退回券

      sendBackTimeOutCoupon(uid);



@@ -598,6 +604,9 @@
         throw new UserSystemCouponException(1, "商品ID为空");

      }



      // 过期券

      updateInvalidSate(uid);

		
      // 退回券

      sendBackTimeOutCoupon(uid);

      

@@ -1224,76 +1233,7 @@
      return userSystemCouponMapper.getCounponNowInvalid(count);

   }

   



   @Override

   public void updateCounponInvalid(List<UserSystemCoupon> list) {

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

         return;

      }



      for (UserSystemCoupon userSystemCoupon : list) {

         UserSystemCoupon userCoupon = new UserSystemCoupon();

         userCoupon.setUpdateTime(new Date());

         userSystemCoupon.setState(UserSystemCoupon.STATE_OVERDUE);

         userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);



         SystemCoupon baseCoupon = userSystemCoupon.getSystemCoupon();

         if (baseCoupon == null) {

            continue;

         }

			
         baseCoupon = systemCouponService.selectByPrimaryKey(baseCoupon.getId());

         if (baseCoupon == null || baseCoupon.getId() == null) {

            continue;

         }



         // 消息推送

         try {

            if (baseCoupon.getType() == CouponTypeEnum.welfareFreeCoupon) {

               userOtherMsgNotificationService.welfareCouponAlreadyOutOfDate(userSystemCoupon);

            } else if (baseCoupon.getType() == CouponTypeEnum.freeCoupon) {

               userOtherMsgNotificationService.freeSheetCouponAlreadyOutOfDate(userSystemCoupon);

            } else if (baseCoupon.getType() == CouponTypeEnum.rebatePercentCoupon) {

               userOtherMsgNotificationService.rewardCouponAlreadyOutOfDate(userSystemCoupon);

            }else if (baseCoupon.getType() == CouponTypeEnum.freeCouponBuy) {

               userOtherMsgNotificationService.outOfDate(userSystemCoupon, MsgTypeOtherTypeEnum.freeCouponBuy);

            } else if (baseCoupon.getType() == CouponTypeEnum.freeCouponGive) {

               userOtherMsgNotificationService.outOfDate(userSystemCoupon, MsgTypeOtherTypeEnum.freeCouponGive);

            }

         } catch (Exception e) {

            try {

               LogHelper.errorDetailInfo(e);

            } catch (Exception e1) {

               e1.printStackTrace();

            }

         }

      }

   }



   @Transactional

   @Override

   public void sendBackTimeOutCoupon(Long uid) {

      // 超过10分钟   未被匹配的券

      List<UserSystemCouponRecord> list = userSystemCouponRecordService.getCouponByUsingTimeOut(uid, 600L);

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

         return;

      }



      for (UserSystemCouponRecord couponRecord : list) {

         // 更新状态：匹配超时

         couponRecord.setState(UserSystemCouponRecord.STATE_WAIT_TIME_OUT);

         couponRecord.setUpdateTime(new Date());

         userSystemCouponRecordService.updateByPrimaryKeySelective(couponRecord);



         UserSystemCoupon userSystemCoupon = couponRecord.getUserSystemCoupon();

         // 状态初始化

         userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE);

         userSystemCoupon.setUseTime(null);

         userSystemCoupon.setUpdateTime(new Date());

         userSystemCouponMapper.updateByPrimaryKey(userSystemCoupon);

      }

   }



	
   @Transactional

   @Override

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

@@ -1372,56 +1312,7 @@
      return isfree;

   }



   /**

    * 退回券 初始数据

    * 
    * @param userSystemCoupon

    */

   public void sendBackCoupon(UserSystemCoupon userCoupon, UserSystemCouponRecord record) throws Exception {

      if (userCoupon == null)

         return;

			
      Integer state = userCoupon.getState();

      if (state != UserSystemCoupon.STATE_IN_USE) 
         return;

		
      Date now = new Date();

      Date endTime = userCoupon.getEndTime();

      if (endTime != null && endTime.getTime() < now.getTime()) {

         // 过期

         List<UserSystemCoupon> list = new ArrayList<UserSystemCoupon>();

         list.add(userCoupon);

         updateCounponInvalid(list);

         return;

      }

		
      // 退回券

      UserSystemCoupon userSystemCoupon = new UserSystemCoupon();

      userSystemCoupon.setId(userCoupon.getId());

      userSystemCoupon.setGive(false);

      userSystemCoupon.setUseTime(null);

      userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE);

      userSystemCoupon.setUpdateTime(new Date());

      userSystemCouponMapper.updateByPrimaryKey(userSystemCoupon);

		
      // 使用记录

      if  (record != null) {

         UserSystemCouponRecord useRecordUpdate = new UserSystemCouponRecord();

         useRecordUpdate.setId(record.getId());

         useRecordUpdate.setState(UserSystemCouponRecord.STATE_WAIT_TIME_OUT);

         useRecordUpdate.setUpdateTime(new Date());

         userSystemCouponRecordService.updateByPrimaryKeySelective(useRecordUpdate);

			
         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());

         } else if (CouponTypeEnum.freeCouponBuy.name().equals(record.getCouponType())) {

            userOtherMsgNotificationService.couponDrawBack(userSystemCoupon, record.getOrderNo(), MsgTypeOtherTypeEnum.freeCouponBuy);

         }

      }

		
   }

	


   @Override

   @Transactional

@@ -1715,9 +1606,14 @@
   @Override

   public List<UserSystemCouponVO> getCouponList(long start, int count, Long uid)

         throws UserSystemCouponException, Exception {

	
      // 过期券

      updateInvalidSate(uid);

		
      // 退回券

      sendBackTimeOutCoupon(uid);



		
      List<UserSystemCouponVO> listVO = userSystemCouponMapper.getUserCouponVOList(start, count, uid);

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

         return listVO;

@@ -1889,9 +1785,9 @@
         } else if (UserSystemCoupon.STATE_END_USE == state) {

            

            if (give) {

               userCouponVO.setCouponEffect("任性0元购");

               userCouponVO.setCouponRule(systemCoupon.getRemark());

               if (CouponTypeEnum.freeCouponGive == type) {

                  userCouponVO.setCouponEffect("任性0元购");

                  userCouponVO.setState(UserSystemCoupon.STATE_GIVE_END);

               }

               

@@ -1902,7 +1798,7 @@
               Date useTime = userCouponVO.getUseTime();

               if (useTime != null) {

                  Map<String, Object> remainDays = new HashMap<String, Object>();

                  remainDays.put("content", "于" + sdf.format(useTime) + "成功赠送");

                  remainDays.put("content", "于" + sdf.format(useTime) + "赠送");

                  remainDays.put("fontColor", "#CCCCCC");

                  userCouponVO.setRemainDays(remainDays);

               }

@@ -1910,7 +1806,7 @@
               Date useTime = userCouponVO.getUseTime();

               if (useTime != null) {

                  Map<String, Object> remainDays = new HashMap<String, Object>();

                  remainDays.put("content", "于" + sdf.format(useTime) + "成功使用");

                  remainDays.put("content", "于" + sdf.format(useTime) + "使用");

                  remainDays.put("fontColor", "#CCCCCC");

                  userCouponVO.setRemainDays(remainDays);

               }

@@ -2069,6 +1965,139 @@
   }



   

   @Transactional

   @Override

   public void updateInvalidSate(Long uid) {

      List<UserSystemCoupon> list = userSystemCouponMapper.getCounponNowInvalidByUid(uid);

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

         return;

      }

      updateCounponInvalid(list);

   }

	
	
   @Override

   public void updateCounponInvalid(List<UserSystemCoupon> list) {

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

         return;

      }



      for (UserSystemCoupon userSystemCoupon : list) {

         UserSystemCoupon userCoupon = new UserSystemCoupon();

         userCoupon.setUpdateTime(new Date());

         userSystemCoupon.setState(UserSystemCoupon.STATE_OVERDUE);

         userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);



         SystemCoupon baseCoupon = userSystemCoupon.getSystemCoupon();

         if (baseCoupon == null) {

            continue;

         }

			
         baseCoupon = systemCouponService.selectByPrimaryKey(baseCoupon.getId());

         if (baseCoupon == null || baseCoupon.getId() == null) {

            continue;

         }



         // 消息推送

         try {

            if (baseCoupon.getType() == CouponTypeEnum.welfareFreeCoupon) {

               userOtherMsgNotificationService.welfareCouponAlreadyOutOfDate(userSystemCoupon);

            } else if (baseCoupon.getType() == CouponTypeEnum.freeCoupon) {

               userOtherMsgNotificationService.freeSheetCouponAlreadyOutOfDate(userSystemCoupon);

            } else if (baseCoupon.getType() == CouponTypeEnum.rebatePercentCoupon) {

               userOtherMsgNotificationService.rewardCouponAlreadyOutOfDate(userSystemCoupon);

            }else if (baseCoupon.getType() == CouponTypeEnum.freeCouponBuy) {

               userOtherMsgNotificationService.outOfDate(userSystemCoupon, MsgTypeOtherTypeEnum.freeCouponBuy);

            } else if (baseCoupon.getType() == CouponTypeEnum.freeCouponGive) {

               userOtherMsgNotificationService.outOfDate(userSystemCoupon, MsgTypeOtherTypeEnum.freeCouponGive);

            }

         } catch (Exception e) {

            try {

               LogHelper.errorDetailInfo(e);

            } catch (Exception e1) {

               e1.printStackTrace();

            }

         }

      }

   }

	
	
   /**

    * 退回券 初始数据

    * 
    * @param userSystemCoupon

    */

   public void sendBackCoupon(UserSystemCoupon userCoupon, UserSystemCouponRecord record) throws Exception {

      if (userCoupon == null)

         return;

			
      Integer state = userCoupon.getState();

      if (state != UserSystemCoupon.STATE_IN_USE) 
         return;

		
      Date now = new Date();

      Date endTime = userCoupon.getEndTime();

      if (endTime != null && endTime.getTime() < now.getTime()) {

         // 过期

         List<UserSystemCoupon> list = new ArrayList<UserSystemCoupon>();

         list.add(userCoupon);

         updateCounponInvalid(list);

         return;

      }

		
      // 退回券

      UserSystemCoupon userSystemCoupon = new UserSystemCoupon();

      userSystemCoupon.setId(userCoupon.getId());

      userSystemCoupon.setGive(false);

      userSystemCoupon.setUseTime(null);

      userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE);

      userSystemCoupon.setUpdateTime(new Date());

      userSystemCouponMapper.updateByPrimaryKey(userSystemCoupon);

		
      // 使用记录

      if  (record != null) {

         UserSystemCouponRecord useRecordUpdate = new UserSystemCouponRecord();

         useRecordUpdate.setId(record.getId());

         useRecordUpdate.setState(UserSystemCouponRecord.STATE_WAIT_TIME_OUT);

         useRecordUpdate.setUpdateTime(new Date());

         userSystemCouponRecordService.updateByPrimaryKeySelective(useRecordUpdate);

			
         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());

         } else if (CouponTypeEnum.freeCouponBuy.name().equals(record.getCouponType())) {

            userOtherMsgNotificationService.couponDrawBack(userSystemCoupon, record.getOrderNo(), MsgTypeOtherTypeEnum.freeCouponBuy);

         }

      }

   }

	
	
   @Transactional

   @Override

   public void sendBackTimeOutCoupon(Long uid) {

      // 超过10分钟   未被匹配的券

      List<UserSystemCouponRecord> list = userSystemCouponRecordService.getCouponByUsingTimeOut(uid, 600L);

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

         return;

      }



      for (UserSystemCouponRecord couponRecord : list) {

         // 更新状态：匹配超时

         couponRecord.setState(UserSystemCouponRecord.STATE_WAIT_TIME_OUT);

         couponRecord.setUpdateTime(new Date());

         userSystemCouponRecordService.updateByPrimaryKeySelective(couponRecord);



         // 状态初始化

         UserSystemCoupon userSystemCoupon = couponRecord.getUserSystemCoupon();

         userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE);

         userSystemCoupon.setUseTime(null);

         userSystemCoupon.setUpdateTime(new Date());

         userSystemCouponMapper.updateByPrimaryKey(userSystemCoupon);

      }

   }



	
   @Override

   public void sendBackGiveCoupon(List<UserSystemCouponGiveRecord> overdueList) {

      for (UserSystemCouponGiveRecord record: overdueList) {

@@ -2128,11 +2157,12 @@
         if (systemCoupon == null)

            continue;

         

			
         // 退回消息

         String couponName = systemCoupon.getName();

         if (CouponTypeEnum.freeCouponGive == systemCoupon.getType())

            couponName = "免单券";

         

         // 退回消息

         String beiZhu = "请到我的-福利中心查看";

         SimpleDateFormat sd = new SimpleDateFormat("yyyy.MM.dd HH:mm");

         MsgOtherGiveContentDTO msgOther = new MsgOtherGiveContentDTO();

@@ -2148,6 +2178,9 @@
   

   @Override

   public boolean getIncludeExchange(Long uid) {

      // 过期券

      updateInvalidSate(uid);

		
      String percent = configService.get("exchange_rebate_percent");

      if (StringUtil.isNullOrEmpty(percent)) 

         percent = "35";

@@ -2160,6 +2193,9 @@
   

   @Override

   public boolean getIncludeNotExchange(Long uid) {

      // 过期券

      updateInvalidSate(uid);

		
      String percent = configService.get("exchange_rebate_percent");

      if (StringUtil.isNullOrEmpty(percent)) 

         percent = "35";

@@ -2172,6 +2208,10 @@
   

   @Override

   public List<UserSystemCouponVO> listIncludeNotExchange(Long uid) throws Exception{

      // 过期券

      updateInvalidSate(uid);

		
      // 退回券

      sendBackTimeOutCoupon(uid);

      

      String percent = configService.get("exchange_rebate_percent");