TaskService.java 1.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243
  1. package com.fdkankan.manage_jp.task;
  2. import com.fdkankan.manage_jp.entity.Project;
  3. import com.fdkankan.manage_jp.entity.ProjectSceneGps;
  4. import com.fdkankan.manage_jp.entity.ScenePlus;
  5. import com.fdkankan.manage_jp.service.IProjectSceneGpsService;
  6. import com.fdkankan.manage_jp.vo.response.SceneGpsDb;
  7. import lombok.extern.slf4j.Slf4j;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.scheduling.annotation.Scheduled;
  10. import org.springframework.stereotype.Service;
  11. import java.util.ArrayList;
  12. import java.util.Date;
  13. import java.util.List;
  14. @Service
  15. @Slf4j
  16. public class TaskService {
  17. @Autowired
  18. IProjectSceneGpsService projectSceneGpsService;
  19. @Scheduled(initialDelay = 2000, fixedDelay = 1000 * 60 )
  20. public void run() {
  21. List<SceneGpsDb> numList = projectSceneGpsService.getNotGpsScene();
  22. if(numList.isEmpty()){
  23. log.info("没有需要更新GPS数据的场景");
  24. }
  25. List<ProjectSceneGps> list = new ArrayList<>();
  26. for (SceneGpsDb sceneGpsDb : numList) {
  27. ProjectSceneGps sceneGps = projectSceneGpsService.addGps(sceneGpsDb);
  28. if(sceneGps != null){
  29. log.info("num:{}gps:{}",sceneGpsDb.getNum(),sceneGps);
  30. list.add(sceneGps);
  31. }
  32. }
  33. projectSceneGpsService.saveBatch(list);
  34. }
  35. }