主分类 + 子分类 DAO改造

yujian

2019-03-27 cdcbed9af813b2a02cdc01eefa24db8bec6b51a9

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

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



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

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

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

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

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

@@ -26,6 +27,8 @@
import com.yeshi.fanli.entity.common.JumpDetailV2;

import com.yeshi.fanli.entity.money.UserMoneyDetail;

import com.yeshi.fanli.entity.order.CommonOrder;

import com.yeshi.fanli.entity.push.PushCoupon;

import com.yeshi.fanli.entity.push.PushCouponRecord;

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

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

import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;

@@ -39,10 +42,14 @@
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.CommonOrderCountService;

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

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

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

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

import com.yeshi.fanli.service.inter.push.PushCouponRecordService;

import com.yeshi.fanli.service.inter.push.PushCouponService;

import com.yeshi.fanli.service.inter.user.DeviceLotteryRecordService;

import com.yeshi.fanli.service.inter.user.UserInfoExtraService;

import com.yeshi.fanli.service.inter.user.UserInfoService;

import com.yeshi.fanli.service.inter.user.UserMoneyDetailService;

@@ -65,10 +72,10 @@


   @Resource(name = "taskExecutor")

   private TaskExecutor executor;

	


   @Resource

   private RedisManager redisManager;

	


   @Resource

   private UserSystemCouponMapper userSystemCouponMapper;



@@ -107,17 +114,29 @@


   @Resource

   private UserMoneyMsgNotificationService userMoneyMsgNotificationService;

	


   @Resource

   private UserInfoExtraService userInfoExtraService;

	


   @Resource

   private ThreeSaleSerivce threeSaleSerivce;

	


   @Resource

   private UserOtherMsgNotificationService userOtherMsgNotificationService;

	


   @Resource

   private DeviceLotteryRecordService deviceLotteryRecordService;



   @Resource

   private CommonOrderCountService commonOrderCountService;

	
   @Resource

   private PushCouponService pushCouponService;

	
   @Resource

   private PushCouponRecordService pushCouponRecordService;

	
	
   @Override

   public int insertSelective(UserSystemCoupon record) {

      return userSystemCouponMapper.insertSelective(record);

@@ -147,24 +166,34 @@
   public List<UserSystemCoupon> getUserCouponBySource(Long uid, String source) {

      return userSystemCouponMapper.getUserCouponBySource(uid, source);

   }

	


   @Override

   public long countUserCouponList(Long uid) {

      return userSystemCouponMapper.countUserCouponList(uid);

   }



   @Override

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

		
   @Transactional

   public void insertUserCoupon(Long uid, String couponType, String source)

         throws UserSystemCouponException, Exception {



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

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

      } 
      }



      SystemCoupon coupon = null;

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

         // 福利免单券

         coupon = systemCouponService.getCouponByType(couponType);

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

         // 奖励券10%

         coupon = systemCouponService.getCouponByTypeAndPercent(couponType,new BigDecimal(10));

      }

      

      SystemCoupon coupon= systemCouponService.getCouponByType(couponType);

      if (coupon == null) {

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

      } 
		
      }



      int stateActivated = 1;

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

         // 福利券状态

@@ -174,12 +203,13 @@
            stateActivated = 0;

         }

      }

		


      // 结束日期

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

      // 今天在内  减去一天

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

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

      Date endTime = format.parse(endDay);

		


      UserSystemCoupon userCoupon = new UserSystemCoupon();

      userCoupon.setUid(uid);

      userCoupon.setSource(source);

