From 88b54772dbcf5ecab1e2316e4e4626ac901b8908 Mon Sep 17 00:00:00 2001 From: yujian <yujian> Date: 星期二, 22 一月 2019 15:58:24 +0800 Subject: [PATCH] 邀请码添加返回状态 --- fanli/src/main/java/com/yeshi/fanli/service/impl/goods/TaoBaoGoodsBriefRecordServiceImpl.java | 137 +++++++++++++++------------------------------ 1 files changed, 47 insertions(+), 90 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/goods/TaoBaoGoodsBriefRecordServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/goods/TaoBaoGoodsBriefRecordServiceImpl.java index 2a04556..c328811 100644 --- a/fanli/src/main/java/com/yeshi/fanli/service/impl/goods/TaoBaoGoodsBriefRecordServiceImpl.java +++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/goods/TaoBaoGoodsBriefRecordServiceImpl.java @@ -1,8 +1,9 @@ package com.yeshi.fanli.service.impl.goods; import java.util.ArrayList; -import java.util.Date; +import java.util.Iterator; import java.util.List; +import java.util.ListIterator; import javax.annotation.Resource; @@ -10,7 +11,6 @@ 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 @@ -19,111 +19,68 @@ @Resource private TaoBaoGoodsBriefRecordMapper taoBaoGoodsBriefRecordMapper; - @Override - public int deleteByPrimaryKey(Long id) { - return taoBaoGoodsBriefRecordMapper.deleteByPrimaryKey(id); - } @Override - public int insert(TaoBaoGoodsBriefRecord record) { - return taoBaoGoodsBriefRecordMapper.insert(record); + public int deleteAllData() { + return taoBaoGoodsBriefRecordMapper.deleteAllData(); } - @Override - public int insertSelective(TaoBaoGoodsBriefRecord record) { - return taoBaoGoodsBriefRecordMapper.insertSelective(record); - } @Override - public TaoBaoGoodsBriefRecord selectByPrimaryKey(Long id) { - return taoBaoGoodsBriefRecordMapper.selectByPrimaryKey(id); - } + public void insertBatch(List<TaoBaoGoodsBrief> listAdd) { - @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) { + if (listAdd == null || listAdd.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<Long> auctionIdList = new ArrayList<Long>(); + for (TaoBaoGoodsBrief goodsBrief : listAdd) { + auctionIdList.add(goodsBrief.getAuctionId()); + } + + if (auctionIdList.size() == 0) { + return; + } + + List<TaoBaoGoodsBrief> listHas = taoBaoGoodsBriefRecordMapper.queryByAuctionIdList(auctionIdList); + if (listHas != null && listHas.size() > 0) { + for (TaoBaoGoodsBrief taoBaoGoodsBrief : listHas) { + Long auctionId = taoBaoGoodsBrief.getAuctionId(); + + for (TaoBaoGoodsBrief goodsBrief : listAdd) { + Long auctionId2 = goodsBrief.getAuctionId(); + if (auctionId.equals(auctionId2) || auctionId == auctionId2) { + + } + } + } } - - /* 鏌ヨ缁撴灉姣斿*/ - 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 +""); - } + + Iterator<TaoBaoGoodsBrief> listIterator = listHas.iterator(); + while (listIterator.hasNext()) { + // 宸茬粡淇濆瓨鍦ㄦ暟鎹簱涓殑鏁版嵁 + TaoBaoGoodsBrief taoBaoGoodsBrief = listIterator.next(); + Long auctionId = taoBaoGoodsBrief.getAuctionId(); + + // 鍒犻櫎宸插瓨鍦ㄦ暟鎹� + ListIterator<TaoBaoGoodsBrief> listNew = listAdd.listIterator(); + while (listNew.hasNext()) { + TaoBaoGoodsBrief goodsBrief = listNew.next(); + Long auctionIdNew = goodsBrief.getAuctionId(); + if (auctionId.equals(auctionIdNew) || auctionId == auctionIdNew) { + listAdd.remove(goodsBrief); + break; } } } - - - - /* 姣�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); - } - + + // 鎻掑叆鏁版嵁搴� + if (listAdd.size() > 0) { + taoBaoGoodsBriefRecordMapper.insertBatch(listAdd); } - } - @Override - public List<TaoBaoGoodsBrief> queryByAuctionId(Long auctionId) { - return taoBaoGoodsBriefRecordMapper.queryByAuctionId(auctionId); - } - } -- Gitblit v1.8.0