动态

yujian

2019-05-14 7ce92ff4ff754d62632a0d1254730cb32487aee6

动态

 fanli/src/main/java/com/yeshi/fanli/controller/client/DynamicController.java

New file
@@ -0,0 +1,221 @@
package com.yeshi.fanli.controller.client;



import java.io.PrintWriter;

import java.lang.reflect.Type;

import java.util.ArrayList;

import java.util.Date;

import java.util.List;



import javax.annotation.Resource;



import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.yeshi.utils.JsonUtil;



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.entity.accept.AcceptData;

import com.yeshi.fanli.entity.bus.clazz.GoodsClass;

import com.yeshi.fanli.entity.dynamic.DynamicInfo;

import com.yeshi.fanli.service.inter.common.JumpDetailV2Service;

import com.yeshi.fanli.service.inter.dynamic.DynamicInfoService;

import com.yeshi.fanli.service.inter.goods.TaoBaoGoodsBriefService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;

import com.yeshi.fanli.util.Constant;

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

import com.yeshi.fanli.vo.dynamic.DynamicClassVO;



import net.sf.json.JSONObject;



/**

 * 动态

 * 
 * @author Administrator

 *

 */

@Controller

@RequestMapping("api/v1/dynamic")

public class DynamicController {



    @Resource

    private HongBaoManageService hongBaoManageService;



    @Resource

    private TaoBaoGoodsBriefService taoBaoGoodsBriefService;



    @Resource

    private JumpDetailV2Service jumpDetailV2Service;



    @Resource

    private DynamicInfoService dynamicInfoService;



    /**

     * 查询顶部分类

     * 
     * @param acceptData

     * @param page

     * @param cid

     * @param out

     */

    @RequestMapping(value = "getClass", method = RequestMethod.POST)

    public void getClass(AcceptData acceptData, Integer cid, PrintWriter out) {

        try {

            // ios 只返回子集分类

            if (cid != null) {

                List<GoodsClass> list = new ArrayList<GoodsClass>();



                switch (cid) {

                case 1:

                    list.add(new GoodsClass(0L, "今日单品"));

                    list.addAll(DaTaoKeUtil.goodsClasses);

                    break;

                case 2:

                    break;

                case 3:

                    break;

                case 4:

                    break;

                default:

                    break;

                }



                JSONObject data = new JSONObject();

                data.put("list", JsonUtil.getApiCommonGson().toJson(list));

                out.print(JsonUtil.loadTrueResult(data));

                return;

            }



            // Android 返回分类以及顶部数据

            List<DynamicClassVO> list = new ArrayList<DynamicClassVO>();

            DynamicClassVO c1 = new DynamicClassVO();

            c1.setId(1L);

            c1.setName("热销单品");



            List<GoodsClass> listSub = new ArrayList<GoodsClass>();

            listSub.add(new GoodsClass(0L, "今日单品"));

            listSub.addAll(DaTaoKeUtil.goodsClasses);

            c1.setListSub(listSub);



            DynamicClassVO c2 = new DynamicClassVO();

            c2.setId(2L);

            c2.setName("好货推荐");

            c2.setListSub(new ArrayList<GoodsClass>());



            DynamicClassVO c3 = new DynamicClassVO();

            c3.setId(3L);

            c3.setName("有家好店");

            c3.setListSub(new ArrayList<GoodsClass>());



            DynamicClassVO c4 = new DynamicClassVO();

            c4.setId(4L);

            c4.setName("邀请素材");

            c4.setListSub(new ArrayList<GoodsClass>());



            list.add(c1);

            list.add(c2);

            list.add(c3);

            list.add(c4);



            JSONObject data = new JSONObject();

            data.put("list", JsonUtil.getApiCommonGson().toJson(list));

            out.print(JsonUtil.loadTrueResult(data));

        } catch (Exception e) {

            out.print(JsonUtil.loadFalseResult("查询失败"));

            e.printStackTrace();

        }

    }



    @RequestMapping(value = "getList", method = RequestMethod.POST)

    public void getList2(AcceptData acceptData, Integer page, Long cid, Long subId, PrintWriter out) {

        try {

            if (cid == null) {

                out.print(JsonUtil.loadFalseResult("主分类id不能为空"));

                return;

            }

			
            long count = 0;

            List<DynamicInfo> list = dynamicInfoService.query((page - 1) * Constant.PAGE_SIZE, Constant.PAGE_SIZE, cid,

                    subId);

            if (list == null) {

                list = new ArrayList<DynamicInfo>();

            } else {

                count = dynamicInfoService.count(cid, subId);

            }



            JSONObject data = new JSONObject();

            data.put("count", count);

            data.put("list", getGson().toJson(list));

            out.print(JsonUtil.loadTrueResult(data));

        } catch (Exception e) {

            out.print(JsonUtil.loadFalseResult("查询失败"));

            e.printStackTrace();

        }

    }