@@ -192,7 +222,7 @@
      userCoupon.setUpdateTime(new Date());

      // 插入数据库

      insertSelective(userCoupon);

		


      executor.execute(new Runnable() {

         @Override

         public void run() {

@@ -204,18 +234,17 @@
               } else {

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

               }

					
					


               try {

                  userInfoExtraService.saveUserInfoExtra(userInfoExtra);

               } catch (UserInfoExtraException e) {

                  e.printStackTrace();

               }

            }

				


         }

      });

		


      // 消息推送

      try {

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

@@ -223,10 +252,10 @@
         } else if (coupon.getType() == CouponTypeEnum.freeCoupon) {

            userOtherMsgNotificationService.freeSheetCouponGet(userCoupon);

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

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

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

         }

			
      } catch(Exception e) {



      } catch (Exception e) {

         try {

            LogHelper.errorDetailInfo(e);

         } catch (Exception e1) {

@@ -235,7 +264,6 @@
      }

   }



	
   @Transactional

   @Override

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

@@ -244,12 +272,12 @@
      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;

@@ -266,7 +294,7 @@
    * 

    * @param listVO

    */

   public void listDataFactory(List<UserSystemCouponVO> listVO, Long uid) throws Exception{

   public void listDataFactory(List<UserSystemCouponVO> listVO, Long uid) throws Exception {



      for (UserSystemCouponVO userCouponVO : listVO) {



@@ -290,15 +318,15 @@


         // 使用状态

         Integer state = userCouponVO.getState();

			


         // 券类型

         CouponTypeEnum type = systemCoupon.getType();

			


         // 按钮跳转

         Map<String, Object> jumpBtn = null;

			


         Integer stateActivated = userCouponVO.getStateActivated();

			


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

            // 显示规则

            userCouponVO.setCouponRule(systemCoupon.getRemark());

@@ -310,20 +338,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") +

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



         } else if (stateActivated == 1) {

@@ -335,7 +364,7 @@


               if (CouponTypeEnum.freeCoupon == type || CouponTypeEnum.welfareFreeCoupon == type) {

                  // 免单券、 福利免单券

						


                  // 免单商品列表

                  jumpLink.put("url", configService.get("free_goods_list"));



@@ -346,24 +375,24 @@
               } else if (CouponTypeEnum.rebatePercentCoupon == type) {

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

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

						


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

                  jumpBtn.put("params", jumpLink);

                  // 跳转订单列表

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

               }

					


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

               // 使用中

               userCouponVO.setInUseExplain(configService.get("free_coupon_using-help"));

            }

         }

			


         // 券失效图片替换

         if (UserSystemCoupon.STATE_END_USE == state || UserSystemCoupon.STATE_OVERDUE == state) {

            userCouponVO.setCouponPicture(systemCoupon.getPictureInvalid());

         } 
			
         }



         userCouponVO.setJumpBtn(jumpBtn);



         String couponTerm = "有效期：";

@@ -430,7 +459,6 @@
         userCouponVO.setCouponRule(systemCoupon.getRule());

         userCouponVO.setCouponPictureInvalid(systemCoupon.getPictureInvalid());





         int differentDays = 0;

         String couponTerm = "有效期：";

         Date startTime = userCouponVO.getStartTime();

@@ -438,7 +466,7 @@
         if (endTime != null && startTime != null) {

            SimpleDateFormat sdf = new SimpleDateFormat("yyyy.MM.dd");

            couponTerm = couponTerm + sdf.format(startTime) + "-" + sdf.format(endTime);

				


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

            differentDays = DateUtil.daysBetween(sdf2.format(new Date()), sdf2.format(endTime)) + 1;

            if (differentDays < 0) {

@@ -451,22 +479,22 @@
         // 剩余天数

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

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

         String  remainDaysFontColor = "";

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

      }

@@ -501,15 +529,18 @@
   @Transactional

   @Override

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

		
      if (uid == null) {

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

      }

		


      // 更新过期券

      updateCounponInvalid(uid);

      // 退回券

      sendBackTimeOutCoupon(uid);

				
      // 活动领取券

//      receivedCoupon(uid);



      // 订单相关的券

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

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

@@ -521,21 +552,25 @@


   @Transactional

   @Override

   public List<UserSystemCouponVO> getGoodsCouponList(Long uid, Long auctionId) 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);

      // 退回券

      sendBackTimeOutCoupon(uid);

      

      // 活动领取券

