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.         if($this->token == null )
  221.             $this->token = $this->Connect2CRM();
  223.         if( $this->sugarCrm->isConnected() !== false ){
  225.             if( !strpos($module,'_') )
  226.                 $entity = ucfirst(strtolower($module));
  227.             else $entity = $module;
  228.             $data =null;
  230.             if($filters != null){
  231.                 $this->sugarCrm->setObjUrl("$entity/$id/link/$children_field");
  232.                 $where = [];
  233.                 if($filters != null ) {
  234.                     $afilters = explode(",", $filters);
  235.                     for ($i = 0; $i < sizeof($afilters); $i++) {
  236.                         $itm = explode("=", $afilters[$i]);
  237.                         if($itm[0] != "q"){
  238.                             if(str_contains($itm[1],'$')){
  239.                                 $itmm = explode(":", $itm[1]);
  240.                                 $where[$itm[0]][$itmm[0]] = $itmm[1];
  241.                             }else {
  242.                                 $where[$itm[0]] = $itm[1];
  243.                             }
  244.                         }
  245.                     }
  246.                 }
  247.                 $where["deleted"] = false;
  249.                 $fields = $this->getRelatedField($fields);
  251.                 $data = $this->sugarCrm->filter("$entity/$id/link/$children_field",$where,$max,$offset,$fields, "date_modified:DESC");
  253.             }else{
  254.                 $this->sugarCrm->setObjUrl($entity);
  255.                 $data = $this->sugarCrm->get($entity,$id."/link/$children_field");
  256.             }
  261.             if($data) {
  262.                 if (sizeof($data->records) > 0)
  263.                     return $this->getJsonResponse($data->records);
  264.                 else
  265.                     return $this->getJsonResponse($data);
  266.             }
  267.             return $this->getJsonResponse([]);
  268.         }
  269.     }
  271.     #[Route("/{module}/id/{id}/{fields}", name:"module_by_id", methods:["GET"])]
  272.     public function getModuleById($module,$id,$fields){
  273.         if($this->token == null )
  274.             $this->token = $this->Connect2CRM();
  276.         if( $this->sugarCrm->isConnected() !== false ){
  278.             if( !strpos($module,'_') )
  279.                 $entity = ucfirst(strtolower($module));
  280.             else $entity = strtolower($module);
  282.             $this->sugarCrm->setObjUrl($entity);
  284.             $where["deleted"] = false;
  285.             $where["id"] = $id;
  286.             $data = $this->sugarCrm->filter($entity,$where,1,0,$fields);
  288.             //$data = $this->sugarCrm->get($entity,$id);
  290.             if($data) {
  291.                 if (sizeof($data->records) > 0)
  292.                     return $this->getJsonResponse($data->records);
  293.                 else
  294.                     return $this->getJsonResponse($data);
  295.             }
  296.             return $this->getJsonResponse([]);
  297.         }
  299.     }
  301.     public function getRelatedField($fields){
  302.         $fieldsArray = explode(",", $fields);
  303.         foreach ($fieldsArray as $index => $item) {
  304.             if( is_numeric(substr($item, -1)) && substr($item, -2) == "_".substr($item, -1)  ){
  305.                 $fieldsArray[$index] = '{"name" : "'.$item.'", "fields" : ["id","name"]}';
  306.             }
  307.         }
  308.         return implode(",",$fieldsArray);
  309.     }
  311. #[Route("/{module}/{filters}/{max}/{offset}/{fields}", name:"module_filtered_by_arg", methods:["GET"])]
  312. public function getModule($module,$filters, $max=1, $offset=0, $fields=null){
  313.     if($this->token == null )
  314.         $this->token = $this->Connect2CRM();
  316.     if( $this->sugarCrm->isConnected() !== false ){
  318.         if( !strpos($module,'_') )
  319.             $entity = ucfirst(strtolower($module));
  320.         else $entity = $module;
  322.         $this->sugarCrm->setObjUrl($entity);
  323.         $where = [];
  324.         $afilters = [];
  325.         $q = null;
  326.         if($filters != null ) {
  327.             $afilters = explode(",", $filters);
  329.             for ($i = 0; $i < sizeof($afilters); $i++) {
  330.                 $itm = explode("=", $afilters[$i]);
  331.                 if($itm[0] == "q"){
  332.                     $q = $itm[1];
  333.                 }else{
  334.                     if(str_contains($itm[1],'$')){
  335.                         $itmm = explode(":", $itm[1]);
  336.                         $where[$itm[0]][$itmm[0]] = $itmm[1];
  337.                     }else {
  338.                         $where[$itm[0]] = $itm[1];
  339.                     }
  340.                 }
  342.             }
  343.         }
  345.         $fields = $this->getRelatedField($fields);
  347.         $where["deleted"] = false;
  348.         if($q != null ) $where = null;
  350.         $data = $this->sugarCrm->filter($entity,$where,$max,$offset,$fields,null,null,null,$q);
  352.         if($data){
  353.             if( sizeof($data->records) > 0 )
  354.                 return $this->getJsonResponse($data->records);
  355.             else
  356.                 return $this->getJsonResponse($data);
  357.         }
  358.         return $this->getJsonResponse([]);
  359.     }
  361. }
  363. }