Lesson.php 35 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001
  1. <?php
  2. namespace app\api\controller;
  3. use app\common\controller\Api;
  4. use think\Db;
  5. /**
  6. * 售课
  7. */
  8. class Lesson extends Api
  9. {
  10. // 无需登录的接口,*表示全部
  11. protected $noNeedLogin = [];
  12. // 无需鉴权的接口,*表示全部
  13. protected $noNeedRight = ['*'];
  14. //售课列表
  15. public function lists(){
  16. $list = Db::name('lesson')->where('is_show',1)->order('weigh desc')->autopage()->select();
  17. $list = list_domain_image($list,['image']);
  18. $list = $this->list_lang($list,['name','title','info','shiherenqun','pingjunrenshu','sirenkecheng','daoshi']);
  19. $this->success(1,$list);
  20. }
  21. //售课分类列表
  22. public function lesson_cate(){
  23. $list = Db::name('lesson_cate')->order('id asc')->select();
  24. $list = $this->list_lang($list,['name']);
  25. $this->success(1,$list);
  26. }
  27. //日历列表
  28. //教练列表
  29. public function coach_list(){
  30. $list = Db::name('coach')->field('id,nickname,avatar')->where('status',1)->order('nickname asc')->select();
  31. $list = list_domain_image($list,['avatar']);
  32. $this->success(1,$list);
  33. }
  34. //课时列表首页
  35. //根据年,月获取当月剩余日期,有课程的标记1
  36. public function slot_index(){
  37. $getdate = input('date',date('Y-m'));
  38. if(empty($getdate)){
  39. $getdate = date('Y-m');
  40. }
  41. $year = substr($getdate,0,4);
  42. $month = substr($getdate,-2,2);
  43. //今天是哪日
  44. if($year == date('Y') && $month == date('m')){
  45. //如果是今年今月,默认今天开始
  46. $startday = date('d');
  47. }else{
  48. //从1号开始
  49. $startday = '01';
  50. }
  51. //所有课程点进来的 额外传参
  52. $lesson_id = input('lesson_id',0);
  53. if($lesson_id){
  54. $first_starttime = Db::name('lesson_slot')->where('lesson_id',$lesson_id)->where('status',0)->where('starttime','gt',time())->where('is_show',1)->order('starttime asc')->value('starttime');
  55. // $first_startdate = date('Y-m-d H:i:s',$first_starttime);dump($first_startdate);exit;
  56. if($first_starttime){
  57. $year = date('Y',$first_starttime);
  58. $month = date('m',$first_starttime);
  59. $startday = date('d',$first_starttime);
  60. }
  61. }
  62. //一周
  63. $week_arr = [
  64. 1 => '周一',
  65. 2 => '周二',
  66. 3 => '周三',
  67. 4 => '周四',
  68. 5 => '周五',
  69. 6 => '周六',
  70. 7 => '周日',
  71. ];
  72. //本月结束日
  73. $endday_arr = [
  74. '01' => 31,
  75. '02' => 28,
  76. '03' => 31,
  77. '04' => 30,
  78. '05' => 31,
  79. '06' => 30,
  80. '07' => 31,
  81. '08' => 31,
  82. '09' => 30,
  83. '10' => 31,
  84. '11' => 30,
  85. '12' => 31,
  86. ];
  87. if($year%4 == 0){
  88. $endday_arr['02'] = 29;
  89. }
  90. $endday = $endday_arr[$month];
  91. //拿数据
  92. $startdate = $getdate.'-'.$startday;
  93. $enddate = $getdate.'-'.$endday;
  94. $where = [
  95. 'starttime' => ['BETWEEN',[strtotime($startdate),strtotime($enddate)+86399]],
  96. 'status' => 0,
  97. 'is_show' => 1,
  98. ];
  99. //dump($where);exit;
  100. $slots = Db::name('lesson_slot')->where($where)->field('id,starttime')->select();
  101. $date_arr = [];
  102. for($i=intval($startday);$i<=$endday;$i++){
  103. $j = $i;
  104. if($j < 10){
  105. $j = 0 . $j;
  106. }
  107. $idate = $year.'-'.$month.'-'.$j;
  108. $itime = strtotime($idate);
  109. $week = $this->lang == 'en' ? date('D',$itime) : $week_arr[date('N',$itime)];
  110. $i_data = [
  111. 'yeah' =>$year,
  112. 'month'=>$month,
  113. 'day' => $j.'',
  114. 'date' => $idate,
  115. 'week' => $week,
  116. 'is_today' => 0,
  117. 'slot_num' => 0,
  118. 'date_show'=> $this->lang == 'en' ? $j.'.'.$month : $month.'.'.$j,
  119. ];
  120. foreach($slots as $slot){
  121. if(date('Y-m-d',$slot['starttime']) == $idate)
  122. {
  123. $i_data['slot_num'] += 1;
  124. }
  125. }
  126. if($idate == date('Y-m-d')){
  127. $i_data['is_today'] = 1;
  128. }
  129. $date_arr[] = $i_data;
  130. }
  131. $this->success(1,$date_arr);
  132. }
  133. //某日课时列表
  134. public function slot_list(){
  135. $date = strtotime(input('date',date('Y-m-d')));
  136. $cate_id = input('cate_id',0);
  137. $coach_id = input('coach_id',0);
  138. //所有课程点进来的 额外传参
  139. $lesson_id = input('lesson_id',0);
  140. $where = [
  141. 'slot.starttime' => ['BETWEEN',[$date,$date+86399]],
  142. 'slot.status' => 0,
  143. 'slot.is_show' => 1,
  144. ];
  145. //课时
  146. $list = Db::name('lesson_slot')->alias('slot')
  147. ->field('slot.*,lesson.name,lesson.name_en,lesson.image,lesson.price')
  148. ->join('lesson','slot.lesson_id = lesson.id','LEFT')
  149. ->where($where);
  150. if($lesson_id){
  151. $list->where('slot.lesson_id',$lesson_id);
  152. }else{
  153. if($cate_id){
  154. $list->where('lesson.lessoncate_id',$cate_id);
  155. }
  156. if($coach_id){
  157. $list->where('find_in_set(:coach_ids,coach_ids)', ['coach_ids' => $coach_id]);
  158. }
  159. }
  160. $list = $list->order('slot.starttime asc')->select();
  161. if(empty($list)){
  162. $this->success(1,[]);
  163. }
  164. $list = list_domain_image($list,['image']);
  165. $list = $this->list_lang($list,['name']);
  166. //准备教练数据
  167. $coach_list = Db::name('coach')->column('id,nickname');
  168. foreach($list as $key => &$slot){
  169. //hours转换
  170. $slot['hours'] = floatval($slot['hours']);
  171. //放入教练
  172. $coach_text = '';
  173. $coach_ids = explode(',',$slot['coach_ids']);
  174. foreach($coach_ids as $coach_id){
  175. if(isset($coach_list[$coach_id])){
  176. $coach_text .= $coach_list[$coach_id].',';
  177. }
  178. }
  179. $slot['coach_text'] = substr($coach_text,0,-1);
  180. //剩余空位数量
  181. $pay_number = Db::name('lesson_order')->where('slot_id',$slot['id'])->where('order_status',10)->sum('usernumber');
  182. $slot['num_remain'] = $slot['num_max'] - $pay_number;
  183. if($slot['num_remain'] < 0){
  184. $slot['num_remain'] = 0;
  185. }
  186. //剩余候补数量
  187. $slot['wait_remain'] = 0;
  188. if($slot['waitnum_max'] > 0){
  189. $wait_number = Db::name('lesson_order')->where('slot_id',$slot['id'])->where('jointype',2)->sum('usernumber');
  190. $slot['wait_remain'] = $slot['waitnum_max'] - $wait_number;
  191. if($slot['wait_remain'] < 0){
  192. $slot['wait_remain'] = 0;
  193. }
  194. }
  195. //预约按钮,1能预约,0不能
  196. $slot['button_status'] = 0;
  197. if($slot['status'] == 0 && $slot['num_remain'] > 0){
  198. $slot['button_status'] = 1;//能预约
  199. }
  200. if($slot['status'] == 0 && $slot['wait_remain'] > 0){
  201. $slot['button_status'] = 2;//能候补
  202. }
  203. //右上角备注
  204. if(time() >= $slot['starttime']){
  205. $slot['num_remark'] = __('报名已截止');
  206. $slot['button_status'] = 0;//报名截止了,强制改
  207. }else{
  208. // $slot['num_remark'] = __('剩N个名额',['number'=>$slot['num_remain']]);
  209. $slot['num_remark'] = $pay_number.'/'.$slot['num_max'];
  210. if($slot['waitnum_max'] > 0){
  211. $slot['num_remark'] .= '--'.$wait_number.'/'.$slot['waitnum_max'];
  212. }
  213. }
  214. }
  215. $this->success(1,$list);
  216. }
  217. public function test(){
  218. echo __('剩N个名额',['number'=>8]);
  219. }
  220. //课时详情
  221. public function slot_info(){
  222. $slot_id = input('slot_id',0);
  223. $number = input('number',1,'intval');
  224. //课时
  225. $info = Db::name('lesson_slot')->alias('slot')
  226. ->field('slot.*,lesson.name,lesson.name_en,lesson.image,lesson.price')
  227. ->join('lesson','slot.lesson_id = lesson.id','LEFT')
  228. ->where('slot.id',$slot_id)->where('slot.is_show',1)->find();
  229. if(empty($info)){
  230. $this->error('课程可能已取消,请刷新重试');
  231. }
  232. $info = info_domain_image($info,['image']);
  233. $info = $this->info_lang($info,['name']);
  234. //准备教练数据
  235. $coach_list = Db::name('coach')->where('id','IN',$info['coach_ids'])->column('nickname');
  236. $info['coach_text'] = implode(',',$coach_list);
  237. //剩余空位数量
  238. $pay_number = Db::name('lesson_order')->where('slot_id',$info['id'])->where('order_status',10)->sum('usernumber');
  239. $info['num_remain'] = $info['num_max'] - $pay_number;
  240. if($info['num_remain'] < 0){
  241. $info['num_remain'] = 0;
  242. }
  243. //剩余候补数量
  244. $info['wait_remain'] = 0;
  245. if($info['waitnum_max'] > 0){
  246. $wait_number = Db::name('lesson_order')->where('slot_id',$info['id'])->where('jointype',2)->sum('usernumber');
  247. $info['wait_remain'] = $info['waitnum_max'] - $wait_number;
  248. if($info['wait_remain'] < 0){
  249. $info['wait_remain'] = 0;
  250. }
  251. }
  252. //时间
  253. if($this->lang == 'en'){
  254. $info['slot_time'] = date('M d',$info['starttime']).'('.date('D',$info['starttime']).')'.','.date('H:i',$info['starttime']).'-'.date('H:i',$info['endtime']);
  255. }else{
  256. $info['slot_time'] = date('n月d',$info['starttime']).'(周'.date('N',$info['starttime']).')'.','.date('H:i',$info['starttime']).'-'.date('H:i',$info['endtime']);
  257. }
  258. //是否有可买配套
  259. $wait_buy_package = Db::name('lesson_package')
  260. ->where('find_in_set(:lesson_ids,lesson_ids)', ['lesson_ids' => $info['lesson_id']])
  261. ->where('is_show',1)
  262. ->find();
  263. $info['wait_buy_package'] = !empty($wait_buy_package) ? 1 : 0;
  264. //预约按钮,1能预约,0不能
  265. $info['button_status'] = 0;
  266. if($info['status'] == 0 && $info['num_remain'] > 0){
  267. $info['button_status'] = 1;//能预约
  268. }
  269. if($info['status'] == 0 && $info['wait_remain'] > 0){
  270. $info['button_status'] = 2;//能候补
  271. }
  272. //右上角备注
  273. if(time() >= $info['starttime']){
  274. $info['button_status'] = 0;//报名截止了,强制改
  275. }
  276. //总价格乘出来
  277. $info['price'] = bcmul($info['price'],$number,2);
  278. //此课程是否还有未使用的套餐(多个包含赠送的)
  279. $number_hours = bcmul($number,$info['hours'],1);//每日课时按小时扣
  280. $map = [
  281. 'o.user_id' =>$this->auth->id,
  282. 'o.endtime' => ['gt',time()],
  283. 'o.remain' => ['egt',$number_hours], //不能只是大于0,还得大于等于报名人数
  284. 'o.order_status' => 1,
  285. // 'o.use_status' => 1, //已激活的。未激活的也要展示,但是变灰
  286. ];
  287. $package_list = Db::name('package_order')->alias('o')
  288. ->join('lesson_package p','o.package_id = p.id','LEFT')
  289. ->field('o.id,o.remain,o.starttime,o.endtime,o.is_gift,p.name,p.name_en')
  290. ->where($map)
  291. ->where('find_in_set(:lesson_ids,o.lesson_ids)', ['lesson_ids' => $info['lesson_id']])
  292. ->order('o.endtime asc')->select();
  293. $package_list = $this->list_lang($package_list,['name']);
  294. if(!empty($package_list)){
  295. foreach($package_list as $key => &$val){
  296. //转换remain
  297. $val['remain'] = floatval($val['remain']);
  298. if($this->lang == 'zh-cn'){
  299. $val['time_text'] = date('m月d,Y',$val['starttime']).'-'.date('m月d,Y',$val['endtime']);
  300. }else{
  301. $val['time_text'] = date('M d,Y',$val['starttime']).'-'.date('M d,Y',$val['endtime']);
  302. }
  303. }
  304. }
  305. $info['package_list'] = $package_list;
  306. //可用试课
  307. if($number == 1){
  308. $try_map = [
  309. 'o.user_id' => $this->auth->id,
  310. 'o.endtime' => ['gt',time()],
  311. 'o.order_status' => 10,
  312. ];
  313. $tryorder_list = Db::name('trylesson_order')->alias('o')
  314. ->join('trylesson','o.trylesson_id = trylesson.id','LEFT')
  315. ->field('o.id,o.starttime,o.endtime,trylesson.name,trylesson.name_en')
  316. ->where($try_map)
  317. ->where('find_in_set(:lesson_ids,o.lesson_ids)', ['lesson_ids' => $info['lesson_id']])
  318. ->order('o.endtime asc')->select();
  319. $tryorder_list = $this->list_lang($tryorder_list,['name']);
  320. if(!empty($tryorder_list)){
  321. foreach($tryorder_list as $key => &$val){
  322. if($this->lang == 'zh-cn'){
  323. $val['time_text'] = date('m月d,Y',$val['starttime']).'-'.date('m月d,Y',$val['endtime']);
  324. }else{
  325. $val['time_text'] = date('M d,Y',$val['starttime']).'-'.date('M d,Y',$val['endtime']);
  326. }
  327. }
  328. }
  329. }else{
  330. $tryorder_list = [];
  331. }
  332. $info['tryorder_list'] = $tryorder_list;
  333. //hours转换
  334. $info['hours'] = floatval($info['hours']);
  335. $this->success(1,$info);
  336. }
  337. //课时申请报名
  338. public function slot_apply(){
  339. $this->apiLimit();
  340. $slot_id = input('slot_id',0,'intval');
  341. $number = input('number',1,'intval');
  342. $remark = input('remark','','trim');
  343. $paytype = input('paytype',1,'intval');//支付类型:1=课程套餐,2=线上付款,3=购买套餐中,4=试课单,5=候补
  344. $packageorder_id = input('packageorder_id',0,'intval');
  345. $trylessonorder_id = input('trylessonorder_id',0,'intval');
  346. $jointype = input('jointype',1);//预约类型:1=预约,2=候补
  347. if($number <= 0){
  348. $this->error('预约人数错误');
  349. }
  350. if(!in_array($paytype,[1,2,3,4])){
  351. $this->error();
  352. }
  353. if(!in_array($jointype,[1,2])){
  354. $this->error();
  355. }
  356. //课时
  357. $info = Db::name('lesson_slot')->alias('slot')
  358. ->field('slot.*,lesson.name,lesson.name_en,lesson.image,lesson.price')
  359. ->join('lesson','slot.lesson_id = lesson.id','LEFT')
  360. ->where('slot.id',$slot_id)->where('slot.status',0)->where('slot.is_show',1)->find();
  361. if(empty($info)){
  362. $this->error('课程可能已取消,请刷新重试');
  363. }
  364. if($info['endtime'] < time()){
  365. $this->error('课程已经结束了,不能再进行预约');
  366. }
  367. //剩余空位数量
  368. $pay_number = Db::name('lesson_order')->where('slot_id',$slot_id)->where('order_status',10)->sum('usernumber');
  369. $num_remain = $info['num_max'] - $pay_number;
  370. if($num_remain < 0){
  371. $num_remain = 0;
  372. }
  373. //剩余候补数量
  374. $wait_remain = 0;
  375. if($info['waitnum_max'] > 0){
  376. $wait_number = Db::name('lesson_order')->where('slot_id',$info['id'])->where('jointype',2)->sum('usernumber');
  377. $wait_remain = $info['waitnum_max'] - $wait_number;
  378. if($wait_remain < 0){
  379. $wait_remain = 0;
  380. }
  381. }
  382. //报名人数不能超限
  383. if($jointype == 1){
  384. if($num_remain < $number){
  385. $this->error(__('预约名额只剩N名',['number'=>$num_remain]));
  386. }
  387. //可以继续
  388. }else{
  389. if($num_remain > 0){
  390. $this->error(__('预约还有名额,不能候补'));
  391. }
  392. //候补人数不能超限
  393. if($wait_remain < $number){
  394. $this->error(__('候补名额只剩N名',['number'=>$wait_remain]));
  395. }
  396. //可以继续
  397. $paytype = 5;//强改支付方式,候补
  398. }
  399. //
  400. $number_hours = bcmul($number,$info['hours'],1);//每日课时按小时扣
  401. $lesson_order = [
  402. 'order_no' => createUniqueNo('S',$this->auth->id),
  403. 'user_id' => $this->auth->id,
  404. 'slot_id' => $slot_id,
  405. 'lesson_id' => $info['lesson_id'],
  406. 'order_amount' => bcmul($info['price'],$number,2),
  407. 'order_status' => 0,
  408. 'paytype' => $paytype, //支付类型:1=课程套餐,2=线上付款,3=购买套餐中,4=试课单,5=候补
  409. 'paytime' => 0,
  410. 'createtime' => time(),
  411. // 'updatetime' => ,
  412. // 'finishtime' => ,
  413. 'usernumber' => $number,
  414. 'usernumber_hours' => $number_hours,
  415. 'userremark' => $remark,
  416. 'package_order_id' => 0,
  417. 'package_remark' => '',// 比如:5/30,5-7/30
  418. 'jointype' => $jointype,
  419. ];
  420. //
  421. Db::startTrans();
  422. if($paytype == 1){
  423. //检查已选择套餐
  424. $map = [
  425. 'user_id' =>$this->auth->id,
  426. 'endtime' => ['gt',time()],
  427. 'remain' => ['gt',0],
  428. 'order_status' => 1,
  429. // 'use_status' => 1, //已激活的
  430. 'id' => $packageorder_id,
  431. ];
  432. $package_order = Db::name('package_order')->where($map)->where('find_in_set(:lesson_ids,lesson_ids)', ['lesson_ids' => $info['lesson_id']])->lock(true)->find();
  433. if(!$package_order){
  434. Db::rollback();
  435. $this->error('配套信息不正确,请刷新重试');
  436. }
  437. //课时不足支撑报名人数
  438. if($package_order['remain'] < $number_hours){
  439. Db::rollback();
  440. $this->error('该配套余额不足,可以使用其他支付方式');
  441. }
  442. if($package_order['use_status'] != 1){
  443. Db::rollback();
  444. $this->error('该配套尚未激活');
  445. }
  446. //扣除一节
  447. $update = [
  448. 'remain' => bcsub($package_order['remain'],$number_hours,1),
  449. 'updatetime' => time(),
  450. ];
  451. $rs1 = Db::name('package_order')->where('id',$packageorder_id)->update($update);
  452. if($rs1 === false){
  453. Db::rollback();
  454. $this->error('扣除套餐余额失败');
  455. }
  456. //修改预约单数据
  457. $lesson_order['order_amount'] = 0;
  458. $lesson_order['order_status'] = 10;
  459. $lesson_order['paytime'] = time();
  460. $lesson_order['package_order_id'] = $packageorder_id;
  461. $lesson_order['package_remark'] = ($package_order['sessions'] - $package_order['remain']) . '-' . ($package_order['sessions'] - $package_order['remain'] + $number_hours) .'/'. $package_order['sessions'];
  462. //预约单写入
  463. $lesson_order_id = Db::name('lesson_order')->insertGetId($lesson_order);
  464. if(!$lesson_order_id){
  465. Db::rollback();
  466. $this->error('预约失败');
  467. }
  468. //更新已预约人数
  469. $pay_number = Db::name('lesson_order')->where('slot_id',$slot_id)->where('order_status',10)->sum('usernumber');
  470. $rs_slot = Db::name('lesson_slot')->where('id',$slot_id)->update(['bookednum' => $pay_number]);
  471. if($rs_slot === false){
  472. Db::rollback();
  473. $this->error('预约失败');
  474. }
  475. Db::commit();
  476. $this->success('预约成功',['returntype'=>1]);
  477. }
  478. elseif($paytype == 2)
  479. {
  480. //预约单写入
  481. $lesson_order_id = Db::name('lesson_order')->insertGetId($lesson_order);
  482. if(!$lesson_order_id){
  483. Db::rollback();
  484. $this->error('预约失败');
  485. }
  486. //支付订单下单
  487. $pay_order = [];
  488. $pay_order['user_id'] = $lesson_order['user_id'];
  489. $pay_order['out_trade_no'] = $lesson_order['order_no'];
  490. $pay_order['order_amount'] = $lesson_order['order_amount'];
  491. $pay_order['createtime'] = $lesson_order['createtime'];
  492. $pay_order['pay_type'] = 'hitpay';
  493. $pay_order['platform'] = 'app';
  494. $pay_order['order_status'] = 0;
  495. $pay_order['table_name'] = 'lesson_order';
  496. $pay_order['table_id'] = $lesson_order_id;
  497. $pay_order['args'] = '';
  498. //拉起支付
  499. $notify_url = config('notify_cdnurl');
  500. $redirect_cdnurl = config('hitpay.lesson_redirect_cdnurl').'?out_trade_no='.$pay_order['out_trade_no'].'&lang='.$this->lang;
  501. $hitpay_return = $this->hitpay_payment($pay_order['out_trade_no'],$pay_order['order_amount'],$notify_url,$redirect_cdnurl);
  502. if($hitpay_return['status'] !== true){
  503. $this->error($hitpay_return['msg']);
  504. }
  505. //支付请求id
  506. $pay_order['payment_request_id'] = $hitpay_return['id'];
  507. $pay_order_id = Db::name('pay_order')->insertGetId($pay_order);
  508. if(!$pay_order_id){
  509. Db::rollback();
  510. $this->error('下单失败');
  511. }
  512. Db::commit();
  513. $return = [
  514. 'url' => $hitpay_return['url'],
  515. 'id' => $hitpay_return['id'],
  516. 'returntype' => 2,
  517. ];
  518. $this->success(1,$return);
  519. }
  520. elseif($paytype == 3)
  521. {
  522. //预约单写入
  523. $lesson_order['order_amount'] = 0;
  524. $lesson_order_id = Db::name('lesson_order')->insertGetId($lesson_order);
  525. if(!$lesson_order_id){
  526. Db::rollback();
  527. $this->error('预约失败');
  528. }
  529. Db::commit();
  530. //去购买套餐,参数代入过去
  531. $return = [
  532. 'lesson_order_id' => $lesson_order_id,
  533. 'returntype' => 3,
  534. ];
  535. $this->success(1,$return);
  536. }
  537. elseif($paytype == 4)
  538. {
  539. //使用试课单
  540. $map = [
  541. 'id' => $trylessonorder_id,
  542. 'user_id' =>$this->auth->id,
  543. 'endtime' => ['gt',time()],
  544. 'order_status' => 10,
  545. ];
  546. $trylesson_order = Db::name('trylesson_order')->where($map)->where('find_in_set(:lesson_ids,lesson_ids)', ['lesson_ids' => $info['lesson_id']])->lock(true)->find();
  547. if(!$trylesson_order){
  548. Db::rollback();
  549. $this->error('试课信息不正确,请刷新重试');
  550. }
  551. //修改预约单数据
  552. $lesson_order['order_amount'] = 0;
  553. $lesson_order['order_status'] = 10;
  554. $lesson_order['paytime'] = time();
  555. $lesson_order['trylesson_order_id'] = $trylessonorder_id;
  556. //预约单写入
  557. $lesson_order_id = Db::name('lesson_order')->insertGetId($lesson_order);
  558. if(!$lesson_order_id){
  559. Db::rollback();
  560. $this->error('预约失败');
  561. }
  562. //改掉试课单状态
  563. $update = [
  564. 'order_status' => 20,
  565. 'updatetime' => time(),
  566. 'lesson_order_id' => $lesson_order_id,
  567. ];
  568. $rs1 = Db::name('trylesson_order')->where('id',$trylessonorder_id)->update($update);
  569. if($rs1 === false){
  570. Db::rollback();
  571. $this->error('使用试课失败');
  572. }
  573. //更新已预约人数
  574. $pay_number = Db::name('lesson_order')->where('slot_id',$slot_id)->where('order_status',10)->sum('usernumber');
  575. $rs_slot = Db::name('lesson_slot')->where('id',$slot_id)->update(['bookednum' => $pay_number]);
  576. if($rs_slot === false){
  577. Db::rollback();
  578. $this->error('预约失败');
  579. }
  580. Db::commit();
  581. $this->success('预约成功',['returntype'=>4]);
  582. }
  583. elseif($paytype == 5)
  584. {
  585. //检查可用的套餐,找一个就可以
  586. $map = [
  587. 'user_id' =>$this->auth->id,
  588. 'endtime' => ['gt',time()],
  589. 'remain' => ['gt',$number_hours],
  590. 'order_status' => 1,
  591. 'use_status' => 1, //已激活的
  592. ];
  593. $package_order = Db::name('package_order')->where($map)->where('find_in_set(:lesson_ids,lesson_ids)', ['lesson_ids' => $info['lesson_id']])->find();
  594. if(!$package_order){
  595. Db::rollback();
  596. $this->error('没有找到足够预约人数的配套,请刷新重试');
  597. }
  598. //扣除一节。延迟到转正的时候处理
  599. /*$update = [
  600. 'remain' => bcsub($package_order['remain'],$number_hours,1),
  601. 'updatetime' => time(),
  602. ];
  603. $rs1 = Db::name('package_order')->where('id',$packageorder_id)->update($update);
  604. if($rs1 === false){
  605. Db::rollback();
  606. $this->error('扣除套餐余额失败');
  607. }*/
  608. //修改预约单数据。延迟到转正的时候处理
  609. /*$lesson_order['order_amount'] = 0;
  610. $lesson_order['order_status'] = 10;
  611. $lesson_order['paytime'] = time();
  612. $lesson_order['package_order_id'] = $packageorder_id;
  613. $lesson_order['package_remark'] = ($package_order['sessions'] - $package_order['remain']) . '-' . ($package_order['sessions'] - $package_order['remain'] + $number_hours) .'/'. $package_order['sessions'];*/
  614. //预约单写入
  615. $lesson_order_id = Db::name('lesson_order')->insertGetId($lesson_order);
  616. if(!$lesson_order_id){
  617. Db::rollback();
  618. $this->error('预约失败');
  619. }
  620. //更新已预约人数。候补就不需要了
  621. /*$pay_number = Db::name('lesson_order')->where('slot_id',$slot_id)->where('order_status',10)->sum('usernumber');
  622. $rs_slot = Db::name('lesson_slot')->where('id',$slot_id)->update(['bookednum' => $pay_number]);
  623. if($rs_slot === false){
  624. Db::rollback();
  625. $this->error('预约失败');
  626. }*/
  627. Db::commit();
  628. $this->success('预约候补成功',['returntype'=>5]);
  629. }
  630. }
  631. //配套商店 所有套餐列表
  632. public function package_shop(){
  633. $where2 = [];
  634. //排除限购一次的
  635. $map = [
  636. 'o.user_id' => $this->auth->id,
  637. 'o.order_status' => 1,
  638. 'o.is_gift' => 0,
  639. 'p.buytimes' => 1,
  640. ];
  641. $check_first = Db::name('package_order')->alias('o')
  642. ->join('lesson_package p','o.package_id = p.id','LEFT')
  643. ->where($map)->column('o.package_id');
  644. if(!empty($check_first)){
  645. $where2['id'] = ['NOTIN',$check_first];
  646. }
  647. //排除新旧会员群体
  648. if($this->auth->oldstatus == 0){ //新会员
  649. $where2['newuser'] = 1;
  650. }
  651. if($this->auth->oldstatus == 1){ //旧会员
  652. $where2['olduser'] = 1;
  653. }
  654. //套餐列表
  655. $list = Db::name('lesson_package')
  656. ->where('is_show',1)
  657. ->where($where2)
  658. ->order('weigh desc')->select();
  659. $list = list_domain_image($list,['image']);
  660. $list = $this->list_lang($list,['name','validity','activeremark']);
  661. $this->success(1,$list);
  662. }
  663. //从预约过来的 售课套餐列表
  664. public function package_list(){
  665. $lesson_id = input('lesson_id',0);
  666. $where2 = [];
  667. //排除限购一次的
  668. $map = [
  669. 'o.user_id' => $this->auth->id,
  670. 'o.order_status' => 1,
  671. 'o.is_gift' => 0,
  672. 'p.buytimes' => 1,
  673. ];
  674. $check_first = Db::name('package_order')->alias('o')
  675. ->join('lesson_package p','o.package_id = p.id','LEFT')
  676. ->where($map)->column('o.package_id');
  677. if(!empty($check_first)){
  678. $where2['id'] = ['NOTIN',$check_first];
  679. }
  680. //排除新旧会员群体
  681. if($this->auth->oldstatus == 0){ //新会员
  682. $where2['newuser'] = 1;
  683. }
  684. if($this->auth->oldstatus == 1){ //旧会员
  685. $where2['olduser'] = 1;
  686. }
  687. //套餐列表
  688. $list = Db::name('lesson_package')
  689. ->where('find_in_set(:lesson_ids,lesson_ids)', ['lesson_ids' => $lesson_id])
  690. ->where('is_show',1)
  691. ->where($where2)
  692. ->order('weigh desc')->select();
  693. $list = list_domain_image($list,['image']);
  694. $list = $this->list_lang($list,['name','validity','activeremark']);
  695. $this->success(1,$list);
  696. }
  697. //售课套餐详情
  698. public function package_info(){
  699. $package_id = input('package_id',0);
  700. //套餐详情
  701. $list = Db::name('lesson_package')
  702. ->where('id',$package_id)
  703. ->order('weigh desc')->find();
  704. $list = info_domain_image($list,['image']);
  705. $list = $this->info_lang($list,['name','validity','activeremark','content']);
  706. $this->success(1,$list);
  707. }
  708. //下单购买售课套餐
  709. public function package_buy(){
  710. $package_id = input('package_id',0);
  711. $lesson_order_id = input('lesson_order_id',0,'intval');//预约单id
  712. $package_info = Db::name('lesson_package')->where('id',$package_id)->find();
  713. //如果限购,则报错
  714. if($package_info['buytimes'] == 1){
  715. $map = [
  716. 'user_id' => $this->auth->id,
  717. 'order_status' => 1,
  718. 'is_gift' => 0,
  719. 'package_id' => $package_id,
  720. ];
  721. $check_first = Db::name('package_order')->where($map)->find();
  722. if(!empty($check_first)){
  723. $this->error('该配套限购一次,您已经买过了');
  724. }
  725. }
  726. //排除新旧会员群体
  727. if($this->auth->oldstatus == 0 && $package_info['newuser'] != 1 ){ //新会员
  728. $this->error('您不能购买改配套,请刷新并重试');
  729. }
  730. if($this->auth->oldstatus == 1 && $package_info['olduser'] != 1 ){ //旧会员
  731. $this->error('您不能购买改配套,请刷新并重试');
  732. }
  733. //套餐订单
  734. $data = [
  735. 'order_no' => createUniqueNo('P',$this->auth->id),
  736. 'user_id' => $this->auth->id,
  737. 'package_id' => $package_id,
  738. 'lesson_ids' => $package_info['lesson_ids'],
  739. 'sessions' => $package_info['sessions'],
  740. 'starttime' => 0,
  741. 'days' => $package_info['days'],
  742. 'endtime' => 0,
  743. 'price' => $package_info['price'],
  744. 'remain' => $package_info['sessions'],
  745. 'order_status'=> 0,
  746. 'use_status' => 0,//默认不激活
  747. 'paytime' => 0,
  748. 'pay_type' => 1, //线上支付
  749. 'createtime' => time(),
  750. 'updatetime' => 0,
  751. 'is_gift' => 0,
  752. ];
  753. //如果有赠品,赠品订单
  754. $gift = [];
  755. if(!empty($package_info['gift_lesson_id']) && !empty($package_info['gift_sessions'])){
  756. $gift = $data;
  757. //订单号不换了
  758. $gift['lesson_ids'] = $package_info['gift_lesson_id'];
  759. $gift['sessions'] = $package_info['gift_sessions'];
  760. $gift['remain'] = $package_info['gift_sessions'];
  761. $gift['is_gift'] = 1;
  762. }
  763. //支付订单下单
  764. $pay_order = [];
  765. $pay_order['user_id'] = $data['user_id'];
  766. $pay_order['out_trade_no'] = $data['order_no'];
  767. $pay_order['order_amount'] = $data['price'];
  768. $pay_order['createtime'] = $data['createtime'];
  769. $pay_order['pay_type'] = 'hitpay';
  770. $pay_order['platform'] = 'app';
  771. $pay_order['order_status'] = 0;
  772. $pay_order['table_name'] = 'package_order';
  773. $pay_order['table_id'] = 0;
  774. $pay_order['args'] = json_encode(['lesson_order_id'=>$lesson_order_id]);//用来支付完成回调时,扣除N节课,并改掉预约单的状态
  775. //拉起支付
  776. $notify_url = config('notify_cdnurl');
  777. $redirect_cdnurl = config('hitpay.package_redirect_cdnurl').'?out_trade_no='.$pay_order['out_trade_no'].'&lang='.$this->lang;
  778. $hitpay_return = $this->hitpay_payment($pay_order['out_trade_no'],$pay_order['order_amount'],$notify_url,$redirect_cdnurl);
  779. if($hitpay_return['status'] !== true){
  780. $this->error($hitpay_return['msg']);
  781. }
  782. //支付请求id
  783. $pay_order['payment_request_id'] = $hitpay_return['id'];
  784. //入库
  785. Db::startTrans();
  786. $order_id = Db::name('package_order')->insertGetId($data);
  787. if(!$order_id){
  788. Db::rollback();
  789. $this->error('下单失败');
  790. }
  791. //礼物
  792. if(!empty($gift)){
  793. $gift_order_id = Db::name('package_order')->insertGetId($gift);
  794. if(!$gift_order_id){
  795. Db::rollback();
  796. $this->error('下单失败');
  797. }
  798. }
  799. //支付单
  800. $pay_order['table_id'] = $order_id;
  801. $pay_order_id = Db::name('pay_order')->insertGetId($pay_order);
  802. if(!$pay_order_id){
  803. Db::rollback();
  804. $this->error('下单失败');
  805. }
  806. Db::commit();
  807. $return = [
  808. 'url' => $hitpay_return['url'],
  809. 'id' => $hitpay_return['id'],
  810. ];
  811. $this->success(1,$return);
  812. }
  813. //拉起支付
  814. private function hitpay_payment($out_trade_no,$money,$notifyurl,$redirect_cdnurl)
  815. {
  816. $return = [
  817. 'status' => false,
  818. 'msg' => '',
  819. 'url' => '',
  820. 'id' => 0,
  821. ];
  822. $apiKey = config('hitpay.apikey');
  823. try {
  824. $hitPayClient = new \HitPay\Client($apiKey, true);
  825. $request = new \HitPay\Request\CreatePayment();
  826. $request->setAmount($money)
  827. ->setCurrency('SGD')
  828. ->setRedirectUrl($redirect_cdnurl)
  829. // ->setPaymentMethods(['paynow_online','card'])
  830. ->setPaymentMethods(['paynow_online'])
  831. ->setPurpose('Elin Dance Studio')
  832. ->setWebhook($notifyurl)
  833. ->setReferenceNumber($out_trade_no);
  834. $result = $hitPayClient->createPayment($request);
  835. $return['status'] = true;
  836. $return['url'] = $result->getUrl();
  837. $return['id'] = $result->getId();
  838. //print_r($result);
  839. /*$data = $hitPayClient->getPaymentStatus($result->getId());
  840. dump($data);
  841. dump($data->status);*/
  842. /*$data = $hitPayClient->deletePaymentRequest($data->getId());
  843. print_r($data);*/
  844. } catch (\Exception $e) {
  845. $return['msg'] = $e->getMessage();
  846. }
  847. return $return;
  848. }
  849. }