package com.highdatas.mdm.service.impl;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.mapper.Wrapper;
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
import com.highdatas.mdm.entity.*;
import com.highdatas.mdm.mapper.MaintainDetailMapper;
import com.highdatas.mdm.mapper.MaintainMapper;
import com.highdatas.mdm.mapper.TableInfoMapper;
import com.highdatas.mdm.pojo.*;
import com.highdatas.mdm.service.*;
import com.highdatas.mdm.util.Constant;
import com.highdatas.mdm.util.DbUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.text.MessageFormat;
import java.util.*;
import java.util.stream.Collectors;

/**
 * <p>
 * 服务实现类
 * </p>
 *
 * @author kimi
 * @since 2019-12-16
 */
@Service
public class MaintainServiceImpl extends ServiceImpl<MaintainMapper, Maintain> implements IMaintainService {
    @Autowired
    IMaintainDetailService maintainDetailService;

    @Autowired
    TableInfoMapper tableInfoMapper;
    @Autowired
    MasterDataService masterDataService;
    @Autowired
    ISysFieldService fieldService;

    @Autowired
    MaintainMapper maintainMapper;

    @Autowired
    IFlowsService flowsService;
    @Autowired
    MaintainDetailMapper maintainDetailMapper;
    @Autowired
    IMaintainFieldService maintainFieldService;

    @Override
    public JSONObject compare(String maintainId, String maintainId2, Operate operate, int pageNo, int pageSize) {
        Maintain baseMaintain = selectById(maintainId);
        Maintain compareMaintain = selectById(maintainId2);

        HashMap<Operate, Object> operateIntegerMap = new HashMap<Operate, Object>();
        List<Map<String, Object>> maps;
        Page page;
        List<SysField> fieldByMaintain;
        if (DbUtils.compareVersion(baseMaintain, compareMaintain) > 0) {
            String maintainTableName = baseMaintain.getTableName();
            String tempName = baseMaintain.getTableName() + Constant.RECORD;
            fieldByMaintain = fieldService.getFieldByMaintain(baseMaintain.getId());
            String collect = fieldByMaintain.stream().map(sysField -> sysField.getField()).collect(Collectors.joining(Constant.COMMA));
            maps = maintainDetailMapper.selectOperateDatas("count(*) as cnt", tempName, operate.name(), maintainTableName, compareMaintain.getOrderNo(), baseMaintain.getOrderNo(), null, null);
            Object cnt = maps.get(0).get("cnt");
            page = new Page(Integer.valueOf(cnt.toString()));
            page.setPageNo(pageNo);
            page.setPageSize(pageSize);
            maps = maintainDetailMapper.selectOperateDatas(collect, tempName, operate.name(), maintainTableName, compareMaintain.getOrderNo(), baseMaintain.getOrderNo(), "desc", page.getLimitSQL());

        } else {
            if (operate.equals(Operate.create)) {
                operate = Operate.delete;
            } else if (operate.equals(Operate.delete)) {
                operate = Operate.create;
            }
            String maintainTableName = compareMaintain.getTableName();
            String tempName = compareMaintain.getTableName() + Constant.RECORD;
            fieldByMaintain = fieldService.getFieldByMaintain(compareMaintain.getId());
            String collect = fieldByMaintain.stream().map(sysField -> sysField.getField()).collect(Collectors.joining(Constant.COMMA));
            maps = maintainDetailMapper.selectOperateDatas("count(*) as cnt", tempName, operate.name(), maintainTableName, baseMaintain.getOrderNo(), compareMaintain.getOrderNo(), null, null);
            Object cnt = maps.get(0).get("cnt");
            page = new Page(Integer.valueOf(cnt.toString()));
            page.setPageNo(pageNo);
            page.setPageSize(pageSize);
            maps = maintainDetailMapper.selectOperateDatas(collect, tempName, operate.name(), maintainTableName, baseMaintain.getOrderNo(), compareMaintain.getOrderNo(), null, page.getLimitSQL());
        }

        JSONObject object = new JSONObject();
        object.fluentPut("total", page.getRecordCount());
        object.fluentPut("size", page.getPageSize());
        object.fluentPut("pages", page.getPageCount());
        object.fluentPut("current", page.getPageNo());
        object.fluentPut("records", maps);
        object.fluentPut("fields", fieldByMaintain);

        return object;
    }