//      receivedCoupon(uid);



      // 商品相关的券

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

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

@@ -543,31 +578,31 @@
      }



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

               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;

   }



@@ -586,6 +621,16 @@
      if (userSystemCoupon == null) {

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

      }

		
      if (userSystemCoupon.getUid().longValue() != uid) {

         throw new UserSystemCouponException(1, "不属于该用户的券");

      }



      Integer state = userSystemCoupon.getState();

      Integer stateActivated = userSystemCoupon.getStateActivated();

      if (UserSystemCoupon.STATE_CAN_USE != state || 1 != stateActivated) {

         throw new UserSystemCouponException(1, "该券不能被使用");

      }



      Long couponUid = userSystemCoupon.getUid();

      if (!uid.equals(couponUid)) {

@@ -603,7 +648,7 @@
            && baseCoupon.getType() != CouponTypeEnum.welfareFreeCoupon) {

         throw new UserSystemCouponException(1, "券类型不匹配");

      }

		


      Date date = new Date();

      // 更新券使用

      userSystemCoupon.setState(UserSystemCoupon.STATE_IN_USE); // 正在匹配

@@ -621,19 +666,19 @@
      couponRecord.setCreateTime(date);

      couponRecord.setUpdateTime(date);

      userSystemCouponRecordService.insertSelective(couponRecord);

		


      // 消息推送

      try {

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

            //userOtherMsgNotificationService.welfareCouponUsing(userSystemCoupon,order.get);

            // userOtherMsgNotificationService.welfareCouponUsing(userSystemCoupon,order.get);

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

            //userOtherMsgNotificationService.freeSheetCouponUsing(userSystemCoupon);

            // userOtherMsgNotificationService.freeSheetCouponUsing(userSystemCoupon);

         }

			
      } catch(Exception e) {



      } catch (Exception e) {

         LogHelper.errorDetailInfo(e);

      }

		


   }



   @Transactional

@@ -650,6 +695,16 @@
         throw new UserSystemCouponException(1, "券信息不存在");

      }



      if (userSystemCoupon.getUid().longValue() != uid) {

         throw new UserSystemCouponException(1, "不属于该用户的券");

      }



      Integer state = userSystemCoupon.getState();

      Integer stateActivated = userSystemCoupon.getStateActivated();

      if (UserSystemCoupon.STATE_CAN_USE != state || 1 != stateActivated) {

         throw new UserSystemCouponException(1, "该券不能被使用");

      }



      // 系统券信息

      SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon();

      if (systemCoupon != null && systemCoupon.getId() != null) {

@@ -663,7 +718,6 @@
         throw new UserSystemCouponException(1, "券类型不匹配");

      }



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

         throw new UserSystemCouponException(1, "订单号不存在");

      }

@@ -673,7 +727,6 @@
      if (orderVO == null) {

         throw new UserSystemCouponException(1, "订单信息获取失败");

      }





      BigDecimal hongBao = orderVO.getHongBao();

      // 红包状态

@@ -739,11 +792,11 @@
         couponRecord.setCreateTime(date);

         couponRecord.setUpdateTime(date);

         userSystemCouponRecordService.insertSelective(couponRecord);

			


         // 消息推送

         try {

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

         } catch(Exception e) {

         } catch (Exception e) {

            LogHelper.errorDetailInfo(e);

         }

      }

@@ -785,17 +838,17 @@
      }



      Long uid = userSystemCoupon.getUid();

		
      CommonOrderVO commonOrderVO= commonOrderService.getCommonOrderByOrderNo(userSystemCoupon.getUid(),

            orderNo, CommonOrder.STATE_JS);

		


      CommonOrderVO commonOrderVO = commonOrderService.getCommonOrderByOrderNo(userSystemCoupon.getUid(), orderNo,

            CommonOrder.STATE_JS);



      if (commonOrderVO == null) {

         throw new UserSystemCouponException(1, "订单信息获取失败");

      }

		


      // 获取奖励金额

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

		


      UserSystemCouponRecordVO userRecordVO = new UserSystemCouponRecordVO();

      userRecordVO.setCouponMoneyState("已到账");

      userRecordVO.setCommonOrder(commonOrderVO);

