/*
 *      Copyright (c) 2018-2028, Chill Zhuang All rights reserved.
 *
 *  Redistribution and use in source and binary forms, with or without
 *  modification, are permitted provided that the following conditions are met:
 *
 *  Redistributions of source code must retain the above copyright notice,
 *  this list of conditions and the following disclaimer.
 *  Redistributions in binary form must reproduce the above copyright
 *  notice, this list of conditions and the following disclaimer in the
 *  documentation and/or other materials provided with the distribution.
 *  Neither the name of the dreamlu.net developer nor the names of its
 *  contributors may be used to endorse or promote products derived from
 *  this software without specific prior written permission.
 *  Author: Chill 庄骞 (smallchill@163.com)
 */
package org.springblade.modules.mountainrain.service.impl;

import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
import org.apache.poi.ss.usermodel.Cell;
import org.apache.poi.ss.usermodel.Row;
import org.apache.poi.ss.usermodel.Sheet;
import org.apache.poi.ss.usermodel.Workbook;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
import org.springblade.core.mp.support.Condition;
import org.springblade.core.mp.support.Query;
import org.springblade.modules.mountain.entity.Mountain;
import org.springblade.modules.mountain.service.IMountainService;
import org.springblade.modules.mountainrain.entity.Mountainrain;
import org.springblade.modules.mountainrain.mapper.MountainrainMapper;
import org.springblade.modules.mountainrain.service.IMountainrainService;
import org.springblade.modules.mountainrain.vo.*;
import org.springblade.modules.mountainrain.wrapper.MountainrainWrapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;

import java.io.InputStream;
import java.text.DecimalFormat;
import java.util.List;
import java.util.Map;

/**
 *  服务实现类
 *
 * @author BladeX
 * @since 2020-02-27
 */
@Service
@DS("slaves")
public class MountainrainServiceImpl extends ServiceImpl<MountainrainMapper,Mountainrain> implements  IMountainrainService {


	@Autowired
	private IMountainService iMountainService;
	@Override
	public IPage<MountainrainVO> selectMountainrainPage(IPage<MountainrainVO> page, MountainrainVO mountainrain) {
		return page.setRecords(baseMapper.selectMountainrainPage(page, mountainrain));
	}

	@Override
	public List<MountainrainsVO> selectALl(String dateBegin, String dateEnd) {
		return baseMapper.selectALl(dateBegin, dateEnd);
	}

	@Override
	public List<MountainrainsCVO> selectcInfo(String times, String dateEnd24, String dateEnd1,String dateEnd3,String dateEnd6,String timess) {
		return baseMapper.selectcInfo(times, dateEnd24, dateEnd1, dateEnd3, dateEnd6,timess);
	}

	@Override
	public List<MountainrainsCVO> selectaInfo(String times, String dateEnd24, String dateEnd1,String dateEnd3,String dateEnd6,String timess) {
		return baseMapper.selectaInfo(times, dateEnd24, dateEnd1, dateEnd3, dateEnd6,timess);
	}

	@Override
	public List<MountainrainsCVO> selectcInfos(String times, String dateEnd24, String dateEnd1, String dateEnd3, String dateEnd6,String timess) {
		return baseMapper.selectcInfos(times, dateEnd24, dateEnd1, dateEnd3, dateEnd6,timess);
	}

	@Override
	public List<MountainrainsCVO> selectcInfosdx(String times, String dateEnd24, String dateEnd1, String dateEnd3, String dateEnd6, String addvnm) {
		return baseMapper.selectcInfosdx(times, dateEnd24, dateEnd1, dateEnd3, dateEnd6, addvnm);
	}

	@Override
	public List<MountainrainsCVO> selectaInfos(String times, String dateEnd24, String dateEnd1, String dateEnd3, String dateEnd6,String timess) {
		return baseMapper.selectaInfos(times, dateEnd24, dateEnd1, dateEnd3, dateEnd6,times);
	}

	@Override
	public List<MountainrainsCVO> selectaInfosdx(String times, String dateEnd24, String dateEnd1, String dateEnd3, String dateEnd6, String addvnm) {
		return baseMapper.selectcInfosdx(times, dateEnd24, dateEnd1, dateEnd3, dateEnd6, addvnm);
	}