    private void addCompareInfo(Maintain baseMaintain, Maintain compareMaintain, HashMap<Operate, Object> operateIntegerMap) {
        Integer fromNo = compareMaintain.getOrderNo();
        Integer toNo = baseMaintain.getOrderNo();
        for (int i = fromNo + 1; i <= toNo; i++) {
            Maintain maintain = selectOne(new EntityWrapper<Maintain>().eq("table_name", baseMaintain.getTableName()).eq("order_no", i));
            List<MaintainDetail> maintainDetailList = maintainDetailService.selectList(new EntityWrapper<MaintainDetail>().eq("parent_id", maintain.getId()));
            for (MaintainDetail maintainDetail : maintainDetailList) {
                Operate operate = maintainDetail.getOperate();
                Integer integer = (Integer) operateIntegerMap.get(operate);
                if (integer == null) {
                    integer = 1;
                } else {
                    integer++;
                }
                operateIntegerMap.put(operate, integer);
            }
        }
    }

    @Override
    public void dealFlow(String maintainId, ActivitiStatus status) {
        try {
            Maintain maintain = selectById(maintainId);
            String tableName = maintain.getTableName();
            List<MaintainDetail> maintainDetailList = maintainDetailService.selectList(new EntityWrapper<MaintainDetail>().eq("parent_id", maintainId));
            if (status.equals(ActivitiStatus.close)) {
                String collect = maintainDetailList.stream().map(detail -> DbUtils.quotedStr(detail.getPreMergeId())).collect(Collectors.joining(Constant.COMMA));
                //delete temp
                if (!StringUtils.isEmpty(collect)) {
                    masterDataService.delete(tableName + Constant.RECORD, "id in (" + collect + ")");
                }

                //delete detail
                for (MaintainDetail maintainDetail : maintainDetailList) {
                    maintainDetail.deleteById();
                }
                //delete maintain
                maintain.deleteById();
                return;
            }
            String fields = masterDataService.getTempFields(null, tableName);
            String tempFields = masterDataService.getFields(tableName + Constant.RECORD);

            String tableTempName = tableName + Constant.RECORD;
            // insert 2 std
            tableInfoMapper.tempCreate2std(tableName, fields, tableTempName, DbUtils.quotedStr(maintainId));


            // update
            List<Map<String, Object>> updeateDatas = tableInfoMapper.tempByOperate(DbUtils.quotedStr(Operate.update.name()), tempFields, tableTempName, DbUtils.quotedStr(maintainId));
            for (Map<String, Object> updeateData : updeateDatas) {
                String stdId = updeateData.get(Constant.STD_ID).toString();
                String id = updeateData.get(Constant.ID).toString();
                Result result = masterDataService.selectById(tableName, stdId);
                Object tempData = result.getData();
                String datas = JSON.toJSONString(tempData);
                JSONObject object = JSON.parseObject(datas);
                Object grid = object.get("grid");
                object = JSON.parseObject(JSON.toJSONString(grid));

                object.put(Constant.STD_ID, stdId);
                object.put(Constant.ID, id);

                datas = JSON.toJSONString(object);

                masterDataService.updateById(tableTempName, datas, id, true);

                updeateData.put(Constant.STD_ID, null);
                updeateData.put(Constant.ID, stdId);

                masterDataService.updateById(tableName, JSON.toJSONString(updeateData), stdId, true);
            }
            //delete
            List<Map<String, Object>> delDatas = tableInfoMapper.tempByOperate(DbUtils.quotedStr(Operate.delete.name()), tempFields, tableTempName, DbUtils.quotedStr(maintainId));
            for (Map<String, Object> delData : delDatas) {
                Object id = delData.get(Constant.STD_ID);
                masterDataService.deleteById(tableName, id.toString());
            }
            // update deal
            tableInfoMapper.tempDeal(tableTempName, DbUtils.quotedStr(maintainId));
        }
        catch (Exception e ){
            e.printStackTrace();
        }


    }

