fix：时间字符串格式化

services/eta_bridge/xy.go

@@ -525,9 +525,6 @@ func min(a, b int) int {
 // 同步crm指标信息锁
 var lockGetCrmIndex sync.Mutex
 
-// 每次同步crm数据的指标数量
-var syncCrmPageSize = 20
-
 // SyncXyCrmIndex
 // @Description: 定时同步CRM指标信息
 // @author: Roc
@@ -577,7 +574,7 @@ func SyncXyCrmIndex(cont context.Context) (err error) {
 	syncCrmAssetPkgCdList := strings.Split(syncCrmAssetPkgCd, ",")
 
 	for _, assetPkgCd := range syncCrmAssetPkgCdList {
-		err, errMsgList = syncCrmIndex(assetPkgCd, 1, syncCrmPageSize, lastUpdateTimeStr)
+		err, errMsgList = syncCrmIndex(assetPkgCd, 1, utils.SyncCrmIndexNum, lastUpdateTimeStr)
 	}
 
 	// 修改最后的更新时间
@@ -596,8 +593,10 @@ func SyncXyCrmIndex(cont context.Context) (err error) {
 // @param lastUpdateTimeStr string
 // @return err error
 // @return errMsgList []string
-func syncCrmIndex(assetPkgCd string, currIndex, pageSize int, lastUpdateTimeStr string) (err error, errMsgList []string) {
+func syncCrmIndex(assetPkgCd string, currIndex, pageSize int, baseLastUpdateTimeStr string) (err error, errMsgList []string) {
 	errMsgList = make([]string, 0)
+
+	lastUpdateTimeStr := baseLastUpdateTimeStr
 	if lastUpdateTimeStr != `` {
 		lastUpdateTimeStr = url.QueryEscape(lastUpdateTimeStr)
 	}
@@ -627,7 +626,7 @@ func syncCrmIndex(assetPkgCd string, currIndex, pageSize int, lastUpdateTimeStr
 
 	// 如果还有下一页，那么就继续请求下一页
 	if currIndex < result.Data.Paging.Pages {
-		_, tmpErrMsgList := syncCrmIndex(assetPkgCd, currIndex+1, syncCrmPageSize, lastUpdateTimeStr)
+		_, tmpErrMsgList := syncCrmIndex(assetPkgCd, currIndex+1, utils.SyncCrmIndexNum, baseLastUpdateTimeStr)
 		errMsgList = append(errMsgList, tmpErrMsgList...)
 	}
 

utils/config.go

@@ -134,6 +134,7 @@ var (
 	SyncCrmIndexTime      string // 桥接服务-crm指标同步的时间配置
 	SyncCrmAssetPkgCd     string // 桥接服务-crm资产包配置
 	SyncCrmDataSourceType string // 桥接服务-crm内部来源系统参数配置
+	SyncCrmIndexNum       int    // 桥接服务-每次同步crm数据的数量
 )
 
 var (
@@ -294,6 +295,14 @@ func init() {
 		SyncCrmIndexTime = config["sync_crm_index_time"]            // 桥接服务-crm指标同步的时间配置
 		SyncCrmAssetPkgCd = config["sync_crm_asset_pkg_cd"]         // 桥接服务-crm资产包配置
 		SyncCrmDataSourceType = config["sync_crm_data_source_type"] // 桥接服务-crm内部来源系统参数配置
+
+		syncCrmIndexNumStr := config["sync_crm_index_num"] // 桥接服务-每次同步crm数据的数量
+		if syncCrmIndexNumStr != `` {
+			SyncCrmIndexNum, _ = strconv.Atoi(syncCrmIndexNumStr)
+		}
+		if SyncCrmIndexNum <= 0 {
+			SyncCrmIndexNum = 2000
+		}
 	}
 
 	// 公共服务