package jnpf.provider.impl;

import jnpf.base.UserInfo;
import jnpf.base.entity.LogEntity;
import jnpf.base.service.LogService;
import jnpf.config.ConfigValueUtil;
import jnpf.database.util.TenantDataSourceUtil;
import jnpf.provider.system.LogProvider;
import jnpf.util.UserProvider;
import lombok.extern.slf4j.Slf4j;
import org.apache.dubbo.config.annotation.DubboService;
import org.springframework.beans.factory.annotation.Autowired;


/**
 * Dubbo服务提供者
 *
 * @author JNPF开发平台组
 * @version V3.1.0
 * @copyright 引迈信息技术有限公司（https://www.jnpfsoft.com）
 * @date 2021-07-27
 */
@Slf4j
@DubboService
public class LogProviderImpl implements LogProvider {

    @Autowired
    private ConfigValueUtil configValueUtil;
    @Autowired
    private LogService logService;

    @Override
    public void writeLogAsync(String dbId, String userId, String userName, String account, String abstracts) {
        //判断是否为多租户
        if (configValueUtil.isMultiTenancy()) {
            TenantDataSourceUtil.switchTenant(dbId);
        }
        try {
            if(log.isDebugEnabled()) {
                log.debug("写入登录日志：" + userName);
            }
//            logService.writeLogAsync(userInfo.getUserId(), userInfo.getUserName() + "/" + userInfo.getUserAccount(), "登录成功", (System.currentTimeMillis() - millis));
        } catch (Exception e) {
            log.error(e.getMessage());
        }
    }

    @Override
    public void writeLogRequest(LogEntity logEntity) {
        UserInfo userInfo = UserProvider.getUser();
        if (configValueUtil.isMultiTenancy()) {
            TenantDataSourceUtil.switchTenant(userInfo.getTenantId());
        }
        try {
            if(log.isDebugEnabled()) {
                log.debug("写入日志：" + logEntity);
            }
            logService.save(logEntity);
        } catch (Exception e) {
            log.error(e.getMessage());
        }
    }

}