定时获取卸料平台数据
This commit is contained in:
parent
cde5ab179c
commit
e58cce6201
@ -299,6 +299,7 @@ public class WebSecurityConfig extends WebSecurityConfigurerAdapter {
|
|||||||
.antMatchers("/xmgl/workerInfo/selectPersonTypeAndEduStatistics").permitAll()
|
.antMatchers("/xmgl/workerInfo/selectPersonTypeAndEduStatistics").permitAll()
|
||||||
.antMatchers("/xmgl/taskProgressRt/queryById").permitAll()
|
.antMatchers("/xmgl/taskProgressRt/queryById").permitAll()
|
||||||
.antMatchers("/xmgl/frontierProtectionNoNetData/alaDeviceSubscribe").permitAll()
|
.antMatchers("/xmgl/frontierProtectionNoNetData/alaDeviceSubscribe").permitAll()
|
||||||
|
.antMatchers("/xmgl/highSlopeCurrentData/exportData").permitAll()
|
||||||
.antMatchers(HttpMethod.OPTIONS, "/**").anonymous()
|
.antMatchers(HttpMethod.OPTIONS, "/**").anonymous()
|
||||||
.anyRequest().authenticated() // 剩下所有的验证都需要验证.
|
.anyRequest().authenticated() // 剩下所有的验证都需要验证.
|
||||||
.and()
|
.and()
|
||||||
|
|||||||
@ -85,7 +85,7 @@ public class DischargingPlatformCurrentDataTask {
|
|||||||
map.put("pageNum", "1");
|
map.put("pageNum", "1");
|
||||||
map.put("startTime", DateUtil.formatDateTime(DateUtil.offsetMinute(now, -5)));
|
map.put("startTime", DateUtil.formatDateTime(DateUtil.offsetMinute(now, -5)));
|
||||||
map.put("endTime", DateUtil.formatDateTime(now));
|
map.put("endTime", DateUtil.formatDateTime(now));
|
||||||
JSONObject realTimeData = xiwonUtil.postForm("/unload/listRealUnloadData", project.getXiwonAppId(), project.getXiwonAppSecret(), map, JSONObject.class, (() -> {
|
JSONObject realTimeData = xiwonUtil.postForm("/unloading/realTimeData", project.getXiwonAppId(), project.getXiwonAppSecret(), map, JSONObject.class, (() -> {
|
||||||
map.put("deviceSn", devSn);
|
map.put("deviceSn", devSn);
|
||||||
return map;
|
return map;
|
||||||
}));
|
}));
|
||||||
@ -96,7 +96,10 @@ public class DischargingPlatformCurrentDataTask {
|
|||||||
JSONArray dataArray = realTimeData.getJSONArray("data");
|
JSONArray dataArray = realTimeData.getJSONArray("data");
|
||||||
if (CollUtil.isNotEmpty(dataArray)) {
|
if (CollUtil.isNotEmpty(dataArray)) {
|
||||||
DischargingPlatformDev platformDev = dischargingPlatformDevMapper.selectOne(new LambdaQueryWrapper<DischargingPlatformDev>()
|
DischargingPlatformDev platformDev = dischargingPlatformDevMapper.selectOne(new LambdaQueryWrapper<DischargingPlatformDev>()
|
||||||
.eq(DischargingPlatformDev::getDevSn, dev));
|
.eq(DischargingPlatformDev::getDevSn, devSn));
|
||||||
|
if (platformDev == null) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
// 解析请求到的参数,保存到我们的数据库
|
// 解析请求到的参数,保存到我们的数据库
|
||||||
for (Object o : dataArray) {
|
for (Object o : dataArray) {
|
||||||
DischargingPlatformCurrentDataDto dto = BeanUtil.toBean(o, DischargingPlatformCurrentDataDto.class);
|
DischargingPlatformCurrentDataDto dto = BeanUtil.toBean(o, DischargingPlatformCurrentDataDto.class);
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user