From 8b43be03454bb282b7c32e485ab5edaae3e0db6c Mon Sep 17 00:00:00 2001 From: hzj <826100833@qq.com> Date: Wed, 24 Jan 2024 13:27:46 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=9B=BD=E7=BD=91=E4=B8=8A?= =?UTF-8?q?=E9=80=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mysql/send/impl/PqTypicalSourceCreatePOServiceImpl.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/send/impl/PqTypicalSourceCreatePOServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/send/impl/PqTypicalSourceCreatePOServiceImpl.java index a32cd80f4..312aaf386 100644 --- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/send/impl/PqTypicalSourceCreatePOServiceImpl.java +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/send/impl/PqTypicalSourceCreatePOServiceImpl.java @@ -136,15 +136,17 @@ public class PqTypicalSourceCreatePOServiceImpl extends ServiceImpl idList = tractionstation_dict.stream().map(SysDicTreePO::getId).collect(Collectors.toList()); tempList = monitorList.stream().filter(tempmonitor -> idList.contains(tempmonitor.getObjType())).collect(Collectors.toList()); + pqTypicalSourceCreatePO.setIndustryType("99"); } else if (temp.equals(DicDataEnum.WINDFARM_USER.getCode())) { List idList = windfarm_user_dict.stream().map(SysDicTreePO::getId).collect(Collectors.toList()); tempList = monitorList.stream().filter(tempmonitor -> idList.contains(tempmonitor.getObjType())).collect(Collectors.toList()); + pqTypicalSourceCreatePO.setIndustryType("99"); }else if(temp.equals(DicDataEnum.PHOTOVOLTAICSIT_EUSERS.getCode())) { List idList = photovoltaicsit_eusers_dict.stream().map(SysDicTreePO::getId).collect(Collectors.toList()); tempList = monitorList.stream().filter(tempmonitor -> idList.contains(tempmonitor.getObjType())).collect(Collectors.toList()); - + pqTypicalSourceCreatePO.setIndustryType("99"); }else if(temp.equals(DicDataEnum.OTHER_INTERFERENCESOURCE_USERS.getCode())) { List idList = other_interferencesource_users_dict.stream().map(SysDicTreePO::getId).collect(Collectors.toList()); tempList = monitorList.stream().filter(tempmonitor -> idList.contains(tempmonitor.getObjType())).collect(Collectors.toList());