|
@@ -44,6 +44,7 @@ public class DeviceRegisterServiceImpl implements IDeviceRegisterService {
|
|
|
@Autowired
|
|
|
private com.huimv.eartag2.manage.producer.ManageProducer producer;
|
|
|
|
|
|
+ private static String FARM_CODE = "101";
|
|
|
@Override
|
|
|
public Result addDevice(String chipId, String deviceCode, Integer deviceStatus, Integer activeStatus, String deviceAlias, String location, String remark, String farmId) throws ParseException {
|
|
|
DateUtil dateUtil = new DateUtil();
|
|
@@ -315,9 +316,8 @@ public class DeviceRegisterServiceImpl implements IDeviceRegisterService {
|
|
|
|
|
|
@Override
|
|
|
public void fanoutSyncDevice(Map<String,String> map) throws ParseException {
|
|
|
- if ( "101".equals(map.get("farmCode"))){
|
|
|
+ if ( "FARM_CODE".equals(map.get("farmCode"))){
|
|
|
//说明消息中的数据是该业务平台的,进行数据持久化
|
|
|
-
|
|
|
EartagDeviceRegisterEntity deviceRegisterEntity = new EartagDeviceRegisterEntity();
|
|
|
deviceRegisterEntity.setChipId(map.get("chipId").trim());
|
|
|
deviceRegisterEntity.setDeviceCode(map.get("deviceCode").trim());
|