From 643e1af242a139b408969dfa1ba2f52e554c8c41 Mon Sep 17 00:00:00 2001 From: “linengliang” <vanSuperEnergy@163.com> Date: 星期三, 25 十月 2023 17:03:53 +0800 Subject: [PATCH] 已经处理的问题 --- lxzn-module-eam/src/main/java/org/jeecg/modules/eam/controller/EquipmentReportRepairController.java | 28 ++++++++++++++++++++++++---- 1 files changed, 24 insertions(+), 4 deletions(-) diff --git a/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/controller/EquipmentReportRepairController.java b/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/controller/EquipmentReportRepairController.java index 5710b28..f82e765 100644 --- a/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/controller/EquipmentReportRepairController.java +++ b/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/controller/EquipmentReportRepairController.java @@ -7,6 +7,7 @@ import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; +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; @@ -19,11 +20,15 @@ import org.jeecg.modules.eam.service.IEamEquipmentService; import org.jeecg.modules.eam.service.IEquipmentReportRepairService; import org.jeecg.modules.eam.service.IFaultDescriptionService; +import org.jeecg.modules.system.entity.SysUser; +import org.jeecg.modules.system.service.ISysUserService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Lazy; +import org.springframework.transaction.annotation.Transactional; import org.springframework.web.bind.annotation.*; import javax.servlet.http.HttpServletRequest; +import java.util.List; import java.util.Map; /** @@ -44,13 +49,12 @@ @Autowired private ISysBaseAPI sysBaseApi; + @Autowired + private ISysUserService userService; @Autowired @Lazy private IFaultDescriptionService faultDescriptionService; -// @Autowired -// private IUploadRelaService uploadRelaService; - /** * 鍒嗛〉鍒楄〃鏌ヨ * @@ -89,6 +93,7 @@ @AutoLog(value = "mom_eam_equipment_report_repair-娣诲姞") @ApiOperation(value = "mom_eam_equipment_report_repair-娣诲姞", notes = "mom_eam_equipment_report_repair-娣诲姞") @PostMapping(value = "/add") + @Transactional(rollbackFor = {Exception.class}) public Result<String> add(@RequestBody EquipmentReportRepair equipmentReportRepair) { equipmentReportRepair.setStatus("1"); equipmentReportRepair.setSource("1"); @@ -98,7 +103,21 @@ equipment.setEquipmentStatus("2"); String teamId = equipment.getTeamId(); if(StringUtils.isNotBlank(teamId)){ - + List<SysUser> sysUsers = userService.list(new QueryWrapper<SysUser>() + .eq("team_id",teamId) + .eq("del_flag",0)); + for(SysUser user:sysUsers){ + String msg = "缁熶竴缂栧彿涓恒��"+equipment.getNum()+"銆戠殑璁惧闇�瑕佺淮淇紝璇风Щ姝ヨ嚦鏁呴殰鎶ヤ慨鏌ョ湅"; + MessageDTO messageDTO = new MessageDTO(); + messageDTO.setTitle("鏁呴殰鎶ヤ慨鎻愰啋"); + messageDTO.setContent(msg); + messageDTO.setCategory("鏁呴殰鎶ヤ慨鎻愰啋"); + messageDTO.setFromUser("鏁呴殰鎶ヤ慨鎻愰啋灏忓姪鎵�"); + messageDTO.setToUser(user.getUsername()); + sysBaseApi.sendSysAnnouncement(messageDTO); + } + }else { + return Result.error("璇ヨ澶囧皻鏈淮鎶ょ淮淇彮缁�,璇风淮鎶ゅ悗鍐嶆姤淇�"); } //娣诲姞鏁呴殰鎻忚堪淇℃伅 FaultDescription faultDescription = new FaultDescription(); @@ -106,6 +125,7 @@ faultDescription.setFaultId(equipmentReportRepair.getId()); faultDescription.setPhoto(equipmentReportRepair.getPhoto()); faultDescriptionService.save(faultDescription); + equipmentService.updateById(equipment); return Result.OK("娣诲姞鎴愬姛锛�"); } -- Gitblit v1.9.3