|
@@ -46,8 +46,10 @@ public class OpcTask {
|
|
|
List<String> uniqueStr = list.stream().distinct().collect(Collectors.toList());
|
|
|
if (!CollectionUtils.isEmpty(uniqueStr)) {
|
|
|
List<RemoteOpc> remoteOpcList = OpcDAClient.addGroupAndItems(findAllItems(uniqueStr));
|
|
|
- remoteOpcMapper.updateBatch(remoteOpcList);
|
|
|
- log.info("添加新点位:" + uniqueStr);
|
|
|
+ if(CollectionUtils.isEmpty(remoteOpcList)){
|
|
|
+ remoteOpcMapper.updateBatch(remoteOpcList);
|
|
|
+ // log.info("添加新点位:" + uniqueStr);
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
RedisUtils.del(RedisKeyConstants.redis_opc_wait_add_list);
|