+ return list;\r
+ }\r
+\r
+ private KieFileSystem createKieFileSystemWithKProject(KieServices ks) {\r
+ KieModuleModel kieModuleModel = ks.newKieModuleModel();\r
+ KieBaseModel kieBaseModel = kieModuleModel.newKieBaseModel(K_BASE)\r
+ .addPackage("rules")\r
+ .setDefault(true)\r
+ .setEqualsBehavior(EqualityBehaviorOption.EQUALITY)\r
+ .setEventProcessingMode(EventProcessingOption.STREAM);\r
+ KieSessionModel kieSessionModel = kieBaseModel.newKieSessionModel("KSession")\r
+ .setDefault( true )\r
+ .setType( KieSessionModel.KieSessionType.STATEFUL )\r
+ .setClockType( ClockTypeOption.get("realtime") );\r
+ KieFileSystem kfs = ks.newKieFileSystem();\r
+ kfs.writeKModuleXML(kieModuleModel.toXML());\r
+ return kfs;\r
+ }\r
+\r
+ private void avoidDeployBug() {\r
+ String tmp = Math.random() + "";\r
+ String rule = "package justInOrderToAvoidDeployBug" + tmp.substring(2);\r
+ kfs.write(RULES_FILE_NAME, rule);\r
+ kieBuilder = ks.newKieBuilder(kfs).buildAll();\r
+ InternalKieModule internalKieModule = (InternalKieModule)kieBuilder.getKieModule();\r
+ String packageName = internalKieModule.getKnowledgePackagesForKieBase(K_BASE).iterator().next().getName();\r
+ kieRepository.addKieModule(internalKieModule);\r
+ kieContainer.updateToVersion(internalKieModule.getReleaseId());\r
+\r
+ KiePackage kiePackage = kieBase.getKiePackage(packageName);\r
+ kieBase.removeKiePackage(kiePackage.getName());\r
+ }\r
+\r
+ public void alarmSynchronization() throws AlarmInfoException {\r
+ alarmInfoDao.queryAllAlarm().forEach(alarmInfo -> alarmInfoDao.deleteClearedAlarm(alarmInfo));\r
+ alarmInfoDao.queryAllAlarm().forEach(alarmInfo -> putRaisedIntoStream(convertAlarmInfo2VesAlarm(alarmInfo)));\r
+ }\r
+\r
+ private VesAlarm convertAlarmInfo2VesAlarm(AlarmInfo alarmInfo) {\r
+ VesAlarm vesAlarm = new VesAlarm();\r
+ vesAlarm.setEventId(alarmInfo.getEventId());\r
+ vesAlarm.setEventName(alarmInfo.getEventName());\r
+ vesAlarm.setStartEpochMicrosec(alarmInfo.getStartEpochMicroSec());\r
+ vesAlarm.setSourceId(alarmInfo.getSourceId());\r
+ vesAlarm.setSourceName(alarmInfo.getSourceName());\r
+ vesAlarm.setRootFlag(alarmInfo.getRootFlag());\r
+ vesAlarm.setAlarmIsCleared(alarmInfo.getAlarmIsCleared());\r
+ vesAlarm.setLastEpochMicrosec(alarmInfo.getLastEpochMicroSec());\r
+ return vesAlarm;\r
+ }\r
+\r
+ private AlarmInfo convertVesAlarm2AlarmInfo(VesAlarm vesAlarm){\r
+ AlarmInfo alarmInfo = new AlarmInfo();\r
+ alarmInfo.setEventId(vesAlarm.getEventId());\r
+ alarmInfo.setEventName(vesAlarm.getEventName());\r
+ alarmInfo.setStartEpochMicroSec(vesAlarm.getStartEpochMicrosec());\r
+ alarmInfo.setLastEpochMicroSec(vesAlarm.getLastEpochMicrosec());\r
+ alarmInfo.setSourceId(vesAlarm.getSourceId());\r
+ alarmInfo.setSourceName(vesAlarm.getSourceName());\r
+ alarmInfo.setAlarmIsCleared(vesAlarm.getAlarmIsCleared());\r
+ alarmInfo.setRootFlag(vesAlarm.getRootFlag());\r
+\r
+ return alarmInfo;\r