热销转换发圈

Administrator

2020-02-24 09417e97672be66c5e312b10f23a9e30da3acb97

热销转换发圈

 fanli/src/main/java/com/yeshi/fanli/controller/client/v2/DynamicControllerV2.java

@@ -2,7 +2,6 @@

import java.io.PrintWriter;
import java.lang.reflect.Type;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
@@ -27,7 +26,6 @@
import com.google.gson.JsonSerializer;
import com.yeshi.fanli.dto.jd.JDCouponInfo;
import com.yeshi.fanli.entity.accept.AcceptData;
import com.yeshi.fanli.entity.bus.activity.ActivityUser;
import com.yeshi.fanli.entity.bus.clazz.GoodsClass;
import com.yeshi.fanli.entity.bus.homemodule.Special;
import com.yeshi.fanli.entity.bus.homemodule.SpecialLabel;
@@ -40,10 +38,8 @@
import com.yeshi.fanli.entity.dynamic.DynamicInfo;
import com.yeshi.fanli.entity.dynamic.GoodsEvaluate;
import com.yeshi.fanli.entity.dynamic.GoodsEvaluate.EvaluateEnum;
import com.yeshi.fanli.entity.dynamic.GoodsPicture;
import com.yeshi.fanli.entity.dynamic.ImgInfo;
import com.yeshi.fanli.entity.dynamic.ImgInfo.ImgEnum;
import com.yeshi.fanli.entity.dynamic.SimpleGoods;
import com.yeshi.fanli.entity.jd.JDGoods;
import com.yeshi.fanli.entity.system.ConfigKeyEnum;
import com.yeshi.fanli.service.inter.common.JumpDetailV2Service;
@@ -70,7 +66,6 @@
import com.yeshi.fanli.util.pinduoduo.PinDuoDuoApiUtil;
import com.yeshi.fanli.util.taobao.DaTaoKeUtil;
import com.yeshi.fanli.vo.dynamic.ArticleVO;
import com.yeshi.fanli.vo.goods.CouponInfoVO;
import com.yeshi.fanli.vo.goods.GoodsDetailVO;
import com.yeshi.fanli.vo.msg.ClientTextStyleVO;

@@ -596,8 +591,6 @@
        int type = 1;
        if (cid == TYPE_FAQUAN){
            type = 1;
            oldDynamicInfo(acceptData, page, subId, out); // 老版动态
            return;
        } else if (cid == TYPE_SUCAI) {
            type = 2;
        }
@@ -702,14 +695,6 @@
    @RequestMapping(value = "evaluateShare", method = RequestMethod.POST)
    public void evaluateShare(AcceptData acceptData, Long uid, String id, Integer type, Long goodsId, Integer goodsType,
            PrintWriter out) {
		
        // 老版动态
        if (1 > 0) {
            oldDynamicShare(acceptData, uid, id, type, goodsId, goodsType, out);
            return;
        }
		
		
        if (uid == null) {
            out.print(JsonUtil.loadFalseResult("用户未登录"));
            return;
@@ -944,251 +929,5 @@
        out.print(JsonUtil.loadTrueResult(data));
    }
    
	
    public void oldDynamicInfo(AcceptData acceptData, Integer page, String subId, PrintWriter out) {
        long cid = 1;
        Long sid = null;
        if (!StringUtil.isNullOrEmpty(subId)){
            sid = Long.parseLong(subId);
        }
        List<DynamicInfo> listd = dynamicInfoService.queryV2(2, 74, (page - 1) * Constant.PAGE_SIZE, Constant.PAGE_SIZE,
                cid, sid);
        if (listd == null) {
            listd = new ArrayList<DynamicInfo>();
        }

        List<GoodsEvaluate> list = new ArrayList<>();
        for (DynamicInfo info : listd) {
            GoodsEvaluate goodsEvaluate = new GoodsEvaluate();
            goodsEvaluate.setId(info.getId());
            ActivityUser user = info.getUser();
            goodsEvaluate.setUser(user);
            List<ClientTextStyleVO> titles = info.getTitle();
            if (titles != null) {
                goodsEvaluate.setTitle(info.getTitle().get(0).getContent());
            } else {
                goodsEvaluate.setTitle("");
            }
            goodsEvaluate.setShareNum(info.getShareCount());
            goodsEvaluate.setPublishTime(info.getCreateTime());
            goodsEvaluate.setLineNum(2);
            List<GoodsPicture> imgs = info.getImgs();

            int i = 0; 
            GoodsDetailVO goods= null;
            List<ImgInfo> imgList = new ArrayList<>();
            for (GoodsPicture goodsPicture : imgs) {
                ImgInfo imgInfo = new ImgInfo();
                imgInfo.setH(1);
                imgInfo.setW(1);
                imgInfo.setLarge(false);
                imgInfo.setUrl(goodsPicture.getUrl());
                imgInfo.setUrlHD(goodsPicture.getUrl());
			    
                GoodsDetailVO goodsVO = goodsPicture.getGoodsVO();
                if (goodsVO == null) {
                    imgInfo.setType(ImgEnum.img);
                } else {
                    imgInfo.setType(ImgEnum.goods);
                    SimpleGoods simpleGoods = new SimpleGoods();
                    simpleGoods.setGoodsId(goodsVO.getGoodsId());
                    simpleGoods.setGoodsType(goodsVO.getGoodsType());
					
                    CouponInfoVO couponInfo = goodsVO.getCouponInfo();
                    if (couponInfo == null) {
                        simpleGoods.setState(0);
                        simpleGoods.setPrice(goodsVO.getZkPrice());
                    } else {
                        simpleGoods.setState(goodsVO.getState());
                        simpleGoods.setPrice(goodsVO.getCouponPrice());
                        simpleGoods.setAmount(couponInfo.getAmount());
                    }
                    imgInfo.setGoods(simpleGoods);
                    goods = goodsVO;
                    i++;
                }
                imgList.add(imgInfo);
            }
			
            goodsEvaluate.setImgList(imgList);
            if (i == 1) {
                goodsEvaluate.setGoods(goods);
            }
            list.add(goodsEvaluate);
        }

        GsonBuilder gsonBuilder = new GsonBuilder().excludeFieldsWithoutExposeAnnotation();
        gsonBuilder.registerTypeAdapter(CommentInfoEnum.class, new JsonSerializer<CommentInfoEnum>() {
            @Override
            public JsonElement serialize(CommentInfoEnum value, Type theType, JsonSerializationContext context) {
                if (value == null) {
                    return new JsonPrimitive(1);
                } else {
                    return new JsonPrimitive(value.getDesc());
                }
            }
        }).registerTypeAdapter(ImgEnum.class, new JsonSerializer<ImgEnum>() {
            @Override
            public JsonElement serialize(ImgEnum value, Type theType, JsonSerializationContext context) {
                if (value == null) {
                    return new JsonPrimitive("");
                } else {
                    return new JsonPrimitive(value.getVlaue());
                }
            }
        }).registerTypeAdapter(Date.class, new JsonSerializer<Date>() {
            @Override
            public JsonElement serialize(Date value, Type theType, JsonSerializationContext context) {
                String desc = "";
                if (value != null) {
                    // 判断是否是同一天

                    Calendar calendar = Calendar.getInstance();
                    calendar.setTime(value);
                    int y1 = calendar.get(Calendar.YEAR);// 获取年份
                    int d1 = calendar.get(Calendar.DAY_OF_YEAR);// 获取年中第几天

                    Date nowDate = new Date();
                    Calendar calendar2 = Calendar.getInstance();
                    calendar2.setTime(nowDate);
                    int y2 = calendar2.get(Calendar.YEAR);// 获取年份
                    int d2 = calendar2.get(Calendar.DAY_OF_YEAR);// 获取年中第几天

                    long old = value.getTime();
                    long now = nowDate.getTime();
                    if (y1 == y2) {
                        if (d1 == d2) {
                            long cha = now - old;
                            if (cha < 1000 * 60 * 2L) {
                                desc = "刚刚";
                            } else if (cha < 1000 * 60 * 60L) {
                                desc = (cha / (1000 * 60)) + "分钟前";
                            } else {
                                desc = (cha / (1000 * 60 * 60)) + "小时前";
                            }
                        } else if (d2 - d1 == 1) {
                            desc = "昨天";
                        } else {
                            desc = (d2 - d1) + "天前";
                        }
                    } else {
                        int timeDistance = 0;
                        for (int i = y1; i < y2; i++) {
                            if (i % 4 == 0 && i % 100 != 0 || i % 400 == 0) {
                                timeDistance += 366; // 闰年
                            } else {
                                timeDistance += 365; // 不是闰年
                            }
                        }
                        desc = timeDistance + (d2 - d1) + "天前";
                    }

                    return new JsonPrimitive(desc);
                }

                return new JsonPrimitive("");
            }
        });
        Gson gson = gsonBuilder.create();
		
        JSONObject data = new JSONObject();
        data.put("list", gson.toJson(list));
        data.put("count",  dynamicInfoService.count(cid, sid));
        out.print(JsonUtil.loadTrueResult(data));
    }
	
    public void oldDynamicShare(AcceptData acceptData, Long uid, String id, Integer type, Long goodsId, Integer goodsType,
            PrintWriter out) {
        if (uid == null) {
            out.print(JsonUtil.loadFalseResult("用户未登录"));
            return;
        }

        if (StringUtil.isNullOrEmpty(id) || type == null) {
            out.print(JsonUtil.loadFalseResult("传递参数不能为空"));
            return;
        }

        if (type == 1 && (goodsId == null || goodsType == null)) {
            out.print(JsonUtil.loadFalseResult("商品参数不能为空"));
            return;
        }

        DynamicInfo dynamicInfo = dynamicInfoService.getById(id);
        if (dynamicInfo == null) {
            out.print(JsonUtil.loadFalseResult("该内容已不存在"));
            return;
        }
		
        UserInfo user = userInfoService.getUserByIdWithMybatis(uid);
        if (user == null) {
            out.print(JsonUtil.loadFalseResult("用户未登录"));
            return;
        }

        if (user != null && user.getState() != UserInfo.STATE_NORMAL) {
            out.print(JsonUtil.loadFalseResult(Constant.CODE_FORBIDDEN_USER, Constant.FORBIDDEN_USER_REASON_DESC));
            return;
        }

        UserExtraTaoBaoInfo taoBaoInfo = userExtraTaoBaoInfoService.getByUid(uid);
        String relationId = null;
        if (taoBaoInfo != null && taoBaoInfo.getRelationId() != null && taoBaoInfo.getRelationValid() != null
                && taoBaoInfo.getRelationValid() == true)
            relationId = taoBaoInfo.getRelationId();

        if (StringUtil.isNullOrEmpty(relationId)) {
            out.print(JsonUtil.loadFalseResult(2, "淘宝未授权，请前往\"我的\"绑定淘宝账号"));
            return;
        }

        String inviteCode = userInfoExtraService.getInviteCodeByUid(uid);
        if (StringUtil.isNullOrEmpty(inviteCode)) {
            out.print(JsonUtil.loadFalseResult(1, "邀请码未激活"));
            return;
        }

        List<GoodsPicture> imgs = dynamicInfo.getImgs();
        if (imgs == null) {
            out.print(JsonUtil.loadFalseResult("该图片内容已不存在"));
            return;
        }

        List<String> list = new ArrayList<>();
        // 热销为单品
        for (GoodsPicture imgInfo : imgs) {
            GoodsDetailVO goodsVO = imgInfo.getGoodsVO();
            if (goodsVO == null) {
                list.add(imgInfo.getUrl());
                continue;
            }

            String jumpLink = getJumpLink(goodsVO, user, inviteCode);
            if (!StringUtil.isNullOrEmpty(jumpLink)) {
                list.add(jumpLink);
            }
        }

        Integer shareCount = dynamicInfo.getShareCount();
        if (shareCount == null) {
            shareCount = 0;
        }

        if (type == 3) {
            shareCount++;
            dynamicInfoService.updateShareCount(dynamicInfo);
        }
		
        if (list.size() == 0) {
            out.print(JsonUtil.loadFalseResult("该信息已下架"));
            return;
        }

        JSONObject data = new JSONObject();
        data.put("count", shareCount);
        data.put("list", list);
        out.print(JsonUtil.loadTrueResult(data));
    }

}


 fanli/src/main/java/com/yeshi/fanli/service/impl/dynamic/DynamicInfoServiceImpl.java

