ReferrerController.php 62 KB

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