- update wnfuwu

service/wnfuwu/api.go

@@ -0,0 +1 @@
+package wnfuwu

service/wnfuwu/check.go

@@ -0,0 +1,52 @@
+package wnfuwu
+
+import (
+	"context"
+	"github.com/dtapps/go-library/utils/gojson"
+	"github.com/dtapps/go-library/utils/gorequest"
+)
+
+type CheckResponse struct {
+	Errno  int64  `json:"errno"`  // 错误码，0代表成功，非0代表失败
+	Errmsg string `json:"errmsg"` // 错误描述
+	Data   struct {
+		OrderNumber  string  `json:"order_number"`  // 系统定单号
+		OutTradeNum  string  `json:"out_trade_num"` // 商户订单号
+		CreateTime   string  `json:"create_time"`   // 下单时间
+		Mobile       string  `json:"mobile"`        // 手机号
+		ProductId    string  `json:"product_id"`    // 产品ID
+		ChargeAmount float64 `json:"charge_amount"` // 充值成功面额
+		ChargeKami   string  `json:"charge_kami"`   // 卡密流水
+		State        string  `json:"state"`         // 充值状态：-1取消，0充值中 ，1充值成功，2充值失败，3部分成功
+	} `json:"data,omitempty"`
+}
+
+type CheckResult struct {
+	Result CheckResponse      // 结果
+	Body   []byte             // 内容
+	Http   gorequest.Response // 请求
+}
+
+func newCheckResult(result CheckResponse, body []byte, http gorequest.Response) *CheckResult {
+	return &CheckResult{Result: result, Body: body, Http: http}
+}
+
+// Check 自发查询订单状态
+// https://www.showdoc.com.cn/dyr/9227006175502841
+func (c *Client) Check(ctx context.Context, outTradeNums string, notMustParams ...gorequest.Params) (*CheckResult, error) {
+	// 参数
+	params := gorequest.NewParamsWith(notMustParams...)
+	params.Set("userid", c.GetUserId())
+	if outTradeNums != "" {
+		params.Set("out_trade_nums", outTradeNums)
+	}
+	// 请求
+	request, err := c.request(ctx, apiUrl+"/index/check", params)
+	if err != nil {
+		return newCheckResult(CheckResponse{}, request.ResponseBody, request), err
+	}
+	// 定义
+	var response CheckResponse
+	err = gojson.Unmarshal(request.ResponseBody, &response)
+	return newCheckResult(response, request.ResponseBody, request), err
+}

service/wnfuwu/client.go

@@ -0,0 +1,38 @@
+package wnfuwu
+
+import (
+	"github.com/dtapps/go-library/utils/golog"
+	"github.com/dtapps/go-library/utils/gorequest"
+)
+
+// ClientConfig 实例配置
+type ClientConfig struct {
+	UserId int64  // 商户ID
+	ApiKey string // 秘钥
+}
+
+// Client 实例
+type Client struct {
+	requestClient *gorequest.App // 请求服务
+	config        struct {
+		userId int64  // 商户ID
+		apiKey string // 秘钥
+	}
+	log struct {
+		status bool             // 状态
+		client *golog.ApiClient // 日志服务
+	}
+}
+
+// NewClient 创建实例化
+func NewClient(config *ClientConfig) (*Client, error) {
+
+	c := &Client{}
+
+	c.config.userId = config.UserId
+	c.config.apiKey = config.ApiKey
+
+	c.requestClient = gorequest.NewHttp()
+
+	return c, nil
+}

service/wnfuwu/config.go

@@ -0,0 +1,19 @@
+package wnfuwu
+
+import "github.com/dtapps/go-library/utils/golog"
+
+// ConfigApp 配置
+func (c *Client) ConfigApp(userId int64, apiKey string) *Client {
+	c.config.userId = userId
+	c.config.apiKey = apiKey
+	return c
+}
+
+// ConfigApiClientFun 日志配置
+func (c *Client) ConfigApiClientFun(apiClientFun golog.ApiClientFun) {
+	apiClient := apiClientFun()
+	if apiClient != nil {
+		c.log.client = apiClient
+		c.log.status = true
+	}
+}

service/wnfuwu/const.go

@@ -0,0 +1,9 @@
+package wnfuwu
+
+const (
+	apiUrl = "http://wn.wnfuwu.cn/yrapi.php"
+)
+
+const (
+	LogTable = "wnfuwu"
+)

service/wnfuwu/elecity.go