	@Override
	public void upLoadFile(MultipartFile file) {
		try{
		InputStream in = file.getInputStream();
			Workbook workbook = null;
			try{
				workbook = new HSSFWorkbook(in);
			}catch(Exception e){
				workbook = new XSSFWorkbook(in);
			}

			int numberOfSheets = workbook.getNumberOfSheets();
			//第一个sheet
			for (int j=0;j<numberOfSheets;j++) {
				Sheet sheet1 = workbook.getSheetAt(j);

				//有效行数
				int rowNubms = sheet1.getPhysicalNumberOfRows();
				for (int i = 3; i < rowNubms; i++) {
					Row rowi = sheet1.getRow(i);

					if (rowi == null) {
						continue;
					}
					//创建数据库表对应的实体类
					Mountain mountain = new Mountain();
					//Cell cell1 = rowi.getCell(0);
					Cell cell2 = rowi.getCell(0);//对应雨量站
					if(cell2==null || cell2.getStringCellValue()=="") {
						continue;
					}
					Cell cell3 = rowi.getCell(1);//对应雨量站编码
					Cell cell4 = rowi.getCell(2);//备选雨量站
					Cell cell5 = rowi.getCell(3);//备选雨量站编码
					Cell cell6 = rowi.getCell(4);//乡镇
					Cell cell7 = rowi.getCell(5);//行政村
					Cell cell8 = rowi.getCell(6);//村小组
					Cell cell9 = rowi.getCell(7);//东经
					Cell cell10 = rowi.getCell(8);//北纬
					Cell cell11 = rowi.getCell(9);//准备转移1小时
					Cell cell12 = rowi.getCell(10);//准备转移3小时
					Cell cell13 = rowi.getCell(11);//准备转移6小时
					Cell cell14 = rowi.getCell(12);//立即转移1小时
					Cell cell15 = rowi.getCell(13);//立即转移3小时
					Cell cell16 = rowi.getCell(14);//立即转移6小时
					Cell cell17 = rowi.getCell(15);//5年一遇
					Cell cell18 = rowi.getCell(16);//20年一遇
					Cell cell19 = rowi.getCell(17);//100年一遇
					Cell cell20 = rowi.getCell(18);//县、区


					//此处判断为null，以防get值的时候 报空指针
					DecimalFormat df = new DecimalFormat("0");
					String crainfall = (cell2 != null) ? getCellValue(cell2) : null;//对应雨量站
					String cenconding ="";//对应雨量站编码
					if(cell3.getCellType() == Cell.CELL_TYPE_NUMERIC){
						cenconding=df.format(cell3.getNumericCellValue());
					}
					else {
						cenconding = cell3.toString();
					}
					String arainfall = (cell4 != null) ? getCellValue(cell4) : null;//备选雨量站
					//String aconding = cell5.toString();//备选雨量站编码
					String aconding="";
					if(cell5.getCellType() == Cell.CELL_TYPE_NUMERIC){
						 aconding=df.format(cell5.getNumericCellValue());
					}
					else {
						 aconding = cell5.toString();
					}
					String township = (cell6 != null) ? getCellValue(cell6) : null;//乡镇
					String village = (cell7 != null) ? getCellValue(cell7) : null;//行政村
					String village_group = (cell8 != null) ? getCellValue(cell8) : null;//村小组
					String dj = (cell9 != null) ? getCellValue(cell9) : null;//东经
					String bw = (cell10 != null) ? getCellValue(cell10) : null;//北纬
					String gohour = df.format(cell11.getNumericCellValue());//准备转移1小时
					String gthour = df.format(cell12.getNumericCellValue());//准备转移3小时
					String gshour = df.format(cell13.getNumericCellValue());//准备转移6小时
					String imohour = df.format(cell14.getNumericCellValue());//立即转移6小时
					String imthour = df.format(cell15.getNumericCellValue());//立即转移6小时
					String imshour = df.format(cell16.getNumericCellValue());//立即转移6小时
					String fyear = df.format(cell17.getNumericCellValue());//5年一遇
					String tyear = df.format(cell18.getNumericCellValue());//20年一遇
					String oyear = df.format(cell19.getNumericCellValue());//100年一遇
					String county = (cell20 != null) ? getCellValue(cell20) : null;//县、区


					//填充实体类
					//mountain
					mountain.setCenconding(cenconding);
					mountain.setCrainfall(crainfall);
					mountain.setArainfall(arainfall);
					mountain.setAconding(aconding);
					mountain.setTownship(township);
					mountain.setVillage(village);
					mountain.setVillage_group(village_group);
					mountain.setDj(dj);
					mountain.setBw(bw);
					mountain.setFyear(fyear);
					mountain.setTyear(tyear);
					mountain.setOyear(oyear);
					mountain.setCounty(county);
					mountain.setGohour(Integer.parseInt(gohour));
					mountain.setGthour(Integer.parseInt(gthour));
					mountain.setGshour(Integer.parseInt(gshour));
					mountain.setImohour(Integer.parseInt(imohour));
					mountain.setImthour(Integer.parseInt(imthour));
					mountain.setImshour(Integer.parseInt(imshour));



					//使用JPA 保存到数据库中
					iMountainService.save(mountain);

					in.close();  //关闭流
				}
			}
	} catch (Exception e) {
		e.printStackTrace();
	}
}


