From fe879975a3e8a0a1aa280fb839e02d159bfbcff8 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期二, 27 八月 2019 18:04:38 +0800 Subject: [PATCH] 金币任务多次获取bug修改 --- fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java | 1240 +++++++++++++++++++++++++++++++++++++++++++++------------- 1 files changed, 956 insertions(+), 284 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 190c158..5a7cf37 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 @@ -1,7 +1,6 @@ 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; @@ -17,18 +16,21 @@ import org.yeshi.utils.DateUtil; import com.yeshi.fanli.dao.mybatis.user.UserSystemCouponMapper; +import com.yeshi.fanli.dto.msg.MsgOtherGiveContentDTO; +import com.yeshi.fanli.entity.bus.msg.MsgOtherDetail.MsgTypeOtherTypeEnum; 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.TokenRecord; +import com.yeshi.fanli.entity.bus.user.TokenRecord.TokenTypeEnum; import com.yeshi.fanli.entity.bus.user.UserInfo; import com.yeshi.fanli.entity.bus.user.UserInfoExtra; import com.yeshi.fanli.entity.bus.user.UserSystemCoupon; +import com.yeshi.fanli.entity.bus.user.UserSystemCouponGiveRecord; import com.yeshi.fanli.entity.bus.user.UserSystemCouponRecord; 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; @@ -50,14 +52,18 @@ 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.TokenRecordService; import com.yeshi.fanli.service.inter.user.UserInfoExtraService; import com.yeshi.fanli.service.inter.user.UserInfoService; import com.yeshi.fanli.service.inter.user.UserMoneyDetailService; +import com.yeshi.fanli.service.inter.user.UserSystemCouponGiveRecordService; import com.yeshi.fanli.service.inter.user.UserSystemCouponRecordService; 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.StringUtil; +import com.yeshi.fanli.util.TokenUtil; import com.yeshi.fanli.util.factory.UserMoneyDetailFactory; import com.yeshi.fanli.util.taobao.TaoBaoUtil; import com.yeshi.fanli.vo.msg.ClientTextStyleVO; @@ -72,13 +78,16 @@ @Resource(name = "taskExecutor") private TaskExecutor executor; - + @Resource private RedisManager redisManager; - + @Resource private UserSystemCouponMapper userSystemCouponMapper; + @Resource + private UserSystemCouponGiveRecordService userSystemCouponGiveRecordService; + @Resource private ConfigService configService; @@ -114,19 +123,19 @@ @Resource private UserMoneyMsgNotificationService userMoneyMsgNotificationService; - + @Resource private UserInfoExtraService userInfoExtraService; - + @Resource private ThreeSaleSerivce threeSaleSerivce; - + @Resource private UserOtherMsgNotificationService userOtherMsgNotificationService; - + @Resource private DeviceLotteryRecordService deviceLotteryRecordService; - + @Resource private CommonOrderCountService commonOrderCountService; @@ -135,6 +144,9 @@ @Resource private PushCouponRecordService pushCouponRecordService; + + @Resource + private TokenRecordService tokenRecordService; @Override @@ -168,23 +180,43 @@ } @Override + public int countTodatyUserCouponBySource(Long uid, String source) { + return userSystemCouponMapper.countTodatyUserCouponBySource(uid, source); + } + + @Override public long countUserCouponList(Long uid) { return userSystemCouponMapper.countUserCouponList(uid); } @Override @Transactional - public void insertUserCoupon(Long uid, String couponType, String source)throws UserSystemCouponException,Exception{ - + public void insertUserCoupon(Long uid, String couponType, String source, BigDecimal percent) + throws UserSystemCouponException, Exception { + if (couponType == null || uid == null) { throw new UserSystemCouponException(1, "鍙傛暟涓嶆纭�"); - } + } + + SystemCoupon coupon = null; + if (couponType.equals(CouponTypeEnum.welfareFreeCoupon.name()) || couponType.equals(CouponTypeEnum.freeCoupon.name()) + | couponType.equals(CouponTypeEnum.freeCouponBuy.name())) { + // 鍏嶅崟鍒� + coupon = systemCouponService.getCouponByType(couponType); + } else if (couponType.equals(CouponTypeEnum.rebatePercentCoupon.name())) { + // 闅忔満濂栧姳鍒� + if (percent == null || percent.compareTo(new BigDecimal(0)) < 1) { + randomRewardCoupon(1, uid, source); + return; + } else { + coupon = systemCouponService.getCouponByTypeAndPercent(couponType, percent); + } + } - SystemCoupon coupon= systemCouponService.getCouponByType(couponType); if (coupon == null) { throw new UserSystemCouponException(1, "鍒哥被鍨嬩笉姝g‘"); - } - + } + int stateActivated = 1; if (coupon.getType() == CouponTypeEnum.welfareFreeCoupon) { // 绂忓埄鍒哥姸鎬� @@ -193,14 +225,23 @@ if (countSuccess == 0) { stateActivated = 0; } + } else if (coupon.getType() == CouponTypeEnum.freeCoupon) { + stateActivated = 0; } + + Integer expiryDay = null; + if (stateActivated == 0) + expiryDay = coupon.getActivateDay(); + + if (expiryDay == null || expiryDay == 0) + expiryDay = coupon.getExpiryDay(); // 缁撴潫鏃ユ湡 // 浠婂ぉ鍦ㄥ唴 鍑忓幓涓�澶� - String endDay = DateUtil.plusDay(coupon.getExpiryDay() - 1, new Date()); + String endDay = DateUtil.plusDay(expiryDay - 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); @@ -213,7 +254,7 @@ userCoupon.setUpdateTime(new Date()); // 鎻掑叆鏁版嵁搴� insertSelective(userCoupon); - + executor.execute(new Runnable() { @Override public void run() { @@ -225,18 +266,17 @@ } else { userInfoExtra.setCouponNews(userInfoExtra.getCouponNews() + 1); } - - + try { userInfoExtraService.saveUserInfoExtra(userInfoExtra); } catch (UserInfoExtraException e) { e.printStackTrace(); } } - + } }); - + // 娑堟伅鎺ㄩ�� try { if (coupon.getType() == CouponTypeEnum.welfareFreeCoupon) { @@ -244,10 +284,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) { @@ -256,18 +296,15 @@ } } - @Transactional @Override - public List<UserSystemCouponVO> getUserCouponVOList(long start, int count, Long uid) + public List<UserSystemCouponVO> getUserCouponVOList(long start, int count, Long uid, boolean changeJump) throws UserSystemCouponException, Exception { if (uid == null) { return null; } - - // 鏇存柊杩囨湡鍒� - updateCounponInvalid(uid); + // 閫�鍥炲埜 sendBackTimeOutCoupon(uid); @@ -277,7 +314,7 @@ } // 鏁版嵁缁勭粐 - listDataFactory(listVO, uid); + listDataFactory(listVO, uid, changeJump); return listVO; } @@ -287,8 +324,14 @@ * * @param listVO */ - public void listDataFactory(List<UserSystemCouponVO> listVO, Long uid) throws Exception{ + public void listDataFactory(List<UserSystemCouponVO> listVO, Long uid, boolean changeJump) throws Exception { + String inviteCode = null; + UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid); + if (userInfoExtra != null) { + inviteCode = userInfoExtra.getInviteCode(); + } + for (UserSystemCouponVO userCouponVO : listVO) { SystemCoupon systemCoupon = userCouponVO.getSystemCoupon(); @@ -311,20 +354,19 @@ // 浣跨敤鐘舵�� 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()); userCouponVO.setCouponEffect("寰呮縺娲�"); - // 鐘舵�佹湭婵�娲� -涓旀湭琚娇鐢� if (UserSystemCoupon.STATE_CAN_USE == state) { userCouponVO.setState(0); @@ -332,21 +374,19 @@ jumpBtn = new HashMap<String, Object>(); + // 绂忓埄鍒搁渶瑕佹縺娲荤晫闈� + if (!changeJump) { + jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite")); + } else { + if (inviteCode != null && inviteCode.trim().length() > 0) { + // 閭�璇峰ソ鍙嬬晫闈� + jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite_friends")); + } else { + // 閭�璇锋縺娲荤晫闈� + jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite_activate")); + } + } - // 閭�璇烽槦鍛樼晫闈� - /* - * 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("jumpDetail", jumpDetailV2Service.getByTypeCache("invite")); - } else if (stateActivated == 1) { // 鏄剧ず瑙勫垯 userCouponVO.setCouponRule(systemCoupon.getRule()); @@ -356,7 +396,7 @@ if (CouponTypeEnum.freeCoupon == type || CouponTypeEnum.welfareFreeCoupon == type) { // 鍏嶅崟鍒搞�� 绂忓埄鍏嶅崟鍒� - + // 鍏嶅崟鍟嗗搧鍒楄〃 jumpLink.put("url", configService.get("free_goods_list")); @@ -367,24 +407,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 = "鏈夋晥鏈燂細"; @@ -444,13 +484,17 @@ } String source = userCouponVO.getSource(); + if (source != null && "濂栧姳鍒稿ぉ澶╂娊".equals(source)) { + source = "澶╁ぉ鎶�"; + } + userCouponVO.setSource("鏉ユ簮锛�" + source); - userCouponVO.setCouponName(systemCoupon.getName()); userCouponVO.setCouponEffect(systemCoupon.getEffect()); userCouponVO.setCouponRule(systemCoupon.getRule()); + userCouponVO.setCouponRuleLink(systemCoupon.getRuleLink()); + userCouponVO.setCouponPicture(systemCoupon.getPicture()); userCouponVO.setCouponPictureInvalid(systemCoupon.getPictureInvalid()); - int differentDays = 0; String couponTerm = "鏈夋晥鏈燂細"; @@ -459,35 +503,31 @@ 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) { differentDays = 0; } } - userCouponVO.setCouponTerm(couponTerm); // 鍓╀綑澶╂暟 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); } @@ -495,6 +535,7 @@ return listVO; } + /** * 鏄惁瀛樺湪濂栧姳鍒� * @@ -522,15 +563,14 @@ @Transactional @Override public List<UserSystemCouponVO> getOrderCouponList(Long uid) throws UserSystemCouponException, Exception { + if (uid == null) { throw new UserSystemCouponException(1, "鐢ㄦ埛鏈櫥褰�"); } - - // 鏇存柊杩囨湡鍒� - updateCounponInvalid(uid); + // 閫�鍥炲埜 sendBackTimeOutCoupon(uid); - + // 璁㈠崟鐩稿叧鐨勫埜 List<SystemCoupon> couponList = systemCouponService.getOrderCouponList(); if (couponList == null || couponList.size() == 0) { @@ -542,18 +582,17 @@ @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); @@ -569,32 +608,30 @@ 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; } @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, "鐢ㄦ埛鏈櫥褰�"); } @@ -608,12 +645,15 @@ throw new UserSystemCouponException(1, "鍒告暟鎹笉姝g‘"); } + 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)) { @@ -628,10 +668,11 @@ } if (baseCoupon.getType() != CouponTypeEnum.freeCoupon - && baseCoupon.getType() != CouponTypeEnum.welfareFreeCoupon) { + && baseCoupon.getType() != CouponTypeEnum.welfareFreeCoupon + && baseCoupon.getType() != CouponTypeEnum.freeCouponBuy) { throw new UserSystemCouponException(1, "鍒哥被鍨嬩笉鍖归厤"); } - + Date date = new Date(); // 鏇存柊鍒镐娇鐢� userSystemCoupon.setState(UserSystemCoupon.STATE_IN_USE); // 姝e湪鍖归厤 @@ -642,42 +683,50 @@ // 鎻掑叆浣跨敤鍒歌褰� 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()); 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 @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) { 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) { @@ -697,17 +746,15 @@ throw new UserSystemCouponException(1, "鍒哥被鍨嬩笉鍖归厤"); } - if (orderNo == null || orderNo.trim().length() == 0) { throw new UserSystemCouponException(1, "璁㈠崟鍙蜂笉瀛樺湪"); } // 璁㈠崟 - 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, "璁㈠崟淇℃伅鑾峰彇澶辫触"); } - BigDecimal hongBao = orderVO.getHongBao(); // 绾㈠寘鐘舵�� @@ -718,7 +765,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; @@ -740,19 +787,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()); /* 鐢ㄦ埛鍒镐俊鎭姸鎬佸強璁板綍澶勭悊 */ @@ -767,17 +815,18 @@ // 鎻掑叆浣跨敤鍒歌褰� UserSystemCouponRecord couponRecord = new UserSystemCouponRecord(); couponRecord.setState(UserSystemCouponRecord.STATE_SUCCESS); + couponRecord.setGoodSource(sourceType); couponRecord.setOrderNo(orderNo); couponRecord.setUserSystemCoupon(userSystemCoupon); couponRecord.setCouponType(systemCoupon.getType().name()); 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,7 +834,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, "璁㈠崟鍙蜂笉瀛樺湪"); @@ -819,17 +868,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, sourceType); + if (commonOrderVO == null) { throw new UserSystemCouponException(1, "璁㈠崟淇℃伅鑾峰彇澶辫触"); } - + // 鑾峰彇濂栧姳閲戦 BigDecimal couponMoney = orderHongBaoMapService.getCouponHongbaoByOrderNo(orderNo, uid); - + UserSystemCouponRecordVO userRecordVO = new UserSystemCouponRecordVO(); userRecordVO.setCouponMoneyState("宸插埌璐�"); userRecordVO.setCommonOrder(commonOrderVO); @@ -862,9 +911,8 @@ return userRecordVO; } - @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, "璁㈠崟鍙蜂笉瀛樺湪"); @@ -892,7 +940,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, "璁㈠崟淇℃伅鑾峰彇澶辫触"); } @@ -912,7 +960,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"; @@ -1063,54 +1111,50 @@ return userRecordVO; } - - + @Transactional @Override public void activatedWelfareFreeCoupon(Long uid, String fromNickName) { - - LogHelper.test("鍒告縺娲�:"+uid); + + 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 update=new 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 { UserInfo userInfo = new UserInfo(); userInfo.setId(uid); userInfo.setNickName(fromNickName); - + userOtherMsgNotificationService.welfareCouponActive(userSystemCoupon, userInfo); - } catch(Exception e) { + } catch (Exception e) { try { LogHelper.errorDetailInfo(e); } catch (Exception e1) { @@ -1119,11 +1163,11 @@ } } } - + @Transactional @Override public void updateStateByDrawback(String orderNo) throws Exception { - + if (orderNo == null || orderNo.trim().length() == 0) { return; } @@ -1132,20 +1176,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; } @@ -1154,43 +1198,50 @@ 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); - } + } else if (CouponTypeEnum.freeCouponBuy.name().equals(record.getCouponType())) { + userOtherMsgNotificationService.couponUsedFreeSheet(record.getUserSystemCoupon(), orderNo, MsgTypeOtherTypeEnum.freeCouponBuy); + } } - @Transactional @Override - public void updateCounponInvalid(Long uid) { - List<UserSystemCoupon> list = userSystemCouponMapper.getCounponNowInvalid(uid); + public List<UserSystemCoupon> getCounponNowInvalid(int count) { + return userSystemCouponMapper.getCounponNowInvalid(count); + } + + + @Override + public void updateCounponInvalid(List<UserSystemCoupon> list) { if (list == null || list.size() == 0) { return; } - - for (UserSystemCoupon userSystemCoupon: list) { - // 鏇存柊鍒稿凡杩囨湡 + + for (UserSystemCoupon userSystemCoupon : list) { + UserSystemCoupon userCoupon = new UserSystemCoupon(); + userCoupon.setUpdateTime(new Date()); userSystemCoupon.setState(UserSystemCoupon.STATE_OVERDUE); userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon); - - SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon(); - if (systemCoupon == null) { + + SystemCoupon baseCoupon = userSystemCoupon.getSystemCoupon(); + if (baseCoupon == null) { continue; } - SystemCoupon baseCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId()); + baseCoupon = systemCouponService.selectByPrimaryKey(baseCoupon.getId()); if (baseCoupon == null || baseCoupon.getId() == null) { continue; } - + // 娑堟伅鎺ㄩ�� try { if (baseCoupon.getType() == CouponTypeEnum.welfareFreeCoupon) { @@ -1199,9 +1250,12 @@ userOtherMsgNotificationService.freeSheetCouponAlreadyOutOfDate(userSystemCoupon); } else if (baseCoupon.getType() == CouponTypeEnum.rebatePercentCoupon) { userOtherMsgNotificationService.rewardCouponAlreadyOutOfDate(userSystemCoupon); + }else if (baseCoupon.getType() == CouponTypeEnum.freeCouponBuy) { + userOtherMsgNotificationService.outOfDate(userSystemCoupon, MsgTypeOtherTypeEnum.freeCouponBuy); + } else if (baseCoupon.getType() == CouponTypeEnum.freeCouponGive) { + userOtherMsgNotificationService.outOfDate(userSystemCoupon, MsgTypeOtherTypeEnum.freeCouponGive); } - - } catch(Exception e) { + } catch (Exception e) { try { LogHelper.errorDetailInfo(e); } catch (Exception e1) { @@ -1210,76 +1264,53 @@ } } } - + @Transactional @Override - public void sendBackTimeOutCoupon(Long uid) { - // 瓒呰繃120绉� 鏈鍖归厤鐨勫埜 - List<UserSystemCouponRecord> list = userSystemCouponRecordService.getCouponByUsingTimeOut(uid, 120L); + public void sendBackTimeOutCoupon(Long uid) { + // 瓒呰繃10鍒嗛挓 鏈鍖归厤鐨勫埜 + List<UserSystemCouponRecord> list = userSystemCouponRecordService.getCouponByUsingTimeOut(uid, 600L); 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()); - if (coupon != null) { - expiryDay = coupon.getExpiryDay(); - } - - // 缁撴潫鏃ユ湡 - Date endTime = null; - try { - // 浠婂ぉ鍦ㄥ唴 鍑忓幓涓�澶� - String endDay = DateUtil.plusDay(expiryDay - 1, 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); } } - + @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)) { @@ -1288,131 +1319,140 @@ 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); - } + } else if (CouponTypeEnum.freeCouponBuy.name().equals(couponType)) { + userOtherMsgNotificationService.couponUsingFreeSheet(userSystemCoupon, orderNo, payment, MsgTypeOtherTypeEnum.freeCouponBuy); + } } } - + return isfree; } - + /** * 閫�鍥炲埜 鍒濆鏁版嵁 + * * @param userSystemCoupon */ - public void sendBackCoupon(UserSystemCoupon userSystemCoupon, UserSystemCouponRecord record) 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 - 1, 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); + public void sendBackCoupon(UserSystemCoupon userCoupon, UserSystemCouponRecord record) throws Exception { + if (userCoupon == null) + return; + + Integer state = userCoupon.getState(); + if (state != UserSystemCoupon.STATE_IN_USE) + return; - 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) { + Date now = new Date(); + Date endTime = userCoupon.getEndTime(); + if (endTime != null && endTime.getTime() < now.getTime()) { + // 杩囨湡 + List<UserSystemCoupon> list = new ArrayList<UserSystemCoupon>(); + list.add(userCoupon); + updateCounponInvalid(list); return; } + // 閫�鍥炲埜 + UserSystemCoupon userSystemCoupon = new UserSystemCoupon(); + userSystemCoupon.setId(userCoupon.getId()); + userSystemCoupon.setGive(false); + userSystemCoupon.setUseTime(null); + userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE); + userSystemCoupon.setUpdateTime(new Date()); + userSystemCouponMapper.updateByPrimaryKey(userSystemCoupon); + + // 浣跨敤璁板綍 + if (record != null) { + UserSystemCouponRecord useRecordUpdate = new UserSystemCouponRecord(); + useRecordUpdate.setId(record.getId()); + useRecordUpdate.setState(UserSystemCouponRecord.STATE_WAIT_TIME_OUT); + useRecordUpdate.setUpdateTime(new Date()); + userSystemCouponRecordService.updateByPrimaryKeySelective(useRecordUpdate); + + 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()); + } else if (CouponTypeEnum.freeCouponBuy.name().equals(record.getCouponType())) { + userOtherMsgNotificationService.couponDrawBack(userSystemCoupon, record.getOrderNo(), MsgTypeOtherTypeEnum.freeCouponBuy); + } + } + + } + + @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) { + + // 鏄惁鏄柊鐢ㄦ埛 + boolean isNewUser = userInfoExtraService.isNewUser(uid); + if (!isNewUser) { return; } - + int coupon = 0; - - for (DeviceLotteryRecord reviceLotteryRecord: list) { - + + for (DeviceLotteryRecord reviceLotteryRecord : list) { + // 鍒犻櫎璁板綍 deviceLotteryRecordService.deleteByPrimaryKey(reviceLotteryRecord.getId()); - + Long systemCouponId = reviceLotteryRecord.getSystemCouponId(); if (systemCouponId == null) { continue; @@ -1421,7 +1461,7 @@ if (systemCoupon == null) { continue; } - + int stateActivated = 1; if (systemCoupon.getType() == CouponTypeEnum.welfareFreeCoupon) { // 绂忓埄鍒哥姸鎬� @@ -1432,14 +1472,15 @@ } } + // 缁撴潫鏃ユ湡 // 浠婂ぉ鍦ㄥ唴 鍑忓幓涓�澶� 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.setSource(UserSystemCoupon.SOURCE_NEWBIES); userCoupon.setSystemCoupon(systemCoupon); userCoupon.setState(UserSystemCoupon.STATE_CAN_USE); userCoupon.setStateActivated(stateActivated); @@ -1449,10 +1490,10 @@ userCoupon.setUpdateTime(new Date()); // 鎻掑叆鏁版嵁搴� insertSelective(userCoupon); - + // 鍒告暟閲� - coupon ++; - + coupon++; + // 娑堟伅鎺ㄩ�� try { if (systemCoupon.getType() == CouponTypeEnum.welfareFreeCoupon) { @@ -1460,9 +1501,74 @@ } else if (systemCoupon.getType() == CouponTypeEnum.freeCoupon) { userOtherMsgNotificationService.freeSheetCouponGet(userCoupon); } else if (systemCoupon.getType() == CouponTypeEnum.rebatePercentCoupon) { - userOtherMsgNotificationService.rewardCouponGet(userCoupon,systemCoupon.getPercent().intValue()); + 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(int num, Long uid, String source) throws Exception { + if (num < 1) { + return; + } + + for (int i = 0; i < num; i++) { + + // 杩斿埄姣�-闅忔満 + BigDecimal percent = new BigDecimal(randomNum()); + // 鏌ヨ濂栧姳鍒� + SystemCoupon systemCoupon = systemCouponService.getCouponByTypeAndPercent( + CouponTypeEnum.rebatePercentCoupon.name(),percent); + if (systemCoupon == null) { + return; + } + + // 缁撴潫鏃ユ湡 浠婂ぉ鍦ㄥ唴 鍑忓幓涓�澶� + 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(source); + userCoupon.setSystemCoupon(systemCoupon); + userCoupon.setState(UserSystemCoupon.STATE_CAN_USE); + userCoupon.setStateActivated(1); + userCoupon.setStartTime(new Date()); + userCoupon.setEndTime(endTime); + userCoupon.setCreateTime(new Date()); + userCoupon.setUpdateTime(new Date()); + // 鎻掑叆鏁版嵁搴� + insertSelective(userCoupon); + + // 娑堟伅鎺ㄩ�� + try { + userOtherMsgNotificationService.rewardCouponGet(userCoupon,systemCoupon.getPercent().intValue()); } catch(Exception e) { try { LogHelper.errorDetailInfo(e); @@ -1472,23 +1578,589 @@ } } - if(userInfoExtra == null) { - userInfoExtra = new UserInfoExtra(); - userInfoExtra.setUserInfo(new UserInfo(uid)); + // 绂忓埄涓績绾㈢偣 + UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid); + if (userInfoExtra == null) { + return; } - - userInfoExtra.setLotteryNewbies(Constant.MAX_COUNT_LOTTERY_NEWBIES-list.size()); Integer couponNews = userInfoExtra.getCouponNews(); if (couponNews == null) { - userInfoExtra.setCouponNews(coupon); + userInfoExtra.setCouponNews(num); } else { - userInfoExtra.setCouponNews(couponNews + coupon); + userInfoExtra.setCouponNews(couponNews + num); } userInfoExtraService.saveUserInfoExtra(userInfoExtra); + } + /** + * 闅忔満鍒告瘮渚� + * @return + */ + public int randomNum() { + + int result = 1; + + List<RandomProportion> list = new ArrayList<RandomProportion>(); + 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() * (199))); + + for (int i = 0; i < list.size(); i++) { + + RandomProportion proportion = list.get(i); + int probability = proportion.probability; + + maxRange = maxRange + probability; + minRange = maxRange - probability; + + if(randomNum > minRange && randomNum <= maxRange) { + result = proportion.num; + break; + } + } + + return result; + } + + class RandomProportion { + public int num;//鍒稿�� + public int probability; // 姒傜巼 + + RandomProportion () {} + + RandomProportion (int num, int probability) { + this.num = num; + this.probability = probability; + } } + @Override + @Transactional + public void exchangeCoupon(Long uid, String couponType, String source, BigDecimal percent) throws UserSystemCouponException, Exception { + if (couponType == null || uid == null) { + throw new UserSystemCouponException(1, "鍙傛暟涓嶆纭�"); + } + + SystemCoupon coupon = null; + if (couponType.equals(CouponTypeEnum.rebatePercentCoupon.name())) { + coupon = systemCouponService.getCouponByTypeAndPercent(couponType, percent); + } else { + coupon = systemCouponService.getCouponByType(couponType); + } + + if (coupon == null) { + throw new UserSystemCouponException(1, "鍒哥被鍨嬩笉姝g‘"); + } + + int stateActivated = 1; + if (couponType == CouponTypeEnum.freeCoupon.name()) { + stateActivated = 0; // + } else if (couponType == CouponTypeEnum.welfareFreeCoupon.name() && threeSaleSerivce.countSuccessFirstTeam(uid) <= 0) { + stateActivated = 0; // 鏃犱笅绾ч槦鍛� --寰呮縺娲� + } + + + Integer expiryDay = null; + if (stateActivated == 0) + expiryDay = coupon.getActivateDay(); + + if (expiryDay == null || expiryDay == 0) + expiryDay = coupon.getExpiryDay(); + + + // 璁$畻缁撴潫鏃ユ湡锛氫粖澶╁湪鍐� 鍑忓幓涓�澶� + String endDay = DateUtil.plusDay(expiryDay - 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); + userCoupon.setSystemCoupon(coupon); + userCoupon.setStateActivated(stateActivated); + userCoupon.setStartTime(new Date()); + userCoupon.setEndTime(endTime); + userCoupon.setGive(false); + userCoupon.setCreateTime(new Date()); + userCoupon.setUpdateTime(new Date()); + userCoupon.setState(UserSystemCoupon.STATE_CAN_USE); + + insertSelective(userCoupon); + } + + @Transactional + @Override + public List<UserSystemCouponVO> getCouponList(long start, int count, Long uid) + throws UserSystemCouponException, Exception { + // 閫�鍥炲埜 + sendBackTimeOutCoupon(uid); + + List<UserSystemCouponVO> listVO = userSystemCouponMapper.getUserCouponVOList(start, count, uid); + if (listVO == null || listVO.size() == 0) { + return listVO; + } + + // 鏄惁婵�娲婚個璇风爜 + String inviteCode = null; + UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid); + if (userInfoExtra != null) { + inviteCode = userInfoExtra.getInviteCode(); + } + + for (UserSystemCouponVO userCouponVO : listVO) { + SystemCoupon systemCoupon = userCouponVO.getSystemCoupon(); + if (systemCoupon != null && systemCoupon.getId() != null) { + systemCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId()); + } + + if (systemCoupon == null) { + continue; // 鍒镐俊鎭笉瀹屾暣 + } + + String source = userCouponVO.getSource(); + if (source != null && "濂栧姳鍒稿ぉ澶╂娊".equals(source)) { + source = "澶╁ぉ鎶�"; + } + + userCouponVO.setSource("鏉ユ簮锛�" + source); + userCouponVO.setCouponName(systemCoupon.getName()); + userCouponVO.setCouponEffect(systemCoupon.getEffect()); + userCouponVO.setCouponRule(systemCoupon.getRule()); + userCouponVO.setCouponRuleLink(systemCoupon.getRuleLink()); + + String couponTerm = "鏈夋晥鏈燂細"; + Date startTime = userCouponVO.getStartTime(); + Date endTime = userCouponVO.getEndTime(); + if (endTime != null && startTime != null) { + SimpleDateFormat sdf = new SimpleDateFormat("yyyy.MM.dd"); + couponTerm = couponTerm + sdf.format(startTime) + "-" + sdf.format(endTime); + } + userCouponVO.setCouponTerm(couponTerm); + + Integer state = userCouponVO.getState(); + if (UserSystemCoupon.STATE_END_USE == state || UserSystemCoupon.STATE_OVERDUE == state) { + userCouponVO.setCouponPicture(systemCoupon.getPictureInvalid()); + } else { + userCouponVO.setCouponPicture(systemCoupon.getPicture()); + } + + if (UserSystemCoupon.STATE_CAN_USE == state || UserSystemCoupon.STATE_IN_USE == state) { + int differentDays = 0; + if (endTime != null && startTime != null) { + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); + differentDays = DateUtil.daysBetween(sdf.format(new Date()), sdf.format(endTime)) + 1; + if (differentDays < 0) { + differentDays = 0; + } + } + // 鍓╀綑澶╂暟 + Map<String, Object> remainDays = new HashMap<String, Object>(); + remainDays.put("content", "杩樺墿" + differentDays + "澶╄繃鏈�"); + remainDays.put("fontColor", "#F14242"); + userCouponVO.setRemainDays(remainDays); + } + + Map<String, Object> jumpBtn = null; + CouponTypeEnum type = systemCoupon.getType(); + Integer stateActivated = userCouponVO.getStateActivated(); + + // 鏈縺娲� + if (stateActivated == null || stateActivated == 0) { + userCouponVO.setCouponEffect("寰呮縺娲�"); + userCouponVO.setCouponRule(systemCoupon.getRemark()); + if (UserSystemCoupon.STATE_CAN_USE == state) { + state = 0; + userCouponVO.setState(state); + if (CouponTypeEnum.freeCoupon == type) { + List<String> listTip = new ArrayList<String>(); + listTip.add("鏈厤鍗曞埜鐢卞ソ鍙嬭禒閫侊紝浠庤幏璧犳棩璧�60澶╁唴闇�浜х敓3绗旇繑鍒╄鍗曪紱"); + listTip.add("杩斿埄璁㈠崟鈥滃凡鍒拌处鈥濆悗锛屾柟鑳借涓鸿鍗曚骇鐢熸垚鍔燂紱"); + listTip.add("婊¤冻鏉′欢鍚庯紝绯荤粺灏嗚嚜鍔ㄦ縺娲伙紝骞跺湪娑堟伅-鍏跺畠娑堟伅涓彁閱掋��"); + userCouponVO.setTips(listTip); + userCouponVO.setPopup(true); + } else if (CouponTypeEnum.welfareFreeCoupon == type) { + jumpBtn = new HashMap<String, Object>(); + if (inviteCode != null && inviteCode.trim().length() > 0) { + jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite_friends")); + } else { + jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite_activate")); + } + } + } + } + + if (UserSystemCoupon.STATE_IN_USE == state && (CouponTypeEnum.freeCouponBuy == type + || CouponTypeEnum.freeCoupon == type || CouponTypeEnum.welfareFreeCoupon == type)) { + userCouponVO.setInUseExplain(configService.get("free_coupon_using-help")); + } + + // 鏄惁宸茶禒閫� + Boolean give = userCouponVO.getGive(); + if (give == null) { + give = false; + } + + SimpleDateFormat sdf = new SimpleDateFormat("yyyy.MM.dd"); + + if (UserSystemCoupon.STATE_CAN_USE == state) { + Map<String, Object> jumpLink = new HashMap<String, Object>(); + if (CouponTypeEnum.freeCouponGive == type) { + userCouponVO.setState(UserSystemCoupon.STATE_GIVE_ONLY); + } else if (CouponTypeEnum.freeCoupon == type || CouponTypeEnum.welfareFreeCoupon == type + || CouponTypeEnum.freeCouponBuy == type) { + jumpLink.put("url", configService.get("free_goods_list")); + jumpBtn = new HashMap<String, Object>(); + jumpBtn.put("params", jumpLink); + jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("web")); + } else if (CouponTypeEnum.rebatePercentCoupon == type) { + // 鍙娇鐢ㄣ�� 鍙禒閫� + userCouponVO.setState(UserSystemCoupon.STATE_USE_GIVE); + + // 杩斿埄濂栧姳鍒�- 璺宠浆鑷宠鍗曞埌璐︾晫闈� + 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 && give) { + userCouponVO.setCouponEffect("璧犻�佷腑"); + userCouponVO.setCouponRule(systemCoupon.getRemark()); + String tips = null; + + TokenTypeEnum tokenType = null; + if (CouponTypeEnum.freeCouponGive == type) { + userCouponVO.setState(UserSystemCoupon.STATE_GIVE_IN); + tips = configService.get("give_free_coupon_tips"); + tokenType = TokenTypeEnum.freeCoupon; + } + + if (CouponTypeEnum.rebatePercentCoupon == type) { + userCouponVO.setState(UserSystemCoupon.STATE_GIVE_IN); + tips = configService.get("give_free_coupon_tips"); + tokenType = TokenTypeEnum.rebatePercentCoupon; + } + + if (!StringUtil.isNullOrEmpty(tips) && tokenType != null) { + UserSystemCouponGiveRecord record = userSystemCouponGiveRecordService.getRecordByUidAndCouponId(uid, userCouponVO.getId()); + if (record != null) { + TokenRecord tokenRecord = tokenRecordService.getNearByTypeAndIdentify(tokenType.name(), record.getId().toString()); + if (tokenRecord != null && !StringUtil.isNullOrEmpty(tokenRecord.getToken())) { + String projectChineseName = Constant.systemCommonConfig.getProjectChineseName(); + while(tips.contains("{APP鍚嶇О}")) { + tips = tips.replace("{APP鍚嶇О}", projectChineseName); + } + tips = tips.replace("{鍙d护}", tokenRecord.getToken()).replace("{涓嬭浇閾炬帴}", configService.get("app_down_link")); + userCouponVO.setGiveTips(tips); + } + + Date endTimeGive = record.getEndTime(); + if (endTimeGive != null) { + Map<String, Object> remainDays = new HashMap<String, Object>(); + remainDays.put("content", "鍓╀綑" + DateUtil.dateDiff2(new Date(), endTimeGive) + "杩囨湡"); + remainDays.put("fontColor", "#F14242"); + userCouponVO.setRemainDays(remainDays); + } + } + } + } else if (UserSystemCoupon.STATE_END_USE == state) { + + if (give) { + userCouponVO.setCouponEffect("浠绘��0鍏冭喘"); + userCouponVO.setCouponRule(systemCoupon.getRemark()); + if (CouponTypeEnum.freeCouponGive == type) { + userCouponVO.setState(UserSystemCoupon.STATE_GIVE_END); + } + + if (CouponTypeEnum.rebatePercentCoupon == type) { + userCouponVO.setState(UserSystemCoupon.STATE_GIVE_END); + } + + Date useTime = userCouponVO.getUseTime(); + if (useTime != null) { + Map<String, Object> remainDays = new HashMap<String, Object>(); + remainDays.put("content", "浜�" + sdf.format(useTime) + "鎴愬姛璧犻��"); + remainDays.put("fontColor", "#CCCCCC"); + userCouponVO.setRemainDays(remainDays); + } + } else { + Date useTime = userCouponVO.getUseTime(); + if (useTime != null) { + Map<String, Object> remainDays = new HashMap<String, Object>(); + remainDays.put("content", "浜�" + sdf.format(useTime) + "鎴愬姛浣跨敤"); + remainDays.put("fontColor", "#CCCCCC"); + userCouponVO.setRemainDays(remainDays); + } + } + + }else if (UserSystemCoupon.STATE_OVERDUE == state) { + if (endTime != null) { + Map<String, Object> remainDays = new HashMap<String, Object>(); + remainDays.put("content", "浜�" + sdf.format(endTime) + "杩囨湡"); + remainDays.put("fontColor", "#CCCCCC"); + userCouponVO.setRemainDays(remainDays); + } + + if(give) + userCouponVO.setCouponRule(systemCoupon.getRemark()); + } + userCouponVO.setJumpBtn(jumpBtn); + } + return listVO; + } + + + @Transactional + @Override + public UserSystemCouponVO giveCoupon(Long uid, Long id) throws UserSystemCouponException { + UserSystemCoupon userSystemCoupon = userSystemCouponMapper.selectByPrimaryKey(id); + if (userSystemCoupon == null) + throw new UserSystemCouponException(1, "璇ュ埜宸蹭笉瀛樺湪"); + + SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon(); + if (systemCoupon == null) + throw new UserSystemCouponException(1, "璇ュ埜宸蹭笉瀛樺湪"); + + systemCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId()); + if (systemCoupon == null) + throw new UserSystemCouponException(1, "璇ュ埜宸插け鏁�"); + + Integer state = userSystemCoupon.getState(); + if (state != UserSystemCoupon.STATE_CAN_USE) + throw new UserSystemCouponException(1, "璇ュ埜宸茶浣跨敤鎴栬禒閫�"); + + CouponTypeEnum type = systemCoupon.getType(); + if (type != CouponTypeEnum.freeCouponGive && type != CouponTypeEnum.rebatePercentCoupon ) + throw new UserSystemCouponException(1, "璇ュ埜涓嶆敮鎸佽禒閫�"); + + String tips = null; + TokenTypeEnum tokenTypeEnum = null; + if (type == CouponTypeEnum.freeCouponGive) { + tokenTypeEnum = TokenTypeEnum.freeCoupon; + tips = configService.get("give_free_coupon_tips"); + } else if (type == CouponTypeEnum.rebatePercentCoupon){ + tokenTypeEnum = TokenTypeEnum.rebatePercentCoupon; + tips = configService.get("give_rebate_percent_coupon_tips"); + } else { + throw new UserSystemCouponException(1, "璇ュ埜涓嶆敮鎸佽禒閫�"); + } + + if (StringUtil.isNullOrEmpty(tips)) + throw new UserSystemCouponException(1, "tips鏁版嵁缂哄け"); + + + // 鏄惁鏈�杩戠敓鎴愬彛浠ゆ湁鏁� + UserSystemCouponGiveRecord record = userSystemCouponGiveRecordService.getRecordByUidAndCouponId(uid, id); + if (record != null) { + TokenRecord tokenRecord = tokenRecordService.getNearByTypeAndIdentify(tokenTypeEnum.name(), id+""); + if (tokenRecord != null && !StringUtil.isNullOrEmpty(tokenRecord.getToken())) { + String projectChineseName = Constant.systemCommonConfig.getProjectChineseName(); + while(tips.contains("{APP鍚嶇О}")) { + tips = tips.replace("{APP鍚嶇О}", projectChineseName); + } + tips = tips.replace("{鍙d护}", tokenRecord.getToken()).replace("{涓嬭浇閾炬帴}", configService.get("app_down_link")); + + return createUserCouponVOo(userSystemCoupon, systemCoupon, record, tips); + } + } + + + Date nowDate = new Date(); + // 鎻掑叆璧犻�佽褰� + UserSystemCouponGiveRecord giveRecord = new UserSystemCouponGiveRecord(); + giveRecord.setCouponId(id); + giveRecord.setGiveUid(uid); + giveRecord.setGiveTime(nowDate); + giveRecord.setEndTime(DateUtil.plusDayDate(Constant.GIVE_DAYS, nowDate)); + userSystemCouponGiveRecordService.insertSelective(giveRecord); + + // 鍒涘缓璁板綍 + TokenRecord tokenRecord = new TokenRecord(); + tokenRecord.setUid(uid); + tokenRecord.setIdentify(giveRecord.getId()+""); + tokenRecord.setType(tokenTypeEnum); + tokenRecord.setStartTime(nowDate); + tokenRecord.setEndTime(DateUtil.plusDayDate(Constant.TOKEN_DAYS, nowDate)); + tokenRecord.setState(0); + tokenRecordService.insertSelective(tokenRecord); + + // 鍒涘缓鍙d护 + String token = TokenUtil.createToken(tokenRecord.getId()); + tokenRecord.setToken(token); + tokenRecordService.updateByPrimaryKeySelective(tokenRecord); + + // 鍒哥姸鎬� + userSystemCoupon.setState(UserSystemCoupon.STATE_IN_USE); + userSystemCoupon.setGive(true); + userSystemCoupon.setUpdateTime(nowDate); + userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon); + + // 鎻掑叆浣跨敤鍒歌褰� + UserSystemCouponRecord couponRecord = new UserSystemCouponRecord(); + couponRecord.setState(UserSystemCouponRecord.STATE_GIVE_ON); + couponRecord.setUserSystemCoupon(userSystemCoupon); + couponRecord.setCouponType(type.name()); + couponRecord.setCreateTime(nowDate); + couponRecord.setUpdateTime(nowDate); + userSystemCouponRecordService.insertSelective(couponRecord); + + String projectChineseName = Constant.systemCommonConfig.getProjectChineseName(); + while(tips.contains("{APP鍚嶇О}")) { + tips = tips.replace("{APP鍚嶇О}", projectChineseName); + } + tips = tips.replace("{鍙d护}", token).replace("{涓嬭浇閾炬帴}", configService.get("app_down_link")); + + return createUserCouponVOo(userSystemCoupon, systemCoupon, giveRecord, tips); + } + + + private UserSystemCouponVO createUserCouponVOo(UserSystemCoupon userSystemCoupon, SystemCoupon systemCoupon, + UserSystemCouponGiveRecord record, String tips) { + UserSystemCouponVO userCouponVO = new UserSystemCouponVO(); + userCouponVO.setId(userSystemCoupon.getId()); + userCouponVO.setUid(userSystemCoupon.getUid()); + userCouponVO.setSource("鏉ユ簮锛�" + userSystemCoupon.getSource()); + userCouponVO.setCouponName(systemCoupon.getName()); + userCouponVO.setCouponEffect("璧犻�佷腑"); + userCouponVO.setState(UserSystemCoupon.STATE_GIVE_IN); + userCouponVO.setCouponRule(systemCoupon.getRemark()); + userCouponVO.setCouponRuleLink(systemCoupon.getRuleLink()); + userCouponVO.setCouponPicture(systemCoupon.getPicture()); + userCouponVO.setGiveTips(tips); + + String couponTerm = "鏈夋晥鏈燂細"; + Date startTime = userCouponVO.getStartTime(); + Date endTime = userCouponVO.getEndTime(); + if (endTime != null && startTime != null) { + SimpleDateFormat sdf = new SimpleDateFormat("yyyy.MM.dd"); + couponTerm = couponTerm + sdf.format(startTime) + "-" + sdf.format(endTime); + } + userCouponVO.setCouponTerm(couponTerm); + + Map<String, Object> remainDays = new HashMap<String, Object>(); + remainDays.put("content", "鍓╀綑23鏃�59鍒嗚繃鏈�"); + remainDays.put("fontColor", "#F14242"); + userCouponVO.setRemainDays(remainDays); + + return userCouponVO; + } + + + @Override + public void sendBackGiveCoupon(List<UserSystemCouponGiveRecord> overdueList) { + for (UserSystemCouponGiveRecord record: overdueList) { + // 鏇存柊璧犻�佽褰� + UserSystemCouponGiveRecord updateRecord = new UserSystemCouponGiveRecord(); + updateRecord.setId(record.getId()); + updateRecord.setState(UserSystemCouponGiveRecord.STATE_OVERDUE); + userSystemCouponGiveRecordService.updateByPrimaryKeySelective(updateRecord); + + // 鏇存柊鍒镐俊鎭� + Long couponId = record.getCouponId(); + if (couponId == null) { + continue; + } + + // 鍒稿垪琛� + UserSystemCoupon userCoupon = userSystemCouponMapper.selectByPrimaryKey(couponId); + if (userCoupon == null) + continue; + + Integer state = userCoupon.getState(); + if (state != UserSystemCoupon.STATE_IN_USE) + return; + + Date now = new Date(); + Date endTime = userCoupon.getEndTime(); + if (endTime != null && endTime.getTime() < now.getTime()) { + List<UserSystemCoupon> list = new ArrayList<UserSystemCoupon>(); + list.add(userCoupon); + updateCounponInvalid(list); + continue; + } + + // 閫�鍥炲埜 + UserSystemCoupon userSystemCoupon = new UserSystemCoupon(); + userSystemCoupon.setId(userCoupon.getId()); + userSystemCoupon.setGive(false); + userSystemCoupon.setUseTime(null); + userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE); + userSystemCoupon.setUpdateTime(new Date()); + userSystemCouponMapper.updateByPrimaryKey(userSystemCoupon); + + // 浣跨敤璁板綍 + UserSystemCouponRecord useRecord = userSystemCouponRecordService.getNearByUserCouponId(couponId); + if (useRecord != null) { + UserSystemCouponRecord useRecordUpdate = new UserSystemCouponRecord(); + useRecordUpdate.setId(useRecord.getId()); + useRecordUpdate.setState(UserSystemCouponRecord.STATE_WAIT_TIME_OUT); + useRecordUpdate.setUpdateTime(new Date()); + userSystemCouponRecordService.updateByPrimaryKeySelective(useRecordUpdate); + } + + SystemCoupon systemCoupon = userCoupon.getSystemCoupon(); + if (systemCoupon != null) + systemCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId()); + + if (systemCoupon == null) + continue; + + String couponName = systemCoupon.getName(); + if (CouponTypeEnum.freeCouponGive == systemCoupon.getType()) + couponName = "鍏嶅崟鍒�"; + + // 閫�鍥炴秷鎭� + String beiZhu = "璇峰埌鎴戠殑-绂忓埄涓績鏌ョ湅"; + SimpleDateFormat sd = new SimpleDateFormat("yyyy.MM.dd HH:mm"); + MsgOtherGiveContentDTO msgOther = new MsgOtherGiveContentDTO(); + msgOther.setType(MsgOtherGiveContentDTO.TYEP_COUPON); + msgOther.setTitle("璧犻��" + couponName + "閫�鍥�"); + msgOther.setGiveType("浣犺禒閫佺殑"+ couponName + "鏈鎴愬姛棰嗗彇"); + msgOther.setGiveTime(sd.format(record.getGiveTime())); + msgOther.setReturnTime(sd.format(new Date())); + userOtherMsgNotificationService.tokenGiveMsg(record.getGiveUid(), beiZhu, msgOther); + } + } + + + @Override + public boolean getIncludeExchange(Long uid) { + List<String> list = new ArrayList<String>(); + list.add(UserSystemCoupon.SOURCE_EXCHANGE); + list.add(UserSystemCoupon.SOURCE_GIVE); + List<UserSystemCoupon> listCoupon = userSystemCouponMapper.getIncludeExchange(uid, list); + if (listCoupon == null || listCoupon.size() == 0) + return false; + return true; + } + + + @Override + public boolean getIncludeNotExchange(Long uid) { + List<String> list = new ArrayList<String>(); + list.add(UserSystemCoupon.SOURCE_EXCHANGE); + list.add(UserSystemCoupon.SOURCE_GIVE); + List<UserSystemCoupon> listCoupon = userSystemCouponMapper.getIncludeNotExchange(uid, list); + if (listCoupon == null || listCoupon.size() == 0) + return false; + return true; + } + } - -- Gitblit v1.8.0