@@ -0,0 +1,52 @@
+package wnfuwu
+
+import (
+	"context"
+	"github.com/dtapps/go-library/utils/gojson"
+	"github.com/dtapps/go-library/utils/gorequest"
+)
+
+type ElecityResponse struct {
+	Errno  int64  `json:"errno"`  // 错误码，0代表成功，非0代表失败
+	Errmsg string `json:"errmsg"` // 错误描述
+	Data   []struct {
+		Id        int64  `json:"id,omitempty"`
+		CityName  string `json:"city_name"`  // 地区名称
+		Sort      int64  `json:"sort"`       // 排序
+		Initial   string `json:"initial"`    // 首字母
+		NeedYtype int64  `json:"need_ytype"` // 是否三要素认证
+		NeedCity  int64  `json:"need_city"`  // 是否需要选择城市（当此开关打开以后才有下面的城市列表）
+		City      []struct {
+			Id       int64  `json:"id,omitempty"`
+			CityName string `json:"city_name"` // 城市名称
+			Initial  string `json:"initial"`   // 首字母
+		} `json:"city"` // 支持的地级市
+	} `json:"data,omitempty"`
+}
+
+type ElecityResult struct {
+	Result ElecityResponse    // 结果
+	Body   []byte             // 内容
+	Http   gorequest.Response // 请求
+}
+
+func newElecityResult(result ElecityResponse, body []byte, http gorequest.Response) *ElecityResult {
+	return &ElecityResult{Result: result, Body: body, Http: http}
+}
+
+// Elecity 电费支持地区查询
+// https://www.showdoc.com.cn/dyr/9227008514209156
+func (c *Client) Elecity(ctx context.Context, notMustParams ...gorequest.Params) (*ElecityResult, error) {
+	// 参数
+	params := gorequest.NewParamsWith(notMustParams...)
+	params.Set("userid", c.GetUserId())
+	// 请求
+	request, err := c.request(ctx, apiUrl+"/index/elecity", params)
+	if err != nil {
+		return newElecityResult(ElecityResponse{}, request.ResponseBody, request), err
+	}
+	// 定义
+	var response ElecityResponse
+	err = gojson.Unmarshal(request.ResponseBody, &response)
+	return newElecityResult(response, request.ResponseBody, request), err
+}

service/wnfuwu/get.go

@@ -0,0 +1,15 @@
+package wnfuwu
+
+import "github.com/dtapps/go-library/utils/golog"
+
+func (c *Client) GetUserId() int64 {
+	return c.config.userId
+}
+
+func (c *Client) GetApiKey() string {
+	return c.config.apiKey
+}
+
+func (c *Client) GetLog() *golog.ApiClient {
+	return c.log.client
+}

service/wnfuwu/price.go

@@ -0,0 +1,55 @@
+package wnfuwu
+
+import (
+	"context"
+	"github.com/dtapps/go-library/utils/gojson"
+	"github.com/dtapps/go-library/utils/gorequest"
+)
+
+type PriceResponse struct {
+	Errno  int64  `json:"errno"`  // 错误码，0代表成功，非0代表失败
+	Errmsg string `json:"errmsg"` // 错误描述
+	Data   struct {
+		Name     string `json:"name"`      // 产品名称
+		Desc     string `json:"desc"`      // 产品说明
+		ApiOpen  string `json:"api_open"`  // 自动充值
+		Isp      string `json:"isp"`       // 运营商集合（话费、流量有效），1移动,2电信,3联通,4虚拟
+		YsTag    string `json:"ys_tag"`    // 标签
+		Price    string `json:"price"`     // 价格，下单扣费金额
+		YPrice   string `json:"y_price"`   // 原价
+		MaxPrice string `json:"max_price"` // 封顶价格
+		Type     string `json:"type"`      // 产品类型ID
+		CateName string `json:"cate_name"` // 产品分类名称
+		TypeName string `json:"type_name"` // 产品类型名称
+	} `json:"data,omitempty"`
+}
+
+type PriceResult struct {
+	Result PriceResponse      // 结果
+	Body   []byte             // 内容
+	Http   gorequest.Response // 请求
+}
+
+func newPriceResult(result PriceResponse, body []byte, http gorequest.Response) *PriceResult {
+	return &PriceResult{Result: result, Body: body, Http: http}
+}
+
+// Price 产品ID查询【新增】
+// https://www.showdoc.com.cn/dyr/9757701226597233
+func (c *Client) Price(ctx context.Context, id int64, notMustParams ...gorequest.Params) (*PriceResult, error) {
+	// 参数
+	params := gorequest.NewParamsWith(notMustParams...)
+	params.Set("userid", c.GetUserId())
+	if id != 0 {
+		params.Set("id", id)
+	}
+	// 请求
+	request, err := c.request(ctx, apiUrl+"/index/price", params)
+	if err != nil {
+		return newPriceResult(PriceResponse{}, request.ResponseBody, request), err
+	}
+	// 定义
+	var response PriceResponse
+	err = gojson.Unmarshal(request.ResponseBody, &response)
+	return newPriceResult(response, request.ResponseBody, request), err
+}

