fix:fwh_faultRecord.go增加错误打印信息，便于调试

service/repositories/api/fwh_pro/fwh_faultRecord.go

@@ -22,7 +22,7 @@ func queryFaultRecordList(sn string, startTime string, endTime string) (*domain.
 	params.Add("lang", "ZH_CN")
 	response, err := FwhHttpGetUnmarshal[[]domain.FaultRecordInfo](getFullEnergyUrl("/hes-gateway/manage/faultRecordingLst"), params)
 	if err != nil {
-		return nil, err
+		return nil, fmt.Errorf("[queryFaultRecordList] 请求失败 sn=%s, startTime=%s, endTime=%s: %w", sn, startTime, endTime, err)
 	}
 	return response, nil
 }
@@ -31,11 +31,11 @@ func queryFaultRecordList(sn string, startTime string, endTime string) (*domain.
 func QueryFaultRecordList(sn string, startTime string, endTime string) ([]domain.FaultRecordInfo, error) {
 	faultRecordResp, err := queryFaultRecordList(sn, startTime, endTime)
 	if err != nil {
-		return nil, fmt.Errorf("[QueryFaultRecordList] %s", err.Error())
+		return nil, fmt.Errorf("[QueryFaultRecordList] %w", err)
 	}
 
 	if faultRecordResp.Code != 200 {
-		return nil, fmt.Errorf("[QueryFaultRecordList] 查询失败 code: %d, message: %s", faultRecordResp.Code, faultRecordResp.Message)
+		return nil, fmt.Errorf("[QueryFaultRecordList] 查询失败 sn=%s, startTime=%s, endTime=%s, code: %d, message: %s", sn, startTime, endTime, faultRecordResp.Code, faultRecordResp.Message)
 	}
 
 	return *faultRecordResp.Result, nil
@@ -52,7 +52,11 @@ func queryFaultRecordCallableList(devType int, sn string) (*domain.FwhResponse[[
 	response, err := FwhHttpGetUnmarshal[[]domain.FaultRecordCallableInfo](getFullEnergyUrl("/hes-gateway/manage/getWaveRecordingCatalog"), params)
 	// 此处无数据也会失败，暂时定义失败为无数据，不报错
 	if err != nil {
-		zap.L().Error("[queryFaultRecordCallableList] Response failed", zap.String("err", err.Error()))
+		zap.L().Error("[queryFaultRecordCallableList] Response failed",
+			zap.Int("devType", devType),
+			zap.String("sn", sn),
+			zap.String("err", err.Error()),
+		)
 		// 创造假的空数据
 		return &domain.FwhResponse[[]domain.FaultRecordCallableInfo]{
 			Code:   200,
@@ -67,7 +71,7 @@ func queryFaultRecordCallableList(devType int, sn string) (*domain.FwhResponse[[
 func QueryFaultRecordCallableList(devType int, sn string) ([]domain.FaultRecordCallableInfo, error) {
 	faultRecordCallableResp, err := queryFaultRecordCallableList(devType, sn)
 	if err != nil {
-		return nil, fmt.Errorf("[QueryFaultRecordCallableList] %s", err.Error())
+		return nil, fmt.Errorf("[QueryFaultRecordCallableList] %w", err)
 	}
 
 	if faultRecordCallableResp.Code != 200 {
@@ -75,7 +79,7 @@ func QueryFaultRecordCallableList(devType int, sn string) ([]domain.FaultRecordC
 		if faultRecordCallableResp.Code == 400 && faultRecordCallableResp.Message == "故障目录为空" {
 			return []domain.FaultRecordCallableInfo{}, nil
 		}
-		return nil, fmt.Errorf("[QueryFaultRecordCallableList] 查询失败 code: %d, message: %s", faultRecordCallableResp.Code, faultRecordCallableResp.Message)
+		return nil, fmt.Errorf("[QueryFaultRecordCallableList] 查询失败 devType=%d, sn=%s, code: %d, message: %s", devType, sn, faultRecordCallableResp.Code, faultRecordCallableResp.Message)
 	}
 
 	return *faultRecordCallableResp.Result, nil
@@ -84,7 +88,7 @@ func QueryFaultRecordCallableList(devType int, sn string) ([]domain.FaultRecordC
 // 召唤故障录波日志
 func queryCellFaultRecord(devType int, sn string, indexList []int) (*domain.FwhResponse[interface{}], error) {
 	if len(indexList) < 1 {
-		return nil, fmt.Errorf("未选择召唤数据idx")
+		return nil, fmt.Errorf("未选择召唤数据idx devType=%d, sn=%s", devType, sn)
 	}
 
 	// 将 []int 转为 []string
@@ -104,7 +108,7 @@ func queryCellFaultRecord(devType int, sn string, indexList []int) (*domain.FwhR
 
 	response, err := FwhHttpPostUnmarshal[interface{}](getFullEnergyUrl("/hes-gateway/manage/callFaultRecording"), body)
 	if err != nil {
-		return nil, err
+		return nil, fmt.Errorf("[queryCellFaultRecord] 请求失败 devType=%d, sn=%s, index=%s: %w", devType, sn, strings.Join(indexListStr, ","), err)
 	}
 	return response, nil
 }
@@ -113,11 +117,11 @@ func queryCellFaultRecord(devType int, sn string, indexList []int) (*domain.FwhR
 func QueryCellFaultRecord(devType int, sn string, indexList []int) error {
 	cellFaultRecordResp, err := queryCellFaultRecord(devType, sn, indexList)
 	if err != nil {
-		return fmt.Errorf("[QueryCellFaultRecord] %s", err.Error())
+		return fmt.Errorf("[QueryCellFaultRecord] %w", err)
 	}
 
 	if cellFaultRecordResp.Code != 200 {
-		return fmt.Errorf("[QueryCellFaultRecord] 查询失败 code: %d, message: %s", cellFaultRecordResp.Code, cellFaultRecordResp.Message)
+		return fmt.Errorf("[QueryCellFaultRecord] 查询失败 devType=%d, sn=%s, indexList=%v, code: %d, message: %s", devType, sn, indexList, cellFaultRecordResp.Code, cellFaultRecordResp.Message)
 	}
 
 	return nil
@@ -133,7 +137,7 @@ func queryFaultRecordCallRecordList() (*domain.FwhResponse[[]domain.FaultRecordI
 
 	response, err := FwhHttpGetUnmarshal[[]domain.FaultRecordInfo](getFullEnergyUrl("/hes-gateway/manage/lstFaultWaveCall"), params)
 	if err != nil {
-		return nil, err
+		return nil, fmt.Errorf("[queryFaultRecordCallRecordList] 请求失败: %w", err)
 	}
 	return response, nil
 }
@@ -142,7 +146,7 @@ func queryFaultRecordCallRecordList() (*domain.FwhResponse[[]domain.FaultRecordI
 func QueryFaultRecordCallRecordList() ([]domain.FaultRecordInfo, error) {
 	faultRecordCallRecordResp, err := queryFaultRecordCallRecordList()
 	if err != nil {
-		return nil, fmt.Errorf("[QueryFaultRecordCallRecordList] %s", err.Error())
+		return nil, fmt.Errorf("[QueryFaultRecordCallRecordList] %w", err)
 	}
 
 	if faultRecordCallRecordResp.Code != 200 {
@@ -163,7 +167,7 @@ func queryFaultRecordSubList(id int64) (*domain.FwhResponse[[]domain.FaultRecord
 
 	response, err := FwhHttpGetUnmarshal[[]domain.FaultRecordSubInfo](getFullEnergyUrl("/hes-gateway/manage/lstSubFaultWave"), params)
 	if err != nil {
-		return nil, err
+		return nil, fmt.Errorf("[queryFaultRecordSubList] 请求失败 faultId=%d: %w", id, err)
 	}
 	return response, nil
 }
@@ -172,11 +176,11 @@ func queryFaultRecordSubList(id int64) (*domain.FwhResponse[[]domain.FaultRecord
 func QueryFaultRecordSubList(id int64) ([]domain.FaultRecordSubInfo, error) {
 	faultRecordSubResp, err := queryFaultRecordSubList(id)
 	if err != nil {
-		return nil, fmt.Errorf("[QueryFaultRecordSubList] %s", err.Error())
+		return nil, fmt.Errorf("[QueryFaultRecordSubList] %w", err)
 	}
 
 	if faultRecordSubResp.Code != 200 {
-		return nil, fmt.Errorf("[QueryFaultRecordSubList] 查询失败 code: %d, message: %s", faultRecordSubResp.Code, faultRecordSubResp.Message)
+		return nil, fmt.Errorf("[QueryFaultRecordSubList] 查询失败 faultId=%d, code: %d, message: %s", id, faultRecordSubResp.Code, faultRecordSubResp.Message)
 	}
 
 	return *faultRecordSubResp.Result, nil
@@ -193,7 +197,7 @@ func QueryDownloadFaultRecordData(faultId int64, subRecordId int64) (string, []b
 
 	response, err := FwhHttpGet(getFullEnergyUrl("/hes-gateway/manage/exportSubFaultWave"), params)
 	if err != nil {
-		return "", nil, err
+		return "", nil, fmt.Errorf("[QueryDownloadFaultRecordData] 下载失败 faultId=%d, subRecordId=%d: %w", faultId, subRecordId, err)
 	}
 
 	// 从 Content-Disposition 提取真实文件名

service/repositories/api/fwh_test/fwh_faultRecord.go

@@ -22,7 +22,7 @@ func queryFaultRecordList(sn string, startTime string, endTime string) (*domain.
 	params.Add("lang", "ZH_CN")
 	response, err := FwhHttpGetUnmarshal[[]domain.FaultRecordInfo](getFullEnergyUrl("/hes-gateway/manage/faultRecordingLst"), params)
 	if err != nil {
-		return nil, err
+		return nil, fmt.Errorf("[queryFaultRecordList] 请求失败 sn=%s, startTime=%s, endTime=%s: %w", sn, startTime, endTime, err)
 	}
 	return response, nil
 }
@@ -31,11 +31,11 @@ func queryFaultRecordList(sn string, startTime string, endTime string) (*domain.
 func QueryFaultRecordList(sn string, startTime string, endTime string) ([]domain.FaultRecordInfo, error) {
 	faultRecordResp, err := queryFaultRecordList(sn, startTime, endTime)
 	if err != nil {
-		return nil, fmt.Errorf("[QueryFaultRecordList] %s", err.Error())
+		return nil, fmt.Errorf("[QueryFaultRecordList] %w", err)
 	}
 
 	if faultRecordResp.Code != 200 {
-		return nil, fmt.Errorf("[QueryFaultRecordList] 查询失败 code: %d, message: %s", faultRecordResp.Code, faultRecordResp.Message)
+		return nil, fmt.Errorf("[QueryFaultRecordList] 查询失败 sn=%s, startTime=%s, endTime=%s, code: %d, message: %s", sn, startTime, endTime, faultRecordResp.Code, faultRecordResp.Message)
 	}
 
 	return *faultRecordResp.Result, nil
@@ -52,7 +52,11 @@ func queryFaultRecordCallableList(devType int, sn string) (*domain.FwhResponse[[
 	response, err := FwhHttpGetUnmarshal[[]domain.FaultRecordCallableInfo](getFullEnergyUrl("/hes-gateway/manage/getWaveRecordingCatalog"), params)
 	// 此处无数据也会失败，暂时定义失败为无数据，不报错
 	if err != nil {
-		zap.L().Error("[queryFaultRecordCallableList] Response failed", zap.String("err", err.Error()))
+		zap.L().Error("[queryFaultRecordCallableList] Response failed",
+			zap.Int("devType", devType),
+			zap.String("sn", sn),
+			zap.String("err", err.Error()),
+		)
 		// 创造假的空数据
 		return &domain.FwhResponse[[]domain.FaultRecordCallableInfo]{
 			Code:   200,
@@ -67,7 +71,7 @@ func queryFaultRecordCallableList(devType int, sn string) (*domain.FwhResponse[[
 func QueryFaultRecordCallableList(devType int, sn string) ([]domain.FaultRecordCallableInfo, error) {
 	faultRecordCallableResp, err := queryFaultRecordCallableList(devType, sn)
 	if err != nil {
-		return nil, fmt.Errorf("[QueryFaultRecordCallableList] %s", err.Error())
+		return nil, fmt.Errorf("[QueryFaultRecordCallableList] %w", err)
 	}
 
 	if faultRecordCallableResp.Code != 200 {
@@ -75,7 +79,7 @@ func QueryFaultRecordCallableList(devType int, sn string) ([]domain.FaultRecordC
 		if faultRecordCallableResp.Code == 400 && faultRecordCallableResp.Message == "故障目录为空" {
 			return []domain.FaultRecordCallableInfo{}, nil
 		}
-		return nil, fmt.Errorf("[QueryFaultRecordCallableList] 查询失败 code: %d, message: %s", faultRecordCallableResp.Code, faultRecordCallableResp.Message)
+		return nil, fmt.Errorf("[QueryFaultRecordCallableList] 查询失败 devType=%d, sn=%s, code: %d, message: %s", devType, sn, faultRecordCallableResp.Code, faultRecordCallableResp.Message)
 	}
 
 	return *faultRecordCallableResp.Result, nil
@@ -84,7 +88,7 @@ func QueryFaultRecordCallableList(devType int, sn string) ([]domain.FaultRecordC
 // 召唤故障录波日志
 func queryCellFaultRecord(devType int, sn string, indexList []int) (*domain.FwhResponse[interface{}], error) {
 	if len(indexList) < 1 {
-		return nil, fmt.Errorf("未选择召唤数据idx")
+		return nil, fmt.Errorf("未选择召唤数据idx devType=%d, sn=%s", devType, sn)
 	}
 
 	// 将 []int 转为 []string
@@ -104,7 +108,7 @@ func queryCellFaultRecord(devType int, sn string, indexList []int) (*domain.FwhR
 
 	response, err := FwhHttpPostUnmarshal[interface{}](getFullEnergyUrl("/hes-gateway/manage/callFaultRecording"), body)
 	if err != nil {
-		return nil, err
+		return nil, fmt.Errorf("[queryCellFaultRecord] 请求失败 devType=%d, sn=%s, index=%s: %w", devType, sn, strings.Join(indexListStr, ","), err)
 	}
 	return response, nil
 }
@@ -113,11 +117,11 @@ func queryCellFaultRecord(devType int, sn string, indexList []int) (*domain.FwhR
 func QueryCellFaultRecord(devType int, sn string, indexList []int) error {
 	cellFaultRecordResp, err := queryCellFaultRecord(devType, sn, indexList)
 	if err != nil {
-		return fmt.Errorf("[QueryCellFaultRecord] %s", err.Error())
+		return fmt.Errorf("[QueryCellFaultRecord] %w", err)
 	}
 
 	if cellFaultRecordResp.Code != 200 {
-		return fmt.Errorf("[QueryCellFaultRecord] 查询失败 code: %d, message: %s", cellFaultRecordResp.Code, cellFaultRecordResp.Message)
+		return fmt.Errorf("[QueryCellFaultRecord] 查询失败 devType=%d, sn=%s, indexList=%v, code: %d, message: %s", devType, sn, indexList, cellFaultRecordResp.Code, cellFaultRecordResp.Message)
 	}
 
 	return nil
@@ -133,7 +137,7 @@ func queryFaultRecordCallRecordList() (*domain.FwhResponse[[]domain.FaultRecordI
 
 	response, err := FwhHttpGetUnmarshal[[]domain.FaultRecordInfo](getFullEnergyUrl("/hes-gateway/manage/lstFaultWaveCall"), params)
 	if err != nil {
-		return nil, err
+		return nil, fmt.Errorf("[queryFaultRecordCallRecordList] 请求失败: %w", err)
 	}
 	return response, nil
 }
@@ -142,7 +146,7 @@ func queryFaultRecordCallRecordList() (*domain.FwhResponse[[]domain.FaultRecordI
 func QueryFaultRecordCallRecordList() ([]domain.FaultRecordInfo, error) {
 	faultRecordCallRecordResp, err := queryFaultRecordCallRecordList()
 	if err != nil {
-		return nil, fmt.Errorf("[QueryFaultRecordCallRecordList] %s", err.Error())
+		return nil, fmt.Errorf("[QueryFaultRecordCallRecordList] %w", err)
 	}
 
 	if faultRecordCallRecordResp.Code != 200 {
@@ -163,7 +167,7 @@ func queryFaultRecordSubList(id int64) (*domain.FwhResponse[[]domain.FaultRecord
 
 	response, err := FwhHttpGetUnmarshal[[]domain.FaultRecordSubInfo](getFullEnergyUrl("/hes-gateway/manage/lstSubFaultWave"), params)
 	if err != nil {
-		return nil, err
+		return nil, fmt.Errorf("[queryFaultRecordSubList] 请求失败 faultId=%d: %w", id, err)
 	}
 	return response, nil
 }
@@ -172,11 +176,11 @@ func queryFaultRecordSubList(id int64) (*domain.FwhResponse[[]domain.FaultRecord
 func QueryFaultRecordSubList(id int64) ([]domain.FaultRecordSubInfo, error) {
 	faultRecordSubResp, err := queryFaultRecordSubList(id)
 	if err != nil {
-		return nil, fmt.Errorf("[QueryFaultRecordSubList] %s", err.Error())
+		return nil, fmt.Errorf("[QueryFaultRecordSubList] %w", err)
 	}
 
 	if faultRecordSubResp.Code != 200 {
-		return nil, fmt.Errorf("[QueryFaultRecordSubList] 查询失败 code: %d, message: %s", faultRecordSubResp.Code, faultRecordSubResp.Message)
+		return nil, fmt.Errorf("[QueryFaultRecordSubList] 查询失败 faultId=%d, code: %d, message: %s", id, faultRecordSubResp.Code, faultRecordSubResp.Message)
 	}
 
 	return *faultRecordSubResp.Result, nil
@@ -193,7 +197,7 @@ func QueryDownloadFaultRecordData(faultId int64, subRecordId int64) (string, []b
 
 	response, err := FwhHttpGet(getFullEnergyUrl("/hes-gateway/manage/exportSubFaultWave"), params)
 	if err != nil {
-		return "", nil, err
+		return "", nil, fmt.Errorf("[QueryDownloadFaultRecordData] 下载失败 faultId=%d, subRecordId=%d: %w", faultId, subRecordId, err)
 	}
 
 	// 从 Content-Disposition 提取真实文件名