    @Override
    public boolean checkNowVersion(String maintainId) {
        Maintain maintain = selectById(maintainId);
        Maintain maxVersion = getNowVersion(maintain.getTableName());
        Integer compared = DbUtils.compareVersion(maxVersion, maintain);
        if (compared != null && compared == 0) {
            return true;
        } else {
            return false;
        }
    }

    @Override
    public boolean checkFirstVersion(String id) {
        Maintain maintain = selectById(id);
        Maintain order_no = selectOne(new EntityWrapper<Maintain>().eq("table_name", maintain.getTableName()).orderBy("order_no"));
        if (maintain.getId().equalsIgnoreCase(order_no.getId())) {
            return true;
        }
        return false;
    }

    @Override
    public Long getUnSubmitDataCnt(TUser user, String tableName, String whereSegment) {
        Wrapper<Maintain> versionWrapper = new EntityWrapper<Maintain>().eq("table_name", tableName).isNull("flow_id").orderBy("order_no desc");
        Maintain maintain = selectOne(versionWrapper);
        if (maintain == null) {
            return null;
        }
        String maintainId = maintain.getId();
        String tempName = tableName + Constant.RECORD;
        Long aLong = maintainMapper.countUnSubmitData(tempName, whereSegment, DbUtils.quotedStr(maintainId));
        return aLong;
    }
        @Override
    public Result getUnSubmitData(TUser user, String tableName, Integer pageNo, String pageSize, String whereSegment) {
        Wrapper<Maintain> versionWrapper = new EntityWrapper<Maintain>().eq("table_name", tableName).isNull("flow_id").orderBy("order_no desc");
        Maintain maintain = selectOne(versionWrapper);
        if (maintain == null) {
            return Result.error(CodeMsg.SELECT_ERROR_NOTFOUND);
        }
        String maintainId = maintain.getId();
        String tempName = tableName + Constant.RECORD;
        Long aLong = maintainMapper.countUnSubmitData(tempName, whereSegment, DbUtils.quotedStr(maintainId));
        Page page = new Page(aLong);
        page.setPageNo(pageNo);
        if (!StringUtils.isEmpty(pageSize)) {
            page.setPageSize(Integer.valueOf(pageSize));
        }
        String tempFields = masterDataService.getTempFields(user, tableName);
        List<Map<String, Object>> maps = maintainMapper.selectUnSubmitData(tempName, tempFields, whereSegment, DbUtils.quotedStr(maintainId), page.getLimitSQL());
        JSONObject object = new JSONObject();
        object.fluentPut("records", maps);
        object.fluentPut("maintainId", maintainId);
        object.fluentPut("total", page.getRecordCount());
        object.fluentPut("size", page.getPageSize());
        object.fluentPut("pages", page.getPageCount());
        object.fluentPut("current", page.getPageNo());
        return Result.success(object);
    }

    @Override
    public Maintain getNextMaintain(String tableName, String userId) {
        Maintain maintain = this.getMaxVersion(tableName);
        Maintain unFlowMaxVersion = this.getUnFlowMaxVersion(tableName);
        if (unFlowMaxVersion == null) {
            unFlowMaxVersion = new Maintain();
            if (maintain != null) {
                unFlowMaxVersion.setVersion(DbUtils.versionAddSub(maintain.getVersion()));
                int orderNo = maintain.getOrderNo();
                orderNo++;
                unFlowMaxVersion.setOrderNo(orderNo);
            } else {
                unFlowMaxVersion.setVersion(Constant.VERSION_Default);
                unFlowMaxVersion.setOrderNo(0);
            }

            unFlowMaxVersion.setId(DbUtils.getUUID());
            unFlowMaxVersion.setChargeId(userId);
            unFlowMaxVersion.setCreateTime(new Date());
            unFlowMaxVersion.setTableName(tableName);
        }

        Maintain nowMaintain = unFlowMaxVersion;
        if (DbUtils.compareVersion(maintain, unFlowMaxVersion) != 0) {
            nowMaintain = new Maintain();
            String maintanId = DbUtils.getUUID();
            nowMaintain.setId(maintanId);
            nowMaintain.setCreateTime(new Date());
            int orderNo = maintain.getOrderNo();
            orderNo++;
            nowMaintain.setVersion(DbUtils.versionAddSub(maintain.getVersion()));
            nowMaintain.setOrderNo(orderNo);
            nowMaintain.setTableName(tableName);
        }

        nowMaintain.setChargeId(userId);
        String maintainId = nowMaintain.getId();
        if (StringUtils.isEmpty(maintainId)) {
            nowMaintain.setId(DbUtils.getUUID());
        }
        return nowMaintain;
    }

