admin
2019-06-14 1e92eff67b997263ecefa255c63eb6641c47b57f
fanli/src/main/java/com/yeshi/fanli/service/impl/dynamic/DynamicInfoServiceImpl.java
@@ -20,6 +20,7 @@
import com.yeshi.fanli.dto.taobao.TaoBaoShopDTO;
import com.yeshi.fanli.entity.bus.activity.ActivityUser;
import com.yeshi.fanli.entity.bus.activity.RecommendActivity;
import com.yeshi.fanli.entity.bus.activity.RecommendActivityInviteInfo;
import com.yeshi.fanli.entity.bus.activity.RecommendActivityTaoBaoGoods;
import com.yeshi.fanli.entity.bus.clazz.GoodsClass;
import com.yeshi.fanli.entity.dynamic.DynamicInfo;
@@ -37,9 +38,11 @@
import com.yeshi.fanli.service.inter.dynamic.InviteMaterialService;
import com.yeshi.fanli.service.inter.goods.TaoBaoGoodsBriefService;
import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;
import com.yeshi.fanli.service.inter.taobao.TaoBaoGoodsUpdateService;
import com.yeshi.fanli.service.inter.taobao.TaoBaoShopService;
import com.yeshi.fanli.service.inter.taobao.dataoke.DaTaoKeGoodsService;
import com.yeshi.fanli.service.inter.user.QrCodeService;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.MoneyBigDecimalUtil;
import com.yeshi.fanli.util.RedisManager;
import com.yeshi.fanli.util.StringUtil;
@@ -87,6 +90,9 @@
   @Resource
   private QrCodeService qrCodeService;
   
   @Resource
   private TaoBaoGoodsUpdateService taoBaoGoodsUpdateService;
   
   @Override
   public void insert(DynamicInfo record) {
@@ -111,7 +117,7 @@
      String materialId = inviteMaterial.getId();
      String content = inviteMaterial.getText();
      
      ActivityUser user=activityUserService.selectByPrimaryKey(1L);
      ActivityUser user=activityUserService.selectByPrimaryKey(2L);
      
      if (!StringUtil.isNullOrEmpty(content)) {
         DynamicInfo dynamicTxt= new DynamicInfo();
@@ -129,7 +135,7 @@
         SimpleDateFormat format = new SimpleDateFormat("MM月dd日");
         
         StringBuffer buffer = new StringBuffer();
         buffer.append("------------------------------------------\n");
         buffer.append("-------------------\n");
         buffer.append("今天 : " + format.format(date));
         buffer.append("     ");
         buffer.append(DateLunarUtil.getWeekd(date) + "\n");
@@ -139,7 +145,9 @@
         buffer.append("我的邀请码:【邀请码】\n");
         buffer.append("购物省钱返利券App:【邀请链接】");
      
         content = content.replaceAll("\\,", "\\,").replaceAll("\\.", "\\。")   .replaceAll("\\;", "\\;")
               .replaceAll("\\!", "\\!").replaceAll("\\?", "\\?").replaceAll("\\:", "\\:");
         ClientTextStyleVO row1 = new ClientTextStyleVO();
         row1.setColor("#333333");
         row1.setContent(content + "\n" + buffer.toString());
@@ -336,7 +344,8 @@
         DaTaoKeDetail daTaoKeDetail = null;
         // 商品列表
         List<GoodsPicture> listPicture = new ArrayList<GoodsPicture>();
         // 商品列表
         List<TaoBaoGoodsBrief> listGoods = new ArrayList<TaoBaoGoodsBrief>();
         // 分享奖金
         BigDecimal shareMoney = new BigDecimal(0);
@@ -346,8 +355,9 @@
               daTaoKeDetail = daTaoKe;
            }
            // 分享奖金
            TaoBaoGoodsBrief taoBaoGoodsBrief = TaoBaoUtil.convert(daTaoKe);
            listGoods.add(taoBaoGoodsBrief);
            TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion.toString(), null);
            if (!taoBaoGoodsBriefExtra.isCoupon()) {
               taoBaoGoodsBriefExtra.setState(1);
@@ -371,6 +381,7 @@
         // 发布用户
         dynamicInfo.setUser(activityUserService.getRandomByDaTaoKeCid(cid));
         dynamicInfo.setImgs(listPicture);
         dynamicInfo.setListGoodsBrief(listGoods);
         ClientTextStyleVO shareMoneyDesc = new ClientTextStyleVO();
         shareMoneyDesc.setColor("#FFFFFF");
@@ -449,13 +460,16 @@
      // 大淘客数据
      DaTaoKeDetail daTaoKe = daTaoKeGoodsService.getGoodsNotInList(subclassId, listId, 1).get(0);
      List<TaoBaoGoodsBrief> listGoods = new ArrayList<TaoBaoGoodsBrief>();
      TaoBaoGoodsBrief taoBaoGoodsBrief = TaoBaoUtil.convert(daTaoKe);
      listGoods.add(taoBaoGoodsBrief);
      BigDecimal proportion = hongBaoManageService.getFanLiRate();
      TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion.toString(), null);
      if (!taoBaoGoodsBriefExtra.isCoupon()) {
         taoBaoGoodsBriefExtra.setState(1);
      }
      taoBaoGoodsBriefExtra.setTkRate(taoBaoGoodsBrief.getTkRate());
      
      // 分享奖金
      BigDecimal shareMoney = taoBaoGoodsBriefService.getShareGoodsUserHongBao(taoBaoGoodsBrief);