	@Override
	public IPage<MountainrainVO> parentList(Map<String, Object> blog, Query query) {
		IPage<Mountainrain> pages = this.page(Condition.getPage(query), Condition.getQueryWrapper(blog, Mountainrain.class));
		return MountainrainWrapper.build().pageVO(pages);
	}

	@Override
	public IPage<MountainrainSSVO> selectNoticePage(IPage<MountainrainSSVO> page, MountainrainSSVO mountainrainSSVO) {
		return page.setRecords(baseMapper.selectNoticePage(page, mountainrainSSVO));
	}

	@Override
	public MountainrainSSVO selectInfo(String id) {
		return baseMapper.selectInfo(id);
	}

	@Override
	public List<MountainrainSSVO> selectNoticeList(String query) {
		return baseMapper.selectNoticeList(query);
	}

	@Override
	public List<MountainrainSSVO> queryXZ() {
		return baseMapper.queryXZ();
	}

	@Override
	public List<Map<String, Object>> queryZY() {
		return baseMapper.queryZY();
	}

	@Override
	public List<MountainrainsDPVO> queryZL() {
		return baseMapper.queryZL();
	}

	@Override
	public List<Map<String, Object>> selectMon(String begintime24,String time,String pid,String timess) {
		return baseMapper.selectMon(begintime24, time, pid,timess);
	}

	@Override
	public List<Map<String, Object>> selectMoncs(String begintime24, String time, String timess) {
		return baseMapper.selectMoncs(begintime24, time, timess);
	}

	@Override
	public List<Map<String, Object>> selectMoncss(String begintime24, String time, String timess) {
		return baseMapper.selectMoncss(begintime24, time, timess)
			;
	}

	@Override
	public String selectPId() {
		return baseMapper.selectPId();
	}

	@Override
	public String selectFd(String pid) {
		return baseMapper.selectFd(pid);
	}

	@Override
	@DS("slavey_1")
	public String selectGrid(String fd) {
		return selectGrid(fd);
	}

	@Override
	@DS("slavey_1")
	public Map<String, Integer> selectThree(String beg0, String end0, String beg1, String end1, String beg2, String end2, String beg3, String end3, String beg4, String end4, String beg5, String end5, String beg6, String end6, String beg7, String end7, String fymdh, String s2) {
		return baseMapper.selectThree(beg0, end0, beg1, end1, beg2, end2, beg3, end3, beg4, end4, beg5, end5, beg6, end6, beg7, end7, fymdh, s2);
	}

	@Override
	@DS("slavey_1")
	public Map<String, Integer> selectSix(String beg60, String end60, String beg61, String end61, String beg62, String end62, String fymdh, String s2) {
		return baseMapper.selectSix(beg60, end60, beg61, end61, beg62, end62, fymdh, s2);
	}

	@Override
	@DS("slavey_1")
	public String selectMax1(String fymdh, String begtime, String endtime, String s2) {
		return baseMapper.selectMax1(fymdh, begtime, endtime, s2);
	}

	@Override
	public List<Map<String, Object>> selectdYc(String times, String dateEnd24, String dateEnd1, String dateEnd3, String dateEnd6,String pid,String timess) {
		return baseMapper.selectdYc(times, dateEnd24, dateEnd1, dateEnd3, dateEnd6,pid,timess);
	}

