VideoVip.php 6.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186
  1. <?php namespace App\Http\Controllers\Admin;
  2. use App\Http\Requests\Admin\Video\VideoVip as Request;
  3. use App\Models\Custom;
  4. use App\Models\Video\VideoVip as Model;
  5. /**
  6. * 课程会员
  7. *
  8. * @author huanglei
  9. *
  10. */
  11. class VideoVip extends Auth{
  12. protected function _initialize(){
  13. parent::_initialize();
  14. $this->assign('breadcrumb1','课程管理');
  15. $this->assign('breadcrumb2','课程会员');
  16. }
  17. /**
  18. * 首页列表
  19. *
  20. * */
  21. public function index(Model $Model,Custom $Custom){
  22. // 接受参数
  23. $code = request('custom_code','');
  24. $customName = request('custom_name',0);
  25. $customPhone = request('custom_phone',0);
  26. $status = request('status');
  27. // 编码转ID
  28. $uid = $Custom->codeToId($code);
  29. // 查询条件
  30. $map = [];
  31. // 编码ID
  32. if( $uid ) $map[] = ['custom_uid','=',$uid];
  33. if( $customName ) $map[] = ['custom.username','LIKE','%'.$customName.'%'];
  34. if( $customPhone ) $map[] = ['custom.phone','=',$customPhone];
  35. if( !is_null($status) ) $map[] = ['video_vip.status','=',$status];
  36. // 查询数据
  37. $list = $Model->query()->join('custom','video_vip.custom_uid','=','custom.uid')->where($map)->orderByDesc('id')->select(['video_vip.*','custom.username as custom_name','custom.phone as custom_phone'])->paginate(request('limit',config('page_num',10)))->appends(request()->all());
  38. // 循环处理数据
  39. foreach ($list as $key => $value) {
  40. // 编码
  41. $value['custom_code'] = $Custom->idToCode($value['custom_uid']);
  42. // 重组
  43. $list[$key] = $value;
  44. }
  45. // 分配数据
  46. $this->assign('empty', '<tr><td colspan="20">~~暂无数据</td></tr>');
  47. $this->assign('list', $list);
  48. // 加载模板
  49. return $this->fetch();
  50. }
  51. /**
  52. * 添加
  53. *
  54. * */
  55. public function add(Request $request,Model $Model,Custom $Custom){
  56. if( request()->isMethod('post') ){
  57. // 验证参数
  58. $request->scene('add')->validate();
  59. // 接收数据
  60. $startTime = request('start_time','');
  61. $endTime = request('end_time','');
  62. $customPhone = request('custom_phones','');
  63. $startTime = $startTime ? strtotime($startTime) : 0;
  64. $endTime = $endTime ? strtotime($endTime) : 0;
  65. // 兼容逗号问题
  66. $customPhone = str_ireplace(',',',',$customPhone);
  67. $customPhone = str_ireplace("\r\n",',',$customPhone);
  68. $customPhone = str_ireplace("\n",',',$customPhone);
  69. // 转数组处理
  70. $customPhone = explode(',',$customPhone);
  71. // 去重
  72. $customPhone = array_unique($customPhone);
  73. // 数量
  74. if( count($customPhone) > 1000 ) return json_send(['code'=>'error','msg'=>'请勿超过1000条']);
  75. // 循环处理
  76. foreach ($customPhone as $key=>$phone) {
  77. // 兼容空格
  78. $phone = trim($phone);
  79. // 正则判断是不是手机号
  80. if( !preg_match("/^1[345789]{1}\d{9}$/",$phone) ) return json_send(['code'=>'error','msg'=> $phone . '不是手机号']);
  81. // 转ID
  82. $custom = $Custom->getOneByPhone($phone);
  83. // 如果不存在,新增客户
  84. $customUid = $custom ? $custom['uid'] : $Custom->add(['phone'=>$phone,'username'=>hide_phone($phone)]);
  85. // id有问题
  86. if( !$customUid ) return json_send(['code'=>'error','msg'=> $phone.'创建用户失败']);
  87. // 重组
  88. $customPhone[$key] = $customUid;
  89. }
  90. // 客户列表
  91. $customPhone = is_array($customPhone) ? $customPhone : [];
  92. // 查询已经存在的会员
  93. $oldVip = $Model->query()->whereIn('custom_uid',$customPhone)->pluck('id','custom_uid')->toArray();
  94. // 不在存在的会员中的客户即新会员
  95. $newVip = array_diff($customPhone,array_keys($oldVip));
  96. // 存在的的用户修改
  97. $result = $oldVip ? $Model->query()->whereIn('id',$oldVip)->update(['start_time'=>$startTime,'end_time'=>$endTime,'status'=>0,'update_time'=>time()]) : true;
  98. // 更新失败
  99. if( !$result ) return json_send(['code'=>'error','msg'=>'修改失败']);
  100. // 重组数据
  101. foreach ($newVip as $key => $value) {
  102. // 重组
  103. $newVip[$key] = ['custom_uid'=>$value,'start_time'=>$startTime,'end_time'=>$endTime,'status'=>0,'insert_time'=>time(),'update_time'=>time()];
  104. }
  105. // 不存在的用户添加
  106. $result = $newVip ? $Model->query()->insert($newVip) : true;
  107. // 更新失败
  108. if( !$result ) return json_send(['code'=>'error','msg'=>'新增失败']);
  109. // 修改缓存
  110. $Model->getList(true);
  111. // 告知结果
  112. return json_send(['code'=>'success','msg'=>'新增成功','action'=>'add','path'=>url('admin/video_vip/index')]);
  113. }
  114. // 分配数据
  115. $this->assign('crumbs','新增会员');
  116. // 加载模板
  117. return $this->fetch();
  118. }
  119. /**
  120. * 编辑
  121. *
  122. * */
  123. public function edit( Request $request, Model $Model,Custom $Custom ){
  124. // 接收参数
  125. $id = request('id',0);
  126. // 查询数据
  127. $oldData = $Model->where(['id'=>$id])->first();
  128. $oldData = $oldData ? $oldData->toArray() : [];
  129. // 修改
  130. if(request()->isMethod('post')){
  131. // 验证参数
  132. $request->scene('edit')->validate();
  133. // 组合数据
  134. $data['start_time'] = request('start_time','');
  135. $data['end_time'] = request('end_time','');
  136. $data['start_time'] = $data['start_time'] ? strtotime($data['start_time']) : 0;
  137. $data['end_time'] = $data['end_time'] ? strtotime($data['end_time']) : 0;
  138. // 写入
  139. $result = $Model->edit($id,$data);
  140. // 提示新增失败
  141. if( !$result ) return json_send(['code'=>'error','msg'=>'修改失败']);
  142. // 删除结果
  143. unset($oldData['content']);
  144. // 记录行为
  145. $this->addAdminHistory(admin('uid'),$Model->getTable(),$id,2,$oldData,$data);
  146. // 告知结果
  147. return json_send(['code'=>'success','msg'=>'修改成功','action'=>'edit']);
  148. }
  149. // 如果是没有数据
  150. if( !$oldData ) return $this->error('查无数据');
  151. // 查询用户信息
  152. $oldData['custom_name'] = $Custom->getValue($oldData['custom_uid'],'username');
  153. $oldData['custom_code'] = $Custom->idToCode($oldData['custom_uid']);
  154. // 分配数据
  155. $this->assign('oldData',$oldData);
  156. $this->assign('crumbs','修改');
  157. // 加载模板
  158. return $this->fetch();
  159. }
  160. /**
  161. * 状态
  162. *
  163. * */
  164. public function set_status( Request $request, Model $Model){
  165. // 验证参数
  166. $request->scene('set_status')->validate();
  167. // 接收参数
  168. $id = request('id',0);
  169. $status = request('status',0);
  170. // 查询数据
  171. $result = $Model->edit($id,['status'=>$status]);
  172. // 提示新增失败
  173. if( !$result ) return json_send(['code'=>'error','msg'=>'设置失败']);
  174. // 告知结果
  175. return json_send(['code'=>'success','msg'=>'设置成功','path'=>'']);
  176. }
  177. }