proto文件：
syntax = "proto3";
package coupon; //
//message UnsetUseC2URequest {
// int64 bid = 1;
// int64 uid = 2;
// int64 sid = 3;
// int64 transId = 4;
// repeated int64 c2uIds = 5;
//}
//
//message UnsetUseC2UReply {
// int64 errCode = 1;
// string errMsg = 2;
// bool result = 3;
//}
//
////检查发送的券是否可撤销
//message CheckCancelSendC2UByTradeRequest{
// int64 bid = 1;
// int64 uid = 2;
// int64 sid = 3;
// int64 transId = 4;
//}
//
//message CheckCancelSendC2UByTradeReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// bool result = 3; //true表示可以撤销。false表示不可以撤销。
//
//}
//
//// 检查交易发送的券是否可撤销
//message CheckCancelSendC2UByConsumeTradeRequest{
// int64 bid = 1;
// int64 uid = 2;
// int64 sid = 3;
// int64 transId = 4;
//}
//
//message CheckCancelSendC2UByConsumeTradeReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// string result = 3; //true表示可以撤销。false表示不可以撤销
//}
//
//message UidAndTransId{
// int64 uid = 1;
// int64 transId = 2;
//}
//message CheckCancelSendC2UByTradeMultiRequest{
// int64 bid = 1;
// int64 sid = 2;
// repeated UidAndTransId params = 3; //json(array(array('uid'=>, 'transId'=>), ..))
//}
//
//message CheckCancelSendC2UByTradeMultiReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// string result = 3; // json
//}
//message RecoverCouponsByC2uIdsRequest{
// int64 bid = 1;
// int64 uid = 2;
// repeated int64 c2uids = 3;
// string type = 4;
//}
//
//message RecoverCouponsByC2uIdsReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// bool result = 3; //true表示注销成功，false表示注销失败
//}
//
//message UpdateC2URequest{
// int64 bid = 1;
// int64 uid = 2;
// string data = 3; //json
// string conditions = 4; //json
//}
//message UpdateC2UReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// bool result = 3; //true表示操作成功
//}
//
//// 添加券账户信息
//message AddC2URequest{
// int64 bid = 1;
// int64 uid = 2;
// string data = 3; //json
// string shardKey = 4; //json 可能是无用的 bhy
//}
//
//message AddC2UReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// bool result = 3; //true表示操作成功
//}
//
////删除券账户信息
//message DeleteC2URequest{
// int64 bid = 1;
// int64 uid = 2;
// string conditions = 3; //json
//}
//
//message DeleteC2UReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// bool result = 3; //true表示操作成功
//}
//
////根据条件获取券账户
//message ListC2UByConditionsRequest{
// int64 bid = 1;
// int64 uid = 2;
// string conditions = 3; //json
//}
//
//message ListC2UByConditionsReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// string result = 3; //json
//}
//
////从mysql 获取券账户
//message ListC2UByMySQLRequest{
// string conditions = 1; //json
// string pageOptions = 2; //json
// string order = 3; //json
// repeated string fields = 4; //fields
//}
//
//message ListC2UByMySQLReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// string result = 3; //json
//}
//
//message ListC2UFutureCanUseRequest{
// int64 bid = 1;
// int64 uid = 2;
// int64 sid = 3;
// int64 cType = 4;
// string pageOptions = 5; //json
// bool isMerge = 6;
//}
//
//message ListC2UFutureCanUseReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// string result = 3; //json
//}
//
//message ListC2UFutureCanUseForPosRequest{
// int64 bid = 1;
// int64 uid = 2;
// int64 sid = 3;
// int64 cType = 4;
// string pageOptions = 5; //json
// bool isMerge = 6;
//}
//
//message ListC2UFutureCanUseForPosReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// string result = 3; //json
//}
//
//message GetC2uForPosConsumeRequest{
// int64 bid = 1;
// int64 uid = 2;
// int64 sid = 3;
// string pageOptions = 4; //json
//}
//
//message GetC2uForPosConsumeReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// string result = 3; //json
//}
//
//message UserGetCouponRequest {
// int64 bid = 1;
// int64 uid = 2;
// string data = 3; //json
//}
//
//message UserGetCouponReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// string result = 3; //json
//}
//
//message IsCouponSendComplateRequest {
// int64 bid = 1;
// int64 uid = 2;
// string aids = 3; //json
//}
//
//message IsCouponSendComplateReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// bool result = 3;
//}
//
//message UserCanUseConditionsRequest{
// int64 bid = 1;
// int64 uid = 2;
// string conditions = 3; //json
// string order = 4; //json
// string pageOptions = 5; //json
// bool isMerge = 6;
//}
//
//message UserCanUseConditionsReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// string result = 3; //json
//}
//
//message UserOverCouponRequest{
// int64 bid = 1;
// int64 uid = 2;
// string conditions = 3; //json
// string pageOptions = 4; //json
//}
//
//message UserOverCouponReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// string result = 3; //json
//}
//
//message UpdateCouponRequest{
// int64 bid = 1;
// int64 couponId = 2;
// string couponData = 3; //json
//}
//
//message UpdateCouponReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// bool result = 3;
//}
//
//message DeleteCouponRequest{
// int64 bid = 1;
// int64 couponId = 2;
//}
//
//message DeleteCouponReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// bool result = 3;
//}
//
//message ListAllCouponByConditionsRequest{
// int64 bid = 1;
// string conditions = 2; //json
// string pageOptions = 3; //json
// string order = 4; //json
// string fields = 5; //fields
// int64 sid = 6;
//}
//
//message ListAllCouponByConditionsReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// bool result = 3;
//}
//
//message CountCouponNumsRequest{
// int64 bid = 1;
// int64 cType = 2;
// string cName = 3;
// int64 sid = 4;
//}
//
//message CountCouponNumsReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// int64 result = 3;
//}
//
//message CouponQuoteByActivityRequest{
// int64 bid = 1;
// int64 aid = 2;
// repeated int64 couponids = 3;
//}
//
//message CouponQuoteByActivityReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// bool result = 3;
//}
//
//message CouponUnquoteByActivityRequest{
// int64 bid = 1;
// int64 aid = 2;
// repeated int64 couponids = 3;
//}
//
//message CouponUnquoteByActivityReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// bool result = 3;
//}
//
//message ListCouponsByCouponIdsRequest{
// int64 bid = 1;
// repeated int64 couponIds = 2;
//}
//message ListCouponsByCouponIdsReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// string result = 3;
//}
//
//message UseMassCouponRequest{
// int64 bid = 1;
// string data = 2; //json
// string condition = 3; //json
//}
//
//message UseMassCouponReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// bool result = 3;
//}
//
//message AddPackRequest{
// string coupon = 1; //json
// string subCoupons = 2; //json
//}
//
//message AddPackReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// bool result = 3;
//}
//
//message UpdatePackRequest{
// int64 bid = 1;
// int64 packId = 2;
// string couponData = 3; //json
//}
//
//message UpdatePackReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// bool result = 3;
//}
//
//message checkSubCouponsRequest{
// int64 bid = 1;
// int64 packId = 2;
// string couponIdArray = 3; //json
//}
//
//message checkSubCouponsReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// string result = 3;
//}
//
//message DeletePackRequest{
// int64 bid = 1;
// int64 packId = 2;
//}
//
//message DeletePackReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// bool result = 3;
//}
//
//message PackRefreshSubCouponsRequest{
// int64 bid = 1;
// int64 packId = 2;
//}
//
//message PackRefreshSubCouponsReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// string result = 3;
//}
//
//message ListCouponByConditionsRequest{
// string conditions = 1;
// string pageOptions = 2;
// string order = 3;
// string fields = 4;
//}
//
//message ListCouponByConditionsReply{
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// string result = 3;
//}
//
//// 查询当前用户所有的优惠券列表(相同券需要合并)
//message ListC2URequest {
// int64 bid = 1;
// int64 uid = 2;
// string conditions = 3; //查询条件json字符串,php调用传json
//
//}
//
//message ListC2UReply {
// int64 errCode = 1;
// string errMsg = 2;
// string result = 3; //券账户字段json字符串,php调用的时候解析json
//}
//
//// 查询当前用户所有可用的优惠券列表
//message ListC2UCanUseRequest {
// int64 bid = 1;
// int64 uid = 2;
// int64 sid = 3;
// int64 cType = 4;
// string pageOptions = 5; //php 传递 json
// bool isMerge = 6;
// int64 aid = 7;
// string from = 8;
// bool allNotUse = 9;
//}
//
//message ListC2UCanUseReply {
// int64 errCode = 1;
// string errMsg = 2;
// string result = 3; //券账户字段json字符串,php调用的时候解析json
//}
//
//// 根据状态参数查询当前用户优惠券列表
//message ListC2UCurrentCouponsRequest {
// int64 bid = 1;
// int64 uid = 2;
// int64 sid = 3;
// int64 cType = 4;
// string pageOptions = 5; //php 传递 json
// bool isMerge = 6;
// int64 aid = 7;
// string from = 8;
// bool allNotUse = 9;
// int32 useStatus = 10;
//}
//
//message ListC2UCurrentCouponsReply {
// int64 errCode = 1;
// string errMsg = 2;
// string result = 3; //券账户字段json字符串,php调用的时候解析json
//}
//
//// 通过c2uIds 拉取用户账户信息
//message ListC2UByC2UIdsRequest {
// int64 bid = 1;
// int64 uid = 2;
// repeated int64 c2uIds = 3;
//}
//
//message ListC2UByC2UIdsReply {
// int64 errCode = 1;
// string errMsg = 2;
// string result = 3;
//} message CouponInfo{
int64 CouponId = 1;
int64 CouponNum = 2;
string Code = 3;
} message SendCouponRequest {
int64 bid = 1;
int64 aid = 2;
int64 sid = 3;
int64 transId = 4;
bool fromJob =5;
repeated int64 uids = 6;
repeated CouponInfo couponids = 7;
int64 obid = 8; // 默认0
bool isBag = 9; // 是否券包
} message BoolReply {
int64 errCode = 1; //0值表示调用接口成功
string errMsg = 2;
bool result = 3;
}
//
////消费使用券
//message UseC2URequest {
// int64 bid = 1;
// int64 uid = 2;
// int64 sid = 3;
// int64 transId = 4;
// repeated int64 c2uIds = 5;
// string tradeType = 6;
//
//}
//
//message UseC2UReply {
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// string result = 3;
//}
//
////撤销发送券
//message CancelSendC2UByTradeRequest {
// int64 bid = 1;
// int64 uid = 2;
// int64 sid = 3;
// int64 transId = 4;
// string delType = 5;
// int64 couponsNum = 6;
// int64 sourceType = 7;
// int64 repealTcId = 8;
//
//}
//
//message CancelSendC2UByTradeReply {
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// string result = 3;
//}
//
////合并用户的券帐户
//message MergeCouponAccountRequest {
// int64 bid = 1;
// int64 fromUid = 2;
// int64 toUid = 3;
// int64 mid = 4;
//}
//
//message MergeCouponAccountReply {
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// int32 result = 3;
//}
//
//message RedisC2USelectRequest {
// int64 bid = 1;
// string c2uKey = 2;
// string fields = 3;
// string conditions = 4;
//}
//
//message RedisC2USelectReply {
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// string result = 3;
//}
//
//message RedisC2UUpdateRequest {
// int64 bid = 1;
// string c2uKey = 2;
// string data = 3;
// string conditions = 4;
//}
//
//message RedisC2UUpdateReply {
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// bool result = 3;
//}
//
//message RedisC2URemoveRequest {
// int64 bid = 1;
// string c2uKey = 2;
// string conditions = 3;
//}
//
//message RedisC2URemoveReply {
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// bool result = 3;
//}
//
////添加数据
//message RedisC2UAddRequest {
// int64 bid = 1;
// string c2uKey = 2;
// string data = 3;
// string conditions = 4;
//}
//
//message RedisC2UAddReply {
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// bool result = 3;
//}
//
////券模板redis获取
//message RedisSelectCouponRequest {
// int64 bid = 1;
// string fields = 2;
// string conditions = 3;
//}
//
//message RedisSelectCouponReply {
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// string result = 3;
//}
//
//message RedisUpdateCouponRequest {
// int64 bid = 1;
// string data = 2;
// string conditions = 3;
//}
//
//message RedisUpdateCouponReply {
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// bool result = 3;
//}
//
//message RedisRemoveCouponRequest {
// int64 bid = 1;
// string conditions = 2;
//}
//
//message RedisRemoveCouponReply {
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// bool result = 3;
//}
//
////添加数据
//message RedisAddCouponRequest {
// int64 bid = 1;
// string data = 2;
// string conditions = 3;
//}
//
//message RedisAddCouponReply {
// int64 errCode = 1; //0值表示调用接口成功
// string errMsg = 2;
// bool result = 3;
//}
//
service coupon {
//
// // 撤销消费使用券
// rpc UnsetUseC2U (UnsetUseC2URequest) returns (UnsetUseC2UReply) {}
//
// // 检查发送的券是否可撤销
// rpc CheckCancelSendC2UByTrade(CheckCancelSendC2UByTradeRequest) returns (CheckCancelSendC2UByTradeReply) {}
//
// // 查询当前用户所有的优惠券列表(相同券需要合并)
// rpc ListC2U (ListC2URequest) returns (ListC2UReply) {}
//
// // 查询当前用户所有可用的优惠券列表
// rpc ListC2UCanUse (ListC2UCanUseRequest) returns (ListC2UCanUseReply) {}
//
// // 通过c2uIds 拉取用户账户信息
// rpc ListC2UByC2UIds(ListC2UByC2UIdsRequest) returns (ListC2UByC2UIdsReply) {}
//
// // 检查交易发送的券是否可撤销
// rpc CheckCancelSendC2UByConsumeTrade (CheckCancelSendC2UByConsumeTradeRequest) returns (CheckCancelSendC2UByConsumeTradeReply) {}
//
// // 检查发送的券是否可撤销
// rpc CheckCancelSendC2UByTradeMulti (CheckCancelSendC2UByTradeMultiRequest) returns (CheckCancelSendC2UByTradeMultiReply) {}
//
// // 从指定用户账户中收回指定券 - 已使用的券无法被收回，将自动跳过
// rpc RecoverCouponsByC2uIds (RecoverCouponsByC2uIdsRequest) returns (RecoverCouponsByC2uIdsReply) {}
//
// // 更新券账户信息
// rpc UpdateC2U (UpdateC2URequest) returns (UpdateC2UReply) {}
//
// // 添加券账户信息
// rpc AddC2U (AddC2URequest) returns (AddC2UReply) {}
//
// // 删除券账户
// rpc DeleteC2U (DeleteC2URequest) returns (DeleteC2UReply) {}
//
// // 根据条件获取券账户
// rpc ListC2UByConditions (ListC2UByConditionsRequest) returns (ListC2UByConditionsReply) {}
//
// // 根据条件获取券账户 从mysql 直接获取
// rpc ListC2UByMySQL (ListC2UByMySQLRequest) returns (ListC2UByMySQLReply) {}
//
// // 查询当前用户所有未来可用的优惠券列表
// rpc ListC2UFutureCanUse (ListC2UFutureCanUseRequest) returns (ListC2UFutureCanUseReply) {}
//
// // 查询当前用户所有未来可用的优惠券列表
// rpc ListC2UFutureCanUseForPos (ListC2UFutureCanUseForPosRequest) returns (ListC2UFutureCanUseForPosReply) {}
//
// // 软pos消费页面Pos_ConsumeController的indexAction调用的方法
// rpc GetC2uForPosConsume (GetC2uForPosConsumeRequest) returns (GetC2uForPosConsumeReply) {}
//
// // 用户领取卡券
// rpc UserGetCoupon (UserGetCouponRequest) returns (UserGetCouponReply) {}
//
// // 查看券包有没有发完
// rpc IsCouponSendComplate(IsCouponSendComplateRequest) returns (IsCouponSendComplateReply) {}
// // 查询当前用户所有可用的优惠券搜索
// rpc UserCanUseConditions (UserCanUseConditionsRequest) returns (UserCanUseConditionsReply) {}
// //userOverCoupon
// rpc UserOverCoupon (UserOverCouponRequest) returns (UserOverCouponReply) {}
//
// //coupon:更新券模板
// rpc UpdateCoupon (UpdateCouponRequest) returns (UpdateCouponReply) {}
//
// //coupon:删除券模板
// rpc DeleteCoupon (DeleteCouponRequest) returns (DeleteCouponReply) {}
//
// //coupon:根据条件获取
// rpc ListAllCouponByConditions(ListAllCouponByConditionsRequest) returns (ListAllCouponByConditionsReply) {}
//
// //coupon: 统计优惠券数量
// rpc CountCouponNums (CountCouponNumsRequest) returns (CountCouponNumsReply) {}
//
// //coupon:券被活动引用(优惠券cAids字段增加该活动aid) 支持券包，如果是券包，将券包下的子券也标记为引用
// rpc CouponQuoteByActivity(CouponQuoteByActivityRequest) returns(CouponQuoteByActivityReply) {}
// //coupon:券被活动取消引用 支持券包，如果是券包，将券包下的子券也取消引用
// rpc CouponUnquoteByActivity(CouponUnquoteByActivityRequest) returns(CouponUnquoteByActivityReply) {}
//
// //coupon: 根据couponIds获取券
// rpc ListCouponsByCouponIds (ListCouponsByCouponIdsRequest) returns (ListCouponsByCouponIdsReply) {}
//
// //coupon:useMassCoupon
// rpc UseMassCoupon (UseMassCouponRequest) returns (UseMassCouponReply) {}
//
// //coupon: 创建卡包
// rpc AddPack(AddPackRequest) returns (AddPackReply) {}
//
// //coupon: 更新卡包
// rpc UpdatePack (UpdatePackRequest) returns (UpdatePackReply) {}
//
// //coupon:检查子券
// rpc CheckSubCoupons (checkSubCouponsRequest) returns (checkSubCouponsReply) {}
//
// //coupon:删除卡包
// rpc DeletePack (DeletePackRequest) returns (DeletePackReply) {}
//
// //coupon:刷新券包下的券
// rpc PackRefreshSubCoupons (PackRefreshSubCouponsRequest) returns (PackRefreshSubCouponsReply) {}
//
// //coupon:根据条件获取
// rpc ListCouponByConditions (ListCouponByConditionsRequest) returns (ListCouponByConditionsReply) {}
//
// SendCoupon : 发券
rpc SendCoupon (SendCouponRequest) returns (BoolReply);
//
// //UseC2U 消费使用券
// rpc UseC2U (UseC2URequest) returns (UseC2UReply) {}
//
// //CancelSendC2UByTrade 撤销发送券
// rpc CancelSendC2UByTrade (CancelSendC2UByTradeRequest) returns (CancelSendC2UByTradeReply) {}
//
// //合并用户的券帐户
// rpc MergeCouponAccount (MergeCouponAccountRequest) returns (MergeCouponAccountReply) {}
//
// //redis添加券账户
// rpc RedisC2UAdd(RedisC2UAddRequest) returns (RedisC2UAddReply) {}
//
// //redis查询券账户
// rpc RedisC2USelect(RedisC2USelectRequest) returns (RedisC2USelectReply) {}
//
// //redis更新券账户
// rpc RedisC2UUpdate(RedisC2UUpdateRequest) returns (RedisC2UUpdateReply) {}
//
// //redis删除券账户
// rpc RedisC2URemove(RedisC2URemoveRequest) returns (RedisC2URemoveReply) {}
//
// // 根据状态查询当前用户的优惠券列表
// rpc ListC2UCurrentCoupons(ListC2UCurrentCouponsRequest) returns (ListC2UCurrentCouponsReply) {}
//
// //券模板获取
// rpc RedisSelectCoupon(RedisSelectCouponRequest) returns (RedisSelectCouponReply) {}
//
// //券模板更新
// rpc RedisUpdateCoupon(RedisUpdateCouponRequest) returns (RedisUpdateCouponReply) {}
//
// //券模板删除
// rpc RedisRemoveCoupon(RedisRemoveCouponRequest) returns (RedisRemoveCouponReply) {}
//
// //券模板添加
// rpc RedisAddCoupon(RedisAddCouponRequest) returns (RedisAddCouponReply) {}
//
//
}
命令行，生成python rpc架构文件：
python3 -m grpc_tools.protoc -I. --python_out=. --grpc_python_out=. coupon.proto
生成后的两个文件：
coupon_pb2.py
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: coupon.proto import sys
_b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1'))
from google.protobuf import descriptor as _descriptor
from google.protobuf import message as _message
from google.protobuf import reflection as _reflection
from google.protobuf import symbol_database as _symbol_database
from google.protobuf import descriptor_pb2
# @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() DESCRIPTOR = _descriptor.FileDescriptor(
name='coupon.proto',
package='coupon',
syntax='proto3',
serialized_pb=_b('\n\x0c\x63oupon.proto\x12\x06\x63oupon\"?\n\nCouponInfo\x12\x10\n\x08\x43ouponId\x18\x01 \x01(\x03\x12\x11\n\tCouponNum\x18\x02 \x01(\x03\x12\x0c\n\x04\x43ode\x18\x03 \x01(\t\"\xae\x01\n\x11SendCouponRequest\x12\x0b\n\x03\x62id\x18\x01 \x01(\x03\x12\x0b\n\x03\x61id\x18\x02 \x01(\x03\x12\x0b\n\x03sid\x18\x03 \x01(\x03\x12\x0f\n\x07transId\x18\x04 \x01(\x03\x12\x0f\n\x07\x66romJob\x18\x05 \x01(\x08\x12\x0c\n\x04uids\x18\x06 \x03(\x03\x12%\n\tcouponids\x18\x07 \x03(\x0b\x32\x12.coupon.CouponInfo\x12\x0c\n\x04obid\x18\x08 \x01(\x03\x12\r\n\x05isBag\x18\t \x01(\x08\"<\n\tBoolReply\x12\x0f\n\x07\x65rrCode\x18\x01 \x01(\x03\x12\x0e\n\x06\x65rrMsg\x18\x02 \x01(\t\x12\x0e\n\x06result\x18\x03 \x01(\x08\x32\x44\n\x06\x63oupon\x12:\n\nSendCoupon\x12\x19.coupon.SendCouponRequest\x1a\x11.coupon.BoolReplyb\x06proto3')
) _COUPONINFO = _descriptor.Descriptor(
name='CouponInfo',
full_name='coupon.CouponInfo',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='CouponId', full_name='coupon.CouponInfo.CouponId', index=0,
number=1, type=3, cpp_type=2, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='CouponNum', full_name='coupon.CouponInfo.CouponNum', index=1,
number=2, type=3, cpp_type=2, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='Code', full_name='coupon.CouponInfo.Code', index=2,
number=3, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None, file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=24,
serialized_end=87,
) _SENDCOUPONREQUEST = _descriptor.Descriptor(
name='SendCouponRequest',
full_name='coupon.SendCouponRequest',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='bid', full_name='coupon.SendCouponRequest.bid', index=0,
number=1, type=3, cpp_type=2, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='aid', full_name='coupon.SendCouponRequest.aid', index=1,
number=2, type=3, cpp_type=2, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='sid', full_name='coupon.SendCouponRequest.sid', index=2,
number=3, type=3, cpp_type=2, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='transId', full_name='coupon.SendCouponRequest.transId', index=3,
number=4, type=3, cpp_type=2, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='fromJob', full_name='coupon.SendCouponRequest.fromJob', index=4,
number=5, type=8, cpp_type=7, label=1,
has_default_value=False, default_value=False,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='uids', full_name='coupon.SendCouponRequest.uids', index=5,
number=6, type=3, cpp_type=2, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='couponids', full_name='coupon.SendCouponRequest.couponids', index=6,
number=7, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='obid', full_name='coupon.SendCouponRequest.obid', index=7,
number=8, type=3, cpp_type=2, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='isBag', full_name='coupon.SendCouponRequest.isBag', index=8,
number=9, type=8, cpp_type=7, label=1,
has_default_value=False, default_value=False,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None, file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=90,
serialized_end=264,
) _BOOLREPLY = _descriptor.Descriptor(
name='BoolReply',
full_name='coupon.BoolReply',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='errCode', full_name='coupon.BoolReply.errCode', index=0,
number=1, type=3, cpp_type=2, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='errMsg', full_name='coupon.BoolReply.errMsg', index=1,
number=2, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='result', full_name='coupon.BoolReply.result', index=2,
number=3, type=8, cpp_type=7, label=1,
has_default_value=False, default_value=False,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
options=None, file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=266,
serialized_end=326,
) _SENDCOUPONREQUEST.fields_by_name['couponids'].message_type = _COUPONINFO
DESCRIPTOR.message_types_by_name['CouponInfo'] = _COUPONINFO
DESCRIPTOR.message_types_by_name['SendCouponRequest'] = _SENDCOUPONREQUEST
DESCRIPTOR.message_types_by_name['BoolReply'] = _BOOLREPLY
_sym_db.RegisterFileDescriptor(DESCRIPTOR) CouponInfo = _reflection.GeneratedProtocolMessageType('CouponInfo', (_message.Message,), dict(
DESCRIPTOR = _COUPONINFO,
__module__ = 'coupon_pb2'
# @@protoc_insertion_point(class_scope:coupon.CouponInfo)
))
_sym_db.RegisterMessage(CouponInfo) SendCouponRequest = _reflection.GeneratedProtocolMessageType('SendCouponRequest', (_message.Message,), dict(
DESCRIPTOR = _SENDCOUPONREQUEST,
__module__ = 'coupon_pb2'
# @@protoc_insertion_point(class_scope:coupon.SendCouponRequest)
))
_sym_db.RegisterMessage(SendCouponRequest) BoolReply = _reflection.GeneratedProtocolMessageType('BoolReply', (_message.Message,), dict(
DESCRIPTOR = _BOOLREPLY,
__module__ = 'coupon_pb2'
# @@protoc_insertion_point(class_scope:coupon.BoolReply)
))
_sym_db.RegisterMessage(BoolReply) _COUPON = _descriptor.ServiceDescriptor(
name='coupon',
full_name='coupon.coupon',
file=DESCRIPTOR,
index=0,
options=None,
serialized_start=328,
serialized_end=396,
methods=[
_descriptor.MethodDescriptor(
name='SendCoupon',
full_name='coupon.coupon.SendCoupon',
index=0,
containing_service=None,
input_type=_SENDCOUPONREQUEST,
output_type=_BOOLREPLY,
options=None,
),
])
_sym_db.RegisterServiceDescriptor(_COUPON) DESCRIPTOR.services_by_name['coupon'] = _COUPON # @@protoc_insertion_point(module_scope)
coupon_pb2_grpc.py
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc import coupon_pb2 as coupon__pb2 class couponStub(object):
"""
//消费使用券
message UseC2URequest {
int64 bid = 1;
int64 uid = 2;
int64 sid = 3;
int64 transId = 4;
repeated int64 c2uIds = 5;
string tradeType = 6; } message UseC2UReply {
int64 errCode = 1; //0值表示调用接口成功
string errMsg = 2;
string result = 3;
} //撤销发送券
message CancelSendC2UByTradeRequest {
int64 bid = 1;
int64 uid = 2;
int64 sid = 3;
int64 transId = 4;
string delType = 5;
int64 couponsNum = 6;
int64 sourceType = 7;
int64 repealTcId = 8; } message CancelSendC2UByTradeReply {
int64 errCode = 1; //0值表示调用接口成功
string errMsg = 2;
string result = 3;
} //合并用户的券帐户
message MergeCouponAccountRequest {
int64 bid = 1;
int64 fromUid = 2;
int64 toUid = 3;
int64 mid = 4;
} message MergeCouponAccountReply {
int64 errCode = 1; //0值表示调用接口成功
string errMsg = 2;
int32 result = 3;
} message RedisC2USelectRequest {
int64 bid = 1;
string c2uKey = 2;
string fields = 3;
string conditions = 4;
} message RedisC2USelectReply {
int64 errCode = 1; //0值表示调用接口成功
string errMsg = 2;
string result = 3;
} message RedisC2UUpdateRequest {
int64 bid = 1;
string c2uKey = 2;
string data = 3;
string conditions = 4;
} message RedisC2UUpdateReply {
int64 errCode = 1; //0值表示调用接口成功
string errMsg = 2;
bool result = 3;
} message RedisC2URemoveRequest {
int64 bid = 1;
string c2uKey = 2;
string conditions = 3;
} message RedisC2URemoveReply {
int64 errCode = 1; //0值表示调用接口成功
string errMsg = 2;
bool result = 3;
} //添加数据
message RedisC2UAddRequest {
int64 bid = 1;
string c2uKey = 2;
string data = 3;
string conditions = 4;
} message RedisC2UAddReply {
int64 errCode = 1; //0值表示调用接口成功
string errMsg = 2;
bool result = 3;
} //券模板redis获取
message RedisSelectCouponRequest {
int64 bid = 1;
string fields = 2;
string conditions = 3;
} message RedisSelectCouponReply {
int64 errCode = 1; //0值表示调用接口成功
string errMsg = 2;
string result = 3;
} message RedisUpdateCouponRequest {
int64 bid = 1;
string data = 2;
string conditions = 3;
} message RedisUpdateCouponReply {
int64 errCode = 1; //0值表示调用接口成功
string errMsg = 2;
bool result = 3;
} message RedisRemoveCouponRequest {
int64 bid = 1;
string conditions = 2;
} message RedisRemoveCouponReply {
int64 errCode = 1; //0值表示调用接口成功
string errMsg = 2;
bool result = 3;
} //添加数据
message RedisAddCouponRequest {
int64 bid = 1;
string data = 2;
string conditions = 3;
} message RedisAddCouponReply {
int64 errCode = 1; //0值表示调用接口成功
string errMsg = 2;
bool result = 3;
} """ def __init__(self, channel):
"""Constructor. Args:
channel: A grpc.Channel.
"""
self.SendCoupon = channel.unary_unary(
'/coupon.coupon/SendCoupon',
request_serializer=coupon__pb2.SendCouponRequest.SerializeToString,
response_deserializer=coupon__pb2.BoolReply.FromString,
) class couponServicer(object):
"""
//消费使用券
message UseC2URequest {
int64 bid = 1;
int64 uid = 2;
int64 sid = 3;
int64 transId = 4;
repeated int64 c2uIds = 5;
string tradeType = 6; } message UseC2UReply {
int64 errCode = 1; //0值表示调用接口成功
string errMsg = 2;
string result = 3;
} //撤销发送券
message CancelSendC2UByTradeRequest {
int64 bid = 1;
int64 uid = 2;
int64 sid = 3;
int64 transId = 4;
string delType = 5;
int64 couponsNum = 6;
int64 sourceType = 7;
int64 repealTcId = 8; } message CancelSendC2UByTradeReply {
int64 errCode = 1; //0值表示调用接口成功
string errMsg = 2;
string result = 3;
} //合并用户的券帐户
message MergeCouponAccountRequest {
int64 bid = 1;
int64 fromUid = 2;
int64 toUid = 3;
int64 mid = 4;
} message MergeCouponAccountReply {
int64 errCode = 1; //0值表示调用接口成功
string errMsg = 2;
int32 result = 3;
} message RedisC2USelectRequest {
int64 bid = 1;
string c2uKey = 2;
string fields = 3;
string conditions = 4;
} message RedisC2USelectReply {
int64 errCode = 1; //0值表示调用接口成功
string errMsg = 2;
string result = 3;
} message RedisC2UUpdateRequest {
int64 bid = 1;
string c2uKey = 2;
string data = 3;
string conditions = 4;
} message RedisC2UUpdateReply {
int64 errCode = 1; //0值表示调用接口成功
string errMsg = 2;
bool result = 3;
} message RedisC2URemoveRequest {
int64 bid = 1;
string c2uKey = 2;
string conditions = 3;
} message RedisC2URemoveReply {
int64 errCode = 1; //0值表示调用接口成功
string errMsg = 2;
bool result = 3;
} //添加数据
message RedisC2UAddRequest {
int64 bid = 1;
string c2uKey = 2;
string data = 3;
string conditions = 4;
} message RedisC2UAddReply {
int64 errCode = 1; //0值表示调用接口成功
string errMsg = 2;
bool result = 3;
} //券模板redis获取
message RedisSelectCouponRequest {
int64 bid = 1;
string fields = 2;
string conditions = 3;
} message RedisSelectCouponReply {
int64 errCode = 1; //0值表示调用接口成功
string errMsg = 2;
string result = 3;
} message RedisUpdateCouponRequest {
int64 bid = 1;
string data = 2;
string conditions = 3;
} message RedisUpdateCouponReply {
int64 errCode = 1; //0值表示调用接口成功
string errMsg = 2;
bool result = 3;
} message RedisRemoveCouponRequest {
int64 bid = 1;
string conditions = 2;
} message RedisRemoveCouponReply {
int64 errCode = 1; //0值表示调用接口成功
string errMsg = 2;
bool result = 3;
} //添加数据
message RedisAddCouponRequest {
int64 bid = 1;
string data = 2;
string conditions = 3;
} message RedisAddCouponReply {
int64 errCode = 1; //0值表示调用接口成功
string errMsg = 2;
bool result = 3;
} """ def SendCoupon(self, request, context):
"""
// 撤销消费使用券
rpc UnsetUseC2U (UnsetUseC2URequest) returns (UnsetUseC2UReply) {} // 检查发送的券是否可撤销
rpc CheckCancelSendC2UByTrade(CheckCancelSendC2UByTradeRequest) returns (CheckCancelSendC2UByTradeReply) {} // 查询当前用户所有的优惠券列表(相同券需要合并)
rpc ListC2U (ListC2URequest) returns (ListC2UReply) {} // 查询当前用户所有可用的优惠券列表
rpc ListC2UCanUse (ListC2UCanUseRequest) returns (ListC2UCanUseReply) {} // 通过c2uIds 拉取用户账户信息
rpc ListC2UByC2UIds(ListC2UByC2UIdsRequest) returns (ListC2UByC2UIdsReply) {} // 检查交易发送的券是否可撤销
rpc CheckCancelSendC2UByConsumeTrade (CheckCancelSendC2UByConsumeTradeRequest) returns (CheckCancelSendC2UByConsumeTradeReply) {} // 检查发送的券是否可撤销
rpc CheckCancelSendC2UByTradeMulti (CheckCancelSendC2UByTradeMultiRequest) returns (CheckCancelSendC2UByTradeMultiReply) {} // 从指定用户账户中收回指定券 - 已使用的券无法被收回，将自动跳过
rpc RecoverCouponsByC2uIds (RecoverCouponsByC2uIdsRequest) returns (RecoverCouponsByC2uIdsReply) {} // 更新券账户信息
rpc UpdateC2U (UpdateC2URequest) returns (UpdateC2UReply) {} // 添加券账户信息
rpc AddC2U (AddC2URequest) returns (AddC2UReply) {} // 删除券账户
rpc DeleteC2U (DeleteC2URequest) returns (DeleteC2UReply) {} // 根据条件获取券账户
rpc ListC2UByConditions (ListC2UByConditionsRequest) returns (ListC2UByConditionsReply) {} // 根据条件获取券账户 从mysql 直接获取
rpc ListC2UByMySQL (ListC2UByMySQLRequest) returns (ListC2UByMySQLReply) {} // 查询当前用户所有未来可用的优惠券列表
rpc ListC2UFutureCanUse (ListC2UFutureCanUseRequest) returns (ListC2UFutureCanUseReply) {} // 查询当前用户所有未来可用的优惠券列表
rpc ListC2UFutureCanUseForPos (ListC2UFutureCanUseForPosRequest) returns (ListC2UFutureCanUseForPosReply) {} // 软pos消费页面Pos_ConsumeController的indexAction调用的方法
rpc GetC2uForPosConsume (GetC2uForPosConsumeRequest) returns (GetC2uForPosConsumeReply) {} // 用户领取卡券
rpc UserGetCoupon (UserGetCouponRequest) returns (UserGetCouponReply) {} // 查看券包有没有发完
rpc IsCouponSendComplate(IsCouponSendComplateRequest) returns (IsCouponSendComplateReply) {}
// 查询当前用户所有可用的优惠券搜索
rpc UserCanUseConditions (UserCanUseConditionsRequest) returns (UserCanUseConditionsReply) {}
//userOverCoupon
rpc UserOverCoupon (UserOverCouponRequest) returns (UserOverCouponReply) {} //coupon:更新券模板
rpc UpdateCoupon (UpdateCouponRequest) returns (UpdateCouponReply) {} //coupon:删除券模板
rpc DeleteCoupon (DeleteCouponRequest) returns (DeleteCouponReply) {} //coupon:根据条件获取
rpc ListAllCouponByConditions(ListAllCouponByConditionsRequest) returns (ListAllCouponByConditionsReply) {} //coupon: 统计优惠券数量
rpc CountCouponNums (CountCouponNumsRequest) returns (CountCouponNumsReply) {} //coupon:券被活动引用(优惠券cAids字段增加该活动aid) 支持券包，如果是券包，将券包下的子券也标记为引用
rpc CouponQuoteByActivity(CouponQuoteByActivityRequest) returns(CouponQuoteByActivityReply) {}
//coupon:券被活动取消引用 支持券包，如果是券包，将券包下的子券也取消引用
rpc CouponUnquoteByActivity(CouponUnquoteByActivityRequest) returns(CouponUnquoteByActivityReply) {} //coupon: 根据couponIds获取券
rpc ListCouponsByCouponIds (ListCouponsByCouponIdsRequest) returns (ListCouponsByCouponIdsReply) {} //coupon:useMassCoupon
rpc UseMassCoupon (UseMassCouponRequest) returns (UseMassCouponReply) {} //coupon: 创建卡包
rpc AddPack(AddPackRequest) returns (AddPackReply) {} //coupon: 更新卡包
rpc UpdatePack (UpdatePackRequest) returns (UpdatePackReply) {} //coupon:检查子券
rpc CheckSubCoupons (checkSubCouponsRequest) returns (checkSubCouponsReply) {} //coupon:删除卡包
rpc DeletePack (DeletePackRequest) returns (DeletePackReply) {} //coupon:刷新券包下的券
rpc PackRefreshSubCoupons (PackRefreshSubCouponsRequest) returns (PackRefreshSubCouponsReply) {} //coupon:根据条件获取
rpc ListCouponByConditions (ListCouponByConditionsRequest) returns (ListCouponByConditionsReply) {} SendCoupon : 发券 //UseC2U 消费使用券
rpc UseC2U (UseC2URequest) returns (UseC2UReply) {} //CancelSendC2UByTrade 撤销发送券
rpc CancelSendC2UByTrade (CancelSendC2UByTradeRequest) returns (CancelSendC2UByTradeReply) {} //合并用户的券帐户
rpc MergeCouponAccount (MergeCouponAccountRequest) returns (MergeCouponAccountReply) {} //redis添加券账户
rpc RedisC2UAdd(RedisC2UAddRequest) returns (RedisC2UAddReply) {} //redis查询券账户
rpc RedisC2USelect(RedisC2USelectRequest) returns (RedisC2USelectReply) {} //redis更新券账户
rpc RedisC2UUpdate(RedisC2UUpdateRequest) returns (RedisC2UUpdateReply) {} //redis删除券账户
rpc RedisC2URemove(RedisC2URemoveRequest) returns (RedisC2URemoveReply) {} // 根据状态查询当前用户的优惠券列表
rpc ListC2UCurrentCoupons(ListC2UCurrentCouponsRequest) returns (ListC2UCurrentCouponsReply) {} //券模板获取
rpc RedisSelectCoupon(RedisSelectCouponRequest) returns (RedisSelectCouponReply) {} //券模板更新
rpc RedisUpdateCoupon(RedisUpdateCouponRequest) returns (RedisUpdateCouponReply) {} //券模板删除
rpc RedisRemoveCoupon(RedisRemoveCouponRequest) returns (RedisRemoveCouponReply) {} //券模板添加
rpc RedisAddCoupon(RedisAddCouponRequest) returns (RedisAddCouponReply) {} """
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!') def add_couponServicer_to_server(servicer, server):
rpc_method_handlers = {
'SendCoupon': grpc.unary_unary_rpc_method_handler(
servicer.SendCoupon,
request_deserializer=coupon__pb2.SendCouponRequest.FromString,
response_serializer=coupon__pb2.BoolReply.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'coupon.coupon', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
自己新建一个文件，来调用接口：
# -*- coding: utf-8 -*-
import grpc
import coupon_pb2,coupon_pb2_grpc _HOST = '60.205.x.x'
_PORT = '' def run():
conn = grpc.insecure_channel(_HOST + ':' + _PORT,)
client = coupon_pb2_grpc.couponStub(channel=conn)
#couponInfo是个数组结构体
info = coupon_pb2.CouponInfo()
info.CouponId = 12345692#1 券模版id
info.CouponNum = 1 #发券数量
#1061693987532739 args = coupon_pb2.SendCouponRequest()
args.bid = 1991243684#
args.aid = 11111111
args.sid = 3691394527#
args.uids.append(31609394374409511) #因uids是数组，所以这里单个要用append增加值，多个用extend([111,3333])
args.couponids.extend([info]) #info是个结构体
print(args) response = client.SendCoupon(args)
print(response.errCode) #正确，返回0
print(response.errMsg) if __name__ == '__main__':
run()
输出结果：
D:\python36\python3.exe D:/untitled4/sendCoupon-grpc.py
bid: 1991243684
aid: 11111111
sid: 3691394527
uids: 31609394374409511
couponids {
CouponId: 12345692
CouponNum: 1
} 0 Process finished with exit code 0