|
@@ -1,7 +1,9 @@
|
|
|
package com.huimv.center.listener;
|
|
|
|
|
|
+import com.huimv.center.pojo.BizBaseArea;
|
|
|
import com.huimv.center.pojo.BizDeviceRegister;
|
|
|
import com.huimv.center.pojo.BizFarm;
|
|
|
+import com.huimv.center.service.BizBaseAreaService;
|
|
|
import com.huimv.center.service.BizDeviceRegisterService;
|
|
|
import com.huimv.center.service.BizFarmService;
|
|
|
import com.huimv.center.utils.Const;
|
|
@@ -32,6 +34,9 @@ public class SysBaseConfigListener {
|
|
|
@Resource
|
|
|
private BizDeviceRegisterService bizDeviceRegisterService;
|
|
|
|
|
|
+ @Resource
|
|
|
+ private BizBaseAreaService bizBaseAreaService;
|
|
|
+
|
|
|
|
|
|
@RabbitListener(queues = Const.QUEUE_SYNC_SYS_CONFIG)
|
|
|
@RabbitHandler
|
|
@@ -40,19 +45,22 @@ public class SysBaseConfigListener {
|
|
|
System.out.println("======================收到基础配置信息同步"+params);
|
|
|
//查询牧场表是否有数据
|
|
|
String farmCode = params.get("farmCode");
|
|
|
- String chipId = params.get("chipId");
|
|
|
- String deviceCode = params.get("deviceCode");
|
|
|
+ String areaName = params.get("areaCode");
|
|
|
+ String substring = areaName.substring(areaName.length() - 6);
|
|
|
+
|
|
|
+ BizBaseArea bizBaseArea = bizBaseAreaService.queryAreaName(substring);
|
|
|
+
|
|
|
String bizFarmByFarmCode = bizFarmService.getBizFarmByFarmCode(farmCode);
|
|
|
System.out.println("-------------------"+bizFarmByFarmCode);
|
|
|
if (StringUtils.isBlank(bizFarmByFarmCode)){
|
|
|
//插入数据
|
|
|
- bizFarmService.save(params.get("areaName"),farmCode,"","","",params.get("areaName"));
|
|
|
+ bizFarmService.save(params.get("farmName"),farmCode,"","","",bizBaseArea.getAreaName());
|
|
|
insertRegistration(params);
|
|
|
}else {
|
|
|
System.out.println("******************查到了数据******");
|
|
|
BizFarm bizFarm = bizFarmService.getBizFarm(farmCode);
|
|
|
//1、更新农场表
|
|
|
- bizFarmService.edit(bizFarm.getId(),params.get("areaName"),farmCode,"","","",params.get("areaName"));
|
|
|
+ bizFarmService.edit(bizFarm.getId(),params.get("farmName"),farmCode,"","","",bizBaseArea.getAreaName());
|
|
|
//2、更新注册表中数据
|
|
|
insertRegistration(params);
|
|
|
}
|
|
@@ -72,7 +80,7 @@ public class SysBaseConfigListener {
|
|
|
List<BizDeviceRegister> oneByChipIdAndDeviceCode = bizDeviceRegisterService.getOneByChipIdAndDeviceCode(chipId, deviceCode);
|
|
|
if (null == oneByChipIdAndDeviceCode || oneByChipIdAndDeviceCode.size() == 0){
|
|
|
//插入数据到注册表中
|
|
|
- bizDeviceRegisterService.add(params.get("areaName"),farmCode,chipId,deviceCode,params.get("ip"),params.get("port"),"");
|
|
|
+ bizDeviceRegisterService.add(params.get("farmName"),farmCode,chipId,deviceCode,params.get("ip"),params.get("port"),"");
|
|
|
}else {
|
|
|
//更新注册表
|
|
|
BizDeviceRegister bizDeviceRegister = oneByChipIdAndDeviceCode.get(0);
|