SP天气查询系统，SP项目

package com.intac.sms.service; import java.io.*; import java.net.*; import java.util.*; import com.intac.sms.util.Constants; import com.intac.sms.msg.IntacMsg; import com.intac.sms.msg.ConnectMsg; import com.intac.sms.msg.ConnectRespMsg; import com.intac.sms.util.Converter; import com.intac.sms.msg.ActiveMsg; import com.intac.sms.msg.ActiveRespMsg; import com.intac.sms.msg.DeliverMsg; import com.intac.sms.msg.DeliverRespMsg; import com.intac.sms.business.BusinessHandler; import com.intac.sms.msg.SubmitRespMsg; import com.intac.sms.msg.SubmitMsg; import com.intac.db.WeatherDAO; import com.intac.sms.business.OperationWeather; import com.intac.sms.business.OrderDAO; import com.intac.sms.business.OrderHandler; import com.intac.sms.msg.ProvisionMsg; /** * * <p>Title: 主连接处理类</p> * * <p>Description:主连接处理 </p> * * <p>Copyright: Copyright (c) 2006</p> * * <p>Company:IMTI </p> * * @author not attributable * @version 1.0 */ public class SMGConnection extends Thread { private String myip; private int myport; private boolean mystate; private boolean canSubmit; private Socket mySocket; private DataInputStream dataInStream; private DataOutputStream dataOutStream; private long mylastactivetime; private long mylogintime; private boolean myShutdownFlag = false; Vector vt = new Vector();; // int sequence; public SMGConnection(String ip, int port) { myip = ip; myport = port; mystate = false; canSubmit = false; } //connect Cmpp public boolean init() { try { System.out.println("Init SMGConnection ..."); mylogintime = System.currentTimeMillis(); mySocket = new Socket(myip, myport); mySocket.setSoTimeout(100000); dataInStream = new DataInputStream(mySocket.getInputStream()); dataOutStream = new DataOutputStream(mySocket.getOutputStream()); System.out.println("SMG connected !"); ConnectMsg connectmsg = new ConnectMsg(Constants.SP_ID, Constants.SP_PWD, Constants.Cmpp_Version); connectmsg.sequenceID = IntacMsg.getSequence(); send(connectmsg.encode()); System.out.println("SEND to SMG LOGIN :" + "\n\treq.sourceAddr=" + connectmsg.sourceAddr + "\n\treq.authSource=" + Converter.bytes2HexString(connectmsg.authSource. getBytes("ISO-8859-1")) + "\n\treq.timeStamp=" + connectmsg.timeStamp + "\n\treq.version=" + connectmsg.version); mylastactivetime = System.currentTimeMillis(); mystate = true; } catch (Exception e) { disconnect(); mystate = false; } return mystate; } /** * 用于发送下行信息 */ public boolean sendSubmitMsg(IntacMsg msg) { if (!canSubmit) { return false; } System.out.println("aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaB"); SubmitMsg sm = (SubmitMsg) msg; // WeatherDAO wdao = new WeatherDAO(); //OperationWeather ow = new OperationWeather(); // int sequence = sm.getSequence(); // // int commandID = sm.commandID; // long msg_id = sm.Msg_Id; //得到信息标识 // //String dest_id = sm; //得到目的号码 // String service_id = sm.Service_Id; //业务标识 // int msg_fmt = sm.Msg_Fmt; //信息格式 // //String src_terminal_id = sm.; //源终端号码 // // byte src_terminal_type = sm.; //源终端号码类型 // int registered_delivery = sm.Registered_Delivery; //是否为状态报告：0：非状态报告,1：状态报告 // // int msg_length = sm.Msg_Length; //消息长度 // String msg_content = sm.Msg_Content; //消息内容 // String link_ID = sm.LinkID; //点播业务使用的LinkID，非点播类业务的MT流程不使用该字段 vt.add(sm); try { send(sm.encode()); //TODO: send(byte[]) } catch (Exception ex1) { ex1.printStackTrace(); System.out.println("send SubmitMsg is Exception!!!"); } return true; } /** * 在连接上发送消息 */ private synchronized void send(byte[] bb) throws Exception { if (bb == null) { throw new Exception("Cmpp send pack is null ."); } if ( (bb.length > Constants.Cmpp_MAX_MSG_LEN) || (bb.length < Constants.Cmpp_MIN_MSG_LEN)) { throw new Exception("Cmpp send pack length error : " + bb.length); } System.out.println("Send to SMG len = " + (bb.length + 4) + "\n\t" + Converter.bytes2HexString(bb)); dataOutStream.writeInt(bb.length + 4); dataOutStream.write(bb); dataOutStream.flush(); } /** * 接收数据线程<br> * 接收阻塞，收取完整数据包后调用处理数据方法<br> */ public void run() { while (!myShutdownFlag) { try { if (mystate) { byte[] buf = recv(); //System.out.println("Cmpp received pack len: "+ (buf.length+4)); if (buf.length == 1) { if (buf[0] == Constants.ERROR_INTERRUPT) { if (System.currentTimeMillis() - mylastactivetime < 300 * 1000) { sendActive(); //发送连接测试信号 continue; } else { //timeout disconnect(); mystate = false; System.out.println( "Cmpp socket timeout . Disconnected . "); mylogintime = 0; continue; } } else if (buf[0] == Constants.ERROR_SOCKET) { disconnect(); mystate = false; System.out.println("Cmpp socket error . Disconnected . "); mylogintime = 0; continue; } else { continue; } } mylastactivetime = System.currentTimeMillis(); // todo 处理消息 handle(buf); } else { //未连接 if (System.currentTimeMillis() - mylogintime > 30 * 1000) { disconnect(); this.init(); } else { Thread.sleep(1000); } } } catch (Exception ee) { ee.printStackTrace(); try { Thread.sleep(10000); } catch (Exception e) { } } } // end while } /** * 在连接上接收数据 * 根据SMPP报文的长度字段从输入数据流中读取相应的报文 * @return * receivedData <br> * receivedData[0]=ERROR_SOCKET SOCKET出错<br> * receivedData[0]=ERROR_INTERRUPT SOCKET超时中断<br> */ private byte[] recv() { //接受的数据不包含总共长度 byte[] receivedData; try { int dataSize = dataInStream.readInt(); //System.out.println ("dataSize= "+dataSize); if ( (dataSize < 12) || (dataSize > Constants.Cmpp_MAX_MSG_LEN)) { receivedData = new byte[1]; receivedData[0] = Constants.ERROR_SOCKET; return receivedData; } receivedData = new byte[dataSize - 4]; dataInStream.readFully(receivedData); System.out.println("Recv from SMG len = " + dataSize); System.out.println("\t" + Converter.bytes2HexString(receivedData)); } catch (NullPointerException e) { e.printStackTrace(); receivedData = new byte[1]; receivedData[0] = C