AnniversaryNoticeService.java 3.57 KB
package com.pipihelper.project.feishu.service.anniversary;

import com.pipihelper.project.feishu.dto.FeiShuConfig;
import com.pipihelper.project.feishu.dto.employee.FeiShuEmployeeDTO;
import com.pipihelper.project.feishu.dto.msg.FeiShuMsgDTO;
import com.pipihelper.project.feishu.service.FeiShuApiService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.time.LocalDate;
import java.util.List;
import java.util.stream.Collectors;

/**
 * 飞书入职周年提醒
 */
@Service
@Slf4j
public class AnniversaryNoticeService extends AbstractNoticeService{

    @Autowired
    private FeiShuApiService feiShuApiService;

    @Resource
    private FeiShuConfig feiShuConfig;

    @Override
    public void notice() {
        // 1. 获取当天生日人
        List<FeiShuEmployeeDTO> feiShuEmployeeDTOList = feiShuApiService.getEmployeeList(feiShuConfig.getAnniversaryApp());
        List<FeiShuEmployeeDTO> hireDayEmployees = feiShuEmployeeDTOList.stream()
                .filter(feiShuEmployeeDTO -> StringUtils.isNotEmpty(feiShuEmployeeDTO.getSystemFields().getHireDate()))
                .filter(feiShuEmployeeDTO -> {
                    LocalDate hireDay = LocalDate.parse(feiShuEmployeeDTO.getSystemFields().getHireDate());
                    // 使用plusYears可以避免2月29日的特殊情况.当年若无2月29日,生日则为2月28日
                    long years = LocalDate.now().getYear() - hireDay.getYear();
                    // 1,2,3,5周年时发送提醒
                    return hireDay.plusYears(years).equals(LocalDate.now()) && (years == 1 || years == 2 || years == 3 || years == 5);
                })
                .peek(feiShuEmployeeDTO -> {
                    // 给员工自己发消息
                    feiShuApiService.sendMsg(generateEmployeeMsgCard(feiShuEmployeeDTO), "open_id",feiShuConfig.getAnniversaryApp());
                    // 给领导发送消息
                    sendMsgToLeader(generateLeaderMsgCard(feiShuEmployeeDTO),feiShuEmployeeDTO);

                }).collect(Collectors.toList());
        log.info("{} 当日周年人: {}", LocalDate.now(), hireDayEmployees);

    }

    @Override
    public FeiShuMsgDTO generateEmployeeMsgCard(FeiShuEmployeeDTO feiShuEmployeeDTO) {
        LocalDate hireDay = LocalDate.parse(feiShuEmployeeDTO.getSystemFields().getHireDate());
        long years = LocalDate.now().getYear() - hireDay.getYear();
        String fileName  = String.format("/templates/anniversary-employee-%s.json", years);
        FeiShuMsgDTO feiShuMsgDTO = new FeiShuMsgDTO();
        feiShuMsgDTO.setMsgType("interactive");
        feiShuMsgDTO.setContent(String.format(getInteractiveCardStr(fileName), feiShuEmployeeDTO.getSystemFields().getName()));
        feiShuMsgDTO.setReceiveId(feiShuEmployeeDTO.getUserId());
        return feiShuMsgDTO;
    }

    @Override
    public FeiShuMsgDTO generateLeaderMsgCard(FeiShuEmployeeDTO feiShuEmployeeDTO) {
        LocalDate hireDay = LocalDate.parse(feiShuEmployeeDTO.getSystemFields().getHireDate());
        long years = LocalDate.now().getYear() - hireDay.getYear();
        String fileName  = String.format("/templates/anniversary-leader-%s.json", String.valueOf(years));
        FeiShuMsgDTO feiShuMsgDTO = new FeiShuMsgDTO();
        feiShuMsgDTO.setMsgType("interactive");
        feiShuMsgDTO.setContent(String.format(getInteractiveCardStr(fileName), feiShuEmployeeDTO.getSystemFields().getName()));
        return feiShuMsgDTO;
    }

}