src/ApplicationBundle/Modules/Inventory/Controller/CentralProductControlController.php line 105

Open in your IDE?
  1. <?php
  3. namespace ApplicationBundle\Modules\Inventory\Controller;
  5. use ApplicationBundle\Controller\GenericController;
  6. use ApplicationBundle\Interfaces\SessionCheckInterface;
  7. use ApplicationBundle\Modules\Authentication\Constants\UserConstants;
  8. use ApplicationBundle\Modules\Inventory\Service\CentralProductControlService;
  9. use Symfony\Component\HttpFoundation\JsonResponse;
  10. use Symfony\Component\HttpFoundation\Request;
  12. /**
  13.  * Central Product Control — the reconciliation hub UI on the _CENTRAL_ server (also reachable from the
  14.  * super-admin dashboard). P1: list every global product, edit attributes, and push edits down to the ERPs.
  15.  *
  16.  * The list renders anywhere (queries inv_products), but all MUTATIONS are gated to _CENTRAL_.
  17.  * Design: CENTRAL_PRODUCT_CONTROL_PLAN.md.
  18.  */
  19. class CentralProductControlController extends GenericController implements SessionCheckInterface
  20. {
  21.     private function svc(): CentralProductControlService
  22.     {
  23.         return new CentralProductControlService($this->getDoctrine()->getManager());
  24.     }
  26.     private function isCentral(): bool
  27.     {
  28.         $sys = $this->container->hasParameter('system_type') ? $this->container->getParameter('system_type') : '_ERP_';
  29.         return $sys === '_CENTRAL_';
  30.     }
  32.     public function listAction(Request $request)
  33.     {
  34.         $search = trim((string) $request->query->get('q', ''));
  35.         $products = [];
  36.         try {
  37.             $products = $this->svc()->listProducts($search, 150, 0);
  38.         } catch (\Throwable $e) { /* lean/missing schema → empty list */ }
  40.         return $this->render('@Inventory/pages/central/central_product_control.html.twig', [
  41.             'page_title'     => 'Central Product Control',
  42.             'products'       => $products,
  43.             'search'         => $search,
  44.             'is_central'     => $this->isCentral(),
  45.             'sidebar_partial' => '@Inventory/pages/central/_central_catalog_sidebar.html.twig',
  46.             'cp_active'      => 'products',
  47.         ]);
  48.     }
  50.     /** Save edited attributes to the central product (name/description/alias/specifications). */
  51.     public function saveAction(Request $request): JsonResponse
  52.     {
  53.         if (!$this->isCentral()) {
  54.             return new JsonResponse(['success' => false, 'message' => 'Editing the global catalog is only available on the central server.'], 403);
  55.         }
  56.         $globalId = (int) $request->request->get('globalId', 0);
  57.         if ($globalId <= 0) {
  58.             return new JsonResponse(['success' => false, 'message' => 'globalId is required.'], 400);
  59.         }
  60.         $fields = [];
  61.         foreach (['name', 'description', 'alias', 'specifications'] as $f) {
  62.             if ($request->request->has($f)) {
  63.                 $fields[$f] = $request->request->get($f);
  64.             }
  65.         }
  66.         try {
  67.             $written = $this->svc()->updateProductAttributes($globalId, $fields);
  68.         } catch (\Throwable $e) {
  69.             return new JsonResponse(['success' => false, 'message' => $e->getMessage()], 500);
  70.         }
  71.         return new JsonResponse(['success' => true, 'updated' => $written]);
  72.     }
  74.     /** Return a single product's editable attributes (for the edit modal). */
  75.     public function getAction(Request $request, $globalId): JsonResponse
  76.     {
  77.         $p = $this->svc()->getProductByGlobalId((int) $globalId);
  78.         if (!$p) {
  79.             return new JsonResponse(['success' => false, 'message' => 'Product not found.'], 404);
  80.         }
  81.         return new JsonResponse(['success' => true, 'product' => $p]);
  82.     }
  84.     /** JSON product search (for the in-modal "find & merge duplicates" box). */
  85.     public function searchAction(Request $request): JsonResponse
  86.     {
  87.         $q = trim((string) $request->query->get('q', ''));
  88.         $items = [];
  89.         if ($q !== '') {
  90.             try {
  91.                 foreach ($this->svc()->listProducts($q, 25, 0) as $p) {
  92.                     $items[] = [
  93.                         'globalId' => (int) $p['globalId'],
  94.                         'name'     => $p['name'],
  95.                         'modelNo'  => $p['modelNo'] ?? '',
  96.                         'merged'   => (int) ($p['merged'] ?? 0),
  97.                     ];
  98.                 }
  99.             } catch (\Throwable $e) { /* lean schema → empty */ }
  100.         }
  101.         return new JsonResponse(['success' => true, 'items' => $items]);
  102.     }
  104.     /** Duplicate-cluster detection page → the merge wizard. */
  105.     public function duplicatesAction(Request $request)
  106.     {
  107.         $clusters = [];
  108.         try {
  109.             $clusters = $this->svc()->findDuplicateClusters(60);
  110.         } catch (\Throwable $e) { /* lean schema → none */ }
  112.         return $this->render('@Inventory/pages/central/central_product_duplicates.html.twig', [
  113.             'page_title'     => 'Duplicate Products',
  114.             'clusters'       => $clusters,
  115.             'is_central'     => $this->isCentral(),
  116.             'sidebar_partial' => '@Inventory/pages/central/_central_catalog_sidebar.html.twig',
  117.             'cp_active'      => 'duplicates',
  118.         ]);
  119.     }
  121.     /**
  122.      * Merge duplicate products into a canonical one, then push the bulk global-ID remap to every ERP.
  123.      * Never deletes — duplicates become aliases of the canonical.
  124.      */
  125.     public function mergeAction(Request $request): JsonResponse
  126.     {
  127.         if (!$this->isCentral()) {
  128.             return new JsonResponse(['success' => false, 'message' => 'Merge is only available on the central server.'], 403);
  129.         }
  130.         $loginId   = (int) $request->getSession()->get(UserConstants::USER_LOGIN_ID);
  131.         $canonical = (int) $request->request->get('canonicalGlobalId', 0);
  132.         $dups      = $request->request->get('dupGlobalIds', []);
  133.         if (!is_array($dups)) {
  134.             $dups = explode(',', (string) $dups);
  135.         }
  136.         $dups = array_values(array_filter(array_map('intval', $dups)));
  137.         if ($canonical <= 0 || empty($dups)) {
  138.             return new JsonResponse(['success' => false, 'message' => 'canonicalGlobalId and dupGlobalIds are required.'], 400);
  139.         }
  141.         $svc = $this->svc();
  142.         try {
  143.             // Optional: caller-supplied winning field values for the canonical (the conflict picker, P3).
  144.             $fields = $request->request->get('canonicalFields', []);
  145.             if (is_array($fields) && !empty($fields)) {
  146.                 $svc->updateProductAttributes($canonical, $fields);
  147.             }
  148.             $map = $svc->recordMerge($canonical, $dups, $loginId, 'central merge');
  149.         } catch (\Throwable $e) {
  150.             return new JsonResponse(['success' => false, 'message' => $e->getMessage()], 500);
  151.         }
  153.         $push = $this->pushRemapToErps($map);
  154.         return new JsonResponse(['success' => true, 'canonical' => $canonical, 'remap' => $map, 'push' => $push]);
  155.     }
  157.     /** Bulk datasheet import + review queue page (P4). */
  158.     public function importFormAction(Request $request)
  159.     {
  160.         $queue = [];
  161.         try {
  162.             $queue = $this->svc()->importQueue('pending', 200);
  163.         } catch (\Throwable $e) { /* lean schema → empty */ }
  165.         return $this->render('@Inventory/pages/central/central_product_import.html.twig', [
  166.             'page_title'      => 'Bulk Datasheet Import',
  167.             'queue'           => $queue,
  168.             'is_central'      => $this->isCentral(),
  169.             'sidebar_partial' => '@Inventory/pages/central/_central_catalog_sidebar.html.twig',
  170.             'cp_active'       => 'import',
  171.         ]);
  172.     }
  174.     /** Parse a pasted blob of datasheets and stage them for review. */
  175.     public function importStageAction(Request $request): JsonResponse
  176.     {
  177.         if (!$this->isCentral()) {
  178.             return new JsonResponse(['success' => false, 'message' => 'Import runs on the central server.'], 403);
  179.         }
  180.         $blob = trim((string) $request->request->get('blob', ''));
  181.         if ($blob === '') {
  182.             return new JsonResponse(['success' => false, 'message' => 'Nothing to import.'], 400);
  183.         }
  184.         $loginId = (int) $request->getSession()->get(UserConstants::USER_LOGIN_ID);
  185.         try {
  186.             $res = $this->svc()->stageImportBatch($blob, $loginId);
  187.         } catch (\Throwable $e) {
  188.             return new JsonResponse(['success' => false, 'message' => $e->getMessage()], 500);
  189.         }
  190.         return new JsonResponse(array_merge(['success' => true], $res));
  191.     }
  193.     /** Apply one staged import row to its matched global product. */
  194.     public function importApplyAction(Request $request): JsonResponse
  195.     {
  196.         if (!$this->isCentral()) {
  197.             return new JsonResponse(['success' => false, 'message' => 'Import runs on the central server.'], 403);
  198.         }
  199.         $id = (int) $request->request->get('id', 0);
  200.         try {
  201.             $res = $this->svc()->applyImport($id);
  202.         } catch (\Throwable $e) {
  203.             return new JsonResponse(['success' => false, 'message' => $e->getMessage()], 400);
  204.         }
  205.         return new JsonResponse(array_merge(['success' => true], $res));
  206.     }
  208.     public function importRejectAction(Request $request): JsonResponse
  209.     {
  210.         if (!$this->isCentral()) {
  211.             return new JsonResponse(['success' => false, 'message' => 'Import runs on the central server.'], 403);
  212.         }
  213.         $id = (int) $request->request->get('id', 0);
  214.         try {
  215.             $this->svc()->rejectImport($id);
  216.         } catch (\Throwable $e) {
  217.             return new JsonResponse(['success' => false, 'message' => $e->getMessage()], 400);
  218.         }
  219.         return new JsonResponse(['success' => true]);
  220.     }
  222.     /** Merge + datasheet-import history (audit trail). */
  223.     public function auditAction(Request $request)
  224.     {
  225.         $merges = []; $imports = [];
  226.         try { $merges  = $this->svc()->mergeHistory(200); } catch (\Throwable $e) {}
  227.         try { $imports = $this->svc()->importHistory(200); } catch (\Throwable $e) {}
  229.         return $this->render('@Inventory/pages/central/central_product_audit.html.twig', [
  230.             'page_title'      => 'Catalog History',
  231.             'merges'          => $merges,
  232.             'imports'         => $imports,
  233.             'is_central'      => $this->isCentral(),
  234.             'sidebar_partial' => '@Inventory/pages/central/_central_catalog_sidebar.html.twig',
  235.             'cp_active'       => 'audit',
  236.         ]);
  237.     }
  239.     /** Bulk-push a {oldGid: newGid} remap to every active ERP server (shared-secret guarded). */
  240.     private function pushRemapToErps(array $map): array
  241.     {
  242.         $secret = $this->container->hasParameter('central_sync_secret') ? (string) $this->container->getParameter('central_sync_secret') : '';
  243.         try {
  244.             $cgManager = $this->getDoctrine()->getManager('company_group');
  245.         } catch (\Throwable $e) {
  246.             return ['pushed' => 0, 'results' => ['error' => $e->getMessage()]];
  247.         }
  248.         return CentralProductControlService::pushRemapMap($cgManager, $secret, $map);
  249.     }
  250. }