package com.highdatas.mdm.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.highdatas.mdm.entity.Maintain;
import com.highdatas.mdm.entity.SysField;
import com.highdatas.mdm.entity.TableSchemaResult;
import com.highdatas.mdm.mapper.MaintainFieldMapper;
import com.highdatas.mdm.mapper.MasterModifiedMapper;
import com.highdatas.mdm.mapper.TableInfoMapper;
import com.highdatas.mdm.pojo.ActivitiStatus;
import com.highdatas.mdm.pojo.Segment;
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.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

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

/**
 * <p>
 *  服务实现类
 * </p>
 *
 * @author kimi
 * @since 2020-03-11
 */
@Service
public class MasterModifiedServiceImpl implements IMasterModifiedService {
    @Autowired
    IMaintainService maintainService;
    @Autowired
    ISysFieldService fieldService;
    @Autowired
    MasterModifiedMapper masterModifiedMapper;
    @Autowired
    TableInfoMapper tableInfoMapper;
    @Autowired
    IMaintainFieldService maintainFieldService;
    @Autowired
    MaintainFieldMapper maintainFieldMapper;
    @Autowired
    MasterDataService masterDataService;

    public static final String master_id = "master_id";
    public static final String pre_record = "pre_record";
    public static final String table_name = "table_name";
    public static final String master_modified = "master_modified";

    @Override
    public Map<String, String> getModifiedUserById(String maintainId, String masterId) {
        return null;
    }

    @Override
    public List<Map<String, String>> getModifiedUserByIds(String maintainId, List<String> masterId) {
        return null;
    }

    @Override
    public boolean updateModifiedUserById(String maintainId, String masterId, String userId, List<String> modifiedFieldList) {
        if (StringUtils.isEmpty(maintainId)) {
            return false;
        }
        try {
            Maintain nowMaintain = maintainService.selectById(maintainId);
            List<SysField> fieldByMaintain = fieldService.getFieldByMaintain(maintainId);
            if (nowMaintain == null) {
                return false;
            }
            Map<String, String> masterModifiedMap = masterModifiedMapper.selectByTableMasterId(DbUtils.quotedStr(nowMaintain.getTableName()), DbUtils.quotedStr(masterId));
            if (masterModifiedMap == null) {
                masterModifiedMap = new HashMap<>();
                masterModifiedMap.put(table_name, nowMaintain.getTableName());
                masterModifiedMap.put(master_id, masterId);
            }
            String preRecordStr = masterModifiedMap.get(pre_record);
            JSONObject preRecordJSON = null;
            if (!StringUtils.isEmpty(preRecordStr)) {
                preRecordJSON = JSONObject.parseObject(preRecordStr);
            }else  {
                preRecordJSON = new JSONObject();
            }
            for (String field : modifiedFieldList) {
                preRecordJSON.fluentPut(field, userId);
            }
            masterModifiedMap.put(pre_record,  preRecordJSON.toJSONString());
            String id = masterModifiedMap.get(Constant.ID);
            if (StringUtils.isEmpty(id)) {
                masterModifiedMap.put(Constant.ID, DbUtils.getUUID());
                insert(masterModifiedMap);
            }else {
                updateById(masterModifiedMap);
            }
            return true;
        }
        catch (Exception e){
            e.printStackTrace();
            return false;
        }
    }

    private void insert(Map<String, String> masterModifiedMap) {
        String fields = masterModifiedMap.keySet().stream().collect(Collectors.joining(Constant.COMMA));
        String values = masterModifiedMap.values().stream().map(s -> DbUtils.quotedStr(s)).collect(Collectors.joining(Constant.COMMA));
        tableInfoMapper.insert(master_modified, fields, DbUtils.bracketStr(values));
    }

    private void updateById(Map<String, String> masterModifiedMap) {
        String id = masterModifiedMap.get(Constant.ID);
        Segment whereSegment = new Segment(Constant.ID, id);
        List<Segment> updateSgement = DbUtils.map2Segment(masterModifiedMap);
        String updateStr = updateSgement.stream().map(segment -> segment.toString()).collect(Collectors.joining(Constant.COMMA));
        tableInfoMapper.update(master_modified, updateStr, whereSegment.toString());
    }

