StoreOrder.php 57 KB

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