|
@@ -266,6 +266,9 @@ public class OpcDaFrequencyTask extends TimerTask {
|
|
|
break;
|
|
|
}
|
|
|
try {
|
|
|
+ System.out.println("--------------server" + server);
|
|
|
+ System.out.println("--------------serverState" + server.getServerState());
|
|
|
+ System.out.println("--------------group" + group);
|
|
|
Map<org.openscada.opc.lib.da.Item, ItemState> resultMap = group.read(true, itemArr);
|
|
|
index++;
|
|
|
List<CursorRawData> cursorRawDataList = new ArrayList<>();
|
|
@@ -302,6 +305,7 @@ public class OpcDaFrequencyTask extends TimerTask {
|
|
|
//组装相应的原始数据
|
|
|
opcAsyncTask.packageRawDataList(itemList, dataSourceId, sqlCurrentYmdh);
|
|
|
sqlCurrentYmdh = currentYmdh;
|
|
|
+ redisUtil.set(ConstantStr.VALUE_BELONG_TIME + id, currentYmdh, ConstantStr.TWO_HOUR);
|
|
|
}
|
|
|
}
|
|
|
if (Blank.isNotEmpty(dm) && dm.getModelType().equals(ConstantStr.VALUE_REPLACE)) {
|