实时同步数据

services/data/edb_info_sync.go

@@ -106,4 +106,39 @@ func SyncSmmDataBase() {
 			}
 		}
 	}
+}
+
+
+//同步手工数据
+func SyncManualDataBase() {
+	var err error
+	defer func() {
+		if err != nil {
+			utils.FileLog.Info("SyncLzDataBase Err:" + err.Error())
+		}
+	}()
+	var condition string
+	var pars []interface{}
+	condition += " AND source=? "
+	pars = append(pars, utils.DATA_SOURCE_MANUAL)
+	items, err := data_manage.GetEdbInfoByCondition(condition, pars, 0)
+	if err != nil {
+		return
+	}
+	for _, v := range items {
+		err = data_manage.RefreshManual(v.EdbInfoId, v.EdbCode, v.StartDate.Format(utils.FormatDate), "")
+		if err != nil {
+			return
+		}
+		item, err := data_manage.GetEdbInfoMaxAndMinInfo(v.Source, v.EdbCode)
+		if err != nil {
+			return
+		}
+		if item != nil {
+			err = data_manage.ModifyEdbInfoMaxAndMinInfo(v.EdbInfoId, item)
+			if err != nil {
+				return
+			}
+		}
+	}
 }

services/task.go

@@ -107,9 +107,9 @@ func releaseTask() {
 	//refreshBaseData := task.NewTask("refreshBaseData", "0 1 18,23 * * *", RefreshBaseData)
 	//task.AddTask("refreshBaseData", refreshBaseData)
 
-	//刷新弘则数据库中来自，钢联，隆众，有色等基础数据
-	//refreshHzBaseData := task.NewTask("refreshHzBaseData", "0 */5 * * * * ", RefreshHzBaseData)
-	//task.AddTask("refreshHzBaseData", refreshHzBaseData)
+	//同步弘则数据库中来自，钢联，隆众，有色,人工等基础数据--每隔五分钟，同步一次最新数据
+	syncBaseData := task.NewTask("syncBaseData", "0 */5 * * * * ", SyncBaseData)
+	task.AddTask("syncBaseData", syncBaseData)
 
 	// 定时往同花顺同步微信群的截止日期（凌晨4点）
 	syncThsWxGroupEveryDay := task.NewTask("syncThsWxGroupEveryDay", "0 1 4 * * * ", SyncWxGroupEveryDay)
@@ -189,10 +189,13 @@ func RefreshBaseData(cont context.Context) (err error) {
 }
 
 //刷新基础数据
-func RefreshHzBaseData(cont context.Context) (err error) {
+func SyncBaseData(cont context.Context) (err error) {
 	//同步钢联基础数据
 	go data.SyncGlDataBase()
 	//同步隆众基础数据
+	go data.SyncLzDataBase()
+	//同步手工数据
+	go data.SyncManualDataBase()
 	//同步有色基础数据
 	return
 }