thinkphp6.0封裝資料庫及快取模型
阿新 • • 發佈：2021-07-25
專案中的thinkphp6.0\app\common\Model.php
1 <?php 2 /** 3 * 資料庫及快取模型 4 */ 5 namespace app\common; 6 7 use app\index\server\RedisServer; 8 use think\db\BaseQuery; 9 use think\facade\Db; 10 use think\facade\Log; 11 12 class Model 13 { 14 protected $name; 15 16 /** 查詢多條資料資訊(批量查詢方法), 快取中未找到時去資料庫查詢17 * @param $ids 18 * @return array 19 */ 20 public function getCacheList($ids) 21 { 22 // 整理查詢的資料, 並存入 $key 23 $keys = []; 24 foreach ($ids as $id) { 25 if($id) 26 { 27 $keys[$id] = $id; 28 }29 } 30 if (empty($keys)) { 31 return []; 32 } 33 34 // 準備結果集 35 $result = []; 36 37 38 /** 在Redis中查詢資料 39 * @var \Redis $redis 40 */ 41 $redis = Instance::getInstance(RedisServer::class); 42 if ($redis) { 43 //建立管道，批量獲取 44 $pip = $redis->pipeline(); 45 foreach ($keys as $id) { 46 $pip->hGetAll(static::class . ':' . $id); 47 } 48 if ($caches = $pip->exec()) { 49 foreach ($caches as $value) { 50 if ($value) { 51 // 在$key中刪除掉已查詢到的資料 52 unset($keys[$value['id']]); 53 $result[$value['id']] = $value; 54 } 55 } 56 } 57 } 58 59 // 如果 $keys 不為空, 則表示有資料未從快取中查詢到, 在 mysql 中進行查詢並快取到Redis 60 if ($keys) { 61 foreach ($this->query()->whereIn('id', array_values($keys))->cursor() as $item) { 62 $redis->hMSet(static::class . ':' . $item['id'], $item); 63 $redis->expire(static::class . ':' . $item['id'], 60); //有效期10分鐘 64 $result[$item['id']] = $item; 65 } 66 } 67 return $result; 68 } 69 70 71 /** 查詢單條資料資訊, 快取中未找到時去資料庫查詢 72 * @param $id 73 * @param null $showKey 74 * @return mixed|null 75 */ 76 public function getCacheInfo($id, $showKey = null) 77 { 78 $redis = Instance::getInstance(RedisServer::class); 79 if ($redis) { 80 if ($cache = $redis->hGetAll(static::class . ':' . $id)) { 81 return $showKey ? $cache[$showKey] : $cache; 82 } 83 } 84 $data = $this->query()->where('id', $id)->find(); 85 if ($data) { 86 $redis->hMSet(static::class . ':' . $id, $data); 87 $redis->expire(static::class . ':' . $id, 60); //有效期10分鐘 88 return $showKey ? $data[$showKey] : $data; 89 } 90 return null; 91 } 92 93 94 /** 查詢多條資料資訊, 快取中未找到時去資料庫查詢 95 * @param $ids 96 * @return array 97 */ 98 public function getCacheDataList($ids) 99 { 100 $result = []; 101 foreach ($ids as $id) { 102 $result[$id] = $this->getCacheInfo($id); 103 } 104 return $result; 105 } 106 107 108 /** 根據ID執行單條資料查詢, 並存儲到Redis 109 * @param $id 110 * @return null 111 */ 112 public function setCacheInfo($id) 113 { 114 $redis = Instance::getInstance(RedisServer::class); 115 $data = $this->query()->where('id', $id)->find(); 116 if ($data) { 117 $redis->hMSet(static::class . ':' . $id, $data); 118 $redis->expire(static::class . ':' . $id, 600); //有效期10分鐘 119 return $data; 120 } 121 return null; 122 } 123 124 125 126 /** 資料庫中根據ID查詢資訊(不經過快取) 127 * @param $id 128 * @param string $field 129 * @return mixed 130 */ 131 public function getById($id, $field = '*') 132 { 133 $where = [ 134 'id' => $id, 135 'is_delete' => 0 136 ]; 137 return $this->query()->where($where)->field($field)->find(); 138 } 139 140 141 142 /** 資料庫中根據ID查詢使用者資訊(不經過快取) 143 * @param $id 144 * @param string $field 145 * @return mixed 146 */ 147 public function getByUserId($userId) 148 { 149 $where = [ 150 'user_id' => $userId, 151 'is_delete' => 0 152 ]; 153 return $this->query()->where($where)->find(); 154 } 155 156 /** 157 * @return BaseQuery 158 */ 159 public function query() 160 { 161 return Db::name($this->name); 162 } 163 164 165 166 /** 建立$query物件 167 * @return \think\Model 168 */ 169 public static function createQuery($field = '*', $where = null, $order = null) 170 { 171 $query = Instance::getInstance(static::class)->query()->field($field); 172 if ($where) { 173 $query->where($where); 174 } 175 if ($order) { 176 $query->order($order); 177 } 178 return $query; 179 } 180 181 182 /** 建立查詢$query 並新增查詢條件, (where, order, limit, field) 183 * 不直接呼叫, 只通過該類下的 select等方法呼叫 184 * @param null $where 185 * @param array $order 186 * @param null $limit 187 * @param null $field 188 * @return BaseQuery 189 */ 190 public function createSelect($where = null, $order = [], $limit = null, $field = null) 191 { 192 $query = $this->query(); 193 if ($where) { 194 $query->where($where); 195 } 196 if ($field) { 197 $query->field($field); 198 } 199 if ($order) { 200 foreach ($order as $key => $value) { 201 $query->order($key, $value); 202 } 203 } 204 if ($limit) { 205 if (is_integer($limit)) { 206 $query->limit($limit); 207 } else { 208 $query->limit($limit[0], $limit[1]); 209 } 210 } 211 return $query; 212 } 213 214 215 /** 多條資料查詢方法 216 * @param null $where 217 * @param array $order 218 * @param null $limit 219 * @param null $format 220 * @param null $field 221 * @return array 222 */ 223 public function select($where = null, $order = [], $limit = null, $format = null, $field = null) 224 { 225 $result = []; 226 $query = $this->createSelect($where, $order, $limit, $field); 227 if ($dataList = $query->select()) { 228 foreach ($dataList as $value) { 229 $result[] = $format ? call_user_func_array($format, [$value]) : $value; 230 } 231 } 232 return $result; 233 } 234 235 236 /** 單條資料查詢方法 237 * @param null $where 238 * @param array $order 239 * @param null $limit 240 * @param null $field 241 * @return mixed 242 */ 243 public function find($where = null, $order = [], $limit = null, $field = null) 244 { 245 return $this->createSelect($where, $order, $limit, $field)->find(); 246 } 247 248 public function selectIndex($where = null, $order = [], $limit = null, $format = null, $field = null) 249 { 250 $result = []; 251 $query = $this->createSelect($where, $order, $limit, $field); 252 if ($dataList = $query->select()) { 253 foreach ($dataList as $value) { 254 $result[$value['id']] = $format ? call_user_func_array($format, [$value]) : $value; 255 } 256 } 257 return $result; 258 } 259 260 261 /** 根據ID刪除資料(軟刪除) 262 * @param $id 263 * @return mixed 264 */ 265 public function deleteById($id) 266 { 267 return $this->query()->where(['id' => $id])->update(['is_delete' => 1]); 268 } 269 270 271 /** 根據where條件刪除資料 272 * @param $where 273 * @return mixed 274 */ 275 public function deleteByWhere($where) 276 { 277 return $this->query()->where($where)->delete(); 278 } 279 280 281 /** 插入資料 282 * 自動條件建立時間和更新時間 283 * @param $data 284 * @param array $exception 285 * @return false 286 * @throws Exception 287 */ 288 public function create($data, $exception = []) 289 { 290 try { 291 $data['create_time'] = time(); 292 $data['update_time'] = time(); 293 $id = $this->query()->insertGetId($data); 294 295 if ($id) { 296 $data['id'] = $id; 297 return $data; 298 } else { 299 return false; 300 } 301 } catch (\Exception $e) { 302 Log::record(Db::getLastSql(), 'SQL-ERROR'); 303 Log::record($e->getMessage(), 'SQL-ERROR'); 304 if ($exception) { 305 throw new Exception($exception); 306 } 307 return false; 308 } 309 } 310 311 /** 312 * 根據陣列和key 獲取ids 313 * @param array $arr 314 * @param null $key 315 * @return bool|string 316 */ 317 public function getIds($arr = [], $key = null) 318 { 319 if (empty($arr) || empty($key)) { 320 return false; 321 } 322 $res = []; 323 foreach ($arr as $k => $v) { 324 $res[] = $v[$key]; 325 } 326 $res = implode(',', $res); 327 return $res; 328 } 329 330 331 /** 更新資料資訊 332 * 自動新增更新時間 333 * @param $where 334 * @param $data 335 * @param array $exception 336 * @return false 337 * @throws Exception 338 */ 339 public function update($where, $data, $exception = []) 340 { 341 try { 342 if (!is_array($where)) { 343 $where = [ 344 'id' => $where 345 ]; 346 } 347 $data['update_time'] = time(); 348 return $this->query()->where($where)->update($data); 349 } catch (\Exception $e) { 350 Log::record(Db::getLastSql(), 'SQL-ERROR'); 351 Log::record($e->getMessage(), 'SQL-ERROR'); 352 if ($exception) { 353 throw new Exception($exception); 354 } 355 return false; 356 } 357 } 358 359 }