    @RequestMapping(value = "shareRecord", method = RequestMethod.POST)

    public void shareRecord(AcceptData acceptData, String id, Long uid, PrintWriter out) {

        try {

            DynamicInfo dynamicInfo = dynamicInfoService.getById(id);

            if (dynamicInfo == null) {

                out.print(JsonUtil.loadFalseResult("该动态信息已不存在"));

                return;

            }

			
            Integer shareCount = dynamicInfo.getShareCount();

            dynamicInfo.setShareCount(shareCount + 1);

            dynamicInfoService.updateShareCount(dynamicInfo);

			
            JSONObject data = new JSONObject();

            data.put("shareCount", shareCount +1);

            out.print(JsonUtil.loadTrueResult(data));

			
        } catch (Exception e) {

            out.print(JsonUtil.loadFalseResult("记录失败"));

        }

		
    }



	
	
    private Gson getGson() {

        GsonBuilder gb = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder());

        gb.excludeFieldsWithoutExposeAnnotation();

        gb.registerTypeAdapter(Date.class, new JsonSerializer<Date>() {

            @Override

            public JsonElement serialize(Date value, Type theType, JsonSerializationContext context) {

                String desc = "";

                if (value != null) {

                    // 判断是否是同一天

                    long old = value.getTime();

                    long now = System.currentTimeMillis();

                    long oldDay = old / (1000 * 60 * 60 * 24L);

                    long nowDay = now / (1000 * 60 * 60 * 24L);

                    if (oldDay == nowDay) {// 同一天

                        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 (nowDay - oldDay == 1) {

                        desc = "昨天";

                    } else {

                        desc = (nowDay - oldDay) + "天前";

                    }

                    return new JsonPrimitive(desc);

                }



                return new JsonPrimitive("");

            }

        });



        Gson gson = gb.create();

        return gson;

    }

}


 fanli/src/main/java/com/yeshi/fanli/entity/dynamic/DynamicInfo.java

New file
@@ -0,0 +1,211 @@
package com.yeshi.fanli.entity.dynamic;



import java.util.Date;

import java.util.List;



import org.springframework.data.annotation.Id;

import org.springframework.data.mongodb.core.mapping.Document;

import org.springframework.data.mongodb.core.mapping.Field;



import com.google.gson.annotations.Expose;

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

import com.yeshi.fanli.entity.taobao.TaoBaoShop;

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



@Document(collection = "dynamic_info")

public class DynamicInfo {



	
    // 分享类型      1:单图分享 、2:4图分享、 3:9图分享 、 4:邀请分享

    public final static int SHARE_TYPE_ONE = 1;

    public final static int SHARE_TYPE_FOUR = 2;

    public final static int SHARE_TYPE_NINE = 3;

    public final static int SHARE_TYPE_INVITE = 4;

	
	
    // 图片格式： 一排显示： 0无图 1一张 2两张  3张

    public final static int SHOW_TYPE_ZERO = 0;

    public final static int SHOW_TYPE_ONE = 1;

    public final static int SHOW_TYPE_TWO = 2;

    public final static int SHOW_TYPE_THREE = 3;

	
	
    @Id

    @Expose

    @Field("id")

    private String id;

    // 发布用户

    @Expose

    @Field("user")

    private ActivityUser user;

    // 发布内容

    @Expose

    @Field("title")

    private List<ClientTextStyleVO> title;

    // 图片信息

    @Expose

    @Field("imgs")

    private List<GoodsPicture> imgs;

    // 图片格式： 2-一排2个 1-一排一个 3-一排三个

    @Expose

    @Field("showType")

    private Integer showType;

    // 分享次数

    @Expose

    @Field("shareCount")

    private Integer shareCount;

    // 分享类型 1单图分享 、2 多图分享

    @Expose

    @Field("shareType")

    private Integer shareType;

    // 预计收入

    @Expose

    @Field("desc")

    private ClientTextStyleVO desc;

    // 店铺信息

    @Expose

    @Field("shop")

    private TaoBaoShop shop;

