From 83ea655f2d36ab319d2dfe885947957c550d4f64 Mon Sep 17 00:00:00 2001
From: 叶松 <2217086471@qq.com>
Date: 星期一, 13 十一月 2023 14:17:26 +0800
Subject: [PATCH] Merge branch 'master' of http://111.30.93.211:10101/r/supipe
---
hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionInspection/service/impl/RegionInspectionServiceImpl.java | 129 +++++++++++++++++++++++++++++++++++++++++++
1 files changed, 129 insertions(+), 0 deletions(-)
diff --git a/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionInspection/service/impl/RegionInspectionServiceImpl.java b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionInspection/service/impl/RegionInspectionServiceImpl.java
new file mode 100644
index 0000000..69f9e05
--- /dev/null
+++ b/hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/regionInspection/service/impl/RegionInspectionServiceImpl.java
@@ -0,0 +1,129 @@
+package com.thhy.secure.modules.biz.regionInspection.service.impl;
+
+import com.github.pagehelper.Page;
+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.UUIDUtils;
+import com.thhy.general.utils.UserInfoUtils;
+import com.thhy.secure.modules.biz.regionInspection.entity.RegionInspectionEntity;
+import com.thhy.secure.modules.biz.regionInspection.entity.RegionInspectionHazardInformEntity;
+import com.thhy.secure.modules.biz.regionInspection.entity.RegionInspectionUserEntity;
+import com.thhy.secure.modules.biz.regionInspection.mapper.RegionInspectionMapper;
+import com.thhy.secure.modules.biz.regionInspection.service.RegionInspectionService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @Author QiuYuHao
+ * @CreateDate 2023-11-10 11:26:29
+ * 区域巡检接口实现
+ */
+@Service
+public class RegionInspectionServiceImpl implements RegionInspectionService
+{
+
+ @Autowired
+ private RegionInspectionMapper regionInspectionMapper;
+
+ private static final Object lock = new Object();
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public BasicResult insert(RegionInspectionEntity regionInspectionEntity) {
+ SysUserInfo s = UserInfoUtils.getInstance().getUserInfo();
+ String companyId = s.getCompanyId();
+ String userId = s.getUserId();
+ regionInspectionEntity.setCompanyId(companyId);
+ //默认给uuid
+ String regionInspectId = UUIDUtils.create();
+ //修改区域巡检判断
+ if (!"".equals(regionInspectionEntity.getId())){
+ regionInspectId = regionInspectionEntity.getId();
+ //根据区域巡检id删除中间表
+ regionInspectionEntity.setUpdateTime(new Date());
+ regionInspectionEntity.setUpdateUser(userId);
+ regionInspectionMapper.deleteUser(regionInspectId);
+ regionInspectionMapper.deleteInspectionHazardInform(regionInspectId);
+ }
+ //添加/修改区域巡检
+ synchronized (lock) {
+ regionInspectionEntity.setId(regionInspectId);
+ regionInspectionEntity.setCreateUser(userId);
+ regionInspectionMapper.insert(regionInspectionEntity);
+ //添加巡检人
+ for (RegionInspectionUserEntity userEntity : regionInspectionEntity.getRegionUsersList()) {
+ userEntity.setId(UUIDUtils.create());
+ userEntity.setRegionInspectionId(regionInspectId);
+ regionInspectionMapper.insertUser(userEntity);
+ }
+ //添加巡检的区域
+ for (RegionInspectionHazardInformEntity region : regionInspectionEntity.getRegionList()) {
+ region.setId(UUIDUtils.create());
+ region.setRegionInspectionId(regionInspectId);
+ regionInspectionMapper.insertInspectionHazardInform(region);
+ }
+ }
+ return BasicResult.success();
+ }
+
+ @Override
+ public BasicResult delete(String id) {
+ regionInspectionMapper.delete(id);
+ regionInspectionMapper.deleteUser(id);
+ regionInspectionMapper.deleteInspectionHazardInform(id);
+ return BasicResult.success();
+ }
+
+ @Override
+ public BasicResult selectPageList(Map map) {
+ SysUserInfo s = UserInfoUtils.getInstance().getUserInfo();
+ String companyId = s.getCompanyId();
+ map.put("companyId",companyId);
+ int pageNum = (int) map.get("pageNum");
+ int pageSize = (int) map.get("pageSize");
+ PageHelper.startPage(pageNum,pageSize);
+ List<RegionInspectionEntity> regionInspectionEntities = regionInspectionMapper.selectPageList(map);
+ //处理区域巡检对象数组
+ regionInspectionEntities.forEach(obj->{
+ List<RegionInspectionHazardInformEntity> regionList = new ArrayList<>();
+ List<RegionInspectionUserEntity> userList = new ArrayList<>();
+ if(obj.getRealNames() !=null){
+ String[] realNames = obj.getRealNames().intern().split("、");
+ String[] userIds = obj.getUserIds().intern().split("、");
+ //人员对象数组
+ for (int i = 0; i < realNames.length; i++) {
+ RegionInspectionUserEntity userEntity = RegionInspectionUserEntity
+ .builder()
+ .regionInspectionId(obj.getId())
+ .userId(userIds[i])
+ .realName(realNames[i]).build();
+ userList.add(userEntity);
+ }
+ }
+ if (obj.getRegionIds()!=null){
+ String[] regionIds = obj.getRegionIds().intern().split(",");
+ String[] regions = obj.getRegions().intern().split(",");
+ //区域对象数组
+ for (int i = 0; i < regionIds.length; i++) {
+ RegionInspectionHazardInformEntity regionEntity = RegionInspectionHazardInformEntity
+ .builder()
+ .regionInspectionId(obj.getId())
+ .regionHazardInformId(regionIds[i])
+ .region(regions[i]).build();
+ regionList.add(regionEntity);
+ }
+ }
+ obj.setRegionList(regionList);
+ obj.setRegionUsersList(userList);
+ });
+ return BasicResult.success(new PageInfo<>(regionInspectionEntities));
+ }
+
+}
--
Gitblit v1.9.3