feat: enhance Modbus point view with tooltip and format inference

- Updated ModbusSlavePointView.vue to include a tooltip for point types, displaying device protocol and storage type.
- Added logic to infer format from point data, ensuring consistent display in the UI.
- Adjusted column definitions in the table to accommodate new tooltip functionality.

style: improve form controls and help drawer styles

- Introduced new styles for field hints and warnings in form-controls.css to enhance user experience.
- Modified help-drawer.css for better layout and readability, including adjustments to spacing and element sizes.

fix: ensure safe ID handling in device routes

- Added isPathSafeId utility function to check for safe ID usage in URL paths, preventing routing issues.
- Updated DeviceList.vue to utilize this function when deleting devices, ensuring proper handling of IDs with unsafe characters.

refactor: enhance point list with additional hints and warnings

- Updated PointList.vue to provide clearer labels and hints for data format and parsing type selections.
- Implemented warnings for mismatched parsing types and data types to guide user configuration.

test: add unit tests for ID sanitization and ensure device ID functionality

- Created tests for EnsureDeviceID, EnsurePointID, and EnsureChannelID to validate ID sanitization logic.
- Added comprehensive tests for sanitizeID function to ensure correct behavior across various input cases.

Author: Thouen

cmd/main.go

@@ -358,6 +358,11 @@ func main() {
 
 	zap.L().Info("Shutting down...")
 
+	// 有序关闭：HTTP → EdgeCompute → Channels → Pipeline，
+	// 之后再由 defer 依次关闭 Northbound、Shadow、Store。
 	srv.StopBackgroundTasks()
+	srv.Shutdown()
+	ecm.Stop()
 	cm.Shutdown()
+	pipeline.Stop()
 }

internal/ai_agent/manager.go