    // 前端发布时间

    @Expose

    @Field("createTime")

    private Date createTime;



    // 所属类型 1热销 2好货 3好店 4邀请

    @Field("classId")

    private Long classId;

    // 所属类型 1热销 2好货 3好店 4邀请

    @Field("subclassId")

    private Long subclassId;



    // 所属类型 1热销 2好货 3好店 4邀请

    @Field("daTaoKeId")

    private Long daTaoKeId;

	
	
    // 所属类型 人工编辑的动态id

    @Field("activityId")

    private Long activityId;





    public DynamicInfo() {

    }



    public DynamicInfo(String id) {

        this.id = id;

    }



    public String getId() {

        return id;

    }



    public void setId(String id) {

        this.id = id;

    }



    public ActivityUser getUser() {

        return user;

    }



    public void setUser(ActivityUser user) {

        this.user = user;

    }



    public List<ClientTextStyleVO> getTitle() {

        return title;

    }



    public void setTitle(List<ClientTextStyleVO> title) {

        this.title = title;

    }



    public List<GoodsPicture> getImgs() {

        return imgs;

    }



    public void setImgs(List<GoodsPicture> imgs) {

        this.imgs = imgs;

    }



    public Integer getShowType() {

        return showType;

    }



    public void setShowType(Integer showType) {

        this.showType = showType;

    }



    public Integer getShareCount() {

        return shareCount;

    }



    public void setShareCount(Integer shareCount) {

        this.shareCount = shareCount;

    }



    public ClientTextStyleVO getDesc() {

        return desc;

    }



    public void setDesc(ClientTextStyleVO desc) {

        this.desc = desc;

    }



    public TaoBaoShop getShop() {

        return shop;

    }



    public void setShop(TaoBaoShop shop) {

        this.shop = shop;

    }



    public Date getCreateTime() {

        return createTime;

    }



    public void setCreateTime(Date createTime) {

        this.createTime = createTime;

    }





    public Integer getShareType() {

        return shareType;

    }



    public void setShareType(Integer shareType) {

        this.shareType = shareType;

    }



    public Long getClassId() {

        return classId;

    }



    public void setClassId(Long classId) {

        this.classId = classId;

    }



    public Long getSubclassId() {

        return subclassId;

    }



    public void setSubclassId(Long subclassId) {

        this.subclassId = subclassId;

    }



    public Long getDaTaoKeId() {

        return daTaoKeId;

    }



    public void setDaTaoKeId(Long daTaoKeId) {

        this.daTaoKeId = daTaoKeId;

    }



    public Long getActivityId() {

        return activityId;

    }



    public void setActivityId(Long activityId) {

        this.activityId = activityId;

    }



}


 fanli/src/main/java/com/yeshi/fanli/entity/dynamic/GoodsPicture.java

New file
@@ -0,0 +1,76 @@
package com.yeshi.fanli.entity.dynamic;



import com.google.gson.annotations.Expose;

import com.yeshi.fanli.entity.common.JumpDetailV2;

import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBriefExtra;



public class GoodsPicture {

    // 图片链接

    @Expose

    private String url;

    // 宽度

    @Expose

    private Integer w;

    // 高度

    @Expose

    private Integer h;

    // 商品信息

    @Expose

    private TaoBaoGoodsBriefExtra goods;

    // 跳转类型

    @Expose

    private JumpDetailV2 jumpDetail;

    // 跳转参数

    @Expose

    private String params;

	
	


    public String getUrl() {

        return url;

    }



    public void setUrl(String url) {

        this.url = url;

    }



    public Integer getW() {

        return w;

    }



    public void setW(Integer w) {

        this.w = w;

    }



    public Integer getH() {

        return h;

    }



    public void setH(Integer h) {

        this.h = h;

    }



    public TaoBaoGoodsBriefExtra getGoods() {

        return goods;

    }



    public void setGoods(TaoBaoGoodsBriefExtra goods) {

        this.goods = goods;

    }



    public JumpDetailV2 getJumpDetail() {

        return jumpDetail;

    }



    public void setJumpDetail(JumpDetailV2 jumpDetail) {

        this.jumpDetail = jumpDetail;

    }



    public String getParams() {

        return params;

    }



    public void setParams(String params) {

        this.params = params;

    }

}


 fanli/src/main/java/com/yeshi/fanli/job/DynamicInfoJob.java

New file
@@ -0,0 +1,221 @@
package com.yeshi.fanli.job;



import java.util.Date;

