// +---------------------------------------------------------------------- declare (strict_types=1); namespace app\dao\wechat; use think\model; use app\dao\BaseDao; use app\model\wechat\WechatReply; use app\model\wechat\WechatKey; /** * * Class UserWechatUserDao * @package app\dao\user */ class WechatReplyKeyDao extends BaseDao { /** * 主表别名 * @var string */ protected $alias = 'r'; /** * 附表别名 * @var string */ protected $joinAlis = 'k'; /** * 设置模型 * @return string */ protected function setModel(): string { return WechatReply::class; } /** * 设置join连表模型 * @return string */ protected function setJoinModel(): string { return WechatKey::class; } /** * 关联模型 * @param string $alias * @param string $join_alias * @return \crmeb\basic\BaseModel */ protected function getModel(string $key = 'id', string $join = 'LEFT') { /** @var WechatKey $keys */ $keys = app()->make($this->setJoinModel()); $name = $keys->getName(); return parent::getModel()->join($name . ' ' . $this->joinAlis, $this->alias . '.' . $key . ' = ' . $this->joinAlis . '.reply_id', $join)->alias($this->alias); } /** * 获取所有关键字 * @param array $where * @param bool $group * @return \crmeb\basic\BaseModel|mixed|Model */ public function search(array $where = [], bool $search = false) { return $this->getModel()->when(isset($where['key']) && $where['key'], function ($query) use ($where) { $query->where($this->joinAlis . '.keys', 'LIKE', "%$where[key]%"); })->when(isset($where['type']) && $where['type'], function ($query) use ($where) { $query->where($this->alias . '.type', $where['type']); })->when(isset($where['key_type']) && $where['key_type'] !== '', function ($query) use ($where) { $query->where($this->joinAlis . '.key_type', $where['key_type']); })->where($this->joinAlis . '.keys', '<>', 'subscribe') ->where($this->joinAlis . '.keys', '<>', 'default'); } /** * 获取关键字回复列表 * @param array $where * @param bool $group * @param int $page * @param int $limit * @return array * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function getReplyKeyList(array $where, int $page, int $limit) { return $this->search($where)->page($page, $limit)->group($this->alias . '.id')->field($this->alias . '.*,' . $this->joinAlis . '.keys')->select()->toArray(); } /** * 获取条件下的条数 * @param array $where * @param bool $search * @return int */ public function count(array $where = [], bool $search = true) { return $this->search($where, $search)->group($this->alias . '.id')->count(); } }