瀏覽代碼

更改bug

shiyue 1 年之前
父節點
當前提交
e2f519a502

+ 11 - 3
energy-manage-service/src/main/java/com/energy/manage/service/service/windenginegroup/impl/WindEngineGroupServiceImpl.java

@@ -11,6 +11,7 @@ import com.energy.manage.common.enums.DeleteStatusEnum;
 import com.energy.manage.common.enums.IdPrefixEnum;
 import com.energy.manage.common.po.windenginegroup.WindEngineGroupPO;
 import com.energy.manage.common.po.windenginemill.WindEngineMillPO;
+import com.energy.manage.common.po.windfield.WindFieldPO;
 import com.energy.manage.common.reponse.ResultResp;
 import com.energy.manage.common.util.IdGeneratorUtil;
 import com.energy.manage.service.domain.dto.windenginegroup.*;
@@ -122,9 +123,16 @@ public class WindEngineGroupServiceImpl extends BaseServiceImpl<WindEngineGroupP
             }
         }
 
-
-
-
+        // 数据校验是否有重名风机编号
+        List<String> engineNamees = windFieldExceVoList.stream().map(item -> item.getEngineName()).collect(Collectors.toList());
+        Example queryExample = new Example(WindEngineGroupPO.class);
+        Example.Criteria criteria = queryExample.createCriteria();
+        criteria.andIn("engineName", engineNamees);
+        criteria.andEqualTo("delState", DeleteStatusEnum.NODELETE.getCode());
+        int count = windEngineGroupMapper.selectCountByExample(queryExample);
+        if (count > 0) {
+            return ResultResp.FAIL("当前项目公司中有已经存在的风场,请核查导入数据!");
+        }
 
         WindEngineGroupPO windEngineGroupPO = null;
         List<WindEngineGroupPO> list = Lists.newArrayList();