Initial Commit

.gitignore

@@ -1,26 +0,0 @@
-# ---> Java
-# Compiled class file
-*.class
-
-# Log file
-*.log
-
-# BlueJ files
-*.ctxt
-
-# Mobile Tools for Java (J2ME)
-.mtj.tmp/
-
-# Package Files #
-*.jar
-*.war
-*.nar
-*.ear
-*.zip
-*.tar.gz
-*.rar
-
-# virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
-hs_err_pid*
-replay_pid*
-

I2.sh

@@ -0,0 +1,6 @@
+export JAVA_HOME=/usr/lib/jvm/jdk1.8.0_271  
+export JRE_HOME=${JAVA_HOME}/jre  
+export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib  
+export  PATH=${JAVA_HOME}/bin:$PATH
+/usr/lib/jvm/jdk1.8.0_271/bin/java -version
+/usr/lib/jvm/jdk1.8.0_271/bin/java ${CLASSPATH} -jar /root/Downloads/I2client/dist/I2client.jar

I2client.sh

@@ -0,0 +1,18 @@
+#!/bin/bash
+ps -x |grep I2client | grep -v grep
+if [ $? -eq 0 ]; then echo "正在运行"
+else 
+export JAVA_HOME=/usr/java/jdk1.8.0_171
+export JRE_HOME=${JAVA_HOME}/jre
+export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib:$CLASSPATH
+export JAVA_PATH=${JAVA_HOME}/bin:${JRE_HOME}/bin
+export PATH=$PATH:${JAVA_PATH}
+
+cd /home/quyi/I2client/dist/
+java -jar I2client.jar
+fi
+
+
+
+
+

README.md

@@ -1,2 +0,0 @@
-# I2client
-

manifest.mf

@@ -0,0 +1,3 @@
+Manifest-Version: 1.0
+X-COMMENT: Main-Class will be added automatically by build
+

src/META-INF/jax-ws-catalog.xml

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8" standalone="no"?>
+<catalog xmlns="urn:oasis:names:tc:entity:xmlns:xml:catalog" prefer="system">
+    <system systemId="http://222.90.232.140:8443/xydl/service/XydlService?wsdl" uri="wsdl/222.90.232.140_8443/xydl/service/XydlService.wsdl"/>
+    <system systemId="http://192.168.128.86:10080/busi-back-ws/service/XydlService?wsdl" uri="wsdl/192.168.128.86:10080/busi-back-ws/service/XydlService.wsdl"/>
+</catalog>

src/i2client/DBHelper.java

@@ -0,0 +1,192 @@
+/*
+ * 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.
+ */
+package i2client;
+
+import java.io.BufferedReader;
+import java.lang.reflect.Field;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.ResultSetMetaData;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.List;
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.FileNotFoundException;
+import java.io.FileReader;
+import java.io.IOException;
+import java.io.InputStream;
+/**
+ *
+ * @author LENOVO
+ */
+public class DBHelper {
+    
+    private static String DRIVER="";
+    //private static final String URL="jdbc:mysql://192.168.1.188/dss";
+    private static  String URL="";
+    private static  String USER="";
+    private static  String PASSWORD="";
+   
+    public void GetText(String path){
+        if(DRIVER!=""){
+            return;
+        }
+        // 1.定义目标文件
+        File srcFile = new File(path);
+        // 2.创建一个流，指向目标文件
+        BufferedReader is = null;
+        try {
+            is = new BufferedReader(new FileReader(srcFile));
+            int i= 0;
+            String s = null;
+            while ((s = is.readLine()) != null) {// 使用readLine方法，一次读一行
+                if(i==0){
+                    DRIVER = s;
+                }
+                if(i==1){
+                    URL = s;
+                }
+                if(i==2){
+                    USER = s;
+                }
+                if(i==3){
+                    PASSWORD = s;
+                }
+                i++;
+            }
+        } catch (FileNotFoundException e) {
+                e.printStackTrace();
+        } catch (IOException e) {
+                e.printStackTrace();
+        } finally {
+                // 关闭io流
+                try {
+                        is.close();
+                } catch (IOException e) {
+                        e.printStackTrace();
+                }
+        }
+    }
+    /**
+     * 连接数据库
+     * @return 链接数据库对象
+     */
+    public Connection getConnection(){
+        GetText("/home/shjdconfig.txt");
+        //GetText("E:\\shjd\\shjdconfig.txt");
+        Connection conn=null;
+        try {
+            Class.forName(DRIVER);
+        } catch (ClassNotFoundException e) {
+            // TODO Auto-generated catch block
+            e.printStackTrace();
+        }
+        try {
+            conn=DriverManager.getConnection(URL, USER, PASSWORD);
+        } catch (SQLException e) {
+            // TODO Auto-generated catch block
+            e.printStackTrace();
+        }
+        return conn;
+    }
+     
+    /**
+     * 释放相应的资源
+     * @param rs
+     * @param pstmt
+     * @param conn
+     */
+    public void closeAll(ResultSet rs,PreparedStatement pstmt,Connection conn){
+        try {
+            if(rs!=null){
+                rs.close();
+            }
+            if(pstmt!=null){
+                pstmt.close();
+            }
+            if(conn!=null){
+                conn.close();
+            }
+        } catch (SQLException e) {
+            // TODO Auto-generated catch block
+            e.printStackTrace();
+        }
+    }
+     
+    /**
+     * 此方法可以完成增删改所有的操作
+     * @param sql
+     * @return true or false
+     */
+    public int excuteUpdate(String sql){
+        int res=0;//受影响的行数
+        Connection conn=null;
+        PreparedStatement pstmt = null;
+        ResultSet rs=null;
+        try {
+            conn=getConnection();
+            pstmt=conn.prepareStatement(sql);//装载sql语句
+            
+            res=pstmt.executeUpdate();
+             
+        } catch (SQLException e) {
+            // TODO Auto-generated catch block
+            e.printStackTrace();
+        }finally{
+            closeAll(rs, pstmt, conn);
+        }
+        return res;
+    }
+     
+    /**
+     * 使用泛型方法和反射机制进行封装
+     * @param sql
+     * @param params
+     * @param cls
+     * @return
+     */
+    public <T> List<T> executeQuery(String sql,List<Object> params,Class<T> cls) throws Exception{
+        Connection conn=null;
+        PreparedStatement pstmt = null;
+        ResultSet rs=null;
+        List<T> data=new ArrayList<T>();
+        try {
+            conn=getConnection();
+            pstmt=conn.prepareStatement(sql);//装载sql语句
+            if(params!=null){
+                //加入有？占位符，在执行之前把？占位符替换掉
+                for(int i=0;i<params.size();i++){
+                    pstmt.setObject(i+1, params.get(i));
+                }
+            }
+            rs=pstmt.executeQuery();
+            //把查询出来的记录封装成对应的实体类对象
+            ResultSetMetaData rsd=rs.getMetaData();//获得列对象,通过此对象可以得到表的结构，包括，列名，列的个数，列的数据类型
+            while(rs.next()){
+                T m=cls.newInstance();
+                for(int i=0;i<rsd.getColumnCount();i++){
+                    String col_name=rsd.getColumnName(i+1);//获得列名
+                    Object value=rs.getObject(col_name);//获得列所对应的值
+                    Field field=cls.getDeclaredField(col_name);
+                    field.setAccessible(true);//给私有属性设置可访问权
+                    field.set(m, value);//给对象的私有属性赋值
+                }
+                data.add(m);
+            }
+             
+        } catch (SQLException e) {
+            // TODO Auto-generated catch block
+            e.printStackTrace();
+        }finally{
+            closeAll(rs, pstmt, conn);
+        }
+        return data;
+    }
+}

