src/Controller/SugarCrmController.php line 219

  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);
  236.                     foreach ($afilters as $afilterItem ){
  237.                         if (str_contains($afilterItem, '||')) {
  238.                             $afieldsFiltered = explode("||", $afilterItem);
  239.                             foreach ($afieldsFiltered as $afieldItem){
  240.                                 $aItem = explode("=", $afieldItem);
  241.                                 if (str_contains($aItem[1], '$')) {
  242.                                     $aSubItem = explode(":", $aItem[1]);
  243.                                     $where['$or'][] = [ $aItem[0] =>[ $aSubItem[0]=> $aSubItem[1] ] ];
  244.                                 }else{
  245.                                     $where['$or'][] = [ $aItem[0] => $aItem[1] ];
  246.                                 }
  248.                             }
  249.                         }else{
  250.                             $aItem = explode("=", $afilterItem);
  251.                             if (str_contains($aItem[1], '$')) {
  252.                                 $aSubItem = explode(":", $aItem[1]);
  253.                                 $where[$aItem[0]][$aSubItem[0]] = $aSubItem[1];
  254.                             }else{
  255.                                 $where[$aItem[0]] = $aItem[1];
  256.                             }
  257.                         }
  259.                     }
  261. /*
  262.                     for ($i = 0; $i < sizeof($afilters); $i++) {
  263.                         $itm = explode("=", $afilters[$i]);
  264.                         if($itm[0] != "q"){
  265.                             if(str_contains($itm[1],'$')){
  266.                                 $itmm = explode(":", $itm[1]);
  267.                                 $where[$itm[0]][$itmm[0]] = $itmm[1];
  268.                             }else {
  269.                                 $where[$itm[0]] = $itm[1];
  270.                             }
  271.                         }
  272.                     } */
  273.                 }
  274.                 $where["deleted"] = false;
  276.                 $fields = $this->getRelatedField($fields);
  278.                 $data = $this->sugarCrm->filter("$entity/$id/link/$children_field",$where,$max,$offset,$fields, "date_modified:DESC");
  280.             }else{
  281.                 $this->sugarCrm->setObjUrl($entity);
  282.                 $data = $this->sugarCrm->get($entity,$id."/link/$children_field");
  283.             }
  288.             if($data) {
  289.                 if (sizeof($data->records) > 0)
  290.                     return $this->getJsonResponse($data->records);
  291.                 else
  292.                     return $this->getJsonResponse($data);
  293.             }
  294.             return $this->getJsonResponse([]);
  295.         }
  296.     }
  298.     #[Route("/{module}/id/{id}/{fields}", name:"module_by_id", methods:["GET"])]
  299.     public function getModuleById($module,$id,$fields){
  300.         if($this->token == null )
  301.             $this->token = $this->Connect2CRM();
  303.         if( $this->sugarCrm->isConnected() !== false ){
  305.             if( !strpos($module,'_') )
  306.                 $entity = ucfirst(strtolower($module));
  307.             else $entity = strtolower($module);
  309.             $this->sugarCrm->setObjUrl($entity);
  311.             $where["deleted"] = false;
  312.             $where["id"] = $id;
  313.             $data = $this->sugarCrm->filter($entity,$where,1,0,$fields);
  315.             //$data = $this->sugarCrm->get($entity,$id);
  317.             if($data) {
  318.                 if (sizeof($data->records) > 0)
  319.                     return $this->getJsonResponse($data->records);
  320.                 else
  321.                     return $this->getJsonResponse($data);
  322.             }
  323.             return $this->getJsonResponse([]);
  324.         }
  326.     }
  328.     public function getRelatedField($fields){
  329.         $fieldsArray = explode(",", $fields);
  330.         foreach ($fieldsArray as $index => $item) {
  331.             if( is_numeric(substr($item, -1)) && substr($item, -2) == "_".substr($item, -1)  ){
  332.                 $fieldsArray[$index] = '{"name" : "'.$item.'", "fields" : ["id","name"]}';
  333.             }
  334.         }
  335.         return implode(",",$fieldsArray);
  336.     }
  338. #[Route("/{module}/{filters}/{max}/{offset}/{fields}", name:"module_filtered_by_arg", methods:["GET"])]
  339. public function getModule($module,$filters, $max=1, $offset=0, $fields=null){
  340.     if($this->token == null )
  341.         $this->token = $this->Connect2CRM();
  343.     if( $this->sugarCrm->isConnected() !== false ){
  345.         if( !strpos($module,'_') )
  346.             $entity = ucfirst(strtolower($module));
  347.         else $entity = $module;
  349.         $this->sugarCrm->setObjUrl($entity);
  350.         $where = [];
  351.         $afilters = [];
  352.         $q = null;
  353.         if($filters != null ) {
  354.             $afilters = explode(",", $filters);
  356.             for ($i = 0; $i < sizeof($afilters); $i++) {
  357.                 $itm = explode("=", $afilters[$i]);
  358.                 if($itm[0] == "q"){
  359.                     $q = $itm[1];
  360.                 }else{
  361.                     if(str_contains($itm[1],'$')){
  362.                         $itmm = explode(":", $itm[1]);
  363.                         $where[$itm[0]][$itmm[0]] = $itmm[1];
  364.                     }else {
  365.                         $where[$itm[0]] = $itm[1];
  366.                     }
  367.                 }
  369.             }
  370.         }
  372.         $fields = $this->getRelatedField($fields);
  374.         $where["deleted"] = false;
  375.         if($q != null ) $where = null;
  377.         $data = $this->sugarCrm->filter($entity,$where,$max,$offset,$fields,null,null,null,$q);
  379.         if($data){
  380.             if( sizeof($data->records) > 0 )
  381.                 return $this->getJsonResponse($data->records);
  382.             else
  383.                 return $this->getJsonResponse($data);
  384.         }
  385.         return $this->getJsonResponse([]);
  386.     }
  388. }
  390. }