更新bug修改

admin

2019-06-25 fdc0107ce99b959423a2baf3cb1b31abb96f0169

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
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
package com.yeshi.fanli.job; 
 
import java.text.SimpleDateFormat; 
import java.util.ArrayList; 
import java.util.Date; 
import java.util.List; 
 
import javax.annotation.Resource; 
 
import org.springframework.scheduling.annotation.Scheduled; 
import org.springframework.stereotype.Component; 
 
import com.yeshi.fanli.entity.bus.lable.BoutiqueAutoRule; 
import com.yeshi.fanli.entity.bus.lable.QualityFactory; 
import com.yeshi.fanli.entity.common.AdminUser; 
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.lable.QualityFactoryService; 
import com.yeshi.fanli.service.inter.taobao.dataoke.DaTaoKeGoodsDetailService; 
import com.yeshi.fanli.service.inter.taobao.dataoke.DaTaoKeGoodsDetailV2Service; 
import com.yeshi.fanli.util.Constant; 
import com.yeshi.fanli.util.taobao.DaTaoKeUtil; 
import com.yeshi.fanli.util.taobao.TaoBaoUtil; 
 
/** 
 * 更新大淘客数据 
 */ 
 
@Component 
public class UpdateDaTaoKeJob { 
 
    @Resource 
    private QualityFactoryService qualityFactoryService; 
 
    @Resource 
    private DaTaoKeGoodsDetailService daTaoKeGoodsService; 
     
    @Resource 
    private DaTaoKeGoodsDetailV2Service daTaoKeGoodsDetailV2Service; 
 
    /** 
     * 限时秒杀 数据更新 
     */ 
    @Scheduled(cron = "0 0 0/2 * * ?") 
    public void doUpdateJob() { 
 
        if (!Constant.IS_TASK) 
            return; 
 
        List<DaTaoKeDetail> listTaoKe = DaTaoKeUtil.getDingDongQiang(); 
        if (listTaoKe == null || listTaoKe.size() == 0) { 
            return; 
        } 
 
        List<Long> listDaoKeId = new ArrayList<Long>(); 
        for (DaTaoKeDetail daTaoKeDetail : listTaoKe) { 
            listDaoKeId.add(daTaoKeDetail.getId()); 
        } 
 
        List<DaTaoKeDetail> listDetail = daTaoKeGoodsService.listByIds(listDaoKeId); 
        if (listDetail == null || listDetail.size() == 0) { 
            return; 
        } 
 
        List<TaoBaoGoodsBrief> listgoods = new ArrayList<TaoBaoGoodsBrief>(); 
        for (DaTaoKeDetail daTaoKeDetail : listDetail) { 
            listgoods.add(TaoBaoUtil.convert(daTaoKeDetail)); 
        } 
 
        String formatDate = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss").format(new Date()); 
        try { 
            /* 操作人： 开发账号 */ 
            AdminUser admin = new AdminUser(2L); 
            BoutiqueAutoRule autoRule = new BoutiqueAutoRule(); 
            autoRule.setAdminUser(admin); 
            autoRule.setCalss9k9(false); 
            autoRule.setFlashSale(true); 
            autoRule.setStartWeight(1); 
            autoRule.setEndWeight(3000); 
            autoRule.setGoodsSource(QualityFactory.SOURCE_TAOBAO_DATAOKE); 
            qualityFactoryService.autoInsertOrUpadateStorage(autoRule, listgoods, null); 
 
            // 删除之前的 
            qualityFactoryService.deleteNotUpdateGoods(null, formatDate, autoRule.getGoodsSource()); 
        } catch (Exception e) { 
            LogHelper.errorDetailInfo(e); 
        } 
    } 
 
    // 1个小时更新一次 
    @Scheduled(cron = "0 0 0/1 * * ? ") 
    public void doSyncJob() { 
        if (!Constant.IS_TASK) 
            return; 
        try { 
            new Thread(new Runnable() { 
 
                @Override 
                public void run() { 
                    daTaoKeGoodsService.startSyncGoods(); 
                } 
            }).start(); 
 
        } catch (Exception e) { 
            LogHelper.errorDetailInfo(e); 
        } 
    } 
 
    // 每天早上同步一次 
    @Scheduled(cron = "0 0 6 * * ? ") 
    public void doSyncJobNew() { 
        if (!Constant.IS_TASK) 
            return; 
        try { 
            new Thread(new Runnable() { 
 
                @Override 
                public void run() { 
                    daTaoKeGoodsDetailV2Service.startSyncGoods(); 
                } 
            }).start(); 
 
        } catch (Exception e) { 
            LogHelper.errorDetailInfo(e); 
        } 
    } 
 
}