service/wnfuwu/product.go

@@ -0,0 +1,77 @@
+package wnfuwu
+
+import (
+	"context"
+	"github.com/dtapps/go-library/utils/gojson"
+	"github.com/dtapps/go-library/utils/gorequest"
+)
+
+type ProductResponse struct {
+	Errno  int64  `json:"errno"`  // 错误码，0代表成功，非0代表失败
+	Errmsg string `json:"errmsg"` // 错误描述
+	Data   []struct {
+		Id       int64  `json:"id"`   // 分类ID
+		Cate     string `json:"cate"` // 分类名称
+		Sort     int64  `json:"sort"` // 排序
+		Type     int64  `json:"type"` // 产品类型ID
+		Products []struct {
+			Id           int64   `json:"id"`   // 产品ID,下单报文中用此参数
+			Name         string  `json:"name"` // 产品名称
+			Yname        string  `json:"yname,omitempty"`
+			Desc         string  `json:"desc"`     // 产品说明
+			ApiOpen      int64   `json:"api_open"` // 自动充值
+			Isp          string  `json:"isp"`      // 运营商集合（话费、流量有效），1移动,2电信,3联通,4虚拟
+			YsTag        string  `json:"ys_tag"`   // 标签
+			Price        string  `json:"price"`    // 价格，下单扣费金额
+			ShowStyle    int64   `json:"show_style,omitempty"`
+			CateId       int64   `json:"cate_id,omitempty"`
+			DelayApi     string  `json:"delay_api,omitempty"`
+			YPrice       float64 `json:"y_price"`   // 原价
+			MaxPrice     string  `json:"max_price"` // 封顶价格
+			Type         int64   `json:"type"`      // 产品类型ID
+			AllowPro     string  `json:"allow_pro,omitempty"`
+			AllowCity    string  `json:"allow_city,omitempty"`
+			ForbidPro    string  `json:"forbid_pro,omitempty"`
+			ForbidCity   string  `json:"forbid_city,omitempty"`
+			JmapiId      int64   `json:"jmapi_id,omitempty"`
+			JmapiParamId int64   `json:"jmapi_param_id,omitempty"`
+			IsJiema      int64   `json:"is_jiema,omitempty"`
+			CateName     string  `json:"cate_name"` // 产品分类名称
+			TypeName     string  `json:"type_name"` // 产品类型名称
+			TypecId      int64   `json:"typec_id,omitempty"`
+		} `json:"products"` // 产品列表
+	} `json:"data,omitempty"`
+}
+
+type ProductResult struct {
+	Result ProductResponse    // 结果
+	Body   []byte             // 内容
+	Http   gorequest.Response // 请求
+}
+
+func newProductResult(result ProductResponse, body []byte, http gorequest.Response) *ProductResult {
+	return &ProductResult{Result: result, Body: body, Http: http}
+}
+
+// Product 获取产品
+// https://www.showdoc.com.cn/dyr/9227005691961526
+func (c *Client) Product(ctx context.Context, Type, cateId int64, notMustParams ...gorequest.Params) (*ProductResult, error) {
+	// 参数
+	params := gorequest.NewParamsWith(notMustParams...)
+	params.Set("userid", c.GetUserId())
+	if Type != 0 {
+		params.Set("type", Type)
+	}
+	if cateId != 0 {
+		params.Set("cate_id", cateId)
+	}
+	// 请求
+	request, err := c.request(ctx, apiUrl+"/index/product", params)
+	if err != nil {
+		return newProductResult(ProductResponse{}, request.ResponseBody, request), err
+	}
+	// 定义
+	var response ProductResponse
+	err = gojson.Unmarshal(request.ResponseBody, &response)
+	return newProductResult(response, request.ResponseBody, request), err
+}

service/wnfuwu/recharge.go

