Order.php 35 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883
  1. <?php
  2. /**
  3. * Niushop商城系统 - 团队十年电商经验汇集巨献!
  4. * =========================================================
  5. * Copy right 2019-2029 杭州牛之云科技有限公司, 保留所有权利。
  6. * ----------------------------------------------
  7. * 官方网址: https://www.niushop.com
  8. * =========================================================
  9. */
  10. namespace app\model\order;
  11. use addon\electronicsheet\model\ElectronicsheetDelivery;
  12. use app\model\express\ExpressDelivery;
  13. use app\model\express\ExpressPackage;
  14. use app\model\message\Message;
  15. use app\model\system\Cron;
  16. /**
  17. * 普通(快递)订单
  18. *
  19. * @author Administrator
  20. *
  21. */
  22. class Order extends OrderCommon
  23. {
  24. /*****************************************************************************************订单状态***********************************************/
  25. // 订单创建
  26. const ORDER_CREATE = 0;
  27. // 订单已支付
  28. const ORDER_PAY = 1;
  29. // 订单备货中
  30. const ORDER_PENDING_DELIVERY = 2;
  31. // 订单已发货(配货)
  32. const ORDER_DELIVERY = 3;
  33. // 订单已收货
  34. const ORDER_TAKE_DELIVERY = 4;
  35. // 订单已结算完成
  36. const ORDER_COMPLETE = 10;
  37. // 订单已关闭
  38. const ORDER_CLOSE = -1;
  39. /**
  40. * 订单类型
  41. *
  42. * @var int
  43. */
  44. public $order_type = 1;
  45. /***********************************************************************************订单项 配送状态**************************************************/
  46. // 待发货
  47. const DELIVERY_WAIT = 0;
  48. // 已发货
  49. const DELIVERY_DOING = 1;
  50. // 已收货
  51. const DELIVERY_FINISH = 2;
  52. /**
  53. */
  54. public $order_status = [
  55. self::ORDER_CREATE => [
  56. 'status' => self::ORDER_CREATE,
  57. 'name' => '待支付',
  58. 'is_allow_refund' => 0,
  59. 'icon' => 'public/uniapp/order/order-icon.png',
  60. 'action' => [
  61. [
  62. 'action' => 'orderClose',
  63. 'title' => '关闭订单',
  64. 'color' => ''
  65. ],
  66. [
  67. 'action' => 'orderAddressUpdate',
  68. 'title' => '修改地址',
  69. 'color' => ''
  70. ],
  71. [
  72. 'action' => 'orderAdjustMoney',
  73. 'title' => '调整价格',
  74. 'color' => ''
  75. ],
  76. ],
  77. 'member_action' => [
  78. [
  79. 'action' => 'orderClose',
  80. 'title' => '关闭订单',
  81. 'color' => '',
  82. ],
  83. [
  84. 'action' => 'orderPay',
  85. 'title' => '支付',
  86. 'color' => ''
  87. ],
  88. ],
  89. 'color' => ''
  90. ],
  91. self::ORDER_PAY => [
  92. 'status' => self::ORDER_PAY,
  93. 'name' => '待发货',
  94. 'is_allow_refund' => 0,
  95. 'icon' => 'public/uniapp/order/order-icon-send.png',
  96. 'action' => [
  97. [
  98. 'action' => 'orderDelivery',
  99. 'title' => '发货',
  100. 'color' => ''
  101. ],
  102. [
  103. 'action' => 'orderAddressUpdate',
  104. 'title' => '修改地址',
  105. 'color' => ''
  106. ],
  107. ],
  108. 'member_action' => [],
  109. 'color' => ''
  110. ],
  111. self::ORDER_DELIVERY => [
  112. 'status' => self::ORDER_DELIVERY,
  113. 'name' => '已发货',
  114. 'is_allow_refund' => 1,
  115. 'icon' => 'public/uniapp/order/order-icon-receive.png',
  116. 'action' => [
  117. [
  118. 'action' => 'takeDelivery',
  119. 'title' => '确认收货',
  120. 'color' => ''
  121. ],
  122. ],
  123. 'member_action' => [
  124. [
  125. 'action' => 'memberTakeDelivery',
  126. 'title' => '确认收货',
  127. 'color' => ''
  128. ],
  129. [
  130. 'action' => 'trace',
  131. 'title' => '查看物流',
  132. 'color' => ''
  133. ]
  134. ],
  135. 'color' => ''
  136. ],
  137. self::ORDER_TAKE_DELIVERY => [
  138. 'status' => self::ORDER_TAKE_DELIVERY,
  139. 'name' => '已收货',
  140. 'is_allow_refund' => 1,
  141. 'icon' => 'public/uniapp/order/order-icon-received.png',
  142. 'action' => [],
  143. 'member_action' => [],
  144. 'color' => ''
  145. ],
  146. self::ORDER_COMPLETE => [
  147. 'status' => self::ORDER_COMPLETE,
  148. 'name' => '已完成',
  149. 'icon' => 'public/uniapp/order/order-icon-received.png',
  150. 'is_allow_refund' => 1,
  151. 'action' => [],
  152. 'member_action' => [],
  153. 'color' => ''
  154. ],
  155. self::ORDER_CLOSE => [
  156. 'status' => self::ORDER_CLOSE,
  157. 'name' => '已关闭',
  158. 'icon' => 'public/uniapp/order/order-icon-close.png',
  159. 'is_allow_refund' => 0,
  160. 'action' => [],
  161. 'member_action' => [],
  162. 'color' => ''
  163. ]
  164. ];
  165. /**
  166. * 订单状态(发货列表)
  167. */
  168. public $delivery_order_status = [
  169. self::ORDER_PAY => [
  170. 'status' => self::ORDER_PAY,
  171. 'name' => '待发货',
  172. 'is_allow_refund' => 0,
  173. 'icon' => 'public/uniapp/order/order-icon-send.png',
  174. 'action' => [
  175. [
  176. 'action' => 'orderDelivery',
  177. 'title' => '发货',
  178. 'color' => ''
  179. ],
  180. [
  181. 'action' => 'orderAddressUpdate',
  182. 'title' => '修改地址',
  183. 'color' => ''
  184. ],
  185. ],
  186. 'member_action' => [],
  187. 'color' => ''
  188. ]
  189. ];
  190. /**
  191. * 配送状态
  192. */
  193. public $delivery_status = [
  194. self::DELIVERY_WAIT => [
  195. 'status' => self::DELIVERY_WAIT,
  196. 'name' => '待发货',
  197. 'color' => ''
  198. ],
  199. self::DELIVERY_DOING => [
  200. 'status' => self::DELIVERY_DOING,
  201. 'name' => '已发货',
  202. 'color' => ''
  203. ],
  204. self::DELIVERY_FINISH => [
  205. 'status' => self::DELIVERY_FINISH,
  206. 'name' => '已收货',
  207. 'color' => ''
  208. ]
  209. ];
  210. /**
  211. * 订单支付
  212. * @param unknown $order_info
  213. */
  214. public function orderPay($order_info, $pay_type, $log_data = [])
  215. {
  216. $pay_type_list = $this->getPayType();
  217. if ($order_info[ 'order_status' ] != 0) {
  218. return $this->error();
  219. }
  220. $condition = array (
  221. [ 'order_id', '=', $order_info[ 'order_id' ] ],
  222. [ 'order_status', '=', self::ORDER_CREATE ],
  223. );
  224. $data = array (
  225. 'order_status' => self::ORDER_PAY,
  226. 'order_status_name' => $this->order_status[ self::ORDER_PAY ][ 'name' ],
  227. 'pay_status' => 1,
  228. 'order_status_action' => json_encode($this->order_status[ self::ORDER_PAY ], JSON_UNESCAPED_UNICODE),
  229. 'pay_time' => time(),
  230. 'is_enable_refund' => 1,
  231. 'pay_type' => $pay_type,
  232. 'pay_type_name' => $pay_type_list[ $pay_type ]
  233. );
  234. //记录订单日志 start
  235. $action = '商家对订单进行了线下支付';
  236. //获取用户信息
  237. if (empty($log_data)) {
  238. $member_info = model('member')->getInfo([ 'member_id' => $order_info[ 'member_id' ] ], 'nickname');
  239. $log_data = [
  240. 'uid' => $order_info[ 'member_id' ],
  241. 'nick_name' => $member_info[ 'nickname' ],
  242. 'action_way' => 1
  243. ];
  244. $buyer_name = empty($member_info[ 'nickname' ]) ? '' : '【' . $member_info[ 'nickname' ] . '】';
  245. $action = '买家' . $buyer_name . '支付了订单';
  246. }
  247. $log_data = array_merge($log_data, [
  248. 'order_id' => $order_info[ 'order_id' ],
  249. 'action' => $action,
  250. 'order_status' => self::ORDER_PAY,
  251. 'order_status_name' => $this->order_status[ self::ORDER_PAY ][ 'name' ]
  252. ]);
  253. $this->addOrderLog($log_data);
  254. //记录订单日志 end
  255. //操作接龙订单start
  256. $where = array (
  257. [ 'relate_order_id', '=', $order_info[ 'order_id' ] ],
  258. [ 'order_status', '=', self::ORDER_CREATE ],
  259. );
  260. model('promotion_jielong_order')->update([
  261. 'order_status' => self::ORDER_PAY,
  262. 'order_status_name' => $this->order_status[ self::ORDER_PAY ][ 'name' ],
  263. 'order_status_action' => json_encode($this->order_status[ self::ORDER_PAY ], JSON_UNESCAPED_UNICODE),
  264. 'pay_time' => time(),
  265. 'pay_type' => $pay_type,
  266. 'pay_type_name' => $pay_type_list[ $pay_type ]
  267. ], $where);
  268. //操作接龙订单end
  269. $result = model('order')->update($data, $condition);
  270. return $this->success($result);
  271. }
  272. /**
  273. * 订单项发货(物流)
  274. * @param $param
  275. * @param int $type //1 订单项发货 2整体发货
  276. * @return array
  277. */
  278. public function orderGoodsDelivery($param, $type = 1, $log_data = [])
  279. {
  280. $param[ 'type' ] = isset($param[ 'type' ]) ? $param[ 'type' ] : 'manual';
  281. model('order_goods')->startTrans();
  282. try {
  283. $order_id = $param[ 'order_id' ];
  284. $delivery_no = $param[ 'delivery_no' ]; //物流单号
  285. $delivery_type = $param[ 'delivery_type' ];
  286. if ($delivery_type == 0) {
  287. $express_company_id = 0;
  288. } else {
  289. $express_company_id = $param[ 'express_company_id' ] ?? 0;
  290. }
  291. $site_id = $param[ 'site_id' ];
  292. if ($type == 1) {
  293. if (empty($param[ 'order_goods_ids' ]))
  294. return $this->error('', '发送货物不可为空!');
  295. $order_goods_id_array = explode(',', $param[ 'order_goods_ids' ]);
  296. } else {
  297. $order_goods_id_array = model('order_goods')->getColumn(
  298. [
  299. [ 'order_id', '=', $order_id ],
  300. [ 'site_id', '=', $site_id ],
  301. [ 'delivery_status', '=', self::DELIVERY_WAIT ],
  302. [ 'refund_status', '<>', 3 ]
  303. ],
  304. 'order_goods_id'
  305. );
  306. }
  307. if (empty($order_goods_id_array))
  308. return $this->error('', '发送货物不可为空!');
  309. $order_id = 0;
  310. $member_id = 0;
  311. $goods_id_array = [];
  312. $order_stock_model = new OrderStock();
  313. $stock_sku_list = [];
  314. foreach ($order_goods_id_array as $k => $v) {
  315. $order_goods_info = model('order_goods')->getInfo([ [ 'order_goods_id', '=', $v ], [ 'site_id', '=', $site_id ] ], '*');
  316. //已退款的订单项不可发货
  317. if ($order_goods_info[ 'refund_status' ] == 3) {
  318. model('order_goods')->rollback();
  319. return $this->error([], 'ORDER_GOODS_IS_REFUND');
  320. }
  321. if ($order_goods_info[ 'delivery_status' ] == self::DELIVERY_DOING) {
  322. model('order_goods')->rollback();
  323. return $this->error([], 'ORDER_GOODS_IS_DELIVERYED');
  324. }
  325. $order_goods_info[ 'num' ] = numberFormat($order_goods_info[ 'num' ]);
  326. $member_id = $order_goods_info[ 'member_id' ];
  327. $goods_id_array[] = $order_goods_info[ 'sku_id' ] . ':' . $order_goods_info[ 'num' ] . ':' . $order_goods_info[ 'sku_name' ] . ':' . $order_goods_info[ 'sku_image' ];
  328. $data = [ 'delivery_status' => self::DELIVERY_DOING, 'delivery_status_name' => $this->delivery_status[ self::DELIVERY_DOING ][ 'name' ] ];
  329. if (!empty($delivery_no)) {
  330. $data[ 'delivery_no' ] = $delivery_no;
  331. }
  332. $res = model('order_goods')->update($data, [
  333. [ 'order_goods_id', '=', $v ],
  334. [ 'delivery_status', '=', self::DELIVERY_WAIT ]
  335. ]);
  336. $order_id = $order_goods_info[ 'order_id' ];
  337. //实际发货扣除库存
  338. $stock_sku_list[] = $order_goods_info;
  339. }
  340. $order_info = model('order')->getInfo([ [ 'order_id', '=', $order_id ] ], 'store_id,site_id');
  341. $stock_result = $order_stock_model->decOrderStock([
  342. 'store_id' => $order_info[ 'store_id' ],
  343. 'site_id' => $order_info[ 'site_id' ],
  344. 'goods_sku_list' => $stock_sku_list,
  345. 'user_info' => $param[ 'user_info' ] ?? []
  346. ]);
  347. if ($stock_result[ 'code' ] < 0) {
  348. model('order')->rollback();
  349. return $stock_result;
  350. }
  351. //创建包裹
  352. $order_common_model = new OrderCommon();
  353. $lock_result = $order_common_model->verifyOrderLock($order_id);
  354. if ($lock_result[ 'code' ] < 0) {
  355. model('order_goods')->rollback();
  356. return $lock_result;
  357. }
  358. $express_delivery_model = new ExpressDelivery();
  359. $delivery_data = array (
  360. 'order_id' => $order_id,
  361. 'order_goods_id_array' => $order_goods_id_array,
  362. 'goods_id_array' => $goods_id_array,
  363. 'goods_array' => $goods_id_array,
  364. 'site_id' => $site_id,
  365. 'delivery_no' => $delivery_no,
  366. 'member_id' => $member_id,
  367. 'express_company_id' => $express_company_id,
  368. 'delivery_type' => $delivery_type,
  369. 'type' => $param[ 'type' ],
  370. 'template_id' => $param[ 'template_id' ]
  371. );
  372. $delivery_id = $express_delivery_model->delivery($delivery_data);
  373. //检测整体, 订单中订单项是否全部发放完毕
  374. $res = $this->orderCommonDelivery($order_id, $log_data);
  375. if ($res[ 'code' ] < 0) {
  376. model('order_goods')->rollback();
  377. return $res;
  378. }
  379. model('order_goods')->commit();
  380. return $this->success($delivery_id);
  381. } catch (\Exception $e) {
  382. model('order_goods')->rollback();
  383. return $this->error('', $e->getMessage() . $e->getFile() . $e->getLine());
  384. }
  385. }
  386. /**
  387. * 批量订单发货(物流)
  388. * @param $param
  389. * @return array
  390. */
  391. public function orderBatchDelivery($param, $order_list)
  392. {
  393. model('express_delivery_package')->startTrans();
  394. try {
  395. if (empty($order_list)) {
  396. return $this->error('', '请先选择要发货的订单');
  397. }
  398. foreach ($order_list as $v) {
  399. $param[ 'order_id' ] = $v[ 'order_id' ];
  400. $param[ 'order_goods_ids' ] = '';
  401. if ($param[ 'type' ] == 'electronicsheet') {//电子面单发货
  402. $addon_is_exit = addon_is_exit('electronicsheet', $param[ 'site_id' ]);
  403. if ($addon_is_exit != 1) {
  404. return $this->error('', '电子面单插件不存在');
  405. }
  406. $electronicsheet_model = new ElectronicsheetDelivery();
  407. $result = $electronicsheet_model->delivery($param);
  408. if ($result[ 'code' ] < 0) {
  409. return $result;
  410. }
  411. $param[ 'delivery_no' ] = $result[ 'data' ][ 'Order' ][ 'LogisticCode' ];
  412. } else {
  413. $param[ 'delivery_no' ] = $v[ 'delivery_no' ];
  414. }
  415. $result = $this->orderGoodsDelivery($param, 2);
  416. if ($result[ 'code' ] < 0) {
  417. model('express_delivery_package')->rollback();
  418. return $result;
  419. }
  420. }
  421. model('express_delivery_package')->commit();
  422. return $this->success();
  423. } catch (\Exception $e) {
  424. model('express_delivery_package')->rollback();
  425. return $this->error('', $e->getMessage());
  426. }
  427. }
  428. /**
  429. * 批量订单发货(导入excel文件发货)
  430. * @param $filename
  431. */
  432. public function orderFileDelivery($param, $site_id, $uid)
  433. {
  434. //电子面单插件
  435. $addon_is_exit = addon_is_exit('electronicsheet', $site_id);
  436. $PHPReader = \PhpOffice\PhpSpreadsheet\IOFactory::createReader('Xlsx');
  437. //载入文件
  438. $PHPExcel = $PHPReader->load($param[ 'path' ]);
  439. //获取表中的第一个工作表,如果要获取第二个,把0改为1,依次类推
  440. $currentSheet = $PHPExcel->getSheet(0);
  441. //获取总行数
  442. $allRow = $currentSheet->getHighestRow();
  443. if ($allRow < 2) {
  444. return $this->error('', '导入了一个空文件');
  445. }
  446. $user_info = model('user')->getInfo([ [ 'uid', '=', $uid ] ], 'username');
  447. //添加文件上传记录
  448. $success_num = $allRow - 1;
  449. $error_num = 0;
  450. $data = [
  451. 'site_id' => $site_id,
  452. 'filename' => $param[ 'filename' ],
  453. 'path' => $param[ 'path' ],
  454. 'order_num' => $allRow - 1,
  455. 'success_num' => $success_num,
  456. 'create_time' => time(),
  457. 'uid' => $uid,
  458. 'username' => $user_info[ 'username' ]
  459. ];
  460. $res = model('order_import_file')->add($data);
  461. if (!$res) {
  462. return $this->error('', '上传文件失败');
  463. }
  464. model('order_import_file')->startTrans();
  465. try {
  466. for ($i = 2; $i <= $allRow; $i++) {
  467. $delivery_data = [
  468. 'type' => '',//发货方式(手动发货、电子面单)
  469. 'express_company_id' => 0,//物流公司
  470. 'delivery_type' => 1,//是否需要物流
  471. 'site_id' => $site_id,
  472. 'template_id' => 0,//电子面单模板id
  473. 'delivery_no' => ''
  474. ];
  475. //订单编号
  476. $order_no = $PHPExcel->getActiveSheet()->getCell('A' . $i)->getValue();
  477. $order_no = trim($order_no, ' ');
  478. $order_no = preg_replace('/\s+/', '', $order_no);
  479. //订单内容
  480. $order_name = $PHPExcel->getActiveSheet()->getCell('B' . $i)->getValue();
  481. $order_name = trim($order_name, ' ');
  482. //发货方式
  483. $type = $PHPExcel->getActiveSheet()->getCell('F' . $i)->getValue();
  484. $type = trim($type, ' ');
  485. //物流公司名称或电子面单名称
  486. $name = $PHPExcel->getActiveSheet()->getCell('G' . $i)->getValue();
  487. $name = trim($name, ' ');
  488. //物流单号
  489. $delivery_no = $PHPExcel->getActiveSheet()->getCell('H' . $i)->getValue();
  490. $delivery_no = trim($delivery_no, ' ');
  491. if (empty($type)) {
  492. $error_num += 1;
  493. $success_num -= 1;
  494. //修改数量
  495. model('order_import_file')->update([ 'success_num' => $success_num, 'error_num' => $error_num ], [ [ 'id', '=', $res ] ]);
  496. //添加失败记录
  497. model('order_import_file_log')->add(
  498. [
  499. 'site_id' => $site_id, 'file_id' => $res, 'order_no' => $order_no, 'order_name' => $order_name,
  500. 'status' => -1, 'reason' => '发货方式为空'
  501. ]
  502. );
  503. continue;
  504. }
  505. if ($type == '电子面单' && $addon_is_exit == 1) {
  506. if (empty($name)) {
  507. $error_num += 1;
  508. $success_num -= 1;
  509. //修改数量
  510. model('order_import_file')->update([ 'success_num' => $success_num, 'error_num' => $error_num ], [ [ 'id', '=', $res ] ]);
  511. //添加失败记录
  512. model('order_import_file_log')->add(
  513. [
  514. 'site_id' => $site_id, 'file_id' => $res, 'order_no' => $order_no, 'order_name' => $order_name,
  515. 'status' => -1, 'reason' => '电子面单模板为空'
  516. ]
  517. );
  518. continue;
  519. }
  520. $delivery_data[ 'type' ] = 'electronicsheet';
  521. $template_id = model('express_electronicsheet')->getValue([ [ 'template_name', '=', $name ], [ 'site_id', '=', $site_id ] ], 'id');
  522. if (empty($template_id)) {
  523. $error_num += 1;
  524. $success_num -= 1;
  525. //修改数量
  526. model('order_import_file')->update([ 'success_num' => $success_num, 'error_num' => $error_num ], [ [ 'id', '=', $res ] ]);
  527. //添加失败记录
  528. model('order_import_file_log')->add(
  529. [
  530. 'site_id' => $site_id, 'file_id' => $res, 'order_no' => $order_no, 'order_name' => $order_name,
  531. 'status' => -1, 'reason' => '电子面单模板不存在'
  532. ]
  533. );
  534. continue;
  535. }
  536. $delivery_data[ 'template_id' ] = $template_id;
  537. } elseif ($type == '电子面单' && $addon_is_exit != 1) {
  538. $error_num += 1;
  539. $success_num -= 1;
  540. //修改数量
  541. model('order_import_file')->update([ 'success_num' => $success_num, 'error_num' => $error_num ], [ [ 'id', '=', $res ] ]);
  542. //添加失败记录
  543. model('order_import_file_log')->add(
  544. [
  545. 'site_id' => $site_id, 'file_id' => $res, 'order_no' => $order_no, 'order_name' => $order_name,
  546. 'status' => -1, 'reason' => '电子面单插件未安装' ]
  547. );
  548. continue;
  549. } else {
  550. $delivery_data[ 'type' ] = 'manual';
  551. if (empty($delivery_no) || empty($name)) {//无需物流
  552. $delivery_data[ 'delivery_type' ] = 0;
  553. } else {
  554. $company_id = model('express_company')->getValue([ [ 'site_id', '=', $site_id ], [ 'company_name', '=', $name ] ], 'company_id');
  555. if ($company_id == '') {
  556. $error_num += 1;
  557. $success_num -= 1;
  558. //修改数量
  559. model('order_import_file')->update([ 'success_num' => $success_num, 'error_num' => $error_num ], [ [ 'id', '=', $res ] ]);
  560. //添加失败记录
  561. model('order_import_file_log')->add(
  562. [
  563. 'site_id' => $site_id, 'file_id' => $res, 'order_no' => $order_no, 'order_name' => $order_name,
  564. 'status' => -1, 'reason' => '物流公司不存在'
  565. ]
  566. );
  567. continue;
  568. }
  569. $delivery_data[ 'express_company_id' ] = $company_id;
  570. $delivery_data[ 'delivery_no' ] = $delivery_no;
  571. }
  572. }
  573. //获取订单信息
  574. $order_info = model('order')->getInfo([ [ 'order_no', '=', $order_no ], [ 'site_id', '=', $site_id ] ], 'order_id,order_status');
  575. if (empty($order_info) || $order_info[ 'order_status' ] != self::ORDER_PAY) {
  576. $error_num += 1;
  577. $success_num -= 1;
  578. //修改数量
  579. model('order_import_file')->update([ 'success_num' => $success_num, 'error_num' => $error_num ], [ [ 'id', '=', $res ] ]);
  580. //添加失败记录
  581. model('order_import_file_log')->add(
  582. [
  583. 'site_id' => $site_id, 'file_id' => $res, 'order_no' => $order_no, 'order_name' => $order_name,
  584. 'status' => -1, 'reason' => '订单不存在或者已发货'
  585. ]
  586. );
  587. continue;
  588. }
  589. $delivery_data[ 'order_id' ] = $order_info[ 'order_id' ];
  590. $delivery_data[ 'order_goods_ids' ] = '';
  591. if ($delivery_data[ 'type' ] == 'electronicsheet') {//电子面单发货
  592. $electronicsheet_model = new ElectronicsheetDelivery();
  593. $result = $electronicsheet_model->delivery($delivery_data);
  594. if ($result[ 'code' ] < 0) {
  595. $error_num += 1;
  596. $success_num -= 1;
  597. //修改数量
  598. model('order_import_file')->update([ 'success_num' => $success_num, 'error_num' => $error_num ], [ [ 'id', '=', $res ] ]);
  599. //添加失败记录
  600. model('order_import_file_log')->add(
  601. [
  602. 'site_id' => $site_id, 'file_id' => $res, 'order_no' => $order_no, 'order_name' => $order_name,
  603. 'status' => -1, 'reason' => $result[ 'message' ]
  604. ]
  605. );
  606. continue;
  607. }
  608. $delivery_data[ 'delivery_no' ] = $result[ 'data' ][ 'Order' ][ 'LogisticCode' ];
  609. }
  610. $result = $this->orderGoodsDelivery($delivery_data, 2);
  611. if ($result[ 'code' ] < 0) {
  612. $error_num += 1;
  613. $success_num -= 1;
  614. //修改数量
  615. model('order_import_file')->update([ 'success_num' => $success_num, 'error_num' => $error_num ], [ [ 'id', '=', $res ] ]);
  616. //添加失败记录
  617. model('order_import_file_log')->add(
  618. [
  619. 'site_id' => $site_id, 'file_id' => $res, 'order_no' => $order_no, 'order_name' => $order_name,
  620. 'status' => -1, 'reason' => $result[ 'message' ]
  621. ]
  622. );
  623. continue;
  624. }
  625. //添加成功记录
  626. model('order_import_file_log')->add(
  627. [
  628. 'site_id' => $site_id, 'file_id' => $res, 'order_no' => $order_no, 'order_name' => $order_name,
  629. 'status' => 0, 'reason' => ''
  630. ]
  631. );
  632. }
  633. model('order_import_file')->commit();
  634. return $this->success();
  635. } catch (\Exception $e) {
  636. model('order_import_file')->rollback();
  637. //修改数量
  638. model('order_import_file')->update([ 'success_num' => 0, 'error_num' => $allRow - 1 ], [ [ 'id', '=', $res ] ]);
  639. return $this->error('', $e->getMessage());
  640. }
  641. }
  642. /**
  643. * 订单发货
  644. *
  645. * @param array $condition
  646. */
  647. public function orderDelivery($order_id, $log_data = [])
  648. {
  649. $order_info = model('order')->getInfo([ [ 'order_id', '=', $order_id ] ], 'site_id, order_status');
  650. if ($order_info[ 'order_status' ] == 1) {
  651. //统计订单项目
  652. $count = model('order_goods')->getCount([ [ 'order_id', '=', $order_id ], [ 'delivery_status', '=', self::DELIVERY_WAIT ], [ 'refund_status', '<>', 3 ] ], 'order_goods_id');
  653. $delivery_count = model('order_goods')->getCount([ [ 'order_id', '=', $order_id ], [ 'delivery_status', '=', self::DELIVERY_DOING ], [ 'refund_status', '<>', 3 ] ], 'order_goods_id');
  654. if ($count == 0 && $delivery_count > 0) {
  655. model('order')->startTrans();
  656. try {
  657. //修改订单项的配送状态
  658. $order_data = array (
  659. 'order_status' => self::ORDER_DELIVERY,
  660. 'order_status_name' => $this->order_status[ self::ORDER_DELIVERY ][ 'name' ],
  661. 'delivery_status' => self::DELIVERY_FINISH,
  662. 'delivery_status_name' => $this->delivery_status[ self::DELIVERY_FINISH ][ 'name' ],
  663. 'order_status_action' => json_encode($this->order_status[ self::ORDER_DELIVERY ], JSON_UNESCAPED_UNICODE),
  664. 'delivery_time' => time()
  665. );
  666. $res = model('order')->update($order_data, [ [ 'order_id', '=', $order_id ] ]);
  667. if ($log_data) {
  668. //记录订单日志 start
  669. $log_data = array_merge($log_data, [
  670. 'order_id' => $order_id,
  671. 'order_status' => self::ORDER_DELIVERY,
  672. 'order_status_name' => $this->order_status[ self::ORDER_DELIVERY ][ 'name' ]
  673. ]);
  674. $this->addOrderLog($log_data);
  675. //记录订单日志 end
  676. }
  677. //获取订单自动收货时间
  678. $config_model = new Config();
  679. $event_time_config_result = $config_model->getOrderEventTimeConfig($order_info[ 'site_id' ]);
  680. $event_time_config = $event_time_config_result[ 'data' ];
  681. $now_time = time(); //当前时间
  682. if ($event_time_config[ 'value' ][ 'auto_take_delivery' ] > 0) {
  683. $execute_time = $now_time + $event_time_config[ 'value' ][ 'auto_take_delivery' ] * 86400;//自动收货时间
  684. $cron_model = new Cron();
  685. $cron_model->addCron(1, 1, '订单自动收货', 'CronOrderTakeDelivery', $execute_time, $order_id);
  686. }
  687. $result = event('OrderDelivery', [ 'order_id' => $order_id ]);
  688. if (!empty($result[ 0 ]) && $result[ 0 ][ 'code' ] < 0) {
  689. model('order')->rollback();
  690. return $this->error();
  691. }
  692. //订单发货消息
  693. $message_model = new Message();
  694. $message_model->sendMessage([ 'keywords' => 'ORDER_DELIVERY', 'order_id' => $order_id, 'site_id' => $order_info[ 'site_id' ] ]);
  695. model('order')->commit();
  696. return $this->success();
  697. } catch (\Exception $e) {
  698. model('order')->rollback();
  699. return $this->error('', $e->getMessage());
  700. }
  701. } else {
  702. if ($log_data) {
  703. //记录订单日志 start
  704. $log_data = array_merge($log_data, [
  705. 'order_id' => $order_id,
  706. 'order_status' => $order_info[ 'order_status' ],
  707. 'order_status_name' => $this->order_status[ $order_info[ 'order_status' ] ][ 'name' ]
  708. ]);
  709. $this->addOrderLog($log_data);
  710. //记录订单日志 end
  711. }
  712. return $this->success();
  713. }
  714. } else {
  715. return $this->success();
  716. }
  717. }
  718. /**
  719. * 订单收货
  720. *
  721. * @param int $order_id
  722. */
  723. public function orderTakeDelivery($order_id)
  724. {
  725. return $this->success();
  726. }
  727. /**
  728. * 订单收货地址修改
  729. */
  730. public function orderAddressUpdate($param, $condition, $log_data = [])
  731. {
  732. $province_id = $param[ 'province_id' ];
  733. $city_id = $param[ 'city_id' ];
  734. $district_id = $param[ 'district_id' ];
  735. $community_id = $param[ 'community_id' ];
  736. $address = $param[ 'address' ];
  737. $full_address = $param[ 'full_address' ];
  738. $longitude = $param[ 'longitude' ];
  739. $latitude = $param[ 'latitude' ];
  740. $mobile = $param[ 'mobile' ];
  741. $telephone = $param[ 'telephone' ];
  742. $name = $param[ 'name' ];
  743. $data = array (
  744. 'province_id' => $province_id,
  745. 'city_id' => $city_id,
  746. 'district_id' => $district_id,
  747. 'community_id' => $community_id,
  748. 'address' => $address,
  749. 'full_address' => $full_address,
  750. 'longitude' => $longitude,
  751. 'latitude' => $latitude,
  752. 'mobile' => $mobile,
  753. 'telephone' => $telephone,
  754. 'name' => $name,
  755. );
  756. $order_info = model('order')->getInfo($condition, 'order_status,order_status_name');
  757. $order_status_array = [ self::ORDER_PAY, self::ORDER_CREATE ];
  758. if (!in_array($order_info[ 'order_status' ], $order_status_array))
  759. return $this->error('', '当前订单状态不可编辑收货地址!');
  760. //记录订单日志 start
  761. if ($log_data) {
  762. $log_data = array_merge($log_data, [
  763. 'order_status' => $order_info[ 'order_status' ],
  764. 'order_status_name' => $order_info[ 'order_status_name' ]
  765. ]);
  766. $this->addOrderLog($log_data);
  767. }
  768. //记录订单日志 end
  769. $result = model('order')->update($data, $condition);
  770. return $this->success($result);
  771. }
  772. /**
  773. * 退款完成操作
  774. * @param $order_info
  775. */
  776. public function refund($order_goods_info)
  777. {
  778. //是否入库
  779. if ($order_goods_info[ 'is_refund_stock' ] == 1) {
  780. $order_stock_model = new OrderStock();
  781. $order_stock_model->incOrderStock($order_goods_info);
  782. }
  783. //检测订单项是否否全部发放完毕
  784. $this->orderDelivery($order_goods_info[ 'order_id' ]);
  785. }
  786. /**
  787. * 订单详情
  788. * @param $order_info
  789. */
  790. public function orderDetail($order_info)
  791. {
  792. $express_package_model = new ExpressPackage();
  793. $package_list = $express_package_model->package([ [ 'order_id', '=', $order_info[ 'order_id' ] ] ], $order_info[ 'mobile' ]);
  794. $order_info = [];
  795. $order_info[ 'package_list' ] = $package_list;
  796. return $order_info;
  797. }
  798. /**
  799. * 计算订单销售额
  800. * @param array $condition
  801. * @param string $field
  802. * @return array
  803. */
  804. public function getOrderMoneySum($condition = [], $field = 'order_money')
  805. {
  806. $res = model('order')->getSum($condition, $field);
  807. return $this->success($res);
  808. }
  809. }