@@ -1,1237 +1,1249 @@
package com.yeshi.fanli.service.impl.dynamic;



import java.io.InputStream;

import java.lang.reflect.InvocationTargetException;

import java.math.BigDecimal;

import java.text.SimpleDateFormat;

import java.util.ArrayList;

import java.util.Date;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import java.util.UUID;



import javax.annotation.Resource;



import org.apache.commons.beanutils.PropertyUtils;

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.HttpUtil;

import org.yeshi.utils.taobao.TbImgUtil;



import com.yeshi.fanli.dao.dynamic.DynamicInfoDao;

import com.yeshi.fanli.dto.ConfigParamsDTO;

import com.yeshi.fanli.dto.taobao.TaoBaoShopDTO;

import com.yeshi.fanli.entity.bus.activity.ActivityRuleUser;

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.common.JumpDetailV2;

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;

import com.yeshi.fanli.entity.taobao.dataoke.DaTaoKeDetailV2;

import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;

import com.yeshi.fanli.log.LogHelper;

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.order.config.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.DaTaoKeGoodsDetailV2Service;

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;

import com.yeshi.fanli.util.dataoke.DaTaoKeApiUtil;

import com.yeshi.fanli.util.factory.goods.GoodsDetailVOFactory;

import com.yeshi.fanli.util.taobao.DaTaoKeUtil;

import com.yeshi.fanli.util.taobao.TaoBaoUtil;

import com.yeshi.fanli.util.taobao.TaoKeApiUtil;

import com.yeshi.fanli.vo.goods.GoodsDetailVO;

import com.yeshi.fanli.vo.msg.ClientTextStyleVO;



import net.sf.json.JSONObject;



@Service

public class DynamicInfoServiceImpl implements DynamicInfoService {



    @Resource(name = "taskExecutor")

    private TaskExecutor executor;



    @Resource

    private DynamicInfoDao dynamicInfoDao;



    @Resource

    private RedisManager redisManager;



    @Resource

    private DaTaoKeGoodsDetailV2Service daTaoKeGoodsDetailV2Service;



    @Resource

    private JumpDetailV2Service jumpDetailV2Service;



    @Resource

    private ActivityUserService activityUserService;



    @Resource

    private TaoBaoGoodsBriefService taoBaoGoodsBriefService;



    @Resource

    private HongBaoManageService hongBaoManageService;



    @Resource

    private TaoBaoShopService taoBaoShopService;



    @Resource

    private InviteMaterialService inviteMaterialService;



    @Resource

    private QrCodeService qrCodeService;



    @Resource

    private TaoBaoGoodsUpdateService taoBaoGoodsUpdateService;



    @Override

    public void insert(DynamicInfo record) {

        dynamicInfoDao.insert(record);

    }



    @Override

    public DynamicInfo getById(String id) {

        return dynamicInfoDao.getById(id);

    }



    @Override

    public void insertTimeInvite() {

        InviteMaterial inviteMaterial = inviteMaterialService.getInviteMaterial();

        if (inviteMaterial == null) {

            return;

        }



        Date date = new Date();

        String materialId = inviteMaterial.getId();

        String content = inviteMaterial.getText();



        ActivityUser user = activityUserService.selectByPrimaryKey(2L);



        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(user);

            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：【邀请链接】");



            content = content.replaceAll("\\,", "\\，").replaceAll("\\.", "\\。").replaceAll("\\;", "\\；")

                    .replaceAll("\\!", "\\！").replaceAll("\\?", "\\？").replaceAll("\\:", "\\：");



            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(user);

            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 (Exception e) {

                try {

                    LogHelper.errorDetailInfo(e);

                } catch (Exception e1) {

                    e1.printStackTrace();

                }

            }

        }

        // 更新素材状态

