package com.yeshi.fanli.service.impl.goods;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
import javax.annotation.Resource;
|
|
import org.springframework.stereotype.Service;
|
|
import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoGoodsBriefRecordMapper;
|
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
|
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBriefRecord;
|
import com.yeshi.fanli.service.inter.goods.TaoBaoGoodsBriefRecordService;
|
|
@Service
|
public class TaoBaoGoodsBriefRecordServiceImpl implements TaoBaoGoodsBriefRecordService {
|
|
@Resource
|
private TaoBaoGoodsBriefRecordMapper taoBaoGoodsBriefRecordMapper;
|
|
@Override
|
public int deleteByPrimaryKey(Long id) {
|
return taoBaoGoodsBriefRecordMapper.deleteByPrimaryKey(id);
|
}
|
|
@Override
|
public int insert(TaoBaoGoodsBriefRecord record) {
|
return taoBaoGoodsBriefRecordMapper.insert(record);
|
}
|
|
@Override
|
public int insertSelective(TaoBaoGoodsBriefRecord record) {
|
return taoBaoGoodsBriefRecordMapper.insertSelective(record);
|
}
|
|
@Override
|
public TaoBaoGoodsBriefRecord selectByPrimaryKey(Long id) {
|
return taoBaoGoodsBriefRecordMapper.selectByPrimaryKey(id);
|
}
|
|
@Override
|
public int updateByPrimaryKeySelective(TaoBaoGoodsBriefRecord record) {
|
return taoBaoGoodsBriefRecordMapper.updateByPrimaryKeySelective(record);
|
}
|
|
@Override
|
public int updateByPrimaryKey(TaoBaoGoodsBriefRecord record) {
|
return taoBaoGoodsBriefRecordMapper.updateByPrimaryKey(record);
|
}
|
|
|
@Override
|
public void insertBatch(List<TaoBaoGoodsBrief> record) {
|
|
/* 数据为空 */
|
if (record == null || record.size() == 0) {
|
return;
|
}
|
|
|
/* 根据auctionId 查询数据库是否存在数据 */
|
List<String> auctionIdList = new ArrayList<String>();
|
for (int i = 0; i < record.size(); i++) {
|
TaoBaoGoodsBrief taoBaoGoodsBrief = record.get(i);
|
Long auctionId = taoBaoGoodsBrief.getAuctionId();
|
if (auctionId != null) {
|
auctionIdList.add(auctionId+"");
|
}
|
}
|
|
/* 查询结果比对*/
|
List<String> existAuctionIdList = new ArrayList<String>();
|
if (auctionIdList.size() > 0) {
|
List<TaoBaoGoodsBrief> existList = taoBaoGoodsBriefRecordMapper.queryGoodsByAuctionId(auctionIdList);
|
|
if (existList != null && existList.size() > 0) {
|
for (TaoBaoGoodsBrief taoBaoGoodsBrief : existList) {
|
Long auctionId = taoBaoGoodsBrief.getAuctionId();
|
if (auctionIdList.contains(auctionId+"")) {
|
existAuctionIdList.add(auctionId +"");
|
}
|
}
|
}
|
}
|
|
|
|
/* 每100 数据 插入数据库 */
|
int j = 0;
|
List<TaoBaoGoodsBrief> newList = new ArrayList<TaoBaoGoodsBrief>();
|
|
for (int i = 0; i < record.size(); i++) {
|
|
TaoBaoGoodsBrief taoBaoGoodsBrief = record.get(i);
|
|
Long auctionId = taoBaoGoodsBrief.getAuctionId();
|
|
|
if (existAuctionIdList.size() > 0){
|
// 已经存在数据库
|
if (existAuctionIdList.contains(auctionId+ "")){
|
continue;
|
}
|
}
|
|
taoBaoGoodsBrief.setCreatetime(new Date());
|
j++;
|
newList.add(taoBaoGoodsBrief);
|
|
if (j == 100) {
|
taoBaoGoodsBriefRecordMapper.insertBatch(newList);
|
j = 0;
|
newList.clear();
|
|
} else if (i == record.size() - 1) {
|
taoBaoGoodsBriefRecordMapper.insertBatch(newList);
|
}
|
|
}
|
|
}
|
|
@Override
|
public List<TaoBaoGoodsBrief> queryByAuctionId(Long auctionId) {
|
return taoBaoGoodsBriefRecordMapper.queryByAuctionId(auctionId);
|
}
|
|
}
|
