diff --git a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/DataSetFeignClient.java b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/DataSetFeignClient.java index 874e4c8..8f2774c 100644 --- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/DataSetFeignClient.java +++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/DataSetFeignClient.java @@ -24,4 +24,7 @@ public interface DataSetFeignClient { @PostMapping("/getDataSet") HttpResult> getDataSet(@RequestParam("modelId") String modelId,@RequestParam("clDev") Integer clDev); + @PostMapping("/getModuleDataSet") + HttpResult> getModuleDataSet(@RequestParam("modelId") String modelId); + } diff --git a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/EquipmentFeignClient.java b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/EquipmentFeignClient.java index 9099693..ec80c1d 100644 --- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/EquipmentFeignClient.java +++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/EquipmentFeignClient.java @@ -26,5 +26,5 @@ public interface EquipmentFeignClient { HttpResult> queryDeviceById(@RequestParam("ids") List ids); @PostMapping("/updateSoftInfoBynDid") - HttpResult updateSoftInfoBynDid(@RequestParam("nDId") String nDid,@RequestParam("id") String id); + HttpResult updateSoftInfoBynDid(@RequestParam("nDId") String nDid, @RequestParam("id") String id, @RequestParam("module") Integer module); } diff --git a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/fallback/DataSetFeignClientFallbackFactory.java b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/fallback/DataSetFeignClientFallbackFactory.java index ffcf106..1d1b3bf 100644 --- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/fallback/DataSetFeignClientFallbackFactory.java +++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/fallback/DataSetFeignClientFallbackFactory.java @@ -44,6 +44,12 @@ public class DataSetFeignClientFallbackFactory implements FallbackFactory> getModuleDataSet(String modelId) { + log.error("{}异常,降级处理,异常为:{}","获取子模块数据集",cause.toString()); + throw new BusinessException(finalExceptionEnum); + } }; } } diff --git a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/fallback/EquipmentFeignClientFallbackFactory.java b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/fallback/EquipmentFeignClientFallbackFactory.java index 270d48d..90be12f 100644 --- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/fallback/EquipmentFeignClientFallbackFactory.java +++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/fallback/EquipmentFeignClientFallbackFactory.java @@ -48,7 +48,7 @@ public class EquipmentFeignClientFallbackFactory implements FallbackFactory updateSoftInfoBynDid(String nDid, String id) { + public HttpResult updateSoftInfoBynDid(String nDid, String id, Integer module) { log.error("{}异常,降级处理,异常为:{}","根据网关id调整软件信息",cause.toString()); throw new BusinessException(finalExceptionEnum); } diff --git a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsEquipmentDeliveryAddParm.java b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsEquipmentDeliveryAddParm.java index d578fe8..95679dd 100644 --- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsEquipmentDeliveryAddParm.java +++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsEquipmentDeliveryAddParm.java @@ -119,4 +119,10 @@ public class CsEquipmentDeliveryAddParm{ @ApiModelProperty(value="软件信息") private String softinfoId; + /** + * 模块个数 + */ + @ApiModelProperty(value="模块个数") + private Integer modelNumber; + } \ No newline at end of file diff --git a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsEquipmentDeliveryAuditParm.java b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsEquipmentDeliveryAuditParm.java index d933f62..34a66d9 100644 --- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsEquipmentDeliveryAuditParm.java +++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsEquipmentDeliveryAuditParm.java @@ -123,4 +123,9 @@ public class CsEquipmentDeliveryAuditParm { @ApiModelProperty(value="软件信息") private String softinfoId; + /** + * 模块个数 + */ + @ApiModelProperty(value="模块个数") + private Integer modelNumber; } \ No newline at end of file diff --git a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/po/CsEquipmentDeliveryPO.java b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/po/CsEquipmentDeliveryPO.java index 24f761f..2c800eb 100644 --- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/po/CsEquipmentDeliveryPO.java +++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/po/CsEquipmentDeliveryPO.java @@ -132,5 +132,11 @@ public class CsEquipmentDeliveryPO extends BaseEntity { @TableField(value = "softinfo_id") private String softinfoId; + /** + * 模块个数 + */ + @TableField(value = "module_number") + private Integer moduleNumber; + } \ No newline at end of file diff --git a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/po/CsLinePO.java b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/po/CsLinePO.java index 92bcab0..bcff67c 100644 --- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/po/CsLinePO.java +++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/po/CsLinePO.java @@ -72,5 +72,13 @@ public class CsLinePO extends BaseEntity { @TableField(value = "conType") private Integer conType; + /** + * 逻辑子设备id(与模板对应) + * 治理监测点 0 + * 负载监测点 1 + * 电网监测点 2 + */ + @TableField(value = "clDid") + private Integer clDid; } \ No newline at end of file diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/equipment/CsDataSetController.java b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/equipment/CsDataSetController.java index a351c99..99dcb04 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/equipment/CsDataSetController.java +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/equipment/CsDataSetController.java @@ -66,5 +66,15 @@ public class CsDataSetController extends BaseController { return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, list, methodDescribe); } + @OperateInfo(info = LogEnum.BUSINESS_COMMON) + @PostMapping("/getModuleDataSet") + @ApiOperation("获取子模块数据集") + @ApiImplicitParam(name = "modelId", value = "模板id", required = true) + public HttpResult> getModuleDataSet(@RequestParam("modelId") String modelId){ + String methodDescribe = getMethodDescribe("getModuleDataSet"); + List list = csDataSetService.getModuleDataSet(modelId); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, list, methodDescribe); + } + } diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/equipment/EquipmentDeliveryController.java b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/equipment/EquipmentDeliveryController.java index ce40e34..2cb71df 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/equipment/EquipmentDeliveryController.java +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/equipment/EquipmentDeliveryController.java @@ -170,11 +170,12 @@ public class EquipmentDeliveryController extends BaseController { @ApiOperation("根据网关id调整软件信息") @ApiImplicitParams({ @ApiImplicitParam(name = "nDId", value = "网关id", required = true), - @ApiImplicitParam(name = "id", value = "软件信息id", required = true) + @ApiImplicitParam(name = "id", value = "软件信息id", required = true), + @ApiImplicitParam(name = "module", value = "模块个数", required = true) }) - public HttpResult updateSoftInfoBynDid(@RequestParam("nDId") String nDid,@RequestParam("id") String id){ + public HttpResult updateSoftInfoBynDid(@RequestParam("nDId") String nDid,@RequestParam("id") String id,@RequestParam("module") Integer module){ String methodDescribe = getMethodDescribe("updateSoftInfoBynDid"); - csEquipmentDeliveryService.updateSoftInfoBynDid(nDid,id); + csEquipmentDeliveryService.updateSoftInfoBynDid(nDid,id,module); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); } diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/mapper/mapping/CsDataArrayMapper.xml b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/mapper/mapping/CsDataArrayMapper.xml index f567d8a..d2b9dcf 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/mapper/mapping/CsDataArrayMapper.xml +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/mapper/mapping/CsDataArrayMapper.xml @@ -106,5 +106,6 @@ and t1.did = #{param.did} and t3.cl_dev = #{param.cldId} and t4.stat_method = #{param.statMethod} + order by t4.sort \ No newline at end of file diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/CsEquipmentDeliveryService.java b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/CsEquipmentDeliveryService.java index 81f2874..9acd585 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/CsEquipmentDeliveryService.java +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/CsEquipmentDeliveryService.java @@ -81,5 +81,5 @@ public interface CsEquipmentDeliveryService extends IService { * @return */ List getDataSet(String modelId,Integer clDev); + + /** + * 获取子模块数据集 + * @param modelId 模板id + * @return + */ + List getModuleDataSet(String modelId); } diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsDataSetServiceImpl.java b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsDataSetServiceImpl.java index fb277d6..2b222b3 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsDataSetServiceImpl.java +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsDataSetServiceImpl.java @@ -36,4 +36,9 @@ public class CsDataSetServiceImpl extends ServiceImpl getModuleDataSet(String modelId) { + return this.lambdaQuery().eq(CsDataSet::getPid,modelId).ne(CsDataSet::getClDev,0).list(); + } + } diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsEquipmentDeliveryServiceImpl.java b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsEquipmentDeliveryServiceImpl.java index d365195..34e1328 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsEquipmentDeliveryServiceImpl.java +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsEquipmentDeliveryServiceImpl.java @@ -255,9 +255,9 @@ public class CsEquipmentDeliveryServiceImpl extends ServiceImpl lambdaUpdateWrapper = new LambdaUpdateWrapper<>(); - lambdaUpdateWrapper.set(CsEquipmentDeliveryPO::getSoftinfoId,id).eq(CsEquipmentDeliveryPO::getNdid,nDid); + lambdaUpdateWrapper.set(CsEquipmentDeliveryPO::getSoftinfoId,id).set(CsEquipmentDeliveryPO::getModuleNumber,module).eq(CsEquipmentDeliveryPO::getNdid,nDid); this.update(lambdaUpdateWrapper); }