diff --git a/pmapi/src/main/java/com/ningdatech/pmapi/scheduler/task/CheckProvincialReviewResultTask.java b/pmapi/src/main/java/com/ningdatech/pmapi/scheduler/task/CheckProvincialReviewResultTask.java index 6306c20..c6d24de 100644 --- a/pmapi/src/main/java/com/ningdatech/pmapi/scheduler/task/CheckProvincialReviewResultTask.java +++ b/pmapi/src/main/java/com/ningdatech/pmapi/scheduler/task/CheckProvincialReviewResultTask.java @@ -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());