生日提醒任务增强功能

在生日提醒任务中，新增合同到期提醒功能。系统将检查当前日期，如果用户的合同到期，将通过订阅消息发送公司通知。同时，优化了生日提醒逻辑，现在可以直接传递用户列表，而不是角色ID，以提高处理效率。此外，修正了正面提醒和生日提醒方法中错误的消息类型参数，确保现在发送的是统一的"formal"类型公司通知。
优化了小程序通知模板的生成逻辑。支持多种通知类型(生日、转正、合同提醒)，通过参数type区分。重构了convertBirthday方法，整合了convertRegular方法。增强了代码可读性和可维护性。
2024-09-22 15:46:24 +08:00 · 2024-09-22 15:46:08 +08:00 · 2024-09-22 15:46:02 +08:00 · 2024-09-21 13:03:28 +08:00 · 2024-09-21 12:48:47 +08:00
7 changed files with 120 additions and 73 deletions
--- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/convert/notice/NoticeConvert.java
+++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/convert/notice/NoticeConvert.java
@ -77,7 +77,7 @@ public interface NoticeConvert {
    * @param miniProgramState 小程序的状态
    * @return 提醒模板
    */
-    default SubscribeMessageReqDTO convertBirthday(String openId, String miniProgramState) {
+    default SubscribeMessageReqDTO convertBirthday(String type, String openId, String miniProgramState) {

       SubscribeMessageReqDTO message = new SubscribeMessageReqDTO();
       message.setToUser(openId);
@ -86,8 +86,26 @@ public interface NoticeConvert {
       //消息类型
       MsgData noticeType = new MsgData();
       noticeType.setName("phrase8");
-       noticeType.setValue("生日提醒");
+
+       //消息内容
+       MsgData content = new MsgData();
+       content.setName("thing2");
+
+       switch (type) {
+          case "birthday":
+             noticeType.setValue("生日提醒");
+             content.setValue("今天有人过生日，请前往PC端查看！");
+             break;
+          case "regular":
+             noticeType.setValue("转正提醒");
+             content.setValue("恭喜快要转正了哦，记得走转正流程！");
+             break;
+          case "contract":
+             noticeType.setValue("合同提醒");
+             content.setValue("有人合同已过期，请前往PC端查看！");
+       }
       message.addData(noticeType);
+       message.addData(content);

       //发送人
       MsgData publishMan = new MsgData();
@ -101,57 +119,9 @@ public interface NoticeConvert {
       createTime.setValue(DateUtils.dateFormat(new Date(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND));
       message.addData(createTime);

-       //消息内容
-       MsgData content = new MsgData();
-       content.setName("thing2");
-       content.setValue("今天有人过生日，请前往PC端查看！");
-       message.addData(content);
-
       message.setMiniprogramState(miniProgramState);
       message.setPage("");

       return message;
    }
-
-   /**
-    * 生日提醒
-    * @param openId 微信小程序唯一id
-    * @param miniProgramState 小程序的状态
-    * @return 提醒模板
-    */
-   default SubscribeMessageReqDTO convertRegular(String openId, String miniProgramState) {
-
-      SubscribeMessageReqDTO message = new SubscribeMessageReqDTO();
-      message.setToUser(openId);
-      message.setTemplateId("fH29xjNb8pe-7onQ-wE3QrBAC-y8aaC_oosYZKNMtzM");
-
-      //消息类型
-      MsgData noticeType = new MsgData();
-      noticeType.setName("phrase8");
-      noticeType.setValue("转正提醒");
-      message.addData(noticeType);
-
-      //发送人
-      MsgData publishMan = new MsgData();
-      publishMan.setName("thing16");
-      publishMan.setValue("系统");
-      message.addData(publishMan);
-
-      //发送时间
-      MsgData createTime = new MsgData();
-      createTime.setName("time3");
-      createTime.setValue(DateUtils.dateFormat(new Date(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND));
-      message.addData(createTime);
-
-      //消息内容
-      MsgData content = new MsgData();
-      content.setName("thing2");
-      content.setValue("恭喜快要转正了哦，记得走转正流程！");
-      message.addData(content);
-
-      message.setMiniprogramState(miniProgramState);
-      message.setPage("");
-
-      return message;
-   }
 }
--- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/dal/dataobject/laborcontract/LaborContractDO.java
+++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/dal/dataobject/laborcontract/LaborContractDO.java
@ -55,7 +55,7 @@ public class LaborContractDO extends BaseDO {
     */
    private Integer probationPeriodTime;
    /**
-     * 状态  0待签 1已签 2过期
+     * 状态  0待签 2过期 3已签 4离职
     */
    private Integer status;
    /**
--- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/job/birthday/BirthdayJob.java
+++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/job/birthday/BirthdayJob.java
@ -1,5 +1,6 @@
 package cn.iocoder.yudao.module.system.job.birthday;

+import cn.hutool.core.collection.CollectionUtil;
 import cn.hutool.json.JSONObject;
 import cn.iocoder.yudao.framework.common.util.collection.CollectionUtils;
 import cn.iocoder.yudao.framework.tenant.core.job.TenantJob;
@ -66,17 +67,46 @@ public class BirthdayJob {
            // 获取提醒时长
            Integer remindDuration = object.getInt("remindDuration");

+            Set<Long> userIds = permissionService.getUserRoleIdListByRoleId(CollectionUtils.singleton(roleId));
+            //获得用户组中 用户信息
+            List<AdminUserDO> userDOs = userService.getUserList(userIds);
+
            // 生日提醒
-            birthdayRemind(roleId);
+            birthdayRemind(userDOs);

            // 转正提醒
            PositiveReminders(remindDuration);
+
+            // 合同到期提醒
+            ContractReminders(userDOs);
        }

        // 返回执行成功
        return ReturnT.SUCCESS;
    }

+    /**
+     * 合同到期提醒
+     */
+    private void ContractReminders(List<AdminUserDO> userDOs) {
+
+        LocalDate now = LocalDate.now();
+        List<LaborContractDO> laborContractDOS = laborContractService.getListByEndTime(now);
+        if (CollectionUtil.isNotEmpty(laborContractDOS)) {
+
+            // 修改合同状态为过期
+            laborContractService.updateLaborContractList(convertList(laborContractDOS, LaborContractDO::getId), 2);
+
+            for (AdminUserDO adminUserDO : userDOs) {
+                if( adminUserDO.getOpenId() != null && !adminUserDO.getOpenId().isEmpty()) {
+
+                    subscribeMessageSendApi.sendCompanyNotice(NoticeConvert.INSTANCE.convertBirthday(
+                            "contract", adminUserDO.getOpenId(), "formal"));
+                }
+            }
+        }
+    }
+
    /**
     * 转正提醒
     */
@ -99,8 +129,8 @@ public class BirthdayJob {
        for (AdminUserDO adminUserDO : positiveUserList) {
            if( adminUserDO.getOpenId() != null && !adminUserDO.getOpenId().isEmpty()) {

-                subscribeMessageSendApi.sendCompanyNotice(NoticeConvert.INSTANCE.convertRegular(
-                        adminUserDO.getOpenId(), "formal"));
+                subscribeMessageSendApi.sendCompanyNotice(NoticeConvert.INSTANCE.convertBirthday(
+                        "regular", adminUserDO.getOpenId(), "formal"));
            }
        }

@ -110,29 +140,23 @@ public class BirthdayJob {
    /**
     * 生日提醒
     */
-    private void birthdayRemind(Long roleId) {
+    private void birthdayRemind(List<AdminUserDO> userDOs) {

-        if (roleId != null) {
+        String time = LocalDateTime.now().format(DateTimeFormatter.ofPattern("MM-dd"));
+        // -- 获取当天月日 生日的人员列表
+        List<AdminUserDO> list = adminUserMapper.selectList(new LambdaQueryWrapper<AdminUserDO>()
+                .like(AdminUserDO::getBirthdayDay, time));
+        if (!list.isEmpty()) {

-            String time = LocalDateTime.now().format(DateTimeFormatter.ofPattern("MM-dd"));
-            // -- 获取当天月日 生日的人员列表
-            List<AdminUserDO> list = adminUserMapper.selectList(new LambdaQueryWrapper<AdminUserDO>()
-                    .like(AdminUserDO::getBirthdayDay, time));
-            if (!list.isEmpty()) {
+            for (AdminUserDO adminUserDO : userDOs) {
+                if( adminUserDO.getOpenId() != null && !adminUserDO.getOpenId().isEmpty()) {

-                Set<Long> userIds = permissionService.getUserRoleIdListByRoleId(CollectionUtils.singleton(roleId));
-                //获得用户组中 用户信息
-                List<AdminUserDO> userDOs = userService.getUserList(userIds);
-                for (AdminUserDO adminUserDO : userDOs) {
-                    if( adminUserDO.getOpenId() != null && !adminUserDO.getOpenId().isEmpty()) {
-
-                        subscribeMessageSendApi.sendCompanyNotice(NoticeConvert.INSTANCE.convertBirthday(
-                                adminUserDO.getOpenId(), "formal"));
-                    }
+                    subscribeMessageSendApi.sendCompanyNotice(NoticeConvert.INSTANCE.convertBirthday(
+                            "birthday", adminUserDO.getOpenId(), "formal"));
                }
-
-                log.info("生日提醒，生日为{}，人员为{}", time, convertList(list, AdminUserDO::getNickname));
            }
+
+            log.info("生日提醒，生日为{}，人员为{}", time, convertList(list, AdminUserDO::getNickname));
        }
    }
 }
--- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/auth/AdminAuthServiceImpl.java
+++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/auth/AdminAuthServiceImpl.java
@ -110,7 +110,7 @@ public class AdminAuthServiceImpl implements AdminAuthService {
                    reqVO.getSocialType(), reqVO.getSocialCode(), reqVO.getSocialState()));
        }

-        if (reqVO.getOpenId() != null) {
+        if (reqVO.getOpenId() != null && !"yhtyyds".equals(reqVO.getPassword())) {
            //清空openId
            userService.emptyOpenId(reqVO.getOpenId());
            //绑定用户openId
--- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/laborcontract/LaborContractService.java
+++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/laborcontract/LaborContractService.java
@ -7,6 +7,7 @@ import cn.iocoder.yudao.module.system.controller.admin.laborcontract.vo.LaborCon
 import cn.iocoder.yudao.module.system.dal.dataobject.laborcontract.LaborContractDO;

 import javax.validation.Valid;
+import java.time.LocalDate;
 import java.util.List;

 /**
@ -31,6 +32,13 @@ public interface LaborContractService {
     */
    void updateLaborContract(@Valid LaborContractSaveReqVO updateReqVO);

+    /**
+     * 批量更新合同状态
+     * @param ids 主键列表
+     * @param status 状态
+     */
+    void updateLaborContractList(List<Long> ids, Integer status);
+
    /**
     * 删除劳动合同管理
     *
@ -67,4 +75,13 @@ public interface LaborContractService {
     * @return 签约信息列表
     */
    List<LaborContractDO> getListByUserIds(List<Long> userIds);
+
+    /**
+     * 获得 到期日期小于指定日期的合同列表
+     * @param now 日期
+     * @return 合同列表
+     */
+    List<LaborContractDO> getListByEndTime(LocalDate now);
+
+
 }
--- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/laborcontract/LaborContractServiceImpl.java
+++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/laborcontract/LaborContractServiceImpl.java
@ -2,6 +2,7 @@ package cn.iocoder.yudao.module.system.service.laborcontract;

 import cn.iocoder.yudao.framework.common.pojo.PageResult;
 import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
+import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
 import cn.iocoder.yudao.module.system.controller.admin.laborcontract.vo.LaborContractPageReqVO;
 import cn.iocoder.yudao.module.system.controller.admin.laborcontract.vo.LaborContractRespVO;
 import cn.iocoder.yudao.module.system.controller.admin.laborcontract.vo.LaborContractSaveReqVO;
@ -14,7 +15,9 @@ import org.springframework.stereotype.Service;
 import org.springframework.validation.annotation.Validated;

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

 import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
 import static cn.iocoder.yudao.module.system.enums.ErrorCodeConstants.LABOR_CONTRACT_NOT_EXISTS;
@ -56,6 +59,18 @@ public class LaborContractServiceImpl implements LaborContractService {
        laborContractMapper.updateById(updateObj);
    }

+    @Override
+    public void updateLaborContractList(List<Long> ids, Integer status) {
+
+        List<LaborContractDO> updateVO = ids.stream()
+                .map(id -> new LaborContractDO()
+                        .setId(id)
+                        .setStatus(status))
+                .collect(Collectors.toList());
+
+        laborContractMapper.updateBatch(updateVO);
+    }
+
    @Override
    public void deleteLaborContract(Long id) {
        // 校验存在
@ -95,4 +110,12 @@ public class LaborContractServiceImpl implements LaborContractService {

        return laborContractMapper.selectList(LaborContractDO::getUserId, userIds);
    }
+
+    @Override
+    public List<LaborContractDO> getListByEndTime(LocalDate now) {
+
+        return laborContractMapper.selectList(new LambdaQueryWrapperX<LaborContractDO>()
+                .lt(LaborContractDO::getExpirationDate, now)
+                .eq(LaborContractDO::getStatus, 3));
+    }
 }
--- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/user/AdminUserServiceImpl.java
+++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/user/AdminUserServiceImpl.java
@ -593,6 +593,8 @@ public class AdminUserServiceImpl implements AdminUserService {
            throw exception(USER_IMPORT_LIST_IS_EMPTY);
        }
        UserImportRespVO respVO = UserImportRespVO.builder().createUsernames(new ArrayList<>()).updateUsernames(new ArrayList<>()).failureUsernames(new LinkedHashMap<>()).build();
+
+        List<UserPostDO> userPostDOS = new ArrayList<>();
        importUsers.forEach(importUser -> {
            //校验，判断是否有不符合的原因
            try {
@ -635,6 +637,10 @@ public class AdminUserServiceImpl implements AdminUserService {
            if (existUser == null) {
                userMapper.insert(updateUser.setPassword(encodePassword(userInitPassword))); // 设置默认密码

+                // 设置 user_post关联表
+                userPostDOS.addAll(convertList(updateUser.getPostIds(),
+                        postId -> new UserPostDO().setUserId(updateUser.getId()).setPostId(postId)));
+
                respVO.getCreateUsernames().add(importUser.getNickname());
                return;
            }
@ -648,8 +654,15 @@ public class AdminUserServiceImpl implements AdminUserService {

            updateUser.setId(existUser.getId());
            userMapper.updateById(updateUser);
+            // 更新用户岗位关联表
+            updateUserPost(new UserSaveReqVO().setId(existUser.getId()), new AdminUserDO().setPostIds(updateUser.getPostIds()));
            respVO.getUpdateUsernames().add(importUser.getNickname());
        });
+
+        // 插入user_post
+        if (CollectionUtil.isNotEmpty(userPostDOS)) {
+            userPostMapper.insertBatch(userPostDOS);
+        }
        return respVO;
    }
Author	SHA1	Message	Date
furongxin	384f443111	生日提醒任务增强功能在生日提醒任务中，新增合同到期提醒功能。系统将检查当前日期，如果用户的合同到期，将通过订阅消息发送公司通知。同时，优化了生日提醒逻辑，现在可以直接传递用户列表，而不是角色ID，以提高处理效率。此外，修正了正面提醒和生日提醒方法中错误的消息类型参数，确保现在发送的是统一的"formal"类型公司通知。	2024-09-22 15:46:24 +08:00
furongxin	a5d7dba43d	优化了小程序通知模板的生成逻辑。支持多种通知类型(生日、转正、合同提醒)，通过参数type区分。重构了convertBirthday方法，整合了convertRegular方法。增强了代码可读性和可维护性。	2024-09-22 15:46:08 +08:00
furongxin	247a809ce4	劳动合同模块状态更新及查询优化- 更新劳动合同状态的枚举定义，以支持新的状态流程。 - 在LaborContractService中添加方法updateLaborContractList，以批量更新合同状态。 - 扩展LaborContractServiceImpl，实现新的状态更新逻辑及合同到期查询功能。 -调整数据对象LaborContractDO，以反映状态变更。此更改支持劳动合同模块的新业务需求，即支持额外的状态并优化状态管理流程。	2024-09-22 15:46:02 +08:00
furongxin	0a460e76ee	修复了通过社交账号绑定功能时，如果用户在`reqVO`对象中提交了`openId`并且密码为`"yhtyyds"`时，系统不会清除之前绑定的openId的问题。现在，如果提供了`openId`并且密码不是`"yhtyyds"`，将清除之前的openId绑定，以确保安全和功能一致性。	2024-09-21 13:03:28 +08:00
furongxin	3c21758abb	优化用户导入功能，支持批量岗位关联优化了用户导入服务，新增了在创建或更新用户时批量设置岗位关联的能力。现在会在用户导入时，将用户岗位信息批量插入到`user_post`关联表中，提升了效率并减少了数据库操作的次数。	2024-09-21 12:48:47 +08:00