diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/config/ExceptionEnum.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/config/ExceptionEnum.java index d31b9ad..df44374 100644 --- a/bonus-modules/bonus-base/src/main/java/com/bonus/base/config/ExceptionEnum.java +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/config/ExceptionEnum.java @@ -23,6 +23,7 @@ public enum ExceptionEnum { UN_BIND_TO_DATABASE(500, "解散失败,请联系管理员"), EXISTENCE_OF_MEMBERS(1005, "班组中还存在成员,无法解散"), EXISTENCE_OF_HELMET(1008, "该班组人员绑定相关安全帽,无法解散"), + DELETE_BIND_DEVICE(1010, "该设备还绑定相关人员,无法删除"), EXISTENCE_OF_BIND(1006, "该人员还绑定相关设备,无法移出"), UPDATE_TO_DATABASE(500, "修改失败,请联系管理员"), BIND_TO_DATABASE(500, "人员设备绑定失败,请联系管理员"), diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/domain/TbPeople.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/domain/TbPeople.java index b54a354..9461f4b 100644 --- a/bonus-modules/bonus-base/src/main/java/com/bonus/base/domain/TbPeople.java +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/domain/TbPeople.java @@ -99,5 +99,7 @@ public class TbPeople implements Serializable { */ private String devName; + private Long relId; + } diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/domain/TbProject.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/domain/TbProject.java index 71f25a7..1378934 100644 --- a/bonus-modules/bonus-base/src/main/java/com/bonus/base/domain/TbProject.java +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/domain/TbProject.java @@ -95,5 +95,10 @@ public class TbProject implements Serializable { */ private Long updateUser; + /** + * 工程编码 + */ + private String proCode; + } diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/mapper/TbDeviceMapper.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/mapper/TbDeviceMapper.java index 25206ee..6c7d58e 100644 --- a/bonus-modules/bonus-base/src/main/java/com/bonus/base/mapper/TbDeviceMapper.java +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/mapper/TbDeviceMapper.java @@ -76,4 +76,11 @@ public interface TbDeviceMapper { DeviceTypeEnum leadStrainMonitor); List getDeviceModelDetailsPage(TbDevice tbDevice); + + /** + * 根据主键查询是否被人员绑定 + * @param id + * @return + */ + int getById(Long id); } \ No newline at end of file diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/mapper/TbPeopleMapper.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/mapper/TbPeopleMapper.java index 48aa3bd..0541ec4 100644 --- a/bonus-modules/bonus-base/src/main/java/com/bonus/base/mapper/TbPeopleMapper.java +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/mapper/TbPeopleMapper.java @@ -65,8 +65,11 @@ public interface TbPeopleMapper { */ List queryPeoplePositionByProId(@Param("proId") Integer proId); - - - + /** + * 根据人员ID修改 + * @param id + * @return + */ + int updateById(Long id); } diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/service/impl/TbDeviceServiceImpl.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/service/impl/TbDeviceServiceImpl.java index 0ad954c..9c45e19 100644 --- a/bonus-modules/bonus-base/src/main/java/com/bonus/base/service/impl/TbDeviceServiceImpl.java +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/service/impl/TbDeviceServiceImpl.java @@ -30,6 +30,11 @@ public class TbDeviceServiceImpl implements TbDeviceService{ */ @Override public AjaxResult deleteByPrimaryKey(Long id) { + //根据id判断改设备是否被绑定,被绑定则不能删除 + int count = tbDeviceMapper.getById(id); + if (count > 0) { + return AjaxResult.error(ExceptionEnum.DELETE_BIND_DEVICE.getCode(), ExceptionEnum.DELETE_BIND_DEVICE.getMsg()); + } int result = tbDeviceMapper.deleteByPrimaryKey(id); if (result > 0) { return AjaxResult.success(ExceptionEnum.SUCCESS.getMsg(), result); diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/service/impl/TbPeopleServiceImpl.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/service/impl/TbPeopleServiceImpl.java index bf6b795..72771ea 100644 --- a/bonus-modules/bonus-base/src/main/java/com/bonus/base/service/impl/TbPeopleServiceImpl.java +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/service/impl/TbPeopleServiceImpl.java @@ -83,17 +83,6 @@ public class TbPeopleServiceImpl implements TbPeopleService { people.setRelPhone(Sm4Utils.decode(people.getRelPhone())); } }); - // 使用流对条件进行过滤 - Stream stream = peopleList.stream(); - if (tbPeople.getRelName() != null) { - stream = stream.filter(people -> StringUtils.contains(people.getRelName(), tbPeople.getRelName())); - } - if (tbPeople.getSex() != null) { - stream = stream.filter(people -> people.getSex().equals(tbPeople.getSex())); - } - - // 收集过滤后的结果 - peopleList = stream.collect(Collectors.toList()); } return peopleList; } diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/service/impl/TbTeamServiceImpl.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/service/impl/TbTeamServiceImpl.java index 0d93a77..2625e91 100644 --- a/bonus-modules/bonus-base/src/main/java/com/bonus/base/service/impl/TbTeamServiceImpl.java +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/service/impl/TbTeamServiceImpl.java @@ -128,6 +128,7 @@ public class TbTeamServiceImpl implements TbTeamService { tbTeam.setRelPhone(Sm4Utils.encode(tbTeam.getRelPhone())); } result += tbTeamDao.insert(tbTeam); + result += tbTeamDao.insertPeople(tbTeam.getTeamId(), tbTeam.getRelId()); if (CollectionUtils.isNotEmpty(tbTeam.getIdList())) { //将班组id插入到班组人员表 for (Long id : tbTeam.getIdList()) { @@ -165,7 +166,11 @@ public class TbTeamServiceImpl implements TbTeamService { result += tbTeamDao.updatePeople(tbTeam.getId()); //修改 tbTeam.setUpdateUser(SecurityUtils.getUserId()); + if (StringUtils.isNotBlank(tbTeam.getRelPhone())) { + tbTeam.setRelPhone(Sm4Utils.encode(tbTeam.getRelPhone())); + } result += tbTeamDao.update(tbTeam); + result += tbTeamDao.insertPeople(tbTeam.getId(), tbTeam.getRelId()); if (CollectionUtils.isNotEmpty(tbTeam.getIdList())) { //将班组id插入到班组人员表 for (Long id : tbTeam.getIdList()) { @@ -187,7 +192,7 @@ public class TbTeamServiceImpl implements TbTeamService { @Override public AjaxResult deleteById(Long id) { //根据id去查询班组中是否存在成员,存在则不能解散 - if (tbTeamDao.getList(id).size() > 0) { + if (tbTeamDao.getList(id).size() > 1) { return AjaxResult.error(ExceptionEnum.EXISTENCE_OF_MEMBERS.getCode(), ExceptionEnum.EXISTENCE_OF_MEMBERS.getMsg()); } //根据id查询该班组长是否绑定安全帽,绑定则不允许解散 @@ -196,6 +201,8 @@ public class TbTeamServiceImpl implements TbTeamService { return AjaxResult.error(ExceptionEnum.EXISTENCE_OF_HELMET.getCode(), ExceptionEnum.EXISTENCE_OF_HELMET.getMsg()); } int result = tbTeamDao.updateById(id); + //根据班组id去人员表中解绑班组长 + result += tbPeopleMapper.updateById(id); if (result > 0) { return AjaxResult.success(ExceptionEnum.SUCCESS.getMsg(), result); } diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/screen/service/impl/ProjectDetailsViewServiceImpl.java b/bonus-modules/bonus-base/src/main/java/com/bonus/screen/service/impl/ProjectDetailsViewServiceImpl.java index 179bfbe..63e1547 100644 --- a/bonus-modules/bonus-base/src/main/java/com/bonus/screen/service/impl/ProjectDetailsViewServiceImpl.java +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/screen/service/impl/ProjectDetailsViewServiceImpl.java @@ -1,5 +1,6 @@ package com.bonus.screen.service.impl; +import com.alibaba.nacos.common.utils.CollectionUtils; import com.bonus.common.core.web.domain.AjaxResult; import com.bonus.data.entity.DevAttributeVo; import com.bonus.screen.mapper.TbDeviceDataRecord; @@ -64,7 +65,7 @@ public class ProjectDetailsViewServiceImpl { public AjaxResult getTowerDevAttributeWarnRecord(Integer proId) { List records = tbDeviceDataRecordMapper.getTowerDevAttributeWarnRecord(proId); if (records.isEmpty()) { - return AjaxResult.error("暂无数据"); + return AjaxResult.success("暂无数据"); } return AjaxResult.success(records); } @@ -72,7 +73,7 @@ public class ProjectDetailsViewServiceImpl { public AjaxResult getPitDevAttributeWarnRecord(Integer proId) { List records = tbDeviceDataRecordMapper.getPitDevAttributeWarnRecord(proId); if (records.isEmpty()) { - return AjaxResult.error("暂无数据"); + return AjaxResult.success("暂无数据"); } return AjaxResult.success(records); } diff --git a/bonus-modules/bonus-base/src/main/resources/mapper/base/TbDeviceMapper.xml b/bonus-modules/bonus-base/src/main/resources/mapper/base/TbDeviceMapper.xml index bac9025..8b16880 100644 --- a/bonus-modules/bonus-base/src/main/resources/mapper/base/TbDeviceMapper.xml +++ b/bonus-modules/bonus-base/src/main/resources/mapper/base/TbDeviceMapper.xml @@ -337,4 +337,10 @@ and td.dev_code like concat('%',#{devCode},'%') + + diff --git a/bonus-modules/bonus-base/src/main/resources/mapper/base/TbPeopleMapper.xml b/bonus-modules/bonus-base/src/main/resources/mapper/base/TbPeopleMapper.xml index 1430cbd..1425add 100644 --- a/bonus-modules/bonus-base/src/main/resources/mapper/base/TbPeopleMapper.xml +++ b/bonus-modules/bonus-base/src/main/resources/mapper/base/TbPeopleMapper.xml @@ -11,21 +11,19 @@ SELECT - tp.id_card, - tp.rel_name, - tp.dev_id, + tp.id_card as idCard, + tp.rel_name as relName, + tp.dev_id as devId, tp.team_id AS teamId, - tt.team_name, - tt.pro_id, - project.pro_name, - device.dev_code, + tt.team_name as teamName, + tt.pro_id as proId, + project.pro_name as proName, + device.dev_code as devCode, MAX(CASE WHEN tda.jc_name = '经度' THEN tda.jc_value END) AS lon, MAX(CASE WHEN tda.jc_name = '纬度' THEN tda.jc_value END) AS lat diff --git a/bonus-modules/bonus-base/src/main/resources/mapper/base/TbProjectMapper.xml b/bonus-modules/bonus-base/src/main/resources/mapper/base/TbProjectMapper.xml index 4850b61..b9b8d14 100644 --- a/bonus-modules/bonus-base/src/main/resources/mapper/base/TbProjectMapper.xml +++ b/bonus-modules/bonus-base/src/main/resources/mapper/base/TbProjectMapper.xml @@ -109,6 +109,7 @@ lat, create_time, create_user, + pro_code, del_flag @@ -122,6 +123,7 @@ #{lat}, NOW(), #{createUser}, + #{proCode}, 0 @@ -161,6 +163,9 @@ update_user = #{updateUser}, + + pro_code = #{proCode}, + where id = #{id} diff --git a/bonus-modules/bonus-base/src/main/resources/mapper/base/TbTeamMapper.xml b/bonus-modules/bonus-base/src/main/resources/mapper/base/TbTeamMapper.xml index a0421be..cf3e64b 100644 --- a/bonus-modules/bonus-base/src/main/resources/mapper/base/TbTeamMapper.xml +++ b/bonus-modules/bonus-base/src/main/resources/mapper/base/TbTeamMapper.xml @@ -8,7 +8,7 @@ relName, tt.rel_phone as relPhone, tt.pro_id as proId, tt.pro_name as proName, tt.create_time as createTime, tt.create_user as createUser, tt.update_time as updateTime, tt.js_time as jsTime, tt.update_user as updateUser, tt.del_flag as delFlag, - (count(tp.team_id) + 1) as peopleCount, + count(tp.team_id) as peopleCount, CASE WHEN tt.js_time is null THEN '正常' ELSE '已解散' @@ -40,8 +40,19 @@ diff --git a/bonus-modules/bonus-base/src/main/resources/mapper/screen/TbDeviceDataRecordMapper.xml b/bonus-modules/bonus-base/src/main/resources/mapper/screen/TbDeviceDataRecordMapper.xml index ead81c2..a20775b 100644 --- a/bonus-modules/bonus-base/src/main/resources/mapper/screen/TbDeviceDataRecordMapper.xml +++ b/bonus-modules/bonus-base/src/main/resources/mapper/screen/TbDeviceDataRecordMapper.xml @@ -4,8 +4,8 @@ SELECT - tddr.dev_id,tddr.dev_name,tddr.dev_type,tddr.attribute_name as jcName,tddr.attribute_val as jcValue, - tddr.is_warn,tddr.create_time as jcTime + tddr.dev_id as devId,tddr.dev_name as devName,tddr.dev_type as devType,tddr.attribute_name as jcName,tddr.attribute_val as jcValue, + tddr.is_warn as isWarn,tddr.create_time as jcTime FROM tb_dev_data_record AS tddr LEFT JOIN tb_device device ON device.id = tddr.dev_id LEFT JOIN tb_bd_device_record tbdr ON tbdr.id = device.bd_id @@ -84,8 +84,8 @@ SELECT - tddr.dev_id,tddr.dev_name,tddr.dev_type,tddr.attribute_name as jcName,tddr.attribute_val as jcValue, - tddr.is_warn,tddr.create_time as jcTime + tddr.dev_id as devId,tddr.dev_name as devName,tddr.dev_type as devType,tddr.attribute_name as jcName,tddr.attribute_val as jcValue, + tddr.is_warn as isWarn,tddr.create_time as jcTime FROM tb_dev_data_record AS tddr WHERE tddr.dev_id = #{devId} AND tddr.attribute_name IN ('一氧化碳', '可燃气体', '含氧量','硫化氢') @@ -117,8 +117,8 @@ SELECT - tddr.dev_id,tddr.dev_name,tddr.dev_type,tddr.attribute_name as jcName,tddr.attribute_val as jcValue, - tddr.is_warn,tddr.create_time as jcTime + tddr.dev_id as devId,tddr.dev_name as devName,tddr.dev_type as devType,tddr.attribute_name as jcName,tddr.attribute_val as jcValue, + tddr.is_warn as isWarn,tddr.create_time as jcTime FROM tb_dev_data_record AS tddr LEFT JOIN tb_device device ON device.id = tddr.dev_id diff --git a/bonus-modules/bonus-base/src/main/resources/template/TbPeopleTemplate.xlsx b/bonus-modules/bonus-base/src/main/resources/template/TbPeopleTemplate.xlsx index 9e5035b..f32b35f 100644 Binary files a/bonus-modules/bonus-base/src/main/resources/template/TbPeopleTemplate.xlsx and b/bonus-modules/bonus-base/src/main/resources/template/TbPeopleTemplate.xlsx differ diff --git a/bonus-modules/bonus-data/pom.xml b/bonus-modules/bonus-data/pom.xml deleted file mode 100644 index 3da46d3..0000000 --- a/bonus-modules/bonus-data/pom.xml +++ /dev/null @@ -1,123 +0,0 @@ - - - - com.bonus - bonus-modules - 24.8.0 - - 4.0.0 - - bonus-data - - - bonus-modules-data 数据中心服务 - - - - - - - com.alibaba.cloud - spring-cloud-starter-alibaba-nacos-discovery - - - - - com.alibaba.cloud - spring-cloud-starter-alibaba-nacos-config - - - - - com.alibaba.cloud - spring-cloud-starter-alibaba-sentinel - - - - - org.springframework.boot - spring-boot-starter-actuator - - - - - - - com.mysql - mysql-connector-j - - - - - com.bonus - bonus-common-datasource - - - - com.bonus - bonus-common-core - - - - - com.bonus - bonus-common-datascope - - - com.bonus - bonus-common-swagger - - - com.bonus - bonus-common-log - - - - - com.bonus - bonus-common-log - - - - - com.bonus - bonus-common-swagger - - - com.google.guava - guava - 30.0-jre - compile - - - com.bonus - bonus-common-security - - - com.google.code.gson - gson - - - - - - ${project.artifactId} - - - org.springframework.boot - spring-boot-maven-plugin - - - - repackage - - - - - - - - - \ No newline at end of file diff --git a/bonus-modules/bonus-data/src/main/java/com/bonus/data/BonusDataApplication.java b/bonus-modules/bonus-data/src/main/java/com/bonus/data/BonusDataApplication.java deleted file mode 100644 index 58e2129..0000000 --- a/bonus-modules/bonus-data/src/main/java/com/bonus/data/BonusDataApplication.java +++ /dev/null @@ -1,33 +0,0 @@ -package com.bonus.data; - -import com.bonus.common.security.annotation.EnableCustomConfig; -import com.bonus.common.security.annotation.EnableRyFeignClients; -import com.bonus.common.swagger.annotation.EnableCustomSwagger2; -import org.springframework.boot.SpringApplication; -import org.springframework.boot.autoconfigure.SpringBootApplication; -import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration; - -/** - * base基础模块启动服务 - * @author ma_sh - */ - -@EnableCustomConfig -@EnableCustomSwagger2 -@EnableRyFeignClients -@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class }) -public class BonusDataApplication { - public static void main(String[] args) { - SpringApplication.run(BonusDataApplication.class, args); - System.err.println("(♥◠‿◠)ノ゙ 数据中心服务启动成功 ლ(´ڡ`ლ)゙ \n" + - " .-------. ____ __ \n" + - " | _ _ \\ \\ \\ / / \n" + - " | ( ' ) | \\ _. / ' \n" + - " |(_ o _) / _( )_ .' \n" + - " | (_,_).' __ ___(_ o _)' \n" + - " | |\\ \\ | || |(_,_)' \n" + - " | | \\ `' /| `-' / \n" + - " | | \\ / \\ / \n" + - " ''-' `'-' `-..-' "); - } -} \ No newline at end of file diff --git a/bonus-modules/bonus-data/src/main/resources/banner.txt b/bonus-modules/bonus-data/src/main/resources/banner.txt deleted file mode 100644 index 27cacb9..0000000 --- a/bonus-modules/bonus-data/src/main/resources/banner.txt +++ /dev/null @@ -1,10 +0,0 @@ -Spring Boot Version: ${spring-boot.version} -Spring Application Name: ${spring.application.name} - _ __ _ _ - (_) / _|(_)| | - _ __ _ _ ___ _ _ _ ______ | |_ _ | | ___ -| '__|| | | | / _ \ | | | || ||______|| _|| || | / _ \ -| | | |_| || (_) || |_| || | | | | || || __/ -|_| \__,_| \___/ \__, ||_| |_| |_||_| \___| - __/ | - |___/ \ No newline at end of file diff --git a/bonus-modules/bonus-data/src/main/resources/bootstrap.yml b/bonus-modules/bonus-data/src/main/resources/bootstrap.yml deleted file mode 100644 index 66f2933..0000000 --- a/bonus-modules/bonus-data/src/main/resources/bootstrap.yml +++ /dev/null @@ -1,29 +0,0 @@ -# Tomcat -server: - port: 18089 -# Spring -spring: - application: - # 应用名称 - name: bonus-data - profiles: - # 环境配置 - active: dev - cloud: - nacos: - username: nacos - password: Jjsp@nacos2023 - discovery: - # 服务注册地址 - server-addr: 127.0.0.1:8848 - namespace: bns-public - config: - # 配置中心地址 - server-addr: 127.0.0.1:8848 - namespace: bns-public - # 配置文件格式 - file-extension: yml - # 共享配置 - shared-configs: - - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} - diff --git a/bonus-modules/bonus-data/src/main/resources/logback.xml b/bonus-modules/bonus-data/src/main/resources/logback.xml deleted file mode 100644 index 7c7bf48..0000000 --- a/bonus-modules/bonus-data/src/main/resources/logback.xml +++ /dev/null @@ -1,74 +0,0 @@ - - - - - - - - - - - ${log.pattern} - - - - - - ${log.path}/info.log - - - - ${log.path}/info.%d{yyyy-MM-dd}.log - - 60 - - - ${log.pattern} - - - - INFO - - ACCEPT - - DENY - - - - - ${log.path}/error.log - - - - ${log.path}/error.%d{yyyy-MM-dd}.log - - 60 - - - ${log.pattern} - - - - ERROR - - ACCEPT - - DENY - - - - - - - - - - - - - - - - - -