yujian
2019-06-25 b7b8f2a4fe9059ef7b5470a68bb1b34787bc92b2
fanli/src/main/java/com/yeshi/fanli/controller/client/v1/ShareController.java
@@ -22,6 +22,7 @@
import com.yeshi.fanli.entity.bus.share.UserShareGoodsGroup;
import com.yeshi.fanli.entity.bus.share.UserShareGoodsHistory;
import com.yeshi.fanli.entity.bus.share.UserShareGoodsRecord;
import com.yeshi.fanli.entity.bus.tlj.UserTaoLiJinRecord;
import com.yeshi.fanli.entity.bus.user.UserExtraTaoBaoInfo;
import com.yeshi.fanli.entity.bus.user.UserInfo;
import com.yeshi.fanli.entity.bus.user.UserInfoExtra;
@@ -37,6 +38,7 @@
import com.yeshi.fanli.exception.goods.ShareGoodsTextTemplateException;
import com.yeshi.fanli.exception.share.UserShareGoodsRecordException;
import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;
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.config.SystemClientParamsService;
@@ -47,6 +49,9 @@
import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;
import com.yeshi.fanli.service.inter.monitor.BusinessEmergent110Service;
import com.yeshi.fanli.service.inter.monitor.MonitorService;
import com.yeshi.fanli.service.inter.tlj.ConfigTaoLiJinService;
import com.yeshi.fanli.service.inter.tlj.GoodsTaoLiJinRateService;
import com.yeshi.fanli.service.inter.tlj.UserTaoLiJinRecordService;
import com.yeshi.fanli.service.inter.user.SpreadUserImgService;
import com.yeshi.fanli.service.inter.user.UserExtraTaoBaoInfoService;
import com.yeshi.fanli.service.inter.user.UserInfoExtraService;
@@ -126,6 +131,16 @@
   @Resource
   private BusinessEmergent110Service businessEmergent110Service;
   @Resource
   private ConfigTaoLiJinService configTaoLiJinService;
   @Resource
   private GoodsTaoLiJinRateService goodsTaoLiJinRateService;
   @Resource
   private UserTaoLiJinRecordService userTaoLiJinRecordService;
   // 获取商品分享链接
   @RequestMapping(value = "getGoodsShareUrl")
