getfixdatathread.java

GPRS数据通讯软件源码

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 * 补取历史数据线程
 */

package documenteditor;

import java.text.ParseException;
import java.util.Date;
import java.util.logging.Level;
import java.util.logging.Logger;

/**
 *
 * @author Administrator
 */
public class GetFixDataThread extends Thread{
    
    private GPRSClientThread gct = null;
    
    private String BeginTime = "";//开始时间
    
    private String EndTime = "";//结束时间
    
    public GetFixDataThread(GPRSClientThread gct,String BeginTime,String EndTime){
        this.gct = gct;
        this.BeginTime = BeginTime;
        this.EndTime = EndTime;
    }
    
    @Override
    public void run(){
        try {
            gct.setGetfixing(true);            
            //gct.SendMessage(Protocol_WR_WDC07A.ReturnStopNowData(gct.getID().toString()).getBytes());
            Date DBeginTime = new Date();
            Date DEndTime = new Date();
            DBeginTime = Protocol_WR_WDC07A.df4.parse(BeginTime);
            DEndTime = Protocol_WR_WDC07A.df4.parse(EndTime);
            gct.getDevMessage().Enqueue("站点：<"+gct.getSite_id()+">"+gct.getName()+" 开始取历史数据，开始时间：<"+BeginTime+"> 结束时间：<"+EndTime+">");
            sleep(5000);
            while(DBeginTime.getTime()<=DEndTime.getTime()){
                String temp = Protocol_WR_WDC07A.df2.format(DBeginTime);                
                gct.SendMessage(Protocol_WR_WDC07A.ReturnGetFixData(gct.getID().toString(), temp, temp,gct.getST()).getBytes());
                gct.getDevMessage().Enqueue("发送出补取<"+gct.getSite_id()+">"+gct.getName()+"<"+Protocol_WR_WDC07A.df3.format(DBeginTime)+">历史数据的命令");
                sleep(15000);
                DBeginTime.setTime(DBeginTime.getTime()+10*60*1000);
            }
            gct.setGetfixing(false);
            gct.getDevMessage().Enqueue("站点：<"+gct.getSite_id()+">"+gct.getName()+" 取历史数据完成");
            //gct.SendMessage(Protocol_WR_WDC07A.ReturnGetNowData(gct.getID().toString()).getBytes());
        } catch (InterruptedException ex) {
            Logger.getLogger(GetFixDataThread.class.getName()).log(Level.SEVERE, null, ex);
            gct.setGetfixing(false);
        } catch (ParseException ex) {
            //Logger.getLogger(GetFixDataThread.class.getName()).log(Level.SEVERE, null, ex);
            gct.getDevMessage().Enqueue("日期格式不正确，站点："+gct.getSite_id()+"<"+gct.getName()+">取历史数据失败");
            gct.setGetfixing(false);
        }
    }

}