package org.jeecg.modules.eam.controller; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; import com.baomidou.mybatisplus.core.toolkit.StringUtils; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; import org.apache.poi.ss.usermodel.*; import org.apache.poi.xssf.usermodel.XSSFWorkbook; import org.apache.shiro.SecurityUtils; import org.jeecg.common.api.dto.message.MessageDTO; import org.jeecg.common.api.vo.Result; import org.jeecg.common.aspect.annotation.AutoLog; import org.jeecg.common.constant.CommonConstant; import org.jeecg.common.system.api.ISysBaseAPI; import org.jeecg.common.system.base.controller.JeecgController; import org.jeecg.common.system.query.QueryGenerator; import org.jeecg.common.system.vo.LoginUser; import org.jeecg.common.util.ImportExcelUtil; import org.jeecg.modules.eam.entity.*; import org.jeecg.modules.eam.service.*; import org.jeecg.modules.eam.vo.InspectionStandardImportVo; import org.jeecg.modules.system.entity.*; import org.jeecg.modules.system.service.*; import org.jeecgframework.poi.excel.entity.ImportParams; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.transaction.annotation.Transactional; 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 javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.io.IOException; import java.io.InputStream; import java.math.BigDecimal; import java.util.*; /** * @Description: mom_eam_inspection_project * @Author: jeecg-boot * @Date: 2023-03-10 * @Version: V1.0 */ @Api(tags = "mom_eam_daily_inspection_standard") @RestController @RequestMapping("/eam/inspectionStandard") @Slf4j public class DailyInspectionStandardController extends JeecgController { @Autowired private IDailyInspectionStandardService dailyInspectionStandardService; @Autowired private IEamEquipmentService equipmentService; @Autowired private IDailyInspectionStandardDetailService dailyInspectionStandardDetailService; @Autowired private IdentityService identityService; @Autowired private IInspectionProjectService inspectionProjectService; @Autowired private IInspectionCycleService inspectionCycleService; @Autowired private ISysBaseAPI sysBaseApi; @Autowired private ISysUserService sysUserService; @Resource private ISysRoleService sysRoleService; @Resource private ISysDictService sysDictService; @Resource private ISysDictItemService sysDictItemService; @Resource private ISysUserRoleService sysUserRoleService; /** * 分页列表查询 * * @param dailyInspectionStandard * @param pageNo * @param pageSize * @param req * @return */ @ApiOperation(value = "mom_eam_daily_inspection_standard-分页列表查询", notes = "mom_eam_daily_inspection_standard-分页列表查询") @GetMapping(value = "/list") public Result> queryPageList(DailyInspectionStandard dailyInspectionStandard, @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo, @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize, HttpServletRequest req) { QueryWrapper queryWrapper = QueryGenerator.initQueryWrapper(dailyInspectionStandard, req.getParameterMap()); Page page = new Page(pageNo, pageSize); IPage pageList = dailyInspectionStandardService.page(page, queryWrapper); return Result.OK(pageList); } /** * 日常点检 * qsw 2023-4-26 */ @GetMapping("getInspectionStandardList") public Result getInspectionStandardList(@RequestParam("pageNo") Integer pageNo, @RequestParam("pageSize") Integer pageSize, @RequestParam Map params) { IPage> inspectionStandardList = dailyInspectionStandardService.getInspectionStandardList(pageNo, pageSize, params); List> records = inspectionStandardList.getRecords(); for (Map record : records) { String dailyInspectionStandardId = (String)record.get("id"); List> dailyInspectionStandardDetaillist = dailyInspectionStandardDetailService.getInspectionStandardDetailList(dailyInspectionStandardId); record.put("dailyInspectionStandardDetaillist",dailyInspectionStandardDetaillist); } return Result.ok(inspectionStandardList); } /** *创建日常点检工单获取，日常点检标准 * 2023-8-2 qsw */ @GetMapping("findInspectionStandardList") public Result findInspectionStandardList(@RequestParam("pageNo") Integer pageNo, @RequestParam("pageSize") Integer pageSize, @RequestParam Map params) { IPage> inspectionStandardList = dailyInspectionStandardService.findInspectionStandardList(pageNo, pageSize, params); return Result.ok(inspectionStandardList); } /** * 添加 * * @param dailyInspectionStandard * @return */ @AutoLog(value = "mom_eam_daily_inspection_standard-添加") @ApiOperation(value = "mom_eam_daily_inspection_standard-添加", notes = "mom_eam_daily_inspection_standard-添加") @PostMapping(value = "/add") @Transactional(rollbackFor = { Exception.class }) public Result add(@RequestBody DailyInspectionStandard dailyInspectionStandard) { LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); dailyInspectionStandard.setWritePerson(sysUser.getRealname()); dailyInspectionStandard.setAssignMode("1"); dailyInspectionStandardService.save(dailyInspectionStandard); List dailyInspectionStandardDetaillist = dailyInspectionStandard.getDailyInspectionStandardDetaillist(); DailyInspectionStandardDetail isd = null; for (DailyInspectionStandardDetail dailyInspectionStandardDetail : dailyInspectionStandardDetaillist) { isd = new DailyInspectionStandardDetail(); isd.setDailyInspectionStandardId(dailyInspectionStandard.getId()); isd.setLocation(dailyInspectionStandardDetail.getLocation()); isd.setPhoto(dailyInspectionStandardDetail.getPhoto()); isd.setInspectionProjectId(dailyInspectionStandardDetail.getInspectionProjectId()); isd.setInspectionCycleId(dailyInspectionStandardDetail.getInspectionCycleId()); dailyInspectionStandardDetailService.save(isd); } //消息提醒 this.inspectionStandardAlert(dailyInspectionStandard.getApprovalStatus(),dailyInspectionStandard.getNum()); return Result.OK("添加成功！"); } /** * 编辑 * * @param dailyInspectionStandard * @return */ @AutoLog(value = "mom_eam_daily_inspection_standard-编辑") @ApiOperation(value = "mom_eam_daily_inspection_standard-编辑", notes = "mom_eam_daily_inspection_standard-编辑") @RequestMapping(value = "/edit", method = {RequestMethod.PUT, RequestMethod.POST}) @Transactional(rollbackFor = { Exception.class }) public Result edit(@RequestBody DailyInspectionStandard dailyInspectionStandard) { dailyInspectionStandard.setApprovalStatus("1"); dailyInspectionStandardService.updateById(dailyInspectionStandard); //1.删除原点检项目 List dailyInspectionStandardDetails = dailyInspectionStandardDetailService.lambdaQuery() .eq(DailyInspectionStandardDetail::getDailyInspectionStandardId, dailyInspectionStandard.getId()) .eq(DailyInspectionStandardDetail::getDelFlag, 0) .eq(DailyInspectionStandardDetail::getStatus, "1").list(); for (DailyInspectionStandardDetail dailyInspectionStandardDetail : dailyInspectionStandardDetails) { dailyInspectionStandardDetail.setDelFlag(1); dailyInspectionStandardDetailService.updateById(dailyInspectionStandardDetail); } //2.重新持久点检项目 List dailyInspectionStandardDetaillist = dailyInspectionStandard.getDailyInspectionStandardDetaillist(); DailyInspectionStandardDetail isd = null; for (DailyInspectionStandardDetail dailyInspectionStandardDetail : dailyInspectionStandardDetaillist) { isd = new DailyInspectionStandardDetail(); isd.setDailyInspectionStandardId(dailyInspectionStandard.getId()); isd.setLocation(dailyInspectionStandardDetail.getLocation()); isd.setPhoto(dailyInspectionStandardDetail.getPhoto()); isd.setInspectionProjectId(dailyInspectionStandardDetail.getInspectionProjectId()); isd.setInspectionCycleId(dailyInspectionStandardDetail.getInspectionCycleId()); dailyInspectionStandardDetailService.save(isd); } //消息提醒 this.inspectionStandardAlert(dailyInspectionStandard.getApprovalStatus(),dailyInspectionStandard.getNum()); return Result.OK("编辑成功!"); } /** * 通过id删除 * * @param id * @return */ @AutoLog(value = "mom_eam_daily_inspection_standard-通过id删除") @ApiOperation(value = "mom_eam_daily_inspection_standard-通过id删除", notes = "mom_eam_daily_inspection_standard-通过id删除") @DeleteMapping(value = "/delete") public Result delete(@RequestParam(name = "id", required = true) String id) { DailyInspectionStandard dailyInspectionStandard = dailyInspectionStandardService.getById(id); dailyInspectionStandard.setDelFlag(1); dailyInspectionStandardService.updateById(dailyInspectionStandard); List dailyInspectionStandardDetails = dailyInspectionStandardDetailService.lambdaQuery() .eq(DailyInspectionStandardDetail::getDailyInspectionStandardId, id) .eq(DailyInspectionStandardDetail::getDelFlag, 0) .eq(DailyInspectionStandardDetail::getStatus, "1").list(); for (DailyInspectionStandardDetail dailyInspectionStandardDetail : dailyInspectionStandardDetails) { dailyInspectionStandardDetail.setDelFlag(1); dailyInspectionStandardDetailService.updateById(dailyInspectionStandardDetail); } return Result.OK("删除成功!"); } /** * 批量删除 * * @param ids * @return */ @AutoLog(value = "mom_eam_daily_inspection_standard-批量删除") @ApiOperation(value = "mom_eam_daily_inspection_standard-批量删除", notes = "mom_eam_daily_inspection_standard-批量删除") @DeleteMapping(value = "/deleteBatch") public Result deleteBatch(@RequestParam(name = "ids", required = true) String ids) { List idList = Arrays.asList(ids.split(",")); for (String id : idList) { DailyInspectionStandard dailyInspectionStandard = dailyInspectionStandardService.getById(id); dailyInspectionStandard.setDelFlag(1); dailyInspectionStandardService.updateById(dailyInspectionStandard); } return Result.OK("批量删除成功!"); } /** * 通过id查询 * * @param id * @return */ @ApiOperation(value = "mom_eam_daily_inspection_standard-通过id查询", notes = "mom_eam_daily_inspection_standard-通过id查询") @GetMapping(value = "/queryById") public Result queryById(@RequestParam(name = "id", required = true) String id) { DailyInspectionStandard dailyInspectionStandard = dailyInspectionStandardService.getById(id); if (dailyInspectionStandard == null) { return Result.error("未找到对应数据"); } return Result.OK(dailyInspectionStandard); } /** * 导出excel * * @param request * @param dailyInspectionStandard */ @RequestMapping(value = "/exportXls") public ModelAndView exportXls(HttpServletRequest request, DailyInspectionStandard dailyInspectionStandard) { return super.exportXls(request, dailyInspectionStandard, DailyInspectionStandard.class, "mom_eam_daily_inspection_standard"); } /** * 通过excel导入数据 * * @param request * @param response * @return */ @RequestMapping(value = "/importExcel", method = RequestMethod.POST) public Result importExcel(HttpServletRequest request, HttpServletResponse response) throws IOException { MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request; LoginUser user= (LoginUser) SecurityUtils.getSubject().getPrincipal(); Map fileMap = multipartRequest.getFileMap(); // 错误信息 List errorMessage = new ArrayList<>(); int successLines = 0, errorLines = 0; //a = 1开始读取点检项目；b = 1开始读取周保养项目；c = 1该设备导入信息存在错误；projectColumnIndex点检项目所在列；maintenanceColumnIndex周保养项目所在列 int a = 0,b = 0,c = 0,projectColumnIndex = -1,maintenanceColumnIndex = 0; //表头标题 String title = ""; String dailyInspectionStandardId = null; String equipmentNum = null; DailyInspectionStandard dailyInspectionStandard = null; List dailyInspectionStandardDetailList = new ArrayList<>(); for (Map.Entry entity : fileMap.entrySet()) { MultipartFile file = entity.getValue(); ImportParams params = new ImportParams(); params.setNeedSave(true); try { InputStream fis = file.getInputStream(); Workbook workbook = new XSSFWorkbook(fis); int sheets = workbook.getNumberOfSheets(); //判断点检周期是否存在 InspectionCycle dayInspectionCycle = inspectionCycleService.lambdaQuery().eq(InspectionCycle::getName,"1日").eq(InspectionCycle::getVersionStatus,"2").one(); InspectionCycle weekInspectionCycle = inspectionCycleService.lambdaQuery().eq(InspectionCycle::getName,"1周").eq(InspectionCycle::getVersionStatus,"2").one(); if(dayInspectionCycle == null || weekInspectionCycle == null){ c = 1; errorMessage.add("点检周期不存在，请先维护点检周期"); errorLines++; }else{ for(int i = 0;i < sheets;i++){ Sheet sheet = workbook.getSheetAt(i); for (Row row : sheet) { // 遍历每一个单元格 // for (Cell cell : row) { for(int j = 0;j < 5;j++){ // 处理单元格数据，例如输出单元格的值 Cell cell = row.getCell(j); // if("STRING".equals(cell.getCellType().toString())|| "BLANK".equals(cell.getCellType().toString())){ if("STRING".equals(cell.getCellType().toString())|| "BLANK".equals(cell.getCellType().toString())){ //点检周期存在，判断设备统一编码是否存在 String strCell = cell.getStringCellValue(); if(strCell.contains("生产设备自主维护点检表")){ title = strCell.trim().substring(11).trim(); } if(strCell.contains("设备名称：")){ String[] tybh1 = strCell.split("统一编号："); String[] tybh2 = tybh1[1].split("年"); // equipmentNum = tybh2[0].trim().substring(0,tybh2[0].trim().length()-4).trim(); equipmentNum = tybh2[0].trim(); /*String year = tybh2[0].trim().substring(tybh2[0].trim().length()-4,tybh2[0].trim().length()).trim(); String[] month1 = tybh2[1].split("月"); String month = month1[0].trim(); String[] unit1 = strCell.split("单位："); String unit = unit1[1].trim();*/ Equipment equipment = equipmentService.lambdaQuery().eq(Equipment::getNum,equipmentNum).eq(Equipment::getDelFlag, CommonConstant.DEL_FLAG_0).one(); if(equipment == null){ c = 1; errorMessage.add("sheet页为"+sheet.getSheetName()+"，设备统一编码为"+ equipmentNum + "的数据导入失败,原因:设备不存在，请先维护设备台账！"); errorLines++; }else { List dailyInspectionStandardList = dailyInspectionStandardService.lambdaQuery().eq(DailyInspectionStandard::getEquipmentId,equipment.getId()) .eq(DailyInspectionStandard::getVersionStatus,"2").eq(DailyInspectionStandard::getDelFlag,CommonConstant.DEL_FLAG_0).list(); if(CollectionUtils.isNotEmpty(dailyInspectionStandardList)){ c = 1; errorMessage.add("sheet页为"+sheet.getSheetName()+"，设备统一编码为"+ equipmentNum + "的数据导入失败,原因:该设备已经存在点检标准！"); errorLines++; }else { c = 0; String num = identityService.getNumByTypeAndLength("DailylnspectionStandard", 4); dailyInspectionStandard = new DailyInspectionStandard(); dailyInspectionStandard.setNum(num); dailyInspectionStandard.setVersionStatus("2"); dailyInspectionStandard.setVersion("1.0"); dailyInspectionStandard.setAssignMode("1"); dailyInspectionStandard.setEquipmentId(equipment.getId()); dailyInspectionStandard.setApprovalStatus("5"); dailyInspectionStandard.setDisUda1(title); //dailyInspectionStandardService.save(dailyInspectionStandard); //dailyInspectionStandardId = dailyInspectionStandard.getId(); } } break; } //设备统一编码存在，判断点检项目是否存在 if(c == 0){ System.out.print(strCell + "\t"); if(strCell.contains("点检项目")){ a = 1; projectColumnIndex = cell.getColumnIndex(); break; } if(strCell.contains("维护责任人签字")){ a = 0; } if(projectColumnIndex == cell.getColumnIndex() && a == 1){ DailyInspectionStandardDetail dailyInspectionStandardDetail = new DailyInspectionStandardDetail(); dailyInspectionStandardDetail.setDailyInspectionStandardId(dailyInspectionStandardId); String dayInspectionProjectName = row.getCell(projectColumnIndex).toString(); String standard = row.getCell(projectColumnIndex+3).toString(); //查询点检项目，如果没有新增点检项目 if(StringUtils.isNotBlank(dayInspectionProjectName)){ List inspectionProjectList = inspectionProjectService.lambdaQuery().eq(InspectionProject::getName,dayInspectionProjectName) .eq(InspectionProject::getDetectionStandard,standard).eq(InspectionProject::getDelFlag,CommonConstant.DEL_FLAG_0).list(); if(CollectionUtils.isEmpty(inspectionProjectList)){ InspectionProject inspectionProject = new InspectionProject(); inspectionProject.setNum(identityService.getNumByTypeAndLength("InspectionProject",4)); inspectionProject.setName(dayInspectionProjectName); inspectionProject.setDetectionStandard(standard); inspectionProjectService.save(inspectionProject); dailyInspectionStandardDetail.setInspectionProjectId(inspectionProject.getId()); dailyInspectionStandardDetail.setInspectionCycleId(dayInspectionCycle.getId()); dailyInspectionStandardDetailList.add(dailyInspectionStandardDetail); // c = 1; // errorMessage.add("sheet页为"+sheet.getSheetName()+"，设备统一编码为"+ equipmentNum + "的数据导入失败,原因:点检项目不存在，请先维护点检项目！"); // errorLines++; }else { dailyInspectionStandardDetail.setInspectionProjectId(inspectionProjectList.get(0).getId()); dailyInspectionStandardDetail.setInspectionCycleId(dayInspectionCycle.getId()); dailyInspectionStandardDetailList.add(dailyInspectionStandardDetail); //dailyInspectionStandardDetailService.save(dailyInspectionStandardDetail); } } break; } if(strCell.contains("周保养项目")){ b = 1; maintenanceColumnIndex = cell.getColumnIndex(); break; } if(strCell.contains("周保养操作者执行")){ b = 0; dailyInspectionStandardService.save(dailyInspectionStandard); for(DailyInspectionStandardDetail dailyInspectionStandardDetail : dailyInspectionStandardDetailList){ dailyInspectionStandardDetail.setDailyInspectionStandardId(dailyInspectionStandard.getId()); } dailyInspectionStandardDetailService.saveBatch(dailyInspectionStandardDetailList); successLines++; dailyInspectionStandard = null; dailyInspectionStandardDetailList.clear(); } if(b == 1 && c == 0 && maintenanceColumnIndex == cell.getColumnIndex()){ DailyInspectionStandardDetail dailyInspectionStandardDetail = new DailyInspectionStandardDetail(); dailyInspectionStandardDetail.setDailyInspectionStandardId(dailyInspectionStandardId); String weekInspectionProjectName = row.getCell(maintenanceColumnIndex).toString(); String inspectionStandardName = row.getCell(maintenanceColumnIndex+3).toString(); if(StringUtils.isNotBlank(weekInspectionProjectName)){ List inspectionProjectList = inspectionProjectService.lambdaQuery().eq(InspectionProject::getName,weekInspectionProjectName) .eq(InspectionProject::getDetectionStandard,inspectionStandardName).eq(InspectionProject::getDelFlag,CommonConstant.DEL_FLAG_0).list(); if(CollectionUtils.isEmpty(inspectionProjectList)){ InspectionProject inspectionProject = new InspectionProject(); inspectionProject.setNum(identityService.getNumByTypeAndLength("InspectionProject",4)); inspectionProject.setName(weekInspectionProjectName); inspectionProject.setDetectionStandard(inspectionStandardName); inspectionProjectService.save(inspectionProject); dailyInspectionStandardDetail.setInspectionProjectId(inspectionProject.getId()); dailyInspectionStandardDetail.setInspectionCycleId(weekInspectionCycle.getId()); dailyInspectionStandardDetailList.add(dailyInspectionStandardDetail); // c = 1; // errorMessage.add("sheet页为"+sheet.getSheetName()+"，行数为："+row.getRowNum()+"，设备统一编码为"+ equipmentNum + "的数据导入失败,原因:点检项目不存在，请先维护点检项目！"); // errorLines++; }else { dailyInspectionStandardDetail.setInspectionProjectId(inspectionProjectList.get(0).getId()); dailyInspectionStandardDetail.setInspectionCycleId(weekInspectionCycle.getId()); dailyInspectionStandardDetailList.add(dailyInspectionStandardDetail); //dailyInspectionStandardDetailService.save(dailyInspectionStandardDetail); } } break; } } }/*else if("NUMERIC".equals(cell.getCellType().toString())){ System.out.print(cell.getNumericCellValue() + "\t"); } */ } System.out.println(); } } } } catch (IOException e) { e.printStackTrace(); } } return ImportExcelUtil.imporReturnRes(errorLines, successLines, errorMessage); } /** *日常点检标准 根据设备台账 获取对象部门（使用部门） * 2023-7-31 */ @GetMapping("getDepartByEquipment") public Result getDepartByEquipment(@RequestParam("pageNo") Integer pageNo, @RequestParam("pageSize") Integer pageSize, @RequestParam Map params) { IPage> departByEquipment = dailyInspectionStandardService.getDepartByEquipment(pageNo, pageSize, params); return Result.ok(departByEquipment); } /** * 版本升级 */ @PostMapping(value = "/revise") @Transactional(rollbackFor = { Exception.class }) public Result revise(@RequestBody DailyInspectionStandard dailyInspectionStandard) { LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); dailyInspectionStandard.setWritePerson(sysUser.getRealname()); dailyInspectionStandard.setId(""); dailyInspectionStandard.setAssignMode("1"); dailyInspectionStandard.setApprovalStatus("1"); dailyInspectionStandard.setCreateTime(new Date()); dailyInspectionStandard.setTakeEffectTime(null); dailyInspectionStandard.setLoseEfficacyTime(null); dailyInspectionStandard.setApprovalFeedback(null); dailyInspectionStandard.setAuditFeedback(null); dailyInspectionStandard.setAuditPerson(null); dailyInspectionStandard.setApprovalPerson(null); dailyInspectionStandardService.save(dailyInspectionStandard); List dailyInspectionStandardDetaillist = dailyInspectionStandard.getDailyInspectionStandardDetaillist(); DailyInspectionStandardDetail isd = null; for (DailyInspectionStandardDetail dailyInspectionStandardDetail : dailyInspectionStandardDetaillist) { isd = new DailyInspectionStandardDetail(); isd.setDailyInspectionStandardId(dailyInspectionStandard.getId()); isd.setLocation(dailyInspectionStandardDetail.getLocation()); isd.setPhoto(dailyInspectionStandardDetail.getPhoto()); isd.setInspectionProjectId(dailyInspectionStandardDetail.getInspectionProjectId()); isd.setInspectionCycleId(dailyInspectionStandardDetail.getInspectionCycleId()); dailyInspectionStandardDetailService.save(isd); } return Result.OK("添加成功！"); } /** * 日常点检标准升版 * qsw 2023-7-26 */ @RequestMapping("/getReviseVersion") public Result getReviseVersion(@RequestBody DailyInspectionStandard dailyInspectionStandard) { List dailyInspectionStandards = dailyInspectionStandardService.lambdaQuery().eq(DailyInspectionStandard::getNum, dailyInspectionStandard.getNum()) .orderByDesc(DailyInspectionStandard::getVersion).list(); String version = dailyInspectionStandards.get(0).getVersion(); BigDecimal versionB = null; if(StringUtils.isBlank(version)){ versionB = new BigDecimal(0); }else{ versionB = new BigDecimal(version); } BigDecimal versionCode = versionB.add(new BigDecimal(1)); return Result.ok(versionCode.toString()); } /** * 版本生效 * qsw 2023-7-26 */ @RequestMapping(value = "/versionTakeEffect", method = {RequestMethod.PUT,RequestMethod.POST}) @Transactional(rollbackFor = { Exception.class }) public Result versionTakeEffect(@RequestBody DailyInspectionStandard dailyInspectionStandard) { // List dailyInspectionStandards = dailyInspectionStandardService.lambdaQuery() // .eq(DailyInspectionStandard::getNum, dailyInspectionStandard.getNum()) // .eq(DailyInspectionStandard::getVersionStatus, "2").list(); // for (DailyInspectionStandard standard : dailyInspectionStandards) { // standard.setVersionStatus("3"); // standard.setLoseEfficacyTime(new Date()); // dailyInspectionStandardService.updateById(standard); // } // dailyInspectionStandard.setTakeEffectTime(new Date()); LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); dailyInspectionStandard.setLoseEfficacyPerson(sysUser.getRealname()); dailyInspectionStandard.setLoseEfficacyTime(new Date()); boolean b = dailyInspectionStandardService.updateById(dailyInspectionStandard); if (b){ return Result.OK("编辑成功!"); }else{ return Result.error("编辑失败!"); } } /** * 签审流程 * qsw 2023-11-16 */ @RequestMapping(value = "/auditApproval", method = {RequestMethod.PUT,RequestMethod.POST}) @Transactional(rollbackFor = { Exception.class }) public Result auditApproval(@RequestBody DailyInspectionStandard dailyInspectionStandard) { LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); String approvalStatus = dailyInspectionStandard.getApprovalStatus(); if("5".equals(approvalStatus)){//审核通过后，版本生效 List dailyInspectionStandards = dailyInspectionStandardService.lambdaQuery() .eq(DailyInspectionStandard::getNum, dailyInspectionStandard.getNum()) .eq(DailyInspectionStandard::getVersionStatus, "2").list(); for (DailyInspectionStandard standard : dailyInspectionStandards) { standard.setVersionStatus("3"); standard.setLoseEfficacyTime(new Date()); standard.setLoseEfficacyPerson(sysUser.getRealname()); dailyInspectionStandardService.updateById(standard); } dailyInspectionStandard.setApprovalPerson(sysUser.getRealname()); dailyInspectionStandard.setVersionStatus("2"); dailyInspectionStandard.setTakeEffectTime(new Date()); }else if("3".equals(approvalStatus)){ dailyInspectionStandard.setAuditPerson(sysUser.getRealname()); } boolean b = dailyInspectionStandardService.updateById(dailyInspectionStandard); if (b){ if(!"5".equals(approvalStatus)){//已编制 this.inspectionStandardAlert(approvalStatus,dailyInspectionStandard.getNum()); } return Result.OK("审核成功!"); }else{ return Result.error("审核失败!"); } } /** *点检标准签审流程消息提醒 * qsw 2024-3-11 */ void inspectionStandardAlert(String approvalStatus,String standardNum){ LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); SysDict sysDict = sysDictService.getOne(new QueryWrapper().eq("dict_code","info_type"),false); SysDictItem sysDictItem = null; String roleDictItem = ""; if("1".equals(approvalStatus)){//已编制 roleDictItem = "点检标准审核"; sysDictItem = sysDictItemService.getOne(new QueryWrapper() .eq("item_text","点检标准审核") .eq("dict_id",sysDict.getId()),false); }else if("2".equals(approvalStatus)){//驳回编制 roleDictItem = "点检标准编制"; sysDictItem = sysDictItemService.getOne(new QueryWrapper() .eq("item_text","点检标准编制") .eq("dict_id",sysDict.getId()),false); }else if("3".equals(approvalStatus)){//已审核 roleDictItem = "点检标准审批"; sysDictItem = sysDictItemService.getOne(new QueryWrapper() .eq("item_text","点检标准审批") .eq("dict_id",sysDict.getId()),false); }else if("4".equals(approvalStatus)){//驳回审核 roleDictItem = "点检标准审核"; sysDictItem = sysDictItemService.getOne(new QueryWrapper() .eq("item_text","点检标准审核") .eq("dict_id",sysDict.getId()),false); } // else if("5".equals(approvalStatus)){//通过 // roleDictItem = "点检标准审批"; // sysDictItem = sysDictItemService.getOne(new QueryWrapper() // .eq("item_text","点检标准审批") // .eq("dict_id",sysDict.getId()),false); // } String roleCode = sysDictItem.getItemValue(); SysRole sysRole = sysRoleService.getOne(new QueryWrapper().eq("role_code",roleCode),false); List sysUserRoles = sysUserRoleService.list(new QueryWrapper().eq("role_id",sysRole.getId())); for(SysUserRole sysUserRole:sysUserRoles){ SysUser user = sysUserService.getById(sysUserRole.getUserId()); String msg = ""; if("1".equals(approvalStatus)){ msg = "【"+sysUser.getRealname()+"】"+"将【"+standardNum+"】的自主维护点检标准编制成功，请到自主维护点检标准页面审核！"; }else if("2".equals(approvalStatus)){ msg = "【"+sysUser.getRealname()+"】"+"将【"+standardNum+"】的自主维护点检标准已驳回，请到自主维护点检标准页面查看！"; }else if("3".equals(approvalStatus)){ msg = "【"+sysUser.getRealname()+"】"+"将【"+standardNum+"】的自主维护点检标准审核通过，请到自主维护点检标准页面审批！"; }else if("4".equals(approvalStatus)){ msg = "【"+sysUser.getRealname()+"】"+"将【"+standardNum+"】的自主维护点检标准已驳回，请到自主维护点检标准页面查看！"; } // else if("5".equals(approvalStatus)){ // msg = "【"+sysUser.getRealname()+"】"+"将二级保养工单号【"+standardNum+"】的完工移交单确认通过，请到二级保养页面查看！"; // } MessageDTO messageDTO = new MessageDTO(); messageDTO.setTitle("自主维护点检标准签审消息提醒！"); messageDTO.setContent(msg); messageDTO.setCategory(roleDictItem); messageDTO.setFromUser("自主维护点检标准签审消息提醒提醒小助手"); if(user != null){ messageDTO.setToUser(user.getUsername()); } sysBaseApi.sendSysAnnouncement(messageDTO); } } /** * 批量 签审流程 * qsw 2023-12-12 */ @RequestMapping(value = "/auditApprovalBatch", method = {RequestMethod.PUT,RequestMethod.POST}) @Transactional(rollbackFor = { Exception.class }) public Result auditApprovalBatch(@RequestBody DailyInspectionStandard dailyInspectionStandard) { LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); List dailyInspectionStandardlist = dailyInspectionStandard.getDailyInspectionStandardlist(); for (DailyInspectionStandard inspectionStandard : dailyInspectionStandardlist) { String approvalStatus = inspectionStandard.getApprovalStatus(); if("5".equals(approvalStatus)){//审核通过后，版本生效 List dailyInspectionStandards = dailyInspectionStandardService.lambdaQuery() .eq(DailyInspectionStandard::getNum, inspectionStandard.getNum()) .eq(DailyInspectionStandard::getVersionStatus, "2").list(); for (DailyInspectionStandard standard : dailyInspectionStandards) { standard.setVersionStatus("3"); standard.setLoseEfficacyTime(new Date()); standard.setLoseEfficacyPerson(sysUser.getRealname()); dailyInspectionStandardService.updateById(standard); } inspectionStandard.setApprovalPerson(sysUser.getRealname()); inspectionStandard.setVersionStatus("2"); inspectionStandard.setTakeEffectTime(new Date()); }else if("3".equals(approvalStatus)){ inspectionStandard.setAuditPerson(sysUser.getRealname()); } boolean b = dailyInspectionStandardService.updateById(inspectionStandard); if (!b){ return Result.error("审核失败!"); } } return Result.OK("审核成功!"); } }