Kaynağa Gözat

调用 MachineInfoRepository#updateMachineStat 的方法需要添加 @Transactional 注解

reghao 5 ay önce
ebeveyn
işleme
7d0ba6452f

+ 3 - 0
mgr/src/main/java/cn/reghao/devops/mgr/machine/service/impl/MachineServiceImpl.java

@@ -68,6 +68,7 @@ public class MachineServiceImpl implements MachineService {
         machineHostRepository.save(machineHost);
     }
 
+    @Transactional(rollbackFor = Exception.class)
     @Override
     public void setMachineDeprecate(String machineId) {
         List<MachineInfo> list = machineQuery.getMachineInfos(List.of(machineId));
@@ -76,11 +77,13 @@ public class MachineServiceImpl implements MachineService {
         }
     }
 
+    @Transactional(rollbackFor = Exception.class)
     @Override
     public void setAgentStatus(String machineId, NodeStatus nodeStatus) {
         machineInfoRepository.updateMachineStat(machineId, nodeStatus.getCode());
     }
 
+    @Transactional(rollbackFor = Exception.class)
     @Override
     public void setMachineOffline() {
         List<MachineInfo> list = machineInfoRepository.findByStat(NodeStatus.Online.getCode()).stream()