init

Author: 52fhy

Diff for: .gitignore

@@ -0,0 +1 @@
+.idea

Diff for: LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2019 geek-go
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

Diff for: README.md

@@ -0,0 +1,39 @@
+# hwpush
+华为push
+
+由于官方没有推出Go版本的推送SDK，故自己实现了。支持：
+
+- 按cid单推
+- 按cid群推
+
+全推不支持，官方接口没有提供全推。  
+
+
+## 使用
+
+安装：
+``` bash
+go get https://github.com/geek-go/hwpush
+```
+
+SDK 测试（使用前先打开`hwpush_test.go`配置appid等参数）：
+``` bash
+# 测试单推
+go test -v  -run="^TestHwPush_SendByCid$" 
+
+# 测试群推
+go test -v  -run="^TestHwPush_SendByCids$" 
+```
+
+其它例子参照 `hwpush_test.go` 的调用。
+
+> 测试用例里针对SDK进行了一些封装，大家可以参考快速实现。
+
+## 如何参与该项目
+
+如果需要增加个推其它接口的实现，请参考`push_send`实现。规范：
+
+- 每个接口对应一个文件
+- 每个文件均包含接口请求结构体、接口响应结构体、接口调用的实现
+- 增加测试用例
+- 注意避免过度封装，以免使用者困惑

Diff for: const.go

@@ -0,0 +1,9 @@
+package huawei
+
+const (
+	TOKEN_URL = "https://login.cloud.huawei.com/oauth2/v2/token"
+	PUSH_URL  = "https://api.push.hicloud.com/pushsend.do"
+)
+
+//流控：https://club.huawei.com/thread-16930815-1-2.html
+//Push SDK-服务端常见问题 https://club.huawei.com/thread-10204980-1-1.html

Diff for: httpclient.go

@@ -0,0 +1,79 @@
+package huawei
+
+import (
+	"io/ioutil"
+	"net/http"
+	"net/url"
+	"strconv"
+	"strings"
+)
+
+const (
+	NSP_STATUS_6   = 6
+	NSP_STATUS_102 = 102
+	NSP_STATUS_105 = 105
+	NSP_STATUS_111 = 111
+	NSP_STATUS_112 = 112
+	NSP_STATUS_113 = 113
+	NSP_STATUS_114 = 114
+	NSP_STATUS_199 = 199
+	NSP_STATUS_403 = 403
+)
+
+var NSP_STATUS_MSG = map[int]string{
+	NSP_STATUS_6:   "session过期",
+	NSP_STATUS_102: "无效的SESSION_KEY",
+	NSP_STATUS_105: "参数错误",
+	NSP_STATUS_111: "系统、服务处理忙",
+	NSP_STATUS_112: "找不到对应服务",
+	NSP_STATUS_113: "请求服务失败",
+	NSP_STATUS_114: "服务不可达、无路由",
+	NSP_STATUS_199: "未知错误",
+	NSP_STATUS_403: "无权限",
+}
+
+//对方业务异常
+type BizErr struct {
+	Errno  int    `json:"errno"`
+	Errmsg string `json:"errmsg"`
+}
+
+func NewBizErr(errno int, errmsg string) *BizErr {
+	return &BizErr{
+		Errno:  errno,
+		Errmsg: errmsg,
+	}
+}
+
+//post请求
+func SendFormPost(url string, data url.Values) ([]byte, error, *BizErr) {
+	body := ioutil.NopCloser(strings.NewReader(data.Encode()))
+	response, err := http.Post(url, "application/x-www-form-urlencoded", body)
+	if err != nil {
+
+		return []byte(""), err, nil
+	}
+	defer response.Body.Close()
+
+	//HTTP协议错误码处理
+	if response.StatusCode == 500 {
+		return []byte(""), nil, NewBizErr(response.StatusCode, "推送服务器系统错误")
+	}
+
+	if response.StatusCode == 503 {
+		return []byte(""), nil, NewBizErr(response.StatusCode, "流量控制错误，发送流量过高")
+	}
+
+	//系统级错误码(通过扩展HTTP协议头 NSP_STATUS)
+	NSP_STATUS := response.Header.Get("NSP_STATUS")
+	NSP_STATUS_INT, _ := strconv.Atoi(NSP_STATUS)
+	if NSP_STATUS_INT != 0 {
+		return []byte(""), nil, NewBizErr(NSP_STATUS_INT, NSP_STATUS_MSG[NSP_STATUS_INT])
+	}
+
+	result, err := ioutil.ReadAll(response.Body)
+	if err != nil {
+		return []byte(""), err, nil
+	}
+	return result, err, nil
+}