import java.util.List;



import javax.annotation.Resource;



import org.springframework.scheduling.annotation.Scheduled;

import org.springframework.stereotype.Component;

import org.yeshi.utils.DateUtil;



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

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.activity.ActivityService;

import com.yeshi.fanli.service.inter.dynamic.DynamicInfoService;

import com.yeshi.fanli.util.Constant;



@Component

public class DynamicInfoJob {

	
    @Resource

    private DynamicInfoService dynamicInfoService;

	
    @Resource

    private ActivityService activityService;

	
	
    /**

     * 每10分钟  晚上00:00~06:00不下发任何一个商品

     */

    @Scheduled(cron = "0 0/10 6-23 * * ?")

    public void insetDynamicInfo() {

		
        if (!Constant.IS_TASK) {

            return;

        }

		
        try {

            dynamicInfoService.insertTimeHotSale();

        } catch (Exception e) {

            try {

                LogHelper.errorDetailInfo(e);

            } catch (Exception e1) {

                e1.printStackTrace();

            }

        }

		
		
        try {

            dynamicInfoService.insertTimeRecommend();

        } catch (Exception e) {

            try {

                LogHelper.errorDetailInfo(e);

            } catch (Exception e1) {

                e1.printStackTrace();

            }

        }

    }

	
	
    /**

     * 早上6,7,15,16,21,22,23点更新1次

     */

    @Scheduled(cron = "0 0 6,7,15,16,21,22,23 * * ? ")

    public void insetShopInfo1() {

		
        if (!Constant.IS_TASK) {

            return;

        }

		
        try {

            dynamicInfoService.insertShopInfo();

        } catch (Exception e) {

            try {

                LogHelper.errorDetailInfo(e);

            } catch (Exception e1) {

                e1.printStackTrace();

            }

        }

    }

	
    /**

     * 早上8:00~10:00每半个小时更新

     */

    @Scheduled(cron = "0 0/30 8,9,10 * * ?")

    public void insetShopInfo2() {

		
        if (!Constant.IS_TASK) {

            return;

        }

		
        try {

            dynamicInfoService.insertShopInfo();

        } catch (Exception e) {

            try {

                LogHelper.errorDetailInfo(e);

            } catch (Exception e1) {

                e1.printStackTrace();

            }

        }

    }

	
	
    /**

     * 早上11:00~14:00每半个小时更新

     */

    @Scheduled(cron = "0 0/30 11,12,13,14 * * ?")

    public void insetShopInfo3() {

		
        if (!Constant.IS_TASK) {

            return;

        }

		
        try {

            dynamicInfoService.insertShopInfo();

        } catch (Exception e) {

            try {

                LogHelper.errorDetailInfo(e);

            } catch (Exception e1) {

                e1.printStackTrace();

            }

        }

    }

	
	
    /**

     * 下午17:00~20:00每半个小时更新

     */

    @Scheduled(cron = "0 0/30 17,18,19,20 * * ? ")

    public void insetShopInfo4() {

		
        if (!Constant.IS_TASK) {

            return;

        }

		
        try {

            dynamicInfoService.insertShopInfo();

        } catch (Exception e) {

            try {

                LogHelper.errorDetailInfo(e);

            } catch (Exception e1) {

                e1.printStackTrace();

            }

        }

    }	
	
	
    /**

     * 每天零点删除3天之前数据

     */

    @Scheduled(cron = "0 0 0 * * ?")

    public void remove() {

		
        if (!Constant.IS_TASK) {

            return;

        }

		
        try {

            dynamicInfoService.removeByDate(DateUtil.reduceDay(3, new Date()));

        } catch (Exception e) {

            try {

                LogHelper.errorDetailInfo(e);

            } catch (Exception e1) {

                e1.printStackTrace();

            }

        }

    }

	
	
    /**

     *  后台编辑动态： 每3分钟检索

     */

    @Scheduled(cron = "0 0/3 * * * ?")

