package com.platform.service.impl;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.annotation.Resource;

import org.apache.log4j.Logger;
import org.apache.poi.openxml4j.exceptions.InvalidFormatException;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
import org.springframework.core.io.ClassPathResource;
import org.springframework.stereotype.Service;

import com.platform.utils.BeanCopy;
import com.platform.utils.Configs;
import com.platform.utils.Constant;
import com.platform.utils.DateForm;
import com.platform.controller.ExcelController;
import com.platform.dao.IRegionalismCodeDao;
import com.platform.dao.ISystemCodeDao;
import com.platform.dao.PreDataInfoDao;
import com.platform.dao.VolumeDao;
import com.platform.entities.PagerOptions;
import com.platform.entities.PreDataInfo;
import com.platform.entities.RegionalismEntity;
import com.platform.entities.SystemEntity;
import com.platform.service.IPreDataInfoService;
import com.platform.utils.excelUtils.ExcelOperation;

@Service(value = "preDataInfoService")
public class PreDataInfoServiceImpl implements IPreDataInfoService {
	
	public static Logger log = Configs.DAILY_ROLLING_LOGGER.getLogger(PreDataInfoServiceImpl.class);
	
	@Resource(name = "preDataInfoDao")
	private PreDataInfoDao preDataInfoDao;
	
	@Resource(name = "systemCodeDao")
	private ISystemCodeDao systemCodeDao;
	
	@Resource(name = "regionalismCodeDao")
	private IRegionalismCodeDao regionalismCodeDao;

	@Override
	public List<PreDataInfo> findAll() throws Exception {
		List<PreDataInfo> result = preDataInfoDao.findAll();
		for (PreDataInfo preDataInfo : result) {
			preDataInfo.setWorkRange(new ArrayList<String>());
		}
		return result;
	}

