src/main/java/com/zy/core/thread/SiemensDevpThread.java
@@ -198,6 +198,25 @@ staProtocol.setPakMk(true); } } // 根据实时信息更新数据库 try { List<BasDevp> basDevps = new ArrayList<>(); for (Integer siteId2 : staNos) { StaProtocol staProtocol2 = station.get(siteId2); basDevps.add(staProtocol2.toSqlModel()); } BasDevpService basDevpService = SpringUtils.getBean(BasDevpService.class); if(basDevps.size() > 0) { if (null != basDevpService && !basDevpService.updateBatchById(basDevps)) { throw new Exception("更新数据库数据失败"); } } } catch (Exception e){ } } @Override