package jnpf.base.util;

import com.baomidou.dynamic.datasource.annotation.DS;
import jnpf.base.*;
import jnpf.base.entity.DictionaryDataEntity;
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.permission.*;
import jnpf.permission.entity.*;
import jnpf.util.JsonUtil;
import jnpf.util.StringUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
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
 */
@Component
@DS("")
public class ServiceBaseUtil {

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

    //--------------------------------数据连接------------------------------
    public DbLinkEntity getDbLink(String dbLink) {
        DbLinkEntity link = StringUtil.isNotEmpty(dbLink) ? dblinkService.getInfo(dbLink) : null;
        return link;
    }

    public boolean isExistTable(String dbLinkId, String table) throws Exception {
        return dbTableService.isExistTable(dbLinkId, table);
    }

    public void createTable(List<DbTableFieldModel> dbTable) throws Exception {
        dbTableService.createTable(dbTable);
    }

    public void addField(DbTableFieldModel dbTable) throws Exception {
        dbTableService.addField(dbTable);
    }

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


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

    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) {

        }
        return billNo;
    }


    //--------------------------------组织------------------------------
    public String getOrganizeName(String idStr) {
        return organizeService.getNameByIdStr(idStr);
    }

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

    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);
    }

}