@@ -828,7 +881,6 @@
      return userRecordVO;

   }



	
   @Override

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



@@ -878,7 +930,7 @@
      String progressMsg = "";

      String progressColor = "";

      // 跳转奖励券规则

      userRecordVO.setRuleLink(configService.get("reward_coupon_help"));

      userRecordVO.setRuleLink(configService.get("free_coupon_help"));



      // 进度： 1 灰色 2 红色 3 绿色

      String progressState1 = "3";

@@ -1029,37 +1081,53 @@


      return userRecordVO;

   }

	


   @Transactional

   @Override

   public void activatedWelfareFreeCoupon(Long uid) {

   public void activatedWelfareFreeCoupon(Long uid, String fromNickName) {



      LogHelper.test("券激活:" + uid);

      if (uid == null) {

         return;

      }

      // 福利免单券

      String welfareFree = CouponTypeEnum.welfareFreeCoupon.name();

		


      SystemCoupon systemCoupon = systemCouponService.getCouponByType(welfareFree);

      if (systemCoupon == null) {

         return;

      }

		


      // 验证是否失效

      updateCounponInvalid(uid);



      // 待活福利免单券

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

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

         return;

      }

		
      for (UserSystemCoupon userSystemCoupon: list) {



      for (UserSystemCoupon userSystemCoupon : list) {

         // 激活

         userSystemCoupon.setStateActivated(1);

         userSystemCoupon.setUpdateTime(new Date());

         userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);

			
         UserSystemCoupon update = new UserSystemCoupon();

         update.setId(userSystemCoupon.getId());

         update.setStateActivated(1);

         update.setUpdateTime(new Date());

         userSystemCouponMapper.updateByPrimaryKeySelective(update);



         Integer state = userSystemCoupon.getState();

         if (UserSystemCoupon.STATE_OVERDUE == state) {

            continue; // 已失效不做消息推送

         }



         // 消息推送

         try {

            userOtherMsgNotificationService.welfareCouponGet(userSystemCoupon);

         } catch(Exception e) {

            UserInfo userInfo = new UserInfo();

            userInfo.setId(uid);

            userInfo.setNickName(fromNickName);



            userOtherMsgNotificationService.welfareCouponActive(userSystemCoupon, userInfo);

         } catch (Exception e) {

            try {

               LogHelper.errorDetailInfo(e);

            } catch (Exception e1) {

@@ -1068,11 +1136,11 @@
         }

      }

   }

	


   @Transactional

   @Override

   public void updateStateByDrawback(String orderNo) throws Exception {

		


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

         return;

      }

@@ -1081,20 +1149,20 @@
      if (record == null) {

         return;

      }

		


      record.setOrderNo(orderNo);

      record.setUpdateTime(new Date());

      record.setState(UserSystemCouponRecord.STATE_FAIL_DRAWBACK);

      userSystemCouponRecordService.updateByPrimaryKeySelective(record);

		


      // 券退回

      sendBackCoupon(record.getUserSystemCoupon(), record);

   }

	


   @Transactional

   @Override

   public void updateStateByArrivalAccount(String orderNo) throws Exception {

		


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

         return;

      }

@@ -1103,18 +1171,18 @@
      if (record == null) {

         return;

      }

		


      record.setOrderNo(orderNo);

      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

