package cn.mb.cloud.auth.security.service.impl;

import cn.mb.cloud.auth.security.entity.SysSocialDetails;
import cn.mb.cloud.auth.security.entity.SysUser;
import cn.mb.cloud.auth.security.mapper.SysSocialDetailsMapper;
import cn.mb.cloud.auth.security.mapper.SysUserMapper;
import cn.mb.cloud.auth.security.service.SysSocialDetailsService;
import cn.mb.cloud.auth.security.social.handler.LoginHandler;
import cn.mb.cloud.common.api.vo.UserVO;
import cn.mb.cloud.common.core.constant.CacheConstants;
import cn.mb.cloud.common.core.constant.enums.LoginTypeEnum;
import com.baomidou.mybatisplus.core.toolkit.StringPool;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.cache.CacheManager;
import org.springframework.stereotype.Service;

import java.util.Map;

/**
 * @author jason
 * @date 2018年08月16日
 */
@Slf4j
@AllArgsConstructor
@Service("sysSocialDetailsService")
public class SysSocialDetailsServiceImpl extends ServiceImpl<SysSocialDetailsMapper, SysSocialDetails>
        implements SysSocialDetailsService {

    private final Map<String, LoginHandler> loginHandlerMap;

    private final CacheManager cacheManager;

    private final SysUserMapper sysUserMapper;

    /**
     * 绑定社交账号
     *
     * @param type   type
     * @param code   code
     * @param userId
     * @return
     */
    @Override
    public Boolean bindSocial(String type, String code, Long userId) {
        String identify = loginHandlerMap.get(type).identify(code);
        SysUser sysUser = sysUserMapper.selectById(userId);

        if (LoginTypeEnum.GITEE.getType().equals(type)) {
            sysUser.setGiteeLogin(identify);
        } else if (LoginTypeEnum.OSC.getType().equals(type)) {
            sysUser.setOscId(identify);
        } else if (LoginTypeEnum.WECHAT.getType().equals(type)) {
            sysUser.setWxOpenid(identify);
        } else if (LoginTypeEnum.QQ.getType().equals(type)) {
            sysUser.setQqOpenid(identify);
        } else if (LoginTypeEnum.MINI_APP.getType().equals(type)) {
            sysUser.setMiniOpenid(identify);
        }

        sysUserMapper.updateById(sysUser);
        // 更新緩存
        cacheManager.getCache(CacheConstants.USER_DETAILS).evict(sysUser.getUsername());
        return Boolean.TRUE;
    }

    /**
     * 根据入参查询用户信息
     *
     * @param inStr TYPE@code
     * @return
     */
    @Override
    public UserVO getUserInfo(String inStr) {
        int size = 0;
        String[] inStrs = inStr.split(StringPool.AT);
        String type = inStrs[0];
        //size += inStrs[0].length();
        size++;
        String loginStr = inStrs[1];
        size++;
        //size += inStrs[1].length();
        String threeAvatar = null;
        String threeName = null;
        if (inStrs.length > size) {
            threeAvatar = inStrs[2];
            //size += inStrs[2].length();
            size++;
            if (inStrs.length > size) {
                threeName = inStrs[3];
            }
        }
        return loginHandlerMap.get(type).handle(loginStr, threeAvatar, threeName);
    }

}