/*
 *      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.floodinundation.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.modules.floodinundation.entity.floodinundation;
import org.springblade.modules.floodinundation.mapper.FloodinundationMapper;
import org.springblade.modules.floodinundation.service.IfloodinundationService;
import org.springblade.modules.floodinundation.vo.FloodinundationVO;
import org.springblade.modules.water.entity.water;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;

import java.io.InputStream;
import java.math.BigDecimal;
import java.text.DecimalFormat;
import java.text.NumberFormat;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * 服务实现类
 *
 * @author BladeX
 * @since 2020-02-27
 */
@Service
@DS("slaves")
public class FloodinundationServiceImpl extends ServiceImpl<FloodinundationMapper, floodinundation> implements IfloodinundationService {

	@Override
	public IPage<FloodinundationVO> selectfloodinundationPage(IPage<FloodinundationVO> page, FloodinundationVO floodinundationVO) {
		return baseMapper.selectfloodinundationPage(page, floodinundationVO);
	}

	@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 = 1; i < rowNubms; i++) {
					Row rowi = sheet1.getRow(i);

					if (rowi == null) {
						continue;
					}
					//创建数据库表对应的实体类
					floodinundation floodinundation = new floodinundation();
					//Cell cell1 = rowi.getCell(0);
					Cell cell0 = rowi.getCell(0);//危险期编码
					Cell cell1 = rowi.getCell(1);//行政区
					Cell cell2 = rowi.getCell(2);//乡镇
					Cell cell3 = rowi.getCell(3);//行政村
					Cell cell4 = rowi.getCell(4);//村小组
					Cell cell5 = rowi.getCell(5);//东经
					Cell cell6 = rowi.getCell(6);//北纬
					Cell cell7 = rowi.getCell(7);//成灾水位（85黄海）
					Cell cell8 = rowi.getCell(8);//河段编码
					Cell cell9 = rowi.getCell(9);//起点距
					Cell cell10 = rowi.getCell(10);//总人口
					Cell cell11 = rowi.getCell(11);//灾频率
					Cell cell12 = rowi.getCell(12);//5年一遇人口
					Cell cell13 = rowi.getCell(13);//5年一遇户数
					Cell cell14 = rowi.getCell(14);//5年一遇耕地
					Cell cell15 = rowi.getCell(15);//20年一遇耕地
					Cell cell16 = rowi.getCell(16);//20年一遇耕地
					Cell cell17 = rowi.getCell(17);//20年一遇耕地
					Cell cell18 = rowi.getCell(18);//50年一遇耕地
					Cell cell19 = rowi.getCell(19);//50年一遇耕地
					Cell cell20 = rowi.getCell(20);//50年一遇耕地


					//此处判断为null，以防get值的时候 报空指针
					DecimalFormat df = new DecimalFormat("0");
					NumberFormat nf = NumberFormat.getInstance();
					nf.setGroupingUsed(false);
					String wcode = (cell0 != null) ? getCellValue(cell0) : null;//危险期编码
					int number = FloodinundationServiceImpl.super.baseMapper.selectInfo(wcode);
					if (number==1){
						FloodinundationServiceImpl.super.baseMapper.deleteInfo(wcode);
					}
					String district = (cell1 != null) ? getCellValue(cell1) : null;//行政区
					String township = (cell2 != null) ? getCellValue(cell2) : null;//乡镇
					String village = (cell3 != null) ? getCellValue(cell3) : null;//行政村
					String village_group = (cell4 != null) ? getCellValue(cell4) : null;//村小组
					String dj = (cell5 != null) ? getCellValue(cell5) : null;//东经
					String bw = (cell6 != null) ? getCellValue(cell6) : null;//北纬
					String z = (cell7 != null) ? getCellValue(cell7) : null;//成灾水位（85黄海）
					String hcode = (cell8 != null) ? getCellValue(cell8) : null;//河段编码
					String origin = (cell9 != null) ? getCellValue(cell9) : null;//河段编码
					//String totalp = (cell10 != null) ? getCellValue(cell10) : null;//总人口
					String totalp = (cell10 != null) ? nf.format(cell10.getNumericCellValue()):null;
					//String disaster = (cell11 != null) ? getCellValue(cell11) : null;//受灾频率
					String disaster = (cell11 != null) ? getCellValue2(cell11) : null;
					//String fpopulation = (cell12 != null) ? getCellValue(cell12) : null;//5年一遇人口
					String fpopulation =(cell12 != null) ? nf.format(cell12.getNumericCellValue()):null;
					//String fhouseholds = (cell13 != null) ? getCellValue(cell13) : null;//5年一遇户数
					String fhouseholds = (cell13 != null) ? nf.format(cell13.getNumericCellValue()):null;
					//String ftill = (cell14 != null) ? getCellValue(cell14) : null;//5年一遇耕地
					String ftill = (cell14 != null) ? nf.format(cell14.getNumericCellValue()):null;
					//String tpopulation = (cell15 != null) ? getCellValue(cell15) : null;//20年一遇耕地
					String tpopulation = (cell15 != null) ? nf.format(cell15.getNumericCellValue()):null;
					//String thouseholds = (cell16 != null) ? getCellValue(cell16) : null;//20年一遇耕地
					String thouseholds = (cell16 != null) ? nf.format(cell16.getNumericCellValue()):null;
					//String ttill = (cell17 != null) ? getCellValue(cell17) : null;//20年一遇耕地
					String ttill = (cell17 != null) ?nf.format(cell17.getNumericCellValue()):null;
					//String ftpopulation = (cell18 != null) ? getCellValue(cell18) : null;//50年一遇耕地
					String ftpopulation = (cell18 != null) ?nf.format(cell18.getNumericCellValue()):null;
					//String fthouseholds = (cell19 != null) ? getCellValue(cell19) : null;//50年一遇耕地
					String fthouseholds = (cell19 != null) ?nf.format(cell19.getNumericCellValue()):null;
					//String fttill = (cell20 != null) ? getCellValue(cell20) : null;//50年一遇耕地
					String fttill = (cell20 != null) ?nf.format(cell20.getNumericCellValue()):null;


					//填充实体类
					floodinundation.setWcode(wcode);
					floodinundation.setDistrict(district);
					floodinundation.setTownship(township);
					floodinundation.setVillage(village);
					floodinundation.setVillagegroup(village_group);
					floodinundation.setDj(dj);
					floodinundation.setBw(bw);
					floodinundation.setZ(z);
					floodinundation.setHcode(hcode);
					floodinundation.setOrigin(origin);
					floodinundation.setTotalp(totalp);
					floodinundation.setDisaster(disaster);
					floodinundation.setFpopulation(fpopulation);
					floodinundation.setFhouseholds(fhouseholds);
					floodinundation.setFtill(ftill);
					floodinundation.setTpopulation(tpopulation);
					floodinundation.setThouseholds(thouseholds);
					floodinundation.setTtill(ttill);
					floodinundation.setFtpopulation(ftpopulation);
					floodinundation.setFthouseholds(fthouseholds);
					floodinundation.setFttill(fttill);

					//使用JPA 保存到数据库中
					FloodinundationServiceImpl.super.save(floodinundation);

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

	@Override
	public FloodinundationVO selectfId(String id) {
		return baseMapper.selectfId(id);
	}

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

	@Override
	public List<Map<Object, String>> selectC(int code, String times, String dateEnd) {
		return baseMapper.selectC(code, times, dateEnd);
	}

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

	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;
	}
	private String getCellValue2(Cell cell){
		String value ="";
		switch (cell.getCellType()){
			case Cell.CELL_TYPE_STRING:
				value = cell.getStringCellValue();
				break;
			case  Cell.CELL_TYPE_NUMERIC:
				NumberFormat nf = NumberFormat.getInstance();
				value = nf.format(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 Double selectSS(List<water> waters, Double z, Double ds, Double bzgc) {
		/*//根据名称查询
		List<water> watersInfo = waterService.queryList(null, log);*/
		//根据id查询
		//List<water> waters = waterService.queryList(pid, "");
		int size = waters.size();
		Double[] arr1 = new Double[size];
		int length = arr1.length;
		int length1 = arr1.length - 1;
		//根据名称查询查出预警水面线值，通过实时水位值推算出最新水位差
		Double water = bzgc;
		Double number = z;//实时水面线值
		Double numbers = ds;//淹没区起点距
		double vs = number - water;
		Double v = Double.parseDouble(String.format("%.2f", vs));
		//定义一个返回的值
		Double count = 0.0;
		Double water1;
		Double origin;
		Double sums;
		Double sum;
		//循环遍历水面线值，然后通过最新水位差进行更新
		for (int i = 0; i < size; i++) {
			water1 = Double.parseDouble(waters.get(i).getWater());
			origin = Double.parseDouble(waters.get(i).getOrigin());
			//预警水面值+差值
			sums = water1 + v;
			sum = Double.parseDouble(String.format("%.2f", sums));
			waters.get(i).setWater(sum + "");
			//把起点距存放到数组里
			arr1[i] = origin;
		}
		//循环判断淹没区起点距位置
		Double water0;
		Double water2;
		Double origin1;
		Double origin2;
		Double origins1;
		Double waters1;
		Double origins2;
		Double waters2;
		for (int j = 0; j < length; j++) {
			if (numbers <= arr1[j]) {
				water0 = Double.parseDouble(waters.get(j).getWater());
				count = water0;
				break;
			}
			//判断是不是超过数组最大值
			else if (numbers < arr1[length1]) {
				if (numbers > arr1[j+1] && numbers < arr1[j + 2]) {
					if(numbers==arr1[j+1]){
						water2 = Double.parseDouble(waters.get(j + 1).getWater());
						count = water2;
						break;
					}
					else if (numbers==arr1[j+2]){
						water2 = Double.parseDouble(waters.get(j + 2).getWater());
						count = water2;
						break;
					}
					else {
						//获取范围前的水面线值和起点距
						origin1 = Double.parseDouble(waters.get(j + 1).getOrigin());
						water1 = Double.parseDouble(waters.get(j + 1).getWater());
						//获取范围后的水面线值和起点距
						origin2 = Double.parseDouble(waters.get(j + 2).getOrigin());
						water2 = Double.parseDouble(waters.get(j + 2).getWater());
						count = algorithm(origin1, water1, origin2, water2, ds);
						break;
					}
				}
				/*//出现等于起点距的时候
				else {
					Double water2 = Double.parseDouble(waters.get(j + 2).getWater());
					count = water2;
					break;
				}*/
			}
			//出现超过最大值的时候
			else {
				origins1 = Double.parseDouble(waters.get(length1 - 1).getOrigin());
				waters1 = Double.parseDouble(waters.get(length1 - 1).getWater());
				//获取范围后的水面线值和起点距
				origins2 = Double.parseDouble(waters.get(length1).getOrigin());
				waters2 = Double.parseDouble(waters.get(length1).getWater());
				count= algorithm(origins1, waters1, origins2, waters2, ds);
				break;
			}
		}
		return count;
	}

	/**
	 * @param origin1 前一个起点距
	 * @param water1  前一个水面线
	 * @param origin2 后一个起点距
	 * @param water2  后一个水面线
	 * @param ds      淹没区起点距
	 * @return
	 */
	@Override
	public Double algorithm(Double origin1, Double water1, Double origin2, Double water2, Double ds) {
		//算X的值
		double v = water2 - water1;//水面线差
		double v1 = origin2 - origin1;//起点差
		double count = 0.0;
		if (v < 0) {
			//如果水面线差是负数就先转正数
			double abs = Math.abs(v);
			//去小数点2位数
			Double parseDouble = Double.parseDouble(String.format("%.2f", abs));
			//通过2点水面线和以及起点距，求出平均每米的差值
			double v2 = parseDouble / v1;
			//把V2的值不以科学计数法输出，保留6位有效数字
			Double s = Double.parseDouble(big2(v2));
			//通过淹没区水面线起点距，算水面线值
			double v3s = ds - origin1;
			Double v3 = Double.parseDouble(String.format("%.2f", v3s));
			//通过起点距差*每米的差
			double v4s = v3 * s;
			Double v4 = Double.parseDouble(String.format("%.2f", v4s));
			//距离第一个起点距的水面线-计算出每米的差
			count = water1 - v4;

		} else {
			//去小数点2位数
			Double parseDouble = Double.parseDouble(String.format("%.2f", v));
			//算2点水面线，起点距每米的差
			double v2 = parseDouble / v1;
			//把V2的值不以科学计数法输出，保留6位有效数字
			Double s = Double.parseDouble(big2(v2));
			//通过淹没区水面线起点距，算水面线值
			double v3s = ds - origin1;
			Double v3 = Double.parseDouble(String.format("%.2f", v3s));
			//通过起点距差*每米的差
			double v4s = v3 * s;
			Double v4 = Double.parseDouble(String.format("%.2f", v4s));
			//距离第一个起点距的水面线-计算出每米的差
			count = water1 + v4;

		}
		return count;
	}
	//把科学计数法转化成String
	private static String big2(double d) {
		BigDecimal d1 = new BigDecimal(Double.toString(d));
		BigDecimal d2 = new BigDecimal(Integer.toString(1));
		// 四舍五入,保留2位小数
		return d1.divide(d2, 5, BigDecimal.ROUND_HALF_UP).toString();
	}

}