message/rpc/integral.go

package rpc

import (
	"app.yhyue.com/moapp/jyPoints/rpc/integral"
	"app.yhyue.com/moapp/jyPoints/rpc/integralclient"
	"app.yhyue.com/moapp/jybase/date"
	"app.yhyue.com/moapp/jybase/go-logger/logger"
	"app.yhyue.com/moapp/message/model"
	"fmt"
	"github.com/gogf/gf/v2/os/gcfg"
	"github.com/gogf/gf/v2/os/gctx"
	"github.com/tal-tech/go-zero/core/discov"
	"github.com/tal-tech/go-zero/zrpc"
	"log"
	"time"
)

var zrpcClient zrpc.Client

func init() {
	var err error
	zrpcClient, err = zrpc.NewClient(zrpc.RpcClientConf{
		Etcd: discov.EtcdConf{
			Hosts: gcfg.Instance().MustGet(gctx.New(), "etcd.baseserver.integral.address", nil).Strings(),
			Key:   gcfg.Instance().MustGet(gctx.New(), "etcd.baseserver.integral.key", nil).String(),
		},
	})
	if err != nil {
		log.Fatalln(err)
	}
}

func IntegralHarvest(msg *model.Message, point, pointType int64) error {
	t := time.Unix(msg.E_time, 0).AddDate(1, 0, 0)
	req := &integral.Req{
		UserId:        msg.E_userId,
		AppId:         gcfg.Instance().MustGet(gctx.New(), "docPoints.appId", "10000").String(),
		PointType:     pointType,
		Point:         point,
		EndDate:       date.FormatDate(&t, date.Date_Full_Layout),
		OperationType: false,
	}
	resp, err := integralclient.NewIntegral(zrpcClient).IntegralHarvest(gctx.New(), req)
	if err != nil {
		return fmt.Errorf(fmt.Sprintf("%+v", msg), "IntegralHarvest Resp error", err)
	}
	if resp.Code == 1 {
		logger.Info(fmt.Sprintf("%+v", msg), "已成功增加", point, "积分")
		return nil
	} else {
		return fmt.Errorf(fmt.Sprintf("%+v", msg), "增加", point, "积分失败", "Code", resp.Code, "Message", resp.Message)
	}
}