        inviteMaterialService.updateState(1, materialId);

    }



    @Override

    public void insertShopInfo() {

        List<String> brandIdList = DaTaoKeApiUtil.getBrandIdList();

        if (brandIdList == null || brandIdList.size() == 0) {

            LogHelper.test("大淘客品牌id获取失败（DynamicInfoService-insertShopInfo）");

            return;

        }



        Long classId = 3L;

        Long subclassId = 0L;

        List<DynamicInfo> listInfo = dynamicInfoDao.query(classId, subclassId);



        // 清理已存在品牌

        if (listInfo != null && listInfo.size() > 0) {

            for (int i = 0; i < brandIdList.size(); i++) {

                String brandId = brandIdList.get(i);



                for (int j = 0; j < listInfo.size(); j++) {

                    String id = listInfo.get(j).getId();

                    if (brandId.equals(id)) {

                        brandIdList.remove(brandId);

                        i--;



                        listInfo.remove(listInfo.get(j));

                        j--;

                    }

                }

            }

        }



        if (brandIdList == null || brandIdList.size() == 0) {

            LogHelper.test("大淘客品牌已全部爬取（DynamicInfoService-insertShopInfo）");

            return;

        }



        int index = (int) (Math.random() * brandIdList.size());

        String brandId = brandIdList.get(index);



        TaoBaoShopDTO dynamicShopInfo = DaTaoKeApiUtil.getDynamicShopInfo(brandId);

        if (dynamicShopInfo == null) {

            LogHelper.test("大淘客品牌信息爬取失败（DynamicInfoService-insertShopInfo）");

            return;

        }



        List<TaoBaoGoodsBrief> listGoods = dynamicShopInfo.getListGoods();

        if (listGoods == null || listGoods.size() == 0) {

            LogHelper.test("大淘客品牌商品信息爬取失败（DynamicInfoService-insertShopInfo）");

            return;

        }



        Long sellerId = dynamicShopInfo.getSellerId();

        TaoBaoGoodsBrief taoBaoGoodsBrief = listGoods.get(0);

        TaoBaoShop taoBaoShop = taoBaoShopService.getTaoBaoShop(taoBaoGoodsBrief.getAuctionId(), sellerId);

        if (taoBaoShop == null) {

            LogHelper.test("店铺详情信息获取失败（DynamicInfoService-insertShopInfo）");

            return;

        }

        String shopLink = taoBaoShop.getShopLink();

        if (StringUtil.isNullOrEmpty(shopLink)) {

            taoBaoShop.setShopLink(TaoBaoUtil.getShopLink(taoBaoShop.getId()));

        }

		
        if(StringUtil.isNullOrEmpty(taoBaoShop.getShopIcon())) 
            taoBaoShop.setShopIcon(dynamicShopInfo.getShopIcon());



        DynamicInfo dynamicVO = new DynamicInfo();

        dynamicVO.setId(brandId);

        dynamicVO.setClassId(classId);

        dynamicVO.setSubclassId(subclassId);

        dynamicVO.setShowType(DynamicInfo.SHOW_TYPE_TWO);

        dynamicVO.setShop(taoBaoShop);

        List<ActivityRuleUser> userList = activityUserService.listByRuleCode(ActivityRuleUser.RULE_HAODIAN, 1, 50);

        dynamicVO.setUser(userList.get((int) (userList.size() * Math.random())).getActivityUser());

        dynamicVO.setCreateTime(DateUtil.reduceRandomMinute(new Date(), 8));

        dynamicVO.setUpdateTime(new Date());



        // 介绍内容

        ClientTextStyleVO row1 = new ClientTextStyleVO();

        row1.setColor("#333333");

        row1.setContent(dynamicShopInfo.getBrandDes());

        List<ClientTextStyleVO> listTitle = new ArrayList<ClientTextStyleVO>();

        listTitle.add(row1);

        dynamicVO.setTitle(listTitle);



        // 商品信息

        List<GoodsPicture> listPicture = new ArrayList<GoodsPicture>();

        for (TaoBaoGoodsBrief goodsBrief : listGoods) {

            BigDecimal proportion = hongBaoManageService.getFanLiRate();

            TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief,

                    proportion.toString(), null);

            taoBaoGoodsBriefExtra.setCouponInfo(null);

            taoBaoGoodsBriefExtra.setUpdatetime(new Date());



            if (!taoBaoGoodsBriefExtra.isCoupon()) {

                taoBaoGoodsBriefExtra.setState(1);

            }



            String goodsId = goodsBrief.getAuctionId().toString();

            JSONObject item = new JSONObject();

            item.put("id", goodsId);

            item.put("from", "dynamics");



            GoodsPicture goodsPicture = new GoodsPicture();

            goodsPicture.setH(100);

            goodsPicture.setW(100);

            goodsPicture.setUrl(TbImgUtil.getTBSize320Img(goodsBrief.getPictUrl()));

            goodsPicture.setJumpDetail(jumpDetailV2Service.getByTypeCache("goodsdetail"));

            goodsPicture.setParams(item.toString());

            goodsPicture.setGoods(taoBaoGoodsBriefExtra);



            listPicture.add(goodsPicture);

        }

        dynamicVO.setImgs(listPicture);



        dynamicInfoDao.insert(dynamicVO);

    }



    @Override

    public void insertTimeRecommend() {

        try {

            Long classId = 2L;

            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.4) {

                count = 9;

            } else {

                count = 4;

            }



            List<DaTaoKeDetailV2> listDaTaoKe = daTaoKeGoodsDetailV2Service.getGoodsNotInList(subclassId, null, count);



            DaTaoKeDetailV2 daTaoKeDetail = null;

            // 商品列表

            List<GoodsPicture> listPicture = new ArrayList<GoodsPicture>();

            // 商品列表

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

            // 分享奖金

            BigDecimal shareMoney = new BigDecimal(0);



            BigDecimal proportion = hongBaoManageService.getFanLiRate();

            for (DaTaoKeDetailV2 daTaoKe : listDaTaoKe) {

                if (daTaoKeDetail == null) {

                    daTaoKeDetail = daTaoKe;

                }

                // 分享奖金

                TaoBaoGoodsBrief taoBaoGoodsBrief = TaoBaoUtil.convert(daTaoKe);

                listGoods.add(taoBaoGoodsBrief);



                TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief,

                        proportion.toString(), null);

                if (!taoBaoGoodsBriefExtra.isCoupon()) {

                    taoBaoGoodsBriefExtra.setState(1);

                }



                BigDecimal money = taoBaoGoodsBriefService.getShareGoodsUserHongBao(taoBaoGoodsBrief);

                shareMoney = MoneyBigDecimalUtil.add(shareMoney, money);

                // 商品图片

                taoBaoGoodsBriefExtra.setUpdatetime(new Date());

                taoBaoGoodsBriefExtra.setCouponInfo(null);

                GoodsPicture goodsPicture = getGoodsPicture(daTaoKe);

                goodsPicture.setGoods(taoBaoGoodsBriefExtra);



                listPicture.add(goodsPicture);

            }



            // 组织动态信息

            DynamicInfo dynamicInfo = getDynamicInfo(daTaoKeDetail, classId, subclassId);

            // 无内容

            dynamicInfo.setTitle(new ArrayList<ClientTextStyleVO>());

            // 发布用户

            dynamicInfo.setUser(activityUserService.getRandomByDaTaoKeCid(cid));

            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 (count == 4) {

                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

    public void insertTimeHotSale() {

        Long classId = 1L;

        try {

            for (int i = 0; i < 3; i++) {

                boolean addSuccess = saveHotSale(classId, 0L);

                if (addSuccess) {

                    break;

                }

            }

        } catch (Exception e) {

            try {

                LogHelper.errorDetailInfo(e);

            } catch (Exception e1) {

                e1.printStackTrace();

            }

        }



        // 热销单品的分类

        List<GoodsClass> list = DaTaoKeUtil.goodsClasses;

        for (GoodsClass goodsClass : list) {

            try {

                for (int i = 0; i < 3; i++) {

                    boolean addSuccess = saveHotSale(classId, goodsClass.getId());

                    if (addSuccess) {

                        break;

                    }

                }

            } catch (Exception e) {

                try {

                    LogHelper.errorDetailInfo(e);

                } catch (Exception e1) {

                    e1.printStackTrace();

                }

            }

        }

    }



    /**

     * 保存热销单品

     * 
     * @param classId

     * @param subclassId

     * @throws TaobaoGoodsDownException

     */

    public boolean saveHotSale(Long classId, Long subclassId) throws TaobaoGoodsDownException {

        boolean addSuccess = false;

        List<Long> listId = null;

        List<DynamicInfo> listInfo = dynamicInfoDao.query(classId, subclassId);

        if (listInfo != null && listInfo.size() > 0) {

            listId = new ArrayList<Long>();

            for (DynamicInfo dynamicInfo : listInfo) {

                Long daTaoKeId = dynamicInfo.getDaTaoKeId();

                if (daTaoKeId != null) {

                    listId.add(dynamicInfo.getDaTaoKeId());

                }

            }

        }

        // 大淘客数据

        DaTaoKeDetailV2 daTaoKe = daTaoKeGoodsDetailV2Service.getGoodsNotInList(subclassId, listId, 1).get(0);

        if (daTaoKe == null) {

            return addSuccess;

        }



        try {

            daTaoKe = DaTaoKeUtil.filterDaTaoKe(TaoKeApiUtil.searchGoodsDetail(daTaoKe.getGoodsId()), daTaoKe);

        } catch (Exception e) {



        }



        TaoBaoGoodsBrief taoBaoGoodsBrief = TaoBaoUtil.convert(daTaoKe);

        BigDecimal proportion = hongBaoManageService.getFanLiRate();

        TaoBaoGoodsBriefExtra goodsExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion.toString(),

                null);



        if (!goodsExtra.isCoupon() || (goodsExtra.getState() != null && goodsExtra.getState() == 1)) {

            return addSuccess; // 已下架 、无券 不加入

        }



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

        listGoods.add(taoBaoGoodsBrief);



        goodsExtra.setTkRate(taoBaoGoodsBrief.getTkRate());

        goodsExtra.setUpdatetime(new Date());

        goodsExtra.setCouponInfo(null);



        GoodsPicture goodsPicture = getGoodsPicture(daTaoKe);

        goodsPicture.setGoods(goodsExtra);

        // 商品列表

        List<GoodsPicture> listPicture = new ArrayList<GoodsPicture>();

        listPicture.add(goodsPicture);



        // 获取商品列表图片

        TaoBaoGoodsBrief taoBaoGoodsBrief2 = TaoKeApiUtil.getSimpleGoodsInfo(daTaoKe.getGoodsId());

        List<String> imgList = taoBaoGoodsBrief2.getImgList();

        List<String> listimgs = new ArrayList<String>();

        String pic = daTaoKe.getMainPic();

        listimgs.add(TbImgUtil.getTBSize320Img(pic));

        if (imgList != null && imgList.size() > 0) {

            for (String img : imgList) {



                if (listPicture.size() >= 4) {

                    break;

                }

                if (pic.equals(img)) {

                    continue;

                }



                listimgs.add(img);

                GoodsPicture picture = new GoodsPicture();

                picture.setH(100);

                picture.setW(100);

                picture.setUrl(TbImgUtil.getTBSize320Img(img));

                listPicture.add(picture);

            }

        }

        goodsExtra.setImgList(imgList);



        // 分享奖金

        BigDecimal shareMoney = taoBaoGoodsBriefService.getShareGoodsUserHongBao(taoBaoGoodsBrief);

        ClientTextStyleVO shareMoneyDesc = new ClientTextStyleVO();

        shareMoneyDesc.setColor("#FFFFFF");

        shareMoneyDesc.setBottomColor("#E8AE48");

        shareMoneyDesc.setContent("预估分享奖金：¥" + shareMoney);



        // 组织动态信息

        DynamicInfo dynamicInfo = getDynamicInfo(daTaoKe, classId, subclassId);

        dynamicInfo.setUser(activityUserService.getRandomByDaTaoKeCid(daTaoKe.getCid()));

        dynamicInfo.setImgs(listPicture);

        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)) {

            int index = desc.lastIndexOf("\n");

            String newDesc = desc.substring(index + 1);

            if (StringUtil.isNullOrEmpty(newDesc)) {

                desc = desc.substring(0, index);

            }

        }

        dynamicInfo.setTitle(convertIntroduce(desc));



        // 保存信息

        dynamicInfoDao.insert(dynamicInfo);



        addSuccess = true;

        return addSuccess;

    }



    /**

     * 数据组织存入MongoDB中

     * 
     * @param daTaoKe

     * @param classId

     * @param subclassId

     * @throws TaobaoGoodsDownException

     */

    public DynamicInfo getDynamicInfo(DaTaoKeDetailV2 daTaoKe, Long classId, Long subclassId) {

        DynamicInfo dynamicInfo = new DynamicInfo();

        dynamicInfo.setId(UUID.randomUUID().toString().replace("-", ""));

        dynamicInfo.setClassId(classId);

        dynamicInfo.setSubclassId(subclassId);

        dynamicInfo.setDaTaoKeId(daTaoKe.getId());

        dynamicInfo.setCreateTime(DateUtil.reduceRandomMinute(new Date(), 8));

        dynamicInfo.setUpdateTime(new Date());

        // 随机分享次数

        dynamicInfo.setShareCount(1000 + (int) (Math.random() * 8000));



        return dynamicInfo;

    }



    /**

     * 文字内容

     * 
     * @param introduce

     * @return

     */

    public List<ClientTextStyleVO> convertIntroduce(String introduce) {

        List<ClientTextStyleVO> title = new ArrayList<ClientTextStyleVO>();

        ClientTextStyleVO desc = new ClientTextStyleVO();

        desc.setColor("#333333");

        desc.setContent(introduce);

        title.add(desc);

        return title;

    }



    /**

     * 图片列表

     * 
     * @param daTaoKe

     * @return

     */

    public GoodsPicture getGoodsPicture(DaTaoKeDetailV2 daTaoKe) {

        GoodsPicture goodsPicture = new GoodsPicture();

        goodsPicture.setH(100);

        goodsPicture.setW(100);

        goodsPicture.setUrl(TbImgUtil.getTBSize320Img(daTaoKe.getMainPic()));

        goodsPicture.setJumpDetail(jumpDetailV2Service.getByTypeCache("goodsdetail"));



        String goodsId = daTaoKe.getGoodsId().toString();

        JSONObject item = new JSONObject();

        item.put("id", goodsId);

        item.put("from", "dynamics");

        goodsPicture.setParams(item.toString());

        return goodsPicture;

    }



    @Override

    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;

        }



        // 判断是否已存在

        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);

        dynamicVO.setSubclassId(0L);

        dynamicVO.setShareType(DynamicInfo.SHARE_TYPE_INVITE);

        dynamicVO.setUpdateTime(new Date());



        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.selectByPrimaryKey(2L));

        } else {

            dynamicVO.setUser(activityUser);

        }



        // 介绍内容

        List<ClientTextStyleVO> listtitle = new ArrayList<ClientTextStyleVO>();

        if (!StringUtil.isNullOrEmpty(title)) {

            ClientTextStyleVO row1 = new ClientTextStyleVO();

            row1.setColor("#333333");

            row1.setContent(title);

            listtitle.add(row1);

        }



        // 图片

        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();

            }



            InputStream asInputStream = HttpUtil.getAsInputStream(picUrl);

			
            int index = picUrl.lastIndexOf("/");

            String newUrl = picUrl.substring(index + 1);

            String urlMd5 = newUrl.substring(0, newUrl.lastIndexOf("."));

			
            // 图片

            String imgLink = qrCodeService.drawInviteQrCodeNew(asInputStream, urlMd5, 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

    public void removeByDate(Date createTime) {

        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;

    }



    private Map<Long, TaoBaoGoodsBrief> getFilterGoodsMap(List<DynamicInfo> list) {

        // 提取过滤商品

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

        for (DynamicInfo dynamicInfo : list) {

            List<GoodsPicture> gpList = dynamicInfo.getImgs();

            if (gpList != null)

                for (GoodsPicture gp : gpList) {

                    if (gp != null && gp.getGoods() != null) {

                        TaoBaoGoodsBriefExtra newGoods = new TaoBaoGoodsBriefExtra();

                        try {

                            PropertyUtils.copyProperties(newGoods, gp.getGoods());

                            goodsList.add(newGoods);

                        } catch (IllegalAccessException e) {

                            e.printStackTrace();

                        } catch (InvocationTargetException e) {

                            e.printStackTrace();

                        } catch (NoSuchMethodException e) {

                            e.printStackTrace();

                        }



                    }

                }

        }

        goodsList = taoBaoGoodsUpdateService.filterImportantTaoBaoGoods(goodsList);

        Map<Long, TaoBaoGoodsBrief> map = new HashMap<>();

        if (goodsList != null)

            for (TaoBaoGoodsBrief goods : goodsList)

                map.put(goods.getAuctionId(), goods);

        return map;

    }



    @Override

    @Cacheable(value = "dynamicCache", key = "'queryV2-'+#platform+'-'+#version+'-'+#start+'-'+#count+'-'+#cid+'-'+#subId")

    public List<DynamicInfo> queryV2(int platform, int version, int start, int count, Long cid, Long subId) {

        List<DynamicInfo> listNew = new ArrayList<DynamicInfo>();

        List<DynamicInfo> list = dynamicInfoDao.query(start, count, cid, subId);

        // 需要更新的商品

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

        if (list != null && list.size() > 0) {

            // 提取商品

            Map<Long, TaoBaoGoodsBrief> goodsMap = getFilterGoodsMap(list);



            BigDecimal fanLiRate = hongBaoManageService.getFanLiRate();

            BigDecimal shareRate = hongBaoManageService.getShareRate();

            ConfigParamsDTO paramsDTO = new ConfigParamsDTO(fanLiRate, shareRate, Constant.MAX_REWARD_RATE,hongBaoManageService.getVIPFanLiRate());



            for (DynamicInfo dynamicInfo : list) {

                DynamicInfo dynamicNew = new DynamicInfo();

                try {

                    PropertyUtils.copyProperties(dynamicNew, dynamicInfo);

                } catch (Exception e) {

                    e.printStackTrace();

                    continue;

                }



                // 店铺信息

                TaoBaoShop shop = dynamicNew.getShop();

                if (shop != null) {

                    TaoBaoShop shopNew = new TaoBaoShop();

                    try {

                        PropertyUtils.copyProperties(shopNew, shop);

                    } catch (Exception e) {

                        e.printStackTrace();

                        continue;

                    }

                    Integer userType = shopNew.getUserType();

                    if (userType == null || userType == 0) {

                        shopNew.setUserType(10);

                    } else {

                        shopNew.setUserType(11);

                    }

                    dynamicNew.setShop(shopNew);

                }



                List<GoodsPicture> imgsNew = new ArrayList<GoodsPicture>();

                List<GoodsPicture> imgs = dynamicNew.getImgs();

                if (imgs != null && imgs.size() > 0) {

                    for (GoodsPicture goodsPicture : imgs) {

                        TaoBaoGoodsBriefExtra goods = goodsPicture.getGoods();

                        if (goods == null) {

                            imgsNew.add(goodsPicture);

                            continue;

                        }



                        taoBaoGoodsUpdateList.add(goods);



                        GoodsPicture goodsNew = new GoodsPicture();

                        try {

                            PropertyUtils.copyProperties(goodsNew, goodsPicture);

                        } catch (Exception e) {

                            e.printStackTrace();

                            continue;

                        }



                        // 过滤券信息与资金信息

                        goods.setCouponAmount(goodsMap.get(goods.getAuctionId()).getCouponAmount());

                        goods.setZkPrice(goodsMap.get(goods.getAuctionId()).getZkPrice());

                        goods.setCouponStartFee(goodsMap.get(goods.getAuctionId()).getCouponStartFee());

                        goods.setTkRate(goodsMap.get(goods.getAuctionId()).getTkRate());



                        GoodsDetailVO detailVO = GoodsDetailVOFactory.convertTaoBaoGoodsBriefExtra(goods, paramsDTO);



                        goodsNew.setGoodsVO(detailVO);

                        goodsNew.setGoods(null);



                        JumpDetailV2 jumpDetail = goodsNew.getJumpDetail();

                        if (jumpDetail != null) {

                            JumpDetailV2 jumpDetailV2 = jumpDetailV2Service.getByTypeCache(jumpDetail.getType(),

                                    platform, version);

                            if (jumpDetailV2 != null) {

                                goodsNew.setJumpDetail(jumpDetailV2);

                            }

                        }



                        imgsNew.add(goodsNew);

                    }

                    dynamicNew.setImgs(imgsNew);

                }

                listNew.add(dynamicNew);

            }

        }



        // 更新商品信息

        executor.execute(new Runnable() {

            @Override

            public void run() {

                updateGoodInfo(list);

            }

        });



        taoBaoGoodsUpdateService.addUpdateQueueAsync(taoBaoGoodsUpdateList);

        return listNew;

    }



    /**

     * 更新商品信息

     */

    public void updateGoodInfo(List<DynamicInfo> list) {

        if (!Constant.IS_OUTNET) {

            return; // 外网进行更新

        }



        if (list == null || list.size() == 0) {

            return;

        }



        try {

            BigDecimal proportion = hongBaoManageService.getFanLiRate();

            for (DynamicInfo dynamicInfo : list) {

                // 邀请数据不做更新

                long classId = dynamicInfo.getClassId();

                if (classId == 4) {

                    break;

                }



                // 更新商品信息

                List<GoodsPicture> listPicture = dynamicInfo.getImgs();

                if (listPicture == null || listPicture.size() == 0) {

                    continue;

                }



                // 是否一个小时之内已更新

                Date updateTime = dynamicInfo.getUpdateTime();

                if (updateTime != null) {

                    long nd = 1000 * 24 * 60 * 60;// 一天的毫秒数

                    long nh = 1000 * 60 * 60;// 一小时的毫秒数

                    long diff = System.currentTimeMillis() - updateTime.getTime();

                    long day = diff / nd;// 计算差多少天

                    long hour = diff % nd / nh + day * 24;// 计算差多少小时

                    if (hour < 1) {

                        continue;

                    }

                }



                boolean needUpdate = false;

                // 已下架ID

                List<Long> listDown = new ArrayList<Long>();

                // 商品列表

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



                for (GoodsPicture goodsPicture : listPicture) {

                    TaoBaoGoodsBriefExtra oldExtra = goodsPicture.getGoods();

                    if (oldExtra == null) {

                        continue;

                    }



                    /*

                     * Integer state = oldExtra.getState(); if (state != null && state == 1) {

                     * continue; }

                     */



                    TaoBaoGoodsBrief goodsBrief = null;

                    try {

                        goodsBrief = redisManager.getTaoBaoGoodsBrief(oldExtra.getAuctionId());

                    } catch (TaobaoGoodsDownException e) {

                    }



                    // 是否下架 ： 1、商品本身下架 2、无券信息则认为下架

                    boolean isDown = true;



                    if (goodsBrief == null) {

                        listDown.add(oldExtra.getAuctionId()); // 下架商品

                    } else if (goodsBrief.getCouponAmount() != null

                            && goodsBrief.getCouponAmount().compareTo(BigDecimal.valueOf(0)) > 0) {

                        isDown = false;

                    }



                    if (isDown) {

                        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);

                        }

                    } else {

                        listGoods.add(goodsBrief);



                        TaoBaoGoodsBriefExtra newExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief,

                                proportion.toString(), null);

                        newExtra.setUpdatetime(new Date());

                        goodsPicture.setGoods(newExtra);



                        // 更新热销单品的分享奖金

                        if (classId == 1) {

                            BigDecimal shareMoney = taoBaoGoodsBriefService.getShareGoodsUserHongBao(goodsBrief);

                            ClientTextStyleVO shareMoneyDesc = new ClientTextStyleVO();

                            shareMoneyDesc.setColor("#FFFFFF");

                            shareMoneyDesc.setBottomColor("#E8AE48");

                            shareMoneyDesc.setContent("预估分享奖金：¥" + shareMoney);

                            dynamicInfo.setDesc(shareMoneyDesc);

                        }

                    }



                    // 需要更新信息；

                    needUpdate = true;

                }



                // 无效更新信息

                if (!needUpdate) {

                    continue;

                }



                // 更新商品信息

                dynamicInfo.setImgs(listPicture);



                // 商品已下架

                List<TaoBaoGoodsBrief> listGoodsBrief = dynamicInfo.getListGoodsBrief();

                if (listGoodsBrief != null && listGoodsBrief.size() > 0) {

                    // 淘宝已下架商品

                    if (listDown.size() > 0) {

                        for (TaoBaoGoodsBrief taoBaoGoodsBrief : listGoodsBrief) {

                            if (listDown.contains(taoBaoGoodsBrief.getAuctionId())) {

                                taoBaoGoodsBrief.setState(1);

                            }

                        }

                    }



                    if (listGoods.size() == 0) {

                        dynamicInfo.setListGoodsBrief(listGoodsBrief);

                    } else {

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

                        for (int i = 0; i < listGoodsBrief.size(); i++) {

                            TaoBaoGoodsBrief taoBaoGoodsBrief = listGoodsBrief.get(i);

                            if (taoBaoGoodsBrief.getState() != null && taoBaoGoodsBrief.getState() == 1) {

                                listNew.add(taoBaoGoodsBrief);

                            } else {

                                boolean isUpdate = false;

                                Long auctionId = taoBaoGoodsBrief.getAuctionId();

                                for (TaoBaoGoodsBrief goods : listGoods) {

                                    if (goods.getAuctionId().equals(auctionId) || goods.getAuctionId() == auctionId) {

                                        listNew.add(goods);

                                        isUpdate = true;

                                        break;

                                    }

                                }



                                if (!isUpdate) {

                                    listNew.add(taoBaoGoodsBrief);

                                }

                            }

                        }

                        dynamicInfo.setListGoodsBrief(listNew);

                    }

                }

                dynamicInfo.setUpdateTime(new Date());

                dynamicInfoDao.updateGoodInfo(dynamicInfo);

            }

        } catch (Exception e) {

            LogHelper.errorDetailInfo(e);

        }



    }



}