    @Override
    public JSONObject compareField(String maintainId1, String maintainId2) {
        Maintain baseMaintain = selectById(maintainId1);
        Maintain compareMaintain = selectById(maintainId2);
        boolean pre = false;
        if (DbUtils.compareVersion(baseMaintain, compareMaintain) > 0) {
            pre = true;
        }

        List<SysField> baseFieldList = fieldService.getFieldByMaintain(maintainId1);
        List<SysField> compareFieldList = fieldService.getFieldByMaintain(maintainId2);
        List<String> baseFieldStrList = baseFieldList.stream().map(sysField -> sysField.getField()).collect(Collectors.toList());
        List<String> compareFieldStrList = compareFieldList.stream().map(sysField -> sysField.getField()).collect(Collectors.toList());

        List<String> baseExportList = baseFieldStrList.stream().filter(s -> !compareFieldStrList.contains(s)).collect(Collectors.toList());
        List<SysField> baseExprotFieldList = baseFieldList.stream().filter(sysField -> baseExportList.contains(sysField.getField())).collect(Collectors.toList());
        List<String> compareExportList = compareFieldStrList.stream().filter(s -> !baseFieldStrList.contains(s)).collect(Collectors.toList());
        List<SysField> compareExprotFieldList = compareFieldList.stream().filter(sysField -> compareExportList.contains(sysField.getField())).collect(Collectors.toList());

        List<String> collect = baseFieldStrList.stream().filter(s -> compareFieldList.contains(s)).collect(Collectors.toList());
        List<SysField> changedList = new ArrayList<>();
        for (String s : collect) {
            List<SysField> baseCol = baseFieldList.stream().filter(sysField -> sysField.getField().equalsIgnoreCase(s)).collect(Collectors.toList());
            List<SysField> compareCol = compareFieldList.stream().filter(sysField -> sysField.getField().equalsIgnoreCase(s)).collect(Collectors.toList());
            SysField baseField = baseCol.get(0);
            SysField sysField = compareCol.get(0);
            if (!baseField.equals(sysField)) {
                if (pre) {
                    //base 大
                    changedList.add(baseField);
                } else {
                    changedList.add(sysField);
                }
            }
        }
        JSONObject object = new JSONObject();
        if (pre) {
            object.fluentPut("create", baseExprotFieldList);
            object.fluentPut("delete", compareExprotFieldList);
            object.fluentPut("update", changedList);
        } else {
            object.fluentPut("create", compareExprotFieldList);
            object.fluentPut("delete", baseExprotFieldList);
            object.fluentPut("update", changedList);
        }
        return object;
    }

    @Override
    public boolean checkdMaxVersion(String maintainId) {
        Maintain maintain = selectById(maintainId);
        Maintain maxVersion = getMaxVersion(maintain.getTableName());
        Integer compared = DbUtils.compareVersion(maxVersion, maintain);
        if (compared == 0) {
            return true;
        } else {
            return false;
        }
    }

    @Override
    public Maintain getMaxVersion(String tableName) {
        Wrapper<Maintain> versionWrapper = new EntityWrapper<Maintain>().eq("table_name", tableName).orderBy("order_no desc");

        Maintain maxVersion = selectOne(versionWrapper);
        return maxVersion;
    }

    @Override
    public Maintain getUnFlowMaxVersion(String tableName) {
        Wrapper<Maintain> versionWrapper = new EntityWrapper<Maintain>().isNull("flow_id").eq("table_name", tableName).orderBy("order_no desc");

        Maintain maxVersion = selectOne(versionWrapper);
        return maxVersion;
    }

