modelwechat

app/controller/Base.php

@@ -0,0 +1,57 @@
+<?php
+
+
+namespace app\controller;
+
+
+use think\App;
+use think\Response;
+use think\exception\HttpResponseException;
+class Base extends \app\BaseController{
+	public function __construct(App $app) {parent::__construct($app);}
+	     /**
+	* @param string $message
+	* @param int $code
+	* @param null $data
+	 */
+    public function error($message='',$code=0,$data=null){
+        $this->result($message,$data,$code);
+    }
+    /**
+	* @param string $message
+	* @param int $code
+	* @param null $data
+	 */
+     public function success($message='',$data=null,$code=1){
+        $this->result($message,$data,$code);
+    }
+    
+     /**
+	* @param string $msg
+	* @param null $data
+	* @param int $code
+	* @param string|null $type
+	* @param array $header
+	* @param array $options
+	 */
+    private function result(string $msg, $data = null, int $code = 0, string $type = null, array $header = [], array
+    $options = [])
+    {
+        $result = [
+            'code' => $code,
+            'message'  => $msg,
+            'data' => $data,
+        ];
+        // 如果未设置类型则自动判断
+        $type = $type ?:  'jsonp';
+
+        $code = 200;
+        if (isset($header['statuscode'])) {
+            $code = $header['statuscode'];
+            unset($header['statuscode']);
+        }
+         $response = Response::create($result, $type, $code)->header($header)->options($options);
+         throw new HttpResponseException($response);
+    }
+	
+}

app/controller/User.php

@@ -3,20 +3,22 @@ declare (strict_types = 1);
 
 namespace app\controller;
 
-use app\BaseController;
 use app\model\Account;
 use think\facade\Cache;
-use think\Exception;use think\facade\Db;
+use think\Exception;
+use think\facade\Db;
 use think\App;
 use think\facade\Validate;
 
