package com.yeshi.fanli.service.impl.taobao.dataoke;
|
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.HashMap;
|
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.mybatis.taobao.dataoke.DaTaoKeDetailMapper;
|
import com.yeshi.fanli.dto.dataoke.DaTaoKeApiResult;
|
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
|
import com.yeshi.fanli.entity.taobao.dataoke.DaTaoKeDetail;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.service.inter.taobao.dataoke.DaTaoKeGoodsDetailService;
|
import com.yeshi.fanli.util.MoneyBigDecimalUtil;
|
import com.yeshi.fanli.util.RedisManager;
|
import com.yeshi.fanli.util.dataoke.DaTaoKeApiUtil;
|
|
@Service
|
public class DaTaoKeGoodsDetailServiceImpl implements DaTaoKeGoodsDetailService {
|
@Resource
|
private DaTaoKeDetailMapper daTaoKeDetailMapper;
|
|
@Resource
|
private RedisManager redisManager;
|
|
@Override
|
public void startSyncGoods() {
|
// 判断是否有正在进行的更新
|
String key1 = "dataoke-updating";
|
// if (!StringUtil.isNullOrEmpty(redisManager.getCommonString(key1)))
|
// return;
|
|
// 开始更新
|
redisManager.cacheCommonString(key1, "1", 60 * 20);
|
long firstTime = System.currentTimeMillis() - 1000 * 60 * 5L;
|
int totalCount = 0;
|
for (int p = 1; p <= 2000; p++) {// 10W数据
|
DaTaoKeApiResult result = DaTaoKeApiUtil.goodsList(p);
|
if (result.getDetailList().size() < 50)// 更新完成
|
{
|
redisManager.removeCommonString(key1);
|
break;
|
}
|
addGoodsList(result.getDetailList());
|
totalCount += result.getDetailList().size();
|
}
|
|
LogHelper.test("大淘客总共更新数据数量:" + totalCount);
|
// 清除过期数据
|
if (totalCount > 50000)// 保证有5w数据再清除过期
|
{
|
daTaoKeDetailMapper.deleteByMinUpdateTime(firstTime);
|
LogHelper.test("删除大淘客过期数据:" + totalCount);
|
}
|
}
|
|
@Transactional
|
private void addGoodsList(List<DaTaoKeDetail> goodsList) {
|
List<Long> idList = new ArrayList<>();
|
for (DaTaoKeDetail goods : goodsList) {
|
goods.setUpdateTime(new Date());
|
idList.add(goods.getId());
|
}
|
// 批量删除
|
daTaoKeDetailMapper.deleteByIdList(idList);
|
// 批量插入
|
daTaoKeDetailMapper.insertByBatch(goodsList);
|
}
|
|
@Override
|
public List<DaTaoKeDetail> listByGoodsIds(List<Long> goodsIdList) {
|
if (goodsIdList == null || goodsIdList.size() == 0)
|
return null;
|
List<DaTaoKeDetail> goodsList = daTaoKeDetailMapper.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<DaTaoKeDetail> dtList = listByGoodsIds(goodsIdList);
|
|
Map<Long, DaTaoKeDetail> map = new HashMap<>();
|
for (DaTaoKeDetail goods : dtList)
|
map.put(goods.getGoodsId(), goods);
|
for (TaoBaoGoodsBrief goods : goodsList) {
|
DaTaoKeDetail detail = map.get(goods.getAuctionId());
|
goods = filterTaoBaoGoods(goods, detail);
|
}
|
return goodsList;
|
}
|
|
@Override
|
public TaoBaoGoodsBrief filterTaoBaoGoods(TaoBaoGoodsBrief goods) {
|
List<Long> goodsIdList = new ArrayList<>();
|
goodsIdList.add(goods.getAuctionId());
|
|
List<DaTaoKeDetail> daTaoKeList = daTaoKeDetailMapper.listByGoodsIds(goodsIdList);
|
if (daTaoKeList == null || daTaoKeList.size() == 0)
|
return goods;
|
|
// 重新设置标题与券价格
|
goods = filterTaoBaoGoods(goods, daTaoKeList.get(0));
|
|
return goods;
|
}
|
|
private TaoBaoGoodsBrief filterTaoBaoGoods(TaoBaoGoodsBrief goods, DaTaoKeDetail detail) {
|
if (detail != null) {
|
// 重新设置标题与券价格
|
goods.setTitle(detail.getdTitle());
|
goods.setCouponAmount(detail.getQuanPrice());
|
if (new BigDecimal(detail.getQuanCondition()).compareTo(new BigDecimal(0)) > 0)
|
goods.setCouponInfo(String.format("满%s元减%s元", detail.getQuanCondition(),
|
MoneyBigDecimalUtil.getWithNoZera(detail.getQuanPrice()).toString()));
|
else
|
goods.setCouponInfo(String.format("%s元无条件券", detail.getQuanPrice()));
|
}
|
return goods;
|
}
|
|
@Override
|
public List<DaTaoKeDetail> listByIds(List<Long> idList) {
|
return daTaoKeDetailMapper.listByIds(idList);
|
}
|
|
}
|
