跑马灯接口编写，

amos-boot-module/amos-boot-module-api/amos-boot-module-command-api/src/main/java/com/yeejoin/amos/boot/module/command/api/dao/SeismometeorologyDtoDao.java

+package com.yeejoin.amos.boot.module.command.api.dao;
+
+import java.util.ArrayList;
+import java.util.Calendar;
+import java.util.Date;
+import java.util.List;
+
+import ch.qos.logback.core.net.SyslogOutputStream;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.domain.Sort;
+import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.data.mongodb.core.query.Query;
+import org.springframework.stereotype.Component;
+import com.yeejoin.amos.boot.module.command.api.dto.SeismometeorologyDto;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.stereotype.Service;
+/**
+ * @description:
+ * @author: tw
+ * @createDate: 2021/7/19
+ */
+@Component
+public class SeismometeorologyDtoDao {
+
+
+    @Autowired
+    private MongoTemplate mongoTemplate;
+
+    /**
+     * 保存对象SeismometeorologyDto
+     * @param
+     *
+     */
+    public void saveObj(SeismometeorologyDto book) {
+        mongoTemplate.save(book);
+    }
+
+
+
+    /**
+     *
+     * 24小時预警
+     *
+     * **/
+    public   List<SeismometeorologyDto> findCarStateByWatchSn(){
+        Calendar calendar = Calendar.getInstance(); //创建Calendar 的实例
+        calendar.add(Calendar.DAY_OF_MONTH,-1);
+        System.out.println(new Date().getTime());
+        Query query = new Query(Criteria.where("releaseTime").gte(calendar.getTimeInMillis()));
+        Sort sort= Sort.by(Sort.Direction.DESC, "releaseTime");    
+        query.with(sort);      
+        List<SeismometeorologyDto> gpsList = mongoTemplate.find(query, SeismometeorologyDto.class);
+        return gpsList;
+    }
+
+
+}
+

amos-boot-module/amos-boot-module-api/amos-boot-module-command-api/src/main/java/com/yeejoin/amos/boot/module/command/api/dto/SeismometeorologyDto.java

+package com.yeejoin.amos.boot.module.command.api.dto;
+
+import com.alibaba.excel.annotation.ExcelIgnore;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.springframework.data.mongodb.core.mapping.Document;
+import org.springframework.data.mongodb.core.mapping.Field;
+import org.springframework.data.mongodb.core.mapping.MongoId;
+
+import java.util.Date;
+
+/**
+ * @description:
+ * @author: tw
+ * @createDate: 2021/7/19
+ * 地震气象信息
+ */
+@Data
+@ApiModel(value = "SeismometeorologyDto", description = "地震气象信息")
+@Document(collection = "heart_rate")
+public class SeismometeorologyDto {
+
+
+    @MongoId
+    @ApiModelProperty(value = "主键ID")
+    protected Long sequenceNbr;
+
+    @ApiModelProperty(value = "预警类型")
+    @Field("type")
+    private String type;
+
+    @ApiModelProperty(value = "预警类型名称")
+    @Field("typeName")
+    private String typeName;
+
+    @ApiModelProperty(value = "预警等级")
+    @Field("grade")
+    private String grade;
+
+    @ApiModelProperty(value = "发布时间")
+    @Field("releaseTime")
+    private Long releaseTime;
+
+    @ApiModelProperty(value = "发布单位")
+    @Field("releaseCompany")
+    private String releaseCompany;
+
+    @ApiModelProperty(value = "发布内容")
+    @Field("content")
+    private String content;
+
+
+    public SeismometeorologyDto(Long sequenceNbr, String type, String typeName, String grade, Long releaseTime, String releaseCompany, String content) {
+        this.sequenceNbr = sequenceNbr;
+        this.type = type;
+        this.typeName = typeName;
+        this.grade = grade;
+        this.releaseTime = releaseTime;
+        this.releaseCompany = releaseCompany;
+        this.content = content;
+    }
+}

amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/resources/mapper/FireStationMapper.xml

@@ -24,7 +24,7 @@
     <select id="getStationListCount" resultType="Integer">
     SELECT
     COUNT(a.sequence_nbr) num
