每天同步科远库中的定位卡deviceNo至三个hr库

src/main/java/com/hxjt/dataupload/jobhandler/devicenohandle/DeviceNoSynchronizationJobHandler.java

@@ -2,6 +2,7 @@ package com.hxjt.dataupload.jobhandler.devicenohandle;
 
 import com.google.common.collect.BoundType;
 import com.hxjt.dataupload.model.entity.devicenohandle.IsmTag;
+import com.hxjt.dataupload.model.entity.devicenohandle.PersonArchives;
 import com.hxjt.dataupload.service.IsmTagService;
 import com.xxl.job.core.handler.annotation.XxlJob;
 import org.slf4j.Logger;
@@ -24,10 +25,39 @@ public class DeviceNoSynchronizationJobHandler {
     public void execute(String param) {
         //查出科远
         ArrayList<IsmTag> ismTagList= ismTagService.getIsmTagList();
+        int count = 0;
         for (IsmTag ismTag:ismTagList) {
             //System.out.println(ismTag);
+            //根据workNumber查询hr_new.person_archives表
+            PersonArchives pa = ismTagService.getPersonArchivesByNumber(ismTag.getWorkNumber());
+            //System.out.println(pa);
 
+            if(null!=pa){
+                //System.out.println(pa);
+                //if(pa.getDeviceNo().equals(ismTag.getDeviceNo())){
+                if(2==1){
+                    //System.out.println(pa);
+                    //System.out.println("数据一致无需同步");
+                }else{
+                    pa.setDeviceNo(ismTag.getDeviceNo());
+                    try{
+
+                        ismTagService.update2point87(pa);
+                        ismTagService.update5point33(pa);
+                        ismTagService.updateLowcodeOnline(pa);
+                        //System.out.println(pa);
+                        count++;
+
+                    }catch(Exception e){
+                        System.out.println(pa);
+                        System.out.println("更新失败");
+                        e.printStackTrace();
+                    }
+
+                }
+            }
         }
+        System.out.println("更新"+count+"个");
 
     }
 

src/main/java/com/hxjt/dataupload/mapper/PersonArchivesMapper.java

@@ -0,0 +1,11 @@
+package com.hxjt.dataupload.mapper;
+
+import com.hxjt.dataupload.model.entity.devicenohandle.PersonArchives;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface PersonArchivesMapper {
+    PersonArchives getPersonArchivesByNumber(String number);
+
+    void updateDeviceNoForPersonArchives(PersonArchives personArchives);
+}

src/main/java/com/hxjt/dataupload/model/entity/devicenohandle/PersonArchives.java

@@ -0,0 +1,41 @@
+package com.hxjt.dataupload.model.entity.devicenohandle;
+
+public class PersonArchives {
+
+    private String id;
+    private String number;
+    private String deviceNo;
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public String getNumber() {
+        return number;
+    }
+
+    public void setNumber(String number) {
+        this.number = number;
+    }
+
+    public String getDeviceNo() {
+        return deviceNo;
+    }
+
+    public void setDeviceNo(String deviceNo) {
+        this.deviceNo = deviceNo;
+    }
+
+    @Override
+    public String toString() {
+        return "PersonArchives{" +
+                "id='" + id + '\'' +
+                ", number='" + number + '\'' +
+                ", deviceNo='" + deviceNo + '\'' +
+                '}';
+    }
+}

src/main/java/com/hxjt/dataupload/service/IsmTagService.java

@@ -1,9 +1,18 @@
 package com.hxjt.dataupload.service;
 
 import com.hxjt.dataupload.model.entity.devicenohandle.IsmTag;
+import com.hxjt.dataupload.model.entity.devicenohandle.PersonArchives;
 
 import java.util.ArrayList;
 
 public interface IsmTagService {
     ArrayList<IsmTag> getIsmTagList();
+
+    PersonArchives getPersonArchivesByNumber(String number);
+
+    void update2point87(PersonArchives personArchives);
+
+    void update5point33(PersonArchives pa);
+
+    void updateLowcodeOnline(PersonArchives pa);
 }

src/main/java/com/hxjt/dataupload/service/impl/IsmTagServiceImpl.java

@@ -2,19 +2,46 @@ package com.hxjt.dataupload.service.impl;
 
 import com.baomidou.dynamic.datasource.annotation.DS;
 import com.hxjt.dataupload.mapper.IsmTagMapper;
+import com.hxjt.dataupload.mapper.PersonArchivesMapper;
 import com.hxjt.dataupload.model.entity.devicenohandle.IsmTag;
+import com.hxjt.dataupload.model.entity.devicenohandle.PersonArchives;
 import com.hxjt.dataupload.service.IsmTagService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.util.ArrayList;
 @Service
-@DS("syncplant")
+
 public class IsmTagServiceImpl implements IsmTagService {
     @Autowired
     IsmTagMapper ismTagMapper;
+    @Autowired
+    PersonArchivesMapper personArchivesMapper;
+    @DS("syncplant")
     @Override
     public ArrayList<IsmTag> getIsmTagList() {
         return ismTagMapper.getIsmTagList();
     }
+    @DS("hrnew87")
+    @Override
+    public PersonArchives getPersonArchivesByNumber(String number) {
+        return personArchivesMapper.getPersonArchivesByNumber(number);
+    }
+
+    @DS("hrnew87")
+    @Override
+    public void update2point87(PersonArchives personArchives) {
+        personArchivesMapper.updateDeviceNoForPersonArchives(personArchives);
+    }
+    @DS("hrnewlowcodetest")
+    @Override
+    public void update5point33(PersonArchives pa) {
+        personArchivesMapper.updateDeviceNoForPersonArchives(pa);
+    }
+    @DS("hrnewlowcodeprod")
+    @Override
+    public void updateLowcodeOnline(PersonArchives pa) {
+        personArchivesMapper.updateDeviceNoForPersonArchives(pa);
+    }
+
 }

src/main/resources/application-dev.yml

@@ -85,8 +85,9 @@ xxl:
   job:
     admin:
       #调度中心部署地址,多个配置逗号分隔 "http://address01,http://address02"
-      addresses: http://172.20.2.57:8080/xxl-job-admin
-      #addresses: http://127.0.0.1:8080/xxl-job-admin
+      #上线
+      #addresses: http://172.20.2.57:8080/xxl-job-admin
+      addresses: http://127.0.0.1:8080/xxl-job-admin
     #执行器token，非空时启用 xxl-job, access token
     accessToken: data_upload
     executor:
@@ -106,8 +107,9 @@ xxl:
   mqtt:
     username: 10@ningyanghuagongchany20250508114250
     password: ce07f3c284084b42b674017b72fe73f2
-    #hostUrl: tcp://112.245.55.112:18183
-    hostUrl: tcp://172.20.2.57:1883
+    #上线
+    hostUrl: tcp://112.245.55.112:18183
+    #hostUrl: tcp://172.20.2.57:1883
     clientId: 10@ningyanghuagongchany20250508114250
     sensorDataTopic: /iot/10@ningyanghuagongchany20250422172632/thirdParty/sensorData
     timeout: 100

src/main/resources/mapper/PersonArchivesMapper.xml

@@ -0,0 +1,18 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
+<mapper namespace="com.hxjt.dataupload.mapper.PersonArchivesMapper">
+
+
+    <select id="getPersonArchivesByNumber" resultType="com.hxjt.dataupload.model.entity.devicenohandle.PersonArchives">
+		select id,number,deviceNo from person_archives where `number` = #{number}
+	</select>
+
+	<update id="updateDeviceNoForPersonArchives">
+		UPDATE person_archives
+		SET deviceNo = #{deviceNo}
+		WHERE number = #{number}
+
+	</update>
+
+
+</mapper>