From 35e2c44605969e48666aaa0e5c7342e6b869cb0f Mon Sep 17 00:00:00 2001 From: guzeng Date: Wed, 3 Nov 2021 21:35:55 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E7=A7=AF=E5=88=86=E6=B7=BB?= =?UTF-8?q?=E5=8A=A0=E5=8F=82=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- account.client.go | 1116 +++++++++++++++++++++++---------------------- 1 file changed, 560 insertions(+), 556 deletions(-) diff --git a/account.client.go b/account.client.go index 8000d77..1d512f0 100644 --- a/account.client.go +++ b/account.client.go @@ -1,58 +1,61 @@ package userrpc import ( - "encoding/json" - "errors" - "log" + "encoding/json" + "errors" + "log" ) type GetAddReq struct { - Req - UserId string - Value string + Req + UserId string + Value string + Memo string + Source string + SourceId string } type GetUpdateReq struct { - Req - UserId string - Value string - UsedValue string + 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 + 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 + 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 + Req + UserId string + CouponId string + ExpireTime string + OrderSn string + Remark string + IsUse string + Usertime string } /** @@ -60,49 +63,49 @@ type GetCouponReq struct { */ func GetUserScore(dbname, userId string, url ...string) (string, error) { - if dbname == "" || userId == "" { - return "", errors.New("参数错误") - } + if dbname == "" || userId == "" { + return "", errors.New("参数错误") + } - conn, err := rpc_server_conn(url...) - if err != nil { - return "", err - } - defer conn.Close() + conn, err := rpc_server_conn(url...) + if err != nil { + return "", err + } + defer conn.Close() - data := GetUserReq{} - data.Dbname = dbname - data.UserId = userId + data := GetUserReq{} + data.Dbname = dbname + data.UserId = userId - req, err := SetReqData(data) - if err != nil { - return "", err - } + req, err := SetReqData(data) + if err != nil { + return "", err + } - res := &Response{} + res := &Response{} - err = conn.GetUserScore(req, res) + err = conn.GetUserScore(req, res) - if err != nil { - return "", err - } + if err != nil { + return "", err + } - res_data_de, err := GetResData(res) - if err != nil { - return "", err - } - if res_data_de == "" { - return "", nil - } + 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) + var score string + err = json.Unmarshal([]byte(res_data_de), &score) - if err != nil { - return "", err - } + if err != nil { + return "", err + } - return score, nil + return score, nil } /** @@ -110,49 +113,49 @@ func GetUserScore(dbname, userId string, url ...string) (string, error) { */ func GetUserRedEnvelope(dbname, userId string, url ...string) (string, error) { - if dbname == "" || userId == "" { - return "", errors.New("参数错误") - } + if dbname == "" || userId == "" { + return "", errors.New("参数错误") + } - conn, err := rpc_server_conn(url...) - if err != nil { - return "", err - } - defer conn.Close() + conn, err := rpc_server_conn(url...) + if err != nil { + return "", err + } + defer conn.Close() - data := GetUserReq{} - data.Dbname = dbname - data.UserId = userId + data := GetUserReq{} + data.Dbname = dbname + data.UserId = userId - req, err := SetReqData(data) - if err != nil { - return "", err - } + req, err := SetReqData(data) + if err != nil { + return "", err + } - res := &Response{} + res := &Response{} - err = conn.GetUserRedEnvelope(req, res) + err = conn.GetUserRedEnvelope(req, res) - if err != nil { - return "", err - } + if err != nil { + return "", err + } - res_data_de, err := GetResData(res) - if err != nil { - return "", err - } - if res_data_de == "" { - return "", nil - } + 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) + var redEnvelope string + err = json.Unmarshal([]byte(res_data_de), &redEnvelope) - if err != nil { - return "", err - } + if err != nil { + return "", err + } - return redEnvelope, nil + return redEnvelope, nil } /** @@ -160,56 +163,57 @@ func GetUserRedEnvelope(dbname, userId string, url ...string) (string, error) { * @2021/09/30 * @bin */ -func AddUserScore(dbname, userId, score string, url ...string) (int64, error) { - if dbname == "" || userId == "" || score == "" { - return 0, errors.New("参数错误") - } +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() + 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 := 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 - } + req, err := SetReqData(data) + if err != nil { + log.Println("AddUserScore crypter error:", err) + return 0, err + } - res := &Response{} + res := &Response{} - err = conn.AddUserScore(req, res) + err = conn.AddUserScore(req, res) - if err != nil { - log.Println("userrpc AddUserScore error:", err) - return 0, err - } + if err != nil { + log.Println("userrpc AddUserScore error:", err) + return 0, err + } - res_data_de, err := GetResData(res) + res_data_de, err := GetResData(res) - if err != nil { - return 0, err - } + if err != nil { + return 0, err + } - if res_data_de == "" { - return 0, nil - } + if res_data_de == "" { + return 0, nil + } - var insertId int64 + var insertId int64 - err = json.Unmarshal([]byte(res_data_de), &insertId) + err = json.Unmarshal([]byte(res_data_de), &insertId) - if err != nil { - return 0, err - } + if err != nil { + return 0, err + } - return insertId, nil + return insertId, nil } /** @@ -218,56 +222,56 @@ func AddUserScore(dbname, userId, score string, url ...string) (int64, error) { * @bin */ func UpdateUserScore(dbname, userId, score, used_score string, url ...string) (bool, error) { - if dbname == "" || userId == "" || score == "" { - return false, errors.New("参数错误") - } + if dbname == "" || userId == "" || score == "" { + return false, errors.New("参数错误") + } - conn, err := rpc_server_conn(url...) - if err != nil { - return false, err - } - defer conn.Close() + 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 + 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 - } + req, err := SetReqData(data) + if err != nil { + log.Println("UpdateUserScore crypter error:", err) + return false, err + } - res := &Response{} + res := &Response{} - err = conn.UpdateUserScore(req, res) + err = conn.UpdateUserScore(req, res) - if err != nil { - log.Println("userrpc UpdateUserScore error:", err) - return false, err - } + if err != nil { + log.Println("userrpc UpdateUserScore error:", err) + return false, err + } - res_data_de, err := GetResData(res) + res_data_de, err := GetResData(res) - if err != nil { - return false, err - } + if err != nil { + return false, err + } - if res_data_de == "" { - return false, nil - } + if res_data_de == "" { + return false, nil + } - var updateres bool + var updateres bool - err = json.Unmarshal([]byte(res_data_de), &updateres) + err = json.Unmarshal([]byte(res_data_de), &updateres) - if err != nil { - return false, err - } + if err != nil { + return false, err + } - return updateres, nil + return updateres, nil } /** @@ -276,64 +280,64 @@ func UpdateUserScore(dbname, userId, score, used_score string, url ...string) (b * @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 + 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 } /** @@ -342,55 +346,55 @@ func AddUserScoreLog(dbname, UserId, Score, Before, After, Source, SourceId, Ord * @bin */ func AddUserUpgrade(dbname, userId, upgrade string, url ...string) (int64, error) { - if dbname == "" || userId == "" || upgrade == "" { - return 0, errors.New("参数错误") - } + if dbname == "" || userId == "" || upgrade == "" { + return 0, errors.New("参数错误") + } - conn, err := rpc_server_conn(url...) - if err != nil { - return 0, err - } - defer conn.Close() + 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 := GetAddReq{} + data.Dbname = dbname + data.UserId = userId + data.Value = upgrade - req, err := SetReqData(data) - if err != nil { - log.Println("AddUserUpgrade crypter error:", err) - return 0, err - } + req, err := SetReqData(data) + if err != nil { + log.Println("AddUserUpgrade crypter error:", err) + return 0, err + } - res := &Response{} + res := &Response{} - err = conn.AddUserUpgrade(req, res) + err = conn.AddUserUpgrade(req, res) - if err != nil { - log.Println("userrpc AddUserUpgrade error:", err) - return 0, err - } + if err != nil { + log.Println("userrpc AddUserUpgrade error:", err) + return 0, err + } - res_data_de, err := GetResData(res) + res_data_de, err := GetResData(res) - if err != nil { - return 0, err - } + if err != nil { + return 0, err + } - if res_data_de == "" { - return 0, nil - } + if res_data_de == "" { + return 0, nil + } - var insertId int64 + var insertId int64 - err = json.Unmarshal([]byte(res_data_de), &insertId) + err = json.Unmarshal([]byte(res_data_de), &insertId) - if err != nil { - return 0, err - } + if err != nil { + return 0, err + } - return insertId, nil + return insertId, nil } /** @@ -399,55 +403,55 @@ func AddUserUpgrade(dbname, userId, upgrade string, url ...string) (int64, error * @bin */ func UpdateUserUpgrade(dbname, userId, upgrade string, url ...string) (bool, error) { - if dbname == "" || userId == "" || upgrade == "" { - return false, errors.New("参数错误") - } + if dbname == "" || userId == "" || upgrade == "" { + return false, errors.New("参数错误") + } - conn, err := rpc_server_conn(url...) - if err != nil { - return false, err - } - defer conn.Close() + 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 + 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 - } + req, err := SetReqData(data) + if err != nil { + log.Println("UpdateUserUpgrade crypter error:", err) + return false, err + } - res := &Response{} + res := &Response{} - err = conn.UpdateUserUpgrade(req, res) + err = conn.UpdateUserUpgrade(req, res) - if err != nil { - log.Println("userrpc UpdateUserUpgrade error:", err) - return false, err - } + if err != nil { + log.Println("userrpc UpdateUserUpgrade error:", err) + return false, err + } - res_data_de, err := GetResData(res) + res_data_de, err := GetResData(res) - if err != nil { - return false, err - } + if err != nil { + return false, err + } - if res_data_de == "" { - return false, nil - } + if res_data_de == "" { + return false, nil + } - var updateres bool + var updateres bool - err = json.Unmarshal([]byte(res_data_de), &updateres) + err = json.Unmarshal([]byte(res_data_de), &updateres) - if err != nil { - return false, err - } + if err != nil { + return false, err + } - return updateres, nil + return updateres, nil } /** @@ -456,59 +460,59 @@ func UpdateUserUpgrade(dbname, userId, upgrade string, url ...string) (bool, err * @bin */ func AddUserUpgradeLog(dbname, UserId, Upgrade, Before, After, Source, Memo string, url ...string) (int64, error) { - if dbname == "" || UserId == "" || Upgrade == "" || After == "" { - return 0, errors.New("参数错误") - } + if dbname == "" || UserId == "" || Upgrade == "" || After == "" { + return 0, errors.New("参数错误") + } - conn, err := rpc_server_conn(url...) - if err != nil { - return 0, err - } - defer conn.Close() + 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 + 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 - } + req, err := SetReqData(data) + if err != nil { + log.Println("AddUserUpgradeLog crypter error:", err) + return 0, err + } - res := &Response{} + res := &Response{} - err = conn.AddUserUpgradeLog(req, res) + err = conn.AddUserUpgradeLog(req, res) - if err != nil { - log.Println("userrpc AddUserUpgradeLog error:", err) - return 0, err - } + if err != nil { + log.Println("userrpc AddUserUpgradeLog error:", err) + return 0, err + } - res_data_de, err := GetResData(res) + res_data_de, err := GetResData(res) - if err != nil { - return 0, err - } + if err != nil { + return 0, err + } - if res_data_de == "" { - return 0, nil - } + if res_data_de == "" { + return 0, nil + } - var insertId int64 + var insertId int64 - err = json.Unmarshal([]byte(res_data_de), &insertId) + err = json.Unmarshal([]byte(res_data_de), &insertId) - if err != nil { - return 0, err - } + if err != nil { + return 0, err + } - return insertId, nil + return insertId, nil } /** @@ -517,55 +521,55 @@ func AddUserUpgradeLog(dbname, UserId, Upgrade, Before, After, Source, Memo stri * @bin */ func AddUserRedEnvelope(dbname, userId, money string, url ...string) (int64, error) { - if dbname == "" || userId == "" || money == "" { - return 0, errors.New("参数错误") - } + if dbname == "" || userId == "" || money == "" { + return 0, errors.New("参数错误") + } - conn, err := rpc_server_conn(url...) - if err != nil { - return 0, err - } - defer conn.Close() + 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 := GetAddReq{} + data.Dbname = dbname + data.UserId = userId + data.Value = money - req, err := SetReqData(data) - if err != nil { - log.Println("AddUserRedEnvelope crypter error:", err) - return 0, err - } + req, err := SetReqData(data) + if err != nil { + log.Println("AddUserRedEnvelope crypter error:", err) + return 0, err + } - res := &Response{} + res := &Response{} - err = conn.AddUserRedEnvelope(req, res) + err = conn.AddUserRedEnvelope(req, res) - if err != nil { - log.Println("userrpc AddUserRedEnvelope error:", err) - return 0, err - } + if err != nil { + log.Println("userrpc AddUserRedEnvelope error:", err) + return 0, err + } - res_data_de, err := GetResData(res) + res_data_de, err := GetResData(res) - if err != nil { - return 0, err - } + if err != nil { + return 0, err + } - if res_data_de == "" { - return 0, nil - } + if res_data_de == "" { + return 0, nil + } - var insertId int64 + var insertId int64 - err = json.Unmarshal([]byte(res_data_de), &insertId) + err = json.Unmarshal([]byte(res_data_de), &insertId) - if err != nil { - return 0, err - } + if err != nil { + return 0, err + } - return insertId, nil + return insertId, nil } /** @@ -574,56 +578,56 @@ func AddUserRedEnvelope(dbname, userId, money string, url ...string) (int64, err * @bin */ func UpdateUserRedEnvelope(dbname, userId, money, used_money string, url ...string) (bool, error) { - if dbname == "" || userId == "" || money == "" { - return false, errors.New("参数错误") - } + if dbname == "" || userId == "" || money == "" { + return false, errors.New("参数错误") + } - conn, err := rpc_server_conn(url...) - if err != nil { - return false, err - } - defer conn.Close() + 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 + 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 - } + req, err := SetReqData(data) + if err != nil { + log.Println("UpdateUserRedEnvelope crypter error:", err) + return false, err + } - res := &Response{} + res := &Response{} - err = conn.UpdateUserRedEnvelope(req, res) + err = conn.UpdateUserRedEnvelope(req, res) - if err != nil { - log.Println("userrpc UpdateUserRedEnvelope error:", err) - return false, err - } + if err != nil { + log.Println("userrpc UpdateUserRedEnvelope error:", err) + return false, err + } - res_data_de, err := GetResData(res) + res_data_de, err := GetResData(res) - if err != nil { - return false, err - } + if err != nil { + return false, err + } - if res_data_de == "" { - return false, nil - } + if res_data_de == "" { + return false, nil + } - var updateres bool + var updateres bool - err = json.Unmarshal([]byte(res_data_de), &updateres) + err = json.Unmarshal([]byte(res_data_de), &updateres) - if err != nil { - return false, err - } + if err != nil { + return false, err + } - return updateres, nil + return updateres, nil } /** @@ -632,63 +636,63 @@ func UpdateUserRedEnvelope(dbname, userId, money, used_money string, url ...stri * @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 + 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 } /** @@ -697,58 +701,58 @@ func AddUserRedEnvelopeLog(dbname, UserId, Money, Before, After, Source, SourceI * @bin */ func AddUserCoupon(dbname, userId, couponId, expireTime, orderSn, remark string, url ...string) (int64, error) { - if dbname == "" || userId == "" || couponId == "" { - return 0, errors.New("参数错误") - } + if dbname == "" || userId == "" || couponId == "" { + return 0, errors.New("参数错误") + } - conn, err := rpc_server_conn(url...) - if err != nil { - return 0, err - } - defer conn.Close() + 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 + 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 - } + req, err := SetReqData(data) + if err != nil { + log.Println("AddUserCoupon crypter error:", err) + return 0, err + } - res := &Response{} + res := &Response{} - err = conn.AddUserCoupon(req, res) + err = conn.AddUserCoupon(req, res) - if err != nil { - log.Println("userrpc AddUserCoupon error:", err) - return 0, err - } + if err != nil { + log.Println("userrpc AddUserCoupon error:", err) + return 0, err + } - res_data_de, err := GetResData(res) + res_data_de, err := GetResData(res) - if err != nil { - return 0, err - } + if err != nil { + return 0, err + } - if res_data_de == "" { - return 0, nil - } + if res_data_de == "" { + return 0, nil + } - var insertId int64 + var insertId int64 - err = json.Unmarshal([]byte(res_data_de), &insertId) + err = json.Unmarshal([]byte(res_data_de), &insertId) - if err != nil { - return 0, err - } + if err != nil { + return 0, err + } - return insertId, nil + return insertId, nil } /** @@ -757,57 +761,57 @@ func AddUserCoupon(dbname, userId, couponId, expireTime, orderSn, remark string, * @bin */ func UpdateUserCoupon(dbname, userId, couponId, remark, orderSn, isUse, usetime string, url ...string) (bool, error) { - if dbname == "" || userId == "" || couponId == "" { - return false, errors.New("参数错误") - } + if dbname == "" || userId == "" || couponId == "" { + return false, errors.New("参数错误") + } - conn, err := rpc_server_conn(url...) - if err != nil { - return false, err - } - defer conn.Close() + 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 + 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 - } + req, err := SetReqData(data) + if err != nil { + log.Println("UpdateUserCoupon crypter error:", err) + return false, err + } - res := &Response{} + res := &Response{} - err = conn.UpdateUserCoupon(req, res) + err = conn.UpdateUserCoupon(req, res) - if err != nil { - log.Println("userrpc UpdateUserCoupon error:", err) - return false, err - } + if err != nil { + log.Println("userrpc UpdateUserCoupon error:", err) + return false, err + } - res_data_de, err := GetResData(res) + res_data_de, err := GetResData(res) - if err != nil { - return false, err - } + if err != nil { + return false, err + } - if res_data_de == "" { - return false, nil - } + if res_data_de == "" { + return false, nil + } - var updateres bool + var updateres bool - err = json.Unmarshal([]byte(res_data_de), &updateres) + err = json.Unmarshal([]byte(res_data_de), &updateres) - if err != nil { - return false, err - } + if err != nil { + return false, err + } - return updateres, nil + return updateres, nil }