[ 'status' => self::ORDER_CREATE, 'name' => '待支付', 'is_allow_refund' => 0, 'icon' => 'public/resource/order/order-icon.png', 'action' => [ [ 'action' => 'orderClose', 'title' => '关闭订单', 'color' => '' ], [ 'action' => 'orderAddressUpdate', 'title' => '修改地址', 'color' => '' ], [ 'action' => 'orderAdjustMoney', 'title' => '调整价格', 'color' => '' ], ], 'member_action' => [ [ 'action' => 'orderClose', 'title' => '关闭订单', 'color' => '', ], [ 'action' => 'orderPay', 'title' => '支付', 'color' => '' ], ], 'color' => '' ], self::ORDER_PAY => [ 'status' => self::ORDER_PAY, 'name' => '待发货', 'is_allow_refund' => 0, 'icon' => 'public/resource/order/order-icon-send.png', 'action' => [ [ 'action' => 'orderDelivery', 'title' => '发货', 'color' => '' ], [ 'action' => 'orderAddressUpdate', 'title' => '修改地址', 'color' => '' ], ], 'member_action' => [], 'color' => '' ], self::ORDER_DELIVERY => [ 'status' => self::ORDER_DELIVERY, 'name' => '已发货', 'is_allow_refund' => 1, 'icon' => 'public/resource/order/order-icon-receive.png', 'action' => [ [ 'action' => 'takeDelivery', 'title' => '确认收货', 'color' => '' ], ], 'member_action' => [ [ 'action' => 'memberTakeDelivery', 'title' => '确认收货', 'color' => '' ], [ 'action' => 'trace', 'title' => '查看物流', 'color' => '' ] ], 'color' => '' ], self::ORDER_TAKE_DELIVERY => [ 'status' => self::ORDER_TAKE_DELIVERY, 'name' => '已收货', 'is_allow_refund' => 1, 'icon' => 'public/resource/order/order-icon-received.png', 'action' => [], 'member_action' => [], 'color' => '' ], self::ORDER_COMPLETE => [ 'status' => self::ORDER_COMPLETE, 'name' => '已完成', 'icon' => 'public/resource/order/order-icon-received.png', 'is_allow_refund' => 1, 'action' => [], 'member_action' => [], 'color' => '' ], self::ORDER_CLOSE => [ 'status' => self::ORDER_CLOSE, 'name' => '已关闭', 'icon' => 'public/resource/order/order-icon-close.png', 'is_allow_refund' => 0, 'action' => [], 'member_action' => [], 'color' => '' ] ]; /** * 订单状态(发货列表) */ public $delivery_order_status = [ self::ORDER_PAY => [ 'status' => self::ORDER_PAY, 'name' => '待发货', 'is_allow_refund' => 0, 'icon' => 'public/resource/order/order-icon-send.png', 'action' => [ [ 'action' => 'orderDelivery', 'title' => '发货', 'color' => '' ], [ 'action' => 'orderAddressUpdate', 'title' => '修改地址', 'color' => '' ], ], 'member_action' => [], 'color' => '' ] ]; /** * 配送状态 */ public $delivery_status = [ self::DELIVERY_WAIT => [ 'status' => self::DELIVERY_WAIT, 'name' => '待发货', 'color' => '' ], self::DELIVERY_DOING => [ 'status' => self::DELIVERY_DOING, 'name' => '已发货', 'color' => '' ], self::DELIVERY_FINISH => [ 'status' => self::DELIVERY_FINISH, 'name' => '已收货', 'color' => '' ] ]; /** * 订单支付 * @param unknown $order_info */ public function orderPay($order_info, $pay_type, $log_data = []) { $pay_type_list = $this->getPayType(); if ($order_info['order_status'] != 0) { return $this->error(); } $condition = array( ['order_id', '=', $order_info['order_id']], ['order_status', '=', self::ORDER_CREATE], ); $data = array( 'order_status' => self::ORDER_PAY, 'order_status_name' => $this->order_status[self::ORDER_PAY]['name'], 'pay_status' => 1, 'order_status_action' => json_encode($this->order_status[self::ORDER_PAY], JSON_UNESCAPED_UNICODE), 'pay_time' => time(), 'is_enable_refund' => 1, 'pay_type' => $pay_type, 'pay_type_name' => $pay_type_list[$pay_type] ); //记录订单日志 start $action = '商家对订单进行了线下支付'; //获取用户信息 if (empty($log_data)) { $member_info = model('member')->getInfo(['member_id' => $order_info['member_id']], 'nickname'); $log_data = [ 'uid' => $order_info['member_id'], 'nick_name' => $member_info['nickname'], 'action_way' => 1 ]; $buyer_name = empty($member_info['nickname']) ? '' : '【' . $member_info['nickname'] . '】'; $action = '买家' . $buyer_name . '支付了订单'; } $log_data = array_merge($log_data, [ 'order_id' => $order_info['order_id'], 'action' => $action, 'order_status' => self::ORDER_PAY, 'order_status_name' => $this->order_status[self::ORDER_PAY]['name'] ]); $this->addOrderLog($log_data); //记录订单日志 end $result = model('order')->update($data, $condition); return $this->success($result); } /** * 订单项发货(物流) * @param $param * @param int $type //1 订单项发货 2整体发货 * @return array */ public function orderGoodsDelivery($param, $type = 1, $log_data = []) { $param['type'] = isset($param['type']) ? $param['type'] : 'manual'; model('order_goods')->startTrans(); try { $order_id = $param['order_id']; $delivery_no = $param['delivery_no']; //物流单号 $delivery_type = $param['delivery_type']; if ($delivery_type == 0) { $express_company_id = 0; } else { $express_company_id = $param['express_company_id'] ?? 0; } $site_id = $param['site_id']; if ($type == 1) { if (empty($param['order_goods_ids'])) { model('order_goods')->rollback(); return $this->error('', '货品ID不存在!'); } $order_goods_id_array = explode(',', $param['order_goods_ids']); } else { $order_goods_id_array = model('order_goods')->getColumn( [ ['order_id', '=', $order_id], ['site_id', '=', $site_id], ['delivery_status', '=', self::DELIVERY_WAIT], // ['refund_status', '<>', 3] ], 'order_goods_id' ); } if (empty($order_goods_id_array)) { model('order_goods')->rollback(); return $this->error('', '订单已发货或者订单信息不存在!'); } $order_id = 0; $member_id = 0; $goods_id_array = []; $order_stock_model = new OrderStock(); $stock_sku_list = []; foreach ($order_goods_id_array as $k => $v) { $order_goods_info = model('order_goods')->getInfo([['order_goods_id', '=', $v], ['site_id', '=', $site_id]], '*'); //已退款的订单项不可发货 if ($order_goods_info['refund_status'] == 3) { model('order_goods')->rollback(); return $this->error([], 'ORDER_GOODS_IS_REFUND'); } if ($order_goods_info['delivery_status'] == self::DELIVERY_DOING) { model('order_goods')->rollback(); return $this->error([], 'ORDER_GOODS_IS_DELIVERYED'); } $order_goods_info['num'] = numberFormat($order_goods_info['num']); $member_id = $order_goods_info['member_id']; $goods_id_array[] = $order_goods_info['sku_id'] . ':' . $order_goods_info['num'] . ':' . $order_goods_info['sku_name'] . ':' . $order_goods_info['sku_image']; $data = ['delivery_status' => self::DELIVERY_DOING, 'delivery_status_name' => $this->delivery_status[self::DELIVERY_DOING]['name']]; if (!empty($delivery_no)) { $data['delivery_no'] = $delivery_no; } $res = model('order_goods')->update($data, [ ['order_goods_id', '=', $v], ['delivery_status', '=', self::DELIVERY_WAIT] ]); $order_id = $order_goods_info['order_id']; //实际发货扣除库存 $stock_sku_list[] = $order_goods_info; } $order_info = model('order')->getInfo([['order_id', '=', $order_id]], 'store_id,site_id'); $stock_result = $order_stock_model->decOrderStock([ 'store_id' => $order_info['store_id'], 'site_id' => $order_info['site_id'], 'goods_sku_list' => $stock_sku_list, 'user_info' => $param['user_info'] ?? [] ]); //创建包裹 $order_common_model = new OrderCommon(); $lock_result = $order_common_model->verifyOrderLock($order_id); if ($lock_result['code'] < 0) { model('order_goods')->rollback(); return $lock_result; } $express_delivery_model = new ExpressDelivery(); $delivery_data = array( 'order_id' => $order_id, 'order_goods_id_array' => $order_goods_id_array, 'goods_id_array' => $goods_id_array, 'goods_array' => $goods_id_array, 'site_id' => $site_id, 'delivery_no' => $delivery_no, 'member_id' => $member_id, 'express_company_id' => $express_company_id, 'delivery_type' => $delivery_type, 'type' => $param['type'], 'template_id' => $param['template_id'] ); $delivery_id = $express_delivery_model->delivery($delivery_data); //检测整体, 订单中订单项是否全部发放完毕 $res = $this->orderCommonDelivery($order_id, $log_data, $delivery_id); if ($res['code'] < 0) { model('order_goods')->rollback(); return $res; } model('order_goods')->commit(); return $this->success($delivery_id); } catch (\Exception $e) { model('order_goods')->rollback(); return $this->error('', $e->getMessage() . $e->getFile() . $e->getLine()); } } /** * 批量订单发货(物流) * @param $param * @return array */ public function orderBatchDelivery($param, $order_list) { model('express_delivery_package')->startTrans(); try { if (empty($order_list)) { return $this->error('', '请先选择要发货的订单'); } foreach ($order_list as $v) { $param['order_id'] = $v['order_id']; $param['order_goods_ids'] = ''; if ($param['type'] == 'electronicsheet') {//电子面单发货 $addon_is_exit = addon_is_exit('electronicsheet', $param['site_id']); if ($addon_is_exit != 1) { return $this->error('', '电子面单插件不存在'); } $electronicsheet_model = new ElectronicsheetDelivery(); $result = $electronicsheet_model->delivery($param); if ($result['code'] < 0) { return $result; } $param['delivery_no'] = $result['data']['Order']['LogisticCode']; } else { $param['delivery_no'] = $v['delivery_no']; } $result = $this->orderGoodsDelivery($param, 2); if ($result['code'] < 0) { model('express_delivery_package')->rollback(); return $result; } } model('express_delivery_package')->commit(); return $this->success(); } catch (\Exception $e) { model('express_delivery_package')->rollback(); return $this->error('', $e->getMessage()); } } /** * 批量订单发货(导入excel文件发货) * @param $filename */ public function orderFileDelivery($param, $site_id, $uid) { //电子面单插件 $addon_is_exit = addon_is_exit('electronicsheet', $site_id); $PHPReader = \PhpOffice\PhpSpreadsheet\IOFactory::createReader('Xlsx'); //载入文件 $PHPExcel = $PHPReader->load($param['path']); //获取表中的第一个工作表,如果要获取第二个,把0改为1,依次类推 $currentSheet = $PHPExcel->getSheet(0); //获取总行数 $allRow = $currentSheet->getHighestRow(); if ($allRow < 2) { return $this->error('', '导入了一个空文件'); } $user_info = model('user')->getInfo([['uid', '=', $uid]], 'username'); //添加文件上传记录 $success_num = $allRow - 1; $error_num = 0; $data = [ 'site_id' => $site_id, 'filename' => $param['filename'], 'path' => $param['path'], 'order_num' => $allRow - 1, 'success_num' => $success_num, 'create_time' => time(), 'uid' => $uid, 'username' => $user_info['username'] ]; $res = model('order_import_file')->add($data); if (!$res) { return $this->error('', '上传文件失败'); } model('order_import_file')->startTrans(); try { for ($i = 2; $i <= $allRow; $i++) { $delivery_data = [ 'type' => '',//发货方式(手动发货、电子面单) 'express_company_id' => 0,//物流公司 'delivery_type' => 1,//是否需要物流 'site_id' => $site_id, 'template_id' => 0,//电子面单模板id 'delivery_no' => '' ]; //订单编号 $order_no = $PHPExcel->getActiveSheet()->getCell('A' . $i)->getValue(); $order_no = trim($order_no, ' '); $order_no = preg_replace('/\s+/', '', $order_no); //订单内容 $order_name = $PHPExcel->getActiveSheet()->getCell('B' . $i)->getValue(); $order_name = trim($order_name, ' '); //发货方式 $type = $PHPExcel->getActiveSheet()->getCell('F' . $i)->getValue(); $type = trim($type, ' '); //物流公司名称或电子面单名称 $name = $PHPExcel->getActiveSheet()->getCell('G' . $i)->getValue(); $name = trim($name, ' '); //物流单号 $delivery_no = $PHPExcel->getActiveSheet()->getCell('H' . $i)->getValue(); $delivery_no = trim($delivery_no, ' '); if (empty($type)) { $error_num += 1; $success_num -= 1; //修改数量 model('order_import_file')->update(['success_num' => $success_num, 'error_num' => $error_num], [['id', '=', $res]]); //添加失败记录 model('order_import_file_log')->add( [ 'site_id' => $site_id, 'file_id' => $res, 'order_no' => $order_no, 'order_name' => $order_name, 'status' => -1, 'reason' => '发货方式为空' ] ); continue; } if ($type == '电子面单' && $addon_is_exit == 1) { if (empty($name)) { $error_num += 1; $success_num -= 1; //修改数量 model('order_import_file')->update(['success_num' => $success_num, 'error_num' => $error_num], [['id', '=', $res]]); //添加失败记录 model('order_import_file_log')->add( [ 'site_id' => $site_id, 'file_id' => $res, 'order_no' => $order_no, 'order_name' => $order_name, 'status' => -1, 'reason' => '电子面单模板为空' ] ); continue; } $delivery_data['type'] = 'electronicsheet'; $template_id = model('express_electronicsheet')->getValue([['template_name', '=', $name], ['site_id', '=', $site_id]], 'id'); if (empty($template_id)) { $error_num += 1; $success_num -= 1; //修改数量 model('order_import_file')->update(['success_num' => $success_num, 'error_num' => $error_num], [['id', '=', $res]]); //添加失败记录 model('order_import_file_log')->add( [ 'site_id' => $site_id, 'file_id' => $res, 'order_no' => $order_no, 'order_name' => $order_name, 'status' => -1, 'reason' => '电子面单模板不存在' ] ); continue; } $delivery_data['template_id'] = $template_id; } elseif ($type == '电子面单' && $addon_is_exit != 1) { $error_num += 1; $success_num -= 1; //修改数量 model('order_import_file')->update(['success_num' => $success_num, 'error_num' => $error_num], [['id', '=', $res]]); //添加失败记录 model('order_import_file_log')->add( [ 'site_id' => $site_id, 'file_id' => $res, 'order_no' => $order_no, 'order_name' => $order_name, 'status' => -1, 'reason' => '电子面单插件未安装'] ); continue; } else { $delivery_data['type'] = 'manual'; if (empty($delivery_no) || empty($name)) {//无需物流 $delivery_data['delivery_type'] = 0; } else { $company_id = model('express_company')->getValue([['site_id', '=', $site_id], ['company_name', '=', trim($name)]], 'company_id'); if ($company_id == '') { $error_num += 1; $success_num -= 1; //修改数量 model('order_import_file')->update(['success_num' => $success_num, 'error_num' => $error_num], [['id', '=', $res]]); //添加失败记录 model('order_import_file_log')->add( [ 'site_id' => $site_id, 'file_id' => $res, 'order_no' => $order_no, 'order_name' => $order_name, 'status' => -1, 'reason' => '物流公司不存在' ] ); continue; } $delivery_data['express_company_id'] = $company_id; $delivery_data['delivery_no'] = $delivery_no; } } //获取订单信息 $order_info = model('order')->getInfo([['order_no', '=', $order_no], ['site_id', '=', $site_id]], 'order_id,order_status'); if (empty($order_info) || $order_info['order_status'] != self::ORDER_PAY) { $error_num += 1; $success_num -= 1; //修改数量 model('order_import_file')->update(['success_num' => $success_num, 'error_num' => $error_num], [['id', '=', $res]]); //添加失败记录 model('order_import_file_log')->add( [ 'site_id' => $site_id, 'file_id' => $res, 'order_no' => $order_no, 'order_name' => $order_name, 'status' => -1, 'reason' => '订单不存在或者已发货' ] ); continue; } $delivery_data['order_id'] = $order_info['order_id']; $delivery_data['order_goods_ids'] = ''; if ($delivery_data['type'] == 'electronicsheet') {//电子面单发货 $electronicsheet_model = new ElectronicsheetDelivery(); $result = $electronicsheet_model->delivery($delivery_data); if ($result['code'] < 0) { $error_num += 1; $success_num -= 1; //修改数量 model('order_import_file')->update(['success_num' => $success_num, 'error_num' => $error_num], [['id', '=', $res]]); //添加失败记录 model('order_import_file_log')->add( [ 'site_id' => $site_id, 'file_id' => $res, 'order_no' => $order_no, 'order_name' => $order_name, 'status' => -1, 'reason' => $result['message'] ] ); continue; } $delivery_data['delivery_no'] = $result['data']['Order']['LogisticCode']; } $result = $this->orderGoodsDelivery($delivery_data, 2); if ($result['code'] < 0) { $error_num += 1; $success_num -= 1; //修改数量 model('order_import_file')->update(['success_num' => $success_num, 'error_num' => $error_num], [['id', '=', $res]]); //添加失败记录 model('order_import_file_log')->add( [ 'site_id' => $site_id, 'file_id' => $res, 'order_no' => $order_no, 'order_name' => $order_name, 'status' => -1, 'reason' => $result['message'] ] ); continue; } //添加成功记录 model('order_import_file_log')->add( [ 'site_id' => $site_id, 'file_id' => $res, 'order_no' => $order_no, 'order_name' => $order_name, 'status' => 0, 'reason' => '' ] ); } model('order_import_file')->commit(); return $this->success(); } catch (\Exception $e) { model('order_import_file')->rollback(); //修改数量 model('order_import_file')->update(['success_num' => 0, 'error_num' => $allRow - 1], [['id', '=', $res]]); return $this->error('', $e->getMessage()); } } /*** * 异步处理订单发货 * @return array|void */ public function AsyncOrderDelivery($site_id = 0) { $where = [ ['status', '=', 0], ['site_id', '=', $site_id] ]; $order_info = model('order_import_file_log')->getList($where, '*', '', '', '', '', 20); $result = [ 'code' => 0 ]; if ($order_info) { $electronicsheet_model = new ElectronicsheetDelivery(); foreach ($order_info as $item) { $delivery_data = [ 'type' => $item['delivery_type'],//发货方式(手动发货、电子面单) 'express_company_id' => $item['express_company_id'],//物流公司 'delivery_type' => $item['is_delivery'],//是否需要物流 'site_id' => $item['site_id'], 'template_id' => $item['template_id'],//电子面单模板id 'delivery_no' => $item['delivery_no'], 'order_id' => $item['order_id'], 'order_goods_ids' => '', ]; if ($delivery_data['type'] == 'electronicsheet') {//电子面单发货 $result = $electronicsheet_model->delivery($delivery_data); if ($result['code'] < 0) { //修改数量 model('order_import_file_log')->update(['status' => -1, 'reason' => $result['message']], ['id' => $item['id']]); continue; } else { Db::name('order_import_file')->where('id', '=', $item['file_id'])->update( [ 'error_num' => Db::raw('error_num- 1') ] ); } $delivery_data['delivery_no'] = $result['data']['Order']['LogisticCode']; } $result = $this->orderGoodsDelivery($delivery_data, 2);// if ($result['code'] < 0) { model('order_import_file_log')->update(['status' => -1, 'reason' => $result['message']], ['id' => $item['id']]); } else { Db::name('order_import_file')->where('id', '=', $item['file_id'])->update( [ 'error_num' => Db::raw('error_num- 1') ] ); } } $cron_model = new Cron(); $cron_model->addCron(1, 1, '订单批量发货任务', 'AsyncOrderDelivery', time() + 20, $site_id); } else { $res = Db::name('order_import_file_log')->where('status', '=', 0)->column('site_id', 'site_id'); if ($res) { $cron_model = new Cron(); foreach ($res as $key => $site_id) { $cron_model->addCron(1, 1, '订单批量发货任务', 'AsyncOrderDelivery', time() + 20, $site_id); } } } return $this->success($result); } /*** * 异步发货导入 * @param $param * @param $site_id * @param $uid * @return array * @throws \PhpOffice\PhpSpreadsheet\Exception * @throws \PhpOffice\PhpSpreadsheet\Reader\Exception */ public function AsyncorderFileDelivery($param, $site_id, $uid) { //电子面单插件 $addon_is_exit = addon_is_exit('electronicsheet', $site_id); $PHPReader = \PhpOffice\PhpSpreadsheet\IOFactory::createReader('Xlsx'); //载入文件 $PHPExcel = $PHPReader->load($param['path']); //获取表中的第一个工作表,如果要获取第二个,把0改为1,依次类推 $currentSheet = $PHPExcel->getSheet(0); //获取总行数 $allRow = $currentSheet->getHighestRow(); if ($allRow < 2) { return $this->error('', '导入了一个空文件'); } elseif ($allRow >= 800) { return $this->error('', '请导入数量800内数据'); } $user_info = model('user')->getInfo([['uid', '=', $uid]], 'username'); //添加文件上传记录 $success_num = 0; $error_num = $allRow - 1; $data = [ 'site_id' => $site_id, 'filename' => $param['filename'], 'path' => $param['path'], 'order_num' => $allRow - 1, 'success_num' => $success_num, 'create_time' => time(), 'uid' => $uid, 'username' => $user_info['username'] ]; $res = model('order_import_file')->add($data); if (!$res) { return $this->error('', '上传文件失败'); } model('order_import_file')->startTrans(); try { $delivery_data_all = []; for ($i = 2; $i <= $allRow; $i++) { //订单编号 $order_no = $PHPExcel->getActiveSheet()->getCell('A' . $i)->getValue(); $order_no = trim($order_no, ' '); $order_no = preg_replace('/\s+/', '', $order_no); //订单内容 $order_name = $PHPExcel->getActiveSheet()->getCell('B' . $i)->getValue(); $order_name = trim($order_name, ' '); //发货方式 $type = $PHPExcel->getActiveSheet()->getCell('F' . $i)->getValue(); $type = trim($type, ' '); //物流公司名称或电子面单名称 $name = $PHPExcel->getActiveSheet()->getCell('G' . $i)->getValue(); $name = trim($name, ' '); //物流单号 $delivery_no = $PHPExcel->getActiveSheet()->getCell('H' . $i)->getValue(); $delivery_no = trim($delivery_no, ' '); $delivery_data = [ 'site_id' => $site_id, 'file_id' => $res, 'order_no' => $order_no, 'order_name' => $order_name, 'express_company_id' => 0,//物流公司 'delivery_type' => '',//是否需要物流 'is_delivery' => 1,//是否需要物流 'template_id' => 0,//电子面单模板id 'delivery_no' => $delivery_no ]; if (empty($type)) { //添加失败记录 $delivery_data['status'] = -1; $delivery_data['reason'] = '发货方式为空'; $delivery_data_all[] = $delivery_data; continue; } if ($type == '电子面单' && $addon_is_exit == 1) { if (empty($name)) { //添加失败记录 $delivery_data['status'] = -1; $delivery_data['reason'] = '电子面单模板为空'; $delivery_data_all[] = $delivery_data; continue; } $delivery_data['delivery_type'] = 'electronicsheet'; $template_id = model('express_electronicsheet')->getValue([['template_name', '=', $name], ['site_id', '=', $site_id]], 'id'); if (empty($template_id)) { //添加失败记录 $delivery_data['status'] = -1; $delivery_data['reason'] = '电子面单模板不存在'; $delivery_data_all[] = $delivery_data; continue; } $delivery_data['template_id'] = $template_id; } elseif ($type == '电子面单' && $addon_is_exit != 1) { //添加失败记录 $delivery_data['status'] = -1; $delivery_data['reason'] = '电子面单插件未安装'; $delivery_data_all[] = $delivery_data; continue; } else { $delivery_data['delivery_type'] = 'manual'; if (empty($delivery_no) || empty($name)) {//无需物流 $delivery_data['is_delivery'] = 0; } else { $company_id = model('express_company')->getValue([['site_id', '=', $site_id], ['company_name', '=', trim($name)]], 'company_id'); if ($company_id == '') { //添加失败记录 $delivery_data['status'] = -1; $delivery_data['reason'] = '物流公司不存在'; $delivery_data_all[] = $delivery_data; continue; } $delivery_data['express_company_id'] = $company_id; $delivery_data['delivery_no'] = $delivery_no; } } //获取订单信息 $order_info = model('order')->getInfo([['order_no', '=', $order_no], ['site_id', '=', $site_id]], 'order_id,order_status'); if (empty($order_info) || $order_info['order_status'] != self::ORDER_PAY) { //添加失败记录 if ($order_info && in_array($order_info['order_status'], [self::ORDER_DELIVERY, self::ORDER_TAKE_DELIVERY, self::ORDER_COMPLETE])) { $delivery_data['status'] = 1; $delivery_data['reason'] = '已发货无需重新发货'; $success_num += 1; $error_num -= 1; } else if ($order_info && $order_info['order_status'] == -1) { $delivery_data['status'] = -1; $delivery_data['reason'] = '订单已关闭或者已退款'; } else { $delivery_data['status'] = -1; $delivery_data['reason'] = '订单不存在或者已发货'; } $delivery_data_all[] = $delivery_data; continue; } $success_num += 1; $error_num -= 1; $delivery_data['order_id'] = $order_info['order_id'] ?? 0; //添加成功记录 $delivery_data_all[] = $delivery_data; } model('order_import_file')->update(['success_num' => $success_num, 'error_num' => $error_num], [['id', '=', $res]]); foreach ($delivery_data_all as $item) { model('order_import_file_log')->add($item); } $cron_model = new Cron(); $cron_model->addCron(1, 1, '订单批量发货任务', 'AsyncOrderDelivery', time(), $site_id); model('order_import_file')->commit(); return $this->success(); } catch (\Exception $e) { model('order_import_file')->rollback(); //修改数量 model('order_import_file')->update(['success_num' => 0, 'error_num' => $allRow - 1], [['id', '=', $res]]); return $this->error('', $e->getMessage()); } } /** * 订单发货 * * @param array $condition */ public function orderDelivery($order_id, $log_data = [], $delivery_id = 0) { $order_info = model('order')->getInfo([['order_id', '=', $order_id]], 'site_id, order_status'); if ($order_info['order_status'] == 1) { //统计订单项目 $count = model('order_goods')->getCount([['order_id', '=', $order_id], ['delivery_status', '=', self::DELIVERY_WAIT], ['refund_status', '<>', 3]], 'order_goods_id'); $delivery_count = model('order_goods')->getCount([['order_id', '=', $order_id], ['delivery_status', '=', self::DELIVERY_DOING], ['refund_status', '<>', 3]], 'order_goods_id'); if ($count == 0 && $delivery_count > 0) { model('order')->startTrans(); try { //修改订单项的配送状态 $order_data = array( 'order_status' => self::ORDER_DELIVERY, 'order_status_name' => $this->order_status[self::ORDER_DELIVERY]['name'], 'delivery_status' => self::DELIVERY_FINISH, 'delivery_status_name' => $this->delivery_status[self::DELIVERY_FINISH]['name'], 'order_status_action' => json_encode($this->order_status[self::ORDER_DELIVERY], JSON_UNESCAPED_UNICODE), 'delivery_time' => time() ); $res = model('order')->update($order_data, [['order_id', '=', $order_id]]); if ($log_data) { //记录订单日志 start $log_data = array_merge($log_data, [ 'order_id' => $order_id, 'order_status' => self::ORDER_DELIVERY, 'order_status_name' => $this->order_status[self::ORDER_DELIVERY]['name'] ]); $this->addOrderLog($log_data); //记录订单日志 end } //获取订单自动收货时间 $config_model = new Config(); $event_time_config_result = $config_model->getOrderEventTimeConfig($order_info['site_id']); $event_time_config = $event_time_config_result['data']; $now_time = time(); //当前时间 if ($event_time_config['value']['auto_take_delivery'] > 0) { $execute_time = $now_time + $event_time_config['value']['auto_take_delivery'] * 86400;//自动收货时间 $cron_model = new Cron(); $cron_model->addCron(1, 1, '订单自动收货', 'CronOrderTakeDelivery', $execute_time, $order_id); } $deliveryInfo = model('express_delivery_package')->getInfo(['id' => $delivery_id]); if ($deliveryInfo['delivery_type'] == 1) { $result = event('OrderDelivery', ['order_id' => $order_id]); if (!empty($result[0]) && $result[0]['code'] < 0) { model('order')->rollback(); return $this->error(); } } //订单发货消息 $message_model = new Message(); $message_model->sendMessage(['keywords' => 'ORDER_DELIVERY', 'order_id' => $order_id, 'site_id' => $order_info['site_id']]); model('order')->commit(); return $this->success(); } catch (\Exception $e) { model('order')->rollback(); return $this->error('', $e->getMessage()); } } else { if ($log_data) { //记录订单日志 start $log_data = array_merge($log_data, [ 'order_id' => $order_id, 'order_status' => $order_info['order_status'], 'order_status_name' => $this->order_status[$order_info['order_status']]['name'] ]); $this->addOrderLog($log_data); //记录订单日志 end } return $this->success(); } } else { return $this->success(); } } /** * 订单收货 * * @param int $order_id */ public function orderTakeDelivery($order_id) { return $this->success(); } /** * 订单收货地址修改 */ public function orderAddressUpdate($param, $condition, $log_data = []) { $province_id = $param['province_id']; $city_id = $param['city_id']; $district_id = $param['district_id']; $community_id = $param['community_id']; $address = $param['address']; $full_address = $param['full_address']; $longitude = $param['longitude']; $latitude = $param['latitude']; $mobile = $param['mobile']; $telephone = $param['telephone']; $name = $param['name']; $data = array( 'province_id' => $province_id, 'city_id' => $city_id, 'district_id' => $district_id, 'community_id' => $community_id, 'address' => $address, 'full_address' => $full_address, 'longitude' => $longitude, 'latitude' => $latitude, 'mobile' => $mobile, 'telephone' => $telephone, 'name' => $name, ); $order_info = model('order')->getInfo($condition, 'order_status,order_status_name'); $order_status_array = [self::ORDER_PAY, self::ORDER_CREATE]; if (!in_array($order_info['order_status'], $order_status_array)) return $this->error('', '当前订单状态不可编辑收货地址!'); //记录订单日志 start if ($log_data) { $log_data = array_merge($log_data, [ 'order_status' => $order_info['order_status'], 'order_status_name' => $order_info['order_status_name'] ]); $this->addOrderLog($log_data); } //记录订单日志 end $result = model('order')->update($data, $condition); return $this->success($result); } /** * 退款完成操作 * @param $order_info */ public function refund($order_goods_info) { //是否入库 if ($order_goods_info['is_refund_stock'] == 1) { $order_stock_model = new OrderStock(); $order_stock_model->incOrderStock($order_goods_info); } //检测订单项是否否全部发放完毕 $this->orderDelivery($order_goods_info['order_id']); } /** * 订单详情 * @param $order_info */ public function orderDetail($order_info) { $express_package_model = new ExpressPackage(); $package_list = $express_package_model->package([['order_id', '=', $order_info['order_id']]], $order_info['mobile']); $order_info = []; $order_info['package_list'] = $package_list; return $order_info; } /** * 计算订单销售额 * @param array $condition * @param string $field * @return array */ public function getOrderMoneySum($condition = [], $field = 'order_money') { $res = model('order')->getSum($condition, $field); return $this->success($res); } /** * 退款中订单数量 */ public function getRefundOrderCount($condition) { $field = 'o.order_id'; $alias = 'o'; $join = [ [ 'order_goods og', 'og.order_id = o.order_id', 'left' ] ]; $res = model('order')->getJoinCount($condition, $field, $alias, $join); return $this->success($res); } }