bug2

huimv-env-admin/src/main/java/com/huimv/env/admin/timer/DeviceTimer.java

@@ -6,10 +6,12 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.huimv.env.admin.entity.BasePigpen;
 import com.huimv.env.admin.entity.Gateway;
 import com.huimv.env.admin.entity.Terminal;
+import com.huimv.env.admin.entity.TerminalPort;
 import com.huimv.env.admin.entity.dto.HeartDto;
 import com.huimv.env.admin.mapper.GatewayMapper;
 import com.huimv.env.admin.mapper.HeartInfoMapper;
 import com.huimv.env.admin.mapper.TerminalMapper;
+import com.huimv.env.admin.mapper.TerminalPortMapper;
 import org.checkerframework.checker.units.qual.A;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Configuration;
@@ -31,6 +33,8 @@ public class DeviceTimer {
     private TerminalMapper terminalMapper;
     @Autowired
     private GatewayMapper gatewayMapper;
+    @Autowired
+    private TerminalPortMapper portMapper;
 
     @Scheduled(cron = "0 0 0/1 * * ? ")
     private void action() {
@@ -46,6 +50,13 @@ public class DeviceTimer {
                 if (ObjectUtil.isNotEmpty(terminal)) {
                     terminal.setStatus(1);
                     terminalMapper.updateById(terminal);
+                    QueryWrapper<TerminalPort> queryWrapper1 = new QueryWrapper<>();
+                    queryWrapper1.eq("terminal_id", terminal.getId());
+                    List<TerminalPort> terminalPorts = portMapper.selectList(queryWrapper1);
+                    for (TerminalPort terminalPort : terminalPorts) {
+                        terminalPort.setStatus(1);
+                        portMapper.updateById(terminalPort);
+                    }
                 }
             } else {
                 QueryWrapper<Terminal> queryWrapper = new QueryWrapper<>();
@@ -54,6 +65,13 @@ public class DeviceTimer {
                 if (ObjectUtil.isNotEmpty(terminal)) {
                     terminal.setStatus(0);
                     terminalMapper.updateById(terminal);
+                    QueryWrapper<TerminalPort> queryWrapper1 = new QueryWrapper<>();
+                    queryWrapper1.eq("terminal_id", terminal.getId());
+                    List<TerminalPort> terminalPorts = portMapper.selectList(queryWrapper1);
+                    for (TerminalPort terminalPort : terminalPorts) {
+                        terminalPort.setStatus(0);
+                        portMapper.updateById(terminalPort);
+                    }
                 }
             }
         }