|
@@ -64,29 +64,28 @@ func SyncGnIndex(cont context.Context) (err error) {
|
|
|
|
|
|
var lastUpdateTimeStr string // 上一次更新的时间
|
|
|
|
|
|
- // TODO:暂时注释下, 只取部分有数据的
|
|
|
- //err, errMsgList = syncGnIndex(1, utils.SyncCrmIndexNum, lastUpdateTimeStr)
|
|
|
+ err, errMsgList = syncGnIndex(1, utils.SyncCrmIndexNum, lastUpdateTimeStr)
|
|
|
|
|
|
- // TODO:下面的用完整体注释掉就行
|
|
|
- indexIds, e := LoadGnTempIndexIds()
|
|
|
- if e != nil {
|
|
|
- err = fmt.Errorf("读取IDs配置文件失败, %v", e)
|
|
|
- return
|
|
|
- }
|
|
|
- if len(indexIds) == 0 {
|
|
|
- fmt.Println("IndexIds为空")
|
|
|
- return
|
|
|
- }
|
|
|
- for _, v := range indexIds {
|
|
|
- strId := strconv.Itoa(v)
|
|
|
- fmt.Printf("正在同步IndexId: %s\n", strId)
|
|
|
- err, errMsgList = syncGnIndexV2(1, 1, lastUpdateTimeStr, strId)
|
|
|
- if err != nil {
|
|
|
- errMsg := strings.Join(errMsgList, "\n")
|
|
|
- fmt.Printf("IndexId: %s, 同步失败, ErrMsg: %s", strId, errMsg)
|
|
|
- continue
|
|
|
- }
|
|
|
- }
|
|
|
+ // 下面的用完整体注释掉就行
|
|
|
+ //indexIds, e := LoadGnTempIndexIds()
|
|
|
+ //if e != nil {
|
|
|
+ // err = fmt.Errorf("读取IDs配置文件失败, %v", e)
|
|
|
+ // return
|
|
|
+ //}
|
|
|
+ //if len(indexIds) == 0 {
|
|
|
+ // fmt.Println("IndexIds为空")
|
|
|
+ // return
|
|
|
+ //}
|
|
|
+ //for _, v := range indexIds {
|
|
|
+ // strId := strconv.Itoa(v)
|
|
|
+ // fmt.Printf("正在同步IndexId: %s\n", strId)
|
|
|
+ // err, errMsgList = syncGnIndexV2(1, 1, lastUpdateTimeStr, strId)
|
|
|
+ // if err != nil {
|
|
|
+ // errMsg := strings.Join(errMsgList, "\n")
|
|
|
+ // fmt.Printf("IndexId: %s, 同步失败, ErrMsg: %s", strId, errMsg)
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ //}
|
|
|
return
|
|
|
}
|
|
|
|