/*
|
* 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.common.cache.DictCache;
|
import org.springblade.common.cache.ParamCache;
|
import org.springblade.common.cache.SysCache;
|
import org.springblade.common.cache.UserCache;
|
import org.springblade.common.enums.DictEnum;
|
import org.springblade.core.mp.support.Condition;
|
import org.springblade.core.mp.support.Query;
|
import org.springblade.core.secure.utils.AuthUtil;
|
import org.springblade.core.tool.utils.BeanUtil;
|
import org.springblade.core.tool.utils.Func;
|
import org.springblade.core.tool.utils.StringUtil;
|
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.entity.Yucpptn;
|
import org.springblade.modules.mountainrain.excel.BgrExcel;
|
import org.springblade.modules.mountainrain.excel.MgrExcel;
|
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.springblade.modules.system.entity.User;
|
import org.springblade.modules.system.excel.UserExcel;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.web.multipart.MultipartFile;
|
|
import java.io.InputStream;
|
import java.text.DecimalFormat;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Objects;
|
|
import static org.springblade.common.constant.CommonConstant.DEFAULT_PARAM_PASSWORD;
|
|
/**
|
* 服务实现类
|
*
|
* @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;//1小时
|
}
|
else {
|
return 3;//3小时
|
}
|
}
|
|
@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, Object>> 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 List<Map<String, Object>> selectAddvcd(String addvcd) {
|
return baseMapper.selectAddvcd(addvcd);
|
}
|
|
@Override
|
public int rainthree(int number, Integer gthour) {
|
if (number<=gthour){
|
return 0;//正常
|
}else if(number>gthour){
|
return 1;//准备转移
|
}
|
else {
|
return 3;//立即转移
|
}
|
}
|
|
@Override
|
public String selectCode() {
|
return baseMapper.selectCode();
|
}
|
|
@Override
|
public void soleInster(String stcd, String soilval,String stime) {
|
baseMapper.soleInster(stcd,soilval,stime);
|
}
|
|
@Override
|
public void soildel() {
|
baseMapper.soildel();
|
}
|
|
@Override
|
public int insertYuc(List<Yucpptn> yucpptnList) {
|
return baseMapper.insertYuc(yucpptnList);
|
}
|
|
@Override
|
public List<Map<String, Object>> selectYup() {
|
return baseMapper.selectYup();
|
}
|
|
@Override
|
public List<MountainrainsCVO> selectYum() {
|
return baseMapper.selectYum();
|
}
|
|
@Override
|
public List<Map<String, Object>> selctsmriver(String time,String dateEnd) {
|
return baseMapper.selctsmriver(time, dateEnd);
|
}
|
|
@Override
|
public List<Map<String, Object>> selctbgriver(String time,String dateEnd) {
|
return baseMapper.selctbgriver(time, dateEnd);
|
}
|
|
@Override
|
public List<MountainrainsCVO> MountainYi(String times, String dateEnd1, String code) {
|
return baseMapper.MountainYi(times, dateEnd1, code);
|
}
|
|
@Override
|
public List<MountainrainsCVO> MountainTw(String times, String dateEnd2, String code) {
|
return baseMapper.MountainTw(times, dateEnd2, code);
|
}
|
|
@Override
|
public List<MountainrainsCVO> MountainTr(String times, String dateEnd3, String code) {
|
return baseMapper.MountainTr(times, dateEnd3, code);
|
}
|
|
@Override
|
public List<Map<String, Object>> selecMoneYi(String times, String dateEnd1, String code) {
|
return baseMapper.selecMoneYi(times, dateEnd1, code);
|
}
|
|
@Override
|
public List<Map<String, Object>> selecMoneTw(String times, String dateEnd2, String code) {
|
return baseMapper.selecMoneTw(times, dateEnd2, code);
|
}
|
|
@Override
|
public List<Map<String, Object>> selecMoneTr(String times, String dateEnd3, String code) {
|
return baseMapper.selecMoneTr(times, dateEnd3, code);
|
}
|
|
@Override
|
public List<Map<String, Object>> selectTu() {
|
return baseMapper.selectTu();
|
}
|
|
@Override
|
public List<Map<String, Object>> selectS(String stime) {
|
return baseMapper.selectS(stime);
|
}
|
|
@Override
|
public void del() {
|
baseMapper.del();
|
}
|
|
/*
|
* 计算最大值
|
* @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;
|
}
|
}
|
}
|
|
}
|
