src/Diplix/KMGBundle/Controller/Accounting/JobController.php line 151

Open in your IDE?
  1. <?php
  2. namespace Diplix\KMGBundle\Controller\Accounting;
  4. use Diplix\Commons\DataHandlingBundle\Repository\SysLogRepository;
  5. use Diplix\KMGBundle\Controller\BaseController;
  6. use Diplix\KMGBundle\Controller\Member\MyMembershipController;
  7. use Diplix\KMGBundle\DataTables\DataTablesHelper;
  8. use Diplix\KMGBundle\DataTables\Expr\ExprStub;
  9. use Diplix\KMGBundle\Entity\Accounting\Billing;
  10. use Diplix\KMGBundle\Entity\Accounting\CoopMember;
  11. use Diplix\KMGBundle\Entity\Accounting\Job;
  12. use Diplix\KMGBundle\Entity\Accounting\JobCalcItem;
  13. use Diplix\KMGBundle\Entity\Customer;
  14. use Diplix\KMGBundle\Entity\Order;
  15. use Diplix\KMGBundle\Entity\Role;
  16. use Diplix\KMGBundle\Form\Accounting\ImportJobFileForm;
  17. use Diplix\KMGBundle\Form\Accounting\JobForm;
  18. use Diplix\KMGBundle\Helper\ClientConfigProvider;
  19. use Diplix\KMGBundle\PriceCalculator\CalculatorService;
  20. use Diplix\KMGBundle\Repository\JobRepository;
  21. use Diplix\KMGBundle\Service\Accounting\PaymentCalculator;
  22. use Diplix\KMGBundle\Service\Accounting\TamiJobImporter;
  23. use Diplix\KMGBundle\Service\OrderHandler;
  24. use Diplix\KMGBundle\Util\ExcelExportHelper;
  25. use Doctrine\ORM\AbstractQuery;
  26. use Doctrine\ORM\EntityManagerInterface;
  27. use Doctrine\ORM\EntityRepository;
  28. use Doctrine\ORM\Tools\Pagination\Paginator;
  29. use PHPExcel_Style_Border;
  30. use Symfony\Component\Form\FormError;
  31. use Symfony\Component\HttpFoundation\BinaryFileResponse;
  32. use Symfony\Component\HttpFoundation\File\UploadedFile;
  33. use Symfony\Component\HttpFoundation\JsonResponse;
  34. use Symfony\Component\HttpFoundation\Request;
  35. use Symfony\Component\HttpFoundation\ResponseHeaderBag;
  36. use Vtiful\Kernel\Excel;
  38. class JobController extends BaseController
  39. {
  40.     public static $columnSetup =
  41.                 array(  0=>array('fieldName' => 'job.id', 'caption' => '#', 'headStyle' => 'width:16px;', 'type' =>DataTablesHelper::T_SELECTOR),
  42.                         1=>array('fieldName' => 'job.orderNumber', 'caption' => 'Auftrag'),
  43.                         2=>array('fieldName' => 'job.orderTime' , 'caption'=>'Datum'),
  44.                         3=>array('fieldName' => 'cust.name','caption'=>'Kunde'),
  45.                         4=>array('fieldName' => 'job.originCity','caption'=>'Ab Ort'),
  46.                         5=>array('fieldName' => 'job.destinationCity', 'caption'=>'Zu Ort'),
  47.                         6=>array('fieldName' => 'mem.id', 'caption'=>'MID','visible'=>false,'searchWithLike'=>false),
  48.                         7=>array('fieldName' => 'job.driverId', 'caption'=>'Fahrer','visible'=>false),
  49.                         8=>array('fieldName' => 'job.member', 'caption'=>'M', 'virtual'=>true,'visible'=>false,'sortable'=>false),
  50.                         9=>array('fieldName' => 'job.billed', 'caption'=>'A', 'type'=>DataTablesHelper::T_CSSICON, 'virtual'=>true),
  51.                         10=>array('fieldName' => 'mem.shortCode','virtual'=>false,'visible'=>true,'caption'=>"Mitglied"),
  52.                         11=>array('fieldName' => '_order_id','virtual'=>true,'visible'=>false),
  53.                         12=>array('fieldName' => '_ffl','virtual'=>true,'visible'=>false),
  54.                         13=>array('fieldName' => '_readyforBilling','virtual'=>true,'visible'=>false),
  55.                         14=>array('fieldName' => '_customer_id','virtual'=>true,'visible'=>false),
  56.                         15=>array('fieldName' => 'job.totalCustomerNet', 'caption'=>'€Kunde'),
  57.                         16=>array('fieldName' => 'job.totalMemberNet', 'caption'=> '€Mitgld.'),
  58.                         17=>array('fieldName' => '_buttons', 'caption' => '', 'virtual' =>true, 'headStyle' => 'width:96px;', 'type' =>DataTablesHelper::T_BUTTONS),
  59.                         18=>array('fieldName'=>'job.passenerNotMet','visible'=>false,'sortable'=>false,'searchable'=>false),
  60.                         19=>array('fieldName'=>'job.discarded','visible'=>false,'sortable'=>false,'searchable'=>false),
  61.                         20=>    [ 'fieldName' => '_hasExtraMemberKm', 'visible'=>false, 'virtual'=>true],
  62.                         21=>    [ 'fieldName' => '_changedByMember', 'visible'=>false, 'virtual'=>true],
  63.                         22=>    [ 'fieldName' => 'lastReadyForBillingCheckResult', 'visible'=>false, 'virtual'=>true],
  64.                         23=>    [ 'fieldName' => '_approvalStatus', 'visible'=>false, 'virtual'=>true],
  65.                         24=>    [ 'fieldName' => 'ord.orderId', 'visible'=>false],
  66.                         25=>    [ 'fieldName' => 'ord.orderStatus', 'visible'=>false,'sortable'=>false,'searchable'=>false],
  67.                         26=>    [ 'fieldName' => 'ord.internalComment','visible'=>false,'sortable'=>false,'searchable'=>false],
  68.                         27=>    [ 'fieldName' => 'ord.taxameter','visible'=>false,'sortable'=>false,'searchable'=>false],
  70.                         28=>['fieldName'=>'_km','caption'=>'A/KM','virtual'=>true,'sortable'=>false],
  71.                         29=>['fieldName'=>'_p','caption'=>'A/P','virtual'=>true,'sortable'=>false],
  72.                         30=>['fieldName'=>'_wz','caption'=>'A/WZ(€)','virtual'=>true,'sortable'=>false],
  73.                         31=>['fieldName'=>'_ex','caption'=>'A/EX(€)','virtual'=>true,'sortable'=>false],
  74.                         32=>['fieldName'=>'_ctrl1','virtual'=>true,'visible'=>false],
  75.                         33=>['fieldName'=>'_ctrl2','virtual'=>true,'visible'=>false],
  76.                         34=>[ 'fieldName' => 'pt.icon','visible'=>false,'sortable'=>false,'searchable'=>false],
  77.                         35=>['fieldName'=>'_wzmin','caption'=>'A/WZ(Min)','virtual'=>true,'sortable'=>false],
  78.                         36=>['fieldName'=>'_customersignature','caption'=>'','virtual'=>true,'sortable'=>false,'visible'=>false],
  79.                         37=>['fieldName'=>'_discount','caption'=>'R','virtual'=>true,'sortable'=>false],
  80.                         38=>['fieldName'=>'ord.originOrderId','caption'=>'','virtual'=>false,'sortable'=>false,'visible'=>false]
  82.                 );
  84.     protected function getDth()
  85.     {
  86.         if ($this->config->isAlternateJobListView())
  87.         {
  88.             self::$columnSetup[3]['visible']=false;
  89.         }
  90.         return new DataTablesHelper(self::$columnSetup,
  91.                     [
  92.                     'ajaxUrl'       => $this->get('router')->generate('acc-jobs-jsonlist'),
  93.                     'ajaxData'      => 'requestData',
  94.                     'ajaxType'      => "POST",
  95.                     'deferLoading'  => true,
  96.                     'stateSave'=>false, // implemented manually
  97.                     'defaultSorting'=> array(2=> 'asc')
  98.                     ]);
  99.     }
  101.     protected function init()
  102.     {
  103.         $this->ensureUserHasRole(Role::ACCOUNTING);
  104.     }
  106.     public function __construct(
  107.         protected PaymentCalculator $paymentCalculator,
  108.         protected CalculatorService $calculatorService,
  109.         protected TamiJobImporter $tamiJobImporter,
  110.         ClientConfigProvider $ccp,
  111.         private readonly \Doctrine\Persistence\ManagerRegistry $managerRegistry
  112.     )
  113.     {
  114.         $this->config = $ccp;
  115.     }
  117.     protected function getMemberList()
  118.     {
  119.         $r = $this->managerRegistry->getRepository(CoopMember::class);
  120.         $all = $r->findBy([],['name'=>'asc']);
  121.         $list = [];
  122.         foreach ($all as $a){
  123.             $list [$a->getId()] = $a->getShortCode() . ' ('.$a->getName().')';
  124.         }
  125.         return $list;
  126.     }
  128.     /** @var \Diplix\KMGBundle\Helper\ClientConfigProvider */
  129.     protected $config;
  131.     public function indexAction()
  132.     {
  133.         $this->init();
  135.         //$jr = $this->getDoctrine()->getRepository(Job::class);
  136.         //$carList = $jr->findCars();
  139.         $now = new \DateTime();
  140.         $from = (new \DateTime())->sub(new \DateInterval('P3M'));
  142.         $dth = $this->getDth();
  143.         return $this->render('@DiplixKMG/Accounting/Job/list.html.twig',[
  144.             'columnSetup' =>$dth->getColumnSetup(),
  145.             'memberList' => $this->getMemberList(),
  146.             'filterFrom' =>$from->format('Y-m-d'),
  147.             'filterTo' =>$now->format('Y-m-d')
  148.         ]);
  149.     }
  151.     public function memberListAction(Request $request)
  152.     {
  153.         $this->init();
  154.         /** @var EntityRepository $repo */
  155.         $repo = $this->managerRegistry->getRepository(Job::class);
  156.         $cb = $repo->createQueryBuilder('job')
  157.             ->select('job,mem')
  158.             ->leftJoin('job.member','mem')
  159.             ->groupBy('mem.id');
  160.         $req = $request->query->all();
  161.         $from = new \DateTime($req["filterFrom"]); $from->setTime(0,0,0);
  162.         $to = new \DateTime($req["filterTo"]); $to->setTime(23,59,59);
  163.         $cb->andWhere('job.orderTime >= :from')->setParameter('from',$from);
  164.         $cb->andWhere('job.orderTime <= :to')->setParameter('to',$to);
  165.         //$cb->orderBy('mem.shortCode','asc');
  166.         $jobs = $cb->getQuery()->getResult();
  167.         $members = [];
  168.         /** @var Job $j */
  169.         foreach ($jobs as $j)
  170.         {
  171.             if ($j->getMember()===null) continue;
  172.             $mid = $j->getMember()->getId();
  173.             if (!array_key_exists($mid,$members))
  174.             {
  175.                 $members[$mid] = $j->getMember()->getShortCode() . ' ('.$j->getMember()->getName().')';
  176.             }
  177.         }
  178.         uasort($members, fn($a,$b) => strcmp($a,$b));
  179.         return $this->getJsonDataResponse($request,true,$members);
  180.     }
  182.     protected function nf($v)
  183.     {
  184.         return number_format($v,2,',','.');
  185.     }
  187.     protected function diTi($time)
  188.     {
  189.         if ($time === null) return '-';
  190.         return $time->format('H:i');
  191.     }
  193.     public function jsonListAction(Request $request)
  194.     {
  195.         $this->init();
  196.         $dth = $this->getDth();
  197.         $req = array_merge($request->query->all(),$request->request->all());
  198.         /** @var EntityRepository $repo */
  199.         $repo = $this->managerRegistry->getRepository(Job::class);
  200.         $cb = $repo->createQueryBuilder('job')
  201.                         ->select('job','ord')
  202.                         ->leftJoin('job.member','mem')
  203.                         ->leftJoin('job.customer','cust')
  204.                         ->leftJoin('job.knownOrder','ord')
  205.                         ->leftJoin("ord.paymentType","pt");
  206.         // process filtering,ordering,paging
  207.         $dth->setQueryBuilder($cb);
  208.         $dth->processRequest($request);
  209.         // additional filters
  210.         $from = new \DateTime($req["filterFrom"]); $from->setTime(0,0,0);
  211.         $to = new \DateTime($req["filterTo"]); $to->setTime(23,59,59);
  213.         $cb->andWhere('job.orderTime >= :from')->setParameter('from',$from);
  214.         $cb->andWhere('job.orderTime <= :to')->setParameter('to',$to);
  217.         $dth->addSimpleFilter(10,$req,$dth->getRawColumnOrder($req),
  218.             [ExprStub::like("mem.shortCode")],"mem.shortCode",true);
  219.         //// XOR filter
  221.         if ($req['filterBilled']==="true")
  222.         {
  223.             $cb->andWhere('job.billingForCustomer IS NOT NULL');
  224.             $cb->andWhere('job.billingForMember IS NOT NULL');
  225.         }
  226.         else
  227.         {
  228.             $cb->andWhere($cb->expr()->orX('job.billingForCustomer IS NULL','job.billingForMember IS NULL'));
  229.         }
  231.         if ($req['filterDiscarded']==='true')
  232.         {
  233.             $cb->andWhere('job.discarded = 1');
  234.         }
  235.         else
  236.         {
  237.             $cb->andWhere('job.discarded = 0');
  238.         }
  240.         /// triState Filter
  242.         if ($req['filterFFL']==="true")
  243.         {
  244.             $cb->andWhere("job.detectedFFL != ''");
  245.         }
  246.         else
  247.         if ($req['filterFFL']==="false")
  248.         {
  249.             $cb->andWhere("job.detectedFFL = ''");
  250.         }
  251.         $plainBoolFilters = [
  252.             'filterReadyForBilling' => 'job.readyForBilling',
  253.             'filterApprovedByDriver' => 'job.approvedByDriver',
  254.             'filterApprovedByPassenger' => 'job.approvedByPassenger',
  255.             'filterApprovedByAccounting' => 'job.approvedByAccounting'
  256.         ];
  257.         foreach ($plainBoolFilters as $formName=>$dbName)
  258.         {
  259.             if ($req[$formName]==='true')
  260.             {
  261.                 $cb->andWhere($dbName.' = 1');
  262.             }
  263.             else
  264.             if ($req[$formName]==='false')
  265.             {
  266.                 $cb->andWhere($dbName.' = 0');
  267.             }
  269.         }
  270.         // query and compile paged data
  271.         $query = $cb->getQuery();
  272.         $query->setHydrationMode(AbstractQuery::HYDRATE_OBJECT);
  273.         $paginator = new Paginator($cb->getQuery(),true);
  274.         $filteredCount = $paginator->count();
  275.         $filteredAndPaged = array();
  276.         $dit = $paginator->getIterator();
  277.         /** @var Job  $row */
  278.         foreach ($dit as $row)
  279.         {
  280.             $memberDetails = MyMembershipController::sumUpMemberCalcCategories($row,true);
  281.             $options = [];
  282.             $options[]= array('route' => 'acc-jobs-edit', 'title' => 'Bearbeiten', 'icon' => 'glyphicon glyphicon-pencil', 'parameters' =>array('id' =>$row->getId()) );
  283.             if ($this->hasUserRole(Role::ACCOUNTING_EDIT))
  284.             {
  285.                 $options[]= array('attr'=>['onClick' => sprintf('approvePrompt([%d],true);',$row->getId())], 'title' => 'Freigeben für Abrechnung', 'icon' => 'glyphicon glyphicon-thumbs-up', 'parameters' =>array('id' =>$row->getId()) );
  286.                 $options[]= array('attr'=>['onClick' => sprintf('delPrompt(%d,%s);',$row->getId(),$row->isDiscarded()?'true':false)], 'title' => 'Löschen', 'icon' => 'glyphicon glyphicon-trash', 'parameters' =>array('id' =>$row->getId()) );
  287.             }
  288.             $one = array(
  289.                     0 => $row->getId(),
  290.                     1 => $row->getOrderNumber(),
  291.                     2 => ( $row->getOrderTime() !== null ? $row->getOrderTime()->format('d.m.Y H:i') : '-'),
  292.                     3 =>     $row->getCustomer() !== null ? $row->getCustomer()->getName(): $row->getCustomerName(),
  293.                     4 => $row->getOriginCity(),
  294.                     5 => $row->getDestinationCity(),
  295.                     6 => $row->getMember()!== null ? $row->getMember()->getId() : 0,
  296.                     7 => $row->getDriverId(),
  297.                     8 => $row->getMember() !== null ? 1: 0,
  298.                     9 => ($row->isBilled(Billing::TYPE_CUSTOMER)  &&  $row->isBilled(Billing::TYPE_MEMBER))  ? 1 : 0,
  299.                     10 => $row->getMember() !== null ? $row->getMember()->getShortCode(): '',
  300.                     11 => $row->getKnownOrder() !== null ? $row->getKnownOrder()->getId() : 0,
  301.                     12 => $row->getDetectedFFL() ,
  302.                     13 => $row->isReadyForBilling(),
  303.                     14 => $row->getCustomer() !== null ? $row->getCustomer()->getId() : 0,
  304.                     15 => $row->getTotalCustomerNet(),
  305.                     16 => $row->getTotalMemberNet(),
  306.                     17 =>$options,
  307.                     18 => $row->getPassengerNotMet() ? 1 : 0,
  308.                     19 => $row->isDiscarded() ? 1 : 0,
  309.                     20 => $row->getHasMemberExtraKm() ? 1 : 0,
  310.                     21 => $row->getLastChangeByMember()!==null ? 1 : 0,
  311.                     22 => $row->getLastReadyForBillingCheckResult(),
  312.                     23 => $row->getApprovalStatus(),
  313.                     24 => $row->getKnownOrder() !== null ? $row->getKnownOrder()->getOrderId() : '',
  314.                     25 => $row->getKnownOrder() !== null ? $row->getKnownOrder()->getOrderStatus()->getId() : '',
  315.                     26 => $row->getKnownOrder() !== null ? $row->getKnownOrder()->getInternalComment() : '',
  316.                     27 => $row->getTaxameter(),
  319.                     28 => $memberDetails[JobCalcItem::KM],
  320.                     29 => $memberDetails[JobCalcItem::Pauschale],
  321.                     30 => $this->nf($memberDetails[JobCalcItem::Wartezeit]['value']),
  322.                     31 => $this->nf($memberDetails[JobCalcItem::Extra]['value']),
  323.                     32 => implode(";",$row->getControlling()),
  324.                     33 => $memberDetails[JobCalcItem::Extra]['text'],
  325.                     34 => $row->getKnownOrder() !== null ? $row->getKnownOrder()->getPaymentType()->getIcon() : '',
  326.                     35 => $memberDetails[MyMembershipController::WartezeitMin] ?? 0,
  327.                     36 => ($row->getCustomerSignature()!==null) ? 1 : 0,
  328.                     37 => $row->getKnownOrder() !== null ? ( ($row->getKnownOrder()->getDiscount())??0) : 0,
  329.                     38 => ($row->getKnownOrder()!==null ? $row->getKnownOrder()->getOriginOrderId() : '')
  331.             );
  332.             $filteredAndPaged[]= $one;
  333.         }
  334.         // get total unfiltered count
  335.         $query = $repo->createQueryBuilder('job')
  336.                         ->select('COUNT(job.id)')
  337.                         ->getQuery();
  338.         $res = $query->getResult();
  339.         $totalRecords = (int)$res[0][1];
  340.         // compile output
  341.         $output = array(
  342.             'draw' => $req['draw'],
  343.             'recordsTotal' =>$totalRecords,
  344.             'recordsFiltered' =>$filteredCount,
  345.             'data' => $filteredAndPaged
  346.         );
  347.         return $this->getJsonResponse($request,$output);
  348.     }
  350.     public function exportAction(Request $request)
  351.     {
  352.         $this->init();
  353.         $req = $request->query->all();
  354.         $from = new \DateTime($req['filterFrom']); $from->setTime(0,0,0);
  355.         $to = new \DateTime($req['filterTo']); $to->setTime(23,59,59);
  356.         $repo = $this->managerRegistry->getRepository(Job::class);
  357.         $cb = $repo->createQueryBuilder('job')
  358.             ->select('job','ord')
  359.             ->leftJoin('job.member','mem')
  360.             ->leftJoin('job.knownOrder','ord');
  361.         // filter time range
  362.         $from = new \DateTime($req["filterFrom"]); $from->setTime(0,0,0);
  363.         $to = new \DateTime($req["filterTo"]); $to->setTime(23,59,59);
  364.         $cb->andWhere('job.orderTime >= :from')->setParameter('from',$from);
  365.         $cb->andWhere('job.orderTime <= :to')->setParameter('to',$to);
  366.         $member = (int)($req['filterCar']??0);
  367.         if ($member > 0)
  368.         {
  369.             $cb->andWhere('job.member = :member')->setParameter('member',$member);
  370.         }
  371.         $cb
  372.             ->andWhere('job.discarded = 0')
  373.             ->orderBy('job.orderTime','asc');
  374.         $list = $cb->getQuery()->getResult(AbstractQuery::HYDRATE_OBJECT);
  376.         $tempFn = $this->getParameter("dx.temp_dir") . uniqid("export", true) . ".xlsx";
  377.         $xh = new ExcelExportHelper();
  378.         ExcelExportHelper::$xlsHeadStyle['borders'] = array('bottom' => ['style' => PHPExcel_Style_Border::BORDER_THIN]);
  379.         $xh->setSingleSheetMode('Fahrten');
  380.         $xh->addIndexedRow(sprintf('Fahrten %s bis %s (%s)',$from->format('d.m.y'),$to->format('d.m.y'),($member>0 ? 'Einzelmitglied':'Alle Mitglieder')));
  381.         /** @var Job $row */
  382.         foreach ($list as $row)
  383.         {
  384.             $memberDetails = MyMembershipController::sumUpMemberCalcCategories($row,true);
  385.             $one = array(
  386.                 "Bestellung"    => $row->getKnownOrder() !== null ? $row->getKnownOrder()->getOrderId() : '',
  387.                 "Datum"         => ($row->getOrderTime() !== null ? $row->getOrderTime()->format('d.m.Y H:i') : '-'),
  388.                 "Kostenstelle"  => [$row->getKnownOrder() !== null ? $row->getKnownOrder()->getCostCenter() : '', ExcelExportHelper::TYPE_STRING],
  389.                 "Start"         => $row->getOriginCity(),
  390.                 "Ziel"          => $row->getDestinationCity(),
  391.                 "Mitglied"      => $row->getMember() !== null ? $row->getMember()->getShortCode(): '',
  392.                 "Kunde"      => $row->getCustomer() !== null ? $row->getCustomer()->getName(): '',
  394.                 "Stil" => [$row->getRideStyle(),ExcelExportHelper::TYPE_STRING],
  395.                 "FRA"           => [$row->getDetectedFFL() != '' ? 1: 0, ExcelExportHelper::TYPE_NUMERIC],
  396.                 "Nicht angetroffen" => [$row->getPassengerNotMet() ? 1 : 0 , ExcelExportHelper::TYPE_NUMERIC],
  397.                 "Werksrundfahrt" => [$row->isWerksRundfahrt()?1:0,ExcelExportHelper::TYPE_NUMERIC],
  398.                 "Bewerberfahrt" => [$row->isApplicantTimeRide()?1:0,ExcelExportHelper::TYPE_NUMERIC],
  399.                 "Sofortfahrt" => [$row->isInstantRide()?1:0,ExcelExportHelper::TYPE_NUMERIC],
  400.                 "Wartezeitfahrt" => [$row->isExtraWaitingTimeRide()?1:0,ExcelExportHelper::TYPE_NUMERIC],
  401.                 "Wartezeit" => [$row->getExtraWaitingTime(),ExcelExportHelper::TYPE_NUMERIC],
  402.                 "Mehr-KM abw." => [$row->getHasMemberExtraKm()?1:0, ExcelExportHelper::TYPE_NUMERIC],
  403.                 "Mehr-KM"  => [$row->getMemberExtraKm(), ExcelExportHelper::TYPE_NUMERIC],
  404.                 "Kunde/€"       => [$row->getTotalCustomerNet(), ExcelExportHelper::TYPE_NUMERIC],
  405.                 "Mitglied/€"    => [$row->getTotalMemberNet(), ExcelExportHelper::TYPE_NUMERIC],
  407.                 "Abfahrt" => [$row->getDepartureAtOriginTime()!==null ? $row->getDepartureAtOriginTime()->format("H:i") :'', ExcelExportHelper::TYPE_STRING],
  408.                 "Ankunft" => [$row->getArrivalAtDestinationTime()!==null ?$row->getArrivalAtDestinationTime()->format("H:i") :'', ExcelExportHelper::TYPE_STRING],
  409.                 "Pos-Zeit" => [$row->getFlightOnPositionTime()!==null ? $row->getFlightOnPositionTime()->format("H:i") :'', ExcelExportHelper::TYPE_STRING],
  411.                 'KM' => [ $memberDetails[JobCalcItem::KM], ExcelExportHelper::TYPE_NUMERIC],
  412.                 'P' => $memberDetails[JobCalcItem::Pauschale],
  413.                 'WZ(€)' => [$memberDetails[JobCalcItem::Wartezeit]['value'], ExcelExportHelper::TYPE_NUMERIC],
  414.                 'DA(€)' => [$memberDetails[JobCalcItem::Stunde]['value'], ExcelExportHelper::TYPE_NUMERIC],
  415.                 'EX(€)' => [$memberDetails[JobCalcItem::Extra]['value'], ExcelExportHelper::TYPE_NUMERIC],
  416.                 'EX Kommentar' => [$row->getExtraCostName(), ExcelExportHelper::TYPE_STRING],
  418.                 "Ursprungsauftrag" => [ $row->getKnownOrder() !== null ? $row->getKnownOrder()->getOriginOrderId() : '', ExcelExportHelper::TYPE_STRING]
  420.             );
  421.             $xh->addRow($one,false,[ 0 => ExcelExportHelper::$centerH]);
  422.         }
  423.         $xh->changeColumnWidths([
  424.             1 => 20,
  425.             3 => 25,
  426.             4 => 25,
  427.         ]);
  428.         // finalize
  429.         $outFn = ""
  430.             .'Fahrten'
  431.             .'_von_'.$from->format('Y-m-d')
  432.             .'_bis_'.$to->format('Y-m-d')
  433.             .'_Stand_'.date('Y-m-d_H-i')
  434.             .'.' .$xh->getExtension();
  435.         $xh->saveTo($tempFn);
  436.         $resp = new BinaryFileResponse( $tempFn);
  437.         $resp->setContentDisposition(
  438.             ResponseHeaderBag::DISPOSITION_ATTACHMENT,
  439.             $outFn
  440.         );
  441.         return $resp;
  442.     }
  444.     public function exportAccAction(Request $request)
  445.     {
  446.         $this->init();
  447.         $req = $request->query->all();
  448.         $from = new \DateTime($req['filterFrom']); $from->setTime(0,0,0);
  449.         $to = new \DateTime($req['filterTo']); $to->setTime(23,59,59);
  450.         $repo = $this->managerRegistry->getRepository(Job::class);
  451.         $cb = $repo->createQueryBuilder('job')
  452.             ->select('job','ord')
  453.             ->leftJoin('job.member','mem')
  454.             ->leftJoin('job.knownOrder','ord');
  455.         // filter time range
  456.         $from = new \DateTime($req["filterFrom"]); $from->setTime(0,0,0);
  457.         $to = new \DateTime($req["filterTo"]); $to->setTime(23,59,59);
  458.         $cb->andWhere('job.orderTime >= :from')->setParameter('from',$from);
  459.         $cb->andWhere('job.orderTime <= :to')->setParameter('to',$to);
  460.         $member = (int)($req['filterCar']??0);
  461.         if ($member > 0)
  462.         {
  463.             $cb->andWhere('job.member = :member')->setParameter('member',$member);
  464.         }
  465.         $cb
  466.             ->andWhere('job.discarded = 0')
  467.             ->orderBy('job.orderTime','asc');
  468.         $list = $cb->getQuery()->getResult(AbstractQuery::HYDRATE_OBJECT);
  470.         $tempFn = $this->getParameter("dx.temp_dir") . uniqid("export", true) . ".xlsx";
  471.         $xh = new ExcelExportHelper();
  472.         ExcelExportHelper::$xlsHeadStyle['borders'] = array('bottom' => ['style' => PHPExcel_Style_Border::BORDER_THIN]);
  473.         $xh->setSingleSheetMode('Mitglieder,Fahrer');
  474.         $xh->addIndexedRow(sprintf('Fahrten %s bis %s (%s)',$from->format('d.m.y'),$to->format('d.m.y'),($member>0 ? 'Einzelmitglied':'Alle Mitglieder')));
  475.         //////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
  476.         $SAP_NR = 'LeistungsNr';
  477.         $item2array = function ($type, JobCalcItem $item) use($SAP_NR) {
  478.             return [
  479.                 "M/K" => $type,
  480.                 $SAP_NR => $item->accNumber,
  481.                 "Menge" => [$item->quantity, ExcelExportHelper::TYPE_NUMERIC],
  482.                 "Betrag" => [$item->amount, ExcelExportHelper::TYPE_NUMERIC],
  483.                 "Summe" => [$item->totalNet, ExcelExportHelper::TYPE_NUMERIC],
  484.                 "MwSt." => [$item->vat, ExcelExportHelper::TYPE_NUMERIC],
  485.                 "Text" => [$item->name, ExcelExportHelper::TYPE_STRING]
  486.             ];
  487.         };
  488.         $all = [
  489.             'M' => [],
  490.             'K' => [],
  491.         ];
  492.         /** @var Job $row */
  493.         foreach ($list as $row)
  494.         {
  495.             $base = [
  496.                 "Bestellung"    => $row->getKnownOrder() !== null ? $row->getKnownOrder()->getOrderId() : '',
  497.                 "Datum"         => ($row->getOrderTime() !== null ? $row->getOrderTime()->format('d.m.Y H:i') : '-'),
  498.                 "Kostenstelle"  => [$row->getKnownOrder() !== null ? $row->getKnownOrder()->getCostCenter() : '', ExcelExportHelper::TYPE_STRING],
  499.                 "Start"         => $row->getOriginCity(),
  500.                 "Ziel"          => $row->getDestinationCity(),
  501.                 "Mitglied"      => $row->getMember() !== null ? $row->getMember()->getShortCode(): '',
  502.                 "Stil" => [$row->getRideStyle(),ExcelExportHelper::TYPE_STRING],
  503.             ];
  504.             /** @var JobCalcItem $item */
  505.             foreach ($row->getMemberCalculationItems() as $item)
  506.             {
  507.                 $all["M"][] = array_merge($item2array("M",$item),$base);
  508.             }
  509.             foreach ($row->getCustomerCalculationItems() as $item)
  510.             {
  511.                 $all["K"][] = array_merge($item2array("K",$item),$base);
  512.             }
  513.         }
  514.         // Summieren
  515.         $blank = [ 'Menge'=>0,'Summe'=>0];
  516.         $sum = [];
  517.         foreach ($all as $part)
  518.         foreach ($part as $one)
  519.         {
  520.             $k = $one[$SAP_NR];
  521.             if (!array_key_exists($k,$sum))
  522.             {
  523.                 $sum[$k] = $blank;
  524.             }
  525.             $sum[$k]['Menge'] += (int)$one['Menge'][0];
  526.             $sum[$k]['Summe'] += $one['Summe'][0];
  527.         }
  528.         // erstes sheet
  529.         foreach ($all['M'] as $one)
  530.         {
  531.             $xh->addRow($one);
  532.         }
  533.         // zweites Sheet
  534.         $xh->addSheet('Interne Kunden',true);
  535.         foreach ($all['K'] as $one)
  536.         {
  537.             $xh->addRow($one);
  538.         }
  539.         // Summen
  540.         $xh->addSheet('Summen');
  541.         $xh->setupColumns([$SAP_NR,"Menge","Summe"]);
  542.         foreach ($sum as $k=>$one)
  543.         {
  544.             $xh->addRow([
  545.                 $SAP_NR => $k,
  546.                 'Menge'=> [$one['Menge'], ExcelExportHelper::TYPE_NUMERIC],
  547.                 'Summe' => [$one['Summe'], ExcelExportHelper::TYPE_NUMERIC]
  548.             ]);
  549.         }
  550.         /////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
  551.         // finalize
  552.         $outFn = ""
  553.             .'Fahrten-Abrechnung'
  554.             .'_von_'.$from->format('Y-m-d')
  555.             .'_bis_'.$to->format('Y-m-d')
  556.             .'_Stand_'.date('Y-m-d_H-i')
  557.             .'.' .$xh->getExtension();
  558.         $xh->saveTo($tempFn);
  559.         $resp = new BinaryFileResponse( $tempFn);
  560.         $resp->setContentDisposition(
  561.             ResponseHeaderBag::DISPOSITION_ATTACHMENT,
  562.             $outFn
  563.         );
  564.         return $resp;
  565.     }
  570.     public function recalcAction(Request $request)
  571.     {
  573.         $this->init();
  574.         /** @var JobRepository $repo */
  575.         $repo = $this->managerRegistry->getRepository(Job::class);
  576.         $ids = json_decode($request->request->get('selector','[]'),true);
  577.         if (count($ids)<1)
  578.         {
  579.             $this->addFlash('warning','Keine Einträge ausgewählt.');
  580.             return $this->redirectToRoute('acc-jobs');
  581.         }
  582.         if (count($ids)>250)
  583.         {
  584.             $this->addFlash('warning','Bitte wählen Sie max. 250 Einträge für eine Neuberechnung aus.');
  585.             return $this->redirectToRoute('acc-jobs');
  586.         }
  588.         $qb = $repo->createQueryBuilder('J');
  589.         $qb->where($qb->expr()->in('J.id',':ids'))->setParameter('ids',$ids);
  590.         $jobs = $qb->getQuery()->getResult();
  591.         /** @var Job $row */
  592.         foreach ($jobs as $row)
  593.         {
  594.             if ($row->getMember() === null) {
  595.                continue;
  596.             }
  597.             if ($row->getCustomer() === null) {
  598.                 continue;
  599.             }
  601.             $pc = $this->paymentCalculator;
  602.             $pc->setFlashBag($this->container->get('session')->getFlashBag());
  603.             $pc->calculateTotals($row,$row->isBilled(Billing::TYPE_CUSTOMER),$row->isBilled(Billing::TYPE_MEMBER),);
  605.             $on = $row->getKnownOrder() !== null ? $row->getKnownOrder()->getOrderId() : $row->getOrderNumber();
  607.             $this->addFlash('info', ['html' => PaymentCalculator::log2html($on.': Berechnungsergebnis für Mitglieder', $row->getMemberCalculationItems())]);
  608.             $this->addFlash('info', ['html' => PaymentCalculator::log2html($on.': Berechnungsergebnis für Kunden', $row->getCustomerCalculationItems())]);
  609.             if (count($row->getControlling())>0)
  610.             {
  611.                 $this->addFlash('info', ['html' => PaymentCalculator::log2html($on.': Controlling ', $row->getControlling())]);
  612.             }
  613.         }
  614.         $repo->flush();
  615.         return $this->redirectToRoute('acc-jobs');
  616.     }
  618.     public function editAction(Request $request, $id)
  619.     {
  620.         $this->init();
  621.         /** @var EntityManagerInterface $em */
  622.         $em = $this->managerRegistry->getManager();
  623.         /** @var JobRepository $repo */
  624.         $repo = $this->managerRegistry->getRepository(Job::class);
  625.         /** @var Job $row */
  626.         $row = $repo->findOneBy(['id'=>$id]);
  627.         $prev = $repo->findPreviousJobForMember($row);
  628.         $next = $repo->findNextJobForMember($row);
  629.         $customerPrev = $repo->findPreviousJobForCustomer($row);
  630.         $customerNext = $repo->findNextJobForCustomer($row);
  632.         $form = $this->createForm(JobForm::class,$row,[]);
  633.         $form->handleRequest($request);
  634.         if ( $form->isSubmitted() )
  635.         {
  636.             $this->ensureUserHasRole(Role::ACCOUNTING_EDIT);
  637.             // fetch changes
  638.             $uow = $em->getUnitOfWork();
  639.             $uow->computeChangeSets();
  640.             $changeSet = $uow->getEntityChangeSet($row);
  642.             if ( (isset($changeSet['member'])) && ($form->has('confirmMemberChange')) && ($form->get('confirmMemberChange')->getData()!==true) )
  643.             {
  644.                 $form->get('confirmMemberChange')->addError(new FormError('Bitte bestätigen Sie die Änderung des Mitglieds.'));
  645.             }
  647.             if ( (isset($changeSet['customer'])) && ($form->has('confirmCustomerChange')) && ($form->get('confirmCustomerChange')->getData()!==true) )
  648.             {
  649.                 $form->get('confirmCustomerChange')->addError(new FormError('Bitte bestätigen Sie die Änderung des Kunden.'));
  650.             }
  653.             if ($form->isValid())
  654.             {
  656.                 $repo->flush($row); // initial flush required, otherwise doctrine may loose changes on the way. TODO : why is that ?
  658.                 if ( ($form->has('calc')) && ($form->get('calc')->isClicked()) ) {
  659.                     if ($row->getMember() === null) {
  660.                         $this->addFlash('danger', 'Fehler: Kein Mitglied zugeordnet !');
  661.                     }
  662.                     if ($row->getCustomer() === null) {
  663.                         $this->addFlash('danger', 'Fehler: Kein Kunde zugeordnet !');
  664.                     }
  666.                     $pc = $this->paymentCalculator;
  667.                     $pc->setFlashBag($this->container->get('session')->getFlashBag());
  668.                     $pc->calculateTotals($row,
  669.                         $row->isBilled(Billing::TYPE_CUSTOMER),
  670.                         $row->isBilled(Billing::TYPE_MEMBER),
  671.                     );
  674.                     $this->addFlash('info', ['html' => PaymentCalculator::log2html('Berechnungsergebnis für Mitglieder', $row->getMemberCalculationItems())]);
  675.                     $this->addFlash('info', ['html' => PaymentCalculator::log2html('Berechnungsergebnis für Kunden', $row->getCustomerCalculationItems())]);
  677.                     if (count($row->getControlling())>0)
  678.                     {
  679.                         $this->addFlash('info', ['html' => PaymentCalculator::log2html('Controlling ', $row->getControlling())]);
  680.                     }
  681.                 }
  683.                 if (($form->has('checkReadyForBilling')) && ($form->get('checkReadyForBilling')->isClicked())) {
  684.                     $msg = [];
  685.                     JobRepository::detectReadyForBilling($row, $msg);
  686.                     if ($row->isReadyForBilling())
  687.                     {
  688.                         $this->addFlash('info', 'Buchung ist bereit zur Abrechnung');
  689.                     }
  690.                     else
  691.                     {
  692.                         // if the job is not ready for billing, the warning messages and the state are not persisted since
  693.                         // we also do not want to persist the other changes made via form
  694.                         $this->addFlash('warning', 'Buchung ist nicht bereit zur Abrechnung');
  695.                         foreach ($msg as $k=>$m) {
  696.                             $this->addFlash('warning', $m);
  697.                             if ($form->has($k))
  698.                             {
  699.                                 $form->get($k)->addError(new FormError($m));
  700.                             }
  701.                         }
  702.                     }
  703.                 }
  705.                 if ($form->getErrors(true,true)->count() < 1)
  706.                 {
  707.                     $row->setLastChangeByMember(null);
  708.                     $this->addFlash('success','Änderungen gespeichert.');
  709.                     $repo->flush($row);
  710.                     return $this->redirectToRoute('acc-jobs-edit', ['id' => $row->getId()]);
  711.                 }
  713.             }
  714.         }
  716.         return $this->render('@DiplixKMG/Accounting/Job/edit.html.twig',[
  717.             'row'=>$row,
  718.             'prev' => $prev,
  719.             'next' => $next,
  720.             'config'=>$this->config,
  721.             'customerPrev'=>$customerPrev,
  722.             'customerNext'=>$customerNext,
  723.             'form' => $form->createView(),
  724.         ]);
  725.     }
  727.     public function deleteAction(Request $request, $id)
  728.     {
  729.         $this->init();
  730.         $this->ensureUserHasRole(Role::ACCOUNTING_EDIT);
  731.         /** @var EntityManagerInterface $em */
  732.         $em = $this->managerRegistry->getManager();
  733.         /** @var JobRepository $repo */
  734.         $repo = $this->managerRegistry->getRepository(Job::class);
  735.         $d = $request->request->get('discard',-1);
  736.         $ids = [ $id ];
  737.         /** @noinspection TypeUnsafeComparisonInspection */
  738.         if ($id == 0)
  739.         {
  740.             $ids = json_decode($request->request->get('selector','[]'),true);
  741.         }
  743.         if (count($ids)<1)
  744.         {
  745.             $this->addFlash('warning','Keine Einträge ausgewählt.');
  746.             return $this->redirectToRoute('acc-jobs');
  747.         }
  749.         $r = $repo->discardJobs($ids,$d==1?true:false,$this->getCurrentUser()->getId());
  751.         $this->addFlash('success',sprintf('%d Einträge wurden aktualisiert.',$r));
  753.         return $this->redirectToRoute('acc-jobs');
  754.     }
  756.     public function importAction(Request $request)
  757.     {
  758.         $this->init();
  759.         $this->ensureUserHasRole(Role::ACCOUNTING_EDIT);
  760. //        if (!$this->getParameter('tami.enabled'))
  761. //        {
  762. //            $this->addFlash('warning', 'TaMi-Integration ist deaktiviert.');
  763. //            return $this->redirectToRoute('acc-jobs');
  764. //        }
  765.         /** @var EntityManagerInterface $em */
  766.         $em = $this->managerRegistry->getManager();
  767.         $form = $this->createForm(ImportJobFileForm::class);
  768.         $form->handleRequest($request);
  769.         if ($form->isSubmitted())
  770.         {
  771.             if ($form->isValid())
  772.             {
  773.                 /** @var UploadedFile $file */
  774.                 $file = $form->get("importFile")->getData();
  775.                 if ($file->isValid())
  776.                 {
  777.                     try
  778.                     {
  779.                         $imp = $this->tamiJobImporter;
  780.                         $resultMessages = $imp->importAndProcessJobFile($file->getRealPath());
  781.                         foreach ($resultMessages as $m)
  782.                         {
  783.                             $this->addFlash('success',$m);
  784.                         }
  786.                         return $this->redirectToRoute('acc-jobs');
  787.                     }
  788.                     catch (\Throwable $ex)
  789.                     {
  790.                         $this->addFlash('danger', 'Import fehlgeschlagen. (' .$ex->getMessage(). ')');
  791.                         throw $ex;
  792.                     }
  793.                 }
  794.                 $this->addFlash('danger', 'Upload fehlgeschlagen.');
  795.             }
  796.             else
  797.             {
  798.                 $this->addFlash('warning', 'Bitte überprüfen SIe Ihre Eingaben');
  799.             }
  800.         }
  801.         return $this->render('@DiplixKMG/Accounting/Job/import.html.twig', array('form' => $form->createView()));
  802.     }
  804.     public function reprocessAction(Request $request)
  805.     {
  806.         $this->init();
  807.         $this->ensureUserHasRole(Role::ACCOUNTING_EDIT);
  808.         if (!$this->getParameter('tami.enabled'))
  809.         {
  810.             $this->addFlash('warning', 'TaMi-Integration ist deaktiviert.');
  811.             return $this->redirectToRoute('acc-jobs');
  812.         }
  813.         /** @var EntityManagerInterface $em */
  814.         $em = $this->managerRegistry->getManager();
  815.         $imp = $this->tamiJobImporter;
  816.         $repo = $em->getRepository(Job::class);
  818.         $items = $repo->findBy(['readyForBilling'=>false]);
  819.         $this->addFlash('success', count($items) . ' noch nicht zur Abrechnung bereite Einträge geladen');
  821.         $resultInfo = $imp->postProcessImport($items);
  822.         foreach ($items as $job)
  823.         {
  824.             JobRepository::detectReadyForBilling($job);
  825.         }
  826.         $repo->flush();
  827.         $msgs = $imp->getResultMessages($resultInfo);
  828.         foreach ($msgs as $m)
  829.         {
  830.             $this->addFlash('success',$m);
  831.         }
  832.         return $this->redirectToRoute('acc-jobs');
  833.     }
  835.     protected function timeOrNull($date)
  836.     {
  837.         if ($date === null)
  838.             return null;
  839.         return $date->format('H:i');
  840.     }
  842.     const XFER_ENTRY = "[TRANSFER]";
  844.     public function submitxchgAction(Request $request)
  845.     {
  846.         /** @var Job $job */
  847.         $job = null;
  848.         $repo = null;
  849.         try
  850.         {
  851.             $this->init();
  852.             if ($request->getMethod()!==Request::METHOD_POST)
  853.             {
  854.                 throw new \RuntimeException('Use POST');
  855.             }
  856.             /** @var JobRepository $repo */
  857.             $repo = $this->managerRegistry->getRepository(Job::class);
  858.             $sel = $request->get('selector','[]');
  859.             $ids = strpos($sel,"[") !== false ? json_decode($sel,true) : [(int)$sel];
  860.             if (count($ids)<1)
  861.             {
  862.                 throw new \RuntimeException("Keine Einträge ausgewählt. ($sel)");
  864.             }
  865.             if (count($ids)>1)
  866.             {
  867.                 throw new \RuntimeException('Zuviele Einträge ausgewählt.');
  869.             }
  870.             $qb = $repo->createQueryBuilder('J');
  871.             $qb->where($qb->expr()->in('J.id',':ids'))->setParameter('ids',$ids);
  872.             $jobs = $qb->getQuery()->getResult();
  873.             $clientCache = [];
  874.             /** @var Job $job */
  875.             $job = reset($jobs);
  877.             if ($job->getCustomer() === null)
  878.             {
  879.                 throw new \RuntimeException("Kein Kunde im Auftrag");
  880.             }
  881.             if ($job->getKnownOrder() === null)
  882.             {
  883.                 throw new \RuntimeException("Keine Bestellung im Auftrag");
  884.             }
  885.             if ($job->getCustomer()->getXchgPlatformUrl()=="")
  886.             {
  887.                 throw new \RuntimeException("Fehlende Fremdsystem-URL");
  888.             }
  889.             if ($job->getKnownOrder()->getXchgStatus()!==Order::XCHG_RECEIVED_FROM_OTHER)
  890.             {
  891.                 throw new \RuntimeException("Auftrag kommt nicht von Fremdsystem.");
  892.             }
  894.             if (!array_key_exists($job->getCustomer()->getId(),$clientCache))
  895.             {
  896.                 $clientCache[$job->getCustomer()->getId()]= OrderHandler::getClientForCustomerWhoLoginsAsMember($job->getCustomer());;
  897.             }
  898.             $client = $clientCache[$job->getCustomer()->getId()];
  900.             $res = $client->request("POST",rtrim($job->getCustomer()->getXchgPlatformUrl(),'/')."/job-update-by-oid",[
  901.                 'headers'=> [
  902.                     "Content-Type"=>"application/json"
  903.                 ],
  904.                 'body' => json_encode(
  905.                     [
  906.                         "login" => $job->getCustomer()->getXchgLoginAsMember(),
  907.                         "password" => $job->getCustomer()->getXchgLoginPassword(),
  908.                         "orderId"=> $job->getKnownOrder()->getXchgOrderId(),
  909.                         "xchg"=>true,
  910.                         // data
  911.                         'flightOnPositionTime' => $this->timeOrNull($job->getFlightOnPositionTime()),
  912.                         'departureAtOriginTime' => $this->timeOrNull($job->getDepartureAtOriginTime()),
  913.                         'arrivalAtDestinationTime' => $this->timeOrNull($job->getArrivalAtDestinationTime()),
  914.                         'passengerNotMet'=>$job->getPassengerNotMet(),
  915.                         'taxameter'=>$job->getTaxameter(),
  916.                         'taxameterVat'=>$job->getTaxameterVat(),
  917.                         'extraCostName'=>$job->getExtraCostName(),
  918.                         'extraCostPrice'=>$job->getExtraCostPrice(),
  919.                         'hasMemberExtraKm' => $job->getHasMemberExtraKm(),
  920.                         'memberExtraKm'=>$job->getMemberExtraKm(),
  921.                         'confirmedByCustomerThrough'=>$job->getConfirmedByCustomerThrough(),
  922.                         'approvedByDriver'=>$job->isApprovedByDriver(),
  924.                         'werksRundfahrt' => $job->isWerksRundfahrt(),
  925.                         'extraWaitingTimeRide' => $job->isExtraWaitingTimeRide(),
  926.                         'extraWaitingTime' => $job->getExtraWaitingTime(),
  927.                         'instantRideAdditionalWaitingTime' => $job->getInstantRideAdditionalWaitingTime(),
  929.                     ]
  930.                     , JSON_THROW_ON_ERROR)
  931.             ]);
  933.             $res = json_decode($res->getBody(), true, 512, JSON_THROW_ON_ERROR);
  934.             if ($res['success']!==true)
  935.             {
  936.                 throw new \RuntimeException('Fehler bei der Übertragung.'.var_export($res,true));
  937.             }
  939.             $jobId =$job->getKnownOrder() !== null ? $job->getKnownOrder()->getOrderId().": " : '';
  940.             return new JsonResponse(['success'=>true,'message'=> $jobId.'Job übertragen.']);
  942.         }
  943.         catch (\Throwable $ex)
  944.         {
  945.             $jobId= '';
  946.             if ($job !== null)
  947.             {
  948.                 $cleanCo = array_filter($job->getControlling(), function($v) { return strpos($v, self::XFER_ENTRY) === false; });
  949.                 $cleanCo[]= self::XFER_ENTRY.$ex->getMessage();
  950.                 $job->setControlling($cleanCo);
  951.                 if ($repo !==null) $repo->flush($job);
  952.                 SysLogRepository::logError($this->managerRegistry->getConnection(),$ex->getMessage().$ex->getTraceAsString(),$job);
  953.                 $jobId =$job->getKnownOrder() !== null ? $job->getKnownOrder()->getOrderId().": " : '';
  954.             }
  955.             return new JsonResponse(['success'=>false,'message'=>$jobId.$ex->getMessage()]);
  956.         }
  960. //        $qb = $repo->createQueryBuilder('J');
  961. //        $qb->where($qb->expr()->in('J.id',':ids'))->setParameter('ids',$ids);
  962. //        $jobs = $qb->getQuery()->getResult();
  963. //        $clientCache = [];
  964. //        /** @var Job $job */
  965. //        foreach ($jobs as $job)
  966. //        {
  967. //            try
  968. //            {
  969. //                if ($job->getCustomer() === null)
  970. //                {
  971. //                    throw new \RuntimeException("Kein Kunde im Auftrag");
  972. //                }
  973. //                if ($job->getKnownOrder() === null)
  974. //                {
  975. //                    throw new \RuntimeException("Keine Bestellung im Auftrag");
  976. //                }
  977. //                if ($job->getCustomer()->getXchgPlatformUrl()=="")
  978. //                {
  979. //                    throw new \RuntimeException("Fehlende Fremdsystem-URL");
  980. //                }
  981. //                if ($job->getKnownOrder()->getXchgStatus()!==Order::XCHG_RECEIVED_FROM_OTHER)
  982. //                {
  983. //                    throw new \RuntimeException("Auftrag kommt nicht von Fremdsystem.");
  984. //                }
  985. //
  986. //                if (!array_key_exists($job->getCustomer()->getId(),$clientCache))
  987. //                {
  988. //                    $clientCache[$job->getCustomer()->getId()]= OrderHandler::getClientForCustomerWhoLoginsAsMember($job->getCustomer());;
  989. //                }
  990. //                $client = $clientCache[$job->getCustomer()->getId()];
  991. //
  992. //                $res = $client->request("POST",rtrim($job->getCustomer()->getXchgPlatformUrl(),'/')."/job-update-by-oid",[
  993. //                    'headers'=> [
  994. //                        "Content-Type"=>"application/json"
  995. //                    ],
  996. //                    'body' => json_encode(
  997. //                        [
  998. //                            "login" => $job->getCustomer()->getXchgLoginAsMember(),
  999. //                            "password" => $job->getCustomer()->getXchgLoginPassword(),
  1000. //                            "orderId"=> $job->getKnownOrder()->getXchgOrderId(),
  1001. //                            "xchg"=>true,
  1002. //                            // data
  1003. //                              'flightOnPositionTime' => $this->timeOrNull($job->getFlightOnPositionTime()),
  1004. //                              'departureAtOriginTime' => $this->timeOrNull($job->getDepartureAtOriginTime()),
  1005. //                              'arrivalAtDestinationTime' => $this->timeOrNull($job->getArrivalAtDestinationTime()),
  1006. //                              'passengerNotMet'=>$job->getPassengerNotMet(),
  1007. //                              'taxameter'=>$job->getTaxameter(),
  1008. //                              'taxameterVat'=>$job->getTaxameterVat(),
  1009. //                              'extraCostName'=>$job->getExtraCostName(),
  1010. //                              'extraCostPrice'=>$job->getExtraCostPrice(),
  1011. //                                'hasMemberExtraKm' => $job->getHasMemberExtraKm(),
  1012. //                              'memberExtraKm'=>$job->getMemberExtraKm(),
  1013. //                              'confirmedByCustomerThrough'=>$job->getConfirmedByCustomerThrough(),
  1014. //                              'approvedByDriver'=>$job->isApprovedByDriver(),
  1015. //
  1016. //                            'werksRundfahrt' => $job->isWerksRundfahrt(),
  1017. //                            'extraWaitingTimeRide' => $job->isExtraWaitingTimeRide(),
  1018. //                            'extraWaitingTime' => $job->getExtraWaitingTime(),
  1019. //                            'instantRideAdditionalWaitingTime' => $job->getInstantRideAdditionalWaitingTime(),
  1020. //
  1021. //                        ]
  1022. //                        , JSON_THROW_ON_ERROR)
  1023. //                ]);
  1024. //
  1025. //                $res = json_decode($res->getBody(), true, 512, JSON_THROW_ON_ERROR);
  1026. //                if ($res['success']!==true)
  1027. //                {
  1028. //                    throw new \RuntimeException('Fehler bei der Übertragung.'.var_export($res,true));
  1029. //                }
  1030. //                $this->addFlash("success",sprintf("Job %s: %s",$job->getKnownOrder()->getOrderId(),"Übertragen."));
  1031. //            }
  1032. //            catch (\Throwable $ex)
  1033. //            {
  1034. //                $this->addFlash('danger',sprintf("Job %s: %s",$job->getKnownOrder()->getOrderId(),$ex->getMessage()));
  1035. //                SysLogRepository::logError($this->getDoctrine()->getConnection(),$ex->getMessage().$ex->getTraceAsString(),$job);
  1036. //            }
  1037. //        }
  1038. //        return $this->redirectToRoute('acc-jobs');
  1039.     }
  1041.     public function customerRatesAction(Request $request, $customerId)
  1042.     {
  1043.         $repo = $this->managerRegistry->getRepository(Customer::class);
  1044.         /** @var Customer $customer */
  1045.         $customer = $repo->findOneBy(['id'=>$customerId]);
  1046.         return new JsonResponse( $customer->getAccRates() );
  1047.     }
  1049.     public function memberRatesAction(Request $request, $memberId)
  1050.     {
  1051.         $repo = $this->managerRegistry->getRepository(CoopMember::class);
  1052.         /** @var CoopMember $mem  */
  1053.         $mem = $repo->findOneBy(['id'=>$memberId]);
  1054.         return new JsonResponse( $mem->getRates() );
  1055.     }
  1057.     public function checkReady4BillingAction(Request $request)
  1058.     {
  1059.         $this->init();
  1060.         $this->ensureUserHasRole(Role::ACCOUNTING_EDIT);
  1061.         /** @var JobRepository $repo */
  1062.         $repo = $this->managerRegistry->getRepository(Job::class);
  1063.         $ids = json_decode($request->request->get('selector','[]'),true);
  1064.         if (count($ids)<1)
  1065.         {
  1066.             $this->addFlash('warning','Keine Einträge ausgewählt.');
  1067.             return $this->redirectToRoute('acc-jobs');
  1068.         }
  1069.         $qb = $repo->createQueryBuilder('J');
  1070.         $qb->where($qb->expr()->in('J.id',':ids'))->setParameter('ids',$ids);
  1071.         $jobs = $qb->getQuery()->getResult();
  1072.         /** @var Job $j */
  1073.         foreach ($jobs as $j)
  1074.         {
  1075.             $msg = [];
  1076.             JobRepository::detectReadyForBilling($j, $msg);
  1077.             if ($j->isReadyForBilling())
  1078.             {
  1079.                 $j->setLastChangeByMember(null);
  1080.             }
  1081.             $repo->flush($j);
  1083.             $orderTitle = $j->getKnownOrder()!==null ? $j->getKnownOrder()->getOrderId() : 'null';
  1084.             if ($j->getOrderNumber()!=='') $orderTitle.= ' (TaMi: '.$j->getOrderNumber().')';
  1086.             if ($j->isReadyForBilling())
  1087.             {
  1088.                 $this->addFlash('success', $orderTitle.': Buchung ist bereit zur Abrechnung');
  1089.             }
  1090.             else
  1091.             {
  1092.                 $txt = '<b>'.$orderTitle.'</b><br>';
  1093.                 foreach ($msg as $k=>$m) {
  1094.                     $txt.= $m.'<br>';
  1095.                 }
  1096.                 $this->addFlash('danger',['html'=>$txt]);
  1097.             }
  1098.         }
  1100.         return $this->redirectToRoute('acc-jobs');
  1101.     }
  1103.     public function approve4BillingAction(Request $request, $approveOrNot)
  1104.     {
  1105.         $this->init();
  1106.         $this->ensureUserHasRole(Role::ACCOUNTING_EDIT);
  1107.         /** @var JobRepository $repo */
  1108.         $repo = $this->managerRegistry->getRepository(Job::class);
  1109.         $ids = json_decode($request->request->get('selector','[]'),true);
  1110.         if (count($ids)<1)
  1111.         {
  1112.             $this->addFlash('warning','Keine Einträge ausgewählt.');
  1113.             return $this->redirectToRoute('acc-jobs');
  1114.         }
  1115.         $qb = $repo->createQueryBuilder('J');
  1116.         $qb->where($qb->expr()->in('J.id',':ids'))->setParameter('ids',$ids);
  1117.         $jobs = $qb->getQuery()->getResult();
  1118.         /** @var Job $j */
  1119.         foreach ($jobs as $j)
  1120.         {
  1121.             $on = ($j->getKnownOrder()!==null?$j->getKnownOrder()->getOrderId():'').' '.$j->getOrderNumber();
  1122.             if (!$j->isReadyForBilling())
  1123.             {
  1125.                 $this->addFlash('warning', $on.': Achtung: Buchung war nicht bereit zur Abrechnung. Freigabestatus wurde trotzdem verändert.');
  1126.             }
  1127.             /** @noinspection TypeUnsafeComparisonInspection */
  1128.             $approveOrNot = ($approveOrNot==1);
  1129.             $j->setApprovedByAccounting($approveOrNot);
  1130.             $this->addFlash('success', $on.': '.($approveOrNot?"Freigegeben":"Freigabe entfernt"));
  1131.         }
  1132.         $repo->flush();
  1133.         return $this->redirectToRoute('acc-jobs');
  1134.     }
  1136.     public function refreshFromOrderAction(Request $request, $jobId)
  1137.     {
  1138.         $this->init();
  1139.         $this->ensureUserHasRole(Role::ACCOUNTING_EDIT);
  1140.         $redir = $this->redirectToRoute('acc-jobs-edit',['id'=>$jobId]);
  1141.         /** @var EntityManagerInterface $em */
  1142.         $em = $this->managerRegistry->getManager();
  1143.         /** @var JobRepository $repo */
  1144.         $repo = $this->managerRegistry->getRepository(Job::class);
  1145.         /** @var Job $job */
  1146.         $job = $repo->findOneBy(['id'=>$jobId]);
  1147.         if ($job->isApprovedByAccounting())
  1148.         {
  1149.             $this->addFlash('warning','Fahrtdaten wurden bereits durch die Abrechnung bestätigt. Abgleich mit Bestellung nicht mehr möglich.');
  1150.             return $redir;
  1151.         }
  1153.         if ($job->getKnownOrder() === null)
  1154.         {
  1155.             $this->addFlash('warning','Es ist keine Bestellung verknüpft.');
  1156.             return $redir;
  1157.         }
  1159.         $job->updateFromOrder($job->getKnownOrder());
  1160.         $this->addFlash('info','Daten aus Bestellung neu übernommen');
  1162.         if ($job->getMember()===null)
  1163.         {
  1164.             $job->setMember($job->getKnownOrder()->getAssignedTo());
  1165.             if ($job->getMember()!==null)
  1166.             {
  1167.                 $this->addFlash('info',sprintf('Mitglied %s wurde übernommen.',$job->getMember()->getName()));
  1168.             }
  1169.         }
  1170.         else
  1171.         {
  1172.             if (( $job->getKnownOrder()->getAssignedTo()!==null)&&($job->getKnownOrder()->getAssignedTo()->getId()!=$job->getMember()->getId()) )
  1173.             {
  1174.                 $this->addFlash('warning',sprintf('Achtung Mitglieder unterscheiden sich. Bestellung: %s, Fahrauftrag: %s. Diese Änderung wurde nicht automatisch übernommen.',
  1175.                     $job->getKnownOrder()->getAssignedTo()->getName(), $job->getMember()->getName()
  1176.                 ));
  1177.             }
  1178.         }
  1180.         $repo->flush();
  1182.         return $redir;
  1183.     }
  1186.     public function reCalcDistanceAction(Request $request, $jobId)
  1187.     {
  1188.         $this->init();
  1189.         $this->ensureUserHasRole(Role::ACCOUNTING_EDIT);
  1190.         $redir = $this->redirectToRoute('acc-jobs-edit',['id'=>$jobId]);
  1191.         /** @var EntityManagerInterface $em */
  1192.         $em = $this->managerRegistry->getManager();
  1193.         /** @var JobRepository $repo */
  1194.         $repo = $this->managerRegistry->getRepository(Job::class);
  1195.         /** @var Job $job */
  1196.         $job = $repo->findOneBy(['id'=>$jobId]);
  1197.         if ($job->isApprovedByAccounting())
  1198.         {
  1199.             $this->addFlash('warning','Fahrtdaten wurden bereits durch die Abrechnung bestätigt. Abgleich mit Bestellung nicht mehr möglich.');
  1200.             return $redir;
  1201.         }
  1202.         if ($job->getKnownOrder() === null)
  1203.         {
  1204.             $this->addFlash('warning','Es ist keine Bestellung verknüpft.');
  1205.             return $redir;
  1206.         }
  1207.         $calcService = $this->calculatorService;
  1208.         /** @var Order $order */
  1209.         $order = $job->getKnownOrder();
  1210.         $flatWaypoints = [ $order->getPriceList()->getHomeAddress() ]; // start/endpoint
  1211.         foreach ($order->getAddressList() as $a) {
  1212.             $flatWaypoints[] = CalculatorService::addressToFlatString(json_decode(json_encode($a),true));
  1213.         }
  1214.         $distances =  $calcService->getDistance($flatWaypoints);
  1215.         $job->setActualKm( $calcService->getDistanceSumInKm($distances) );
  1217.         $this->addFlash('info',sprintf('Berechnete Distanz: %02.2f',$job->getActualKm()));
  1219.         $repo->flush();
  1221.         return $redir;
  1222.     }
  1224.     public function reCheckCombiAction(Request $request, $jobId)
  1225.     {
  1226.         $this->init();
  1227.         $this->ensureUserHasRole(Role::ACCOUNTING_EDIT);
  1228.         $redir = $this->redirectToRoute('acc-jobs-edit',['id'=>$jobId]);
  1229.         /** @var EntityManagerInterface $em */
  1230.         $em = $this->managerRegistry->getManager();
  1231.         /** @var JobRepository $repo */
  1232.         $repo = $this->managerRegistry->getRepository(Job::class);
  1233.         /** @var Job $job */
  1234.         $job = $repo->findOneBy(['id'=>$jobId]);
  1235.         if ($job->isApprovedByAccounting())
  1236.         {
  1237.             $this->addFlash('warning','Fahrtdaten wurden bereits durch die Abrechnung bestätigt. Aktualisierung nicht möglich.');
  1238.             return $redir;
  1239.         }
  1240.         $pc = $this->paymentCalculator;
  1241.         if ($pc->detectCombiAssociations($job))
  1242.         {
  1243.             $this->addFlash('info','Zuordnung wurde erneut durchgeführt');
  1244.             $em->flush();
  1245.         }
  1246.         return $redir;
  1247.     }
  1249.     public function removeCombiAction(Request $request, $jobId)
  1250.     {
  1251.         $this->init();
  1252.         $this->ensureUserHasRole(Role::ACCOUNTING_EDIT);
  1253.         $redir = $this->redirectToRoute('acc-jobs-edit',['id'=>$jobId]);
  1254.         /** @var EntityManagerInterface $em */
  1255.         $em = $this->managerRegistry->getManager();
  1256.         /** @var JobRepository $repo */
  1257.         $repo = $this->managerRegistry->getRepository(Job::class);
  1258.         /** @var Job $job */
  1259.         $job = $repo->findOneBy(['id'=>$jobId]);
  1260.         if ($job->isApprovedByAccounting())
  1261.         {
  1262.             $this->addFlash('warning','Fahrtdaten wurden bereits durch die Abrechnung bestätigt. Aktualisierung nicht möglich.');
  1263.             return $redir;
  1264.         }
  1265.         self::removeRelation($job);
  1266. //        if ($job->getCombiRideChild()!==null)
  1267. //        {
  1268. //            $job->getCombiRideChild()->setCombiRideParent(null);
  1269. //        }
  1270. //        $job->setCombiRideParent(null);
  1271.         $job->setCombiAssignmentState(Job::CAS_MANUAL);
  1272.         $em->flush();
  1273.         $this->addFlash('info','Zuordnung wurde entfernt. Automatik deaktiviert.');
  1274.         return $redir;
  1275.     }
  1277.     public function getPossibleCombiOptionsAction(Request $request, $jobId)
  1278.     {
  1279.         $this->init();
  1280.         $this->ensureUserHasRole(Role::ACCOUNTING_EDIT);
  1281.         $redir = $this->redirectToRoute('acc-jobs-edit',['id'=>$jobId]);
  1282.         /** @var EntityManagerInterface $em */
  1283.         $em = $this->managerRegistry->getManager();
  1284.         /** @var JobRepository $repo */
  1285.         $repo = $this->managerRegistry->getRepository(Job::class);
  1286.         /** @var Job $job */
  1287.         $job = $repo->findOneBy(['id'=>$jobId]);
  1288.         $possible = $repo->findPossiblyRelatedRidesForMemberAsArray($job);
  1289.         return $this->getJsonDataResponse($request,true,$possible);
  1290.     }
  1292.     protected static function removeRelation(Job $job)
  1293.     {
  1294.         if ($job->getCombiRideChild()!==null)
  1295.         {
  1296.             $job->getCombiRideChild()->setCombiRideParent(null);
  1297.         }
  1298.         $job->setCombiRideParent(null);
  1299.     }
  1301.     public function setManualCombiAction(Request $request, $jobId, $assignJobId)
  1302.     {
  1303.         $this->init();
  1304.         $this->ensureUserHasRole(Role::ACCOUNTING_EDIT);
  1305.         $redir = $this->redirectToRoute('acc-jobs-edit',['id'=>$jobId]);
  1306.         /** @var EntityManagerInterface $em */
  1307.         $em = $this->managerRegistry->getManager();
  1308.         /** @var JobRepository $repo */
  1309.         $repo = $this->managerRegistry->getRepository(Job::class);
  1310.         /** @var Job $job */
  1311.         $job = $repo->findOneBy(['id'=>$jobId]);
  1312.         /** @var Job $assignJob */
  1313.         $assignJob = $repo->findOneBy(['id'=>$assignJobId]);
  1314.         if ($job->isApprovedByAccounting() || $assignJob->isApprovedByAccounting())
  1315.         {
  1316.             $this->addFlash('warning','Fahrtdaten wurden bereits durch die Abrechnung bestätigt. Aktualisierung nicht möglich.');
  1317.             return $redir;
  1318.         }
  1319.         if ($jobId === $assignJobId)
  1320.         {
  1321.             $this->addFlash('warning','Zuordnung zweier gleicher Fahrten nicht möglich.');
  1322.             return $redir;
  1323.         }
  1324.         // remove assignment
  1325.         self::removeRelation($job);
  1326.         self::removeRelation($assignJob);
  1327.         // set assignment
  1328.         if ($assignJob->getOrderTime() < $job->getOrderTime())
  1329.         {
  1330.             $job->setCombiRideParent($assignJob);
  1331.         }
  1332.         else
  1333.         {
  1334.             $assignJob->setCombiRideParent($job);
  1335.         }
  1336.         $job->setCombiAssignmentState(Job::CAS_MANUAL);
  1337.         $assignJob->setCombiAssignmentState(Job::CAS_MANUAL);
  1338.         $em->flush();
  1339.         $this->addFlash('info','Zuordnung wurde gespeichert. Automatik deaktiviert.');
  1340.         return $redir;
  1341.     }
  1343. }