fanli/src/main/java/com/yeshi/fanli/controller/client/v2/InviteControllerV2.java
@@ -367,12 +367,13 @@ } try { List<String> listIOS = new ArrayList<String>(); List<String> listAndroid = new ArrayList<String>(); pushService.pushZNX(remindId, "", "", listIOS, listAndroid); userSystemMsgService.addUserSystemMsg(remindId, UserSystemMsgTypeEnum.question, "", "", UserSystemMsg.TIME_TAG_EMERGENT, null); // TODO版本区分 // List<String> listIOS = new ArrayList<String>(); // List<String> listAndroid = new ArrayList<String>(); // pushService.pushZNX(remindId, "", "", listIOS, listAndroid); // userSystemMsgService.addUserSystemMsg(remindId, UserSystemMsgTypeEnum.question, // "", "", UserSystemMsg.TIME_TAG_EMERGENT, null); JSONObject data = new JSONObject(); data.put("weiXinState", 2); fanli/src/main/java/com/yeshi/fanli/controller/client/v2/SearchControllerV2.java
@@ -34,6 +34,7 @@ import com.yeshi.fanli.entity.taobao.TaoBaoSearchResult; import com.yeshi.fanli.entity.taobao.dataoke.DaTaoKeDetail; import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException; import com.yeshi.fanli.exception.user.TokenRecordException; import com.yeshi.fanli.log.LogHelper; import com.yeshi.fanli.service.inter.config.BusinessSystemService; import com.yeshi.fanli.service.inter.config.ConfigService; @@ -45,11 +46,13 @@ import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionConfigService; import com.yeshi.fanli.service.inter.taobao.dataoke.DaTaoKeGoodsDetailService; import com.yeshi.fanli.service.inter.user.HistorySearchService; import com.yeshi.fanli.service.inter.user.TokenRecordService; import com.yeshi.fanli.tag.PageEntity; import com.yeshi.fanli.util.Constant; import com.yeshi.fanli.util.StringUtil; import com.yeshi.fanli.util.ThreadUtil; import com.yeshi.fanli.util.Utils; import com.yeshi.fanli.util.VersionUtil; import com.yeshi.fanli.util.cache.TaoBaoGoodsCacheUtil; import com.yeshi.fanli.util.factory.CommonGoodsFactory; import com.yeshi.fanli.util.factory.goods.GoodsDetailVOFactory; @@ -62,6 +65,7 @@ import com.yeshi.fanli.util.taobao.TaoKeApiUtil; import com.yeshi.fanli.vo.brand.TaoBaoShopVO; import com.yeshi.fanli.vo.goods.GoodsDetailVO; import com.yeshi.fanli.vo.msg.TokenVO; import net.sf.json.JSONArray; import net.sf.json.JSONObject; @@ -105,6 +109,9 @@ @Resource(name = "taskExecutor") private TaskExecutor executor; @Resource private TokenRecordService tokenRecordService; /** * 粘贴板信息推荐 @@ -115,15 +122,25 @@ * @param out */ @RequestMapping(value = "getRecommendInfo", method = RequestMethod.POST) public void getRecommendInfo(AcceptData acceptData, String text, PrintWriter out) { public void getRecommendInfo(AcceptData acceptData, String text, Long uid, PrintWriter out) { if (StringUtil.isNullOrEmpty(text)) { out.print(JsonUtil.loadFalseResult("值为空")); return; } // 去除前后空格 text = text.trim(); try { TokenVO tokenVO = tokenRecordService.discernToken(text, uid); out.print(JsonUtil.loadTrueResult(tokenVO)); return; } catch (TokenRecordException e) { if (e.getCode() == 1001) { // 需要用户登录 out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg())); return; } } TaoBaoGoodsBrief tb = null; String URL_REGEX = "(((http|https)://)|(www\\.))[a-zA-Z0-9\\._-]+\\.[a-zA-Z]{2,6}(:[0-9]{1,4})?(/[a-zA-Z0-9\\&%_\\./-~-]*)?"; @@ -228,6 +245,18 @@ } JSONObject data = new JSONObject(); if(VersionUtil.greaterThan_1_6_5(acceptData.getPlatform(), acceptData.getVersion())) { BigDecimal fanLiRate = hongBaoManageService.getFanLiRate(); BigDecimal shareRate = hongBaoManageService.getShareRate(); Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()) .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create(); data.put("type", 3); data.put("goods", gson.toJson(GoodsDetailVOFactory.convertCommonGoods(commonGoods, null, fanLiRate, shareRate))); out.print(JsonUtil.loadTrueResult(data)); return; } JSONObject taoBaoGoodsJSON = new JSONObject(); taoBaoGoodsJSON.put("title", commonGoods.getTitle()); taoBaoGoodsJSON.put("zkPrice", commonGoods.getPrice() + ""); @@ -247,7 +276,6 @@ JSONObject root = new JSONObject(); root.put("type", 1); root.put("data", data); out.print(JsonUtil.loadTrueResult(root)); } @@ -289,6 +317,26 @@ return false; } /** * * @param acceptData * @param kw * @param goodsType * @param out */ @RequestMapping(value = "tokenReceive", method = RequestMethod.POST) public void tokenReceive(AcceptData acceptData, Long uid, String token, PrintWriter out) { try { tokenRecordService.receiveToken(token, uid); out.print(JsonUtil.loadTrueResult("领取成功")); } catch (TokenRecordException e) { out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg())); } } /** * 搜索候选词 * fanli/src/main/java/com/yeshi/fanli/controller/client/v2/TaoLiJinControllerV2.java
@@ -39,6 +39,7 @@ import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief; import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBriefExtra; import com.yeshi.fanli.exception.tlj.UserTaoLiJinOriginException; import com.yeshi.fanli.exception.tlj.UserTaoLiJinRecordException; import com.yeshi.fanli.service.inter.common.JumpDetailV2Service; import com.yeshi.fanli.service.inter.config.ConfigService; import com.yeshi.fanli.service.inter.goods.ShareGoodsService; @@ -253,13 +254,13 @@ lastMonthUse = zero; } // 问号链接 String helpLink = configTaoLiJinService.getValueByKey("hongbao_help_link"); String giveMin = configTaoLiJinService.getValueByKey("give_min_amount"); JSONObject data = new JSONObject(); data.put("tlj", tlj.setScale(2).toString()); data.put("helpLink", helpLink); data.put("giveMin", giveMin); data.put("giveTip", "注:赠送推广红包金额至少"+ giveMin +"元"); data.put("helpLink", configTaoLiJinService.getValueByKey("hongbao_help_link")); data.put("countShare", countShare); data.put("todayWin", todayWin.setScale(2).toString()); data.put("yesterdayWin", yesterdayWin.setScale(2).toString()); @@ -838,5 +839,28 @@ } out.print(JsonUtil.loadTrueResult(data)); } /** * 赠送淘礼金 * @param acceptData * @param uid * @param amount * @param out */ @RequestMapping(value = "giveTLJ", method = RequestMethod.POST) public void giveTLJ(AcceptData acceptData, Long uid, BigDecimal amount, PrintWriter out) { if (uid == null || uid <= 0) { out.print(JsonUtil.loadFalseResult(1, "用户未登录")); return; } try { String tips = userTaoLiJinRecordService.giveTaolijin(uid, amount); out.print(JsonUtil.loadTrueResult(tips)); } catch (UserTaoLiJinRecordException e) { out.print(JsonUtil.loadFalseResult(1, e.getMsg())); } } } fanli/src/main/java/com/yeshi/fanli/dao/mybatis/tlj/UserTaoLiJinGiveRecordMapper.java
@@ -4,5 +4,6 @@ import com.yeshi.fanli.entity.bus.tlj.UserTaoLiJinGiveRecord; public interface UserTaoLiJinGiveRecordMapper extends BaseMapper<UserTaoLiJinGiveRecord> { } fanli/src/main/java/com/yeshi/fanli/entity/bus/tlj/UserTaoLiJinDetail.java
@@ -21,7 +21,9 @@ add("红包增加", "http://img.flqapp.com/img/tlj/icon_tlj.png"), reduce("成功使用扣除", "http://img.flqapp.com/img/tlj/icon_tlj.png"), sendBack("长期未使用收回", "http://img.flqapp.com/img/tlj/icon_tlj.png"), refund("未使用成功退回", "http://img.flqapp.com/img/tlj/icon_tlj.png"); refund("未使用成功退回", "http://img.flqapp.com/img/tlj/icon_tlj.png"), give("红包赠送", "http://img.flqapp.com/img/tlj/icon_tlj.png"), giveBack("赠送退回 ", "http://img.flqapp.com/img/tlj/icon_tlj.png"); private final String desc; private final String picture; fanli/src/main/java/com/yeshi/fanli/entity/bus/tlj/UserTaoLiJinGiveRecord.java
@@ -1,5 +1,6 @@ package com.yeshi.fanli.entity.bus.tlj; import java.math.BigDecimal; import java.util.Date; import org.yeshi.utils.mybatis.Column; @@ -11,9 +12,20 @@ */ @Table("yeshi_ec_user_taolijin_give_record") public class UserTaoLiJinGiveRecord { // 未领取 public final static int STATE_INIT = 0; // 已领取 public final static int STATE_RECEIVE =1; // 已过期 退回 public final static int STATE_OVERDUE = 2; @Column(name = "tgr_id") private Long id; // 面额 @Column(name = "tgr_amount") private BigDecimal amount; // 赠送uid @Column(name = "tgr_give_uid") private Long giveUid; @@ -80,4 +92,11 @@ this.state = state; } public BigDecimal getAmount() { return amount; } public void setAmount(BigDecimal amount) { this.amount = amount; } } fanli/src/main/java/com/yeshi/fanli/service/impl/tlj/UserTaoLiJinRecordServiceImpl.java
@@ -13,14 +13,18 @@ import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.yeshi.utils.BigDecimalUtil; import org.yeshi.utils.DateUtil; import com.yeshi.fanli.dao.mybatis.tlj.UserTaoLiJinRecordMapper; import com.yeshi.fanli.dto.msg.MsgOtherTaoLiJinContentDTO; import com.yeshi.fanli.dto.taobao.TaoLiJinDTO; import com.yeshi.fanli.entity.bus.tlj.UserTaoLiJinDetail; import com.yeshi.fanli.entity.bus.tlj.UserTaoLiJinDetail.TaoLiJinDetailTypeEnum; import com.yeshi.fanli.entity.bus.tlj.UserTaoLiJinGiveRecord; import com.yeshi.fanli.entity.bus.tlj.UserTaoLiJinOrigin; import com.yeshi.fanli.entity.bus.tlj.UserTaoLiJinRecord; import com.yeshi.fanli.entity.bus.user.TokenRecord; import com.yeshi.fanli.entity.bus.user.TokenRecord.TokenTypeEnum; import com.yeshi.fanli.entity.bus.user.UserMoneyExtra; import com.yeshi.fanli.entity.goods.CommonGoods; import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief; @@ -28,6 +32,7 @@ import com.yeshi.fanli.exception.taobao.TaoKeApiException; import com.yeshi.fanli.exception.tlj.UserTaoLiJinRecordException; import com.yeshi.fanli.log.LogHelper; import com.yeshi.fanli.service.inter.config.ConfigService; import com.yeshi.fanli.service.inter.goods.CommonGoodsService; import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService; import com.yeshi.fanli.service.inter.msg.UserOtherMsgNotificationService; @@ -35,9 +40,11 @@ import com.yeshi.fanli.service.inter.taobao.TaoBaoBuyRelationMapService; import com.yeshi.fanli.service.inter.tlj.ConfigTaoLiJinService; import com.yeshi.fanli.service.inter.tlj.UserTaoLiJinDetailService; import com.yeshi.fanli.service.inter.tlj.UserTaoLiJinGiveRecordService; import com.yeshi.fanli.service.inter.tlj.UserTaoLiJinOriginService; import com.yeshi.fanli.service.inter.tlj.UserTaoLiJinRecordService; import com.yeshi.fanli.service.inter.tlj.UserTaoLiJinReportService; import com.yeshi.fanli.service.inter.user.TokenRecordService; import com.yeshi.fanli.service.inter.user.UserExtraTaoBaoInfoService; import com.yeshi.fanli.service.inter.user.UserInfoExtraService; import com.yeshi.fanli.service.inter.user.UserMoneyExtraService; @@ -46,6 +53,7 @@ import com.yeshi.fanli.util.RedisManager; import com.yeshi.fanli.util.StringUtil; import com.yeshi.fanli.util.TaoBaoConstant; import com.yeshi.fanli.util.account.UserUtil; import com.yeshi.fanli.util.factory.CommonGoodsFactory; import com.yeshi.fanli.util.taobao.TaoKeApiUtil; import com.yeshi.fanli.util.taobao.TaoLiJinUtil; @@ -60,6 +68,9 @@ @Resource private RedisManager redisManager; @Resource private ConfigService configService; @Resource private UserTaoLiJinRecordMapper userTaoLiJinRecordMapper; @@ -99,6 +110,13 @@ @Resource private ShareHotGoodsService shareHotGoodsService; @Resource private TokenRecordService tokenRecordService; @Resource private UserTaoLiJinGiveRecordService userTaoLiJinGiveRecordService; @Override public UserTaoLiJinRecord selectByPrimaryKey(Long id) { @@ -496,5 +514,130 @@ public UserTaoLiJinRecord getByRightsId(String rightsId) { return userTaoLiJinRecordMapper.getByRightsId(rightsId); } @Override public String giveTaolijin(Long uid, BigDecimal amount) throws UserTaoLiJinRecordException{ if (uid == null || amount == null) throw new UserTaoLiJinRecordException(1,"参数不正确"); String giveMin = configTaoLiJinService.getValueByKey("give_min_amount"); if (amount.compareTo(new BigDecimal(giveMin)) < 0) throw new UserTaoLiJinRecordException(1,"赠送推广红包金额至少" + giveMin + "元"); // 用户剩余可以淘礼金验证 UserMoneyExtra userMoneyExtra = userMoneyExtraService.selectByPrimaryKey(uid); if (userMoneyExtra == null || userMoneyExtra.getTlj() == null) throw new UserTaoLiJinRecordException(1, "红包余额不足"); BigDecimal tlj = userMoneyExtra.getTlj(); if (amount.compareTo(tlj) > 0) throw new UserTaoLiJinRecordException(1, "红包余额不足"); Date nowDate = new Date(); // 赠送记录 UserTaoLiJinGiveRecord giveRecord = new UserTaoLiJinGiveRecord(); giveRecord.setAmount(amount); giveRecord.setGiveUid(uid); giveRecord.setState(UserTaoLiJinGiveRecord.STATE_INIT); giveRecord.setGiveTime(nowDate); userTaoLiJinGiveRecordService.insertSelective(giveRecord); String token = null; for (int i = 0; i < 5; i++) { try { // TODO 口令生成规则待定 long num = 10000 + (long) (Math.random() * 10000); token = UserUtil.getInviteCode(num); TokenRecord tokenRecord = new TokenRecord(); tokenRecord.setUid(uid); tokenRecord.setIdentify(giveRecord.getId()+""); // 记录id tokenRecord.setType(TokenTypeEnum.taoLiJin); tokenRecord.setStartTime(nowDate); tokenRecord.setEndTime(DateUtil.plusDayDate(3, nowDate)); tokenRecord.setToken(token); tokenRecord.setState(0); tokenRecordService.insertSelective(tokenRecord); } catch (Exception e) { LogHelper.errorDetailInfo(e); token = null; } if(!StringUtil.isNullOrEmpty(token)) { break; } } if(StringUtil.isNullOrEmpty(token)) throw new UserTaoLiJinRecordException(1, "口令生成失败"); UserMoneyExtra updateExtra = new UserMoneyExtra(); updateExtra.setUid(uid); updateExtra.setTlj(MoneyBigDecimalUtil.sub(tlj, amount)); updateExtra.setUpdateTime(new Date()); userMoneyExtraService.updateByPrimaryKeySelective(updateExtra); String tips = "送给你[%s]元推广红包快去领取吧，复制本条消息[&%s&]，打开[返利券]App领取，用推广分享爆款商品，成单率更高哦。\r\n" + "----------------------------\r\n" + "下载[返利券]App链接:%s\r\n" + "PS：口令将会24小时内失效，请及时领取。"; tips = String.format(tips, amount, token, configService.get("app_down_link")); executor.execute(new Runnable() { @Override public void run() { try { // 插入明细 UserTaoLiJinDetail detail = new UserTaoLiJinDetail(); detail.setUid(uid); detail.setMoney(new BigDecimal("-" + amount)); detail.setTitle(TaoLiJinDetailTypeEnum.give.getDesc()); detail.setType(TaoLiJinDetailTypeEnum.give); detail.setCreateTime(new Date()); userTaoLiJinDetailService.insertSelective(detail); } catch (Exception e) { LogHelper.errorDetailInfo(e); } // 成功使用红包 try { BigDecimal total = amount; BigDecimal lastMoney = null; BigDecimal zero = new BigDecimal(0); // 修改余额 List<UserTaoLiJinOrigin> list = userTaoLiJinOriginService.getSurplusLiJin(uid); if (list != null && list.size() > 0) { for (UserTaoLiJinOrigin taoLiJinOrigin : list) { if (total.compareTo(zero) < 1) { break; } BigDecimal moneySurplus = taoLiJinOrigin.getMoneySurplus(); lastMoney = total; total = MoneyBigDecimalUtil.sub(total, moneySurplus); if (total.compareTo(zero) >= 0) { moneySurplus = zero; } else { moneySurplus = MoneyBigDecimalUtil.sub(moneySurplus, lastMoney); } UserTaoLiJinOrigin usertlj = new UserTaoLiJinOrigin(); usertlj.setId(taoLiJinOrigin.getId()); usertlj.setMoneySurplus(moneySurplus); usertlj.setUpdateTime(new Date()); userTaoLiJinOriginService.updateByPrimaryKeySelective(usertlj); } } } catch (Exception e) { LogHelper.errorDetailInfo(e); } } }); return tips; } } fanli/src/main/java/com/yeshi/fanli/service/impl/user/TokenRecordServiceImpl.java
@@ -7,16 +7,24 @@ import javax.annotation.Resource; import org.springframework.stereotype.Service; import org.yeshi.utils.JsonUtil; import com.yeshi.fanli.dao.mybatis.user.TokenRecordMapper; import com.yeshi.fanli.entity.bus.tlj.UserTaoLiJinGiveRecord; import com.yeshi.fanli.entity.bus.user.ThreeSale; 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.system.SystemCoupon.CouponTypeEnum; import com.yeshi.fanli.exception.user.TokenRecordException; import com.yeshi.fanli.exception.user.UserSystemCouponException; import com.yeshi.fanli.log.LogHelper; import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce; import com.yeshi.fanli.service.inter.tlj.UserTaoLiJinGiveRecordService; 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.UserSystemCouponService; import com.yeshi.fanli.util.Constant; @@ -24,41 +32,45 @@ import com.yeshi.fanli.vo.msg.TokenVO; @Service public class TokenRecordServiceImpl implements TokenRecordService{ public class TokenRecordServiceImpl implements TokenRecordService { @Resource private TokenRecordMapper tokenRecordMapper; @Resource private UserInfoService userInfoService; @Resource private UserSystemCouponService userSystemCouponService; @Resource private ThreeSaleSerivce threeSaleSerivce; @Resource private UserTaoLiJinGiveRecordService userTaoLiJinGiveRecordService; @Resource private UserInfoExtraService userInfoExtraService; @Override public void insertSelective(TokenRecord record) { record.setCreateTime(new Date()); record.setUpdateTime(new Date()); tokenRecordMapper.insertSelective(record); } @Override public TokenRecord getNearByTypeAndIdentify(String type, String identify) { return tokenRecordMapper.getNearByTypeAndIdentify(type, identify); } public void discernToken(String token, Long uid) throws TokenRecordException { @Override public TokenVO discernToken(String token, Long uid) throws TokenRecordException { // TODO token 验证 TokenRecord rokenRecord = tokenRecordMapper.getByToken(token); if (rokenRecord == null) if (rokenRecord == null) throw new TokenRecordException(1, "口令不存在"); String nickName = null; @@ -66,114 +78,237 @@ Long inviteId = rokenRecord.getUid(); if (inviteId != null) { UserInfo inviteUser = userInfoService.selectByPKey(inviteId); if (inviteUser !=null) { if (inviteUser != null) { nickName = inviteUser.getNickName(); portrait = inviteUser.getPortrait(); } } if (StringUtil.isNullOrEmpty(nickName)) nickName = Constant.systemCommonConfig.getDefaultNickName(); if (StringUtil.isNullOrEmpty(portrait)) if (StringUtil.isNullOrEmpty(portrait)) portrait = Constant.systemCommonConfig.getDefaultPortrait(); if (nickName.length() > 6) { nickName = nickName.substring(0, 6) + "..."; } Integer stateTtoken = rokenRecord.getState(); if (stateTtoken == 1) throw new TokenRecordException(1, "口令已失效"); TokenVO tokenVO = new TokenVO(); tokenVO.setNickName(nickName); tokenVO.setPortrait(portrait); String identify = rokenRecord.getIdentify(); if (StringUtil.isNullOrEmpty(identify)) if (StringUtil.isNullOrEmpty(identify)) throw new TokenRecordException(1, "口令标识不存在"); Integer type = 0; boolean state = false; List<String> tips = new ArrayList<String>(); TokenTypeEnum tokenType = rokenRecord.getType(); if (tokenType == TokenTypeEnum.freeCoupon) { type = 10; UserSystemCoupon userCoupon = userSystemCouponService.selectByPrimaryKey(Long.parseLong(identify)); if (userCoupon == null || userCoupon.getState() == UserSystemCoupon.STATE_OVERDUE) { if (userCoupon == null) { tips.add("哎呀，这张免单券已失效了！"); } else if (userCoupon.getState() == UserSystemCoupon.STATE_END_USE) { tips.add("哎呀，这张免单券已被领取了！"); } else if (userCoupon.getState() == UserSystemCoupon.STATE_CAN_USE) { throw new TokenRecordException(1, "口令已失效"); } else if (userCoupon.getState() == UserSystemCoupon.STATE_IN_USE) { if (uid == null || uid <= 0) throw new TokenRecordException(1001, "用户未登录"); state = true; ThreeSale boss = threeSaleSerivce.getMyBoss(uid); if (boss != null) { tips.add("获赠的免单券，需要激活后才能使用，详情参见免单券激活规则；"); tips.add("成功领取后，请到“我的-福利中心”查看。"); } else { Boolean give = userCoupon.getGive(); if (give == null) give = false; if (userCoupon.getState() == UserSystemCoupon.STATE_OVERDUE) { tips.add("哎呀，这张免单券已失效了！"); } else if (userCoupon.getState() == UserSystemCoupon.STATE_END_USE) { tips.add("哎呀，这张免单券已被领取了！"); } else if (userCoupon.getState() == UserSystemCoupon.STATE_CAN_USE) { throw new TokenRecordException(1, "口令已失效"); } else if (give && userCoupon.getState() == UserSystemCoupon.STATE_IN_USE) { if (uid == null || uid <= 0) throw new TokenRecordException(1001, "温馨提示，[免单券]需要登录后领取"); state = true; UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid); if (userInfoExtra == null || StringUtil.isNullOrEmpty(userInfoExtra.getInviteCode())) { tips.add("确认领取后，你将成为赠送者的一级队员；"); tips.add("获赠的免单券，需要激活后才能使用，详情参见免单券激活规则；"); tips.add("成功领取后，请到“我的-福利中心”查看。"); } else { tips.add("获赠的免单券，需要激活后才能使用，详情参见免单券激活规则；"); tips.add("成功领取后，请到“我的-福利中心”查看。"); } } else { tips.add("确认领取后，你将成为赠送者的一级队员；"); tips.add("获赠的免单券，需要激活后才能使用，详情参见免单券激活规则；"); tips.add("成功领取后，请到“我的-福利中心”查看。"); throw new TokenRecordException(1, "口令已失效"); } } } else if (tokenType == TokenTypeEnum.rebatePercentCoupon) { type = 11; UserSystemCoupon userCoupon = userSystemCouponService.selectByPrimaryKey(Long.parseLong(identify)); if (userCoupon == null || userCoupon.getState() == UserSystemCoupon.STATE_OVERDUE) { tips.add("哎呀，这张返利奖励券已失效了！"); } else if (userCoupon.getState() == UserSystemCoupon.STATE_END_USE) { tips.add("哎呀，这张返利奖励券已被领取了！"); } else if (userCoupon.getState() == UserSystemCoupon.STATE_CAN_USE) { throw new TokenRecordException(1, "口令已失效"); } else if (userCoupon.getState() == UserSystemCoupon.STATE_IN_USE) { if (uid == null || uid <= 0) throw new TokenRecordException(1001, "用户未登录"); state = true; ThreeSale boss = threeSaleSerivce.getMyBoss(uid); if (boss != null) { tips.add("返利券奖励券，可用于“已到账”的返利订单，在返利的基础上再获得一定比例的返利；"); tips.add("成功领取后，请到“我的-福利中心”中查看。"); if (userCoupon == null) { } else { Boolean give = userCoupon.getGive(); if (give == null) give = false; if (userCoupon.getState() == UserSystemCoupon.STATE_OVERDUE) { tips.add("哎呀，这张返利奖励券已失效了！"); } else if (userCoupon.getState() == UserSystemCoupon.STATE_END_USE) { tips.add("哎呀，这张返利奖励券已被领取了！"); } else if (userCoupon.getState() == UserSystemCoupon.STATE_CAN_USE) { throw new TokenRecordException(1, "口令已失效"); } else if (give && userCoupon.getState() == UserSystemCoupon.STATE_IN_USE) { if (uid == null || uid <= 0) throw new TokenRecordException(1001, "温馨提示，[返利奖励券]需要登录后领取"); state = true; UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid); if (userInfoExtra == null || StringUtil.isNullOrEmpty(userInfoExtra.getInviteCode())) { tips.add("确认领取后，你将成为赠送者的一级队员；"); tips.add("返利券奖励券，可用于“已到账”的返利订单，在返利的基础上再获得一定比例的返利；"); tips.add("成功领取后，请到“我的-福利中心”中查看。"); } else { tips.add("返利券奖励券，可用于“已到账”的返利订单，在返利的基础上再获得一定比例的返利；"); tips.add("成功领取后，请到“我的-福利中心”中查看。"); } } else { tips.add("确认领取后，你将成为赠送者的一级队员；"); tips.add("返利券奖励券，可用于“已到账”的返利订单，在返利的基础上再获得一定比例的返利；"); tips.add("成功领取后，请到“我的-福利中心”中查看。"); throw new TokenRecordException(1, "口令已失效"); } } } else if (tokenType == TokenTypeEnum.taoLiJin) { UserSystemCoupon userCoupon = userSystemCouponService.selectByPrimaryKey(Long.parseLong(identify)); if (userCoupon == null || userCoupon.getState() == UserSystemCoupon.STATE_OVERDUE) { tips.add("哎呀，这张返利奖励券已失效了！"); } else if (userCoupon.getState() == UserSystemCoupon.STATE_END_USE) { tips.add("哎呀，这张返利奖励券已被领取了！"); } else if (userCoupon.getState() == UserSystemCoupon.STATE_CAN_USE) { throw new TokenRecordException(1, "口令已失效"); } else if (userCoupon.getState() == UserSystemCoupon.STATE_IN_USE) { type = 12; UserTaoLiJinGiveRecord giveRecord = userTaoLiJinGiveRecordService .selectByPrimaryKey(Long.parseLong(identify)); if (giveRecord == null || giveRecord.getState() == UserTaoLiJinGiveRecord.STATE_OVERDUE) { tips.add("哎呀，推广红包已失效了！"); } else if (giveRecord.getState() == UserTaoLiJinGiveRecord.STATE_RECEIVE) { tips.add("哎呀，推广红包已被领取了！"); } else { if (uid == null || uid <= 0) throw new TokenRecordException(1001, "用户未登录"); throw new TokenRecordException(1001, "温馨提示，[推广红包]需要登录后领取"); state = true; ThreeSale boss = threeSaleSerivce.getMyBoss(uid); if (boss != null) { tips.add("返利券奖励券，可用于“已到账”的返利订单，在返利的基础上再获得一定比例的返利；"); tips.add("成功领取后，请到“我的-福利中心”中查看。"); } else { UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid); if (userInfoExtra == null || StringUtil.isNullOrEmpty(userInfoExtra.getInviteCode())) { tips.add("确认领取后，你将成为赠送者的一级队员；"); tips.add("返利券奖励券，可用于“已到账”的返利订单，在返利的基础上再获得一定比例的返利；"); tips.add("成功领取后，请到“我的-福利中心”中查看。"); tips.add("推广红包，可分享爆款商品，让分享订单成单率更高；"); tips.add("成功领取后，请到“我的-推广红包”中查看。"); } else { tips.add("推广红包，可分享爆款商品，让分享订单成单率更高；"); tips.add("成功领取后，请到“我的-推广红包”中查看。"); } } } else { throw new TokenRecordException(1, "无对应类型"); } tokenVO.setTips(tips); tokenVO.setState(state); tokenVO.setType(tokenType.name()); tokenVO.setType(type); return tokenVO; } @Override public void receiveToken(String token, Long uid) throws TokenRecordException { if (uid == null || uid <= 0) throw new TokenRecordException(1, "用户未登录"); if (StringUtil.isNullOrEmpty(token)) throw new TokenRecordException(1, "口令不能为空"); TokenRecord rokenRecord = tokenRecordMapper.getByToken(token); if (rokenRecord == null || rokenRecord.getState() == 1) throw new TokenRecordException(1, "口令已失效"); String identify = rokenRecord.getIdentify(); if (StringUtil.isNullOrEmpty(identify)) throw new TokenRecordException(1, "口令标识不存在"); boolean receive = false; TokenTypeEnum tokenType = rokenRecord.getType(); if (tokenType == TokenTypeEnum.freeCoupon) { UserSystemCoupon userCoupon = userSystemCouponService.selectByPrimaryKey(Long.parseLong(identify)); if (userCoupon == null) throw new TokenRecordException(1, "该券不存在"); Boolean give = userCoupon.getGive(); if (give == null) give = false; if (userCoupon.getState() == UserSystemCoupon.STATE_OVERDUE) throw new TokenRecordException(1, "哎呀，这张免单券已失效了！"); if (userCoupon.getState() == UserSystemCoupon.STATE_END_USE) throw new TokenRecordException(1, "哎呀，这张免单券已被领取了！"); if (userCoupon.getState() == UserSystemCoupon.STATE_CAN_USE) throw new TokenRecordException(1, "口令已失效"); if (give && userCoupon.getState() == UserSystemCoupon.STATE_IN_USE) { try { userSystemCouponService.insertUserCoupon(uid, CouponTypeEnum.freeCoupon.name(), UserSystemCoupon.SOURCE_GIVE); } catch (Exception e) { LogHelper.errorDetailInfo(e); } // 领取成功 receive = true; } else { throw new TokenRecordException(1, "口令已失效"); } } else if (tokenType == TokenTypeEnum.rebatePercentCoupon) { UserSystemCoupon userCoupon = userSystemCouponService.selectByPrimaryKey(Long.parseLong(identify)); if (userCoupon == null) throw new TokenRecordException(1, "该券不存在"); Boolean give = userCoupon.getGive(); if (give == null) give = false; if (userCoupon.getState() == UserSystemCoupon.STATE_OVERDUE) throw new TokenRecordException(1, "哎呀，这张返利奖励券已失效了！"); if (userCoupon.getState() == UserSystemCoupon.STATE_END_USE) throw new TokenRecordException(1, "哎呀，这张返利奖励券已被领取了！"); if (userCoupon.getState() == UserSystemCoupon.STATE_CAN_USE) throw new TokenRecordException(1, "口令已失效"); if (give && userCoupon.getState() == UserSystemCoupon.STATE_IN_USE) { try { userSystemCouponService.insertUserCoupon(uid, CouponTypeEnum.rebatePercentCoupon.name(), UserSystemCoupon.SOURCE_GIVE); } catch (Exception e) { LogHelper.errorDetailInfo(e); } // 领取成功 receive = true; } else { throw new TokenRecordException(1, "口令已失效"); } } else if (tokenType == TokenTypeEnum.taoLiJin) { UserTaoLiJinGiveRecord giveRecord = userTaoLiJinGiveRecordService .selectByPrimaryKey(Long.parseLong(identify)); if (giveRecord == null || giveRecord.getState() == UserTaoLiJinGiveRecord.STATE_OVERDUE) { throw new TokenRecordException(1, "哎呀，哎呀，推广红包已失效了！"); } else if (giveRecord.getState() == UserTaoLiJinGiveRecord.STATE_RECEIVE) { throw new TokenRecordException(1, "哎呀，推广红包已被领取了！"); } else { } } else { throw new TokenRecordException(1, "无对应类型"); } if (receive) throw new TokenRecordException(1, "领取失败啦"); UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid); } } fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java
@@ -1899,7 +1899,7 @@ tokenRecord.setStartTime(nowDate); tokenRecord.setEndTime(DateUtil.plusDayDate(3, nowDate)); tokenRecord.setToken(token); tokenRecord.setState(state); tokenRecord.setState(0); tokenRecordService.insertSelective(tokenRecord); } catch (Exception e) { LogHelper.errorDetailInfo(e); @@ -1927,10 +1927,10 @@ String tips = "送给你一张返利奖励券快去领取吧，复制本条消息[&%s&]，打开[返利券]App领取，使用后可让返利加倍。\r\n" +"----------------------------\r\n" + "下载[返利券]App链接:http://t.cn/2H7AXAH\r\n" + "下载[返利券]App链接:%s\r\n" + "PS：口令将会24小时内失效，请及时领取。"; tips = String.format(tips, token); tips = String.format(tips, token, configService.get("app_down_link")); return tips; } fanli/src/main/java/com/yeshi/fanli/service/inter/tlj/UserTaoLiJinRecordService.java
@@ -96,6 +96,16 @@ */ public UserTaoLiJinRecord createShareTaoLiJin(Long uid, int totalNum, TaoBaoGoodsBrief goods) throws UserTaoLiJinRecordException; /** * 赠送推广红包 * @param uid * @param amount * @return * @throws UserTaoLiJinRecordException */ public String giveTaolijin(Long uid, BigDecimal amount) throws UserTaoLiJinRecordException; } fanli/src/main/java/com/yeshi/fanli/service/inter/user/TokenRecordService.java
@@ -1,6 +1,8 @@ package com.yeshi.fanli.service.inter.user; import com.yeshi.fanli.entity.bus.user.TokenRecord; import com.yeshi.fanli.exception.user.TokenRecordException; import com.yeshi.fanli.vo.msg.TokenVO; public interface TokenRecordService { @@ -14,4 +16,22 @@ */ public TokenRecord getNearByTypeAndIdentify(String type, String identify); /** * 赠送口令解析 * @param token * @param uid * @return * @throws TokenRecordException */ public TokenVO discernToken(String token, Long uid) throws TokenRecordException; /** * 口令领取 * @param token * @param uid * @throws TokenRecordException */ public void receiveToken(String token, Long uid) throws TokenRecordException; } fanli/src/main/java/com/yeshi/fanli/vo/msg/TokenVO.java
@@ -7,7 +7,7 @@ public class TokenVO { @Expose // id private Long id; private String token; @Expose // 昵称 private String nickName; @@ -15,8 +15,8 @@ @Expose // 头像 private String portrait; @Expose // 类型 private String type; @Expose // 类型 1标题搜索 2链接搜索 private Integer type; @Expose // 数量、面额 private Integer amount; @@ -44,11 +44,12 @@ this.portrait = portrait; } public String getType() { public Integer getType() { return type; } public void setType(String type) { public void setType(Integer type) { this.type = type; } @@ -68,12 +69,12 @@ this.tips = tips; } public Long getId() { return id; public String getToken() { return token; } public void setId(Long id) { this.id = id; public void setToken(String token) { this.token = token; } public Boolean getState() {
