From ec7cdee5ac6e87038b6987098fb80edc8ce3631c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=B8=B8=E8=83=9C=E6=8C=AF?= <449117895@qq.com> Date: Sat, 27 Jul 2024 18:35:23 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E4=BA=A4=E5=90=8E=E4=BF=AE=E6=94=B9?= =?UTF-8?q?=E7=9B=B8=E5=85=B3-=E5=AE=A1=E6=89=B9=E3=80=81=E9=99=84?= =?UTF-8?q?=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/HighDangerController.java | 66 ++++++++++++++++++- .../server_api/mapper/HighDangerMapper.java | 2 + .../server_api/mapper/ThtApproveMapper.java | 11 ++++ .../server_api/mapper/ThtAttachsMapper.java | 9 +++ .../server_api/service/ThtApproveService.java | 10 +++ .../server_api/service/ThtAttachsService.java | 10 +++ .../service/impl/ThtApproveServiceImpl.java | 19 ++++++ .../service/impl/ThtAttachsServiceImpl.java | 19 ++++++ .../resources/sql-mapper/HighDangerMapper.xml | 8 +++ .../resources/sql-mapper/ThtApproveMapper.xml | 39 +++++++++++ .../resources/sql-mapper/ThtAttachsMapper.xml | 34 ++++++++++ .../hiatmp/model/common/ThtApprove.java | 24 +++++++ .../hiatmp/model/common/ThtAttachs.java | 26 ++++++++ 13 files changed, 275 insertions(+), 2 deletions(-) create mode 100644 hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/mapper/ThtApproveMapper.java create mode 100644 hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/mapper/ThtAttachsMapper.java create mode 100644 hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/service/ThtApproveService.java create mode 100644 hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/service/ThtAttachsService.java create mode 100644 hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/service/impl/ThtApproveServiceImpl.java create mode 100644 hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/service/impl/ThtAttachsServiceImpl.java create mode 100644 hiatmp-hidden-danger-server/src/main/resources/sql-mapper/ThtApproveMapper.xml create mode 100644 hiatmp-hidden-danger-server/src/main/resources/sql-mapper/ThtAttachsMapper.xml create mode 100644 hiatmp-model/src/main/java/com/hisense/hiatmp/model/common/ThtApprove.java create mode 100644 hiatmp-model/src/main/java/com/hisense/hiatmp/model/common/ThtAttachs.java diff --git a/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/controller/HighDangerController.java b/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/controller/HighDangerController.java index 6ffdee5..02293ff 100644 --- a/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/controller/HighDangerController.java +++ b/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/controller/HighDangerController.java @@ -8,10 +8,15 @@ import com.hisense.hiatmp.server_api.mapper.OperatorMapper; import com.hisense.hiatmp.model.common.DangerProblem; import com.hisense.hiatmp.server_api.service.HighDangerService; import com.hisense.hiatmp.model.dmr.Point; +import com.hisense.hiatmp.server_api.service.ThtApproveService; +import com.hisense.hiatmp.server_api.service.ThtAttachsService; import com.hisense.hiatmp.server_api.utils.CoordinateConverter; import com.hisense.hiatmp.server_api.utils.CoordinateUtils; import lombok.extern.slf4j.Slf4j; +import org.apache.commons.collections4.CollectionUtils; +import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.bind.annotation.*; import org.springframework.web.multipart.MultipartFile; @@ -34,7 +39,25 @@ public class HighDangerController { @Autowired HighDangerService highDangerService; + @Autowired + ThtAttachsService thtAttachsService; + @Autowired + ThtApproveService thtApproveService; + + @Value("${spring.ftp.username}") //用户名 + private String userName; + + @Value("${spring.ftp.password}") //密码 + private String passWord; + @Value("${spring.ftp.host}") //ip地址 + private String ip; + + @Value("${spring.ftp.port}") //端口号 + private int port; + + @Value("${spring.ftp.currentdir}") + private String CURRENT_DIR; // 文件存放的目录 /* 查询各个状态的数据情况 */ @@ -705,7 +728,7 @@ public class HighDangerController { @Transactional @PostMapping("/saveManualInvestigation") public ServerResponse saveManualInvestigation(@RequestBody ManualInvestigation manualInvestigation, HttpServletRequest request) { - + String ftpUrl = "ftp://"+userName+":"+passWord+"@"+ip+":"+port+CURRENT_DIR; log.info("/saveManualInvestigation（保存 & 暂存人工排查）接口被调用,调用ip: {}, 入参:{}", request.getRemoteAddr(), manualInvestigation); Date lastModDate = new Date(); manualInvestigation.setLastModeDate(lastModDate); @@ -742,7 +765,7 @@ public class HighDangerController { extra.setBusinessId(manualInvestigation.getBusinessId()); highDangerMapper.saveThtHiddenDataCollectConfigExtra(extra); } - + Date date = new Date(); // 隐患排查表--如果存在该记录则更新 highDangerMapper.deleteRoadInfo(manualInvestigation.getBusinessId()); for (HiddenDangerDTO details : manualInvestigation.getDescribe()) { @@ -753,6 +776,28 @@ public class HighDangerController { details.setBusinessId(manualInvestigation.getBusinessId()); // 保存重点排查数据 highDangerMapper.saveDangerExtra(details); + + //提交的时候保存附件 + if (manualInvestigation.getTemporary() == Boolean.TRUE + && StringUtils.isNotEmpty(details.getHdPic())) { + String hdPicArr[] = details.getHdPic().split(","); + for (String s : hdPicArr) { + uuid = UUID.randomUUID(); + uuidString = uuid.toString().replace("-", ""); + ThtAttachs thtAttachs = new ThtAttachs(); + String accachName = s.substring(s.lastIndexOf("/") + 1); + thtAttachs.setId(uuidString); + thtAttachs.setAttachUrl(ftpUrl + accachName); + thtAttachs.setAttachType("3"); + thtAttachs.setUploadTime(date); + thtAttachs.setInfoId(details.getNid()); + thtAttachs.setAttachName(accachName); + thtAttachs.setBusinessId(manualInvestigation.getBusinessId()); + thtAttachs.setPcCount(pcCount); + thtAttachs.setLastModDate(date); + thtAttachsService.saveAttachs(thtAttachs); + } + } } /*if(!highDangerMapper.isExtraExistence(manualInvestigation.getBusinessId()).isEmpty()){ }else{ @@ -808,6 +853,23 @@ public class HighDangerController { } else { log.info("/saveManualInvestigation（保存 & 暂存人工排查）接口返回, 客户端ip: {}, 返回数据:{},{}", request.getRemoteAddr(), "数据已保存", manualInvestigation); highDangerMapper.updateTemporary(manualInvestigation.getBusinessId(), "20"); + //隐患项不为空时，修改tht_hidden_danger_road + String hdFlag = "0"; + if (CollectionUtils.isNotEmpty(manualInvestigation.getDescribe())) { + hdFlag = "1"; + } + highDangerMapper.updateDangerRoad(hdFlag,manualInvestigation.getBusinessId(),pcCount); + ThtApprove thtAApprove = new ThtApprove(); + UUID uuid = UUID.randomUUID(); + String uuidString = uuid.toString().replace("-", ""); + thtAApprove.setNid(uuidString); + thtAApprove.setBusinessId(manualInvestigation.getBusinessId()); + thtAApprove.setOperator(manualInvestigation.getLastModeUser()); + thtAApprove.setStatus("10"); + thtAApprove.setOperateTime(date); + thtAApprove.setOperateContent("0"); + thtAApprove.setLastModDate(date); + thtApproveService.save(thtAApprove); return ServerResponse.ok("数据已保存", manualInvestigation); } diff --git a/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/mapper/HighDangerMapper.java b/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/mapper/HighDangerMapper.java index 7bce952..4ed6730 100644 --- a/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/mapper/HighDangerMapper.java +++ b/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/mapper/HighDangerMapper.java @@ -65,6 +65,8 @@ public interface HighDangerMapper extends BaseMapper{ void updateTemporary(String businessId, String temporary); + void updateDangerRoad(String hdFlag,String businessId,String pcCount); + void saveHiddenDataCollectConfig(ThtHiddenDataCollectConfig config); void saveDangerExtra(HiddenDangerDTO describe); diff --git a/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/mapper/ThtApproveMapper.java b/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/mapper/ThtApproveMapper.java new file mode 100644 index 0000000..ce2d5c5 --- /dev/null +++ b/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/mapper/ThtApproveMapper.java @@ -0,0 +1,11 @@ +package com.hisense.hiatmp.server_api.mapper; + +import com.hisense.hiatmp.model.common.ThtApprove; +import com.hisense.hiatmp.model.common.ThtAttachs; +import org.springframework.stereotype.Repository; + +@Repository +public interface ThtApproveMapper { + + int save(ThtApprove thtApprove); +} diff --git a/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/mapper/ThtAttachsMapper.java b/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/mapper/ThtAttachsMapper.java new file mode 100644 index 0000000..3e9827c --- /dev/null +++ b/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/mapper/ThtAttachsMapper.java @@ -0,0 +1,9 @@ +package com.hisense.hiatmp.server_api.mapper; + +import com.hisense.hiatmp.model.common.ThtAttachs; +import org.springframework.stereotype.Repository; +@Repository +public interface ThtAttachsMapper { + + int saveAttachs(ThtAttachs thtAttachs); +} diff --git a/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/service/ThtApproveService.java b/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/service/ThtApproveService.java new file mode 100644 index 0000000..697c224 --- /dev/null +++ b/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/service/ThtApproveService.java @@ -0,0 +1,10 @@ +package com.hisense.hiatmp.server_api.service; + +import com.hisense.hiatmp.model.common.ThtApprove; +import org.springframework.stereotype.Service; + +@Service +public interface ThtApproveService { + + public int save(ThtApprove thtAApprove); +} diff --git a/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/service/ThtAttachsService.java b/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/service/ThtAttachsService.java new file mode 100644 index 0000000..aa82dc8 --- /dev/null +++ b/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/service/ThtAttachsService.java @@ -0,0 +1,10 @@ +package com.hisense.hiatmp.server_api.service; + +import com.hisense.hiatmp.model.common.ThtAttachs; +import org.springframework.stereotype.Service; + +@Service +public interface ThtAttachsService { + + public int saveAttachs(ThtAttachs thtAttachs); +} diff --git a/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/service/impl/ThtApproveServiceImpl.java b/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/service/impl/ThtApproveServiceImpl.java new file mode 100644 index 0000000..feac8d6 --- /dev/null +++ b/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/service/impl/ThtApproveServiceImpl.java @@ -0,0 +1,19 @@ +package com.hisense.hiatmp.server_api.service.impl; + +import com.hisense.hiatmp.model.common.ThtApprove; +import com.hisense.hiatmp.server_api.mapper.ThtApproveMapper; +import com.hisense.hiatmp.server_api.service.ThtApproveService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +@Service +public class ThtApproveServiceImpl implements ThtApproveService { + + @Autowired + private ThtApproveMapper thtApproveMapper; + + @Override + public int save(ThtApprove thtApprove) { + return thtApproveMapper.save(thtApprove); + } +} diff --git a/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/service/impl/ThtAttachsServiceImpl.java b/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/service/impl/ThtAttachsServiceImpl.java new file mode 100644 index 0000000..ee4d206 --- /dev/null +++ b/hiatmp-hidden-danger-server/src/main/java/com/hisense/hiatmp/server_api/service/impl/ThtAttachsServiceImpl.java @@ -0,0 +1,19 @@ +package com.hisense.hiatmp.server_api.service.impl; + +import com.hisense.hiatmp.model.common.ThtAttachs; +import com.hisense.hiatmp.server_api.mapper.ThtAttachsMapper; +import com.hisense.hiatmp.server_api.service.ThtAttachsService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +@Service +public class ThtAttachsServiceImpl implements ThtAttachsService { + + @Autowired + private ThtAttachsMapper thtAttachsMapper; + + @Override + public int saveAttachs(ThtAttachs thtAttachs) { + return thtAttachsMapper.saveAttachs(thtAttachs); + } +} diff --git a/hiatmp-hidden-danger-server/src/main/resources/sql-mapper/HighDangerMapper.xml b/hiatmp-hidden-danger-server/src/main/resources/sql-mapper/HighDangerMapper.xml index 4d46a49..f44aa07 100644 --- a/hiatmp-hidden-danger-server/src/main/resources/sql-mapper/HighDangerMapper.xml +++ b/hiatmp-hidden-danger-server/src/main/resources/sql-mapper/HighDangerMapper.xml @@ -369,6 +369,14 @@ where business_id = #{businessId} + + update tht_hidden_danger_road + set hd_flag = #{hdFlag} + ,pc_end_time = CURRENT_TIMESTAMP + where business_id = #{businessId} + and pc_count = #{pcCount} + + INSERT INTO tht_hidden_data_collect_config_extra (nid, itemid, "order", type, name, standar, unit, business_id) VALUES (nextval('test_id_seq2'), #{itemid}, #{order}, #{type}, #{name}, #{standar}, #{unit}, #{businessId}) diff --git a/hiatmp-hidden-danger-server/src/main/resources/sql-mapper/ThtApproveMapper.xml b/hiatmp-hidden-danger-server/src/main/resources/sql-mapper/ThtApproveMapper.xml new file mode 100644 index 0000000..2e3e302 --- /dev/null +++ b/hiatmp-hidden-danger-server/src/main/resources/sql-mapper/ThtApproveMapper.xml @@ -0,0 +1,39 @@ + + + + + + + INSERT INTO tht_approve ( + nid, + business_id, + operator, + status, + timeline_nid, + operate_time, + operate_content, + last_mod_date + ) + VALUES ( + #{nid} , + #{businessId}, + #{operator}, + #{status}, + (SELECT + nid + FROM + tht_timeline + WHERE + business_id = #{businessId} + AND status = #{status} + ORDER BY + start_time DESC + LIMIT 1), + #{operateTime}, + #{operateContent}, + #{lastModDate} + ) + + + + \ No newline at end of file diff --git a/hiatmp-hidden-danger-server/src/main/resources/sql-mapper/ThtAttachsMapper.xml b/hiatmp-hidden-danger-server/src/main/resources/sql-mapper/ThtAttachsMapper.xml new file mode 100644 index 0000000..9cf05d1 --- /dev/null +++ b/hiatmp-hidden-danger-server/src/main/resources/sql-mapper/ThtAttachsMapper.xml @@ -0,0 +1,34 @@ + + + + + + + INSERT INTO tht_attachs ( + id, + attach_url, + attach_type, + upload_time, + info_id, + attach_name, + info_type, + business_id, + pc_count, + last_mod_date + ) + VALUES ( + #{id} , + #{attachUrl}, + #{attachType}, + #{uploadTime}, + #{infoId}, + #{attachName}, + #{infoType}, + #{businessId}, + #{pcCount}, + #{lastModDate} + ) + + + + \ No newline at end of file diff --git a/hiatmp-model/src/main/java/com/hisense/hiatmp/model/common/ThtApprove.java b/hiatmp-model/src/main/java/com/hisense/hiatmp/model/common/ThtApprove.java new file mode 100644 index 0000000..ae4d040 --- /dev/null +++ b/hiatmp-model/src/main/java/com/hisense/hiatmp/model/common/ThtApprove.java @@ -0,0 +1,24 @@ +package com.hisense.hiatmp.model.common; + +import lombok.Data; + +import java.io.Serializable; +import java.util.Date; + +/** + * 隐患闭环审批记录表 + */ +@Data +public class ThtApprove implements Serializable { + + private static final long serialVersionUID = 1L; + + String nid; + String businessId; + String operator; + String status; + String timelineNid; + Date operateTime; + String operateContent; + Date lastModDate; +} diff --git a/hiatmp-model/src/main/java/com/hisense/hiatmp/model/common/ThtAttachs.java b/hiatmp-model/src/main/java/com/hisense/hiatmp/model/common/ThtAttachs.java new file mode 100644 index 0000000..d7573aa --- /dev/null +++ b/hiatmp-model/src/main/java/com/hisense/hiatmp/model/common/ThtAttachs.java @@ -0,0 +1,26 @@ +package com.hisense.hiatmp.model.common; + +import lombok.Data; + +import java.io.Serializable; +import java.util.Date; + +/** + * 隐患附件表 + */ +@Data +public class ThtAttachs implements Serializable { + + private static final long serialVersionUID = 1L; + + String id; + String attachUrl; + String attachType; + Date uploadTime; + String infoId; + String attachName; + String infoType; + String businessId; + String pcCount; + Date lastModDate; +}