| | |
| | | package com.se.simu.controller; |
| | | |
| | | import com.baomidou.mybatisplus.core.metadata.IPage; |
| | | import com.se.simu.domain.dto.GeDb; |
| | | import com.se.simu.domain.dto.GeLayer; |
| | | import com.se.simu.domain.po.DataPo; |
| | | import com.se.simu.domain.po.SimuPo; |
| | | import com.se.simu.domain.vo.CreateSimuVo; |
| | | import com.se.simu.domain.vo.R; |
| | | import com.se.simu.domain.vo.SimuVo; |
| | | import com.se.simu.helper.StringHelper; |
| | | import com.se.simu.service.GedbService; |
| | | import com.se.simu.service.ResultService; |
| | | import com.se.simu.service.SimuService; |
| | | import com.se.simu.service.UwService; |
| | | import io.swagger.annotations.*; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.web.bind.annotation.*; |
| | |
| | | import java.util.Date; |
| | | import java.util.List; |
| | | |
| | | /** |
| | | * 仿真管理 |
| | | * |
| | | * @author WWW |
| | | * @date 2024-09-18 |
| | | */ |
| | | @Api(tags = "仿真管理") |
| | | @Slf4j |
| | | @RestController |
| | |
| | | @SuppressWarnings("ALL") |
| | | public class SimuController extends BaseController { |
| | | @Resource |
| | | UwService uwService; |
| | | |
| | | @Resource |
| | | GedbService gedbService; |
| | | |
| | | @Resource |
| | | SimuService simuService; |
| | | |
| | | @Resource |
| | | ResultService resultService; |
| | | |
| | | private final List<String> FLOOD_TYPE = new ArrayList<>(Arrays.asList("沙袋", "防水板")); |
| | | |
| | |
| | | if (null == vo.getTotal() || vo.getTotal() < 1 || vo.getTotal() > 1000) { |
| | | return fail("降雨量不能为空,且取值在1~1000之间"); |
| | | } |
| | | if (null == vo.getDuration() || vo.getDuration() < 1 || vo.getDuration() > 120) { |
| | | return fail("仿真时长不能为空,且取值在1~120之间"); |
| | | if (null == vo.getDuration() || vo.getDuration() < 1 || vo.getDuration() > 10080) { |
| | | return fail("仿真时长不能为空,且取值在1~10080之间"); |
| | | } |
| | | if (null == vo.getMinx() || null == vo.getMiny() || null == vo.getMaxx() || null == vo.getMaxy()) { |
| | | return fail("选择范围不能为空", false); |
| | | } |
| | | if (null == vo.getIsFlood() || vo.getIsFlood() < 0) { |
| | | vo.setIsFlood(0); |
| | | } |
| | | if (StringHelper.isEmpty(vo.getName())) { |
| | | vo.setName(StringHelper.YMDHMS2_FORMAT.format(new Date())); |
| | | if (null == vo.getPid() || vo.getPid() < 0) { |
| | | vo.setPid(0); |
| | | } |
| | | if (null == vo.getNum() || vo.getNum() < 1) { |
| | | vo.setNum(simuService.getMaxId() + 1); |
| | | } |
| | | if (vo.getIsFlood() > 0) { |
| | | vo.setIsFlood(1); |
| | | if (null == vo.getPid() || vo.getPid() < 0) { |
| | | vo.setPid(0); |
| | | } |
| | | if (null == vo.getStartTime()) { |
| | | vo.setStartTime(new Date()); |
| | | } |
| | | if (vo.getPid() > 0) { |
| | | SimuPo pp = simuService.getSimuByPid(vo.getPid()); |
| | | if (null == pp) { |
| | | return fail("pid不存在"); |
| | | } |
| | | if (null == vo.getFloodStart() || vo.getFloodStart() < 1 || vo.getFloodStart() > vo.getDuration() * 60) { |
| | | return fail("防汛开始时间不能为空,且取值在1~" + (vo.getDuration() * 60) + "之间"); |
| | | } |
| | |
| | | } |
| | | } |
| | | |
| | | @ApiOperation(value = "Test *") |
| | | @GetMapping("/test") |
| | | public R<Object> test() { |
| | | @ApiOperation(value = "降水范围校验") |
| | | @GetMapping("/rangeVerify") |
| | | public R<Object> rangeVerify(@RequestParam @ApiParam("最小X") double minx, |
| | | @RequestParam @ApiParam("最小y") double miny, |
| | | @RequestParam @ApiParam("最大X") double maxx, |
| | | @RequestParam @ApiParam("最大y") double maxy) { |
| | | try { |
| | | // 469538.6536261877,4416744.922022615,469853.14714664617,4417049.378602433 |
| | | //String bbox = "116.64388473935195,39.884315914604464,116.64754729082588,39.887069143903496"; |
| | | DataPo data = new DataPo("20240913", "20240913", "20240913", 116.64388473935195, 39.884315914604464, 116.64754729082588, 39.887069143903496, 50.0, 25); |
| | | Object rs = gedbService.test(data); |
| | | DataPo data = new DataPo(); |
| | | data.setMinx(minx); |
| | | data.setMiny(miny); |
| | | data.setMaxx(maxx); |
| | | data.setMaxy(maxy); |
| | | data.setEpsg(4326); |
| | | |
| | | return success(rs); |
| | | String token = gedbService.getToken(); |
| | | GeDb db = gedbService.connectGedb(token, data); |
| | | List<GeLayer> layers = gedbService.getLayers(token, db); |
| | | |
| | | return success(gedbService.queryBboxCount(token, db, layers)); |
| | | } catch (Exception ex) { |
| | | return fail(ex, null); |
| | | return fail(ex, false); |
| | | } |
| | | } |
| | | |
| | | @ApiOperation(value = "当前时间 *") |
| | | @GetMapping("/getTime") |
| | | public Object getTime() { |
| | | return System.currentTimeMillis(); |
| | | } |
| | | } |