GetUserByToken方法增加返回内容

account.client.go

@@ -0,0 +1,819 @@
+package userrpc
+
+import (
+	"encoding/json"
+	"errors"
+	"log"
+)
+
+type GetAddReq struct {
+	Req
+	UserId   string
+	Value    string
+	Memo     string
+	Source   string
+	SourceId string
+}
+
+type GetUpdateReq struct {
+	Req
+	UserId    string
+	Value     string
+	UsedValue string
+}
+
+type GetLogReq struct {
+	Req
+	UserId       string
+	Value        string
+	Before       string
+	After        string
+	Source       string
+	SourceId     string
+	OrderSn      string
+	Target       string
+	TargetId     string
+	ProductThumb string
+	Memo         string
+}
+
+type GetUpgradeLogReq struct {
+	Req
+	UserId  string
+	Upgrade string
+	Before  string
+	After   string
+	Source  string
+	Memo    string
+}
+
+type GetCouponReq struct {
+	Req
+	UserId     string
+	CouponId   string
+	ExpireTime string
+	OrderSn    string
+	Remark     string
+	IsUse      string
+	Usertime   string
+}
+
+/**
+ * 获取用户积分
+ */
+func GetUserScore(dbname, userId string, url ...string) (string, error) {
+
+	if dbname == "" || userId == "" {
+		return "", errors.New("参数错误")
+	}
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return "", err
+	}
+	defer conn.Close()
+
+	data := GetUserReq{}
+	data.Dbname = dbname
+	data.UserId = userId
+
+	req, err := SetReqData(data)
+	if err != nil {
+		return "", err
+	}
+
+	res := &Response{}
+
+	err = conn.GetUserScore(req, res)
+
+	if err != nil {
+		return "", err
+	}
+
+	res_data_de, err := GetResData(res)
+	if err != nil {
+		return "", err
+	}
+	if res_data_de == "" {
+		return "", nil
+	}
+
+	var score string
+	err = json.Unmarshal([]byte(res_data_de), &score)
+
+	if err != nil {
+		return "", err
+	}
+
+	return score, nil
+}
+
+/**
+ * 获取用户红包
+ */
+func GetUserRedEnvelope(dbname, userId string, url ...string) (string, error) {
+
+	if dbname == "" || userId == "" {
+		return "", errors.New("参数错误")
+	}
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return "", err
+	}
+	defer conn.Close()
+
+	data := GetUserReq{}
+	data.Dbname = dbname
+	data.UserId = userId
+
+	req, err := SetReqData(data)
+	if err != nil {
+		return "", err
+	}
+
+	res := &Response{}
+
+	err = conn.GetUserRedEnvelope(req, res)
+
+	if err != nil {
+		return "", err
+	}
+
+	res_data_de, err := GetResData(res)
+	if err != nil {
+		return "", err
+	}
+	if res_data_de == "" {
+		return "", nil
+	}
+
+	var redEnvelope string
+	err = json.Unmarshal([]byte(res_data_de), &redEnvelope)
+
+	if err != nil {
+		return "", err
+	}
+
+	return redEnvelope, nil
+}
+
+/**
+ * 添加积分
+ * @2021/09/30
+ * @bin
+ */
+func AddUserScore(dbname, userId, score, memo string, url ...string) (int64, error) {
+	if dbname == "" || userId == "" || score == "" {
+		return 0, errors.New("参数错误")
+	}
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return 0, err
+	}
+	defer conn.Close()
+
+	data := GetAddReq{}
+	data.Dbname = dbname
+	data.UserId = userId
+	data.Value = score
+	data.Memo = memo
+
+	req, err := SetReqData(data)
+	if err != nil {
+		log.Println("AddUserScore crypter error:", err)
+		return 0, err
+	}
+
+	res := &Response{}
+
+	err = conn.AddUserScore(req, res)
+
+	if err != nil {
+		log.Println("userrpc AddUserScore error:", err)
+		return 0, err
+	}
+
+	res_data_de, err := GetResData(res)
+
+	if err != nil {
+		return 0, err
+	}
+
+	if res_data_de == "" {
+		return 0, nil
+	}
+
+	var insertId int64
+
+	err = json.Unmarshal([]byte(res_data_de), &insertId)
+
+	if err != nil {
+		return 0, err
+	}
+
+	return insertId, nil
+}
+
+/**
+ * 更新积分记录
+ * @2021/09/30
+ * @bin
+ */
+func UpdateUserScore(dbname, userId, score, used_score string, url ...string) (bool, error) {
+	if dbname == "" || userId == "" || score == "" {
+		return false, errors.New("参数错误")
+	}
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return false, err
+	}
+	defer conn.Close()
+
+	data := GetUpdateReq{}
+	data.Dbname = dbname
+	data.UserId = userId
+	data.Value = score
+	data.UsedValue = used_score
+
+	req, err := SetReqData(data)
+	if err != nil {
+		log.Println("UpdateUserScore crypter error:", err)
+		return false, err
+	}
+
+	res := &Response{}
+
+	err = conn.UpdateUserScore(req, res)
+
+	if err != nil {
+		log.Println("userrpc UpdateUserScore error:", err)
+		return false, err
+	}
+
+	res_data_de, err := GetResData(res)
+
+	if err != nil {
+		return false, err
+	}
+
+	if res_data_de == "" {
+		return false, nil
+	}
+
+	var updateres bool
+
+	err = json.Unmarshal([]byte(res_data_de), &updateres)
+
+	if err != nil {
+		return false, err
+	}
+
+	return updateres, nil
+}
+
+/**
+ * 增加积分日志
+ * @2021/09/30
+ * @bin
+ */
+func AddUserScoreLog(dbname, UserId, Score, Before, After, Source, SourceId, OrderSn, Target, TargetId, ProductThumb, Memo string, url ...string) (int64, error) {
+	if dbname == "" || UserId == "" || Score == "" || After == "" {
+		return 0, errors.New("参数错误")
+	}
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return 0, err
+	}
+	defer conn.Close()
+
+	data := GetLogReq{}
+	data.Dbname = dbname
+	data.UserId = UserId
+	data.Value = Score
+	data.Before = Before
+	data.After = After
+	data.Source = Source
+	data.SourceId = SourceId
+	data.OrderSn = OrderSn
+	data.Target = Target
+	data.TargetId = TargetId
+	data.ProductThumb = ProductThumb
+	data.Memo = Memo
+
+	req, err := SetReqData(data)
+	if err != nil {
+		log.Println("AddUserScoreLog crypter error:", err)
+		return 0, err
+	}
+
+	res := &Response{}
+
+	err = conn.AddUserScoreLog(req, res)
+
+	if err != nil {
+		log.Println("userrpc AddUserScoreLog error:", err)
+		return 0, err
+	}
+
+	res_data_de, err := GetResData(res)
+
+	if err != nil {
+		return 0, err
+	}
+
+	if res_data_de == "" {
+		return 0, nil
+	}
+
+	var insertId int64
+
+	err = json.Unmarshal([]byte(res_data_de), &insertId)
+
+	if err != nil {
+		return 0, err
+	}
+
+	return insertId, nil
+}
+
+/**
+ * 添加成长值
+ * @2021/09/30
+ * @bin
+ */
+func AddUserUpgrade(dbname, userId, upgrade, memo string, url ...string) (int64, error) {
+	if dbname == "" || userId == "" || upgrade == "" {
+		return 0, errors.New("参数错误")
+	}
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return 0, err
+	}
+	defer conn.Close()
+
+	data := GetAddReq{}
+	data.Dbname = dbname
+	data.UserId = userId
+	data.Value = upgrade
+	data.Memo = memo
+
+	req, err := SetReqData(data)
+	if err != nil {
+		log.Println("AddUserUpgrade crypter error:", err)
+		return 0, err
+	}
+
+	res := &Response{}
+
+	err = conn.AddUserUpgrade(req, res)
+
+	if err != nil {
+		log.Println("userrpc AddUserUpgrade error:", err)
+		return 0, err
+	}
+
+	res_data_de, err := GetResData(res)
+
+	if err != nil {
+		return 0, err
+	}
+
+	if res_data_de == "" {
+		return 0, nil
+	}
+
+	var insertId int64
+
+	err = json.Unmarshal([]byte(res_data_de), &insertId)
+
+	if err != nil {
+		return 0, err
+	}
+
+	return insertId, nil
+}
+
+/**
+ * 更新成长值记录
+ * @2021/09/30
+ * @bin
+ */
+func UpdateUserUpgrade(dbname, userId, upgrade string, url ...string) (bool, error) {
+	if dbname == "" || userId == "" || upgrade == "" {
+		return false, errors.New("参数错误")
+	}
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return false, err
+	}
+	defer conn.Close()
+
+	data := GetAddReq{}
+	data.Dbname = dbname
+	data.UserId = userId
+	data.Value = upgrade
+
+	req, err := SetReqData(data)
+	if err != nil {
+		log.Println("UpdateUserUpgrade crypter error:", err)
+		return false, err
+	}
+
+	res := &Response{}
+
+	err = conn.UpdateUserUpgrade(req, res)
+
+	if err != nil {
+		log.Println("userrpc UpdateUserUpgrade error:", err)
+		return false, err
+	}
+
+	res_data_de, err := GetResData(res)
+
+	if err != nil {
+		return false, err
+	}
+
+	if res_data_de == "" {
+		return false, nil
+	}
+
+	var updateres bool
+
+	err = json.Unmarshal([]byte(res_data_de), &updateres)
+
+	if err != nil {
+		return false, err
+	}
+
+	return updateres, nil
+}
+
+/**
+ * 增加成长值日志
+ * @2021/09/30
+ * @bin
+ */
+func AddUserUpgradeLog(dbname, UserId, Upgrade, Before, After, Source, Memo string, url ...string) (int64, error) {
+	if dbname == "" || UserId == "" || Upgrade == "" || After == "" {
+		return 0, errors.New("参数错误")
+	}
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return 0, err
+	}
+	defer conn.Close()
+
+	data := GetUpgradeLogReq{}
+	data.Dbname = dbname
+	data.UserId = UserId
+	data.Upgrade = Upgrade
+	data.Before = Before
+	data.After = After
+	data.Source = Source
+	data.Memo = Memo
+
+	req, err := SetReqData(data)
+	if err != nil {
+		log.Println("AddUserUpgradeLog crypter error:", err)
+		return 0, err
+	}
+
+	res := &Response{}
+
+	err = conn.AddUserUpgradeLog(req, res)
+
+	if err != nil {
+		log.Println("userrpc AddUserUpgradeLog error:", err)
+		return 0, err
+	}
+
+	res_data_de, err := GetResData(res)
+
+	if err != nil {
+		return 0, err
+	}
+
+	if res_data_de == "" {
+		return 0, nil
+	}
+
+	var insertId int64
+
+	err = json.Unmarshal([]byte(res_data_de), &insertId)
+
+	if err != nil {
+		return 0, err
+	}
+
+	return insertId, nil
+}
+
+/**
+ * 添加红包
+ * @2021/09/30
+ * @bin
+ */
+func AddUserRedEnvelope(dbname, userId, money, memo string, url ...string) (int64, error) {
+	if dbname == "" || userId == "" || money == "" {
+		return 0, errors.New("参数错误")
+	}
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return 0, err
+	}
+	defer conn.Close()
+
+	data := GetAddReq{}
+	data.Dbname = dbname
+	data.UserId = userId
+	data.Value = money
+	data.Memo = memo
+
+	req, err := SetReqData(data)
+	if err != nil {
+		log.Println("AddUserRedEnvelope crypter error:", err)
+		return 0, err
+	}
+
+	res := &Response{}
+
+	err = conn.AddUserRedEnvelope(req, res)
+
+	if err != nil {
+		log.Println("userrpc AddUserRedEnvelope error:", err)
+		return 0, err
+	}
+
+	res_data_de, err := GetResData(res)
+
+	if err != nil {
+		return 0, err
+	}
+
+	if res_data_de == "" {
+		return 0, nil
+	}
+
+	var insertId int64
+
+	err = json.Unmarshal([]byte(res_data_de), &insertId)
+
+	if err != nil {
+		return 0, err
+	}
+
+	return insertId, nil
+}
+
+/**
+ * 更新红包记录
+ * @2021/09/30
+ * @bin
+ */
+func UpdateUserRedEnvelope(dbname, userId, money, used_money string, url ...string) (bool, error) {
+	if dbname == "" || userId == "" || money == "" {
+		return false, errors.New("参数错误")
+	}
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return false, err
+	}
+	defer conn.Close()
+
+	data := GetUpdateReq{}
+	data.Dbname = dbname
+	data.UserId = userId
+	data.Value = money
+	data.UsedValue = used_money
+
+	req, err := SetReqData(data)
+	if err != nil {
+		log.Println("UpdateUserRedEnvelope crypter error:", err)
+		return false, err
+	}
+
+	res := &Response{}
+
+	err = conn.UpdateUserRedEnvelope(req, res)
+
+	if err != nil {
+		log.Println("userrpc UpdateUserRedEnvelope error:", err)
+		return false, err
+	}
+
+	res_data_de, err := GetResData(res)
+
+	if err != nil {
+		return false, err
+	}
+
+	if res_data_de == "" {
+		return false, nil
+	}
+
+	var updateres bool
+
+	err = json.Unmarshal([]byte(res_data_de), &updateres)
+
+	if err != nil {
+		return false, err
+	}
+
+	return updateres, nil
+}
+
+/**
+ * 增加红包日志
+ * @2021/09/30
+ * @bin
+ */
+func AddUserRedEnvelopeLog(dbname, UserId, Money, Before, After, Source, SourceId, OrderSn, Target, TargetId, Memo string, url ...string) (int64, error) {
+	if dbname == "" || UserId == "" || Money == "" || After == "" {
+		return 0, errors.New("参数错误")
+	}
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return 0, err
+	}
+	defer conn.Close()
+
+	data := GetLogReq{}
+	data.Dbname = dbname
+	data.UserId = UserId
+	data.Value = Money
+	data.Before = Before
+	data.After = After
+	data.Source = Source
+	data.SourceId = SourceId
+	data.OrderSn = OrderSn
+	data.Target = Target
+	data.TargetId = TargetId
+	data.Memo = Memo
+
+	req, err := SetReqData(data)
+	if err != nil {
+		log.Println("AddUserRedEnvelopeLog crypter error:", err)
+		return 0, err
+	}
+
+	res := &Response{}
+
+	err = conn.AddUserRedEnvelopeLog(req, res)
+
+	if err != nil {
+		log.Println("userrpc AddUserRedEnvelopeLog error:", err)
+		return 0, err
+	}
+
+	res_data_de, err := GetResData(res)
+
+	if err != nil {
+		return 0, err
+	}
+
+	if res_data_de == "" {
+		return 0, nil
+	}
+
+	var insertId int64
+
+	err = json.Unmarshal([]byte(res_data_de), &insertId)
+
+	if err != nil {
+		return 0, err
+	}
+
+	return insertId, nil
+}
+
+/**
+ * 添加优惠券
+ * @2021/09/30
+ * @bin
+ */
+func AddUserCoupon(dbname, userId, couponId, expireTime, orderSn, remark string, url ...string) (int64, error) {
+	if dbname == "" || userId == "" || couponId == "" {
+		return 0, errors.New("参数错误")
+	}
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return 0, err
+	}
+	defer conn.Close()
+
+	data := GetCouponReq{}
+	data.Dbname = dbname
+	data.UserId = userId
+	data.CouponId = couponId
+	data.ExpireTime = expireTime
+	data.OrderSn = orderSn
+	data.Remark = remark
+
+	req, err := SetReqData(data)
+	if err != nil {
+		log.Println("AddUserCoupon crypter error:", err)
+		return 0, err
+	}
+
+	res := &Response{}
+
+	err = conn.AddUserCoupon(req, res)
+
+	if err != nil {
+		log.Println("userrpc AddUserCoupon error:", err)
+		return 0, err
+	}
+
+	res_data_de, err := GetResData(res)
+
+	if err != nil {
+		return 0, err
+	}
+
+	if res_data_de == "" {
+		return 0, nil
+	}
+
+	var insertId int64
+
+	err = json.Unmarshal([]byte(res_data_de), &insertId)
+
+	if err != nil {
+		return 0, err
+	}
+
+	return insertId, nil
+}
+
+/**
+ * 更新优惠券记录
+ * @2021/09/30
+ * @bin
+ */
+func UpdateUserCoupon(dbname, userId, couponId, remark, orderSn, isUse, usetime string, url ...string) (bool, error) {
+	if dbname == "" || userId == "" || couponId == "" {
+		return false, errors.New("参数错误")
+	}
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return false, err
+	}
+	defer conn.Close()
+
+	data := GetCouponReq{}
+	data.Dbname = dbname
+	data.UserId = userId
+	data.CouponId = couponId
+	data.Remark = remark
+	data.OrderSn = orderSn
+	data.IsUse = isUse
+	data.Usertime = usetime
+
+	req, err := SetReqData(data)
+	if err != nil {
+		log.Println("UpdateUserCoupon crypter error:", err)
+		return false, err
+	}
+
+	res := &Response{}
+
+	err = conn.UpdateUserCoupon(req, res)
+
+	if err != nil {
+		log.Println("userrpc UpdateUserCoupon error:", err)
+		return false, err
+	}
+
+	res_data_de, err := GetResData(res)
+
+	if err != nil {
+		return false, err
+	}
+
+	if res_data_de == "" {
+		return false, nil
+	}
+
+	var updateres bool
+
+	err = json.Unmarshal([]byte(res_data_de), &updateres)
+
+	if err != nil {
+		return false, err
+	}
+
+	return updateres, nil
+}

