<?php # 支付 namespace Mshop\Lib; use Dever; class Buy { # 1是门店,2是仓库,3是工厂,1,2,3是查看采购人的订单,11,12,13是查看供货商的订单 public $type = 1; # 1是列表,2是详情 public $view = 1; # 获取配置 public $config = array(); # table public $table = 'shop/buy_order'; public function __construct() { $this->config = Dever::db($this->table)->config; } # 设置订单的类型 public function set($type, $view) { $this->type = $type; $this->view = $view; return $this; } # 获取公共的where public function where($id) { $where = array(); if ($this->type > 10) { $type = $this->type - 10; $where['source_type'] = $type; $where['source_id'] = $id; } else { $where['type'] = $this->type; $where['type_id'] = $id; } if (!$where) { Dever::alert('参数错误'); } return $where; } # 获取订单列表 public function getList($id) { $result = array(); $where = $this->where($id); $status = Dever::input('status'); if ($status) { if ($status == 'refund') { $where['refund_status'] = 2; } else { $where['status'] = $status; } } $order_num = Dever::input('order_num'); if ($order_num) { $where['order_num'] = $order_num; } $refund_status = Dever::input('refund_status'); if ($refund_status) { $where['refund_status'] = $refund_status; } $result['search_value'] = $where; $result['search_value']['day'] = $day = Dever::input('day'); if ($day) { if ($this->type > 10) { $where['start_o'] = Dever::maketime($day . ' 00:00:00'); $where['end_o'] = Dever::maketime($day . ' 23:59:59'); } else { $where['start'] = Dever::maketime($day . ' 00:00:00'); $where['end'] = Dever::maketime($day . ' 23:59:59'); } } $result['search_value']['start'] = $start = Dever::input('start'); $result['search_value']['end'] = $end = Dever::input('end'); if ($start && $end) { if ($this->type > 10) { $where['start_o'] = Dever::maketime($start); $where['end_o'] = Dever::maketime($end); } else { $where['start'] = Dever::maketime($start); $where['end'] = Dever::maketime($end); } } $result['order'] = Dever::db($this->table)->getAll($where); if ($result['order']) { foreach ($result['order'] as $k => $v) { $result['order'][$k] = $this->getInfo($v); } } $result['search'] = array(); $result['search']['status'] = array ( array('value' => 1, 'name' => '待支付'), array('value' => 2, 'name' => '待审核'), array('value' => 3, 'name' => '待发货'), array('value' => 4, 'name' => '待收货确认'), array('value' => 5, 'name' => '已完成'), array('value' => 6, 'name' => '已完成(有退款)'), array('value' => '7,8,11', 'name' => '已取消'), ); $result['config'] = Dever::db('main/manage_config')->find(); return $result; } # 查看详情 public function getView($id, $order_id, $show = true) { $where = $this->where($id); $where['id'] = $order_id; $result = Dever::db($this->table)->find($where); if (!$result) { Dever::alert('订单不存在'); } if ($show) { $result = $this->getInfo($result, true); } return $result; } # 查看退款详情 public function getRefund($id, $order_id) { $data = $this->getView($id, $order_id, false); $data['refund'] = Dever::db('shop/buy_order_refund')->select(array('order_id' => $info['id'])); return $data; } # 获取订单详细信息 public function getInfo($info, $view = false) { if ($info['status'] == 1) { # 15分钟内支付,900秒 $m = 9000; # 支付倒计时 $info['time'] = time() - $info['cdate']; if ($info['time'] >= $m) { # 已过期,自动取消 $info['time'] = -1; Dever::db($this->table)->update(array('where_id' => $info['id'], 'status' => 11)); $info['status'] = 11; } else { $info['time'] = $m - $info['time']; } } $info['status_name'] = $this->config['status'][$info['status']]; $info['goods'] = Dever::db('shop/buy_order_goods')->select(array('order_id' => $info['id'])); if ($info['type'] == 1) { $info['type_info'] = Dever::db('shop/info')->getOne($info['type_id']); } elseif ($info['type'] == 2) { $info['type_info'] = Dever::db('store/info')->find($info['type_id']); } elseif ($info['type'] == 3) { $info['type_info'] = Dever::db('factory/info')->find($info['type_id']); } if ($info['source_type'] == 1) { $info['source_info'] = Dever::db('shop/info')->getOne($info['source_id']); } elseif ($info['source_type'] == 2) { $info['source_info'] = Dever::db('store/info')->find($info['source_id']); } elseif ($info['source_type'] == 3) { $info['source_info'] = Dever::db('factory/info')->find($info['source_id']); } $info['cdate'] = date('Y-m-d H:i', $info['cdate']); if ($info['operdate']) { $info['operdate'] = date('Y-m-d H:i', $info['operdate']); } $goods_status = Dever::db('shop/buy_order_goods')->config['status']; $goods_process = Dever::db('shop/buy_order_refund')->config['process']; if ($view || $this->view == 2) { foreach ($info['goods'] as $k => $v) { $info['goods'][$k]['info'] = Dever::load('goods/lib/info')->getPayInfo($v['goods_id'], $v['sku_id']); $info['goods'][$k]['status_name'] = $goods_status[$v['status']]; } } else { foreach ($info['goods'] as $k => $v) { $goods = Dever::db('goods/info')->one($v['goods_id']); $info['goods'][$k]['name'] = $goods['name']; $info['goods'][$k]['cover'] = $goods['cover']; $info['goods'][$k]['status_name'] = $goods_status[$v['status']]; } } if (!$info['refund_cash']) { $info['refund_cash'] = 0; } # 配送信息 $info['ps_info'] = Dever::db('shop/buy_order_ps')->find(array('order_id' => $info['id'])); if ($info['ps_info']) { $info['ps_info']['service_name'] = '商家自送'; $info['ps_info']['cdate'] = date('Y-m-d H:i', $info['ps_info']['cdate']); if ($info['ps_info']['ydate']) { $info['ps_info']['ydate'] = date('Y-m-d H:i', $info['ps_info']['ydate']); } $status = Dever::db('shop/buy_order_ps')->config['status']; $info['ps_info']['status_name'] = $status[$info['ps_info']['status']]; if ($info['ps_info']['service_id'] > 0) { //暂时还没有 $service = Dever::db('shop/service')->find($info['ps_info']['service_id']); $info['ps_info']['service_name'] = $service['name']; } } return $info; } # 发起支付 public function action($type, $type_id, $name, $num, $goods, $price, $info, $refer = '') { $order_data['type'] = $type; $order_data['type_id'] = $type_id; $order_data['name'] = $name; $order_data['num'] = $num; $order_data['info'] = $info; $order_data['price'] = $price; $order_data['order_num'] = $this->getOrderId(); $id = Dever::db('shop/buy_order')->insert($order_data); if (!$id) { Dever::alert('支付失败'); } foreach($goods as $k => $v) { $data['order_id'] = $id; $data['goods_id'] = $v['id']; $data['sku_id'] = $v['sku_id']; $data['price'] = $v['price'] * $v['buy_num']; $data['num'] = $v['buy_num']; Dever::db('shop/buy_order_goods')->insert($data); } if ($price <= 0) { $param['pay_product_id'] = $id; $param['pay_order_id'] = $order_data['order_num']; $param['pay_status'] = 2; $param['pay_cash'] = $price; $param['pay_msg'] = ''; $this->success($param); return array ( 'order' => '', 'order_num' => $order_data['order_num'], 'order_id' => $id, 'type' => 'pay', ); } $param = array ( 'project_id' => 2, 'channel_id' => 1, 'system_source' => 5, 'uid' => -1, 'name' => $order_data['name'], 'cash' => $price, 'product_id' => $id, 'order_id' => $order_data['order_num'], 'refer' => $refer, ); $receipt = Dever::input('receipt'); if ($receipt) { $param['receipt'] = $receipt; } //$result = Dever::load('pay/api.pay', $param); $result['type'] = 'test'; $result['order'] = ''; $result['order_num'] = $order_data['order_num']; $result['order_id'] = $id; return $result; } # 再次发起支付 public function raction($id, $refer = '') { $order = Dever::db('shop/buy_order')->find($id); if (!$order) { Dever::alert('订单信息错误'); } if ($order['status'] > 1) { Dever::alert('订单已支付或已取消'); } $param = array ( 'project_id' => 2, 'channel_id' => 1, 'system_source' => 5, 'uid' => -1, 'name' => $order['name'], 'cash' => $order['price'], 'product_id' => $id, 'order_id' => $order['order_num'], 'refer' => $refer, ); $receipt = Dever::input('receipt'); if ($receipt) { $param['receipt'] = $receipt; } $result = Dever::load('pay/api.pay', $param); $result['order_num'] = $order['order_num']; $result['order_id'] = $id; return $result; } # 支付成功回调 安全加密 设置token public function success_secure_api_token() { $project_id = Dever::input('pay_project_id'); $info = Dever::db('pay/project')->one($project_id); if ($info) { return $info['key']; } return 'shop_buy_dever_2020'; } # 支付成功回调 安全加密 public function success_secure_api($param = array()) { $this->success($param); } # 支付成功回调 public function success($param = array()) { $send = $param ? $param : Dever::preInput('pay_'); $product_id = $send['pay_product_id']; $order_id = $send['pay_order_id']; $status = $send['pay_status']; $cash = $send['pay_cash']; $msg = $send['pay_msg']; $order = Dever::db('shop/buy_order')->one(array('id' => $product_id, 'time' => time())); if ($order && $order['status'] == 1) { if ($status == 2) { } $update['status'] = 2; $update['where_id'] = $order['id']; Dever::db('shop/buy_order')->update($update); } return 'ok'; } # 生成订单号 public function getOrderId() { $where['order_num'] = Dever::order('C'); $state = Dever::db('shop/buy_order')->one($where); if (!$state) { return $where['order_num']; } else { return $this->getOrderId(); } } # 添加配送信息 public function updatePs($order, $status = 1) { $where['order_id'] = $order['id']; $data = Dever::db('shop/buy_order_ps')->find($where); if ($data) { $update['where_id'] = $data['id']; $update['status'] = $status; $update['ydate'] = time(); Dever::db('shop/buy_order_ps')->update($update); } } # 确认收货 public function finish($id, $order_id) { $data = $this->getView($id, $order_id, false); if ($data['status'] <= 4) { if ($data['refund_cash'] > 0) { $status = 6; } else { $status = 5; } $state = Dever::db('shop/buy_order')->update(array('where_id' => $data['id'], 'status' => $status)); if ($state) { $this->updatePs($data, 3); # 增加库存 $where['order_id'] = $data['id']; $where['status'] = 1; $goods = Dever::db('shop/buy_order_goods')->select($where); if ($goods) { Dever::load('shop/lib/goods')->oper($data, 1, 1, $goods); } } return 'ok'; } else { Dever::alert('您没有权限'); } } # 取消订单 public function cancel($id, $order_id) { $data = $this->getView($id, $order_id, false); if ($data['status'] == 1) { $state = Dever::db('shop/buy_order')->update(array('where_id' => $data['id'], 'status' => 7, 'operdate' => time())); return 'ok'; } else { Dever::alert('当前订单状态不允许取消'); } } # 查看订单状态 public function orderStatus($id) { $config = Dever::db('shop/buy_order')->config; $info = Dever::db('shop/buy_order')->one($id); $tk = Dever::db('shop/buy_order_refund')->find(array('order_id' => $info['id'], 'process' => 1)); $status = $config['status'][$info['status']]; if ($tk) { $status = '申请退款中'; } return $status; } # 后台审核退款 public function refund_commit_api() { $id = Dever::input('id'); $process = Dever::input('process'); return Dever::load('shop/lib/refund')->set('buy')->action($id, $process, false); } # 货物未发出,仅退款 public function refund_apply_commit_api() { $order_id = Dever::input('order_id'); $type = Dever::input('type'); $type_id = Dever::input('type_id'); $desc = Dever::input('desc'); $pic = Dever::input('pic'); return Dever::load('shop/lib/refund')->set('buy')->apply($type, $type_id, $order_id, false, 3, 0, $desc, $pic, 2); } # 货物已收到 全部退款 报损 需要审核 public function refund_apply_info_commit_api() { $order_id = Dever::input('order_id'); $status = Dever::input('status'); $desc = Dever::input('desc'); $pic = Dever::input('pic'); $type = Dever::input('type'); $type_id = Dever::input('type_id'); return Dever::load('shop/lib/refund')->set('buy')->apply($type, $type_id, $order_id, false, $status, 0, $desc, $pic, 1); } # 部分退款 报损 public function refund_apply_info_one_commit_api() { $order_id = Dever::input('order_id'); $order_goods_id = Dever::input('order_goods_id'); $num = Dever::input('num', 0); $status = Dever::input('status'); $desc = Dever::input('desc'); $pic = Dever::input('pic'); $type = Dever::input('type'); $type_id = Dever::input('type_id'); return Dever::load('shop/lib/refund')->set('buy')->apply($type, $type_id, $order_id, $order_goods_id, $status, $num, $desc, $pic, 1); } # 展示订单详情 public function show() { $id = Dever::input('order_id'); $type = Dever::input('type', 1); $config = Dever::db('shop/buy_order')->config; $info = Dever::db('shop/buy_order')->one($id); $tk_status = Dever::db('shop/buy_order_refund')->config['status']; $tk_process = Dever::db('shop/buy_order_refund')->config['process']; $status = $config['status'][$info['status']]; $tk = Dever::db('shop/buy_order_refund')->find(array('order_id' => $info['id'], 'type' => 1)); $cdate = date('Y-m-d H:i', $info['cdate']); $opertime = date('Y-m-d H:i', $info['operdate']); $html = '<div class="layui-col-md12"><div class="layui-card"><div class="layui-card-header">基本信息</div><div class="layui-card-body">'; $html .= '<table class="layui-table"><thead><tr><th style="width:20%">项目</th><th style="width:80%">详情</th></tr> </thead><tbody>'; if ($type == 2) { $info['price'] = $info['p_price']; } $html .= '<tr> <td>基本信息</td> <td>'.$this->table(false, array(array('订单号:' . $info['order_num'], '金额:' . $info['price'], '数量:' . $info['num'], '状态:' . $status))).'</td> </tr>'; if ($type == 1 && $tk && $tk['process'] == 1) { $status = '申请' . $tk_status[$tk['status']]; } if ($type == 1) { $time = array('下单时间:' . $cdate, '订货时间:' . $opertime); } else { $time = array('订货时间:' . $opertime); } $html .= '<tr> <td>订单时间</td> <td>'.$this->table(false, array($time)).'</td> </tr>'; if ($info['type'] == 1) { $type_info = Dever::db('shop/info')->find($info['type_id']); } elseif ($info['type'] == 2) { $type_info = Dever::db('store/info')->find($info['type_id']); } elseif ($info['type'] == 3) { $type_info = Dever::db('store/info')->find($info['type_id']); } $html .= '<tr> <td>配送信息</td> <td>'.$this->table(false, array(array($type_info['name'] . ',' . $type_info['truename'] . ',' . $type_info['mobile'] . ',' . $type_info['address']))).'</td> </tr>'; if ($type == 1 && $info['source_id'] > 0) { if ($info['source_type'] == 2) { # 仓库 $source_info = Dever::db('store/info')->find($info['source_id']); } elseif ($info['source_type'] == 3) { # 工厂 $source_info = Dever::db('factory/info')->find($info['source_id']); } $html .= '<tr> <td>供应商信息</td> <td>'.$this->table(false, array(array($source_info['name'] . ',' . $source_info['truename'] . ',' . $source_info['mobile']))).'</td> </tr>'; } if ($info['info']) { $html .= '<tr> <td>订单备注</td> <td>'.$this->table(false, array(array($info['info']))).'</td> </tr>'; } if ($type == 2) { $config = Dever::load('factory/admin/auth.config'); $button = array(); if ($info['status'] < 5) { $button[] = '<button class="layui-btn layui-btn-primary" onclick="$(\'#print_'.$info['id'].'\').click()">打印货单</button>'; } if ($info['status'] == 3) { $cancel = Dever::url('lib/buy.refund_apply_commit?json=1', 'mshop'); $button[] = '<button class="layui-btn layui-btn-primary" onclick="$(\'#send_'.$info['id'].'\').click()">配送发货</button>'; $button[] = '<button class="layui-btn layui-btn-primary" onclick="cancel('.$info['id'].','.$info['source_id'].', \''.$cancel.'\')">取消订单</button>'; } $config['phone'] = '您的专属客服:' . $config['kf_name'] . ',联系电话:' . $config['phone']; $button[] = '<button class="layui-btn layui-btn-primary" onclick="showAlert(\''.$config['phone'].'\')">联系平台</button>'; $html .= '<tr> <td>功能按钮</td> <td>'.$this->table(false, array($button)).'</td> </tr>'; } $html .= '</tbody></table></div></div>'; $url = Dever::url('lib/buy.refund_commit?json=1', 'mshop'); if (!$info['refund_cash']) { $info['refund_cash'] = 0; } if ($info['refund_cash'] > 0 && $tk) { if ($tk['process'] == 1) { $process = '<a href="javascript:;" onclick="audit('.$tk['id'].', 2, \''.$url.'\')" class="layui-btn">通过</a><a href="javascript:;" onclick="audit('.$tk['id'].', 3, \''.$url.'\')" class="layui-btn layui-btn-danger">驳回</a>'; } else { $process = $tk_process[$tk['process']]; } $desc = array(); $desc['退款原因'] = $tk['desc']; $desc['退款图片'] = '暂无'; if ($tk['pic']) { $desc['退款图片'] = ''; $pic = explode(',', $tk['pic']); foreach ($pic as $k => $v) { $desc['退款图片'] .= '<a href="'.$v.'" target="_blank"><img src="'.$v.'" width="100"/></a>'; } } $tk['desc'] = '<a href="javascript:showAlert($(\'#desc_content\').html());">查看</a><span id="desc_content" style="display:none">'.Dever::table($desc).'</span>'; $head = array('退款金额', '数量', '退款进度', '退款原因'); $body = array(array($info['refund_cash'], $info['num'], $process, $tk['desc'])); $html .= '<div class="layui-card"><div class="layui-card-header">退款信息</div><div class="layui-card-body">' . $this->table($head, $body) . '</div></div>'; } $info['ps_info'] = Dever::db('shop/buy_order_ps')->find(array('order_id' => $info['id'])); if ($info['ps_info']) { $info['ps_info']['service_name'] = '供应商自送'; $info['ps_info']['cdate'] = date('Y-m-d H:i', $info['ps_info']['cdate']); if ($info['ps_info']['ydate']) { $info['ps_info']['ydate'] = date('Y-m-d H:i', $info['ps_info']['ydate']); } $status = Dever::db('shop/buy_order_ps')->config['status']; $info['ps_info']['status_name'] = $status[$info['ps_info']['status']]; if ($info['ps_info']['service_id'] > 0) { //暂时还没有 $service = Dever::db('shop/service')->find($info['ps_info']['service_id']); $info['ps_info']['service_name'] = $service['name']; } $head = array('名称', '单号', '费用', '配货员', '更多'); $table = array(); $table['打包员'] = $info['ps_info']['dby']; $table['数量'] = $info['ps_info']['num']; $table['重量'] = $info['ps_info']['zl']; $table['体积'] = $info['ps_info']['tj']; $table['发货时间'] = $info['ps_info']['cdate']; if ($info['ps_info']['ydate']) { $table['收货时间'] = $info['ps_info']['ydate']; } $body = array(array($info['ps_info']['service_name'], $info['ps_info']['order_num'], $info['ps_info']['price'], $info['ps_info']['phy'], '<a href="javascript:showAlert($(\'#refund_content\').html());">查看</a><span id="refund_content" style="display:none">'.Dever::table($table).'</span>')); $html .= '<div class="layui-card"><div class="layui-card-header">物流信息</div><div class="layui-card-body">' . $this->table($head, $body) . '</div></div>'; } $body = array(); $body_total = array(); $body_total['price'] = 0; $body_total['num'] = 0; $goods = Dever::db('shop/buy_order_goods')->select(array('order_id' => $info['id'])); $goods_status = Dever::db('shop/buy_order_goods')->config['status']; $refund_body = array(); $refund_body_total = array(); $refund_body_total['price'] = 0; $refund_body_total['num'] = 0; foreach ($goods as $k => $v) { if ($type == 2) { $v['price'] = $v['p_price']; } $goods_info = Dever::load('goods/lib/info')->getInfoBySku($v['goods_id'], $v['sku_id']); $status = $goods_status[$v['status']]; $tk = Dever::db('shop/buy_order_refund')->find(array('order_id' => $info['id'], 'order_goods_id' => $v['id'], 'type' => 2)); if ($tk && $tk['process'] == 1) { if ($type == 1) { $status = '申请' . $tk_status[$tk['status']]; } else { $status = '已上报'; } if ($type == 1) { $desc = array(); $desc['退款原因'] = $tk['desc']; $desc['退款图片'] = '暂无'; if ($tk['pic']) { $desc['退款图片'] = ''; $pic = explode(',', $tk['pic']); foreach ($pic as $k => $v) { $desc['退款图片'] .= '<a href="'.$v.'" target="_blank"><img src="'.$v.'" width="100"/></a>'; } } $status .= ' <a href="javascript:showAlert($(\'#desc_content\').html());">查看原因</a><span id="desc_content" style="display:none">'.Dever::table($desc).'</span>'; $status .= ' <a href="javascript:;" onclick="audit('.$tk['id'].', 2, \''.$url.'\')" class="layui-btn">通过</a><a href="javascript:;" onclick="audit('.$tk['id'].', 3, \''.$url.'\')" class="layui-btn layui-btn-danger">驳回</a>'; } } elseif ($type > 1 && (!$tk || ($tk && $tk['process'] == 3))) { $tui = Dever::url('lib/buy.refund_apply_info_one_commit?json=1', 'mshop'); if ($info['status'] == 3) { $status = '<a href="javascript:;" onclick="tui('.$v['id'].','.$info['id'].','.$info['source_id'].', 2, \''.$tui.'\')" class="layui-btn">缺货退款</a>'; } elseif ($info['status'] == 4) { $status = '<a href="javascript:;" onclick="tui('.$v['id'].','.$info['id'].','.$info['source_id'].', 1, \''.$tui.'\')" class="layui-btn">报损退款</a>'; } } if (isset($goods_info['sku'])) { $sku = '[' . $goods_info['sku']['string'] . ']'; } else { $sku = ''; } if ($tk && $v['status'] == 3) { $refund_body[] = array ( $goods_info['name'] . ' ' . $sku, $v['price'], $v['num'], $tk_status[$tk['status']], ); $refund_body_total['price'] += $v['price']; $refund_body_total['num'] += $v['num']; } else { $body[] = array ( $goods_info['name'] . ' ' . $sku, $v['price'], $v['num'], $status, ); $body_total['price'] += $v['price']; $body_total['num'] += $v['num']; } } if ($body) { $head = array('名称', '金额', '数量', '状态'); $body[] = array ( '合计', $body_total['price'], $body_total['num'], '-' ); $html .= '<div class="layui-card"><div class="layui-card-header">商品清单</div><div class="layui-card-body" style="max-height: 500px;overflow: auto;">' . $this->table($head, $body) . '</div></div>'; } if ($refund_body) { $head = array('名称', '金额', '数量', '状态'); $refund_body[] = array ( '合计', $refund_body_total['price'], $refund_body_total['num'], '-' ); $html .= '<div class="layui-card"><div class="layui-card-header">缺货与报损商品</div><div class="layui-card-body" style="max-height: 300px;overflow: auto;">' . $this->table($head, $refund_body) . '</div></div>'; } $html .= '</div>'; return $html; } private function table($head, $data) { $html = ''; if ($head) { $html = '<table class="layui-table">'; $html .= '<thead><tr>'; foreach ($head as $k => $v) { $html .= '<th>'.$v.'</th>'; } $html .= '</tr></thead>'; $html .= '<tbody>'; foreach ($data as $k => $v) { $html .= '<tr>'; foreach ($v as $k1 => $v1) { $html .= '<td>'.$v1.'</td>'; } $html .= '</tr>'; } $html .= '</tbody>'; $html .= '</table>'; } else { foreach ($data as $k => $v) { $html .= ''; foreach ($v as $k1 => $v1) { $html .= $v1 . ' '; } $html .= ''; } } return $html; } # 发货 /* public function send_commit() { $order_id = Dever::input('order_id'); $order = Dever::db('shop/buy_order')->find($order_id); if (!$order || ($order && $order['status'] != 3)) { Dever::alert('当前订单状态无法发货'); } $state = Dever::db('shop/buy_order')->update(array('where_id' => $order['id'], 'status' => 4)); if ($state) { $this->updatePs($order, 1); } return 'reload'; }*/ # 采购订单审核 拆单 public function audit_commit() { $order_id = Dever::input('order_id'); $order = Dever::db('shop/buy_order')->find($order_id); if (!$order || ($order && $order['status'] != 2)) { Dever::alert('当前订单状态无法拆单'); } if ($order['type'] != 1) { Dever::alert('这不是门店的订单'); } $goods = Dever::db('shop/buy_order_goods')->select(array('order_id' => $order_id)); $shop = Dever::db('shop/info')->find($order['type_id']); # 获取门店分配的仓库和工厂 $shop_store = Dever::db('shop/store')->select(array('shop_id' => $shop['id'])); $store = array(); $distance = array(); # 按照距离排序 foreach ($shop_store as $k => $v) { $info = Dever::db('store/info')->find($v['store_id']); if ($info && $info['status'] == 1) { $distance[] = $info['distance'] = Dever::distance($shop['lng'], $shop['lat'], $info['lng'], $info['lat']); $store[] = $info; } } if (!$store) { Dever::alert('未分配仓库'); } array_multisort($distance, SORT_ASC, SORT_NUMERIC, $store); $shop_factory = Dever::db('shop/factory')->select(array('shop_id' => $shop['id'])); $factory = array(); $distance = array(); # 按照距离排序 foreach ($shop_factory as $k => $v) { $info = Dever::db('factory/info')->find($v['factory_id']); if ($info && $info['status'] == 1) { $distance[] = $info['distance'] = Dever::distance($shop['lng'], $shop['lat'], $info['lng'], $info['lat']); $factory[] = $info; } } if (!$factory) { Dever::alert('未分配工厂'); } array_multisort($distance, SORT_ASC, SORT_NUMERIC, $factory); $this->order_num = 0; $this->order_id = array(); $delete = array(); $yes = array(); foreach ($goods as $k => $v) { # 开始找仓库 $find = $this->store($order['id'], $order['order_num'] . '_' . $this->order_num, $shop, $store, $v); if (!$find[1]) { # 仓库没有,找厂家 if ($factory) { $find = $this->factory($order['id'], $order['order_num'] . '_' . $this->order_num, $shop, $factory, $v); } } if ($find[1]) { $delete[$v['id']] = $v; } else { $yes[$v['id']] = $v; } } if ($this->order_num > 0) { if ($this->order_num == 1) { Dever::db('shop/buy_order')->delete($find[2][0]); $goods = Dever::db('shop/buy_order_goods')->select(array('order_id' => $find[2][0])); $p_price = 0; foreach ($goods as $k => $v) { $goods_info = Dever::db('shop/buy_order_goods')->find(array('order_id' => $order['id'], 'goods_id' => $v['goods_id'])); if ($goods_info) { Dever::db('shop/buy_order_goods')->update(array('where_id' => $goods_info['id'], 'set_p_price' => $v['p_price'])); $p_price += $v['p_price']; } } Dever::db('shop/buy_order')->update(array('where_id' => $order['id'], 'status' => 3, 'source_type' => $find[0], 'source_id' => $find[1][0], 'p_price' => $p_price, 'operdate' => time())); Dever::db('shop/buy_order_goods')->delete(array('order_id' => $find[2][0])); unset($this->order_id[$find[2][0]]); $this->order_id[$order['id']] = array($find[0], $find[1][0]); } else { if (!$yes) { Dever::db('shop/buy_order')->update(array('where_id' => $order['id'], 'state' => 2)); } else { $price = 0; $num = 0; foreach ($delete as $k => $v) { Dever::db('shop/buy_order_goods')->delete(array('where_id' => $v['id'])); $price += $v['price']; $num += $v['num']; } $price = $order['price'] - $price; $num = $order['num'] - $num; Dever::db('shop/buy_order')->update(array('where_id' => $order['id'], 'price' => $price, 'num' => $num)); Dever::load('shop/lib/refund')->set('buy')->apply(1, $shop['id'], $order_id, false, 3, 0, '供货商库存不足'); } } } else { # 没有找到,退款 Dever::load('shop/lib/refund')->set('buy')->apply(1, $shop['id'], $order_id, false, 3, 0, '供货商库存不足'); } if ($this->order_id) { foreach ($this->order_id as $k => $v) { $this->sendMsg($v[0], $v[1], $k); } } return 'ok'; } private function store($order_id, $order_num, $shop, $store, $goods, $state = 2) { $find = array(); $type_id = array(); $id = array(); if (!$store) { return array(2, $type_id, $id); } foreach ($store as $k => $v) { $where['store_id'] = $v['id']; $where['goods_id'] = $goods['goods_id']; $where['sku_id'] = ($goods['sku_id'] && $goods['sku_id'] > 0) ? $goods['sku_id'] : -1; $sku = Dever::db('store/goods_sku')->getOne($where); if ($sku) { if ($goods['num'] <= $sku['total']) { # 如果库存符合,直接下单即可,生成仓库订单 $state = $this->createOrder($order_id, $order_num, 1, $shop['id'], 2, $where['store_id'], $goods['price'], $goods['price'], $goods['num'], $where['goods_id'], $where['sku_id']); if ($state) { $type_id[] = $where['store_id']; $id[] = $state; $this->order_id[$state] = array(2, $where['store_id']); break; } } elseif ($state == 1 && $sku['total'] > 0) { # 如果库存不够,从这个仓库扣下一部分,剩余的从另外仓库处理 $goods['num'] = $goods['num'] - $sku['total']; # 生成仓库订单 $state = $this->createOrder($order_id, $order_num, 1, $shop['id'], 2, $where['store_id'], $goods['price'], $goods['price'], $sku['total'], $where['goods_id'], $where['sku_id']); if (!$state) { $goods['num'] = $goods['num'] + $sku['total']; } else { $type_id[] = $where['store_id']; $id[] = $state; $this->order_id[$state] = array(2, $where['store_id']); } continue; } else { # 直接切换到下一个仓库处理 continue; } } } return array(2, $type_id, $id); } private function factory($order_id, $order_num, $shop, $factory, $goods) { $find = array(); $type_id = array(); $id = array(); if (!$factory) { return array(3, $type_id, $id); } foreach ($factory as $k => $v) { $where['factory_id'] = $v['id']; $where['goods_id'] = $goods['goods_id']; $where['sku_id'] = ($goods['sku_id'] && $goods['sku_id'] > 0) ? $goods['sku_id'] : -1; $sku = Dever::db('factory/goods_sku')->getOne($where); if ($sku) { $state = $this->createOrder($order_id, $order_num, 1, $shop['id'], 3, $where['factory_id'], $goods['price'], $sku['p_price'], $goods['num'], $where['goods_id'], $where['sku_id']); if ($state) { $type_id[] = $where['factory_id']; $id[] = $state; $this->order_id[$state] = array(3, $where['factory_id']); break; } } else { continue; } } return array(3, $type_id, $id); } # 发送消息 private function sendMsg($source_type, $source_id, $id) { if (Dever::project('message')) { $msg_param['type'] = 1;//消息类型1是订单消息 $msg_param['id'] = $id; $msg_param['source_id'] = $source_id; $msg_param['source_type'] = $source_type; $msg_param = Dever::json_encode($msg_param); $project = $source_type + 1; $msg = '您有一个新的订货单,请及时处理。'; Dever::load('message/lib/data')->push(-1, $source_id, '订货通知', $msg, 2, $project, false, $msg_param); } } # 生成拆单的订单 private function createOrder($order_id, $order_num, $type, $type_id, $source_type, $source_id, $price, $p_price, $num, $goods_id, $sku_id) { $where['parent_order_id'] = $order_id; $where['type'] = $type; $where['type_id'] = $type_id; $where['source_type'] = $source_type; $where['source_id'] = $source_id; $where['r'] = $goods_id; $info = Dever::db('shop/buy_order')->find($where); if (!$info) { $this->order_num++; $data = $where; $data['name'] = $order_id; $data['order_num'] = $order_num; $data['operdate'] = time(); $data['status'] = 3; $data['price'] = $price; $data['p_price'] = $p_price; $data['num'] = $num; $id = $state = Dever::db('shop/buy_order')->insert($data); } else { $id = $info['id']; $data['where_id'] = $id; $data['price'] = $info['price'] + $price; $data['p_price'] = $info['p_price'] + $p_price; $data['num'] = $info['num'] + $num; $state = Dever::db('shop/buy_order')->update($data); } if ($state && $id > 0) { $goods_info = Dever::db('shop/buy_order_goods')->find(array('order_id' => $id)); if (!$goods_info) { $goods['order_id'] = $id; $goods['goods_id'] = $goods_id; $goods['sku_id'] = $sku_id; $goods['price'] = $price; $goods['p_price'] = $p_price; $goods['num'] = $num; Dever::db('shop/buy_order_goods')->insert($goods); } //$state = $this->updateSell($source_type, $source_id, $goods_id, $sku_id, $num); return $id; } return false; } # 减少库存,增加销量 public function updateSell($source_type, $source_id, $goods_id, $sku_id, $num) { if ($source_type == 2) { $data['store_id'] = $source_id; $data['goods_id'] = $goods_id; $data['sku_id'] = $sku_id; $data['num'] = $num; return Dever::load('store/lib/goods')->oper($source_id, 1, 2, array($data)); } else { $up = array(); $up['where_factory_id'] = $source_id; $up['where_goods_id'] = $goods_id; $up['sell_num'] = $num; $state = Dever::db('factory/goods')->incSell($up); if ($state) { if ($sku_id > 0) { } else { $sku_id = -1; } $upSku = $up; $upSku['where_sku_id'] = $sku_id; $state = Dever::db('factory/goods_sku')->incSell($upSku); } return $state; } } }