gprsclientthread.java

GPRS数据通讯软件源码

                dbconn.SendToDBMessage(new ToDBConnMessage(this, Str));
                if(Str.indexOf("Avg")>0){
                    if(TimingDataTableModel.getRowCount()>100){
                        TimingDataTableModel.removeRow(TimingDataTableModel.getRowCount()-1);
                    }
                    TimingDataTableModel.insertRow(0, ReVector);
                }else{
                    if(NowDataTableModel.getRowCount()>100){
                        NowDataTableModel.removeRow(NowDataTableModel.getRowCount()-1);
                    }
                    NowDataTableModel.insertRow(0, ReVector);
                }
            }else if(CN.equals("2051")){                
                Vector ReVector = Protocol_WR_WDC07A.GetValues(bytes);
                String Str = new String(bytes);
                dbconn.SendToDBMessage(new ToDBConnMessage(this, Str));
                if(FixDataTableModel.getRowCount()>100){
                    FixDataTableModel.removeRow(FixDataTableModel.getRowCount()-1);
                }
                FixDataTableModel.insertRow(0, ReVector);
            }else if(CN.equals("2081")){                
                Vector ReVector = Protocol_WR_WDC07A.GetValues(bytes);
                String Str = new String(bytes);
                dbconn.SendToDBMessage(new ToDBConnMessage(this, Str));
                if(TimingDataTableModel.getRowCount()>100){
                    TimingDataTableModel.removeRow(TimingDataTableModel.getRowCount()-1);
                }
                TimingDataTableModel.insertRow(0, ReVector);
            }
        }
    }

    public MessageQueue getReceMessage() {
        return ReceMessage;
    }
    
    //发送数据方法
    public void SendMessage(byte[] buff){
        changIcoThread.setSending(true);
        SendMessage.Enqueue(buff); 
        if(!ID.toString().equals("00000000000000")){
            getLogClass().SendWriteLog(new String(buff), ID.toString());
        }
    }
    
    //设置第i个监测项目名
    public void SetItem(int i,String ItemName){
        if(i<16){
            Items[i] = ItemName;
        }
    }
    
    //返回有效的数据通道
    public String GetItems_(){
        String ReStr = "";        
        for(int i=0;i<ItemsSet.length();i++){
            if(ItemsSet.substring(i,i+1).equals("1")){
                if(Items[i]!=null){
                    ReStr += Items[i]+",";
                }                
            }
        }
        return ReStr;
    }
    
    //设置数据展示表列
    public String SetItems_(){
        String ReStr = "";
        Vector Columns = new Vector();        
        Columns.add("采集时间");
        getUseIsChannV().clear();
        for(int i=0;i<ItemsSet.length();i++){            
            if(ItemsSet.substring(i,i+1).equals("1")){                
                getUseIsChannV().add("是");
                try {
                    if (Items[i] != null) {
                        if (ItmeProp.getProperty(Items[i]) != null) {
                            String temp = ItmeProp.getProperty(Items[i]);
                            Columns.add(temp);                            
                        }
                    }
                } catch (ArrayIndexOutOfBoundsException exception) {
                }            
            }else{
                getUseIsChannV().add("否");
            }
        }
        Columns.add("开关量");
        NowDataTableModel.setColumnIdentifiers(Columns);
        TimingDataTableModel.setColumnIdentifiers(Columns);
        FixDataTableModel.setColumnIdentifiers(Columns);
        return ReStr;
    }

    public Socket getSocket() {
        return socket;
    }

    public Date getLastTime() {
        return LastTime;
    }

    public void setShutdown(boolean Shutdown) {
        this.Shutdown = Shutdown;
    }

    public StringBuffer getID() {
        return ID;
    }

    public void setID(StringBuffer ID) {
        this.ID = ID;
    }

    public void setName(String Name) {
        this.Name = Name;
    }

    public String getName() {
        return Name;
    }

    public String getInetAddress() {
        return InetAddress;
    }

    public void setInetAddress(String InetAddress) {
        this.InetAddress = InetAddress;
    }

    public String getPort() {
        return Port;
    }

    public void setPort(String Port) {
        this.Port = Port;
    }

    public Date getLastRtdTime() {
        return LastRtdTime;
    }

    public void setLastRtdTime(Date LastRtdTime) {
        this.LastRtdTime = LastRtdTime;
    }

    public Date getLastTimingTime() {
        return LastTimingTime;
    }

    public void setLastTimingTime(Date LastTimingTime) {
        this.LastTimingTime = LastTimingTime;
    }

    public OutputStream getSocketOut() {
        return socketOut;
    }

    public MessageQueue getSendMessage() {
        return SendMessage;
    }

    public void setLastTime(Date LastTime) {
        this.LastTime = LastTime;
    }

    public String[] getItems() {
        return Items;
    }

    public String getItemsSet() {
        return ItemsSet;
    }

    public void setItemsSet(String ItemsSet) {
        this.ItemsSet = ItemsSet;
    }
    
    @Override
    public String toString(){
        if(Name.equals("")){
            return ID.toString();
        }else{
            return Name;
        }        
    }

    public DefaultMutableTreeNode getTsn() {
        return tsn;
    }

    public void setTsn(DefaultMutableTreeNode tsn) {
        this.tsn = tsn;
    }

    public DefaultTableModel getNowDataTableModel() {
        return NowDataTableModel;
    }

    public DefaultTableModel getTimingDataTableModel() {
        return TimingDataTableModel;
    }

    public DefaultTableModel getFixDataTableModel() {
        return FixDataTableModel;
    }

    public boolean isGetfixing() {
        return getfixing;
    }

    public void setGetfixing(boolean getfixing) {
        this.getfixing = getfixing;
    }

    public String getSite_id() {
        return site_id;
    }

    public void setSite_id(String site_id) {
        this.site_id = site_id;
    }

    public MessageQueue getDevMessage() {
        return devMessage;
    }

    public LogClass getLogClass() {
        return logClass;
    }

    public String getLoginTime() {
        return Protocol_WR_WDC07A.df3.format(LoginTime);
    }
    
    public Date getLoginTime_() {
        return LoginTime;
    }

    public int getSplit() {
        return split;
    }

    public void setSplit(int split) {
        this.split = split;
    }

    public Vector getUseSetChannV() {
        return UseSetChannV;
    }

    public Vector getUseIsChannV() {
        return UseIsChannV;
    }

    public String getMN_() {
        return MN_;
    }

    public void setMN_(String MN_) {
        this.MN_ = MN_;
    }

    public String getST() {
        return ST;
    }

    public void setST(String ST) {
        this.ST = ST;
    }

}