	@Override
	@DS("slavey_1")
	public Map<String, Integer> selectAllmax(String beg0, String end0, String beg1, String end1, String beg2, String end2, String beg3, String end3, String beg4, String end4, String beg5, String end5, String beg6, String end6, String beg7, String end7, String beg60, String end60, String beg61, String end61, String beg62, String end62, String begtime, String endtime, String fymdh, String s2) {
		return baseMapper.selectAllmax(beg0, end0, beg1, end1, beg2, end2, beg3, end3, beg4, end4, beg5, end5, beg6, end6, beg7, end7, beg60, end60, beg61, end61, beg62, end62, begtime, endtime, fymdh, s2);
	}

	@Override
	public List<Map<String, Object>> selectdYcs(String time, String dateEnd24, String dateEnd1, String dateEnd3, String dateEnd6, String timess) {
		return baseMapper.selectdYcs(time, dateEnd24, dateEnd1, dateEnd3, dateEnd6, timess);
	}

	@Override
	public List<Map<String, Object>> selectdYcss(String time, String dateEnd24, String dateEnd1, String dateEnd3, String dateEnd6, String timess) {
		return baseMapper.selectdYcss(time, dateEnd24, dateEnd1, dateEnd3, dateEnd6, timess);
	}

	@Override
	@DS("slavey_1")
	public Integer selectCount(String beginTime, String endTime) {
		return baseMapper.selectCount(beginTime,endTime);
	}

	private String getCellValue(Cell cell){
		String value ="";
		switch (cell.getCellType()){
			case Cell.CELL_TYPE_STRING:
				value = cell.getStringCellValue();
				break;
			case  Cell.CELL_TYPE_NUMERIC:
				value = String.valueOf(cell.getNumericCellValue());
				break;
			case  Cell.CELL_TYPE_BLANK:
				value = "";
				break;
			case Cell.CELL_TYPE_BOOLEAN:
				value = String.valueOf(cell.getBooleanCellValue());
				break;
			case Cell.CELL_TYPE_ERROR:
				value = String.valueOf(cell.getErrorCellValue());
				break;
			case Cell.CELL_TYPE_FORMULA:
				value = String.valueOf(cell.getCellFormula());
				break;
		}
		return value;
	}
	@Override
	public int Max(int number,int number3,Integer gohour, Integer gthour) {
		int Max=0;
			int i1 = rainOne(number, gohour);
			int i3 = rainthree(number3, gthour);
			Max=getMax(i1,i3,0);
		return Max;
	}

	@Override
	public int rainOne(int number,Integer gohour) {
		if (number<=gohour){
			return 0;//正常
		}else  if(number>gohour){
			return  1;//准备转移
		}
		else {
			return  2;//立即转移
		}
	}

	@Override
	public List<MountainrainsCVO> Mountains(String times ,String dateEnd1, String dateEnd2, String dateEnd3, String code) {
		return baseMapper.Mountains(times, dateEnd1, dateEnd2, dateEnd3, code);
	}

	@Override
	public List<Map<String, Integer>> selecMone(String times, String dateEnd1, String dateEnd2, String dateEnd3, String code) {
		return baseMapper.selecMone(times, dateEnd1, dateEnd2, dateEnd3, code);
	}

	@Override
	public List<Map<String, Object>> selectMtwo(String time3, String time, String code) {
		return baseMapper.selectMtwo(time3,time,code);
	}

	@Override
	public int rainthree(int number, Integer gthour) {
		if (number<=gthour){
			return 0;//正常
		}else  if(number>gthour){
			return  1;//准备转移
		}
		else {
			return  2;//立即转移
		}
	}

	@Override
	public String selectCode() {
		return baseMapper.selectCode();
	}

	@Override
	public void soleInster(String stcd, String soilval) {
		baseMapper.soleInster(stcd,soilval);
	}

	@Override
	public void soildel() {
		baseMapper.soildel();
	}


	/*
	 * 计算最大值
	 * @param a
	 * @param b
	 * @param c
	 * @return
	 */
	public  int getMax(int a, int b, int c) {
		if (a > b) {
			if (a > c) {
				return a;
			} else {
				return c;
			}
		} else {
			if (b > c) {
				return b;
			} else {
				return c;
			}
		}
	}

}