奖励详情跳转地址调整

yujian

2019-02-28 70c9043f312a52a922cb15490d90a172b3515060

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

@@ -11,6 +11,7 @@


import javax.annotation.Resource;



import org.springframework.core.task.TaskExecutor;

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

import org.yeshi.utils.DateUtil;

@@ -27,6 +28,8 @@
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;

import com.yeshi.fanli.service.inter.common.JumpDetailV2Service;

@@ -47,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;

@@ -58,6 +63,12 @@
@Service

public class UserSystemCouponServiceImpl implements UserSystemCouponService {



   @Resource(name = "taskExecutor")

   private TaskExecutor executor;

	
   @Resource

   private RedisManager redisManager;

	
   @Resource

   private UserSystemCouponMapper userSystemCouponMapper;



@@ -185,6 +196,22 @@
      // 插入数据库

      insertSelective(userCoupon);

      

      executor.execute(new Runnable() {

         @Override

         public void run() {

            UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);

            // 添加一条消息

            if (userInfoExtra != null) {

               userInfoExtra.setCouponNews(userInfoExtra.getCouponNews() + 1);

               try {

                  userInfoExtraService.saveUserInfoExtra(userInfoExtra);

               } catch (UserInfoExtraException e) {

                  e.printStackTrace();

               }

            }

				
         }

      });

      

      // 消息推送

      try {

@@ -193,7 +220,7 @@
         } else if (coupon.getType() != CouponTypeEnum.freeCoupon) {

            userOtherMsgNotificationService.freeSheetCouponGet(userCoupon);

         } else if (coupon.getType() != CouponTypeEnum.rebatePercentCoupon) {

            userOtherMsgNotificationService.rewardCouponGet(userCoupon);

            userOtherMsgNotificationService.rewardCouponGet(userCoupon,coupon.getPercent().intValue());

         }

         

      } catch(Exception e) {

@@ -206,7 +233,7 @@
   }



   

	
   @Transactional

   @Override

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

         throws UserSystemCouponException, Exception {

@@ -218,7 +245,7 @@
      // 更新过期券

      updateCounponInvalid(uid);

      // 退回券

      sendBackCoupon(uid);

      sendBackTimeOutCoupon(uid);

      

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

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

@@ -313,7 +340,7 @@


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

                  // 返利奖励券- 跳转至订单到账界面

                  jumpLink.put("state", 2);

                  jumpLink.put("state", "2");

                  

                  jumpBtn = new HashMap<String, Object>();

                  jumpBtn.put("params", jumpLink);

@@ -399,8 +426,9 @@


         Integer stateActivated = userCouponVO.getStateActivated();

         if (stateActivated == null || stateActivated == 0) {

            userCouponVO.setCouponPicture(PIC_INVALID); // 未激活

            userCouponVO.setState(0);

            userCouponVO.setCouponEffect("待激活");

            userCouponVO.setCouponPicture(PIC_INVALID); // 未激活图片

         } else {

            userCouponVO.setCouponPicture(systemCoupon.getPicture());

         }

@@ -456,6 +484,7 @@
      return hasCoupon;

   }



   @Transactional

   @Override

   public List<UserSystemCouponVO> getOrderCouponList(Long uid) throws UserSystemCouponException, Exception {

      if (uid == null) {

@@ -465,7 +494,7 @@
      // 更新过期券

      updateCounponInvalid(uid);

      // 退回券

      sendBackCoupon(uid);

      sendBackTimeOutCoupon(uid);

            

      // 订单相关的券

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

@@ -476,16 +505,22 @@
      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为空");

      }

      

      // 更新过期券

      updateCounponInvalid(uid);

      // 退回券

      sendBackCoupon(uid);

      sendBackTimeOutCoupon(uid);

      

      // 商品相关的券

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

@@ -493,9 +528,29 @@
         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(PIC_INVALID);

               }

            }

         }

      }

		
      return list;

   }



   @Transactional

   @Override

   public void useGoodsCoupon(Long uid, Long id, Long goodId) throws UserSystemCouponException, Exception {

      if (uid == null) {

@@ -549,9 +604,9 @@
      // 消息推送

      try {

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

            userOtherMsgNotificationService.welfareCouponUsing(userSystemCoupon);

//            userOtherMsgNotificationService.welfareCouponUsing(userSystemCoupon,order);

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

            userOtherMsgNotificationService.freeSheetCouponUsing(userSystemCoupon);

//            userOtherMsgNotificationService.freeSheetCouponUsing(userSystemCoupon);

         }

         

      } catch(Exception e) {

@@ -666,7 +721,7 @@
         

         // 消息推送

         try {

            userOtherMsgNotificationService.rewardCouponUsed(userSystemCoupon);

            userOtherMsgNotificationService.rewardCouponUsed(userSystemCoupon, hongBao, money, orderNo);

         } catch(Exception e) {

            LogHelper.errorDetailInfo(e);

         }

@@ -718,20 +773,23 @@
      }

      

      // 获取奖励金额

      Map<String, BigDecimal> map = orderHongBaoMapService.getCouponHongbaoByOrderNo(orderNo, uid);



      BigDecimal couponMoney = orderHongBaoMapService.getCouponHongbaoByOrderNo(orderNo, uid);

		
      UserSystemCouponRecordVO userRecordVO = new UserSystemCouponRecordVO();

      userRecordVO.setCouponMoneyState("已到账");

      userRecordVO.setCommonOrder(commonOrderVO);

      userRecordVO.setCouponName("奖励金: ¥" + map.get("couponMoney").setScale(2, BigDecimal.ROUND_DOWN));

      userRecordVO.setCouponName("奖励金: ¥" + couponMoney.setScale(2, BigDecimal.ROUND_DOWN));



      // 比例

      BigDecimal percent = baseCoupon.getPercent();

      BigDecimal hongBao = map.get("totalMoney").setScale(2, BigDecimal.ROUND_DOWN);

      userRecordVO.setCouponEffect("返利¥" + hongBao + "已返" + percent + "%");

      BigDecimal hongBao = commonOrderVO.getHongBao();

      if (hongBao == null) {

         hongBao = new BigDecimal(0);

      }

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

@@ -749,6 +807,7 @@
      return userRecordVO;

   }



	
   @Override

   public UserSystemCouponRecordVO getFreeCouponRecord(String orderNo) throws UserSystemCouponException, Exception {



@@ -950,7 +1009,7 @@
      return userRecordVO;

   }

   

	
   @Transactional

   @Override

   public void activatedWelfareFreeCoupon(Long uid) {

      if (uid == null) {

@@ -963,11 +1022,74 @@
      if (systemCoupon == null) {

         return;

      }

      // 激活福利免单券

      userSystemCouponMapper.activateCouponByType(uid, systemCoupon.getId());

		
      // 待活福利免单券

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

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

         return;

      }

		
      for (UserSystemCoupon userSystemCoupon: list) {

         // 激活

         userSystemCoupon.setStateActivated(1);

         userSystemCoupon.setUpdateTime(new Date());

         userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);

			
         // 消息推送

         try {

            userOtherMsgNotificationService.welfareCouponGet(userSystemCoupon);

         } catch(Exception e) {

            try {

               LogHelper.errorDetailInfo(e);

            } catch (Exception e1) {

               e1.printStackTrace();

            }

         }

      }

   }

   

   @Transactional

   @Override

   public void updateStateByDrawback(String orderNo) throws Exception {

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

         return;

      }



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

      if (record == null) {

         return;

      }

		
      record.setOrderNo(orderNo);

      record.setUpdateTime(new Date());

      record.setState(UserSystemCouponRecord.STATE_FAIL_DRAWBACK);

      userSystemCouponRecordService.updateByPrimaryKeySelective(record);

		
      // 券退回

      sendBackCoupon(record.getUserSystemCoupon());

   }

	
   @Transactional

   @Override

   public void updateStateByArrivalAccount(String orderNo) throws Exception {

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

         return;

      }



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

      if (record == null) {

         return;

      }

		
      record.setOrderNo(orderNo);

      record.setUpdateTime(new Date());

      record.setState(UserSystemCouponRecord.STATE_SUCCESS);

      userSystemCouponRecordService.updateByPrimaryKeySelective(record);

   }



   @Transactional

   @Override

   public void updateCounponInvalid(Long uid) {

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

@@ -1010,10 +1132,11 @@
      }

   }

   

   @Transactional

   @Override

   public void  sendBackCoupon(Long uid) {

   public void  sendBackTimeOutCoupon(Long uid) {

      // 超过120秒 未被匹配的券

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

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

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

         return;

      }

@@ -1025,9 +1148,6 @@
         userSystemCouponRecordService.updateByPrimaryKeySelective(couponRecord);

         

         UserSystemCoupon userSystemCoupon = couponRecord.getUserSystemCoupon();

         // 状态初始化

         userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE);

         userSystemCoupon.setUseTime(null);

         

         int expiryDay = 15;

         