account.client_test.go

@@ -0,0 +1,168 @@
+package userrpc
+
+import (
+    "strconv"
+    "testing"
+    "time"
+)
+
+func Test_GetUserScore(t *testing.T) {
+
+    dbname := "shop_v2_org"
+    id := "2"
+
+    ret, err := GetUserScore(dbname, id)
+    t.Log(ret)
+    t.Log(err)
+}
+
+func Test_GetUserRedEnvelope(t *testing.T) {
+
+    dbname := "shop_v2_org"
+    id := "2"
+
+    ret, err := GetUserRedEnvelope(dbname, id)
+    t.Log(ret)
+    t.Log(err)
+}
+
+func Test_AddUserScore(t *testing.T) {
+    dbname := "shop_v2_org"
+    userid := "2"
+    score := "20"
+
+    ret, err := AddUserScore(dbname, userid, score,"")
+    t.Log(ret)
+    t.Log(err)
+}
+
+func Test_UpdateUserScore(t *testing.T) {
+    dbname := "shop_v2_org"
+    userid := "2"
+    score := "400"
+    used_score := "300"
+
+    ret, err := UpdateUserScore(dbname, userid, score, used_score)
+    t.Log(ret)
+    t.Log(err)
+}
+
+func Test_AddUserScoreLog(t *testing.T) {
+    dbname := "shop_v2_org"
+    userid := "2"
+    score := "100"
+    before := "500"
+    after := "400"
+    Source := "task"
+    SourceId := ""
+    OrderSn := ""
+    Target := ""
+    TargetId := ""
+    ProductThumb := ""
+    Memo := ""
+
+    ret, err := AddUserScoreLog(dbname, userid, score, before, after, Source, SourceId, OrderSn, Target, TargetId, ProductThumb, Memo)
+    t.Log(ret)
+    t.Log(err)
+}
+
+func Test_AddUserUpgrade(t *testing.T) {
+    dbname := "shop_v2_org"
+    userid := "5"
+    upgrade := "100"
+
+    ret, err := AddUserUpgrade(dbname, userid, upgrade,"")
+    t.Log(ret)
+    t.Log(err)
+}
+
+func Test_UpdateUserUpgrade(t *testing.T) {
+    dbname := "shop_v2_org"
+    userid := "5"
+    upgrade := "100"
+
+    ret, err := UpdateUserUpgrade(dbname, userid, upgrade)
+    t.Log(ret)
+    t.Log(err)
+}
+
+func Test_AddUserUpgradeLog(t *testing.T) {
+    dbname := "shop_v2_org"
+    userid := "2"
+    upgrade := "20"
+    before := "11"
+    after := "31"
+    Source := "task"
+    Memo := ""
+
+    ret, err := AddUserUpgradeLog(dbname, userid, upgrade, before, after, Source, Memo)
+    t.Log(ret)
+    t.Log(err)
+}
+
+func Test_AddUserRedEnvelope(t *testing.T) {
+    dbname := "shop_v2_org"
+    userid := "5"
+    money := "20"
+
+    ret, err := AddUserRedEnvelope(dbname, userid, money,"")
+    t.Log(ret)
+    t.Log(err)
+}
+
+func Test_UpdateUserRedEnvelope(t *testing.T) {
+    dbname := "shop_v2_org"
+    userid := "2"
+    money := "40"
+    used_money := "1"
+
+    ret, err := UpdateUserRedEnvelope(dbname, userid, money, used_money)
+    t.Log(ret)
+    t.Log(err)
+}
+
+func Test_AddUserRedEnvelopeLog(t *testing.T) {
+    dbname := "shop_v2_org"
+    userid := "2"
+    money := "-1"
+    before := "41"
+    after := "40"
+    Source := "task"
+    SourceId := ""
+    OrderSn := "216304042479173922"
+    Target := ""
+    TargetId := ""
+    ProductThumb := ""
+    Memo := ""
+
+    ret, err := AddUserRedEnvelopeLog(dbname, userid, money, before, after, Source, SourceId, OrderSn, Target, TargetId, ProductThumb, Memo)
+    t.Log(ret)
+    t.Log(err)
+}
+
+func Test_AddUserCoupon(t *testing.T) {
+    dbname := "shop_v2_org"
+    userid := "2"
+    couponId := "6"
+    expired_time := "1634684122"
+    order_sn := ""
+    remark := "商品券"
+
+    ret, err := AddUserCoupon(dbname, userid, couponId, expired_time,order_sn,remark)
+    t.Log(ret)
+    t.Log(err)
+}
+
+func Test_UpdateUserCoupon(t *testing.T) {
+    dbname := "shop_v2_org"
+    userid := "2"
+    couponId := "6"
+    remark := "下单使用优惠券"
+    orderSn := "12345678910"
+    isUse := "1"
+    usetime := strconv.Itoa(int(time.Now().Unix()))
+
+    ret, err := UpdateUserCoupon(dbname, userid, couponId, remark, orderSn, isUse,usetime)
+    t.Log(ret)
+    t.Log(err)
+}

