替换原来老的资金详情

admin

2018-12-25 4cb15e222cd7d099d533ccbeb7f9a8cd99bf180c

 fanli/src/main/java/com/yeshi/fanli/service/impl/activity/ActivityServiceImpl.java

@@ -8,6 +8,7 @@


import javax.annotation.Resource;



import net.sf.json.JSONArray;

import net.sf.json.JSONObject;



import org.springframework.cache.annotation.Cacheable;

@@ -97,10 +98,10 @@


   @Resource

   private TaoBaoGoodsUpdateService taoBaoGoodsUpdateService;

	


   @Resource

   private UserShareGoodsRecordService userShareGoodsRecordService;

	


   @Resource

   private CommonGoodsService commonGoodsService;



@@ -120,133 +121,160 @@
   }



   @Override

   public ActivityShareResult shareActivityGoods(Long uid, Long activityId) throws ActivityException,UserShareGoodsRecordException {

		
   public ActivityShareResult shareActivityGoods(Long uid, Long activityId)

         throws ActivityException, UserShareGoodsRecordException {



      RecommendActivity activity = recommendActivityMapper.selectByPrimaryKey(activityId);

		


      if (activity == null)

         throw new ActivityException(2, "动态不存在");

		


      if (activity.getType() != RecommendActivity.TYPE_SHARE_GOODS)

         throw new ActivityException(3, "不属于分享商品动态");

	


      ActivityShareResult result = new ActivityShareResult();

		


      String title = activity.getTitle().replace("<br>", "/n").replace("<p>", "").replace("</p>", "");

      if (title != null && title.trim().endsWith("/n"))

         title = title.trim().substring(0, title.trim().length() - 2);

      result.setTitle(title);

      List<FileUploadResult> imgList = new ArrayList<>();

		


      List<TaoBaoGoodsBrief> listGoodsBrief = new ArrayList<TaoBaoGoodsBrief>();

		


      if (activity.getGoodsList() != null) {

			


         activity.getGoodsList().stream().parallel().forEach(goodsActivity -> {

				


            try {

               TaoBaoGoodsBrief goodsBrief = 
                     redisManager.getTaoBaoGoodsBrief(Long.parseLong(goodsActivity.getAuctionId()));

               TaoBaoGoodsBrief goodsBrief = redisManager

                     .getTaoBaoGoodsBrief(Long.parseLong(goodsActivity.getAuctionId()));

               listGoodsBrief.add(goodsBrief);

            } catch (TaobaoGoodsDownException e) {

					
               CommonGoods commonGoods= commonGoodsService.getCommonGoodsByGoodsIdAndGoodsType(Long.parseLong(goodsActivity.getAuctionId()),

                     CommonGoods.GOODS_TYPE_TB);



               CommonGoods commonGoods = commonGoodsService.getCommonGoodsByGoodsIdAndGoodsType(

                     Long.parseLong(goodsActivity.getAuctionId()), CommonGoods.GOODS_TYPE_TB);

               if (commonGoods != null) {

                  TaoBaoGoodsBrief goodsBrief =  TaoBaoUtil.convert(commonGoods);

                  TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.convert(commonGoods);

                  goodsBrief.setState(1);

                  listGoodsBrief.add(goodsBrief);

               }

					


               try {

                  LogHelper.errorDetailInfo(e, "分享商品出错-商品ID:" + goodsActivity.getAuctionId(),   "--");

                  LogHelper.errorDetailInfo(e, "分享商品出错-商品ID:" + goodsActivity.getAuctionId(), "--");

               } catch (Exception e1) {

                  e1.printStackTrace();

               }

            }

         });

      }

		


      if (listGoodsBrief.size() < 1) {

         throw new ActivityException(1, "商品下架");

      }

		
      Map<String,Object> map =  userShareGoodsRecordService.save(uid, ShareSourceTypeEnum.activity, title, listGoodsBrief);



      Map<String, Object> map = userShareGoodsRecordService.save(uid, ShareSourceTypeEnum.activity, title,

            listGoodsBrief);

      imgList.add((FileUploadResult) map.get("loadResult"));

      result.setImgList(imgList);

		


      return result;

   }

	
	


   @Override

   public JSONObject shareGoodsV2(Long uid, Long activityId) throws ActivityException,UserShareGoodsRecordException {

		
   public JSONObject shareGoodsV2(Long uid, Long activityId) throws ActivityException, UserShareGoodsRecordException {



      RecommendActivity activity = recommendActivityMapper.selectByPrimaryKey(activityId);

		


      if (activity == null)

         throw new ActivityException(2, "动态不存在");

		


      if (activity.getType() != RecommendActivity.TYPE_SHARE_GOODS)

         throw new ActivityException(3, "不属于分享商品动态");

	


      ActivityShareResult result = new ActivityShareResult();

		


      String title = activity.getTitle().replace("<br>", "/n").replace("<p>", "").replace("</p>", "");

      if (title != null && title.trim().endsWith("/n"))

         title = title.trim().substring(0, title.trim().length() - 2);

		


      result.setTitle(title);

		


      List<TaoBaoGoodsBrief> listGoodsBrief = new ArrayList<TaoBaoGoodsBrief>();

		


      if (activity.getGoodsList() != null) {

         activity.getGoodsList().stream().parallel().forEach(goodsActivity -> {

            try {

               TaoBaoGoodsBrief goodsBrief = 
                     redisManager.getTaoBaoGoodsBrief(Long.parseLong(goodsActivity.getAuctionId()));

               TaoBaoGoodsBrief goodsBrief = redisManager

                     .getTaoBaoGoodsBrief(Long.parseLong(goodsActivity.getAuctionId()));

               listGoodsBrief.add(goodsBrief);

					


            } catch (TaobaoGoodsDownException e) {

					
               CommonGoods commonGoods= commonGoodsService.getCommonGoodsByGoodsIdAndGoodsType(Long.parseLong(goodsActivity.getAuctionId()),

                     CommonGoods.GOODS_TYPE_TB);



               CommonGoods commonGoods = commonGoodsService.getCommonGoodsByGoodsIdAndGoodsType(

                     Long.parseLong(goodsActivity.getAuctionId()), CommonGoods.GOODS_TYPE_TB);

               if (commonGoods != null) {

                  TaoBaoGoodsBrief goodsBrief =  TaoBaoUtil.convert(commonGoods);

                  TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.convert(commonGoods);

                  goodsBrief.setState(1);

                  listGoodsBrief.add(goodsBrief);

               }

					


               try {

                  LogHelper.errorDetailInfo(e, "分享商品出错-商品ID:" + goodsActivity.getAuctionId(),   "--");

                  LogHelper.errorDetailInfo(e, "分享商品出错-商品ID:" + goodsActivity.getAuctionId(), "--");

               } catch (Exception e1) {

                  e1.printStackTrace();

               }

            }

         });

      }

		


      if (listGoodsBrief.size() < 1) {

         throw new ActivityException(1, "商品下架");

      }

		
      String revenue = "";



      String fontColor1 = "#000000";

      String fontColor2 = "#E5005C";

      JSONArray array = new JSONArray();



      JSONObject contentJson1 = new JSONObject();

      contentJson1.put("color", fontColor1);

      contentJson1.put("content", "预估分享奖金:");

      String shareMoney = "0";

      String revenue = "¥0";

      String totalGetMoney = activity.getTotalGetMoney();

      if (totalGetMoney != null && totalGetMoney.trim().length() > 0) {

         revenue = totalGetMoney.replace("预计分享奖金", listGoodsBrief.size()+"个商品预估分享奖金");

         String[] split = totalGetMoney.split("：");

         if (split != null) {

            revenue = split[1];

         }



         String[] splitMoney = totalGetMoney.split("¥");

         if (splitMoney != null) {

            shareMoney = splitMoney[1];

         }

      }

		


      JSONObject contentJson2 = new JSONObject();

      contentJson2.put("color", fontColor2);

      contentJson2.put("content", revenue);



      array.add(contentJson1);

      array.add(contentJson2);



      JSONObject data = new JSONObject();

		
      Map<String,Object> map = userShareGoodsRecordService.save(uid, ShareSourceTypeEnum.activity, title, listGoodsBrief);

		
      data.put("revenue", revenue);



      Map<String, Object> map = userShareGoodsRecordService.save(uid, ShareSourceTypeEnum.activity, title,

            listGoodsBrief);



      data.put("title", title);

      data.put("revenue", array);

      data.put("fanMoney", shareMoney);

      data.put("shareId", map.get("shareId"));

      data.put("shareImg", map.get("loadResult"));

      data.put("notifyDesc", configService.get("goods_share_notify"));

      data.put("notifyDesc", configService.get("goods_share_multiple_notify"));



      return data;

		


   }



   @Override

@@ -295,9 +323,9 @@
      activity.setTop(top);

      activity.setType(RecommendActivity.TYPE_SHARE_GOODS);

      recommendActivityMapper.insertSelective(activity);

		


      List<CommonGoods> listCommonGoods = new ArrayList<CommonGoods>();

		


      BigDecimal taotaoMoney = new BigDecimal(0);

      for (long auctionId : goodsList) {

         TaoBaoGoodsBrief tb = null;

@@ -320,12 +348,12 @@
         recommendActivityTaoBaoGoodsMapper.insertSelective(goods);

         BigDecimal money = taoBaoGoodsBriefService.getShareGoodsUserHongBao(tb);

         taotaoMoney = taotaoMoney.add(money);

			


         // 转换简版商品信息

         CommonGoods commonGoods = CommonGoodsFactory.create(tb);

         listCommonGoods.add(commonGoods);

      }

		


      try {

         // 更新简版信息

         commonGoodsService.addBatchCommonGoods(listCommonGoods);

@@ -335,7 +363,7 @@


      RecommendActivity updateActivity = new RecommendActivity();

      updateActivity.setId(activity.getId());

      updateActivity.setTotalGetMoney("预计分享奖金：¥" + taotaoMoney.toString());

      updateActivity.setTotalGetMoney("预估分享奖金：¥" + taotaoMoney.toString());

      recommendActivityMapper.updateByPrimaryKeySelective(updateActivity);



      return activity;

@@ -469,7 +497,7 @@


      RecommendActivity updateActivity = new RecommendActivity();

      updateActivity.setId(activity.getId());

      updateActivity.setTotalGetMoney("预计分享奖金：¥" + taotaoMoney.toString());

      updateActivity.setTotalGetMoney("预估分享奖金：¥" + taotaoMoney.toString());

      recommendActivityMapper.updateByPrimaryKeySelective(updateActivity);



      return activity;

@@ -608,7 +636,7 @@
               update.setId(goods.getId());

               update.setState(RecommendActivityTaoBaoGoods.STATE_UNSHELVE);

               recommendActivityTaoBaoGoodsMapper.updateByPrimaryKeySelective(update);

               taoBaoGoodsUpdateService.downTaoBaoGoods(Long.parseLong(goods.getAuctionId()));

               taoBaoGoodsUpdateService.offlineTaoBaoGoods(Long.parseLong(goods.getAuctionId()));

            }

         }

   }

