AppointmentService.php 40 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725
  1. <?php
  2. namespace app\admin\service\order;
  3. use app\admin\controller\member\BenefitController;
  4. use app\admin\controller\member\QuotaController;
  5. use app\model\Appointment;
  6. use app\model\Goods;
  7. use app\model\GoodsSku;
  8. use app\model\Member;
  9. use app\model\MemberAccount;
  10. use app\model\MemberBenefit;
  11. use app\model\MemberCert;
  12. use app\model\MemberInfo;
  13. use app\model\MemberQuota;
  14. use app\model\Order;
  15. use app\model\OrderSheet;
  16. use app\model\PayDetail;
  17. use app\model\SysDept;
  18. use app\model\SysSerial;
  19. use support\Db;
  20. use support\exception\BusinessException;
  21. use support\Request;
  22. use function _PHPStan_cc8d35ffb\RingCentral\Psr7\str;
  23. class AppointmentService
  24. {
  25. public static function select(Request $request)
  26. {
  27. $page = $request->get('page');
  28. $pageSize = $request->get('pageSize');
  29. $id = $request->get('id', '');
  30. $mobile = $request->get('mobile', '');
  31. $status = $request->get('status', '');
  32. $premisesName = $request->get('premises', '');
  33. $appointmentMode = $request->get('appointment_mode', '');
  34. $rows = Db::table('appointment')
  35. ->leftJoin('member', 'member.member_id', '=', 'appointment.join_appointment_member_id')
  36. ->leftJoin('member_cert', 'member_cert.join_cert_member_id', '=', 'appointment.join_appointment_member_id')
  37. ->leftJoin('member_info', 'member_info.join_info_member_id', '=', 'appointment.join_appointment_member_id')
  38. ->leftJoin('goods', 'goods.goods_id', '=', 'appointment.join_appointment_goods_id')
  39. ->leftJoin('order', 'order.order_id', '=', 'appointment.join_appointment_order_id')
  40. ->leftJoin('member_benefit', 'member_benefit.member_benefit_id', '=', 'appointment.join_appointment_member_benefit_id')
  41. ->leftJoin('goods_sku', 'goods_sku.goods_sku_id', '=', 'appointment.join_appointment_goods_sku_id')
  42. ->whereIn('appointment_status',['PAYING','WAITING','PENDING','DOING','DONE','CANCEL','REVOKE'])
  43. ->when($id != '', function ($query) use ($id) {
  44. $query->where('appointment.appointment_id', 'like', '%' . $id . '%');
  45. })->when($mobile != '', function ($query) use ($mobile) {
  46. $query->where(function($query2) use ($mobile) {
  47. $query2->where('member.member_mobile', 'like', '%' . $mobile . '%')
  48. ->orWhere('member_cert.member_cert_name', 'like', '%' . $mobile . '%');
  49. });
  50. })->when($status != '', function ($query) use ($status) {
  51. $query->where('appointment.appointment_status', $status);
  52. })->when($premisesName != '',function($query) use ($premisesName){
  53. $query->whereJsonContains('appointment_apply_json->premises',$premisesName);
  54. })->when($appointmentMode != '',function($query) use ($appointmentMode){
  55. if($appointmentMode == 'ONLINE'){
  56. $query->whereIn('appointment_mode',['ONLINE','ORDER']);
  57. }else{
  58. $query->where('appointment_mode',$appointmentMode);
  59. }
  60. });
  61. $total = $rows->count('member.member_id');
  62. $rows = $rows->select('appointment.*',
  63. 'member.member_mobile',
  64. 'member_cert.member_cert_name',
  65. 'member_info.member_info_nickname',
  66. 'goods.goods_name', 'goods.goods_cover', 'goods.goods_sales_price',
  67. 'order.order_id','order.order_name', 'goods_sku.goods_sku_specs_json', 'order.order_amount_total', 'order.order_amount_pay',
  68. 'order.order_category', 'order.order_status_system', 'order.order_status_payment', 'order.order_status_storage',
  69. 'order.order_addtimes',
  70. 'member_benefit.member_benefit_name','member_benefit.member_benefit_id as benefit_id'
  71. )
  72. ->orderBy('appointment.appointment_addtimes', 'desc')
  73. ->forPage($page, $pageSize)
  74. ->get();
  75. foreach ($rows as &$row) {
  76. $row->goods_cover = getenv('STORAGE_DOMAIN') . $row->goods_cover;
  77. $row->goods_sku_specs_json = !empty($row->goods_sku_specs_json) ? json_decode($row->goods_sku_specs_json, true) : [];
  78. $row->order_addtimes = date('Y-m-d H:i:s', $row->order_addtimes);
  79. $row->appointment_addtimes = date('Y-m-d H:i:s', $row->appointment_addtimes);
  80. $row->appointment_apply_json = !empty($row->appointment_apply_json) ? json_decode($row->appointment_apply_json,true) : [];
  81. $row->appointment_doing_json = !empty($row->appointment_doing_json) ? json_decode($row->appointment_doing_json,true) : [];
  82. $row->appointment_result_json = !empty($row->appointment_result_json) ? json_decode($row->appointment_result_json,true) : [];
  83. if ($row->appointment_category == 'NOFEE') {
  84. $row->member_benefit_name = "后付费预约";
  85. }elseif ($row->appointment_category == 'GREENWAY'){
  86. $row->member_benefit_name = "就医绿通";
  87. }
  88. if (!empty($row->appointment_apply_json)) {
  89. $applyJson = $row->appointment_apply_json;
  90. $row->person = $applyJson['person'] ?? '';
  91. $row->appointment_times = $applyJson['times'] ?? '';
  92. }
  93. $skus = GoodsSku::where('join_sku_goods_id',$row->join_appointment_goods_id)
  94. ->where('goods_sku_id',$row->join_appointment_goods_sku_id)
  95. ->select('goods_sku_id','goods_sku_specs_json','goods_sku_sales_price')
  96. ->get();
  97. $skuJson = [];
  98. foreach ($skus as $key => $sku){
  99. if (!empty($sku->goods_sku_specs_json)) {
  100. $specsJson = json_decode($sku->goods_sku_specs_json, true);
  101. $skuTitle = '';
  102. foreach ($specsJson as $item3) {
  103. if (is_array($item3)) {
  104. $item3 = implode(',', $item3);
  105. }
  106. $skuTitle .= $item3 . '-';
  107. }
  108. $skuJson[$key] = [
  109. 'goods_sku_id' => $sku->goods_sku_id,
  110. 'goods_sku_sales_price' => $sku->goods_sku_sales_price,
  111. 'sku_name' => rtrim($skuTitle, '-')
  112. ];
  113. }
  114. }
  115. $row->sku = $skuJson;
  116. }
  117. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  118. }
  119. public static function confirm($id)
  120. {
  121. $appointment = Appointment::where('appointment_id', $id)->where('appointment_status', 'WAITING')->first();
  122. if (!$appointment) {
  123. return json_fail('数据异常');
  124. }
  125. try {
  126. $appointment->appointment_status = 'PENDING';
  127. $appointment->save();
  128. return json_success('操作成功');
  129. } catch (\Exception $e) {
  130. dump($e->getMessage());
  131. return json_fail("操作失败");
  132. }
  133. }
  134. public static function add(Request $request)
  135. {
  136. $params = $request->post();
  137. Db::beginTransaction();
  138. try {
  139. // 先检查选择的时段是否可预约
  140. $goods = Goods::where('goods_id', $params['join_appointment_goods_id'])->first();
  141. // $appointments = Appointment::where('appointment_datetime', $params['appointment_datetime'])->get()->toArray();
  142. // if ($goods->is_support_appointment == 'Y' && !empty($goods->goods_attribute_json)) {
  143. // $extendJson = json_decode($goods->goods_attribute_json, true);
  144. // foreach ($extendJson['times'] as $key => $time) {
  145. // if ($time['duration'] == $params['appointment_times']) {
  146. // if (!empty($appointments)) {
  147. // foreach ($appointments as $appointment) {
  148. // $applyJson = json_decode($appointment['appointment_apply_json'], true);
  149. // $applyJsonTimes = $applyJson['times'] ?? '';
  150. // if ($time['duration'] == $applyJsonTimes) {
  151. // $extendJson['times'][$key]['person'] -= $applyJson['person'];
  152. // if ($extendJson['times'][$key]['person'] < $params['person']) {
  153. // return json_fail('当前时段名额不足,请选择其他时段');
  154. // }
  155. // }
  156. // }
  157. // } else {
  158. // if ($extendJson['times'][$key]['person'] < $params['person']) {
  159. // return json_fail('当前时段名额不足,请选择其他时段');
  160. // }
  161. // }
  162. // }
  163. // }
  164. // }
  165. // 如果没有,新建
  166. if (empty($params['join_appointment_member_id']) && !empty($params['username']) && !empty($params['mobile'])) {
  167. if(Member::where('member_mobile',$params['mobile'])->exists()){
  168. Db::rollBack();
  169. return json_fail('会员已存在,请勿重复创建');
  170. }
  171. $memberId = "MR" . str_pad(SysSerial::getSerial(), 16, "0", STR_PAD_LEFT) . random_string(6, 'up');
  172. $params['join_appointment_member_id'] = $memberId;
  173. // 主表
  174. $memberData = [
  175. 'member_id' => $memberId,
  176. 'member_is_owner' => 'N',
  177. 'member_classify' => 'MEMBER',
  178. 'member_status' => 'ACTIVED',
  179. 'member_mobile' => $params['mobile'],
  180. 'member_extend_json'=>json_encode(['come_from'=>'SYSTEM']),
  181. 'member_addtimes' => time()
  182. ];
  183. Member::insert($memberData);
  184. // 账户表
  185. $accountData = [
  186. 'join_account_member_id' => $memberId,
  187. 'member_account_classify' => 'POINTS',
  188. 'member_account_status' => 'ACTIVED',
  189. 'member_account_category' => 'NORMAL',
  190. 'member_account_nbr' => $memberId . '-POINTS',
  191. 'member_account_name' => '积分账户',
  192. 'member_account_addtimes' => time()
  193. ];
  194. // 积分账户
  195. MemberAccount::insert($accountData);
  196. $accountData['member_account_classify'] = 'CASH';
  197. $accountData['member_account_nbr'] = $memberId . '-CASH';
  198. $accountData['member_account_name'] = '余额账户';
  199. // 现金/余额账户
  200. MemberAccount::insert($accountData);
  201. // cert
  202. // $certData = [
  203. // 'join_cert_member_id' => $memberId,
  204. // 'member_cert_name' => $params['username']
  205. // ];
  206. // MemberCert::insert($certData);
  207. // info
  208. $infoData = [
  209. 'join_info_member_id' => $memberId,
  210. 'member_info_nickname' => $params['username']
  211. ];
  212. MemberInfo::insert($infoData);
  213. }
  214. $appointmentId = "AP" . date('YmdHis') . random_string(6, 'up');
  215. $data = [
  216. 'appointment_id' => $appointmentId,
  217. 'join_appointment_member_id' => $params['join_appointment_member_id'] ?? '',
  218. 'join_appointment_goods_id' => $params['join_appointment_goods_id'] ?? '',
  219. 'join_appointment_goods_sku_id' => $params['join_appointment_goods_sku_id'] ?? '',
  220. 'appointment_status' => $params['appointment_status'] ?? '',
  221. 'appointment_datetime' => isset($params['appointment_datetime']) ? date('Y-m-d', strtotime($params['appointment_datetime'])) : '',
  222. 'appointment_apply_datetime' => isset($params['appointment_apply_datetime']) ? date('Y-m-d H:i:s', strtotime($params['appointment_apply_datetime'])) : '',
  223. 'appointment_doing_datetime' => isset($params['appointment_doing_datetime']) ? date('Y-m-d H:i:s', strtotime($params['appointment_doing_datetime'])) : '',
  224. 'appointment_done_datetime' => isset($params['appointment_done_datetime']) ? date('Y-m-d H:i:s', strtotime($params['appointment_done_datetime'])) : '',
  225. 'appointment_cancel_datetime' => isset($params['appointment_cancel_datetime']) ? date('Y-m-d H:i:s', strtotime($params['appointment_cancel_datetime'])) : '',
  226. 'appointment_remark' => $params['appointment_remark'] ?? '',
  227. 'appointment_category' => 'NOFEE',
  228. 'appointment_addtimes' => time(),
  229. 'appointment_mode' => $params['appointment_mode'] ?? '',
  230. 'settlement_mode' => $params['settlement_mode'] ?? '',
  231. 'appointment_platform' => 'SYSTEM'
  232. ];
  233. if (!empty($params['join_appointment_member_id'])) {
  234. $member = Member::with([
  235. 'cert' => function ($query) {
  236. $query->select('join_cert_member_id', 'member_cert_name');
  237. }
  238. ])->where('member_id', $params['join_appointment_member_id'])
  239. ->first()
  240. ->toArray();
  241. $data['appointment_apply_json'] = json_encode([
  242. 'name' => !empty($member['cert']['member_cert_name']) ? $member['cert']['member_cert_name'] : $member['member_mobile'],
  243. 'mobile' => $member['member_mobile'],
  244. 'person' => $params['person'],
  245. 'remark' => '',
  246. 'remark_apply_employe' => $params['remark_apply_employe'] ?? '',
  247. 'premises' => $params['premises'],
  248. 'times' => $params['appointment_times']
  249. ]);
  250. }
  251. Appointment::insert($data);
  252. // 如果预约已完成,生成订单
  253. // if ($params['appointment_status'] == 'DONE') {
  254. // $sku = GoodsSku::find($params['join_appointment_goods_sku_id']);
  255. // $orderId = 'OD' . date('YmdHis') . random_string(6, 'up');
  256. // $groupBy = 'OD' . date('YmdHis') . random_string(6, 'up');
  257. // $order = [
  258. // 'order_id' => $orderId,
  259. // 'order_groupby' => $groupBy,
  260. // 'join_order_member_id' => $params['join_appointment_member_id'],
  261. // 'order_name' => "预约-" . $goods->goods_name,
  262. // 'order_amount_total' => $sku->goods_sku_sales_price * $params['person'],
  263. // 'order_amount_pay' => $sku->goods_sku_sales_price * $params['person'],
  264. // 'order_is_complete' => 'N',
  265. // 'order_category' => $goods->goods_classify,
  266. // 'order_status_system' => 'PAYING',
  267. // 'order_status_payment' => 'PENDING',
  268. // 'order_status_storage' => 'PENDING',
  269. // 'order_platform' => 'SYSTEM',
  270. // 'order_addtimes' => time()
  271. // ];
  272. // Order::insert($order);
  273. // // 订单详情
  274. // $sheet = [
  275. // 'join_sheet_member_id' => $params['join_appointment_member_id'],
  276. // 'join_sheet_order_id' => $orderId,
  277. // 'join_sheet_goods_id' => $params['join_appointment_goods_id'],
  278. // 'order_sheet_status' => 'PAYING',
  279. // 'order_sheet_category' => 'APPOINTMENT',
  280. // 'order_sheet_unit' => '套',
  281. // 'order_sheet_num' => $params['person'],
  282. // 'order_sheet_price' => $sku->goods_sku_sales_price,
  283. // 'order_sheet_amount' => $sku->goods_sku_sales_price * $params['person'],
  284. // 'order_sheet_pay' => $sku->goods_sku_sales_price * $params['person'],
  285. // 'order_sheet_task_status' => 'NONE',
  286. // 'order_sheet_addtimes' => time()
  287. // ];
  288. // OrderSheet::insert($sheet);
  289. // // 订单号更新到预约
  290. // Appointment::where('appointment_id', $data['appointment_id'])->update(['join_appointment_order_id' => $orderId]);
  291. // // 支付数据
  292. // $pay = [
  293. // 'join_pay_member_id' => $params['join_appointment_member_id'],
  294. // 'join_pay_order_id' => $groupBy,
  295. // 'pay_amount' => $sheet['order_sheet_pay'],
  296. // 'pay_remark' => '预约单',
  297. // 'pay_addtimes' => time(),
  298. // 'pay_prepayid' => $params['join_appointment_member_id'] . '-' . $params['settlement_mode'],
  299. // 'pay_paytimes' => date('Y-m-d H:i:s'),
  300. // 'join_pay_object_json' => json_encode(['appointment_id' => $appointmentId]),
  301. // 'pay_category' => "APPOINTMENT"
  302. // ];
  303. // // 现金余额结算
  304. // if ($params['settlement_mode'] == 'CASH') {
  305. // $account = MemberAccount::where('join_account_member_id', $params['join_appointment_member_id'])
  306. // ->where('member_account_classify', 'CASH')
  307. // ->where('member_account_status', 'ACTIVED')
  308. // ->first();
  309. // if (!$account) {
  310. // Db::rollBack();
  311. // return json_fail('当前账户不存在或已过期');
  312. // }
  313. // if ($account->member_account_surplus < $sheet['order_sheet_pay']) {
  314. // throw new BusinessException("账户余额不足");
  315. // // $pay['pay_status'] = 'PENDING';
  316. // } else {
  317. // MemberAccount::where('member_account_id', $account->member_account_id)->update([
  318. // 'member_account_expend' => $account->member_account_expend + $sheet['order_sheet_pay'],
  319. // 'member_account_surplus' => $account->member_account_surplus - $sheet['order_sheet_pay']
  320. // ]);
  321. // $pay['pay_status'] = 'SUCCESS';
  322. // // 更新订单状态
  323. // Order::where('order_id', $orderId)->update(['order_status_system' => 'DONE','order_is_complete'=>'Y', 'order_status_payment' => 'SUCCESS']);
  324. // OrderSheet::where('join_sheet_order_id', $orderId)->update(['order_sheet_status' => 'DONE']);
  325. // }
  326. // PayDetail::insert($pay);
  327. // } elseif ($params['settlement_mode'] == 'QRCODE') {
  328. // $pay['pay_status'] = 'SUCCESS';
  329. // PayDetail::insert($pay);
  330. // // 更新订单状态
  331. // Order::where('order_id', $orderId)->update(['order_status_system' => 'DONE','order_is_complete'=>'Y', 'order_status_payment' => 'SUCCESS']);
  332. // OrderSheet::where('join_sheet_order_id', $orderId)->update(['order_sheet_status' => 'DONE']);
  333. // }
  334. // }
  335. Db::commit();
  336. _syslog("预约","添加预约成功");
  337. return json_success("添加预约成功");
  338. }catch (BusinessException $e){
  339. Db::rollBack();
  340. _syslog("预约","添加预约失败");
  341. return json_fail($e->getMessage());
  342. } catch (\Exception $e) {
  343. Db::rollBack();
  344. dump($e->getMessage());
  345. _syslog("预约","添加预约失败");
  346. return json_fail("添加预约失败");
  347. }
  348. }
  349. public static function update(Request $request)
  350. {
  351. $params = $request->post();
  352. $appointmentId = $params['appointment_id'];
  353. $appointment = Appointment::where('appointment_id', $appointmentId)->first();
  354. if (empty($appointment)) {
  355. return json_fail("数据不存在");
  356. }
  357. Db::beginTransaction();
  358. try {
  359. // 先检查选择的时段是否可预约
  360. $goods = Goods::where('goods_id', $params['join_appointment_goods_id'])->first();
  361. // $appointments = Appointment::where('appointment_datetime', $params['appointment_datetime'])
  362. // ->where('appointment_id', '<>', $params['appointment_id'])
  363. // ->get()
  364. // ->toArray();
  365. // if ($goods->is_support_appointment == 'Y' && !empty($goods->goods_attribute_json) && $appointment->appointment_category != 'GREENWAY') {
  366. // $extendJson = json_decode($goods->goods_attribute_json, true);
  367. // foreach ($extendJson['times'] as $key => $time) {
  368. // if ($time['duration'] == $params['appointment_times']) {
  369. // if (!empty($appointments)){
  370. // foreach ($appointments as $appointmentItem) {
  371. // $applyJson = json_decode($appointmentItem['appointment_apply_json'], true);
  372. // $applyJsonTimes = $applyJson['times'] ?? '';
  373. // if ($time['duration'] == $applyJsonTimes) {
  374. // $extendJson['times'][$key]['person'] -= $applyJson['person'];
  375. // if ($extendJson['times'][$key]['person'] < $params['person']) {
  376. // return json_fail('当前时段名额不足,请选择其他时段');
  377. // }
  378. // }
  379. // }
  380. // }else{
  381. // if ($extendJson['times'][$key]['person'] < $params['person']) {
  382. // return json_fail('当前时段名额不足,请选择其他时段');
  383. // }
  384. // }
  385. // }
  386. // }
  387. // }
  388. $data = [
  389. 'appointment_status' => $params['appointment_status'],
  390. // 'join_appointment_goods_sku_id' => $params['join_appointment_goods_sku_id'] ?? '',
  391. 'appointment_datetime' => $params['appointment_datetime'] ? date('Y-m-d', strtotime($params['appointment_datetime'])) : null,
  392. 'appointment_apply_datetime' => $params['appointment_apply_datetime'] ? date('Y-m-d H:i:s', strtotime($params['appointment_apply_datetime'])) : null,
  393. 'appointment_doing_datetime' => $params['appointment_doing_datetime'] ? date('Y-m-d H:i:s', strtotime($params['appointment_doing_datetime'])) : null,
  394. 'appointment_done_datetime' => $params['appointment_done_datetime'] ? date('Y-m-d H:i:s', strtotime($params['appointment_done_datetime'])) : null,
  395. 'appointment_cancel_datetime' => $params['appointment_cancel_datetime'] ? date('Y-m-d H:i:s', strtotime($params['appointment_cancel_datetime'])) : null,
  396. // 'appointment_remark' => $params['appointment_remark'] ?? '',
  397. 'appointment_mode' => $params['appointment_mode'] ?? '',
  398. 'settlement_mode' => $params['settlement_mode'] ?? '',
  399. ];
  400. // 如果是完成状态
  401. // if ($params['appointment_status'] == 'DONE' && $appointment->appointment_status != 'DONE') {
  402. // if (empty($params['appointment_done_datetime'])) {
  403. // $data['appointment_done_datetime'] = date('Y-m-d H:i:s');
  404. // }
  405. // MemberBenefit::where('member_benefit_id', $appointment->join_appointment_member_benefit_id)->increment('member_benefit_used_count');
  406. // }
  407. if (!empty($params['join_appointment_member_id'])) {
  408. $member = Member::with([
  409. 'cert' => function ($query) {
  410. $query->select('join_cert_member_id', 'member_cert_name');
  411. }
  412. ])->where('member_id', $params['join_appointment_member_id'])
  413. ->first();
  414. if(!$member){
  415. throw new BusinessException("核销人员不存在");
  416. }
  417. $member = $member->toArray();
  418. $applyJson = [];
  419. if (!empty($appointment->appointment_apply_json)){
  420. $applyJson = json_decode($appointment->appointment_apply_json,true);
  421. }
  422. $applyJson['name'] = !empty($member['cert']['member_cert_name']) ? $member['cert']['member_cert_name'] : $member['member_mobile'];
  423. $applyJson['mobile'] = $member['member_mobile'];
  424. $applyJson['person'] = $params['person'];
  425. $applyJson['remark_apply_employe'] = $params['remark_apply_employe'] ?? '';
  426. $applyJson['remark_done_employe'] = $params['remark_done_employe'] ?? '';
  427. $applyJson['remark_cancel_employe'] = $params['remark_cancel_employe'] ?? '';
  428. $applyJson['premises'] = $params['premises'];
  429. $applyJson['times'] = $params['appointment_times'];
  430. $data['appointment_apply_json'] = json_encode($applyJson);
  431. // $data['appointment_apply_json'] = json_encode([
  432. // 'name' => !empty($member['cert']['member_cert_name']) ? $member['cert']['member_cert_name'] : $member['member_mobile'],
  433. // 'mobile' => $member['member_mobile'],
  434. // 'person' => $params['person'],
  435. // 'remark' => $data['appointment_remark'],
  436. // 'premises' => $params['premises'],
  437. // 'times' => $params['appointment_times']
  438. // ]);
  439. }
  440. Appointment::where('appointment_id', $appointmentId)->update($data);
  441. // 如果服务结束,没有生成过订单,生成订单
  442. if ($params['appointment_status'] == 'DONE' && empty($appointment->join_appointment_order_id) && $params['settlement_mode'] != 'QUOTA') {
  443. $sku = GoodsSku::find($params['join_appointment_goods_sku_id']);
  444. $orderId = 'OD' . date('YmdHis') . random_string(6, 'up');
  445. $groupBy = 'OD' . date('YmdHis') . random_string(6, 'up');
  446. $order = [
  447. 'order_id' => $orderId,
  448. 'order_groupby' => $groupBy,
  449. 'join_order_member_id' => $params['join_appointment_member_id'],
  450. 'order_name' => "预约-" . $goods->goods_name,
  451. 'order_amount_total' => $sku->goods_sku_sales_price * $params['person'],
  452. 'order_amount_pay' => $sku->goods_sku_sales_price * $params['person'],
  453. 'order_is_complete' => 'N',
  454. 'order_category' => $goods->goods_classify,
  455. 'order_status_system' => 'PAYING',
  456. 'order_status_payment' => 'PENDING',
  457. 'order_status_storage' => 'PENDING',
  458. 'order_platform' => 'SYSTEM',
  459. 'order_addtimes' => time()
  460. ];
  461. Order::insert($order);
  462. // 订单详情
  463. $sheet = [
  464. 'join_sheet_member_id' => $params['join_appointment_member_id'],
  465. 'join_sheet_order_id' => $orderId,
  466. 'join_sheet_goods_id' => $params['join_appointment_goods_id'],
  467. 'order_sheet_status' => 'PAYING',
  468. 'order_sheet_category' => 'APPOINTMENT',
  469. 'order_sheet_unit' => '套',
  470. 'order_sheet_num' => $params['person'],
  471. 'order_sheet_price' => $sku->goods_sku_sales_price,
  472. 'order_sheet_amount' => $sku->goods_sku_sales_price * $params['person'],
  473. 'order_sheet_pay' => $sku->goods_sku_sales_price * $params['person'],
  474. 'order_sheet_task_status' => 'NONE',
  475. 'order_sheet_addtimes' => time()
  476. ];
  477. OrderSheet::insert($sheet);
  478. // 订单号更新到预约
  479. Appointment::where('appointment_id', $appointmentId)->update(['join_appointment_order_id' => $orderId]);
  480. // 支付数据
  481. $pay = [
  482. 'join_pay_member_id' => $params['join_appointment_member_id'],
  483. 'join_pay_order_id' => $groupBy,
  484. 'pay_amount' => $sheet['order_sheet_pay'],
  485. 'pay_remark' => '预约单',
  486. 'pay_addtimes' => time(),
  487. 'pay_prepayid' => $params['join_appointment_member_id'].'-'.$params['settlement_mode'],
  488. 'pay_paytimes' => date('Y-m-d H:i:s'),
  489. 'pay_category'=>$goods->goods_classify
  490. ];
  491. // 现金余额结算
  492. if ($params['settlement_mode'] == 'CASH') {
  493. $account = MemberAccount::where('join_account_member_id', $params['join_appointment_member_id'])
  494. ->where('member_account_classify', 'CASH')
  495. ->where('member_account_status', 'ACTIVED')
  496. ->first();
  497. if (!$account) {
  498. throw new BusinessException("当前账户不存在或已过期");
  499. }
  500. $amount = $account->member_account_surplus + $account->member_account_added;
  501. if ($amount < $sheet['order_sheet_pay']) {
  502. throw new BusinessException("账户余额不足");
  503. } else {
  504. if($account->member_account_surplus < $sheet['order_sheet_pay']){
  505. $account->member_account_added = $account->member_account_added - ($sheet['order_sheet_pay']-$account->member_account_surplus);
  506. $account->member_account_surplus = 0;
  507. }else{
  508. $account->member_account_surplus = $account->member_account_surplus - $sheet['order_sheet_pay'];
  509. }
  510. MemberAccount::where('member_account_id', $account->member_account_id)->update([
  511. 'member_account_expend' => $account->member_account_expend + $sheet['order_sheet_pay'],
  512. 'member_account_surplus' => $account->member_account_surplus,
  513. 'member_account_added' => $account->member_account_added
  514. ]);
  515. $pay['pay_status'] = 'SUCCESS';
  516. $pay['join_pay_object_json'] = json_encode(['payment' => ['member_account_id' => $account->member_account_id]]);
  517. // 更新订单状态
  518. Order::where('order_id', $orderId)->update(['order_status_system' => 'DONE','order_is_complete'=>'Y', 'order_status_payment' => 'SUCCESS']);
  519. OrderSheet::where('join_sheet_order_id', $orderId)->update(['order_sheet_status' => 'DONE']);
  520. }
  521. // $pay['pay_category'] = 'CASH';
  522. PayDetail::insert($pay);
  523. } elseif ($params['settlement_mode'] == 'WELFARE') {
  524. $account = MemberAccount::where('join_account_member_id', $params['join_appointment_member_id'])
  525. ->where('member_account_classify', 'WELFARE')
  526. ->where('member_account_status', 'ACTIVED')
  527. ->first();
  528. if (!$account) {
  529. throw new BusinessException("当前账户不存在或已过期");
  530. }
  531. if ($account->member_account_surplus < $sheet['order_sheet_pay']) {
  532. throw new BusinessException("账户余额不足");
  533. } else {
  534. MemberAccount::where('member_account_id', $account->member_account_id)->update([
  535. 'member_account_expend' => $account->member_account_expend + $sheet['order_sheet_pay'],
  536. 'member_account_surplus' => $account->member_account_surplus - $sheet['order_sheet_pay']
  537. ]);
  538. $pay['pay_status'] = 'SUCCESS';
  539. $pay['join_pay_object_json'] = json_encode(['payment' => ['member_account_id' => $account->member_account_id]]);
  540. // 更新订单状态
  541. Order::where('order_id', $orderId)->update(['order_status_system' => 'DONE','order_is_complete'=>'Y', 'order_status_payment' => 'SUCCESS']);
  542. OrderSheet::where('join_sheet_order_id', $orderId)->update(['order_sheet_status' => 'DONE']);
  543. }
  544. // $pay['pay_category'] = 'CASH';
  545. PayDetail::insert($pay);
  546. } elseif ($params['settlement_mode'] == 'QRCODE' && empty($appointment->join_appointment_order_id)) {
  547. // $pay['pay_category'] = 'QRCODE';
  548. $pay['pay_status'] = 'SUCCESS';
  549. PayDetail::insert($pay);
  550. // 更新订单状态
  551. Order::where('order_id', $orderId)->update(['order_status_system' => 'DONE','order_is_complete'=>'Y', 'order_status_payment' => 'SUCCESS']);
  552. OrderSheet::where('join_sheet_order_id', $orderId)->update(['order_sheet_status' => 'DONE']);
  553. }
  554. // 回写权益表
  555. $benefitId = 'BF'.date('YmdHis').random_string(6,'up');
  556. $benefitData = [
  557. 'member_benefit_id'=>$benefitId,
  558. 'join_benefit_member_id'=>$params['join_appointment_member_id'],
  559. 'join_benefit_goods_id'=>$params['join_appointment_goods_id'],
  560. 'join_benefit_goods_sku_id'=>$params['join_appointment_goods_sku_id'] ?? '',
  561. 'join_benefit_order_id'=>$orderId,
  562. 'member_benefit_status'=>'DONE',
  563. 'member_benefit_name'=>$goods->goods_name,
  564. 'member_benefit_limit_count'=>1,
  565. 'member_benefit_used_count'=>1,
  566. 'member_benefit_addtimes'=>time()
  567. ];
  568. MemberBenefit::insert($benefitData);
  569. // $premisesName = SysDept::where('dept_id',$params['premises'])->value('dept_name');
  570. // 记录核销
  571. $paramsData = [
  572. 'dept_premises_id' => $params['premises'],
  573. 'order_remark'=>$params['appointment_remark'],
  574. 'write_off_member_id' => $params['write_off_member_id'],
  575. 'join_order_member_id' => $params['join_appointment_member_id'],
  576. ];
  577. $writeOffData = OrderService::generateWriteOffData($paramsData);
  578. Appointment::where('appointment_id', $appointmentId)->update([
  579. 'join_appointment_member_benefit_id' => $benefitId,
  580. 'appointment_status' => 'DONE',
  581. 'appointment_done_datetime' => $params['appointment_done_datetime'] ? date('Y-m-d H:i:s', strtotime($params['appointment_done_datetime'])) : null,
  582. 'appointment_done_json' => json_encode($writeOffData)
  583. ]);
  584. }
  585. // 已有服务核销
  586. if($params['appointment_status'] == 'DONE' && $params['settlement_mode'] == 'QUOTA' && !empty($params['quota_id'])){
  587. // $premisesName = SysDept::where('dept_id',$params['premises'])->value('dept_name');
  588. $paramsData = [
  589. 'member_id'=>$params['join_appointment_member_id'],
  590. 'nbr'=>$params['person'],
  591. 'times'=>date('Y-m-d H:i:s'),
  592. 'write_off_member_id' => $params['write_off_member_id'],
  593. 'remark'=>$params['appointment_remark'],
  594. 'dept_premises_id'=>$params['premises']
  595. ];
  596. $quotaType = substr($params['quota_id'],0,2);
  597. if($quotaType == 'MQ'){
  598. $quota = MemberQuota::where('member_quota_id',$params['quota_id'])
  599. ->select('member_quota_id','join_member_rule_added_component_id')
  600. ->first()
  601. ->toArray();
  602. $paramsData['component_id'] = $quota['join_member_rule_added_component_id'];
  603. QuotaController::doWriteOff($paramsData);
  604. // 回写权益ID
  605. if(empty($appointment->join_appointment_member_benefit_id)){
  606. Appointment::where('appointment_id', $appointmentId)->update(['join_appointment_member_benefit_id' => $params['quota_id']]);
  607. }
  608. }else if($quotaType == 'BF'){
  609. $paramsData['benefit_id'] = $params['quota_id'];
  610. BenefitController::doWriteOff($paramsData,$appointment);
  611. // 清除后付费预约
  612. if($appointment->appointment_category == 'NOFEE'){
  613. Appointment::where('appointment_id', $appointmentId)->delete();
  614. }
  615. }
  616. _syslog("预约","已有服务核销");
  617. }
  618. Db::commit();
  619. _syslog("预约","预约数据更新成功");
  620. return json_success("数据更新成功");
  621. }catch(\support\exception\BusinessException $e){
  622. Db::rollBack();
  623. dump($e->getFile().'--'.$e->getLine());
  624. _syslog("预约","预约数据更新失败");
  625. return json_fail($e->getMessage());
  626. } catch (\Exception $e) {
  627. Db::rollBack();
  628. dump($e->getFile().'--'.$e->getLine());
  629. _syslog("预约","预约数据更新失败");
  630. return json_fail("数据更新失败");
  631. }
  632. }
  633. public static function getTimes(Request $request)
  634. {
  635. $goodsId = $request->get('goods_id', '');
  636. $date = $request->get('date', '');
  637. // $memberId = $request->get('member_id', '');
  638. $appointmentId = $request->get('appointment_id', '');
  639. $premisesName = $request->get('premisses','');
  640. if (!$goodsId || !$date) {
  641. return json_fail("查询时间段失败!");
  642. }
  643. if (!$premisesName){
  644. return json_fail("请先选择预约场所");
  645. }
  646. $goods = Goods::where('goods_id', $goodsId)->first();
  647. if (!$goods) {
  648. return json_fail('数据不存在');
  649. }
  650. // 当前服务已预约出去的
  651. $appointments = Appointment::where('join_appointment_goods_id', $goodsId)
  652. ->where('appointment_datetime', $date)
  653. ->whereJsonContains('appointment_apply_json->premises',$premisesName)
  654. ->when($appointmentId != '', function ($query) use ($appointmentId) {
  655. $query->where('appointment_id', '<>', $appointmentId);
  656. })
  657. ->get()
  658. ->toArray();
  659. if ($goods->is_support_appointment == 'Y' && !empty($goods->goods_attribute_json)) {
  660. $extendJson = json_decode($goods->goods_attribute_json, true);
  661. $times = $extendJson['times'];
  662. foreach ($times as $key => $time) {
  663. if (strtotime($date) < strtotime(date('Y-m-d')) || ($date == date('Y-m-d') && strtotime($date . ' ' . $key) < time())) {
  664. unset($times[$key]);
  665. continue;
  666. }
  667. $times[$key]['timesStr'] = $time['duration'];
  668. foreach ($appointments as $appointment) {
  669. if (!empty($appointment['appointment_apply_json'])) {
  670. $applyJson = json_decode($appointment['appointment_apply_json'], true);
  671. $applyJsonTimes = $applyJson['times'] ?? '';
  672. if ($time['duration'] == $applyJsonTimes) {
  673. $times[$key]['person'] -= $applyJson['person'];
  674. if ($times[$key]['person'] < 1) {
  675. $times[$key]['person'] = 0;
  676. $times[$key]['disabled'] = true;
  677. }
  678. }
  679. }
  680. }
  681. }
  682. return json_success('', $times);
  683. }
  684. }
  685. }