From 3417cf014a65765e02696c1d121ce58b2b4a8aed Mon Sep 17 00:00:00 2001 From: 13693261870 <252740454@qq.com> Date: 星期二, 08 四月 2025 15:55:36 +0800 Subject: [PATCH] 修改pom.xml --- src/main/java/com/se/simu/controller/WaterController.java | 149 ++++++++++++++++++++++++++++++++++++++++++++----- 1 files changed, 133 insertions(+), 16 deletions(-) diff --git a/src/main/java/com/se/simu/controller/WaterController.java b/src/main/java/com/se/simu/controller/WaterController.java index f391f72..8141dbc 100644 --- a/src/main/java/com/se/simu/controller/WaterController.java +++ b/src/main/java/com/se/simu/controller/WaterController.java @@ -1,8 +1,15 @@ package com.se.simu.controller; +import com.se.simu.domain.po.SimuPo; +import com.se.simu.domain.vo.PondingVo; +import com.se.simu.domain.vo.R; +import com.se.simu.helper.StringHelper; import com.se.simu.helper.WebHelper; +import com.se.simu.service.SimuService; import com.se.simu.service.WaterService; import io.swagger.annotations.Api; +import io.swagger.annotations.ApiImplicitParam; +import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; import org.springframework.http.HttpStatus; @@ -13,18 +20,17 @@ import javax.annotation.Resource; import javax.servlet.http.HttpServletResponse; +import java.io.File; -/** - * 鍐呮稘绠$悊 - * - * @author WWW - * @date 2024-07-16 - */ @Api(tags = "鍐呮稘绠$悊") @Slf4j @RestController +@SuppressWarnings("ALL") @RequestMapping("/waterlogging") -public class WaterController { +public class WaterController extends BaseController { + @Resource + SimuService simuService; + @Resource WaterService waterService; @@ -34,21 +40,66 @@ private final static long Y2000 = 949334400000L; - @ApiOperation(value = "鑾峰彇褰撳墠鏃堕棿") - @GetMapping("/getTime") - public Object getTime() { - return System.currentTimeMillis(); - } - - @ApiOperation(value = "鑾峰彇鍏冩暟鎹俊鎭�") + @ApiOperation(value = "鑾峰彇鍏冩暟鎹甁SON") @GetMapping("/{serviceName}/layer.json") - public void getLayer(@PathVariable String serviceName, HttpServletResponse res) { + public void getLayerJson(@PathVariable String serviceName, HttpServletResponse res) { try { if (!validate(serviceName, res)) { return; } - byte[] bytes = waterService.getLayerJson(serviceName); + byte[] bytes = waterService.getson(serviceName, "layer.json"); + + WebHelper.writeBytes(bytes, res); + } catch (Exception ex) { + log.error(ex.getMessage(), ex); + WebHelper.writeStr2Page(res, HttpStatus.INTERNAL_SERVER_ERROR, ex.getMessage()); + } + } + + @ApiOperation(value = "鑾峰彇闄嶆按鏇茬嚎JSON") + @GetMapping("/{serviceName}/rainfall.json") + public void getRainfallJson(@PathVariable String serviceName, HttpServletResponse res) { + try { + if (!validate(serviceName, res)) { + return; + } + + byte[] bytes = waterService.getson(serviceName, "rainfall.json"); + + WebHelper.writeBytes(bytes, res); + } catch (Exception ex) { + log.error(ex.getMessage(), ex); + WebHelper.writeStr2Page(res, HttpStatus.INTERNAL_SERVER_ERROR, ex.getMessage()); + } + } + + @ApiOperation(value = "鑾峰彇寤虹瓚鐗╂秹姘碕SON") + @GetMapping("/{serviceName}/building.json") + public void getBuildingJson(@PathVariable String serviceName, HttpServletResponse res) { + try { + if (!validate(serviceName, res)) { + return; + } + + byte[] bytes = waterService.getson(serviceName, "building.json"); + + WebHelper.writeBytes(bytes, res); + } catch (Exception ex) { + log.error(ex.getMessage(), ex); + WebHelper.writeStr2Page(res, HttpStatus.INTERNAL_SERVER_ERROR, ex.getMessage()); + } + } + + @ApiOperation(value = "鑾峰彇绉按JSON") + @GetMapping("/{serviceName}/{timestamp}/water.json") + public void getWaterJson(@PathVariable String serviceName, @PathVariable String timestamp, HttpServletResponse res) { + try { + if (!validate(serviceName, res)) { + return; + } + + byte[] bytes = waterService.getson(serviceName, "waters" + File.separator + timestamp + File.separator + "water.json"); WebHelper.writeBytes(bytes, res); } catch (Exception ex) { @@ -108,6 +159,72 @@ } } + @ApiOperation(value = "鏍规嵁鍧愭爣鏌ヨ绉按娣卞害") + @ApiImplicitParams({ + @ApiImplicitParam(name = "serviceName", value = "鏈嶅姟鍚�", dataType = "String", paramType = "path", example = "20241010095328"), + @ApiImplicitParam(name = "x", value = "X", dataType = "double", paramType = "query", example = "116.6447998"), + @ApiImplicitParam(name = "y", value = "Y", dataType = "double", paramType = "query", example = "39.8868915"), + @ApiImplicitParam(name = "timestamp", value = "鏃堕棿鎴�", dataType = "long", paramType = "query", example = "1730217660000") + }) + @GetMapping("/{serviceName}/getWaterHeight") + public R<Object> getWaterHeight(@PathVariable String serviceName, double x, double y, long timestamp, HttpServletResponse res) { + try { + SimuPo simu = simuService.getSimuByServiceName(serviceName); + if (null == simu) { + return null; + } + + Double depth = waterService.getWaterHeight(simu, x, y, timestamp); + Double area = waterService.getWaterArea(simu, x, y, timestamp); + + return success(new PondingVo(depth, area)); + } catch (Exception ex) { + log.error(ex.getMessage(), ex); + return fail(ex); + } + } + + @ApiOperation(value = "鏍规嵁seid鏌ヨ寤虹瓚鐗╂秹姘存繁搴�") + @ApiImplicitParams({ + @ApiImplicitParam(name = "serviceName", value = "鏈嶅姟鍚�", dataType = "String", paramType = "path", example = "20241010095328"), + @ApiImplicitParam(name = "seid", value = "X", dataType = "String", paramType = "query", example = "5_f128d8b1aba6455c88d2f42334ca62bb") + }) + @GetMapping("/{serviceName}/getBuildingDepthBySeid") + public R<Object> getBuildingDepthBySeid(@PathVariable String serviceName, String seid) { + try { + if (StringHelper.isEmpty(serviceName) || StringHelper.isEmpty(seid)) { + return null; + } + + // 鏍规嵁鏈嶅姟鍚�+鏃堕棿鎴�+鍧愭爣锛屾煡璇㈠搴旂殑绉按娣卞害 + return success(waterService.getBuildingDepthBySeid(serviceName, seid)); + } catch (Exception ex) { + log.error(ex.getMessage(), ex); + return fail(ex); + } + } + + + @ApiOperation(value = "鏍规嵁timestamp鏌ヨ寤虹瓚鐗╂秹姘存繁搴�") + @ApiImplicitParams({ + @ApiImplicitParam(name = "serviceName", value = "鏈嶅姟鍚�", dataType = "String", paramType = "path", example = "20241010095328"), + @ApiImplicitParam(name = "timestamp", value = "鏃堕棿鎴�", dataType = "Long", paramType = "query", example = "1730217660000") + }) + @GetMapping("/{serviceName}/getBuildingDepthByTime") + public R<Object> getBuildingDepthByTime(@PathVariable String serviceName, Long timestamp) { + try { + if (StringHelper.isEmpty(serviceName) || null == timestamp) { + return null; + } + + // 鏍规嵁鏈嶅姟鍚�+鏃堕棿鎴�+鍧愭爣锛屾煡璇㈠搴旂殑绉按娣卞害 + return success(waterService.getBuildingDepthByTime(serviceName, timestamp)); + } catch (Exception ex) { + log.error(ex.getMessage(), ex); + return fail(ex); + } + } + private boolean validate(String serviceName, HttpServletResponse res) { if (WebHelper.isEmpty(serviceName)) { return WebHelper.writeJson2Page(res, HttpStatus.BAD_REQUEST, "鏈嶅姟鍚嶄笉鑳戒负绌�"); -- Gitblit v1.9.3