PartnerController.php 64 KB

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