发送天气资源消息

src/main/java/com/hivekion/baseData/entity/Scenario.java

@@ -67,6 +67,7 @@ public class Scenario extends SearchInputVo {
   @ApiModelProperty("是不是小堆")
   private Byte isXd;
   @TableField(value = "start_time")
+  @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
   private LocalDateTime startTime;
   @TableField(value = "end_time")
   @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")

src/main/java/com/hivekion/scenario/service/impl/ScenarioTaskServiceImpl.java

@@ -76,7 +76,7 @@ public class ScenarioTaskServiceImpl extends
 
     //查询天气数据
     List<WeatherResource> weatherList = weatherResourceService.list(new QueryWrapper<WeatherResource>()
-    .eq("scenario_id",id));
+    .eq("scenario_id",scenarioId));
     JSONArray jsonArray = new JSONArray();
     for(WeatherResource weatherResource: weatherList) {
       String  weaherStr = JSON.toJSONString(weatherResource);
@@ -92,7 +92,7 @@ public class ScenarioTaskServiceImpl extends
       jsonArray.add(weatherObj);
     }
     //放入天气数据
-    redisUtil.hset(roomId + "_" + id, "weather", JSON.toJSONString(jsonArray));
+    redisUtil.hset(roomId + "_" + scenarioId, "weather", JSON.toJSONString(jsonArray));
     //查询任务
     ScenarioTask queryTask = new ScenarioTask();
     queryTask.setScenarioId(scenarioId);

src/main/resources/mapper/tbl/ScenarioMapper.xml

@@ -63,6 +63,8 @@
       Author,
       CreateUserId,
       CreateTime,
+      start_time As startTime,
+      end_time,
       id,
       left_up_lng AS leftUpLng,
       right_up_lng AS rightUpLng,