package org.jeecg.modules.eam.controller; import org.apache.commons.lang3.StringUtils; import org.jeecg.common.system.query.QueryGenerator; 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.common.system.base.controller.JeecgController; import org.jeecg.common.api.vo.Result; import org.jeecg.modules.eam.vo.EquipmentDisposalPage; import org.jeecg.modules.eam.vo.EquipmentSealPage; //import org.jeecg.modules.flowable.apithird.business.entity.FlowMyBusiness; //import org.jeecg.modules.flowable.apithird.business.service.IFlowMyBusinessService; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.springframework.web.servlet.ModelAndView; import java.util.ArrayList; import java.util.Arrays; import org.jeecg.common.util.oConvertUtils; import org.jeecg.modules.eam.entity.EquipmentSealDetail; import org.jeecg.modules.eam.entity.EquipmentSeal; import org.jeecg.modules.eam.service.IEquipmentSealService; import org.jeecg.modules.eam.service.IEquipmentSealDetailService; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import org.jeecg.common.aspect.annotation.AutoLog; import org.apache.shiro.SecurityUtils; import org.jeecg.common.system.vo.LoginUser; 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.web.multipart.MultipartFile; import org.springframework.web.multipart.MultipartHttpServletRequest; import java.io.IOException; import java.util.List; import java.util.Map; import java.util.stream.Collectors; /** * @Description: 设备封存 * @Author: jeecg-boot * @Date: 2023-05-06 * @Version: V1.0 */ @Api(tags = "设备封存") @RestController @RequestMapping("/eam/equipmentSeal") @Slf4j public class EquipmentSealController extends JeecgController { @Autowired private IEquipmentSealService equipmentSealService; @Autowired private IEquipmentSealDetailService equipmentSealDetailService; // @Autowired // private IFlowMyBusinessService flowMyBusinessService; /*---------------------------------主表处理-begin-------------------------------------*/ /** * 分页列表查询 * * @param equipmentSeal * @param pageNo * @param pageSize * @param req * @return */ //@AutoLog(value = "设备封存-分页列表查询") @ApiOperation(value = "设备封存-分页列表查询", notes = "设备封存-分页列表查询") @GetMapping(value = "/list") public Result> queryPageList(EquipmentSeal equipmentSeal, @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo, @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize, HttpServletRequest req) { //QueryWrapper queryWrapper = QueryGenerator.initQueryWrapper(equipmentSeal, req.getParameterMap()); QueryWrapper queryWrapper = new QueryWrapper<>(); Page page = new Page(pageNo, pageSize); if(StringUtils.isNotBlank(equipmentSeal.getNum())){ queryWrapper.like("num",equipmentSeal.getNum()); } if(StringUtils.isNotBlank(equipmentSeal.getAuditStatus())){ queryWrapper.eq("audit_status",equipmentSeal.getAuditStatus()); } queryWrapper.eq("change_method",equipmentSeal.getChangeMethod()); queryWrapper.eq("del_flag",equipmentSeal.getDelFlag()); queryWrapper.eq("status",equipmentSeal.getStatus()); queryWrapper.orderByDesc("create_time"); IPage pageList = equipmentSealService.page(page, queryWrapper); List equipmentSealList = pageList.getRecords(); for (EquipmentSeal entity : equipmentSealList) { String id = entity.getId(); // FlowMyBusiness flowMyBusiness = flowMyBusinessService.getByDataId(id); } return Result.OK(pageList); } /** * 添加 * * @param equipmentSealPage * @return */ @AutoLog(value = "设备封存-添加") @ApiOperation(value = "设备封存-添加", notes = "设备封存-添加") //@RequiresPermissions("org.jeecg.modules:mom_eam_equipment_change:add") @PostMapping(value = "/add") public Result add(@RequestBody EquipmentSealPage equipmentSealPage) { EquipmentSeal equipmentSeal = new EquipmentSeal(); BeanUtils.copyProperties(equipmentSealPage, equipmentSeal); equipmentSealService.saveMain(equipmentSeal, equipmentSealPage.getEquipmentSealDetailList()); return Result.OK("添加成功!"); } /** * 编辑 * * @param equipmentSealPage * @return */ @AutoLog(value = "设备封存-编辑") @ApiOperation(value = "设备封存-编辑", notes = "设备封存-编辑") //@RequiresPermissions("org.jeecg.modules:mom_eam_equipment_change:edit") @RequestMapping(value = "/edit", method = {RequestMethod.PUT, RequestMethod.POST}) public Result edit(@RequestBody EquipmentSealPage equipmentSealPage) { EquipmentSeal equipmentSeal = new EquipmentSeal(); BeanUtils.copyProperties(equipmentSealPage, equipmentSeal); EquipmentSeal equipmentSealEntity = equipmentSealService.getById(equipmentSeal.getId()); if (equipmentSealEntity == null) { return Result.error("未找到对应数据"); } equipmentSealService.updateMain(equipmentSeal, equipmentSealPage.getEquipmentSealDetailList()); return Result.OK("编辑成功!"); } /** * 通过id删除 * * @param id * @return */ @AutoLog(value = "设备封存-通过id删除") @ApiOperation(value = "设备封存-通过id删除", notes = "设备封存-通过id删除") //@RequiresPermissions("org.jeecg.modules:mom_eam_equipment_change:delete") @DeleteMapping(value = "/delete") public Result delete(@RequestParam(name = "id", required = true) String id) { equipmentSealService.delMain(id); return Result.OK("删除成功!"); } /** * 批量删除 * * @param ids * @return */ @AutoLog(value = "设备封存-批量删除") @ApiOperation(value = "设备封存-批量删除", notes = "设备封存-批量删除") //@RequiresPermissions("org.jeecg.modules:mom_eam_equipment_change:deleteBatch") @DeleteMapping(value = "/deleteBatch") public Result deleteBatch(@RequestParam(name = "ids", required = true) String ids) { this.equipmentSealService.delBatchMain(Arrays.asList(ids.split(","))); return Result.OK("批量删除成功!"); } /** * 通过id查询 * * @param id * @return */ //@AutoLog(value = "设备封存-通过id查询") @ApiOperation(value = "设备封存-通过id查询", notes = "设备封存-通过id查询") @GetMapping(value = "/queryById") public Result queryById(@RequestParam(name = "id", required = true) String id) { EquipmentSeal equipmentSeal = equipmentSealService.getById(id); if (equipmentSeal == null) { return Result.error("未找到对应数据"); } return Result.OK(equipmentSeal); } /** * 通过id查询 * * @param id * @return */ //@AutoLog(value = "设备封存明细通过主表ID查询") @ApiOperation(value = "设备封存明细主表ID查询", notes = "设备封存明细-通主表ID查询") @GetMapping(value = "/queryEquipmentSealDetailByMainId") public Result> queryEquipmentSealDetailListByMainId(@RequestParam(name = "id", required = true) String id) { List equipmentSealDetailList = equipmentSealDetailService.selectByMainId(id); return Result.OK(equipmentSealDetailList); } /** * 导出excel * * @param request * @param equipmentSeal */ //@RequiresPermissions("org.jeecg.modules:mom_eam_equipment_change:exportXls") @RequestMapping(value = "/exportXls") public ModelAndView exportXls(HttpServletRequest request, EquipmentSeal equipmentSeal) { // Step.1 组装查询条件查询数据 QueryWrapper queryWrapper = QueryGenerator.initQueryWrapper(equipmentSeal, request.getParameterMap()); LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); //配置选中数据查询条件 String selections = request.getParameter("selections"); if (oConvertUtils.isNotEmpty(selections)) { List selectionList = Arrays.asList(selections.split(",")); queryWrapper.in("id", selectionList); } //Step.2 获取导出数据 List equipmentSealList = equipmentSealService.list(queryWrapper); // Step.3 组装pageList List pageList = new ArrayList(); for (EquipmentSeal main : equipmentSealList) { EquipmentSealPage vo = new EquipmentSealPage(); BeanUtils.copyProperties(main, vo); List equipmentSealDetailList = equipmentSealDetailService.selectByMainId(main.getId()); vo.setEquipmentSealDetailList(equipmentSealDetailList); pageList.add(vo); } // Step.4 AutoPoi 导出Excel ModelAndView mv = new ModelAndView(new JeecgEntityExcelView()); mv.addObject(NormalExcelConstants.FILE_NAME, "设备封存列表"); mv.addObject(NormalExcelConstants.CLASS, EquipmentSealPage.class); mv.addObject(NormalExcelConstants.PARAMS, new ExportParams("设备封存数据", "导出人:" + sysUser.getRealname(), "设备封存")); mv.addObject(NormalExcelConstants.DATA_LIST, pageList); return mv; } /** * 通过excel导入数据 * * @param request * @param response * @return */ //@RequiresPermissions("org.jeecg.modules:mom_eam_equipment_change:importExcel") @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(), EquipmentSealPage.class, params); for (EquipmentSealPage page : list) { EquipmentSeal po = new EquipmentSeal(); BeanUtils.copyProperties(page, po); equipmentSealService.saveMain(po, page.getEquipmentSealDetailList()); } 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.OK("文件导入失败!"); } /*---------------------------------主表处理-end-------------------------------------*/ /*--------------------------------子表处理-设备封存明细-begin----------------------------------------------*/ /** * 通过主表ID查询 * * @return */ //@AutoLog(value = "设备封存明细-通过主表ID查询") @ApiOperation(value = "设备封存明细-通过主表ID查询", notes = "设备封存明细-通过主表ID查询") @GetMapping(value = "/listEquipmentSealDetailByMainId") public Result> listEquipmentSealDetailByMainId(EquipmentSealDetail equipmentSealDetail, @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo, @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize, HttpServletRequest req) { QueryWrapper queryWrapper = QueryGenerator.initQueryWrapper(equipmentSealDetail, req.getParameterMap()); Page page = new Page(pageNo, pageSize); IPage pageList = equipmentSealDetailService.page(page, queryWrapper); return Result.OK(pageList); } /** * 添加 * * @param equipmentSealDetail * @return */ @AutoLog(value = "设备封存明细-添加") @ApiOperation(value = "设备封存明细-添加", notes = "设备封存明细-添加") @PostMapping(value = "/addEquipmentSealDetail") public Result addEquipmentSealDetail(@RequestBody EquipmentSealDetail equipmentSealDetail) { equipmentSealDetailService.save(equipmentSealDetail); return Result.OK("添加成功!"); } /** * 编辑 * * @param equipmentSealDetail * @return */ @AutoLog(value = "设备封存明细-编辑") @ApiOperation(value = "设备封存明细-编辑", notes = "设备封存明细-编辑") @RequestMapping(value = "/editEquipmentSealDetail", method = {RequestMethod.PUT, RequestMethod.POST}) public Result editEquipmentSealDetail(@RequestBody EquipmentSealDetail equipmentSealDetail) { equipmentSealDetailService.updateById(equipmentSealDetail); return Result.OK("编辑成功!"); } /** * 通过id删除 * * @param id * @return */ @AutoLog(value = "设备封存明细-通过id删除") @ApiOperation(value = "设备封存明细-通过id删除", notes = "设备封存明细-通过id删除") @DeleteMapping(value = "/deleteEquipmentSealDetail") public Result deleteEquipmentSealDetail(@RequestParam(name = "id", required = true) String id) { equipmentSealDetailService.removeById(id); return Result.OK("删除成功!"); } /** * 批量删除 * * @param ids * @return */ @AutoLog(value = "设备封存明细-批量删除") @ApiOperation(value = "设备封存明细-批量删除", notes = "设备封存明细-批量删除") @DeleteMapping(value = "/deleteBatchEquipmentSealDetail") public Result deleteBatchEquipmentSealDetail(@RequestParam(name = "ids", required = true) String ids) { this.equipmentSealDetailService.removeByIds(Arrays.asList(ids.split(","))); return Result.OK("批量删除成功!"); } /** * 导出 * * @return */ @RequestMapping(value = "/exportEquipmentSealDetail") public ModelAndView exportEquipmentSealDetail(HttpServletRequest request, EquipmentSealDetail equipmentSealDetail) { // Step.1 组装查询条件 QueryWrapper queryWrapper = QueryGenerator.initQueryWrapper(equipmentSealDetail, request.getParameterMap()); LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); // Step.2 获取导出数据 List pageList = equipmentSealDetailService.list(queryWrapper); List exportList = null; // 过滤选中数据 String selections = request.getParameter("selections"); if (oConvertUtils.isNotEmpty(selections)) { List selectionList = Arrays.asList(selections.split(",")); exportList = pageList.stream().filter(item -> selectionList.contains(item.getId())).collect(Collectors.toList()); } else { exportList = pageList; } // Step.3 AutoPoi 导出Excel ModelAndView mv = new ModelAndView(new JeecgEntityExcelView()); //此处设置的filename无效,前端会重更新设置一下 mv.addObject(NormalExcelConstants.FILE_NAME, "设备封存明细"); mv.addObject(NormalExcelConstants.CLASS, EquipmentSealDetail.class); mv.addObject(NormalExcelConstants.PARAMS, new ExportParams("设备封存明细报表", "导出人:" + sysUser.getRealname(), "设备封存明细")); mv.addObject(NormalExcelConstants.DATA_LIST, exportList); return mv; } /** * 导入 * * @return */ @RequestMapping(value = "/importEquipmentSealDetail/{mainId}") public Result importEquipmentSealDetail(HttpServletRequest request, HttpServletResponse response, @PathVariable("mainId") String mainId) { 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(), EquipmentSealDetail.class, params); for (EquipmentSealDetail temp : list) { temp.setEquipmentChangeId(mainId); } long start = System.currentTimeMillis(); equipmentSealDetailService.saveBatch(list); log.info("消耗时间" + (System.currentTimeMillis() - start) + "毫秒"); 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("文件导入失败!"); } /*--------------------------------子表处理-设备封存明细-end----------------------------------------------*/ /** * 提交 * * @param equipmentDisposalPage * @return */ @AutoLog(value = "设备封存-提交") @ApiOperation(value = "设备封存-提交", notes = "设备封存-提交") //@RequiresPermissions("org.jeecg.modules:mom_eam_equipment_change:submitBatch") @PostMapping(value = "/submit") public Result submit(@RequestBody EquipmentDisposalPage equipmentDisposalPage) { String id = equipmentDisposalPage.getId(); this.equipmentSealService.submit(id); return Result.OK("提交成功!"); } /** * 批量提交 * * @param equipmentDisposalPage * @return */ @AutoLog(value = "设备封存-批量提交") @ApiOperation(value = "设备封存-批量提交", notes = "设备封存-批量提交") //@RequiresPermissions("org.jeecg.modules:mom_eam_equipment_change:submitBatch") @PostMapping(value = "/submitBatch") public Result submitBatch(@RequestBody EquipmentDisposalPage equipmentDisposalPage) { String ids = equipmentDisposalPage.getIds(); this.equipmentSealService.submitBatch(Arrays.asList(ids.split(","))); return Result.OK("批量提交成功!"); } /** * 撤回 * * @param equipmentDisposalPage * @return */ @AutoLog(value = "设备封存-撤回") @ApiOperation(value = "设备封存-撤回", notes = "设备封存-撤回") //@RequiresPermissions("org.jeecg.modules:mom_eam_equipment_change:submitBatch") @PostMapping(value = "/revocation") public Result revocation(@RequestBody EquipmentDisposalPage equipmentDisposalPage) { String id = equipmentDisposalPage.getId(); equipmentSealService.revocation(id); return Result.OK("撤回成功!"); } /** * 批量撤回 * * @param equipmentDisposalPage * @return */ @AutoLog(value = "设备封存-批量撤回") @ApiOperation(value = "设备封存-批量撤回", notes = "设备封存-批量撤回") //@RequiresPermissions("org.jeecg.modules:mom_eam_equipment_change:submitBatch") @PostMapping(value = "/revocationBatch") public Result revocationBatch(@RequestBody EquipmentDisposalPage equipmentDisposalPage) { String ids = equipmentDisposalPage.getIds(); this.equipmentSealService.revocationBatch(Arrays.asList(ids.split(","))); return Result.OK("批量撤回成功!"); } /** * 撤回 * * @param equipmentSeal * @return */ @ApiOperation(value = "设备封存-审批", notes = "设备封存-审批") @PostMapping(value = "/approve") public Result approve(@RequestBody EquipmentSeal equipmentSeal) { equipmentSealService.updateById(equipmentSeal); return Result.OK("操作成功!"); } }