StoreOrderDao.php 54 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248
  1. <?php
  2. // +----------------------------------------------------------------------
  3. // | CRMEB [ CRMEB赋能开发者,助力企业发展 ]
  4. // +----------------------------------------------------------------------
  5. // | Copyright (c) 2016~2024 https://www.crmeb.com All rights reserved.
  6. // +----------------------------------------------------------------------
  7. // | Licensed CRMEB并不是自由软件,未经许可不能去掉CRMEB相关版权
  8. // +----------------------------------------------------------------------
  9. // | Author: CRMEB Team <admin@crmeb.com>
  10. // +----------------------------------------------------------------------
  11. namespace app\common\dao\store\order;
  12. use app\common\dao\BaseDao;
  13. use app\common\model\store\order\StoreOrder;
  14. use app\common\model\store\order\StoreOrderProduct;
  15. use app\common\model\store\order\StoreOrderStatus;
  16. use app\common\model\user\User;
  17. use app\common\repositories\store\order\StoreOrderStatusRepository;
  18. use app\common\repositories\store\product\ProductAssistSetRepository;
  19. use app\common\repositories\store\product\ProductGroupBuyingRepository;
  20. use think\db\BaseQuery;
  21. use think\db\exception\DataNotFoundException;
  22. use think\db\exception\DbException;
  23. use think\db\exception\ModelNotFoundException;
  24. use think\facade\Db;
  25. use think\Model;
  26. /**
  27. * Class StoreOrderDao
  28. * @package app\common\dao\store\order
  29. * @author xaboy
  30. * @day 2020/6/8
  31. */
  32. class StoreOrderDao extends BaseDao
  33. {
  34. //订单状态(0:待发货;1:待收货;2:待评价;3:已完成; 9: 拼团中 10: 待付尾款 11:尾款超时未付 -1:已退款)
  35. const ORDER_STATUS_BE_SHIPPED = 0;
  36. const ORDER_STATUS_BE_RECEIVE = 1;
  37. const ORDER_STATUS_REPLY = 2;
  38. const ORDER_STATUS_SUCCESS = 3;
  39. const ORDER_STATUS_SPELL = 9;
  40. const ORDER_STATUS_TAIL = 10;
  41. const ORDER_STATUS_TAIL_FAIL = 11;
  42. const ORDER_STATUS_REFUND = -1;
  43. /**
  44. * @return string
  45. * @author xaboy
  46. * @day 2020/6/8
  47. */
  48. protected function getModel(): string
  49. {
  50. return StoreOrder::class;
  51. }
  52. /**
  53. * 订单搜索
  54. * @param array $where
  55. * @param int $sysDel
  56. * @return BaseQuery
  57. * @author wuhaotian
  58. * @email 442384644@qq.com
  59. * @date 2024/7/16
  60. */
  61. public function search(array $where, $sysDel = 0)
  62. {
  63. $query = StoreOrder::hasWhere('merchant', function ($query) use ($where) {
  64. // 分组权限
  65. if (app('request')->hasMacro('regionAuthority') && $region = app('request')->regionAuthority()) {
  66. $query->whereIn('mer_id', $region);
  67. }
  68. if (isset($where['is_trader']) && $where['is_trader'] !== '') {
  69. $query->where('is_trader', $where['is_trader']);
  70. }
  71. $query->where('is_del', 0);
  72. });
  73. $query = $this->whereSearch($query, $where, $sysDel);
  74. return $query;
  75. }
  76. public function whereSearch($query, $where, $sysDel = 0)
  77. {
  78. $query->where('StoreOrder.activity_type', '<>', 20);
  79. $query->when(($sysDel !== null), function ($query) use ($sysDel) {
  80. $query->where('is_system_del', $sysDel);
  81. });
  82. $query->when(isset($where['order_type']) && $where['order_type'] >= 0 && $where['order_type'] !== '', function ($query) use ($where) {
  83. if ($where['order_type'] == 2) {
  84. $query->where('is_virtual', 1);
  85. } else if ($where['order_type'] == 3) { // 卡密商品
  86. $query->where('is_virtual', 2);
  87. } else if ($where['order_type'] == 4) { // 预约商品订单
  88. $query->where('is_virtual', 4);
  89. } else {
  90. $query->where('order_type', $where['order_type']);
  91. }
  92. });
  93. $query->when(isset($where['activity_type']) && $where['activity_type'] !== '', function ($query) use ($where) {
  94. $query->where('StoreOrder.activity_type', $where['activity_type']);
  95. })
  96. ->when(isset($where['status']) && $where['status'] !== '', function ($query) use ($where) {
  97. switch ($where['status']) {
  98. case 0 :
  99. $query->whereIn('StoreOrder.status', [0, 9]);
  100. break;
  101. case -2 :
  102. $query->where('paid', 1)->whereNotIn('StoreOrder.status', [10, 11]);
  103. break;
  104. case 10 :
  105. $query->where('paid', 1)->whereIn('StoreOrder.status', [10, 11]);
  106. break;
  107. default:
  108. $query->where('StoreOrder.status', $where['status']);
  109. break;
  110. }
  111. })
  112. ->when(isset($where['uid']) && $where['uid'] !== '', function ($query) use ($where) {
  113. $query->where('uid', $where['uid']);
  114. })
  115. ->when(isset($where['is_spread']) && $where['is_spread'] !== '', function ($query) use ($where) {
  116. if ($where['is_spread']) {
  117. $query->where(function ($query) {
  118. $query->where('StoreOrder.spread_uid', '>', 0)->whereOr('StoreOrder.top_uid', '>', 0);
  119. });
  120. }
  121. })
  122. ->when(isset($where['is_user']) && $where['is_user'] !== '', function ($query) use ($where) {
  123. $query->where(function ($query) {
  124. $query->where('order_type', 0)->whereOr(function ($query) {
  125. $query->where('order_type', 1)->where('main_id', 0);
  126. });
  127. });
  128. })
  129. //待核销订单
  130. ->when(isset($where['is_verify']) && $where['is_verify'], function ($query) use ($where) {
  131. $query->where('paid', 1);
  132. $query->where(function($query) use($where){
  133. $query->where(function ($query) {
  134. $query->where('StoreOrder.order_type', 1)->where('StoreOrder.status', 0);
  135. })->whereOr(function ($query) {
  136. $query->where('StoreOrder.order_type', 0)->where('StoreOrder.status', 20)->where('is_virtual', 4);
  137. })->whereOr(function ($query) {
  138. $query->where('StoreOrder.order_type', 1)->where('StoreOrder.status', 1)->where('enable_assigned', 1)->where('is_virtual', 4);
  139. });
  140. });
  141. })
  142. ->when(isset($where['pay_type']) && $where['pay_type'] !== '', function ($query) use ($where) {
  143. if (is_int($where['pay_type'])) {
  144. $query->where('StoreOrder.pay_type', $where['pay_type']);
  145. } else {
  146. $query->whereIn('StoreOrder.pay_type', $where['pay_type']);
  147. }
  148. })
  149. ->when(isset($where['order_ids']) && $where['order_ids'] !== '', function ($query) use ($where) {
  150. $query->whereIn('order_id', $where['order_ids']);
  151. })
  152. ->when(isset($where['order_id']) && $where['order_id'] !== '', function ($query) use ($where) {
  153. $query->where('StoreOrder.order_id', $where['order_id']);
  154. })
  155. ->when(isset($where['take_order']) && $where['take_order'] != '', function ($query) use ($where) {
  156. $query->whereNotNull('verify_time');
  157. })
  158. ->when(isset($where['mer_id']) && $where['mer_id'] !== '', function ($query) use ($where) {
  159. $query->where('StoreOrder.mer_id', $where['mer_id']);
  160. })
  161. ->when(isset($where['mer_ids']) && $where['mer_ids'] !== '', function ($query) use ($where) {
  162. $query->whereIn('StoreOrder.mer_id', $where['mer_ids']);
  163. })
  164. ->when(isset($where['date']) && $where['date'] !== '', function ($query) use ($where) {
  165. getModelTime($query, $where['date'], 'StoreOrder.create_time');
  166. })
  167. ->when(isset($where['verify_date']) && $where['verify_date'] !== '', function ($query) use ($where) {
  168. getModelTime($query, $where['verify_date'], 'verify_time');
  169. })
  170. ->when(isset($where['order_sn']) && $where['order_sn'] !== '', function ($query) use ($where) {
  171. $query->where('order_sn', 'like', '%' . $where['order_sn'] . '%');
  172. })
  173. ->when(isset($where['paid']) && $where['paid'] !== '', function ($query) use ($where) {
  174. $query->where('StoreOrder.paid', $where['paid']);
  175. })
  176. ->when(isset($where['is_del']) && $where['is_del'] !== '', function ($query) use ($where) {
  177. $query->where('StoreOrder.is_del', $where['is_del']);
  178. })
  179. ->when(isset($where['service_id']) && $where['service_id'] !== '', function ($query) use ($where) {
  180. $query->where('service_id', $where['service_id']);
  181. })
  182. ->when(isset($where['delivery_id']) && $where['delivery_id'] !== '', function ($query) use ($where) {
  183. $query->where('delivery_id', $where['delivery_id']);
  184. })
  185. ->when(isset($where['delivery_name']) && $where['delivery_name'] !== '', function ($query) use ($where) {
  186. $query->whereLike('StoreOrder.real_name', "%{$where['delivery_name']}%");
  187. })
  188. ->when(isset($where['delivery_phone']) && $where['delivery_phone'] !== '', function ($query) use ($where) {
  189. $query->whereLike('user_phone', "%{$where['delivery_phone']}%");
  190. })
  191. ->when(isset($where['username']) && $where['username'] !== '', function ($query) use ($where) {
  192. $query->join('User U', 'StoreOrder.uid = U.uid')
  193. ->where(function ($query) use ($where) {
  194. $query->where('nickname', 'like', "%{$where['username']}%")
  195. ->whereOr('phone', 'like', "%{$where['username']}%")
  196. ->whereOr('StoreOrder.user_phone', 'like', "%{$where['username']}%");
  197. });
  198. })
  199. ->when(isset($where['spread_name']) && $where['spread_name'] !== '', function ($query) use ($where) {
  200. $uid = User::where('nickname', 'like', "%{$where['spread_name']}%")->column('uid');
  201. $query->whereIn('StoreOrder.uid', $uid);
  202. })
  203. ->when(isset($where['phone']) && $where['phone'] !== '', function ($query) use ($where) {
  204. $uid = User::where('phone', 'like', "%{$where['phone']}%")->column('uid');
  205. $query->whereIn('StoreOrder.uid', $uid);
  206. })
  207. ->when(isset($where['nickname']) && $where['nickname'] !== '', function ($query) use ($where) {
  208. $uid = User::where('nickname', 'like', "%{$where['nickname']}%")->column('uid');
  209. $query->whereIn('StoreOrder.uid', $uid);
  210. })
  211. ->when(isset($where['real_name']) && $where['real_name'] !== '', function ($query) use ($where) {
  212. $uid = User::where('real_name', 'like', "%{$where['real_name']}%")->column('uid');
  213. $query->whereIn('StoreOrder.spread_uid', $uid);
  214. })
  215. ->when(isset($where['top_spread_name']) && $where['top_spread_name'] !== '', function ($query) use ($where) {
  216. $uid = User::where('nickname', 'like', "%{$where['top_spread_name']}%")->column('uid');
  217. $query->whereIn('StoreOrder.top_uid', $uid);
  218. })
  219. ->when(isset($where['enable_assigned']) && $where['enable_assigned'] !== '', function ($query) use ($where) {
  220. $query->where('enable_assigned', $where['enable_assigned']);
  221. })
  222. ->when(isset($where['reservation_date']) && $where['reservation_date'] !== '', function ($query) use ($where) {
  223. $query->join('StoreOrderProduct op', 'op.order_id = StoreOrder.order_id');
  224. if(strtotime($where['reservation_date']) !== false) {
  225. $query->where('op.reservation_date', $where['reservation_date']);
  226. } else {
  227. list($startTime, $endTime) = explode('-', $where['reservation_date']);
  228. $query->whereBetweenTime('op.reservation_date', date('Y-m-d',strtotime($startTime)), date('Y-m-d',strtotime($endTime)));
  229. }
  230. })
  231. ->when(isset($where['store_name']) && $where['store_name'] !== '', function ($query) use ($where) {
  232. $orderId = StoreOrderProduct::alias('op')
  233. ->join('storeProduct sp', 'op.product_id = sp.product_id')
  234. ->whereLike('store_name', "%{$where['store_name']}%")
  235. ->when((isset($where['sp.mer_id']) && $where['mer_id'] !== ''), function ($query) use ($where) {
  236. $query->where('mer_id', $where['mer_id']);
  237. })->column('op.order_id');
  238. $query->whereIn('StoreOrder.order_id', $orderId ?: '');
  239. })
  240. ->when(isset($where['search']) && $where['search'] !== '', function ($query) use ($where) {
  241. $orderId = StoreOrderProduct::alias('op')
  242. ->join('storeProduct sp', 'op.product_id = sp.product_id')
  243. ->whereLike('store_name', "%{$where['search']}%")
  244. ->when((isset($where['sp.mer_id']) && $where['mer_id'] !== ''), function ($query) use ($where) {
  245. $query->where('mer_id', $where['mer_id']);
  246. })->column('op.order_id');
  247. $query->where(function ($query) use ($orderId, $where) {
  248. if ($orderId)$query->whereIn('StoreOrder.order_id', $orderId);
  249. $query->whereOr('order_sn', 'like', "%{$where['search']}%")
  250. ->whereOr('StoreOrder.user_phone', 'like', "%{$where['search']}%");
  251. });
  252. })
  253. ->when(isset($where['group_order_sn']) && $where['group_order_sn'] !== '', function ($query) use ($where) {
  254. $query->join('StoreGroupOrder GO', 'StoreOrder.group_order_id = GO.group_order_id')->where('group_order_sn', $where['group_order_sn']);
  255. })
  256. ->when(isset($where['group_order_id']) && $where['group_order_id'] !== '', function ($query) use ($where) {
  257. $query->where('group_order_id', $where['group_order_id']);
  258. })
  259. ->when(isset($where['keywords']) && $where['keywords'] !== '', function ($query) use ($where) {
  260. $query->where(function ($query) use ($where) {
  261. $query->whereLike('StoreOrder.real_name|StoreOrder.user_phone|order_sn', "%" . $where['keywords'] . "%");
  262. });
  263. })
  264. ->when(isset($where['filter_delivery']) && $where['filter_delivery'] !== '', function ($query) use ($where) {
  265. //1 快递 2 配送 3 虚拟
  266. //按发货方式:1快递订单、2配送订单、4核销订单、3虚拟发货、6自动发货
  267. switch ($where['filter_delivery']) {
  268. case 1:
  269. $query->whereIn('delivery_type', '1,4');
  270. break;
  271. case 2:
  272. $query->whereIn('delivery_type', '2,5');
  273. break;
  274. case 3:
  275. $query->whereIn('delivery_type', '3');
  276. break;
  277. case 4:
  278. $query->where('order_type', 1);
  279. break;
  280. case 6:
  281. $query->whereIn('delivery_type', '6');
  282. break;
  283. }
  284. })
  285. ->when(isset($where['filter_product']) && $where['filter_product'] !== '', function ($query) use ($where) {
  286. // 1 实物商品、2虚拟商品、3卡密商品
  287. switch ($where['filter_product']) {
  288. case 1:
  289. $query->where('is_virtual', 0);
  290. break;
  291. case 2:
  292. $query->where('is_virtual', 1);
  293. break;
  294. case 3:
  295. $query->where('is_virtual', 2);
  296. break;
  297. case 4:
  298. $query->where('is_virtual', 4);
  299. break;
  300. default:
  301. break;
  302. }
  303. })
  304. ->when((isset($where['is_behalf']) && $where['is_behalf'] !== ''), function ($query) use ($where) {
  305. $query->where('StoreOrder.is_behalf', $where['is_behalf']);
  306. })
  307. ->when((isset($where['staffs_id']) && $where['staffs_id'] !== ''), function ($query) use ($where) {
  308. $query->where('StoreOrder.staffs_id', $where['staffs_id']);
  309. })
  310. ->when((isset($where['staffs_ids']) && $where['staffs_ids'] !== ''), function ($query) use ($where) {
  311. $query->whereIn('StoreOrder.staffs_id', $where['staffs_ids']);
  312. })
  313. ->when(isset($where['service_type']) && $where['service_type']!== '', function ($query) use ($where) {
  314. $query->where('StoreOrder.order_type', $where['service_type']);
  315. })
  316. ->when(isset($where['reservation_keyword']) && $where['reservation_keyword']!== '', function ($query) use ($where) {
  317. $query->where(function ($query) use ($where) {
  318. $query->where('StoreOrder.real_name', 'like', "%{$where['reservation_keyword']}%")->whereOr('StoreOrder.user_phone', 'like', "%{$where['reservation_keyword']}%");
  319. });
  320. })
  321. ->when(isset($where['reservation_status']) && !empty($where['reservation_status']), function ($query) use ($where) {
  322. $query->where(function ($query) use ($where) {
  323. foreach($where['reservation_status'] as $reservationStatus){
  324. switch ($reservationStatus) {
  325. case 1: // 待服务
  326. $query->whereOr(function ($query) {
  327. $query->whereIn('status', '0,1');
  328. });
  329. break;
  330. case 2: // 服务中 只有上门
  331. $query->whereOr(function ($query) {
  332. $query->where('status', '20')->where('order_type', 0);
  333. });
  334. break;
  335. case 3: // 已完成
  336. $query->whereOr(function ($query) {
  337. $query->whereIn('status', '2,3');
  338. });
  339. break;
  340. default:
  341. $query->whereOr(function ($query) {
  342. $query->where(function ($query) { // 上门
  343. $query->where('status', '1')->where('order_type', 0);
  344. });
  345. $query->whereOr(function ($query) { // 到店
  346. $query->whereIn('status', '0,1')->where('order_type', 1);
  347. });
  348. });
  349. break;
  350. }
  351. }
  352. });
  353. })
  354. ->order('StoreOrder.create_time DESC');
  355. return $query;
  356. }
  357. public function reservationSearch(array $where, $sysDel = 0)
  358. {
  359. $query = StoreOrder::getDB()->alias('StoreOrder');
  360. $query = $this->whereSearch($query, $where, $sysDel);
  361. return $query;
  362. }
  363. /**
  364. * 搜索全部
  365. * @param array $where
  366. * @param int $sysDel
  367. * @param null $is_points
  368. * @return BaseQuery
  369. * @author wuhaotian
  370. * @email 442384644@qq.com
  371. * @date 2024/7/16
  372. */
  373. public function searchAll(array $where, $sysDel = 0, $is_points = null)
  374. {
  375. $query = StoreOrder::getDB()->alias('StoreOrder');
  376. $query->when(($sysDel !== null), function ($query) use ($sysDel) {
  377. $query->where('is_system_del', $sysDel);
  378. });
  379. $query->when(!is_null($is_points), function ($query) use ($is_points) {
  380. if ($is_points) {
  381. $query->where('activity_type', 20);
  382. } else {
  383. $query->where('activity_type', '<>', 20);
  384. }
  385. });
  386. $query->when(isset($where['order_type']) && $where['order_type'] >= 0 && $where['order_type'] !== '', function ($query) use ($where) {
  387. if ($where['order_type'] == 2) {
  388. $query->where('is_virtual', 1);
  389. } else if ($where['order_type'] == 0) { //实体发货订单
  390. $query->where('order_type', 0)->where('is_virtual', 0);
  391. } else if ($where['order_type'] == 3) { //发货订单
  392. $query->where('order_type', 0);
  393. } else {
  394. $query->where('order_type', $where['order_type']);
  395. }
  396. });
  397. $query->when(isset($where['activity_type']) && $where['activity_type'] !== '', function ($query) use ($where) {
  398. $query->where('activity_type', $where['activity_type']);
  399. })
  400. ->when(isset($where['status']) && $where['status'] !== '', function ($query) use ($where) {
  401. switch ($where['status']) {
  402. case 0 :
  403. $query->whereIn('StoreOrder.status', [0, 9])->where('paid', 1)->where('is_del', 0);
  404. break;
  405. case -2 :
  406. $query->where('paid', 1)->whereNotIn('StoreOrder.status', [10, 11])->where('is_del', 0);
  407. break;
  408. case -3 :
  409. $query->where('paid', 0)->where('is_del', 0);
  410. break;
  411. case 10 :
  412. $query->where('paid', 1)->whereIn('StoreOrder.status', [10, 11])->where('is_del', 0);
  413. break;
  414. default:
  415. $query->where('StoreOrder.status', $where['status'])->where('is_del', 0);
  416. break;
  417. }
  418. })
  419. ->when(isset($where['uid']) && $where['uid'] !== '', function ($query) use ($where) {
  420. $query->where('uid', $where['uid']);
  421. })
  422. ->when(isset($where['is_user']) && $where['is_user'] !== '', function ($query) use ($where) {
  423. $query->where(function ($query) {
  424. $query->where('order_type', 0)->whereOr(function ($query) {
  425. $query->where('order_type', 1)->where('main_id', 0);
  426. });
  427. });
  428. })
  429. //待核销订单
  430. ->when(isset($where['is_verify']) && $where['is_verify'], function ($query) use ($where) {
  431. $query->where('StoreOrder.order_type', 1)->where('StoreOrder.status', 0);
  432. })
  433. ->when(isset($where['pay_type']) && $where['pay_type'] !== '', function ($query) use ($where) {
  434. $query->where('StoreOrder.pay_type', $where['pay_type']);
  435. })
  436. ->when(isset($where['order_ids']) && $where['order_ids'] !== '', function ($query) use ($where) {
  437. $query->whereIn('order_id', $where['order_ids']);
  438. })
  439. ->when(isset($where['order_id']) && $where['order_id'] !== '', function ($query) use ($where) {
  440. $query->where('order_id', $where['order_id']);
  441. })
  442. ->when(isset($where['take_order']) && $where['take_order'] != '', function ($query) use ($where) {
  443. $query->where('order_type', 1)->whereNotNull('verify_time');
  444. })
  445. ->when(isset($where['date']) && $where['date'] !== '', function ($query) use ($where) {
  446. getModelTime($query, $where['date'], 'StoreOrder.create_time');
  447. })
  448. ->when(isset($where['order_sn']) && $where['order_sn'] !== '', function ($query) use ($where) {
  449. $query->where('order_sn', 'like', '%' . $where['order_sn'] . '%');
  450. })
  451. ->when(isset($where['paid']) && $where['paid'] !== '', function ($query) use ($where) {
  452. $query->where('StoreOrder.paid', $where['paid']);
  453. })
  454. ->when(isset($where['is_del']) && $where['is_del'] !== '', function ($query) use ($where) {
  455. $query->where('StoreOrder.is_del', $where['is_del']);
  456. })
  457. ->when(isset($where['service_id']) && $where['service_id'] !== '', function ($query) use ($where) {
  458. $query->where('service_id', $where['service_id']);
  459. })
  460. ->when(isset($where['username']) && $where['username'] !== '', function ($query) use ($where) {
  461. $query->join('User U', 'StoreOrder.uid = U.uid')
  462. ->where(function ($query) use ($where) {
  463. $query->where('nickname', 'like', "%{$where['username']}%")
  464. ->whereOr('phone', 'like', "%{$where['username']}%")
  465. ->whereOr('user_phone', 'like', "%{$where['username']}%");
  466. });
  467. })
  468. ->when(isset($where['nickname']) && $where['nickname'] !== '', function ($query) use ($where) {
  469. $query->whereLike('StoreOrder.real_name', "%" . $where['nickname'] . "%");
  470. })
  471. ->when(isset($where['phone']) && $where['phone'] !== '', function ($query) use ($where) {
  472. $query->join('User U', 'StoreOrder.uid = U.uid')->where('phone', 'like', "%{$where['phone']}%");
  473. })
  474. ->when(isset($where['store_name']) && $where['store_name'] !== '', function ($query) use ($where) {
  475. $orderId = StoreOrderProduct::alias('op')
  476. ->join('storeProduct sp', 'op.product_id = sp.product_id')
  477. ->whereLike('store_name', "%{$where['store_name']}%")
  478. ->when((isset($where['sp.mer_id']) && $where['mer_id'] !== ''), function ($query) use ($where) {
  479. $query->where('mer_id', $where['mer_id']);
  480. })->column('order_id');
  481. $query->whereIn('order_id', $orderId ?: '');
  482. })
  483. ->when(isset($where['search']) && $where['search'] !== '', function ($query) use ($where) {
  484. $orderId = StoreOrderProduct::alias('op')
  485. ->join('storeProduct sp', 'op.product_id = sp.product_id')
  486. ->whereLike('store_name', "%{$where['search']}%")
  487. ->when((isset($where['sp.mer_id']) && $where['mer_id'] !== ''), function ($query) use ($where) {
  488. $query->where('mer_id', $where['mer_id']);
  489. })->column('order_id');
  490. $query->where(function ($query) use ($orderId, $where) {
  491. $query->whereIn('order_id', $orderId ? $orderId : '')
  492. ->whereOr('order_sn', 'like', "%{$where['search']}%")
  493. ->whereOr('user_phone', 'like', "%{$where['search']}%");
  494. });
  495. })
  496. ->when(isset($where['product_id']) && $where['product_id'] !== '', function ($query) use ($where) {
  497. $orderId = StoreOrderProduct::alias('op')
  498. ->join('storeProduct sp', 'op.product_id = sp.product_id')
  499. ->where('sp.product_id', $where['product_id'])
  500. ->column('order_id');
  501. $query->whereIn('order_id', $orderId ? $orderId : '');
  502. })
  503. ->when(isset($where['group_order_sn']) && $where['group_order_sn'] !== '', function ($query) use ($where) {
  504. $query->join('StoreGroupOrder GO', 'StoreOrder.group_order_id = GO.group_order_id')->where('group_order_sn', $where['group_order_sn']);
  505. })
  506. ->when(isset($where['keywords']) && $where['keywords'] !== '', function ($query) use ($where) {
  507. $query->where(function ($query) use ($where) {
  508. $query->whereLike('StoreOrder.real_name|StoreOrder.user_phone|order_sn', "%" . $where['keywords'] . "%");
  509. });
  510. })
  511. ->order('StoreOrder.create_time DESC');
  512. return $query;
  513. }
  514. /**
  515. * 查询用户的订单
  516. * @param $id
  517. * @param $uid
  518. * @return array|Model|null
  519. * @throws DataNotFoundException
  520. * @throws DbException
  521. * @throws ModelNotFoundException
  522. * @author xaboy
  523. * @day 2020/6/11
  524. */
  525. public function userOrder($id, $uid)
  526. {
  527. return StoreOrder::getDB()->where('order_id', $id)->where('uid', $uid)->where('is_del', 0)->where('paid', 1)->where('is_system_del', 0)->find();
  528. }
  529. /**
  530. * 条件查询用户订单
  531. * @param array $where
  532. * @param $ids
  533. * @return BaseQuery
  534. * @author xaboy
  535. * @day 2020/6/26
  536. */
  537. public function usersOrderQuery(array $where, $ids, $uid)
  538. {
  539. return StoreOrder::getDB()->where(function ($query) use ($uid, $ids) {
  540. $query->when(isset($ids['spread_uid']) && $ids['spread_uid'] !== '',function($query) use($ids){
  541. $query->where('spread_uid', $ids['spread_uid']);
  542. })->when(isset($ids['top_uid']) && $ids['top_uid'] !== '',function($query) use($ids){
  543. $query->where('top_uid', $ids['top_uid']);
  544. })->when(isset($ids['spread_uids']) && $ids['spread_uids'] !== '',function($query) use($ids){
  545. $query->whereOr('spread_uid', $ids['spread_uids'])->whereOr('top_uid', $ids['spread_uids']);
  546. });
  547. $query->whereOr(function ($query) use ($uid) {
  548. if ($uid) {$query->where('uid', $uid)->where('is_selfbuy', 1);}
  549. });
  550. })->when(isset($where['date']) && $where['date'] !== '', function ($query) use ($where) {
  551. getModelTime($query, $where['date'], 'pay_time');
  552. })->when(isset($where['create_time']) && $where['create_time'] !== '', function ($query) use ($where) {
  553. getModelTime($query, $where['create_time'], 'create_time');
  554. })->when(isset($where['keyword']) && $where['keyword'] !== '', function ($query) use ($where) {
  555. $_uid = User::where('nickname', 'like', "%{$where['keyword']}%")->column('uid');
  556. $orderId = StoreOrderProduct::alias('op')
  557. ->join('storeProduct sp', 'op.product_id = sp.product_id')
  558. ->whereLike('store_name', "%{$where['keyword']}%")
  559. ->column('order_id');
  560. $query->where(function ($query) use ($orderId, $where, $_uid) {
  561. $query->whereLike('order_id|order_sn', "%{$where['keyword']}%")->whereOr('order_id', 'in', $orderId)->whereOr('uid', 'in', $_uid);
  562. });
  563. })->where('paid', 1)->where('status', '>',0)->order('pay_time DESC');
  564. }
  565. /**
  566. * 查询订单是否存在
  567. * @param $field
  568. * @param $value
  569. * @param int|null $except
  570. * @return bool
  571. * @author xaboy
  572. * @day 2020/6/11
  573. */
  574. public function fieldExists($field, $value, ?int $except = null): bool
  575. {
  576. return ($this->getModel()::getDB())->when($except, function ($query) use ($field, $except) {
  577. $query->where($field, '<>', $except);
  578. })->where($field, $value)->count() > 0;
  579. }
  580. /**
  581. * 获取商户id
  582. * @param $id
  583. * @return mixed
  584. * @author xaboy
  585. * @day 2020/6/12
  586. */
  587. public function getMerId($id)
  588. {
  589. return StoreOrder::getDB()->where('order_id', $id)->value('mer_id');
  590. }
  591. /**
  592. * 查询商户订单是否存在
  593. * @param array $where
  594. * @return bool
  595. * @author Qinii
  596. * @day 2020-06-12
  597. */
  598. public function merFieldExists(array $where)
  599. {
  600. return ($this->getModel()::getDB())->where($where)->count() > 0;
  601. }
  602. /**
  603. * 对账更新
  604. * @param $reconciliation_id
  605. * @return mixed
  606. * @author Qinii
  607. * @day 2020-06-15
  608. */
  609. public function reconciliationUpdate($reconciliation_id)
  610. {
  611. return ($this->getModel()::getDB())->whereIn('reconciliation_id', $reconciliation_id)->update(['reconciliation_id' => 0]);
  612. }
  613. /**
  614. * 每日订单数量
  615. * @param $day
  616. * @param null $merId
  617. * @return int
  618. * @throws DbException
  619. * @author wuhaotian
  620. * @email 442384644@qq.com
  621. * @date 2024/7/16
  622. */
  623. public function dayOrderNum($day, $merId = null)
  624. {
  625. return StoreOrder::getDB()->where('paid', 1)->when($merId, function ($query, $merId) {
  626. $query->where('mer_id', $merId);
  627. })->when($day, function ($query, $day) {
  628. getModelTime($query, $day, 'pay_time');
  629. })->count();
  630. }
  631. /**
  632. * 每日订单金额
  633. * @param $day
  634. * @param null $merId
  635. * @return float
  636. * @author wuhaotian
  637. * @email 442384644@qq.com
  638. * @date 2024/7/16
  639. */
  640. public function dayOrderPrice($day, $merId = null)
  641. {
  642. return getModelTime(StoreOrder::getDB()->where('paid', 1)->when($merId, function ($query, $merId) {
  643. $query->where('mer_id', $merId);
  644. }), $day, 'pay_time')->sum('pay_price');
  645. }
  646. /**
  647. * 时间区间订单金额
  648. * @param $date
  649. * @param null $merId
  650. * @return float
  651. * @author wuhaotian
  652. * @email 442384644@qq.com
  653. * @date 2024/7/16
  654. */
  655. public function dateOrderPrice($date, $merId = null)
  656. {
  657. return StoreOrder::getDB()->where('paid', 1)->when($merId, function ($query, $merId) {
  658. $query->where('mer_id', $merId);
  659. })->when($date, function ($query, $date) {
  660. getModelTime($query, $date, 'pay_time');
  661. })->sum('pay_price');
  662. }
  663. /**
  664. * 时间区间订单数量
  665. * @param $date
  666. * @param null $merId
  667. * @return int
  668. * @throws DbException
  669. * @author wuhaotian
  670. * @email 442384644@qq.com
  671. * @date 2024/7/16
  672. */
  673. public function dateOrderNum($date, $merId = null)
  674. {
  675. return StoreOrder::getDB()->where('paid', 1)->when($merId, function ($query, $merId) {
  676. $query->where('mer_id', $merId);
  677. })->when($date, function ($query, $date) {
  678. getModelTime($query, $date, 'pay_time');
  679. })->count();
  680. }
  681. /**
  682. * 每日下单用户数量
  683. * @param $day
  684. * @param null $merId
  685. * @return mixed
  686. * @author wuhaotian
  687. * @email 442384644@qq.com
  688. * @date 2024/7/16
  689. */
  690. public function dayOrderUserNum($day, $merId = null)
  691. {
  692. return StoreOrder::getDB()->where('paid', 1)->when($merId, function ($query, $merId) {
  693. $query->where('mer_id', $merId);
  694. })->when($day, function ($query, $day) {
  695. getModelTime($query, $day, 'pay_time');
  696. })->group('uid')->count();
  697. }
  698. /**
  699. * 时间区间订单数量
  700. * @param $date
  701. * @param null $paid
  702. * @param null $merId
  703. * @return mixed
  704. * @author wuhaotian
  705. * @email 442384644@qq.com
  706. * @date 2024/7/16
  707. */
  708. public function orderUserNum($date, $paid = null, $merId = null)
  709. {
  710. return StoreOrder::getDB()->when($paid, function ($query, $paid) {
  711. $query->where('paid', $paid);
  712. })->when($merId, function ($query, $merId) {
  713. $query->where('mer_id', $merId);
  714. })->when($date, function ($query, $date) use ($paid) {
  715. if (!$paid) {
  716. getModelTime($query, $date);
  717. } else
  718. getModelTime($query, $date, 'pay_time');
  719. })->group('uid')->count();
  720. }
  721. /**
  722. * 查询下单用户数量,金额
  723. * @param $date
  724. * @param null $paid
  725. * @param null $merId
  726. * @return mixed
  727. * @author wuhaotian
  728. * @email 442384644@qq.com
  729. * @date 2024/7/16
  730. */
  731. public function orderUserGroup($date, $paid = null, $merId = null)
  732. {
  733. return StoreOrder::getDB()->when($paid, function ($query, $paid) {
  734. $query->where('paid', $paid);
  735. })->when($merId, function ($query, $merId) {
  736. $query->where('mer_id', $merId);
  737. })->when($date, function ($query, $date) {
  738. getModelTime($query, $date, 'pay_time');
  739. })->group('uid')->field(Db::raw('uid,sum(pay_price) as pay_price,count(order_id) as total'))->select();
  740. }
  741. /**
  742. * 查询下单用户数量
  743. * @param array $ids
  744. * @param null $merId
  745. * @return mixed
  746. * @author wuhaotian
  747. * @email 442384644@qq.com
  748. * @date 2024/7/16
  749. */
  750. public function oldUserNum(array $ids, $merId = null)
  751. {
  752. return StoreOrder::getDB()->when($merId, function ($query, $merId) {
  753. $query->where('mer_id', $merId);
  754. })->whereIn('uid', $ids)->where('paid', 1)->group('uid')->count();
  755. }
  756. /**
  757. * 查询下单用户id
  758. * @param array $ids
  759. * @param null $merId
  760. * @return mixed
  761. * @author wuhaotian
  762. * @email 442384644@qq.com
  763. * @date 2024/7/16
  764. */
  765. public function oldUserIds(array $ids, $merId = null)
  766. {
  767. return StoreOrder::getDB()->when($merId, function ($query, $merId) {
  768. $query->where('mer_id', $merId);
  769. })->whereIn('uid', $ids)->where('paid', 1)->group('uid')->column('uid');
  770. }
  771. /**
  772. * 查询订单金额
  773. * @param $date
  774. * @param null $paid
  775. * @param null $merId
  776. * @return float
  777. * @author wuhaotian
  778. * @email 442384644@qq.com
  779. * @date 2024/7/16
  780. */
  781. public function orderPrice($date, $paid = null, $merId = null)
  782. {
  783. return StoreOrder::getDB()->when($paid, function ($query, $paid) {
  784. $query->where('paid', $paid);
  785. })->when($merId, function ($query, $merId) {
  786. $query->where('mer_id', $merId);
  787. })->when($date, function ($query, $date) use ($paid) {
  788. if (!$paid) {
  789. $query->where(function ($query) use ($date) {
  790. $query->where(function ($query) use ($date) {
  791. $query->where('paid', 1);
  792. getModelTime($query, $date, 'pay_time');
  793. })->whereOr(function ($query) use ($date) {
  794. $query->where('paid', 0);
  795. getModelTime($query, $date);
  796. });
  797. });
  798. } else
  799. getModelTime($query, $date, 'pay_time');
  800. })->sum('pay_price');
  801. }
  802. /**
  803. * 查询订单数量
  804. * @param $date
  805. * @param null $merId
  806. * @return mixed
  807. * @author wuhaotian
  808. * @email 442384644@qq.com
  809. * @date 2024/7/16
  810. */
  811. public function orderGroupNum($date, $merId = null)
  812. {
  813. $field = Db::raw('sum(pay_price) as pay_price,count(*) as total,count(distinct uid) as user,pay_time,from_unixtime(unix_timestamp(pay_time),\'%m-%d\') as `day`');
  814. if ($date == 'year') {
  815. $field = Db::raw('sum(pay_price) as pay_price,count(*) as total,count(distinct uid) as user,pay_time,from_unixtime(unix_timestamp(pay_time),\'%m\') as `day`');
  816. }
  817. $query = StoreOrder::getDB()->field($field)
  818. ->where('paid', 1)->when($date, function ($query, $date) {
  819. getModelTime($query, $date, 'pay_time');
  820. })->when($merId, function ($query, $merId) {
  821. $query->where('mer_id', $merId);
  822. });
  823. return $query->order('pay_time ASC')->group('day')->select();
  824. }
  825. /**
  826. * 根据时间筛选订单 统计数据
  827. * @param $where
  828. * @param $page
  829. * @param $limit
  830. * @param $merId
  831. * @return mixed
  832. * @author Qinii
  833. */
  834. public function orderGroupNumPage($where, $page, $limit, $merId = null)
  835. {
  836. return StoreOrder::getDB()->when(isset($where['dateRange']), function ($query) use ($where) {
  837. getModelTime($query, date('Y/m/d 00:00:00', $where['dateRange']['start']) . '-' . date('Y/m/d 00:00:00', $where['dateRange']['stop']), 'pay_time');
  838. })->field(Db::raw('sum(pay_price) as pay_price,count(*) as total,count(distinct uid) as user,pay_time,from_unixtime(unix_timestamp(pay_time),\'%m-%d\') as `day`'))
  839. ->where('paid', 1)->when($merId, function ($query, $merId) {
  840. $query->where('mer_id', $merId);
  841. })->order('pay_time DESC')->page($page, $limit)->group('day')->select();
  842. }
  843. /**
  844. * 按照日期分组统计订单金额
  845. * @param $date
  846. * @param $merId
  847. * @return mixed
  848. * @author Qinii
  849. */
  850. public function dayOrderPriceGroup($date, $merId = null)
  851. {
  852. return StoreOrder::getDB()->field(Db::raw('sum(pay_price) as price, from_unixtime(unix_timestamp(pay_time),\'%H:%i\') as time'))
  853. ->where('paid', 1)->when($date, function ($query, $date) {
  854. getModelTime($query, $date, 'pay_time');
  855. })->when($merId, function ($query, $merId) {
  856. $query->where('mer_id', $merId);
  857. })->group('time')->select();
  858. }
  859. /**
  860. * 按照日期分组统计订单数量
  861. * @param $date
  862. * @param null $merId
  863. * @return mixed
  864. * @author wuhaotian
  865. * @email 442384644@qq.com
  866. * @date 2024/7/16
  867. */
  868. public function dayOrderNumGroup($date, $merId = null)
  869. {
  870. return StoreOrder::getDB()->field(Db::raw('count(*) as total, from_unixtime(unix_timestamp(pay_time),\'%H:%i\') as time'))
  871. ->where('paid', 1)->when($date, function ($query, $date) {
  872. getModelTime($query, $date, 'pay_time');
  873. })->when($merId, function ($query, $merId) {
  874. $query->where('mer_id', $merId);
  875. })->group('time')->select();
  876. }
  877. /**
  878. * 按照日期分组统计订单用户数量
  879. * @param $date
  880. * @param null $merId
  881. * @return mixed
  882. * @author wuhaotian
  883. * @email 442384644@qq.com
  884. * @date 2024/7/16
  885. */
  886. public function dayOrderUserGroup($date, $merId = null)
  887. {
  888. return StoreOrder::getDB()->field(Db::raw('count(DISTINCT uid) as total, from_unixtime(unix_timestamp(pay_time),\'%H:%i\') as time'))
  889. ->where('paid', 1)->when($date, function ($query, $date) {
  890. getModelTime($query, $date, 'pay_time');
  891. })->when($merId, function ($query, $merId) {
  892. $query->where('mer_id', $merId);
  893. })->group('time')->select();
  894. }
  895. /**
  896. * 获取当前时间到指定时间的支付金额 管理员
  897. * @param string $start 开始时间
  898. * @param string $stop 结束时间
  899. * @return mixed
  900. */
  901. public function chartTimePrice($start, $stop, $merId = null)
  902. {
  903. return StoreOrder::getDB()->where('paid', 1)
  904. ->where('pay_time', '>=', $start)
  905. ->where('pay_time', '<', $stop)
  906. ->when($merId, function ($query, $merId) {
  907. $query->where('mer_id', $merId);
  908. })
  909. ->field('sum(pay_price) as num,FROM_UNIXTIME(unix_timestamp(pay_time), \'%Y-%m-%d\') as time')
  910. ->group('time')
  911. ->order('pay_time ASC')->select()->toArray();
  912. }
  913. /**
  914. * 获取当前时间到指定时间的支付订单数量 管理员
  915. * @param $date
  916. * @param null $merId
  917. * @return mixed
  918. */
  919. public function chartTimeNum($date, $merId = null)
  920. {
  921. return StoreOrder::getDB()->where('paid', 1)->when($date, function ($query) use ($date) {
  922. getModelTime($query, $date, 'pay_time');
  923. })->when($merId, function ($query, $merId) {
  924. $query->where('mer_id', $merId);
  925. })->field('count(order_id) as num,FROM_UNIXTIME(unix_timestamp(pay_time), \'%Y-%m-%d\') as time')
  926. ->group('time')
  927. ->order('pay_time ASC')->select()->toArray();
  928. }
  929. /**
  930. * 获取完成以及到期的订单id
  931. * @param $end
  932. * @return mixed
  933. * @author xaboy
  934. * @day 2020/9/16
  935. */
  936. public function getFinishTimeoutIds($end)
  937. {
  938. return StoreOrderStatus::getDB()->alias('A')->leftJoin('StoreOrder B', 'A.order_id = B.order_id')
  939. ->where('A.change_type', 'take')
  940. ->where('A.change_time', '<', $end)->where('B.paid', 1)->where('B.status', 2)
  941. ->column('A.order_id');
  942. }
  943. /**
  944. * 参与人数
  945. * @param array $data
  946. * @param int|null $uid
  947. * @return BaseQuery
  948. * @author Qinii
  949. * @day 2020-11-11
  950. */
  951. public function getTattendCount(array $data, ?int $uid)
  952. {
  953. $query = StoreOrder::hasWhere('orderProduct', function ($query) use ($data, $uid) {
  954. $query->when(isset($data['activity_id']), function ($query) use ($data) {
  955. $query->where('activity_id', $data['activity_id']);
  956. })
  957. ->when(isset($data['product_sku']), function ($query) use ($data) {
  958. $query->where('product_sku', $data['product_sku']);
  959. })
  960. ->when(isset($data['product_id']), function ($query) use ($data) {
  961. $query->where('product_id', $data['product_id']);
  962. })
  963. ->when(isset($data['exsits_id']), function ($query) use ($data) {
  964. switch ($data['product_type']) {
  965. case 3:
  966. $make = app()->make(ProductAssistSetRepository::class);
  967. $id = 'product_assist_id';
  968. break;
  969. case 4:
  970. $make = app()->make(ProductGroupBuyingRepository::class);
  971. $id = 'product_group_id';
  972. break;
  973. }
  974. $where = [$id => $data['exsits_id']];
  975. $activity_id = $make->getSearch($where)->column($make->getPk());
  976. if ($activity_id) {
  977. $id = array_unique($activity_id);
  978. $query->where('activity_id', 'in', $id);
  979. } else {
  980. $query->where('activity_id', '<', 0);
  981. }
  982. })
  983. ->where('product_type', $data['product_type']);
  984. if ($uid) $query->where('uid', $uid);
  985. });
  986. $query->where('activity_type', $data['product_type']);
  987. switch ($data['product_type']) {
  988. case 0:
  989. $query->where(function ($query) {
  990. $query->where(function ($query) {
  991. $query->where('paid', 1);
  992. })->whereOr(function ($query) {
  993. $query->where('paid', 0)->where('is_del', 0);
  994. });
  995. });
  996. break;
  997. case 1: //秒杀
  998. $query->where(function ($query) {
  999. $query->where(function ($query) {
  1000. $query->where('paid', 1);
  1001. })->whereOr(function ($query) {
  1002. $query->where('paid', 0)->where('is_del', 0);
  1003. });
  1004. })->when(isset($data['day']), function ($query) use ($data) {
  1005. $query->whereDay('StoreOrder.create_time', $data['day']);
  1006. });
  1007. break;
  1008. case 2: //预售
  1009. /**
  1010. * 第一阶段参与人数:所有人
  1011. * 第二阶段参与人数:支付了第一阶段
  1012. */
  1013. //第二阶段
  1014. if ($data['type'] == 1) {
  1015. $query->where(function ($query) {
  1016. $query->where('paid', 1)->whereOr(function ($query) {
  1017. $query->where('paid', 0)->where('is_del', 0);
  1018. });
  1019. });
  1020. }
  1021. if ($data['type'] == 2) $query->where('paid', 1)->where('status', 'in', [0, 1, 2, 3, -1]);
  1022. break;
  1023. case 3: //助力
  1024. $query->where(function ($query) {
  1025. $query->where('paid', 1)->whereOr(function ($query) {
  1026. $query->where('paid', 0)->where('is_del', 0);
  1027. });
  1028. });
  1029. break;
  1030. case 4: //
  1031. $query->where(function ($query) {
  1032. $query->where('paid', 1)->whereOr(function ($query) {
  1033. $query->where('paid', 0)->where('is_del', 0);
  1034. })
  1035. ->where('status', '>', -1);
  1036. });
  1037. break;
  1038. }
  1039. return $query;
  1040. }
  1041. /**
  1042. * 未使用
  1043. * 成功支付人数
  1044. * @param int $productType
  1045. * @param int $activityId
  1046. * @param int|null $uid
  1047. * @param int|null $status
  1048. * @author Qinii
  1049. * @day 2020-10-30
  1050. */
  1051. public function getTattendSuccessCount($data, ?int $uid)
  1052. {
  1053. $query = StoreOrder::hasWhere('orderProduct', function ($query) use ($data, $uid) {
  1054. $query->when(isset($data['activity_id']), function ($query) use ($data) {
  1055. $query->where('activity_id', $data['activity_id']);
  1056. })
  1057. ->when(isset($data['product_sku']), function ($query) use ($data) {
  1058. $query->where('product_sku', $data['product_sku']);
  1059. })
  1060. ->when(isset($data['product_id']), function ($query) use ($data) {
  1061. $query->where('product_id', $data['product_id']);
  1062. })
  1063. ->when(isset($data['exsits_id']), function ($query) use ($data) {
  1064. switch ($data['product_type']) {
  1065. case 3:
  1066. $make = app()->make(ProductAssistSetRepository::class);
  1067. $id = 'product_assist_id';
  1068. break;
  1069. case 4:
  1070. $make = app()->make(ProductGroupBuyingRepository::class);
  1071. $id = 'product_group_id';
  1072. break;
  1073. }
  1074. $where = [$id => $data['exsits_id']];
  1075. $activity_id = $make->getSearch($where)->column($make->getPk());
  1076. if ($activity_id) {
  1077. $id = array_unique($activity_id);
  1078. $query->where('activity_id', 'in', $id);
  1079. } else {
  1080. $query->where('activity_id', '<', 0);
  1081. }
  1082. })
  1083. ->where('product_type', $data['product_type']);
  1084. if ($uid) $query->where('uid', $uid);
  1085. });
  1086. $query->where('activity_type', $data['product_type'])->where('paid', 1);
  1087. switch ($data['product_type']) {
  1088. case 1: //秒杀
  1089. $query->where(function ($query) {
  1090. $query->where(function ($query) {
  1091. $query->where('paid', 1);
  1092. });
  1093. })->when(isset($data['day']), function ($query) use ($data) {
  1094. $query->whereDay('StoreOrder.create_time', $data['day']);
  1095. });
  1096. break;
  1097. case 2: //预售
  1098. if ($data['type'] == 1) { //第一阶段
  1099. $query->where('status', 'in', [0, 1, 2, 3, 10]);
  1100. } else { //第二阶段
  1101. $query->where('status', 'in', [0, 1, 2, 3]);
  1102. }
  1103. break;
  1104. case 3: //助力
  1105. break;
  1106. case 4:
  1107. break;
  1108. }
  1109. return $query;
  1110. }
  1111. /**
  1112. * 获取退款单数量
  1113. * @param $where
  1114. * @return mixed
  1115. * @author Qinii
  1116. * @day 1/4/21
  1117. */
  1118. public function getSeckillRefundCount($where, $type = 1)
  1119. {
  1120. $query = StoreOrderProduct::getDB()->alias('P')->join('StoreRefundOrder R', 'P.order_id = R.order_id');
  1121. $query->join('StoreOrder O', 'O.order_id = P.order_id');
  1122. $query
  1123. ->when(isset($where['activity_id']), function ($query) use ($where) {
  1124. $query->where('P.activity_id', $where['activity_id']);
  1125. })
  1126. ->when(isset($where['product_id']), function ($query) use ($where) {
  1127. $query->where('P.product_id', $where['product_id']);
  1128. })
  1129. ->when(isset($where['product_sku']), function ($query) use ($where) {
  1130. $query->where('P.product_sku', $where['product_sku']);
  1131. })
  1132. ->when(isset($where['day']), function ($query) use ($where) {
  1133. $query->whereDay('P.create_time', $where['day']);
  1134. })
  1135. ->when($type == 1, function ($query) use ($where) {
  1136. $query->where('O.verify_time', null)->where('O.delivery_type', null);
  1137. }, function ($query) {
  1138. $query->where('R.refund_type', 2);
  1139. })
  1140. ->where('P.product_type', 1)->where('R.status', 3);
  1141. return $query->sum('R.refund_num');
  1142. }
  1143. /**
  1144. * 用户的某个商品购买数量
  1145. * @param int $uid
  1146. * @param int $productId
  1147. * @return int
  1148. * @author Qinii
  1149. * @day 2022/9/26
  1150. */
  1151. public function getMaxCountNumber(int $uid, int $productId)
  1152. {
  1153. return (int)StoreOrderProduct::hasWhere('orderInfo', function ($query) use ($uid) {
  1154. $query->where('uid', $uid)->where(function ($query) {
  1155. $query->where('is_del', 0)->whereOr(function ($query) {
  1156. $query->where('is_del', 1)->where('paid', 1);
  1157. });
  1158. });
  1159. })->where('product_id', $productId)->sum('product_num');
  1160. }
  1161. public function getOrderSn($order_id)
  1162. {
  1163. return StoreOrder::getDB()->where($this->getPk(), $order_id)->value('order_sn', '');
  1164. }
  1165. public function getSubOrderNotSend(int $group_order_id, int $order_id)
  1166. {
  1167. return StoreOrder::getDB()->where('group_order_id', $group_order_id)->where('status', 0)->where('order_id', '<>', $order_id)->count();
  1168. }
  1169. /**
  1170. * 获取商户排行
  1171. * @param string $date
  1172. * @param string $type
  1173. * @param string $sort
  1174. * @return mixed
  1175. */
  1176. public function getMerchantTop(string $date, string $type = 'sales', string $sort = 'desc')
  1177. {
  1178. $query = StoreOrder::getDB()->with(['merchant' => function ($query) {
  1179. $query->field('mer_id,mer_name,mer_avatar,care_count');
  1180. }]);
  1181. $query = getModelTime($query, $date)->where('paid', 1)->where('mer_id', '>', 0)->field('mer_id,sum(total_num) as sales,sum(pay_price + pay_postage) as price')->group('mer_id');
  1182. switch ($type) {
  1183. case 'sales':
  1184. $query->order('sales ' . $sort);
  1185. break;
  1186. case 'price':
  1187. $query->order('price ' . $sort);
  1188. break;
  1189. }
  1190. return $query->limit(0, 10)->select()->toArray();
  1191. }
  1192. }