@@ -677,4 +705,26 @@
   public ActivityUser selectActivityUserByPrimaryKey(Long id) {

      return activityUserMapper.selectByPrimaryKey(id);

   }



   @Override

   public void updateRecommendActivityGoods(TaoBaoGoodsBrief goods) {

      List<RecommendActivityTaoBaoGoods> list = recommendActivityTaoBaoGoodsMapper

            .selectByAuctionId(goods.getAuctionId());

		
      BigDecimal d = TaoBaoUtil.getAfterUseCouplePrice(goods);

		
      RecommendActivityTaoBaoGoods updateGoods = new RecommendActivityTaoBaoGoods();

      if (!StringUtil.isNullOrEmpty(goods.getCouponInfo()) && !"无".equalsIgnoreCase(goods.getCouponInfo())) {

         updateGoods.setDesc("券后价：¥" + d);

         updateGoods.setState(RecommendActivityTaoBaoGoods.STATE_NORMAL);

      } else {

         updateGoods.setState(RecommendActivityTaoBaoGoods.STATE_UNSHELVE);

      }



      if (list != null)

         for (RecommendActivityTaoBaoGoods tbGoods : list) {

            updateGoods.setId(tbGoods.getId());

            recommendActivityTaoBaoGoodsMapper.updateByPrimaryKeySelective(updateGoods);

         }

   }

}