@@ -1046,16 +1166,129 @@
         } 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);

      }

		
   }

   

   @Transactional

   @Override

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

         Long auctionId) throws  Exception{

		
      boolean isfree = false;

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

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

      }

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

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

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

         return  isfree;

      }

		
      // 匹配

      boolean matching = false;

      UserSystemCouponRecord record = null;

		
      for (UserSystemCouponRecord userSystemCouponRecord : list) {

         Long goodId = userSystemCouponRecord.getGoodId();

         if (auctionId.equals(goodId)) {

            matching = true; // 匹配成功

            record = userSystemCouponRecord;

            break;

         }

      }

		
      // 商品匹配成功

      if (matching) {

			
         record.setOrderNo(orderNo);

         record.setUpdateTime(new Date());

			
         UserSystemCoupon userSystemCoupon = record.getUserSystemCoupon();

			
         if (payment.compareTo(new BigDecimal(10)) > 0) {

            // 更新记录 -- 金额不匹配  大10元

            record.setState(UserSystemCouponRecord.STATE_FAIL_RULE);

            userSystemCouponRecordService.updateByPrimaryKeySelective(record);

				
            // 退回券

            sendBackCoupon(userSystemCoupon);

				
         } else {

            // 免单匹配成功

            isfree = true;

				
            //更新记录--免单中

            record.setState(UserSystemCouponRecord.STATE_FREE_ON);

            userSystemCouponRecordService.updateByPrimaryKeySelective(record);

				
            // 券结束使用

            userSystemCoupon.setState(UserSystemCoupon.STATE_END_USE);

            userSystemCoupon.setUpdateTime(new Date());

            userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);

				
            SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon();

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

            if (baseCoupon == null) {

               // 券已使用

               userOtherMsgNotificationService.freeSheetCouponUsed(userSystemCoupon, orderNo);

            } else    if (baseCoupon.getType() != CouponTypeEnum.welfareFreeCoupon) {

               userOtherMsgNotificationService.welfareCouponUsing(userSystemCoupon,orderNo,payment);

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

               userOtherMsgNotificationService.freeSheetCouponUsed(userSystemCoupon,orderNo);

            } 
         }

      }

		
      return isfree;

   }

	
   /**

    * 退回券 初始数据

    * @param userSystemCoupon

    */

   public void sendBackCoupon(UserSystemCoupon userSystemCoupon) throws Exception{



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

   }