src/Controller/MessageController.php line 75

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