package com.ibeetl.admin.console.service;

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

import org.apache.poi.ss.util.CellReference;
import org.beetl.sql.core.engine.PageQuery;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import com.ibeetl.admin.console.dao.DictConsoleDao;
import com.ibeetl.admin.console.web.dto.DictExcelImportData;
import com.ibeetl.admin.core.entity.CoreDict;
import com.ibeetl.admin.core.entity.CoreUser;
import com.ibeetl.admin.core.service.CoreBaseService;
import com.ibeetl.admin.core.util.ExcelError;
import com.ibeetl.admin.core.util.PlatformException;

/** CoreDict Service */
@Service
@Transactional
public class DictConsoleService extends CoreBaseService<CoreDict> {

  @Autowired private DictConsoleDao dictDao;

  public PageQuery<CoreDict> queryByCondition(PageQuery query) {
    PageQuery ret = dictDao.queryByCondition(query);
    queryListAfter(ret.getList());
    return ret;
  }

  public void batchDelCoreDict(List<Long> ids) {
    try {
      // TODO,找到数据字典所有子类，设置删除标记
      dictDao.batchDelCoreDictByIds(ids);
    } catch (Exception e) {
      throw new PlatformException("批量删除CoreDict失败", e);
    }
  }

  public List<CoreDict> queryExcel(PageQuery<CoreUser> query) {
    // 同查询，不需要额外数据
    PageQuery ret = dictDao.queryByCondition(query);
    queryListAfter(ret.getList());
    return ret.getList();
  }
  /**
   * 参考：dict_mapping.xml
   *
   * @param list
   * @return
   */
  public void batchInsert(List<DictExcelImportData> list) {
    int dataStartRow = 2;
    final Map<Integer, DictExcelImportData> map = new HashMap<>();
    list.forEach((item) -> map.put(item.getExcelId(), item));
    // 逐个按照顺序导入
    for (DictExcelImportData item : list) {
      CoreDict dict = new CoreDict();
      dict.setName(item.getName());
      dict.setRemark(item.getRemark());
      dict.setType(item.getType());
      dict.setTypeName(item.getTypeName());
      dict.setValue(item.getValue());

      // 设置父字典
      if (item.getParentExcelId() != 0) {
        DictExcelImportData parentItem = map.get(item.getParentExcelId());
        if (parentItem == null) {
          // 硬编码，TODO,用reader缺少校验，替换手写导入
          int row = item.getExcelId() + dataStartRow;
          throwImporError(row, 5, "未找到父字典");
        }
        if (parentItem.getId() == null) {
          int row = item.getExcelId() + dataStartRow;
          throwImporError(row, 5, "父字典未被导入，请先导入父字典");
        }
        dict.setParent(parentItem.getId());
      }
      dict.setCreateTime(new Date());
      // 导入前先查找是否有此值
      CoreDict template = new CoreDict();
      template.setType(dict.getType());
      template.setValue(dict.getValue());
      CoreDict dbDict = dictDao.templateOne(template);
      if (dbDict != null) {
        int row = item.getExcelId() + dataStartRow;
        throwImporError(row, 0, "字典数据已经存在");
      }
      dictDao.insert(dict);

      item.setId(dict.getId());
      dataStartRow++;
    }
  }

  private void throwImporError(int row, int col, String msg) {
    ExcelError error = new ExcelError();
    CellReference cr = new CellReference(row, col, false, false);
    error.setCell(cr.formatAsString());
    error.setMsg(msg);
    throw new PlatformException("导入错误在:" + error.getCell() + "," + msg);
  }
}
