|
@@ -92,7 +92,6 @@ public class EartagServiceImpl implements IEartagService {
|
|
private BasePigpenEntityRepo basePigpenRepo;
|
|
private BasePigpenEntityRepo basePigpenRepo;
|
|
@Autowired
|
|
@Autowired
|
|
private BizBaseStageEntityRepo bizBaseStageRepo;
|
|
private BizBaseStageEntityRepo bizBaseStageRepo;
|
|
-
|
|
|
|
@Override
|
|
@Override
|
|
public void handleEartag(JSONObject dataJo) throws ParseException {
|
|
public void handleEartag(JSONObject dataJo) throws ParseException {
|
|
//设备编码
|
|
//设备编码
|
|
@@ -593,12 +592,12 @@ public class EartagServiceImpl implements IEartagService {
|
|
Integer unitId = eartagEartagRegister2Entity.getUnitId();
|
|
Integer unitId = eartagEartagRegister2Entity.getUnitId();
|
|
Optional<EartagOnlineStatusEntity> optionEartagStatus = eartagOnlineStatusEntityRepo.findLastOne(farmId, unitId);
|
|
Optional<EartagOnlineStatusEntity> optionEartagStatus = eartagOnlineStatusEntityRepo.findLastOne(farmId, unitId);
|
|
if (!optionEartagStatus.isPresent()) {
|
|
if (!optionEartagStatus.isPresent()) {
|
|
- System.out.println("该记录不存在");
|
|
|
|
|
|
+ log.error("该记录不存在");
|
|
return;
|
|
return;
|
|
}
|
|
}
|
|
EartagOnlineStatusEntity eartagOnlineStatusEntity = optionEartagStatus.get();
|
|
EartagOnlineStatusEntity eartagOnlineStatusEntity = optionEartagStatus.get();
|
|
- System.out.println("onlineEarmark=" + eartagOnlineStatusEntity.getOnlineEarmark());
|
|
|
|
- System.out.println("offlineEarmark=" + eartagOnlineStatusEntity.getOfflineEarmark());
|
|
|
|
|
|
+// System.out.println("onlineEarmark=" + eartagOnlineStatusEntity.getOnlineEarmark());
|
|
|
|
+// System.out.println("offlineEarmark=" + eartagOnlineStatusEntity.getOfflineEarmark());
|
|
if (eartagOnlineStatusEntity.getOnlineEarmark().indexOf(earmark) == -1 && eartagOnlineStatusEntity.getOfflineEarmark().indexOf(earmark) == -1) {
|
|
if (eartagOnlineStatusEntity.getOnlineEarmark().indexOf(earmark) == -1 && eartagOnlineStatusEntity.getOfflineEarmark().indexOf(earmark) == -1) {
|
|
//新耳标(在线,离线都不包含该耳标)
|
|
//新耳标(在线,离线都不包含该耳标)
|
|
log.info("耳标连线状态统计:增加新耳标[" + earmark + "]");
|
|
log.info("耳标连线状态统计:增加新耳标[" + earmark + "]");
|