yujian
2019-05-24 ff942c3f9f6fe84f6d141c87f47e58bf70273d40
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;
@@ -586,29 +587,48 @@
      return goodsPicture;
   }
   @Override
   public void updateShareCount(DynamicInfo record) {
      dynamicInfoDao.updateShareCount(record);
   public void insertInviteActivity(RecommendActivity activity) throws Exception{
      String title = activity.getTitle();
      String picUrl = null;
      List<String> imageList = activity.getImageList();
      if (imageList != null && imageList.size() > 0) {
         picUrl = imageList.get(0);
   }
   
      if (StringUtil.isNullOrEmpty(title) || StringUtil.isNullOrEmpty(picUrl)) {
         return;
      }
   
   @Override
   public void insertInviteMaterial(String title, String picUrl, Long activityId, ActivityUser activityUser) {
      // 判断是否已存在
      String dynamicInfoId = null;
      
      DynamicInfo existInfo = null;
      if (activityId != null) {
         existInfo = dynamicInfoDao.getByActivityId(activityId);
         if (existInfo != null) {
            dynamicInfoDao.deleteById(existInfo.getId());
      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.replace("<p>", "");
            title = title.replace("</p>", "");
         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);
         }
      }
      
      DynamicInfo dynamicVO = new DynamicInfo();
      dynamicVO.setId(UUID.randomUUID().toString().replace("-", ""));
      dynamicVO.setActivityId(activityId);
      dynamicVO.setClassId(4L);
@@ -616,66 +636,210 @@
      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);
         // 介绍内容
         SimpleDateFormat format = new SimpleDateFormat("MM月dd日");
         StringBuffer buffer = new StringBuffer();
         buffer.append("-------------------\n");
         buffer.append("今天 : " + format.format(new Date()));
         buffer.append("     ");
         buffer.append(DateLunarUtil.getWeekd(new Date()) + "\n");
         buffer.append("各位亲爱的你");
         buffer.append("         ");
         buffer.append("早安~\n");
         buffer.append("我的邀请码:【邀请码】\n");
         buffer.append("购物省钱返利券App:【邀请链接】");
      List<ClientTextStyleVO> listtitle = new ArrayList<ClientTextStyleVO>();
      if(!StringUtil.isNullOrEmpty(title)) {
         ClientTextStyleVO row1 = new ClientTextStyleVO();
         row1.setColor("#333333");
         row1.setContent(title + "\n" + buffer.toString());
         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);
      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);
            listImg.add(p2);
            dynamicVO.setImgs(listImg);
         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);
@@ -685,8 +849,15 @@
         }
      }
      
   }
   
   @Override
   public void deleteActivity(Long activityId) {
      DynamicInfo dynamicInfo = dynamicInfoDao.getByActivityId(activityId);
      if (dynamicInfo != null) {
         // 删除之前的
         dynamicInfoDao.deleteById(dynamicInfo.getId());
      }
   }
   
   
   @Override
@@ -694,6 +865,32 @@
      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;
   }
   
   
   /**
@@ -773,6 +970,9 @@
               oldExtra.setUpdatetime(new Date());
               goodsPicture.setGoods(oldExtra);
               
               // 商品真实下架
               goodsPicture.setGoodState(1);
               // 更新热销单品的分享奖金  ,其余不做更新
               if (classId == 1) {
                  ClientTextStyleVO shareMoneyDesc = new ClientTextStyleVO();
@@ -784,8 +984,6 @@
               e.printStackTrace();
            }
         }
         
         // 更新商品
         List<TaoBaoGoodsBrief> listGoodsBrief = dynamicInfo.getListGoodsBrief();
@@ -814,160 +1012,10 @@
               dynamicInfo.setListGoodsBrief(listGoods);
            }
         }
         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<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图
         }
         // 保存信息
         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;
   }
}