[核查模块] d增加缓存注解

dev-library/src/main/java/com/tykj/dev/device/library/service/impl/CacheLibraryServiceImpl.java

@@ -42,6 +42,7 @@ public class CacheLibraryServiceImpl implements DeviceLibraryCacheService {
      * @return key = 装备主键id , Value = {@link DeviceLibrary}
      */
     @Override
+    @Cacheable(key = "'device'")
     public Map<Integer, DeviceLibrary> getDevicesMap() {
         return deviceLibraryDao.findAll().stream()
                 .collect(Collectors.toMap(DeviceLibrary::getId, Function.identity()));

dev-task/src/main/java/com/tykj/dev/device/task/service/impl/TaskServiceImpl.java

@@ -317,15 +317,15 @@ public class TaskServiceImpl implements TaskService {
     @ExceptionHandler(Exception.class)
     @Log
     public TaskBto start(TaskBto taskBto) {
-        Task task = taskDao.save(taskBto.toDo());
+        Task task = taskDao.saveAndFlush(taskBto.toDo());
         myWebSocket.sendMessage1();
+        Task task1 = taskDao.findById(task.getId()).get();
         CompletableFuture.runAsync(() -> {
             try {
                 Thread.sleep(2000);
             } catch (InterruptedException e) {
                 e.printStackTrace();
             }
-            Task task1 = taskDao.findById(task.getId()).get();
             BcHash bcText = blockChainUtil.sendHash(1000, JacksonUtil.toJSon(task1));
             String recordId = bcText.getData().getRecordID();
             task1.setRecordId(recordId);