From b3fce41f7960a21c707788aa87448c3e4de82da9 Mon Sep 17 00:00:00 2001 From: yujian <yujian> Date: 星期三, 27 二月 2019 11:47:51 +0800 Subject: [PATCH] 福利券 邀请队员成功之后激活 --- fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java | 275 +++++++++++++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 256 insertions(+), 19 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 f2a951f..f4effdd 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,6 +1,7 @@ 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; @@ -18,6 +19,7 @@ import com.yeshi.fanli.entity.bus.user.HongBaoV2; import com.yeshi.fanli.entity.bus.user.Order; 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.UserSystemCouponRecord; import com.yeshi.fanli.entity.common.JumpDetailV2; @@ -26,15 +28,19 @@ import com.yeshi.fanli.entity.system.SystemCoupon; import com.yeshi.fanli.entity.system.SystemCoupon.CouponTypeEnum; 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.CommonOrderService; import com.yeshi.fanli.service.inter.order.HongBaoOrderService; import com.yeshi.fanli.service.inter.order.OrderHongBaoMapService; import com.yeshi.fanli.service.inter.order.OrderService; +import com.yeshi.fanli.service.inter.user.UserInfoExtraService; import com.yeshi.fanli.service.inter.user.UserInfoService; import com.yeshi.fanli.service.inter.user.UserMoneyDetailService; import com.yeshi.fanli.service.inter.user.UserSystemCouponRecordService; @@ -90,6 +96,16 @@ @Resource private UserMoneyMsgNotificationService userMoneyMsgNotificationService; + + @Resource + private UserInfoExtraService userInfoExtraService; + + @Resource + private ThreeSaleSerivce threeSaleSerivce; + + @Resource + private UserOtherMsgNotificationService userOtherMsgNotificationService; + // 鍒稿け鏁堝浘鐗� public final static String PIC_INVALID = "http://192.168.1.200/icon/mian_invalid.png"; @@ -130,20 +146,87 @@ } @Override + public void insertUserCoupon(Long uid, String couponType,String source)throws UserSystemCouponException,Exception{ + + if (couponType == null || uid == null) { + throw new UserSystemCouponException(1, "鍙傛暟涓嶆纭�"); + } + + SystemCoupon coupon= systemCouponService.getCouponByType(couponType); + 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; + } + } + + // 缁撴潫鏃ユ湡 + String endDay = DateUtil.plusDay(coupon.getExpiryDay(), 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); + + + // 娑堟伅鎺ㄩ�� + 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); + } + + } catch(Exception e) { + try { + LogHelper.errorDetailInfo(e); + } catch (Exception e1) { + e1.printStackTrace(); + } + } + } + + + + @Override public List<UserSystemCouponVO> getUserCouponVOList(long start, int count, Long uid) throws UserSystemCouponException, Exception { if (uid == null) { return null; } - + + // 鏇存柊杩囨湡鍒� + updateCounponInvalid(uid); + // 閫�鍥炲埜 + sendBackCoupon(uid); + List<UserSystemCouponVO> listVO = userSystemCouponMapper.getUserCouponVOList(start, count, uid); if (listVO == null || listVO.size() == 0) { return listVO; } // 鏁版嵁缁勭粐 - listDataFactory(listVO); + listDataFactory(listVO, uid); return listVO; } @@ -153,7 +236,7 @@ * * @param listVO */ - public void listDataFactory(List<UserSystemCouponVO> listVO) throws Exception{ + public void listDataFactory(List<UserSystemCouponVO> listVO, Long uid) throws Exception{ for (UserSystemCouponVO userCouponVO : listVO) { @@ -174,21 +257,18 @@ 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); - } // 鎸夐挳璺宠浆 - Map<String, Object> jumpBtn = null; + Integer stateActivated = userCouponVO.getStateActivated(); + if (stateActivated == null || stateActivated == 0) { // 鏄剧ず瑙勫垯 userCouponVO.setCouponRule(systemCoupon.getRemark()); - systemCoupon.setEffect("寰呮縺娲�"); + userCouponVO.setCouponEffect("寰呮縺娲�"); // 鐘舵�佹湭婵�娲� -涓旀湭琚娇鐢� if (UserSystemCoupon.STATE_CAN_USE == state) { @@ -197,9 +277,21 @@ jumpBtn = new HashMap<String, Object>(); Map<String, Object> jumpLink = new HashMap<String, Object>(); - jumpLink.put("url", configService.get("invite_activation_url")); + + UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid); + + // 閭�璇烽槦鍛樼晫闈� + if (userInfoExtra != null && userInfoExtra.getInviteCode() != null + && userInfoExtra.getInviteCode().trim().length() > 0) { + // 閭�璇锋縺娲绘垚鍔熺晫闈� + jumpLink.put("url", configService.get("invite_activation_success_url") + "?alert=true"); + } else { + // 婵�娲婚個璇风爜鐣岄潰 + jumpLink.put("url", configService.get("invite_activation_url")); + } + jumpBtn.put("params", jumpLink); - jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite")); + jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite_web")); } else if (stateActivated == 1) { // 鏄剧ず瑙勫垯 @@ -220,21 +312,26 @@ jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("web")); } 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_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(PIC_INVALID); + } + userCouponVO.setJumpBtn(jumpBtn); String couponTerm = "鏈夋晥鏈燂細"; @@ -255,7 +352,6 @@ differentDays = 0; } } - // 鍓╀綑澶╂暟 Map<String, Object> remainDays = new HashMap<String, Object>(); remainDays.put("content", "杩樺墿" + differentDays + "澶╄繃鏈�"); @@ -365,6 +461,12 @@ if (uid == null) { throw new UserSystemCouponException(1, "鐢ㄦ埛鏈櫥褰�"); } + + // 鏇存柊杩囨湡鍒� + updateCounponInvalid(uid); + // 閫�鍥炲埜 + sendBackCoupon(uid); + // 璁㈠崟鐩稿叧鐨勫埜 List<SystemCoupon> couponList = systemCouponService.getOrderCouponList(); if (couponList == null || couponList.size() == 0) { @@ -379,6 +481,12 @@ if (uid == null) { throw new UserSystemCouponException(1, "鐢ㄦ埛鏈櫥褰�"); } + + // 鏇存柊杩囨湡鍒� + updateCounponInvalid(uid); + // 閫�鍥炲埜 + sendBackCoupon(uid); + // 鍟嗗搧鐩稿叧鐨勫埜 List<SystemCoupon> couponList = systemCouponService.getGoodsCouponList(); if (couponList == null || couponList.size() == 0) { @@ -437,6 +545,19 @@ couponRecord.setCreateTime(date); couponRecord.setUpdateTime(date); userSystemCouponRecordService.insertSelective(couponRecord); + + // 娑堟伅鎺ㄩ�� + try { + if (baseCoupon.getType() != CouponTypeEnum.welfareFreeCoupon) { + userOtherMsgNotificationService.welfareCouponUsing(userSystemCoupon); + } else if (baseCoupon.getType() != CouponTypeEnum.freeCoupon) { + userOtherMsgNotificationService.freeSheetCouponUsing(userSystemCoupon); + } + + } catch(Exception e) { + LogHelper.errorDetailInfo(e); + } + } @Transactional @@ -542,6 +663,13 @@ couponRecord.setCreateTime(date); couponRecord.setUpdateTime(date); userSystemCouponRecordService.insertSelective(couponRecord); + + // 娑堟伅鎺ㄩ�� + try { + userOtherMsgNotificationService.rewardCouponUsed(userSystemCoupon); + } catch(Exception e) { + LogHelper.errorDetailInfo(e); + } } } @@ -821,5 +949,114 @@ return userRecordVO; } + + + @Override + public void activatedWelfareFreeCoupon(Long uid) { + if (uid == null) { + return; + } + // 绂忓埄鍏嶅崟鍒� + String welfareFree = CouponTypeEnum.welfareFreeCoupon.name(); + + SystemCoupon systemCoupon = systemCouponService.getCouponByType(welfareFree); + if (systemCoupon == null) { + return; + } + // 婵�娲荤鍒╁厤鍗曞埜 + userSystemCouponMapper.activateCouponByType(uid, systemCoupon.getId()); + } + + @Override + public void updateCounponInvalid(Long uid) { + List<UserSystemCoupon> list = userSystemCouponMapper.getCounponNowInvalid(uid); + if (list == null || list.size() == 0) { + return; + } + + for (UserSystemCoupon userSystemCoupon: list) { + // 鏇存柊鍒稿凡杩囨湡 + userSystemCoupon.setState(UserSystemCoupon.STATE_OVERDUE); + userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon); + + SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon(); + if (systemCoupon == null) { + continue; + } + + SystemCoupon baseCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId()); + if (baseCoupon == null || baseCoupon.getId() == null) { + continue; + } + + // 娑堟伅鎺ㄩ�� + try { + if (baseCoupon.getType() != CouponTypeEnum.welfareFreeCoupon) { + userOtherMsgNotificationService.welfareCouponAlreadyOutOfDate(userSystemCoupon); + } else if (baseCoupon.getType() != CouponTypeEnum.freeCoupon) { + userOtherMsgNotificationService.freeSheetCouponAlreadyOutOfDate(userSystemCoupon); + } else if (baseCoupon.getType() != CouponTypeEnum.rebatePercentCoupon) { + userOtherMsgNotificationService.rewardCouponAlreadyOutOfDate(userSystemCoupon); + } + + } catch(Exception e) { + try { + LogHelper.errorDetailInfo(e); + } catch (Exception e1) { + e1.printStackTrace(); + } + } + } + } + + @Override + public void sendBackCoupon(Long uid) { + // 瓒呰繃120绉� 鏈鍖归厤鐨勫埜 + List<UserSystemCouponRecord> list = userSystemCouponRecordService.getCouponByUsingTimeOut(uid, 120); + 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); + + 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, new Date()); + SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd"); + endTime = format.parse(endDay); + } catch (ParseException e) { + e.printStackTrace(); + } + + // 鏈夋晥鏈熸椂闂撮噸鏂板畾涔� + userSystemCoupon.setStartTime(new Date()); + userSystemCoupon.setEndTime(endTime); + userSystemCoupon.setUpdateTime(new Date()); + userSystemCouponMapper.updateByPrimaryKey(userSystemCoupon); + } + + } + + + + } -- Gitblit v1.8.0