package com.fdkankan.openApi.service.www.impl;

import cn.hutool.core.util.StrUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.fdkankan.common.constant.ErrorCode;
import com.fdkankan.common.exception.BusinessException;
import com.fdkankan.openApi.constant.JmgaConstant;
import com.fdkankan.openApi.entity.www.JyUser;
import com.fdkankan.openApi.httpclient.client.JmgaClient;
import com.fdkankan.openApi.mapper.www.IJyUserMapper;
import com.fdkankan.openApi.service.www.IJyUserService;
import com.fdkankan.openApi.vo.www.DelJyUserParamVo;
import com.fdkankan.openApi.vo.www.JyUserParamVo;
import com.fdkankan.openApi.vo.www.SaveJyUserParamVo;
import com.fdkankan.web.response.ResultData;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.List;
import java.util.Objects;
import java.util.Set;

/**
 * <p>
 *  服务实现类
 * </p>
 *
 * @author
 * @since 2023-09-11
 */
@DS("www")
@Service
public class JyUserServiceImpl extends ServiceImpl<IJyUserMapper, JyUser> implements IJyUserService {

    @Resource
    private JmgaClient fdKKClient;

    @Override
    public JyUser getByUserName(String userName) {
        return this.getOne(new LambdaQueryWrapper<JyUser>().eq(JyUser::getRyNo, userName));
    }

    @Override
    public JyUser getByRyId(String ryId) {
        return this.getOne(new LambdaQueryWrapper<JyUser>().eq(JyUser::getRyId, ryId));
    }

    @Override
    public List<JyUser> listByRyNos(Set<String> ryNoSet) {
        return this.list(new LambdaQueryWrapper<JyUser>().in(JyUser::getRyNo, ryNoSet));
    }

    @Override
    public List<JyUser> listByRyIds(Set<String> ryIdSet) {
        return this.list(new LambdaQueryWrapper<JyUser>().in(JyUser::getRyId, ryIdSet));
    }

    @Override
    public ResultData addUcenterUser(SaveJyUserParamVo param) {
        if(StrUtil.isEmpty(param.getNickName())){
            param.setNickName(param.getRyNo());
        }

        return fdKKClient.post(JmgaConstant.API_ADD_UCENTER_USER, param);
    }

    @Override
    public ResultData delUcenterUser(DelJyUserParamVo param) {
        return fdKKClient.post(JmgaConstant.API_DEL_UCENTER_USER, param);
    }

    @Override
    public ResultData getByRyId(JyUserParamVo param) {
        if(StrUtil.isEmpty(param.getRyId())){
            throw new BusinessException(ErrorCode.PARAM_REQUIRED.code(), "ryId不能为空");
        }
        return fdKKClient.post(JmgaConstant.API_GET_UCENTER_USER, param);
    }

    @Override
    public ResultData updateStatus(DelJyUserParamVo param) {
        if(Objects.isNull(param)){
            throw new BusinessException(ErrorCode.PARAM_REQUIRED.code(), "status不能为空");
        }
        return fdKKClient.post(JmgaConstant.API_STATUS_UCENTER_USER, param);
    }
}