From bc350c6492a2142233f691eb819eb01e1efe6b44 Mon Sep 17 00:00:00 2001
From: dxfeng <dongxuefengdd@163.com>
Date: Mon, 10 Mar 2025 15:20:05 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8C=89=E6=97=A5=E6=9C=9F=E6=9F=A5=E8=AF=A2?=
 =?UTF-8?q?=E5=B9=B6=E5=B0=86=E5=88=B0=E6=9C=9F=E7=9A=84=E5=91=98=E5=B7=A5?=
 =?UTF-8?q?=E7=8A=B6=E6=80=81=E6=9B=B4=E6=96=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../cronjob/EmployeeRegularizationJob.java    | 44 +++++++++++++++++++
 1 file changed, 44 insertions(+)
 create mode 100644 src/weaver/interfaces/zhewen/cronjob/EmployeeRegularizationJob.java

diff --git a/src/weaver/interfaces/zhewen/cronjob/EmployeeRegularizationJob.java b/src/weaver/interfaces/zhewen/cronjob/EmployeeRegularizationJob.java
new file mode 100644
index 0000000..efe575d
--- /dev/null
+++ b/src/weaver/interfaces/zhewen/cronjob/EmployeeRegularizationJob.java
@@ -0,0 +1,44 @@
+package weaver.interfaces.zhewen.cronjob;
+
+import org.apache.commons.collections.CollectionUtils;
+import weaver.common.DateUtil;
+import weaver.conn.RecordSet;
+import weaver.interfaces.schedule.BaseCronJob;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @author:dxfeng
+ * @createTime: 2025/03/04
+ * @version: 1.0
+ */
+public class EmployeeRegularizationJob extends BaseCronJob {
+    @Override
+    public void execute() {
+        RecordSet rs = new RecordSet();
+        try {
+            rs.writeLog("EmployeeRegularizationJob---start");
+            String currentDate = DateUtil.getCurrentDate();
+            List<String> userList = new ArrayList<>();
+            rs.executeQuery("select xm from uf_ygzzxx where zzrq = ? ", currentDate);
+            while (rs.next()) {
+                userList.add(rs.getString("xm"));
+            }
+
+            if (CollectionUtils.isNotEmpty(userList)) {
+                for (String user : userList) {
+                    rs.writeLog(user + "==已转正");
+                    rs.executeUpdate("update hrmresource set status = 1 where id = ? ", user);
+                }
+            } else {
+                rs.writeLog(currentDate + "---未查询到数据");
+            }
+
+
+            rs.writeLog("EmployeeRegularizationJob---finish");
+        } catch (Exception e) {
+            rs.writeLog("EmployeeRegularizationJob", e);
+        }
+    }
+}