    @Override
    public Maintain getInvalidMaxVersion(String tableName) {
        Maintain result = null;
        Wrapper<Maintain> versionWrapper = new EntityWrapper<Maintain>().eq("table_name", tableName).orderBy("order_no desc");

        List<Maintain> maintainList = selectList(versionWrapper);

        for (Maintain maintain : maintainList) {
            String flowId = maintain.getFlowId();
            if (StringUtils.isEmpty(flowId)) {
                result = maintain;
            } else {
                Flows flows = flowsService.selectById(flowId);
                if (flows == null) {
                    continue;
                }
                if (!flows.getStatus().equals(ActivitiStatus.open) && !flows.getStatus().equals(ActivitiStatus.close)) {
                    result = maintain;
                }
            }

        }
        return result;
    }

    @Override
    public Long getInvalidVerionDataCnt(TUser user, String tableName, String where) {
        Maintain invalidVersion = getInvalidMaxVersion(tableName);
        if (invalidVersion == null) {
            return null;
        }
        String tableTempName = tableName + Constant.RECORD;
        String tempFields = masterDataService.getTempFields(user, tableName);
        Long count = maintainMapper.countInvalidVersionData(tableTempName, where, invalidVersion.getOrderNo());
        return count;
    }
    @Override
    public Result getInvalidVerionData(TUser user, String tableName, String where, Integer pageNo, Integer pageSize) {
        Maintain invalidVersion = getInvalidMaxVersion(tableName);
        if (invalidVersion == null) {
            return Result.success(null);
        }
        String tableTempName = tableName + Constant.RECORD;
        String tempFields = masterDataService.getTempFields(user, tableName);
        Long count = maintainMapper.countInvalidVersionData(tableTempName, where, invalidVersion.getOrderNo());
        Page page = new Page(count);
        page.setPageNo(pageNo);
        if (pageSize != null) {
            page.setPageSize(pageSize);
        }
        List<Map<String, Object>> maps = maintainMapper.selectInvalidVersionData(tableTempName, tempFields, where, invalidVersion.getOrderNo(), page.getLimitSQL());
        JSONObject resultObj = new JSONObject();
        JSONObject object = new JSONObject();
        object.fluentPut("record", maps);
        object.fluentPut("total", page.getRecordCount());
        object.fluentPut("size", page.getPageSize());
        object.fluentPut("pages", page.getPageCount());
        object.fluentPut("current", page.getPageNo());
        resultObj.fluentPut("grid", object);
        return Result.success(resultObj);
    }

    @Override
    public Maintain getNowVersion(String tableName) {
        Wrapper<Maintain> versionWrapper = new EntityWrapper<Maintain>().eq("table_name", tableName).isNotNull("flow_id").orderBy("order_no desc");

        List<Maintain> maintains = selectList(versionWrapper);
        for (Maintain maintain : maintains) {
            Flows flows = flowsService.selectById(maintain.getFlowId());
            if (flows == null) {
                continue;
            }
            ActivitiStatus status = flows.getStatus();
            if (status.equals(ActivitiStatus.open)) {
                return maintain;
            }
        }
        return null;
        //return selectOne(new EntityWrapper<Maintain>().eq("table_name", tableName).orderBy("version desc"));
    }


    @Override
    public Maintain getMaintainFromVersion(String tableName, String verison) {
        Wrapper<Maintain> versionWrapper = new EntityWrapper<Maintain>().eq("version", verison).eq("table_name", tableName);
        Maintain maxVersion = selectOne(versionWrapper);
        return maxVersion;
    }


    @Override
    public List<Map<String, Object>> selectVersionOperatorByType(String tableTempName, String maintaInId, Operate operate) {
        return maintainMapper.selectVersionOperatorByType(tableTempName, Constant.WHERE_DEFAULT, maintaInId, operate.name());
    }


    @Override
    public long countVersionOperatorByType(String tableTempName, String filterSegment, String maintaInId, Operate operate) {
        return maintainMapper.countVersionOperatorByType(tableTempName, filterSegment, maintaInId, operate.name());
    }


    @Override
    public List<Map<String, Object>> selectVersionOperatorByTypeByPage(String tableTempName, String maintaInId, Operate operate, String limit) {
        return maintainMapper.selectVersionOperatorByTypeByPage(tableTempName, Constant.WHERE_DEFAULT, maintaInId, operate.name(), limit);
    }


