Vehicle.cs 57 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703
  1. using System;
  2. using System.Collections;
  3. using System.Collections.Generic;
  4. using System.Linq;
  5. using System.Threading;
  6. using System.Threading.Tasks;
  7. using FluentResults;
  8. using GSG.NET.Concurrent;
  9. using GSG.NET.Extensions;
  10. using GSG.NET.LINQ;
  11. using GSG.NET.Logging;
  12. using GSG.NET.Quartz;
  13. using GSG.NET.Utils;
  14. using OHV.Common.Events;
  15. using OHV.Common.Model;
  16. using OHV.Common.Shareds;
  17. using OHV.SqliteDAL;
  18. using Prism.Events;
  19. using VehicleControlSystem.ControlLayer.Actuator.Cylinder;
  20. using VehicleControlSystem.ControlLayer.Drive;
  21. using VehicleControlSystem.ControlLayer.IO;
  22. using VehicleControlSystem.ControlLayer.Serial.BatteryTabos;
  23. using VehicleControlSystem.ControlLayer.Serial.DataModel;
  24. using VehicleControlSystem.Managers;
  25. namespace VehicleControlSystem.ControlLayer
  26. {
  27. /// <summary>
  28. /// Control Layer 의 자원을 여기서 사용하자.
  29. /// </summary>
  30. public class Vehicle : ControlObjectBase, IDisposable
  31. {
  32. /// <summary>
  33. /// OCS Report Code
  34. /// 목적지에 도착해서 Load, Unload 시 발생하는 Alarm
  35. /// </summary>
  36. public enum eFailCode
  37. {
  38. Load_PortHasNotCarrier = 1,
  39. Load_VehicleHasCarrier,
  40. Unload_PortHasCarrier,
  41. Unload_VehicleHasNotCarrier,
  42. LoadPIOInterlockTimeout,
  43. UnlaodPIOInterlockTimeout,
  44. }
  45. static Logger logger = Logger.GetLogger();
  46. static Logger loggerPIO = Logger.GetLogger( "PIO" );
  47. #region Properties
  48. /// <summary>
  49. /// Tag 위치
  50. /// </summary>
  51. private string currentTag = "0000";
  52. public string CurrentTag
  53. {
  54. get { return currentTag; }
  55. set
  56. {
  57. if ( SetField( ref this.currentTag, value ) )
  58. {
  59. var info = sql.VehicleInfoDAL.GetInfo();
  60. info.CurrentTag = value;
  61. sql.VehicleInfoDAL.Update( info );
  62. this.OnCurrentTagChanged?.Invoke( value );
  63. }
  64. }
  65. }
  66. /// <summary>
  67. /// Scale Value
  68. /// </summary>
  69. private double currentPosition;
  70. public double CurrentPosition
  71. {
  72. get { return currentPosition; }
  73. set
  74. {
  75. if ( SetField( ref this.currentPosition, value ) )
  76. {
  77. }
  78. }
  79. }
  80. private double currentSpeed;
  81. public double CurrentSpeed
  82. {
  83. get { return currentSpeed; }
  84. set { SetField( ref this.currentSpeed, value ); }
  85. }
  86. private double currentTorque;
  87. public double CurrentTorque
  88. {
  89. get { return currentTorque; }
  90. set { SetField( ref this.currentTorque, value ); }
  91. }
  92. private bool isContain;
  93. public bool IsContain
  94. {
  95. get { return isContain; }
  96. set { SetField( ref this.isContain, value ); }
  97. }
  98. eClampState _clampState;
  99. public eClampState ClampState
  100. {
  101. get { return this._clampState; }
  102. set { this.SetField( ref this._clampState, value ); }
  103. }
  104. private eSteeringState steeringState;
  105. public eSteeringState SteeringState
  106. {
  107. get { return steeringState; }
  108. set { SetField( ref this.steeringState, value ); }
  109. }
  110. private int _obstacleDrive;
  111. public int ObstacleDrive { get { return this._obstacleDrive; } set { SetField( ref this._obstacleDrive, value ); } }
  112. private int _obstacleCurve;
  113. public int ObstacleCurve { get { return this._obstacleCurve; } set { SetField( ref this._obstacleCurve, value ); } }
  114. private eObstacleState obstacleState = eObstacleState.Normal;
  115. public eObstacleState ObstacleStateProperty
  116. {
  117. get { return obstacleState; }
  118. set
  119. {
  120. if ( SetField( ref this.obstacleState, value ) )
  121. {
  122. if ( value == eObstacleState.Blocked )
  123. this.VehicleStateProperty = eVehicleState.Blocked;
  124. }
  125. }
  126. }
  127. private eVehicleState vehicleState = eVehicleState.None;
  128. public eVehicleState VehicleStateProperty
  129. {
  130. get { return vehicleState; }
  131. set
  132. {
  133. if ( SetField( ref this.vehicleState, value ) )
  134. {
  135. var info = sql.VehicleInfoDAL.GetInfo();
  136. info.VehicleState = value;
  137. sql.VehicleInfoDAL.Update( info );
  138. }
  139. }
  140. }
  141. private eMachineMode machineMode = eMachineMode.LocalMode;
  142. public eMachineMode MachineMode
  143. {
  144. get { return machineMode; }
  145. set
  146. {
  147. if ( SetField( ref this.machineMode, value ) )
  148. {
  149. var info = sql.VehicleInfoDAL.GetInfo();
  150. info.MachineMode = value;
  151. sql.VehicleInfoDAL.Update( info );
  152. }
  153. }
  154. }
  155. private int obstaclePattern;
  156. public int ObstaclePattern
  157. {
  158. get { return obstaclePattern; }
  159. set { SetField( ref this.obstaclePattern, value ); }
  160. }
  161. //이동
  162. public bool Busy
  163. {
  164. get
  165. {
  166. return this.CurrentSubCommand == null ? false : true;
  167. }
  168. set { }
  169. }
  170. public bool IsMoving { get; set; }
  171. #region Battery Property
  172. double batteryVoltage;
  173. public double BatteryVoltage
  174. {
  175. get { return this.batteryVoltage; }
  176. set { this.SetField( ref this.batteryVoltage, value ); }
  177. }
  178. double batteryCurrent;
  179. public double BatteryCurrent
  180. {
  181. get { return this.batteryCurrent; }
  182. set { this.SetField( ref this.batteryCurrent, value ); }
  183. }
  184. double batteryState;
  185. public double BatteryState
  186. {
  187. get { return this.batteryState; }
  188. set { this.SetField( ref this.batteryState, value ); }
  189. }
  190. double batteryChargeTime;
  191. public double BatteryChargeTime
  192. {
  193. get { return this.batteryChargeTime; }
  194. set { this.SetField( ref this.batteryChargeTime, value ); }
  195. }
  196. double batteryDisChargeTime;
  197. public double BatteryDisChargeTime
  198. {
  199. get { return this.batteryDisChargeTime; }
  200. set { this.SetField( ref this.batteryDisChargeTime, value ); }
  201. }
  202. double batteryStateOfCharge;
  203. public double BatteryStateOfCharge
  204. {
  205. get { return this.batteryStateOfCharge; }
  206. set { this.SetField( ref this.batteryStateOfCharge, value ); }
  207. }
  208. double batteryStateOfHealth;
  209. public double BatteryStateOfHealth
  210. {
  211. get { return this.batteryStateOfHealth; }
  212. set { this.SetField( ref this.batteryStateOfHealth, value ); }
  213. }
  214. double batteryCapacity;
  215. public double BatteryCapacity
  216. {
  217. get { return this.batteryCapacity; }
  218. set { this.SetField( ref this.batteryCapacity, value ); }
  219. }
  220. double batteryEnergy;
  221. public double BatteryEnergy
  222. {
  223. get { return this.batteryEnergy; }
  224. set { this.SetField( ref this.batteryEnergy, value ); }
  225. }
  226. double batteryTemperature;
  227. public double BatteryTemperature
  228. {
  229. get { return this.batteryTemperature; }
  230. set { this.SetField( ref this.batteryTemperature, value ); }
  231. }
  232. bool batteryIsConnect;
  233. public bool BatteryIsConnect
  234. {
  235. get
  236. {
  237. this.BatteryIsConnect = this.bMUManager.IsConnected;
  238. return this.bMUManager.IsConnected;
  239. }
  240. set { this.SetField( ref this.batteryIsConnect, value ); }
  241. }
  242. #endregion
  243. public bool IsError { get; set; }
  244. public SubCmd CurrentSubCommand { get; private set; }
  245. #endregion
  246. #region Event
  247. public event Action OnMoveReady;
  248. public event Action OnMoving;
  249. public event Action OnMoveFinish;
  250. public event Action OnChargingStart;
  251. public event Action OnCharging;
  252. public event Action OnChargingFull;
  253. public event Action<double> OnBatteryVelueChanged;
  254. public event Action<bool> OnPIOStart;
  255. public event Action<bool> OnConveyorStart;
  256. public event Action<bool> OnConveyorStop;
  257. public event Action<bool> OnCarrierDetected;
  258. public event Action OnLoadComplete;
  259. public event Action OnUnloadComplete;
  260. public event Action<string> OnCurrentTagChanged;
  261. public event Action OnManualMove;
  262. public event Action OnManualLoad;
  263. public event Action OnManualUnload;
  264. public event Action OnManualCharging;
  265. public event Action<eFailCode> OnFailReport;
  266. #endregion
  267. #region List.
  268. List<ICylinder> cylinders = new List<ICylinder>();
  269. List<string> obstacleBitList = new List<string>();
  270. #endregion
  271. EzIO iO = null;
  272. GSIDrive drive = null;
  273. SqliteManager sql = null;
  274. Clamp clamp = null;
  275. Steering steering = null;
  276. AutoManager autoManager = null;
  277. BMUManager bMUManager = null;
  278. private Conveyor conveyor = null;
  279. ThreadCancel cancel = new ThreadCancel();
  280. TaskCancel taskCancel = new TaskCancel();
  281. TaskCancel taskMoveCancel = new TaskCancel();
  282. IEventAggregator eventAggregator;
  283. public Vehicle( IIO io, SqliteManager sqliteManager, IEventAggregator ea, AutoManager auto )
  284. {
  285. this.iO = io as EzIO;
  286. this.iO.OnChangedIO += IO_OnChangedIO;
  287. this.sql = sqliteManager;
  288. this.autoManager = auto;
  289. this.obstacleBitList.AddRange( new string[]
  290. {
  291. "OUT_OBSTRUCTION_PATTERN_00",
  292. "OUT_OBSTRUCTION_PATTERN_01",
  293. "OUT_OBSTRUCTION_PATTERN_02",
  294. "OUT_OBSTRUCTION_PATTERN_03",
  295. "OUT_OBSTRUCTION_PATTERN_04",
  296. } );
  297. this.eventAggregator = ea;
  298. /*Drive*/
  299. this.eventAggregator.GetEvent<DriveControlPubSubEvent>().Unsubscribe( ReceiveDriveControlEvent );
  300. this.eventAggregator.GetEvent<DriveControlPubSubEvent>().Subscribe( ReceiveDriveControlEvent );
  301. this.eventAggregator.GetEvent<ObstacleControlPubSubEvent>().Unsubscribe( ObstacleReceiveEvent );
  302. this.eventAggregator.GetEvent<ObstacleControlPubSubEvent>().Subscribe( ObstacleReceiveEvent );
  303. }
  304. private void ObstacleReceiveEvent( ObstacleControlEventArgs obj )
  305. {
  306. if ( this.autoManager.OperationModeProperty != eOperatationMode.ManualMode )
  307. return;
  308. if ( obj.EventDir == ObstacleControlEventArgs.eEventDir.ToBack )
  309. {
  310. switch ( obj.ControlKind )
  311. {
  312. case ObstacleControlEventArgs.eControlKind.NONE:
  313. break;
  314. case ObstacleControlEventArgs.eControlKind.DRIVE:
  315. //this.ChgObstacleDetectPattern( new Random().Next( 0 , 40 ) );
  316. break;
  317. case ObstacleControlEventArgs.eControlKind.CURVE:
  318. //this.ChgObstacleDetectPattern( new Random().Next( 0 , 40 ) );
  319. break;
  320. case ObstacleControlEventArgs.eControlKind.STATE:
  321. //var value = this.GetObstacleDetectPattern();
  322. break;
  323. case ObstacleControlEventArgs.eControlKind.INFO:
  324. {
  325. var msg = new ObstacleControlEventArgs
  326. {
  327. ControlKind = ObstacleControlEventArgs.eControlKind.INFO,
  328. Drive = this.ObstacleDrive,
  329. Curve = this.ObstacleCurve,
  330. ObstacleState = this.ObstacleStateProperty.ToString()
  331. };
  332. this.ObstacleControlEventPublish( msg );
  333. }
  334. break;
  335. case ObstacleControlEventArgs.eControlKind.SAVE:
  336. {
  337. this.ObstacleCurve = obj.Curve;
  338. this.ObstacleDrive = obj.Drive;
  339. var reply = new ObstacleControlEventArgs
  340. {
  341. ControlKind = ObstacleControlEventArgs.eControlKind.SAVE
  342. };
  343. reply.Result = Results.Ok( ObstacleControlEventArgs.eControlKind.SAVE );
  344. this.ObstacleControlEventPublish( reply );
  345. }
  346. break;
  347. }
  348. }
  349. }
  350. private void ObstacleControlEventPublish( ObstacleControlEventArgs args )
  351. {
  352. args.EventDir = ObstacleControlEventArgs.eEventDir.ToFront;
  353. this.eventAggregator.GetEvent<ObstacleControlPubSubEvent>().Publish( args );
  354. }
  355. private void ReceiveDriveControlEvent( DriveControlEventArgs _args )
  356. {
  357. if ( this.autoManager.OperationModeProperty != eOperatationMode.ManualMode )
  358. return;
  359. var msg = _args;
  360. if ( msg.EventDir == DriveControlEventArgs.eEventDir.ToBack )
  361. {
  362. switch ( msg.ControlKind )
  363. {
  364. case DriveControlEventArgs.eControlKind.MOVE:
  365. this.ReqMoveToPos( _args );
  366. break;
  367. case DriveControlEventArgs.eControlKind.STOP:
  368. break;
  369. case DriveControlEventArgs.eControlKind.Steering:
  370. if ( msg.MoveDir == DriveControlEventArgs.eMoveDir.LEFT )
  371. this.steering.ControlSteering( true );
  372. else
  373. this.steering.ControlSteering();
  374. break;
  375. case DriveControlEventArgs.eControlKind.SteeringState:
  376. {
  377. var reply = new DriveControlEventArgs();
  378. reply.ControlKind = DriveControlEventArgs.eControlKind.SteeringState;
  379. if ( this.steering.IsLeft() )
  380. reply.Result = FluentResults.Results.Ok<DriveControlEventArgs.eMoveDir>( DriveControlEventArgs.eMoveDir.LEFT );
  381. else
  382. reply.Result = FluentResults.Results.Ok<DriveControlEventArgs.eMoveDir>( DriveControlEventArgs.eMoveDir.RIGHT );
  383. this.DriveControlEventPublish( reply );
  384. }
  385. break;
  386. case DriveControlEventArgs.eControlKind.ReqCurrentPos:
  387. //this.ReqCurrentPos();
  388. break;
  389. case DriveControlEventArgs.eControlKind.ReqStopCurrentPos:
  390. //this.taskCancel.Cancel();
  391. //this.taskCancel.WaitAll();
  392. break;
  393. case DriveControlEventArgs.eControlKind.FaultReset:
  394. this.ReqFaultReset( _args );
  395. break;
  396. case DriveControlEventArgs.eControlKind.DriveON:
  397. this.ReqDriveOn( _args );
  398. break;
  399. case DriveControlEventArgs.eControlKind.DriveOFF:
  400. this.ReqDriveOff( _args );
  401. break;
  402. case DriveControlEventArgs.eControlKind.JOG:
  403. this.ReqJog( _args );
  404. break;
  405. case DriveControlEventArgs.eControlKind.VehicleState:
  406. ReqVehicleState( _args );
  407. break;
  408. case DriveControlEventArgs.eControlKind.NONE:
  409. break;
  410. case DriveControlEventArgs.eControlKind.Conveyor:
  411. break;
  412. default:
  413. break;
  414. }
  415. }
  416. }
  417. public void ReqConveyorMove( string dir )
  418. {
  419. if ( dir.Equals( "CW" ) )
  420. this.conveyor.OnOffConveyor( true, false );
  421. else if ( dir.Equals( "CCW" ) )
  422. this.conveyor.OnOffConveyor( true, true );
  423. else if ( dir.Equals( "STOP" ) )
  424. this.conveyor.OnOffConveyor( false, false );
  425. }
  426. private void DriveControlEventPublish( DriveControlEventArgs args )
  427. {
  428. args.EventDir = DriveControlEventArgs.eEventDir.ToFront;
  429. this.eventAggregator.GetEvent<DriveControlPubSubEvent>().Publish( args );
  430. }
  431. public void Init()
  432. {
  433. this.CreateClamp();
  434. this.CreateSteering();
  435. this.CreateDrive();
  436. this.CreateBMUManager();
  437. this.CreateConveyor();
  438. ThreadStart();
  439. //TimerUtils.Once(5000, () => { this.CurrentPosition = 1000; });
  440. var v = sql.VehicleInfoDAL.GetInfo();
  441. v.CurrentTag = "0000";
  442. v.VehicleState = eVehicleState.None;
  443. v.MachineMode = eMachineMode.LocalMode;
  444. sql.VehicleInfoDAL.Update( v );
  445. }
  446. public int InitializationVehicle()
  447. {
  448. #if SIMULATION
  449. this.VehicleStateProperty = eVehicleState.Idle;
  450. return 0;
  451. #else
  452. int result = 0;
  453. if ( this.conveyor.IsDetectedCenter() ) //자제가 있으면 Lock
  454. result = this.clamp.Lock_Sync();
  455. else
  456. result = this.clamp.Unlock_Sync();
  457. if ( this.drive.IsErrorOn )
  458. return 22;
  459. this.VehicleStateProperty = eVehicleState.Idle;
  460. return result;
  461. #endif
  462. }
  463. public void Dispose()
  464. {
  465. this.cancel.Cancel();
  466. this.cancel.StopWaitAll();
  467. this.bMUManager.Disconnect();
  468. this.drive.Dispose();
  469. }
  470. #region Request Method
  471. private void ReqVehicleState( DriveControlEventArgs args )
  472. {
  473. VehicleInfo state = new VehicleInfo();
  474. state.CurrentPosition = this.CurrentPosition;
  475. state.CurrentSpeed = this.CurrentSpeed;
  476. state.CurrentTag = this.CurrentTag;
  477. state.CurrentTorque = this.CurrentTorque;
  478. state.Voltage = this.BatteryVoltage;
  479. state.Current = this.BatteryCurrent;
  480. state.BatteryState = this.BatteryState;
  481. state.ChargeTime = this.BatteryChargeTime;
  482. state.DisChargeTime = this.BatteryDisChargeTime;
  483. state.SOC = this.BatteryStateOfCharge;
  484. state.SOH = this.BatteryStateOfHealth;
  485. state.Capacity = this.BatteryCapacity;
  486. state.Energy = this.BatteryEnergy;
  487. state.Temperature = this.BatteryTemperature;
  488. state.BatteryIsConnect = this.BatteryIsConnect;
  489. var msg = new DriveControlEventArgs();
  490. msg.ControlKind = args.ControlKind;
  491. msg.Args = state;
  492. DriveControlEventPublish( msg );
  493. }
  494. private void ReqMoveToPos( DriveControlEventArgs args )
  495. {
  496. //var result = drive.Move( args.PositionTag );
  497. //this.MoveTo( "1111" );
  498. var reply = new DriveControlEventArgs();
  499. int targetTag = args.TargetRouteID;
  500. var route = sql.RouteDal.GetK( targetTag );
  501. if ( route == null )
  502. {
  503. reply.Result = Results.Fail( "Not Found Route" );
  504. this.DriveControlEventPublish( reply );
  505. return;
  506. }
  507. this.MoveTo( route.Name );
  508. reply.Result = Results.Ok( "Position Move" );
  509. this.DriveControlEventPublish( reply );
  510. }
  511. void ReqFaultReset( DriveControlEventArgs _args )
  512. {
  513. var drive = 0;
  514. //var result = drive.ResetAmpFault();
  515. var msg = new DriveControlEventArgs
  516. {
  517. ControlKind = DriveControlEventArgs.eControlKind.FaultReset
  518. };
  519. msg.Result = Results.Ok( "Drive On" );
  520. this.DriveControlEventPublish( msg );
  521. }
  522. void ReqJog( DriveControlEventArgs _args )
  523. {
  524. var drive = string.Empty;
  525. if ( _args.JogDir == DriveControlEventArgs.eJogMoveDir.Positive )
  526. drive = "POSITIVE";
  527. else
  528. drive = "NEGATIVE";
  529. }
  530. void ReqCurrentPos()
  531. {
  532. var task = Task.Factory.StartNew( () =>
  533. {
  534. while ( !this.taskCancel.Canceled )
  535. {
  536. LockUtils.Wait( 500 );
  537. var msg = new DriveControlEventArgs
  538. {
  539. EventDir = DriveControlEventArgs.eEventDir.ToFront,
  540. ControlKind = DriveControlEventArgs.eControlKind.ReqCurrentPos,
  541. CurrentPosition = new Random().Next( 0, 1000 ),
  542. };
  543. this.DriveControlEventPublish( msg );
  544. }
  545. } );
  546. this.taskCancel.Add( task );
  547. }
  548. void ReqDriveOn( DriveControlEventArgs _args )
  549. {
  550. var drive = "Drive Name";
  551. //drive.On();
  552. var msg = new DriveControlEventArgs
  553. {
  554. ControlKind = DriveControlEventArgs.eControlKind.DriveON
  555. };
  556. msg.Result = Results.Ok( "Drive On" );
  557. this.DriveControlEventPublish( msg );
  558. }
  559. void ReqDriveOff( DriveControlEventArgs _args )
  560. {
  561. var drive = "Drive Name";
  562. //drive.Off();
  563. var msg = new DriveControlEventArgs
  564. {
  565. ControlKind = DriveControlEventArgs.eControlKind.DriveOFF
  566. };
  567. msg.Result = Results.Ok( "Drive On" );
  568. this.DriveControlEventPublish( msg );
  569. }
  570. #endregion
  571. #region Thread
  572. void ThreadStart()
  573. {
  574. this.cancel.AddGo( new Action( this._ThSubCmdWorker ) );
  575. this.cancel.AddGo( new Action( this._ThVehicleStateCheck ) );
  576. }
  577. //장애물 감지 Thread
  578. //장애물 감지 패턴 변경도 여기 하자.
  579. private void _ThVehicleStateCheck()
  580. {
  581. while ( !this.cancel.Canceled )
  582. {
  583. try
  584. {
  585. if ( this.autoManager.OperationModeProperty == eOperatationMode.AutoMode )
  586. this.CheckObstacle();
  587. this.CheckIOState();
  588. }
  589. catch ( ThreadInterruptedException threadInterruptedException )
  590. {
  591. }
  592. catch ( Exception exception )
  593. {
  594. logger.E( exception );
  595. }
  596. finally
  597. {
  598. LockUtils.Wait( 5 );
  599. }
  600. }
  601. logger.D( "Vehicle - _ThObstacleChecker Dispose" );
  602. }
  603. /// <summary>
  604. /// Scheduler 가 주는 Sub Command 를 이용하여 동작하자.
  605. /// </summary>
  606. public void _ThSubCmdWorker()
  607. {
  608. while ( !this.cancel.Canceled )
  609. {
  610. try
  611. {
  612. if ( this.ObstacleStateProperty != eObstacleState.Normal ) //장애물 감지 상태 시 조그 동작만 가능하게.
  613. continue;
  614. if ( this.autoManager.AutoModeStateProperty != eAutoModeState.Run ) //
  615. continue;
  616. var subCmd = sql.SubCmdDAL.GetSubCmd();
  617. if ( subCmd == null ) continue;
  618. if ( !sql.CommandDAL.All.Any( x => x.CommandID.Equals( subCmd.CmdID ) ) )
  619. {
  620. if ( subCmd.CmdType == SubCmd.eCmdType.Auto ) //자동 명령중 Main Command 가 없으면 삭제.
  621. {
  622. sql.SubCmdDAL.Delete( subCmd );
  623. logger.I( $"SubCmd Deleted - ID={subCmd.ID}, CommandID={subCmd.CmdID}" );
  624. }
  625. }
  626. switch ( subCmd.Type )
  627. {
  628. case eSubCommandType.Move:
  629. this.CurrentSubCommand = subCmd;
  630. this.Move( subCmd );
  631. break;
  632. case eSubCommandType.Load:
  633. this.CurrentSubCommand = subCmd;
  634. this.LoadCarrier( subCmd );
  635. break;
  636. case eSubCommandType.Unload:
  637. this.CurrentSubCommand = subCmd;
  638. this.UnloadCarrier( subCmd );
  639. break;
  640. case eSubCommandType.Charge:
  641. this.CurrentSubCommand = subCmd;
  642. this.BatteryCharge( subCmd );
  643. break;
  644. default:
  645. break;
  646. }
  647. }
  648. catch ( ThreadInterruptedException threadInterruptedException )
  649. {
  650. }
  651. catch ( Exception exception )
  652. {
  653. logger.E( exception );
  654. }
  655. finally
  656. {
  657. LockUtils.Wait( 500 );
  658. }
  659. }
  660. logger.D( "Vehicle - _ThSubCmdWorker Dispose" );
  661. }
  662. #endregion
  663. #region Control Action Method
  664. public void EStop()
  665. {
  666. this.conveyor.OnOffConveyor( false );
  667. //Clamp EStop
  668. this.clamp.ClampEStop();
  669. this.drive.EStop();
  670. this.OccurVehicleAlarm( 23 );
  671. }
  672. #region For Moving
  673. void Move( SubCmd sub )
  674. {
  675. if ( this.MoveTo( sub.TargetID ) )
  676. {
  677. }
  678. sql.SubCmdDAL.Delete( sub );
  679. }
  680. bool MoveTo( string pointID )
  681. {
  682. //this.BuzzerOnOff(true, eBuzzerKind.StartWarn);
  683. ////TimerUtils.Once(3000, BuzzerOnOff, false, eBuzzerKind.StartWarn );
  684. //Thread.Sleep(3000);
  685. //this.BuzzerOnOff(false);
  686. if ( this.VehicleStateProperty == eVehicleState.Idle )
  687. {
  688. this.OnMoveReady?.Invoke();
  689. var moveReadyBuzzerTime = sql.ConfigDal.GetValueToInt( ConstString.BuzzerStartReadyTime );
  690. Thread.Sleep( moveReadyBuzzerTime );
  691. this.VehicleStateProperty = eVehicleState.Move;
  692. }
  693. this.OnMoving?.Invoke();
  694. this.IsMoving = true;
  695. //이전에 있던 작업들 종료 및 삭제
  696. this.taskMoveCancel.Cancel();
  697. this.taskMoveCancel.WaitAll();
  698. this.taskMoveCancel.Add( CheckCrossPoint() );
  699. //this.BuzzerOnOff(true, eBuzzerKind.Moving);
  700. this.drive.MoveToPoint( pointID, 100 );
  701. bool result = Wait4MoveDone();
  702. //this.BuzzerOnOff(false);
  703. this.taskMoveCancel.Cancel();
  704. this.taskMoveCancel.WaitAll();
  705. if ( drive.IsStop )
  706. {
  707. this.IsMoving = false;
  708. this.OnMoveFinish?.Invoke();
  709. this.VehicleStateProperty = eVehicleState.Idle;
  710. }
  711. //PhysicalCheckupLogger.Instance.UploadPhysicalCheckupLog();
  712. return result;
  713. }
  714. bool Wait4MoveDone()
  715. {
  716. int waitTime = 9000; //설정 할 수있게.
  717. long st = SwUtils.CurrentTimeMillis;
  718. //Todo: 이동시 확인 사항들.
  719. while ( true )
  720. {
  721. Thread.Sleep( 5 );
  722. if ( SwUtils.Gt( st, waitTime ) )
  723. {
  724. //Todo: 이동시간 초과 시 동작들.
  725. break;
  726. }
  727. //Todo: 이동중 명령이 삭제 되면 처리 할일들.
  728. //이동중 메인 명력이 없어진다면 정지 후
  729. if ( !sql.CommandDAL.HasK( this.CurrentSubCommand.CmdID ) )
  730. {
  731. logger.D( "[Wait Move Done] - 메인 명령 사라짐" );
  732. var cmd = sql.CommandDAL.GetCmd();
  733. if ( cmd == null )
  734. {
  735. logger.D( "[Wait Move Done] - Main Command not Exist Motion Stop" );
  736. drive.Stop();
  737. return true;
  738. }
  739. else
  740. {
  741. logger.D( "[Wait Move Done] - Main Command not Exist Motion command 없음" );
  742. return true;
  743. }
  744. }
  745. PhysicalCheckupLogger.Instance.DriveStateLog( this.drive.CurrentSpeed.ToString(), this.drive.CurrentTorque.ToString() );
  746. //20.04.04 Kang Drive 측으로 상태만 알려주면 알아서 처리함.
  747. //if ( this.ObstacleStateProperty != eObstacleState.Normal )
  748. //{
  749. // if ( this.ObstacleStateProperty == eObstacleState.Blocked )
  750. // this.VehicleStateProperty = eVehicleState.Blocked;
  751. // if ( this.ObstacleStateProperty == eObstacleState.Abnormal )
  752. // {
  753. // this.VehicleStateProperty = eVehicleState.Abnormal;
  754. // this.OccurVehicleAlarm( 24 );
  755. // return false;
  756. // }
  757. //}
  758. }
  759. return true;
  760. }
  761. Task CheckCrossPoint()
  762. {
  763. var task = Task.Run( () =>
  764. {
  765. long sTime = SwUtils.CurrentTimeMillis;
  766. while ( !this.taskMoveCancel.Canceled )
  767. {
  768. Thread.Sleep( 10 );
  769. //ToDo: approach Cross Point Check
  770. //ToDo: Obstacle Laser Sensor Pattern Change Method 구현 필요.
  771. }
  772. } );
  773. return task;
  774. }
  775. #endregion
  776. public bool LoadCarrier( SubCmd sub )
  777. {
  778. this.VehicleStateProperty = eVehicleState.Load;
  779. var route = sql.RouteDal.GetRoute( sub.TargetID );
  780. if ( !CorrectPosition( route, this.CurrentPosition ) )
  781. {
  782. this.OccurVehicleAlarm( 20 );
  783. return false; //Alarm
  784. }
  785. int result = this.clamp.Unlock_Sync();
  786. if ( result != 0 )
  787. {
  788. this.OccurVehicleAlarm( result );
  789. return false;
  790. }
  791. this.iO.OutputOn( "OUT_PIO_SENSOR_ONOFF" );
  792. result = this.PIOAndLoad( sub.TargetID );
  793. if ( result != 0 )
  794. {
  795. this.iO.OutputOff( "OUT_PIO_SENSOR_ONOFF" );
  796. this.OccurVehicleAlarm( result );
  797. return false;
  798. }
  799. this.iO.OutputOff( "OUT_PIO_SENSOR_ONOFF" );
  800. result = this.clamp.Lock_Sync();
  801. if ( result != 0 )
  802. {
  803. this.OccurVehicleAlarm( result );
  804. return false;
  805. }
  806. //Load, Unload 가 끝나면 메인 Command 를 완료 했다고 판단.
  807. sql.CommandDAL.UpdateState( sub.CmdID, eCommandState.Complete );
  808. sql.SubCmdDAL.Delete( sub );
  809. this.VehicleStateProperty = eVehicleState.Idle;
  810. return true;
  811. }
  812. public bool UnloadCarrier( SubCmd sub )
  813. {
  814. this.VehicleStateProperty = eVehicleState.Unload;
  815. var route = sql.RouteDal.GetRoute( sub.TargetID );
  816. if ( !CorrectPosition( route, this.CurrentPosition ) )
  817. {
  818. this.OccurVehicleAlarm( 21 );
  819. return false; //Alarm
  820. }
  821. int result = this.clamp.Unlock_Sync();
  822. if ( result != 0 )
  823. {
  824. this.OccurVehicleAlarm( result );
  825. return false;
  826. }
  827. this.iO.OutputOn( "OUT_PIO_SENSOR_ONOFF" );
  828. result = this.PIOAndUnload( sub.TargetID );
  829. if ( result != 0 )
  830. {
  831. this.iO.OutputOff( "OUT_PIO_SENSOR_ONOFF" );
  832. this.OccurVehicleAlarm( result );
  833. return false;
  834. }
  835. this.iO.OutputOff( "OUT_PIO_SENSOR_ONOFF" );
  836. sql.CommandDAL.UpdateState( sub.CmdID, eCommandState.Complete );
  837. sql.SubCmdDAL.Delete( sub );
  838. this.VehicleStateProperty = eVehicleState.Idle;
  839. return true;
  840. }
  841. private void BatteryCharge( SubCmd subCmd )
  842. {
  843. this.VehicleStateProperty = eVehicleState.Charge;
  844. this.iO.OutputOn( "OUT_PIO_SENSOR_ONOFF" );
  845. this.PIOBatteryCharge( subCmd );
  846. this.iO.OutputOff( "OUT_PIO_SENSOR_ONOFF" );
  847. sql.CommandDAL.UpdateState( subCmd.CmdID, eCommandState.Complete );
  848. sql.SubCmdDAL.Delete( subCmd );
  849. this.VehicleStateProperty = eVehicleState.Idle;
  850. }
  851. /// <summary>
  852. /// Battery Charge
  853. /// 충전 시 PIO 를 해야 함.
  854. /// </summary>
  855. /// <param name="sub"></param>
  856. /// <returns></returns>
  857. public int PIOBatteryCharge( SubCmd sub )
  858. {
  859. var route = sql.RouteDal.GetRoute( sub.TargetID );
  860. if ( !CorrectPosition( route, this.CurrentPosition ) )
  861. {
  862. this.OccurVehicleAlarm( 21 );
  863. return 0; //Alarm
  864. }
  865. var pioTimeout = sql.ConfigDal.GetValueToInt( ConstString.PIOTimeOut );
  866. PIOClear();
  867. loggerPIO.I( $"Start Charge PIO - [{sub.TargetID}]" );
  868. if ( !this.iO.IsOn( "IN_PIO_READY" ) )
  869. {
  870. loggerPIO.E( "[Port] - 1 Ready not On" );
  871. this.iO.OutputOff( "OUT_PIO_SENSOR_ONOFF" );
  872. this.OccurVehicleAlarm( 25 );
  873. return 0;
  874. }
  875. this.iO.WriteOutputIO( "OUT_PIO_READY", true );
  876. loggerPIO.I( "[Vehicle] - 1 Ready On" );
  877. if ( !this.iO.WaitChangeInputIO( true, pioTimeout, "IN_PIO_RECEIVE_RUN" ) )
  878. {
  879. PIOClear();
  880. loggerPIO.E( "[Port] - 2 Receive CV Run Timeout" );
  881. this.OccurVehicleAlarm( 26 );
  882. return 0;
  883. }
  884. this.iO.WriteOutputIO( "OUT_PIO_SENDING_RUN", true );
  885. loggerPIO.I( "[Vehicle] - 2 Send Run On" );
  886. var sTime = SwUtils.CurrentTimeMillis;
  887. while ( true )
  888. {
  889. Thread.Sleep( 5 );
  890. if ( !this.iO.IsOn( "IN_PIO_READY" ) || this.iO.IsOn( "IN_PIO_RECEIVE_RUN" ) )
  891. break;
  892. if ( !sql.CommandDAL.HasK( this.CurrentSubCommand.CmdID ) )
  893. {
  894. PIOClear();
  895. logger.D( "[Wait Charging] - 메인 명령 사라짐" );
  896. break;
  897. }
  898. }
  899. if ( !this.iO.WaitChangeInputIO( true, pioTimeout, "IN_PIO_RECEIVE_COMPLITE" ) )
  900. {
  901. PIOClear();
  902. loggerPIO.E( "[Port] - 3 Receive Complete Timeout" );
  903. this.OccurVehicleAlarm( 26 );
  904. return 0;
  905. }
  906. PIOClear();
  907. this.iO.WriteOutputIO( "OUT_PIO_SEND_COMPLITE", true );
  908. Thread.Sleep( 1000 );
  909. this.iO.WriteOutputIO( "OUT_PIO_SEND_COMPLITE", false );
  910. return 0;
  911. }
  912. #endregion
  913. #region Check Method
  914. bool CheckObstacle()
  915. {
  916. //if ( this.iO.IsOn( "IN_OBSTRUCTION_DETECT_SAFETY" ) || this.iO.IsOn( "IN_OBSTRUCTION_DETECT_ERROR" ) )
  917. //{
  918. // this.ObstacleStateProperty = eObstacleState.Abnormal;
  919. // this.motion.SetObstacleState( this.ObstacleStateProperty );
  920. // return true;
  921. //}
  922. //if ( this.iO.IsOn( "IN_OBSTRUCTION_DETECT_STOP" ) )
  923. //{
  924. // this.ObstacleStateProperty = eObstacleState.Blocked;
  925. // this.motion.SetObstacleState( this.ObstacleStateProperty );
  926. // return true;
  927. //}
  928. //if ( this.iO.IsOn( "IN_OBSTRUCTION_DETECT_SLOW" ) )
  929. //{
  930. // this.ObstacleStateProperty = eObstacleState.Decelerate;
  931. // this.motion.SetObstacleState( this.ObstacleStateProperty );
  932. // return true;
  933. //}
  934. this.ObstacleStateProperty = eObstacleState.Normal;
  935. this.drive.SetObstacleState( this.ObstacleStateProperty );
  936. return false;
  937. }
  938. void CheckIOState()
  939. {
  940. //이미 알람이면 체크 안함.
  941. if ( this.VehicleStateProperty == eVehicleState.Abnormal ) return;
  942. if ( !this.iO.IsConnectError ) return;
  943. if ( this.iO.IsOn( "IN_EMS_SW" ) ) this.OccurVehicleAlarm( 28 );
  944. if ( !this.iO.IsOn( "IN_CP_ON_SAFETY" ) ) this.OccurVehicleAlarm( 31 );
  945. if ( !this.iO.IsOn( "IN_CP_ON_24V" ) ) this.OccurVehicleAlarm( 30 );
  946. if ( !this.iO.IsOn( "IN_MC_ON" ) ) this.OccurVehicleAlarm( 29 );
  947. }
  948. #endregion
  949. #region Mechanical Method
  950. #region Conveyor
  951. public int ConveyorLoad() => this.conveyor.ConveyorLoad();
  952. public int ConveyorUnload() => this.conveyor.ConveyorUnload();
  953. public int PIOAndLoad( string targetName )
  954. {
  955. #if SIMULATION
  956. PIOClear();
  957. loggerPIO.I( $"Start Load PIO - [{targetName}]" );
  958. this.OnPIOStart?.Invoke( true );
  959. this.iO.WriteOutputIO( "OUT_PIO_RECEIVE_RUN", true );
  960. loggerPIO.I( "[Vehicle] - 4 Receive Run On" );
  961. Thread.Sleep( 1000 );//상대 IO 기다린다 생각.
  962. loggerPIO.E( "[Port] - 4 Ready On" );
  963. //Conveyor Start
  964. loggerPIO.I( "[Vehicle] - Conveyor Run" );
  965. this.OnConveyorStart?.Invoke( true );
  966. Thread.Sleep( 10000 );//Conveyor 구동
  967. this.OnCarrierDetected?.Invoke( true );
  968. PIOClear();
  969. Thread.Sleep( 1000 );
  970. this.OnConveyorStop?.Invoke( true );
  971. Thread.Sleep( 1000 );
  972. this.OnLoadComplete?.Invoke();
  973. #else
  974. var pioTimeout = sql.ConfigDal.GetValueToInt( ConstString.PIOTimeOut );
  975. if ( this.conveyor.IsInverterError() )
  976. return 16;
  977. if ( !this.conveyor.IsLifterPositinCheck() )
  978. return 14;
  979. //Todo: Sensor Setting 이 후 주석 풀기.
  980. //if ( !this.IsLifterDuplication() )
  981. //{
  982. // this.OnFailReport?.Invoke( eFailCode.Load_PortHasNotCarrier );
  983. // return 0;
  984. //}
  985. if ( this.conveyor.IsDetectedCenter() )
  986. {
  987. this.OnFailReport?.Invoke( eFailCode.Load_VehicleHasCarrier );
  988. return 0;
  989. }
  990. PIOClear();
  991. loggerPIO.I( $"Start Load PIO - [{targetName}]" );
  992. this.OnPIOStart?.Invoke( true );
  993. this.iO.WriteOutputIO( "OUT_PIO_RECEIVABLE", true );
  994. loggerPIO.I( "[Vehicle] - 4 Receivable" );
  995. if ( !this.iO.WaitChangeInputIO( true, pioTimeout, "IN_PIO_SENDABLE" ) )
  996. {
  997. PIOClear();
  998. loggerPIO.E( "[Port] - 4 Ready Time Out" );
  999. this.OnFailReport?.Invoke( eFailCode.LoadPIOInterlockTimeout );
  1000. return 0;
  1001. }
  1002. loggerPIO.E( "[Port] - 4 Ready On" );
  1003. this.conveyor.SetConveyorSpeed( true );
  1004. this.conveyor.OnOffConveyor( true, true );
  1005. this.iO.WriteOutputIO( "OUT_PIO_RECEIVE_RUN", true, 1000 ); //1Sec 이후 On
  1006. loggerPIO.I( "[Vehicle] - Conveyor Run" );
  1007. this.OnConveyorStart?.Invoke( true );
  1008. if ( !this.iO.WaitChangeInputIO( true, pioTimeout, "IN_PIO_SEND_RUN" ) )
  1009. {
  1010. this.conveyor.OnOffConveyor( false, true );
  1011. PIOClear();
  1012. loggerPIO.E( "[Port] - 5 Sending Run Time Out" );
  1013. this.OnFailReport?.Invoke( eFailCode.LoadPIOInterlockTimeout );
  1014. return 0;
  1015. }
  1016. loggerPIO.I( "[Port] - 5 Sending Run On" );
  1017. bool isStartDetected = false;
  1018. var sTime = SwUtils.CurrentTimeMillis;
  1019. while ( true )
  1020. {
  1021. LockUtils.Wait( 10 );
  1022. if ( SwUtils.Gt( sTime, 20 * ConstUtils.ONE_SECOND ) )
  1023. {
  1024. PIOClear();
  1025. this.conveyor.OnOffConveyor( false, true );
  1026. loggerPIO.E( "[Vehicle] Conveyor Wait Time Out" );
  1027. this.OnFailReport?.Invoke( eFailCode.LoadPIOInterlockTimeout );
  1028. if ( this.conveyor.IsDetectedLoadStart() ) // 감지가 시작 되었으면 이동중 Error 로 판단 설비를 정지 상태로
  1029. return 10; //Conveyor Moving Timeout
  1030. else
  1031. return 0;
  1032. }
  1033. if ( this.conveyor.IsDetectedLoadStart() && !isStartDetected )
  1034. isStartDetected = true;
  1035. if ( !this.conveyor.IsDetectedLoadStart() && isStartDetected )
  1036. this.conveyor.SetConveyorSpeed( false );
  1037. if ( this.conveyor.IsDetectedLoadStop() ) break;
  1038. if ( this.conveyor.IsPIOInterLockOn() )
  1039. {
  1040. PIOClear();
  1041. this.conveyor.OnOffConveyor( false ); //Stop
  1042. loggerPIO.E( "[Port] PIO InterLock On " );
  1043. return 19; //
  1044. }
  1045. }
  1046. if ( this.conveyor.IsDetectedCenter() )
  1047. this.OnCarrierDetected?.Invoke( true );
  1048. this.conveyor.OnOffConveyor( false ); //Stop
  1049. PIOClear();
  1050. this.OnConveyorStop?.Invoke( true );
  1051. loggerPIO.I( "[Vehicle] Conveyor Stop" );
  1052. this.iO.WriteOutputIO( "OUT_PIO_RECIVE_COMPLITE", true );
  1053. loggerPIO.I( "[Vehicle] Receive Complete On" );
  1054. if ( !this.iO.WaitChangeInputIO( true, pioTimeout, "IN_PIO_SEND_COMPLITE" ) )
  1055. {
  1056. this.iO.WriteOutputIO( "OUT_PIO_RECIVE_COMPLITE", false );
  1057. loggerPIO.E( "[Port] IN_PIO_SEND_COMPLITE On Time Out" );
  1058. }
  1059. loggerPIO.I( "[Port] Send Complete On" );
  1060. this.iO.WriteOutputIO( "OUT_PIO_RECIVE_COMPLITE", false, 1000 );
  1061. this.OnLoadComplete?.Invoke();
  1062. loggerPIO.I( $"End Load PIO - [{targetName}]" );
  1063. #endif
  1064. return 0;
  1065. }
  1066. public int PIOAndUnload( string targetName )
  1067. {
  1068. #if SIMULATION
  1069. PIOClear();
  1070. loggerPIO.I( $"Start Unload PIO - [{targetName}]" );
  1071. this.OnPIOStart?.Invoke( false );
  1072. Thread.Sleep( 1000 );
  1073. this.iO.WriteOutputIO( "OUT_PIO_READY", true );
  1074. loggerPIO.I( "[Vehicle] - 1 Ready On" );
  1075. Thread.Sleep( 1000 );
  1076. this.OnConveyorStart?.Invoke( false );
  1077. Thread.Sleep( 10000 );
  1078. this.OnOffConveyor( false ); //Stop
  1079. this.OnConveyorStop?.Invoke( false );
  1080. PIOClear();
  1081. Thread.Sleep( 1000 );
  1082. this.OnUnloadComplete?.Invoke();
  1083. #else
  1084. var pioTimeout = sql.ConfigDal.GetValueToInt( ConstString.PIOTimeOut );
  1085. if ( this.conveyor.IsInverterError() )
  1086. return 16;
  1087. if ( this.conveyor.IsLifterDuplication() )
  1088. {
  1089. this.OnFailReport?.Invoke( eFailCode.Unload_PortHasCarrier );
  1090. return 0;
  1091. }
  1092. if ( !this.conveyor.IsDetectedCenter() )
  1093. {
  1094. this.OnFailReport?.Invoke( eFailCode.Unload_VehicleHasNotCarrier );
  1095. return 0;
  1096. }
  1097. if ( !this.conveyor.IsLifterPositinCheck() )
  1098. return 13;
  1099. PIOClear();
  1100. loggerPIO.I( $"Start Unload PIO - [{targetName}]" );
  1101. this.OnPIOStart?.Invoke( false );
  1102. if ( !this.iO.IsOn( "IN_PIO_READY" ) )
  1103. {
  1104. loggerPIO.E( "[Port] - 1 Ready not On" );
  1105. this.OnFailReport?.Invoke( eFailCode.UnlaodPIOInterlockTimeout );
  1106. return 0;
  1107. }
  1108. this.iO.WriteOutputIO( "OUT_PIO_READY", true );
  1109. loggerPIO.I( "[Vehicle] - 1 Ready On" );
  1110. if ( !this.iO.WaitChangeInputIO( true, pioTimeout, "IN_PIO_RECEIVE_RUN" ) )
  1111. {
  1112. PIOClear();
  1113. loggerPIO.E( "[Port] - 2 Receive CV Run Timeout" );
  1114. this.OnFailReport?.Invoke( eFailCode.UnlaodPIOInterlockTimeout );
  1115. return 0;
  1116. }
  1117. loggerPIO.E( "[Port] - 2 Receive CV Run On" );
  1118. this.iO.WriteOutputIO( "OUT_PIO_SENDING_RUN", true );
  1119. loggerPIO.I( "[Vehicle] - 2 Send Run On" );
  1120. this.conveyor.SetConveyorSpeed( true );
  1121. this.conveyor.OnOffConveyor( true );
  1122. this.OnConveyorStart?.Invoke( false );
  1123. var sTime = SwUtils.CurrentTimeMillis;
  1124. while ( true )
  1125. {
  1126. if ( SwUtils.Gt( sTime, 20 * ConstUtils.ONE_SECOND ) )
  1127. {
  1128. PIOClear();
  1129. this.conveyor.OnOffConveyor( false, true );
  1130. loggerPIO.E( "[Port] Conveyor Wait Time Out" );
  1131. this.OnFailReport?.Invoke( eFailCode.UnlaodPIOInterlockTimeout );
  1132. if ( this.conveyor.IsDetectedLoadStart() || this.conveyor.IsDetectedCenter() ) //중간에 걸려 있다고 생각해서 알람 처리.
  1133. return 12; //Conveyor Moving Timeout
  1134. else
  1135. return 0;
  1136. }
  1137. if ( !this.conveyor.IsDetectedLoadStart() && !this.conveyor.IsDetectedCenter() )
  1138. {
  1139. if ( this.iO.IsOn( "IN_PIO_RECEIVE_COMPLITE" ) )
  1140. {
  1141. loggerPIO.I( "[Port] - 3 Receive Complete On" );
  1142. break;
  1143. }
  1144. }
  1145. }
  1146. if ( !this.conveyor.IsDetectedCenter() )
  1147. this.OnCarrierDetected?.Invoke( false );
  1148. this.conveyor.OnOffConveyor( false ); //Stop
  1149. this.OnConveyorStop?.Invoke( false );
  1150. PIOClear();
  1151. this.iO.WriteOutputIO( "OUT_PIO_SEND_COMPLITE", true );
  1152. Thread.Sleep( 1000 );
  1153. this.iO.WriteOutputIO( "OUT_PIO_SEND_COMPLITE", false );
  1154. loggerPIO.I( "[Vehicle] - 3 Send Complete OnOff" );
  1155. this.OnUnloadComplete?.Invoke();
  1156. #endif
  1157. loggerPIO.I( $"End Unload PIO - [{targetName}]" );
  1158. return 0;
  1159. }
  1160. void PIOClear()
  1161. {
  1162. string[] pio = { "OUT_PIO_READY", "OUT_PIO_SENDING_RUN", "OUT_PIO_SEND_COMPLITE", "OUT_PIO_RECEIVABLE", "OUT_PIO_RECEIVE_RUN", "OUT_PIO_RECIVE_COMPLITE", "OUT_PIO_INTERLOCK" };
  1163. pio.FwEach( x => { this.iO.OutputOff( x ); } );
  1164. }
  1165. #endregion
  1166. #endregion
  1167. #region Hardware Create Method
  1168. void CreateSteering()
  1169. {
  1170. this.steering = new Steering( this.iO, this.sql, this.eventAggregator );
  1171. this.steering.OnSteeringError += Steering_OnSteeringError;
  1172. this.steering.PropertyChanged += Steering_PropertyChanged;
  1173. }
  1174. void CreateClamp()
  1175. {
  1176. this.clamp = new Clamp( this.sql, this.eventAggregator );
  1177. this.clamp.Init();
  1178. this.clamp.PropertyChanged += Clamp_PropertyChanged;
  1179. }
  1180. void CreateDrive()
  1181. {
  1182. this.drive = new GSIDrive( this.sql );
  1183. this.drive.PropertyChanged += Motion_PropertyChanged;
  1184. this.drive.Init();
  1185. }
  1186. void CreateConveyor()
  1187. {
  1188. this.conveyor = new Conveyor( this.iO );
  1189. }
  1190. void CreateBMUManager()
  1191. {
  1192. this.bMUManager = new BMUManager();
  1193. this.bMUManager.BMUConfig = new Serial.BatteryTabos.Config() { ID = "0" };
  1194. this.bMUManager.OnConnect += BMUManager_OnConnect;
  1195. this.bMUManager.OnDisconnect += BMUManager_OnDisconnect;
  1196. this.bMUManager.OnChangedReceivedData += BMUManager_OnChangedReceivedData;
  1197. this.bMUManager.OnFirstColtd += BMUManager_OnFirstColtd;
  1198. var setV = sql.ConfigDal.GetValueToInt( ConstString.BatteryCanType );
  1199. var canType = CastTo<BMUManager.eCANSelect>.From<int>( setV );
  1200. this.bMUManager.Connect( canType );
  1201. }
  1202. private void BMUManager_OnDisconnect( string obj, bool state )
  1203. {
  1204. this.BatteryIsConnect = state;
  1205. this.OccurVehicleAlarm( 32 );
  1206. }
  1207. private void BMUManager_OnConnect( string obj, bool state )
  1208. {
  1209. this.BatteryIsConnect = state;
  1210. }
  1211. private void BMUManager_OnFirstColtd( List<ReceivedData> obj )
  1212. {
  1213. }
  1214. private void BMUManager_OnChangedReceivedData( Serial.DataModel.ReceivedData obj )
  1215. {
  1216. var kind = CastTo<eDataKind>.From<Enum>( obj.DataKind );
  1217. switch ( kind )
  1218. {
  1219. case eDataKind.Voltage:
  1220. this.BatteryVoltage = (double)obj.Value * obj.Scale;
  1221. break;
  1222. case eDataKind.Current:
  1223. this.BatteryCurrent = (double)obj.Value * obj.Scale;
  1224. break;
  1225. case eDataKind.BatteryState:
  1226. if ( obj.Value == null )
  1227. return;
  1228. this.BatteryState = (double)obj.Value;
  1229. break;
  1230. case eDataKind.ChargeCompleteTime:
  1231. if ( obj.Value == null || obj.Value <= 0 )
  1232. return;
  1233. this.BatteryChargeTime = (double)obj.Value / obj.Scale;
  1234. break;
  1235. case eDataKind.DisChargeCompleteTime:
  1236. if ( obj.Value == null || obj.Value <= 0 )
  1237. return;
  1238. this.BatteryDisChargeTime = (double)obj.Value / obj.Scale;
  1239. break;
  1240. case eDataKind.SOC:
  1241. this.BatteryStateOfCharge = (double)obj.Value * obj.Scale;
  1242. break;
  1243. case eDataKind.SOH:
  1244. this.BatteryStateOfHealth = (double)obj.Value * obj.Scale;
  1245. break;
  1246. case eDataKind.ResidualCapacity:
  1247. this.BatteryCapacity = (double)obj.Value * obj.Scale;
  1248. break;
  1249. case eDataKind.ResidualEnergy:
  1250. this.BatteryEnergy = (double)obj.Value * obj.Scale;
  1251. break;
  1252. case eDataKind.Temperature:
  1253. this.BatteryTemperature = (double)obj.Value * obj.Scale;
  1254. break;
  1255. default:
  1256. break;
  1257. }
  1258. }
  1259. #endregion
  1260. #region Help Method
  1261. /// <summary>
  1262. /// 현재 좌표 값이 등록된 Route 에 맞는 위치인지 확인한다.
  1263. /// 판단 기준은 Route 에 Tolerance 범위를 사용.
  1264. /// </summary>
  1265. /// <param name="route"></param>
  1266. /// <param name="currentPosition"></param>
  1267. /// <returns></returns>
  1268. bool CorrectPosition( Route route, double currentPosition )
  1269. {
  1270. var rScale = route.ScaleValue;
  1271. var rTolerance = route.ScaleTolerance;
  1272. var result = currentPosition - rScale;
  1273. if ( rTolerance < Math.Abs( result ) )
  1274. return false;
  1275. return true;
  1276. }
  1277. /// <summary>
  1278. /// if no is zero, Laser Off
  1279. /// bit Off, On, On, On,On Area1
  1280. /// </summary>
  1281. /// <param name="no"> 0 == Off Laser</param>
  1282. /// <returns></returns>
  1283. public bool ChgObstacleDetectPattern( int no )
  1284. {
  1285. var bitArray = BitUtils.ChgBitArray( no );
  1286. int bitIndex = 0;
  1287. this.obstacleBitList.ForEach( b =>
  1288. {
  1289. if ( bitArray[bitIndex] )
  1290. this.iO.OutputOff( b );
  1291. else
  1292. this.iO.OutputOn( b );
  1293. bitIndex++;
  1294. } );
  1295. ObstaclePattern = no;
  1296. return true;
  1297. }
  1298. public int GetObstacleDetectPattern()
  1299. {
  1300. int bitIndex = 0;
  1301. BitArray bitArray = new BitArray( this.obstacleBitList.Count );
  1302. this.obstacleBitList.ForEach( b =>
  1303. {
  1304. if ( this.iO.IsOn( b, false ) )
  1305. bitArray.Set( bitIndex, false );
  1306. else
  1307. bitArray.Set( bitIndex, true );
  1308. bitIndex++;
  1309. } );
  1310. return BitUtils.ChgInt32( bitArray );
  1311. }
  1312. void OccurVehicleAlarm( int alarmID )
  1313. {
  1314. this.MachineMode = eMachineMode.LocalMode;
  1315. this.VehicleStateProperty = eVehicleState.Abnormal;
  1316. this.autoManager.ProcessAlarm( alarmID );
  1317. }
  1318. public void SetObstaclePattern( ObstacleControlEventArgs.eControlKind state, int value )
  1319. {
  1320. if ( state == ObstacleControlEventArgs.eControlKind.DRIVE )
  1321. {
  1322. this.ObstacleDrive = value;
  1323. ChgObstacleDetectPattern( this.ObstacleDrive );
  1324. }
  1325. else if ( state == ObstacleControlEventArgs.eControlKind.CURVE )
  1326. {
  1327. this.ObstacleCurve = value;
  1328. ChgObstacleDetectPattern( this.ObstacleCurve );
  1329. }
  1330. else
  1331. return;
  1332. }
  1333. #endregion
  1334. #region Event Subscribe
  1335. private void Motion_PropertyChanged( object sender, System.ComponentModel.PropertyChangedEventArgs e )
  1336. {
  1337. var property = sender.GetType().GetProperty( e.PropertyName );
  1338. var newValue = property.GetValue( sender, null );
  1339. if ( e.PropertyName.Equals( "CurrentPos" ) )
  1340. {
  1341. var v = CastTo<double>.From<object>( newValue );
  1342. this.CurrentPosition = v;
  1343. }
  1344. if ( e.PropertyName.Equals( "CurrentTag" ) )
  1345. {
  1346. var v = CastTo<string>.From<object>( newValue );
  1347. this.CurrentTag = v;
  1348. }
  1349. if ( e.PropertyName.Equals( "CurrentSpeed" ) )
  1350. {
  1351. var v = CastTo<double>.From<object>( newValue );
  1352. this.CurrentSpeed = v;
  1353. }
  1354. if ( e.PropertyName.Equals( "CurrentTorque" ) )
  1355. {
  1356. var v = CastTo<double>.From<object>( newValue );
  1357. this.CurrentTorque = v;
  1358. }
  1359. if ( e.PropertyName.Equals( "ReqSteeringState" ) )
  1360. {
  1361. var v = CastTo<eSteeringState>.From<object>( newValue );
  1362. switch ( v )
  1363. {
  1364. case eSteeringState.None:
  1365. break;
  1366. case eSteeringState.Left:
  1367. this.steering.ControlSteering(true);
  1368. break;
  1369. case eSteeringState.Right:
  1370. this.steering.ControlSteering();
  1371. break;
  1372. default:
  1373. break;
  1374. }
  1375. }
  1376. }
  1377. private void Steering_PropertyChanged( object sender, System.ComponentModel.PropertyChangedEventArgs e )
  1378. {
  1379. var property = sender.GetType().GetProperty( e.PropertyName );
  1380. var newValue = property.GetValue( sender, null );
  1381. //Todo: 나중에 Test 하자
  1382. //var ownPropperty = this.GetType().GetProperty(e.PropertyName);
  1383. if ( e.PropertyName.Equals( "SteeringState" ) )
  1384. {
  1385. var v = CastTo<eSteeringState>.From<object>( newValue );
  1386. this.SteeringState = v;
  1387. }
  1388. }
  1389. private void Clamp_PropertyChanged( object sender, System.ComponentModel.PropertyChangedEventArgs e )
  1390. {
  1391. var property = sender.GetType().GetProperty( e.PropertyName );
  1392. var newValue = property.GetValue( sender, null );
  1393. if ( e.PropertyName.Equals( "ClampState" ) )
  1394. {
  1395. var v = CastTo<eClampState>.From<object>( newValue );
  1396. this.ClampState = v;
  1397. }
  1398. }
  1399. private void IO_OnChangedIO( BitBlock bit )
  1400. {
  1401. if ( bit.Tag.Equals( "IN_CV_DETECT_01" ) )
  1402. {
  1403. this.IsContain = bit.IsBitOn;
  1404. }
  1405. }
  1406. private void Steering_OnSteeringError( object sender, int e )
  1407. {
  1408. if ( e != 0 )
  1409. {
  1410. logger.E( $"[Steering] - Control Error {e}" );
  1411. this.OccurVehicleAlarm( e );
  1412. }
  1413. else
  1414. {
  1415. var msg = new DriveControlEventArgs()
  1416. {
  1417. EventDir = DriveControlEventArgs.eEventDir.ToFront,
  1418. ControlKind = DriveControlEventArgs.eControlKind.Steering,
  1419. Result = FluentResults.Results.Ok<DriveControlEventArgs.eMoveDir>( DriveControlEventArgs.eMoveDir.LEFT ),
  1420. };
  1421. this.eventAggregator.GetEvent<DriveControlPubSubEvent>().Publish( msg );
  1422. }
  1423. }
  1424. #endregion
  1425. }
  1426. }