|
|
|
@ -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); |
|
|
|
|