金币获取服务修改

admin

2019-08-21 75b9f225c0fb0bbd429d542d4e20337f3c0e13f1

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

@@ -1,7 +1,6 @@
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;

@@ -17,6 +16,8 @@
import org.yeshi.utils.DateUtil;



import com.yeshi.fanli.dao.mybatis.user.UserSystemCouponMapper;

import com.yeshi.fanli.dto.msg.MsgOtherGiveContentDTO;

import com.yeshi.fanli.entity.bus.msg.MsgOtherDetail.MsgTypeOtherTypeEnum;

import com.yeshi.fanli.entity.bus.user.DeviceLotteryRecord;

import com.yeshi.fanli.entity.bus.user.HongBaoV2;

import com.yeshi.fanli.entity.bus.user.Order;

@@ -62,7 +63,7 @@
import com.yeshi.fanli.util.MoneyBigDecimalUtil;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.account.UserUtil;

import com.yeshi.fanli.util.TokenUtil;

import com.yeshi.fanli.util.factory.UserMoneyDetailFactory;

import com.yeshi.fanli.util.taobao.TaoBaoUtil;

import com.yeshi.fanli.vo.msg.ClientTextStyleVO;

@@ -198,8 +199,8 @@
      }



      SystemCoupon coupon = null;

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

         // 福利免单券

      if (couponType.equals(CouponTypeEnum.welfareFreeCoupon.name()) || couponType.equals(CouponTypeEnum.freeCoupon.name())) {

         // 免单券

         coupon = systemCouponService.getCouponByType(couponType);

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

         // 随机奖励券

@@ -219,6 +220,8 @@
         if (countSuccess == 0) {

            stateActivated = 0;

         }

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

         stateActivated = 0;

      }



      // 结束日期

@@ -290,8 +293,6 @@
         return null;

      }



      // 更新过期券

      updateCounponInvalid(uid);

      // 退回券

      sendBackTimeOutCoupon(uid);

      

@@ -553,8 +554,6 @@
         throw new UserSystemCouponException(1, "用户未登录");

      }



      // 更新过期券

      updateCounponInvalid(uid);

      // 退回券

      sendBackTimeOutCoupon(uid);



@@ -580,8 +579,6 @@
         throw new UserSystemCouponException(1, "商品ID为空");

      }



      // 更新过期券

      updateCounponInvalid(uid);

      // 退回券

      sendBackTimeOutCoupon(uid);

      

@@ -1118,9 +1115,6 @@
         return;

      }



      // 验证是否失效

      updateCounponInvalid(uid);



      // 待活福利免单券

      List<UserSystemCoupon> list = userSystemCouponMapper.getCouponByTypeAndNotActivated(uid, systemCoupon.getId());

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

@@ -1205,25 +1199,30 @@
      }

   }



   @Transactional

   @Override

   public void updateCounponInvalid(Long uid) {

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

   public List<UserSystemCoupon> getCounponNowInvalid(int count) {

      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 systemCoupon = userSystemCoupon.getSystemCoupon();

         if (systemCoupon == null) {

         SystemCoupon baseCoupon = userSystemCoupon.getSystemCoupon();

         if (baseCoupon == null) {

            continue;

         }



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

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

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

            continue;

         }

@@ -1236,8 +1235,11 @@
               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);

@@ -1252,7 +1254,7 @@
   @Override

   public void sendBackTimeOutCoupon(Long uid) {

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

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

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

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

         return;

      }

@@ -1265,31 +1267,9 @@


         UserSystemCoupon userSystemCoupon = couponRecord.getUserSystemCoupon();



         int expiryDay = 15;



         SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon();

         SystemCoupon coupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());

         if (coupon != null) {

            expiryDay = coupon.getExpiryDay();

         }



         // 结束日期

         Date endTime = null;

         try {

            // 今天在内  减去一天

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

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

            endTime = format.parse(endDay);

         } catch (ParseException e) {

            e.printStackTrace();

         }

         // 状态初始化

         userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE);

         userSystemCoupon.setUseTime(null);



         // 有效期时间重新定义

         userSystemCoupon.setStartTime(new Date());

         userSystemCoupon.setEndTime(endTime);

         userSystemCoupon.setUpdateTime(new Date());

         userSystemCouponMapper.updateByPrimaryKey(userSystemCoupon);

      }

