package com.estate.expert.admin.service.impl;

import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.estate.expert.admin.domain.business.screenaccount.ScreenAccount;
import com.estate.expert.admin.domain.common.EntityBase;
import com.estate.expert.admin.domain.session.UserSession;
import com.estate.expert.admin.domain.session.UserSessionRepository;
import com.estate.expert.admin.domain.user.UserDto;
import com.estate.expert.admin.domain.user.UserMapper;
import com.estate.expert.admin.domain.user.UserRepository;
import com.estate.expert.admin.domain.user.UserState;
import com.estate.expert.admin.domain.common.response.UserLoginResponse;
import com.estate.expert.admin.enums.BizResultCode;
import com.estate.expert.admin.service.LoginService;
import com.estate.expert.admin.service.ScreenAccountService;
import com.estate.expert.admin.service.screen.ScreenService;
import com.estate.expert.admin.utils.MD5Utils;
import com.estate.expert.admin.utils.UUIDGenerator;
import com.estate.expert.common.domain.Session;
import com.estate.expert.common.domain.SessionStatus;
import com.estate.expert.common.utils.PasswordUtils;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.time.LocalDateTime;

/**
 * 登录服务实现
 */
@Service
public class LoginServiceImpl implements LoginService {

    @Resource
    private UserRepository userRepository;

    @Resource
    private UserMapper userMapper;
    @Resource
    private UserSessionRepository userSessionRepository;

    @Resource
    private ScreenAccountService screenAccountService;



    public UserLoginResponse login(String mobile, String password) {
        var user = userRepository.findByMobile(mobile);
        BizResultCode.ACCOUNT_NOT_FOUND.check(user == null);

        String passInDb = user.getPassword();
        var checkPasswordBl = PasswordUtils.verify(password, passInDb);
        BizResultCode.BIZ_PASSWORD_INVALID.check(!checkPasswordBl);
        BizResultCode.ACCOUNT_FORBIDDEN.check(user.getState() == UserState.DISABLE || user.isDeleted());

        Session session = new Session();
        session.setUserId(user.getId());
        session.setUser(user);
        session.setLastAccessTime(LocalDateTime.now());
        session.setToken(UUIDGenerator.generate32Uuid());
        session.setCreateTime(LocalDateTime.now());
        session.setClientCode("admin");
        session.setStatus(SessionStatus.ENABLED);

        UserLoginResponse response = new UserLoginResponse();
        response.setToken(session.getToken());
        response.setUserInfo(userMapper.toDto(user));

        // 将session保存到数据库
        UserSession userSession = new UserSession();
        userSession.setUser(user);
        userSession.setToken(session.getToken());
        userSession.setCreateTime(LocalDateTime.now());
        userSession.setLastAccessTime(LocalDateTime.now());
        userSession.setClientCode("admin");
        userSession.setState(SessionStatus.ENABLED.name());
        userSessionRepository.save(userSession);

        user.setLastAccessTime(LocalDateTime.now());
        userRepository.save(user);
        return response;

    }

    public void logout(String token) {
        UserSession session = userSessionRepository.findByTokenOrderByIdDesc(token).orElse(null);
        if (session == null) {
            return;
        }

        session.setState(SessionStatus.LOGOUT.name());
        userSessionRepository.save(session);
    }

}