StoreOrder.php 61 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405
  1. <?php
  2. /**
  3. *
  4. * @author: xaboy<365615158@qq.com>
  5. * @day: 2017/11/11
  6. */
  7. namespace app\admin\model\order;
  8. use crmeb\basic\BaseModel;
  9. use crmeb\traits\ModelTrait;
  10. use think\db\Query;
  11. use think\facade\Db;
  12. use think\facade\Route as Url;
  13. use app\models\store\StoreCart;
  14. use app\admin\model\wechat\WechatUser;
  15. use app\admin\model\store\StoreProduct;
  16. use app\models\routine\RoutineTemplate;
  17. use app\admin\model\user\{User, UserBill};
  18. use app\admin\model\ump\{StoreCouponUser, StorePink};
  19. use crmeb\services\{PHPExcelService, WechatTemplateService};
  20. /**
  21. * 订单管理Model
  22. * Class StoreOrder
  23. * @package app\admin\model\store
  24. */
  25. class StoreOrder extends BaseModel
  26. {
  27. /**
  28. * 数据表主键
  29. * @var string
  30. */
  31. protected $pk = 'id';
  32. /**
  33. * 模型名称
  34. * @var string
  35. */
  36. protected $name = 'store_order';
  37. use ModelTrait;
  38. public static function orderCount()
  39. {
  40. $data['ys'] = self::statusByWhere(9, new self())->where(['is_system_del' => 0])->count();
  41. $data['wz'] = self::statusByWhere(0, new self())->where(['is_system_del' => 0])->count();
  42. $data['wf'] = self::statusByWhere(1, new self())->where(['is_system_del' => 0, 'shipping_type' => 1])->whereNotIn(
  43. 'order_id', function ($query) {
  44. $query->name('store_pink')->where('status', '<>', 2)->field('order_id')->select();
  45. }
  46. )->count();
  47. // $data['wf1'] = self::statusByWhere(1, new self())->where(['is_system_del' => 0, 'shipping_type' => 1, 'pink_id' => 0, 'is_auto_pink' => 0])->count();
  48. // $data['wf2'] = self::statusByWhere(1, new self())->where(['is_system_del' => 0, 'shipping_type' => 1])->where('pink_id', '>', 0)->whereIn('order_id', function ($query) {
  49. // $query->name('store_pink')->where('status', 2)->field('order_id')->select();
  50. // })->count();
  51. // $data['wf'] = $data['wf1'] + $data['wf2'];
  52. $data['ds'] = self::statusByWhere(2, new self())->where(['is_system_del' => 0, 'shipping_type' => 1])->count();
  53. $data['dp'] = self::statusByWhere(3, new self())->where(['is_system_del' => 0])->count();
  54. $data['jy'] = self::statusByWhere(4, new self())->where(['is_system_del' => 0])->count();
  55. $data['tk'] = self::statusByWhere(-1, new self())->where(['is_system_del' => 0])->count();
  56. $data['yt'] = self::statusByWhere(-2, new self())->where(['is_system_del' => 0])->count();
  57. $data['del'] = self::statusByWhere(-4, new self())->where(['is_system_del' => 0])->count();
  58. $data['write_off'] = self::statusByWhere(5, new self())->where(['is_system_del' => 0])->count();
  59. $data['general'] = self::where(['pink_id' => 0, 'combination_id' => 0, 'seckill_id' => 0, 'bargain_id' => 0, 'activity_id' => 0, 'live_id' => 0, 'bargain_id' => 0, 'is_system_del' => 0])->count();
  60. $data['pink'] = self::where('pink_id|combination_id', '>', 0)->where('is_system_del', 0)->count();
  61. $data['seckill'] = self::where('seckill_id', '>', 0)->where('is_system_del', 0)->count();
  62. $data['bargain'] = self::where('bargain_id', '>', 0)->where('is_system_del', 0)->count();
  63. $data['activity'] = self::where('activity_id', '>', 0)->where('is_system_del', 0)->count();
  64. $data['live'] = self::where('live_id', '>', 0)->where('is_system_del', 0)->count();
  65. return $data;
  66. }
  67. public static function OrderList($where)
  68. {
  69. $model = self::getOrderWhere($where, self::alias('a')
  70. ->join('user r', 'r.uid=a.uid', 'LEFT'), 'a.', 'r')
  71. ->field('a.*,r.nickname,r.phone,r.spread_uid');
  72. if ($where['order'] != '') {
  73. $model = $model->order(self::setOrder($where['order']));
  74. } else {
  75. $model = $model->order('a.id desc');
  76. }
  77. // if (isset($where['status']) && $where['status'] == 1) {
  78. // $model = $model->join('store_pink p', "a.order_id=p.order_id and p.status=2");
  79. // }
  80. if (isset($where['status']) && $where['status'] == 1) {
  81. $model = $model->whereNotIn('order_id', function ($query) {
  82. $query->name('store_pink')->field('order_id')->where('status', '<>', 2)->select();
  83. });
  84. }
  85. if (isset($where['excel']) && $where['excel'] == 1) {
  86. $data = ($data = $model->select()) && count($data) ? $data->toArray() : [];
  87. } else {
  88. $data = ($data = $model->page((int)$where['page'], (int)$where['limit'])->select()) && count($data) ? $data->toArray() : [];
  89. }
  90. // if (isset($where['status']) && $where['status'] == 1) {
  91. // $order_ids = StorePink::where('status', '<>', 2)->column('order_id');
  92. // foreach ($data as $k => $v) {
  93. // if ($v['pink_id'] && in_array($v['order_id'], $order_ids)) {
  94. // unset($data[$k]);
  95. // }
  96. // }
  97. //
  98. //// foreach ($data as $k => $v) {
  99. //// if ($v['is_auto_pink'] && !$v['is_ok']) {
  100. //// unset($data[$k]);
  101. //// }
  102. //// }
  103. // }
  104. // $data = array_values($data);
  105. foreach ($data as &$item) {
  106. $_info = StoreOrderCartInfo::where('oid', $item['id'])->field('cart_info')->select();
  107. $_info = count($_info) ? $_info->toArray() : [];
  108. foreach ($_info as $k => $v) {
  109. $cart_info = json_decode($v['cart_info'], true);
  110. if (!isset($cart_info['productInfo'])) $cart_info['productInfo'] = [];
  111. $_info[$k]['cart_info'] = $cart_info;
  112. unset($cart_info);
  113. }
  114. $item['_info'] = $_info;
  115. $item['spread_nickname'] = User::where('uid', $item['spread_uid'])->value('nickname');
  116. $item['add_time'] = $item['add_time'] ? date('Y-m-d H:i:s', $item['add_time']) : '';
  117. $item['back_integral'] = $item['back_integral'] ?: 0;
  118. $pinkStatus = null;
  119. if ($item['pink_id'] || $item['combination_id']) {
  120. if (!$item['is_auto_pink']) { //不是自动拼团
  121. $pinkStatus = StorePink::where('order_id_key', $item['id'])->value('status');
  122. switch ($pinkStatus) {
  123. case 1:
  124. $item['pink_name'] = '[拼团订单]正在进行中';
  125. $item['color'] = '#f00';
  126. break;
  127. case 2:
  128. $item['pink_name'] = '[拼团订单]已完成';
  129. $item['color'] = '#00f';
  130. break;
  131. case 3:
  132. $item['pink_name'] = '[拼团订单]未完成';
  133. $item['color'] = '#f0f';
  134. break;
  135. default:
  136. $item['pink_name'] = '[拼团订单]历史订单';
  137. $item['color'] = '#457856';
  138. break;
  139. }
  140. } else { //自动拼团
  141. if ($item['is_ok'] == 0 && $item['refund_status'] == 0) {
  142. $item['pink_name'] = '[拼团订单]正在进行中';
  143. $item['color'] = '#f08';
  144. } else if ($item['is_ok'] == 1 && $item['refund_status'] == 0) {
  145. $item['pink_name'] = '[拼团订单]已完成';
  146. $item['color'] = '#50f';
  147. } else {
  148. $item['pink_name'] = '[拼团订单]未完成';
  149. $item['color'] = '#32f';
  150. }
  151. }
  152. } elseif ($item['seckill_id']) {
  153. $item['pink_name'] = '[秒杀订单]';
  154. $item['color'] = '#32c5e9';
  155. } elseif ($item['bargain_id']) {
  156. $item['pink_name'] = '[砍价订单]';
  157. $item['color'] = '#12c5e9';
  158. } elseif ($item['activity_id']) {
  159. $item['pink_name'] = '[活动订单]';
  160. $item['color'] = '#ffaabb';
  161. } else if ($item['live_id']) {
  162. $item['pink_name'] = '[直播订单]';
  163. $item['color'] = '#ffcc22';
  164. } else {
  165. if ($item['shipping_type'] == 1) {
  166. $item['pink_name'] = '[普通订单]';
  167. $item['color'] = '#895612';
  168. } else if ($item['shipping_type'] == 2) {
  169. $item['pink_name'] = '[核销订单]';
  170. $item['color'] = '#8956E8';
  171. }
  172. }
  173. if ($item['paid'] == 1) {
  174. switch ($item['pay_type']) {
  175. case 'weixin':
  176. $item['pay_type_name'] = '微信支付';
  177. break;
  178. case 'yue':
  179. $item['pay_type_name'] = '余额支付';
  180. break;
  181. case 'offline':
  182. $item['pay_type_name'] = '线下支付';
  183. break;
  184. default:
  185. $item['pay_type_name'] = '其他支付';
  186. break;
  187. }
  188. } else {
  189. switch ($item['pay_type']) {
  190. default:
  191. $item['pay_type_name'] = '未支付';
  192. break;
  193. case 'offline':
  194. $item['pay_type_name'] = '线下支付';
  195. $item['pay_type_info'] = 1;
  196. break;
  197. }
  198. }
  199. if ($item['paid'] == 0 && $item['status'] == 0) {
  200. $item['status_name'] = '未支付';
  201. } else if ($item['paid'] == 1 && $item['status'] == 0 && $item['shipping_type'] == 1 && $item['refund_status'] == 0) {
  202. $item['status_name'] = '未发货';
  203. } else if ($item['paid'] == 1 && $item['status'] == 0 && $item['shipping_type'] == 2 && $item['refund_status'] == 0) {
  204. $item['status_name'] = '未核销';
  205. } else if ($item['paid'] == 1 && $item['status'] == 1 && $item['shipping_type'] == 1 && $item['refund_status'] == 0) {
  206. $item['status_name'] = '待收货';
  207. } else if ($item['paid'] == 1 && $item['status'] == 1 && $item['shipping_type'] == 2 && $item['refund_status'] == 0) {
  208. $item['status_name'] = '未核销';
  209. } else if ($item['paid'] == 1 && $item['status'] == 2 && $item['refund_status'] == 0) {
  210. $item['status_name'] = '待评价';
  211. } else if ($item['paid'] == 1 && $item['status'] == 3 && $item['refund_status'] == 0) {
  212. $item['status_name'] = '已完成';
  213. } else if ($item['paid'] == 1 && $item['refund_status'] == 1) {
  214. $refundReasonTime = date('Y-m-d H:i', $item['refund_reason_time']);
  215. $refundReasonWapImg = json_decode($item['refund_reason_wap_img'], true);
  216. $refundReasonWapImg = $refundReasonWapImg ? $refundReasonWapImg : [];
  217. $img = '';
  218. if (count($refundReasonWapImg)) {
  219. foreach ($refundReasonWapImg as $itemImg) {
  220. if (strlen(trim($itemImg)))
  221. $img .= '<img style="height:50px;" src="' . $itemImg . '" />';
  222. }
  223. }
  224. if (!strlen(trim($img))) $img = '无';
  225. if (isset($where['excel']) && $where['excel'] == 1) {
  226. $refundImageStr = implode(',', $refundReasonWapImg);
  227. $item['status_name'] = <<<TEXT
  228. 退款原因:{$item['refund_reason_wap']}
  229. 备注说明:{$item['refund_reason_wap_explain']}
  230. 退款时间:{$refundReasonTime}
  231. 凭证连接:{$refundImageStr}
  232. TEXT;
  233. unset($refundImageStr);
  234. } else {
  235. $item['status_name'] = <<<HTML
  236. <b style="color:#f124c7">申请退款</b><br/>
  237. <span>退款原因:{$item['refund_reason_wap']}</span><br/>
  238. <span>备注说明:{$item['refund_reason_wap_explain']}</span><br/>
  239. <span>退款时间:{$refundReasonTime}</span><br/>
  240. <span>退款凭证:{$img}</span>
  241. HTML;
  242. }
  243. } else if ($item['paid'] == 1 && $item['refund_status'] == 2) {
  244. $item['status_name'] = '已退款';
  245. }
  246. if ($item['paid'] == 1 && $item['status'] == 0 && $item['shipping_type'] == 2) {
  247. $item['_status'] = 0;
  248. } else if ($item['paid'] == 0 && $item['status'] == 0 && $item['refund_status'] == 0) {
  249. $item['_status'] = 1;
  250. } else if ($item['paid'] == 1 && $item['status'] == 0 && $item['refund_status'] == 0) {
  251. $item['_status'] = 2;
  252. } else if ($item['paid'] == 1 && $item['refund_status'] == 1) {
  253. $item['_status'] = 3;
  254. } else if ($item['paid'] == 1 && $item['status'] == 1 && $item['refund_status'] == 0) {
  255. $item['_status'] = 4;
  256. } else if ($item['paid'] == 1 && $item['status'] == 2 && $item['refund_status'] == 0) {
  257. $item['_status'] = 5;
  258. } else if ($item['paid'] == 1 && $item['status'] == 3 && $item['refund_status'] == 0) {
  259. $item['_status'] = 6;
  260. } else if ($item['paid'] == 1 && $item['refund_status'] == 2) {
  261. $item['_status'] = 7;
  262. }
  263. }
  264. if (isset($where['excel']) && $where['excel'] == 1) {
  265. self::SaveExcel($data);
  266. }
  267. if (isset($where['status']) && $where['status'] == 1) {
  268. // $count = self::getOrderWhere($where, self::alias('a')->join('user r', 'r.uid=a.uid', 'LEFT'), 'a.', 'r')->join('store_pink p', "a.order_id=p.order_id and p.status=2")->count();
  269. $model = self::getOrderWhere($where, self::alias('a')
  270. ->join('user r', 'r.uid=a.uid', 'LEFT'), 'a.', 'r')
  271. ->field('a.*,r.nickname,r.phone,r.spread_uid');
  272. $model = $model->whereNotIn('order_id', function ($query) {
  273. $query->name('store_pink')->field('order_id')->where('status', '<>', 2)->select();
  274. });
  275. $data2 = ($data2 = $model->select()) && count($data2) ? $data2->toArray() : [];
  276. // $order_ids = StorePink::where('status', '<>', 2)->column('order_id');
  277. // foreach ($data2 as $k => $v) {
  278. // if ($v['pink_id'] && in_array($v['order_id'], $order_ids)) {
  279. // unset($data2[$k]);
  280. // }
  281. // }
  282. //// foreach ($data2 as $k => $v) {
  283. //// if ($v['is_auto_pink'] && !$v['is_ok']) {
  284. //// unset($data2[$k]);
  285. //// }
  286. //// }
  287. // $data2 = array_values($data2);
  288. $count = sizeof($data2);
  289. } else {
  290. $count = self::getOrderWhere($where, self::alias('a')->join('user r', 'r.uid=a.uid', 'LEFT'), 'a.', 'r')->count();
  291. }
  292. // $count = self::getOrderWhere($where, self::alias('a')->join('user r', 'r.uid=a.uid', 'LEFT'), 'a.', 'r')->count();
  293. return compact('count', 'data');
  294. }
  295. /*
  296. * 保存并下载excel
  297. * $list array
  298. * return
  299. */
  300. public static function SaveExcel($list)
  301. {
  302. $export = [];
  303. foreach ($list as $index => $item) {
  304. $_info = StoreOrderCartInfo::where('oid', $item['id'])->column('cart_info');
  305. $goodsName = [];
  306. foreach ($_info as $k => $v) {
  307. $v = json_decode($v, true);
  308. $suk = '';
  309. if (isset($v['productInfo']['attrInfo'])) {
  310. if (isset($v['productInfo']['attrInfo']['suk'])) {
  311. $suk = '(' . $v['productInfo']['attrInfo']['suk'] . ')';
  312. }
  313. }
  314. $goodsName[] = implode(
  315. [$v['productInfo']['store_name'],
  316. $suk,
  317. "[{$v['cart_num']} * {$v['truePrice']}]"
  318. ], ' ');
  319. }
  320. $item['cartInfo'] = $_info;
  321. $sex = WechatUser::where('uid', $item['uid'])->value('sex');
  322. if ($sex == 1) $sex_name = '男';
  323. else if ($sex == 2) $sex_name = '女';
  324. else $sex_name = '未知';
  325. $cart = Db::name('store_order_cart_info')->where('oid', $item['id'])->value('cart_info');
  326. $cart = json_decode($cart, true);
  327. $res = Db::name('store_product')->where('id', $cart['product_id'])->find();
  328. $export[] = [
  329. $item['id'],
  330. $res['supplier'],
  331. $item['order_id'],
  332. $sex_name,
  333. $item['phone'],
  334. $item['real_name'],
  335. $item['user_phone'],
  336. $item['user_address'],
  337. $goodsName,
  338. $item['total_price'],
  339. $item['pay_price'],
  340. $item['cost'],
  341. $item['pay_postage'],
  342. $item['coupon_price'],
  343. $item['pay_type_name'],
  344. $item['pay_time'] > 0 ? date('Y/m-d H:i', $item['pay_time']) : '暂无',
  345. $item['status_name'],
  346. $item['add_time'],
  347. $item['mark']
  348. ];
  349. }
  350. PHPExcelService::setExcelHeader(['ID', '供货商', '订单号', '性别', '电话', '收货人姓名', '收货人电话', '收货地址', '商品信息',
  351. '总价格', '实际支付', '成本价', '邮费', '优惠金额', '支付状态', '支付时间', '订单状态', '下单时间', '用户备注'])
  352. ->setExcelTile('订单导出' . date('YmdHis', time()), '订单信息' . time(), ' 生成时间:' . date('Y-m-d H:i:s', time()))
  353. ->setExcelContent($export)
  354. ->ExcelSave();
  355. }
  356. /**
  357. * @param $where
  358. * @return array
  359. */
  360. public static function systemPage($where, $userid = false)
  361. {
  362. $model = self::getOrderWhere($where, self::alias('a')
  363. ->join('user r', 'r.uid=a.uid', 'LEFT'), 'a.', 'r')
  364. ->field('a.*,r.nickname');
  365. if ($where['order']) {
  366. $model = $model->order('a.' . $where['order']);
  367. } else {
  368. $model = $model->order('a.id desc');
  369. }
  370. if ($where['export'] == 1) {
  371. $list = $model->select()->toArray();
  372. $export = [];
  373. foreach ($list as $index => $item) {
  374. if ($item['pay_type'] == 'weixin') {
  375. $payType = '微信支付';
  376. } elseif ($item['pay_type'] == 'yue') {
  377. $payType = '余额支付';
  378. } elseif ($item['pay_type'] == 'offline') {
  379. $payType = '线下支付';
  380. } else {
  381. $payType = '其他支付';
  382. }
  383. $_info = StoreOrderCartInfo::where('oid', $item['id'])->column('cart_info', 'oid');
  384. $goodsName = [];
  385. foreach ($_info as $k => $v) {
  386. $v = json_decode($v, true);
  387. $goodsName[] = implode(
  388. [$v['productInfo']['store_name'],
  389. isset($v['productInfo']['attrInfo']) ? '(' . $v['productInfo']['attrInfo']['suk'] . ')' : '',
  390. "[{$v['cart_num']} * {$v['truePrice']}]"
  391. ], ' ');
  392. }
  393. $item['cartInfo'] = $_info;
  394. $export[] = [
  395. $item['order_id'], $payType,
  396. $item['total_num'], $item['total_price'], $item['total_postage'], $item['pay_price'], $item['refund_price'],
  397. $item['mark'], $item['remark'],
  398. [$item['real_name'], $item['user_phone'], $item['user_address']],
  399. $goodsName,
  400. [$item['paid'] == 1 ? '已支付' : '未支付', '支付时间: ' . ($item['pay_time'] > 0 ? date('Y/md H:i', $item['pay_time']) : '暂无')]
  401. ];
  402. $list[$index] = $item;
  403. }
  404. PHPExcelService::setExcelHeader(['订单号', '支付方式', '商品总数', '商品总价', '邮费', '支付金额', '退款金额', '用户备注', '管理员备注', '收货人信息', '商品信息', '支付状态'])
  405. ->setExcelTile('订单导出', '订单信息' . time(), ' 生成时间:' . date('Y-m-d H:i:s', time()))
  406. ->setExcelContent($export)
  407. ->ExcelSave();
  408. }
  409. return self::page($model, function ($item) {
  410. $_info = StoreOrderCartInfo::where('oid', $item['id'])->field('cart_info')->select();
  411. foreach ($_info as $k => $v) {
  412. $_info[$k]['cart_info'] = json_decode($v['cart_info'], true);
  413. }
  414. $item['_info'] = $_info;
  415. if ($item['pink_id'] && $item['combination_id']) {
  416. $pinkStatus = StorePink::where('order_id_key', $item['id'])->value('status');
  417. switch ($pinkStatus) {
  418. case 1:
  419. $item['pink_name'] = '[拼团订单]正在进行中';
  420. $item['color'] = '#f00';
  421. break;
  422. case 2:
  423. $item['pink_name'] = '[拼团订单]已完成';
  424. $item['color'] = '#00f';
  425. break;
  426. case 3:
  427. $item['pink_name'] = '[拼团订单]未完成';
  428. $item['color'] = '#f0f';
  429. break;
  430. default:
  431. $item['pink_name'] = '[拼团订单]历史订单';
  432. $item['color'] = '#457856';
  433. break;
  434. }
  435. } else {
  436. if ($item['seckill_id']) {
  437. $item['pink_name'] = '[秒杀订单]';
  438. $item['color'] = '#32c5e9';
  439. } elseif ($item['bargain_id']) {
  440. $item['pink_name'] = '[砍价订单]';
  441. $item['color'] = '#12c5e9';
  442. } else {
  443. $item['pink_name'] = '[普通订单]';
  444. $item['color'] = '#895612';
  445. }
  446. }
  447. }, $where);
  448. }
  449. public static function statusByWhere($status, $model = null, $alert = '')
  450. {
  451. if ($model == null) $model = new self;
  452. if ('' === $status)
  453. return $model;
  454. else if ($status == 8)
  455. return $model;
  456. else if ($status == 0)//未支付
  457. return $model->where($alert . 'paid', 0)->where($alert . 'status', 0)->where($alert . 'refund_status', 0)->where($alert . 'is_del', 0);
  458. else if ($status == 1)//已支付 未发货
  459. return $model->where($alert . 'paid', 1)->where($alert . 'status', 0)->where($alert . 'shipping_type', 1)->where($alert . 'refund_status', 0)->where($alert . 'is_del', 0);
  460. else if ($status == 2)//已支付 待收货
  461. return $model->where($alert . 'paid', 1)->where($alert . 'status', 1)->where($alert . 'shipping_type', 1)->where($alert . 'refund_status', 0)->where($alert . 'is_del', 0);
  462. else if ($status == 5)//已支付 待核销
  463. return $model->where($alert . 'paid', 1)->where($alert . 'status', 0)->where($alert . 'shipping_type', 2)->where($alert . 'refund_status', 0)->where($alert . 'is_del', 0);
  464. else if ($status == 3)// 已支付 已收货 待评价
  465. return $model->where($alert . 'paid', 1)->where($alert . 'status', 2)->where($alert . 'refund_status', 0)->where($alert . 'is_del', 0);
  466. else if ($status == 4)// 交易完成
  467. return $model->where($alert . 'paid', 1)->where($alert . 'status', 3)->where($alert . 'refund_status', 0)->where($alert . 'is_del', 0);
  468. else if ($status == -1)//退款中
  469. return $model->where($alert . 'paid', 1)->where($alert . 'refund_status', 1)->where($alert . 'is_del', 0);
  470. else if ($status == -2)//已退款
  471. return $model->where($alert . 'paid', 1)->where($alert . 'refund_status', 2)->where($alert . 'is_del', 0);
  472. else if ($status == -3)//退款
  473. return $model->where($alert . 'paid', 1)->where($alert . 'refund_status', 'in', '1,2')->where($alert . 'is_del', 0);
  474. else if ($status == -4)//已删除
  475. return $model->where($alert . 'is_del', 1);
  476. else if ($status == 9)//已卖出
  477. return $model->where($alert . 'paid', 1)->where($alert . 'refund_status', 0)->where($alert . 'is_del', 0);
  478. else
  479. return $model;
  480. }
  481. public static function timeQuantumWhere($startTime = null, $endTime = null, $model = null)
  482. {
  483. if ($model === null) $model = new self;
  484. if ($startTime != null && $endTime != null)
  485. $model = $model->where('add_time', '>', strtotime($startTime))->where('add_time', '<', strtotime($endTime));
  486. return $model;
  487. }
  488. public static function changeOrderId($orderId)
  489. {
  490. $ymd = substr($orderId, 2, 8);
  491. $key = substr($orderId, 16);
  492. return 'wx' . $ymd . date('His') . $key;
  493. }
  494. /**
  495. * 线下付款
  496. * @param $id
  497. * @return $this
  498. */
  499. public static function updateOffline($id)
  500. {
  501. $count = self::where('id', $id)->count();
  502. if (!$count) return self::setErrorInfo('订单不存在');
  503. $count = self::where('id', $id)->where('paid', 0)->count();
  504. if (!$count) return self::setErrorInfo('订单已支付');
  505. $res = self::where('id', $id)->update(['paid' => 1, 'pay_time' => time()]);
  506. return $res;
  507. }
  508. /**
  509. * TODO 公众号退款发送模板消息
  510. * @param $oid
  511. * $oid 订单id key
  512. */
  513. public static function refundTemplate($data, $oid)
  514. {
  515. $order = self::where('id', $oid)->find();
  516. $urlWeChat = config('wx.wx_notify_jump_url') . $order['order_id'];
  517. WechatTemplateService::sendTemplate(WechatUser::where('uid', $order['uid'])->value('openid'), WechatTemplateService::ORDER_REFUND_STATUS, [
  518. 'first' => '亲,您购买的商品已退款,本次退款' . $data['refund_price'] . '金额',
  519. 'keyword1' => $order['order_id'],
  520. 'keyword2' => $order['pay_price'],
  521. 'keyword3' => date('Y-m-d H:i:s', $order['add_time']),
  522. 'remark' => '点击查看订单详情'
  523. ], $urlWeChat);
  524. }
  525. /**
  526. * TODO 小程序余额退款模板消息
  527. * @param $oid
  528. * @return bool|mixed
  529. * @throws \think\db\exception\DataNotFoundException
  530. * @throws \think\db\exception\ModelNotFoundException
  531. * @throws \think\exception\DbException
  532. */
  533. public static function refundRoutineTemplate($oid)
  534. {
  535. $order = self::where('id', $oid)->find();
  536. return RoutineTemplate::sendOrderRefundSuccess($order);
  537. }
  538. /**
  539. * 处理where条件
  540. * @param $where
  541. * @param $model
  542. * @return mixed
  543. */
  544. public static function getOrderWhere($where, $model, $aler = '', $join = '')
  545. {
  546. // $model = $model->where('combination_id',0);
  547. $model = $model->where('is_system_del', 0);
  548. if (isset($where['status']) && $where['status'] !== '') {
  549. $model = self::statusByWhere($where['status'], $model, $aler);
  550. }
  551. if (isset($where['is_del']) && $where['is_del'] != '' && $where['is_del'] != -1) $model = $model->where($aler . 'is_del', $where['is_del']);
  552. if (isset($where['combination_id'])) {
  553. if ($where['combination_id'] == '普通订单') {
  554. $model = $model->where($aler . 'combination_id', 0)->where($aler . 'seckill_id', 0)->where($aler . 'bargain_id', 0);
  555. }
  556. if ($where['combination_id'] == '拼团订单') {
  557. $model = $model->where($aler . 'combination_id', ">", 0)->where($aler . 'pink_id', ">", 0);
  558. }
  559. if ($where['combination_id'] == '秒杀订单') {
  560. $model = $model->where($aler . 'seckill_id', ">", 0);
  561. }
  562. if ($where['combination_id'] == '砍价订单') {
  563. $model = $model->where($aler . 'bargain_id', ">", 0);
  564. }
  565. }
  566. if (isset($where['pay_type'])) {
  567. switch ($where['pay_type']) {
  568. case 1:
  569. $model = $model->where($aler . 'pay_type', 'weixin');
  570. break;
  571. case 2:
  572. $model = $model->where($aler . 'pay_type', 'yue');
  573. break;
  574. case 3:
  575. $model = $model->where($aler . 'pay_type', 'offline');
  576. break;
  577. }
  578. }
  579. if (isset($where['type'])) {
  580. switch ($where['type']) {
  581. case 1:
  582. $model = $model->where($aler . 'combination_id', 0)->where($aler . 'seckill_id', 0)->where($aler . 'bargain_id', 0)->where($aler . 'activity_id', 0)->where($aler . 'live_id', 0);
  583. break;
  584. case 2:
  585. // $model = $model->where($aler.'combination_id',">",0)->where($aler.'pink_id',">",0);
  586. $model = $model->where($aler . 'combination_id', ">", 0);
  587. break;
  588. case 3:
  589. $model = $model->where($aler . 'seckill_id', ">", 0);
  590. break;
  591. case 4:
  592. $model = $model->where($aler . 'bargain_id', ">", 0);
  593. break;
  594. case 5:
  595. $model = $model->where($aler . 'activity_id', ">", 0);
  596. break;
  597. case 6:
  598. $model = $model->where($aler . 'live_id', ">", 0);
  599. break;
  600. }
  601. }
  602. if (isset($where['real_name']) && $where['real_name'] != '') {
  603. $model = $model->where($aler . 'order_id|' . $aler . 'real_name|' . $aler . 'user_phone' . ($join ? '|' . $join . '.nickname|' . $join . '.uid|' . $join . '.phone' : ''), 'LIKE', "%$where[real_name]%");
  604. }
  605. if (isset($where['data']) && $where['data'] !== '') {
  606. $model = self::getModelTime($where, $model, $aler . 'add_time');
  607. }
  608. return $model;
  609. }
  610. public static function getBadge($where)
  611. {
  612. $price = self::getOrderPrice($where);
  613. return [
  614. [
  615. 'name' => '订单数量',
  616. 'field' => '件',
  617. 'count' => $price['count_sum'],
  618. 'background_color' => 'layui-bg-blue',
  619. 'col' => 2
  620. ],
  621. [
  622. 'name' => '售出商品',
  623. 'field' => '件',
  624. 'count' => $price['total_num'],
  625. 'background_color' => 'layui-bg-blue',
  626. 'col' => 2
  627. ],
  628. [
  629. 'name' => '订单金额',
  630. 'field' => '元',
  631. 'count' => $price['pay_price'],
  632. 'background_color' => 'layui-bg-blue',
  633. 'col' => 2
  634. ],
  635. [
  636. 'name' => '退款金额',
  637. 'field' => '元',
  638. 'count' => $price['refund_price'],
  639. 'background_color' => 'layui-bg-blue',
  640. 'col' => 2
  641. ],
  642. [
  643. 'name' => '微信支付金额',
  644. 'field' => '元',
  645. 'count' => $price['pay_price_wx'],
  646. 'background_color' => 'layui-bg-blue',
  647. 'col' => 2
  648. ],
  649. [
  650. 'name' => '余额支付金额',
  651. 'field' => '元',
  652. 'count' => $price['pay_price_yue'],
  653. 'background_color' => 'layui-bg-blue',
  654. 'col' => 2
  655. ],
  656. [
  657. 'name' => '运费金额',
  658. 'field' => '元',
  659. 'count' => $price['pay_postage'],
  660. 'background_color' => 'layui-bg-blue',
  661. 'col' => 2
  662. ],
  663. [
  664. 'name' => '分佣金额',
  665. 'field' => '元',
  666. 'count' => $price['brokerage'],
  667. 'background_color' => 'layui-bg-blue',
  668. 'col' => 2
  669. ],
  670. [
  671. 'name' => '线下支付金额',
  672. 'field' => '元',
  673. 'count' => $price['pay_price_offline'],
  674. 'background_color' => 'layui-bg-blue',
  675. 'col' => 2
  676. ],
  677. [
  678. 'name' => '积分抵扣',
  679. 'field' => '分',
  680. 'count' => $price['use_integral'] . '(抵扣金额:¥' . $price['deduction_price'] . ')',
  681. 'background_color' => 'layui-bg-blue',
  682. 'col' => 2
  683. ],
  684. [
  685. 'name' => '退回积分',
  686. 'field' => '元',
  687. 'count' => $price['back_integral'],
  688. 'background_color' => 'layui-bg-blue',
  689. 'col' => 2
  690. ]
  691. ];
  692. }
  693. /**
  694. * 处理订单金额
  695. * @param $where
  696. * @return array
  697. */
  698. public static function getOrderPrice($where)
  699. {
  700. $where['is_del'] = 0;//删除订单不统计
  701. $model = new self;
  702. $price = [];
  703. $price['pay_price'] = 0;//支付金额
  704. $price['refund_price'] = 0;//退款金额
  705. $price['pay_price_wx'] = 0;//微信支付金额
  706. $price['pay_price_yue'] = 0;//余额支付金额
  707. $price['pay_price_offline'] = 0;//线下支付金额
  708. $price['pay_price_other'] = 0;//其他支付金额
  709. $price['use_integral'] = 0;//用户使用积分
  710. $price['back_integral'] = 0;//退积分总数
  711. $price['deduction_price'] = 0;//抵扣金额
  712. $price['total_num'] = 0; //商品总数
  713. $price['count_sum'] = 0; //商品总数
  714. $price['brokerage'] = 0;
  715. $price['pay_postage'] = 0;
  716. $whereData = ['is_del' => 0];
  717. if ($where['status'] == '') {
  718. $whereData['paid'] = 1;
  719. $whereData['refund_status'] = 0;
  720. }
  721. $ids = self::getOrderWhere($where, $model)->where($whereData)->column('id');
  722. if (count($ids)) {
  723. // $price['brokerage'] = UserBill::where(['category' => 'now_money', 'type' => 'brokerage'])->where('link_id', 'in', $ids)->sum('number');
  724. $price['brokerage'] = UserBill::where(['category' => 'now_money', 'type' => 'brokerage', 'pm' => 1])->sum('number');
  725. }
  726. $price['refund_price'] = self::getOrderWhere($where, $model)->where(['is_del' => 0, 'paid' => 1, 'refund_status' => 2])->sum('refund_price');
  727. $sumNumber = self::getOrderWhere($where, $model)->where('is_del', 0)->field([
  728. 'sum(total_num) as sum_total_num',
  729. 'count(id) as count_sum',
  730. 'sum(pay_price) as sum_pay_price',
  731. 'sum(pay_postage) as sum_pay_postage',
  732. 'sum(use_integral) as sum_use_integral',
  733. 'sum(back_integral) as sum_back_integral',
  734. 'sum(deduction_price) as sum_deduction_price'
  735. ])->find();
  736. if ($sumNumber) {
  737. $price['count_sum'] = $sumNumber['count_sum'];
  738. $price['total_num'] = $sumNumber['sum_total_num'];
  739. $price['pay_price'] = $sumNumber['sum_pay_price'];
  740. $price['pay_postage'] = $sumNumber['sum_pay_postage'];
  741. $price['use_integral'] = $sumNumber['sum_use_integral'];
  742. $price['back_integral'] = $sumNumber['sum_back_integral'];
  743. $price['deduction_price'] = $sumNumber['sum_deduction_price'];
  744. }
  745. $list = self::getOrderWhere($where, $model)->where($whereData)->group('pay_type')->column('sum(pay_price) as sum_pay_price,pay_type', 'id');
  746. foreach ($list as $v) {
  747. if ($v['pay_type'] == 'weixin') {
  748. $price['pay_price_wx'] = $v['sum_pay_price'];
  749. } elseif ($v['pay_type'] == 'yue') {
  750. $price['pay_price_yue'] = $v['sum_pay_price'];
  751. } elseif ($v['pay_type'] == 'offline') {
  752. $price['pay_price_offline'] = $v['sum_pay_price'];
  753. } else {
  754. $price['pay_price_other'] = $v['sum_pay_price'];
  755. }
  756. }
  757. return $price;
  758. }
  759. public static function systemPagePink($where)
  760. {
  761. $model = new self;
  762. $model = self::getOrderWherePink($where, $model);
  763. $model = $model->order('id desc');
  764. if ($where['export'] == 1) {
  765. $list = $model->select()->toArray();
  766. $export = [];
  767. foreach ($list as $index => $item) {
  768. if ($item['pay_type'] == 'weixin') {
  769. $payType = '微信支付';
  770. } elseif ($item['pay_type'] == 'yue') {
  771. $payType = '余额支付';
  772. } elseif ($item['pay_type'] == 'offline') {
  773. $payType = '线下支付';
  774. } else {
  775. $payType = '其他支付';
  776. }
  777. $_info = StoreOrderCartInfo::where('oid', $item['id'])->column('cart_info', 'oid');
  778. $goodsName = [];
  779. foreach ($_info as $k => $v) {
  780. $v = json_decode($v, true);
  781. $goodsName[] = implode(
  782. [$v['productInfo']['store_name'],
  783. isset($v['productInfo']['attrInfo']) ? '(' . $v['productInfo']['attrInfo']['suk'] . ')' : '',
  784. "[{$v['cart_num']} * {$v['truePrice']}]"
  785. ], ' ');
  786. }
  787. $item['cartInfo'] = $_info;
  788. $export[] = [
  789. $item['order_id'], $payType,
  790. $item['total_num'], $item['total_price'], $item['total_postage'], $item['pay_price'], $item['refund_price'],
  791. $item['mark'], $item['remark'],
  792. [$item['real_name'], $item['user_phone'], $item['user_address']],
  793. $goodsName,
  794. [$item['paid'] == 1 ? '已支付' : '未支付', '支付时间: ' . ($item['pay_time'] > 0 ? date('Y/md H:i', $item['pay_time']) : '暂无')]
  795. ];
  796. $list[$index] = $item;
  797. }
  798. ExportService::exportCsv($export, '订单导出' . time(), ['订单号', '支付方式', '商品总数', '商品总价', '邮费', '支付金额', '退款金额', '用户备注', '管理员备注', '收货人信息', '商品信息', '支付状态']);
  799. }
  800. return self::page($model, function ($item) {
  801. $item['nickname'] = WechatUser::where('uid', $item['uid'])->value('nickname');
  802. $_info = StoreOrderCartInfo::where('oid', $item['id'])->field('cart_info')->select();
  803. foreach ($_info as $k => $v) {
  804. $_info[$k]['cart_info'] = json_decode($v['cart_info'], true);
  805. }
  806. $item['_info'] = $_info;
  807. }, $where);
  808. }
  809. /**
  810. * 处理where条件
  811. * @param $where
  812. * @param $model
  813. * @return mixed
  814. */
  815. public static function getOrderWherePink($where, $model)
  816. {
  817. $model = $model->where('combination_id', '>', 0);
  818. if ($where['status'] != '') $model = $model::statusByWhere($where['status']);
  819. // if($where['is_del'] != '' && $where['is_del'] != -1) $model = $model->where('is_del',$where['is_del']);
  820. if ($where['real_name'] != '') {
  821. $model = $model->where('order_id|real_name|user_phone', 'LIKE', "%$where[real_name]%");
  822. }
  823. if ($where['data'] !== '') {
  824. $model = self::getModelTime($where, $model, 'add_time');
  825. }
  826. return $model;
  827. }
  828. /**
  829. * 处理订单金额
  830. * @param $where
  831. * @return array
  832. */
  833. public static function getOrderPricePink($where)
  834. {
  835. $model = new self;
  836. $price = [];
  837. $price['pay_price'] = 0;//支付金额
  838. $price['refund_price'] = 0;//退款金额
  839. $price['pay_price_wx'] = 0;//微信支付金额
  840. $price['pay_price_yue'] = 0;//余额支付金额
  841. $price['pay_price_offline'] = 0;//线下支付金额
  842. $price['pay_price_other'] = 0;//其他支付金额
  843. $price['use_integral'] = 0;//用户使用积分
  844. $price['back_integral'] = 0;//退积分总数
  845. $price['deduction_price'] = 0;//抵扣金额
  846. $price['total_num'] = 0; //商品总数
  847. $model = self::getOrderWherePink($where, $model);
  848. $list = $model->select()->toArray();
  849. foreach ($list as $v) {
  850. $price['total_num'] = bcadd($price['total_num'], $v['total_num'], 0);
  851. $price['pay_price'] = bcadd($price['pay_price'], $v['pay_price'], 2);
  852. $price['refund_price'] = bcadd($price['refund_price'], $v['refund_price'], 2);
  853. $price['use_integral'] = bcadd($price['use_integral'], $v['use_integral'], 2);
  854. $price['back_integral'] = bcadd($price['back_integral'], $v['back_integral'], 2);
  855. $price['deduction_price'] = bcadd($price['deduction_price'], $v['deduction_price'], 2);
  856. if ($v['pay_type'] == 'weixin') {
  857. $price['pay_price_wx'] = bcadd($price['pay_price_wx'], $v['pay_price'], 2);
  858. } elseif ($v['pay_type'] == 'yue') {
  859. $price['pay_price_yue'] = bcadd($price['pay_price_yue'], $v['pay_price'], 2);
  860. } elseif ($v['pay_type'] == 'offline') {
  861. $price['pay_price_offline'] = bcadd($price['pay_price_offline'], $v['pay_price'], 2);
  862. } else {
  863. $price['pay_price_other'] = bcadd($price['pay_price_other'], $v['pay_price'], 2);
  864. }
  865. }
  866. return $price;
  867. }
  868. /**
  869. * 获取昨天的订单 首页在使用
  870. * @param int $preDay
  871. * @param int $day
  872. * @return $this|StoreOrder
  873. */
  874. public static function isMainYesterdayCount($preDay = 0, $day = 0)
  875. {
  876. $model = new self();
  877. $model = $model->where('add_time', '>', $preDay);
  878. $model = $model->where('add_time', '<', $day);
  879. return $model;
  880. }
  881. /**
  882. * 获取用户购买次数
  883. * @param int $uid
  884. * @return int|string
  885. */
  886. public static function getUserCountPay($uid = 0)
  887. {
  888. if (!$uid) return 0;
  889. return self::where('uid', $uid)->where('paid', 1)->count();
  890. }
  891. /**
  892. * 获取单个用户购买列表
  893. * @param array $where
  894. * @return array
  895. */
  896. public static function getOneorderList($where)
  897. {
  898. return self::where('uid', $where['uid'])
  899. ->order('add_time desc')
  900. ->page((int)$where['page'], (int)$where['limit'])
  901. ->field(['order_id,real_name,total_num,total_price,pay_price,FROM_UNIXTIME(pay_time,"%Y-%m-%d") as pay_time,paid,pay_type,pink_id,seckill_id,bargain_id'
  902. ])->select()
  903. ->toArray();
  904. }
  905. /**
  906. * 设置订单统计图搜索
  907. * @param array $where 条件
  908. * @param null $status
  909. * @param null $time
  910. * @return array
  911. */
  912. public static function setEchatWhere($where, $status = null, $time = null)
  913. {
  914. $model = self::statusByWhere($where['status'])->where('is_system_del', 0);
  915. if ($status !== null) $where['type'] = $status;
  916. if ($time === true) $where['data'] = '';
  917. switch ($where['type']) {
  918. case 1:
  919. //普通商品
  920. $model = $model->where('combination_id', 0)->where('seckill_id', 0)->where('bargain_id', 0);
  921. break;
  922. case 2:
  923. //拼团商品
  924. $model = $model->where('combination_id', ">", 0)->where('pink_id', ">", 0);
  925. break;
  926. case 3:
  927. //秒杀商品
  928. $model = $model->where('seckill_id', ">", 0);
  929. break;
  930. case 4:
  931. //砍价商品
  932. $model = $model->where('bargain_id', '>', 0);
  933. break;
  934. }
  935. return self::getModelTime($where, $model);
  936. }
  937. /*
  938. * 获取订单数据统计图
  939. * $where array
  940. * $limit int
  941. * return array
  942. */
  943. public static function getEchartsOrder($where, $limit = 20)
  944. {
  945. $orderlist = self::setEchatWhere($where)->field(
  946. 'FROM_UNIXTIME(add_time,"%Y-%m-%d") as _add_time,sum(total_num) total_num,count(*) count,sum(total_price) total_price,sum(refund_price) refund_price,group_concat(cart_id SEPARATOR "|") cart_ids'
  947. )->group('_add_time')->order('_add_time asc')->select();
  948. count($orderlist) && $orderlist = $orderlist->toArray();
  949. $legend = ['商品数量', '订单数量', '订单金额', '退款金额'];
  950. $seriesdata = [
  951. [
  952. 'name' => $legend[0],
  953. 'type' => 'line',
  954. 'data' => [],
  955. ],
  956. [
  957. 'name' => $legend[1],
  958. 'type' => 'line',
  959. 'data' => []
  960. ],
  961. [
  962. 'name' => $legend[2],
  963. 'type' => 'line',
  964. 'data' => []
  965. ],
  966. [
  967. 'name' => $legend[3],
  968. 'type' => 'line',
  969. 'data' => []
  970. ]
  971. ];
  972. $xdata = [];
  973. $zoom = '';
  974. foreach ($orderlist as $item) {
  975. $xdata[] = $item['_add_time'];
  976. $seriesdata[0]['data'][] = $item['total_num'];
  977. $seriesdata[1]['data'][] = $item['count'];
  978. $seriesdata[2]['data'][] = $item['total_price'];
  979. $seriesdata[3]['data'][] = $item['refund_price'];
  980. }
  981. count($xdata) > $limit && $zoom = $xdata[$limit - 5];
  982. $badge = self::getOrderBadge($where);
  983. $bingpaytype = self::setEchatWhere($where)->group('pay_type')->field('count(*) as count,pay_type')->select();
  984. count($bingpaytype) && $bingpaytype = $bingpaytype->toArray();
  985. $bing_xdata = ['微信支付', '余额支付', '其他支付'];
  986. $color = ['#ffcccc', '#99cc00', '#fd99cc', '#669966'];
  987. $bing_data = [];
  988. foreach ($bingpaytype as $key => $item) {
  989. if ($item['pay_type'] == 'weixin') {
  990. $value['name'] = $bing_xdata[0];
  991. } else if ($item['pay_type'] == 'yue') {
  992. $value['name'] = $bing_xdata[1];
  993. } else {
  994. $value['name'] = $bing_xdata[2];
  995. }
  996. $value['value'] = $item['count'];
  997. $value['itemStyle']['color'] = isset($color[$key]) ? $color[$key] : $color[0];
  998. $bing_data[] = $value;
  999. }
  1000. return compact('zoom', 'xdata', 'seriesdata', 'badge', 'legend', 'bing_data', 'bing_xdata');
  1001. }
  1002. public static function getOrderBadge($where)
  1003. {
  1004. return [
  1005. [
  1006. 'name' => '拼团订单数量',
  1007. 'field' => '个',
  1008. 'count' => self::setEchatWhere($where, 2)->count(),
  1009. 'content' => '拼团总订单数量',
  1010. 'background_color' => 'layui-bg-cyan',
  1011. 'sum' => self::setEchatWhere($where, 2, true)->count(),
  1012. 'class' => 'fa fa-line-chart',
  1013. 'col' => 2
  1014. ],
  1015. [
  1016. 'name' => '砍价订单数量',
  1017. 'field' => '个',
  1018. 'count' => self::setEchatWhere($where, 4)->count(),
  1019. 'content' => '砍价总订单数量',
  1020. 'background_color' => 'layui-bg-cyan',
  1021. 'sum' => self::setEchatWhere($where, 4, true)->count(),
  1022. 'class' => 'fa fa-line-chart',
  1023. 'col' => 2
  1024. ],
  1025. [
  1026. 'name' => '秒杀订单数量',
  1027. 'field' => '个',
  1028. 'count' => self::setEchatWhere($where, 3)->count(),
  1029. 'content' => '秒杀总订单数量',
  1030. 'background_color' => 'layui-bg-cyan',
  1031. 'sum' => self::setEchatWhere($where, 3, true)->count(),
  1032. 'class' => 'fa fa-line-chart',
  1033. 'col' => 2
  1034. ],
  1035. [
  1036. 'name' => '普通订单数量',
  1037. 'field' => '个',
  1038. 'count' => self::setEchatWhere($where, 1)->count(),
  1039. 'content' => '普通总订单数量',
  1040. 'background_color' => 'layui-bg-cyan',
  1041. 'sum' => self::setEchatWhere($where, 1, true)->count(),
  1042. 'class' => 'fa fa-line-chart',
  1043. 'col' => 2,
  1044. ],
  1045. [
  1046. 'name' => '使用优惠卷金额',
  1047. 'field' => '元',
  1048. 'count' => self::setEchatWhere($where)->sum('coupon_price'),
  1049. 'content' => '普通总订单数量',
  1050. 'background_color' => 'layui-bg-cyan',
  1051. 'sum' => self::setEchatWhere($where, null, true)->sum('coupon_price'),
  1052. 'class' => 'fa fa-line-chart',
  1053. 'col' => 2
  1054. ],
  1055. [
  1056. 'name' => '积分消耗数',
  1057. 'field' => '个',
  1058. 'count' => self::setEchatWhere($where)->sum('use_integral'),
  1059. 'content' => '积分消耗总数',
  1060. 'background_color' => 'layui-bg-cyan',
  1061. 'sum' => self::setEchatWhere($where, null, true)->sum('use_integral'),
  1062. 'class' => 'fa fa-line-chart',
  1063. 'col' => 2
  1064. ],
  1065. [
  1066. 'name' => '积分抵扣金额',
  1067. 'field' => '个',
  1068. 'count' => self::setEchatWhere($where)->sum('deduction_price'),
  1069. 'content' => '积分抵扣总金额',
  1070. 'background_color' => 'layui-bg-cyan',
  1071. 'sum' => self::setEchatWhere($where, null, true)->sum('deduction_price'),
  1072. 'class' => 'fa fa-money',
  1073. 'col' => 2
  1074. ],
  1075. [
  1076. 'name' => '在线支付金额',
  1077. 'field' => '元',
  1078. 'count' => self::setEchatWhere($where)->where(['paid' => 1, 'refund_status' => 0])->where('pay_type', 'weixin')->sum('pay_price'),
  1079. 'content' => '在线支付总金额',
  1080. 'background_color' => 'layui-bg-cyan',
  1081. 'sum' => self::setEchatWhere($where, null, true)->where(['paid' => 1, 'refund_status' => 0])->where('pay_type', 'weixin')->sum('pay_price'),
  1082. 'class' => 'fa fa-weixin',
  1083. 'col' => 2
  1084. ],
  1085. [
  1086. 'name' => '余额支付金额',
  1087. 'field' => '元',
  1088. 'count' => self::setEchatWhere($where)->where('pay_type', 'yue')->where(['paid' => 1, 'refund_status' => 0])->sum('pay_price'),
  1089. 'content' => '余额支付总金额',
  1090. 'background_color' => 'layui-bg-cyan',
  1091. 'sum' => self::setEchatWhere($where, null, true)->where(['paid' => 1, 'refund_status' => 0])->where('pay_type', 'yue')->sum('pay_price'),
  1092. 'class' => 'fa fa-balance-scale',
  1093. 'col' => 2
  1094. ],
  1095. [
  1096. 'name' => '赚取积分',
  1097. 'field' => '分',
  1098. 'count' => self::setEchatWhere($where)->sum('gain_integral'),
  1099. 'content' => '赚取总积分',
  1100. 'background_color' => 'layui-bg-cyan',
  1101. 'sum' => self::setEchatWhere($where, null, true)->sum('gain_integral'),
  1102. 'class' => 'fa fa-gg-circle',
  1103. 'col' => 2
  1104. ],
  1105. [
  1106. 'name' => '交易额',
  1107. 'field' => '元',
  1108. 'count' => self::setEchatWhere($where)->where(['paid' => 1, 'refund_status' => 0])->sum('pay_price'),
  1109. 'content' => '总交易额',
  1110. 'background_color' => 'layui-bg-cyan',
  1111. 'sum' => self::setEchatWhere($where, null, true)->where(['paid' => 1, 'refund_status' => 0])->sum('pay_price'),
  1112. 'class' => 'fa fa-jpy',
  1113. 'col' => 2
  1114. ],
  1115. [
  1116. 'name' => '订单商品数量',
  1117. 'field' => '元',
  1118. 'count' => self::setEchatWhere($where)->sum('total_num'),
  1119. 'content' => '订单商品总数量',
  1120. 'background_color' => 'layui-bg-cyan',
  1121. 'sum' => self::setEchatWhere($where, null, true)->sum('total_num'),
  1122. 'class' => 'fa fa-cube',
  1123. 'col' => 2
  1124. ]
  1125. ];
  1126. }
  1127. /**
  1128. * 微信 订单发货
  1129. * @param $oid
  1130. * @param array $postageData
  1131. * @throws \think\db\exception\DataNotFoundException
  1132. * @throws \think\db\exception\ModelNotFoundException
  1133. * @throws \think\exception\DbException
  1134. */
  1135. public static function orderPostageAfter($oid, $postageData = [])
  1136. {
  1137. $order = self::where('id', $oid)->find();
  1138. $url = Url::buildUrl('/order/detail/' . $order['order_id'])->suffix('')->domain(true)->build();
  1139. $group = [
  1140. 'first' => '亲,您的订单已发货,请注意查收',
  1141. 'remark' => '点击查看订单详情'
  1142. ];
  1143. if ($postageData['delivery_type'] == 'send') {//送货
  1144. $goodsName = StoreOrderCartInfo::getProductNameList($order['id']);
  1145. if ($order['is_channel'] == 1) {
  1146. //小程序送货模版消息
  1147. RoutineTemplate::sendOrderPostage($order);
  1148. } else {//公众号
  1149. $openid = WechatUser::where('uid', $order['uid'])->value('openid');
  1150. $group = array_merge($group, [
  1151. 'keyword1' => $goodsName,
  1152. 'keyword2' => $order['pay_type'] == 'offline' ? '线下支付' : date('Y/m/d H:i', $order['pay_time']),
  1153. 'keyword3' => $order['user_address'],
  1154. 'keyword4' => $postageData['delivery_name'],
  1155. 'keyword5' => $postageData['delivery_id']
  1156. ]);
  1157. WechatTemplateService::sendTemplate($openid, WechatTemplateService::ORDER_DELIVER_SUCCESS, $group, $url);
  1158. }
  1159. } else if ($postageData['delivery_type'] == 'express') {//发货
  1160. if ($order['is_channel'] == 1) {
  1161. //小程序发货模版消息
  1162. RoutineTemplate::sendOrderPostage($order, 1);
  1163. } else {//公众号
  1164. $openid = WechatUser::where('uid', $order['uid'])->value('openid');
  1165. $group = array_merge($group, [
  1166. 'keyword1' => $order['order_id'],
  1167. 'keyword2' => $postageData['delivery_name'],
  1168. 'keyword3' => $postageData['delivery_id']
  1169. ]);
  1170. WechatTemplateService::sendTemplate($openid, WechatTemplateService::ORDER_POSTAGE_SUCCESS, $group, $url);
  1171. }
  1172. }
  1173. }
  1174. /** 收货后发送模版消息
  1175. * @param $order
  1176. */
  1177. public static function orderTakeAfter($order)
  1178. {
  1179. $title = '';
  1180. $cartInfo = StoreOrderCartInfo::where('oid', $order['id'])->column('cart_info', 'oid');
  1181. if (count($cartInfo)) {
  1182. foreach ($cartInfo as $key => &$cart) {
  1183. $cart = json_decode($cart, true);
  1184. $title .= $cart['productInfo']['store_name'] . ',';
  1185. }
  1186. }
  1187. if (strlen(trim($title)))
  1188. $title = substr($title, 0, bcsub(strlen($title), 1, 0));
  1189. else {
  1190. $cartInfo = StoreCart::alias('a')->where('a.id', 'in', implode(',', json_decode($order['cart_id'], true)))->find();
  1191. $title = StoreProduct::where('id', $cartInfo['product_id'])->value('store_name');
  1192. }
  1193. if ($order['is_channel'] == 1) {//小程序
  1194. RoutineTemplate::sendOrderTakeOver($order, $title);
  1195. } else {
  1196. $openid = WechatUser::where('uid', $order['uid'])->value('openid');
  1197. WechatTemplateService::sendTemplate($openid, WechatTemplateService::ORDER_TAKE_SUCCESS, [
  1198. 'first' => '亲,您的订单已收货',
  1199. 'keyword1' => $order['order_id'],
  1200. 'keyword2' => '已收货',
  1201. 'keyword3' => date('Y-m-d H:i:s', time()),
  1202. 'keyword4' => $title,
  1203. 'remark' => '感谢您的光临!'
  1204. ]);
  1205. }
  1206. }
  1207. /**
  1208. * 不退款发送模板消息
  1209. * @param int $id 订单id
  1210. * @param array $data 退款详情
  1211. * */
  1212. public static function refundNoPrieTemplate($id, $data)
  1213. {
  1214. $order = self::get($id);
  1215. if ($order) return false;
  1216. //小程序模板消息
  1217. $cartInfo = StoreOrderCartInfo::where('oid', $order['id'])->column('product_id', 'oid') ?: [];
  1218. $title = '';
  1219. foreach ($cartInfo as $k => $productId) {
  1220. $store_name = StoreProduct::where('id', $productId)->value('store_name');
  1221. $title .= $store_name . ',';
  1222. }
  1223. if ($order->is_channel == 1) {
  1224. RoutineTemplate::sendOrderRefundFail($order, $title);
  1225. } else {
  1226. WechatTemplateService::sendTemplate(WechatUser::where('uid', $order->uid)->value('openid'), WechatTemplateService::ORDER_REFUND_STATUS, [
  1227. 'first' => '很抱歉您的订单退款失败,失败原因:' . $data,
  1228. 'keyword1' => $order->order_id,
  1229. 'keyword2' => $order->pay_price,
  1230. 'keyword3' => date('Y-m-d H:i:s', time()),
  1231. 'remark' => '给您带来的不便,请谅解!'
  1232. ], Url::buildUrl('/order/detail/' . $order['order_id'])->suffix('')->domain(true)->build());
  1233. }
  1234. }
  1235. /**
  1236. * 获取订单总数
  1237. * @param int $uid
  1238. * @return int|string
  1239. */
  1240. public static function getOrderCount($uid = 0)
  1241. {
  1242. if (!$uid) return 0;
  1243. return self::where('uid', $uid)->where('paid', 1)->where('refund_status', 0)->where('status', 2)->count();
  1244. }
  1245. /**
  1246. * 获取已支付的订单
  1247. * @param int $is_promoter
  1248. * @return int|string
  1249. */
  1250. public static function getOrderPayCount($is_promoter = 0)
  1251. {
  1252. return self::where('o.paid', 1)->alias('o')->join('User u', 'u.uid=o.uid')->where('u.is_promoter', $is_promoter)->count();
  1253. }
  1254. /**
  1255. * 获取最后一个月已支付的订单
  1256. * @param int $is_promoter
  1257. * @return int|string
  1258. */
  1259. public static function getOrderPayMonthCount($is_promoter = 0)
  1260. {
  1261. return self::where('o.paid', 1)->alias('o')->whereTime('o.pay_time', 'last month')->join('User u', 'u.uid=o.uid')->where('u.is_promoter', $is_promoter)->count();
  1262. }
  1263. /** 订单收货处理积分
  1264. * @param $order
  1265. * @return bool
  1266. */
  1267. public static function gainUserIntegral($order, bool $open = true)
  1268. {
  1269. if ($order['gain_integral'] > 0) {
  1270. $userInfo = User::get($order['uid']);
  1271. $open && BaseModel::beginTrans();
  1272. $integral = bcadd($userInfo['integral'], $order['gain_integral'], 2);
  1273. $res1 = false != User::where('uid', $userInfo['uid'])->update(['integral' => $integral]);
  1274. $res2 = false != UserBill::income('购买商品赠送积分', $order['uid'], 'integral', 'gain', $order['gain_integral'], $order['id'], bcadd($userInfo['integral'], $order['gain_integral'], 2), '购买商品赠送' . floatval($order['gain_integral']) . '积分');
  1275. $res = $res1 && $res2;
  1276. $open && BaseModel::checkTrans($res);
  1277. RoutineTemplate::sendUserIntegral($order['uid'], $order, $order['gain_integral'], $integral);
  1278. return $res;
  1279. }
  1280. return true;
  1281. }
  1282. public static function integralBack($id)
  1283. {
  1284. $order = self::get($id)->toArray();
  1285. if (!(float)bcsub($order['use_integral'], 0, 2) && !$order['back_integral']) return true;
  1286. if ($order['back_integral'] && !(int)$order['use_integral']) return true;
  1287. BaseModel::beginTrans();
  1288. $data['back_integral'] = bcsub($order['use_integral'], $order['use_integral'], 0);
  1289. if (!$data['back_integral']) return true;
  1290. $data['use_integral'] = 0;
  1291. $data['deduction_price'] = 0.00;
  1292. $data['pay_price'] = 0.00;
  1293. $data['coupon_id'] = 0.00;
  1294. $data['coupon_price'] = 0.00;
  1295. $res4 = true;
  1296. $integral = User::where('uid', $order['uid'])->value('integral');
  1297. $res1 = User::bcInc($order['uid'], 'integral', $data['back_integral'], 'uid');
  1298. $res2 = UserBill::income('商品退积分', $order['uid'], 'integral', 'pay_product_integral_back', $data['back_integral'], $order['id'], bcadd($integral, $data['back_integral'], 2), '订单退积分' . floatval($data['back_integral']) . '积分到用户积分');
  1299. $res3 = self::edit($data, $id);
  1300. if ($order['coupon_id']) $res4 = StoreCouponUser::recoverCoupon($order['coupon_id']);
  1301. StoreOrderStatus::setStatus($id, 'integral_back', '商品退积分:' . $data['back_integral']);
  1302. $res = $res1 && $res2 && $res3 && $res4;
  1303. BaseModel::checkTrans($res);
  1304. return $res;
  1305. }
  1306. /**
  1307. * 订单数量 支付方式
  1308. * @return array
  1309. */
  1310. public static function payTypeCount()
  1311. {
  1312. $where['status'] = 8;
  1313. $where['is_del'] = 0;
  1314. $where['real_name'] = '';
  1315. $where['data'] = '';
  1316. $where['type'] = '';
  1317. $where['order'] = '';
  1318. $where['pay_type'] = 1;
  1319. $weixin = self::getOrderWhere($where, new self)->count();
  1320. $where['pay_type'] = 2;
  1321. $yue = self::getOrderWhere($where, new self)->count();
  1322. $where['pay_type'] = 3;
  1323. $offline = self::getOrderWhere($where, new self)->count();
  1324. return compact('weixin', 'yue', 'offline');
  1325. }
  1326. /**
  1327. * 订单物流发货
  1328. * @param int $id
  1329. * @param string $delivery_name
  1330. * @param string $delivery_id
  1331. * @return bool
  1332. */
  1333. public static function orderPostageExpress($id = 0, $delivery_name = '', $delivery_id = '')
  1334. {
  1335. if (!$delivery_name) return false;
  1336. if (!$delivery_id) return false;
  1337. $data = [
  1338. 'delivery_name' => $delivery_name,
  1339. 'delivery_id' => $delivery_id,
  1340. 'delivery_type' => 'express',
  1341. 'status' => 1,
  1342. ];
  1343. $res = self::edit($data, $id);
  1344. event('StoreProductOrderDeliveryGoodsAfter', [$data, $id]);
  1345. event('ShortMssageSend', [self::where('id', $id)->value('order_id'), 'Deliver']);//短信发送
  1346. StoreOrderStatus::setStatus($id, 'delivery_goods', '已发货 快递公司:' . $data['delivery_name'] . ' 快递单号:' . $data['delivery_id']);
  1347. return $res ? true : false;
  1348. }
  1349. }