<?php namespace app\api\controller\user; use app\admin\model\user\CertType; use app\http\validates\user\AddressValidate; use app\models\member\MemberCheck; use app\models\member\MemberGrade; use app\models\system\SystemCity; use app\models\user\Cert; use app\models\user\UserTicket; use app\models\user\UserVisit; use crmeb\repositories\OrderRepository; use crmeb\services\FormBuilder; use think\db\exception\DataNotFoundException; use think\db\exception\DbException; use think\db\exception\ModelNotFoundException; use think\exception\ValidateException; use app\Request; use app\models\user\UserLevel; use app\models\user\UserSign; use app\models\store\StoreBargain; use app\models\store\StoreCombination; use app\models\store\StoreCouponUser; use app\models\store\StoreOrder; use app\models\store\StoreProductRelation; use app\models\store\StoreSeckill; use app\models\user\User; use app\models\user\UserAddress; use app\models\user\UserBill; use app\models\user\UserExtract; use app\models\user\UserNotice; use crmeb\services\GroupDataService; use crmeb\services\UtilService; use think\facade\Route; /** * 用户类 * Class UserController * @package app\api\controller\store */ class UserController { /** * 获取用户信息 * @param Request $request * @return mixed */ public function userInfo(Request $request) { $info = $request->user()->toArray(); $broken_time = intval(sys_config('extract_time')); $search_time = time() - 86400 * $broken_time; //返佣 + $brokerage_commission = UserBill::where(['uid' => $info['uid'], 'category' => 'now_money', 'type' => 'brokerage']) ->where('add_time', '>', $search_time) ->where('pm', 1) ->sum('number'); //退款退的佣金 - $refund_commission = UserBill::where(['uid' => $info['uid'], 'category' => 'now_money', 'type' => 'brokerage']) ->where('add_time', '>', $search_time) ->where('pm', 0) ->sum('number'); $info['broken_commission'] = bcsub($brokerage_commission, $refund_commission, 2); if ($info['broken_commission'] < 0) $info['broken_commission'] = 0; $info['commissionCount'] = bcsub($info['brokerage_price'], $info['broken_commission'], 2); if ($info['commissionCount'] < 0) $info['commissionCount'] = 0; return app('json')->success($info); } /** * 用户资金统计 * @param Request $request * @return mixed * @throws \think\Exception * @throws DataNotFoundException * @throws ModelNotFoundException * @throws \think\exception\DbException */ public function balance(Request $request) { $uid = $request->uid(); $user['now_money'] = User::getUserInfo($uid, 'now_money')['now_money'];//当前总资金 $user['recharge'] = UserBill::getRecharge($uid);//累计充值 $user['orderStatusSum'] = StoreOrder::getOrderStatusSum($uid);//累计消费 return app('json')->successful($user); } /** * 个人中心 * @param Request $request * @return mixed */ public function user(Request $request) { $user = $request->user(); $user = $user->toArray(); $user['couponCount'] = StoreCouponUser::getUserValidCouponCount($user['uid']); $user['like'] = StoreProductRelation::getUserIdCollect($user['uid']); $user['orderStatusNum'] = StoreOrder::getOrderData($user['uid']); $user['notice'] = UserNotice::getNotice($user['uid']); // $user['brokerage'] = UserBill::getBrokerage($user['uid']);//获取总佣金 $user['recharge'] = UserBill::getRecharge($user['uid']);//累计充值 $user['orderStatusSum'] = StoreOrder::getOrderStatusSum($user['uid']);//累计消费 $user['extractTotalPrice'] = UserExtract::userExtractTotalPrice($user['uid']);//累计提现 $user['extractPrice'] = $user['brokerage_price'];//可提现 $user['statu'] = (int)sys_config('store_brokerage_statu'); $broken_time = intval(sys_config('extract_time')); $search_time = time() - 86400 * $broken_time; if (!$user['is_promoter'] && $user['statu'] == 2) { $price = StoreOrder::where(['paid' => 1, 'refund_status' => 0, 'uid' => $user['uid']])->sum('pay_price'); $status = is_brokerage_statu($price); if ($status) { User::where('uid', $user['uid'])->update(['is_promoter' => 1]); $user['is_promoter'] = 1; } else { $storeBrokeragePrice = sys_config('store_brokerage_price', 0); $user['promoter_price'] = bcsub($storeBrokeragePrice, $price, 2); } } //可提现佣金 //返佣 + $brokerage_commission = UserBill::where(['uid' => $user['uid'], 'category' => 'now_money', 'type' => 'brokerage']) ->where('add_time', '>', $search_time) ->where('pm', 1) ->sum('number'); //退款退的佣金 - $refund_commission = UserBill::where(['uid' => $user['uid'], 'category' => 'now_money', 'type' => 'brokerage']) ->where('add_time', '>', $search_time) ->where('pm', 0) ->sum('number'); $user['broken_commission'] = bcsub($brokerage_commission, $refund_commission, 2); if ($user['broken_commission'] < 0) $user['broken_commission'] = 0; $user['commissionCount'] = bcsub($user['brokerage_price'], $user['broken_commission'], 2); if ($user['commissionCount'] < 0) $user['commissionCount'] = 0; if (!sys_config('vip_open')) $user['vip'] = false; else { $vipId = UserLevel::getUserLevel($user['uid']); $user['vip'] = $vipId !== false ? true : false; if ($user['vip']) { $user['vip_id'] = $vipId; $user['vip_icon'] = UserLevel::getUserLevelInfo($vipId, 'icon'); $user['vip_name'] = UserLevel::getUserLevelInfo($vipId, 'name'); } } $user['yesterDay'] = UserBill::yesterdayCommissionSum($user['uid']); $user['recharge_switch'] = (int)sys_config('recharge_switch');//充值开关 $user['adminid'] = (boolean)\app\models\store\StoreService::orderServiceStatus($user['uid']); if ($user['phone'] && $user['user_type'] != 'h5') { $user['switchUserInfo'][] = $request->user(); if ($h5UserInfo = User::where('account', $user['phone'])->where('user_type', 'h5')->find()) { $user['switchUserInfo'][] = $h5UserInfo; } } else if ($user['phone'] && $user['user_type'] == 'h5') { if ($wechatUserInfo = User::where('phone', $user['phone'])->where('user_type', '<>', 'h5')->find()) { $user['switchUserInfo'][] = $wechatUserInfo; } $user['switchUserInfo'][] = $request->user(); } else if (!$user['phone']) { $user['switchUserInfo'][] = $request->user(); } return app('json')->successful($user); } /** * 地址 获取单个 * @param Request $request * @param $id * @return mixed * @throws DataNotFoundException * @throws ModelNotFoundException * @throws \think\exception\DbException */ public function address(Request $request, $id) { $addressInfo = []; if ($id && is_numeric($id) && UserAddress::be(['is_del' => 0, 'id' => $id, 'uid' => $request->uid()])) { $addressInfo = UserAddress::find($id)->toArray(); } return app('json')->successful($addressInfo); } /** * 地址列表 * @param Request $request * @param $page * @param $limit * @return mixed */ public function address_list(Request $request) { list($page, $limit) = UtilService::getMore([['page', 0], ['limit', 20]], $request, true); $list = UserAddress::getUserValidAddressList($request->uid(), $page, $limit, 'id,real_name,phone,province,city,district,detail,is_default'); return app('json')->successful($list); } /** * 设置默认地址 * * @param Request $request * @return mixed */ public function address_default_set(Request $request) { list($id) = UtilService::getMore([['id', 0]], $request, true); if (!$id || !is_numeric($id)) return app('json')->fail('参数错误!'); if (!UserAddress::be(['is_del' => 0, 'id' => $id, 'uid' => $request->uid()])) return app('json')->fail('地址不存在!'); $res = UserAddress::setDefaultAddress($id, $request->uid()); if (!$res) return app('json')->fail('地址不存在!'); else return app('json')->successful(); } /** * 获取默认地址 * @param Request $request * @return mixed */ public function address_default(Request $request) { $defaultAddress = UserAddress::getUserDefaultAddress($request->uid(), 'id,real_name,phone,province,city,district,detail,is_default'); if ($defaultAddress) { $defaultAddress = $defaultAddress->toArray(); return app('json')->successful('ok', $defaultAddress); } return app('json')->successful('empty', []); } /** * 修改 添加地址 * @param Request $request * @return mixed */ public function address_edit(Request $request) { $addressInfo = UtilService::postMore([ ['address', []], ['is_default', false], ['real_name', ''], ['post_code', ''], ['phone', ''], ['detail', ''], ['id', 0], ['type', 0] ], $request); if (!isset($addressInfo['address']['province'])) return app('json')->fail('收货地址格式错误!'); if (!isset($addressInfo['address']['city'])) return app('json')->fail('收货地址格式错误!'); if (!isset($addressInfo['address']['district'])) return app('json')->fail('收货地址格式错误!'); if (!isset($addressInfo['address']['city_id']) && $addressInfo['type'] == 0) { return app('json')->fail('收货地址格式错误!请重新选择!'); } else if ($addressInfo['type'] == 1 && !$addressInfo['id']) { $city = $addressInfo['address']['city']; $cityId = SystemCity::where('name', $city)->where('parent_id', '<>', 0)->value('city_id'); if ($cityId) { $addressInfo['address']['city_id'] = $cityId; } else { if (!($cityId = SystemCity::where('parent_id', '<>', 0)->where('name', 'like', "%$city%")->value('city_id'))) { return app('json')->fail('收货地址格式错误!修改后请重新导入!'); } } } $addressInfo['province'] = $addressInfo['address']['province']; $addressInfo['city'] = $addressInfo['address']['city']; $addressInfo['city_id'] = $addressInfo['address']['city_id'] ?? 0; $addressInfo['district'] = $addressInfo['address']['district']; $addressInfo['is_default'] = (int)$addressInfo['is_default'] == true ? 1 : 0; $addressInfo['uid'] = $request->uid(); unset($addressInfo['address'], $addressInfo['type']); try { validate(AddressValidate::class)->check($addressInfo); } catch (ValidateException $e) { return app('json')->fail($e->getError()); } if ($addressInfo['id'] && UserAddress::be(['id' => $addressInfo['id'], 'uid' => $request->uid(), 'is_del' => 0])) { $id = $addressInfo['id']; unset($addressInfo['id']); if (UserAddress::edit($addressInfo, $id, 'id')) { if ($addressInfo['is_default']) UserAddress::setDefaultAddress($id, $request->uid()); return app('json')->successful(); } else return app('json')->fail('编辑收货地址失败!'); } else { $addressInfo['add_time'] = time(); if ($address = UserAddress::create($addressInfo)) { if ($addressInfo['is_default']) { UserAddress::setDefaultAddress($address->id, $request->uid()); } return app('json')->successful(['id' => $address->id]); } else { return app('json')->fail('添加收货地址失败!'); } } } /** * 删除地址 * * @param Request $request * @return mixed */ public function address_del(Request $request) { list($id) = UtilService::postMore([['id', 0]], $request, true); if (!$id || !is_numeric($id)) return app('json')->fail('参数错误!'); if (!UserAddress::be(['is_del' => 0, 'id' => $id, 'uid' => $request->uid()])) return app('json')->fail('地址不存在!'); if (UserAddress::edit(['is_del' => '1'], $id, 'id')) return app('json')->successful(); else return app('json')->fail('删除地址失败!'); } /** * 获取收藏产品 * * @param Request $request * @return mixed */ public function collect_user(Request $request) { list($page, $limit) = UtilService::getMore([ ['page', 0], ['limit', 0] ], $request, true); if (!(int)$limit) return app('json')->successful([]); $productRelationList = StoreProductRelation::getUserCollectProduct($request->uid(), (int)$page, (int)$limit); return app('json')->successful($productRelationList); } /** * 添加收藏 * @param Request $request * @param $id * @param $category * @return mixed */ public function collect_add(Request $request) { list($id, $category) = UtilService::postMore([['id', 0], ['category', 'product']], $request, true); if (!$id || !is_numeric($id)) return app('json')->fail('参数错误'); $res = StoreProductRelation::productRelation($id, $request->uid(), 'collect', $category); if (!$res) return app('json')->fail(StoreProductRelation::getErrorInfo()); else return app('json')->successful(); } /** * 取消收藏 * * @param Request $request * @return mixed */ public function collect_del(Request $request) { list($id, $category) = UtilService::postMore([['id', 0], ['category', 'product']], $request, true); if (!$id || !is_numeric($id)) return app('json')->fail('参数错误'); $res = StoreProductRelation::unProductRelation($id, $request->uid(), 'collect', $category); if (!$res) return app('json')->fail(StoreProductRelation::getErrorInfo()); else return app('json')->successful(); } /** * 批量收藏 * @param Request $request * @return mixed */ public function collect_all(Request $request) { $collectInfo = UtilService::postMore([ ['id', []], ['category', 'product'], ], $request); if (!count($collectInfo['id'])) return app('json')->fail('参数错误'); $productIdS = $collectInfo['id']; $res = StoreProductRelation::productRelationAll($productIdS, $request->uid(), 'collect', $collectInfo['category']); if (!$res) return app('json')->fail(StoreProductRelation::getErrorInfo()); else return app('json')->successful('收藏成功'); } /** * 添加点赞 * * @param Request $request * @return mixed */ // public function like_add(Request $request) // { // list($id, $category) = UtilService::postMore([['id',0], ['category','product']], $request, true); // if(!$id || !is_numeric($id)) return app('json')->fail('参数错误'); // $res = StoreProductRelation::productRelation($id,$request->uid(),'like',$category); // if(!$res) return app('json')->fail(StoreProductRelation::getErrorInfo()); // else return app('json')->successful(); // } /** * 取消点赞 * * @param Request $request * @return mixed */ // public function like_del(Request $request) // { // list($id, $category) = UtilService::postMore([['id',0], ['category','product']], $request, true); // if(!$id || !is_numeric($id)) return app('json')->fail('参数错误'); // $res = StoreProductRelation::unProductRelation($id, $request->uid(),'like',$category); // if(!$res) return app('json')->fail(StoreProductRelation::getErrorInfo()); // else return app('json')->successful(); // } /** * 签到 配置 * @return mixed * @throws DataNotFoundException * @throws ModelNotFoundException * @throws \think\exception\DbException */ public function sign_config() { $signConfig = sys_data('sign_day_num') ?? []; return app('json')->successful($signConfig); } /** * 签到 列表 * @param Request $request * @param $page * @param $limit * @return mixed */ public function sign_list(Request $request) { list($page, $limit) = UtilService::getMore([ ['page', 0], ['limit', 0] ], $request, true); if (!$limit) return app('json')->successful([]); $signList = UserSign::getSignList($request->uid(), (int)$page, (int)$limit); if ($signList) $signList = $signList->toArray(); return app('json')->successful($signList); } /** * 签到 * @param Request $request * @return mixed */ public function sign_integral(Request $request) { $signed = UserSign::getIsSign($request->uid()); if ($signed) return app('json')->fail('已签到'); if (false !== ($integral = UserSign::sign($request->uid()))) return app('json')->successful('签到获得' . floatval($integral) . '积分', ['integral' => $integral]); return app('json')->fail(UserSign::getErrorInfo('签到失败')); } /** * 签到用户信息 * @param Request $request * @return mixed */ public function sign_user(Request $request) { list($sign, $integral, $all) = UtilService::postMore([ ['sign', 0], ['integral', 0], ['all', 0], ], $request, true); $user = $request->user(); //是否统计签到 if ($sign || $all) { $user['sum_sgin_day'] = UserSign::getSignSumDay($user['uid']); $user['is_day_sgin'] = UserSign::getIsSign($user['uid']); $user['is_YesterDay_sgin'] = UserSign::getIsSign($user['uid'], 'yesterday'); if (!$user['is_day_sgin'] && !$user['is_YesterDay_sgin']) { $user['sign_num'] = 0; } } //是否统计积分使用情况 if ($integral || $all) { $user['sum_integral'] = (int)UserBill::getRecordCount($user['uid'], 'integral', 'sign,system_add,gain'); $user['deduction_integral'] = (int)UserBill::getRecordCount($user['uid'], 'integral', 'deduction', '', true) ?? 0; $user['today_integral'] = (int)UserBill::getRecordCount($user['uid'], 'integral', 'sign,system_add,gain', 'today'); } unset($user['pwd']); if (!$user['is_promoter']) { $user['is_promoter'] = (int)sys_config('store_brokerage_statu') == 2 ? true : false; } return app('json')->successful($user->hidden(['account', 'real_name', 'birthday', 'card_id', 'mark', 'partner_id', 'group_id', 'add_time', 'add_ip', 'phone', 'last_time', 'last_ip', 'spread_uid', 'spread_time', 'user_type', 'status', 'level', 'clean_time', 'addres'])->toArray()); } /** * 签到列表(年月) * * @param Request $request * @return mixed */ public function sign_month(Request $request) { list($page, $limit) = UtilService::getMore([ ['page', 0], ['limit', 0] ], $request, true); if (!$limit) return app('json')->successful([]); $userSignList = UserSign::getSignMonthList($request->uid(), (int)$page, (int)$limit); return app('json')->successful($userSignList); } /** * 获取活动状态 * @return mixed */ public function activity() { $data['is_bargin'] = StoreBargain::validBargain() ? true : false; $data['is_pink'] = StoreCombination::getPinkIsOpen() ? true : false; $data['is_seckill'] = StoreSeckill::getSeckillCount() ? true : false; return app('json')->successful($data); } /** * 用户修改信息 * @param Request $request * @return mixed */ public function edit(Request $request) { list($avatar, $nickname) = UtilService::postMore([ ['avatar', ''], ['nickname', ''], ], $request, true); if (User::editUser($avatar, $nickname, $request->uid())) return app('json')->successful('修改成功'); return app('json')->fail('修改失败'); } /** * 推广人排行 * @param Request $request * @return mixed * @throws DataNotFoundException * @throws ModelNotFoundException * @throws \think\exception\DbException */ public function rank(Request $request) { $data = UtilService::getMore([ ['page', ''], ['limit', ''], ['type', ''] ], $request); $users = User::getRankList($data); return app('json')->success($users); } /** * 佣金排行 * @param Request $request * @return mixed */ public function brokerage_rank(Request $request) { $data = UtilService::getMore([ ['page', ''], ['limit'], ['type'] ], $request); return app('json')->success([ 'rank' => User::brokerageRank($data), 'position' => User::currentUserRank($data['type'], $request->user()['brokerage_price']) ]); } /** * 添加访问记录 * @param Request $request * @return mixed */ public function set_visit(Request $request) { $data = UtilService::postMore([ ['url', ''], ['stay_time', 0] ], $request); if ($data['url'] == '') return app('json')->fail('未获取页面路径'); $data['uid'] = $request->uid(); $data['ip'] = $request->ip(); $data['add_time'] = time(); $res = UserVisit::insert($data); if ($res) { return app('json')->success('添加访问记录成功'); } else { return app('json')->fail('添加访问记录失败'); } } /** * 静默绑定推广人 * @param Request $request * @return mixed * @throws DataNotFoundException * @throws DbException * @throws ModelNotFoundException */ public function spread(Request $request) { $puid = $request->post('puid/d', 0); return app('json')->success(User::setSpread($puid, $request->uid())); } public function getMemberConfig($type, Request $request) { $member = MemberGrade::where(['type' => $type])->order('grade asc')->select(); return app('json')->success('ok', $member ? $member->toArray() : []); } public function getMember($type, Request $request) { $name = $request->get('name', ''); $idcard = $request->get('idcard', ''); $info = MemberCheck::where(['status' => 1, 'paid' => 1])->where(compact('type', 'name')); if ($type == 1) $info = $info->where('idcard', $idcard); $info = $info->find(); if (!$info) { return app('json')->fail('找不到会员,请检查查询项'); } else { $info['grade_info'] = MemberGrade::where(['type' => $info['type'], 'grade' => $info['grade']])->find(); $info['id'] = str_pad($info['check_id'], '6', '0', STR_PAD_LEFT); $info['imgs'] = explode(',', $info['imgs']); return app('json')->success('ok', ['data' => $info]); } } public function applyMemberCheck($type, Request $request) { $uid = $request->uid(); $param = UtilService::postMore([ ['name', ''], ['id', ''], ['phone', ''], ['location', ''], ['address', ''], ['occupation', ''], ['careerYears', ''], ['sponsor', ''], ['img', ''], ['grade', ''], ['pay_type', 'weixin'], ['from', 'weixin'], ], $request); $payType = $param['pay_type']; $from = $param['from']; $param['type'] = $type; $order = MemberCheck::createOrder($param, $uid, $payType, $from); if ($order === false) return app('json')->fail(MemberCheck::getErrorInfo('订单生成失败')); $orderId = $order['order_id']; $info = ['order_id' => $orderId]; if ($orderId) { switch ($payType) { case "weixin": $orderInfo = MemberCheck::where('order_id', $orderId)->find(); if (!$orderInfo || !isset($orderInfo['paid'])) return app('json')->fail('支付订单不存在!'); $orderInfo = $orderInfo->toArray(); if ($orderInfo['paid']) return app('json')->fail('订单已支付!'); //支付金额为0 if (bcsub((float)$orderInfo['pay_money'], 0, 2) <= 0) { //创建订单jspay支付 $payPriceStatus = MemberCheck::jsPayPrice($orderId, $uid); if ($payPriceStatus)//0元支付成功 return app('json')->status('success', '微信支付成功'); else return app('json')->status('pay_error', MemberCheck::getErrorInfo()); } else { try { if ($from == 'routine') { $jsConfig = OrderRepository::jsMemberPay($orderId); //创建订单jspay } else if ($from == 'weixinh5') { $jsConfig = OrderRepository::h5MemberPay($orderId); } else { $jsConfig = OrderRepository::wxMemberPay($orderId); } } catch (\Exception $e) { return app('json')->status('pay_error', $e->getMessage()); } $info['jsConfig'] = $jsConfig; if ($from == 'weixinh5') { return app('json')->status('wechat_h5_pay', '订单创建成功', $info); } else { return app('json')->status('wechat_pay', '订单创建成功', $info); } } case 'yue': if (MemberCheck::yuePay($orderId, $request->uid())) return app('json')->status('success', '余额支付成功', $info); else { $errorinfo = MemberCheck::getErrorInfo(); if (is_array($errorinfo)) return app('json')->status($errorinfo['status'], $errorinfo['msg'], $info); else return app('json')->status('pay_error', $errorinfo); } break; } } else return app('json')->fail(MemberCheck::getErrorInfo('订单生成失败!')); } public function tickets(Request $request) { list($page, $limit) = UtilService::getMore([['page', 1], ['limit', 10]], $request, true); $list = UserTicket::where('all_num > num')->where('uid', $request->uid())->order('id', 'desc')->page($page, $limit)->select(); $count = UserTicket::where('all_num > num')->where('uid', $request->uid())->count(); return app('json')->success('ok', compact('list', 'count')); } public function check_tickets(Request $request) { if (!$request->user()['checker']) return app('json')->fail('非核销员身份无法核销'); list($code) = UtilService::postMore([['code', '']], $request, true); $ticket = UserTicket::where('ticket_code', $code)->find(); if (!$ticket) return app('json')->fail('核销码无效'); if ($ticket['all_num'] <= $ticket['num']) return app('json')->fail('该核销码核销次数已用完'); $ticket->num++; $res = $ticket->save(); if ($res) return app('json')->success('核销成功'); else return app('json')->fail('核销失败'); } public function jobs(Request $request) { return app('json')->success('ok', ['data' => CertType::select()]); } public function addCert(Request $request) { list($name, $gender, $idcard, $job, $photo) = UtilService::postMore([ ['name', '', '', '', 'not_empty_check', '请输入姓名'], ['gender', '', '', '', 'not_empty_check', '请选择性别'], ['idcard', '', '', '', 'not_empty_check', '请输入身份证号码'], ['job', '', '', '', 'not_empty_check', '请输入职业'], ['photo', '', '', '', 'not_empty_check', '请上传照片'], ], $request, true); $res = Cert::add_cert($request->uid(), $name, $gender, $idcard, $job, $photo); if ($res) { return app('json')->success('申请成功'); } else { return app('json')->fail(Cert::getErrorInfo()); } } public function getCertList(Request $request) { $where = UtilService::getMore([ ['status', ''], ['page', 1], ['limit', 10], ['uid', $request->uid()] ]); return app('json')->success('ok', ['list' => Cert::getList($where)]); } public function getCert(Request $request, $id = 0) { list($name) = UtilService::getMore([ ['name', ''], ], $request, true); if ($id) { return app('json')->success('ok', ['info' => Cert::get($id)]); } else { return app('json')->success('ok', ['info' => Cert::search($name)]); } } }