Order.php 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490
  1. <?php
  2. namespace addons\unishop\model;
  3. use addons\unishop\extend\Hashids;
  4. use addons\unishop\extend\Snowflake;
  5. use think\Hook;
  6. use think\Model;
  7. use traits\model\SoftDelete;
  8. /**
  9. * 收货地址模型
  10. * Class Favorite
  11. * @package addons\unishop\model
  12. */
  13. class Order extends Model
  14. {
  15. use SoftDelete;
  16. protected $deleteTime = 'deletetime';
  17. // 表名
  18. protected $name = 'unishop_order';
  19. // 开启自动写入时间戳字段
  20. protected $autoWriteTimestamp = 'int';
  21. // 定义时间戳字段名
  22. protected $createTime = 'createtime';
  23. protected $updateTime = 'updatetime';
  24. // 隐藏属性
  25. protected $hidden = [
  26. 'id',
  27. 'user_id'
  28. ];
  29. // 支付类型
  30. const PAY_ONLINE = 1; // 在线支付
  31. const PAY_OFFLINE = 2; // 线下支付 或 货到付款
  32. const PAY_WXPAY = 3; // 微信支付
  33. const PAY_ALIPAY = 4; // 支付宝支付
  34. // 订单状态
  35. const STATUS_NORMAL = 1; // 正常
  36. const STATUS_CANCEL = 0; // 用户取消订单
  37. const STATUS_REFUND = -1; // 申请售后
  38. // 申请售后状态 0=无,1=申请中,2=通过(让用户发货),3=通过,4=拒绝
  39. const REFUND_STATUS_NONE = 0;
  40. const REFUND_STATUS_APPLY = 1;
  41. const REFUND_STATUS_DELIVERY = 2;
  42. const REFUND_STATUS_AGREE = 3;
  43. const REFUND_STATUS_REFUSE = 4;
  44. // 是否支付
  45. const PAID_NO = 0; // 否
  46. // 是否发货 delivered
  47. const DELIVERED_NO = 0; // 否
  48. // 是否评论
  49. const COMMENTED_NO = 0; // 否
  50. // 是否收货
  51. const RECEIVED_NO = 0; // 否
  52. // 订单类型
  53. const TYPE_ALL = 0; // 全部
  54. const TYPE_PAY = 1; // 待付款
  55. const TYPE_DELIVES = 2; // 待发货
  56. const TYPE_RECEIVE = 3; // 待核销
  57. const TYPE_COMMENT = 4; // 待评价
  58. const TYPE_REFUND = 5; // 售后
  59. const TYPE_REFUSE = 6; // 拒绝退款
  60. const TYPE_OFF = 9; // 订单关闭
  61. const TYPE_CANCEL = 20; //订单取消(已支付+未支付)
  62. /**
  63. * 格式化时间
  64. * @param $value
  65. * @return false|string
  66. */
  67. public function getCreatetimeAttr($value)
  68. {
  69. return date('Y-m-d H:i:s', $value);
  70. }
  71. /**
  72. * 格式化时间 paidtime
  73. * @return false|int|string
  74. */
  75. public function getPaidtimeAttr($value, $data)
  76. {
  77. return $data['have_paid'] > 0 ? date('Y-m-d H:i:s', $data['have_paid']) : 0;
  78. }
  79. /**
  80. * 格式化时间 deliveredtime
  81. * @return false|int|string
  82. */
  83. public function getDeliveredtimeAttr($value, $data)
  84. {
  85. return $data['have_delivered'] > 0 ? date('Y-m-d H:i:s', $data['have_delivered']) : 0;
  86. }
  87. /**
  88. * 格式化时间 receivedtime
  89. * @return false|int|string
  90. */
  91. public function getReceivedtimeAttr($value, $data)
  92. {
  93. return $data['have_received'] > 0 ? date('Y-m-d H:i:s', $data['have_received']) : 0;
  94. }
  95. /**
  96. * 格式化时间 commentedtime
  97. * @return false|int|string
  98. */
  99. public function getCommentedtimeAttr($value, $data)
  100. {
  101. return $data['have_commented'] > 0 ? date('Y-m-d H:i:s', $data['have_commented']) : 0;
  102. }
  103. /**
  104. * 支付类型
  105. */
  106. public function getPayTypeTextAttr($value, $data)
  107. {
  108. switch ($data['pay_type']) {
  109. case self::PAY_ONLINE:
  110. return __('Online');
  111. break;
  112. case self::PAY_OFFLINE:
  113. return __('Offline');
  114. break;
  115. case self::PAY_WXPAY:
  116. return __('wxPay');
  117. break;
  118. case self::PAY_ALIPAY:
  119. return __('aliPay');
  120. break;
  121. }
  122. }
  123. /**
  124. * 加密订单id
  125. * @param $value
  126. * @param $data
  127. * @return string
  128. */
  129. public function getOrderIdAttr($value, $data)
  130. {
  131. return Hashids::encodeHex($data['id']);
  132. }
  133. /**
  134. * 0=全部,1=待付款,2=待发货,3=待收货,4=待评价,5=售后
  135. * 0=全部,1=待付款,3=待核销,4=已完成,20=已取消
  136. * 获取当前的订单状态
  137. */
  138. public function getStateAttr($value, $data)
  139. {
  140. switch (true) {
  141. case $data['have_paid'] == self::PAID_NO && $data['status'] == self::STATUS_NORMAL:
  142. $state = self::TYPE_PAY;
  143. break;
  144. /*case $data['have_delivered'] == self::DELIVERED_NO && $data['status'] == self::STATUS_NORMAL:
  145. $state = self::TYPE_DELIVES;
  146. break;*/
  147. case $data['have_paid'] != self::PAID_NO && $data['have_received'] == self::RECEIVED_NO && $data['status'] == self::STATUS_NORMAL:
  148. $state = self::TYPE_RECEIVE;
  149. break;
  150. case $data['have_paid'] != self::PAID_NO && $data['have_received'] != self::RECEIVED_NO && $data['status'] == self::STATUS_NORMAL:
  151. $state = self::TYPE_COMMENT;
  152. break;
  153. /* case $data['status'] == self::STATUS_REFUND && $data['refund_status'] == self::REFUND_STATUS_AGREE: // TODO 申请退款并且已通过同意,则订单为关闭状态
  154. case $data['status'] == self::STATUS_CANCEL:
  155. $state = self::TYPE_OFF;
  156. break;
  157. case $data['status'] == self::STATUS_REFUND && $data['refund_status'] == self::REFUND_STATUS_REFUSE:
  158. $state = self::TYPE_REFUSE;
  159. break;
  160. case $data['status'] == self::STATUS_REFUND:
  161. $state = self::TYPE_REFUND;
  162. break;*/
  163. case $data['status'] == self::STATUS_CANCEL:
  164. $state = self::TYPE_CANCEL;
  165. break;
  166. default:
  167. $state = self::TYPE_ALL;
  168. break;
  169. }
  170. return $state;
  171. }
  172. //获取当前的订单状态,中文
  173. public function getStatetextAttr($state,$refund_status){
  174. $data = [
  175. 1 => '待付款',
  176. 3 => '待核销',
  177. 4 => '已完成',
  178. 20 => '已取消',
  179. ];
  180. if($state == 20 && $refund_status == 3){
  181. return '已退订';
  182. }
  183. return isset($data[$state]) ? $data[$state] : $state;
  184. }
  185. /**
  186. * 退款状态
  187. */
  188. public function getRefundStatusTextAttr($value, $data)
  189. {
  190. $name = '';
  191. if ($data['status'] == self::STATUS_REFUND) {
  192. switch ($data['refund_status']) {
  193. case self::REFUND_STATUS_APPLY:
  194. $name = '申请中';
  195. break;
  196. case self::REFUND_STATUS_DELIVERY:
  197. $name = '通过申请/请发货';
  198. break;
  199. case self::REFUND_STATUS_AGREE:
  200. $name = '退款成功';
  201. break;
  202. case self::REFUND_STATUS_REFUSE:
  203. $name = '退款失败';
  204. break;
  205. }
  206. }
  207. return $name;
  208. }
  209. /**
  210. * 创建订单
  211. * @param $userId
  212. * @param $data
  213. * @return int
  214. * @throws \Exception
  215. */
  216. public function createOrder($userId, $data, $intro_uid)
  217. {
  218. $data['userId'] = $userId;
  219. Hook::listen('create_order_before', $params, $data);
  220. list($products, $delivery, $coupon, $baseProductInfos, $address, $orderPrice, $specs, $numbers) = $params;
  221. // 获取雪花算法分布式id,方便以后扩展
  222. $snowflake = new Snowflake();
  223. $id = $snowflake->id();
  224. // 优惠费用
  225. $discountPrice = isset($coupon['value']) ? $coupon['value'] : 0;
  226. // 订单费用
  227. //$orderPrice;
  228. // 运费
  229. // $deliveryPrice = Delivery::algorithm($delivery, array_sum($numbers));
  230. $deliveryPrice = '0';
  231. // 总费用
  232. $totalPrice = bcadd(bcsub($orderPrice, $discountPrice, 2), $deliveryPrice, 2);
  233. $out_trade_no = date('Ymd',time()).uniqid().$userId;
  234. $db_pay_type = [
  235. 'wallet' => 2,
  236. 'wechat' => 3,
  237. 'alipay' => 4,
  238. ];
  239. (new self)->save([
  240. 'id' => $id,
  241. 'user_id' => $userId,
  242. 'out_trade_no' => $out_trade_no,
  243. 'order_price' => $orderPrice,
  244. 'discount_price' => $discountPrice,
  245. 'delivery_price' => $deliveryPrice,
  246. 'total_price' => $totalPrice,
  247. 'pay_type' => $db_pay_type[$data['pay_type']],
  248. 'ip' => $_SERVER['REMOTE_ADDR'] ?? '',
  249. 'remark' => $data['remark'] ?? '',
  250. 'status' => self::STATUS_NORMAL,
  251. 'booktime' => $data['booktime'] ?? '',
  252. 'book_realname' => $data['book_realname'] ?? '',
  253. 'book_mobile' => $data['book_mobile'] ?? '',
  254. 'intro_uid' => $intro_uid,
  255. ]);
  256. (new OrderExtend)->save([
  257. 'user_id' => $userId,
  258. 'order_id' => $id,
  259. 'coupon_id' => $coupon ? $coupon['id'] : 0,
  260. 'coupon_user_id' => $coupon ? $coupon['cu_id'] : 0,
  261. 'coupon_json' => json_encode($coupon),
  262. 'delivery_id' => $delivery ? $delivery['id'] : 0,
  263. 'delivery_json' => json_encode($delivery),
  264. 'address_id' => $address ? $address['id'] : 0,
  265. 'address_json' => json_encode($address),
  266. ]);
  267. $orderProduct = $specNumber = [];
  268. foreach($products as $key => $product) {
  269. $orderProduct[] = [
  270. 'user_id' => $userId,
  271. 'order_id' => $id,
  272. 'product_id' => $product['id'],
  273. 'title' => $product['title'],
  274. 'image' => $product['image'],
  275. 'number' => $numbers[$key],
  276. 'spec' => $specs[$key] ?? '',
  277. 'price' => $baseProductInfos[$key]['sales_price'],
  278. //'product_json' => json_encode($product), // Todo 耗内存,损速度 (考虑去掉)
  279. 'createtime' => time(),
  280. 'updatetime' => time(),
  281. 'flash_id' => $data['flash_id'] ?? 0, // 秒杀id
  282. ];
  283. if (!empty($specs[$key])) {
  284. $specNumber[$specs[$key]] = $numbers[$key];
  285. } else {
  286. $specNumber[$key] = $numbers[$key];
  287. }
  288. }
  289. (new OrderProduct)->insertAll($orderProduct);
  290. $data['specNumber'] = $specNumber;
  291. $data['coupon'] = $coupon;//消耗掉优惠券
  292. Hook::listen('create_order_after', $products, $data);
  293. return [
  294. 'order_id' => Hashids::encodeHex($id),
  295. 'out_trade_no' => $out_trade_no
  296. ];
  297. }
  298. /**
  299. * 获取我的订单
  300. * @param int $userId 用户id
  301. * @param int $state 0=全部,1=待付款,3=待核销,4=已完成,20=已取消
  302. */
  303. public function getOrdersByType($userId, $state = 0, $page = 1, $pageSize = 10)
  304. {
  305. $condition['user_id'] = ['=', $userId];
  306. switch ($state) {
  307. case self::TYPE_PAY: //1=待付款
  308. $condition['have_paid'] = ['=', self::PAID_NO];
  309. $condition['status'] = ['=', self::STATUS_NORMAL];
  310. $orderBy = 'createtime';
  311. break;
  312. /*case self::TYPE_DELIVES:
  313. $condition['have_paid'] = ['>', self::PAID_NO];
  314. $condition['have_delivered'] = ['=', self::DELIVERED_NO];
  315. $condition['status'] = ['=', self::STATUS_NORMAL];
  316. $orderBy = 'have_paid';
  317. break;*/
  318. case self::TYPE_RECEIVE: //3=待核销
  319. $condition['have_paid'] = ['>', self::PAID_NO];
  320. $condition['have_delivered'] = ['>', self::DELIVERED_NO];
  321. $condition['have_received'] = ['=', self::RECEIVED_NO];
  322. $condition['status'] = ['=', self::STATUS_NORMAL];
  323. $orderBy = 'have_delivered';
  324. break;
  325. case self::TYPE_COMMENT: //4=已完成
  326. $condition['have_paid'] = ['>', self::PAID_NO];
  327. $condition['have_delivered'] = ['>', self::DELIVERED_NO];
  328. $condition['have_received'] = ['>', self::RECEIVED_NO];
  329. // $condition['have_commented'] = ['=', self::COMMENTED_NO]; //到底要不要注释?
  330. $condition['status'] = ['=', self::STATUS_NORMAL];
  331. $orderBy = 'have_received';
  332. break;
  333. /*case self::TYPE_REFUND:
  334. $condition['have_paid'] = ['>', self::PAID_NO];
  335. $condition['status'] = ['=', self::STATUS_REFUND];
  336. $condition['refund_status'] = ['<>', self::REFUND_STATUS_AGREE];
  337. $orderBy = 'createtime';
  338. break;*/
  339. case self::TYPE_CANCEL: //20=已取消
  340. // $condition['have_paid'] = ['>', self::PAID_NO];
  341. $condition['status'] = ['=', self::STATUS_CANCEL];
  342. $orderBy = 'createtime';
  343. break;
  344. default: //全部
  345. $orderBy = 'createtime';
  346. break;
  347. }
  348. $result = $this
  349. ->with([
  350. 'products' => function($query) {
  351. $query->field('id,title,image,number,price,spec,order_id,product_id');
  352. },
  353. /* 'extend' => function($query) {
  354. $query->field('order_id,express_number,express_company');
  355. },
  356. 'evaluate' => function($query) {
  357. $query->field('id,order_id,product_id');
  358. },
  359. 'refundProducts' => function($query) {
  360. $query->field('id,order_id,order_product_id');
  361. }*/
  362. ])
  363. ->where($condition)
  364. ->order([$orderBy => 'desc'])
  365. ->limit(($page - 1) * $pageSize, $pageSize)
  366. ->select();
  367. foreach ($result as &$item) {
  368. $item->append(['order_id','state', 'refund_status_text']);
  369. $item['state_text'] = $this->getStatetextAttr($item['state'],$item['refund_status']);//状态中文
  370. $item = $item->toArray();
  371. unset($item['pay_out_trade_no']);
  372. /*$evaluate = array_column($item['evaluate'], 'product_id');
  373. $refundProducts = array_column($item['refund_products'], 'order_product_id');
  374. unset($item['evaluate']);
  375. unset($item['refund_products']);*/
  376. foreach ($item['products'] as &$product) {
  377. $product['image'] = Config::getImagesFullUrl($product['image']);
  378. // 是否已评论
  379. /*if (in_array($product['id'], $evaluate)) {
  380. $product['evaluate'] = true;
  381. } else {
  382. $product['evaluate'] = false;
  383. }*/
  384. // 是否退货
  385. /*if ($item['refund_status'] == self::REFUND_STATUS_AGREE && in_array($product['order_product_id'], $refundProducts)) {
  386. $product['refund'] = true;
  387. } else {
  388. $product['refund'] = false;
  389. }*/
  390. }
  391. }
  392. return $result;
  393. }
  394. /**
  395. * 关联订单的商品
  396. */
  397. public function products()
  398. {
  399. return $this->hasMany('orderProduct', 'order_id', 'id');
  400. }
  401. /**
  402. * 关联扩展订单信息
  403. * @return \think\model\relation\HasOne
  404. */
  405. public function extend()
  406. {
  407. return $this->hasOne('orderExtend', 'order_id', 'id');
  408. }
  409. /**
  410. * 关联评价
  411. * @return \think\model\relation\HasOne
  412. */
  413. public function evaluate()
  414. {
  415. return $this->hasMany('evaluate', 'order_id', 'id');
  416. }
  417. /**
  418. * 关联退货信息
  419. * @return \think\model\relation\HasMany
  420. */
  421. public function refund()
  422. {
  423. return $this->hasOne('orderRefund', 'order_id', 'id');
  424. }
  425. /**
  426. * 关联退货的商品
  427. * @return \think\model\relation\HasMany
  428. */
  429. public function refundProducts()
  430. {
  431. return $this->hasMany('orderRefundProduct', 'order_id', 'id');
  432. }
  433. }