考勤功能完成
This commit is contained in:
@@ -0,0 +1,53 @@
|
||||
package com.ruoyi.oa.service;
|
||||
|
||||
import com.ruoyi.oa.domain.vo.SysOaAttendanceVo;
|
||||
import com.ruoyi.oa.domain.bo.SysOaAttendanceBo;
|
||||
import com.ruoyi.common.core.page.TableDataInfo;
|
||||
import com.ruoyi.common.core.domain.PageQuery;
|
||||
import com.ruoyi.oa.domain.vo.SysUserVo;
|
||||
|
||||
import java.util.Collection;
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 人员考勤Service接口
|
||||
*
|
||||
* @author hdka
|
||||
* @date 2024-11-05
|
||||
*/
|
||||
public interface ISysOaAttendanceService {
|
||||
|
||||
/**
|
||||
* 查询人员考勤
|
||||
*/
|
||||
SysOaAttendanceVo queryById(Long id);
|
||||
|
||||
/**
|
||||
* 查询人员考勤列表
|
||||
*/
|
||||
TableDataInfo<SysOaAttendanceVo> queryPageList(SysOaAttendanceBo bo, PageQuery pageQuery);
|
||||
|
||||
/**
|
||||
* 查询人员考勤列表
|
||||
*/
|
||||
List<SysOaAttendanceVo> queryList(SysOaAttendanceBo bo);
|
||||
|
||||
/**
|
||||
* 新增人员考勤
|
||||
*/
|
||||
Boolean insertByBo(SysOaAttendanceBo bo);
|
||||
|
||||
/**
|
||||
* 修改人员考勤
|
||||
*/
|
||||
Boolean updateByBo(SysOaAttendanceBo bo);
|
||||
|
||||
/**
|
||||
* 校验并批量删除人员考勤信息
|
||||
*/
|
||||
Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid);
|
||||
|
||||
List<SysUserVo> workerList(SysOaAttendanceBo bo);
|
||||
|
||||
int insertBatch(SysOaAttendanceBo bo);
|
||||
}
|
||||
@@ -0,0 +1,185 @@
|
||||
package com.ruoyi.oa.service.impl;
|
||||
|
||||
import cn.hutool.core.bean.BeanUtil;
|
||||
import com.ruoyi.common.core.page.TableDataInfo;
|
||||
import com.ruoyi.common.core.domain.PageQuery;
|
||||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
||||
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
||||
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
||||
import com.ruoyi.oa.domain.vo.SysOaProjectVo;
|
||||
import com.ruoyi.oa.domain.vo.SysUserVo;
|
||||
import com.ruoyi.oa.service.ISysOaProjectService;
|
||||
import com.ruoyi.system.mapper.SysUserRoleMapper;
|
||||
import com.ruoyi.system.service.ISysUserService;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Service;
|
||||
import com.ruoyi.oa.domain.bo.SysOaAttendanceBo;
|
||||
import com.ruoyi.oa.domain.vo.SysOaAttendanceVo;
|
||||
import com.ruoyi.oa.domain.SysOaAttendance;
|
||||
import com.ruoyi.oa.mapper.SysOaAttendanceMapper;
|
||||
import com.ruoyi.oa.service.ISysOaAttendanceService;
|
||||
|
||||
import java.time.LocalDate;
|
||||
import java.util.*;
|
||||
|
||||
/**
|
||||
* 人员考勤Service业务层处理
|
||||
*
|
||||
* @author hdka
|
||||
* @date 2024-11-05
|
||||
*/
|
||||
@RequiredArgsConstructor
|
||||
@Service
|
||||
public class SysOaAttendanceServiceImpl implements ISysOaAttendanceService {
|
||||
|
||||
private final SysOaAttendanceMapper baseMapper;
|
||||
|
||||
@Autowired
|
||||
private ISysUserService sysUserService;
|
||||
|
||||
@Autowired
|
||||
private SysUserRoleMapper sysUserRoleMapper;
|
||||
|
||||
@Autowired
|
||||
private ISysOaProjectService projectService;
|
||||
|
||||
/**
|
||||
* 查询人员考勤
|
||||
*/
|
||||
@Override
|
||||
public SysOaAttendanceVo queryById(Long id){
|
||||
return baseMapper.selectVoById(id);
|
||||
}
|
||||
|
||||
/**
|
||||
* 查询人员考勤列表
|
||||
*/
|
||||
@Override
|
||||
public TableDataInfo<SysOaAttendanceVo> queryPageList(SysOaAttendanceBo bo, PageQuery pageQuery) {
|
||||
LambdaQueryWrapper<SysOaAttendance> lqw = buildQueryWrapper(bo);
|
||||
Page<SysOaAttendanceVo> result = baseMapper.selectVoPage(pageQuery.build(), lqw);
|
||||
return TableDataInfo.build(result);
|
||||
}
|
||||
|
||||
/**
|
||||
* 查询人员考勤列表
|
||||
*/
|
||||
@Override
|
||||
public List<SysOaAttendanceVo> queryList(SysOaAttendanceBo bo) {
|
||||
LambdaQueryWrapper<SysOaAttendance> lqw = buildQueryWrapper(bo);
|
||||
return baseMapper.selectVoList(lqw);
|
||||
}
|
||||
|
||||
private LambdaQueryWrapper<SysOaAttendance> buildQueryWrapper(SysOaAttendanceBo bo) {
|
||||
Map<String, Object> params = bo.getParams();
|
||||
LambdaQueryWrapper<SysOaAttendance> lqw = Wrappers.lambdaQuery();
|
||||
lqw.eq(bo.getUserId() != null, SysOaAttendance::getUserId, bo.getUserId());
|
||||
lqw.eq(bo.getAttendanceDay() != null, SysOaAttendance::getAttendanceDay, bo.getAttendanceDay());
|
||||
lqw.eq(bo.getProjectId() != null, SysOaAttendance::getProjectId, bo.getProjectId());
|
||||
lqw.eq(bo.getDayLength() != null, SysOaAttendance::getDayLength, bo.getDayLength());
|
||||
lqw.eq(bo.getHour() != null, SysOaAttendance::getHour, bo.getHour());
|
||||
return lqw;
|
||||
}
|
||||
|
||||
/**
|
||||
* 新增人员考勤
|
||||
*/
|
||||
@Override
|
||||
public Boolean insertByBo(SysOaAttendanceBo bo) {
|
||||
SysOaAttendanceBo sysOaAttendanceBo = new SysOaAttendanceBo();
|
||||
|
||||
BeanUtil.copyProperties(bo, sysOaAttendanceBo);
|
||||
sysOaAttendanceBo.setProjectId(null);
|
||||
List<SysOaAttendanceVo> sysOaAttendanceVos = this.queryList(sysOaAttendanceBo);
|
||||
SysOaAttendance add = BeanUtil.toBean(bo, SysOaAttendance.class);
|
||||
validEntityBeforeSave(add);
|
||||
if (sysOaAttendanceVos.size()<=0){
|
||||
boolean flag = baseMapper.insert(add) > 0;
|
||||
if (flag) {
|
||||
bo.setId(add.getId());
|
||||
}
|
||||
return flag;
|
||||
}else{
|
||||
SysOaAttendanceVo sysOaAttendanceVo = sysOaAttendanceVos.get(0);
|
||||
sysOaAttendanceVo.setProjectId(bo.getProjectId());
|
||||
boolean flag = baseMapper.updateById(BeanUtil.toBean(sysOaAttendanceVo, SysOaAttendance.class))>0;
|
||||
if (flag) {
|
||||
bo.setId(add.getId());
|
||||
}
|
||||
return flag;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* 修改人员考勤
|
||||
*/
|
||||
@Override
|
||||
public Boolean updateByBo(SysOaAttendanceBo bo) {
|
||||
SysOaAttendance update = BeanUtil.toBean(bo, SysOaAttendance.class);
|
||||
validEntityBeforeSave(update);
|
||||
return baseMapper.updateById(update) > 0;
|
||||
}
|
||||
|
||||
/**
|
||||
* 保存前的数据校验
|
||||
*/
|
||||
private void validEntityBeforeSave(SysOaAttendance entity){
|
||||
//TODO 做一些数据校验,如唯一约束
|
||||
}
|
||||
|
||||
/**
|
||||
* 批量删除人员考勤
|
||||
*/
|
||||
@Override
|
||||
public Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid) {
|
||||
if(isValid){
|
||||
//TODO 做一些业务上的校验,判断是否需要校验
|
||||
}
|
||||
return baseMapper.deleteBatchIds(ids) > 0;
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<SysUserVo> workerList(SysOaAttendanceBo bo) {
|
||||
List<Long> userIds = sysUserRoleMapper.selectUserIdsByRoleId(1852970465740505090L);
|
||||
LocalDate localDate = LocalDate.now();
|
||||
int year = localDate.getYear();
|
||||
int month = localDate.getMonthValue();
|
||||
List<SysUserVo> sysUserVos = new ArrayList<>();
|
||||
for (Long userId : userIds) {
|
||||
SysUserVo sysUser = BeanUtil.toBean(sysUserService.selectUserById(userId), SysUserVo.class);
|
||||
SysOaAttendanceVo sysOaAttendanceVo = new SysOaAttendanceVo();
|
||||
sysOaAttendanceVo.setUserId(sysUser.getUserId());
|
||||
LambdaQueryWrapper<SysOaAttendance> lqw = Wrappers.lambdaQuery();
|
||||
|
||||
// 查询当月记录
|
||||
lqw.eq(SysOaAttendance::getUserId, userId)
|
||||
.ge(SysOaAttendance::getCreateTime,LocalDate.of(year,month,1))
|
||||
.le(SysOaAttendance::getCreateTime,LocalDate.of(year,month,localDate.lengthOfMonth()));
|
||||
List<SysOaAttendanceVo> sysOaAttendanceVos = baseMapper.selectVoList(lqw);
|
||||
|
||||
List<SysOaProjectVo> projectVos = new ArrayList<>();
|
||||
for (SysOaAttendanceVo oaAttendanceVo : sysOaAttendanceVos) {
|
||||
SysOaProjectVo sysOaProjectVo = projectService.queryById(oaAttendanceVo.getProjectId());
|
||||
oaAttendanceVo.setColor(sysOaProjectVo.getColor());
|
||||
projectVos.add(sysOaProjectVo);
|
||||
}
|
||||
sysUser.setProjects(projectVos);
|
||||
sysUser.setAttendances(sysOaAttendanceVos);
|
||||
sysUserVos.add(sysUser);
|
||||
}
|
||||
return sysUserVos;
|
||||
}
|
||||
|
||||
@Override
|
||||
public int insertBatch(SysOaAttendanceBo bo) {
|
||||
List<Long> userIds = sysUserRoleMapper.selectUserIdsByRoleId(1852970465740505090L);
|
||||
for (Long userId : userIds) {
|
||||
SysOaAttendanceBo sysOaAttendanceBo = BeanUtil.toBean(bo,SysOaAttendanceBo.class);
|
||||
sysOaAttendanceBo.setUserId(userId);
|
||||
this.insertByBo(sysOaAttendanceBo);
|
||||
}
|
||||
return 1;
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user