KangyangCityController.php 58 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177
  1. <?php
  2. namespace app\admin\controller\order;
  3. use app\admin\service\coupon\CouponService;
  4. use app\admin\service\member\MemberService;
  5. use app\admin\service\order\OrderService;
  6. use app\admin\service\order\OrderSheetService;
  7. use app\admin\service\order\PayDetailService;
  8. use app\admin\validate\order\OrderValidate;
  9. use app\controller\Curd;
  10. use app\model\Appointment;
  11. use app\model\ClientConfig;
  12. use app\model\Coupon;
  13. use app\model\Goods;
  14. use app\model\GoodsComponent;
  15. use app\model\GoodsRunning;
  16. use app\model\GoodsSku;
  17. use app\model\Member;
  18. use app\model\MemberAccount;
  19. use app\model\MemberBenefit;
  20. use app\model\MemberRole;
  21. use app\model\Order;
  22. use app\model\OrderExpress;
  23. use app\model\OrderReturn;
  24. use app\model\OrderSheet;
  25. use app\model\PayDetail;
  26. use app\model\Supplier;
  27. use app\model\SysDept;
  28. use app\model\SysUser;
  29. use support\Db;
  30. use support\exception\BusinessException;
  31. use support\Redis;
  32. use support\Request;
  33. use support\Response;
  34. use Webman\Event\Event;
  35. class KangyangCityController extends Curd
  36. {
  37. public function __construct()
  38. {
  39. $this->model = new Order();
  40. $this->validate = true;
  41. $this->validateClass = new OrderValidate();
  42. }
  43. /**
  44. * @Desc 列表
  45. * @Author Gorden
  46. * @Date 2024/3/28 15:01
  47. *
  48. * @param Request $request
  49. * @return Response
  50. * @throws \support\exception\BusinessException
  51. */
  52. public function select(Request $request): Response
  53. {
  54. $timeType = $request->get('time_type', 'add');
  55. [$where, $format, $limit, $field, $order] = $this->selectInput($request);
  56. $where['order_classify'] = 'VIP';
  57. if (!empty($where['order_addtimes']) && $timeType == 'add') {
  58. $where['order_addtimes'][0] = strtotime($where['order_addtimes'][0]);
  59. $where['order_addtimes'][1] = strtotime($where['order_addtimes'][1]);
  60. }
  61. $order = $request->get('order', 'desc');
  62. $orderId = $request->get('orderId');
  63. $field = $field ?? 'order_addtimes';
  64. $orderIds = [];
  65. if (!empty($orderId)) {
  66. $orderIds = Order::where('order_id', 'like', '%' . $orderId . '%')
  67. ->where('order_classify', 'VIP')
  68. ->pluck('order_id')
  69. ->toArray();
  70. }
  71. $goodsName = trim($request->get('goods_name', ''));
  72. if (!empty($goodsName)) {
  73. $goodsIds = Goods::where('goods_classify', 'VIP')
  74. ->where('goods_name', 'like', '%' . $goodsName . '%')
  75. ->pluck('goods_id')
  76. ->toArray();
  77. $goodsOrderIds = OrderSheet::whereIn('join_sheet_goods_id', $goodsIds)->pluck('join_sheet_order_id')->toArray();
  78. if (!empty($where['order_id'])) {
  79. $orderIds = array_intersect($orderIds, $goodsOrderIds);
  80. } else {
  81. $orderIds = $goodsOrderIds;
  82. }
  83. }
  84. // 付款时间
  85. $payOrderIds = [];
  86. if ($timeType == 'pay' && !empty($where['order_addtimes'])) {
  87. $payTimeStart = strtotime($where['order_addtimes'][0]);
  88. $payTimeEnd = strtotime($where['order_addtimes'][1]);
  89. unset($where['order_addtimes']);
  90. $payOrderIds = PayDetailService::getPayOrderId($payTimeStart, $payTimeEnd, ['VIP']);
  91. }
  92. if ((!empty($orderId) || !empty($goodsName)) && $timeType == 'pay') {
  93. $orderIds = array_intersect($orderIds, $payOrderIds);
  94. $where['order_id'] = ['in', implode(',', $orderIds)];
  95. } elseif (!empty($orderId) || !empty($goodsName)) {
  96. $where['order_id'] = ['in', implode(',', $orderIds)];
  97. } elseif ($timeType == 'pay') {
  98. $where['order_id'] = ['in', implode(',', $payOrderIds)];
  99. }
  100. $query = $this->doSelect($where, $field, $order);
  101. return $this->doFormat($query, $format, $limit);
  102. }
  103. protected function doSelect(array $where, string $field = null, string $order = 'desc')
  104. {
  105. $model = $this->model->with([
  106. 'sheets' => function ($query) {
  107. $query->select('join_sheet_order_id', 'order_sheet_id', 'join_sheet_goods_id', 'order_sheet_num', 'order_sheet_price');
  108. },
  109. 'member' => function ($query) {
  110. $query->select('member_id', 'member_mobile');
  111. },
  112. 'cert' => function ($query) {
  113. $query->select('join_cert_member_id', 'member_cert_name');
  114. },
  115. ])->leftJoin('order_return', 'order_return.join_return_order_id', '=', 'order.order_id')
  116. ->leftJoin('order_express', 'order_express.join_express_order_id', '=', 'order.order_id');
  117. foreach ($where as $column => $value) {
  118. if (is_array($value)) {
  119. if ($value[0] === 'like' || $value[0] === 'not like') {
  120. $model = $model->where($column, $value[0], "%$value[1]%");
  121. } elseif (in_array($value[0], ['>', '=', '<', '<>'])) {
  122. $model = $model->where($column, $value[0], $value[1]);
  123. } elseif ($value[0] == 'in' && !empty($value[1])) {
  124. $valArr = $value[1];
  125. if (is_string($value[1])) {
  126. $valArr = explode(",", trim($value[1]));
  127. }
  128. $model = $model->whereIn($column, $valArr);
  129. } elseif ($value[0] == 'not in' && !empty($value[1])) {
  130. $valArr = $value[1];
  131. if (is_string($value[1])) {
  132. $valArr = explode(",", trim($value[1]));
  133. }
  134. $model = $model->whereNotIn($column, $valArr);
  135. } elseif ($value[0] == 'null') {
  136. $model = $model->whereNull($column);
  137. } elseif ($value[0] == 'not null') {
  138. $model = $model->whereNotNull($column);
  139. } elseif ($value[0] !== '' || $value[1] !== '') {
  140. $model = $model->whereBetween($column, $value);
  141. }
  142. } else {
  143. $model = $model->where($column, $value);
  144. }
  145. }
  146. if ($field) {
  147. $model = $model->orderBy($field, $order);
  148. }
  149. $model = $model->select('order.*', 'order_express.join_express_order_id', 'order_express.order_express_type', 'order_return.orders_return_id', 'order_return.join_return_order_id', 'order_return.order_return_status', 'order_return.order_return_apply_json', 'order_return.order_return_remark');
  150. return $model;
  151. }
  152. public function afterQuery($items)
  153. {
  154. foreach ($items as &$item) {
  155. $sheetDeng = '';
  156. $item['sheet'] = $item['sheets'][0] ?? [];
  157. if (!empty($item['sheet'])) {
  158. $goods = Goods::where('goods_id', $item['sheet']['join_sheet_goods_id'])->first();
  159. if (count($item['sheets']) > 1 && $goods->goods_classify == 'MEALS') {
  160. $sheetDeng = ' 等餐品';
  161. }
  162. $item['sheet']['goods_name'] = ($goods && $goods->goods_name) ? $goods->goods_name . $sheetDeng : '';
  163. $item['sheet']['goods_classify'] = $goods->goods_classify ?? '';
  164. $item['sheet']['order_sheet_num'] = intval($item['sheet']['order_sheet_num']);
  165. }
  166. unset($item['sheets']);
  167. if (isset($item['orders_return_id'])) {
  168. $item['return'] = [
  169. 'orders_return_id' => $item['orders_return_id'],
  170. 'join_return_order_id' => $item['join_return_order_id'],
  171. 'order_return_status' => $item['order_return_status'],
  172. 'order_return_apply_json' => $item['order_return_apply_json'],
  173. 'order_return_remark' => $item['order_return_remark']
  174. ];
  175. }
  176. if (isset($item['join_express_order_id'])) {
  177. $item['express'] = [
  178. 'join_express_order_id' => $item['join_express_order_id'],
  179. 'order_express_type' => $item['order_express_type']
  180. ];
  181. unset($item['join_express_order_id'], $item['order_express_type']);
  182. }
  183. $item['payDetail'] = PayDetailService::getPayWay($item['order_groupby'],$item['order_id']);
  184. }
  185. return $items;
  186. }
  187. /**
  188. * @Desc 下单+支付
  189. * @Author Gorden
  190. * @Date 2024/9/5 13:13
  191. *
  192. * @param Request $request
  193. * @return Response
  194. */
  195. public function insert(Request $request): Response
  196. {
  197. $params = $request->post();
  198. // 判断餐品是否连带着服务或实体
  199. $goodsClassifys = array_unique(array_column($params['goodsContentList'], 'goods_classify'));
  200. if (in_array('MEALS', $goodsClassifys) && count($goodsClassifys) > 1) {
  201. return json_fail('餐饮餐品不支持和其他类型的产品一起下单');
  202. }
  203. if (in_array('MEALS', $goodsClassifys)) {
  204. $params['submit_goods_classify'] = 'MEALS';
  205. }
  206. if (in_array('PACKAGE', $goodsClassifys)) {
  207. $params['submit_goods_classify'] = 'PACKAGE';
  208. }
  209. if (!empty($params['dept_premises_id'])) {
  210. $premises = SysDept::where('dept_name', $params['dept_premises_id'])->first();
  211. }
  212. $params['goods_classify'] = $goodsClassifys[0];
  213. Db::beginTransaction();
  214. try {
  215. // 验证线下付款密码
  216. if ($params['settlement_now'] == 'Y' && $params['pay_constitute'] == 'N' && in_array($params['pay_category'], ['OFFLINE', 'MONEY'])) {
  217. $password = $params['offline_password'];
  218. if ($password != '666888') {
  219. throw new BusinessException('密码错误,请重新输入');
  220. }
  221. }
  222. // 下单账户
  223. if (empty($params['join_order_member_id']) && !empty($params['mobile'])) {
  224. if (Member::where('member_mobile', $params['mobile'])->exists()) {
  225. throw new BusinessException('会员已存在');
  226. }
  227. $params['join_order_member_id'] = $params['member_id'] = 'MR' . date('ymdHi') . random_string(4, 'up');
  228. // 创建会员
  229. MemberService::createMember($params);
  230. } else if (empty($params['join_order_member_id']) && empty($params['mobile'])) {
  231. $params['join_order_member_id'] = Member::where('member_mobile', '0000')->value('member_id');
  232. }
  233. if (empty($params['join_order_member_id'])) {
  234. throw new BusinessException('检查下单账户');
  235. }
  236. $qrcodePayAmount = 0;
  237. $params['orderId'] = 'OD' . date('ymdHi') . random_string(4, 'up');
  238. $params['orderGroupId'] = 'OD' . date('ymdHi') . random_string(4, 'up');
  239. // 查询是否有未完全支付订单
  240. $paidOrder = Order::where('join_order_member_id', $params['join_order_member_id'])
  241. ->where('order_category', 'VIP')
  242. ->where('order_status_system', 'PAYING')
  243. ->first();
  244. if (!empty($paidOrder)) {
  245. $paidOrder->order_groupby = $params['orderGroupId'];
  246. $params['orderId'] = $paidOrder->order_id;
  247. }
  248. $systemStatus = 'PAYING'; // 待发货
  249. // 立即结算
  250. if ($params['settlement_now'] == 'Y') {
  251. if (in_array($params['goods_classify'], ['SERVICE', 'CHNMED', 'CHNNCD', 'MEALS', 'VIP'])) {
  252. $params['order_is_complete'] = 'Y';
  253. $systemStatus = 'DONE';
  254. }
  255. }
  256. if ($params['settlement_now'] == 'Y' && ($params['pay_category'] == 'OFFLINE' || $params['pay_category'] == 'MONEY')) {
  257. if ($params['pay_category'] == 'OFFLINE' && !empty($params['pay_category_sub'])) {
  258. $params['pay_category'] = $params['pay_category_sub'];
  259. }
  260. $params['order_status_system'] = $systemStatus;
  261. $params['order_status_payment'] = 'SUCCESS';
  262. }
  263. if (($params['pay_constitute'] == 'Y' || $params['pay_category'] == 'QRCODE') && $params['settlement_now'] == 'Y' && !empty($params['qrcode_nbr'])) { // 付款码
  264. // 提交过来的支付分类
  265. $submitPayCategory = $params['pay_category'];
  266. // 账户支付的金额
  267. $accountAmount = $params['order_amount_pay'];
  268. if ($params['pay_constitute'] == 'Y' && $qrcodePayAmount > 0) {
  269. // 组合支付,支付金额改成需要付款码需要支付的金额
  270. $params['order_amount_pay'] = $qrcodePayAmount;
  271. }
  272. if ($params['pay_constitute'] == 'Y' && $qrcodePayAmount <= 0) {
  273. $params['order_status_system'] = $systemStatus;
  274. $params['order_status_payment'] = 'SUCCESS';
  275. }
  276. // 不组合或者组合后需要付款码的金额>0
  277. if ($params['pay_constitute'] == 'N' || ($params['pay_constitute'] == 'Y' && $qrcodePayAmount > 0)) {
  278. $result = OrderService::qrcodePay($params);
  279. $result = json_encode($result);
  280. $params['pay_json_response'] = $result;
  281. $result = json_decode($result, true);
  282. $prefix = substr($params['qrcode_nbr'], 0, 2);
  283. if (in_array($prefix, [10, 11, 12, 13, 14, 15])) {
  284. $params['pay_category'] = 'WXPAY';
  285. if ((!isset($result['return_code']) || $result['return_code'] != 'SUCCESS') || (!isset($result['result_code']) || $result['result_code'] != 'SUCCESS') || (empty($result['trade_state']) || $result['trade_state'] != 'SUCCESS')) {
  286. $params['order_status_system'] = 'PAYING';
  287. $params['order_status_payment'] = 'PENDING';
  288. $params['order_is_complete'] = 'N';
  289. // Db::rollBack();
  290. // return json_fail('支付失败');
  291. } else {
  292. $params['order_status_system'] = $systemStatus;
  293. $params['order_status_payment'] = 'SUCCESS';
  294. }
  295. } else if (in_array($prefix, [25, 26, 27, 28, 29, 30])) {
  296. $params['pay_category'] = 'ALIPAY';
  297. if ((!isset($result['code']) || $result['code'] != '10000') || (empty($result['trade_status']) || $result['trade_status'] != 'TRADE_SUCCESS')) {
  298. $params['order_status_system'] = 'PAYING';
  299. $params['order_status_payment'] = 'PENDING';
  300. $params['order_is_complete'] = 'N';
  301. // Db::rollBack();
  302. // return json_fail('支付失败');
  303. } else {
  304. $params['order_status_system'] = $systemStatus;
  305. $params['order_status_payment'] = 'SUCCESS';
  306. }
  307. } else {
  308. throw new BusinessException('付款码无效');
  309. }
  310. // 账户支付的金额
  311. $params['order_amount_pay'] = $accountAmount;
  312. }
  313. }
  314. $orderConfigJson = [];
  315. // 配送方式
  316. if (isset($params['delivery']) && ($params['delivery'] == 'PICKUP' || $params['delivery'] == 'ARRIVAL')) { // 自提/ 到店
  317. $orderConfigJson['premises'] = $params['dept_premises_id'];
  318. } else if (isset($params['delivery']) && $params['delivery'] == 'LOGISTICS') {
  319. // $params['order_express_json'] = json_encode([
  320. // 'express' => 'Y',
  321. // ]);
  322. }
  323. $params['order_config_json'] = json_encode($orderConfigJson);
  324. if (empty($paidOrder)) {
  325. // 写入主订单
  326. $this->insertMain($params);
  327. // 订单详情
  328. $this->insertSheet($params);
  329. } else {
  330. $params['orderGroupId'] = $paidOrder->order_groupby;
  331. $params['order_amount_paid'] = $paidOrder->order_amount_paid;
  332. $paidOrder->order_amount_paid = $paidOrder->order_amount_paid + $params['order_amount_pay'];
  333. $paidOrder->order_amount_pay = $paidOrder->order_amount_paid;
  334. if (floatval($paidOrder->order_amount_paid) >= $paidOrder->order_amount_total) {
  335. $paidOrder->order_is_complete = 'Y';
  336. $paidOrder->order_status_system = 'DONE';
  337. $paidOrder->order_status_payment = 'SUCCESS';
  338. // 更新sheet
  339. OrderSheet::where('join_sheet_order_id', $paidOrder->order_id)->update(['order_sheet_status' => 'DONE']);
  340. }
  341. $paidOrder->save();
  342. }
  343. // 支付记录
  344. $this->insertPayDetail($params);
  345. // $params['order_express_goods'] = json_encode(['sheet' => [$sheetId]]);
  346. // 2.4W 康养城
  347. $full = '';
  348. if ($params['goods_classify'] == 'VIP' && $params['order_status_payment'] == 'SUCCESS' && (!empty($paidOrder) && floatval($paidOrder->order_amount_paid) >= $paidOrder->order_amount_total || floatval($params['order_amount_pay']) >= $params['order_amount_total'])) {
  349. $full = '-满额';
  350. $params['member_id'] = $params['join_order_member_id'];
  351. Event::dispatch('order.kangyangCityVIP.grant', $params);
  352. }
  353. // 触发事件
  354. if (!empty($params['order_is_complete']) && $params['order_is_complete'] == 'Y' && $params['order_status_payment'] == 'SUCCESS') {
  355. // 入收支明细表
  356. $params['inout_category'] = '购买康养城VIP套餐包' . $full;
  357. Event::dispatch('statistics.inout.in', $params);
  358. }
  359. Db::commit();
  360. if ($params['settlement_now'] == 'Y' && $params['order_status_payment'] != 'SUCCESS') {
  361. _syslog("订单", "支付异常,检查是否有轮询");
  362. return json_throw(2001, '支付异常', ['order_id' => $params['orderId']]);
  363. }
  364. _syslog("订单", "创建订单成功");
  365. return json_success('创建订单成功');
  366. } catch (BusinessException $e) {
  367. Db::rollBack();
  368. dump($e->getMessage());
  369. dump($e->getTrace());
  370. _syslog("订单", $e->getMessage());
  371. return json_fail($e->getMessage());
  372. } catch (\Exception $e) {
  373. Db::rollBack();
  374. dump($e->getMessage());
  375. dump($e->getTrace());
  376. _syslog("订单", "创建订单失败");
  377. return json_fail('创建订单失败');
  378. }
  379. }
  380. /**
  381. * @Desc 支付
  382. * @Author Gorden
  383. * @Date 2024/9/5 13:12
  384. *
  385. * @param Request $request
  386. * @return Response
  387. */
  388. public function pay(Request $request)
  389. {
  390. $params = $request->post();
  391. // 验证线下付款密码
  392. if ($params['pay_constitute'] == 'N' && in_array($params['pay_category'], ['OFFLINE', 'MONEY'])) {
  393. $password = $params['offline_password'];
  394. if ($password != '666888') {
  395. return json_fail("密码错误,请重新输入");
  396. }
  397. }
  398. $order = Order::where('order_id', $params['order_id'])->first();
  399. if (!$order) {
  400. return json_fail('订单异常');
  401. }
  402. if ($order->order_status_system != 'PAYING') {
  403. return json_fail('订单不是可支付状态');
  404. }
  405. $params['orderId'] = $params['order_id'];
  406. $params['orderGroupId'] = 'OD' . date('ymdHi') . random_string(4, 'up');
  407. $order->order_groupby = $params['orderGroupId'];
  408. $goods = Goods::where('goods_id', $params['join_sheet_goods_id'])
  409. ->select('goods_id', 'goods_name', 'goods_classify')
  410. ->first();
  411. if (!$goods) {
  412. return json_fail('产品数据异常');
  413. }
  414. $goods = $goods->toArray();
  415. $params['goods_classify'] = $goods['goods_classify'] ?? '';
  416. $systemStatus = 'SENDING'; // 待发货
  417. // 立即结算
  418. if (in_array($params['goods_classify'], ['SERVICE', 'CHNMED', 'CHNNCD', 'MEALS', 'VIP'])) {
  419. $order->order_is_complete = 'Y';
  420. $systemStatus = 'DONE';
  421. }
  422. if ($params['goods_classify'] == 'PACKAGE' && $params['delivery'] == 'ARRIVAL') {
  423. $systemStatus = "WAITING";
  424. }
  425. $paymentStatus = 'PENDING';
  426. Db::beginTransaction();
  427. try {
  428. // 组合支付时,付款码应收金额
  429. $qrcodePayAmount = 0;
  430. if ($params['pay_category'] == 'OFFLINE' || $params['pay_category'] == 'MONEY') {
  431. $order->order_status_system = $systemStatus;
  432. $order->order_status_payment = 'SUCCESS';
  433. $paymentStatus = 'SUCCESS';
  434. if ($params['pay_category'] == 'OFFLINE' && !empty($params['pay_category_sub'])) {
  435. $params['pay_category'] = $params['pay_category_sub'];
  436. }
  437. }
  438. if (($params['pay_constitute'] == 'Y' || $params['pay_category'] == 'QRCODE') && !empty($params['qrcode_nbr'])) { // 付款码
  439. // 提交过来的支付分类
  440. $submitPayCategory = $params['pay_category'];
  441. // 账户支付的金额
  442. $accountAmount = $params['order_amount_pay'];
  443. if ($params['pay_constitute'] == 'Y' && $qrcodePayAmount > 0) {
  444. // 组合支付,改成需要付款码需要支付的金额
  445. $params['order_amount_pay'] = $qrcodePayAmount;
  446. }
  447. // 去支付
  448. $result = OrderService::qrcodePay($params);
  449. $result = json_encode($result);
  450. $params['pay_json_response'] = $result;
  451. $result = json_decode($result, true);
  452. $prefix = substr($params['qrcode_nbr'], 0, 2);
  453. if (in_array($prefix, [10, 11, 12, 13, 14, 15])) {
  454. $params['pay_category'] = 'WXPAY';
  455. if ((!isset($result['return_code']) || $result['return_code'] != 'SUCCESS') || (!isset($result['result_code']) || $result['result_code'] != 'SUCCESS') || (empty($result['trade_state']) || $result['trade_state'] != 'SUCCESS')) {
  456. $order->order_status_system = 'PAYING';
  457. $order->order_status_payment = 'PENDING';
  458. $order->order_is_complete = 'N';
  459. // Db::rollBack();
  460. // return json_fail('支付失败');
  461. } else {
  462. $order->order_status_system = $systemStatus;
  463. $order->order_status_payment = 'SUCCESS';
  464. $paymentStatus = 'SUCCESS';
  465. }
  466. } else if (in_array($prefix, [25, 26, 27, 28, 29, 30])) {
  467. $params['pay_category'] = 'ALIPAY';
  468. if ((!isset($result['code']) || $result['code'] != '10000') || (empty($result['trade_status']) || $result['trade_status'] != 'TRADE_SUCCESS')) {
  469. $order->order_status_system = 'PAYING';
  470. $order->order_status_payment = 'PENDING';
  471. $order->order_is_complete = 'N';
  472. // Db::rollBack();
  473. // return json_fail('支付失败');
  474. } else {
  475. $order->order_status_system = $systemStatus;
  476. $order->order_status_payment = 'SUCCESS';
  477. $paymentStatus = 'SUCCESS';
  478. }
  479. } else {
  480. throw new BusinessException('付款码无效');
  481. }
  482. // 账户支付的金额
  483. $params['order_amount_pay'] = $accountAmount;
  484. }
  485. $orderConfigJson = [];
  486. if (!empty($order->order_config_json)) {
  487. $orderConfigJson = json_decode($order->order_config_json, true);
  488. }
  489. $orderConfigJson['preferential'] = $params['preferential'] ?? '';
  490. if (isset($orderConfigJson['tableid']) && !empty($orderConfigJson['tableid'])) {
  491. SysDept::where('dept_id', $orderConfigJson['tableid'])->where('dept_category', '桌台')->update(['dept_status' => 'ACTIVED']);
  492. }
  493. $order->order_config_json = json_encode($orderConfigJson);
  494. $order->order_amount_paid = $order->order_amount_paid + $params['order_amount_pay'];
  495. $order->order_amount_pay = $order->order_amount_paid;
  496. // 康养城订单,支付完就结束了
  497. if ($order->order_status_payment == 'SUCCESS' && $params['goods_classify'] == 'VIP' && floatval($order->order_amount_paid) >= $order->order_amount_total) {
  498. $order->order_is_complete = 'Y';
  499. }
  500. if (floatval($order->order_amount_paid) < $order->order_amount_total) {
  501. $order->order_status_system = 'PAYING';
  502. $order->order_status_payment = 'PENDING';
  503. $order->order_is_complete = 'N';
  504. }
  505. // 主订单
  506. $order->save();
  507. // sheet
  508. if ($order->order_status_payment == 'SUCCESS') {
  509. $data = [
  510. 'order_sheet_status' => $systemStatus
  511. ];
  512. if (floatval($order->order_amount_paid) < $order->order_amount_total) {
  513. $data['order_sheet_status'] = 'BEING';
  514. }
  515. OrderSheet::where('join_sheet_order_id', $params['order_id'])->update($data);
  516. }
  517. // payDetail
  518. $payData = [
  519. 'pay_amount' => $params['order_amount_pay']
  520. ];
  521. if ($paymentStatus == 'SUCCESS') {
  522. $payData['pay_paytimes'] = date('Y-m-d H:i:s');
  523. $payData['pay_status'] = 'SUCCESS';
  524. }
  525. if ($params['pay_constitute'] == 'N' && in_array($params['pay_category'], ['WXPAY', 'ALIPAY'])) {
  526. $payData['pay_prepayid'] = $params['pay_category'];
  527. $payData['pay_json_response'] = $params['pay_json_response'];
  528. } else if ($params['pay_category'] == 'CASH') {
  529. $payData['pay_prepayid'] = $params['join_order_member_id'] . '-CASH';
  530. } else if ($params['pay_category'] == 'WELFARE') {
  531. $payData['pay_prepayid'] = $params['join_order_member_id'] . '-WELFARE';
  532. } else if ($params['pay_category'] == 'CARD') {
  533. $payData['pay_prepayid'] = $params['card_nbr'];
  534. } else if ($params['pay_category'] == 'OFFLINE') {
  535. $payData['pay_prepayid'] = 'OFFLINE';
  536. } else if ($params['pay_category'] == 'OFFLINE_ALIPAY') {
  537. $payData['pay_prepayid'] = 'OFFLINE_ALIPAY';
  538. } else if ($params['pay_category'] == 'OFFLINE_WXPAY') {
  539. $payData['pay_prepayid'] = 'OFFLINE_WXPAY';
  540. } else if ($params['pay_category'] == 'MONEY') {
  541. $payData['pay_prepayid'] = 'MONEY';
  542. }
  543. // 如果 是APP 过来的菜订单,可能没有paydetail
  544. // if (!PayDetail::where('join_pay_order_id', $order->order_groupby)->where('pay_category', '<>', 'WXPAY')->where('pay_category', '<>', 'ALIPAY')->exists()) {
  545. $payData['join_pay_member_id'] = $params['join_order_member_id'];
  546. $payData['join_pay_order_id'] = $order->order_groupby;
  547. $payData['pay_status'] = !empty($payData['pay_status']) && $payData['pay_status'] == 'SUCCESS' ? $payData['pay_status'] : 'WAITING';
  548. $payData['pay_category'] = $params['goods_classify'] ?? '';
  549. $payData['pay_paytimes'] = date('Y-m-d H:i:s');
  550. $payData['pay_json_request'] = json_encode($params); // {"pay-result": "支付成功", "result-datetime": "2024-07-29 18:38:21"}
  551. $payData['pay_json_response'] = $payData['pay_status'] == 'SUCCESS' ? json_encode([
  552. 'pay-result' => '支付成功', 'result-datetime' => date('Y-m-d H:i:s')
  553. ]) : '[]';
  554. $payData['join_pay_object_json'] = !empty($params['orderId']) ? json_encode(['order_id' => $params['orderId']]) : '[]';
  555. $payData['pay_addtimes'] = time();
  556. PayDetail::insert($payData);
  557. $full = '';
  558. // 2.4W 康养城
  559. if ($params['goods_classify'] == 'VIP' && $order->order_status_payment == 'SUCCESS' && floatval($order->order_amount_paid) >= $order->order_amount_total) {
  560. $full = '-满额';
  561. $params['member_id'] = $params['join_order_member_id'];
  562. Event::dispatch('order.kangyangCityVIP.grant', $params);
  563. }
  564. Db::commit();
  565. if ($order->order_is_complete == 'Y' && $order->order_status_payment == 'SUCCESS') {
  566. // 加销售量
  567. OrderSheetService::addGoodsSales($params['orderId']);
  568. Event::dispatch('order.complete', $params);
  569. }// 触发事件
  570. if ($paymentStatus == 'SUCCESS') {
  571. // 入收支明细表
  572. $params['inout_category'] = '购买康养城VIP套餐包' . $full;
  573. Event::dispatch('statistics.inout.in', $params);
  574. }
  575. if ($order->order_status_payment != 'SUCCESS' && $paymentStatus != 'SUCCESS') {
  576. // 已支付去掉这次的
  577. $order->order_amount_paid = $order->order_amount_paid - $params['order_amount_pay'];
  578. $order->order_amount_pay = $order->order_amount_paid;
  579. $order->save();
  580. _syslog("订单", "支付异常,检查是否有轮询");
  581. return json_throw(2001, '支付异常', ['order_id' => $params['orderId']]);
  582. }
  583. _syslog("订单", "订单支付成功");
  584. return json_success('支付成功');
  585. } catch (BusinessException $e) {
  586. dump($e->getMessage());
  587. Db::rollBack();
  588. _syslog("订单", "订单支付失败:" . $e->getMessage());
  589. return json_fail("支付失败:" . $e->getMessage());
  590. } catch (\Exception $e) {
  591. dump($e->getMessage());
  592. Db::rollBack();
  593. _syslog("订单", "订单支付失败");
  594. return json_fail('支付失败');
  595. }
  596. }
  597. /**
  598. * @Desc
  599. * @Author Gorden
  600. * @Date 2024/6/7 10:30
  601. *
  602. * @param $params
  603. * @return void
  604. * @throws BusinessException
  605. */
  606. public function insertMain($params)
  607. {
  608. try {
  609. $orderCategory = 'NORMAL';
  610. if (!empty($params['order_category'])) {
  611. $orderCategory = $params['order_category'];
  612. } else if (isset($params['submit_goods_classify']) && $params['submit_goods_classify'] == 'MEALS') {
  613. $orderCategory = 'DISHES';
  614. } else if (isset($params['goods_classify'])) {
  615. $orderCategory = $params['goods_classify'];
  616. }
  617. if (empty($params['order_extend_json'])) {
  618. $params['order_extend_json'] = [];
  619. } else {
  620. if (is_json($params['order_extend_json'])) {
  621. $params['order_extend_json'] = json_decode($params['order_extend_json'], true);
  622. }
  623. }
  624. // 推荐人
  625. $params['order_extend_json']['referee'] = $params['referee'] ?? '';
  626. $data = [
  627. 'order_id' => $params['orderId'],
  628. 'order_groupby' => $params['orderGroupId'],
  629. 'join_order_member_id' => $params['join_order_member_id'],
  630. 'order_name' => date('Y-m-d H:i:s') . '-订单',
  631. 'order_amount_total' => $params['order_amount_total'],
  632. 'order_amount_pay' => $params['order_amount_pay'],
  633. 'order_amount_paid' => $params['order_amount_pay'],
  634. 'order_category' => $orderCategory,
  635. 'order_classify' => $orderCategory,
  636. 'order_is_complete' => floatval($params['order_amount_pay']) >= floatval($params['order_amount_total']) && $params['order_status_payment'] == 'SUCCESS' ? 'Y' : 'N',
  637. 'order_status_system' => floatval($params['order_amount_pay']) >= floatval($params['order_amount_total']) && $params['order_status_payment'] == 'SUCCESS' ? 'DONE' : 'PAYING',
  638. 'order_status_payment' => floatval($params['order_amount_pay']) >= floatval($params['order_amount_total']) && $params['order_status_payment'] == 'SUCCESS' ? 'SUCCESS' : 'PENDING',
  639. 'order_status_storage' => $params['order_status_storage'],
  640. 'order_platform' => $params['order_platform'],
  641. 'order_remark' => $params['order_remark'] ?? '',
  642. 'order_discount_json' => $params['order_discount_json'] ?? '[]',
  643. 'order_config_json' => $params['order_config_json'] ?? '[]',
  644. 'order_express_json' => $params['order_express_json'] ?? '[]',
  645. 'order_extend_json' => $params['order_extend_json'] ? json_encode($params['order_extend_json']) : '[]',
  646. 'order_addtimes' => time()
  647. ];
  648. Order::insert($data);
  649. } catch (\Exception $e) {
  650. dump($e->getMessage());
  651. throw new BusinessException('订单创建信息失败');
  652. }
  653. }
  654. /**
  655. * @Desc
  656. * @Author Gorden
  657. * @Date 2024/6/7 10:25
  658. *
  659. * @param $params
  660. * @return void
  661. * @throws BusinessException
  662. */
  663. public function insertSheet($params)
  664. {
  665. try {
  666. $orderSheetIds = [];
  667. foreach ($params['goodsContentList'] as $goods) {
  668. //{"unit": "份", "table": null, "premises": "15"}
  669. $price = floatval($goods['goods_sales_price']);
  670. $extendJson['unit'] = $goods['sku_name'];
  671. if (isset($params['submit_premises_id'])) {
  672. $extendJson['premises'] = $params['submit_premises_id'];
  673. }
  674. if (isset($params['submit_goods_classify']) && $params['submit_goods_classify'] == 'MEALS') {
  675. $extendJson['table'] = null;
  676. }
  677. $orderSheetStatus = 'PAYING';
  678. if ($params['settlement_now'] == 'Y' && $params['order_status_payment'] == 'SUCCESS') {
  679. if (floatval($params['order_amount_pay']) >= floatval($params['order_amount_total'])) {
  680. $orderSheetStatus = 'DONE';
  681. } else {
  682. $orderSheetStatus = 'BEING';
  683. }
  684. }
  685. $data = [
  686. 'join_sheet_member_id' => $params['join_order_member_id'],
  687. 'join_sheet_order_id' => $params['orderId'],
  688. 'join_sheet_goods_id' => $goods['goods_id'],
  689. 'join_sheet_goods_sku_id' => $goods['sku_id'],
  690. 'order_sheet_status' => $orderSheetStatus,
  691. 'order_sheet_category' => (isset($params['submit_goods_classify']) && $params['submit_goods_classify'] == 'MEALS') ? 'DISHES' : 'NORMAL',
  692. 'order_sheet_num' => $goods['nbr'],
  693. 'order_sheet_price' => $goods['goods_sales_price'],
  694. 'order_sheet_price_pay' => $goods['goods_sales_price'],
  695. 'order_sheet_amount' => $price * $goods['nbr'],
  696. 'order_sheet_pay' => $price * $goods['nbr'],
  697. 'order_sheet_task_status' => 'NONE',
  698. 'order_sheet_remark' => $params['order_remark'] ?? '',
  699. 'order_sheet_addtimes' => time(),
  700. 'order_sheet_extend_json' => json_encode($extendJson)
  701. ];
  702. $orderSheetId = OrderSheet::insertGetId($data);
  703. $orderSheetIds[] = $orderSheetId;
  704. // 减库存,规格和总库存
  705. if (!isset($params['submit_goods_classify']) || !in_array($params['submit_goods_classify'], ['MEALS', 'PACKAGE'])) {
  706. $goodsSku = GoodsSku::where('goods_sku_id', $goods['sku_id'])->first();
  707. $skuStorageJson = json_decode($goodsSku->goods_sku_storage_json, true);
  708. if (isset($skuStorageJson['storage']) && !empty($skuStorageJson['storage'])) {
  709. $skuStorageJson['storage'] = $skuStorageJson['storage'] - $goods['nbr'];
  710. }
  711. if (!isset($skuStorageJson['storage']) || (!empty($skuStorageJson['storage']) && $skuStorageJson['storage'] < 0)) {
  712. throw new BusinessException('库存不足');
  713. }
  714. $goodsSku->goods_sku_storage_json = json_encode($skuStorageJson);
  715. $goodsSku->save();
  716. }
  717. $goodsRunning = GoodsRunning::where('join_running_goods_id', $goods['goods_id'])->first();
  718. $goodsRunning->goods_running_storage = $goodsRunning->goods_running_storage - $goods['nbr'];
  719. if ($goodsRunning->goods_running_storage < 0) {
  720. throw new BusinessException('库存不足');
  721. }
  722. if ($params['order_status_payment'] == 'SUCCESS') {
  723. $goodsRunning->goods_running_sale = $goodsRunning->goods_running_sale + $goods['nbr'];
  724. }
  725. $goodsRunning->save();
  726. }
  727. return $orderSheetIds;
  728. } catch (\support\exception\BusinessException $e) {
  729. dump($e->getMessage() . '||' . $e->getLine());
  730. throw new BusinessException($e->getMessage());
  731. } catch (\Exception $e) {
  732. dump($e->getMessage() . '||' . $e->getLine());
  733. throw new BusinessException('订单创建失败');
  734. }
  735. }
  736. /**
  737. * @Desc
  738. * @Author Gorden
  739. * @Date 2024/6/7 10:35
  740. *
  741. * @param $params
  742. * @return void
  743. * @throws BusinessException
  744. */
  745. public function insertPayDetail($params)
  746. {
  747. try {
  748. if (in_array($params['pay_category'], ['WXPAY', 'ALIPAY'])) {
  749. $payPrepayid = $params['pay_category'];
  750. } else if ($params['pay_category'] == 'OFFLINE') {
  751. $payPrepayid = 'OFFLINE';
  752. } else if ($params['pay_category'] == 'OFFLINE_ALIPAY') {
  753. $payPrepayid = 'OFFLINE_ALIPAY';
  754. } else if ($params['pay_category'] == 'OFFLINE_WXPAY') {
  755. $payPrepayid = 'OFFLINE_WXPAY';
  756. } else if ($params['pay_category'] == 'MONEY') {
  757. $payPrepayid = 'MONEY';
  758. } else {
  759. $payPrepayid = $params['join_order_member_id'] . '-' . $params['pay_category'];
  760. }
  761. $data = [
  762. 'join_pay_member_id' => $params['join_order_member_id'],
  763. 'join_pay_order_id' => $params['orderGroupId'],
  764. 'pay_status' => $params['settlement_now'] == 'Y' && $params['order_status_payment'] == 'SUCCESS' ? 'SUCCESS' : 'WAITING',
  765. 'pay_category' => $params['goods_classify'],
  766. 'pay_amount' => $params['order_amount_pay'],
  767. 'pay_prepayid' => $payPrepayid,
  768. 'pay_paytimes' => date('Y-m-d H:i:s'),
  769. 'join_pay_object_json' => !empty($params['orderId']) ? json_encode(['order_id' => $params['orderId']]) : '[]',
  770. 'pay_json_request' => json_encode($params),
  771. 'pay_json_response' => $params['pay_json_response'] ?? '[]',
  772. 'pay_remark' => $params['order_remark'] ?? '',
  773. 'pay_addtimes' => time(),
  774. ];
  775. PayDetail::insert($data);
  776. } catch (\Exception $e) {
  777. dump($e->getMessage());
  778. throw new BusinessException('创建支付记录失败');
  779. }
  780. }
  781. /**
  782. * @Desc 订单商品详情
  783. * @Author Gorden
  784. * @Date 2024/3/29 8:50
  785. *
  786. * @param Request $request
  787. * @return Response
  788. */
  789. public function sheet(Request $request)
  790. {
  791. try {
  792. $orderId = $request->get('order_id');
  793. $orderSheet = OrderSheet::with([
  794. 'member' => function ($query) {
  795. $query->select('member_id', 'member_mobile', 'member_is_owner', 'member_is_vip', 'member_is_partner', 'member_is_referrer', 'join_member_role_id');
  796. },
  797. 'goods' => function ($query) {
  798. $query->select('goods_id', 'goods_name', 'goods_cover', 'goods_market_price', 'goods_sales_price', 'goods_classify', 'goods_if_express');
  799. },
  800. 'memberInfo',
  801. 'cert',
  802. 'sku' => function ($query) {
  803. $query->where('goods_sku_status', 'ON')
  804. ->select('goods_sku_id', 'join_sku_goods_id', 'goods_sku_specs_json', 'goods_sku_sales_price');
  805. },
  806. 'skus',
  807. 'refund' => function ($query) {
  808. $query->select('join_return_order_id', 'order_return_status');
  809. }
  810. ])->where('join_sheet_order_id', $orderId)
  811. ->orderBy('order_sheet_id', 'DESC')
  812. ->get()
  813. ->toArray();
  814. $order = Order::where('order_id', $orderId)->first();
  815. $express = OrderExpress::where('join_express_order_id', $orderId)->first();
  816. $premises = '';
  817. if ($express && $express->order_express_type == '自提') {
  818. $premises = $express->order_express_company;
  819. }
  820. $sheetAmount = 0;
  821. foreach ($orderSheet as &$item) {
  822. $sheetAmount += $item['order_sheet_amount'];
  823. $item['goods']['goods_cover'] = getenv('STORAGE_DOMAIN') . $item['goods']['goods_cover'];
  824. if (!empty($item['goods']) && $item['goods']['goods_classify'] == 'PACKAGE') {
  825. $components = GoodsComponent::with('goods')
  826. ->where('join_component_master_goods_id', $item['goods']['goods_id'])
  827. ->select('join_component_master_goods_id', 'join_component_goods_id', 'goods_component_price',
  828. 'goods_component_price', 'goods_component_json')
  829. ->get()
  830. ->toArray();
  831. $goodsArr = [];
  832. foreach ($components as $component) {
  833. $configJson = !empty($component['goods_component_json']) ? json_decode($component['goods_component_json'], true) : [];
  834. if (!empty($component['goods'])) {
  835. $supplierName = Supplier::where('supplier_id', $component['goods']['join_goods_supplier_id'])->value('supplier_name');
  836. $benefit = MemberBenefit::where('join_benefit_member_id', $item['join_sheet_member_id'])
  837. ->where('join_benefit_goods_id', $component['goods']['goods_id'])
  838. ->where('join_benefit_order_id', $orderId)
  839. ->first();
  840. $goodsArr[] = [
  841. 'goods_name' => $component['goods']['goods_name'],
  842. 'goods_cover' => getenv('STORAGE_DOMAIN') . $component['goods']['goods_cover'],
  843. 'supplier_name' => $supplierName,
  844. 'nbr' => $configJson['nbr'] ?? 0,
  845. 'used' => !empty($benefit->member_benefit_used_count) ? intval($benefit->member_benefit_used_count) : ''
  846. ];
  847. }
  848. }
  849. $item['goods']['components'] = $goodsArr;
  850. }
  851. if (!empty($item['sku'])) {
  852. if (!empty($item['sku']['goods_sku_specs_json'])) {
  853. $specsJson = json_decode($item['sku']['goods_sku_specs_json'], true);
  854. $skuName = '';
  855. foreach ($specsJson as $specsKey => $skuSpecs) {
  856. if (is_array($skuSpecs)) {
  857. $skuName = $skuName . ' ' . implode(' ', $skuSpecs) . ';';
  858. } else {
  859. $skuName = $skuName . ' ' . $skuSpecs . ';';
  860. }
  861. }
  862. $item['sku']['goods_sku_title'] = rtrim($skuName, ';');
  863. }
  864. }
  865. if (!empty($item['skus'])) {
  866. foreach ($item['skus'] as $key => $skus) {
  867. if (!empty($skus['goods_sku_specs_json'])) {
  868. $item['skus'][$key]['goods_sku_specs_json'] = json_decode($skus['goods_sku_specs_json']);
  869. $skuName = '';
  870. foreach ($item['skus'][$key]['goods_sku_specs_json'] as $specsKey => $skuSpecs) {
  871. $keyStr = ($specsKey == '规格') ? '' : ($specsKey . ':');
  872. if (is_array($skuSpecs)) {
  873. $skuName = $skuName . $keyStr . ' ' . implode(' ', $skuSpecs) . '; ';
  874. } else {
  875. $skuName = $skuName . $keyStr . ' ' . $skuSpecs . '; ';
  876. }
  877. }
  878. $item['skus'][$key]['sku_name'] = rtrim($skuName, '; ');
  879. }
  880. }
  881. } else {
  882. $item['skus'] = [];
  883. }
  884. if (in_array($item['goods']['goods_classify'], ['SERVICE', 'CHNMED', 'CHNNCD', 'PACKAGE']) && $order->order_status_system == 'DONE') {
  885. $item['appontment'] = [];
  886. $appontments = Appointment::where('join_appointment_order_id', $orderId)
  887. ->where('appointment_status', 'DONE')
  888. ->select('appointment_status', 'appointment_id', 'appointment_done_datetime', 'appointment_done_json', 'appointment_apply_json')
  889. ->get()
  890. ->toArray();
  891. foreach ($appontments as $appontment) {
  892. $doneJson = [];
  893. $username = '';
  894. if (!empty($appontment['appointment_done_json'])) {
  895. $doneJson = json_decode($appontment['appointment_done_json'], true);
  896. if (isset($doneJson['charge'])) {
  897. $username = SysUser::where('user_id', $doneJson['charge']['charge_user_id'])->value('user_name');
  898. }
  899. }
  900. $person = 1;
  901. if (!empty($appontment->appointment_apply_json)) {
  902. $applyJson = json_decode($appontment->appointment_apply_json, true);
  903. if (isset($applyJson['person'])) {
  904. $person = $applyJson['person'];
  905. }
  906. }
  907. $item['appontment'][] = [
  908. 'member' => ($item['cert'] ? $item['cert']['member_cert_name'] . '-' : '') . ($item['member'] ? $item['member']['member_mobile'] : ''),
  909. 'goods_name' => $item['goods']['goods_name'],
  910. 'premisses' => isset($doneJson['charge']) ? $doneJson['charge']['charge_premises'] : '',
  911. 'username' => $username,
  912. 'nbr' => $person,
  913. 'done_time' => $appontment['appointment_done_datetime'],
  914. 'appointment_status' => $appontment['appointment_status'],
  915. ];
  916. }
  917. }
  918. if (!empty($item['order_sheet_extend_json']) && !$express) {
  919. $extendJson = json_decode($item['order_sheet_extend_json'], true);
  920. if (isset($extendJson['address_id'])) {
  921. $address = ClientConfig::where('client_config_id', $extendJson['address_id'])->first();
  922. if (!empty($address)) {
  923. $valJson = json_decode($address->client_config_val_json, true);
  924. $express = [
  925. 'order_express_address' => $valJson['address'] . ($valJson['numbers'] ?? ''),
  926. 'order_express_city' => $valJson['city'],
  927. 'order_express_mobile' => $valJson['mobile'],
  928. 'order_express_person' => $valJson['person']
  929. ];
  930. }
  931. }
  932. }
  933. $item['member']['level'] = '普通会员';
  934. if (!empty($item['member']['join_member_role_id'])) {
  935. $item['member']['level'] = MemberRole::where('member_role_id', $item['member']['join_member_role_id'])->value('member_role_name');
  936. }
  937. $item['member_info']['member_info_nickname'] = MemberService::getNickname(!empty($item['member_info']) ? $item['member_info']['member_info_nickname'] : '', (!empty($item['member']) ? $item['member']['member_mobile'] : ''));
  938. $item['member_info']['member_info_headimg'] = MemberService::getAvatarUrl(!empty($item['member_info']) && !empty($item['member_info']['member_info_headimg']) ? $item['member_info']['member_info_headimg'] : '');
  939. }
  940. $order->sheet_amount = number_format($sheetAmount, 2);
  941. $payDetails = PayDetail::whereJsonContains('join_pay_object_json->order_id', $order->order_id)
  942. ->where('pay_category', 'VIP')
  943. ->where('pay_status', 'SUCCESS')
  944. ->select('pay_id', 'pay_category', 'pay_prepayid', 'pay_paytimes', 'pay_status', 'pay_amount', 'pay_extend_json')
  945. ->orderBy('pay_addtimes', 'DESC')
  946. ->get();
  947. $order->pay_amount_total = 0;
  948. foreach ($payDetails as &$payDetail) {
  949. $categoryArray = explode('-', $payDetail->pay_prepayid);
  950. if (isset($categoryArray[1])) {
  951. $payDetail->pay_category = $categoryArray[1];
  952. } else if (in_array($categoryArray[0], ['WXPAY', 'ALIPAY', 'OFFLINE', 'OFFLINE_ALIPAY', 'OFFLINE_WXPAY', 'MONEY'])) {
  953. $payDetail->pay_category = $categoryArray[0];
  954. }
  955. if (!empty($payDetail->pay_extend_json)) {
  956. $payExtendJson = json_decode($payDetail->pay_extend_json, true);
  957. $order->cancel_times = $payExtendJson['cancel_times'] ?? '';
  958. if (isset($payExtendJson['ticket'])) {
  959. $payDetail->ticket = str_replace('/thumb', '', getenv("STORAGE_DOMAIN") . $payExtendJson['ticket']);
  960. }
  961. }
  962. $order->pay_amount_total += $payDetail->pay_amount;
  963. }
  964. $refund = OrderReturn::where('join_return_order_id', $orderId)
  965. ->select('order_return_status', 'order_return_apply_datetime', 'order_return_apply_json', 'order_return_accept_datetime', 'order_return_refund_json', 'order_return_extend_json')
  966. ->first();
  967. if (!empty($refund->order_return_refund_json)) {
  968. $returnRefundJson = json_decode($refund->order_return_refund_json, true);
  969. if (isset($returnRefundJson['user_id'])) {
  970. $userName = SysUser::where('user_id', $returnRefundJson['user_id'])->value('user_name');
  971. $returnRefundJson['person'] = $userName;
  972. unset($returnRefundJson['user_id']);
  973. }
  974. $refund->order_return_refund_json = json_encode($returnRefundJson);
  975. }
  976. if (!empty($order->order_config_json)) {
  977. $orderConfigJson = json_decode($order->order_config_json, true);
  978. if (isset($orderConfigJson['reach'])) {
  979. $order->reach = $orderConfigJson['reach'];
  980. }
  981. if (isset($orderConfigJson['table'])) {
  982. $order->table = $orderConfigJson['table'];
  983. }
  984. if (isset($orderConfigJson['eat'])) {
  985. $order->eat = $orderConfigJson['eat'];
  986. }
  987. if (isset($orderConfigJson['express'])) {
  988. $order->express = $orderConfigJson['express'];
  989. }
  990. if (isset($orderConfigJson['premises'])) {
  991. $order->premises = $orderConfigJson['premises'];
  992. }
  993. if (isset($orderConfigJson['tableid'])) {
  994. $order->dept_table_id = $orderConfigJson['tableid'];
  995. }
  996. }
  997. if (!empty($order->order_extend_json)) {
  998. $orderExtendJson = json_decode($order->order_extend_json, true);
  999. $order->referee = $orderExtendJson['referee'] ?? '';
  1000. if (isset($orderExtendJson['cancel_times'])) {
  1001. $order->cancel_times = $orderExtendJson['cancel_times'];
  1002. }
  1003. if (isset($orderExtendJson['free_remark'])) {
  1004. $order->free_remark = $orderExtendJson['free_remark'];
  1005. }
  1006. }
  1007. $discount = ['coupon_name' => '', 'classify' => '', 'value' => 0];
  1008. if (!empty($order->order_discount_json)) {
  1009. $orderDiscountJson = json_decode($order->order_discount_json, true);
  1010. foreach ($orderDiscountJson as $discountItem) {
  1011. if (!empty($discountItem['coupon_id'])) {
  1012. $coupon = Coupon::where('coupon_id', $discountItem['coupon_id'])
  1013. ->select('coupon_name', 'coupon_classify', 'coupon_category', 'coupon_value', 'coupon_minimum_limit')
  1014. ->first();
  1015. if (!$coupon) {
  1016. continue;
  1017. }
  1018. $classify = CouponService::couponClassifyInfo($coupon->coupon_classify, $coupon->coupon_category, $coupon->coupon_value, $coupon->coupon_minimum_limit);
  1019. $discount['coupon_name'] .= $coupon->coupon_classify . ':' . $coupon->coupon_name . '(优惠¥' . sprintf("%.2f", $discountItem['coupon_value']) . '), ';
  1020. }
  1021. if ($discountItem['coupon_classify'] == '退款') {
  1022. continue;
  1023. }
  1024. if (empty($discountItem['coupon_id']) && !empty($discountItem['coupon_classify'])) {
  1025. if (!empty($discountItem['coupon_detail_id'])) {
  1026. $discount['classify'] .= $discountItem['coupon_detail_id'][0] . '(优惠¥' . sprintf("%.2f", $discountItem['coupon_value']) . '), ';
  1027. } else {
  1028. $discount['classify'] .= $discountItem['coupon_classify'] . '(优惠¥' . sprintf("%.2f", $discountItem['coupon_value']) . '), ';
  1029. }
  1030. }
  1031. if (!empty($discountItem['coupon_value'])) {
  1032. $discount['value'] += $discountItem['coupon_value'];
  1033. }
  1034. }
  1035. if (!empty($discount['coupon_name'])) {
  1036. $discount['coupon_name'] = rtrim($discount['coupon_name'], ', ');
  1037. }
  1038. if (!empty($discount['classify'])) {
  1039. $discount['classify'] = rtrim($discount['classify'], ', ');
  1040. }
  1041. }
  1042. $discount['value'] = sprintf("%.2f", $discount['value']);
  1043. $order->discount = $discount;
  1044. $order->premises = $order->premises ?? $premises;
  1045. $data = [
  1046. 'order' => $order,
  1047. 'refund' => json_decode(json_encode($refund)),
  1048. 'sheet' => json_decode(json_encode($orderSheet)),
  1049. 'express' => json_decode(json_encode($express)),
  1050. 'payDetails' => json_decode(json_encode($payDetails))
  1051. ];
  1052. return json_success('', $data);
  1053. } catch (\Exception $e) {
  1054. dump($e->getMessage());
  1055. }
  1056. }
  1057. /**
  1058. * @Desc 获取分期的订单
  1059. * @Author Gorden
  1060. * @Date 2024/9/10 15:14
  1061. *
  1062. * @param Request $request
  1063. * @return Response
  1064. */
  1065. public function getPaidOrder(Request $request)
  1066. {
  1067. $memberId = $request->get('member_id');
  1068. if (!$memberId) {
  1069. return json_fail('参数异常');
  1070. }
  1071. $order = Order::where('join_order_member_id', $memberId)
  1072. ->where('order_category', 'VIP')
  1073. ->where('order_status_system', 'PAYING')
  1074. ->select('order_id', 'order_amount_total', 'order_amount_paid', 'order_amount_pay')
  1075. ->first();
  1076. return json_success('', $order);
  1077. }
  1078. /**
  1079. * @Desc 上传支付凭证
  1080. * @Author Gorden
  1081. * @Date 2024/9/12 10:14
  1082. *
  1083. * @param Request $request
  1084. * @return Response
  1085. */
  1086. public function uploadTicket(Request $request)
  1087. {
  1088. $payId = $request->post('pay_id');
  1089. $url = $request->post('url');
  1090. if (!$payId || !$url) {
  1091. return json_fail("参数异常");
  1092. }
  1093. $url = str_replace(getenv("STORAGE_DOMAIN"), '', $url);
  1094. try {
  1095. $payDetail = PayDetail::where('pay_id', $payId)->first();
  1096. if (!$payDetail) {
  1097. return json_fail('数据异常');
  1098. }
  1099. $extendJson = [];
  1100. if (!empty($payDetail->pay_extend_json)) {
  1101. $extendJson = json_decode($payDetail->pay_extend_json, true);
  1102. }
  1103. $extendJson['ticket'] = $url;
  1104. $payDetail->pay_extend_json = json_encode($extendJson);
  1105. dump($payDetail->save());
  1106. return json_success('success');
  1107. } catch (\Exception $e) {
  1108. return json_fail("上传附件失败");
  1109. }
  1110. }
  1111. }