Sfoglia il codice sorgente

已处理 加taskId

tags/24080901
PoffyZhang 1 anno fa
parent
commit
6218f8dc2e
1 ha cambiato i file con 2 aggiunte e 5 eliminazioni
  1. +2
    -5
      pmapi/src/main/java/com/ningdatech/pmapi/scheduler/task/CheckProvincialReviewResultTask.java

+ 2
- 5
pmapi/src/main/java/com/ningdatech/pmapi/scheduler/task/CheckProvincialReviewResultTask.java Vedi File

@@ -4,14 +4,13 @@ import cn.hutool.core.collection.CollUtil;
import cn.hutool.http.HttpStatus;
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.ningdatech.basic.model.ApiResponse;
import com.ningdatech.pmapi.common.statemachine.util.StateMachineUtils;
import com.ningdatech.pmapi.projectdeclared.manage.PrequalificationDeclaredProjectManage;
import com.ningdatech.pmapi.projectlib.enumeration.ProjectStatusEnum;
import com.ningdatech.pmapi.projectlib.model.entity.Project;
import com.ningdatech.pmapi.projectlib.service.IProjectService;
import com.ningdatech.pmapi.provincial.enumeration.ProjectProvincialAuditStatusEnum;
import com.ningdatech.pmapi.provincial.model.res.ProvincialProjectRes;
import com.ningdatech.pmapi.provincial.model.res.SjApiResponse;
import com.ningdatech.pmapi.provincial.service.IJoinReviewProvincialBureauService;
import com.ningdatech.pmapi.scheduler.contants.TaskContant;
import lombok.RequiredArgsConstructor;
@@ -41,8 +40,6 @@ public class CheckProvincialReviewResultTask {
private final IProjectService projectService;
private final StateMachineUtils stateMachineUtils;

private final PrequalificationDeclaredProjectManage prequalificationDeclaredProjectManage;

@Scheduled(cron = "0 */2 * * * ?")
public void statusFlow() throws UnknownHostException {
//测试暂时用自己电脑HOST
@@ -62,7 +59,7 @@ public class CheckProvincialReviewResultTask {
//遍历
for(Project project: projectList){
try{
ApiResponse apiResponse = reviewProvincialBureauService.processInfo(project.getProjectCode());
SjApiResponse apiResponse = reviewProvincialBureauService.processInfo(project.getProjectCode());
log.info("项目 【{}】 去获取省局联审结果 :{}",project.getId(),apiResponse);
if(Objects.isNull(apiResponse) || !Integer.valueOf(HttpStatus.HTTP_OK).equals(apiResponse.getCode())){
log.info("项目 【{}】 去获取省局联审结果失败",project.getId());


Loading…
Annulla
Salva