package jnpf.base.util;

import com.baomidou.dynamic.datasource.annotation.DS;
import jnpf.base.BillRuleApi;
import jnpf.base.DataInterFaceApi;
import jnpf.base.DataModelApi;
import jnpf.base.DataSourceApi;
import jnpf.constant.MsgCode;
import jnpf.database.model.dbfield.DbFieldModel;
import jnpf.database.model.dbfield.base.DbFieldModelBase;
import jnpf.database.model.dbtable.DbTableFieldModel;
import jnpf.database.model.entity.DbLinkEntity;
import jnpf.database.util.TenantDataSourceUtil;
import jnpf.exception.DataException;
import jnpf.permission.OrganizeApi;
import jnpf.permission.PositionApi;
import jnpf.permission.UserApi;
import jnpf.permission.entity.OrganizeEntity;
import jnpf.permission.entity.UserEntity;
import jnpf.util.JsonUtil;
import jnpf.util.StringUtil;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import java.util.Collections;
import java.util.List;
import java.util.Map;

import static jnpf.util.Constants.ADMIN_KEY;

/**
 * @author ：JNPF开发平台组
 * @version: V3.1.0
 * @copyright 引迈信息技术有限公司
 * @date ：2022/4/9 13:28
 */
@Slf4j
@DS("")
@Component
@RequiredArgsConstructor
public class ServiceBaseUtil {

    private final DataSourceApi dblinkService;
    private final DataModelApi dbTableService;
    private final UserApi userService;
    private final OrganizeApi organizeService;
    private final PositionApi positionService;
    private final BillRuleApi billRuleService;
    private final DataInterFaceApi dataInterfaceService;

    //--------------------------------数据连接------------------------------
    public DbLinkEntity getDbLink(String dbLink) {
        DbLinkEntity link = StringUtil.isNotEmpty(dbLink) && !"0".equals(dbLink) ? dblinkService.getInfo(dbLink) : TenantDataSourceUtil.getDataSourceConfig();
        if (dbLink == null) {
            throw new DataException(MsgCode.SYS054.get());
        }
        return link;
    }

    public boolean isExistTable(String dbLinkId, String table) {
        try {
            return dbTableService.isExistTable(dbLinkId, table);
        } catch (Exception e) {
            throw new DataException(e.getMessage());
        }
    }

    public void createTable(List<DbTableFieldModel> dbTable) {
        try {
            dbTableService.createTable(dbTable);
        } catch (Exception e) {
            throw new DataException(e.getMessage());
        }
    }

    public void addField(DbTableFieldModel dbTable) {
        try {
            dbTableService.addField(dbTable);
        } catch (Exception e) {
            throw new DataException(e.getMessage());
        }
    }

    /**
     * 获取所有字段
     *
     * @param linkId 链接名
     * @param table  表名
     * @return
     * @throws Exception
     */
    public List<DbFieldModel> getFieldList(String linkId, String table) {
        try {
            List<DbFieldModelBase> fieldList = dbTableService.getDbTableModel(linkId, table);
            return JsonUtil.getJsonToList(fieldList, DbFieldModel.class);
        } catch (Exception e) {
            throw new DataException(e.getMessage());
        }
    }


    //--------------------------------用户------------------------------

    public UserEntity getUserInfo(String id) {
        UserEntity entity = null;
        if (StringUtil.isNotEmpty(id)) {
            entity = id.equalsIgnoreCase(ADMIN_KEY) ? userService.getInfoByAccount(id) : userService.getInfoById(id);
        }
        return entity;
    }


    //--------------------------------单据规则------------------------------
    public String getBillNumber(String enCode) {
        String billNo = "";
        try {
            billNo = billRuleService.getBillNumber(enCode).getData();
        } catch (Exception e) {
            log.error(e.getMessage(), e);
        }
        return billNo;
    }


    //--------------------------------组织------------------------------

    public String getOrganizeName(String idStr) {
        return organizeService.getNameByIdStr(idStr);
    }

    public OrganizeEntity getOrganizeInfo(String id) {
        return StringUtil.isNotEmpty(id) ? organizeService.getInfoById(id) : null;
    }

    public List<OrganizeEntity> getOrganizeId(String organizeId) {
        List<OrganizeEntity> organizeList = organizeService.getOrganizeId(organizeId);
        Collections.reverse(organizeList);
        return organizeList;
    }

    //--------------------------------岗位------------------------------
    public String getPositionName(String idStr) {
        return positionService.getNameByIdStr(idStr);
    }

    //--------------------------------远端------------------------------
    public void infoToId(String interId, Map<String, String> parameterMap) {
        dataInterfaceService.infoToIdById(interId, parameterMap);
    }

}