From 30d8e227e8d823b6c38c3b9c90ac2df03b63befe Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期二, 25 二月 2025 16:41:22 +0800 Subject: [PATCH] 淘宝转链接口更新 --- fanli/src/main/java/com/yeshi/fanli/service/impl/dynamic/DynamicInfoServiceImpl.java | 2000 +++++++++++++++++++++++++++++----------------------------- 1 files changed, 1,000 insertions(+), 1,000 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/dynamic/DynamicInfoServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/dynamic/DynamicInfoServiceImpl.java index d9d809b..4711ee7 100644 --- a/fanli/src/main/java/com/yeshi/fanli/service/impl/dynamic/DynamicInfoServiceImpl.java +++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/dynamic/DynamicInfoServiceImpl.java @@ -24,7 +24,7 @@ import org.yeshi.utils.taobao.TbImgUtil; import com.yeshi.fanli.dao.dynamic.DynamicInfoDao; -import com.yeshi.fanli.dto.ConfigParamsDTO; +import com.yeshi.fanli.dto.GoodsMoneyConfigParamsDTO; import com.yeshi.goods.facade.dto.taobao.TaoBaoShopDTO; import com.yeshi.fanli.entity.bus.activity.ActivityRuleUser; import com.yeshi.fanli.entity.bus.activity.ActivityUser; @@ -70,1170 +70,1170 @@ @Service public class DynamicInfoServiceImpl implements DynamicInfoService { - @Resource(name = "taskExecutor") - private TaskExecutor executor; + @Resource(name = "taskExecutor") + private TaskExecutor executor; - @Resource - private DynamicInfoDao dynamicInfoDao; + @Resource + private DynamicInfoDao dynamicInfoDao; - @Resource - private RedisManager redisManager; + @Resource + private RedisManager redisManager; - @Resource - private DaTaoKeGoodsDetailV2Service daTaoKeGoodsDetailV2Service; + @Resource + private DaTaoKeGoodsDetailV2Service daTaoKeGoodsDetailV2Service; - @Resource - private JumpDetailV2Service jumpDetailV2Service; + @Resource + private JumpDetailV2Service jumpDetailV2Service; - @Resource - private ActivityUserService activityUserService; + @Resource + private ActivityUserService activityUserService; - @Resource - private TaoBaoGoodsBriefService taoBaoGoodsBriefService; + @Resource + private TaoBaoGoodsBriefService taoBaoGoodsBriefService; - @Resource - private HongBaoManageService hongBaoManageService; + @Resource + private HongBaoManageService hongBaoManageService; - @Resource - private TaoBaoShopService taoBaoShopService; + @Resource + private TaoBaoShopService taoBaoShopService; - @Resource - private InviteMaterialService inviteMaterialService; + @Resource + private InviteMaterialService inviteMaterialService; - @Resource - private QrCodeService qrCodeService; + @Resource + private QrCodeService qrCodeService; - @Resource - private TaoBaoGoodsUpdateService taoBaoGoodsUpdateService; + @Resource + private TaoBaoGoodsUpdateService taoBaoGoodsUpdateService; - @Override - public void insert(DynamicInfo record) { - dynamicInfoDao.insert(record); - } + @Override + public void insert(DynamicInfo record) { + dynamicInfoDao.insert(record); + } - @Override - public DynamicInfo getById(String id) { - return dynamicInfoDao.getById(id); - } + @Override + public DynamicInfo getById(String id) { + return dynamicInfoDao.getById(id); + } - @Override - public void insertTimeInvite() { - InviteMaterial inviteMaterial = inviteMaterialService.getInviteMaterial(); - if (inviteMaterial == null) { - return; - } + @Override + public void insertTimeInvite() { + InviteMaterial inviteMaterial = inviteMaterialService.getInviteMaterial(); + if (inviteMaterial == null) { + return; + } - Date date = new Date(); - String materialId = inviteMaterial.getId(); - String content = inviteMaterial.getText(); + Date date = new Date(); + String materialId = inviteMaterial.getId(); + String content = inviteMaterial.getText(); - ActivityUser user = activityUserService.selectByPrimaryKey(2L); + 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); + 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鏈坉d鏃�"); + SimpleDateFormat format = new SimpleDateFormat("MM鏈坉d鏃�"); - 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锛氥�愰個璇烽摼鎺ャ��"); + 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("\\:", "\\锛�"); + 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); + 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); + // 绌烘暟鎹� + List<GoodsPicture> listImg = new ArrayList<GoodsPicture>(); + dynamicTxt.setImgs(listImg); - dynamicInfoDao.insert(dynamicTxt); - } + 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); + 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()); + try { + // 鐢诲浘 + String url = qrCodeService.drawInviteToGreet(picture, null, null, null, content, new Date()); - List<ClientTextStyleVO> listtitle = new ArrayList<ClientTextStyleVO>(); - dynamicPic.setTitle(listtitle); + 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); + 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); - } + 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("澶ф窐瀹㈠搧鐗宨d鑾峰彇澶辫触锛圖ynamicInfoService-insertShopInfo锛�"); - return; - } + @Override + public void insertShopInfo() { + List<String> brandIdList = DaTaoKeApiUtil.getBrandIdList(); + if (brandIdList == null || brandIdList.size() == 0) { + LogHelper.test("澶ф窐瀹㈠搧鐗宨d鑾峰彇澶辫触锛圖ynamicInfoService-insertShopInfo锛�"); + return; + } - Long classId = 3L; - Long subclassId = 0L; - List<DynamicInfo> listInfo = dynamicInfoDao.query(classId, subclassId); + 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); + // 娓呯悊宸插瓨鍦ㄥ搧鐗� + 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--; + 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--; - } - } - } - } + listInfo.remove(listInfo.get(j)); + j--; + } + } + } + } - if (brandIdList == null || brandIdList.size() == 0) { - LogHelper.test("澶ф窐瀹㈠搧鐗屽凡鍏ㄩ儴鐖彇锛圖ynamicInfoService-insertShopInfo锛�"); - return; - } + if (brandIdList == null || brandIdList.size() == 0) { + LogHelper.test("澶ф窐瀹㈠搧鐗屽凡鍏ㄩ儴鐖彇锛圖ynamicInfoService-insertShopInfo锛�"); + return; + } - int index = (int) (Math.random() * brandIdList.size()); - String brandId = brandIdList.get(index); + 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; - } + 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; - } + 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("搴楅摵璇︽儏淇℃伅鑾峰彇澶辫触锛圖ynamicInfoService-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()); + Long sellerId = dynamicShopInfo.getSellerId(); + TaoBaoGoodsBrief taoBaoGoodsBrief = listGoods.get(0); + TaoBaoShop taoBaoShop = taoBaoShopService.getTaoBaoShop(taoBaoGoodsBrief.getAuctionId(), sellerId); + if (taoBaoShop == null) { + LogHelper.test("搴楅摵璇︽儏淇℃伅鑾峰彇澶辫触锛圖ynamicInfoService-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); - 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()); + if (StringUtil.isNullOrEmpty(taoBaoShop.getShopIcon())) + taoBaoShop.setShopIcon(dynamicShopInfo.getShopIcon()); - // 浠嬬粛鍐呭 - ClientTextStyleVO row1 = new ClientTextStyleVO(); - row1.setColor("#333333"); - row1.setContent(dynamicShopInfo.getBrandDes()); - List<ClientTextStyleVO> listTitle = new ArrayList<ClientTextStyleVO>(); - listTitle.add(row1); - dynamicVO.setTitle(listTitle); + 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()); - // 鍟嗗搧淇℃伅 - List<GoodsPicture> listPicture = new ArrayList<GoodsPicture>(); - for (TaoBaoGoodsBrief goodsBrief : listGoods) { - BigDecimal proportion = hongBaoManageService.getFanLiRate(SystemEnum.blks); - TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief, - proportion.toString(), null); - taoBaoGoodsBriefExtra.setCouponInfo(null); - taoBaoGoodsBriefExtra.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); - if (!taoBaoGoodsBriefExtra.isCoupon()) { - taoBaoGoodsBriefExtra.setState(1); - } + // 鍟嗗搧淇℃伅 + List<GoodsPicture> listPicture = new ArrayList<GoodsPicture>(); + for (TaoBaoGoodsBrief goodsBrief : listGoods) { + BigDecimal proportion = hongBaoManageService.getFanLiRate(SystemEnum.blks); + 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"); + if (!taoBaoGoodsBriefExtra.isCoupon()) { + taoBaoGoodsBriefExtra.setState(1); + } - 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); + String goodsId = goodsBrief.getAuctionId().toString(); + JSONObject item = new JSONObject(); + item.put("id", goodsId); + item.put("from", "dynamics"); - listPicture.add(goodsPicture); - } - dynamicVO.setImgs(listPicture); + GoodsPicture goodsPicture = new GoodsPicture(); + goodsPicture.setH(100); + goodsPicture.setW(100); + goodsPicture.setUrl(TbImgUtil.getTBSize320Img(goodsBrief.getPictUrl())); + goodsPicture.setJumpDetail(jumpDetailV2Service.getByTypeCache("goodsdetail", SystemEnum.blks)); + goodsPicture.setParams(item.toString()); + goodsPicture.setGoods(taoBaoGoodsBriefExtra); - dynamicInfoDao.insert(dynamicVO); - } + listPicture.add(goodsPicture); + } + dynamicVO.setImgs(listPicture); - @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; - } + dynamicInfoDao.insert(dynamicVO); + } - List<DaTaoKeDetailV2> listDaTaoKe = daTaoKeGoodsDetailV2Service.getGoodsNotInList(subclassId, null, count); + @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; + } - DaTaoKeDetailV2 daTaoKeDetail = null; - // 鍟嗗搧鍒楄〃 - List<GoodsPicture> listPicture = new ArrayList<GoodsPicture>(); - // 鍟嗗搧鍒楄〃 - List<TaoBaoGoodsBrief> listGoods = new ArrayList<TaoBaoGoodsBrief>(); - // 鍒嗕韩濂栭噾 - BigDecimal shareMoney = new BigDecimal(0); + List<DaTaoKeDetailV2> listDaTaoKe = daTaoKeGoodsDetailV2Service.getGoodsNotInList(subclassId, null, count); - BigDecimal proportion = hongBaoManageService.getFanLiRate(SystemEnum.blks); - for (DaTaoKeDetailV2 daTaoKe : listDaTaoKe) { - if (daTaoKeDetail == null) { - daTaoKeDetail = daTaoKe; - } - // 鍒嗕韩濂栭噾 - TaoBaoGoodsBrief taoBaoGoodsBrief = TaoBaoUtil.convert(daTaoKe); - listGoods.add(taoBaoGoodsBrief); + DaTaoKeDetailV2 daTaoKeDetail = null; + // 鍟嗗搧鍒楄〃 + List<GoodsPicture> listPicture = new ArrayList<GoodsPicture>(); + // 鍟嗗搧鍒楄〃 + List<TaoBaoGoodsBrief> listGoods = new ArrayList<TaoBaoGoodsBrief>(); + // 鍒嗕韩濂栭噾 + BigDecimal shareMoney = new BigDecimal(0); - TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, - proportion.toString(), null); - if (!taoBaoGoodsBriefExtra.isCoupon()) { - taoBaoGoodsBriefExtra.setState(1); - } + BigDecimal proportion = hongBaoManageService.getFanLiRate(SystemEnum.blks); + for (DaTaoKeDetailV2 daTaoKe : listDaTaoKe) { + if (daTaoKeDetail == null) { + daTaoKeDetail = daTaoKe; + } + // 鍒嗕韩濂栭噾 + TaoBaoGoodsBrief taoBaoGoodsBrief = TaoBaoUtil.convert(daTaoKe); + listGoods.add(taoBaoGoodsBrief); - BigDecimal money = taoBaoGoodsBriefService.getShareGoodsUserHongBao(taoBaoGoodsBrief,SystemEnum.blks); - shareMoney = MoneyBigDecimalUtil.add(shareMoney, money); - // 鍟嗗搧鍥剧墖 - taoBaoGoodsBriefExtra.setUpdatetime(new Date()); - taoBaoGoodsBriefExtra.setCouponInfo(null); - GoodsPicture goodsPicture = getGoodsPicture(daTaoKe); - goodsPicture.setGoods(taoBaoGoodsBriefExtra); + TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, + proportion.toString(), null); + if (!taoBaoGoodsBriefExtra.isCoupon()) { + taoBaoGoodsBriefExtra.setState(1); + } - listPicture.add(goodsPicture); - } + BigDecimal money = taoBaoGoodsBriefService.getShareGoodsUserHongBao(taoBaoGoodsBrief, SystemEnum.blks); + shareMoney = MoneyBigDecimalUtil.add(shareMoney, money); + // 鍟嗗搧鍥剧墖 + taoBaoGoodsBriefExtra.setUpdatetime(new Date()); + taoBaoGoodsBriefExtra.setCouponInfo(null); + GoodsPicture goodsPicture = getGoodsPicture(daTaoKe, SystemEnum.blks); + goodsPicture.setGoods(taoBaoGoodsBriefExtra); - // 缁勭粐鍔ㄦ�佷俊鎭� - DynamicInfo dynamicInfo = getDynamicInfo(daTaoKeDetail, classId, subclassId); - // 鏃犲唴瀹� - dynamicInfo.setTitle(new ArrayList<ClientTextStyleVO>()); - // 鍙戝竷鐢ㄦ埛 - dynamicInfo.setUser(activityUserService.getRandomByDaTaoKeCid(cid)); - dynamicInfo.setImgs(listPicture); - dynamicInfo.setListGoodsBrief(listGoods); + listPicture.add(goodsPicture); + } - ClientTextStyleVO shareMoneyDesc = new ClientTextStyleVO(); - shareMoneyDesc.setColor("#FFFFFF"); - shareMoneyDesc.setBottomColor("#E8AE48"); - shareMoneyDesc.setContent("棰勪及鍒嗕韩濂栭噾锛毬�" + shareMoney); - dynamicInfo.setDesc(shareMoneyDesc); - dynamicInfo.setShowType(2); + // 缁勭粐鍔ㄦ�佷俊鎭� + DynamicInfo dynamicInfo = getDynamicInfo(daTaoKeDetail, classId, subclassId); + // 鏃犲唴瀹� + dynamicInfo.setTitle(new ArrayList<ClientTextStyleVO>()); + // 鍙戝竷鐢ㄦ埛 + dynamicInfo.setUser(activityUserService.getRandomByDaTaoKeCid(cid)); + dynamicInfo.setImgs(listPicture); + dynamicInfo.setListGoodsBrief(listGoods); - 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); + ClientTextStyleVO shareMoneyDesc = new ClientTextStyleVO(); + shareMoneyDesc.setColor("#FFFFFF"); + shareMoneyDesc.setBottomColor("#E8AE48"); + shareMoneyDesc.setContent("棰勪及鍒嗕韩濂栭噾锛毬�" + shareMoney); + dynamicInfo.setDesc(shareMoneyDesc); + dynamicInfo.setShowType(2); - } catch (Exception e) { - try { - LogHelper.errorDetailInfo(e); - } catch (Exception e1) { - e1.printStackTrace(); - } - } - } + 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); - // 瀹氭椂鎻掑叆 - @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(); - } - } + } 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(); - } - } - } - } + // 瀹氭椂鎻掑叆 + @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(); + } + } - /** - * 淇濆瓨鐑攢鍗曞搧 - * - * @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; - } + // 鐑攢鍗曞搧鐨勫垎绫� + 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(); + } + } + } + } - try { - daTaoKe = DaTaoKeUtil.filterDaTaoKe(TaoKeApiUtil.searchGoodsDetail(daTaoKe.getGoodsId()), daTaoKe); - } catch (Exception e) { + /** + * 淇濆瓨鐑攢鍗曞搧 + * + * @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(SystemEnum.blks); - TaoBaoGoodsBriefExtra goodsExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion.toString(), - null); + } - if (!goodsExtra.isCoupon() || (goodsExtra.getState() != null && goodsExtra.getState() == 1)) { - return addSuccess; // 宸蹭笅鏋� 銆佹棤鍒� 涓嶅姞鍏� - } + TaoBaoGoodsBrief taoBaoGoodsBrief = TaoBaoUtil.convert(daTaoKe); + BigDecimal proportion = hongBaoManageService.getFanLiRate(SystemEnum.blks); + TaoBaoGoodsBriefExtra goodsExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion.toString(), + null); - List<TaoBaoGoodsBrief> listGoods = new ArrayList<TaoBaoGoodsBrief>(); - listGoods.add(taoBaoGoodsBrief); + if (!goodsExtra.isCoupon() || (goodsExtra.getState() != null && goodsExtra.getState() == 1)) { + return addSuccess; // 宸蹭笅鏋� 銆佹棤鍒� 涓嶅姞鍏� + } - goodsExtra.setTkRate(taoBaoGoodsBrief.getTkRate()); - goodsExtra.setUpdatetime(new Date()); - goodsExtra.setCouponInfo(null); + List<TaoBaoGoodsBrief> listGoods = new ArrayList<TaoBaoGoodsBrief>(); + listGoods.add(taoBaoGoodsBrief); - GoodsPicture goodsPicture = getGoodsPicture(daTaoKe); - goodsPicture.setGoods(goodsExtra); - // 鍟嗗搧鍒楄〃 - List<GoodsPicture> listPicture = new ArrayList<GoodsPicture>(); - listPicture.add(goodsPicture); + goodsExtra.setTkRate(taoBaoGoodsBrief.getTkRate()); + goodsExtra.setUpdatetime(new Date()); + goodsExtra.setCouponInfo(null); - // 鑾峰彇鍟嗗搧鍒楄〃鍥剧墖 - 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) { + GoodsPicture goodsPicture = getGoodsPicture(daTaoKe, SystemEnum.blks); + goodsPicture.setGoods(goodsExtra); + // 鍟嗗搧鍒楄〃 + List<GoodsPicture> listPicture = new ArrayList<GoodsPicture>(); + listPicture.add(goodsPicture); - if (listPicture.size() >= 4) { - break; - } - if (pic.equals(img)) { - continue; - } + // 鑾峰彇鍟嗗搧鍒楄〃鍥剧墖 + 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) { - listimgs.add(img); - GoodsPicture picture = new GoodsPicture(); - picture.setH(100); - picture.setW(100); - picture.setUrl(TbImgUtil.getTBSize320Img(img)); - listPicture.add(picture); - } - } - goodsExtra.setImgList(imgList); + if (listPicture.size() >= 4) { + break; + } + if (pic.equals(img)) { + continue; + } - // 鍒嗕韩濂栭噾 - BigDecimal shareMoney = taoBaoGoodsBriefService.getShareGoodsUserHongBao(taoBaoGoodsBrief,SystemEnum.blks); - ClientTextStyleVO shareMoneyDesc = new ClientTextStyleVO(); - shareMoneyDesc.setColor("#FFFFFF"); - shareMoneyDesc.setBottomColor("#E8AE48"); - shareMoneyDesc.setContent("棰勪及鍒嗕韩濂栭噾锛毬�" + shareMoney); + listimgs.add(img); + GoodsPicture picture = new GoodsPicture(); + picture.setH(100); + picture.setW(100); + picture.setUrl(TbImgUtil.getTBSize320Img(img)); + listPicture.add(picture); + } + } + goodsExtra.setImgList(imgList); - // 缁勭粐鍔ㄦ�佷俊鎭� - 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); + // 鍒嗕韩濂栭噾 + BigDecimal shareMoney = taoBaoGoodsBriefService.getShareGoodsUserHongBao(taoBaoGoodsBrief, SystemEnum.blks); + ClientTextStyleVO shareMoneyDesc = new ClientTextStyleVO(); + shareMoneyDesc.setColor("#FFFFFF"); + shareMoneyDesc.setBottomColor("#E8AE48"); + shareMoneyDesc.setContent("棰勪及鍒嗕韩濂栭噾锛毬�" + shareMoney); - 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)); + // 缁勭粐鍔ㄦ�佷俊鎭� + 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); - // 淇濆瓨淇℃伅 - dynamicInfoDao.insert(dynamicInfo); - - addSuccess = true; - return addSuccess; - } + 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)); - /** - * 鏁版嵁缁勭粐瀛樺叆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)); + // 淇濆瓨淇℃伅 + dynamicInfoDao.insert(dynamicInfo); - return dynamicInfo; - } + addSuccess = true; + return addSuccess; + } - /** - * 鏂囧瓧鍐呭 - * - * @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; - } + /** + * 鏁版嵁缁勭粐瀛樺叆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)); - /** - * 鍥剧墖鍒楄〃 - * - * @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")); + return dynamicInfo; + } - String goodsId = daTaoKe.getGoodsId().toString(); - JSONObject item = new JSONObject(); - item.put("id", goodsId); - item.put("from", "dynamics"); - goodsPicture.setParams(item.toString()); - return goodsPicture; - } + /** + * 鏂囧瓧鍐呭 + * + * @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; + } - @Override - public void insertInviteActivity(RecommendActivity activity) throws Exception { + /** + * 鍥剧墖鍒楄〃 + * + * @param daTaoKe + * @return + */ + public GoodsPicture getGoodsPicture(DaTaoKeDetailV2 daTaoKe, SystemEnum system) { + GoodsPicture goodsPicture = new GoodsPicture(); + goodsPicture.setH(100); + goodsPicture.setW(100); + goodsPicture.setUrl(TbImgUtil.getTBSize320Img(daTaoKe.getMainPic())); + goodsPicture.setJumpDetail(jumpDetailV2Service.getByTypeCache("goodsdetail", system)); - String title = activity.getTitle(); + String goodsId = daTaoKe.getGoodsId().toString(); + JSONObject item = new JSONObject(); + item.put("id", goodsId); + item.put("from", "dynamics"); + goodsPicture.setParams(item.toString()); + return goodsPicture; + } - String picUrl = null; - List<String> imageList = activity.getImageList(); - if (imageList != null && imageList.size() > 0) { - picUrl = imageList.get(0); - } + @Override + public void insertInviteActivity(RecommendActivity activity) throws Exception { - if (StringUtil.isNullOrEmpty(title) || StringUtil.isNullOrEmpty(picUrl)) { - return; - } + String title = activity.getTitle(); - // 鍒ゆ柇鏄惁宸插瓨鍦� - String dynamicInfoId = null; + String picUrl = null; + List<String> imageList = activity.getImageList(); + if (imageList != null && imageList.size() > 0) { + picUrl = imageList.get(0); + } - 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) || 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); + } - if (!StringUtil.isNullOrEmpty(title)) { - title = title.replaceAll("<p>", "").replaceAll("</p>", "").replaceAll("<br>", "\n"); + title = title.replaceAll("\\,", "\\锛�").replaceAll("\\.", "\\銆�").replaceAll("\\;", "\\锛�") + .replaceAll("\\!", "\\锛�").replaceAll("\\?", "\\锛�").replaceAll("\\:", "\\锛�"); + } - int index = title.lastIndexOf("\n"); - String newDesc = title.substring(index + 1); - if (StringUtil.isNullOrEmpty(newDesc)) { - title = title.substring(0, index); - } + 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()); - title = title.replaceAll("\\,", "\\锛�").replaceAll("\\.", "\\銆�").replaceAll("\\;", "\\锛�") - .replaceAll("\\!", "\\锛�").replaceAll("\\?", "\\锛�").replaceAll("\\:", "\\锛�"); - } + Integer shareCount = activity.getShareCount(); + if (shareCount == null || shareCount <= 0) { + dynamicVO.setShareCount(1000 + (int) (Math.random() * 8000)); + } else { + dynamicVO.setShareCount(shareCount); + } - 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()); + // 鍙戝竷鐢ㄦ埛 + ActivityUser activityUser = activity.getActivityUser(); + if (activityUser == null) { + dynamicVO.setUser(activityUserService.selectByPrimaryKey(2L)); + } else { + dynamicVO.setUser(activityUser); + } - Integer shareCount = activity.getShareCount(); - if (shareCount == null || shareCount <= 0) { - dynamicVO.setShareCount(1000 + (int) (Math.random() * 8000)); - } else { - dynamicVO.setShareCount(shareCount); - } + // 浠嬬粛鍐呭 + List<ClientTextStyleVO> listtitle = new ArrayList<ClientTextStyleVO>(); + if (!StringUtil.isNullOrEmpty(title)) { + ClientTextStyleVO row1 = new ClientTextStyleVO(); + row1.setColor("#333333"); + row1.setContent(title); + listtitle.add(row1); + } - // 鍙戝竷鐢ㄦ埛 - ActivityUser activityUser = activity.getActivityUser(); - if (activityUser == null) { - dynamicVO.setUser(activityUserService.selectByPrimaryKey(2L)); - } else { - dynamicVO.setUser(activityUser); - } + // 鍥剧墖 + 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(); - // 浠嬬粛鍐呭 - List<ClientTextStyleVO> listtitle = new ArrayList<ClientTextStyleVO>(); - if (!StringUtil.isNullOrEmpty(title)) { - ClientTextStyleVO row1 = new ClientTextStyleVO(); - row1.setColor("#333333"); - row1.setContent(title); - listtitle.add(row1); - } + Integer pX = null; + Integer pY = null; + Integer size = null; + if (inviteInfo != null) { + pX = inviteInfo.getPx(); + pY = inviteInfo.getPy(); + size = inviteInfo.getSize(); + } - // 鍥剧墖 - 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(); + InputStream asInputStream = HttpUtil.getAsInputStream(picUrl); - Integer pX = null; - Integer pY = null; - Integer size = null; - if (inviteInfo != null) { - pX = inviteInfo.getPx(); - pY = inviteInfo.getPy(); - size = inviteInfo.getSize(); - } + int index = picUrl.lastIndexOf("/"); + String newUrl = picUrl.substring(index + 1); + String urlMd5 = newUrl.substring(0, newUrl.lastIndexOf(".")); - 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); + // 鍥剧墖 + 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); - } + listImg.add(p2); + } - dynamicVO.setImgs(listImg); - dynamicVO.setTitle(listtitle); + dynamicVO.setImgs(listImg); + dynamicVO.setTitle(listtitle); - if (!StringUtil.isNullOrEmpty(dynamicInfoId)) { - dynamicInfoDao.deleteById(dynamicInfoId); - } + if (!StringUtil.isNullOrEmpty(dynamicInfoId)) { + dynamicInfoDao.deleteById(dynamicInfoId); + } - dynamicInfoDao.insert(dynamicVO); - } + dynamicInfoDao.insert(dynamicVO); + } - @Override - public void insertActivityRecommend(RecommendActivity activity) { - if (activity == null || activity.getGoodsList() == null) { - return; - } + @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(); - } + 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()); + 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"); + 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); - } + 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); + 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); - } + 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); - } + // 鍙戝竷鐢ㄦ埛 + 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(SystemEnum.blks); - // 鍒嗕韩濂栭噾 - BigDecimal shareMoney = new BigDecimal(0); + List<TaoBaoGoodsBrief> listGoods = new ArrayList<TaoBaoGoodsBrief>(); + // 鍟嗗搧鍒楄〃 + List<GoodsPicture> listPicture = new ArrayList<GoodsPicture>(); + BigDecimal proportion = hongBaoManageService.getFanLiRate(SystemEnum.blks); + // 鍒嗕韩濂栭噾 + BigDecimal shareMoney = new BigDecimal(0); - if (activity.getGoodsList() != null) { - for (RecommendActivityTaoBaoGoods activityGoods : activity.getGoodsList()) { + 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)); + TaoBaoGoodsBrief taoBaoGoodsBrief = null; + TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = null; + String auctionId = activityGoods.getAuctionId(); + try { + taoBaoGoodsBrief = redisManager.getTaoBaoGoodsBrief(auctionId); - taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, - proportion.toString(), null); - if (!taoBaoGoodsBriefExtra.isCoupon()) { - taoBaoGoodsBriefExtra.setState(1); - } + taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, + proportion.toString(), null); + if (!taoBaoGoodsBriefExtra.isCoupon()) { + taoBaoGoodsBriefExtra.setState(1); + } - BigDecimal money = taoBaoGoodsBriefService.getShareGoodsUserHongBao(taoBaoGoodsBrief,SystemEnum.blks); - 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); + BigDecimal money = taoBaoGoodsBriefService.getShareGoodsUserHongBao(taoBaoGoodsBrief, SystemEnum.blks); + 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()); + // 鍟嗗搧鍥剧墖 + taoBaoGoodsBriefExtra.setCouponInfo(null); + taoBaoGoodsBriefExtra.setUpdatetime(new Date()); - JSONObject item = new JSONObject(); - item.put("id", auctionId); - item.put("from", "dynamics"); + 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); + GoodsPicture goodsPicture = new GoodsPicture(); + goodsPicture.setH(100); + goodsPicture.setW(100); + goodsPicture.setUrl(TbImgUtil.getTBSize320Img(taoBaoGoodsBrief.getPictUrl())); + goodsPicture.setJumpDetail(jumpDetailV2Service.getByTypeCache("goodsdetail", SystemEnum.blks)); + goodsPicture.setParams(item.toString()); + goodsPicture.setGoods(taoBaoGoodsBriefExtra); - listPicture.add(goodsPicture); - } - } - dynamicInfo.setImgs(listPicture); - dynamicInfo.setListGoodsBrief(listGoods); + 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); + 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 (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); + if (!StringUtil.isNullOrEmpty(dynamicInfoId)) { + dynamicInfoDao.deleteById(dynamicInfoId); + } + // 淇濆瓨淇℃伅 + dynamicInfoDao.insert(dynamicInfo); - } catch (Exception e) { - try { - LogHelper.errorDetailInfo(e); - } catch (Exception e1) { - e1.printStackTrace(); - } - } - } + } 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 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 removeByDate(Date createTime) { + dynamicInfoDao.removeByDate(createTime); + } - @Override - public void updateShareCount(DynamicInfo record) { - dynamicInfoDao.updateShareCount(record); - } + @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 = "'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); + @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); - } - }); + // 鏇存柊鍟嗗搧淇℃伅 + executor.execute(new Runnable() { + @Override + public void run() { + updateGoodInfo(list); + } + }); - return 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(); - } + private Map<String, 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; - } + } + } + } + goodsList = taoBaoGoodsUpdateService.filterImportantTaoBaoGoods(goodsList); + Map<String, 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); + @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<String, TaoBaoGoodsBrief> goodsMap = getFilterGoodsMap(list); - BigDecimal fanLiRate = hongBaoManageService.getFanLiRate(SystemEnum.blks); - BigDecimal shareRate = hongBaoManageService.getShareRate(SystemEnum.blks); - ConfigParamsDTO paramsDTO = new ConfigParamsDTO(fanLiRate, shareRate, Constant.MAX_REWARD_RATE,hongBaoManageService.getFanLiRate(UserLevelEnum.superVIP,SystemEnum.blks)); + BigDecimal fanLiRate = hongBaoManageService.getFanLiRate(SystemEnum.blks); + BigDecimal shareRate = hongBaoManageService.getShareRate(SystemEnum.blks); + GoodsMoneyConfigParamsDTO paramsDTO = new GoodsMoneyConfigParamsDTO(fanLiRate, shareRate, Constant.MAX_REWARD_RATE, hongBaoManageService.getFanLiRate(UserLevelEnum.superVIP, SystemEnum.blks)); - for (DynamicInfo dynamicInfo : list) { - DynamicInfo dynamicNew = new DynamicInfo(); - try { - PropertyUtils.copyProperties(dynamicNew, dynamicInfo); - } catch (Exception e) { - e.printStackTrace(); - continue; - } + 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); - } + // 搴楅摵淇℃伅 + 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; - } + 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); + taoBaoGoodsUpdateList.add(goods); - GoodsPicture goodsNew = new GoodsPicture(); - try { - PropertyUtils.copyProperties(goodsNew, goodsPicture); - } catch (Exception e) { - e.printStackTrace(); - continue; - } + 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()); + // 杩囨护鍒镐俊鎭笌璧勯噾淇℃伅 + 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); + GoodsDetailVO detailVO = GoodsDetailVOFactory.convertTaoBaoGoodsBriefExtra(goods, paramsDTO); - goodsNew.setGoodsVO(detailVO); - goodsNew.setGoods(null); + 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); - } - } + JumpDetailV2 jumpDetail = goodsNew.getJumpDetail(); + if (jumpDetail != null) { + JumpDetailV2 jumpDetailV2 = jumpDetailV2Service.getByTypeCache(jumpDetail.getType(), + platform, version, SystemEnum.blks); + if (jumpDetailV2 != null) { + goodsNew.setJumpDetail(jumpDetailV2); + } + } - imgsNew.add(goodsNew); - } - dynamicNew.setImgs(imgsNew); - } - listNew.add(dynamicNew); - } - } + imgsNew.add(goodsNew); + } + dynamicNew.setImgs(imgsNew); + } + listNew.add(dynamicNew); + } + } - // 鏇存柊鍟嗗搧淇℃伅 - executor.execute(new Runnable() { - @Override - public void run() { - updateGoodInfo(list); - } - }); + // 鏇存柊鍟嗗搧淇℃伅 + executor.execute(new Runnable() { + @Override + public void run() { + updateGoodInfo(list); + } + }); - taoBaoGoodsUpdateService.addUpdateQueueAsync(taoBaoGoodsUpdateList); - return listNew; - } + taoBaoGoodsUpdateService.addUpdateQueueAsync(taoBaoGoodsUpdateList); + return listNew; + } - /** - * 鏇存柊鍟嗗搧淇℃伅 - */ - public void updateGoodInfo(List<DynamicInfo> list) { - if (!Constant.IS_OUTNET) { - return; // 澶栫綉杩涜鏇存柊 - } + /** + * 鏇存柊鍟嗗搧淇℃伅 + */ + public void updateGoodInfo(List<DynamicInfo> list) { + if (!Constant.IS_OUTNET) { + return; // 澶栫綉杩涜鏇存柊 + } - if (list == null || list.size() == 0) { - return; - } + if (list == null || list.size() == 0) { + return; + } - try { - BigDecimal proportion = hongBaoManageService.getFanLiRate(SystemEnum.blks); - for (DynamicInfo dynamicInfo : list) { - // 閭�璇锋暟鎹笉鍋氭洿鏂� - long classId = dynamicInfo.getClassId(); - if (classId == 4) { - break; - } + try { + BigDecimal proportion = hongBaoManageService.getFanLiRate(SystemEnum.blks); + for (DynamicInfo dynamicInfo : list) { + // 閭�璇锋暟鎹笉鍋氭洿鏂� + long classId = dynamicInfo.getClassId(); + if (classId == 4) { + break; + } - // 鏇存柊鍟嗗搧淇℃伅 - List<GoodsPicture> listPicture = dynamicInfo.getImgs(); - if (listPicture == null || listPicture.size() == 0) { - continue; - } + // 鏇存柊鍟嗗搧淇℃伅 + 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; - } - } + // 鏄惁涓�涓皬鏃朵箣鍐呭凡鏇存柊 + 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; - // 宸蹭笅鏋禝D - List<Long> listDown = new ArrayList<Long>(); - // 鍟嗗搧鍒楄〃 - List<TaoBaoGoodsBrief> listGoods = new ArrayList<TaoBaoGoodsBrief>(); + boolean needUpdate = false; + // 宸蹭笅鏋禝D + List<String> listDown = new ArrayList<>(); + // 鍟嗗搧鍒楄〃 + List<TaoBaoGoodsBrief> listGoods = new ArrayList<>(); - for (GoodsPicture goodsPicture : listPicture) { - TaoBaoGoodsBriefExtra oldExtra = goodsPicture.getGoods(); - if (oldExtra == null) { - continue; - } + for (GoodsPicture goodsPicture : listPicture) { + TaoBaoGoodsBriefExtra oldExtra = goodsPicture.getGoods(); + if (oldExtra == null) { + continue; + } - /* - * Integer state = oldExtra.getState(); if (state != null && state == 1) { - * continue; } - */ + /* + * Integer state = oldExtra.getState(); if (state != null && state == 1) { + * continue; } + */ - TaoBaoGoodsBrief goodsBrief = null; - try { - goodsBrief = redisManager.getTaoBaoGoodsBrief(oldExtra.getAuctionId()); - } catch (TaobaoGoodsDownException e) { - } + TaoBaoGoodsBrief goodsBrief = null; + try { + goodsBrief = redisManager.getTaoBaoGoodsBrief(oldExtra.getAuctionId()); + } catch (TaobaoGoodsDownException e) { + } - // 鏄惁涓嬫灦 锛� 1銆佸晢鍝佹湰韬笅鏋� 2銆佹棤鍒镐俊鎭垯璁や负涓嬫灦 - boolean isDown = true; + // 鏄惁涓嬫灦 锛� 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 (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); + if (isDown) { + oldExtra.setState(1); + oldExtra.setCoupon(false); + oldExtra.setUpdatetime(new Date()); + goodsPicture.setGoods(oldExtra); - // 鍟嗗搧宸叉姠鍏� - goodsPicture.setGoodState(1); + // 鍟嗗搧宸叉姠鍏� + 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); + // 鏇存柊鐑攢鍗曞搧鐨勫垎浜閲� + 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); + TaoBaoGoodsBriefExtra newExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief, + proportion.toString(), null); + newExtra.setUpdatetime(new Date()); + goodsPicture.setGoods(newExtra); - // 鏇存柊鐑攢鍗曞搧鐨勫垎浜閲� - if (classId == 1) { - BigDecimal shareMoney = taoBaoGoodsBriefService.getShareGoodsUserHongBao(goodsBrief,SystemEnum.blks); - ClientTextStyleVO shareMoneyDesc = new ClientTextStyleVO(); - shareMoneyDesc.setColor("#FFFFFF"); - shareMoneyDesc.setBottomColor("#E8AE48"); - shareMoneyDesc.setContent("棰勪及鍒嗕韩濂栭噾锛毬�" + shareMoney); - dynamicInfo.setDesc(shareMoneyDesc); - } - } + // 鏇存柊鐑攢鍗曞搧鐨勫垎浜閲� + if (classId == 1) { + BigDecimal shareMoney = taoBaoGoodsBriefService.getShareGoodsUserHongBao(goodsBrief, SystemEnum.blks); + ClientTextStyleVO shareMoneyDesc = new ClientTextStyleVO(); + shareMoneyDesc.setColor("#FFFFFF"); + shareMoneyDesc.setBottomColor("#E8AE48"); + shareMoneyDesc.setContent("棰勪及鍒嗕韩濂栭噾锛毬�" + shareMoney); + dynamicInfo.setDesc(shareMoneyDesc); + } + } - // 闇�瑕佹洿鏂颁俊鎭紱 - needUpdate = true; - } + // 闇�瑕佹洿鏂颁俊鎭紱 + needUpdate = true; + } - // 鏃犳晥鏇存柊淇℃伅 - if (!needUpdate) { - continue; - } + // 鏃犳晥鏇存柊淇℃伅 + if (!needUpdate) { + continue; + } - // 鏇存柊鍟嗗搧淇℃伅 - dynamicInfo.setImgs(listPicture); + // 鏇存柊鍟嗗搧淇℃伅 + 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); - } - } - } + // 鍟嗗搧宸蹭笅鏋� + 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 (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; + String auctionId = taoBaoGoodsBrief.getAuctionId(); + for (TaoBaoGoodsBrief goods : listGoods) { + if (TaoBaoUtil.isEqual( 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); - } + if (!isUpdate) { + listNew.add(taoBaoGoodsBrief); + } + } + } + dynamicInfo.setListGoodsBrief(listNew); + } + } + dynamicInfo.setUpdateTime(new Date()); + dynamicInfoDao.updateGoodInfo(dynamicInfo); + } + } catch (Exception e) { + LogHelper.errorDetailInfo(e); + } - } + } } -- Gitblit v1.8.0