	@Override
	public Map<String, List> importExcel(List<String> paths) throws Exception {
		Map<String, List> errmap = new HashMap<String, List>();
		List<String> errArea = new ArrayList<String>();
		List<String> errFile = new ArrayList<String>();
		// 待增加的
		List<PreDataInfo> all2Insert = new ArrayList<PreDataInfo>();
		// 待修改的
		List<PreDataInfo> all2Update = new ArrayList<PreDataInfo>();
		//excel读出的 所有
		List<PreDataInfo> all = new ArrayList<PreDataInfo>();
		//excel读出的 所有修改操作的数据
		List<PreDataInfo> list4Update = new ArrayList<PreDataInfo>();
		//excel读出的 所有新增地区操作的数据
		List<PreDataInfo> list4AddArea = new ArrayList<PreDataInfo>();
		//excel读出的 所有新增系统操作的数据
		List<PreDataInfo> list4AddSystem = new ArrayList<PreDataInfo>();
		for (String filePath : paths) {
			// file.temp 文件存在？ 存在则删除 file，且读入 file.temp
			//读取完后删除源文件（不管是否成功导入）
			XSSFWorkbook workbook = null;
			File tmpf = new File(filePath + ".temp");
			File f = new File(filePath);
			// file.temp 文件存在
			if (tmpf.exists()) {
				//删除 file
				workbook = new XSSFWorkbook(tmpf);
			}
			else {
				if (!f.exists()) {
					log.error(filePath + "  文件 不存在! ");
					errFile.add(f.getName());
					continue;
				}
				else {
					workbook = new XSSFWorkbook(f);
				}
			}
			//Excel导入
			try {
				//excel数据  --> java bean
				List<PreDataInfo> subPreData = ExcelOperation.readExcel4Update(workbook,  Constant.EXCEL_TEMPLATE_INIT_ROW, 0, PreDataInfo.class, "id", "workRange","sysCode","updateTime");
				if (null != subPreData && subPreData.size() > 0) {
					//是否是 同一个县区的 系统--是则 加入
					boolean isSameArea = true;
					String areaCode = subPreData.get(0).getAreaCode();
					for (PreDataInfo preDataInfo : subPreData) {
						if (!areaCode.equals(preDataInfo.getAreaCode())) {
							isSameArea = false;
							errArea.add(areaCode);
							break;
						}
					}
					if (isSameArea) {
						all.addAll(subPreData);
					}
				}
			} catch (IllegalArgumentException
					| IllegalAccessException | InstantiationException e) {
				e.printStackTrace();
			}
			finally{
				if (null != workbook) {
					workbook.close();
				}
			}
		}
		
		if (errFile.size() > 0) {
			errmap.put("fileUnExist",errFile);
		}
		if (errArea.size() > 0) {
			errmap.put("areaUnImport", errArea);
		}
		//根据 操作 类别 分类（修改， 新增行政区划，新增信息系统）
		if (all.size() > 0) {
			for (PreDataInfo preDataInfo : all) {
				
				switch (preDataInfo.getIsupdate()) {
					case Constant.preDataInfo_add_system:
						list4AddSystem.add(preDataInfo);
						break;
						
					case Constant.preDataInfo_add_area:
						list4AddArea.add(preDataInfo);
						break;
						
					case Constant.preDataInfo_update:
						list4Update.add(preDataInfo);
						break;
	
					default:
						break;
				}
			}
		}
		// 查系统 是否没有-（没有则在 pre_data_info添加新系统）：
		if (list4AddSystem.size() > 0) {
			this.AddSystem(list4AddSystem);
			List<String> sysNames = new ArrayList<String>(); 
			for (PreDataInfo preDataInfo : list4AddSystem) {
				sysNames.add(preDataInfo.getSysName());
			}
			List<SystemEntity> listSystem = new ArrayList<SystemEntity>();
			if (sysNames.size() > 0) {
				listSystem = systemCodeDao.findByName(sysNames);
			}
			Map<String, Object> syscodeMap = new HashMap<String, Object>();
			for (SystemEntity systemEntity : listSystem) {
				syscodeMap.put(systemEntity.getSystemName(), String.valueOf(systemEntity.getCode()));
			}
			for ( PreDataInfo systemEntity : list4AddSystem) {
				PreDataInfo systemFull = new PreDataInfo();
				BeanCopy.copyBean(systemEntity, systemFull);
				systemFull.setSysCode((int) syscodeMap.get(systemFull.getSysName()));
				systemFull.setUpdateTime(DateForm.date2StringBysecond(new Date()));
				all2Insert.add(systemFull);
			}
		}
		//TODO 去掉 已经导入的系统。。（例如 excel反复导入）
		//在 pre_data_info表中 新增 操作为（新增信息系统）的系统
		if (all2Insert.size() > 0) {
			preDataInfoDao.insertBatch(all2Insert);
		}
		// 查 地区 是否没有-（没有则添加新地区）：
		if (list4AddArea.size() > 0) {
			this.addArea(list4AddArea);
		}
		//在 pre_data_info表中 新增 操作为（新增行政区划）的系统
		List<PreDataInfo> allAreaInsert = new ArrayList<PreDataInfo>();
		List<String> sysNamesArea = new ArrayList<String>();
		for (PreDataInfo preDataInfo : list4AddArea) {
			sysNamesArea.add(preDataInfo.getSysName());
		}
		//查询系统的code。
		List<SystemEntity> listSystem = new ArrayList<SystemEntity>();
		if (sysNamesArea.size() > 0) {
			listSystem = systemCodeDao.findByName(sysNamesArea);
		}
		Map<String, Object> syscodeMap = new HashMap<String, Object>();
		for (SystemEntity systemEntity : listSystem) {
			syscodeMap.put(systemEntity.getSystemName(), String.valueOf(systemEntity.getCode()));
		}
		for (PreDataInfo preDataInfo : list4AddArea) {
			PreDataInfo areaFull = new PreDataInfo();
			BeanCopy.copyBean(preDataInfo, areaFull);
			areaFull.setSysCode((int) syscodeMap.get(areaFull.getSysName()));
			areaFull.setUpdateTime(DateForm.date2StringBysecond(new Date()));
			allAreaInsert.add(areaFull);
		}
		//TODO 去掉 已经导入的系统。。（例如 excel反复导入）
		//在 pre_data_info表中 新增 操作为（新增行政区划）的系统
		if (allAreaInsert.size() > 0) {
			preDataInfoDao.insertBatch(allAreaInsert);
		}
		
		//在 pre_data_info表中 更新 操作为 (修改) 的系统
		if (list4Update.size() > 0) {
			List<PreDataInfo> allUpdate = new ArrayList<PreDataInfo>();
			// 查询系统 code 
			for (PreDataInfo preDataInfo : list4Update) {
				sysNamesArea.add(preDataInfo.getSysName());
			}
			//查询系统的code。
			List<SystemEntity> listSystem4Update = new ArrayList<SystemEntity>();
			if (sysNamesArea.size() > 0) {
				listSystem4Update = systemCodeDao.findByName(sysNamesArea);
			}
			for (SystemEntity systemEntity : listSystem4Update) {
				syscodeMap.put(systemEntity.getSystemName(), String.valueOf(systemEntity.getCode()));
			}
			for (PreDataInfo preUpdate : list4Update) {
				PreDataInfo UpdateFull = new PreDataInfo();
				BeanCopy.copyBean(preUpdate, UpdateFull);
				UpdateFull.setSysCode((int) syscodeMap.get(UpdateFull.getSysName()));
				UpdateFull.setUpdateTime(DateForm.date2StringBysecond(new Date()));
				allUpdate.add(UpdateFull);
			}
			for (PreDataInfo preEntity : allUpdate) {
				preDataInfoDao.update(preEntity);
			}
		}
		return errmap;
	}
	
