Merge remote-tracking branch 'origin/master'

pom.xml

@@ -45,7 +45,7 @@
         <middle.server.url>192.168.1.18</middle.server.url>
         <!--微服务模块发布地址-->
 <!--        <service.server.url>198.120.100.195</service.server.url>-->
-        <service.server.url>192.168.1.114</service.server.url>
+        <service.server.url>192.168.1.166</service.server.url>
         <!--docker仓库地址-->
         <docker.server.url>192.168.1.13</docker.server.url>
         <!--nacos的ip:port-->
@@ -54,7 +54,7 @@
 <!--                        <nacos.namespace></nacos.namespace>-->
 <!--        <nacos.namespace>fd74182b-1fce-4dba-afa7-2623b0376205</nacos.namespace>-->
 <!--        <nacos.namespace>ba3ba5d1-3480-4755-8b87-6b1fce16201c</nacos.namespace>-->
-        <nacos.namespace>fe40a052-d787-48f4-940f-688cabdff26a</nacos.namespace>
+        <nacos.namespace>012fcc94-a4d4-4dff-a75a-396a1b997f25</nacos.namespace>
         <!--sentinel:port-->
         <!--        <sentinel.url>192.168.1.14:8080</sentinel.url>-->
         <sentinel.url>${middle.server.url}:8080</sentinel.url>

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/AppBaseInformationAddParm.java

@@ -15,9 +15,7 @@ import javax.validation.constraints.NotBlank;
  * @version V1.0.0
  */
 