-class User extends BaseController
+class User extends Base
 {
 	private $token_time = 0;// token 有效时间
+	private $model =null;// token 有效时间
     public function __construct(App $app)
     {
        parent::__construct($app);
        $this->token_time= env("token.expire");
+       $this->model = new Account();
     }
     /**注册接口
     * @param string username 账户名称
@@ -128,11 +130,12 @@ class User extends BaseController
     }
 
 	/**
-    * @param string username 账户
+	* @param string username 账户
     * @param string password 密码
     * @param string plat_code 来源
 	* @return \think\response\Json
 	* @throws \Psr\SimpleCache\InvalidArgumentException
+	* @throws \think\Exception
 	* @throws \think\db\exception\DataNotFoundException
 	* @throws \think\db\exception\DbException
 	* @throws \think\db\exception\ModelNotFoundException
@@ -140,53 +143,26 @@ class User extends BaseController
 	 */
     public function login()
     {
-        $post = $this->request->only(["username" => "", "password" => "", "plat_code" => ""], "post", "trim");
+        $post = $this->request->only(["username" => "", "password" => "", "plat_code" => "","openId"=>""], "post", "trim");
         $validate = Validate::rule([
             'username|账户名称' => 'require|max:255',
             'password|密码' => 'require|min:6|max:200',
         ]);
-        if ($validate->check($post) == false) return json_show(1004, $validate->getError());
+        if ($validate->check($post) == false) $this->error($validate->getError(),1004);
 
-        $acc = Db::name("account")
-            ->where(['username' => $post['username'], "is_del" => Account::$account_del])
-            ->find();
-        if ($acc == false) return json_show(1003, '账户名不存在');
-
-        if ($acc['status'] == Account::$account_end) return json_show(1003, '账户已禁用');
+        $acc = $this->model->withJoin(["userinfo","accountitem"],"left")->where(['username' => $post['username']])->findOrEmpty();
+        if ($acc->isEmpty() == false) return json_show(1003, '账户名不存在');
 
+        if ($acc['status'] == Account::$account_end)$this->error('账户已禁用',1003);
         $sha1 = sha1($post['password'] . $acc['salt']);
-        if ($sha1 != $acc['password']) return json_show(1003, '账户或密码错误');
+        if ($sha1 != $acc['password']) $this->error('账户或密码错误',1003);
 
         $token = makeToken($acc);
-        if ($token == "") return json_show(1003, 'token生成失败');
-
-        //account_plat 是空表
-//        if ($post['plat_code'] != "") {
-//            $platinfo = Db::name("account_plat")
-//                ->alias("a")
-//                ->leftJoin("platform b", "a.plat_code=b.plat_code and b.is_del=0 and b.status=1")
-//                ->where(["a.status" => 1, "a.is_del" => 0, "a.plat_code" => $post['plat_code'], "a.account_id" => $acc['id']])
-//                ->findOrEmpty();
-//            if (empty($platinfo)) return json_show(1003, '该系统账号未开通登录');
-//
-//        }
-        $user = Db::name("account")
-            ->alias("a")
-            ->leftJoin("user b", "a.id=b.account_id and b.status=1")
-            ->leftJoin("account_item c", "c.account_id=a.id")
-            ->field("a.id,a.username,a.mobile,a.source,a.level,b.nickname,b.sex,b.email,a.addtime,a.updatetime,c.itemid,c.position")
-            ->where(["a.id" => $acc["id"]])
-            ->find();
-        if ($user == false) return json_show(1003, '用户信息不存在');
-
-        $usercompany = Db::name("account_company")
-            ->where(["account_id" => $user['id'], "is_del" => 0, "status" => 1])
-            ->column("companyCode,companyCode companyNo,companyName,companyName company_name,company_type,is_main,status");
-        $user['company_relaton'] = $usercompany;
-        $cache = Cache::store("redis")->set("user:info:{$token}", $user, $this->token_time);
-        if ($cache == false) return json_show(1003, 'token保存失败');
-        $user['token'] = $token;
-        return json_show(0, "登录成功", $user);
+        if ($token == "") $this->error('token生成失败',1003);
+        $cache = Cache::store("redis")->set("user:info:{$token}", $acc->toArray(), $this->token_time);
+        if ($cache == false)$this->error('token保存失败',1003);
+        $acc['token'] = $token;
+        $this->success("登录成功", $acc);
     }
 
     /**

app/controller/WeChat.php

@@ -0,0 +1,65 @@
+<?php
+namespace app\controller;
+
+use app\model\Account;use think\App;
+use think\facade\Cache;use think\facade\Validate;
+class WeChat  extends  Base {
+	private $wechat=null;
+	private $token_time=3600;
+	protected $isLogin = 0;
+	 public function __construct(App $app)
+    {
+        parent::__construct($app);
+        $wechat_conf=['appid'=>env('WECHAT.APPID'),'appsecret'=>env('WECHAT.APPSECRET')];
+		$this->wechat=new \Wechat($wechat_conf);
+		$this->token_time= env('token.expire');
+    }
+    
+    public function WebAuth(){
+	 	$code =$this->request->only(['code'=>''],'post','trim');
+		$valid =Validate::rule([
+			'code|微信授权Code'=>'require|max:255|min:5',
+			]);
+		if($valid->check($code)==false) $this->error($valid->getError());
+		
+		$uid =$this->wechat->getAccessTokenByCode($code['code']);
+		if($uid==false){
+			$this->error('未获取到用户数据');
+		}
+		if(!isset($uid['openid'])|| $uid['openid']=='')	$this->error('用户openid 未获取到');
+		$userinfo = $this->checkOpendId($uid['openid']);
+		$wxinfo = $this->wechat->getUserInfo($uid['openid']);
+		$this->success("获取成功",["wxinfo"=>$wxinfo,"userinfo"=>$userinfo,"isLogin"=>$this->isLogin]);
+		
+    }
+    	//网页端调用jssdk配置config
+	public function getConfig(){
+		$url =$this->request->only(['url'=>''],'post','trim');
+		$valid =Validate::rule(['url|微信授权地址'=>'require|max:255|min:5']);
+		if($valid->check($url)==false)$this->error($valid->getError());
+		$baseconfig =$this->wechat->getJsTicket();
+		if($baseconfig==false){
+			$this->error('签名获取失败');
+		}
+		$baseconfig =$this->wechat->getJsSign($url['url']);
+		if($baseconfig==false){
+			$this->error('签名获取失败');
+		}
+		$this->success('获取成功',$baseconfig);
+	}
+	
+	protected function checkOpendId($openId){
+		$account =new Account();
+		$isT = $account->withJoin(["userinfo","accountitem"],"left")
+		->where(["openId"=>$openId])
+		->findOrEmpty();
+		if($isT->isEmpty())return [];
+		$token = makeToken($isT);
+		$cache = Cache::store('redis')->set("user:info:{$token}", $isT->toArray(), $this->token_time);
+		if ($cache == false) return [];
+        $isT['token'] = $token;
+        $this->isLogin=1;
+        return $isT;
+	}
+	
+}

app/model/Account.php

@@ -3,7 +3,7 @@ declare (strict_types = 1);
 
 namespace app\model;
 
-use think\Model;
+use app\account\model\AccountItem;use app\account\model\User;use think\Model;
 
 /**
  * @mixin \think\Model
@@ -13,5 +13,33 @@ class Account extends Model
 	public static $account_start=1;
 	public static $account_end=0;
 	public static $account_del=0;
-
+	protected $globalScope=['Del'];
+	protected $append=['depart_name','company_relaton'];
+	
+    public function scopeDel($query){
+        $query->where('is_del',0);
+	}
+	
+	public function getDepartNameAttr($v,$row){
+        $item = new AccountItem();
+        $depart=$item->where(['account_id'=>$row['id']])->with(['depart'])->findOrEmpty();
+        return $depart->isEmpty()?'':$depart->depart_name;
+	}
+	
+	public function getCompanyRelatonAttr($v,$row){
+        $item = new AccountCompany();
+        $company=$item->where(['account_id'=>$row['id'],'is_del' => 0, 'status' => 1])->column("companyCode,companyCode companyNo,companyName,companyName company_name,company_type,is_main,status");
+        return $company;
+	}
+	public function UserInfo(){
+    	return $this->belongsTo(User::class,'id','account_id');
+	}
+	
+	public function AccountItem(){
+    	return $this->belongsTo(AccountItem::class,'id','account_id');
+	}
+	
+	public function CompanyRelat(){
+ 
+	}
 }

app/model/AccountItem.php

@@ -0,0 +1,14 @@
+<?php
+declare (strict_types = 1);
+
+namespace app\model;
+
+use think\Model;
+
+/**
+ * @mixin \think\Model
+ */
+class AccountItem extends Model
+{
+    //
+}

app/model/User.php

@@ -0,0 +1,14 @@
+<?php
+declare (strict_types = 1);
+
+namespace app\model;
+
+use think\Model;
+
+/**
+ * @mixin \think\Model
+ */
+class User extends Model
+{
+    //
+}

config/database.php

@@ -34,7 +34,7 @@ return [
             // 端口
             'hostport'        => env('database.hostport', '3306'),
             // 数据库连接参数
-            'params'          => [],
+           'params'          => [\PDO::ATTR_STRINGIFY_FETCHES=>true],
             // 数据库编码默认采用utf8
             'charset'         => env('database.charset', 'utf8'),
             // 数据库表前缀