123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175 |
- <?php
- // +----------------------------------------------------------------------
- // | CRMEB [ CRMEB赋能开发者,助力企业发展 ]
- // +----------------------------------------------------------------------
- // | Copyright (c) 2016~2022 https://www.crmeb.com All rights reserved.
- // +----------------------------------------------------------------------
- // | Licensed CRMEB并不是自由软件,未经许可不能去掉CRMEB相关版权
- // +----------------------------------------------------------------------
- // | Author: CRMEB Team <admin@crmeb.com>
- // +----------------------------------------------------------------------
- namespace app\wap\model\user;
- use basic\ModelBasic;
- use service\WechatService;
- use service\WechatSubscribe;
- use service\CacheService as Cache;
- use think\Session;
- use traits\ModelTrait;
- /**微信信息表
- * Class WechatUser
- * @package app\wap\model\user
- */
- class WechatUser extends ModelBasic
- {
- use ModelTrait;
- protected $insert = ['add_time'];
- public static function setAddTimeAttr($value)
- {
- return time();
- }
- /**
- * 添加一个新用户
- * @param array $wechatInfo
- * @return boolen
- * */
- public static function setNewUserInfo($wechatInfo)
- {
- if (self::be(['openid' => $wechatInfo['openid']])) {
- self::where(['openid' => $wechatInfo['openid']])->update(['uid' => $wechatInfo]);
- } else {
- self::set($wechatInfo);
- }
- }
- /**
- * .添加新用户
- * @param $openid
- * @return object
- */
- public static function setNewUser($openid)
- {
- $userInfo = WechatService::getUserInfo($openid);
- $userInfo['nickname'] = '';
- $userInfo['headimgurl'] = '/system/images/user_log.jpg';
- if (!isset($userInfo['subscribe']) || !$userInfo['subscribe'] || !isset($userInfo['openid']))
- exception('请关注公众号!');
- $userInfo['tagid_list'] = implode(',', $userInfo['tagid_list']);
- self::beginTrans();
- $wechatUser = User::setWechatUser($userInfo);
- if (!$wechatUser) {
- self::rollbackTrans();
- exception('用户信息储存失败!');
- }
- $wechatUser = self::set($wechatUser);
- if (!$wechatUser) {
- self::rollbackTrans();
- exception('用户储存失败!');
- }
- self::commitTrans();
- return $wechatUser;
- }
- /**
- * 更新用户信息
- * @param $openid
- * @return bool
- */
- public static function updateUser($openid)
- {
- $userInfo = WechatService::getUserInfo($openid);
- $userInfo['tagid_list'] = implode(',', $userInfo['tagid_list']);
- return self::edit($userInfo, $openid, 'openid');
- }
- /**
- * 用户存在就更新 不存在就添加
- * @param $openid
- */
- public static function saveUser($openid)
- {
- self::be($openid, 'openid') == true ? self::updateUser($openid) : self::setNewUser($openid);
- }
- /**
- * 用户取消关注
- * @param $openid
- * @return bool
- */
- public static function unSubscribe($openid)
- {
- return self::edit(['subscribe' => 0], $openid, 'openid');
- }
- /**
- * 用uid获得openid
- * @param $uid
- * @return mixed
- */
- public static function uidToOpenid($uid, $update = false)
- {
- $cacheName = 'openid_' . $uid;
- $openid = Cache::get($cacheName);
- if ($openid && !$update) return $openid;
- $openid = self::where('uid', $uid)->value('openid');
- Cache::set($cacheName, $openid, 0);
- return $openid;
- }
- /**
- * 用uid获得Unionid
- * @param $uid
- * @return mixed
- */
- public static function uidToUnionid($uid, $update = false)
- {
- $cacheName = 'unionid_' . $uid;
- $unionid = Cache::get($cacheName);
- if ($unionid && !$update) return $unionid;
- $unionid = self::where('uid', $uid)->value('unionid');
- if (!$unionid) exception('对应的unionid不存在!');
- Cache::set($cacheName, $unionid, 0);
- return $unionid;
- }
- /**
- * 用openid获得uid
- * @param $uid
- * @return mixed
- */
- public static function openidToUid($openid, $update = false)
- {
- $cacheName = 'uid_' . $openid;
- $uid = Cache::get($cacheName);
- if ($uid && !$update) return $uid;
- $uid = self::where('openid', $openid)->value('uid');
- if (!$uid) exception('对应的uid不存在!');
- Cache::set($cacheName, $uid, 0);
- return $uid;
- }
- /**
- * 获取用户信息
- * @param $openid
- * @return array
- */
- public static function getWechatInfo($openid)
- {
- if (is_numeric($openid)) $openid = self::uidToOpenid($openid);
- $wechatInfo = self::where('openid', $openid)->find();
- if (!$wechatInfo) {
- self::setNewUser($openid);
- $wechatInfo = self::where('openid', $openid)->find();
- }
- if (!$wechatInfo) exception('获取用户信息失败!');
- return $wechatInfo->toArray();
- }
- }
|