|
@@ -25,7 +25,7 @@ import (
|
|
|
// 渠道定时任务
|
|
// 渠道定时任务
|
|
|
func everythingSync() {
|
|
func everythingSync() {
|
|
|
lastEverythingTime := cfg.LastEverythingTime
|
|
lastEverythingTime := cfg.LastEverythingTime
|
|
|
- nowTime := time.Now().Format(dates.Date_Full_Layout)
|
|
|
|
|
|
|
+
|
|
|
codeArr := []string{}
|
|
codeArr := []string{}
|
|
|
if len(UserChannel) > 0 {
|
|
if len(UserChannel) > 0 {
|
|
|
for i, _ := range UserChannel {
|
|
for i, _ := range UserChannel {
|
|
@@ -47,6 +47,7 @@ func everythingSync() {
|
|
|
log.Println("三方渠道数据定时任务结束")
|
|
log.Println("三方渠道数据定时任务结束")
|
|
|
}
|
|
}
|
|
|
func everythingSyncHandle(data *[]map[string]interface{}, isUpdate bool) {
|
|
func everythingSyncHandle(data *[]map[string]interface{}, isUpdate bool) {
|
|
|
|
|
+ nowTime := time.Now().Format(dates.Date_Full_Layout)
|
|
|
for _, v := range *data {
|
|
for _, v := range *data {
|
|
|
id := gconv.Int64(v["id"])
|
|
id := gconv.Int64(v["id"])
|
|
|
channel_code := gconv.String(v["channel_code"])
|
|
channel_code := gconv.String(v["channel_code"])
|
