* @copyright 2007-2017 PrestaShop SA
* @license http://opensource.org/licenses/osl-3.0.php Open Software License (OSL 3.0)
* International Registered Trademark & Property of PrestaShop SA
*/
/**
* @property CustomerThread $object
*/
class AdminCustomerThreadsControllerCore extends AdminController
{
public function __construct()
{
$this->bootstrap = true;
$this->context = Context::getContext();
$this->table = 'customer_thread';
$this->className = 'CustomerThread';
$this->lang = false;
$contact_array = array();
$contacts = Contact::getContacts($this->context->language->id);
foreach ($contacts as $contact) {
$contact_array[$contact['id_contact']] = $contact['name'];
}
$language_array = array();
$languages = Language::getLanguages();
foreach ($languages as $language) {
$language_array[$language['id_lang']] = $language['name'];
}
$icon_array = array(
CustomerThread::QLO_CUSTOMER_THREAD_STATUS_OPEN => array(
'class' => 'icon-circle text-success',
'alt' => $this->l('Open')
),
CustomerThread::QLO_CUSTOMER_THREAD_STATUS_CLOSED => array(
'class' => 'icon-circle text-danger',
'alt' => $this->l('Closed')
),
CustomerThread::QLO_CUSTOMER_THREAD_STATUS_PENDING1 => array(
'class' => 'icon-circle text-warning',
'alt' => $this->l('Pending 1')
),
CustomerThread::QLO_CUSTOMER_THREAD_STATUS_PENDING2 => array(
'class' => 'icon-circle text-warning',
'alt' => $this->l('Pending 2')
),
);
$status_array = array();
foreach ($icon_array as $k => $v) {
$status_array[$k] = $v['alt'];
}
// START send access query information to the admin controller
$this->access_select = ' SELECT a.`id_customer_thread` FROM '._DB_PREFIX_.'customer_thread a';
$this->access_join = ' LEFT JOIN '._DB_PREFIX_.'orders ord ON (a.id_order = ord.id_order)';
$this->access_join .= ' LEFT JOIN '._DB_PREFIX_.'htl_booking_detail hbd ON (hbd.id_order = ord.id_order)';
if ($acsHtls = HotelBranchInformation::getProfileAccessedHotels($this->context->employee->id_profile, 1, 1)) {
$this->access_where = ' WHERE IF(a.`id_order`, hbd.`id_hotel` IN ('.implode(',', $acsHtls).'), 1)';
} else {
$this->access_where = ' WHERE a.`id_order` = 0';
}
$this->fields_list = array(
'id_customer_thread' => array(
'title' => $this->l('ID'),
'align' => 'center',
'class' => 'fixed-width-xs'
),
'customer' => array(
'title' => $this->l('Customer'),
'filter_key' => 'customer',
'callback' => 'getCustomerLink',
'tmpTableFilter' => true,
),
'email' => array(
'title' => $this->l('Email'),
'filter_key' => 'a!email',
),
'phone' => array(
'title' => $this->l('Phone'),
'filter_key' => 'a!phone',
'optional' => true,
'visible_default' => true,
),
'contact' => array(
'title' => $this->l('Contact'),
'type' => 'select',
'list' => $contact_array,
'filter_key' => 'cl!id_contact',
'filter_type' => 'int',
),
'subject' => array(
'title' => $this->l('Title'),
'filter_key' => 'a!subject',
'tmpTableFilter' => true,
'maxlength' => 30,
'optional' => true,
'visible_default' => true,
),
'language' => array(
'title' => $this->l('Language'),
'type' => 'select',
'list' => $language_array,
'filter_key' => 'l!id_lang',
'filter_type' => 'int',
'optional' => true,
),
'status' => array(
'title' => $this->l('Status'),
'type' => 'select',
'list' => $status_array,
'icon' => $icon_array,
'align' => 'center',
'filter_key' => 'a!status',
'filter_type' => 'string',
),
'employee' => array(
'title' => $this->l('Employee'),
'filter_key' => 'employee',
'tmpTableFilter' => true,
'optional' => true,
'hint' => $this->l('The first employee to reply becomes responsible. They can then forward the message to another employee if needed.')
),
'last_employee' => array(
'title' => $this->l('Last Reply by'),
'filter_key' => 'employee',
'tmpTableFilter' => true,
'optional' => true,
),
'messages' => array(
'title' => $this->l('Messages'),
'filter_key' => 'messages',
'tmpTableFilter' => true,
'maxlength' => 30,
'optional' => true,
),
'has_private' => array(
'title' => $this->l('Has Private'),
'type' => 'bool',
'havingFilter' => true,
'filter_key' => 'has_private',
'align' => 'center',
'callback' => 'printOptinIcon',
),
'date_upd' => array(
'title' => $this->l('Last message'),
'havingFilter' => true,
'type' => 'datetime',
'optional' => true,
),
'id_order' => array(
'title' => $this->l('ID Order'),
'filter_key' => 'a!id_order',
'optional' => true,
'visible_default' => false,
'displayed' => false,
),
);
$this->bulk_actions = array(
'delete' => array(
'text' => $this->l('Delete selected'),
'confirm' => $this->l('Delete selected items?'),
'icon' => 'icon-trash'
),
);
$this->shopLinkType = 'shop';
$arr = array();
if ($contacts = Contact::getContacts($this->context->language->id)) {
foreach ($contacts as $contact) {
$arr[] = array('email_message' => $contact['id_contact'], 'name' => $contact['name']);
}
}
$this->fields_options = array(
'contact' => array(
'title' => $this->l('Contact options'),
'fields' => array(
'PS_CUSTOMER_SERVICE_FILE_UPLOAD' => array(
'title' => $this->l('Allow file uploading'),
'hint' => $this->l('Allow customers to upload files using the contact page.'),
'type' => 'bool'
),
'PS_MAIL_EMAIL_MESSAGE' => array(
'title' => $this->l('Send email to'),
'desc' => $this->l('Where customers send messages from the order page.'),
'validation' => 'isUnsignedId',
'type' => 'select',
'cast' => 'intval',
'identifier' => 'email_message',
'list' => $arr
),
'PS_CUSTOMER_SERVICE_CONTACT_ALLOW' => array(
'title' => $this->l('Allow guest to select contact'),
'hint' => $this->l('Allow guest to select the contact while submitting message from the contact page.'),
'type' => 'bool'
),
'PS_CUSTOMER_SERVICE_EMAIL_MESSAGE' => array(
'title' => $this->l('Send email to'),
'desc' => $this->l('Where customers send messages from the Contact page.'),
'validation' => 'isUnsignedId',
'type' => 'select',
'cast' => 'intval',
'identifier' => 'email_message',
'list' => $arr
),
'PS_CUSTOMER_SERVICE_NAME_REQUIRED' => array(
'title' => $this->l('Set Name as required'),
'hint' => $this->l('Set Name as required while submitting message from the contact page.'),
'type' => 'bool'
),
'PS_CUSTOMER_SERVICE_NAME_DISPLAY' => array(
'title' => $this->l('Display Name field'),
'hint' => $this->l('Display name field on contact page.'),
'type' => 'bool',
),
'PS_CUSTOMER_SERVICE_PHONE_REQUIRED' => array(
'title' => $this->l('Set Phone as required'),
'hint' => $this->l('Set Phone as required while submitting message from the contact page.'),
'type' => 'bool'
),
'PS_CUSTOMER_SERVICE_PHONE_DISPLAY' => array(
'title' => $this->l('Display Phone field'),
'hint' => $this->l('Display phone field on contact page.'),
'type' => 'bool',
),
'PS_CUSTOMER_SERVICE_SIGNATURE' => array(
'title' => $this->l('Default message'),
'hint' => $this->l('Please fill out the message fields that appear by default when you answer a thread on the customer service page.'),
'type' => 'textareaLang',
'lang' => true
)
),
'submit' => array(
'title' => $this->l('Save'),
'name' => 'submitOptionsCustomerService'
)
),
'general' => array(
'title' => $this->l('Customer service options'),
'fields' => array(
'PS_SAV_IMAP_URL' => array(
'title' => $this->l('IMAP URL'),
'hint' => $this->l('URL for your IMAP server (ie.: mail.server.com).'),
'type' => 'text'
),
'PS_SAV_IMAP_PORT' => array(
'title' => $this->l('IMAP port'),
'hint' => $this->l('Port to use to connect to your IMAP server.'),
'type' => 'text',
'defaultValue' => 143,
),
'PS_SAV_IMAP_USER' => array(
'title' => $this->l('IMAP user'),
'hint' => $this->l('User to use to connect to your IMAP server.'),
'type' => 'text'
),
'PS_SAV_IMAP_PWD' => array(
'title' => $this->l('IMAP password'),
'hint' => $this->l('Password to use to connect your IMAP server.'),
'type' => 'text'
),
'PS_SAV_IMAP_DELETE_MSG' => array(
'title' => $this->l('Delete messages'),
'hint' => $this->l('Delete messages after synchronization. If you do not enable this option, the synchronization will take more time.'),
'type' => 'bool',
),
'PS_SAV_IMAP_CREATE_THREADS' => array(
'title' => $this->l('Create new threads'),
'hint' => $this->l('Create new threads for unrecognized emails.'),
'type' => 'bool',
),
'PS_SAV_IMAP_OPT_NORSH' => array(
'title' => $this->l('IMAP options').' (/norsh)',
'type' => 'bool',
'hint' => $this->l('Do not use RSH or SSH to establish a preauthenticated IMAP sessions.'),
),
'PS_SAV_IMAP_OPT_SSL' => array(
'title' => $this->l('IMAP options').' (/ssl)',
'type' => 'bool',
'hint' => $this->l('Use the Secure Socket Layer (TLS/SSL) to encrypt the session.'),
),
'PS_SAV_IMAP_OPT_VALIDATE-CERT' => array(
'title' => $this->l('IMAP options').' (/validate-cert)',
'type' => 'bool',
'hint' => $this->l('Validate certificates from the TLS/SSL server.'),
),
'PS_SAV_IMAP_OPT_NOVALIDATE-CERT' => array(
'title' => $this->l('IMAP options').' (/novalidate-cert)',
'type' => 'bool',
'hint' => $this->l('Do not validate certificates from the TLS/SSL server. This is only needed if a server uses self-signed certificates.'),
),
'PS_SAV_IMAP_OPT_TLS' => array(
'title' => $this->l('IMAP options').' (/tls)',
'type' => 'bool',
'hint' => $this->l('Force use of start-TLS to encrypt the session, and reject connection to servers that do not support it.'),
),
'PS_SAV_IMAP_OPT_NOTLS' => array(
'title' => $this->l('IMAP options').' (/notls)',
'type' => 'bool',
'hint' => $this->l('Do not use start-TLS to encrypt the session, even with servers that support it.'),
),
),
'submit' => array(
'title' => $this->l('Save'),
'name' => 'submitOptionsIMAPConfig'
),
),
);
parent::__construct();
$this->_new_list_header_design = true;
$this->list_no_link = true;
}
public function getCustomerLink($customer, $tr)
{
if ($tr['id_customer']) {
return ''.$customer.' (#'.$tr['id_customer'].')';
}
return $customer;
}
public function setMedia()
{
parent::setMedia();
if (!$this->display || $this->display == 'list') {
$this->addJS(_PS_JS_DIR_.'admin/customer_thread.js');
}
}
public function renderList()
{
// Check the new IMAP messages before rendering the list
$this->renderProcessSyncImap();
$this->addRowAction('view');
$this->addRowAction('delete');
$this->_select = '
IF(a.`user_name`="", CONCAT(c.`firstname`," ",c.`lastname`), a.`user_name`) AS customer, cl.`name` as contact, l.`name` as language, group_concat(message) as messages,
cm.private, IF(COUNT(CASE WHEN cm.`private` = 1 THEN 1 END), 1, 0) AS `has_private`,
(
SELECT IFNULL(CONCAT(LEFT(e.`firstname`, 1),". ",e.`lastname`), "--")
FROM `'._DB_PREFIX_.'customer_message` cm2
INNER JOIN '._DB_PREFIX_.'employee e
ON e.`id_employee` = cm2.`id_employee`
WHERE cm2.id_employee > 0
AND cm2.`id_customer_thread` = a.`id_customer_thread`
ORDER BY cm2.`date_add` DESC LIMIT 1
) AS last_employee,
IFNULL(CONCAT(LEFT(emp.`firstname`, 1),". ",emp.`lastname`), "--") AS employee';
$this->_join = '
LEFT JOIN `'._DB_PREFIX_.'employee` emp
ON emp.`id_employee` = a.`id_employee`
LEFT JOIN `'._DB_PREFIX_.'customer` c
ON c.`id_customer` = a.`id_customer`
LEFT JOIN `'._DB_PREFIX_.'customer_message` cm
ON cm.`id_customer_thread` = a.`id_customer_thread`
LEFT JOIN `'._DB_PREFIX_.'lang` l
ON l.`id_lang` = a.`id_lang`
LEFT JOIN `'._DB_PREFIX_.'contact_lang` cl
ON (cl.`id_contact` = a.`id_contact` AND cl.`id_lang` = '.(int)$this->context->language->id.')';
$this->_group = 'GROUP BY cm.id_customer_thread';
$this->_orderBy = 'id_customer_thread';
$this->_orderWay = 'DESC';
$contacts = CustomerThread::getContacts();
$categories = Contact::getCategoriesContacts();
$stats = array(
array(
'title' => $this->l('Total threads'),
'val' => $all = CustomerThread::getTotalCustomerThreads(),
),
array(
'title' => $this->l('Threads pending'),
'val' => $pending = CustomerThread::getTotalCustomerThreads(
'status='.CustomerThread::QLO_CUSTOMER_THREAD_STATUS_PENDING1.'
OR status='.CustomerThread::QLO_CUSTOMER_THREAD_STATUS_PENDING2
),
),
array(
'title' => $this->l('Total number of customer messages'),
'val' => CustomerMessage::getTotalCustomerMessages('cm.`id_employee` = 0'),
),
array(
'title' => $this->l('Total number of employee messages'),
'val' => CustomerMessage::getTotalCustomerMessages('cm.`id_employee` != 0'),
),
array(
'title' => $this->l('Unread threads'),
'val' => $unread = CustomerThread::getTotalCustomerThreads(
'status='.CustomerThread::QLO_CUSTOMER_THREAD_STATUS_OPEN
),
),
array(
'title' => $this->l('Closed threads'),
'val' => $all - ($unread + $pending),
),
);
$this->tpl_list_vars = array(
'contacts' => $contacts,
'categories' => $categories,
'stats' => $stats
);
return parent::renderList();
}
public function initToolbar()
{
parent::initToolbar();
unset($this->toolbar_btn['new']);
}
public function printOptinIcon($value, $customer)
{
return ($value ? '' : '');
}
public function postProcess()
{
if ($this->tabAccess['edit'] === '1') {
// using this to separate the saving process for the both option fields
$fields = $this->fields_options;
if (Tools::isSubmit('submitOptionsCustomerService')) {
unset($this->fields_options['general']);
$this->processUpdateOptions();
if (Tools::getValue('PS_CUSTOMER_SERVICE_NAME_REQUIRED')) {
Configuration::updateValue('PS_CUSTOMER_SERVICE_NAME_DISPLAY', 1);
}
if (Tools::getValue('PS_CUSTOMER_SERVICE_PHONE_REQUIRED')) {
Configuration::updateValue('PS_CUSTOMER_SERVICE_PHONE_DISPLAY', 1);
}
} else if (Tools::isSubmit('submitOptionsIMAPConfig')) {
unset($this->fields_options['contact']);
$this->processUpdateOptions();
}
$this->fields_options = $fields;
} else {
$this->errors[] = Tools::displayError('You do not have permission to edit this.');
}
if ($id_customer_thread = (int)Tools::getValue('id_customer_thread')) {
$ct = new CustomerThread($id_customer_thread);
if (($id_contact = (int)Tools::getValue('id_contact'))) {
Db::getInstance()->execute('
UPDATE '._DB_PREFIX_.'customer_thread
SET id_contact = '.(int)$id_contact.'
WHERE id_customer_thread = '.(int)$id_customer_thread
);
}
if ($id_status = (int)Tools::getValue('setstatus')) {
Db::getInstance()->execute('
UPDATE '._DB_PREFIX_.'customer_thread
SET status = "'.(int) $id_status.'"
WHERE id_customer_thread = '.(int)$id_customer_thread.' LIMIT 1
');
}
if ($id_employee = (int) Tools::getValue('id_employee_forward')) {
$messages = Db::getInstance()->getRow('
SELECT ct.*, cm.*, cl.name subject, CONCAT(e.firstname, \' \', e.lastname) employee_name,
CONCAT(c.firstname, \' \', c.lastname) customer_name, c.firstname
FROM '._DB_PREFIX_.'customer_thread ct
LEFT JOIN '._DB_PREFIX_.'customer_message cm
ON (ct.id_customer_thread = cm.id_customer_thread)
LEFT JOIN '._DB_PREFIX_.'contact_lang cl
ON (cl.id_contact = ct.id_contact AND cl.id_lang = '.(int)$this->context->language->id.')
LEFT OUTER JOIN '._DB_PREFIX_.'employee e
ON e.id_employee = cm.id_employee
LEFT OUTER JOIN '._DB_PREFIX_.'customer c
ON (c.email = ct.email)
WHERE ct.id_customer_thread = '.(int)Tools::getValue('id_customer_thread').'
ORDER BY cm.id_employee, cm.private, cm.date_add DESC
');
$output = $this->displayMessage($messages, true, (int)Tools::getValue('id_employee_forward'));
$cm = new CustomerMessage();
$cm->id_employee = (int)$this->context->employee->id;
$cm->id_customer_thread = (int)Tools::getValue('id_customer_thread');
$cm->ip_address = (int)ip2long(Tools::getRemoteAddr());
$current_employee = $this->context->employee;
$id_employee = (int)Tools::getValue('id_employee_forward');
$employee = new Employee($id_employee);
$email = Tools::getValue('email');
$message = Tools::getValue('message_forward');
if (($error = $cm->validateField('message', $message, null, array(), true)) !== true) {
$this->errors[] = $error;
} elseif ($id_employee && $employee && Validate::isLoadedObject($employee)) {
$params = array(
'{messages}' => stripslashes($output),
'{employee}' => $current_employee->firstname.' '.$current_employee->lastname,
'{comment}' => stripslashes(Tools::nl2br($_POST['message_forward'])),
'{firstname}' => $employee->firstname,
'{lastname}' => $employee->lastname,
);
if (Mail::Send(
$this->context->language->id,
'forward_msg',
Mail::l('Fwd: Customer message', $this->context->language->id),
$params,
$employee->email,
$employee->firstname.' '.$employee->lastname,
$current_employee->email,
$current_employee->firstname.' '.$current_employee->lastname,
null, null, _PS_MAIL_DIR_, true)
) {
$ct->id_employee = $employee->id;
$ct->save();
$cm->id_employee = (int)$employee->id;
$cm->private = 1;
$cm->message = $this->l('Message forwarded to').' '.$employee->firstname.' '.$employee->lastname."\n".$this->l('Comment:').' '.$message;
$cm->add();
}
} elseif ($email && Validate::isEmail($email)) {
$params = array(
'{messages}' => Tools::nl2br(stripslashes($output)),
'{employee}' => $current_employee->firstname.' '.$current_employee->lastname,
'{comment}' => stripslashes($_POST['message_forward']),
'{firstname}' => '',
'{lastname}' => '',
);
if (Mail::Send(
$this->context->language->id,
'forward_msg',
Mail::l('Fwd: Customer message', $this->context->language->id),
$params, $email, null,
$current_employee->email, $current_employee->firstname.' '.$current_employee->lastname,
null, null, _PS_MAIL_DIR_, true)) {
$cm->message = $this->l('Message forwarded to').' '.$email."\n".$this->l('Comment:').' '.$message;
$cm->add();
}
} else {
$this->errors[] = ''.Tools::displayError('The email address is invalid.').'
';
}
}
if (Tools::isSubmit('submitReply') || Tools::isSubmit('submitReplyAndClose')) {
ShopUrl::cacheMainDomainForShop((int)$ct->id_shop);
$cm = new CustomerMessage();
$cm->id_employee = (int)$this->context->employee->id;
if (!$ct->id_employee) {
$ct->id_employee = $this->context->employee->id;
}
$cm->id_customer_thread = $ct->id;
$cm->ip_address = (int)ip2long(Tools::getRemoteAddr());
$cm->message = Tools::getValue('reply_message');
if (($error = $cm->validateField('message', $cm->message, null, array(), true)) !== true) {
$this->errors[] = $error;
} elseif (isset($_FILES) && !empty($_FILES['joinFile']['name']) && $_FILES['joinFile']['error'] != 0) {
$this->errors[] = Tools::displayError('An error occurred during the file upload process.');
} elseif ($cm->add()) {
$file_attachment = null;
if (!empty($_FILES['joinFile']['name'])) {
$file_attachment['content'] = file_get_contents($_FILES['joinFile']['tmp_name']);
$file_attachment['name'] = $_FILES['joinFile']['name'];
$file_attachment['mime'] = $_FILES['joinFile']['type'];
}
$customer = new Customer($ct->id_customer);
//#ct == id_customer_thread #tc == token of thread <== used in the synchronization imap
$contact = new Contact((int)$ct->id_contact, (int)$ct->id_lang);
if (Validate::isLoadedObject($contact)) {
$from_name = $contact->name;
$from_email = $contact->email;
} else {
$from_name = null;
$from_email = null;
}
if ($ct->id_order) {
$link = Tools::url(
$this->context->link->getPageLink('order-detail', true, (int)$ct->id_lang, null, false, $ct->id_shop),
'id_order='.$ct->id_order
);
$objOrder = new Order($ct->id_order);
$message = $cm->message;
if (Configuration::get('PS_MAIL_TYPE', null, null, $objOrder->id_shop) != Mail::TYPE_TEXT) {
$message = Tools::nl2br($cm->message);
}
$objCustomer = new Customer($objOrder->id_customer);
$idShop = $objOrder->id_shop;
$params = array(
'{lastname}' => $objCustomer->lastname,
'{firstname}' => $objCustomer->firstname,
'{id_order}' => $objOrder->id,
'{order_name}' => $objOrder->getUniqReference(),
'{message}' => $message
);
$toEmail = $objCustomer->email;
$toName = $objCustomer->firstname.' '.$objCustomer->lastname;
$title = Mail::l('New message regarding your booking', (int)$objOrder->id_lang);
$template = 'order_merchant_comment';
$idLang = $objOrder->id_lang;
} else {
$link = Tools::url(
$this->context->link->getPageLink('contact', true, (int)$ct->id_lang, null, false, $ct->id_shop),
'token='.$ct->token
);
$headingText = $this->l('Hi') .' '.$ct->user_name;
$idShop = $ct->id_shop;
$params = array(
'{reply}' => Tools::nl2br(Tools::getValue('reply_message')),
'{link}' => $link,
'{headingtext}' => $headingText,
);
if (!empty(trim($ct->subject))) {
$params['{subject}'] = $ct->subject;
}
$idLang = $ct->id_lang;
$toEmail = Tools::getValue('msg_email');
$toName = null;
$template = 'reply_msg';
$title = Mail::l('An answer to your message is available', $ct->id_lang);
if ($customer->id) {
$headingText .= ' '.$customer->firstname.' '.$customer->lastname;
}
}
if (Mail::Send(
(int) $idLang,
$template,
$title,
$params,
$toEmail,
$toName,
$from_email,
$from_name,
$file_attachment,
null,
_PS_MAIL_DIR_,
true,
$idShop
)) {
if (Tools::isSubmit('submitReplyAndClose')) {
$ct->status = CustomerThread::QLO_CUSTOMER_THREAD_STATUS_CLOSED;
} else {
$ct->status = CustomerThread::QLO_CUSTOMER_THREAD_STATUS_OPEN;
}
$ct->update();
}
Tools::redirectAdmin(
self::$currentIndex.'&id_customer_thread='.(int)$id_customer_thread.'&viewcustomer_thread&token='.Tools::getValue('token')
);
} else {
$this->errors[] = Tools::displayError('An error occurred. Your message was not sent. Please contact your system administrator.');
}
} else if (Tools::isSubmit('submitReplyAsPrivate')) {
if (!$ct->id_employee) {
$ct->id_employee = $this->context->employee->id;
$ct->update();
}
ShopUrl::cacheMainDomainForShop((int)$ct->id_shop);
$cm = new CustomerMessage();
$cm->id_employee = (int)$this->context->employee->id;
$cm->id_customer_thread = $ct->id;
$cm->ip_address = (int)ip2long(Tools::getRemoteAddr());
$cm->message = Tools::getValue('reply_message');
$cm->private = 1;
$cm->read = 1;
if (($error = $cm->validateField('message', $cm->message, null, array(), true)) !== true) {
$this->errors[] = $error;
} elseif (!$cm->add()) {
$this->errors[] = Tools::displayError('Some error occured while saving the message');
}
}
}
return parent::postProcess();
}
public function initContent()
{
if (isset($_GET['filename']) && (bool)Tools::file_get_contents($this->context->link->getMediaLink(_THEME_PROD_PIC_DIR_.$_GET['filename'])) && Validate::isFileName($_GET['filename'])) { // by webkul
AdminCustomerThreadsController::openUploadedFile();
}
return parent::initContent();
}
protected function openUploadedFile()
{
$filename = $_GET['filename'];
$extensions = array(
'.txt' => 'text/plain',
'.rtf' => 'application/rtf',
'.doc' => 'application/msword',
'.docx'=> 'application/msword',
'.pdf' => 'application/pdf',
'.zip' => 'multipart/x-zip',
'.png' => 'image/png',
'.jpeg' => 'image/jpeg',
'.gif' => 'image/gif',
'.jpg' => 'image/jpeg',
);
$extension = false;
foreach ($extensions as $key => $val) {
if (substr(Tools::strtolower($filename), -4) == $key || substr(Tools::strtolower($filename), -5) == $key) {
$extension = $val;
break;
}
}
if (!$extension || !Validate::isFileName($filename)) {
die(Tools::displayError());
}
if (ob_get_level() && ob_get_length() > 0) {
ob_end_clean();
}
header('Content-Type: '.$extension);
header('Content-Disposition:attachment;filename="'.$filename.'"');
readfile(_PS_UPLOAD_DIR_.$filename);
die;
}
public function renderKpis()
{
$time = time();
$kpis = array();
$helper = new HelperKpi();
$helper->id = 'box-pending-messages';
$helper->icon = 'icon-envelope';
$helper->color = 'color1';
$helper->title = $this->l('Pending Discussion Threads', null, null, false);
$helper->source = $this->context->link->getAdminLink('AdminStats').'&ajax=1&action=getKpi&kpi=pending_messages';
$this->kpis[] = $helper;
$helper = new HelperKpi();
$helper->id = 'box-age';
$helper->icon = 'icon-time';
$helper->color = 'color2';
$helper->title = $this->l('Average Response Time', null, null, false);
$helper->subtitle = $this->l('30 days', null, null, false);
$helper->source = $this->context->link->getAdminLink('AdminStats').'&ajax=1&action=getKpi&kpi=avg_msg_response_time';
$this->kpis[] = $helper;
$helper = new HelperKpi();
$helper->id = 'box-messages-per-thread';
$helper->icon = 'icon-copy';
$helper->color = 'color3';
$helper->title = $this->l('Messages per Thread', null, null, false);
$helper->subtitle = $this->l('30 day', null, null, false);
$helper->source = $this->context->link->getAdminLink('AdminStats').'&ajax=1&action=getKpi&kpi=messages_per_thread';
$this->kpis[] = $helper;
return parent::renderKpis();
}
public function renderView()
{
if (!$id_customer_thread = (int)Tools::getValue('id_customer_thread')) {
return;
}
if (!($thread = $this->loadObject())) {
return;
}
$this->context->cookie->{'customer_threadFilter_cl!id_contact'} = $thread->id_contact;
$employees = Employee::getEmployees();
$messages = CustomerThread::getMessageCustomerThreads($id_customer_thread);
foreach ($messages as $key => $mess) {
if ($mess['id_employee']) {
$employee = new Employee($mess['id_employee']);
$messages[$key]['employee_image'] = $employee->getImage();
}
if (isset($mess['file_name']) && $mess['file_name'] != '') {
$messages[$key]['file_name'] = _THEME_PROD_PIC_DIR_.$mess['file_name'];
} else {
unset($messages[$key]['file_name']);
}
if ($mess['id_product']) {
$product = new Product((int)$mess['id_product'], false, $this->context->language->id);
if (Validate::isLoadedObject($product)) {
$messages[$key]['product_name'] = $product->name;
$messages[$key]['product_link'] = $this->context->link->getAdminLink('AdminProducts').'&updateproduct&id_product='.(int)$product->id;
}
}
}
$contacts = Contact::getContacts($this->context->language->id);
$actions = array();
if ($thread->status != CustomerThread::QLO_CUSTOMER_THREAD_STATUS_CLOSED) {
$actions[CustomerThread::QLO_CUSTOMER_THREAD_STATUS_CLOSED] = array(
'href' => self::$currentIndex.'&viewcustomer_thread&setstatus='.CustomerThread::QLO_CUSTOMER_THREAD_STATUS_CLOSED.'&id_customer_thread='.(int)Tools::getValue('id_customer_thread').'&viewmsg&token='.$this->token,
'label' => $this->l('Mark as "handled"'),
'name' => 'setstatus',
'value' => CustomerThread::QLO_CUSTOMER_THREAD_STATUS_CLOSED
);
} else {
$actions[CustomerThread::QLO_CUSTOMER_THREAD_STATUS_OPEN] = array(
'href' => self::$currentIndex.'&viewcustomer_thread&setstatus='.CustomerThread::QLO_CUSTOMER_THREAD_STATUS_OPEN.'&id_customer_thread='.(int)Tools::getValue('id_customer_thread').'&viewmsg&token='.$this->token,
'label' => $this->l('Re-open'),
'name' => 'setstatus',
'value' => CustomerThread::QLO_CUSTOMER_THREAD_STATUS_OPEN
);
}
if ($thread->status != CustomerThread::QLO_CUSTOMER_THREAD_STATUS_PENDING1) {
$actions[CustomerThread::QLO_CUSTOMER_THREAD_STATUS_PENDING1] = array(
'href' => self::$currentIndex.'&viewcustomer_thread&setstatus='.CustomerThread::QLO_CUSTOMER_THREAD_STATUS_PENDING1.'&id_customer_thread='.(int)Tools::getValue('id_customer_thread').'&viewmsg&token='.$this->token,
'label' => $this->l('Mark as "pending 1" (will be answered later)'),
'name' => 'setstatus',
'value' => CustomerThread::QLO_CUSTOMER_THREAD_STATUS_PENDING1
);
} else {
$actions[CustomerThread::QLO_CUSTOMER_THREAD_STATUS_PENDING1] = array(
'href' => self::$currentIndex.'&viewcustomer_thread&setstatus='.CustomerThread::QLO_CUSTOMER_THREAD_STATUS_OPEN.'&id_customer_thread='.(int)Tools::getValue('id_customer_thread').'&viewmsg&token='.$this->token,
'label' => $this->l('Disable pending status'),
'name' => 'setstatus',
'value' => CustomerThread::QLO_CUSTOMER_THREAD_STATUS_OPEN
);
}
if ($thread->status != CustomerThread::QLO_CUSTOMER_THREAD_STATUS_PENDING2) {
$actions[CustomerThread::QLO_CUSTOMER_THREAD_STATUS_PENDING2] = array(
'href' => self::$currentIndex.'&viewcustomer_thread&setstatus='.CustomerThread::QLO_CUSTOMER_THREAD_STATUS_PENDING2.'&id_customer_thread='.(int)Tools::getValue('id_customer_thread').'&viewmsg&token='.$this->token,
'label' => $this->l('Mark as "pending 2" (will be answered later)'),
'name' => 'setstatus',
'value' => CustomerThread::QLO_CUSTOMER_THREAD_STATUS_PENDING2
);
} else {
$actions[CustomerThread::QLO_CUSTOMER_THREAD_STATUS_PENDING2] = array(
'href' => self::$currentIndex.'&viewcustomer_thread&setstatus='.CustomerThread::QLO_CUSTOMER_THREAD_STATUS_OPEN.'&id_customer_thread='.(int)Tools::getValue('id_customer_thread').'&viewmsg&token='.$this->token,
'label' => $this->l('Disable pending status'),
'name' => 'setstatus',
'value' => CustomerThread::QLO_CUSTOMER_THREAD_STATUS_OPEN
);
}
if ($thread->id_customer) {
$customer = new Customer($thread->id_customer);
$orders = Order::getCustomerOrders($customer->id);
if ($orders && count($orders)) {
$total_ok = 0;
$orders_ok = array();
foreach ($orders as $key => $order) {
if ($order['valid']) {
$orders_ok[] = $order;
$total_ok += $order['total_paid_real']/$order['conversion_rate'];
}
$orders[$key]['date_add'] = Tools::displayDate($order['date_add']);
$orders[$key]['total_paid_real'] = Tools::displayPrice($order['total_paid_real'], new Currency((int)$order['id_currency']));
}
}
$products = $customer->getBoughtProducts();
if ($products && count($products)) {
foreach ($products as $key => $product) {
$products[$key]['date_add'] = Tools::displayDate($product['date_add'], null, true);
}
}
}
$timeline_items = $this->getTimeline($messages, $thread->id_order);
$first_message = $messages[0];
if (!$messages[0]['id_employee']) {
unset($messages[0]);
}
$contact = '';
foreach ($contacts as $c) {
if ($c['id_contact'] == $thread->id_contact) {
$contact = $c['name'];
}
}
$this->tpl_view_vars = array(
'id_customer_thread' => $id_customer_thread,
'thread' => $thread,
'actions' => $actions,
'employees' => $employees,
'current_employee' => $this->context->employee,
'messages' => $messages,
'first_message' => $first_message,
'contact' => $contact,
'orders' => isset($orders) ? $orders : false,
'customer' => isset($customer) ? $customer : false,
'products' => isset($products) ? $products : false,
'total_ok' => isset($total_ok) ? Tools::displayPrice($total_ok, $this->context->currency) : false,
'orders_ok' => isset($orders_ok) ? $orders_ok : false,
'count_ok' => isset($orders_ok) ? count($orders_ok) : false,
'PS_CUSTOMER_SERVICE_SIGNATURE' => str_replace('\r\n', "\n", Configuration::get('PS_CUSTOMER_SERVICE_SIGNATURE', (int)$thread->id_lang)),
'timeline_items' => $timeline_items,
);
return parent::renderView();
}
public function getTimeline($messages, $id_order)
{
$timeline = array();
foreach ($messages as $message) {
$product = new Product((int)$message['id_product'], false, $this->context->language->id);
$link_product = $this->context->link->getAdminLink('AdminOrders').'&vieworder&id_order='.(int)$product->id;
$content = '';
if (!$message['private']) {
$customerName = false;
if (!$message['id_customer']) {
$customerName = $message['user_name'];
} else if ($message['customer_name']) {
$customerName = $message['customer_name'];
}
if ($message['id_employee'] && $customerName) {
$content .= $this->l('Message to: ').' '.($customerName).'
';
}
} else {
$content .= ''.$this->l('Private').'
';
}
if (Validate::isLoadedObject($product)) {
$content .= $this->l('Room type: ').''.$product->name.'
';
}
$content .= Tools::safeOutput($message['message']);
$timeline[$message['date_add']][] = array(
'arrow' => 'left',
'background_color' => '',
'icon' => 'icon-envelope',
'content' => $content,
'date' => $message['date_add'],
);
}
$order = new Order((int)$id_order);
if (Validate::isLoadedObject($order)) {
$order_history = $order->getHistory($this->context->language->id);
foreach ($order_history as $history) {
$link_order = $this->context->link->getAdminLink('AdminOrders').'&vieworder&id_order='.(int)$order->id;
$content = ''.$this->l('Order').' #'.(int)$order->id.'
';
$content .= ''.$this->l('Status:').' '.$history['ostate_name'].'';
$timeline[$history['date_add']][] = array(
'arrow' => 'right',
'alt' => true,
'background_color' => $history['color'],
'icon' => 'icon-credit-card',
'content' => $content,
'date' => $history['date_add'],
'see_more_link' => $link_order,
);
}
}
krsort($timeline);
return $timeline;
}
protected function displayMessage($message, $email = false, $id_employee = null)
{
$tpl = $this->createTemplate('message.tpl');
$contacts = Contact::getContacts($this->context->language->id);
foreach ($contacts as $contact) {
$contact_array[$contact['id_contact']] = array('id_contact' => $contact['id_contact'], 'name' => $contact['name']);
}
$contacts = $contact_array;
if (!$email) {
if (!empty($message['id_product']) && empty($message['employee_name'])) {
$id_order_product = Order::getIdOrderProduct((int)$message['id_customer'], (int)$message['id_product']);
}
}
$message['date_add'] = Tools::displayDate($message['date_add'], null, true);
$message['user_agent'] = strip_tags($message['user_agent']);
$message['message'] = preg_replace(
'/(https?:\/\/[a-z0-9#%&_=\(\)\.\? \+\-@\/]{6,1000})([\s\n<])/Uui',
'\1\2',
html_entity_decode($message['message'],
ENT_QUOTES, 'UTF-8')
);
$is_valid_order_id = true;
$order = new Order((int)$message['id_order']);
if (!Validate::isLoadedObject($order)) {
$is_valid_order_id = false;
}
$tpl->assign(array(
'thread_url' => Tools::getAdminUrl(basename(_PS_ADMIN_DIR_).'/'.
$this->context->link->getAdminLink('AdminCustomerThreads').'&id_customer_thread='
.(int)$message['id_customer_thread'].'&viewcustomer_thread=1'),
'link' => $this->context->link,
'current' => self::$currentIndex,
'token' => $this->token,
'message' => $message,
'id_order_product' => isset($id_order_product) ? $id_order_product : null,
'email' => $email,
'id_employee' => $id_employee,
'PS_SHOP_NAME' => Configuration::get('PS_SHOP_NAME'),
'file_name' => (bool)Tools::file_get_contents($this->context->link->getMediaLink(_THEME_PROD_PIC_DIR_.$message['file_name'])), // by webkul
'contacts' => $contacts,
'is_valid_order_id' => $is_valid_order_id
));
return $tpl->fetch();
}
protected function displayButton($content)
{
return '';
}
public function renderOptions()
{
if (Configuration::get('PS_SAV_IMAP_URL')
&& Configuration::get('PS_SAV_IMAP_PORT')
&& Configuration::get('PS_SAV_IMAP_USER')
&& Configuration::get('PS_SAV_IMAP_PWD')) {
$this->tpl_option_vars['use_sync'] = true;
} else {
$this->tpl_option_vars['use_sync'] = false;
}
return parent::renderOptions();
}
/**
* AdminController::getList() override
* @see AdminController::getList()
*
* @param int $id_lang
* @param string|null $order_by
* @param string|null $order_way
* @param int $start
* @param int|null $limit
* @param int|bool $id_lang_shop
*
* @throws PrestaShopException
*/
public function getList($id_lang, $order_by = null, $order_way = null, $start = 0, $limit = null, $id_lang_shop = false)
{
parent::getList($id_lang, $order_by, $order_way, $start, $limit, $id_lang_shop);
$nb_items = count($this->_list);
for ($i = 0; $i < $nb_items; ++$i) {
if (isset($this->_list[$i]['messages'])) {
$this->_list[$i]['messages'] = Tools::htmlentitiesDecodeUTF8($this->_list[$i]['messages']);
}
}
}
public function updateOptionPsSavImapOpt($value)
{
if ($this->tabAccess['edit'] != '1') {
throw new PrestaShopException(Tools::displayError('You do not have permission to edit this.'));
}
if (!$this->errors && $value) {
Configuration::updateValue('PS_SAV_IMAP_OPT', implode('', $value));
}
}
public function ajaxProcessMarkAsRead()
{
if ($this->tabAccess['edit'] != '1') {
throw new PrestaShopException(Tools::displayError('You do not have permission to edit this.'));
}
$id_thread = Tools::getValue('id_thread');
$messages = CustomerThread::getMessageCustomerThreads($id_thread);
if (count($messages)) {
Db::getInstance()->execute('UPDATE `'._DB_PREFIX_.'customer_message` set `read` = 1 WHERE `id_employee` = '.(int)$this->context->employee->id.' AND `id_customer_thread` = '.(int)$id_thread);
}
}
/**
* Call the IMAP synchronization during an AJAX process.
*
* @throws PrestaShopException
*/
public function ajaxProcessSyncImap()
{
if ($this->tabAccess['edit'] != '1') {
throw new PrestaShopException(Tools::displayError('You do not have permission to edit this.'));
}
if (Tools::isSubmit('syncImapMail')) {
die(json_encode($this->syncImap()));
}
}
/**
* Call the IMAP synchronization during the render process.
*/
public function renderProcessSyncImap()
{
// To avoid an error if the IMAP isn't configured, we check the configuration here, like during
// the synchronization. All parameters will exists.
if (!(Configuration::get('PS_SAV_IMAP_URL')
|| Configuration::get('PS_SAV_IMAP_PORT')
|| Configuration::get('PS_SAV_IMAP_USER')
|| Configuration::get('PS_SAV_IMAP_PWD'))) {
return;
}
// Executes the IMAP synchronization.
$sync_errors = $this->syncImap();
// Show the errors.
if (isset($sync_errors['hasError']) && $sync_errors['hasError']) {
if (isset($sync_errors['errors'])) {
foreach ($sync_errors['errors'] as &$error) {
$this->displayWarning($error);
}
}
}
}
/**
* Imap synchronization method.
*
* @return array Errors list.
*/
public function syncImap()
{
if (!($url = Configuration::get('PS_SAV_IMAP_URL'))
|| !($port = Configuration::get('PS_SAV_IMAP_PORT'))
|| !($user = Configuration::get('PS_SAV_IMAP_USER'))
|| !($password = Configuration::get('PS_SAV_IMAP_PWD'))) {
return array('hasError' => true, 'errors' => array('IMAP configuration is not correct'));
}
$conf = Configuration::getMultiple(array(
'PS_SAV_IMAP_OPT_NORSH', 'PS_SAV_IMAP_OPT_SSL',
'PS_SAV_IMAP_OPT_VALIDATE-CERT', 'PS_SAV_IMAP_OPT_NOVALIDATE-CERT',
'PS_SAV_IMAP_OPT_TLS', 'PS_SAV_IMAP_OPT_NOTLS'));
$conf_str = '';
if ($conf['PS_SAV_IMAP_OPT_NORSH']) {
$conf_str .= '/norsh';
}
if ($conf['PS_SAV_IMAP_OPT_SSL']) {
$conf_str .= '/ssl';
}
if ($conf['PS_SAV_IMAP_OPT_VALIDATE-CERT']) {
$conf_str .= '/validate-cert';
}
if ($conf['PS_SAV_IMAP_OPT_NOVALIDATE-CERT']) {
$conf_str .= '/novalidate-cert';
}
if ($conf['PS_SAV_IMAP_OPT_TLS']) {
$conf_str .= '/tls';
}
if ($conf['PS_SAV_IMAP_OPT_NOTLS']) {
$conf_str .= '/notls';
}
if (!function_exists('imap_open')) {
return array('hasError' => true, 'errors' => array('imap is not installed on this server'));
}
$mbox = @imap_open('{'.$url.':'.$port.$conf_str.'}', $user, $password);
//checks if there is no error when connecting imap server
$errors = imap_errors();
if (is_array($errors)) {
$errors = array_unique($errors);
}
$str_errors = '';
$str_error_delete = '';
if (count($errors) && is_array($errors)) {
$str_errors = '';
foreach ($errors as $error) {
$str_errors .= $error.', ';
}
$str_errors = rtrim(trim($str_errors), ',');
}
//checks if imap connexion is active
if (!$mbox) {
return array('hasError' => true, 'errors' => array('Cannot connect to the mailbox :
'.($str_errors)));
}
//Returns information about the current mailbox. Returns FALSE on failure.
$check = imap_check($mbox);
if (!$check) {
return array('hasError' => true, 'errors' => array('Fail to get information about the current mailbox'));
}
if ($check->Nmsgs == 0) {
return array('hasError' => true, 'errors' => array('NO message to sync'));
}
$result = imap_fetch_overview($mbox, "1:{$check->Nmsgs}", 0);
foreach ($result as $overview) {
//check if message exist in database
if (isset($overview->subject)) {
$subject = $overview->subject;
} else {
$subject = '';
}
//Creating an md5 to check if message has been allready processed
$md5 = md5($overview->date.$overview->from.$subject.$overview->msgno);
$exist = Db::getInstance()->getValue(
'SELECT `md5_header`
FROM `'._DB_PREFIX_.'customer_message_sync_imap`
WHERE `md5_header` = \''.pSQL($md5).'\'');
if ($exist) {
if (Configuration::get('PS_SAV_IMAP_DELETE_MSG')) {
if (!imap_delete($mbox, $overview->msgno)) {
$str_error_delete = ', Fail to delete message';
}
}
} else {
//check if subject has id_order
preg_match('/\#ct([0-9]*)/', $subject, $matches1);
preg_match('/\#tc([0-9-a-z-A-Z]*)/', $subject, $matches2);
$match_found = false;
if (isset($matches1[1]) && isset($matches2[1])) {
$match_found = true;
}
$new_ct = (Configuration::get('PS_SAV_IMAP_CREATE_THREADS') && !$match_found && (strpos($subject, '[no_sync]') == false));
if ($match_found || $new_ct) {
if ($new_ct) {
if (!preg_match('/<('.Tools::cleanNonUnicodeSupport('[a-z\p{L}0-9!#$%&\'*+\/=?^`{}|~_-]+[.a-z\p{L}0-9!#$%&\'*+\/=?^`{}|~_-]*@[a-z\p{L}0-9]+[._a-z\p{L}0-9-]*\.[a-z0-9]+').')>/', $overview->from, $result)
|| !Validate::isEmail($from = $result[1])) {
continue;
}
// we want to assign unrecognized mails to the right contact category
$contacts = Contact::getContacts($this->context->language->id);
if (!$contacts) {
continue;
}
foreach ($contacts as $contact) {
if (strpos($overview->to, $contact['email']) !== false) {
$id_contact = $contact['id_contact'];
}
}
if (!isset($id_contact)) { // if not use the default contact category
$id_contact = $contacts[0]['id_contact'];
}
$customer = new Customer;
$client = $customer->getByEmail($from); //check if we already have a customer with this email
$ct = new CustomerThread();
if (isset($client->id)) { //if mail is owned by a customer assign to him
$ct->id_customer = $client->id;
}
$ct->email = $from;
$ct->id_contact = $id_contact;
$ct->id_lang = (int)Configuration::get('PS_LANG_DEFAULT');
$ct->id_shop = $this->context->shop->id; //new customer threads for unrecognized mails are not shown without shop id
$ct->status = CustomerThread::QLO_CUSTOMER_THREAD_STATUS_OPEN;
$ct->token = Tools::passwdGen(12);
$ct->add();
} else {
$ct = new CustomerThread((int)$matches1[1]);
} //check if order exist in database
if (Validate::isLoadedObject($ct) && ((isset($matches2[1]) && $ct->token == $matches2[1]) || $new_ct)) {
$message = imap_fetchbody($mbox, $overview->msgno, 1);
$message = quoted_printable_decode($message);
$message = utf8_encode($message);
$message = quoted_printable_decode($message);
$message = nl2br($message);
$message = Tools::substr($message, 0, (int) CustomerMessage::$definition['fields']['message']['size']);
$cm = new CustomerMessage();
$cm->id_customer_thread = $ct->id;
if (empty($message) || !Validate::isCleanHtml($message)) {
$str_errors.= Tools::displayError(sprintf('Invalid Message Content for subject: %1s', $subject));
} else {
$cm->message = $message;
$cm->add();
}
}
}
Db::getInstance()->execute('INSERT INTO `'._DB_PREFIX_.'customer_message_sync_imap` (`md5_header`) VALUES (\''.pSQL($md5).'\')');
}
}
imap_expunge($mbox);
imap_close($mbox);
if ($str_errors.$str_error_delete) {
return array('hasError' => true, 'errors' => array($str_errors.$str_error_delete));
}
else {
return array('hasError' => false, 'errors' => '');
}
}
}