liwenxuan 6 months ago
parent
commit
a95be0d70d
  1. 8
      src/main/java/com/hxjt/dataupload/jobhandler/devicenohandle/DeviceNoSynchronizationJobHandler.java

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

@ -4,6 +4,7 @@ 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.context.XxlJobHelper;
import com.xxl.job.core.handler.annotation.XxlJob;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@ -39,6 +40,7 @@ public class DeviceNoSynchronizationJobHandler {
//System.out.println(pa);
//System.out.println("数据一致无需同步");
}else{
XxlJobHelper.log("需更新:" + pa+"-----"+ismTag);
pa.setDeviceNo(ismTag.getDeviceNo());
try{
@ -46,18 +48,22 @@ public class DeviceNoSynchronizationJobHandler {
ismTagService.update5point33(pa);
ismTagService.updateLowcodeOnline(pa);
//System.out.println(pa);
XxlJobHelper.log("成功更新:" + pa);
count++;
}catch(Exception e){
System.out.println(pa);
System.out.println("更新失败");
XxlJobHelper.log("更新失败"+pa);
XxlJobHelper.log(e.getMessage());
e.printStackTrace();
}
}
}
}
System.out.println("更新"+count+"个");
System.out.println("更新了"+count+"个");
XxlJobHelper.log("更新了"+count+"个");
}

Loading…
Cancel
Save