IFSFManager.cs 254 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313331433153316331733183319332033213322332333243325332633273328332933303331333233333334333533363337333833393340334133423343334433453346334733483349335033513352335333543355335633573358335933603361336233633364336533663367336833693370337133723373337433753376337733783379338033813382338333843385338633873388338933903391339233933394339533963397339833993400340134023403340434053406340734083409341034113412341334143415341634173418341934203421342234233424342534263427342834293430343134323433343434353436343734383439344034413442344334443445344634473448344934503451345234533454345534563457345834593460346134623463346434653466346734683469347034713472347334743475347634773478347934803481348234833484348534863487348834893490349134923493349434953496349734983499350035013502350335043505350635073508350935103511351235133514351535163517351835193520352135223523352435253526352735283529353035313532353335343535353635373538353935403541354235433544354535463547354835493550355135523553355435553556355735583559356035613562356335643565356635673568356935703571357235733574357535763577357835793580358135823583358435853586358735883589359035913592359335943595359635973598359936003601360236033604360536063607360836093610361136123613361436153616361736183619362036213622362336243625362636273628362936303631363236333634363536363637363836393640364136423643364436453646364736483649365036513652365336543655365636573658365936603661366236633664366536663667366836693670367136723673367436753676367736783679368036813682368336843685368636873688368936903691369236933694369536963697369836993700370137023703370437053706370737083709371037113712371337143715371637173718371937203721372237233724372537263727372837293730373137323733373437353736373737383739374037413742374337443745374637473748374937503751375237533754375537563757375837593760376137623763376437653766376737683769377037713772377337743775377637773778377937803781378237833784378537863787378837893790379137923793379437953796379737983799380038013802380338043805380638073808380938103811381238133814381538163817381838193820382138223823382438253826382738283829383038313832383338343835383638373838383938403841384238433844384538463847384838493850385138523853385438553856385738583859386038613862386338643865386638673868386938703871387238733874387538763877387838793880388138823883388438853886388738883889389038913892389338943895389638973898389939003901390239033904390539063907390839093910391139123913391439153916391739183919392039213922392339243925392639273928392939303931393239333934393539363937393839393940394139423943394439453946394739483949395039513952395339543955395639573958395939603961396239633964396539663967396839693970397139723973397439753976397739783979398039813982398339843985398639873988398939903991399239933994399539963997399839994000400140024003400440054006400740084009401040114012401340144015401640174018401940204021402240234024402540264027402840294030403140324033403440354036403740384039404040414042404340444045404640474048404940504051405240534054405540564057405840594060406140624063406440654066406740684069407040714072407340744075407640774078407940804081408240834084408540864087408840894090409140924093409440954096409740984099410041014102410341044105410641074108410941104111411241134114411541164117411841194120412141224123412441254126412741284129413041314132413341344135413641374138413941404141414241434144414541464147414841494150415141524153415441554156415741584159416041614162416341644165416641674168416941704171417241734174417541764177417841794180418141824183418441854186418741884189419041914192419341944195419641974198419942004201420242034204420542064207420842094210421142124213421442154216421742184219422042214222422342244225422642274228422942304231423242334234423542364237423842394240424142424243424442454246424742484249425042514252425342544255425642574258425942604261426242634264426542664267426842694270427142724273427442754276427742784279428042814282428342844285428642874288428942904291429242934294429542964297429842994300430143024303430443054306430743084309431043114312431343144315431643174318431943204321432243234324432543264327432843294330433143324333433443354336433743384339434043414342434343444345434643474348434943504351435243534354435543564357435843594360436143624363436443654366436743684369437043714372437343744375437643774378437943804381438243834384438543864387438843894390439143924393439443954396439743984399440044014402440344044405440644074408440944104411441244134414441544164417441844194420442144224423442444254426442744284429443044314432443344344435443644374438443944404441444244434444444544464447444844494450445144524453445444554456445744584459446044614462446344644465446644674468446944704471447244734474447544764477447844794480448144824483448444854486448744884489449044914492449344944495449644974498449945004501450245034504450545064507450845094510451145124513451445154516451745184519452045214522452345244525452645274528452945304531453245334534453545364537453845394540454145424543454445454546454745484549455045514552455345544555455645574558455945604561456245634564456545664567456845694570457145724573457445754576457745784579458045814582458345844585458645874588458945904591459245934594459545964597459845994600460146024603460446054606460746084609461046114612461346144615461646174618461946204621462246234624462546264627462846294630463146324633463446354636463746384639464046414642464346444645464646474648464946504651465246534654465546564657465846594660466146624663466446654666466746684669467046714672467346744675467646774678467946804681468246834684468546864687468846894690469146924693469446954696469746984699470047014702470347044705470647074708470947104711471247134714471547164717471847194720472147224723472447254726472747284729473047314732473347344735473647374738473947404741474247434744474547464747474847494750475147524753475447554756475747584759476047614762476347644765476647674768476947704771477247734774477547764777477847794780478147824783478447854786478747884789479047914792479347944795479647974798479948004801480248034804480548064807480848094810481148124813481448154816481748184819482048214822482348244825482648274828482948304831483248334834483548364837483848394840484148424843484448454846484748484849
  1. using System;
  2. using Wayne.ForecourtControl.OptBridge;
  3. using Wayne.Lib;
  4. using Wayne.FDCPOSLibrary;
  5. using System.Text;
  6. using System.Threading;
  7. using System.Globalization;
  8. namespace Wayne.ForecourtControl.Fusion
  9. {
  10. public class Heartbeat
  11. {
  12. private Timer heartbeatTimer = null;
  13. private Timer disconnectionTimer = null;
  14. public event EventHandler OnHeartbeatTimeout;
  15. public event EventHandler OnHeartbeatInterval;
  16. public long heartbeatTimeout = 30000;
  17. public long heartbeatInterval = 10000;
  18. public bool tryingConnect = false;
  19. public bool connecting = false;
  20. public IFSFManager ifsfManager;
  21. public Heartbeat(IFSFManager _ifsfManager, long _heartbeatInterval, long _heartbeatTimeout)
  22. {
  23. ifsfManager = _ifsfManager;
  24. heartbeatInterval = _heartbeatInterval;
  25. heartbeatTimeout = _heartbeatTimeout;
  26. }
  27. private void HeartbeatTimeout(Object state)
  28. {
  29. lock (ifsfManager.SyncObject)
  30. {
  31. Trace.WriteLine(string.Format("Heartbeat Timeout - Id={0}", this.ifsfManager.clientSocket.Id));
  32. if (OnHeartbeatTimeout != null)
  33. OnHeartbeatTimeout.Invoke(this, null);
  34. if (disconnectionTimer != null)
  35. disconnectionTimer.Dispose();
  36. if (heartbeatTimeout > 0)
  37. disconnectionTimer = new System.Threading.Timer(new System.Threading.TimerCallback(HeartbeatTimeout), this, heartbeatTimeout, System.Threading.Timeout.Infinite);
  38. }
  39. }
  40. private void HeartbeatInterval(Object state)
  41. {
  42. lock (ifsfManager.SyncObject)
  43. {
  44. if (OnHeartbeatInterval != null)
  45. OnHeartbeatInterval.Invoke(this, null);
  46. }
  47. }
  48. public void ResetDisconnectionTimeout()
  49. {
  50. if (disconnectionTimer != null)
  51. disconnectionTimer.Dispose();
  52. if (heartbeatTimeout > 0)
  53. disconnectionTimer = new System.Threading.Timer(new System.Threading.TimerCallback(HeartbeatTimeout), this, heartbeatTimeout, System.Threading.Timeout.Infinite);
  54. }
  55. public void Restart()
  56. {
  57. lock (ifsfManager.SyncObject)
  58. {
  59. // start sending heartbeat when receive logon and send
  60. if (heartbeatTimer != null)
  61. {
  62. heartbeatTimer.Dispose();
  63. heartbeatTimer = null;
  64. }
  65. if (heartbeatInterval > 0)
  66. heartbeatTimer = new System.Threading.Timer(new System.Threading.TimerCallback(HeartbeatInterval), this, heartbeatInterval, System.Threading.Timeout.Infinite);
  67. }
  68. }
  69. public void NotifyDisconnection()
  70. {
  71. lock (ifsfManager.SyncObject)
  72. {
  73. tryingConnect = true;
  74. //if (disconnectionTimer != null)
  75. // disconnectionTimer.Dispose();
  76. Restart();
  77. }
  78. }
  79. }
  80. #region Event Args
  81. public class DeviceStateChangedEventArgs : EventArgs
  82. {
  83. public string deviceType;
  84. public int deviceId;
  85. public LogicalDeviceState state;
  86. public LogicalDeviceState substate;
  87. public string lockingAS;
  88. public int nozzleUp;
  89. public DeviceStateChangedEventArgs(string _deviceType, int _deviceId, LogicalDeviceState _state, LogicalDeviceState _substate, string _lockingAS, int _nozzleUp)
  90. {
  91. deviceType = _deviceType;
  92. deviceId = _deviceId;
  93. state = _state;
  94. substate = _substate;
  95. lockingAS = _lockingAS;
  96. nozzleUp = _nozzleUp;
  97. }
  98. }
  99. public class VIRStateChangedEventArgs : EventArgs
  100. {
  101. public int deviceId;
  102. public string virId;
  103. public DeviceConnectionState state;
  104. public VIRStateChangedEventArgs(int _deviceId, string _virId, DeviceConnectionState _state)
  105. {
  106. deviceId = _deviceId;
  107. virId = _virId;
  108. state = _state;
  109. }
  110. }
  111. public class FuelModeChangedEventArgs : EventArgs
  112. {
  113. public string deviceType;
  114. public int deviceId;
  115. public int mode;
  116. public FuelModeChangedEventArgs(string _deviceType, int _deviceId, int _mode)
  117. {
  118. deviceType = _deviceType;
  119. deviceId = _deviceId;
  120. mode = _mode;
  121. }
  122. }
  123. public class CurrentFuellingStatusEventArgs : EventArgs
  124. {
  125. public string deviceType;
  126. public int deviceId;
  127. public int nozzleId;
  128. public decimal volume;
  129. public decimal amount;
  130. public decimal price;
  131. public string authAS;
  132. public CurrentFuellingStatusEventArgs(string _deviceType, int _deviceId, int _nozzleId, decimal _volume, decimal _amount, decimal _price, string _authAS)
  133. {
  134. deviceType = _deviceType;
  135. deviceId = _deviceId;
  136. nozzleId = _nozzleId;
  137. volume = _volume;
  138. amount = _amount;
  139. price = _price;
  140. authAS = _authAS;
  141. }
  142. }
  143. public class FuelPointTotalsEventArgs : EventArgs
  144. {
  145. public int requestId;
  146. public bool overallResult;
  147. public string deviceType;
  148. public int deviceId;
  149. public int nozzleId;
  150. public decimal volume;
  151. public decimal amount;
  152. public decimal price;
  153. public FuelPointTotalsEventArgs(int _requestId, bool _overallResult, string _deviceType, int _deviceId, int _nozzleId, decimal _volume, decimal _amount, decimal _price)
  154. {
  155. requestId = _requestId;
  156. overallResult = _overallResult;
  157. deviceType = _deviceType;
  158. deviceId = _deviceId;
  159. nozzleId = _nozzleId;
  160. volume = _volume;
  161. amount = _amount;
  162. price = _price;
  163. }
  164. }
  165. public class FuelSaleTrxEventArgs : EventArgs
  166. {
  167. public int transactionId;
  168. public Wayne.FDCPOSLibrary.FuellingState transactionStatus;
  169. public int completionReason;
  170. public string deviceType;
  171. public int deviceId;
  172. public int nozzleId;
  173. public decimal volume;
  174. public decimal amount;
  175. public decimal price;
  176. public int fuelMode;
  177. public DateTime trxStartDateTime;
  178. public DateTime trxEndDateTime;
  179. public string lockingAS;
  180. public string authAS;
  181. //public byte[] DSPFields;
  182. //public byte[] CRCMode;
  183. public string DSPFields;
  184. public string CRCMode;
  185. public string MIDLinesNarrow;
  186. public string MIDLinesWide;
  187. public int releaseToken;
  188. public byte reservingDeviceId;
  189. public FuellingType fuellingType;
  190. public FuelSaleTrxEventArgs(int _transactionId, Wayne.FDCPOSLibrary.FuellingState _transactionStatus, int _completionReason, string _deviceType, int _deviceId, int _nozzleId, decimal _volume, decimal _amount, decimal _price, int _fuelMode, DateTime _trxStartDateTime, DateTime _trxEndDateTime, string _lockingAS, string _authAS, string /*byte[]*/ _DSPFields, string /*byte[]*/ _CRCMode, string _MIDLinesNarrow, string _MIDLinesWide, int _releaseToken, byte _reservingDeviceId, FuellingType _fuellingType)
  191. {
  192. transactionId = _transactionId;
  193. transactionStatus = _transactionStatus;
  194. completionReason = _completionReason;
  195. deviceType = _deviceType;
  196. deviceId = _deviceId;
  197. nozzleId = _nozzleId;
  198. volume = _volume;
  199. amount = _amount;
  200. price = _price;
  201. fuelMode = _fuelMode;
  202. trxStartDateTime = _trxStartDateTime;
  203. trxEndDateTime = _trxEndDateTime;
  204. lockingAS = _lockingAS;
  205. authAS = _authAS;
  206. DSPFields = _DSPFields;
  207. CRCMode = _CRCMode;
  208. MIDLinesNarrow = _MIDLinesNarrow;
  209. MIDLinesWide = _MIDLinesWide;
  210. releaseToken = _releaseToken;
  211. reservingDeviceId = _reservingDeviceId;
  212. fuellingType = _fuellingType;
  213. }
  214. }
  215. public class ChangeFuelPriceEventArgs : EventArgs
  216. {
  217. public int productId;
  218. public int mode;
  219. public decimal oldPrice;
  220. public decimal newPrice;
  221. public ChangeFuelPriceEventArgs(int _productId, int _mode, decimal _oldPrice, decimal _newPrice)
  222. {
  223. productId = _productId;
  224. mode = _mode;
  225. oldPrice = _oldPrice;
  226. newPrice = _newPrice;
  227. }
  228. }
  229. public class DeviceAlarmEventArgs : EventArgs
  230. {
  231. public string deviceType;
  232. public int deviceId;
  233. public int alarmId;
  234. public string alarmDescr;
  235. public DeviceAlarmEventArgs(string _deviceType, int _deviceId, int _alarmId, string _alarmDescr)
  236. {
  237. deviceType = _deviceType;
  238. deviceId = _deviceId;
  239. alarmId = _alarmId;
  240. alarmDescr = _alarmDescr;
  241. }
  242. }
  243. public class VersionInfoEventArgs : EventArgs
  244. {
  245. public string release;
  246. public string version;
  247. public string hotfix;
  248. public VersionInfoEventArgs(string _release, string _version, string _hotfix)
  249. {
  250. version = _version;
  251. release = _release;
  252. hotfix = _hotfix;
  253. }
  254. }
  255. public class TankDataEventArgs : EventArgs
  256. {
  257. int DeviceID;
  258. int TankNo;
  259. string Type;
  260. int ManualMode;
  261. decimal AverageTemp;
  262. decimal GrossStandardVolume;
  263. decimal ObservedDensity;
  264. decimal ProductLevel;
  265. decimal TotalObservedVolume;
  266. decimal WaterLevel;
  267. int TPStatus;
  268. public TankDataEventArgs(int _DeviceID, int _TankNo, string _Type, int _ManualMode,
  269. decimal _AverageTemp, decimal _GrossStandardVolume, decimal _ObservedDensity,
  270. decimal _ProductLevel, decimal _TotalObservedVolume, decimal _WaterLevel, int _TPStatus)
  271. {
  272. DeviceID = _DeviceID;
  273. TankNo = _TankNo;
  274. Type = _Type;
  275. ManualMode = _ManualMode;
  276. AverageTemp = _AverageTemp;
  277. GrossStandardVolume = _GrossStandardVolume;
  278. ObservedDensity = _ObservedDensity;
  279. ProductLevel = _ProductLevel;
  280. TotalObservedVolume = _TotalObservedVolume;
  281. WaterLevel = _WaterLevel;
  282. TPStatus = _TPStatus;
  283. }
  284. }
  285. public class GetConfigurationRespEventArgs : EventArgs
  286. {
  287. public ServiceResponseGetConfiguration sr = null;
  288. public EventHandler<AsyncCompletedEventArgs> getConfigurationRequestCompleted = null;
  289. public object getConfigurationUserToken = null;
  290. public int requestId;
  291. public bool result;
  292. public GetConfigurationRespEventArgs(int _requestId, bool _result, ServiceResponseGetConfiguration _sr, EventHandler<AsyncCompletedEventArgs> _getConfigurationRequestCompleted, object _getConfigurationUserToken)
  293. {
  294. sr = _sr;
  295. getConfigurationRequestCompleted = _getConfigurationRequestCompleted;
  296. getConfigurationUserToken = _getConfigurationUserToken;
  297. requestId = _requestId;
  298. result = _result;
  299. }
  300. }
  301. public class GetConfigurationEventArgs : EventArgs
  302. {
  303. public ServiceResponseGetConfiguration sr = null;
  304. public GetConfigurationEventArgs(ServiceResponseGetConfiguration _sr)
  305. {
  306. sr = _sr;
  307. }
  308. }
  309. public class GetProductTableEventArgs : EventArgs
  310. {
  311. public ServiceResponseGetProductTable sr;
  312. public GetProductTableEventArgs(ServiceResponseGetProductTable _sr)
  313. {
  314. sr = _sr;
  315. }
  316. }
  317. public class OptReadEventArgs : EventArgs
  318. {
  319. public string deviceType;
  320. public int deviceId;
  321. public byte[] message;
  322. public OptReadEventArgs(string _deviceType, int _deviceId, byte[] _message)
  323. {
  324. deviceType = _deviceType;
  325. deviceId = _deviceId;
  326. message = _message;
  327. }
  328. }
  329. #endregion
  330. public class IFSFManager
  331. {
  332. public bool isConfigRead = false;
  333. public bool isForcedToDisconnect = false;
  334. public int count = 0;
  335. public ServiceRequestSetConfiguration serviceRequestSetConfiguration;
  336. public ServiceRequest serviceRequestLogOn;
  337. private IFSFSockets _clientSocket;
  338. public IFSFSockets clientSocket
  339. {
  340. get { return _clientSocket; }
  341. }
  342. private Heartbeat _heartbeat;
  343. public Heartbeat heartbeat
  344. {
  345. get { return _heartbeat; }
  346. }
  347. private object _syncObject = new object();
  348. internal object SyncObject
  349. {
  350. get { return _syncObject; }
  351. }
  352. public bool authentificationErrorRetry;
  353. public event EventHandler<DeviceStateChangedEventArgs> OnDeviceStateChange;
  354. public event EventHandler<VIRStateChangedEventArgs> OnVirStateChange;
  355. public event EventHandler<FuelModeChangedEventArgs> OnFuelModeChange;
  356. public event EventHandler<CurrentFuellingStatusEventArgs> OnCurrentFuellingStatus;
  357. public event EventHandler<FuelPointTotalsEventArgs> OnFuelPointTotals;
  358. public event EventHandler<FuelSaleTrxEventArgs> OnFuelSaleTrx;
  359. public event EventHandler<DeviceAlarmEventArgs> OnDeviceAlarm;
  360. public event EventHandler<VersionInfoEventArgs> OnVersionInfo;
  361. public event EventHandler<ChangeFuelPriceEventArgs> OnChangeFuelPrice;
  362. public event EventHandler<FuelSaleTrxEventArgs> OnLockFuelSaleTrx;
  363. public event EventHandler<FuelSaleTrxEventArgs> OnUnlockFuelSaleTrx;
  364. public event EventHandler<FuelSaleTrxEventArgs> OnClearFuelSaleTrx;
  365. public event EventHandler<FuelSaleTrxEventArgs> OnGetAvailableFuelSaleTrx;
  366. public event EventHandler<FuelSaleTrxEventArgs> OnGetFuelSaleTrxDetails;
  367. public event EventHandler<GetConfigurationEventArgs> OnGetConfiguration;
  368. public event EventHandler<GetProductTableEventArgs> OnGetProductTable;
  369. public event EventHandler<OptReadEventArgs> OnOptRead;
  370. public event EventHandler<TankDataEventArgs> OnTankData;
  371. public event EventHandler<EventArgs> OnConfigurationChange;
  372. public event EventHandler<EventArgs> OnTwinMasterReady;
  373. public readonly ConfigurationParams ConfigParam;
  374. public IFSFManager(int id, ConfigurationParams configParam)
  375. {
  376. ConfigParam = configParam;
  377. this._clientSocket = new IFSFSockets(id, this);
  378. this._clientSocket.OnResponseTimeout += new EventHandler(_clientSocket_OnResponseTimeout);
  379. this._heartbeat = new Heartbeat(this, this._clientSocket.heartbeatInterval, this._clientSocket.heartbeatTimeout);
  380. heartbeat.OnHeartbeatInterval += new EventHandler(heartbeat_OnHeartbeatInterval);
  381. heartbeat.OnHeartbeatTimeout += new EventHandler(heartbeat_OnHeartbeatTimeout);
  382. serviceRequestSetConfiguration = null;
  383. authentificationErrorRetry = true;
  384. }
  385. public static void ArrayResize<T>(ref T[] array, int newSize)
  386. {
  387. int oldSize = (array == null) ? 0 : array.Length;
  388. T[] newArray = new T[newSize];
  389. int preserveLength = System.Math.Min(oldSize, newSize);
  390. for (int i = 0; i < preserveLength; i++)
  391. newArray[i] = array[i];
  392. array = newArray;
  393. }
  394. public LogicalDeviceState convertLogicalDeviceState(string state)
  395. {
  396. var logicalDeviceState = EnumSupport.ParseDefaultNull<LogicalDeviceState>(state, true);
  397. return logicalDeviceState ?? 0;
  398. }
  399. public Wayne.FDCPOSLibrary.FuellingState convertFuellingState(string state)
  400. {
  401. if (state == Wayne.FDCPOSLibrary.FuellingState.Locked.ToString())
  402. return Wayne.FDCPOSLibrary.FuellingState.Locked;
  403. else if (state == Wayne.FDCPOSLibrary.FuellingState.Payable.ToString())
  404. return Wayne.FDCPOSLibrary.FuellingState.Payable;
  405. else if (state == Wayne.FDCPOSLibrary.FuellingState.Paid.ToString() || state == Wayne.FDCPOSLibrary.FuellingState.Cleared.ToString())
  406. return Wayne.FDCPOSLibrary.FuellingState.Paid;
  407. return 0;
  408. }
  409. public static string getClientID(string workstationID, string applicationSender)
  410. {
  411. return workstationID + "-" + applicationSender;
  412. }
  413. public void Disconnect()
  414. {
  415. isForcedToDisconnect = false; // reset value
  416. Trace.WriteLine("IFSFManager - Disconnect() before locking - Id=" + clientSocket.Id);
  417. lock (SyncObject)
  418. {
  419. Trace.WriteLine("IFSFManager - Disconnect()-calling clientSocket.Disconnect() - Id=" + clientSocket.Id);
  420. clientSocket.Disconnect();
  421. clientSocket.mainConnectionState = DeviceConnectionState.Disconnected;
  422. }
  423. if (heartbeat != null)
  424. heartbeat.NotifyDisconnection();
  425. }
  426. private void _clientSocket_OnResponseTimeout(object sender, EventArgs e)
  427. {
  428. //FG, MAR-15-2011, bug fix #28041; trigger to GetConfiguration again if there's no pump on FM.
  429. if (!isConfigRead && ((Wayne.Lib.EventArgs<string>)(e)).Argument == "GetConfiguration")
  430. {
  431. Trace.WriteLine("GetConfiguration() timedout!");
  432. //this.GetConfiguration(null, null, null);
  433. }
  434. if (this.OnDeviceAlarm != null)
  435. {
  436. //AsyncResponseOperation aro = (AsyncResponseOperation)sender;
  437. //string deviceType = "";
  438. //int deviceId = 0;
  439. //int alarmId = 0;
  440. //string alarmmsg = string.Format("Timeout nella risposta - requestId: '{0}', requestType: '{1}'", aro.requestId, aro.requestType);
  441. //OnDeviceAlarm.Invoke(this, new DeviceAlarmEventArgs(deviceType, deviceId, alarmId, alarmmsg));
  442. }
  443. }
  444. private void heartbeat_OnHeartbeatTimeout(object sender, EventArgs e)
  445. {
  446. Trace.WriteLine("Heartbeat Timeout - disconnecting");
  447. //if (clientSocket.mainConnectionState != DeviceConnectionState.Disconnected || this.heartbeat.tryingConnect)
  448. {
  449. //clientSocket.Disconnect();
  450. isForcedToDisconnect = true; // forcing Disconnect because this is a heartbeat disconnection
  451. Disconnect();
  452. clientSocket.mainConnectionState = DeviceConnectionState.Disconnected;
  453. }
  454. }
  455. private void heartbeat_OnHeartbeatInterval(object sender, EventArgs e)
  456. {
  457. Heartbeat();
  458. }
  459. public string ReadResponse(string myString, int msglength, ref OverallResult result) //StreamReader networkStream)
  460. {
  461. string requestType = "";
  462. int requestId = 0;
  463. try
  464. {
  465. requestType = GetRequestType("RequestType", myString);
  466. requestId = GetRequestID("RequestID", myString);
  467. }
  468. catch (Exception ex)
  469. {
  470. Trace.WriteLine(string.Format("Unable to get request type or id - Exception! {0}", ex.Message));
  471. //result = OverallResult.Failure;
  472. }
  473. if (result != OverallResult.Success)
  474. {
  475. Trace.WriteLine(string.Format("ReadResponse ERROR result='{0}'", result));
  476. }
  477. else
  478. {
  479. if (requestType == "")
  480. {
  481. Trace.WriteLine(string.Format("ReadResponse INVALID requestType='{0}', requestId={1}", requestType, requestId));
  482. result = OverallResult.FormatError;
  483. //return requestType;
  484. }
  485. //int headerlength = getMsgLength(myString.Substring(0, Define.HeaderLength));
  486. //myString = myString.Substring(Define.HeaderLength + Define.EncriptionLength);
  487. int UTFlength = System.Text.Encoding.UTF8.GetBytes(myString).Length;
  488. if (result == OverallResult.Success && UTFlength != msglength)
  489. {
  490. Trace.WriteLine(string.Format("ReadResponse header='{0}' != msgLength={1}, requestType='{2}', requestId={3}", msglength, UTFlength, requestType, requestId));
  491. result = OverallResult.FormatError;
  492. //return requestType;
  493. }
  494. else
  495. {
  496. try
  497. {
  498. //string myString = networkStream.ReadToEnd();
  499. Trace.WriteLine(string.Format("ReadResponse init: requestType='{0}', requestId={1}", requestType, requestId));
  500. switch (requestType)
  501. {
  502. case "LogOn":
  503. {
  504. ServiceResponseLogOn sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseLogOn>(myString, ref result);
  505. LogOnResp(sr.OverallResult, sr.Value, sr.FDCdata[0].FDCTimeStamp);
  506. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  507. }
  508. break;
  509. case "LogOff":
  510. {
  511. ServiceResponseLogOff sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseLogOff>(myString, ref result);
  512. LogOffResp(sr.OverallResult);
  513. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  514. }
  515. break;
  516. case "VersionInfo":
  517. {
  518. ServiceResponseVersionInfo sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseVersionInfo>(myString, ref result);
  519. VersionInfoResp(sr.RequestIDNumber, sr.OverallResult, sr);
  520. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  521. }
  522. break;
  523. case "StartForecourt":
  524. {
  525. ServiceResponseStartForecourt sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseStartForecourt>(myString, ref result);
  526. string errorCode = (sr.FDCdata[0].FDCStatus != null) ? sr.FDCdata[0].FDCStatus : sr.FDCdata[0].ErrorCode;
  527. StartForecourtResp(sr.RequestIDNumber, sr.OverallResult, errorCode);
  528. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  529. }
  530. break;
  531. case "TwinOpenMaster":
  532. {
  533. ServiceResponseTwinOpenMaster sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseTwinOpenMaster>(myString, ref result);
  534. string errorCode = (sr.FDCdata[0].FDCStatus != null) ? sr.FDCdata[0].FDCStatus : sr.FDCdata[0].ErrorCode;
  535. TwinOpenMasterResp(sr.RequestIDNumber, sr.OverallResult, errorCode);
  536. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  537. }
  538. break;
  539. case "StopForecourt":
  540. {
  541. ServiceResponseStopForecourt sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseStopForecourt>(myString, ref result);
  542. string errorCode = (sr.FDCdata[0].FDCStatus != null) ? sr.FDCdata[0].FDCStatus : sr.FDCdata[0].ErrorCode;
  543. StopForecourtResp(sr.RequestIDNumber, sr.OverallResult, errorCode);
  544. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  545. }
  546. break;
  547. case "GetCurrentFuellingStatus":
  548. {
  549. ServiceResponseGetCurrentFuellingStatus sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseGetCurrentFuellingStatus>(myString, ref result);
  550. GetCurrentFuellingStatusResp(sr.RequestIDNumber, sr.OverallResult, sr);
  551. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  552. }
  553. break;
  554. case "GetFuelPointTotals":
  555. {
  556. ServiceResponseGetFuelPointTotals sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseGetFuelPointTotals>(myString, ref result);
  557. GetFuelPointTotalsResp(sr.RequestIDNumber, sr.OverallResult, sr);
  558. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  559. }
  560. break;
  561. case "GetDeviceState":
  562. {
  563. ServiceResponseGetDeviceState sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseGetDeviceState>(myString, ref result);
  564. GetDeviceStateResp(sr.RequestIDNumber, sr.OverallResult, sr);
  565. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  566. }
  567. break;
  568. case "GetFPState":
  569. {
  570. ServiceResponseGetFPState sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseGetFPState>(myString, ref result);
  571. GetFPStateResp(sr.RequestIDNumber, sr.OverallResult, sr);
  572. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  573. }
  574. break;
  575. case "GetTPState":
  576. {
  577. ServiceResponseGetTPState sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseGetTPState>(myString, ref result);
  578. GetTPStateResp(sr.RequestIDNumber, sr.OverallResult, sr);
  579. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  580. }
  581. break;
  582. case "GetPPState":
  583. {
  584. ServiceResponseGetPPState sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseGetPPState>(myString, ref result);
  585. GetPPStateResp(sr.RequestIDNumber, sr.OverallResult, sr);
  586. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  587. }
  588. break;
  589. case "GetVIRState":
  590. {
  591. ServiceResponseGetVIRState sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseGetVIRState>(myString, ref result);
  592. GetVIRStateResp(sr.RequestIDNumber, sr.OverallResult, sr);
  593. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  594. }
  595. break;
  596. case "TerminateFuelling":
  597. {
  598. ServiceResponseTerminateFuelling sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseTerminateFuelling>(myString, ref result);
  599. TerminateFuellingResp(sr.RequestIDNumber, sr.OverallResult, sr);
  600. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  601. }
  602. break;
  603. case "AuthoriseFuelPoint":
  604. {
  605. ServiceResponseAuthoriseFuelPoint sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseAuthoriseFuelPoint>(myString, ref result);
  606. AuthoriseFuelPointResp(sr.RequestIDNumber, sr.OverallResult, sr);
  607. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  608. }
  609. break;
  610. case "ChangeFuelMode":
  611. {
  612. ServiceResponseChangeFuelMode sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseChangeFuelMode>(myString, ref result);
  613. ChangeFuelModeResp(sr.RequestIDNumber, sr.OverallResult, sr.FDCdata);
  614. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  615. }
  616. break;
  617. case "ChangeFPFuelMode":
  618. {
  619. ServiceResponseChangeFPFuelMode sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseChangeFPFuelMode>(myString, ref result);
  620. ChangeFuelModeResp(sr.RequestIDNumber, sr.OverallResult, sr.FDCdata);
  621. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  622. }
  623. break;
  624. case "ChangeFuelPrice":
  625. {
  626. ServiceResponseChangeFuelPrice sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseChangeFuelPrice>(myString, ref result);
  627. ChangeFuelPriceResp(sr.RequestIDNumber, sr.OverallResult, sr.FDCdata);
  628. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  629. }
  630. break;
  631. case "LockFuelSaleTrx":
  632. {
  633. ServiceResponseLockFuelSaleTrx sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseLockFuelSaleTrx>(myString, ref result);
  634. LockFuelSaleTrxResp(sr.RequestIDNumber, sr.OverallResult, sr);
  635. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  636. }
  637. break;
  638. case "UnlockFuelSaleTrx":
  639. {
  640. ServiceResponseUnlockFuelSaleTrx sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseUnlockFuelSaleTrx>(myString, ref result);
  641. UnlockFuelSaleTrxResp(sr.RequestIDNumber, sr.OverallResult, sr);
  642. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  643. }
  644. break;
  645. case "ClearFuelSaleTrx":
  646. {
  647. ServiceResponseClearFuelSaleTrx sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseClearFuelSaleTrx>(myString, ref result);
  648. ClearFuelSaleTrxResp(sr.RequestIDNumber, sr.OverallResult, sr);
  649. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  650. }
  651. break;
  652. case "GetAvailableFuelSaleTrxs":
  653. {
  654. ServiceResponseGetAvailableFuelSaleTrxs sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseGetAvailableFuelSaleTrxs>(myString, ref result);
  655. GetAvailableFuelSaleTrxsResp(sr.RequestIDNumber, sr.OverallResult, sr);
  656. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  657. }
  658. break;
  659. case "GetFuelSaleTrxDetails":
  660. {
  661. string res = "";
  662. if (FDCGlobal.ProtocolVersion == FDCVersion.V0003)
  663. {
  664. ServiceResponseGetFuelSaleTrxDetailsV03 sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseGetFuelSaleTrxDetailsV03>(myString, ref result);
  665. GetFuelSaleTrxDetailsResp(sr.RequestIDNumber, sr.OverallResult, sr);
  666. res = sr.OverallResult;
  667. }
  668. else
  669. {
  670. ServiceResponseGetFuelSaleTrxDetails sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseGetFuelSaleTrxDetails>(myString, ref result);
  671. GetFuelSaleTrxDetailsResp(sr.RequestIDNumber, sr.OverallResult, sr);
  672. res = sr.OverallResult;
  673. }
  674. result = FDCConvert.OverallResultToInt(res);
  675. }
  676. break;
  677. case "GetProductTable":
  678. {
  679. ServiceResponseGetProductTable sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseGetProductTable>(myString, ref result);
  680. GetProductTableResp(sr.RequestIDNumber, sr.OverallResult, sr);
  681. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  682. }
  683. break;
  684. case "GetModeTable":
  685. {
  686. ServiceResponseGetModeTable sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseGetModeTable>(myString, ref result);
  687. GetModeTableResp(sr.RequestIDNumber, sr.OverallResult, sr);
  688. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  689. }
  690. break;
  691. case "GetFuelMode":
  692. {
  693. ServiceResponseGetFuelMode sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseGetFuelMode>(myString, ref result);
  694. GetFuelModeResp(sr.RequestIDNumber, sr.OverallResult, sr.FDCdata);
  695. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  696. }
  697. break;
  698. case "GetFPFuelMode":
  699. {
  700. ServiceResponseGetFPFuelMode sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseGetFPFuelMode>(myString, ref result);
  701. GetFuelModeResp(sr.RequestIDNumber, sr.OverallResult, sr.FDCdata);
  702. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  703. }
  704. break;
  705. case "GetConfiguration":
  706. {
  707. ServiceResponseGetConfiguration sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseGetConfiguration>(myString, ref result);
  708. GetConfigurationResp(sr.RequestIDNumber, sr.OverallResult, sr);
  709. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  710. }
  711. break;
  712. case "GetDSPConfiguration":
  713. {
  714. ServiceResponseGetDSPConfiguration sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseGetDSPConfiguration>(myString, ref result);
  715. GetDSPConfigurationResp(sr.RequestIDNumber, sr.OverallResult, sr);
  716. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  717. }
  718. break;
  719. case "GetTLGConfiguration":
  720. {
  721. ServiceResponseGetTLGConfiguration sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseGetTLGConfiguration>(myString, ref result);
  722. GetTLGConfigurationResp(sr.RequestIDNumber, sr.OverallResult, sr);
  723. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  724. }
  725. break;
  726. case "GetPPConfiguration":
  727. {
  728. ServiceResponseGetPPConfiguration sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseGetPPConfiguration>(myString, ref result);
  729. //GetPPConfigurationResp(sr.RequestIDNumber, sr.OverallResult, sr);
  730. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  731. }
  732. break;
  733. case "SetConfiguration":
  734. {
  735. ServiceResponseSetConfiguration sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseSetConfiguration>(myString, ref result);
  736. SetConfigurationResp(sr.RequestIDNumber, sr.OverallResult, sr);
  737. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  738. }
  739. break;
  740. case "LockNozzle":
  741. {
  742. ServiceResponseLockNozzle sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseLockNozzle>(myString, ref result);
  743. LockNozzleResp(sr.RequestIDNumber, sr.OverallResult, sr);
  744. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  745. }
  746. break;
  747. case "UnlockNozzle":
  748. {
  749. ServiceResponseUnlockNozzle sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseUnlockNozzle>(myString, ref result);
  750. UnlockNozzleResp(sr.RequestIDNumber, sr.OverallResult, sr);
  751. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  752. }
  753. break;
  754. case "GetCountrySettings":
  755. {
  756. ServiceResponseGetCountrySettings sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseGetCountrySettings>(myString, ref result);
  757. GetCountrySettingsResp(sr.RequestIDNumber, sr.OverallResult, sr);
  758. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  759. }
  760. break;
  761. case "GetDSPLimits":
  762. {
  763. ServiceResponseGetDSPLimits sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseGetDSPLimits>(myString, ref result);
  764. GetDSPLimitsResp(sr.RequestIDNumber, sr.OverallResult, sr);
  765. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  766. }
  767. break;
  768. case "ChangeDSPLimits":
  769. {
  770. ServiceResponseChangeDSPLimits sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseChangeDSPLimits>(myString, ref result);
  771. ChangeDSPLimitsResp(sr.RequestIDNumber, sr.OverallResult, sr);
  772. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  773. }
  774. break;
  775. case "SuspendFuelling":
  776. {
  777. ServiceResponseSuspendFuelling sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseSuspendFuelling>(myString, ref result);
  778. SuspendFuellingResp(sr.RequestIDNumber, sr.OverallResult, sr);
  779. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  780. }
  781. break;
  782. case "ResumeFuelling":
  783. {
  784. ServiceResponseResumeFuelling sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseResumeFuelling>(myString, ref result);
  785. ResumeFuellingResp(sr.RequestIDNumber, sr.OverallResult, sr);
  786. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  787. }
  788. break;
  789. case "LockTank":
  790. {
  791. ServiceResponseLockTank sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseLockTank>(myString, ref result);
  792. LockTankResp(sr.RequestIDNumber, sr.OverallResult, sr);
  793. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  794. }
  795. break;
  796. case "UnlockTank":
  797. {
  798. ServiceResponseUnlockTank sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseUnlockTank>(myString, ref result);
  799. UnlockTankResp(sr.RequestIDNumber, sr.OverallResult, sr);
  800. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  801. }
  802. break;
  803. case "GetTankData":
  804. {
  805. ServiceResponseGetTankData sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseGetTankData>(myString, ref result);
  806. GetTankDataResp(sr.RequestIDNumber, sr.OverallResult, sr);
  807. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  808. }
  809. break;
  810. case "ReserveFuelPoint":
  811. {
  812. ServiceResponseReserveFuelPoint sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseReserveFuelPoint>(myString, ref result);
  813. ReserveFuelPointResp(sr.RequestIDNumber, sr.OverallResult, sr);
  814. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  815. }
  816. break;
  817. case "FreeFuelPoint":
  818. {
  819. ServiceResponseFreeFuelPoint sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseFreeFuelPoint>(myString, ref result);
  820. FreeFuelPointResp(sr.RequestIDNumber, sr.OverallResult, sr);
  821. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  822. }
  823. break;
  824. case "StartFuelPointTest":
  825. {
  826. ServiceResponseStartFuelPointTest sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseStartFuelPointTest>(myString, ref result);
  827. StartFuelPointTestResp(sr.RequestIDNumber, sr.OverallResult, sr);
  828. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  829. }
  830. break;
  831. case "EndFuelPointTest":
  832. {
  833. ServiceResponseEndFuelPointTest sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseEndFuelPointTest>(myString, ref result);
  834. EndFuelPointTestResp(sr.RequestIDNumber, sr.OverallResult, sr);
  835. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  836. }
  837. break;
  838. case "OpenFuelPoint":
  839. {
  840. ServiceResponseOpenFuelPoint sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseOpenFuelPoint>(myString, ref result);
  841. OpenFuelPointResp(sr.RequestIDNumber, sr.OverallResult, sr);
  842. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  843. }
  844. break;
  845. case "CloseFuelPoint":
  846. {
  847. ServiceResponseCloseFuelPoint sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseCloseFuelPoint>(myString, ref result);
  848. CloseFuelPointResp(sr.RequestIDNumber, sr.OverallResult, sr);
  849. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  850. }
  851. break;
  852. case "OpenDevice":
  853. {
  854. ServiceResponseOpenDevice sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseOpenDevice>(myString, ref result);
  855. OpenDeviceResp(sr.RequestIDNumber, sr.OverallResult, sr);
  856. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  857. }
  858. break;
  859. case "CloseDevice":
  860. {
  861. ServiceResponseCloseDevice sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseCloseDevice>(myString, ref result);
  862. CloseDeviceResp(sr.RequestIDNumber, sr.OverallResult, sr);
  863. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  864. }
  865. break;
  866. case "SetDeviceAlarm":
  867. {
  868. ServiceResponseSetDeviceAlarm sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseSetDeviceAlarm>(myString, ref result);
  869. SetDeviceAlarmResp(sr.RequestIDNumber, sr.OverallResult, sr);
  870. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  871. }
  872. break;
  873. case "OPTAdd":
  874. {
  875. ServiceResponseOPTAdd sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseOPTAdd>(myString, ref result);
  876. OptAddResp(sr.RequestIDNumber, sr.OverallResult, sr);
  877. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  878. }
  879. break;
  880. case "OPTRemove":
  881. {
  882. ServiceResponseOPTRemove sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseOPTRemove>(myString, ref result);
  883. OptRemoveResp(sr.RequestIDNumber, sr.OverallResult, sr);
  884. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  885. }
  886. break;
  887. case "OPTWrite":
  888. {
  889. ServiceResponseOPTWrite sr = clientSocket.ifsfMessages.Deserialize<ServiceResponseOPTWrite>(myString, ref result);
  890. OptWriteResp(sr.RequestIDNumber, sr.OverallResult, sr);
  891. result = FDCConvert.OverallResultToInt(sr.OverallResult);
  892. }
  893. break;
  894. default:
  895. break;
  896. }
  897. Trace.WriteLine(string.Format("ReadResponse end: requestType={0}, requestId={1}", requestType, requestId));
  898. }
  899. catch (Exception ex)
  900. {
  901. Trace.WriteLine(string.Format("ReadResponse RequestType='{0}', requestId={1} Exception! {2} - {3}", requestType, requestId, ex.Message, ex.StackTrace));
  902. result = OverallResult.Failure;
  903. }
  904. }
  905. }
  906. if (result != OverallResult.Success)
  907. {
  908. if (result != OverallResult.NoData)
  909. {
  910. //AsyncResponseOperation aro = (AsyncResponseOperation)sender;
  911. string deviceType = "";
  912. int deviceId = 0;
  913. int alarmId = 0;
  914. string alarmmsg = string.Format("Error '{0}' receiving Response for requestId:'{1}', requestType:'{2}'", result.ToString(), requestId, requestType);
  915. OnDeviceAlarm.BeginInvoke(this, new DeviceAlarmEventArgs(deviceType, deviceId, alarmId, alarmmsg), null, null);
  916. }
  917. }
  918. return requestType;
  919. }
  920. public string ReadMessage(string myString, int msglength, ref OverallResult result) //StreamReader networkStream)
  921. {
  922. if (result != OverallResult.Success)
  923. {
  924. Trace.WriteLine(string.Format("ReadMessage ERROR result='{0}'", result));
  925. }
  926. string requestType = GetRequestType("MessageType", myString);
  927. int requestId = GetRequestID("MessageID", myString);
  928. Trace.WriteLine(string.Format("ReadMessage init: MessageType='{0}', requestId={1}", requestType, requestId));
  929. if (requestType == "")
  930. {
  931. Trace.WriteLine(string.Format("ReadMessage INVALID requestType='{0}', requestId={1}", requestType, requestId));
  932. return requestType;
  933. }
  934. //int headerlength = getHeaderLength(myString.Substring(0, Define.HeaderLength));
  935. //myString = myString.Substring(Define.HeaderLength + Define.EncriptionLength);
  936. int UTFlength = System.Text.Encoding.UTF8.GetBytes(myString).Length;
  937. if (UTFlength != msglength)
  938. {
  939. Trace.WriteLine(string.Format("ReadMessage header='{0}' != msgLength={1}", msglength, UTFlength));
  940. result = OverallResult.FormatError;
  941. return requestType;
  942. }
  943. try
  944. {
  945. //string myString = networkStream.ReadToEnd();
  946. switch (requestType)
  947. {
  948. case "FDCHeartBeat":
  949. {
  950. FDCMessageFDCHeartbeat msg = clientSocket.ifsfMessages.Deserialize<FDCMessageFDCHeartbeat>(myString, ref result);
  951. HeartbeatMsg();
  952. }
  953. break;
  954. case "FDCStarted":
  955. {
  956. FDCMessageStarted msg = clientSocket.ifsfMessages.Deserialize<FDCMessageStarted>(myString, ref result);
  957. FDCStartedMsg(msg);
  958. }
  959. break;
  960. case "FDCStopped":
  961. {
  962. FDCMessageStopped msg = clientSocket.ifsfMessages.Deserialize<FDCMessageStopped>(myString, ref result);
  963. FDCStoppedMsg(msg);
  964. }
  965. break;
  966. case "DeviceStateChange":
  967. {
  968. FDCMessageDeviceStateChange msg = clientSocket.ifsfMessages.Deserialize<FDCMessageDeviceStateChange>(myString, ref result);
  969. DeviceStateChangeMsg(msg);
  970. }
  971. break;
  972. case "FPStateChange":
  973. {
  974. FDCMessageFPStateChange msg = clientSocket.ifsfMessages.Deserialize<FDCMessageFPStateChange>(myString, ref result);
  975. FPStateChangeMsg(msg);
  976. }
  977. break;
  978. case "CurrentFuellingStatus":
  979. {
  980. FDCMessageCurrentFuellingStatus msg = clientSocket.ifsfMessages.Deserialize<FDCMessageCurrentFuellingStatus>(myString, ref result);
  981. CurrentFuellingStatusMsg(msg);
  982. }
  983. break;
  984. case "DeviceAlarm":
  985. {
  986. FDCMessageDeviceAlarm msg = clientSocket.ifsfMessages.Deserialize<FDCMessageDeviceAlarm>(myString, ref result);
  987. DeviceAlarmMsg(msg);
  988. }
  989. break;
  990. case "FuelSaleTrx":
  991. {
  992. FDCMessageFuelSaleTrx msg = clientSocket.ifsfMessages.Deserialize<FDCMessageFuelSaleTrx>(myString, ref result);
  993. FuelSaleTrxMsg(msg);
  994. }
  995. break;
  996. case "FuelPriceChange":
  997. {
  998. FDCMessageFuelPriceChange msg = clientSocket.ifsfMessages.Deserialize<FDCMessageFuelPriceChange>(myString, ref result);
  999. FuelPriceChangeMsg(msg);
  1000. }
  1001. break;
  1002. case "FuelModeChange":
  1003. {
  1004. FDCMessageFDCdataFuelModeChange msg = clientSocket.ifsfMessages.Deserialize<FDCMessageFDCdataFuelModeChange>(myString, ref result);
  1005. FuelModeChangeMsg(msg);
  1006. }
  1007. break;
  1008. case "FDCExceptionMsg":
  1009. {
  1010. FDCMessageFDCExceptionMsg msg = clientSocket.ifsfMessages.Deserialize<FDCMessageFDCExceptionMsg>(myString, ref result);
  1011. FDCExceptionMsg(msg);
  1012. }
  1013. break;
  1014. case "ConfigurationChange":
  1015. {
  1016. FDCMessageConfigurationChange msg = clientSocket.ifsfMessages.Deserialize<FDCMessageConfigurationChange>(myString, ref result);
  1017. FDCMessageConfigurationChangeMsg(msg);
  1018. }
  1019. break;
  1020. case "OPTRead":
  1021. {
  1022. if (FDCGlobal.ProtocolVersion <= FDCVersion.V0007)
  1023. {
  1024. FDCMessageOPTReadV07 msg = clientSocket.ifsfMessages.Deserialize<FDCMessageOPTReadV07>(myString, ref result);
  1025. OptReadMsg(msg);
  1026. }
  1027. else
  1028. {
  1029. FDCMessageOPTRead msg = clientSocket.ifsfMessages.Deserialize<FDCMessageOPTRead>(myString, ref result);
  1030. OptReadMsg(msg);
  1031. }
  1032. }
  1033. break;
  1034. }
  1035. Trace.WriteLine(string.Format("ReadMessage end: ", requestType, requestId));
  1036. }
  1037. catch (Exception ex)
  1038. {
  1039. Trace.WriteLine(string.Format("ReadMessage MessageType='{0}', requestId={1} Exception! {2} - {3}", requestType, requestId, ex.Message, ex.StackTrace));
  1040. }
  1041. return requestType;
  1042. }
  1043. private string GetRequestType(string typeField, string myString)
  1044. {
  1045. string requestType = "";
  1046. try
  1047. {
  1048. if (myString.IndexOf(typeField) >= 0)
  1049. {
  1050. myString = myString.Substring(myString.IndexOf(typeField));
  1051. myString = myString.Substring(myString.IndexOf('\"') + 1);
  1052. requestType = myString.Substring(0, myString.IndexOf('\"'));
  1053. }
  1054. }
  1055. catch (Exception ex)
  1056. {
  1057. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1058. }
  1059. return requestType;
  1060. }
  1061. private int GetRequestID(string typeField, string myString)
  1062. {
  1063. int requestID = 0;
  1064. try
  1065. {
  1066. if (myString.IndexOf(typeField) >= 0)
  1067. {
  1068. myString = myString.Substring(myString.IndexOf(typeField));
  1069. myString = myString.Substring(myString.IndexOf('\"') + 1);
  1070. requestID = Convert.ToInt32(myString.Substring(0, myString.IndexOf('\"')));
  1071. }
  1072. }
  1073. catch (Exception ex)
  1074. {
  1075. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1076. }
  1077. return requestID;
  1078. }
  1079. public void LogOn(string posInfo, string sFDCDateTime)
  1080. {
  1081. // POS open channel A and send LogOn command
  1082. // FDC open channel B and C and send LogOn response
  1083. try
  1084. {
  1085. Trace.WriteLine("LogOn init");
  1086. LogOn(null, posInfo, sFDCDateTime);
  1087. Trace.WriteLine("LogOn end");
  1088. }
  1089. catch (Exception ex)
  1090. {
  1091. Trace.WriteLine("LogOn Exception! " + ex.Message + " - " + ex.StackTrace);
  1092. }
  1093. }
  1094. public void LogOn(byte[][] validationInfoArray, string posInfo, string sFDCDateTime)
  1095. {
  1096. // POS open channel A and send LogOn command
  1097. // FDC open channel B and C and send LogOn response
  1098. try
  1099. {
  1100. Trace.WriteLine(string.Format("LogOn2 init version={0}", FDCGlobal.ProtocolVersion));
  1101. ServiceRequest logOn;
  1102. if (FDCGlobal.ProtocolVersion <= FDCVersion.V0007)
  1103. {
  1104. // create XML ServiceRequest object
  1105. logOn = new ServiceRequestLogOnV07();
  1106. logOn.ApplicationSender = clientSocket.applicationSender;
  1107. logOn.WorkstationID = clientSocket.workstationID;
  1108. var posDataElem = new ServiceRequestPOSdataLogOnV07();
  1109. posDataElem.POSName = "";
  1110. if (sFDCDateTime == "")
  1111. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  1112. else
  1113. posDataElem.POSTimeStamp = sFDCDateTime;
  1114. posDataElem.ResponsePort = clientSocket.iIPPortB.ToString();
  1115. posDataElem.UnsolicitedPort = clientSocket.iIPPortC.ToString();
  1116. posDataElem.interfaceVersion = FDCGlobal.VersionToString();
  1117. //posDataElem.InterfaceVersion = FDCGlobal.VersionToString(); // wont work for older versions
  1118. if (posInfo != "")
  1119. {
  1120. posDataElem.posInfo = UTF8Encoding.UTF8.GetBytes(posInfo);
  1121. }
  1122. if (validationInfoArray != null)
  1123. {
  1124. posDataElem.ValidationInfo = validationInfoArray;
  1125. }
  1126. ServiceRequestPOSdataLogOnV07[] posDataArray = { posDataElem };
  1127. ((ServiceRequestLogOnV07)logOn).POSdata = posDataArray;
  1128. }
  1129. else
  1130. {
  1131. // create XML ServiceRequest object
  1132. logOn = new ServiceRequestLogOn();
  1133. logOn.ApplicationSender = clientSocket.applicationSender;
  1134. logOn.WorkstationID = clientSocket.workstationID;
  1135. //logOn.requestId = "";
  1136. //logOn.RequestType = "LogOn";
  1137. ServiceRequestPOSdataLogOn posDataElem = new ServiceRequestPOSdataLogOn();
  1138. posDataElem.POSName = "";
  1139. if (sFDCDateTime == "")
  1140. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  1141. else
  1142. posDataElem.POSTimeStamp = sFDCDateTime;
  1143. posDataElem.ResponsePort = clientSocket.iIPPortB.ToString();
  1144. posDataElem.UnsolicitedPort = clientSocket.iIPPortC.ToString();
  1145. //posDataElem.interfaceVersion = IniFile.IniReadValue(ConfigurationParams.inifile, "FUSION-Connection", "FDCPOSInterfaceVersion");
  1146. posDataElem.interfaceVersion = FDCGlobal.VersionToString();
  1147. if (posInfo != "")
  1148. {
  1149. // Get UTF16 bytes and convert UTF16 bytes to UTF8 bytes
  1150. Trace.WriteLine(string.Format("EnqueueMessage logOn2 posInfo='{0}'", posInfo));
  1151. posDataElem.posInfo = posInfo;
  1152. }
  1153. if (validationInfoArray != null)
  1154. {
  1155. posDataElem.ValidationInfo = validationInfoArray;
  1156. }
  1157. // calculate posValidation string
  1158. string posValidationSourceString = logOn.ApplicationSender + logOn.WorkstationID + posDataElem.POSTimeStamp;
  1159. MD5Crypter crypter = new MD5Crypter();
  1160. byte[] posValidationSource = new byte[posValidationSourceString.Length + crypter.getPassphrase().GetLength(0)];
  1161. Array.Copy(System.Text.Encoding.ASCII.GetBytes(posValidationSourceString), posValidationSource, (int)posValidationSourceString.Length);
  1162. Array.Copy(crypter.getPassphrase(), 0, posValidationSource, (int)posValidationSourceString.Length, (int)crypter.getPassphrase().Length);
  1163. Trace.WriteLine(string.Format("EnqueueMessage logOn2 posValidationSource='{0}'", System.Text.Encoding.ASCII.GetString(posValidationSource, 0, posValidationSource.Length)));
  1164. byte[] posValidation = crypter.ComputeHash(posValidationSource);
  1165. posDataElem.posValidation = "";
  1166. StringBuilder sb = new StringBuilder(posValidation.Length * 2);
  1167. foreach (byte b in posValidation)
  1168. sb.Append(Convert.ToString(b, 16).PadLeft(2, '0'));
  1169. posDataElem.posValidation = sb.ToString().ToUpper();
  1170. Trace.WriteLine(string.Format("EnqueueMessage logOn2 posValidationSource='{0}',posValidation='{1}'", posValidationSource, posDataElem.posValidation));
  1171. ServiceRequestPOSdataLogOn[] posDataArray = { posDataElem };
  1172. ((ServiceRequestLogOn)logOn).POSdata = posDataArray;
  1173. }
  1174. Trace.WriteLine("EnqueueMessage logOn2");
  1175. clientSocket.ifsfMessages.EnqueueMessage(logOn, null, null, null, true);
  1176. Trace.WriteLine("LogOn2 end");
  1177. }
  1178. catch (Exception ex)
  1179. {
  1180. Trace.WriteLine("LogOn2 Exception! " + ex.Message + " - " + ex.StackTrace);
  1181. }
  1182. }
  1183. public void LogOnAddValidationInfo(byte[] validationInfo)
  1184. {
  1185. // POS open channel A and send LogOn command
  1186. // FDC open channel B and C and send LogOn response
  1187. try
  1188. {
  1189. if (validationInfo == null)
  1190. {
  1191. Trace.WriteLine("LogOnAddValidationInfo: null validationInfo");
  1192. return;
  1193. }
  1194. Trace.WriteLine("LogOnAddValidationInfo init");
  1195. if (this._clientSocket.logOnSendCalled && this._clientSocket.validationInfo != null)
  1196. {
  1197. this._clientSocket.validationInfo = null;
  1198. this._clientSocket.logOnSendCalled = false;
  1199. Trace.WriteLine("LogOnAddValidationInfo logOnSendCalled=false");
  1200. }
  1201. byte[][] ValidationInfo = this._clientSocket.validationInfo;
  1202. IFSFManager.ArrayResize<byte[]>(ref ValidationInfo, (ValidationInfo != null) ? ValidationInfo.Length + 1 : 1);
  1203. this._clientSocket.validationInfo = ValidationInfo;
  1204. this._clientSocket.validationInfo[this._clientSocket.validationInfo.Length - 1] = new byte[validationInfo.Length];
  1205. this._clientSocket.validationInfo[this._clientSocket.validationInfo.Length - 1] = validationInfo;
  1206. Trace.WriteLine("LogOnAddValidationInfo end");
  1207. }
  1208. catch (Exception ex)
  1209. {
  1210. Trace.WriteLine("LogOnAddValidationInfo Exception! " + ex.Message + " - " + ex.StackTrace);
  1211. }
  1212. }
  1213. public void LogOnSend(string posInfo)
  1214. {
  1215. // POS open channel A and send LogOn command
  1216. // FDC open channel B and C and send LogOn response
  1217. try
  1218. {
  1219. Trace.WriteLine("LogOnSend init");
  1220. // create XML ServiceRequest object
  1221. if (serviceRequestLogOn == null)
  1222. {
  1223. LogOn(posInfo, "");
  1224. }
  1225. else
  1226. {
  1227. Trace.WriteLine("EnqueueMessage logOn");
  1228. ServiceRequest logOn;
  1229. if (FDCGlobal.ProtocolVersion <= FDCVersion.V0007)
  1230. logOn = new ServiceRequestLogOnV07();
  1231. else
  1232. logOn = new ServiceRequestLogOn();
  1233. logOn = serviceRequestLogOn;
  1234. serviceRequestLogOn = null;
  1235. clientSocket.ifsfMessages.EnqueueMessage(logOn, (EventHandler<AsyncCompletedEventArgs>)null, null, null, true);
  1236. }
  1237. this._clientSocket.logOnSendCalled = true;
  1238. Trace.WriteLine("LogOnSend logOnSendCalled=true");
  1239. Trace.WriteLine("LogOnSend end");
  1240. }
  1241. catch (Exception ex)
  1242. {
  1243. Trace.WriteLine("LogOnSend Exception! " + ex.Message + " - " + ex.StackTrace);
  1244. }
  1245. }
  1246. public void LogOnResp(string sOverallResult, string seal, string sFDCTimeStamp)
  1247. {
  1248. try
  1249. {
  1250. if (sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString())
  1251. {
  1252. // must be called after LogOn successful because the server must register the client before receiving messages
  1253. heartbeat.Restart();
  1254. GetCountrySettings(null, null, null);
  1255. // check if != Connected becose FDCStart (that set state to Connected) could became before LogOnResp
  1256. if (clientSocket.mainConnectionState != DeviceConnectionState.Connected)
  1257. clientSocket.mainConnectionState = DeviceConnectionState.Connecting;
  1258. if (seal != "" && OnDeviceAlarm != null)
  1259. {
  1260. string deviceType = "";
  1261. int deviceId = 0;
  1262. int alarmId = 2020; // FUSION_IMSG_SEAL
  1263. string alarmmsg = seal;
  1264. OnDeviceAlarm.BeginInvoke(this, new DeviceAlarmEventArgs(deviceType, deviceId, alarmId, alarmmsg), null, null);
  1265. }
  1266. }
  1267. else if (sOverallResult == FDCPOSLibrary.OverallResult.AuthentificationError.ToString())
  1268. {
  1269. Trace.WriteLine(string.Format("authentificationErrorRetry={0}, sFDCTimeStamp={1}", authentificationErrorRetry, sFDCTimeStamp));
  1270. if (authentificationErrorRetry)
  1271. {
  1272. authentificationErrorRetry = false;
  1273. this.LogOn(clientSocket.validationInfo, clientSocket.posInfo, sFDCTimeStamp);
  1274. }
  1275. else if (OnDeviceAlarm != null)
  1276. {
  1277. authentificationErrorRetry = true;
  1278. string deviceType = "";
  1279. int deviceId = 0;
  1280. int alarmId = 1001; //FUSION_E_AUTHENTIFICATION_FAILED
  1281. string alarmmsg = "";
  1282. OnDeviceAlarm.BeginInvoke(this, new DeviceAlarmEventArgs(deviceType, deviceId, alarmId, alarmmsg), null, null);
  1283. }
  1284. }
  1285. }
  1286. catch (Exception ex)
  1287. {
  1288. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1289. }
  1290. }
  1291. public void LogOff()
  1292. {
  1293. // POS send LogOff command and close channel A
  1294. // FDC send LogOff response and close channel B and C
  1295. try
  1296. {
  1297. Trace.WriteLine("init");
  1298. // create XML ServiceRequest object
  1299. ServiceRequestLogOff logOff = new ServiceRequestLogOff();
  1300. logOff.ApplicationSender = clientSocket.applicationSender;
  1301. logOff.WorkstationID = clientSocket.workstationID;
  1302. ServiceRequestPOSdataLogOff posDataElem = new ServiceRequestPOSdataLogOff();
  1303. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  1304. ServiceRequestPOSdataLogOff[] posDataArray = { posDataElem };
  1305. logOff.POSdata = posDataArray;
  1306. Trace.WriteLine("EnqueueMessage logOn");
  1307. clientSocket.ifsfMessages.EnqueueMessage(logOff, (EventHandler<AsyncCompletedEventArgs>)null, null, null, true);
  1308. Trace.WriteLine("end");
  1309. }
  1310. catch (Exception ex)
  1311. {
  1312. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1313. }
  1314. }
  1315. public void LogOffResp(string sOverallResult)
  1316. {
  1317. try
  1318. {
  1319. if (sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString())
  1320. {
  1321. if (clientSocket.mainConnectionState != DeviceConnectionState.Connected || clientSocket.mainConnectionState != DeviceConnectionState.Connecting)
  1322. clientSocket.mainConnectionState = DeviceConnectionState.Disconnecting;
  1323. }
  1324. }
  1325. catch (Exception ex)
  1326. {
  1327. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1328. }
  1329. }
  1330. public void Heartbeat()
  1331. {
  1332. try
  1333. {
  1334. //if (!heartbeat.tryingConnect)
  1335. if (clientSocket.ConnectionState == DeviceConnectionState.Connected) // sometimes tryingConnect messed up
  1336. {
  1337. ServiceRequestHeartbeat heartbeatmsg = new ServiceRequestHeartbeat();
  1338. heartbeatmsg.ApplicationSender = this.clientSocket.applicationSender;
  1339. heartbeatmsg.WorkstationID = this.clientSocket.workstationID;
  1340. ServiceRequestPOSReady srPosready = new ServiceRequestPOSReady();
  1341. srPosready.ApplicationSender = this.clientSocket.applicationSender;
  1342. srPosready.WorkstationID = this.clientSocket.workstationID;
  1343. POSMessagePOSReady msgPOSReady = new POSMessagePOSReady();
  1344. msgPOSReady.ApplicationSender = this.clientSocket.applicationSender;
  1345. msgPOSReady.WorkstationID = this.clientSocket.workstationID;
  1346. Trace.WriteLine(string.Format("new POSReady: type={0},id={1}, counter={2}", msgPOSReady.MessageType, msgPOSReady.MessageID, FDCMessage.requestIDConter));
  1347. ServiceRequestPOSdataHeartbeat posDataElem = new ServiceRequestPOSdataHeartbeat();
  1348. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  1349. ServiceRequestPOSdataHeartbeat[] posDataArray = { posDataElem };
  1350. heartbeatmsg.POSdata = posDataArray;
  1351. srPosready.POSdata = posDataArray;
  1352. msgPOSReady.POSdata = posDataArray;
  1353. heartbeat.Restart();
  1354. bool useSRPOSReady = false;
  1355. if (FDCGlobal.ProtocolVersion <= FDCVersion.V0007)
  1356. clientSocket.ifsfMessages.EnqueueMessage(heartbeatmsg, (EventHandler<AsyncCompletedEventArgs>)null, null, null, false);
  1357. else if (useSRPOSReady)
  1358. clientSocket.ifsfMessages.EnqueueMessage(srPosready, (EventHandler<AsyncCompletedEventArgs>)null, null, null, false);
  1359. else
  1360. clientSocket.ifsfMessages.EnqueueMessage(msgPOSReady, (EventHandler<AsyncCompletedEventArgs>)null, null, null, false);
  1361. }
  1362. else
  1363. {
  1364. //if (!heartbeat.connecting)
  1365. {
  1366. //heartbeat.connecting = true;
  1367. if (this.clientSocket.respChannelBThreadObj != null && !this.clientSocket.respChannelBThreadObj.bRunning)
  1368. {
  1369. if (this.clientSocket.ConnectionState == DeviceConnectionState.Connecting)
  1370. {
  1371. // we need to disconnect first. Otherwise Connect() will ignore because it's in Connecting state.
  1372. // It can stuck in Connecting state forever if GetCountrySetting lost (timeout)
  1373. if (count > 5) // 60 seconds already
  1374. {
  1375. Disconnect();
  1376. count = 0;
  1377. }
  1378. count++;
  1379. }
  1380. else if (this.clientSocket.Connect(""))
  1381. {
  1382. //heartbeat.connecting = false;
  1383. heartbeat.tryingConnect = false;
  1384. // WJU - restart heartbeat
  1385. heartbeat.Restart();
  1386. }
  1387. }
  1388. else // either null or running, we need to restart even it's connecting because connecting could have been timed out
  1389. {
  1390. //Disconnect running ChannelB thread
  1391. Disconnect();
  1392. // WJU - 11/1/12, let next heartbeat handle reconnect
  1393. }
  1394. // Restart Timeout timer because NotifyDisconnection disposed it!!!
  1395. heartbeat.ResetDisconnectionTimeout();
  1396. }
  1397. }
  1398. }
  1399. catch (Exception ex)
  1400. {
  1401. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1402. }
  1403. }
  1404. public void VersionInfo(EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  1405. {
  1406. try
  1407. {
  1408. // create XML ServiceRequest object
  1409. ServiceRequestVersionInfo sr = new ServiceRequestVersionInfo();
  1410. sr.ApplicationSender = this.clientSocket.applicationSender;
  1411. sr.WorkstationID = this.clientSocket.workstationID;
  1412. ServiceRequestPOSdataVersionInfo posDataElem = new ServiceRequestPOSdataVersionInfo();
  1413. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  1414. ServiceRequestPOSdataVersionInfo[] posDataArray = { posDataElem };
  1415. sr.POSdata = posDataArray;
  1416. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  1417. }
  1418. catch (Exception ex)
  1419. {
  1420. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1421. }
  1422. }
  1423. public void VersionInfoResp(int requestId, string sOverallResult, ServiceResponseVersionInfo sr)
  1424. {
  1425. try
  1426. {
  1427. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  1428. if (OnVersionInfo != null)
  1429. {
  1430. OnVersionInfo.BeginInvoke(this, new VersionInfoEventArgs(sr.FDCdata[0].FDCversion, sr.FDCdata[0].FDCrelease, sr.FDCdata[0].FDChotfix), null, null);
  1431. }
  1432. }
  1433. catch (Exception ex)
  1434. {
  1435. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1436. }
  1437. }
  1438. public void StartForecourt(EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  1439. {
  1440. try
  1441. {
  1442. // create XML ServiceRequest object
  1443. ServiceRequestStartForecourt sr = new ServiceRequestStartForecourt();
  1444. sr.ApplicationSender = this.clientSocket.applicationSender;
  1445. sr.WorkstationID = this.clientSocket.workstationID;
  1446. ServiceRequestPOSdataStartForecourt posDataElem = new ServiceRequestPOSdataStartForecourt();
  1447. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  1448. ServiceRequestPOSdataStartForecourt[] posDataArray = { posDataElem };
  1449. sr.POSdata = posDataArray;
  1450. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  1451. }
  1452. catch (Exception ex)
  1453. {
  1454. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1455. }
  1456. }
  1457. public void TwinOpenMaster(EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  1458. {
  1459. try
  1460. {
  1461. // create XML ServiceRequest object
  1462. ServiceRequestTwinOpenMaster sr = new ServiceRequestTwinOpenMaster();
  1463. sr.ApplicationSender = this.clientSocket.applicationSender;
  1464. sr.WorkstationID = this.clientSocket.workstationID;
  1465. ServiceRequestPOSdataTwinOpenMaster posDataElem = new ServiceRequestPOSdataTwinOpenMaster();
  1466. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  1467. ServiceRequestPOSdataTwinOpenMaster[] posDataArray = { posDataElem };
  1468. sr.POSdata = posDataArray;
  1469. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  1470. }
  1471. catch (Exception ex)
  1472. {
  1473. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1474. }
  1475. }
  1476. public void StartForecourtResp(int requestId, string sOverallResult, string errorCode)
  1477. {
  1478. try
  1479. {
  1480. //QQ-this.clientSocket.mainConnectionState = DeviceConnectionState.Connected;
  1481. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, errorCode == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  1482. }
  1483. catch (Exception ex)
  1484. {
  1485. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1486. }
  1487. }
  1488. public void TwinOpenMasterResp(int requestId, string sOverallResult, string errorCode)
  1489. {
  1490. try
  1491. {
  1492. //QQ-this.clientSocket.mainConnectionState = DeviceConnectionState.Connected;
  1493. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, errorCode == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  1494. }
  1495. catch (Exception ex)
  1496. {
  1497. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1498. }
  1499. }
  1500. public void StopForecourt(EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  1501. {
  1502. try
  1503. {
  1504. // create XML ServiceRequest object
  1505. ServiceRequestStopForecourt sr = new ServiceRequestStopForecourt();
  1506. sr.ApplicationSender = this.clientSocket.applicationSender;
  1507. sr.WorkstationID = this.clientSocket.workstationID;
  1508. ServiceRequestPOSdataStopForecourt posDataElem = new ServiceRequestPOSdataStopForecourt();
  1509. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  1510. posDataElem.EmergencyStop = "false";
  1511. ServiceRequestPOSdataStopForecourt[] posDataArray = { posDataElem };
  1512. sr.POSdata = posDataArray;
  1513. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  1514. }
  1515. catch (Exception ex)
  1516. {
  1517. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1518. }
  1519. }
  1520. public void StopForecourtResp(int requestId, string sOverallResult, string errorCode)
  1521. {
  1522. try
  1523. {
  1524. // TODO
  1525. // ....
  1526. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, errorCode == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  1527. }
  1528. catch (Exception ex)
  1529. {
  1530. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1531. }
  1532. }
  1533. public void GetCurrentFuellingStatus(int pumpId, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  1534. {
  1535. try
  1536. {
  1537. // create XML ServiceRequest object
  1538. ServiceRequestGetCurrentFuellingStatus sr = new ServiceRequestGetCurrentFuellingStatus();
  1539. sr.ApplicationSender = this.clientSocket.applicationSender;
  1540. sr.WorkstationID = this.clientSocket.workstationID;
  1541. ServiceRequestPOSdataGetCurrentFuellingStatus posDataElem = new ServiceRequestPOSdataGetCurrentFuellingStatus();
  1542. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  1543. ServiceRequestDeviceClass deviceClass = new ServiceRequestDeviceClass();
  1544. deviceClass.DeviceID = (pumpId == -1) ? "*" : Convert.ToString(pumpId);
  1545. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuellingPoint;
  1546. posDataElem.DeviceClass = deviceClass;
  1547. ServiceRequestPOSdataGetCurrentFuellingStatus[] posDataArray = { posDataElem };
  1548. sr.POSdata = posDataArray;
  1549. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  1550. }
  1551. catch (Exception ex)
  1552. {
  1553. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1554. }
  1555. }
  1556. public void GetFuelPointTotals(int pumpId, int nozzleId, EventHandler<AsyncCompletedEventArgs<PumpAccumulatorReading>> requestCompleted, object userToken, object src)
  1557. {
  1558. try
  1559. {
  1560. // create XML ServiceRequest object
  1561. ServiceRequestGetFuelPointTotals sr = new ServiceRequestGetFuelPointTotals();
  1562. sr.ApplicationSender = this.clientSocket.applicationSender;
  1563. sr.WorkstationID = this.clientSocket.workstationID;
  1564. ServiceRequestPOSdataGetFuelPointTotals posDataElem = new ServiceRequestPOSdataGetFuelPointTotals();
  1565. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  1566. ServiceRequestDeviceClassGetFuelPointTotals deviceClass = new ServiceRequestDeviceClassGetFuelPointTotals();
  1567. deviceClass.DeviceID = (pumpId == -1) ? "*" : Convert.ToString(pumpId);
  1568. deviceClass.NozzleNo = (nozzleId == -1) ? "*" : Convert.ToString(nozzleId);
  1569. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuellingPoint;
  1570. posDataElem.DeviceClass = deviceClass;
  1571. ServiceRequestPOSdataGetFuelPointTotals[] posDataArray = { posDataElem };
  1572. sr.POSdata = posDataArray;
  1573. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true, null);
  1574. }
  1575. catch (Exception ex)
  1576. {
  1577. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1578. }
  1579. }
  1580. public void GetCurrentFuellingStatusResp(int requestId, string sOverallResult, ServiceResponseGetCurrentFuellingStatus sr)
  1581. {
  1582. try
  1583. {
  1584. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("init GetCurrentFuellingStatusResp"));
  1585. if (OnCurrentFuellingStatus != null && sr.FDCdata[0] != null && sr.FDCdata[0].DeviceClass != null)
  1586. {
  1587. for (int i = 0; i < sr.FDCdata[0].DeviceClass.Length; i++)
  1588. {
  1589. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("type={0}, id={1}, volume={2}, amount={3}", sr.FDCdata[0].DeviceClass[i].Type, sr.FDCdata[0].DeviceClass[i].DeviceID, sr.FDCdata[0].DeviceClass[i].CurrentVolume, sr.FDCdata[0].DeviceClass[i].CurrentAmount));
  1590. string deviceType = sr.FDCdata[0].DeviceClass[i].Type;
  1591. int deviceId = Convert.ToInt16(sr.FDCdata[0].DeviceClass[i].DeviceID);
  1592. int nozzleId = Convert.ToInt16(sr.FDCdata[0].DeviceClass[i].CurrentNozzle);
  1593. Decimal volume = FDCConvert.ToDecimal(sr.FDCdata[0].DeviceClass[i].CurrentVolume);
  1594. Decimal amount = FDCConvert.ToDecimal(sr.FDCdata[0].DeviceClass[i].CurrentAmount);
  1595. Decimal price = FDCConvert.ToDecimal(sr.FDCdata[0].DeviceClass[i].CurrentUnitPrice);
  1596. string authAS = sr.FDCdata[0].DeviceClass[i].AuthorisationApplicationSender;
  1597. OnCurrentFuellingStatus.BeginInvoke(this, new CurrentFuellingStatusEventArgs(deviceType, deviceId, nozzleId, volume, amount, price, authAS), null, null);
  1598. }
  1599. }
  1600. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("end GetCurrentFuellingStatusResp"));
  1601. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  1602. }
  1603. catch (Exception ex)
  1604. {
  1605. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1606. }
  1607. }
  1608. public void GetFuelPointTotalsResp(int requestId, string sOverallResult, ServiceResponseGetFuelPointTotals sr)
  1609. {
  1610. // TODO
  1611. try
  1612. {
  1613. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("init GetFuelPointTotalsResp"));
  1614. if (OnFuelPointTotals != null && sr.FDCdata[0] != null && sr.FDCdata[0].DeviceClass != null)
  1615. for (int i = 0; i < sr.FDCdata[0].DeviceClass.Length; i++)
  1616. {
  1617. Trace.WriteLine(string.Format("type={0}, id={1}, volume={2}, amount={3}", sr.FDCdata[0].DeviceClass[i].Type, sr.FDCdata[0].DeviceClass[i].DeviceID, sr.FDCdata[0].DeviceClass[i].Volume, sr.FDCdata[0].DeviceClass[i].Amount));
  1618. string deviceType = sr.FDCdata[0].DeviceClass[i].Type;
  1619. int deviceId = Convert.ToInt16(sr.FDCdata[0].DeviceClass[i].DeviceID);
  1620. int nozzleId = Convert.ToInt16(sr.FDCdata[0].DeviceClass[i].NozzleNo);
  1621. Decimal volume = FDCConvert.ToDecimal(sr.FDCdata[0].DeviceClass[i].Volume);
  1622. Decimal amount = FDCConvert.ToDecimal(sr.FDCdata[0].DeviceClass[i].Amount);
  1623. Decimal price = FDCConvert.ToDecimal(sr.FDCdata[0].DeviceClass[i].UnitPrice);
  1624. OnFuelPointTotals.BeginInvoke(this, new FuelPointTotalsEventArgs(requestId, sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString(),
  1625. deviceType, deviceId, nozzleId, volume, amount, price), null, null);
  1626. }
  1627. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("end GetFuelPointTotalsResp"));
  1628. //PumpAccumulatorReading pumpAccumulatorReading = new PumpAccumulatorReading(this.pump, nozzle, 0, PumpAccumulatorReadingType.RequestedReading,
  1629. // FDCConvert.ToDecimal(sr.FDCdata[0].DeviceClass[i].Volume), FDCConvert.ToDecimal(sr.FDCdata[0].DeviceClass[i].Amount));
  1630. //clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString(), pumpAccumulatorReading);
  1631. }
  1632. catch (Exception ex)
  1633. {
  1634. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1635. }
  1636. }
  1637. public void GetDeviceState(string deviceType, int deviceId, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  1638. {
  1639. try
  1640. {
  1641. Trace.WriteLine(string.Format("GetDeviceState init: deviceId={0}, deviceType={1}", deviceId, deviceType));
  1642. // create XML ServiceRequest object
  1643. if (deviceType == Wayne.FDCPOSLibrary.DeviceType.DT_FuellingPoint && !ConfigParam.IsEMSGVersion)
  1644. {
  1645. ServiceRequestGetFPState sr = new ServiceRequestGetFPState();
  1646. sr.ApplicationSender = this.clientSocket.applicationSender;
  1647. sr.WorkstationID = this.clientSocket.workstationID;
  1648. ServiceRequestPOSdataGetDeviceState posDataElem = new ServiceRequestPOSdataGetDeviceState();
  1649. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  1650. ServiceRequestDeviceClass deviceClass = new ServiceRequestDeviceClass();
  1651. deviceClass.DeviceID = (deviceId == -1) ? "*" : Convert.ToString(deviceId);
  1652. deviceClass.Type = deviceType;
  1653. posDataElem.DeviceClass = deviceClass;
  1654. ServiceRequestPOSdataGetDeviceState[] posDataArray = { posDataElem };
  1655. sr.POSdata = posDataArray;
  1656. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  1657. }
  1658. else if (deviceType == Wayne.FDCPOSLibrary.DeviceType.DT_TankProbe || deviceType == Wayne.FDCPOSLibrary.DeviceType.DT_TankLevelGauge)
  1659. {
  1660. ServiceRequestGetTPState sr = new ServiceRequestGetTPState();
  1661. sr.ApplicationSender = this.clientSocket.applicationSender;
  1662. sr.WorkstationID = this.clientSocket.workstationID;
  1663. ServiceRequestPOSdataGetDeviceState posDataElem = new ServiceRequestPOSdataGetDeviceState();
  1664. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  1665. ServiceRequestDeviceClass deviceClass = new ServiceRequestDeviceClass();
  1666. deviceClass.DeviceID = (deviceId == -1) ? "*" : Convert.ToString(deviceId);
  1667. deviceClass.Type = deviceType;
  1668. posDataElem.DeviceClass = deviceClass;
  1669. ServiceRequestPOSdataGetDeviceState[] posDataArray = { posDataElem };
  1670. sr.POSdata = posDataArray;
  1671. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  1672. }
  1673. else if (deviceType == Wayne.FDCPOSLibrary.DeviceType.DT_Vir)
  1674. {
  1675. ServiceRequestGetVIRState sr = new ServiceRequestGetVIRState();
  1676. sr.ApplicationSender = this.clientSocket.applicationSender;
  1677. sr.WorkstationID = this.clientSocket.workstationID;
  1678. ServiceRequestPOSdataGetDeviceState posDataElem = new ServiceRequestPOSdataGetDeviceState();
  1679. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  1680. ServiceRequestDeviceClass deviceClass = new ServiceRequestDeviceClass();
  1681. deviceClass.DeviceID = (deviceId == -1) ? "*" : Convert.ToString(deviceId);
  1682. deviceClass.Type = deviceType;
  1683. posDataElem.DeviceClass = deviceClass;
  1684. ServiceRequestPOSdataGetDeviceState[] posDataArray = { posDataElem };
  1685. sr.POSdata = posDataArray;
  1686. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  1687. }
  1688. else if (deviceType == Wayne.FDCPOSLibrary.DeviceType.DT_PricePole || deviceType == Wayne.FDCPOSLibrary.DeviceType.DT_PricePolePoint)
  1689. {
  1690. ServiceRequestGetPPState sr = new ServiceRequestGetPPState();
  1691. sr.ApplicationSender = this.clientSocket.applicationSender;
  1692. sr.WorkstationID = this.clientSocket.workstationID;
  1693. ServiceRequestPOSdataGetDeviceState posDataElem = new ServiceRequestPOSdataGetDeviceState();
  1694. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  1695. ServiceRequestDeviceClass deviceClass = new ServiceRequestDeviceClass();
  1696. deviceClass.DeviceID = (deviceId == -1) ? "*" : Convert.ToString(deviceId);
  1697. deviceClass.Type = deviceType;
  1698. posDataElem.DeviceClass = deviceClass;
  1699. ServiceRequestPOSdataGetDeviceState[] posDataArray = { posDataElem };
  1700. sr.POSdata = posDataArray;
  1701. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  1702. }
  1703. else
  1704. {
  1705. ServiceRequestGetDeviceState sr = new ServiceRequestGetDeviceState();
  1706. sr.ApplicationSender = this.clientSocket.applicationSender;
  1707. sr.WorkstationID = this.clientSocket.workstationID;
  1708. ServiceRequestPOSdataGetDeviceState posDataElem = new ServiceRequestPOSdataGetDeviceState();
  1709. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  1710. ServiceRequestDeviceClass deviceClass = new ServiceRequestDeviceClass();
  1711. deviceClass.DeviceID = (deviceId == -1) ? "*" : Convert.ToString(deviceId);
  1712. deviceClass.Type = deviceType;
  1713. posDataElem.DeviceClass = deviceClass;
  1714. ServiceRequestPOSdataGetDeviceState[] posDataArray = { posDataElem };
  1715. sr.POSdata = posDataArray;
  1716. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  1717. }
  1718. Trace.WriteLine(string.Format("GetDeviceState end: deviceId={0}, deviceType={1}", deviceId, deviceType));
  1719. }
  1720. catch (Exception ex)
  1721. {
  1722. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1723. }
  1724. }
  1725. public void GetDeviceStateResp(int requestId, string sOverallResult, ServiceResponseGetDeviceState sr)
  1726. {
  1727. try
  1728. {
  1729. if (OnDeviceStateChange != null && sr.FDCdata[0] != null && sr.FDCdata[0].DeviceClass != null)
  1730. {
  1731. for (int i = 0; i < sr.FDCdata[0].DeviceClass.Length; i++)
  1732. {
  1733. Trace.WriteLine(string.Format("type={0}, id={1}, state={2}, substate={3}", sr.FDCdata[0].DeviceClass[0].Type, sr.FDCdata[0].DeviceClass[i].DeviceID, sr.FDCdata[0].DeviceClass[i].LogicalState, sr.FDCdata[0].DeviceClass[i].LogicalSubState));
  1734. string deviceType = sr.FDCdata[0].DeviceClass[i].Type;
  1735. int deviceId = Convert.ToInt16(sr.FDCdata[0].DeviceClass[i].DeviceID);
  1736. LogicalDeviceState state = this.convertLogicalDeviceState((sr.FDCdata[0].DeviceClass[i].LogicalState != null && sr.FDCdata[0].DeviceClass[i].LogicalState != "") ? sr.FDCdata[0].DeviceClass[i].LogicalState : sr.FDCdata[0].DeviceClass[i].DeviceState);
  1737. LogicalDeviceState substate = convertLogicalDeviceState((sr.FDCdata[0].DeviceClass[i].LogicalSubState != null && sr.FDCdata[0].DeviceClass[i].LogicalSubState != "") ? sr.FDCdata[0].DeviceClass[i].LogicalSubState : sr.FDCdata[0].DeviceClass[i].DeviceSubState);
  1738. int nozzleUp = 0;
  1739. if (sr.FDCdata[0].DeviceClass[i].Nozzle != null)
  1740. {
  1741. foreach (NozzleStateClass nozzleState in sr.FDCdata[0].DeviceClass[i].Nozzle)
  1742. {
  1743. if (nozzleState.LogicalNozzle == "NozzleUp")
  1744. nozzleUp = Convert.ToInt32(nozzleState.NozzleNo);
  1745. }
  1746. }
  1747. OnDeviceStateChange.Invoke(this, new DeviceStateChangedEventArgs(deviceType, deviceId, state, substate, "", nozzleUp));
  1748. }
  1749. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  1750. }
  1751. Trace.WriteLine(string.Format("end"));
  1752. }
  1753. catch (Exception ex)
  1754. {
  1755. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1756. }
  1757. }
  1758. public void GetFPStateResp(int requestId, string sOverallResult, ServiceResponseGetFPState sr)
  1759. {
  1760. try
  1761. {
  1762. if (OnDeviceStateChange != null && sr.FDCdata[0] != null && sr.FDCdata[0].DeviceClass != null)
  1763. {
  1764. if (sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString())
  1765. {
  1766. for (int i = 0; i < sr.FDCdata[0].DeviceClass.Length; i++)
  1767. {
  1768. Trace.WriteLine(string.Format("type={0}, id={1}, state={2}, substate={3}", sr.FDCdata[0].DeviceClass[0].Type, sr.FDCdata[0].DeviceClass[i].DeviceID, sr.FDCdata[0].DeviceClass[i].DeviceState, sr.FDCdata[0].DeviceClass[i].DeviceSubState));
  1769. string deviceType = sr.FDCdata[0].DeviceClass[i].Type;
  1770. int deviceId = Convert.ToInt16(sr.FDCdata[0].DeviceClass[i].DeviceID);
  1771. LogicalDeviceState state = this.convertLogicalDeviceState(sr.FDCdata[0].DeviceClass[i].DeviceState);
  1772. LogicalDeviceState substate = convertLogicalDeviceState(sr.FDCdata[0].DeviceClass[i].DeviceSubState);
  1773. string lockingAS = sr.FDCdata[0].DeviceClass[i].LockingApplicationSender;
  1774. int nozzleUp = 0;
  1775. if (sr.FDCdata[0].DeviceClass[i].Nozzle != null)
  1776. {
  1777. foreach (NozzleStateClass nozzleState in sr.FDCdata[0].DeviceClass[i].Nozzle)
  1778. {
  1779. if (nozzleState.LogicalNozzle == "NozzleUp")
  1780. nozzleUp = Convert.ToInt32(nozzleState.NozzleNo);
  1781. }
  1782. }
  1783. OnDeviceStateChange.Invoke(this, new DeviceStateChangedEventArgs(deviceType, deviceId, state, substate, lockingAS, nozzleUp));
  1784. }
  1785. }
  1786. else
  1787. Trace.WriteLine(string.Format("overallResult={0}", sOverallResult));
  1788. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  1789. }
  1790. Trace.WriteLine(string.Format("end"));
  1791. }
  1792. catch (Exception ex)
  1793. {
  1794. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1795. }
  1796. }
  1797. public void GetTPStateResp(int requestId, string sOverallResult, ServiceResponseGetTPState sr)
  1798. {
  1799. try
  1800. {
  1801. if (OnDeviceStateChange != null && sr.FDCdata[0] != null && sr.FDCdata[0].DeviceClass != null)
  1802. {
  1803. for (int i = 0; i < sr.FDCdata[0].DeviceClass.Length; i++)
  1804. {
  1805. Trace.WriteLine(string.Format("type={0}, id={1}, state={2}", sr.FDCdata[0].DeviceClass[0].Type, sr.FDCdata[0].DeviceClass[i].DeviceID, sr.FDCdata[0].DeviceClass[i].DeviceState));
  1806. string deviceType = sr.FDCdata[0].DeviceClass[i].Type;
  1807. int deviceId = Convert.ToInt16(sr.FDCdata[0].DeviceClass[i].DeviceID);
  1808. LogicalDeviceState state = this.convertLogicalDeviceState(sr.FDCdata[0].DeviceClass[i].DeviceState);
  1809. LogicalDeviceState substate = convertLogicalDeviceState(sr.FDCdata[0].DeviceClass[i].DeviceSubState);
  1810. string lockingAS = sr.FDCdata[0].DeviceClass[i].LockingApplicationSender;
  1811. OnDeviceStateChange.Invoke(this, new DeviceStateChangedEventArgs(deviceType, deviceId, state, substate, lockingAS, 0));
  1812. }
  1813. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  1814. }
  1815. Trace.WriteLine(string.Format("end"));
  1816. }
  1817. catch (Exception ex)
  1818. {
  1819. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1820. }
  1821. }
  1822. public void GetPPStateResp(int requestId, string sOverallResult, ServiceResponseGetPPState sr)
  1823. {
  1824. try
  1825. {
  1826. if (OnDeviceStateChange != null && sr.FDCdata[0] != null && sr.FDCdata[0].DeviceClass != null)
  1827. {
  1828. for (int i = 0; i < sr.FDCdata[0].DeviceClass.Length; i++)
  1829. {
  1830. Trace.WriteLine(string.Format("type={0}, id={1}, state={2}", sr.FDCdata[0].DeviceClass[0].Type, sr.FDCdata[0].DeviceClass[i].DeviceID, sr.FDCdata[0].DeviceClass[i].DeviceState));
  1831. string deviceType = sr.FDCdata[0].DeviceClass[i].Type;
  1832. int deviceId = Convert.ToInt16(sr.FDCdata[0].DeviceClass[i].DeviceID);
  1833. LogicalDeviceState state = this.convertLogicalDeviceState(sr.FDCdata[0].DeviceClass[i].DeviceState);
  1834. //OnDeviceStateChange.BeginInvoke(this, new DeviceStateChangedEventArgs(deviceType, deviceId, state, substate, lockingAS, nozzleUp), null, null);
  1835. }
  1836. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  1837. }
  1838. Trace.WriteLine(string.Format("end"));
  1839. }
  1840. catch (Exception ex)
  1841. {
  1842. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1843. }
  1844. }
  1845. public void GetVIRStateResp(int requestId, string sOverallResult, ServiceResponseGetVIRState sr)
  1846. {
  1847. try
  1848. {
  1849. if (OnVirStateChange != null && sr.FDCdata[0] != null && sr.FDCdata[0].DeviceClass != null)
  1850. {
  1851. for (int i = 0; i < sr.FDCdata[0].DeviceClass.Length; i++)
  1852. {
  1853. string deviceType = sr.FDCdata[0].DeviceClass[i].Type;
  1854. int deviceId = Convert.ToInt16(sr.FDCdata[0].DeviceClass[i].DeviceID);
  1855. DeviceConnectionState deviceState = DeviceConnectionState.Unknown;
  1856. if (sr.FDCdata[0].DeviceClass[i].Vir != null)
  1857. {
  1858. foreach (VIRStateClass virState in sr.FDCdata[0].DeviceClass[i].Vir)
  1859. {
  1860. Trace.WriteLine(string.Format("type={0}, id={1}, virId={2}, state={3}", sr.FDCdata[0].DeviceClass[0].Type, sr.FDCdata[0].DeviceClass[i].DeviceID, virState.VirID, virState.DeviceState));
  1861. LogicalDeviceState state = this.convertLogicalDeviceState(virState.DeviceState);
  1862. if (state == LogicalDeviceState.FDC_READY)
  1863. deviceState = DeviceConnectionState.Connected;
  1864. else if (state == LogicalDeviceState.FDC_OFFLINE)
  1865. deviceState = DeviceConnectionState.Disconnected;
  1866. else
  1867. deviceState = DeviceConnectionState.Unknown;
  1868. OnVirStateChange.BeginInvoke(this, new VIRStateChangedEventArgs(deviceId, virState.VirID, deviceState), null, null);
  1869. }
  1870. }
  1871. }
  1872. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  1873. }
  1874. Trace.WriteLine(string.Format("end"));
  1875. }
  1876. catch (Exception ex)
  1877. {
  1878. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1879. }
  1880. }
  1881. public void TerminateFuelling(int pumpId, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  1882. {
  1883. try
  1884. {
  1885. // create XML ServiceRequest object
  1886. ServiceRequestTerminateFuelling sr = new ServiceRequestTerminateFuelling();
  1887. sr.ApplicationSender = this.clientSocket.applicationSender;
  1888. sr.WorkstationID = this.clientSocket.workstationID;
  1889. ServiceRequestPOSdataTerminateFuelling posDataElem = new ServiceRequestPOSdataTerminateFuelling();
  1890. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  1891. ServiceRequestDeviceClass deviceClass = new ServiceRequestDeviceClass();
  1892. deviceClass.DeviceID = (pumpId == -1) ? "*" : Convert.ToString(pumpId);
  1893. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuellingPoint;
  1894. posDataElem.DeviceClass = deviceClass;
  1895. ServiceRequestPOSdataTerminateFuelling[] posDataArray = { posDataElem };
  1896. sr.POSdata = posDataArray;
  1897. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  1898. }
  1899. catch (Exception ex)
  1900. {
  1901. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1902. }
  1903. }
  1904. public void TerminateFuellingResp(int requestId, string sOverallResult, ServiceResponseTerminateFuelling sr)
  1905. {
  1906. try
  1907. {
  1908. string errorCode = (sr.FDCdata[0].FDCStatus != null) ? sr.FDCdata[0].FDCStatus : sr.FDCdata[0].DeviceClass[0].ErrorCode;
  1909. Trace.WriteLine(string.Format("type={0}, id={1}, errorCode={2}", sr.FDCdata[0].DeviceClass[0].Type, sr.FDCdata[0].DeviceClass[0].DeviceID, errorCode));
  1910. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, errorCode == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  1911. Trace.WriteLine(string.Format("end"));
  1912. }
  1913. catch (Exception ex)
  1914. {
  1915. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1916. }
  1917. }
  1918. public void AuthoriseFuelPoint(int pumpId, int transactionId, FuellingType fuellingType, byte reservingDeviceId, IAuthorizeParameters authParams, EventHandler<AsyncCompletedEventArgs<long>> requestCompleted, object userToken, object src)
  1919. {
  1920. try
  1921. {
  1922. // create XML ServiceRequest object
  1923. ServiceRequestAuthoriseFuelPoint sr = new ServiceRequestAuthoriseFuelPoint();
  1924. sr.ApplicationSender = this.clientSocket.applicationSender;
  1925. sr.WorkstationID = this.clientSocket.workstationID;
  1926. ServiceRequestPOSdataAuthoriseFuelPoint posDataElem = new ServiceRequestPOSdataAuthoriseFuelPoint();
  1927. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  1928. ServiceRequestDeviceClassAuthoriseFuelPoint authFP = new ServiceRequestDeviceClassAuthoriseFuelPoint();
  1929. authFP.DeviceID = (pumpId == -1) ? "*" : Convert.ToString(pumpId);
  1930. authFP.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuellingPoint;
  1931. if (authParams.PresetType == PresetType.Amount)
  1932. {
  1933. authFP.MaxTrxVolume = FDCConvert.ToString((Decimal)0);
  1934. authFP.MaxTrxAmount = FDCConvert.ToString(authParams.PresetValue);
  1935. }
  1936. else
  1937. {
  1938. authFP.MaxTrxVolume = FDCConvert.ToString(authParams.PresetValue);
  1939. authFP.MaxTrxAmount = FDCConvert.ToString((Decimal)0);
  1940. }
  1941. authFP.LockFuelSaleTrx = Convert.ToString(authParams.LockToReleaseClient);
  1942. authFP.ReleaseToken = string.Format("{0:X}", transactionId);
  1943. authFP.ReservingDeviceId = Convert.ToString(reservingDeviceId);
  1944. authFP.FuellingType = Convert.ToString((int)fuellingType);
  1945. //FG, OCT-13-10, Add PayType to show outdoor payment type on FM
  1946. authFP.PayType = Convert.ToString(authParams.PayType);
  1947. //Product[] products = new Product[8];
  1948. //Product product;
  1949. ReleasedProductsClass products = new ReleasedProductsClass();
  1950. AllowedFuelGrades fgs = (AllowedFuelGrades)(authParams.AllowedFuelGrade);
  1951. int count = 0;
  1952. products.Product = new ProductElementClass[fgs.Count];
  1953. for (int iFuelGrade = 0; iFuelGrade < fgs.Count; iFuelGrade++)
  1954. {
  1955. if (fgs[iFuelGrade])
  1956. {
  1957. products.Product[count] = new ProductElementClass();
  1958. products.Product[count].ProductNo = Convert.ToString(iFuelGrade);
  1959. //products[count] = product;
  1960. count++;
  1961. }
  1962. }
  1963. authFP.ReleasedProducts = products;
  1964. posDataElem.DeviceClass = authFP;
  1965. ServiceRequestPOSdataAuthoriseFuelPoint[] posDataArray = { posDataElem };
  1966. sr.POSdata = posDataArray;
  1967. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true, transactionId);
  1968. }
  1969. catch (Exception ex)
  1970. {
  1971. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1972. }
  1973. }
  1974. public void AuthoriseFuelPointResp(int requestId, string sOverallResult, ServiceResponseAuthoriseFuelPoint sr)
  1975. {
  1976. try
  1977. {
  1978. if (clientSocket.ifsfMessages.asyncResponseManager.AsyncResponseOperationList.ContainsKey(requestId))
  1979. {
  1980. AsyncResponseOperation asyncResponseOperation = (AsyncResponseOperation)(clientSocket.ifsfMessages.asyncResponseManager.AsyncResponseOperationList[requestId]);
  1981. try
  1982. {
  1983. asyncResponseOperation.resultLong = Int32.Parse(sr.FDCdata[0].DeviceClass.ReleaseToken, NumberStyles.HexNumber);
  1984. }
  1985. catch (Exception ex)
  1986. {
  1987. Trace.WriteLine("AuthoriseFuelPointResp Exception! cannot convert ReleaseToken to Int32");
  1988. }
  1989. }
  1990. string errorCode = (sr.FDCdata[0].FDCStatus != null) ? sr.FDCdata[0].FDCStatus : sr.FDCdata[0].DeviceClass.ErrorCode;
  1991. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, errorCode == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  1992. }
  1993. catch (Exception ex)
  1994. {
  1995. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  1996. }
  1997. }
  1998. public void ChangeFuelMode(int pumpId, int mode, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  1999. {
  2000. try
  2001. {
  2002. // create XML ServiceRequest object
  2003. ServiceRequestChangeFuelMode sr = new ServiceRequestChangeFuelMode();
  2004. if (FDCGlobal.ProtocolVersion <= FDCVersion.V0007)
  2005. sr.RequestType = "ChangeFuelMode";
  2006. else
  2007. sr.RequestType = "ChangeFPFuelMode";
  2008. sr.ApplicationSender = this.clientSocket.applicationSender;
  2009. sr.WorkstationID = this.clientSocket.workstationID;
  2010. ServiceRequestPOSdataChangeFuelMode posDataElem = new ServiceRequestPOSdataChangeFuelMode();
  2011. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  2012. ServiceRequestDeviceClassChangeFuelMode deviceClass = new ServiceRequestDeviceClassChangeFuelMode();
  2013. deviceClass.DeviceID = (pumpId == -1) ? "*" : Convert.ToString(pumpId);
  2014. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuellingPoint;
  2015. deviceClass.FuelMode = new FuelModeElementClass();
  2016. deviceClass.FuelMode.ModeNo = Convert.ToString(mode);
  2017. ServiceRequestDeviceClassChangeFuelMode[] deviceClassArray = { deviceClass };
  2018. posDataElem.DeviceClass = deviceClassArray;
  2019. ServiceRequestPOSdataChangeFuelMode[] posDataArray = { posDataElem };
  2020. sr.POSdata = posDataArray;
  2021. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  2022. }
  2023. catch (Exception ex)
  2024. {
  2025. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2026. }
  2027. }
  2028. public void ChangeFuelModeAdd(ServiceRequestChangeFuelMode sr, int pumpId, int mode, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  2029. {
  2030. // create XML ServiceRequest object
  2031. sr.ApplicationSender = this.clientSocket.applicationSender;
  2032. sr.WorkstationID = this.clientSocket.workstationID;
  2033. Trace.WriteLine(string.Format("ChangeFuelModeAdd init: sr.ApplicationSender={0}, sr.WorkstationID={1}, pumpId={2}, mode={3}", sr.ApplicationSender, sr.WorkstationID, pumpId, mode));
  2034. ServiceRequestPOSdataChangeFuelMode POSDataElem = null;
  2035. if (sr.POSdata != null)
  2036. POSDataElem = sr.POSdata[0];
  2037. else
  2038. {
  2039. ServiceRequestPOSdataChangeFuelMode[] POSDataArray = null;
  2040. Trace.WriteLine(string.Format("ChangeFuelModeAdd: new ServiceRequestPOSdataChangeFuelMode"));
  2041. POSDataElem = new ServiceRequestPOSdataChangeFuelMode();
  2042. ArrayResize<ServiceRequestPOSdataChangeFuelMode>(ref POSDataArray, (POSDataArray != null) ? POSDataArray.Length + 1 : 1);
  2043. POSDataArray[POSDataArray.Length - 1] = POSDataElem;
  2044. POSDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  2045. sr.POSdata = POSDataArray;
  2046. }
  2047. ServiceRequestDeviceClassChangeFuelMode devicemode = null;
  2048. if (POSDataElem.DeviceClass != null)
  2049. {
  2050. foreach (ServiceRequestDeviceClassChangeFuelMode devicemodeTemp in POSDataElem.DeviceClass)
  2051. if (devicemodeTemp.DeviceID == Convert.ToString(pumpId) && devicemodeTemp.ModeNo == Convert.ToString(mode))
  2052. {
  2053. devicemode = devicemodeTemp;
  2054. Trace.WriteLine(string.Format("ChangeFuelModeAdd: device/mode found"));
  2055. }
  2056. }
  2057. if (devicemode == null)
  2058. {
  2059. Trace.WriteLine(string.Format("ChangeFuelModeAdd: new mode"));
  2060. devicemode = new ServiceRequestDeviceClassChangeFuelMode();
  2061. devicemode.DeviceID = (pumpId == -1) ? "*" : Convert.ToString(pumpId);
  2062. devicemode.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuellingPoint;
  2063. devicemode.FuelMode = new FuelModeElementClass();
  2064. devicemode.FuelMode.ModeNo = Convert.ToString(mode);
  2065. ServiceRequestDeviceClassChangeFuelMode[] devicemodeArray = POSDataElem.DeviceClass;
  2066. ArrayResize<ServiceRequestDeviceClassChangeFuelMode>(ref devicemodeArray, (devicemodeArray != null) ? devicemodeArray.Length + 1 : 1);
  2067. Trace.WriteLine(string.Format("ChangeFuelModeAdd: resize devidemodeArray to '{0}' items", devicemodeArray.Length));
  2068. devicemodeArray[devicemodeArray.Length - 1] = devicemode;
  2069. POSDataElem.DeviceClass = devicemodeArray;
  2070. }
  2071. Trace.WriteLine(string.Format("ChangeFuelModeAdd end: sr.ApplicationSender={0}, sr.WorkstationID={1}", sr.ApplicationSender, sr.WorkstationID));
  2072. }
  2073. public void ChangeFuelModeSend(ServiceRequestChangeFuelMode sr, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  2074. {
  2075. Trace.WriteLine(string.Format("ChangeFuelModeSend init: sr.ApplicationSender={0}, sr.WorkstationID={1}", sr.ApplicationSender, sr.WorkstationID));
  2076. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  2077. Trace.WriteLine(string.Format("ChangeFuelModeSend end: sr.ApplicationSender={0}, sr.WorkstationID={1}", sr.ApplicationSender, sr.WorkstationID));
  2078. }
  2079. public void ChangeFuelModeResp(int requestId, string sOverallResult, ServiceResponseFDCdataChangeFuelMode[] fdcData)
  2080. {
  2081. try
  2082. {
  2083. Trace.WriteLine(string.Format("ChangeFuelModeResp sOverallResult={0}", sOverallResult));
  2084. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  2085. if (fdcData[0] != null && fdcData[0].DeviceClass != null)
  2086. {
  2087. for (int i = 0; i < fdcData[0].DeviceClass.Length; i++)
  2088. {
  2089. if (fdcData[0].DeviceClass[i].ErrorCode != null && fdcData[0].DeviceClass[i].ErrorCode != ErrorCode.ERRCD_OK.ToString() && fdcData[0].DeviceClass[i].ErrorCode != ErrorCode.ERRCD_NO.ToString())
  2090. {
  2091. Trace.WriteLine(string.Format("ChangeFuelModeResp type={0}, id={1}, errorCode={2}", fdcData[0].DeviceClass[i].Type, fdcData[0].DeviceClass[i].DeviceID, fdcData[0].DeviceClass[i].ErrorCode));
  2092. string deviceType = fdcData[0].DeviceClass[i].Type;
  2093. int deviceId = Convert.ToInt16(fdcData[0].DeviceClass[i].DeviceID);
  2094. int alarmId = -1;
  2095. string alarmmsg = "Error " + fdcData[0].DeviceClass[i].ErrorCode + " changing fuel mode";
  2096. OnDeviceAlarm.BeginInvoke(this, new DeviceAlarmEventArgs(deviceType, deviceId, alarmId, alarmmsg), null, null);
  2097. }
  2098. }
  2099. }
  2100. Trace.WriteLine(string.Format("end"));
  2101. }
  2102. catch (Exception ex)
  2103. {
  2104. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2105. }
  2106. }
  2107. public void ChangeFuelPrice(int productId, Decimal price, int mode, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  2108. {
  2109. try
  2110. {
  2111. // create XML ServiceRequest object
  2112. ServiceRequestChangeFuelPrice sr = new ServiceRequestChangeFuelPrice();
  2113. sr.ApplicationSender = this.clientSocket.applicationSender;
  2114. sr.WorkstationID = this.clientSocket.workstationID;
  2115. ServiceRequestPOSdataChangeFuelPrice posDataElem = new ServiceRequestPOSdataChangeFuelPrice();
  2116. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  2117. ServiceRequestProductChangeFuelPrice[] products = new ServiceRequestProductChangeFuelPrice[1];
  2118. ServiceRequestProductChangeFuelPrice product = new ServiceRequestProductChangeFuelPrice();
  2119. product.ProductNo = (productId == -1) ? "*" : Convert.ToString(productId);
  2120. ServiceRequestFuelModeChangeFuelPrice[] fuelModes = new ServiceRequestFuelModeChangeFuelPrice[1];
  2121. ServiceRequestFuelModeChangeFuelPrice fuelMode = new ServiceRequestFuelModeChangeFuelPrice();
  2122. fuelMode.PriceNew = FDCConvert.ToString(price);
  2123. fuelMode.ModeNo = Convert.ToString(mode);
  2124. fuelMode.EffectiveDateTime = "";
  2125. fuelModes[0] = fuelMode;
  2126. product.FuelMode = fuelModes;
  2127. products[0] = product;
  2128. posDataElem.Product = products;
  2129. ServiceRequestPOSdataChangeFuelPrice[] posDataArray = { posDataElem };
  2130. sr.POSdata = posDataArray;
  2131. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  2132. }
  2133. catch (Exception ex)
  2134. {
  2135. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2136. }
  2137. }
  2138. public void ChangeFuelPriceAdd(ServiceRequestChangeFuelPrice sr, int productId, Decimal price, int mode)
  2139. {
  2140. // create XML ServiceRequest object
  2141. sr.ApplicationSender = this.clientSocket.applicationSender;
  2142. sr.WorkstationID = this.clientSocket.workstationID;
  2143. Trace.WriteLine(string.Format("ChangeFuelPriceAdd init: sr.ApplicationSender={0}, sr.WorkstationID={1}, productId={2}, price={3}, mode={4}", sr.ApplicationSender, sr.WorkstationID, productId, price, mode));
  2144. ServiceRequestPOSdataChangeFuelPrice POSDataElem = null;
  2145. if (sr.POSdata != null)
  2146. POSDataElem = sr.POSdata[0];
  2147. else
  2148. {
  2149. ServiceRequestPOSdataChangeFuelPrice[] POSDataArray = null;
  2150. Trace.WriteLine(string.Format("ChangeFuelPriceAdd: new ServiceRequestPOSdataChangeFuelPrice"));
  2151. POSDataElem = new ServiceRequestPOSdataChangeFuelPrice();
  2152. ArrayResize<ServiceRequestPOSdataChangeFuelPrice>(ref POSDataArray, (POSDataArray != null) ? POSDataArray.Length + 1 : 1);
  2153. POSDataArray[POSDataArray.Length - 1] = POSDataElem;
  2154. POSDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  2155. sr.POSdata = POSDataArray;
  2156. }
  2157. ServiceRequestProductChangeFuelPrice product = null;
  2158. if (POSDataElem.Product != null)
  2159. {
  2160. foreach (ServiceRequestProductChangeFuelPrice productTemp in POSDataElem.Product)
  2161. if (productTemp.ProductNo == Convert.ToString(productId) && productTemp.ModeNo == Convert.ToString(mode))
  2162. {
  2163. product = productTemp;
  2164. Trace.WriteLine(string.Format("ChangeFuelPriceAdd: product found"));
  2165. }
  2166. }
  2167. if (product == null && productId > 0)
  2168. {
  2169. Trace.WriteLine(string.Format("ChangeFuelPriceAdd: new product"));
  2170. product = new ServiceRequestProductChangeFuelPrice();
  2171. product.ProductNo = (productId == -1) ? "*" : Convert.ToString(productId);
  2172. ServiceRequestProductChangeFuelPrice[] productArray = POSDataElem.Product;
  2173. ArrayResize<ServiceRequestProductChangeFuelPrice>(ref productArray, (productArray != null) ? productArray.Length + 1 : 1);
  2174. Trace.WriteLine(string.Format("ChangeFuelPriceAdd: resize product to '{0}' items", productArray.Length));
  2175. productArray[productArray.Length - 1] = product;
  2176. POSDataElem.Product = productArray;
  2177. }
  2178. ServiceRequestFuelModeChangeFuelPrice fuelMode = null;
  2179. if (product.FuelMode != null)
  2180. {
  2181. foreach (ServiceRequestFuelModeChangeFuelPrice fuelModeTemp in product.FuelMode)
  2182. if (product.ProductNo == Convert.ToString(productId) && fuelModeTemp.ModeNo == Convert.ToString(mode))
  2183. {
  2184. fuelMode = fuelModeTemp;
  2185. Trace.WriteLine(string.Format("ChangeFuelPriceAdd: fuelMode found"));
  2186. }
  2187. }
  2188. if (fuelMode == null && mode > 0)
  2189. {
  2190. fuelMode = new ServiceRequestFuelModeChangeFuelPrice();
  2191. fuelMode.PriceNew = FDCConvert.ToString(price);
  2192. fuelMode.ModeNo = Convert.ToString(mode);
  2193. fuelMode.EffectiveDateTime = "";
  2194. ServiceRequestFuelModeChangeFuelPrice[] fuelModeArray = product.FuelMode;
  2195. ArrayResize<ServiceRequestFuelModeChangeFuelPrice>(ref fuelModeArray, (fuelModeArray != null) ? fuelModeArray.Length + 1 : 1);
  2196. Trace.WriteLine(string.Format("ChangeFuelPriceAdd: resize fuelMode to '{0}' items", fuelModeArray.Length));
  2197. fuelModeArray[fuelModeArray.Length - 1] = fuelMode;
  2198. product.FuelMode = fuelModeArray;
  2199. }
  2200. Trace.WriteLine(string.Format("ChangeFuelPriceAdd end: sr.ApplicationSender={0}, sr.WorkstationID={1}", sr.ApplicationSender, sr.WorkstationID));
  2201. }
  2202. public void ChangeFuelPriceSend(ServiceRequestChangeFuelPrice sr, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  2203. {
  2204. Trace.WriteLine(string.Format("ChangeFuelPriceSend init: sr.ApplicationSender={0}, sr.WorkstationID={1}", sr.ApplicationSender, sr.WorkstationID));
  2205. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  2206. Trace.WriteLine(string.Format("ChangeFuelPriceSend end: sr.ApplicationSender={0}, sr.WorkstationID={1}", sr.ApplicationSender, sr.WorkstationID));
  2207. }
  2208. public void ChangeFuelPriceResp(int requestId, string sOverallResult, ServiceResponseFDCdataChangeFuelPrice[] fdcData)
  2209. {
  2210. try
  2211. {
  2212. //Trace.WriteLine(string.Format("product={0}, newprice={1}, oldprice={2}", fdcData[0].Product[0].ProductNo, fdcData[0].Product[0].NewPrice, fdcData[0].Product[0].OldPrice));
  2213. Trace.WriteLine(string.Format("ChangeFuelPriceResp init"));
  2214. string errorCode = (fdcData[0].FDCStatus != null) ? fdcData[0].FDCStatus : fdcData[0].ErrorCode;
  2215. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, errorCode == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  2216. // OnChangeFuelPrice event is sent when FuelPriceChange FDCMessage is coming
  2217. //if (OnChangeFuelPrice != null)
  2218. //{
  2219. // OnChangeFuelPrice.BeginInvoke(this, new ChangeFuelPriceEventArgs(Convert.ToInt32(fdcData[0].Product[0].ProductNo), Convert.ToInt32(fdcData[0].Product[0].ModeNo),
  2220. // FDCConvert.ToDecimal(fdcData[0].Product[0].OldPrice), FDCConvert.ToDecimal(fdcData[0].Product[0].NewPrice)), null, null);
  2221. //}
  2222. Trace.WriteLine(string.Format("ChangeFuelPriceResp end"));
  2223. }
  2224. catch (Exception ex)
  2225. {
  2226. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2227. }
  2228. }
  2229. public void LockFuelSaleTrx(int pumpId, int transactionNo, int releaseToken, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  2230. {
  2231. try
  2232. {
  2233. ServiceRequestLockFuelSaleTrx sr = new ServiceRequestLockFuelSaleTrx();
  2234. sr.ApplicationSender = this.clientSocket.applicationSender;
  2235. sr.WorkstationID = this.clientSocket.workstationID;
  2236. ServiceRequestPOSdataBaseFuelSaleTrx posDataElem = new ServiceRequestPOSdataBaseFuelSaleTrx();
  2237. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  2238. ServiceRequestDeviceClassBaseFuelSaleTrx deviceClass = new ServiceRequestDeviceClassBaseFuelSaleTrx();
  2239. deviceClass.DeviceID = (pumpId == -1) ? "*" : Convert.ToString(pumpId);
  2240. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuellingPoint;
  2241. deviceClass.TransactionSeqNo = Convert.ToString(transactionNo);
  2242. deviceClass.ReleaseToken = string.Format("{0:X}", releaseToken);
  2243. posDataElem.DeviceClass = deviceClass;
  2244. ServiceRequestPOSdataBaseFuelSaleTrx[] posDataArray = { posDataElem };
  2245. sr.POSdata = posDataArray;
  2246. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  2247. }
  2248. catch (Exception ex)
  2249. {
  2250. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2251. }
  2252. }
  2253. public void LockFuelSaleTrxResp(int requestId, string sOverallResult, ServiceResponseLockFuelSaleTrx sr)
  2254. {
  2255. try
  2256. {
  2257. string errorCode = (sr.FDCdata[0].FDCStatus != null) ? sr.FDCdata[0].FDCStatus : sr.FDCdata[0].DeviceClass.ErrorCode;
  2258. Trace.WriteLine(string.Format("type={0}, id={1}, errorCode={2}", sr.FDCdata[0].DeviceClass.Type, sr.FDCdata[0].DeviceClass.DeviceID, errorCode));
  2259. if (OnLockFuelSaleTrx != null)
  2260. {
  2261. //string deviceType = sr.FDCdata[0].DeviceClass.Type;
  2262. //int deviceId = Convert.ToInt16(sr.FDCdata[0].DeviceClass.DeviceID);
  2263. //int transactionNo = Convert.ToInt16(sr.FDCdata[0].DeviceClass.TransactionSeqNo);
  2264. //string status = sr.FDCdata[0].FDCStatus;
  2265. //OnLockFuelSaleTrx.Invoke(this, new FuelSaleTrxEventArgs(deviceType, deviceId, state));
  2266. }
  2267. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, errorCode == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  2268. Trace.WriteLine(string.Format("end"));
  2269. }
  2270. catch (Exception ex)
  2271. {
  2272. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2273. }
  2274. }
  2275. public void UnlockFuelSaleTrx(int pumpId, int transactionNo, int releaseToken, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  2276. {
  2277. try
  2278. {
  2279. ServiceRequestUnlockFuelSaleTrx sr = new ServiceRequestUnlockFuelSaleTrx();
  2280. sr.ApplicationSender = this.clientSocket.applicationSender;
  2281. sr.WorkstationID = this.clientSocket.workstationID;
  2282. ServiceRequestPOSdataBaseFuelSaleTrx posDataElem = new ServiceRequestPOSdataBaseFuelSaleTrx();
  2283. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  2284. ServiceRequestDeviceClassBaseFuelSaleTrx deviceClass = new ServiceRequestDeviceClassBaseFuelSaleTrx();
  2285. deviceClass.DeviceID = (pumpId == -1) ? "*" : Convert.ToString(pumpId);
  2286. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuellingPoint;
  2287. deviceClass.TransactionSeqNo = Convert.ToString(transactionNo);
  2288. deviceClass.ReleaseToken = string.Format("{0:X}", releaseToken);
  2289. posDataElem.DeviceClass = deviceClass;
  2290. ServiceRequestPOSdataBaseFuelSaleTrx[] posDataArray = { posDataElem };
  2291. sr.POSdata = posDataArray;
  2292. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  2293. }
  2294. catch (Exception ex)
  2295. {
  2296. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2297. }
  2298. }
  2299. public void UnlockFuelSaleTrxResp(int requestId, string sOverallResult, ServiceResponseUnlockFuelSaleTrx sr)
  2300. {
  2301. try
  2302. {
  2303. string errorCode = (sr.FDCdata[0].FDCStatus != null) ? sr.FDCdata[0].FDCStatus : sr.FDCdata[0].DeviceClass.ErrorCode;
  2304. Trace.WriteLine(string.Format("type={0}, id={1}, errorCode={2}", sr.FDCdata[0].DeviceClass.Type, sr.FDCdata[0].DeviceClass.DeviceID, errorCode));
  2305. if (OnUnlockFuelSaleTrx != null)
  2306. {
  2307. //string deviceType = sr.FDCdata[0].DeviceClass.Type;
  2308. //int deviceId = Convert.ToInt16(sr.FDCdata[0].DeviceClass.DeviceID);
  2309. //int transactionNo = Convert.ToInt16(sr.FDCdata[0].DeviceClass.TransactionSeqNo);
  2310. //string status = sr.FDCdata[0].FDCStatus;
  2311. //OnUnlockFuelSaleTrx.Invoke(this, new FuelSaleTrxEventArgs(deviceType, deviceId, state));
  2312. }
  2313. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, errorCode == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  2314. Trace.WriteLine(string.Format("end"));
  2315. }
  2316. catch (Exception ex)
  2317. {
  2318. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2319. }
  2320. }
  2321. public void ClearFuelSaleTrx(int pumpId, int transactionNo, int releaseToken, string note, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  2322. {
  2323. try
  2324. {
  2325. ServiceRequestClearFuelSaleTrx sr = new ServiceRequestClearFuelSaleTrx();
  2326. sr.ApplicationSender = this.clientSocket.applicationSender;
  2327. sr.WorkstationID = this.clientSocket.workstationID;
  2328. ServiceRequestPOSdataClearFuelSaleTrx posDataElem = new ServiceRequestPOSdataClearFuelSaleTrx();
  2329. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  2330. ServiceRequestDeviceClassClearFuelSaleTrx deviceClass = new ServiceRequestDeviceClassClearFuelSaleTrx();
  2331. deviceClass.DeviceID = (pumpId == -1) ? "*" : Convert.ToString(pumpId);
  2332. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuellingPoint;
  2333. deviceClass.TransactionSeqNo = Convert.ToString(transactionNo);
  2334. deviceClass.ReleaseToken = string.Format("{0:X}", releaseToken);
  2335. deviceClass.FuelSaleNote = note;
  2336. posDataElem.DeviceClass = deviceClass;
  2337. ServiceRequestPOSdataClearFuelSaleTrx[] posDataArray = { posDataElem };
  2338. sr.POSdata = posDataArray;
  2339. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  2340. }
  2341. catch (Exception ex)
  2342. {
  2343. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2344. }
  2345. }
  2346. public void ClearFuelSaleTrxResp(int requestId, string sOverallResult, ServiceResponseClearFuelSaleTrx sr)
  2347. {
  2348. try
  2349. {
  2350. string errorCode = (sr.FDCdata[0].FDCStatus != null) ? sr.FDCdata[0].FDCStatus : sr.FDCdata[0].DeviceClass.ErrorCode;
  2351. Trace.WriteLine(string.Format("type={0}, id={1}, errorCode={2}", sr.FDCdata[0].DeviceClass.Type, sr.FDCdata[0].DeviceClass.DeviceID, errorCode));
  2352. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, errorCode == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  2353. if (OnClearFuelSaleTrx != null)
  2354. {
  2355. //string deviceType = sr.FDCdata[0].DeviceClass.Type;
  2356. //int deviceId = Convert.ToInt16(sr.FDCdata[0].DeviceClass.DeviceID);
  2357. //int transactionNo = Convert.ToInt16(sr.FDCdata[0].DeviceClass.TransactionSeqNo);
  2358. //string status = sr.FDCdata[0].FDCStatus;
  2359. //OnClearFuelSaleTrx.Invoke(this, new FuelSaleTrxEventArgs(deviceType, deviceId, state));
  2360. }
  2361. Trace.WriteLine(string.Format("end"));
  2362. }
  2363. catch (Exception ex)
  2364. {
  2365. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2366. }
  2367. }
  2368. public void SendConfig(string commandFileName, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  2369. {
  2370. clientSocket.SendConfig(commandFileName);
  2371. }
  2372. public void GetAvailableFuelSaleTrxs(int pumpId, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  2373. {
  2374. try
  2375. {
  2376. // create XML ServiceRequest object
  2377. ServiceRequestGetAvailableFuelSaleTrxs sr = new ServiceRequestGetAvailableFuelSaleTrxs();
  2378. sr.ApplicationSender = this.clientSocket.applicationSender;
  2379. sr.WorkstationID = this.clientSocket.workstationID;
  2380. ServiceRequestPOSdataGetAvailableFuelSaleTrxs posDataElem = new ServiceRequestPOSdataGetAvailableFuelSaleTrxs();
  2381. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  2382. ServiceRequestDeviceClass deviceClass = new ServiceRequestDeviceClass();
  2383. deviceClass.DeviceID = (pumpId == -1) ? "*" : Convert.ToString(pumpId);
  2384. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuellingPoint;
  2385. posDataElem.DeviceClass = deviceClass;
  2386. ServiceRequestPOSdataGetAvailableFuelSaleTrxs[] posDataArray = { posDataElem };
  2387. sr.POSdata = posDataArray;
  2388. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  2389. }
  2390. catch (Exception ex)
  2391. {
  2392. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2393. }
  2394. }
  2395. public void GetAvailableFuelSaleTrxsResp(int requestId, string sOverallResult, ServiceResponseGetAvailableFuelSaleTrxs sr)
  2396. {
  2397. try
  2398. {
  2399. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("init GetAvailableFuelSaleTrxsResp"));
  2400. if (sr.FDCdata == null || sr.FDCdata[0].DeviceClass == null)
  2401. {
  2402. Trace.WriteLine(string.Format("no fuel sale available - end"));
  2403. return;
  2404. }
  2405. if (OnGetAvailableFuelSaleTrx != null && sr.FDCdata[0] != null && sr.FDCdata[0].DeviceClass != null)
  2406. {
  2407. for (int i = 0; i < sr.FDCdata[0].DeviceClass.Length; i++)
  2408. {
  2409. //if (sr.FDCdata[0].DeviceClass[i].Transaction == null)
  2410. // continue;
  2411. //for (int j = 0; j < sr.FDCdata[0].DeviceClass[i].Transaction.Length; j++)
  2412. //{
  2413. // Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("type={0}, id={1}, TransactionSeqNo={2}", sr.FDCdata[0].DeviceClass[0].Type, sr.FDCdata[0].DeviceClass[0].DeviceID, sr.FDCdata[0].DeviceClass[i].Transaction[j].TransactionSeqNo));
  2414. // string deviceType = sr.FDCdata[0].DeviceClass[i].Type;
  2415. // int deviceId = Convert.ToInt16(sr.FDCdata[0].DeviceClass[i].DeviceID);
  2416. // int transactionNo = Convert.ToInt32(sr.FDCdata[0].DeviceClass[i].Transaction[j].TransactionSeqNo);
  2417. // OnGetAvailableFuelSaleTrx.Invoke(this, new FuelSaleTrxEventArgs(transactionNo, 0, 0, deviceType, deviceId, 0, 0, 0, 0, 0,
  2418. // DateTime.Now, DateTime.Now, CRC16.CalculateCRC(deviceId, transactionNo, 0, 0)));
  2419. //}
  2420. if (ConfigParam.IsEMSGVersion || (sr.FDCdata[0].DeviceClass[i].ErrorCode != null && sr.FDCdata[0].DeviceClass[i].ErrorCode == ErrorCode.ERRCD_OK.ToString()))
  2421. {
  2422. string deviceType = sr.FDCdata[0].DeviceClass[i].Type;
  2423. int deviceId = Convert.ToInt16(sr.FDCdata[0].DeviceClass[i].DeviceID);
  2424. int transactionNo = Convert.ToInt32(sr.FDCdata[0].DeviceClass[i].TransactionSeqNo);
  2425. int releaseToken;
  2426. //#if !_USE_OLD_FCONTROL_
  2427. // if (!Strings.TryParseInt(sr.FDCdata[0].DeviceClass[i].ReleaseToken, out releaseToken))
  2428. // releaseToken = 0;
  2429. //#else
  2430. try
  2431. {
  2432. releaseToken = Int32.Parse(sr.FDCdata[0].DeviceClass[i].ReleaseToken, System.Globalization.NumberStyles.HexNumber);
  2433. }
  2434. catch (Exception ex)
  2435. {
  2436. releaseToken = 0;
  2437. }
  2438. //#endif
  2439. OnGetAvailableFuelSaleTrx.BeginInvoke(this, new FuelSaleTrxEventArgs(transactionNo, 0, 0, deviceType, deviceId, 0, 0, 0, 0, 0,
  2440. DateTime.Now, DateTime.Now, "", "", null, null, null, null, releaseToken, 0, FuellingType.Unknown), null, null);
  2441. int timeout = 0;
  2442. string sValue = IniFile.IniReadValue(ConfigurationParams.inifile, "FUSION-Connection", "GetFuelSaleTrxDetailTimeout");
  2443. if (sValue.Length > 0)
  2444. timeout = Convert.ToInt16(sValue);
  2445. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("GetFuelSaleTrxDetailTimeout={0}", timeout));
  2446. Thread.Sleep(timeout);
  2447. }
  2448. else
  2449. Trace.WriteLine(string.Format("Id={0} - Error={1}", sr.FDCdata[0].DeviceClass[i].DeviceID, sr.FDCdata[0].DeviceClass[i].ErrorCode));
  2450. }
  2451. }
  2452. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, true);
  2453. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("end GetAvailableFuelSaleTrxsResp"));
  2454. }
  2455. catch (Exception ex)
  2456. {
  2457. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2458. }
  2459. }
  2460. public void GetFuelSaleTrxDetails(int pumpId, int transactionNo, int releaseToken, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  2461. {
  2462. // create XML ServiceRequest object
  2463. try
  2464. {
  2465. ServiceRequestGetFuelSaleTrxDetails sr = new ServiceRequestGetFuelSaleTrxDetails();
  2466. sr.ApplicationSender = this.clientSocket.applicationSender;
  2467. sr.WorkstationID = this.clientSocket.workstationID;
  2468. ServiceRequestPOSdataGetFuelSaleTrxDetails posDataElem = new ServiceRequestPOSdataGetFuelSaleTrxDetails();
  2469. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  2470. ServiceRequestDeviceClassGetFuelSaleTrxDetails deviceClass = new ServiceRequestDeviceClassGetFuelSaleTrxDetails();
  2471. deviceClass.DeviceID = (pumpId == -1) ? "*" : Convert.ToString(pumpId);
  2472. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuellingPoint;
  2473. deviceClass.TransactionSeqNo = (transactionNo == -1) ? "*" : Convert.ToString(transactionNo);
  2474. deviceClass.ReleaseToken = string.Format("{0:X}", releaseToken);
  2475. posDataElem.DeviceClass = deviceClass;
  2476. ServiceRequestPOSdataGetFuelSaleTrxDetails[] posDataArray = { posDataElem };
  2477. sr.POSdata = posDataArray;
  2478. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  2479. }
  2480. catch (Exception ex)
  2481. {
  2482. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2483. }
  2484. }
  2485. public void GetFuelSaleTrxDetailsResp(int requestId, string sOverallResult, ServiceResponseGetFuelSaleTrxDetails sr)
  2486. {
  2487. try
  2488. {
  2489. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("init GetFuelSaleTrxDetailsResp"));
  2490. if (sr.FDCdata == null || sr.FDCdata[0].DeviceClass == null)
  2491. {
  2492. Trace.WriteLine(string.Format("no fuel sale details - end"));
  2493. return;
  2494. }
  2495. if ((OnGetFuelSaleTrxDetails != null || OnFuelSaleTrx != null) && sr.FDCdata[0] != null && sr.FDCdata[0].DeviceClass != null)
  2496. {
  2497. for (int i = 0; i < sr.FDCdata[0].DeviceClass.Length; i++)
  2498. {
  2499. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("type={0}, id={1}, nozzle={2}, amount={3}, vol={4}",
  2500. sr.FDCdata[0].DeviceClass[i].Type, sr.FDCdata[0].DeviceClass[i].DeviceID,
  2501. sr.FDCdata[0].DeviceClass[i].NozzleNo, sr.FDCdata[0].DeviceClass[i].Amount, sr.FDCdata[0].DeviceClass[i].Volume));
  2502. string deviceType = sr.FDCdata[0].DeviceClass[0].Type;
  2503. int transactionSeqNum = Convert.ToInt32(sr.FDCdata[0].DeviceClass[i].TransactionSeqNo);
  2504. int deviceId = Convert.ToInt16(sr.FDCdata[0].DeviceClass[i].DeviceID);
  2505. Wayne.FDCPOSLibrary.FuellingState transactionState = convertFuellingState(sr.FDCdata[0].DeviceClass[i].State);
  2506. int completionReason = 0;
  2507. int nozzleId = Convert.ToInt16(sr.FDCdata[0].DeviceClass[i].NozzleNo);
  2508. decimal volume = FDCConvert.ToDecimal(sr.FDCdata[0].DeviceClass[i].Volume);
  2509. decimal amount = FDCConvert.ToDecimal(sr.FDCdata[0].DeviceClass[i].Amount);
  2510. decimal price = FDCConvert.ToDecimal(sr.FDCdata[0].DeviceClass[i].UnitPrice);
  2511. int fuelMode = Convert.ToInt16(sr.FDCdata[0].DeviceClass[i].FuelMode.ModeNo);
  2512. DateTime trxStartDateTime = Convert.ToDateTime(sr.FDCdata[0].DeviceClass[i].StartTimeStamp);
  2513. DateTime trxEndDateTime = Convert.ToDateTime(sr.FDCdata[0].DeviceClass[i].EndTimeStamp);
  2514. string lockingAS = sr.FDCdata[0].DeviceClass[i].LockingApplicationSender;
  2515. string authAS = sr.FDCdata[0].DeviceClass[i].AuthorisationApplicationSender;
  2516. string DSPFields = sr.FDCdata[0].DeviceClass[i].DSPFields;
  2517. string CRCMode = sr.FDCdata[0].DeviceClass[i].CRCMode;
  2518. string MIDLinesNarrow = sr.FDCdata[0].DeviceClass[i].MIDLinesNarrow;
  2519. string MIDLinesWide = sr.FDCdata[0].DeviceClass[i].MIDLinesWide;
  2520. //string DSPFields = System.Text.UTF8Encoding.UTF8.GetString(sr.FDCdata[0].DeviceClass[i].DSPFieldsByte, 0, sr.FDCdata[0].DeviceClass[i].DSPFieldsByte.GetLength(0));
  2521. //string CRCMode = System.Text.UTF8Encoding.UTF8.GetString(sr.FDCdata[0].DeviceClass[i].CRCModeByte, 0, sr.FDCdata[0].DeviceClass[i].CRCModeByte.GetLength(0));
  2522. FuellingType fuellingType = (sr.FDCdata[0].DeviceClass[i].FuellingType == "") ? FuellingType.Unknown : ((FuellingType)Convert.ToInt16(sr.FDCdata[0].DeviceClass[i].FuellingType));
  2523. int releaseToken;
  2524. //#if !_USE_OLD_FCONTROL_
  2525. // if (!Strings.TryParseInt(sr.FDCdata[0].DeviceClass[i].ReleaseToken, out releaseToken))
  2526. // releaseToken = 0;
  2527. //#else
  2528. try
  2529. {
  2530. releaseToken = Int32.Parse(sr.FDCdata[0].DeviceClass[i].ReleaseToken, NumberStyles.HexNumber);
  2531. }
  2532. catch (Exception ex)
  2533. {
  2534. releaseToken = 0;
  2535. }
  2536. //#endif
  2537. byte reservingDeviceId;
  2538. //#if !_SINP
  2539. // if (!Strings.TryParseByte(sr.FDCdata[0].DeviceClass[i].ReservingDeviceId, out reservingDeviceId))
  2540. // reservingDeviceId = 0;
  2541. //#else
  2542. try
  2543. {
  2544. reservingDeviceId = Convert.ToByte(sr.FDCdata[0].DeviceClass[i].ReservingDeviceId);
  2545. }
  2546. catch (Exception ex)
  2547. {
  2548. reservingDeviceId = 0;
  2549. }
  2550. //#endif
  2551. if (OnGetFuelSaleTrxDetails != null)
  2552. {
  2553. OnGetFuelSaleTrxDetails.BeginInvoke(this, new FuelSaleTrxEventArgs(transactionSeqNum, transactionState, completionReason, deviceType, deviceId, nozzleId, volume, amount, price, fuelMode, trxStartDateTime, trxEndDateTime, lockingAS, authAS, DSPFields, CRCMode, MIDLinesNarrow, MIDLinesWide, releaseToken, reservingDeviceId, fuellingType), null, null);
  2554. }
  2555. if (OnFuelSaleTrx != null)
  2556. {
  2557. OnFuelSaleTrx.BeginInvoke(this, new FuelSaleTrxEventArgs(transactionSeqNum, transactionState, completionReason, deviceType, deviceId, nozzleId, volume, amount, price, fuelMode, trxStartDateTime, trxEndDateTime, lockingAS, authAS, DSPFields, CRCMode, MIDLinesNarrow, MIDLinesWide, releaseToken, reservingDeviceId, fuellingType), null, null);
  2558. }
  2559. }
  2560. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, true);
  2561. }
  2562. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("end GetFuelSaleTrxDetailsResp"));
  2563. }
  2564. catch (Exception ex)
  2565. {
  2566. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2567. }
  2568. }
  2569. public void GetFuelSaleTrxDetailsResp(int requestId, string sOverallResult, ServiceResponseGetFuelSaleTrxDetailsV03 sr)
  2570. {
  2571. try
  2572. {
  2573. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("init GetFuelSaleTrxDetailsRespV03"));
  2574. if (sr.FDCdata == null || sr.FDCdata[0].DeviceClass == null)
  2575. {
  2576. Trace.WriteLine(string.Format("no fuel sale details - end"));
  2577. return;
  2578. }
  2579. if ((OnGetFuelSaleTrxDetails != null || OnFuelSaleTrx != null) && sr.FDCdata[0] != null && sr.FDCdata[0].DeviceClass != null)
  2580. {
  2581. for (int i = 0; i < sr.FDCdata[0].DeviceClass.Length; i++)
  2582. {
  2583. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("type={0}, id={1}, nozzle={2}, amount={3}, vol={4}",
  2584. sr.FDCdata[0].DeviceClass[i].Type, sr.FDCdata[0].DeviceClass[i].DeviceID,
  2585. sr.FDCdata[0].DeviceClass[i].NozzleNo, sr.FDCdata[0].DeviceClass[i].Amount, sr.FDCdata[0].DeviceClass[i].Volume));
  2586. string deviceType = sr.FDCdata[0].DeviceClass[0].Type;
  2587. int transactionSeqNum = Convert.ToInt32(sr.FDCdata[0].DeviceClass[i].TransactionNo);
  2588. int deviceId = Convert.ToInt16(sr.FDCdata[0].DeviceClass[i].DeviceID);
  2589. Wayne.FDCPOSLibrary.FuellingState transactionState = convertFuellingState(sr.FDCdata[0].DeviceClass[i].State);
  2590. int completionReason = 0;
  2591. int nozzleId = Convert.ToInt16(sr.FDCdata[0].DeviceClass[i].NozzleNo);
  2592. decimal volume = FDCConvert.ToDecimal(sr.FDCdata[0].DeviceClass[i].Volume);
  2593. decimal amount = FDCConvert.ToDecimal(sr.FDCdata[0].DeviceClass[i].Amount);
  2594. decimal price = FDCConvert.ToDecimal(sr.FDCdata[0].DeviceClass[i].UnitPrice);
  2595. int fuelMode = Convert.ToInt16(sr.FDCdata[0].DeviceClass[i].FuelMode);
  2596. DateTime trxStartDateTime = Convert.ToDateTime(sr.FDCdata[0].DeviceClass[i].StartTimeStamp);
  2597. DateTime trxEndDateTime = Convert.ToDateTime(sr.FDCdata[0].DeviceClass[i].EndTimeStamp);
  2598. string lockingAS = "";
  2599. string authAS = "";
  2600. string DSPFields = sr.FDCdata[0].DeviceClass[i].DSPFields;
  2601. string CRCMode = sr.FDCdata[0].DeviceClass[i].CRCMode;
  2602. string MIDLinesNarrow = "";
  2603. string MIDLinesWide = "";
  2604. //string DSPFields = System.Text.UTF8Encoding.UTF8.GetString(sr.FDCdata[0].DeviceClass[i].DSPFieldsByte, 0, sr.FDCdata[0].DeviceClass[i].DSPFieldsByte.GetLength(0));
  2605. //string CRCMode = System.Text.UTF8Encoding.UTF8.GetString(sr.FDCdata[0].DeviceClass[i].CRCModeByte, 0, sr.FDCdata[0].DeviceClass[i].CRCModeByte.GetLength(0));
  2606. if (OnGetFuelSaleTrxDetails != null)
  2607. OnGetFuelSaleTrxDetails.BeginInvoke(this, new FuelSaleTrxEventArgs(transactionSeqNum, transactionState, completionReason, deviceType, deviceId, nozzleId, volume, amount, price, fuelMode, trxStartDateTime, trxEndDateTime, lockingAS, authAS, DSPFields, CRCMode, MIDLinesNarrow, MIDLinesWide, Int32.Parse(sr.FDCdata[0].DeviceClass[i].ReleaseToken, NumberStyles.HexNumber), 0, FuellingType.Unknown), null, null);
  2608. if (OnFuelSaleTrx != null)
  2609. OnFuelSaleTrx.BeginInvoke(this, new FuelSaleTrxEventArgs(transactionSeqNum, transactionState, completionReason, deviceType, deviceId, nozzleId, volume, amount, price, fuelMode, trxStartDateTime, trxEndDateTime, lockingAS, authAS, DSPFields, CRCMode, MIDLinesNarrow, MIDLinesWide, Int32.Parse(sr.FDCdata[0].DeviceClass[i].ReleaseToken, NumberStyles.HexNumber), 0, FuellingType.Unknown), null, null);
  2610. }
  2611. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, true);
  2612. }
  2613. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("end GetFuelSaleTrxDetailsResp"));
  2614. }
  2615. catch (Exception ex)
  2616. {
  2617. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2618. }
  2619. }
  2620. public void GetProductTable(EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  2621. {
  2622. try
  2623. {
  2624. // create XML ServiceRequest object
  2625. ServiceRequestGetProductTable sr = new ServiceRequestGetProductTable();
  2626. sr.ApplicationSender = this.clientSocket.applicationSender;
  2627. sr.WorkstationID = this.clientSocket.workstationID;
  2628. ServiceRequestPOSdataGetProductTable posDataElem = new ServiceRequestPOSdataGetProductTable();
  2629. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  2630. ServiceRequestPOSdataGetProductTable[] posDataArray = { posDataElem };
  2631. sr.POSdata = posDataArray;
  2632. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  2633. }
  2634. catch (Exception ex)
  2635. {
  2636. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2637. }
  2638. }
  2639. public void GetProductTableResp(int requestId, string sOverallResult, ServiceResponseGetProductTable sr)
  2640. {
  2641. try
  2642. {
  2643. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("init GetProductTableResp"));
  2644. //load products
  2645. if (OnGetProductTable != null)
  2646. {
  2647. Trace.WriteLineIf(Trace.CheckTraceLevel(3), "Call OnGetProductTable");
  2648. OnGetProductTable.Invoke(this, new GetProductTableEventArgs(sr));
  2649. }
  2650. //manage getConfigurationData
  2651. Trace.WriteLineIf(Trace.CheckTraceLevel(3), "Call AsyncResponseManager");
  2652. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, true);
  2653. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("end GetProductTableResp"));
  2654. }
  2655. catch (Exception ex)
  2656. {
  2657. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2658. }
  2659. }
  2660. public void GetConfiguration_Result(object src, Wayne.Lib.AsyncCompletedEventArgs completed)
  2661. {
  2662. try
  2663. {
  2664. Trace.WriteLine("init");
  2665. GetConfigurationRespEventArgs gcr = (GetConfigurationRespEventArgs)completed.UserToken;
  2666. if (OnGetConfiguration != null)
  2667. {
  2668. Trace.WriteLine("call OnGetConfiguration");
  2669. OnGetConfiguration.Invoke(this, new GetConfigurationEventArgs(gcr.sr));
  2670. }
  2671. if (gcr.getConfigurationRequestCompleted != null)
  2672. {
  2673. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(gcr.requestId, gcr.result);
  2674. }
  2675. Trace.WriteLine("end");
  2676. }
  2677. catch (Exception ex)
  2678. {
  2679. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2680. }
  2681. }
  2682. public void GetDSPConfiguration_Result(object src, Wayne.Lib.AsyncCompletedEventArgs completed)
  2683. {
  2684. // delegGetConfiguration_Result mydelegGetConfiguration_Result = new delegGetConfiguration_Result(this.deleg_method_GetConfiguration_Result);
  2685. // mydelegGetConfiguration_Result.BeginInvoke(src, completed, null, null);
  2686. //}
  2687. //void deleg_method_GetConfiguration_Result(object src, Wayne.Lib.AsyncCompletedEventArgs completed)
  2688. //{
  2689. try
  2690. {
  2691. Trace.WriteLine("init");
  2692. GetConfigurationRespEventArgs gcr = (GetConfigurationRespEventArgs)completed.UserToken;
  2693. if (OnGetConfiguration != null)
  2694. {
  2695. Trace.WriteLine("call OnGetConfiguration");
  2696. OnGetConfiguration.Invoke(this, new GetConfigurationEventArgs(gcr.sr));
  2697. }
  2698. if (gcr.getConfigurationRequestCompleted != null)
  2699. {
  2700. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(gcr.requestId, gcr.result);
  2701. }
  2702. Trace.WriteLine("end");
  2703. }
  2704. catch (Exception ex)
  2705. {
  2706. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2707. }
  2708. }
  2709. //public void GetConfigurationProductTableResp
  2710. public void GetModeTable(EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  2711. {
  2712. try
  2713. {
  2714. // create XML ServiceRequest object
  2715. ServiceRequestGetModeTable sr = new ServiceRequestGetModeTable();
  2716. sr.ApplicationSender = this.clientSocket.applicationSender;
  2717. sr.WorkstationID = this.clientSocket.workstationID;
  2718. ServiceRequestPOSdataGetModeTable posDataElem = new ServiceRequestPOSdataGetModeTable();
  2719. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  2720. ServiceRequestPOSdataGetModeTable[] posDataArray = { posDataElem };
  2721. sr.POSdata = posDataArray;
  2722. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  2723. }
  2724. catch (Exception ex)
  2725. {
  2726. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2727. }
  2728. }
  2729. public void GetModeTableResp(int requestId, string sOverallResult, ServiceResponseGetModeTable sr)
  2730. {
  2731. try
  2732. {
  2733. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("init GetModeTableResp"));
  2734. /* if (sr.FDCdata == null || sr.FDCdata[0].ModeProduct == null )
  2735. {
  2736. Trace.WriteLine(string.Format("no fuel product available - end"));
  2737. return;
  2738. }
  2739. for (int i = 0; i < sr.FDCdata[0].ModeProduct.Length; i++)
  2740. {
  2741. string ModeNo = sr.FDCdata[0].ModeProduct[i].ModeNo;
  2742. string ModeName = sr.FDCdata[0].ModeProduct[i].ModeName;
  2743. Trace.WriteLine(string.Format("ModeNo={0}, ModeName = {1}", ModeNo, ModeName));
  2744. if (OnGetModeTable != null)
  2745. {
  2746. OnGetModeTable.Invoke(this, new ModeTableEventArgs(ModeNo,ModeName));
  2747. }
  2748. }
  2749. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, true);*/
  2750. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("end GetModeTableResp"));
  2751. }
  2752. catch (Exception ex)
  2753. {
  2754. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2755. }
  2756. }
  2757. public void GetFuelMode(int pumpId, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  2758. {
  2759. try
  2760. {
  2761. // create XML ServiceRequest object
  2762. ServiceRequestGetFuelMode srV07 = new ServiceRequestGetFuelMode();
  2763. ServiceRequestGetFPFuelMode sr = new ServiceRequestGetFPFuelMode();
  2764. srV07.ApplicationSender = this.clientSocket.applicationSender;
  2765. srV07.WorkstationID = this.clientSocket.workstationID;
  2766. sr.ApplicationSender = this.clientSocket.applicationSender;
  2767. sr.WorkstationID = this.clientSocket.workstationID;
  2768. ServiceRequestPOSdataGetFuelMode posDataElem = new ServiceRequestPOSdataGetFuelMode();
  2769. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  2770. ServiceRequestDeviceClass deviceClass = new ServiceRequestDeviceClass();
  2771. deviceClass.DeviceID = (pumpId == -1) ? "*" : Convert.ToString(pumpId);
  2772. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuellingPoint;
  2773. posDataElem.DeviceClass = deviceClass;
  2774. ServiceRequestPOSdataGetFuelMode[] posDataArray = { posDataElem };
  2775. srV07.POSdata = posDataArray;
  2776. sr.POSdata = posDataArray;
  2777. if (FDCGlobal.ProtocolVersion <= FDCVersion.V0007)
  2778. clientSocket.ifsfMessages.EnqueueMessage(srV07, requestCompleted, userToken, src, true);
  2779. else
  2780. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  2781. }
  2782. catch (Exception ex)
  2783. {
  2784. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2785. }
  2786. }
  2787. public void GetFuelModeResp(int requestId, string sOverallResult, ServiceResponseFDCdataGetFuelMode[] fdcData)
  2788. {
  2789. try
  2790. {
  2791. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("init GetFuelModeResp"));
  2792. if (fdcData == null || fdcData[0].DeviceClass == null)
  2793. {
  2794. Trace.WriteLine(string.Format("no device available - end"));
  2795. return;
  2796. }
  2797. // TO ADD
  2798. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("end GetFuelModeResp"));
  2799. }
  2800. catch (Exception ex)
  2801. {
  2802. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2803. }
  2804. }
  2805. public void GetConfiguration(EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  2806. {
  2807. try
  2808. {
  2809. // create XML ServiceRequest object
  2810. ServiceRequestGetConfiguration sr = new ServiceRequestGetConfiguration();
  2811. sr.ApplicationSender = this.clientSocket.applicationSender;
  2812. sr.WorkstationID = this.clientSocket.workstationID;
  2813. ServiceRequestPOSdataGetConfiguration posDataElem = new ServiceRequestPOSdataGetConfiguration();
  2814. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  2815. ServiceRequestPOSdataGetConfiguration[] posDataArray = { posDataElem };
  2816. sr.POSdata = posDataArray;
  2817. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  2818. }
  2819. catch (Exception ex)
  2820. {
  2821. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2822. }
  2823. }
  2824. public void GetConfigurationResp(int requestId, string sOverallResult, ServiceResponseGetConfiguration sr)
  2825. {
  2826. try
  2827. {
  2828. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("init GetConfigurationResp: INVALID FOR V7 !"));
  2829. GetConfigurationRespEventArgs gcea = new GetConfigurationRespEventArgs(requestId, sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString(), sr, null, null);
  2830. if (clientSocket.ifsfMessages.asyncResponseManager.AsyncResponseOperationList.ContainsKey(requestId))
  2831. {
  2832. AsyncResponseOperation aro = (AsyncResponseOperation)clientSocket.ifsfMessages.asyncResponseManager.AsyncResponseOperationList[requestId];
  2833. if (aro.requestCompleted != null)
  2834. {
  2835. gcea.getConfigurationUserToken = aro.userToken;
  2836. gcea.getConfigurationRequestCompleted = aro.requestCompleted;
  2837. }
  2838. }
  2839. this.GetProductTable(new EventHandler<Wayne.Lib.AsyncCompletedEventArgs>(GetConfiguration_Result), gcea, this);
  2840. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("end GetConfigurationResp"));
  2841. }
  2842. catch (Exception ex)
  2843. {
  2844. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2845. }
  2846. }
  2847. public void GetDSPConfiguration(EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  2848. {
  2849. try
  2850. {
  2851. // create XML ServiceRequest object
  2852. ServiceRequestGetDSPConfiguration sr = new ServiceRequestGetDSPConfiguration();
  2853. sr.ApplicationSender = this.clientSocket.applicationSender;
  2854. sr.WorkstationID = this.clientSocket.workstationID;
  2855. ServiceRequestPOSdataGetConfiguration posDataElem = new ServiceRequestPOSdataGetConfiguration();
  2856. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  2857. ServiceRequestPOSdataGetConfiguration[] posDataArray = { posDataElem };
  2858. sr.POSdata = posDataArray;
  2859. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  2860. }
  2861. catch (Exception ex)
  2862. {
  2863. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2864. }
  2865. }
  2866. public void GetDSPConfigurationResp(int requestId, string sOverallResult, ServiceResponseGetDSPConfiguration sr)
  2867. {
  2868. try
  2869. {
  2870. Trace.WriteLine("init");
  2871. if (OnGetConfiguration != null)
  2872. {
  2873. Trace.WriteLine("call OnGetConfiguration");
  2874. OnGetConfiguration.Invoke(this, new GetConfigurationEventArgs(sr));
  2875. }
  2876. Trace.WriteLine("end");
  2877. }
  2878. catch (Exception ex)
  2879. {
  2880. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2881. }
  2882. }
  2883. public void GetTLGConfiguration(EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  2884. {
  2885. try
  2886. {
  2887. // create XML ServiceRequest object
  2888. ServiceRequestGetTLGConfiguration sr = new ServiceRequestGetTLGConfiguration();
  2889. sr.ApplicationSender = this.clientSocket.applicationSender;
  2890. sr.WorkstationID = this.clientSocket.workstationID;
  2891. ServiceRequestPOSdataGetConfiguration posDataElem = new ServiceRequestPOSdataGetConfiguration();
  2892. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  2893. ServiceRequestPOSdataGetConfiguration[] posDataArray = { posDataElem };
  2894. sr.POSdata = posDataArray;
  2895. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  2896. }
  2897. catch (Exception ex)
  2898. {
  2899. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2900. }
  2901. }
  2902. public void GetTLGConfigurationResp(int requestId, string sOverallResult, ServiceResponseGetTLGConfiguration sr)
  2903. {
  2904. try
  2905. {
  2906. if (OnGetConfiguration != null)
  2907. {
  2908. Trace.WriteLine("call OnGetConfiguration");
  2909. OnGetConfiguration.Invoke(this, new GetConfigurationEventArgs(sr));
  2910. }
  2911. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("end GetDSPConfigurationResp"));
  2912. }
  2913. catch (Exception ex)
  2914. {
  2915. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2916. }
  2917. }
  2918. public void SetConfigurationResp(int requestId, string sOverallResult, ServiceResponseSetConfiguration sr)
  2919. {
  2920. try
  2921. {
  2922. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("init"));
  2923. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("end"));
  2924. }
  2925. catch (Exception ex)
  2926. {
  2927. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2928. }
  2929. }
  2930. public void LockNozzle(int deviceId, int nozzleNo, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  2931. {
  2932. try
  2933. {
  2934. // create XML ServiceRequest object
  2935. ServiceRequestLockNozzle sr = new ServiceRequestLockNozzle();
  2936. sr.ApplicationSender = this.clientSocket.applicationSender;
  2937. sr.WorkstationID = this.clientSocket.workstationID;
  2938. ServiceRequestPOSdataLockNozzle posDataElem = new ServiceRequestPOSdataLockNozzle();
  2939. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  2940. ServiceRequestDeviceClassLockNozzle deviceClass = new ServiceRequestDeviceClassLockNozzle();
  2941. deviceClass.DeviceID = Convert.ToString(deviceId);
  2942. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuellingPoint;
  2943. deviceClass.NozzleNo = (nozzleNo == -1) ? "*" : Convert.ToString(nozzleNo);
  2944. posDataElem.DeviceClass = deviceClass;
  2945. ServiceRequestPOSdataLockNozzle[] posDataArray = { posDataElem };
  2946. sr.POSdata = posDataArray;
  2947. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  2948. }
  2949. catch (Exception ex)
  2950. {
  2951. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2952. }
  2953. }
  2954. public void LockNozzleResp(int requestId, string sOverallResult, ServiceResponseLockNozzle sr)
  2955. {
  2956. try
  2957. {
  2958. string errorCode = (sr.FDCdata[0].FDCStatus != null) ? sr.FDCdata[0].FDCStatus : sr.FDCdata[0].DeviceClass.ErrorCode;
  2959. Trace.WriteLine(string.Format("type={0}, id={1}, nozzleNo={2}, errorCode={3}", sr.FDCdata[0].DeviceClass.Type, sr.FDCdata[0].DeviceClass.DeviceID, sr.FDCdata[0].DeviceClass.NozzleNo, errorCode));
  2960. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, errorCode == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  2961. Trace.WriteLine(string.Format("end"));
  2962. }
  2963. catch (Exception ex)
  2964. {
  2965. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2966. }
  2967. }
  2968. public void UnlockNozzle(int deviceId, int nozzleNo, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  2969. {
  2970. try
  2971. {
  2972. // create XML ServiceRequest object
  2973. ServiceRequestUnlockNozzle sr = new ServiceRequestUnlockNozzle();
  2974. sr.ApplicationSender = this.clientSocket.applicationSender;
  2975. sr.WorkstationID = this.clientSocket.workstationID;
  2976. ServiceRequestPOSdataUnlockNozzle posDataElem = new ServiceRequestPOSdataUnlockNozzle();
  2977. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  2978. ServiceRequestDeviceClassUnlockNozzle deviceClass = new ServiceRequestDeviceClassUnlockNozzle();
  2979. deviceClass.DeviceID = Convert.ToString(deviceId);
  2980. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuellingPoint;
  2981. deviceClass.NozzleNo = (nozzleNo == -1) ? "*" : Convert.ToString(nozzleNo);
  2982. posDataElem.DeviceClass = deviceClass;
  2983. ServiceRequestPOSdataUnlockNozzle[] posDataArray = { posDataElem };
  2984. sr.POSdata = posDataArray;
  2985. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  2986. }
  2987. catch (Exception ex)
  2988. {
  2989. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  2990. }
  2991. }
  2992. public void UnlockNozzleResp(int requestId, string sOverallResult, ServiceResponseUnlockNozzle sr)
  2993. {
  2994. try
  2995. {
  2996. string errorCode = (sr.FDCdata[0].FDCStatus != null) ? sr.FDCdata[0].FDCStatus : sr.FDCdata[0].DeviceClass.ErrorCode;
  2997. Trace.WriteLine(string.Format("type={0}, id={1}, nozzleNo={2}, errorCode{3}", sr.FDCdata[0].DeviceClass.Type, sr.FDCdata[0].DeviceClass.DeviceID, sr.FDCdata[0].DeviceClass.NozzleNo, errorCode));
  2998. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, errorCode == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  2999. Trace.WriteLine(string.Format("end"));
  3000. }
  3001. catch (Exception ex)
  3002. {
  3003. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3004. }
  3005. }
  3006. public void GetCountrySettings(EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  3007. {
  3008. try
  3009. {
  3010. // create XML ServiceRequest object
  3011. ServiceRequestGetCountrySettings sr = new ServiceRequestGetCountrySettings();
  3012. sr.ApplicationSender = this.clientSocket.applicationSender;
  3013. sr.WorkstationID = this.clientSocket.workstationID;
  3014. ServiceRequestPOSdataGetCountrySettings posDataElem = new ServiceRequestPOSdataGetCountrySettings();
  3015. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  3016. ServiceRequestPOSdataGetCountrySettings[] posDataArray = { posDataElem };
  3017. sr.POSdata = posDataArray;
  3018. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  3019. }
  3020. catch (Exception ex)
  3021. {
  3022. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3023. }
  3024. }
  3025. public void GetCountrySettingsResp(int requestId, string sOverallResult, ServiceResponseGetCountrySettings sr)
  3026. {
  3027. try
  3028. {
  3029. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("init"));
  3030. if (sr.FDCdata[0].DecimalSign != null)
  3031. FDCConvert.DecimalSeparator = sr.FDCdata[0].DecimalSign;
  3032. if (sr.FDCdata[0].ThousandDelimiter != null)
  3033. FDCConvert.ThousandSeparator = sr.FDCdata[0].ThousandDelimiter;
  3034. //clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, true);
  3035. Console.WriteLine("GetCountrySetting Response back, now switch to FC connected");
  3036. this.clientSocket.mainConnectionState = DeviceConnectionState.Connected;
  3037. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("end: DecimalSeparator={0}, ThousandSeparator={1}, connectionState={2}", FDCConvert.DecimalSeparator, FDCConvert.ThousandSeparator, this.clientSocket.mainConnectionState));
  3038. }
  3039. catch (Exception ex)
  3040. {
  3041. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3042. }
  3043. }
  3044. public void GetDSPLimits(int deviceId, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  3045. {
  3046. try
  3047. {
  3048. // create XML ServiceRequest object
  3049. ServiceRequestGetDSPLimits sr = new ServiceRequestGetDSPLimits();
  3050. sr.ApplicationSender = this.clientSocket.applicationSender;
  3051. sr.WorkstationID = this.clientSocket.workstationID;
  3052. ServiceRequestPOSdataGetDSPLimits posDataElem = new ServiceRequestPOSdataGetDSPLimits();
  3053. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  3054. ServiceRequestDeviceClass deviceClass = new ServiceRequestDeviceClass();
  3055. deviceClass.DeviceID = (deviceId == -1) ? "*" : Convert.ToString(deviceId);
  3056. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuelDispenser;
  3057. posDataElem.DeviceClass = deviceClass;
  3058. ServiceRequestPOSdataGetDSPLimits[] posDataArray = { posDataElem };
  3059. sr.POSdata = posDataArray;
  3060. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  3061. }
  3062. catch (Exception ex)
  3063. {
  3064. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3065. }
  3066. }
  3067. public void GetDSPLimitsResp(int requestId, string sOverallResult, ServiceResponseGetDSPLimits sr)
  3068. {
  3069. try
  3070. {
  3071. if (sr.FDCdata[0] != null && sr.FDCdata[0].DeviceClass != null)
  3072. for (int i = 0; i < sr.FDCdata[0].DeviceClass.Length; i++)
  3073. {
  3074. Trace.WriteLine(string.Format("type={0}, id={1}", sr.FDCdata[0].DeviceClass[0].Type, sr.FDCdata[0].DeviceClass[i].DeviceID));
  3075. }
  3076. Trace.WriteLine(string.Format("end"));
  3077. }
  3078. catch (Exception ex)
  3079. {
  3080. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3081. }
  3082. }
  3083. public void ChangeDSPLimits(int deviceId, int productNo, int modeNo, double maxTrxAmount, double maxTrxVolume, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  3084. {
  3085. try
  3086. {
  3087. // create XML ServiceRequest object
  3088. ServiceRequestChangeDSPLimits sr = new ServiceRequestChangeDSPLimits();
  3089. sr.ApplicationSender = this.clientSocket.applicationSender;
  3090. sr.WorkstationID = this.clientSocket.workstationID;
  3091. ServiceRequestPOSdataChangeDSPLimits posDataElem = new ServiceRequestPOSdataChangeDSPLimits();
  3092. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  3093. ServiceRequestDeviceClassChangeDSPLimits deviceClass = new ServiceRequestDeviceClassChangeDSPLimits();
  3094. deviceClass.DeviceID = (deviceId == -1) ? "*" : Convert.ToString(deviceId);
  3095. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuelDispenser;
  3096. //deviceClass.Product = new ServiceRequestProductDeviceClassChangeDSPLimits();
  3097. //deviceClass.Product.ProductNo = Convert.ToString(productNo);
  3098. //deviceClass.Product.ModeNo = Convert.ToString(modeNo);
  3099. deviceClass.ProductNo = Convert.ToString(productNo);
  3100. deviceClass.ModeNo = Convert.ToString(modeNo);
  3101. System.Globalization.NumberFormatInfo provider = new System.Globalization.NumberFormatInfo();
  3102. provider.NumberDecimalSeparator = System.Globalization.NumberFormatInfo.CurrentInfo.NumberDecimalSeparator;
  3103. provider.NumberGroupSeparator = System.Globalization.NumberFormatInfo.CurrentInfo.NumberGroupSeparator;
  3104. provider.NumberGroupSizes = System.Globalization.NumberFormatInfo.CurrentInfo.NumberGroupSizes;
  3105. //deviceClass.Product.MaxTrxAmount = string.Format(provider, "{0:F2}", maxTrxAmount);
  3106. deviceClass.MaxTrxAmount = string.Format(provider, "{0:F2}", maxTrxAmount);
  3107. provider.NumberDecimalDigits = 3;
  3108. //deviceClass.Product.MaxTrxVolume = string.Format(provider, "{0:F3}", maxTrxVolume);
  3109. deviceClass.MaxTrxVolume = string.Format(provider, "{0:F3}", maxTrxVolume);
  3110. posDataElem.DeviceClass = deviceClass;
  3111. ServiceRequestPOSdataChangeDSPLimits[] posDataArray = { posDataElem };
  3112. sr.POSdata = posDataArray;
  3113. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  3114. }
  3115. catch (Exception ex)
  3116. {
  3117. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3118. }
  3119. }
  3120. public void ChangeDSPLimitsResp(int requestId, string sOverallResult, ServiceResponseChangeDSPLimits sr)
  3121. {
  3122. try
  3123. {
  3124. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("init"));
  3125. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("end"));
  3126. }
  3127. catch (Exception ex)
  3128. {
  3129. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3130. }
  3131. }
  3132. public void SuspendFuelling(int deviceId, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  3133. {
  3134. try
  3135. {
  3136. // create XML ServiceRequest object
  3137. ServiceRequestSuspendFuelling sr = new ServiceRequestSuspendFuelling();
  3138. sr.ApplicationSender = this.clientSocket.applicationSender;
  3139. sr.WorkstationID = this.clientSocket.workstationID;
  3140. ServiceRequestPOSdataSuspendFuelling posDataElem = new ServiceRequestPOSdataSuspendFuelling();
  3141. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  3142. ServiceRequestDeviceClass deviceClass = new ServiceRequestDeviceClass();
  3143. deviceClass.DeviceID = Convert.ToString(deviceId);
  3144. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuellingPoint;
  3145. posDataElem.DeviceClass = deviceClass;
  3146. ServiceRequestPOSdataSuspendFuelling[] posDataArray = { posDataElem };
  3147. sr.POSdata = posDataArray;
  3148. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  3149. }
  3150. catch (Exception ex)
  3151. {
  3152. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3153. }
  3154. }
  3155. public void SuspendFuellingResp(int requestId, string sOverallResult, ServiceResponseSuspendFuelling sr)
  3156. {
  3157. try
  3158. {
  3159. string errorCode = (sr.FDCdata[0].FDCStatus != null) ? sr.FDCdata[0].FDCStatus : sr.FDCdata[0].DeviceClass[0].ErrorCode;
  3160. Trace.WriteLine(string.Format("type={0}, id={1}, errorCode={2}", sr.FDCdata[0].DeviceClass[0].Type, sr.FDCdata[0].DeviceClass[0].DeviceID, errorCode));
  3161. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, errorCode == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  3162. Trace.WriteLine(string.Format("end"));
  3163. }
  3164. catch (Exception ex)
  3165. {
  3166. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3167. }
  3168. }
  3169. public void ResumeFuelling(int deviceId, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  3170. {
  3171. try
  3172. {
  3173. // create XML ServiceRequest object
  3174. ServiceRequestResumeFuelling sr = new ServiceRequestResumeFuelling();
  3175. sr.ApplicationSender = this.clientSocket.applicationSender;
  3176. sr.WorkstationID = this.clientSocket.workstationID;
  3177. ServiceRequestPOSdataResumeFuelling posDataElem = new ServiceRequestPOSdataResumeFuelling();
  3178. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  3179. ServiceRequestDeviceClass deviceClass = new ServiceRequestDeviceClass();
  3180. deviceClass.DeviceID = Convert.ToString(deviceId);
  3181. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuellingPoint;
  3182. posDataElem.DeviceClass = deviceClass;
  3183. ServiceRequestPOSdataResumeFuelling[] posDataArray = { posDataElem };
  3184. sr.POSdata = posDataArray;
  3185. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  3186. }
  3187. catch (Exception ex)
  3188. {
  3189. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3190. }
  3191. }
  3192. public void ResumeFuellingResp(int requestId, string sOverallResult, ServiceResponseResumeFuelling sr)
  3193. {
  3194. try
  3195. {
  3196. string errorCode = (sr.FDCdata[0].FDCStatus != null) ? sr.FDCdata[0].FDCStatus : sr.FDCdata[0].DeviceClass[0].ErrorCode;
  3197. Trace.WriteLine(string.Format("ResumeFuellingResp type={0}, id={1}, errorCode={2}", sr.FDCdata[0].DeviceClass[0].Type, sr.FDCdata[0].DeviceClass[0].DeviceID, errorCode));
  3198. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, errorCode == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  3199. Trace.WriteLine(string.Format("ResumeFuellingResp end"));
  3200. }
  3201. catch (Exception ex)
  3202. {
  3203. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3204. }
  3205. }
  3206. public void LockTank(int deviceId, int tankNo, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  3207. {
  3208. try
  3209. {
  3210. // create XML ServiceRequest object
  3211. ServiceRequestLockTank sr = new ServiceRequestLockTank();
  3212. sr.ApplicationSender = this.clientSocket.applicationSender;
  3213. sr.WorkstationID = this.clientSocket.workstationID;
  3214. ServiceRequestPOSdataLockTank posDataElem = new ServiceRequestPOSdataLockTank();
  3215. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  3216. ServiceRequestDeviceClassLockTank deviceClass = new ServiceRequestDeviceClassLockTank();
  3217. deviceClass.DeviceID = Convert.ToString(deviceId);
  3218. deviceClass.TankNo = Convert.ToString(tankNo);
  3219. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_TankProbe;
  3220. posDataElem.DeviceClass = deviceClass;
  3221. ServiceRequestPOSdataLockTank[] posDataArray = { posDataElem };
  3222. sr.POSdata = posDataArray;
  3223. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  3224. }
  3225. catch (Exception ex)
  3226. {
  3227. Trace.WriteLine("LockTank Exception! " + ex.Message + " - " + ex.StackTrace);
  3228. }
  3229. }
  3230. public void LockTankResp(int requestId, string sOverallResult, ServiceResponseLockTank sr)
  3231. {
  3232. try
  3233. {
  3234. string errorCode = (sr.FDCdata[0].FDCStatus != null) ? sr.FDCdata[0].FDCStatus : sr.FDCdata[0].DeviceClass[0].ErrorCode;
  3235. Trace.WriteLine(string.Format("LockTankResp type={0}, id={1}, errorCode={2}", sr.FDCdata[0].DeviceClass[0].Type, sr.FDCdata[0].DeviceClass[0].DeviceID, errorCode));
  3236. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, errorCode == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  3237. Trace.WriteLine(string.Format("LockTankResp end"));
  3238. }
  3239. catch (Exception ex)
  3240. {
  3241. Trace.WriteLine("LockTankResp Exception! " + ex.Message + " - " + ex.StackTrace);
  3242. }
  3243. }
  3244. public void UnlockTank(int deviceId, int tankNo, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  3245. {
  3246. try
  3247. {
  3248. // create XML ServiceRequest object
  3249. ServiceRequestUnlockTank sr = new ServiceRequestUnlockTank();
  3250. sr.ApplicationSender = this.clientSocket.applicationSender;
  3251. sr.WorkstationID = this.clientSocket.workstationID;
  3252. ServiceRequestPOSdataUnlockTank posDataElem = new ServiceRequestPOSdataUnlockTank();
  3253. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  3254. ServiceRequestDeviceClassUnlockTank deviceClass = new ServiceRequestDeviceClassUnlockTank();
  3255. deviceClass.DeviceID = Convert.ToString(deviceId);
  3256. deviceClass.TankNo = Convert.ToString(tankNo);
  3257. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_TankProbe;
  3258. posDataElem.DeviceClass = deviceClass;
  3259. ServiceRequestPOSdataUnlockTank[] posDataArray = { posDataElem };
  3260. sr.POSdata = posDataArray;
  3261. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  3262. }
  3263. catch (Exception ex)
  3264. {
  3265. Trace.WriteLine("UnlockTank Exception! " + ex.Message + " - " + ex.StackTrace);
  3266. }
  3267. }
  3268. public void UnlockTankResp(int requestId, string sOverallResult, ServiceResponseUnlockTank sr)
  3269. {
  3270. try
  3271. {
  3272. string errorCode = (sr.FDCdata[0].FDCStatus != null) ? sr.FDCdata[0].FDCStatus : sr.FDCdata[0].DeviceClass[0].ErrorCode;
  3273. Trace.WriteLine(string.Format("UnlockTankResp type={0}, id={1}, errorCode={2}", sr.FDCdata[0].DeviceClass[0].Type, sr.FDCdata[0].DeviceClass[0].DeviceID, errorCode));
  3274. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, errorCode == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  3275. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("UnlockTankResp end"));
  3276. }
  3277. catch (Exception ex)
  3278. {
  3279. Trace.WriteLine("UnlockTankResp Exception! " + ex.Message + " - " + ex.StackTrace);
  3280. }
  3281. }
  3282. public void GetTankData(int deviceId, int tankNo, EventHandler<AsyncCompletedEventArgs<ITankReadingEx>> requestCompleted, object userToken, object src)
  3283. {
  3284. try
  3285. {
  3286. // create XML ServiceRequest object
  3287. ServiceRequestGetTankData sr = new ServiceRequestGetTankData();
  3288. sr.ApplicationSender = this.clientSocket.applicationSender;
  3289. sr.WorkstationID = this.clientSocket.workstationID;
  3290. ServiceRequestPOSdataGetTankData posDataElem = new ServiceRequestPOSdataGetTankData();
  3291. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  3292. ServiceRequestDeviceClassGetTankData deviceClass = new ServiceRequestDeviceClassGetTankData();
  3293. deviceClass.DeviceID = (deviceId == -1) ? "*" : Convert.ToString(deviceId);
  3294. deviceClass.TankNo = (tankNo == -1) ? "*" : Convert.ToString(tankNo);
  3295. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_TankProbe;
  3296. posDataElem.DeviceClass = deviceClass;
  3297. ServiceRequestPOSdataGetTankData[] posDataArray = { posDataElem };
  3298. sr.POSdata = posDataArray;
  3299. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true, null);//, (ITankReading)(new FUSIONTankReading()));
  3300. }
  3301. catch (Exception ex)
  3302. {
  3303. Trace.WriteLine("GetTankData Exception! " + ex.Message + " - " + ex.StackTrace);
  3304. }
  3305. }
  3306. public void GetTankDataResp(int requestId, string sOverallResult, ServiceResponseGetTankData sr)
  3307. {
  3308. try
  3309. {
  3310. // TODO Tank
  3311. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("GetTankDataResp init"));
  3312. ServiceResponseDeviceClassGetTankData tankdata = sr.FDCdata[0].DeviceClass[0];
  3313. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("GetTankDataResp data received: tank={0}, state={1}, fuelLevel={2}, fuelVolume={3}, waterLevel={4}, waterVolume={5}, temperature={6}",
  3314. tankdata.TankNo, tankdata.MeasurementData.TPStatus,
  3315. tankdata.MeasurementData.ProductLevel,
  3316. tankdata.MeasurementData.TotalObservedVolume,
  3317. tankdata.MeasurementData.WaterLevel,
  3318. tankdata.MeasurementData.WaterVolume,
  3319. tankdata.MeasurementData.AverageTemp));
  3320. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("GetTankDataResp: tank={0}, date={1}",
  3321. tankdata.TankNo, sr.FDCdata[0].FDCTimeStamp));
  3322. DateTime date = DateTime.Now;
  3323. try
  3324. {
  3325. date = Convert.ToDateTime(sr.FDCdata[0].FDCTimeStamp);
  3326. }
  3327. catch (Exception ex)
  3328. {
  3329. Trace.WriteLine("GetTankDataResp: Exception! " + ex.Message + " - " + ex.StackTrace);
  3330. Trace.WriteLine("GetTankDataResp: set datetime to now");
  3331. date = DateTime.Now;
  3332. }
  3333. string errorCode = (sr.FDCdata[0].FDCStatus != null) ? sr.FDCdata[0].FDCStatus : sr.FDCdata[0].DeviceClass[0].ErrorCode;
  3334. ProbeState probeState = ((errorCode != ErrorCode.ERRCD_OK.ToString()) ||
  3335. tankdata.DeviceState != null && convertLogicalDeviceState(tankdata.DeviceState) != LogicalDeviceState.FDC_READY) ? ProbeState.Failed : ProbeState.Ok;
  3336. FUSIONTankReading tankreading = new FUSIONTankReading(Convert.ToInt32(tankdata.TankNo), probeState,
  3337. date, FDCConvert.ToDecimal(tankdata.MeasurementData.ProductLevel), FDCConvert.ToDecimal(tankdata.MeasurementData.TotalObservedVolume),
  3338. 0, FDCConvert.ToDecimal(tankdata.MeasurementData.WaterLevel), FDCConvert.ToDecimal(tankdata.MeasurementData.WaterVolume), FDCConvert.ToDecimal(tankdata.MeasurementData.AverageTemp),
  3339. UnitOfMeasure.Liters, UnitOfMeasure.Liters, false);
  3340. //tankdata.Type;
  3341. //Convert.ToInt32(tankdata.ManualMode);
  3342. //FDCConvert.ToDecimal(tankdata.MeasurementData.GrossStandardVolume);
  3343. //FDCConvert.ToDecimal(tankdata.MeasurementData.ObservedDensity)
  3344. //FDCConvert.ToDecimal(tankdata.MeasurementData.TotalObservedVolume);
  3345. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString(), tankreading);
  3346. //foreach (ServiceResponseDeviceClassGetTankData tankdata in sr.FDCdata[0].DeviceClass)
  3347. //{
  3348. // if (OnTankData != null)
  3349. // {
  3350. // OnTankData.Invoke(this, new TankDataEventArgs(Convert.ToInt32(tankdata.DeviceID), Convert.ToInt32(tankdata.TankNo), tankdata.Type, Convert.ToInt32(tankdata.ManualMode),
  3351. // FDCConvert.ToDecimal(tankdata.MeasurementData.AverageTemp), FDCConvert.ToDecimal(tankdata.MeasurementData.GrossStandardVolume),
  3352. // FDCConvert.ToDecimal(tankdata.MeasurementData.ObservedDensity), FDCConvert.ToDecimal(tankdata.MeasurementData.ProductLevel),
  3353. // FDCConvert.ToDecimal(tankdata.MeasurementData.TotalObservedVolume), FDCConvert.ToDecimal(tankdata.MeasurementData.WaterLevel),
  3354. // Convert.ToInt32(tankdata.MeasurementData.TPStatus)));
  3355. // }
  3356. //}
  3357. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("GetTankDataResp end"));
  3358. }
  3359. catch (Exception ex)
  3360. {
  3361. Trace.WriteLine("GetTankDataResp Exception! " + ex.Message + " - " + ex.StackTrace);
  3362. }
  3363. }
  3364. public void ReserveFuelPoint(int deviceId, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  3365. {
  3366. try
  3367. {
  3368. // create XML ServiceRequest object
  3369. ServiceRequestReserveFuelPoint sr = new ServiceRequestReserveFuelPoint();
  3370. sr.ApplicationSender = this.clientSocket.applicationSender;
  3371. sr.WorkstationID = this.clientSocket.workstationID;
  3372. ServiceRequestPOSdataReserveFuelPoint posDataElem = new ServiceRequestPOSdataReserveFuelPoint();
  3373. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  3374. ServiceRequestDeviceClass deviceClass = new ServiceRequestDeviceClass();
  3375. deviceClass.DeviceID = Convert.ToString(deviceId);
  3376. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuellingPoint;
  3377. posDataElem.DeviceClass = deviceClass;
  3378. ServiceRequestPOSdataReserveFuelPoint[] posDataArray = { posDataElem };
  3379. sr.POSdata = posDataArray;
  3380. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  3381. }
  3382. catch (Exception ex)
  3383. {
  3384. Trace.WriteLine("ReserveFuelPoint Exception! " + ex.Message + " - " + ex.StackTrace);
  3385. }
  3386. }
  3387. public void ReserveFuelPointResp(int requestId, string sOverallResult, ServiceResponseReserveFuelPoint sr)
  3388. {
  3389. try
  3390. {
  3391. string errorCode = (sr.FDCdata[0].FDCStatus != null) ? sr.FDCdata[0].FDCStatus : sr.FDCdata[0].DeviceClass.ErrorCode;
  3392. Trace.WriteLine(string.Format("ReserveFuelPointResp type={0}, id={1}, errorCode={2}", sr.FDCdata[0].DeviceClass.Type, sr.FDCdata[0].DeviceClass.DeviceID, errorCode));
  3393. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, errorCode == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  3394. Trace.WriteLine(string.Format("ReserveFuelPointResp end"));
  3395. }
  3396. catch (Exception ex)
  3397. {
  3398. Trace.WriteLine("ReserveFuelPointResp Exception! " + ex.Message + " - " + ex.StackTrace);
  3399. }
  3400. }
  3401. public void FreeFuelPoint(int deviceId, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  3402. {
  3403. try
  3404. {
  3405. // create XML ServiceRequest object
  3406. ServiceRequestFreeFuelPoint sr = new ServiceRequestFreeFuelPoint();
  3407. sr.ApplicationSender = this.clientSocket.applicationSender;
  3408. sr.WorkstationID = this.clientSocket.workstationID;
  3409. ServiceRequestPOSdataFreeFuelPoint posDataElem = new ServiceRequestPOSdataFreeFuelPoint();
  3410. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  3411. ServiceRequestDeviceClass deviceClass = new ServiceRequestDeviceClass();
  3412. deviceClass.DeviceID = Convert.ToString(deviceId);
  3413. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuellingPoint;
  3414. posDataElem.DeviceClass = deviceClass;
  3415. ServiceRequestPOSdataFreeFuelPoint[] posDataArray = { posDataElem };
  3416. sr.POSdata = posDataArray;
  3417. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  3418. }
  3419. catch (Exception ex)
  3420. {
  3421. Trace.WriteLine("FreeFuelPoint Exception! " + ex.Message + " - " + ex.StackTrace);
  3422. }
  3423. }
  3424. public void StartFuelPointTest(int deviceId, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  3425. {
  3426. try
  3427. {
  3428. // create XML ServiceRequest object
  3429. ServiceRequestStartFuelPointTest sr = new ServiceRequestStartFuelPointTest();
  3430. sr.ApplicationSender = this.clientSocket.applicationSender;
  3431. sr.WorkstationID = this.clientSocket.workstationID;
  3432. ServiceRequestPOSdataStartFuelPointTest posDataElem = new ServiceRequestPOSdataStartFuelPointTest();
  3433. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  3434. ServiceRequestDeviceClass deviceClass = new ServiceRequestDeviceClass();
  3435. deviceClass.DeviceID = Convert.ToString(deviceId);
  3436. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuellingPoint;
  3437. posDataElem.DeviceClass = deviceClass;
  3438. ServiceRequestPOSdataStartFuelPointTest[] posDataArray = { posDataElem };
  3439. sr.POSdata = posDataArray;
  3440. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  3441. }
  3442. catch (Exception ex)
  3443. {
  3444. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3445. }
  3446. }
  3447. public void EndFuelPointTest(int deviceId, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  3448. {
  3449. try
  3450. {
  3451. // create XML ServiceRequest object
  3452. ServiceRequestEndFuelPointTest sr = new ServiceRequestEndFuelPointTest();
  3453. sr.ApplicationSender = this.clientSocket.applicationSender;
  3454. sr.WorkstationID = this.clientSocket.workstationID;
  3455. ServiceRequestPOSdataEndFuelPointTest posDataElem = new ServiceRequestPOSdataEndFuelPointTest();
  3456. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  3457. ServiceRequestDeviceClass deviceClass = new ServiceRequestDeviceClass();
  3458. deviceClass.DeviceID = Convert.ToString(deviceId);
  3459. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuellingPoint;
  3460. posDataElem.DeviceClass = deviceClass;
  3461. ServiceRequestPOSdataEndFuelPointTest[] posDataArray = { posDataElem };
  3462. sr.POSdata = posDataArray;
  3463. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  3464. }
  3465. catch (Exception ex)
  3466. {
  3467. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3468. }
  3469. }
  3470. public void OpenFuelPoint(int deviceId, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  3471. {
  3472. try
  3473. {
  3474. // create XML ServiceRequest object
  3475. ServiceRequestOpenFuelPoint sr = new ServiceRequestOpenFuelPoint();
  3476. sr.ApplicationSender = this.clientSocket.applicationSender;
  3477. sr.WorkstationID = this.clientSocket.workstationID;
  3478. ServiceRequestPOSdataOpenFuelPoint posDataElem = new ServiceRequestPOSdataOpenFuelPoint();
  3479. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  3480. ServiceRequestDeviceClass deviceClass = new ServiceRequestDeviceClass();
  3481. deviceClass.DeviceID = Convert.ToString(deviceId);
  3482. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuellingPoint;
  3483. posDataElem.DeviceClass = deviceClass;
  3484. ServiceRequestPOSdataOpenFuelPoint[] posDataArray = { posDataElem };
  3485. sr.POSdata = posDataArray;
  3486. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  3487. }
  3488. catch (Exception ex)
  3489. {
  3490. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3491. }
  3492. }
  3493. public void OpenDevice(int deviceId, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  3494. {
  3495. try
  3496. {
  3497. // create XML ServiceRequest object
  3498. ServiceRequestOpenDevice sr = new ServiceRequestOpenDevice();
  3499. sr.ApplicationSender = this.clientSocket.applicationSender;
  3500. sr.WorkstationID = this.clientSocket.workstationID;
  3501. ServiceRequestPOSdataOpenFuelPoint posDataElem = new ServiceRequestPOSdataOpenFuelPoint();
  3502. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  3503. ServiceRequestDeviceClass deviceClass = new ServiceRequestDeviceClass();
  3504. deviceClass.DeviceID = Convert.ToString(deviceId);
  3505. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuellingPoint;
  3506. posDataElem.DeviceClass = deviceClass;
  3507. ServiceRequestPOSdataOpenFuelPoint[] posDataArray = { posDataElem };
  3508. sr.POSdata = posDataArray;
  3509. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  3510. }
  3511. catch (Exception ex)
  3512. {
  3513. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3514. }
  3515. }
  3516. public void CloseFuelPoint(int deviceId, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  3517. {
  3518. try
  3519. {
  3520. // create XML ServiceRequest object
  3521. ServiceRequestCloseFuelPoint sr = new ServiceRequestCloseFuelPoint();
  3522. sr.ApplicationSender = this.clientSocket.applicationSender;
  3523. sr.WorkstationID = this.clientSocket.workstationID;
  3524. ServiceRequestPOSdataCloseFuelPoint posDataElem = new ServiceRequestPOSdataCloseFuelPoint();
  3525. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  3526. ServiceRequestDeviceClass deviceClass = new ServiceRequestDeviceClass();
  3527. deviceClass.DeviceID = Convert.ToString(deviceId);
  3528. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuellingPoint;
  3529. posDataElem.DeviceClass = deviceClass;
  3530. ServiceRequestPOSdataCloseFuelPoint[] posDataArray = { posDataElem };
  3531. sr.POSdata = posDataArray;
  3532. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  3533. }
  3534. catch (Exception ex)
  3535. {
  3536. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3537. }
  3538. }
  3539. public void CloseDevice(int deviceId, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  3540. {
  3541. try
  3542. {
  3543. // create XML ServiceRequest object
  3544. ServiceRequestCloseDevice sr = new ServiceRequestCloseDevice();
  3545. sr.ApplicationSender = this.clientSocket.applicationSender;
  3546. sr.WorkstationID = this.clientSocket.workstationID;
  3547. ServiceRequestPOSdataCloseFuelPoint posDataElem = new ServiceRequestPOSdataCloseFuelPoint();
  3548. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  3549. ServiceRequestDeviceClass deviceClass = new ServiceRequestDeviceClass();
  3550. deviceClass.DeviceID = Convert.ToString(deviceId);
  3551. deviceClass.Type = Wayne.FDCPOSLibrary.DeviceType.DT_FuellingPoint;
  3552. posDataElem.DeviceClass = deviceClass;
  3553. ServiceRequestPOSdataCloseFuelPoint[] posDataArray = { posDataElem };
  3554. sr.POSdata = posDataArray;
  3555. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  3556. }
  3557. catch (Exception ex)
  3558. {
  3559. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3560. }
  3561. }
  3562. public void SetDeviceAlarm(string deviceType, int deviceId, int alarmCode, string alarmMsg, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  3563. {
  3564. try
  3565. {
  3566. // create XML ServiceRequest object
  3567. ServiceRequestSetDeviceAlarm sr = new ServiceRequestSetDeviceAlarm();
  3568. sr.ApplicationSender = this.clientSocket.applicationSender;
  3569. sr.WorkstationID = this.clientSocket.workstationID;
  3570. ServiceRequestPOSdataSetDeviceAlarm posDataElem = new ServiceRequestPOSdataSetDeviceAlarm();
  3571. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  3572. ServiceRequestDeviceClassSetDeviceAlarm deviceClass = new ServiceRequestDeviceClassSetDeviceAlarm();
  3573. deviceClass.DeviceID = Convert.ToString(deviceId);
  3574. deviceClass.Type = deviceType;
  3575. ServiceRequestDeviceAlarmMsg alarmElem = new ServiceRequestDeviceAlarmMsg();
  3576. alarmElem.Number = Convert.ToString(alarmCode);
  3577. alarmElem.Text = alarmMsg;
  3578. ServiceRequestDeviceAlarmMsg[] alarmMsgArray = { alarmElem };
  3579. posDataElem.DeviceClass = deviceClass;
  3580. ServiceRequestPOSdataSetDeviceAlarm[] posDataArray = { posDataElem };
  3581. sr.POSdata = posDataArray;
  3582. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  3583. }
  3584. catch (Exception ex)
  3585. {
  3586. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3587. }
  3588. }
  3589. public void FreeFuelPointResp(int requestId, string sOverallResult, ServiceResponseFreeFuelPoint sr)
  3590. {
  3591. try
  3592. {
  3593. string errorCode = (sr.FDCdata[0].FDCStatus != null) ? sr.FDCdata[0].FDCStatus : sr.FDCdata[0].DeviceClass.ErrorCode;
  3594. Trace.WriteLine(string.Format("type={0}, id={1}, errorCode={2}", sr.FDCdata[0].DeviceClass.Type, sr.FDCdata[0].DeviceClass.DeviceID, errorCode));
  3595. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, errorCode == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  3596. Trace.WriteLine(string.Format("end"));
  3597. }
  3598. catch (Exception ex)
  3599. {
  3600. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3601. }
  3602. }
  3603. public void StartFuelPointTestResp(int requestId, string sOverallResult, ServiceResponseStartFuelPointTest sr)
  3604. {
  3605. try
  3606. {
  3607. string errorCode = (sr.FDCdata[0].FDCStatus != null) ? sr.FDCdata[0].FDCStatus : sr.FDCdata[0].DeviceClass.ErrorCode;
  3608. Trace.WriteLine(string.Format("type={0}, id={1}, errorCode{2}", sr.FDCdata[0].DeviceClass.Type, sr.FDCdata[0].DeviceClass.DeviceID, errorCode));
  3609. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, errorCode == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  3610. Trace.WriteLine(string.Format("end"));
  3611. }
  3612. catch (Exception ex)
  3613. {
  3614. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3615. }
  3616. }
  3617. public void EndFuelPointTestResp(int requestId, string sOverallResult, ServiceResponseEndFuelPointTest sr)
  3618. {
  3619. try
  3620. {
  3621. string errorCode = (sr.FDCdata[0].FDCStatus != null) ? sr.FDCdata[0].FDCStatus : sr.FDCdata[0].DeviceClass.ErrorCode;
  3622. Trace.WriteLine(string.Format("type={0}, id={1}, errorCode{2}", sr.FDCdata[0].DeviceClass.Type, sr.FDCdata[0].DeviceClass.DeviceID, errorCode));
  3623. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, errorCode == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  3624. Trace.WriteLine(string.Format("end"));
  3625. }
  3626. catch (Exception ex)
  3627. {
  3628. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3629. }
  3630. }
  3631. public void OpenFuelPointResp(int requestId, string sOverallResult, ServiceResponseOpenFuelPoint sr)
  3632. {
  3633. try
  3634. {
  3635. string errorCode = sr.FDCdata[0].FDCStatus;
  3636. Trace.WriteLine(string.Format("requestId={0}, errorCode={1}", requestId, errorCode));
  3637. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, errorCode == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  3638. Trace.WriteLine(string.Format("end"));
  3639. }
  3640. catch (Exception ex)
  3641. {
  3642. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3643. }
  3644. }
  3645. public void CloseFuelPointResp(int requestId, string sOverallResult, ServiceResponseCloseFuelPoint sr)
  3646. {
  3647. try
  3648. {
  3649. string errorCode = sr.FDCdata[0].FDCStatus;
  3650. Trace.WriteLine(string.Format("requestId={0}, errorCode={1}", requestId, errorCode));
  3651. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, errorCode == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  3652. Trace.WriteLine(string.Format("end"));
  3653. }
  3654. catch (Exception ex)
  3655. {
  3656. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3657. }
  3658. }
  3659. public void OpenDeviceResp(int requestId, string sOverallResult, ServiceResponseOpenDevice sr)
  3660. {
  3661. try
  3662. {
  3663. string errorCode = (sr.FDCdata[0].FDCStatus != null) ? sr.FDCdata[0].FDCStatus : sr.FDCdata[0].DeviceClass[0].ErrorCode;
  3664. Trace.WriteLine(string.Format("OpenDeviceResp requestId={0}, errorCode={1}", requestId, errorCode));
  3665. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, errorCode == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  3666. Trace.WriteLine(string.Format("OpenDeviceResp end"));
  3667. }
  3668. catch (Exception ex)
  3669. {
  3670. Trace.WriteLine("OpenDeviceResp Exception! " + ex.Message + " - " + ex.StackTrace);
  3671. }
  3672. }
  3673. public void CloseDeviceResp(int requestId, string sOverallResult, ServiceResponseCloseDevice sr)
  3674. {
  3675. try
  3676. {
  3677. string errorCode = (sr.FDCdata[0].FDCStatus != null) ? sr.FDCdata[0].FDCStatus : sr.FDCdata[0].DeviceClass[0].ErrorCode;
  3678. Trace.WriteLine(string.Format("CloseDeviceResp requestId={0}, errorCode={1}", requestId, errorCode));
  3679. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, errorCode == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  3680. Trace.WriteLine(string.Format("CloseDeviceResp end"));
  3681. }
  3682. catch (Exception ex)
  3683. {
  3684. Trace.WriteLine("CloseDeviceResp Exception! " + ex.Message + " - " + ex.StackTrace);
  3685. }
  3686. }
  3687. public void SetDeviceAlarmResp(int requestId, string sOverallResult, ServiceResponseSetDeviceAlarm sr)
  3688. {
  3689. try
  3690. {
  3691. string errorCode = sr.FDCdata[0].FDCStatus;
  3692. Trace.WriteLine(string.Format("SetDeviceAlarmResp requestId={0}, errorCode={1}", requestId, errorCode));
  3693. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, errorCode == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  3694. Trace.WriteLine(string.Format("SetDeviceAlarmResp end"));
  3695. }
  3696. catch (Exception ex)
  3697. {
  3698. Trace.WriteLine("SetDeviceAlarmResp Exception! " + ex.Message + " - " + ex.StackTrace);
  3699. }
  3700. }
  3701. public void OptAddSerialPort(int optId, string port, int baudRate, int dataBit, int stopBit, int parity, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  3702. {
  3703. try
  3704. {
  3705. Trace.WriteLine(string.Format("OptAddSerialPort init: tp={0}, port={1}", optId, port));
  3706. // create XML ServiceRequest object
  3707. ServiceRequestOPTAdd sr = new ServiceRequestOPTAdd();
  3708. sr.ApplicationSender = this.clientSocket.applicationSender;
  3709. sr.WorkstationID = this.clientSocket.workstationID;
  3710. ServiceRequestPOSdataOPTAdd posDataElem = new ServiceRequestPOSdataOPTAdd();
  3711. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  3712. ServiceRequestDeviceClassOPTAdd optadd = new ServiceRequestDeviceClassOPTAdd();
  3713. optadd.DeviceID = (optId == -1) ? "*" : Convert.ToString(optId);
  3714. optadd.Type = Wayne.FDCPOSLibrary.DeviceType.DT_OutdoorPaymentTerminal;
  3715. ServiceRequestDeviceClassSerialPortOPTAdd serialPort = new ServiceRequestDeviceClassSerialPortOPTAdd();
  3716. serialPort.Port = port;
  3717. serialPort.BaudRate = Convert.ToString(baudRate);
  3718. serialPort.DataBit = Convert.ToString(dataBit);
  3719. serialPort.StopBit = Convert.ToString(stopBit);
  3720. serialPort.Parity = Convert.ToString(parity);
  3721. optadd.serialPort = serialPort;
  3722. posDataElem.DeviceClass = optadd;
  3723. ServiceRequestPOSdataOPTAdd[] posDataArray = { posDataElem };
  3724. sr.POSdata = posDataArray;
  3725. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  3726. Trace.WriteLine(string.Format("OptAddSerialPort end: tp={0}, port={1}", optId, port));
  3727. }
  3728. catch (Exception ex)
  3729. {
  3730. Trace.WriteLine("OptAddSerialPort Exception! " + ex.Message + " - " + ex.StackTrace);
  3731. }
  3732. }
  3733. public void OptAddTCP(int optId, string address, int port, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  3734. {
  3735. try
  3736. {
  3737. // create XML ServiceRequest object
  3738. ServiceRequestOPTAdd sr = new ServiceRequestOPTAdd();
  3739. sr.ApplicationSender = this.clientSocket.applicationSender;
  3740. sr.WorkstationID = this.clientSocket.workstationID;
  3741. ServiceRequestPOSdataOPTAdd posDataElem = new ServiceRequestPOSdataOPTAdd();
  3742. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  3743. ServiceRequestDeviceClassOPTAdd optadd = new ServiceRequestDeviceClassOPTAdd();
  3744. optadd.DeviceID = (optId == -1) ? "*" : Convert.ToString(optId);
  3745. optadd.Type = Wayne.FDCPOSLibrary.DeviceType.DT_OutdoorPaymentTerminal;
  3746. ServiceRequestDeviceClassTCPOPTAdd tcp = new ServiceRequestDeviceClassTCPOPTAdd();
  3747. tcp.Address = address;
  3748. tcp.Port = Convert.ToString(port);
  3749. optadd.tcp = tcp;
  3750. posDataElem.DeviceClass = optadd;
  3751. ServiceRequestPOSdataOPTAdd[] posDataArray = { posDataElem };
  3752. sr.POSdata = posDataArray;
  3753. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  3754. }
  3755. catch (Exception ex)
  3756. {
  3757. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3758. }
  3759. }
  3760. public void OptAddResp(int requestId, string sOverallResult, ServiceResponseOPTAdd sr)
  3761. {
  3762. try
  3763. {
  3764. //clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, sr.FDCdata[0].FDCStatus == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  3765. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  3766. }
  3767. catch (Exception ex)
  3768. {
  3769. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3770. }
  3771. }
  3772. public void OptRemove(int optId, EventHandler<AsyncCompletedEventArgs> requestCompleted, object userToken, object src)
  3773. {
  3774. try
  3775. {
  3776. // create XML ServiceRequest object
  3777. ServiceRequestOPTRemove sr = new ServiceRequestOPTRemove();
  3778. sr.ApplicationSender = this.clientSocket.applicationSender;
  3779. sr.WorkstationID = this.clientSocket.workstationID;
  3780. ServiceRequestPOSdataOPTRemove posDataElem = new ServiceRequestPOSdataOPTRemove();
  3781. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  3782. ServiceRequestDeviceClassOPTRemove optRemove = new ServiceRequestDeviceClassOPTRemove();
  3783. optRemove.DeviceID = (optId == -1) ? "*" : Convert.ToString(optId);
  3784. optRemove.Type = Wayne.FDCPOSLibrary.DeviceType.DT_OutdoorPaymentTerminal;
  3785. posDataElem.DeviceClass = optRemove;
  3786. ServiceRequestPOSdataOPTRemove[] posDataArray = { posDataElem };
  3787. sr.POSdata = posDataArray;
  3788. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true);
  3789. }
  3790. catch (Exception ex)
  3791. {
  3792. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3793. }
  3794. }
  3795. public void OptRemoveResp(int requestId, string sOverallResult, ServiceResponseOPTRemove sr)
  3796. {
  3797. try
  3798. {
  3799. //clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, sr.FDCdata[0].FDCStatus == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  3800. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  3801. }
  3802. catch (Exception ex)
  3803. {
  3804. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3805. }
  3806. }
  3807. public void OptWrite(int optId, byte[] message, EventHandler<OptWriteCompletedEventArgs> requestCompleted, object userToken, object src)
  3808. {
  3809. try
  3810. {
  3811. // create XML ServiceRequest object
  3812. if (FDCGlobal.ProtocolVersion <= FDCVersion.V0007)
  3813. {
  3814. ServiceRequestOPTWriteV07 sr = new ServiceRequestOPTWriteV07();
  3815. sr.ApplicationSender = this.clientSocket.applicationSender;
  3816. sr.WorkstationID = this.clientSocket.workstationID;
  3817. ServiceRequestPOSdataOPTWriteV07 posDataElem = new ServiceRequestPOSdataOPTWriteV07();
  3818. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  3819. ServiceRequestDeviceClassOPTWriteV07 optwrite = new ServiceRequestDeviceClassOPTWriteV07();
  3820. optwrite.DeviceID = (optId == -1) ? "*" : Convert.ToString(optId);
  3821. optwrite.Type = Wayne.FDCPOSLibrary.DeviceType.DT_OutdoorPaymentTerminal;
  3822. optwrite.Message = message;
  3823. posDataElem.DeviceClass = optwrite;
  3824. ServiceRequestPOSdataOPTWriteV07[] posDataArray = { posDataElem };
  3825. sr.POSdata = posDataArray;
  3826. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true, null);//, new OptWriteCompletedEventArgs(true, userToken, 0));
  3827. }
  3828. else
  3829. {
  3830. ServiceRequestOPTWrite sr = new ServiceRequestOPTWrite();
  3831. sr.ApplicationSender = this.clientSocket.applicationSender;
  3832. sr.WorkstationID = this.clientSocket.workstationID;
  3833. ServiceRequestPOSdataOPTWrite posDataElem = new ServiceRequestPOSdataOPTWrite();
  3834. posDataElem.POSTimeStamp = DateTime.Now.ToString(FDCConvert.DateFormat);
  3835. ServiceRequestDeviceClassOPTWrite optwrite = new ServiceRequestDeviceClassOPTWrite();
  3836. optwrite.DeviceID = (optId == -1) ? "*" : Convert.ToString(optId);
  3837. optwrite.Type = Wayne.FDCPOSLibrary.DeviceType.DT_OutdoorPaymentTerminal;
  3838. optwrite.Message = UTF8Encoding.UTF8.GetString(message, 0, message.GetLength(0)); ;
  3839. posDataElem.DeviceClass = optwrite;
  3840. ServiceRequestPOSdataOPTWrite[] posDataArray = { posDataElem };
  3841. sr.POSdata = posDataArray;
  3842. clientSocket.ifsfMessages.EnqueueMessage(sr, requestCompleted, userToken, src, true, null);//, new OptWriteCompletedEventArgs(true, userToken, 0));
  3843. }
  3844. }
  3845. catch (Exception ex)
  3846. {
  3847. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3848. }
  3849. }
  3850. public void OptWriteResp(int requestId, string sOverallResult, ServiceResponseOPTWrite sr)
  3851. {
  3852. try
  3853. {
  3854. //clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, sr.FDCdata[0].FDCStatus == ErrorCode.ERRCD_OK.ToString() && sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  3855. clientSocket.ifsfMessages.asyncResponseManager.SendResponse(requestId, sOverallResult == FDCPOSLibrary.OverallResult.Success.ToString());
  3856. }
  3857. catch (Exception ex)
  3858. {
  3859. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3860. }
  3861. }
  3862. public void HeartbeatMsg()
  3863. {
  3864. try
  3865. {
  3866. // when the heartbeat is received the disconnection timer is reset (the timer that is activated when the heartbeat is no more received)
  3867. Trace.WriteLineIf(Trace.CheckTraceLevel(3), "Ci sono !");
  3868. heartbeat.ResetDisconnectionTimeout();
  3869. }
  3870. catch (Exception ex)
  3871. {
  3872. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3873. }
  3874. }
  3875. public void DeviceStateChangeMsg(FDCMessageDeviceStateChange msg)
  3876. {
  3877. try
  3878. {
  3879. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("init DeviceStateChangeMsg: type={0}, id={1}, state={2}, substate={3}", msg.FDCdata[0].DeviceClass[0].Type, msg.FDCdata[0].DeviceClass[0].DeviceID, msg.FDCdata[0].DeviceClass[0].LogicalState, msg.FDCdata[0].DeviceClass[0].LogicalSubState));
  3880. if (OnDeviceStateChange != null)
  3881. {
  3882. string deviceType = msg.FDCdata[0].DeviceClass[0].Type;
  3883. int deviceId = Convert.ToInt16(msg.FDCdata[0].DeviceClass[0].DeviceID);
  3884. LogicalDeviceState state = convertLogicalDeviceState(msg.FDCdata[0].DeviceClass[0].LogicalState);
  3885. LogicalDeviceState substate = convertLogicalDeviceState(msg.FDCdata[0].DeviceClass[0].LogicalSubState);
  3886. int nozzleUp = 0;
  3887. if (msg.FDCdata[0].DeviceClass[0].Nozzle != null)
  3888. {
  3889. foreach (NozzleStateClass nozzleState in msg.FDCdata[0].DeviceClass[0].Nozzle)
  3890. {
  3891. if (nozzleState.LogicalNozzle == "NozzleUp")
  3892. nozzleUp = Convert.ToInt32(nozzleState.NozzleNo);
  3893. }
  3894. }
  3895. OnDeviceStateChange.Invoke(this, new DeviceStateChangedEventArgs(deviceType, deviceId, state, substate, "", nozzleUp));
  3896. }
  3897. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("end DeviceStateChangeMsg"));
  3898. }
  3899. catch (Exception ex)
  3900. {
  3901. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3902. }
  3903. }
  3904. public void FPStateChangeMsg(FDCMessageFPStateChange msg)
  3905. {
  3906. try
  3907. {
  3908. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("init FPStateChangeMsg: type={0}, id={1}, state={2}, substate={3}", msg.FDCdata[0].DeviceClass[0].Type, msg.FDCdata[0].DeviceClass[0].DeviceID, msg.FDCdata[0].DeviceClass[0].DeviceState, msg.FDCdata[0].DeviceClass[0].DeviceSubState));
  3909. if (OnDeviceStateChange != null)
  3910. {
  3911. string deviceType = msg.FDCdata[0].DeviceClass[0].Type;
  3912. int deviceId = Convert.ToInt16(msg.FDCdata[0].DeviceClass[0].DeviceID);
  3913. LogicalDeviceState state = convertLogicalDeviceState(msg.FDCdata[0].DeviceClass[0].DeviceState);
  3914. LogicalDeviceState substate = convertLogicalDeviceState(msg.FDCdata[0].DeviceClass[0].DeviceSubState);
  3915. string lockingAS = msg.FDCdata[0].DeviceClass[0].LockingApplicationSender;
  3916. int nozzleUp = 0;
  3917. if (msg.FDCdata[0].DeviceClass[0].Nozzle != null)
  3918. {
  3919. foreach (NozzleStateClass nozzleState in msg.FDCdata[0].DeviceClass[0].Nozzle)
  3920. {
  3921. if (nozzleState.LogicalNozzle == "NozzleUp")
  3922. nozzleUp = Convert.ToInt32(nozzleState.NozzleNo);
  3923. }
  3924. }
  3925. OnDeviceStateChange.Invoke(this, new DeviceStateChangedEventArgs(deviceType, deviceId, state, substate, lockingAS, nozzleUp));
  3926. }
  3927. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("end DeviceStateChangeMsg"));
  3928. }
  3929. catch (Exception ex)
  3930. {
  3931. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3932. }
  3933. }
  3934. public void TPStateChangeMsg(FDCMessageTPStateChange msg)
  3935. {
  3936. try
  3937. {
  3938. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("init TPStateChangeMsg: type={0}, id={1}, state={2}", msg.FDCdata[0].DeviceClass[0].Type, msg.FDCdata[0].DeviceClass[0].DeviceID, msg.FDCdata[0].DeviceClass[0].DeviceState));
  3939. if (OnDeviceStateChange != null)
  3940. {
  3941. string deviceType = msg.FDCdata[0].DeviceClass[0].Type;
  3942. int deviceId = Convert.ToInt16(msg.FDCdata[0].DeviceClass[0].DeviceID);
  3943. LogicalDeviceState state = convertLogicalDeviceState(msg.FDCdata[0].DeviceClass[0].DeviceState);
  3944. OnDeviceStateChange.Invoke(this, new DeviceStateChangedEventArgs(deviceType, deviceId, state, LogicalDeviceState.FDC_UNDEFINED, "", 0));
  3945. }
  3946. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("end DeviceStateChangeMsg"));
  3947. }
  3948. catch (Exception ex)
  3949. {
  3950. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3951. }
  3952. }
  3953. public void VIRStateChangeMsg(FDCMessageVIRStateChange msg)
  3954. {
  3955. try
  3956. {
  3957. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("init VIRStateChangeMsg: type={0}, id={1}, state={2}, substate={3}", msg.FDCdata[0].DeviceClass[0].Type, msg.FDCdata[0].DeviceClass[0].DeviceID, msg.FDCdata[0].DeviceClass[0].DeviceState, msg.FDCdata[0].DeviceClass[0].DeviceSubState));
  3958. if (OnVirStateChange != null)
  3959. {
  3960. string deviceType = msg.FDCdata[0].DeviceClass[0].Type;
  3961. int deviceId = Convert.ToInt16(msg.FDCdata[0].DeviceClass[0].DeviceID);
  3962. LogicalDeviceState state;
  3963. DeviceConnectionState deviceState = DeviceConnectionState.Unknown;
  3964. if (msg.FDCdata[0].DeviceClass[0].Vir != null)
  3965. {
  3966. foreach (VIRStateClass virState in msg.FDCdata[0].DeviceClass[0].Vir)
  3967. {
  3968. state = convertLogicalDeviceState(virState.DeviceState);
  3969. if (state == LogicalDeviceState.FDC_READY)
  3970. deviceState = DeviceConnectionState.Connected;
  3971. else if (state == LogicalDeviceState.FDC_OFFLINE)
  3972. deviceState = DeviceConnectionState.Disconnected;
  3973. else
  3974. deviceState = DeviceConnectionState.Unknown;
  3975. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("init VIRStateChangeMsg: type={0}, id={1}, virID={2}, virstate={3}", msg.FDCdata[0].DeviceClass[0].Type, msg.FDCdata[0].DeviceClass[0].DeviceID, virState.VirID, virState.DeviceState));
  3976. OnVirStateChange.BeginInvoke(this, new VIRStateChangedEventArgs(deviceId, virState.VirID, deviceState), null, null);
  3977. }
  3978. }
  3979. }
  3980. else
  3981. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("OnVirStateChange == null"));
  3982. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("end VIRStateChangeMsg"));
  3983. }
  3984. catch (Exception ex)
  3985. {
  3986. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  3987. }
  3988. }
  3989. private void CalcCallback(IAsyncResult ar)
  3990. {
  3991. }
  3992. public void FDCStoppedMsg(FDCMessageStopped msg)
  3993. {
  3994. try
  3995. {
  3996. Trace.WriteLine(string.Format("init FDCStoppedMsg"));
  3997. this.clientSocket.mainConnectionState = DeviceConnectionState.Connecting;
  3998. Trace.WriteLine(string.Format("end FDCStoppedMsg"));
  3999. }
  4000. catch (Exception ex)
  4001. {
  4002. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  4003. }
  4004. }
  4005. public void FDCStartedMsg(FDCMessageStarted msg)
  4006. {
  4007. try
  4008. {
  4009. Trace.WriteLine(string.Format("init FDCStartedMsg"));
  4010. //QQ-
  4011. //this.clientSocket.mainConnectionState = DeviceConnectionState.Connected;
  4012. Trace.WriteLine(string.Format("end FDCStartedMsg"));
  4013. }
  4014. catch (Exception ex)
  4015. {
  4016. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  4017. }
  4018. }
  4019. public void TwinMasterReadyMsg(FDCMessageTwinMasterIsOn msg)
  4020. {
  4021. try
  4022. {
  4023. Trace.WriteLine(string.Format("init TwinMasterReadyMsg"));
  4024. if (OnTwinMasterReady != null)
  4025. OnTwinMasterReady.BeginInvoke(this, null, null, null);
  4026. Trace.WriteLine(string.Format("end TwinMasterReadyMsg"));
  4027. }
  4028. catch (Exception ex)
  4029. {
  4030. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  4031. }
  4032. }
  4033. public void CurrentFuellingStatusMsg(FDCMessageCurrentFuellingStatus msg)
  4034. {
  4035. try
  4036. {
  4037. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("init CurrentFuellingStatusMsg: type={0}, id={1}, volume={2}, amount={3}", msg.FDCdata[0].DeviceClass[0].Type, msg.FDCdata[0].DeviceClass[0].DeviceID, msg.FDCdata[0].DeviceClass[0].CurrentVolume, msg.FDCdata[0].DeviceClass[0].CurrentAmount));
  4038. if (OnCurrentFuellingStatus != null)
  4039. {
  4040. string deviceType = msg.FDCdata[0].DeviceClass[0].Type;
  4041. int deviceId = Convert.ToInt16(msg.FDCdata[0].DeviceClass[0].DeviceID);
  4042. int nozzleId = Convert.ToInt16(msg.FDCdata[0].DeviceClass[0].CurrentNozzleNo);
  4043. Decimal volume = FDCConvert.ToDecimal(msg.FDCdata[0].DeviceClass[0].CurrentVolume);
  4044. Decimal amount = FDCConvert.ToDecimal(msg.FDCdata[0].DeviceClass[0].CurrentAmount);
  4045. Decimal price = FDCConvert.ToDecimal(msg.FDCdata[0].DeviceClass[0].CurrentUnitPrice);
  4046. OnCurrentFuellingStatus.BeginInvoke(this, new CurrentFuellingStatusEventArgs(deviceType, deviceId, nozzleId, volume, amount, price, ""), null, null);
  4047. }
  4048. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("end CurrentFuellingStatusMsg"));
  4049. }
  4050. catch (Exception ex)
  4051. {
  4052. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  4053. }
  4054. }
  4055. public void DeviceAlarmMsg(FDCMessageDeviceAlarm msg)
  4056. {
  4057. try
  4058. {
  4059. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("init DeviceAlarmMsg: type={0}, id={1}", msg.FDCdata[0].DeviceClass[0].Type, msg.FDCdata[0].DeviceClass[0].DeviceID));
  4060. string deviceType = "";
  4061. int deviceId = 0;
  4062. foreach (FDCMessageDeviceAlarmDeviceClass device in msg.FDCdata[0].DeviceClass)
  4063. {
  4064. deviceType = device.Type;
  4065. deviceId = Convert.ToInt16(device.DeviceID);
  4066. if (device.AlarmMsg != null && device.AlarmMsg.Length > 0)
  4067. {
  4068. foreach (FDCMessageDeviceAlarmMsg alarmmsg in device.AlarmMsg)
  4069. {
  4070. if (OnDeviceAlarm != null)
  4071. {
  4072. int alarmId = Convert.ToInt32(alarmmsg.Number);
  4073. OnDeviceAlarm.BeginInvoke(this, new DeviceAlarmEventArgs(deviceType, deviceId, alarmId, alarmmsg.Text), null, null);
  4074. }
  4075. }
  4076. }
  4077. else //if (deviceType == "TP") // send empty message for Tank Probe
  4078. {
  4079. if (OnDeviceAlarm != null)
  4080. {
  4081. OnDeviceAlarm.BeginInvoke(this, new DeviceAlarmEventArgs(deviceType, deviceId, 0, ""), null, null);
  4082. }
  4083. }
  4084. }
  4085. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("end DeviceAlarmMsg"));
  4086. }
  4087. catch (Exception ex)
  4088. {
  4089. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  4090. }
  4091. }
  4092. public void FuelSaleTrxMsg(FDCMessageFuelSaleTrx msg)
  4093. {
  4094. try
  4095. {
  4096. Trace.WriteLine(string.Format("FuelSaleTrxMsg init"));
  4097. //foreach (FDCMessageDeviceClassFuelSaleTrx deviceClass in msg.FDCdata[0].DeviceClass)
  4098. if (msg != null && msg.FDCdata != null && msg.FDCdata[0] != null && msg.FDCdata[0].DeviceClass != null)
  4099. {
  4100. FDCMessageDeviceClassFuelSaleTrx deviceClass = msg.FDCdata[0].DeviceClass;
  4101. if (OnFuelSaleTrx != null)
  4102. {
  4103. string deviceType = deviceClass.Type;
  4104. Trace.WriteLine(string.Format("FuelSaleTrxMsg type={0}, id={1}", deviceClass.Type, deviceClass.DeviceID));
  4105. Trace.WriteLine(string.Format("FuelSaleTrxMsg nozzle={0}, price={1}, vol={2}, amount={3}", deviceClass.NozzleNo, deviceClass.UnitPrice, deviceClass.Volume, deviceClass.Amount));
  4106. Trace.WriteLine(string.Format("FuelSaleTrxMsg authAS={0}, lockAS={1}", deviceClass.AuthorisationApplicationSender, deviceClass.LockingApplicationSender));
  4107. int deviceId = Convert.ToInt16(deviceClass.DeviceID);
  4108. int nozzleId = Convert.ToInt16(deviceClass.NozzleNo);
  4109. Decimal volume = FDCConvert.ToDecimal(deviceClass.Volume);
  4110. Decimal amount = FDCConvert.ToDecimal(deviceClass.Amount);
  4111. Decimal price = FDCConvert.ToDecimal(deviceClass.UnitPrice);
  4112. int transactionSeqNum = Convert.ToInt32(deviceClass.TransactionSeqNo);
  4113. Wayne.FDCPOSLibrary.FuellingState transactionState = convertFuellingState(deviceClass.State);
  4114. int completionReason = Convert.ToInt32(deviceClass.CompletionReason);
  4115. int fuelMode = (deviceClass.FuelMode != null && deviceClass.FuelMode.ModeNo != null && deviceClass.FuelMode.ModeNo != "") ? Convert.ToInt32(deviceClass.FuelMode.ModeNo) : 0;
  4116. DateTime trxStartDateTime = Convert.ToDateTime(deviceClass.StartTimeStamp);
  4117. DateTime trxEndDateTime = Convert.ToDateTime(deviceClass.EndTimeStamp);
  4118. string authAS = deviceClass.AuthorisationApplicationSender;
  4119. string lockingAS = deviceClass.LockingApplicationSender;
  4120. string DSPFields = deviceClass.DSPFields;
  4121. string CRCMode = deviceClass.CRCMode;
  4122. string MIDLinesNarrow = deviceClass.MIDLinesNarrow;
  4123. string MIDLinesWide = deviceClass.MIDLinesWide;
  4124. //string DSPFields = System.Text.UTF8Encoding.UTF8.GetString(deviceClass.DSPFieldsByte, 0, deviceClass.DSPFieldsByte.GetLength(0));
  4125. //string CRCMode = System.Text.UTF8Encoding.UTF8.GetString(deviceClass.CRCModeByte, 0, deviceClass.CRCModeByte.GetLength(0));
  4126. int releaseToken = 0;
  4127. //#if !_USE_OLD_FCONTROL_
  4128. // if (!Strings.TryParseInt(deviceClass.ReleaseToken, out releaseToken))
  4129. // releaseToken = 0;
  4130. //#else
  4131. try
  4132. {
  4133. releaseToken = Int32.Parse(deviceClass.ReleaseToken, NumberStyles.HexNumber);
  4134. }
  4135. catch (Exception ex)
  4136. {
  4137. releaseToken = 0;
  4138. }
  4139. //#endif
  4140. byte reservingDeviceId = 0;
  4141. try
  4142. {
  4143. reservingDeviceId = Convert.ToByte(deviceClass.ReservingDeviceId);
  4144. }
  4145. catch (Exception ex)
  4146. {
  4147. Trace.WriteLine("FuelSaleTrxMsg Exception! cannot convert ReleaseToken to Int32");
  4148. }
  4149. OnFuelSaleTrx.BeginInvoke(this, new FuelSaleTrxEventArgs(transactionSeqNum, transactionState, completionReason, deviceType, deviceId, nozzleId, volume, amount, price, fuelMode, trxStartDateTime, trxEndDateTime, lockingAS, authAS, DSPFields, CRCMode, MIDLinesNarrow, MIDLinesWide, releaseToken, reservingDeviceId, (FuellingType)(Convert.ToInt16(deviceClass.FuellingType))), null, null);
  4150. }
  4151. else
  4152. Trace.WriteLine("FuelSaleTrxMsg OnFuelSaleTrx == null");
  4153. }
  4154. else
  4155. {
  4156. if (msg == null)
  4157. Trace.WriteLine("FuelSaleTrxMsg msg == null");
  4158. else if (msg.FDCdata == null)
  4159. Trace.WriteLine("FuelSaleTrxMsg msg.FDCdata == null");
  4160. else if (msg.FDCdata[0] == null)
  4161. Trace.WriteLine("FuelSaleTrxMsg msg.FDCdata[0] == null");
  4162. else if (msg.FDCdata[0].DeviceClass == null)
  4163. Trace.WriteLine("FuelSaleTrxMsg msg.FDCdata[0].DeviceClass == null");
  4164. }
  4165. //foreach (FDCMessageTRXdataFuelSaleTrx trxdata in msg.FDCdata[0].TRXdata)
  4166. //{
  4167. // if (OnFuelSaleTrx != null)
  4168. // {
  4169. // string deviceType = trxdata.DeviceClass.Type;
  4170. // Trace.WriteLine(string.Format("type={0}, id={1}, nozzle={2}, price={3}, vol={4}, amount={5}", trxdata.DeviceClass.Type, trxdata.DeviceClass.DeviceID, trxdata.DeviceClass.NozzleNo, trxdata.UnitPrice, trxdata.Volume, trxdata.Amount));
  4171. // int deviceId = Convert.ToInt16(trxdata.DeviceClass.DeviceID);
  4172. // int nozzleId = Convert.ToInt16(trxdata.DeviceClass.NozzleNo);
  4173. // Decimal volume = FDCConvert.ToDecimal(trxdata.Volume);
  4174. // Decimal amount = FDCConvert.ToDecimal(trxdata.Amount);
  4175. // Decimal price = FDCConvert.ToDecimal(trxdata.UnitPrice);
  4176. // int transactionSeqNum = Convert.ToInt32(trxdata.TransactionSeqNo);
  4177. // Wayne.FDCPOSLibrary.FuellingState transactionState = convertFuellingState(trxdata.State);
  4178. // int completionReason = Convert.ToInt32(trxdata.CompletionReason);
  4179. // int fuelMode = Convert.ToInt32(trxdata.FuelMode);
  4180. // DateTime trxStartDateTime = Convert.ToDateTime(trxdata.StartTimeStamp);
  4181. // DateTime trxEndDateTime = Convert.ToDateTime(trxdata.EndTimeStamp);
  4182. // string sCRC = (trxdata.DSPFields.LastIndexOf(' ') >= 0) ? trxdata.DSPFields.Substring(trxdata.DSPFields.LastIndexOf(' ')) : "";
  4183. // ushort CRC = 0;
  4184. // try
  4185. // {
  4186. // CRC = Convert.ToUInt16(sCRC);
  4187. // }
  4188. // catch (Exception ex)
  4189. // {
  4190. // }
  4191. // OnFuelSaleTrx.Invoke(this, new FuelSaleTrxEventArgs(transactionSeqNum, transactionState, completionReason, deviceType, deviceId, nozzleId, volume, amount, price, fuelMode, trxStartDateTime, trxEndDateTime, CRC));
  4192. // }
  4193. //}
  4194. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("FuelSaleTrxMsg end"));
  4195. }
  4196. catch (Exception ex)
  4197. {
  4198. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  4199. }
  4200. }
  4201. public void FuelPriceChangeMsg(FDCMessageFuelPriceChange msg)
  4202. {
  4203. try
  4204. {
  4205. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("init FuelPriceChangeMsg"));
  4206. Trace.WriteLine(string.Format("product={0}, newprice={1}, oldprice={2}", msg.FDCdata[0].Product[0].ProductNo, msg.FDCdata[0].Product[0].NewPrice, msg.FDCdata[0].Product[0].OldPrice));
  4207. if (OnChangeFuelPrice != null)
  4208. {
  4209. OnChangeFuelPrice.BeginInvoke(this, new ChangeFuelPriceEventArgs(Convert.ToInt32(msg.FDCdata[0].Product[0].ProductNo), Convert.ToInt32(msg.FDCdata[0].Product[0].ModeNo),
  4210. FDCConvert.ToDecimal(msg.FDCdata[0].Product[0].OldPrice), FDCConvert.ToDecimal(msg.FDCdata[0].Product[0].NewPrice)), null, null);
  4211. }
  4212. //foreach (FDCMessageProductFuelPriceChange product in msg.FDCdata[0].Product)
  4213. //{
  4214. // if (OnDeviceAlarm != null)
  4215. // {
  4216. // string deviceType = "";
  4217. // int deviceId = 0;
  4218. // int alarmId = Convert.ToInt32(1409); //MC_INFO_PUMPPRICECHANGED 1409
  4219. // string alarmmsg = string.Format("prezzo prodotto '{0}'", product.ProductNo);
  4220. // OnDeviceAlarm.Invoke(this, new DeviceAlarmEventArgs(deviceType, deviceId, alarmId, alarmmsg));
  4221. // }
  4222. //}
  4223. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("end FuelPriceChangeMsg"));
  4224. }
  4225. catch (Exception ex)
  4226. {
  4227. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  4228. }
  4229. }
  4230. public void FuelModeChangeMsg(FDCMessageFDCdataFuelModeChange fdcData)
  4231. {
  4232. try
  4233. {
  4234. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("init FuelModeChangeMsg"));
  4235. foreach (FDCMessageDeviceClassFuelModeChange device in fdcData.DeviceClass)
  4236. {
  4237. if (OnFuelModeChange != null)
  4238. {
  4239. string deviceType = fdcData.DeviceClass[0].Type;
  4240. int deviceId = Convert.ToInt16(fdcData.DeviceClass[0].DeviceID);
  4241. int mode = 0;
  4242. if (fdcData.DeviceClass[0].FuelMode.ModeNo != null)
  4243. mode = Convert.ToInt16(fdcData.DeviceClass[0].FuelMode.ModeNo);
  4244. else
  4245. mode = Convert.ToInt16(fdcData.DeviceClass[0].ModeNo);
  4246. OnFuelModeChange.BeginInvoke(this, new FuelModeChangedEventArgs(deviceType, deviceId, mode), null, null);
  4247. }
  4248. }
  4249. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("end FuelModeChangeMsg"));
  4250. }
  4251. catch (Exception ex)
  4252. {
  4253. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  4254. }
  4255. }
  4256. public void FDCExceptionMsg(FDCMessageFDCExceptionMsg msg)
  4257. {
  4258. try
  4259. {
  4260. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("init FDCExceptionMsg"));
  4261. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("end FDCExceptionMsg"));
  4262. }
  4263. catch (Exception ex)
  4264. {
  4265. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  4266. }
  4267. }
  4268. public void FDCMessageConfigurationChangeMsg(FDCMessageConfigurationChange msg)
  4269. {
  4270. try
  4271. {
  4272. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("init FDCMessageConfigurationChangeMsg"));
  4273. OnConfigurationChange.Invoke(this, null);
  4274. Trace.WriteLineIf(Trace.CheckTraceLevel(3), string.Format("end FDCMessageConfigurationChangeMsg"));
  4275. }
  4276. catch (Exception ex)
  4277. {
  4278. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  4279. }
  4280. }
  4281. public void OptReadMsg(FDCMessageOPTRead msg)
  4282. {
  4283. try
  4284. {
  4285. Trace.WriteLineIf(Trace.CheckTraceLevel(3), "init OptReadMsg");
  4286. foreach (FDCMessageDeviceClassOPTRead optdata in msg.FDCdata[0].DeviceClass)
  4287. {
  4288. if (OnOptRead != null)
  4289. {
  4290. string deviceType = optdata.Type;
  4291. byte[] databytes = ASCIIEncoding.ASCII.GetBytes(optdata.Message); ;
  4292. Trace.WriteLine(string.Format("type={0}, id={1}, msg={2}", optdata.Type, optdata.DeviceID, optdata.Message));
  4293. int deviceId = Convert.ToInt16(optdata.DeviceID);
  4294. OnOptRead.BeginInvoke(this, new OptReadEventArgs(deviceType, deviceId, databytes), null, null);
  4295. }
  4296. }
  4297. Trace.WriteLineIf(Trace.CheckTraceLevel(3), "end OptReadMsg");
  4298. }
  4299. catch (Exception ex)
  4300. {
  4301. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  4302. }
  4303. }
  4304. public void OptReadMsg(FDCMessageOPTReadV07 msg)
  4305. {
  4306. try
  4307. {
  4308. Trace.WriteLineIf(Trace.CheckTraceLevel(3), "init OptReadMsg");
  4309. foreach (FDCMessageDeviceClassOPTReadV07 optdata in msg.FDCdata[0].DeviceClass)
  4310. {
  4311. if (OnOptRead != null)
  4312. {
  4313. string deviceType = optdata.Type;
  4314. System.Text.ASCIIEncoding encoding = new System.Text.ASCIIEncoding();
  4315. Trace.WriteLine(string.Format("type={0}, id={1}, msg={2}", optdata.Type, optdata.DeviceID, encoding.GetString(optdata.Message, 0, optdata.Message.Length)));
  4316. int deviceId = Convert.ToInt16(optdata.DeviceID);
  4317. byte[] message = optdata.Message;
  4318. OnOptRead.BeginInvoke(this, new OptReadEventArgs(deviceType, deviceId, message), null, null);
  4319. }
  4320. }
  4321. Trace.WriteLineIf(Trace.CheckTraceLevel(3), "end OptReadMsg");
  4322. }
  4323. catch (Exception ex)
  4324. {
  4325. Trace.WriteLine("Exception! " + ex.Message + " - " + ex.StackTrace);
  4326. }
  4327. }
  4328. }
  4329. }