From e38ed8ad96af9893ab53bd34f8fd50f7b6b921b0 Mon Sep 17 00:00:00 2001 From: yujian <yujian> Date: 星期三, 06 三月 2019 10:15:52 +0800 Subject: [PATCH] 使用券是否可以使用加以验证 --- fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java | 341 ++++++++++++++++++++++++++++++++++++++++++++++++++++---- 1 files changed, 313 insertions(+), 28 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 9238670..d4af745 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 @@ -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,7 @@ 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.system.SystemCoupon; import com.yeshi.fanli.entity.system.SystemCoupon.CouponTypeEnum; import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief; @@ -39,10 +41,12 @@ 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.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; @@ -117,9 +121,11 @@ @Resource private UserOtherMsgNotificationService userOtherMsgNotificationService; - - // 鍒稿け鏁堝浘鐗� - public final static String PIC_INVALID = "http://192.168.1.200/icon/mian_invalid.png"; + @Resource + private DeviceLotteryRecordService deviceLotteryRecordService; + + @Resource + private CommonOrderCountService commonOrderCountService; @Override public int insertSelective(UserSystemCoupon record) { @@ -157,7 +163,8 @@ } @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, "鍙傛暟涓嶆纭�"); @@ -202,7 +209,13 @@ UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid); // 娣诲姞涓�鏉℃秷鎭� if (userInfoExtra != null) { - userInfoExtra.setCouponNews(userInfoExtra.getCouponNews() + 1); + if (userInfoExtra.getCouponNews() == null) { + userInfoExtra.setCouponNews(1); + } else { + userInfoExtra.setCouponNews(userInfoExtra.getCouponNews() + 1); + } + + try { userInfoExtraService.saveUserInfoExtra(userInfoExtra); } catch (UserInfoExtraException e) { @@ -283,10 +296,14 @@ userCouponVO.setCouponPicture(systemCoupon.getPicture()); userCouponVO.setCouponEffect(systemCoupon.getEffect()); userCouponVO.setCouponRule(systemCoupon.getRule()); + userCouponVO.setCouponPictureInvalid(systemCoupon.getPictureInvalid()); // 浣跨敤鐘舵�� Integer state = userCouponVO.getState(); - + + // 鍒哥被鍨� + CouponTypeEnum type = systemCoupon.getType(); + // 鎸夐挳璺宠浆 Map<String, Object> jumpBtn = null; @@ -303,22 +320,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") + "?alert=true"); - } else { - // 婵�娲婚個璇风爜鐣岄潰 - jumpLink.put("url", configService.get("invite_activation_url")); - } + /* + * 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=true"); } else { // 婵�娲婚個璇风爜鐣岄潰 jumpLink.put("url", + * configService.get("invite_activation_url")); } + * jumpBtn.put("params", jumpLink); + */ - jumpBtn.put("params", jumpLink); - jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite_web")); + jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite")); } else if (stateActivated == 1) { // 鏄剧ず瑙勫垯 @@ -327,7 +343,6 @@ if (UserSystemCoupon.STATE_CAN_USE == state) { Map<String, Object> jumpLink = new HashMap<String, Object>(); - CouponTypeEnum type = systemCoupon.getType(); if (CouponTypeEnum.freeCoupon == type || CouponTypeEnum.welfareFreeCoupon == type) { // 鍏嶅崟鍒搞�� 绂忓埄鍏嶅崟鍒� @@ -356,8 +371,8 @@ // 鍒稿け鏁堝浘鐗囨浛鎹� if (UserSystemCoupon.STATE_END_USE == state || UserSystemCoupon.STATE_OVERDUE == state) { - userCouponVO.setCouponPicture(PIC_INVALID); - } + userCouponVO.setCouponPicture(systemCoupon.getPictureInvalid()); + } userCouponVO.setJumpBtn(jumpBtn); @@ -423,6 +438,7 @@ userCouponVO.setCouponName(systemCoupon.getName()); userCouponVO.setCouponEffect(systemCoupon.getEffect()); userCouponVO.setCouponRule(systemCoupon.getRule()); + userCouponVO.setCouponPictureInvalid(systemCoupon.getPictureInvalid()); int differentDays = 0; @@ -451,7 +467,7 @@ if (stateActivated == null || stateActivated == 0) { userCouponVO.setState(0); userCouponVO.setCouponEffect("寰呮縺娲�"); - userCouponVO.setCouponPicture(PIC_INVALID); // 鏈縺娲诲浘鐗� + userCouponVO.setCouponPicture(systemCoupon.getPictureInvalid()); remainDaysFontColor = "#CCCCCC"; @@ -549,7 +565,7 @@ for (UserSystemCouponVO userCouponVO: list) { // 鏄剧ず涓嶈兘浣跨敤 userCouponVO.setState(0); - userCouponVO.setCouponPicture(PIC_INVALID); + userCouponVO.setCouponPicture(userCouponVO.getCouponPictureInvalid()); Map<String, Object> map = userCouponVO.getRemainDays(); if (map != null) { @@ -580,6 +596,13 @@ if (userSystemCoupon == null) { throw new UserSystemCouponException(1, "鍒告暟鎹笉姝g‘"); } + + 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)) { @@ -642,6 +665,12 @@ UserSystemCoupon userSystemCoupon = selectByPrimaryKey(id); if (userSystemCoupon == null) { throw new UserSystemCouponException(1, "鍒镐俊鎭笉瀛樺湪"); + } + + Integer state = userSystemCoupon.getState(); + Integer stateActivated = userSystemCoupon.getStateActivated(); + if (UserSystemCoupon.STATE_CAN_USE != state || 1 != stateActivated) { + throw new UserSystemCouponException(1, "璇ュ埜涓嶈兘琚娇鐢�"); } // 绯荤粺鍒镐俊鎭� @@ -1024,9 +1053,12 @@ return userRecordVO; } + @Transactional @Override - public void activatedWelfareFreeCoupon(Long uid) { + public void activatedWelfareFreeCoupon(Long uid, String fromNickName) { + + LogHelper.test("鍒告縺娲�:"+uid); if (uid == null) { return; } @@ -1038,6 +1070,9 @@ return; } + // 楠岃瘉鏄惁澶辨晥 + updateCounponInvalid(uid); + // 寰呮椿绂忓埄鍏嶅崟鍒� List<UserSystemCoupon> list = userSystemCouponMapper.getCouponByTypeAndNotActivated(uid, systemCoupon.getId()); if (list == null || list.size() == 0) { @@ -1046,13 +1081,24 @@ 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); + UserInfo userInfo = new UserInfo(); + userInfo.setId(uid); + userInfo.setNickName(fromNickName); + + userOtherMsgNotificationService.welfareCouponActive(userSystemCoupon, userInfo); } catch(Exception e) { try { LogHelper.errorDetailInfo(e); @@ -1319,5 +1365,244 @@ } + @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(), 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 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; + } + } } + -- Gitblit v1.8.0