DataVCacheQuartz.java
5.14 KB
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
package com.xiniunet.quartz;
import com.alibaba.dubbo.common.utils.StringUtils;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.xiniunet.framework.base.BaseRequest;
import com.xiniunet.framework.cache.CacheManager;
import com.xiniunet.framework.constant.CacheTimeEnum;
import com.xiniunet.framework.log.LogUtil;
import com.xiniunet.framework.security.Passport;
import com.xiniunet.framework.util.EncryptUtil;
import com.xiniunet.framework.util.SettingUtil;
import com.xiniunet.framework.util.SpringContext;
import com.xiniunet.railway.domain.DiffLinesTrainsEscortCount;
import com.xiniunet.railway.domain.DiffTrainsEscortCount;
import com.xiniunet.railway.domain.EscortTrainNoCount;
import com.xiniunet.railway.enumication.LaidTypeEnum;
import com.xiniunet.railway.request.ApiLogCreateRequest;
import com.xiniunet.railway.request.DiffLinesTrainsEscortsNumberPercentGetRequest;
import com.xiniunet.railway.response.ApiLogCreateResponse;
import com.xiniunet.railway.response.EscortsNumberPercentGetResponse;
import com.xiniunet.service.railway.Constant;
import com.xiniunet.service.railway.biz.ApiLogManager;
import com.xiniunet.service.railway.biz.EscortAttendanceManager;
import com.xiniunet.service.railway.util.RailwayThirdTools;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.Date;
/**
* Created by 胡 on 2016/12/30.
* dataV接口的缓存 弃用
*/
@Component
@Deprecated
public class DataVCacheQuartz {
private static Logger logger = LoggerFactory.getLogger(RailwayThirdTools.class);
private static CacheManager cacheManager = SpringContext.getApplicationContext().getBean(CacheManager.class);
@Autowired
private EscortAttendanceManager escortAttendanceManager;
/**
* 执行定时器,每5s执行一次
*/
public void execute() {
logger.warn("dataV接口的缓存的缓存开始==========================");
String quartzTask = SettingUtil.getProperty("", "enable.quartz.task");
if (StringUtils.isEmpty(quartzTask) || quartzTask.toLowerCase().equals("false")) {
logger.warn("定时任务CheckIsLaidOffQuartz错误，该服务器未设置自动同步定时任务！");
return;
}
Passport passport = new Passport();
passport.setTenantId(Constant.RAILWAY_TENANT_ID);
passport.setUserId(Constant.RAILWAY_USER_ID);
DiffLinesTrainsEscortsNumberPercentGetRequest diffLinesTrainsEscortsNumberPercentGetRequest = new DiffLinesTrainsEscortsNumberPercentGetRequest();
diffLinesTrainsEscortsNumberPercentGetRequest.setFromCache(false);
diffLinesTrainsEscortsNumberPercentGetRequest.setType(LaidTypeEnum.LAID_ON.toString());
EscortsNumberPercentGetResponse<DiffLinesTrainsEscortCount> escortsNumberPercentGetResponse= escortAttendanceManager.getDiffLinesTrainsCarriageEscortsNumberPercent(diffLinesTrainsEscortsNumberPercentGetRequest,passport);
if(escortsNumberPercentGetResponse.hasError()){
logger.warn("escortAttendanceManager.getDiffLinesTrainsCarriageEscortsNumberPercent 出错！"+JSONObject.toJSONString(escortsNumberPercentGetResponse));
}
EscortsNumberPercentGetResponse<DiffTrainsEscortCount> escortsNumberPercentGetResponse1 = escortAttendanceManager.getDiffTrainsCarriageEscortsNumberPercent(diffLinesTrainsEscortsNumberPercentGetRequest,passport);
if(escortsNumberPercentGetResponse1.hasError()){
logger.warn("escortAttendanceManager.getDiffTrainsCarriageEscortsNumberPercent 出错！"+JSONObject.toJSONString(escortsNumberPercentGetResponse1));
}
EscortsNumberPercentGetResponse<DiffTrainsEscortCount> escortsNumberPercentGetResponse2 = escortAttendanceManager.getDiffTrainsEscortsNumberPercent(diffLinesTrainsEscortsNumberPercentGetRequest,passport);
if(escortsNumberPercentGetResponse2.hasError()){
logger.warn("escortAttendanceManager.getDiffTrainsEscortsNumberPercent 出错！"+JSONObject.toJSONString(escortsNumberPercentGetResponse2));
}
EscortsNumberPercentGetResponse<EscortTrainNoCount> escortTrainNoCountEscortsNumberPercentGetResponse =escortAttendanceManager.findHaveEscortsTrainNo(diffLinesTrainsEscortsNumberPercentGetRequest,passport);
if(escortTrainNoCountEscortsNumberPercentGetResponse.hasError()){
logger.warn("escortAttendanceManager.findHaveEscortsTrainNo 出错！"+JSONObject.toJSONString(escortTrainNoCountEscortsNumberPercentGetResponse));
}
EscortsNumberPercentGetResponse<DiffLinesTrainsEscortCount> escortsNumberPercentGetResponse3 =escortAttendanceManager.getDiffLinesTrainsEscortsNumberPercentCache(diffLinesTrainsEscortsNumberPercentGetRequest,passport);
if(escortsNumberPercentGetResponse3.hasError()){
logger.warn("escortAttendanceManager.getDiffLinesTrainsEscortsNumberPercentCache 出错！"+JSONObject.toJSONString(escortsNumberPercentGetResponse3));
}
logger.warn("dataV接口的缓存的缓存结束====================");
}
}