package com.yeshi.fanli.service.impl.dynamic;

import java.io.InputStream;
import java.lang.reflect.InvocationTargetException;
import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.UUID;

import javax.annotation.Resource;

import org.apache.commons.beanutils.PropertyUtils;
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.HttpUtil;
import org.yeshi.utils.taobao.TbImgUtil;

import com.yeshi.fanli.dao.dynamic.DynamicInfoDao;
import com.yeshi.fanli.dto.ConfigParamsDTO;
import com.yeshi.fanli.dto.taobao.TaoBaoShopDTO;
import com.yeshi.fanli.entity.bus.activity.ActivityRuleUser;
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.common.JumpDetailV2;
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;
import com.yeshi.fanli.entity.taobao.dataoke.DaTaoKeDetailV2;
import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;
import com.yeshi.fanli.log.LogHelper;
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.GoodsEvaluateService;
import com.yeshi.fanli.service.inter.dynamic.InviteMaterialService;
import com.yeshi.fanli.service.inter.goods.TaoBaoGoodsBriefService;
import com.yeshi.fanli.service.inter.order.config.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.DaTaoKeGoodsDetailV2Service;
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;
import com.yeshi.fanli.util.dataoke.DaTaoKeApiUtil;
import com.yeshi.fanli.util.factory.goods.GoodsDetailVOFactory;
import com.yeshi.fanli.util.taobao.DaTaoKeUtil;
import com.yeshi.fanli.util.taobao.TaoBaoUtil;
import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
import com.yeshi.fanli.vo.goods.GoodsDetailVO;
import com.yeshi.fanli.vo.msg.ClientTextStyleVO;

import net.sf.json.JSONObject;

@Service
public class DynamicInfoServiceImpl implements DynamicInfoService {

    @Resource(name = "taskExecutor")
    private TaskExecutor executor;

    @Resource
    private DynamicInfoDao dynamicInfoDao;

    @Resource
    private RedisManager redisManager;

    @Resource
    private DaTaoKeGoodsDetailV2Service daTaoKeGoodsDetailV2Service;

    @Resource
    private JumpDetailV2Service jumpDetailV2Service;

    @Resource
    private ActivityUserService activityUserService;

    @Resource
    private TaoBaoGoodsBriefService taoBaoGoodsBriefService;

    @Resource
    private HongBaoManageService hongBaoManageService;

    @Resource
    private TaoBaoShopService taoBaoShopService;

    @Resource
    private InviteMaterialService inviteMaterialService;

    @Resource
    private QrCodeService qrCodeService;

    @Resource
    private TaoBaoGoodsUpdateService taoBaoGoodsUpdateService;

    @Resource
    private GoodsEvaluateService goodsEvaluateService;
	
    @Override
    public void insert(DynamicInfo record) {
        dynamicInfoDao.insert(record);
    }

    @Override
    public DynamicInfo getById(String id) {
        return dynamicInfoDao.getById(id);
    }

