@@ -157,7 +157,7 @@ func autoTasks() {
func autoExitSea() {
log.Println("自动退海任务开始")
- data := TiDb.Find("dwd_f_crm_clue_info", map[string]interface{}{"trailstatus": "02", "is_assign": 1}, "", "", -1, -1)
+ data := TiDb.SelectBySql(`select * from dwd_f_crm_clue_info where trailstatus = "02" and (is_assign = 1 or is_assign = 0)`)
if data != nil && len(*data) > 0 {
for _, v := range *data {
clueId := common.Int64All(v["id"])
@@ -122,7 +122,7 @@ func main() {
})
g.Start()
h := cron.New()
- h.AddFunc(cfg.CornExp2, func() {
+ h.AddFunc(cfg.CornExp5, func() {
autoExitSea()
h.Start()