From 6f29c4f4f54f1ae0fc44773cfb867046f2747a51 Mon Sep 17 00:00:00 2001
From: 邱宇豪 <qyh123230312>
Date: 星期二, 26 九月 2023 17:24:02 +0800
Subject: [PATCH] 完成区域包保、危险源告知接口
---
hd/pipe/secure/src/main/resources/mapping/TRegionHazardInformMapper.xml | 125 ++++++++
hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/entity/TRegionWarrantyUserEntity.java | 19 +
hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionHazardInform/dto/TRegionHazardInformDto.java | 16 +
hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionHazardInform/service/impl/TRegionHazardInformServiceImpl.java | 65 ++++
hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionHazardInform/mapper/TRegionHazardInformMapper.java | 26 +
hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionHazardInform/controller/TRegionHazardInformController.java | 49 +++
hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionHazardInform/entity/TRegionHazardInformEntity.java | 24 +
hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/mapper/TRegionWarrantyMapper.java | 48 +++
hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/service/TRegionWarrantyService.java | 24 +
hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/controller/TRegionWarrantyController.java | 48 +++
hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/dto/TRegionWarrantyDto.java | 15 +
hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionHazardInform/service/TRegionHazardInformService.java | 25 +
hd/pipe/secure/src/main/resources/mapping/TRegionWarrantyMapper.xml | 168 ++++++++++++
hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/service/impl/TRegionWarrantyServiceImpl.java | 111 +++++++
hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/entity/TRegionWarrantyEntity.java | 33 ++
15 files changed, 796 insertions(+), 0 deletions(-)
diff --git a/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionHazardInform/controller/TRegionHazardInformController.java b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionHazardInform/controller/TRegionHazardInformController.java
new file mode 100644
index 0000000..5f0b0dd
--- /dev/null
+++ b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionHazardInform/controller/TRegionHazardInformController.java
@@ -0,0 +1,49 @@
+package com.thhy.secure.modules.biz.regionHazardInform.controller;
+
+import com.thhy.general.common.BasicResult;
+import com.thhy.secure.modules.biz.regionHazardInform.dto.TRegionHazardInformDto;
+import com.thhy.secure.modules.biz.regionHazardInform.entity.TRegionHazardInformEntity;
+import com.thhy.secure.modules.biz.regionHazardInform.service.TRegionHazardInformService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @Author QiuYuHao
+ * @CreateDate 2023-09-26 13:32:08
+ * 危险源告知控制层
+ */
+@RestController
+@RequestMapping(value = "regionHazardInform")
+public class TRegionHazardInformController {
+
+ @Autowired
+ private TRegionHazardInformService service;
+
+ @PostMapping(value = "findAll")
+ public BasicResult findAll(TRegionHazardInformDto tRegionHazardInformDto){
+ return service.findAll(tRegionHazardInformDto);
+ }
+
+ @GetMapping(value = "findEntity")
+ public BasicResult findEntity(String id){
+ return service.findEntity(id);
+ }
+
+ @PostMapping(value = "insert")
+ public BasicResult insert(TRegionHazardInformEntity tRegionHazardInformEntity){
+ return service.insert(tRegionHazardInformEntity);
+ }
+
+ @PostMapping(value = "update")
+ public BasicResult update(TRegionHazardInformEntity tRegionHazardInformEntity){
+ return service.update(tRegionHazardInformEntity);
+ }
+
+ @GetMapping(value = "delete")
+ public BasicResult delete(String id){
+ return service.delete(id);
+ }
+}
diff --git a/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionHazardInform/dto/TRegionHazardInformDto.java b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionHazardInform/dto/TRegionHazardInformDto.java
new file mode 100644
index 0000000..51f18f1
--- /dev/null
+++ b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionHazardInform/dto/TRegionHazardInformDto.java
@@ -0,0 +1,16 @@
+package com.thhy.secure.modules.biz.regionHazardInform.dto;
+
+import lombok.Data;
+
+/**
+ * @Author QiuYuHao
+ * @CreateDate 2023-09-26 13:33:54
+ * 危险源告知dto
+ */
+@Data
+public class TRegionHazardInformDto {
+ private Integer level;//安全等级
+ private Integer pageNum;
+ private Integer pageSize;
+ private String companyId;
+}
diff --git a/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionHazardInform/entity/TRegionHazardInformEntity.java b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionHazardInform/entity/TRegionHazardInformEntity.java
new file mode 100644
index 0000000..33fae80
--- /dev/null
+++ b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionHazardInform/entity/TRegionHazardInformEntity.java
@@ -0,0 +1,24 @@
+package com.thhy.secure.modules.biz.regionHazardInform.entity;
+
+import com.thhy.general.annotations.Idkey;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @Author QiuYuHao
+ * @CreateDate 2023-09-26 13:35:42
+ * 危险告知实体
+ */
+@Data
+public class TRegionHazardInformEntity implements Serializable {
+ @Idkey(value = "id")
+ private String id;
+ private String region;
+ private Integer level;
+ private String regionColor;
+ private String companyId;
+ private String createUser;
+ private Date createTime;
+}
diff --git a/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionHazardInform/mapper/TRegionHazardInformMapper.java b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionHazardInform/mapper/TRegionHazardInformMapper.java
new file mode 100644
index 0000000..ecdc93a
--- /dev/null
+++ b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionHazardInform/mapper/TRegionHazardInformMapper.java
@@ -0,0 +1,26 @@
+package com.thhy.secure.modules.biz.regionHazardInform.mapper;
+
+import com.thhy.secure.modules.biz.regionHazardInform.dto.TRegionHazardInformDto;
+import com.thhy.secure.modules.biz.regionHazardInform.entity.TRegionHazardInformEntity;
+import org.apache.ibatis.annotations.Mapper;
+
+import java.util.List;
+
+/**
+ * @Author QiuYuHao
+ * @CreateDate 2023-09-26 13:39:01
+ * 危险告知mapper
+ */
+@Mapper
+public interface TRegionHazardInformMapper {
+
+ List<TRegionHazardInformEntity> findAll(TRegionHazardInformDto tRegionHazardInformDto);
+
+ TRegionHazardInformEntity findEntity(String id);
+
+ void insert(TRegionHazardInformEntity tRegionHazardInformEntity);
+
+ void update(TRegionHazardInformEntity tRegionHazardInformEntity);
+
+ void delete(String id);
+}
diff --git a/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionHazardInform/service/TRegionHazardInformService.java b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionHazardInform/service/TRegionHazardInformService.java
new file mode 100644
index 0000000..8b51ec1
--- /dev/null
+++ b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionHazardInform/service/TRegionHazardInformService.java
@@ -0,0 +1,25 @@
+package com.thhy.secure.modules.biz.regionHazardInform.service;
+
+import com.thhy.general.common.BasicResult;
+import com.thhy.secure.modules.biz.regionHazardInform.dto.TRegionHazardInformDto;
+import com.thhy.secure.modules.biz.regionHazardInform.entity.TRegionHazardInformEntity;
+
+import java.util.List;
+
+/**
+ * @Author QiuYuHao
+ * @CreateDate 2023-09-26 13:42:53
+ * 危险告知源接口
+ */
+public interface TRegionHazardInformService {
+
+ BasicResult findAll(TRegionHazardInformDto tRegionHazardInformDto);
+
+ BasicResult findEntity(String id);
+
+ BasicResult insert(TRegionHazardInformEntity tRegionHazardInformEntity);
+
+ BasicResult update(TRegionHazardInformEntity tRegionHazardInformEntity);
+
+ BasicResult delete(String id);
+}
diff --git a/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionHazardInform/service/impl/TRegionHazardInformServiceImpl.java b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionHazardInform/service/impl/TRegionHazardInformServiceImpl.java
new file mode 100644
index 0000000..157bf98
--- /dev/null
+++ b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionHazardInform/service/impl/TRegionHazardInformServiceImpl.java
@@ -0,0 +1,65 @@
+package com.thhy.secure.modules.biz.regionHazardInform.service.impl;
+
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
+import com.thhy.general.common.BasicResult;
+import com.thhy.general.config.SysUserInfo;
+import com.thhy.general.utils.UserInfoUtils;
+import com.thhy.secure.modules.biz.regionHazardInform.dto.TRegionHazardInformDto;
+import com.thhy.secure.modules.biz.regionHazardInform.entity.TRegionHazardInformEntity;
+import com.thhy.secure.modules.biz.regionHazardInform.mapper.TRegionHazardInformMapper;
+import com.thhy.secure.modules.biz.regionHazardInform.service.TRegionHazardInformService;
+import org.checkerframework.checker.units.qual.A;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * @Author QiuYuHao
+ * @CreateDate 2023-09-26 13:44:04
+ * 危险告知源逻辑实现
+ */
+@Service
+public class TRegionHazardInformServiceImpl implements TRegionHazardInformService {
+
+ @Autowired
+ private TRegionHazardInformMapper tRegionHazardInformMapper;
+
+ @Override
+ public BasicResult findAll(TRegionHazardInformDto tRegionHazardInformDto) {
+ SysUserInfo userInfo = UserInfoUtils.getInstance().getUserInfo();
+ tRegionHazardInformDto.setCompanyId(userInfo.getCompanyId());
+ PageHelper.startPage(tRegionHazardInformDto.getPageNum(), tRegionHazardInformDto.getPageSize());
+ List<TRegionHazardInformEntity> all = this.tRegionHazardInformMapper.findAll(tRegionHazardInformDto);
+ PageInfo<TRegionHazardInformEntity> pageInfo = new PageInfo<>(all);
+ return BasicResult.success(pageInfo);
+ }
+
+ @Override
+ public BasicResult findEntity(String id) {
+ TRegionHazardInformEntity entity = this.tRegionHazardInformMapper.findEntity(id);
+ return BasicResult.success(entity);
+ }
+
+ @Override
+ public BasicResult insert(TRegionHazardInformEntity tRegionHazardInformEntity) {
+ SysUserInfo userInfo = UserInfoUtils.getInstance().getUserInfo();
+ tRegionHazardInformEntity.setCompanyId(userInfo.getCompanyId());
+ tRegionHazardInformEntity.setCreateUser(userInfo.getRealName());
+ this.tRegionHazardInformMapper.insert(tRegionHazardInformEntity);
+ return BasicResult.success();
+ }
+
+ @Override
+ public BasicResult update(TRegionHazardInformEntity tRegionHazardInformEntity) {
+ this.tRegionHazardInformMapper.update(tRegionHazardInformEntity);
+ return BasicResult.success();
+ }
+
+ @Override
+ public BasicResult delete(String id) {
+ this.tRegionHazardInformMapper.delete(id);
+ return BasicResult.success();
+ }
+}
diff --git a/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/controller/TRegionWarrantyController.java b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/controller/TRegionWarrantyController.java
new file mode 100644
index 0000000..45d8ad1
--- /dev/null
+++ b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/controller/TRegionWarrantyController.java
@@ -0,0 +1,48 @@
+package com.thhy.secure.modules.biz.regionWarranty.controller;
+
+import com.thhy.general.common.BasicResult;
+import com.thhy.secure.modules.biz.regionWarranty.dto.TRegionWarrantyDto;
+import com.thhy.secure.modules.biz.regionWarranty.entity.TRegionWarrantyEntity;
+import com.thhy.secure.modules.biz.regionWarranty.service.TRegionWarrantyService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * @Author QiuYuHao
+ * @CreateDate 2023-09-26 14:20:54
+ * 区域包保控制层
+ */
+
+@RestController
+@RequestMapping(value = "tRegionWarranty")
+public class TRegionWarrantyController {
+
+
+ @Autowired
+ private TRegionWarrantyService tRegionWarrantyService;
+
+ @PostMapping(value = "insert")
+ BasicResult insert(@RequestBody TRegionWarrantyEntity tRegionWarrantyEntity){
+ return tRegionWarrantyService.insert(tRegionWarrantyEntity);
+ }
+
+ @GetMapping(value = "delete")
+ BasicResult delete(@RequestParam String id){
+ return tRegionWarrantyService.delete(id);
+ }
+
+ @PostMapping(value = "update")
+ BasicResult update(@RequestBody TRegionWarrantyEntity tRegionWarrantyEntity){
+ return tRegionWarrantyService.update(tRegionWarrantyEntity);
+ }
+
+ @PostMapping(value = "findAll")
+ BasicResult findAll(@RequestBody TRegionWarrantyDto tRegionWarrantyDto){
+ return tRegionWarrantyService.findAll(tRegionWarrantyDto);
+ }
+
+ @GetMapping(value = "findEntity")
+ BasicResult findEntity(@RequestParam String id){
+ return tRegionWarrantyService.findEntity(id);
+ }
+}
diff --git a/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/dto/TRegionWarrantyDto.java b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/dto/TRegionWarrantyDto.java
new file mode 100644
index 0000000..d4145cb
--- /dev/null
+++ b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/dto/TRegionWarrantyDto.java
@@ -0,0 +1,15 @@
+package com.thhy.secure.modules.biz.regionWarranty.dto;
+
+import lombok.Data;
+
+/**
+ * @Author QiuYuHao
+ * @CreateDate 2023-09-26 14:22:22
+ * 区域包保dto
+ */
+@Data
+public class TRegionWarrantyDto {
+ private Integer pageNum;
+ private Integer pageSize;
+ private String regionHazardInformId;//区域名称id
+}
diff --git a/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/entity/TRegionWarrantyEntity.java b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/entity/TRegionWarrantyEntity.java
new file mode 100644
index 0000000..8198d79
--- /dev/null
+++ b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/entity/TRegionWarrantyEntity.java
@@ -0,0 +1,33 @@
+package com.thhy.secure.modules.biz.regionWarranty.entity;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Author QiuYuHao
+ * @CreateDate 2023-09-26 14:28:10
+ * 区域包保实体
+ */
+@Data
+public class TRegionWarrantyEntity implements Serializable {
+
+ private String id;
+
+ private String regionHazardInformId;//区域id
+ private String region;//区域名称
+
+ private String riskSourceSituation;//危险情况
+ private String countermeasures;//应对措施
+ private String createUser;
+ private String companyId;
+ private Date createTime;
+
+ private List<String> leader;//领导id集合
+ private List<String> staff;//员工id集合
+
+ private List<TRegionWarrantyUserEntity> leaderList;//领导集合
+ private List<TRegionWarrantyUserEntity> staffList;//领导集合
+}
diff --git a/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/entity/TRegionWarrantyUserEntity.java b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/entity/TRegionWarrantyUserEntity.java
new file mode 100644
index 0000000..ca9ebf4
--- /dev/null
+++ b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/entity/TRegionWarrantyUserEntity.java
@@ -0,0 +1,19 @@
+package com.thhy.secure.modules.biz.regionWarranty.entity;
+
+import com.thhy.general.annotations.Idkey;
+import lombok.Data;
+
+/**
+ * @Author QiuYuHao
+ * @CreateDate 2023-09-26 14:39:29
+ * 中间表
+ */
+@Data
+public class TRegionWarrantyUserEntity {
+ @Idkey("id")
+ private String id;
+ private String regionWarrantyId;//区域包保表id
+ private Integer userType;
+ private String userId;//1是领导 2是小组成员
+ private String realName;//姓名
+}
diff --git a/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/mapper/TRegionWarrantyMapper.java b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/mapper/TRegionWarrantyMapper.java
new file mode 100644
index 0000000..2ce2b1c
--- /dev/null
+++ b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/mapper/TRegionWarrantyMapper.java
@@ -0,0 +1,48 @@
+package com.thhy.secure.modules.biz.regionWarranty.mapper;
+
+import com.thhy.secure.modules.biz.regionWarranty.dto.TRegionWarrantyDto;
+import com.thhy.secure.modules.biz.regionWarranty.entity.TRegionWarrantyEntity;
+import com.thhy.secure.modules.biz.regionWarranty.entity.TRegionWarrantyUserEntity;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+/**
+ * @Author QiuYuHao
+ * @CreateDate 2023-09-26 14:38:26
+ * 区域包保mapper
+ */
+@Mapper
+public interface TRegionWarrantyMapper {
+
+ void insert(TRegionWarrantyEntity tRegionWarrantyEntity);
+
+ /**
+ * 添加中间表
+ * @param tRegionWarrantyUserEntity
+ */
+ void insertMiddleTable(TRegionWarrantyUserEntity tRegionWarrantyUserEntity);
+ void delete(String id);
+
+ /**
+ * 删除中间表
+ * @param id
+ */
+ void deleteMiddleTable(String id);
+
+ void update(TRegionWarrantyEntity tRegionWarrantyEntity);
+
+ List<TRegionWarrantyEntity> findAll(TRegionWarrantyDto tRegionWarrantyDto);
+ TRegionWarrantyEntity findEntity(String id);
+
+ /**
+ * 查询中间表
+ * @param regionWarrantyId
+ * @param userType
+ * @return
+ */
+ List<TRegionWarrantyUserEntity> findMiddleTable(@Param("regionWarrantyId") String regionWarrantyId,
+ @Param("userType") Integer userType);
+
+}
diff --git a/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/service/TRegionWarrantyService.java b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/service/TRegionWarrantyService.java
new file mode 100644
index 0000000..fc7bc93
--- /dev/null
+++ b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/service/TRegionWarrantyService.java
@@ -0,0 +1,24 @@
+package com.thhy.secure.modules.biz.regionWarranty.service;
+
+import com.thhy.general.common.BasicResult;
+import com.thhy.secure.modules.biz.regionWarranty.dto.TRegionWarrantyDto;
+import com.thhy.secure.modules.biz.regionWarranty.entity.TRegionWarrantyEntity;
+import com.thhy.secure.modules.biz.regionWarranty.entity.TRegionWarrantyUserEntity;
+
+import java.util.List;
+
+/**
+ * @Author QiuYuHao
+ * @CreateDate 2023-09-26 14:48:39
+ * 区域包保interface
+ */
+public interface TRegionWarrantyService {
+
+ BasicResult insert(TRegionWarrantyEntity tRegionWarrantyEntity);
+ BasicResult delete(String id);
+
+ BasicResult update(TRegionWarrantyEntity tRegionWarrantyEntity);
+
+ BasicResult findAll(TRegionWarrantyDto tRegionWarrantyDto);
+ BasicResult findEntity(String id);
+}
diff --git a/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/service/impl/TRegionWarrantyServiceImpl.java b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/service/impl/TRegionWarrantyServiceImpl.java
new file mode 100644
index 0000000..649e8a3
--- /dev/null
+++ b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionWarranty/service/impl/TRegionWarrantyServiceImpl.java
@@ -0,0 +1,111 @@
+package com.thhy.secure.modules.biz.regionWarranty.service.impl;
+
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
+import com.thhy.general.common.BasicResult;
+import com.thhy.general.utils.UUIDUtils;
+import com.thhy.secure.modules.biz.regionWarranty.dto.TRegionWarrantyDto;
+import com.thhy.secure.modules.biz.regionWarranty.entity.TRegionWarrantyEntity;
+import com.thhy.secure.modules.biz.regionWarranty.entity.TRegionWarrantyUserEntity;
+import com.thhy.secure.modules.biz.regionWarranty.mapper.TRegionWarrantyMapper;
+import com.thhy.secure.modules.biz.regionWarranty.service.TRegionWarrantyService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @Author QiuYuHao
+ * @CreateDate 2023-09-26 14:49:45
+ * 区域包保实现
+ */
+@Service
+public class TRegionWarrantyServiceImpl implements TRegionWarrantyService {
+
+ @Autowired
+ private TRegionWarrantyMapper tRegionWarrantyMapper;
+
+ @Override
+ public BasicResult insert(TRegionWarrantyEntity tRegionWarrantyEntity) {
+ String id = UUIDUtils.create();//
+ tRegionWarrantyEntity.setId(id);
+ tRegionWarrantyMapper.insert(tRegionWarrantyEntity);
+
+ //新增领导
+ List<String> leader = tRegionWarrantyEntity.getLeader();
+ leader.forEach(s->{
+ TRegionWarrantyUserEntity t = new TRegionWarrantyUserEntity();
+ t.setRegionWarrantyId(id);
+ t.setUserId(s);
+ t.setUserType(1);
+ tRegionWarrantyMapper.insertMiddleTable(t);
+ });
+
+ //员工
+ List<String> staff = tRegionWarrantyEntity.getStaff();
+ staff.forEach(s -> {
+ TRegionWarrantyUserEntity t = new TRegionWarrantyUserEntity();
+ t.setRegionWarrantyId(id);
+ t.setUserId(s);
+ t.setUserType(2);
+ tRegionWarrantyMapper.insertMiddleTable(t);
+ });
+ return BasicResult.success();
+ }
+
+ @Override
+ public BasicResult delete(String id) {
+ tRegionWarrantyMapper.delete(id);
+ tRegionWarrantyMapper.deleteMiddleTable(id);
+ return BasicResult.success();
+ }
+
+ @Override
+ public BasicResult update(TRegionWarrantyEntity tRegionWarrantyEntity) {
+ tRegionWarrantyMapper.deleteMiddleTable(tRegionWarrantyEntity.getId());
+ //领导
+ List<String> leader = tRegionWarrantyEntity.getLeader();
+ leader.forEach(s->{
+ TRegionWarrantyUserEntity t = new TRegionWarrantyUserEntity();
+ t.setRegionWarrantyId(tRegionWarrantyEntity.getId());
+ t.setUserId(s);
+ t.setUserType(1);
+ tRegionWarrantyMapper.insertMiddleTable(t);
+ });
+
+ //员工
+ List<String> staff = tRegionWarrantyEntity.getStaff();
+ staff.forEach(s -> {
+ TRegionWarrantyUserEntity t = new TRegionWarrantyUserEntity();
+ t.setRegionWarrantyId(tRegionWarrantyEntity.getId());
+ t.setUserId(s);
+ t.setUserType(2);
+ tRegionWarrantyMapper.insertMiddleTable(t);
+ });
+ tRegionWarrantyMapper.update(tRegionWarrantyEntity);
+ return null;
+ }
+
+ @Override
+ public BasicResult findAll(TRegionWarrantyDto tRegionWarrantyDto) {
+ PageHelper.startPage(tRegionWarrantyDto.getPageNum(), tRegionWarrantyDto.getPageSize());
+ List<TRegionWarrantyEntity> all = tRegionWarrantyMapper.findAll(tRegionWarrantyDto);
+ all.forEach(tRegionWarrantyEntity -> {
+ tRegionWarrantyEntity.setLeaderList(tRegionWarrantyMapper.findMiddleTable(tRegionWarrantyEntity.getId(),1));
+ tRegionWarrantyEntity.setStaffList(tRegionWarrantyMapper.findMiddleTable(tRegionWarrantyEntity.getId(),2));
+ });
+ PageInfo<TRegionWarrantyEntity> info = new PageInfo(all);
+ return BasicResult.success(info);
+ }
+
+ @Override
+ public BasicResult findEntity(String id) {
+ TRegionWarrantyEntity entity = tRegionWarrantyMapper.findEntity(id);
+ List<TRegionWarrantyUserEntity> leaderList = tRegionWarrantyMapper.findMiddleTable(id,1);
+ entity.setLeaderList(leaderList);
+ List<TRegionWarrantyUserEntity> staffList= tRegionWarrantyMapper.findMiddleTable(id,2);
+ entity.setStaffList(staffList);
+ return BasicResult.success(entity);
+ }
+}
diff --git a/hd/pipe/secure/src/main/resources/mapping/TRegionHazardInformMapper.xml b/hd/pipe/secure/src/main/resources/mapping/TRegionHazardInformMapper.xml
new file mode 100644
index 0000000..19e8fa0
--- /dev/null
+++ b/hd/pipe/secure/src/main/resources/mapping/TRegionHazardInformMapper.xml
@@ -0,0 +1,125 @@
+<?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.thhy.secure.modules.biz.regionHazardInform.mapper.TRegionHazardInformMapper">
+ <resultMap id="BaseResultMap" type="com.thhy.secure.modules.biz.regionHazardInform.entity.TRegionHazardInformEntity">
+ <!--
+ WARNING - @mbg.generated
+ This element is automatically generated by MyBatis Generator, do not modify.
+ This element was generated on Fri Jun 02 10:07:36 CST 2023.
+ -->
+ <id column="id" jdbcType="VARCHAR" property="id" />
+ <result column="region" jdbcType="VARCHAR" property="region" />
+ <result column="level" jdbcType="INTEGER" property="level" />
+ <result column="region_color" jdbcType="VARCHAR" property="regionColor" />
+ <result column="company_id" jdbcType="VARCHAR" property="companyId" />
+ <result column="create_user" jdbcType="VARCHAR" property="createUser" />
+ <result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
+ </resultMap>
+
+
+ <insert id="insert" >
+ insert into t_region_hazard_inform
+ <trim prefix="(" suffix=")" suffixOverrides=",">
+ <if test="id != null">
+ id,
+ </if>
+ <if test="region != null">
+ region,
+ </if>
+ <if test="level != null">
+ `level`,
+ </if>
+ <if test="regionColor != null">
+ region_color,
+ </if>
+
+ <if test="createTime != null">
+ create_time,
+ </if>
+ <if test="createUser != null">
+ create_user,
+ </if>
+ <if test="companyId != null">
+ company_id,
+ </if>
+ </trim>
+ <trim prefix="values (" suffix=")" suffixOverrides=",">
+ <if test="id != null">
+ #{id,jdbcType=VARCHAR},
+ </if>
+ <if test="region != null">
+ #{region,jdbcType=VARCHAR},
+ </if>
+ <if test="level != null">
+ #{level,jdbcType=INTEGER},
+ </if>
+ <if test="regionColor != null">
+ #{regionColor,jdbcType=VARCHAR},
+ </if>
+ <if test="createTime != null">
+ #{createTime,jdbcType=TIMESTAMP},
+ </if>
+ <if test="createUser != null">
+ #{createUser,jdbcType=VARCHAR},
+ </if>
+ <if test="companyId != null">
+ #{companyId,jdbcType=VARCHAR},
+ </if>
+ </trim>
+ </insert>
+ <select id="findAll" parameterType="com.thhy.secure.modules.biz.regionHazardInform.dto.TRegionHazardInformDto" resultMap="BaseResultMap">
+ SELECT
+ id,
+ region,
+ `level`,
+ region_color,
+ company_id,
+ create_user,
+ create_time,
+ is_use
+ FROM
+ t_region_hazard_inform
+ WHERE
+ is_use = 1
+ <if test="companyId!=null and companyId!='' ">
+ and company_id=#{companyId}
+ </if>
+ <if test="level!=null and level!='' ">
+ and `level`=#{level}
+ </if>
+ order by create_time desc
+ </select>
+ <select id="findEntity" parameterType="java.lang.String" resultType="com.thhy.secure.modules.biz.regionHazardInform.entity.TRegionHazardInformEntity">
+ SELECT
+ id,
+ region,
+ `level`,
+ region_color,
+ company_id,
+ create_user,
+ create_time,
+ is_use
+ FROM
+ t_region_hazard_inform
+ WHERE
+ is_use = 1 and id = #{id,jdbcType=VARCHAR}
+ </select>
+ <update id="update">
+ update t_region_hazard_inform
+ <set>
+ <if test="level != null">
+ level = #{level,jdbcType=INTEGER},
+ </if>
+ <if test="region != null">
+ region = #{region,jdbcType=VARCHAR},
+ </if>
+ <if test="regionColor != null">
+ region_color = #{regionColor,jdbcType=VARCHAR},
+ </if>
+ </set>
+ where id = #{id,jdbcType=VARCHAR}
+ </update>
+ <delete id="delete">
+ update t_region_hazard_inform set is_use = 2 where id = #{id,jdbcType=VARCHAR}
+ </delete>
+</mapper>
\ No newline at end of file
diff --git a/hd/pipe/secure/src/main/resources/mapping/TRegionWarrantyMapper.xml b/hd/pipe/secure/src/main/resources/mapping/TRegionWarrantyMapper.xml
new file mode 100644
index 0000000..60f5393
--- /dev/null
+++ b/hd/pipe/secure/src/main/resources/mapping/TRegionWarrantyMapper.xml
@@ -0,0 +1,168 @@
+<?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.thhy.secure.modules.biz.regionWarranty.mapper.TRegionWarrantyMapper">
+
+ <resultMap id="com.thhy.secure.modules.biz.regionWarranty.entity.TRegionWarrantyEntity"
+ type="com.thhy.secure.modules.biz.regionWarranty.entity.TRegionWarrantyEntity">
+ <result column="region" jdbcType="VARCHAR" property="region" />
+ <result column="region_hazard_inform_id" jdbcType="VARCHAR" property="regionHazardInformId" />
+ <result column="risk_source_situation" jdbcType="VARCHAR" property="riskSourceSituation" />
+ <result column="countermeasures" jdbcType="VARCHAR" property="countermeasures" />
+ <result column="company_id" jdbcType="VARCHAR" property="companyId" />
+ <result column="create_user" jdbcType="VARCHAR" property="createUser" />
+ <result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
+ </resultMap>
+
+ <insert id="insert" >
+ insert into t_region_warranty
+ <trim prefix="(" suffix=")" suffixOverrides=",">
+ <if test="id != null">
+ id,
+ </if>
+ <if test="regionHazardInformId != null">
+ region_hazard_inform_id,
+ </if>
+ <if test="riskSourceSituation != null">
+ risk_source_situation,
+ </if>
+ <if test="countermeasures != null">
+ countermeasures,
+ </if>
+
+ <if test="createTime != null">
+ create_time,
+ </if>
+ <if test="createUser != null">
+ create_user,
+ </if>
+ <if test="companyId != null">
+ company_id,
+ </if>
+ </trim>
+ <trim prefix="values (" suffix=")" suffixOverrides=",">
+ <if test="id != null">
+ #{id,jdbcType=VARCHAR},
+ </if>
+ <if test="regionHazardInformId != null">
+ #{regionHazardInformId,jdbcType=VARCHAR},
+ </if>
+ <if test="riskSourceSituation != null">
+ #{riskSourceSituation,jdbcType=VARCHAR},
+ </if>
+ <if test="countermeasures != null">
+ #{countermeasures,jdbcType=VARCHAR},
+ </if>
+ <if test="createTime != null">
+ #{createTime,jdbcType=TIMESTAMP},
+ </if>
+ <if test="createUser != null">
+ #{createUser,jdbcType=VARCHAR},
+ </if>
+ <if test="companyId != null">
+ #{companyId,jdbcType=VARCHAR},
+ </if>
+ </trim>
+ </insert>
+
+ <select id="findAll" parameterType="com.thhy.secure.modules.biz.regionWarranty.dto.TRegionWarrantyDto" resultMap="com.thhy.secure.modules.biz.regionWarranty.entity.TRegionWarrantyEntity">
+ SELECT
+ a.id,
+ a.region_hazard_inform_id regionHazardInformId,
+ a.risk_source_situation riskSourceSituation,
+ a.countermeasures countermeasures,
+ a.create_time createTime,
+ a.create_user createUser,
+ b.region
+ FROM
+ t_region_warranty a
+ LEFT JOIN t_region_hazard_inform b ON b.id = a.region_hazard_inform_id
+ WHERE is_use = 1
+ <if test="companyId!=null and companyId!='' ">
+ and a.company_id=#{companyId}
+ </if>
+ <if test="regionHazardInformId!=null and regionHazardInformId!='' ">
+ and b.id = #{regionHazardInformId}
+ </if>
+ order by a.create_time desc
+ </select>
+ <select id="findEntity" parameterType="java.lang.String" resultType="com.thhy.secure.modules.biz.regionWarranty.entity.TRegionWarrantyEntity">
+ SELECT
+ a.id,
+ a.region_hazard_inform_id regionHazardInformId,
+ a.risk_source_situation riskSourceSituation,
+ a.countermeasures countermeasures,
+ a.create_time createTime,
+ a.create_user createUser,
+ b.region
+ FROM
+ t_region_warranty a
+ LEFT JOIN t_region_hazard_inform b ON b.id = a.region_hazard_inform_id
+ WHERE is_use = 1 and a.id = #{id,jdbcType=VARCHAR}
+ </select>
+ <update id="update">
+ update t_region_warranty
+ <set>
+ <if test="regionHazardInformId != null">
+ #{regionHazardInformId,jdbcType=VARCHAR},
+ </if>
+ <if test="riskSourceSituation != null">
+ #{riskSourceSituation,jdbcType=VARCHAR},
+ </if>
+ <if test="countermeasures != null">
+ #{countermeasures,jdbcType=VARCHAR},
+ </if>
+ </set>
+ where id = #{id,jdbcType=VARCHAR}
+ </update>
+ <delete id="delete">
+ update t_region_warranty set is_use = 2 where id = #{id,jdbcType=VARCHAR}
+ </delete>
+
+ <insert id="insertMiddleTable" >
+ insert into t_region_warranty_user
+ <trim prefix="(" suffix=")" suffixOverrides=",">
+ <if test="id != null">
+ id,
+ </if>
+ <if test="regionWarrantyId != null">
+ region_warranty_id,
+ </if>
+ <if test="userType != null">
+ user_type,
+ </if>
+ <if test="userId != null">
+ user_id,
+ </if>
+ </trim>
+ <trim prefix="values (" suffix=")" suffixOverrides=",">
+ <if test="id != null">
+ #{id},
+ </if>
+ <if test="regionWarrantyId != null">
+ #{regionWarrantyId},
+ </if>
+ <if test="userType != null">
+ #{userType},
+ </if>
+ <if test="userId != null">
+ #{userId},
+ </if>
+ </trim>
+ </insert>
+
+ <delete id="deleteMiddleTable">
+ delete from t_region_warranty_user where region_warranty_id = #{id,jdbcType=VARCHAR}
+ </delete>
+
+ <select id="findMiddleTable" parameterType="java.lang.String" resultType="com.thhy.secure.modules.biz.regionWarranty.entity.TRegionWarrantyUserEntity">
+ SELECT
+ a.id,
+ a.region_warranty_id regionWarrantyId,
+ a.user_id userId,
+ a.user_type userType,
+ b.real_name as realName
+ FROM t_region_warranty_user a
+ LEFT JOIN sys_plat_user b ON b.user_id = a.user_id
+ WHERE a.region_warranty_id = #{regionWarrantyId} and a.user_type = #{userType}
+ </select>
+</mapper>
\ No newline at end of file
--
Gitblit v1.9.3