Diff for: hwpush_test.go

@@ -0,0 +1,165 @@
+package huawei
+
+import (
+	"encoding/json"
+	"errors"
+	"fmt"
+	"os"
+	"testing"
+)
+
+var Cfg = &HwpushConfig{
+	AppId:     "",
+	AppSecret: "",
+	Package:   "",
+}
+
+//测试单推
+func TestHwPush_SendByCid(t *testing.T) {
+	igetui, err := NewHuawei(Cfg)
+	if err != nil {
+		t.Error(err)
+		os.Exit(1)
+	}
+
+	cid := "xxx"
+	payLoad := Payload{"这是测试title", "这是测试内容", "1", ""}
+	err = igetui.SendByCid(cid, &payLoad)
+	if err != nil {
+		t.Error(err)
+	} else {
+		t.Log("ok")
+	}
+}
+
+//测试群推
+func TestHwPush_SendByCids(t *testing.T) {
+	igetui, err := NewHuawei(Cfg)
+	if err != nil {
+		t.Error(err)
+		os.Exit(1)
+	}
+
+	cids := []string{"xxx"}
+	payLoad := Payload{"这是测试title", "这是测试内容", "1", ""}
+	err = igetui.SendByCids(cids, &payLoad)
+	if err != nil {
+		t.Error(err)
+	} else {
+		t.Log("ok")
+	}
+}
+
+type HwpushConfig struct {
+	AppId     string `toml:"app_id"`
+	AppSecret string `toml:"app_secret"`
+	Package   string `toml:"package"`
+}
+
+//消息payload，根据业务自定义
+type Payload struct {
+	PushTitle    string `json:"push_title"`
+	PushBody     string `json:"push_body"`
+	IsShowNotify string `json:"is_show_notify"`
+	Ext          string `json:"ext"`
+}
+
+type HuaweiPush struct {
+	Config *HwpushConfig
+}
+
+//存储每个cid失败的原因
+type PushSendResultMsg struct {
+	Success       int64    `json:"success"`
+	Failure       int64    `json:"failure"`
+	IllegalTokens []string `json:"illegal_tokens"`
+}
+
+//获取实例
+func NewHuawei(config *HwpushConfig) (*HuaweiPush, error) {
+
+	if config.AppId == "" || config.Package == "" || config.AppSecret == "" {
+		return nil, errors.New("请检查配置")
+	}
+
+	hwpush := &HuaweiPush{
+		Config: config,
+	}
+
+	return hwpush, nil
+}
+
+//根据用户cid推送
+func (h *HuaweiPush) SendByCid(cid string, payload *Payload) error {
+	cids := []string{cid}
+	return h.SendByCids(cids, payload)
+}
+
+//组装消息体
+func NewMessage(appPkgName string, payload *Payload) *Message {
+
+	msgType := 1                     //默认透传
+	if payload.IsShowNotify == "1" { //通知栏
+		msgType = 3
+	}
+
+	payload_str, _ := json.Marshal(payload)
+
+	return &Message{
+		Hps: Hps{
+			Msg: Msg{
+				Type: msgType, //1, 透传异步消息; 3, 系统通知栏异步消息。注意：2和4以后为保留后续扩展使用
+				Body: Body{
+					Content: payload.PushBody,
+					Title:   payload.PushTitle,
+				},
+				Action: Action{
+					Type: 3, //1, 自定义行为; 2, 打开URL; 3, 打开App;
+					Param: Param{
+						AppPkgName: appPkgName,
+					},
+				},
+			},
+			Ext: Ext{
+				Customize: []string{string(payload_str)},
+			},
+		},
+	}
+}
+
+//根据用户cids批量推送
+func (h *HuaweiPush) SendByCids(cids []string, payload *Payload) error {
+
+	//nspCtx
+	vers := &Vers{
+		Ver:   "1",
+		AppID: h.Config.AppId,
+	}
+	nspCtx, _ := json.Marshal(vers)
+
+	//hps
+	hps, err := json.Marshal(NewMessage(h.Config.Package, payload))
+	if err != nil {
+		return err
+	}
+
+	deviceToken, err := json.Marshal(cids)
+	if err != nil {
+		return err
+	}
+
+	pushSendParam := &PushSendParam{
+		DeviceToken: string(deviceToken),
+		NspCtx:      string(nspCtx),
+		Payload:     string(hps),
+	}
+
+	pushSendResult, err, bizErr := PushSend(h.Config.AppId, h.Config.AppSecret, pushSendParam)
+	if err != nil {
+		return err
+	}
+
+	fmt.Println(pushSendResult, bizErr)
+
+	return nil
+}

