feature: 数据同步

1.kafka同步增加了默认操作人

ruoyi-server/ruoyi-server-common/src/main/java/org/dromara/server/common/constant/DefaultConstants.java

@@ -102,4 +102,8 @@ public interface DefaultConstants {
      * 全量同步管理员
      */
     Long FULL_SYNC_ADMIN = 11L;
+    /**
+     * kafka同步管理员
+     */
+    Long KAFKA_SYNC_ADMIN = 12L;
 }

ruoyi-server/ruoyi-server-mqdata/src/main/java/org/dromara/server/mq/event/kafka/impl/teacher/TeacherUtils.java

@@ -22,10 +22,11 @@ public class TeacherUtils {
 
     /**
      * 处理教职工信息
+     *
      * @param data 教职工
      * @return 结果
      */
-    public static List<ResourcePerson> getSyncTeacher(JSONObject data){
+    public static List<ResourcePerson> getSyncTeacher(JSONObject data) {
         List<ResourcePerson> resourcePersonList = new ArrayList<>();
         ResourcePerson person = new ResourcePerson();
         person.setUserId(data.get("employee_id").toString());
@@ -36,7 +37,8 @@ public class TeacherUtils {
         person.setPhone(data.get("mobile_phone").toString());
         person.setCategory("1");
         person.setUserState(data.get("status").toString());
-
+        person.setTenantId(DefaultConstants.TENANT_ID);
+        person.setOperatorId(DefaultConstants.KAFKA_SYNC_ADMIN);
         resourcePersonList.add(person);
 
         return resourcePersonList;
@@ -44,17 +46,19 @@ public class TeacherUtils {
 
     /**
      * 处理部门数据
+     *
      * @param data 部门
      * @return 处理结果
      */
-    public static List<ResourceDept> getSyncDept(JSONObject data){
+    public static List<ResourceDept> getSyncDept(JSONObject data) {
         List<ResourceDept> resourceDeptlist = new ArrayList<>();
         ResourceDept dept = new ResourceDept();
         dept.setParent_id(data.get("parent_id").toString());
         dept.setDept_id(data.get("dept_id").toString());
         dept.setDept_name(data.get("dept_name").toString());
         dept.setDept_num(data.get("dept_num").toString());
-
+        dept.setTenantId(DefaultConstants.TENANT_ID);
+        dept.setOperatorId(DefaultConstants.KAFKA_SYNC_ADMIN);
         resourceDeptlist.add(dept);
 
         return resourceDeptlist;

ruoyi-server/ruoyi-server-mqdata/src/main/java/org/dromara/server/mq/event/kafka/impl/train/TrainUtils.java

@@ -41,7 +41,8 @@ public class TrainUtils {
         dept.setCanEat("1");
         dept.setPayCheck(data.get("noPayAllow").toString());
         dept.setDept_num(data.get("sortNum").toString());
-
+        dept.setOperatorId(DefaultConstants.KAFKA_SYNC_ADMIN);
+        dept.setTenantId(DefaultConstants.TENANT_ID);
         resourceDeptlist.add(dept);
 
         return resourceDeptlist;