src/Controller/MessageController.php line 426

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use App\Entity\Clinic\Clinic;
  6. use App\Entity\Clinic\Person\ClinicUser;
  7. use App\Entity\Domain;
  8. use App\Entity\Website;
  9. use App\Entity\Person\Setting;
  10. use App\Entity\Media\Media;
  11. use App\Services\MediaManager;
  12. use App\Aws\SESManager;
  13. use App\Aws\S3Manager;
  14. use App\Entity\Meeting;
  15. use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
  16. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  17. use Symfony\Component\HttpFoundation\JsonResponse;
  18. use Symfony\Component\HttpFoundation\Request;
  19. use Symfony\Component\HttpFoundation\Response;
  20. use Symfony\Component\Routing\Annotation\Route;
  21. use Symfony\Component\HttpFoundation\RedirectResponse;
  22. use Psr\Log\LoggerInterface;
  23. use Symfony\Component\Routing\Generator\UrlGeneratorInterface;
  24. use App\Entity\Person\SuperClinicAdmin;
  25. use App\Entity\Person\User;
  26. use Symfony\Component\Serializer\SerializerInterface;
  27. use Symfony\Component\Filesystem\Filesystem;
  28. use Symfony\Component\HttpFoundation\File\UploadedFile;
  29. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  31. /**
  32.  * Class MessageController.
  33.  */
  34. class MessageController extends AbstractController
  35. {
  37.        /**
  38.      * @var SerializerInterface
  39.      */
  40.     private $serializer;
  41.     /**
  42.      * @var LoggerInterface
  43.      */
  44.     private $logger;
  45.     /**
  46.      * @var SESManager
  47.      */
  49.      
  50.     private $SESManager;
  51.     /**
  52.      * @var MediaManager
  53.      */
  54.     private $mediaManager;
  55.     /**
  56.      * @var Filesystem
  57.      */
  58.     private $filesystem;
  59.     /**
  60.      * @var string
  61.      */
  62.     /**
  63.      * @var S3Manager
  64.      */
  65.     private $s3Manager;
  67.     public function __construct(LoggerInterface $logger,SerializerInterface $serializer, SESManager $SESManager, MediaManager $mediaManager, S3Manager $s3Manager, Filesystem $filesystem)
  68.     {
  69.         $this->logger = $logger;
  70.         $this->SESManager = $SESManager;
  71.         $this->mediaManager = $mediaManager;
  72.         $this->filesystem = $filesystem;
  73.         $this->s3Manager = $s3Manager;
  74.         $this->serializer = $serializer;
  75.         @date_default_timezone_set(@$_COOKIE['tz']);
  76.     }
  77.     /**
  78.      * @Route("/admin/message/index", name="index")
  79.      */
  80.     public function index(Request $request): Response
  81.     {
  83.         // dd($_COOKIE);
  84.         $data = [];
  85.         $data['convId'] = (@$_GET['conv_id'] > 0) ? $_GET['conv_id'] : 0;
  86.         $data['user'] = $this->getUser();
  87.         $data['needLicense'] = false;
  88.         
  89.         if ($data['user']->getRole() != 'ROLE_CONSENTZ_ADMIN') {
  90.             
  91.             if ($data['user']->getClinic() != null) {
  92.                 $data['clinic'] = $this->getDoctrine()->getRepository(Clinic::class)
  93.                     ->find($data['user']->getClinic());
  94.             } else if ($data['user']->getOrganisation() && $data['user']->getOrganisation()->getClinics()->count() > 0 && $data['user']->getRole() == 'ROLE_SUPER_CLINIC_ADMIN') {
  95.                 $data['clinic'] = $data['user']->getOrganisation()->getClinics()->first();
  96.             }
  97.             if ($data['clinic']) {
  98.                 return new RedirectResponse($this->generateUrl('clinic_message_index', ['clinicId' => $data['clinic']->getId()]));
  99.             }
  100.             return $this->render('message/index.html.twig', $data);
  102.         }else{
  103.             if($request->get('clinic') > 0){
  104.    
  105.             $clinic = $this->getDoctrine()->getRepository(Clinic::class)
  106.                     ->find( $request->get('clinic'));
  107.                 $user =  $this->getDoctrine()->getRepository(ClinicUser::class)->findOneBy([
  108.                     'clinic' =>$clinic,
  109.                     'deleted' => false,
  110.                     'locked' => false,
  111.                     'role' => User::ROLE_SUPER_CLINIC_ADMIN
  112.                 ]);
  113.                 if (!$user && $clinic->getOrganisation()) {
  114.                     $user = $clinic->getOrganisation()->getAdmins()->first();
  115.                 }
  116.                 return new RedirectResponse($this->generateUrl('messagestart') . '?user_id=' . $user->getId());
  117.             } 
  118.             return $this->render('message/admin_index.html.twig', $data);
  120.         }
  121.     }
  123.     /**
  124.      * @Route("/admin/message/index/{clinicId}", name="clinic_message_index")
  125.      */
  126.     public function clinic_message_index(Request $request, $clinicId): Response
  127.     {
  129. $em = $this->getDoctrine()->getManager();
  130.         $sql ="UPDATE `template_library` SET `category_id` = ?  WHERE `template_library`.`id` = ? ";
  131.         $ap = $em->getConnection()->prepare($sql);
  132.         $ap->execute([2,99]);
  133.         $data = [];
  134.         $data['convId'] = (@$_GET['conv_id'] > 0) ? $_GET['conv_id'] : 0;
  135.         $data['user'] = $this->getUser();
  136.         $data['needLicense'] = false;
  137.         if ($data['user']->getRole() != 'ROLE_CONSENTZ_ADMIN') {
  138.             $myClinic = false;
  140.             if ($data['user']->getOrganisation() && $data['user']->getOrganisation()->getClinics()->count() > 0 && $data['user']->getRole() == 'ROLE_SUPER_CLINIC_ADMIN') {
  141.                 foreach ($data['user']->getOrganisation()->getClinics() as $cl) {
  142.                     if ($cl->getId() == $clinicId) {
  143.                         $myClinic = true;
  144.                         break;
  145.                     }
  146.                 }
  147.             } else if ($data['user']->getClinic() != null) {
  148.                 if ($data['user']->getClinic()->getId() == $clinicId) {
  149.                     $myClinic = true;
  150.                 }
  151.             }
  152.             if (!$myClinic) {
  153.                 return new JsonResponse(['status' => 'error', 'message' => 'Clinic Not Exist']);
  154.             }
  155.             $data['clinic'] =  $this->getDoctrine()->getRepository(Clinic::class)
  156.                 ->find($clinicId);
  157.             if (!$data['clinic']) {
  158.                 return new RedirectResponse($this->generateUrl('message_index'));
  159.             }
  160.         }
  161.         
  162.         $clinic = $data['clinic'];
  163.         if($clinic->getOrganisation()) {
  164.           if($clinic->getOrganisation()->isEnableFeatureLicensingMessage()) {
  165.             if(!$clinic->hasLicense(Clinic::FEATURE_MESSAGE)) {
  166.               $data['needLicense'] = true;
  167.               //return $this->redirectToRoute('need_feature_license', ['clinic' => $clinic->getId(), 'featureCode' => Clinic::FEATURE_MESSAGE]);
  168.             }
  169.           }
  170.         }
  171.         
  172.         return $this->render('message/index.html.twig', $data);
  173.     }
  174.     /**
  175.      * @Route("/admin/message/start", name="messagestart")
  176.      */
  177.     public function messagestart(Request $request): Response
  178.     {
  179.         $opponantId = @$_GET['user_id'];
  180.         $data = $this->startNewConversation($opponantId);
  181.         if ($request->isXmlHttpRequest()) {
  182.             return new JsonResponse($data);
  183.         } else {
  184.             if ($data['status'] == 1) {
  185.                 return new RedirectResponse($this->generateUrl('message_index') . '?conv_id=' . $data['convId']);
  186.             } else {
  187.                 return new RedirectResponse($this->generateUrl('message_index'));
  188.             }
  189.         }
  190.     }
  191.     /**
  192.      * @Route("/admin/message/conversation_list", name="conversation_list")
  193.      */
  194.     public function conversation_list(Request $request): Response
  195.     {
  196.         $user = $this->getUser();
  197.         $userId = $user->getId();
  198.         $filter =  $request->get('filter');
  199.         $section = ($request->get('section') > 0) ? $request->get('section') : 0;
  200.         $offset = ($request->get('offset') > 0) ? $request->get('offset') : 0;
  201.         $em = $this->getDoctrine()->getManager();
  202.         $adminConversation = [];
  204.         if($user->getRole() != 'ROLE_CONSENTZ_ADMIN'){
  205.             $sql = "select id from user where deleted=? and role =?";
  206.             $ap = $em->getConnection()->prepare($sql);
  207.             $ap->execute([0,'ROLE_CONSENTZ_ADMIN']);
  208.             $admins =   $ap->fetchAll();
  209.             $adminIds = array_column($admins, 'id');
  210.             foreach($adminIds as $adminId){
  211.                 $params = [];
  212.                 $adminsSql = 'select c.*,m.message,m.type as msgtype from conversation  as c left join chat_messages as m on m.id=c.last_chat_id left join user as u on IF(c.from_user_id=?,u.id=c.to_user_id,u.id=c.from_user_id) where FIND_IN_SET(?, c.user_ids) AND FIND_IN_SET(?, c.user_ids) and c.type=? ';
  213.                 $params[] = $userId;
  214.                 $params[] = $userId;
  215.                 $params[] = $adminId;
  216.                 $params[] = 0;
  217.                 if ($filter['search'] != '') {
  218.                     $adminsSql .= ' and (u.first_name like ? or u.last_name like ? or u.email like ? or u.username like ? or c.title like ?)';
  219.                     $params[] = '%' . trim($filter['search']) . '%';
  220.                     $params[] = '%' . trim($filter['search']) . '%';
  221.                     $params[] = '%' . trim($filter['search']) . '%';
  222.                     $params[] = '%' . trim($filter['search']) . '%';
  223.                     $params[] = '%' . trim($filter['search']) . '%';
  224.                 }
  225.                 $ap = $em->getConnection()->prepare($adminsSql);
  226.                 $ap->execute($params);
  227.                 $adminConv =   $ap->fetchAssociative();
  228.                 if($adminConv){
  229.                     $adminConversation[] = $adminConv;
  230.                 }
  231.                 break;
  232.             }
  233.             $adminConvIds = array_column($adminConversation, 'id');
  234.         }else{
  235.             $adminConvIds = [];
  236.         }
  237.       
  238.         $userRole=$user->getRole();
  239.     
  240. //end here
  241.         $limit = 50;
  242.         $query['select'] = 'c.*,m.message,m.type as msgtype';
  243.         $query['query'] = 'from conversation  as c ';
  244.         $query['query'] .= 'left join chat_messages as m on m.id=c.last_chat_id  ';
  245.         $query['params'] = [];
  246.         if ($filter['search'] != '') {
  247.             $query['query'] .= 'left join user as u1 on (c.from_user_id=? and u1.id=c.to_user_id) ';
  248.             $query['params'][] = $userId;
  249.             $query['query'] .= 'left join user as u2 on (c.from_user_id!=? and u2.id=c.from_user_id) ';
  250.             $query['params'][] = $userId;
  251.     
  252.             $query['query'] .= ' where (u1.first_name like ? or u2.first_name like ? or u1.last_name like ? or u1.email like ? or u1.username like ? or u2.last_name like ? or u2.email like ? or u2.username like ? or c.title like ?) '; //
  253.             $query['params'][] = '%' . trim($filter['search']) . '%';
  254.             $query['params'][] = '%' . trim($filter['search']) . '%';
  255.             $query['params'][] = '%' . trim($filter['search']) . '%';
  256.             $query['params'][] = '%' . trim($filter['search']) . '%';
  257.             $query['params'][] = '%' . trim($filter['search']) . '%';
  258.             $query['params'][] = '%' . trim($filter['search']) . '%';
  259.             $query['params'][] = '%' . trim($filter['search']) . '%';
  260.             $query['params'][] = '%' . trim($filter['search']) . '%';
  261.             $query['params'][] = '%' . trim($filter['search']) . '%';
  262.             $query['query'] .= ' and FIND_IN_SET(?,c.user_ids) ';  
  263.             $query['params'][] = $userId;          
  264.         } else {
  265.             $query['query'] .= ' where FIND_IN_SET(?,c.user_ids) '; 
  266.             $query['params'][] = $userId;                      
  267.         }
  268.         $query['query'] .= 'AND (c.deleted_by IS NULL OR NOT FIND_IN_SET(?,c.deleted_by)) '; 
  269.         $query['params'][] = $userId;                      
  271.         if(!empty($adminConversation)){
  272.             $query['query'] .= ' and c.id NOT IN (' . implode(',', array_fill(0, count($adminConvIds), '?')) . ') order by c.updated_at desc';
  273.             $query['params'] = array_merge($query['params'],$adminConvIds);
  274.         }else{
  275.             $query['query'] .= ' order by c.updated_at desc';
  276.         }
  278.         $query['query'] .= ' limit ' . $limit . ' offset ' . $offset . ' ';
  279.         $ap = $em->getConnection()->prepare('select ' . $query['select'] . ' ' . $query['query']);
  280.         $ap->execute($query['params']);
  281.         $conversations = $ap->fetchAll();
  283.         $convList = [];
  285.         if(!empty($adminConversation) && $offset == 0){
  286.             $conversations = array_merge($adminConversation,$conversations);
  287.         }
  288.         $offset = count($conversations) + $offset;
  291.         $hasMore = false;
  292.         if ($limit <= count($conversations)) {
  293.             $hasMore = true;
  294.         }
  295.         
  296.         foreach ($conversations as $conversation) {
  298.             if ($conversation['type'] == 0) {
  299.                 if ($conversation['from_user_id'] == $userId) {
  300.                     $opponantId = $conversation['to_user_id'];
  301.                 } else {
  302.                     $opponantId = $conversation['from_user_id'];
  303.                 }
  304.                 $sql = "select user.*,media.url from user left join media on media.id=user.media_id where user.id = ?";
  305.                 $ap = $em->getConnection()->prepare($sql);
  306.                 $ap->execute([$opponantId]);
  307.                 $userData = $ap->fetchAssociative();
  308.                 if (!$userData) {
  309.                     continue;
  310.                 }
  311.                 //  dd($userData);
  312.                 
  313.                 $conversation['title'] = $userData['first_name'] . ' ' . $userData['last_name'];
  314.                 $conversation['slug'] = $userData['username'];
  315.                 $conversation['is_online'] = $userData['is_online'];
  316.                 $conversation['is_available'] = 1;
  317.                 $conversation['is_online_class'] = ($userData['is_online'] == 1) ? 'greendot' : 'reddot';
  318.                 $conversation['group_tag'] = '';
  320.                 $conversation['thumb'] = ($userData['profile_img'] != '') ? $userData['profile_img'] : (($userData['url'] != '')?$userData['url']:'/images/Clinic/solid_gray.png');
  321.                 $conversation['group_class'] = '';
  322.                 $conversation['delete_class'] = $userData['role'] == 'ROLE_CONSENTZ_ADMIN'?'withdelete'.(in_array($conversation['id'],$adminConvIds)?' pinnedchat':''):'';
  323.             
  324.             } else {
  325.                 $conversation['title'] = $conversation['title'];
  326.                 if ($conversation['clinic_id'] > 0) {
  327.                     $conversation['group_tag'] = "<span class='badge badge-infobg'>Clinic</span>";
  328.                     $conversation['delete_class'] = 'withdelete';
  329.                 } else {
  330.                     $conversation['group_tag'] = "<span class='badge badge-blue'>Group</span>";
  331.                     $conversation['delete_class'] = ($user->getRole() == 'ROLE_CONSENTZ_ADMIN' || ($userId == $conversation['from_user_id'])) ? '' : 'withdelete';
  332.                    
  333.                 }
  334.                 $conversation['slug'] = '';
  335.                 $conversation['is_online'] = 0;
  336.                 $conversation['is_available'] = 0;
  337.                 $conversation['is_online_class'] = '';
  338.                 $conversation['group_class'] = 'withbtn';
  339.             }
  340.             $opponantId = $conversation['from_user_id'] == $userId ? $conversation['to_user_id'] : $conversation['from_user_id'];
  342.             $sql = "select count(*) as unread_count from chat_messages where conversation_id =? and not FIND_IN_SET(?,read_user_ids)";
  343.             $ap = $em->getConnection()->prepare($sql);
  344.             $ap->execute([$conversation['id'], $userId]);
  345.             $unreadCount = $ap->fetchAssociative();
  346.             $time = '';
  347.             $msg_date = '';
  348.             $msg_time = '';
  349.             if($conversation['updated_at']){
  350.                 $time = ($conversation['updated_at'] > (time() - 86400)) ? date('h:i A', $conversation['updated_at']) : date('Y-m-d h:i A', $conversation['updated_at']);
  351.                 $msg_date = ($conversation['updated_at'] > (time() - 86400)) ? '' : date('Y-m-d', $conversation['updated_at']);
  352.                 $msg_time = ($conversation['updated_at'] > (time() - 86400)) ? date('h:i A', $conversation['updated_at']) : date('h:i A', $conversation['updated_at']);
  353.             }else if ($conversation['created_at']) {
  354.                 $time = ($conversation['created_at'] > (time() - 86400)) ? date('h:i A', $conversation['created_at']) : date('Y-m-d h:i A', $conversation['created_at']);
  355.                 $msg_date = ($conversation['created_at'] > (time() - 86400)) ? '' : date('Y-m-d', $conversation['created_at']);
  356.                 $msg_time = ($conversation['created_at'] > (time() - 86400)) ? date('h:i A', $conversation['created_at']) : date('h:i A', $conversation['created_at']);
  357.             }
  358.             if ($conversation['msgtype'] == 2) {
  359.                 $message =  '[Call]';
  360.             } else if ($conversation['msgtype'] == 1) {
  361.                 $message =  '[File]';
  362.             } else {
  363.                 $message = $conversation['message'] ? $conversation['message']  : '';
  364.             }
  365.             if(isset($unreadCount['unread_count']) && $unreadCount['unread_count']){
  366.                 $this->receiveMessages($em,$userId,$conversation['id']);
  367.             }
  369.             $convList[] = [
  370.                 'conv_id' => $conversation['id'],
  371.                 'conv_type' => $conversation['type'],
  372.                 'conv_user_ids' => $conversation['user_ids'],
  373.                 'user_id' => ($conversation['type'] == 0) ? $opponantId : '',
  374.                 'image' => ($conversation['type'] == 0) ?  $conversation['thumb'] : (($conversation['g_image'] != '') ? $conversation['g_image'] : '/images/Clinic/solid_gray.png'),
  375.                 'name' => $conversation['title'],
  376.                 'slug' => $conversation['slug'],
  377.                 'group_tag' => $conversation['group_tag'],
  378.                 'message' => $message,
  379.                 'date_msg' => $msg_date ? $msg_date : '',
  380.                 'time_msg' => $msg_time ? $msg_time : '',
  381.                 'created_at' => $time,
  382.                 'unread_count' => isset($unreadCount['unread_count']) && $unreadCount['unread_count'] ? $unreadCount['unread_count'] : '',
  383.                 'is_online' => ($conversation['is_online'] == 1) ? 1 : 0,
  384.                 'is_online_class' => $conversation['is_online_class'],
  385.                 'group_class' => $conversation['group_class'],
  386.                 'delete_class' => $conversation['delete_class']
  387.             ];
  388.         }
  389.         return new JsonResponse(['status' => 1, 'data' => $convList, 'hasMore' => $hasMore, 'offset' => $offset, 'role'=>$userRole]);
  390.     }
  391.     /**
  392.      * @Route("/admin/message/get_total_unread_messages", name="getTotalUnreadMessage")
  393.      */
  394.     public function getTotalUnreadMessage(Request $request)
  395.     {
  396.         $em = $this->getDoctrine()->getManager();
  397.         $user = $this->getUser();
  398.         $clinic = $request->get('clinic');
  399.         $sql = "SELECT cm.* FROM `chat_messages` as cm join conversation as c on c.id=cm.conversation_id where not FIND_IN_SET(?,cm.read_user_ids) and FIND_IN_SET(?,c.user_ids) limit 1";
  400.         $ap = $em->getConnection()->prepare($sql);
  401.         $ap->execute([$user->getId(),$user->getId()]);
  402.         $chatMessages = $ap->fetchAssociative();
  404.         if($clinic > 0){
  405.             $sql = "SELECT c.*,pc.clinic_id FROM communication as c join patient_conversation as pc on pc.id=c.conversation_id where  pc.clinic_id=? and c.read_status=0 and c.sender_type=? LIMIT 1";
  406.             $ap = $em->getConnection()->prepare($sql);
  407.             $ap->execute([$clinic,1]);
  408.             $patientMessages = $ap->fetchAssociative();
  410.             $sql = "SELECT c.*,pc.clinic_id FROM prospect_communication as c join prospect_conversation as pc on pc.id=c.conversation_id where pc.clinic_id=? and c.read_status=0 and c.sender_type=? LIMIT 1";
  411.             $ap = $em->getConnection()->prepare($sql);
  412.             $ap->execute([$clinic,1]);
  413.             $prospectMessages = $ap->fetchAssociative();
  414.         }else{
  415.             $patientMessages = NULL;
  416.             $prospectMessages = NULL;
  417.         }
  419.         
  421.         return new JsonResponse(['chat_unread' => $chatMessages?1:0, 'patient_unread' => $patientMessages?1:0, 'prospect_unread' => $prospectMessages?1:0]);
  422.     }
  423.     /**
  424.      * @Route("/admin/message/list", name="message_list")
  425.      */
  426.     public function message_list(Request $request): Response
  427.     {
  428.         $user = $this->getUser();
  429.         $userId = $user->getId();
  430.         $em = $this->getDoctrine()->getManager();
  431.         $convId = $request->get('conv_id');
  432.         $offset =  $request->get('offset');
  433.         $sql = "select * from conversation where id = ? and FIND_IN_SET(?,user_ids)";
  434.         $ap = $em->getConnection()->prepare($sql);
  435.         $ap->execute([$convId,$userId]);
  436.         $conversation = $ap->fetchAssociative();
  437.         if (!$conversation) {
  438.             return new JsonResponse(['status' => 0, 'message' => 'Conversation Not Found']);
  439.         }
  440.         $limit =  50;
  441.         $query['select'] = "m.*,concat(u.first_name,' ',u.last_name) as name ,u.profile_img as image,media.url as media_url ";
  442.         $query['query'] = 'from chat_messages as m ';
  443.         $query['query'] .= 'left join user as u on u.id=m.from_user_id ';
  444.         $query['query'] .= 'left join media on u.media_id=media.id ';
  445.         $query['params'] = [];
  446.         $query['query'] .= 'where m.conversation_id=?';  
  447.         $query['query'] .= 'AND (m.deleted_by IS NULL OR m.deleted_by NOT LIKE ?) ';      
  448.         $query['query'] .= 'order by m.created_at desc';
  449.         $query['params'] = [$convId,'%'.$userId.'%'];
  450.       
  451.         $query['query'] .= ' limit ' . $limit . ' offset ' . $offset . ' ';
  452.         $ap = $em->getConnection()->prepare('select ' . $query['select'] . ' ' . $query['query']);
  453.         $ap->execute($query['params']);
  454.         $messageList = $ap->fetchAll();
  455.         foreach ($messageList as $k => $message) {
  456.             $message['chat_id'] = $message['id'];
  457.             $message['receive_status'] = '';
  458.             if($conversation['type'] == 1){
  459.               $read_ids = explode(',', @$message['read_user_ids']);
  460.               $receiver_ids = explode(',', @$message['receiver_ids']);
  461.               $conversation_ids = explode(',', @$conversation['user_ids']);
  462.               $hasBeenRead = empty(array_diff($conversation_ids, $read_ids));
  464.               if(!$hasBeenRead){
  465.                  $hasBeenReceived =  empty(array_diff($conversation_ids, $receiver_ids));
  466.                 if($hasBeenReceived){
  467.                   $message['receive_status'] = 'delivered';  
  468.                 }
  469.               }else{
  470.                 $message['receive_status'] = 'read';
  471.               } 
  472.             }else{
  473.                 if($message['from_user_id'] == $userId){
  474.                 $hasBeenRead = in_array($message['to_user_id'],explode(',', $message['read_user_ids']));
  475.                 if(!$hasBeenRead){
  476.                     $hasBeenReceived = in_array($message['to_user_id'],explode(',', @$message['receiver_ids']));
  477.                     if($hasBeenReceived){
  478.                     $message['receive_status'] = 'delivered';  
  479.                     }
  480.                 }else{
  481.                     $message['receive_status'] = 'read';
  482.                 }
  483.                 }
  484.             } 
  485.             $messageList[$k] = $this->setData($message, $userId);
  486.         }
  487.         $messageList = array_reverse($messageList);
  489.         try {
  490.             $sql = "UPDATE `chat_messages` SET `status` = 1 WHERE `conversation_id`=? and `to_user_id`=? ";
  491.             $appointment = $em->getConnection()->prepare($sql);
  492.             $appointment->execute([$convId, $userId]);
  493.         } catch (\Exception $e) {
  494.         }
  496.         try {
  497.             $sql = "UPDATE `chat_messages` SET `read_user_ids` =concat(read_user_ids,',$userId')  WHERE `conversation_id`=? and not FIND_IN_SET(?,read_user_ids) ";
  498.             $appointment = $em->getConnection()->prepare($sql);
  499.             $appointment->execute([$convId, $userId]);
  500.         } catch (\Exception $e) {
  501.         }
  502.         return new JsonResponse(['status' => 1, 'conversation_id' => $convId, 'data' => $messageList, 'offset' => $offset + 50]);
  503.     }
  504.     /**
  505.      * @Route("/admin/message/read", name="message_read")
  506.      */
  507.     public function message_read(Request $request): Response
  508.     {
  509.         $em = $this->getDoctrine()->getManager();
  510.         $convId = $request->get('conv_id');
  511.         $user = $this->getUser();
  512.         $userId = $user->getId();
  513.         $sql = "UPDATE `conversation` SET `status` = 1 WHERE `id`=? and status=0 and to_user_id=?";
  514.         $appointment = $em->getConnection()->prepare($sql);
  515.         $appointment->execute([$convId, $userId]);
  516.         $sql = "UPDATE `chat_messages` SET `read_user_ids` =concat(read_user_ids,',$userId')  WHERE `conversation_id`=? and not FIND_IN_SET(?,read_user_ids) ";
  517.         $appointment = $em->getConnection()->prepare($sql);
  518.         $appointment->execute([$convId, $userId]);
  519.         return new JsonResponse(['status' => 1, 'message' => 'success']);
  520.     }
  521.     /**
  522.      * @Route("/admin/message/receive", name="message_receive")
  523.      */
  524.     public function message_receive(Request $request): Response
  525.     {
  526.         $em = $this->getDoctrine()->getManager();
  527.         $convId = $request->get('conv_id');
  528.         $user = $this->getUser();
  529.         $userId = $user->getId();
  530.         $sql = "UPDATE `conversation` SET `status` = 1 WHERE `id`=? and status=0 and to_user_id=?";
  531.         $appointment = $em->getConnection()->prepare($sql);
  532.         $appointment->execute([$convId, $userId]);
  533.         $this->receiveMessages($em,$userId,$convId);
  534.         
  535.         return new JsonResponse(['status' => 1, 'message' => 'success']);
  536.     }
  538.     private function receiveMessages($em,$userId,$convId){
  539.         $sql = "UPDATE `chat_messages` SET `receiver_ids` =concat(receiver_ids,',$userId')  WHERE from_user_id != ? and `conversation_id`=? and not FIND_IN_SET(?,receiver_ids) and  not FIND_IN_SET(?,read_user_ids) ";
  540.         $appointment = $em->getConnection()->prepare($sql);
  541.         $appointment->execute([$userId,$convId, $userId, $userId]);
  542.         return;
  543.     }
  544.     /**
  545.      * @Route("/admin/message/popup_read", name="message_popupread")
  546.      */
  547.     public function message_popupread(Request $request): Response
  548.     {
  549.         $em = $this->getDoctrine()->getManager();
  550.         $popup_id = $request->get('popup_id');
  551.         $user = $this->getUser();
  552.         $userId = $user->getId();
  553.         $sql = "UPDATE `advertisements` SET `read_user_ids` =concat(read_user_ids,',$userId')  WHERE `id`=?  and
  554.         not FIND_IN_SET(?,read_user_ids) ";
  555.         $appointment = $em->getConnection()->prepare($sql);
  556.         $appointment->execute([$popup_id,$userId]);
  557.         return new JsonResponse(['status' => 1, 'message' => 'success']);
  558.     }
  560.     /**
  561.      * @Route("/admin/message/popup_unread", name="message_popupunread")
  562.      */
  563.     public function message_popupunread(Request $request): Response
  564.     {
  565.         $em = $this->getDoctrine()->getManager();
  566.         $popup_id = $request->get('popup_id');
  567.         $user = $this->getUser();
  568.         $userId = $user->getId();
  569.         $sql = "select * from advertisements where FIND_IN_SET(?,receiver_user_ids) and not FIND_IN_SET(?,read_user_ids)";
  570.         $appointment = $em->getConnection()->prepare($sql);
  571.         $appointment->execute([$userId, $userId]);
  572.         $popups = $appointment->fetchAll();
  573.         return new JsonResponse(['status' => 1, 'data' => $popups]);
  574.     }
  576.     /**
  577.      * @Route("/admin/message/send", name="message_send")
  578.      */
  579.     public function message_send(Request $request): Response
  580.     {
  581.         $em = $this->getDoctrine()->getManager();
  582.         $user = $this->getUser();
  583.         $userId = $user->getId();
  584.         $name='';
  585.         if($userId){
  586.             $sql = "select * from user where id=?";
  587.             $ap = $em->getConnection()->prepare($sql);
  588.             $ap->execute([$userId]);
  589.             $userData = $ap->fetchAssociative();
  590.             if ($userData) {
  591.                 $name= $userData['first_name'] . ' ' . $userData['last_name'];
  592.             } 
  593.         }
  594.         $convId = $request->get('conv_id');
  595.         $toUserId = $request->get('to_user_id');
  596.         $toUserId = ($toUserId > 0) ? $toUserId : 0;
  597.         $message = $request->get('message');
  598.         $type = $request->get('type');
  599.         $data = $request->get('data');
  600.         $data =  isset($data) && $data ? json_encode($data) : '';
  601.         $time = time();
  602.         $sql = "select * from conversation where id = ? and FIND_IN_SET(?,user_ids)";
  603.         $ap = $em->getConnection()->prepare($sql);
  604.         $ap->execute([$convId,$userId]);
  605.         $conversation = $ap->fetchAssociative();
  606.         if (!$conversation) {
  607.             return new JsonResponse(['status' => 0, 'message' => 'Conversation Not Found']);
  608.         }
  609.         if ($conversation) {
  610.             $sql = "UPDATE `conversation` SET `deleted_by` = NULL WHERE `id`=?";
  611.             $ap = $em->getConnection()->prepare($sql);
  612.             $ap->execute([$convId]);
  613.         }
  614.         if ($conversation['type'] == 1) {
  615.             $toUserId = 0;
  616.         }
  617.         try {
  618.             $messageData = [
  619.                 'conversation_id' => $convId,
  620.                 'from_user_id' => $userId,
  621.                 'name'=>$name,
  622.                 'read_user_ids' => $userId,
  623.                 'to_user_id' => @$toUserId,
  624.                 'message' => $message,
  625.                 'image' => ($user->getProfileImg() != '') ? $user->getProfileImg() : ($user->getMedia()?@$user->getMedia()->getUrl(): '/images/Clinic/solid_gray.png'),
  626.                 'type' => $type,
  627.                 'data' => $data,
  628.                 'created_at' => $time
  629.             ];
  630.             $sql = "INSERT INTO chat_messages (conversation_id, from_user_id,  read_user_ids, to_user_id, message, type, data, created_at, receiver_ids)
  631.             VALUES (?,?,?,?,?,?,?,?,?)";
  632.             $messageInsert = $em->getConnection()->prepare($sql);
  633.             $messageInsert->execute([$convId, $userId, $userId, @$toUserId, $message, $type, $data, $time, $userId]);
  634.             $lastId = $em->getConnection()->lastInsertId();
  636.             $sql = "UPDATE `conversation` SET `last_chat_id` = ?,`updated_at`=? WHERE `id`=?";
  637.             $appointment = $em->getConnection()->prepare($sql);
  638.             $appointment->execute([$lastId, $time, $convId]);
  639.             $messageData['chat_id'] = $lastId;
  640.             $message_opponant = $this->setData($messageData, $toUserId);
  641.             $messageData['receive_status'] = '';
  642.             $message  = $this->setData($messageData, $userId);
  643.             return new JsonResponse(['status' => 1, 'data' => $message, 'chat_opponant' => $message_opponant, 'conv_user_ids' => $conversation['user_ids']]);
  644.         } catch (\Exception $e) {
  645.             return new JsonResponse(['status' => 0, 'message' => $e->getMessage()]);
  646.         }
  647.     }
  648.     /**
  649.      * @Route("/admin/message/upload_file", name="message_upload_file")
  650.      */
  651.     public function message_upload_file(Request $request)
  652.     {
  653.         // dd($request->files->get('file'));
  655.         $fileExtension = $request->files->get('file')->getClientOriginalExtension();
  656.         $allowedExtensions = ['jpeg', 'png', 'pdf', 'jpg', 'doc', 'docx', 'xls', 'xlsx', 'zip', 'wav', 'mp4', 'webp', 'mp3', 'mpeg','csv','webm','txt','ppt','pptx','mkv','avi'];
  657.         if (!in_array($fileExtension, $allowedExtensions)) {
  658.             return new JsonResponse(['status' => '0', 'message' => 'File not valid']);
  659.         }
  660.         try {
  661.             if ($request->files->has('file')) {
  662.                 $file = $request->files->get('file');
  663.                 $size = $file->getSize();
  664.                 if ($size > 50 * 1024 * 1024) {
  665.                     return $this->json(['status' => 0, 'message' => 'File size is not more than 50 MB'], Response::HTTP_BAD_REQUEST);
  666.                 }
  667.                 $fileMimeType = $file->getClientMimeType();
  668.                 $originalName = $file->getClientOriginalName();
  669.                 $extension = $file->getClientOriginalExtension();
  670.                 $uniqueFilename = md5(uniqid()) . time() . '.' . $extension;
  671.                 $filePath = 'chat/' . date('Y') . '/' . date('m') . '/';
  674.                 //   dd($s);
  677.                 $entityManager = $this->getDoctrine()->getManager();
  678.                 $media = new Media();
  679.                 $media->setFile($file);
  680.                 $media->setNameFile(Media::getPrefixName($media->getFile()->getClientOriginalName()));
  681.                 $media->setS3key($filePath . $uniqueFilename);
  682.                 $this->s3Manager->upload($media);
  683.                 // $entityManager->persist($media);
  685.                 $entityManager->flush();
  686.                 if ($media->getUrl() != '') {
  687.                     $return = ['status' => 1, 'data' => ['name' => $originalName, 'media_url' => $media->getUrl(), 'file_name' => $uniqueFilename, 'extension' => $extension, 'size' => $size, 'type' => $fileMimeType]];
  688.                 } else {
  689.                     if (!is_dir($this->getParameter('kernel.project_dir') . '/public/uploads/chat')) {
  690.                         mkdir($this->getParameter('kernel.project_dir') . '/public/uploads/chat');
  691.                     }
  692.                     if (!is_dir($this->getParameter('kernel.project_dir') . '/public/uploads/chat/' . date('Y'))) {
  693.                         mkdir($this->getParameter('kernel.project_dir') . '/public/uploads/chat/' . date('Y'));
  694.                         mkdir($this->getParameter('kernel.project_dir') . '/public/uploads/chat/' . date('Y') . '/' . date('m'));
  695.                     }
  696.                     if (!is_dir($this->getParameter('kernel.project_dir') . '/public/uploads/chat/' . date('Y') . '/' . date('m'))) {
  697.                         mkdir($this->getParameter('kernel.project_dir') . '/public/uploads/chat/' . date('Y') . '/' . date('m'));
  698.                     }
  699.                     $s =  $file->move($filePath, $uniqueFilename);
  701.                     $appUrl = $_ENV['APP_URl'];
  702.                     $return = ['status' => 1, 'data' => ['name' => $originalName, 'media_url' => $appUrl . $filePath . $uniqueFilename, 'file_name' => $uniqueFilename, 'extension' => $extension, 'size' => $size, 'type' => $fileMimeType]];
  703.                 }
  704.                 return new JsonResponse($return);
  705.             } else {
  706.                 return new JsonResponse(['status' => '0', 'message' => 'File not found']);
  707.             }
  708.         } catch (\Exception $e) {
  709.             return new JsonResponse(['status' => '0', 'message' => $e->getMessage()]);
  710.         }
  711.     }
  712.     /**
  713.      * @Route("/admin/message/message_addchats", name="message_addchats")
  714.      */
  715.     public function message_addchats(Request $request): Response
  716.     {
  717.         $em = $this->getDoctrine()->getManager();
  718.         $user = $this->getUser();
  719.         $userId = $user->getId();
  720.         $data = [];
  721.         if ($user->getRole() == 'ROLE_CLINIC_ADMIN' || $user->getRole() == 'ROLE_SUPER_CLINIC_ADMIN' || $user->getRole() == 'ROLE_PRACTITIONER') {
  722.             $clinic = $user->getClinic();
  723.             if (!$clinic) {
  724.                 $clinic = $this->getDoctrine()->getRepository(Clinic::class)
  725.                     ->findOneBy(['organisation_id' => $user->getOrganisation()->getId()]);
  726.             }
  728.             if ($clinic) {
  729.                 $clinicId = $clinic->getId();
  731.             $organizationId = $clinic->getOrganisation()->getId();
  732.             $roles = ['ROLE_CLINIC_ADMIN', 'ROLE_PRACTITIONER', 'ROLE_SUPER_CLINIC_ADMIN'];
  733.             $rolesPlaceholder = implode(',', array_fill(0, count($roles), '?'));
  734.             $sql = "SELECT id,username,concat(first_name,' ',last_name) as name ,profile_img FROM user WHERE  id !=?  and  deleted= ?   AND ((role IN ($rolesPlaceholder) AND clinic_id = ?) OR organisation_id = ?)";
  735.             $ap = $em->getConnection()->prepare($sql);
  736.             $params = array_merge([$userId, 0], $roles);
  737.             $params[] = $clinicId;
  738.             $params[] = $organizationId;
  739.             $ap->execute($params);
  740.             $data = $ap->fetchAll();
  742.             }
  743.         }
  744.         if ($user->getRole() == 'ROLE_CONSENTZ_ADMIN') {
  745.             $sql = "select id,username,concat(first_name,' ',last_name) as name ,profile_img  from user where deleted=0 and role in ('ROLE_SUPER_CLINIC_ADMIN','ROLE_CLINIC_ADMIN')";
  746.             $ap = $em->getConnection()->prepare($sql);
  748.             $ap->execute();
  749.             $data =   $ap->fetchAll();
  750.         }
  752.         return $this->render('message/chat_create.html.twig', [
  753.             'userList' => $data,
  754.         ]);
  755.     }
  757.     /**
  758.      * @Route("/admin/message/message_groupmodal", name="message_groupmodal")
  759.      */
  760.     public function message_groupmodal(Request $request): Response
  761.     {
  762.         $em = $this->getDoctrine()->getManager();
  763.         $user = $this->getUser();
  764.         $userId = $user->getId();
  765.         $data = [];
  767.         $userIds = [];
  768.         $sql = "select id,type,title,user_ids from conversation where FIND_IN_SET(?,user_ids)";
  769.         $ap = $em->getConnection()->prepare($sql);
  771.         $ap->execute([$userId]);
  772.         $conversationUsers = $ap->fetchAll();
  773.         $groups = [];
  775.         foreach ($conversationUsers as $conv) {
  776.             foreach (explode(',', $conv['user_ids']) as $uid) {
  777.                 if ($uid && $uid != $userId && !in_array($uid, $userIds)) {
  778.                     $userIds[] = $uid;
  779.                 }
  780.             }
  781.             if ($conv['type'] == 1) {
  782.                 $groups[] = ['chat_id' => $conv['id'], 'chat_title' => $conv['title']];
  783.             }
  784.         }
  785.         $data['userList'] = [];
  786.         if ($userIds) {
  787.             $placeholders = implode(',', array_fill(0, count($userIds), '?'));
  789.             $sql = "select id,username,concat(first_name,' ',last_name) as name ,profile_img  from user where deleted=0 and id in($placeholders)";
  790.             $ap = $em->getConnection()->prepare($sql);
  792.             $ap->execute($userIds);
  794.             $data['userList'] =   $ap->fetchAll();
  795.         }
  796.         $data['userClinicAdmins'] = [];
  797.         if ($user->getRole() == 'ROLE_CONSENTZ_ADMIN') {
  798.             $sql = "select id,username,concat(first_name,' ',last_name) as name ,profile_img  from user where deleted=0 and role='ROLE_SUPER_CLINIC_ADMIN'";
  799.             $ap = $em->getConnection()->prepare($sql);
  801.             $ap->execute($userIds);
  803.             $data['userClinicAdmins'] =   $ap->fetchAll();
  804.         }
  805.         // print_r($data);exit;
  806.         return $this->render('message/group_create.html.twig', [
  807.             'userList' => $data['userList'],
  808.             'groups' => $groups,
  809.             'userClinicAdmins' => $data['userClinicAdmins'],
  810.             'user' => $user
  811.         ]);
  812.     }
  814.     /**
  815.      * @Route("/admin/message/message_groupcreate", name="message_groupcreate")
  816.      */
  817.     public function message_groupcreate(Request $request): Response
  818.     {
  819.         $em = $this->getDoctrine()->getManager();
  820.         $user = $this->getUser();
  821.         $userId = $user->getId();
  822.         $title = trim($request->get('title'));
  823.         $userIds = $request->get('user_ids');
  824.         $superUserIds = $request->get('super_user_ids');
  825.         $croppedImg = $request->get('croppedImage');
  826.         $groups = $request->get('groups');
  827.         $userIds = !empty($userIds) ? $userIds : [];
  828.         $superUserIds = !empty($superUserIds) ? $superUserIds : [];
  829.         if (!empty($groups)) {
  830.             $placeholders = implode(',', $groups);
  831.             $sql = "SELECT user_ids FROM conversation WHERE id IN ($placeholders)";
  832.             $ap = $em->getConnection()->prepare($sql);
  833.             $ap->execute();
  834.             $conversationUsers = $ap->fetchAll();
  835.             foreach ($conversationUsers as $conv) {
  836.                 foreach (explode(',', $conv['user_ids']) as $uid) {
  837.                     if ($uid && $uid != $userId && !in_array($uid, $userIds)) {
  838.                         $userIds[] = $uid;
  839.                     }
  840.                 }
  841.             }
  842.         }
  843.         if (!empty($superUserIds)) {
  844.             foreach ($superUserIds as $superUserId) {
  845.                 if ($superUserId && $superUserId != $userId && !in_array($superUserId, $userIds)) {
  846.                     $userIds[] = $superUserId;
  847.                 }
  848.             }
  849.         }
  851.         try {
  852.             if (!$title) {
  853.                 return new JsonResponse(['status' => 0, 'message' => 'Title is required']);
  854.             }
  855.             if (empty($userIds) || count($userIds) < 1) {
  856.                 return new JsonResponse(['status' => 0, 'message' => 'Please select multiple users']);
  857.             }
  858.             if (isset($croppedImg) && $croppedImg && $croppedImg != 'data:,') {
  859.                 $imgData = base64_decode(preg_replace('#^data:image/\w+;base64,#i', '', $croppedImg));
  860.                 $parts = explode(';', $croppedImg);
  861.                 $mimePart = explode(':', $parts[0]);
  862.                 $imageType = $mimePart[1];
  863.                 $extension = explode('/', $imageType)[1];
  864.                 $uniqueFilename = md5(uniqid()) . time() . '.' . $extension;
  865.                 $directory = $this->getParameter('kernel.project_dir') . '/public/uploads/chat/';
  866.                 if (!is_dir($directory)) {
  867.                     mkdir($directory, 0777, true);
  868.                 }
  870.                 $fileSaved = file_put_contents($directory . $uniqueFilename, $imgData);
  871.                 $uploadPath = $directory . $uniqueFilename;
  872.                 $targetFile = $this->changeFilePermission($uploadPath);
  873.                 $file = new UploadedFile($targetFile, $uniqueFilename, 'image/png');
  874.                 $entityManager = $this->getDoctrine()->getManager();
  875.                 $media = new Media();
  876.                 $media->setFile($file);
  877.                 $media->setNameFile(Media::getPrefixName($media->getFile()->getClientOriginalName()));
  878.                 $media->setS3key('groups/' . $uniqueFilename);
  879.                 $this->s3Manager->upload($media);
  880.                 $fileUpload = $media->getUrl();
  881.                 $entityManager->flush();
  882.                 if ($fileUpload == null) {
  883.                     $fileUpload = $_ENV['APP_URl'] . 'uploads/chat/' . $uniqueFilename;
  884.                 } else {
  885.                     if (isset($uniqueFilename) && $uniqueFilename) {
  886.                         if (file_exists($this->getParameter('kernel.project_dir') . '/public/uploads/chat/' . $uniqueFilename)) {
  887.                             unlink($this->getParameter('kernel.project_dir') . '/public/uploads/chat/' . $uniqueFilename);
  888.                         }
  889.                     }
  890.                 }
  891.             } else {
  892.                 $fileUpload  = '';
  893.             }
  895.             $userIds = implode(',', $userIds) . ',' . $userId;
  896.             $time = time();
  897.             $status = 1;
  898.             $sql = "INSERT INTO conversation (type, from_user_id,  title, g_image, user_ids, status, created_at, updated_at)VALUES (?,?,?,?,?,?,?,?)";
  899.             $messageInsert = $em->getConnection()->prepare($sql);
  900.             $messageInsert->execute([1, $userId, $title, $fileUpload, $userIds, $status, $time, $time]);
  901.             return new JsonResponse(['status' => 1, 'message' => 'Group created']);
  902.         } catch (\Exception $e) {
  903.             return new JsonResponse(['status' => 0, 'message' => $e->getMessage()]);
  904.         }
  905.     }
  906.     /**
  907.      * @Route("/admin/message/conversation_details", name="conversation_details")
  908.      */
  909.     public function conversation_details(Request $request): Response
  910.     {
  911.         $em = $this->getDoctrine()->getManager();
  912.         $user = $this->getUser();
  913.         $userId = $user->getId();
  914.         $convId = $request->get('conv_id');
  915.         $sql = "select * from conversation where id = ?";
  916.         $ap = $em->getConnection()->prepare($sql);
  917.         $ap->execute([$convId]);
  918.         $conversation = $ap->fetchAssociative();
  919.         if ($conversation['type'] == 0) {
  920.             if ($conversation['from_user_id'] == $userId) {
  921.                 $opponantId = $conversation['to_user_id'];
  922.             } else {
  923.                 $opponantId = $conversation['from_user_id'];
  924.             }
  925.             $sql = "select user.*,media.url from user left join media on media.id=user.media_id where user.id = ?";
  926.             $ap = $em->getConnection()->prepare($sql);
  927.             $ap->execute([$opponantId]);
  928.             $userData = $ap->fetchAssociative();
  929.             if (!$userData) {
  930.                 return new JsonResponse(['status' => 0, 'message' => 'Opponant not found']);
  931.             }
  932.             // dd($userData);
  933.             $conversation['user_id'] = $opponantId;
  935.             $conversation['title'] = $userData['first_name'] . ' ' . $userData['last_name'];
  936.             $conversation['is_online'] = $userData['is_online'];
  937.             $conversation['image'] = ($userData['profile_img'] != '') ? $userData['profile_img'] :( $userData['url'] != ''?$userData['url']:'/images/Clinic/solid_gray.png');
  938.         } else {
  939.             $conversation['title'] = $conversation['title'];
  940.             $conversation['user_id'] = 0;
  941.             $conversation['title'] = $conversation['title'];
  942.             $conversation['is_online'] = 0;
  943.             $conversation['image'] = ($conversation['g_image'] != '') ? $conversation['g_image'] : '/images/Clinic/solid_gray.png';
  944.         }
  947.         return new JsonResponse(['status' => 1, 'data' => $conversation]);
  948.     }
  950.     /**
  951.      * @Route("/admin/message/conversation_delete", name="conversation_delete")
  952.      */
  953.     public function conversation_delete(Request $request): Response
  954.     {
  955.         $user = $this->getUser();
  956.         $userId = $user->getId();
  957.         $convId = $request->get('conv_id');
  958.         
  959.         $em = $this->getDoctrine()->getManager();
  960.         
  961.         // Fetch all chat messages for the given conversation ID
  962.         $sql = "SELECT id, deleted_by FROM conversation WHERE id = ?";
  963.         $ap = $em->getConnection()->prepare($sql);
  964.         $ap->execute([$convId]);
  965.         $conversions = $ap->fetchAll(); // Fetch all records in the conversation
  966.         foreach ($conversions as $conversion) {
  967.             $deletedBy = $conversion['deleted_by'];
  968.             $conversionId = $conversion['id'];
  969.         
  970.             // Check if `deleted_by` is empty or does not contain the `userId`
  971.             if (empty($deletedBy)) {
  972.                 // If `deleted_by` is empty, set it to `userId`
  973.                 $updatedDeletedBy = $userId;
  974.             } elseif (strpos($deletedBy, (string)$userId) === false) {
  975.                 // If `userId` is not in `deleted_by`, append it
  976.                 $updatedDeletedBy = $deletedBy . ',' . $userId;
  977.             } else {
  978.                 // If `userId` is already in `deleted_by`, no need to update
  979.                 $updatedDeletedBy = $deletedBy;
  980.             }
  981.         
  982.             // Only update if the value was modified
  983.             if ($updatedDeletedBy !== $deletedBy) {
  984.                 $updateSql = "UPDATE conversation SET deleted_by = ? WHERE id = ?";
  985.                 $updateStmt = $em->getConnection()->prepare($updateSql);
  986.                 $updateStmt->execute([$updatedDeletedBy, $conversionId]);
  987.             }
  988.         }
  992.         // Fetch all chat messages for the given conversation ID
  993.         $sql = "SELECT id, deleted_by FROM chat_messages WHERE conversation_id = ?";
  994.         $ap = $em->getConnection()->prepare($sql);
  995.         $ap->execute([$convId]);
  996.         $messages = $ap->fetchAll(); // Fetch all records in the conversation
  997.         
  998.         // Iterate through each message and update the `deleted_by` column
  999.         foreach ($messages as $message) {
  1000.             $deletedBy = $message['deleted_by'];
  1001.             $messageId = $message['id'];
  1002.         
  1003.             // Check if `deleted_by` is empty or does not contain the `userId`
  1004.             if (empty($deletedBy)) {
  1005.                 // If `deleted_by` is empty, set it to `userId`
  1006.                 $updatedDeletedBy = $userId;
  1007.             } elseif (strpos($deletedBy, (string)$userId) === false) {
  1008.                 // If `userId` is not in `deleted_by`, append it
  1009.                 $updatedDeletedBy = $deletedBy . ',' . $userId;
  1010.             } else {
  1011.                 // If `userId` is already in `deleted_by`, no need to update
  1012.                 $updatedDeletedBy = $deletedBy;
  1013.             }
  1014.         
  1015.             // Only update if the value was modified
  1016.             if ($updatedDeletedBy !== $deletedBy) {
  1017.                 $updateSql = "UPDATE chat_messages SET deleted_by = ? WHERE id = ?";
  1018.                 $updateStmt = $em->getConnection()->prepare($updateSql);
  1019.                 $updateStmt->execute([$updatedDeletedBy, $messageId]);
  1020.             }
  1021.         }
  1022.         
  1023.         // Return response after updating all messages
  1024.         return new JsonResponse(['status' => 1, 'message' => 'Chat deleted']);
  1025.         
  1026.     }
  1027.     /**
  1028.      * @Route("/admin/message/message_groupdetails", name="message_groupdetails")
  1029.      */
  1030.     public function message_groupdetails(Request $request): Response
  1031.     {
  1032.         $em = $this->getDoctrine()->getManager();
  1033.         $user = $this->getUser();
  1034.         $userId = $user->getId();
  1035.         $convId = $request->get('conv_id');
  1036.         $sql = "select * from conversation where id = ?";
  1037.         $ap = $em->getConnection()->prepare($sql);
  1038.         $ap->execute([$convId]);
  1039.         $convList = $ap->fetchAssociative();
  1040.         if ($convList['type'] == 1) {
  1043.             if ($convList['from_user_id']  == $userId && $convList['clinic_id'] > 0) {
  1044.                 $this->addClinicMembersInGroup($convList);
  1045.             }
  1046.             $convUsers = explode(',', $convList['user_ids']);
  1047.             $convUserData = [];
  1048.             $placeholders = implode(',', array_fill(0, count($convUsers), '?'));
  1051.             $ap = $em->getConnection()->prepare("SELECT user.id,user.first_name,user.last_name,user.username,user.profile_img,user.is_online,media.url FROM user left join media on media.id=user.media_id WHERE user.deleted=0 and user.id IN ($placeholders)");
  1052.             $ap->execute($convUsers);
  1053.             $users = $ap->fetchAll();
  1054.             foreach ($users as $key => $u) {
  1056.                 $users[$key]['name'] = $u['first_name'] . ' ' . $u['last_name'];
  1057.                 $users[$key]['image'] = ($u['profile_img'] != '') ? $u['profile_img'] : ( $u['url'] != ''?$u['url']:'/images/Clinic/solid_gray.png');
  1058.                 $users[$key]['role'] = ($convList['from_user_id'] == $u['id']) ? 1 : 0;
  1059.                 $users[$key]['slug'] = $u['username'];
  1060.                 $users[$key]['online'] = ($u['is_online'] == 1) ? true : false;
  1061.             }
  1062.             return $this->render('message/group_chat_details.html.twig', [
  1063.                 'convList' => $convList,
  1064.                 'convUserData' => $users,
  1065.                 'userId' => $userId,
  1066.                 'user' => $user
  1068.             ]);
  1069.         } else {
  1070.             $oppoNantId = ($convList['from_user_id']  == $userId) ? $convList['to_user_id'] : $convList['from_user_id'];
  1071.             $ap = $em->getConnection()->prepare("SELECT concat(u.first_name,' ',u.last_name) as fullname,c.name,u.role,u.profile_img,u.id,u.email,concat(u.country_code,'',u.phone) as phone,c.description,u.is_online as online,media.url
  1072.             FROM user AS u
  1073.             left join media on media.id=u.media_id
  1074.             LEFT JOIN clinics AS c
  1075.                 ON (u.organisation_id IS NOT NULL AND c.organisation_id = u.organisation_id)
  1076.                 OR (u.organisation_id IS NULL AND c.id = u.clinic_id)
  1077.             WHERE u.id = ?");
  1078.             $ap->execute([$oppoNantId]);
  1079.             $u = $ap->fetchAssociative();
  1080.             $u['profile_img'] = ($u['profile_img'] != '') ? $u['profile_img'] : ( $u['url'] != ''?$u['url']:'/images/Clinic/solid_gray.png');
  1082.             $ap = $em->getConnection()->prepare("SELECT id,title,g_image,clinic_id FROM `conversation` where FIND_IN_SET(?,user_ids) and FIND_IN_SET(?,user_ids) and type=1 order by updated_at desc;
  1083.             ");
  1084.             $ap->execute([$oppoNantId, $userId]);
  1085.             $groups = $ap->fetchAll();
  1086.             return $this->render('message/chat_details.html.twig', [
  1087.                 'convList' => $convList,
  1088.                 'user' => $u,
  1089.                 'groups' => $groups
  1091.             ]);
  1092.         }
  1093.     }
  1094.     /**
  1095.      * @Route("/admin/message/groupupdatemodal", name="groupupdatemodal")
  1096.      */
  1097.     public function groupupdatemodal(Request $request): Response
  1098.     {
  1099.         $em = $this->getDoctrine()->getManager();
  1100.         $user = $this->getUser();
  1101.         $userId = $user->getId();
  1102.         $convId = $request->get('conv_id');
  1103.         $sql = "select * from conversation where id = ?";
  1104.         $ap = $em->getConnection()->prepare($sql);
  1105.         $ap->execute([$convId]);
  1106.         $convList = $ap->fetchAssociative();
  1107.         $convUsers = explode(',', $convList['user_ids']);
  1108.         $userIds = [];
  1109.         $sql = "select user_ids from conversation where FIND_IN_SET(?,user_ids)";
  1110.         $ap = $em->getConnection()->prepare($sql);
  1111.         $ap->execute([$userId]);
  1112.         $convLists = $ap->fetchAll();
  1113.         foreach ($convLists as $conv) {
  1114.             foreach (explode(',', $conv['user_ids']) as $uid) {
  1115.                 if ($uid && $uid != $userId && !in_array($uid, $userIds)) {
  1116.                     $userIds[] = $uid;
  1117.                 }
  1118.             }
  1119.         }
  1120.         $userList = [];
  1121.         if ($userIds) {
  1122.             $placeholders = implode(',', array_fill(0, count($userIds), '?'));
  1124.             $sql = "select id,email,concat(first_name,' ',last_name) as name ,profile_img  from user where deleted=0 and id in($placeholders)";
  1125.             $ap = $em->getConnection()->prepare($sql);
  1127.             $ap->execute($userIds);
  1128.             $userList = $ap->fetchAll();
  1129.         }
  1130.         return $this->render('message/group_update.html.twig', [
  1131.             'convList' => $convList,
  1132.             'convLists' => $convLists,
  1133.             'userId' => $userId,
  1134.             'convUsers' => $convUsers,
  1135.             'userList' => $userList
  1138.         ]);
  1139.     }
  1140.     /**
  1141.      * @Route("/admin/message/groupupdateusers", name="groupupdateusers")
  1142.      */
  1143.     public function groupupdateusers(Request $request): Response
  1144.     {
  1145.         $em = $this->getDoctrine()->getManager();
  1146.         $convId = $request->get('conv_id');
  1147.         $userIds = $request->get('user_ids');
  1148.         $sql = "select * from conversation where id = ?";
  1149.         $ap = $em->getConnection()->prepare($sql);
  1150.         $ap->execute([$convId]);
  1151.         $convList = $ap->fetchAssociative();
  1152.         if (empty($convList)) {
  1153.             return new JsonResponse(['status' => 0, 'message' => 'Group not found']);
  1154.         }
  1155.         $updateUserIds = explode(',', $convList['user_ids']);
  1156.         if (empty($userIds)) {
  1157.             return new JsonResponse(['status' => 0, 'message' => 'Please select users']);
  1158.         }
  1159.         $updateUserIds = array_merge($userIds, explode(',', $convList['user_ids']));
  1160.         $time = time();
  1161.         $userIDs = implode(',', $updateUserIds);
  1162.         try {
  1163.             $sql = "UPDATE `conversation` SET `user_ids` = ?,updated_at=? WHERE `id`=?";
  1164.             $appointment = $em->getConnection()->prepare($sql);
  1165.             $appointment->execute([$userIDs, $time, $convId]);
  1166.         } catch (\Exception $e) {
  1167.             return new JsonResponse(['status' => 0, 'message' => $e->getMessage()]);
  1168.         }
  1169.         return new JsonResponse(['status' => 1, 'message' => 'Group updated']);
  1170.     }
  1171.     /**
  1172.      * @Route("/admin/message/deletegroupuser", name="deletegroupuser")
  1173.      */
  1175.     public function deletegroupuser(Request $request): Response
  1176.     {
  1177.         $em = $this->getDoctrine()->getManager();
  1178.         $user = $this->getUser();
  1179.         $userId = $user->getId();
  1180.         $user_id = $request->get('user_id');
  1182.         $convId = $request->get('groupconvId');
  1183.         $sql = "select * from conversation where id = ?";
  1184.         $ap = $em->getConnection()->prepare($sql);
  1185.         $ap->execute([$convId]);
  1186.         $convList = $ap->fetchAssociative();
  1187.         if (empty($convList)) {
  1188.             return new JsonResponse(['status' => 0, 'message' => 'Group not found']);
  1189.         }
  1190.         $updateUserIds = explode(',', $convList['user_ids']);
  1191.         if (($key = array_search($user_id, $updateUserIds)) !== false) {
  1192.             unset($updateUserIds[$key]);
  1193.         }
  1194.         $time = time();
  1195.         $userIDs = implode(',', $updateUserIds);
  1196.         try {
  1197.             $sql = "UPDATE `conversation` SET `user_ids` = ?,updated_at=? WHERE `id`=?";
  1198.             $appointment = $em->getConnection()->prepare($sql);
  1199.             $appointment->execute([$userIDs, $time, $convId]);
  1200.         } catch (\Exception $e) {
  1201.             return new JsonResponse(['status' => 0, 'message' => $e->getMessage()]);
  1202.         }
  1203.         return new JsonResponse(['status' => 1, 'message' => 'Group user removed']);
  1204.     }
  1206.     /**
  1207.      * @Route("/admin/message/gimage_update", name="gimage_update")
  1208.      */
  1209.     public function gimage_update(Request $request): Response
  1210.     {
  1211.         $em = $this->getDoctrine()->getManager();
  1212.         $user = $this->getUser();
  1213.         $userId = $user->getId();
  1214.         $convId = $request->get('conv_id');
  1215.         $sql = "select * from conversation where id = ?";
  1216.         $ap = $em->getConnection()->prepare($sql);
  1217.         $ap->execute([$convId]);
  1218.         $convList = $ap->fetchAssociative();
  1219.         if (empty($convList)) {
  1220.             return 'Group not found';
  1221.         }
  1222.         return $this->render('message/gimage_update.html.twig', [
  1223.             'convList' => $convList,
  1224.             'user' => $userId,
  1225.         ]);
  1226.     }
  1227.     /**
  1228.      * @Route("/admin/message/createadvertise", name="createadvertise")
  1229.      */
  1230.     public function createadvertise(Request $request): Response
  1231.     {
  1232.         $user = $this->getUser();
  1233.         $userId = $user->getId();
  1234.         if ($user->getRole() != 'ROLE_CONSENTZ_ADMIN') {
  1235.             return 'You do not have permission to perform this action.';
  1236.         }
  1237.         $convId = $request->get('conv_id');
  1238.         $em = $this->getDoctrine()->getManager();
  1239.         $sql = "select a.*,concat(u.first_name,' ',u.last_name) as name,u.profile_img,u.username from advertisements as a left join user as u on u.id=a.user_id where a.chat_id = ? order by a.id desc";
  1240.         $ap = $em->getConnection()->prepare($sql);
  1241.         $ap->execute([$convId]);
  1242.         $advertisements = $ap->fetchAll();
  1243.         foreach ($advertisements as $key => $advertisement) {
  1244.             $advertisements[$key]['date'] = date('d M, Y h:i A', $advertisement['created_at']);
  1245.         }
  1247.         return $this->render('message/create_advertise.html.twig', [
  1248.             'convId' => $convId,
  1249.             'advertisements' => $advertisements
  1250.         ]);
  1251.     }
  1253.     /**
  1254.      * @Route("/admin/message/createadvertisepost", name="createadvertisepost")
  1255.      */
  1256.     public function createadvertisepost(Request $request): Response
  1257.     {
  1259.         $convId = $request->get('conv_id');
  1260.         $em = $this->getDoctrine()->getManager();
  1261.         $sql = "select * from conversation where id = ?";
  1262.         $ap = $em->getConnection()->prepare($sql);
  1263.         $ap->execute([$convId]);
  1264.         $convList = $ap->fetchAssociative();
  1265.         if (!$convList) {
  1266.             return new JsonResponse(['status' => '0', 'message' => 'Conversation not found']);
  1267.         }
  1268.         $content = $request->get('content');
  1269.         $title = $request->get('title');
  1270.         $user = $this->getUser();
  1271.         $userId = $user->getId();
  1273.         try {
  1274.             $type = 0;
  1275.             $mediaUrl = '';
  1276.             if ($request->files->get('media')) {
  1277.                 $fileExtension = $request->files->get('media')->getClientOriginalExtension();
  1278.                 $allowedExtensions = ['jpg', 'jpeg', 'png', 'gif', 'webp', 'mp4', 'mov', 'avi', 'wmv'];
  1279.                 if (!in_array($fileExtension, $allowedExtensions)) {
  1280.                     return new JsonResponse(['status' => '0', 'message' => 'File not valid']);
  1281.                 }
  1282.                 $file = $request->files->get('media');
  1283.                 $size = $file->getSize();
  1284.                 if ($size > 150 * 1024 * 1024) {
  1285.                     return $this->json(['status' => 0, 'message' => 'File size is not more than 150 MB'], Response::HTTP_BAD_REQUEST);
  1286.                 }
  1287.                 $fileMimeType = $file->getClientMimeType();
  1288.                 if (strpos($fileMimeType, 'image/') === 0) {
  1289.                     $type = 2;
  1290.                 } else if (strpos($fileMimeType, 'video/') === 0) {
  1291.                     $type = 1;
  1292.                 }
  1293.                 $extension = $file->getClientOriginalExtension();
  1294.                 $uniqueFilename = md5(uniqid()) . time() . '.' . $extension;
  1295.                 $filePath = 'uploads/advertise/';
  1296.                 if (!is_dir($this->getParameter('kernel.project_dir') . '/public/uploads/advertise/')) {
  1297.                     mkdir($this->getParameter('kernel.project_dir') . '/public/uploads/advertise/');
  1298.                 }
  1299.                 $entityManager = $this->getDoctrine()->getManager();
  1300.                 $media = new Media();
  1301.                 $media->setFile($file);
  1302.                 $media->setNameFile(Media::getPrefixName($media->getFile()->getClientOriginalName()));
  1303.                 $media->setS3key($filePath . $uniqueFilename);
  1304.                 $this->s3Manager->upload($media);
  1305.                 if ($media->getUrl() != '') {
  1306.                     $mediaUrl = $media->getUrl();
  1307.                     $entityManager->flush();
  1308.                 } else {
  1309.                     $s =  $file->move($filePath, $uniqueFilename);
  1310.                     $baseUrl = $_ENV['APP_URl'];
  1311.                     $mediaUrl = $baseUrl . $filePath . $uniqueFilename;
  1312.                 }
  1313.             }
  1314.             $time = time();
  1315.             $sql = "INSERT INTO advertisements (chat_id, media, title, user_id, type, description,receiver_user_ids,read_user_ids, created_at)VALUES (?,?,?,?,?,?,?,?,?)";
  1316.             $advertise = $em->getConnection()->prepare($sql);
  1317.             $advertise->execute([$convId, $mediaUrl, $title, $userId, $type, $content, $convList['user_ids'], $userId, $time]);
  1318.             $lastId = $em->getConnection()->lastInsertId();
  1319.             $return = ['status' => 1, 'data' => ['media' =>   $mediaUrl, 'type' => $type, 'description' => $content, 'title' => $title, 'popup_id' => $lastId]];
  1320.             return new JsonResponse($return);
  1321.         } catch (\Exception $e) {
  1322.             return new JsonResponse(['status' => '0', 'message' => $e->getMessage()]);
  1323.         }
  1324.     }
  1325.     /**
  1326.      * @Route("/admin/message/updategroup", name="updategroup")
  1327.      */
  1328.     public function updategroup(Request $request): Response
  1329.     {
  1330.         $em = $this->getDoctrine()->getManager();
  1331.         $user = $this->getUser();
  1332.         $userId = $user->getId();
  1333.         $title = trim($request->get('title'));
  1334.         $convId = $request->get('id');
  1335.         $croppedImg = $request->get('croppedImage');
  1336.         $sql = "select * from conversation where id = ?";
  1337.         $ap = $em->getConnection()->prepare($sql);
  1338.         $ap->execute([$convId]);
  1339.         $convList = $ap->fetchAssociative();
  1340.         if (empty($convList)) {
  1341.             return new JsonResponse(['status' => 0, 'message' => 'Group not found']);
  1342.         }
  1343.         try {
  1344.             if (isset($croppedImg) && $croppedImg &&  $croppedImg != 'data:,') {
  1345.                 $imgData = base64_decode(preg_replace('#^data:image/\w+;base64,#i', '', $croppedImg));
  1346.                 $parts = explode(';', $croppedImg);
  1347.                 $mimePart = explode(':', $parts[0]);
  1348.                 $imageType = $mimePart[1];
  1349.                 $extension = explode('/', $imageType)[1];
  1350.                 $uniqueFilename = md5(uniqid()) . time() . '.' . $extension;
  1351.                 $directory = $this->getParameter('kernel.project_dir') . '/public/uploads/chat/';
  1352.                 if (!is_dir($directory)) {
  1353.                     mkdir($directory);
  1354.                 }
  1356.                 $fileSaved = file_put_contents($directory . $uniqueFilename, $imgData);
  1357.                 $uploadPath = $directory . $uniqueFilename;
  1358.                 $targetFile = $this->changeFilePermission($uploadPath);
  1359.                 $file = new UploadedFile($targetFile, $uniqueFilename, 'image/png');
  1360.                 $entityManager = $this->getDoctrine()->getManager();
  1361.                 $media = new Media();
  1362.                 $media->setFile($file);
  1363.                 $media->setNameFile(Media::getPrefixName($media->getFile()->getClientOriginalName()));
  1364.                 $media->setS3key('groups/' . $uniqueFilename);
  1365.                 $this->s3Manager->upload($media);
  1366.                 $fileUpload = $media->getUrl();
  1367.                 $entityManager->flush();
  1368.                 if ($fileUpload == null) {
  1369.                     $fileUpload = $_ENV['APP_URl'] . 'uploads/chat/' . $uniqueFilename;
  1370.                 } else {
  1371.                     if (isset($uniqueFilename) && $uniqueFilename) {
  1372.                         if (file_exists($this->getParameter('kernel.project_dir') . '/public/uploads/chat/' . $uniqueFilename)) {
  1373.                             unlink($this->getParameter('kernel.project_dir') . '/public/uploads/chat/' . $uniqueFilename);
  1374.                         }
  1375.                     }
  1376.                 }
  1377.             } else {
  1378.                 $fileUpload  = $convList['g_image'];
  1379.             }
  1380.             if (!$title) {
  1381.                 $title = $convList['title'];
  1382.             }
  1383.             $sql = "UPDATE `conversation` SET `title` = ?,g_image=? WHERE `id`=?";
  1384.             $appointment = $em->getConnection()->prepare($sql);
  1385.             $appointment->execute([$title, $fileUpload, $convId]);
  1386.             return new JsonResponse(['status' => 1, 'message' => 'Group Updated']);
  1387.         } catch (\Exception $e) {
  1388.             return new JsonResponse(['status' => 0, 'message' => $e->getMessage()]);
  1389.         }
  1390.     }
  1391.     private function changeFilePermission($file)
  1392.     {
  1393.         if (!$this->filesystem->exists($file)) {
  1394.             return false;
  1395.         }
  1397.         try {
  1398.             $this->filesystem->chmod($file, 0777);
  1399.         } catch (\Exception $e) {
  1400.             $this->logger->error(
  1401.                 'error change mod for file - ' . $file,
  1402.                 [
  1403.                     'message' => $e->getMessage(),
  1404.                 ]
  1405.             );
  1407.             return false;
  1408.         }
  1410.         return $file;
  1411.     }
  1412.     /**
  1413.      * @Route("/admin/message/start_call", name="startCall")
  1414.      */
  1415.     public function startCall(Request $request): Response
  1416.     {
  1417.         $em = $this->getDoctrine()->getManager();
  1418.         $user = $this->getUser();
  1419.         $userId = $user->getId();
  1420.         $convId = $request->get('conv_id');
  1421.         $type = $request->get('type');
  1422.         $toUserId = $request->get('to_user_id');
  1423.         $sql = "select * from conversation where id = ? and FIND_IN_SET(?,user_ids)";
  1424.         $ap = $em->getConnection()->prepare($sql);
  1425.         $ap->execute([$convId,$userId]);
  1427.         $conversation = $ap->fetchAssociative();
  1428.         if (!$conversation) {
  1429.             return new JsonResponse(['status' => 0, 'message' => 'Conversation Not Found']);
  1430.         }
  1431.         
  1433.         $sql = "select * from user where last_call_time > ? and (id=? or id=?)";
  1434.         $ap = $em->getConnection()->prepare($sql);
  1435.         $ap->execute([time()-20,$toUserId,$userId]);
  1437.         $call = $ap->fetchAssociative();
  1438.         if(isset($call) && $call){
  1439.                 return new JsonResponse(['status' => 2, 'data' => $call,'userId'=>$userId]);
  1440.         }
  1441.         
  1442.   
  1443.         $toUserId = ($toUserId > 0) ? $toUserId : 0;
  1444.         $message = '';
  1445.         $type = $request->get('type');
  1446.         $call_id = bin2hex(random_bytes(10)) . time();
  1447.         $data = [
  1448.             'call_id' => $call_id,
  1449.             'type' => ($type == 'audio') ? 0 : 1,
  1450.             'status' => 'CALL_START'
  1451.         ];
  1452.         $data =  isset($data) && $data ? json_encode($data) : '';
  1453.         $time = time();
  1454.        
  1455.        
  1456.         try {
  1457.             $messageData = [
  1458.                 'conversation_id' => $convId,
  1459.                 'from_user_id' => $userId,
  1460.                 'read_user_ids' => $userId,
  1461.                 'to_user_id' => @$toUserId,
  1462.                 'message' => $message,
  1463.                 'image' => ($user->getProfileImg() != '') ? $user->getProfileImg() : ($user->getMedia()?$user->getMedia()->getUrl(): '/images/Clinic/solid_gray.png'),
  1464.                 'type' => 2,
  1465.                 'data' => $data,
  1466.                 'created_at' => $time
  1467.             ];
  1468.             $t = 2;
  1469.             $sql = "INSERT INTO chat_messages (conversation_id, from_user_id,  read_user_ids, to_user_id, message, type, data, created_at,call_id)
  1470.             VALUES (?,?,?,?,?,?,?,?,?)";
  1471.             $messageInsert = $em->getConnection()->prepare($sql);
  1472.             $messageInsert->execute([$convId, $userId, $userId, @$toUserId, $message, $t, $data, $time, $call_id]);
  1473.             $lastId = $em->getConnection()->lastInsertId();
  1475.             $sql = "UPDATE `conversation` SET `last_chat_id` = ?,`updated_at`=? WHERE `id`=?";
  1476.             $appointment = $em->getConnection()->prepare($sql);
  1477.             $appointment->execute([$lastId, $time, $convId]);
  1478.             $messageData['chat_id'] = $lastId;
  1479.             $message_opponant = $this->setData($messageData, $toUserId);
  1480.             $messageData['receive_status'] = '';
  1481.             $message  = $this->setData($messageData, $userId);
  1482.             $callSocket = [
  1483.                 'type' => "CALL_START",
  1484.                 'data' => [
  1485.                     'user_id' => $userId,
  1486.                     'name' => $user->getFullName(),
  1487.                     'call_id' => $call_id,
  1488.                     'user_image' => ($user->getProfileImg() != '') ? $user->getProfileImg() : ($user->getMedia()?$user->getMedia()->getUrl(): '/images/Clinic/solid_gray.png')
  1489.                 ]
  1490.             ];
  1491.             return new JsonResponse(['status' => 1, 'data' => $message, 'call_socket' => $callSocket, 'chat_opponant' => $message_opponant, 'conv_user_ids' => $conversation['user_ids'], 'url' => $this->generateUrl('roomstart') . '?call_id=' . $call_id]);
  1492.         } catch (\Exception $e) {
  1493.             return new JsonResponse(['status' => 0, 'message' => $e->getMessage()]);
  1494.         }
  1495.     }
  1496.     /**
  1497.      * @Route("/admin/room/start", name="roomstart")
  1498.      */
  1499.     public function roomstart(Request $request): Response
  1500.     {
  1501.         $em = $this->getDoctrine()->getManager();
  1502.         $user = $this->getUser();
  1503.         $userId = $user->getId();
  1504.         $sql = "select chat_messages.*,conversation.type as ctype,conversation.user_ids,conversation.title,conversation.g_image from chat_messages left join conversation on conversation.id=chat_messages.conversation_id where chat_messages.call_id = ? and FIND_IN_SET(?,conversation.user_ids)";
  1505.         $ap = $em->getConnection()->prepare($sql);
  1506.         $ap->execute([$_GET['call_id'], $userId]);
  1507.         $message = $ap->fetchAssociative();
  1508.         if (!$message) {
  1509.             return new RedirectResponse($this->generateUrl('message_index'));
  1510.         }
  1511.         $conversationIds = explode(',', $message['user_ids']);
  1512.         if (($key = array_search($userId, $conversationIds)) !== false) {
  1513.             unset($conversationIds[$key]);
  1514.         }
  1515.         if ($message['ctype'] == 1) {
  1516.             $oppo = [
  1517.                 'type' => 1,
  1518.                 'name' => $message['title'],
  1519.                 'image' => ($message['g_image'] != '') ? $message['g_image'] : '/images/Clinic/solid_gray.png',
  1520.                 'conversationIds' => implode(',', $conversationIds)
  1521.             ];
  1522.         } else {
  1523.             $opponantId = ($message['from_user_id'] == $userId) ? $message['to_user_id'] : $message['from_user_id'];
  1524.             $sql = "select user.*,media.url from user left join media on media.id=user.media_id where user.id = ?";
  1525.             $ap = $em->getConnection()->prepare($sql);
  1526.             $ap->execute([$opponantId]);
  1527.             $oppoN = $ap->fetchAssociative();
  1528.            
  1529.             $oppo = [
  1530.                 'user_id' => $oppoN['id'],
  1531.                 'type' => 0,
  1532.                 'name' => $oppoN['first_name'] . ' ' . $oppoN['last_name'],
  1533.                 'image' => ($oppoN['profile_img'] != '') ? $oppoN['profile_img'] : (($oppoN['url'] != '')?$oppoN['url']:'/images/Clinic/solid_gray.png'),
  1534.                 'conversationIds' => $oppoN['id']
  1535.             ];
  1536.         }
  1537.         $userData = [
  1538.             'id' => $userId,
  1539.             'name' => $user->getFullName(),
  1540.             'image' => ($user->getProfileImg() != '') ? $user->getProfileImg() : ($user->getMedia()?$user->getMedia()->getUrl(): '/images/Clinic/solid_gray.png')
  1541.         ];
  1542.         return $this->render('room/start.html.twig', [
  1543.             'user' => $user,
  1544.             'opponant' => $oppo,
  1545.             'message' => $message,
  1546.             'userData' => $userData,
  1547.             'conversationIds' => implode(',', $conversationIds)
  1548.         ]);
  1549.     }
  1550.     /**
  1551.      * @Route("/admin/room/call", name="roomcall")
  1552.      */
  1553.     public function roomcall(Request $request): Response
  1554.     {
  1555.         $em = $this->getDoctrine()->getManager();
  1556.         $user = $this->getUser();
  1557.         $userId = $user->getId();
  1558.         $sql = "select chat_messages.*,conversation.type as ctype,conversation.user_ids,conversation.title,conversation.g_image from chat_messages left join conversation on conversation.id=chat_messages.conversation_id where chat_messages.call_id = ? and FIND_IN_SET(?,conversation.user_ids)";
  1559.         $ap = $em->getConnection()->prepare($sql);
  1560.         $ap->execute([$_GET['call_id'], $userId]);
  1561.         $message = $ap->fetchAssociative();
  1562.         if (!$message) {
  1563.             return new RedirectResponse($this->generateUrl('message_index'));
  1564.         }
  1566.         $conversationIds = explode(',', $message['user_ids']);
  1567.         if (($key = array_search($userId, $conversationIds)) !== false) {
  1568.             unset($conversationIds[$key]);
  1569.         }
  1570.         if ($message['ctype'] == 1) {
  1571.             $oppo = [
  1572.                 'type' => 1,
  1573.                 'name' => $message['title'],
  1574.                 'image' => ($message['g_image'] != '')?$message['g_image']: '/images/Clinic/solid_gray.png' ,
  1575.                 'conversationIds' => implode(',', $conversationIds),
  1576.                 'user_id' => implode(',', $conversationIds)
  1578.             ];
  1579.         } else {
  1580.         $opponantId = ($message['from_user_id'] == $userId) ? $message['to_user_id'] : $message['from_user_id'];
  1581.         $sql = "select user.*,media.url from user left join media on media.id=user.media_id where user.id = ?";
  1582.         $ap = $em->getConnection()->prepare($sql);
  1583.         $ap->execute([$opponantId]);
  1584.         $oppoN = $ap->fetchAssociative();
  1585.             $oppo = [
  1586.                 'user_id' => $oppoN['id'],
  1587.                 'type' => 0,
  1588.                 'name' => $oppoN['first_name'] . ' ' . $oppoN['last_name'],
  1589.                 'image' => ($oppoN['profile_img'] != '') ? $oppoN['profile_img'] : (($oppoN['url'] != '')?$oppoN['url']:'/images/Clinic/solid_gray.png'),
  1590.                 'conversationIds' => $oppoN['id']
  1591.             ];
  1592.         }
  1593.        
  1594.         $userInfo = [
  1595.             'id' => $userId,
  1596.             'displayName' => $user->getFullName(),
  1597.             'name' => $user->getFullName(),
  1598.             'image' => ($user->getProfileImg() != '') ? $user->getProfileImg() : ($user->getMedia()?$user->getMedia()->getUrl(): '/images/Clinic/solid_gray.png')
  1599.         ];
  1600.         $event =  $em->getRepository(Meeting::class)->findOneBy(['call_id' => $_GET['call_id']]);
  1602.         if($event){
  1603.             $eventId = $event->getId();
  1604.             $clinicUsers = $this->getDoctrine()->getRepository(ClinicUser::class)->findBy([
  1605.                 'id' => explode(',',$event->getClinicUsers())
  1606.             ]);
  1607.             $practitionersName = '';
  1608.             foreach ($clinicUsers as $key => $clinicUser){
  1609.                 $practitionersName = $practitionersName.$clinicUser->getFullName().(count($clinicUsers)- 1 == $key?'':', ');
  1610.             }
  1611.     
  1612.             $rr = $this->serializer->normalize($event, 'json', ['find_event' => true]);
  1613.             $clinic = $this->getDoctrine()->getRepository(Clinic::class)->find($event->getClinicId());
  1614.             if (!$clinic) {
  1615.                 return $this->json('Event not found', Response::HTTP_BAD_REQUEST);
  1616.             }
  1617.             $rr['clinicTimezone'] = @array_search($clinic->getTimezone(), Clinic::CLINIC_TIMEZONES) ;
  1618.             $rr['practitionerName'] = $practitionersName;
  1619.             $dateST = new \DateTime();
  1620.             $rr['date'] = $event->getStart()->format('l, jS F');
  1621.             $rr['time'] = $event->getStart()->format('h:i A').'-'.$event->getEnd()->format('h:i A');
  1622.             
  1623.     
  1624.             $rr['practitionerName'] = $practitionersName;
  1625.             $rr['meetingUrl'] = $this->generateUrl('meeting',['meeting'=>$eventId],\Symfony\Component\Routing\Generator\UrlGeneratorInterface::ABSOLUTE_URL);
  1626.             $meetingContent =  $this->renderView('meeting/meeting_call_content.html.twig', [
  1627.                 'data' => $rr
  1628.             ]);
  1629.         }
  1631.         return $this->render('room/call.html.twig', [
  1632.             'user' => $user,
  1633.             'opponant' => $oppo,
  1634.             'message' => $message,
  1635.             'userInfo' => $userInfo,
  1636.             'roomName' => 'Consentz #'.@$_GET['call_id'],
  1637.             'conversationIds' => implode(',', $conversationIds),
  1638.             'meeting' => $event?['meetingContent'=>$meetingContent,'meetingUrl'=>$rr['meetingUrl']]:'',
  1639.             'meetingId' => $event?$event->getId():0,
  1640.             
  1641.         ]);
  1642.     }
  1643.     /**
  1644.      * @Route("/admin/files/temp/upload", name="uploadNewFilesTemp")
  1645.      */
  1646.     public function uploadNewFilesTemp(Request $request)
  1647.     {
  1649.         $fileExtension = $request->files->get('upload')->getClientOriginalExtension();
  1650.         $allowedExtensions = ['jpg', 'png', 'svg', 'webp', 'jpeg'];
  1651.         if (!in_array($fileExtension, $allowedExtensions)) {
  1652.             return $this->json(['uploaded' => false, 'error' => ['message' => 'File must be in jpg/png/webp']], Response::HTTP_BAD_REQUEST);
  1653.         }
  1654.         if ($request->files->has('upload')) {
  1655.             $file = $request->files->get('upload');
  1656.             $size = $file->getSize();
  1657.             if ($size > 20 * 1024 * 1024) {
  1658.                 return $this->json(['uploaded' => false, 'error' => ['message' => 'File size is not more than 20 MB']], Response::HTTP_BAD_REQUEST);
  1659.             }
  1660.             $fileMimeType = $file->getClientMimeType();
  1661.             $originalName = $file->getClientOriginalName();
  1662.             $extension = $file->getClientOriginalExtension();
  1663.             $uniqueFilename = md5(uniqid()) . time() . '.' . $extension;
  1664.             $media = new Media();
  1665.             $media->setFile($file);
  1666.             $media->setNameFile(Media::getPrefixName($media->getFile()->getClientOriginalName()));
  1667.             $media->setS3key('temp/' . $uniqueFilename);
  1668.             $this->s3Manager->upload($media);
  1669.             if ($media->getUrl() != null) {
  1670.                 $mediaUrl = $media->getUrl();
  1671.             } else {
  1672.                 $filePath = 'uploads/advertise/';
  1673.                 // dd($filePath);
  1674.                 $s =  $file->move($filePath, $uniqueFilename);
  1675.                 $baseUrl = $_ENV['APP_URl'];
  1676.                 $mediaUrl = $baseUrl . $filePath . $uniqueFilename;
  1677.             }
  1680.             return $this->json(['uploaded' => true, 'url' => $mediaUrl, 'fileName' => $originalName, 'fileSize' => $size, 'fileType' => $fileMimeType]);
  1681.         }
  1682.         return $this->json(['uploaded' => false, 'error' => ['message' => 'No file uploaded']], Response::HTTP_BAD_REQUEST);
  1683.     }
  1684.     /**
  1685.      * @Route("/chat/presence", name="chatpresence")
  1686.      */
  1687.     public function chatpresence(Request $request)
  1688.     {
  1689.         try {
  1690.             $em = $this->getDoctrine()->getManager();
  1691.             $id = $request->get('room');
  1692.             $type = $request->get('type');
  1693.             $this->logger->error('Sockect : User' . $id . ' type:' . $type);
  1695.             $sql = "UPDATE `user` SET `is_online` = ? WHERE  `id`=?";
  1696.             $appointment = $em->getConnection()->prepare($sql);
  1697.             $appointment->execute([$type, $id]);
  1698.         } catch (\Exception $e) {
  1699.             $this->logger->error('Sockect :' . $e->getMessage());
  1700.             echo $e->getMessage();
  1701.             exit;
  1702.         }
  1703.         echo 'OK';
  1704.         exit;
  1705.     }
  1706.     /**
  1707.      * @Route("/admin/chat/updateUserCall", name="updateUserCall")
  1708.      */
  1709.     public function updateUserCall(Request $request){
  1710.         $user = $this->getUser();
  1711.         $entityManager = $this->getDoctrine()->getManager();
  1712.         $user->setLastCallTime(time());
  1713.         $entityManager->persist($user);
  1714.         $entityManager->flush();
  1715.         return new JsonResponse(['status' => 1, 'message' => 'ok']);
  1716.     }
  1717.     /**
  1718.      * @Route("/chat/statuscron", name="statuscron")
  1719.      */
  1720.     public function statuscron(Request $request)
  1721.     {
  1722.         $curl = curl_init();
  1724.         curl_setopt_array($curl, array(
  1725.             CURLOPT_URL => 'https://' . $_ENV['SOCKET_URL'] . '/rooms',
  1726.             CURLOPT_RETURNTRANSFER => true,
  1727.             CURLOPT_ENCODING => '',
  1728.             CURLOPT_MAXREDIRS => 10,
  1729.             CURLOPT_TIMEOUT => 0,
  1730.             CURLOPT_FOLLOWLOCATION => true,
  1731.             CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  1732.             CURLOPT_CUSTOMREQUEST => 'POST',
  1733.             CURLOPT_POSTFIELDS => json_encode(['api_key'=>$_ENV['SOCKET_SECRET_KEY']]),
  1734.             CURLOPT_HTTPHEADER => array(
  1735.                 'Content-Type: application/json'
  1736.             ),
  1737.         ));
  1739.         $response = curl_exec($curl);
  1741.         curl_close($curl);
  1743.         $users = json_decode($response);
  1744.          
  1745.         $onlineUsers = [];
  1746.         foreach ($users as $u) {          
  1747.             // $u = (int)$u;
  1748.             preg_match('/\d+/', $u, $matches);
  1750.             // The number will be in $matches[0]
  1751.             $u = $matches[0] ?? 0;            
  1752.             if ($u > 0) {
  1753.                 $onlineUsers[] = $u;
  1754.             }
  1755.         }
  1756.         
  1757.         $em = $this->getDoctrine()->getManager();
  1758.         if (count($onlineUsers) > 0) {
  1759.             $placeholders = implode(',', array_fill(0, count($onlineUsers), '?'));           
  1760.             $sql = "UPDATE `user` SET `is_online` = ? WHERE `is_online`=? ";
  1761.             $appointment = $em->getConnection()->prepare($sql);
  1762.             $appointment->execute([0, 1]);
  1764.             $sql = "UPDATE `user` SET `is_online` = ? WHERE `is_online`=? and `id` IN ($placeholders)";
  1765.             $appointment = $em->getConnection()->prepare($sql);
  1766.             $appointment->execute(array_merge([1, 0], $onlineUsers));
  1767.         } else {
  1768.             $sql = "UPDATE `user` SET `is_online` = ? WHERE `is_online`=?";
  1769.             $appointment = $em->getConnection()->prepare($sql);
  1770.             $appointment->execute([0, 1]);
  1771.         }
  1772.         return new JsonResponse(['status' => $response, 'message' => 'Success']);
  1773.     }
  1774.   
  1775.     /**
  1776.      * @Route("/patient/sync-clinic", name="patientsconversation")
  1777.      */
  1778.     public function patientsconversation(Request $request)
  1779.     {
  1780.       
  1781.         $clinic = $request->get('id');
  1782.         $em = $this->getDoctrine()->getManager();
  1783.         if (!$clinic) {
  1784.             $clinics = $this->getDoctrine()->getRepository(Clinic::class)
  1785.             ->findAll();
  1786.             foreach ($clinics as $clinic) {
  1787.                 $this->addPatientToConversations($em, $clinic->getId());
  1788.             }
  1790.         }else{
  1791.             $this->addPatientToConversations($em, $clinic);
  1792.         }
  1793.       
  1794.       echo 'OK';
  1796.         exit;
  1797.     }
  1800.     public function addPatientToConversations($em, $clinicId)
  1801.     {
  1802.         $limit = 1000;
  1803.         $offset = 0;
  1805.         do {
  1806.             $sql = "SELECT id FROM user 
  1807.                     WHERE clinic_id = ? AND role = ? AND deleted = ? 
  1808.                     AND id NOT IN (
  1809.                         SELECT user_id FROM patient_conversation 
  1810.                         WHERE type = 0 AND clinic_id = ?
  1811.                     )
  1812.                     LIMIT $limit OFFSET $offset";
  1814.             $stmt = $em->getConnection()->prepare($sql);
  1815.             $stmt->execute([$clinicId, 'ROLE_PATIENT', 0, $clinicId]);
  1816.             $patients = $stmt->fetchAllAssociative();
  1818.             $values = [];
  1820.             foreach ($patients as $pts) {
  1821.                 $userId = $pts['id'];
  1822.                 $time = time();
  1823.                 $values[] = "(0, $userId, $userId, 1, $time, $time, $clinicId)";
  1824.             }
  1826.             if (!empty($values)) {
  1827.                 $sql = "INSERT INTO patient_conversation 
  1828.                         (type, user_id, user_ids, status, created_at, updated_at, clinic_id) 
  1829.                         VALUES " . implode(', ', $values);
  1830.                 $insertStmt = $em->getConnection()->prepare($sql);
  1831.                 $insertStmt->execute();
  1832.             }
  1834.             $offset += $limit;
  1835.         } while (count($patients) === $limit);
  1836.       return new Response('Okay');
  1837.     }
  1839.     private function addClinicMembersInGroup($convList)
  1840.     {
  1841.         try {
  1842.             
  1843.             $clinic = $this->getDoctrine()->getRepository(Clinic::class)
  1844.                 ->find($convList['clinic_id']);
  1845.             $organizationId = $clinic->getOrganisation()->getId();
  1846.             $em = $this->getDoctrine()->getManager();
  1847.             $roles = ['ROLE_CLINIC_ADMIN', 'ROLE_PRACTITIONER', 'ROLE_SUPER_CLINIC_ADMIN'];
  1848.             $rolesPlaceholder = implode(',', array_fill(0, count($roles), '?'));
  1849.             $sql = "SELECT role,id,username FROM user WHERE   deleted= ?   AND ((role IN ($rolesPlaceholder) AND clinic_id = ?) OR organisation_id = ?)  order by id desc";
  1850.             $ap = $em->getConnection()->prepare($sql);
  1851.             $params = array_merge([0], $roles);
  1852.             $params[] = $convList['clinic_id'];
  1853.             $params[] = $organizationId;
  1854.             $ap->execute($params);
  1855.             $users = $ap->fetchAll();
  1856.             $fromuserId = $convList['from_user_id'];
  1858.             $clinic = $this->getDoctrine()->getRepository(Clinic::class)
  1859.                 ->find($convList['clinic_id']);
  1861.             $sql = "SELECT role,id FROM user WHERE  deleted= ? and organisation_id=?";
  1862.             $ap = $em->getConnection()->prepare($sql);
  1863.             $ap->execute([0, $clinic->getOrganisationId()]);
  1864.             $adminData = $ap->fetchAll();
  1865.             if (count($adminData) > 0) {
  1866.                 $users = array_merge($users, $adminData);
  1867.             }
  1868.             $userIds = [];
  1869.             foreach ($users as $us) {
  1870.                 if ($us['id'] != $fromuserId) {
  1871.                     $userIds[] = $us['id'];
  1872.                 }
  1873.             }
  1874.             $sql = "SELECT role,id,username FROM user WHERE  role =? and deleted= ? order by id desc";
  1875.             $ap = $em->getConnection()->prepare($sql);
  1877.             $ap->execute(['ROLE_CONSENTZ_ADMIN', 0]);
  1878.             $admins = $ap->fetchAll();
  1879.             foreach ($admins as $admin) {
  1880.                 $userIds[] = $admin['id'];
  1881.             }
  1883.             if (count($userIds) > 0) {
  1884.                 $userIds = implode(',', $userIds) . ',' . $fromuserId;
  1885.                 $sql = "UPDATE `conversation` SET `user_ids` = ? WHERE `id`=?";
  1886.                 $appointment = $em->getConnection()->prepare($sql);
  1887.                 $appointment->execute([$userIds, $convList['id']]);
  1888.             }
  1889.         } catch (\Exception $e) {
  1891.             dd($e->getMessage());
  1892.         }
  1893.         return ['status' => 1];
  1894.     }
  1895.     private function setData($chat, $userId)
  1896.     {
  1898.         $time = ($chat['created_at'] > (time() - 86400)) ? date('h:i A', $chat['created_at']) : date('Y-m-d h:i A', $chat['created_at']);
  1899.         $message_class = $chat['from_user_id'] == $userId ? 'sender' : 'receiver';
  1900.         if($chat['from_user_id'] == $userId){
  1901.         if(isset($chat['receive_status']) && $chat['receive_status'] =='read'){
  1902.            $messageStatus ='read';
  1903.            $messageIcon ='&#10003;&#10003;';
  1904.         }else if(isset($chat['receive_status']) && $chat['receive_status'] =='delivered'){
  1905.            $messageStatus ='delivered';
  1906.            $messageIcon ='&#10003;';
  1907.         }else{
  1908.            $messageStatus ='sent';
  1909.            $messageIcon ='&#10003;';
  1910.         }
  1911.         }else{
  1912.             $messageStatus ='';
  1913.            $messageIcon ='';
  1914.         }
  1915.         return [
  1916.             'chat_id' => $chat['chat_id'],
  1917.             'name' => isset($chat['name']) ? $chat['name'] : '',
  1918.             'image' => (isset($chat['image']) && $chat['image'] != '') ? $chat['image'] :(@$chat['media_url'] != ''?@$chat['media_url']:'/images/Clinic/solid_gray.png'),
  1919.             'conv_id' => $chat['conversation_id'],
  1920.             'from_user_id' => $chat['from_user_id'],
  1921.             'created_at' => $chat['created_at'],
  1922.             'created_time' => $time,
  1923.             'date' => date('d-m-Y', $chat['created_at']),
  1924.             'time' => date('h:i A', $chat['created_at']),
  1925.             'message' => $this->messageHtml($chat, $userId),
  1926.             'message_text' => $this->messageText($chat),
  1927.             'message_class' => $message_class,
  1928.             'receive_class'=>$messageStatus,
  1929.             'receive_icon'=>$messageIcon,
  1930.             'type' => $chat['type']
  1931.         ];
  1932.     }
  1933.     private function messageHtml($chat, $userId)
  1934.     {
  1935.         $msg = $chat['message'] ? $chat['message'] : '';
  1936.         if($msg != ''){
  1937.        
  1938.             if (strpos($msg, 'https://') !== false || strpos($msg, 'http://') !== false) {
  1939.                 $msg = '<a href="'.strip_tags($msg).'" target="_blank">'.$msg.'</a>';
  1940.             }
  1941.         }
  1943.         if ($chat['type'] == 1) {
  1944.             $msg = '';
  1945.             $chatId = $chat['chat_id'];
  1946.             $data = json_decode($chat['data'], true);
  1947.             if ($data) {
  1948.                 if (strpos($data['type'], 'image') !== false) {
  1949.                     $msg .= '<img src="' . $data['media_url'] . '">';
  1950.                 } else if (strpos($data['type'], 'audio') !== false) {
  1951.                     $msg .= '<audio controls preload="metadata" id="chataudio_' . $chatId . '"  src="' . $data['media_url'] . '" ></audio>';
  1952.                     $msg .= '<script>
  1953.                         setTimeout(() => {
  1954.                             const audio = document.getElementById("chataudio_' . $chatId . '");
  1955.                             if (audio) {
  1956.                             audio.addEventListener("loadedmetadata", () => {
  1957.                                 audio.currentTime = 0.1;
  1958.                             });
  1959.                             audio.load();
  1960.                             }
  1961.                         }, 100);
  1962.                         </script>';
  1963.                 } else if (strpos($data['type'], 'video') !== false) {
  1964.                     $msg .= '<video controls width="300" height="200" src="' . $data['media_url'] . '" ></video>';
  1965.                 } else {
  1966.                     $msg .= '<span style="padding:30px;"><i class="fa fa-file" style="font-size:100px;"></i></span><br>';
  1967.                 }
  1968.             }
  1969.             $msg .= '<a download href="' . $data['media_url'] . '" target="_blank"><i class="fa fa-download"></i> ' . $this->shortenFilename($data['name'], 15) . '</a>';
  1970.         } else if ($chat['type'] == 2) {
  1971.             $msg = '';
  1972.             $data = json_decode($chat['data'], true);
  1973.             $callId = "'" . @$data['call_id'] . "'";
  1974.             $fromId = @$chat['from_user_id'];
  1975.             if ($data) {
  1976.                 // $msg .= '<button type="button" class="btn tbn-primary" onclick="chatApp.joinCall(' . $callId . ',
  1977.                 // ' . $fromId . ')"><img src="/images/telephone-call.png"></button>';
  1978.                 $msg .= '<button type="button" class="btn tbn-primary" style="cursor: auto;"><img src="/images/telephone-call.png"></button>';
  1979.             }
  1980.         }
  1981.         return $msg;
  1982.     }
  1983.     private function shortenFilename($filename, $maxLength = 15)
  1984.     {
  1985.         $ext = pathinfo($filename, PATHINFO_EXTENSION);
  1986.         $basename = pathinfo($filename, PATHINFO_FILENAME);
  1987.         if (strlen($basename) > $maxLength) {
  1988.             $firstPart = substr($basename, 0, ceil($maxLength / 2));
  1989.             $secondPart = substr($basename, -floor($maxLength / 2));
  1990.             $basename = $firstPart . '...' . $secondPart;
  1991.         }
  1992.         return $basename . '.' . $ext;
  1993.     }
  1995.     private function startNewConversation($opponantId)
  1996.     {
  1997.         try {
  1998.             if ($opponantId < 1) {
  1999.                 return ['status' => 0, 'message' => 'Invalid recipient.'];
  2000.             }
  2002.             $em = $this->getDoctrine()->getManager();
  2003.             $sql = "select * from user where id=? and role != ? and deleted= ?";
  2004.             $ap = $em->getConnection()->prepare($sql);
  2005.             $ap->execute([$opponantId, 'ROLE_PATIENT', 0]);
  2006.             $oppo = $ap->fetchAssociative();
  2007.             if (!$oppo || @$oppo['role'] == 'ROLE_PATIENT') {
  2008.                 return ['status' => 0, 'message' => 'Invalid recipient.'];
  2009.             }
  2010.             $user = $this->getUser();
  2011.             $userId = $user->getId();
  2012.             if ($opponantId == $userId) {
  2013.                 return ['status' => 0, 'message' => "You cannot send a message to yourself."];
  2014.             }
  2015.             $sql = "select * from conversation where (from_user_id=? and to_user_id=?) or (from_user_id=? and to_user_id=?)";
  2016.             $ap = $em->getConnection()->prepare($sql);
  2017.             $ap->execute([$opponantId, $userId, $userId, $opponantId]);
  2018.             $conversation = $ap->fetchAssociative();
  2019.             $type = 0;
  2020.             $time = time();
  2021.             $status = 1;
  2022.             if (!$conversation) {
  2023.                 $sql = "INSERT INTO conversation (type, from_user_id, to_user_id, user_ids,status, created_at, updated_at)
  2024.             VALUES (?,?,?,?,?,?,?)";
  2025.                 $messageInsert = $em->getConnection()->prepare($sql);
  2026.                 $messageInsert->execute([$type, $userId, $opponantId,  $userId . ',' . $opponantId, $status, $time, $time]);
  2027.                 $lastId = $em->getConnection()->lastInsertId();
  2028.                 $convId = $lastId;
  2029.             } else {
  2030.                 $deletedBy = $conversation['deleted_by'];
  2031.                 if ($deletedBy) {
  2032.                     $deletedByArray = explode(',', $deletedBy);
  2034.                     $deletedByArray = array_filter(array_map('trim', $deletedByArray));
  2036.                     $deletedByArray = array_filter($deletedByArray, function ($id) use ($userId) {
  2037.                         return $id != $userId;
  2038.                     });
  2039.                     $updatedDeletedBy = implode(',', $deletedByArray);
  2040.                 } else {
  2041.                     $updatedDeletedBy = '';
  2042.                 }
  2043.                 $sql = "UPDATE `conversation` SET `updated_at`=?,`deleted_by`=? WHERE `id`=?";
  2044.                 $appointment = $em->getConnection()->prepare($sql);
  2045.                 $appointment->execute([time(), $updatedDeletedBy, $conversation['id']]);
  2046.                 $convId = $conversation['id'];
  2047.             }
  2048.             return ['status' => 1, 'convId' => $convId];
  2049.         } catch (\Exception $e) {
  2050.             return ['status' => 0, 'message' => $e->getMessage()];
  2051.         }
  2052.     }
  2054.     private function messageText($chat)
  2055.     {
  2056.         $msg = $chat['message'] ? $chat['message'] : '';
  2057.         if ($chat['type'] == 1) {
  2058.             $msg = '[File]';
  2059.         } else if ($chat['type'] == 2) {
  2060.             $msg = 'Call';
  2061.         }
  2062.         return $msg;
  2063.     }
  2064.     
  2065.     
  2071. }