|
@@ -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");
|
|
|
}
|
|
|
}
|