diff --git a/inspect-main/inspect-main-task/src/main/java/com/inspect/analysis/controller/AnalysisController.java b/inspect-main/inspect-main-task/src/main/java/com/inspect/analysis/controller/AnalysisController.java index 7b25da7..c96121a 100644 --- a/inspect-main/inspect-main-task/src/main/java/com/inspect/analysis/controller/AnalysisController.java +++ b/inspect-main/inspect-main-task/src/main/java/com/inspect/analysis/controller/AnalysisController.java @@ -3,6 +3,7 @@ package com.inspect.analysis.controller; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.alibaba.nacos.shaded.com.google.gson.Gson; +import com.inspect.analysis.constant.AnalyseConstants; import com.inspect.analysis.domain.*; import com.inspect.analysis.service.IAnalyseResponseService; import com.inspect.analysis.service.IResultAnalysisService; @@ -17,6 +18,7 @@ import com.inspect.base.redis.service.RedisService; import com.inspect.message.MessageUtils; import com.inspect.mqtt.services.Warn.IUploadServer; import com.inspect.partrolresult.client.WebsocketService; +import com.inspect.partrolresult.domain.AnalyseRequest; import com.inspect.partrolresult.domain.PatrolResult; import com.inspect.partrolresult.service.IPatrolResultService; import com.inspect.resultmain.domain.PatrolTaskResultMain; @@ -91,6 +93,20 @@ public class AnalysisController extends BaseController { } } + /** + * 跳过61上报,直接验证初筛、大模型流程 + * 该接口仅用于“调试” + * @param analyseRequest + * @return + */ + @PostMapping("/sendRequest") + public AjaxResult sendRequest(@RequestBody AnalyseRequest analyseRequest) { + logger.info("sendRequest: {}", analyseRequest); + String requestDataToRedis = new Gson().toJson(analyseRequest); + redisService.redisTemplate.opsForList().rightPush(AnalyseConstants.ALGORITHM_REQUEST_QUEUE, requestDataToRedis); + return AjaxResult.success(); + } + @PostMapping("/old/picAnalyseRetNotify") public AjaxResult add(@RequestBody final String alarmDefect) { System.out.println(alarmDefect);