503 lines
19 KiB
PHP
503 lines
19 KiB
PHP
<?php
|
|
namespace app\admin\controller;
|
|
require_once(__DIR__.'/xlsxwriter.class.php');
|
|
|
|
use app\model\Admins;
|
|
use app\model\Backs;
|
|
use app\model\Follows;
|
|
use app\model\Orders;
|
|
use app\model\Logs;
|
|
use stdClass;
|
|
use support\Log;
|
|
use support\Redis;
|
|
use support\Request;
|
|
use think\facade\Db;
|
|
|
|
class OrderController extends base
|
|
{
|
|
|
|
public function index(Request $request) {
|
|
$sn = $request->get('sn');
|
|
$timetype = $request->get('timetype');
|
|
$times = $request->get('times');
|
|
$os_status = $request->get('os_status');
|
|
|
|
$where = [];
|
|
if(!$request->admin->is_super) {
|
|
$where = [['admin_id','=', $request->admin->id]];
|
|
}
|
|
|
|
if($sn) {
|
|
$where[] = ['sn','=', $sn];
|
|
}
|
|
|
|
$status = $request->get('status', null);
|
|
|
|
$query = Orders::attimes($timetype, $times)->with(['admin','anchor','backs'])->where($where)
|
|
->order('create_at','desc')
|
|
->order('update_time','desc')
|
|
->order('id','desc');
|
|
|
|
if($status!=null && $status >= 0) {
|
|
$query->where('status', $status);
|
|
}
|
|
|
|
if($os_status) {
|
|
$query->where('os', $os_status[0] ?? 0 )->where('order_status', $os_status[1] ?? 0);
|
|
}
|
|
|
|
$mobile = $request->get('mobile');
|
|
if($mobile){
|
|
$query->where('mobile','like', '%'.$mobile.'%');
|
|
}
|
|
|
|
$zhubo = $request->get('zhubo');
|
|
if($zhubo){
|
|
$zhubo_id = Admins::where('username', $zhubo)->value('id');
|
|
$query->where('zhubo', $zhubo_id);
|
|
}
|
|
|
|
$admin = $request->get('admin');
|
|
if($admin){
|
|
$admin_id = Admins::where('username', $admin)->value('id');
|
|
$query->where('admin_id', $admin_id);
|
|
}
|
|
|
|
$excel = $request->get('excel');
|
|
if($excel == 1) {
|
|
$orders = $query->select();
|
|
|
|
$writer = new \XLSXWriter();
|
|
$writer->writeSheetHeader('Sheet1', ['电话'=>'string','平台'=>'string','直播'=>'string','订单号'=>'string','下单时间'=>'string','状态'=>'string','跟进状态'=>'string',
|
|
'标题'=>'string','跟进备注'=>'string','联系人'=>'string','出行时间'=>'string','回来时间'=>'string',
|
|
'跟进时间'=>'string',
|
|
'总金额'=>'price','支付金额'=>'price','核销金额'=>'price','人数'=>'integer','跟单人'=>'string','主播'=>'string']);
|
|
|
|
foreach($orders as $order) {
|
|
$writer->writeSheetRow('Sheet1', [$order->mobile, $order->os_name, $order->is_zhibo, "$order->sn", date('Y-m-d H:i:s', intval($order->create_at/1000)),$order->order_status_name, $order->status_name,
|
|
$order->product_name, $order->remark, $order->contact, $order->travel_date, $order->travel_end,
|
|
$order->last_follow ? date('Y-m-d H:i:s', intval($order->last_follow/1000)):'',
|
|
$order->total_price/100, $order->actual_price/100, $order->asset_price/100, $order->quantity, $order->admin->username ?? '', $order->anchor->username ?? '']);
|
|
}
|
|
|
|
$file_name = "订单导出-".date('Ymd-His').".xlsx";
|
|
|
|
$response = response();
|
|
$c = $writer->writeToString();
|
|
$response->withHeaders([
|
|
'Content-Type' => 'application/force-download',
|
|
'Content-Disposition' => 'attachment; filename="'.$file_name.'"',
|
|
'Content-Transfer-Encoding' => 'binary',
|
|
'Cache-Control' => 'max-age=0',
|
|
])->withBody($c);
|
|
return $response;
|
|
// return;
|
|
}else{
|
|
$orders = $query->paginate($request->get('limit',10));
|
|
}
|
|
|
|
foreach($orders as &$order) {
|
|
if(empty($order->personnel)) {
|
|
$order->personnel = new stdClass();
|
|
}
|
|
}
|
|
|
|
$list = $orders->visible(['admin' => ['username','name','avatar']])->hidden(['check_sn'])->append(['order_status_name','status_name','os_name']);
|
|
|
|
$_oss = [];
|
|
$_oss[] = [];
|
|
foreach (Orders::OSS as $key=>$os) {
|
|
$_oss[$key] = ['label' => $os,'value' => $key];
|
|
if($key == 1) {
|
|
$statss = Orders::OrderStatus;
|
|
}elseif($key ==2) {
|
|
$statss = Orders::KuaishouStatus;
|
|
}elseif($key ==3) {
|
|
$statss = Orders::DouyinStatus;
|
|
}/*elseif ($key == 4) {
|
|
$statss = Orders::AllPlatform;
|
|
}*/
|
|
|
|
$_ch = [];
|
|
foreach($statss as $k=>$v) {
|
|
$_ch[] = ['label' => $v,'value' => $k];
|
|
}
|
|
|
|
$_oss[$key]['children'] = $_ch;
|
|
}
|
|
|
|
return $this->success($list,null,['timetype'=> Orders::timeType, 'oss' => $_oss]);
|
|
}
|
|
|
|
public function all(Request $request) {
|
|
$sn = $request->get('sn');
|
|
|
|
if($sn) {
|
|
$where[] = ['sn','=', $sn];
|
|
}
|
|
$orders = Orders::with(['admin'])->where($where)->order('update_time','desc')->order('create_at','desc')->order('id','desc')->paginate($request->get('limit',10));
|
|
|
|
return $this->success($orders->visible(['admin' => ['username','name','avatar']])->hidden(['mobile','check_sn'])->append(['order_status_name','status_name','os_name']));
|
|
}
|
|
|
|
public function pub(Request $request) {
|
|
$orders = Orders::where('admin_id', 0)->order('create_at','desc')->order('id','desc')->paginate($request->get('limit',10));
|
|
|
|
return $this->success($orders->hidden(['mobile','check_sn'])->append(['order_status_name','os_name']));
|
|
}
|
|
|
|
//公海领取订单
|
|
public function fish(Request $request) {
|
|
$id = $request->post('id');
|
|
if(empty($id) || intval($id) <=0) return $this->error(2001, '请提交id');
|
|
|
|
$order = Orders::find($id);
|
|
if($order->admin_id > 0 ) return $this->error(2002, '订单没有找到或者已经转移到其他人');
|
|
|
|
try{
|
|
Orders::fish($order->id, $request->admin->id);
|
|
return $this->success(null);
|
|
}catch(\Exception $e){
|
|
return $this->error(2003, '公海获取订单失败,订单没有找到或者已经转移到其他人');
|
|
}
|
|
}
|
|
|
|
public function info(Request $request) {
|
|
$id = $request->get('id');
|
|
|
|
if(empty($id) || intval($id) <=0) return $this->error(2001, '请提交id');
|
|
|
|
$where[] = ['id','=',$id];
|
|
|
|
if($request->admin->is_super == 0) {
|
|
$where[] = ['admin_id','=',$request->admin->id];
|
|
}
|
|
$item = Orders::where($where)->with(['follow.admin','finance'])->find();
|
|
|
|
if(empty($item)) {
|
|
return $this->error(2002, '订单没有找到或者已经转移到其他人');
|
|
}
|
|
Logs::see($item->id, $request->admin->id);
|
|
|
|
if(empty($item->personnel)) {
|
|
$item->personnel = new stdClass();
|
|
}
|
|
|
|
return $this->success($item->append(['order_status_name','os_name']));
|
|
}
|
|
|
|
//核销,跟单
|
|
public function save(Request $request) {
|
|
$id = $request->post('id');
|
|
$next_follow = $request->post('next_follow');
|
|
$check_sn = $request->post('check_sn');
|
|
$desc = $request->post('desc');
|
|
$status = $request->post('status');
|
|
$is_wechat = $request->post('is_wechat');
|
|
$personnel = $request->post('personnel');
|
|
$travel_date = $request->post('travel_date');
|
|
$travel_end = $request->post('travel_end');
|
|
|
|
|
|
if(empty($desc) || empty($status)) return $this->error(2004, '跟进说明需要填写！');
|
|
if(empty($personnel)) return $this->error(2004, '人员情况需要填写！');
|
|
if(empty($travel_date)) return $this->error(2004, '出游时间需要填写！');
|
|
if ($status == 1){
|
|
if(empty($next_follow)) return $this->error(2004, '下次跟进时间需要填写！');
|
|
|
|
}
|
|
if ($status == 2){
|
|
$next_follow = '';
|
|
if(empty($travel_end)) return $this->error(2004, '返回日期需要填写！');
|
|
if(empty($check_sn)) return $this->error(2004, '核销码需要填写！');
|
|
}
|
|
|
|
$lock = 'Travel:Order:'.$id.':lock';
|
|
$back = Redis::set($lock, $request->admin->id, 'EX', 6, 'NX');
|
|
if(!$back) return $this->error(2005, '锁定失败');
|
|
|
|
$item = Orders::where('id', $id)->where('admin_id', $request->admin->id)->find();
|
|
if(empty($item)) return $this->error(2006, '订单不存在');
|
|
if($item->admin_id != $request->admin->id) return $this->error(2007, '订单已经发生转移');
|
|
|
|
if(!empty($travel_date) && empty($travel_end)) return $this->error(2008, '核销的订单请填写出行和返回时间');
|
|
|
|
Follows::create([
|
|
'admin_id' => $request->admin->id,
|
|
'order_id' => $item->id,
|
|
'status' => $status,
|
|
'desc' => $desc
|
|
]);
|
|
|
|
//放弃跟进
|
|
// if($status == 4) {
|
|
// $item->status = 0;
|
|
// $item->admin_id = 0;
|
|
// $item->remark = $desc;
|
|
// $item->save();
|
|
// return $this->success($item);
|
|
// }else{
|
|
//修改状态
|
|
$item->check_sn = $check_sn;
|
|
$item->status = $status;
|
|
!empty($travel_date) && empty($item->travel_date) ? $item->travel_date = date('Y-m-d', strtotime($travel_date)) : null;
|
|
!empty($travel_end) && empty($item->travel_end) ? $item->travel_end = date('Y-m-d', strtotime($travel_end)) : null;
|
|
$item->personnel = json_encode($personnel);
|
|
$item->is_wechat = $is_wechat? 1: 0;
|
|
$item->last_follow = microtime(true) * 1000;
|
|
$item->next_follow = strtotime($next_follow??'') * 1000;
|
|
$item->remark = $desc;
|
|
|
|
$back = $item->save();
|
|
// }
|
|
|
|
if($back) {
|
|
if ($item->check_sn) {
|
|
//通过命令行核销订单
|
|
Redis::LPUSH('Travel:Order:check:lits',json_encode([
|
|
'id' => $item->id,
|
|
'check_sn' => $item->check_sn
|
|
]));
|
|
|
|
// 限制只被录入一次
|
|
$has = Logs::where('admin_id', $request->admin->id)->whereIN('action',[2,3])->where('check_sn',$check_sn)->find();
|
|
if(empty($has)) {
|
|
Logs::pass($item->id, $request->admin->id, $check_sn);
|
|
}
|
|
}
|
|
if($item->is_wechat > 0 ) {
|
|
$has = Logs::where('admin_id', $request->admin->id)->where('order_id', $item->id)->where('action', 5)->find();
|
|
if(empty($has)) {
|
|
Logs::wechat($item->id, $request->admin->id);
|
|
}
|
|
}
|
|
|
|
return $this->success($item);
|
|
}else{
|
|
return $this->error(2008, '保存订单失败');
|
|
}
|
|
}
|
|
|
|
public function pass(Request $request) {
|
|
$check_sn = $request->post('check_sn');
|
|
if(!is_numeric($check_sn)) return $this->error(2008, '格式错误');
|
|
|
|
$has = Orders::where('check_sn', $check_sn)->find();
|
|
if($has) {
|
|
return $this->error(2008, '核销码已经被使用了');
|
|
}
|
|
|
|
//限制只被录入一次
|
|
$has = Logs::where('admin_id', $request->admin->id)->whereIN('action',[2,3])->where('check_sn', $check_sn)->find();
|
|
if(empty($has)) {
|
|
Logs::pass2($request->admin->id, $check_sn);
|
|
}
|
|
|
|
//通过命令行核销订单
|
|
Redis::LPUSH('Travel:Order:check:lits',json_encode([
|
|
'admin_id' => $request->admin->id,
|
|
'check_sn' => $check_sn
|
|
]));
|
|
|
|
return $this->success(null,'提交成功');
|
|
}
|
|
|
|
//把订单拉回
|
|
public function backlist(Request $request) {
|
|
$sn = $request->get('sn');
|
|
$status = $request->get('status',null);
|
|
|
|
$query = Backs::with(['into','outto','orders','apply'])->where(function($query) use($request) {
|
|
$query->where('admin_id', $request->admin->id)->WhereOr('admin', $request->admin->id);
|
|
})->order('update_time','desc')->order('id','desc');
|
|
|
|
if($sn) {
|
|
$order_id = Orders::where('sn', $sn)->value('id');
|
|
$query->where('order_id', $order_id);
|
|
}
|
|
|
|
if($status != null) {
|
|
$query->where('status', $status);
|
|
}
|
|
|
|
$backs = $query->paginate($request->get('limit',10));
|
|
foreach($backs as &$back){
|
|
if ($back->admin_id == $request->admin->id || $back->admin == $request->admin->id){
|
|
$back->self = 0;
|
|
if($back->apply_id == $request->admin->id) {
|
|
$back->self = 3;
|
|
}
|
|
}else{
|
|
$back->self = 1;
|
|
}
|
|
}
|
|
|
|
return $this->success($backs->append(['order_status_name','os_name']),null, Orders::OSS);
|
|
}
|
|
|
|
//把订单拉回
|
|
public function back(Request $request) {
|
|
$sn = $request->post('sn');
|
|
$os = $request->post('os');
|
|
$to_admin_id = $request->post('to_admin_id');
|
|
$admin_id = empty($to_admin_id) ? $request->admin->id : $to_admin_id;
|
|
|
|
if(empty($sn)) return $this->error(2001, '提交单号');
|
|
|
|
$item = Orders::where('sn', $sn)->where('os', $os)->find();
|
|
if(empty($item)) return $this->error(2002, '订单没有找到');
|
|
if($item->admin_id == $admin_id) return $this->error(2002, '订单已经在账号上,不需要再拉取!');
|
|
|
|
//管理员不用审批
|
|
$status = 0;
|
|
if ($request->admin->is_super == 1 || $request->admin->id == 1){
|
|
$status = 1;
|
|
}
|
|
|
|
$backs = [
|
|
'order_id' => $item->id,
|
|
'admin_id' => $admin_id,
|
|
'admin' => $item->admin_id,
|
|
'apply_id' => $request->admin->id,
|
|
'status' => $status
|
|
];
|
|
try {
|
|
Db::transaction(function() use ($backs,$item) {
|
|
Backs::create($backs);
|
|
Logs::todo($backs['order_id'], $backs['apply_id'], $backs['status'] == 1 ? 12 : 7,$item->sn);
|
|
|
|
if ($backs['status'] == 1){//管理员审批处理
|
|
Orders::where('id', $backs['order_id'])->where('admin_id', $backs['admin'])->update(['admin_id'=> $backs['admin_id']]);
|
|
$other = Backs::where('order_id', $backs['order_id'])->where('status', 0)->lock()->select();
|
|
foreach($other as $o) {
|
|
Backs::where('id', $o->id)->where('status', 0)->update(['status' => 3]);
|
|
Logs::todo($o->order_id, $o->admin, 10); //取消其他转单需求
|
|
}
|
|
}
|
|
});
|
|
}catch (\Exception $e){
|
|
return $this->error(2003, '创建拉回记录失败了');
|
|
}
|
|
|
|
return $this->success(true);
|
|
}
|
|
|
|
public function toBack(Request $request) {
|
|
$sn = $request->post('sn');
|
|
$os = $request->post('os');
|
|
$to_admin_id = $request->post('to_admin_id');
|
|
$admin_id = empty($to_admin_id) ? $request->admin->id : $to_admin_id;
|
|
|
|
if(empty($sn)) return $this->error(2001, '提交单号');
|
|
|
|
$item = Orders::where('sn', $sn)->where('os', $os)->find();
|
|
if(empty($item)) return $this->error(2002, '订单没有找到');
|
|
if($item->admin_id == $admin_id) return $this->error(2002, '订单已经在账号上,不需要再拉取!');
|
|
|
|
//管理员不用审批
|
|
$status = 0;
|
|
if ($request->admin->is_super == 1 || $request->admin->id == 1){
|
|
$status = 1;
|
|
}
|
|
|
|
$backs = [
|
|
'order_id' => $item->id,
|
|
'admin_id' => $admin_id,
|
|
'admin' => $item->admin_id,
|
|
'apply_id' => $request->admin->id,
|
|
'status' => $status
|
|
];
|
|
try {
|
|
Db::transaction(function() use ($backs,$item) {
|
|
Backs::create($backs);
|
|
Logs::todo($backs['order_id'], $backs['apply_id'], $backs['status'] == 1 ? 12 : 7,$item->sn);
|
|
|
|
if ($backs['status'] == 1){//管理员审批处理
|
|
Orders::where('id', $backs['order_id'])->where('admin_id', $backs['admin'])->update(['admin_id'=> $backs['admin_id']]);
|
|
$other = Backs::where('order_id', $backs['order_id'])->where('status', 0)->lock()->select();
|
|
foreach($other as $o) {
|
|
Backs::where('id', $o->id)->where('status', 0)->update(['status' => 3]);
|
|
Logs::todo($o->order_id, $o->admin, 10); //取消其他转单需求
|
|
}
|
|
}
|
|
});
|
|
}catch (\Exception $e){
|
|
return $this->error(2003, '创建拉回记录失败了');
|
|
}
|
|
|
|
return $this->success(true);
|
|
}
|
|
|
|
/**
|
|
* 同意操作
|
|
* @param Request $request
|
|
* @return \support\Response
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\DbException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
*/
|
|
public function backpass(Request $request) {
|
|
$id = $request->post('id', 0);
|
|
|
|
$item = Backs::where('id', $id)->find();
|
|
if($item->status != 0) return $this->error(2004, '记录已经处理了.');
|
|
if($item->admin != $request->admin->id && $item->admin != $item->apply_id) return $this->error(2005, '管理员错误');
|
|
|
|
try {
|
|
Backs::change($item);
|
|
return $this->success('');
|
|
}catch(\Exception $e) {
|
|
return $this->error(2006, '确认失败了');
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 拒绝操作
|
|
* @param Request $request
|
|
* @return \support\Response
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\DbException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
*/
|
|
public function backrefuse(Request $request) {
|
|
$id = $request->post('id', 0);
|
|
|
|
$item = Backs::where('id', $id)->find();
|
|
if(empty($item)) return $this->error(2004, '记录没有找到.');
|
|
if($item->status != 0) return $this->error(2004, '记录已经处理了.');
|
|
if($item->admin != $request->admin->id && $item->admin != $item->apply_id) return $this->error(2005, '管理员错误');
|
|
|
|
try {
|
|
Backs::refuse($item);
|
|
return $this->success('');
|
|
}catch(\Exception $e) {
|
|
return $this->error(2006, '确认失败了');
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 取消操作
|
|
* @param Request $request
|
|
* @return \support\Response
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\DbException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
*/
|
|
public function backcancel(Request $request)
|
|
{
|
|
$id = $request->post('id', 0);
|
|
|
|
$item = Backs::where('id', $id)->find();
|
|
if(empty($item)) return $this->error(2004, '记录没有找到.');
|
|
if($item->status != 0) return $this->error(2004, '记录已经处理了.');
|
|
if($item->admin != $request->admin->id && $item->admin == $item->apply_id) return $this->error(2005, '管理员错误');
|
|
|
|
try {
|
|
Backs::cancel($item);
|
|
return $this->success('');
|
|
}catch(\Exception $e) {
|
|
return $this->error(2006, '确认失败了');
|
|
}
|
|
}
|
|
|
|
} |