296 lines
9.2 KiB
PHP
296 lines
9.2 KiB
PHP
<?php
|
||
|
||
/**
|
||
* SaaSMall商城系统 - 团队十年电商经验汇集巨献!
|
||
* =========================================================
|
||
* Copy right 2019-2029 成都SAAS云科技有限公司, 保留所有权利。
|
||
* ----------------------------------------------
|
||
* 官方网址: https://www.gobuysaas.com
|
||
|
||
* =========================================================
|
||
*/
|
||
|
||
namespace addon\servicer\model;
|
||
|
||
use app\model\BaseModel;
|
||
use think\db\exception\DataNotFoundException;
|
||
use think\db\exception\DbException;
|
||
use think\db\exception\ModelNotFoundException;
|
||
use think\Model;
|
||
|
||
class Dialogue extends BaseModel
|
||
{
|
||
/**
|
||
* 消息类型，字符串
|
||
*/
|
||
const CONTENTTYPE_STRING = 0;
|
||
/**
|
||
* 消息类型，商品SKU
|
||
*/
|
||
const CONTENTTYPE_GOODSKU = 1;
|
||
/**
|
||
* 消息类型，订单
|
||
*/
|
||
const CONTENTTYPE_ORDER = 2;
|
||
/**
|
||
* 消息类型，图片
|
||
*/
|
||
const CONTENTTYPE_IMAGE = 3;
|
||
|
||
/**
|
||
* 状态
|
||
* @param mixed $content_type
|
||
* @param string $type
|
||
* @return array
|
||
*/
|
||
public static function contentType($content_type = null, $type = 'content_type')
|
||
{
|
||
$data = array(
|
||
array(
|
||
'content_type' => self::CONTENTTYPE_STRING,
|
||
'name' => '字符串',
|
||
'type' => 'string',
|
||
'const' => 'CONTENTTYPE_STRING',
|
||
),
|
||
array(
|
||
'content_type' => self::CONTENTTYPE_GOODSKU,
|
||
'name' => '商品',
|
||
'type' => 'goodssku',
|
||
'const' => 'CONTENTTYPE_GOODSKU',
|
||
),
|
||
array(
|
||
'content_type' => self::CONTENTTYPE_ORDER,
|
||
'name' => '订单',
|
||
'type' => 'order',
|
||
'const' => 'CONTENTTYPE_ORDER',
|
||
),
|
||
array(
|
||
'content_type' => self::CONTENTTYPE_IMAGE,
|
||
'name' => '图片',
|
||
'type' => 'image',
|
||
'const' => 'CONTENTTYPE_IMAGE',
|
||
),
|
||
);
|
||
$result = [];
|
||
if (is_null($content_type)) {
|
||
$result = $data;
|
||
} else {
|
||
if (is_array($content_type)) {
|
||
|
||
foreach ($data as $val) {
|
||
|
||
if (in_array($val[$type], $content_type)) {
|
||
$result[] = $val;
|
||
}
|
||
}
|
||
} else {
|
||
foreach ($data as $val) {
|
||
if ($content_type == $val[$type]) {
|
||
$result = $val;
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* 插入对话数据
|
||
* @param integer $type 会话方向，0 客户，1 客服
|
||
* @param integer $memberId 会员ID
|
||
* @param integer $serviceId 客服ID
|
||
* @param integer $contentType 内容类型
|
||
* @param integer $read 是否已读
|
||
* @param integer $shopId 商户ID
|
||
* @param integer $userId 用户ID
|
||
* @param string $consumerSay 客户咨询内容
|
||
* @param string $servicerSay 客服回答内容
|
||
* @param integer $goodSkuId 商品ID
|
||
* @param integer $orderId 订单ID
|
||
* @return integer
|
||
*/
|
||
public function createDialogue($type, $memberId, $serviceId, $contentType, $read, $shopId, $userId, $consumerSay = '', $servicerSay = '', $goodSkuId = 0, $orderId = 0, $relate_data = '')
|
||
{
|
||
return model('servicer_dialogue')->add([
|
||
'member_id' => $memberId,
|
||
'servicer_id' => $serviceId,
|
||
'create_day' => date('Y-m-d'),
|
||
'create_time' => date('H:i:s'),
|
||
'add_time' => time(),
|
||
'content_type' => $contentType,
|
||
'read' => $read,
|
||
'shop_id' => $shopId,
|
||
'goods_sku_id' => $goodSkuId,
|
||
'order_id' => $orderId,
|
||
'consumer_say' => $consumerSay,
|
||
'servicer_say' => $servicerSay,
|
||
'type' => $type,
|
||
'relate_data' => $relate_data,
|
||
'content' => empty($servicerSay) ? $consumerSay : $servicerSay,
|
||
'message' => $this->handleMessage($consumerSay, $servicerSay, $contentType),
|
||
]);
|
||
}
|
||
|
||
/**
|
||
* 处理纯文本消息
|
||
* @param string $consumerSay
|
||
* @param string $servicerSay
|
||
* @param $contentType
|
||
* @return mixed
|
||
*/
|
||
private function handleMessage(string $consumerSay, string $servicerSay, $contentType = 0)
|
||
{
|
||
$message = '';
|
||
if ($contentType == self::CONTENTTYPE_STRING) {
|
||
if (!empty($servicerSay)) {
|
||
$message = $servicerSay;
|
||
}
|
||
if (!empty($consumerSay)) {
|
||
$message = $consumerSay;
|
||
}
|
||
$message = strip_tags($message);
|
||
$message = str_replace([' ', '\r\n', '\r', '\n'], '', $message);
|
||
}
|
||
return $message;
|
||
}
|
||
|
||
/**
|
||
* 设置消息已读状态
|
||
* @param $id
|
||
* @param bool $read
|
||
* @return int
|
||
* @throws DbException
|
||
*/
|
||
public function setDialogueRead($id, $read = true)
|
||
{
|
||
return model('servicer_dialogue')->setFieldValue(['id' => $id], 'read', $read ? 1 : 0);
|
||
}
|
||
|
||
/**
|
||
* 获取会话详情
|
||
* @param $id
|
||
* @return array|Model|null
|
||
* @throws DataNotFoundException
|
||
* @throws DbException
|
||
* @throws ModelNotFoundException
|
||
*/
|
||
public function getDialogue($id)
|
||
{
|
||
return model('servicer_dialogue')->getInfo(['id' => $id]);
|
||
}
|
||
|
||
/**
|
||
* 查询聊天记录
|
||
* @param $memberId
|
||
* @param int $page
|
||
* @param int $limit
|
||
* @param int $siteId
|
||
* @param int $servicerId
|
||
* @return mixed
|
||
* @throws DataNotFoundException
|
||
* @throws DbException
|
||
* @throws ModelNotFoundException
|
||
*/
|
||
public function getDialogueList($memberId, $page = 1, $limit = 20, $siteId = 0, $servicerId=0)
|
||
{
|
||
$alias = 'sd';
|
||
$field = ['sd.id', 'sd.create_day', 'sd.type', 'sd.create_time', 'sd.content_type', 'sd.read', 'sd.goods_sku_id', 'sd.order_id', 'sd.consumer_say', 'sd.servicer_say'];
|
||
$order = ['sd.id' => 'desc'];
|
||
|
||
$join = [
|
||
['servicer s', 's.id = sd.servicer_id', 'LEFT'], // 关联客服
|
||
['goods_sku g', 'g.sku_id = sd.goods_sku_id', 'LEFT'], // 关联商品，聊天记录为商品时
|
||
['order o', 'o.order_id = sd.order_id', 'LEFT'],
|
||
['order_goods og', 'og.order_id = o.order_id', 'LEFT']
|
||
];
|
||
|
||
$field = array_merge($field, ['s.is_platform']);
|
||
$field = array_merge($field, ['g.goods_name', 'g.sku_image', 'g.price']);
|
||
$field = array_merge($field, ['o.order_no', 'o.goods_money', 'o.order_money', 'o.order_status', 'o.order_status_name']);
|
||
$field = array_merge($field, ['og.sku_name', 'og.sku_image']);
|
||
|
||
$condition[] = ['sd.member_id', '=', $memberId];
|
||
$condition[] = ['sd.shop_id', '=', $siteId];
|
||
if(!empty($servicerId)){
|
||
$condition[] = ['sd.servicer_id', '=', $servicerId];
|
||
}
|
||
|
||
return model('servicer_dialogue')->pageList($condition, $field, $order, $page, $limit, $alias, $join, null, $limit);
|
||
}
|
||
|
||
|
||
/**
|
||
* 获取聊天列表相关信息-分页查询
|
||
* @param array $map
|
||
* @param bool $field
|
||
* @param string $order
|
||
* @param int $page
|
||
* @param int $list_rows
|
||
* @param string $alias
|
||
* @param array $join
|
||
* @param null $group
|
||
* @param null $limit
|
||
* @return mixed
|
||
* @throws DataNotFoundException
|
||
* @throws DbException
|
||
* @throws ModelNotFoundException
|
||
*/
|
||
public function getPageList($map = [], $field = true, $order = '', $page = 1, $list_rows = PAGE_LIST_ROWS, $alias = '', $join = [], $group = null, $limit = null)
|
||
{
|
||
return model('servicer_dialogue')->pageList($map, $field, $order, $page, $list_rows, $alias, $join, $group, $limit);
|
||
}
|
||
|
||
|
||
/**
|
||
* 设置消息读取状态
|
||
* @param $condition
|
||
* @param bool $read
|
||
* @return int
|
||
*/
|
||
public function setDialoguesRead($condition, $read = true)
|
||
{
|
||
return model('servicer_dialogue')->setFieldValue($condition, 'read', $read ? 1 : 0);
|
||
}
|
||
|
||
/**
|
||
* 获取信息
|
||
* @param $condition
|
||
* @param bool $field
|
||
* @return array
|
||
*/
|
||
public function getInfo($condition, $field = true)
|
||
{
|
||
$res = model('servicer_dialogue')->getInfo($condition, $field);
|
||
$res = $this->handleData($res);
|
||
return $this->success($res);
|
||
}
|
||
|
||
/**
|
||
* 处理数据
|
||
* @param $info
|
||
* @return mixed
|
||
*/
|
||
private function handleData($info)
|
||
{
|
||
if (!empty($info)) {
|
||
if (isset($info['relate_data'])) {
|
||
$info['relate_data_parse'] = !empty($info['relate_data']) ? json_decode($info['relate_data'], true) : [];
|
||
}
|
||
}
|
||
return $info;
|
||
}
|
||
|
||
/**
|
||
* 接入所有未读消息给客服
|
||
* @param $siteId
|
||
* @param $servicerId
|
||
* @return int
|
||
*/
|
||
public function joinDialogues($siteId, $servicerId)
|
||
{
|
||
$condition = [['shop_id', '=', $siteId], ['servicer_id', '=', 0], ['type', '=', 0]];
|
||
return model('servicer_dialogue')->setFieldValue($condition, 'servicer_id', $servicerId);
|
||
}
|
||
}
|