调整cron定时

cmd/task/find_goods/main.go

@@ -48,16 +48,17 @@ func main () {
 	if task_setup_details.TaskExecTimeType == 1 {
 		str := strings.Split(task_setup_details.TsakExecTime, ":")
 		cron_time = "0 " + str[1] + " " + str[0] + " * * *"
-		fmt.Println(cron_time)
 	} else {
 		cron_time = "0 " + task_setup_details.TsakExecTime + " * * * *"
 	}
 
 	c := cron.New()
 	c.AddFunc(cron_time, func() {
+		fmt.Println(cron_time)
 		go setFindGoods(task_setup.Status, task_setup.Id, task_setup.TaskType, task_setup.TaskDisplayDegree)
 	})
 	c.Start()
+	defer c.Stop()
 	select {
 	}
 }
@@ -81,7 +82,7 @@ func setFindGoods(status, task_id, task_type, task_display_degree int) {
 
 		// 判断该用户是否存在注册领取任务记录或快速找料任务，若存在则跳过
 		var task_info model.TaskInfo
-		dao.GetDb().Get(&task_info, "select * from lie_task_info where user_id = ? and status = ? and (task_type = ? or task_type = ?) limit 1", feedback.User_Id, 1, 1, 4)
+		dao.GetDb().Get(&task_info, "select * from lie_task_info where user_id = ? and status = ? and (task_type = ? or task_type = ?) limit 1", feedback.Outter_Uid, 1, 1, 4)
 
 		if task_info.Id != 0 {
 			continue
@@ -91,13 +92,13 @@ func setFindGoods(status, task_id, task_type, task_display_degree int) {
 
 		// 查看用户是否分配
 		var salesman model.Salesman
-		dao.GetDb().Get(&salesman, "select * from lie_salesman where user_id = ?", feedback.User_Id)
+		dao.GetDb().Get(&salesman, "select * from lie_salesman where user_id = ?", feedback.Outter_Uid)
 
 		dao.GetDb().Exec("insert into lie_task_info (user_id, task_id, task_type, task_display_degree, sale_id, create_time, update_time) value (?, ?, ?, ?, " +
-			"?, ?, ?)", feedback.User_Id, task_id, task_type, task_display_degree, salesman.Sale_Id, current_time, current_time)
+			"?, ?, ?)", feedback.Outter_Uid, task_id, task_type, task_display_degree, salesman.Sale_Id, current_time, current_time)
 		dao.GetDb().Exec("update lie_feedback set is_add_task = ? where id = ?", 1, feedback.Id)
 
-		service.DingAlert(configs.Ding_crm_task_token, "任务告警：快速找料任务脚本添加任务记录成功，CRM用户ID："+strconv.Itoa(feedback.User_Id), "")
+		service.DingAlert(configs.Ding_crm_task_token, "任务告警：快速找料任务脚本添加任务记录成功，CRM用户ID："+strconv.Itoa(feedback.Outter_Uid), "")
 	}
 
 

cmd/task/multi_search/main.go

@@ -46,16 +46,17 @@ func main () {
 	if task_setup_details.TaskExecTimeType == 1 {
 		str := strings.Split(task_setup_details.TsakExecTime, ":")
 		cron_time = "0 " + str[1] + " " + str[0] + " * * *"
-		fmt.Println(cron_time)
 	} else {
 		cron_time = "0 " + task_setup_details.TsakExecTime + " * * * *"
 	}
 
 	c := cron.New()
 	c.AddFunc(cron_time, func() {
+		fmt.Println(cron_time)
 		go setMultiSearch(task_setup.Status, task_setup.Id, task_setup.TaskType, task_setup.TaskDisplayDegree)
 	})
 	c.Start()
+	defer c.Stop()
 	select {
 	}
 }
@@ -78,7 +79,7 @@ func setMultiSearch(status, task_id, task_type, task_display_degree int) {
 		row.StructScan(&feedback)
 
 		var task_info model.TaskInfo
-		dao.GetDb().Get(&task_info, "select * from lie_task_info where user_id = ? and status = ? and task_type = ? limit 1", feedback.User_Id, 1, 5)
+		dao.GetDb().Get(&task_info, "select * from lie_task_info where user_id = ? and status = ? and task_type = ? limit 1", feedback.Outter_Uid, 1, 5)
 
 		if task_info.Id != 0 {
 			continue
@@ -88,13 +89,13 @@ func setMultiSearch(status, task_id, task_type, task_display_degree int) {
 
 		// 查看用户是否分配
 		var salesman model.Salesman
-		dao.GetDb().Get(&salesman, "select * from lie_salesman where user_id = ?", feedback.User_Id)
+		dao.GetDb().Get(&salesman, "select * from lie_salesman where user_id = ?", feedback.Outter_Uid)
 
 		dao.GetDb().Exec("insert into lie_task_info (user_id, task_id, task_type, task_display_degree, sale_id, create_time, update_time) value (?, ?, ?, ?, " +
-			"?, ?, ?)", feedback.User_Id, task_id, task_type, task_display_degree, salesman.Sale_Id, current_time, current_time)
+			"?, ?, ?)", feedback.Outter_Uid, task_id, task_type, task_display_degree, salesman.Sale_Id, current_time, current_time)
 		dao.GetDb().Exec("update lie_feedback set is_add_task = ? where id = ?", 1, feedback.Id)
 
-		service.DingAlert(configs.Ding_crm_task_token, "任务告警：多次搜索任务脚本添加任务记录成功，CRM用户ID："+strconv.Itoa(feedback.User_Id), "")
+		service.DingAlert(configs.Ding_crm_task_token, "任务告警：多次搜索任务脚本添加任务记录成功，CRM用户ID："+strconv.Itoa(feedback.Outter_Uid), "")
 	}