@@ -1124,22 +1192,22 @@
      if (list == null || list.size() == 0) {

         return;

      }

		
      for (UserSystemCoupon userSystemCoupon: list) {



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

@@ -1149,8 +1217,8 @@
            } else if (baseCoupon.getType() == CouponTypeEnum.rebatePercentCoupon) {

               userOtherMsgNotificationService.rewardCouponAlreadyOutOfDate(userSystemCoupon);

            }

				
         } catch(Exception e) {



         } catch (Exception e) {

            try {

               LogHelper.errorDetailInfo(e);

            } catch (Exception e1) {

@@ -1159,36 +1227,37 @@
         }

      }

   }

	


   @Transactional

   @Override

   public void  sendBackTimeOutCoupon(Long uid) {

   public void sendBackTimeOutCoupon(Long uid) {

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

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

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

         return;

      }

		
      for (UserSystemCouponRecord couponRecord: list) {



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

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

         if (coupon != null) {

            expiryDay = coupon.getExpiryDay();

         } 
			
         }



         // 结束日期

         Date endTime = null;

         try {

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

            // 今天在内  减去一天

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

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

            endTime = format.parse(endDay);

         } catch (ParseException e) {

@@ -1197,7 +1266,7 @@
         // 状态初始化

         userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE);

         userSystemCoupon.setUseTime(null);

						


         // 有效期时间重新定义

         userSystemCoupon.setStartTime(new Date());

         userSystemCoupon.setEndTime(endTime);

@@ -1205,29 +1274,29 @@
         userSystemCouponMapper.updateByPrimaryKey(userSystemCoupon);

      }

   }

	


   @Transactional

   @Override

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

         Long auctionId) throws  Exception{

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



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

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

            UserSystemCouponRecord.STATE_WAIT);

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

         return  isfree;

         return isfree;

      }

		


      // 匹配

      boolean matching = false;

      UserSystemCouponRecord record = null;

		


      for (UserSystemCouponRecord userSystemCouponRecord : list) {

         Long goodId = userSystemCouponRecord.getGoodId();

         if (auctionId.equals(goodId)) {

@@ -1236,57 +1305,58 @@
            break;

         }

      }

		


      // 商品匹配成功

      if (matching) {

			


         record.setOrderNo(orderNo);

         record.setUpdateTime(new Date());

			


         UserSystemCoupon userSystemCoupon = record.getUserSystemCoupon();

			


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

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

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

            record.setState(UserSystemCouponRecord.STATE_FAIL_RULE);

            userSystemCouponRecordService.updateByPrimaryKeySelective(record);

				


            // 退回券

            sendBackCoupon(userSystemCoupon, record);

				


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

				


            String couponType = record.getCouponType();

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

               throw new Exception("券类型未被记录");

            }

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

               userOtherMsgNotificationService.welfareCouponUsing(userSystemCoupon,orderNo,payment);



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

               userOtherMsgNotificationService.welfareCouponUsing(userSystemCoupon, orderNo, payment);

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

               userOtherMsgNotificationService.freeSheetCouponUsing(userSystemCoupon, orderNo, payment);

            } 
            }

         }

      }

		


      return isfree;

   }

	


   /**

    * 退回券 初始数据

    * 
    * @param userSystemCoupon

    */

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

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



      int expiryDay = 15;



