package org.jeecg.modules.eam.controller; import cn.hutool.core.collection.CollectionUtil; import com.baomidou.mybatisplus.core.metadata.IPage; 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.jeecg.common.api.vo.Result; import org.jeecg.common.aspect.annotation.AutoLog; import org.jeecg.common.system.base.controller.JeecgController; import org.jeecg.modules.eam.constant.BusinessCodeConst; import org.jeecg.modules.eam.constant.TechnicalStatusEvaluationStandardEnum; import org.jeecg.modules.eam.entity.EamTechnicalStatusEvaluationStandard; import org.jeecg.modules.eam.request.EamTechnicalStatusEvaluationStandardRequest; import org.jeecg.modules.eam.service.IEamTechnicalStatusEvaluationStandardService; import org.jeecg.modules.system.service.ISysBusinessCodeRuleService; 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 javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.util.HashMap; import java.util.LinkedHashMap; import java.util.Map; /** * @Description: 技术状态鉴定规范 * @Author: jeecg-boot * @Date: 2025-07-07 * @Version: V1.0 */ @Slf4j @Api(tags = "技术状态鉴定规范") @RestController @RequestMapping("/eam/eamTechnicalStatusEvaluationStandard") public class EamTechnicalStatusEvaluationStandardController extends JeecgController { @Autowired private IEamTechnicalStatusEvaluationStandardService eamTechnicalStatusEvaluationStandardService; @Autowired private ISysBusinessCodeRuleService businessCodeRuleService; /** * 分页列表查询 * * @param eamTechnicalStatusEvaluationStandard * @param pageNo * @param pageSize * @return */ @ApiOperation(value = "技术状态鉴定规范-分页列表查询", notes = "技术状态鉴定规范-分页列表查询") @GetMapping(value = "/list") public Result queryPageList(EamTechnicalStatusEvaluationStandard eamTechnicalStatusEvaluationStandard, @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo, @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize) { Page page = new Page<>(pageNo, pageSize); IPage pageList = eamTechnicalStatusEvaluationStandardService.queryPageList(page, eamTechnicalStatusEvaluationStandard); return Result.OK(pageList); } /** * 添加 * * @param request * @return */ @AutoLog(value = "技术状态鉴定规范-添加") @ApiOperation(value = "技术状态鉴定规范-添加", notes = "技术状态鉴定规范-添加") @PostMapping(value = "/add") public Result add(@RequestBody EamTechnicalStatusEvaluationStandardRequest request) { if (request == null) { return Result.error("添加的对象不能为空!"); } if (CollectionUtil.isEmpty(request.getTableDetailList())) { return Result.error("检查项不能为空!"); } String codeSeq = businessCodeRuleService.generateBusinessCodeSeq(BusinessCodeConst.TECHNICAL_STATUS_EVALUATION_STANDARD_CODE_RULE); request.setStandardCode(codeSeq); boolean b = eamTechnicalStatusEvaluationStandardService.addEamTechnicalStatusEvaluationStandard(request); if (!b) { return Result.error("添加失败!"); } return Result.OK("添加成功!"); } /** * 编辑 * * @param request * @return */ @AutoLog(value = "技术状态鉴定规范-编辑") @ApiOperation(value = "技术状态鉴定规范-编辑", notes = "技术状态鉴定规范-编辑") @PutMapping(value = "/edit") public Result edit(@RequestBody EamTechnicalStatusEvaluationStandardRequest request) { if (request == null) { return Result.error("添加的对象不能为空!"); } if (CollectionUtil.isEmpty(request.getTableDetailList())) { return Result.error("检查项不能为空!"); } boolean b = eamTechnicalStatusEvaluationStandardService.editEamTechnicalStatusEvaluationStandard(request); if (!b) { return Result.error("编辑失败!"); } return Result.OK("编辑成功!"); } /** * 升版 * * @param request * @return */ @AutoLog(value = "技术状态鉴定规范-升版") @ApiOperation(value = "技术状态鉴定规范-升版", notes = "技术状态鉴定规范-升版") @PutMapping(value = "/upgrade") public Result upgrade(@RequestBody EamTechnicalStatusEvaluationStandardRequest request) { if (request == null) { return Result.error("添加的对象不能为空!"); } if (CollectionUtil.isEmpty(request.getTableDetailList())) { return Result.error("保养项不能为空!"); } String codeSeq = businessCodeRuleService.generateBusinessCodeSeq(BusinessCodeConst.TECHNICAL_STATUS_EVALUATION_STANDARD_CODE_RULE); request.setStandardCode(codeSeq); boolean b = eamTechnicalStatusEvaluationStandardService.upgrade(request); if (!b) { return Result.error("升版失败!"); } 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) { EamTechnicalStatusEvaluationStandard eamTechnicalStatusEvaluationStandard = eamTechnicalStatusEvaluationStandardService.getById(id); return Result.OK(eamTechnicalStatusEvaluationStandard); } /** * 提交 * @param id * @return */ @AutoLog(value = "技术状态鉴定规范-提交") @ApiOperation(value = "技术状态鉴定规范-提交", notes = "技术状态鉴定规范-提交") @GetMapping(value = "/submit") public Result submit(@RequestParam(name = "id", required = true) String id) { EamTechnicalStatusEvaluationStandard entity = eamTechnicalStatusEvaluationStandardService.getById(id); if (entity != null) { entity.setStandardStatus(TechnicalStatusEvaluationStandardEnum.ENABLE.name()); eamTechnicalStatusEvaluationStandardService.updateById(entity); } return Result.OK("提交成功!"); } /** * 安全装置检查明细导入 * * @param request * @return */ @PostMapping(value = "/importSafetyEquipmentCheck") public Result importSafetyEquipmentCheck(HttpServletRequest request) { MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request; Map results = new LinkedHashMap<>(); Map fileMap = multipartRequest.getFileMap(); // 统计导入结果 int successCount = 0; int failureCount = 0; for (Map.Entry entity : fileMap.entrySet()) { MultipartFile file = entity.getValue(); String fileName = file.getOriginalFilename(); Result importResult = eamTechnicalStatusEvaluationStandardService.importSafetyEquipmentCheck(file); if (importResult.isSuccess()) { results.put(fileName, "成功: " + importResult.getMessage()); successCount++; } else { results.put(fileName, "失败: " + importResult.getMessage()); failureCount++; } } // 构建最终响应 Map response = new HashMap<>(); response.put("results", results); response.put("totalFiles", fileMap.size()); response.put("successCount", successCount); response.put("failureCount", failureCount); if (failureCount > 0) { return Result.error("部分文件导入失败", response); } return Result.ok("所有文件导入成功"+response); } /** * 安全装置检查明细导入 * * @param request * @param response * @return */ @PostMapping(value = "/importPrecisionCheck") public Result importPrecisionCheck(HttpServletRequest request, HttpServletResponse response) { return null; } /** * 安全装置检查明细导入 * * @param request * @param response * @return */ @PostMapping(value = "/importOtherCheck") public Result importOtherCheck(HttpServletRequest request, HttpServletResponse response) { return null; } }