GMM/GMMSoft.git

{------------------------------------------------------------------------------}
{µ¥ÔªÃû³Æ£ºtestThread.pas                                                      }
{Ä£¿éÃû³Æ£º×Ô¶¯¼ì²âÏß³Ì                                                        }
{Ä£¿éËµÃ÷£ºÏß³Ì´´½¨ºó×Ô¶¯Æô¶¯                                                  }
{          ×Ô¶¯¼ì²âÏß³Ì¸ù¾ÝplcÖ¸Áî£¬¿ØÖÆË®·ÖÒÇ×Ô¶¯Íê³Éº¬Ë®ÂÊ¼ì²â£¬×Ô¶¯ÉÏ±¨½á¹û }
{½¨Á¢ÈÕÆÚ£º2023-10-27                                                          }
{ÐÞ¸ÄÐÞ¸Ä£º2023-11-11                                                          }
{°æÈ¨ËùÓÐ£ºÀîÁ¼Í¥ liangtingli@outlook.com                                      }
{------------------------------------------------------------------------------}
unit testThread;
 
interface
 
uses
  Windows, Classes, SysUtils, PubUtils, DateUtils, ActuatorLib;
 
type
  TTestThread = class(TThread)
  private
    { Private declarations }
    t_ret : Integer;
    t_faultCode : Word;                //Ë®·ÖÒÇ¹ÊÕÏÂë
 
    t_val1, t_val2 : Double;           //¼ÆËã³öÀ´µÄº¬Ë®ÂÊ¡¢ÈÝÖØ±È
    t_val3, t_val4 : Double;           //²É¼¯³öÀ´µÄ ÎÂ¶È¡¢Êª¶È
    t_nGrainType : Word;               //Á¸ÖÖ´úÂë
    t_nDatas : array[0..3] of Word;    //Ë®·ÖÒÇÊý¾Ý
    x0,x1,x2,x3,x4,x5 : double;        //Ð£×¼ÏµÊý
    procedure UpdateStartClock;
    procedure UpdateStopClock;
    procedure UpdateSendGrain;
    procedure UpdateSendTest;
    procedure UpdateReadStateError;
    procedure UpdateReLink;
    procedure UpdateModifyGrain;
    procedure UpdateModifyGrainError;
    procedure UpdateTest;
    procedure UpdateTestError;
    procedure UpdateResetError;
    procedure UpdateQuit;
  protected
    procedure Start();
    procedure Execute; override;
  public
    constructor Create(param: Boolean=false);
    procedure Terminate;
  end;
 
implementation
 
uses
  uMain, uDM, uInit, uSaveData, Global, log4me;
 
{ TTestThread }
//--------Ïß³Ì³õÊ¼»¯----------------------------------------
//Ïß³Ì³õÊ¼»¯
constructor TTestThread.Create(param: Boolean=false);
begin
  //Ïß³ÌÍ£Ö¹ºó×Ô¶¯ÊÍ·Å
  inherited Create(param);        //ÉèÖÃÏß³ÌÔËÐÐ, False-×Ô¶¯ÔËÐÐ, True-ÊÖ¶¯Æô¶¯
  FreeOnTerminate := True;        //ÉèÖÃÏß³ÌÍË³ö×Ô¶¯Ïú
  t_val1 := 0;
  t_val2 := 0;
  t_val3 := 0;
  t_val4 := 0;
  t_ret := 0;
end;
 
//Ïß³ÌÏú»ÙÊÂ¼þ
procedure TTestThread.Terminate;
begin
  inherited;
  m_TestThread := 0;             //ÇåÀíÏß³Ì¾ä±ú
end;
 
//--------½çÃæ´¦Àíº¯Êý--------------------------------------
//¼ÆÊýÆ÷¿ªÊ¼
procedure TTestThread.UpdateStartClock;
begin
  //Æô¶¯¼ì²â¼ÆÊ±Æ÷¶¯»
  glStartTest := GetMillisecondTimeStamp;
  dm.tmAutoTest.Enabled := true;
end;
 
//¼ÆÊýÆ÷½áÊø
procedure TTestThread.UpdateStopClock;
begin
  dm.tmAutoTest.Enabled := false;
  frmMain.mtAutoClock.Value := 0;
end;
 
