From 4f3a98f19143865cdc1de4791e8a95d96bd40c65 Mon Sep 17 00:00:00 2001
From: maven <2163098428@qq.com>
Date: 星期五, 01 八月 2025 13:27:59 +0800
Subject: [PATCH] yys 密码已重置
---
cnas-device/src/main/java/com/ruoyi/device/service/impl/DeviceTraceabilityManagementServiceImpl.java | 292 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 292 insertions(+), 0 deletions(-)
diff --git a/cnas-device/src/main/java/com/ruoyi/device/service/impl/DeviceTraceabilityManagementServiceImpl.java b/cnas-device/src/main/java/com/ruoyi/device/service/impl/DeviceTraceabilityManagementServiceImpl.java
new file mode 100644
index 0000000..fd4acd1
--- /dev/null
+++ b/cnas-device/src/main/java/com/ruoyi/device/service/impl/DeviceTraceabilityManagementServiceImpl.java
@@ -0,0 +1,292 @@
+package com.ruoyi.device.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.deepoove.poi.XWPFTemplate;
+import com.deepoove.poi.config.Configure;
+import com.ruoyi.common.constant.MenuJumpPathConstants;
+import com.ruoyi.common.core.domain.Result;
+import com.ruoyi.common.core.domain.entity.InformationNotification;
+import com.ruoyi.common.core.domain.entity.User;
+import com.ruoyi.common.utils.QueryWrappers;
+import com.ruoyi.common.utils.SecurityUtils;
+import com.ruoyi.common.utils.WxCpUtils;
+import com.ruoyi.device.dto.DeviceTraceabilityManagementDetailsDto;
+import com.ruoyi.device.dto.DeviceTraceabilityManagementDto;
+import com.ruoyi.device.mapper.DeviceTraceabilityManagementDetailsMapper;
+import com.ruoyi.device.mapper.DeviceTraceabilityManagementMapper;
+import com.ruoyi.device.pojo.DeviceTraceabilityManagement;
+import com.ruoyi.device.pojo.DeviceTraceabilityManagementDetails;
+import com.ruoyi.device.service.DeviceTraceabilityManagementDetailsService;
+import com.ruoyi.device.service.DeviceTraceabilityManagementService;
+import com.ruoyi.inspect.util.HackLoopTableRenderPolicy;
+import com.ruoyi.inspect.util.UserUtils;
+import com.ruoyi.system.mapper.UserMapper;
+import com.ruoyi.system.service.InformationNotificationService;
+import org.apache.commons.collections4.CollectionUtils;
+import org.springframework.beans.BeanUtils;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import javax.servlet.http.HttpServletResponse;
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.net.URLEncoder;
+import java.time.LocalDateTime;
+import java.util.HashMap;
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ * <p>
+ * 璁惧閲忓�兼函婧愯鍒掕〃 鏈嶅姟瀹炵幇绫�
+ * </p>
+ *
+ * @author 姹熻嫃榈烽洀缃戠粶绉戞妧鏈夐檺鍏徃
+ * @since 2024-12-20 02:27:44
+ */
+@Service
+public class DeviceTraceabilityManagementServiceImpl extends ServiceImpl<DeviceTraceabilityManagementMapper, DeviceTraceabilityManagement> implements DeviceTraceabilityManagementService {
+
+ @Resource
+ private DeviceTraceabilityManagementDetailsService deviceTraceabilityManagementDetailsService;
+
+ @Resource
+ private DeviceTraceabilityManagementDetailsMapper deviceTraceabilityManagementDetailsMapper;
+ @Resource
+ private ThreadPoolTaskExecutor threadPoolTaskExecutor;
+ @Resource
+ private InformationNotificationService informationNotificationService;
+
+ @Resource
+ private UserMapper userMapper;
+
+ /**
+ * 鍒嗛〉鏌ヨ璁惧閲忓�兼函婧愯鍒�
+ *
+ * @param page
+ * @return
+ */
+ @Override
+ public Result<IPage<DeviceTraceabilityManagement>> selectDeviceTraceabilityManagementByPage(Page page, DeviceTraceabilityManagementDto deviceTraceabilityManagementDto) {
+ IPage<DeviceTraceabilityManagement> iPage = baseMapper.selectDeviceParameterPage(page, QueryWrappers.queryWrappers(deviceTraceabilityManagementDto));
+ return Result.success(iPage);
+ }
+
+
+ /**
+ * 鏂板璁惧閲忓�兼函婧愯鍒�
+ *
+ * @param deviceTraceabilityManagementDto 璁惧閲忓�兼函婧愯鍒�
+ */
+ @Override
+ public Result addTraceabilityManagement(DeviceTraceabilityManagementDto deviceTraceabilityManagementDto) {
+ Integer userId = SecurityUtils.getUserId().intValue();
+ User user = userMapper.selectById(userId);
+ deviceTraceabilityManagementDto.setCompilerId(userId);
+ deviceTraceabilityManagementDto.setCompiler(user.getName());
+ deviceTraceabilityManagementDto.setDatePreparation(LocalDateTime.now());
+
+ // 鏌ヨ瀹℃牳浜篿d
+ if (deviceTraceabilityManagementDto.getAuditId() != null) {
+ User auditUser = userMapper.selectById(deviceTraceabilityManagementDto.getAuditId());
+ deviceTraceabilityManagementDto.setAudit(auditUser.getName());
+ }
+ this.saveOrUpdate(deviceTraceabilityManagementDto);
+
+ // 璇︽儏璧嬪�煎苟淇濆瓨
+ List<DeviceTraceabilityManagementDetailsDto> deviceTraceabilityManagementDetails = deviceTraceabilityManagementDto.getDeviceTraceabilityManagementDetails();
+ if (CollectionUtils.isNotEmpty(deviceTraceabilityManagementDetails)) { // 璇︽儏涓嶄负绌�
+ List<DeviceTraceabilityManagementDetails> collect = deviceTraceabilityManagementDetails.stream().map(detailsDto -> {
+ detailsDto.setTraceabilityManagementId(deviceTraceabilityManagementDto.getTraceabilityManagementId()); // 閲忓�兼函婧愯鍒扞D
+ DeviceTraceabilityManagementDetails details = new DeviceTraceabilityManagementDetails();
+ BeanUtils.copyProperties(detailsDto, details);
+ return details;
+ }).collect(Collectors.toList());
+ deviceTraceabilityManagementDetailsService.saveBatch(collect);
+ }
+
+ return Result.success();
+ }
+
+ /**
+ * 淇敼璁惧閲忓�兼函婧愯鍒�
+ *
+ * @param deviceTraceabilityManagementDto 璁惧閲忓�兼函婧愯鍒�
+ */
+ @Override
+ public Result updateTraceabilityManagement(DeviceTraceabilityManagementDto deviceTraceabilityManagementDto) {
+ // 鏌ヨ瀹℃牳浜篿d
+ if (deviceTraceabilityManagementDto.getAuditId() != null) {
+ User auditUser = userMapper.selectById(deviceTraceabilityManagementDto.getAuditId());
+ deviceTraceabilityManagementDto.setAudit(auditUser.getName());
+ }
+ this.saveOrUpdate(deviceTraceabilityManagementDto);
+
+ // 鍒犻櫎鍘熸湰鐨勮鎯�
+ deviceTraceabilityManagementDetailsService.remove(Wrappers.<DeviceTraceabilityManagementDetails>lambdaQuery().eq(DeviceTraceabilityManagementDetails::getTraceabilityManagementId, deviceTraceabilityManagementDto.getTraceabilityManagementId()));
+ // 璇︽儏璧嬪�煎苟淇濆瓨
+ List<DeviceTraceabilityManagementDetailsDto> deviceTraceabilityManagementDetails = deviceTraceabilityManagementDto.getDeviceTraceabilityManagementDetails();
+ if (CollectionUtils.isNotEmpty(deviceTraceabilityManagementDetails)) { // 璇︽儏涓嶄负绌�
+ List<DeviceTraceabilityManagementDetails> collect = deviceTraceabilityManagementDetails.stream().map(detailsDto -> {
+ detailsDto.setTraceabilityManagementId(deviceTraceabilityManagementDto.getTraceabilityManagementId()); // 閲忓�兼函婧愯鍒扞D
+ DeviceTraceabilityManagementDetails details = new DeviceTraceabilityManagementDetails();
+ BeanUtils.copyProperties(detailsDto, details);
+ return details;
+ }).collect(Collectors.toList());
+ deviceTraceabilityManagementDetailsService.saveBatch(collect);
+ }
+ return Result.success();
+ }
+
+ /**
+ * 鍒犻櫎璁惧閲忓�兼函婧愯鍒�
+ *
+ * @param deviceTraceabilityManagementDto 璁惧閲忓�兼函婧愯鍒�
+ */
+ @Override
+ public Result deleteTraceabilityManagement(DeviceTraceabilityManagementDto deviceTraceabilityManagementDto) {
+ this.removeById(deviceTraceabilityManagementDto);
+ deviceTraceabilityManagementDetailsService.remove(Wrappers.<DeviceTraceabilityManagementDetails>lambdaQuery().eq(DeviceTraceabilityManagementDetails::getTraceabilityManagementId, deviceTraceabilityManagementDto.getTraceabilityManagementId()));
+ return Result.success();
+ }
+
+ /**
+ * 鏌ヨ璁惧閲忓�兼函婧愯鍒掕鎯�
+ *
+ * @param traceabilityManagementId 璁惧閲忓�兼函婧愯鍒抜d
+ */
+ @Override
+ public Result<DeviceTraceabilityManagementDto> getTraceabilityManagementDetail(Integer traceabilityManagementId) {
+ // 鏌ヨ璁惧閲忓�兼函婧愯鍒�
+ DeviceTraceabilityManagement deviceTraceabilityManagement = baseMapper.selectById(traceabilityManagementId);
+ // 鏌ヨ璇︽儏
+ DeviceTraceabilityManagementDto deviceTraceabilityManagementDto = new DeviceTraceabilityManagementDto();
+ BeanUtils.copyProperties(deviceTraceabilityManagement, deviceTraceabilityManagementDto);
+ deviceTraceabilityManagementDto.setDeviceTraceabilityManagementDetails(deviceTraceabilityManagementDetailsMapper.deviceTraceabilityManagementDetailsList(traceabilityManagementId));
+ return Result.success(deviceTraceabilityManagementDto);
+ }
+
+ /**
+ * 鎻愪氦鎵瑰噯
+ * @param deviceTraceabilityManagementDto
+ * @return
+ */
+ @Override
+ public Result submitReviewTraceabilityManagementStatus(DeviceTraceabilityManagementDto deviceTraceabilityManagementDto) {
+ User audit = userMapper.selectById(deviceTraceabilityManagementDto.getAuditId());
+ this.update(Wrappers.<DeviceTraceabilityManagement>lambdaUpdate()
+ .eq(DeviceTraceabilityManagement::getTraceabilityManagementId, deviceTraceabilityManagementDto.getTraceabilityManagementId())
+ .set(DeviceTraceabilityManagement::getAuditId, audit.getId())
+ .set(DeviceTraceabilityManagement::getAudit, audit.getName())
+ .set(DeviceTraceabilityManagement::getAuditDate, null)
+ .set(DeviceTraceabilityManagement::getStatus, null)
+ .set(DeviceTraceabilityManagement::getAuditRemark, null));
+
+ DeviceTraceabilityManagement deviceTraceabilityManagement = baseMapper.selectById(deviceTraceabilityManagementDto.getTraceabilityManagementId());
+
+ // 鍙戦�佹秷鎭�
+ Integer userId = SecurityUtils.getUserId().intValue();
+ User user = userMapper.selectById(userId);
+ // 娑堟伅鍙戦��
+ InformationNotification info = new InformationNotification();
+ // 鍙戦�佷汉
+ info.setCreateUser(user.getName());
+ info.setMessageType("6");
+ info.setTheme("CNAS璁惧閲忓�兼函婧愯鍒掓壒鍑嗛�氱煡");
+ info.setContent(deviceTraceabilityManagement.getPlanYear() + "骞寸殑璁惧閲忓�兼函婧愯鍒掑緟鎵瑰噯");
+ info.setSenderId(userId);
+ // 鎺ユ敹浜�
+ info.setConsigneeId(audit.getId());
+ info.setJumpPath(MenuJumpPathConstants.DEVICE);
+ informationNotificationService.addInformationNotification(info);
+
+ // 鍙戦�佷紒涓氬井淇￠�氱煡
+ threadPoolTaskExecutor.execute(() -> {
+ String message = "";
+ message += "CNAS璁惧閲忓�兼函婧愯鍒掓牳閫氱煡";
+ message += "\n璇峰幓璧勬簮绠＄悊-璁惧涓�灞傜洰褰�-璁惧閲忓�兼函婧愯鍒掑～鍐�";
+ message += "\n" + deviceTraceabilityManagement.getPlanYear() + "骞寸殑璁惧閲忓�兼函婧愯鍒掑緟鎵瑰噯";
+ //鍙戦�佷紒涓氬井淇℃秷鎭�氱煡
+ try {
+ WxCpUtils.inform(audit.getAccount(), message, null);
+ } catch (Exception e) {
+ throw new RuntimeException(e);
+ }
+ });
+ return Result.success();
+ }
+
+ /**
+ * 瀹℃牳璁惧閲忓�兼函婧愯鍒�
+ *
+ * @param deviceTraceabilityManagementDto 璁惧閲忓�兼函婧愯鍒�
+ */
+ @Override
+ public Result reviewTraceabilityManagementStatus(DeviceTraceabilityManagementDto deviceTraceabilityManagementDto) {
+ LambdaUpdateWrapper<DeviceTraceabilityManagement> wrapper = Wrappers.<DeviceTraceabilityManagement>lambdaUpdate()
+ .eq(DeviceTraceabilityManagement::getTraceabilityManagementId, deviceTraceabilityManagementDto.getTraceabilityManagementId())
+ .set(DeviceTraceabilityManagement::getAuditDate, LocalDateTime.now())
+ .set(DeviceTraceabilityManagement::getStatus, deviceTraceabilityManagementDto.getStatus()) // 瀹℃牳鐘舵��
+ .set(DeviceTraceabilityManagement::getAuditRemark, deviceTraceabilityManagementDto.getAuditRemark());// 瀹℃牳澶囨敞
+
+ this.update(wrapper); // 鏇存柊
+ return Result.success();
+ }
+
+ /**
+ * 瀵煎嚭璁惧閲忓�兼函婧愯鍒�
+ *
+ * @param traceabilityManagementId 璁惧閲忓�兼函婧愯鍒抜d
+ */
+ @Override
+ public Result exportDeviceTraceabilityManagementDto(Integer traceabilityManagementId, HttpServletResponse response) {
+ // 鏌ヨ璁惧淇濆吇璁″垝
+ DeviceTraceabilityManagementDto deviceTraceabilityManagement = baseMapper.selectDeviceTraceabilityManagementById(traceabilityManagementId);
+
+ // 鏌ヨ璁惧淇濆吇璁″垝璇︽儏
+ List<DeviceTraceabilityManagementDetailsDto> deviceTraceabilityManagementDetailsDtoList = deviceTraceabilityManagementDetailsMapper.deviceTraceabilityManagementDetailsList(traceabilityManagementId);
+ // 璁剧疆搴忓彿
+ deviceTraceabilityManagementDetailsDtoList.forEach(deviceTraceabilityManagementDetails -> {
+ deviceTraceabilityManagementDetails.setIndex(deviceTraceabilityManagementDetailsDtoList.indexOf(deviceTraceabilityManagementDetails) + 1);
+ });
+
+ // 鑾峰彇璺緞
+ InputStream inputStream = this.getClass().getResourceAsStream("/static/word/traceability-management-details.docx");
+ Configure configure = Configure.builder()
+ .bind("deviceTraceabilityManagementDetailsDtoList", new HackLoopTableRenderPolicy())
+ .build();
+ XWPFTemplate template = XWPFTemplate.compile(inputStream, configure).render(
+ new HashMap<String, Object>() {{
+ put("deviceTraceabilityManagement", deviceTraceabilityManagement);
+ put("deviceTraceabilityManagementDetailsDtoList", deviceTraceabilityManagementDetailsDtoList);
+ // 缂栧埗浜虹鍚嶅湴鍧�
+ put("compilerUrl", UserUtils.getFinalUserSignatureUrl(deviceTraceabilityManagement.getCompilerId()));
+ // 瀹℃牳浜虹鍚嶅湴鍧�
+ put("auditUrl", UserUtils.getFinalUserSignatureUrl(deviceTraceabilityManagement.getAuditId()));
+ }});
+
+ try {
+ response.setContentType("application/msword");
+ String finalFileName = deviceTraceabilityManagement.getFileName() == null ? "" : deviceTraceabilityManagement.getFileName() + "_";
+ String fileName = URLEncoder.encode(
+ finalFileName+ "璁惧閲忓�兼函婧愯鍒�", "UTF-8");
+ response.setHeader("Content-disposition",
+ "attachment;filename=" + fileName + ".docx");
+ OutputStream os = response.getOutputStream();
+ template.write(os);
+ os.flush();
+ os.close();
+ inputStream.close();
+ } catch (Exception e) {
+ e.printStackTrace();
+ throw new RuntimeException("瀵煎嚭澶辫触");
+ }
+ return Result.success();
+ }
+
+}
--
Gitblit v1.9.3