package com.qianwen.smartman.modules.notify.business;

import com.baomidou.mybatisplus.core.toolkit.BeanUtils;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.List;
import com.qianwen.smartman.common.constant.NotifyConstant;
import com.qianwen.smartman.modules.notify.dto.MaintainDTO;
import com.qianwen.smartman.modules.notify.dto.MaintainOverdueDTO;
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 com.qianwen.smartman.modules.tpm.entity.MaintainPlan;
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/MaintainOverdueBusinessSend.class */
public class MaintainOverdueBusinessSend implements BusinessSend<MaintainPlan> {
    @Autowired
    private IBusinessNotifyService businessNotifyService;
    @Autowired
    private TemplateEngine templateEngine;
    @Autowired
    private IBusinessNotifyStateService businessNotifyStateService;

    @Override // org.springblade.modules.notify.business.BusinessSend
    public void sendMessage(MaintainPlan maintainPlan, NotifyBusinessSendDTO notifyBusinessSend) {
        List<Long> empIds = notifyBusinessSend.getEmpIds();
        List<Long> orgIds = notifyBusinessSend.getOrgIds();
        LocalDateTime maintainDate = maintainPlan.getMaintainDate();
        String code = maintainPlan.getCode() != null ? maintainPlan.getCode() : "-";
        String deviceCode = maintainPlan.getDeviceCode() != null ? maintainPlan.getDeviceCode() : "-";
        String deviceName = maintainPlan.getDeviceName() != null ? maintainPlan.getDeviceName() : "-";
        MaintainDTO maintainDTO = new MaintainDTO();
        maintainDTO.setName(deviceName);
        maintainDTO.setCode(deviceCode);
        List<MaintainDTO> maintains = new ArrayList<>();
        maintains.add(maintainDTO);
        Context context = new Context();
        context.setVariable("machineList", maintains);
        String machinesHtml = this.templateEngine.process("machines", context);
        if (machinesHtml == null) {
            machinesHtml = "";
        }
        MaintainOverdueDTO overdueDTO = new MaintainOverdueDTO();
        overdueDTO.setCode(code);
        if (maintainDate != null) {
            long day = LocalDateTime.now().toLocalDate().toEpochDay() - maintainDate.toLocalDate().toEpochDay();
            if (day < 0) {
                day = 0;
            }
            overdueDTO.setDay(String.valueOf(day));
        }
        DateTimeFormatter df = DateTimeFormatter.ofPattern("yyyy年MM月dd日 HH时mm分");
        overdueDTO.setNow(LocalDateTime.now().format(df));
        overdueDTO.setMaintains(machinesHtml);
        NotifySendDTO notifySendDTO = new NotifySendDTO();
        notifySendDTO.setData(BeanUtils.beanToMap(overdueDTO));
        notifySendDTO.setEmpIds(empIds);
        notifySendDTO.setOrgIds(orgIds);
        notifySendDTO.setBusinessKey(NotifyConstant.MAINTAIN_OVERDUE);
        this.businessNotifyService.sendMessage(notifySendDTO);
    }

    @Override // org.springblade.modules.notify.business.BusinessSend
    @Async
    public void saveState(MaintainPlan maintainPlan, NotifyBusinessSendDTO notifyBusinessSend) {
        List<Long> empIds = notifyBusinessSend.getEmpIds();
        List<Long> orgIds = notifyBusinessSend.getOrgIds();
        Long businessId = maintainPlan.getId();
        this.businessNotifyStateService.saveBatchByIds(NotifyConstant.MAINTAIN_OVERDUE, businessId, empIds, orgIds);
    }
}