dev
zhanglei 2026-08-03 15:52:12 +08:00
parent a1beb09e48
commit 73370b5d78
3 changed files with 23 additions and 7 deletions

View File

@ -13,6 +13,7 @@ import org.qinan.safetyeval.client.dto.SingleResponse;
import org.qinan.safetyeval.client.dto.institution.EditSignTaskSaveCmd; import org.qinan.safetyeval.client.dto.institution.EditSignTaskSaveCmd;
import org.qinan.safetyeval.client.dto.institution.EvalSignTaskPageQuery; import org.qinan.safetyeval.client.dto.institution.EvalSignTaskPageQuery;
import org.qinan.safetyeval.client.dto.institution.EvalSignTaskSaveCmd; import org.qinan.safetyeval.client.dto.institution.EvalSignTaskSaveCmd;
import org.qinan.safetyeval.domain.constant.ProjectRoleEnum;
import org.qinan.safetyeval.domain.constant.ProjectStageEnum; import org.qinan.safetyeval.domain.constant.ProjectStageEnum;
import org.qinan.safetyeval.domain.constant.SignTaskStatusEnum; import org.qinan.safetyeval.domain.constant.SignTaskStatusEnum;
import org.qinan.safetyeval.domain.constant.SignatureTaskStatusEnum; import org.qinan.safetyeval.domain.constant.SignatureTaskStatusEnum;
@ -106,7 +107,7 @@ public class EvalSignTaskExecutor implements EvalSignTaskApi {
.last("limit 1")); .last("limit 1"));
if (!CollectionUtils.isEmpty(evalProjectMemberDOS)) { if (!CollectionUtils.isEmpty(evalProjectMemberDOS)) {
evalSignTaskCO.setSignerPersonnelName(evalProjectMemberDOS.get(0).getPersonnelName()); evalSignTaskCO.setSignerPersonnelName(evalProjectMemberDOS.get(0).getPersonnelName());
evalSignTaskCO.setSignerRoles(ProjectStageEnum.fromVals(evalProjectMemberDOS.get(0).getRole())); evalSignTaskCO.setSignerRoles(ProjectRoleEnum.fromVals(evalProjectMemberDOS.get(0).getRole()));
} }
return evalSignTaskCO; return evalSignTaskCO;
}).collect(Collectors.toList()); }).collect(Collectors.toList());
@ -172,7 +173,7 @@ public class EvalSignTaskExecutor implements EvalSignTaskApi {
public SingleResponse<EvalSignTaskStatisticsCO> signStatistics(EvalSignTaskPageQuery cmd) { public SingleResponse<EvalSignTaskStatisticsCO> signStatistics(EvalSignTaskPageQuery cmd) {
EvalSignTaskStatisticsCO evalSignTaskStatisticsCO = new EvalSignTaskStatisticsCO(); EvalSignTaskStatisticsCO evalSignTaskStatisticsCO = new EvalSignTaskStatisticsCO();
List<EvalSignTaskDO> evalSignTaskDOS = evalSignTaskMapper.selectList(new LambdaQueryWrapper<EvalSignTaskDO>() List<EvalSignTaskDO> evalSignTaskDOS = evalSignTaskMapper.selectList(new LambdaQueryWrapper<EvalSignTaskDO>()
.eq(EvalSignTaskDO::getProjectId, cmd.getProjectId()) .eq(Objects.nonNull(cmd.getProjectId()), EvalSignTaskDO::getProjectId, cmd.getProjectId())
.eq(EvalSignTaskDO::getSignerPersonnelId, cmd.getSignerPersonnelId())); .eq(EvalSignTaskDO::getSignerPersonnelId, cmd.getSignerPersonnelId()));
if (!CollectionUtils.isEmpty(evalSignTaskDOS)) { if (!CollectionUtils.isEmpty(evalSignTaskDOS)) {
long pendingSign = evalSignTaskDOS.stream().filter(f -> f.getTaskStatusCode() == 1).count(); long pendingSign = evalSignTaskDOS.stream().filter(f -> f.getTaskStatusCode() == 1).count();

View File

@ -1,8 +1,11 @@
package org.qinan.safetyeval.domain.constant; package org.qinan.safetyeval.domain.constant;
import cn.hutool.json.JSONUtil;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Getter; import lombok.Getter;
import java.util.List;
/** /**
* *
* *
@ -39,4 +42,19 @@ public enum ProjectRoleEnum {
} }
return null; return null;
} }
public static String fromVals(String val) {
StringBuilder sb = new StringBuilder();
List<String> vals = jsonToList(val);
for (ProjectRoleEnum stage : values()) {
if (vals.contains(stage.val)) {
sb.append(stage.mas).append(",");
}
}
return sb.toString();
}
public static List<String> jsonToList(String json) {
return json == null ? null : JSONUtil.toList(json, String.class);
}
} }

View File

@ -4,10 +4,7 @@ import com.alibaba.fastjson2.JSON;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import org.qinan.safetyeval.domain.constant.MessageSendStateEnum; import org.qinan.safetyeval.domain.constant.*;
import org.qinan.safetyeval.domain.constant.MsgConstant;
import org.qinan.safetyeval.domain.constant.NoticeTypeEnum;
import org.qinan.safetyeval.domain.constant.ProjectStageEnum;
import org.qinan.safetyeval.domain.entity.SafetyMessageEntity; import org.qinan.safetyeval.domain.entity.SafetyMessageEntity;
import org.qinan.safetyeval.domain.exception.BizException; import org.qinan.safetyeval.domain.exception.BizException;
import org.qinan.safetyeval.domain.exception.ErrorCode; import org.qinan.safetyeval.domain.exception.ErrorCode;
@ -71,7 +68,7 @@ public class SafetyMessageGatewayImpl implements SafetyMessageGateway {
.eq(EvalProjectMemberDO::getProjectId, projectId) .eq(EvalProjectMemberDO::getProjectId, projectId)
.eq(EvalProjectMemberDO::getPersonnelId, signerPersonnelId) .eq(EvalProjectMemberDO::getPersonnelId, signerPersonnelId)
.last("limit 1")); .last("limit 1"));
fillMap.put("role", ProjectStageEnum.fromVals(evalProjectMemberDOS.get(0).getRole())); fillMap.put("role", ProjectRoleEnum.fromVals(evalProjectMemberDOS.get(0).getRole()));
} }
params.put(MsgConstant.MSG_CONTENT_KEY_CONTENT, NoticeTypeEnum.SIGN_TASK_NOTICE.fillTemplate(fillMap)); params.put(MsgConstant.MSG_CONTENT_KEY_CONTENT, NoticeTypeEnum.SIGN_TASK_NOTICE.fillTemplate(fillMap));