diff --git a/hz-pm-api/pom.xml b/hz-pm-api/pom.xml
index 0a30453..df2e4fc 100644
--- a/hz-pm-api/pom.xml
+++ b/hz-pm-api/pom.xml
@@ -9,9 +9,6 @@
hz-pm-api
1.0.0
-
- 0.11.5
-
@@ -108,12 +105,6 @@
org.apache.poi
poi-ooxml
-
-
- com.aliyun.oss
- aliyun-sdk-oss
- 3.15.0
-
junit
junit
@@ -128,12 +119,6 @@
org.springframework.boot
spring-boot-starter-test
-
-
- com.auth0
- java-jwt
- 3.10.3
-
org.springframework.boot
spring-boot-configuration-processor
@@ -274,6 +259,13 @@
+ test
+
+
+ test
+
+
+
prod
prod
diff --git a/hz-pm-api/src/main/java/com/hz/pm/api/common/helper/RegionLimitHelper.java b/hz-pm-api/src/main/java/com/hz/pm/api/common/helper/RegionLimitHelper.java
index bb5a8c0..f4883ff 100644
--- a/hz-pm-api/src/main/java/com/hz/pm/api/common/helper/RegionLimitHelper.java
+++ b/hz-pm-api/src/main/java/com/hz/pm/api/common/helper/RegionLimitHelper.java
@@ -39,14 +39,4 @@ public interface RegionLimitHelper {
*/
RegionContainsBO getContainsRegionBo(Integer regionLevel, String regionCode);
-
-
- /**
- * 根据专家管理员用户id 获取专家管理员管辖区域列表
- *
- * @param expertAdminUserId 专家管理员用户id
- * @return
- */
- List getExpertAdminContainsRegion(Long expertAdminUserId);
-
}
diff --git a/hz-pm-api/src/main/java/com/hz/pm/api/common/helper/UserInfoHelper.java b/hz-pm-api/src/main/java/com/hz/pm/api/common/helper/UserInfoHelper.java
index 96acd77..72cbdb2 100644
--- a/hz-pm-api/src/main/java/com/hz/pm/api/common/helper/UserInfoHelper.java
+++ b/hz-pm-api/src/main/java/com/hz/pm/api/common/helper/UserInfoHelper.java
@@ -1,7 +1,9 @@
package com.hz.pm.api.common.helper;
-import com.hz.pm.api.user.entity.UserInfo;
+import cn.hutool.core.util.NumberUtil;
+import com.hz.pm.api.user.model.entity.UserInfo;
import com.hz.pm.api.user.security.model.UserFullInfoDTO;
+import com.ningdatech.basic.util.CollUtils;
import java.util.Collection;
import java.util.List;
@@ -14,18 +16,17 @@ import java.util.List;
public interface UserInfoHelper {
- /**
- * 根据用户id 获取 用户所属组织code organizationCode
- *
- * @param userId \
- * @return \
- */
- String getOrganizationCode(Long userId);
-
UserFullInfoDTO getUserFullInfoByMhUserIdOrOpenId(String mhUserId);
UserFullInfoDTO getUserFullInfo(Long userId);
+ default UserFullInfoDTO getUserFullInfo(String userId) {
+ if (NumberUtil.isLong(userId)) {
+ return getUserFullInfo(Long.parseLong(userId));
+ }
+ return null;
+ }
+
UserFullInfoDTO getUserFullInfo(UserInfo userInfo);
List getUserFullInfos(List userInfos);
@@ -39,16 +40,11 @@ public interface UserInfoHelper {
*/
boolean isSuperOrRegionAdmin(Long userId);
- UserFullInfoDTO getUserFullInfoByEmployeeCode(String employeeCode);
+ List listUserFullInfoByUserIds(Collection userIds);
- List getUserFullInfoByEmployeeCodes(Collection employeeCodes);
-
- /**
- * 获取用户任职所在单位code \
- *
- * @return \
- */
- String getUserEmpPosUnitCode(Long userId);
+ default List listUserFullInfoByUserIds(List userIds){
+ List userIdsLong = CollUtils.convert(userIds, Long::parseLong);
+ return listUserFullInfoByUserIds(userIdsLong);
+ }
- String getMainOrgCode(String empPosUnitCode);
}
diff --git a/hz-pm-api/src/main/java/com/hz/pm/api/common/helper/impl/RegionLimitHelperImpl.java b/hz-pm-api/src/main/java/com/hz/pm/api/common/helper/impl/RegionLimitHelperImpl.java
index 1d20bba..215967f 100644
--- a/hz-pm-api/src/main/java/com/hz/pm/api/common/helper/impl/RegionLimitHelperImpl.java
+++ b/hz-pm-api/src/main/java/com/hz/pm/api/common/helper/impl/RegionLimitHelperImpl.java
@@ -1,15 +1,10 @@
package com.hz.pm.api.common.helper.impl;
-import cn.hutool.core.collection.CollectionUtil;
-import com.baomidou.mybatisplus.core.toolkit.StringUtils;
-import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.hz.pm.api.common.helper.RegionCacheHelper;
import com.hz.pm.api.common.helper.basic.AbstractRegionLimitHelper;
import com.hz.pm.api.expert.service.IExpertUserFullInfoService;
import com.hz.pm.api.meta.model.bo.RegionContainsBO;
-import com.hz.pm.api.sys.model.entity.Region;
import com.hz.pm.api.sys.service.IRegionService;
-import com.hz.pm.api.user.entity.UserInfo;
import com.hz.pm.api.user.service.IUserInfoService;
import org.apache.commons.collections4.CollectionUtils;
import org.slf4j.Logger;
@@ -28,8 +23,6 @@ import java.util.Objects;
@Component
public class RegionLimitHelperImpl extends AbstractRegionLimitHelper {
- private static final Logger logger = LoggerFactory.getLogger(RegionLimitHelperImpl.class);
-
public RegionLimitHelperImpl(RegionCacheHelper regionCache, IExpertUserFullInfoService expertUserFullInfoService
, IUserInfoService iUserInfoService, IRegionService regionService) {
super(regionCache, expertUserFullInfoService, iUserInfoService, regionService);
@@ -91,29 +84,4 @@ public class RegionLimitHelperImpl extends AbstractRegionLimitHelper {
return regionContains;
}
-
- @Override
- public List getExpertAdminContainsRegion(Long expertAdminUserId) {
- if (Objects.isNull(expertAdminUserId)) {
- logger.error("getExpertAdminContainsRegion expertAdminUserId is null");
- return new ArrayList<>();
- }
- UserInfo userInfo = iUserInfoService.getById(expertAdminUserId);
- if (Objects.isNull(userInfo) || StringUtils.isBlank(userInfo.getRegionCode())) {
- logger.error("getExpertAdminContainsRegion userInfo is null Or regionCode is null");
- return new ArrayList<>();
- }
- String regionCode = userInfo.getRegionCode();
- List regionList = regionService.list(Wrappers.lambdaQuery(Region.class)
- .eq(Region::getRegionCode, regionCode)
- .orderByDesc(Region::getRegionLevel));
- Region region = regionList.get(0);
- Collection regionCodes = regionCache
- .listChildRegionCodeList(region.getRegionCode(), region.getRegionLevel());
- RegionContainsBO regionContainsBO = new RegionContainsBO();
- regionContainsBO.setContainsRegionCodeList(new ArrayList<>(regionCodes));
- regionContainsBO.setParentRegionTreeLevel(region.getRegionLevel());
- return CollectionUtil.toList(regionContainsBO);
- }
-
}
diff --git a/hz-pm-api/src/main/java/com/hz/pm/api/common/helper/impl/UserInfoHelperImpl.java b/hz-pm-api/src/main/java/com/hz/pm/api/common/helper/impl/UserInfoHelperImpl.java
index edd8963..6fb1551 100644
--- a/hz-pm-api/src/main/java/com/hz/pm/api/common/helper/impl/UserInfoHelperImpl.java
+++ b/hz-pm-api/src/main/java/com/hz/pm/api/common/helper/impl/UserInfoHelperImpl.java
@@ -1,31 +1,28 @@
package com.hz.pm.api.common.helper.impl;
import cn.hutool.core.collection.CollUtil;
-import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
-import com.hz.pm.api.common.model.constant.BizConst;
import com.hz.pm.api.common.helper.UserInfoHelper;
-import com.hz.pm.api.organization.model.entity.DingEmployeeInfo;
-import com.hz.pm.api.organization.model.entity.DingOrganization;
-import com.hz.pm.api.organization.service.IDingEmployeeInfoService;
-import com.hz.pm.api.organization.service.IDingOrganizationService;
+import com.hz.pm.api.common.util.StrUtils;
import com.hz.pm.api.sys.mapper.RoleMapper;
import com.hz.pm.api.sys.model.entity.Role;
import com.hz.pm.api.sys.model.entity.UserRole;
import com.hz.pm.api.sys.service.IUserRoleService;
-import com.hz.pm.api.user.model.enumeration.UserAvailableEnum;
-import com.hz.pm.api.user.entity.UserInfo;
+import com.hz.pm.api.user.model.entity.UserInfo;
import com.hz.pm.api.user.model.enumeration.RoleEnum;
+import com.hz.pm.api.user.model.enumeration.UserAvailableEnum;
import com.hz.pm.api.user.security.model.UserFullInfoDTO;
import com.hz.pm.api.user.service.IUserInfoService;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Component;
-import java.util.*;
+import java.util.Collection;
+import java.util.Collections;
+import java.util.List;
+import java.util.Objects;
import java.util.stream.Collectors;
-import java.util.stream.Stream;
/**
* @author liuxinxin
@@ -37,22 +34,14 @@ public class UserInfoHelperImpl implements UserInfoHelper {
private final IUserInfoService userInfoService;
- private final IDingEmployeeInfoService iDingEmployeeInfoService;
- private final IDingOrganizationService iDingOrganizationService;
private final IUserRoleService iUserRoleService;
private final RoleMapper roleMapper;
@Override
- public String getOrganizationCode(Long userId) {
- UserFullInfoDTO userFullInfo = getUserFullInfo(userId);
- return userFullInfo.getOrganizationCode();
- }
-
- @Override
public UserFullInfoDTO getUserFullInfoByMhUserIdOrOpenId(String mhUserId) {
LambdaQueryWrapper query = Wrappers.lambdaQuery(UserInfo.class)
.eq(UserInfo::getMhUserId, mhUserId)
- .or(q1 -> q1.eq(UserInfo::getWechatOpenId,mhUserId));
+ .or(q1 -> q1.eq(UserInfo::getWechatOpenId, mhUserId));
UserInfo userInfo = userInfoService.getOne(query);
if (Objects.isNull(userInfo)) {
return null;
@@ -74,65 +63,25 @@ public class UserInfoHelperImpl implements UserInfoHelper {
@Override
public UserFullInfoDTO getUserFullInfo(UserInfo userInfo) {
UserFullInfoDTO userFullInfo = new UserFullInfoDTO();
- // 获取浙政钉雇员信息 组织信息
- String employeeCode = userInfo.getEmployeeCode();
- if (StringUtils.isNotBlank(employeeCode)) {
- List dingEmployeeInfoList = iDingEmployeeInfoService
- .list(Wrappers.lambdaQuery(DingEmployeeInfo.class)
- .eq(DingEmployeeInfo::getEmployeeCode, employeeCode)
- .eq(DingEmployeeInfo::getMainJob, "true"));
- DingEmployeeInfo dingEmployeeInfo = dingEmployeeInfoList.get(0);
-
-
- // 装配用户任职所在单位
- String empPosUnitCode = dingEmployeeInfo.getEmpPosUnitCode();
- if (StringUtils.isNotBlank(empPosUnitCode)) {
- DingOrganization dingOrganization = iDingOrganizationService.getByOrgCode(empPosUnitCode);
- if (Objects.nonNull(dingOrganization)) {
- userFullInfo.setEmpPosUnitCode(empPosUnitCode);
- userFullInfo.setEmpPosUnitName(dingOrganization.getOrganizationName());
- userFullInfo.setRegionCode(dingOrganization.getDivisionCode());
- }
- }
-
- // 装配用户所在orgCode
- String organizationCode = dingEmployeeInfo.getOrganizationCode();
- List dingOrganizationList = iDingOrganizationService.list(Wrappers
- .lambdaQuery(DingOrganization.class)
- .eq(DingOrganization::getOrganizationCode, organizationCode));
- if (CollectionUtil.isNotEmpty(dingOrganizationList)) {
- DingOrganization dingOrganization = dingOrganizationList.get(0);
- userFullInfo.setOrganizationCode(dingOrganization.getOrganizationCode());
- userFullInfo.setOrganizationName(dingOrganization.getOrganizationName());
- // 测试使用
- userFullInfo.setRegionLevel(3);
- }
- }
-
- List roleList = new ArrayList<>();
// 获取用户角色列表信息
- List userRoleList = iUserRoleService
- .list(Wrappers.lambdaQuery(UserRole.class)
- .eq(UserRole::getUserId, userInfo.getId()));
- if (CollectionUtil.isNotEmpty(userRoleList)) {
+ List userRoleList = iUserRoleService.listByUserId(userInfo.getId());
+ if (CollUtil.isNotEmpty(userRoleList)) {
List roleIdList = userRoleList.stream()
.map(UserRole::getRoleId).distinct()
.collect(Collectors.toList());
- roleList = roleMapper.selectBatchIds(roleIdList);
+ userFullInfo.setUserRoleList(roleMapper.selectBatchIds(roleIdList));
}
- userFullInfo.setUserRoleList(roleList);
-
- // 装配用户任职所在单位
// 装配返回
userFullInfo.setUserId(userInfo.getId());
+ userFullInfo.setMhUserId(userInfo.getMhUserId());
userFullInfo.setIdentifier(userInfo.getRealName());
userFullInfo.setRealName(userInfo.getRealName());
- userFullInfo.setEmployeeCode(employeeCode);
+ userFullInfo.setMhUnitId(userInfo.getMhUnitId());
+ userFullInfo.setMhUnitName(userInfo.getMhUnitName());
userFullInfo.setUsername(userInfo.getRealName());
userFullInfo.setMobile(userInfo.getMobile());
userFullInfo.setAccountId(userInfo.getAccountId());
-
String available = userInfo.getAvailable();
if (StringUtils.isNotBlank(available)) {
userFullInfo.setAvailable(UserAvailableEnum.valueOf(available));
@@ -151,60 +100,20 @@ public class UserInfoHelperImpl implements UserInfoHelper {
if (CollUtil.isEmpty(userInfos)) {
return Collections.emptyList();
}
- Map userMap = userInfos.stream().collect(Collectors.toMap(UserInfo::getEmployeeCode, e -> e));
- // 获取浙政钉雇员信息 组织信息
- List employeeCodes = userInfos.stream().map(UserInfo::getEmployeeCode).collect(Collectors.toList());
- List dingEmployeeInfoList = iDingEmployeeInfoService
- .list(Wrappers.lambdaQuery(DingEmployeeInfo.class)
- .in(DingEmployeeInfo::getEmployeeCode, employeeCodes)
- .eq(DingEmployeeInfo::getMainJob, "true"));
-
- if (CollUtil.isEmpty(dingEmployeeInfoList)) {
- return Collections.emptyList();
- }
-
- // 装配用户任职所在单位
- List empPosUnitCodes = dingEmployeeInfoList.stream().map(DingEmployeeInfo::getEmpPosUnitCode).collect(Collectors.toList());
- List orgCodes = dingEmployeeInfoList.stream().map(DingEmployeeInfo::getOrganizationCode).collect(Collectors.toList());
- List allOrgCodes = Stream.concat(empPosUnitCodes.stream(), orgCodes.stream()).collect(Collectors.toList());
- if (CollUtil.isEmpty(allOrgCodes)) {
- return Collections.emptyList();
- }
- List dingOrganizations = iDingOrganizationService.listByCodes(allOrgCodes);
- if (CollUtil.isEmpty(dingOrganizations)) {
- return Collections.emptyList();
- }
- Map orgMap = dingOrganizations.stream().collect(Collectors.toMap(DingOrganization::getOrganizationCode, d -> d));
-
- return dingEmployeeInfoList.stream().map(e -> {
+ return userInfos.stream().map(userInfo -> {
UserFullInfoDTO userFullInfo = new UserFullInfoDTO();
- if (orgMap.containsKey(e.getEmpPosUnitCode())) {
- DingOrganization organization = orgMap.get(e.getEmpPosUnitCode());
- userFullInfo.setEmpPosUnitCode(e.getEmpPosUnitCode());
- userFullInfo.setEmpPosUnitName(organization.getOrganizationName());
- userFullInfo.setRegionCode(organization.getDivisionCode());
- }
- if (orgMap.containsKey(e.getOrganizationCode())) {
- DingOrganization organization = orgMap.get(e.getOrganizationCode());
- userFullInfo.setOrganizationCode(organization.getOrganizationCode());
- userFullInfo.setOrganizationName(organization.getOrganizationName());
- // 测试使用
- userFullInfo.setRegionLevel(3);
- }
- if (userMap.containsKey(e.getEmployeeCode())) {
- UserInfo userInfo = userMap.get(e.getEmployeeCode());
- // 装配返回
- userFullInfo.setUserId(userInfo.getId());
- userFullInfo.setIdentifier(userInfo.getRealName());
- userFullInfo.setRealName(userInfo.getRealName());
- userFullInfo.setEmployeeCode(e.getEmployeeCode());
- userFullInfo.setUsername(userInfo.getRealName());
- userFullInfo.setMobile(userInfo.getMobile());
- userFullInfo.setAccountId(userInfo.getAccountId());
- String available = userInfo.getAvailable();
- if (StringUtils.isNotBlank(available)) {
- userFullInfo.setAvailable(UserAvailableEnum.valueOf(available));
- }
+ // 装配返回
+ userFullInfo.setMhUnitName(userInfo.getMhUnitName());
+ userFullInfo.setMhUnitId(userInfo.getMhUnitId());
+ userFullInfo.setUserId(userInfo.getId());
+ userFullInfo.setIdentifier(userInfo.getRealName());
+ userFullInfo.setRealName(userInfo.getRealName());
+ userFullInfo.setUsername(userInfo.getRealName());
+ userFullInfo.setMobile(userInfo.getMobile());
+ userFullInfo.setAccountId(userInfo.getAccountId());
+ String available = userInfo.getAvailable();
+ if (StrUtils.isNotBlank(available)) {
+ userFullInfo.setAvailable(UserAvailableEnum.valueOf(available));
}
return userFullInfo;
}).collect(Collectors.toList());
@@ -231,31 +140,9 @@ public class UserInfoHelperImpl implements UserInfoHelper {
}
@Override
- public UserFullInfoDTO getUserFullInfoByEmployeeCode(String employeeCode) {
- UserInfo userInfo = userInfoService.getUserInfoByEmployeeCode(employeeCode);
- return getUserFullInfo(userInfo);
- }
-
- @Override
- public List getUserFullInfoByEmployeeCodes(Collection employeeCodes) {
- List userInfos = userInfoService.getUserInfoByEmployeeCodes(employeeCodes);
+ public List listUserFullInfoByUserIds(Collection userIds) {
+ List userInfos = userInfoService.listByIds(userIds);
return getUserFullInfos(userInfos);
}
- @Override
- public String getUserEmpPosUnitCode(Long userId) {
- UserFullInfoDTO userFullInfo = getUserFullInfo(userId);
- return userFullInfo.getEmpPosUnitCode();
- }
-
- @Override
- public String getMainOrgCode(String empPosUnitCode) {
- DingOrganization org = iDingOrganizationService.getOne(Wrappers.lambdaQuery(DingOrganization.class)
- .eq(DingOrganization::getOrganizationCode, empPosUnitCode)
- .last(BizConst.LIMIT_1));
- if(Objects.isNull(org)){
- return null;
- }
- return org.getParentCode();
- }
}
diff --git a/hz-pm-api/src/main/java/com/hz/pm/api/common/model/constant/BizConst.java b/hz-pm-api/src/main/java/com/hz/pm/api/common/model/constant/BizConst.java
index 5f90688..7382f81 100644
--- a/hz-pm-api/src/main/java/com/hz/pm/api/common/model/constant/BizConst.java
+++ b/hz-pm-api/src/main/java/com/hz/pm/api/common/model/constant/BizConst.java
@@ -65,6 +65,7 @@ public class BizConst {
* 浙江省的region_id
*/
public static final long ZJ_REGION_CODE = 330000L;
+
public static final String NINE_AREA_CODE_LAST = "000";
/**
diff --git a/hz-pm-api/src/main/java/com/hz/pm/api/common/model/constant/RegionConst.java b/hz-pm-api/src/main/java/com/hz/pm/api/common/model/constant/RegionConst.java
index 38fb723..4957888 100644
--- a/hz-pm-api/src/main/java/com/hz/pm/api/common/model/constant/RegionConst.java
+++ b/hz-pm-api/src/main/java/com/hz/pm/api/common/model/constant/RegionConst.java
@@ -25,7 +25,7 @@ public interface RegionConst {
//---------------------------------------地区编码(缩写RC)-------------------------------------------------------------
/**
- * 丽水行政区划编码
+ * 杭州市行政区划编码
*/
String RC_HZ = "330100";
//丽水开发区
diff --git a/hz-pm-api/src/main/java/com/hz/pm/api/common/model/constant/StateMachineConst.java b/hz-pm-api/src/main/java/com/hz/pm/api/common/model/constant/StateMachineConst.java
index c9ce670..a1d0ff9 100644
--- a/hz-pm-api/src/main/java/com/hz/pm/api/common/model/constant/StateMachineConst.java
+++ b/hz-pm-api/src/main/java/com/hz/pm/api/common/model/constant/StateMachineConst.java
@@ -7,8 +7,10 @@ package com.hz.pm.api.common.model.constant;
public class StateMachineConst {
+ private StateMachineConst() {
+ }
+
public static final String PROJECT_DECLARE = "projectDeclare";
public static final String APPLICATION_DECLARE = "applicationDeclare";
- public static final String LI_SHUI_CITY_AREA_CODE = "331100";
}
diff --git a/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/ProjectDeclareSBJAction.java b/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/HzProjectDeclareAction.java
similarity index 98%
rename from hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/ProjectDeclareSBJAction.java
rename to hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/HzProjectDeclareAction.java
index adc1d69..0b252ac 100644
--- a/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/ProjectDeclareSBJAction.java
+++ b/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/HzProjectDeclareAction.java
@@ -1,7 +1,7 @@
package com.hz.pm.api.common.statemachine.action;
import com.hz.pm.api.common.model.constant.StateMachineConst;
-import com.hz.pm.api.common.statemachine.contant.RegionContant;
+import com.hz.pm.api.common.statemachine.builder.ProjectDeclareStateMachineBuilderImpl;
import com.hz.pm.api.common.statemachine.event.ProjectStatusChangeEvent;
import com.hz.pm.api.projectlib.model.enumeration.ProjectStatusEnum;
import com.hz.pm.api.projectlib.model.entity.Project;
@@ -17,8 +17,8 @@ import org.springframework.statemachine.annotation.WithStateMachine;
* @since 2023/02/08 13:48
*/
@Slf4j
-@WithStateMachine(id = RegionContant.LS_SBJ_CODE)
-public class ProjectDeclareSBJAction {
+@WithStateMachine(id = ProjectDeclareStateMachineBuilderImpl.MACHINE_ID)
+public class HzProjectDeclareAction {
private static final String PROJECT_DECLARE = StateMachineConst.PROJECT_DECLARE;
diff --git a/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/ProjectDeclareAction.java b/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/ProjectDeclareAction.java
deleted file mode 100644
index 68eeb56..0000000
--- a/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/ProjectDeclareAction.java
+++ /dev/null
@@ -1,273 +0,0 @@
-package com.hz.pm.api.common.statemachine.action;
-
-import com.hz.pm.api.common.model.constant.StateMachineConst;
-import com.hz.pm.api.common.statemachine.contant.RegionContant;
-import com.hz.pm.api.common.statemachine.event.ProjectStatusChangeEvent;
-import com.hz.pm.api.projectlib.model.enumeration.ProjectStatusEnum;
-import com.hz.pm.api.projectlib.model.entity.Project;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.messaging.Message;
-import org.springframework.statemachine.annotation.OnTransition;
-import org.springframework.statemachine.annotation.WithStateMachine;
-
-/**
- * 项目申报状态机action集合类
- *
- * @author CMM
- * @since 2023/02/08 13:48
- */
-@Slf4j
-@WithStateMachine(id = RegionContant.LS_SBJ_CODE)
-public class ProjectDeclareAction {
-
- private static final String PROJECT_DECLARE = StateMachineConst.PROJECT_DECLARE;
-
- @OnTransition(source = "UNDER_INTERNAL_AUDIT", target = "PENDING_PREQUALIFICATION")
- public void UNDER_INTERNAL_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PENDING_PREQUALIFICATION.getCode());
- }
-
- @OnTransition(source = "UNDER_INTERNAL_AUDIT", target = "UNDER_INTERNAL_AUDIT_NOT_PASS")
- public void UNDER_INTERNAL_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_INTERNAL_AUDIT_NOT_PASS.getCode());
- }
-
- @OnTransition(source = "UNDER_INTERNAL_AUDIT", target = "TO_BE_DECLARED")
- public void UNDER_INTERNAL_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.TO_BE_DECLARED.getCode());
- }
-
- @OnTransition(source = "UNDER_INTERNAL_AUDIT_NOT_PASS", target = "UNDER_INTERNAL_AUDIT")
- public void UNDER_INTERNAL_REJECT_RESUBMIT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_INTERNAL_AUDIT.getCode());
- }
-
-
- @OnTransition(source = "PENDING_PREQUALIFICATION", target = "PENDING_PREQUALIFICATION_CHOICE")
- public void PRELIMINARY_REVIEW_DECLARE(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PENDING_PREQUALIFICATION_CHOICE.getCode());
- }
-
- @OnTransition(source = "PENDING_PREQUALIFICATION", target = "UNDER_INTERNAL_AUDIT")
- public void PENDING_PREQUALIFICATION_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_INTERNAL_AUDIT.getCode());
- }
-
-
- @OnTransition(source = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS", target = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS_SUCCESS")
- public void PROVINCIAL_DEPARTMENT_REVIEW_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS_SUCCESS.getCode());
- }
-
- @OnTransition(source = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS_SUCCESS", target = "PRE_APPLYING")
- public void PROVINCIAL_PASS_TO_PRELIMINARY_REVIEW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PRE_APPLYING.getCode());
- }
-
- @OnTransition(source = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS", target = "THE_JOINT_REVIEW_OF_PROVINCIAL_DEPARTMENTS_FAILED")
- public void PROVINCIAL_DEPARTMENT_REVIEW_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.THE_JOINT_REVIEW_OF_PROVINCIAL_DEPARTMENTS_FAILED.getCode());
- }
-
- @OnTransition(source = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS", target = "PENDING_PREQUALIFICATION")
- public void JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PENDING_PREQUALIFICATION.getCode());
- }
-
- @OnTransition(source = "PRE_APPLYING", target = "DEPARTMENT_JOINT_REVIEW")
- public void PRELIMINARY_REVIEW_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.DEPARTMENT_JOINT_REVIEW.getCode());
- }
-
- @OnTransition(source = "PRE_APPLYING", target = "PREQUALIFICATION_FAILED")
- public void PRELIMINARY_REVIEW_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PREQUALIFICATION_FAILED.getCode());
- }
-
- @OnTransition(source = "PREQUALIFICATION_FAILED", target = "PENDING_PREQUALIFICATION_CHOICE")
- public void PRELIMINARY_REVIEW_REJECT_RESUBMIT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PENDING_PREQUALIFICATION_CHOICE.getCode());
- }
-
- @OnTransition(source = "PRE_APPLYING", target = "PREQUALIFICATION_WITHDRAW_CHOICE")
- public void PRE_APPLYING_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PREQUALIFICATION_WITHDRAW_CHOICE.getCode());
- }
-
-
- @OnTransition(source = "DEPARTMENT_JOINT_REVIEW", target = "IN_THE_ANNUAL_PLAN")
- public void DEPARTMENT_UNITED_REVIEW_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.IN_THE_ANNUAL_PLAN.getCode());
- }
-
- @OnTransition(source = "DEPARTMENT_JOINT_REVIEW", target = "DEPARTMENT_JOINT_REVIEW_FAILED")
- public void DEPARTMENT_UNITED_REVIEW_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.DEPARTMENT_JOINT_REVIEW_FAILED.getCode());
- }
-
- @OnTransition(source = "DEPARTMENT_JOINT_REVIEW", target = "PRE_APPLYING")
- public void DEPARTMENT_JOINT_REVIEW_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PRE_APPLYING.getCode());
- }
-
-
- @OnTransition(source = "IN_THE_ANNUAL_PLAN", target = "PLAN_TO_BE_DECLARED")
- public void ANNUAL_PLAN_PROJECT_OPEN_PLAN_DECLARE(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PLAN_TO_BE_DECLARED.getCode());
- }
-
- @OnTransition(source = "IN_THE_ANNUAL_PLAN", target = "BE_SUSPENDED")
- public void ANNUAL_PLAN_SUSPEND(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.BE_SUSPENDED.getCode());
- }
-
- @OnTransition(source = "IN_THE_ANNUAL_PLAN", target = "DEPARTMENT_JOINT_REVIEW")
- public void IN_THE_ANNUAL_PLAN_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.DEPARTMENT_JOINT_REVIEW.getCode());
- }
-
-
- @OnTransition(source = "PLAN_TO_BE_DECLARED", target = "SCHEME_UNDER_REVIEW")
- public void DECLARE_PLAN(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.SCHEME_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "PLAN_TO_BE_DECLARED", target = "IN_THE_ANNUAL_PLAN")
- public void PLAN_TO_DECLARE_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.IN_THE_ANNUAL_PLAN.getCode());
- }
-
- @OnTransition(source = "SCHEME_REVIEW_FAILED", target = "SCHEME_UNDER_REVIEW")
- public void DECLARE_PLAN_RESUBMIT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.SCHEME_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "SCHEME_UNDER_REVIEW", target = "TO_BE_APPROVED")
- public void PLAN_REVIEW_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.TO_BE_APPROVED.getCode());
- }
-
- @OnTransition(source = "SCHEME_UNDER_REVIEW", target = "SCHEME_REVIEW_FAILED")
- public void PLAN_REVIEW_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.SCHEME_REVIEW_FAILED.getCode());
- }
-
- @OnTransition(source = "SCHEME_REVIEW_FAILED", target = "SCHEME_UNDER_REVIEW")
- public void PLAN_REVIEW_REJECT_RESUBMIT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.SCHEME_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "SCHEME_UNDER_REVIEW", target = "PLAN_TO_BE_DECLARED")
- public void SCHEME_UNDER_REVIEW_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PLAN_TO_BE_DECLARED.getCode());
- }
-
-
- @OnTransition(source = "TO_BE_APPROVED", target = "TO_BE_PURCHASED")
- public void PROJECT_APPROVAL(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- // 待立项批复批复后,项目一级状态变更为已立项
- project.setStage(ProjectStatusEnum.PROJECT_APPROVED.getCode());
- project.setStatus(ProjectStatusEnum.TO_BE_PURCHASED.getCode());
- }
-
- @OnTransition(source = "TO_BE_APPROVED", target = "SCHEME_UNDER_REVIEW")
- public void TO_BE_APPROVED_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.SCHEME_UNDER_REVIEW.getCode());
- }
-
-
- @OnTransition(source = "TO_BE_PURCHASED", target = "OPERATION")
- public void PURCHASE_PUT_ON_RECORD(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.OPERATION.getCode());
- }
- @OnTransition(source = "OPERATION", target = "UNDER_CONSTRUCTION")
- public void START_TO_WORK(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_CONSTRUCTION.getCode());
- }
-
- @OnTransition(source = "TO_BE_PURCHASED", target = "TO_BE_APPROVED")
- public void TO_BE_PURCHASED_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- // 待采购状态撤回后,项目一级状态回退到未立项
- project.setStage(ProjectStatusEnum.NOT_APPROVED.getCode());
- project.setStatus(ProjectStatusEnum.TO_BE_APPROVED.getCode());
- }
-
-
- @OnTransition(source = "UNDER_CONSTRUCTION", target = "TO_BE_FINALLY_INSPECTED")
- public void PRELIMINARY_ACCEPTANCE_PUT_ON_RECORD(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.TO_BE_FINALLY_INSPECTED.getCode());
- }
-
- @OnTransition(source = "UNDER_CONSTRUCTION", target = "TO_BE_PURCHASED")
- public void UNDER_CONSTRUCTION_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.TO_BE_PURCHASED.getCode());
- }
-
-
- @OnTransition(source = "TO_BE_FINALLY_INSPECTED", target = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW")
- public void FINAL_ACCEPTANCE_APPLICATION(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.FINAL_ACCEPTANCE_IS_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "TO_BE_FINALLY_INSPECTED", target = "UNDER_CONSTRUCTION")
- public void TO_BE_FINALLY_INSPECTED_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_CONSTRUCTION.getCode());
- }
-
-
- @OnTransition(source = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW", target = "ARCHIVED")
- public void FINAL_ACCEPTANCE_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- // 终验审核通过后,项目一级状态变更为已归档
- project.setStage(ProjectStatusEnum.ARCHIVED.getCode());
- project.setStatus(ProjectStatusEnum.ACCEPTED.getCode());
- }
-
- @OnTransition(source = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW", target = "FINAL_ACCEPTANCE_REVIEW_FAILED")
- public void FINAL_ACCEPTANCE_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.FINAL_ACCEPTANCE_REVIEW_FAILED.getCode());
- }
-
- @OnTransition(source = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW", target = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW")
- public void FINAL_ACCEPTANCE_IS_UNDER_REVIEW_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.FINAL_ACCEPTANCE_IS_UNDER_REVIEW.getCode());
- }
-}
diff --git a/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/ProjectDeclareChoiceAction.java b/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/ProjectDeclareChoiceAction.java
index b5eff58..c481265 100644
--- a/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/ProjectDeclareChoiceAction.java
+++ b/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/ProjectDeclareChoiceAction.java
@@ -1,6 +1,8 @@
package com.hz.pm.api.common.statemachine.action;
import cn.hutool.core.collection.CollUtil;
+import cn.hutool.json.JSONUtil;
+import com.baomidou.mybatisplus.core.toolkit.Assert;
import com.hz.pm.api.common.model.constant.ProjectDeclareConst;
import com.hz.pm.api.common.model.constant.StateMachineConst;
import com.hz.pm.api.common.enumeration.CommonEnum;
@@ -32,7 +34,7 @@ public class ProjectDeclareChoiceAction implements Action stateContext) {
log.info(String.valueOf(stateContext.getTarget().getId()));
ProjectStatusEnum projectStatusEnum = stateContext.getTarget().getId();
- switch (projectStatusEnum){
+ switch (projectStatusEnum) {
case PENDING_PREQUALIFICATION_CHOICE:
preDeclareChoice(stateContext);
break;
@@ -48,49 +50,51 @@ public class ProjectDeclareChoiceAction implements Action stateContext) {
- List projectApplications = stateContext.getMessage().getHeaders().get(APPLICATION_DECLARE, List.class);
- Project project = stateContext.getMessage().getHeaders().get(PROJECT_DECLARE, Project.class);
- log.info("立项批复之后,项目的状态为:{}" + project.getStatus());
+ Project project = getProject(stateContext);
+ List projectApplications = getProjectApplication(stateContext);
+ log.info("立项批复之后,项目的状态为:{}", project.getStatus());
// 判断 是否有初次创建的应用
- if (CollUtil.isEmpty(projectApplications)){
+ if (CollUtil.isEmpty(projectApplications)) {
project.setStage(ProjectStatusEnum.PROJECT_APPROVED.getCode());
project.setStatus(ProjectStatusEnum.TO_BE_PURCHASED.getCode());
}
- final Boolean[] isFirstApp = {Boolean.FALSE};
- projectApplications.stream().forEach(app -> {
+ final boolean[] isFirstApp = {Boolean.FALSE};
+ projectApplications.forEach(app -> {
Integer isFirst = app.getIsFirst();
- if(isFirst.equals(CommonEnum.YES.getCode())){
+ if (isFirst.equals(CommonEnum.YES.getCode())) {
isFirstApp[0] = Boolean.TRUE;
}
});
- if(isFirstApp[0]){
+ if (isFirstApp[0]) {
project.setStage(ProjectStatusEnum.NOT_APPROVED.getCode());
project.setStatus(ProjectStatusEnum.TO_BE_APP_REGISTER.getCode());
- }else{
+ } else {
project.setStage(ProjectStatusEnum.PROJECT_APPROVED.getCode());
project.setStatus(ProjectStatusEnum.TO_BE_PURCHASED.getCode());
}
}
private void preDeclareChoice(StateContext stateContext) {
- Project project = stateContext.getMessage().getHeaders().get(PROJECT_DECLARE, Project.class);
- log.info("预审申报事件之前,项目的状态为:{}"+project.getStatus());
- if (StateMachineUtil.isCityProject(project) && StateMachineUtil.judgeDeclareAmount(project,
- ProjectDeclareConst.Number.DECLARE_AMOUNT_JUDGEMENT)){
- project.setStatus(ProjectStatusEnum.JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS.getCode());
- }else {
- project.setStatus(ProjectStatusEnum.PRE_APPLYING.getCode());
- }
+ Project project = getProject(stateContext);
+ log.info("预审申报事件之前,项目的状态为:{}", project.getStatus());
+ project.setStatus(ProjectStatusEnum.PRE_APPLYING.getCode());
}
private void preWithDrawChoice(StateContext stateContext) {
+ Project project = getProject(stateContext);
+ log.info("预审中撤回事件之前,项目的状态为:{}", project.getStatus());
+ project.setStatus(ProjectStatusEnum.PENDING_PREQUALIFICATION.getCode());
+ }
+
+ private Project getProject(StateContext stateContext) {
Project project = stateContext.getMessage().getHeaders().get(PROJECT_DECLARE, Project.class);
- log.info("预审中撤回事件之前,项目的状态为:{}"+project.getStatus());
- if (StateMachineUtil.isCityProject(project) && StateMachineUtil.judgeDeclareAmount(project,
- ProjectDeclareConst.Number.DECLARE_AMOUNT_JUDGEMENT)){
- project.setStatus(ProjectStatusEnum.JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS_SUCCESS.getCode());
- }else {
- project.setStatus(ProjectStatusEnum.PENDING_PREQUALIFICATION.getCode());
- }
+ Assert.notNull(project, "项目信息获取失败%s", JSONUtil.toJsonStr(stateContext.getMessage()));
+ return project;
+ }
+
+ @SuppressWarnings("unchecked")
+ private List getProjectApplication(StateContext stateContext) {
+ return stateContext.getMessage().getHeaders().get(APPLICATION_DECLARE, List.class);
}
+
}
diff --git a/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/ProjectDeclareJNAction.java b/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/ProjectDeclareJNAction.java
deleted file mode 100644
index 6a63e55..0000000
--- a/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/ProjectDeclareJNAction.java
+++ /dev/null
@@ -1,279 +0,0 @@
-package com.hz.pm.api.common.statemachine.action;
-
-import com.hz.pm.api.common.model.constant.StateMachineConst;
-import com.hz.pm.api.common.statemachine.contant.RegionContant;
-import com.hz.pm.api.common.statemachine.event.ProjectStatusChangeEvent;
-import com.hz.pm.api.projectlib.model.enumeration.ProjectStatusEnum;
-import com.hz.pm.api.projectlib.model.entity.Project;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.messaging.Message;
-import org.springframework.statemachine.annotation.OnTransition;
-import org.springframework.statemachine.annotation.WithStateMachine;
-
-/**
- * 项目申报状态机action集合类
- * 景宁畲族自治县
- * @author CMM
- * @since 2023/02/08 13:48
- */
-@Slf4j
-@WithStateMachine(id = RegionContant.LS_JN_CODE)
-public class ProjectDeclareJNAction {
-
- private static final String PROJECT_DECLARE = StateMachineConst.PROJECT_DECLARE;
-
- @OnTransition(source = "UNDER_INTERNAL_AUDIT", target = "PENDING_PREQUALIFICATION")
- public void UNDER_INTERNAL_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PENDING_PREQUALIFICATION.getCode());
- }
-
- @OnTransition(source = "UNDER_INTERNAL_AUDIT", target = "UNDER_INTERNAL_AUDIT_NOT_PASS")
- public void UNDER_INTERNAL_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_INTERNAL_AUDIT_NOT_PASS.getCode());
- }
-
- @OnTransition(source = "UNDER_INTERNAL_AUDIT", target = "TO_BE_DECLARED")
- public void UNDER_INTERNAL_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.TO_BE_DECLARED.getCode());
- }
-
- @OnTransition(source = "UNDER_INTERNAL_AUDIT_NOT_PASS", target = "UNDER_INTERNAL_AUDIT")
- public void UNDER_INTERNAL_REJECT_RESUBMIT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_INTERNAL_AUDIT.getCode());
- }
-
-
- @OnTransition(source = "PENDING_PREQUALIFICATION", target = "PENDING_PREQUALIFICATION_CHOICE")
- public void PRELIMINARY_REVIEW_DECLARE(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PENDING_PREQUALIFICATION_CHOICE.getCode());
- }
-
- @OnTransition(source = "PENDING_PREQUALIFICATION", target = "UNDER_INTERNAL_AUDIT")
- public void PENDING_PREQUALIFICATION_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_INTERNAL_AUDIT.getCode());
- }
-
-
- @OnTransition(source = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS", target = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS_SUCCESS")
- public void PROVINCIAL_DEPARTMENT_REVIEW_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS_SUCCESS.getCode());
- }
-
- @OnTransition(source = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS_SUCCESS", target = "PRE_APPLYING")
- public void PROVINCIAL_PASS_TO_PRELIMINARY_REVIEW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PRE_APPLYING.getCode());
- }
-
- @OnTransition(source = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS", target = "THE_JOINT_REVIEW_OF_PROVINCIAL_DEPARTMENTS_FAILED")
- public void PROVINCIAL_DEPARTMENT_REVIEW_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.THE_JOINT_REVIEW_OF_PROVINCIAL_DEPARTMENTS_FAILED.getCode());
- }
-
- @OnTransition(source = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS", target = "PENDING_PREQUALIFICATION")
- public void JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PENDING_PREQUALIFICATION.getCode());
- }
-
- @OnTransition(source = "PRE_APPLYING", target = "DEPARTMENT_JOINT_REVIEW")
- public void PRELIMINARY_REVIEW_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.DEPARTMENT_JOINT_REVIEW.getCode());
- }
-
- @OnTransition(source = "PRE_APPLYING", target = "PREQUALIFICATION_FAILED")
- public void PRELIMINARY_REVIEW_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PREQUALIFICATION_FAILED.getCode());
- }
-
- @OnTransition(source = "PREQUALIFICATION_FAILED", target = "PENDING_PREQUALIFICATION_CHOICE")
- public void PRELIMINARY_REVIEW_REJECT_RESUBMIT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PENDING_PREQUALIFICATION_CHOICE.getCode());
- }
-
- @OnTransition(source = "PRE_APPLYING", target = "PREQUALIFICATION_WITHDRAW_CHOICE")
- public void PRE_APPLYING_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PREQUALIFICATION_WITHDRAW_CHOICE.getCode());
- }
-
-
- @OnTransition(source = "DEPARTMENT_JOINT_REVIEW", target = "IN_THE_ANNUAL_PLAN")
- public void DEPARTMENT_UNITED_REVIEW_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.IN_THE_ANNUAL_PLAN.getCode());
- }
-
- @OnTransition(source = "DEPARTMENT_JOINT_REVIEW", target = "DEPARTMENT_JOINT_REVIEW_FAILED")
- public void DEPARTMENT_UNITED_REVIEW_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.DEPARTMENT_JOINT_REVIEW_FAILED.getCode());
- }
-
- @OnTransition(source = "DEPARTMENT_JOINT_REVIEW", target = "PRE_APPLYING")
- public void DEPARTMENT_JOINT_REVIEW_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PRE_APPLYING.getCode());
- }
-
-
- @OnTransition(source = "IN_THE_ANNUAL_PLAN", target = "PLAN_TO_BE_DECLARED")
- public void ANNUAL_PLAN_PROJECT_OPEN_PLAN_DECLARE(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PLAN_TO_BE_DECLARED.getCode());
- }
-
- @OnTransition(source = "IN_THE_ANNUAL_PLAN", target = "BE_SUSPENDED")
- public void ANNUAL_PLAN_SUSPEND(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.BE_SUSPENDED.getCode());
- }
-
- @OnTransition(source = "IN_THE_ANNUAL_PLAN", target = "DEPARTMENT_JOINT_REVIEW")
- public void IN_THE_ANNUAL_PLAN_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.DEPARTMENT_JOINT_REVIEW.getCode());
- }
-
-
- @OnTransition(source = "PLAN_TO_BE_DECLARED", target = "SCHEME_UNDER_REVIEW")
- public void DECLARE_PLAN(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.SCHEME_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "PLAN_TO_BE_DECLARED", target = "IN_THE_ANNUAL_PLAN")
- public void PLAN_TO_DECLARE_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.IN_THE_ANNUAL_PLAN.getCode());
- }
-
- @OnTransition(source = "SCHEME_REVIEW_FAILED", target = "SCHEME_UNDER_REVIEW")
- public void DECLARE_PLAN_RESUBMIT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.SCHEME_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "SCHEME_UNDER_REVIEW", target = "TO_BE_APPROVED")
- public void PLAN_REVIEW_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.TO_BE_APPROVED.getCode());
- }
-
- @OnTransition(source = "SCHEME_UNDER_REVIEW", target = "SCHEME_REVIEW_FAILED")
- public void PLAN_REVIEW_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.SCHEME_REVIEW_FAILED.getCode());
- }
-
- @OnTransition(source = "SCHEME_REVIEW_FAILED", target = "SCHEME_UNDER_REVIEW")
- public void PLAN_REVIEW_REJECT_RESUBMIT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.SCHEME_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "SCHEME_UNDER_REVIEW", target = "PLAN_TO_BE_DECLARED")
- public void SCHEME_UNDER_REVIEW_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PLAN_TO_BE_DECLARED.getCode());
- }
-
-
- @OnTransition(source = "TO_BE_APPROVED", target = "TO_BE_PURCHASED")
- public void PROJECT_APPROVAL(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- // 待立项批复批复后,项目一级状态变更为已立项
- project.setStage(ProjectStatusEnum.PROJECT_APPROVED.getCode());
- project.setStatus(ProjectStatusEnum.TO_BE_PURCHASED.getCode());
- }
-
- @OnTransition(source = "TO_BE_APPROVED", target = "SCHEME_UNDER_REVIEW")
- public void TO_BE_APPROVED_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.SCHEME_UNDER_REVIEW.getCode());
- }
-
-
- @OnTransition(source = "TO_BE_PURCHASED", target = "OPERATION")
- public void PURCHASE_PUT_ON_RECORD(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.OPERATION.getCode());
- }
- @OnTransition(source = "OPERATION", target = "UNDER_CONSTRUCTION")
- public void START_TO_WORK(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_CONSTRUCTION.getCode());
- }
-
- @OnTransition(source = "TO_BE_PURCHASED", target = "TO_BE_APPROVED")
- public void TO_BE_PURCHASED_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- // 待采购状态撤回后,项目一级状态回退到未立项
- project.setStage(ProjectStatusEnum.NOT_APPROVED.getCode());
- project.setStatus(ProjectStatusEnum.TO_BE_APPROVED.getCode());
- }
-
-
- @OnTransition(source = "UNDER_CONSTRUCTION", target = "TO_BE_FINALLY_INSPECTED")
- public void PRELIMINARY_ACCEPTANCE_PUT_ON_RECORD(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.TO_BE_FINALLY_INSPECTED.getCode());
- }
-
- @OnTransition(source = "UNDER_CONSTRUCTION", target = "TO_BE_PURCHASED")
- public void UNDER_CONSTRUCTION_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.TO_BE_PURCHASED.getCode());
- }
-
-
- @OnTransition(source = "TO_BE_FINALLY_INSPECTED", target = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW")
- public void FINAL_ACCEPTANCE_APPLICATION(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.FINAL_ACCEPTANCE_IS_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "TO_BE_FINALLY_INSPECTED", target = "UNDER_CONSTRUCTION")
- public void TO_BE_FINALLY_INSPECTED_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_CONSTRUCTION.getCode());
- }
-
-
- @OnTransition(source = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW", target = "ARCHIVED")
- public void FINAL_ACCEPTANCE_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- // 终验审核通过后,项目一级状态变更为已归档
- project.setStage(ProjectStatusEnum.ARCHIVED.getCode());
- project.setStatus(ProjectStatusEnum.ACCEPTED.getCode());
- }
-
- @OnTransition(source = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW", target = "FINAL_ACCEPTANCE_REVIEW_FAILED")
- public void FINAL_ACCEPTANCE_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.FINAL_ACCEPTANCE_REVIEW_FAILED.getCode());
- }
-
- @OnTransition(source = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW", target = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW")
- public void FINAL_ACCEPTANCE_IS_UNDER_REVIEW_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.FINAL_ACCEPTANCE_IS_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "FINAL_ACCEPTANCE_REVIEW_FAILED", target = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW")
- public void FINAL_RE_ACCEPTANCE_APPLICATION(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.FINAL_ACCEPTANCE_IS_UNDER_REVIEW.getCode());
- }
-}
diff --git a/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/ProjectDeclareJYAction.java b/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/ProjectDeclareJYAction.java
deleted file mode 100644
index a0c4521..0000000
--- a/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/ProjectDeclareJYAction.java
+++ /dev/null
@@ -1,279 +0,0 @@
-package com.hz.pm.api.common.statemachine.action;
-
-import com.hz.pm.api.common.model.constant.StateMachineConst;
-import com.hz.pm.api.common.statemachine.contant.RegionContant;
-import com.hz.pm.api.common.statemachine.event.ProjectStatusChangeEvent;
-import com.hz.pm.api.projectlib.model.enumeration.ProjectStatusEnum;
-import com.hz.pm.api.projectlib.model.entity.Project;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.messaging.Message;
-import org.springframework.statemachine.annotation.OnTransition;
-import org.springframework.statemachine.annotation.WithStateMachine;
-
-/**
- * 项目申报状态机action集合类
- * 缙云县
- * @author CMM
- * @since 2023/02/08 13:48
- */
-@Slf4j
-@WithStateMachine(id = RegionContant.LS_JY_CODE)
-public class ProjectDeclareJYAction {
-
- private static final String PROJECT_DECLARE = StateMachineConst.PROJECT_DECLARE;
-
- @OnTransition(source = "UNDER_INTERNAL_AUDIT", target = "PENDING_PREQUALIFICATION")
- public void UNDER_INTERNAL_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PENDING_PREQUALIFICATION.getCode());
- }
-
- @OnTransition(source = "UNDER_INTERNAL_AUDIT", target = "UNDER_INTERNAL_AUDIT_NOT_PASS")
- public void UNDER_INTERNAL_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_INTERNAL_AUDIT_NOT_PASS.getCode());
- }
-
- @OnTransition(source = "UNDER_INTERNAL_AUDIT", target = "TO_BE_DECLARED")
- public void UNDER_INTERNAL_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.TO_BE_DECLARED.getCode());
- }
-
- @OnTransition(source = "UNDER_INTERNAL_AUDIT_NOT_PASS", target = "UNDER_INTERNAL_AUDIT")
- public void UNDER_INTERNAL_REJECT_RESUBMIT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_INTERNAL_AUDIT.getCode());
- }
-
-
- @OnTransition(source = "PENDING_PREQUALIFICATION", target = "PENDING_PREQUALIFICATION_CHOICE")
- public void PRELIMINARY_REVIEW_DECLARE(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PENDING_PREQUALIFICATION_CHOICE.getCode());
- }
-
- @OnTransition(source = "PENDING_PREQUALIFICATION", target = "UNDER_INTERNAL_AUDIT")
- public void PENDING_PREQUALIFICATION_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_INTERNAL_AUDIT.getCode());
- }
-
-
- @OnTransition(source = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS", target = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS_SUCCESS")
- public void PROVINCIAL_DEPARTMENT_REVIEW_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS_SUCCESS.getCode());
- }
-
- @OnTransition(source = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS_SUCCESS", target = "PRE_APPLYING")
- public void PROVINCIAL_PASS_TO_PRELIMINARY_REVIEW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PRE_APPLYING.getCode());
- }
-
- @OnTransition(source = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS", target = "THE_JOINT_REVIEW_OF_PROVINCIAL_DEPARTMENTS_FAILED")
- public void PROVINCIAL_DEPARTMENT_REVIEW_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.THE_JOINT_REVIEW_OF_PROVINCIAL_DEPARTMENTS_FAILED.getCode());
- }
-
- @OnTransition(source = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS", target = "PENDING_PREQUALIFICATION")
- public void JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PENDING_PREQUALIFICATION.getCode());
- }
-
- @OnTransition(source = "PRE_APPLYING", target = "DEPARTMENT_JOINT_REVIEW")
- public void PRELIMINARY_REVIEW_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.DEPARTMENT_JOINT_REVIEW.getCode());
- }
-
- @OnTransition(source = "PRE_APPLYING", target = "PREQUALIFICATION_FAILED")
- public void PRELIMINARY_REVIEW_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PREQUALIFICATION_FAILED.getCode());
- }
-
- @OnTransition(source = "PREQUALIFICATION_FAILED", target = "PENDING_PREQUALIFICATION_CHOICE")
- public void PRELIMINARY_REVIEW_REJECT_RESUBMIT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PENDING_PREQUALIFICATION_CHOICE.getCode());
- }
-
- @OnTransition(source = "PRE_APPLYING", target = "PREQUALIFICATION_WITHDRAW_CHOICE")
- public void PRE_APPLYING_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PREQUALIFICATION_WITHDRAW_CHOICE.getCode());
- }
-
-
- @OnTransition(source = "DEPARTMENT_JOINT_REVIEW", target = "IN_THE_ANNUAL_PLAN")
- public void DEPARTMENT_UNITED_REVIEW_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.IN_THE_ANNUAL_PLAN.getCode());
- }
-
- @OnTransition(source = "DEPARTMENT_JOINT_REVIEW", target = "DEPARTMENT_JOINT_REVIEW_FAILED")
- public void DEPARTMENT_UNITED_REVIEW_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.DEPARTMENT_JOINT_REVIEW_FAILED.getCode());
- }
-
- @OnTransition(source = "DEPARTMENT_JOINT_REVIEW", target = "PRE_APPLYING")
- public void DEPARTMENT_JOINT_REVIEW_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PRE_APPLYING.getCode());
- }
-
-
- @OnTransition(source = "IN_THE_ANNUAL_PLAN", target = "PLAN_TO_BE_DECLARED")
- public void ANNUAL_PLAN_PROJECT_OPEN_PLAN_DECLARE(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PLAN_TO_BE_DECLARED.getCode());
- }
-
- @OnTransition(source = "IN_THE_ANNUAL_PLAN", target = "BE_SUSPENDED")
- public void ANNUAL_PLAN_SUSPEND(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.BE_SUSPENDED.getCode());
- }
-
- @OnTransition(source = "IN_THE_ANNUAL_PLAN", target = "DEPARTMENT_JOINT_REVIEW")
- public void IN_THE_ANNUAL_PLAN_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.DEPARTMENT_JOINT_REVIEW.getCode());
- }
-
-
- @OnTransition(source = "PLAN_TO_BE_DECLARED", target = "SCHEME_UNDER_REVIEW")
- public void DECLARE_PLAN(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.SCHEME_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "PLAN_TO_BE_DECLARED", target = "IN_THE_ANNUAL_PLAN")
- public void PLAN_TO_DECLARE_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.IN_THE_ANNUAL_PLAN.getCode());
- }
-
- @OnTransition(source = "SCHEME_REVIEW_FAILED", target = "SCHEME_UNDER_REVIEW")
- public void DECLARE_PLAN_RESUBMIT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.SCHEME_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "SCHEME_UNDER_REVIEW", target = "TO_BE_APPROVED")
- public void PLAN_REVIEW_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.TO_BE_APPROVED.getCode());
- }
-
- @OnTransition(source = "SCHEME_UNDER_REVIEW", target = "SCHEME_REVIEW_FAILED")
- public void PLAN_REVIEW_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.SCHEME_REVIEW_FAILED.getCode());
- }
-
- @OnTransition(source = "SCHEME_REVIEW_FAILED", target = "SCHEME_UNDER_REVIEW")
- public void PLAN_REVIEW_REJECT_RESUBMIT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.SCHEME_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "SCHEME_UNDER_REVIEW", target = "PLAN_TO_BE_DECLARED")
- public void SCHEME_UNDER_REVIEW_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PLAN_TO_BE_DECLARED.getCode());
- }
-
-
- @OnTransition(source = "TO_BE_APPROVED", target = "TO_BE_PURCHASED")
- public void PROJECT_APPROVAL(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- // 待立项批复批复后,项目一级状态变更为已立项
- project.setStage(ProjectStatusEnum.PROJECT_APPROVED.getCode());
- project.setStatus(ProjectStatusEnum.TO_BE_PURCHASED.getCode());
- }
-
- @OnTransition(source = "TO_BE_APPROVED", target = "SCHEME_UNDER_REVIEW")
- public void TO_BE_APPROVED_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.SCHEME_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "TO_BE_PURCHASED", target = "OPERATION")
- public void PURCHASE_PUT_ON_RECORD(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.OPERATION.getCode());
- }
-
- @OnTransition(source = "OPERATION", target = "UNDER_CONSTRUCTION")
- public void START_TO_WORK(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_CONSTRUCTION.getCode());
- }
-
- @OnTransition(source = "TO_BE_PURCHASED", target = "TO_BE_APPROVED")
- public void TO_BE_PURCHASED_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- // 待采购状态撤回后,项目一级状态回退到未立项
- project.setStage(ProjectStatusEnum.NOT_APPROVED.getCode());
- project.setStatus(ProjectStatusEnum.TO_BE_APPROVED.getCode());
- }
-
-
- @OnTransition(source = "UNDER_CONSTRUCTION", target = "TO_BE_FINALLY_INSPECTED")
- public void PRELIMINARY_ACCEPTANCE_PUT_ON_RECORD(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.TO_BE_FINALLY_INSPECTED.getCode());
- }
-
- @OnTransition(source = "UNDER_CONSTRUCTION", target = "TO_BE_PURCHASED")
- public void UNDER_CONSTRUCTION_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.TO_BE_PURCHASED.getCode());
- }
-
-
- @OnTransition(source = "TO_BE_FINALLY_INSPECTED", target = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW")
- public void FINAL_ACCEPTANCE_APPLICATION(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.FINAL_ACCEPTANCE_IS_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "TO_BE_FINALLY_INSPECTED", target = "UNDER_CONSTRUCTION")
- public void TO_BE_FINALLY_INSPECTED_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_CONSTRUCTION.getCode());
- }
-
-
- @OnTransition(source = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW", target = "ARCHIVED")
- public void FINAL_ACCEPTANCE_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- // 终验审核通过后,项目一级状态变更为已归档
- project.setStage(ProjectStatusEnum.ARCHIVED.getCode());
- project.setStatus(ProjectStatusEnum.ACCEPTED.getCode());
- }
-
- @OnTransition(source = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW", target = "FINAL_ACCEPTANCE_REVIEW_FAILED")
- public void FINAL_ACCEPTANCE_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.FINAL_ACCEPTANCE_REVIEW_FAILED.getCode());
- }
-
- @OnTransition(source = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW", target = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW")
- public void FINAL_ACCEPTANCE_IS_UNDER_REVIEW_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.FINAL_ACCEPTANCE_IS_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "FINAL_ACCEPTANCE_REVIEW_FAILED", target = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW")
- public void FINAL_RE_ACCEPTANCE_APPLICATION(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.FINAL_ACCEPTANCE_IS_UNDER_REVIEW.getCode());
- }
-}
diff --git a/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/ProjectDeclareKFBAction.java b/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/ProjectDeclareKFBAction.java
deleted file mode 100644
index 9189f14..0000000
--- a/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/ProjectDeclareKFBAction.java
+++ /dev/null
@@ -1,279 +0,0 @@
-package com.hz.pm.api.common.statemachine.action;
-
-import com.hz.pm.api.common.model.constant.StateMachineConst;
-import com.hz.pm.api.common.statemachine.contant.RegionContant;
-import com.hz.pm.api.common.statemachine.event.ProjectStatusChangeEvent;
-import com.hz.pm.api.projectlib.model.enumeration.ProjectStatusEnum;
-import com.hz.pm.api.projectlib.model.entity.Project;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.messaging.Message;
-import org.springframework.statemachine.annotation.OnTransition;
-import org.springframework.statemachine.annotation.WithStateMachine;
-
-/**
- * 项目申报状态机action集合类
- * 开发区
- * @author CMM
- * @since 2023/02/08 13:48
- */
-@Slf4j
-@WithStateMachine(id = RegionContant.LS_KFQ_CODE)
-public class ProjectDeclareKFBAction {
-
- private static final String PROJECT_DECLARE = StateMachineConst.PROJECT_DECLARE;
-
- @OnTransition(source = "UNDER_INTERNAL_AUDIT", target = "PENDING_PREQUALIFICATION")
- public void UNDER_INTERNAL_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PENDING_PREQUALIFICATION.getCode());
- }
-
- @OnTransition(source = "UNDER_INTERNAL_AUDIT", target = "UNDER_INTERNAL_AUDIT_NOT_PASS")
- public void UNDER_INTERNAL_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_INTERNAL_AUDIT_NOT_PASS.getCode());
- }
-
- @OnTransition(source = "UNDER_INTERNAL_AUDIT", target = "TO_BE_DECLARED")
- public void UNDER_INTERNAL_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.TO_BE_DECLARED.getCode());
- }
-
- @OnTransition(source = "UNDER_INTERNAL_AUDIT_NOT_PASS", target = "UNDER_INTERNAL_AUDIT")
- public void UNDER_INTERNAL_REJECT_RESUBMIT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_INTERNAL_AUDIT.getCode());
- }
-
-
- @OnTransition(source = "PENDING_PREQUALIFICATION", target = "PENDING_PREQUALIFICATION_CHOICE")
- public void PRELIMINARY_REVIEW_DECLARE(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PENDING_PREQUALIFICATION_CHOICE.getCode());
- }
-
- @OnTransition(source = "PENDING_PREQUALIFICATION", target = "UNDER_INTERNAL_AUDIT")
- public void PENDING_PREQUALIFICATION_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_INTERNAL_AUDIT.getCode());
- }
-
-
- @OnTransition(source = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS", target = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS_SUCCESS")
- public void PROVINCIAL_DEPARTMENT_REVIEW_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS_SUCCESS.getCode());
- }
-
- @OnTransition(source = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS_SUCCESS", target = "PRE_APPLYING")
- public void PROVINCIAL_PASS_TO_PRELIMINARY_REVIEW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PRE_APPLYING.getCode());
- }
-
- @OnTransition(source = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS", target = "THE_JOINT_REVIEW_OF_PROVINCIAL_DEPARTMENTS_FAILED")
- public void PROVINCIAL_DEPARTMENT_REVIEW_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.THE_JOINT_REVIEW_OF_PROVINCIAL_DEPARTMENTS_FAILED.getCode());
- }
-
- @OnTransition(source = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS", target = "PENDING_PREQUALIFICATION")
- public void JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PENDING_PREQUALIFICATION.getCode());
- }
-
- @OnTransition(source = "PRE_APPLYING", target = "DEPARTMENT_JOINT_REVIEW")
- public void PRELIMINARY_REVIEW_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.DEPARTMENT_JOINT_REVIEW.getCode());
- }
-
- @OnTransition(source = "PRE_APPLYING", target = "PREQUALIFICATION_FAILED")
- public void PRELIMINARY_REVIEW_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PREQUALIFICATION_FAILED.getCode());
- }
-
- @OnTransition(source = "PREQUALIFICATION_FAILED", target = "PENDING_PREQUALIFICATION_CHOICE")
- public void PRELIMINARY_REVIEW_REJECT_RESUBMIT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PENDING_PREQUALIFICATION_CHOICE.getCode());
- }
-
- @OnTransition(source = "PRE_APPLYING", target = "PREQUALIFICATION_WITHDRAW_CHOICE")
- public void PRE_APPLYING_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PREQUALIFICATION_WITHDRAW_CHOICE.getCode());
- }
-
-
- @OnTransition(source = "DEPARTMENT_JOINT_REVIEW", target = "IN_THE_ANNUAL_PLAN")
- public void DEPARTMENT_UNITED_REVIEW_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.IN_THE_ANNUAL_PLAN.getCode());
- }
-
- @OnTransition(source = "DEPARTMENT_JOINT_REVIEW", target = "DEPARTMENT_JOINT_REVIEW_FAILED")
- public void DEPARTMENT_UNITED_REVIEW_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.DEPARTMENT_JOINT_REVIEW_FAILED.getCode());
- }
-
- @OnTransition(source = "DEPARTMENT_JOINT_REVIEW", target = "PRE_APPLYING")
- public void DEPARTMENT_JOINT_REVIEW_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PRE_APPLYING.getCode());
- }
-
-
- @OnTransition(source = "IN_THE_ANNUAL_PLAN", target = "PLAN_TO_BE_DECLARED")
- public void ANNUAL_PLAN_PROJECT_OPEN_PLAN_DECLARE(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PLAN_TO_BE_DECLARED.getCode());
- }
-
- @OnTransition(source = "IN_THE_ANNUAL_PLAN", target = "BE_SUSPENDED")
- public void ANNUAL_PLAN_SUSPEND(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.BE_SUSPENDED.getCode());
- }
-
- @OnTransition(source = "IN_THE_ANNUAL_PLAN", target = "DEPARTMENT_JOINT_REVIEW")
- public void IN_THE_ANNUAL_PLAN_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.DEPARTMENT_JOINT_REVIEW.getCode());
- }
-
-
- @OnTransition(source = "PLAN_TO_BE_DECLARED", target = "SCHEME_UNDER_REVIEW")
- public void DECLARE_PLAN(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.SCHEME_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "PLAN_TO_BE_DECLARED", target = "IN_THE_ANNUAL_PLAN")
- public void PLAN_TO_DECLARE_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.IN_THE_ANNUAL_PLAN.getCode());
- }
-
- @OnTransition(source = "SCHEME_REVIEW_FAILED", target = "SCHEME_UNDER_REVIEW")
- public void DECLARE_PLAN_RESUBMIT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.SCHEME_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "SCHEME_UNDER_REVIEW", target = "TO_BE_APPROVED")
- public void PLAN_REVIEW_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.TO_BE_APPROVED.getCode());
- }
-
- @OnTransition(source = "SCHEME_UNDER_REVIEW", target = "SCHEME_REVIEW_FAILED")
- public void PLAN_REVIEW_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.SCHEME_REVIEW_FAILED.getCode());
- }
-
- @OnTransition(source = "SCHEME_REVIEW_FAILED", target = "SCHEME_UNDER_REVIEW")
- public void PLAN_REVIEW_REJECT_RESUBMIT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.SCHEME_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "SCHEME_UNDER_REVIEW", target = "PLAN_TO_BE_DECLARED")
- public void SCHEME_UNDER_REVIEW_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PLAN_TO_BE_DECLARED.getCode());
- }
-
-
- @OnTransition(source = "TO_BE_APPROVED", target = "TO_BE_PURCHASED")
- public void PROJECT_APPROVAL(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- // 待立项批复批复后,项目一级状态变更为已立项
- project.setStage(ProjectStatusEnum.PROJECT_APPROVED.getCode());
- project.setStatus(ProjectStatusEnum.TO_BE_PURCHASED.getCode());
- }
-
- @OnTransition(source = "TO_BE_APPROVED", target = "SCHEME_UNDER_REVIEW")
- public void TO_BE_APPROVED_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.SCHEME_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "TO_BE_PURCHASED", target = "OPERATION")
- public void PURCHASE_PUT_ON_RECORD(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.OPERATION.getCode());
- }
-
- @OnTransition(source = "OPERATION", target = "UNDER_CONSTRUCTION")
- public void START_TO_WORK(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_CONSTRUCTION.getCode());
- }
-
- @OnTransition(source = "TO_BE_PURCHASED", target = "TO_BE_APPROVED")
- public void TO_BE_PURCHASED_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- // 待采购状态撤回后,项目一级状态回退到未立项
- project.setStage(ProjectStatusEnum.NOT_APPROVED.getCode());
- project.setStatus(ProjectStatusEnum.TO_BE_APPROVED.getCode());
- }
-
-
- @OnTransition(source = "UNDER_CONSTRUCTION", target = "TO_BE_FINALLY_INSPECTED")
- public void PRELIMINARY_ACCEPTANCE_PUT_ON_RECORD(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.TO_BE_FINALLY_INSPECTED.getCode());
- }
-
- @OnTransition(source = "UNDER_CONSTRUCTION", target = "TO_BE_PURCHASED")
- public void UNDER_CONSTRUCTION_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.TO_BE_PURCHASED.getCode());
- }
-
-
- @OnTransition(source = "TO_BE_FINALLY_INSPECTED", target = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW")
- public void FINAL_ACCEPTANCE_APPLICATION(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.FINAL_ACCEPTANCE_IS_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "TO_BE_FINALLY_INSPECTED", target = "UNDER_CONSTRUCTION")
- public void TO_BE_FINALLY_INSPECTED_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_CONSTRUCTION.getCode());
- }
-
-
- @OnTransition(source = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW", target = "ARCHIVED")
- public void FINAL_ACCEPTANCE_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- // 终验审核通过后,项目一级状态变更为已归档
- project.setStage(ProjectStatusEnum.ARCHIVED.getCode());
- project.setStatus(ProjectStatusEnum.ACCEPTED.getCode());
- }
-
- @OnTransition(source = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW", target = "FINAL_ACCEPTANCE_REVIEW_FAILED")
- public void FINAL_ACCEPTANCE_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.FINAL_ACCEPTANCE_REVIEW_FAILED.getCode());
- }
-
- @OnTransition(source = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW", target = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW")
- public void FINAL_ACCEPTANCE_IS_UNDER_REVIEW_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.FINAL_ACCEPTANCE_IS_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "FINAL_ACCEPTANCE_REVIEW_FAILED", target = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW")
- public void FINAL_RE_ACCEPTANCE_APPLICATION(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.FINAL_ACCEPTANCE_IS_UNDER_REVIEW.getCode());
- }
-}
diff --git a/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/ProjectDeclareLDAction.java b/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/ProjectDeclareLDAction.java
deleted file mode 100644
index 7b7c50c..0000000
--- a/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/ProjectDeclareLDAction.java
+++ /dev/null
@@ -1,279 +0,0 @@
-package com.hz.pm.api.common.statemachine.action;
-
-import com.hz.pm.api.common.model.constant.StateMachineConst;
-import com.hz.pm.api.common.statemachine.contant.RegionContant;
-import com.hz.pm.api.common.statemachine.event.ProjectStatusChangeEvent;
-import com.hz.pm.api.projectlib.model.enumeration.ProjectStatusEnum;
-import com.hz.pm.api.projectlib.model.entity.Project;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.messaging.Message;
-import org.springframework.statemachine.annotation.OnTransition;
-import org.springframework.statemachine.annotation.WithStateMachine;
-
-/**
- * 项目申报状态机action集合类
- * 莲都区
- * @author CMM
- * @since 2023/02/08 13:48
- */
-@Slf4j
-@WithStateMachine(id = RegionContant.LS_LD_CODE)
-public class ProjectDeclareLDAction {
-
- private static final String PROJECT_DECLARE = StateMachineConst.PROJECT_DECLARE;
-
- @OnTransition(source = "UNDER_INTERNAL_AUDIT", target = "PENDING_PREQUALIFICATION")
- public void UNDER_INTERNAL_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PENDING_PREQUALIFICATION.getCode());
- }
-
- @OnTransition(source = "UNDER_INTERNAL_AUDIT", target = "UNDER_INTERNAL_AUDIT_NOT_PASS")
- public void UNDER_INTERNAL_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_INTERNAL_AUDIT_NOT_PASS.getCode());
- }
-
- @OnTransition(source = "UNDER_INTERNAL_AUDIT", target = "TO_BE_DECLARED")
- public void UNDER_INTERNAL_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.TO_BE_DECLARED.getCode());
- }
-
- @OnTransition(source = "UNDER_INTERNAL_AUDIT_NOT_PASS", target = "UNDER_INTERNAL_AUDIT")
- public void UNDER_INTERNAL_REJECT_RESUBMIT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_INTERNAL_AUDIT.getCode());
- }
-
-
- @OnTransition(source = "PENDING_PREQUALIFICATION", target = "PENDING_PREQUALIFICATION_CHOICE")
- public void PRELIMINARY_REVIEW_DECLARE(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PENDING_PREQUALIFICATION_CHOICE.getCode());
- }
-
- @OnTransition(source = "PENDING_PREQUALIFICATION", target = "UNDER_INTERNAL_AUDIT")
- public void PENDING_PREQUALIFICATION_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_INTERNAL_AUDIT.getCode());
- }
-
-
- @OnTransition(source = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS", target = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS_SUCCESS")
- public void PROVINCIAL_DEPARTMENT_REVIEW_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS_SUCCESS.getCode());
- }
-
- @OnTransition(source = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS_SUCCESS", target = "PRE_APPLYING")
- public void PROVINCIAL_PASS_TO_PRELIMINARY_REVIEW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PRE_APPLYING.getCode());
- }
-
- @OnTransition(source = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS", target = "THE_JOINT_REVIEW_OF_PROVINCIAL_DEPARTMENTS_FAILED")
- public void PROVINCIAL_DEPARTMENT_REVIEW_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.THE_JOINT_REVIEW_OF_PROVINCIAL_DEPARTMENTS_FAILED.getCode());
- }
-
- @OnTransition(source = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS", target = "PENDING_PREQUALIFICATION")
- public void JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PENDING_PREQUALIFICATION.getCode());
- }
-
- @OnTransition(source = "PRE_APPLYING", target = "DEPARTMENT_JOINT_REVIEW")
- public void PRELIMINARY_REVIEW_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.DEPARTMENT_JOINT_REVIEW.getCode());
- }
-
- @OnTransition(source = "PRE_APPLYING", target = "PREQUALIFICATION_FAILED")
- public void PRELIMINARY_REVIEW_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PREQUALIFICATION_FAILED.getCode());
- }
-
- @OnTransition(source = "PREQUALIFICATION_FAILED", target = "PENDING_PREQUALIFICATION_CHOICE")
- public void PRELIMINARY_REVIEW_REJECT_RESUBMIT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PENDING_PREQUALIFICATION_CHOICE.getCode());
- }
-
- @OnTransition(source = "PRE_APPLYING", target = "PREQUALIFICATION_WITHDRAW_CHOICE")
- public void PRE_APPLYING_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PREQUALIFICATION_WITHDRAW_CHOICE.getCode());
- }
-
-
- @OnTransition(source = "DEPARTMENT_JOINT_REVIEW", target = "IN_THE_ANNUAL_PLAN")
- public void DEPARTMENT_UNITED_REVIEW_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.IN_THE_ANNUAL_PLAN.getCode());
- }
-
- @OnTransition(source = "DEPARTMENT_JOINT_REVIEW", target = "DEPARTMENT_JOINT_REVIEW_FAILED")
- public void DEPARTMENT_UNITED_REVIEW_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.DEPARTMENT_JOINT_REVIEW_FAILED.getCode());
- }
-
- @OnTransition(source = "DEPARTMENT_JOINT_REVIEW", target = "PRE_APPLYING")
- public void DEPARTMENT_JOINT_REVIEW_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PRE_APPLYING.getCode());
- }
-
-
- @OnTransition(source = "IN_THE_ANNUAL_PLAN", target = "PLAN_TO_BE_DECLARED")
- public void ANNUAL_PLAN_PROJECT_OPEN_PLAN_DECLARE(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PLAN_TO_BE_DECLARED.getCode());
- }
-
- @OnTransition(source = "IN_THE_ANNUAL_PLAN", target = "BE_SUSPENDED")
- public void ANNUAL_PLAN_SUSPEND(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.BE_SUSPENDED.getCode());
- }
-
- @OnTransition(source = "IN_THE_ANNUAL_PLAN", target = "DEPARTMENT_JOINT_REVIEW")
- public void IN_THE_ANNUAL_PLAN_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.DEPARTMENT_JOINT_REVIEW.getCode());
- }
-
-
- @OnTransition(source = "PLAN_TO_BE_DECLARED", target = "SCHEME_UNDER_REVIEW")
- public void DECLARE_PLAN(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.SCHEME_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "PLAN_TO_BE_DECLARED", target = "IN_THE_ANNUAL_PLAN")
- public void PLAN_TO_DECLARE_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.IN_THE_ANNUAL_PLAN.getCode());
- }
-
- @OnTransition(source = "SCHEME_REVIEW_FAILED", target = "SCHEME_UNDER_REVIEW")
- public void DECLARE_PLAN_RESUBMIT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.SCHEME_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "SCHEME_UNDER_REVIEW", target = "TO_BE_APPROVED")
- public void PLAN_REVIEW_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.TO_BE_APPROVED.getCode());
- }
-
- @OnTransition(source = "SCHEME_UNDER_REVIEW", target = "SCHEME_REVIEW_FAILED")
- public void PLAN_REVIEW_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.SCHEME_REVIEW_FAILED.getCode());
- }
-
- @OnTransition(source = "SCHEME_REVIEW_FAILED", target = "SCHEME_UNDER_REVIEW")
- public void PLAN_REVIEW_REJECT_RESUBMIT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.SCHEME_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "SCHEME_UNDER_REVIEW", target = "PLAN_TO_BE_DECLARED")
- public void SCHEME_UNDER_REVIEW_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PLAN_TO_BE_DECLARED.getCode());
- }
-
-
- @OnTransition(source = "TO_BE_APPROVED", target = "TO_BE_PURCHASED")
- public void PROJECT_APPROVAL(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- // 待立项批复批复后,项目一级状态变更为已立项
- project.setStage(ProjectStatusEnum.PROJECT_APPROVED.getCode());
- project.setStatus(ProjectStatusEnum.TO_BE_PURCHASED.getCode());
- }
-
- @OnTransition(source = "TO_BE_APPROVED", target = "SCHEME_UNDER_REVIEW")
- public void TO_BE_APPROVED_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.SCHEME_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "TO_BE_PURCHASED", target = "OPERATION")
- public void PURCHASE_PUT_ON_RECORD(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.OPERATION.getCode());
- }
-
- @OnTransition(source = "OPERATION", target = "UNDER_CONSTRUCTION")
- public void START_TO_WORK(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_CONSTRUCTION.getCode());
- }
-
- @OnTransition(source = "TO_BE_PURCHASED", target = "TO_BE_APPROVED")
- public void TO_BE_PURCHASED_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- // 待采购状态撤回后,项目一级状态回退到未立项
- project.setStage(ProjectStatusEnum.NOT_APPROVED.getCode());
- project.setStatus(ProjectStatusEnum.TO_BE_APPROVED.getCode());
- }
-
-
- @OnTransition(source = "UNDER_CONSTRUCTION", target = "TO_BE_FINALLY_INSPECTED")
- public void PRELIMINARY_ACCEPTANCE_PUT_ON_RECORD(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.TO_BE_FINALLY_INSPECTED.getCode());
- }
-
- @OnTransition(source = "UNDER_CONSTRUCTION", target = "TO_BE_PURCHASED")
- public void UNDER_CONSTRUCTION_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.TO_BE_PURCHASED.getCode());
- }
-
-
- @OnTransition(source = "TO_BE_FINALLY_INSPECTED", target = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW")
- public void FINAL_ACCEPTANCE_APPLICATION(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.FINAL_ACCEPTANCE_IS_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "TO_BE_FINALLY_INSPECTED", target = "UNDER_CONSTRUCTION")
- public void TO_BE_FINALLY_INSPECTED_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_CONSTRUCTION.getCode());
- }
-
-
- @OnTransition(source = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW", target = "ARCHIVED")
- public void FINAL_ACCEPTANCE_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- // 终验审核通过后,项目一级状态变更为已归档
- project.setStage(ProjectStatusEnum.ARCHIVED.getCode());
- project.setStatus(ProjectStatusEnum.ACCEPTED.getCode());
- }
-
- @OnTransition(source = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW", target = "FINAL_ACCEPTANCE_REVIEW_FAILED")
- public void FINAL_ACCEPTANCE_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.FINAL_ACCEPTANCE_REVIEW_FAILED.getCode());
- }
-
- @OnTransition(source = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW", target = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW")
- public void FINAL_ACCEPTANCE_IS_UNDER_REVIEW_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.FINAL_ACCEPTANCE_IS_UNDER_REVIEW.getCode());
- }
-
- @OnTransition(source = "FINAL_ACCEPTANCE_REVIEW_FAILED", target = "FINAL_ACCEPTANCE_IS_UNDER_REVIEW")
- public void FINAL_RE_ACCEPTANCE_APPLICATION(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.FINAL_ACCEPTANCE_IS_UNDER_REVIEW.getCode());
- }
-}
diff --git a/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/ProjectDeclareLQAction.java b/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/ProjectDeclareLQAction.java
deleted file mode 100644
index f664b7b..0000000
--- a/hz-pm-api/src/main/java/com/hz/pm/api/common/statemachine/action/ProjectDeclareLQAction.java
+++ /dev/null
@@ -1,279 +0,0 @@
-package com.hz.pm.api.common.statemachine.action;
-
-import com.hz.pm.api.common.model.constant.StateMachineConst;
-import com.hz.pm.api.common.statemachine.contant.RegionContant;
-import com.hz.pm.api.common.statemachine.event.ProjectStatusChangeEvent;
-import com.hz.pm.api.projectlib.model.enumeration.ProjectStatusEnum;
-import com.hz.pm.api.projectlib.model.entity.Project;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.messaging.Message;
-import org.springframework.statemachine.annotation.OnTransition;
-import org.springframework.statemachine.annotation.WithStateMachine;
-
-/**
- * 项目申报状态机action集合类
- * ;龙泉市
- * @author CMM
- * @since 2023/02/08 13:48
- */
-@Slf4j
-@WithStateMachine(id = RegionContant.LS_LQ_CODE)
-public class ProjectDeclareLQAction {
-
- private static final String PROJECT_DECLARE = StateMachineConst.PROJECT_DECLARE;
-
- @OnTransition(source = "UNDER_INTERNAL_AUDIT", target = "PENDING_PREQUALIFICATION")
- public void UNDER_INTERNAL_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PENDING_PREQUALIFICATION.getCode());
- }
-
- @OnTransition(source = "UNDER_INTERNAL_AUDIT", target = "UNDER_INTERNAL_AUDIT_NOT_PASS")
- public void UNDER_INTERNAL_REJECT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_INTERNAL_AUDIT_NOT_PASS.getCode());
- }
-
- @OnTransition(source = "UNDER_INTERNAL_AUDIT", target = "TO_BE_DECLARED")
- public void UNDER_INTERNAL_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.TO_BE_DECLARED.getCode());
- }
-
- @OnTransition(source = "UNDER_INTERNAL_AUDIT_NOT_PASS", target = "UNDER_INTERNAL_AUDIT")
- public void UNDER_INTERNAL_REJECT_RESUBMIT(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_INTERNAL_AUDIT.getCode());
- }
-
-
- @OnTransition(source = "PENDING_PREQUALIFICATION", target = "PENDING_PREQUALIFICATION_CHOICE")
- public void PRELIMINARY_REVIEW_DECLARE(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PENDING_PREQUALIFICATION_CHOICE.getCode());
- }
-
- @OnTransition(source = "PENDING_PREQUALIFICATION", target = "UNDER_INTERNAL_AUDIT")
- public void PENDING_PREQUALIFICATION_WITHDRAW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.UNDER_INTERNAL_AUDIT.getCode());
- }
-
-
- @OnTransition(source = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS", target = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS_SUCCESS")
- public void PROVINCIAL_DEPARTMENT_REVIEW_PASS(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS_SUCCESS.getCode());
- }
-
- @OnTransition(source = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS_SUCCESS", target = "PRE_APPLYING")
- public void PROVINCIAL_PASS_TO_PRELIMINARY_REVIEW(Message message) {
- Project project = (Project) message.getHeaders().get(PROJECT_DECLARE);
- project.setStatus(ProjectStatusEnum.PRE_APPLYING.getCode());
- }
-
- @OnTransition(source = "JOINT_REVIEW_BY_PROVINCIAL_DEPARTMENTS", target = "THE_JOINT_REVIEW_OF_PROVINCIAL_DEPARTMENTS_FAILED")
- public void PROVINCIAL_DEPARTMENT_REVIEW_REJECT(Message