-/**
+
-    * app基础信息表
-    */
 @Data
 public class AppBaseInformationAddParm {
 

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/AppLineTopologyDiagramAddParm.java

@@ -15,9 +15,7 @@ import javax.validation.constraints.NotBlank;
  * @version V1.0.0
  */
 
-/**
+
-    * 项目拓扑图关系表
-    */
 @Data
 public class AppLineTopologyDiagramAddParm  {
     /**

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/AppLineTopologyDiagramAuditParm.java

@@ -15,9 +15,7 @@ import javax.validation.constraints.NotBlank;
  * @version V1.0.0
  */
 
-/**
+
-    * 项目拓扑图关系表
-    */
 @Data
 public class AppLineTopologyDiagramAuditParm  {
     /**

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/AppPersonSetAddParm.java

@@ -15,9 +15,7 @@ import javax.validation.constraints.NotBlank;
  * @version V1.0.0
  */
 
-/**
+
-    * app个人中心-设置信息
-    */
 @Data
 public class AppPersonSetAddParm  {
 

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/AppTopologyDiagramAddParm.java

@@ -17,9 +17,7 @@ import javax.validation.constraints.NotNull;
  * @version V1.0.0
  */
 
-/**
+
-    * 项目拓扑图关系表
-    */
 @Data
 public class AppTopologyDiagramAddParm  {
 

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/AppTopologyDiagramAuditParm.java

@@ -16,9 +16,6 @@ import javax.validation.constraints.NotBlank;
  * @version V1.0.0
  */
 
-/**
-    * 项目拓扑图关系表
-    */
 @Data
 public class AppTopologyDiagramAuditParm {
     @ApiModelProperty(value = "拓扑图id")

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelAddParm.java

@@ -17,9 +17,7 @@ import java.util.Date;
  * @version V1.0.0
  */
 
-/**
+
-    * 装置数据模板表
-    */
 @Data
 public class CsDevModelAddParm  {
 

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelAuditParm.java

@@ -18,9 +18,7 @@ import java.util.Date;
  * @version V1.0.0
  */
 
-/**
+
-    * 装置数据模板表
-    */
 @Data
 public class CsDevModelAuditParm {
     @NotNull(message="版本id不能为空！")

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelQueryListParm.java

@@ -15,9 +15,7 @@ import org.springframework.format.annotation.DateTimeFormat;
  * @version V1.0.0
  */
 
-/**
+
- * 程序版本表
- */
 @Data
 public class CsDevModelQueryListParm {
 

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelQueryParm.java

@@ -18,9 +18,7 @@ import javax.validation.constraints.NotNull;
  * @version V1.0.0
  */
 
-/**
+
- * 程序版本表
- */
 @Data
 public class CsDevModelQueryParm {
 

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDictAddParm.java

@@ -13,9 +13,7 @@ import lombok.Data;
  * @version V1.0.0
  */
 
-/**
+
-    * 数据字典表
-    */
 @Data
 public class CsDictAddParm {
 

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEdDataAddParm.java

@@ -20,9 +20,7 @@ import java.util.Date;
  * @version V1.0.0
  */
 
-/**
+
- * 程序版本表
- */
 @Data
 public class CsEdDataAddParm  {
 

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEdDataAuditParm.java

@@ -19,9 +19,7 @@ import java.time.LocalDate;
  * @version V1.0.0
  */
 
-/**
+
- * 程序版本表
- */
 @Data
 public class CsEdDataAuditParm {
 

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEdDataQueryParm.java

@@ -18,9 +18,7 @@ import javax.validation.constraints.NotNull;
  * @version V1.0.0
  */
 
-/**
+
- * 程序版本表
- */
 @Data
 public class CsEdDataQueryParm {
 

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEngineeringAddParm.java

@@ -0,0 +1,58 @@
+package com.njcn.algorithm.pojo.param;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+
+/**
+ * 
+ * Description:
+ * 接口文档访问地址：http://serverIP:port/swagger-ui.html
+ * Date: 2023/4/7  11:04【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+
+
+@Data
+public class CsEngineeringAddParm  {
+
+    /**
+     * 工程名称
+     */
+    @ApiModelProperty(value = "工程名称")
+    @NotBlank(message="工程名称不能为空！")
+    private String name;
+
+    /**
+     * 用户id
+     */
+    @ApiModelProperty(value = "用户id")
+    @NotBlank(message="用户id不能为空！")
+    private String userId;
+
+    /**
+     * 省
+     */
+    @ApiModelProperty(value = "省")
+    @NotBlank(message="省不能为空！")
+    private String province;
+
+    /**
+     * 市
+     */
+    @ApiModelProperty(value = "市")
+    @NotBlank(message="市不能为空！")
+    private String city;
+
+    /**
+     * 描述
+     */
+    @ApiModelProperty(value = "描述")
+    private String description;
+
+
+
+}

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEngineeringAuditParm.java

@@ -0,0 +1,59 @@
+package com.njcn.algorithm.pojo.param;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import javax.validation.constraints.NotNull;
+
+/**
+ * 
+ * Description:
+ * 接口文档访问地址：http://serverIP:port/swagger-ui.html
+ * Date: 2023/4/7  11:04【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+
+
+@Data
+public class CsEngineeringAuditParm {
+
+    @NotNull(message="版本id不能为空！")
+    private String id;
+    /**
+     * 工程名称
+     */
+    @ApiModelProperty(value = "工程名称")
+    private String name;
+
+    /**
+     * 用户id
+     */
+    @ApiModelProperty(value = "用户id")
+    private String userId;
+
+    /**
+     * 省
+     */
+    @ApiModelProperty(value = "省")
+    private String province;
+
+    /**
+     * 市
+     */
+    @ApiModelProperty(value = "市")
+    private String city;
+
+    /**
+     * 描述
+     */
+    @ApiModelProperty(value = "描述")
+    private String description;
+
+    @ApiModelProperty(value="0：删除 1：正常")
+    private String status;
+
+
+
+}

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEngineeringQueryParm.java

@@ -0,0 +1,38 @@
+package com.njcn.algorithm.pojo.param;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * Description:
+ * 接口文档访问地址：http://serverIP:port/swagger-ui.html
+ * Date: 2023/4/10  19:47【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Data
+public class CsEngineeringQueryParm {
+
+    @ApiModelProperty(value = "工程名称")
+    private String name;
+
+    /**
+     * 用户id
+     */
+    @ApiModelProperty(value = "用户id")
+    private String userId;
+
+    /**
+     * 省
+     */
+    @ApiModelProperty(value = "省")
+    private String province;
+
+    /**
+     * 市
+     */
+    @ApiModelProperty(value = "市")
+    private String city;
+
+}

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEquipmentDeliveryAddParm.java

@@ -18,9 +18,6 @@ import java.util.Date;
  * @version V1.0.0
  */
 
-/**
-    * 设备出厂表
-    */
 @Data
 public class CsEquipmentDeliveryAddParm{
 

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEquipmentDeliveryQueryParm.java

@@ -16,9 +16,6 @@ import java.util.Date;
  * @version V1.0.0
  */
 
-/**
-    * 设备出厂表
-    */
 @Data
 public class CsEquipmentDeliveryQueryParm {
 

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsFeedbackQueryParm.java

@@ -16,9 +16,7 @@ import javax.validation.constraints.NotNull;
  * @version V1.0.0
  */
 
-/**
+
-    * 信息反馈表
-    */
 @Data
 public class CsFeedbackQueryParm {
 

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/po/AppLineTopologyDiagramPO.java

@@ -1,6 +1,8 @@
 package com.njcn.algorithm.pojo.po;
 
+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.github.jeffreyning.mybatisplus.anno.MppMultiId;
 import com.njcn.db.bo.BaseEntity;
@@ -24,7 +26,7 @@ public class AppLineTopologyDiagramPO  extends BaseEntity {
     /**
      * 拓扑图Id
      */
-    @MppMultiId(value = "id")
+    @TableId(value = "id", type = IdType.ASSIGN_UUID)
     private String id;
 
     /**

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/po/AppProjectPO.java

@@ -1,8 +1,9 @@
 package com.njcn.algorithm.pojo.po;
 
+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.github.jeffreyning.mybatisplus.anno.MppMultiId;
 import com.njcn.db.bo.BaseEntity;
 import lombok.Data;
 
@@ -24,7 +25,7 @@ public class AppProjectPO  extends BaseEntity {
     /**
      * 项目Id
      */
-    @MppMultiId(value = "id")
+    @TableId(value = "id", type = IdType.ASSIGN_UUID)
     private String id;
 
 

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/po/AppTopologyDiagramPO.java

@@ -1,8 +1,9 @@
 package com.njcn.algorithm.pojo.po;
 
+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.github.jeffreyning.mybatisplus.anno.MppMultiId;
 import com.njcn.db.bo.BaseEntity;
 import lombok.Data;
 
@@ -24,7 +25,7 @@ public class AppTopologyDiagramPO  extends BaseEntity {
     /**
      * 拓扑图Id
      */
-    @MppMultiId(value = "id")
+    @TableId(value = "id", type = IdType.ASSIGN_UUID)
     private String id;
 
     /**

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/po/CsEngineeringPO.java

@@ -62,7 +62,7 @@ public class CsEngineeringPO extends BaseEntity {
      * 状态(0：删除 1：正常)
      */
     @TableField(value = "status")
-    private Boolean status;
+    private String status;
 
 
 }

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/vo/AppBaseInformationVO.java

@@ -14,9 +14,7 @@ import lombok.Data;
  * @version V1.0.0
  */
 
-/**
+
-    * app基础信息表
-    */
 @Data
 public class AppBaseInformationVO extends BaseEntity {
     /**

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/vo/AppTopologyDiagramVO.java

@@ -14,9 +14,7 @@ import lombok.Data;
  * @version V1.0.0
  */
 
-/**
+
-    * 项目拓扑图关系表
-    */
 @Data
 public class AppTopologyDiagramVO extends BaseEntity {
     /**

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/vo/CsDevModelPageVO.java

@@ -17,9 +17,7 @@ import java.time.LocalDate;
  * @version V1.0.0
  */
 
-/**
+
-    * 装置数据模板表
-    */
 @Data
 public class CsDevModelPageVO extends BaseEntity {
     /**

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/vo/CsDictVO.java

@@ -14,9 +14,7 @@ import lombok.Data;
  * @version V1.0.0
  */
 
-/**
+
-    * 数据字典表
-    */
 @Data
 public class CsDictVO extends BaseEntity {
     /**

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/vo/CsEdDataVO.java

@@ -16,9 +16,7 @@ import java.time.LocalDate;
  * @version V1.0.0
  */
 
-/**
+
- * 程序版本表
- */
 @Data
 public class CsEdDataVO  extends BaseEntity {
 

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/vo/CsEngineeringVO.java

@@ -0,0 +1,67 @@
+package com.njcn.algorithm.pojo.vo;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.njcn.db.bo.BaseEntity;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * 
+ * Description:
+ * 接口文档访问地址：http://serverIP:port/swagger-ui.html
+ * Date: 2023/4/7  11:04【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+
+/**
+    * 工程信息表
+    */
+@Data
+@TableName(value = "cs_engineering")
+public class CsEngineeringVO extends BaseEntity {
+    /**
+     * id
+     */
+    @ApiModelProperty(value = "id")
+    private String id;
+
+    /**
+     * 工程名称
+     */
+    @ApiModelProperty(value = "工程名称")
+    private String name;
+
+    /**
+     * 用户id
+     */
+    @ApiModelProperty(value = "用户id")
+    private String userId;
+
+    /**
+     * 省
+     */
+    @ApiModelProperty(value = "省")
+    private String province;
+
+    /**
+     * 市
+     */
+    @ApiModelProperty(value = "市")
+    private String city;
+
+    /**
+     * 描述
+     */
+    @ApiModelProperty(value = "描述")
+    private String description;
+
+    /**
+     * 状态(0：删除 1：正常)
+     */
+    @ApiModelProperty(value = "状态")
+    private String status;
+
+
+}

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/vo/CsEquipmentDeliveryVO.java

@@ -18,9 +18,7 @@ import java.util.Date;
  * @version V1.0.0
  */
 
-/**
+
-    * 设备出厂表
-    */
 @Data
 public class CsEquipmentDeliveryVO extends BaseEntity {
     /**

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/vo/CsFeedbackDetailVO.java

@@ -18,9 +18,7 @@ import java.util.List;
  * @version V1.0.0
  */
 
-/**
+
-    * 信息反馈列表
-    */
 @Data
 public class CsFeedbackDetailVO {
     /**

pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/vo/CsFeedbackVO.java

@@ -16,9 +16,7 @@ import java.time.LocalDateTime;
  * @version V1.0.0
  */
 
-/**
+
-    * 信息反馈列表
-    */
 @Data
 public class CsFeedbackVO  {
     /**

pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/project/EngineeringController.java

@@ -0,0 +1,77 @@
+package com.njcn.algorithm.controller.project;
+
+import com.njcn.algorithm.pojo.param.CsEngineeringAddParm;
+import com.njcn.algorithm.pojo.param.CsEngineeringAuditParm;
+import com.njcn.algorithm.pojo.param.CsEngineeringQueryParm;
+import com.njcn.algorithm.pojo.vo.CsEngineeringVO;
+import com.njcn.algorithm.service.CsEngineeringService;
+import com.njcn.common.pojo.annotation.OperateInfo;
+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.web.controller.BaseController;
+import io.swagger.annotations.Api;
+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.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+/**
+ * Description:
+ * 接口文档访问地址：http://serverIP:port/swagger-ui.html
+ * Date: 2023/3/27  10:54【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Slf4j
+@RestController
+@RequestMapping("/engineering")
+@Api(tags = " 工程管理")
+@AllArgsConstructor
+public class EngineeringController extends BaseController {
+
+
+    private final CsEngineeringService csEngineeringService;
+
+
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @PostMapping("/addEngineering")
+    @ApiOperation("新增工程")
+    @ApiImplicitParam(name = "csEngineeringAddParm", value = "新增工程参数", required = true)
+    public HttpResult<Boolean> addEngineering(@Validated @RequestBody CsEngineeringAddParm csEngineeringAddParm){
+        String methodDescribe = getMethodDescribe("addEngineering");
+
+        Boolean flag = csEngineeringService.addEngineering(csEngineeringAddParm);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, flag, methodDescribe);
+    }
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @PostMapping("/auditEngineering")
+    @ApiOperation("修改/删除工程")
+    @ApiImplicitParam(name = "csEngineeringAuditParm", value = "修改项目参数", required = true)
+    public HttpResult<Boolean> auditAppProject(@Validated @RequestBody CsEngineeringAuditParm csEngineeringAuditParm){
+        String methodDescribe = getMethodDescribe("auditEngineering");
+
+        Boolean flag = csEngineeringService.auditEngineering(csEngineeringAuditParm);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, flag, methodDescribe);
+    }
+
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @PostMapping("/queryEngineering")
+    @ApiOperation("查询工程列表")
+    @ApiImplicitParam(name = "csEngineeringQueryParm", value = "修改项目参数", required = true)
+    public HttpResult<List<CsEngineeringVO>> queryEngineering(@Validated @RequestBody CsEngineeringQueryParm csEngineeringQueryParm){
+        String methodDescribe = getMethodDescribe("queryEngineering");
+
+        List<CsEngineeringVO> csEngineeringVOList = csEngineeringService.queryEngineering(csEngineeringQueryParm);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, csEngineeringVOList, methodDescribe);
+    }
+}

pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/mapping/CsDevModelMapper.xml

@@ -25,7 +25,7 @@
         FROM cs_dev_model a
                      LEFT JOIN sys_dict_data b ON a.dev_type = b.id
                 WHERE
-                1 = 1
+                1 = 1 And a.`status`='1'
         <if test="csDevModelQueryParm.versionStartDate != null and csDevModelQueryParm.versionStartDate != ''">
             AND a.version_date &gt;= #{csDevModelQueryParm.versionStartDate }
         </if>
@@ -45,7 +45,7 @@
         FROM cs_dev_model a
                      LEFT JOIN sys_dict_data b ON a.dev_type = b.id
                 WHERE
-                1 = 1
+                1 = 1 And a.`status`='1'
         <if test="csDevModelQueryListParm.versionStartDate != null and csDevModelQueryListParm.versionStartDate != ''">
             AND a.version_date &gt;= #{csDevModelQueryListParm.versionStartDate }
         </if>

pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/mapping/CsEdDataMapper.xml

@@ -29,7 +29,7 @@
         FROM cs_ed_data a
                      LEFT JOIN sys_dict_data b ON a.dev_type = b.id
                 WHERE
-                1 = 1
+                1 = 1 And a.`status`='1'
         <if test="csEdDataQueryParm.versionStartDate != null and csEdDataQueryParm.versionStartDate != ''">
             AND a.version_date &gt;= #{csEdDataQueryParm.versionStartDate }
         </if>

pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/CsEngineeringService.java

@@ -1,8 +1,15 @@
 package com.njcn.algorithm.service;
 
+import com.njcn.algorithm.pojo.param.CsEngineeringAddParm;
+import com.njcn.algorithm.pojo.param.CsEngineeringAuditParm;
+import com.njcn.algorithm.pojo.param.CsEngineeringQueryParm;
 import com.njcn.algorithm.pojo.po.CsEngineeringPO;
 import com.baomidou.mybatisplus.extension.service.IService;
-    /**
+import com.njcn.algorithm.pojo.vo.CsEngineeringVO;
+
+import java.util.List;
+
+/**
  * 
  * Description:
  * 接口文档访问地址：http://serverIP:port/swagger-ui.html
@@ -13,5 +20,22 @@ import com.baomidou.mybatisplus.extension.service.IService;
  */
 public interface CsEngineeringService extends IService<CsEngineeringPO>{
 
+        /** 
+        * @Description: 新增工程
+        * @Param: [csEngineeringAddParm] 
+        * @return: java.lang.Boolean 
+        * @Author: clam
+        * @Date: 2023/4/10 
+        */ 
+        Boolean addEngineering(CsEngineeringAddParm csEngineeringAddParm);
 
-}
+        Boolean auditEngineering(CsEngineeringAuditParm csEngineeringAuditParm);
+        /** 
+        * @Description: 查询工程
+        * @Param: [csEngineeringQueryParm] 
+        * @return: java.util.List<com.njcn.algorithm.pojo.vo.CsEngineeringVO> 
+        * @Author: clam
+        * @Date: 2023/4/10 
+        */ 
+        List<CsEngineeringVO> queryEngineering(CsEngineeringQueryParm csEngineeringQueryParm);
+    }

pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/impl/CsEngineeringServiceImpl.java

@@ -1,10 +1,23 @@
 package com.njcn.algorithm.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.njcn.algorithm.mapper.CsEngineeringMapper;
+import com.njcn.algorithm.pojo.param.CsEngineeringAddParm;
+import com.njcn.algorithm.pojo.param.CsEngineeringAuditParm;
+import com.njcn.algorithm.pojo.param.CsEngineeringQueryParm;
 import com.njcn.algorithm.pojo.po.CsEngineeringPO;
+import com.njcn.algorithm.pojo.vo.CsEngineeringVO;
 import com.njcn.algorithm.service.CsEngineeringService;
+import org.apache.commons.lang.StringUtils;
+import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.stream.Collectors;
+
 /**
  * 
  * Description:
@@ -17,4 +30,41 @@ import org.springframework.stereotype.Service;
 @Service
 public class CsEngineeringServiceImpl extends ServiceImpl<CsEngineeringMapper, CsEngineeringPO> implements CsEngineeringService{
 
+    @Override
+    @Transactional(rollbackFor = {Exception.class})
+    public Boolean addEngineering(CsEngineeringAddParm csEngineeringAddParm) {
+        CsEngineeringPO csEngineeringPO = new CsEngineeringPO ();
+        BeanUtils.copyProperties (csEngineeringAddParm, csEngineeringPO);
+        csEngineeringPO.setStatus ("1");
+        boolean save = this.save (csEngineeringPO);
+        return save;
+    }
+
+    @Override
+    @Transactional(rollbackFor = {Exception.class})
+    public Boolean auditEngineering(CsEngineeringAuditParm csEngineeringAuditParm) {
+
+        CsEngineeringPO csEngineeringPO = new CsEngineeringPO ();
+        BeanUtils.copyProperties (csEngineeringAuditParm, csEngineeringPO);
+        boolean b = this.updateById (csEngineeringPO);
+        return b;
+    }
+
+    @Override
+    public List<CsEngineeringVO> queryEngineering(CsEngineeringQueryParm csEngineeringQueryParm) {
+        List<CsEngineeringVO> csEngineeringVOList = new ArrayList<> ();
+        QueryWrapper<CsEngineeringPO> queryWrapper = new QueryWrapper<> ();
+        queryWrapper.eq (StringUtils.isNotBlank (csEngineeringQueryParm.getUserId ()),"user_id",csEngineeringQueryParm.getUserId ()).
+                eq (StringUtils.isNotBlank (csEngineeringQueryParm.getProvince ()),"province",csEngineeringQueryParm.getProvince ()).
+                eq (StringUtils.isNotBlank (csEngineeringQueryParm.getCity ()),"city",csEngineeringQueryParm.getCity ()).
+                eq ("status","1" ).
+                like (StringUtils.isNotBlank (csEngineeringQueryParm.getName ()),"name",csEngineeringQueryParm.getName ());
+        List<CsEngineeringPO> csEngineeringPOS = this.getBaseMapper ( ).selectList (queryWrapper);
+        csEngineeringVOList = csEngineeringPOS.stream ().map (temp->{
+            CsEngineeringVO vo = new CsEngineeringVO();
+            BeanUtils.copyProperties (temp, vo);
+            return vo;
+        }).collect(Collectors.toList());
+        return csEngineeringVOList;
+    }
 }

pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/impl/CsEquipmentDeliveryServiceImpl.java

@@ -16,6 +16,7 @@ import com.njcn.algorithm.service.CsEquipmentDeliveryService;
 import com.njcn.common.pojo.exception.BusinessException;
 import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.Objects;
 
@@ -32,6 +33,7 @@ import java.util.Objects;
 public class CsEquipmentDeliveryServiceImpl extends ServiceImpl<CsEquipmentDeliveryMapper, CsEquipmentDeliveryPO> implements CsEquipmentDeliveryService{
 
     @Override
+    @Transactional(rollbackFor = {Exception.class})
     public Boolean save(CsEquipmentDeliveryAddParm csEquipmentDeliveryAddParm) {
         CsEquipmentDeliveryPO po = this.queryEquipmentPOByndid (csEquipmentDeliveryAddParm.getNdid ( ));
         if(!Objects.isNull (po)){
@@ -46,6 +48,7 @@ public class CsEquipmentDeliveryServiceImpl extends ServiceImpl<CsEquipmentDeliv
     }
 
     @Override
+    @Transactional(rollbackFor = {Exception.class})
     public Boolean AuditEquipmentDelivery(String id) {
         UpdateWrapper<CsEquipmentDeliveryPO> wrapper = new UpdateWrapper();
         wrapper.eq ("id", id);

pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/impl/CsFeedbackChatServiceImpl.java

@@ -35,6 +35,7 @@ public class CsFeedbackChatServiceImpl extends ServiceImpl<CsFeedbackChatMapper,
     }
 
     @Override
+    @Transactional(rollbackFor = {Exception.class})
     public Boolean updateChatStatus(CsFeedbackChatCheckParm csFeedbackChatCheckParm) {
         UpdateWrapper<CsFeedbackChatPO> updateWrapper = new UpdateWrapper<> ();
 

pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/impl/CsFeedbackServiceImpl.java

@@ -52,7 +52,7 @@ public class CsFeedbackServiceImpl extends ServiceImpl<CsFeedbackMapper, CsFeedb
         csFeedbackPO.setStatus ("1");
         boolean save = this.save (csFeedbackPO);
         boolean flag= true;
-        if(Objects.isNull (csFeedbackAddParm.getFiles ( ))){
+        if(!Objects.isNull (csFeedbackAddParm.getFiles ( ))){
             List<CsFilePathPO> csFilePathPOS= new ArrayList<> ();
             for (int i = 0; i < csFeedbackAddParm.getFiles ( ).length; i++) {
 
@@ -90,7 +90,7 @@ public class CsFeedbackServiceImpl extends ServiceImpl<CsFeedbackMapper, CsFeedb
                     ne ("user_id",temp.getUserId ()).
                     eq ("chat_status","0").
                     eq ("status", "1");
-            int count = csFeedbackChatService.count ( );
+            int count = csFeedbackChatService.count (csFeedbackChatPOQueryWrapper );
             csFeedbackVO.setChatCount (count);
             return csFeedbackVO;
         }).collect (Collectors.toList ( ));

pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/param/PqsParam.java

@@ -12,6 +12,8 @@ import lombok.NoArgsConstructor;
 @NoArgsConstructor
 @EqualsAndHashCode(callSuper = true)
 public class PqsParam extends DeviceInfoParam.BusinessParam {
+    @ApiModelProperty("装置id")
+    private String devId;
     @ApiModelProperty("当前页码")
     private Integer pageNum;
     @ApiModelProperty("当前页条数")

pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/vo/DataScaleVO.java

@@ -0,0 +1,30 @@
+package com.njcn.device.pq.pojo.vo;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @version 1.0.0
+ * @author: zbj
+ * @date: 2023/04/10
+ */
+@Data
+public class DataScaleVO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 月份
+     */
+    @ApiModelProperty("月份")
+    private String timeId;
+
+    /**
+     * 数据
+     */
+    @ApiModelProperty("数据")
+    private Float dataStatis;
+
+}

pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/controller/OperationContrController.java

@@ -22,10 +22,7 @@ import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.ibatis.annotations.Param;
 import org.springframework.validation.annotation.Validated;
-import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.*;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
 
 import java.util.List;
 
@@ -118,6 +115,16 @@ public class OperationContrController extends BaseController {
         return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, result, methodDescribe);
     }
 
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @PostMapping("/getMonthFlow")
+    @ApiOperation("获取每月流量")
+    @ApiImplicitParam(name = "deviceInfoParam", value = "实体", required = true)
+    public HttpResult<List<LineFlowMealDetailVO>> getMonthFlow (@RequestBody PqsParam deviceInfoParam){
+        String methodDescribe = getMethodDescribe("getMonthFlow");
+        LogUtil.njcnDebug(log, "{}，参数集合：{}", methodDescribe, deviceInfoParam);
+        List<LineFlowMealDetailVO> result = lineService.getMonthFlow(deviceInfoParam);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, result, methodDescribe);
+    }
 
 
     @OperateInfo(info = LogEnum.BUSINESS_COMMON)

pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/LineMapper.java

@@ -420,6 +420,8 @@ public interface LineMapper extends BaseMapper<Line> {
 
     List<LineFlowMealDetailVO> getDeviceRunStatistics(@Param("list") List<String> list, @Param("startTime") DateTime startTime, @Param("endTime") DateTime endTime);
 
-    Page<LineFlowMealDetailVO> getNewDeviceRunStatistics(Page<LineFlowMealDetailVO> page,@Param("devs") List<String> list, @Param("startTime") DateTime startTime, @Param("endTime") DateTime endTime);
+    Page<LineFlowMealDetailVO> getNewDeviceRunStatistics (Page<LineFlowMealDetailVO> page,@Param("devs") List<String> list, @Param("startTime") DateTime startTime, @Param("endTime") DateTime endTime);
-    Page<LineFlowMealDetailVO> getNewDeviceFlowStatistics(Page<LineFlowMealDetailVO> page,@Param("devs") List<String> list, @Param("startTime") DateTime startTime, @Param("endTime") DateTime endTime);
+    Page<LineFlowMealDetailVO> getNewDeviceFlowStatistics (Page<LineFlowMealDetailVO> page,@Param("devs") List<String> list, @Param("startTime") DateTime startTime, @Param("endTime") DateTime endTime);
+
+    List<LineFlowMealDetailVO> getMonthFlow (@Param("devId") String devId,@Param("startTime") DateTime beginOfDay, @Param("endTime") DateTime endOfDay);
 }

pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/DeviceMapper.xml

@@ -118,7 +118,7 @@
 
     <select id="getRunManageDevList" resultType="com.njcn.device.pq.pojo.vo.RunTimeVO">
         SELECT
-        dev.Id as id,
+        dev.Id AS id,
         area.NAME AS areaName,
         gd.NAME AS gdName,
         sub.NAME AS bdName,
@@ -170,7 +170,7 @@
                 #{item2}
             </foreach>
         </if>
-        <if test="manufacturers.size()!=0">
+        <if test="manufacturers.size() != 0">
             and device.Manufacturer in
             <foreach collection="manufacturers" item="item3" separator="," open="("  close=")">
                 #{item3}

pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/LineMapper.xml

@@ -1053,5 +1053,23 @@
         and d.com_flag = #{comFlag}
         and a.state = 1
     </select>
+    <select id="getMonthFlow" resultType="com.njcn.device.pq.pojo.vo.LineFlowMealDetailVO">
+        select t.*,
+        (t.statisValue)/(t.flowMeal) flowProportion
+        from (
+            SELECT
+            m.Dev_Id,
+            ifnull(d.flow, (select flow from cld_flow_meal where type = 0 and flag = 1)) + ifnull(d1.flow, 0) flowMeal,
+            ifnull(m.Actual_Value,0)/1024/1024 statisValue
+            FROM    cld_month_flow  m
+            LEFT JOIN cld_dev_meal c ON m.Dev_Id = c.line_id
+            LEFT JOIN cld_flow_meal d ON c.Base_Meal_Id = d.id
+            LEFT JOIN cld_flow_meal d1 ON c.Ream_Meal_Id = d1.id
+            where m.Dev_Id = #{devId}
+            and
+            m.Time_Id between #{startTime} and #{endTime}
+        ) t
+        ORDER BY flowProportion DESC
+    </select>
 
 </mapper>

pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/LineService.java

@@ -208,4 +208,6 @@ public interface LineService {
     Page<TopMsgPO> dailyDeviceAbnormalStatistics(PqsParam param);
 
     List<TopMsgPO> dailyDeviceAbnormal(DeviceInfoParam.BusinessParam conditionBusinessParam);
+
+    List<LineFlowMealDetailVO> getMonthFlow (PqsParam deviceInfoParam);
 }

pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/LineServiceImpl.java

@@ -403,6 +403,12 @@ public class LineServiceImpl extends ServiceImpl<LineMapper, Line> implements Li
         return topMsgDetails;
     }
 
+    @Override
+    public List<LineFlowMealDetailVO> getMonthFlow(PqsParam deviceInfoParam) {
+        List<LineFlowMealDetailVO> list = lineMapper.getMonthFlow(deviceInfoParam.getDevId(),DateUtil.beginOfDay(DateUtil.parse(deviceInfoParam.getSearchBeginTime())),DateUtil.endOfDay(DateUtil.parse(deviceInfoParam.getSearchEndTime())));
+        return list;
+    }
+
     @Override
     public List<LineFlowMealDetailVO> getDeviceRunStatistics(DeviceInfoParam.BusinessParam deviceInfoParam) {
         ArrayList<LineFlowMealDetailVO> lineFlowMealDetailList = new ArrayList<>();

pqs-system/system-boot/pom.xml

@@ -46,6 +46,12 @@
             <artifactId>common-swagger</artifactId>
             <version>${project.version}</version>
         </dependency>
+        <dependency>
+            <groupId>com.njcn</groupId>
+            <artifactId>pq-device-api</artifactId>
+            <version>1.0.0</version>
+            <scope>compile</scope>
+        </dependency>
     </dependencies>
 
     <build>

pqs-system/system-boot/src/main/java/com/njcn/system/controller/LargeScreenController.java

@@ -0,0 +1,52 @@
+package com.njcn.system.controller;
+
+import com.njcn.common.pojo.annotation.OperateInfo;
+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.device.pq.pojo.param.LargeScreenParam;
+import com.njcn.device.pq.pojo.vo.DataScaleVO;
+import com.njcn.system.service.LargeScreenService;
+import com.njcn.web.controller.BaseController;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiOperation;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+
+/**
+ * @version 1.0.0
+ * @author: zbj
+ * @date: 2023/04/10
+ */
+@Slf4j
+@Api(tags = "大屏")
+@RestController
+@RequestMapping("/largeScreen")
+@RequiredArgsConstructor
+public class LargeScreenController extends BaseController {
+
+    private final LargeScreenService largeScreenService;
+
+    /**
+     * 数据规模
+     */
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @PostMapping("/getDataScale")
+    @ApiOperation("数据规模")
+    @ApiImplicitParam(name = "largeScreenParam", value = "数据规模", required = true)
+    public HttpResult<List<DataScaleVO>> getDataScale(@RequestBody @Validated LargeScreenParam largeScreenParam) {
+        String methodDescribe = getMethodDescribe("getDataScale");
+        List<DataScaleVO> result = largeScreenService.getDataScale(largeScreenParam);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, result, methodDescribe);
+    }
+}

pqs-system/system-boot/src/main/java/com/njcn/system/mapper/LargeScreenMapper.java

@@ -0,0 +1,19 @@
+package com.njcn.system.mapper;
+
+
+import com.njcn.device.pq.pojo.param.LargeScreenParam;
+import com.njcn.device.pq.pojo.vo.DataScaleVO;
+import com.njcn.device.pq.pojo.vo.UserScaleVO;
+
+import java.util.List;
+
+/**
+ * @version 1.0.0
+ * @author: zbj
+ * @date: 2023/04/10
+ */
+public interface LargeScreenMapper {
+
+    List<DataScaleVO>  getDataScale (LargeScreenParam largeScreenParam);
+
+}

pqs-system/system-boot/src/main/java/com/njcn/system/mapper/mapping/LargeScreenMapper.xml

@@ -0,0 +1,34 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.njcn.system.mapper.LargeScreenMapper">
+
+    <select id="getUserScale" resultType="com.njcn.device.pq.pojo.vo.UserScaleVO">
+        SELECT DATE_FORMAT(REGISTER_TIME, '%Y-%m') AS `timeId`, COUNT(*) AS `monthIncrementNum`
+        FROM app_user
+        <where>
+        STATE = '1'
+        <if test="searchBeginTime != null and searchBeginTime != ''">
+            and date_format(REGISTER_TIME,'%y%m%d') &gt;= date_format(#{searchBeginTime},'%y%m%d')
+        </if>
+        <if test="searchEndTime != null and searchEndTime != ''">
+            and date_format(REGISTER_TIME,'%y%m%d') &lt;= date_format(#{searchEndTime},'%y%m%d')
+        </if>
+        </where>
+        GROUP BY `timeId`;
+    </select>
+
+    <select id="getDataScale" resultType="com.njcn.device.pq.pojo.vo.DataScaleVO">
+        SELECT DATE(pd.TIMEID) as "timeId", round(sum(DATASTATIS),2) as "dataStatis"
+        FROM pqs_datastatis pd
+        <where>
+        <if test="searchBeginTime != null and searchBeginTime != ''">
+            and date_format(pd.TIMEID,'%y%m%d') &gt;= date_format(#{searchBeginTime},'%y%m%d')
+        </if>
+        <if test="searchEndTime != null and searchEndTime != ''">
+            and date_format(pd.TIMEID,'%y%m%d') &lt;= date_format(#{searchEndTime},'%y%m%d')
+        </if>
+        </where>
+        GROUP BY DATE(pd.TIMEID);
+    </select>
+
+</mapper>

pqs-system/system-boot/src/main/java/com/njcn/system/service/LargeScreenService.java

@@ -0,0 +1,18 @@
+package com.njcn.system.service;
+
+import com.njcn.device.pq.pojo.param.LargeScreenParam;
+import com.njcn.device.pq.pojo.vo.DataScaleVO;
+
+import java.util.List;
+
+
+/**
+ * @version 1.0.0
+ * @author: zbj
+ * @date: 2023/04/10
+ */
+public interface LargeScreenService {
+
+    List<DataScaleVO> getDataScale(LargeScreenParam largeScreenParam);
+
+}

pqs-system/system-boot/src/main/java/com/njcn/system/service/impl/LargeScreenServiceImpl.java

@@ -0,0 +1,126 @@
+package com.njcn.system.service.impl;
+
+import com.njcn.device.pq.pojo.param.LargeScreenParam;
+import com.njcn.device.pq.pojo.vo.DataScaleVO;
+import com.njcn.system.mapper.LargeScreenMapper;
+import com.njcn.system.service.LargeScreenService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import java.text.SimpleDateFormat;
+import java.time.LocalDate;
+import java.time.format.DateTimeFormatter;
+import java.util.*;
+
+/**
+ * @version 1.0.0
+ * @author: zbj
+ * @date: 2023/04/10
+ */
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class LargeScreenServiceImpl implements LargeScreenService {
+
+    private final LargeScreenMapper largeScreenMapper;
+
+    /**
+     * 数据规模
+     */
+    @Override
+    public List<DataScaleVO> getDataScale(LargeScreenParam largeScreenParam) {
+        //创建返回VO
+        List<DataScaleVO> result = new ArrayList<>();
+        //创建模板
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
+        //获取当前日期
+        LocalDate today = LocalDate.now();
+        String endTime = today.format(formatter);
+        String startTime = "";
+        //获取30天前的日期
+        try {
+            startTime = getDate(endTime);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        largeScreenParam.setSearchBeginTime(startTime);
+        largeScreenParam.setSearchEndTime(endTime);
+        List<DataScaleVO> list = largeScreenMapper.getDataScale(largeScreenParam);
+        //获取区间中所有日期
+        List<String> days = null;
+        try {
+            days = selectDate(startTime, endTime);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        //加上今天
+        days.add(endTime);
+        for (String s : days) {
+            DataScaleVO vo = new DataScaleVO();
+            vo.setTimeId(s);
+            result.add(vo);
+        }
+        //集合不为空
+        if (list.size() > 0) {
+            for (DataScaleVO dataScaleVO : result) {
+                for (DataScaleVO scaleVO : list) {
+                    if (Objects.equals(scaleVO.getTimeId(), dataScaleVO.getTimeId())) {
+                        dataScaleVO.setDataStatis(scaleVO.getDataStatis());
+                    }
+                }
+            }
+            for (DataScaleVO vo : result) {
+                if (vo.getDataStatis() == null) {
+                    vo.setDataStatis(0.0f);
+                }
+            }
+            return result;
+        } else {
+            return result;
+        }
+    }
+
+    /**
+     * 传入字符串日期获取当前日期30天日期
+     *
+     * @param stringDate
+     * @throws Exception
+     */
+    public static String getDate(String stringDate) throws Exception {
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+        Date date = sdf.parse(stringDate); // 将字符串日期转换为Date对象
+        Calendar calendar = Calendar.getInstance();
+        calendar.setTime(date);
+        calendar.add(Calendar.DAY_OF_MONTH, -30); // 计算30天前的日期
+        Date newDate = calendar.getTime(); // 获取新日期
+        String newDateStr = sdf.format(newDate); // 将新日期转换为字符串日期
+        return newDateStr;
+    }
+
+    /**
+     * 获取传入起始月结束月中所有天
+     *
+     * @param startTime
+     * @param endTime
+     * @return
+     */
+    public List<String> selectDate(String startTime, String endTime) throws Exception {
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+
+        Date startDate = sdf.parse(startTime);
+        Date endDate = sdf.parse(endTime);
+
+        Calendar calendar = Calendar.getInstance();
+        calendar.setTime(startDate);
+
+        List<String> dates = new ArrayList<>();
+        while (calendar.getTime().before(endDate)) {
+            Date date = calendar.getTime();
+            String dateStr = sdf.format(date);
+            dates.add(dateStr);
+            calendar.add(Calendar.DATE, 1);
+        }
+        return dates;
+    }
+}