package com.ruoyi.staff.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
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.ruoyi.common.utils.SecurityUtils;
|
import com.ruoyi.framework.security.LoginUser;
|
import com.ruoyi.project.system.domain.SysUser;
|
import com.ruoyi.project.system.mapper.SysUserMapper;
|
import com.ruoyi.project.system.service.ISysNoticeService;
|
import com.ruoyi.staff.dto.SaveStaffSchedulingDto;
|
import com.ruoyi.staff.dto.StaffSchedulingDto;
|
import com.ruoyi.staff.mapper.StaffSchedulingMapper;
|
import com.ruoyi.staff.pojo.StaffOnJob;
|
import com.ruoyi.staff.pojo.StaffScheduling;
|
import com.ruoyi.staff.mapper.StaffOnJobMapper;
|
import com.ruoyi.staff.service.StaffSchedulingService;
|
import com.ruoyi.staff.vo.SearchSchedulingVo;
|
import lombok.RequiredArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.context.annotation.Lazy;
|
import org.springframework.stereotype.Service;
|
|
import jakarta.annotation.Resource;
|
import java.math.BigDecimal;
|
import java.time.Duration;
|
import java.time.format.DateTimeFormatter;
|
import java.util.ArrayList;
|
import java.util.Arrays;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
/**
|
* @author buhuazhen
|
* @description 针对表【staff_scheduling】的数据库操作Service实现
|
* @createDate 2025-09-03 14:50:34
|
*/
|
@Slf4j
|
@Service
|
@RequiredArgsConstructor
|
public class StaffSchedulingServiceImpl extends ServiceImpl<StaffSchedulingMapper, StaffScheduling>
|
implements StaffSchedulingService {
|
|
private final StaffSchedulingMapper staffSchedulingMapper;
|
private final StaffOnJobMapper staffOnJobMapper;
|
private final SysUserMapper sysUserMapper;
|
private final ISysNoticeService sysNoticeService;
|
|
@Lazy
|
@Resource
|
private StaffSchedulingService staffSchedulingService;
|
|
@Override
|
public void saveStaffScheduling(SaveStaffSchedulingDto saveStaffSchedulingDto) {
|
StaffScheduling staffScheduling = new StaffScheduling();
|
BeanUtils.copyProperties(saveStaffSchedulingDto, staffScheduling);
|
// 开始计算时间
|
Duration duration = Duration.between(staffScheduling.getWorkStartTime(), staffScheduling.getWorkEndTime());
|
long hours = duration.toHours();
|
// 0.5
|
double minutes = (duration.toMinutes() % 60) / 60.0;
|
// minutes = minutes < 0.5 ? 0 : 0.5; 公司一般以0.5为标准计算
|
staffScheduling.setWorkHours(BigDecimal.valueOf(hours + minutes));
|
staffSchedulingService.saveOrUpdate(staffScheduling);
|
|
// 发送排班通知
|
sendSchedulingNotification(staffScheduling);
|
}
|
|
/**
|
* 发送排班通知给被排班人员
|
* @param staffScheduling 排班信息
|
*/
|
private void sendSchedulingNotification(StaffScheduling staffScheduling) {
|
try {
|
if (staffScheduling.getStaffId() == null || staffScheduling.getStaffId().isEmpty()) {
|
return;
|
}
|
|
// 解析员工ID列表
|
List<Long> staffIds = Arrays.stream(staffScheduling.getStaffId().split(","))
|
.map(String::trim)
|
.filter(s -> !s.isEmpty())
|
.map(Long::parseLong)
|
.collect(Collectors.toList());
|
|
if (staffIds.isEmpty()) {
|
return;
|
}
|
|
// 查询员工档案
|
List<StaffOnJob> staffList = staffOnJobMapper.selectList(Wrappers.<StaffOnJob>lambdaQuery()
|
.in(StaffOnJob::getId, staffIds)
|
.eq(StaffOnJob::getStaffState, 1));
|
|
if (staffList.isEmpty()) {
|
return;
|
}
|
|
// 获取员工编号列表
|
List<String> staffNos = staffList.stream()
|
.map(StaffOnJob::getStaffNo)
|
.filter(s -> s != null && !s.isEmpty())
|
.collect(Collectors.toList());
|
|
if (staffNos.isEmpty()) {
|
return;
|
}
|
|
// 查询系统用户
|
List<SysUser> users = sysUserMapper.selectList(Wrappers.<SysUser>lambdaQuery()
|
.in(SysUser::getUserName, staffNos)
|
.eq(SysUser::getStatus, "0"));
|
|
if (users.isEmpty()) {
|
log.warn("排班通知：未找到对应的系统用户");
|
return;
|
}
|
|
// 格式化日期时间
|
DateTimeFormatter dateFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
|
DateTimeFormatter timeFormatter = DateTimeFormatter.ofPattern("HH:mm");
|
|
String workDateStr = staffScheduling.getWorkDate() != null
|
? new java.text.SimpleDateFormat("yyyy-MM-dd").format(staffScheduling.getWorkDate())
|
: "";
|
String startTimeStr = staffScheduling.getWorkStartTime() != null
|
? staffScheduling.getWorkStartTime().format(timeFormatter)
|
: "";
|
String endTimeStr = staffScheduling.getWorkEndTime() != null
|
? staffScheduling.getWorkEndTime().format(timeFormatter)
|
: "";
|
|
// 构建通知内容
|
String title = "排班通知";
|
String message = String.format("您好，您已被安排在 %s 上班，工作时间：%s - %s",
|
workDateStr, startTimeStr, endTimeStr);
|
|
// 发送通知给所有被排班人员
|
List<Long> userIds = users.stream()
|
.map(SysUser::getUserId)
|
.collect(Collectors.toList());
|
|
sysNoticeService.simpleNoticeByUser(title, message, userIds, "/scheduling");
|
|
log.info("已向 {} 名员工发送排班通知", userIds.size());
|
} catch (Exception e) {
|
log.error("发送排班通知失败：{}", e.getMessage(), e);
|
}
|
}
|
|
@Override
|
public IPage<StaffSchedulingDto> listPage(SearchSchedulingVo vo) {
|
Page<StaffScheduling> page = new Page<>(vo.getCurrent(), vo.getSize());
|
|
return staffSchedulingMapper.listPage(page, vo);
|
}
|
|
@Override
|
public StaffScheduling getCurrentUserLatestScheduling() {
|
LoginUser loginUser = SecurityUtils.getLoginUser();
|
return staffSchedulingMapper.selectOne(new LambdaQueryWrapper<StaffScheduling>()
|
.like(StaffScheduling::getStaffId,loginUser.getUserId())
|
.orderByDesc(StaffScheduling::getWorkEndTime)
|
.last("LIMIT 1"));
|
}
|
}
|
