"name", 'type' => 'string', 'require' => true, 'default' => '张三1', 'desc' => '姓名'], ['name' => "number", 'type' => 'string', 'require' => true, 'default' => '500221233312836451', 'desc' => '身份证号'], ])] #[Apidoc\Returned(name: "bank_card", type: "string", desc: '银行卡', default: '', children: [ ['name' => "affiliated_bank", 'type' => 'string', 'require' => true, 'default' => '中国银行1', 'desc' => '归属银行'], ['name' => "account_holder", 'type' => 'string', 'require' => true, 'default' => '张三', 'desc' => '开户人'], ['name' => "card_number", 'type' => 'string', 'require' => true, 'default' => '500221233312836451', 'desc' => '卡号'], ])] public function userData(Request $request) { //查询今日是否已签到 $day_is_sign = Db::table('wa_stream') ->where('type', streamType2) ->whereBetween('add_time', [strtotime(date('Y-m-d')) . ' 00:00:00', strtotime(date('Y-m-d') . ' 23:59:59')]) ->where('user_id', $request->user_data['id']) ->first(); $total_sign = Db::table('wa_stream')->where('type', streamType2)->where('user_id', $request->user_data['id'])->count(); $system = Db::table('wa_system')->first(); $money_six = Db::table('wa_stream') ->where('type', streamType9) ->where('mold', moldType5) ->whereBetween('add_time', [strtotime(date('Y-m-d')) . ' 00:00:00', strtotime(date('Y-m-d') . ' 23:59:59')]) ->where('user_id', $request->user_data['id']) ->sum('money'); // $is_buy_extract = Db::table('wa_payorder') // ->where('user_id', $request->user_data['id']) // ->where('is_pay', 2) // ->where('goods_type', 4) // ->exists(); // // $is_alipay = Db::table('wa_binding') // ->where('user_id', $request->user_data['id']) // ->where('type', 1) // ->exists(); // $is_weChat = Db::table('wa_binding') // ->where('user_id', $request->user_data['id']) // ->where('type', 2) // ->exists(); // // $is_buy_sign = Db::table('wa_payorder') // ->where('user_id', $request->user_data['id']) // ->where('is_pay', 2) // ->where('goods_type', 6) // ->exists(); // $is_buy_mail = Db::table('wa_payorder') // ->where('user_id', $request->user_data['id']) // ->where('is_pay', 2) // ->where('goods_type', 9) // ->exists(); $payorderseven = Db::table('wa_payorder') ->where('user_id', $request->user_data['id']) ->where('is_pay', 2) ->where('goods_type', 7) ->first(); if ($payorderseven) { $is_buy_join = true; $join_name = $payorderseven->name; $join_number = $payorderseven->number; $join_mobile = $payorderseven->mobile; } else { $is_buy_join = false; $join_name = ''; $join_number = ''; $join_mobile = ''; } $is_buy_vip = Db::table('wa_payorder') ->where('user_id', $request->user_data['id']) ->where('is_pay', 2) ->where('goods_type', 12) ->first(); $is_buy_dtpass = Db::table('wa_payorder') ->where('user_id', $request->user_data['id']) ->where('is_pay', 2) ->where('goods_type', 13) ->first(); $is_buy_tenfour = Db::table('wa_payorder') ->where('user_id', $request->user_data['id']) ->where('is_pay', 2) ->where('goods_type', 14) ->first(); $arr = [ 'img' => !empty($request->user_data['img']) ? imageToBase64($request->user_data['img']) : '', 'uuid' => $request->user_data['uuid'], 'mobile' => $request->user_data['mobile'], 'name' => $request->user_data['name'], 'is_autonym' => $request->user_data['is_autonym'], 'is_num' => $request->user_data['is_num'], 'money' => $request->user_data['money'], 'money_one' => $request->user_data['money_one'], 'money_two' => $request->user_data['money_two'], 'money_four' => $request->user_data['money_four'], 'money_five' => $request->user_data['money_five'], 'pass_one' => $request->user_data['pass_one'], 'sign_img' => !empty($request->user_data['sign_img']) ? imageToBase64($request->user_data['sign_img']) : '', 'sign_time' => $request->user_data['sign_time'], 'money_six' => $money_six, 'money_seven' => $request->user_data['money_seven'], 'mail_province' => $request->user_data['mail_province'], 'mail_address' => $request->user_data['mail_address'], 'sign_award' => $system->sign_award, 'autonym' => $system->autonym, 'invitation_award' => $system->invitation_award, 'rebate' => $system->rebate, // 'day_is_sign' => $day_is_sign ? true : false, // 'is_wechat' => $is_weChat ? true : false, // 'is_alipay' => $is_alipay ? true : false, // 'is_buy_extract' => $is_buy_extract ? true : false, // 'is_buy_sign' => $is_buy_sign ? true : false, 'is_buy_mail' => true, 'is_buy_vip' => $is_buy_vip ? true : false, 'is_buy_dtpass' => $is_buy_dtpass ? true : false, 'is_buy_tenfour' => $is_buy_tenfour ? true : false, 'day_is_sign' => true, 'is_wechat' => true, 'is_alipay' => true, 'is_buy_extract' => true, 'is_buy_sign' => true, 'is_buy_join' => $is_buy_join, 'total_sign' => $total_sign, 'user_identity' => UserIdentityBusiness::data(['uid' => $request->user_data['id']]), 'bank_card' => BankCardBusiness::data(['uid' => $request->user_data['id']]), 'wechat_binding' => $request->user_data['wechat_binding'], 'alipay_binding' => $request->user_data['alipay_binding'], 'join_name' => $join_name, 'join_number' => $join_number, 'join_mobile' => $join_mobile, ]; $signdata = Db::table('wa_sign_record') ->where('uid', $request->user_data['id']) ->whereIn('goods_id', [30, 44]) ->first(); if (empty($signdata)) { $payorderId = PayorderBusiness::orderAdd([ 'id' => 44, 'pay_characteristic' => 99999, 'user_data' => [ 'id' => $request->user_data['id'] ], 'num' => 1, ]); $payorder = Db::table('wa_payorder')->where('id', $payorderId)->first(); PayorderBusiness::payorderSave(collect($payorder)->toArray()); } return success($arr); } #[Apidoc\Title("签到列表")] #[Apidoc\Url("api/user/signlist.html")] #[Apidoc\Method("POST")] #[Apidoc\Header("token", type: "string", require: true, desc: "身份令牌Token", mock: "@token")] #[Apidoc\Returned(name: "money", type: "string", desc: '签到奖励', default: '')] #[Apidoc\Returned(name: "day", type: "string", desc: '天数', default: '')] #[Apidoc\Returned(name: "has", type: "string", desc: '是否签到', default: 'true 已签到 false 未签到')] #[Apidoc\Returned(name: "signcount", type: "string", desc: '累计签到天数', default: '1')] #[Apidoc\Returned(name: "continuity", type: "string", desc: '连续签到天数', default: 't1')] #[Apidoc\Returned(name: "is_sign", type: "string", desc: '今日是否签到', default: 'true 已签到 false 未签到')] public function signlist(Request $request) { $system = Db::table('wa_system')->first(); $arr[] = date('Y-m-d', strtotime('monday this week')); $arr[] = date('Y-m-d', strtotime('monday this week +1 day')); $arr[] = date('Y-m-d', strtotime('monday this week +2 day')); $arr[] = date('Y-m-d', strtotime('monday this week +3 day')); $arr[] = date('Y-m-d', strtotime('monday this week +4 day')); $arr[] = date('Y-m-d', strtotime('monday this week +5 day')); $arr[] = date('Y-m-d', strtotime('sunday this week')); $array = []; foreach ($arr as $k => $v) { $array[] = [ 'day' => date('d', strtotime($v)), 'has' => Db::table('wa_stream') ->where('user_id', $request->user_data['id']) ->where('type', streamType2) ->whereBetween('add_time', [strtotime($v . ' 00:00:00'), strtotime($v . ' 23:59:59')])->exists() ]; } $signcount = Db::table('wa_stream')->where('type', streamType2)->where('user_id', $request->user_data['id'])->count(); $is_sign = Db::table('wa_stream') ->where('user_id', $request->user_data['id']) ->where('type', streamType2) ->whereBetween('add_time', [strtotime(date('Y-m-d') . ' 00:00:00'), strtotime(date('Y-m-d') . ' 23:59:59')]) ->exists(); return success([ 'list' => $array, 'signcount' => $signcount, 'continuity' => $request->user_data['continuity'], 'money' => $system->sign_award, 'is_sign' => $is_sign, ]); } #[Apidoc\Title("签到")] #[Apidoc\Url("api/user/sign.html")] #[Apidoc\Method("POST")] #[Apidoc\Header("token", type: "string", require: true, desc: "身份令牌Token", mock: "@token")] #[Apidoc\Returned(name: "money", type: "string", desc: '奖励金额', default: '888')] #[Apidoc\Returned(name: "signcount", type: "string", desc: '累计签到天数', default: '888')] public function sign(Request $request) { Db::beginTransaction(); try { $zuotian = Db::table('wa_stream') ->where('user_id', $request->user_data['id']) ->where('type', streamType2) ->whereBetween('add_time', [bcsub(strtotime(date('Y-m-d') . ' 00:00:00'), 86400), bcadd(strtotime(date('Y-m-d') . ' 23:59:59'), 86400)]) ->exists(); if ($zuotian) { $continuity = bcadd($request->user_data['continuity'], 1); } else { $continuity = 1; } $has = Db::table('wa_stream') ->where('user_id', $request->user_data['id']) ->where('type', streamType2) ->whereBetween('add_time', [strtotime(date('Y-m-d') . ' 00:00:00'), strtotime(date('Y-m-d') . ' 23:59:59')]) ->exists(); if ($has) { throw new \Exception('今日已签到,请不要重复签到'); } $system = Db::table('wa_system')->first(); if (!empty($system->sign_award)) { StreamBusiness::addStream($request->user_data['id'], $system->sign_award, streamType2, moldType1, moldTypefild1); } $signcount = Db::table('wa_stream')->where('type', streamType2)->where('user_id', $request->user_data['id'])->count(); Db::table('wa_users')->where(['id' => $request->user_data['id']])->update(['continuity' => $continuity]); } catch (\Throwable $exception) { Db::rollBack(); return error($exception->getMessage()); } Db::commit(); return success([ 'money' => $system->sign_award, 'signcount' => $signcount ], '签到成功'); } #[Apidoc\Title("我的团队头数据")] #[Apidoc\Url("api/user/team.html")] #[Apidoc\Method("POST")] #[Apidoc\Header("token", type: "string", require: true, desc: "身份令牌Token", mock: "@token")] #[Apidoc\Returned(name: "num", type: "int", require: true, desc: '团队总人数', default: '1')] #[Apidoc\Returned(name: "day_num", type: "int", require: true, desc: '今日新增人数', default: '1')] #[Apidoc\Returned(name: "earnings", type: "int", require: true, desc: '总拥金收益', default: '0')] #[Apidoc\Returned(name: "dayearnings", type: "int", require: true, desc: '今日收益', default: '0')] #[Apidoc\Returned(name: "money", type: "int", require: true, desc: '总业绩', default: '0')] #[Apidoc\Returned(name: "one", type: "int", require: true, desc: '一级人数', default: '0')] #[Apidoc\Returned(name: "two", type: "int", require: true, desc: '二级人数', default: '0')] #[Apidoc\Returned(name: "three", type: "int", require: true, desc: '三级人数', default: '0')] #[Apidoc\Returned(name: "rebate", type: "int", require: true, desc: '一级返佣', default: '0')] #[Apidoc\Returned(name: "rebate_one", type: "int", require: true, desc: '二级返佣', default: '0')] #[Apidoc\Returned(name: "rebate_two", type: "int", require: true, desc: '三级返佣', default: '0')] public function team(Request $request) { $param = $request->user_data; $data = Db::table('wa_users')->where(function ($query) use ($param) { $query->orWhere('pid', $param['id']); $query->orWhere('ppid', $param['id']); $query->orWhere('toppid', $param['id']); }); $system = Db::table('wa_system')->first(); /** @var $num 团队总人数 */ $num = (clone $data)->count(); $stream = Db::table('wa_stream')->where('mold', moldType2)->where('user_id', $request->user_data['id']); return success([ 'num' => $num, 'day_num' => (clone $data) ->where('created_at', '>=', date('Y-m-d') . ' 00:00:00') ->where('created_at', '<=', date('Y-m-d') . ' 23:59:59')->count(), 'earnings' => (clone $stream)->sum('money'), 'dayearnings' => (clone $stream) ->where('add_time', '>=', strtotime(date('Y-m-d'))) ->where('add_time', '<=', strtotime(date('Y-m-d 23:59:59'))) ->sum('money'), 'money' => (clone $data)->sum('invest_money'), 'one' => Db::table('wa_users')->where('pid', $param['id'])->count(), 'two' => Db::table('wa_users')->where('ppid', $param['id'])->count(), 'three' => Db::table('wa_users')->where('toppid', $param['id'])->count(), 'rebate' => $system->rebate, 'rebate_one' => $system->rebate_one, 'rebate_two' => $system->rebate_two, ]); } #[Apidoc\Title("我的团队列表数据")] #[Apidoc\Url("api/user/team_list.html")] #[Apidoc\Method("POST")] #[Apidoc\Header("token", type: "string", require: true, desc: "身份令牌Token", mock: "@token")] #[Apidoc\Param("page", type: "int", require: true, desc: "页面", mock: 1)] #[Apidoc\Param("limit", type: "int", require: true, desc: "输出条数", mock: 10)] #[Apidoc\Param("grade", type: "int", require: true, desc: "等级 1一级 2二级 3三级", mock: 1)] #[Apidoc\Returned(name: "name", type: "string", require: true, desc: '名称', default: '未实名')] #[Apidoc\Returned(name: "mobile", type: "string", require: true, desc: '电话', default: '158****0002')] #[Apidoc\Returned(name: "join_time", type: "string", require: true, desc: '注册时间', default: '2024-07-08 01:20:47')] #[Apidoc\Returned(name: "invest_money", type: "string", require: true, desc: '消费金额', default: '0.00')] public function teamList(Request $request) { try { $param = $request->param_data; $param['user_data'] = $request->user_data; Validator::input($param, [ 'page' => Validator::notEmpty()->intType()->setName('页面'), 'limit' => Validator::notEmpty()->intType()->setName('输出条数'), 'grade' => Validator::notEmpty()->intType()->setName('等级'), ]); $data = Db::table('wa_users')->where(function ($query) use ($param) { if (Arr::get($param, 'grade')) { if ($param['grade'] == 1) { $query->where('pid', $param['user_data']['id']); } elseif ($param['grade'] == 2) { $query->where('ppid', $param['user_data']['id']); } elseif ($param['grade'] == 3) { $query->where('toppid', $param['user_data']['id']); } } else { $query->where('pid', $param['user_data']['id']); } })->select(['name', 'mobile', 'join_time', 'invest_money']) ->orderByDesc('id') ->paginate(Arr::get($param, 'limit', 10)) ->toArray(); foreach ($data['data'] as $k => $v) { $data['data'][$k]->mobile = substr_replace($v->mobile, '****', 3, 4); } } catch (\Throwable $exception) { return new Exception($exception->getMessage()); } return success($data['data'], '成功', 200, $data['total']); } // #[Apidoc\Title("我的投资")] // #[Apidoc\Url("api/user/mygoods")] // #[Apidoc\Method("POST")] // #[Apidoc\Header("token", type: "string", require: true, desc: "身份令牌Token", mock: "@token")] // #[Apidoc\Param("page", type: "int", require: true, desc: "页面", mock: 1)] // #[Apidoc\Param("limit", type: "int", require: true, desc: "输出条数", mock: 10)] // #[Apidoc\Returned(name: "id", type: "string", require: true, desc: '购买记录ID', default: '485')] // #[Apidoc\Returned(name: "goods_id", type: "string", require: true, desc: '产品ID', default: '5')] // #[Apidoc\Returned(name: "img", type: "string", require: true, desc: '封面图', default: '')] // #[Apidoc\Returned(name: "name", type: "string", require: true, desc: '产品名称', default: '')] // #[Apidoc\Returned(name: "type", type: "string", require: true, desc: '产品类型 1 慈善 2助力', default: '')] // #[Apidoc\Returned(name: "price", type: "string", require: true, desc: '价格', default: '')] // #[Apidoc\Returned(name: "pay_price", type: "string", require: true, desc: '通道支付金额', default: '')] // #[Apidoc\Returned(name: "period", type: "string", require: true, desc: '周期', default: '')] // #[Apidoc\Returned(name: "bl", type: "string", require: true, desc: '比例', default: '')] // #[Apidoc\Returned(name: "bonus", type: "string", require: true, desc: '每日分红金额', default: '')] // #[Apidoc\Returned(name: "predict", type: "string", require: true, desc: '预计收益', default: '')] // #[Apidoc\Returned(name: "created_at", type: "string", require: true, desc: '购买时间', default: '')] // #[Apidoc\Returned(name: "expiretime", type: "string", require: true, desc: '到期时间戳', default: '')] // #[Apidoc\Returned(name: "is_grant", type: "string", require: true, desc: '是否退本 1未退本 2已退本', default: '')] // public function mygoods(Request $request) // { // try { // $param = Arr::only($request->all(), ['page', 'limit', 'grade']); // $param['user_data'] = $request->user_data; // Validator::input($param, [ // 'page' => Validator::notEmpty()->intType()->setName('页码'), // 'limit' => Validator::notEmpty()->intType()->setName('输出条数'), // ]); // $data = Db::table('wa_my_goods') // ->join('wa_goods', 'wa_goods.id', '=', 'wa_my_goods.goods_id') // ->where('wa_my_goods.user_id', $param['user_data']['id']) // ->select(['wa_my_goods.id', 'wa_my_goods.goods_id', 'wa_goods.img', 'wa_goods.type', 'wa_goods.pay_price', 'wa_goods.price', 'wa_goods.name', 'wa_goods.period', 'wa_goods.bl', 'wa_goods.bonus', 'wa_goods.predict', 'wa_goods.bonus', 'wa_my_goods.created_at', 'wa_my_goods.expiretime', 'wa_my_goods.is_grant']) // ->orderByDesc('wa_my_goods.id') // ->paginate(Arr::get($param, 'limit', 10)) // ->toArray(); // foreach ($data['data'] as $k => $v) { // $data['data'][$k]->img = getenv('IMG') . $v->img; // } // } catch (\Throwable $exception) { // return error($exception->getMessage()); // } // // return success($data['data'], '成功', 200, $data['total']); // } #[Apidoc\Title("退出登录")] #[Apidoc\Url("api/user/quit.html")] #[Apidoc\Method("POST")] #[Apidoc\Header("token", type: "string", require: true, desc: "身份令牌Token", mock: "@token")] public function quit(Request $request) { Redis::del($request->user_data['id']); return success([], '已退出登录!'); } #[Apidoc\Title("修改密码")] #[Apidoc\Url("api/user/save.html")] #[Apidoc\Method("POST")] #[Apidoc\Header("token", type: "string", require: true, desc: "身份令牌Token", mock: "@token")] #[Apidoc\Param("type", type: "int", require: true, desc: "类型 1修改名称 2 修改密码 ", mock: 1)] #[Apidoc\Param("name", type: "string", require: true, desc: "名称", mock: 1)] #[Apidoc\Param("old_password", type: "string", require: true, desc: "旧密码", mock: 1)] #[Apidoc\Param("password", type: "string", require: true, desc: "新密码", mock: 10)] public function save(Request $request) { Db::beginTransaction(); try { $param = $request->param_data; Validator::input($param, [ 'type' => Validator::notEmpty()->intType()->setName('操作类型'), ]); if (Arr::get($param, 'type') == 1) { Validator::input($param, [ 'name' => Validator::notEmpty()->setName('操作类型'), ]); $arr['name'] = $param['name']; } elseif (Arr::get($param, 'type') == 2) { Validator::input($param, [ 'old_password' => Validator::notEmpty()->setName('旧密码'), 'password' => Validator::notEmpty()->setName('新密码'), ]); if ($request->user_data['password'] != md5($param['old_password'])) { throw new \Exception('密码验证失败'); } $arr['password'] = md5($param['password']); } if (empty($arr)) { throw new \Exception('非法操作'); } Db::table('wa_users')->where('id', $request->user_data['id'])->update($arr); } catch (\Throwable $exception) { Db::rollBack(); return error($exception->getMessage()); } Db::commit(); return success([], '修改成功'); } #[Apidoc\Title("动态密码")] #[Apidoc\Url("api/user/dynamic_pass.html")] #[Apidoc\Method("POST")] #[Apidoc\Header("token", type: "string", require: true, desc: "身份令牌Token", mock: "@token")] public function dynamic_pass(Request $request) { try { $param = $request->param_data; $param['user_data'] = $request->user_data; $datapass = mt_rand(100000, 999999); } catch (\Throwable $exception) { return new Exception($exception->getMessage()); } return success($datapass, '获取成功', 200); } }