request = $request;
$this->prepare();
}
public function prepare(){
$this->setFields();
$userString = $this->slackUsers($this->request->get('tagging'));
$this->payload = ($this->request->has('payload')) ? $this->request->get('payload') : json_encode(array('text'=>$this->request->get('title'), "username" => (Auth::user()) ? Auth::user()->name : 'System','attachments'=>array(array('fields'=>$this->field), array('text' =>$userString))));
if($this->request->has('group') && $this->request->get('group') == 'loan_application'){
$this->endPoint = $this->cosumerappgroup;
}else if($this->request->has('group') && $this->request->get('group') == 'businessdevelopment'){
$this->endPoint = $this->businessdevelopment;
}else if($this->request->has('group') && $this->request->get('group') == 'customer_documents'){
$this->endPoint = self::$customer_documents;
}else if($this->request->has('group') && $this->request->get('group') == 'payment_collection'){
$this->endPoint = $this->payment_collection;
}else if ($this->request->has('group')){
$this->endPoint = $this->request->get('group');
}
}
public function sendCWNotif(){
$cwFactory = new CloudWatchLoggerFactory();
$_title = array('message' => $this->request->get('title'));
$_data = array_merge($_title, $this->request->get('fields'));
$cwFactory->logger(json_encode($_data));
}
public function sendCWNotifWithData($message, $data){
$cwFactory = new CloudWatchLoggerFactory();
$_title = array('message' => $message);
$_data = array_merge($_title, $data);
$cwFactory->logger(json_encode($_data));
}
public function slackUsers($user){
$userString = '';
if($user) {
$users = User::whereIn('id', $user)->get(['id', 'name', 'slack_id']);
if ($users) {
foreach ($users as $segment) {
if ($segment->slack_id) {
//$userString .= '<@' . $segment->slack_id . "|" . str_replace(' ', '',$segment->name) . '>';
$this->ms_mention_string[] = [
"id" => 0,
"mentionText" => $segment->name,
"mentioned" => [
"user" => [
"id" => $segment->slack_id,//"ae8181c7-c6a7-421d-b7b9-feb8320d122b",
"displayName" => $segment->name,
//"userPrincipalName" => "sunil@creditfair.in"
]
]
];
$this->ms_mention_string_content .= "".$segment->name."";
}
}
}
}
// Get Access Token
$this->ref_token = (new MicrosoftAuthController())->getAccessToken($this->ms_auth_user_id);
//$this->sendCWNotifWithData('Slack Message Alert', ['ref_token' => json_encode($this->ref_token), 'title' => $this->request->get('title')]);
//$this->ref_token = $userToken->access_token ?? $userToken;
//End
//return $userString ? 'Please acknowledge '.$userString : '';
return '';
}
public function setFields(){
foreach ($this->request->get('fields') as $title=>$field){
if ($title && $field)
$this->field[] = array('title' => ucwords(str_replace('_',' ',$title)), "value" => $field, "short" => true);
}
if (!$this->request->has('hide_footer') || !$this->request->get('hide_footer')) {
$this->field[] = array('title'=>'ENV', 'value' => (env('APP_CONNECTION') == 0) ? 'Staging' : 'Production','short'=>true);
}
}
public function send(){
if ($this->ms_mention_string && !$this->ref_token){
return true;
}
if (in_array($this->endPoint, [$this->payment_collection, self::$CASE_REVIEWS, self::$DISBURSEMENT_QUERY, self::$customer_documents, self::$merchant_customer_review, self::$CREDIT_DECISION, self::$PROD_TECH_BUG])){
// Pass
}else{ //in_array($this->endPoint, [self::$BIRTHDAY_REMINDER, self::$NACH_ERROR,self::$application_reminder,self::$CREDIT_DECISION,self::$customer_documents,self::$APPLICATIONS_THROUGH_CONSUMER_APP,self::$MERCHANT_ACTIVITY,self::$JUSPAY_DIGIO,self::$AVANSE_DISBURSEMENT,self::$STAGE_TESTING, self::$PROD_TECH_BUG, $this->techBug, $this->prodTechBug, self::$M_CONNECT, self::$CREDIT_DECISION, $this->businessdevelopment])
$this->sendCWNotif();
return true;
}
if ((env('APP_CONNECTION') == 0) || empty($this->endPoint)) {
$this->endPoint = $this->techBug;
return true;
}
if ($this->endPoint == $this->techBug && env('APP_CONNECTION')){
$this->endPoint = $this->prodTechBug;
return true;
}
try {
//$this->sendCWNotifWithData('Slack Message Alert', ['header' => json_encode($this->headers), 'payload' => $this->getPayload(), 'title' => $this->request->get('title')]);
$curl = curl_init();
curl_setopt_array($curl, array(
CURLOPT_URL => $this->endPoint,
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "POST",
CURLOPT_POSTFIELDS => $this->getPayload(),
CURLOPT_HTTPHEADER => $this->headers,
));
$res = curl_exec($curl);
$err = curl_error($curl);
//$this->sendCWNotifWithData('Slack Message Alert', ['res' => json_encode($res), 'error' => $err, 'title' => $this->request->get('title')]);
curl_close($curl);
}catch (\Exception $e){}
}
private function getPayload(){
if ($this->isMicroSoftTeams){
return json_encode($this->getMSTeamsPayloadV1());
//return json_encode($this->getMSTeamsPayload());
}
return "payload=" . $this->payload;
}
private function getMSTeamsPayload(){
$this->headers = array("Content-Type: application/json");
$content = [
'$schema' => "http =>//adaptivecards.io/schemas/adaptive-card.json",
"type" => "AdaptiveCard",
"version" => "1.2",
"body" => [
[
"type" => "TextBlock",
"text" => $this->request->get('title'),
"weight" => "bolder"
],
[
"type" => "TextBlock",
"text" => 'By '.((Auth::user()) ? Auth::user()->name : 'System')
],
[
"type" => "FactSet",
"facts" => $this->field
]
]
];
/*$content['msteams'] = [
"entities" => [
[
"type" => "mention",
"text" => "John Doe",
"mentioned" => [
"id" => "29:123124124124",
"name" => "John Doe"
]
]
]
];*/
return [
"type" => "message",
"attachments" => [
[
"contentType" => "application/vnd.microsoft.card.adaptive",
"content" => $content
]
]
];
}
public function getMSTeamsPayloadV1(){
//$this->sendCWNotifWithData('Slack Message Alert', ['Auth Header' => $this->ref_token]);
$this->headers = array("Content-Type: application/json", "Authorization: Bearer ".$this->ref_token);
$field_string = '';
foreach($this->field as $field){
$field_string .= "| ".$field['title'].": | ".$field['value']." |
";
}
if (!$this->request->has('hide_footer') || !$this->request->get('hide_footer')) {
$field_string .= "| By: | ".((Auth::user()) ? Auth::user()->name : 'System')." |
";
}
$tableHtml = '';
if (!empty($field_string)) {
$tableHtml = "
";
}
$content = " ".$this->request->get('title')."".$tableHtml."
";
if (!empty($this->ms_mention_string_content)) {
$content .= "
".$this->ms_mention_string_content;
}
$payload = [
"body" => [
"contentType" => "html",
"content" => $content
]
];
if ($this->ms_mention_string) {
$payload["mentions"] = $this->ms_mention_string;
}
return $payload;
}
public function send_dm(){
// $this->payload = ($this->request->has('payload')) ? $this->request->get('payload') : json_encode(array('attachment'=>json_encode($this->request->get('fields')), "channel" => $this->request->get('channel')));
$this->payload = ($this->request->has('payload')) ? $this->request->get('payload') : json_encode(array('channel'=>$this->request->get('channel'), 'text' => $this->request->get('title'), 'attachments'=>array(array('fields'=>$this->field))));
$curl = curl_init();
curl_setopt_array($curl, array(
CURLOPT_URL => "https://slack.com/api/chat.postMessage",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "POST",
CURLOPT_POSTFIELDS => $this->payload,
CURLOPT_HTTPHEADER => array(
"Content-Type: application/json",
"Authorization: Bearer ".env('SLACK_DM_AUTH')
),
));
$res = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
}
}