|
@@ -3,8 +3,15 @@
|
|
|
namespace app\admin\controller\user;
|
|
|
|
|
|
use app\admin\model\Message;
|
|
|
+use app\admin\model\UserPower;
|
|
|
use app\common\controller\Backend;
|
|
|
use app\common\library\Auth;
|
|
|
+use app\common\service\TenimService;
|
|
|
+use fast\Random;
|
|
|
+use think\Db;
|
|
|
+use think\Exception;
|
|
|
+use think\exception\PDOException;
|
|
|
+use think\exception\ValidateException;
|
|
|
|
|
|
/**
|
|
|
* 会员管理
|
|
@@ -27,8 +34,10 @@ class User extends Backend
|
|
|
parent::_initialize();
|
|
|
$this->model = model('User');
|
|
|
$typeList = [
|
|
|
+ 'genderList' => $this->model->getGenderList(),
|
|
|
'isCoolList' => $this->model->getIsCoolList(),
|
|
|
'isManagerList' => $this->model->getIsManagerList(),
|
|
|
+ 'isStealthList' => $this->model->getIsStealthList(),
|
|
|
];
|
|
|
$this->view->assign($typeList);
|
|
|
$this->assignconfig($typeList);
|
|
@@ -68,12 +77,69 @@ class User extends Backend
|
|
|
/**
|
|
|
* 添加
|
|
|
*/
|
|
|
+ /**
|
|
|
+ * 添加
|
|
|
+ */
|
|
|
public function add()
|
|
|
{
|
|
|
if ($this->request->isPost()) {
|
|
|
- $this->token();
|
|
|
+ $params = $this->request->post("row/a");
|
|
|
+ $params = $this->preExcludeFields($params);
|
|
|
+ if (!$params) {
|
|
|
+ $this->error(__('Parameter %s can not be empty', ''));
|
|
|
+ }
|
|
|
+ $result = false;
|
|
|
+ Db::startTrans();
|
|
|
+ try {
|
|
|
+ //是否采用模型验证
|
|
|
+ if ($this->modelValidate) {
|
|
|
+ $name = str_replace("\\model\\", "\\validate\\", get_class($this->model));
|
|
|
+ $validate = is_bool($this->modelValidate) ? ($this->modelSceneValidate ? $name . '.add' : $name) : $this->modelValidate;
|
|
|
+ $this->model->validateFailException(true)->validate($validate);
|
|
|
+ }
|
|
|
+ if (empty($params['avatar'])) {
|
|
|
+ $params['avatar'] = '/assets/img/default_avatar.png';
|
|
|
+ }
|
|
|
+ $ids = $this->model->column("u_id");
|
|
|
+ $invite_no = $this->model->column("invite_no");
|
|
|
+ $params['u_id'] = $this->model->getUinqueId(8, [$ids]);
|
|
|
+ $params['invite_no'] = $this->model->getUinqueNo(8, $invite_no);
|
|
|
+ if (empty($params['nickname'])) {
|
|
|
+ $params['nickname'] = 'gg_'.$params['u_id'];
|
|
|
+ }
|
|
|
+ $params['image'] = '/assets/img/default_avatar.png';
|
|
|
+ $params['username'] = $params['mobile'];
|
|
|
+ $params['status'] = 'normal';
|
|
|
+ $params['salt'] = Random::alnum();
|
|
|
+ $params['has_info'] = 1;
|
|
|
+ $result = $this->model->allowField(true)->save($params);
|
|
|
+ $userId = $this->model->id;
|
|
|
+ $userPower = new UserPower();
|
|
|
+ $userPowerData['user_id'] = $userId;
|
|
|
+ $userPowerRes = $userPower->insertGetId($userPowerData);
|
|
|
+ if (!$userPowerRes) {
|
|
|
+ throw new Exception('创建用户权限失败');
|
|
|
+ }
|
|
|
+ //创建IM用户
|
|
|
+ $tenimService = new TenimService();
|
|
|
+ $imParams['user_id'] = $userPowerRes;
|
|
|
+ $imParams['nickname'] = $params['nickname'];
|
|
|
+ $imParams['avatar'] = cdnurl($params['avatar']);
|
|
|
+ $tenimRes = $tenimService->accountImport($imParams);
|
|
|
+ if (!$tenimRes['status']) {
|
|
|
+ throw new Exception($tenimRes['msg']);
|
|
|
+ }
|
|
|
+ } catch (ValidateException|PDOException|Exception $e) {
|
|
|
+ Db::rollback();
|
|
|
+ $this->error($e->getMessage());
|
|
|
+ }
|
|
|
+ if ($result == false) {
|
|
|
+ $this->error(__('No rows were inserted'));
|
|
|
+ }
|
|
|
+ Db::commit();
|
|
|
+ $this->success();
|
|
|
}
|
|
|
- return parent::add();
|
|
|
+ return $this->view->fetch();
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -81,15 +147,56 @@ class User extends Backend
|
|
|
*/
|
|
|
public function edit($ids = null)
|
|
|
{
|
|
|
- if ($this->request->isPost()) {
|
|
|
- $this->token();
|
|
|
- }
|
|
|
$row = $this->model->get($ids);
|
|
|
- $this->modelValidate = true;
|
|
|
if (!$row) {
|
|
|
$this->error(__('No Results were found'));
|
|
|
}
|
|
|
- return parent::edit($ids);
|
|
|
+ $adminIds = $this->getDataLimitAdminIds();
|
|
|
+ if (is_array($adminIds)) {
|
|
|
+ if (!in_array($row[$this->dataLimitField], $adminIds)) {
|
|
|
+ $this->error(__('You have no permission'));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if ($this->request->isPost()) {
|
|
|
+ $params = $this->request->post("row/a");
|
|
|
+ if (!$params) {
|
|
|
+ $this->error(__('Parameter %s can not be empty', ''));
|
|
|
+ }
|
|
|
+ $params = $this->preExcludeFields($params);
|
|
|
+ $result = false;
|
|
|
+ try {
|
|
|
+ //是否采用模型验证
|
|
|
+ if ($this->modelValidate) {
|
|
|
+ $name = str_replace("\\model\\", "\\validate\\", get_class($this->model));
|
|
|
+ $validate = is_bool($this->modelValidate) ? ($this->modelSceneValidate ? $name . '.edit' : $name) : $this->modelValidate;
|
|
|
+ $row->validateFailException(true)->validate($validate);
|
|
|
+ }
|
|
|
+ if (!empty($params['u_id'])) {
|
|
|
+ $userWhere['u_id'] = $params['u_id'];
|
|
|
+ $userWhere['id'] = ['neq',$ids];
|
|
|
+ $user = $this->model->where($userWhere)->find();
|
|
|
+ if (!empty($user)) {
|
|
|
+ throw new Exception('前端用户ID已存在');
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (!empty($params['mobile'])) {
|
|
|
+ $userWhere['mobile'] = $params['mobile'];
|
|
|
+ $user = $this->model->where($userWhere)->find();
|
|
|
+ if (!empty($user)) {
|
|
|
+ throw new Exception('手机号已存在');
|
|
|
+ }
|
|
|
+ }
|
|
|
+ $result = $row->allowField(true)->save($params);
|
|
|
+ } catch (ValidateException|PDOException|Exception $e) {
|
|
|
+ $this->error($e->getMessage());
|
|
|
+ }
|
|
|
+ if ($result == false) {
|
|
|
+ $this->error(__('No rows were updated'));
|
|
|
+ }
|
|
|
+ $this->success();
|
|
|
+ }
|
|
|
+ $this->view->assign("row", $row);
|
|
|
+ return $this->view->fetch();
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -219,4 +326,76 @@ class User extends Backend
|
|
|
]);
|
|
|
return $this->view->fetch();
|
|
|
}
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 钻石充值
|
|
|
+ * @param null $ids
|
|
|
+ * @return string
|
|
|
+ */
|
|
|
+ public function addJewel($ids=null)
|
|
|
+ {
|
|
|
+ /* 判断数据是否存在*/
|
|
|
+ $row = $this->model->get($ids);
|
|
|
+ if (!$row) {
|
|
|
+ $this->error(__('No Results were found'));
|
|
|
+ }
|
|
|
+ /* 判断是否有权限访问*/
|
|
|
+ $adminIds = $this->getDataLimitAdminIds();
|
|
|
+ if (is_array($adminIds)) {
|
|
|
+ if (!in_array($row[$this->dataLimitField], $adminIds)) {
|
|
|
+ $this->error(__('You have no permission'));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if ($this->request->isPost()) {
|
|
|
+ $params = $this->request->post("row/a");
|
|
|
+ if (!$params) {
|
|
|
+ $this->error(__('Parameter %s can not be empty', ''));
|
|
|
+ }
|
|
|
+ $params = $this->preExcludeFields($params);
|
|
|
+ Db::startTrans();
|
|
|
+ try {
|
|
|
+ //是否采用模型验证
|
|
|
+ if ($this->modelValidate) {
|
|
|
+ $name = str_replace("\\model\\", "\\validate\\", get_class($this->model));
|
|
|
+ $validate = is_bool($this->modelValidate) ? ($this->modelSceneValidate ? $name . '.edit' : $name) : $this->modelValidate;
|
|
|
+ $row->validateFailException(true)->validate($validate);
|
|
|
+ }
|
|
|
+ if (!empty($params['jewel_add'])) {//钻石充值
|
|
|
+ $userWhere['id'] = $row['id'];
|
|
|
+ $user = Db::name('user')->where($userWhere)->lock(true)->find();
|
|
|
+ $before = isset($user['jewel']) ? $user['jewel'] : 0;
|
|
|
+ $jewelRes = model('Wallet')->lockChangeAccountRemain($row['id'],$params['jewel_add'],'+',$before,$remark='钻石充值()',17,'jewel');
|
|
|
+ if (!$jewelRes['status']) {
|
|
|
+ throw new Exception($jewelRes['msg']);
|
|
|
+ }
|
|
|
+ $params['jewel'] = bcadd($user['jewel'],$params['jewel_add']);
|
|
|
+ //充值日志记录
|
|
|
+ //判断是否首充
|
|
|
+ $jewellogWhere['user_id'] = $row['id'];
|
|
|
+ $jewellogWhere['type'] = 1;
|
|
|
+ $userJewelLog = model('UserJewelLog')->where($jewellogWhere)->find();
|
|
|
+ $isFirst = 1;
|
|
|
+ if (!empty($userJewelLog)) {
|
|
|
+ $isFirst = 0;
|
|
|
+ }
|
|
|
+ $preUserId = $user['pre_userid'];
|
|
|
+ $userRechargeLogRes = model('UserRechargeLog')->addRecord($row['id'], $params['jewel_add'], $user['money'], $params['jewel'], $user['money'], 4, 4,$isFirst,$preUserId);
|
|
|
+ if (!$userRechargeLogRes) {
|
|
|
+ throw new Exception('充值记录生成失败');
|
|
|
+ }
|
|
|
+ }
|
|
|
+ $result = $row->allowField(true)->save($params);
|
|
|
+ if ($result == false) {
|
|
|
+ throw new Exception(__('No rows were updated'));
|
|
|
+ }
|
|
|
+ Db::commit();
|
|
|
+ $this->success();
|
|
|
+ } catch (ValidateException|PDOException|Exception $e) {
|
|
|
+ Db::rollback();
|
|
|
+ $this->error($e->getMessage());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ $this->view->assign("row", $row);
|
|
|
+ return $this->view->fetch();
|
|
|
+ }
|
|
|
}
|