package com.qianwen.smartman.modules.notify.business;
|
|
import com.baomidou.mybatisplus.core.toolkit.BeanUtils;
|
import java.util.ArrayList;
|
import java.util.List;
|
import com.qianwen.smartman.common.constant.NotifyConstant;
|
import com.qianwen.core.tool.utils.Func;
|
import com.qianwen.smartman.modules.notify.dto.NotifyBusinessSendDTO;
|
import com.qianwen.smartman.modules.notify.dto.NotifySendDTO;
|
import com.qianwen.smartman.modules.notify.dto.RepairApplySendDTO;
|
import com.qianwen.smartman.modules.notify.dto.RepairMaintainDTO;
|
import com.qianwen.smartman.modules.notify.service.IBusinessNotifyService;
|
import com.qianwen.smartman.modules.tpm.entity.RepairApply;
|
import com.qianwen.smartman.modules.tpm.enums.UrgencyEnum;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.stereotype.Component;
|
import org.thymeleaf.TemplateEngine;
|
import org.thymeleaf.context.Context;
|
|
@Component
|
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/notify/business/RepairApplySend.class */
|
public class RepairApplySend implements BusinessSend<RepairApply> {
|
@Autowired
|
private IBusinessNotifyService businessNotifyService;
|
@Autowired
|
private TemplateEngine templateEngine;
|
|
@Override // org.springblade.modules.notify.business.BusinessSend
|
public void sendMessage(RepairApply repairApply, NotifyBusinessSendDTO notifyBusinessSendDTO) {
|
String deviceCode = repairApply.getDeviceCode() != null ? repairApply.getDeviceCode() : "-";
|
String deviceName = repairApply.getDeviceName() != null ? repairApply.getDeviceName() : "-";
|
Integer urgency = repairApply.getUrgency();
|
String description = Func.isNotBlank(repairApply.getDescription()) ? repairApply.getDescription() : "-";
|
String code = repairApply.getApplyCode() != null ? repairApply.getApplyCode() : "-";
|
String malfunctionName = Func.isNotBlank(repairApply.getMalfunctionName()) ? repairApply.getMalfunctionName() : "-";
|
List<Long> empIds = notifyBusinessSendDTO.getEmpIds();
|
List<Long> orgIds = notifyBusinessSendDTO.getOrgIds();
|
String urgencyStr = "-";
|
if (Func.isNotEmpty(urgency)) {
|
if (urgency.equals(Integer.valueOf(UrgencyEnum.U1.getType()))) {
|
urgencyStr = UrgencyEnum.U1.getDesc();
|
} else if (urgency.equals(Integer.valueOf(UrgencyEnum.U2.getType()))) {
|
urgencyStr = UrgencyEnum.U2.getDesc();
|
} else {
|
urgencyStr = UrgencyEnum.U3.getDesc();
|
}
|
}
|
RepairApplySendDTO repairApplySendDTO = new RepairApplySendDTO();
|
repairApplySendDTO.setCode(code);
|
repairApplySendDTO.setDeviceCode(deviceCode);
|
repairApplySendDTO.setDeviceName(deviceName);
|
repairApplySendDTO.setUrgency(urgencyStr);
|
repairApplySendDTO.setMalfunctionName(malfunctionName);
|
repairApplySendDTO.setDescription(description);
|
RepairMaintainDTO maintainDTO = new RepairMaintainDTO();
|
maintainDTO.setDeviceCode(deviceCode);
|
maintainDTO.setDeviceName(deviceName);
|
maintainDTO.setUrgency(urgencyStr);
|
maintainDTO.setDescription(description);
|
maintainDTO.setMalfunctionName(malfunctionName);
|
List<RepairMaintainDTO> maintains = new ArrayList<>();
|
maintains.add(maintainDTO);
|
Context context = new Context();
|
context.setVariable("repairMaintainTable", maintains);
|
String machinesHtml = this.templateEngine.process("repairMaintainTable", context);
|
repairApplySendDTO.setRepairMaintainTable(machinesHtml);
|
NotifySendDTO notifySendDTO = new NotifySendDTO();
|
notifySendDTO.setData(BeanUtils.beanToMap(repairApplySendDTO));
|
notifySendDTO.setEmpIds(empIds);
|
notifySendDTO.setOrgIds(orgIds);
|
notifySendDTO.setBusinessKey(NotifyConstant.MAINTENANCE_APPLY);
|
this.businessNotifyService.sendMessage(notifySendDTO);
|
}
|
|
@Override // org.springblade.modules.notify.business.BusinessSend
|
@Async
|
public void saveState(RepairApply repairApply, NotifyBusinessSendDTO notifyBusinessSend) {
|
sendMessage(repairApply, notifyBusinessSend);
|
}
|
}
|
