dev-tmp1
zhanglei 2026-08-17 09:46:42 +08:00
parent 074d985f73
commit 4338960b85
5 changed files with 48 additions and 4 deletions

View File

@ -12,6 +12,7 @@ import org.qinan.safetyeval.client.dto.SingleResponse;
import org.qinan.safetyeval.client.dto.institution.*; import org.qinan.safetyeval.client.dto.institution.*;
import org.qinan.safetyeval.domain.constant.EvalProjectProgressStatEnum; import org.qinan.safetyeval.domain.constant.EvalProjectProgressStatEnum;
import org.qinan.safetyeval.domain.constant.EvalTypeEnum; import org.qinan.safetyeval.domain.constant.EvalTypeEnum;
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.entity.EvalProjectEntity; import org.qinan.safetyeval.domain.entity.EvalProjectEntity;
import org.qinan.safetyeval.domain.entity.EvalProjectMemberEntity; import org.qinan.safetyeval.domain.entity.EvalProjectMemberEntity;
@ -279,11 +280,32 @@ public class EvalProjectExecutor implements EvalProjectApi {
Map<Long, String> customerNameMap = evalCustomerMapper.selectBatchIds(co.stream() Map<Long, String> customerNameMap = evalCustomerMapper.selectBatchIds(co.stream()
.map(EvalProjectCO::getCustomerId).collect(Collectors.toList())) .map(EvalProjectCO::getCustomerId).collect(Collectors.toList()))
.stream().collect(Collectors.toMap(EvalCustomerDO::getId, EvalCustomerDO::getCustomerName)); .stream().collect(Collectors.toMap(EvalCustomerDO::getId, EvalCustomerDO::getCustomerName));
co.forEach(item -> item.setCustomerName(customerNameMap.get(Long.valueOf(item.getCustomerId())))); Map<Long, String> projectRole = getProjectRole(co.stream().map(EvalProjectCO::getId).map(Long::new).collect(Collectors.toList()));
co.forEach(item -> {
item.setCustomerName(customerNameMap.get(Long.valueOf(item.getCustomerId())));
item.setRole(projectRole.get(Long.valueOf(item.getId())));
});
} }
return PageResponse.of(co, pageResult.getTotal()); return PageResponse.of(co, pageResult.getTotal());
} }
/**
* ,
* @return
*/
public Map<Long, String> getProjectRole(List<Long> projectIds) {
List<EvalProjectMemberDO> evalProjectMemberDOS = evalProjectMemberMapper.selectList(new LambdaQueryWrapper<EvalProjectMemberDO>()
.eq(EvalProjectMemberDO::getProjectId, projectIds)
.eq(EvalProjectMemberDO::getPersonnelId, AuthUserContextAdapter.getCurrentUserId()));
if (CollectionUtils.isEmpty(evalProjectMemberDOS)) {
return null;
}
for (EvalProjectMemberDO evalProjectMemberDO : evalProjectMemberDOS) {
evalProjectMemberDO.setRole(ProjectRoleEnum.fromVals(evalProjectMemberDO.getRole()));
}
return evalProjectMemberDOS.stream().collect(Collectors.toMap(EvalProjectMemberDO::getId, EvalProjectMemberDO::getRole));
}
@Override @Override
public SingleResponse<EvalProjectStatisticsCO> appProjectStatistics() { public SingleResponse<EvalProjectStatisticsCO> appProjectStatistics() {
EvalProjectPageQuery evalProjectPageQuery = new EvalProjectPageQuery(); EvalProjectPageQuery evalProjectPageQuery = new EvalProjectPageQuery();

View File

@ -8,6 +8,7 @@ import org.qinan.safetyeval.client.dto.PageResponse;
import org.qinan.safetyeval.client.dto.SingleResponse; import org.qinan.safetyeval.client.dto.SingleResponse;
import org.qinan.safetyeval.client.dto.institution.EvalProjectMemberAddCmd; import org.qinan.safetyeval.client.dto.institution.EvalProjectMemberAddCmd;
import org.qinan.safetyeval.client.dto.institution.EvalProjectMemberPageQuery; import org.qinan.safetyeval.client.dto.institution.EvalProjectMemberPageQuery;
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.entity.EvalProjectMemberEntity; import org.qinan.safetyeval.domain.entity.EvalProjectMemberEntity;
import org.qinan.safetyeval.domain.exception.ErrorCode; import org.qinan.safetyeval.domain.exception.ErrorCode;
@ -69,8 +70,12 @@ public class EvalProjectMemberExecutor implements EvalProjectMemberApi {
EvalProjectMemberQuery domainQuery = evalProjectMemberCmdConvertor.convertPageQueryToQ(query); EvalProjectMemberQuery domainQuery = evalProjectMemberCmdConvertor.convertPageQueryToQ(query);
domainQuery.setOrgId(institutionOrgSupport.resolveCurrentOrgId()); domainQuery.setOrgId(institutionOrgSupport.resolveCurrentOrgId());
PageResult<EvalProjectMemberEntity> pageResult = evalProjectMemberDomainService.page(domainQuery); PageResult<EvalProjectMemberEntity> pageResult = evalProjectMemberDomainService.page(domainQuery);
return PageResponse.of( List<EvalProjectMemberCO> evalProjectMemberCOS = evalProjectMemberCmdConvertor.convertEListToCOList(pageResult.getRecords());
evalProjectMemberCmdConvertor.convertEListToCOList(pageResult.getRecords()), for (EvalProjectMemberCO evalProjectMemberCO : evalProjectMemberCOS) {
evalProjectMemberCO.setRole(ProjectRoleEnum.froms(evalProjectMemberCO.getRole()));
}
return PageResponse.of(evalProjectMemberCOS
,
pageResult.getTotal()); pageResult.getTotal());
} }
} }

