| | |
| | | import com.se.nsl.domain.po.Simu; |
| | | import com.se.nsl.domain.po.SimuData; |
| | | import com.se.nsl.domain.vo.*; |
| | | import com.se.nsl.service.RealTimeSimulationService; |
| | | import com.se.nsl.service.ResolveService; |
| | | import com.se.nsl.service.SimuService; |
| | | import com.se.nsl.service.*; |
| | | import com.se.nsl.utils.SimulateType; |
| | | import io.swagger.annotations.Api; |
| | | import io.swagger.annotations.ApiOperation; |
| | | import io.swagger.v3.oas.annotations.Parameter; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.gdal.ogr.Geometry; |
| | | import org.gdal.ogr.ogr; |
| | |
| | | ResolveService resolveService; |
| | | |
| | | @Resource |
| | | RealTimeSimulationService rts; |
| | | RealTimeSimulationAsyncService rtsas; |
| | | |
| | | @Resource |
| | | CrossSectionAnalysisService scas; |
| | | |
| | | /** |
| | | * 分页查询推演模拟 |
| | |
| | | if (null == id || id < 1) return fail("id为空"); |
| | | |
| | | Simu simu = simuService.selectById(id); |
| | | if (null == simu) return fail("方案找不到"); |
| | | if (null == simu) return notFound("方案找不到"); |
| | | if (StringUtils.isEmpty(simu.getData())) return fail("方案数据(JSON)为空"); |
| | | |
| | | SimuData data = JSON.parseObject(simu.getData(), SimuData.class); |
| | |
| | | int rows = resolveService.start(simu); |
| | | return success("ok"); |
| | | } else if (simulateType == SimulateType.REAL_TIME) { |
| | | String s = rts.realTimeSimulate(simu); |
| | | return success(s); |
| | | rtsas.startSimulation(simu); |
| | | return success(null, "实时模拟任务已提交"); |
| | | } |
| | | return fail("模拟类型暂不支持"); |
| | | } catch (Exception ex) { |
| | |
| | | return success(simuResults, simuResults.size()); |
| | | } |
| | | } |
| | | |
| | | @ApiOperation(value = "crossSection") |
| | | @GetMapping("/crossSection") |
| | | public R<Object> crossSection(@Parameter(description = "方案id,示例:50") Integer id, |
| | | @Parameter(description = "时间戳,示例:1751552400000") Long time, |
| | | @Parameter(description = "起点坐标,示例:116.59049537485063,40.564178548127686") String startPoint, |
| | | @Parameter(description = "终点坐标,示例:116.5901406492509,40.56499045715429") String endPoint) { |
| | | if (null == id || id < 1) return clientError("id不能为空"); |
| | | Simu simu = simuService.selectById(id); |
| | | if (simu == null) { |
| | | return clientError("找不到对应的服务"); |
| | | } |
| | | String serviceName = simu.getServiceName(); |
| | | if (serviceName == null) { |
| | | return fail("找不到对应的服务"); |
| | | } |
| | | if (startPoint == null) { |
| | | return clientError("起点不能为空"); |
| | | } |
| | | if (endPoint == null) { |
| | | return clientError("终点不能为空"); |
| | | } |
| | | String[] sp = startPoint.split(","); |
| | | double[] s = new double[] {Double.parseDouble(sp[0]), Double.parseDouble(sp[1])}; |
| | | String[] ep = endPoint.split(","); |
| | | double[] e = new double[] {Double.parseDouble(ep[0]), Double.parseDouble(ep[1])}; |
| | | try { |
| | | if (time == null) { |
| | | List<CrossSectionAnalysisResult> result = scas.crossSectionAnalysis(serviceName, s, e); |
| | | return success(result, result.size()); |
| | | } else { |
| | | CrossSectionAnalysisResult res = scas.crossSectionAnalysis(serviceName, s, e, time); |
| | | return success(res, 1); |
| | | } |
| | | } catch (IllegalArgumentException ex) { |
| | | return fail(ex.getMessage(), null); |
| | | } |
| | | } |
| | | |
| | | @ApiOperation(value = "stop") |
| | | @GetMapping("/stop") |
| | | public R<Object> stop(Integer id) { |
| | | if (id == null) { |
| | | return fail("id不能为空"); |
| | | } |
| | | try { |
| | | rtsas.stopSimulation(id); |
| | | } catch (IllegalArgumentException e) { |
| | | return notFound(e.getMessage()); |
| | | } |
| | | return success(null, "正在停止id为" + id + "的模拟任务"); |
| | | } |
| | | |
| | | @ApiOperation(value = "results") |
| | | @GetMapping("/results") |
| | | public R<Object> querySimulationResult(Integer id) { |
| | | if (null == id || id < 1) return clientError("id不能为空"); |
| | | Simu simu = simuService.selectById(id); |
| | | if (simu == null) { |
| | | return clientError("找不到对应的服务"); |
| | | } |
| | | String serviceName = simu.getServiceName(); |
| | | if (serviceName == null) { |
| | | return fail("找不到对应的服务"); |
| | | } |
| | | List<String> results = resolveService.simulationResults(serviceName); |
| | | return success(results, results.size()); |
| | | } |
| | | } |