    public void activityNeedPublish() {

		
        if (!Constant.IS_TASK) {

            return;

        }

		
        try {

            List<RecommendActivity> list = activityService.getNeedPublish();

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

                return;

            }

			
			
            for (RecommendActivity activity : list) {

                Integer type = activity.getType();

                if (RecommendActivity.TYPE_SHARE_GOODS == type) {

                    // 商品动态

                    dynamicInfoService.saveActivityRecommend(activity);

					
                    activity.setState(1);

                    activityService.updateByPrimaryKeySelective(activity);

					
                } else if (RecommendActivity.TYPE_INVITE == type) {

                    // 邀请素材

                    String imgUrl = null;

                    List<String> imageList = activityService.getImgByActivityId(activity.getId());

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

                        imgUrl = imageList.get(0);

                    }

					
                    dynamicInfoService.insertInviteMaterial(activity.getTitle(), imgUrl, activity.getId(), activity.getActivityUser());

					
                    activity.setState(1);

                    activityService.updateByPrimaryKeySelective(activity);

                }

            }

			
        } catch (Exception e) {

            try {

                LogHelper.errorDetailInfo(e);

            } catch (Exception e1) {

                e1.printStackTrace();

            }

        }

    }

	
	
}


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

New file
@@ -0,0 +1,727 @@
package com.yeshi.fanli.service.impl.dynamic;



import java.math.BigDecimal;

import java.util.ArrayList;

import java.util.Date;

import java.util.List;

import java.util.UUID;



import javax.annotation.Resource;



import org.springframework.core.task.TaskExecutor;

import org.springframework.stereotype.Service;

import org.yeshi.utils.taobao.TbImgUtil;



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

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

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

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

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

import com.yeshi.fanli.entity.bus.clazz.GoodsClass;

import com.yeshi.fanli.entity.dynamic.DynamicInfo;

import com.yeshi.fanli.entity.dynamic.GoodsPicture;

import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;

import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBriefExtra;

import com.yeshi.fanli.entity.taobao.TaoBaoShop;

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

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.goods.TaoBaoGoodsBriefService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;

import com.yeshi.fanli.service.inter.taobao.TaoBaoShopService;

import com.yeshi.fanli.service.inter.taobao.dataoke.DaTaoKeGoodsService;

