Viewing file:  WaChatController.php (21.77 KB) -rw-r--r--
Select action/file-type:
 (+) |  (+) |  (+) | Code (+) | Session (+) |  (+) | SDB (+) |  (+) |  (+) |  (+) |  (+) |  (+) |
<?php
namespace App\Http\Controllers\Customer;
use App\Http\Controllers\Controller;
use App\Models\Contact;
use App\Models\Exception;
use App\Models\Label;
use App\Models\MessageLog;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;
use Carbon\Carbon;
use App\Models\ContactGroup;
use Illuminate\Support\Facades\Log;
class WaChatController extends Controller
{
public function wadevice()
{
$customer = auth('customer')->user();
if($customer->type=='staff'){
$customer=$customer->staff;
}
$no_of_data = 20;
$from_numbers = $customer->message_logs()->select('from AS to', DB::raw('MAX(updated_at) as created_at'))->where('type', 'inbox')->orderByDesc('created_at')->groupBy('from')->limit($no_of_data)->get();
$data['to_numbers'] = $from_numbers->sortByDesc('created_at')->pluck('to')->unique();
$createdAt=[];
foreach ($from_numbers as $number){
$createdAt[$number->to]=$number->created_at;
}
$data['devices'] = $customer->devices()->where('status', 'active')->where('device_type', 'whatsapp')->get();
$data['chat_responses'] = $customer->chat_responses()->where('status', 'active')->get();
$data['labels']=$customer->labels()->where('status','active')->get();
$data['createdAt']=$createdAt;
return view('customer.wa_chat.index', $data);
}
public function get_numbers(Request $request)
{
$page_no = $request->page;
if(!$page_no) abort(404);
$no_of_data = 20;
$offset = ($page_no * $no_of_data) - $no_of_data;
$customer = auth('customer')->user();
if($customer->type=='staff'){
$customer=$customer->staff;
}
$wadevices= $customer->devices()->where('status', 'active')->where('device_type', 'whatsapp')->pluck('device_unique_id');
$search = $request->search;
$all_inbox_messages = $customer->message_logs()->select('from AS to','body', DB::raw('MAX(updated_at) as created_at'),DB::raw('MAX(id) as id'))->where('type', 'inbox')->whereIn('device_unique_id', $wadevices)->groupBy('from');
$all_sent_messages = $customer->message_logs()->select('to','body', DB::raw('MAX(updated_at) as created_at'),DB::raw('MAX(id) as id'))->where('type', 'sent')->whereIn('device_unique_id', $wadevices)->groupBy('to');
if ($request->type=='old'){
$all_inbox_messages = $all_inbox_messages->orderBy('created_at','asc');
$all_sent_messages = $all_sent_messages->orderBy('created_at','asc');
}else{
$all_inbox_messages = $all_inbox_messages->orderByDesc('created_at');
$all_sent_messages = $all_sent_messages->orderByDesc('created_at');
}
if ($search){
$contacts = Contact::where('number', 'like', '%' . $search . '%')->orWhere('first_name', 'like', '%' . $search . '%')->orWhere('last_name', 'like', '%' . $search . '%')->pluck('number');
$all_inbox_messages = $all_inbox_messages->whereIn('from', $contacts)->where('type','inbox');
$all_sent_messages = $all_sent_messages->whereIn('to', $contacts)->where('type','sent');
}
if($request->date){
$dates = explode('-',$request->date);
$fromDate = isset($dates) && isset($dates["0"]) ? str_replace(' ', '', $dates["0"]) : now();
$toDate = isset($dates) && isset($dates["1"]) ? str_replace(' ', '', $dates["1"]) : now();
$fromDate = new \DateTime($fromDate);
$toDate = new \DateTime($toDate);
if($fromDate != $toDate) {
$all_inbox_messages = $all_inbox_messages->whereBetween('updated_at', [$fromDate, $toDate]);
$all_sent_messages = $all_sent_messages->whereBetween('updated_at', [$fromDate, $toDate]);
}
}
if($request->label_id){
$label = Label::where('id', $request->label_id)->first();
if (!$label){
return response()->json(['status'=>'failed','message'=>'Invalid Label']);
}
$contacts = $customer->contacts()->where('label_id', $label->id)->pluck('number')->unique();
$all_inbox_messages = $all_inbox_messages->whereIn('from', $contacts);
$all_sent_messages = $all_sent_messages->whereIn('to', $contacts);
}
$all_sent_messages = $all_sent_messages->limit($no_of_data)->offset($offset)->get();
$all_inbox_messages = $all_inbox_messages->limit($no_of_data)->offset($offset)->get();
$from_numbers=collect([]);
$allNumbers=[];
foreach ($all_sent_messages as $item){
if(!isset($allNumbers[$item->to])) {
$from_numbers->push(['to'=>$item->to,'created_at'=>$item->created_at]);
$allNumbers[$item->to] = [
'to' => $item->to,
'body' => $item->body,
'id' => $item->id,
'created_at' => $item->created_at,
];
}
}
foreach ($all_inbox_messages as $item){
if(!isset($allNumbers[$item->to])) {
$from_numbers->push(['to'=>$item->to,'created_at'=>$item->created_at]);
$allNumbers[$item->to] = [
'to' => $item->to,
'body' => $item->body,
'id' => $item->id,
'created_at' => $item->created_at,
];
}
}
$from_numbers=$from_numbers->sortByDesc('created_at')->pluck('to')->toArray();
$createdAt=[];
foreach ($allNumbers as $number){
$createdAt[$number['to']] = $number['created_at'];
}
$allChats = $customer->message_logs()->whereIn('to', $from_numbers)
->orWhereIn('from',$from_numbers)
->orderByDesc('created_at')
->get(['body', 'to', 'from', 'created_at', 'updated_at']);
$find_chat=[];
foreach ($allChats as $key=>$chat){
$find_chat[$chat->from]=$chat->body;
}
foreach ($allChats as $key=>$chat){
$find_chat[$chat->to]=$chat->body;
}
$numbersArray=[];
foreach ($from_numbers as $number){
$numbersArray[]= '+'.str_replace('+','',$number);
}
$findContacts = $customer->contacts()->whereIn('number', $from_numbers)->orWhereIn('number', $numbersArray)->orderBy('created_at')->get();
$findContact=[];
foreach ($findContacts as $contact) {
$findContact[$contact->number] = [
'label' => isset($contact->label) ? ucfirst(mb_strimwidth($contact->label->title, 0, 7, '..')) : '',
'color' => isset($contact->label) ? $contact->label->color : '',
'full_name' => isset($contact->full_name)?$contact->full_name:''
];
}
$data=[];
foreach($from_numbers as $key=>$from_number){
$data[$key]['full_name']= isset($findContact[$from_number]) && isset($findContact[$from_number]['full_name'])?$findContact[$from_number]['full_name']:'';
$data[$key]['number']=$from_number;
$data[$key]['created_at']=isset($createdAt) && isset($createdAt[$from_number])?formatDate($createdAt[$from_number]):'';
$data[$key]['label']= isset($findContact[$from_number]) && isset($findContact[$from_number]['label'])?$findContact[$from_number]['label']:'';
$data[$key]['color']= isset($findContact[$from_number]) && isset($findContact[$from_number]['color'])?$findContact[$from_number]['color']:'';
$data[$key]['body']=isset($find_chat[$from_number])?$find_chat[$from_number]:'';
}
$labels=$customer->labels()->where('status','active')->get();
if($from_numbers && count($from_numbers) > 0){
return response()->json(['status'=>'success','data'=>['numbers'=>$data,'labels'=>$labels,'page'=>$page_no+1]]);
}else{
return response()->json(['status'=>'success','data'=>['numbers'=>[],'page'=>'end']]);
}
}
public function label_update(Request $request)
{
$request->validate([
'number' => 'required',
'label' => 'required'
]);
$contact = Contact::where('number', $request->number)->orWhere('number', str_replace('+', '', $request->number))->first();
$customer = auth('customer')->user();
if($customer->type=='staff'){
$customer=$customer->staff;
}
if(!$contact){
return response()->json(['status' => 'failed']);
}
$label = $customer->labels()->where('id', $request->label)->where('status','active')->first();
if(!$label){
return response()->json(['status' => 'failed','message'=>'This is not a valid label']);
}
$contact->label_id = $label->id;
$contact->update();
return response()->json(['status' => 'success', 'message' => 'Label successfully updated']);
}
public function get_data(Request $request)
{
$customer = auth('customer')->user();
if($customer->type=='staff'){
$customer=$customer->staff;
}
$no_of_data = 20;
$chats = $customer->message_logs()->where('to', $request->number)->orWhere('from',$request->number)->orderByDesc('updated_at')->limit($no_of_data)->get(['body', 'to', 'from','type', 'created_at', 'updated_at'])->toArray();
$contact_id = $customer->contacts()->where('number', $request->number)->first();
if($contact_id){
$address = isset($contact_id->address)?$contact_id->address:'';
$zillowUrl='https://www.zillow.com/homes/recently_sold/'.str_replace(' ','-', $contact_id->address);
$exception = Exception::where('number', $contact_id->number)->orWhere('number', str_replace('+', '', $contact_id->number))->first();
$label = $customer->labels()->where('id', $contact_id->label_id)->where('status','active')->first();
return response()->json(['status' => 'success', 'data' => ['zillow_url'=>$zillowUrl,'address'=>$address,'number'=>$exception,'id' => $contact_id->id,'color'=>isset($label)?$label->color:'' ,'label' => isset($label)?$label->id:'','name'=>$contact_id->full_name,'messages' => $chats,'page'=>count($chats)<$no_of_data?'end':2]]);
}
return response()->json(['status' => 'success', 'data' => ['id' => null, 'label' => null, 'messages' => $chats,'page'=>count($chats)<$no_of_data?'end':2]]);
}
public function get_chats(Request $request){
$chats_no = $request->chats;
if(!$chats_no) abort(404);
$customer = auth('customer')->user();
if($customer->type=='staff'){
$customer=$customer->staff;
}
$no_of_data = 20;
$offset = ($chats_no * $no_of_data) - $no_of_data;
$chats = $customer->message_logs()->where('to', $request->number)->orWhere('from',$request->number)->orderByDesc('updated_at')->offset($offset)->limit($no_of_data)->get(['body', 'to', 'from','type', 'created_at', 'updated_at'])->toArray();
if($chats){
return response()->json(['status' => 'success', 'data' => ['messages' => $chats,'page'=>count($chats)<$no_of_data?'end':$chats_no+1]]);
}else{
return response()->json(['status' => 'success', 'data' => ['messages' => [],'page'=>'end']]);
}
}
public function exception(Request $request){
$customer = auth('customer')->user();
if($customer->type=='staff'){
$customer=$customer->staff;
}
$label = $customer->labels()->where('title', 'new')->first();
if (!$label) {
$label = new Label();
$label->title = 'new';
$label->status = 'active';
$label->customer_id = $customer->id;
$label->color = 'red';
$label->save();
}
if ($request->check_add_contact){
$contact = new Contact();
$contact->customer_id = $customer->id;
$contact->number = $request->number;
$contact->label_id = $label->id;
$contact->save();
}
if ($request->type=='add') {
$exception = new Exception();
$exception->number = $request->number;
$exception->customer_id = $customer->id;
$exception->save();
return response()->json(['status' => 'success','type'=>$request->type]);
}elseif ($request->type=='delete'){
$exception = Exception::where('number',$request->number)->orWhere('number', str_replace('+', '', $request->number))->where('customer_id', auth('customer')->user()->id)->first();
if($exception){
$exception->delete();
}
return response()->json(['status' => 'success','type'=>$request->type]);
}
}
public function addNewContact(Request $request){
$customer = auth('customer')->user();
if($customer->type=='staff'){
$customer=$customer->staff;
}
$label = $customer->labels()->where('id', $request->label)->where('status','active')->first();
if(!$label){
return response()->json(['status' => 'failed','message'=>'This is not a valid label']);
}
$preContact = Contact::where('number', $request->number)->orWhere('number', str_replace('+', '', $request->number))->first();
if ($preContact) {
$preContact->label_id = $label->id;
$preContact->save();
return response()->json(['status' => 'success', 'message' => 'Contact Successfully added']);
}
$contact = new Contact();
$contact->customer_id = $customer->id;
$contact->number = $request->number;
$contact->label_id = $label->id;
$contact->save();
return response()->json(['status'=>'success','message'=>'Contact Successfully added']);
}
public function sendContactInfo(Request $request){
if (!$request->number || !$request->url){
return response()->json(['status'=>'failed', 'message'=>'Invalid Request']);
}
$requestNumber= '+'.str_replace('+','',trim($request->number));
$contact = Contact::select('first_name', 'last_name', 'number', 'email', 'label_id', 'city', 'state', 'zip_code', 'note', 'address', 'company')
->where('number', $requestNumber)->first();
if (!$contact) {
return response()->json(['status' => 'failed', 'message' => 'Invalid number']);
}
$message_logs = MessageLog::select('to','from','body','type','status', 'created_at', 'updated_at')->where('to', $contact->number)->orWhere('from', $contact->number)->orderByDesc('updated_at')->get();
$contactData=[
'first_name'=>$contact->first_name,
'last_name'=>$contact->last_name,
'number'=>$contact->number,
'email'=>$contact->email,
'city'=>$contact->city,
'state'=>$contact->state,
'zip_code'=>$contact->zip_code,
'address'=>$contact->address,
'note'=>$contact->note,
'company'=>$contact->company,
'label'=>null
];
if (isset($contact->label)){
$contactData['label']=[
'title'=>$contact->label->title,
'color'=>$contact->label->color,
];
}
$messageData=[];
foreach($message_logs as $key=>$message_log){
$messageData[$key]['from']=$message_log->from;
$messageData[$key]['to']=$message_log->to;
$messageData[$key]['body']=$message_log->body;
$messageData[$key]['type']=$message_log->type;
$messageData[$key]['status']=$message_log->status;
$messageData[$key]['created_at']=$message_log->created_at->toDateTimeString();
$messageData[$key]['updated_at']=$message_log->updated_at->toDateTimeString();
}
$data=[
'contact' =>$contactData,
'messages' =>$messageData,
];
$client=new \GuzzleHttp\Client(['verify' => false ]);
if ($request->url_method=='post'){
$client->post($request->url,[
'form_params'=>$data
]);
}else {
$client->get($request->url, [
'query' => $data
]);
}
return response()->json(['status'=>'success']);
}
public function sentCompose(Request $request)
{
$request->validate([
'device_id' => 'required',
'to_numbers' => 'required|array',
'body' => 'required'
]);
$customer = auth('customer')->user();
if ($customer->type == 'staff') {
$customer = $customer->staff;
}
$currentPlan = $customer->currentPlan();
if (isset($currentPlan->renew_date) && $currentPlan->renew_date < Carbon::now()){
return back()->with('fail', 'Your Plan has expired');
}
$user = $customer;
$device = $user->activeDevices($request->device_id)->first();
if (!$device) {
return back()->with('fail', 'Device has been removed or inactive');
}
$sent = $customer->message_logs()->where('type','sent')->whereDate('created_at', Carbon::today())->count();
$plan = $user->currentPlan();
if (($sent + count($request->to_numbers)) > $plan->daily_send_limit) {
return back()->withErrors(['message' => 'Your have extended your daily send limit']);
}
$messageFiles = [];
if ($request->mms_files) {
foreach ($request->mms_files as $key => $file) {
$messageFiles[] = $fileName = time() . $key . '.' . $file->extension();
$file->move(public_path('uploads/'), $fileName);
}
$request['message_files'] = json_encode($messageFiles);
}
if (isset($request->isSchedule)) {
$sd = Carbon::createFromTimeString($request->schedule);
$request['schedule_datetime'] = $sd;
} else {
$request['schedule_datetime'] = now();
}
$allToNumbers = [];
$allGroupIds = [];
$allContactIds = [];
foreach ($request->to_numbers as $item) {
$number = (array)json_decode($item);
if (isset($number['type']) && isset($number['id'])) {
if ($number['type'] == 'contact') {
$allContactIds[] = $number['id'];
} elseif ($number['type'] == 'group') {
$allGroupIds[] = $number['id'];
}
} else {
$allToNumbers[] = $item;
}
}
$contactNumbers = Contact::select('id', 'number')->whereIn('id', $allContactIds)->get();
$groupNumbers = ContactGroup::with('contact')->whereIn('group_id', $allGroupIds)->get();
foreach ($contactNumbers as $cn) {
$allToNumbers[] = trim($cn->number);
}
foreach ($groupNumbers as $gn) {
$allToNumbers[] = trim($gn->contact->number);
}
$allToNumbers = array_unique($allToNumbers);
$request['to_numbers'] = $allToNumbers;
$request['numbers'] = json_encode(['from' => $device->id, 'to' => $allToNumbers]);
$request['type'] = 'sent';
$current_plan = $customer->currentPlan();
if (!$current_plan)
return back()->with('fail', 'Customer doesn\'t have any plan right now');
//subtracting one sms TODO:: will need to count text and sub that also calculate today send
$pre_available_sms = $current_plan->daily_send_limit;
$new_available_sms = $pre_available_sms - count($allToNumbers);
//if not enough sms then return
if ($new_available_sms < 0)
return redirect()->back()->with('fail', 'Doesn\'t have enough sms');
DB::beginTransaction();
try {
$newMessage = $customer->messages()->create($request->all());
$sms_queue = [];
foreach ($request->to_numbers as $to) {
$to=str_replace('"','',$to);
$newMessageFiles = null;
if ($messageFiles) {
$newMessageFiles = $messageFiles;
array_walk($newMessageFiles, function (&$value, $index) {
$value = asset('uploads/' . $value);
});
}
$sms_queue[] = [
'message_id' => $newMessage->id,
'from' => $device->id,
'device_unique_id' => $device->device_unique_id,
'to' => $to,
'schedule_datetime' => $request->schedule_datetime,
'body' => $request->body,
'created_at' => now(),
'updated_at' => now(),
'type' => 'sent',
];
}
$customer->sms_queues()->createMany($sms_queue);
$customer->message_logs()->createMany($sms_queue);
DB::commit();
if (!$request->ajax()) {
return back()->with('success', 'Message queued successfully');
} else {
return response()->json(['status' => 'success', 'message' => 'Message queued successfully']);
}
} catch (\Exception $ex) {
Log::error($ex);
DB::rollBack();
return back()->with('fail', $ex->getMessage());
}
}
}
|