product-inventory-management-after.git

			@@ -2,6 +2,7 @@

			import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
			import com.baomidou.mybatisplus.core.metadata.IPage;
			import com.baomidou.mybatisplus.core.toolkit.Wrappers;
			import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
			import com.ruoyi.common.exception.ServiceException;
			import com.ruoyi.common.exception.base.BaseException;
			@@ -12,12 +13,16 @@
			import com.ruoyi.project.system.service.ISysDictDataService;
			import com.ruoyi.staff.dto.PersonalAttendanceRecordsDto;
			import com.ruoyi.staff.dto.StaffOnJobDto;
			import com.ruoyi.staff.mapper.PersonalAttendanceLocationConfigMapper;
			import com.ruoyi.staff.mapper.StaffOnJobMapper;
			import com.ruoyi.staff.pojo.PersonalAttendanceLocationConfig;
			import com.ruoyi.staff.pojo.PersonalAttendanceRecords;
			import com.ruoyi.staff.mapper.PersonalAttendanceRecordsMapper;
			import com.ruoyi.staff.pojo.StaffOnJob;
			import com.ruoyi.staff.service.PersonalAttendanceRecordsService;
			import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
			import com.ruoyi.staff.task.PersonalAttendanceRecordsTask;
			import com.ruoyi.staff.utils.LocationUtils;
			import org.springframework.beans.BeanUtils;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.stereotype.Service;
			@@ -28,6 +33,7 @@
			import java.math.RoundingMode;
			import java.time.LocalDate;
			import java.time.LocalDateTime;
			import java.time.LocalTime;
			import java.time.format.DateTimeFormatter;
			import java.util.List;

			@@ -40,6 +46,7 @@
			* @since 2026-02-09 01:20:07
			*/
			@Service
			@Transactional(rollbackFor = Exception.class)
			public class PersonalAttendanceRecordsServiceImpl extends ServiceImpl<PersonalAttendanceRecordsMapper, PersonalAttendanceRecords> implements PersonalAttendanceRecordsService {
			@Autowired
			private PersonalAttendanceRecordsMapper personalAttendanceRecordsMapper;
			@@ -48,43 +55,61 @@
			private StaffOnJobMapper staffOnJobMapper;

			@Autowired
			private PersonalAttendanceLocationConfigMapper personalAttendanceLocationConfigMapper;

			@Autowired
			private ISysDictDataService dictDataService;

			@Autowired
			private SysDeptMapper sysDeptMapper;

			@Override
			@Transactional(rollbackFor = Exception.class)
			public int add(PersonalAttendanceRecords personalAttendanceRecords) {
			public int add(PersonalAttendanceRecordsDto personalAttendanceRecordsDto) {
			// 当前时间
			LocalDate currentDate = LocalDate.now();

			// 首先根据用户ID查询员工信息
			LocalDateTime currentDateTime = LocalDateTime.now();
			/查询员工信息/
			QueryWrapper<StaffOnJob> staffQueryWrapper = new QueryWrapper<>();
			staffQueryWrapper.eq("staff_no", SecurityUtils.getUsername());
			StaffOnJob staffOnJob = staffOnJobMapper.selectOne(staffQueryWrapper);
			if (staffOnJob == null) {
			throw new BaseException("当前用户没有对应的员工信息");
			}

			// 当前时间
			LocalDateTime currentDateTime = LocalDateTime.now();

			// 如果打卡时间超过考勤下班时间不能打卡
			/判断打卡位置是否在规则范围内/
			List<PersonalAttendanceLocationConfig> personalAttendanceLocationConfigs = personalAttendanceLocationConfigMapper.selectList(Wrappers.<PersonalAttendanceLocationConfig>lambdaQuery()
			.eq(PersonalAttendanceLocationConfig::getSysDeptId, staffOnJob.getSysDeptId())
			.orderByDesc(PersonalAttendanceLocationConfig::getId));
			if (personalAttendanceLocationConfigs == null \|\| personalAttendanceLocationConfigs.isEmpty()) {
			throw new BaseException("当前部门没有设置打卡规则");
			}
			Double punchLongitude = personalAttendanceRecordsDto.getLongitude(); //打卡的经度
			Double punchLatitude = personalAttendanceRecordsDto.getLatitude(); // 打卡的纬度
			if (punchLongitude == null \|\| punchLatitude == null) {
			throw new BaseException("打卡失败：未获取到您的位置信息，请开启定位权限");
			}
			//计算打卡位置与考勤点的距离
			PersonalAttendanceLocationConfig locationConfig = personalAttendanceLocationConfigs.get(0);//获取最新的一条数据
			double allowedRadius = locationConfig.getRadius(); // 允许的范围（米）
			double actualDistance = LocationUtils.calculateDistance(
			punchLatitude, punchLongitude, // 员工打卡的经纬度
			locationConfig.getLatitude(), locationConfig.getLongitude() // 考勤点的经纬度
			);
			//判断是否在范围内
			if (actualDistance > allowedRadius) {
			throw new BaseException(String.format("打卡失败：您当前位置距离考勤点%.2f米，超出允许范围（%s米）", actualDistance, allowedRadius));
			}
			/判断打卡时间/
			LocalTime endAt = locationConfig.getEndAt(); //下班时间
			// 获取考勤下班时间点
			String[] timeConfigs = getAttendanceTimeConfig();
			String timeConfig = timeConfigs[1];
			String[] timeParts = timeConfig.split(":");
			int standardHour = Integer.parseInt(timeParts[0]);
			int standardMinute = Integer.parseInt(timeParts[1]);
			int standardHour = endAt.getHour();
			int standardMinute = endAt.getMinute();
			// 当前时间
			int actualHour = currentDateTime.getHour();
			int actualMinute = currentDateTime.getMinute();
			// 判断打卡时间是否晚于当前时间
			if (actualHour > standardHour \|\| (actualHour == standardHour && actualMinute > standardMinute)) {
			throw new BaseException("打卡时间不能晚于下班时间");
			throw new BaseException(String.format("打卡失败：打卡时间不能晚于下班时间（%02d:%02d）", standardHour, standardMinute));
			}

			// 根据员工ID和当前日期查询打卡记录
			QueryWrapper<PersonalAttendanceRecords> attendanceQueryWrapper = new QueryWrapper<>();
			attendanceQueryWrapper.eq("staff_on_job_id", staffOnJob.getId())
			@@ -93,10 +118,11 @@
			// 根据字典设置的考勤时间判断迟到早退
			if (attendanceRecord == null) {
			// 不存在打卡记录，创建新记录
			PersonalAttendanceRecords personalAttendanceRecords = new PersonalAttendanceRecords();
			personalAttendanceRecords.setStaffOnJobId(staffOnJob.getId());
			personalAttendanceRecords.setDate(currentDate);
			personalAttendanceRecords.setWorkStartAt(currentDateTime);
			personalAttendanceRecords.setStatus(determineAttendanceStatus(personalAttendanceRecords, true));
			personalAttendanceRecords.setStatus(determineAttendanceStatus(personalAttendanceRecords, true,locationConfig));
			personalAttendanceRecords.setRemark(personalAttendanceRecords.getRemark());
			personalAttendanceRecords.setTenantId(staffOnJob.getTenantId());
			return personalAttendanceRecordsMapper.insert(personalAttendanceRecords);
			@@ -113,7 +139,7 @@
			.divide(BigDecimal.valueOf(60), 2, RoundingMode.HALF_UP);
			attendanceRecord.setWorkHours(workHours);
			// 更新考勤状态
			attendanceRecord.setStatus(determineAttendanceStatus(attendanceRecord, false));
			attendanceRecord.setStatus(determineAttendanceStatus(attendanceRecord, false,locationConfig));
			return personalAttendanceRecordsMapper.updateById(attendanceRecord);
			} else {
			throw new BaseException("您已经打过卡了,无需重复打卡!!!");
			@@ -121,46 +147,22 @@
			}
			}

			// 获取考勤时间配置
			private String[] getAttendanceTimeConfig() {
			String[] timeConfigs = new String[2];
			try {
			String dictType = "sys_work_time";

			// 获取上班时间配置，默认为09:00
			String startTimeConfig = dictDataService.selectDictLabel(dictType, "start_at");
			timeConfigs[0] = (startTimeConfig == null \|\| startTimeConfig.trim().isEmpty()) ? "09:00" : startTimeConfig;

			// 获取下班时间配置，默认为18:00
			String endTimeConfig = dictDataService.selectDictLabel(dictType, "end_at");
			timeConfigs[1] = (endTimeConfig == null \|\| endTimeConfig.trim().isEmpty()) ? "18:00" : endTimeConfig;

			return timeConfigs;
			} catch (Exception e) {
			timeConfigs[0] = "09:00"; // 默认上班时间
			timeConfigs[1] = "18:00"; // 默认下班时间
			return timeConfigs;
			}
			}

			// 根据实际时间和是否上班时间判断考勤状态
			// 0 正常 1 迟到 2 早退 3 迟到早退 4 缺勤
			private Integer determineAttendanceStatus(PersonalAttendanceRecords attendanceRecord, boolean isStart) {
			private Integer determineAttendanceStatus(PersonalAttendanceRecords attendanceRecord, boolean isStart,PersonalAttendanceLocationConfig locationConfig) {
			//判断是上班打卡还是下班打卡
			LocalDateTime actualTime = isStart ? attendanceRecord.getWorkStartAt() : attendanceRecord.getWorkEndAt();
			try {
			// 获取考勤时间配置
			String[] timeConfigs = getAttendanceTimeConfig();
			String timeConfig = isStart ? timeConfigs[0] : timeConfigs[1];

			// 解析标准时间
			String[] timeParts = timeConfig.split(":");
			int standardHour = Integer.parseInt(timeParts[0]);
			int standardMinute = Integer.parseInt(timeParts[1]);

			LocalTime startAt = locationConfig.getStartAt();//上班时间
			LocalTime endAt = locationConfig.getEndAt();//下班时间
			LocalTime timeConfig = isStart ? startAt : endAt;
			// 解析小时和分钟
			int standardHour = timeConfig.getHour();
			int standardMinute = timeConfig.getMinute();
			// 获取实际时间的时分
			int actualHour = actualTime.getHour();
			int actualMinute = actualTime.getMinute();

			// 判断状态
			if (isStart) {
			// 上班打卡：超过标准时间算迟到
			@@ -174,11 +176,11 @@
			return 3; // 迟到早退
			}
			return 2; // 早退
			}else if (attendanceRecord.getStatus() == 1) {
			return 1; // 下班打卡正常但是上班迟到
			}
			}

			return 0; // 正常

			} catch (Exception e) {
			// 如果获取配置失败，默认返回正常状态
			log.warn("获取考勤时间配置失败，使用默认状态：" + e.getMessage());
			@@ -213,7 +215,7 @@
			StaffOnJob staffOnJob = staffOnJobMapper.selectOne(staffQueryWrapper);

			if (staffOnJob == null) {
			return null; // 当前用户没有对应的员工信息
			throw new BaseException("当前用户没有对应的员工信息");
			}

			// 根据员工ID和当前日期查询打卡记录
			@@ -236,7 +238,14 @@
			resultDto.setDeptId(staffOnJob.getSysDeptId() != null ? staffOnJob.getSysDeptId() : null);
			SysDept dept = sysDeptMapper.selectDeptById(staffOnJob.getSysDeptId());
			resultDto.setDeptName(dept != null ? dept.getDeptName() : null);

			//获取该员工对应的打卡规则
			List<PersonalAttendanceLocationConfig> personalAttendanceLocationConfigs = personalAttendanceLocationConfigMapper.selectList(Wrappers.<PersonalAttendanceLocationConfig>lambdaQuery()
			.eq(PersonalAttendanceLocationConfig::getSysDeptId, staffOnJob.getSysDeptId())
			.orderByDesc(PersonalAttendanceLocationConfig::getId));
			if (personalAttendanceLocationConfigs.size()>0){
			resultDto.setStartAt(personalAttendanceLocationConfigs.get(0).getStartAt());
			resultDto.setEndAt(personalAttendanceLocationConfigs.get(0).getEndAt());
			}
			return resultDto;
			}