@@ -144,8 +159,9 @@
    * @param out
    */
   @RequestMapping(value = "gettaobaosharelink")
   public void getTaobaoShareLink(AcceptData acceptData, Long uid, Long auctionId, HttpServletRequest request,
         PrintWriter out) {
   public void getTaobaoShareLink(AcceptData acceptData, Long uid, Long auctionId, String source, Integer totalNum,
         HttpServletRequest request, PrintWriter out) {
      if (uid == null || uid <= 0) {
         out.print(JsonUtil.loadFalseResult(1, "用户ID不能为空"));
         return;
@@ -168,13 +184,56 @@
         if (extraInfo != null && extraInfo.getRelationId() != null && extraInfo.getRelationValid() != null
               && extraInfo.getRelationValid() == true)
            relationId = extraInfo.getRelationId();
         TaoBaoLink taoBaoLink = shareGoodsService.getTaoBaoLinkForShare(uid, auctionId, relationId);
         TaoBaoLink taoBaoLink  = new TaoBaoLink();
         if (source != null && "taolijin".equals(source)) {
            taoBaoLink = shareGoodsService.getTaoLiJinLinkForShare(uid, auctionId, relationId);
         } else {
            taoBaoLink = shareGoodsService.getTaoBaoLinkForShare(uid, auctionId, relationId);
         }
         JSONObject data = new JSONObject();
         String url = String.format("http://%s%s?uid=%s&id=%s&appType=flq", configService.getH5Host(),
               Constant.systemCommonConfig.getShareGoodsPagePath(), AESUtil.encrypt(uid + "", Constant.UIDAESKEY),
               auctionId + "");
         if (source != null && "taolijin".equals(source)) {
            BigDecimal spreadMoney = goodsTaoLiJinRateService.getGoodsSpreadMoney(taoBaoLink.getGoods());
            // 推广红包 不能小于1
            if (spreadMoney.compareTo(new BigDecimal(1)) < 0) {
               out.print(JsonUtil.loadFalseResult(1, "该商品淘礼金不足1元"));
               return;
            }
            data.put("spreadMoney", "淘礼金 ¥" + spreadMoney.toString());
            String taoLiJinLink = null;
            try {
               UserTaoLiJinRecord record = userTaoLiJinRecordService.createShareTaoLiJin(uid, totalNum, taoBaoLink.getGoods());
               taoLiJinLink = record.getSendUrl();
               data.put("tljId", record.getId());
               data.put("surplusMoney", record.getSurplusMoney());
            } catch (UserTaoLiJinRecordException e) {
               out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg()));
               return;
            }
            // 创建淘口令
            TaoBaoGoodsBrief goods = taoBaoLink.getGoods();
            if (!StringUtil.isNullOrEmpty(taoLiJinLink)) {// 通过立即推广方式获取淘口令成功
               String quanToken = TaoKeApiUtil.getTKToken(goods.getPictUrl(), goods.getTitle(), taoLiJinLink);
               if (!StringUtil.isNullOrEmpty(quanToken)) {
                  taoBaoLink.setTaoToken(quanToken);
               }
            } else if (!StringUtil.isNullOrEmpty(taoBaoLink.getClickUrl())) {
               String quanToken = TaoKeApiUtil.getTKToken(goods.getPictUrl(), goods.getTitle(), taoBaoLink.getClickUrl());
               if (!StringUtil.isNullOrEmpty(quanToken)) {
                  taoBaoLink.setTaoToken(quanToken);
               }
            }
         }
         String shortLink = HttpUtil.getShortLink(url);
         if (!StringUtil.isNullOrEmpty(shortLink)) {
            url = shortLink;
@@ -190,6 +249,7 @@
         // 无券
         String shopType = taoBaoLink.getGoods().getUserType() == 0 ? "淘宝价" : "天猫价";
         if (StringUtil.isNullOrEmpty(taoBaoLink.getGoods().getCouponInfo())) {
            String text = shareGoodsTextTemplateService.getCommonTemplate(uid);
            if (StringUtil.isNullOrEmpty(text))
@@ -198,16 +258,33 @@
                  MoneyBigDecimalUtil.getWithNoZera(taoBaoLink.getGoods().getZkPrice()) + "");
         } else// 有券
         {
            String text = shareGoodsTextTemplateService.geteCouponTemplate(uid);
            if (StringUtil.isNullOrEmpty(text))
               text = configService.get("goods_share_text_coupon");
            shareText = text.replace("{标题}", taoBaoLink.getGoods().getTitle())
                  .replace("{商品原价}", MoneyBigDecimalUtil.getWithNoZera(taoBaoLink.getGoods().getZkPrice()) + "")
                  .replace("{优惠券面额}",
                        MoneyBigDecimalUtil.getWithNoZera(taoBaoLink.getGoods().getCouponAmount()).toString())
                  .replace("{优惠券价}", TaoBaoUtil.getAfterUseCouplePrice(taoBaoLink.getGoods()) + "");
            if (source != null && "taolijin".equals(source)) {
               String text = shareGoodsTextTemplateService.getTaoLiJinTemplate(uid);
               if (StringUtil.isNullOrEmpty(text))
                  text = configTaoLiJinService.getValueByKey("goods_share_text");
               shareText = text.replace("{标题}", taoBaoLink.getGoods().getTitle())
                     .replace("{商品原价}", MoneyBigDecimalUtil.getWithNoZera(taoBaoLink.getGoods().getZkPrice()) + "")
                     .replace("{优惠券面额}",
                           MoneyBigDecimalUtil.getWithNoZera(taoBaoLink.getGoods().getCouponAmount()).toString())
                     .replace("{淘礼金面额}", MoneyBigDecimalUtil.getWithNoZera(goodsTaoLiJinRateService.getGoodsSpreadMoney(taoBaoLink.getGoods())).toString())
                     .replace("{优惠券价}", TaoBaoUtil.getAfterUseCouplePrice(taoBaoLink.getGoods()) + "");
            } else {
               String text = shareGoodsTextTemplateService.geteCouponTemplate(uid);
               if (StringUtil.isNullOrEmpty(text))
                  text = configService.get("goods_share_text_coupon");
               shareText = text.replace("{标题}", taoBaoLink.getGoods().getTitle())
                     .replace("{商品原价}", MoneyBigDecimalUtil.getWithNoZera(taoBaoLink.getGoods().getZkPrice()) + "")
                     .replace("{优惠券面额}",
                           MoneyBigDecimalUtil.getWithNoZera(taoBaoLink.getGoods().getCouponAmount()).toString())
                     .replace("{优惠券价}", TaoBaoUtil.getAfterUseCouplePrice(taoBaoLink.getGoods()) + "");
            }
         }
         shareText = shareText.replace("{店铺类型}", shopType)
               .replace("{月销量}", TaoBaoUtil.getSaleCount(taoBaoLink.getGoods().getBiz30day()))
               .replace("{领券短链}", shortLink).replace("{淘口令}", taoBaoLink.getTaoToken());
@@ -241,6 +318,7 @@
         }
         out.print(JsonUtil.loadTrueResult(data));
         final TaoBaoLink taobaoLink = taoBaoLink;
         // 异步操作
         com.yeshi.fanli.util.ThreadUtil.run(new Runnable() {
            @Override
@@ -251,13 +329,13 @@
               history.setHongbao(shareMoney);
               history.setCreateTime(new Date());
               history.setGoodsType(UserShareGoodsHistory.TYPE_TAOBAO);
               history.setTkCode(taoBaoLink.getTaoToken());
               history.setLink(taoBaoLink.getClickUrl());
               history.setQuanLink(taoBaoLink.getCouponLink());
               history.setGoodsId(taoBaoLink.getGoods().getAuctionId());
               history.setPostPicture(taoBaoLink.getGoods().getPictUrl());
               history.setTkCode(taobaoLink.getTaoToken());
               history.setLink(taobaoLink.getClickUrl());
               history.setQuanLink(taobaoLink.getCouponLink());
               history.setGoodsId(taobaoLink.getGoods().getAuctionId());
               history.setPostPicture(taobaoLink.getGoods().getPictUrl());
               List<String> imgList = taoBaoLink.getGoods().getImgList();
               List<String> imgList = taobaoLink.getGoods().getImgList();
               if (imgList == null) {
                  imgList = new ArrayList<>();
               }
@@ -267,6 +345,7 @@
         });
         return;
      } catch (ShareGoodsException e) {
         LogHelper.errorDetailInfo(e, "分享出错:uid:"+uid+"auctionId:"+auctionId, "");
         // 分享出错报警
         try {
            monitorService.addClientAPIMonitor(MonitorFactory.createClientAPI(request, e.getCode(), 0, "分享出错"));
@@ -454,7 +533,7 @@
    * @param out
    */
   @RequestMapping(value = "viewShareTextTemplate", method = RequestMethod.POST)
   public void preViewShareTextTemplate(AcceptData acceptData, Long uid, String template, Long goodsId,
   public void preViewShareTextTemplate(AcceptData acceptData, Long uid, String template, Long goodsId, Long tljId,
         Boolean hasCoupon, PrintWriter out) {
      if (uid == null) {
         out.print(JsonUtil.loadFalseResult(1, "用户未登录"));
@@ -478,20 +557,28 @@
         out.print(JsonUtil.loadFalseResult(4, "商品已下架"));
         return;
      }
      if (StringUtil.isNullOrEmpty(template))
         template = getShareTemplate(uid, hasCoupon);
         template = getShareTemplate(uid, hasCoupon, tljId);
      // 校验券模板是否正确
      if (hasCoupon) {
         // 有券商品
         try {
            shareGoodsTextTemplateService.isCouponTemplateRight(template);
         } catch (ShareGoodsTextTemplateException e) {
            out.print(JsonUtil.loadFalseResult(5, e.getMsg()));
            return;
         if (tljId != null) {
            try {
               shareGoodsTextTemplateService.isTaoLiJinTemplateRight(template);
            } catch (ShareGoodsTextTemplateException e) {
               out.print(JsonUtil.loadFalseResult(5, e.getMsg()));
               return;
            }
         } else {
            try {
               shareGoodsTextTemplateService.isCouponTemplateRight(template);
            } catch (ShareGoodsTextTemplateException e) {
               out.print(JsonUtil.loadFalseResult(5, e.getMsg()));
               return;
            }
         }
      } else {
         // 普通商品
         try {
@@ -502,12 +589,25 @@
         }
      }
      String url = null;
      if (tljId != null) {
         UserTaoLiJinRecord userTaoLiJinRecord = userTaoLiJinRecordService.selectByPrimaryKey(tljId);
         if (userTaoLiJinRecord == null) {
            out.print(JsonUtil.loadFalseResult(5, "淘礼金领取链接不存在"));
            return;
         }
         url = userTaoLiJinRecord.getSendUrl();
      } else {
         url = String.format("http://%s%s?uid=%s&id=%s&appType=flq", configService.getH5Host(),
               Constant.systemCommonConfig.getShareGoodsPagePath(), AESUtil.encrypt(uid + "", Constant.UIDAESKEY),
               goods.getAuctionId() + "");
      }
      String shortLink = HttpUtil.getShortLink(url);
      // 查询是否有分享
      UserShareGoodsHistory userShareHistory = shareGoodsService.getShareGoodsHistory(uid, goods.getAuctionId());
      String url = String.format("http://%s%s?uid=%s&id=%s&appType=flq", configService.getH5Host(),
            Constant.systemCommonConfig.getShareGoodsPagePath(), AESUtil.encrypt(uid + "", Constant.UIDAESKEY),
            goods.getAuctionId() + "");
      String shortLink = HttpUtil.getShortLink(url);
      String token = "";
      if (userShareHistory != null) {
         token = userShareHistory.getTkCode();
@@ -526,7 +626,7 @@
                        : goodsLink.getCouponLink());
      }
      String content = shareGoodsTextTemplateService.createContentByTemplate(template, uid, goods, token, shortLink,
            hasCoupon);
            hasCoupon, tljId);
      JSONObject data = new JSONObject();
      data.put("content", content);
      out.print(JsonUtil.loadTrueResult(data));
@@ -542,7 +642,7 @@
    * @param out
    */
   @RequestMapping(value = "saveShareTextTemplate", method = RequestMethod.POST)
   public void saveShareTextTemplate(AcceptData acceptData, Long uid, Boolean hasCoupon, String template,
   public void saveShareTextTemplate(AcceptData acceptData, Long uid, Long tljId, Boolean hasCoupon, String template,
         PrintWriter out) {
      if (StringUtil.isNullOrEmpty(template)) {
         out.print(JsonUtil.loadFalseResult(1, "分享模板为空"));
@@ -551,15 +651,25 @@
      // 校验券模板是否正确
      if (hasCoupon) {
         // 有券商品
         try {
            shareGoodsTextTemplateService.isCouponTemplateRight(template);
            shareGoodsTextTemplateService.saveCouponTemplate(uid, template);
            out.print(JsonUtil.loadTrueResult(""));
         } catch (ShareGoodsTextTemplateException e) {
            out.print(JsonUtil.loadFalseResult(5, e.getMsg()));
            return;
         if (tljId != null) {
            try {
               shareGoodsTextTemplateService.isTaoLiJinTemplateRight(template);
               shareGoodsTextTemplateService.saveTaoLiJinTemplate(uid, template);
               out.print(JsonUtil.loadTrueResult(""));
            } catch (ShareGoodsTextTemplateException e) {
               out.print(JsonUtil.loadFalseResult(5, e.getMsg()));
               return;
            }
         } else {
            try {
               shareGoodsTextTemplateService.isCouponTemplateRight(template);
               shareGoodsTextTemplateService.saveCouponTemplate(uid, template);
               out.print(JsonUtil.loadTrueResult(""));
            } catch (ShareGoodsTextTemplateException e) {
               out.print(JsonUtil.loadFalseResult(5, e.getMsg()));
               return;
            }
         }
      } else {
         // 普通商品
         try {
@@ -584,32 +694,46 @@
    * @param out
    */
   @RequestMapping(value = "resetShareTextTemplate", method = RequestMethod.POST)
   public void resetShareTextTemplate(AcceptData acceptData, Long uid, Long goodsId, Boolean hasCoupon,
   public void resetShareTextTemplate(AcceptData acceptData, Long uid, Long goodsId, Long tljId, Boolean hasCoupon,
         PrintWriter out) {
      if (uid == null) {
         out.print(JsonUtil.loadFalseResult(1, "用户未登录"));
         return;
      }
      if (hasCoupon) {
         shareGoodsTextTemplateService.resetCouponTemplate(uid);
         if (tljId != null) {
            shareGoodsTextTemplateService.resetTaoLijinTemplate(uid);
         } else {
            shareGoodsTextTemplateService.resetCouponTemplate(uid);
         }
      } else {
         shareGoodsTextTemplateService.resetCommonTemplate(uid);
      }
      if (goodsId != null) {
         preViewShareTextTemplate(acceptData, uid, null, goodsId, hasCoupon, out);
         preViewShareTextTemplate(acceptData, uid, null, goodsId, tljId, hasCoupon, out);
         return;
      }
      out.print(JsonUtil.loadTrueResult(""));
   }
   private String getShareTemplate(Long uid, boolean hasCoupon) {
   private String getShareTemplate(Long uid, boolean hasCoupon, Long tljId) {
      if (hasCoupon) {
         String template = shareGoodsTextTemplateService.geteCouponTemplate(uid);
         if (StringUtil.isNullOrEmpty(template))
            template = configService.get("goods_share_text_coupon");
         return template;
         if (tljId != null) {
            String template = shareGoodsTextTemplateService.getTaoLiJinTemplate(uid);
            if (StringUtil.isNullOrEmpty(template))
               template = configTaoLiJinService.getValueByKey("goods_share_text");
            return template;
         } else {
            String template = shareGoodsTextTemplateService.geteCouponTemplate(uid);
            if (StringUtil.isNullOrEmpty(template))
               template = configService.get("goods_share_text_coupon");
            return template;
         }
      } else {
         String template = shareGoodsTextTemplateService.getCommonTemplate(uid);
         if (StringUtil.isNullOrEmpty(template))
@@ -627,13 +751,19 @@
    * @param out
    */
   @RequestMapping(value = "getShareTextTemplate", method = RequestMethod.POST)
   public void getShareTextTemplate(AcceptData acceptData, Long uid, Boolean hasCoupon, PrintWriter out) {
   public void getShareTextTemplate(AcceptData acceptData, Long uid, Long tljId, Boolean hasCoupon, PrintWriter out) {
      if (uid == null) {
         out.print(JsonUtil.loadFalseResult(1, "用户未登录"));
         return;
      }
      if (hasCoupon == null) {
         out.print(JsonUtil.loadFalseResult(1, "是否有券字段为空"));
         return;
      }
      JSONObject data = new JSONObject();
      data.put("template", getShareTemplate(uid, hasCoupon));
      data.put("template", getShareTemplate(uid, hasCoupon, tljId));
      out.print(JsonUtil.loadTrueResult(data));
   }
@@ -644,8 +774,12 @@
    * @param out
    */
   @RequestMapping(value = "getShareTextTemplateRules", method = RequestMethod.POST)
   public void getShareTextTemplateRules(AcceptData acceptData, PrintWriter out) {
      out.print(JsonUtil.loadTrueResult(configService.get("share_goods_template_rules")));
   public void getShareTextTemplateRules(AcceptData acceptData, Long tljId, PrintWriter out) {
      if (tljId != null) {
         out.print(JsonUtil.loadTrueResult( configTaoLiJinService.getValueByKey("share_goods_rules")));
      } else {
         out.print(JsonUtil.loadTrueResult(configService.get("share_goods_template_rules")));
      }
   }
   /**
@@ -719,7 +853,7 @@
            ClientTextStyleVO desc = dynamicInfo.getDesc();
            String content = desc.getContent();
            int index = content.indexOf("¥");
            data.put("shareMoney", new BigDecimal(content.substring(index + 1, content.length())));
            data.put("shareMoney", new BigDecimal(content.substring(index + 1, content.length())).toString());
            // 分享提醒
            data.put("notifyDesc", configService.get("goods_share_notify"));