@@ -1299,7 +1369,8 @@
      // 结束日期

      Date endTime = null;

      try {

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

         // 今天在内  减去一天

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

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

         endTime = format.parse(endDay);

      } catch (ParseException e) {

@@ -1311,19 +1382,319 @@
      // 有效期时间重新定义

      userSystemCoupon.setStartTime(new Date());

      userSystemCoupon.setEndTime(endTime);

		


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

      } 
      }

   }



   @Override

   @Transactional

   public void copyLotteryPrize(Long uid, int platform, String device) throws Exception {



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

         return;

      }



      // 未登陆之前抽奖记录

      List<DeviceLotteryRecord> list = deviceLotteryRecordService.listByPlatformAndDevice(platform, device);

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

         return;

      }



      // 获取额外信息

      UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);



      // 已经抽过奖的或者已经进入过抽奖页面的

      if (userInfoExtra != null && userInfoExtra.getLotteryNewbies() != null) {

         return;

      }



      // 是否有过订单：返利、分享订单

      boolean hasOrder = commonOrderCountService.hasRebateAndShareOrder(uid);

      if (hasOrder) {

         return;

      }



      int coupon = 0;



      for (DeviceLotteryRecord reviceLotteryRecord : list) {



         // 删除记录

         deviceLotteryRecordService.deleteByPrimaryKey(reviceLotteryRecord.getId());



         Long systemCouponId = reviceLotteryRecord.getSystemCouponId();

         if (systemCouponId == null) {

            continue;

         }

         SystemCoupon systemCoupon = systemCouponService.selectByPrimaryKey(systemCouponId);

         if (systemCoupon == null) {

            continue;

         }



         int stateActivated = 1;

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

            // 福利券状态

            long countSuccess = threeSaleSerivce.countSuccessFirstTeam(uid);

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

            if (countSuccess == 0) {

               stateActivated = 0;

            }

         }

			
         // 结束日期

         // 今天在内  减去一天

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

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

         Date endTime = format.parse(endDay);



         UserSystemCoupon userCoupon = new UserSystemCoupon();

         userCoupon.setUid(uid);

         userCoupon.setSource(UserSystemCoupon.SOURCE_CHOUJIANG);

         userCoupon.setSystemCoupon(systemCoupon);

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



         // 券数量

         coupon++;



         // 消息推送

         try {

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

               userOtherMsgNotificationService.welfareCouponGet(userCoupon);

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

               userOtherMsgNotificationService.freeSheetCouponGet(userCoupon);

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

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

            }



         } catch (Exception e) {

            try {

               LogHelper.errorDetailInfo(e);

            } catch (Exception e1) {

               e1.printStackTrace();

            }

         }

      }



      if (userInfoExtra == null) {

         userInfoExtra = new UserInfoExtra();

         userInfoExtra.setUserInfo(new UserInfo(uid));

      }



      userInfoExtra.setLotteryNewbies(Constant.MAX_COUNT_LOTTERY_NEWBIES - list.size());

      Integer couponNews = userInfoExtra.getCouponNews();

      if (couponNews == null) {

         userInfoExtra.setCouponNews(coupon);

      } else {

         userInfoExtra.setCouponNews(couponNews + coupon);

      }

      userInfoExtraService.saveUserInfoExtra(userInfoExtra);



   }

   

   @Override

   @Transactional

   public void receivedCoupon(Long uid) throws Exception {

		
      List<PushCoupon> list = pushCouponService.listQueryEffective();

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

         return;

      }

		
      List<PushCouponRecord> listRecord = pushCouponRecordService.listByUid(uid);

		
      for (PushCoupon pushCoupon: list) {

			
         boolean receive = false;

			
         String uids = pushCoupon.getUids();

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

            receive = true;

         } else {

            String[] uidArray = uids.split(",");

				
            if (uidArray != null) {

               for (int i = 0; i < uidArray.length; i++) {

                  String str_uid = uidArray[i];

                  if (str_uid != null && str_uid.trim().length() > 0) {

                     if(str_uid.equals(uid.toString())) {

                        receive = true;

                     }

                  }

               }

            }

         }

			
         if (!receive) {

            continue;

         }

			
         if (listRecord != null && listRecord.size() > 0) {

            for (PushCouponRecord PushCouponRecord: listRecord) {

                PushCoupon pushCoupon2 = PushCouponRecord.getPushCoupon();

					
               if (pushCoupon.getId().equals(pushCoupon2.getId()) ) {

                  receive = false;

                  break;

               }

            }

         }

			
         if (receive) {

            // 插入记录

            PushCouponRecord pushCouponRecord = new PushCouponRecord();

            pushCouponRecord.setPushCoupon(pushCoupon);

            pushCouponRecord.setUid(uid);

            pushCouponRecord.setCreateTime(new Date());

            pushCouponRecordService.insertSelective(pushCouponRecord);

				
            // 插入券

            randomRewardCoupon(pushCoupon, uid);

         }

      }

   }

   

   @Override

   @Transactional

   public void randomRewardCoupon(PushCoupon pushCoupon, Long uid) throws Exception {

      int coupon = 0;

		
      Integer amount = pushCoupon.getAmount();

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

			
         BigDecimal percent = pushCoupon.getPercent();

         if (percent == null) {

            // 返利比-随机

            percent = new BigDecimal(randomNum());

         }

			
         // 查询奖励券

         SystemCoupon systemCoupon = systemCouponService.getCouponByTypeAndPercent(

               CouponTypeEnum.rebatePercentCoupon.name(),percent);

			
         if (systemCoupon == null) {

            return;

         }

			
         UserSystemCoupon userCoupon = new UserSystemCoupon();

         userCoupon.setUid(uid);

         userCoupon.setSource(UserSystemCoupon.SOURCE_SYSTEM_PUSH);

         userCoupon.setSystemCoupon(systemCoupon);

         userCoupon.setState(UserSystemCoupon.STATE_CAN_USE);

         userCoupon.setStateActivated(1);

         userCoupon.setStartTime(pushCoupon.getStartTime());

         userCoupon.setEndTime(pushCoupon.getEndTime());

         userCoupon.setCreateTime(new Date());

         userCoupon.setUpdateTime(new Date());

         // 插入数据库

         insertSelective(userCoupon);

			
         // 券数量

         coupon ++;

			
         // 消息推送

         try {

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

               userOtherMsgNotificationService.welfareCouponGet(userCoupon);

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

               userOtherMsgNotificationService.freeSheetCouponGet(userCoupon);

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

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

            }

				
         } catch(Exception e) {

            try {

               LogHelper.errorDetailInfo(e);

            } catch (Exception e1) {

               e1.printStackTrace();

            }

         }

      }

		
      // 获取额外信息

      UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);

      if (userInfoExtra == null) {

         return;

      }

		
      Integer couponNews = userInfoExtra.getCouponNews();

      if (couponNews == null) {

         userInfoExtra.setCouponNews(coupon);

      } else {

         userInfoExtra.setCouponNews(couponNews + coupon);

      }

      userInfoExtraService.saveUserInfoExtra(userInfoExtra);

   }

		
   /**

    * 随机券比例

    * @return

    */

   public int randomNum() {

		
      int result = 1;

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

      list.add(new RandomProportion(1,2,30));

      list.add(new RandomProportion(2,4,25));

      list.add(new RandomProportion(4,6,20));

      list.add(new RandomProportion(6,8,6));

      list.add(new RandomProportion(8,10,6));

      list.add(new RandomProportion(10,20,6));

      list.add(new RandomProportion(20,30,2));

      list.add(new RandomProportion(30,40,2));

      list.add(new RandomProportion(40,50,2));

      list.add(new RandomProportion(50,60,1));



      int minRange = 0;

      int maxRange = 0;

      int randomNum = (int) (1 + Math.round(Math.random() * (99)));

		
      for (int i = 0; i < list.size(); i++) {

			
         RandomProportion proportion = list.get(i);

         int probability = proportion.probability;

			
         maxRange = maxRange + probability;

         minRange = maxRange - probability;

			
         if (i == list.size() && randomNum > minRange && randomNum <= maxRange) {

            result = proportion.minNum + (int) (Math.random() * ((proportion.maxNum - proportion.minNum) + 1));

            break;

         } else if(randomNum > minRange && randomNum <= maxRange) {

            result = proportion.minNum + (int) (Math.random() * ((proportion.maxNum - proportion.minNum)));

            break;

         }

      }

		
      return result;

   }

	
   class RandomProportion {

      public int minNum;// 最小

      public int maxNum;// 最大

      public int probability; // 概率

		
      RandomProportion () {}

		
      RandomProportion (int minNum, int maxNum, int probability) {

         this.minNum = minNum;

         this.maxNum = maxNum;

         this.probability = probability;

      }

   }

   

}