liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
邹宗楠
2022-06-02 14:40:22 +08:00
parent 6ffd572c59
commit 3173f8e5b3
3 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
business/jxstore/cms/store_responsible_person_config.go
View File

@@ -50,6 +50,8 @@ func UpdateStoreOperatorConfig() {
globals.SugarLogger.Debug("Marshal err :", err) globals.SugarLogger.Debug("Marshal err :", err)
return return
} }
globals.SugarLogger.Debug("=============222222",userData)
globals.SugarLogger.Debug("=============222222",string(byteData))
if err := dao.UpdateOperatorConfig(string(byteData)); err != nil { if err := dao.UpdateOperatorConfig(string(byteData)); err != nil {
globals.SugarLogger.Debug("update new_config err :", err) globals.SugarLogger.Debug("update new_config err :", err)
return return

2
business/jxstore/misc/misc.go
View File

@@ -186,7 +186,7 @@ func Init() {
}) })
ScheduleTimerFuncByInterval(func() { ScheduleTimerFuncByInterval(func() {
cms.UpdateStoreOperatorConfig() cms.UpdateStoreOperatorConfig()
}, 10*time.Second, 5*time.Minute) }, 10*time.Second, 2*time.Minute)
ScheduleTimerFuncByInterval(func() { ScheduleTimerFuncByInterval(func() {
defsch.FixedScheduler.ConfirmSelfTakeOrders(jxcontext.AdminCtx, []int{model.VendorIDJD}, time.Now().Add(-48*time.Hour), time.Now().Add(-30*time.Minute), true, true) defsch.FixedScheduler.ConfirmSelfTakeOrders(jxcontext.AdminCtx, []int{model.VendorIDJD}, time.Now().Add(-48*time.Hour), time.Now().Add(-30*time.Minute), true, true)

5
business/model/dao/new_config.go
View File

@@ -3,6 +3,7 @@ package dao
import ( import (
"fmt" "fmt"
"git.rosy.net.cn/baseapi/utils/errlist" "git.rosy.net.cn/baseapi/utils/errlist"
"time"
"git.rosy.net.cn/baseapi/utils" "git.rosy.net.cn/baseapi/utils"
"git.rosy.net.cn/jx-callback/business/model" "git.rosy.net.cn/jx-callback/business/model"
@@ -62,7 +63,7 @@ func GetSysConfigAsInt64(db *DaoDB, key string) (value int64, err error) {
// 修改配置 // 修改配置
func UpdateOperatorConfig(param string) error { func UpdateOperatorConfig(param string) error {
sql := `UPDATE new_config c SET c.value = ? WHERE c.type = ? AND c.key = ?` sql := `UPDATE new_config c SET c.value = ?,c.updated_at = ? WHERE c.type = ? AND c.key = ?`
_, err := ExecuteSQL(GetDB(), sql, []interface{}{param, "Sys", "FZR"}) _, err := ExecuteSQL(GetDB(), sql, []interface{}{param, time.Now(), "Sys", "FZR"})
return err return err
} }