/**
 * Copyright (c) 2018-2028, Chill Zhuang 庄骞 (smallchill@163.com).
 * <p>
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 * <p>
 * http://www.apache.org/licenses/LICENSE-2.0
 * <p>
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package org.springblade.modules.water.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.water.entity.water;
import org.springblade.modules.water.mapper.WaterMapper;
import org.springblade.modules.water.service.WaterService;
import org.springblade.modules.water.vo.WaterVO;
import org.springblade.modules.water.wrapper.WaterWrapper;
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 Blade
 * @since 2019-11-07
 */
@Service
@DS("slaves")
public class WaterServiceImpl extends ServiceImpl<WaterMapper, water> implements WaterService {
	@Override
	public IPage<WaterVO> childList(Map<String, Object> dict, Long parentId, Query query) {
		dict.remove("parentId");
		IPage<water> page = this.page(Condition.getPage(query), Condition.getQueryWrapper(dict, water.class).lambda().eq(water::getParentId, parentId).orderByAsc(water::getOrigin));
		return WaterWrapper.build().pageVO(page);
	}

	@Override
	public List<water> queryList(String pid, String loc) {
		return baseMapper.queryList(pid,loc);
	}


	@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);

				String sheetName = sheet1.getSheetName();
				String temp[]=sheetName.split("-",1);

				/*//获取当前时间戳作为水面线ID
				Long waterID = new Date().getTime();
				//获取sheet名称作为水面线数据录入
				waterLine.setId(waterID);
				waterLine.setWaterline(temp[0]);
				if(temp.length >1){
					waterLine.setCjtime(temp[1]);
				}*/

				//有效行数
				int rowNubms = sheet1.getPhysicalNumberOfRows();
				for (int i = 1; i < rowNubms; i++) {
					Row rowi = sheet1.getRow(i);
					if (rowi == null) {
						continue;
					}
					//创建数据库表对应的实体类
					water water = new water();

					Cell cell1 = rowi.getCell(0);//水面线编码
					if(cell1.getCellType() == Cell.CELL_TYPE_BLANK) {
						continue;
					}
					Cell cell2 = rowi.getCell(1);//序号
					Cell cell3 = rowi.getCell(2);//位置
					Cell cell4 = rowi.getCell(3);//经度
					Cell cell5 = rowi.getCell(4);//纬度
					Cell cell6 = rowi.getCell(5);//起点距
					Cell cell7 = rowi.getCell(6);//水面线高程（黄海）

					//此处判断为null，以防get值的时候 报空指针
					DecimalFormat df = new DecimalFormat("0");
					String smxbm = (cell1 != null) ? getCellValue(cell1) : null;
					String xh = df.format(cell2.getNumericCellValue());
					int number = WaterServiceImpl.super.baseMapper.selectInfo(smxbm, xh);
					if(number==1){
						WaterServiceImpl.super.baseMapper.deleteInfo(smxbm, xh);
					}
					String wz = (cell3 != null) ? getCellValue(cell3) : null;
					String jd = (cell4 != null) ? getCellValue(cell4) : null;
					String wd = (cell5 != null) ? getCellValue(cell5) : null;
					String qdj = (cell6 != null) ? getCellValue(cell6) : null;
					String gc = (cell7 != null) ? getCellValue(cell7) : null;


					water.setParentId(smxbm);
					water.setXh(Integer.parseInt(xh));
					water.setLocation(wz);
					water.setLng(jd);
					water.setLat(wd);
					water.setOrigin(qdj);
					water.setWater(gc);

					//水面线新增
					WaterServiceImpl.super.save(water);

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

	@Override
	public int selectInfo(String pid, String num) {
		return baseMapper.selectInfo(pid, num);
	}

	@Override
	public void deleteInfo(String pid, String num) {
		baseMapper.deleteInfo(pid, num);
	}

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

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

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

	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;
	}

}