Compare commits
	
		
			No commits in common. "aaf8de98306b35f61ad2b0956af93598aff2dc0d" and "d6f50295c71dfe7fae9c5b6d7b637ecafff5247e" have entirely different histories.
		
	
	
		
			aaf8de9830
			...
			d6f50295c7
		
	
		|  | @ -1,21 +0,0 @@ | ||||||
| package client |  | ||||||
| 
 |  | ||||||
| import ( |  | ||||||
| 	"git.selly.red/Selly-Modules/natsio" |  | ||||||
| 	"git.selly.red/Selly-Modules/natsio/model" |  | ||||||
| 	"git.selly.red/Selly-Modules/natsio/subject" |  | ||||||
| ) |  | ||||||
| 
 |  | ||||||
| // Socket ...
 |  | ||||||
| type Socket struct{} |  | ||||||
| 
 |  | ||||||
| // GetSocket ...
 |  | ||||||
| func GetSocket() Socket { |  | ||||||
| 	return Socket{} |  | ||||||
| } |  | ||||||
| 
 |  | ||||||
| // EmitSocketEventDataReward ...
 |  | ||||||
| func (s Socket) EmitSocketEventDataReward(p model.PayloadEmitSocketEvent) error { |  | ||||||
| 	_, err := natsio.GetServer().Request(subject.Socket.EmitEventReward, toBytes(p)) |  | ||||||
| 	return err |  | ||||||
| } |  | ||||||
|  | @ -2,17 +2,13 @@ package jsconsumer | ||||||
| 
 | 
 | ||||||
| // Selly ...
 | // Selly ...
 | ||||||
| var Selly = struct { | var Selly = struct { | ||||||
| 	PushNotification                    string | 	PushNotification               string | ||||||
| 	UpdateSellerAffiliateStatistic      string | 	UpdateSellerAffiliateStatistic string | ||||||
| 	CheckAnDInsertCashflowBySeller      string | 	CheckAnDInsertCashflowBySeller string | ||||||
| 	SubscriberTopic                     string | 	SubscriberTopic                string | ||||||
| 	UpdateSellerSavingCampaignStatistic string |  | ||||||
| 	GenerateVoucherPromotion            string |  | ||||||
| }{ | }{ | ||||||
| 	PushNotification:                    "PULL_PUSH_NOTIFICATION", | 	PushNotification:               "PULL_PUSH_NOTIFICATION", | ||||||
| 	UpdateSellerAffiliateStatistic:      "PULL_UPDATE_SELLER_AFFILIATE_STATISTIC", | 	UpdateSellerAffiliateStatistic: "PULL_UPDATE_SELLER_AFFILIATE_STATISTIC", | ||||||
| 	CheckAnDInsertCashflowBySeller:      "PULL_CHECK_AND_INSERT_CASHFLOW_BY_SELLER", | 	CheckAnDInsertCashflowBySeller: "PULL_CHECK_AND_INSERT_CASHFLOW_BY_SELLER", | ||||||
| 	SubscriberTopic:                     "PULL_SUBSCRIBER_TOPIC", | 	SubscriberTopic:                "PULL_SUBSCRIBER_TOPIC", | ||||||
| 	UpdateSellerSavingCampaignStatistic: "PULL_UPDATE_SELLER_SAVING_CAMPAIGN_STATISTIC", |  | ||||||
| 	GenerateVoucherPromotion:            "PULL_GENERATE_VOUCHER_PROMOTION", |  | ||||||
| } | } | ||||||
|  |  | ||||||
|  | @ -1,7 +1,5 @@ | ||||||
| package jsmodel | package jsmodel | ||||||
| 
 | 
 | ||||||
| import "go.mongodb.org/mongo-driver/bson/primitive" |  | ||||||
| 
 |  | ||||||
| // PushNotification ...
 | // PushNotification ...
 | ||||||
