增加日志

go.mod

@@ -4,7 +4,7 @@ go 1.14
 
 require (
 	app.yhyue.com/moapp/jyPoints v0.0.0-20210319094929-f8c029fa5c82
-	app.yhyue.com/moapp/jybase v0.0.0-20210319015107-fe59d2046cf8
+	app.yhyue.com/moapp/jybase v0.0.0-20210322021809-141cc2c37946
 	github.com/nsqio/go-nsq v1.0.8
 	github.com/tal-tech/go-zero v1.1.5
 )

go.sum

@@ -2,6 +2,8 @@ app.yhyue.com/moapp/jyPoints v0.0.0-20210319094929-f8c029fa5c82 h1:GoyZQMQNVfi+f
 app.yhyue.com/moapp/jyPoints v0.0.0-20210319094929-f8c029fa5c82/go.mod h1:ZuQoeKgip9OrJPRDpXkv4XOHV/oFIqL1aK+tcfIN+KQ=
 app.yhyue.com/moapp/jybase v0.0.0-20210319015107-fe59d2046cf8 h1:0wnq1iFfpPrASDJzO24+Lr2pMO18ISNDf1n4TU3faTQ=
 app.yhyue.com/moapp/jybase v0.0.0-20210319015107-fe59d2046cf8/go.mod h1:29ShuI8y7qEyg2KviHSx1iamiCioBKdTMm2ndVzWAhk=
+app.yhyue.com/moapp/jybase v0.0.0-20210322021809-141cc2c37946 h1:w4voEoJ5RqjlUyGhNC15sk3RdwCCi2U5uX33Btw9BMc=
+app.yhyue.com/moapp/jybase v0.0.0-20210322021809-141cc2c37946/go.mod h1:29ShuI8y7qEyg2KviHSx1iamiCioBKdTMm2ndVzWAhk=
 cloud.google.com/go v0.26.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=
 cloud.google.com/go v0.34.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=
 cloud.google.com/go v0.37.4/go.mod h1:NHPJ89PdicEuT9hdPXMROBD91xc5uRDxsMtSB16k7hw=

main.go

@@ -3,11 +3,18 @@ package main
 import (
 	"log"
 
+	"app.yhyue.com/moapp/jybase/go-logger/logger"
 	. "app.yhyue.com/moapp/message/config"
 	"app.yhyue.com/moapp/message/points"
 	"github.com/nsqio/go-nsq"
 )
 
+func init() {
+	logger.SetConsole(false)
+	logger.SetRollingDaily("./logs", "message.log")
+}
+
+//
 func main() {
 	// Instantiate a consumer that will subscribe to the provided channel.
 	config := nsq.NewConfig()

points/points.go

@@ -3,7 +3,6 @@ package points
 import (
 	"encoding/json"
 	"fmt"
-	"log"
 	"time"
 
 	"context"
@@ -12,6 +11,7 @@ import (
 	"app.yhyue.com/moapp/jyPoints/rpc/integralclient"
 	"app.yhyue.com/moapp/jybase/common"
 	"app.yhyue.com/moapp/jybase/date"
+	"app.yhyue.com/moapp/jybase/go-logger/logger"
 	"app.yhyue.com/moapp/jybase/redis"
 	. "app.yhyue.com/moapp/message/client"
 	. "app.yhyue.com/moapp/message/config"
@@ -49,22 +49,22 @@ func (p *Points) HandleMessage(m *nsq.Message) error {
 	var msg *model.Message
 	err := json.Unmarshal(m.Body, &msg)
 	if err != nil {
-		log.Println(err)
+		logger.Error(err)
 		return err
 	}
-	log.Println("接收到消息", fmt.Sprintf("%+v", msg))
+	logger.Info("接收到消息", fmt.Sprintf("%+v", msg))
 	if msg.E_code == "" {
-		log.Println("缺少参数e_code", fmt.Sprintf("%+v", msg))
+		logger.Info("缺少参数e_code", fmt.Sprintf("%+v", msg))
 		return nil
 	} else if msg.E_time == 0 {
-		log.Println("缺少参数e_time", fmt.Sprintf("%+v", msg))
+		logger.Info("缺少参数e_time", fmt.Sprintf("%+v", msg))
 		return nil
 	}
 	f, f_ok := funcMap[msg.E_code]
 	if f_ok {
 		f(msg)
 	} else {
-		log.Println("无效的code值", msg)
+		logger.Info("无效的code值", msg)
 	}
 	Mgo_Log.Save("nsq_logs", map[string]interface{}{
 		"createtime": time.Now().Unix(),
@@ -108,7 +108,7 @@ func jy_open(msg *model.Message, key string, point int64) {
 		redis.SetExpire(Redis_Main, key, OneDay)
 		integralHarvest(msg, point, 1005)
 	} else {
-		log.Println(fmt.Sprintf("%+v", msg), "超过一天最大次数", Config.DocPoints.Open.Max, "限制,不再增加积分")
+		logger.Info(fmt.Sprintf("%+v", msg), "超过一天最大次数", Config.DocPoints.Open.Max, "限制,不再增加积分")
 	}
 }
 
@@ -125,14 +125,14 @@ func integralHarvest(msg *model.Message, point, pointType int64) bool {
 	}
 	resp, err := integralclient.NewIntegral(ZrpcClient).IntegralHarvest(context.Background(), req)
 	if err != nil {
-		log.Println(fmt.Sprintf("%+v", msg), "IntegralHarvest Resp error", err)
+		logger.Info(fmt.Sprintf("%+v", msg), "IntegralHarvest Resp error", err)
 		return false
 	}
 	if resp.Code == 1 {
-		log.Println(fmt.Sprintf("%+v", msg), "已成功增加", point, "积分")
+		logger.Info(fmt.Sprintf("%+v", msg), "已成功增加", point, "积分")
 		return true
 	} else {
-		log.Println(fmt.Sprintf("%+v", msg), "增加", point, "积分失败", "Code", resp.Code, "Message", resp.Message)
+		logger.Info(fmt.Sprintf("%+v", msg), "增加", point, "积分失败", "Code", resp.Code, "Message", resp.Message)
 		return false
 	}
 }