address.client.go

@@ -0,0 +1,54 @@
+package userrpc
+
+import (
+	"encoding/json"
+	"errors"
+)
+
+func GetAddressInfo(site_id, dbname, address_id string, url ...string) (map[string]string, error) {
+
+	if dbname == "" || address_id == "" {
+		return nil, errors.New("参数错误")
+	}
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return nil, err
+	}
+	defer conn.Close()
+
+	data := GetAddressReq{}
+	data.SiteId = site_id
+	data.Dbname = dbname
+	data.AddressId = address_id
+
+	req, err := SetReqData(data)
+	if err != nil {
+		return nil, err
+	}
+
+	res := &Response{}
+
+	err = conn.GetAddressInfo(req, res)
+
+	if err != nil {
+		return nil, err
+	}
+
+	res_data_de, err := GetResData(res)
+	if err != nil {
+		return nil, err
+	}
+	if res_data_de == "" {
+		return nil, nil
+	}
+	var res_arr map[string]string
+
+	err = json.Unmarshal([]byte(res_data_de), &res_arr)
+
+	if err != nil {
+		return nil, err
+	}
+	return res_arr, nil
+
+}

address.client_test.go

@@ -0,0 +1,16 @@
+package userrpc
+
+import (
+	"testing"
+)
+
+func Test_GetAddressInfo(t *testing.T) {
+
+	site_id := ""
+	dbname := "shop_v2"
+	id := "2"
+
+	ret, err := GetAddressInfo(site_id, dbname, id)
+	t.Log(ret)
+	t.Log(err)
+}

business.client.go