    @Override
    public void insertTimeInvite() {
        InviteMaterial inviteMaterial = inviteMaterialService.getInviteMaterial();
        if (inviteMaterial == null) {
            return;
        }

        Date date = new Date();
        String materialId = inviteMaterial.getId();
        String content = inviteMaterial.getText();

        ActivityUser user = activityUserService.selectByPrimaryKey(2L);

        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(user);
            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：【邀请链接】");

            content = content.replaceAll("\\,", "\\，").replaceAll("\\.", "\\。").replaceAll("\\;", "\\；")
                    .replaceAll("\\!", "\\！").replaceAll("\\?", "\\？").replaceAll("\\:", "\\：");

            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(user);
            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 (Exception e) {
                try {
                    LogHelper.errorDetailInfo(e);
                } catch (Exception e1) {
                    e1.printStackTrace();
                }
            }
        }
        // 更新素材状态
        inviteMaterialService.updateState(1, materialId);
    }

    @Override
    public void insertShopInfo() {
        List<String> brandIdList = DaTaoKeApiUtil.getBrandIdList();
        if (brandIdList == null || brandIdList.size() == 0) {
            LogHelper.test("大淘客品牌id获取失败（DynamicInfoService-insertShopInfo）");
            return;
        }

        Long classId = 3L;
        Long subclassId = 0L;
        List<DynamicInfo> listInfo = dynamicInfoDao.query(classId, subclassId);

        // 清理已存在品牌
        if (listInfo != null && listInfo.size() > 0) {
            for (int i = 0; i < brandIdList.size(); i++) {
                String brandId = brandIdList.get(i);

                for (int j = 0; j < listInfo.size(); j++) {
                    String id = listInfo.get(j).getId();
                    if (brandId.equals(id)) {
                        brandIdList.remove(brandId);
                        i--;

                        listInfo.remove(listInfo.get(j));
                        j--;
                    }
                }
            }
        }

        if (brandIdList == null || brandIdList.size() == 0) {
            LogHelper.test("大淘客品牌已全部爬取（DynamicInfoService-insertShopInfo）");
            return;
        }

        int index = (int) (Math.random() * brandIdList.size());
        String brandId = brandIdList.get(index);

        TaoBaoShopDTO dynamicShopInfo = DaTaoKeApiUtil.getDynamicShopInfo(brandId);
        if (dynamicShopInfo == null) {
            LogHelper.test("大淘客品牌信息爬取失败（DynamicInfoService-insertShopInfo）");
            return;
        }

        List<TaoBaoGoodsBrief> listGoods = dynamicShopInfo.getListGoods();
        if (listGoods == null || listGoods.size() == 0) {
            LogHelper.test("大淘客品牌商品信息爬取失败（DynamicInfoService-insertShopInfo）");
            return;
        }

        Long sellerId = dynamicShopInfo.getSellerId();
        TaoBaoGoodsBrief taoBaoGoodsBrief = listGoods.get(0);
        TaoBaoShop taoBaoShop = taoBaoShopService.getTaoBaoShop(taoBaoGoodsBrief.getAuctionId(), sellerId);
        if (taoBaoShop == null) {
            LogHelper.test("店铺详情信息获取失败（DynamicInfoService-insertShopInfo）");
            return;
        }
        String shopLink = taoBaoShop.getShopLink();
        if (StringUtil.isNullOrEmpty(shopLink)) {
            taoBaoShop.setShopLink(TaoBaoUtil.getShopLink(taoBaoShop.getId()));
        }
		
        if(StringUtil.isNullOrEmpty(taoBaoShop.getShopIcon())) 
            taoBaoShop.setShopIcon(dynamicShopInfo.getShopIcon());

        DynamicInfo dynamicVO = new DynamicInfo();
        dynamicVO.setId(brandId);
        dynamicVO.setClassId(classId);
        dynamicVO.setSubclassId(subclassId);
        dynamicVO.setShowType(DynamicInfo.SHOW_TYPE_TWO);
        dynamicVO.setShop(taoBaoShop);
        List<ActivityRuleUser> userList = activityUserService.listByRuleCode(ActivityRuleUser.RULE_HAODIAN, 1, 50);
        dynamicVO.setUser(userList.get((int) (userList.size() * Math.random())).getActivityUser());
        dynamicVO.setCreateTime(DateUtil.reduceRandomMinute(new Date(), 8));
        dynamicVO.setUpdateTime(new Date());

        // 介绍内容
        ClientTextStyleVO row1 = new ClientTextStyleVO();
        row1.setColor("#333333");
        row1.setContent(dynamicShopInfo.getBrandDes());
        List<ClientTextStyleVO> listTitle = new ArrayList<ClientTextStyleVO>();
        listTitle.add(row1);
        dynamicVO.setTitle(listTitle);

        // 商品信息
        List<GoodsPicture> listPicture = new ArrayList<GoodsPicture>();
        for (TaoBaoGoodsBrief goodsBrief : listGoods) {
            BigDecimal proportion = hongBaoManageService.getFanLiRate();
            TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief,
                    proportion.toString(), null);
            taoBaoGoodsBriefExtra.setCouponInfo(null);
            taoBaoGoodsBriefExtra.setUpdatetime(new Date());

            if (!taoBaoGoodsBriefExtra.isCoupon()) {
                taoBaoGoodsBriefExtra.setState(1);
            }

            String goodsId = goodsBrief.getAuctionId().toString();
            JSONObject item = new JSONObject();
            item.put("id", goodsId);
            item.put("from", "dynamics");

            GoodsPicture goodsPicture = new GoodsPicture();
            goodsPicture.setH(100);
            goodsPicture.setW(100);
            goodsPicture.setUrl(TbImgUtil.getTBSize320Img(goodsBrief.getPictUrl()));
            goodsPicture.setJumpDetail(jumpDetailV2Service.getByTypeCache("goodsdetail"));
            goodsPicture.setParams(item.toString());
            goodsPicture.setGoods(taoBaoGoodsBriefExtra);

            listPicture.add(goodsPicture);
        }
        dynamicVO.setImgs(listPicture);

        dynamicInfoDao.insert(dynamicVO);
    }

    @Override
    public void insertTimeRecommend() {
        try {
            Long classId = 2L;
            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.4) {
                count = 9;
            } else {
                count = 4;
            }

            List<DaTaoKeDetailV2> listDaTaoKe = daTaoKeGoodsDetailV2Service.getGoodsNotInList(subclassId, null, count);

            DaTaoKeDetailV2 daTaoKeDetail = null;
            // 商品列表
            List<GoodsPicture> listPicture = new ArrayList<GoodsPicture>();
            // 商品列表
            List<TaoBaoGoodsBrief> listGoods = new ArrayList<TaoBaoGoodsBrief>();
            // 分享奖金
            BigDecimal shareMoney = new BigDecimal(0);

            BigDecimal proportion = hongBaoManageService.getFanLiRate();
            for (DaTaoKeDetailV2 daTaoKe : listDaTaoKe) {
                if (daTaoKeDetail == null) {
                    daTaoKeDetail = daTaoKe;
                }
                // 分享奖金
                TaoBaoGoodsBrief taoBaoGoodsBrief = TaoBaoUtil.convert(daTaoKe);
                listGoods.add(taoBaoGoodsBrief);

                TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief,
                        proportion.toString(), null);
                if (!taoBaoGoodsBriefExtra.isCoupon()) {
                    taoBaoGoodsBriefExtra.setState(1);
                }

                BigDecimal money = taoBaoGoodsBriefService.getShareGoodsUserHongBao(taoBaoGoodsBrief);
                shareMoney = MoneyBigDecimalUtil.add(shareMoney, money);
                // 商品图片
                taoBaoGoodsBriefExtra.setUpdatetime(new Date());
                taoBaoGoodsBriefExtra.setCouponInfo(null);
                GoodsPicture goodsPicture = getGoodsPicture(daTaoKe);
                goodsPicture.setGoods(taoBaoGoodsBriefExtra);

                listPicture.add(goodsPicture);
            }

            // 组织动态信息
            DynamicInfo dynamicInfo = getDynamicInfo(daTaoKeDetail, classId, subclassId);
            // 无内容
            dynamicInfo.setTitle(new ArrayList<ClientTextStyleVO>());
            // 发布用户
            dynamicInfo.setUser(activityUserService.getRandomByDaTaoKeCid(cid));
            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 (count == 4) {
                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
    public void insertTimeHotSale() {
        Long classId = 1L;
        try {
            for (int i = 0; i < 3; i++) {
                boolean addSuccess = saveHotSale(classId, 0L);
                if (addSuccess) {
                    break;
                }
            }
        } catch (Exception e) {
            try {
                LogHelper.errorDetailInfo(e);
            } catch (Exception e1) {
                e1.printStackTrace();
            }
        }

        // 热销单品的分类
        List<GoodsClass> list = DaTaoKeUtil.goodsClasses;
        for (GoodsClass goodsClass : list) {
            try {
                for (int i = 0; i < 3; i++) {
                    boolean addSuccess = saveHotSale(classId, goodsClass.getId());
                    if (addSuccess) {
                        break;
                    }
                }
            } catch (Exception e) {
                try {
                    LogHelper.errorDetailInfo(e);
                } catch (Exception e1) {
                    e1.printStackTrace();
                }
            }
        }
    }

    /**
     * 保存热销单品
     * 
     * @param classId
     * @param subclassId
     * @throws TaobaoGoodsDownException
     */
    public boolean saveHotSale(Long classId, Long subclassId) throws TaobaoGoodsDownException {
        boolean addSuccess = false;
        List<Long> listId = null;
        List<DynamicInfo> listInfo = dynamicInfoDao.query(classId, subclassId);
        if (listInfo != null && listInfo.size() > 0) {
            listId = new ArrayList<Long>();
            for (DynamicInfo dynamicInfo : listInfo) {
                Long daTaoKeId = dynamicInfo.getDaTaoKeId();
                if (daTaoKeId != null) {
                    listId.add(dynamicInfo.getDaTaoKeId());
                }
            }
        }
        // 大淘客数据
        DaTaoKeDetailV2 daTaoKe = daTaoKeGoodsDetailV2Service.getGoodsNotInList(subclassId, listId, 1).get(0);
        if (daTaoKe == null) {
            return addSuccess;
        }

        try {
            daTaoKe = DaTaoKeUtil.filterDaTaoKe(TaoKeApiUtil.searchGoodsDetail(daTaoKe.getGoodsId()), daTaoKe);
        } catch (Exception e) {

        }

        TaoBaoGoodsBrief taoBaoGoodsBrief = TaoBaoUtil.convert(daTaoKe);
        BigDecimal proportion = hongBaoManageService.getFanLiRate();
        TaoBaoGoodsBriefExtra goodsExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion.toString(),
                null);

        if (!goodsExtra.isCoupon() || (goodsExtra.getState() != null && goodsExtra.getState() == 1)) {
            return addSuccess; // 已下架 、无券 不加入
        }

        List<TaoBaoGoodsBrief> listGoods = new ArrayList<TaoBaoGoodsBrief>();
        listGoods.add(taoBaoGoodsBrief);

        goodsExtra.setTkRate(taoBaoGoodsBrief.getTkRate());
        goodsExtra.setUpdatetime(new Date());
        goodsExtra.setCouponInfo(null);

        GoodsPicture goodsPicture = getGoodsPicture(daTaoKe);
        goodsPicture.setGoods(goodsExtra);
        // 商品列表
        List<GoodsPicture> listPicture = new ArrayList<GoodsPicture>();
        listPicture.add(goodsPicture);

        // 获取商品列表图片
        TaoBaoGoodsBrief taoBaoGoodsBrief2 = TaoKeApiUtil.getSimpleGoodsInfo(daTaoKe.getGoodsId());
        List<String> imgList = taoBaoGoodsBrief2.getImgList();
        List<String> listimgs = new ArrayList<String>();
        String pic = daTaoKe.getMainPic();
        listimgs.add(TbImgUtil.getTBSize320Img(pic));
        if (imgList != null && imgList.size() > 0) {
            for (String img : imgList) {

                if (listPicture.size() >= 4) {
                    break;
                }
                if (pic.equals(img)) {
                    continue;
                }

                listimgs.add(img);
                GoodsPicture picture = new GoodsPicture();
                picture.setH(100);
                picture.setW(100);
                picture.setUrl(TbImgUtil.getTBSize320Img(img));
                listPicture.add(picture);
            }
        }
        goodsExtra.setImgList(imgList);

        // 分享奖金
        BigDecimal shareMoney = taoBaoGoodsBriefService.getShareGoodsUserHongBao(taoBaoGoodsBrief);
        ClientTextStyleVO shareMoneyDesc = new ClientTextStyleVO();
        shareMoneyDesc.setColor("#FFFFFF");
        shareMoneyDesc.setBottomColor("#E8AE48");
        shareMoneyDesc.setContent("预估分享奖金：¥" + shareMoney);

        // 组织动态信息
        DynamicInfo dynamicInfo = getDynamicInfo(daTaoKe, classId, subclassId);
        dynamicInfo.setUser(activityUserService.getRandomByDaTaoKeCid(daTaoKe.getCid()));
        dynamicInfo.setImgs(listPicture);
        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)) {
            int index = desc.lastIndexOf("\n");
            String newDesc = desc.substring(index + 1);
            if (StringUtil.isNullOrEmpty(newDesc)) {
                desc = desc.substring(0, index);
            }
        }
        dynamicInfo.setTitle(convertIntroduce(desc));

        // 保存信息
        dynamicInfoDao.insert(dynamicInfo);

        // 更新商品信息
        executor.execute(new Runnable() {
            @Override
            public void run() {
                goodsEvaluateService.addGoodsEvaluateByDynamicInfo(dynamicInfo);
            }
        });
		
        addSuccess = true;
        return addSuccess;
    }

    /**
     * 数据组织存入MongoDB中
     * 
     * @param daTaoKe
     * @param classId
     * @param subclassId
     * @throws TaobaoGoodsDownException
     */
    public DynamicInfo getDynamicInfo(DaTaoKeDetailV2 daTaoKe, Long classId, Long subclassId) {
        DynamicInfo dynamicInfo = new DynamicInfo();
        dynamicInfo.setId(UUID.randomUUID().toString().replace("-", ""));
        dynamicInfo.setClassId(classId);
        dynamicInfo.setSubclassId(subclassId);
        dynamicInfo.setDaTaoKeId(daTaoKe.getId());
        dynamicInfo.setCreateTime(DateUtil.reduceRandomMinute(new Date(), 8));
        dynamicInfo.setUpdateTime(new Date());
        // 随机分享次数
        dynamicInfo.setShareCount(1000 + (int) (Math.random() * 8000));

        return dynamicInfo;
    }

    /**
     * 文字内容
     * 
     * @param introduce
     * @return
     */
    public List<ClientTextStyleVO> convertIntroduce(String introduce) {
        List<ClientTextStyleVO> title = new ArrayList<ClientTextStyleVO>();
        ClientTextStyleVO desc = new ClientTextStyleVO();
        desc.setColor("#333333");
        desc.setContent(introduce);
        title.add(desc);
        return title;
    }

    /**
     * 图片列表
     * 
     * @param daTaoKe
     * @return
     */
    public GoodsPicture getGoodsPicture(DaTaoKeDetailV2 daTaoKe) {
        GoodsPicture goodsPicture = new GoodsPicture();
        goodsPicture.setH(100);
        goodsPicture.setW(100);
        goodsPicture.setUrl(TbImgUtil.getTBSize320Img(daTaoKe.getMainPic()));
        goodsPicture.setJumpDetail(jumpDetailV2Service.getByTypeCache("goodsdetail"));

        String goodsId = daTaoKe.getGoodsId().toString();
        JSONObject item = new JSONObject();
        item.put("id", goodsId);
        item.put("from", "dynamics");
        goodsPicture.setParams(item.toString());
        return goodsPicture;
    }

    @Override
    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;
        }

        // 判断是否已存在
        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);
        dynamicVO.setSubclassId(0L);
        dynamicVO.setShareType(DynamicInfo.SHARE_TYPE_INVITE);
        dynamicVO.setUpdateTime(new Date());

        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.selectByPrimaryKey(2L));
        } else {
            dynamicVO.setUser(activityUser);
        }

        // 介绍内容
        List<ClientTextStyleVO> listtitle = new ArrayList<ClientTextStyleVO>();
        if (!StringUtil.isNullOrEmpty(title)) {
            ClientTextStyleVO row1 = new ClientTextStyleVO();
            row1.setColor("#333333");
            row1.setContent(title);
            listtitle.add(row1);
        }

        // 图片
        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();
            }

            InputStream asInputStream = HttpUtil.getAsInputStream(picUrl);
			
            int index = picUrl.lastIndexOf("/");
            String newUrl = picUrl.substring(index + 1);
            String urlMd5 = newUrl.substring(0, newUrl.lastIndexOf("."));
			
            // 图片
            String imgLink = qrCodeService.drawInviteQrCodeNew(asInputStream, urlMd5, 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
    public void removeByDate(Date createTime) {
        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;
    }

    private Map<Long, TaoBaoGoodsBrief> getFilterGoodsMap(List<DynamicInfo> list) {
        // 提取过滤商品
        List<TaoBaoGoodsBrief> goodsList = new ArrayList<>();
        for (DynamicInfo dynamicInfo : list) {
            List<GoodsPicture> gpList = dynamicInfo.getImgs();
            if (gpList != null)
                for (GoodsPicture gp : gpList) {
                    if (gp != null && gp.getGoods() != null) {
                        TaoBaoGoodsBriefExtra newGoods = new TaoBaoGoodsBriefExtra();
                        try {
                            PropertyUtils.copyProperties(newGoods, gp.getGoods());
                            goodsList.add(newGoods);
                        } catch (IllegalAccessException e) {
                            e.printStackTrace();
                        } catch (InvocationTargetException e) {
                            e.printStackTrace();
                        } catch (NoSuchMethodException e) {
                            e.printStackTrace();
                        }

                    }
                }
        }
        goodsList = taoBaoGoodsUpdateService.filterImportantTaoBaoGoods(goodsList);
        Map<Long, TaoBaoGoodsBrief> map = new HashMap<>();
        if (goodsList != null)
            for (TaoBaoGoodsBrief goods : goodsList)
                map.put(goods.getAuctionId(), goods);
        return map;
    }

    @Override
    @Cacheable(value = "dynamicCache", key = "'queryV2-'+#platform+'-'+#version+'-'+#start+'-'+#count+'-'+#cid+'-'+#subId")
    public List<DynamicInfo> queryV2(int platform, int version, int start, int count, Long cid, Long subId) {
        List<DynamicInfo> listNew = new ArrayList<DynamicInfo>();
        List<DynamicInfo> list = dynamicInfoDao.query(start, count, cid, subId);
        // 需要更新的商品
        List<TaoBaoGoodsBrief> taoBaoGoodsUpdateList = new ArrayList<>();
        if (list != null && list.size() > 0) {
            // 提取商品
            Map<Long, TaoBaoGoodsBrief> goodsMap = getFilterGoodsMap(list);

            BigDecimal fanLiRate = hongBaoManageService.getFanLiRate();
            BigDecimal shareRate = hongBaoManageService.getShareRate();
            ConfigParamsDTO paramsDTO = new ConfigParamsDTO(fanLiRate, shareRate, Constant.MAX_REWARD_RATE,hongBaoManageService.getVIPFanLiRate());

            for (DynamicInfo dynamicInfo : list) {
                DynamicInfo dynamicNew = new DynamicInfo();
                try {
                    PropertyUtils.copyProperties(dynamicNew, dynamicInfo);
                } catch (Exception e) {
                    e.printStackTrace();
                    continue;
                }

                // 店铺信息
                TaoBaoShop shop = dynamicNew.getShop();
                if (shop != null) {
                    TaoBaoShop shopNew = new TaoBaoShop();
                    try {
                        PropertyUtils.copyProperties(shopNew, shop);
                    } catch (Exception e) {
                        e.printStackTrace();
                        continue;
                    }
                    Integer userType = shopNew.getUserType();
                    if (userType == null || userType == 0) {
                        shopNew.setUserType(10);
                    } else {
                        shopNew.setUserType(11);
                    }
                    dynamicNew.setShop(shopNew);
                }

                List<GoodsPicture> imgsNew = new ArrayList<GoodsPicture>();
                List<GoodsPicture> imgs = dynamicNew.getImgs();
                if (imgs != null && imgs.size() > 0) {
                    for (GoodsPicture goodsPicture : imgs) {
                        TaoBaoGoodsBriefExtra goods = goodsPicture.getGoods();
                        if (goods == null) {
                            imgsNew.add(goodsPicture);
                            continue;
                        }

                        taoBaoGoodsUpdateList.add(goods);

                        GoodsPicture goodsNew = new GoodsPicture();
                        try {
                            PropertyUtils.copyProperties(goodsNew, goodsPicture);
                        } catch (Exception e) {
                            e.printStackTrace();
                            continue;
                        }

                        // 过滤券信息与资金信息
                        goods.setCouponAmount(goodsMap.get(goods.getAuctionId()).getCouponAmount());
                        goods.setZkPrice(goodsMap.get(goods.getAuctionId()).getZkPrice());
                        goods.setCouponStartFee(goodsMap.get(goods.getAuctionId()).getCouponStartFee());
                        goods.setTkRate(goodsMap.get(goods.getAuctionId()).getTkRate());

                        GoodsDetailVO detailVO = GoodsDetailVOFactory.convertTaoBaoGoodsBriefExtra(goods, paramsDTO);

                        goodsNew.setGoodsVO(detailVO);
                        goodsNew.setGoods(null);

                        JumpDetailV2 jumpDetail = goodsNew.getJumpDetail();
                        if (jumpDetail != null) {
                            JumpDetailV2 jumpDetailV2 = jumpDetailV2Service.getByTypeCache(jumpDetail.getType(),
                                    platform, version);
                            if (jumpDetailV2 != null) {
                                goodsNew.setJumpDetail(jumpDetailV2);
                            }
                        }

                        imgsNew.add(goodsNew);
                    }
                    dynamicNew.setImgs(imgsNew);
                }
                listNew.add(dynamicNew);
            }
        }

        // 更新商品信息
        executor.execute(new Runnable() {
            @Override
            public void run() {
                updateGoodInfo(list);
            }
        });

        taoBaoGoodsUpdateService.addUpdateQueueAsync(taoBaoGoodsUpdateList);
        return listNew;
    }

    /**
     * 更新商品信息
     */
    public void updateGoodInfo(List<DynamicInfo> list) {
        if (!Constant.IS_OUTNET) {
            return; // 外网进行更新
        }

        if (list == null || list.size() == 0) {
            return;
        }

        try {
            BigDecimal proportion = hongBaoManageService.getFanLiRate();
            for (DynamicInfo dynamicInfo : list) {
                // 邀请数据不做更新
                long classId = dynamicInfo.getClassId();
                if (classId == 4) {
                    break;
                }

                // 更新商品信息
                List<GoodsPicture> listPicture = dynamicInfo.getImgs();
                if (listPicture == null || listPicture.size() == 0) {
                    continue;
                }

                // 是否一个小时之内已更新
                Date updateTime = dynamicInfo.getUpdateTime();
                if (updateTime != null) {
                    long nd = 1000 * 24 * 60 * 60;// 一天的毫秒数
                    long nh = 1000 * 60 * 60;// 一小时的毫秒数
                    long diff = System.currentTimeMillis() - updateTime.getTime();
                    long day = diff / nd;// 计算差多少天
                    long hour = diff % nd / nh + day * 24;// 计算差多少小时
                    if (hour < 1) {
                        continue;
                    }
                }

                boolean needUpdate = false;
                // 已下架ID
                List<Long> listDown = new ArrayList<Long>();
                // 商品列表
                List<TaoBaoGoodsBrief> listGoods = new ArrayList<TaoBaoGoodsBrief>();

                for (GoodsPicture goodsPicture : listPicture) {
                    TaoBaoGoodsBriefExtra oldExtra = goodsPicture.getGoods();
                    if (oldExtra == null) {
                        continue;
                    }

                    /*
                     * Integer state = oldExtra.getState(); if (state != null && state == 1) {
                     * continue; }
                     */

                    TaoBaoGoodsBrief goodsBrief = null;
                    try {
                        goodsBrief = redisManager.getTaoBaoGoodsBrief(oldExtra.getAuctionId());
                    } catch (TaobaoGoodsDownException e) {
                    }

                    // 是否下架 ： 1、商品本身下架 2、无券信息则认为下架
                    boolean isDown = true;

                    if (goodsBrief == null) {
                        listDown.add(oldExtra.getAuctionId()); // 下架商品
                    } else if (goodsBrief.getCouponAmount() != null
                            && goodsBrief.getCouponAmount().compareTo(BigDecimal.valueOf(0)) > 0) {
                        isDown = false;
                    }

                    if (isDown) {
                        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);
                        }
                    } else {
                        listGoods.add(goodsBrief);

                        TaoBaoGoodsBriefExtra newExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief,
                                proportion.toString(), null);
                        newExtra.setUpdatetime(new Date());
                        goodsPicture.setGoods(newExtra);

                        // 更新热销单品的分享奖金
                        if (classId == 1) {
                            BigDecimal shareMoney = taoBaoGoodsBriefService.getShareGoodsUserHongBao(goodsBrief);
                            ClientTextStyleVO shareMoneyDesc = new ClientTextStyleVO();
                            shareMoneyDesc.setColor("#FFFFFF");
                            shareMoneyDesc.setBottomColor("#E8AE48");
                            shareMoneyDesc.setContent("预估分享奖金：¥" + shareMoney);
                            dynamicInfo.setDesc(shareMoneyDesc);
                        }
                    }

                    // 需要更新信息；
                    needUpdate = true;
                }

                // 无效更新信息
                if (!needUpdate) {
                    continue;
                }

                // 更新商品信息
                dynamicInfo.setImgs(listPicture);

                // 商品已下架
                List<TaoBaoGoodsBrief> listGoodsBrief = dynamicInfo.getListGoodsBrief();
                if (listGoodsBrief != null && listGoodsBrief.size() > 0) {
                    // 淘宝已下架商品
                    if (listDown.size() > 0) {
                        for (TaoBaoGoodsBrief taoBaoGoodsBrief : listGoodsBrief) {
                            if (listDown.contains(taoBaoGoodsBrief.getAuctionId())) {
                                taoBaoGoodsBrief.setState(1);
                            }
                        }
                    }

                    if (listGoods.size() == 0) {
                        dynamicInfo.setListGoodsBrief(listGoodsBrief);
                    } else {
                        List<TaoBaoGoodsBrief> listNew = new ArrayList<TaoBaoGoodsBrief>();
                        for (int i = 0; i < listGoodsBrief.size(); i++) {
                            TaoBaoGoodsBrief taoBaoGoodsBrief = listGoodsBrief.get(i);
                            if (taoBaoGoodsBrief.getState() != null && taoBaoGoodsBrief.getState() == 1) {
                                listNew.add(taoBaoGoodsBrief);
                            } else {
                                boolean isUpdate = false;
                                Long auctionId = taoBaoGoodsBrief.getAuctionId();
                                for (TaoBaoGoodsBrief goods : listGoods) {
                                    if (goods.getAuctionId().equals(auctionId) || goods.getAuctionId() == auctionId) {
                                        listNew.add(goods);
                                        isUpdate = true;
                                        break;
                                    }
                                }

                                if (!isUpdate) {
                                    listNew.add(taoBaoGoodsBrief);
                                }
                            }
                        }
                        dynamicInfo.setListGoodsBrief(listNew);
                    }
                }
                dynamicInfo.setUpdateTime(new Date());
                dynamicInfoDao.updateGoodInfo(dynamicInfo);
            }
        } catch (Exception e) {
            LogHelper.errorDetailInfo(e);
        }

    }

}

 fanli/src/main/java/com/yeshi/fanli/service/impl/dynamic/GoodsEvaluateServiceImpl.java