	/** 给system_info增加新系统
	 * @param list4AddSystem
	 * @return
	 * @throws Exception
	 */
	private int AddSystem(List<PreDataInfo> list4AddSystem) throws Exception {
		int insertNum = 0;
		// 查系统 是否没有-（没有则添加新系统）：
		List<String> sysNames = new ArrayList<String>(); 
		for (PreDataInfo preDataInfo : list4AddSystem) {
			sysNames.add(preDataInfo.getSysName());
		}
		//  判断-是否存在该系统
		if (sysNames.size() > 0) {
			//数据库 已存在的  系统
			List<SystemEntity> listSystem = systemCodeDao.findByName(sysNames);
			List<String> existSysNames = new ArrayList<String>(); 
			if (null != listSystem) {
				for ( SystemEntity systemEntity : listSystem) {
					existSysNames.add(systemEntity.getSystemName());
				}
				sysNames.removeAll(existSysNames);
			}
			////数据库 不存在的  系统-（添加新系统）
			if (sysNames.size() > 0) {
				systemCodeDao.insertBatch(sysNames);
				insertNum = sysNames.size();
			}
		}
		return insertNum;
	}
	
	/** 新增地区
	 * @param list4AddArea 待新增地区的列表
	 * @return
	 * @throws Exception
	 */
	private int addArea(List<PreDataInfo> list4AddArea)throws Exception {
		int insertNum = 0;
		List<String> areacodeList = new ArrayList<String>();
		Map<String,RegionalismEntity> areaMap = new HashMap<String, RegionalismEntity>();
		for (PreDataInfo preDataInfo : list4AddArea) {
			areacodeList.add(preDataInfo.getAreaCode());
			RegionalismEntity region = new RegionalismEntity();
			region.setCode(preDataInfo.getAreaCode());
			region.setCityName(preDataInfo.getCityName());
			region.setDistrictName(preDataInfo.getDistrictName());
			areaMap.put(region.getCode(), region);
		}
		List<RegionalismEntity> existEntity = regionalismCodeDao.findExistRegionalism(areacodeList);
		for (RegionalismEntity regionalismEntity : existEntity) {
			areaMap.remove(regionalismEntity.getCode());
		}
		//新增 地区
		if (areaMap.size() > 0) {
			List<RegionalismEntity> insert2Regionalism = new ArrayList<RegionalismEntity>();
			for ( String key : areaMap.keySet()) {
				insert2Regionalism.add(areaMap.get(key));
			}
			if (insert2Regionalism.size() > 0) {
				regionalismCodeDao.insertBatch(insert2Regionalism);
				insertNum = insert2Regionalism.size();
			}
		}
		return insertNum;
	}
	

	@Override
	public List<PreDataInfo> findByParam(PagerOptions op) {
		List<PreDataInfo> result = preDataInfoDao.getLimitedDataInfoEntities(op);
		return result;
	}

	@Override
	public Map<String, List> exportExcel(String path) throws Exception {
		Map<String, List> map = new HashMap<String, List>();
		List<String> errList = new ArrayList<String>();
		List<PreDataInfo> list = findAll();
//		InputStreamReader in= new InputStreamReader(Resource.class.getResourceAsStream(templateFilePath), "UTF-8");
		ClassPathResource res = new ClassPathResource(Constant.SYSTEM_INFO_EXCEL_TEMPLATE_FIEL_PATH);
		//此处 耗时太久：（原因：excel 2007 以后采用的方式不同造成的建议升级 到 poi 3.15以上）
		XSSFWorkbook workbook = null;
		XSSFWorkbook result = null;
		try {
			workbook = new XSSFWorkbook(res.getInputStream());
			result = ExcelOperation.writeExcelTemplate(workbook, Constant.EXCEL_TEMPLATE_INIT_ROW, 0, 25, list, "id", "workRange","sysCode","updateTime");
		} catch (IllegalArgumentException
				| IllegalAccessException | IOException e) {
			errList.add(e.getMessage());
		}
		finally{
			if (null != workbook) {
				workbook.close();
			}
		}
		FileOutputStream fileOut = null;
		try {
			File f = new File(path);
			f.createNewFile();
			fileOut = new FileOutputStream(f);
			result.write(fileOut);
		} catch (IOException e) {
			errList.add(e.getMessage());
		}
		finally{
			if (null != fileOut) {
				fileOut.close();
			}
		}
		if (errList.size() > 0) {
			map.put("err", errList);
		}
		return map;
	}

}