ResendPosNotify.cs 1.7 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849
  1. using SinochemPosClient.Models;
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Linq;
  5. using System.Text;
  6. using System.Threading.Tasks;
  7. using Wayne.Lib.StateEngine;
  8. using Wayne.Lib.StateEngine.Generic;
  9. namespace SinochemInternetPlusApp.EpsTrxCleanup.States
  10. {
  11. class ResendPosNotify : State<EpsTrxCleanupManager>
  12. {
  13. protected override void Enter(StateEntry stateEntry, ref Transition transition)
  14. {
  15. base.Enter(stateEntry, ref transition);
  16. // resend the notify for the trxes that are not yet successfully notified to pos
  17. var neeResendPosNotifyEpsTrxes = Main.GetNeedResendPosNotifyEpsTrxes();
  18. foreach (var epsTrx in neeResendPosNotifyEpsTrxes)
  19. {
  20. TrxNotificationResponse response = Main.NotifySuccessfulTrxToPos(epsTrx.Model);
  21. if (response != null && response.IsSuccessful())
  22. {
  23. epsTrx.UpdateNotifyPosFlagToDb(NotifyPosFlag.NotifyOk);
  24. }
  25. }
  26. transition = new Transition(this, TransitionType.ResendPosNotifyDone);
  27. }
  28. protected override void HandleEvent(StateEngineEvent stateEngineEvent, ref Transition transition)
  29. {
  30. base.HandleEvent(stateEngineEvent, ref transition);
  31. if (stateEngineEvent.Type is BasicTransitionType)
  32. {
  33. switch ((BasicTransitionType)stateEngineEvent.Type)
  34. {
  35. case BasicTransitionType.Error:
  36. transition = new Transition(this, BasicTransitionType.Error);
  37. stateEngineEvent.Handled = true;
  38. break;
  39. }
  40. }
  41. }
  42. }
  43. }