@@ -2,8 +2,11 @@

import java.awt.image.BufferedImage;
import java.io.InputStream;
import java.io.PrintWriter;
import java.lang.reflect.Type;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Collections;
import java.util.Comparator;
import java.util.Date;
@@ -18,15 +21,29 @@
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.multipart.MultipartHttpServletRequest;
import org.yeshi.utils.DateUtil;
import org.yeshi.utils.JsonUtil;
import org.yeshi.utils.tencentcloud.COSManager;

import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.google.gson.JsonElement;
import com.google.gson.JsonPrimitive;
import com.google.gson.JsonSerializationContext;
import com.google.gson.JsonSerializer;
import com.yeshi.fanli.dao.dynamic.GoodsEvaluateDao;
import com.yeshi.fanli.dto.ConfigParamsDTO;
import com.yeshi.fanli.dto.pdd.PDDGoodsDetail;
import com.yeshi.fanli.entity.accept.AcceptData;
import com.yeshi.fanli.entity.bus.activity.ActivityUser;
import com.yeshi.fanli.entity.bus.user.UserExtraTaoBaoInfo;
import com.yeshi.fanli.entity.bus.user.UserInfo;
import com.yeshi.fanli.entity.dynamic.CommentInfo;
import com.yeshi.fanli.entity.dynamic.DynamicInfo;
import com.yeshi.fanli.entity.dynamic.CommentInfo.CommentInfoEnum;
import com.yeshi.fanli.entity.dynamic.GoodsEvaluate;
import com.yeshi.fanli.entity.dynamic.GoodsEvaluate.EvaluateEnum;
import com.yeshi.fanli.entity.dynamic.GoodsPicture;
import com.yeshi.fanli.entity.dynamic.ImgInfo;
import com.yeshi.fanli.entity.dynamic.ImgInfo.ImgEnum;
import com.yeshi.fanli.entity.dynamic.SimpleGoods;
@@ -49,6 +66,8 @@
import com.yeshi.fanli.vo.goods.CouponInfoVO;
import com.yeshi.fanli.vo.goods.GoodsDetailVO;
import com.yeshi.fanli.vo.msg.ClientTextStyleVO;

