package com.qianwen.smartman.modules.notify.business;
|
|
import com.baomidou.mybatisplus.core.toolkit.BeanUtils;
|
import java.util.LinkedList;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
import org.jeewx.api.core.util.DateUtils;
|
import com.qianwen.smartman.common.constant.DateConstant;
|
import com.qianwen.smartman.common.constant.NotifyConstant;
|
import com.qianwen.core.tool.utils.Func;
|
import com.qianwen.smartman.modules.andon.dto.AndonMessageDTO;
|
import com.qianwen.smartman.modules.andon.dto.AndonMessageSendDTO;
|
import com.qianwen.smartman.modules.andon.vo.AndonMessageSendVO;
|
import com.qianwen.smartman.modules.notify.dto.NotifyBusinessSendDTO;
|
import com.qianwen.smartman.modules.notify.dto.NotifySendDTO;
|
import com.qianwen.smartman.modules.notify.service.IBusinessNotifyService;
|
import com.qianwen.smartman.modules.notify.service.IBusinessNotifyStateService;
|
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/AndonTakeOverSend.class */
|
public class AndonTakeOverSend implements BusinessSend<AndonMessageSendVO> {
|
@Autowired
|
private IBusinessNotifyService businessNotifyService;
|
@Autowired
|
private TemplateEngine templateEngine;
|
@Autowired
|
private IBusinessNotifyStateService businessNotifyStateService;
|
|
@Override // org.springblade.modules.notify.business.BusinessSend
|
public void saveState(AndonMessageSendVO andonMessageSendVO, NotifyBusinessSendDTO notifyBusinessSend) {
|
String reasons;
|
String workstationCode = Func.isNotBlank(andonMessageSendVO.getWorkstationCode()) ? andonMessageSendVO.getWorkstationCode() : "-";
|
String workstationName = Func.isNotBlank(andonMessageSendVO.getWorkstationName()) ? andonMessageSendVO.getWorkstationName() : "-";
|
String typeCode = Func.isNotBlank(andonMessageSendVO.getTypeCode()) ? andonMessageSendVO.getTypeCode() : "-";
|
String typeName = Func.isNotBlank(andonMessageSendVO.getTypeName()) ? andonMessageSendVO.getTypeName() : "-";
|
if (Func.isNotEmpty(andonMessageSendVO.getReasonList())) {
|
reasons = (String) andonMessageSendVO.getReasonList().stream().map(s -> {
|
return "(" + s.getReasonCode() + ")" + s.getReasonName();
|
}).collect(Collectors.joining(";"));
|
} else {
|
reasons = "-";
|
}
|
String callEmpName = Func.isNotBlank(andonMessageSendVO.getCallEmpName()) ? andonMessageSendVO.getCallEmpName() : "-";
|
String callTime = DateUtils.datetoStr(andonMessageSendVO.getCallTime(), DateConstant.PATTERN_DATE_TIME);
|
List<Long> empIds = notifyBusinessSend.getEmpIds();
|
List<Long> orgIds = notifyBusinessSend.getOrgIds();
|
AndonMessageSendDTO andonMessageSendDTO = new AndonMessageSendDTO();
|
andonMessageSendDTO.setWorkstationName("(" + workstationCode + ")" + workstationName).setTypeName("(" + typeCode + ")" + typeName).setReasons(reasons).setCallEmpName(callEmpName).setCallTime(callTime);
|
AndonMessageDTO andonMessageDTO = new AndonMessageDTO();
|
andonMessageDTO.setWorkstationName("(" + workstationCode + ")" + workstationName).setTypeName("(" + typeCode + ")" + typeName).setReasons(reasons).setCallEmpName(callEmpName).setCallTime(callTime);
|
List<AndonMessageDTO> messages = new LinkedList<>();
|
messages.add(andonMessageDTO);
|
Context context = new Context();
|
context.setVariable("andonCallTable", messages);
|
String andonHtml = this.templateEngine.process("andonCallTable", context);
|
andonMessageSendDTO.setAndonCallTable(andonHtml);
|
NotifySendDTO notifySendDTO = new NotifySendDTO();
|
notifySendDTO.setData(BeanUtils.beanToMap(andonMessageSendDTO));
|
notifySendDTO.setEmpIds(empIds);
|
notifySendDTO.setOrgIds(orgIds);
|
notifySendDTO.setBusinessKey(NotifyConstant.ANDON_TAKE_OVER);
|
this.businessNotifyService.sendMessage(notifySendDTO);
|
}
|
|
@Override // org.springblade.modules.notify.business.BusinessSend
|
@Async
|
public void sendMessage(AndonMessageSendVO andonMessageSendVO, NotifyBusinessSendDTO notifyBusinessSend) {
|
Long businessId = andonMessageSendVO.getId();
|
this.businessNotifyStateService.saveBatchByIds(NotifyConstant.MAINTENANCE_WARNING, businessId, notifyBusinessSend.getEmpIds(), notifyBusinessSend.getOrgIds());
|
}
|
}
|