@@ -1376,42 +1356,48 @@
    * 

    * @param userSystemCoupon

    */

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



      int expiryDay = 15;



      SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon();

      SystemCoupon coupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());

      if (coupon != null) {

         expiryDay = coupon.getExpiryDay();

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

			
         // TODO 过期

         return;

      }



      // 结束日期

      Date endTime = null;

      try {

         // 今天在内  减去一天

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

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

         endTime = format.parse(endDay);

      } catch (ParseException e) {

         e.printStackTrace();

      }

      // 状态初始化

      userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE);

		
      // 退回券

      UserSystemCoupon userSystemCoupon = new UserSystemCoupon();

      userSystemCoupon.setId(userCoupon.getId());

      userSystemCoupon.setGive(false);

      userSystemCoupon.setUseTime(null);

      // 有效期时间重新定义

      userSystemCoupon.setStartTime(new Date());

      userSystemCoupon.setEndTime(endTime);



      userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE);

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

		
      // 使用记录

      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

@@ -1697,8 +1683,6 @@
   @Override

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

         throws UserSystemCouponException, Exception {

      // 更新过期券

      updateCounponInvalid(uid);

      // 退回券

      sendBackTimeOutCoupon(uid);



@@ -1822,16 +1806,38 @@
               jumpBtn.put("params", jumpLink);

               jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("orderList"));

            }

         } else if (UserSystemCoupon.STATE_IN_USE == state) {

         } else if (UserSystemCoupon.STATE_IN_USE == state && give) {

            userCouponVO.setCouponEffect("赠送中");

            String tips = null;

            if (CouponTypeEnum.freeCouponGive == type) {

               userCouponVO.setState(UserSystemCoupon.STATE_GIVE_IN);

               tips = configService.get("give_free_coupon_tips");

            }

            

            if (give && CouponTypeEnum.rebatePercentCoupon == type) {

            if (CouponTypeEnum.rebatePercentCoupon == type) {

               userCouponVO.setState(UserSystemCoupon.STATE_GIVE_IN);

               tips = configService.get("give_free_coupon_tips");

            }

				
            if (!StringUtil.isNullOrEmpty(tips)) {

               UserSystemCouponGiveRecord record = userSystemCouponGiveRecordService.getRecordByUidAndCouponId(uid, userCouponVO.getId());

               if (record != null) {

                  TokenRecord tokenRecord = tokenRecordService.getNearByTypeAndIdentify(CouponTypeEnum.freeCoupon.name(), record.getId().toString());

                  if (tokenRecord != null && !StringUtil.isNullOrEmpty(tokenRecord.getToken())) {

                     String projectChineseName = Constant.systemCommonConfig.getProjectChineseName();

                     while(tips.contains("{APP名称}")) {

                        tips = tips.replace("{APP名称}", projectChineseName);

                     }

                     tips = tips.replace("{口令}", tokenRecord.getToken()).replace("{下载链接}", configService.get("app_down_link"));

                  }

               }

            } else {

               tips = "";

            }

            userCouponVO.setGiveTips(tips);

				
         } else if (UserSystemCoupon.STATE_END_USE == state) {

            if (CouponTypeEnum.freeCouponGive == type) {

            if (give && CouponTypeEnum.freeCouponGive == type) {

               userCouponVO.setState(UserSystemCoupon.STATE_GIVE_END);

            }

            

@@ -1871,68 +1877,154 @@
      if (type != CouponTypeEnum.freeCouponGive && type != CouponTypeEnum.rebatePercentCoupon )

         throw new UserSystemCouponException(1, "该券不支持赠送");

      

      String tips = null;

      TokenTypeEnum tokenTypeEnum = null;

      if (type == CouponTypeEnum.freeCouponGive) {

         tokenTypeEnum = TokenTypeEnum.freeCoupon;

         tips = configService.get("give_free_coupon_tips");

      } else if (type == CouponTypeEnum.rebatePercentCoupon){

         tokenTypeEnum = TokenTypeEnum.rebatePercentCoupon;

         tips = configService.get("give_rebate_percent_coupon_tips");

      } else {

         throw new UserSystemCouponException(1, "该券不支持赠送");

      }

      

      String token = null;

      Date nowDate = new Date();

      TokenRecord record = tokenRecordService.getNearByTypeAndIdentify(tokenTypeEnum.name(), id+"");

      if (record != null && record.getEndTime().getTime() > nowDate.getTime()) {

         token = record.getToken();

      } else {

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

            try {

               // TODO 口令生成规则待定

               long num = 10000 + (long) (Math.random() * 10000);

               token = UserUtil.getInviteCode(num);

					
               TokenRecord tokenRecord = new TokenRecord();

               tokenRecord.setUid(uid);

               tokenRecord.setIdentify(id+"");

               tokenRecord.setType(tokenTypeEnum);

               tokenRecord.setStartTime(nowDate);

               tokenRecord.setEndTime(DateUtil.plusDayDate(3, nowDate));

               tokenRecord.setToken(token);

               tokenRecord.setState(state);

               tokenRecordService.insertSelective(tokenRecord);

            } catch (Exception e) {

               LogHelper.errorDetailInfo(e);

               token = null;

      if (StringUtil.isNullOrEmpty(tips))

         throw new UserSystemCouponException(1, "tips数据缺失");

		
		
      // 是否最近生成口令有效

      UserSystemCouponGiveRecord record = userSystemCouponGiveRecordService.getRecordByUidAndCouponId(uid, id);

      if (record != null) {

         TokenRecord tokenRecord = tokenRecordService.getNearByTypeAndIdentify(tokenTypeEnum.name(), id+"");

         if (tokenRecord != null && !StringUtil.isNullOrEmpty(tokenRecord.getToken())) {

            String projectChineseName = Constant.systemCommonConfig.getProjectChineseName();

            while(tips.contains("{APP名称}")) {

               tips = tips.replace("{APP名称}", projectChineseName);

            }

				
            if(!StringUtil.isNullOrEmpty(token)) {

               break;

            }

            tips = tips.replace("{口令}", tokenRecord.getToken()).replace("{下载链接}", configService.get("app_down_link"));

            return tips;

         }

			
         if(StringUtil.isNullOrEmpty(token))

            throw new UserSystemCouponException(1, "口令生成失败");

			
         // 插入赠送记录

         UserSystemCouponGiveRecord giveRecord = new UserSystemCouponGiveRecord();

         giveRecord.setCouponId(id);

         giveRecord.setGiveUid(uid);

         giveRecord.setGiveTime(nowDate);

         userSystemCouponGiveRecordService.insertSelective(giveRecord);

      }

      

      if(StringUtil.isNullOrEmpty(token))

         throw new UserSystemCouponException(1, "口令生成失败");



      String tips = "送给你一张返利奖励券快去领取吧，复制本条消息[&%s&]，打开[返利券]App领取，使用后可让返利加倍。\r\n" 
            +"----------------------------\r\n" 
            + "下载[返利券]App链接:http://t.cn/2H7AXAH\r\n"

            + "PS：口令将会24小时内失效，请及时领取。";

      

      tips = String.format(tips, token);

      Date nowDate = new Date();

      // 插入赠送记录

      UserSystemCouponGiveRecord giveRecord = new UserSystemCouponGiveRecord();

      giveRecord.setCouponId(id);

      giveRecord.setGiveUid(uid);

      giveRecord.setGiveTime(nowDate);

      giveRecord.setEndTime(DateUtil.plusDayDate(Constant.GIVE_DAYS, nowDate));

      userSystemCouponGiveRecordService.insertSelective(giveRecord);

      

      // 创建记录

      TokenRecord tokenRecord = new TokenRecord();

      tokenRecord.setUid(uid);

      tokenRecord.setIdentify(giveRecord.getId()+"");

      tokenRecord.setType(tokenTypeEnum);

      tokenRecord.setStartTime(nowDate);

      tokenRecord.setEndTime(DateUtil.plusDayDate(Constant.TOKEN_DAYS, nowDate));

      tokenRecord.setState(0);

      tokenRecordService.insertSelective(tokenRecord);

		
      // 创建口令

      String token = TokenUtil.createToken(tokenRecord.getId());

      tokenRecord.setToken(token);

      tokenRecordService.updateByPrimaryKeySelective(tokenRecord);

			
      // 券状态

      userSystemCoupon.setState(UserSystemCoupon.STATE_IN_USE);

      userSystemCoupon.setGive(true);

      userSystemCoupon.setUpdateTime(nowDate);

      userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);

		
      // 插入使用券记录

      UserSystemCouponRecord couponRecord = new UserSystemCouponRecord();

      couponRecord.setState(UserSystemCouponRecord.STATE_GIVE_ON);

      couponRecord.setUserSystemCoupon(userSystemCoupon);

      couponRecord.setCouponType(type.name());

      couponRecord.setCreateTime(nowDate);

      couponRecord.setUpdateTime(nowDate);

      userSystemCouponRecordService.insertSelective(couponRecord);

				
      String projectChineseName = Constant.systemCommonConfig.getProjectChineseName();

      while(tips.contains("{APP名称}")) {

         tips = tips.replace("{APP名称}", projectChineseName);

      }

      tips = tips.replace("{口令}", token).replace("{下载链接}", configService.get("app_down_link"));

      return tips;

   }



	
   @Override

   public void sendBackGiveCoupon(List<UserSystemCouponGiveRecord> overdueList) {

      for (UserSystemCouponGiveRecord record: overdueList) {

         // 更新赠送记录

         UserSystemCouponGiveRecord updateRecord = new UserSystemCouponGiveRecord();

         updateRecord.setId(record.getId());

         updateRecord.setState(UserSystemCouponGiveRecord.STATE_OVERDUE);

         userSystemCouponGiveRecordService.updateByPrimaryKeySelective(updateRecord);

			
         // 更新券信息

         Long couponId = record.getCouponId();

         if (couponId == null) {

            continue;

         }

			
         // 券列表

         UserSystemCoupon userCoupon = userSystemCouponMapper.selectByPrimaryKey(couponId);

         if (userCoupon == null)

            continue;

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

				
            // TODO 过期

            continue;

         }

			
         // 退回券

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

			
         // 使用记录

         UserSystemCouponRecord useRecord = userSystemCouponRecordService.getNearByUserCouponId(couponId);

         if  (useRecord != null) {

            UserSystemCouponRecord useRecordUpdate = new UserSystemCouponRecord();

            useRecordUpdate.setId(useRecord.getId());

            useRecordUpdate.setState(UserSystemCouponRecord.STATE_WAIT_TIME_OUT);

            useRecordUpdate.setUpdateTime(new Date());

            userSystemCouponRecordService.updateByPrimaryKeySelective(useRecordUpdate);

         }

			
         SystemCoupon systemCoupon = userCoupon.getSystemCoupon();

         if (systemCoupon != null) 
            systemCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());

			
         if (systemCoupon == null)

            continue;

			
         // 退回消息

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

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

         MsgOtherGiveContentDTO msgOther = new MsgOtherGiveContentDTO();

         msgOther.setType(MsgOtherGiveContentDTO.TYEP_COUPON);

         msgOther.setTitle("赠送" + systemCoupon.getName() + "退回");

         msgOther.setGiveType("你赠送的"+ systemCoupon.getName() + "未被成功领取");

         msgOther.setGiveTime(sd.format(record.getGiveTime()));

         msgOther.setReturnTime(sd.format(new Date()));

         userOtherMsgNotificationService.tokenGiveMsg(record.getGiveUid(), beiZhu, msgOther);

      }

   }



}