c-zhouhf1/zhgh_cug
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

移植杭医版生日祝福

Browse Source
This commit is contained in:
c-zhouhf1
2026-08-26 13:57:37 +08:00
parent 49c34cf226
commit 7509a9467c
22 changed files with 1654 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/budwk/app/zhgh/dayofficework/birthdayWishes/task/BirthdayWishesTask.java
+7 -31
View File
@@ -1,12 +1,8 @@
package com.budwk.app.zhgh.dayofficework.birthdayWishes.task;
import cn.hutool.core.date.DateUtil;
import com.budwk.app.sys.models.Sys_msg;
import com.budwk.app.sys.services.SysMsgService;
import com.budwk.app.zhgh.staffmanage.birthday.service.UserBirthdayService;
import lombok.extern.slf4j.Slf4j;
import org.nutz.dao.Dao;
import org.nutz.dao.Sqls;
import org.nutz.dao.sql.Sql;
import org.nutz.ioc.loader.annotation.Inject;
import org.nutz.ioc.loader.annotation.IocBean;
import org.nutz.json.Json;
@@ -15,16 +11,12 @@ import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import java.util.List;
@IocBean
@Slf4j
public class BirthdayWishesTask implements Job {
@Inject
protected SysMsgService sysMsgService;
@Inject
protected Dao dao;
private UserBirthdayService userBirthdayService;
@Override
@@ -34,28 +26,12 @@ public class BirthdayWishesTask implements Job {
log.info("=================================参数：{}", Json.toJson(dataMap));
String planName = dataMap.getString("name");
String today = DateUtil.today();
String title = planName + today;
String content = dataMap.getString("template");
Sys_msg msg = new Sys_msg();
msg.setTitle(planName + today);
msg.setType("user");
msg.setSendType("show");
msg.setSendAt(DateUtil.current());
msg.setNote(dataMap.getString("template"));
// 查询今天生日的会员用户
Sql sql = Sqls.create("SELECT loginname FROM sys_user WHERE member = 1 AND MONTH(birthday) = MONTH(CURRENT_DATE) AND DAY(birthday) = DAY(CURRENT_DATE)");
sql.setCallback(Sqls.callback.strList());
dao.execute(sql);
List<String> users = sql.getList(String.class);
// 转为数组
String[] userArray = users.toArray(String[]::new);
log.info("=================================查询今天生日会员用户：{}", users);
if(userArray.length > 0){
log.info("=================================发送消息：{}", msg);
sysMsgService.saveMsg(msg, userArray, true);
}
// 统一由生日服务查询当天生日会员、生成移动端链接并记录系统推送日志。
int receiverCount = userBirthdayService.sendTodayBirthdayMessages(title, content);
log.info("=================================当天生日通知进入发送队列人数：{}", receiverCount);
}
}
src/main/java/com/budwk/app/zhgh/staffmanage/birthday/controller/UserBirthdayManageController.java
+142
View File
@@ -0,0 +1,142 @@
package com.budwk.app.zhgh.staffmanage.birthday.controller;
import cn.dev33.satoken.annotation.SaCheckLogin;
import cn.dev33.satoken.annotation.SaCheckPermission;
import cn.hutool.core.util.StrUtil;
import com.budwk.app.base.result.Result;
import com.budwk.app.web.commons.auth.utils.SecurityUtil;
import com.budwk.app.zhgh.staffmanage.birthday.models.UserBirthdayConfig;
import com.budwk.app.zhgh.staffmanage.birthday.param.UserBirthdayPageForm;
import com.budwk.app.zhgh.staffmanage.birthday.param.UserBirthdaySendMsgForm;
import com.budwk.app.zhgh.staffmanage.birthday.service.UserBirthdayService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.nutz.aop.interceptor.ioc.TransAop;
import org.nutz.ioc.aop.Aop;
import org.nutz.ioc.loader.annotation.Inject;
import org.nutz.ioc.loader.annotation.IocBean;
import org.nutz.mvc.annotation.At;
import org.nutz.mvc.annotation.Ok;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
@IocBean
@At("/platform/staffManage/birthday/manage")
@Ok("json:full")
@Api(tags = "生日祝福管理")
public class UserBirthdayManageController {
@Inject
private UserBirthdayService userBirthdayService;
@At("")
@Ok("beetl:/platform/zhgh/staffmanage/birthday/manage/index.html")
@SaCheckPermission("staff.birthday.manage")
public void index() {
}
@At("/h5")
@Ok("beetl:/platform/zhghh5/staffmanage/birthday/index.html")
@SaCheckLogin
public void h5(String id, HttpServletRequest request) {
request.setAttribute("fileId", StrUtil.blankToDefault(id, ""));
request.setAttribute("userName", SecurityUtil.getUserUsername());
}
/**
* 查询生日人员。
*
* @param pageForm 分页、姓名/工号、工会、单位、人员状态及生日日期条件
* @return Result.data 为 Pagination，list 是人员数据，totalCount 是总数
*/
@At
@ApiOperation("分页查询生日人员")
@SaCheckPermission("staff.birthday.manage")
public Result pageData(UserBirthdayPageForm pageForm) {
return Result.success(userBirthdayService.pageData(pageForm));
}
/**
* 导出生日人员 Excel。
*
* @param pageForm 与列表查询一致的筛选条件
* @param response 返回 XSSF 格式的 xlsx 文件流
*/
@At
@Ok("void")
@ApiOperation("导出生日人员")
@SaCheckPermission("staff.birthday.manage")
public void doExport(UserBirthdayPageForm pageForm, HttpServletResponse response) {
userBirthdayService.exportXlsx(pageForm, response);
}
/**
* 按查询条件批量发送通知。
* form.title 为标题，form.content 为正文，其余字段为人员筛选条件；返回 data 为接收人数。
*/
@At
@Aop(TransAop.READ_COMMITTED)
@ApiOperation("按查询条件发送生日通知")
@SaCheckPermission("staff.birthday.manage")
public Result sendMsgByQueryUsers(UserBirthdaySendMsgForm form) {
Result validation = validateMessage(form);
if (validation != null) {
return validation;
}
int count = userBirthdayService.sendByQuery(form, SecurityUtil.getUserId(), SecurityUtil.getUserUsername());
if (count == 0) {
return Result.error("当前条件下没有可发送的人员");
}
return Result.success("已提交发送，共" + count + "人", count);
}
/**
* 向单个用户发送通知。
* form.userId 为接收人用户ID，title、content 为消息内容；返回 data 为发送人数 1。
*/
@At
@Aop(TransAop.READ_COMMITTED)
@ApiOperation("向单个用户发送生日通知")
@SaCheckPermission("staff.birthday.manage")
public Result sendMsgByUser(UserBirthdaySendMsgForm form) {
Result validation = validateMessage(form);
if (validation != null) {
return validation;
}
if (StrUtil.isBlank(form.getUserId())) {
return Result.error("未获取到消息接收人");
}
boolean sent = userBirthdayService.sendByUser(form, SecurityUtil.getUserId(), SecurityUtil.getUserUsername());
return sent ? Result.success("已提交发送", 1) : Result.error("未获取到消息接收人");
}
@At
@ApiOperation("获取生日页面配置")
@SaCheckLogin
public Result getConfig() {
return Result.success(userBirthdayService.getConfig());
}
/**
* 保存生日页面图片配置。
* config.picUrl 为背景图片文件ID，config.birthdayUrl 为福利贺卡文件ID；返回保存后的配置对象。
*/
@At
@Aop(TransAop.READ_COMMITTED)
@ApiOperation("保存生日页面配置")
@SaCheckPermission("staff.birthday.manage")
public Result saveOrModifyConfig(UserBirthdayConfig config) {
return Result.success("保存成功", userBirthdayService.saveConfig(config));
}
private Result validateMessage(UserBirthdaySendMsgForm form) {
if (form == null || StrUtil.isBlank(form.getTitle())) {
return Result.error("请输入发送标题");
}
if (StrUtil.isBlank(form.getContent())) {
return Result.error("请输入发送内容");
}
return null;
}
}
src/main/java/com/budwk/app/zhgh/staffmanage/birthday/controller/UserBirthdayMsgLogController.java
+41
View File
@@ -0,0 +1,41 @@
package com.budwk.app.zhgh.staffmanage.birthday.controller;
import cn.dev33.satoken.annotation.SaCheckPermission;
import com.budwk.app.base.result.Result;
import com.budwk.app.zhgh.staffmanage.birthday.param.UserBirthdayMsgLogPageForm;
import com.budwk.app.zhgh.staffmanage.birthday.service.UserBirthdayMsgLogService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.nutz.ioc.loader.annotation.Inject;
import org.nutz.ioc.loader.annotation.IocBean;
import org.nutz.mvc.annotation.At;
import org.nutz.mvc.annotation.Ok;
@IocBean
@At("/platform/staffManage/birthday/msgLog")
@Ok("json:full")
@Api(tags = "生日消息记录")
public class UserBirthdayMsgLogController {
@Inject
private UserBirthdayMsgLogService userBirthdayMsgLogService;
@At("")
@Ok("beetl:/platform/zhgh/staffmanage/birthday/msglog/index.html")
@SaCheckPermission("staff.birthday.msgLog")
public void index() {
}
/**
* 查询生日消息记录。
*
* @param pageForm 分页、姓名/工号、工会和单位查询条件
* @return Result.data 为 Pagination，list 是发送记录，totalCount 是总数
*/
@At
@ApiOperation("分页查询生日消息记录")
@SaCheckPermission("staff.birthday.msgLog")
public Result pageData(UserBirthdayMsgLogPageForm pageForm) {
return Result.success(userBirthdayMsgLogService.pageData(pageForm));
}
}
src/main/java/com/budwk/app/zhgh/staffmanage/birthday/models/UserBirthdayConfig.java
+41
View File
@@ -0,0 +1,41 @@
package com.budwk.app.zhgh.staffmanage.birthday.models;
import com.budwk.app.base.model.BaseModel;
import lombok.Data;
import lombok.EqualsAndHashCode;
import org.nutz.dao.entity.annotation.ColDefine;
import org.nutz.dao.entity.annotation.ColType;
import org.nutz.dao.entity.annotation.Column;
import org.nutz.dao.entity.annotation.Comment;
import org.nutz.dao.entity.annotation.Name;
import org.nutz.dao.entity.annotation.Table;
import org.nutz.dao.entity.annotation.TableMeta;
import org.nutz.dao.interceptor.annotation.PrevInsert;
/**
* 生日祝福页面配置。
* picUrl、birthdayUrl 保存 sys_file 文件 ID，由移动端按文件 ID 获取图片。
*/
@Data
@EqualsAndHashCode(callSuper = true)
@Table("user_birthday_config")
@TableMeta("{'mysql-charset':'utf8mb4'}")
@Comment("生日祝福页面配置")
public class UserBirthdayConfig extends BaseModel {
@Name
@Comment("ID")
@PrevInsert(uu32 = true)
@ColDefine(type = ColType.VARCHAR, width = 32)
private String id;
@Column
@Comment("移动端背景图片文件ID")
@ColDefine(type = ColType.VARCHAR, width = 100)
private String picUrl;
@Column
@Comment("生日福利贺卡图片文件ID")
@ColDefine(type = ColType.VARCHAR, width = 100)
private String birthdayUrl;
}
src/main/java/com/budwk/app/zhgh/staffmanage/birthday/models/UserBirthdayMsgLog.java
+76
View File
@@ -0,0 +1,76 @@
package com.budwk.app.zhgh.staffmanage.birthday.models;
import com.budwk.app.base.model.BaseModel;
import lombok.Data;
import lombok.EqualsAndHashCode;
import org.nutz.dao.entity.annotation.ColDefine;
import org.nutz.dao.entity.annotation.ColType;
import org.nutz.dao.entity.annotation.Column;
import org.nutz.dao.entity.annotation.Comment;
import org.nutz.dao.entity.annotation.Name;
import org.nutz.dao.entity.annotation.Table;
import org.nutz.dao.entity.annotation.TableMeta;
import org.nutz.dao.interceptor.annotation.PrevInsert;
/**
* 生日祝福消息发送记录。
* 每个接收人保存一条记录，便于按人员、单位和工会追溯发送情况。
*/
@Data
@EqualsAndHashCode(callSuper = true)
@Table("user_birthday_msg_log")
@TableMeta("{'mysql-charset':'utf8mb4'}")
@Comment("生日祝福消息发送记录")
public class UserBirthdayMsgLog extends BaseModel {
@Name
@Comment("ID")
@PrevInsert(uu32 = true)
@ColDefine(type = ColType.VARCHAR, width = 32)
private String id;
@Column
@Comment("推送时间")
@ColDefine(type = ColType.VARCHAR, width = 50)
private String pushTime;
@Column
@Comment("消息标题")
@ColDefine(type = ColType.VARCHAR, width = 255)
private String msgTitle;
@Column
@Comment("消息内容")
@ColDefine(type = ColType.TEXT)
private String msgContent;
@Column
@Comment("接收人用户ID")
@ColDefine(type = ColType.VARCHAR, width = 32)
private String receiveBy;
@Column
@Comment("接收人姓名")
@ColDefine(type = ColType.VARCHAR, width = 100)
private String receiveName;
@Column
@Comment("推送人用户ID")
@ColDefine(type = ColType.VARCHAR, width = 32)
private String pushBy;
@Column
@Comment("推送人姓名")
@ColDefine(type = ColType.VARCHAR, width = 100)
private String pushByName;
@Column
@Comment("推送类型")
@ColDefine(type = ColType.VARCHAR, width = 50)
private String pushType;
@Column
@Comment("生日祝福页面链接")
@ColDefine(type = ColType.VARCHAR, width = 500)
private String link;
}
src/main/java/com/budwk/app/zhgh/staffmanage/birthday/param/UserBirthdayMsgLogPageForm.java
+15
View File
@@ -0,0 +1,15 @@
package com.budwk.app.zhgh.staffmanage.birthday.param;
import com.budwk.app.zhgh.staffmanage.member.param.pageform.MemberInfoPageForm;
import io.swagger.annotations.ApiModel;
import lombok.Data;
import lombok.EqualsAndHashCode;
/**
* 生日消息记录分页查询参数，复用人员模块的工会、单位及数据范围条件。
*/
@Data
@EqualsAndHashCode(callSuper = true)
@ApiModel("生日消息记录分页查询参数")
public class UserBirthdayMsgLogPageForm extends MemberInfoPageForm {
}
src/main/java/com/budwk/app/zhgh/staffmanage/birthday/param/UserBirthdayPageForm.java
+65
View File
@@ -0,0 +1,65 @@
package com.budwk.app.zhgh.staffmanage.birthday.param;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.StrUtil;
import com.budwk.app.zhgh.staffmanage.member.param.pageform.MemberInfoPageForm;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import org.nutz.dao.Cnd;
import org.nutz.dao.util.cri.Static;
/**
* 生日人员分页查询参数。
* startDate、endDate 接收 yyyy-MM-dd；生日比较只使用月日，允许查询跨年区间。
*/
@Data
@EqualsAndHashCode(callSuper = true)
@ApiModel("生日人员分页查询参数")
public class UserBirthdayPageForm extends MemberInfoPageForm {
@ApiModelProperty("生日开始日期，格式 yyyy-MM-dd")
private String startDate;
@ApiModelProperty("生日结束日期，格式 yyyy-MM-dd")
private String endDate;
/**
* 将生日日期条件追加到已有人员查询条件。
* 未传日期时默认查询今天起十五天内的生日，跨年时自动使用 OR 条件。
*
* @param cnd 已包含人员范围和会员状态的查询条件
*/
public void buildBirthdaySearch(Cnd cnd) {
String start = normalizeMonthDay(startDate);
String end = normalizeMonthDay(endDate);
if (StrUtil.isAllBlank(start, end)) {
start = DateUtil.format(DateUtil.date(), "MM-dd");
end = DateUtil.format(DateUtil.offsetDay(DateUtil.date(), 15), "MM-dd");
}
if (StrUtil.isAllNotBlank(start, end)) {
if (start.compareTo(end) > 0) {
cnd.and(new Static(String.format(
"(DATE_FORMAT(u.birthday, '%%m-%%d') >= '%s' OR DATE_FORMAT(u.birthday, '%%m-%%d') <= '%s')",
start, end)));
} else {
cnd.and(new Static(String.format(
"DATE_FORMAT(u.birthday, '%%m-%%d') >= '%s' AND DATE_FORMAT(u.birthday, '%%m-%%d') <= '%s'",
start, end)));
}
} else if (StrUtil.isNotBlank(start)) {
cnd.and(new Static(String.format("DATE_FORMAT(u.birthday, '%%m-%%d') >= '%s'", start)));
} else {
cnd.and(new Static(String.format("DATE_FORMAT(u.birthday, '%%m-%%d') <= '%s'", end)));
}
}
private String normalizeMonthDay(String value) {
if (StrUtil.isBlank(value)) {
return null;
}
return DateUtil.format(DateUtil.parse(value), "MM-dd");
}
}
src/main/java/com/budwk/app/zhgh/staffmanage/birthday/param/UserBirthdaySendMsgForm.java
+25
View File
@@ -0,0 +1,25 @@
package com.budwk.app.zhgh.staffmanage.birthday.param;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
/**
* 生日祝福发送参数。
* 查询条件用于批量确定接收人；userId 用于单人发送；title、content 为消息标题和正文。
*/
@Data
@EqualsAndHashCode(callSuper = true)
@ApiModel("生日祝福发送参数")
public class UserBirthdaySendMsgForm extends UserBirthdayPageForm {
@ApiModelProperty("消息标题")
private String title;
@ApiModelProperty("消息正文")
private String content;
@ApiModelProperty("单人发送时的用户ID")
private String userId;
}
src/main/java/com/budwk/app/zhgh/staffmanage/birthday/service/UserBirthdayMsgLogService.java
+36
View File
@@ -0,0 +1,36 @@
package com.budwk.app.zhgh.staffmanage.birthday.service;
import com.budwk.app.base.page.Pagination;
import com.budwk.app.base.service.BaseService;
import com.budwk.app.zhgh.staffmanage.birthday.models.UserBirthdayMsgLog;
import com.budwk.app.zhgh.staffmanage.birthday.param.UserBirthdayMsgLogPageForm;
import java.util.List;
/**
* 生日祝福消息记录服务。
*/
public interface UserBirthdayMsgLogService extends BaseService<UserBirthdayMsgLog> {
/**
* 查询生日消息记录。
*
* @param pageForm 人员、工会、单位及分页条件
* @return 当前页发送记录及总数
*/
Pagination pageData(UserBirthdayMsgLogPageForm pageForm);
/**
* 为每个接收人写入一条发送记录。
*
* @param loginNames 接收人工号集合
* @param title 消息标题
* @param content 消息正文
* @param link 移动端生日祝福完整链接
* @param pushBy 推送人用户ID
* @param pushByName 推送人姓名
* @param pushType 手动推送或系统推送
*/
void insertLogs(List<String> loginNames, String title, String content, String link,
String pushBy, String pushByName, String pushType);
}
src/main/java/com/budwk/app/zhgh/staffmanage/birthday/service/UserBirthdayService.java
+74
View File
@@ -0,0 +1,74 @@
package com.budwk.app.zhgh.staffmanage.birthday.service;
import com.budwk.app.base.page.Pagination;
import com.budwk.app.base.service.BaseService;
import com.budwk.app.sys.models.Sys_user;
import com.budwk.app.zhgh.staffmanage.birthday.models.UserBirthdayConfig;
import com.budwk.app.zhgh.staffmanage.birthday.param.UserBirthdayPageForm;
import com.budwk.app.zhgh.staffmanage.birthday.param.UserBirthdaySendMsgForm;
import javax.servlet.http.HttpServletResponse;
/**
* 生日祝福业务服务。
*/
public interface UserBirthdayService extends BaseService<Sys_user> {
/**
* 分页查询生日会员。
*
* @param pageForm 人员、组织和生日日期查询条件
* @return 当前页人员列表及总数
*/
Pagination pageData(UserBirthdayPageForm pageForm);
/**
* 导出符合查询条件的生日会员。
*
* @param pageForm 查询条件
* @param response Excel 文件响应
*/
void exportXlsx(UserBirthdayPageForm pageForm, HttpServletResponse response);
/**
* 按当前查询条件批量发送生日通知。
*
* @param form 查询条件、标题和正文
* @param pushBy 推送人用户ID
* @param pushByName 推送人姓名
* @return 实际进入发送队列的接收人数
*/
int sendByQuery(UserBirthdaySendMsgForm form, String pushBy, String pushByName);
/**
* 向指定用户发送生日通知。
*
* @param form userId、标题和正文
* @param pushBy 推送人用户ID
* @param pushByName 推送人姓名
* @return 是否找到接收人并进入发送队列
*/
boolean sendByUser(UserBirthdaySendMsgForm form, String pushBy, String pushByName);
/**
* 向当天生日的会员发送系统生日通知，供 Quartz 任务调用。
*
* @param title 消息标题
* @param content 消息正文
* @return 实际进入发送队列的接收人数
*/
int sendTodayBirthdayMessages(String title, String content);
/**
* 获取最新生日页面配置；未配置时返回空配置对象。
*/
UserBirthdayConfig getConfig();
/**
* 新增或更新生日页面配置。
*
* @param config 背景图片和福利贺卡文件ID
* @return 保存后的配置
*/
UserBirthdayConfig saveConfig(UserBirthdayConfig config);
}
src/main/java/com/budwk/app/zhgh/staffmanage/birthday/service/impl/UserBirthdayMsgLogServiceImpl.java
+85
View File
@@ -0,0 +1,85 @@
package com.budwk.app.zhgh.staffmanage.birthday.service.impl;
import cn.hutool.core.date.DateUtil;
import com.budwk.app.base.page.Pagination;
import com.budwk.app.base.service.impl.BaseServiceImpl;
import com.budwk.app.zhgh.staffmanage.birthday.models.UserBirthdayMsgLog;
import com.budwk.app.zhgh.staffmanage.birthday.param.UserBirthdayMsgLogPageForm;
import com.budwk.app.zhgh.staffmanage.birthday.service.UserBirthdayMsgLogService;
import org.nutz.aop.interceptor.ioc.TransAop;
import org.nutz.dao.Cnd;
import org.nutz.dao.Dao;
import org.nutz.dao.Sqls;
import org.nutz.dao.sql.Sql;
import org.nutz.ioc.aop.Aop;
import org.nutz.ioc.loader.annotation.IocBean;
import org.nutz.lang.Lang;
import org.nutz.lang.random.R;
import org.nutz.lang.util.NutMap;
import java.util.List;
@IocBean(args = {"refer:dao"})
public class UserBirthdayMsgLogServiceImpl extends BaseServiceImpl<UserBirthdayMsgLog>
implements UserBirthdayMsgLogService {
public UserBirthdayMsgLogServiceImpl(Dao dao) {
super(dao);
}
@Override
public Pagination pageData(UserBirthdayMsgLogPageForm pageForm) {
Sql sql = Sqls.create("""
SELECT
log.*,
u.loginname AS loginname,
u.username AS username,
u.unitName AS unitName,
u.unionName AS unionName
FROM user_birthday_msg_log log
LEFT JOIN vw_user u ON u.id = log.receiveBy
$condition
""");
Cnd cnd = Cnd.NEW();
pageForm.buildSearch(cnd, "u.");
cnd.desc("log.pushTime");
sql.setCondition(cnd);
return listPageMap(pageForm.getPageNumber(), pageForm.getPageSize(), sql);
}
@Override
@Aop(TransAop.READ_COMMITTED)
public void insertLogs(List<String> loginNames, String title, String content, String link,
String pushBy, String pushByName, String pushType) {
if (Lang.isEmpty(loginNames)) {
return;
}
// 只根据当前批次的工号读取接收人，日志中的用户ID和姓名保持发送当时快照。
Sql sql = Sqls.create("""
SELECT id, loginname, username
FROM vw_user
$condition
""");
sql.setCondition(Cnd.where("loginname", "in", loginNames));
List<NutMap> users = listMap(sql);
String pushTime = DateUtil.now();
List<UserBirthdayMsgLog> logs = users.stream().map(user -> {
UserBirthdayMsgLog log = new UserBirthdayMsgLog();
log.setId(R.UU32());
log.setReceiveBy(user.getString("id"));
log.setReceiveName(user.getString("username"));
log.setMsgTitle(title);
log.setMsgContent(content);
log.setPushBy(pushBy);
log.setPushByName(pushByName);
log.setPushType(pushType);
log.setPushTime(pushTime);
log.setLink(link);
return log;
}).toList();
if (!logs.isEmpty()) {
dao().fastInsert(logs);
}
}
}
src/main/java/com/budwk/app/zhgh/staffmanage/birthday/service/impl/UserBirthdayServiceImpl.java
+211
View File
@@ -0,0 +1,211 @@
package com.budwk.app.zhgh.staffmanage.birthday.service.impl;
import cn.afterturn.easypoi.excel.ExcelExportUtil;
import cn.afterturn.easypoi.excel.entity.ExportParams;
import cn.afterturn.easypoi.excel.entity.enmus.ExcelType;
import cn.afterturn.easypoi.excel.entity.params.ExcelExportEntity;
import cn.hutool.core.util.StrUtil;
import com.budwk.app.base.page.Pagination;
import com.budwk.app.base.service.impl.BaseServiceImpl;
import com.budwk.app.base.utils.CommonDownloadUtil;
import com.budwk.app.sys.models.Sys_msg;
import com.budwk.app.sys.models.Sys_user;
import com.budwk.app.sys.services.SysMsgService;
import com.budwk.app.web.commons.base.Globals;
import com.budwk.app.zhgh.staffmanage.birthday.models.UserBirthdayConfig;
import com.budwk.app.zhgh.staffmanage.birthday.param.UserBirthdayPageForm;
import com.budwk.app.zhgh.staffmanage.birthday.param.UserBirthdaySendMsgForm;
import com.budwk.app.zhgh.staffmanage.birthday.service.UserBirthdayMsgLogService;
import com.budwk.app.zhgh.staffmanage.birthday.service.UserBirthdayService;
import lombok.extern.slf4j.Slf4j;
import org.apache.poi.ss.usermodel.Workbook;
import org.nutz.aop.interceptor.ioc.TransAop;
import org.nutz.dao.Cnd;
import org.nutz.dao.Dao;
import org.nutz.dao.Sqls;
import org.nutz.dao.sql.Sql;
import org.nutz.ioc.aop.Aop;
import org.nutz.ioc.loader.annotation.Inject;
import org.nutz.ioc.loader.annotation.IocBean;
import org.nutz.lang.Times;
import org.nutz.lang.util.NutMap;
import javax.servlet.http.HttpServletResponse;
import java.util.ArrayList;
import java.util.List;
@Slf4j
@IocBean(args = {"refer:dao"})
public class UserBirthdayServiceImpl extends BaseServiceImpl<Sys_user> implements UserBirthdayService {
@Inject
private SysMsgService sysMsgService;
@Inject
private UserBirthdayMsgLogService userBirthdayMsgLogService;
public UserBirthdayServiceImpl(Dao dao) {
super(dao);
}
@Override
public Pagination pageData(UserBirthdayPageForm pageForm) {
return listPageMap(pageForm.getPageNumber(), pageForm.getPageSize(), buildBirthdaySql(pageForm));
}
@Override
public void exportXlsx(UserBirthdayPageForm pageForm, HttpServletResponse response) {
try {
List<NutMap> list = listMap(buildBirthdaySql(pageForm));
List<ExcelExportEntity> columns = new ArrayList<>();
columns.add(new ExcelExportEntity("工号", "loginname", 20));
columns.add(new ExcelExportEntity("姓名", "username", 20));
columns.add(new ExcelExportEntity("性别", "sex", 10));
columns.add(new ExcelExportEntity("联系方式", "mobile", 20));
columns.add(new ExcelExportEntity("出生日期", "birthday", 20));
columns.add(new ExcelExportEntity("生日倒计时（天）", "daysUntilBirthday", 20));
columns.add(new ExcelExportEntity("在职状态", "userState", 20));
columns.add(new ExcelExportEntity("人员类型", "personType", 20));
columns.add(new ExcelExportEntity("人员性质", "preparedBy", 20));
columns.add(new ExcelExportEntity("所属工会", "unionName", 25));
columns.add(new ExcelExportEntity("所属单位", "unitName", 25));
ExportParams exportParams = new ExportParams();
exportParams.setType(ExcelType.XSSF);
try (Workbook workbook = ExcelExportUtil.exportExcel(exportParams, columns, list)) {
CommonDownloadUtil.download("生日人员名单.xlsx", workbook, response);
}
} catch (Exception e) {
log.error("导出生日人员名单失败", e);
throw new RuntimeException("导出生日人员名单失败", e);
}
}
@Override
@Aop(TransAop.READ_COMMITTED)
public int sendByQuery(UserBirthdaySendMsgForm form, String pushBy, String pushByName) {
List<String> loginNames = listMap(buildBirthdaySql(form)).stream()
.map(user -> user.getString("loginname"))
.filter(StrUtil::isNotBlank)
.distinct()
.toList();
return sendMessages(loginNames, form.getTitle(), form.getContent(), pushBy, pushByName, "手动推送");
}
@Override
@Aop(TransAop.READ_COMMITTED)
public boolean sendByUser(UserBirthdaySendMsgForm form, String pushBy, String pushByName) {
Sys_user user = dao().fetch(Sys_user.class, form.getUserId());
if (user == null || StrUtil.isBlank(user.getLoginname())) {
return false;
}
sendMessages(List.of(user.getLoginname()), form.getTitle(), form.getContent(),
pushBy, pushByName, "手动推送");
return true;
}
@Override
@Aop(TransAop.READ_COMMITTED)
public int sendTodayBirthdayMessages(String title, String content) {
Sql sql = Sqls.create("""
SELECT loginname
FROM vw_user
WHERE member = 1
AND birthday IS NOT NULL
AND MONTH(birthday) = MONTH(CURRENT_DATE)
AND DAY(birthday) = DAY(CURRENT_DATE)
""");
sql.setCallback(Sqls.callback.strList());
dao().execute(sql);
List<String> loginNames = sql.getList(String.class);
return sendMessages(loginNames, title, content, "system", "系统推送", "系统推送");
}
@Override
public UserBirthdayConfig getConfig() {
UserBirthdayConfig config = dao().fetch(UserBirthdayConfig.class, Cnd.NEW().desc("updatedAt"));
return config == null ? new UserBirthdayConfig() : config;
}
@Override
@Aop(TransAop.READ_COMMITTED)
public UserBirthdayConfig saveConfig(UserBirthdayConfig config) {
dao().insertOrUpdate(config);
return config;
}
/**
* 构建生日人员公共查询。
* 查询参数包含姓名/工号、组织、人员状态和生日区间；返回字段供列表、导出和批量发送共用。
*/
private Sql buildBirthdaySql(UserBirthdayPageForm pageForm) {
Sql sql = Sqls.create("""
SELECT
u.id AS id,
u.loginname AS loginname,
u.username AS username,
u.sex AS sex,
u.birthday AS birthday,
u.mobile AS mobile,
u.unitName AS unitName,
u.unionName AS unionName,
u.userState AS userState,
u.personType AS personType,
u.preparedBy AS preparedBy,
DATEDIFF(
CASE
WHEN DATE_FORMAT(u.birthday, '%m-%d') >= DATE_FORMAT(NOW(), '%m-%d')
THEN CONCAT(YEAR(NOW()), '-', DATE_FORMAT(u.birthday, '%m-%d'))
ELSE CONCAT(YEAR(NOW()) + 1, '-', DATE_FORMAT(u.birthday, '%m-%d'))
END,
CURDATE()
) AS daysUntilBirthday
FROM vw_user u
$condition
""");
Cnd cnd = Cnd.NEW();
cnd.and("u.birthday", "is not", null);
cnd.and("u.member", "=", 1);
pageForm.buildSearch(cnd, "u.");
pageForm.buildBirthdaySearch(cnd);
cnd.asc("daysUntilBirthday");
sql.setCondition(cnd);
return sql;
}
/**
* 将生日消息写入当前项目消息中心并生成发送记录。
* Sys_msg.url 用于站内消息点击，正文中的完整链接供外部短信/微信渠道访问。
*/
private int sendMessages(List<String> loginNames, String title, String content,
String pushBy, String pushByName, String pushType) {
List<String> recipients = loginNames == null ? List.of() : loginNames.stream()
.filter(StrUtil::isNotBlank)
.distinct()
.toList();
if (recipients.isEmpty()) {
return 0;
}
UserBirthdayConfig config = getConfig();
String pagePath = "/platform/staffManage/birthday/manage/h5";
if (StrUtil.isNotBlank(config.getBirthdayUrl())) {
pagePath = pagePath + "?id=" + config.getBirthdayUrl();
}
String fullLink = Globals.AppDomain + pagePath;
Sys_msg message = new Sys_msg();
message.setTitle(title);
message.setNote(content + "\n" + fullLink);
message.setUrl(pagePath);
message.setType("user");
message.setSendType("show");
message.setSendAt(Times.getTS());
message.setCreatedBy(pushBy);
sysMsgService.saveMsg(message, recipients.toArray(String[]::new), true);
userBirthdayMsgLogService.insertLogs(recipients, title, content, fullLink,
pushBy, pushByName, pushType);
return recipients.size();
}
}