From ac64c21e39cbc448c32792f839f985e146c5b61f Mon Sep 17 00:00:00 2001 From: lSun <15893999301@qq.com> Date: Tue, 5 Aug 2025 17:48:22 +0800 Subject: [PATCH] =?UTF-8?q?=E9=BB=91=E5=90=8D=E5=8D=95=E5=AE=9A=E6=97=B6?= =?UTF-8?q?=E4=BB=BB=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../bonus/ahsbs/base/dao/BlackListDao.java | 29 ++++++++++ .../ahsbs/base/entity/BlackListBean.java | 44 +++++++++++++++ .../com/bonus/ahsbs/base/task/BlackTask.java | 53 +++++++++++++++++++ .../mappers/base/BlackListMapper.xml | 16 ++++++ 4 files changed, 142 insertions(+) create mode 100644 src/main/java/com/bonus/ahsbs/base/dao/BlackListDao.java create mode 100644 src/main/java/com/bonus/ahsbs/base/entity/BlackListBean.java create mode 100644 src/main/java/com/bonus/ahsbs/base/task/BlackTask.java create mode 100644 src/main/resources/mappers/base/BlackListMapper.xml diff --git a/src/main/java/com/bonus/ahsbs/base/dao/BlackListDao.java b/src/main/java/com/bonus/ahsbs/base/dao/BlackListDao.java new file mode 100644 index 0000000..e231b56 --- /dev/null +++ b/src/main/java/com/bonus/ahsbs/base/dao/BlackListDao.java @@ -0,0 +1,29 @@ +package com.bonus.ahsbs.base.dao; + + +import com.bonus.ahsbs.base.entity.BlackListBean; +import org.apache.ibatis.annotations.Param; +import org.springframework.stereotype.Repository; + +import java.util.List; +import java.util.Map; + +/** + * @author lsun + */ +@Repository(value = "BlackListDao") +public interface BlackListDao { + + /** + * 获取黑名单列表-当天 + * @param endTime + * @return + */ + List getList(String endTime); + + /** + * 修改状态 + * @param idNumber,endTime + */ + void updateStatus(@Param("idNumber") String idNumber, @Param("endTime") String endTime); +} diff --git a/src/main/java/com/bonus/ahsbs/base/entity/BlackListBean.java b/src/main/java/com/bonus/ahsbs/base/entity/BlackListBean.java new file mode 100644 index 0000000..15ec126 --- /dev/null +++ b/src/main/java/com/bonus/ahsbs/base/entity/BlackListBean.java @@ -0,0 +1,44 @@ +package com.bonus.ahsbs.base.entity; + +import lombok.Data; + +@Data +public class BlackListBean { + public String name; //姓名 + public String idNumber; //身份证 + public String age; + public String address; + public String event;//事件 + public String remark;//备注（岗位） + public String personType;//人员类型 + private String status; //是否生效 + private String dept;//所属分公司或者分包商 + private String post; + private String proId; + private String orgId; + private String proName; + private String orgName; + private String startTime; + private String endTime; + private Integer companyId; + + @Override + public String toString() { + return "BlackListBean{" + + "name='" + name + '\'' + + ", idNumber='" + idNumber + '\'' + + ", age='" + age + '\'' + + ", address='" + address + '\'' + + ", event='" + event + '\'' + + ", remark='" + remark + '\'' + + ", personType='" + personType + '\'' + + ", status='" + status + '\'' + + ", dept='" + dept + '\'' + + ", post='" + post + '\'' + + ", proId='" + proId + '\'' + + ", orgId='" + orgId + '\'' + + ", proName='" + proName + '\'' + + ", orgName='" + orgName + '\'' + + '}'; + } +} diff --git a/src/main/java/com/bonus/ahsbs/base/task/BlackTask.java b/src/main/java/com/bonus/ahsbs/base/task/BlackTask.java new file mode 100644 index 0000000..91d312e --- /dev/null +++ b/src/main/java/com/bonus/ahsbs/base/task/BlackTask.java @@ -0,0 +1,53 @@ +package com.bonus.ahsbs.base.task; + +import com.bonus.ahsbs.base.dao.BlackListDao; +import com.bonus.ahsbs.base.entity.BlackListBean; +import com.bonus.ahsbs.core.util.DateTimeHelper; +import lombok.extern.slf4j.Slf4j; +import org.springframework.scheduling.annotation.EnableAsync; +import org.springframework.scheduling.annotation.EnableScheduling; +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; +import java.util.Collections; +import java.util.List; + +/** + * packageName com.bonus.ahsbs.base.task + * + * @author lsun + * @version 1.0.0 + * @className BlackTask (此处以class为例) + * @date 2025/8/5 + * @description 实名制黑名单定时任务 + */ +@Component +@Slf4j +@EnableScheduling +@EnableAsync +public class BlackTask { + @Resource(name = "BlackListDao") + private BlackListDao dao; + + @Scheduled(cron = "0 0 23 * * ?") +// @Scheduled(cron = "0 */3 * * * ?") + public void attDataByWorkerADay() { + log.info("黑名单定时任务开始执行"); + try { + String endTime = DateTimeHelper.getNowDate(); + List list = dao.getList(endTime); + if (list != null && list.size() > 0) { + //获取list中所以的idNumber，进行循环修改 + for (BlackListBean bean : list) { + System.err.println("黑名单:"+bean.getIdNumber()); + dao.updateStatus(bean.getIdNumber(), endTime); + } + } + } catch (Exception e) { + log.error(e.toString(), e); + } + log.info("黑名单定时任务结束执行"); + } + +} diff --git a/src/main/resources/mappers/base/BlackListMapper.xml b/src/main/resources/mappers/base/BlackListMapper.xml new file mode 100644 index 0000000..b491921 --- /dev/null +++ b/src/main/resources/mappers/base/BlackListMapper.xml @@ -0,0 +1,16 @@ + + + + + UPDATE `bm_blacklist_worker` + SET status = '2' + WHERE id_number = #{idNumber} + AND end_time = #{endTime} + + + + \ No newline at end of file