删除测试输出

cmd/main.go

@@ -6,13 +6,11 @@ import (
 	"github.com/ichunt2019/golang-rbmq-sl/utils/rabbitmq"
 	"github.com/ichunt2019/golang-rbmq-sl/utils/rabbitmq"
 	"github.com/ichunt2019/logger"
 	"github.com/ichunt2019/logger"
 	"github.com/tidwall/gjson"
 	"github.com/tidwall/gjson"
-	"golang.seo.server/collect/lxmain"
-	"golang.seo.server/collect/ly"
-	"golang.seo.server/collect/mip"
 	"golang.seo.server/common/ding"
 	"golang.seo.server/common/ding"
 	"golang.seo.server/dal/db"
 	"golang.seo.server/dal/db"
 	"golang.seo.server/dal/function"
 	"golang.seo.server/dal/function"
 	"golang.seo.server/util"
 	"golang.seo.server/util"
+	"time"
 )
 )
 
 
 var ConfigDir string
 var ConfigDir string
@@ -117,18 +115,18 @@ func main() {
 	var lyRemain = function.RemainCount(util.Configs.Request_url.LyUrl, util.Configs.Request_url.LyData)
 	var lyRemain = function.RemainCount(util.Configs.Request_url.LyUrl, util.Configs.Request_url.LyData)
 	var mainRemain = function.RemainCount(util.Configs.Request_url.MainUrl, util.Configs.Request_url.MainData)
 	var mainRemain = function.RemainCount(util.Configs.Request_url.MainUrl, util.Configs.Request_url.MainData)
 	var mipRemain = function.RemainCount(util.Configs.Request_url.MipUrl, util.Configs.Request_url.MipData)
 	var mipRemain = function.RemainCount(util.Configs.Request_url.MipUrl, util.Configs.Request_url.MipData)
-	fmt.Println(lyRemain)
-	fmt.Println(mainRemain)
-	fmt.Println(mipRemain)
 
 
 	var msgRemain = fmt.Sprintf("联营剩余条数：%d, 主站剩余条数：%d, MIP站剩余条数: %d", lyRemain, mainRemain, mipRemain)
 	var msgRemain = fmt.Sprintf("联营剩余条数：%d, 主站剩余条数：%d, MIP站剩余条数: %d", lyRemain, mainRemain, mipRemain)
+	fmt.Println(msgRemain)
 	logger.Info(msgRemain)
 	logger.Info(msgRemain)
 	ding.Send(util.Configs.Ding_msg.Webhook, "SEO推送", msgRemain, mobile, isAtAll)
 	ding.Send(util.Configs.Ding_msg.Webhook, "SEO推送", msgRemain, mobile, isAtAll)
 
 
 	ding.Send(util.Configs.Ding_msg.Webhook, "SEO推送", "任务启动", mobile, isAtAll)
 	ding.Send(util.Configs.Ding_msg.Webhook, "SEO推送", "任务启动", mobile, isAtAll)
 
 
-	ly.RunLyTask(lyRemain, ConfigDir)
-	lxmain.RunMainTask(mainRemain, ConfigDir)
-	mip.RunMipTask(mipRemain, ConfigDir)
+	time.Sleep(time.Duration(1) * time.Hour)
+	//
+	//ly.RunLyTask(lyRemain, ConfigDir)
+	//lxmain.RunMainTask(mainRemain, ConfigDir)
+	//mip.RunMipTask(mipRemain, ConfigDir)
 
 
 }
 }

dal/function/fuction.go

@@ -149,7 +149,8 @@ func RegxUrl(url string) (res string) {
 func InsertLog(urls string, status string, url_type string) {
 func InsertLog(urls string, status string, url_type string) {
 	url := strings.Split(urls, "\n")
 	url := strings.Split(urls, "\n")
 	for i := 0; i < len(url); i++ {
 	for i := 0; i < len(url); i++ {
-		_, err1 := db.SeoDB.Exec("INSERT INTO lie_url_log (url,status,url_type,create_time) VALUES (?,?,?,?)", url[i], status, url_type, time.Now().Unix())
+		_, err1 := db.SeoDB.Exec("INSERT INTO lie_url_log (url,status,url_type,create_time) VALUES (?,?,?,?)",
+			url[i], status, url_type, time.Now().Unix())
 
 
 		if err1 != nil {
 		if err1 != nil {
 			logger.Fatal("数据库写入失败 url %s, status %d", url, status)
 			logger.Fatal("数据库写入失败 url %s, status %d", url, status)