|
@@ -3,6 +3,7 @@ package services
|
|
import (
|
|
import (
|
|
"fmt"
|
|
"fmt"
|
|
"github.com/astaxie/beego/toolbox"
|
|
"github.com/astaxie/beego/toolbox"
|
|
|
|
+ "hongze/hongze_task/services/data_manage"
|
|
"hongze/hongze_task/services/company_contract"
|
|
"hongze/hongze_task/services/company_contract"
|
|
"hongze/hongze_task/utils"
|
|
"hongze/hongze_task/utils"
|
|
)
|
|
)
|
|
@@ -83,6 +84,10 @@ func releaseTask(){
|
|
//潜在客户
|
|
//潜在客户
|
|
freeViewerDetail := toolbox.NewTask("freeViewerDetail", "0 0 9 * * 1 ", FreeViewerDetail)
|
|
freeViewerDetail := toolbox.NewTask("freeViewerDetail", "0 0 9 * * 1 ", FreeViewerDetail)
|
|
toolbox.AddTask("潜在客户", freeViewerDetail)
|
|
toolbox.AddTask("潜在客户", freeViewerDetail)
|
|
|
|
+
|
|
|
|
+ //刷新数据
|
|
|
|
+ refreshData := toolbox.NewTask("refreshData", "0 0 18 * * *", RefreshData)
|
|
|
|
+ toolbox.AddTask("refreshData", refreshData)
|
|
}
|
|
}
|
|
|
|
|
|
func TaskTest(){
|
|
func TaskTest(){
|
|
@@ -120,4 +125,12 @@ func OneMinute() (err error) {
|
|
//月度
|
|
//月度
|
|
FrequencyByMonth()
|
|
FrequencyByMonth()
|
|
return
|
|
return
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+func RefreshData() (err error){
|
|
|
|
+ //wind
|
|
|
|
+ go data_manage.RefreshDataFromWind()
|
|
|
|
+ //同花顺
|
|
|
|
+ go data_manage.RefreshDataFromThs()
|
|
|
|
+ return
|
|
}
|
|
}
|