//×´Ì¬ÏÔÊ¾--ÏÂ·¢ÐÞ¸ÄÁ¸ÖÖÖ¸Áî
procedure TTestThread.UpdateSendGrain;
begin
  //¼ÓÔØÁ¸ÖÖÐ£×¼ÏµÊý
  Grain := queryGrainSql1(t_Grain, t_nGrainType);
  x0 := StrToFloat(Grain.coef[0]);
  x1 := StrToFloat(Grain.coef[1]);
  x2 := StrToFloat(Grain.coef[2]);
  x3 := StrToFloat(Grain.coef[3]);
  x4 := StrToFloat(Grain.coef[4]);
  x5 := StrToFloat(Grain.Intercept);//ÐÂÔö½Ø¾à
 
  //¸üÐÂ½çÃæÐÅÏ¢
  frmMain.lblAutoInfo.Caption := 'ÐÞ¸ÄÁ¸ÖÖÐÅÏ¢£¬ÇëÉÔºò......';
  frmMain.lblAutoRet.Caption := '';
  frmMain.lblAutoRet_error.Caption := '';
end;
 
//×´Ì¬ÏÔÊ¾--ÏÂ·¢¼ì²âÖ¸Áî
procedure TTestThread.UpdateSendTest;
begin
  //¸üÐÂ½çÃæÐÅÏ¢
  frmMain.lblAutoInfo.Caption := 'ÕýÔÚ¼ì²âº¬Ë®ÂÊ£¬ÇëÉÔºò......';
  frmMain.lblAutoRet.Caption := '';
  frmMain.lblAutoRet_error.Caption := '';
end;
 
//-------- ´íÎóÐÅÏ¢ ---------------------------------------
//³ö´íÏÔÊ¾--¶ÁPLC×´Ì¬×ÖÒì³£
procedure TTestThread.UpdateReadStateError;
begin
  //¸üÐÂ½çÃæÐÅÏ¢
  frmMain.lblAutoRet.Caption := '';
  frmMain.lblAutoRet_error.Caption := '¶ÁÈ¡ PLC×´Ì¬×Ö Òì³££¡';
  log4error(Format('´íÎó£º¶ÁÈ¡ PLC×´Ì¬×Ö Òì³££¬·µ»ØÖµ=[%d].',[t_ret]));
end;
 
//³ö´í»Ø¸´--Ò»°ãÊÇÖØÁ¬»Ö¸´
procedure TTestThread.UpdateReLink;
begin
  if frmMain.lblAutoRet_error.Caption<>'' then begin
    frmMain.lblAutoRet_error.Caption := '';
    log4error('Á¬½Ó£ºÍ¨Ñ¶Òì³£ºó£¬×Ô¶¯¶Ï¿ªÖØÁ¬³É¹¦£¡');
  end;
end;
 
//Õý³£ÏÔÊ¾--ÐÞ¸ÄÁ¸ÖÖÐÅÏ¢
procedure TTestThread.UpdateModifyGrain;
begin
  //¸üÐÂ½çÃæÐÅÏ¢
  frmMain.lblAutoInfo.Caption := 'Á¸Ê³Æ·ÖÖÐÞ¸Ä³É¹¦£¬×¼±¸¾ÍÐ÷£¡';
  frmMain.lblAutoRet.Caption := '';
  frmMain.lblAutoRet_error.Caption := '';
  log4info('Á¸ÖÖÐÅÏ¢£ºÁ¸Ê³Æ·ÖÖÐÞ¸Ä³É¹¦£¬×¼±¸¾ÍÐ÷£¡');
end;
 
//³ö´íÏÔÊ¾--ÐÞ¸ÄÁ¸ÖÖ³ö´í
procedure TTestThread.UpdateModifyGrainError;
begin
  //¸üÐÂ½çÃæÐÅÏ¢
  frmMain.lblAutoRet.Caption := '';
  frmMain.lblAutoRet_error.Caption := Format('Á¸Ê³Æ·ÖÖÐÞ¸ÄÊ§°Ü£¬Ë®·ÖÒÇ¹ÊÕÏÂë [%d]£¡',[t_faultCode]);
  log4error('Á¸ÖÖÐÅÏ¢£ºÁ¸Ê³Æ·ÖÖÐÞ¸ÄÊ§°Ü£¬Ë®·ÖÒÇ¹ÊÕÏ£¡');
end;
 
//Õý³£ÏÔÊ¾--Ö´ÐÐ¼ì²â
procedure TTestThread.UpdateTest;
var ss : string;
begin
  if glIsDebug then
    frmMain.lblAutoInfo1.Caption := Format('Á¸ÖÖ[%s], ÏµÊý[%s,%s,%s,%s,%s]',
                  [Grain.Name,
                   Grain.Coef[0],
                   Grain.Coef[1],
                   Grain.Coef[2],
                   Grain.Coef[3],
                   Grain.Coef[4]]);
  //¸üÐÂ½çÃæÐÅÏ¢
  frmMain.lblAutoInfo.Caption := 'º¬Ë®ÂÊ¼ì²â³É¹¦£¡';
  ss := 'º¬Ë®ÂÊ: '+Format('%.2f',[Trunc(t_val1*100)/100])+'%, ÎÂ¶È: '+Format('%.2f',[t_val3])+'¡æ, Êª¶È: '+Format('%.2f',[t_val4])+'%.';
  frmMain.lblAutoRet.Caption := ss;
  frmMain.lblAutoRet_error.Caption := '';
  log4info('×Ô¶¯¼ì²â£ºº¬Ë®ÂÊ¼ì²â³É¹¦£¬'+ss);
 
  //¸üÐÂÊý¾Ý¿âºÍ±£´æcsv
  insertTestSql(t_Data,Ord(rmAuto),1,DateTimeToUnix(Now),
                Grain.Code,Grain.Name,'',
                Trunc(t_val1*100)/100, t_val3, t_val4);
  //±£´æcsvÎÄ¼þ
  WriteCsvFile(Grain.Name, t_val1, t_val3, t_val4);
