|
@@ -51,32 +51,32 @@ public class SceneApplication implements CommandLineRunner {
|
|
|
@Override
|
|
|
public void run(String... args) throws Exception {
|
|
|
|
|
|
- String initscene = redisClient.get("initscene");
|
|
|
- if(StrUtil.isNotEmpty(initscene)){
|
|
|
- return;
|
|
|
- }
|
|
|
- redisClient.add("initscene", "111");
|
|
|
-
|
|
|
- log.info("初始化站址编码和时间任务开始");
|
|
|
- List<Scene> list = sceneService.list(new LambdaQueryWrapper<Scene>().select(Scene::getId, Scene::getNum).isNull(Scene::getStationcode));
|
|
|
- list.stream().forEach(s->{
|
|
|
- String num = s.getNum();
|
|
|
- try {
|
|
|
- List<SceneConvertLog> logs = sceneConvertLogService.list(new LambdaQueryWrapper<SceneConvertLog>()
|
|
|
- .eq(SceneConvertLog::getEntityId, num)
|
|
|
- .eq(SceneConvertLog::getStatus, 1)
|
|
|
- .orderByDesc(SceneConvertLog::getCreateTime));
|
|
|
- if(CollUtil.isNotEmpty(logs)){
|
|
|
- SceneConvertLog sceneConvertLog = logs.get(0);
|
|
|
- s.setStationcode(sceneConvertLog.getStationCode());
|
|
|
- s.setAlgorithmTime(sceneConvertLog.getCreateTime());
|
|
|
- sceneService.updateById(s);
|
|
|
- }
|
|
|
- }catch (Exception e){
|
|
|
- log.error("填充场景站址编码和时间失败, num:{}", num, e);
|
|
|
- }
|
|
|
- });
|
|
|
- log.info("初始化站址编码和时间任务结束");
|
|
|
- redisClient.del("initscene");
|
|
|
+// String initscene = redisClient.get("initscene");
|
|
|
+// if(StrUtil.isNotEmpty(initscene)){
|
|
|
+// return;
|
|
|
+// }
|
|
|
+// redisClient.add("initscene", "111");
|
|
|
+//
|
|
|
+// log.info("初始化站址编码和时间任务开始");
|
|
|
+// List<Scene> list = sceneService.list(new LambdaQueryWrapper<Scene>().select(Scene::getId, Scene::getNum).isNull(Scene::getStationcode));
|
|
|
+// list.stream().forEach(s->{
|
|
|
+// String num = s.getNum();
|
|
|
+// try {
|
|
|
+// List<SceneConvertLog> logs = sceneConvertLogService.list(new LambdaQueryWrapper<SceneConvertLog>()
|
|
|
+// .eq(SceneConvertLog::getEntityId, num)
|
|
|
+// .eq(SceneConvertLog::getStatus, 1)
|
|
|
+// .orderByDesc(SceneConvertLog::getCreateTime));
|
|
|
+// if(CollUtil.isNotEmpty(logs)){
|
|
|
+// SceneConvertLog sceneConvertLog = logs.get(0);
|
|
|
+// s.setStationcode(sceneConvertLog.getStationCode());
|
|
|
+// s.setAlgorithmTime(sceneConvertLog.getCreateTime());
|
|
|
+// sceneService.updateById(s);
|
|
|
+// }
|
|
|
+// }catch (Exception e){
|
|
|
+// log.error("填充场景站址编码和时间失败, num:{}", num, e);
|
|
|
+// }
|
|
|
+// });
|
|
|
+// log.info("初始化站址编码和时间任务结束");
|
|
|
+// redisClient.del("initscene");
|
|
|
}
|
|
|
}
|