import com.yeshi.fanli.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.taobao.DaTaoKeUtil;

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

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

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 DaTaoKeGoodsService daTaoKeGoodsService;



    @Resource

    private JumpDetailV2Service jumpDetailV2Service;



    @Resource

    private ActivityUserService activityUserService;



    @Resource

    private TaoBaoGoodsBriefService taoBaoGoodsBriefService;

	
    @Resource

    private HongBaoManageService hongBaoManageService;

	
    @Resource

    private TaoBaoShopService taoBaoShopService;

	
    @Override

    public void insert(DynamicInfo record) {

         dynamicInfoDao.insert(record);

    }

	
	
    @Override

    public DynamicInfo getById(String id) {

        return dynamicInfoDao.getById(id);

    }

	


    @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 count = 0;

            double random = Math.random();

            if (random > 0.5) {

                count = 9;

            } else {

                count = 4;

            }



            List<DaTaoKeDetail> listDaTaoKe = daTaoKeGoodsService.getGoodsNotInList(subclassId, null, count);



            DaTaoKeDetail daTaoKeDetail = null;

            // 商品列表

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



            // 分享奖金

            BigDecimal shareMoney = new BigDecimal(0);



            BigDecimal proportion = hongBaoManageService.getFanLiRate();

            for (DaTaoKeDetail daTaoKe : listDaTaoKe) {

                if (daTaoKeDetail == null) {

                    daTaoKeDetail = daTaoKe;

                }

                // 分享奖金



                TaoBaoGoodsBrief taoBaoGoodsBrief = TaoBaoUtil.convert(daTaoKe);

                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.setImgs(listPicture);



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

            e.printStackTrace();

        }

    }



    // 定时插入

    @Override

    public void insertTimeHotSale() {

        Long classId = 1L;

        try {

            saveHotSale(classId, 0L);

        } catch (Exception e) {

            e.printStackTrace();

        }



        // 热销单品的分类

        List<GoodsClass> list = DaTaoKeUtil.goodsClasses;

        for (GoodsClass goodsClass : list) {

            try {

                saveHotSale(classId, goodsClass.getId());

            } catch (Exception e) {

                e.printStackTrace();

            }

        }

    }



    /**

     * 保存热销单品

     * 
     * @param classId

     * @param subclassId

     * @throws TaobaoGoodsDownException

     */

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

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

                }

            }

        }

        // 大淘客数据

        DaTaoKeDetail daTaoKe = daTaoKeGoodsService.getGoodsNotInList(subclassId, listId, 1).get(0);



		
        TaoBaoGoodsBrief taoBaoGoodsBrief = TaoBaoUtil.convert(daTaoKe);

        BigDecimal proportion = hongBaoManageService.getFanLiRate();

        TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion.toString(), null);

        if (!taoBaoGoodsBriefExtra.isCoupon()) {

            taoBaoGoodsBriefExtra.setState(1);

        }

		
        // 分享奖金

        BigDecimal shareMoney = taoBaoGoodsBriefService.getShareGoodsUserHongBao(taoBaoGoodsBrief);

        ClientTextStyleVO shareMoneyDesc = new ClientTextStyleVO();

        shareMoneyDesc.setColor("#FFFFFF");

        shareMoneyDesc.setBottomColor("#E8AE48");

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

        // 商品图片

        GoodsPicture goodsPicture = getGoodsPicture(daTaoKe);

        taoBaoGoodsBriefExtra.setUpdatetime(new Date());

        taoBaoGoodsBriefExtra.setCouponInfo(null);

        goodsPicture.setGoods(taoBaoGoodsBriefExtra);

        // 商品列表

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

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

            }

        }

		
        taoBaoGoodsBriefExtra.setImgList(imgList);



        // 组织动态信息

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



        dynamicInfo.setImgs(listPicture);

        dynamicInfo.setDesc(shareMoneyDesc);

        dynamicInfo.setShareType(DynamicInfo.SHARE_TYPE_ONE);

        dynamicInfo.setShowType(DynamicInfo.SHOW_TYPE_TWO);



        // 保存信息

        dynamicInfoDao.insert(dynamicInfo);

    }



    /**

     * 数据组织存入MongoDB中

     * 
     * @param daTaoKe

     * @param classId

     * @param subclassId

     * @throws TaobaoGoodsDownException

     */

    public DynamicInfo getDynamicInfo(DaTaoKeDetail 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(new Date());



        // 随机分享次数

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

        // 随机分布用户

        dynamicInfo.setUser(activityUserService.listRand(1).get(0));

        // 内容

        dynamicInfo.setTitle(convertIntroduce(DaTaoKeUtil.getDesc(daTaoKe)));



        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(DaTaoKeDetail daTaoKe) {

        GoodsPicture goodsPicture = new GoodsPicture();

        goodsPicture.setH(100);

        goodsPicture.setW(100);

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

        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 long count(Long cid, Long subId) {

        return dynamicInfoDao.count(cid, subId);

    }



    @Override

    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;

    }



    @Override

    public void updateShareCount(DynamicInfo record) {

        dynamicInfoDao.updateShareCount(record);

    }

	
	
    @Override

    public void insertInviteMaterial(String title, String picUrl, Long activityId, ActivityUser activityUser) {

		
        DynamicInfo existInfo = null;

        if (activityId != null) {

            existInfo = dynamicInfoDao.getByActivityId(activityId);

            if (existInfo != null) {

                dynamicInfoDao.deleteById(existInfo.getId());

            }

			
            if (!StringUtil.isNullOrEmpty(title)) {

                title = title.replace("<p>", "");

                title = title.replace("</p>", "");

            }

        }

		
        DynamicInfo dynamicVO = new DynamicInfo();

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

        dynamicVO.setActivityId(activityId);

        dynamicVO.setClassId(4L);

        dynamicVO.setSubclassId(0L);

        dynamicVO.setShareType(DynamicInfo.SHARE_TYPE_INVITE);

        if (existInfo != null) {

            dynamicVO.setCreateTime(existInfo.getCreateTime());

            dynamicVO.setShareCount(existInfo.getShareCount());

        } else {

            dynamicVO.setCreateTime(new Date());

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

        }

		
		
        if (activityUser == null) {

            dynamicVO.setUser(activityUserService.listRand(1).get(0));

        } else {

            dynamicVO.setUser(activityUser);

        }

		
		
        // 介绍内容

        ClientTextStyleVO row1 = new ClientTextStyleVO();

        row1.setColor("#333333");

        row1.setContent(title);

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

        listtitle.add(row1);

        dynamicVO.setTitle(listtitle);

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

        if(!StringUtil.isNullOrEmpty(picUrl)) {

            GoodsPicture p2 = new GoodsPicture();

            p2.setW(100);

            p2.setH(100);

            p2.setUrl(picUrl);

            listImg.add(p2);

            dynamicVO.setShowType(DynamicInfo.SHOW_TYPE_ONE);

        } else {

            dynamicVO.setShowType(DynamicInfo.SHOW_TYPE_ZERO);

        }

		
        dynamicVO.setImgs(listImg);

        dynamicInfoDao.insert(dynamicVO);

    }

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

        }

		
        DynamicInfo dynamicVO = new DynamicInfo();

        dynamicVO.setId(brandId);

        dynamicVO.setClassId(classId);

        dynamicVO.setSubclassId(subclassId);

        dynamicVO.setShowType(DynamicInfo.SHOW_TYPE_TWO);

        dynamicVO.setShop(taoBaoShop);

        dynamicVO.setUser(activityUserService.listRand(1).get(0));

        dynamicVO.setCreateTime(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());

			
            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 removeByDate(Date createTime) {

        dynamicInfoDao.removeByDate(createTime);

    }

	
	
	
    /**

     * 更新商品信息

     */

    public void updateGoodInfo(List<DynamicInfo> list) {

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

            return;

        }

		
        BigDecimal proportion = hongBaoManageService.getFanLiRate();

        for (DynamicInfo dynamicInfo: list) {

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

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

                continue;

            }

			
            boolean isupdate = false;

            BigDecimal shareMoney = null;

            for (GoodsPicture goodsPicture: imgs) {

                TaoBaoGoodsBriefExtra oldExtra = goodsPicture.getGoods();

                if (oldExtra == null) {

                    continue;

                }

				
                Integer state = oldExtra.getState();

                if (state != null && state == 1) {

                    continue;

                }

				
                long nd = 1000 * 24 * 60 * 60;// 一天的毫秒数    
                long nh = 1000 * 60 * 60;// 一小时的毫秒数    
                long diff = System.currentTimeMillis() - oldExtra.getUpdatetime().getTime();    
                long day = diff / nd;// 计算差多少天    
                long hour = diff % nd / nh + day * 24;// 计算差多少小时    
                if (hour < 1) {

                    continue;

                }

				
                isupdate = true;

                try {

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

                    TaoBaoGoodsBriefExtra newExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief, proportion.toString(), null);

					
                    if (!newExtra.isCoupon()) {

                        newExtra.setState(1);

                    }

                    newExtra.setUpdatetime(new Date());

                    goodsPicture.setGoods(newExtra);

					
                    BigDecimal money = taoBaoGoodsBriefService.getShareGoodsUserHongBao(goodsBrief);

                    shareMoney = MoneyBigDecimalUtil.add(shareMoney, money);

					
                } catch (TaobaoGoodsDownException e) {

                    oldExtra.setState(1);

                    oldExtra.setCoupon(false);

                    oldExtra.setUpdatetime(new Date());

                    goodsPicture.setGoods(oldExtra);

                    e.printStackTrace();

                }

            }

			
            if (shareMoney != null) {

                ClientTextStyleVO shareMoneyDesc = new ClientTextStyleVO();

                shareMoneyDesc.setColor("#FFFFFF");

                shareMoneyDesc.setBottomColor("#E8AE48");

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

                dynamicInfo.setDesc(shareMoneyDesc);

            }

			
            if (isupdate) {

                dynamicInfoDao.updateGoodInfo(dynamicInfo);

            }

        }

    }

	
	
    @Override

    public void deleteActivity(Long activityId) {

        DynamicInfo dynamicInfo = dynamicInfoDao.getByActivityId(activityId);

        if (dynamicInfo != null) {

            // 删除之前的

            dynamicInfoDao.deleteById(dynamicInfo.getId());

        }

    }

	
	


    @Override

    public void saveActivityRecommend(RecommendActivity activity) {

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

            return;

        }

		
        try {

            DynamicInfo existInfo = dynamicInfoDao.getByActivityId(activity.getId());

            if (existInfo != null) {

                dynamicInfoDao.deleteById(existInfo.getId());

            }

			
            DynamicInfo dynamicInfo = new DynamicInfo();

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

            dynamicInfo.setClassId(2L);

            dynamicInfo.setSubclassId(0L);

            dynamicInfo.setUser(activity.getActivityUser());

            dynamicInfo.setActivityId(activity.getId());

			
            String title = activity.getTitle();

            if (!StringUtil.isNullOrEmpty(title)) {

                title = title.replace("<p>", "");

                title = title.replace("</p>", "");

                dynamicInfo.setTitle(convertIntroduce(title));

            }

			
            if (existInfo != null) {

                dynamicInfo.setCreateTime(existInfo.getCreateTime());

                dynamicInfo.setShareCount(existInfo.getShareCount());

            } else {

                dynamicInfo.setCreateTime(new Date());

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

            }



            // 商品列表

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

            BigDecimal proportion = hongBaoManageService.getFanLiRate();

            // 分享奖金

            BigDecimal shareMoney = new BigDecimal(0);



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

                for (RecommendActivityTaoBaoGoods activityGoods : activity.getGoodsList()) {

				
                    TaoBaoGoodsBrief taoBaoGoodsBrief = null;

                     TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = null;

                    String auctionId = activityGoods.getAuctionId();

                    try {

                        taoBaoGoodsBrief = redisManager.getTaoBaoGoodsBrief(Long.parseLong(auctionId));

					
                        taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion.toString(), null);

                        if (!taoBaoGoodsBriefExtra.isCoupon()) {

                            taoBaoGoodsBriefExtra.setState(1);

                        }

						
                        BigDecimal money = taoBaoGoodsBriefService.getShareGoodsUserHongBao(taoBaoGoodsBrief);

                        shareMoney = MoneyBigDecimalUtil.add(shareMoney, money);

                    } catch (TaobaoGoodsDownException e) {

                         taoBaoGoodsBrief = activityGoods.getTaoBaoGoodsBrief();

                         taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion.toString(), null);

                         taoBaoGoodsBriefExtra.setState(1);

                         taoBaoGoodsBriefExtra.setCoupon(false);

                    }

                    // 商品图片

                    taoBaoGoodsBriefExtra.setCouponInfo(null);

                    taoBaoGoodsBriefExtra.setUpdatetime(new Date());

					
                    JSONObject item = new JSONObject();

                    item.put("id", auctionId);

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

					
                    GoodsPicture goodsPicture = new GoodsPicture();

                    goodsPicture.setH(100);

                    goodsPicture.setW(100);

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

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

                    goodsPicture.setParams(item.toString());

                    goodsPicture.setGoods(taoBaoGoodsBriefExtra);

					
                    listPicture.add(goodsPicture);

                }

            }

            dynamicInfo.setImgs(listPicture);

			
			
            ClientTextStyleVO shareMoneyDesc = new ClientTextStyleVO();

            shareMoneyDesc.setColor("#FFFFFF");

            shareMoneyDesc.setBottomColor("#E8AE48");

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

            dynamicInfo.setDesc(shareMoneyDesc);

            dynamicInfo.setShowType(2);



            if (listPicture.size() < 7) {

                dynamicInfo.setShowType(DynamicInfo.SHOW_TYPE_TWO);

                dynamicInfo.setShareType(DynamicInfo.SHARE_TYPE_FOUR); // 分享类型4图

            } else {

                dynamicInfo.setShowType(DynamicInfo.SHOW_TYPE_THREE);

                dynamicInfo.setShareType(DynamicInfo.SHARE_TYPE_NINE); // 分享类型9图

            }

            // 保存信息

            dynamicInfoDao.insert(dynamicInfo);



        } catch (Exception e) {

            e.printStackTrace();

        }

    }



}


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

