From 332ea634ad0939eea407d8fab25980c09e6e5500 Mon Sep 17 00:00:00 2001 From: xuyang <748613696@qq.com> Date: Fri, 13 Oct 2023 10:50:38 +0800 Subject: [PATCH] =?UTF-8?q?=E8=AE=BE=E5=A4=87=E6=B3=A8=E5=86=8C=E5=8A=9F?= =?UTF-8?q?=E8=83=BD=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../njcn/csdevice/api/CsLineFeignClient.java | 4 ++ .../csdevice/api/DevCapacityFeignClient.java | 22 +++++++ .../csdevice/api/EquipmentFeignClient.java | 14 +++++ .../fallback/CsLineClientFallbackFactory.java | 7 +++ .../DevCapacityClientFallbackFactory.java | 38 ++++++++++++ .../EquipmentFeignClientFallbackFactory.java | 12 ++++ .../njcn/csdevice/pojo/param/CsLineParam.java | 41 +++++++++++++ .../njcn/csdevice/pojo/param/CsLineParm.java | 58 ------------------- .../equipment/CsDevCapacityController.java | 13 ++++- .../EquipmentDeliveryController.java | 30 ++++++++++ .../controller/line/CslineController.java | 13 +++++ .../service/CsDevCapacityPOService.java | 15 ++++- .../service/CsEquipmentDeliveryService.java | 14 +++++ .../csdevice/service/CsLinePOService.java | 7 +++ .../impl/CsDevCapacityPOServiceImpl.java | 5 ++ .../impl/CsEquipmentDeliveryServiceImpl.java | 18 ++++++ .../service/impl/CsLinePOServiceImpl.java | 14 +++++ 17 files changed, 264 insertions(+), 61 deletions(-) create mode 100644 cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/DevCapacityFeignClient.java create mode 100644 cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/fallback/DevCapacityClientFallbackFactory.java create mode 100644 cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsLineParam.java delete mode 100644 cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsLineParm.java diff --git a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/CsLineFeignClient.java b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/CsLineFeignClient.java index d1e1725..92326a7 100644 --- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/CsLineFeignClient.java +++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/CsLineFeignClient.java @@ -3,6 +3,7 @@ package com.njcn.csdevice.api; import com.njcn.common.pojo.constant.ServerInfo; import com.njcn.common.pojo.response.HttpResult; import com.njcn.csdevice.api.fallback.CsLineClientFallbackFactory; +import com.njcn.csdevice.pojo.param.CsLineParam; import com.njcn.csdevice.pojo.po.CsLinePO; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.web.bind.annotation.PostMapping; @@ -32,4 +33,7 @@ public interface CsLineFeignClient { @PostMapping("/getPositionById") HttpResult getPositionById(@RequestParam("id") String id); + + @PostMapping("/updateLine") + HttpResult updateLine(@RequestBody CsLineParam csLineParam); } diff --git a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/DevCapacityFeignClient.java b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/DevCapacityFeignClient.java new file mode 100644 index 0000000..c2767d9 --- /dev/null +++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/DevCapacityFeignClient.java @@ -0,0 +1,22 @@ +package com.njcn.csdevice.api; + +import com.njcn.common.pojo.constant.ServerInfo; +import com.njcn.common.pojo.response.HttpResult; +import com.njcn.csdevice.api.fallback.DevCapacityClientFallbackFactory; +import com.njcn.csdevice.pojo.po.CsDevCapacityPO; +import org.springframework.cloud.openfeign.FeignClient; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; + +import java.util.List; + +/** + * @author xy + */ +@FeignClient(value = ServerInfo.CS_DEVICE_BOOT, path = "/capacity", fallbackFactory = DevCapacityClientFallbackFactory.class,contextId = "capacity") +public interface DevCapacityFeignClient { + + @PostMapping("/addList") + HttpResult> addList(@RequestBody List list); + +} 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 9021996..dc29dce 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 @@ -36,4 +36,18 @@ public interface EquipmentFeignClient { */ @PostMapping("/findDevByNDid") HttpResult findDevByNDid(@RequestParam("nDid") String nDid); + + /** + * 根据nDid更新软件信息 + * @return + */ + @PostMapping("/updateSoftInfo") + HttpResult updateSoftInfo(@RequestParam("nDid") String nDid,@RequestParam("id") String id); + + /** + * 根据nDid更新模块信息 + * @return + */ + @PostMapping("/updateModuleNumber") + HttpResult updateModuleNumber(@RequestParam("nDid") String nDid,@RequestParam("number") Integer number); } diff --git a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/fallback/CsLineClientFallbackFactory.java b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/fallback/CsLineClientFallbackFactory.java index ec5cb7c..07a7465 100644 --- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/fallback/CsLineClientFallbackFactory.java +++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/fallback/CsLineClientFallbackFactory.java @@ -4,6 +4,7 @@ import com.njcn.common.pojo.enums.response.CommonResponseEnum; import com.njcn.common.pojo.exception.BusinessException; import com.njcn.common.pojo.response.HttpResult; import com.njcn.csdevice.api.CsLineFeignClient; +import com.njcn.csdevice.pojo.param.CsLineParam; import com.njcn.csdevice.pojo.po.CsLinePO; import feign.hystrix.FallbackFactory; import lombok.extern.slf4j.Slf4j; @@ -56,6 +57,12 @@ public class CsLineClientFallbackFactory implements FallbackFactory updateLine(CsLineParam csLineParam) { + log.error("{}异常，降级处理，异常为：{}","更新监测点信息",cause.toString()); + throw new BusinessException(finalExceptionEnum); + } }; } } diff --git a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/fallback/DevCapacityClientFallbackFactory.java b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/fallback/DevCapacityClientFallbackFactory.java new file mode 100644 index 0000000..aecd916 --- /dev/null +++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/fallback/DevCapacityClientFallbackFactory.java @@ -0,0 +1,38 @@ +package com.njcn.csdevice.api.fallback; + +import com.njcn.common.pojo.enums.response.CommonResponseEnum; +import com.njcn.common.pojo.exception.BusinessException; +import com.njcn.common.pojo.response.HttpResult; +import com.njcn.csdevice.api.DevCapacityFeignClient; +import com.njcn.csdevice.pojo.po.CsDevCapacityPO; +import feign.hystrix.FallbackFactory; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +import java.util.List; + +/** + * @author xy + */ +@Slf4j +@Component +public class DevCapacityClientFallbackFactory implements FallbackFactory { + @Override + public DevCapacityFeignClient create(Throwable cause) { + //判断抛出异常是否为解码器抛出的业务异常 + Enum exceptionEnum = CommonResponseEnum.SERVICE_FALLBACK; + if (cause.getCause() instanceof BusinessException) { + BusinessException businessException = (BusinessException) cause.getCause(); + } + Enum finalExceptionEnum = exceptionEnum; + return new DevCapacityFeignClient() { + + @Override + public HttpResult> addList(List list) { + 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 45b1a5f..2649b58 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 @@ -59,6 +59,18 @@ public class EquipmentFeignClientFallbackFactory implements FallbackFactory updateSoftInfo(String nDid, String id) { + log.error("{}异常，降级处理，异常为：{}","更新设备软件信息",cause.toString()); + throw new BusinessException(finalExceptionEnum); + } + + @Override + public HttpResult updateModuleNumber(String nDid, Integer number) { + log.error("{}异常，降级处理，异常为：{}","更新设备模块个数",cause.toString()); + throw new BusinessException(finalExceptionEnum); + } }; } } diff --git a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsLineParam.java b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsLineParam.java new file mode 100644 index 0000000..6bb4a0e --- /dev/null +++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsLineParam.java @@ -0,0 +1,41 @@ +package com.njcn.csdevice.pojo.param; + +import com.njcn.db.bo.BaseEntity; +import lombok.Data; +import lombok.EqualsAndHashCode; + +/** + * + * Description: + * Date: 2023/5/18 14:01【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@EqualsAndHashCode(callSuper = true) +@Data +public class CsLineParam extends BaseEntity { + + private String lineId; + + /** + * 电压等级 + */ + private Double volGrade; + + /** + * PT变比 + */ + private Double ptRatio; + + /** + * CT变比 + */ + private Double ctRatio; + + /** + * 接线方式 + */ + private Integer conType; + +} \ No newline at end of file diff --git a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsLineParm.java b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsLineParm.java deleted file mode 100644 index 2607799..0000000 --- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsLineParm.java +++ /dev/null @@ -1,58 +0,0 @@ -package com.njcn.csdevice.pojo.param; - -import com.baomidou.mybatisplus.annotation.IdType; -import com.baomidou.mybatisplus.annotation.TableField; -import com.baomidou.mybatisplus.annotation.TableId; -import com.baomidou.mybatisplus.annotation.TableName; -import com.njcn.db.bo.BaseEntity; -import lombok.Data; - -import java.math.BigDecimal; - -/** - * - * Description: - * Date: 2023/5/18 14:01【需求编号】 - * - * @author clam - * @version V1.0.0 - */ -@Data -public class CsLineParm { - - private String topoId; - private String projectId; - - private String devId; - /** - * 监测点名称 - */ - private String name; - - /** - * 字典表：安装位置（负载侧,电网侧, 输出侧） - */ - private String position; - - /** - * 电压等级 - */ - private String volGrade; - - /** - * PT变比 - */ - private BigDecimal ptRatio; - - /** - * CT变比 - */ - private BigDecimal ctRatio; - - private Double lat; - private Double lng; - - - - -} \ No newline at end of file diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/equipment/CsDevCapacityController.java b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/equipment/CsDevCapacityController.java index 6d73a28..5aeb228 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/equipment/CsDevCapacityController.java +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/equipment/CsDevCapacityController.java @@ -6,7 +6,6 @@ import com.njcn.common.pojo.enums.response.CommonResponseEnum; import com.njcn.common.pojo.response.HttpResult; import com.njcn.common.utils.HttpResultUtil; import com.njcn.csdevice.pojo.po.CsDevCapacityPO; -import com.njcn.csdevice.pojo.po.CsDevModelPO; import com.njcn.csdevice.service.CsDevCapacityPOService; import com.njcn.web.controller.BaseController; import io.swagger.annotations.Api; @@ -16,6 +15,8 @@ import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.web.bind.annotation.*; +import java.util.List; + /** * Description: * 接口文档访问地址：http://serverIP:port/swagger-ui.html @@ -44,4 +45,14 @@ public class CsDevCapacityController extends BaseController { return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, limit, methodDescribe); } + @OperateInfo(info = LogEnum.BUSINESS_COMMON) + @PostMapping("/addList") + @ApiOperation("批量新增") + @ApiImplicitParam(name = "id", value = "设备id", required = true) + public HttpResult addList(@RequestBody List list){ + String methodDescribe = getMethodDescribe("addList"); + csDevCapacityPOService.addList(list); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, 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 c84190f..c154b55 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 @@ -31,6 +31,7 @@ import org.springframework.beans.BeanUtils; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; import org.springframework.web.multipart.MultipartFile; +import springfox.documentation.annotations.ApiIgnore; import javax.servlet.http.HttpServletResponse; import java.util.ArrayList; @@ -177,6 +178,7 @@ public class EquipmentDeliveryController extends BaseController { @ApiImplicitParam(name = "id", value = "软件信息id", required = true), @ApiImplicitParam(name = "module", value = "模块个数", required = true) }) + @Deprecated public HttpResult updateSoftInfoBynDid(@RequestParam("nDId") String nDid,@RequestParam("id") String id,@RequestParam("module") Integer module){ String methodDescribe = getMethodDescribe("updateSoftInfoBynDid"); csEquipmentDeliveryService.updateSoftInfoBynDid(nDid,id,module); @@ -237,5 +239,33 @@ public class EquipmentDeliveryController extends BaseController { return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); } + @OperateInfo(info = LogEnum.BUSINESS_COMMON) + @PostMapping("/updateSoftInfo") + @ApiOperation("更新设备软件信息") + @ApiImplicitParams({ + @ApiImplicitParam(name = "nDid", value = "网络设备码", required = true), + @ApiImplicitParam(name = "id", value = "软件信息id", required = true) + }) + @ApiIgnore + public HttpResult updateSoftInfo(@RequestParam("nDid") String nDid,@RequestParam("id") String id){ + String methodDescribe = getMethodDescribe("updateSoftInfo"); + csEquipmentDeliveryService.updateSoftInfo(nDid,id); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); + } + + @OperateInfo(info = LogEnum.BUSINESS_COMMON) + @PostMapping("/updateModuleNumber") + @ApiOperation("更新设备模块个数") + @ApiImplicitParams({ + @ApiImplicitParam(name = "nDid", value = "网络设备码", required = true), + @ApiImplicitParam(name = "number", value = "模块个数", required = true) + }) + @ApiIgnore + public HttpResult updateModuleNumber(@RequestParam("nDid") String nDid,@RequestParam("number") Integer number){ + String methodDescribe = getMethodDescribe("updateModuleNumber"); + csEquipmentDeliveryService.updateModuleNumber(nDid,number); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); + } + } diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/line/CslineController.java b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/line/CslineController.java index 48a0f57..c8bdaf4 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/line/CslineController.java +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/line/CslineController.java @@ -5,6 +5,7 @@ import com.njcn.common.pojo.enums.common.LogEnum; import com.njcn.common.pojo.enums.response.CommonResponseEnum; import com.njcn.common.pojo.response.HttpResult; import com.njcn.common.utils.HttpResultUtil; +import com.njcn.csdevice.pojo.param.CsLineParam; import com.njcn.csdevice.pojo.po.CsLinePO; import com.njcn.csdevice.service.CsLinePOService; import com.njcn.web.controller.BaseController; @@ -13,6 +14,7 @@ import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiOperation; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; +import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; import springfox.documentation.annotations.ApiIgnore; @@ -95,4 +97,15 @@ public class CslineController extends BaseController { return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, lineList, methodDescribe); } + @OperateInfo(info = LogEnum.BUSINESS_COMMON) + @PostMapping("/updateLine") + @ApiOperation("修改监测点信息") + @ApiImplicitParam(name = "csLineParam", value = "监测点信息", required = true) + @ApiIgnore + public HttpResult updateLine(@RequestBody @Validated CsLineParam csLineParam) { + String methodDescribe = getMethodDescribe("updateLine"); + csLinePOService.updateLine(csLineParam); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); + } + } diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/CsDevCapacityPOService.java b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/CsDevCapacityPOService.java index 4e8e0a9..d050936 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/CsDevCapacityPOService.java +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/CsDevCapacityPOService.java @@ -1,8 +1,11 @@ package com.njcn.csdevice.service; -import com.njcn.csdevice.pojo.po.CsDevCapacityPO; import com.baomidou.mybatisplus.extension.service.IService; - /** +import com.njcn.csdevice.pojo.po.CsDevCapacityPO; + +import java.util.List; + +/** * * Description: * Date: 2023/9/27 10:29【需求编号】 @@ -12,6 +15,14 @@ import com.baomidou.mybatisplus.extension.service.IService; */ public interface CsDevCapacityPOService extends IService{ + /** + * 批量新增数据 + * @param list + */ + void addList(List list); + Double getDevCapacity(String id); + + } 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 5583171..55f11e6 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 @@ -100,4 +100,18 @@ public interface CsEquipmentDeliveryService extends IService{ */ List findByNdid(String id); + /** + * 更新监测点信息 + * @param csLineParam + */ + void updateLine(CsLineParam csLineParam); + } diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsDevCapacityPOServiceImpl.java b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsDevCapacityPOServiceImpl.java index 56fe9f7..4d3e211 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsDevCapacityPOServiceImpl.java +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsDevCapacityPOServiceImpl.java @@ -36,6 +36,11 @@ public class CsDevCapacityPOServiceImpl extends ServiceImpl list) { + this.saveOrUpdateBatch(list); + } + @Override public Double getDevCapacity(String id) { List csLinePOS = csLinePOService.queryByDevId(id); 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 14e737b..06a56de 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 @@ -518,6 +518,24 @@ public class CsEquipmentDeliveryServiceImpl extends ServiceImpl lambdaUpdateWrapper = new LambdaUpdateWrapper<>(); + lambdaUpdateWrapper.eq(CsEquipmentDeliveryPO::getNdid,nDid) + .ne(CsEquipmentDeliveryPO::getRunStatus,0) + .set(CsEquipmentDeliveryPO::getSoftinfoId,id); + this.update(lambdaUpdateWrapper); + } + + @Override + public void updateModuleNumber(String nDid, Integer number) { + LambdaUpdateWrapper lambdaUpdateWrapper = new LambdaUpdateWrapper<>(); + lambdaUpdateWrapper.eq(CsEquipmentDeliveryPO::getNdid,nDid) + .ne(CsEquipmentDeliveryPO::getRunStatus,0) + .set(CsEquipmentDeliveryPO::getModuleNumber,number); + this.update(lambdaUpdateWrapper); + } + /** * 根据ndid生成二维码 * @param ndid diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsLinePOServiceImpl.java b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsLinePOServiceImpl.java index 5418418..c7943a3 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsLinePOServiceImpl.java +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsLinePOServiceImpl.java @@ -2,9 +2,11 @@ package com.njcn.csdevice.service.impl; import cn.hutool.core.collection.CollectionUtil; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.njcn.csdevice.mapper.CsLedgerMapper; import com.njcn.csdevice.mapper.CsLinePOMapper; +import com.njcn.csdevice.pojo.param.CsLineParam; import com.njcn.csdevice.pojo.po.CsLedger; import com.njcn.csdevice.pojo.po.CsLinePO; import com.njcn.csdevice.service.CsLinePOService; @@ -57,6 +59,18 @@ public class CsLinePOServiceImpl extends ServiceImpl i return this.baseMapper.findByNdid(id); } + @Override + public void updateLine(CsLineParam csLineParam) { + LambdaUpdateWrapper lambdaUpdateWrapper = new LambdaUpdateWrapper<>(); + lambdaUpdateWrapper.eq(CsLinePO::getLineId,csLineParam.getLineId()) + .eq(CsLinePO::getStatus,1) + .set(CsLinePO::getVolGrade,csLineParam.getVolGrade()) + .set(CsLinePO::getPtRatio,csLineParam.getPtRatio()) + .set(CsLinePO::getCtRatio,csLineParam.getCtRatio()) + .set(CsLinePO::getConType,csLineParam.getConType()); + this.update(lambdaUpdateWrapper); + } + // /** // * 1.平台端默认配置拓扑图模板，包含拓扑图信息(cs_topology_diagram_template)和拓扑图上监测点的点位信息(cs_line_topology_template) // *