|
@@ -1,9 +1,13 @@ |
|
|
package com.ningdatech.pmapi.provincial; |
|
|
package com.ningdatech.pmapi.provincial; |
|
|
|
|
|
|
|
|
|
|
|
import cn.hutool.core.collection.CollUtil; |
|
|
import cn.hutool.crypto.SecureUtil; |
|
|
import cn.hutool.crypto.SecureUtil; |
|
|
|
|
|
import com.alibaba.fastjson.JSON; |
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
|
|
import com.ningdatech.file.service.FileService; |
|
|
import com.ningdatech.file.service.FileService; |
|
|
import com.ningdatech.pmapi.AppTests; |
|
|
import com.ningdatech.pmapi.AppTests; |
|
|
|
|
|
import com.ningdatech.pmapi.common.constant.ProjectDeclareConst; |
|
|
|
|
|
import com.ningdatech.pmapi.common.constant.RegionConst; |
|
|
import com.ningdatech.pmapi.projectdeclared.converter.ApplicationConverter; |
|
|
import com.ningdatech.pmapi.projectdeclared.converter.ApplicationConverter; |
|
|
import com.ningdatech.pmapi.projectdeclared.manage.PrequalificationDeclaredProjectManage; |
|
|
import com.ningdatech.pmapi.projectdeclared.manage.PrequalificationDeclaredProjectManage; |
|
|
import com.ningdatech.pmapi.projectlib.enumeration.ProjectStatusEnum; |
|
|
import com.ningdatech.pmapi.projectlib.enumeration.ProjectStatusEnum; |
|
@@ -12,6 +16,9 @@ import com.ningdatech.pmapi.projectlib.model.entity.ProjectApplication; |
|
|
import com.ningdatech.pmapi.projectlib.service.IProjectApplicationService; |
|
|
import com.ningdatech.pmapi.projectlib.service.IProjectApplicationService; |
|
|
import com.ningdatech.pmapi.projectlib.service.IProjectService; |
|
|
import com.ningdatech.pmapi.projectlib.service.IProjectService; |
|
|
import com.ningdatech.pmapi.provincial.service.IJoinReviewProvincialBureauService; |
|
|
import com.ningdatech.pmapi.provincial.service.IJoinReviewProvincialBureauService; |
|
|
|
|
|
import com.ningdatech.pmapi.staging.contants.StagingContant; |
|
|
|
|
|
import com.ningdatech.pmapi.staging.model.entity.ProjectStaging; |
|
|
|
|
|
import com.ningdatech.pmapi.staging.service.IProjectStagingService; |
|
|
import com.ningdatech.pmapi.todocenter.constant.TodoCenterContant; |
|
|
import com.ningdatech.pmapi.todocenter.constant.TodoCenterContant; |
|
|
import com.wflow.exception.BusinessException; |
|
|
import com.wflow.exception.BusinessException; |
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
import lombok.extern.slf4j.Slf4j; |
|
@@ -51,6 +58,9 @@ public class Test extends AppTests{// |
|
|
@Autowired |
|
|
@Autowired |
|
|
private IJoinReviewProvincialBureauService joinReviewProvincialBureauService; |
|
|
private IJoinReviewProvincialBureauService joinReviewProvincialBureauService; |
|
|
|
|
|
|
|
|
|
|
|
@Autowired |
|
|
|
|
|
private IProjectStagingService projectStagingService; |
|
|
|
|
|
|
|
|
@org.junit.Test |
|
|
@org.junit.Test |
|
|
public void test() throws NoSuchAlgorithmException, UnsupportedEncodingException, InvalidKeyException { |
|
|
public void test() throws NoSuchAlgorithmException, UnsupportedEncodingException, InvalidKeyException { |
|
|
// Long timeStamp = System.currentTimeMillis()/1000; |
|
|
// Long timeStamp = System.currentTimeMillis()/1000; |
|
@@ -93,4 +103,28 @@ public class Test extends AppTests{// |
|
|
} |
|
|
} |
|
|
System.out.println("成功"); |
|
|
System.out.println("成功"); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@org.junit.Test |
|
|
|
|
|
public void test5(){ |
|
|
|
|
|
//1. 定时取 项目暂存表的数据 去进行状态继续流转 |
|
|
|
|
|
List<ProjectStaging> stagingList = projectStagingService.list(Wrappers.lambdaQuery(ProjectStaging.class) |
|
|
|
|
|
.eq(ProjectStaging::getDead,Boolean.FALSE) |
|
|
|
|
|
.le(ProjectStaging::getNextTime, LocalDateTime.now()) |
|
|
|
|
|
.le(ProjectStaging::getRetryTimes, StagingContant.Retry.MAX_RETRY_TIMES) |
|
|
|
|
|
.orderByAsc(ProjectStaging::getProjectId)); |
|
|
|
|
|
|
|
|
|
|
|
log.info("需要状态流转的项目 size:{} :{}",stagingList.size(), JSON.toJSONString(stagingList)); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@org.junit.Test |
|
|
|
|
|
public void test6(){ |
|
|
|
|
|
List<Project> projectList = projectService.list(Wrappers.lambdaQuery(Project.class) |
|
|
|
|
|
.eq(Project::getStage, ProjectStatusEnum.NOT_APPROVED.getCode()) |
|
|
|
|
|
.eq(Project::getStatus, ProjectStatusEnum.JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS.getCode()) |
|
|
|
|
|
.ge(Project::getDeclareAmount, ProjectDeclareConst.Number.DECLARE_AMOUNT_JUDGEMENT) |
|
|
|
|
|
.eq(Project::getAreaCode, RegionConst.RC_LS) |
|
|
|
|
|
.orderByAsc(Project::getCreateOn)); |
|
|
|
|
|
|
|
|
|
|
|
log.info("需要去查询省级联审结果的项目 size:{}",projectList.size()); |
|
|
|
|
|
} |
|
|
} |
|
|
} |