yujian
2019-12-12 8c04d27e5cebb7e654c208533e9567c4df2c8acc
fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserShareGoodsRecordServiceImpl.java
@@ -92,11 +92,9 @@
   @Resource
   private UserGoodsStorageService userGoodsStorageService;
   @Resource
   private IntegralGetService integralGetService;
   @Override
   public int insert(UserShareGoodsRecord record) {
@@ -127,10 +125,10 @@
   public long countQueryByUid(Long uid, String source) {
      return userShareGoodsRecordMapper.countQueryByUid(uid, source);
   }
   @Override
   public List<UserShareGoodsGroup> listByRecordId(Long shareId) {
      return  userShareGoodsGroupService.listByRecordId(shareId);
      return userShareGoodsGroupService.listByRecordId(shareId);
   }
   @Override
@@ -211,12 +209,12 @@
                     }
                  }
               }
               String shareType = shareRecord.getShareType();
               if (StringUtil.isNullOrEmpty(shareType)) {
                  shareRecord.setShareType(UserShareGoodsRecord.SHARETYPE_SINGLE);
               }
               BigDecimal totalMoney = shareRecord.getTotalMoney();
               if (totalMoney == null) {
                  shareRecord.setTotalMoney(new BigDecimal(0));
@@ -228,7 +226,7 @@
               if (StringUtil.isNullOrEmpty(shareType)) {
                  shareRecord.setShareType(UserShareGoodsRecord.SHARETYPE_SINGLE);
               }
               BigDecimal totalMoney = shareRecord.getTotalMoney();
               if (totalMoney == null) {
                  shareRecord.setTotalMoney(new BigDecimal(0));
@@ -241,8 +239,7 @@
   }
   @Override
   public void saveSingleShareRecord(Long uid, Long goodsId, Integer goodsType)
         throws UserShareGoodsRecordException {
   public void saveSingleShareRecord(Long uid, Long goodsId, Integer goodsType) throws UserShareGoodsRecordException {
      if (goodsId == null) {
         throw new UserShareGoodsRecordException(1, "分享商品不能为空");
      }
@@ -426,9 +423,12 @@
   /**
    * 生成分享图
    * 
    * @param uid       用户id
    * @param shareId   分享记录id
    * @param source    来源
    * @param uid
    *            用户id
    * @param shareId
    *            分享记录id
    * @param source
    *            来源
    * @param listGoods
    * @return
    * @throws UserShareGoodsRecordException
@@ -661,7 +661,8 @@
   }
   @Override
   public ShareGoodsRecordDTO addRecordGoodsDetail(Long uid, Long auctionId, Integer goodsType, boolean isTaolijin) throws UserShareGoodsRecordException {
   public ShareGoodsRecordDTO addRecordGoodsDetail(Long uid, Long auctionId, Integer goodsType, boolean isTaolijin)
         throws UserShareGoodsRecordException {
      if (auctionId == null || uid == null || uid <= 0) {
         throw new UserShareGoodsRecordException(1, "传递参数不正确");
      }
@@ -674,7 +675,7 @@
      recordDTO.setSource(ShareSourceTypeEnum.goodsDetail);
      // 分享id
      String key = StringUtil.Md5(uid + "#GoodsDetail#" + auctionId + "#Type#"+ goodsType);
      String key = StringUtil.Md5(uid + "#GoodsDetail#" + auctionId + "#Type#" + goodsType);
      redisManager.cacheCommonString(key, JsonUtil.getSimpleGson().toJson(recordDTO), 60 * 20);
      recordDTO.setRedisKey(key);
@@ -682,8 +683,8 @@
   }
   @Override
   public ShareGoodsRecordDTO addRecordGoodsStorage(Long uid, List<TaoBaoGoodsBrief> listGoodsBrief, List<Long> listStorageID)
         throws UserShareGoodsRecordException {
   public ShareGoodsRecordDTO addRecordGoodsStorage(Long uid, List<TaoBaoGoodsBrief> listGoodsBrief,
         List<Long> listStorageID) throws UserShareGoodsRecordException {
      if (uid == null || uid <= 0 || listGoodsBrief == null || listGoodsBrief.size() == 0) {
         throw new UserShareGoodsRecordException(1, "传递参数不正确");
      }
@@ -697,11 +698,10 @@
      userShareGoodsRecordMapper.insertSelective(record);
      List<CommonGoods> listCommonGoods = new ArrayList<CommonGoods>();
      for (TaoBaoGoodsBrief goodsBrief: listGoodsBrief) {
      for (TaoBaoGoodsBrief goodsBrief : listGoodsBrief) {
         listCommonGoods.add(CommonGoodsFactory.create(goodsBrief));
      }
      Long id = record.getId();
      // 分享链接
      String shareUrl = getShareUrl(record);
@@ -725,10 +725,10 @@
      return recordDTO;
   }
   @Override
   public ShareGoodsRecordDTO addRecordGoodsStorageV2(Long uid, List<CommonGoods> listGoods, List<Long> listStorageID)
         throws UserShareGoodsRecordException {
   public ShareGoodsRecordDTO addRecordGoodsStorageV2(Long uid, List<CommonGoods> listGoods, List<Long> listStorageID,
         boolean needDrawPicture) throws UserShareGoodsRecordException {
      if (uid == null || uid <= 0 || listGoods == null || listGoods.size() == 0) {
         throw new UserShareGoodsRecordException(1, "传递参数不正确");
      }
@@ -745,7 +745,6 @@
      // 分享链接
      String shareUrl = getShareUrlV2(record);
      // 分享二维码链接
      FileUploadResult uploadResult = drawingSharePicture(uid, id, shareUrl, listGoods);
      ShareGoodsRecordDTO recordDTO = new ShareGoodsRecordDTO();
      recordDTO.setUid(uid);
@@ -753,7 +752,10 @@
      recordDTO.setShareUrl(shareUrl);
      recordDTO.setListId(listStorageID);
      recordDTO.setListGoods(listGoods);
      recordDTO.setSharePictureUrl(uploadResult.getUrl());
      if (needDrawPicture) {
         FileUploadResult uploadResult = drawingSharePicture(uid, id, shareUrl, listGoods);
         recordDTO.setSharePictureUrl(uploadResult.getUrl());
      }
      recordDTO.setSource(ShareSourceTypeEnum.storage);
      // 缓存分享商品信息
@@ -783,10 +785,10 @@
      userShareGoodsRecordMapper.insertSelective(record);
      List<CommonGoods> listCommonGoods = new ArrayList<CommonGoods>();
      for (TaoBaoGoodsBrief goodsBrief: listGoodsBrief) {
      for (TaoBaoGoodsBrief goodsBrief : listGoodsBrief) {
         listCommonGoods.add(CommonGoodsFactory.create(goodsBrief));
      }
      Long id = record.getId();
      // 分享链接
      String shareUrl = getShareUrl(record);
@@ -826,10 +828,10 @@
      userShareGoodsRecordMapper.insertSelective(record);
      List<CommonGoods> listCommonGoods = new ArrayList<CommonGoods>();
      for (TaoBaoGoodsBrief goodsBrief: listGoodsBrief) {
      for (TaoBaoGoodsBrief goodsBrief : listGoodsBrief) {
         listCommonGoods.add(CommonGoodsFactory.create(goodsBrief));
      }
      Long id = record.getId();
      // 分享链接
      String shareUrl = getShareUrl(record);
@@ -872,7 +874,7 @@
      ShareSourceTypeEnum source = recordDTO.getSource();
      if (ShareSourceTypeEnum.goodsDetail.equals(source)) {
         // 商品详情分享
         saveSingleShareRecord(recordDTO.getUid(), recordDTO.getAuctionId(),recordDTO.getGoodsType());
         saveSingleShareRecord(recordDTO.getUid(), recordDTO.getAuctionId(), recordDTO.getGoodsType());
      } else if (ShareSourceTypeEnum.activity.equals(source)) {
         // 动态分享
         UserShareGoodsRecord shareRecord = new UserShareGoodsRecord();
@@ -882,16 +884,16 @@
         updateByPrimaryKeySelective(shareRecord);
         List<CommonGoods> listGoods = recordDTO.getListGoods();
         if (listGoods != null && listGoods.size() > 1)
         if (listGoods != null && listGoods.size() > 1)
            singleGoods = false;
         // 保存商品信息
         multipleGoodsShareRecord(shareId, recordDTO.getListGoods());
      } else if (ShareSourceTypeEnum.storage.equals(source)) {
         // 分享库分享
         singleGoods = false;
         UserShareGoodsRecord shareRecord = new UserShareGoodsRecord();
         shareRecord.setId(shareId);
         shareRecord.setShareState(1);
@@ -900,7 +902,7 @@
         // 保存商品信息
         multipleGoodsShareRecord(shareId, recordDTO.getListGoods());
         // 更新选品库商品状态 为已分享
         List<Long> listId = recordDTO.getListId();
         if (listId != null && listId.size() > 0) {
@@ -912,10 +914,10 @@
            }
         }
      }
      // 清理缓存
      redisManager.removeCommonString(shareKey);
      if (singleGoods) {
         if (taolijin) {
            integralGetService.addShareTLJGoods(uid);
@@ -947,8 +949,7 @@
      }
      return url;
   }
   /**
    * 分享链接
    * 
@@ -959,8 +960,8 @@
      Long uid = shareRecord.getUid();
      Long shareId = shareRecord.getId();
      String url = String.format("http://%s/share_mushGoods_1.6.0.html?uid=%s&shareId=%s",
            configService.getH5Host(), AESUtil.encrypt(uid + "", Constant.UIDAESKEY), shareId + "");
      String url = String.format("http://%s/share_mushGoods_1.6.0.html?uid=%s&shareId=%s", configService.getH5Host(),
            AESUtil.encrypt(uid + "", Constant.UIDAESKEY), shareId + "");
      String shortLink = HttpUtil.getShortLink(url);
      if (!StringUtil.isNullOrEmpty(shortLink)) {
@@ -972,9 +973,12 @@
   /**
    * 生成分享图
    * 
    * @param uid       用户id
    * @param shareId   分享记录id
    * @param source    来源
    * @param uid
    *            用户id
    * @param shareId
    *            分享记录id
    * @param source
    *            来源
    * @param listGoods
    * @return
    * @throws UserShareGoodsRecordException