@@ -506,6 +520,7 @@
      dynamicInfo.setDesc(shareMoneyDesc);
      dynamicInfo.setShareType(DynamicInfo.SHARE_TYPE_ONE);
      dynamicInfo.setShowType(DynamicInfo.SHOW_TYPE_TWO);
      dynamicInfo.setListGoodsBrief(listGoods);
      
      String desc = DaTaoKeUtil.getDesc(daTaoKe);
      if (!StringUtil.isNullOrEmpty(desc)) {
@@ -579,29 +594,49 @@
      return goodsPicture;
   }
   @Override
   public void updateShareCount(DynamicInfo record) {
      dynamicInfoDao.updateShareCount(record);
   }
   
   
   @Override
   public void insertInviteMaterial(String title, String picUrl, Long activityId, ActivityUser activityUser) {
   public void insertInviteActivity(RecommendActivity activity) throws Exception{
      
      DynamicInfo existInfo = null;
      if (activityId != null) {
         existInfo = dynamicInfoDao.getByActivityId(activityId);
         if (existInfo != null) {
            dynamicInfoDao.deleteById(existInfo.getId());
         }
         if (!StringUtil.isNullOrEmpty(title)) {
            title = title.replace("<p>", "");
            title = title.replace("</p>", "");
         }
      String title = activity.getTitle();
      String picUrl = null;
      List<String> imageList = activity.getImageList();
      if (imageList != null && imageList.size() > 0) {
         picUrl = imageList.get(0);
      }
      
      DynamicInfo dynamicVO = new DynamicInfo();
      if (StringUtil.isNullOrEmpty(title) || StringUtil.isNullOrEmpty(picUrl)) {
         return;
      }
      // 判断是否已存在
      String dynamicInfoId = null;
      Long activityId =  activity.getId();
      DynamicInfo dynamicVO = dynamicInfoDao.getByActivityId(activityId);
      if (dynamicVO == null) {
         dynamicVO = new DynamicInfo();
         dynamicVO.setId(UUID.randomUUID().toString().replace("-", ""));
         dynamicVO.setCreateTime(DateUtil.reduceRandomMinute(new Date(), 8));
      } else {
         dynamicInfoId = dynamicVO.getId();
      }
      if (!StringUtil.isNullOrEmpty(title)) {
         title = title.replaceAll("<p>", "").replaceAll("</p>", "").replaceAll("<br>", "\n");
         int index = title.lastIndexOf("\n");
         String newDesc = title.substring(index + 1);
         if(StringUtil.isNullOrEmpty(newDesc)) {
            title = title.substring(0, index);
         }
         title = title.replaceAll("\\,", "\\,").replaceAll("\\.", "\\。")   .replaceAll("\\;", "\\;")
               .replaceAll("\\!", "\\!").replaceAll("\\?", "\\?").replaceAll("\\:", "\\:");
      }
      dynamicVO.setId(UUID.randomUUID().toString().replace("-", ""));
      dynamicVO.setActivityId(activityId);
      dynamicVO.setClassId(4L);
@@ -609,64 +644,228 @@
      dynamicVO.setShareType(DynamicInfo.SHARE_TYPE_INVITE);
      dynamicVO.setUpdateTime(new Date());
      
      if (existInfo != null) {
         dynamicVO.setCreateTime(existInfo.getCreateTime());
         dynamicVO.setShareCount(existInfo.getShareCount());
      } else {
         dynamicVO.setCreateTime(DateUtil.reduceRandomMinute(new Date(), 8));
      Integer shareCount = activity.getShareCount();
      if (shareCount == null || shareCount <= 0) {
         dynamicVO.setShareCount(1000 + (int) (Math.random() * 8000));
      } else {
         dynamicVO.setShareCount(shareCount);
      }
      
      // 发布用户
      ActivityUser activityUser = activity.getActivityUser();
      if (activityUser == null) {
         dynamicVO.setUser(activityUserService.listRand(1).get(0));
         dynamicVO.setUser(activityUserService.selectByPrimaryKey(2L));
      } else {
         dynamicVO.setUser(activityUser);
      }
      
      
      // 介绍内容
      List<ClientTextStyleVO> listtitle = new ArrayList<ClientTextStyleVO>();
      List<GoodsPicture> listImg = new ArrayList<GoodsPicture>();
      if(StringUtil.isNullOrEmpty(picUrl)) {
         dynamicVO.setImgs(listImg);
         dynamicVO.setShowType(DynamicInfo.SHOW_TYPE_ZERO);
         // 介绍内容
      if(!StringUtil.isNullOrEmpty(title)) {
         ClientTextStyleVO row1 = new ClientTextStyleVO();
         row1.setColor("#333333");
         row1.setContent(title);
         row1.setContent(title );
         listtitle.add(row1);
         dynamicVO.setTitle(listtitle);
         dynamicInfoDao.insert(dynamicVO);
      } else {
         try {
            dynamicVO.setTitle(listtitle);
            dynamicVO.setShowType(DynamicInfo.SHOW_TYPE_ONE);
            // 图片
            String imgLink = qrCodeService.drawInviteQrCodeNew(picUrl , null, null, null);
            GoodsPicture p2 = new GoodsPicture();
            p2.setW(100);
            p2.setH(100);
            p2.setUrl(imgLink);
            p2.setUrlOriginal(picUrl);
            listImg.add(p2);
            dynamicVO.setImgs(listImg);
            dynamicInfoDao.insert(dynamicVO);
         } catch (Exception e) {
            try {
               LogHelper.errorDetailInfo(e);
            } catch (Exception e1) {
               e1.printStackTrace();
            }
         }
      }
      
      // 图片
      List<GoodsPicture> listImg = new ArrayList<GoodsPicture>();
      if(StringUtil.isNullOrEmpty(picUrl)) {
         dynamicVO.setShowType(DynamicInfo.SHOW_TYPE_ZERO);
      } else {
         dynamicVO.setShowType(DynamicInfo.SHOW_TYPE_ONE);
         RecommendActivityInviteInfo inviteInfo = activity.getInviteInfo();
         Integer pX = null;
         Integer pY = null;
         Integer size = null;
         if (inviteInfo != null) {
            pX = inviteInfo.getPx();
            pY = inviteInfo.getPy();
            size = inviteInfo.getSize();
         }
         // 图片
         String imgLink = qrCodeService.drawInviteQrCodeNew(picUrl , null, null, pX, pY, size, null);
         GoodsPicture p2 = new GoodsPicture();
         p2.setW(100);
         p2.setH(100);
         p2.setUrl(imgLink);
         p2.setUrlOriginal(picUrl);
         p2.setPx(pX);
         p2.setPy(pY);
         p2.setSize(size);
         listImg.add(p2);
      }
      dynamicVO.setImgs(listImg);
      dynamicVO.setTitle(listtitle);
      if (!StringUtil.isNullOrEmpty(dynamicInfoId)) {
         dynamicInfoDao.deleteById(dynamicInfoId);
      }
      dynamicInfoDao.insert(dynamicVO);
   }
   
   @Override
   public void insertActivityRecommend(RecommendActivity activity) {
      if (activity == null || activity.getGoodsList() == null) {
         return;
      }
      try {
         String dynamicInfoId = null;
         DynamicInfo dynamicInfo = dynamicInfoDao.getByActivityId(activity.getId());
         if (dynamicInfo == null) {
            dynamicInfo = new DynamicInfo();
            dynamicInfo.setId(UUID.randomUUID().toString().replace("-", ""));
            dynamicInfo.setCreateTime(new Date());
         } else {
            dynamicInfoId = dynamicInfo.getId();
         }
         dynamicInfo.setClassId(2L);
         dynamicInfo.setSubclassId(0L);
         dynamicInfo.setUser(activity.getActivityUser());
         dynamicInfo.setActivityId(activity.getId());
         dynamicInfo.setUpdateTime(new Date());
         List<ClientTextStyleVO> listtitle = new ArrayList<ClientTextStyleVO>();
         String title = activity.getTitle();
         if (!StringUtil.isNullOrEmpty(title)) {
            title = title.replaceAll("<p>", "");
            title = title.replaceAll("</p>", "");
            title = title.replaceAll("<br>", "\n");
            int index = title.lastIndexOf("\n");
            String newDesc = title.substring(index + 1);
            if(StringUtil.isNullOrEmpty(newDesc)) {
               title = title.substring(0, index);
            }
            ClientTextStyleVO row1 = new ClientTextStyleVO();
            row1.setColor("#333333");
            row1.setContent(title );
            listtitle.add(row1);
         }
         dynamicInfo.setTitle(listtitle);
         Integer shareCount = activity.getShareCount();
         if (shareCount == null || shareCount <= 0) {
            dynamicInfo.setShareCount(1000 + (int) (Math.random() * 8000));
         } else {
            dynamicInfo.setShareCount(shareCount);
         }
         // 发布用户
         ActivityUser activityUser = activity.getActivityUser();
         if (activityUser == null) {
            dynamicInfo.setUser(activityUserService.selectByPrimaryKey(2L));
         } else {
            dynamicInfo.setUser(activityUser);
         }
         List<TaoBaoGoodsBrief> listGoods = new ArrayList<TaoBaoGoodsBrief>();
         // 商品列表
         List<GoodsPicture> listPicture = new ArrayList<GoodsPicture>();
         BigDecimal proportion = hongBaoManageService.getFanLiRate();
         // 分享奖金
         BigDecimal shareMoney = new BigDecimal(0);
         if (activity.getGoodsList() != null) {
            for (RecommendActivityTaoBaoGoods activityGoods : activity.getGoodsList()) {
               TaoBaoGoodsBrief taoBaoGoodsBrief = null;
                TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = null;
               String auctionId = activityGoods.getAuctionId();
               try {
                  taoBaoGoodsBrief = redisManager.getTaoBaoGoodsBrief(Long.parseLong(auctionId));
                  taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion.toString(), null);
                  if (!taoBaoGoodsBriefExtra.isCoupon()) {
                     taoBaoGoodsBriefExtra.setState(1);
                  }
                  BigDecimal money = taoBaoGoodsBriefService.getShareGoodsUserHongBao(taoBaoGoodsBrief);
                  shareMoney = MoneyBigDecimalUtil.add(shareMoney, money);
               } catch (TaobaoGoodsDownException e) {
                   taoBaoGoodsBrief = activityGoods.getTaoBaoGoodsBrief();
                   taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion.toString(), null);
                   taoBaoGoodsBriefExtra.setState(1);
                   taoBaoGoodsBriefExtra.setCoupon(false);
               }
               listGoods.add(taoBaoGoodsBrief);
               // 商品图片
               taoBaoGoodsBriefExtra.setCouponInfo(null);
               taoBaoGoodsBriefExtra.setUpdatetime(new Date());
               JSONObject item = new JSONObject();
               item.put("id", auctionId);
               item.put("from", "dynamics");
               GoodsPicture goodsPicture = new GoodsPicture();
               goodsPicture.setH(100);
               goodsPicture.setW(100);
               goodsPicture.setUrl(TbImgUtil.getTBSize320Img(taoBaoGoodsBrief.getPictUrl()));
               goodsPicture.setJumpDetail(jumpDetailV2Service.getByTypeCache("goodsdetail"));
               goodsPicture.setParams(item.toString());
               goodsPicture.setGoods(taoBaoGoodsBriefExtra);
               listPicture.add(goodsPicture);
            }
         }
         dynamicInfo.setImgs(listPicture);
         dynamicInfo.setListGoodsBrief(listGoods);
         ClientTextStyleVO shareMoneyDesc = new ClientTextStyleVO();
         shareMoneyDesc.setColor("#FFFFFF");
         shareMoneyDesc.setBottomColor("#E8AE48");
         shareMoneyDesc.setContent("预估分享奖金:¥" + shareMoney);
         dynamicInfo.setDesc(shareMoneyDesc);
         dynamicInfo.setShowType(2);
         if (listPicture.size() < 7) {
            dynamicInfo.setShowType(DynamicInfo.SHOW_TYPE_TWO);
            dynamicInfo.setShareType(DynamicInfo.SHARE_TYPE_FOUR); // 分享类型4图
         } else {
            dynamicInfo.setShowType(DynamicInfo.SHOW_TYPE_THREE);
            dynamicInfo.setShareType(DynamicInfo.SHARE_TYPE_NINE); // 分享类型9图
         }
         if (!StringUtil.isNullOrEmpty(dynamicInfoId)) {
            dynamicInfoDao.deleteById(dynamicInfoId);
         }
         // 保存信息
         dynamicInfoDao.insert(dynamicInfo);
      } catch (Exception e) {
         try {
            LogHelper.errorDetailInfo(e);
         } catch (Exception e1) {
            e1.printStackTrace();
         }
      }
   }
   @Override
   public void deleteActivity(Long activityId) {
      DynamicInfo dynamicInfo = dynamicInfoDao.getByActivityId(activityId);
      if (dynamicInfo != null) {
         // 删除之前的
         dynamicInfoDao.deleteById(dynamicInfo.getId());
      }
   }
   
   
   @Override
@@ -674,12 +873,44 @@
      dynamicInfoDao.removeByDate(createTime);
   }
   
   @Override
   public void updateShareCount(DynamicInfo record) {
      dynamicInfoDao.updateShareCount(record);
   }
   @Override
   @Cacheable(value = "dynamicCache", key = "'count-'+#cid+'-'+#subId")
   public long count(Long cid, Long subId) {
      return dynamicInfoDao.count(cid, subId);
   }
   @Override
   @Cacheable(value = "dynamicCache", key = "'query-'+#start+'-'+#count+'-'+#cid+'-'+#subId")
   public List<DynamicInfo> query(int start, int count, Long cid, Long subId) {
      List<DynamicInfo> list = dynamicInfoDao.query(start, count, cid, subId);
      // 更新商品信息
      executor.execute(new Runnable() {
         @Override
         public void run() {
            updateGoodInfo(list);
         }
      });
      return list;
   }
   
   
   /**
    * 更新商品信息
    */
   public void updateGoodInfo(List<DynamicInfo> list) {
      // 外网进行更新
      if (!Constant.IS_OUTNET) {
         return;
      }
      if (list == null || list.size() == 0) {
         return;
      }
@@ -711,8 +942,11 @@
            }
         }
         
         // 更新
         BigDecimal shareMoney = new BigDecimal(0);
         // 已下架ID
         List<Long> listDown = new ArrayList<Long>();
         // 商品列表
         List<TaoBaoGoodsBrief> listGoods = new ArrayList<TaoBaoGoodsBrief>();
         for (GoodsPicture goodsPicture: imgs) {
            TaoBaoGoodsBriefExtra oldExtra = goodsPicture.getGoods();
            if (oldExtra == null) {
@@ -726,191 +960,103 @@
            
            try {
               TaoBaoGoodsBrief goodsBrief = redisManager.getTaoBaoGoodsBrief(oldExtra.getAuctionId());
               // 更新商品信息
               try {
                  taoBaoGoodsUpdateService.updateTaoBaoGoods(goodsBrief);
               } catch (Exception e) {
                  e.printStackTrace();
               }
               listGoods.add(goodsBrief);
               // 更新热销单品的分享奖金  ,其余不做更新
               if (classId == 1) {
                  BigDecimal shareMoney = taoBaoGoodsBriefService.getShareGoodsUserHongBao(goodsBrief);
                  ClientTextStyleVO shareMoneyDesc = new ClientTextStyleVO();
                  shareMoneyDesc.setColor("#FFFFFF");
                  shareMoneyDesc.setBottomColor("#E8AE48");
                  shareMoneyDesc.setContent("预估分享奖金:¥" + shareMoney);
                  dynamicInfo.setDesc(shareMoneyDesc);
               }
               TaoBaoGoodsBriefExtra newExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief, proportion.toString(), null);
               
               if (!newExtra.isCoupon()) {
                  newExtra.setState(1);
               }
               newExtra.setUpdatetime(new Date());
               goodsPicture.setGoods(newExtra);
               // 更新热销单品的分享奖金  ,其余不做更新
               if (classId == 1) {
                  BigDecimal money = taoBaoGoodsBriefService.getShareGoodsUserHongBao(goodsBrief);
                  shareMoney = MoneyBigDecimalUtil.add(shareMoney, money);
               }
               goodsPicture.setGoods(oldExtra);
               
            } catch (TaobaoGoodsDownException e) {
               listDown.add(oldExtra.getAuctionId());
               oldExtra.setState(1);
               oldExtra.setCoupon(false);
               oldExtra.setUpdatetime(new Date());
               goodsPicture.setGoods(oldExtra);
               // 商品真实下架
               goodsPicture.setGoodState(1);
               // 更新热销单品的分享奖金  ,其余不做更新
               if (classId == 1) {
                  ClientTextStyleVO shareMoneyDesc = new ClientTextStyleVO();
                  shareMoneyDesc.setColor("#FFFFFF");
                  shareMoneyDesc.setBottomColor("#E8AE48");
                  shareMoneyDesc.setContent("预估分享奖金:¥" + new BigDecimal(0));
                  dynamicInfo.setDesc(shareMoneyDesc);
               }
               e.printStackTrace();
            }
         }
         dynamicInfo.setImgs(imgs);
         
         // 更新热销单品的分享奖金  ,其余不做更新
         if (classId == 1) {
            ClientTextStyleVO shareMoneyDesc = new ClientTextStyleVO();
            shareMoneyDesc.setColor("#FFFFFF");
            shareMoneyDesc.setBottomColor("#E8AE48");
            shareMoneyDesc.setContent("预估分享奖金:¥" + shareMoney);
            dynamicInfo.setDesc(shareMoneyDesc);
         // 商品已下架
         List<TaoBaoGoodsBrief> listGoodsBrief = dynamicInfo.getListGoodsBrief();
         if (listGoodsBrief != null && listGoodsBrief.size() > 0) {
            if (listGoods.size() > 0 ) {
               if (classId == 1) {
                  dynamicInfo.setListGoodsBrief(listGoods);
               } else {
                  for (int i =0; i < listGoodsBrief.size(); i ++) {
                     TaoBaoGoodsBrief taoBaoGoodsBrief = listGoodsBrief.get(i);
                     Long auctionId = taoBaoGoodsBrief.getAuctionId();
                     boolean isadd = true;
                     for (TaoBaoGoodsBrief goods: listGoods) {
                        if(goods.getAuctionId().equals(auctionId) || goods.getAuctionId() == auctionId) {
                           isadd = false;
                           break;
                        }
                     }
                     if (isadd) {
                        // 商品已下架 则添加原来商品信息
                        if (listDown.size() > 0 && listDown.contains(taoBaoGoodsBrief.getAuctionId())) {
                           taoBaoGoodsBrief.setState(1);
                        }
                        listGoods.add(taoBaoGoodsBrief);
                     }
                  }
                  dynamicInfo.setListGoodsBrief(listGoods);
               }
            } else {
               if (listDown.size() > 0) {
                  for (TaoBaoGoodsBrief taoBaoGoodsBrief: listGoodsBrief) {
                     if (listDown.contains(taoBaoGoodsBrief.getAuctionId())) {
                        taoBaoGoodsBrief.setState(1);
                     }
                  }
                  dynamicInfo.setListGoodsBrief(listGoodsBrief);
               }
            }
         }
         
         dynamicInfo.setImgs(imgs);
         dynamicInfo.setUpdateTime(new Date());
         dynamicInfoDao.updateGoodInfo(dynamicInfo);
      }
   }
   
   @Override
   public void deleteActivity(Long activityId) {
      DynamicInfo dynamicInfo = dynamicInfoDao.getByActivityId(activityId);
      if (dynamicInfo != null) {
         // 删除之前的
         dynamicInfoDao.deleteById(dynamicInfo.getId());
      }
   }
   @Override
   public void saveActivityRecommend(RecommendActivity activity) {
      if (activity == null || activity.getGoodsList() == null) {
         return;
      }
      try {
         DynamicInfo existInfo = dynamicInfoDao.getByActivityId(activity.getId());
         if (existInfo != null) {
            dynamicInfoDao.deleteById(existInfo.getId());
         }
         DynamicInfo dynamicInfo = new DynamicInfo();
         dynamicInfo.setId(UUID.randomUUID().toString().replace("-", ""));
         dynamicInfo.setClassId(2L);
         dynamicInfo.setSubclassId(0L);
         dynamicInfo.setUser(activity.getActivityUser());
         dynamicInfo.setActivityId(activity.getId());
         String title = activity.getTitle();
         if (!StringUtil.isNullOrEmpty(title)) {
            title = title.replace("<p>", "");
            title = title.replace("</p>", "");
            dynamicInfo.setTitle(convertIntroduce(title));
         }
         if (existInfo != null) {
            dynamicInfo.setCreateTime(existInfo.getCreateTime());
            dynamicInfo.setShareCount(existInfo.getShareCount());
         } else {
            dynamicInfo.setCreateTime(new Date());
            dynamicInfo.setUpdateTime(new Date());
            dynamicInfo.setShareCount(1000 + (int) (Math.random() * 8000));
         }
         // 商品列表
         List<GoodsPicture> listPicture = new ArrayList<GoodsPicture>();
         BigDecimal proportion = hongBaoManageService.getFanLiRate();
         // 分享奖金
         BigDecimal shareMoney = new BigDecimal(0);
         if (activity.getGoodsList() != null) {
            for (RecommendActivityTaoBaoGoods activityGoods : activity.getGoodsList()) {
               TaoBaoGoodsBrief taoBaoGoodsBrief = null;
                TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = null;
               String auctionId = activityGoods.getAuctionId();
               try {
                  taoBaoGoodsBrief = redisManager.getTaoBaoGoodsBrief(Long.parseLong(auctionId));
                  taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion.toString(), null);
                  if (!taoBaoGoodsBriefExtra.isCoupon()) {
                     taoBaoGoodsBriefExtra.setState(1);
                  }
                  BigDecimal money = taoBaoGoodsBriefService.getShareGoodsUserHongBao(taoBaoGoodsBrief);
                  shareMoney = MoneyBigDecimalUtil.add(shareMoney, money);
               } catch (TaobaoGoodsDownException e) {
                   taoBaoGoodsBrief = activityGoods.getTaoBaoGoodsBrief();
                   taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion.toString(), null);
                   taoBaoGoodsBriefExtra.setState(1);
                   taoBaoGoodsBriefExtra.setCoupon(false);
               }
               // 商品图片
               taoBaoGoodsBriefExtra.setCouponInfo(null);
               taoBaoGoodsBriefExtra.setUpdatetime(new Date());
               JSONObject item = new JSONObject();
               item.put("id", auctionId);
               item.put("from", "dynamics");
               GoodsPicture goodsPicture = new GoodsPicture();
               goodsPicture.setH(100);
               goodsPicture.setW(100);
               goodsPicture.setUrl(TbImgUtil.getTBSize320Img(taoBaoGoodsBrief.getPictUrl()));
               goodsPicture.setJumpDetail(jumpDetailV2Service.getByTypeCache("goodsdetail"));
               goodsPicture.setParams(item.toString());
               goodsPicture.setGoods(taoBaoGoodsBriefExtra);
               listPicture.add(goodsPicture);
            }
         }
         dynamicInfo.setImgs(listPicture);
         ClientTextStyleVO shareMoneyDesc = new ClientTextStyleVO();
         shareMoneyDesc.setColor("#FFFFFF");
         shareMoneyDesc.setBottomColor("#E8AE48");
         shareMoneyDesc.setContent("预估分享奖金:¥" + shareMoney);
         dynamicInfo.setDesc(shareMoneyDesc);
         dynamicInfo.setShowType(2);
         if (listPicture.size() < 7) {
            dynamicInfo.setShowType(DynamicInfo.SHOW_TYPE_TWO);
            dynamicInfo.setShareType(DynamicInfo.SHARE_TYPE_FOUR); // 分享类型4图
         } else {
            dynamicInfo.setShowType(DynamicInfo.SHOW_TYPE_THREE);
            dynamicInfo.setShareType(DynamicInfo.SHARE_TYPE_NINE); // 分享类型9图
         }
         // 保存信息
         dynamicInfoDao.insert(dynamicInfo);
      } catch (Exception e) {
         try {
            LogHelper.errorDetailInfo(e);
         } catch (Exception e1) {
            e1.printStackTrace();
         }
      }
   }
   @Override
   @Cacheable(value = "dynamicCache", key = "'count-'+#cid+'-'+#subId")
   public long count(Long cid, Long subId) {
      return dynamicInfoDao.count(cid, subId);
   }
   @Override
   @Cacheable(value = "dynamicCache", key = "'query-'+#start+'-'+#count+'-'+#cid+'-'+#subId")
   public List<DynamicInfo> query(int start, int count, Long cid, Long subId) {
      List<DynamicInfo> list = dynamicInfoDao.query(start, count, cid, subId);
      // 更新商品信息
      executor.execute(new Runnable() {
         @Override
         public void run() {
            updateGoodInfo(list);
         }
      });
      return list;
   }
}