    @Override
    @Async
    public void dealFlow(String maintainId, ActivitiStatus status) {
        try {
            Maintain maintain = maintainService.selectById(maintainId);
            if (maintain == null) {
                return;
            }
            String tableName = maintain.getTableName();
            String recordTableName = tableName + Constant.RECORD;
            List<Map<String,String>> modifiedList = masterModifiedMapper.selectByMaintainId(recordTableName, DbUtils.quotedStr(maintainId));
            switch (status) {
                case open:
                    for (Map<String, String> masterModifiedMap : modifiedList) {
                        String preJson = masterModifiedMap.get(pre_record);
                        JSONObject jsonObject = JSONObject.parseObject(preJson);
                        if (jsonObject == null){
                            continue;
                        }
                        Set<String> keySet = jsonObject.keySet();
                        HashMap<String, String> userMap = new HashMap<>();
                        for (String field : keySet) {
                            String userId = jsonObject.getString(field);
                            if (userMap.containsKey(userId)) {
                                String preFieldStr = userMap.get(userId);
                                field = preFieldStr + Constant.SEMICOLON  + field;
                            }
                            userMap.put(userId, field);
                        }
                        List<TableSchemaResult> tableField = tableInfoMapper.getTableField(master_modified);
                        List<String> existsFieldList = tableField.stream().map(TableSchemaResult::getFieldName).collect(Collectors.toList());
                        Set<String> userIdList = userMap.keySet();

                        if (!existsFieldList.containsAll(userIdList)) {
                            //新增之前不存在的用户
                            List<String> unExistsUserList = userIdList.stream().filter(s -> !existsFieldList.contains(s)).collect(Collectors.toList());
                            for (String s : unExistsUserList) {
                                //新增字段
                                maintainFieldMapper.addCloumn(master_modified, s, Constant.Text);
                            }
                        }
                        masterModifiedMap.putAll(userMap);
                        updateById(masterModifiedMap);
                    }
                    break;
                case close:
                    List<String> unUserIdList = new ArrayList<>();
                    unUserIdList.add(Constant.ID);
                    unUserIdList.add(master_id);
                    unUserIdList.add(table_name);
                    unUserIdList.add(pre_record);
                    for (Map<String, String> masterModifiedMap : modifiedList) {
                        //todo   反更新 perjson  获取当前表所有可更改的用户 之后待修改 先从本地user表中拿
                        Set<String> keySet = masterModifiedMap.keySet();
                        List<String> userIdList = keySet.stream().filter(s -> !unUserIdList.contains(s)).collect(Collectors.toList());
                        JSONObject jsonObject = new JSONObject();
                        for (String s : userIdList) {
                            String fields = masterModifiedMap.get(s);
                            if (StringUtils.isEmpty(fields)) {
                                continue;
                            }
                            String[] split = fields.split(Constant.SEMICOLON);
                            for (String field : split) {
                                jsonObject.fluentPut(field, s);
                            }
                        }
                        masterModifiedMap.put(pre_record, jsonObject.toJSONString());
                        updateById(masterModifiedMap);
                    }
                    break;
            }
        }
        catch (Exception e) {
            e.printStackTrace();
        }

    }

    @Override
    public void dealAssemble(String maintainId, String userId, boolean audit) {
        List<SysField> fieldByMaintain = fieldService.getFieldByMaintain(maintainId);
        if(fieldByMaintain == null) {
            return;
        }
        String fieldStr = fieldByMaintain.stream().map(SysField::getField).collect(Collectors.joining(Constant.SEMICOLON));
        List<TableSchemaResult> tableField = tableInfoMapper.getTableField(master_modified);
        long count = tableField.stream().map(tableSchemaResult -> tableSchemaResult.getFieldName()).filter(s -> s.equalsIgnoreCase(userId)).count();
        if (count == 0) {
            maintainFieldMapper.addCloumn(master_modified, userId, Constant.Text);
        }

        Maintain maintain = maintainService.selectById(maintainId);
        String tableName = maintain.getTableName();
        String recordTableName = tableName + Constant.RECORD;
        if (!audit) {
            masterModifiedMapper.insertUserByTableNameUserId(DbUtils.quotedStr(maintainId), DbUtils.quotedStr(tableName), recordTableName, userId, DbUtils.quotedStr(fieldStr));
        }
       else {
            JSONObject jsonObject = new JSONObject();
            for (SysField field : fieldByMaintain) {
                String oneField = field.getField();
                jsonObject.fluentPut(oneField, userId);
            }

            masterModifiedMapper.insertJsonByTableNameUserId(DbUtils.quotedStr(maintainId), DbUtils.quotedStr(tableName), recordTableName, DbUtils.quotedStr(jsonObject.toJSONString()));
        }
    }

}