Browse Source

1、批量插入设备信息优化;

dev
25604 2 weeks ago
parent
commit
1fbeb593d0
  1. 4
      user-service/src/main/java/com/mh/user/controller/DeviceInstallController.java
  2. 3
      user-service/src/main/java/com/mh/user/mapper/BuildingMapper.java
  3. 4
      user-service/src/main/java/com/mh/user/mapper/DeviceInstallMapper.java
  4. 2
      user-service/src/main/java/com/mh/user/service/BuildingService.java
  5. 2
      user-service/src/main/java/com/mh/user/service/DeviceInstallService.java
  6. 5
      user-service/src/main/java/com/mh/user/service/impl/BuildingServiceImpl.java
  7. 13
      user-service/src/main/java/com/mh/user/service/impl/DeviceInstallServiceImpl.java
  8. 16
      user-service/src/main/resources/application-prod.yml

4
user-service/src/main/java/com/mh/user/controller/DeviceInstallController.java

@ -280,7 +280,7 @@ public class DeviceInstallController {
uploadEntity.setBrand(deviceList.get(6));//品牌 uploadEntity.setBrand(deviceList.get(6));//品牌
uploadEntity.setModel(deviceList.get(7));//型号 uploadEntity.setModel(deviceList.get(7));//型号
uploadEntity.setInstaller(deviceList.get(8));//安装人员 uploadEntity.setInstaller(deviceList.get(8));//安装人员
uploadEntity.setBuildingId(deviceList.get(9));//所属楼栋 uploadEntity.setBuildingName(deviceList.get(9));//所属楼栋
if (deviceList.get(10).equals("是")){ if (deviceList.get(10).equals("是")){
uploadEntity.setIsUse(1); uploadEntity.setIsUse(1);
}else{ }else{
@ -289,7 +289,7 @@ public class DeviceInstallController {
deviceList.clear(); deviceList.clear();
uploadEntityList.add(uploadEntity); uploadEntityList.add(uploadEntity);
is=deviceInstallService.selectDeviceCount(uploadEntity.getDeviceAddr(),uploadEntity.getDeviceType()); is=deviceInstallService.selectDeviceCount(uploadEntity.getBuildingName(),uploadEntity.getDeviceAddr(),uploadEntity.getDeviceType());
if (is>0){ if (is>0){
httpResult.setMsg("通讯编号有重复!"); httpResult.setMsg("通讯编号有重复!");
httpResult.setCode(500); httpResult.setCode(500);

3
user-service/src/main/java/com/mh/user/mapper/BuildingMapper.java

@ -146,4 +146,7 @@ public interface BuildingMapper {
@Select("select sum(check_in_count) from building where area_id = #{areaId} ") @Select("select sum(check_in_count) from building where area_id = #{areaId} ")
int queryCheckInCount(@Param("areaId") String areaId); int queryCheckInCount(@Param("areaId") String areaId);
@Select("select top 1 id from building where building_name = #{buildingName} ")
Integer selectBuildingIdByName(String buildingName);
} }

4
user-service/src/main/java/com/mh/user/mapper/DeviceInstallMapper.java

@ -166,8 +166,8 @@ public interface DeviceInstallMapper extends BaseMapper<DeviceInstallEntity> {
DeviceInstallEntity selectDevice(@Param("deviceAddr") String deviceAddr,@Param("deviceType") String deviceType,@Param("buildingId") String buildingId); DeviceInstallEntity selectDevice(@Param("deviceAddr") String deviceAddr,@Param("deviceType") String deviceType,@Param("buildingId") String buildingId);
//查询通讯编号是否存在 //查询通讯编号是否存在
@Select("select count(*) from device_install where device_addr=#{deviceAddr} and device_type=#{deviceType} ") @Select("select count(*) from device_install where device_addr=#{deviceAddr} and device_type=#{deviceType} and building_name = #{buildingName} ")
int selectDeviceCount(@Param("deviceAddr") String deviceAddr,@Param("deviceType") String deviceType); int selectDeviceCount(@Param("buildingName") String buildingName, @Param("deviceAddr") String deviceAddr,@Param("deviceType") String deviceType);
/** /**
* 设备管理模块 * 设备管理模块
* 根据通讯地址删除设备信息 * 根据通讯地址删除设备信息

2
user-service/src/main/java/com/mh/user/service/BuildingService.java

@ -81,4 +81,6 @@ public interface BuildingService {
List<String> queryBuildingIdListByAreaId(String areaId); List<String> queryBuildingIdListByAreaId(String areaId);
int queryCheckInCount(String areaId); int queryCheckInCount(String areaId);
Integer selectBuildingIdByName(String buildingName);
} }

2
user-service/src/main/java/com/mh/user/service/DeviceInstallService.java

@ -93,7 +93,7 @@ public interface DeviceInstallService {
DeviceInstallEntity selectDevice(String deviceAddr,String deviceType,String buildingId); DeviceInstallEntity selectDevice(String deviceAddr,String deviceType,String buildingId);
//查询通讯编号是否存在 //查询通讯编号是否存在
int selectDeviceCount(String deviceAddr,String deviceType); int selectDeviceCount(String buildingName, String deviceAddr,String deviceType);
/** /**
* 设备管理模块 * 设备管理模块
* 根据通讯地址删除设备信息 * 根据通讯地址删除设备信息

5
user-service/src/main/java/com/mh/user/service/impl/BuildingServiceImpl.java

@ -214,4 +214,9 @@ public class BuildingServiceImpl implements BuildingService {
public int queryCheckInCount(String areaId) { public int queryCheckInCount(String areaId) {
return buildingMapper.queryCheckInCount(areaId); return buildingMapper.queryCheckInCount(areaId);
} }
@Override
public Integer selectBuildingIdByName(String buildingName) {
return buildingMapper.selectBuildingIdByName(buildingName);
}
} }

13
user-service/src/main/java/com/mh/user/service/impl/DeviceInstallServiceImpl.java

@ -1,5 +1,6 @@
package com.mh.user.service.impl; package com.mh.user.service.impl;
import com.github.pagehelper.util.StringUtil;
import com.mh.user.entity.DeviceCodeParamEntity; import com.mh.user.entity.DeviceCodeParamEntity;
import com.mh.user.entity.DeviceInstallEntity; import com.mh.user.entity.DeviceInstallEntity;
import com.mh.user.entity.DeviceInstallTempEntity; import com.mh.user.entity.DeviceInstallTempEntity;
@ -40,8 +41,12 @@ public class DeviceInstallServiceImpl implements DeviceInstallService {
@Override @Override
public int saveDevice(DeviceInstallEntity deviceInstallEntity) { public int saveDevice(DeviceInstallEntity deviceInstallEntity) {
String buildingName = buildingService.selectBuildingNameById(deviceInstallEntity.getBuildingId()); if (StringUtil.isEmpty(deviceInstallEntity.getBuildingId()) && !StringUtil.isEmpty(deviceInstallEntity.getBuildingName())) {
deviceInstallEntity.setBuildingName(buildingName); Integer buildingId = buildingService.selectBuildingIdByName(deviceInstallEntity.getBuildingName());
deviceInstallEntity.setBuildingId(String.valueOf(buildingId));
} else if (StringUtil.isEmpty(deviceInstallEntity.getBuildingName()) && !StringUtil.isEmpty(deviceInstallEntity.getBuildingId())) {
deviceInstallEntity.setBuildingName(buildingService.selectBuildingNameById(deviceInstallEntity.getBuildingId()));
}
if ("电表".equalsIgnoreCase(deviceInstallEntity.getDeviceType())) { if ("电表".equalsIgnoreCase(deviceInstallEntity.getDeviceType())) {
// 000005500773 // 000005500773
deviceInstallEntity.setDeviceAddr(ExchangeStringUtil.addZeroForNum(deviceInstallEntity.getDeviceAddr(), 12)); deviceInstallEntity.setDeviceAddr(ExchangeStringUtil.addZeroForNum(deviceInstallEntity.getDeviceAddr(), 12));
@ -273,8 +278,8 @@ public class DeviceInstallServiceImpl implements DeviceInstallService {
} }
@Override @Override
public int selectDeviceCount(String deviceAddr, String deviceType) { public int selectDeviceCount(String buildingName, String deviceAddr, String deviceType) {
return deviceInstallMapper.selectDeviceCount(deviceAddr, deviceType); return deviceInstallMapper.selectDeviceCount(buildingName, deviceAddr, deviceType);
} }
@Override @Override

16
user-service/src/main/resources/application-prod.yml

@ -19,10 +19,10 @@ spring:
# username: test # username: test
# password: minghan123456@ # password: minghan123456@
# #华厦云服务器 # #华厦云服务器
# url: jdbc:sqlserver://127.0.0.1:1433;DatabaseName=CHWS;allowMultiQueries=true url: jdbc:sqlserver://127.0.0.1:1433;DatabaseName=CHWS;allowMultiQueries=true
# driver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriver driver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriver
# username: chws username: chws
# password: minghan123456@ password: minghan123456@
#创新服务器 #创新服务器
# url: jdbc:sqlserver://106.55.173.225:57238;DatabaseName=chws_chx;allowMultiQueries=true # url: jdbc:sqlserver://106.55.173.225:57238;DatabaseName=chws_chx;allowMultiQueries=true
# driver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriver # driver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriver
@ -59,10 +59,10 @@ spring:
# password: chws_gw@803 # password: chws_gw@803
# 华软江门 # 华软江门
url: jdbc:sqlserver://127.0.0.1:57238;DatabaseName=chws_jm;allowMultiQueries=true # url: jdbc:sqlserver://127.0.0.1:57238;DatabaseName=chws_jm;allowMultiQueries=true
driver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriver # driver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriver
username: chws_jm # username: chws_jm
password: Mhtech@803 # password: Mhtech@803
filters: stat,wall,config filters: stat,wall,config
max-active: 100 max-active: 100

Loading…
Cancel
Save