update

Author: Matrix-X

src/work/application.go

@@ -10,6 +10,8 @@ import (
 	"github.com/ArtisanCloud/power-wechat/src/work/corpgroup"
 	"github.com/ArtisanCloud/power-wechat/src/work/department"
 	"github.com/ArtisanCloud/power-wechat/src/work/externalContact"
+	"github.com/ArtisanCloud/power-wechat/src/work/groupRobot"
+	"github.com/ArtisanCloud/power-wechat/src/work/invoice"
 	"github.com/ArtisanCloud/power-wechat/src/work/media"
 	"github.com/ArtisanCloud/power-wechat/src/work/menu"
 	"github.com/ArtisanCloud/power-wechat/src/work/message"
@@ -63,6 +65,11 @@ type Work struct {
 	MsgAudit *msgaudit.Client
 
 	CorpGroup *corpgroup.Client
+
+	Invoice *invoice.Client
+
+	GroupRobot          *groupRobot.Client
+	GroupRobotMessenger *groupRobot.Messager
 }
 
 func NewWork(config *object.HashMap, r *http.Request) (*Work, error) {
@@ -145,6 +152,11 @@ func NewWork(config *object.HashMap, r *http.Request) (*Work, error) {
 	//-------------- corp group --------------
 	app.CorpGroup = corpgroup.RegisterProvider(app)
 
+	//-------------- invoice --------------
+	app.Invoice = invoice.RegisterProvider(app)
+
+	app.GroupRobot, app.GroupRobotMessenger = groupRobot.RegisterProvider(app)
+
 	return app, err
 }
 
@@ -218,6 +230,13 @@ func (app *Work) GetComponent(name string) interface{} {
 		return app.MsgAudit
 	case "CorpGroup":
 		return app.CorpGroup
+	case "Invoice":
+		return app.Invoice
+
+	case "GroupRobot":
+		return app.GroupRobot
+	case "GroupRobotMessenger":
+		return app.GroupRobotMessenger
 
 	default:
 		return nil

src/work/groupRobot/client.go

@@ -0,0 +1,35 @@
+package groupRobot
+
+import (
+	"github.com/ArtisanCloud/go-libs/object"
+	"github.com/ArtisanCloud/power-wechat/src/kernel"
+	"github.com/ArtisanCloud/power-wechat/src/work/groupRobot/response"
+)
+
+type Client struct {
+	*kernel.BaseClient
+}
+
+func NewClient(app kernel.ApplicationInterface) *Client {
+	return &Client{
+		kernel.NewBaseClient(&app, nil),
+	}
+}
+
+func (comp *Client) Message(message interface{}) (*Messager, error) {
+	return NewMessager(comp).Message(message)
+}
+
+// https://open.work.weixin.qq.com/api/doc/90000/90136/91770#%E6%96%87%E6%9C%AC%E7%B1%BB%E5%9E%8B
+func (comp *Client) Send(key string, message *object.HashMap) (*response.ResponseGroupRobotSend, error) {
+
+	result := &response.ResponseGroupRobotSend{}
+
+	comp.Token = nil
+
+	_, err := comp.HttpPostJson("cgi-bin/webhook/send", message, &object.StringMap{
+		"key": key,
+	}, nil, result)
+
+	return result, err
+}

src/work/groupRobot/messager.go

@@ -0,0 +1,46 @@
+package groupRobot
+
+import (
+	"errors"
+	"fmt"
+	"github.com/ArtisanCloud/power-wechat/src/kernel/messages"
+)
+
+type Messager struct {
+	*Client
+	message  *messages.Message
+	GroupKey string
+}
+
+func NewMessager(client *Client) *Messager {
+	return &Messager{
+		Client: client,
+	}
+}
+
+func (comp *Messager) Message(message interface{}) (*Messager, error) {
+
+	switch message.(type) {
+	case string:
+		message = messages.NewText(message.(string))
+	case int, int8, int16, int32, int64, uint, uint8, uint16, uint32, uint64:
+		message = messages.NewText(fmt.Sprintf("%d", message))
+	case float32, float64, complex64, complex128:
+		message = messages.NewText(fmt.Sprintf("%f", message))
+	case messages.Message:
+		obj := message.(messages.Message)
+		comp.message = &obj
+	case *messages.Message:
+		comp.message = message.(*messages.Message)
+	default:
+		return nil, errors.New(" Invalid message. ")
+	}
+
+	return comp, nil
+}
+
+func (comp *Messager) ToGroup(groupKey string) *Messager {
+	comp.GroupKey = groupKey
+
+	return comp
+}

src/work/groupRobot/provider.go

@@ -0,0 +1,16 @@
+package groupRobot
+
+import (
+	"github.com/ArtisanCloud/power-wechat/src/kernel"
+)
+
+func RegisterProvider(app kernel.ApplicationInterface) (*Client, *Messager) {
+
+
+	client := NewClient(app)
+
+	messager := NewMessager(client)
+
+	return client, messager
+
+}

src/work/groupRobot/response/responseGroupRobotSend.go

@@ -0,0 +1,14 @@
+package response
+
+import (
+	"github.com/ArtisanCloud/power-wechat/src/kernel/response"
+)
+
+type ResponseGroupRobotSend struct {
+	*response.ResponseWork
+
+	Type string `json:"type"`
+	MediaID string `json:"media_id"`
+	CreatedAt string `json:"created_at"`
+
+}

src/work/invoice/client.go

@@ -0,0 +1,69 @@
+package invoice
+
+import (
+	"github.com/ArtisanCloud/go-libs/object"
+	"github.com/ArtisanCloud/power-wechat/src/kernel"
+	response2 "github.com/ArtisanCloud/power-wechat/src/kernel/response"
+	"github.com/ArtisanCloud/power-wechat/src/work/invoice/response"
+)
+
+type Client struct {
+	*kernel.BaseClient
+}
+
+// https://open.work.weixin.qq.com/api/doc/90000/90135/90284
+func (comp *Client) Get(cardID string, encryptCode string) (*response.ResponseInvoiceGetInfo, error) {
+
+	result := &response.ResponseInvoiceGetInfo{}
+
+	data := &object.HashMap{
+		"card_id":      cardID,
+		"encrypt_code": encryptCode,
+	}
+	_, err := comp.HttpPostJson("cgi-bin/card/invoice/reimburse/getinvoiceinfo", data, nil, nil, result)
+
+	return result, err
+}
+
+// https://open.work.weixin.qq.com/api/doc/90000/90135/90287
+func (comp *Client) Select(invoices *object.HashMap) (*response.ResponseInvoiceGetInfoBatch, error) {
+
+	result := &response.ResponseInvoiceGetInfoBatch{}
+
+	data := &object.HashMap{
+		"item_list": invoices,
+	}
+	_, err := comp.HttpPostJson("cgi-bin/card/invoice/reimburse/getinvoiceinfobatch", data, nil, nil, result)
+
+	return result, err
+}
+
+// https://open.work.weixin.qq.com/api/doc/90000/90135/90285
+func (comp *Client) Update(cardId string, encryptCode string, status string) (*response2.ResponseWork, error) {
+
+	result := &response2.ResponseWork{}
+
+	data := &object.HashMap{
+		"card_id":          cardId,
+		"encrypt_code":     encryptCode,
+		"reimburse_status": status,
+	}
+	_, err := comp.HttpPostJson("cgi-bin/card/invoice/reimburse/updateinvoicestatus", data, nil, nil, result)
+
+	return result, err
+}
+
+// https://open.work.weixin.qq.com/api/doc/90000/90135/90286
+func (comp *Client) BatchUpdate(invoices *object.HashMap, openid string, status string) (*response2.ResponseWork, error) {
+
+	result := &response2.ResponseWork{}
+
+	data := &object.HashMap{
+		"openid":           invoices,
+		"reimburse_status": openid,
+		"invoice_list":     status,
+	}
+	_, err := comp.HttpPostJson("cgi-bin/card/invoice/reimburse/updatestatusbatch", data, nil, nil, result)
+
+	return result, err
+}

src/work/invoice/provider.go

@@ -0,0 +1,13 @@
+package invoice
+
+import (
+	"github.com/ArtisanCloud/power-wechat/src/kernel"
+)
+
+func RegisterProvider(app kernel.ApplicationInterface) *Client {
+
+	return &Client{
+		kernel.NewBaseClient(&app, nil),
+	}
+
+}

src/work/invoice/response/responseInvoiceGetInfo.go

@@ -0,0 +1,21 @@
+package response
+
+import (
+	"github.com/ArtisanCloud/go-libs/object"
+	"github.com/ArtisanCloud/power-wechat/src/kernel/response"
+)
+
+type ResponseInvoiceGetInfo struct {
+	*response.ResponseWork
+
+	CardID string `json:"card_id"`
+	BeginTime string `json:"begin_time"`
+	EndTime string `json:"end_time"`
+	Openid string `json:"openid"`
+	Type string `json:"type"`
+	Payee string `json:"payee"`
+	Detail string `json:"detail"`
+	UserInfo *object.HashMap `json:"user_info"`
+
+}
+

src/work/invoice/response/responseInvoiceGetInfoBatch.go

@@ -0,0 +1,13 @@
+package response
+
+import (
+	"github.com/ArtisanCloud/go-libs/object"
+	"github.com/ArtisanCloud/power-wechat/src/kernel/response"
+)
+
+type ResponseInvoiceGetInfoBatch struct {
+	*response.ResponseWork
+
+	ItemList []*object.HashMap `json:"item_list"`
+}
+