@@ -0,0 +1,150 @@
+package userrpc
+
+import (
+	"encoding/json"
+	"errors"
+	"strconv"
+	"time"
+
+	"git.tetele.net/tgo/crypter"
+	"github.com/golang/protobuf/proto"
+)
+
+/**
+ * 查找商户信息
+ * 2021/04/06
+ * gz
+ */
+func GetBusiness(site_id, dbname, business_id string, url ...string) (*Business, error) {
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return nil, err
+	}
+	defer conn.Close()
+
+	data := GetBusinessReq{}
+	data.SiteId = site_id
+	data.Dbname = dbname
+	data.BusinessId = business_id
+
+	data_json, err := json.Marshal(data)
+	if err != nil {
+		return nil, err
+	}
+
+	encryData := crypter.DesEn(string(data_json), DES_KEY)
+
+	now_int64 := time.Now().Unix()
+
+	now := strconv.FormatInt(now_int64, 10)
+
+	sign := Sign(encryData, now)
+
+	req := &Request{
+		proto.String(encryData),
+		proto.String(now),
+		proto.String(sign),
+		nil}
+
+	res := &Response{}
+
+	err = conn.GetBusiness(req, res)
+
+	if err != nil {
+		return nil, err
+	}
+
+	return HandleGetBusinessRes(res)
+}
+
+/**
+ * 处理返回结果
+ */
+func HandleGetBusinessRes(res *Response) (*Business, error) {
+
+	res_data := res.GetData()
+
+	if res_data == "" {
+
+		return nil, errors.New("未收到收据")
+	}
+
+	time_int64, err := strconv.ParseInt(res.GetTime(), 10, 64)
+	if err != nil {
+		return nil, err
+	}
+
+	now_int64 := time.Now().Unix()
+
+	if now_int64-time_int64 > 10 || time_int64-now_int64 > 10 {
+		//时间误差前后10秒，返回
+		return nil, errors.New("返回时间错误")
+	}
+
+	check_sign := CheckSign(res.GetSign(), res_data, res.GetTime())
+	if !check_sign {
+		return nil, errors.New("返回数据签名错误")
+	}
+
+	//解密
+	res_data_de := crypter.DesDe(res_data, DES_KEY)
+
+	var res_arr Business
+
+	err = json.Unmarshal([]byte(res_data_de), &res_arr)
+
+	if err != nil {
+		return nil, err
+	}
+
+	return &res_arr, nil
+}
+
+func GetBusinessInfo(site_id, dbname, id string, url ...string) (map[string]string, error) {
+
+	if dbname == "" || id == "" {
+		return nil, errors.New("参数错误")
+	}
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return nil, err
+	}
+	defer conn.Close()
+
+	data := GetBusinessReq{}
+	data.SiteId = site_id
+	data.Dbname = dbname
+	data.BusinessId = id
+
+	req, err := SetReqData(data)
+	if err != nil {
+		return nil, err
+	}
+
+	res := &Response{}
+
+	err = conn.GetBusinessInfo(req, res)
+
+	if err != nil {
+		return nil, err
+	}
+
+	res_data_de, err := GetResData(res)
+	if err != nil {
+		return nil, err
+	}
+	if res_data_de == "" {
+		return nil, nil
+	}
+	var res_arr map[string]string
+
+	err = json.Unmarshal([]byte(res_data_de), &res_arr)
+
+	if err != nil {
+		return nil, err
+	}
+	return res_arr, nil
+
+}

business.client_test.go

@@ -0,0 +1,16 @@
+package userrpc
+
+import (
+	"testing"
+)
+
+func Test_GetBusinessInfo(t *testing.T) {
+
+	site_id := ""
+	dbname := "shop_v2"
+	id := "5"
+
+	ret, err := GetBusinessInfo(site_id, dbname, id)
+	t.Log(ret)
+	t.Log(err)
+}

common.go

@@ -1,5 +1,9 @@
 package userrpc
 
