From 534e0d10fdedf5fdaba6f63c99605520314a97d4 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 27 六月 2019 15:39:31 +0800
Subject: [PATCH] 分享爆品修改
---
fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/dataoke/DaTaoKeGoodsDetailV2ServiceImpl.java | 39 +++++++++++++++++++++++++++++++--------
1 files changed, 31 insertions(+), 8 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/dataoke/DaTaoKeGoodsDetailV2ServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/dataoke/DaTaoKeGoodsDetailV2ServiceImpl.java
index c9b9a31..a2238d6 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/dataoke/DaTaoKeGoodsDetailV2ServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/dataoke/DaTaoKeGoodsDetailV2ServiceImpl.java
@@ -1,8 +1,11 @@
package com.yeshi.fanli.service.impl.taobao.dataoke;
import java.util.ArrayList;
+import java.util.Collections;
+import java.util.Comparator;
import java.util.Date;
import java.util.HashMap;
+import java.util.Iterator;
import java.util.List;
import java.util.Map;
@@ -17,6 +20,7 @@
import com.yeshi.fanli.entity.taobao.dataoke.DaTaoKeDetailV2;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.taobao.dataoke.DaTaoKeGoodsDetailV2Service;
+import com.yeshi.fanli.util.BeanUtil;
import com.yeshi.fanli.util.RedisManager;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.TimeUtil;
@@ -35,11 +39,11 @@
public void startSyncGoods() {
LogHelper.test("澶ф窐瀹㈠悓姝ュ紑濮�");
DaTaoKeGoodsResult result = DaTaoKeApiUtil.listAll("1");
- int page=0;
+ int page = 0;
while (result.getGoodsList() != null && result.getGoodsList().size() > 0) {
System.out.println(page++);
for (DaTaoKeDetailV2 v2 : result.getGoodsList())
- daTaoKeGoodsDetailV2Dao.save(v2);
+ daTaoKeGoodsDetailV2Dao.saveWithCommision(v2);
result = DaTaoKeApiUtil.listAll(result.getPageId());
try {
Thread.sleep(10);
@@ -97,7 +101,7 @@
while (!StringUtil.isNullOrEmpty(result.getPageId())) {
for (DaTaoKeDetailV2 v2 : result.getGoodsList()) {
v2.setUpdateTime(new Date());
- daTaoKeGoodsDetailV2Dao.save(v2);
+ daTaoKeGoodsDetailV2Dao.saveWithCommision(v2);
}
result = DaTaoKeApiUtil.getNewGoodsList(result.getPageId(), startTime, null);
try {
@@ -112,7 +116,7 @@
private void addGoodsList(List<DaTaoKeDetailV2> goodsList) {
for (DaTaoKeDetailV2 goods : goodsList) {
goods.setUpdateTime(new Date());
- daTaoKeGoodsDetailV2Dao.save(goods);
+ daTaoKeGoodsDetailV2Dao.saveWithCommision(goods);
}
}
@@ -186,10 +190,29 @@
@Override
public List<DaTaoKeDetailV2> listPreShareHotGoods() {
-
-
-
- return null;
+ DaTaoKeGoodsDetailV2Dao daTaoKeGoodsDetailV2Dao = BeanUtil.getBean(DaTaoKeGoodsDetailV2Dao.class);
+ Map<Long, DaTaoKeDetailV2> map = new HashMap<>();
+ List<DaTaoKeDetailV2> list = daTaoKeGoodsDetailV2Dao.listPreShareHotGoods(20, "monthSales");
+ System.out.println(list);
+ list.addAll(daTaoKeGoodsDetailV2Dao.listPreShareHotGoods(20, "twoHoursSales"));
+ list.addAll(daTaoKeGoodsDetailV2Dao.listPreShareHotGoods(20, "dailySales"));
+ for (DaTaoKeDetailV2 v2 : list) {
+ map.put(v2.getId(), v2);
+ }
+
+ List<DaTaoKeDetailV2> finalList = new ArrayList<>();
+ for (Iterator<Long> its = map.keySet().iterator(); its.hasNext();) {
+ finalList.add(map.get(its.next()));
+ }
+
+ Comparator<DaTaoKeDetailV2> cm = new Comparator<DaTaoKeDetailV2>() {
+ @Override
+ public int compare(DaTaoKeDetailV2 o1, DaTaoKeDetailV2 o2) {
+ return o1.getActualPrice().compareTo(o2.getActualPrice());
+ }
+ };
+ Collections.sort(finalList, cm);
+ return finalList;
}
}
--
Gitblit v1.8.0