盛世科技插入需求 刷新人员安全级别

src/weaver/interfaces/sskj/crob/RefreshHrmSecLevelCrob.java

@@ -0,0 +1,54 @@
+package weaver.interfaces.sskj.crob;
+
+import com.engine.integration.util.StringUtils;
+import org.apache.commons.collections.CollectionUtils;
+import weaver.conn.RecordSet;
+import weaver.general.Util;
+import weaver.interfaces.schedule.BaseCronJob;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @Author liang.cheng
+ * @Date 2023/11/28 3:53 PM
+ * @Description: 刷新人员安全级别
+ * @Version 1.0
+ */
+public class RefreshHrmSecLevelCrob extends BaseCronJob {
+    @Override
+    public void execute() {
+
+        List<ReleationPO> releationList = new ArrayList<>();
+        RecordSet rs = new RecordSet();
+        rs.executeQuery("select zwlb,aqjb from uf_aqjbdygxb");
+        while (rs.next()) {
+            releationList.add(ReleationPO.builder()
+                    .jobGroups(Util.getIntValue(rs.getString("zwlb")))
+                    .secLevel(Util.getIntValue(rs.getString("aqjb")))
+                    .build());
+        }
+
+
+        releationList.forEach(releationPo -> {
+            List<Integer> jobTitles = new ArrayList<>();
+            selectJobTitlesByJobGroup(jobTitles,releationPo.getJobGroups());
+            if (CollectionUtils.isNotEmpty(jobTitles)) {
+                rs.executeUpdate("update hrmresource a set a.seclevel = ? where " +
+                        " a.jobtitle in ("+StringUtils.join(jobTitles, ",")+")",releationPo.getSecLevel());
+            }
+        });
+    }
+
+    private List<Integer> selectJobTitlesByJobGroup(List<Integer> jobTitles,Integer jobGroup){
+        RecordSet rs = new RecordSet();
+        rs.executeQuery("select a.id from hrmjobtitles a join hrmjobactivities b on a.jobactivityid = b.id\n" +
+                " join hrmjobgroups c on b.jobgroupid = c.id where c.id = ?",jobGroup);
+        while (rs.next()) {
+            jobTitles.add(Util.getIntValue(rs.getString("id")));
+        }
+
+        return jobTitles;
+
+    }
+}

src/weaver/interfaces/sskj/crob/ReleationPO.java

@@ -0,0 +1,23 @@
+package weaver.interfaces.sskj.crob;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * @Author liang.cheng
+ * @Date 2023/11/28 4:24 PM
+ * @Description: 安全级别关系对照表
+ * @Version 1.0
+ */
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class ReleationPO {
+
+    private Integer jobGroups;
+
+    private Integer secLevel;
+}