新增环境（浊度）接口

environment-data-service/src/main/java/com/zksy/environment/EnvironmentApplication.java

@@ -16,6 +16,6 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
 public class EnvironmentApplication {
     public static void main(String[] args) {
         SpringApplication.run(EnvironmentApplication.class,args);
-        System.out.println("启动成功");
+        System.out.println("浊度传感服务启动成功");
     }
 }

environment-data-service/src/main/java/com/zksy/environment/controller/PictureMessageController.java

@@ -0,0 +1,35 @@
+package com.zksy.environment.controller;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.zksy.common.core.domain.Result;
+import com.zksy.common.utils.SearchUtil;
+import com.zksy.environment.domain.po.PictureMessage;
+import com.zksy.environment.service.PictureMessageService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+@RestController
+@RequestMapping("/pictureMessage")
+@Api(tags = "遥测站图片采集信息", description = "遥测站图片采集信息")
+public class PictureMessageController {
+    @Autowired
+    private PictureMessageService service;
+    @GetMapping("/findByPage")
+    @ApiOperation(value = "分页查询")
+    public Result getPictureMessagePage(long pageNum, long pageSize, String conditionJson) throws Exception {
+        Page<PictureMessage> page = service.page(new Page<>(pageNum, pageSize), SearchUtil.parseWhereSql(conditionJson));
+        return Result.ok(page);
+    }
+    @GetMapping("/getAll")
+    @ApiOperation(value = "查询所有")
+    public Result getAllByConditionJson(String conditionJson) throws Exception {
+        List<PictureMessage> list = service.list(SearchUtil.parseWhereSql(conditionJson));
+        return Result.ok(list);
+    }
+}

environment-data-service/src/main/java/com/zksy/environment/controller/StationHourController.java

@@ -0,0 +1,35 @@
+package com.zksy.environment.controller;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.zksy.common.core.domain.Result;
+import com.zksy.common.utils.SearchUtil;
+import com.zksy.environment.domain.po.StationHour;
+import com.zksy.environment.service.StationHourService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+@RestController
+@RequestMapping("/stationHour")
+@Api(tags = "报送以小时为基本单位的历史数据和实时数据", description = "报送以小时为基本单位的历史数据和实时数据")
+public class StationHourController {
+    @Autowired
+    private StationHourService service;
+    @GetMapping("/findByPage")
+    @ApiOperation(value = "分页查询")
+    public Result getPictureMessagePage(long pageNum, long pageSize, String conditionJson) throws Exception {
+        Page<StationHour> page = service.page(new Page<>(pageNum, pageSize), SearchUtil.parseWhereSql(conditionJson));
+        return Result.ok(page);
+    }
+    @GetMapping("/getAll")
+    @ApiOperation(value = "查询所有")
+    public Result getAllByConditionJson(String conditionJson) throws Exception {
+        List<StationHour> list = service.list(SearchUtil.parseWhereSql(conditionJson));
+        return Result.ok(list);
+    }
+}