package com.yami.trading.service.agent.impl;
import java.text.MessageFormat;
import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.yami.trading.bean.agent.AgentDto;
import com.yami.trading.bean.model.Agent;
import com.yami.trading.bean.model.User;
import com.yami.trading.common.constants.Constants;
import com.yami.trading.common.exception.BusinessException;
import com.yami.trading.common.util.IPHelper;
import com.yami.trading.dao.agent.AgentMapper;
import com.yami.trading.service.agent.AgentService;
import com.yami.trading.service.system.LogService;
import com.yami.trading.service.user.UserRecomService;
import com.yami.trading.service.user.UserService;

@Service
public class   AgentServiceImpl  extends ServiceImpl<AgentMapper, Agent> implements AgentService {

    @Autowired
    UserRecomService userRecomService;

    @Autowired
    UserService userService;

    @Autowired
    LogService logService;

    @Override
    public Page<AgentDto> listTotal(Page page, String userName, List<String> userIds) {
        Page<AgentDto> reportDtoPage=  baseMapper.listTotal(page,userName,userIds);
        return reportDtoPage;
    }

    @Override
    @Transactional
    public void saveAgent(String userName, String password, String safeWord, String roleName, String remarks, String parentsUserCode, boolean loginAuthorityboolean, boolean  operaAuthority) {

        User user=  userService.saveAgentUser(userName,password,safeWord,roleName,remarks,parentsUserCode,loginAuthorityboolean);
        Agent  agent=new Agent();
        agent.setUserId(user.getUserId());
        if (null!=parentsUserCode && 0!=(parentsUserCode=parentsUserCode.trim()).length()) {
            agent.setParentUserId(user.getUserRecom());
        }
        save(agent);
        String log = MessageFormat.format(
                "ip:" + IPHelper.getIpAddr() + ",新增代理商，用户名:{0},登录权限:{1},备注:{2},推荐人uid:{3},操作权限:{4}",
               userName,loginAuthorityboolean,remarks,parentsUserCode,operaAuthority);
        logService.saveLog(user,log,Constants.LOG_CATEGORY_OPERATION);
    }

    @Override
    @Transactional
    public void updateAgent(String id, boolean loginAuthority, boolean operaAuthority,String remarks) {
        Agent agent = getById(id);
        if (agent==null){
            throw  new BusinessException("代理商不存在!");
        }
        User  user = userService.getById(agent.getUserId());
        String log = MessageFormat.format("ip:" +IPHelper.getIpAddr()  + ",修改代理商，用户名:{0},原登录权限:{1},原备注:{2},原操作权限:{3}",
                user.getUserName(), user.getStatus(), user.getRemarks(),
                Constants.SECURITY_ROLE_AGENT.equals(user.getRoleName()));

        String roleName = operaAuthority? Constants.SECURITY_ROLE_AGENT : Constants.SECURITY_ROLE_AGENTLOW;
        user.setRoleName(roleName);

        user.setLoginAuthority(loginAuthority);
        user.setEnabled(operaAuthority);
        user.setRemarks(remarks);

        user.setStatus(loginAuthority ? 1 : 0);
        userService.updateById(user);
        log += MessageFormat.format(",新登录权限:{0},新备注:{1},新操作权限:{2}", loginAuthority, user.getRemarks(), operaAuthority);
        logService.saveLog(user,log,Constants.LOG_CATEGORY_OPERATION);

    }

    @Override
    public Page<AgentDto> pagedQueryNetwork(Page page) {
        return baseMapper.pagedQueryNetwork(page);
    }
}