// +---------------------------------------------------------------------- namespace app\services\store; use app\dao\store\StoreUserDao; use app\services\BaseServices; use app\services\user\level\SystemUserLevelServices; use app\services\user\level\UserLevelServices; use app\services\user\UserServices; use think\exception\ValidateException; /** * 门店用户 * Class StoreUser * @package app\services\store * @mixin StoreUserDao */ class StoreUserServices extends BaseServices { /** * 构造方法 * StoreUser constructor. * @param StoreUserDao $dao */ public function __construct(StoreUserDao $dao) { $this->dao = $dao; } /** * @param array $where * @param int $store_id * @return array * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function index(array $where, int $store_id) { $where['is_filter_del'] = 1; $where['store_id'] = $store_id; /** @var UserStoreUserServices $userStoreUserServices */ $userStoreUserServices = app()->make(UserStoreUserServices::class); $fields = 'u.*'; [$list, $count] = $userStoreUserServices->getWhereUserList($where, $fields); if ($list) { $uids = array_column($list, 'uid'); /** @var UserServices $userServices */ $userServices = app()->make(UserServices::class); $userlabel = $userServices->getUserLablel($uids, 1, $store_id); $levelName = app()->make(SystemUserLevelServices::class)->getUsersLevel(array_unique(array_column($list, 'level'))); $userLevel = app()->make(UserLevelServices::class)->getUsersLevelInfo($uids); $spread_names = $userServices->getColumn([['uid', 'in', $uids]], 'nickname', 'uid'); /** @var SystemStoreStaffServices $staffServices */ $staffServices = app()->make(SystemStoreStaffServices::class); $staffNames = $staffServices->getColumn([['store_id', '=', $store_id], ['uid', 'in', array_column($list, 'uid')], ['is_del', '=', 0]], 'uid,staff_name', 'uid'); foreach ($list as &$item) { $item['status'] = ($item['status'] == 1) ? '正常' : '禁止'; $item['birthday'] = $item['birthday'] ? date('Y-m-d', (int)$item['birthday']) : ''; $item['spread_uid_nickname'] = $item['spread_uid'] ? ($spread_names[$item['spread_uid']] ?? '') . '/' . $item['spread_uid'] : '无'; $item['staff_name'] = $staffNames[$item['uid']]['staff_name'] ?? ''; //用户类型 if ($item['user_type'] == 'routine') { $item['user_type'] = '小程序'; } else if ($item['user_type'] == 'wechat') { $item['user_type'] = '公众号'; } else if ($item['user_type'] == 'h5') { $item['user_type'] = 'H5'; } else if ($item['user_type'] == 'pc') { $item['user_type'] = 'PC'; } else if ($item['user_type'] == 'app') { $item['user_type'] = 'APP'; } else $item['user_type'] = '其他'; //等级名称 $item['level'] = $levelName[$item['level']] ?? '无'; //用户等级 $item['vip_name'] = false; $levelinfo = $userLevel[$item['uid']] ?? null; if ($levelinfo) { if ($levelinfo && ($levelinfo['is_forever'] || time() < $levelinfo['valid_time'])) { $item['vip_name'] = $item['level'] != '无' ? $item['level'] : false; } } $item['labels'] = $userlabel[$item['uid']] ?? ''; $item['isMember'] = $item['is_money_level'] > 0 ? 1 : 0; } } return compact('count', 'list'); } /** * 同步写入门店用户 * @param int $uid * @param int $store_id * @return bool * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function setStoreUser(int $uid, int $store_id) { $storeUser = $this->dao->getOne(['uid' => $uid, 'store_id' => $store_id]); if (!$storeUser) { if (!$this->dao->save(['uid' => $uid, 'store_id' => $store_id, 'add_time' => time()])) { throw new ValidateException('新增门店用户失败'); } } return true; } }