src/Diplix/KMGBundle/Service/TaMiConnector.php line 87

Open in your IDE?
  1. <?php
  2. namespace Diplix\KMGBundle\Service;
  3. use Diplix\Commons\DataHandlingBundle\Entity\SysLogEntry;
  4. use Diplix\Commons\DataHandlingBundle\Repository\SysLogRepository;
  5. use Diplix\KMGBundle\Entity\Accounting\CoopMember;
  6. use Diplix\KMGBundle\Entity\Address;
  7. use Diplix\KMGBundle\Entity\Availability;
  8. use Diplix\KMGBundle\Entity\Order;
  9. use Diplix\KMGBundle\Entity\OrderStatus;
  10. use Diplix\KMGBundle\Entity\PriceList;
  11. use Diplix\KMGBundle\Util\XmlCapable;
  12. use Doctrine\DBAL\Driver\Connection;
  13. use Doctrine\ORM\EntityManager;
  14. use Doctrine\ORM\EntityManagerInterface;
  15. use DOMDocument;
  16. use GuzzleHttp;
  17. use SimpleXMLElement;
  18. use Symfony\Component\HttpFoundation\JsonResponse;
  19. use Symfony\Component\HttpFoundation\Request;
  20. use Symfony\Component\HttpFoundation\Response;
  23. class TaMiConnector extends XmlCapable
  24. {
  25.     const TAMI_OK = 1; // ErgebnisCode für OK
  26.     const TAMI_ERR = 2; // ErgebnisCode !=1 = nicht ok
  28.     public static $tamiStatusMap = [
  29.         0 => 'Offen',
  30.         1 => 'Vermittelt',
  31.         2 => 'Erfolgreich',
  32.         3 => 'Fehlfahrt',
  33.         4 => 'Storniert',
  34.         11 => 'Angebot'
  35.     ];
  37.     const LogRequest = 101;
  38.     const LogResponse = 102;
  39.     const LogCallback = 103;
  40.     const TimestampFormat = "Y-m-d\TH:i:sP";
  41.     public static $connectionSettings = array(
  42.                 'connect_timeout' => "5", // abort if no response after X seconds
  43.                 'verify' => false, // we do not care if the cert is valid or not
  44.     );
  46.     /**
  47.      * @var GuzzleHttp\Client
  48.      */
  49.     protected $client;
  50.     /**
  51.      * @var EntityManager
  52.      */
  53.     protected $em;
  55.     /**
  56.      * @var Connection
  57.      */
  58.     protected $db;
  60.     protected $statusCache = array();
  62.     protected $serverAddress = "http://localhost/KMG/Web/web/app_dev.php/kmg/server-mock/";
  63.     protected $clientID = "KMGONLINE";
  64.     protected $logPath;
  66.     protected $additionalSyslogging = true;
  68.     protected $trace = false;
  70.     protected $tamiEnabled = true;
  72.     public function enableTami($enableTami)
  73.     {
  74.         $this->tamiEnabled = $enableTami;
  75.     }
  77.     public function __construct(EntityManagerInterface $em)
  78.     {
  79.         parent::__construct();
  80.         $this->logPath =  __DIR__ . "/../../../../app/logs/tami.log";
  81.         $this->em = $em;
  82.         $this->db = $this->em->getConnection();
  83.         // init http client (guzzle 6.x)
  84.         $this->client = new GuzzleHttp\Client($this::$connectionSettings);
  85.         // cache status entities
  86.         $rep = $this->em->getRepository(OrderStatus::class);
  87.         $all = $rep->findAll();
  88.         /** @var OrderStatus $a */
  89.         foreach ($all as $a)
  90.         {
  91.             $this->statusCache[$a->getTamiStatus()] = $a;
  92.         }
  93.     }
  95.     public function setServerAddress($url)
  96.     {
  97.         $this->serverAddress = $url;
  98.     }
  100.     public function enableAdditionalSyslogging($enable)
  101.     {
  102.         $this->additionalSyslogging = $enable;
  103.     }
  105.     protected function logData($dir=0,$data)
  106.     {
  107.         $msg = "[".date("Y-m-d H:i:s")."]".($dir == 0 ? ">>>\n" : ($dir == 1 ?  "<<<\n"  : "(trace)" ) );
  108.         $msg .= $data . "\n";
  109.         file_put_contents($this->logPath, $msg, FILE_APPEND);
  110.     }
  112.     protected function formatXml($simpleXml)
  113.     {
  114.         $xml = parent::formatXml($simpleXml);
  115.         if ($this->trace)
  116.         {
  117.             $this->logData(2,"formatXml()\n".$xml);
  118.         }
  119.         return $xml;
  120.     }
  122.     /**
  123.      * Used to remove the <?xml> tag since LIBXML_NOXMLDECL is not working properly
  124.      * @param $text
  125.      * @return string
  126.      */
  127.     protected function stripFirstLine($text)
  128.     {
  129.         $stripped =  substr( $text, strpos($text, "\n")+1 );
  130.         if ($this->trace)
  131.         {
  132.             $this->logData(2,"stripFirstLine()\n".$text);
  133.         }
  134.         return $stripped;
  135.     }
  137.     /**
  138.      * @param array|SimpleXMLElement $attributeArray
  139.      * @return mixed
  140.      * @throws \Exception
  141.      */
  142.     protected function aid($attributeArray, $throwException=true)
  143.     {
  144.         if ($attributeArray instanceof SimpleXMLElement )
  145.         {
  146.             // no idea why ->attributes() is not working here. we use this workaround instead
  147.             $attributeArray = (array) $attributeArray;
  148.             $attributeArray = $attributeArray["@attributes"];
  149.         }
  151.         // The documentation differs from the live data, so we support both cases
  152.         if (array_key_exists("AuftragID",$attributeArray))
  153.             return $attributeArray["AuftragID"];
  154.         else
  155.         if (array_key_exists("AuftragId",$attributeArray))
  156.             return $attributeArray["AuftragId"];
  157.         else
  158.         {
  159.             if ($throwException) throw new \Exception("No AuftragId/AuftragID in node attributes !");
  160.         }
  162.     }
  165.     /**
  166.      * @param Order $order
  167.      * @return SimpleXMLElement
  168.      */
  169.     protected function createOrderXml(Order $order)
  170.     {
  171.         $now = new \DateTime();
  172.         $xml = new SimpleXMLElement('<?xml version="1.0" encoding="UTF-8"?><VermAuftrag/>',LIBXML_NOEMPTYTAG);
  173.         $xml->addAttribute("Sender",$this->clientID);
  174.         $fa = $xml->addChild("FahrAuftrag");
  175.         $fa->addAttribute("AuftragID",$order->getRemoteOrderId()); // created by remote server if empty, else handled as update
  176.         $fa->addAttribute("ZSt",$now->format($this::TimestampFormat));
  177.         $fa->addChild("Personen",$order->getPersonCount());
  178.         $fa->addChild("Zahlart",$order->getPaymentType()->getTamiCode());
  179.         // Preis soll nicht im Auftag erscheinen, nur als Info :: $fa->addChild("Preis",$order->getLastEstimatedPrice());
  180.         $best = $fa->addChild("Besteller");
  182.         // this name is used by tami. use customer company name instead of orderer's name
  183.         $customerNameForTami = $order->getCustomer()->getName();
  184.         if (
  185.             ($order->getPriceList()!==null)
  186.             &&
  187.             ($order->getPriceList()->getOverwriteCustomerNameForTamiWithThis()!==null)
  188.             &&
  189.             (strlen(trim($order->getPriceList()->getOverwriteCustomerNameForTamiWithThis()))>0)
  190.         )
  191.         {
  192.             $customerNameForTami = $order->getPriceList()->getOverwriteCustomerNameForTamiWithThis();
  193.         }
  194.         $best->addChild("Name",  trim($customerNameForTami) );
  196.         $best->addChild("Telefon",$order->getOrdererPhone());
  197.         $comment = "";
  199.         if ($order->getAlreadyPaid())
  200.         {
  201.             $comment.="BEZAHLT;";
  202.         }
  204.         $comment.= "P: ".number_format($order->getLastEstimatedPrice(),2,',',".").";";
  206.         if ($order->getIsVip())
  207.         {
  208.             $comment.= "VIP;";
  209.         }
  210.         if ($order->getLastEstimatedDistance()>0)
  211.         {
  212.             $comment.= ceil($order->getLastEstimatedDistance())."KM;";
  213.         }
  214.         if ($order->getCostCenter()!="")
  215.         {
  216.             $comment.= sprintf("KoSt: %s;",$order->getCostCenter());
  217.         }
  218.         if ($order->getChildSeatCount()>0)
  219.         {
  220.             $comment.= sprintf("Kindersitze: %d (%s);",$order->getChildSeatCount(),$order->getChildSeatInfo());
  221.         }
  222.         /* do not submit flightno in comment anymore, moved to first address
  223.         if ($order->getFlightNo()!="")
  224.         {
  225.             $comment.= sprintf("FlugNr: %s;",$order->getFlightNo());
  226.         }
  227.         */
  228.         if ($order->getCarType()!="")
  229.         {
  230.             $comment.= sprintf("Fhzg: %s;",$order->getCarType());
  231.         }
  232.         if ($order->getCreditCardNo()!="")
  233.         {
  234.             $comment .= sprintf("KK:%s,%s/%s;",$order->getCreditCardNo(),$order->getCreditCardMonth(),$order->getCreditCardYear());
  235.         }
  237.         $idx = 0;
  238.         /** @var Address $address */
  239.         foreach ($order->getAddressList() as $address)
  240.         {
  241.             if ($address->getBeDeleted()) continue; // maybe deleted already but still available in the current instance
  243.             $comment .= /*sprintf("Quick%d:",$idx+1) .*/ $address->getName();
  244.             if ($address->getPassenger()!="") $comment .= sprintf("(%s)",$address->getPassenger());
  245.             if ($address->getCreditCardNo()!="") $comment .= sprintf("(KK:%s,%s/%s)",$address->getCreditCardNo(),$address->getCreditCardMonth(),$address->getCreditCardYear());
  246.             if ($address->getMobileNumber()!="") $comment.= sprintf("(Tel:%s)",$address->getMobileNumber());
  248.             if ($idx < $order->getAddressList()->count()-1) $comment.=">";
  249.             /** @var SimpleXMLElement $wp */
  250.             $wp = $fa->addChild("Wegpunkt");
  251.             $einaus = ($idx < $order->getAddressList()->count()-1 ? "Einstieg" : "Ausstieg"); // only last waypoint is exit
  252.             $wp->addAttribute("Typ",$einaus);
  253.             if ($idx == 0) $wp->addChild("Zeit",$order->getOrderTime()->format($this::TimestampFormat)); // Timestamp only relevant for first address
  254.             $a = $wp->addChild("Adresse");
  255.             $a->addChild("Quick",htmlspecialchars($address->getName()));
  256.             $a->addChild("Ort",$address->getCity());
  257.             $a->addChild("PLZ",$address->getZipCode());
  258.             $street = $address->getStreet();
  259.             // insert flight-no for first address if available
  260.             if (($idx==0)&&($order->getFlightNo()!=""))
  261.             {
  262.                 $street = sprintf("%s; %s",$order->getFlightNo(),$street);
  263.             }
  264.             $a->addChild("Strasse",$street);
  265.             $a->addChild("HNr",$address->getNumber());
  267.             $idx++;
  269.             if ($this->trace)
  270.             {
  271.                  $this->logData(2,"createOrderXml():address".($idx-1).": ".$address->getName()."\n" );
  272.             }
  273.         }
  274.         $opt = $fa->addChild("Optionen" , implode(' ', $order->getCustomer()->getTamiOptions()));
  276.         $comment .= ";;".$order->getComment();
  277.         $comment = str_replace(";",",",$comment);
  278.         $comment = str_replace("|",",",$comment);
  279.         $fa->addChild("Information", htmlspecialchars($comment));
  281.         if ($this->trace)
  282.         {
  283.             $this->logData(2,"createOrderXml()\n".$xml->asXML());
  284.         }
  286.         return $xml;
  287.     }
  289.     protected function processOrderConfirmation($responseText, Order $order)
  290.     {
  291.         $root = simplexml_load_string($responseText);
  292.         /** @var SimpleXMLElement $fab */
  293.         $faba = $root->{"FahrAuftragBestaetigen"}->attributes();
  294.         $resultCode = $faba["Ergebniscode"];
  295.         $resultMsg = $faba["Ergebnistext"];
  296.         if ($resultCode==1)
  297.         {
  298.             $order->setRemoteOrderId(  $this->aid($faba));
  299.             $order->setRemoteOrderSubmittedTime(  new \DateTime() );
  300.             $order->setRemoteStatus(Order::REMOTE_SUCCESS);
  301.         }
  302.         else
  303.         {
  304.             $order->setRemoteStatus(Order::REMOTE_ERROR);
  305.         }
  306.         $order->setRemoteResult($resultCode);
  307.         $order->setRemoteResultText($resultMsg);
  308.         if ($this->additionalSyslogging) SysLogRepository::logEntityOperation($this->db,self::LogResponse,"Order",$order->getId(),[],
  309.             sprintf("TaMi:FahrAuftragBestaetigen:%d:%s:%s",$resultCode,$resultMsg,$this->aid($faba,false)));
  310.         return ($order->getRemoteStatus()==Order::REMOTE_SUCCESS);
  311.     }
  313.     /**
  314.      * @param SimpleXMLElement $fasNode
  315.      * @return true|string true on success, else error message as string
  316.      */
  317.     protected function processStatusUpdateCallbackNode($fasNode)
  318.     {
  319.         $oid = $this->aid($fasNode);
  320.         $status = $fasNode->{"AuftragStatus"};
  321.         $rep = $this->em->getRepository(Order::class);
  322.         /** @var Order $order */
  323.         $order = $rep->findOneBy(array("remoteOrderId"=>$oid));
  324.         if (!is_object($order))
  325.         {
  326.             return "Unbekannte AuftragID";
  327.         }
  328.         $order->setOrderStatus($this->statusCache[(int)$status]);
  329.         return true;
  330.     }
  332.     /**
  333.      * @param $results array( AuftragID=>(true|string)
  334.      * @return SimpleXMLElement
  335.      */
  336.     protected function createStatusUpdateCallbackReponseXml($results)
  337.     {
  338.         $now = new \DateTime();
  339.         $xml = new SimpleXMLElement('<?xml version="1.0" encoding="UTF-8"?><VermAuftrag/>');
  340.         $xml->addAttribute("Sender",$this->clientID);
  341.         foreach ($results as $oid=>$status)
  342.         {
  343.             $fa = $xml->addChild("FahrAuftragStatusBestaetigen");
  344.             $fa->addAttribute("AuftragID",$oid);
  345.             $fa->addAttribute("ZSt",$now->format($this::TimestampFormat));
  346.             $fa->addAttribute("Ergebniscode", ($status===true? self::TAMI_OK : self::TAMI_ERR));
  347.             $fa->addAttribute("Ergebnistext", ($status!==true? $status : "OK"));
  348.         }
  349.         return $xml;
  350.     }
  352.     protected function VermAuftrag($xml)
  353.     {
  354.         $body = $this->stripFirstLine( $this->formatXml( $xml ) );
  355.         $this->logData(0,$body);
  356.         $res = $this->client->post($this->serverAddress . "VermAuftrag" ,array(
  357.             'headers'   =>['Content-Type' => 'text/xml' ],
  358.             "body"      =>$body));
  359.         $resultXml = $res->getBody()->getContents();
  360.         $this->logData(1,$resultXml);
  361.         if ($res->getStatusCode() != 200) // actually on error status codes, guzzle itsself throws an exception beforehand
  362.         {
  363.             throw new \Exception(sprintf("HTTP %d: %s",$res->getStatusCode(),$res->getReasonPhrase()));
  364.         }
  365.         return $resultXml;
  366.     }
  368.     /**
  369.      * Create or update an order on remote TaMi Server
  370.      * TODO: directly link pricelist via entity, remove separate parameter
  371.      * @param Order $order
  372.      * @return bool
  373.      */
  374.     public function submitOrder(Order $order)
  375.     {
  376.         if ($this->additionalSyslogging) SysLogRepository::logEntityOperation($this->db,self::LogRequest,"Order",$order->getId(),[],sprintf("TaMi:FahrAuftrag"));
  377.         try
  378.         {
  379.             $resultXml = $this->VermAuftrag(  $this->createOrderXml($order) );
  380.             $ok = $this->processOrderConfirmation($resultXml,$order);
  381.             $this->em->flush($order);
  382.             return $ok;
  383.         }
  384.         catch (\Exception $ex)
  385.         {
  386.             $order->setRemoteStatus(Order::REMOTE_ERROR);
  387.             $xtra = "";
  388.             if ($ex instanceof GuzzleHttp\Exception\RequestException)
  389.             {
  390.                 $r = $ex->getResponse();
  391.                 if (is_object($r)) $xtra = $r->getBody();
  392.             }
  393.             else
  394.             {
  395.                 $xtra = $ex->getTraceAsString();
  396.             }
  397.             SysLogRepository::logEntityOperation($this->db,self::LogResponse,"Order",$order->getId(),[],
  398.                 sprintf("TaMi:EXCEPTION:%s:%s",$ex->getMessage(),$xtra));
  399.         }
  400.         return false;
  401.     }
  403.     /**
  404.      * Cancel an open order on remote TaMi Server
  405.      * @param Order $order
  406.      * @return bool
  407.      */
  408.     public function cancelOrder(Order $order)
  409.     {
  410.         if ($this->additionalSyslogging) SysLogRepository::logEntityOperation($this->db,self::LogRequest,"Order",$order->getId(),[],sprintf("TaMi:FahrauftragStorno"));
  411.         try
  412.         {
  413.             $resultXml = $this->VermAuftrag(  $this->createStornoXml($order) );
  414.             $ok = $this->processStornoConfirmation($resultXml,$order);
  415.             $this->em->flush($order);
  416.             return $ok;
  417.         }
  418.         catch (\Exception $ex)
  419.         {
  420.             $order->setRemoteStatus(Order::REMOTE_ERROR);
  421.             $xtra = "";
  422.             if ($ex instanceof GuzzleHttp\Exception\RequestException)
  423.             {
  424.                 $r = $ex->getResponse();
  425.                 if (is_object($r)) $xtra = $r->getBody();
  426.             }
  427.             SysLogRepository::logEntityOperation($this->db,self::LogResponse,"Order",$order->getId(),[],
  428.                 sprintf("TaMi:EXCEPTION:%s:%s",$ex->getMessage(),$xtra));
  429.         }
  430.         return false;
  431.     }
  434.     /**
  435.      * React to a status callback coming from the remote TaMi Server
  436.      * @param Request $request
  437.      * @return Response
  438.      */
  439.     public function fahrAuftragStatusCallbackAction(Request $request)
  440.     {
  441.         if (!$this->tamiEnabled)
  442.         {
  443.             SysLogRepository::logEntityOperation($this->db,self::LogCallback,'',0,[],
  444.                 'Tami:fahrAuftragStatusCallback: Tami interface disabled.');
  445.             return new Response('Tami interface is disabled.',400);
  446.         }
  447.         // TODO: IP-Whitelisting to prevent malicious updates
  448.         try
  449.         {
  450.             $data = $request->getContent();
  452.             SysLogRepository::logEntityOperation($this->db,self::LogCallback,'',0,[],
  453.                 sprintf("TaMi:fahrAuftragStatusCallback %s",$data));
  455.             $this->logData(1,$data);
  456.             $root = simplexml_load_string( $data );
  457.             $results = array();
  458.             foreach ($root->{"VermAuftrag"}->{"FahrAuftragStatus"} as $fas)
  459.             {
  460.                 $oid = $this->aid($fas);
  461.                 $results [$oid] = $this->processStatusUpdateCallbackNode($fas);
  462.             }
  463.             $this->em->flush();
  464.             $responseText = $this->createStatusUpdateCallbackReponseXml($results)->asXML();
  465.             $this->logData(0,$responseText);
  466.             return new Response($responseText, 200, ['Content-Type' => 'text/xml'] );
  467.         }
  468.         catch (\Exception $ex)
  469.         {
  470.             SysLogRepository::logEntityOperation($this->db,500,"",0,[],
  471.                 sprintf("TaMi:fahrAuftragStatusCallback:EXCEPTION:%s",$ex->getMessage()));
  473.             $r = new Response($ex->getMessage());
  474.             $r->setStatusCode(400,$ex->getMessage());
  475.             return $r;
  476.         }
  477.     }
  479.     protected function updateAvailabilityFromOrder(array $one,$knownOrder)
  480.     {
  481.         $rep = $this->em->getRepository(Availability::class);
  482.         $mrep =  $this->em->getRepository(CoopMember::class);
  483.         $member = $mrep->findOneBy(['number'=>$one['carId']]);
  484.         $av = $rep->findOneBy(['createdFromRemoteOrderId'=>$one['orderId']]);
  485.         if ($av===null)
  486.         {
  487.             $av = new Availability();
  488.             $av->setAvailType(  $knownOrder ? Availability::KMG : Availability::BASF );
  489.             $av->setCreatedFromRemoteOrderId($one['orderId']);
  490.         }
  491.         $av->setAvailFrom( new \DateTime($one['time']) );
  492.         $until = clone($av->getAvailFrom());
  493.         $until->add(new \DateInterval('PT1H'));
  494.         $av->setAvailUntil( $until );
  495.         $av->setMember($member);
  496.         $statusText = array_key_exists($one['tamiStatus'],self::$tamiStatusMap) ? self::$tamiStatusMap[$one['tamiStatus']] : $one['tamiStatus'];
  497.         $av->setExtraInfo(sprintf('#%s: %s',$one['orderId'],$statusText));
  498.         $rep->persistFlush($av);
  499.     }
  501.     public function updateCallbackAction(Request $request)
  502.     {
  503.         if (!$this->tamiEnabled)
  504.         {
  505.             SysLogRepository::logEntityOperation($this->db,self::LogCallback,'',0,[],
  506.                 'Tami:updateCallback: Tami interface is disabled');
  507.             return new JsonResponse(['success' =>false, 'message'=>'Tami interface is disabled']);
  508.         }
  509.         try
  510.         {
  511.             $xml = $request->getContent();
  512.             $rep = $this->em->getRepository(Order::class);
  513.             $this->logData(1,$xml);
  514.             $root = simplexml_load_string( $xml );
  515.             $data = [];
  516.             foreach ($root->{"JobList"}->{"Job"} as $job)
  517.             {
  518.                 $data []= [
  519.                     'orderId' => $this->aid($job),
  520.                     'carId' => (int)$job->{"FhzId"},
  521.                     'driverId' => (int)$job->{"FhrId"},
  522.                     'tamiStatus' => (int)$job->{"Status"},
  523.                     'time' => (string)$job->{"ZeitFahrt"}
  524.                 ]  ;
  525.             }
  527.             SysLogRepository::logEntityOperation($this->db,self::LogCallback,'',0,$data,
  528.                     sprintf("TaMi:Callback %s",$request->getMethod()));
  530.             foreach ($data as $one)
  531.             {
  532.                 /** @var Order $order */
  533.                 $order = $rep->findOneBy(array("remoteOrderId"=>$one['orderId']));
  534.                 if ($order!==null)
  535.                 {
  536.                     $order->setOrderStatus($this->statusCache[$one['tamiStatus']]);
  537.                     $rep->flush($order);
  538.                     $this->updateAvailabilityFromOrder($one,true);
  539.                 }
  540.                 else
  541.                 {
  542.                     $this->updateAvailabilityFromOrder($one,false);
  543.                 }
  544.             }
  546.             return new JsonResponse(['success' =>true, 'data'=>$data]);
  547.         }
  548.         catch (\Exception $ex)
  549.         {
  550.             SysLogRepository::logEntityOperation($this->db,500,"",0,[],
  551.                 sprintf("TaMi:Callback:EXCEPTION:%s",$ex->getMessage()));
  552.             return new JsonResponse(['success' =>false, 'message'=>$ex->getMessage()]);
  553.         }
  554.     }
  556.     protected function createStornoXml(Order $order)
  557.     {
  558.         $now = new \DateTime();
  559.         $xml = new SimpleXMLElement('<?xml version="1.0" encoding="UTF-8"?><VermAuftrag/>',LIBXML_NOEMPTYTAG);
  560.         $xml->addAttribute("Sender",$this->clientID);
  561.         $fa = $xml->addChild("FahrauftragStorno");
  562.         $fa->addAttribute("AuftragID",$order->getRemoteOrderId()); // created by remote server if empty, else handled as update
  563.         $fa->addAttribute("ZSt",$now->format($this::TimestampFormat));
  564.         return $xml;
  565.     }
  567.     protected function processStornoConfirmation($responseText, Order $order)
  568.     {
  569.         $root = simplexml_load_string($responseText);
  570.         /** @var SimpleXMLElement $fab */
  571.         $faba = $root->{"FahrauftragStornoBestaetigen"}->attributes();
  572.         $resultCode = $faba["Ergebniscode"];
  573.         $resultMsg = $faba["Ergebnistext"];
  574.         $auftragId = $this->aid($faba);
  575.         if ($resultCode==1)
  576.         {
  577.             // OrderStatus nicht mehr von Tami :: $order->setOrderStatus( $this->em->getReference("Diplix\\KMGBundle\\Entity\\OrderStatus",OrderStatus::STATUS_CANCELED) );
  578.             $order->setRemoteStatus(Order::REMOTE_SUCCESS);
  579.         }
  580.         else
  581.         {
  582.             $order->setRemoteStatus(Order::REMOTE_ERROR);
  583.         }
  584.         $order->setRemoteResult($resultCode);
  585.         $order->setRemoteResultText($resultMsg);
  586.         if ($this->additionalSyslogging) SysLogRepository::logEntityOperation($this->db,self::LogResponse,"Order",$order->getId(),[],
  587.             sprintf("TaMi:FahrauftragStornoBestaetigen:%d:%s:%s",$resultCode,$resultMsg,$this->aid($faba,false)));
  588.         return ($order->getRemoteStatus()==Order::REMOTE_SUCCESS);
  589.     }
  591.     /**
  592.      * @param Order $order
  593.      * @return bool
  594.      */
  595.     public function getOrderStatus(Order $order)
  596.     {
  597.         if ($this->additionalSyslogging) SysLogRepository::logEntityOperation($this->db,self::LogRequest,"Order",$order->getId(),[],sprintf("TaMi:FahrauftragStatus>"));
  598.         try
  599.         {
  600.             $resultXml = $this->VermAuftrag(  $this->createStatusXml($order) );
  601.             $ok = $this->processStatusResponse($resultXml,$order);
  602.             $this->em->flush($order);
  603.             return $ok;
  604.         }
  605.         catch (\Exception $ex)
  606.         {
  607.             $order->setRemoteStatus(Order::REMOTE_ERROR);
  608.             $xtra = "";
  609.             if ($ex instanceof GuzzleHttp\Exception\RequestException)
  610.             {
  611.                 $r = $ex->getResponse();
  612.                 if (is_object($r)) $xtra = $r->getBody();
  613.             }
  614.             SysLogRepository::logEntityOperation($this->db,self::LogResponse,"Order",$order->getId(),[],
  615.                 sprintf("TaMi:EXCEPTION:%s:%s",$ex->getMessage(),$xtra));
  616.         }
  617.         return false;
  618.     }
  620.     protected function createStatusXml(Order $order)
  621.     {
  622.         $now = new \DateTime();
  623.         $xml = new SimpleXMLElement('<?xml version="1.0" encoding="UTF-8"?><VermAuftrag/>',LIBXML_NOEMPTYTAG);
  624.         $xml->addAttribute("Sender",$this->clientID);
  625.         $fa = $xml->addChild("FahrauftragStatus");
  626.         $fa->addAttribute("AuftragID",$order->getRemoteOrderId()); // created by remote server if empty, else handled as update
  627.         $fa->addAttribute("ZSt",$now->format($this::TimestampFormat));
  628.         return $xml;
  629.     }
  631.      protected function processStatusResponse($responseText, Order $order)
  632.     {
  633.         $root = simplexml_load_string($responseText);
  634.         /** @var SimpleXMLElement $fab */
  635.         $faba = $root->{"FahrauftragStatusBestaetigen"}->attributes();
  636.         $resultCode = $faba["Ergebniscode"];
  637.         $resultMsg = $faba["Ergebnistext"];
  638.         $auftragId = $this->aid($faba);
  640.        if ($this->additionalSyslogging)  SysLogRepository::logEntityOperation($this->db,self::LogResponse,"Order",$order->getId(),[],
  641.             sprintf("TaMi:FahrauftragStatusBestaetigen:%d:%s:%s",$resultCode,$resultMsg,$this->aid($faba,false)));
  643.         if ($resultCode==1)
  644.         {
  645.             $status = (int)$root->{"FahrauftragStatusBestaetigen"}->{'AuftragStatus'};
  646.             if (array_key_exists($status,$this->statusCache))
  647.             {
  648.                 $order->setOrderStatus(  $this->statusCache[$status] );
  649.             }
  650.             else
  651.             {
  652.                 if ($this->additionalSyslogging) SysLogRepository::logEntityOperation($this->db,self::LogResponse,"Order",$order->getId(),[],
  653.                     sprintf("TaMi:FahrauftragStatusBestaetigen:Unbekannter Status Code:%d",$status));
  654.                 return false;
  655.             }
  656.         }
  657.         else
  658.         {
  659.             // ignore on error
  660.         }
  661.         // being unable to update the status should not set the whole order to be in REMOTE_ERROR state
  662.         // nor change the result of the last active operation
  663.         // that's why we dont update the entities remote status fields
  664.         return ($resultCode == 1);
  665.     }
  668. }