New file
@@ -0,0 +1,81 @@
package com.yeshi.fanli.service.inter.dynamic;



import java.util.Date;

import java.util.List;



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

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

import com.yeshi.fanli.entity.dynamic.DynamicInfo;



public interface DynamicInfoService {



    /**

     * 定时插入热销单品

     */

    public void insertTimeHotSale();

	
    /**

     * 定时插入推荐好货

     */

    public void insertTimeRecommend();

	
	
    /**

     * 查询

     * @param start

     * @param count

     * @param cid

     * @param subId

     * @param limitTime

     */

    public List<DynamicInfo> query(int start, int count, Long cid, Long subId);



    /**

     * 
     * @param id

     * @return

     */

    public DynamicInfo getById(String id);



    /**

     * 更新分享次数

     * @param record

     */

    public void updateShareCount(DynamicInfo record);



    /**

     * 插入邀请素材

     * @param content

     * @param picUrl

     */

    public void insertInviteMaterial(String content, String picUrl, Long activityId, ActivityUser activityUser);



    void insert(DynamicInfo record);



    public long count(Long cid, Long subId);



    /**

     * 插入店铺信息

     * @return

     */

    public void insertShopInfo();



    /**

     * 根据时间删除

     * @param createTime

     */

    public void removeByDate(Date createTime);



    /**

     *  动态商品

     * @param activity

     */

    public void saveActivityRecommend(RecommendActivity activity);



    /**

     * 删除动态信息

     * @param activityId

     */

    public void deleteActivity(Long activityId);



}