Create LICENSE

LICENSE

@@ -0,0 +1,29 @@
+BSD 3-Clause License
+
+Copyright (c) 2018, Golangltd
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+* Redistributions of source code must retain the above copyright notice, this
+  list of conditions and the following disclaimer.
+
+* Redistributions in binary form must reproduce the above copyright notice,
+  this list of conditions and the following disclaimer in the documentation
+  and/or other materials provided with the distribution.
+
+* Neither the name of the copyright holder nor the names of its
+  contributors may be used to endorse or promote products derived from
+  this software without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
+FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

LollipopGo/src/LollipopGo/DB_Server.go

@@ -0,0 +1,156 @@
+package main
+
+import (
+	"LollipopGo/LollipopGo/conf"
+	"LollipopGo/LollipopGo/log"
+	"LollipopGo/LollipopGo/player"
+	"LollipopGo/LollipopGo/util"
+	_ "LollipopGo/ReadCSV"
+	"LollipopGo/db/mysql"
+	"Proto"
+	"Proto/Proto2"
+	"fmt"
+	"net"
+	"net/rpc"
+	"net/rpc/jsonrpc"
+	"os"
+)
+
+// DB的数据的信息
+var (
+	service = "127.0.0.1:8890"
+)
+
+func init() {
+	arith := new(Arith)
+	rpc.Register(arith)
+	return
+}
+
+func checkError(err error) {
+	if err != nil {
+		fmt.Fprint(os.Stderr, "Usage: %s", err.Error())
+	}
+}
+
+// 监听操作
+func MainListener(strport string) {
+	arith := new(Arith)
+	rpc.Register(arith)
+	// 获取数据操作
+	tcpAddr, err := net.ResolveTCPAddr("tcp", ":"+strport)
+	checkError(err)
+
+	Listener, err := net.ListenTCP("tcp", tcpAddr)
+	checkError(err)
+
+	for {
+		conn, err := Listener.Accept()
+		if err != nil {
+			fmt.Fprint(os.Stderr, "accept err: %s", err.Error())
+			continue
+		}
+		go jsonrpc.ServeConn(conn)
+	}
+}
+
+// -----------------------------------------------------------------------------
+type Arith int
+
+// 登录结构 -- login server
+type Args struct {
+	A, B int
+}
+
+//------------------------------------------------------------------------------
+// 修改GM系统
+func (t *Arith) ModefyPlayerDataGM(args *Proto2.W2GMS_Modify_PlayerData, reply *Proto2.GMS2W_Modify_PlayerData) error {
+	//--------------------------------------------------------------------------
+	defer func() {
+		if err := recover(); err != nil {
+			strerr := fmt.Sprintf("%s", err)
+			//发消息给客户端
+			ErrorST := Proto2.G_Error_All{
+				Protocol:  Proto.G_Error_Proto,      // 主协议
+				Protocol2: Proto2.G_Error_All_Proto, // 子协议
+				ErrCode:   "80006",
+				ErrMsg:    "亲，您发的数据的格式不对！" + strerr,
+			}
+			fmt.Println("GM server 异常错误：", ErrorST)
+		}
+	}()
+	//--------------------------------------------------------------------------
+	uid := util.Str2int_LollipopGo(args.UID)
+	itype := util.Str2int_LollipopGo(args.Itype)
+	modifynum := util.Str2int_LollipopGo(args.ModifyNum)
+	//--------------------------------------------------------------------------
+	switch itype {
+	case Proto2.MODIFY_COIN, Proto2.MODIFY_LEV, Proto2.MODIFY_MASONRY,
+		Proto2.MODIFY_MCARD, Proto2.MODIFY_VIP_LEV:
+		bret := Mysyl_DB.DB.Modefy_PlayerDataGM(uid, itype, modifynum)
+		*reply = Proto2.GMS2W_Modify_PlayerData{
+			Protocol:  Proto.G_GameGM_Proto,
+			Protocol2: Proto2.GMS2W_Modify_PlayerDataProto2,
+			Isucc:     bret,
+		}
+	default:
+		log.Debug("数据类型不存在!")
+	}
+	//--------------------------------------------------------------------------
+	return nil
+}
+
+//------------------------------------------------------------------------------
+
+// 玩家用户保存
+func (t *Arith) SavePlayerST2DB(args *player.PlayerSt, reply *player.PlayerSt) error {
+	defer func() {
+		if err := recover(); err != nil {
+			strerr := fmt.Sprintf("%s", err)
+			//发消息给客户端
+			ErrorST := Proto2.G_Error_All{
+				Protocol:  Proto.G_Error_Proto,      // 主协议
+				Protocol2: Proto2.G_Error_All_Proto, // 子协议
+				ErrCode:   "80006",
+				ErrMsg:    "亲，您发的数据的格式不对！" + strerr,
+			}
+			fmt.Println("Global server 异常错误", ErrorST)
+		}
+	}()
+	// 1 解析数据 *reply = args.A * args.B
+	// roleUID := args.UID
+	// 2 保存或者更新数据
+	if Mysyl_DB.DB != nil {
+		_, data := Mysyl_DB.DB.InsertPlayerST2DB(args)
+		*reply = data
+	} else {
+	}
+	return nil
+}
+
+// 登录的时候，返回的数据
+func (t *Arith) Muliply(args *Args, reply *Proto2.GL2C_GameLogin) error {
+	// *reply = args.A * args.B
+	// 组装数据
+	data := &player.GateWayList{
+		ServerID:        1001,
+		ServerName:      "大厅服务器",
+		ServerIPAndPort: "gateway.a.babaliuliu.com:8888",
+		State:           "空闲",
+		OLPlayerNum:     1024,
+		MaxPlayerNum:    5000,
+	}
+	// 返回数据
+	*reply = Proto2.GL2C_GameLogin{
+		Protocol:   1,
+		Protocol2:  2,
+		Tocken:     "22222",
+		PlayerST:   nil,
+		GateWayST:  data,
+		GameList:   conf.G_GameList,
+		BannerList: conf.G_BannerList,
+	}
+	return nil
+}
+
+// -----------------------------------------------------------------------------