import net.sf.json.JSONObject;

@Service
public class GoodsEvaluateServiceImpl implements GoodsEvaluateService {
@@ -107,7 +126,7 @@
        if (dynamicType == null) {
            record.setDynamicType(1);
        }
		

        if (record.getShareNum() == null)
            record.setShareNum(0);

@@ -212,7 +231,7 @@
                BufferedImage sourceImg = ImageIO.read(inputStream);
                int width = sourceImg.getWidth();
                int height = sourceImg.getHeight();
				

                String picLink = uploadPicture(filevideo);
                if (imgVideo != null) {
                    String url = imgVideo.getUrl();
@@ -265,7 +284,7 @@
                        if (file != null) {
                            picLink = uploadPicture(file);
                        }
						

                    }
                    if (picLink.startsWith("http")) {
                        listpic.add(picLink);
@@ -279,11 +298,12 @@
            picNum = 1;
        }

        GoodsDetailVO goodsDetailVO = getGoodsDetailVO(goodsId, goodsType);;
        GoodsDetailVO goodsDetailVO = getGoodsDetailVO(goodsId, goodsType);
        ;
        if (goodsDetailVO == null) {
            throw new GoodsEvaluateException(1, "该商品信息不存在");
        }
		

        int totalImg = 0;
        if (listpic != null && listpic.size() > 0) {
            for (int i = 0; i < listpic.size(); i++) {
@@ -317,7 +337,7 @@
                    imgInfo0.setType(ImgEnum.img);
                }
                listImg.add(imgInfo0);
                totalImg ++;
                totalImg++;
            }
        }

@@ -325,17 +345,17 @@
            for (int j = 0; j < listOld.size(); j++) {
                boolean del = true;
                String oldPic = listOld.get(j);
                for (ImgInfo imgInfo: listImg) {
                for (ImgInfo imgInfo : listImg) {
                    String url = imgInfo.getUrl();
                    if (url.equals(oldPic)) {
                        del = false;
                    } 
                    }
                }
                if (del)
                    listDel.add(listOld.get(j));
            }
        }
		

        int lineNum = 0;
        if (totalImg > 0) {
            if (totalImg == 1) {
@@ -346,7 +366,7 @@
                lineNum = 3;
            }
        }
		

        resultObj.setLineNum(lineNum);
        resultObj.setGoods(goodsDetailVO);
        resultObj.setMainPicNum(picNum);
@@ -427,7 +447,7 @@
                BufferedImage sourceImg = ImageIO.read(inputStream);
                int width = sourceImg.getWidth();
                int height = sourceImg.getHeight();
				

                String picLink = uploadPicture(filevideo);
                if (imgVideo != null) {
                    String url = imgVideo.getUrl();
@@ -511,7 +531,7 @@
                    imgInfo0.setGoods(simpleGoods);
                    imgInfo0.setGoodsVO(goodsDetailVO);
                    listImg.add(imgInfo0);
                    totalImg ++;
                    totalImg++;
                }
            }
        }
@@ -564,9 +584,9 @@
                lineNum = 3;
            }
        }
		

        resultObj.setLineNum(lineNum);
		

        // 保存图片信息
        resultObj.setImgList(listImg);
        goodsEvaluateDao.save(resultObj);
