liuc/biz_supplier_manage
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

seata测试

Browse Source
This commit is contained in:
dxc
2021-03-02 19:43:12 +08:00
parent 929a879676
commit e53b855daf
1 changed files with 68 additions and 63 deletions
Download Patch File Download Diff File Expand all files Collapse all files

131
src/main/java/com/chinaunicom/mall/ebtp/project/projectreevaluation/service/impl/ProjectReEvaluationServiceImpl.java
View File

@ -31,6 +31,7 @@ import com.chinaunicom.mall.ebtp.project.projectreevaluation.entity.ProjectReEva
import com.chinaunicom.mall.ebtp.project.projectreevaluation.service.IProjectReEvaluationService; import com.chinaunicom.mall.ebtp.project.projectreevaluation.service.IProjectReEvaluationService;
import com.chinaunicom.mall.ebtp.project.projectsection.entity.ProjectSection; import com.chinaunicom.mall.ebtp.project.projectsection.entity.ProjectSection;
import com.chinaunicom.mall.ebtp.project.projectsection.service.IProjectSectionService; import com.chinaunicom.mall.ebtp.project.projectsection.service.IProjectSectionService;
import io.seata.core.context.RootContext;
import io.seata.spring.annotation.GlobalTransactional; import io.seata.spring.annotation.GlobalTransactional;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.StringUtils;
@ -181,31 +182,31 @@ public class ProjectReEvaluationServiceImpl extends BaseServiceImpl<ProjectReEva
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public boolean submitForApproval(String id) { public boolean submitForApproval(String id) {
// initSection(id); initSection(id);
// boolean result = updateStatus(id,ProjectCommonUtil.RE_EVALUATION_STATUS_0,ProjectCommonUtil.RE_EVALUATION_STATUS_2); boolean result = updateStatus(id,ProjectCommonUtil.RE_EVALUATION_STATUS_0,ProjectCommonUtil.RE_EVALUATION_STATUS_2);
//1 去采购系统校验子项目信息是否发生改变 如果发生改变不可以重新评审 // //1 去采购系统校验子项目信息是否发生改变 如果发生改变不可以重新评审
ProjectReEvaluation evaluation = this.getById(id); // ProjectReEvaluation evaluation = this.getById(id);
ProjectSection section = sectionService.getById(evaluation.getSectionId()); // ProjectSection section = sectionService.getById(evaluation.getSectionId());
BaseResponse<Boolean> baseResponse = mallResuApi.findStatusByPurpIdForEval(Long.parseLong(section.getSubprojectId())); // BaseResponse<Boolean> baseResponse = mallResuApi.findStatusByPurpIdForEval(Long.parseLong(section.getSubprojectId()));
if(!baseResponse.isSuccess()){ // if(!baseResponse.isSuccess()){
CommonExceptionEnum.FRAME_EXCEPTION_COMMON_NOT_UPDATE.customValidName(baseResponse.getMessage(),!baseResponse.isSuccess()); // CommonExceptionEnum.FRAME_EXCEPTION_COMMON_NOT_UPDATE.customValidName(baseResponse.getMessage(),!baseResponse.isSuccess());
} // }
if(!baseResponse.getData()){ // if(!baseResponse.getData()){
ProjectExceptionEnum.FRAME_EXCEPTION_PROJECT_EXCEPTION_CHECK_STATUS_ERROR.throwException(); // ProjectExceptionEnum.FRAME_EXCEPTION_PROJECT_EXCEPTION_CHECK_STATUS_ERROR.throwException();
} // }
//
//3、调用流程中心 发起重新评审流程 // //3、调用流程中心 发起重新评审流程
ProjectReEvaluationTaskVO reEvaluationTaskVO = reEvalStart(id); // ProjectReEvaluationTaskVO reEvaluationTaskVO = reEvalStart(id);
//
//修改异常信息进行提交 // //修改异常信息进行提交
UpdateWrapper<ProjectReEvaluation> updateWrapper = new UpdateWrapper<>(); // UpdateWrapper<ProjectReEvaluation> updateWrapper = new UpdateWrapper<>();
updateWrapper.eq(ProjectReEvaluationField.ID,id); // updateWrapper.eq(ProjectReEvaluationField.ID,id);
updateWrapper.eq(ProjectReEvaluationField.STATUS, ProjectCommonUtil.RE_EVALUATION_STATUS_0); // updateWrapper.eq(ProjectReEvaluationField.STATUS, ProjectCommonUtil.RE_EVALUATION_STATUS_0);
updateWrapper.set(ProjectReEvaluationField.STATUS,ProjectCommonUtil.RE_EVALUATION_STATUS_1); // updateWrapper.set(ProjectReEvaluationField.STATUS,ProjectCommonUtil.RE_EVALUATION_STATUS_1);
updateWrapper.set(ProjectReEvaluationField.INSTANCE_ID,reEvaluationTaskVO.getInstanceId()); // updateWrapper.set(ProjectReEvaluationField.INSTANCE_ID,reEvaluationTaskVO.getInstanceId());
boolean result = this.update(updateWrapper); // boolean result = this.update(updateWrapper);
CommonExceptionEnum.FRAME_EXCEPTION_COMMON_NOT_UPDATE.customValid(!result); // CommonExceptionEnum.FRAME_EXCEPTION_COMMON_NOT_UPDATE.customValid(!result);
return result; return result;
} }
@ -356,58 +357,62 @@ public class ProjectReEvaluationServiceImpl extends BaseServiceImpl<ProjectReEva
* 初始化标段信息 * 初始化标段信息
* @param id 主键 * @param id 主键
*/ */
@GlobalTransactional
private void initSection(String id) { private void initSection(String id) {
ProjectReEvaluation evaluation = this.getById(id); ProjectReEvaluation evaluation = this.getById(id);
ProjectExceptionEnum.FRAME_EXCEPTION_PROJECT_RE_EVAL_NOT_FIND.customValid(null == evaluation); ProjectExceptionEnum.FRAME_EXCEPTION_PROJECT_RE_EVAL_NOT_FIND.customValid(null == evaluation);
//第几轮评审（招募多轮） 不是招募多轮 默认 1 //第几轮评审（招募多轮） 不是招募多轮 默认 1
int roomSort = 1; int roomSort = 1;
log.info("xid:"+ RootContext.getXID());
//初始化评审室信息 //初始化评审室信息
log.info("初始化评审 请求参数："+ evaluation.getProjectId(), evaluation.getSectionId(), roomSort); log.info("初始化评审 请求参数："+ evaluation.getProjectId(), evaluation.getSectionId(), roomSort);
BaseResponse<AgainRoomVO> response = mallProcessApi.againinitialize(evaluation.getProjectId(), evaluation.getSectionId(), roomSort); BaseResponse<AgainRoomVO> response = mallProcessApi.againinitialize(evaluation.getProjectId(), evaluation.getSectionId(), roomSort);
ProjectExceptionEnum.FRAME_EXCEPTION_ERROR.customValidName(response.getMessage(),!response.isSuccess()); ProjectExceptionEnum.FRAME_EXCEPTION_ERROR.customValidName(response.getMessage(),!response.isSuccess());
log.info("初始化评审 返回结果："+ JsonUtils.objectToJson(response)); log.info("初始化评审 返回结果："+ JsonUtils.objectToJson(response));
AgainRoomVO againRoomVO = response.getData(); AgainRoomVO againRoomVO = response.getData();
ProjectExceptionEnum.FRAME_EXCEPTION_ERROR.throwException();
//复制招标信息 // //复制招标信息
log.info("复制招标信息 请求参数："+ JsonUtils.objectToJson(againRoomVO)); // log.info("复制招标信息 请求参数："+ JsonUtils.objectToJson(againRoomVO));
response = ebtpMallBidApi.copyDocument(againRoomVO); // response = ebtpMallBidApi.copyDocument(againRoomVO);
ProjectExceptionEnum.FRAME_EXCEPTION_ERROR.customValidName(response.getMessage(),!response.isSuccess()); // ProjectExceptionEnum.FRAME_EXCEPTION_ERROR.customValidName(response.getMessage(),!response.isSuccess());
log.info("复制招标信息 返回结果："+ JsonUtils.objectToJson(response)); // log.info("复制招标信息 返回结果："+ JsonUtils.objectToJson(response));
//
//复制投标信息 // //复制投标信息
log.info("复制投标信息 请求参数："+ JsonUtils.objectToJson(response.getData()),evaluation.getAssessId()); // log.info("复制投标信息 请求参数："+ JsonUtils.objectToJson(response.getData()),evaluation.getAssessId());
response = ebtpTenderApi.reviewAgain(response.getData(),evaluation.getAssessId()); // response = ebtpTenderApi.reviewAgain(response.getData(),evaluation.getAssessId());
ProjectExceptionEnum.FRAME_EXCEPTION_ERROR.customValidName(response.getMessage(),!response.isSuccess()); // ProjectExceptionEnum.FRAME_EXCEPTION_ERROR.customValidName(response.getMessage(),!response.isSuccess());
log.info("复制投标信息 返回结果："+ JsonUtils.objectToJson(response)); // log.info("复制投标信息 返回结果："+ JsonUtils.objectToJson(response));
//
//复制应答信息 // //复制应答信息
log.info("复制应答信息 请求参数："+ JsonUtils.objectToJson(response.getData())); // log.info("复制应答信息 请求参数："+ JsonUtils.objectToJson(response.getData()));
response = ebtpRespsApi.copyTdocByAgainRoom(response.getData()); // response = ebtpRespsApi.copyTdocByAgainRoom(response.getData());
ProjectExceptionEnum.FRAME_EXCEPTION_ERROR.customValidName(response.getMessage(),!response.isSuccess()); // ProjectExceptionEnum.FRAME_EXCEPTION_ERROR.customValidName(response.getMessage(),!response.isSuccess());
log.info("复制应答信息 返回结果："+ JsonUtils.objectToJson(response)); // log.info("复制应答信息 返回结果："+ JsonUtils.objectToJson(response));
//
//复制评审设置信息 // //复制评审设置信息
log.info("复制评审设置信息 请求参数："+ JsonUtils.objectToJson(response.getData())); // log.info("复制评审设置信息 请求参数："+ JsonUtils.objectToJson(response.getData()));
BaseResponse<Boolean> rsmsResponse = ebtpRsmsApi.again(response.getData()); // BaseResponse<Boolean> rsmsResponse = ebtpRsmsApi.again(response.getData());
ProjectExceptionEnum.FRAME_EXCEPTION_ERROR.customValidName(rsmsResponse.getMessage(),!rsmsResponse.isSuccess()); // ProjectExceptionEnum.FRAME_EXCEPTION_ERROR.customValidName(rsmsResponse.getMessage(),!rsmsResponse.isSuccess());
log.info("复制评审设置信息 返回结果："+ JsonUtils.objectToJson(rsmsResponse)); // log.info("复制评审设置信息 返回结果："+ JsonUtils.objectToJson(rsmsResponse));
//
//是否专家与上次一致 如果 是 进行复制 // //是否专家与上次一致 如果 是 进行复制
if(StringUtils.equals(ProjectCommonUtil.IS_AGREEMENT_YES,evaluation.getIsAgreement())){ // if(StringUtils.equals(ProjectCommonUtil.IS_AGREEMENT_YES,evaluation.getIsAgreement())){
BaseResponse<Boolean> juryResponse = ebtpRsmsApi.copyJury(evaluation.getAssessId(),againRoomVO.getRoomId()); // BaseResponse<Boolean> juryResponse = ebtpRsmsApi.copyJury(evaluation.getAssessId(),againRoomVO.getRoomId());
ProjectExceptionEnum.FRAME_EXCEPTION_ERROR.customValidName(juryResponse.getMessage(),!juryResponse.isSuccess()); // ProjectExceptionEnum.FRAME_EXCEPTION_ERROR.customValidName(juryResponse.getMessage(),!juryResponse.isSuccess());
} // }
//
//修改评审开始时间 // //修改评审开始时间
Map<String, LocalDateTime> updateProcessMap = new HashMap<>(16); // Map<String, LocalDateTime> updateProcessMap = new HashMap<>(16);
updateProcessMap.put(evaluation.getSectionId(),evaluation.getEvaluationStartTime()); // updateProcessMap.put(evaluation.getSectionId(),evaluation.getEvaluationStartTime());
log.info("修改评审开始时间 请求参数："+ JsonUtils.objectToJson(updateProcessMap)); // log.info("修改评审开始时间 请求参数："+ JsonUtils.objectToJson(updateProcessMap));
rsmsResponse = mallProcessApi.updateOpenTime(updateProcessMap); // rsmsResponse = mallProcessApi.updateOpenTime(updateProcessMap);
ProjectExceptionEnum.FRAME_EXCEPTION_ERROR.customValidName(rsmsResponse.getMessage(),!rsmsResponse.isSuccess()); // ProjectExceptionEnum.FRAME_EXCEPTION_ERROR.customValidName(rsmsResponse.getMessage(),!rsmsResponse.isSuccess());
log.info("修改评审开始时间 返回结果："+ JsonUtils.objectToJson(rsmsResponse)); // log.info("修改评审开始时间 返回结果："+ JsonUtils.objectToJson(rsmsResponse));
sectionService.calibrationToEvaluation(evaluation.getSectionId()); // sectionService.calibrationToEvaluation(evaluation.getSectionId());
} }