Commit 2c85e672 by Ren Ping

feat:更改BEAN_PEA_ENGINEER_CHANGE egineers 为 engineers

1 parent 8c0098c0
...@@ -45,7 +45,7 @@ public class Rescheduled { ...@@ -45,7 +45,7 @@ public class Rescheduled {
/** /**
* 改约发起人工号 * 改约发起人工号
*/ */
@NotBlank //@NotBlank
private String initiatorOfRescheduling; private String initiatorOfRescheduling;
/** /**
......
...@@ -36,7 +36,7 @@ public class EngineerParamDTO { ...@@ -36,7 +36,7 @@ public class EngineerParamDTO {
* 同步工程师列表 * 同步工程师列表
*/ */
@NotNull @NotNull
private List<Engineer> egineers; private List<Engineer> engineers;
} }
/** /**
......
...@@ -120,13 +120,13 @@ public class BeanKafkaConsumer { ...@@ -120,13 +120,13 @@ public class BeanKafkaConsumer {
try { try {
EngineerParamDTO.Request request = nodeEngineerInfo.get(); EngineerParamDTO.Request request = nodeEngineerInfo.get();
AssertUtil.isNotEmpty(request.getGroupId(), "网点/分站编码不能为空"); AssertUtil.isNotEmpty(request.getGroupId(), "网点/分站编码不能为空");
AssertUtil.isNotEmpty(request.getEgineers(), "工程师列表不能为空"); AssertUtil.isNotEmpty(request.getEngineers(), "工程师列表不能为空");
//网点ID //网点ID
final String targetGroupId = request.getGroupId(); final String targetGroupId = request.getGroupId();
//fixme 是否需要校验网点id是否存在存疑 //fixme 是否需要校验网点id是否存在存疑
//存在则获取工程师信息 最后新增 //存在则获取工程师信息 最后新增
List<EngineerParamDTO.Engineer> engineers = request.getEgineers(); List<EngineerParamDTO.Engineer> engineers = request.getEngineers();
//组装工程师信息 //组装工程师信息
List<EngineerInfoEntity> needSaveEngineer = engineers.stream() List<EngineerInfoEntity> needSaveEngineer = engineers.stream()
.map(t -> getEngineerInfoEntity(targetGroupId, t)).collect(Collectors.toList()); .map(t -> getEngineerInfoEntity(targetGroupId, t)).collect(Collectors.toList());
......
Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!