SkGmServer/library/netutil/gmutil.go

package netutil

import (
	"fmt"
	"github.com/gogf/gf/frame/g"
	"github.com/gogf/gf/text/gstr"
	"gmanager/common"
	"gmanager/library/thrift"
	"net"
	"os"
)

type Gmcmd struct {
	ServerIp   string
	ServerPort string
	Cmd        string
	UserId     string
	Args       string
}

func (gmcmd *Gmcmd) SendGM() int32 {
	transportFactory := thrift.NewTTransportFactory()
	protocolFactory := thrift.NewTBinaryProtocolFactoryDefault()
	transport, err := thrift.NewTSocket(net.JoinHostPort(gmcmd.ServerIp, gmcmd.ServerPort))

	if err != nil {
		fmt.Fprintln(os.Stderr, "error resolving address:", err)
		//os.Exit(1)
		return -100
	}

	useTransport := transportFactory.GetTransport(transport)
	client := common.NewRPCRequestGMIFaceClientFactory(useTransport, protocolFactory)
	if err := transport.Open(); err != nil {
		fmt.Fprintln(os.Stderr, "Error opening socket to server", " ", err)
		//os.Exit(1)
		return -101
	}
	defer transport.Close()

	//for i := 0; i < 2; i++ {
	arges := gmcmd.Args
	if gstr.Equal("sendmail", gmcmd.Cmd) {
		arges = gmcmd.UserId + " " + arges
	} else if gstr.Equal("modifyitem", gmcmd.Cmd) {
		arges = gmcmd.UserId + " " + arges
	}
	cmd := gmcmd.Cmd + " " + gmcmd.UserId + " " + arges
	fmt.Println("cmd "+cmd)
	r1, e1 := client.IdipGm(gmcmd.Cmd, cmd)
	fmt.Println("Call->", r1, e1)
	return *r1.ResultCode
	//}
}

func (gmcmd *Gmcmd) SendGMAll() int32 {
	transportFactory := thrift.NewTTransportFactory()
	protocolFactory := thrift.NewTBinaryProtocolFactoryDefault()
	transport, err := thrift.NewTSocket(net.JoinHostPort(gmcmd.ServerIp, gmcmd.ServerPort))

	if err != nil {
		fmt.Fprintln(os.Stderr, "error resolving address:", err)
		//os.Exit(1)
		return -100
	}

	useTransport := transportFactory.GetTransport(transport)
	client := common.NewRPCRequestGMIFaceClientFactory(useTransport, protocolFactory)
	if err := transport.Open(); err != nil {
		fmt.Fprintln(os.Stderr, "Error opening socket to server", " ", err)
		//os.Exit(1)
		return -101
	}
	defer transport.Close()

	cmd := gmcmd.Cmd + " " + g.Config().GetString("userId") + " " + gmcmd.Args
	//cmd := gmcmd.Cmd + " " + gmcmd.Args
	//fmt.Println("cmd==========================================",cmd)
	r1, e1 := client.IdipGm(gmcmd.Cmd, cmd)
	fmt.Println("Call->", r1, e1)
	return *r1.ResultCode
}

func (gmcmd *Gmcmd) Creatcdk() int32 {
	transportFactory := thrift.NewTTransportFactory()
	protocolFactory := thrift.NewTBinaryProtocolFactoryDefault()
	transport, err := thrift.NewTSocket(net.JoinHostPort(gmcmd.ServerIp, gmcmd.ServerPort))

	if err != nil {
		fmt.Fprintln(os.Stderr, "error resolving address:", err)
		//os.Exit(1)
		return -100
	}

	useTransport := transportFactory.GetTransport(transport)
	client := common.NewRPCRequestGMIFaceClientFactory(useTransport, protocolFactory)
	if err := transport.Open(); err != nil {
		fmt.Fprintln(os.Stderr, "Error opening socket to server", " ", err)
		//os.Exit(1)
		return -101
	}
	defer transport.Close()

	cmd := gmcmd.Cmd + " " + gmcmd.Args
	//fmt.Println("cmd==========================================",cmd)
	r1, e1 := client.IdipGm(gmcmd.Cmd, cmd)
	fmt.Println("Call->", r1, e1)
	return *r1.ResultCode
}