| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062 |
- package com.ruoyi.system.service.impl;
- import java.math.BigDecimal;
- import java.sql.SQLException;
- import java.time.*;
- import java.time.format.DateTimeFormatter;
- import java.util.*;
- import java.util.stream.Collectors;
- import javax.validation.Validator;
- import com.ruoyi.common.core.domain.AjaxResult;
- import com.ruoyi.common.core.domain.entity.SysDept;
- import com.ruoyi.common.enums.UserRolesType;
- import com.ruoyi.common.utils.DateUtils;
- import com.ruoyi.common.utils.bean.BeanUtils;
- import com.ruoyi.project.domain.ProjectStaff;
- import com.ruoyi.project.domain.ProjectStaffRecord;
- import com.ruoyi.project.mapper.ProjectStaffMapper;
- import com.ruoyi.project.mapper.ProjectStaffRecordMapper;
- import com.ruoyi.project.mapper.ProjectTaskMapper;
- import com.ruoyi.system.domain.*;
- import com.ruoyi.system.mapper.*;
- import com.ruoyi.system.service.ISysDeptService;
- import com.ruoyi.weChat.service.WeChatService;
- import org.slf4j.Logger;
- import org.slf4j.LoggerFactory;
- import org.springframework.beans.factory.annotation.Autowired;
- import org.springframework.stereotype.Service;
- import org.springframework.transaction.annotation.Transactional;
- import org.springframework.util.CollectionUtils;
- import com.ruoyi.common.annotation.DataScope;
- import com.ruoyi.common.constant.UserConstants;
- import com.ruoyi.common.core.domain.entity.SysRole;
- import com.ruoyi.common.core.domain.entity.SysUser;
- import com.ruoyi.common.exception.ServiceException;
- import com.ruoyi.common.utils.SecurityUtils;
- import com.ruoyi.common.utils.StringUtils;
- import com.ruoyi.common.utils.spring.SpringUtils;
- import com.ruoyi.system.service.ISysConfigService;
- import com.ruoyi.system.service.ISysUserService;
- /**
- * 用户 业务层处理
- *
- */
- @Service
- public class SysUserServiceImpl implements ISysUserService
- {
- private static final Logger log = LoggerFactory.getLogger(SysUserServiceImpl.class);
- @Autowired
- private SysUserMapper userMapper;
- @Autowired
- private SysRoleMapper roleMapper;
- @Autowired
- private SysPostMapper postMapper;
- @Autowired
- private SysUserRoleMapper userRoleMapper;
- @Autowired
- private SysUserPostMapper userPostMapper;
- @Autowired
- private ISysConfigService configService;
- @Autowired
- private ISysDeptService deptService;
- @Autowired
- private WeChatService weChatService;
- @Autowired
- protected Validator validator;
- @Autowired
- private ProjectStaffMapper projectStaffMapper;
- @Autowired
- private ProjectStaffRecordMapper projectStaffRecordMapper;
- @Autowired
- private ProjectTaskMapper projectTaskMapper;
- @Autowired
- private UserRecordMapper userRecordMapper;
- @Autowired
- private LegalHolidaysMapper legalHolidaysMapper;
- /**
- * 根据条件分页查询用户列表
- *
- * @param user 用户信息
- * @return 用户信息集合信息
- */
- @Override
- @DataScope(deptAlias = "d", userAlias = "u")
- public List<SysUser> selectUserList(SysUser user)
- {
- Long companyId = deptService.selectCompanyByDeptId();
- if (companyId!=null)user.setCompanyId(companyId);
- return userMapper.selectUserList(user);
- }
- /**
- * 根据条件分页查询已分配用户角色列表
- *
- * @param user 用户信息
- * @return 用户信息集合信息
- */
- @Override
- @DataScope(deptAlias = "d", userAlias = "u")
- public List<SysUser> selectAllocatedList(SysUser user)
- {
- return userMapper.selectAllocatedList(user);
- }
- /**
- * 根据条件分页查询未分配用户角色列表
- *
- * @param user 用户信息
- * @return 用户信息集合信息
- */
- @Override
- @DataScope(deptAlias = "d", userAlias = "u")
- public List<SysUser> selectUnallocatedList(SysUser user)
- {
- return userMapper.selectUnallocatedList(user);
- }
- /**
- * 通过用户名查询用户
- *
- * @param userName 用户名
- * @return 用户对象信息
- */
- @Override
- public SysUser selectUserByUserName(String userName)
- {
- return userMapper.selectUserByUserName(userName);
- }
- /**
- * 通过用户ID查询用户
- *
- * @param userId 用户ID
- * @return 用户对象信息
- */
- @Override
- public SysUser selectUserById(Long userId)
- {
- return userMapper.selectUserById(userId);
- }
- /**
- * 查询用户所属角色组
- *
- * @param userName 用户名
- * @return 结果
- */
- @Override
- public String selectUserRoleGroup(String userName)
- {
- List<SysRole> list = roleMapper.selectRolesByUserName(userName);
- if (CollectionUtils.isEmpty(list))
- {
- return StringUtils.EMPTY;
- }
- return list.stream().map(SysRole::getRoleName).collect(Collectors.joining(","));
- }
- /**
- * 查询用户所属岗位组
- *
- * @param userName 用户名
- * @return 结果
- */
- @Override
- public String selectUserPostGroup(String userName)
- {
- List<SysPost> list = postMapper.selectPostsByUserName(userName);
- if (CollectionUtils.isEmpty(list))
- {
- return StringUtils.EMPTY;
- }
- return list.stream().map(SysPost::getPostName).collect(Collectors.joining(","));
- }
- /**
- * 校验用户名称是否唯一
- *
- * @param user 用户信息
- * @return 结果
- */
- @Override
- public boolean checkUserNameUnique(SysUser user)
- {
- Long userId = StringUtils.isNull(user.getUserId()) ? -1L : user.getUserId();
- SysUser info = userMapper.checkUserNameUnique(user.getUserName());
- if (StringUtils.isNotNull(info) && info.getUserId().longValue() != userId.longValue())
- {
- return UserConstants.NOT_UNIQUE;
- }
- return UserConstants.UNIQUE;
- }
- /**
- * 校验手机号码是否唯一
- *
- * @param user 用户信息
- * @return
- */
- @Override
- public boolean checkPhoneUnique(SysUser user)
- {
- Long userId = StringUtils.isNull(user.getUserId()) ? -1L : user.getUserId();
- SysUser info = userMapper.checkPhoneUnique(user.getPhonenumber());
- if (StringUtils.isNotNull(info) && info.getUserId().longValue() != userId.longValue())
- {
- return UserConstants.NOT_UNIQUE;
- }
- return UserConstants.UNIQUE;
- }
- /**
- * 校验email是否唯一
- *
- * @param user 用户信息
- * @return
- */
- @Override
- public boolean checkEmailUnique(SysUser user)
- {
- Long userId = StringUtils.isNull(user.getUserId()) ? -1L : user.getUserId();
- SysUser info = userMapper.checkEmailUnique(user.getEmail());
- if (StringUtils.isNotNull(info) && info.getUserId().longValue() != userId.longValue())
- {
- return UserConstants.NOT_UNIQUE;
- }
- return UserConstants.UNIQUE;
- }
- /**
- * 校验用户是否允许操作
- *
- * @param user 用户信息
- */
- @Override
- public void checkUserAllowed(SysUser user)
- {
- if (StringUtils.isNotNull(user.getUserId()) && user.isAdmin())
- {
- throw new ServiceException("不允许操作超级管理员用户");
- }
- }
- /**
- * 校验用户是否有数据权限
- *
- * @param userId 用户id
- */
- @Override
- public void checkUserDataScope(Long userId)
- {
- if (!SysUser.isAdmin(SecurityUtils.getUserId()))
- {
- SysUser user = new SysUser();
- user.setUserId(userId);
- List<SysUser> users = SpringUtils.getAopProxy(this).selectUserList(user);
- if (StringUtils.isEmpty(users))
- {
- throw new ServiceException("没有权限访问用户数据!");
- }
- }
- }
- /**
- * 新增保存用户信息
- *
- * @param user 用户信息
- * @return 结果
- */
- @Override
- @Transactional
- public int insertUser(SysUser user)
- {
- // 新增用户信息
- int rows = userMapper.insertUser(user);
- // 新增用户岗位关联
- insertUserPost(user);
- // 新增用户与角色管理
- insertUserRole(user);
- return rows;
- }
- /**
- * 注册用户信息
- *
- * @param user 用户信息
- * @return 结果
- */
- @Override
- public boolean registerUser(SysUser user)
- {
- return userMapper.insertUser(user) > 0;
- }
- /**
- * 修改保存用户信息
- *
- * @param user 用户信息
- * @return 结果
- */
- @Override
- @Transactional
- public int updateUser(SysUser user)
- {
- Long userId = user.getUserId();
- // 删除用户与角色关联
- userRoleMapper.deleteUserRoleByUserId(userId);
- // 新增用户与角色管理
- insertUserRole(user);
- // 删除用户与岗位关联
- userPostMapper.deleteUserPostByUserId(userId);
- // 新增用户与岗位管理
- insertUserPost(user);
- //修改关联名称
- updateUserName(user);
- return userMapper.updateUser(user);
- }
- private void updateUserName(SysUser user) {
- SysUser sysUser = userMapper.selectUserById(user.getUserId());
- if (!sysUser.getNickName().equals(user.getNickName())){
- //修改所有名字
- projectStaffMapper.updateNameByAid(user);
- projectStaffRecordMapper.updateNameByAid(user);
- projectTaskMapper.updateAdminNameByAid(user);
- List<ProjectStaff> projectStaffs = projectStaffMapper.selectByAid(user.getUserId());
- for (ProjectStaff projectStaff : projectStaffs) {
- projectTaskMapper.updateStaffName(projectStaff.getPid());
- }
- }
- }
- /**
- * 用户授权角色
- *
- * @param userId 用户ID
- * @param roleIds 角色组
- */
- @Override
- @Transactional
- public void insertUserAuth(Long userId, Long[] roleIds)
- {
- userRoleMapper.deleteUserRoleByUserId(userId);
- insertUserRole(userId, roleIds);
- }
- /**
- * 修改用户状态
- *
- * @param user 用户信息
- * @return 结果
- */
- @Override
- public int updateUserStatus(SysUser user)
- {
- return userMapper.updateUser(user);
- }
- /**
- * 修改用户基本信息
- *
- * @param user 用户信息
- * @return 结果
- */
- @Override
- public int updateUserProfile(SysUser user)
- {
- return userMapper.updateUser(user);
- }
- /**
- * 修改用户头像
- *
- * @param userName 用户名
- * @param avatar 头像地址
- * @return 结果
- */
- @Override
- public boolean updateUserAvatar(String userName, String avatar)
- {
- return userMapper.updateUserAvatar(userName, avatar) > 0;
- }
- /**
- * 重置用户密码
- *
- * @param user 用户信息
- * @return 结果
- */
- @Override
- public int resetPwd(SysUser user)
- {
- return userMapper.updateUser(user);
- }
- /**
- * 重置用户密码
- *
- * @param userName 用户名
- * @param password 密码
- * @return 结果
- */
- @Override
- public int resetUserPwd(String userName, String password)
- {
- return userMapper.resetUserPwd(userName, password);
- }
- /**
- * 新增用户角色信息
- *
- * @param user 用户对象
- */
- public void insertUserRole(SysUser user)
- {
- this.insertUserRole(user.getUserId(), user.getRoleIds());
- }
- /**
- * 新增用户岗位信息
- *
- * @param user 用户对象
- */
- public void insertUserPost(SysUser user)
- {
- Long[] posts = user.getPostIds();
- if (StringUtils.isNotEmpty(posts))
- {
- // 新增用户与岗位管理
- List<SysUserPost> list = new ArrayList<SysUserPost>(posts.length);
- for (Long postId : posts)
- {
- SysUserPost up = new SysUserPost();
- up.setUserId(user.getUserId());
- up.setPostId(postId);
- list.add(up);
- }
- userPostMapper.batchUserPost(list);
- }
- }
- /**
- * 新增用户角色信息
- *
- * @param userId 用户ID
- * @param roleIds 角色组
- */
- public void insertUserRole(Long userId, Long[] roleIds)
- {
- if (StringUtils.isNotEmpty(roleIds))
- {
- // 新增用户与角色管理
- List<SysUserRole> list = new ArrayList<SysUserRole>(roleIds.length);
- for (Long roleId : roleIds)
- {
- SysUserRole ur = new SysUserRole();
- ur.setUserId(userId);
- ur.setRoleId(roleId);
- list.add(ur);
- }
- userRoleMapper.batchUserRole(list);
- }
- }
- /**
- * 通过用户ID删除用户
- *
- * @param userId 用户ID
- * @return 结果
- */
- @Override
- @Transactional
- public int deleteUserById(Long userId)
- {
- // 删除用户与角色关联
- userRoleMapper.deleteUserRoleByUserId(userId);
- // 删除用户与岗位表
- userPostMapper.deleteUserPostByUserId(userId);
- return userMapper.deleteUserById(userId);
- }
- /**
- * 批量删除用户信息
- *
- * @param userIds 需要删除的用户ID
- * @return 结果
- */
- @Override
- @Transactional
- public int deleteUserByIds(Long[] userIds)
- {
- for (Long userId : userIds)
- {
- checkUserAllowed(new SysUser(userId));
- checkUserDataScope(userId);
- }
- // 删除用户与角色关联
- userRoleMapper.deleteUserRole(userIds);
- // 删除用户与岗位关联
- userPostMapper.deleteUserPost(userIds);
- return userMapper.deleteUserByIds(userIds);
- }
- /**
- * 导入用户数据
- *
- * @param userList 用户数据列表
- * @param isUpdateSupport 是否更新支持,如果已存在,则进行更新数据
- * @param operName 操作用户
- * @return 结果
- */
- @Override
- public String importUser(List<SysUser> userList, Boolean isUpdateSupport, String operName)
- {
- if (StringUtils.isNull(userList) || userList.size() == 0)
- {
- throw new ServiceException("导入用户数据不能为空!");
- }
- int successNum = 0;
- int failureNum = 0;
- StringBuilder successMsg = new StringBuilder();
- StringBuilder failureMsg = new StringBuilder();
- String password = configService.selectConfigByKey("sys.user.initPassword");
- Long company = deptService.selectCompanyByDeptId();
- for (SysUser user : userList)
- {
- try
- {
- if (StringUtils.isEmpty(user.getDeptName())){
- throw new ServiceException("部门数据异常");
- }
- if (StringUtils.isEmpty(user.getFullJob())){
- throw new ServiceException("全职/兼职数据异常");
- }
- // 验证是否存在这个用户
- SysUser u = userMapper.checkJobNumber(user.getJobNumber(),company);
- if (StringUtils.isNull(u)){
- SysUser sysUser1 = userMapper.selectUserByUserName(user.getUserName());
- if (sysUser1 != null){
- throw new ServiceException("用户名(账号)已存在");
- }
- user.setPassword(SecurityUtils.encryptPassword(password));
- user.setCreateBy(operName);
- user.setUserId(null);
- if (user.getSuperiorName()!=null){
- SysUser sysUser = userMapper.selectByNikeName(user.getSuperiorName(),company);
- if (sysUser != null){
- user.setSuperiorId(sysUser.getUserId());
- }
- }
- if (user.getDeptName()!=null){
- SysDept sysDept = deptService.selectByDepName(user.getDeptName(), company);
- if (sysDept ==null){
- throw new ServiceException("部门数据异常,找不到部门");
- }else {
- user.setDeptId(sysDept.getDeptId());
- }
- }
- userMapper.insertUser(user);
- if (user.getRoleName()!=null){
- SysRole sysRole = roleMapper.selectByRoleName(user.getRoleName());
- if (sysRole !=null){
- List<SysUserRole> list=new ArrayList<>();
- SysUserRole sur = new SysUserRole();
- sur.setUserId(user.getUserId());
- sur.setRoleId(sysRole.getRoleId());
- list.add(sur);
- userRoleMapper.batchUserRole(list);
- }
- }
- successNum++;
- successMsg.append("<br/>" + successNum + "、账号 " + user.getUserName() + " 导入成功");
- } else if (isUpdateSupport) {
- // BeanValidators.validateWithException(validator, user);
- checkUserAllowed(u);
- checkUserDataScope(u.getUserId());
- user.setUserId(u.getUserId());
- user.setUpdateBy(operName);
- if (user.getSuperiorName()!=null&&!user.getSuperiorName().equals(u.getSuperiorName())){
- SysUser sysUser = userMapper.selectByNikeName(user.getSuperiorName(),company);
- if (sysUser != null){
- user.setSuperiorId(sysUser.getUserId());
- }
- }
- if (user.getDeptName()!=null&&!user.getDeptName().equals(u.getDeptName())){
- SysDept sysDept = deptService.selectByDepName(user.getDeptName(), company);
- if (sysDept ==null){
- throw new ServiceException("部门数据异常,找不到部门");
- }else {
- user.setDeptId(sysDept.getDeptId());
- }
- }
- if (user.getRoleName()!=null&&!user.getRoleName().equals(u.getRoleName())){
- SysRole sysRole = roleMapper.selectByRoleName(user.getRoleName());
- if (sysRole !=null){
- userRoleMapper.deleteUserRoleByUserId(user.getUserId());
- List<SysUserRole> list=new ArrayList<>();
- SysUserRole sur = new SysUserRole();
- sur.setUserId(user.getUserId());
- sur.setRoleId(sysRole.getRoleId());
- list.add(sur);
- userRoleMapper.batchUserRole(list);
- }
- }
- userMapper.updateUser(user);
- successNum++;
- successMsg.append("<br/>" + successNum + "、账号 " + user.getUserName() + " 更新成功");
- }
- else
- {
- failureNum++;
- failureMsg.append("<br/>" + failureNum + "、账号 " + user.getUserName() + " 已存在");
- }
- }
- catch (Exception e)
- {
- failureNum++;
- String msg = "<br/>" + failureNum + "、账号 " + user.getUserName() + " 导入失败:";
- if (e instanceof ServiceException){
- failureMsg.append(msg + e.getMessage());
- }else if (e instanceof SQLException){
- failureMsg.append("数据异常");
- }
- log.error(msg, e);
- }
- }
- if (failureNum > 0)
- {
- failureMsg.insert(0, "很抱歉,导入失败!共 " + failureNum + " 条数据格式不正确,错误如下:");
- throw new ServiceException(failureMsg.toString());
- }
- else
- {
- successMsg.insert(0, "恭喜您,数据已全部导入成功!共 " + successNum + " 条,数据如下:");
- }
- return successMsg.toString();
- }
- @Override
- public Object selectName(String name,Integer type){
- if (name==null||name.length()<2)return new ArrayList<>();
- Long roleId=null;
- if (type==null)type=0;
- if (type==0)roleId= UserRolesType.COMMON.getCode();
- else if (type==1)roleId=UserRolesType.MANAGE.getCode();
- if (SecurityUtils.isSuperAdmin()){
- roleId=UserRolesType.ADMIN.getCode();;
- }
- Long companyId = deptService.selectCompanyByDeptId();
- return userMapper.selectName(name,roleId,companyId);
- }
- @Override
- public String setOpenId(String code) {
- System.out.println(code);
- String openId = weChatService.getOpenId(code);
- SysUser user = new SysUser();
- user.setUserId(SecurityUtils.getUserId());
- user.setOpenId(openId);
- userMapper.updateUser(user);
- return openId;
- }
- @Override
- public boolean checkJobNumber(SysUser user) {
- Long companyId = getCompany(user.getDeptId());
- log.debug("company="+companyId);
- SysUser sysUser = userMapper.checkJobNumber(user.getJobNumber(),companyId);
- if (sysUser==null){
- return false;
- }else if (StringUtils.isNotNull(user.getUserId())&&user.getUserId().equals(sysUser.getUserId())){
- return false;
- }
- return true;
- }
- @Override
- public boolean checkProject(Long[] userIds) {
- for (Long userId : userIds) {
- int i = userMapper.selectParticipateProjectSum(userId);
- if (i>0){
- return true;
- }
- }
- return false;
- }
- private Long getCompany(Long deptId) {
- log.debug("depID="+deptId);
- SysDept sysDept = deptService.selectDeptById(deptId);
- String ancestors = sysDept.getAncestors();
- log.debug("anc="+ancestors);
- String[] split = ancestors.split(",");
- if (split.length>2)return Long.valueOf(split[2]);
- else return deptId;
- }
- @Override
- public void pushUserClock(List<Map<Integer, String>> maps) {
- List<UserClockDtails> list=new ArrayList<>();
- int month =0;
- int year =0;
- int days=0;
- Map<Integer,String> hand=new HashMap<>();
- String startClockTime=null;
- String endClockTime=null;
- if (!maps.isEmpty()){
- for (int i = 0; i < maps.size(); i++) {
- //获取头部
- if (i==0){
- Map<Integer, String> map = maps.get(i);
- String head = map.get(0);
- int i1 = head.indexOf(":")+1;
- int i2 = head.indexOf("至");
- startClockTime = head.substring(i1, i2).trim();
- endClockTime = head.substring(i2+1).trim();
- LocalDate date = LocalDate.parse(startClockTime, DateTimeFormatter.ISO_DATE);
- month=date.getMonthValue();
- year = date.getYear();
- }else if (i==2){
- hand=maps.get(2);
- }else if (i>2){
- Map<Integer, String> map = maps.get(i);
- UserClockDtails userClockDtails=new UserClockDtails();
- List<LegalHolidays> legalHolidays = legalHolidaysMapper.selectAll();
- //每一条是一个人的当月打卡
- days=0;
- for (int j = 0; j < map.size(); j++) {
- String s = map.get(j);
- if (j==0)userClockDtails.setName(s);
- else if (j==1)userClockDtails.setGroupName(s.replace("\n","-").replace(" ",""));
- else if (j==2)userClockDtails.setDepName(s.replace("\n","-"));
- else if (j==3)userClockDtails.setJobNumber(s);
- else if (j==4)userClockDtails.setPosition(s);
- else if (j==5)userClockDtails.setUserId(s);
- //前5为基本信息,后面则是打卡信息
- else {
- UserClockDtails newUserlock=new UserClockDtails(userClockDtails);
- String regex = "\\d+";
- String daystr=hand.get(j);
- if (daystr != null){
- if (daystr.matches(regex)){
- days=Integer.parseInt(hand.get(j));
- }else {
- days++;
- }
- System.out.println("year="+year+",month="+month+",days="+days);
- newUserlock.setClockTime(LocalDate.of(year,month,days));
- //false不用上班 true需要上班
- boolean flag=pushLeaglHolidays(newUserlock.getClockTime(),legalHolidays);
- if (flag || StringUtils.isNotEmpty(s)){
- String[] split = s.split("\n");
- if (split.length==1){
- newUserlock.setStauts(1);
- }
- newUserlock.setClockDate(s);
- if (StringUtils.isNotBlank(split[0])){
- int startHour = Integer.parseInt(getTime(split[0].split(":")[0]));
- int startMinute = Integer.parseInt(getTime(split[0].split(":")[1]));
- LocalDateTime startTime=LocalDateTime.of(year,month,days,startHour,startMinute);
- newUserlock.setStartTime(startTime);
- String s1 = split[split.length - 1];
- if (StringUtils.isNotBlank(s1)&&newUserlock.getStauts()==0){
- int endHour = Integer.parseInt(getTime(split[split.length - 1].split(":")[0]));
- int endMinute = Integer.parseInt(getTime(split[split.length - 1].split(":")[1]));
- LocalDateTime endTime=LocalDateTime.of(year,month,days,endHour,endMinute);
- newUserlock.setEndTime(endTime);
- Double hours = getHuors(startTime, endTime);
- newUserlock.setDuration(hours);
- }
- }
- list.add(newUserlock);
- }
- }
- }
- }
- }
- }
- }
- List<UserRecordOut> userRecordList = new ArrayList<>();
- for (UserClockDtails e:list){
- Long ddUserId = Long.valueOf(e.getUserId());
- List<ProjectStaffRecord> projectStaffRecords = projectStaffRecordMapper.selectByDDUidAndTime(ddUserId, e.getClockTime());
- UserRecordOut ur=new UserRecordOut();
- ur.setName(e.getName());
- ur.setDdUserId(Long.valueOf(e.getUserId()));
- ur.setCheckDuration(e.getDuration());
- ur.setSumDuration(e.getDuration());
- ur.setContent(e.getClockDate());
- if (e.getStartTime() !=null){
- ur.setStartTime(Date.from(e.getStartTime().atZone(ZoneId.systemDefault()).toInstant()));
- }
- if (e.getEndTime() != null){
- ur.setEndTime(Date.from(e.getEndTime().atZone(ZoneId.systemDefault()).toInstant()));
- }
- if (e.getStartTime()==null||e.getEndTime() == null){
- ur.setStatus(1);
- ur.setDuration(0.0);
- ur.setSumDuration(0.0);
- ur.setCheckDuration(0.0);
- }else{
- ur.setStatus(0);
- }
- ur.setRecordTime(Date.from(e.getClockTime().atStartOfDay().atZone(ZoneId.systemDefault()).toInstant()));
- if (projectStaffRecords.isEmpty()){
- ur.setClockStatus(2);
- }else if (projectStaffRecords.size()==1){
- ur.setClockStatus(0);
- ur.setPsrId(projectStaffRecords.get(0).getId());
- }else if (projectStaffRecords.size()>1){
- //判定打卡状态
- // BigDecimal sum = BigDecimal.ZERO;
- // BigDecimal sum2 =BigDecimal.ZERO;
- // if (e.getDuration()!=null){
- // sum2 = BigDecimal.valueOf(e.getDuration());
- // }
- // for (ProjectStaffRecord e2 : projectStaffRecords) {
- // sum = sum.add(BigDecimal.valueOf(e2.getDuration()));
- // }
- // if(sum.compareTo(sum2) == 0){
- // ur.setClockStatus(1);
- // }else {
- // ur.setClockStatus(3);
- // }
- ur.setClockStatus(1);
- ur.setList(projectStaffRecords);
- }
- ur.setCreateId(SecurityUtils.getUserId());
- userRecordList.add(ur);
- }
- if (!userRecordList.isEmpty()){
- for (UserRecordOut userRecordOut : userRecordList) {
- userRecordMapper.insertSelective(userRecordOut);
- }
- }
- }
- private boolean pushLeaglHolidays(LocalDate clockTime ,List<LegalHolidays> legalHolidays) {
- boolean flag = true;
- String format = clockTime.format(DateTimeFormatter.ISO_DATE);
- int weeks = DateUtils.getWeeks(format);
- if (weeks==6||weeks==0) flag=false;
- Instant instant = clockTime.atStartOfDay().toInstant(ZoneOffset.of("+8"));
- long epochMilli = instant.toEpochMilli();
- for (LegalHolidays e : legalHolidays) {
- if (e.getHolidays().getTime()==epochMilli){
- if(e.getStatus()==1){
- flag=false;
- } else if (e.getStatus() == 2) {
- flag=true;
- }
- }
- }
- return flag;
- }
- @Override
- public List<UserRecordOut> selectUserClock(selectUserClockInput in) {
- in.setUserId(SecurityUtils.getUserId());
- return userRecordMapper.selectUserClock(in);
- }
- private String getTime(String s) {
- return s.replace("外勤","").trim();
- }
- private Double getHuors(LocalDateTime startTime, LocalDateTime endTime) {
- //打卡时间处理
- if (startTime.getHour()<=8&&startTime.getMinute()<30){
- startTime=startTime.withHour(8);
- startTime=startTime.withMinute(30);
- }else if (startTime.getHour()>8&&startTime.getMinute()>30){
- startTime=startTime.withMinute(startTime.getHour()+1);
- startTime=startTime.withMinute(0);
- }else if (startTime.getHour()>8&&startTime.getMinute()<30){
- startTime=startTime.withMinute(30);
- }
- if (endTime.getHour()<18 &&endTime.getMinute()<30){
- endTime=endTime.withMinute(0);
- }else if (endTime.getHour()>=18&&endTime.getMinute()<30){
- endTime=endTime.withMinute(0);
- }else if (endTime.getHour()>=18&&endTime.getMinute()>30){
- endTime=endTime.withMinute(30);
- }
- Duration duration = Duration.between(startTime, endTime);
- long minutes = duration.toMinutes();
- long l = minutes / 30;
- double l1 = (double) (l / 2);
- long l2 = l % 2;
- if (l2==1){
- l1+=0.5;
- }
- //在12点之前
- if (startTime.getHour()<13&&endTime.getHour()>13&&endTime.getHour()<18){
- l1=l1-1.5;
- }else if (startTime.getHour()<13&&endTime.getHour()>17){
- l1=l1-2;
- }else if (startTime.getHour()>=13&&endTime.getHour()>17){
- l1=l1-0.5;
- }
- return l1;
- }
- @Override
- public UserRecordOut UserClockDetails(Long id) {
- UserRecord userRecord = userRecordMapper.selectByPrimaryKey(id);
- UserRecordOut out=new UserRecordOut();
- BeanUtils.copyProperties(userRecord, out);
- LocalDate localDate =userRecord.getRecordTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate();
- List<ProjectStaffRecord> projectStaffRecords = projectStaffRecordMapper.selectByDDUidAndTime(out.getDdUserId(), localDate);
- out.setList(projectStaffRecords);
- return out;
- }
- @Override
- public void updateAllUserClock(Integer type) {
- userRecordMapper.updateTypeDuration(SecurityUtils.getUserId(),type);
- }
- @Override
- public void updateUserClockDetails(UserClockDetailsInput in) {
- BigDecimal amount = BigDecimal.ZERO;
- for (ProjectStaffRecord e : in.getList()) {
- amount = amount.add(BigDecimal.valueOf(e.getCheckDuration()));
- }
- UserRecord userRecord = userRecordMapper.selectByPrimaryKey(in.getId());
- if (amount.compareTo(BigDecimal.valueOf(userRecord.getCheckDuration())) > 0){
- throw new ServiceException(String.format("核算统计[%s]间超过打卡工时[%s],请重新输入!",amount,userRecord.getSumDuration()));
- }
- for (ProjectStaffRecord projectStaffRecord : in.getList()) {
- projectStaffRecord.setCheckStatus(1);
- projectStaffRecordMapper.updateByPrimaryKeySelective(projectStaffRecord);
- }
- UserRecord ur =new UserRecord();
- ur.setId(in.getId());
- ur.setStatus(2);
- userRecordMapper.updateByPrimaryKeySelective(ur);
- }
- @Override
- public void updateUserRecord(UserRecord in) {
- UserRecord ur=new UserRecord();
- ur.setId(in.getId());
- ur.setCheckDuration(in.getCheckDuration());
- ur.setStatus(2);
- userRecordMapper.updateByPrimaryKeySelective(ur);
- }
- @Override
- public AjaxResult userRecordMerge() {
- Long userId = SecurityUtils.getUserId();
- List<UserRecord> list = userRecordMapper.selectByUserId(userId);
- //未匹配数量
- List<UserRecord> collect = list.stream().filter(userRecord -> userRecord.getClockStatus() == 2).collect(Collectors.toList());
- int unmatched = collect.size();
- int matched = list.size()-unmatched;
- //合并到打卡表
- userRecordMapper.userRecordMerge(userId);
- //直接补数据
- List<SysUser> userList = new ArrayList<>();
- for (UserRecord e : collect) {
- ProjectStaffRecord newPR = new ProjectStaffRecord();
- pushUser(newPR,e,userList);
- projectStaffRecordMapper.insertSelective(newPR);
- }
- //清楚考勤合并数据
- userRecordMapper.deleteByUserId(userId);
- return AjaxResult.success(String.format("导入数据未匹配新增数据%s条,完成匹配%s条.", unmatched,matched));
- }
- private void pushUser(ProjectStaffRecord newPR, UserRecord e, List<SysUser> userList) {
- Long userid=null;
- String name=null;
- if (userList.isEmpty()){
- SysUser sysUser = userMapper.selectDDUserId(e.getDdUserId());
- if(sysUser==null) throw new ServiceException(String.format("[%s]无法匹配系统用户,请先录入导入钉钉编号", e.getName()));
- userList.add(sysUser);
- userid=sysUser.getUserId();
- name=sysUser.getNickName();
- }else {
- boolean exist = false;
- for (SysUser sysUser : userList) {
- if (sysUser.getDdUserId().equals(e.getDdUserId())){
- exist=true;
- userid=sysUser.getUserId();
- name=sysUser.getNickName();
- break;
- }
- }
- if (!exist){
- SysUser sysUser = userMapper.selectDDUserId(e.getDdUserId());
- userList.add(sysUser);
- userid=sysUser.getUserId();
- name=sysUser.getNickName();
- }
- }
- newPR.setAid(userid);
- newPR.setName(name);
- newPR.setInitDuration(e.getCheckDuration());
- newPR.setCheckDuration(e.getCheckDuration());
- newPR.setDuration(e.getCheckDuration());
- newPR.setRecordTime(e.getRecordTime());
- newPR.setCreateTime(Calendar.getInstance().getTime());
- newPR.setProcessStatus(2);
- newPR.setProjectStatus(0);
- newPR.setContent("系统生成打卡");
- }
- @Override
- public AjaxResult userRecordMergeCheck() {
- Long userId = SecurityUtils.getUserId();
- int i = userRecordMapper.checkUserRecord(userId,1);
- if (i>0){
- return AjaxResult.error("当前用户存在缺卡的考勤,请处理后再提交");
- }
- List<UserRecord> list = userRecordMapper.selectByUserId(userId);
- List<UserRecord> list2 = list.stream().filter(e -> e.getClockStatus() == 1).collect(Collectors.toList());
- //存在多打卡的时候
- if (!list2.isEmpty()){
- //判定多打卡状态是否正常
- for (UserRecord e : list2) {
- e.getRecordTime().toInstant();
- LocalDateTime localDateTime = LocalDateTime.ofInstant(e.getRecordTime().toInstant(), ZoneId.systemDefault());
- LocalDate localDate = localDateTime.toLocalDate();
- List<ProjectStaffRecord> list3 = projectStaffRecordMapper.selectByDDUidAndTime(e.getDdUserId(), localDate);
- BigDecimal sum = BigDecimal.ZERO;
- for (ProjectStaffRecord e2 : list3) {
- if (e2.getCheckDuration()!=null){
- sum = sum.add(BigDecimal.valueOf(e2.getCheckDuration()));
- }
- }
- BigDecimal sum2 = BigDecimal.valueOf(e.getCheckDuration());
- if (sum.compareTo(sum2) != 0){
- String dateStr = DateUtils.parseStrYYYYnMMyDD(e.getRecordTime());
- return AjaxResult.error(String.format("[%S]考勤[%S]多打卡时间[%s != %s],请处理后再提交",e.getName(),dateStr,sum,sum2));
- }
- }
- }
- return AjaxResult.success();
- }
- }
|