yujian
2019-05-21 ff33cdfa1bd3a89ad9f5a72067b1c9b47376ef22
fanli/src/main/java/com/yeshi/fanli/service/impl/dynamic/DynamicInfoServiceImpl.java
@@ -1,6 +1,8 @@
package com.yeshi.fanli.service.impl.dynamic;
import java.io.IOException;
import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
@@ -8,8 +10,10 @@
import javax.annotation.Resource;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.core.task.TaskExecutor;
import org.springframework.stereotype.Service;
import org.yeshi.utils.DateLunarUtil;
import org.yeshi.utils.DateUtil;
import org.yeshi.utils.taobao.TbImgUtil;
@@ -21,6 +25,7 @@
import com.yeshi.fanli.entity.bus.clazz.GoodsClass;
import com.yeshi.fanli.entity.dynamic.DynamicInfo;
import com.yeshi.fanli.entity.dynamic.GoodsPicture;
import com.yeshi.fanli.entity.dynamic.InviteMaterial;
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBriefExtra;
import com.yeshi.fanli.entity.taobao.TaoBaoShop;
@@ -30,10 +35,12 @@
import com.yeshi.fanli.service.inter.activity.ActivityUserService;
import com.yeshi.fanli.service.inter.common.JumpDetailV2Service;
import com.yeshi.fanli.service.inter.dynamic.DynamicInfoService;
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.TaoBaoShopService;
import com.yeshi.fanli.service.inter.taobao.dataoke.DaTaoKeGoodsService;
import com.yeshi.fanli.service.inter.user.QrCodeService;
import com.yeshi.fanli.util.MoneyBigDecimalUtil;
import com.yeshi.fanli.util.RedisManager;
import com.yeshi.fanli.util.StringUtil;
@@ -75,6 +82,13 @@
   @Resource
   private TaoBaoShopService taoBaoShopService;
   
   @Resource
   private InviteMaterialService inviteMaterialService;
   @Resource
   private QrCodeService qrCodeService;
   @Override
   public void insert(DynamicInfo record) {
       dynamicInfoDao.insert(record);
@@ -94,6 +108,7 @@
         List<GoodsClass> list = DaTaoKeUtil.goodsClasses;
         int index = (int) (Math.random() * list.size());
         Long subclassId = list.get(index).getId();
         int cid = Integer.parseInt(subclassId +"");
         int count = 0;
         double random = Math.random();
         if (random > 0.5) {
@@ -137,6 +152,8 @@
         // 组织动态信息
         DynamicInfo dynamicInfo = getDynamicInfo(daTaoKeDetail, classId, subclassId);
         // 发布用户
         dynamicInfo.setUser(activityUserService.getRandomByDaTaoKeCid(cid));
         dynamicInfo.setImgs(listPicture);
         ClientTextStyleVO shareMoneyDesc = new ClientTextStyleVO();
@@ -256,7 +273,8 @@
      // 组织动态信息
      DynamicInfo dynamicInfo = getDynamicInfo(daTaoKe, classId, subclassId);
      // 发布用户
      dynamicInfo.setUser(activityUserService.getRandomByDaTaoKeCid(daTaoKe.getCid()));
      dynamicInfo.setImgs(listPicture);
      dynamicInfo.setDesc(shareMoneyDesc);
      dynamicInfo.setShareType(DynamicInfo.SHARE_TYPE_ONE);
@@ -280,12 +298,10 @@
      dynamicInfo.setClassId(classId);
      dynamicInfo.setSubclassId(subclassId);
      dynamicInfo.setDaTaoKeId(daTaoKe.getId());
      dynamicInfo.setCreateTime(DateUtil.reduceRandomMinute(new Date()));
      dynamicInfo.setCreateTime(DateUtil.reduceRandomMinute(new Date(), 8));
      dynamicInfo.setUpdateTime(new Date());
      // 随机分享次数
      dynamicInfo.setShareCount(1000 + (int) (Math.random() * 8000));
      // 随机分布用户
      dynamicInfo.setUser(activityUserService.listRand(1).get(0));
      // 内容
      dynamicInfo.setTitle(convertIntroduce(DaTaoKeUtil.getDesc(daTaoKe)));
@@ -329,11 +345,13 @@
   }
   @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);
      
@@ -382,7 +400,7 @@
         dynamicVO.setCreateTime(existInfo.getCreateTime());
         dynamicVO.setShareCount(existInfo.getShareCount());
      } else {
         dynamicVO.setCreateTime(DateUtil.reduceRandomMinute(new Date()));
         dynamicVO.setCreateTime(DateUtil.reduceRandomMinute(new Date(), 8));
         dynamicVO.setShareCount(1000 + (int) (Math.random() * 8000));
      }
      
