Middleware/cn-data-platform
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

补招逻辑修改，手动补招和前端采用websokcet通讯

Browse Source
This commit is contained in:
hzj
2025-08-22 15:55:23 +08:00
parent f519fd3e56
commit 648a5e1947
2 changed files with 14 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/api/DataRecallFeignClient.java
View File

@@ -7,6 +7,7 @@ import com.njcn.common.pojo.response.HttpResult;
import com.njcn.dataProcess.api.fallback.DataIFeignClientFallbackFactory; import com.njcn.dataProcess.api.fallback.DataIFeignClientFallbackFactory;
import com.njcn.dataProcess.api.fallback.DataRecallFeignClientFallbackFactory; import com.njcn.dataProcess.api.fallback.DataRecallFeignClientFallbackFactory;
import com.njcn.dataProcess.dto.DataIDTO; import com.njcn.dataProcess.dto.DataIDTO;
import com.njcn.dataProcess.param.FullRecallMessage;
import com.njcn.dataProcess.param.LineCountEvaluateParam; import com.njcn.dataProcess.param.LineCountEvaluateParam;
import com.njcn.dataProcess.pojo.dto.CommonMinuteDto; import com.njcn.dataProcess.pojo.dto.CommonMinuteDto;
import com.njcn.dataProcess.pojo.dto.DataIDto; import com.njcn.dataProcess.pojo.dto.DataIDto;
@@ -32,4 +33,10 @@ public interface DataRecallFeignClient {
@ApiOperation("数据补招") @ApiOperation("数据补招")
@ApiImplicitParam(name = "param", value = "参数", required = true) @ApiImplicitParam(name = "param", value = "参数", required = true)
public HttpResult<List<String>> recall(@RequestBody RecallMessage param); public HttpResult<List<String>> recall(@RequestBody RecallMessage param);
@PostMapping("/fullHourRecall")
@OperateInfo(info = LogEnum.BUSINESS_COMMON)
@ApiOperation("数据全量补招")
@ApiImplicitParam(name = "param", value = "参数", required = true)
public HttpResult<List<String>> fullHourRecall(@RequestBody FullRecallMessage param);
} }

7
data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/api/fallback/DataRecallFeignClientFallbackFactory.java
View File

@@ -5,6 +5,7 @@ import com.njcn.common.pojo.exception.BusinessException;
import com.njcn.common.pojo.response.HttpResult; import com.njcn.common.pojo.response.HttpResult;
import com.njcn.dataProcess.api.DataRecallFeignClient; import com.njcn.dataProcess.api.DataRecallFeignClient;
import com.njcn.dataProcess.param.FullRecallMessage;
import com.njcn.dataProcess.util.DataProcessingEnumUtil; import com.njcn.dataProcess.util.DataProcessingEnumUtil;
import com.njcn.message.message.RecallMessage; import com.njcn.message.message.RecallMessage;
import feign.hystrix.FallbackFactory; import feign.hystrix.FallbackFactory;
@@ -44,6 +45,12 @@ public class DataRecallFeignClientFallbackFactory implements FallbackFactory<Dat
log.error("{}异常，降级处理，异常为：{}","补招接口调用异常",cause.toString()); log.error("{}异常，降级处理，异常为：{}","补招接口调用异常",cause.toString());
throw new BusinessException(finalExceptionEnum); throw new BusinessException(finalExceptionEnum);
} }
@Override
public HttpResult<List<String>> fullHourRecall(FullRecallMessage param) {
log.error("{}异常，降级处理，异常为：{}","按小时补招接口调用异常",cause.toString());
throw new BusinessException(finalExceptionEnum);
}
}; };
} }
} }