@@ -1,6 +1,7 @@
 package ai_agent
 
 import (
+	"encoding/json"
 	"fmt"
 	"sync"
 	"time"
@@ -113,10 +114,11 @@ func (a *Agent) Create(req aitypes.CreateRequest) (*aitypes.TaskRecord, error) {
 
 	a.mu.Lock()
 	a.tasks[id] = rec
+	result := cloneTask(rec)
 	a.mu.Unlock()
 
 	go a.runPipeline(id, req, estTokens)
-	return cloneTask(rec), nil
+	return result, nil
 }
 
 func (a *Agent) AttachFile(taskID, filename string) error {
@@ -222,6 +224,17 @@ func (a *Agent) runPipeline(id string, req aitypes.CreateRequest, tokens int) {
 }
 
 func cloneTask(t *aitypes.TaskRecord) *aitypes.TaskRecord {
+	if t == nil {
+		return nil
+	}
+	data, err := json.Marshal(t)
+	if err == nil {
+		var cp aitypes.TaskRecord
+		if json.Unmarshal(data, &cp) == nil {
+			return &cp
+		}
+	}
+
 	cp := *t
 	if t.Stages != nil {
 		cp.Stages = append([]aitypes.StageProgress(nil), t.Stages...)

internal/core/channel_manager.go

@@ -650,8 +650,12 @@ func (cm *ChannelManager) tryConnectChannel(channelID string) {
 // StartChannel 启动一个采集通道
 func (cm *ChannelManager) StartChannel(channelID string) error {
 	cm.mu.RLock()
-	ch, ok := cm.channels[channelID]
+	chPtr, ok := cm.channels[channelID]
 	d, okDrv := cm.drivers[channelID]
+	var ch model.Channel
+	if ok && chPtr != nil {
+		ch = chPtr.DeepCopy()
+	}
 	cm.mu.RUnlock()
 
 	if !ok || !okDrv {
@@ -688,7 +692,7 @@ func (cm *ChannelManager) StartChannel(channelID string) error {
 			continue
 		}
 
-		if err := cm.registerDeviceToScanEngine(ch, dev); err != nil {
+		if err := cm.registerDeviceToScanEngine(&ch, dev); err != nil {
 			zap.L().Error("Failed to register device to ScanEngine", zap.String("device", dev.Name), zap.Error(err))
 		}
 	}
@@ -702,8 +706,12 @@ func (cm *ChannelManager) StartChannel(channelID string) error {
 // StopChannel 停止一个采集通道
 func (cm *ChannelManager) StopChannel(channelID string) error {
 	cm.mu.RLock()
-	ch, ok := cm.channels[channelID]
+	chPtr, ok := cm.channels[channelID]
 	d, okDrv := cm.drivers[channelID]
+	var ch model.Channel
+	if ok && chPtr != nil {
+		ch = chPtr.DeepCopy()
+	}
 	cm.mu.RUnlock()
 
 	if !ok || !okDrv {
@@ -727,7 +735,7 @@ func (cm *ChannelManager) GetChannels() []model.Channel {
 	defer cm.mu.RUnlock()
 	channels := make([]model.Channel, 0, len(cm.channels))
 	for _, ch := range cm.channels {
-		c := *ch
+		c := ch.DeepCopy()
 		if node := cm.stateManager.GetNode(c.ID); node != nil {
 			c.NodeRuntime = &model.NodeRuntime{
 				FailCount:     node.Runtime.FailCount,
@@ -938,6 +946,15 @@ func (cm *ChannelManager) GetDevicePoints(channelID, deviceID string) ([]model.P
 			Quality:      "Uncertain",
 			Value:        nil,
 			ReadWrite:    point.ReadWrite,
+			Format:       point.Format,
+			WordOrder:    point.WordOrder,
+			Scale:        point.Scale,
+			Offset:       point.Offset,
+			ReadFormula:  point.ReadFormula,
+			WriteFormula: point.WriteFormula,
+			Group:        point.Group,
+			ScanClass:    point.ScanClass,
+			ReportMode:   point.ReportMode,
 		})
 	}
 	return points, nil
@@ -982,6 +999,15 @@ func (cm *ChannelManager) getDevicePointsFromShadow(dev *model.Device, slaveID u
 			Quality:      "Bad",
 			Value:        nil,
 			ReadWrite:    point.ReadWrite,
+			Format:       point.Format,
+			WordOrder:    point.WordOrder,
+			Scale:        point.Scale,
+			Offset:       point.Offset,
+			ReadFormula:  point.ReadFormula,
+			WriteFormula: point.WriteFormula,
+			Group:        point.Group,
+			ScanClass:    point.ScanClass,
+			ReportMode:   point.ReportMode,
 		}
 		if sp, exists := shadow.Points[point.ID]; exists {
 			pd.Value = sp.Value
@@ -1507,7 +1533,11 @@ func (cm *ChannelManager) ScanChannel(ctx context.Context, channelID string, par
 	}
 	cm.mu.RLock()
 	d, okDrv := cm.drivers[channelID]
-	ch, okCh := cm.channels[channelID]
+	chPtr, okCh := cm.channels[channelID]
+	var ch model.Channel
+	if okCh && chPtr != nil {
+		ch = chPtr.DeepCopy()
+	}
 	cm.mu.RUnlock()
 
 	if !okDrv {
@@ -1591,7 +1621,7 @@ func (cm *ChannelManager) ScanChannel(ctx context.Context, channelID string, par
 						zap.Stack("stack"))
 				}
 			}()
-			cm.autoUpdateBACnetAddresses(ch, result)
+			cm.autoUpdateBACnetAddresses(&ch, result)
 		}()
 	}
 
@@ -1755,7 +1785,11 @@ func (cm *ChannelManager) ScanDevice(ctx context.Context, channelID, deviceID st
 	}
 	cm.mu.RLock()
 	d, okDrv := cm.drivers[channelID]
-	ch, okCh := cm.channels[channelID]
+	chPtr, okCh := cm.channels[channelID]
+	var ch model.Channel
+	if okCh && chPtr != nil {
+		ch = chPtr.DeepCopy()
+	}
 	cm.mu.RUnlock()
 
 	if !okDrv || !okCh {
@@ -2543,7 +2577,7 @@ func (cm *ChannelManager) saveChannels() error {
 	// Copy channel data under caller's lock
 	channels := make([]model.Channel, 0, len(cm.channels))
 	for _, c := range cm.channels {
-		channels = append(channels, *c)
+		channels = append(channels, c.DeepCopy())
 	}
 
 	// Save asynchronously to avoid holding cm.mu during disk I/O.