package com.yeshi.fanli.service.impl.taobao.dataoke;
|
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.Calendar;
|
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;
|
|
import javax.annotation.Resource;
|
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import com.yeshi.fanli.dao.goods.taobao.dataoke.DaTaoKeGoodsDetailV2Dao;
|
import com.yeshi.fanli.dto.dataoke.DaTaoKeGoodsResult;
|
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
|
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.RedisManager;
|
import com.yeshi.fanli.util.StringUtil;
|
import com.yeshi.fanli.util.TimeUtil;
|
import com.yeshi.fanli.util.dataoke.DaTaoKeApiUtil;
|
import com.yeshi.fanli.util.taobao.DaTaoKeUtil;
|
import com.yeshi.fanli.util.taobao.TaoBaoUtil;
|
|
@Service
|
public class DaTaoKeGoodsDetailV2ServiceImpl implements DaTaoKeGoodsDetailV2Service {
|
@Resource
|
private DaTaoKeGoodsDetailV2Dao daTaoKeGoodsDetailV2Dao;
|
|
@Resource
|
private RedisManager redisManager;
|
|
@Override
|
public void startSyncGoods() {
|
LogHelper.test("大淘客同步开始");
|
|
int totalCount = 0;
|
try {
|
DaTaoKeGoodsResult result = DaTaoKeApiUtil.listAll("1");
|
int page = 0;
|
|
while (result.getGoodsList() != null && result.getGoodsList().size() > 0) {
|
System.out.println(page++);
|
totalCount += result.getGoodsList().size();
|
for (DaTaoKeDetailV2 v2 : result.getGoodsList()) {
|
try {
|
daTaoKeGoodsDetailV2Dao.saveWithCommision(v2);
|
} catch (Exception e) {
|
}
|
}
|
|
try {
|
result = DaTaoKeApiUtil.listAll(result.getPageId());
|
} catch (Exception e) {
|
result = DaTaoKeApiUtil.listAll(result.getPageId());
|
}
|
|
try {
|
Thread.sleep(10);
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
}
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e, "大淘客全量数据出错", "");
|
} finally {
|
LogHelper.test("大淘客新版商品同步数量:" + totalCount);
|
}
|
}
|
|
@Override
|
public void updateData() {
|
DaTaoKeGoodsResult result = DaTaoKeApiUtil.getUpdateGoodsList("1", null, null);
|
while (result.getGoodsList() != null && result.getGoodsList().size() > 0) {
|
for (DaTaoKeDetailV2 v2 : result.getGoodsList()) {
|
v2.setUpdateTime(new Date());
|
daTaoKeGoodsDetailV2Dao.updateSelective(v2);
|
}
|
try {
|
Thread.sleep(100);
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
result = DaTaoKeApiUtil.getUpdateGoodsList(result.getPageId(), null, null);
|
}
|
}
|
|
@Override
|
public void deleteInvalid() {
|
String startTime = TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyy-MM-dd 00:00:00");
|
|
DaTaoKeGoodsResult result = DaTaoKeApiUtil.getInvalidGoodsList(null, startTime, null);
|
while (result.getGoodsList() != null && result.getGoodsList().size() > 0) {
|
for (DaTaoKeDetailV2 v2 : result.getGoodsList()) {
|
v2.setUpdateTime(new Date());
|
daTaoKeGoodsDetailV2Dao.delete(v2.getId());
|
}
|
result = DaTaoKeApiUtil.getInvalidGoodsList(result.getPageId(), startTime, null);
|
System.out.println(result);
|
try {
|
Thread.sleep(200);
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
@Override
|
public void updateNewGoods() {
|
String startTime = null;
|
DaTaoKeDetailV2 latest = daTaoKeGoodsDetailV2Dao.selectLatest();
|
if (latest != null) {
|
startTime = TimeUtil.getGernalTime(latest.getCreateTime().getTime(), "yyyy-MM-dd HH:mm:ss");
|
}
|
DaTaoKeGoodsResult result = DaTaoKeApiUtil.getNewGoodsList(null, startTime, null);
|
while (!StringUtil.isNullOrEmpty(result.getPageId())) {
|
for (DaTaoKeDetailV2 v2 : result.getGoodsList()) {
|
v2.setUpdateTime(new Date());
|
daTaoKeGoodsDetailV2Dao.saveWithCommision(v2);
|
}
|
result = DaTaoKeApiUtil.getNewGoodsList(result.getPageId(), startTime, null);
|
try {
|
Thread.sleep(200);
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
@Transactional
|
private void addGoodsList(List<DaTaoKeDetailV2> goodsList) {
|
for (DaTaoKeDetailV2 goods : goodsList) {
|
goods.setUpdateTime(new Date());
|
daTaoKeGoodsDetailV2Dao.saveWithCommision(goods);
|
}
|
}
|
|
@Override
|
public List<DaTaoKeDetailV2> listByGoodsIds(List<Long> goodsIdList) {
|
if (goodsIdList == null || goodsIdList.size() == 0)
|
return null;
|
List<DaTaoKeDetailV2> goodsList = daTaoKeGoodsDetailV2Dao.listByGoodsIds(goodsIdList);
|
return goodsList;
|
}
|
|
@Override
|
public List<TaoBaoGoodsBrief> filterTaoBaoGoods(List<TaoBaoGoodsBrief> goodsList) {
|
List<Long> goodsIdList = new ArrayList<>();
|
for (TaoBaoGoodsBrief goods : goodsList)
|
goodsIdList.add(goods.getAuctionId());
|
|
List<DaTaoKeDetailV2> dtList = listByGoodsIds(goodsIdList);
|
|
Map<Long, DaTaoKeDetailV2> map = new HashMap<>();
|
for (DaTaoKeDetailV2 goods : dtList)
|
map.put(goods.getGoodsId(), goods);
|
for (TaoBaoGoodsBrief goods : goodsList) {
|
DaTaoKeDetailV2 detail = map.get(goods.getAuctionId());
|
goods = DaTaoKeUtil.filterTaoBaoGoods(goods, detail);
|
}
|
return goodsList;
|
}
|
|
@Override
|
public TaoBaoGoodsBrief filterTaoBaoGoods(TaoBaoGoodsBrief goods) {
|
List<Long> goodsIdList = new ArrayList<>();
|
goodsIdList.add(goods.getAuctionId());
|
|
List<DaTaoKeDetailV2> daTaoKeList = listByGoodsIds(goodsIdList);
|
if (daTaoKeList == null || daTaoKeList.size() == 0)
|
return goods;
|
|
// 重新设置标题与券价格
|
goods = DaTaoKeUtil.filterTaoBaoGoods(goods, daTaoKeList.get(0));
|
|
return goods;
|
}
|
|
@Override
|
public List<DaTaoKeDetailV2> listByIds(List<Long> idsList) {
|
return daTaoKeGoodsDetailV2Dao.listByIds(idsList);
|
}
|
|
@Override
|
public List<DaTaoKeDetailV2> listByDtitle(String dtitle) {
|
|
return daTaoKeGoodsDetailV2Dao.listByDtitle(dtitle.trim());
|
}
|
|
@Override
|
public List<DaTaoKeDetailV2> listSearchByTitleWithCid(String title, Long cid, int page, int pageSize) {
|
return daTaoKeGoodsDetailV2Dao.listSearchByTitleWithCid(title, (cid == null || cid == 0 ? null : cid),
|
(page - 1) * pageSize, pageSize);
|
}
|
|
@Override
|
public Long countSearchByTitleWithCid(String title, Long cid) {
|
return daTaoKeGoodsDetailV2Dao.countSearchByTitleWithCid(title, (cid == null || cid == 0 ? null : cid));
|
}
|
|
@Override
|
public List<DaTaoKeDetailV2> getGoodsNotInList(Long cid, List<Long> listId, int count) {
|
return daTaoKeGoodsDetailV2Dao.getGoodsNotInList(cid, listId, count);
|
}
|
|
@Override
|
public List<DaTaoKeDetailV2> listPreShareHotGoods(int page,BigDecimal minCommission) {
|
Map<Long, DaTaoKeDetailV2> map = new HashMap<>();
|
List<DaTaoKeDetailV2> list = daTaoKeGoodsDetailV2Dao.listPreShareHotGoods((page - 1) * 100, 100, "hotPush",minCommission);
|
System.out.println(list);
|
for (DaTaoKeDetailV2 v2 : list) {
|
map.put(v2.getId(), v2);
|
}
|
|
List<DaTaoKeDetailV2> finalList = new ArrayList<>();
|
for (Iterator<Long> its = map.keySet().iterator(); its.hasNext();) {
|
DaTaoKeDetailV2 v2 = map.get(its.next());
|
Date time = new Date(TimeUtil.convertToTimeTemp(v2.getCouponEndTime(), "yyyy-MM-dd HH:mm:ss"));
|
Date targetTime = new Date(TimeUtil.convertToTimeTemp(
|
TimeUtil.getGernalTime(System.currentTimeMillis() + 1000 * 60 * 60 * 24 * 2L, "yyyy-MM-dd"),
|
"yyyy-MM-dd") - 1000L);
|
if (time.getTime() >= targetTime.getTime())
|
finalList.add(v2);
|
}
|
|
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;
|
}
|
|
private boolean canAddToTLJBuyGoods(DaTaoKeDetailV2 v2) {
|
return TaoBaoUtil.canAddToTLJBuyGoods(TaoBaoUtil.convert(v2));
|
}
|
|
@Override
|
public List<DaTaoKeDetailV2> listPreTLJBuyGoods(int page) {
|
if (page == 1) {
|
List<DaTaoKeDetailV2> listPreGoodsList = new ArrayList<>();
|
DaTaoKeGoodsResult result = DaTaoKeApiUtil.getRankingList(DaTaoKeApiUtil.RANK_TYPE_HOT, null);
|
if (result != null && result.getGoodsList() != null)
|
listPreGoodsList.addAll(result.getGoodsList());
|
|
result = DaTaoKeApiUtil.getRankingList(DaTaoKeApiUtil.RANK_TYPE_REBUY, null);
|
if (result != null && result.getGoodsList() != null)
|
listPreGoodsList.addAll(result.getGoodsList());
|
|
List<DaTaoKeDetailV2> goodsList = new ArrayList<>();
|
for (DaTaoKeDetailV2 v2 : listPreGoodsList) {
|
if (canAddToTLJBuyGoods(v2)) {
|
Date time = new Date(TimeUtil.convertToTimeTemp(v2.getCouponEndTime(), "yyyy-MM-dd HH:mm:ss"));
|
|
Date targetTime = new Date(TimeUtil
|
.convertToTimeTemp(TimeUtil.getGernalTime(
|
System.currentTimeMillis() + 1000 * 60 * 60 * 24 * 2L, "yyyy-MM-dd"), "yyyy-MM-dd")
|
- 1000L);
|
// 如果是凌晨选择的
|
if (Calendar.getInstance().get(Calendar.HOUR_OF_DAY) < 12) {// 上午选择的计算为当天的
|
targetTime = new Date(TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(
|
System.currentTimeMillis() + 1000 * 60 * 60 * 24 * 1L, "yyyy-MM-dd"), "yyyy-MM-dd")
|
- 1000L);
|
}
|
if (time.getTime() >= targetTime.getTime())
|
goodsList.add(v2);
|
}
|
}
|
|
// 去重
|
Map<Long, DaTaoKeDetailV2> goodsMap = new HashMap<>();
|
for (DaTaoKeDetailV2 v2 : goodsList) {
|
goodsMap.put(v2.getGoodsId(), v2);
|
}
|
goodsList.clear();
|
for (Iterator<Long> its = goodsMap.keySet().iterator(); its.hasNext();) {
|
goodsList.add(goodsMap.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(goodsList, cm);
|
return goodsList;
|
} else
|
return new ArrayList<>();
|
}
|
|
@Override
|
public void deleteOutOfDate(Date minTime) {
|
daTaoKeGoodsDetailV2Dao.listAndRemoveByMinUpdateTime(minTime, 0, 3000);
|
}
|
|
}
|