    @Override
    public List<String> getCompareVersionMaintains(Maintain unFlowMaxVersion, Maintain maintainFromVersion) {
        Integer compare = DbUtils.compareVersion(unFlowMaxVersion, maintainFromVersion);
        ArrayList<String> ids = new ArrayList<>();
        if (compare > 0) {
            getVerionMatintains(unFlowMaxVersion, maintainFromVersion, ids);
        } else if (compare == 0) {
            ids.add(unFlowMaxVersion.getId());
        } else {
            getVerionMatintains(maintainFromVersion, unFlowMaxVersion, ids);
        }
        return ids;
    }

    @Override
    public Result tempDataByVersionByFlow(TUser user, String flowId, String whereSegment, Integer pageNo, Integer pageSize) {
        Flows flows = flowsService.selectById(flowId);
        if (flows == null) {
            return Result.error(CodeMsg.SELECT_ERROR_NOTFOUND);
        }
        String businessId = flows.getBusinessId();
        Maintain maintain = selectById(businessId);
        if (maintain == null) {
            return Result.error(CodeMsg.SELECT_ERROR_NOTFOUND);
        }
        String fields = masterDataService.getTempFields(user, maintain.getTableName());
        String tableTempName = maintain.getTableName() + Constant.RECORD;
        long total = maintainMapper.countTempDataByVersionByFlow(tableTempName, flowId, whereSegment);

        Page page = new Page(total);
        if (pageNo != null) {
            page.setPageNo(pageNo);
            if (pageSize != null) {
                page.setPageSize(pageSize);
            }
        } else {
            page.setPageNo(1);
        }

        List<Map<String, Object>> maps = maintainMapper.tempDataByVersionByFlow(tableTempName, flowId, fields, whereSegment, page.getLimitSQL());

        JSONObject object = new JSONObject();

        object.fluentPut("total", page.getRecordCount());
        object.fluentPut("size", page.getPageSize());
        object.fluentPut("pages", page.getPageCount());
        object.fluentPut("current", page.getPageNo());
        object.fluentPut("record", maps);

        return Result.success(object);
    }

    @Override
    public Map<String, Object> getPreInfo(Maintain maintain, String id) {
        String maintainTableName = maintain.getTableName();
        String recordTableName = maintainTableName + Constant.RECORD;
        List<Map<String, Object>> maps = maintainDetailMapper.seleMaintainDetailByDataId(recordTableName, maintain.getId(), id);

        if (maps == null) {
            return null;
        }
        if (maps == null || maps.isEmpty()) {
            return null;
        }
        Map<String, Object> stringObjectMap = maps.get(0);
        String createTime = stringObjectMap.get("createTime").toString();
        List<SysField> fieldByMaintain = fieldService.getFieldByMaintain(maintain.getId());
        String fields = fieldByMaintain.stream().map(sysField -> sysField.getField())
                .map(s -> s.equalsIgnoreCase(Constant.ID) ? MessageFormat.format("{0} as id", Constant.STD_ID) : s)
                .collect(Collectors.joining(Constant.COMMA));

        List<Map<String, Object>> preData = maintainDetailMapper.getPreData(fields, recordTableName, id, createTime);
        if (preData == null || preData.isEmpty()) {
            return null;
        }
        Map<String, Object> result = preData.get(0);
        String maintainId = result.get("maintainId").toString();
        Maintain preMaintain = selectById(maintainId);
        if (preMaintain != null) {
            String chargeId = preMaintain.getChargeId();
            TUser userById = DbUtils.getUserById(chargeId);
            if (userById != null) {
                result.put("userName", userById.getUserName());
            }
        }
        return result;
    }


    private void getVerionMatintains(Maintain firstVersion, Maintain secondVersion, List<String> ids) {
        Integer fromNo = firstVersion.getOrderNo();
        Integer toNo = secondVersion.getOrderNo();
        for (int i = fromNo + 1; i <= toNo; i++) {
            Maintain maintain = selectOne(new EntityWrapper<Maintain>().eq("table_name", firstVersion.getTableName()).eq("order_no", i));
            ids.add(maintain.getId());
        }
    }
}