<?php
namespace wstmart\admin\model;
use think\Db;
/**
* ============================================================================
* 订单投诉业务处理
*/
class OrderComplains extends Base{
/**
* 获取订单投诉列表
*/
public function pageQuery(){
$startDate = input('startDate');
$endDate = input('endDate');
$shopName = Input('shopName');
$orderNo = Input('orderNo');
$complainStatus = (int)Input('complainStatus',-1);
// 搜素条件
$areaId1 = (int)input('areaId1');
if($areaId1>0){
$where['s.areaIdPath'] = ['like',"$areaId1%"];
$areaId2 = (int)input("areaId1_".$areaId1);
if($areaId2>0)$where['s.areaIdPath'] = ['like',$areaId1."_"."$areaId2%"];
$areaId3 = (int)input("areaId1_".$areaId1."_".$areaId2);
if($areaId3>0)$where['s.areaId'] = $areaId3;
}
if($startDate!='' && $endDate!=''){
$where['oc.complainTime'] = ['between',[$startDate.' 00:00:00',$endDate.' 23:59:59']];
}else if($startDate!=''){
$where['oc.complainTime'] = ['>=',$startDate.' 00:00:00'];
}else if($endDate!=''){
$where['oc.complainTime'] = ['<=',$endDate.' 23:59:59'];
}
if($complainStatus>-1)$where['oc.complainStatus']=$complainStatus;
if($orderNo!='')$where['o.orderNo']=['like',"%$orderNo%"];
$where['o.dataFlag']=1;
$sort = input('sort');
$order = [];
if($sort!=''){
$sortArr = explode('.',$sort);
$order = $sortArr[0].' '.$sortArr[1];
}
$rs = Db::name('orders')->alias('o')
->field('oc.complainId,o.orderId,o.orderNo,o.orderSrc,s.shopName,u.userName,u.loginName,oc.complainTime,oc.complainStatus,oc.complainType,o.orderCode')
->join('__SHOPS__ s','o.shopId=s.shopId','inner','left')
->join('__USERS__ u','o.userId=u.userId','inner')
->join('__ORDER_COMPLAINS__ oc','oc.orderId=o.orderId','inner')
->where($where)
->order($order)
->order('complainId desc')
->paginate()
->toArray();
if(count($rs['Rows'])>0){
foreach ($rs['Rows'] as $key => $v){
$rs['Rows'][$key]['orderCodeTitle'] = WSTOrderCodeTitle($v['orderCode']);
}
}
return $rs;
}
/**
* 获取订单详细信息
*/
public function getDetail(){
$complainId = (int)Input('cid');
$data = $this->alias('oc')
->field('oc.*,u.userName,u.loginName')
->join('__USERS__ u','oc.complainTargetId=u.userId','inner')
->where("oc.complainId=$complainId")
->find();
if($data){
if($data['complainAnnex']!='')$data['complainAnnex'] = explode(',',$data['complainAnnex']);
if($data['respondAnnex']!='')$data['respondAnnex'] = explode(',',$data['respondAnnex']);
$data['userName'] = ($data['userName']=='')?$data['loginName']:$data['userName'];
$rs = Db::name('orders')->alias('o')
->field('o.orderStatus,o.areaId,o.userAddress,o.orderNo,o.userName,s.shopName,o.userAddress')
->join('__SHOPS__ s','o.shopId=s.shopId','left')
->where(['o.dataFlag'=>1,
'o.orderId'=>$data['orderId']])
->find();
//获取日志信息
$rs['log'] = Db::name('log_orders')->alias('lo')
->field('lo.*,u.loginName,u.userType,s.shopName')
->join('__USERS__ u','lo.logUserId=u.userId','left')
->join('__SHOPS__ s','u.userType=1 and s.userId=u.userId','left')
->where(['orderId'=>$data['orderId']])
->select();
//获取相关商品
$rs['goodslist'] = Db::name('order_goods')->where(['orderId'=>$data['orderId']])->select();
$data['order'] = $rs;
}
return $data;
}
/**
* 转交给应诉人应诉
*/
public function deliverRespond(){
$id = (int)Input('id');
if($id==0){
return WSTReturn('无效的投诉信息',-1);
}
//判断是否已经处理过了
$rs = $this->alias('oc')
->field('oc.complainStatus,oc.respondTargetId,o.orderNo,s.userId,o.shopId')
->join('__ORDERS__ o','oc.orderId=o.orderId','inner')
->join('__SHOPS__ s','o.shopId = s.shopId','left')
->where("complainId=$id")
->find();
if($rs['complainStatus']==0){
$data = array();
$data['needRespond'] = 1;
$data['complainStatus'] = 1;
$data['deliverRespondTime'] = date('Y-m-d H:i:s');
Db::startTrans();
try{
$ers = $this->where('complainId='.$id)->update($data);
if($ers!==false){
//发站内信息提醒
$tpl = WSTMsgTemplates('ORDER_NEW_COMPLAIN');
if( $tpl['tplContent']!='' && $tpl['status']=='1'){
$find = ['${ORDER_NO}'];
$replace = [$rs['orderNo']];
$msg = array();
$msg["shopId"] = $rs["shopId"];
$msg["tplCode"] = $tpl["tplCode"];
$msg["msgType"] = 1;
$msg["content"] = str_replace($find,$replace,$tpl['tplContent']) ;
$msg["msgJson"] = ['from'=>3,'dataId'=>$id];
model("common/MessageQueues")->add($msg);
}
Db::commit();
return WSTReturn('操作成功',1);
}
}catch (\Exception $e) {
Db::rollback();errLog($e);
return WSTReturn('操作失败',-1);
}
}else{
return WSTReturn('操作失败，该投诉状态已发生改变，请刷新后重试!',-1);
}
return $rd;
}
/**
* 仲裁
*/
public function finalHandle(){
$rd = array('status'=>-1,'msg'=>'无效的投诉信息');
$complainId = (int)Input('cid');
if($complainId==0){
return WSTReturn('无效的投诉信息',-1);
}
//判断是否已经处理过了
$rs = $this->alias('oc')
->field('oc.complainStatus,s.userId shopUserId,o.shopId,o.userId,o.orderNo,o.orderId,oc.needRespond')
->join('__ORDERS__ o','oc.orderId=o.orderId','inner')
->join('__SHOPS__ s','o.shopId=s.shopId','left')
->where("complainId=$complainId")
->find();
if($rs['complainStatus']!=4){
$data = array();
$data['finalHandleStaffId'] = session('WST_STAFF.staffId');
$data['complainStatus'] = 4;
$data['finalResult'] = Input('finalResult');
$data['finalResultTime'] = date('Y-m-d H:i:s');
Db::startTrans();
try{
$ers = $this->where('complainId='.$complainId)->update($data);
if($ers!==false){
//需要卖家回应的话则给卖家也一条消息
$tpl = WSTMsgTemplates('ORDER_HANDLED_COMPLAIN');
if( $tpl['tplContent']!='' && $tpl['status']=='1'){
//发站内商家信息提醒
$find = ['${ORDER_NO}'];
$replace = [$rs['orderNo']];
$content = str_replace($find,$replace,$tpl['tplContent']) ;
if($rs['needRespond']==1){
$msg = array();
$msg["shopId"] = $rs["shopId"];
$msg["tplCode"] = $tpl["tplCode"];
$msg["msgType"] = 1;
$msg["content"] = $content ;
$msg["msgJson"] = ['from'=>3,'dataId'=>$complainId];
model("common/MessageQueues")->add($msg);
}
//发站内用户信息提醒
WSTSendMsg($rs['userId'],$content,['from'=>3,'dataId'=>$complainId]);
}
Db::commit();
return WSTReturn('操作成功',1);
}
}catch(\Exception $e){
Db::rollback();errLog($e);
return WSTReturn('操作失败',-1);
}
}else{
return WSTReturn('操作失败，该投诉状态已发生改变，请刷新后重试!',-1);
}
}
}