diff --git a/src/main/java/com/hivekion/scenario/service/impl/ScenarioTaskServiceImpl.java b/src/main/java/com/hivekion/scenario/service/impl/ScenarioTaskServiceImpl.java index 0276910..898c208 100644 --- a/src/main/java/com/hivekion/scenario/service/impl/ScenarioTaskServiceImpl.java +++ b/src/main/java/com/hivekion/scenario/service/impl/ScenarioTaskServiceImpl.java @@ -71,13 +71,15 @@ public class ScenarioTaskServiceImpl extends //查询天气数据 WeatherResource weatherList = weatherResourceService.getOne(new QueryWrapper() .eq("scenario_id",id)); -// currentScenario.getGuid()); - //放入天气数据 - redisUtil.hset(roomId + "_" + id, "weather", weatherList.getWeatherType()); + if(weatherList!=null){ + //放入天气数据 + redisUtil.hset(roomId + "_" + id, "weather", weatherList); + } + //查询任务 ScenarioTask queryTask = new ScenarioTask(); queryTask.setScenarioId(id); - redisUtil.hset(roomId + "_" + id, "taskList", queryTaskList(queryTask).get(0).getTaskType()); + redisUtil.hset(roomId + "_" + id, "taskList", queryTaskList(queryTask)); new Thread(() -> { springGlobalTaskManager.startPerSecondTask(roomId + "_" + id + "_task", () -> {