From d8359ddb48dab5cc797a9d552e11fde571f4920c Mon Sep 17 00:00:00 2001 From: yujian <yujian@123.com> Date: 星期二, 27 八月 2019 12:32:46 +0800 Subject: [PATCH] Merge branch 'div' of ssh://193.112.35.168:29418/fanli-server into div --- fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java | 1659 ++++++++++++++++++++++++++++++++++++++++++++++++++++++---- 1 files changed, 1,523 insertions(+), 136 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 2446abf..169bb92 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 @@ -10,30 +10,62 @@ import javax.annotation.Resource; +import org.springframework.core.task.TaskExecutor; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; 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.order.HongBaoOrder; import com.yeshi.fanli.entity.system.SystemCoupon; import com.yeshi.fanli.entity.system.SystemCoupon.CouponTypeEnum; +import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief; +import com.yeshi.fanli.exception.user.UserInfoExtraException; import com.yeshi.fanli.exception.user.UserSystemCouponException; +import com.yeshi.fanli.log.LogHelper; import com.yeshi.fanli.service.inter.common.JumpDetailV2Service; import com.yeshi.fanli.service.inter.config.ConfigService; import com.yeshi.fanli.service.inter.config.SystemCouponService; import com.yeshi.fanli.service.inter.hongbao.HongBaoV2Service; +import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce; +import com.yeshi.fanli.service.inter.msg.UserMoneyMsgNotificationService; +import com.yeshi.fanli.service.inter.msg.UserOtherMsgNotificationService; +import com.yeshi.fanli.service.inter.order.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.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; import com.yeshi.fanli.vo.order.CommonOrderVO; import com.yeshi.fanli.vo.user.UserSystemCouponRecordVO; @@ -44,9 +76,18 @@ @Service public class UserSystemCouponServiceImpl implements UserSystemCouponService { + @Resource(name = "taskExecutor") + private TaskExecutor executor; + + @Resource + private RedisManager redisManager; + @Resource private UserSystemCouponMapper userSystemCouponMapper; + @Resource + private UserSystemCouponGiveRecordService userSystemCouponGiveRecordService; + @Resource private ConfigService configService; @@ -67,12 +108,47 @@ @Resource private HongBaoOrderService hongBaoOrderService; - - // 鍒稿け鏁堝浘鐗� - public final static String PIC_INVALID= "http://192.168.1.200/icon/mian_invalid.png"; - - + @Resource + private OrderHongBaoMapService orderHongBaoMapService; + + @Resource + private OrderService orderService; + + @Resource + private UserMoneyDetailService userMoneyDetailService; + + @Resource + private UserInfoService userInfoService; + + @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; + + @Resource + private TokenRecordService tokenRecordService; + + @Override public int insertSelective(UserSystemCoupon record) { return userSystemCouponMapper.insertSelective(record); @@ -99,25 +175,146 @@ } @Override + public List<UserSystemCoupon> getUserCouponBySource(Long uid, String source) { + return userSystemCouponMapper.getUserCouponBySource(uid, source); + } + + @Override + public int countTodatyUserCouponBySource(Long uid, String source) { + return userSystemCouponMapper.countTodatyUserCouponBySource(uid, source); + } + + @Override public long countUserCouponList(Long uid) { return userSystemCouponMapper.countUserCouponList(uid); } @Override - public List<UserSystemCouponVO> getUserCouponVOList(long start, int count, Long uid) + @Transactional + 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); + } + } + + if (coupon == null) { + throw new UserSystemCouponException(1, "鍒哥被鍨嬩笉姝g‘"); + } + + int stateActivated = 1; + if (coupon.getType() == CouponTypeEnum.welfareFreeCoupon) { + // 绂忓埄鍒哥姸鎬� + long countSuccess = threeSaleSerivce.countSuccessFirstTeam(uid); + // 娌℃湁涓嬬骇闃熷憳 --寰呮縺娲� + 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(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.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); + + executor.execute(new Runnable() { + @Override + public void run() { + UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid); + // 娣诲姞涓�鏉℃秷鎭� + if (userInfoExtra != null) { + if (userInfoExtra.getCouponNews() == null) { + userInfoExtra.setCouponNews(1); + } else { + userInfoExtra.setCouponNews(userInfoExtra.getCouponNews() + 1); + } + + try { + userInfoExtraService.saveUserInfoExtra(userInfoExtra); + } catch (UserInfoExtraException e) { + e.printStackTrace(); + } + } + + } + }); + + // 娑堟伅鎺ㄩ�� + try { + if (coupon.getType() == CouponTypeEnum.welfareFreeCoupon) { + userOtherMsgNotificationService.welfareCouponGet(userCoupon); + } else if (coupon.getType() == CouponTypeEnum.freeCoupon) { + userOtherMsgNotificationService.freeSheetCouponGet(userCoupon); + } else if (coupon.getType() == CouponTypeEnum.rebatePercentCoupon) { + userOtherMsgNotificationService.rewardCouponGet(userCoupon, coupon.getPercent().intValue()); + } + + } catch (Exception e) { + try { + LogHelper.errorDetailInfo(e); + } catch (Exception e1) { + e1.printStackTrace(); + } + } + } + + @Transactional + @Override + public List<UserSystemCouponVO> getUserCouponVOList(long start, int count, Long uid, boolean changeJump) throws UserSystemCouponException, Exception { if (uid == null) { return null; } + // 閫�鍥炲埜 + sendBackTimeOutCoupon(uid); + List<UserSystemCouponVO> listVO = userSystemCouponMapper.getUserCouponVOList(start, count, uid); if (listVO == null || listVO.size() == 0) { return listVO; } // 鏁版嵁缁勭粐 - listDataFactory(listVO); + listDataFactory(listVO, uid, changeJump); return listVO; } @@ -127,8 +324,14 @@ * * @param listVO */ - public void listDataFactory(List<UserSystemCouponVO> listVO) { + 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(); @@ -147,33 +350,43 @@ userCouponVO.setCouponPicture(systemCoupon.getPicture()); userCouponVO.setCouponEffect(systemCoupon.getEffect()); userCouponVO.setCouponRule(systemCoupon.getRule()); - - // 浣跨敤涓姸鎬� 鏀瑰彉涓哄凡浣跨敤 - Integer state = userCouponVO.getState(); - if (UserSystemCoupon.STATE_IN_USE == state) { - state = UserSystemCoupon.STATE_END_USE; - userCouponVO.setState(state); - } - - - // 鎸夐挳璺宠浆 + userCouponVO.setCouponPictureInvalid(systemCoupon.getPictureInvalid()); + // 浣跨敤鐘舵�� + 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()); - systemCoupon.setEffect("寰呮縺娲�"); - - // 鐘舵�佹湭婵�娲� - userCouponVO.setState(0); + userCouponVO.setCouponEffect("寰呮縺娲�"); + // 鐘舵�佹湭婵�娲� -涓旀湭琚娇鐢� + if (UserSystemCoupon.STATE_CAN_USE == state) { + userCouponVO.setState(0); + } jumpBtn = new HashMap<String, Object>(); - Map<String, Object> jumpLink = new HashMap<String, Object>(); - jumpLink.put("url", configService.get("invite_activation_url")); - jumpBtn.put("params", jumpLink); - jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite")); - + + // 绂忓埄鍒搁渶瑕佹縺娲荤晫闈� + 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")); + } + } + } else if (stateActivated == 1) { // 鏄剧ず瑙勫垯 userCouponVO.setCouponRule(systemCoupon.getRule()); @@ -181,28 +394,37 @@ 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) { // 鍏嶅崟鍒搞�� 绂忓埄鍏嶅崟鍒� - jumpLink.put("url", configService.get("invite_activation_url")); + + // 鍏嶅崟鍟嗗搧鍒楄〃 + 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) { - // 杩斿埄濂栧姳鍒� - jumpLink.put("url", configService.get("invite_activation_url")); + // 杩斿埄濂栧姳鍒�- 璺宠浆鑷宠鍗曞埌璐︾晫闈� + jumpLink.put("state", "2"); jumpBtn = new HashMap<String, Object>(); jumpBtn.put("params", jumpLink); - jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite")); + // 璺宠浆璁㈠崟鍒楄〃 + jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("orderList")); } - } else if (UserSystemCoupon.STATE_END_USE == state || UserSystemCoupon.STATE_OVERDUE == state) { - userCouponVO.setCouponPicture(PIC_INVALID); + + } 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 = "鏈夋晥鏈燂細"; @@ -217,12 +439,12 @@ if (UserSystemCoupon.STATE_CAN_USE == state) { int differentDays = 0; if (endTime != null && startTime != null) { - differentDays = DateUtil.differentDaysByMillisecond(new Date(), endTime) + 1; + 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 + "澶╄繃鏈�"); @@ -241,9 +463,8 @@ listCouponId.add(systemCoupon.getId()); } - List<UserSystemCouponVO> listVO = userSystemCouponMapper.getEnableListByCouponId(uid, activated, - listCouponId); - + List<UserSystemCouponVO> listVO = userSystemCouponMapper.getEnableListByCouponId(uid, activated, listCouponId); + if (listVO == null || listVO.size() == 0) { return null; } @@ -263,19 +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()); - - Integer stateActivated = userCouponVO.getStateActivated(); - if (stateActivated == null || stateActivated == 0) { - userCouponVO.setCouponPicture(PIC_INVALID); // 鏈縺娲� - userCouponVO.setState(0); - } else { - userCouponVO.setCouponPicture(systemCoupon.getPicture()); - } + userCouponVO.setCouponRuleLink(systemCoupon.getRuleLink()); + userCouponVO.setCouponPicture(systemCoupon.getPicture()); + userCouponVO.setCouponPictureInvalid(systemCoupon.getPictureInvalid()); int differentDays = 0; String couponTerm = "鏈夋晥鏈燂細"; @@ -285,24 +504,38 @@ SimpleDateFormat sdf = new SimpleDateFormat("yyyy.MM.dd"); couponTerm = couponTerm + sdf.format(startTime) + "-" + sdf.format(endTime); - differentDays = DateUtil.differentDaysByMillisecond(new Date(), endTime) + 1; + 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 + "澶╄繃鏈�"); - remainDays.put("fontColor", "#F14242"); + 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); } return listVO; } + /** * 鏄惁瀛樺湪濂栧姳鍒� * @@ -327,11 +560,17 @@ return hasCoupon; } + @Transactional @Override public List<UserSystemCouponVO> getOrderCouponList(Long uid) throws UserSystemCouponException, Exception { + if (uid == null) { throw new UserSystemCouponException(1, "鐢ㄦ埛鏈櫥褰�"); } + + // 閫�鍥炲埜 + sendBackTimeOutCoupon(uid); + // 璁㈠崟鐩稿叧鐨勫埜 List<SystemCoupon> couponList = systemCouponService.getOrderCouponList(); if (couponList == null || couponList.size() == 0) { @@ -341,22 +580,58 @@ return getEnableListByCouponId(uid, 1, couponList); } + @Transactional @Override - public List<UserSystemCouponVO> getGoodsCouponList(Long uid) 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涓虹┖"); + } + + // 閫�鍥炲埜 + sendBackTimeOutCoupon(uid); + // 鍟嗗搧鐩稿叧鐨勫埜 List<SystemCoupon> couponList = systemCouponService.getGoodsCouponList(); if (couponList == null || couponList.size() == 0) { return null; } - return getEnableListByCouponId(uid, null, couponList); + 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) { + // 鏄剧ず涓嶈兘浣跨敤 + 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, "鐢ㄦ埛鏈櫥褰�"); } @@ -369,17 +644,33 @@ if (userSystemCoupon == null) { 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)) { throw new UserSystemCouponException(1, "浼犻�掑弬鏁颁笉鍖归厤"); } - + SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon(); - + SystemCoupon baseCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId()); if (baseCoupon == null || baseCoupon.getId() == null) { throw new UserSystemCouponException(1, "鏈壘鍒板埜鍩烘湰淇℃伅"); + } + + if (baseCoupon.getType() != CouponTypeEnum.freeCoupon + && baseCoupon.getType() != CouponTypeEnum.welfareFreeCoupon + && baseCoupon.getType() != CouponTypeEnum.freeCouponBuy) { + throw new UserSystemCouponException(1, "鍒哥被鍨嬩笉鍖归厤"); } Date date = new Date(); @@ -392,26 +683,54 @@ // 鎻掑叆浣跨敤鍒歌褰� 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); + } else if (baseCoupon.getType() == CouponTypeEnum.freeCoupon) { + // userOtherMsgNotificationService.freeSheetCouponUsing(userSystemCoupon); + } + + } 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) { + throw new UserSystemCouponException(1, "璇ュ埜涓嶈兘琚娇鐢�"); } // 绯荤粺鍒镐俊鎭� @@ -423,17 +742,19 @@ } } + if (systemCoupon.getType() != CouponTypeEnum.rebatePercentCoupon) { + 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, "璁㈠崟淇℃伅鑾峰彇澶辫触"); } - - Long commonOrderId = orderVO.getId(); BigDecimal hongBao = orderVO.getHongBao(); // 绾㈠寘鐘舵�� @@ -443,6 +764,10 @@ // 鏉′欢: A:蹇呴』鏄繑鍒╄鍗� 銆丅:蹇呴』宸茬粡澶勪簬宸插埌璐︾姸鎬� if (HongBaoV2.TYPE_ZIGOU == hongBaoType && HongBaoV2.STATE_YILINGQU == hongBaoState || hongBao != null) { + + Order order = orderService.findOrderByOrderIdAndType(orderNo, sourceType); + if (order == null) + return; /* 濂栭噾璁$畻 浠ュ強鐩稿叧绾㈠寘淇℃伅澶勭悊 */ @@ -460,15 +785,23 @@ hongBaoV2.setCreateTime(new Date()); hongBaoV2.setUpdateTime(new Date()); hongBaoV2.setUserInfo(new UserInfo(uid)); + hongBaoV2.setPreGetTime(new Date()); + hongBaoV2.setGetTime(new Date()); + hongBaoV2Service.insertSelective(hongBaoV2); - // 2銆佽鍗曞叧鑱旂孩鍖呰〃 - HongBaoOrder hongBaoOrder = new HongBaoOrder(); - hongBaoOrder.setHongBaoV2(hongBaoV2); - hongBaoOrder.setCommonOrder(new CommonOrder(commonOrderId)); - hongBaoOrderService.insertSelective(hongBaoOrder); + // 2.鎻掑叆鍏宠仈 + orderHongBaoMapService.addOrderHongBaoMap(hongBaoV2, order); - // TODO 绾㈠寘鐩稿叧淇℃伅鎻掑叆浠ュ強閫氱煡 + // 3.鎻掑叆璧勯噾鏄庣粏,鐢ㄦ埛浣欓 + UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createOrderReward(orderNo, sourceType, money, + new UserInfo(uid)); + userMoneyDetailService.addUserMoneyDetail(userMoneyDetail); + userInfoService.addMoney(new UserInfo(uid), money); + + // 鎻掑叆璧勯噾閫氱煡 + userMoneyMsgNotificationService.orderReward(uid, orderNo, sourceType, money, + userInfoService.selectByPKey(uid).getMyHongBao()); /* 鐢ㄦ埛鍒镐俊鎭姸鎬佸強璁板綍澶勭悊 */ @@ -482,19 +815,26 @@ // 鎻掑叆浣跨敤鍒歌褰� 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) { + LogHelper.errorDetailInfo(e); + } } } - @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, "璁㈠崟鍙蜂笉瀛樺湪"); @@ -527,25 +867,33 @@ throw new UserSystemCouponException(1, "鍒哥被鍨嬩笉姝g‘"); } - List<CommonOrderVO> list = commonOrderService.getCouponHongbaoByOrderNo(userSystemCoupon.getUid(), - HongBaoV2.STATE_YILINGQU, orderNo); + Long uid = userSystemCoupon.getUid(); - if (list == null || list.size() == 0) { + 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(list.get(0)); - userRecordVO.setCouponName("濂栧姳閲�: 楼" + list.get(0).getCouponMoney().setScale(2, BigDecimal.ROUND_DOWN)); + userRecordVO.setCommonOrder(commonOrderVO); + userRecordVO.setCouponName("濂栧姳閲�: 楼" + couponMoney.setScale(2, BigDecimal.ROUND_DOWN)); // 姣斾緥 BigDecimal percent = baseCoupon.getPercent(); - BigDecimal hongBao = list.get(0).getHongBao().setScale(2, BigDecimal.ROUND_DOWN); - userRecordVO.setCouponEffect("杩斿埄楼" + hongBao + "宸茶繑" + percent + "%"); + BigDecimal hongBao = commonOrderVO.getHongBao(); + if (hongBao == null) { + hongBao = new BigDecimal(0); + } + userRecordVO.setCouponEffect("杩斿埄楼" + hongBao.setScale(2, BigDecimal.ROUND_DOWN) + "宸茶繑" + percent + "%"); - // 璺宠浆绂忓埄涓績 - JumpDetailV2 welfareCore = jumpDetailV2Service.getByTypeCache("welfareCore"); + // 璧勯噾鏄庣粏 + JumpDetailV2 welfareCore = jumpDetailV2Service.getByTypeCache("capitalDetails"); Map<String, Object> jumpWelfare = new HashMap<String, Object>(); jumpWelfare.put("jumpDetail", welfareCore); Map<String, Object> jumpparms = new HashMap<String, Object>(); @@ -563,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, "璁㈠崟鍙蜂笉瀛樺湪"); @@ -593,87 +940,86 @@ } // 璁㈠崟 - CommonOrderVO orderVO = commonOrderService.getCommonOrderByOrderNo(userSystemCoupon.getUid(), orderNo, null); + CommonOrderVO orderVO = commonOrderService.getCommonOrderByOrderNo(userSystemCoupon.getUid(), orderNo, null, sourceType); if (orderVO == null) { throw new UserSystemCouponException(1, "璁㈠崟淇℃伅鑾峰彇澶辫触"); } - + UserSystemCouponRecordVO userRecordVO = new UserSystemCouponRecordVO(); userRecordVO.setCommonOrder(orderVO); - + ClientTextStyleVO fanMoney = new ClientTextStyleVO(); - fanMoney.setContent("杩斿埄: 楼" + orderVO.getHongBao().setScale(2, BigDecimal.ROUND_DOWN)); + fanMoney.setContent("杩斿埄: 楼" + orderVO.getHongBao().setScale(2, BigDecimal.ROUND_DOWN)); fanMoney.setColor("#000000"); // 榛樿榛戣壊 userRecordVO.setFanMoney(fanMoney); - + ClientTextStyleVO payMoney = new ClientTextStyleVO(); - payMoney.setContent("瀹炰粯娆�:楼"+ orderVO.getPayment().setScale(2, BigDecimal.ROUND_DOWN)); + payMoney.setContent("瀹炰粯娆�:楼" + orderVO.getPayment().setScale(2, BigDecimal.ROUND_DOWN)); payMoney.setColor("#000000"); // 榛樿榛戣壊 - - + String progressMsg = ""; String progressColor = ""; // 璺宠浆濂栧姳鍒歌鍒� - userRecordVO.setRuleLink(configService.get("reward_coupon_help")); + userRecordVO.setRuleLink(configService.get("free_coupon_help")); // 杩涘害锛� 1 鐏拌壊 2 绾㈣壊 3 缁胯壊 String progressState1 = "3"; - String progressState2 = "1"; + String progressState2 = "1"; String progressState3 = "1"; String progressState4 = "1"; - + String goodsState = "鍟嗗搧鏀惰揣"; // 鏂囧瓧鐘舵�� String text2Color = "#999999"; String text3Color = "#999999"; String text4Color = "#999999"; - + // 搴曢儴澶囨敞 String rewardCouponRemark = ""; // 鐘舵�佽烦杞� JumpDetailV2 jumpDetail = null; - // 杩涘害鐘舵�� 1绛夊緟 2 澶辫触 3鎴愬姛 + // 杩涘害鐘舵�� 1绛夊緟 2 澶辫触 3鎴愬姛 int progressState = 1; - + Integer stateRecord = record.getState(); if (UserSystemCouponRecord.STATE_FAIL_RULE == stateRecord) { // 瑙勫垯涓嶅尮閰� progressState = 2; - + progressColor = "#E41212"; - progressMsg = "鎶辨瓑涓嶇鍚堝厤鍗曡鍒欙紝鍏嶅崟澶辫触" ; - - progressState1 = "2"; //涓嶅尮閰� - + progressMsg = "鎶辨瓑涓嶇鍚堝厤鍗曡鍒欙紝鍏嶅崟澶辫触"; + + progressState1 = "2"; // 涓嶅尮閰� + payMoney.setColor("#E41212"); - + userRecordVO.setCouponMoneyState("宸查��鍥�"); userRecordVO.setCouponName(baseCoupon.getName()); - + jumpDetail = jumpDetailV2Service.getByTypeCache("welfareCore"); - + rewardCouponRemark = configService.get("free_coupon_back_remark"); - + } else if (UserSystemCouponRecord.STATE_FAIL_DRAWBACK == stateRecord) { // 閫�娆� progressState = 2; - + progressColor = "#E41212"; progressMsg = "鍟嗗搧宸查��娆撅紝鍏嶅崟澶辫触"; - + text2Color = "#E41212"; goodsState = "鍟嗗搧宸查��娆�"; - + progressState2 = "2"; - + userRecordVO.setCouponMoneyState("宸查��鍥�"); userRecordVO.setCouponName(baseCoupon.getName()); - + jumpDetail = jumpDetailV2Service.getByTypeCache("welfareCore"); - + rewardCouponRemark = configService.get("free_coupon_back_remark"); - - } else if (UserSystemCouponRecord.STATE_FREE_ON == stateRecord) { + + } else if (UserSystemCouponRecord.STATE_FREE_ON == stateRecord) { // 鍏嶅崟涓� if (CommonOrder.STATE_JS == orderVO.getState()) { progressColor = "#ECA01B"; @@ -684,65 +1030,65 @@ progressColor = "#ECA01B"; progressMsg = "鍏嶅崟鍙戣捣锛岀瓑寰呮敹璐�"; } - + rewardCouponRemark = configService.get("free_coupon_remark"); - - } else if (UserSystemCouponRecord.STATE_SUCCESS == stateRecord) { + + } else if (UserSystemCouponRecord.STATE_SUCCESS == stateRecord) { // 鍏嶅崟鎴愬姛 progressState = 3; - + progressColor = "#3EBF13"; progressMsg = "鍏嶅崟鎴愬姛锛屽厤鍗曢噾宸茶浆鍏ヤ綑棰�"; - + progressState2 = "3"; progressState3 = "3"; progressState4 = "3"; - + text2Color = "#000000"; text3Color = "#000000"; text4Color = "#000000"; - + userRecordVO.setCouponMoneyState("宸插埌璐�"); userRecordVO.setCouponName("杩斿埄: 楼" + orderVO.getHongBao().setScale(2, BigDecimal.ROUND_DOWN)); - + jumpDetail = jumpDetailV2Service.getByTypeCache("capitalDetails"); - + rewardCouponRemark = configService.get("free_coupon_remark"); } userRecordVO.setProgressState(progressState); userRecordVO.setPayMoney(payMoney); - + // 鏄剧ず鎻愮ず杈冨ぇ瀛� ClientTextStyleVO progressMsgStyle = new ClientTextStyleVO(); - progressMsgStyle.setContent(progressMsg); + progressMsgStyle.setContent(progressMsg); progressMsgStyle.setColor(progressColor); userRecordVO.setProgressMsg(progressMsgStyle); - - /* --- 杩涘害鐐� ---- */ + + /* --- 杩涘害鐐� ---- */ Map<String, Object> map1 = new HashMap<String, Object>(); map1.put("state", progressState1); - + Map<String, Object> map2 = new HashMap<String, Object>(); map2.put("state", progressState2); ClientTextStyleVO style2 = new ClientTextStyleVO(); - style2.setContent(goodsState); + style2.setContent(goodsState); style2.setColor(text2Color); map2.put("text", style2); - + Map<String, Object> map3 = new HashMap<String, Object>(); map3.put("state", progressState3); ClientTextStyleVO style3 = new ClientTextStyleVO(); - style3.setContent("杩斿埄鍒拌处"); + style3.setContent("杩斿埄鍒拌处"); style3.setColor(text3Color); map3.put("text", style3); - + Map<String, Object> map4 = new HashMap<String, Object>(); map4.put("state", progressState4); ClientTextStyleVO style4 = new ClientTextStyleVO(); - style4.setContent("鍏嶅崟鎴愬姛"); + style4.setContent("鍏嶅崟鎴愬姛"); style4.setColor(text4Color); map4.put("text", style4); - + // 鍦嗙偣棰滆壊 List<Object> progressList = new ArrayList<Object>(); progressList.add(map1); @@ -750,7 +1096,7 @@ progressList.add(map3); progressList.add(map4); userRecordVO.setProgressList(progressList); - + if (jumpDetail != null) { Map<String, Object> jumpState = new HashMap<String, Object>(); jumpState.put("jumpDetail", jumpDetail); @@ -762,8 +1108,1049 @@ if (rewardCouponRemark != null && rewardCouponRemark.trim().length() > 0) { userRecordVO.setRemark(JSONObject.fromObject(rewardCouponRemark)); } - + return userRecordVO; } + + @Transactional + @Override + 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; + } + + // 寰呮椿绂忓埄鍏嶅崟鍒� + List<UserSystemCoupon> list = userSystemCouponMapper.getCouponByTypeAndNotActivated(uid, systemCoupon.getId()); + if (list == null || list.size() == 0) { + return; + } + + for (UserSystemCoupon userSystemCoupon : list) { + // 婵�娲� + 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) { + try { + LogHelper.errorDetailInfo(e); + } catch (Exception e1) { + e1.printStackTrace(); + } + } + } + } + + @Transactional + @Override + public void updateStateByDrawback(String orderNo) throws Exception { + + if (orderNo == null || orderNo.trim().length() == 0) { + return; + } + + UserSystemCouponRecord record = userSystemCouponRecordService.getRecordByOrderNo(orderNo, null); + 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; + } + + UserSystemCouponRecord record = userSystemCouponRecordService.getRecordByOrderNo(orderNo, 2); + 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); + } + } + + @Override + 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) { + UserSystemCoupon userCoupon = new UserSystemCoupon(); + userCoupon.setUpdateTime(new Date()); + userSystemCoupon.setState(UserSystemCoupon.STATE_OVERDUE); + userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon); + + SystemCoupon baseCoupon = userSystemCoupon.getSystemCoupon(); + if (baseCoupon == null) { + continue; + } + + baseCoupon = systemCouponService.selectByPrimaryKey(baseCoupon.getId()); + if (baseCoupon == null || baseCoupon.getId() == null) { + continue; + } + + // 娑堟伅鎺ㄩ�� + try { + if (baseCoupon.getType() == CouponTypeEnum.welfareFreeCoupon) { + userOtherMsgNotificationService.welfareCouponAlreadyOutOfDate(userSystemCoupon); + } else if (baseCoupon.getType() == CouponTypeEnum.freeCoupon) { + userOtherMsgNotificationService.freeSheetCouponAlreadyOutOfDate(userSystemCoupon); + } else if (baseCoupon.getType() == CouponTypeEnum.rebatePercentCoupon) { + userOtherMsgNotificationService.rewardCouponAlreadyOutOfDate(userSystemCoupon); + }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) { + try { + LogHelper.errorDetailInfo(e); + } catch (Exception e1) { + e1.printStackTrace(); + } + } + } + } + + @Transactional + @Override + public void sendBackTimeOutCoupon(Long uid) { + // 瓒呰繃10鍒嗛挓 鏈鍖归厤鐨勫埜 + List<UserSystemCouponRecord> list = userSystemCouponRecordService.getCouponByUsingTimeOut(uid, 600L); + if (list == null || list.size() == 0) { + return; + } + + for (UserSystemCouponRecord couponRecord : list) { + // 鏇存柊鐘舵�侊細鍖归厤瓒呮椂 + couponRecord.setState(UserSystemCouponRecord.STATE_WAIT_TIME_OUT); + couponRecord.setUpdateTime(new Date()); + userSystemCouponRecordService.updateByPrimaryKeySelective(couponRecord); + + UserSystemCoupon userSystemCoupon = couponRecord.getUserSystemCoupon(); + // 鐘舵�佸垵濮嬪寲 + userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE); + userSystemCoupon.setUseTime(null); + userSystemCoupon.setUpdateTime(new Date()); + userSystemCouponMapper.updateByPrimaryKey(userSystemCoupon); + } + } + + @Transactional + @Override + 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) { + throw new Exception("浼犻�掑弬鏁颁笉鑳戒负绌�"); + } + + // 鏌ヨ绛夊緟鍖归厤鐨勫埜璁板綍 + List<UserSystemCouponRecord> list = userSystemCouponRecordService.getRecordByState(uid, + UserSystemCouponRecord.STATE_WAIT); + if (list == null || list.size() == 0) { + return isfree; + } + + // 鍖归厤 + boolean matching = false; + UserSystemCouponRecord record = null; + + for (UserSystemCouponRecord userSystemCouponRecord : list) { + Long goodId = userSystemCouponRecord.getGoodId(); + if (auctionId.equals(goodId)) { + matching = true; // 鍖归厤鎴愬姛 + record = userSystemCouponRecord; + break; + } + } + + // 鍟嗗搧鍖归厤鎴愬姛 + if (matching) { + + record.setOrderNo(orderNo); + record.setUpdateTime(new Date()); + + UserSystemCoupon userSystemCoupon = record.getUserSystemCoupon(); + + if (payment.compareTo(new BigDecimal(10)) > 0) { + // 鏇存柊璁板綍 -- 閲戦涓嶅尮閰� 澶�10鍏� + record.setState(UserSystemCouponRecord.STATE_FAIL_RULE); + userSystemCouponRecordService.updateByPrimaryKeySelective(record); + + // 閫�鍥炲埜 + sendBackCoupon(userSystemCoupon, 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); + } 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 userCoupon, UserSystemCouponRecord record) throws Exception { + if (userCoupon == null) + return; + + 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); + 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 isNewUser = userInfoExtraService.isNewUser(uid); + if (!isNewUser) { + 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_NEWBIES); + 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(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); + } catch (Exception e1) { + e1.printStackTrace(); + } + } + } + + // 绂忓埄涓績绾㈢偣 + UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid); + if (userInfoExtra == null) { + return; + } + Integer couponNews = userInfoExtra.getCouponNews(); + if (couponNews == null) { + userInfoExtra.setCouponNews(num); + } else { + 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 countIncludeExchange(Long uid) { +// +// +// } +// +// +// @Override +// public boolean countNotIncludeExchange(Long uid) { +// +// +// } + } -- Gitblit v1.8.0