src/i2client/GenerateXml.java

@@ -0,0 +1,447 @@
+/*
+ * 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.
+ */
+package i2client;
+
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import java.util.TreeMap;
+import java.io.IOException; 
+import java.io.StringReader;
+import org.jdom.Attribute;
+import org.jdom.Document; 
+import org.jdom.Element; 
+import org.jdom.JDOMException; 
+import org.jdom.input.SAXBuilder; 
+import org.xml.sax.InputSource;
+
+/**
+ *
+ * @author LENOVO
+ */
+public class GenerateXml {
+    //解析xml
+    public static TreeMap<String, String> xmlElements(String xmlDoc) throws JDOMException, IOException {
+        if (xmlDoc!=null && !xmlDoc.equals("")) {
+            Pattern p = Pattern.compile("\r|\n");
+            Matcher m = p.matcher(xmlDoc);
+            xmlDoc = m.replaceAll("");
+        }//创建一个新的字符串
+        StringReader read = new StringReader(xmlDoc);
+        //创建新的输入源SAX 解析器将使用 InputSource 对象来确定如何读取 XML 输入
+        InputSource source = new InputSource(read);
+        //创建一个新的SAXBuilder
+        SAXBuilder sb = new SAXBuilder();
+        TreeMap<String, String> rtnMap = new TreeMap<String, String>();
+        SAXBuilder builder = new SAXBuilder();
+        Document doc = (Document) builder.build(new StringReader(xmlDoc));
+        // 得到根节点
+        Element root = doc.getRootElement();
+        String rootName = root.getName();
+        rtnMap.put("root.name", rootName);
+        // 调用递归函数，得到所有最底层元素的名称和值，加入map中
+        convert(root, rtnMap, rootName);
+        return rtnMap;
+    }
+    public static void convert(Element e, Map<String, String> map, String lastname) {
+            if (e.getAttributes().size() > 0) {
+                    Iterator it_attr = e.getAttributes().iterator();
+                    while (it_attr.hasNext()) {
+                            Attribute attribute = (Attribute) it_attr.next();
+                            String attrname = attribute.getName();
+                            String attrvalue = e.getAttributeValue(attrname);
+                            // map.put( attrname, attrvalue);
+                            map.put(lastname + "." + attrname, attrvalue); // key 根据根节点 进行生成
+                    }
+            }
+            List children = e.getChildren();
+            Iterator it = children.iterator();
+            while (it.hasNext()) {
+                    Element child = (Element) it.next();
+                    /* String name = lastname + "." + child.getName(); */
+                    String name = child.getName();
+                    // 如果有子节点，则递归调用
+                    if (child.getChildren().size() > 0) {
+                            convert(child, map, lastname + "." + child.getName());
+                    } else {
+                            // 如果没有子节点，则把值加入map
+                            map.put(name, child.getText());
+                            // 如果该节点有属性，则把所有的属性值也加入map
+                            if (child.getAttributes().size() > 0) {
+                                    Iterator attr = child.getAttributes().iterator();
+                                    while (attr.hasNext()) {
+                                            Attribute attribute = (Attribute) attr.next();
+                                            String attrname = attribute.getName();
+                                            String attrvalue = child.getAttributeValue(attrname);
+                                            map.put(lastname + "." + child.getName() + "." + attrname, attrvalue);
+                                    }
+                            }
+                    }
+            }
+    }
+    public static String createCACData_moa(String cacid, String sensorid, String equipmentid, String timestamp, String phase, String[][] datavalue){
+        String cacdata = "";
+        cacdata += "<?xml version=\"1.0\" encoding=\"UTF-8\"?> ";
+        cacdata += "<request> ";
+        cacdata += "<monitordata cacid=\"" + cacid + "\" datanodenum=\"1\"> ";
+        cacdata += "<datanode sensorid=\"" + sensorid + "\"> ";
+        cacdata += "<type>023001</type> ";
+        cacdata += "<equipmentid>" + equipmentid + "</equipmentid> ";
+        cacdata += "<timestamp>" + timestamp + "</timestamp> ";
+        cacdata += "<attrs> ";
+        cacdata += "<attr name=\"Phase\" value=\""+phase+"\" alarm=\"FALSE\" /> ";
+        cacdata += "<attr name=\"SystemVoltage\" value=\"" + datavalue[0][0] + "\" alarm=\"" + datavalue[0][1] + "\"/> ";
+        cacdata += "<attr name=\"TotalCurrent\" value=\"" + datavalue[1][0] + "\" alarm=\"" + datavalue[1][1] + "\"/> ";
+        cacdata += "<attr name=\"ResistiveCurrent\" value=\"" + datavalue[2][0] + "\" alarm=\"" + datavalue[2][1] + "\"/> ";
+        cacdata += "<attr name=\"ActionCount\" value=\"" + datavalue[3][0] + "\" alarm=\"" + datavalue[3][1] + "\"/> ";
+        cacdata += "<attr name=\"LastActionTime\" value=\"" + datavalue[4][0] + "\" alarm=\"" + datavalue[4][1] + "\"/> ";
+        cacdata += "</attrs> ";
+        cacdata += "</datanode>";
+        cacdata += "</monitordata> ";
+        cacdata += "</request> ";
+        return cacdata;
+    }
+    public static String createCACData_eaif(String cacid, String sensorid, String equipmentid, String timestamp, String phase, String[][] datavalue,String code){
+        String cacdata = "";
+        cacdata = "";
+        cacdata += "<?xml version=\"1.0\" encoding=\"UTF-8\"?> ";
+        cacdata += "<request> ";
+        cacdata += "<monitordata cacid=\"" + cacid + "\" datanodenum=\"1\"> ";
+        cacdata += "<datanode sensorid=\"" + sensorid + "\"> ";
+        cacdata += "<type>" + code + "</type> ";
+        cacdata += "<equipmentid>" + equipmentid + "</equipmentid> ";
+        cacdata += "<timestamp>" + timestamp + "</timestamp> ";
+        cacdata += "<attrs> ";
+        cacdata += "<attr name=\"Phase\" value=\""+phase+"\" alarm=\"FALSE\" /> ";
+        cacdata += "<attr name=\"MaxTmp\" value=\""+ datavalue[0][0] + "\" alarm=\"" +datavalue[0][1] + "\"/> "; 
+        cacdata += "<attr name=\"MinTmp\" value=\""+ datavalue[1][0] + "\" alarm=\"" +datavalue[1][1] + "\"/> ";    
+        cacdata += "<attr name=\"AvgTmp\" value=\""+ datavalue[2][0] + "\" alarm=\"" +datavalue[2][1] + "\"/> ";           
+        cacdata += "</attrs> ";
+        cacdata += "</datanode>";
+        cacdata += "</monitordata> ";
+        cacdata += "</request> ";
+        return cacdata;
+    }
+    public static String createCACData_tx(String cacid, String sensorid, String equipmentid, String timestamp, String phase, String[][] datavalue){
+        String cacdata = "";
+        cacdata = "";
+        cacdata += "<?xml version=\"1.0\" encoding=\"UTF-8\"?> ";
+        cacdata += "<request> ";
+        cacdata += "<monitordata cacid=\"" + cacid + "\" datanodenum=\"1\"> ";
+        cacdata += "<datanode sensorid=\"" + sensorid + "\"> ";
+        cacdata += "<type>021004</type> ";
+        cacdata += "<equipmentid>" + equipmentid + "</equipmentid> ";
+        cacdata += "<timestamp>" + timestamp + "</timestamp> ";
+        cacdata += "<attrs> ";
+        cacdata += "<attr name=\"Phase\" value=\"" + phase + "\" alarm=\"FALSE\" /> ";
+        cacdata += "<attr name=\"TotalCoreCurrent\" value=\""+ datavalue[0][0] + "\" alarm=\"" +datavalue[0][1] + "\"/> ";         
+        cacdata += "</attrs> ";
+        cacdata += "</datanode>";
+        cacdata += "</monitordata> ";
+        cacdata += "</request> ";
+        return cacdata;
+    }
+    public static String createCACData_eia(String cacid, String sensorid, String equipmentid, String timestamp, String phase, String[][] datavalue){
+        String cacdata = "";
+        cacdata = "";
+        cacdata += "<?xml version=\"1.0\" encoding=\"UTF-8\"?> ";
+        cacdata += "<request> ";
+        cacdata += "<monitordata cacid=\"" + cacid + "\" datanodenum=\"1\"> ";
+        cacdata += "<datanode sensorid=\"" + sensorid + "\"> ";
+        cacdata += "<type>022001</type> ";
+        cacdata += "<equipmentid>" + equipmentid + "</equipmentid> ";
+        cacdata += "<timestamp>" + timestamp + "</timestamp> ";
+        cacdata += "<attrs> ";
+        cacdata += "<attr name=\"Phase\" value=\"" + phase + "\" alarm=\"FALSE\" /> ";
+        cacdata += "<attr name=\"Capacitance\" value=\""+ datavalue[0][0] + "\" alarm=\"" +datavalue[0][1] + "\"/> ";         
+        cacdata += "<attr name=\"LossFactor\" value=\""+ datavalue[1][0] + "\" alarm=\"" +datavalue[1][1] + "\"/> ";         
+        cacdata += "<attr name=\"UnbalanceCurrent\" value=\""+ datavalue[2][0] + "\" alarm=\"" +datavalue[2][1] + "\"/> ";         
+        cacdata += "<attr name=\"UnbalanceVoltage\" value=\""+ datavalue[3][0] + "\" alarm=\"" +datavalue[3][1] + "\"/> ";         
+        cacdata += "<attr name=\"TotalCurrent\" value=\""+ datavalue[4][0] + "\" alarm=\"" +datavalue[4][1] + "\"/> ";         
+        cacdata += "<attr name=\"SystemVoltage\" value=\""+ datavalue[5][0] + "\" alarm=\"" +datavalue[5][1] + "\"/> ";         
+        cacdata += "</attrs> ";
+        cacdata += "</datanode>";
+        cacdata += "</monitordata> ";
+        cacdata += "</request> ";
+        return cacdata;
+    }
+    public static String createCACData_sf6pressure(String cacid, String sensorid, String equipmentid, String timestamp,String phase, String[][] datavalue)
+    {
+        String cacdata = "";
+        cacdata += "<?xml version=\"1.0\" encoding=\"UTF-8\"?> ";
+        cacdata += "<request> ";
+        cacdata += "<monitordata cacid=\"" + cacid + "\" datanodenum=\"1\"> ";
+        cacdata += "<datanode sensorid=\"" + sensorid + "\"> ";
+        cacdata += "<type>024004</type> ";
+        cacdata += "<equipmentid>" + equipmentid + "</equipmentid> ";
+        cacdata += "<timestamp>" + timestamp + "</timestamp> ";
+        cacdata += "<attrs> ";
+        cacdata += "<attr name=\"Phase\" value=\""+phase+"\" alarm=\"FALSE\" /> ";
+        cacdata += "<attr name=\"Temperature\" value=\"" + datavalue[0][0] + "\" alarm=\"" + datavalue[0][1] + "\"/> ";
+        cacdata += "<attr name=\"AbsolutePressure\" value=\"" + (datavalue[1][0] +900)+ "\" alarm=\"" + datavalue[1][1] + "\"/> ";
+        cacdata += "<attr name=\"Density\" value=\"" + datavalue[2][0] + "\" alarm=\"" + datavalue[2][1] + "\"/> ";
+        cacdata += "<attr name=\"Moisture\" value=\"" + datavalue[3][0] + "\" alarm=\"" + datavalue[3][1] + "\"/> ";
+        cacdata += "<attr name=\"Pressure20C\" value=\"" + datavalue[1][0] + "\" alarm=\"" + datavalue[1][1] + "\"/> ";
+        cacdata += "</attrs> ";
+        cacdata += "</datanode>";
+        cacdata += "</monitordata> ";
+        cacdata += "</request> ";
+        return cacdata;
+    }
+    public static String createCACData_sf6moisture(String cacid, String sensorid, String equipmentid, String timestamp,String phase, String[][] datavalue)
+    {
+        String cacdata = "";
+        cacdata += "<?xml version=\"1.0\" encoding=\"UTF-8\"?> ";
+        cacdata += "<request> ";
+        cacdata += "<monitordata cacid=\"" + cacid + "\" datanodenum=\"1\"> ";
+        //A相
+        cacdata += "<datanode sensorid=\"" + sensorid + "\"> ";
+        cacdata += "<type>024005</type> ";
+        cacdata += "<equipmentid>" + equipmentid + "</equipmentid> ";
+        cacdata += "<timestamp>" + timestamp + "</timestamp> ";
+        cacdata += "<attrs> ";
+        cacdata += "<attr name=\"Phase\" value=\""+phase+"\" alarm=\"FALSE\" /> ";
+        cacdata += "<attr name=\"Temperature\" value=\"" + datavalue[0][0] + "\" alarm=\"" + datavalue[0][1] + "\"/> ";
+        cacdata += "<attr name=\"Moisture\" value=\"" + datavalue[1][0] + "\" alarm=\"" + datavalue[1][1] + "\"/> ";
+        cacdata += "</attrs> ";
+        cacdata += "</datanode>";         
+        cacdata += "</monitordata> ";
+        cacdata += "</request> ";
+        return cacdata;
+    }
+    public static String createCACData_yw(String cacid, String sensorid, String equipmentid, String timestamp, String phase, String[][] datavalue)
+    {
+        String cacdata = "";
+        cacdata += "<?xml version=\"1.0\" encoding=\"UTF-8\"?> ";
+        cacdata += "<request> ";
+        cacdata += "<monitordata cacid=\"" + cacid + "\" datanodenum=\"1\"> ";
+        cacdata += "<datanode sensorid=\"" + sensorid + "\"> ";
+        cacdata += "<type>021005</type> ";
+        cacdata += "<equipmentid>" + equipmentid + "</equipmentid> ";
+        cacdata += "<timestamp>" + timestamp + "</timestamp> ";
+        cacdata += "<attrs> ";
+        cacdata += "<attr name=\"Phase\" value=\"" + phase + "\" alarm=\"FALSE\" /> ";
+        cacdata += "<attr name=\"OilTemperature\" value=\"" + datavalue[0][0] + "\" alarm=\"" + datavalue[0][1] + "\"/> ";
+        cacdata += "</attrs> ";
+        cacdata += "</datanode>";
+        cacdata += "</monitordata> ";
+        cacdata += "</request> ";
+        return cacdata;
+    }
+    public static String createCACData_mlh(String cacid, String sensorid, String equipmentid, String timestamp, String phase, String[][] datavalue,String code)
+    {
+        String cacdata = "";
+        cacdata += "<?xml version=\"1.0\" encoding=\"UTF-8\"?> ";
+        cacdata += "<request> ";
+        cacdata += "<monitordata cacid=\"" + cacid + "\" datanodenum=\"1\"> ";
+        cacdata += "<datanode sensorid=\"" + sensorid + "\"> ";
+        cacdata += "<type>"+code+"</type> ";
+        cacdata += "<equipmentid>" + equipmentid + "</equipmentid> ";
+        cacdata += "<timestamp>" + timestamp + "</timestamp> ";
+        cacdata += "<attrs> ";
+        cacdata += "<attr name=\"Phase\" value=\"" + phase + "\" alarm=\"FALSE\" /> ";
+        cacdata += "<attr name=\"AirTemperature\" value=\"" + datavalue[0][0] + "\" alarm=\"" + datavalue[0][1] + "\"/> ";
+        cacdata += "<attr name=\"AirPressure\" value=\"" + datavalue[3][0] + "\" alarm=\"" + datavalue[3][1] + "\"/> ";
+        cacdata += "<attr name=\"Humidity\" value=\"" + datavalue[1][0] + "\" alarm=\"" + datavalue[1][1] + "\"/> ";
+        cacdata += "<attr name=\"Precipitation\" value=\"" + datavalue[5][0] + "\" alarm=\"" + datavalue[5][1] + "\"/> ";
+        cacdata += "<attr name=\"PrecipitationIntensity\" value=\"" + datavalue[4][0] + "\" alarm=\"" + datavalue[4][1] + "\"/> ";
+        cacdata += "<attr name=\"RadiationIntensity\" value=\"" + datavalue[2][0] + "\" alarm=\"" + datavalue[2][1] + "\"/> ";
+        cacdata += "<attr name=\"wdgustspd\" value=\"" + datavalue[6][0] + "\" alarm=\"" + datavalue[6][1] + "\"/> ";
+        cacdata += "<attr name=\"wddir\" value=\"" + datavalue[7][0] + "\" alarm=\"" + datavalue[7][1] + "\"/> ";
+        cacdata += "</attrs> ";
+        cacdata += "</datanode>";
+        cacdata += "</monitordata> ";
+        cacdata += "</request> ";
+        return cacdata;
+    }
+    public static String createCACData_dmh(String cacid, String sensorid, String equipmentid, String timestamp, String phase, String[][] datavalue)
+    {
+        String cacdata = "";
+        cacdata += "<?xml version=\"1.0\" encoding=\"UTF-8\"?> ";
+        cacdata += "<request> ";
+        cacdata += "<monitordata cacid=\"" + cacid + "\" datanodenum=\"1\"> ";
+        cacdata += "<datanode sensorid=\"" + sensorid + "\"> ";
+        cacdata += "<type>025001</type> ";
+        cacdata += "<equipmentid>" + equipmentid + "</equipmentid> ";
+        cacdata += "<timestamp>" + timestamp + "</timestamp> ";
+        cacdata += "<attrs> ";
+        cacdata += "<attr name=\"Phase\" value=\"" + phase + "\" alarm=\"FALSE\" /> ";
+        cacdata += "<attr name=\"OilTemperature\" value=\"" + datavalue[0][0] + "\" alarm=\"" + datavalue[0][1] + "\"/> ";
+        cacdata += "</attrs> ";
+        cacdata += "</datanode>";
+        cacdata += "</monitordata> ";
+        cacdata += "</request> ";
+        return cacdata;
+    }
+    public static String createCACData_pd_h(String cacid, String sensorid, String equipmentid, String timestamp, String phase, String[][] datavalue,String code)
+    {
+        String cacdata = "";
+        cacdata += "<?xml version=\"1.0\" encoding=\"UTF-8\"?> ";
+        cacdata += "<request> ";
+        cacdata += "<monitordata cacid=\"" + cacid + "\" datanodenum=\"1\"> ";
+        cacdata += "<datanode sensorid=\"" + sensorid + "\"> ";
+        cacdata += "<type>" + code + "</type> ";
+        cacdata += "<equipmentid>" + equipmentid + "</equipmentid> ";
+        cacdata += "<timestamp>" + timestamp + "</timestamp> ";
+        cacdata += "<attrs> ";
+        cacdata += "<attr name=\"Phase\" value=\"" + phase + "\" alarm=\"FALSE\" /> ";
+        cacdata += "<attr name=\"DischargeCapacity\" value=\"" + datavalue[0][0] + "\" alarm=\"" + datavalue[0][1] + "\"/> ";
+        cacdata += "<attr name=\"DischargePosition\" value=\"" + datavalue[1][0] + "\" alarm=\"" + datavalue[1][1] + "\"/> ";
+        cacdata += "<attr name=\"PulseCount\" value=\"" + datavalue[2][0] + "\" alarm=\"" + datavalue[2][1] + "\"/> ";
+        cacdata += "<attr name=\"DischargeWaveform\" value=\"" + datavalue[3][0] + "\" alarm=\"" + datavalue[3][1] + "\"/> ";
+        cacdata += "<attr name=\"PaDschAlm\" value=\"" + datavalue[4][0] + "\" alarm=\"" + datavalue[4][1] + "\"/> ";
+        cacdata += "<attr name=\"DschType\" value=\"" + datavalue[5][0] + "\" alarm=\"" + datavalue[5][1] + "\"/> ";
+        cacdata += "</attrs> ";
+        cacdata += "</datanode>";
+        cacdata += "</monitordata> ";
+        cacdata += "</request> ";
+        return cacdata;
+    }
+    public static String createCACData_DLQWave(String cacid, String sensorid, String equipmentid, String timestamp, String phase, String[][] datavalue)
+    {
+        String cacdata = "";
+        cacdata += "<?xml version=\"1.0\" encoding=\"UTF-8\"?> ";
+        cacdata += "<request> ";
+        cacdata += "<monitordata cacid=\"" + cacid + "\" datanodenum=\"1\"> ";
+        //A相
+        cacdata += "<datanode sensorid=\"" + sensorid + "\"> ";
+        cacdata += "<type>024002</type> ";
+        cacdata += "<equipmentid>" + equipmentid + "</equipmentid> ";
+        cacdata += "<timestamp>" + timestamp + "</timestamp> ";
+        cacdata += "<attrs> ";
+        cacdata += "<attr name=\"Phase\" value=\"" + phase + "\" alarm=\"FALSE\" /> ";
+        cacdata += "<attr name=\"Action\" value=\"" + datavalue[0][0] + "\" alarm=\"" + datavalue[0][1] + "\"/> ";
+        cacdata += "<attr name=\"CoilWaveform\" value=\"" + datavalue[1][0] + "\" alarm=\"" + datavalue[1][1] + "\"/> ";
+        cacdata += "</attrs> ";
+        cacdata += "</datanode>";
+        cacdata += "</monitordata> ";
+        cacdata += "</request> ";
+        return cacdata;
+    }
+    
+    public static String createCACData_YSP(String cacid, String sensorid, String equipmentid, String timestamp, String phase, String[][] datavalue)
+    {
+        String cacdata = "";
+        cacdata += "<?xml version=\"1.0\" encoding=\"UTF-8\"?> ";
+        cacdata += "<request> ";
+        cacdata += "<monitordata cacid=\"" + cacid + "\" datanodenum=\"1\"> ";
+        cacdata += "<datanode sensorid=\"" + sensorid + "\"> ";
+        cacdata += "<type>021002</type> ";
+        cacdata += "<equipmentid>" + equipmentid + "</equipmentid> ";
+        cacdata += "<timestamp>" + timestamp + "</timestamp> ";
+        cacdata += "<attrs> ";
+        cacdata += "<attr name=\"Phase\" value=\"" + phase + "\" alarm=\"FALSE\" /> ";
+        cacdata += "<attr name=\"H2\" value=\"" + datavalue[0][0] + "\" alarm=\"" + datavalue[0][1] + "\"/> ";
+        cacdata += "<attr name=\"CH4\" value=\"" + datavalue[1][0] + "\" alarm=\"" + datavalue[1][1] + "\"/> ";
+        cacdata += "<attr name=\"C2H6\" value=\"" + datavalue[2][0] + "\" alarm=\"" + datavalue[2][1] + "\"/> ";
+        cacdata += "<attr name=\"C2H4\" value=\"" + datavalue[3][0] + "\" alarm=\"" + datavalue[3][1] + "\"/> ";
+        cacdata += "<attr name=\"C2H2\" value=\"" + datavalue[4][0] + "\" alarm=\"" + datavalue[4][1] + "\"/> ";
+        cacdata += "<attr name=\"CO\" value=\"" + datavalue[5][0] + "\" alarm=\"" + datavalue[5][1] + "\"/> ";
+        cacdata += "<attr name=\"CO2\" value=\"" + datavalue[6][0] + "\" alarm=\"" + datavalue[6][1] + "\"/> ";
+        cacdata += "<attr name=\"O2\" value=\"" + datavalue[7][0] + "\" alarm=\"" + datavalue[7][1] + "\"/> ";
+        cacdata += "<attr name=\"N2\" value=\"" + datavalue[8][0] + "\" alarm=\"" + datavalue[8][1] + "\"/> ";
+        cacdata += "<attr name=\"TotalHydrocarbon\" value=\"" + datavalue[9][0] + "\" alarm=\"" + datavalue[9][1] + "\"/> ";
+        cacdata += "<attr name=\"GasPress\" value=\"" + datavalue[10][0] + "\" alarm=\"" + datavalue[10][1] + "\"/> ";
+        cacdata += "<attr name=\"H2O\" value=\"" + datavalue[11][0] + "\" alarm=\"" + datavalue[11][1] + "\"/> ";
+        cacdata += "</attrs> ";
+        cacdata += "</datanode>";
+        cacdata += "</monitordata> ";
+        cacdata += "</request> ";
+        return cacdata;
+    }
+    
+    public static String createCACData_KGG(String cacid, String sensorid, String equipmentid, String timestamp, String phase, String[][] datavalue)
+    {
+        String cacdata = "";
+        cacdata += "<?xml version=\"1.0\" encoding=\"UTF-8\"?> ";
+        cacdata += "<request> ";
+        cacdata += "<monitordata cacid=\"" + cacid + "\" datanodenum=\"1\"> ";
+        cacdata += "<datanode sensorid=\"" + sensorid + "\"> ";
+        cacdata += "<type>026001</type> ";
+        cacdata += "<equipmentid>" + equipmentid + "</equipmentid> ";
+        cacdata += "<timestamp>" + timestamp + "</timestamp> ";
+        cacdata += "<attrs> ";
+        cacdata += "<attr name=\"Phase\" value=\"" + phase + "\" alarm=\"FALSE\" /> ";
+        cacdata += "<attr name=\"OlTmpA\" value=\"" + datavalue[0][0] + "\" alarm=\"" + datavalue[0][1] + "\"/> ";
+        cacdata += "<attr name=\"OlTmpB\" value=\"" + datavalue[1][0] + "\" alarm=\"" + datavalue[1][1] + "\"/> ";
+        cacdata += "<attr name=\"OlTmpC\" value=\"" + datavalue[2][0] + "\" alarm=\"" + datavalue[2][1] + "\"/> ";
+        cacdata += "<attr name=\"IlTmpA\" value=\"" + datavalue[3][0] + "\" alarm=\"" + datavalue[3][1] + "\"/> ";
+        cacdata += "<attr name=\"IlTmpB\" value=\"" + datavalue[4][0] + "\" alarm=\"" + datavalue[4][1] + "\"/> ";
+        cacdata += "<attr name=\"IlTmpC\" value=\"" + datavalue[5][0] + "\" alarm=\"" + datavalue[5][1] + "\"/> ";
+        cacdata += "<attr name=\"OntologyTmp\" value=\"" + datavalue[6][0] + "\" alarm=\"" + datavalue[6][1] + "\"/> ";
+        cacdata += "</attrs> ";
+        cacdata += "</datanode>";
+        cacdata += "</monitordata> ";
+        cacdata += "</request> ";
+        return cacdata;
+    }
+      public static String createCACData_TMT(String cacid, String sensorid, String equipmentid, String timestamp, String phase, String[][] datavalue)
+    {
+        String cacdata = "";
+        cacdata += "<?xml version=\"1.0\" encoding=\"UTF-8\"?> ";
+        cacdata += "<request> ";
+        cacdata += "<monitordata cacid=\"" + cacid + "\" datanodenum=\"1\"> ";
+        cacdata += "<datanode sensorid=\"" + sensorid + "\"> ";
+        cacdata += "<type>026002</type> ";
+        cacdata += "<equipmentid>" + equipmentid + "</equipmentid> ";
+        cacdata += "<timestamp>" + timestamp + "</timestamp> ";
+        cacdata += "<attrs> ";
+        cacdata += "<attr name=\"Phase\" value=\"" + phase + "\" alarm=\"FALSE\" /> ";
+        cacdata += "<attr name=\"Tmp\" value=\"" + datavalue[0][0] + "\" alarm=\"" + datavalue[0][1] + "\"/> ";
+        cacdata += "</attrs> ";
+        cacdata += "</datanode>";
+        cacdata += "</monitordata> ";
+        cacdata += "</request> ";
+        return cacdata;
+    }
+    public static String createCACData_scur(String cacid, String sensorid, String equipmentid, String timestamp, String phase,String[][] datavalue,String code)
+    {    //电缆环流
+        String cacdata = "";
+        cacdata = "";
+        cacdata += "<?xml version=\"1.0\" encoding=\"UTF-8\"?> ";
+        cacdata += "<request> ";
+        cacdata += "<monitordata cacid=\"" + cacid + "\" datanodenum=\"1\"> ";
+        cacdata += "<datanode sensorid=\"" + sensorid + "\"> ";
+        cacdata += "<type>"+ code +"</type> ";
+        cacdata += "<equipmentid>" + equipmentid + "</equipmentid> ";
+        cacdata += "<timestamp>" + timestamp + "</timestamp> ";
+        cacdata += "<attrs> ";
+        cacdata += "<attr name=\"Phase\" value=\"" + phase + "\" alarm=\"FALSE\" /> ";
+        cacdata += "<attr name=\"TotalCoreCurrent\" value=\""+ datavalue[0][0] + "\" alarm=\"" +datavalue[0][1] + "\"/> ";         
+        cacdata += "</attrs> ";
+        cacdata += "</datanode>";
+        cacdata += "</monitordata> ";
+        cacdata += "</request> ";
+        return cacdata;   
+    }
+    public static String createCACData_DLQChargeTime(String cacid, String sensorid, String equipmentid, String timestamp, String phase, String[][] datavalue)
+    {
+        String cacdata = "";
+        cacdata += "<?xml version=\"1.0\" encoding=\"UTF-8\"?> ";
+        cacdata += "<request> ";
+        cacdata += "<monitordata cacid=\"" + cacid + "\" datanodenum=\"1\"> ";
+        //A相
+        cacdata += "<datanode sensorid=\"" + sensorid + "\"> ";
+        cacdata += "<type>024006</type> ";
+        cacdata += "<equipmentid>" + equipmentid + "</equipmentid> ";
+        cacdata += "<timestamp>" + timestamp + "</timestamp> ";
+        cacdata += "<attrs> ";
+        cacdata += "<attr name=\"Phase\" value=\"" + phase + "\" alarm=\"FALSE\" /> ";
+        cacdata += "<attr name=\"ChargeTime\" value=\"" + datavalue[0][0] + "\" alarm=\"" + datavalue[0][1] + "\"/> ";
+        cacdata += "</attrs> ";
+        cacdata += "</datanode>";
+        cacdata += "</monitordata> ";
+        cacdata += "</request> ";
+        return cacdata;
+    }
+
+}
+    
+
+
+

