From f4548a3ee46afe45da4ee2a42dc169c575deee9f Mon Sep 17 00:00:00 2001 From: yujian <yujian@123.com> Date: 星期三, 31 七月 2019 11:57:36 +0800 Subject: [PATCH] 动态v2兼容 --- fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java | 212 ++++++++++------------------------------------------ 1 files changed, 42 insertions(+), 170 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java index 463116b..5b8f48c 100644 --- a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java +++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java @@ -27,8 +27,6 @@ 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; @@ -191,8 +189,9 @@ // 绂忓埄鍏嶅崟鍒� coupon = systemCouponService.getCouponByType(couponType); } else if (couponType.equals(CouponTypeEnum.rebatePercentCoupon.name())) { - // 濂栧姳鍒�10% - coupon = systemCouponService.getCouponByTypeAndPercent(couponType,new BigDecimal(10)); + // 闅忔満濂栧姳鍒� + randomRewardCoupon(1, uid, source); + return; } if (coupon == null) { @@ -282,8 +281,6 @@ updateCounponInvalid(uid); // 閫�鍥炲埜 sendBackTimeOutCoupon(uid); - // 娲诲姩棰嗗彇鍒� - receivedCoupon(uid); List<UserSystemCouponVO> listVO = userSystemCouponMapper.getUserCouponVOList(start, count, uid); if (listVO == null || listVO.size() == 0) { @@ -547,8 +544,6 @@ updateCounponInvalid(uid); // 閫�鍥炲埜 sendBackTimeOutCoupon(uid); - // 娲诲姩棰嗗彇鍒� - receivedCoupon(uid); // 璁㈠崟鐩稿叧鐨勫埜 List<SystemCoupon> couponList = systemCouponService.getOrderCouponList(); @@ -577,9 +572,6 @@ // 閫�鍥炲埜 sendBackTimeOutCoupon(uid); - // 娲诲姩棰嗗彇鍒� - receivedCoupon(uid); - // 鍟嗗搧鐩稿叧鐨勫埜 List<SystemCoupon> couponList = systemCouponService.getGoodsCouponList(); if (couponList == null || couponList.size() == 0) { @@ -617,7 +609,7 @@ @Transactional @Override - public void useGoodsCoupon(Long uid, Long id, Long goodId) throws UserSystemCouponException, Exception { + public void useGoodsCoupon(Long uid, Long id, Long goodId, Integer sourceType) throws UserSystemCouponException, Exception { if (uid == null) { throw new UserSystemCouponException(1, "鐢ㄦ埛鏈櫥褰�"); } @@ -668,7 +660,7 @@ // 鎻掑叆浣跨敤鍒歌褰� UserSystemCouponRecord couponRecord = new UserSystemCouponRecord(); couponRecord.setGoodId(goodId); - couponRecord.setGoodSource(Constant.SOURCE_TYPE_TAOBAO); // 榛樿娣樺疂 + couponRecord.setGoodSource(sourceType); // 榛樿娣樺疂 couponRecord.setState(UserSystemCouponRecord.STATE_WAIT); // 姝e湪鍖归厤 couponRecord.setUserSystemCoupon(userSystemCoupon); couponRecord.setCouponType(baseCoupon.getType().name()); @@ -692,12 +684,16 @@ @Transactional @Override - public void useOrderCoupon(Long uid, Long id, String orderNo) throws UserSystemCouponException, Exception { + public void useOrderCoupon(Long uid, Long id, String orderNo, Integer sourceType) throws UserSystemCouponException, Exception { if (id == null) { throw new UserSystemCouponException(1, "鍒竔d涓嶅瓨鍦�"); } - + + if (sourceType == null) { + sourceType = Constant.SOURCE_TYPE_TAOBAO; + } + // 鐢ㄦ埛鍒� UserSystemCoupon userSystemCoupon = selectByPrimaryKey(id); if (userSystemCoupon == null) { @@ -732,7 +728,7 @@ } // 璁㈠崟 - CommonOrderVO orderVO = commonOrderService.getCommonOrderByOrderNo(uid, orderNo, CommonOrder.STATE_JS); + CommonOrderVO orderVO = commonOrderService.getCommonOrderByOrderNo(uid, orderNo, CommonOrder.STATE_JS, sourceType); if (orderVO == null) { throw new UserSystemCouponException(1, "璁㈠崟淇℃伅鑾峰彇澶辫触"); } @@ -746,7 +742,7 @@ // 鏉′欢: A:蹇呴』鏄繑鍒╄鍗� 銆丅:蹇呴』宸茬粡澶勪簬宸插埌璐︾姸鎬� if (HongBaoV2.TYPE_ZIGOU == hongBaoType && HongBaoV2.STATE_YILINGQU == hongBaoState || hongBao != null) { - Order order = orderService.findOrderByOrderIdAndType(orderNo, Order.ORDER_TYPE_TAOBAO); + Order order = orderService.findOrderByOrderIdAndType(orderNo, sourceType); if (order == null) return; @@ -768,19 +764,20 @@ hongBaoV2.setUserInfo(new UserInfo(uid)); hongBaoV2.setPreGetTime(new Date()); hongBaoV2.setGetTime(new Date()); + hongBaoV2Service.insertSelective(hongBaoV2); // 2.鎻掑叆鍏宠仈 orderHongBaoMapService.addOrderHongBaoMap(hongBaoV2, order); // 3.鎻掑叆璧勯噾鏄庣粏,鐢ㄦ埛浣欓 - UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createOrderReward(orderNo, money, + UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createOrderReward(orderNo, sourceType, money, new UserInfo(uid)); userMoneyDetailService.addUserMoneyDetail(userMoneyDetail); userInfoService.addMoney(new UserInfo(uid), money); // 鎻掑叆璧勯噾閫氱煡 - userMoneyMsgNotificationService.orderReward(uid, orderNo, money, + userMoneyMsgNotificationService.orderReward(uid, orderNo, sourceType, money, userInfoService.selectByPKey(uid).getMyHongBao()); /* 鐢ㄦ埛鍒镐俊鎭姸鎬佸強璁板綍澶勭悊 */ @@ -795,6 +792,7 @@ // 鎻掑叆浣跨敤鍒歌褰� UserSystemCouponRecord couponRecord = new UserSystemCouponRecord(); couponRecord.setState(UserSystemCouponRecord.STATE_SUCCESS); + couponRecord.setGoodSource(sourceType); couponRecord.setOrderNo(orderNo); couponRecord.setUserSystemCoupon(userSystemCoupon); couponRecord.setCouponType(systemCoupon.getType().name()); @@ -813,7 +811,7 @@ } @Override - public UserSystemCouponRecordVO getRewardCouponRecord(String orderNo) throws UserSystemCouponException, Exception { + public UserSystemCouponRecordVO getRewardCouponRecord(String orderNo, Integer sourceType) throws UserSystemCouponException, Exception { if (orderNo == null || orderNo.trim().length() == 0) { throw new UserSystemCouponException(1, "璁㈠崟鍙蜂笉瀛樺湪"); @@ -849,7 +847,7 @@ Long uid = userSystemCoupon.getUid(); CommonOrderVO commonOrderVO = commonOrderService.getCommonOrderByOrderNo(userSystemCoupon.getUid(), orderNo, - CommonOrder.STATE_JS); + CommonOrder.STATE_JS, sourceType); if (commonOrderVO == null) { throw new UserSystemCouponException(1, "璁㈠崟淇℃伅鑾峰彇澶辫触"); @@ -891,7 +889,7 @@ } @Override - public UserSystemCouponRecordVO getFreeCouponRecord(String orderNo) throws UserSystemCouponException, Exception { + public UserSystemCouponRecordVO getFreeCouponRecord(String orderNo, Integer sourceType) throws UserSystemCouponException, Exception { if (orderNo == null || orderNo.trim().length() == 0) { throw new UserSystemCouponException(1, "璁㈠崟鍙蜂笉瀛樺湪"); @@ -919,7 +917,7 @@ } // 璁㈠崟 - CommonOrderVO orderVO = commonOrderService.getCommonOrderByOrderNo(userSystemCoupon.getUid(), orderNo, null); + CommonOrderVO orderVO = commonOrderService.getCommonOrderByOrderNo(userSystemCoupon.getUid(), orderNo, null, sourceType); if (orderVO == null) { throw new UserSystemCouponException(1, "璁㈠崟淇℃伅鑾峰彇澶辫触"); } @@ -1514,132 +1512,6 @@ } - @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); - - // 鎻掑叆鍒� - randomRewardCouponForPush(pushCoupon, uid); - } - } - } - - @Transactional - public void randomRewardCouponForPush(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 { - 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); - } - @Override @Transactional @@ -1712,20 +1584,25 @@ 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)); + list.add(new RandomProportion(1, 22)); + list.add(new RandomProportion(2, 22)); + list.add(new RandomProportion(3, 22)); + list.add(new RandomProportion(4, 22)); + list.add(new RandomProportion(5, 20)); + list.add(new RandomProportion(6, 18)); + list.add(new RandomProportion(7, 16)); + list.add(new RandomProportion(8, 14)); + list.add(new RandomProportion(9, 12)); + list.add(new RandomProportion(10, 10)); + list.add(new RandomProportion(11, 8)); + list.add(new RandomProportion(12, 6)); + list.add(new RandomProportion(13, 4)); + list.add(new RandomProportion(14, 2)); + list.add(new RandomProportion(15, 1)); int minRange = 0; int maxRange = 0; - int randomNum = (int) (1 + Math.round(Math.random() * (99))); + int randomNum = (int) (1 + Math.round(Math.random() * (199))); for (int i = 0; i < list.size(); i++) { @@ -1735,11 +1612,8 @@ 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))); + if(randomNum > minRange && randomNum <= maxRange) { + result = proportion.num; break; } } @@ -1748,15 +1622,13 @@ } class RandomProportion { - public int minNum;// 鏈�灏� - public int maxNum;// 鏈�澶� + public int num;//鍒稿�� public int probability; // 姒傜巼 RandomProportion () {} - RandomProportion (int minNum, int maxNum, int probability) { - this.minNum = minNum; - this.maxNum = maxNum; + RandomProportion (int num, int probability) { + this.num = num; this.probability = probability; } } -- Gitblit v1.8.0