diff --git a/ruoyi-admin/src/main/java/com/ruoyi/tc/mapper/AssetBasicNetWorkCpMapper.java b/ruoyi-admin/src/main/java/com/ruoyi/tc/mapper/AssetBasicNetWorkCpMapper.java index 011f5c3..ce60bd5 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/tc/mapper/AssetBasicNetWorkCpMapper.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/tc/mapper/AssetBasicNetWorkCpMapper.java @@ -17,13 +17,14 @@ import java.util.List; public interface AssetBasicNetWorkCpMapper extends BaseMapper { /** - * 根据任务id资产供应链原有id + * 根据资产id资产供应链原有id * - * @param taskId 任务id + * @param id 资产id * @return */ - @Select("select a.* from asset_basic_network a left join asset_current_cp b on a.asset_id =b.id where b.task_id=#{taskId} ") - List findByassetId(String taskId); + // @Select("select a.* from asset_basic_network a left join asset_current_cp b on a.asset_id =b.id where b.task_id=#{taskId} ") + @Select("select * from asset_basic_network where asset_id=#{id} ") + List findByassetId(@Param("id") Long id); diff --git a/ruoyi-admin/src/main/java/com/ruoyi/tc/mapper/AssetBusinessFormCpMapper.java b/ruoyi-admin/src/main/java/com/ruoyi/tc/mapper/AssetBusinessFormCpMapper.java index e4d09e3..63e485e 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/tc/mapper/AssetBusinessFormCpMapper.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/tc/mapper/AssetBusinessFormCpMapper.java @@ -23,8 +23,9 @@ public interface AssetBusinessFormCpMapper extends BaseMapper findByassetId(String taskId); +// @Select("select a.* from asset_business_form a left join asset_current_cp b on a.asset_id =b.id where b.task_id=#{taskId} ") + @Select("select * from asset_business_form where asset_id =#{id}") + List findByassetId(@Param("id") Long id); diff --git a/ruoyi-admin/src/main/java/com/ruoyi/tc/mapper/AssetSupplyChainCpMapper.java b/ruoyi-admin/src/main/java/com/ruoyi/tc/mapper/AssetSupplyChainCpMapper.java index 800f2a8..7e16e0a 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/tc/mapper/AssetSupplyChainCpMapper.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/tc/mapper/AssetSupplyChainCpMapper.java @@ -18,13 +18,14 @@ public interface AssetSupplyChainCpMapper extends BaseMapper findByassetId(String taskId); +// @Select("select a.* from asset_supply_chain a left join asset_current_cp b on a.asset_id =b.id where b.task_id=#{taskId}") + @Select("select * from asset_supply_chain where asset_id=#{id}") + List findByassetId(@Param("id") Long id); diff --git a/ruoyi-admin/src/main/java/com/ruoyi/tc/mapper/UnitOtherConcatCpMapper.java b/ruoyi-admin/src/main/java/com/ruoyi/tc/mapper/UnitOtherConcatCpMapper.java index d1d304c..61154a1 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/tc/mapper/UnitOtherConcatCpMapper.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/tc/mapper/UnitOtherConcatCpMapper.java @@ -17,13 +17,14 @@ public interface UnitOtherConcatCpMapper extends BaseMapper /** - * 根据任务id资产供应链原有id + * 根据资产id资产供应链原有id * - * @param taskId 资产id + * @param id 资产id * @return */ - @Select("select a.* from unit_other_contact a left join asset_current_cp b on a.asset_id =b.id where b.task_id =#{taskId}") - List findByassetId( String taskId); + //@Select("select a.* from unit_other_contact a left join asset_current_cp b on a.asset_id =b.id where b.task_id =#{taskId}") + @Select("select * from unit_other_contact where asset_id=#{id}") + List findByassetId(@Param("id") Long id); /** @@ -51,5 +52,5 @@ public interface UnitOtherConcatCpMapper extends BaseMapper * @return */ @Select("select * from unit_other_contact_cp where asset_id=#{assetId} and task_id =#{taskId}") - List findByTaskId(@Param("assetId") int assetId, @Param("taskId")int taskId); + List findByTaskId(@Param("assetId") int assetId, @Param("taskId") int taskId); } diff --git a/ruoyi-admin/src/main/java/com/ruoyi/tc/service/AssetBasicNetworkCpService.java b/ruoyi-admin/src/main/java/com/ruoyi/tc/service/AssetBasicNetworkCpService.java index 91c07d5..8dacbf2 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/tc/service/AssetBasicNetworkCpService.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/tc/service/AssetBasicNetworkCpService.java @@ -14,12 +14,12 @@ import java.util.List; public interface AssetBasicNetworkCpService extends IService { /** - * 根据任务id资产供应链原有id + * 根据资产id资产供应链原有id * - * @param taskId 任务id + * @param id 资产id * @return */ - List findByassetId(String taskId); + List findByassetId(Long id); /** diff --git a/ruoyi-admin/src/main/java/com/ruoyi/tc/service/AssetBusinessFormCpService.java b/ruoyi-admin/src/main/java/com/ruoyi/tc/service/AssetBusinessFormCpService.java index aeb697e..7fb5d28 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/tc/service/AssetBusinessFormCpService.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/tc/service/AssetBusinessFormCpService.java @@ -14,12 +14,12 @@ import java.util.List; public interface AssetBusinessFormCpService extends IService { /** - * 根据任务id查询业务主表原有id + * 根据资产id查询业务主表原有id * - * @param taskId 任务id + * @param id 资产id * @return */ - List findByassetId(String taskId); + List findByassetId(Long id); /** diff --git a/ruoyi-admin/src/main/java/com/ruoyi/tc/service/AssetSupplyChainCpService.java b/ruoyi-admin/src/main/java/com/ruoyi/tc/service/AssetSupplyChainCpService.java index 0b812bb..69191e0 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/tc/service/AssetSupplyChainCpService.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/tc/service/AssetSupplyChainCpService.java @@ -14,12 +14,12 @@ import java.util.List; public interface AssetSupplyChainCpService extends IService { /** - * 根据任务id资产供应链原有id + * 根据资产id资产供应链原有id * - * @param taskId 任务id + * @param id 资产id * @return */ - List findByassetId(String taskId); + List findByassetId(Long id); /** diff --git a/ruoyi-admin/src/main/java/com/ruoyi/tc/service/UnitOtherConcatCpService.java b/ruoyi-admin/src/main/java/com/ruoyi/tc/service/UnitOtherConcatCpService.java index 9628679..4b894cc 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/tc/service/UnitOtherConcatCpService.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/tc/service/UnitOtherConcatCpService.java @@ -16,10 +16,10 @@ public interface UnitOtherConcatCpService extends IService /** * 根据资产id资产供应链原有id * - * @param taskId 任务id + * @param id 资产id * @return */ - List findByassetId(String taskId); + List findByassetId(Long id); /** diff --git a/ruoyi-admin/src/main/java/com/ruoyi/tc/service/impl/AssetBasicNetworkCpServiceImpl.java b/ruoyi-admin/src/main/java/com/ruoyi/tc/service/impl/AssetBasicNetworkCpServiceImpl.java index fe614ef..3c4bda8 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/tc/service/impl/AssetBasicNetworkCpServiceImpl.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/tc/service/impl/AssetBasicNetworkCpServiceImpl.java @@ -22,8 +22,8 @@ public class AssetBasicNetworkCpServiceImpl extends ServiceImpl findByassetId(String taskId) { - return assetBasicNetWorkCpMapper.findByassetId(taskId); + public List findByassetId(Long id) { + return assetBasicNetWorkCpMapper.findByassetId(id); } @Override diff --git a/ruoyi-admin/src/main/java/com/ruoyi/tc/service/impl/AssetBusinessFormCpServiceImpl.java b/ruoyi-admin/src/main/java/com/ruoyi/tc/service/impl/AssetBusinessFormCpServiceImpl.java index e803a15..353e17a 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/tc/service/impl/AssetBusinessFormCpServiceImpl.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/tc/service/impl/AssetBusinessFormCpServiceImpl.java @@ -22,8 +22,8 @@ public class AssetBusinessFormCpServiceImpl extends ServiceImpl findByassetId(String taskId) { - return assetBusinessFormCpMapper.findByassetId(taskId); + public List findByassetId(Long id) { + return assetBusinessFormCpMapper.findByassetId(id); } @Override diff --git a/ruoyi-admin/src/main/java/com/ruoyi/tc/service/impl/AssetSupplyChainCpServiceImpl.java b/ruoyi-admin/src/main/java/com/ruoyi/tc/service/impl/AssetSupplyChainCpServiceImpl.java index b79f6ca..7c23290 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/tc/service/impl/AssetSupplyChainCpServiceImpl.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/tc/service/impl/AssetSupplyChainCpServiceImpl.java @@ -22,8 +22,8 @@ public class AssetSupplyChainCpServiceImpl extends ServiceImpl findByassetId(String taskId) { - return assetSupplyChainCpMapper.findByassetId(taskId); + public List findByassetId(Long id) { + return assetSupplyChainCpMapper.findByassetId(id); } @Override diff --git a/ruoyi-admin/src/main/java/com/ruoyi/tc/service/impl/AssetTaskServiceImpl.java b/ruoyi-admin/src/main/java/com/ruoyi/tc/service/impl/AssetTaskServiceImpl.java index dd1b651..b78e150 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/tc/service/impl/AssetTaskServiceImpl.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/tc/service/impl/AssetTaskServiceImpl.java @@ -192,7 +192,7 @@ public class AssetTaskServiceImpl extends ServiceImpl list = assetTaskDao.findByDwmcAssetCurrent(part); list.forEach(assetCurrentResponse -> { assetCurrentResponse.setTaskId(id); - if (assetCurrentResponse.getXtzt()!=null && assetCurrentResponse.getXtzt().equals("5")) { + if (assetCurrentResponse.getXtzt() != null && assetCurrentResponse.getXtzt().equals("5")) { assetCurrentResponse.setStatus(5); assetCurrentResponse.setBfyy(null); assetCurrentResponse.setBtgyy(null); @@ -203,21 +203,43 @@ public class AssetTaskServiceImpl extends ServiceImpl bussList = assetBusinessFormCpService.findByassetId(assetCurrentResponse.getId()); + bussList.stream() + .forEach(assetBusinessFormCp -> { + assetBusinessFormCp.setBusinessId(null); + assetBusinessFormCp.setTaskId(id); + }); + assetBusinessFormCpService.saveBatch(bussList); + //新增供应 + List supplyChainList = assetSupplyChainCpService.findByassetId(assetCurrentResponse.getId()); + supplyChainList.stream() + .forEach(assetSupplyChainCpPo ->{ + assetSupplyChainCpPo.setSupplyId(null); + assetSupplyChainCpPo.setTaskId(id); + } ); + assetSupplyChainCpService.saveBatch(supplyChainList); + //新增基础网络 + List BasicNetworkCpList = assetBasicNetworkCpService.findByassetId(assetCurrentResponse.getId()); + BasicNetworkCpList.stream() + .forEach(assetBasicNetworkCpPo -> { + assetBasicNetworkCpPo.setNetworkId(null); + assetBasicNetworkCpPo.setTaskId(id); + }); + assetBasicNetworkCpService.saveBatch(BasicNetworkCpList); + //新增其他联系人 + List unitOtherConcatList = unitOtherConcatCpService.findByassetId(assetCurrentResponse.getId()); + unitOtherConcatList.stream() + .forEach(unitOtherConcatCpPo -> { + unitOtherConcatCpPo.setConcatId(null); + unitOtherConcatCpPo.setTaskId(id); + }); + unitOtherConcatCpService.saveBatch(unitOtherConcatList); }); assetCurrentCpService.saveBatch(list); - //新增新监管业务形态 - List bussList = assetBusinessFormCpService.findByassetId(assetTask.getTaskId()); - assetBusinessFormCpService.saveBatch(bussList); - //新增供应 - List supplyChainList = assetSupplyChainCpService.findByassetId(assetTask.getTaskId()); - assetSupplyChainCpService.saveBatch(supplyChainList); - //新增基础网络 - List BasicNetworkCpList = assetBasicNetworkCpService.findByassetId(assetTask.getTaskId()); - assetBasicNetworkCpService.saveBatch(BasicNetworkCpList); - //新增其他联系人 - List unitOtherConcatList = unitOtherConcatCpService.findByassetId(assetTask.getTaskId()); - unitOtherConcatCpService.saveBatch(unitOtherConcatList); + } } else if (assetPart.equals("1")) { //遍历小程序资产单位 @@ -234,7 +256,7 @@ public class AssetTaskServiceImpl extends ServiceImpl a2 = new ArrayList<>(); - if(byId.getGlIp()!=null&& !byId.getGlIp().isEmpty()){ + if (byId.getGlIp() != null && !byId.getGlIp().isEmpty()) { for (Object o : JSONArray.parseArray(byId.getGlIp())) { Acomma acomma = new Acomma(); JSONObject jsonObject = JSONObject.parseObject(o.toString()); acomma.setKey(jsonObject.get("key").toString()); acomma.setIpType(jsonObject.get("ipType").toString()); - acomma.setPort(jsonObject.get("port").toString()); + Object portValue = jsonObject.get("port"); + if (portValue != null && !portValue.toString().isEmpty()) { + acomma.setPort(portValue.toString()); + } a2.add(acomma); } byId.setGlIpList(a2); - }else { + } else { byId.setGlIpList(new ArrayList<>()); } @@ -765,7 +790,7 @@ public class AssetTaskServiceImpl extends ServiceImpl { if (!Objects.equals(x.getKey(), "") && x.getKey() != null) { @@ -778,7 +803,7 @@ public class AssetTaskServiceImpl extends ServiceImpl networksCpPoList = req.getAssetCurrentCpPo().getJcwlList().stream().map(cpPo -> { AssetBasicNetwork assetBasicNetwork = new AssetBasicNetwork(); BeanUtils.copyProperties(cpPo, assetBasicNetwork); // 复制属性 diff --git a/ruoyi-admin/src/main/java/com/ruoyi/tc/service/impl/UnitOtherConcatCpServiceImpl.java b/ruoyi-admin/src/main/java/com/ruoyi/tc/service/impl/UnitOtherConcatCpServiceImpl.java index 4b0151d..0c7ff90 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/tc/service/impl/UnitOtherConcatCpServiceImpl.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/tc/service/impl/UnitOtherConcatCpServiceImpl.java @@ -21,8 +21,8 @@ public class UnitOtherConcatCpServiceImpl extends ServiceImpl findByassetId(String taskId) { - return unitOtherConcatCpMapper.findByassetId(taskId); + public List findByassetId(Long id) { + return unitOtherConcatCpMapper.findByassetId(id); } @Override