diff --git a/src/main/java/com/zhgd/xmgl/modules/weight/controller/WeighBookVehicleInfoController.java b/src/main/java/com/zhgd/xmgl/modules/weight/controller/WeighBookVehicleInfoController.java index e80d897c7..269731076 100644 --- a/src/main/java/com/zhgd/xmgl/modules/weight/controller/WeighBookVehicleInfoController.java +++ b/src/main/java/com/zhgd/xmgl/modules/weight/controller/WeighBookVehicleInfoController.java @@ -53,222 +53,211 @@ import java.util.stream.Collectors; @Slf4j @Api(tags = "WeighBookVehicleInfoController相关Api") public class WeighBookVehicleInfoController { - @Autowired - private IWeighBookVehicleInfoService weighBookVehicleInfoService; + @Autowired + private IWeighBookVehicleInfoService weighBookVehicleInfoService; - /** - * 分页列表查询 - * - * @param weighBookVehicleInfo - * @param pageNo - * @param pageSize - * @param lastAdddatetime 现场上次拉取的时间 - * @param req - * @return - */ - @ApiOperation(value = " 分页列表查询过磅预约车辆信息信息", notes = "分页列表查询过磅预约车辆信息信息", httpMethod = "GET") - @GetMapping(value = "/list") - public Result> queryPageList(WeighBookVehicleInfo weighBookVehicleInfo, @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo, @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize, String lastAdddatetime, HttpServletRequest req) { - Result> result = new Result>(); - LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper() - .eq(StringUtils.isNotBlank(weighBookVehicleInfo.getProjectSn()),WeighBookVehicleInfo::getProjectSn,weighBookVehicleInfo.getProjectSn()) - .like(StringUtils.isNotBlank(weighBookVehicleInfo.getSpecifications()),WeighBookVehicleInfo::getSpecifications,weighBookVehicleInfo.getSpecifications()) - .like(StringUtils.isNotBlank(weighBookVehicleInfo.getGoodsName()),WeighBookVehicleInfo::getGoodsName,weighBookVehicleInfo.getGoodsName()) - .like(StringUtils.isNotBlank(weighBookVehicleInfo.getLicensePlate()),WeighBookVehicleInfo::getLicensePlate,weighBookVehicleInfo.getLicensePlate()); - if (StringUtils.isNotBlank(lastAdddatetime)) { - DateTime dateTime = DateUtil.parse(lastAdddatetime); - queryWrapper.ge(WeighBookVehicleInfo::getAddDateTime, dateTime); - } - Page page = new Page(pageNo, pageSize); - IPage pageList = weighBookVehicleInfoService.page(page, queryWrapper); - result.setSuccess(true); - result.setResult(pageList); - return result; - } - - /** - * 添加 - * @param weighBookVehicleInfo - * @return - */ - @ApiOperation(value = " 添加过磅预约车辆信息信息", notes = "添加过磅预约车辆信息信息" , httpMethod="POST") - @PostMapping(value = "/add") - public Result add(@RequestBody WeighBookVehicleInfo weighBookVehicleInfo) { - Result result = new Result(); - try { - weighBookVehicleInfoService.save(weighBookVehicleInfo); - result.success("添加成功!"); - } catch (Exception e) { - e.printStackTrace(); - log.info(e.getMessage()); - result.error500("操作失败"); - } - return result; - } - - /** - * 编辑 - * @param weighBookVehicleInfo - * @return - */ - @ApiOperation(value = "编辑过磅预约车辆信息信息", notes = "编辑过磅预约车辆信息信息" , httpMethod="POST") - @PostMapping(value = "/edit") - public Result edit(@RequestBody WeighBookVehicleInfo weighBookVehicleInfo) { - Result result = new Result(); - WeighBookVehicleInfo weighBookVehicleInfoEntity = weighBookVehicleInfoService.getById(weighBookVehicleInfo.getId()); - if (weighBookVehicleInfoEntity == null) { - result.error500("未找到对应实体"); - } else { - weighBookVehicleInfoService.updateById(weighBookVehicleInfo); - result.success("修改成功!"); - } + /** + * 分页列表查询 + * + * @param weighBookVehicleInfo + * @param pageNo + * @param pageSize + * @param req + * @return + */ + @ApiOperation(value = " 分页列表查询过磅预约车辆信息信息", notes = "分页列表查询过磅预约车辆信息信息", httpMethod = "GET") + @GetMapping(value = "/list") + public Result> queryPageList(WeighBookVehicleInfo weighBookVehicleInfo, @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo, @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize, HttpServletRequest req) { + return weighBookVehicleInfoService.queryPageList(weighBookVehicleInfo, pageNo, pageSize, req); + } - return result; - } + /** + * 添加 + * + * @param weighBookVehicleInfo + * @return + */ + @ApiOperation(value = " 添加过磅预约车辆信息信息", notes = "添加过磅预约车辆信息信息", httpMethod = "POST") + @PostMapping(value = "/add") + public Result add(@RequestBody WeighBookVehicleInfo weighBookVehicleInfo) { + Result result = new Result(); + try { + weighBookVehicleInfoService.save(weighBookVehicleInfo); + result.success("添加成功!"); + } catch (Exception e) { + e.printStackTrace(); + log.info(e.getMessage()); + result.error500("操作失败"); + } + return result; + } - /** - * 通过id删除 - * - * @param id - * @return - */ - @ApiOperation(value = "删除过磅预约车辆信息信息", notes = "删除过磅预约车辆信息信息", httpMethod = "POST") - @PostMapping(value = "/delete") - public Result delete(@RequestBody String id) { - JSONObject jsonObject = JSON.parseObject(id, JSONObject.class); - id = String.valueOf(jsonObject.get("id")); - Result result = new Result(); - WeighBookVehicleInfo weighBookVehicleInfo = weighBookVehicleInfoService.getById(id); - if (weighBookVehicleInfo == null) { - result.error500("未找到对应实体"); - } else { - boolean ok = weighBookVehicleInfoService.removeById(id); - if (ok) { - result.success("删除成功!"); - } - } + /** + * 编辑 + * + * @param weighBookVehicleInfo + * @return + */ + @ApiOperation(value = "编辑过磅预约车辆信息信息", notes = "编辑过磅预约车辆信息信息", httpMethod = "POST") + @PostMapping(value = "/edit") + public Result edit(@RequestBody WeighBookVehicleInfo weighBookVehicleInfo) { + Result result = new Result(); + WeighBookVehicleInfo weighBookVehicleInfoEntity = weighBookVehicleInfoService.getById(weighBookVehicleInfo.getId()); + if (weighBookVehicleInfoEntity == null) { + result.error500("未找到对应实体"); + } else { + weighBookVehicleInfoService.updateById(weighBookVehicleInfo); + result.success("修改成功!"); + } - return result; - } + return result; + } - /** - * 批量删除 - * @param ids - * @return - */ - @ApiOperation(value = "批量删除过磅预约车辆信息信息", notes = "批量删除过磅预约车辆信息信息", httpMethod="POST") + /** + * 通过id删除 + * + * @param id + * @return + */ + @ApiOperation(value = "删除过磅预约车辆信息信息", notes = "删除过磅预约车辆信息信息", httpMethod = "POST") + @PostMapping(value = "/delete") + public Result delete(@RequestBody String id) { + JSONObject jsonObject = JSON.parseObject(id, JSONObject.class); + id = String.valueOf(jsonObject.get("id")); + Result result = new Result(); + WeighBookVehicleInfo weighBookVehicleInfo = weighBookVehicleInfoService.getById(id); + if (weighBookVehicleInfo == null) { + result.error500("未找到对应实体"); + } else { + boolean ok = weighBookVehicleInfoService.removeById(id); + if (ok) { + result.success("删除成功!"); + } + } + + return result; + } + + /** + * 批量删除 + * + * @param ids + * @return + */ + @ApiOperation(value = "批量删除过磅预约车辆信息信息", notes = "批量删除过磅预约车辆信息信息", httpMethod = "POST") @ApiImplicitParam(name = "id", value = "过磅预约车辆信息ID字符串", paramType = "query", required = true, dataType = "String") - @PostMapping(value = "/deleteBatch") - public Result deleteBatch(@RequestParam(name="ids",required=true) String ids) { - Result result = new Result(); - if(ids==null || "".equals(ids.trim())) { - result.error500("参数不识别!"); - }else { - this.weighBookVehicleInfoService.removeByIds(Arrays.asList(ids.split(","))); - result.success("删除成功!"); - } - return result; - } - - /** - * 通过id查询 - * @param id - * @return - */ - @ApiOperation(value = "通过id查询过磅预约车辆信息信息", notes = "通过id查询过磅预约车辆信息信息" , httpMethod="GET") - @ApiImplicitParam(name = "id", value = "过磅预约车辆信息ID", paramType = "query", required = true, dataType = "Integer") - @GetMapping(value = "/queryById") - public Result queryById(@RequestParam(name="id",required=true) String id) { - Result result = new Result(); - WeighBookVehicleInfo weighBookVehicleInfo = weighBookVehicleInfoService.getById(id); - if(weighBookVehicleInfo==null) { - result.error500("未找到对应实体"); - }else { - result.setResult(weighBookVehicleInfo); - result.setSuccess(true); - } - return result; - } + @PostMapping(value = "/deleteBatch") + public Result deleteBatch(@RequestParam(name = "ids", required = true) String ids) { + Result result = new Result(); + if (ids == null || "".equals(ids.trim())) { + result.error500("参数不识别!"); + } else { + this.weighBookVehicleInfoService.removeByIds(Arrays.asList(ids.split(","))); + result.success("删除成功!"); + } + return result; + } - /** - * 导出excel - * - * @param request - * @param response - */ - @ApiOperation(value = "导出excel过磅预约车辆信息信息", notes = "导出excel过磅预约车辆信息信息" , httpMethod="POST") - @RequestMapping(value = "/exportXls") - public ModelAndView exportXls(HttpServletRequest request, HttpServletResponse response) { - // Step.1 组装查询条件 - QueryWrapper queryWrapper = null; - try { - String paramsStr = request.getParameter("paramsStr"); - if (oConvertUtils.isNotEmpty(paramsStr)) { - String deString = URLDecoder.decode(paramsStr, "UTF-8"); - WeighBookVehicleInfo weighBookVehicleInfo = JSON.parseObject(deString, WeighBookVehicleInfo.class); - queryWrapper = QueryGenerator.initQueryWrapper(weighBookVehicleInfo, request.getParameterMap()); - } - } catch (UnsupportedEncodingException e) { - e.printStackTrace(); - } + /** + * 通过id查询 + * + * @param id + * @return + */ + @ApiOperation(value = "通过id查询过磅预约车辆信息信息", notes = "通过id查询过磅预约车辆信息信息", httpMethod = "GET") + @ApiImplicitParam(name = "id", value = "过磅预约车辆信息ID", paramType = "query", required = true, dataType = "Integer") + @GetMapping(value = "/queryById") + public Result queryById(@RequestParam(name = "id", required = true) String id) { + Result result = new Result(); + WeighBookVehicleInfo weighBookVehicleInfo = weighBookVehicleInfoService.getById(id); + if (weighBookVehicleInfo == null) { + result.error500("未找到对应实体"); + } else { + result.setResult(weighBookVehicleInfo); + result.setSuccess(true); + } + return result; + } - //Step.2 AutoPoi 导出Excel - ModelAndView mv = new ModelAndView(new JeecgEntityExcelView()); - List pageList = weighBookVehicleInfoService.list(queryWrapper); - //导出文件名称 - mv.addObject(NormalExcelConstants.FILE_NAME, "过磅预约车辆信息列表"); - mv.addObject(NormalExcelConstants.CLASS, WeighBookVehicleInfo.class); - mv.addObject(NormalExcelConstants.PARAMS, new ExportParams("过磅预约车辆信息列表数据", "导出人:Jeecg", "导出信息")); - mv.addObject(NormalExcelConstants.DATA_LIST, pageList); - return mv; - } + /** + * 导出excel + * + * @param request + * @param response + */ + @ApiOperation(value = "导出excel过磅预约车辆信息信息", notes = "导出excel过磅预约车辆信息信息", httpMethod = "POST") + @RequestMapping(value = "/exportXls") + public ModelAndView exportXls(HttpServletRequest request, HttpServletResponse response) { + // Step.1 组装查询条件 + QueryWrapper queryWrapper = null; + try { + String paramsStr = request.getParameter("paramsStr"); + if (oConvertUtils.isNotEmpty(paramsStr)) { + String deString = URLDecoder.decode(paramsStr, "UTF-8"); + WeighBookVehicleInfo weighBookVehicleInfo = JSON.parseObject(deString, WeighBookVehicleInfo.class); + queryWrapper = QueryGenerator.initQueryWrapper(weighBookVehicleInfo, request.getParameterMap()); + } + } catch (UnsupportedEncodingException e) { + e.printStackTrace(); + } - /** - * 通过excel导入数据 - * - * @param request - * @param response - * @return - */ - @ApiOperation(value = "通过excel导入过磅预约车辆信息信息", notes = "通过excel导入过磅预约车辆信息信息", httpMethod="POST") - @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 listWeighBookVehicleInfos = ExcelImportUtil.importExcel(file.getInputStream(), WeighBookVehicleInfo.class, params); - for (WeighBookVehicleInfo weighBookVehicleInfoExcel : listWeighBookVehicleInfos) { - weighBookVehicleInfoService.save(weighBookVehicleInfoExcel); - } - return Result.ok("文件导入成功!数据行数:" + listWeighBookVehicleInfos.size()); - } catch (Exception e) { - log.error(e.getMessage()); - return Result.error("文件导入失败!"); - } finally { - try { - file.getInputStream().close(); - } catch (IOException e) { - e.printStackTrace(); - } - } - } - return Result.ok("文件导入失败!"); - } + //Step.2 AutoPoi 导出Excel + ModelAndView mv = new ModelAndView(new JeecgEntityExcelView()); + List pageList = weighBookVehicleInfoService.list(queryWrapper); + //导出文件名称 + mv.addObject(NormalExcelConstants.FILE_NAME, "过磅预约车辆信息列表"); + mv.addObject(NormalExcelConstants.CLASS, WeighBookVehicleInfo.class); + mv.addObject(NormalExcelConstants.PARAMS, new ExportParams("过磅预约车辆信息列表数据", "导出人:Jeecg", "导出信息")); + mv.addObject(NormalExcelConstants.DATA_LIST, pageList); + return mv; + } - /** - * 获取所有过磅类型列表 - * - * @return - */ - @GetMapping("/weighingType") - @ApiOperation(value = "获取所有过磅类型列表", notes = "获取所有过磅类型列表", httpMethod = "GET") - public Result> getWeighingTypeEnums() { - return Result.success(Arrays.stream(WeighingTypeEnum.values()).collect(Collectors.toList())); - } + /** + * 通过excel导入数据 + * + * @param request + * @param response + * @return + */ + @ApiOperation(value = "通过excel导入过磅预约车辆信息信息", notes = "通过excel导入过磅预约车辆信息信息", httpMethod = "POST") + @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 listWeighBookVehicleInfos = ExcelImportUtil.importExcel(file.getInputStream(), WeighBookVehicleInfo.class, params); + for (WeighBookVehicleInfo weighBookVehicleInfoExcel : listWeighBookVehicleInfos) { + weighBookVehicleInfoService.save(weighBookVehicleInfoExcel); + } + return Result.ok("文件导入成功!数据行数:" + listWeighBookVehicleInfos.size()); + } catch (Exception e) { + log.error(e.getMessage()); + return Result.error("文件导入失败!"); + } finally { + try { + file.getInputStream().close(); + } catch (IOException e) { + e.printStackTrace(); + } + } + } + return Result.ok("文件导入失败!"); + } + + /** + * 获取所有过磅类型列表 + * + * @return + */ + @GetMapping("/weighingType") + @ApiOperation(value = "获取所有过磅类型列表", notes = "获取所有过磅类型列表", httpMethod = "GET") + public Result> getWeighingTypeEnums() { + return Result.success(Arrays.stream(WeighingTypeEnum.values()).collect(Collectors.toList())); + } } diff --git a/src/main/java/com/zhgd/xmgl/modules/weight/controller/WeighInfoController.java b/src/main/java/com/zhgd/xmgl/modules/weight/controller/WeighInfoController.java index 51a542beb..a5259b90c 100644 --- a/src/main/java/com/zhgd/xmgl/modules/weight/controller/WeighInfoController.java +++ b/src/main/java/com/zhgd/xmgl/modules/weight/controller/WeighInfoController.java @@ -1,47 +1,43 @@ package com.zhgd.xmgl.modules.weight.controller; +import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; -import io.swagger.annotations.Api; -import io.swagger.annotations.ApiImplicitParam; -import io.swagger.annotations.ApiOperation; - -import java.util.Arrays; -import java.util.List; -import java.util.Map; -import java.io.IOException; -import java.io.UnsupportedEncodingException; -import java.net.URLDecoder; -import javax.servlet.http.HttpServletRequest; -import javax.servlet.http.HttpServletResponse; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; import com.zhgd.jeecg.common.api.vo.Result; import com.zhgd.jeecg.common.system.query.QueryGenerator; import com.zhgd.jeecg.common.util.oConvertUtils; import com.zhgd.xmgl.modules.weight.entity.WeighInfo; import com.zhgd.xmgl.modules.weight.service.IWeighInfoService; - -import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; -import com.baomidou.mybatisplus.core.metadata.IPage; -import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiImplicitParam; +import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; - 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.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 javax.servlet.http.HttpServletRequest; +import javax.servlet.http.HttpServletResponse; +import java.io.IOException; +import java.io.UnsupportedEncodingException; +import java.net.URLDecoder; +import java.util.Arrays; +import java.util.List; +import java.util.Map; + +/** * @Title: Controller * @Description: 称重记录表 * @author: pds - * @date: 2023-03-21 + * @date: 2023-03-21 * @version: V1.0 */ @RestController @@ -49,198 +45,204 @@ import com.alibaba.fastjson.JSON; @Slf4j @Api(tags = "WeighInfoController相关Api") public class WeighInfoController { - @Autowired - private IWeighInfoService weighInfoService; - - /** - * 分页列表查询 - * @param weighInfo - * @param pageNo - * @param pageSize - * @param req - * @return - */ - @ApiOperation(value = " 分页列表查询称重记录表信息", notes = "分页列表查询称重记录表信息", httpMethod="GET") - @GetMapping(value = "/list") - public Result> queryPageList(WeighInfo weighInfo, - @RequestParam(name="pageNo", defaultValue="1") Integer pageNo, - @RequestParam(name="pageSize", defaultValue="10") Integer pageSize, - HttpServletRequest req) { - return weighInfoService.queryPageList(weighInfo, pageNo, pageSize, req); - } - - /** - * 添加 - * @param weighInfo - * @return - */ - @ApiOperation(value = " 添加称重记录表信息", notes = "添加称重记录表信息" , httpMethod="POST") - @PostMapping(value = "/add") - public Result add(@RequestBody WeighInfo weighInfo) { - Result result = new Result(); - try { - weighInfoService.save(weighInfo); - result.success("添加成功!"); - } catch (Exception e) { - e.printStackTrace(); - log.info(e.getMessage()); - result.error500("操作失败"); - } - return result; - } - - /** - * 编辑 - * @param weighInfo - * @return - */ - @ApiOperation(value = "编辑称重记录表信息", notes = "编辑称重记录表信息" , httpMethod="POST") - @PostMapping(value = "/edit") - public Result edit(@RequestBody WeighInfo weighInfo) { - Result result = new Result(); - WeighInfo weighInfoEntity = weighInfoService.getById(weighInfo.getId()); - if(weighInfoEntity==null) { - result.error500("未找到对应实体"); - }else { - weighInfoService.updateById(weighInfo); - result.success("修改成功!"); - } - - return result; - } - - /** - * 通过id删除 - * @param id - * @return - */ - @ApiOperation(value = "删除称重记录表信息", notes = "删除称重记录表信息" , httpMethod="POST") - @PostMapping(value = "/delete") - public Result delete(@RequestBody String id) { - JSONObject jsonObject = JSON.parseObject(id, JSONObject.class); - id = String.valueOf(jsonObject.get("id")); - Result result = new Result(); - WeighInfo weighInfo = weighInfoService.getById(id); - if(weighInfo==null) { - result.error500("未找到对应实体"); - }else { - boolean ok = weighInfoService.removeById(id); - if(ok) { - result.success("删除成功!"); - } - } - - return result; - } - - /** - * 批量删除 - * @param ids - * @return - */ - @ApiOperation(value = "批量删除称重记录表信息", notes = "批量删除称重记录表信息", httpMethod="POST") + @Autowired + private IWeighInfoService weighInfoService; + + /** + * 分页列表查询 + * + * @param weighInfo + * @param pageNo + * @param pageSize + * @param req + * @return + */ + @ApiOperation(value = " 分页列表查询称重记录表信息", notes = "分页列表查询称重记录表信息", httpMethod = "GET") + @GetMapping(value = "/list") + public Result> queryPageList(WeighInfo weighInfo, + @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo, + @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize, + HttpServletRequest req) { + return weighInfoService.queryPageList(weighInfo, pageNo, pageSize, req); + } + + /** + * 现场端添加称重记录表信息 + * + * @param weighInfo + * @return + */ + @ApiOperation(value = " 添加称重记录表信息", notes = "添加称重记录表信息", httpMethod = "POST") + @PostMapping(value = "/add") + public Result add(@RequestBody WeighInfo weighInfo) { + Result result = new Result(); + try { + weighInfoService.save(weighInfo); + result.success("添加成功!"); + } catch (Exception e) { + e.printStackTrace(); + log.info(e.getMessage()); + result.error500("操作失败"); + } + return result; + } + + /** + * 编辑 + * + * @param weighInfo + * @return + */ + @ApiOperation(value = "编辑称重记录表信息", notes = "编辑称重记录表信息", httpMethod = "POST") + @PostMapping(value = "/edit") + public Result edit(@RequestBody WeighInfo weighInfo) { + Result result = new Result(); + WeighInfo weighInfoEntity = weighInfoService.getById(weighInfo.getId()); + if (weighInfoEntity == null) { + result.error500("未找到对应实体"); + } else { + weighInfoService.updateById(weighInfo); + result.success("修改成功!"); + } + + return result; + } + + /** + * 通过id删除 + * + * @param id + * @return + */ + @ApiOperation(value = "删除称重记录表信息", notes = "删除称重记录表信息", httpMethod = "POST") + @PostMapping(value = "/delete") + public Result delete(@RequestBody String id) { + JSONObject jsonObject = JSON.parseObject(id, JSONObject.class); + id = String.valueOf(jsonObject.get("id")); + Result result = new Result(); + WeighInfo weighInfo = weighInfoService.getById(id); + if (weighInfo == null) { + result.error500("未找到对应实体"); + } else { + boolean ok = weighInfoService.removeById(id); + if (ok) { + result.success("删除成功!"); + } + } + + return result; + } + + /** + * 批量删除 + * + * @param ids + * @return + */ + @ApiOperation(value = "批量删除称重记录表信息", notes = "批量删除称重记录表信息", httpMethod = "POST") @ApiImplicitParam(name = "id", value = "称重记录表ID字符串", paramType = "query", required = true, dataType = "String") - @PostMapping(value = "/deleteBatch") - public Result deleteBatch(@RequestParam(name="ids",required=true) String ids) { - Result result = new Result(); - if(ids==null || "".equals(ids.trim())) { - result.error500("参数不识别!"); - }else { - this.weighInfoService.removeByIds(Arrays.asList(ids.split(","))); - result.success("删除成功!"); - } - return result; - } - - /** - * 通过id查询 - * @param id - * @return - */ - @ApiOperation(value = "通过id查询称重记录表信息", notes = "通过id查询称重记录表信息" , httpMethod="GET") - @ApiImplicitParam(name = "id", value = "称重记录表ID", paramType = "query", required = true, dataType = "Integer") - @GetMapping(value = "/queryById") - public Result queryById(@RequestParam(name="id",required=true) String id) { - Result result = new Result(); - WeighInfo weighInfo = weighInfoService.getById(id); - if(weighInfo==null) { - result.error500("未找到对应实体"); - }else { - result.setResult(weighInfo); - result.setSuccess(true); - } - return result; - } + @PostMapping(value = "/deleteBatch") + public Result deleteBatch(@RequestParam(name = "ids", required = true) String ids) { + Result result = new Result(); + if (ids == null || "".equals(ids.trim())) { + result.error500("参数不识别!"); + } else { + this.weighInfoService.removeByIds(Arrays.asList(ids.split(","))); + result.success("删除成功!"); + } + return result; + } - /** - * 导出excel - * - * @param request - * @param response - */ - @ApiOperation(value = "导出excel称重记录表信息", notes = "导出excel称重记录表信息" , httpMethod="POST") - @RequestMapping(value = "/exportXls") - public ModelAndView exportXls(HttpServletRequest request, HttpServletResponse response) { - // Step.1 组装查询条件 - QueryWrapper queryWrapper = null; - try { - String paramsStr = request.getParameter("paramsStr"); - if (oConvertUtils.isNotEmpty(paramsStr)) { - String deString = URLDecoder.decode(paramsStr, "UTF-8"); - WeighInfo weighInfo = JSON.parseObject(deString, WeighInfo.class); - queryWrapper = QueryGenerator.initQueryWrapper(weighInfo, request.getParameterMap()); - } - } catch (UnsupportedEncodingException e) { - e.printStackTrace(); - } + /** + * 通过id查询 + * + * @param id + * @return + */ + @ApiOperation(value = "通过id查询称重记录表信息", notes = "通过id查询称重记录表信息", httpMethod = "GET") + @ApiImplicitParam(name = "id", value = "称重记录表ID", paramType = "query", required = true, dataType = "Integer") + @GetMapping(value = "/queryById") + public Result queryById(@RequestParam(name = "id", required = true) String id) { + Result result = new Result(); + WeighInfo weighInfo = weighInfoService.getById(id); + if (weighInfo == null) { + result.error500("未找到对应实体"); + } else { + result.setResult(weighInfo); + result.setSuccess(true); + } + return result; + } - //Step.2 AutoPoi 导出Excel - ModelAndView mv = new ModelAndView(new JeecgEntityExcelView()); - List pageList = weighInfoService.list(queryWrapper); - //导出文件名称 - mv.addObject(NormalExcelConstants.FILE_NAME, "称重记录表列表"); - mv.addObject(NormalExcelConstants.CLASS, WeighInfo.class); - mv.addObject(NormalExcelConstants.PARAMS, new ExportParams("称重记录表列表数据", "导出人:Jeecg", "导出信息")); - mv.addObject(NormalExcelConstants.DATA_LIST, pageList); - return mv; - } + /** + * 导出excel + * + * @param request + * @param response + */ + @ApiOperation(value = "导出excel称重记录表信息", notes = "导出excel称重记录表信息", httpMethod = "POST") + @RequestMapping(value = "/exportXls") + public ModelAndView exportXls(HttpServletRequest request, HttpServletResponse response) { + // Step.1 组装查询条件 + QueryWrapper queryWrapper = null; + try { + String paramsStr = request.getParameter("paramsStr"); + if (oConvertUtils.isNotEmpty(paramsStr)) { + String deString = URLDecoder.decode(paramsStr, "UTF-8"); + WeighInfo weighInfo = JSON.parseObject(deString, WeighInfo.class); + queryWrapper = QueryGenerator.initQueryWrapper(weighInfo, request.getParameterMap()); + } + } catch (UnsupportedEncodingException e) { + e.printStackTrace(); + } - /** - * 通过excel导入数据 - * - * @param request - * @param response - * @return - */ - @ApiOperation(value = "通过excel导入称重记录表信息", notes = "通过excel导入称重记录表信息", httpMethod="POST") - @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 listWeighInfos = ExcelImportUtil.importExcel(file.getInputStream(), WeighInfo.class, params); - for (WeighInfo weighInfoExcel : listWeighInfos) { - weighInfoService.save(weighInfoExcel); - } - return Result.ok("文件导入成功!数据行数:" + listWeighInfos.size()); - } catch (Exception e) { - log.error(e.getMessage()); - return Result.error("文件导入失败!"); - } finally { - try { - file.getInputStream().close(); - } catch (IOException e) { - e.printStackTrace(); - } - } - } - return Result.ok("文件导入失败!"); - } + //Step.2 AutoPoi 导出Excel + ModelAndView mv = new ModelAndView(new JeecgEntityExcelView()); + List pageList = weighInfoService.list(queryWrapper); + //导出文件名称 + mv.addObject(NormalExcelConstants.FILE_NAME, "称重记录表列表"); + mv.addObject(NormalExcelConstants.CLASS, WeighInfo.class); + mv.addObject(NormalExcelConstants.PARAMS, new ExportParams("称重记录表列表数据", "导出人:Jeecg", "导出信息")); + mv.addObject(NormalExcelConstants.DATA_LIST, pageList); + return mv; + } + + /** + * 通过excel导入数据 + * + * @param request + * @param response + * @return + */ + @ApiOperation(value = "通过excel导入称重记录表信息", notes = "通过excel导入称重记录表信息", httpMethod = "POST") + @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 listWeighInfos = ExcelImportUtil.importExcel(file.getInputStream(), WeighInfo.class, params); + for (WeighInfo weighInfoExcel : listWeighInfos) { + weighInfoService.save(weighInfoExcel); + } + return Result.ok("文件导入成功!数据行数:" + listWeighInfos.size()); + } catch (Exception e) { + log.error(e.getMessage()); + return Result.error("文件导入失败!"); + } finally { + try { + file.getInputStream().close(); + } catch (IOException e) { + e.printStackTrace(); + } + } + } + return Result.ok("文件导入失败!"); + } } diff --git a/src/main/java/com/zhgd/xmgl/modules/weight/controller/WeighPicController.java b/src/main/java/com/zhgd/xmgl/modules/weight/controller/WeighPicController.java index f67bb2d70..ced57d4ca 100644 --- a/src/main/java/com/zhgd/xmgl/modules/weight/controller/WeighPicController.java +++ b/src/main/java/com/zhgd/xmgl/modules/weight/controller/WeighPicController.java @@ -83,7 +83,7 @@ public class WeighPicController { } /** - * 添加 + * 现场端添加称重图片信息 * * @param weighPic * @return diff --git a/src/main/java/com/zhgd/xmgl/modules/weight/entity/WeighBookVehicleInfo.java b/src/main/java/com/zhgd/xmgl/modules/weight/entity/WeighBookVehicleInfo.java index 986fc98ad..6627e5975 100644 --- a/src/main/java/com/zhgd/xmgl/modules/weight/entity/WeighBookVehicleInfo.java +++ b/src/main/java/com/zhgd/xmgl/modules/weight/entity/WeighBookVehicleInfo.java @@ -1,80 +1,117 @@ package com.zhgd.xmgl.modules.weight.entity; -import java.io.Serializable; -import java.util.Date; import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; -import lombok.Data; import com.fasterxml.jackson.annotation.JsonFormat; -import org.springframework.format.annotation.DateTimeFormat; -import org.jeecgframework.poi.excel.annotation.Excel; import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import org.jeecgframework.poi.excel.annotation.Excel; +import org.springframework.format.annotation.DateTimeFormat; + +import java.io.Serializable; + /** * @Description: 过磅预约车辆信息 * @author: pds - * @date: 2023-03-21 + * @date: 2023-03-21 * @version: V1.0 */ @Data @TableName("weigh_book_vehicle_info") -@ApiModel(value="WeighBookVehicleInfo实体类",description="WeighBookVehicleInfo") +@ApiModel(value = "WeighBookVehicleInfo实体类", description = "WeighBookVehicleInfo") public class WeighBookVehicleInfo implements Serializable { private static final long serialVersionUID = 1L; - - /**主键id*/ - @TableId(type = IdType.ASSIGN_ID) - @ApiModelProperty(value="主键id") - private java.lang.Long id ; - /**车牌号码*/ - @Excel(name = "车牌号码", width = 15) - @ApiModelProperty(value="车牌号码") - private java.lang.String licensePlate ; - /**发货单位*/ - @Excel(name = "发货单位", width = 15) - @ApiModelProperty(value="发货单位") - private java.lang.String forwardingUnit ; - /**收货单位*/ - @Excel(name = "收货单位", width = 15) - @ApiModelProperty(value="收货单位") - private java.lang.String receivingUnit ; - /**货名*/ - @Excel(name = "货名", width = 15) - @ApiModelProperty(value="货名") - private java.lang.String goodsName ; - /**规格*/ - @Excel(name = "规格", width = 15) - @ApiModelProperty(value="规格") - private java.lang.String specifications ; - /**备注*/ - @Excel(name = "备注", width = 15) - @ApiModelProperty(value="备注") - private java.lang.String reserve ; - /**过磅类型*/ - @Excel(name = "过磅类型", width = 15) - @ApiModelProperty(value="过磅类型") - private java.lang.Integer weighingType ; - /**录入时间*/ - @Excel(name = "录入时间", width = 20, format = "yyyy-MM-dd HH:mm:ss") - @JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss") - @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") - @ApiModelProperty(value="录入时间") - private java.util.Date addDateTime ; - /**创建时间*/ - @Excel(name = "创建时间", width = 20, format = "yyyy-MM-dd HH:mm:ss") - @JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss") - @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") - @ApiModelProperty(value="创建时间") - private java.util.Date createTime ; - /**更新时间*/ - @Excel(name = "更新时间", width = 20, format = "yyyy-MM-dd HH:mm:ss") - @JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss") - @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") - @ApiModelProperty(value="更新时间") - private java.util.Date updateTime ; - /**所属项目SN*/ - @Excel(name = "所属项目SN", width = 15) - @ApiModelProperty(value="所属项目SN") - private java.lang.String projectSn ; + + /** + * 主键id + */ + @TableId(type = IdType.ASSIGN_ID) + @ApiModelProperty(value = "主键id") + private java.lang.Long id; + /** + * 车牌号码 + */ + @Excel(name = "车牌号码", width = 15) + @ApiModelProperty(value = "车牌号码") + private java.lang.String licensePlate; + /** + * 发货单位 + */ + @Excel(name = "发货单位", width = 15) + @ApiModelProperty(value = "发货单位") + private java.lang.String forwardingUnit; + /** + * 收货单位 + */ + @Excel(name = "收货单位", width = 15) + @ApiModelProperty(value = "收货单位") + private java.lang.String receivingUnit; + /** + * 货名 + */ + @Excel(name = "货名", width = 15) + @ApiModelProperty(value = "货名") + private java.lang.String goodsName; + /** + * 规格 + */ + @Excel(name = "规格", width = 15) + @ApiModelProperty(value = "规格") + private java.lang.String specifications; + /** + * 备注 + */ + @Excel(name = "备注", width = 15) + @ApiModelProperty(value = "备注") + private java.lang.String reserve; + /** + * 过磅类型 + */ + @Excel(name = "过磅类型", width = 15) + @ApiModelProperty(value = "过磅类型") + private java.lang.Integer weighingType; + /** + * 录入时间 + */ + @Excel(name = "录入时间", width = 20, format = "yyyy-MM-dd HH:mm:ss") + @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss") + @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") + @ApiModelProperty(value = "录入时间") + private java.util.Date addDateTime; + /** + * 创建时间 + */ + @Excel(name = "创建时间", width = 20, format = "yyyy-MM-dd HH:mm:ss") + @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss") + @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") + @ApiModelProperty(value = "创建时间") + private java.util.Date createTime; + /** + * 更新时间 + */ + @Excel(name = "更新时间", width = 20, format = "yyyy-MM-dd HH:mm:ss") + @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss") + @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") + @ApiModelProperty(value = "更新时间") + private java.util.Date updateTime; + /** + * 所属项目SN + */ + @Excel(name = "所属项目SN", width = 15) + @ApiModelProperty(value = "所属项目SN") + private java.lang.String projectSn; + /** + * 现场上次拉取的时间 + */ + @TableField(exist = false) + private String lastAddTime; + /** + * 上次查询的id(查询这个id数据之后的数据(不返回这条id数据)) + */ + @TableField(exist = false) + private Long lastQueryId; + } diff --git a/src/main/java/com/zhgd/xmgl/modules/weight/service/IWeighBookVehicleInfoService.java b/src/main/java/com/zhgd/xmgl/modules/weight/service/IWeighBookVehicleInfoService.java index c720a43bb..bdac5ae46 100644 --- a/src/main/java/com/zhgd/xmgl/modules/weight/service/IWeighBookVehicleInfoService.java +++ b/src/main/java/com/zhgd/xmgl/modules/weight/service/IWeighBookVehicleInfoService.java @@ -1,8 +1,12 @@ package com.zhgd.xmgl.modules.weight.service; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.zhgd.jeecg.common.api.vo.Result; import com.zhgd.xmgl.modules.weight.entity.WeighBookVehicleInfo; import com.baomidou.mybatisplus.extension.service.IService; +import javax.servlet.http.HttpServletRequest; + /** * @Description: 过磅预约车辆信息 * @author: pds @@ -11,4 +15,5 @@ import com.baomidou.mybatisplus.extension.service.IService; */ public interface IWeighBookVehicleInfoService extends IService { + Result> queryPageList(WeighBookVehicleInfo weighBookVehicleInfo, Integer pageNo, Integer pageSize, HttpServletRequest req); } diff --git a/src/main/java/com/zhgd/xmgl/modules/weight/service/impl/WeighBookVehicleInfoServiceImpl.java b/src/main/java/com/zhgd/xmgl/modules/weight/service/impl/WeighBookVehicleInfoServiceImpl.java index ecfa71a00..1ca064d2d 100644 --- a/src/main/java/com/zhgd/xmgl/modules/weight/service/impl/WeighBookVehicleInfoServiceImpl.java +++ b/src/main/java/com/zhgd/xmgl/modules/weight/service/impl/WeighBookVehicleInfoServiceImpl.java @@ -1,19 +1,51 @@ package com.zhgd.xmgl.modules.weight.service.impl; +import cn.hutool.core.date.DateTime; +import cn.hutool.core.date.DateUtil; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.zhgd.jeecg.common.api.vo.Result; import com.zhgd.xmgl.modules.weight.entity.WeighBookVehicleInfo; import com.zhgd.xmgl.modules.weight.mapper.WeighBookVehicleInfoMapper; import com.zhgd.xmgl.modules.weight.service.IWeighBookVehicleInfoService; +import org.apache.commons.lang3.StringUtils; import org.springframework.stereotype.Service; -import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import javax.servlet.http.HttpServletRequest; /** * @Description: 过磅预约车辆信息 * @author: pds - * @date: 2023-03-21 + * @date: 2023-03-21 * @version: V1.0 */ @Service public class WeighBookVehicleInfoServiceImpl extends ServiceImpl implements IWeighBookVehicleInfoService { + @Override + public Result queryPageList(WeighBookVehicleInfo weighBookVehicleInfo, Integer pageNo, Integer pageSize, HttpServletRequest req) { + if (StringUtils.isBlank(weighBookVehicleInfo.getProjectSn())) { + return Result.error("projectSn不能为空"); + } + String lastAdddatetime = weighBookVehicleInfo.getLastAddTime(); + Long lastQueryId = weighBookVehicleInfo.getLastQueryId(); + Result> result = new Result>(); + LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper() + .eq(StringUtils.isNotBlank(weighBookVehicleInfo.getProjectSn()), WeighBookVehicleInfo::getProjectSn, weighBookVehicleInfo.getProjectSn()) + .like(StringUtils.isNotBlank(weighBookVehicleInfo.getSpecifications()), WeighBookVehicleInfo::getSpecifications, weighBookVehicleInfo.getSpecifications()) + .like(StringUtils.isNotBlank(weighBookVehicleInfo.getGoodsName()), WeighBookVehicleInfo::getGoodsName, weighBookVehicleInfo.getGoodsName()) + .like(StringUtils.isNotBlank(weighBookVehicleInfo.getLicensePlate()), WeighBookVehicleInfo::getLicensePlate, weighBookVehicleInfo.getLicensePlate()) + .gt(lastQueryId != null, WeighBookVehicleInfo::getId, lastQueryId); + if (StringUtils.isNotBlank(lastAdddatetime)) { + DateTime dateTime = DateUtil.parse(lastAdddatetime); + queryWrapper.ge(WeighBookVehicleInfo::getAddDateTime, dateTime); + } + Page page = new Page(pageNo, pageSize); + IPage pageList = page(page, queryWrapper); + result.setSuccess(true); + result.setResult(pageList); + return result; + } }