Diff for: message.go

@@ -0,0 +1,45 @@
+package huawei
+
+type Message struct {
+	Hps Hps `json:"hps"`
+}
+
+//华为Push消息总结构体
+type Hps struct {
+	Msg Msg `json:"msg"`
+	Ext Ext `json:"ext,omitempty"`
+}
+
+//PUSH消息定义。包括：消息类型type、消息内容body、消息动作action
+type Msg struct {
+	Type   int    `json:"type"` //1, 透传异步消息; 3, 系统通知栏异步消息。注意：2和4以后为保留后续扩展使用
+	Body   Body   `json:"body"`
+	Action Action `json:"action,omitempty"`
+}
+
+//消息内容。注意：对于透传类的消息可以是字符串，不必是JSON Object。
+type Body struct {
+	Content string `json:"content"` //消息内容体
+	Title   string `json:"title"`   //消息标题
+}
+
+//消息点击动作
+type Action struct {
+	Type  int   `json:"type,omitempty"` //1 自定义行为：行为由参数intent定义;2 打开URL：URL地址由参数url定义;3 打开APP：默认值，打开App的首页。注意：富媒体消息开放API不支持。
+	Param Param `json:"param,omitempty"`
+}
+
+//关于消息点击动作的参数
+type Param struct {
+	Intent     string `json:"intent,omitempty"` //Action的type为1的时候表示自定义行为。
+	Url        string `json:"url,omitempty"`    //Action的type为2的时候表示打开URL地址
+	AppPkgName string `json:"appPkgName"`       //需要拉起的应用包名，必须和注册推送的包名一致。
+}
+
+//扩展信息，含BI消息统计，特定展示风格，消息折叠
+type Ext struct {
+	BadgeAddNum string   `json:"badgeAddNum,omitempty"` //设置应用角标数值，取值范围1-99。
+	BadgeClass  string   `json:"badgeClass,omitempty"`  //桌面图标对应的应用入口Activity类。
+	BiTag       string   `json:"biTag,omitempty"`       //设置消息标签，如果带了这个标签，会在回执中推送给CP用于检测某种类型消息的到达率和状态。
+	Customize   []string `json:"customize,omitempty"`   //用于触发onEvent点击事件，扩展样例：[{"season":"Spring"},{"weather":"raining"}] 。说明：这个字段类型必须是JSON Array，里面是key-value的一组扩展信息。
+}