邀请码添加返回状态

yujian

2019-01-22 88b54772dbcf5ecab1e2316e4e4626ac901b8908

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
package com.yeshi.fanli.service.impl.goods; 
 
import java.util.ArrayList; 
import java.util.Iterator; 
import java.util.List; 
import java.util.ListIterator; 
 
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.service.inter.goods.TaoBaoGoodsBriefRecordService; 
 
@Service 
public class TaoBaoGoodsBriefRecordServiceImpl implements TaoBaoGoodsBriefRecordService { 
 
    @Resource 
    private TaoBaoGoodsBriefRecordMapper taoBaoGoodsBriefRecordMapper; 
 
 
    @Override 
    public int deleteAllData() { 
        return taoBaoGoodsBriefRecordMapper.deleteAllData(); 
    } 
 
 
    @Override 
    public void insertBatch(List<TaoBaoGoodsBrief> listAdd) { 
 
        /* 数据为空 */ 
        if (listAdd == null || listAdd.size() == 0) { 
            return; 
        } 
 
        /* 根据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) { 
 
                    } 
                } 
 
            } 
        } 
 
        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; 
                } 
            } 
        } 
 
        // 插入数据库 
        if (listAdd.size() > 0) { 
            taoBaoGoodsBriefRecordMapper.insertBatch(listAdd); 
        } 
    } 
 
}