-    FROM cb_water_resource a
+    FROM cb_fire_station a
     where  a.is_delete=0 and a.longitude is not null and a.latitude   is not null
     <if test='par.distance!=null'>
         Round(st_distance(point(a.longitude,a.latitude),point(#{par.longitude},#{par.latitude}))*111195,1) &lt;= #{par.distance}

amos-boot-module/amos-boot-module-biz/amos-boot-module-command-biz/src/main/java/com/yeejoin/amos/boot/module/command/biz/controller/CommandController.java

@@ -3,6 +3,8 @@ package com.yeejoin.amos.boot.module.command.biz.controller;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.yeejoin.amos.boot.biz.common.controller.BaseController;
+import com.yeejoin.amos.boot.module.command.api.dao.SeismometeorologyDtoDao;
+import com.yeejoin.amos.boot.module.command.api.dto.SeismometeorologyDto;
 import com.yeejoin.amos.boot.module.common.api.dto.*;
 import com.yeejoin.amos.boot.module.common.api.entity.FireTeam;
 import com.yeejoin.amos.boot.module.common.api.service.IFireStationService;
@@ -10,16 +12,21 @@ import com.yeejoin.amos.boot.module.common.api.service.IFireTeamService;
 import com.yeejoin.amos.boot.module.common.api.service.IWaterResourceService;
 import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledZhDto;
 import com.yeejoin.amos.boot.module.jcs.api.service.IAlertCalledService;
+import com.yeejoin.amos.component.rule.config.RuleConfig;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
+import org.eclipse.paho.client.mqttv3.MqttException;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.web.bind.annotation.*;
+import org.typroject.tyboot.component.emq.EmqKeeper;
 import org.typroject.tyboot.core.foundation.enumeration.UserType;
 import org.typroject.tyboot.core.restful.doc.TycloudOperation;
 import org.typroject.tyboot.core.restful.utils.ResponseHelper;
 import org.typroject.tyboot.core.restful.utils.ResponseModel;
 
 import javax.servlet.http.HttpServletRequest;
+import java.util.Calendar;
 import java.util.List;
 
 /**
@@ -43,6 +50,9 @@ public class CommandController extends BaseController {
     IFireTeamService iFireTeamService;
     @Autowired
     IWaterResourceService iWaterResourceService;
+    @Autowired
+    SeismometeorologyDtoDao seismometeorologyDtoDao;
+
     /**
      * 警情列表
      *
@@ -79,7 +89,7 @@ public class CommandController extends BaseController {
      */
     @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
     @GetMapping(value = "SY500/list")
-    @ApiOperation(httpMethod = "GET", value = "水源列表分页查询", notes = "水源列表分页查询")
+    @ApiOperation(httpMethod = "GET", value = "500水源列表分页查询", notes = "500水源列表分页查询")
     public ResponseModel<IPage<WaterResourceZhDto>> listPageSY500(Integer pageNum, Integer pageSize, RequestData par) {
 
         par.setDistance(500D);
@@ -101,7 +111,7 @@ public class CommandController extends BaseController {
      */
     @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
     @GetMapping(value = "SY1000/list")
-    @ApiOperation(httpMethod = "GET", value = "水源列表分页查询", notes = "水源列表分页查询")
+    @ApiOperation(httpMethod = "GET", value = "1000水源列表分页查询", notes = "1000水源列表分页查询")
     public ResponseModel<IPage<WaterResourceZhDto>> listPageSY1000(Integer pageNum, Integer pageSize, RequestData par) {
         par.setDistance(1000D);
         Page<WaterResourceZhDto> pageBean = new Page<>(pageNum, pageSize);
@@ -212,5 +222,18 @@ public class CommandController extends BaseController {
     }
 
 
+    /**
+     * 跑马灯
+     *
+     * @param
+     * @return
+     */
+    @TycloudOperation(needAuth = false,ApiLevel = UserType.AGENCY)
+    @RequestMapping(value = "/seismometeorology", method = RequestMethod.GET)
+    @ApiOperation(httpMethod = "GET", value = "跑马灯", notes = "跑马灯")
+    public ResponseModel<Object> seismometeorology() {
+         
 
+        return ResponseHelper.buildResponse(seismometeorologyDtoDao.findCarStateByWatchSn());
+    }
 }
\ No newline at end of file