优化

services/national_data/common.go

@@ -18,9 +18,9 @@ const (
 
 func NationalHttpPost(reqUrl, payload string) (result []byte, err error) {
 	// 随机延迟执行
-	r := utils.RangeRand(3000, 6000)
-	if r > 5000 && r < 5100 {
-		time.Sleep(10 * time.Second)
+	r := utils.RangeRand(4000, 8000)
+	if r > 6100 && r < 6250 {
+		time.Sleep(15 * time.Second)
 	} else {
 		time.Sleep(time.Duration(r) * time.Millisecond)
 	}

services/national_data/national_data.go

@@ -132,10 +132,12 @@ func SyncXDateYQuotaDb(dbs []string) (err error) {
 
 		// 同步指标和数据
 		for _, c := range classifyList {
+			utils.FileLog.Info("开始同步分类-%d: %s", c.BaseFromNationalStatisticsClassifyId, c.ClassifyName)
 			if e = SyncXDateYQuotaData(c.BaseFromNationalStatisticsClassifyId, c.Dbcode, c.Id); e != nil {
 				err = fmt.Errorf("同步指标数据失败, DbCode: %s, ClassifyId: %d, Err: %s", c.Dbcode, c.BaseFromNationalStatisticsClassifyId, e.Error())
 				return
 			}
+			utils.FileLog.Info("结束同步分类-%d: %s", c.BaseFromNationalStatisticsClassifyId, c.ClassifyName)
 		}
 	}
 	return
@@ -340,10 +342,12 @@ func SyncXDateYQuotaZRegDb(dbs []string) (err error) {
 
 		// 同步指标和数据
 		for _, c := range classifyList {
+			utils.FileLog.Info("开始同步分类-%d: %s", c.BaseFromNationalStatisticsClassifyId, c.ClassifyName)
 			if e = SyncXDateYQuotaZRegData(c.BaseFromNationalStatisticsClassifyId, c.Dbcode, c.Id, regList); e != nil {
 				err = fmt.Errorf("同步指标数据失败, DbCode: %s, ClassifyId: %d, Err: %s", c.Dbcode, c.BaseFromNationalStatisticsClassifyId, e.Error())
 				return
 			}
+			utils.FileLog.Info("结束同步分类-%d: %s", c.BaseFromNationalStatisticsClassifyId, c.ClassifyName)
 		}
 	}
 	return
@@ -545,10 +549,12 @@ func SyncXRegYDateZQuotaDb(dbs []string) (err error) {
 
 		// 同步指标和数据
 		for _, c := range classifyList {
+			utils.FileLog.Info("开始同步分类-%d: %s", c.BaseFromNationalStatisticsClassifyId, c.ClassifyName)
 			if e = SyncXRegYDateZQuotaDbData(c.BaseFromNationalStatisticsClassifyId, c.Dbcode, c.Id); e != nil {
 				err = fmt.Errorf("同步指标数据失败, DbCode: %s, ClassifyId: %d, Err: %s", c.Dbcode, c.BaseFromNationalStatisticsClassifyId, e.Error())
 				return
 			}
+			utils.FileLog.Info("结束同步分类-%d: %s", c.BaseFromNationalStatisticsClassifyId, c.ClassifyName)
 		}
 	}
 	return