219 lines
7.4 KiB
PHP
219 lines
7.4 KiB
PHP
<?php
|
||
// +----------------------------------------------------------------------
|
||
// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
|
||
// +----------------------------------------------------------------------
|
||
// | Copyright (c) 2016~2020 https://www.crmeb.com All rights reserved.
|
||
// +----------------------------------------------------------------------
|
||
// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
|
||
// +----------------------------------------------------------------------
|
||
// | Author: CRMEB Team <admin@crmeb.com>
|
||
// +----------------------------------------------------------------------
|
||
|
||
namespace app\services\order;
|
||
|
||
|
||
use app\dao\order\StoreOrderDao;
|
||
use app\jobs\order\AutoCommentOrderJob;
|
||
use app\services\BaseServices;
|
||
use app\services\product\product\StoreProductReplyServices;
|
||
use app\services\user\UserServices;
|
||
use think\exception\ValidateException;
|
||
|
||
/**
|
||
* 订单评价
|
||
* Class StoreOrderCommentServices
|
||
* @package app\services\order
|
||
* @mixin StoreOrderDao
|
||
*/
|
||
class StoreOrderCommentServices extends BaseServices
|
||
{
|
||
/**
|
||
* 评论默认数据
|
||
* @var string[]
|
||
*/
|
||
protected $commentArr = [
|
||
'reply_score' => 3,
|
||
'product_score' => 5,
|
||
'service_score' => 5,
|
||
'delivery_score' => 5,
|
||
'comment' => '',
|
||
'pics' => [],
|
||
];
|
||
|
||
/**
|
||
* 构造方法
|
||
* StoreOrderTakeServices constructor.
|
||
* @param StoreOrderDao $dao
|
||
*/
|
||
public function __construct(StoreOrderDao $dao)
|
||
{
|
||
$this->dao = $dao;
|
||
}
|
||
|
||
/**
|
||
* 订单评价
|
||
* @param int $oid
|
||
* @param int $uid
|
||
* @param array $group
|
||
* @param string $unique
|
||
* @return bool
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\DbException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
*/
|
||
public function comment(int $oid, int $uid = 0, array $group = [], string $unique = '')
|
||
{
|
||
if (!$oid) throw new ValidateException('参数错误!');
|
||
$order = $this->dao->get($oid);
|
||
if (!$order) {
|
||
throw new ValidateException('订单不存在!');
|
||
}
|
||
$where = ['oid' => $oid];
|
||
if ($unique) {
|
||
$where['unique'] = $unique;
|
||
}
|
||
/** @var StoreOrderCartInfoServices $cartInfoServices */
|
||
$cartInfoServices = app()->make(StoreOrderCartInfoServices::class);
|
||
$cartInfos = $cartInfoServices->getColumn($where, 'oid,product_id,cart_info,unique');
|
||
if (!$cartInfos) {
|
||
throw new ValidateException('评价商品不存在');
|
||
}
|
||
$group = array_merge($this->commentArr, array_intersect_key($group, $this->commentArr));
|
||
$group['comment'] = htmlspecialchars(trim($group['comment']));
|
||
if ($group['product_score'] < 1) throw new ValidateException('请为商品评分');
|
||
if ($group['service_score'] < 1) throw new ValidateException('请为商家服务评分');
|
||
if ($group['delivery_score'] < 1) throw new ValidateException('请为物流服务评分');
|
||
if ($group['pics']) $group['pics'] = json_encode(is_array($group['pics']) ? $group['pics'] : explode(',', $group['pics']));
|
||
$user_info = [];
|
||
if ($uid) {
|
||
/** @var UserServices $userServices */
|
||
$userServices = app()->make(UserServices::class);
|
||
$user_info = $userServices->getUserInfo($uid);
|
||
}
|
||
if ($order['store_id']) {
|
||
$group['type'] = 1;
|
||
$group['relation_id'] = $order['store_id'];
|
||
} elseif ($order['supplier_id']) {
|
||
$group['type'] = 2;
|
||
$group['relation_id'] = $order['supplier_id'];
|
||
} else {
|
||
$group['type'] = $group['relation_id'] = 0;
|
||
}
|
||
$group = array_merge($group, [
|
||
'uid' => $uid,
|
||
'nickname' => $user_info['nickname'] ?? substr(md5($oid . time()), 0, 12),
|
||
'avatar' => $user_info['avatar'] ?? sys_config('h5_avatar'),
|
||
'oid' => $oid,
|
||
'add_time' => time(),
|
||
'reply_type' => 'product'
|
||
]);
|
||
/** @var StoreProductReplyServices $replyServices */
|
||
$replyServices = app()->make(StoreProductReplyServices::class);
|
||
$data_all = [];
|
||
$ids = [];
|
||
foreach ($cartInfos as $cartInfo) {
|
||
if ($replyServices->be(['oid' => $cartInfo['oid'], 'unique' => $cartInfo['unique']])) continue;
|
||
$_info = is_string($cartInfo['cart_info']) ? json_decode($cartInfo['cart_info'], true) : $cartInfo['cart_info'];
|
||
if (isset($_info['activity_id']) && $_info['activity_id']) $productId = $_info['product_id'];
|
||
else $productId = $cartInfo['product_id'];
|
||
$productId = $replyServices->checkReplyProductId((int)$productId);
|
||
$ids[] = $productId;
|
||
$group['unique'] = $cartInfo['unique'];
|
||
$group['product_id'] = $productId;
|
||
$group['sku_unique'] = $_info['productInfo']['attrInfo']['unique'] ?? '';
|
||
$group['sku'] = $_info['productInfo']['attrInfo']['suk'] ?? '';
|
||
$data_all[] = $group;
|
||
}
|
||
if ($data_all) {
|
||
$res = $replyServices->saveAll($data_all);
|
||
if (!$res) {
|
||
throw new ValidateException('评价失败!');
|
||
}
|
||
}
|
||
try {
|
||
/** @var StoreOrderServices $orderServices */
|
||
$orderServices = app()->make(StoreOrderServices::class);
|
||
$orderServices->checkOrderOver($replyServices, $cartInfoServices->getCartColunm(['oid' => $oid, 'is_gift' => 0], 'unique', ''), $oid);
|
||
} catch (\Exception $e) {
|
||
throw new ValidateException($e->getMessage());
|
||
}
|
||
//清除评价缓存
|
||
$replyServices->cacheTag()->clear();
|
||
//订单评价成功事件
|
||
event('order.comment', [$order]);
|
||
if ($ids) {
|
||
//商品评价
|
||
event('product.reply', [$ids]);
|
||
}
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 加入队列
|
||
* @param array $where
|
||
* @param int $count
|
||
* @param int $maxLimit
|
||
* @return bool
|
||
*/
|
||
public function batchJoinJobs(array $where, int $count, int $maxLimit)
|
||
{
|
||
$page = ceil($count / $maxLimit);
|
||
for ($i = 1; $i <= $page; $i++) {
|
||
AutoCommentOrderJob::dispatch([$where, $i, $maxLimit]);
|
||
}
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 执行自动默认好评
|
||
* @param array $where
|
||
* @param int $page
|
||
* @param int $maxLimit
|
||
* @return bool
|
||
*/
|
||
public function runAutoCommentOrder(array $where, int $page = 0, int $maxLimit = 0)
|
||
{
|
||
/** @var StoreOrderStoreOrderStatusServices $service */
|
||
$service = app()->make(StoreOrderStoreOrderStatusServices::class);
|
||
$orderList = $service->getOrderIds($where, $page, $maxLimit);
|
||
foreach ($orderList as $order) {
|
||
if ($order['status'] == 3) {
|
||
continue;
|
||
}
|
||
$group = ['comment' => '此用户未作评价'];
|
||
$this->comment((int)$order['id'], (int)$order['uid'], $group);
|
||
}
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 自动默认好评
|
||
* @return bool
|
||
*/
|
||
public function autoCommentOrder()
|
||
{
|
||
//7天前时间戳
|
||
$systemCommentTime = (int)sys_config('system_comment_time', 0);
|
||
//0为取消自动默认好评功能
|
||
if ($systemCommentTime == 0) {
|
||
return true;
|
||
}
|
||
$sevenDay = strtotime(date('Y-m-d H:i:s', strtotime('-' . $systemCommentTime . ' day')));
|
||
/** @var StoreOrderStoreOrderStatusServices $service */
|
||
$service = app()->make(StoreOrderStoreOrderStatusServices::class);
|
||
$where = [
|
||
'change_time' => $sevenDay,
|
||
'is_del' => 0,
|
||
'paid' => 1,
|
||
'status' => 2,
|
||
'change_type' => ['user_take_delivery', 'take_delivery']
|
||
];
|
||
$maxLimit = 20;
|
||
$count = $service->getOrderCount($where);
|
||
if ($count > $maxLimit) {
|
||
return $this->batchJoinJobs($where, $count, $maxLimit);
|
||
}
|
||
return $this->runAutoCommentOrder($where);
|
||
}
|
||
}
|