import { EntityManager, getEntityManager, Query } from "relaen";
import { __AmDataConfig } from "../service/__data/__amdataconfig";

export async function ClearRepeat(process){
    const condId = process.getParam('condId');
    const condEntity = __AmDataConfig.cond.entity;
    const em:EntityManager = await getEntityManager();
    let query:Query = em.createQuery(condEntity);
    const condProp = condEntity.substring(0,1).toLowerCase() + condEntity.substring(1);
    //状态字段
    for(let status of __AmDataConfig.status){
        query = em.createQuery(status.entity);
        let param = {};
        param[condProp] = condId;
        const rows = await query.select('*').where(param).getResultList() as [];
        if(rows.length>0){
            for(let r of rows){
                await handleOneStatus(r,status);
            }
        }
    }
    await em.close();
    
    async function handleOneStatus(data,status){
        for(let dataCfg of __AmDataConfig.datas){
            if(dataCfg.status === status.entity){
                const stName = status.entity;
                const statusProp = stName.substring(0,1).toLowerCase() + stName.substring(1);
                query = em.createQuery(dataCfg.entity);
                let param = {};
                param[statusProp] = data[status.id];
                const rows = await query.select('*').where(param).getResultList() as [];
                const idName = dataCfg.id;
                if(rows.length>0){
                    //对比找到重复数据进行删除
                    for(let i=0;i<rows.length-1;i++){
                        const r1 = rows[i];
                        for(let j=i+1;j<rows.length;j++){
                            const r2 = rows[j];
                            let isSame = true;
                            for(let k of Object.keys(r1)){
                                if(k === idName){
                                    continue;
                                }
                                if(r1[k] !== r2[k]){
                                    isSame = false;
                                    break;
                                }
                            }
                            if(isSame){
                                await (r2 as any).delete();
                            }
                        }
                    }
                }
            }
        }
    }
}