package org.jeecg.modules.demo.hzz.shjsgc.zbgc.controller; import java.text.DateFormat; import java.util.Arrays; import java.util.List; import java.util.Map; import java.util.UUID; import java.util.stream.Collectors; import java.io.IOException; import java.io.UnsupportedEncodingException; import java.net.URLDecoder; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.jeecg.common.api.vo.Result; import org.jeecg.common.system.query.QueryGenerator; import org.jeecg.common.util.oConvertUtils; import org.jeecg.modules.demo.hzz.shjsgc.bzgc.entity.RmBzgc; import org.jeecg.modules.demo.hzz.shjsgc.bzgc.geo.service.IRmBzgcgeoService; import org.jeecg.modules.demo.hzz.shjsgc.zbgc.entity.RmZbgc; import org.jeecg.modules.demo.hzz.shjsgc.zbgc.geo.service.IRmZbgcgeoService; import org.jeecg.modules.demo.hzz.shjsgc.zbgc.service.IRmZbgcService; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import lombok.extern.slf4j.Slf4j; import org.jeecg.modules.demo.untils.geoinfo; import org.jeecgframework.poi.excel.ExcelImportUtil; import org.jeecgframework.poi.excel.def.NormalExcelConstants; import org.jeecgframework.poi.excel.entity.ExportParams; import org.jeecgframework.poi.excel.entity.ImportParams; import org.jeecgframework.poi.excel.view.JeecgEntityExcelView; import org.jeecg.common.system.base.controller.JeecgController; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; import org.springframework.web.multipart.MultipartFile; import org.springframework.web.multipart.MultipartHttpServletRequest; import org.springframework.web.servlet.ModelAndView; import com.alibaba.fastjson.JSON; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import org.jeecg.common.aspect.annotation.AutoLog; /** * @Description: 闸坝工程 * @Author: jeecg-boot * @Date: 2021-11-04 * @Version: V1.0 */ @Api(tags="闸坝工程") @RestController @RequestMapping("/hzz.shjsgc.zbgc/rmZbgc") @Slf4j public class RmZbgcController extends JeecgController { @Autowired private IRmZbgcService rmZbgcService; @Autowired private IRmZbgcgeoService rmZbgcgeoService; @Autowired private org.jeecg.modules.demo.untils.geoinfo geoinfo; /** * 分页列表查询 * * @param rmZbgc * @param pageNo * @param pageSize * @param req * @return */ @AutoLog(value = "闸坝工程-分页列表查询") @ApiOperation(value="闸坝工程-分页列表查询", notes="闸坝工程-分页列表查询") @GetMapping(value = "/list") public Result queryPageList(RmZbgc rmZbgc, @RequestParam(name="pageNo", defaultValue="1") Integer pageNo, @RequestParam(name="pageSize", defaultValue="10") Integer pageSize, HttpServletRequest req) { QueryWrapper queryWrapper = QueryGenerator.initQueryWrapper(rmZbgc, req.getParameterMap()); Page page = new Page(pageNo, pageSize); IPage pageList = rmZbgcService.page(page, queryWrapper); return Result.OK(pageList); } /** * 添加 * * @param rmZbgc * @return */ @AutoLog(value = "闸坝工程-添加") @ApiOperation(value="闸坝工程-添加", notes="闸坝工程-添加") @PostMapping(value = "/add") public Result add(@RequestBody RmZbgc rmZbgc) { rmZbgcService.save(rmZbgc); String geoinfo=null; if(rmZbgc.getJd()!=null &&rmZbgc.getWd()!=null){ generateGeom(rmZbgc); rmZbgc.setFlag(1); geoinfo = rmZbgcgeoService.getGeojson(rmZbgc.getId()); rmZbgc.setGeoinfo(geoinfo); } String id = UUID.randomUUID().toString().replace("-", ""); String szmc = rmZbgc.getSzmc(); String xzqh = rmZbgc.getXzqh(); String bzgldwmc = rmZbgc.getBzgldwmc(); String szhlmc = rmZbgc.getSzhlmc(); String gcjsqk = rmZbgc.getGcjsqk(); String xmid = rmZbgc.getId(); String spzt = rmZbgc.getSpzt(); String kgny = null; String jcny = null; if(rmZbgc.getKgny()!=null &&rmZbgc.getJcny()!=null) { kgny = DateFormat.getDateInstance().format(rmZbgc.getKgny()); jcny = DateFormat.getDateInstance().format(rmZbgc.getJcny()); } rmZbgcService.insertshxm(id,szmc,xzqh,gcjsqk,xmid,"zbgc",bzgldwmc,kgny,jcny,geoinfo,szhlmc,spzt); rmZbgcService.saveOrUpdate(rmZbgc); return Result.OK("添加成功!"); } /** * 编辑 * * @param rmZbgc * @return */ @AutoLog(value = "闸坝工程-编辑") @ApiOperation(value="闸坝工程-编辑", notes="闸坝工程-编辑") @PostMapping(value = "/edit") public Result edit(@RequestBody RmZbgc rmZbgc) { String szmc = rmZbgc.getSzmc(); String xzqh = rmZbgc.getXzqh(); String gcjsqk = rmZbgc.getGcjsqk(); String bzgldwmc = rmZbgc.getBzgldwmc(); String szhlmc = rmZbgc.getSzhlmc(); String id = rmZbgc.getId(); String spzt = rmZbgc.getSpzt(); String kgny = null; String jcny = null; if(rmZbgc.getKgny()!=null &&rmZbgc.getJcny()!=null) { kgny = DateFormat.getDateInstance().format(rmZbgc.getKgny()); jcny = DateFormat.getDateInstance().format(rmZbgc.getJcny()); } String geoinfo=null; if(rmZbgc.getJd()!=null &&rmZbgc.getWd()!=null){ updateGeom(rmZbgc); geoinfo = rmZbgcgeoService.getGeojson(rmZbgc.getId()); rmZbgc.setGeoinfo(geoinfo); } rmZbgcService.updateshxm(szmc,xzqh,gcjsqk,bzgldwmc,kgny,jcny,geoinfo,szhlmc,spzt,id); rmZbgcService.updateById(rmZbgc); return Result.OK("编辑成功!"); } /** * 通过id删除 * * @param id * @return */ @AutoLog(value = "闸坝工程-通过id删除") @ApiOperation(value="闸坝工程-通过id删除", notes="闸坝工程-通过id删除") @PostMapping(value = "/delete") public Result delete(@RequestParam(name="id",required=true) String id) { // rmZbgcgeoService.delZbgc(rmZbgcService.getById(id).getId()); rmZbgcService.deshxm(id); rmZbgcService.removeById(id); rmZbgcService.delete(id); return Result.OK("删除成功!"); } /** * 批量删除 * * @param ids * @return */ @AutoLog(value = "闸坝工程-批量删除") @ApiOperation(value="闸坝工程-批量删除", notes="闸坝工程-批量删除") @PostMapping(value = "/deleteBatch") public Result deleteBatch(@RequestParam(name="ids",required=true) String ids) { this.rmZbgcService.removeByIds(Arrays.asList(ids.split(","))); List gspIds = Arrays.asList(ids.split(",")); for(int i=0;i queryById(@RequestParam(name="id",required=true) String id) { RmZbgc rmZbgc = rmZbgcService.getById(id); if(rmZbgc==null) { return Result.error("未找到对应数据"); } return Result.OK(rmZbgc); } /** * 生成所有的flag为0的图形,然后地图生成标志flag设置为1 * * * @return */ @AutoLog(value = "") @ApiOperation(value="生成闸坝工程的图形", notes="生成闸坝工程的图形") @GetMapping(value = "/genarateGeo") public Result genarateGeo() { rmZbgcService.GenarateZbgcGeo(); return Result.OK("生成图形成功!"); } /** * 导出excel * * @param request * @param rmZbgc */ @RequestMapping(value = "/exportXls") public ModelAndView exportXls(HttpServletRequest request, RmZbgc rmZbgc) { return super.exportXls(request, rmZbgc, RmZbgc.class, "闸坝工程"); } /** * 通过excel导入数据 * * @param request * @param response * @return */ @RequestMapping(value = "/importExcel", method = RequestMethod.POST) public Result importExcel(HttpServletRequest request, HttpServletResponse response) { MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request; Map fileMap = multipartRequest.getFileMap(); for (Map.Entry entity : fileMap.entrySet()) { MultipartFile file = entity.getValue();// 获取上传文件对象 ImportParams params = new ImportParams(); params.setTitleRows(2); params.setHeadRows(1); params.setNeedSave(true); try { List list = ExcelImportUtil.importExcel(file.getInputStream(), RmZbgc.class, params); long start = System.currentTimeMillis(); rmZbgcService.saveBatch(list); for (RmZbgc page : list) { String id = UUID.randomUUID().toString().replace("-", ""); String xmmc = page.getSzmc(); String xzwz = page.getXzqh(); String xmid = page.getId(); String jsqk = page.getGcjsqk(); String gldw = page.getBzgldwmc(); String spzt = page.getSpzt(); String kgny = null; String jcny = null; if(page.getKgny()!=null &&page.getJcny()!=null) { kgny = DateFormat.getDateInstance().format(page.getKgny()); jcny = DateFormat.getDateInstance().format(page.getJcny()); } String szhl = page.getSzhlmc(); String geoinfo=null; if(page.getJd()!=null &&page.getWd()!=null){ generateGeom(page); page.setFlag(1); geoinfo = rmZbgcgeoService.getGeojson(page.getId()); page.setGeoinfo(geoinfo); } rmZbgcService.saveOrUpdate(page); rmZbgcService.insertshxm(id,xmmc,xzwz,jsqk,xmid,"zbgc",gldw,kgny,jcny,geoinfo,szhl,spzt); } return Result.ok("文件导入成功!数据行数:" + list.size()); } catch (Exception e) { log.error(e.getMessage(),e); return Result.error("文件导入失败:"+e.getMessage()); } finally { try { file.getInputStream().close(); } catch (IOException e) { e.printStackTrace(); } } } return Result.error("文件导入失败!"); } /** * 创建空间图形 */ private void generateGeom(RmZbgc RmZbgc){ Double jd = RmZbgc.getJd(); Double wd = RmZbgc.getWd(); String id = RmZbgc.getId(); if(jd==null||wd==null){ rmZbgcgeoService.addZbgc2(null,id); } if(jd>39000000 || wd>39000000){ if(jd>wd){ rmZbgcgeoService.addZbgc3("POINT("+jd+" "+wd+")",id); }else{ rmZbgcgeoService.addZbgc3("POINT("+wd+" "+jd+")",id); } }else if(jd>180 || wd>180){ if(jdwd){ rmZbgcgeoService.addZbgc2("POINT("+jd+" "+wd+")",id); }else{ rmZbgcgeoService.addZbgc2("POINT("+wd+" "+jd+")",id); } } } /** * 更新空间图形 */ private void updateGeom(RmZbgc RmZbgc){ Double jd = RmZbgc.getJd(); Double wd = RmZbgc.getWd(); String id = RmZbgc.getId(); if(jd>39000000 || wd>39000000){ if(jd>wd){ rmZbgcgeoService.updZbgc2("POINT("+jd+" "+wd+")",id); }else{ rmZbgcgeoService.updZbgc2("POINT("+wd+" "+jd+")",id); } }else if(jd>180 || wd>180){ if(jdwd){ rmZbgcgeoService.updZbgc3("POINT("+jd+" "+wd+")",id); }else{ rmZbgcgeoService.updZbgc3("POINT("+wd+" "+jd+")",id); } } } }