| type PushNotification struct { | type PushNotification struct { | ||||||
| 	User        string              `json:"user"` | 	User        string              `json:"user"` | ||||||
|  | @ -14,11 +12,9 @@ type PushNotification struct { | ||||||
| 
 | 
 | ||||||
| // NotificationOptions ...
 | // NotificationOptions ...
 | ||||||
| type NotificationOptions struct { | type NotificationOptions struct { | ||||||
| 	Title                      string `json:"title"` | 	Title      string `json:"title"` | ||||||
| 	Content                    string `json:"content"` | 	Content    string `json:"content"` | ||||||
| 	CampaignID                 string `json:"campaignId,omitempty"` | 	CampaignID string `json:"campaignId,omitempty"` | ||||||
| 	SellerSavingCampaignID     string `json:"sellerSavingCampaignId,omitempty"` |  | ||||||
| 	SellerSavingCampaignStatus string `json:"sellerSavingCampaignStatus,omitempty"` |  | ||||||
| } | } | ||||||
| 
 | 
 | ||||||
| // PayloadUpdateSellerAffiliateStatistic ...
 | // PayloadUpdateSellerAffiliateStatistic ...
 | ||||||
|  | @ -66,39 +62,6 @@ type CashFlowOptions struct { | ||||||
| 	// Campaign
 | 	// Campaign
 | ||||||
| 	CampaignID   string `json:"campaignId,omitempty"` | 	CampaignID   string `json:"campaignId,omitempty"` | ||||||
| 	CampaignName string `json:"campaignName,omitempty"` | 	CampaignName string `json:"campaignName,omitempty"` | ||||||
| 
 |  | ||||||
| 	// SavingCampaign
 |  | ||||||
| 	SavingCampaignID   string `json:"savingCampaignId,omitempty"` |  | ||||||
| 	SavingCampaignName string `json:"savingCampaignName,omitempty"` |  | ||||||
| 
 |  | ||||||
| 	SavingCampaignItemID   string `json:"savingCampaignItemId,omitempty"` |  | ||||||
| 	SavingCampaignItemName string `json:"savingCampaignItemName,omitempty"` |  | ||||||
| } |  | ||||||
| 
 |  | ||||||
| // PayloadUpdateSellerSavingCampaignStatistic ...
 |  | ||||||
| type PayloadUpdateSellerSavingCampaignStatistic struct { |  | ||||||
| 	SellerID  string                        `json:"sellerId"` |  | ||||||
| 	Statistic SellerSavingCampaignStatistic `json:"statistic"` |  | ||||||
| } |  | ||||||
| 
 |  | ||||||
| // SellerSavingCampaignStatistic ...
 |  | ||||||
| type SellerSavingCampaignStatistic struct { |  | ||||||
| 	SavingCampaignCashPending   float64 `json:"savingCampaignCashPending"` |  | ||||||
| 	SavingCampaignCashCompleted float64 `json:"savingCampaignCashCompleted"` |  | ||||||
| } |  | ||||||
| 
 |  | ||||||
| // GenerateVoucherPromotion ...
 |  | ||||||
| type GenerateVoucherPromotion struct { |  | ||||||
| 	Cash       float64                         `json:"cash"` |  | ||||||
| 	TargetID   primitive.ObjectID              `json:"targetId"` |  | ||||||
| 	TargetType string                          `json:"targetType"` |  | ||||||
| 	Options    GenerateVoucherPromotionOptions `json:"options"` |  | ||||||
| 	Seller     primitive.ObjectID              `json:"seller"` |  | ||||||
| } |  | ||||||
| 
 |  | ||||||
| // GenerateVoucherPromotionOptions ...
 |  | ||||||
| type GenerateVoucherPromotionOptions struct { |  | ||||||
| 	Title string `json:"title"` |  | ||||||
| } | } | ||||||
| 
 | 
 | ||||||
| // SubscriberNotificationTopic ...
 | // SubscriberNotificationTopic ...
 | ||||||
|  |  | ||||||
|  | @ -11,17 +11,13 @@ func getSellyValue(val string) string { | ||||||
| 
 | 
 | ||||||
| // Selly ...
 | // Selly ...
 | ||||||
| var Selly = struct { | var Selly = struct { | ||||||
| 	PushNotification                    string | 	PushNotification               string | ||||||
| 	UpdateSellerAffiliateStatistic      string | 	UpdateSellerAffiliateStatistic string | ||||||
| 	CheckAnDInsertCashflowBySeller      string | 	CheckAnDInsertCashflowBySeller string | ||||||
| 	SubscriberTopic                     string | 	SubscriberTopic                string | ||||||
| 	UpdateSellerSavingCampaignStatistic string |  | ||||||
| 	GenerateVoucherPromotion            string |  | ||||||
| }{ | }{ | ||||||
| 	PushNotification:                    getSellyValue("push_notifications"), | 	PushNotification:               getSellyValue("push_notifications"), | ||||||
| 	UpdateSellerAffiliateStatistic:      getSellyValue("update_seller_affiliate_statistic"), | 	UpdateSellerAffiliateStatistic: getSellyValue("update_seller_affiliate_statistic"), | ||||||
| 	CheckAnDInsertCashflowBySeller:      getSellyValue("check_and_insert_cashflow_statistic"), | 	CheckAnDInsertCashflowBySeller: getSellyValue("check_and_insert_cashflow_statistic"), | ||||||
| 	SubscriberTopic:                     getSellyValue("subscriber_topic"), | 	SubscriberTopic:                getSellyValue("subscriber_topic"), | ||||||
| 	UpdateSellerSavingCampaignStatistic: getSellyValue("update_seller_saving_campaign_statistic"), |  | ||||||
| 	GenerateVoucherPromotion:            getSellyValue("generate_voucher_promotion"), |  | ||||||
| } | } | ||||||
|  |  | ||||||
|  | @ -4,11 +4,9 @@ import "time" | ||||||
| 
 | 
 | ||||||
| // ResponseSellerInfo ...
 | // ResponseSellerInfo ...
 | ||||||
| type ResponseSellerInfo struct { | type ResponseSellerInfo struct { | ||||||
| 	ID            string  `json:"_id"` | 	ID   string `json:"_id"` | ||||||
| 	Name          string  `json:"name"` | 	Name string `json:"name"` | ||||||
| 	Code          string  `json:"code"` | 	Code string `json:"code"` | ||||||
| 	IsAccountPro  bool    `json:"isAccountPro"` |  | ||||||
| 	CashRemaining float64 `json:"cashRemaining"` |  | ||||||
| } | } | ||||||
| 
 | 
 | ||||||
| // ResponseListSellerInfo ...
 | // ResponseListSellerInfo ...
 | ||||||
|  |  | ||||||
|  | @ -1,19 +0,0 @@ | ||||||
| package model |  | ||||||
| 
 |  | ||||||
| // PayloadEmitSocketEvent ...
 |  | ||||||
| type PayloadEmitSocketEvent struct { |  | ||||||
| 	User        string `json:"user"` |  | ||||||
| 	Message     string `json:"message"` |  | ||||||
| 	Data        string `json:"data"` |  | ||||||
| 	IsNotRemove bool   `json:"isNotRemove"` |  | ||||||
| } |  | ||||||
| 
 |  | ||||||
| // PayloadEventSocketReward ...
 |  | ||||||
| type PayloadEventSocketReward struct { |  | ||||||
| 	Type    string      `json:"type"` |  | ||||||
| 	Title   string      `json:"title"` |  | ||||||
| 	Cash    float64     `json:"cash"` |  | ||||||
| 	Message string      `json:"message"` |  | ||||||
| 	Photo   interface{} `json:"photo"` |  | ||||||
| 	Action  *ActionType `json:"action"` |  | ||||||
| } |  | ||||||
|  | @ -18,7 +18,6 @@ var prefixes = struct { | ||||||
| 	Queue         string | 	Queue         string | ||||||
| 	Campaign      string | 	Campaign      string | ||||||
| 	Affiliate     string | 	Affiliate     string | ||||||
| 	Socket        string |  | ||||||
| }{ | }{ | ||||||
| 	Communication: "communication", | 	Communication: "communication", | ||||||
| 	Order:         "order", | 	Order:         "order", | ||||||
|  | @ -37,5 +36,4 @@ var prefixes = struct { | ||||||
| 	Queue:         "queue", | 	Queue:         "queue", | ||||||
| 	Campaign:      "campaign", | 	Campaign:      "campaign", | ||||||
| 	Affiliate:     "affiliate", | 	Affiliate:     "affiliate", | ||||||
| 	Socket:        "socket", |  | ||||||
| } | } | ||||||
|  |  | ||||||
|  | @ -1,14 +0,0 @@ | ||||||
| package subject |  | ||||||
| 
 |  | ||||||
| import "fmt" |  | ||||||
| 
 |  | ||||||
| func getSocketValue(val string) string { |  | ||||||
| 	return fmt.Sprintf("%s.%s", prefixes.Socket, val) |  | ||||||
| } |  | ||||||
| 
 |  | ||||||
| // Socket ...
 |  | ||||||
| var Socket = struct { |  | ||||||
| 	EmitEventReward string |  | ||||||
| }{ |  | ||||||
| 	EmitEventReward: getSocketValue("emit_event_reward"), |  | ||||||
| } |  | ||||||
		Loading…
	
		Reference in New Issue