package com.consum.base.service;

import com.consum.model.po.FinSysOrg;
import com.iplatform.model.po.S_dept;
import com.walker.infrastructure.utils.StringUtils;
import com.walker.jdbc.service.BaseServiceImpl;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.List;

@Service
public class FinOrgServiceImpl extends BaseServiceImpl {

    private static final String QUERY_SYS_ORG_BY_TENANT_ID = "select * from FIN_SYS_ORG where TENANT_ID = ?";
    private static final String QUERY_TREE_ALL = "select * from FIN_SYS_ORG where org_type = ? order by parent_id, LV ASC";
    private static final String QUERY_TREE_ONE = "select * from FIN_SYS_ORG where org_type = ? and parent_id = ? order by parent_id, LV ASC";
    private static final String QUERY_SYS_ORG_BY_ORGID = "SELECT * FROM FIN_SYS_ORG WHERE PARENT_ID IN (\n" +
            "SELECT PARENT_ID FROM FIN_SYS_ORG where ID = ? AND ORG_TYPE = ?) ORDER BY ORG_CODE ASC";

    /**
     * 根据机构代码，查询唯一机构对象。
     * @param orgCode
     * @return
     * @date 2023-07-05
     */
    public FinSysOrg queryOneByCode(String orgCode){
        FinSysOrg org = new FinSysOrg();
        org.setOrgCode(orgCode);
        List<FinSysOrg> orgList = this.select(org);
        if(!StringUtils.isEmptyList(orgList)){
            return orgList.get(0);
        }
        return null;
    }

    /**
     * 批量写入新的机构集合。
     * @param finSysOrgList
     * @date 2023-07-05
     */
    public List<S_dept> execBatchInsertOrgList(List<FinSysOrg> finSysOrgList){
        if(StringUtils.isEmptyList(finSysOrgList)){
            return null;
        }
        List<S_dept> deptList = new ArrayList<>(finSysOrgList.size());
        for(FinSysOrg e : finSysOrgList){
            deptList.add(this.acquirePlatformDept(e));
        }
        this.insertBatch(deptList);
        this.insertBatch(finSysOrgList);
        return deptList;
    }

    private S_dept acquirePlatformDept(FinSysOrg finSysOrg){
        S_dept dept = new S_dept();
        dept.setId(Long.valueOf(finSysOrg.getId()));  // FinSysOrg 的id 和partentId 这里改成String类型了
        dept.setDept_name(finSysOrg.getName());
        dept.setOrder_num(finSysOrg.getOrderNum());
        dept.setOrg_type(finSysOrg.getOrgType());
        dept.setCreate_time(finSysOrg.getCreateTime());

        if(finSysOrg.getParentId() != null){
            //if(finSysOrg.getParentId().longValue() == 0){
            if(finSysOrg.getParentId() == null){
                // 父节点不存在，
                dept.setAncestors("0");
            } else {
                dept.setAncestors(String.valueOf(finSysOrg.getParentId()));
            }
            dept.setOrg_id(Long.valueOf(finSysOrg.getParentId()));
            dept.setParent_id(Long.valueOf(finSysOrg.getParentId()));
        } else {
            dept.setAncestors("0");
            dept.setOrg_id(dept.getId());
            dept.setParent_id(0L);
        }
        return dept;
    }

    /**
     * @Description 查询机构树
     * @Author wh
     * @Date 2023/7/11 11:32
     */
    public List<FinSysOrg> queryOrgListForTree(int orgType, Long parentId) {
        if (parentId <= 0) {
            // 展示全部节点
            return this.select(QUERY_TREE_ALL, new Object[]{orgType}, new FinSysOrg());
        } else {
            // 显示指定下级
            return this.select(QUERY_TREE_ONE, new Object[]{orgType, parentId}, new FinSysOrg());
        }
    }

    public List<FinSysOrg> getAllSysOrgByPhone(String orgId, Integer orgType) {
        return this.select(QUERY_SYS_ORG_BY_ORGID, new Object[]{orgId, orgType}, new FinSysOrg());
    }

    public List<FinSysOrg> getByTenantId(String tenantId) {
        return this.select(QUERY_SYS_ORG_BY_TENANT_ID, new Object[]{tenantId}, new FinSysOrg());
    }
}