@@ -0,0 +1,47 @@
+package wnfuwu
+
+import (
+	"context"
+	"github.com/dtapps/go-library/utils/gojson"
+	"github.com/dtapps/go-library/utils/gorequest"
+)
+
+type RechargeResponse struct {
+	Errno  int64  `json:"errno"`  // 错误码，0代表成功，非0代表失败
+	Errmsg string `json:"errmsg"` // 错误描述
+	Data   struct {
+		OrderNumber string `json:"order_number"`  // 系统定单号
+		Mobile      string `json:"mobile"`        // 充值手机号
+		ProductId   string `json:"product_id"`    // 产品ID
+		TotalPrice  string `json:"total_price"`   // 消费金额
+		OutTradeNum string `json:"out_trade_num"` // 商户订单号
+		Title       string `json:"title"`         // 充值产品说明
+	} `json:"data"`
+}
+
+type RechargeResult struct {
+	Result RechargeResponse   // 结果
+	Body   []byte             // 内容
+	Http   gorequest.Response // 请求
+}
+
+func newRechargeResult(result RechargeResponse, body []byte, http gorequest.Response) *RechargeResult {
+	return &RechargeResult{Result: result, Body: body, Http: http}
+}
+
+// Recharge 充值提交接口
+// https://www.showdoc.com.cn/dyr/9227003154511692
+func (c *Client) Recharge(ctx context.Context, notMustParams ...gorequest.Params) (*RechargeResult, error) {
+	// 参数
+	params := gorequest.NewParamsWith(notMustParams...)
+	params.Set("userid", c.GetUserId())
+	// 请求
+	request, err := c.request(ctx, apiUrl+"/index/recharge", params)
+	if err != nil {
+		return newRechargeResult(RechargeResponse{}, request.ResponseBody, request), err
+	}
+	// 定义
+	var response RechargeResponse
+	err = gojson.Unmarshal(request.ResponseBody, &response)
+	return newRechargeResult(response, request.ResponseBody, request), err
+}

service/wnfuwu/remove.go

@@ -0,0 +1,43 @@
+package wnfuwu
+
+import (
+	"context"
+	"github.com/dtapps/go-library/utils/gojson"
+	"github.com/dtapps/go-library/utils/gorequest"
+)
+
+type RemoveResponse struct {
+	Errno  int64    `json:"errno"`  // 错误码，0代表成功，非0代表失败
+	Errmsg string   `json:"errmsg"` // 错误描述
+	Data   struct{} `json:"data"`
+}
+
+type RemoveResult struct {
+	Result RemoveResponse     // 结果
+	Body   []byte             // 内容
+	Http   gorequest.Response // 请求
+}
+
+func newRemoveResult(result RemoveResponse, body []byte, http gorequest.Response) *RemoveResult {
+	return &RemoveResult{Result: result, Body: body, Http: http}
+}
+
+// Remove 申请撤单【已正式上线】
+// https://www.showdoc.com.cn/dyr/9745453200292104
+func (c *Client) Remove(ctx context.Context, outTradeNums string, notMustParams ...gorequest.Params) (*RemoveResult, error) {
+	// 参数
+	params := gorequest.NewParamsWith(notMustParams...)
+	params.Set("userid", c.GetUserId())
+	if outTradeNums != "" {
+		params.Set("out_trade_nums", outTradeNums)
+	}
+	// 请求
+	request, err := c.request(ctx, apiUrl+"/index/remove", params)
+	if err != nil {
+		return newRemoveResult(RemoveResponse{}, request.ResponseBody, request), err
+	}
+	// 定义
+	var response RemoveResponse
+	err = gojson.Unmarshal(request.ResponseBody, &response)
+	return newRemoveResult(response, request.ResponseBody, request), err
+}

service/wnfuwu/request.go

@@ -0,0 +1,42 @@
+package wnfuwu
+
+import (
+	"context"
+	"github.com/dtapps/go-library"
+	"github.com/dtapps/go-library/utils/gorequest"
+)
+
+// 请求接口
+func (c *Client) request(ctx context.Context, url string, params map[string]interface{}) (gorequest.Response, error) {
+
+	// 签名
+	params["sign"] = c.sign(params)
+
+	// 创建请求
+	client := c.requestClient
+
+	// 设置请求地址
+	client.SetUri(url)
+
+	// 设置FORM格式
+	client.SetContentTypeForm()
+
+	// 设置参数
+	client.SetParams(params)
+
+	// 传入SDk版本
+	client.AfferentSdkUserVersion(go_library.Version())
+
+	// 发起请求
+	request, err := client.Post(ctx)
+	if err != nil {
+		return gorequest.Response{}, err
+	}
+
+	// 日志
+	if c.log.status {
+		go c.log.client.Middleware(ctx, request, go_library.Version())
+	}
+
+	return request, err
+}