@@ -393,28 +411,43 @@
      }
      
      
      // 介绍内容
      ClientTextStyleVO row1 = new ClientTextStyleVO();
      row1.setColor("#333333");
      row1.setContent(title);
      List<ClientTextStyleVO> listtitle = new ArrayList<ClientTextStyleVO>();
      listtitle.add(row1);
      dynamicVO.setTitle(listtitle);
            
      List<GoodsPicture> listImg = new ArrayList<GoodsPicture>();
      if(!StringUtil.isNullOrEmpty(picUrl)) {
         GoodsPicture p2 = new GoodsPicture();
         p2.setW(100);
         p2.setH(100);
         p2.setUrl(picUrl);
         listImg.add(p2);
         dynamicVO.setShowType(DynamicInfo.SHOW_TYPE_ONE);
      } else {
      if(StringUtil.isNullOrEmpty(picUrl)) {
         dynamicVO.setImgs(listImg);
         dynamicVO.setShowType(DynamicInfo.SHOW_TYPE_ZERO);
         // 介绍内容
         ClientTextStyleVO row1 = new ClientTextStyleVO();
         row1.setColor("#333333");
         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) {
            e.printStackTrace();
         }
      }
      
      dynamicVO.setImgs(listImg);
      dynamicInfoDao.insert(dynamicVO);
   }
   
   
@@ -489,7 +522,7 @@
      dynamicVO.setShowType(DynamicInfo.SHOW_TYPE_TWO);
      dynamicVO.setShop(taoBaoShop);
      dynamicVO.setUser(activityUserService.listRand(1).get(0));
      dynamicVO.setCreateTime(DateUtil.reduceRandomMinute(new Date()));
      dynamicVO.setCreateTime(DateUtil.reduceRandomMinute(new Date(), 8));
      dynamicVO.setUpdateTime(new Date());
      
      // 介绍内容
@@ -746,4 +779,97 @@
         e.printStackTrace();
      }
   }
   @Override
   public void insertTimeInvite() {
      InviteMaterial inviteMaterial = inviteMaterialService.getInviteMaterial();
      if (inviteMaterial == null) {
         return;
      }
      Date date = new Date();
      String materialId = inviteMaterial.getId();
      String content = inviteMaterial.getText();
      if (!StringUtil.isNullOrEmpty(content)) {
         DynamicInfo dynamicTxt= new DynamicInfo();
         dynamicTxt.setId(UUID.randomUUID().toString().replace("-", ""));
         dynamicTxt.setInviteMaterialId(materialId);
         dynamicTxt.setClassId(4L);
         dynamicTxt.setSubclassId(0L);
         dynamicTxt.setShowType(DynamicInfo.SHOW_TYPE_ZERO);
         dynamicTxt.setShareType(DynamicInfo.SHARE_TYPE_INVITE);
         dynamicTxt.setUser(activityUserService.listRand(1).get(0));
         dynamicTxt.setShareCount(1000 + (int) (Math.random() * 8000));
         dynamicTxt.setCreateTime(date);
         dynamicTxt.setUpdateTime(date);
         SimpleDateFormat format = new SimpleDateFormat("MM月dd日");
         StringBuffer buffer = new StringBuffer();
         buffer.append("------------------------------------------\n");
         buffer.append("今天 : " + format.format(date));
         buffer.append("     ");
         buffer.append(DateLunarUtil.getWeekd(date) + "\n");
         buffer.append("各位亲爱的你");
         buffer.append("         ");
         buffer.append("早安~\n");
         buffer.append("我的邀请码:【邀请码】\n");
         buffer.append("购物省钱返利券App:【邀请链接】");
         ClientTextStyleVO row1 = new ClientTextStyleVO();
         row1.setColor("#333333");
         row1.setContent(content + "\n" + buffer.toString());
         List<ClientTextStyleVO> listtitle = new ArrayList<ClientTextStyleVO>();
         listtitle.add(row1);
         dynamicTxt.setTitle(listtitle);
         // 空数据
         List<GoodsPicture> listImg = new ArrayList<GoodsPicture>();
         dynamicTxt.setImgs(listImg);
         dynamicInfoDao.insert(dynamicTxt);
      }
      String picture = inviteMaterial.getPicture();
      if (!StringUtil.isNullOrEmpty(picture)) {
         DynamicInfo dynamicPic = new DynamicInfo();
         dynamicPic.setId(UUID.randomUUID().toString().replace("-", ""));
         dynamicPic.setInviteMaterialId(materialId);
         dynamicPic.setClassId(4L);
         dynamicPic.setSubclassId(0L);
         dynamicPic.setShowType(DynamicInfo.SHOW_TYPE_ONE);
         dynamicPic.setShareType(DynamicInfo.SHARE_TYPE_INVITE);
         dynamicPic.setUser(activityUserService.listRand(1).get(0));
         dynamicPic.setShareCount(1000 + (int) (Math.random() * 8000));
         dynamicPic.setCreateTime(date);
         dynamicPic.setUpdateTime(date);
         try {
            // 画图
            String url = qrCodeService.drawInviteToGreet(picture, null, null, null, content, new Date());
            List<ClientTextStyleVO> listtitle = new ArrayList<ClientTextStyleVO>();
            dynamicPic.setTitle(listtitle);
            GoodsPicture p2 = new GoodsPicture();
            p2.setW(100);
            p2.setH(100);
            p2.setUrl(url);
            p2.setUrlOriginal(picture);
            p2.setTitleOriginal(content);
            List<GoodsPicture> listImg = new ArrayList<GoodsPicture>();
            listImg.add(p2);
            dynamicPic.setImgs(listImg);
            dynamicInfoDao.insert(dynamicPic);
         } catch (IOException e) {
            e.printStackTrace();
         }
      }
      // 更新素材状态
      inviteMaterialService.updateState(1, materialId);
   }
}