AppointmentService.php 46 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872
  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. /**
  135. * 到店-生成未支付订单
  136. */
  137. public static function arrival(Request $request)
  138. {
  139. $appointmentId = $request->post('id','');
  140. if (!$appointmentId){
  141. return json_fail("参数异常");
  142. }
  143. $appointment = Appointment::where('appointment_id',$appointmentId)->first();
  144. Db::beginTransaction();
  145. try{
  146. $appointment->appointment_doing_datetime = date('Y-m-d H:i:s');
  147. $appointment->appointment_status = 'DOING';
  148. $appointment->save();
  149. Db::commit();
  150. return json_success('操作成功');
  151. }catch(\Exception $e){
  152. dump($e->getMessage());
  153. Db::rollBack();
  154. return json_fail('到店状态修改失败');
  155. }
  156. }
  157. /**
  158. * 服务完成
  159. */
  160. public static function done(Request $request)
  161. {
  162. $appointmentId = $request->post('id','');
  163. $isGenerateOrder = $request->post('is_generate_order','');
  164. if (!$appointmentId || !$isGenerateOrder){
  165. return json_fail("参数异常");
  166. }
  167. $appointment = Appointment::where('appointment_id',$appointmentId)->first();
  168. Db::beginTransaction();
  169. try{
  170. $appointment->appointment_done_datetime = date('Y-m-d H:i:s');
  171. $appointment->appointment_status = 'DONE';
  172. // 不产生订单,走核销
  173. if ($isGenerateOrder == 'N'){
  174. $appointment->save();
  175. Db::commit();
  176. return json_success('操作成功');
  177. }
  178. $applyJson = json_decode($appointment->appointment_apply_json,true);
  179. $goods = Goods::where('goods_id',$appointment->join_appointment_goods_id)->first();
  180. $sku = GoodsSku::where('goods_sku_id',$appointment->join_appointment_goods_sku_id)->first();
  181. $orderId = 'OD' . date('YmdHis') . random_string(6, 'up');
  182. $groupBy = 'OD' . date('YmdHis') . random_string(6, 'up');
  183. $order = [
  184. 'order_id' => $orderId,
  185. 'order_groupby' => $groupBy,
  186. 'join_order_member_id' => $appointment->join_appointment_member_id,
  187. 'order_name' => "预约-" . $goods->goods_name,
  188. 'order_amount_total' => $sku->goods_sku_sales_price * $applyJson['person'],
  189. 'order_amount_pay' => $sku->goods_sku_sales_price * $applyJson['person'],
  190. 'order_is_complete' => 'N',
  191. 'order_category' => $goods->goods_classify,
  192. 'order_status_system' => 'PAYING',
  193. 'order_status_payment' => 'PENDING',
  194. 'order_status_storage' => 'PENDING',
  195. 'order_platform' => 'SYSTEM',
  196. 'order_addtimes' => time()
  197. ];
  198. Order::insert($order);
  199. // 订单号更新到预约
  200. Appointment::where('appointment_id', $appointmentId)->update(['join_appointment_order_id' => $orderId]);
  201. // 订单详情
  202. $sheet = [
  203. 'join_sheet_member_id' => $appointment->join_appointment_member_id,
  204. 'join_sheet_order_id' => $orderId,
  205. 'join_sheet_goods_id' => $appointment->join_appointment_goods_id,
  206. 'join_sheet_goods_sku_id' => $appointment->join_appointment_goods_sku_id,
  207. 'order_sheet_status' => 'PAYING',
  208. 'order_sheet_category' => 'APPOINTMENT',
  209. // 'order_sheet_unit' => '套',
  210. 'order_sheet_num' => $applyJson['person'],
  211. 'order_sheet_price' => $sku->goods_sku_sales_price,
  212. 'order_sheet_amount' => $sku->goods_sku_sales_price * $applyJson['person'],
  213. 'order_sheet_pay' => $sku->goods_sku_sales_price * $applyJson['person'],
  214. 'order_sheet_task_status' => 'NONE',
  215. 'order_sheet_addtimes' => time()
  216. ];
  217. OrderSheet::insert($sheet);
  218. // 支付数据
  219. $pay = [
  220. 'join_pay_member_id' => $appointment->join_appointment_member_id,
  221. 'join_pay_order_id' => $groupBy,
  222. 'pay_status'=>'WAITING',
  223. 'pay_amount' => $sheet['order_sheet_pay'],
  224. 'pay_remark' => '预约单',
  225. 'pay_addtimes' => time(),
  226. 'pay_paytimes' => date('Y-m-d H:i:s'),
  227. 'pay_prepayid'=>0,
  228. 'pay_category'=>$goods->goods_classify
  229. ];
  230. PayDetail::insert($pay);
  231. $appointment->save();
  232. Db::commit();
  233. return json_success('操作成功');
  234. }catch(\Exception $e){
  235. dump($e->getMessage());
  236. Db::rollBack();
  237. return json_fail('到店状态修改失败');
  238. }
  239. }
  240. public static function add(Request $request)
  241. {
  242. $params = $request->post();
  243. Db::beginTransaction();
  244. try {
  245. // 先检查选择的时段是否可预约
  246. $goods = Goods::where('goods_id', $params['join_appointment_goods_id'])->first();
  247. // $appointments = Appointment::where('appointment_datetime', $params['appointment_datetime'])->get()->toArray();
  248. // if ($goods->is_support_appointment == 'Y' && !empty($goods->goods_attribute_json)) {
  249. // $extendJson = json_decode($goods->goods_attribute_json, true);
  250. // foreach ($extendJson['times'] as $key => $time) {
  251. // if ($time['duration'] == $params['appointment_times']) {
  252. // if (!empty($appointments)) {
  253. // foreach ($appointments as $appointment) {
  254. // $applyJson = json_decode($appointment['appointment_apply_json'], true);
  255. // $applyJsonTimes = $applyJson['times'] ?? '';
  256. // if ($time['duration'] == $applyJsonTimes) {
  257. // $extendJson['times'][$key]['person'] -= $applyJson['person'];
  258. // if ($extendJson['times'][$key]['person'] < $params['person']) {
  259. // return json_fail('当前时段名额不足,请选择其他时段');
  260. // }
  261. // }
  262. // }
  263. // } else {
  264. // if ($extendJson['times'][$key]['person'] < $params['person']) {
  265. // return json_fail('当前时段名额不足,请选择其他时段');
  266. // }
  267. // }
  268. // }
  269. // }
  270. // }
  271. // 如果没有,新建
  272. if (empty($params['join_appointment_member_id']) && !empty($params['username']) && !empty($params['mobile'])) {
  273. if(Member::where('member_mobile',$params['mobile'])->exists()){
  274. Db::rollBack();
  275. return json_fail('会员已存在,请勿重复创建');
  276. }
  277. $memberId = "MR" . str_pad(SysSerial::getSerial(), 16, "0", STR_PAD_LEFT) . random_string(6, 'up');
  278. $params['join_appointment_member_id'] = $memberId;
  279. // 主表
  280. $memberData = [
  281. 'member_id' => $memberId,
  282. 'member_is_owner' => 'N',
  283. 'member_classify' => 'MEMBER',
  284. 'member_status' => 'ACTIVED',
  285. 'member_mobile' => $params['mobile'],
  286. 'member_extend_json'=>json_encode(['come_from'=>'SYSTEM']),
  287. 'member_addtimes' => time()
  288. ];
  289. Member::insert($memberData);
  290. // 账户表
  291. $accountData = [
  292. 'join_account_member_id' => $memberId,
  293. 'member_account_classify' => 'POINTS',
  294. 'member_account_status' => 'ACTIVED',
  295. 'member_account_category' => 'NORMAL',
  296. 'member_account_nbr' => $memberId . '-POINTS',
  297. 'member_account_name' => '积分账户',
  298. 'member_account_addtimes' => time()
  299. ];
  300. // 积分账户
  301. MemberAccount::insert($accountData);
  302. $accountData['member_account_classify'] = 'CASH';
  303. $accountData['member_account_nbr'] = $memberId . '-CASH';
  304. $accountData['member_account_name'] = '余额账户';
  305. // 现金/余额账户
  306. MemberAccount::insert($accountData);
  307. // cert
  308. // $certData = [
  309. // 'join_cert_member_id' => $memberId,
  310. // 'member_cert_name' => $params['username']
  311. // ];
  312. // MemberCert::insert($certData);
  313. // info
  314. $infoData = [
  315. 'join_info_member_id' => $memberId,
  316. 'member_info_nickname' => $params['username']
  317. ];
  318. MemberInfo::insert($infoData);
  319. }
  320. $appointmentId = "AP" . date('YmdHis') . random_string(6, 'up');
  321. $data = [
  322. 'appointment_id' => $appointmentId,
  323. 'join_appointment_member_id' => $params['join_appointment_member_id'] ?? '',
  324. 'join_appointment_goods_id' => $params['join_appointment_goods_id'] ?? '',
  325. 'join_appointment_goods_sku_id' => $params['join_appointment_goods_sku_id'] ?? '',
  326. 'appointment_status' => $params['appointment_status'] ?? '',
  327. 'appointment_datetime' => isset($params['appointment_datetime']) ? date('Y-m-d', strtotime($params['appointment_datetime'])) : '',
  328. 'appointment_apply_datetime' => isset($params['appointment_apply_datetime']) ? date('Y-m-d H:i:s', strtotime($params['appointment_apply_datetime'])) : '',
  329. 'appointment_doing_datetime' => isset($params['appointment_doing_datetime']) ? date('Y-m-d H:i:s', strtotime($params['appointment_doing_datetime'])) : '',
  330. 'appointment_done_datetime' => isset($params['appointment_done_datetime']) ? date('Y-m-d H:i:s', strtotime($params['appointment_done_datetime'])) : '',
  331. 'appointment_cancel_datetime' => isset($params['appointment_cancel_datetime']) ? date('Y-m-d H:i:s', strtotime($params['appointment_cancel_datetime'])) : '',
  332. 'appointment_remark' => $params['appointment_remark'] ?? '',
  333. 'appointment_category' => 'NOFEE',
  334. 'appointment_addtimes' => time(),
  335. 'appointment_mode' => $params['appointment_mode'] ?? '',
  336. 'settlement_mode' => $params['settlement_mode'] ?? '',
  337. 'appointment_platform' => 'SYSTEM'
  338. ];
  339. if (!empty($params['join_appointment_member_id'])) {
  340. $member = Member::with([
  341. 'cert' => function ($query) {
  342. $query->select('join_cert_member_id', 'member_cert_name');
  343. }
  344. ])->where('member_id', $params['join_appointment_member_id'])
  345. ->first()
  346. ->toArray();
  347. $data['appointment_apply_json'] = json_encode([
  348. 'name' => !empty($member['cert']['member_cert_name']) ? $member['cert']['member_cert_name'] : $member['member_mobile'],
  349. 'mobile' => $member['member_mobile'],
  350. 'person' => $params['person'],
  351. 'remark' => '',
  352. 'remark_apply_employe' => $params['remark_apply_employe'] ?? '',
  353. 'premises' => $params['premises'],
  354. 'times' => $params['appointment_times']
  355. ]);
  356. }
  357. Appointment::insert($data);
  358. // 如果预约已完成,生成订单
  359. // if ($params['appointment_status'] == 'DONE') {
  360. // $sku = GoodsSku::find($params['join_appointment_goods_sku_id']);
  361. // $orderId = 'OD' . date('YmdHis') . random_string(6, 'up');
  362. // $groupBy = 'OD' . date('YmdHis') . random_string(6, 'up');
  363. // $order = [
  364. // 'order_id' => $orderId,
  365. // 'order_groupby' => $groupBy,
  366. // 'join_order_member_id' => $params['join_appointment_member_id'],
  367. // 'order_name' => "预约-" . $goods->goods_name,
  368. // 'order_amount_total' => $sku->goods_sku_sales_price * $params['person'],
  369. // 'order_amount_pay' => $sku->goods_sku_sales_price * $params['person'],
  370. // 'order_is_complete' => 'N',
  371. // 'order_category' => $goods->goods_classify,
  372. // 'order_status_system' => 'PAYING',
  373. // 'order_status_payment' => 'PENDING',
  374. // 'order_status_storage' => 'PENDING',
  375. // 'order_platform' => 'SYSTEM',
  376. // 'order_addtimes' => time()
  377. // ];
  378. // Order::insert($order);
  379. // // 订单详情
  380. // $sheet = [
  381. // 'join_sheet_member_id' => $params['join_appointment_member_id'],
  382. // 'join_sheet_order_id' => $orderId,
  383. // 'join_sheet_goods_id' => $params['join_appointment_goods_id'],
  384. // 'order_sheet_status' => 'PAYING',
  385. // 'order_sheet_category' => 'APPOINTMENT',
  386. // 'order_sheet_unit' => '套',
  387. // 'order_sheet_num' => $params['person'],
  388. // 'order_sheet_price' => $sku->goods_sku_sales_price,
  389. // 'order_sheet_amount' => $sku->goods_sku_sales_price * $params['person'],
  390. // 'order_sheet_pay' => $sku->goods_sku_sales_price * $params['person'],
  391. // 'order_sheet_task_status' => 'NONE',
  392. // 'order_sheet_addtimes' => time()
  393. // ];
  394. // OrderSheet::insert($sheet);
  395. // // 订单号更新到预约
  396. // Appointment::where('appointment_id', $data['appointment_id'])->update(['join_appointment_order_id' => $orderId]);
  397. // // 支付数据
  398. // $pay = [
  399. // 'join_pay_member_id' => $params['join_appointment_member_id'],
  400. // 'join_pay_order_id' => $groupBy,
  401. // 'pay_amount' => $sheet['order_sheet_pay'],
  402. // 'pay_remark' => '预约单',
  403. // 'pay_addtimes' => time(),
  404. // 'pay_prepayid' => $params['join_appointment_member_id'] . '-' . $params['settlement_mode'],
  405. // 'pay_paytimes' => date('Y-m-d H:i:s'),
  406. // 'join_pay_object_json' => json_encode(['appointment_id' => $appointmentId]),
  407. // 'pay_category' => "APPOINTMENT"
  408. // ];
  409. // // 现金余额结算
  410. // if ($params['settlement_mode'] == 'CASH') {
  411. // $account = MemberAccount::where('join_account_member_id', $params['join_appointment_member_id'])
  412. // ->where('member_account_classify', 'CASH')
  413. // ->where('member_account_status', 'ACTIVED')
  414. // ->first();
  415. // if (!$account) {
  416. // Db::rollBack();
  417. // return json_fail('当前账户不存在或已过期');
  418. // }
  419. // if ($account->member_account_surplus < $sheet['order_sheet_pay']) {
  420. // throw new BusinessException("账户余额不足");
  421. // // $pay['pay_status'] = 'PENDING';
  422. // } else {
  423. // MemberAccount::where('member_account_id', $account->member_account_id)->update([
  424. // 'member_account_expend' => $account->member_account_expend + $sheet['order_sheet_pay'],
  425. // 'member_account_surplus' => $account->member_account_surplus - $sheet['order_sheet_pay']
  426. // ]);
  427. // $pay['pay_status'] = 'SUCCESS';
  428. // // 更新订单状态
  429. // Order::where('order_id', $orderId)->update(['order_status_system' => 'DONE','order_is_complete'=>'Y', 'order_status_payment' => 'SUCCESS']);
  430. // OrderSheet::where('join_sheet_order_id', $orderId)->update(['order_sheet_status' => 'DONE']);
  431. // }
  432. // PayDetail::insert($pay);
  433. // } elseif ($params['settlement_mode'] == 'QRCODE') {
  434. // $pay['pay_status'] = 'SUCCESS';
  435. // PayDetail::insert($pay);
  436. // // 更新订单状态
  437. // Order::where('order_id', $orderId)->update(['order_status_system' => 'DONE','order_is_complete'=>'Y', 'order_status_payment' => 'SUCCESS']);
  438. // OrderSheet::where('join_sheet_order_id', $orderId)->update(['order_sheet_status' => 'DONE']);
  439. // }
  440. // }
  441. Db::commit();
  442. _syslog("预约","添加预约成功");
  443. return json_success("添加预约成功");
  444. }catch (BusinessException $e){
  445. Db::rollBack();
  446. _syslog("预约","添加预约失败");
  447. return json_fail($e->getMessage());
  448. } catch (\Exception $e) {
  449. Db::rollBack();
  450. dump($e->getMessage());
  451. _syslog("预约","添加预约失败");
  452. return json_fail("添加预约失败");
  453. }
  454. }
  455. public static function update(Request $request)
  456. {
  457. $params = $request->post();
  458. $appointmentId = $params['appointment_id'];
  459. $appointment = Appointment::where('appointment_id', $appointmentId)->first();
  460. if (empty($appointment)) {
  461. return json_fail("数据不存在");
  462. }
  463. Db::beginTransaction();
  464. try {
  465. // 先检查选择的时段是否可预约
  466. $goods = Goods::where('goods_id', $params['join_appointment_goods_id'])->first();
  467. // $appointments = Appointment::where('appointment_datetime', $params['appointment_datetime'])
  468. // ->where('appointment_id', '<>', $params['appointment_id'])
  469. // ->get()
  470. // ->toArray();
  471. // if ($goods->is_support_appointment == 'Y' && !empty($goods->goods_attribute_json) && $appointment->appointment_category != 'GREENWAY') {
  472. // $extendJson = json_decode($goods->goods_attribute_json, true);
  473. // foreach ($extendJson['times'] as $key => $time) {
  474. // if ($time['duration'] == $params['appointment_times']) {
  475. // if (!empty($appointments)){
  476. // foreach ($appointments as $appointmentItem) {
  477. // $applyJson = json_decode($appointmentItem['appointment_apply_json'], true);
  478. // $applyJsonTimes = $applyJson['times'] ?? '';
  479. // if ($time['duration'] == $applyJsonTimes) {
  480. // $extendJson['times'][$key]['person'] -= $applyJson['person'];
  481. // if ($extendJson['times'][$key]['person'] < $params['person']) {
  482. // return json_fail('当前时段名额不足,请选择其他时段');
  483. // }
  484. // }
  485. // }
  486. // }else{
  487. // if ($extendJson['times'][$key]['person'] < $params['person']) {
  488. // return json_fail('当前时段名额不足,请选择其他时段');
  489. // }
  490. // }
  491. // }
  492. // }
  493. // }
  494. $data = [
  495. 'appointment_status' => $params['appointment_status'],
  496. // 'join_appointment_goods_sku_id' => $params['join_appointment_goods_sku_id'] ?? '',
  497. 'appointment_datetime' => $params['appointment_datetime'] ? date('Y-m-d', strtotime($params['appointment_datetime'])) : null,
  498. 'appointment_apply_datetime' => $params['appointment_apply_datetime'] ? date('Y-m-d H:i:s', strtotime($params['appointment_apply_datetime'])) : null,
  499. 'appointment_doing_datetime' => $params['appointment_doing_datetime'] ? date('Y-m-d H:i:s', strtotime($params['appointment_doing_datetime'])) : null,
  500. 'appointment_done_datetime' => $params['appointment_done_datetime'] ? date('Y-m-d H:i:s', strtotime($params['appointment_done_datetime'])) : null,
  501. 'appointment_cancel_datetime' => $params['appointment_cancel_datetime'] ? date('Y-m-d H:i:s', strtotime($params['appointment_cancel_datetime'])) : null,
  502. // 'appointment_remark' => $params['appointment_remark'] ?? '',
  503. 'appointment_mode' => $params['appointment_mode'] ?? '',
  504. 'settlement_mode' => $params['settlement_mode'] ?? '',
  505. ];
  506. // 如果是完成状态
  507. // if ($params['appointment_status'] == 'DONE' && $appointment->appointment_status != 'DONE') {
  508. // if (empty($params['appointment_done_datetime'])) {
  509. // $data['appointment_done_datetime'] = date('Y-m-d H:i:s');
  510. // }
  511. // MemberBenefit::where('member_benefit_id', $appointment->join_appointment_member_benefit_id)->increment('member_benefit_used_count');
  512. // }
  513. if (!empty($params['join_appointment_member_id'])) {
  514. $member = Member::with([
  515. 'cert' => function ($query) {
  516. $query->select('join_cert_member_id', 'member_cert_name');
  517. }
  518. ])->where('member_id', $params['join_appointment_member_id'])
  519. ->first();
  520. if(!$member){
  521. throw new BusinessException("核销人员不存在");
  522. }
  523. $member = $member->toArray();
  524. $applyJson = [];
  525. if (!empty($appointment->appointment_apply_json)){
  526. $applyJson = json_decode($appointment->appointment_apply_json,true);
  527. }
  528. $applyJson['name'] = !empty($member['cert']['member_cert_name']) ? $member['cert']['member_cert_name'] : $member['member_mobile'];
  529. $applyJson['mobile'] = $member['member_mobile'];
  530. $applyJson['person'] = $params['person'];
  531. $applyJson['remark_apply_employe'] = $params['remark_apply_employe'] ?? '';
  532. $applyJson['remark_done_employe'] = $params['remark_done_employe'] ?? '';
  533. $applyJson['remark_cancel_employe'] = $params['remark_cancel_employe'] ?? '';
  534. $applyJson['premises'] = $params['premises'];
  535. $applyJson['times'] = $params['appointment_times'];
  536. $data['appointment_apply_json'] = json_encode($applyJson);
  537. // $data['appointment_apply_json'] = json_encode([
  538. // 'name' => !empty($member['cert']['member_cert_name']) ? $member['cert']['member_cert_name'] : $member['member_mobile'],
  539. // 'mobile' => $member['member_mobile'],
  540. // 'person' => $params['person'],
  541. // 'remark' => $data['appointment_remark'],
  542. // 'premises' => $params['premises'],
  543. // 'times' => $params['appointment_times']
  544. // ]);
  545. }
  546. Appointment::where('appointment_id', $appointmentId)->update($data);
  547. // 如果服务结束,没有生成过订单,生成订单
  548. if ($params['appointment_status'] == 'DONE' && empty($appointment->join_appointment_order_id) && $params['settlement_mode'] != 'QUOTA') {
  549. $sku = GoodsSku::find($params['join_appointment_goods_sku_id']);
  550. $orderId = 'OD' . date('YmdHis') . random_string(6, 'up');
  551. $groupBy = 'OD' . date('YmdHis') . random_string(6, 'up');
  552. $order = [
  553. 'order_id' => $orderId,
  554. 'order_groupby' => $groupBy,
  555. 'join_order_member_id' => $params['join_appointment_member_id'],
  556. 'order_name' => "预约-" . $goods->goods_name,
  557. 'order_amount_total' => $sku->goods_sku_sales_price * $params['person'],
  558. 'order_amount_pay' => $sku->goods_sku_sales_price * $params['person'],
  559. 'order_is_complete' => 'N',
  560. 'order_category' => $goods->goods_classify,
  561. 'order_status_system' => 'PAYING',
  562. 'order_status_payment' => 'PENDING',
  563. 'order_status_storage' => 'PENDING',
  564. 'order_platform' => 'SYSTEM',
  565. 'order_addtimes' => time()
  566. ];
  567. Order::insert($order);
  568. // 订单详情
  569. $sheet = [
  570. 'join_sheet_member_id' => $params['join_appointment_member_id'],
  571. 'join_sheet_order_id' => $orderId,
  572. 'join_sheet_goods_id' => $params['join_appointment_goods_id'],
  573. 'order_sheet_status' => 'PAYING',
  574. 'order_sheet_category' => 'APPOINTMENT',
  575. 'order_sheet_unit' => '套',
  576. 'order_sheet_num' => $params['person'],
  577. 'order_sheet_price' => $sku->goods_sku_sales_price,
  578. 'order_sheet_amount' => $sku->goods_sku_sales_price * $params['person'],
  579. 'order_sheet_pay' => $sku->goods_sku_sales_price * $params['person'],
  580. 'order_sheet_task_status' => 'NONE',
  581. 'order_sheet_addtimes' => time()
  582. ];
  583. OrderSheet::insert($sheet);
  584. // 订单号更新到预约
  585. Appointment::where('appointment_id', $appointmentId)->update(['join_appointment_order_id' => $orderId]);
  586. // 支付数据
  587. $pay = [
  588. 'join_pay_member_id' => $params['join_appointment_member_id'],
  589. 'join_pay_order_id' => $groupBy,
  590. 'pay_amount' => $sheet['order_sheet_pay'],
  591. 'pay_remark' => '预约单',
  592. 'pay_addtimes' => time(),
  593. 'pay_prepayid' => $params['join_appointment_member_id'].'-'.$params['settlement_mode'],
  594. 'pay_paytimes' => date('Y-m-d H:i:s'),
  595. 'pay_category'=>$goods->goods_classify
  596. ];
  597. // 现金余额结算
  598. if ($params['settlement_mode'] == 'CASH') {
  599. $account = MemberAccount::where('join_account_member_id', $params['join_appointment_member_id'])
  600. ->where('member_account_classify', 'CASH')
  601. ->where('member_account_status', 'ACTIVED')
  602. ->first();
  603. if (!$account) {
  604. throw new BusinessException("当前账户不存在或已过期");
  605. }
  606. $amount = $account->member_account_surplus + $account->member_account_added;
  607. if ($amount < $sheet['order_sheet_pay']) {
  608. throw new BusinessException("账户余额不足");
  609. } else {
  610. if($account->member_account_surplus < $sheet['order_sheet_pay']){
  611. $account->member_account_added = $account->member_account_added - ($sheet['order_sheet_pay']-$account->member_account_surplus);
  612. $account->member_account_surplus = 0;
  613. }else{
  614. $account->member_account_surplus = $account->member_account_surplus - $sheet['order_sheet_pay'];
  615. }
  616. MemberAccount::where('member_account_id', $account->member_account_id)->update([
  617. 'member_account_expend' => $account->member_account_expend + $sheet['order_sheet_pay'],
  618. 'member_account_surplus' => $account->member_account_surplus,
  619. 'member_account_added' => $account->member_account_added
  620. ]);
  621. $pay['pay_status'] = 'SUCCESS';
  622. $pay['join_pay_object_json'] = json_encode(['payment' => ['member_account_id' => $account->member_account_id]]);
  623. // 更新订单状态
  624. Order::where('order_id', $orderId)->update(['order_status_system' => 'DONE','order_is_complete'=>'Y', 'order_status_payment' => 'SUCCESS']);
  625. OrderSheet::where('join_sheet_order_id', $orderId)->update(['order_sheet_status' => 'DONE']);
  626. }
  627. // $pay['pay_category'] = 'CASH';
  628. PayDetail::insert($pay);
  629. } elseif ($params['settlement_mode'] == 'WELFARE') {
  630. $account = MemberAccount::where('join_account_member_id', $params['join_appointment_member_id'])
  631. ->where('member_account_classify', 'WELFARE')
  632. ->where('member_account_status', 'ACTIVED')
  633. ->first();
  634. if (!$account) {
  635. throw new BusinessException("当前账户不存在或已过期");
  636. }
  637. if ($account->member_account_surplus < $sheet['order_sheet_pay']) {
  638. throw new BusinessException("账户余额不足");
  639. } else {
  640. MemberAccount::where('member_account_id', $account->member_account_id)->update([
  641. 'member_account_expend' => $account->member_account_expend + $sheet['order_sheet_pay'],
  642. 'member_account_surplus' => $account->member_account_surplus - $sheet['order_sheet_pay']
  643. ]);
  644. $pay['pay_status'] = 'SUCCESS';
  645. $pay['join_pay_object_json'] = json_encode(['payment' => ['member_account_id' => $account->member_account_id]]);
  646. // 更新订单状态
  647. Order::where('order_id', $orderId)->update(['order_status_system' => 'DONE','order_is_complete'=>'Y', 'order_status_payment' => 'SUCCESS']);
  648. OrderSheet::where('join_sheet_order_id', $orderId)->update(['order_sheet_status' => 'DONE']);
  649. }
  650. // $pay['pay_category'] = 'CASH';
  651. PayDetail::insert($pay);
  652. } elseif ($params['settlement_mode'] == 'QRCODE' && empty($appointment->join_appointment_order_id)) {
  653. // $pay['pay_category'] = 'QRCODE';
  654. $pay['pay_status'] = 'SUCCESS';
  655. PayDetail::insert($pay);
  656. // 更新订单状态
  657. Order::where('order_id', $orderId)->update(['order_status_system' => 'DONE','order_is_complete'=>'Y', 'order_status_payment' => 'SUCCESS']);
  658. OrderSheet::where('join_sheet_order_id', $orderId)->update(['order_sheet_status' => 'DONE']);
  659. }
  660. // 回写权益表
  661. $benefitId = 'BF'.date('YmdHis').random_string(6,'up');
  662. $benefitData = [
  663. 'member_benefit_id'=>$benefitId,
  664. 'join_benefit_member_id'=>$params['join_appointment_member_id'],
  665. 'join_benefit_goods_id'=>$params['join_appointment_goods_id'],
  666. 'join_benefit_goods_sku_id'=>$params['join_appointment_goods_sku_id'] ?? '',
  667. 'join_benefit_order_id'=>$orderId,
  668. 'member_benefit_status'=>'DONE',
  669. 'member_benefit_name'=>$goods->goods_name,
  670. 'member_benefit_limit_count'=>1,
  671. 'member_benefit_used_count'=>1,
  672. 'member_benefit_addtimes'=>time()
  673. ];
  674. MemberBenefit::insert($benefitData);
  675. // $premisesName = SysDept::where('dept_id',$params['premises'])->value('dept_name');
  676. // 记录核销
  677. $paramsData = [
  678. 'dept_premises_id' => $params['premises'],
  679. 'order_remark'=>$params['appointment_remark'],
  680. 'write_off_member_id' => $params['write_off_member_id'],
  681. 'join_order_member_id' => $params['join_appointment_member_id'],
  682. ];
  683. $writeOffData = OrderService::generateWriteOffData($paramsData);
  684. Appointment::where('appointment_id', $appointmentId)->update([
  685. 'join_appointment_member_benefit_id' => $benefitId,
  686. 'appointment_status' => 'DONE',
  687. 'appointment_done_datetime' => $params['appointment_done_datetime'] ? date('Y-m-d H:i:s', strtotime($params['appointment_done_datetime'])) : null,
  688. 'appointment_done_json' => json_encode($writeOffData)
  689. ]);
  690. }
  691. // 已有服务核销
  692. if($params['appointment_status'] == 'DONE' && $params['settlement_mode'] == 'QUOTA' && !empty($params['quota_id'])){
  693. // $premisesName = SysDept::where('dept_id',$params['premises'])->value('dept_name');
  694. $paramsData = [
  695. 'member_id'=>$params['join_appointment_member_id'],
  696. 'nbr'=>$params['person'],
  697. 'times'=>date('Y-m-d H:i:s'),
  698. 'write_off_member_id' => $params['write_off_member_id'],
  699. 'remark'=>$params['appointment_remark'],
  700. 'dept_premises_id'=>$params['premises']
  701. ];
  702. $quotaType = substr($params['quota_id'],0,2);
  703. if($quotaType == 'MQ'){
  704. $quota = MemberQuota::where('member_quota_id',$params['quota_id'])
  705. ->select('member_quota_id','join_member_rule_added_component_id')
  706. ->first()
  707. ->toArray();
  708. $paramsData['component_id'] = $quota['join_member_rule_added_component_id'];
  709. QuotaController::doWriteOff($paramsData);
  710. // 回写权益ID
  711. if(empty($appointment->join_appointment_member_benefit_id)){
  712. Appointment::where('appointment_id', $appointmentId)->update(['join_appointment_member_benefit_id' => $params['quota_id']]);
  713. }
  714. }else if($quotaType == 'BF'){
  715. $paramsData['benefit_id'] = $params['quota_id'];
  716. BenefitController::doWriteOff($paramsData,$appointment);
  717. // 清除后付费预约
  718. if($appointment->appointment_category == 'NOFEE'){
  719. Appointment::where('appointment_id', $appointmentId)->delete();
  720. }
  721. }
  722. _syslog("预约","已有服务核销");
  723. }
  724. Db::commit();
  725. _syslog("预约","预约数据更新成功");
  726. return json_success("数据更新成功");
  727. }catch(\support\exception\BusinessException $e){
  728. Db::rollBack();
  729. dump($e->getFile().'--'.$e->getLine());
  730. _syslog("预约","预约数据更新失败");
  731. return json_fail($e->getMessage());
  732. } catch (\Exception $e) {
  733. Db::rollBack();
  734. dump($e->getFile().'--'.$e->getLine());
  735. _syslog("预约","预约数据更新失败");
  736. return json_fail("数据更新失败");
  737. }
  738. }
  739. /**
  740. * 取消预约
  741. */
  742. public static function cancelApply(Request $request)
  743. {
  744. $appointmentId = $request->post('id','');
  745. if (!$appointmentId){
  746. return json_fail("参数异常");
  747. }
  748. $appointment = Appointment::where('appointment_id',$appointmentId)->first();
  749. if(!$appointment){
  750. return json_fail("参数异常");
  751. }
  752. try{
  753. $appointment->appointment_status = 'CANCEL';
  754. $appointment->appointment_cancel_datetime = date('Y-m-d H:i:s');
  755. $appointment->save();
  756. return json_success('取消成功');
  757. }catch(\Exception $e){
  758. return json_fail('取消失败');
  759. }
  760. }
  761. public static function getTimes(Request $request)
  762. {
  763. $goodsId = $request->get('goods_id', '');
  764. $date = $request->get('date', '');
  765. // $memberId = $request->get('member_id', '');
  766. $appointmentId = $request->get('appointment_id', '');
  767. $premisesName = $request->get('premisses','');
  768. if (!$goodsId || !$date) {
  769. return json_fail("查询时间段失败!");
  770. }
  771. if (!$premisesName){
  772. return json_fail("请先选择预约场所");
  773. }
  774. $goods = Goods::where('goods_id', $goodsId)->first();
  775. if (!$goods) {
  776. return json_fail('数据不存在');
  777. }
  778. // 当前服务已预约出去的
  779. $appointments = Appointment::where('join_appointment_goods_id', $goodsId)
  780. ->where('appointment_datetime', $date)
  781. ->whereJsonContains('appointment_apply_json->premises',$premisesName)
  782. ->when($appointmentId != '', function ($query) use ($appointmentId) {
  783. $query->where('appointment_id', '<>', $appointmentId);
  784. })
  785. ->get()
  786. ->toArray();
  787. if ($goods->is_support_appointment == 'Y' && !empty($goods->goods_attribute_json)) {
  788. $extendJson = json_decode($goods->goods_attribute_json, true);
  789. $times = $extendJson['times'];
  790. foreach ($times as $key => $time) {
  791. if (strtotime($date) < strtotime(date('Y-m-d')) || ($date == date('Y-m-d') && strtotime($date . ' ' . $key) < time())) {
  792. unset($times[$key]);
  793. continue;
  794. }
  795. $times[$key]['timesStr'] = $time['duration'];
  796. foreach ($appointments as $appointment) {
  797. if (!empty($appointment['appointment_apply_json'])) {
  798. $applyJson = json_decode($appointment['appointment_apply_json'], true);
  799. $applyJsonTimes = $applyJson['times'] ?? '';
  800. if ($time['duration'] == $applyJsonTimes) {
  801. $times[$key]['person'] -= $applyJson['person'];
  802. if ($times[$key]['person'] < 1) {
  803. $times[$key]['person'] = 0;
  804. $times[$key]['disabled'] = true;
  805. }
  806. }
  807. }
  808. }
  809. }
  810. return json_success('', $times);
  811. }
  812. }
  813. }