免单商品的红包处理

admin

2019-02-27 309a22d0624e8fec46f4b6722ed6135fe0a2ea3d

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

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

@@ -27,11 +28,14 @@
import com.yeshi.fanli.entity.system.SystemCoupon;

import com.yeshi.fanli.entity.system.SystemCoupon.CouponTypeEnum;

import com.yeshi.fanli.exception.user.UserSystemCouponException;

import com.yeshi.fanli.log.LogHelper;

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

import com.yeshi.fanli.service.inter.config.ConfigService;

import com.yeshi.fanli.service.inter.config.SystemCouponService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoV2Service;

import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce;

import com.yeshi.fanli.service.inter.msg.UserMoneyMsgNotificationService;

import com.yeshi.fanli.service.inter.msg.UserOtherMsgNotificationService;

import com.yeshi.fanli.service.inter.order.CommonOrderService;

import com.yeshi.fanli.service.inter.order.HongBaoOrderService;

import com.yeshi.fanli.service.inter.order.OrderHongBaoMapService;

@@ -95,6 +99,13 @@
   

   @Resource

   private UserInfoExtraService userInfoExtraService;

	
   @Resource

   private ThreeSaleSerivce threeSaleSerivce;

	
   @Resource

   private UserOtherMsgNotificationService userOtherMsgNotificationService;

	


   // 券失效图片

   public final static String PIC_INVALID = "http://192.168.1.200/icon/mian_invalid.png";

@@ -135,13 +146,80 @@
   }



   @Override

   public void insertUserCoupon(Long uid, String couponType,String source)throws UserSystemCouponException,Exception{

		
      if (couponType == null || uid == null) {

         throw new UserSystemCouponException(1, "参数不正确");

      } 
		
      SystemCoupon coupon= systemCouponService.getCouponByType(couponType);

      if (coupon == null) {

         throw new UserSystemCouponException(1, "券类型不正确");

      } 
		
      int stateActivated = 1;

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

         // 福利券状态

         long countSuccess = threeSaleSerivce.countSuccessFirstTeam(uid);

         // 没有下级队员 --待激活

         if (countSuccess == 0) {

            stateActivated = 0;

         }

      }

		
      // 结束日期

      String endDay = DateUtil.plusDay(coupon.getExpiryDay(), new Date());

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

      Date endTime = format.parse(endDay);

		
      UserSystemCoupon userCoupon = new UserSystemCoupon();

      userCoupon.setUid(uid);

      userCoupon.setSource(source);

      userCoupon.setSystemCoupon(coupon);

      userCoupon.setState(UserSystemCoupon.STATE_CAN_USE);

      userCoupon.setStateActivated(stateActivated);

      userCoupon.setStartTime(new Date());

      userCoupon.setEndTime(endTime);

      userCoupon.setCreateTime(new Date());

      userCoupon.setUpdateTime(new Date());

      // 插入数据库

      insertSelective(userCoupon);

		
		
      // 消息推送

      try {

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

            userOtherMsgNotificationService.welfareCouponGet(userCoupon);

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

            userOtherMsgNotificationService.freeSheetCouponGet(userCoupon);

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

            userOtherMsgNotificationService.rewardCouponGet(userCoupon);

         }

			
      } catch(Exception e) {

         try {

            LogHelper.errorDetailInfo(e);

         } catch (Exception e1) {

            e1.printStackTrace();

         }

      }

   }



	
	
   @Override

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

         throws UserSystemCouponException, Exception {



      if (uid == null) {

         return null;

      }



		
      // 更新过期券

      updateCounponInvalid(uid);

      // 退回券

      sendBackTimeOutCoupon(uid);

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

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

         return listVO;

@@ -201,17 +279,19 @@
            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=ture"));

               // 邀请激活成功界面

               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("jumpDetail", jumpDetailV2Service.getByTypeCache("invite"));

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



         } else if (stateActivated == 1) {

            // 显示规则

@@ -272,7 +352,6 @@
                  differentDays = 0;

               }

            }



            // 剩余天数

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

            remainDays.put("content", "还剩" + differentDays + "天过期");

@@ -382,6 +461,12 @@
      if (uid == null) {

         throw new UserSystemCouponException(1, "用户未登录");

      }

		
      // 更新过期券

      updateCounponInvalid(uid);

      // 退回券

      sendBackTimeOutCoupon(uid);

				
      // 订单相关的券

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

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

@@ -396,6 +481,12 @@
      if (uid == null) {

         throw new UserSystemCouponException(1, "用户未登录");

      }

		
      // 更新过期券

      updateCounponInvalid(uid);

      // 退回券

      sendBackTimeOutCoupon(uid);

		
      // 商品相关的券

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

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

@@ -454,6 +545,19 @@
      couponRecord.setCreateTime(date);

      couponRecord.setUpdateTime(date);

      userSystemCouponRecordService.insertSelective(couponRecord);

		
      // 消息推送

      try {

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

            userOtherMsgNotificationService.welfareCouponUsing(userSystemCoupon);

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

            userOtherMsgNotificationService.freeSheetCouponUsing(userSystemCoupon);

         }

			
      } catch(Exception e) {

         LogHelper.errorDetailInfo(e);

      }

		
   }



   @Transactional

@@ -559,6 +663,13 @@
         couponRecord.setCreateTime(date);

         couponRecord.setUpdateTime(date);

         userSystemCouponRecordService.insertSelective(couponRecord);

			
         // 消息推送

         try {

            userOtherMsgNotificationService.rewardCouponUsed(userSystemCoupon);

         } catch(Exception e) {

            LogHelper.errorDetailInfo(e);

         }

      }



   }

@@ -607,17 +718,20 @@
      }

      

      // 获取奖励金额

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

@@ -838,7 +952,251 @@


      return userRecordVO;

   }

	
	
   @Override

   public void activatedWelfareFreeCoupon(Long uid) {

      if (uid == null) {

         return;

      }

      // 福利免单券

      String welfareFree = CouponTypeEnum.welfareFreeCoupon.name();

		
      SystemCoupon systemCoupon = systemCouponService.getCouponByType(welfareFree);

      if (systemCoupon == null) {

         return;

      }

		
      // 待活福利免单券

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

            }

         }

      }

		
		
   }

	


   @Override

   public void updateCounponInvalid(Long uid) {

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

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

         return;

      }

		
      for (UserSystemCoupon userSystemCoupon: list) {

         // 更新券已过期

         userSystemCoupon.setState(UserSystemCoupon.STATE_OVERDUE);

         userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);

			
         SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon();

         if (systemCoupon == null) {

            continue;

         }

			
         SystemCoupon baseCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.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);

            }

				
         } catch(Exception e) {

            try {

               LogHelper.errorDetailInfo(e);

            } catch (Exception e1) {

               e1.printStackTrace();

            }

         }

      }

   }

	
   @Override

   public void  sendBackTimeOutCoupon(Long uid) {

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

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

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

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

      }

   }

	
   @Override

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

         Long auctionId) throws  Exception{

		
      //只处理付款金额小于10的

      if(payment==null||payment.compareTo(new BigDecimal(10))<0)

         return false;

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

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

               userOtherMsgNotificationService.welfareCouponUsed(userSystemCoupon);

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

               userOtherMsgNotificationService.freeSheetCouponUsed(userSystemCoupon);

            } 
         }

      }

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

   }

	
   

   

}