src/i2client/Index.form

@@ -0,0 +1,61 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+
+<Form version="1.3" maxVersion="1.9" type="org.netbeans.modules.form.forminfo.JFrameFormInfo">
+  <Properties>
+    <Property name="defaultCloseOperation" type="int" value="3"/>
+    <Property name="title" type="java.lang.String" value="I2&#x901a;&#x9053;&#x6570;&#x636e;&#x663e;&#x793a;"/>
+  </Properties>
+  <SyntheticProperties>
+    <SyntheticProperty name="formSizePolicy" type="int" value="1"/>
+    <SyntheticProperty name="generateCenter" type="boolean" value="false"/>
+  </SyntheticProperties>
+  <AuxValues>
+    <AuxValue name="FormSettings_autoResourcing" type="java.lang.Integer" value="0"/>
+    <AuxValue name="FormSettings_autoSetComponentName" type="java.lang.Boolean" value="false"/>
+    <AuxValue name="FormSettings_generateFQN" type="java.lang.Boolean" value="true"/>
+    <AuxValue name="FormSettings_generateMnemonicsCode" type="java.lang.Boolean" value="false"/>
+    <AuxValue name="FormSettings_i18nAutoMode" type="java.lang.Boolean" value="false"/>
+    <AuxValue name="FormSettings_layoutCodeTarget" type="java.lang.Integer" value="1"/>
+    <AuxValue name="FormSettings_listenerGenerationStyle" type="java.lang.Integer" value="0"/>
+    <AuxValue name="FormSettings_variablesLocal" type="java.lang.Boolean" value="false"/>
+    <AuxValue name="FormSettings_variablesModifier" type="java.lang.Integer" value="2"/>
+  </AuxValues>
+
+  <Layout>
+    <DimensionLayout dim="0">
+      <Group type="103" groupAlignment="0" attributes="0">
+          <Group type="102" alignment="0" attributes="0">
+              <EmptySpace max="-2" attributes="0"/>
+              <Component id="jScrollPane1" pref="785" max="32767" attributes="0"/>
+              <EmptySpace max="-2" attributes="0"/>
+          </Group>
+      </Group>
+    </DimensionLayout>
+    <DimensionLayout dim="1">
+      <Group type="103" groupAlignment="0" attributes="0">
+          <Group type="102" alignment="0" attributes="0">
+              <EmptySpace max="-2" attributes="0"/>
+              <Component id="jScrollPane1" min="-2" pref="344" max="-2" attributes="0"/>
+              <EmptySpace pref="19" max="32767" attributes="0"/>
+          </Group>
+      </Group>
+    </DimensionLayout>
+  </Layout>
+  <SubComponents>
+    <Container class="javax.swing.JScrollPane" name="jScrollPane1">
+      <AuxValues>
+        <AuxValue name="autoScrollPane" type="java.lang.Boolean" value="true"/>
+      </AuxValues>
+
+      <Layout class="org.netbeans.modules.form.compat2.layouts.support.JScrollPaneSupportLayout"/>
+      <SubComponents>
+        <Component class="javax.swing.JTextArea" name="jTextArea1">
+          <Properties>
+            <Property name="columns" type="int" value="20"/>
+            <Property name="rows" type="int" value="5"/>
+          </Properties>
+        </Component>
+      </SubComponents>
+    </Container>
+  </SubComponents>
+</Form>