service/wnfuwu/sign.go

@@ -0,0 +1,23 @@
+package wnfuwu
+
+import (
+	"fmt"
+	"github.com/dtapps/go-library/utils/gomd5"
+	"github.com/dtapps/go-library/utils/gostring"
+	"sort"
+)
+
+// 签名
+func (c *Client) sign(params map[string]interface{}) string {
+	var keys []string
+	for k := range params {
+		keys = append(keys, k)
+	}
+	sort.Strings(keys)
+	signStr := ""
+	for _, key := range keys {
+		signStr += fmt.Sprintf("%s=%s&", key, gostring.ToString(params[key]))
+	}
+	signStr += fmt.Sprintf("apikey=%s", c.GetApiKey())
+	return gomd5.ToUpper(signStr)
+}

service/wnfuwu/typecate.go

@@ -0,0 +1,48 @@
+package wnfuwu
+
+import (
+	"context"
+	"github.com/dtapps/go-library/utils/gojson"
+	"github.com/dtapps/go-library/utils/gorequest"
+)
+
+type TypecateResponse struct {
+	Errno  int64  `json:"errno"`  // 错误码，0代表成功，非0代表失败
+	Errmsg string `json:"errmsg"` // 错误描述
+	Data   []struct {
+		Id       int64  `json:"id"`        // 产品类型id
+		TypeName string `json:"type_name"` // 产品类型名称
+		Cate     []struct {
+			Id   int64  `json:"id"`        // 分类ID
+			Cate string `json:"type_name"` // 分类名称
+			Type int64  `json:"type"`      // 产品类型ID
+		} `json:"cate"` // 分类列表
+	} `json:"data,omitempty"`
+}
+
+type TypecateResult struct {
+	Result TypecateResponse   // 结果
+	Body   []byte             // 内容
+	Http   gorequest.Response // 请求
+}
+
+func newTypecateResult(result TypecateResponse, body []byte, http gorequest.Response) *TypecateResult {
+	return &TypecateResult{Result: result, Body: body, Http: http}
+}
+
+// Typecate 获取产品类型和产品分类
+// https://www.showdoc.com.cn/dyr/9227005390454727
+func (c *Client) Typecate(ctx context.Context, notMustParams ...gorequest.Params) (*TypecateResult, error) {
+	// 参数
+	params := gorequest.NewParamsWith(notMustParams...)
+	params.Set("userid", c.GetUserId())
+	// 请求
+	request, err := c.request(ctx, apiUrl+"/index/typecate", params)
+	if err != nil {
+		return newTypecateResult(TypecateResponse{}, request.ResponseBody, request), err
+	}
+	// 定义
+	var response TypecateResponse
+	err = gojson.Unmarshal(request.ResponseBody, &response)
+	return newTypecateResult(response, request.ResponseBody, request), err
+}

service/wnfuwu/user.go

@@ -0,0 +1,44 @@
+package wnfuwu
+
+import (
+	"context"
+	"github.com/dtapps/go-library/utils/gojson"
+	"github.com/dtapps/go-library/utils/gorequest"
+)
+
+type UserResponse struct {
+	Errno  int64  `json:"errno"`  // 错误码，0代表成功，非0代表失败
+	Errmsg string `json:"errmsg"` // 错误描述
+	Data   struct {
+		Id       int64  `json:"id"`       // userid
+		Username string `json:"username"` // 名称
+		Balance  string `json:"balance"`  // 余额
+	} `json:"data,omitempty"`
+}
+
+type UserResult struct {
+	Result UserResponse       // 结果
+	Body   []byte             // 内容
+	Http   gorequest.Response // 请求
+}
+
+func newUserResult(result UserResponse, body []byte, http gorequest.Response) *UserResult {
+	return &UserResult{Result: result, Body: body, Http: http}
+}
+
+// User 查询用户信息
+// https://www.showdoc.com.cn/dyr/9227004018562421
+func (c *Client) User(ctx context.Context, notMustParams ...gorequest.Params) (*UserResult, error) {
+	// 参数
+	params := gorequest.NewParams()
+	params.Set("userid", c.GetUserId())
+	// 请求
+	request, err := c.request(ctx, apiUrl+"/index/user", params)
+	if err != nil {
+		return newUserResult(UserResponse{}, request.ResponseBody, request), err
+	}
+	// 定义
+	var response UserResponse
+	err = gojson.Unmarshal(request.ResponseBody, &response)
+	return newUserResult(response, request.ResponseBody, request), err
+}