View File

@ -10,6 +10,7 @@ import org.qinan.safetyeval.client.dto.PageResponse;
import org.qinan.safetyeval.client.dto.SingleResponse; import org.qinan.safetyeval.client.dto.SingleResponse;
import org.qinan.safetyeval.client.dto.institution.EvalSurveyPageQuery; import org.qinan.safetyeval.client.dto.institution.EvalSurveyPageQuery;
import org.qinan.safetyeval.client.dto.institution.EvalSurveySaveCmd; import org.qinan.safetyeval.client.dto.institution.EvalSurveySaveCmd;
import org.qinan.safetyeval.domain.constant.ProjectRoleEnum;
import org.qinan.safetyeval.domain.entity.EvalProjectMemberEntity; import org.qinan.safetyeval.domain.entity.EvalProjectMemberEntity;
import org.qinan.safetyeval.domain.entity.EvalSurveyEntity; import org.qinan.safetyeval.domain.entity.EvalSurveyEntity;
import org.qinan.safetyeval.domain.exception.ErrorCode; import org.qinan.safetyeval.domain.exception.ErrorCode;
@ -106,6 +107,8 @@ public class EvalSurveyExecutor implements EvalSurveyApi {
return SingleResponse.success(null); return SingleResponse.success(null);
} }
List<EvalProjectMemberEntity> dbList = evalProjectMemberDOS.stream().map(evalProjectMemberDoConvertor::convertDoToE).collect(Collectors.toList()); List<EvalProjectMemberEntity> dbList = evalProjectMemberDOS.stream().map(evalProjectMemberDoConvertor::convertDoToE).collect(Collectors.toList());
return SingleResponse.success(evalProjectMemberCmdConvertor.convertEListToCOList(dbList).get(0)); EvalProjectMemberCO evalProjectMemberCO = evalProjectMemberCmdConvertor.convertEListToCOList(dbList).get(0);
evalProjectMemberCO.setRole(ProjectRoleEnum.froms(evalProjectMemberCO.getRole()));
return SingleResponse.success(evalProjectMemberCO);
} }
} }

View File

@ -104,4 +104,7 @@ public class EvalProjectCO {
@ApiModelProperty("app项目勘察类型: 0-待勘察, 1-已完成") @ApiModelProperty("app项目勘察类型: 0-待勘察, 1-已完成")
private int surveyType; private int surveyType;
@ApiModelProperty("角色")
private String role;
} }

View File

@ -4,6 +4,7 @@ import cn.hutool.json.JSONUtil;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Getter; import lombok.Getter;
import java.util.ArrayList;
import java.util.List; import java.util.List;
/** /**
@ -54,6 +55,16 @@ public enum ProjectRoleEnum {
return sb.toString(); return sb.toString();
} }
public static List<String> froms(List<String> vals) {
List<String> strings = new ArrayList<>();
for (ProjectRoleEnum stage : values()) {
if (vals.contains(stage.val)) {
strings.add(stage.mas);
}
}
return strings;
}
public static List<String> jsonToList(String json) { public static List<String> jsonToList(String json) {
return json == null ? null : JSONUtil.toList(json, String.class); return json == null ? null : JSONUtil.toList(json, String.class);
} }