package com.zt.life.sync.service;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.StrUtil;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.zt.common.db.query.QueryFilter;
import com.zt.common.service.BaseService;
import com.zt.life.sync.dao.SyncConfigDao;
import com.zt.life.sync.dto.SyncConfigDto;
import com.zt.life.sync.model.SyncConfig;
import com.zt.life.sync.model.SyncConfigTables;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 *
 *
 * @author zt czx
 * @since 1.0.0 2020-07-20
 */
@Service
public class SyncConfigService extends BaseService<SyncConfigDao, SyncConfig> {
    @Autowired
    private SyncConfigTableService syncConfigTableService;

    public List<SyncConfigDto> page(QueryFilter queryFilter) {
        List<SyncConfigDto> resultList = new ArrayList<>();
        // 获取查询结果
        List<SyncConfig> syncConfigList = query(queryFilter);
        resultList = JSONArray.parseArray(JSONArray.toJSONString(syncConfigList), SyncConfigDto.class);
        // 依赖项ID集合
        List<Long> ids = new ArrayList<>();
        resultList.stream().map(SyncConfig::getOtherCond).distinct().forEach(s -> {
            if (StrUtil.isNotEmpty(s)) {
                ids.add(Long.parseLong(s));
            }
        });
        if (CollUtil.isNotEmpty(ids)) {
            // 所有ID结果
            List<SyncConfig> syncConfigIds = baseDao.selectBatchIds(ids);
            resultList.stream().forEach(s -> {
                SyncConfigDto syncConfigDto = (SyncConfigDto) s;
                for (SyncConfig ss : syncConfigIds) {
                    if (StrUtil.isNotEmpty(s.getOtherCond()) && Long.parseLong(s.getOtherCond()) == ss.getId()) {
                        syncConfigDto.setOtherCondDesc(ss.getTabledesc());
                    }
                }
            });
        }
        return resultList;
    }

    public List<SyncConfig> getList(Map<String, Object> map) {
        return baseDao.selectByMap(map);
    }

    public List<String> getTableNameList() {
        List<String> tableNameList = this.baseDao.getTableNameList();
        return tableNameList;
    }

    public void insert(SyncConfigDto syncConfigDto) {
        SyncConfig syncConfig = new SyncConfig();
        syncConfig = JSONObject.toJavaObject(JSONObject.parseObject(JSONObject.toJSONString(syncConfigDto)),
                SyncConfig.class);
        // 新增配置
        super.insert(syncConfig);
        for (SyncConfigTables syt : syncConfigDto.getSyncConfigTableList()) {
            syt.setSyncConfigId(syncConfig.getId());
            syncConfigTableService.insert(syt);
        }
    }

    public void update(SyncConfigDto syncConfigDto) {
        SyncConfig syncConfig = new SyncConfig();
        syncConfig = JSONObject.toJavaObject(JSONObject.parseObject(JSONObject.toJSONString(syncConfigDto)),
                SyncConfig.class);
        // 新增配置
        super.update(syncConfig);
        // 现有集合
        Map<String, Object> parMap = new HashMap<>();
        parMap.put("sync_config_id", syncConfig.getId());
        List<SyncConfigTables> syncConfigTables = syncConfigTableService.getList(parMap);
        System.out.println("前端提交数据");
        syncConfigDto.getSyncConfigTableList().forEach(System.out::println);
        System.out.println("数据库保存的数据");
        syncConfigTables.forEach(System.out::println);
        // 清空历史数据
        syncConfigTableService.deleteByMap(parMap);
        for (SyncConfigTables sct : syncConfigDto.getSyncConfigTableList()) {
            sct.setSyncConfigId(syncConfig.getId());
            // 保存新数据
            syncConfigTableService.insert(sct);
        }
    }
}