同步现场代码

src/main/java/com/iflytop/gd/app/model/vo/HeatCountdownVO.java

@@ -0,0 +1,32 @@
+package com.iflytop.gd.app.model.vo;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.iflytop.gd.app.model.entity.Solutions;
+import com.iflytop.gd.common.enums.HeatModuleCode;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import java.time.LocalDateTime;
+
+@Schema(description = "加热倒计时")
+@Data
+public class HeatCountdownVO {
+    @Schema(description = "加热模块code")
+    private HeatModuleCode heatModuleCode;
+
+    @Schema(description = "加热剩余秒数格式化显示")
+    private String countdownStr;
+
+    @Schema(description = "加热剩余秒数")
+    private Integer countdown;
+
+    @Schema(description = "开始加热时间")
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private LocalDateTime startTime;
+
+    @Schema(description = "结束加热时间")
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private LocalDateTime endTime;
+
+
+}

src/main/java/com/iflytop/gd/app/service/device/module/OtherModuleService.java

@@ -0,0 +1,34 @@
+package com.iflytop.gd.app.service.device.module;
+
+import com.iflytop.gd.hardware.drivers.DODriver.OutputIOCtrlDriver;
+import com.iflytop.gd.hardware.type.IO.OutputIOMId;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import java.util.concurrent.CompletableFuture;
+
+/**
+ * 其他模块
+ */
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class OtherModuleService {
+    private final OutputIOCtrlDriver outputIOCtrlDriver;
+
+    /**
+     * 工艺执行完毕蜂鸣器提醒
+     */
+    public void craftsFinishBeepRemind(){
+        CompletableFuture.runAsync(() -> {
+            try {
+                outputIOCtrlDriver.open(OutputIOMId.DO_BEEP);
+                Thread.sleep(2000);
+                outputIOCtrlDriver.close(OutputIOMId.DO_BEEP);
+            } catch (Exception e) {
+                log.error("工艺执行完毕蜂鸣器调用失败", e);
+            }
+        });
+    }
+}

src/main/java/com/iflytop/gd/app/service/scheduled/HeatCountdownScheduledTask.java

@@ -0,0 +1,86 @@
+package com.iflytop.gd.app.service.scheduled;
+
+import com.iflytop.gd.app.model.bo.status.device.HeatModuleState;
+import com.iflytop.gd.app.model.vo.HeatCountdownVO;
+import com.iflytop.gd.app.service.api.DevicePositionService;
+import com.iflytop.gd.app.service.device.DeviceStateService;
+import com.iflytop.gd.app.service.device.module.HeatModuleService;
+import com.iflytop.gd.app.ws.server.WebSocketSender;
+import com.iflytop.gd.common.enums.HeatingType;
+import com.iflytop.gd.common.enums.data.DevicePositionCode;
+import com.iflytop.gd.common.utils.LocalDateTimeUtil;
+import jakarta.annotation.PostConstruct;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Service;
+
+import java.time.Duration;
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * 加热倒计时
+ */
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class HeatCountdownScheduledTask {
+    private final DeviceStateService deviceStateService;
+    private final DevicePositionService devicePositionService;
+    private final HeatModuleService heatModuleService;
+    private final WebSocketSender webSocketSender;
+
+    @Scheduled(fixedRate = 1000)
+    public void fetchTemperature() {
+        try {
+            LocalDateTime now = LocalDateTime.now();
+            List<HeatCountdownVO> heatCountdownVOList = new ArrayList<>();
+            for (HeatModuleState heatModuleState : deviceStateService.getDeviceState().getHeatModule()) {
+                if (heatModuleState.getHeatingType() == HeatingType.thermostatic) {//如果这个加热模块在加热中
+                    if (heatModuleState.getTemperature() + 1 > heatModuleState.getHeatTemperature()) {//当前温度达到目标温度，允许有1度以内的误差
+                        heatModuleState.setHeatingType(HeatingType.constant);//修改状态为恒温中
+                        if (heatModuleState.getStartHeatTime() == null) {
+                            //设定开始加热时间
+                            heatModuleState.setStartHeatTime(now);
+                        } else {
+                            LocalDateTime endTime = heatModuleState.getStartHeatTime().minusSeconds(heatModuleState.getTargetTime());
+                            //判断是否达到目标加热时间
+                            if (endTime.isBefore(now)) {//加热完毕
+                                double trayLift = devicePositionService.getPosition(DevicePositionCode.trayLift).getDistance();
+                                //抬起托盘
+                                heatModuleService.heaterMotorMove(heatModuleState.getModuleCode(), trayLift);
+                                heatModuleState.setTrayUp(1);
+                                //关闭加棒
+                                heatModuleService.heatRodClose(heatModuleState.getModuleCode());
+                                heatModuleState.setHeatingType(HeatingType.stop);
+                                //还原状态
+                                heatModuleState.setStartHeatTime(null);
+                                heatModuleState.setTargetTime(null);
+                                heatModuleState.setWarmUpTemperature(null);
+                                heatModuleState.setHeatTemperature(null);
+                                heatModuleState.setTargetTemperature(null);
+                                heatModuleState.setHeatingType(HeatingType.stop);
+                            } else {//加热中
+                                long diffSeconds = Duration.between(now, endTime).getSeconds();//计算剩余时间
+                                HeatCountdownVO heatCountdownVO = new HeatCountdownVO();
+                                heatCountdownVO.setHeatModuleCode(heatModuleState.getModuleCode());
+                                heatCountdownVO.setCountdown((int) diffSeconds);
+                                heatCountdownVO.setCountdownStr(LocalDateTimeUtil.formatSecondsToHMS(diffSeconds));
+                                heatCountdownVO.setStartTime(heatModuleState.getStartHeatTime());
+                                heatCountdownVO.setEndTime(endTime);
+                                heatCountdownVOList.add(heatCountdownVO);
+                            }
+                        }
+                    }
+                }
+            }
+            if (!heatCountdownVOList.isEmpty()) {
+                webSocketSender.pushHeatCountdown(heatCountdownVOList);
+            }
+        } catch (Exception e) {
+            log.error("加热倒计时错误", e);
+        }
+    }
+}

src/main/java/com/iflytop/gd/common/utils/LocalDateTimeUtil.java

@@ -0,0 +1,18 @@
+package com.iflytop.gd.common.utils;
+
+public class LocalDateTimeUtil {
+
+    /**
+     * 秒数格式化为 “HH:mm:ss” 格式。
+     * @param diffSeconds 两个时间点相差的秒数（可以为正或负）
+     * @return 格式化后的 “HH:mm:ss” 字符串
+     */
+    public static String formatSecondsToHMS(long diffSeconds) {
+        long absSeconds = Math.abs(diffSeconds);
+        long hours = absSeconds / 3600;
+        long minutes = (absSeconds % 3600) / 60;
+        long seconds = absSeconds % 60;
+        return String.format("%02d:%02d:%02d", hours, minutes, seconds);
+    }
+
+}