test/README.TXT

@@ -0,0 +1,32 @@
+========================
+BUILD OUTPUT DESCRIPTION
+========================
+
+When you build an Java application project that has a main class, the IDE
+automatically copies all of the JAR
+files on the projects classpath to your projects dist/lib folder. The IDE
+also adds each of the JAR files to the Class-Path element in the application
+JAR files manifest file (MANIFEST.MF).
+
+To run the project from the command line, go to the dist folder and
+type the following:
+
+java -jar "I2client.jar" 
+
+To distribute this project, zip up the dist folder (including the lib folder)
+and distribute the ZIP file.
+
+Notes:
+
+* If two JAR files on the project classpath have the same name, only the first
+JAR file is copied to the lib folder.
+* Only JAR files are copied to the lib folder.
+If the classpath contains other types of files or folders, these files (folders)
+are not copied.
+* If a library on the projects classpath also has a Class-Path element
+specified in the manifest,the content of the Class-Path element has to be on
+the projects runtime path.
+* To set a main class in a standard Java project, right-click the project node
+in the Projects window and choose Properties. Then click Run and enter the
+class name in the Main Class field. Alternatively, you can manually type the
+class name in the manifest Main-Class element.

更新日志.txt

@@ -0,0 +1,2 @@
+8月20日，改变SF6上传标志位赋值规则，把原来的三相都传送成功设置标志位为1改为从I2表里面查询所有相关的sensorid，当所有sensorid的数据都传送成功才设置标志为1
+9月5日，改变局放数据的上传规则，由原来的上传15分钟前的标志位为非1的数据更改为上传15分钟前的标志位为非1的数据或局放告警状态为大于0的标志位为非1的数据