| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883 |
- <?php
- /**
- * Niushop商城系统 - 团队十年电商经验汇集巨献!
- * =========================================================
- * Copy right 2019-2029 杭州牛之云科技有限公司, 保留所有权利。
- * ----------------------------------------------
- * 官方网址: https://www.niushop.com
- * =========================================================
- */
- namespace app\model\order;
- use addon\electronicsheet\model\ElectronicsheetDelivery;
- use app\model\express\ExpressDelivery;
- use app\model\express\ExpressPackage;
- use app\model\message\Message;
- use app\model\system\Cron;
- /**
- * 普通(快递)订单
- *
- * @author Administrator
- *
- */
- class Order extends OrderCommon
- {
- /*****************************************************************************************订单状态***********************************************/
- // 订单创建
- const ORDER_CREATE = 0;
- // 订单已支付
- const ORDER_PAY = 1;
- // 订单备货中
- const ORDER_PENDING_DELIVERY = 2;
- // 订单已发货(配货)
- const ORDER_DELIVERY = 3;
- // 订单已收货
- const ORDER_TAKE_DELIVERY = 4;
- // 订单已结算完成
- const ORDER_COMPLETE = 10;
- // 订单已关闭
- const ORDER_CLOSE = -1;
- /**
- * 订单类型
- *
- * @var int
- */
- public $order_type = 1;
- /***********************************************************************************订单项 配送状态**************************************************/
- // 待发货
- const DELIVERY_WAIT = 0;
- // 已发货
- const DELIVERY_DOING = 1;
- // 已收货
- const DELIVERY_FINISH = 2;
- /**
- */
- public $order_status = [
- self::ORDER_CREATE => [
- 'status' => self::ORDER_CREATE,
- 'name' => '待支付',
- 'is_allow_refund' => 0,
- 'icon' => 'public/uniapp/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/uniapp/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/uniapp/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/uniapp/order/order-icon-received.png',
- 'action' => [],
- 'member_action' => [],
- 'color' => ''
- ],
- self::ORDER_COMPLETE => [
- 'status' => self::ORDER_COMPLETE,
- 'name' => '已完成',
- 'icon' => 'public/uniapp/order/order-icon-received.png',
- 'is_allow_refund' => 1,
- 'action' => [],
- 'member_action' => [],
- 'color' => ''
- ],
- self::ORDER_CLOSE => [
- 'status' => self::ORDER_CLOSE,
- 'name' => '已关闭',
- 'icon' => 'public/uniapp/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/uniapp/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
- //操作接龙订单start
- $where = array (
- [ 'relate_order_id', '=', $order_info[ 'order_id' ] ],
- [ 'order_status', '=', self::ORDER_CREATE ],
- );
- model('promotion_jielong_order')->update([
- 'order_status' => self::ORDER_PAY,
- 'order_status_name' => $this->order_status[ self::ORDER_PAY ][ 'name' ],
- 'order_status_action' => json_encode($this->order_status[ self::ORDER_PAY ], JSON_UNESCAPED_UNICODE),
- 'pay_time' => time(),
- 'pay_type' => $pay_type,
- 'pay_type_name' => $pay_type_list[ $pay_type ]
- ], $where);
- //操作接龙订单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' ]))
- return $this->error('', '发送货物不可为空!');
- $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))
- 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' ] ?? []
- ]);
- if ($stock_result[ 'code' ] < 0) {
- model('order')->rollback();
- return $stock_result;
- }
- //创建包裹
- $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);
- 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', '=', $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());
- }
- }
- /**
- * 订单发货
- *
- * @param array $condition
- */
- public function orderDelivery($order_id, $log_data = [])
- {
- $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);
- }
- $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);
- }
- }
|