582 lines
20 KiB
PHP
Executable File
582 lines
20 KiB
PHP
Executable File
<?php
|
||
|
||
namespace app\mobile\controller;
|
||
|
||
use think\Cookie;
|
||
use think\Lang;
|
||
use think\Loader;
|
||
use think\Config;
|
||
use think\Session;
|
||
use think\Validate;
|
||
use think\Cache;
|
||
|
||
class Customer extends BaseController {
|
||
|
||
public function login() {
|
||
if ($this->customer_id > 0)
|
||
$this->redirect(url('mobile/customer/personal'));
|
||
|
||
return view();
|
||
}
|
||
|
||
public function quick_login() {
|
||
if ($this->customer_id > 0)
|
||
$this->redirect(url('mobile/customer/personal'));
|
||
|
||
return view();
|
||
}
|
||
|
||
public function register() {
|
||
if ($this->customer_id > 0)
|
||
$this->redirect(url('mobile/customer/personal'));
|
||
|
||
return view();
|
||
}
|
||
public function personal() {
|
||
if ($this->customer_id <= 0)
|
||
$this->redirect(url('mobile/customer/login'));
|
||
|
||
return view();
|
||
}
|
||
|
||
public function forgetpwd()
|
||
{
|
||
return view();
|
||
}
|
||
|
||
# 用旧密码改新密码
|
||
public function update_pwd()
|
||
{
|
||
$data = $this->request->post();
|
||
if (empty($data) || $this->customer_id <= 0)
|
||
{
|
||
return $this->json(-1, '数据错误');
|
||
}
|
||
|
||
if ($this->customer_info['have_pwd'])
|
||
{
|
||
$customer_info = model('customer')->where(['id' => $this->customer_id])->find();
|
||
if (md5($data['old_password']) != $customer_info['password'])
|
||
{
|
||
return $this->json(-2, '旧密码错误');
|
||
}
|
||
}
|
||
|
||
$update_data = [
|
||
'password' => md5($data['password']),
|
||
'salt' => $data['password']
|
||
];
|
||
|
||
$result = model('customer')->where(['id' => $this->customer_id])->update($update_data);
|
||
if (!$result)
|
||
{
|
||
return $this->json(-4, '修改密码失败');
|
||
}
|
||
|
||
$customer_info = model('customer')->getBasicInfo($this->customer_id);
|
||
|
||
$this->set_login_token($customer_info);
|
||
return $this->json(200, '修改密码成功');
|
||
}
|
||
|
||
# 用手机号/邮箱改密码
|
||
public function update_forget_pwd()
|
||
{
|
||
$data = $this->request->post();
|
||
|
||
if (empty($data))
|
||
{
|
||
return $this->json(-1, '数据错误');
|
||
}
|
||
|
||
if (isset($data['telephone']))
|
||
{
|
||
$flag = 1;
|
||
if (!preg_match("/^1([38][0-9]|4[579]|5[0-3,5-9]|6[6]|7[0135678]|9[89])\d{8}$/", $data['telephone']))
|
||
{
|
||
return $this->json(-2, '手机号格式错误');
|
||
}
|
||
|
||
$captcha = $this->cacheGet('regtel' . $data['telephone'], 'error');
|
||
if ($captcha != $data['captcha'])
|
||
{
|
||
return $this->json(-3, '验证码错误');
|
||
}
|
||
}
|
||
else
|
||
{
|
||
return $this->json(-100, '邮箱暂不可用');
|
||
$flag = 2;
|
||
if (!preg_match("/^[_a-z0-9-]+(\.[_a-z0-9-]+)*@[a-z0-9-]+(\.[a-z0-9-]+)*(\.[a-z]{2,})$/", $data['email']))
|
||
{
|
||
return $this->json(-4, '邮箱格式错误');
|
||
}
|
||
|
||
$captcha = $this->cacheGet('regemail' . $data['email'], 'error');
|
||
if ($captcha != $data['captcha'])
|
||
{
|
||
return $this->json(-5, '验证码错误');
|
||
}
|
||
}
|
||
|
||
if (!preg_match("/^(?![0-9]+$)(?![a-zA-Z]+$)[0-9A-Za-z]{8,20}$/", $data['password']))
|
||
{
|
||
return $this->json(-6, '密码必须包含8-20个字符,且包含数字和字母');
|
||
}
|
||
|
||
if ($flag == 1)
|
||
{
|
||
$customer_info = model('customer')->getBasicInfoByTelephone($data['telephone']);
|
||
if (empty($customer_info))
|
||
{
|
||
return $this->json(-7, '该手机号未注册');
|
||
}
|
||
|
||
$update_data = [
|
||
'password' => md5($data['password']),
|
||
'salt' => $data['password']
|
||
];
|
||
$result = model('customer')->where(['telephone' => $data['telephone']])->update($update_data);
|
||
}
|
||
else
|
||
{
|
||
$customer_info = model('customer')->getBasicInfoByEmail($data['email']);
|
||
if (empty($customer_info))
|
||
{
|
||
return $this->json(-8, '该邮箱未注册');
|
||
}
|
||
|
||
$update_data = [
|
||
'password' => md5($data['password']),
|
||
'salt' => $data['password']
|
||
];
|
||
$result = model('customer')->where(['email' => $data['email']])->update($update_data);
|
||
}
|
||
|
||
if (!$result)
|
||
{
|
||
return $this->json(-9, '修改密码失败,稍后再试');
|
||
}
|
||
|
||
$this->_logout();
|
||
return $this->json(200, '修改密码成功');
|
||
}
|
||
|
||
public function bind_email()
|
||
{
|
||
$data = $this->request->post();
|
||
|
||
if (empty($data) || $this->customer_id <= 0)
|
||
{
|
||
return $this->json(-1, '数据错误');
|
||
}
|
||
|
||
if (!preg_match("/^[_a-z0-9-]+(\.[_a-z0-9-]+)*@[a-z0-9-]+(\.[a-z0-9-]+)*(\.[a-z]{2,})$/", $data['email']))
|
||
{
|
||
return $this->json(-2, '邮箱格式错误');
|
||
}
|
||
|
||
$customer_info = model('customer')->where(['email' => $data['email']])->find();
|
||
if (!empty($customer_info))
|
||
{
|
||
return $this->json(-3, '邮箱已被使用');
|
||
}
|
||
|
||
$update_data = [
|
||
'email' => $data['email']
|
||
];
|
||
|
||
$result = model('customer')->where(['id' => $this->customer_id])->update($update_data);
|
||
if (!$result)
|
||
{
|
||
return $this->json(-3, '绑定邮箱失败,请稍后再试');
|
||
}
|
||
|
||
$customer_info = model('customer')->getBasicInfo($this->customer_id);
|
||
|
||
$this->set_login_token($customer_info);
|
||
return $this->json(200, '绑定邮箱成功');
|
||
|
||
}
|
||
|
||
# 旧手机号改新手机号
|
||
public function update_tel()
|
||
{
|
||
$data = $this->request->post();
|
||
// tiaoshi($data);die;
|
||
if (empty($data) || $this->customer_id <= 0)
|
||
{
|
||
return $this->json(-1, '数据错误');
|
||
}
|
||
$customer_info = model('customer')->where(['id' => $this->customer_id])->find();
|
||
if ($customer_info['telephone'] != $data['old_telephone'])
|
||
{
|
||
return $this->json(-2, '旧手机号错误');
|
||
}
|
||
|
||
if (!preg_match("/^1([38][0-9]|4[579]|5[0-3,5-9]|6[6]|7[0135678]|9[89])\d{8}$/", $data['new_telephone']))
|
||
{
|
||
return $this->json(-3, '手机号格式错误');
|
||
}
|
||
|
||
$captcha = $this->cacheGet('regtel' . $data['new_telephone'], 'error');
|
||
if ($captcha != $data['captcha'])
|
||
{
|
||
return $this->json(-4, '验证码错误');
|
||
}
|
||
|
||
$update_data = [
|
||
'telephone' => $data['new_telephone']
|
||
];
|
||
|
||
$result = model('customer')->where(['id' => $this->customer_id])->update($update_data);
|
||
if (!$result)
|
||
{
|
||
return $this->json(-5, '修改失败');
|
||
}
|
||
|
||
$new_customer_info = model('customer')->getBasicInfo($this->customer_id);
|
||
|
||
$this->set_login_token($new_customer_info);
|
||
return $this->json(200, '修改成功');
|
||
}
|
||
|
||
public function new_register()
|
||
{
|
||
if ($this->customer_id > 0)
|
||
return $this->json(-10001, '已经登录过');
|
||
|
||
$data = $this->request->post();
|
||
tiaoshi($data);die;
|
||
if (empty($data))
|
||
{
|
||
return $this->json(-1, '数据错误');
|
||
}
|
||
|
||
$validate = Loader::validate('customer');
|
||
if (!$validate->scene('register_by_telephone')->check($data))
|
||
{
|
||
return $this->json(-2, $validate->getError());
|
||
}
|
||
|
||
$captcha = $this->cacheGet('regtel' . $data['telephone'], 'error');
|
||
if ($captcha != $data['captcha'])
|
||
{
|
||
return $this->json(-4, '验证码错误');
|
||
}
|
||
|
||
$firstname = 'ORICO' . rand(10000000, 99999999);
|
||
$insert_data = [
|
||
'firstname' => $firstname,
|
||
'telephone' => $data['telephone'],
|
||
'addtime' => time()
|
||
];
|
||
|
||
$customer_id = model('customer')->insertGetId($insert_data);
|
||
if (!$customer_id)
|
||
{
|
||
return $this->json(-100, '注册失败');
|
||
}
|
||
|
||
$customer_info = model('customer')->getBasicInfo($customer_id);
|
||
|
||
$this->set_login_token($customer_info);
|
||
return $this->json(200, '注册成功');
|
||
}
|
||
|
||
|
||
public function new_login()
|
||
{
|
||
if ($this->customer_id > 0)
|
||
return $this->json(-10001, '已经登录过');
|
||
|
||
$data = $this->request->post();
|
||
if (empty($data))
|
||
{
|
||
return $this->json(-1, '数据错误');
|
||
}
|
||
|
||
if (isset($data['password']))
|
||
{
|
||
// 密码登录
|
||
if (preg_match("/^1([38][0-9]|4[579]|5[0-3,5-9]|6[6]|7[0135678]|9[89])\d{8}$/", $data['username']))
|
||
{
|
||
$where = ['telephone' => $data['username']];
|
||
}
|
||
elseif (preg_match("/^[_a-z0-9-]+(\.[_a-z0-9-]+)*@[a-z0-9-]+(\.[a-z0-9-]+)*(\.[a-z]{2,})$/", $data['username']))
|
||
{
|
||
$where = ['email' => $data['username']];
|
||
}
|
||
else
|
||
{
|
||
return $this->json(-2, '账号格式错误');
|
||
}
|
||
|
||
$where['stat'] = 0;
|
||
$customer_info = model('customer')->where($where)->field('id, firstname, picture, sex, email, telephone, qq, birthday, password')->find();
|
||
if (empty($customer_info))
|
||
{
|
||
return $this->json(-3, '账号未注册');
|
||
}
|
||
if ($customer_info['password'] != md5($data['password']))
|
||
{
|
||
return $this->json(-4, '账号或密码错误');
|
||
}
|
||
}
|
||
else
|
||
{
|
||
// 短信验证码登录
|
||
$captcha = $this->cacheGet('regtel' . $data['telephone'], 'error');
|
||
if ($captcha != $data['captcha'])
|
||
{
|
||
return $this->json(-5, '验证码错误');
|
||
}
|
||
|
||
$customer_info = model('customer')->getBasicInfoByTelephone($data['telephone']);
|
||
if (empty($customer_info))
|
||
{
|
||
// 未注册直接入库
|
||
$firstname = 'ORICO' . rand(10000000, 99999999);
|
||
$insert_data = [
|
||
'firstname' => $firstname,
|
||
'telephone' => $data['telephone'],
|
||
];
|
||
|
||
$customer_id = model('customer')->insertGetId($insert_data);
|
||
if (!$customer_id)
|
||
{
|
||
return $this->json(-6, '登录失败');
|
||
}
|
||
|
||
$customer_info = model('customer')->getBasicInfoByTelephone($data['telephone']);
|
||
}
|
||
}
|
||
|
||
$this->set_login_token($customer_info);
|
||
return $this->json(200, '登录成功');
|
||
}
|
||
|
||
public function new_logout()
|
||
{
|
||
$this->_logout();
|
||
return $this->json(200, 'ok');
|
||
}
|
||
|
||
|
||
/**
|
||
* 前台用户登录
|
||
*/
|
||
public function check_login() {
|
||
$data = $this->request->post();
|
||
if (empty($data) || !is_array($data)) {
|
||
return $this->json(-1, '未知错误');
|
||
}
|
||
|
||
// $code = $this->cacheGet('regtel' . $data['telephone']);
|
||
// if ($code != $data['code']) {
|
||
// return $this->json(-1, '短信验证码不正确');
|
||
// }
|
||
|
||
$validate = Loader::validate('customer');
|
||
if (!$validate->scene('login')->check($data)) {
|
||
return $this->json(-1, $validate->getError());
|
||
}
|
||
|
||
// 登录成功
|
||
$user = model('customer')->getBasicInfoByTelephone($data['telephone']);
|
||
$curr_time = time();
|
||
$token = $this->set_token($user['id'], $curr_time);
|
||
|
||
$data = [
|
||
'user_info' => $user,
|
||
'curr_time' => $curr_time,
|
||
'token' => $token,
|
||
];
|
||
return $this->json(1, '登录成功', $data);
|
||
}
|
||
|
||
public function check_register() {
|
||
$data = $this->request->post();
|
||
if (empty($data) || !is_array($data)) {
|
||
return $this->json(-1, '未知错误');
|
||
}
|
||
|
||
// $code = $this->cacheGet('regtel' . $data['telephone']);
|
||
// if ($code != $data['code']) {
|
||
// return $this->json(-1, '短信验证码不正确');
|
||
// }
|
||
|
||
$validate = Loader::validate('customer');
|
||
if (!$validate->scene('register')->check($data)) {
|
||
return $this->json(-1, $validate->getError());
|
||
}
|
||
// tiaoshi($data);die;
|
||
$addtime = time();
|
||
$set = [
|
||
'group_id' => 1,
|
||
'telephone' => $data['telephone'],
|
||
'firstname' => isset($data['firstname']) ? $data['firstname'] : '',
|
||
// 'lastname' => isset($data['lastname']) ? $data['lastname'] : '',
|
||
// 'newsletter' => isset($data['newsletter']) ? $data['newsletter'] : 0,
|
||
'salt' => $data['password'],
|
||
'password' => md5($data['password']),
|
||
'stat' => 0,
|
||
'safe' => 1,
|
||
'code' => '',
|
||
// 'item' => isset($data['item']) ? $data['item'] : 0,
|
||
// 'token' => isset($data['token']) ? $data['token'] : '',
|
||
// 'wishlist' => isset($data['wishlist']) ? $data['wishlist'] : '',
|
||
// 'ip' => isset($data['ip']) ? $data['ip'] : '',
|
||
// 'fenxiang' => isset($data['fenxiang']) ? $data['fenxiang'] : 0,
|
||
// 'guanzhu' => isset($data['guanzhu']) ? $data['guanzhu'] : 0,
|
||
// 'hangye' => isset($data['hangye']) ? $data['hangye'] : '',
|
||
// 'zhiye' => isset($data['zhiye']) ? $data['zhiye'] : '',
|
||
// 'sex' => isset($data['sex']) ? $data['sex'] : '',
|
||
// 'birthday' => isset($data['birthday']) ? $data['birthday'] : '',
|
||
// 'qq' => isset($data['qq']) ? $data['qq'] : '',
|
||
'addtime' => $addtime,
|
||
// 'custom_field' => json_encode([]),
|
||
];
|
||
$result = Loader::model('Customer')->insertRow($set);
|
||
if ($result && $customer_id = $result->getData('id')) {
|
||
$user = model('customer')->getBasicInfo($customer_id);
|
||
$curr_time = time();
|
||
$token = $this->set_token($customer_id, $curr_time);
|
||
$data = [
|
||
'user_info' => $user,
|
||
'curr_time' => $curr_time,
|
||
'token' => $token,
|
||
];
|
||
return $this->json(1, '注册成功', $data);
|
||
} else {
|
||
return $this->json(-1, '注册失败');
|
||
}
|
||
|
||
|
||
}
|
||
|
||
public function sendsms() {
|
||
$data = $this->request->post();
|
||
|
||
if (empty($data) || !is_array($data)) {
|
||
return $this->json(-1, '未知错误');
|
||
}
|
||
|
||
if (isset($data['login']) && $data['login'])
|
||
{
|
||
$customer_info = model('customer')->getBasicInfoByTelephone($data['telephone']);
|
||
if (empty($customer_info))
|
||
{
|
||
return $this->json(-101, '手机号未注册');
|
||
}
|
||
}
|
||
else if (isset($data['register']) && $data['register'])
|
||
{
|
||
$customer_info = model('customer')->getBasicInfoByTelephone($data['telephone']);
|
||
if (!empty($customer_info))
|
||
{
|
||
return $this->json(-102, '手机号已注册');
|
||
}
|
||
}
|
||
|
||
$validaterule = [
|
||
'telephone' => ['regex' => '^1[345789]\d{9}$'],
|
||
];
|
||
$validatemsg = [
|
||
'telephone.regex' => '手机格式错误',
|
||
];
|
||
|
||
$valid_result = $this->validate($data, $validaterule, $validatemsg);
|
||
if (true !== $valid_result) {
|
||
return $this->json(-2, $valid_result);
|
||
}
|
||
|
||
$mobile = $data['telephone'];
|
||
$curr_date = date('Y-m-d');
|
||
// 当前手机号今天是否发送过验证码
|
||
$is_send = Cache::get($mobile . $curr_date, '');
|
||
if ($is_send) {
|
||
// 如果发过,自增一次
|
||
Cache::inc($mobile . $curr_date);
|
||
} else {
|
||
// 如果今天第一次发短信
|
||
$expire = 86400;
|
||
Cache::set($mobile . $curr_date, 1, $expire);
|
||
}
|
||
// 当天发送数量
|
||
$today_send_count = Cache::get($mobile . $curr_date);
|
||
if ($today_send_count > 10) {
|
||
return $this->json(-102, '每天发送验证码不能超过10次');
|
||
}
|
||
|
||
//$mobile = $data['telephone'];
|
||
//$code = mt_rand(10000, 99999);
|
||
//$this->cacheSet('regtel' . $mobile, $code, 300);
|
||
//return $this->success($code);
|
||
//获取对象，如果上面没有引入命名空间，可以这样实例化：$sms = new \alisms\SendSms()
|
||
$sms = new \alisms\SendSms();
|
||
//设置关键的四个配置参数，其实配置参数应该写在公共或者模块下的config配置文件中，然后在获取使用，这里我就直接使用了。
|
||
$sms->accessKeyId = (string) Config::get('sms_accesskeyid');
|
||
$sms->accessKeySecret = (string) Config::get('sms_accesskeysecret');
|
||
$sms->signName = (string) Config::get('sms_signname');
|
||
$sms->templateCode = (string) Config::get('sms_templatecode');
|
||
|
||
|
||
//模板参数，自定义了随机数，你可以在这里保存在缓存或者cookie等设置有效期以便逻辑发送后用户使用后的逻辑处理
|
||
$code = mt_rand(10000, 99999);
|
||
$this->cacheSet('regtel' . $mobile, $code, 300);
|
||
$templateParam = array('code' => $code);
|
||
$m = $sms->send($mobile, $templateParam);
|
||
//类中有说明，默认返回的数组格式，如果需要json，在自行修改类，或者在这里将$m转换后在输出
|
||
if ($m['Code'] == 'OK') {
|
||
return $this->json(200, $m['Message']);
|
||
} else {
|
||
return $this->json(-1, $m['Message']);
|
||
}
|
||
}
|
||
|
||
/*个人中心*/
|
||
|
||
public function my_collection()
|
||
{
|
||
if ($this->customer_id <= 0)
|
||
{
|
||
$this->redirect('mobile/customer/login.html');
|
||
}
|
||
|
||
$param = $this->request->param();
|
||
// tiaoshi($param);die;
|
||
$where = ['a.stat' => 0, 'b.stat' => 0, 'a.customer_id' => $this->customer_id];
|
||
if (isset($param['cid']))
|
||
{
|
||
$cid_arr = model('product_category')->getChildIDArray($param['cid']);
|
||
$where['b.cid'] = ['in', $cid_arr];
|
||
$cid = $param['cid'];
|
||
}
|
||
else
|
||
{
|
||
$cid = 0;
|
||
}
|
||
|
||
$field = ['b.id', 'b.cid', 'b.name', 'b.shortname', 'b.isnew', 'b.ishot', 'b.recommend', 'b.viewcount', 'b.brand_id'];
|
||
$order = ['a.id' => 'desc'];
|
||
$list = model('collection')->getList($where, $order, $field, 10);
|
||
// echo model('collection')->getLastSql();die;
|
||
foreach ($list as $key => $value) {
|
||
$product_two_img = model('product_two_img')->where(['product_id' => $value['id']])->find();
|
||
$list[$key]['product_two_img'] = $product_two_img['image_url'];
|
||
}
|
||
|
||
$data = [
|
||
'list' => $list->isEmpty() ? null : $list->items(),
|
||
'page' => $list->render(),
|
||
'cid' => $cid
|
||
];
|
||
|
||
$this->assign($data);
|
||
return $this->fetch();
|
||
}
|
||
|
||
|
||
}
|