src/Controller/SugarCrmController.php line 312

  1. <?php
  2. namespace App\Controller;
  3. use App\BussinesLogic\sugarBussinessLogic;
  4. use App\BussinesLogic\AzureTokenManager;
  5. use App\Trait\ControllerSugarTrait;
  6. use Google\Auth\Credentials\ServiceAccountJwtAccessCredentials;
  7. use Google\Auth\HttpHandler\HttpClientCache;
  8. use App\BussinesLogic\GoogleBL;
  9. use Google\Cloud\Functions\V1\CloudFunctionsServiceClient;
  10. use App\Entity\Report;
  11. use App\Entity\ReportField;
  12. use App\Entity\ReportPeriod;
  13. use App\Entity\User;
  14. use App\Trait\ControllerTrait;
  15. use GuzzleHttp\Client;
  16. use GuzzleHttp\Exception\RequestException;
  17. use OpenApi\Annotations as OA;
  18. use Nelmio\ApiDocBundle\Annotation\Model;
  19. use Nelmio\ApiDocBundle\Annotation\Security;
  20. use Doctrine\Persistence\ManagerRegistry;
  21. use Symfony\Component\HttpFoundation\JsonResponse;
  22. use Symfony\Component\HttpFoundation\Request;
  23. use Symfony\Component\HttpFoundation\Response;
  24. use Symfony\Component\Routing\Annotation\Route;
  25. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  26. use Google\Auth\Credentials\ServiceAccountCredentials;
  27. use Google\Auth\Middleware\AuthTokenMiddleware;
  28. use Google\Cloud;
  29. use Google\Api;
  30. use Google\Api\Authentication;
  31. use Google\ApiCore\ClientStream;
  32. use GuzzleHttp\HandlerStack;
  34. /**
  35.  * Controller for CRUD operations on User entities
  36.  */
  37. #[AsController]
  38. #[Route('/crm', name: 'crm_search')]
  39. class SugarCrmController extends AbstractController {
  41.     use ControllerTrait;
  42.     use ControllerSugarTrait;
  44.     #[Route("/azure_auth", name:"azure_auth", methods:["GET"])]
  45.     public function azureAuth(){
  46.         $tenantId = 'b004d87e-aee6-4103-b252-fecb81f32160';
  47.         $clientID = 'd6f8dc47-7b5c-4c76-9f49-77b4f1b8f601';
  48.         $apiLoginMs = 'https://login.microsoftonline.com/';
  49.         $tokenEndPoint = '/oauth2/v2.0/token';
  50.         $tokenScope = 'https://graph.microsoft.com/.default';
  51.         $privateKeyPath = $this->getParameter('azure_key_path');
  52.         $base64EncodedThumbprint = 'nUS/8UKloit7g09Jho230koiavk';
  54.         // initialize the class
  55.         $tokenManager = new AzureTokenManager($tenantId, $clientID, $apiLoginMs, $tokenEndPoint, $tokenScope, $privateKeyPath, $base64EncodedThumbprint);
  56. //$tokenManager = new TokenManager($_ENV["TENANT_ID"], $_ENV["CLIENT_ID"], $_ENV["API_LOGIN_MS"], $_ENV["TOKENENDPOINT"], $_ENV["TOKENSCOPE"], $_ENV["PRIVATEKEYPATH"], $_ENV["BASE64THUMBPRINT"]);
  58. //just call getToken and it will return the json
  60.         $token = $tokenManager->getToken();
  62.         return $this->getJsonResponse($token);
  64.     }
  66.     #[Route("/account/{piva}", name:"account_filtered_by_piva", methods:["GET"])]
  67.     public function getAccountByPiva(){
  69.         if($this->token == null )
  70.             $this->token = $this->Connect2CRM();
  71.         
  72.         if( $this->sugarCrm->isConnected() !== false ){
  73.             $this->sugarCrm->setObjUrl("Accounts");
  74.             $data = $this->sugarCrm->filter("Accounts",["partitaiva_c"=>$this->request->get("piva"), "deleted"=> false],1,0);
  76.             if($data){
  77.                 if( sizeof($data->records) > 0 )
  78.                     return $this->getJsonResponse($data->records);
  79.                 else
  80.                     return $this->getJsonResponse($data);
  81.             }
  82.             return $this->getJsonResponse([]);
  83.         }
  84.     }
  85. /*
  86.  * export report
  87.  /Reports/:id/[json,pdf,csv,base64]
  88.  *
  89.  /Reports/:id/record_count?group_filters[0][industry]=Engineering
  90.  *
  91.  /Reports/:id/chart
  92.  *
  93.  /Reports/:id/records?group_filters[0][industry]=Engineering&use_saved_filters=true&offset=0&max_num=20
  94.  */
  95.     #[Route("/chart/{id}", name: 'crm_report_chart', methods: ['GET'])]
  96.     public function getChart($id){
  97.        return $this->getReport($id, null, 'chart');
  98.     }
  100.     #[Route("/report/{id}/export/{export}", name: 'crm_report_export', methods: ['GET'])]
  101.     public function exportReport($id, $export){
  102.         return $this->getReport($id, null, null, $export);
  103.     }
  105.     #[Route("/report/{id}/count/{filters}", name: 'crm_report_total', methods: ['GET'])]
  106.     public function getTotalReport($id, $filters){
  107.         return $this->getReport($id, $filters);
  108.     }
  110.     public function getReport($id, $filters=null, $type=null, $export=null ){
  111.         if($this->token == null )
  112.             $this->token = $this->Connect2CRM();
  113.         if( $this->sugarCrm->isConnected() !== false ){
  114.             $entity = "Reports";
  115.             $this->sugarCrm->setObjUrl($entity);
  116.             if($export){
  117.                 $id = $id . "/$export";
  118.             }
  119.             if($type){
  120.                 $id = $id . "/$type";
  121.             }
  122.             $afilters = null;
  124.             if(!$type and !$export and $filters){
  125.                 $id = $id."/record_count";
  127.                 $afilters = [];
  129.                 if($filters != null ) {
  130.                     $afilters = explode(",", $filters);
  132.                     for ($i = 0; $i < sizeof($afilters); $i++) {
  133.                         $itm = explode("=", $afilters[$i]);
  134.                         $afilters[$i] = [$itm[0] => $itm[1]];
  135.                     }
  136.                 }
  138.             }
  140.             $data = $this->sugarCrm->report($entity."/$id", $afilters);
  141.             if($export !=null or $filters != null or ($type != null and ($type !="pdf" or $type != "html") ) ){
  142.                 if($data)
  143.                     return $this->getJsonResponse($data);
  144.             } else
  145.                 return new Response($data);
  148.             return $this->getJsonResponse([]);
  149.         }
  150.     }
  152. /*public function postModule(){
  153. $body = [
  154.     "name" => "",
  155.     "fiscal_code_c"=>"",
  156.     "description" => "",
  157.     "first_name"=> "",
  158.     "last_name"=> "",
  159.     "full_name"=> "",
  160.     "phone_mobile"=> "",
  161.     "phone_work"=> "",
  162.     "refered_by"=> "",
  163.     "lead_source"=> "bc_origination",
  164.     "contatto_di_orig_c"=> "",
  165.     "status"=> "New",
  166. ];*/
  168. /* Get Leads related records by link
  169. -  /Leads/193bb028-1874-11ef-9c3e-061a8a1a6f52/link/leads_dsreq_products_1
  172. }
  173. */
  175.     #[Route("/{module}/update/{id}", name:"module_update", methods:["PUT"])]
  176.     public function putModule($module,$id){
  178.         $body = $this->request->toArray();
  180.         $result = null;
  181.         if($this->token == null )
  182.             $this->token = $this->Connect2CRM();
  184.         if( $this->sugarCrm->isConnected() !== false ){
  185.             if( !strpos($module,'_') )
  186.                 $entity = ucfirst(strtolower($module));
  187.             else $entity = $module;
  189.             $result = $this->sugarCrm->put( $entity, $body, $id);
  190.         }
  191.         return $this->getJsonResponse($result);
  192.     }
  194.     #[Route("/{module}/add", name:"module_add", methods:["POST"])]
  195.     public function postModule($module){
  197.         $body = $this->request->toArray();
  199.         $result = null;
  200.         if($this->token == null )
  201.             $this->token = $this->Connect2CRM();
  203.         if( $this->sugarCrm->isConnected() !== false ){
  204.             if( !strpos($module,'_') )
  205.                 $entity = ucfirst(strtolower($module));
  206.             else $entity = $module;
  208.             $result = $this->sugarCrm->post( $entity, $body);
  209.         }
  210.         return $this->getJsonResponse($result);
  211.     }
  213.     #[Route("/{module}/link/{id}/{children_field}", name:"childrens_no_filter_by_id", methods:["GET"])]
  214.     public function getChildrensNoFilter($module,$id, $children_field){
  215.         return $this->getChildrensModuleById($module,$id, $children_field, null, null,50,0);
  216.     }
  218.     #[Route("/{module}/link/{id}/{children_field}/{filters}/{fields}/{max}/{offset}", name:"childrens_with_filter_by_id", methods:["GET"])]
  219.     public function getChildrensModuleById($module,$id, $children_field,$filters=null, $fields=null, $max=1, $offset=0){
  220.         $id2 = null;
  221.         if($module == 'dsreq_products' and $id == '714921de-16d8-11f0-888f-029d48ef8892') {
  222.             $id2 = '5695f4ac-16d8-11f0-9273-06dcb2a01ede';
  223.         }
  225.         if($this->token == null )
  226.             $this->token = $this->Connect2CRM();
  228.         if( $this->sugarCrm->isConnected() !== false ){
  230.             if( !strpos($module,'_') )
  231.                 $entity = ucfirst(strtolower($module));
  232.             else $entity = $module;
  233.             $data =null;
  235.             if($filters != null){
  236.                 $this->sugarCrm->setObjUrl("$entity/$id/link/$children_field");
  237.                 $where = [];
  238.                 if($filters != null ) {
  239.                     $afilters = explode(",", $filters);
  241.                     foreach ($afilters as $afilterItem ){
  242.                         if (str_contains($afilterItem, '||')) {
  243.                             $afieldsFiltered = explode("||", $afilterItem);
  244.                             foreach ($afieldsFiltered as $afieldItem){
  245.                                 $aItem = explode("=", $afieldItem);
  246.                                 if (str_contains($aItem[1], '$')) {
  247.                                     $aSubItem = explode(":", $aItem[1]);
  248.                                     $where['$or'][] = [ $aItem[0] =>[ $aSubItem[0]=> $aSubItem[1] ] ];
  249.                                 }else{
  250.                                     $where['$or'][] = [ $aItem[0] => $aItem[1] ];
  251.                                 }
  253.                             }
  254.                         }else{
  255.                             $aItem = explode("=", $afilterItem);
  256.                             if (str_contains($aItem[1], '$')) {
  257.                                 $aSubItem = explode(":", $aItem[1]);
  258.                                 $where[$aItem[0]][$aSubItem[0]] = $aSubItem[1];
  259.                             }else{
  260.                                 $where[$aItem[0]] = $aItem[1];
  261.                             }
  262.                         }
  264.                     }
  266. /*
  267.                     for ($i = 0; $i < sizeof($afilters); $i++) {
  268.                         $itm = explode("=", $afilters[$i]);
  269.                         if($itm[0] != "q"){
  270.                             if(str_contains($itm[1],'$')){
  271.                                 $itmm = explode(":", $itm[1]);
  272.                                 $where[$itm[0]][$itmm[0]] = $itmm[1];
  273.                             }else {
  274.                                 $where[$itm[0]] = $itm[1];
  275.                             }
  276.                         }
  277.                     } */
  278.                 }
  279.                 $where["deleted"] = false;
  281.                 $fields = $this->getRelatedField($fields);
  283.                 $data = $this->sugarCrm->filter("$entity/$id/link/$children_field",$where,$max,$offset,$fields, "date_modified:DESC");
  285.             }else{
  286.                 $this->sugarCrm->setObjUrl($entity);
  287.                 $data = $this->sugarCrm->get($entity,$id."/link/$children_field");
  288.             }
  291.             if($id2 != null ){
  292.                 $this->sugarCrm->setObjUrl("$entity/$id2/link/$children_field");
  293.                 $data2 = $this->sugarCrm->filter("$entity/$id2/link/$children_field",$where,$max,$offset,$fields, "date_modified:DESC");
  294.                 if (sizeof($data->records) > 0 and sizeof($data2->records) > 0) {
  295.                     $dataResult = array_merge($data->records, $data2->records);
  296.                     return $this->getJsonResponse($dataResult);
  297.                 }elseif (sizeof($data2->records) > 0) {
  298.                     return $this->getJsonResponse($data2->records);
  299.                 }
  300.             }
  302.             if($data) {
  303.                 if (sizeof($data->records) > 0)
  304.                     return $this->getJsonResponse($data->records);
  305.                 else
  306.                     return $this->getJsonResponse($data);
  307.             }
  308.             return $this->getJsonResponse([]);
  309.         }
  310.     }
  312.     #[Route("/{module}/id/{id}/{fields}", name:"module_by_id", methods:["GET"])]
  313.     public function getModuleById($module,$id,$fields){
  314.         if($this->token == null )
  315.             $this->token = $this->Connect2CRM();
  317.         if( $this->sugarCrm->isConnected() !== false ){
  319.             if( !strpos($module,'_') )
  320.                 $entity = ucfirst(strtolower($module));
  321.             else $entity = strtolower($module);
  323.             $this->sugarCrm->setObjUrl($entity);
  325.             $where["deleted"] = false;
  326.             $where["id"] = $id;
  327.             $data = $this->sugarCrm->filter($entity,$where,1,0,$fields);
  329.             //$data = $this->sugarCrm->get($entity,$id);
  331.             if($data) {
  332.                 if (sizeof($data->records) > 0)
  333.                     return $this->getJsonResponse($data->records);
  334.                 else
  335.                     return $this->getJsonResponse($data);
  336.             }
  337.             return $this->getJsonResponse([]);
  338.         }
  340.     }
  342.     public function getRelatedField($fields){
  343.         $fieldsArray = explode(",", $fields);
  344.         foreach ($fieldsArray as $index => $item) {
  345.             if( is_numeric(substr($item, -1)) && substr($item, -2) == "_".substr($item, -1)  ){
  346.                 $fieldsArray[$index] = '{"name" : "'.$item.'", "fields" : ["id","name"]}';
  347.             }
  348.         }
  349.         return implode(",",$fieldsArray);
  350.     }
  352. #[Route("/{module}/{filters}/{max}/{offset}/{fields}", name:"module_filtered_by_arg", methods:["GET"])]
  353. public function getModule($module,$filters, $max=1, $offset=0, $fields=null){
  354.     if($this->token == null )
  355.         $this->token = $this->Connect2CRM();
  357.     if( $this->sugarCrm->isConnected() !== false ){
  359.         if( !strpos($module,'_') )
  360.             $entity = ucfirst(strtolower($module));
  361.         else $entity = $module;
  363.         $this->sugarCrm->setObjUrl($entity);
  364.         $where = [];
  365.         $afilters = [];
  366.         $q = null;
  367.         if($filters != null ) {
  368.             $afilters = explode(",", $filters);
  370.             for ($i = 0; $i < sizeof($afilters); $i++) {
  371.                 $itm = explode("=", $afilters[$i]);
  372.                 if($itm[0] == "q"){
  373.                     $q = $itm[1];
  374.                 }else{
  375.                     if(str_contains($itm[1],'$')){
  376.                         $itmm = explode(":", $itm[1]);
  377.                         $where[$itm[0]][$itmm[0]] = $itmm[1];
  378.                     }else {
  379.                         $where[$itm[0]] = $itm[1];
  380.                     }
  381.                 }
  383.             }
  384.         }
  386.         $fields = $this->getRelatedField($fields);
  388.         $where["deleted"] = false;
  389.         if($q != null ) $where = null;
  391.         $data = $this->sugarCrm->filter($entity,$where,$max,$offset,$fields,null,null,null,$q);
  393.         if($data){
  394.             if( sizeof($data->records) > 0 )
  395.                 return $this->getJsonResponse($data->records);
  396.             else
  397.                 return $this->getJsonResponse($data);
  398.         }
  399.         return $this->getJsonResponse([]);
  400.     }
  402. }
  404. }