From d99250ff43460b9408a2a47b3196d00a9ed20493 Mon Sep 17 00:00:00 2001 From: markilue <745518019@qq.com> Date: Thu, 4 May 2023 18:59:47 +0800 Subject: [PATCH] =?UTF-8?q?historian=E8=AF=BB=E5=8F=96=E6=9B=B4=E6=96=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/cqu/ge/ArchiveAPITest.java | 335 ++++++++++++ .../src/main/java/com/cqu/ge/Collector.java | 165 ++++++ .../com/cqu/ge/CollectorServiceImplTest.java | 169 ++++++ .../CollectorStatisticsServiceImplTest.java | 108 ++++ .../java/com/cqu/ge/DHSServiceImplTest.java | 101 ++++ .../java/com/cqu/ge/DataServiceImplTest.java | 495 ++++++++++++++++++ .../com/cqu/ge/DataStoreServiceImplTest.java | 209 ++++++++ .../cqu/ge/InterfaceDefServiceImplTest.java | 130 +++++ .../com/cqu/ge/MessageServiceImplTest.java | 142 +++++ .../ge/PerformanceCounterServiceImplTest.java | 79 +++ .../java/com/cqu/ge/TagServiceImplTest.java | 352 +++++++++++++ .../java/com/cqu/ge/TagsServiceImplTest.java | 99 ++++ .../src/main/java/com/cqu/ge/TestHelper.java | 141 +++++ .../src/main/java/com/cqu/ge/test/1.json | 14 + .../src/main/java/com/cqu/ge/test/Try.java | 40 ++ .../src/main/java/com/cqu/ge/test/test1.java | 34 ++ 16 files changed, 2613 insertions(+) create mode 100644 GE_Migrating_data/src/main/java/com/cqu/ge/ArchiveAPITest.java create mode 100644 GE_Migrating_data/src/main/java/com/cqu/ge/Collector.java create mode 100644 GE_Migrating_data/src/main/java/com/cqu/ge/CollectorServiceImplTest.java create mode 100644 GE_Migrating_data/src/main/java/com/cqu/ge/CollectorStatisticsServiceImplTest.java create mode 100644 GE_Migrating_data/src/main/java/com/cqu/ge/DHSServiceImplTest.java create mode 100644 GE_Migrating_data/src/main/java/com/cqu/ge/DataServiceImplTest.java create mode 100644 GE_Migrating_data/src/main/java/com/cqu/ge/DataStoreServiceImplTest.java create mode 100644 GE_Migrating_data/src/main/java/com/cqu/ge/InterfaceDefServiceImplTest.java create mode 100644 GE_Migrating_data/src/main/java/com/cqu/ge/MessageServiceImplTest.java create mode 100644 GE_Migrating_data/src/main/java/com/cqu/ge/PerformanceCounterServiceImplTest.java create mode 100644 GE_Migrating_data/src/main/java/com/cqu/ge/TagServiceImplTest.java create mode 100644 GE_Migrating_data/src/main/java/com/cqu/ge/TagsServiceImplTest.java create mode 100644 GE_Migrating_data/src/main/java/com/cqu/ge/TestHelper.java create mode 100644 GE_Migrating_data/src/main/java/com/cqu/ge/test/1.json create mode 100644 GE_Migrating_data/src/main/java/com/cqu/ge/test/Try.java create mode 100644 GE_Migrating_data/src/main/java/com/cqu/ge/test/test1.java diff --git a/GE_Migrating_data/src/main/java/com/cqu/ge/ArchiveAPITest.java b/GE_Migrating_data/src/main/java/com/cqu/ge/ArchiveAPITest.java new file mode 100644 index 0000000..8b0ddaf --- /dev/null +++ b/GE_Migrating_data/src/main/java/com/cqu/ge/ArchiveAPITest.java @@ -0,0 +1,335 @@ +package com.cqu.ge; +/* + * To change this license header, choose License Headers in Project Properties. + * To change this template file, choose Tools | Templates + * and open the template in the editor. + */ + +import com.cqu.ge.TestHelper; +import com.ge.ip.hds.historian.API.ArchiveService; +import com.ge.ip.hds.historian.API.ArchiveServiceImpl; +import com.ge.ip.hds.historian.API.CollectorService; +import com.ge.ip.hds.historian.API.CollectorServiceImpl; +import com.ge.ip.hds.historian.API.ConfigurationManager; +import com.ge.ip.hds.historian.API.DataStoreService; +import com.ge.ip.hds.historian.API.DataStoreServiceImpl; +import com.ge.ip.hds.historian.API.TagService; +import com.ge.ip.hds.historian.API.TagServiceImpl; +import com.ge.ip.hds.historian.DataContracts.Archive; +import com.ge.ip.hds.historian.DataContracts.ArchiveStatistics; +import com.ge.ip.hds.historian.DataContracts.CollectorProperty; +import com.ge.ip.hds.historian.DataContracts.DataStore; +import com.ge.ip.hds.historian.DataContracts.DataStoreState; +import com.ge.ip.hds.historian.DataContracts.ErrorCode; +import com.ge.ip.hds.historian.DataContracts.HistorianOperationException; +import com.ge.ip.hds.historian.DataContracts.NativeDataType; +import com.ge.ip.hds.historian.DataContracts.TagProperty; +//import com.ge.ip.hds.historianjavaapitest.ReadClass; +import java.io.File; +import java.util.Date; +import java.util.List; +import javax.xml.parsers.DocumentBuilder; +import javax.xml.parsers.DocumentBuilderFactory; +import static junit.framework.Assert.assertEquals; +import static junit.framework.Assert.assertEquals; +import org.junit.After; +import org.junit.AfterClass; +import static org.junit.Assert.*; +import org.junit.Before; +import org.junit.BeforeClass; +import org.junit.Test; +import org.w3c.dom.Document; +import org.w3c.dom.Element; +import org.w3c.dom.Node; +import org.w3c.dom.NodeList; + +public class ArchiveAPITest { + + public ArchiveAPITest() throws Exception { +// this.newDoc = ob.Read(); + } + +// ReadClass ob = new ReadClass(); + Document newDoc; + + @BeforeClass + public static void setUpClass() { + } + + @AfterClass + public static void tearDownClass() { + } + + @Before + public void setUp() { + + String cppBringPath="C:\\Program Files\\Proficy\\Proficy Historian\\x86\\Java API\\HistorianWebServiceCppBridge.dll"; + String historianServer="localhost"; + + ConfigurationManager.getInstance() + .Initialize(null,historianServer, "administrator", "745518019", 10000, 10000, true, false); + + } + + @After + public void tearDown() { + } + + /** + * Test of GetAllArchives method, of class ArchiveServiceImpl. + * @throws HistorianOperationException + */ + @Test + public void testGetAllArchives() throws HistorianOperationException { + + System.out.println("GetAllArchives"); + + ArchiveService instance = new ArchiveServiceImpl(); + List result = instance.GetAllArchives(); + System.out.println(result); + + } + + @Test + public void testQueryArchives() throws Exception { + + + TestHelper th = new TestHelper(); + ArchiveService instance = new ArchiveServiceImpl(); + + /* Test 1 - retrieve any archive */ + System.out.println("QueryArchives - retrieve any archive"); + Archive createdArchive = th.createArchive("NewArchive"); + List result = instance.QueryArchives("*", "*", 1000); + assertTrue(result.size() >= 1); + th.deleteArchive(createdArchive.getName()); + + /* Test 2 - retrieve specific pattern */ + System.out.println("QueryArchives - retrieve specific pattern"); + createdArchive = th.createArchive("New123"); + result = instance.QueryArchives("*123*", "U*", 1000); + boolean found = false; + for (Archive archive2 : result) { + if (archive2.getName().contains("123")) { + found = true; + } else { + found = false; + } + } + assertTrue(found); + th.deleteArchive(createdArchive.getName()); + + } + + /*@Test + public void testQueryArchives_fail() throws HistorianOperationException { + + System.out.println("QueryArchives_fail"); + + ArchiveServiceImpl instance = new ArchiveServiceImpl(); + List result = instance.QueryArchives("*Test*", "*", 1000); + assertTrue(result.size() == 0); + + }*/ + + /** + * Test of GetArchive method, of class ArchiveServiceImpl. + * @throws Exception + */ + @Test + public void testGetArchive() throws Exception { + + System.out.println("GetArchive"); + + TestHelper th = new TestHelper(); + Archive createdArchive = th.createArchive("NewArchive"); + + ArchiveServiceImpl instance = new ArchiveServiceImpl(); + Archive result = instance.GetArchive(createdArchive.getName(), "User"); + + assertEquals(createdArchive.getName(), result.getName()); + + th.deleteArchive(createdArchive.getName()); + + } + + /*@Test(expected = HistorianOperationException.class) + public void testGetArchive_fail() throws HistorianOperationException { + + System.out.println("GetArchive_fail"); + + String archiveName = "Test"; + String datastoreName = "User"; + ArchiveServiceImpl instance = new ArchiveServiceImpl(); + Archive result = instance.GetArchive(archiveName, datastoreName); + + }*/ + + /** + * Test of DeleteArchive method, of class ArchiveServiceImpl. + */ + @Test + public void testDeleteArchive() throws Exception { + + System.out.println("DeleteArchive"); + + TestHelper th = new TestHelper(); + Archive createdArchive = th.createArchive("NewArchive"); + + ArchiveServiceImpl instance = new ArchiveServiceImpl(); + boolean result = instance.DeleteArchive(createdArchive.getName(),createdArchive.getDataStoreName()); + + assertTrue(result); + + } + + /*@Test(expected = HistorianOperationException.class) + public void testDeleteArchive_fail() throws HistorianOperationException { + + System.out.println("DeleteArchive_fail"); + + String archiveName = "Test"; + String datastoreName = "User"; + ArchiveServiceImpl instance = new ArchiveServiceImpl(); + boolean result = instance.DeleteArchive(archiveName, datastoreName); + + }*/ + + /** + * Test of AddArchive method, of class ArchiveServiceImpl. + */ + @Test + public void testAddArchive() throws Exception { + + System.out.println("AddArchive"); + + Archive archive = new Archive(); + archive.setName("NewArchive"); + archive.setDataStoreName("User"); + + ArchiveServiceImpl instance = new ArchiveServiceImpl(); + Archive result = instance.AddArchive(archive); + + assertEquals(archive.getName(), result.getName()); + + TestHelper th = new TestHelper(); + th.deleteArchive(archive.getName()); + + } + + /** + * Test of UpdateArchive method, of class ArchiveServiceImpl. + */ + /* + * @Test public void testUpdateArchive() throws Exception { //////////NOT + * WORKING///////// System.out.println("UpdateArchive"); //reading input file; + * NodeList nList = newDoc.getElementsByTagName("UpdateArchive"); Node nNode = + * nList.item(0); Element eElement = (Element) nNode; ////////////////PROBLEM + * WITH UPDATE///////////////// //end of reading //creating archive Archive + * archive = new Archive(); + * archive.setName(eElement.getElementsByTagName("ArchiveName").item(0). + * getTextContent()); + * archive.setDataStoreName(eElement.getElementsByTagName("DataStoreName").item( + * 0).getTextContent()); + * archive.setFilename(eElement.getElementsByTagName("FileNameBefore").item(0). + * getTextContent()); ArchiveService archiveService = new ArchiveServiceImpl(); + * archive = archiveService.AddArchive(archive); String archiveName = + * archive.getName(); String dataStoreName = archive.getDataStoreName(); //end + * of creating archive ArchiveServiceImpl instance = new ArchiveServiceImpl(); + * Archive archive2 = instance.GetArchive("SathuArchive34","User"); //Archive + * archiveproperty = instance.GetArchive(archiveName,dataStoreName); + * archive2.setFilename(eElement.getElementsByTagName("FileNameAfter").item(0). + * getTextContent()); String updatedname = + * eElement.getElementsByTagName("FileNameAfter").item(0).getTextContent(); + * Archive result = instance.UpdateArchive(archive2); //Archive expResult = + * archive; //instance.DeleteArchive(archiveName, dataStoreName); + * //datastoreService.DeleteDataStore(dataStoreName); + * //assertEquals(archive,result); // TODO review the generated test code and + * remove the default call to fail. //fail("The test case is a prototype."); } + */ + + /* get archive statistics */ + @Test + public void testGetArchiveStatistics() throws Exception { + + System.out.println("GetArchiveStatistics"); + + ArchiveService instance = new ArchiveServiceImpl(); + ArchiveStatistics result = instance.GetArchiveStatistics("User"); + + } + + /** + * Test of BackupArchive method, of class ArchiveServiceImpl. + */ + /* + * @Test public void testBackupArchive() throws Exception { + * + * /////////////WORKING ONLY WITH SYSTEM ARCHIVE//////////// + * System.out.println("BackupArchive"); //reading input NodeList nList = + * newDoc.getElementsByTagName("BackupArchive"); Node nNode = nList.item(0); + * Element eElement = (Element) nNode; //end of reading //creating archive + * ArchiveService instance = new ArchiveServiceImpl(); Archive archive = new + * Archive(); + * archive.setName(eElement.getElementsByTagName("ArchiveName").item(0). + * getTextContent()); + * archive.setDataStoreName(eElement.getElementsByTagName("DataStoreName").item( + * 0).getTextContent()); archive = instance.AddArchive(archive); String + * archiveName = archive.getName(); String backupFileName = + * eElement.getElementsByTagName("BackupFileName").item(0).getTextContent() ; + * String dataStoreName = archive.getDataStoreName(); boolean zipArchive = + * false; boolean expResult = true; boolean result = + * instance.BackupArchive(archiveName, backupFileName, dataStoreName, + * zipArchive); assertEquals(expResult, result); // TODO review the generated + * test code and remove the default call to fail. + * //fail("The test case is a prototype."); } + */ + + /** + * Test of RestoreArchive method, of class ArchiveServiceImpl. + */ + /* + * @Test public void testRestoreArchive() throws Exception { ////////////////NOT + * WORKING//////////////// System.out.println("RestoreArchive"); //reading input + * NodeList nList = newDoc.getElementsByTagName("RestoreArchive"); Node nNode = + * nList.item(0); Element eElement = (Element) nNode; //end of reading + * //creating archive ArchiveService instance = new ArchiveServiceImpl(); + * Archive archive = new Archive(); + * archive.setName(eElement.getElementsByTagName("ArchiveName").item(0). + * getTextContent()); + * archive.setDataStoreName(eElement.getElementsByTagName("DataStoreName").item( + * 0).getTextContent()); archive = instance.AddArchive(archive); String + * archiveName = archive.getName(); String datastoreName = + * archive.getDataStoreName(); String backupFileName = + * eElement.getElementsByTagName("BackupFileName").item(0).getTextContent(); + * ///////////////PROBLEM WITH BACKUP ARCHIVE//////////// + * instance.BackupArchive(archiveName, backupFileName, datastoreName, false); + * //here filename is backup file name //deleting archive + * instance.DeleteArchive(archiveName, datastoreName); //restoring from backup + * String fileName = backupFileName; Archive result = + * instance.RestoreArchive(archiveName, fileName, datastoreName); + * assertEquals(result.getName(),archiveName); // TODO review the generated test + * code and remove the default call to fail. + * + * } + */ + + /** + * Test of CloseCurrentArchive method, of class ArchiveServiceImpl. + */ + @Test + public void testCloseCurrentArchive() throws Exception { + + System.out.println("CloseCurrentArchive"); + + TestHelper th = new TestHelper(); + Archive createdArchive = th.createArchive("CurrentArchive"); + createdArchive.setIsCurrent(true); + + ArchiveServiceImpl instance = new ArchiveServiceImpl(); + boolean result = instance.CloseCurrentArchive(createdArchive.getDataStoreName()); + + assertTrue(result); + th.deleteArchive(createdArchive.getName()); + } +} diff --git a/GE_Migrating_data/src/main/java/com/cqu/ge/Collector.java b/GE_Migrating_data/src/main/java/com/cqu/ge/Collector.java new file mode 100644 index 0000000..99818a4 --- /dev/null +++ b/GE_Migrating_data/src/main/java/com/cqu/ge/Collector.java @@ -0,0 +1,165 @@ +package com.cqu.ge; + +import com.ge.ip.hds.historian.API.CollectorService; +import com.ge.ip.hds.historian.API.CollectorServiceImpl; +import com.ge.ip.hds.historian.API.ConfigurationManager; +import com.ge.ip.hds.historian.DataContracts.CollectorProperty; +import com.ge.ip.hds.historian.DataContracts.CollectorPropertyBase; +//import com.ge.ip.hds.historianjavaapitest.ReadClass; +import java.io.File; +import java.util.List; +import javax.xml.parsers.DocumentBuilder; +import javax.xml.parsers.DocumentBuilderFactory; +import org.junit.After; +import org.junit.AfterClass; +import static org.junit.Assert.*; +import org.junit.Before; +import org.junit.BeforeClass; +import org.junit.Test; +import org.w3c.dom.Document; +import org.w3c.dom.Element; +import org.w3c.dom.Node; +import org.w3c.dom.NodeList; + + +//mvn install:install-file -DgroupId=com.cqu -DartifactId=ge -Dversion=1.0.0 -Dpackaging=jar -Dfile=E:\software\RepMaven\com\cqu\ge\HistorianServiceAPI.jar +public class Collector { + + public Collector() throws Exception { +// this.newDoc = ob.Read(); + } + +// ReadClass ob = new ReadClass(); + Document newDoc; + + @BeforeClass + public static void setUpClass() { + } + + @AfterClass + public static void tearDownClass() { + } + + @Before + public void setUp() { + String cppBringPath = "C:\\Program Files\\Proficy\\Proficy Historian\\x86\\Java API\\HistorianWebServiceCppBridge.dll"; + String historianServer = "localhost"; + + ConfigurationManager.getInstance().Initialize(cppBringPath, historianServer, "", "", 10000, 10000, true, false); + + } + + @After + public void tearDown() { + } + + /** + * Test of QueryCollector method, of class CollectorServiceImpl + * @throws Exception + */ + @Test + public void testQueryCollector() throws Exception { + + System.out.println("QueryCollector"); + + TestHelper th = new TestHelper(); + CollectorProperty cp = th.createCollector("NewCollector"); + CollectorService instance = new CollectorServiceImpl(); + + List result = instance.QueryCollector("*New*", 1000); + + boolean found = false; + for (CollectorPropertyBase collector1 : result) { + if (collector1.getName().contains("New")) + found = true; + + else + found = false; + + } + instance.DeleteCollector(cp.getName(), true); + assertTrue(found); + + } + + /** + * Test of GetCollector method, of class CollectorServiceImpl. + */ + @Test + public void testGetCollector() throws Exception { + + System.out.println("GetCollector"); + + TestHelper th = new TestHelper(); + CollectorProperty cp = th.createCollector("NewCollector"); + CollectorService instance = new CollectorServiceImpl(); + + CollectorProperty result = instance.GetCollector(cp.getName()); + instance.DeleteCollector(cp.getName(), true); + + assertEquals(cp.getName(), result.getName()); + + } + + /** + * Test of AddCollector method, of class CollectorServiceImpl. + */ + @Test + public void testAddCollector() throws Exception { + + System.out.println("AddCollector"); + + CollectorProperty collectorProperty = new CollectorProperty(); + collectorProperty.setName("NewCollector"); + String collectorName = collectorProperty.getName(); + + CollectorServiceImpl instance = new CollectorServiceImpl(); + CollectorProperty result = instance.AddCollector(collectorProperty); + + instance.DeleteCollector(collectorName, true); + assertEquals(collectorName, result.getName()); + + } + + /** + * Test of DeleteCollector method, of class CollectorServiceImpl. + */ + @Test + public void testDeleteCollector() throws Exception { + + System.out.println("DeleteCollector"); + + TestHelper th = new TestHelper(); + CollectorProperty cp = th.createCollector("NewCollector"); + CollectorService instance = new CollectorServiceImpl(); + + boolean result = instance.DeleteCollector(cp.getName(), true); + assertTrue(result); + + } + + /** + * Test of UpdateCollector method, of class CollectorServiceImpl. + */ + @Test + public void testUpdateCollector() throws Exception { + + System.out.println("UpdateCollector"); + + TestHelper th = new TestHelper(); +// CollectorProperty cp = th.createCollector("NewCollector"); + + +// String collectorName = cp.getName(); + String collectorName = "NewCollector"; + + CollectorServiceImpl instance = new CollectorServiceImpl(); + + CollectorProperty cp = instance.GetCollector(collectorName); + cp.setComment("test comment"); + + CollectorProperty result = instance.UpdateCollector(collectorName, cp); + assertEquals(cp.getComment(), result.getComment()); + + } +} diff --git a/GE_Migrating_data/src/main/java/com/cqu/ge/CollectorServiceImplTest.java b/GE_Migrating_data/src/main/java/com/cqu/ge/CollectorServiceImplTest.java new file mode 100644 index 0000000..77dec96 --- /dev/null +++ b/GE_Migrating_data/src/main/java/com/cqu/ge/CollectorServiceImplTest.java @@ -0,0 +1,169 @@ +package com.cqu.ge; +/* + * To change this license header, choose License Headers in Project Properties. + * To change this template file, choose Tools | Templates + * and open the template in the editor. + */ + +import com.ge.ip.hds.historian.API.CollectorService; +import com.ge.ip.hds.historian.API.CollectorServiceImpl; +import com.ge.ip.hds.historian.API.ConfigurationManager; +import com.ge.ip.hds.historian.DataContracts.CollectorProperty; +import com.ge.ip.hds.historian.DataContracts.CollectorPropertyBase; +//import com.ge.ip.hds.historianjavaapitest.ReadClass; +import java.io.File; +import java.util.List; +import javax.xml.parsers.DocumentBuilder; +import javax.xml.parsers.DocumentBuilderFactory; +import org.junit.After; +import org.junit.AfterClass; +import static org.junit.Assert.*; +import org.junit.Before; +import org.junit.BeforeClass; +import org.junit.Test; +import org.w3c.dom.Document; +import org.w3c.dom.Element; +import org.w3c.dom.Node; +import org.w3c.dom.NodeList; + +public class CollectorServiceImplTest { + + public CollectorServiceImplTest() throws Exception { +// this.newDoc = ob.Read(); + } + +// ReadClass ob = new ReadClass(); + Document newDoc; + + @BeforeClass + public static void setUpClass() { + } + + @AfterClass + public static void tearDownClass() { + } + + /** + * 配置类，设置HistorianWebServiceCppBridge.dll的位置 + * historianServer，设置位置，集群模式还是单机模式，和当时安装时候的配置有关 + */ + @Before + public void setUp() { + String cppBringPath = "C:\\Program Files\\Proficy\\Proficy Historian\\x86\\Java API\\HistorianWebServiceCppBridge.dll"; + String historianServer = "localhost"; + + ConfigurationManager.getInstance().Initialize(cppBringPath, historianServer, "", "", 10000, 10000, true, false); + + } + + @After + public void tearDown() { + } + + /** + * Test of QueryCollector method, of class CollectorServiceImpl + * @throws Exception + */ + @Test + public void testQueryCollector() throws Exception { + + System.out.println("QueryCollector"); + + TestHelper th = new TestHelper(); + CollectorProperty cp = th.createCollector("NewCollector"); + CollectorService instance = new CollectorServiceImpl(); + + List result = instance.QueryCollector("*New*", 1000); + + boolean found = false; + for (CollectorPropertyBase collector1 : result) { + if (collector1.getName().contains("New")) + found = true; + + else + found = false; + + } +// instance.DeleteCollector(cp.getName(), true); + assertTrue(found); + + } + + /** + * Test of GetCollector method, of class CollectorServiceImpl. + */ + @Test + public void testGetCollector() throws Exception { + + System.out.println("GetCollector"); + + TestHelper th = new TestHelper(); + CollectorProperty cp = th.createCollector("NewCollector"); + CollectorService instance = new CollectorServiceImpl(); + + CollectorProperty result = instance.GetCollector(cp.getName()); + instance.DeleteCollector(cp.getName(), true); + + assertEquals(cp.getName(), result.getName()); + + } + + /** + * Test of AddCollector method, of class CollectorServiceImpl. + */ + @Test + public void testAddCollector() throws Exception { + + System.out.println("AddCollector"); + + CollectorProperty collectorProperty = new CollectorProperty(); + collectorProperty.setName("NewCollector"); + String collectorName = collectorProperty.getName(); + + CollectorServiceImpl instance = new CollectorServiceImpl(); + CollectorProperty result = instance.AddCollector(collectorProperty); + + instance.DeleteCollector(collectorName, true); + assertEquals(collectorName, result.getName()); + + } + + /** + * Test of DeleteCollector method, of class CollectorServiceImpl. + */ + @Test + public void testDeleteCollector() throws Exception { + + System.out.println("DeleteCollector"); + + TestHelper th = new TestHelper(); + CollectorProperty cp = th.createCollector("NewCollector"); + CollectorService instance = new CollectorServiceImpl(); + + boolean result = instance.DeleteCollector(cp.getName(), true); + assertTrue(result); + + } + + /** + * Test of UpdateCollector method, of class CollectorServiceImpl. + */ + @Test + public void testUpdateCollector() throws Exception { + + System.out.println("UpdateCollector"); + + TestHelper th = new TestHelper(); + CollectorProperty cp = th.createCollector("NewCollector"); + + String collectorName = cp.getName(); + + CollectorServiceImpl instance = new CollectorServiceImpl(); + cp.setComment("test comment"); + + CollectorProperty result = instance.UpdateCollector(collectorName, cp); + assertEquals(cp.getComment(), result.getComment()); + + } + +} diff --git a/GE_Migrating_data/src/main/java/com/cqu/ge/CollectorStatisticsServiceImplTest.java b/GE_Migrating_data/src/main/java/com/cqu/ge/CollectorStatisticsServiceImplTest.java new file mode 100644 index 0000000..f92ce42 --- /dev/null +++ b/GE_Migrating_data/src/main/java/com/cqu/ge/CollectorStatisticsServiceImplTest.java @@ -0,0 +1,108 @@ +package com.cqu.ge;/* + * To change this license header, choose License Headers in Project Properties. + * To change this template file, choose Tools | Templates + * and open the template in the editor. + */ + +import com.ge.ip.hds.historian.API.CollectorService; +import com.ge.ip.hds.historian.API.CollectorServiceImpl; +import com.ge.ip.hds.historian.API.CollectorStatisticsService; +import com.ge.ip.hds.historian.API.CollectorStatisticsServiceImpl; +import com.ge.ip.hds.historian.API.ConfigurationManager; +import com.ge.ip.hds.historian.DataContracts.CollectorProperty; +import com.ge.ip.hds.historian.DataContracts.CollectorStatistics; +import com.ge.ip.hds.historian.DataContracts.HistorianOperationException; +//import com.ge.ip.hds.historianjavaapitest.ReadClass; +import java.io.File; +import javax.xml.parsers.DocumentBuilder; +import javax.xml.parsers.DocumentBuilderFactory; +import org.junit.After; +import org.junit.AfterClass; +import static org.junit.Assert.*; +import org.junit.Before; +import org.junit.BeforeClass; +import org.junit.Test; +import org.w3c.dom.Document; +import org.w3c.dom.Element; +import org.w3c.dom.Node; +import org.w3c.dom.NodeList; + + +public class CollectorStatisticsServiceImplTest { + + public CollectorStatisticsServiceImplTest() throws Exception { +// this.newDoc = ob.Read(); + } + +// ReadClass ob = new ReadClass(); + Document newDoc; + + @BeforeClass + public static void setUpClass() { + } + + @AfterClass + public static void tearDownClass() { + } + + @Before + public void setUp() { + String cppBringPath = "C:\\Program Files\\Proficy\\Proficy Historian\\x86\\Java API\\HistorianWebServiceCppBridge.dll"; + String historianServer = "localhost"; + + ConfigurationManager.getInstance().Initialize(cppBringPath, historianServer, "", "", 10000, 10000, true, false); + + } + + @After + public void tearDown() { + } + + + /** + * Test of GetStatistics method, of class CollectorStatisticsServiceImpl. + */ + @Test + public void testGetStatistics() throws Exception { + + System.out.println("GetStatistics"); + TestHelper th = new TestHelper(); + CollectorProperty cp = th.createCollector("NewCollector"); + String collectorName = cp.getName(); + + CollectorStatistics collectorStatistics = th.createCollectorStats(1000, 5000); + + CollectorStatisticsService instance = new CollectorStatisticsServiceImpl(); + instance.SetStatistics(collectorName, collectorStatistics); + CollectorStatistics result = instance.GetStatistics(collectorName); + + th.deleteCollector(collectorName); + assertEquals(collectorStatistics.getAverageEventRate(),result.getAverageEventRate(),0.0); + + + } + + /** + * Test of SetStatistics method, of class CollectorStatisticsServiceImpl. + */ + @Test + public void testSetStatistics() throws Exception { + + System.out.println("SetStatistics"); + TestHelper th = new TestHelper(); + CollectorProperty cp = th.createCollector("NewCollector"); + String collectorName = cp.getName(); + + CollectorStatistics collectorStatistics = th.createCollectorStats(4000, 6000); + + CollectorStatisticsService instance = new CollectorStatisticsServiceImpl(); + boolean result = instance.SetStatistics(collectorName, collectorStatistics); + + + th.deleteCollector(collectorName); + assertTrue(result); + + } + + +} diff --git a/GE_Migrating_data/src/main/java/com/cqu/ge/DHSServiceImplTest.java b/GE_Migrating_data/src/main/java/com/cqu/ge/DHSServiceImplTest.java new file mode 100644 index 0000000..4817cd5 --- /dev/null +++ b/GE_Migrating_data/src/main/java/com/cqu/ge/DHSServiceImplTest.java @@ -0,0 +1,101 @@ +package com.cqu.ge; + +import static org.junit.Assert.assertEquals; +import static org.junit.Assert.assertTrue; + +import java.util.List; + +import org.junit.After; +import org.junit.AfterClass; +import org.junit.Before; +import org.junit.BeforeClass; +import org.junit.Test; + +import com.ge.ip.hds.historian.API.ConfigurationManager; +import com.ge.ip.hds.historian.API.DHSServiceImpl; +import com.ge.ip.hds.historian.DataContracts.DHSServiceInfo; +import com.ge.ip.hds.historian.DataContracts.DHSServiceType; +import com.ge.ip.hds.historian.DataContracts.HistorianOperationException; + + +public class DHSServiceImplTest { + + @BeforeClass + public static void setUpClass() { + } + + @AfterClass + public static void tearDownClass() { + } + + @Before + public void setUp() { + + String cppBringPath="C:\\Program Files\\Proficy\\Proficy Historian\\x86\\Java API\\HistorianWebServiceCppBridge.dll"; + String historianServer="localhost"; + + ConfigurationManager.getInstance() + .Initialize(cppBringPath,historianServer, "", "", 10000, 10000, true, false); + + } + + @After + public void tearDown() { + } + + @Test + public void testGetDHSServices() throws HistorianOperationException { + + System.out.println("testGetDHSServices"); + + String dHSServiceMask = "Config*"; + boolean withReasons = false; + + DHSServiceImpl instance = new DHSServiceImpl(); + List result = instance.GetDHSServices(dHSServiceMask, withReasons); + + if(result.size()!= 0) + for(DHSServiceInfo item: result) + assertTrue(item.getLocalName().contains("Config")); + + } + + @Test + public void testDHSGetService() throws HistorianOperationException { + + System.out.println("testGetDHSService"); + + DHSServiceImpl instance = new DHSServiceImpl(); + DHSServiceInfo dhsserviceinfo = instance.GetDHSService("ConfigManager_SoumikM2"); + + assertEquals("ConfigManager_SoumikM2", dhsserviceinfo.getLocalName()); + + } + + @Test + public void testAddDHSServiceNode() throws HistorianOperationException { + + System.out.println("testAddDHSServiceNode"); + + String nodeName= "10.181.212.219"; + + DHSServiceImpl instance = new DHSServiceImpl(); + DHSServiceInfo dhsserviceinfo = instance.AddDHSServiceNode(nodeName,null,false); + + assertEquals(DHSServiceType.DataArchiver, dhsserviceinfo.getDHSServiceType()); + + } + + + @Test + public void testDeleteDHSServiceNode() throws HistorianOperationException { + + System.out.println("testDeleteDHSServiceNode"); + + DHSServiceImpl instance = new DHSServiceImpl(); + boolean result = instance.DeleteDHSServiceNode("10.181.212.219",null); + + assertTrue(result); + } + +} diff --git a/GE_Migrating_data/src/main/java/com/cqu/ge/DataServiceImplTest.java b/GE_Migrating_data/src/main/java/com/cqu/ge/DataServiceImplTest.java new file mode 100644 index 0000000..54cef0b --- /dev/null +++ b/GE_Migrating_data/src/main/java/com/cqu/ge/DataServiceImplTest.java @@ -0,0 +1,495 @@ +package com.cqu.ge; +/* + * To change this license header, choose License Headers in Project Properties. + * To change this template file, choose Tools | Templates + * and open the template in the editor. + */ + +import com.ge.ip.hds.helper.JsonBuilder; +import com.ge.ip.hds.historian.API.ConfigurationManager; +import com.ge.ip.hds.historian.API.DataService; +import com.ge.ip.hds.historian.API.DataServiceImpl; +import com.ge.ip.hds.historian.API.DataStoreService; +import com.ge.ip.hds.historian.API.DataStoreServiceImpl; +import com.ge.ip.hds.historian.API.TagService; +import com.ge.ip.hds.historian.API.TagServiceImpl; +import com.ge.ip.hds.historian.DataContracts.CalculationModeType; +import com.ge.ip.hds.historian.DataContracts.ConditionCollectionComparisonType; +import com.ge.ip.hds.historian.DataContracts.DataCollectionType; +import com.ge.ip.hds.historian.DataContracts.DataSample; +import com.ge.ip.hds.historian.DataContracts.DataStore; +import com.ge.ip.hds.historian.DataContracts.NativeDataType; +import com.ge.ip.hds.historian.DataContracts.QualityStatus; +import com.ge.ip.hds.historian.DataContracts.TagProperty; +import com.ge.ip.hds.historian.DataContracts.TagPropertyBase; +import com.ge.ip.hds.historian.DataContracts.TagSamples; +import com.ge.ip.hds.historian.DataContracts.TagWithData; +import com.ge.ip.hds.historian.DataContracts.TimeResolutionType; +import com.ge.ip.hds.historian.DataContracts.TimeStampDeterminedByType; +//import com.ge.ip.hds.historianjavaapitest.ReadClass; +import java.io.File; +import java.text.DateFormat; +import java.text.SimpleDateFormat; +import java.util.*; +import javax.xml.parsers.DocumentBuilder; +import javax.xml.parsers.DocumentBuilderFactory; + +import org.junit.After; +import org.junit.AfterClass; + +import static org.junit.Assert.*; + +import org.junit.Before; +import org.junit.BeforeClass; +import org.junit.Test; +import org.w3c.dom.Document; +import org.w3c.dom.Element; +import org.w3c.dom.Node; +import org.w3c.dom.NodeList; + + +public class DataServiceImplTest { + + public DataServiceImplTest() throws Exception { +// this.newDoc = ob.Read(); + } + + // ReadClass ob = new ReadClass(); + Document newDoc; + + @BeforeClass + public static void setUpClass() { + } + + @AfterClass + public static void tearDownClass() { + } + + + /** + * 配置类，设置HistorianWebServiceCppBridge.dll的位置 + * historianServer，设置位置，集群模式还是单机模式，和当时安装时候的配置有关 + */ + @Before + public void setUp() { + String cppBringPath = "C:\\Program Files\\Proficy\\Proficy Historian\\x86\\Java API\\HistorianWebServiceCppBridge.dll"; + String historianServer = "localhost"; + + ConfigurationManager.getInstance().Initialize(cppBringPath, historianServer, "", "", 10000, 10000, true, false); + + } + + @After + public void tearDown() { + } + + // TODO add test methods here. + // The methods must be annotated with annotation @Test. For example: + // + /** + * Test of GetCurrentData method, of class DataServiceImpl. + */ + /** + * 测试获取当前数据 + * + * @throws Exception + */ + @Test + public void testGetCurrentData_self() throws Exception { + + System.out.println("GetCurrentData"); + TestHelper th = new TestHelper(); + + TagProperty tagCreated = th.createTag("TagForSample1", "Float"); + String tagName1 = tagCreated.getName(); + + tagCreated = th.createTag("TagForSample2", "Float"); + String tagName2 = tagCreated.getName(); + +// String tagName1 = "AirInletDP"; +// String tagName2 = "AirInletDP_2"; + + + DataService dataService = new DataServiceImpl() { + }; + DataSample dataSample = th.createDataSample("UTC", "100", QualityStatus.Uncertain); + + dataService.CreateTagSample(tagName1, new ArrayList(Arrays.asList(dataSample))); + dataService.CreateTagSample(tagName2, new ArrayList(Arrays.asList(dataSample))); + + List tagNames = new ArrayList(); + tagNames.add(tagName1); + tagNames.add(tagName2); + + DataServiceImpl instance = new DataServiceImpl(); + List result = instance.GetCurrentData(tagNames); + + th.deleteTag(tagName1); + th.deleteTag(tagName2); + + assertEquals(tagName1, result.get(0).getTagName()); + assertEquals(tagName2, result.get(1).getTagName()); + + if (result.get(0).getTagName().equals(tagName1) && result.get(1).getTagName().equals(tagName2)) { + + DataSample[] datasamples1 = result.get(0).getSamples(); + DataSample[] datasamples2 = result.get(1).getSamples(); + System.out.println(datasamples1); + System.out.println(datasamples2); + System.out.println("datasamples1[0].getValue():" + datasamples1[0].getValue()); + System.out.println("datasamples1[0].getValue():" + datasamples2[0].getValue()); + if (datasamples1[0].getValue().equals(tagName1) && datasamples2[0].getValue().equals(tagName2)) { + System.out.println("ll:" + datasamples1[0]); + System.out.println("dd:" + datasamples1[1]); + assertNull(null); + } + } else { + fail(); + } + + // datastoreService.DeleteDataStore(datastoreName); + // TODO review the generated test code and remove the default call to fail. +// fail("The test case is a prototype."); + } + + @Test + public void testGetCurrentData() throws Exception { + + System.out.println("GetCurrentData"); + TestHelper th = new TestHelper(); + + TagProperty tagCreated = th.createTag("TagForSample1", "Float"); + String tagName1 = tagCreated.getName(); + + tagCreated = th.createTag("TagForSample2", "Float"); + String tagName2 = tagCreated.getName(); + + + DataService dataService = new DataServiceImpl() { + }; + DataSample dataSample = th.createDataSample("UTC", "100", QualityStatus.Uncertain); + + dataService.CreateTagSample(tagName1, new ArrayList(Arrays.asList(dataSample))); + dataService.CreateTagSample(tagName2, new ArrayList(Arrays.asList(dataSample))); + + List tagNames = new ArrayList(); + tagNames.add(tagName1); + tagNames.add(tagName2); + + DataServiceImpl instance = new DataServiceImpl(); + List result = instance.GetCurrentData(tagNames); + + th.deleteTag(tagName1); + th.deleteTag(tagName2); + + assertEquals(tagName1, result.get(0).getTagName()); + assertEquals(tagName2, result.get(1).getTagName()); + +// if (result.get(0).getTagName().equals(tagName1) && result.get(1).getTagName().equals(tagName2)) { +// DataSample[] datasamples1 = result.get(0).getSamples(); +// DataSample[] datasamples2 = result.get(1).getSamples(); +// if (datasamples1[0].getValue().equals(tagName1) && datasamples2[0].getValue().equals(tagName2)) { +// assertNull(null); +// } +// } else { +// fail(); +// } + + // datastoreService.DeleteDataStore(datastoreName); + // TODO review the generated test code and remove the default call to fail. +// fail("The test case is a prototype."); + } + + /** + * Test of GetRawDataByTime method, of class DataServiceImpl. + */ + @Test + public void testGetRawDataByTime() throws Exception { + + System.out.println("GetRawDataByTime"); + TestHelper th = new TestHelper(); + + +// TagProperty tagCreated = th.createTag("NewTag", "Float"); +// String tagName = tagCreated.getName(); + + String tagName = "NewTag"; + + List tagNames = new ArrayList(); + tagNames.add(tagName); + + DataService dataService = new DataServiceImpl() { + }; + DataSample dataSample = th.createDataSample("UTC", "72",QualityStatus.Uncertain); + + dataService.CreateTagSample(tagName, new ArrayList(Arrays.asList(dataSample))); + + + Date cur1 = new Date(); + Calendar cal1 = Calendar.getInstance(); + cal1.setTime(cur1); + cal1.add(Calendar.YEAR, -1); + + Calendar cal2 = Calendar.getInstance(); + cal2.setTime(cur1); + cal2.add(Calendar.SECOND, 1); + + Date startTime = cal1.getTime(); + Date endTime = cal2.getTime(); + + DataServiceImpl instance = new DataServiceImpl(); + List result = instance.GetRawDataByTime(tagNames, startTime, endTime); + +// th.deleteTag(tagName); + + for (TagSamples tagSamples : result) { + System.out.println("tagName:" + tagSamples.getTagName()); + DataSample[] samples = tagSamples.getSamples(); + System.out.println(samples.length); + for (DataSample sample : samples) { + System.out.println("tag_value:" + sample.getValue()); + } + +// assertEquals(tagName, tagSamples.getTagName()); +// if (tagSamples.getTagName().equals(tagName)) { +// int length = tagSamples.getSamples().length; +// if (length == 0) { +// assertNull(null); +// break; +// } +// DataSample[] datasample = new DataSample[1]; +// datasample = tagSamples.getSamples(); +// assertEquals(datasample[0].getTimeStamp(), dataSample.getTimeStamp()); +// assertEquals(datasample[0].getValue(), 72); +// } else { +// fail(); +// } + } + + } + + /** + * Test of GetRawDataByNumber method, of class DataServiceImpl. + */ + @Test + public void testGetRawDataByNumber() throws Exception { + + System.out.println("GetRawDataByNumber"); + TestHelper th = new TestHelper(); + + + TagProperty tagCreated = th.createTag("NewTag", "Float"); + String tagName = tagCreated.getName(); + + List tagNames = new ArrayList(); + tagNames.add(tagName); + + DataService dataService = new DataServiceImpl() { + }; + DataSample dataSample = th.createDataSample("UTC", "72", QualityStatus.Uncertain); + + dataService.CreateTagSample(tagName, new ArrayList(Arrays.asList(dataSample))); + + + Calendar cal1 = Calendar.getInstance(); + cal1.setTime(dataSample.getTimeStamp()); + int startTimeOffset = Integer + .parseInt("-1"); + cal1.add(Calendar.SECOND, -1); + + Date startTime = cal1.getTime(); + int count = 2; + boolean backwardTimeOrder = false; + + DataServiceImpl instance = new DataServiceImpl(); + + List result = instance.GetRawDataByNumber(tagNames, startTime, count, backwardTimeOrder); + + th.deleteTag(tagName); + for (TagSamples tagSamples : result) { + assertEquals(tagName, tagSamples.getTagName()); + /*if (tagSamples.getTagName().equals(tagName)) { + DataSample[] datasample = new DataSample[1]; + int length = tagSamples.getSamples().length; + if (length == 0) { + assertNull(null); + break; + } + datasample = tagSamples.getSamples(); + assertEquals(datasample[0].getTimeStamp(), d); + assertEquals(datasample[0].getValue(), value); + } else { + fail(); + }*/ + } + + // assertEquals(expResult, result); + // TODO review the generated test code and remove the default call to fail. + // fail("The test case is a prototype."); + } + + /** + * Test of GetInterpolatedData method, of class DataServiceImpl. + */ + @Test + public void testGetInterpolatedData() throws Exception { + System.out.println("GetInterpolatedData"); + TestHelper th = new TestHelper(); + + TagProperty tagCreated = th.createTag("TagForSample1", "Float"); + String tagName1 = tagCreated.getName(); + + tagCreated = th.createTag("TagForSample2", "Float"); + String tagName2 = tagCreated.getName(); + + List tagNames = new ArrayList(); + tagNames.add(tagName1); + tagNames.add(tagName2); + + DataService dataService = new DataServiceImpl() { + }; + DataSample dataSample1 = th.createDataSample("UTC", "10", QualityStatus.Good); + DataSample dataSample2 = th.createDataSample("UTC", "12", QualityStatus.Good); + + dataService.CreateTagSample(tagName1, new ArrayList(Arrays.asList(dataSample1))); + dataService.CreateTagSample(tagName2, new ArrayList(Arrays.asList(dataSample2))); + + Calendar cal2 = Calendar.getInstance(); + int startTimeOffset = Integer + .parseInt("10"); + cal2.add(Calendar.SECOND, startTimeOffset); + Date startTime = cal2.getTime(); + + Calendar cal3 = Calendar.getInstance(); + int endTimeOffset = Integer.parseInt("10"); + cal3.add(Calendar.SECOND, endTimeOffset); + Date endTime = cal3.getTime(); + + long intervalMs = Long.parseLong("1000"); + DataServiceImpl instance = new DataServiceImpl(); + + List result = instance.GetInterpolatedData(tagNames, startTime, endTime, intervalMs); + th.deleteTag(tagName1); + th.deleteTag(tagName2); + + assertEquals(tagName1, result.get(0).getTagName()); + assertEquals(tagName2, result.get(1).getTagName()); + + // assertEquals(expResult, result); + // TODO review the generated test code and remove the default call to fail. + // fail("The test case is a prototype."); + } + + /** + * Test of CreateTagSample method, of class DataServiceImpl. + * todo 测试获取当前值通过 + */ + @Test + public void testCreateTagSample() throws Exception { + + System.out.println("CreateTagSample"); + TestHelper testhelper = new TestHelper(); + + // creating tag1 +// TagProperty _tagCreated = testhelper.createTag("NewTag", "Float"); + +// String tagName = _tagCreated.getName(); + + // end of creating tag1 + + DataService dataService = new DataServiceImpl(); + List dataSamples = null; + DataServiceImpl instance = new DataServiceImpl(); + String tagName = "NewTag"; + + ArrayList list = new ArrayList<>(); + + for (int i = 0; i < 10; i++) { + DataSample dataSample = testhelper.createDataSample("UTC", "20" + i, QualityStatus.Bad); + Thread.sleep(1000); + list.add(dataSample); + + } + + dataService.CreateTagSample(tagName, list); + + // datasample created + + + List tagNames = new ArrayList(); + + tagNames.add(tagName); + + List lis = instance.GetCurrentData(tagNames); + DataSample[] sample = lis.get(0).getSamples(); + System.out.println("tag_value:" + sample[0].getValue()); + System.out.println("tag_Quality:" + sample[0].getQuality()); + + /** + * CreateTagSample + * tag_value:10 + * tag_Quality:Bad + */ + +// testhelper.deleteTag(tagName); +// assertEquals(sample[0].getValue(), dataSample.getValue()); + + // TODO review the generated test code and remove the default call to fail. + // fail("The test case is a prototype."); + } + + /** + * Test of CreateTagsSample method, of class DataServiceImpl. + */ + @Test + public void testCreateTagsSample() throws Exception { + + System.out.println("CreateTagsSample"); + TestHelper testhelper = new TestHelper(); + + // creating first tag + TagProperty tagCreated = testhelper.createTag("tag1", "Float"); + String tagName1 = tagCreated.getName(); + + // creating 2nd tag + tagCreated = testhelper.createTag("tag2", "Float"); + String tagName2 = tagCreated.getName(); + + + // creating tagsample + DataService dataService = new DataServiceImpl(); + DataSample dataSample = testhelper.createDataSample("UTC", "8", QualityStatus.Good); + // datasample created + + DataSample[] datasamples = new DataSample[1]; + datasamples[0] = dataSample; + + TagWithData tagwithData = testhelper.createTagWithData(datasamples, NativeDataType.Float, tagName1); + TagWithData tagwithData2 = testhelper.createTagWithData(datasamples, NativeDataType.Float, tagName2); + + List tagsDataSample = new ArrayList(); + tagsDataSample.add(tagwithData); + tagsDataSample.add(tagwithData2); + + DataServiceImpl instance = new DataServiceImpl(); + instance.CreateTagsSample(tagsDataSample); + + List tagNames = new ArrayList(); + tagNames.add(tagName1); + tagNames.add(tagName2); + + List lis = instance.GetCurrentData(tagNames); + DataSample[] sample = lis.get(0).getSamples(); + testhelper.deleteTag(tagName1); + testhelper.deleteTag(tagName2); + + + assertEquals(sample[0].getValue(), dataSample.getValue()); + + DataSample[] sample2 = lis.get(1).getSamples(); + assertEquals(sample2[0].getValue(), dataSample.getValue()); + + // TODO review the generated test code and remove the default call to fail. + // fail("The test case is a prototype."); + } +} diff --git a/GE_Migrating_data/src/main/java/com/cqu/ge/DataStoreServiceImplTest.java b/GE_Migrating_data/src/main/java/com/cqu/ge/DataStoreServiceImplTest.java new file mode 100644 index 0000000..5aa6770 --- /dev/null +++ b/GE_Migrating_data/src/main/java/com/cqu/ge/DataStoreServiceImplTest.java @@ -0,0 +1,209 @@ +package com.cqu.ge; +/* + * To change this license header, choose License Headers in Project Properties. + * To change this template file, choose Tools | Templates + * and open the template in the editor. + */ + +import com.ge.ip.hds.historian.API.ConfigurationManager; +import com.ge.ip.hds.historian.API.DataStoreService; +import com.ge.ip.hds.historian.API.DataStoreServiceImpl; +import com.ge.ip.hds.historian.DataContracts.Archive; +import com.ge.ip.hds.historian.DataContracts.DataStore; +//import com.ge.ip.hds.historianjavaapitest.ReadClass; +import java.io.File; +import java.util.List; +import javax.xml.parsers.DocumentBuilder; +import javax.xml.parsers.DocumentBuilderFactory; +import org.junit.After; +import org.junit.AfterClass; +import static org.junit.Assert.*; +import org.junit.Before; +import org.junit.BeforeClass; +import org.junit.Test; +import org.w3c.dom.Document; +import org.w3c.dom.Element; +import org.w3c.dom.Node; +import org.w3c.dom.NodeList; + +public class DataStoreServiceImplTest { + + public DataStoreServiceImplTest() throws Exception { +// this.newDoc = ob.Read(); + } + +// ReadClass ob = new ReadClass(); + Document newDoc; + + @BeforeClass + public static void setUpClass() { + } + + @AfterClass + public static void tearDownClass() { + } + + @Before + public void setUp() { + String cppBringPath = "C:\\Program Files\\Proficy\\Proficy Historian\\x86\\Java API\\HistorianWebServiceCppBridge.dll"; + String historianServer = "localhost"; + + ConfigurationManager.getInstance().Initialize(cppBringPath, historianServer, "", "", 10000, 10000, true, false); + + } + + @After + public void tearDown() { + } + + // TODO add test methods here. + // The methods must be annotated with annotation @Test. For example: + // + /** + * Test of GetDataStores method, of class DataStoreServiceImpl. + */ + @Test + public void testGetDataStores() throws Exception { + + System.out.println("GetDataStores"); + TestHelper testhelper = new TestHelper(); + + DataStoreServiceImpl instance = new DataStoreServiceImpl(); + // creating a datastore + DataStore _dataStoreCreated = testhelper.createDataStore("NewDataStore"); + + String dataStoreName = _dataStoreCreated.getName(); + String dataStoreNameMask = "*"; + + List result = instance.GetDataStores(dataStoreNameMask); + boolean found = false; + for (DataStore datastore1 : result) { + if (datastore1.getName().equals(dataStoreName)) { + found = true; + break; + } + + } + instance.DeleteDataStore(dataStoreName); + assertTrue(found); + + // assertEquals(expResult, result); + // TODO review the generated test code and remove the default call to fail. + // fail("The test case is a prototype."); + } + + /** + * Test of GetDataStore method, of class DataStoreServiceImpl. + */ + @Test + public void testGetDataStore() throws Exception { + + System.out.println("GetDataStore"); + TestHelper testhelper = new TestHelper(); + + // creating datastore + DataStore _datastoreCreated = testhelper.createDataStore("NewDataStore"); + String dataStoreName = _datastoreCreated.getName(); + + DataStoreServiceImpl instance = new DataStoreServiceImpl(); + DataStore result = instance.GetDataStore(dataStoreName); + instance.DeleteDataStore(dataStoreName); + assertEquals(_datastoreCreated.getName(), result.getName()); + + // TODO review the generated test code and remove the default call to fail. + // fail("The test case is a prototype."); + } + + /** + * Test of DeleteDataStore method, of class DataStoreServiceImpl. + */ + @Test + public void testDeleteDataStore() throws Exception { + System.out.println("DeleteDataStore"); + TestHelper testhelper = new TestHelper(); + // creating datastore + DataStore _datastoreCreated = testhelper.createDataStore("NewDataStore"); + String dataStoreName = _datastoreCreated.getName(); + + DataStoreServiceImpl instance = new DataStoreServiceImpl(); + + boolean result = instance.DeleteDataStore(dataStoreName); + assertTrue(result); + // TODO review the generated test code and remove the default call to fail. + // fail("The test case is a prototype."); + } + + /** + * Test of AddDataStore method, of class DataStoreServiceImpl. + */ + @Test + public void testAddDataStore() throws Exception { + + System.out.println("AddDataStore"); + + DataStore datastore = new DataStore(); + datastore.setName("NewDataStore"); + + String datastoreName = datastore.getName(); + + DataStoreServiceImpl instance = new DataStoreServiceImpl(); + DataStore result = instance.AddDataStore(datastore); + DataStore expResult = instance.GetDataStore(datastoreName); + + instance.DeleteDataStore(datastoreName); + assertEquals(expResult.getName(), result.getName()); + + // TODO review the generated test code and remove the default call to fail. + // fail("The test case is a prototype."); + } + + /** + * Test of UpdateDataStore method, of class DataStoreServiceImpl. + */ + @Test + public void testUpdateDataStore() throws Exception { + + System.out.println("UpdateDataStore"); + TestHelper testhelper = new TestHelper(); + + // creating datastore + DataStoreService instance = new DataStoreServiceImpl(); + DataStore dataStore = testhelper.createDataStore("NewDataStore"); + String dataStoreName = dataStore.getName(); + + dataStore.setDescription("updated description"); + DataStore result = instance.UpdateDataStore(dataStoreName, dataStore); + + assertEquals(dataStore.getDescription(),result.getDescription()); + instance.DeleteDataStore(dataStoreName); + + // TODO review the generated test code and remove the default call to fail. + // fail("The test case is a prototype."); + } + + /** + * Test of RenameDataStore method, of class DataStoreServiceImpl. + */ + /* + * @Test public void testRenameDataStore() throws Exception { + * System.out.println("RenameDataStore"); //reading input ReadClass readclass = + * new ReadClass(); Document document = readclass.Read(); + * document.getDocumentElement().normalize(); NodeList nList = + * document.getElementsByTagName("RenameDataStore"); Node nNode = nList.item(0); + * Element eElement = (Element) nNode; //creating datastore DataStore + * _datastoreCreated = null; DataStore datastore= new DataStore(); + * datastore.setName(eElement.getElementsByTagName("DataStoreName").item(0). + * getTextContent()); DataStoreService datastoreService = new + * DataStoreServiceImpl(); _datastoreCreated = + * datastoreService.AddDataStore(datastore); //end of creating datastore String + * oldName = datastore.getName(); String newName = + * eElement.getElementsByTagName("NewDataStoreName").item(0).getTextContent(); + * + * DataStoreServiceImpl instance = new DataStoreServiceImpl(); DataStore result + * = instance.RenameDataStore(oldName, newName); + * assertEquals(result.getName(),newName); // TODO review the generated test + * code and remove the default call to fail. + * //fail("The test case is a prototype."); } + */ + +} diff --git a/GE_Migrating_data/src/main/java/com/cqu/ge/InterfaceDefServiceImplTest.java b/GE_Migrating_data/src/main/java/com/cqu/ge/InterfaceDefServiceImplTest.java new file mode 100644 index 0000000..8eaaefc --- /dev/null +++ b/GE_Migrating_data/src/main/java/com/cqu/ge/InterfaceDefServiceImplTest.java @@ -0,0 +1,130 @@ +package com.cqu.ge; + +import static org.junit.Assert.assertEquals; +import static org.junit.Assert.assertTrue; + +import java.util.List; + +import org.junit.After; +import org.junit.AfterClass; +import org.junit.Before; +import org.junit.BeforeClass; +import org.junit.Test; + +import com.ge.ip.hds.historian.API.ConfigurationManager; +import com.ge.ip.hds.historian.API.InterfaceDefService; +import com.ge.ip.hds.historian.API.InterfaceDefServiceImpl; +import com.ge.ip.hds.historian.DataContracts.ErrorCode; +import com.ge.ip.hds.historian.DataContracts.HistorianOperationException; +import com.ge.ip.hds.historian.DataContracts.InterfaceDef; + +public class InterfaceDefServiceImplTest { + + @BeforeClass + public static void setUpClass() { + } + + @AfterClass + public static void tearDownClass() { + } + + @Before + public void setUp() { + + String cppBringPath="C:\\Program Files\\Proficy\\Proficy Historian\\x86\\Java API\\HistorianWebServiceCppBridge.dll"; + String historianServer="localhost"; + + ConfigurationManager.getInstance() + .Initialize(cppBringPath,historianServer, "", "", 10000, 10000, true, false); + + } + + @After + public void tearDown() { + } + + @Test + public void testGetInterfaceDefs() throws HistorianOperationException { + + System.out.println("GetInterfaceDefs"); + + InterfaceDefService instance = new InterfaceDefServiceImpl(); + List result = instance.GetInterfaceDefs("*"); + + } + + @Test + public void testGetInterfaceDef() throws HistorianOperationException { + + System.out.println("GetInterfaceDef"); + + InterfaceDefService instance = new InterfaceDefServiceImpl(); + + InterfaceDef newintDef = new InterfaceDef(); + newintDef.setInterfaceDefName("TestInterface"); + instance.AddInterfaceDef(newintDef); + + InterfaceDef result = instance.GetInterfaceDef(newintDef.getInterfaceDefName()); + instance.DeleteInterfaceDef(newintDef.getInterfaceDefName()); + + assertEquals(newintDef.getInterfaceDefName(), result.getInterfaceDefName()); + + } + + @Test + public void testAddInterfaceDef() throws HistorianOperationException { + + System.out.println("AddInterfaceDef"); + + //add and delete + + InterfaceDef intDef = new InterfaceDef(); + intDef.setInterfaceDefName("TestInterface"); + intDef.setInterfaceType(16); + + InterfaceDefService instance = new InterfaceDefServiceImpl(); + ErrorCode result = instance.AddInterfaceDef(intDef); + + instance.DeleteInterfaceDef("TestInterface"); + assertEquals(ErrorCode.Success,result); + } + + @Test + public void testDeleteInterfaceDef() throws Exception { + + System.out.println("DeleteInterfaceDef"); + InterfaceDefService instance = new InterfaceDefServiceImpl(); + + //add and delete + InterfaceDef newintDef = new InterfaceDef(); + newintDef.setInterfaceDefName("TestInterface"); + instance.AddInterfaceDef(newintDef); + + boolean result = instance.DeleteInterfaceDef("TestInterface"); + + assertTrue(result); + + } + + @Test + public void testUpdateInterfaceDef() throws HistorianOperationException { + + System.out.println("UpdateInterfaceDef"); + InterfaceDefService instance = new InterfaceDefServiceImpl(); + + //add , update and delete + InterfaceDef newintDef = new InterfaceDef(); + newintDef.setInterfaceDefName("TestInterface"); + instance.AddInterfaceDef(newintDef); + + InterfaceDef intDef = instance.GetInterfaceDef("TestInterface"); + intDef.setGeneral1Description("testdescription1"); + ErrorCode result = instance.UpdateInterfaceDef("TestInterface",intDef); + + instance.DeleteInterfaceDef("TestInterface"); + assertEquals(ErrorCode.Success,result); + + } + + +} diff --git a/GE_Migrating_data/src/main/java/com/cqu/ge/MessageServiceImplTest.java b/GE_Migrating_data/src/main/java/com/cqu/ge/MessageServiceImplTest.java new file mode 100644 index 0000000..c1f4cf1 --- /dev/null +++ b/GE_Migrating_data/src/main/java/com/cqu/ge/MessageServiceImplTest.java @@ -0,0 +1,142 @@ +package com.cqu.ge; +/* + * To change this license header, choose License Headers in Project Properties. + * To change this template file, choose Tools | Templates + * and open the template in the editor. + */ + +import com.ge.ip.hds.historian.API.ConfigurationManager; +import com.ge.ip.hds.historian.API.MessageService; +import com.ge.ip.hds.historian.API.MessageServiceImpl; +import com.ge.ip.hds.historian.DataContracts.Message; +import com.ge.ip.hds.historian.DataContracts.MessageTopic; +//import com.ge.ip.hds.historianjavaapitest.ReadClass; +import java.io.File; +import java.text.SimpleDateFormat; +import java.time.LocalDateTime; +import java.time.ZoneId; +import java.util.Calendar; +import java.util.Date; +import java.util.List; +import java.util.Locale; +import javax.xml.parsers.DocumentBuilder; +import javax.xml.parsers.DocumentBuilderFactory; +import org.junit.After; +import org.junit.AfterClass; +import static org.junit.Assert.*; +import org.junit.Before; +import org.junit.BeforeClass; +import org.junit.Test; +import org.w3c.dom.Document; +import org.w3c.dom.Element; +import org.w3c.dom.Node; +import org.w3c.dom.NodeList; + + +public class MessageServiceImplTest { + + public MessageServiceImplTest() throws Exception { +// this.newDoc = ob.Read(); + } + +// ReadClass ob = new ReadClass(); + Document newDoc; + + @BeforeClass + public static void setUpClass() { + } + + @AfterClass + public static void tearDownClass() { + } + + @Before + public void setUp() { + String cppBringPath = "C:\\Program Files\\Proficy\\Proficy Historian\\x86\\Java API\\HistorianWebServiceCppBridge.dll"; + String historianServer = "localhost"; + + ConfigurationManager.getInstance().Initialize(cppBringPath, historianServer, "", "", 10000, 10000, true, false); + + } + + @After + public void tearDown() { + } + + // TODO add test methods here. + // The methods must be annotated with annotation @Test. For example: + // + + /** + * Test of QueryMessage method, of class MessageServiceImpl. + */ + @Test + public void testQueryMessage() throws Exception { + + System.out.println("QueryMessage"); + + Message message = new Message(); + message.setText("Message for query"); + + LocalDateTime dateTime = LocalDateTime.now(); + Date date = Date.from( dateTime.atZone( ZoneId.systemDefault()).toInstant()); + + message.setTime(date); + message.setTopic(MessageTopic.General); + + MessageServiceImpl instance = new MessageServiceImpl(); + instance.AddMessage(message); + // message added + + String messageTextMask = "for"; + int maxNumber = 1000; + + Date start = Date.from(dateTime.minusDays(1).atZone( ZoneId.systemDefault()).toInstant()); + + Date end = Date.from( dateTime.atZone( ZoneId.systemDefault()).toInstant()); + + MessageTopic topic = MessageTopic.General; + + List result = instance.QueryMessage(start, end, messageTextMask, topic, maxNumber); + boolean found = false; + for (Message msg : result) { + if (msg.getText().equals(message.getText())) { + found = true; + break; + } else + found = false; + } + assertTrue(found); + // assertEquals(expResult, result); + // TODO review the generated test code and remove the default call to fail. + // fail("The test case is a prototype."); + } + + /** + * Test of AddMessage method, of class MessageServiceImpl. + */ + @Test + public void testAddMessage() throws Exception { + + System.out.println("AddMessage"); + + Message message = new Message(); + message.setText("This is a test message"); +// Date time = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss", Locale.ENGLISH) +// .parse("2019-09-18 12:23:0"); + + LocalDateTime dateTime = LocalDateTime.now(); + Date date = Date.from( dateTime.atZone( ZoneId.systemDefault()).toInstant()); + + message.setTime(date); + message.setTopic(MessageTopic.valueOf("General")); + + MessageServiceImpl instance = new MessageServiceImpl(); + + boolean result = instance.AddMessage(message); + assertTrue(result); + // TODO review the generated test code and remove the default call to fail. + // fail("The test case is a prototype."); + } + +} diff --git a/GE_Migrating_data/src/main/java/com/cqu/ge/PerformanceCounterServiceImplTest.java b/GE_Migrating_data/src/main/java/com/cqu/ge/PerformanceCounterServiceImplTest.java new file mode 100644 index 0000000..c44e55c --- /dev/null +++ b/GE_Migrating_data/src/main/java/com/cqu/ge/PerformanceCounterServiceImplTest.java @@ -0,0 +1,79 @@ +package com.cqu.ge;/* + * To change this license header, choose License Headers in Project Properties. + * To change this template file, choose Tools | Templates + * and open the template in the editor. + */ + +import com.ge.ip.hds.historian.API.ConfigurationManager; +import com.ge.ip.hds.historian.API.PerformanceCounterServiceImpl; +import com.ge.ip.hds.historian.DataContracts.ArchiveStatistics; +import com.ge.ip.hds.historian.DataContracts.HistorianConfiguration; +import com.ge.ip.hds.historian.DataContracts.PerformanceCounters; +//import com.ge.ip.hds.historianjavaapitest.ReadClass; +import java.io.File; +import javax.xml.parsers.DocumentBuilder; +import javax.xml.parsers.DocumentBuilderFactory; +import org.junit.After; +import org.junit.AfterClass; +import static org.junit.Assert.*; +import org.junit.Before; +import org.junit.BeforeClass; +import org.junit.Test; +import org.w3c.dom.Document; +import org.w3c.dom.Element; +import org.w3c.dom.Node; +import org.w3c.dom.NodeList; + + +public class PerformanceCounterServiceImplTest { + + public PerformanceCounterServiceImplTest() throws Exception { +// this.newDoc = ob.Read(); + } + +// ReadClass ob = new ReadClass(); + Document newDoc; + + @BeforeClass + public static void setUpClass() { + } + + @AfterClass + public static void tearDownClass() { + } + + @Before + public void setUp() { + String cppBringPath = "C:\\Program Files\\Proficy\\Proficy Historian\\x86\\Java API\\HistorianWebServiceCppBridge.dll"; + String historianServer = "localhost"; + + ConfigurationManager.getInstance().Initialize(cppBringPath, historianServer, "", "", 10000, 10000, true, false); + } + + @After + public void tearDown() { + } + + // TODO add test methods here. + // The methods must be annotated with annotation @Test. For example: + // + /** + * Test of GetPerformanceCounter method, of class PerformanceCounterServiceImpl. + */ + @Test + public void testGetPerformanceCounter() throws Exception { + System.out.println("GetPerformanceCounter"); + + //creating performance counter + PerformanceCounters performanceCounters = new PerformanceCounters(); + //performanceCounters.setAverageAlarmRate(eElement.getElementsByTagName("AverageAlarmRate").item(0).getTextContent()); + PerformanceCounterServiceImpl instance = new PerformanceCounterServiceImpl(); + PerformanceCounters result = instance.GetPerformanceCounter(); + int maxDataStores = Integer.parseInt("200"); + HistorianConfiguration hist = result.getHistConfig(); + assertEquals(hist.getMaxDataStores(),maxDataStores); + // TODO review the generated test code and remove the default call to fail. + //fail("The test case is a prototype."); + } + +} diff --git a/GE_Migrating_data/src/main/java/com/cqu/ge/TagServiceImplTest.java b/GE_Migrating_data/src/main/java/com/cqu/ge/TagServiceImplTest.java new file mode 100644 index 0000000..452c95a --- /dev/null +++ b/GE_Migrating_data/src/main/java/com/cqu/ge/TagServiceImplTest.java @@ -0,0 +1,352 @@ +package com.cqu.ge; +/* + * To change this license header, choose License Headers in Project Properties. + * To change this template file, choose Tools | Templates + * and open the template in the editor. + */ + +import com.ge.ip.hds.historian.API.ConfigurationManager; +import com.ge.ip.hds.historian.API.TagService; +import com.ge.ip.hds.historian.API.TagServiceImpl; +import com.ge.ip.hds.historian.DataContracts.DataCollectionType; +import com.ge.ip.hds.historian.DataContracts.NativeDataType; +import com.ge.ip.hds.historian.DataContracts.TagProperty; +import com.ge.ip.hds.historian.DataContracts.TagPropertyBase; +//import com.ge.ip.hds.historianjavaapitest.ReadClass; +import java.io.File; +import java.util.ArrayList; +import java.util.List; +import java.util.UUID; +import javax.xml.parsers.DocumentBuilder; +import javax.xml.parsers.DocumentBuilderFactory; +import org.junit.After; +import org.junit.AfterClass; +import static org.junit.Assert.*; +import org.junit.Before; +import org.junit.BeforeClass; +import org.junit.Test; +import org.w3c.dom.Document; +import org.w3c.dom.Element; +import org.w3c.dom.Node; +import org.w3c.dom.NodeList; + +public class TagServiceImplTest { + + public TagServiceImplTest() throws Exception { +// this.newDoc = ob.Read(); + } + +// ReadClass ob = new ReadClass(); + Document newDoc; + + @BeforeClass + public static void setUpClass() { + } + + @AfterClass + public static void tearDownClass() { + } + + @Before + public void setUp() { + String cppBringPath = "C:\\Program Files\\Proficy\\Proficy Historian\\x86\\Java API\\HistorianWebServiceCppBridge.dll"; + String historianServer = "localhost"; + + ConfigurationManager.getInstance().Initialize(cppBringPath, historianServer, "", "", 10000, 10000, true, false); + + } + + @After + public void tearDown() { + } + + // TODO add test methods here. + // The methods must be annotated with annotation @Test. For example: + // + /** + * Test of BrowseTag method, of class TagServiceImpl. + */ + + @Test + public void testBrowseTag() throws Exception { + + System.out.println("BrowseTag"); + TestHelper testhelper = new TestHelper(); + + // creating a tag + TagProperty _tagCreated = testhelper.createTag("TestBrowseTag", "Integer"); + // end of creating tag + + String tagName = _tagCreated.getName(); + String tagNameMask = "*Test*"; + int maxNumber = 100; + + TagServiceImpl instance = new TagServiceImpl(); + List result = instance.BrowseTag(tagNameMask, maxNumber); + + boolean found = false; //all tags in result must have the tagmask pattern + for (TagPropertyBase tagproperty : result) { + if (tagproperty.getName().equals(tagName)) { + found = true; + break; + } else + found = false; + } + instance.DeleteTag(tagName, true); + assertTrue(found); + + // assertEquals(expResult, result); + // TODO review the generated test code and remove the default call to fail. + // fail("The test case is a prototype."); + } + + /** + * Test of QueryTagByFilter method, of class TagServiceImpl. + */ + @Test + public void testQueryTagByFilter() throws Exception { + System.out.println("QueryTagByFilter"); + TestHelper testhelper = new TestHelper(); + + // creating a tag + TagProperty tagCreated = testhelper.createTag("dummytag", "Integer"); + + + String tagName = tagCreated.getName(); + String tagNameMask = tagName; + String descriptionMask = ""; + + String dataStoreName = "User"; + String collectorName = ""; + String customTypeNameMask = ""; + int maxNumber = 1; + + TagServiceImpl instance = new TagServiceImpl(); + List result = instance.QueryTagByFilter(tagNameMask, descriptionMask, dataStoreName, + collectorName, customTypeNameMask, maxNumber); + testhelper.deleteTag(tagName); + + assertEquals(result.get(0).getName(), tagName); + // TODO review the generated test code and remove the default call to fail. + // fail("The test case is a prototype."); + } + + /** + * Test of GetTag method, of class TagServiceImpl. + * + * @throws Exception + */ + @Test + public void testGetTag() throws Exception { + + System.out.println("GetTag"); + TestHelper testhelper = new TestHelper(); + // creating a new tag + TagProperty _tagCreated = testhelper.createTag("NewTag", "Integer"); + String tagName = _tagCreated.getName(); + + TagServiceImpl instance = new TagServiceImpl(); + TagProperty result = instance.GetTag(tagName); + instance.DeleteTag(tagName, true); + + assertEquals(tagName, result.getName()); + // TODO review the generated test code and remove the default call to fail. + // fail("The test case is a prototype."); + } + + /** + * Test of AddTag method, of class TagServiceImpl. + * + * @throws Exception + */ + @Test + public void testAddTag() throws Exception { + + System.out.println("AddTag"); + + // creating tag + TagProperty tagProperty = new TagProperty(); + tagProperty.setName("NewTag"); + tagProperty.setDataType( + NativeDataType.valueOf("DoubleInteger")); + tagProperty.setId(UUID.randomUUID()); + tagProperty.setDataStoreName("User"); + String tagName = tagProperty.getName(); + + TagServiceImpl instance = new TagServiceImpl(); + TagProperty result = instance.AddTag(tagProperty); + TagProperty expResult = instance.GetTag(tagName); + instance.DeleteTag(tagName, true); + assertEquals(expResult.getName(), result.getName()); + + // TODO review the generated test code and remove the default call to fail. + // fail("The test case is a prototype."); + } + + /** + * Test of RenameTag method, of class TagServiceImpl. + */ + @Test + public void testRenameTag() throws Exception { + + System.out.println("RenameTag"); + TestHelper testhelper = new TestHelper(); + + // creating a new tag + TagService instance = new TagServiceImpl(); + TagProperty _tagCreated = testhelper.createTag("NewTag", "Integer"); + _tagCreated.setDescription("description remains unchanged"); + + + String oldName = _tagCreated.getName(); + String newName = "TagNameChanged"; + + boolean trueRename = true; + TagProperty result = instance.RenameTag(oldName, newName, trueRename); + TagProperty expResult = instance.GetTag(newName); + instance.DeleteTag(newName, true); + + assertEquals(expResult.getDescription(), result.getDescription()); + + // TODO review the generated test code and remove the default call to fail. + // fail("The test case is a prototype."); + } + + /** + * Test of DeleteTag method, of class TagServiceImpl. + * + * @throws Exception + */ + @Test + public void testDeleteTag() throws Exception { + + System.out.println("DeleteTag"); + TestHelper testhelper = new TestHelper(); + + TagProperty _tagCreated = testhelper.createTag("NewTag", "Float"); + + String tagName = _tagCreated.getName(); + TagServiceImpl instance = new TagServiceImpl(); + + instance.DeleteTag(tagName, true); + // permanent and temporary deletion + assertFalse(instance.TagExists(tagName)); + // TODO review the generated test code and remove the default call to fail. + // fail("The test case is a prototype."); + } + + /** + * Test of UpdateTag method, of class TagServiceImpl. + */ + @Test + public void testUpdateTag() throws Exception { + System.out.println("UpdateTag"); + TestHelper testhelper = new TestHelper(); + + // creating a new tag + TagService instance = new TagServiceImpl(); + TagProperty _tagCreated = testhelper.createTag("NewTag", "Integer"); + + String description = " adding description"; + _tagCreated.setDescription(description); + + String tagName = _tagCreated.getName(); + + TagProperty result = instance.UpdateTag(tagName,_tagCreated); + testhelper.deleteTag(tagName); + assertEquals(description,result.getDescription()); + + // TODO review the generated test code and remove the default call to fail. + } + + /** + * Test of CopyTag method, of class TagServiceImpl. + */ + @Test + public void testCopyTag() throws Exception { + System.out.println("CopyTag"); + TestHelper testhelper = new TestHelper(); + + // creating a new tag + TagService instance = new TagServiceImpl(); + TagProperty tagCreated = testhelper.createTag("NewTag", "Integer"); + + TagProperty expResult = tagCreated; + + String tagName = tagCreated.getName(); + String copyTagName = "CopiedTag"; + + TagProperty result = instance.CopyTag(tagName, copyTagName); + + testhelper.deleteTag(tagName); + testhelper.deleteTag(copyTagName); + + assertEquals(result.getDescription(), expResult.getDescription()); + assertEquals(result.getDataType(), expResult.getDataType()); + assertEquals(result.getDataStoreName(), expResult.getDataStoreName()); + + // TODO review the generated test code and remove the default call to fail. + // fail("The test case is a prototype."); + } + + /** + * Test of GetTagAliasName method, of class TagServiceImpl. + */ + @Test + public void testGetTagAliasName() throws Exception { + System.out.println("GetTagAliasName"); + TestHelper testhelper = new TestHelper(); + + TagService instance = new TagServiceImpl(); + TagProperty tagCreated = testhelper.createTag("Tag1", "Integer"); + String tagName = tagCreated.getName(); + + List tagNames = new ArrayList(); + tagNames.add(tagName); + + String newName = "NewTagName"; + instance.RenameTag(tagName, newName, false); + + List result = instance.GetTagAliasName(tagNames); + boolean check = false; + for (String name : result) { + if (name.contains(tagName)) { + check = true; + break; + } else { + check = false; + } + } + testhelper.deleteTag(newName); + assertTrue(check); + + // TODO review the generated test code and remove the default call to fail. + // fail("The test case is a prototype."); + } + + /** + * Test of TagExists method, of class TagServiceImpl. + */ + @Test + public void testTagExists() throws Exception { + + System.out.println("TagExists"); + TestHelper testhelper = new TestHelper(); + + // creating a new tag + TagService instance = new TagServiceImpl(); + TagProperty _tagCreated = testhelper.createTag("NewTag", "Integer"); + + String tagName = _tagCreated.getName(); + String dataStoreName = _tagCreated.getDataStoreName(); + + boolean result = instance.TagExists(tagName); + instance.DeleteTag(tagName, true); + + assertTrue(result); + + // TODO review the generated test code and remove the default call to fail. + // fail("The test case is a prototype."); + } + +} diff --git a/GE_Migrating_data/src/main/java/com/cqu/ge/TagsServiceImplTest.java b/GE_Migrating_data/src/main/java/com/cqu/ge/TagsServiceImplTest.java new file mode 100644 index 0000000..b61bc99 --- /dev/null +++ b/GE_Migrating_data/src/main/java/com/cqu/ge/TagsServiceImplTest.java @@ -0,0 +1,99 @@ +package com.cqu.ge;/* + * To change this license header, choose License Headers in Project Properties. + * To change this template file, choose Tools | Templates + * and open the template in the editor. + */ + +import com.ge.ip.hds.historian.API.ConfigurationManager; +import com.ge.ip.hds.historian.API.TagService; +import com.ge.ip.hds.historian.API.TagServiceImpl; +import com.ge.ip.hds.historian.API.TagsServiceImpl; +import com.ge.ip.hds.historian.DataContracts.ItemError; +import com.ge.ip.hds.historian.DataContracts.NativeDataType; +import com.ge.ip.hds.historian.DataContracts.TagProperty; +//import com.ge.ip.hds.historianjavaapitest.ReadClass; +import java.io.File; +import java.util.ArrayList; +import java.util.List; +import org.junit.After; +import org.junit.AfterClass; +import static org.junit.Assert.*; +import org.junit.Before; +import org.junit.BeforeClass; +import org.junit.Test; +import org.w3c.dom.Document; +import org.w3c.dom.Element; +import org.w3c.dom.Node; +import org.w3c.dom.NodeList; + +public class TagsServiceImplTest { + + public TagsServiceImplTest() throws Exception{ +// this.newDoc = ob.Read(); + } + +// ReadClass ob = new ReadClass(); + Document newDoc; + + @BeforeClass + public static void setUpClass() { + } + + @AfterClass + public static void tearDownClass() { + } + + @Before + public void setUp() { + String cppBringPath = "C:\\Program Files\\Proficy\\Proficy Historian\\x86\\Java API\\HistorianWebServiceCppBridge.dll"; + String historianServer = "localhost"; + + ConfigurationManager.getInstance().Initialize(cppBringPath, historianServer, "", "", 10000, 10000, true, false); + + } + + @After + public void tearDown() { + } + + // TODO add test methods here. + // The methods must be annotated with annotation @Test. For example: + // + + /** + * Test of AddTags method, of class TagsServiceImpl. + */ + @Test + public void testAddTags() throws Exception + { + + System.out.println("AddTags"); + TestHelper testhelper = new TestHelper(); + + List tagsProperty = new ArrayList(); + TagProperty tagProperty1 = testhelper.createTag("Tag1", "Integer"); + String tagName1 = tagProperty1.getName(); + + TagProperty tagProperty2 = testhelper.createTag("Tag2", "Float"); + String tagName2 = tagProperty2.getName(); + + tagsProperty.add(0,tagProperty1); + tagsProperty.add(1, tagProperty2); + + TagsServiceImpl instance = new TagsServiceImpl(); + List result = instance.AddTags(tagsProperty); + + TagService tagService = new TagServiceImpl(); + boolean found1 = tagService.TagExists(tagName1); + boolean found2 = tagService.TagExists(tagName2); + + tagService.DeleteTag(tagName1,true); + tagService.DeleteTag(tagName2,true); + + assertTrue(found1); + assertTrue(found2); + + // TODO review the generated test code and remove the default call to fail. + //fail("The test case is a prototype."); + } +} diff --git a/GE_Migrating_data/src/main/java/com/cqu/ge/TestHelper.java b/GE_Migrating_data/src/main/java/com/cqu/ge/TestHelper.java new file mode 100644 index 0000000..3d5acff --- /dev/null +++ b/GE_Migrating_data/src/main/java/com/cqu/ge/TestHelper.java @@ -0,0 +1,141 @@ +package com.cqu.ge; + +import java.text.DateFormat; +import java.text.ParseException; +import java.text.SimpleDateFormat; +import java.util.Date; +import java.util.Locale; +import java.util.TimeZone; +import java.util.UUID; + +import com.ge.ip.hds.historian.API.ArchiveService; +import com.ge.ip.hds.historian.API.ArchiveServiceImpl; +import com.ge.ip.hds.historian.API.CollectorService; +import com.ge.ip.hds.historian.API.CollectorServiceImpl; +import com.ge.ip.hds.historian.API.DataStoreService; +import com.ge.ip.hds.historian.API.DataStoreServiceImpl; +import com.ge.ip.hds.historian.API.TagService; +import com.ge.ip.hds.historian.API.TagServiceImpl; +import com.ge.ip.hds.historian.DataContracts.Archive; +import com.ge.ip.hds.historian.DataContracts.CollectorProperty; +import com.ge.ip.hds.historian.DataContracts.CollectorStatistics; +import com.ge.ip.hds.historian.DataContracts.DataSample; +import com.ge.ip.hds.historian.DataContracts.DataStore; +import com.ge.ip.hds.historian.DataContracts.HistorianOperationException; +import com.ge.ip.hds.historian.DataContracts.NativeDataType; +import com.ge.ip.hds.historian.DataContracts.QualityStatus; +import com.ge.ip.hds.historian.DataContracts.TagProperty; +import com.ge.ip.hds.historian.DataContracts.TagWithData; + +public class TestHelper { + + public Archive createArchive(String archName) throws HistorianOperationException { + + Archive archiveCreated = null; + Archive archive = new Archive(); + archive.setName(archName); + archive.setDataStoreName("User"); + + ArchiveService archiveService = new ArchiveServiceImpl(); + archiveCreated = archiveService.AddArchive(archive); + + return archiveCreated; + } + + public void deleteArchive(String archName) throws HistorianOperationException { + ArchiveService archiveService = new ArchiveServiceImpl(); + archiveService.DeleteArchive(archName, "User"); + } + + public CollectorProperty createCollector(String colName) throws HistorianOperationException { + + CollectorService instance = new CollectorServiceImpl(); + CollectorProperty collectorProperty = new CollectorProperty(); + collectorProperty.setName(colName); + collectorProperty.setDefaultCollectionType(2); + collectorProperty = instance.AddCollector(collectorProperty); + + return collectorProperty; + + } + + public void deleteCollector(String colName) throws HistorianOperationException { + CollectorService instance = new CollectorServiceImpl(); + instance.DeleteCollector(colName, true); + } + + public CollectorStatistics createCollectorStats(double avgER, double MaxER) { + + CollectorStatistics collectorStatistics = new CollectorStatistics(); + collectorStatistics.setAverageEventRate(avgER); + collectorStatistics.setMaximumEventRate(MaxER); + + return collectorStatistics; + } + + public TagProperty createTag(String tagName, String dType) throws HistorianOperationException { + + TagProperty tagProperty = new TagProperty(); + + tagProperty.setName(tagName); + tagProperty.setId(UUID.randomUUID()); + tagProperty.setDataType( + NativeDataType.valueOf(dType)); + + tagProperty.setDataStoreName("User"); + + TagService tagService = new TagServiceImpl(); + + //TagServiceImplTest tagService = new TagServiceImplTest(); + tagProperty=tagService.AddTag(tagProperty); + return tagProperty; + + } + + public void deleteTag(String tagName) throws HistorianOperationException { + TagService tagService = new TagServiceImpl(); + tagService.DeleteTag(tagName, true); + } + + public DataSample createDataSample(String tz, String value,QualityStatus qs) throws Exception { + + DataSample dataSample = new DataSample(); + + DateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + Date dateobj = new Date(); + + df.setTimeZone(TimeZone.getTimeZone(tz)); + df.format(dateobj); + + Date d = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss", Locale.ENGLISH).parse(df.format(dateobj)); + dataSample.setTimeStamp(d); + dataSample.setQuality(qs); + + dataSample.setValue(value); + + return dataSample; + } + + public TagWithData createTagWithData(DataSample[] datasamples, NativeDataType dType,String tagName) { + TagWithData tagwithData = new TagWithData(); + tagwithData.setDataSamples(datasamples); + tagwithData.setDataType(dType); + tagwithData.setTagName(tagName); + + return tagwithData; + } + + public DataStore createDataStore(String dsName) throws HistorianOperationException{ + + DataStore datastore = new DataStore(); + datastore.setName(dsName); + + DataStoreService datastoreService = new DataStoreServiceImpl(); + + datastore = datastoreService.AddDataStore(datastore); + + return datastore; + + } + +} diff --git a/GE_Migrating_data/src/main/java/com/cqu/ge/test/1.json b/GE_Migrating_data/src/main/java/com/cqu/ge/test/1.json new file mode 100644 index 0000000..a570158 --- /dev/null +++ b/GE_Migrating_data/src/main/java/com/cqu/ge/test/1.json @@ -0,0 +1,14 @@ +{ + /* + 添加命令获得token + 示例:curl -u username:password https:///uaa/oauth/token -d grant_type=client_credentials + username默认是admin或者是hostname.admin + 如果grant_type=client_credentials不对可以使用grant_type=password试试 + curl -u admin:dingjiawen.123 http://localhost:9480/uaa/oauth/token -d grant_type=client_credentials | iconv -f utf-8 -t gbk + */ + "access_token": "eyJhbGciOiJSUzI1NiIsImprdSI6Imh0dHBzOi8vdGVzdC5nZS5jb20ubG9jYWxob3N0OjEwMDUyL3VhYS90b2tlbl9rZXlzIiwia2lkIjoia2V5LWlkLTEiLCJ0eXAiOiJKV1QifQ.eyJqdGkiOiIwZGEyNzk3YzM5ZGU0ZjMwOGIwYTRiODgzNTMyNWU1YyIsInN1YiI6ImFkbWluIiwiYXV0aG9yaXRpZXMiOlsiY2xpZW50cy5yZWFkIiwicGFzc3dvcmQud3JpdGUiLCJjbGllbnRzLnNlY3JldCIsImNsaWVudHMud3JpdGUiLCJ1YWEuYWRtaW4iLCJjbGllbnRzLmFkbWluIiwic2NpbS53cml0ZSIsInNjaW0ucmVhZCJdLCJzY29wZSI6WyJjbGllbnRzLnJlYWQiLCJwYXNzd29yZC53cml0ZSIsImNsaWVudHMuc2VjcmV0IiwiY2xpZW50cy53cml0ZSIsInVhYS5hZG1pbiIsImNsaWVudHMuYWRtaW4iLCJzY2ltLndyaXRlIiwic2NpbS5yZWFkIl0sImNsaWVudF9pZCI6ImFkbWluIiwiY2lkIjoiYWRtaW4iLCJhenAiOiJhZG1pbiIsInJldm9jYWJsZSI6dHJ1ZSwiZ3JhbnRfdHlwZSI6ImNsaWVudF9jcmVkZW50aWFscyIsInJldl9zaWciOiI4MWMyOTU5YyIsImlhdCI6MTY4MzE5MzA3OSwiZXhwIjoxNjgzMjM2Mjc5LCJpc3MiOiJodHRwczovL3Rlc3QuZ2UuY29tLmxvY2FsaG9zdDoxMDA1Mi91YWEvb2F1dGgvdG9rZW4iLCJ6aWQiOiJ1YWEiLCJhdWQiOlsic2NpbSIsInBhc3N3b3JkIiwiY2xpZW50cyIsInVhYSIsImFkbWluIl19.EFhqDhU6pQe18PKMfsLOZXtPRL2XWJqFoi2qcZtrfM6BcHnMoolO6vildyM-XtlsjPpJenxmAavbpAatn7twl48qxY_I8gmAaOnXvrPgkfRbvBNpNe3X8iYcFG58y_zFHbzgu_zxIbrNwdUTtM-l1Pmeo5sA-Vtm2Agz3bDbYGptbSEr_lOMkmxJYIz0p8tWuQsB-FHg1K9BHOd3nsY6zQN7Ci_q-ZHG_ExlxBJOn8DX3-I2mW0Ddw9OSEWPoLjViovMgavcheIwxIobb8U6SHAeWi-_frnxwTMdZukZNcOZxrZktJTaOhdsiR4OCmVtTOaYmJochoo2m5SvDSjpCA", + "token_type": "bearer", + "expires_in": 43199, + "scope": "clients.read password.write clients.secret clients.write uaa.admin clients.admin scim.write scim.read", + "jti": "0da2797c39de4f308b0a4b8835325e5c" +} \ No newline at end of file diff --git a/GE_Migrating_data/src/main/java/com/cqu/ge/test/Try.java b/GE_Migrating_data/src/main/java/com/cqu/ge/test/Try.java new file mode 100644 index 0000000..43d2e2d --- /dev/null +++ b/GE_Migrating_data/src/main/java/com/cqu/ge/test/Try.java @@ -0,0 +1,40 @@ +package com.cqu.ge.test; + +public class Try { + +/* + public DataTable GetProficyData(String tagName, DateTime startDate, DateTime endDate) { + DataSet ds = new DataSet(); + string queryString; + System.Data.OleDb.OleDbDataAdapter adp; + + using(System.Data.OleDb.OleDbConnection cn = new System.Data.OleDb.OleDbConnection()) + { + cn.ConnectionString = proficyConn.ConnectionString; + cn.Open(); + + // always get a start value + queryString = String.Format( + "set samplingmode = lab\nselect value as theValue,Timestamp from ihrawdata where tagname = '{0}' AND timestamp between '{1}' and '{2}' order by timestamp", + tagName.Replace("'", "\""), startDate.AddMinutes(-1), startDate); + adp = new System.Data.OleDb.OleDbDataAdapter(queryString, cn); + adp.Fill(ds); + + // get the range + queryString = string.Format( + "set samplingmode = rawbytime\nselect value as theValue,Timestamp from ihrawdata where tagname = '{0}' AND timestamp between '{1}' and '{2}' order by timestamp", + tagName.Replace("'", "\""), startDate, endDate); + adp = new System.Data.OleDb.OleDbDataAdapter(queryString, cn); + adp.Fill(ds); + + // always get an end value + queryString = string.Format( + "set samplingmode = lab\nselect value as theValue,Timestamp from ihrawdata where tagname = '{0}' AND timestamp between '{1}' and '{2}' order by timestamp", + tagName.Replace("'", "\""), endDate.AddMinutes(-1), endDate); + adp = new System.Data.OleDb.OleDbDataAdapter(queryString, cn); + adp.Fill(ds); + + return ds.Tables[0]; + } + }*/ +} diff --git a/GE_Migrating_data/src/main/java/com/cqu/ge/test/test1.java b/GE_Migrating_data/src/main/java/com/cqu/ge/test/test1.java new file mode 100644 index 0000000..46abb3a --- /dev/null +++ b/GE_Migrating_data/src/main/java/com/cqu/ge/test/test1.java @@ -0,0 +1,34 @@ +package com.cqu.ge.test; + +import java.util.Calendar; +import java.util.Date; + +/** + *@BelongsProject: GE_Migrating_data + *@BelongsPackage: com.cqu.ge.test + *@Author: markilue + *@CreateTime: 2023-05-04 16:07 + *@Description: TODO + *@Version: 1.0 + */ +public class test1 { + + public static void main(String[] args) { + Date cur1 = new Date(); + System.out.println(cur1); + Calendar cal1 = Calendar.getInstance(); + cal1.setTime(cur1); + cal1.add(Calendar.YEAR, -1); + + Calendar cal2 = Calendar.getInstance(); + cal2.setTime(cur1); + cal2.add(Calendar.SECOND, 1); + + Date startTime = cal1.getTime(); + Date endTime = cal2.getTime(); + System.out.println(startTime); + System.out.println(endTime); + + + } +}