+import (
+	"git.tetele.net/tgo/conf"
+)
+
 const DES_KEY = "usersrpc"
 
 type Req struct {
@@ -7,8 +11,7 @@ type Req struct {
 	Dbname string
 }
 
-type BindThirdReq struct {
-	Req
+type Third struct {
 	Userid   string
 	Platform string
 	Openid   string
@@ -18,19 +21,67 @@ type BindThirdReq struct {
 	Mobile   string
 }
 
+type BindThirdReq struct {
+	Req
+	Third
+}
+
+type GetThirdReq struct {
+	Req
+	Userid   string
+	Platform string
+}
+
+type GetBusinessReq struct {
+	Req
+	BusinessId string
+}
+
+type GetUserReq struct {
+	Req
+	UserId string
+}
+
+type GetAddressReq struct {
+	Req
+	AddressId string
+}
 type Res struct {
 	Errcode int
 	Errmsg  string
 }
 
+type Business struct {
+	Type       string
+	BusinessId string
+	CustomerId string
+	Name       string
+	CompanyId  string
+	Contact    string
+	Mobile     string
+	HandingFee string
+	IsOpen     string
+}
+
+type FansReq struct {
+	Req
+	UserId     string
+	BusinessId string
+	Lock       bool
+}
+
 func rpc_server_conn(url ...string) (*UserServiceClient, error) {
 
-	var user_rpc_url string = "127.0.0.1:7976"
+	var rpc_url string
 	if len(url) > 0 && url[0] != "" {
-		user_rpc_url = url[0]
+		rpc_url = url[0]
+	} else if conf.USER_RPC_URL != "" {
+		rpc_url = conf.USER_RPC_URL
+	} else {
+		rpc_url = "127.0.0.1:" + conf.USER_RPC_PORT
 	}
 
-	conn, _, err := DialUserService("tcp", user_rpc_url)
+	conn, _, err := DialUserService("tcp", rpc_url)
 	if err != nil {
 		return nil, err
 	}

data.go

@@ -0,0 +1,106 @@
+package userrpc
+
+import (
+	"encoding/json"
+	"errors"
+	"strconv"
+	"time"
+
+	"git.tetele.net/tgo/crypter"
+	"github.com/golang/protobuf/proto"
+)
+
+func SetResData(data interface{}, res *Response) {
+	res_data_json, err := json.Marshal(data)
+	if err == nil {
+
+		encryData := crypter.DesEn(string(res_data_json), DES_KEY)
+
+		now_str := strconv.FormatInt(time.Now().Unix(), 10)
+
+		res_sign := Sign(encryData, now_str)
+
+		res.Data = proto.String(encryData)
+		res.Time = proto.String(now_str)
+		res.Sign = proto.String(res_sign)
+	}
+
+}
+
+func SetReqData(arg interface{}) (*Request, error) {
+	data_json, err := json.Marshal(arg)
+	if err != nil {
+		return nil, err
+	}
+
+	now_int64 := time.Now().Unix()
+
+	encryData := crypter.DesEn(string(data_json), DES_KEY)
+
+	now := strconv.FormatInt(now_int64, 10)
+
+	sign := Sign(encryData, now)
+
+	return &Request{proto.String(encryData), proto.String(now), proto.String(sign), nil}, nil
+
+}
+
+func GetReqData(req *Request) (string, error) {
+	res_data := req.GetData()
+
+	if res_data != "" {
+
+		time_int64, err := strconv.ParseInt(req.GetTime(), 10, 64)
+		if err != nil {
+			return "", err
+		}
+
+		now_int64 := time.Now().Unix()
+
+		if now_int64-time_int64 > 10 || time_int64-now_int64 > 10 {
+			//时间误差前后10秒，返回
+			return "", errors.New("返回时间错误")
+		}
+
+		check_sign := CheckSign(req.GetSign(), res_data, req.GetTime())
+		if !check_sign {
+			return "", errors.New("返回数据签名错误")
+		}
+
+		//解密
+		return crypter.DesDe(res_data, DES_KEY), nil
+
+	}
+
+	return "", nil
+}
+
+func GetResData(res *Response) (string, error) {
+	res_data := res.GetData()
+
+	if res_data != "" {
+
+		time_int64, err := strconv.ParseInt(res.GetTime(), 10, 64)
+		if err != nil {
+			return "", err
+		}
+
+		now_int64 := time.Now().Unix()
+
+		if now_int64-time_int64 > 10 || time_int64-now_int64 > 10 {
+			//时间误差前后10秒，返回
+			return "", errors.New("返回时间错误")
+		}
+
+		check_sign := CheckSign(res.GetSign(), res_data, res.GetTime())
+		if !check_sign {
+			return "", errors.New("返回数据签名错误")
+		}
+
+		//解密
+		return crypter.DesDe(res_data, DES_KEY), nil
+
+	}
+
+	return "", nil
+}

fans.client.go

@@ -0,0 +1,75 @@
+package userrpc
+
+/**
+ * 绑定粉丝
+ * 2021/10/23
+ * gz
+ */
+func Fans(site_id, dbname, user_id, business_id string, url ...string) error {
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return err
+	}
+	defer conn.Close()
+
+	data := FansReq{}
+	data.SiteId = site_id
+	data.Dbname = dbname
+	data.UserId = user_id
+	data.BusinessId = business_id
+	data.Lock = false
+
+	req, err := SetReqData(data)
+	if err != nil {
+		return err
+	}
+
+	res := &Response{}
+
+	err = conn.Fans(req, res)
+
+	if err != nil {
+		return err
+	}
+
+	_, err = GetResData(res)
+	return nil
+}
+
+/**
+ * 绑定粉丝
+ * 2021/10/23
+ * gz
+ */
+func LockFans(site_id, dbname, user_id, business_id string, url ...string) error {
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return err
+	}
+	defer conn.Close()
+
+	data := FansReq{}
+	data.SiteId = site_id
+	data.Dbname = dbname
+	data.UserId = user_id
+	data.BusinessId = business_id
+	data.Lock = true
+
+	req, err := SetReqData(data)
+	if err != nil {
+		return err
+	}
+
+	res := &Response{}
+
+	err = conn.Fans(req, res)
+
+	if err != nil {
+		return err
+	}
+
+	_, err = GetResData(res)
+	return nil
+}

fans.client_test.go

@@ -0,0 +1,16 @@
+package userrpc
+
+import (
+	"testing"
+)
+
+func Test_Fans(t *testing.T) {
+
+	dbname := "shop_v2"
+	user_id := "6"
+	business_id := "5"
+
+	err := LockFans("", dbname, user_id, business_id)
+
+	t.Log(err)
+}

go.mod

@@ -3,8 +3,9 @@ module git.tetele.net/tgo/userrpc
 go 1.14
 
 require (
-	git.tetele.net/tgo/crypter v0.2.2 // indirect
-	github.com/chai2010/protorpc v1.0.0
+	git.tetele.net/tgo/conf v0.46.0
+	git.tetele.net/tgo/crypter v0.2.2
+	github.com/chai2010/protorpc v1.1.3
 	github.com/golang/protobuf v1.0.0
 	golang.org/x/crypto v0.0.0-20210322153248-0c34fe9e7dc2 // indirect
 	golang.org/x/sync v0.0.0-20210220032951-036812b2e83c // indirect

go.sum

@@ -1,11 +1,15 @@
+git.tetele.net/tgo/conf v0.46.0/go.mod h1:AWVIBEDE5dtotthUgR0SWaR2Qa6/f+O5WQ3s7Tj8q7A=
 git.tetele.net/tgo/crypter v0.2.2 h1:YMQJh2Gj5Po4ZfelJUmXBKi01UbmtiSy3bmqRfnYQMo=
 git.tetele.net/tgo/crypter v0.2.2/go.mod h1:vfvRLZA8+lHNgNXneOcgvVhDyuv25ZRb+C6xHOmXNx0=
-github.com/chai2010/protorpc v1.0.0 h1:aJ45G9sl1utSKo35EqnBSTs5jqTpdJDJAuZMMYPAtFo=
-github.com/chai2010/protorpc v1.0.0/go.mod h1:woR3WwjaQDqFjlzdVsFEKiK5Ur12QL8mYxVPjfr5z54=
+git.tetele.net/yueheng/conf v0.33.1 h1:ZEIv3Vq35RCv5f3T3Uz97s2mkZLl7W5OlmXvzI3/sS8=
+git.tetele.net/yueheng/conf v0.33.1/go.mod h1:AWVIBEDE5dtotthUgR0SWaR2Qa6/f+O5WQ3s7Tj8q7A=
+git.tetele.net/yueheng/conf v1.2.6/go.mod h1:qRujMTqjMByvdC05qdfscZMFRKM5XA1qbtz4rnFyStY=
+github.com/chai2010/protorpc v1.1.3 h1:VJK5hIoZn0XCGol0GmbxZkUG6FbTI5LP2Lam6RVd15w=
+github.com/chai2010/protorpc v1.1.3/go.mod h1:/wO0kiyVdu7ug8dCMrA2yDr2vLfyhsLEuzLa9J2HJ+I=
 github.com/golang/protobuf v1.0.0 h1:lsek0oXi8iFE9L+EXARyHIjU5rlWIhhTkjDz3vHhWWQ=
 github.com/golang/protobuf v1.0.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
-github.com/golang/snappy v0.0.0-20170215233205-553a64147049 h1:K9KHZbXKpGydfDN0aZrsoHpLJlZsBrGMFWbgLDGnPZk=
-github.com/golang/snappy v0.0.0-20170215233205-553a64147049/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
+github.com/golang/snappy v0.0.3 h1:fHPg5GQYlCeLIPB9BZqMVR5nR9A+IM5zcgeTdjMYmLA=
+github.com/golang/snappy v0.0.3/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
 golang.org/x/crypto v0.0.0-20210322153248-0c34fe9e7dc2 h1:It14KIkyBFYkHkwZ7k45minvA9aorojkyjGk9KJ5B/w=
 golang.org/x/crypto v0.0.0-20210322153248-0c34fe9e7dc2/go.mod h1:T9bdIzuCu7OtxOm1hfPfRQxPLYneinmdGuTeoZ9dtd4=
 golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg=

sign.go

@@ -84,3 +84,46 @@ func HandleRes(res *Response) (*Res, error) {
 
 	return &res_arr, nil
 }
+
+/**
+ * 处理返回结果
+ */
+func HandleUserRes(res *Response) (map[string]string, error) {
+
+	res_data := res.GetData()
+
+	if res_data == "" {
+
+		return nil, errors.New("未收到收据")
+	}
+
+	time_int64, err := strconv.ParseInt(res.GetTime(), 10, 64)
+	if err != nil {
+		return nil, err
+	}
+
+	now_int64 := time.Now().Unix()
+
+	if now_int64-time_int64 > 10 || time_int64-now_int64 > 10 {
+		//时间误差前后10秒，返回
+		return nil, errors.New("返回时间错误")
+	}
+
+	check_sign := CheckSign(res.GetSign(), res_data, res.GetTime())
+	if !check_sign {
+		return nil, errors.New("返回数据签名错误")
+	}
+
+	//解密
+	res_data_de := crypter.DesDe(res_data, DES_KEY)
+
+	var res_arr map[string]string
+
+	err = json.Unmarshal([]byte(res_data_de), &res_arr)
+
+	if err != nil {
+		return nil, err
+	}
+
+	return res_arr, nil
+}

third.client.go

@@ -2,6 +2,7 @@ package userrpc
 
 import (
 	"encoding/json"
+	"errors"
 	"strconv"
 	"time"
 
@@ -62,3 +63,95 @@ func BindThird(site_id, dbname, platform, user_id, openid, openname, unionid, av
 
 	return HandleRes(res)
 }
+
+/**
+ * 查找第三方平台openid
+ * 2021/04/06
+ * gz
+ */
+func GetThird(site_id, dbname, platform, user_id string, url ...string) (*Third, error) {
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return nil, err
+	}
+	defer conn.Close()
+
+	data := GetThirdReq{}
+	data.SiteId = site_id
+	data.Dbname = dbname
+	data.Platform = platform
+	data.Userid = user_id
+
+	data_json, err := json.Marshal(data)
+	if err != nil {
+		return nil, err
+	}
+
+	encryData := crypter.DesEn(string(data_json), DES_KEY)
+
+	now_int64 := time.Now().Unix()
+
+	now := strconv.FormatInt(now_int64, 10)
+
+	sign := Sign(encryData, now)
+
+	req := &Request{
+		proto.String(encryData),
+		proto.String(now),
+		proto.String(sign),
+		nil}
+
+	res := &Response{}
+
+	err = conn.GetThird(req, res)
+
+	if err != nil {
+		return nil, err
+	}
+
+	return HandleGetThirdRes(res)
+}
+
+/**
+ * 处理返回结果
+ */
+func HandleGetThirdRes(res *Response) (*Third, error) {
+
+	res_data := res.GetData()
+
+	if res_data == "" {
+
+		return nil, errors.New("未收到收据")
+	}
+
+	time_int64, err := strconv.ParseInt(res.GetTime(), 10, 64)
+	if err != nil {
+		return nil, err
+	}
+
+	now_int64 := time.Now().Unix()
+
+	if now_int64-time_int64 > 10 || time_int64-now_int64 > 10 {
+		//时间误差前后10秒，返回
+		return nil, errors.New("返回时间错误")
+	}
+
+	check_sign := CheckSign(res.GetSign(), res_data, res.GetTime())
+	if !check_sign {
+		return nil, errors.New("返回数据签名错误")
+	}
+
+	//解密
+	res_data_de := crypter.DesDe(res_data, DES_KEY)
+
+	var res_arr Third
+
+	err = json.Unmarshal([]byte(res_data_de), &res_arr)
+
+	if err != nil {
+		return nil, err
+	}
+
+	return &res_arr, nil
+}

third.client_test.go

@@ -2,18 +2,27 @@ package userrpc
 
 import (
 	"testing"
+
+	"git.tetele.net/tgo/crypter"
 )
 
 func Test_BindThird(t *testing.T) {
-	dbname := "test1_tetele_com"
-	site_id := "1001"
-	platform := "deliver_mini"
-	user_id := "1"
-	openid := "CasfoieFsdfsdfiDiodf_df"
-	openname := "测试中"
-	avatar := "https://ssss.ttt.ddd/sfsd"
-	res, err := BindThird(site_id, dbname, platform, user_id, openid, openname, "", avatar)
-	t.Log(res)
-	t.Log(err)
+	// dbname := "test1_tetele_com"
+	// site_id := "1001"
+	// platform := "deliver_mini"
+	// user_id := "1"
+	// openid := "CasfoieFsdfsdfiDiodf_df"
+	// openname := "测试中"
+	// avatar := "https://ssss.ttt.ddd/sfsd"
+	// mobile := "1234456456"
+	// res, err := BindThird(site_id, dbname, platform, user_id, openid, openname, "", avatar, mobile)
+	// t.Log(res)
+	// t.Log(err)
+
+	// data := "E5B2642BDEA1FBC85BA958C398E58DEC2E1425E26E25D6A178DBD078AD0DFC6859DF5634B0A01CE01F84E056380981A1F1433044FB197D8965FD8F3322DF2373619AD4ACB158605B45AC3947B200C8B62C2B30256B2D2D7283492F268F609944"
+	data := "E5B2642BDEA1FBC85BA958C398E58DEC2E1425E26E25D6A178DBD078AD0DFC6859DF5634B0A01CE01F84E056380981A1F1433044FB197D89AF51E05A9E9F5C76BE8F563F2E4D42AB3C3C649B4187A7C48E98988C734CEACD"
+
+	org := crypter.DesDe(data, DES_KEY)
 
+	t.Log(org)
 }

third_v2.client.go

@@ -0,0 +1,56 @@
+package userrpc
+
+import (
+	"encoding/json"
+)
+
+/**
+ * 查找第三方平台openid V2版
+ * 2021/09/07
+ * gz
+ */
+func GetUserThird(site_id, dbname, platform, user_id, field string, url ...string) (map[string]string, error) {
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return nil, err
+	}
+	defer conn.Close()
+
+	data := map[string]string{
+		"site_id":  site_id,
+		"dbname":   dbname,
+		"user_id":  user_id,
+		"platform": platform,
+		"field":    field,
+	}
+
+	req, err := SetReqData(data)
+	if err != nil {
+		return nil, err
+	}
+	res := &Response{}
+
+	err = conn.GetUserThird(req, res)
+
+	if err != nil {
+		return nil, err
+	}
+
+	res_data_de, err := GetResData(res)
+	if err != nil {
+		return nil, err
+	}
+	if res_data_de == "" {
+		return nil, nil
+	}
+	var res_arr map[string]string
+
+	err = json.Unmarshal([]byte(res_data_de), &res_arr)
+
+	if err != nil {
+		return nil, err
+	}
+	return res_arr, nil
+
+}

third_v2.client_test.go

@@ -0,0 +1,13 @@
+package userrpc
+
+import (
+	"testing"
+)
+
+func Test_GetUserThird(t *testing.T) {
+
+	org, err := GetUserThird("1", "shop_v2", "miniapp", "2", "id,openid")
+
+	t.Log(org)
+	t.Log(err)
+}

user.client.go

@@ -1,19 +1,22 @@
 package userrpc
 
 import (
+	"encoding/json"
+	"strconv"
+	"time"
+
+	"git.tetele.net/tgo/crypter"
+
 	"github.com/golang/protobuf/proto"
 )
 
 func GetUserByToken(dbname, token string, url ...string) (map[string]string, error) {
 
-	var user_rpc_url string = "127.0.0.1:7976"
-	if len(url) > 0 && url[0] != "" {
-		user_rpc_url = url[0]
-	}
-	conn, _, err := DialUserService("tcp", user_rpc_url)
+	conn, err := rpc_server_conn(url...)
 	if err != nil {
 		return map[string]string{}, err
 	}
+
 	defer conn.Close()
 
 	req := &UserRequest{proto.String(dbname), proto.String(token), nil}
@@ -28,19 +31,24 @@ func GetUserByToken(dbname, token string, url ...string) (map[string]string, err
 
 	if res.GetUserId() != "" {
 		return map[string]string{
-			"UserId":     res.GetUserId(),
-			"Username":   res.GetUsername(),
-			"Nickname":   res.GetNickname(),
-			"Mobile":     res.GetMobile(),
-			"Email":      res.GetEmail(),
-			"Status":     res.GetStatus(),
-			"BusinessId": res.GetBusinessId(),
-			"StoreId":    res.GetStoreId(),
-			"FansTo":     res.GetFansTo(),
-			"IsVip":      res.GetIsVip(),
-			"Usercode":   res.GetUsercode(),
-			"GroupId":    res.GetGroupId(),
-			"Type":       res.GetType(),
+			"UserId":       res.GetUserId(),
+			"Username":     res.GetUsername(),
+			"Nickname":     res.GetNickname(),
+			"Mobile":       res.GetMobile(),
+			"Email":        res.GetEmail(),
+			"Status":       res.GetStatus(),
+			"BusinessId":   res.GetBusinessId(),
+			"StoreId":      res.GetStoreId(),
+			"FansTo":       res.GetFansTo(),
+			"IsVip":        res.GetIsVip(),
+			"Usercode":     res.GetUsercode(),
+			"GroupId":      res.GetGroupId(),
+			"Type":         res.GetType(),
+			"ThirdId":      res.GetThirdId(),
+			"Platform":     res.GetPlatform(),
+			"LockFans":     res.GetLockFans(),
+			"CompanyId":    res.GetCompanyId(),
+			"DepartmentId": res.GetDepartmentId(),
 		}, nil
 	}
 
@@ -52,12 +60,8 @@ func GetUserByToken(dbname, token string, url ...string) (map[string]string, err
  */
 func GetUserByUsername(dbname, username string, url ...string) (*UserResponse, error) {
 
-	var user_rpc_url string = "127.0.0.1:7976"
-	if len(url) > 0 && url[0] != "" {
-		user_rpc_url = url[0]
-	}
+	conn, err := rpc_server_conn(url...)
 
-	conn, _, err := DialUserService("tcp", user_rpc_url)
 	if err != nil {
 		return nil, err
 	}
@@ -81,12 +85,8 @@ func GetUserByUsername(dbname, username string, url ...string) (*UserResponse, e
  */
 func GetUserByUsercode(dbname, usercode string, url ...string) (*UserResponse, error) {
 
-	var user_rpc_url string = "127.0.0.1:7976"
-	if len(url) > 0 && url[0] != "" {
-		user_rpc_url = url[0]
-	}
+	conn, err := rpc_server_conn(url...)
 
-	conn, _, err := DialUserService("tcp", user_rpc_url)
 	if err != nil {
 		return nil, err
 	}
@@ -107,12 +107,10 @@ func GetUserByUsercode(dbname, usercode string, url ...string) (*UserResponse, e
 
 func Login(dbname, account, password string, url ...string) (map[string]string, error) {
 
-	var user_rpc_url string = "127.0.0.1:7976"
-	if len(url) > 0 && url[0] != "" {
-		user_rpc_url = url[0]
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return map[string]string{}, err
 	}
-
-	conn, _, err := DialUserService("tcp", user_rpc_url)
 	if err != nil {
 		return map[string]string{}, err
 	}
@@ -149,3 +147,99 @@ func Login(dbname, account, password string, url ...string) (map[string]string,
 
 	return map[string]string{}, nil
 }
+
+/**
+ * 查找商户信息
+ * 2021/04/06
+ * gz
+ */
+func GetById(site_id, dbname, user_id string, url ...string) (map[string]string, error) {
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return nil, err
+	}
+	defer conn.Close()
+
+	data := GetUserReq{}
+	data.SiteId = site_id
+	data.Dbname = dbname
+	data.UserId = user_id
+
+	data_json, err := json.Marshal(data)
+	if err != nil {
+		return nil, err
+	}
+
+	encryData := crypter.DesEn(string(data_json), DES_KEY)
+
+	now_int64 := time.Now().Unix()
+
+	now := strconv.FormatInt(now_int64, 10)
+
+	sign := Sign(encryData, now)
+
+	req := &Request{
+		proto.String(encryData),
+		proto.String(now),
+		proto.String(sign),
+		nil}
+
+	res := &Response{}
+
+	err = conn.GetById(req, res)
+
+	if err != nil {
+		return nil, err
+	}
+
+	return HandleUserRes(res)
+}
+
+/**
+ * 更新用户缓存
+ * 2021/11/23
+ * linsen
+ */
+func UpdateUserCache(site_id, dbname, user_id string, url ...string) (map[string]string, error) {
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return nil, err
+	}
+	defer conn.Close()
+
+	data := GetUserReq{}
+	data.SiteId = site_id
+	data.Dbname = dbname
+	data.UserId = user_id
+
+	data_json, err := json.Marshal(data)
+	if err != nil {
+		return nil, err
+	}
+
+	encryData := crypter.DesEn(string(data_json), DES_KEY)
+
+	now_int64 := time.Now().Unix()
+
+	now := strconv.FormatInt(now_int64, 10)
+
+	sign := Sign(encryData, now)
+
+	req := &Request{
+		proto.String(encryData),
+		proto.String(now),
+		proto.String(sign),
+		nil}
+
+	res := &Response{}
+
+	err = conn.UpdateUserCache(req, res)
+
+	if err != nil {
+		return nil, err
+	}
+
+	return HandleUserRes(res)
+}

user.client_test.go

@@ -5,31 +5,59 @@ import (
 )
 
 func Test_GetUserByToken(t *testing.T) {
-	dbname := "dev_tetele_net"
-	token := "5536827c-36a5-4ec7-946d-49e4380c5103"
-	res, err := GetUserByToken(dbname, token, "111.229.34.252:7976")
-	t.Log(res)
-	t.Log(res["UserId"])
-	t.Log(err)
+	dbname := "shop_v2"
+	// token := "5536827c-36a5-4ec7-946d-49e4380c5103"
+	// res, err := GetUserByToken(dbname, token, "111.229.34.252:7976")
+	// t.Log(res)
+	// t.Log(res["UserId"])
+	// t.Log(err)
 
-	res2, err := GetUserByUsername(dbname, "tetele")
+	res2, err := GetById("1023", dbname, "3")
 	t.Log(res2)
-	t.Log(res2.GetUserId())
+	// t.Log(res2.GetUserId())
 	t.Log(err)
 
-	res3, err := GetUserByUsercode(dbname, "2233")
-	t.Log(res3)
-	t.Log(*res3.UserId)
-	t.Log(err)
+	// res3, err := GetUserByUsercode(dbname, "2233")
+	// t.Log(res3)
+	// t.Log(*res3.UserId)
+	// t.Log(err)
 }
 
-func Test_Login(t *testing.T) {
-	dbname := "dev_tetele_net"
-	account := "admin"
-	password := "e10adc3949ba59abbe56e057f20f883e"
-	res, err := Login(dbname, account, password)
+// func Test_Login(t *testing.T) {
+// 	dbname := "dev_tetele_net"
+// 	account := "admin"
+// 	password := "e10adc3949ba59abbe56e057f20f883e"
+// 	res, err := Login(dbname, account, password)
+// 	t.Log(res)
+// 	t.Log(res["UserId"])
+// 	t.Log(err)
+
+// }
+
+func Test_UpdateUserCache(t *testing.T){
+	dbname := "shop"
+
+	siteId := "1198881"
+
+	res,err := UpdateUserCache(siteId,dbname,"6")
+
+	if err != nil {
+		t.Error(err.Error())
+	}
+
 	t.Log(res)
-	t.Log(res["UserId"])
-	t.Log(err)
+}
+
 
+func Test_GetById(t *testing.T){
+	dbname := "shop"
+	siteId := "1198881"
+
+	res,err := GetById(siteId,dbname,"6")
+
+	if err != nil {
+		t.Error(err.Error())
+	}
+
+	t.Log(res)
 }

user.pb.go

@@ -11,6 +11,7 @@ It is generated from these files:
 It has these top-level messages:
 	UserRequest
 	UserInfoByUsername
+	UserInfoById
 	UserInfoByUsercode
 	UserResponse
 	LoginRequest
@@ -84,6 +85,31 @@ func (m *UserInfoByUsername) GetUsername() string {
 	return ""
 }
 
+// 使用userid查询用户信息请求结构
+type UserInfoById struct {
+	Dbname           *string `protobuf:"bytes,1,opt,name=dbname" json:"dbname,omitempty"`
+	Userid           *string `protobuf:"bytes,2,opt,name=userid" json:"userid,omitempty"`
+	XXX_unrecognized []byte  `json:"-"`
+}
+
+func (m *UserInfoById) Reset()         { *m = UserInfoById{} }
+func (m *UserInfoById) String() string { return proto.CompactTextString(m) }
+func (*UserInfoById) ProtoMessage()    {}
+
+func (m *UserInfoById) GetDbname() string {
+	if m != nil && m.Dbname != nil {
+		return *m.Dbname
+	}
+	return ""
+}
+
+func (m *UserInfoById) GetUserid() string {
+	if m != nil && m.Userid != nil {
+		return *m.Userid
+	}
+	return ""
+}
+
 // 使用usercode查询用户信息请求结构
 type UserInfoByUsercode struct {
 	Dbname           *string `protobuf:"bytes,1,opt,name=dbname" json:"dbname,omitempty"`
@@ -124,6 +150,11 @@ type UserResponse struct {
 	Usercode         *string `protobuf:"bytes,11,opt,name=usercode" json:"usercode,omitempty"`
 	GroupId          *string `protobuf:"bytes,12,opt,name=group_id" json:"group_id,omitempty"`
 	Type             *string `protobuf:"bytes,13,opt,name=type" json:"type,omitempty"`
+	ThirdId          *string `protobuf:"bytes,14,opt,name=third_id" json:"third_id,omitempty"`
+	Platform         *string `protobuf:"bytes,15,opt,name=platform" json:"platform,omitempty"`
+	LockFans         *string `protobuf:"bytes,16,opt,name=lock_fans" json:"lock_fans,omitempty"`
+	CompanyId        *string `protobuf:"bytes,17,opt,name=company_id" json:"company_id,omitempty"`
+	DepartmentId     *string `protobuf:"bytes,18,opt,name=department_id" json:"department_id,omitempty"`
 	XXX_unrecognized []byte  `json:"-"`
 }
 
@@ -222,6 +253,41 @@ func (m *UserResponse) GetType() string {
 	return ""
 }
 
+func (m *UserResponse) GetThirdId() string {
+	if m != nil && m.ThirdId != nil {
+		return *m.ThirdId
+	}
+	return ""
+}
+
+func (m *UserResponse) GetPlatform() string {
+	if m != nil && m.Platform != nil {
+		return *m.Platform
+	}
+	return ""
+}
+
+func (m *UserResponse) GetLockFans() string {
+	if m != nil && m.LockFans != nil {
+		return *m.LockFans
+	}
+	return ""
+}
+
+func (m *UserResponse) GetCompanyId() string {
+	if m != nil && m.CompanyId != nil {
+		return *m.CompanyId
+	}
+	return ""
+}
+
+func (m *UserResponse) GetDepartmentId() string {
+	if m != nil && m.DepartmentId != nil {
+		return *m.DepartmentId
+	}
+	return ""
+}
+
 // 用户登录请求结构
 type LoginRequest struct {
 	Dbname           *string `protobuf:"bytes,1,opt,name=dbname" json:"dbname,omitempty"`
@@ -271,6 +337,8 @@ type LoginResponse struct {
 	Usercode         *string `protobuf:"bytes,12,opt,name=usercode" json:"usercode,omitempty"`
 	GroupId          *string `protobuf:"bytes,13,opt,name=group_id" json:"group_id,omitempty"`
 	Type             *string `protobuf:"bytes,14,opt,name=type" json:"type,omitempty"`
+	ThirdId          *string `protobuf:"bytes,15,opt,name=third_id" json:"third_id,omitempty"`
+	Platform         *string `protobuf:"bytes,16,opt,name=platform" json:"platform,omitempty"`
 	XXX_unrecognized []byte  `json:"-"`
 }
 
@@ -376,6 +444,20 @@ func (m *LoginResponse) GetType() string {
 	return ""
 }
 
+func (m *LoginResponse) GetThirdId() string {
+	if m != nil && m.ThirdId != nil {
+		return *m.ThirdId
+	}
+	return ""
+}
+
+func (m *LoginResponse) GetPlatform() string {
+	if m != nil && m.Platform != nil {
+		return *m.Platform
+	}
+	return ""
+}
+
 // 信息请求结构
 type Request struct {
 	Data             *string `protobuf:"bytes,1,opt,name=data" json:"data,omitempty"`
@@ -451,6 +533,27 @@ type UserService interface {
 	GetByUsername(in *UserInfoByUsername, out *UserResponse) error
 	GetByUsercode(in *UserInfoByUsercode, out *UserResponse) error
 	BindThird(in *Request, out *Response) error
+	GetThird(in *Request, out *Response) error
+	GetUserThird(in *Request, out *Response) error
+	GetBusiness(in *Request, out *Response) error
+	GetById(in *Request, out *Response) error
+	UpdateUserCache(in *Request, out *Response) error
+	GetBusinessInfo(in *Request, out *Response) error
+	GetAddressInfo(in *Request, out *Response) error
+	GetUserScore(in *Request, out *Response) error
+	GetUserRedEnvelope(in *Request, out *Response) error
+	AddUserScore(in *Request, out *Response) error
+	UpdateUserScore(in *Request, out *Response) error
+	AddUserScoreLog(in *Request, out *Response) error
+	AddUserUpgrade(in *Request, out *Response) error
+	UpdateUserUpgrade(in *Request, out *Response) error
+	AddUserUpgradeLog(in *Request, out *Response) error
+	AddUserRedEnvelope(in *Request, out *Response) error
+	UpdateUserRedEnvelope(in *Request, out *Response) error
+	AddUserRedEnvelopeLog(in *Request, out *Response) error
+	AddUserCoupon(in *Request, out *Response) error
+	UpdateUserCoupon(in *Request, out *Response) error
+	Fans(in *Request, out *Response) error
 }
 
 // AcceptUserServiceClient accepts connections on the listener and serves requests
@@ -537,6 +640,69 @@ func (c *UserServiceClient) GetByUsercode(in *UserInfoByUsercode, out *UserRespo
 func (c *UserServiceClient) BindThird(in *Request, out *Response) error {
 	return c.Call("UserService.BindThird", in, out)
 }
+func (c *UserServiceClient) GetThird(in *Request, out *Response) error {
+	return c.Call("UserService.GetThird", in, out)
+}
+func (c *UserServiceClient) GetUserThird(in *Request, out *Response) error {
+	return c.Call("UserService.GetUserThird", in, out)
+}
+func (c *UserServiceClient) GetBusiness(in *Request, out *Response) error {
+	return c.Call("UserService.GetBusiness", in, out)
+}
+func (c *UserServiceClient) GetById(in *Request, out *Response) error {
+	return c.Call("UserService.GetById", in, out)
+}
+func (c *UserServiceClient) UpdateUserCache(in *Request, out *Response) error {
+	return c.Call("UserService.UpdateUserCache", in, out)
+}
+func (c *UserServiceClient) GetBusinessInfo(in *Request, out *Response) error {
+	return c.Call("UserService.GetBusinessInfo", in, out)
+}
+func (c *UserServiceClient) GetAddressInfo(in *Request, out *Response) error {
+	return c.Call("UserService.GetAddressInfo", in, out)
+}
+func (c *UserServiceClient) GetUserScore(in *Request, out *Response) error {
+	return c.Call("UserService.GetUserScore", in, out)
+}
+func (c *UserServiceClient) GetUserRedEnvelope(in *Request, out *Response) error {
+	return c.Call("UserService.GetUserRedEnvelope", in, out)
+}
+func (c *UserServiceClient) AddUserScore(in *Request, out *Response) error {
+	return c.Call("UserService.AddUserScore", in, out)
+}
+func (c *UserServiceClient) UpdateUserScore(in *Request, out *Response) error {
+	return c.Call("UserService.UpdateUserScore", in, out)
+}
+func (c *UserServiceClient) AddUserScoreLog(in *Request, out *Response) error {
+	return c.Call("UserService.AddUserScoreLog", in, out)
+}
+func (c *UserServiceClient) AddUserUpgrade(in *Request, out *Response) error {
+	return c.Call("UserService.AddUserUpgrade", in, out)
+}
+func (c *UserServiceClient) UpdateUserUpgrade(in *Request, out *Response) error {
+	return c.Call("UserService.UpdateUserUpgrade", in, out)
+}
+func (c *UserServiceClient) AddUserUpgradeLog(in *Request, out *Response) error {
+	return c.Call("UserService.AddUserUpgradeLog", in, out)
+}
+func (c *UserServiceClient) AddUserRedEnvelope(in *Request, out *Response) error {
+	return c.Call("UserService.AddUserRedEnvelope", in, out)
+}
+func (c *UserServiceClient) UpdateUserRedEnvelope(in *Request, out *Response) error {
+	return c.Call("UserService.UpdateUserRedEnvelope", in, out)
+}
+func (c *UserServiceClient) AddUserRedEnvelopeLog(in *Request, out *Response) error {
+	return c.Call("UserService.AddUserRedEnvelopeLog", in, out)
+}
+func (c *UserServiceClient) AddUserCoupon(in *Request, out *Response) error {
+	return c.Call("UserService.AddUserCoupon", in, out)
+}
+func (c *UserServiceClient) UpdateUserCoupon(in *Request, out *Response) error {
+	return c.Call("UserService.UpdateUserCoupon", in, out)
+}
+func (c *UserServiceClient) Fans(in *Request, out *Response) error {
+	return c.Call("UserService.Fans", in, out)
+}
 
 // DialUserService connects to an UserService at the specified network address.
 func DialUserService(network, addr string) (*UserServiceClient, *rpc.Client, error) {

user.proto

@@ -11,6 +11,11 @@ message UserInfoByUsername {
 	string dbname = 1;
     string username = 2;
 }
+// 使用userid查询用户信息请求结构
+message UserInfoById {
+	string dbname = 1;
+    string userid = 2;
+}
 
 // 使用usercode查询用户信息请求结构
 message UserInfoByUsercode {
@@ -32,6 +37,11 @@ message UserResponse {
     string usercode = 11;//工号
     string group_id = 12;//分组ID
     string type = 13;//类型
+    string third_id = 14; //token对应的third_id
+    string platform = 15; //平台
+    string lock_fans = 16; //锁定
+    string company_id = 17;
+    string department_id =18;
 }
 
 // 用户登录请求结构
@@ -58,6 +68,8 @@ message LoginResponse {
     string usercode = 12;//工号
     string group_id = 13;//分组ID
     string type = 14;//类型
+    string third_id = 15; //token对应的third_id
+    string platform = 16; //平台
 }
 
 
@@ -82,4 +94,26 @@ service UserService {
     rpc getByUsername (UserInfoByUsername) returns (UserResponse);    // 使用username查询用户
     rpc getByUsercode (UserInfoByUsercode) returns (UserResponse);    // 使用usercode查询用户
     rpc bindThird (Request) returns (Response);    // 绑定第三方账号
+    rpc getThird(Request) returns (Response);    // 查询第三方账号
+    rpc getUserThird(Request) returns (Response);    // 查询第三方账号v2
+    rpc getBusiness(Request) returns (Response);    // 查询商户
+    rpc getById(Request) returns (Response);    // 查询用户
+    rpc updateUserCache(Request) returns (Response);    // 更新用户缓存并返回用户信息
+    rpc getBusinessInfo(Request) returns (Response);    // 查询分销商
+    rpc getAddressInfo(Request) returns (Response);    // 查询地址
+    rpc getUserScore(Request) returns (Response);    // 查询用户积分
+    rpc getUserRedEnvelope(Request) returns (Response);    // 查询用户红包
+    rpc addUserScore(Request) returns (Response);    // 添加用户积分
+    rpc updateUserScore(Request) returns (Response);    // 更新用户积分
+    rpc addUserScoreLog(Request) returns (Response);    // 添加用户积分日志
+    rpc addUserUpgrade(Request) returns (Response);    // 添加用户成长值
+    rpc updateUserUpgrade(Request) returns (Response);    // 更新用户成长值
+    rpc addUserUpgradeLog(Request) returns (Response);    // 添加用户成长值日志
+    rpc addUserRedEnvelope(Request) returns (Response);    // 更新用户红包
+    rpc updateUserRedEnvelope(Request) returns (Response);    // 添加用户红包
+    rpc addUserRedEnvelopeLog(Request) returns (Response);    // 添加用户红包日志
+    rpc addUserCoupon(Request) returns (Response);    // 添加用户优惠券记录
+    rpc updateUserCoupon(Request) returns (Response);    // 更新用户优惠券记录
+    //rpc favoriteProduct(Request) returns (Response);    // 收藏商品
+    rpc Fans(Request) returns (Response);    // 绑定
 }