end;
 
//³ö´íÏÔÊ¾--Ö´ÐÐ¼ì²â³ö´í
procedure TTestThread.UpdateTestError;
begin
  //¸üÐÂ½çÃæÐÅÏ¢
  frmMain.lblAutoInfo.Caption := 'Ö´ÐÐ¼ì²âÊ§°Ü£¡';
  frmMain.lblAutoRet.Caption := '';
  frmMain.lblAutoRet_error.Caption := 'Ö´ÐÐ¼ì²âÊ§°Ü£¬Ë®·ÖÒÇ¹ÊÕÏ£¡';
end;
 
//³ö´íÏÔÊ¾--¸´Î»Ê§°Ü
procedure TTestThread.UpdateResetError;
begin
  //¸üÐÂ½çÃæÐÅÏ¢
  frmMain.lblAutoInfo.Caption := 'Ö´ÐÐ¸´Î»Ê§°Ü£¡';
  frmMain.lblAutoRet.Caption := '';
  frmMain.lblAutoRet_error.Caption := 'Ö´ÐÐ¸´Î»²Ù×÷Ê§°Ü£¬Ë®·ÖÒÇ¹ÊÕÏ£¡';
end;
 
//ÍË³öÏß³Ì--´òÓ¡ÈÕÖ¾
procedure TTestThread.UpdateQuit;
begin
  log4info('ÍË³ö£ºÏß³Ì TestThread()ÍË³ö.');
end;
 
//------- Ö´ÐÐÏß³Ì ----------------------------------------
procedure TTestThread.Start();
var
  nState : Word;    //plc×´Ì¬×Ö¡¢Á¸ÖÖ´úÂë
  ret : Integer;
  y : double; //¹«Ê½y=kx+b
