diff --git a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEquipmentDeliveryAuditParm.java b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEquipmentDeliveryAuditParm.java
new file mode 100644
index 000000000..81d556873
--- /dev/null
+++ b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEquipmentDeliveryAuditParm.java
@@ -0,0 +1,111 @@
+package com.njcn.algorithm.pojo.param;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import java.util.Date;
+
+/**
+ *
+ * Description:
+ * 接口文档访问地址:http://serverIP:port/swagger-ui.html
+ * Date: 2023/3/30 16:23【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+
+@Data
+public class CsEquipmentDeliveryAuditParm {
+
+ @ApiModelProperty(value = "id")
+ @NotBlank(message="id不能为空!")
+ private String id;
+ /**
+ * 装置名称
+ */
+ @ApiModelProperty(value="装置名称")
+ private String name;
+
+ /**
+ * 网关识别码
+ */
+ @ApiModelProperty(value="网关识别码")
+ private String ndid;
+
+ /**
+ * 装置mac地址
+ */
+ @ApiModelProperty(value="装置mac地址")
+ private String mac;
+
+ /**
+ * 装置用途(治理、监测...)
+ */
+ @ApiModelProperty(value="装置用途")
+ private String devUse;
+
+ /**
+ * 装置类型(直连设备、网关设备)
+ */
+ @ApiModelProperty(value="装置类型")
+ private String devType;
+
+ /**
+ * 装置型号(pqs588、pqs680...)
+ */
+ @ApiModelProperty(value="装置型号")
+ private String devModel;
+
+ /**
+ * 装置程序版本
+ */
+ @ApiModelProperty(value="装置程序版本")
+ private String programVersion;
+
+ /**
+ * 调试人员
+ */
+ @ApiModelProperty(value="调试人员")
+ private String debugPerson;
+
+ /**
+ * 出厂日期
+ */
+ @ApiModelProperty(value="出厂日期")
+ @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8")
+ private Date producteTime;
+
+ /**
+ * 检修日期
+ */
+ @ApiModelProperty(value="检修日期")
+ @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8")
+ private Date checkTime;
+
+ /**
+ * 调试日期
+ */
+ @ApiModelProperty(value="调试日期")
+ @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8")
+ private Date debugTime;
+
+ /**
+ * 合同号
+ */
+ @ApiModelProperty(value="合同号")
+ private String cntractNo;
+
+ /**
+ * 营销经理
+ */
+ @ApiModelProperty(value="营销经理")
+ private String salesManager;
+
+ @TableField(value = "status")
+ private String status;
+
+}
\ No newline at end of file
diff --git a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/po/CsDevModelPO.java b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/po/CsDevModelPO.java
index c6a190ffd..d7a67773d 100644
--- a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/po/CsDevModelPO.java
+++ b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/po/CsDevModelPO.java
@@ -39,7 +39,7 @@ public class CsDevModelPO extends BaseEntity {
/**
* 模板名称
*/
- @TableField(value = "模板名称")
+ @TableField(value = "name")
private String name;
/**
diff --git a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/po/CsEquipmentDeliveryPO.java b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/po/CsEquipmentDeliveryPO.java
index ab9c0a3c2..f251d8f2f 100644
--- a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/po/CsEquipmentDeliveryPO.java
+++ b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/po/CsEquipmentDeliveryPO.java
@@ -110,7 +110,7 @@ public class CsEquipmentDeliveryPO extends BaseEntity {
* 状态(0:删除 1:正常)
*/
@TableField(value = "status")
- private Integer status;
+ private String status;
}
\ No newline at end of file
diff --git a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/Equipment/DevModelController.java b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/Equipment/DevModelController.java
index 231454acb..a68f57fb5 100644
--- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/Equipment/DevModelController.java
+++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/Equipment/DevModelController.java
@@ -79,8 +79,8 @@ public class DevModelController extends BaseController {
@OperateInfo(info = LogEnum.BUSINESS_COMMON)
@PostMapping("/queryDevModelOne")
- @ApiOperation("设备模板列表查询")
- @ApiImplicitParam(name = "csDevModelQueryListParm", value = "信息", required = true)
+ @ApiOperation("设备模板查询")
+ @ApiImplicitParam(name = "csDevModelQueryListParm", value = "设备模板信息", required = true)
public HttpResult queryDevModelOne(@RequestBody CsDevModelQueryListParm csDevModelQueryListParm){
String methodDescribe = getMethodDescribe("queryDevModelOne");
diff --git a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/Equipment/EquipmentDeliveryController.java b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/Equipment/EquipmentDeliveryController.java
index 629dfcfd1..9d816f355 100644
--- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/Equipment/EquipmentDeliveryController.java
+++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/Equipment/EquipmentDeliveryController.java
@@ -2,6 +2,7 @@ package com.njcn.algorithm.controller.Equipment;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.njcn.algorithm.pojo.param.CsEquipmentDeliveryAddParm;
+import com.njcn.algorithm.pojo.param.CsEquipmentDeliveryAuditParm;
import com.njcn.algorithm.pojo.param.ProjectEquipmentQueryParm;
import com.njcn.algorithm.pojo.vo.CsEquipmentDeliveryVO;
import com.njcn.algorithm.pojo.vo.ProjectEquipmentVO;
@@ -59,6 +60,17 @@ public class EquipmentDeliveryController extends BaseController {
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, flag, methodDescribe);
}
+ @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+ @PostMapping("/updateEquipmentDelivery")
+ @ApiOperation("修改出厂设备")
+ @ApiImplicitParam(name = "csEquipmentDeliveryAuditParm", value = "新增项目参数", required = true)
+ public HttpResult updateEquipmentDelivery(@RequestBody @Validated CsEquipmentDeliveryAuditParm csEquipmentDeliveryAuditParm ){
+ String methodDescribe = getMethodDescribe("updateEquipmentDelivery");
+
+ Boolean flag = csEquipmentDeliveryService.updateEquipmentDelivery(csEquipmentDeliveryAuditParm);
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, flag, methodDescribe);
+ }
+
@OperateInfo(info = LogEnum.BUSINESS_COMMON)
diff --git a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/CsEquipmentDeliveryService.java b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/CsEquipmentDeliveryService.java
index a5b817b65..1e7e7e54c 100644
--- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/CsEquipmentDeliveryService.java
+++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/CsEquipmentDeliveryService.java
@@ -3,6 +3,7 @@ package com.njcn.algorithm.service;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.IService;
import com.njcn.algorithm.pojo.param.CsEquipmentDeliveryAddParm;
+import com.njcn.algorithm.pojo.param.CsEquipmentDeliveryAuditParm;
import com.njcn.algorithm.pojo.param.ProjectEquipmentQueryParm;
import com.njcn.algorithm.pojo.po.CsEquipmentDeliveryPO;
import com.njcn.algorithm.pojo.vo.CsEquipmentDeliveryVO;
@@ -51,4 +52,6 @@ public interface CsEquipmentDeliveryService extends IService queryEquipmentByProject(ProjectEquipmentQueryParm projectEquipmentQueryParm);
+
+ Boolean updateEquipmentDelivery(CsEquipmentDeliveryAuditParm csEquipmentDeliveryAuditParm);
}
diff --git a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/impl/CsEquipmentDeliveryServiceImpl.java b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/impl/CsEquipmentDeliveryServiceImpl.java
index fa64df23c..f5ebb9bf7 100644
--- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/impl/CsEquipmentDeliveryServiceImpl.java
+++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/impl/CsEquipmentDeliveryServiceImpl.java
@@ -8,6 +8,7 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.njcn.algorithm.enums.AlgorithmResponseEnum;
import com.njcn.algorithm.mapper.CsEquipmentDeliveryMapper;
import com.njcn.algorithm.pojo.param.CsEquipmentDeliveryAddParm;
+import com.njcn.algorithm.pojo.param.CsEquipmentDeliveryAuditParm;
import com.njcn.algorithm.pojo.param.ProjectEquipmentQueryParm;
import com.njcn.algorithm.pojo.po.CsEquipmentDeliveryPO;
import com.njcn.algorithm.pojo.vo.CsEquipmentDeliveryVO;
@@ -42,7 +43,7 @@ public class CsEquipmentDeliveryServiceImpl extends ServiceImpl wrapper = new QueryWrapper();
wrapper.eq ("ndid", ndid);
+ wrapper.eq("status",2);
CsEquipmentDeliveryPO csEquipmentDeliveryPO = this.baseMapper.selectOne (wrapper);
return csEquipmentDeliveryPO;
}
@@ -83,4 +85,12 @@ public class CsEquipmentDeliveryServiceImpl extends ServiceImpl t.getAlgoDescribe() != null).min(Comparator.comparing(TerminalOnlineRateDataVO::getAlgoDescribe)).orElseGet(TerminalOnlineRateDataVO::new);
+ TerminalOnlineRateDataVO temp = gdList.stream()
+ .filter(t -> t.getAlgoDescribe() != null)
+ .min(Comparator.comparing(TerminalOnlineRateDataVO::getAlgoDescribe))
+ .orElseGet(TerminalOnlineRateDataVO::new);
terminalOnlineRateDataVO.setAlgoDescribe(temp.getAlgoDescribe());
terminalOnlineRateDataVO.setChildren(gdList);
} else {
- //还需要额外处理省会
+ // 还需要额外处理省会
dealChildrenData(proList, gdList, false);
terminalOnlineRateDataVO.setChildren(proList);
}
@@ -298,14 +301,27 @@ public class TerminalOnlineRateDataServiceImpl implements TerminalOnlineRateData
List devs = subItem.getChildren();
if (CollectionUtil.isNotEmpty(devs)) {
for (TerminalOnlineRateDataVO devItem : devs) {
- if (Objects.nonNull(devItem.getAlgoDescribe())) {
+ if (Objects.isNull(devItem.getChildren())) {
if (mapAlarm.containsKey(devItem.getAlgoDescribe())) {
- if (devItem.getOnlineRate() != 3.14159 && devItem.getOnlineRate() > mapAlarm.get(devItem.getAlgoDescribe())) {
+ if (devItem.getOnlineRate() != 3.14159 && devItem.getOnlineRate() > mapAlarm.get(devItem.getAlgoDescribe())) {
devItem.setValueOver(1);
} else {
devItem.setValueOver(0);
}
}
+ } else {
+ List children = devItem.getChildren();
+ for (TerminalOnlineRateDataVO child : children) {
+ if (mapAlarm.containsKey(child.getAlgoDescribe())) {
+ if (child.getOnlineRate() != 3.14159 && child.getOnlineRate() > mapAlarm.get(child.getAlgoDescribe())) {
+ child.setValueOver(1);
+ } else {
+ child.setValueOver(0);
+ }
+ }
+ }
+ Double devAvg = children.stream().filter(item -> item.getOnlineRate() != 3.14159).collect(Collectors.averagingDouble(TerminalOnlineRateDataVO::getOnlineRate));
+ devItem.setOnlineRate(devAvg);
}
}
Double devAvg = devs.stream().filter(item -> item.getOnlineRate() != 3.14159).collect(Collectors.averagingDouble(TerminalOnlineRateDataVO::getOnlineRate));
diff --git a/pqs-event/event-api/src/main/java/com/njcn/event/enums/EventResponseEnum.java b/pqs-event/event-api/src/main/java/com/njcn/event/enums/EventResponseEnum.java
index a8577149a..3c132e2f7 100644
--- a/pqs-event/event-api/src/main/java/com/njcn/event/enums/EventResponseEnum.java
+++ b/pqs-event/event-api/src/main/java/com/njcn/event/enums/EventResponseEnum.java
@@ -31,6 +31,7 @@ public enum EventResponseEnum {
INDEX_OUT_OF_BOUNDS("A00655","集合索引越界异常"),
NOT_FOUND("A00656","没有查到数据"),
+ NOT_LINEID("A00657","暂无监测点信息"),
;
private final String code;
diff --git a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/EventDetail.java b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/EventDetail.java
index d55e2db07..07295e390 100644
--- a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/EventDetail.java
+++ b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/EventDetail.java
@@ -1,5 +1,6 @@
package com.njcn.event.pojo.po;
+import com.fasterxml.jackson.annotation.JsonFormat;
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
import com.fasterxml.jackson.datatype.jsr310.ser.InstantSerializer;
import io.swagger.annotations.ApiModelProperty;
@@ -28,8 +29,8 @@ public class EventDetail {
@Column(name = "time")
@ApiModelProperty(value = "开始时间")
- @JsonSerialize(using = InstantSerializer.class)
- private Instant startTime;
+ @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss.SSS",timezone = "GMT+8")
+ private LocalDateTime startTime;
@Column(name = "event_describe")
@ApiModelProperty(value = "事件描述")
diff --git a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RmpEventDetailPO.java b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RmpEventDetailPO.java
index 859a3bb86..d7a48a8a6 100644
--- a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RmpEventDetailPO.java
+++ b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/RmpEventDetailPO.java
@@ -86,7 +86,7 @@ public class RmpEventDetailPO implements Serializable {
@ApiModelProperty(value = "开始时间")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss.SSS",timezone = "GMT+8")
- private String startTime;
+ private LocalDateTime startTime;
@ApiModelProperty(value = "持续时间,单位秒")
diff --git a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/vo/RmpEventDetailVO.java b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/vo/RmpEventDetailVO.java
index d97a2f26c..a5ba4bab6 100644
--- a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/vo/RmpEventDetailVO.java
+++ b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/vo/RmpEventDetailVO.java
@@ -6,6 +6,7 @@ import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.io.Serializable;
+import java.time.LocalDateTime;
import java.util.Date;
/**
@@ -73,7 +74,7 @@ public class RmpEventDetailVO implements Serializable {
*/
@ApiModelProperty(name = "startTime",value = "开始时间")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss.SSS",timezone = "GMT+8")
- private Date startTime;
+ private LocalDateTime startTime;
/**
* 持续时间
diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/influxdb/PqsEventDetailQuery.java b/pqs-event/event-boot/src/main/java/com/njcn/event/influxdb/PqsEventDetailQuery.java
index 0993e2f55..fbd16ccf8 100644
--- a/pqs-event/event-boot/src/main/java/com/njcn/event/influxdb/PqsEventDetailQuery.java
+++ b/pqs-event/event-boot/src/main/java/com/njcn/event/influxdb/PqsEventDetailQuery.java
@@ -16,6 +16,8 @@ import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.time.Instant;
+import java.time.LocalDateTime;
+import java.time.ZoneId;
import java.util.ArrayList;
import java.util.List;
import java.util.function.BiFunction;
@@ -155,8 +157,9 @@ public class PqsEventDetailQuery extends QueryBuilder {
* @return 数据
*/
public static BiFunction> getBetweenTimeEventDetailList(List eventDetailList) {
+ ZoneId zone = ZoneId.systemDefault();
return (beginTime, endTime) -> eventDetailList.stream().filter(eventDetail -> {
- Instant timeId = eventDetail.getStartTime();
+ Instant timeId = eventDetail.getStartTime().atZone(zone).toInstant();
return timeId.isAfter(beginTime.toInstant()) && timeId.isBefore(endTime.toInstant());
}).collect(Collectors.toList());
}
diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/mapper/majornetwork/LargeScreenMapper.java b/pqs-event/event-boot/src/main/java/com/njcn/event/mapper/majornetwork/LargeScreenMapper.java
index 273fc18be..ada8e31ec 100644
--- a/pqs-event/event-boot/src/main/java/com/njcn/event/mapper/majornetwork/LargeScreenMapper.java
+++ b/pqs-event/event-boot/src/main/java/com/njcn/event/mapper/majornetwork/LargeScreenMapper.java
@@ -1,7 +1,9 @@
package com.njcn.event.mapper.majornetwork;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.njcn.device.pq.pojo.vo.AllDataVO;
import com.njcn.device.pq.pojo.vo.EventVO;
+import com.njcn.device.pq.pojo.vo.MiddleChildVO;
import com.njcn.device.pq.pojo.vo.MiddleLimitRateVO;
import com.njcn.harmonic.pojo.po.PQSComAssesPO;
import org.apache.ibatis.annotations.Param;
@@ -28,11 +30,11 @@ public interface LargeScreenMapper {
Map getDownCount (@Param("lineIds") List lineIds, @Param("startTime") String startTime, @Param("endTime") String endTime);
- List getMiddleDown (@Param("lineIds") List lineIds, @Param("startTime") String startTime, @Param("endTime") String endTime);
+ List getMiddleDown (Page page,@Param("lineIds") List lineIds, @Param("startTime") String startTime, @Param("endTime") String endTime);
- List
+ *
+ * @author zbj
+ * @since 2023-04-17
+ */
+@Data
+@TableName("pqs_resinformation")
+public class Resinformation {
+
+ /**
+ * 资源序号
+ */
+ @TableField(value = "id")
+ private String id;
+
+ /**
+ * 资源名称
+ */
+ @TableField(value = "name")
+ private String name;
+
+ /**
+ * 资源描述
+ */
+ @TableField(value = "description")
+ private String description;
+
+ /**
+ * 资源路径
+ */
+ @TableField(value = "res_url")
+ private String url;
+
+ /**
+ * 数据更新人ID(外键user表)
+ */
+ @TableField(value = "updateuser")
+ private String updateUser;
+
+ /**
+ * 数据更新时间
+ */
+ @TableField(value = "updatetime")
+ private LocalDateTime updateTime;
+
+ /**
+ * 数据状态(0: 删除; 1: 正常)
+ */
+ @TableField(value = "state")
+ private Integer state;
+
+ /**
+ * 系统类型Guid
+ */
+ @TableField(value = "systype")
+ private String systemType;
+
+ /**
+ * 资源类型
+ */
+ @TableField(value = "type")
+ private String type;
+
+}
diff --git a/pqs-system/system-boot/pom.xml b/pqs-system/system-boot/pom.xml
index fd3b05e46..9d1c1ed2a 100644
--- a/pqs-system/system-boot/pom.xml
+++ b/pqs-system/system-boot/pom.xml
@@ -52,6 +52,12 @@
okio
2.8.0
+
+ com.njcn
+ common-oss
+ 1.0.0
+ compile
+
diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/controller/ResourceAdministrationController.java b/pqs-system/system-boot/src/main/java/com/njcn/system/controller/ResourceAdministrationController.java
new file mode 100644
index 000000000..c98742291
--- /dev/null
+++ b/pqs-system/system-boot/src/main/java/com/njcn/system/controller/ResourceAdministrationController.java
@@ -0,0 +1,49 @@
+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.system.service.IResourceAdministrationService;
+import com.njcn.web.controller.BaseController;
+import io.swagger.annotations.*;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestPart;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.multipart.MultipartFile;
+
+
+/**
+ * @version 1.0.0
+ * @author: zbj
+ * @date: 2023/04/17
+ */
+@Slf4j
+@Api(tags = "资源管理")
+@RestController
+@RequestMapping("/resourceAdministration")
+@RequiredArgsConstructor
+public class ResourceAdministrationController extends BaseController {
+
+ private final IResourceAdministrationService iResourceAdministrationService;
+
+ /**
+ * 上传资源
+ */
+ @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+ @PostMapping("/uploadFile")
+ @ApiOperation("上传资源")
+ public HttpResult uploadFile(@ApiParam(value = "文件", required = true)@RequestPart("multipartFile") MultipartFile multipartFile,
+ @ApiParam(value = "资源名称", required = true)String name,
+ @ApiParam(value = "资源类型", required = true) String type,
+ @ApiParam(value = "资源描述", required = false)String describe,
+ @ApiParam(value = "系统类型Guid", required = true) String systemType) {
+ String methodDescribe = getMethodDescribe("uploadFile");
+ Boolean flag = iResourceAdministrationService.uploadFile(multipartFile, name, type, describe, systemType);
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, flag, methodDescribe);
+ }
+}
diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/ResourceAdministrationMapper.java b/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/ResourceAdministrationMapper.java
new file mode 100644
index 000000000..d858a4e97
--- /dev/null
+++ b/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/ResourceAdministrationMapper.java
@@ -0,0 +1,16 @@
+package com.njcn.system.mapper;
+
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njcn.system.pojo.po.Resinformation;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * @version 1.0.0
+ * @author: zbj
+ * @date: 2023/04/17
+ */
+@Mapper
+public interface ResourceAdministrationMapper extends BaseMapper {
+
+}
diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/mapping/ResourceAdministrationMapper.xml b/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/mapping/ResourceAdministrationMapper.xml
new file mode 100644
index 000000000..5882096fe
--- /dev/null
+++ b/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/mapping/ResourceAdministrationMapper.xml
@@ -0,0 +1,4 @@
+
+
+
+
diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/service/IResourceAdministrationService.java b/pqs-system/system-boot/src/main/java/com/njcn/system/service/IResourceAdministrationService.java
new file mode 100644
index 000000000..65bf7d118
--- /dev/null
+++ b/pqs-system/system-boot/src/main/java/com/njcn/system/service/IResourceAdministrationService.java
@@ -0,0 +1,17 @@
+package com.njcn.system.service;
+
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.njcn.system.pojo.po.Resinformation;
+import org.springframework.web.multipart.MultipartFile;
+
+/**
+ * @version 1.0.0
+ * @author: zbj
+ * @date: 2023/04/17
+ */
+public interface IResourceAdministrationService extends IService {
+
+ Boolean uploadFile(MultipartFile multipartFile, String name, String type, String describe,String systemType);
+
+}
diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/service/impl/ResourceAdministrationServiceImpl.java b/pqs-system/system-boot/src/main/java/com/njcn/system/service/impl/ResourceAdministrationServiceImpl.java
new file mode 100644
index 000000000..6bf1def06
--- /dev/null
+++ b/pqs-system/system-boot/src/main/java/com/njcn/system/service/impl/ResourceAdministrationServiceImpl.java
@@ -0,0 +1,53 @@
+package com.njcn.system.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.njcn.oss.constant.OssPath;
+import com.njcn.oss.utils.FileStorageUtil;
+import com.njcn.system.mapper.ResourceAdministrationMapper;
+import com.njcn.system.pojo.po.Resinformation;
+import com.njcn.system.service.IResourceAdministrationService;
+import com.njcn.web.utils.RequestUtil;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.time.LocalDateTime;
+import java.util.Objects;
+
+/**
+ * @version 1.0.0
+ * @author: zbj
+ * @date: 2023/04/17
+ */
+@Service
+@RequiredArgsConstructor
+@Slf4j
+public class ResourceAdministrationServiceImpl extends ServiceImpl implements IResourceAdministrationService {
+
+ private final ResourceAdministrationMapper resourceAdministrationMapper;
+
+ private final FileStorageUtil fileStorageUtil;
+
+ @Override
+ public Boolean uploadFile(MultipartFile multipartFile, String name, String type, String describe, String systemType) {
+ //通过封装好的文件工具类来传入文件和文件夹名称来获取文件路径
+ String url = fileStorageUtil.uploadMultipart(multipartFile, OssPath.RESOURCEADMINISTRATION);
+ //创建对象
+ Resinformation resinformation = new Resinformation();
+ resinformation.setName(name);
+ if (Objects.nonNull(describe)) {
+ resinformation.setDescription(describe);
+ }
+ resinformation.setUrl(url);
+ //获取用户id
+ String userIndex = RequestUtil.getUserIndex();
+ //String userIndex = "123456";
+ resinformation.setUpdateUser(userIndex);
+ resinformation.setUpdateTime(LocalDateTime.now());
+ resinformation.setState(1);
+ resinformation.setSystemType(systemType);
+ resinformation.setType(type);
+ return this.save(resinformation);
+ }
+}