报表统计

services/data/base_edb_lib.go

@@ -143,7 +143,16 @@ func postRefreshEdbData(param map[string]interface{}, urlStr string) (resp *mode
 
 // SetEdbSourceStat 指标终端更新情况定时汇总
 func SetEdbSourceStat() (resp *models.BaseResponse, err error) {
-	postUrl := utils.EDB_LIB_URL + "edb_stat/source_update"
+	var postUrl string
+	edbLibUrlListLen := len(utils.EDB_LIB_URL_LIST)
+	if edbLibUrlListLen <= 0 {
+		postUrl = utils.EDB_LIB_URL
+	} else {
+		rn := step % edbLibUrlListLen
+		postUrl = utils.EDB_LIB_URL_LIST[rn].Url
+	}
+	postUrl = postUrl + "edb_stat/source_update"
+	step++
 	result, err := HttpPost(postUrl, "", "application/json")
 	if err != nil {
 		return

services/edb_inspection.go

@@ -221,7 +221,7 @@ func AddEdbInspectionRecord(cont context.Context) (err error) {
 				config.Source, config.TerminalCode, err))
 			continue
 		}
-		if dashboard == nil {
+		if tempErr != nil && utils.IsErrNoRow(tempErr) {
 			dashboard = &edb_inspection.EdbInspectionDashboard{
 				Source:             config.Source,
 				TerminalCode:       config.TerminalCode,
@@ -238,7 +238,7 @@ func AddEdbInspectionRecord(cont context.Context) (err error) {
 					record.InspectionRecordId, err))
 				continue
 			}
-		} else {
+		} else if tempErr == nil && dashboard.DashboardId > 0 {
 			dashboard.InspectionRecordId = record.InspectionRecordId
 			dashboard.InspectionTime = now
 			dashboard.InspectionResult = record.InspectionResult