//******************************************************************************
//*本單元功能是繼承了Comm的一個類模塊                                          *
//*單元名稱：TQueryThreadClass                                                 *
//*單元功能：232-485通訊                                                       *
//*具體描述：                                                                  *
//*開發作者：張志華                                                            *
//*電子郵件：E-mail(MSN):luer88@163.net; QQ:29763034 TEL:13088096280           *
//*開發日期：2004-10-11                                                        *
//*使用方法：用戶需要向串口發送指定的字符的時候只需要調用相應的命令函數，然后再*
///*調用統一的發送函數SendByte(x:integer)其中X表示該命令需要發送的BUF的個數    *
//*屬    性：                                                                  *
//*修改日期：                                                                  *
//******************************************************************************
unit TQueryThreadClass;

interface
uses
    Classes,Db, DBTables,StdCtrls, SysUtils, UnitDataModule,ADODB,
    ComObj, Messages,Dialogs,activeX,Windows
    ,Forms,QDialogs;
type
    TQueryThread = class(TThread)
    private
        query:TAdoquery;
    protected
        procedure Execute; override;
    public

    end;

implementation
uses  UnitMain, UnitPublic;
procedure TQueryThread.Execute;
var
    OpenCount:Integer;
    Cont_NO     :Integer;
    Terminal_NO :Integer;
    Uport_NO    :Integer;
    UportData   :Integer;
begin
    inherited;
    FreeOnTerminate:=True;
	try
	    CoInitialize(nil);
    	query:=TAdoquery.Create(nil);
        query.Connection:=frm_DataModule.ADO_Connection;
        while not terminated do
        begin
            with query do
            begin
                close;
                sql.Clear ;
                Sql.Add('Select Equipment_NO,Equipment_Name,Equipment_Address,Cont,Terminal,Uport from [Equipment]order by Equipment_NO ');
                open;
                if RecordCount>0 then
                begin
                    while Not Eof Do
                    begin
                        Cont_NO     :=FieldByName('Cont').AsInteger;
                        Terminal_NO :=FieldByName('Terminal').AsInteger;
                        Uport_NO    :=FieldByName('Uport').AsInteger;
                        try
                            MySpcomm.ReadUportReader(Cont_NO,Terminal_NO,Uport_NO);
                        except
                        end;
                        Sleep(MusicLength);
                        Next;
                    end;
                end;
            end;
        end;
    finally
	    CoUnInitialize;
    end;
    if terminated then
    exit;
end;

end.