@@ -595,15 +615,15 @@
        CommentInfo currencyCoupon = null;
        List<CommentInfo> oldComments = resultObj.getComments();
        if (oldComments != null) {
            for (CommentInfo info: oldComments) {
                if(CommentInfoEnum.goodsCoupon == info.getType()) {
            for (CommentInfo info : oldComments) {
                if (CommentInfoEnum.goodsCoupon == info.getType()) {
                    goodsCoupon = info;
                } else if (CommentInfoEnum.currencyCoupon == info.getType()) {
                    currencyCoupon = info;
                }
            }
        }
		

        List<CommentInfo> comments = new ArrayList<>();
        if (!StringUtil.isNullOrEmpty(content)) {
            CommentInfo commentInfo = new CommentInfo();
@@ -616,15 +636,15 @@
            commentInfo.setType(CommentInfoEnum.goodsCoupon);
            comments.add(commentInfo);
        }
		

        if (currencyCoupon != null) {
            comments.add(currencyCoupon);
        }
		

        resultObj.setComments(comments);
        goodsEvaluateDao.save(resultObj);
    }
	

    @Override
    public void saveSingleGoodsCoupon(String pid, CommentInfo commentInfo) throws GoodsEvaluateException, Exception {
        if (StringUtil.isNullOrEmpty(pid)) {
@@ -639,20 +659,20 @@
        CommentInfo currencyCoupon = null;
        List<CommentInfo> oldComments = resultObj.getComments();
        if (oldComments != null) {
            for (CommentInfo info: oldComments) {
                if(CommentInfoEnum.goodsCoupon == info.getType()) {
            for (CommentInfo info : oldComments) {
                if (CommentInfoEnum.goodsCoupon == info.getType()) {
                    goodsCoupon = info;
                } else if (CommentInfoEnum.currencyCoupon == info.getType()) {
                    currencyCoupon = info;
                }
            }
        }
		

        List<CommentInfo> comments = new ArrayList<>();
        if (goodsCoupon != null) {
            comments.add(goodsCoupon);
        }
		

        if (commentInfo != null) {
            if (currencyCoupon != null) {
                commentInfo.setId(currencyCoupon.getId());
@@ -660,7 +680,7 @@
                commentInfo.setId(UUID.randomUUID().toString().replace("-", ""));
            }
            commentInfo.setType(CommentInfoEnum.currencyCoupon);
			

            // 标签信息
            List<ClientTextStyleVO> tagList = new ArrayList<>();
            String couponSource = commentInfo.getCouponSource();
@@ -678,10 +698,10 @@
                tagList.add(styleVO);
            }
            commentInfo.setTagList(tagList);
			

            comments.add(commentInfo);
        }
		

        resultObj.setComments(comments);

        goodsEvaluateDao.save(resultObj);
@@ -724,7 +744,7 @@
            MultipartFile filevideo = fileRequest.getFile("filevideo");
            if (filevideo != null) {
                removePicture(videoPic);
				

                InputStream inputStream = filevideo.getInputStream();
                BufferedImage sourceImg = ImageIO.read(inputStream);
                width = sourceImg.getWidth();
@@ -800,8 +820,8 @@
    }

    @Override
    public void saveSuCai(String pid, String videoUrl, String picUrls, 
            MultipartHttpServletRequest fileRequest) throws GoodsEvaluateException, Exception {
    public void saveSuCai(String pid, String videoUrl, String picUrls, MultipartHttpServletRequest fileRequest)
            throws GoodsEvaluateException, Exception {
        if (StringUtil.isNullOrEmpty(pid)) {
            throw new GoodsEvaluateException(1, "请保存第一部分信息");
        }
@@ -815,7 +835,7 @@
        ImgInfo imgActivity = null;
        List<String> listDel = new ArrayList<String>();
        List<String> listOld = new ArrayList<String>();
		

        List<ImgInfo> listOldImgInfo = new ArrayList<ImgInfo>();
        // 处理图片
        List<ImgInfo> resultList = resultObj.getImgList();
@@ -848,7 +868,7 @@
                BufferedImage sourceImg = ImageIO.read(inputStream);
                int width = sourceImg.getWidth();
                int height = sourceImg.getHeight();
				

                String picLink = uploadPicture(filevideo);
                if (imgVideo != null) {
                    String url = imgVideo.getUrl();
@@ -870,8 +890,7 @@
                imgVideo.setW(width);
                imgVideo.setH(height);
            }
			
			

            activityFile = fileRequest.getFile("activityFile");
        }

@@ -881,7 +900,7 @@
                if (imgVideo != null && StringUtil.isNullOrEmpty(imgVideo.getUrl())) {
                    throw new GoodsEvaluateException(1, "视频封面图不能为空");
                }
				

                imgVideo.setVideoUrl(videoUrl);
                listImg.add(imgVideo);
            } else {
@@ -891,15 +910,15 @@
                }
            }
        }
		

        if (activityFile != null) {
            InputStream inputStream = activityFile.getInputStream();
            BufferedImage sourceImg = ImageIO.read(inputStream);
            int width = sourceImg.getWidth();
            int height = sourceImg.getHeight();
			

            String picLink = uploadPicture(activityFile);
			

            ImgInfo activity = new ImgInfo();
            activity.setId(UUID.randomUUID().toString().replace("-", ""));
            activity.setLarge(true);
@@ -914,8 +933,6 @@
        } else if (imgActivity != null) {
            listImg.add(imgActivity);
        }
		
		

        // 编辑图片
        if (!StringUtil.isNullOrEmpty(picUrls)) {
@@ -927,7 +944,7 @@
                        MultipartFile file = fileRequest.getFile("file" + i);
                        if (file != null) {
                            picLink = uploadPicture(file);
							

                            ImgInfo imgInfo0 = new ImgInfo();
                            imgInfo0.setId(UUID.randomUUID().toString().replace("-", ""));
                            imgInfo0.setLarge(true);
@@ -941,12 +958,12 @@
                            continue;
                        }
                    }
					

                    if (picLink.startsWith("http")) {
                        if(listOldImgInfo != null) {
                            for (ImgInfo imgInfo:listOldImgInfo) {
                        if (listOldImgInfo != null) {
                            for (ImgInfo imgInfo : listOldImgInfo) {
                                String url = imgInfo.getUrl();
                                if (picLink.equals(url)){
                                if (picLink.equals(url)) {
                                    listImg.add(imgInfo);
                                    break;
                                }
@@ -961,11 +978,11 @@
            for (int j = 0; j < listOld.size(); j++) {
                boolean del = true;
                String oldPic = listOld.get(j);
                for (ImgInfo imgInfo: listImg) {
                for (ImgInfo imgInfo : listImg) {
                    String url = imgInfo.getUrl();
                    if (url.equals(oldPic)) {
                        del = false;
                    } 
                    }
                }
                if (del)
                    listDel.add(listOld.get(j));
@@ -984,7 +1001,7 @@
            }
        }
    }
	

    @Override
    public void deleteBatchByPrimaryKey(List<String> list) {
        if (list == null || list.size() == 0) {
@@ -1056,7 +1073,7 @@
        goodsEvaluate.setComments(comments);
        goodsEvaluateDao.save(goodsEvaluate);
    }
	

    @Override
    public void release(String id) throws GoodsEvaluateException {
        GoodsEvaluate goodsEvaluate = goodsEvaluateDao.getById(id);
@@ -1066,7 +1083,6 @@
        goodsEvaluate.setState(1);
        goodsEvaluateDao.save(goodsEvaluate);
    }


    @Override
    public void deleteComment(String pid, List<String> list) throws GoodsEvaluateException {
@@ -1146,7 +1162,7 @@
    public long countValid() {
        return goodsEvaluateDao.countValid(1);
    }
	

    @Override
    @Cacheable(value = "dynamicCache", key = "'queryMaterialsCache-'+#start+'-'+#type")
    public List<GoodsEvaluate> queryMaterialsCache(int start, int count, int type) {
@@ -1209,14 +1225,15 @@
                if (imgList == null || imgList.size() == 0) {
                    continue;
                }
				
                for (ImgInfo imgInfo: imgList) {

                for (ImgInfo imgInfo : imgList) {
                    SimpleGoods simpleGoods = imgInfo.getGoods();
                    if (simpleGoods == null) {
                        continue;
                    }
					
                    GoodsDetailVO goodsDetailVO = getGoodsNewInfo(simpleGoods.getGoodsId(), simpleGoods.getGoodsType(), paramsDTO);

                    GoodsDetailVO goodsDetailVO = getGoodsNewInfo(simpleGoods.getGoodsId(), simpleGoods.getGoodsType(),
                            paramsDTO);
                    if (goodsDetailVO != null) {
                        simpleGoods.setPrice(goodsDetailVO.getCouponPrice());
                        CouponInfoVO couponInfo = goodsDetailVO.getCouponInfo();
@@ -1232,7 +1249,7 @@
                        imgInfo.setGoodsVO(goodsDetailVO);
                    }
                }
				

                goodsEvaluate.setUpdateTime(new Date());
                goodsEvaluateDao.save(goodsEvaluate);
            }
@@ -1258,5 +1275,72 @@
        return vo;
    }

}
    @Override
    public void addGoodsEvaluateByDynamicInfo(DynamicInfo info) {
        try {
            GoodsEvaluate goodsEvaluate = new GoodsEvaluate();
            goodsEvaluate.setId(UUID.randomUUID().toString().replace("-", ""));
            ActivityUser user = info.getUser();
            goodsEvaluate.setUser(user);
            goodsEvaluate.setState(1);
            goodsEvaluate.setDynamicType(1);
            goodsEvaluate.setType(EvaluateEnum.single);
            goodsEvaluate.setLineNum(2);
            goodsEvaluate.setShareNum(info.getShareCount());
            goodsEvaluate.setShareNumReal(0);
            goodsEvaluate.setPublishTime(info.getCreateTime());
            goodsEvaluate.setCreateTime(new Date());
            goodsEvaluate.setUpdateTime(new Date());
            goodsEvaluate.setWeight(0.0);
            goodsEvaluate.setStartTime(new Date());
            goodsEvaluate.setEndTime(DateUtil.plusYears(new Date(), 100));

            List<ClientTextStyleVO> titles = info.getTitle();
            if (titles != null) {
                goodsEvaluate.setTitle(info.getTitle().get(0).getContent());
            } else {
                goodsEvaluate.setTitle("");
            }

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

            List<GoodsPicture> imgs = info.getImgs();
            for (GoodsPicture goodsPicture : imgs) {
                ImgInfo imgInfo = new ImgInfo();
                imgInfo.setH(1);
                imgInfo.setW(1);
                imgInfo.setLarge(false);
                imgInfo.setUrl(goodsPicture.getUrl());
                imgInfo.setUrlHD(goodsPicture.getUrl());

                GoodsDetailVO goodsVO = goodsPicture.getGoodsVO();
                if (goodsVO == null) {
                    imgInfo.setType(ImgEnum.img);
                } else {
                    imgInfo.setType(ImgEnum.goods);
                    SimpleGoods simpleGoods = new SimpleGoods();
                    simpleGoods.setGoodsId(goodsVO.getGoodsId());
                    simpleGoods.setGoodsType(goodsVO.getGoodsType());

                    CouponInfoVO couponInfo = goodsVO.getCouponInfo();
                    if (couponInfo == null) {
                        simpleGoods.setState(0);
                        simpleGoods.setPrice(goodsVO.getZkPrice());
                    } else {
                        simpleGoods.setState(goodsVO.getState());
                        simpleGoods.setPrice(goodsVO.getCouponPrice());
                        simpleGoods.setAmount(couponInfo.getAmount());
                    }
                    imgInfo.setGoods(simpleGoods);
                    goodsEvaluate.setGoods(goodsVO);
                }
                imgList.add(imgInfo);
            }
            goodsEvaluate.setImgList(imgList);
            goodsEvaluateDao.save(goodsEvaluate);
        } catch (Exception e) {
            LogHelper.errorDetailInfo(e);
        }
    }

}

 fanli/src/main/java/com/yeshi/fanli/service/inter/dynamic/GoodsEvaluateService.java

@@ -6,6 +6,7 @@
import org.springframework.web.multipart.MultipartHttpServletRequest;

import com.yeshi.fanli.entity.dynamic.CommentInfo;
import com.yeshi.fanli.entity.dynamic.DynamicInfo;
import com.yeshi.fanli.entity.dynamic.GoodsEvaluate;
import com.yeshi.fanli.entity.dynamic.ImgInfo;
import com.yeshi.fanli.exception.dynamic.GoodsEvaluateException;
@@ -134,4 +135,7 @@
    public void release(String id) throws GoodsEvaluateException;


    public void addGoodsEvaluateByDynamicInfo(DynamicInfo info);


}