begin
  //³õÊ¼»¯Ïß³Ì±äÁ¿
  nState := 0;
  t_nGrainType := 0;
  t_nDatas[0] := 0;
  t_nDatas[1] := 0;
  t_nDatas[2] := 0;
  t_nDatas[3] := 0;
 
  //¶ÁPLC×´Ì¬×Ö£¬»ñÈ¡nState¡¢nGrainType
  t_ret := ReadState(hPlcDev,@nState,@t_nGrainType);
  if t_ret<=0 then
    Synchronize(UpdateReadStateError)
  else if ((nState>0) and (t_nGrainType>0)) then begin
  //==========================================
  //´ÓPLC¶ÁÈ¡ÃüÁî²¢Ö´ÐÐ
  //×¢Òâ£¬ÕâÀï½ö´¦ÀíPLCÏÂ·¢¸øË®·ÖÒÇµÄÃüÁî
  //==========================================
    case nState of
      //0x01-Á¸Ê³Æ·ÖÖ¸ÄÁË
      PLC_READY_GRAIN: begin
        //¼ì²éË®·ÖÒÇ¹ÊÕÏÂë
        ret := ReadFaultCode(hWrDev, @t_faultCode);
        //ÏòË®·ÖÒÇÏÂ·¢Á¸ÖÖÐÞ¸ÄÖ¸Áî
        if ret >=0 then begin
          Synchronize(UpdateStartClock);
          Synchronize(UpdateSendGrain);    //¼ÓÔØÁ¸ÖÖÏµÊý
          ret := SendCommands(hWrDev, WR_READY, t_nGrainType, glTime1);
          Synchronize(UpdateStopClock);
        end;
        if ret<0 then begin
          Synchronize(UpdateModifyGrainError);
          ResponseState(hPlcDev, PLC_DEVICE_WR_FAULT);
        end
        else begin
          Synchronize(UpdateModifyGrain);
          ResponseState(hPlcDev, PLC_READY_FINISH);
        end;
      end;
      //0x03-¿ªÊ¼²âÊÔ
      PLC_DETECT_START: begin
        //ÏòË®·ÖÒÇÏÂ·¢¼ì²âÖ¸Áî
        Synchronize(UpdateStartClock);
        Synchronize(UpdateSendTest);
        ret := SendCommands(hWrDev, WR_DETECT, 0, glTime2);
        Synchronize(UpdateStopClock);
        if ret<0 then begin
          Synchronize(UpdateTestError);
          ResponseState(hPlcDev, PLC_DEVICE_WR_FAULT);
        end
        else begin
          //´ÓË®·ÖÒÇ¶ÁÈ¡¼ì²â½á¹û:
          //0-µçÑ¹¡¢1-ÖØÁ¿¡¢2-ÎÂ¶È¡¢3-Êª¶È
          ReadDatas(hWrDev, @t_nDatas);
          //·µ»ØPLC¼ì²â³É¹¦
          ResponseState(hPlcDev, PLC_DETECT_FINISH);
          //¼ÆËãº¬Ë®ÂÊ
          {t_val1 := x0 +
                    x1 * t_nDatas[0] +
                    x2 * t_nDatas[0] * t_nDatas[0] +
                    x3 * t_nDatas[0] * t_nDatas[0] * t_nDatas[0] +
                    x4 * t_nDatas[0] * t_nDatas[0] * t_nDatas[0] * t_nDatas[0]; }
          t_val1 := CalcValue(t_nDatas[0], x0,x1,x2,x3,x4) + x5; //½«½Ø¾à¼Ó½øÈ¥
          //--------------------------------------------
          //ÓÃ¹«Ê½ y=kx+b ¼ÆËãÖØÁ¿£¬ÖØÁ¿-È¥Æ¤
          y := Wg.k * (t_nDatas[1]-SysConfig.Tare) + Wg.b;
          //--------------------------------------------
          //¼ÆËãÈÝÖØ±È
          if SysConfig.Volume=0 then SysConfig.Volume:=1;
          t_val2 := y / SysConfig.Volume;    //×¢ÒâÕâÀïÊ¹ÓÃÐÂ¹«Ê½¼ÆËãÈÝÖØ±È
 
          //µ÷ÕûÎÂÊª¶È¸ßµÍÎ»£¬liliangting 2024-10-15
          t_val3 := t_nDatas[2]/10;
          t_val4 := t_nDatas[3]/10;
          //t_val3 := SwapHighLowWord(t_nDatas[2])/10; //¶ÔÎÂ¶È¸ßµÍÎ»½»»»
          //t_val4 := SwapHighLowWord(t_nDatas[3])/10; //¶ÔÊª¶È¸ßµÍÎ»½»»»
 
          //½á¹ûÊä³öµ½½çÃæ
          Synchronize(UpdateTest);
 
          //Æ´³ÉÈý¸öÊý¾ÝµÄÊý×é£¬´«¸øPLC
          t_nDatas[0] := t_nGrainType;        //Á¸Ê³Æ·ÖÖ
          t_nDatas[1] := Trunc(t_val1*100);   //º¬Ë®ÂÊ-->PLCÒªÇó³ËÒÔ100È¡Õû£¬ÒÔ±ã¼Ä´æÆ÷´æÈëÕûÊý£¬²¢·ÇÕæÊµ½á¹û
          t_nDatas[2] := Trunc(t_val2*10);    //ÈÝÖØ±È-->PLCÒªÇó³ËÒÔ10 È¡Õû£¬ÒÔ±ã¼Ä´æÆ÷´æÈëÕûÊý£¬²¢·ÇÕæÊµ½á¹û
          UploadData(hPlcDev, @t_nDatas);
        end;
      end;
      //0xFE-¸´Î»ÃüÁî
      PLC_DEVICE_WR_RESET: begin
        if SendCommands(hWrDev, WR_RESET, 0, glTime2)<0 then begin
          Synchronize(UpdateResetError);
          ResponseState(hPlcDev, PLC_DEVICE_WR_FAULT);
        end;
      end;
      //ÆäËûÃüÁî×ÖÊ±£¬½öÇå³ýÒì³£±êÇ©£¬liliangting 2023-12-7
      else
        Synchronize(UpdateReLink);
    end;
    //=====PLCÖ¸Áî½âÎö½áÊø======================
  end
  //µ±²»Âú×ãÖ¸ÁîÊ±£¬Ò²¸üÐÂÖØÁ¬±êÇ©ÐÅÏ¢£¡liliangting 2023.12.8
  else
    Synchronize(UpdateReLink);
end;
 
//------- Ïß³ÌÈë¿Ú ----------------------------------------
procedure TTestThread.Execute;
begin
  { Place thread code here }
  while not terminated do begin
    //Ö´ÐÐ¼ì²â´úÂë
    Start();
    //·ÀÖ¹Ïß³Ì×èÈûCPU
    Sleep(1000);
  end;
  Synchronize(UpdateQuit);
end;
 
end.