diff --git a/.gitignore b/.gitignore deleted file mode 100644 index 9154f4c..0000000 --- a/.gitignore +++ /dev/null @@ -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* - diff --git a/I2.sh b/I2.sh new file mode 100644 index 0000000..8973cdd --- /dev/null +++ b/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 diff --git a/I2client.sh b/I2client.sh new file mode 100644 index 0000000..c6d5223 --- /dev/null +++ b/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 + + + + + diff --git a/README.md b/README.md deleted file mode 100644 index 64b7c20..0000000 --- a/README.md +++ /dev/null @@ -1,2 +0,0 @@ -# I2client - diff --git a/activation.jar b/activation.jar new file mode 100644 index 0000000..b7a4b47 Binary files /dev/null and b/activation.jar differ diff --git a/axis.jar b/axis.jar new file mode 100644 index 0000000..20b09a5 Binary files /dev/null and b/axis.jar differ diff --git a/commons-discovery-0.2.jar b/commons-discovery-0.2.jar new file mode 100644 index 0000000..b885548 Binary files /dev/null and b/commons-discovery-0.2.jar differ diff --git a/commons-logging-1.0.4.jar b/commons-logging-1.0.4.jar new file mode 100644 index 0000000..b73a80f Binary files /dev/null and b/commons-logging-1.0.4.jar differ diff --git a/examples.jar b/examples.jar new file mode 100644 index 0000000..8f0b457 Binary files /dev/null and b/examples.jar differ diff --git a/i2.tar.gz b/i2.tar.gz new file mode 100644 index 0000000..84c7cd0 Binary files /dev/null and b/i2.tar.gz differ diff --git a/jaxrpc.jar b/jaxrpc.jar new file mode 100644 index 0000000..a2c13d9 Binary files /dev/null and b/jaxrpc.jar differ diff --git a/jdom.jar b/jdom.jar new file mode 100644 index 0000000..288e64c Binary files /dev/null and b/jdom.jar differ diff --git a/jna.jar b/jna.jar new file mode 100644 index 0000000..33461ec Binary files /dev/null and b/jna.jar differ diff --git a/mailapi_1_3_1.jar b/mailapi_1_3_1.jar new file mode 100644 index 0000000..d6b5d37 Binary files /dev/null and b/mailapi_1_3_1.jar differ diff --git a/manifest.mf b/manifest.mf new file mode 100644 index 0000000..328e8e5 --- /dev/null +++ b/manifest.mf @@ -0,0 +1,3 @@ +Manifest-Version: 1.0 +X-COMMENT: Main-Class will be added automatically by build + diff --git a/saaj.jar b/saaj.jar new file mode 100644 index 0000000..4ea696e Binary files /dev/null and b/saaj.jar differ diff --git a/src/META-INF/jax-ws-catalog.xml b/src/META-INF/jax-ws-catalog.xml new file mode 100644 index 0000000..0012ece --- /dev/null +++ b/src/META-INF/jax-ws-catalog.xml @@ -0,0 +1,5 @@ + + + + + \ No newline at end of file diff --git a/src/i2client/DBHelper.java b/src/i2client/DBHelper.java new file mode 100644 index 0000000..27ad903 --- /dev/null +++ b/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 List executeQuery(String sql,List params,Class cls) throws Exception{ + Connection conn=null; + PreparedStatement pstmt = null; + ResultSet rs=null; + List data=new ArrayList(); + try { + conn=getConnection(); + pstmt=conn.prepareStatement(sql);//装载sql语句 + if(params!=null){ + //加入有？占位符，在执行之前把？占位符替换掉 + for(int i=0;i 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 rtnMap = new TreeMap(); + 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 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 += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += "023001 "; + cacdata += "" + equipmentid + " "; + cacdata += "" + timestamp + " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += ""; + cacdata += " "; + cacdata += " "; + 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 += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += "" + code + " "; + cacdata += "" + equipmentid + " "; + cacdata += "" + timestamp + " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += ""; + cacdata += " "; + cacdata += " "; + return cacdata; + } + public static String createCACData_tx(String cacid, String sensorid, String equipmentid, String timestamp, String phase, String[][] datavalue){ + String cacdata = ""; + cacdata = ""; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += "021004 "; + cacdata += "" + equipmentid + " "; + cacdata += "" + timestamp + " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += ""; + cacdata += " "; + cacdata += " "; + return cacdata; + } + public static String createCACData_eia(String cacid, String sensorid, String equipmentid, String timestamp, String phase, String[][] datavalue){ + String cacdata = ""; + cacdata = ""; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += "022001 "; + cacdata += "" + equipmentid + " "; + cacdata += "" + timestamp + " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += ""; + cacdata += " "; + cacdata += " "; + return cacdata; + } + public static String createCACData_sf6pressure(String cacid, String sensorid, String equipmentid, String timestamp,String phase, String[][] datavalue) + { + String cacdata = ""; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += "024004 "; + cacdata += "" + equipmentid + " "; + cacdata += "" + timestamp + " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += ""; + cacdata += " "; + cacdata += " "; + return cacdata; + } + public static String createCACData_sf6moisture(String cacid, String sensorid, String equipmentid, String timestamp,String phase, String[][] datavalue) + { + String cacdata = ""; + cacdata += " "; + cacdata += " "; + cacdata += " "; + //A相 + cacdata += " "; + cacdata += "024005 "; + cacdata += "" + equipmentid + " "; + cacdata += "" + timestamp + " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += ""; + cacdata += " "; + cacdata += " "; + return cacdata; + } + public static String createCACData_yw(String cacid, String sensorid, String equipmentid, String timestamp, String phase, String[][] datavalue) + { + String cacdata = ""; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += "021005 "; + cacdata += "" + equipmentid + " "; + cacdata += "" + timestamp + " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += ""; + cacdata += " "; + cacdata += " "; + return cacdata; + } + public static String createCACData_mlh(String cacid, String sensorid, String equipmentid, String timestamp, String phase, String[][] datavalue,String code) + { + String cacdata = ""; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += ""+code+" "; + cacdata += "" + equipmentid + " "; + cacdata += "" + timestamp + " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += ""; + cacdata += " "; + cacdata += " "; + return cacdata; + } + public static String createCACData_dmh(String cacid, String sensorid, String equipmentid, String timestamp, String phase, String[][] datavalue) + { + String cacdata = ""; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += "025001 "; + cacdata += "" + equipmentid + " "; + cacdata += "" + timestamp + " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += ""; + cacdata += " "; + cacdata += " "; + 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 += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += "" + code + " "; + cacdata += "" + equipmentid + " "; + cacdata += "" + timestamp + " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += ""; + cacdata += " "; + cacdata += " "; + return cacdata; + } + public static String createCACData_DLQWave(String cacid, String sensorid, String equipmentid, String timestamp, String phase, String[][] datavalue) + { + String cacdata = ""; + cacdata += " "; + cacdata += " "; + cacdata += " "; + //A相 + cacdata += " "; + cacdata += "024002 "; + cacdata += "" + equipmentid + " "; + cacdata += "" + timestamp + " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += ""; + cacdata += " "; + cacdata += " "; + return cacdata; + } + + public static String createCACData_YSP(String cacid, String sensorid, String equipmentid, String timestamp, String phase, String[][] datavalue) + { + String cacdata = ""; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += "021002 "; + cacdata += "" + equipmentid + " "; + cacdata += "" + timestamp + " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += ""; + cacdata += " "; + cacdata += " "; + return cacdata; + } + + public static String createCACData_KGG(String cacid, String sensorid, String equipmentid, String timestamp, String phase, String[][] datavalue) + { + String cacdata = ""; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += "026001 "; + cacdata += "" + equipmentid + " "; + cacdata += "" + timestamp + " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += ""; + cacdata += " "; + cacdata += " "; + return cacdata; + } + public static String createCACData_TMT(String cacid, String sensorid, String equipmentid, String timestamp, String phase, String[][] datavalue) + { + String cacdata = ""; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += "026002 "; + cacdata += "" + equipmentid + " "; + cacdata += "" + timestamp + " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += ""; + cacdata += " "; + cacdata += " "; + 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 += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += ""+ code +" "; + cacdata += "" + equipmentid + " "; + cacdata += "" + timestamp + " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += ""; + cacdata += " "; + cacdata += " "; + return cacdata; + } + public static String createCACData_DLQChargeTime(String cacid, String sensorid, String equipmentid, String timestamp, String phase, String[][] datavalue) + { + String cacdata = ""; + cacdata += " "; + cacdata += " "; + cacdata += " "; + //A相 + cacdata += " "; + cacdata += "024006 "; + cacdata += "" + equipmentid + " "; + cacdata += "" + timestamp + " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += " "; + cacdata += ""; + cacdata += " "; + cacdata += " "; + return cacdata; + } + +} + + + + diff --git a/src/i2client/Index.form b/src/i2client/Index.form new file mode 100644 index 0000000..dd08bfe --- /dev/null +++ b/src/i2client/Index.form @@ -0,0 +1,61 @@ + + +
+ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +
diff --git a/src/i2client/Index.java b/src/i2client/Index.java new file mode 100644 index 0000000..3743a4b --- /dev/null +++ b/src/i2client/Index.java @@ -0,0 +1,1879 @@ +/* + * 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.File; +import java.io.FileOutputStream; +import java.io.OutputStreamWriter; +import java.io.Writer; +import java.math.BigInteger; +import java.security.MessageDigest; +import java.sql.Connection; +import java.sql.PreparedStatement; +import java.sql.ResultSet; +import java.sql.ResultSetMetaData; +import java.text.SimpleDateFormat; +import java.util.List; +import java.util.Timer; +import java.util.TimerTask; +import java.util.TreeMap; +import javax.swing.JOptionPane; +import javax.xml.namespace.QName; +import javax.xml.rpc.ParameterMode; +import java.util.Date; +import java.text.ParsePosition; +import java.util.Calendar; +import java.util.TimeZone; + +import org.apache.axis.client.Call; +import org.apache.axis.client.Service; +import org.apache.axis.encoding.XMLType; + +import javax.xml.namespace.QName; +import javax.xml.rpc.ParameterMode; + +import org.apache.axis.client.Call; +import org.apache.axis.client.Service; +import org.apache.axis.encoding.XMLType; +import org.apache.axis.message.MessageElement; +import org.apache.axis.types.Schema; + +/** + * + * @author LENOVO + */ +public class Index extends javax.swing.JFrame { + + /** + * Creates new form Index + */ + + private Timer Timereqm = new Timer(); + public Index() { + // try{ + // DBHelper help=new DBHelper(); + // Connection conn=null; + // conn=help.getConnection(); + // PreparedStatement pstmt = null; + // ResultSet rs=null; + // String checksql = "select * from sys_rg"; + // pstmt=conn.prepareStatement(checksql);//装载sql语句 + // ResultSet checkrt=null; + // checkrt=pstmt.executeQuery(); + // int checknum; + // while(checkrt.next()){ + // String mc = checkrt.getString("mc"); + // String ac5 = checkrt.getString("ac5"); + // String ck5 = checkrt.getString("ck5"); + // String encrypt = getResult(mc+key); + // if(!ac5.equals(encrypt)){ + // checknum = 0; + // }else{ + // checknum = 1; + // } + // String checkupsql = "UPDATE sys_rg SET ck5= '"+checknum+"' WHERE mc='"+checkrt.getString("mc")+"'"; + // help.getConnection(); + // int num = help.excuteUpdate(checkupsql); + // help.getConnection().close(); + // } + // pstmt=conn.prepareStatement(checksql);//装载sql语句 + // checkrt=null; + // checkrt=pstmt.executeQuery(); + // while(checkrt.next()){ + // int ck ; + // for(int i=0;i<9;i++){ + // ck = checkrt.getInt("ck"+(i+1)); + // if(ck!=1){ + // JOptionPane.showMessageDialog(null, "该软件未注册"); + // System.exit(0); + // return; + // } + // } + // } + // conn.close(); + // }catch (Exception e) {e.printStackTrace();} + initComponents(); + Timereqm.schedule(new TimerTask() { + @Override + public void run() { + try{ + loadFunction(); + } catch (Exception e) { + // TODO Auto-generated catch block + e.printStackTrace(); + writeFile("slog/"+getCurrentYYYYMM()+".log", e.getMessage()); + } + } + }, 0, 120000); + } + + /** + * This method is called from within the constructor to initialize the form. + * WARNING: Do NOT modify this code. The content of this method is always + * regenerated by the Form Editor. + */ + @SuppressWarnings("unchecked") + // //GEN-BEGIN:initComponents + private void initComponents() { + + jScrollPane1 = new javax.swing.JScrollPane(); + jTextArea1 = new javax.swing.JTextArea(); + + setDefaultCloseOperation(javax.swing.WindowConstants.EXIT_ON_CLOSE); + setTitle("I2通道数据显示"); + + jTextArea1.setColumns(20); + jTextArea1.setRows(5); + jScrollPane1.setViewportView(jTextArea1); + + javax.swing.GroupLayout layout = new javax.swing.GroupLayout(getContentPane()); + getContentPane().setLayout(layout); + layout.setHorizontalGroup( + layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING) + .addGroup(layout.createSequentialGroup() + .addContainerGap() + .addComponent(jScrollPane1, javax.swing.GroupLayout.DEFAULT_SIZE, 785, Short.MAX_VALUE) + .addContainerGap()) + ); + layout.setVerticalGroup( + layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING) + .addGroup(layout.createSequentialGroup() + .addContainerGap() + .addComponent(jScrollPane1, javax.swing.GroupLayout.PREFERRED_SIZE, 344, javax.swing.GroupLayout.PREFERRED_SIZE) + .addContainerGap(19, Short.MAX_VALUE)) + ); + + pack(); + }// //GEN-END:initComponents + + /** + * @param args the command line arguments + */ + public static void main(String args[]) { + /* Set the Nimbus look and feel */ + // + /* If Nimbus (introduced in Java SE 6) is not available, stay with the default look and feel. + * For details see http://download.oracle.com/javase/tutorial/uiswing/lookandfeel/plaf.html + */ + try { + for (javax.swing.UIManager.LookAndFeelInfo info : javax.swing.UIManager.getInstalledLookAndFeels()) { + if ("Nimbus".equals(info.getName())) { + javax.swing.UIManager.setLookAndFeel(info.getClassName()); + break; + } + } + } catch (ClassNotFoundException ex) { + java.util.logging.Logger.getLogger(Index.class.getName()).log(java.util.logging.Level.SEVERE, null, ex); + } catch (InstantiationException ex) { + java.util.logging.Logger.getLogger(Index.class.getName()).log(java.util.logging.Level.SEVERE, null, ex); + } catch (IllegalAccessException ex) { + java.util.logging.Logger.getLogger(Index.class.getName()).log(java.util.logging.Level.SEVERE, null, ex); + } catch (javax.swing.UnsupportedLookAndFeelException ex) { + java.util.logging.Logger.getLogger(Index.class.getName()).log(java.util.logging.Level.SEVERE, null, ex); + } + // + + /* Create and display the form */ + java.awt.EventQueue.invokeLater(new Runnable() { + public void run() { + new Index().setVisible(true); + } + }); + } + public String getResult(String inputStr) + { + BigInteger bigInteger=null; + + try { + MessageDigest md = MessageDigest.getInstance("MD5"); + byte[] inputData = inputStr.getBytes(); + md.update(inputData); + bigInteger = new BigInteger(md.digest()); + } catch (Exception e) {e.printStackTrace();} + return bigInteger.toString(16); + } + String key = "295122708900494DAE5701DB80A1C3A5"; + String xml = ""; + public void loadFunction(){ + try{ + XydlServiceImplService ucd = new XydlServiceImplService(); + DBHelper help=new DBHelper(); + Connection conn=null; + conn=help.getConnection(); + PreparedStatement pstmt = null; + ResultSet rs=null; + + String sql ="select * from vw_sb where 1"; + pstmt=conn.prepareStatement(sql);//装载sql语句 + rs=pstmt.executeQuery(); + //System.out.println(rs); + //把查询出来的记录封装成对应的实体类对象 + ResultSetMetaData rsd=rs.getMetaData();//获得列对象,通过此对象可以得到表的结构，包括，列名，列的个数，列的数据类型 + while(rs.next()){ + if(rs.getInt("mtid")==20){ //电缆环流 + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + Calendar beforeTime = Calendar.getInstance(); + beforeTime.add(Calendar.MINUTE, -15);// 15分钟之前的时间 + Date beforeD = beforeTime.getTime(); + String time = sdf.format(beforeD); + String sql1 = "select * from data_scur_h where (isupload is null or isupload=0) and eqmid ="+rs.getString("id")+" and d_time<\""+time+"\" order by d_time asc"; + pstmt=conn.prepareStatement(sql1);//装载sql语句 + ResultSet rs1=null; + rs1=pstmt.executeQuery(); + while(rs1.next()){ + try{ + String sql2 = "select * from warn_cfg where eqmid ="+rs1.getString("eqmid")+""; + pstmt=conn.prepareStatement(sql2);//装载sql语句 + ResultSet rs2=null; + rs2=pstmt.executeQuery(); + String sql3 = "select * from i2relation where eqmid ="+rs1.getString("eqmid"); + //System.out.println(sql3); + pstmt=conn.prepareStatement(sql3);//装载sql语句 + ResultSet rs3=null; + rs3=pstmt.executeQuery(); + String data[][] = new String[2][2]; + while(rs3.next()){ + if(!rs3.getString("cacid").equals("")){ + String timestamp = rs1.getString("d_time"); + data[0][0] = rs1.getString("current_val"); + data[0][1] = rs1.getString("alarm_level"); + if(rs1.getInt("alarm_level")>5){ + data[0][1] = "TRUE" ; + }else{ + data[0][1] = "FALSE" ; + } + /*if(rs2.next()){ + if(rs1.getInt("Cur")>rs2.getInt("warnmin5") && rs1.getInt("Cur")rs2.getInt("warnmin4") && rs1.getInt("Cur")rs2.getInt("warnmin3") && rs1.getInt("Cur")rs2.getInt("warnmin2") && rs1.getInt("Cur")rs2.getInt("warnmin1") && rs1.getInt("Cur")rs2.getInt("warnmin6") && rs1.getInt("Cur")rs2.getInt("warnmin7") && rs1.getInt("Cur")rs2.getInt("warnmin8") && rs1.getInt("Cur")rs2.getInt("warnmin9") && rs1.getInt("Cur")rs2.getInt("warnmin10") && rs1.getInt("Cur")rs2.getInt("warnmin11") && rs1.getInt("Cur")rs2.getInt("warnmin12") && rs1.getInt("Cur")rs2.getInt("warnmin13") && rs1.getInt("Cur")rs2.getInt("warnmin14") && rs1.getInt("Cur")rs2.getInt("warnmin15") && rs1.getInt("Cur")rs2.getInt("warnmin16") && rs1.getInt("Cur")rs2.getInt("warnmin17") && rs1.getInt("Cur")rs2.getInt("warnmin18") && rs1.getInt("Cur")rs2.getInt("warnmin19") && rs1.getInt("Cur")rs2.getInt("warnmin20") && rs1.getInt("Cur") + String str = ucd.getXydlServiceImplPort().uploadCACData(xml); + System.out.println("客户端接受："+str); + TreeMap ret = GenerateXml.xmlElements(str); + System.out.println("客户端接受："+ret); + if( Integer.parseInt(ret.get("response.result.code").toString())==0){ + String sql4 = "UPDATE data_scur_h SET isupload = 1 WHERE d_time ='"+rs1.getString("d_time")+"' and eqmid='"+rs1.getString("eqmid")+"' "; + System.out.println(sql4); + help.getConnection(); + int num = help.excuteUpdate(sql4); + help.getConnection().close(); + if(num>0){ + String old=jTextArea1.getText(); + jTextArea1.append("\n"); + jTextArea1.setText(old+"传输成功！"+xml+"\n"); + System.out.println("Send XML: " + xml ); + } + } + } + } + }catch (Exception e) { + // TODO Auto-generated catch block + e.printStackTrace(); + writeFile("slog/"+getCurrentYYYYMM()+".log", e.getMessage()); + } + } + } + + if(rs.getInt("mtid")==4){//避雷器 + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + Calendar beforeTime = Calendar.getInstance(); + beforeTime.add(Calendar.MINUTE, -15);// 15分钟之前的时间 + Date beforeD = beforeTime.getTime(); + String time = sdf.format(beforeD); + String sql1 = "select eqmid,d_time,pt1,lc1,rc1,ligcnt1,lastligtm1,pt2,lc2,rc2,ligcnt2,lastligtm2,pt3,lc3,rc3,ligcnt3,lastligtm3 from data_moa_h where (isupload is null or isupload=0) and eqmid ="+rs.getString("id")+" and d_time<\""+time+"\" order by d_time asc"; + //System.out.println(sql1); + pstmt=conn.prepareStatement(sql1);//装载sql语句 + ResultSet rs1=null; + rs1=pstmt.executeQuery(); + //System.out.println(sql1); + while(rs1.next()){ + try{ + //System.out.println(rs1.getString("eqmid")); + String sql2 = "select * from warn_cfg where eqmid ="+rs1.getString("eqmid")+""; + pstmt=conn.prepareStatement(sql2);//装载sql语句 + ResultSet rs2=null; + rs2=pstmt.executeQuery(); + + String sql3 = "select * from i2relation where eqmid ="+rs1.getString("eqmid"); + //System.out.println(sql3); + pstmt=conn.prepareStatement(sql3);//装载sql语句 + ResultSet rs3=null; + rs3=pstmt.executeQuery(); + int okstatus = 3; + while(rs3.next()){ + String data[][] = new String[5][2]; + String timestamp = rs1.getString("d_time"); + //System.out.println(rs2); + if(!rs3.getString("cacid").equals("")){ + if(rs3.getString("phase").equals("A相")){ + data[0][0] = rs1.getString("pt1"); + if(rs1.getString("pt1")==null) + { + data[0][0]="0"; + } + data[1][0] = rs1.getString("lc1"); + if(rs1.getString("lc1")==null) + { + data[1][0]="0"; + } + data[2][0] = rs1.getString("rc1"); + if(rs1.getString("rc1")==null) + { + data[2][0]="0"; + } + data[3][0] = rs1.getString("ligcnt1"); + if( rs1.getInt("ligcnt1")==-1 || rs1.getInt("ligcnt1")==0){ + data[3][0] = "0"; + } + data[3][1] = "FALSE"; + if(rs1.getString("lastligtm1")==null || rs1.getString("lastligtm1").equals("0000-0-0 00:00:00")) + { + data[4][0] = "1970-01-01 00:00:00"; + } + else + { + data[4][0] = rs1.getString("lastligtm1"); + } + data[4][1] = "FALSE"; + if(rs2.next()){ + if(rs1.getInt("pt1")>rs2.getInt("warnmin1") && rs1.getInt("pt1")rs2.getInt("warnmin4") && rs1.getInt("lc1")rs2.getInt("warnmin7") && rs1.getInt("rc1")rs2.getInt("warnmin2") && rs1.getInt("pt1")rs2.getInt("warnmin5") && rs1.getInt("lc1")rs2.getInt("warnmin8") && rs1.getInt("rc1")rs2.getInt("warnmin3") && rs1.getInt("pt1")rs2.getInt("warnmin6") && rs1.getInt("lc1")rs2.getInt("warnmin9") && rs1.getInt("rc1")0){ + String old=jTextArea1.getText(); + jTextArea1.append("\n"); + jTextArea1.setText(old+"传输成功！"+xml+"\n"); + } + } + }catch (Exception e) { + // TODO Auto-generated catch block + e.printStackTrace(); + writeFile("slog/"+getCurrentYYYYMM()+".log", e.getMessage()); + } + } + } + if(rs.getInt("mtid")==1){ + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + Calendar beforeTime = Calendar.getInstance(); + beforeTime.add(Calendar.MINUTE, -90);// 30分钟之前的时间 + Date beforeD = beforeTime.getTime(); + String time = sdf.format(beforeD); + String sql1 = "select * from data_epa_h where (isupload is null or isupload=0) and eqmid ="+rs.getString("id")+" and d_time<\""+time+"\" order by d_time asc"; + pstmt=conn.prepareStatement(sql1);//装载sql语句 + ResultSet rs1=null; + rs1=pstmt.executeQuery(); + while(rs1.next()){ + try{ + String sql2 = "select * from warn_cfg where eqmid ="+rs1.getString("eqmid")+""; + pstmt=conn.prepareStatement(sql2);//装载sql语句 + ResultSet rs2=null; + rs2=pstmt.executeQuery(); + String sql3 = "select * from i2relation where eqmid ="+rs1.getString("eqmid"); + //System.out.println(sql3); + pstmt=conn.prepareStatement(sql3);//装载sql语句 + ResultSet rs3=null; + rs3=pstmt.executeQuery(); + String data[][] = new String[12][2]; + //System.out.println(rs2); + while(rs3.next()){ + if(!rs3.getString("cacid").equals("")){ + String timestamp = rs1.getString("d_time"); + data[0][0] = rs1.getString("h2ppm"); + if(rs1.getString("h2ppm")==null) + { + data[0][0]="0"; + } + data[1][0] = rs1.getString("ch4ppm"); + if(rs1.getString("ch4ppm")==null) + { + data[1][0]="0"; + } + data[2][0] = rs1.getString("c2h6ppm"); + if(rs1.getString("c2h6ppm")==null) + { + data[2][0]="0"; + } + data[3][0] = rs1.getString("c2h4ppm"); + if(rs1.getString("c2h4ppm")==null) + { + data[3][0]="0"; + } + data[4][0] = rs1.getString("c2h2ppm"); + if(rs1.getString("c2h2ppm")==null) + { + data[4][0]="0"; + } + data[5][0] = rs1.getString("coppm"); + if(rs1.getString("coppm")==null) + { + data[5][0]="0"; + } + data[6][0] = rs1.getString("co2ppm"); + if(rs1.getString("co2ppm")==null) + { + data[6][0]="34"; + } + data[7][0] = rs1.getString("o2ppm"); + if(rs1.getString("o2ppm")==null) + { + data[7][0]="0"; + } + data[8][0] = rs1.getString("n2ppm"); + if(rs1.getString("n2ppm")==null) + { + data[8][0]="0"; + } + data[9][0] = rs1.getString("totalhydrocarbon"); + if(rs1.getString("totalhydrocarbon")==null) + { + data[9][0]="0"; + } +// data[10][0] = rs1.getString("gaspress"); +// if(data[10][0]==null){ +// data[10][0]="0"; +// } +// if(rs1.getFloat("gaspress")==0) +// { +// data[10][0]="0"; +// } + data[10][0]="1"; + data[11][0] = rs1.getString("h2oppm"); + if(rs1.getString("h2oppm")==null) + { + data[11][0]="0"; + } + if(rs2.next()){ + if(rs1.getInt("h2ppm")>rs2.getInt("warnmin5") && rs1.getInt("h2ppm")rs2.getInt("warnmin1") && rs1.getInt("ch4ppm")rs2.getInt("warnmin3") && rs1.getInt("c2h6ppm")rs2.getInt("warnmin2") && rs1.getInt("c2h4ppm")rs2.getInt("warnmin4") && rs1.getInt("c2h2ppm")rs2.getInt("warnmin6") && rs1.getInt("coppm")rs2.getInt("warnmin7") && rs1.getInt("co2ppm")rs2.getInt("warnmin10") && rs1.getInt("o2ppm")rs2.getInt("warnmin11") && rs1.getInt("n2ppm")rs2.getInt("warnmin8") && rs1.getInt("totalhydrocarbon")rs2.getInt("warnmin12") && rs1.getInt("gaspress")rs2.getInt("warnmin13") && rs1.getInt("h2oppm")0){ + String old=jTextArea1.getText(); + jTextArea1.append("\n"); + jTextArea1.setText(old+"传输成功！"+xml+"\n"); + } + } + } + } + }catch (Exception e) { + // TODO Auto-generated catch block + e.printStackTrace(); + writeFile("slog/"+getCurrentYYYYMM()+".log", e.getMessage()); + } + } + } + if(rs.getInt("mtid")==9){ + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + Calendar beforeTime = Calendar.getInstance(); + beforeTime.add(Calendar.MINUTE, -15);// 15分钟之前的时间 + Date beforeD = beforeTime.getTime(); + String time = sdf.format(beforeD); + String sql1 = "select * from data_eaif_h where (isupload is null or isupload=0) and eqmid ="+rs.getString("id")+" and capturetime<\""+time+"\" order by capturetime asc"; + //System.out.println(sql1); + pstmt=conn.prepareStatement(sql1);//装载sql语句 + ResultSet rs1=null; + rs1=pstmt.executeQuery(); + while(rs1.next()){ + try{ + String sql2 = "select * from warn_cfg where eqmid ="+rs1.getString("eqmid")+""; + pstmt=conn.prepareStatement(sql2);//装载sql语句 + ResultSet rs2=null; + rs2=pstmt.executeQuery(); + + String sql3 = "select * from i2relation where eqmid ="+rs1.getString("eqmid"); + //System.out.println(sql3); + pstmt=conn.prepareStatement(sql3);//装载sql语句 + ResultSet rs3=null; + rs3=pstmt.executeQuery(); + String data[][] = new String[6][2]; + //System.out.println(rs2); + while(rs3.next()){ + if(!rs3.getString("cacid").equals("")){ + String timestamp = rs1.getString("capturetime"); + String phase = rs3.getString("phase"); + String cacid = rs3.getString("cacid"); + data[0][0] = rs1.getString("maxtemp"); + data[1][0] = rs1.getString("mintemp"); + data[2][0] = rs1.getString("avgtemp"); + if(rs2.next()){ + if(rs1.getInt("maxtemp")>rs2.getInt("warnmin1") && rs1.getInt("maxtemp")rs2.getInt("warnmin2") && rs1.getInt("mintemp")rs2.getInt("warnmin3") && rs1.getInt("avgtemp")0){ + String old=jTextArea1.getText(); + jTextArea1.append("\n"); + jTextArea1.setText(old+"传输成功！\n"); + } + } + } + } + }catch (Exception e) { + // TODO Auto-generated catch block + e.printStackTrace(); + writeFile("slog/"+getCurrentYYYYMM()+".log", e.getMessage()); + } + } + } + if(rs.getInt("mtid")==2){ + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + Calendar beforeTime = Calendar.getInstance(); + beforeTime.add(Calendar.MINUTE, -15);// 15分钟之前的时间 + Date beforeD = beforeTime.getTime(); + String time = sdf.format(beforeD); + String sql1 = "select * from data_eia_h where (isupload is null or isupload=0) and eqmid ="+rs.getString("id")+" and d_time<\""+time+"\" order by d_time asc"; + pstmt=conn.prepareStatement(sql1);//装载sql语句 + ResultSet rs1=null; + rs1=pstmt.executeQuery(); + while(rs1.next()){ + try{ + String sql2 = "select * from warn_cfg where eqmid ="+rs1.getString("eqmid")+""; + pstmt=conn.prepareStatement(sql2);//装载sql语句 + ResultSet rs2=null; + rs2=pstmt.executeQuery(); + String sql3 = "select * from i2relation where eqmid ="+rs1.getString("eqmid"); + //System.out.println(sql3); + pstmt=conn.prepareStatement(sql3);//装载sql语句 + ResultSet rs3=null; + rs3=pstmt.executeQuery(); + String data[][] = new String[2][2]; + while(rs3.next()){ + if(!rs3.getString("cacid").equals("")){ + String timestamp = rs1.getString("d_time"); + data[0][0] = rs1.getString("d_ct_1"); + if(rs2.next()){ + if(rs1.getInt("d_ct_1")>rs2.getInt("warnmin5") && rs1.getInt("d_ct_1")0){ + String old=jTextArea1.getText(); + jTextArea1.append("\n"); + jTextArea1.setText(old+"传输成功！"+xml+"\n"); + } + } + } + } + }catch (Exception e) { + // TODO Auto-generated catch block + e.printStackTrace(); + writeFile("slog/"+getCurrentYYYYMM()+".log", e.getMessage()); + } + } + } + if(rs.getInt("mtid")==13||rs.getInt("mtid")==14||rs.getInt("mtid")==15){ + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + Calendar beforeTime = Calendar.getInstance(); + beforeTime.add(Calendar.MINUTE, -15);// 15分钟之前的时间 + Date beforeD = beforeTime.getTime(); + String time = sdf.format(beforeD); + String sql1 = "select * from data_eia_h where (isupload is null or isupload=0) and eqmid ="+rs.getString("id")+" and d_time<\""+time+"\" order by d_time asc"; + pstmt=conn.prepareStatement(sql1);//装载sql语句 + ResultSet rs1=null; + rs1=pstmt.executeQuery(); + while(rs1.next()){ + try{ + String sql2 = "select * from warn_cfg where eqmid ="+rs1.getString("eqmid")+""; + pstmt=conn.prepareStatement(sql2);//装载sql语句 + ResultSet rs2=null; + rs2=pstmt.executeQuery(); + String sql3 = "select * from i2relation where eqmid ="+rs1.getString("eqmid"); + //System.out.println(sql3); + pstmt=conn.prepareStatement(sql3);//装载sql语句 + ResultSet rs3=null; + rs3=pstmt.executeQuery(); + String data[][] = new String[6][2]; + //System.out.println(rs2); + int okstatus = 3; + while(rs3.next()){ + if(!rs3.getString("cacid").equals("")){ + String timestamp = rs1.getString("d_time"); + String d_ct_1 = rs1.getString("d_ct_1"); + String d_ct_2 = rs1.getString("d_ct_2"); + String d_ct_3 = rs1.getString("d_ct_3"); + String d_pt_1 = rs1.getString("d_pt_1"); + String d_pt_2 = rs1.getString("d_pt_2"); + String d_pt_3 = rs1.getString("d_pt_3"); + String maxd_ct = d_ct_1; + String mind_ct = d_ct_1; + String maxd_pt = d_pt_1; + String mind_pt = d_pt_1; + if(Float.parseFloat(d_ct_2)>Float.parseFloat(maxd_ct)){ + maxd_ct = d_ct_2; + } + if(Float.parseFloat(d_ct_3)>Float.parseFloat(maxd_ct)){ + maxd_ct = d_ct_3; + } + if(Float.parseFloat(d_ct_2)>Float.parseFloat(maxd_ct)){ + maxd_ct = d_ct_2; + } + if(Float.parseFloat(d_ct_2)Float.parseFloat(maxd_pt)){ + maxd_pt = d_pt_2; + } + if(Float.parseFloat(d_pt_3)>Float.parseFloat(maxd_pt)){ + maxd_pt = d_pt_3; + } + if(Float.parseFloat(d_pt_2)>Float.parseFloat(maxd_pt)){ + maxd_pt = d_pt_2; + } + if(Float.parseFloat(d_pt_2)rs2.getInt("warnmin10") && rs1.getInt("d_pf_1")rs2.getInt("warnmin14") && rs1.getInt("d_jx_1") rs2.getInt("warnmin5") && rs1.getInt("d_ct_1") < rs2.getInt("warnmax5")) { + data[4][1] = "FALSE"; + } else { + data[4][1] = "TRUE"; + } + if (rs1.getInt("d_pt_1") > rs2.getInt("warnmin1") && rs1.getInt("d_ct_1") < rs2.getInt("warnmax1")) { + data[5][1] = "FALSE"; + } else { + data[5][1] = "TRUE"; + } + }else{ + data[0][1] = "FALSE"; + data[1][1] = "FALSE"; + data[2][1] = "FALSE"; + data[3][1] = "FALSE"; + data[4][1] = "FALSE"; + data[5][1] = "FALSE"; + } + }else if(rs3.getString("sensorindex").equals("2")){ + data[0][0] = rs1.getString("d_pf_2"); + data[1][0] = rs1.getString("d_jx_2"); + data[2][0] = current; + data[3][0] = voltage; + data[4][0] = d_ct_2; + data[5][0] = d_pt_2; + if(rs2.next()){ + if(rs1.getInt("d_pf_2")>rs2.getInt("warnmin11") && rs1.getInt("d_pf_2")rs2.getInt("warnmin15") && rs1.getInt("d_jx_2") rs2.getInt("warnmin6") && rs1.getInt("d_ct_2") < rs2.getInt("warnmax6")) { + data[4][1] = "FALSE"; + } else { + data[4][1] = "TRUE"; + } + if (rs1.getInt("d_pt_2") > rs2.getInt("warnmin2") && rs1.getInt("d_ct_2") < rs2.getInt("warnmax2")) { + data[5][1] = "FALSE"; + } else { + data[5][1] = "TRUE"; + } + }else{ + data[0][1] = "FALSE"; + data[1][1] = "FALSE"; + data[2][1] = "FALSE"; + data[3][1] = "FALSE"; + data[4][1] = "FALSE"; + data[5][1] = "FALSE"; + } + }else if(rs3.getString("sensorindex").equals("3")){ + data[0][0] = rs1.getString("d_pf_3"); + data[1][0] = rs1.getString("d_jx_3"); + data[2][0] = current; + data[3][0] = voltage; + data[4][0] = d_ct_3; + data[5][0] = d_pt_3; + if(rs2.next()){ + if(rs1.getInt("d_pf_3")>rs2.getInt("warnmin12") && rs1.getInt("d_pf_3")rs2.getInt("warnmin16") && rs1.getInt("d_jx_3") rs2.getInt("warnmin7") && rs1.getInt("d_ct_3") < rs2.getInt("warnmax7")) { + data[4][1] = "FALSE"; + } else { + data[4][1] = "TRUE"; + } + if (rs1.getInt("d_pt_3") > rs2.getInt("warnmin3") && rs1.getInt("d_ct_3") < rs2.getInt("warnmax3")) { + data[5][1] = "FALSE"; + } else { + data[5][1] = "TRUE"; + } + }else{ + data[0][1] = "FALSE"; + data[1][1] = "FALSE"; + data[2][1] = "FALSE"; + data[3][1] = "FALSE"; + data[4][1] = "FALSE"; + data[5][1] = "FALSE"; + } + } + + + String cacid = rs3.getString("cacid"); + String sensorid = rs3.getString("sensorid"); + String equipmentid = rs3.getString("equipmentid"); + String phase = rs3.getString("phase"); + xml = GenerateXml.createCACData_eia(cacid,sensorid,equipmentid,timestamp,phase,data); + String str = ucd.getXydlServiceImplPort().uploadCACData(xml); + System.out.println("客户端接受："+xml); + TreeMap ret = GenerateXml.xmlElements(str); + System.out.println("客户端接受："+ret); + if( Integer.parseInt(ret.get("response.result.code").toString())==0){ + okstatus--; + } + } + } + if(okstatus==0){ + String sql4 = "UPDATE data_eia_h SET isupload = 1 WHERE d_time ='"+rs1.getString("d_time")+"' and eqmid='"+rs1.getString("eqmid")+"'"; + //System.out.println(sql4); + help.getConnection(); + int num = help.excuteUpdate(sql4); + help.getConnection().close(); + if(num>0){ + String old=jTextArea1.getText(); + jTextArea1.append("\n"); + jTextArea1.setText(old+"传输成功！\n"); + } + } + }catch (Exception e) { + // TODO Auto-generated catch block + e.printStackTrace(); + writeFile("slog/"+getCurrentYYYYMM()+".log", e.getMessage()); + } + } + } + if(rs.getInt("mtid")==8){ + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + Calendar beforeTime = Calendar.getInstance(); + beforeTime.add(Calendar.MINUTE, -15);// 15分钟之前的时间 + Date beforeD = beforeTime.getTime(); + String time = sdf.format(beforeD); + String sql1 = "select * from data_sf6_h where (isupload is null or isupload=0) and eqmid ="+rs.getString("id")+" and d_time<\""+time+"\" order by d_time asc"; + //System.out.println(sql1); + pstmt=conn.prepareStatement(sql1);//装载sql语句 + ResultSet rs1=null; + rs1=pstmt.executeQuery(); + //System.out.println(sql1); + while(rs1.next()){ + try{ + //System.out.println(rs1.getString("eqmid")); + String sql2 = "select * from warn_cfg where eqmid ="+rs1.getString("eqmid")+""; + pstmt=conn.prepareStatement(sql2);//装载sql语句 + ResultSet rs2=null; + rs2=pstmt.executeQuery(); + String sql3 = "select * from i2relation where eqmid ="+rs1.getString("eqmid"); + //System.out.println(sql3); + pstmt=conn.prepareStatement(sql3);//装载sql语句 + ResultSet rs3=null; + rs3=pstmt.executeQuery(); + String data[][] = new String[4][2]; + String timestamp = rs1.getString("d_time");; + //System.out.println(rs2); + int okstatus = 3; + int idnumbers = 3; + while(rs3.next()){ + if(!rs3.getString("cacid").equals("")){ + String cacid = rs3.getString("cacid"); + String sensorid = rs3.getString("sensorid"); + String equipmentid = rs3.getString("equipmentid"); + String phase = rs3.getString("phase"); + if(rs3.getString("phase").equals("A相")){ + if(rs3.getString("monitortype").equals("024004")){ + data[0][0] = rs1.getString("temp1"); + if(rs1.getString("temp1")==null) + { + data[0][0]="0"; + } + data[1][0] = rs1.getString("pressure1"); + if(rs1.getString("pressure1")==null) + { + data[1][0]="0"; + } + data[2][0] = rs1.getString("md1"); + if(rs1.getString("md1")==null) + { + data[2][0]="0"; + } + data[3][0] = rs1.getString("pm1"); + if(rs1.getString("pm1")==null) + { + data[3][0]="0"; + } + if(rs2.next()){ + if(rs1.getInt("temp1")>rs2.getInt("warnmin1") && rs1.getInt("temp1")rs2.getInt("warnmin2") && rs1.getInt("pressure1")rs2.getInt("warnmin3") && rs1.getInt("md1") rs2.getInt("warnmin4") && rs1.getInt("pm1") < rs2.getInt("warnmax4")) { + data[3][1] = "FALSE"; + } else { + data[3][1] = "TRUE"; + } + }else{ + data[0][1] = "FALSE"; + data[1][1] = "FALSE"; + data[2][1] = "FALSE"; + data[3][1] = "FALSE"; + } + xml = GenerateXml.createCACData_sf6pressure(cacid,sensorid,equipmentid,timestamp,phase,data); + } + }else if(rs3.getString("phase").equals("B相")){ + if(rs3.getString("monitortype").equals("024004")){ + data[0][0] = rs1.getString("temp2"); + if(rs1.getString("temp2")==null) + { + data[0][0]="0"; + } + data[1][0] = rs1.getString("pressure2"); + if(rs1.getString("pressure2")==null) + { + data[1][0]="0"; + } + data[2][0] = rs1.getString("md2"); + if(rs1.getString("md2")==null) + { + data[2][0]="0"; + } + data[3][0] = rs1.getString("pm2"); + if(rs1.getString("pm2")==null) + { + data[3][0]="0"; + } + if(rs2.next()){ + if(rs1.getInt("temp2")>rs2.getInt("warnmin6") && rs1.getInt("temp2")rs2.getInt("warnmin7") && rs1.getInt("pressure2")rs2.getInt("warnmin8") && rs1.getInt("md2")rs2.getInt("warnmin9") && rs1.getInt("pm2")rs2.getInt("warnmin11") && rs1.getInt("temp3")rs2.getInt("warnmin12") && rs1.getInt("pressure3")rs2.getInt("warnmin13") && rs1.getInt("md3")rs2.getInt("warnmin14") && rs1.getInt("pm3")0){ + String old=jTextArea1.getText(); + jTextArea1.append("\n"); + jTextArea1.setText(old+"传输成功！\n"); + } + } + + }catch (Exception e) { + // TODO Auto-generated catch block + e.printStackTrace(); + writeFile("slog/"+getCurrentYYYYMM()+".log", e.getMessage()); + } + } + } + if(rs.getInt("mtid")==11){ + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + Calendar beforeTime = Calendar.getInstance(); + beforeTime.add(Calendar.MINUTE, -15);// 15分钟之前的时间 + Date beforeD = beforeTime.getTime(); + String time = sdf.format(beforeD); + String sql1 = "select * from data_otp_h where (isupload is null or isupload=0) and eqmid ="+rs.getString("id")+" and d_time<\""+time+"\" order by d_time asc"; + pstmt=conn.prepareStatement(sql1);//装载sql语句 + ResultSet rs1=null; + rs1=pstmt.executeQuery(); + while(rs1.next()){ + try{ + String sql2 = "select * from warn_cfg where eqmid ="+rs1.getString("eqmid")+""; + pstmt=conn.prepareStatement(sql2);//装载sql语句 + ResultSet rs2=null; + rs2=pstmt.executeQuery(); + + String sql3 = "select * from i2relation where eqmid ="+rs1.getString("eqmid"); + //System.out.println(sql3); + pstmt=conn.prepareStatement(sql3);//装载sql语句 + ResultSet rs3=null; + rs3=pstmt.executeQuery(); + String data[][] = new String[1][2]; + String timestamp = rs1.getString("d_time"); + //System.out.println(rs2); + while(rs3.next()){ + if(!rs3.getString("cacid").equals("")){ + data[0][0] = rs1.getString("timestamp"); + if(rs2.next()){ + if(rs1.getInt("oiltemperature")>rs2.getInt("warnmin1") && rs1.getInt("oiltemperature")0){ + String old=jTextArea1.getText(); + jTextArea1.append("\n"); + jTextArea1.setText(old+"传输成功！\n"); + } + } + } + } + }catch (Exception e) { + // TODO Auto-generated catch block + e.printStackTrace(); + writeFile("slog/"+getCurrentYYYYMM()+".log", e.getMessage()); + } + } + } + if(rs.getInt("mtid")==10){ + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + Calendar beforeTime = Calendar.getInstance(); + beforeTime.add(Calendar.MINUTE, -15);// 15分钟之前的时间 + Date beforeD = beforeTime.getTime(); + String time = sdf.format(beforeD); + String sql1 = "select * from data_pd_h where (isupload is null or isupload=0) and eqmid ="+rs.getString("id")+" and (d_time<\""+time+"\" or padschalm > 0) order by d_time asc"; + pstmt=conn.prepareStatement(sql1);//装载sql语句 + ResultSet rs1=null; + rs1=pstmt.executeQuery(); + while(rs1.next()){ + try{ + String sql2 = "select * from warn_cfg where eqmid ="+rs1.getString("eqmid")+""; + pstmt=conn.prepareStatement(sql2);//装载sql语句 + ResultSet rs2=null; + rs2=pstmt.executeQuery(); + String sql3 = "select * from i2relation where eqmid ="+rs1.getString("eqmid"); + //System.out.println(sql3); + pstmt=conn.prepareStatement(sql3);//装载sql语句 + ResultSet rs3=null; + rs3=pstmt.executeQuery(); + String data[][] = new String[6][2]; + String timestamp = rs1.getString("d_time"); + //System.out.println(rs2); + while(rs3.next()){ + if(!rs3.getString("cacid").equals("")){ + data[0][0] = rs1.getString("apppadsch"); + if(rs1.getString("apppadsch")==null) + { + data[0][0]="0"; + } + data[1][0] = rs1.getString("phase"); + if(rs1.getString("phase")==null) + { + data[1][0]="0"; + } + data[2][0] = rs1.getString("plsnum"); + if(rs1.getString("plsnum")==null) + { + data[2][0]="0"; + } + data[3][0] = rs1.getString("waveform"); + if(rs1.getString("waveform")==null) + { + data[3][0]=""; + } + data[4][0] = rs1.getString("padschalm"); + if(rs1.getString("padschalm")==null) + { + data[4][0]=""; + } + data[5][0] = rs1.getString("padschtype"); + if(rs1.getString("padschtype")==null) + { + data[5][0]=""; + } + if(rs2.next()){ + if(rs1.getInt("apppadsch")>rs2.getInt("warnmin2") && rs1.getInt("apppadsch")rs2.getInt("warnmin5") && rs1.getInt("phase")0){ + String old=jTextArea1.getText(); + jTextArea1.append("\n"); + jTextArea1.setText(old+"传输成功！\n"); + } + } + } + } + }catch (Exception e) { + // TODO Auto-generated catch block + e.printStackTrace(); + writeFile("slog/"+getCurrentYYYYMM()+".log", e.getMessage()); + } + } + } + if(rs.getInt("mtid")==16){//siteqixiang + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + Calendar beforeTime = Calendar.getInstance(); + beforeTime.add(Calendar.MINUTE, -15);// 15分钟之前的时间 + Date beforeD = beforeTime.getTime(); + String time = sdf.format(beforeD); + String sql1 = "select * from data_microclimate_h where (isupload is null or isupload=0) and eqmid ="+rs.getString("id")+" and d_time<\""+time+"\" order by d_time asc"; + pstmt=conn.prepareStatement(sql1);//装载sql语句 + ResultSet rs1=null; + rs1=pstmt.executeQuery(); + while(rs1.next()){ + try{ + String sql2 = "select * from warn_cfg where eqmid ="+rs1.getString("eqmid")+""; + pstmt=conn.prepareStatement(sql2);//装载sql语句 + ResultSet rs2=null; + rs2=pstmt.executeQuery(); + + String sql3 = "select * from i2relation where eqmid ="+rs1.getString("eqmid"); + //System.out.println(sql3); + pstmt=conn.prepareStatement(sql3);//装载sql语句 + ResultSet rs3=null; + rs3=pstmt.executeQuery(); + String data[][] = new String[8][2]; + String timestamp = rs1.getString("d_time"); + //System.out.println(rs2); + String okstatus = "";//特殊对应多个sid + while(rs3.next()){ + if(!rs3.getString("cacid").equals("")){ + data[0][0] = rs1.getString("envtmp"); + if(rs1.getString("envtmp")==null) + { + data[0][0]="0"; + } + data[1][0] = String.valueOf(rs1.getFloat("envhum")/100); + if(rs1.getString("envhum")==null) + { + data[1][0]="0"; + } + data[6][0] = rs1.getString("wdgustspd"); + if(rs1.getString("wdgustspd")==null) + { + data[6][0]="0"; + } + data[3][0] = String.valueOf(rs1.getFloat("envpres")/10); + if(rs1.getString("envpres")==null) + { + data[3][0]="0"; + } + data[7][0] = rs1.getString("wddir"); + if(rs1.getString("wddir")==null) + { + data[7][0]="0"; + } + data[5][0] = rs1.getString("rnfll"); + if(rs1.getString("rnfll")==null) + { + data[5][0]="0"; + } + if(rs2.next()){ + if(rs1.getInt("envtmp")>rs2.getInt("warnmin1") && rs1.getInt("envtmp")rs2.getInt("warnmin2") && rs1.getInt("envhum")rs2.getInt("warnmin7") && rs1.getInt("wdgustspd")rs2.getInt("warnmin4") && rs1.getInt("envhum")rs2.getInt("warnmin8") && rs1.getInt("wddir")rs2.getInt("warnmin6") && rs1.getInt("wddir")0){ + String old=jTextArea1.getText(); + jTextArea1.append("\n"); + jTextArea1.setText(old+"传输成功！\n"); + } + } + }catch (Exception e) { + // TODO Auto-generated catch block + e.printStackTrace(); + writeFile("slog/"+getCurrentYYYYMM()+".log", e.getMessage()); + } + } + } + if(rs.getInt("mtid")==5){ + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + Calendar beforeTime = Calendar.getInstance(); + beforeTime.add(Calendar.MINUTE, -5);// 5分钟之前的时间 + Date beforeD = beforeTime.getTime(); + String time = sdf.format(beforeD); + String sql1 = "select * from data_etp_h where (isupload is null or isupload=0) and eqmid ="+rs.getString("id")+" and d_time<\""+time+"\" order by d_time asc"; + pstmt=conn.prepareStatement(sql1);//装载sql语句 + ResultSet rs1=null; + rs1=pstmt.executeQuery(); + while(rs1.next()){ + try{ + String sql2 = "select * from warn_cfg where eqmid ="+rs1.getString("eqmid")+""; + pstmt=conn.prepareStatement(sql2);//装载sql语句 + ResultSet rs2=null; + rs2=pstmt.executeQuery(); + String sql3 = "select * from i2relation where eqmid ="+rs1.getString("eqmid"); + //System.out.println(sql3); + pstmt=conn.prepareStatement(sql3);//装载sql语句 + ResultSet rs3=null; + rs3=pstmt.executeQuery(); + String data[][] = new String[1][2]; + String timestamp = rs1.getString("d_time"); + //System.out.println(rs2); + Boolean isupload=true; + while(rs3.next()){ + if(!rs3.getString("cacid").equals("")){ + data[0][0] = rs1.getString("t"+rs3.getString("sensorindex")); + /*if(rs1.getFloat("t"+rs3.getString("sensorindex"))==0) + { + data[0][0]="0"; + }*/ + if(rs1.getString("t"+rs3.getString("sensorindex"))== null) + { + data[0][0]="-999"; + } + if(rs2.next()){ + if(rs1.getFloat("t"+rs3.getString("sensorindex"))rs2.getInt("warnmax"+rs3.getString("sensorindex"))){ + data[0][1] = "TRUE"; + }else{ + data[0][1] = "FALSE"; + } + }else{ + data[0][1] = "FALSE"; + } + String cacid = rs3.getString("cacid"); + String sensorid = rs3.getString("sensorid"); + String equipmentid = rs3.getString("equipmentid"); + String phase = rs3.getString("phase"); + xml = GenerateXml.createCACData_TMT(cacid,sensorid,equipmentid,timestamp,phase,data); + System.out.println("xml："+xml); + String str = ucd.getXydlServiceImplPort().uploadCACData(xml); + System.out.println("客户端接受："+str+xml); + TreeMap ret = GenerateXml.xmlElements(str); + System.out.println("客户端返回："+ret+xml); + if( Integer.parseInt(ret.get("response.result.code").toString())!=0){ + isupload=false; + } + } + } + + if(isupload) + { + String sql4 = "UPDATE data_etp_h SET isupload = 1 WHERE d_time ='"+rs1.getString("d_time")+"' and eqmid='"+rs1.getString("eqmid")+"'"; + //System.out.println(sql4); + help.getConnection(); + int num = help.excuteUpdate(sql4); + help.getConnection().close(); + if(num>0){ + String old=jTextArea1.getText(); + jTextArea1.append("\n"); + jTextArea1.setText(old+"传输成功！\n"+xml); + } + } + }catch (Exception e) { + // TODO Auto-generated catch block + e.printStackTrace(); + writeFile("slog/"+getCurrentYYYYMM()+".log", e.getMessage()); + } + } + } +// if(rs.getInt("mtid")==5){ +// String sql1 = "select * from data_etp_h where (isupload is null or isupload=0) and eqmid ="+rs.getString("id")+" order by d_time asc"; +// pstmt=conn.prepareStatement(sql1);//装载sql语句 +// ResultSet rs1=null; +// rs1=pstmt.executeQuery(); +// while(rs1.next()){ +// String sql2 = "select * from warn_cfg where eqmid ="+rs1.getString("eqmid")+""; +// pstmt=conn.prepareStatement(sql2);//装载sql语句 +// ResultSet rs2=null; +// rs2=pstmt.executeQuery(); +// String sql3 = "select * from i2relation where eqmid ="+rs1.getString("eqmid"); +// //System.out.println(sql3); +// pstmt=conn.prepareStatement(sql3);//装载sql语句 +// ResultSet rs3=null; +// rs3=pstmt.executeQuery(); +// String data[][] = new String[7][2]; +// String timestamp = rs1.getString("d_time"); +// //System.out.println(rs2); +// while(rs3.next()){ +// if(!rs3.getString("cacid").equals("")){ +// data[0][0] = rs1.getString("t1"); +// data[1][0] = rs1.getString("t2"); +// data[2][0] = rs1.getString("t3"); +// data[3][0] = rs1.getString("t4"); +// data[4][0] = rs1.getString("t5"); +// data[5][0] = rs1.getString("t6"); +// data[6][0] = rs1.getString("t7"); +// if(rs2.next()){ +// if(rs1.getInt("t1")>rs2.getInt("warnmin1") && rs1.getInt("t1")rs2.getInt("warnmin2") && rs1.getInt("t2")rs2.getInt("warnmin3") && rs1.getInt("t3")rs2.getInt("warnmin4") && rs1.getInt("t4")rs2.getInt("warnmin5") && rs1.getInt("t5")rs2.getInt("warnmin6") && rs1.getInt("t6")rs2.getInt("warnmin7") && rs1.getInt("t7")0){ +// String old=jTextArea1.getText(); +// jTextArea1.append("\n"); +// jTextArea1.setText(old+"传输成功！\n"); +// } +// } +// } +// } +// } +// } + } + conn.close(); + }catch (Exception e) { + // TODO Auto-generated catch block + e.printStackTrace(); + writeFile("slog/"+getCurrentYYYYMM()+".log", e.getMessage()); + } + } + /** +     *  +     * @param path +     * path:保存日志文件路径 +     * @param content +     * content：日志内容 +     */ + public static void writeFile(String path, String content) { + File writefile; + try { + // 通过这个对象来判断是否向文本文件中追加内容 + // boolean addStr = append; + writefile = new File(path); + // 如果文本文件不存在则创建它 + if (!writefile.exists()) { + writefile.createNewFile(); + writefile = new File(path); // 重新实例化 + } + + FileOutputStream fw = new FileOutputStream(writefile,true); + Writer out = new OutputStreamWriter(fw, "utf-8"); + out.write(content); + String newline = System.getProperty("line.separator"); + //写入换行   + out.write(newline); + out.close(); + fw.flush(); + fw.close(); + } catch (Exception ex) { + System.out.println(ex.getMessage()); + } + } + + // 获取当前时间 + public static String getCurrentYYYYMM() { + SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd"); + Calendar beforeTime = Calendar.getInstance(); + Date beforeD = beforeTime.getTime(); + String time = sdf.format(beforeD); + return time; + } + // Variables declaration - do not modify//GEN-BEGIN:variables + private javax.swing.JScrollPane jScrollPane1; + private javax.swing.JTextArea jTextArea1; + // End of variables declaration//GEN-END:variables +} diff --git a/test/1111I2client.jar b/test/1111I2client.jar new file mode 100644 index 0000000..d8ee5f8 Binary files /dev/null and b/test/1111I2client.jar differ diff --git a/test/I2client.jar b/test/I2client.jar new file mode 100644 index 0000000..dc16bc6 Binary files /dev/null and b/test/I2client.jar differ diff --git a/test/README.TXT b/test/README.TXT new file mode 100644 index 0000000..d14e9d6 --- /dev/null +++ b/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. diff --git a/test/lib/activation.jar b/test/lib/activation.jar new file mode 100644 index 0000000..b7a4b47 Binary files /dev/null and b/test/lib/activation.jar differ diff --git a/test/lib/axis.jar b/test/lib/axis.jar new file mode 100644 index 0000000..20b09a5 Binary files /dev/null and b/test/lib/axis.jar differ diff --git a/test/lib/commons-discovery-0.2.jar b/test/lib/commons-discovery-0.2.jar new file mode 100644 index 0000000..b885548 Binary files /dev/null and b/test/lib/commons-discovery-0.2.jar differ diff --git a/test/lib/commons-logging-1.0.4.jar b/test/lib/commons-logging-1.0.4.jar new file mode 100644 index 0000000..b73a80f Binary files /dev/null and b/test/lib/commons-logging-1.0.4.jar differ diff --git a/test/lib/jaxrpc.jar b/test/lib/jaxrpc.jar new file mode 100644 index 0000000..a2c13d9 Binary files /dev/null and b/test/lib/jaxrpc.jar differ diff --git a/test/lib/jdom.jar b/test/lib/jdom.jar new file mode 100644 index 0000000..288e64c Binary files /dev/null and b/test/lib/jdom.jar differ diff --git a/test/lib/mailapi_1_3_1.jar b/test/lib/mailapi_1_3_1.jar new file mode 100644 index 0000000..d6b5d37 Binary files /dev/null and b/test/lib/mailapi_1_3_1.jar differ diff --git a/test/lib/mysql-connector-java-5.1.23-bin.jar b/test/lib/mysql-connector-java-5.1.23-bin.jar new file mode 100644 index 0000000..1f90414 Binary files /dev/null and b/test/lib/mysql-connector-java-5.1.23-bin.jar differ diff --git a/test/lib/saaj.jar b/test/lib/saaj.jar new file mode 100644 index 0000000..4ea696e Binary files /dev/null and b/test/lib/saaj.jar differ diff --git a/test/lib/wsdl4j-1.5.1.jar b/test/lib/wsdl4j-1.5.1.jar new file mode 100644 index 0000000..c6254ee Binary files /dev/null and b/test/lib/wsdl4j-1.5.1.jar differ diff --git a/wsdl4j-1.5.1.jar b/wsdl4j-1.5.1.jar new file mode 100644 index 0000000..c6254ee Binary files /dev/null and b/wsdl4j-1.5.1.jar differ diff --git a/更新日志.txt b/更新日志.txt new file mode 100644 index 0000000..42ae7c1 --- /dev/null +++ b/更新日志.txt @@ -0,0 +1,2 @@ +8月20日，改变SF6上传标志位赋值规则，把原来的三相都传送成功设置标志位为1改为从I2表里面查询所有相关的sensorid，当所有sensorid的数据都传送成功才设置标志为1 +9月5日，改变局放数据的上传规则，由原来的上传15分钟前的标志位为非1的数据更改为上传15分钟前的标志位为非1的数据或局放告警状态为大于0的标志位为非1的数据