Compare commits
	
		
			No commits in common. "master" and "refactor-location-1701" have entirely different histories.
		
	
	
		
			master
			...
			refactor-l
		
	
		| 
						 | 
					@ -14,5 +14,4 @@
 | 
				
			||||||
# Dependency directories (remove the comment below to include it)
 | 
					# Dependency directories (remove the comment below to include it)
 | 
				
			||||||
# vendor/
 | 
					# vendor/
 | 
				
			||||||
 | 
					
 | 
				
			||||||
.idea
 | 
					.idea
 | 
				
			||||||
*.DS_Store
 | 
					 | 
				
			||||||
| 
						 | 
					@ -38,27 +38,6 @@ func (l Location) GetLocationByCode(payload model.LocationRequestPayload) (*mode
 | 
				
			||||||
	return r.Data, nil
 | 
						return r.Data, nil
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// GetLocationByWardCode ...
 | 
					 | 
				
			||||||
func (l Location) GetLocationByWardCode(payload model.RequestCondition) (*model.ResponseLocationAddress, error) {
 | 
					 | 
				
			||||||
	msg, err := natsio.GetServer().Request(subject.Location.GetLocationByWardCode, toBytes(payload))
 | 
					 | 
				
			||||||
	if err != nil {
 | 
					 | 
				
			||||||
		return nil, err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	var r struct {
 | 
					 | 
				
			||||||
		Data  *model.ResponseLocationAddress `json:"data"`
 | 
					 | 
				
			||||||
		Error string                         `json:"error"`
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	if err = json.Unmarshal(msg.Data, &r); err != nil {
 | 
					 | 
				
			||||||
		return nil, err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	if r.Error != "" {
 | 
					 | 
				
			||||||
		return nil, errors.New(r.Error)
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	return r.Data, nil
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
// GetProvincesByCodes ...
 | 
					// GetProvincesByCodes ...
 | 
				
			||||||
func (l Location) GetProvincesByCodes(p model.ProvinceRequestPayload) (*model.LocationProvinceResponse, error) {
 | 
					func (l Location) GetProvincesByCodes(p model.ProvinceRequestPayload) (*model.LocationProvinceResponse, error) {
 | 
				
			||||||
	msg, err := natsio.GetServer().Request(subject.Location.GetProvincesByCodesFromLocationService, toBytes(p))
 | 
						msg, err := natsio.GetServer().Request(subject.Location.GetProvincesByCodesFromLocationService, toBytes(p))
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -119,22 +119,3 @@ func (o Order) GetSupplierOrders(p model.OrderSupplierQuery) (*model.SupplierOrd
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
	return &r.Data, nil
 | 
						return &r.Data, nil
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					 | 
				
			||||||
// GetUserTotalWarningOrder ...
 | 
					 | 
				
			||||||
func (o Order) GetUserTotalWarningOrder(p model.OrderGetTotalWarningPayload) (*model.OrderGetTotalWarningRes, error) {
 | 
					 | 
				
			||||||
	msg, err := natsio.GetServer().Request(subject.Order.GetUserTotalWarningOrders, toBytes(p))
 | 
					 | 
				
			||||||
	if err != nil {
 | 
					 | 
				
			||||||
		return nil, err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	var r struct {
 | 
					 | 
				
			||||||
		Data  model.OrderGetTotalWarningRes `json:"data"`
 | 
					 | 
				
			||||||
		Error string                        `json:"error"`
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	if err = json.Unmarshal(msg.Data, &r); err != nil {
 | 
					 | 
				
			||||||
		return nil, err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	if r.Error != "" {
 | 
					 | 
				
			||||||
		return nil, errors.New(r.Error)
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	return &r.Data, nil
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -1,86 +0,0 @@
 | 
				
			||||||
package client
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
import (
 | 
					 | 
				
			||||||
	"encoding/json"
 | 
					 | 
				
			||||||
	"errors"
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	"git.selly.red/Selly-Modules/natsio"
 | 
					 | 
				
			||||||
	"git.selly.red/Selly-Modules/natsio/model"
 | 
					 | 
				
			||||||
	"git.selly.red/Selly-Modules/natsio/subject"
 | 
					 | 
				
			||||||
)
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
// Product ...
 | 
					 | 
				
			||||||
type Product struct{}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
// GetProduct ...
 | 
					 | 
				
			||||||
func GetProduct() Product {
 | 
					 | 
				
			||||||
	return Product{}
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
func (c Product) ApplyRequest(p model.ProductApplyRequestPayload) error {
 | 
					 | 
				
			||||||
	msg, err := natsio.GetServer().Request(subject.Product.ApplyRequest, toBytes(p))
 | 
					 | 
				
			||||||
	if err != nil {
 | 
					 | 
				
			||||||
		return err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	var r struct {
 | 
					 | 
				
			||||||
		Error string `json:"error"`
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	if err = json.Unmarshal(msg.Data, &r); err != nil {
 | 
					 | 
				
			||||||
		return err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	if r.Error != "" {
 | 
					 | 
				
			||||||
		return errors.New(r.Error)
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	return nil
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
func (c Product) CreateRequestSteps(p model.ProductCreateStepsPayload) error {
 | 
					 | 
				
			||||||
	msg, err := natsio.GetServer().Request(subject.Product.CreateRequestStep, toBytes(p))
 | 
					 | 
				
			||||||
	if err != nil {
 | 
					 | 
				
			||||||
		return err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	var r struct {
 | 
					 | 
				
			||||||
		Error string `json:"error"`
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	if err = json.Unmarshal(msg.Data, &r); err != nil {
 | 
					 | 
				
			||||||
		return err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	if r.Error != "" {
 | 
					 | 
				
			||||||
		return errors.New(r.Error)
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	return nil
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
func (c Product) ProcessApplyRequest(p model.ProductApplyRequestPayload) error {
 | 
					 | 
				
			||||||
	msg, err := natsio.GetServer().Request(subject.Product.ProcessApplyRequest, toBytes(p))
 | 
					 | 
				
			||||||
	if err != nil {
 | 
					 | 
				
			||||||
		return err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	var r struct {
 | 
					 | 
				
			||||||
		Error string `json:"error"`
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	if err = json.Unmarshal(msg.Data, &r); err != nil {
 | 
					 | 
				
			||||||
		return err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	if r.Error != "" {
 | 
					 | 
				
			||||||
		return errors.New(r.Error)
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	return nil
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
func (c Product) RequestChangeStatus(p model.ProductRequestChangeStatus) error {
 | 
					 | 
				
			||||||
	msg, err := natsio.GetServer().Request(subject.Product.RequestChangeStatus, toBytes(p))
 | 
					 | 
				
			||||||
	if err != nil {
 | 
					 | 
				
			||||||
		return err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	var r struct {
 | 
					 | 
				
			||||||
		Error string `json:"error"`
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	if err = json.Unmarshal(msg.Data, &r); err != nil {
 | 
					 | 
				
			||||||
		return err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	if r.Error != "" {
 | 
					 | 
				
			||||||
		return errors.New(r.Error)
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	return nil
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
| 
						 | 
					@ -1,37 +0,0 @@
 | 
				
			||||||
package client
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
import (
 | 
					 | 
				
			||||||
	"encoding/json"
 | 
					 | 
				
			||||||
	"errors"
 | 
					 | 
				
			||||||
	"git.selly.red/Selly-Modules/natsio"
 | 
					 | 
				
			||||||
	"git.selly.red/Selly-Modules/natsio/model"
 | 
					 | 
				
			||||||
	"git.selly.red/Selly-Modules/natsio/subject"
 | 
					 | 
				
			||||||
)
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
type Promotion struct{}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
func GetPromotion() Promotion {
 | 
					 | 
				
			||||||
	return Promotion{}
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
func (s Promotion) GenerateVoucherPromotion(p model.GenerateVoucherPromotionRequest) (*model.ResponseGenerateVoucherPromotion, error) {
 | 
					 | 
				
			||||||
	msg, err := natsio.GetServer().Request(subject.Promotion.GenerateVoucherPromotion, toBytes(p))
 | 
					 | 
				
			||||||
	if err != nil {
 | 
					 | 
				
			||||||
		return nil, err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	var r struct {
 | 
					 | 
				
			||||||
		Data  *model.ResponseGenerateVoucherPromotion `json:"data"`
 | 
					 | 
				
			||||||
		Error string                                  `json:"error"`
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	if err = json.Unmarshal(msg.Data, &r); err != nil {
 | 
					 | 
				
			||||||
		return nil, err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	if r.Error != "" {
 | 
					 | 
				
			||||||
		return nil, errors.New(r.Error)
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	return r.Data, nil
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
| 
						 | 
					@ -1,35 +0,0 @@
 | 
				
			||||||
package client
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
import (
 | 
					 | 
				
			||||||
	"encoding/json"
 | 
					 | 
				
			||||||
	"errors"
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	"git.selly.red/Selly-Modules/natsio"
 | 
					 | 
				
			||||||
	"git.selly.red/Selly-Modules/natsio/model"
 | 
					 | 
				
			||||||
	"git.selly.red/Selly-Modules/natsio/subject"
 | 
					 | 
				
			||||||
)
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
// Queue ...
 | 
					 | 
				
			||||||
type Queue struct{}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
// GetQueue ...
 | 
					 | 
				
			||||||
func GetQueue() Queue {
 | 
					 | 
				
			||||||
	return Queue{}
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
func (c Queue) ScheduleTask(p model.QueueScheduleTaskRequest) error {
 | 
					 | 
				
			||||||
	msg, err := natsio.GetServer().Request(subject.Queue.ScheduleTask, toBytes(p))
 | 
					 | 
				
			||||||
	if err != nil {
 | 
					 | 
				
			||||||
		return err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	var r struct {
 | 
					 | 
				
			||||||
		Error string `json:"error"`
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	if err = json.Unmarshal(msg.Data, &r); err != nil {
 | 
					 | 
				
			||||||
		return err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	if r.Error != "" {
 | 
					 | 
				
			||||||
		return errors.New(r.Error)
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	return nil
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
| 
						 | 
					@ -9,12 +9,15 @@ import (
 | 
				
			||||||
	"git.selly.red/Selly-Modules/natsio/subject"
 | 
						"git.selly.red/Selly-Modules/natsio/subject"
 | 
				
			||||||
)
 | 
					)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Seller ...
 | 
				
			||||||
type Seller struct{}
 | 
					type Seller struct{}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// GetSeller ...
 | 
				
			||||||
func GetSeller() Seller {
 | 
					func GetSeller() Seller {
 | 
				
			||||||
	return Seller{}
 | 
						return Seller{}
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// GetSellerInfoByID ...
 | 
				
			||||||
func (s Seller) GetSellerInfoByID(p model.GetSellerByIDRequest) (*model.ResponseSellerInfo, error) {
 | 
					func (s Seller) GetSellerInfoByID(p model.GetSellerByIDRequest) (*model.ResponseSellerInfo, error) {
 | 
				
			||||||
	msg, err := natsio.GetServer().Request(subject.Seller.GetSellerInfoByID, toBytes(p))
 | 
						msg, err := natsio.GetServer().Request(subject.Seller.GetSellerInfoByID, toBytes(p))
 | 
				
			||||||
	if err != nil {
 | 
						if err != nil {
 | 
				
			||||||
| 
						 | 
					@ -37,6 +40,7 @@ func (s Seller) GetSellerInfoByID(p model.GetSellerByIDRequest) (*model.Response
 | 
				
			||||||
	return r.Data, nil
 | 
						return r.Data, nil
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// GetListSellerInfoByIDs ...
 | 
				
			||||||
func (s Seller) GetListSellerInfoByIDs(p model.GetListSellerByIDsRequest) (*model.ResponseListSellerInfo, error) {
 | 
					func (s Seller) GetListSellerInfoByIDs(p model.GetListSellerByIDsRequest) (*model.ResponseListSellerInfo, error) {
 | 
				
			||||||
	msg, err := natsio.GetServer().Request(subject.Seller.GetListSellerInfoByIDs, toBytes(p))
 | 
						msg, err := natsio.GetServer().Request(subject.Seller.GetListSellerInfoByIDs, toBytes(p))
 | 
				
			||||||
 | 
					
 | 
				
			||||||
| 
						 | 
					@ -60,6 +64,7 @@ func (s Seller) GetListSellerInfoByIDs(p model.GetListSellerByIDsRequest) (*mode
 | 
				
			||||||
	return r.Data, nil
 | 
						return r.Data, nil
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// GetListSellerInfoSupportChatByIDs ...
 | 
				
			||||||
func (s Seller) GetListSellerInfoSupportChatByIDs(p model.GetListSellerSupportChatByIDsRequest) (*model.ResponseListSellerInfoSupportChat, error) {
 | 
					func (s Seller) GetListSellerInfoSupportChatByIDs(p model.GetListSellerSupportChatByIDsRequest) (*model.ResponseListSellerInfoSupportChat, error) {
 | 
				
			||||||
	msg, err := natsio.GetServer().Request(subject.SupportChat.GetListSellerInfoSupportChatByIDs, toBytes(p))
 | 
						msg, err := natsio.GetServer().Request(subject.SupportChat.GetListSellerInfoSupportChatByIDs, toBytes(p))
 | 
				
			||||||
	if err != nil {
 | 
						if err != nil {
 | 
				
			||||||
| 
						 | 
					@ -80,69 +85,3 @@ func (s Seller) GetListSellerInfoSupportChatByIDs(p model.GetListSellerSupportCh
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
	return r.Data, nil
 | 
						return r.Data, nil
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					 | 
				
			||||||
func (s Seller) CheckAndInsertCashflows(p model.CheckAndInsertCashflowsRequest) (*model.ResponseCheckAndInsertCashflows, error) {
 | 
					 | 
				
			||||||
	msg, err := natsio.GetServer().Request(subject.Seller.CheckAndInsertCashflows, toBytes(p))
 | 
					 | 
				
			||||||
	if err != nil {
 | 
					 | 
				
			||||||
		return nil, err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	var r struct {
 | 
					 | 
				
			||||||
		Data  *model.ResponseCheckAndInsertCashflows `json:"data"`
 | 
					 | 
				
			||||||
		Error string                                 `json:"error"`
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	if err = json.Unmarshal(msg.Data, &r); err != nil {
 | 
					 | 
				
			||||||
		return nil, err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	if r.Error != "" {
 | 
					 | 
				
			||||||
		return nil, errors.New(r.Error)
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	return r.Data, nil
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
func (s Seller) UpdateSellerAffiliateStatistic(p model.UpdateSellerAffiliateStatisticRequest) (*model.ResponseUpdateSellerAffiliateStatistic, error) {
 | 
					 | 
				
			||||||
	msg, err := natsio.GetServer().Request(subject.Seller.UpdateSellerAffiliateStatistic, toBytes(p))
 | 
					 | 
				
			||||||
	if err != nil {
 | 
					 | 
				
			||||||
		return nil, err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	var r struct {
 | 
					 | 
				
			||||||
		Data  *model.ResponseUpdateSellerAffiliateStatistic `json:"data"`
 | 
					 | 
				
			||||||
		Error string                                        `json:"error"`
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	if err = json.Unmarshal(msg.Data, &r); err != nil {
 | 
					 | 
				
			||||||
		return nil, err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	if r.Error != "" {
 | 
					 | 
				
			||||||
		return nil, errors.New(r.Error)
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	return r.Data, nil
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
func (s Seller) UpdateSellerSavingCampaignStatistic(p model.UpdateSellerSavingCampaignStatisticRequest) (*model.ResponseUpdateSellerSavingCampaignStatistic, error) {
 | 
					 | 
				
			||||||
	msg, err := natsio.GetServer().Request(subject.Seller.UpdateSellerSavingCampaignStatistic, toBytes(p))
 | 
					 | 
				
			||||||
	if err != nil {
 | 
					 | 
				
			||||||
		return nil, err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	var r struct {
 | 
					 | 
				
			||||||
		Data  *model.ResponseUpdateSellerSavingCampaignStatistic `json:"data"`
 | 
					 | 
				
			||||||
		Error string                                             `json:"error"`
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	if err = json.Unmarshal(msg.Data, &r); err != nil {
 | 
					 | 
				
			||||||
		return nil, err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	if r.Error != "" {
 | 
					 | 
				
			||||||
		return nil, errors.New(r.Error)
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	return r.Data, nil
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -1,27 +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
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
// EmitEventToUser ...
 | 
					 | 
				
			||||||
func (s Socket) EmitEventToUser(p model.PayloadEmitSocketEvent) error {
 | 
					 | 
				
			||||||
	_, err := natsio.GetServer().Request(subject.Socket.EmitEventToUser, toBytes(p))
 | 
					 | 
				
			||||||
	return err
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
| 
						 | 
					@ -146,25 +146,6 @@ func (w Warehouse) GetConfigByWarehouseID(warehouseID string) (*model.WarehouseC
 | 
				
			||||||
	return r.Data, nil
 | 
						return r.Data, nil
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// GetListConfig ...
 | 
					 | 
				
			||||||
func (w Warehouse) GetListConfig(req model.GetListWarehouseConfigReq) ([]*model.WarehouseConfiguration, error) {
 | 
					 | 
				
			||||||
	msg, err := natsio.GetServer().Request(subject.Warehouse.GetListWarehouseConfig, toBytes(req))
 | 
					 | 
				
			||||||
	if err != nil {
 | 
					 | 
				
			||||||
		return nil, err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	var r struct {
 | 
					 | 
				
			||||||
		Data  []*model.WarehouseConfiguration `json:"data"`
 | 
					 | 
				
			||||||
		Error string                          `json:"error"`
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	if err = json.Unmarshal(msg.Data, &r); err != nil {
 | 
					 | 
				
			||||||
		return nil, err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	if r.Error != "" {
 | 
					 | 
				
			||||||
		return nil, errors.New(r.Error)
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	return r.Data, nil
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
// GetWarehouses ...
 | 
					// GetWarehouses ...
 | 
				
			||||||
func (w Warehouse) GetWarehouses(p model.GetWarehousesRequest) (*model.GetWarehousesResponse, error) {
 | 
					func (w Warehouse) GetWarehouses(p model.GetWarehousesRequest) (*model.GetWarehousesResponse, error) {
 | 
				
			||||||
	msg, err := natsio.GetServer().Request(subject.Warehouse.GetWarehouses, toBytes(p))
 | 
						msg, err := natsio.GetServer().Request(subject.Warehouse.GetWarehouses, toBytes(p))
 | 
				
			||||||
| 
						 | 
					@ -201,43 +182,3 @@ func (w Warehouse) UpdateORDeliveryStatus(p model.WarehouseORUpdateDeliveryStatu
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
	return nil
 | 
						return nil
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					 | 
				
			||||||
// UpdateStatusWarehousePendingInactive ...
 | 
					 | 
				
			||||||
func (w Warehouse) UpdateStatusWarehousePendingInactive(p model.UpdateStatusWarehousePendingInactiveRequest) error {
 | 
					 | 
				
			||||||
	msg, err := natsio.GetServer().Request(subject.Warehouse.UpdateStatusWarehousePendingInactive, toBytes(p))
 | 
					 | 
				
			||||||
	if err != nil {
 | 
					 | 
				
			||||||
		return err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	var r struct {
 | 
					 | 
				
			||||||
		Error string `json:"error"`
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	if err = json.Unmarshal(msg.Data, &r); err != nil {
 | 
					 | 
				
			||||||
		return fmt.Errorf("nats: update_status_warehouse_pending_inactive %v", err)
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	if r.Error != "" {
 | 
					 | 
				
			||||||
		return errors.New(r.Error)
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	return nil
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
// UpdateIsSellyMall ...
 | 
					 | 
				
			||||||
func (w Warehouse) UpdateIsSellyMall(p model.UpdateIsSellyMallRequest) error {
 | 
					 | 
				
			||||||
	msg, err := natsio.GetServer().Request(subject.Warehouse.UpdateIsSellyMall, toBytes(p))
 | 
					 | 
				
			||||||
	if err != nil {
 | 
					 | 
				
			||||||
		return err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	var r struct {
 | 
					 | 
				
			||||||
		Error string `json:"error"`
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	if err = json.Unmarshal(msg.Data, &r); err != nil {
 | 
					 | 
				
			||||||
		return fmt.Errorf("nats: update_is_selly_mall %v", err)
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	if r.Error != "" {
 | 
					 | 
				
			||||||
		return errors.New(r.Error)
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	return nil
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -3,7 +3,6 @@ package client
 | 
				
			||||||
import (
 | 
					import (
 | 
				
			||||||
	"encoding/json"
 | 
						"encoding/json"
 | 
				
			||||||
	"errors"
 | 
						"errors"
 | 
				
			||||||
 | 
					 | 
				
			||||||
	"git.selly.red/Selly-Modules/natsio"
 | 
						"git.selly.red/Selly-Modules/natsio"
 | 
				
			||||||
	"git.selly.red/Selly-Modules/natsio/model"
 | 
						"git.selly.red/Selly-Modules/natsio/model"
 | 
				
			||||||
	"git.selly.red/Selly-Modules/natsio/subject"
 | 
						"git.selly.red/Selly-Modules/natsio/subject"
 | 
				
			||||||
| 
						 | 
					@ -84,39 +83,3 @@ func (w Warehouse) FindByCondition(p model.FindWithCondition) ([]*model.Warehous
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
	return r.Data, nil
 | 
						return r.Data, nil
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					 | 
				
			||||||
// UpdateWarehouseConfig ...
 | 
					 | 
				
			||||||
func (w Warehouse) UpdateWarehouseConfig(p model.UpdatePayload) error {
 | 
					 | 
				
			||||||
	msg, err := natsio.GetServer().Request(subject.Warehouse.UpdateWarehouseConfig, bsonToBytes(p))
 | 
					 | 
				
			||||||
	if err != nil {
 | 
					 | 
				
			||||||
		return err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	var r struct {
 | 
					 | 
				
			||||||
		Error string `json:"error"`
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	if err = json.Unmarshal(msg.Data, &r); err != nil {
 | 
					 | 
				
			||||||
		return err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	if r.Error != "" {
 | 
					 | 
				
			||||||
		return errors.New(r.Error)
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	return nil
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
// BulkWriteWarehouseConfig ...
 | 
					 | 
				
			||||||
func (w Warehouse) BulkWriteWarehouseConfig(p model.UpdatePayload) error {
 | 
					 | 
				
			||||||
	msg, err := natsio.GetServer().Request(subject.Warehouse.BulkWriteWarehouseConfig, bsonToBytes(p))
 | 
					 | 
				
			||||||
	if err != nil {
 | 
					 | 
				
			||||||
		return err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	var r struct {
 | 
					 | 
				
			||||||
		Error string `json:"error"`
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	if err = json.Unmarshal(msg.Data, &r); err != nil {
 | 
					 | 
				
			||||||
		return err
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	if r.Error != "" {
 | 
					 | 
				
			||||||
		return errors.New(r.Error)
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
	return nil
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -2,17 +2,11 @@ package jsconsumer
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// Selly ...
 | 
					// Selly ...
 | 
				
			||||||
var Selly = struct {
 | 
					var Selly = struct {
 | 
				
			||||||
	PushNotification                    string
 | 
						PushNotification               string
 | 
				
			||||||
	UpdateSellerAffiliateStatistic      string
 | 
						UpdateSellerAffiliateStatistic string
 | 
				
			||||||
	CheckAnDInsertCashflowBySeller      string
 | 
						CheckAnDInsertCashflowBySeller 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",
 | 
					 | 
				
			||||||
	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,45 +62,4 @@ 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 ...
 | 
					 | 
				
			||||||
type SubscriberNotificationTopic struct {
 | 
					 | 
				
			||||||
	User     string `json:"user"`
 | 
					 | 
				
			||||||
	Topic    string `json:"topic"`
 | 
					 | 
				
			||||||
	DeviceId string `json:"deviceId"`
 | 
					 | 
				
			||||||
	FCMToken string `json:"fcmToken"`
 | 
					 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -11,17 +11,11 @@ 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
 | 
					 | 
				
			||||||
	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"),
 | 
					 | 
				
			||||||
	UpdateSellerSavingCampaignStatistic: getSellyValue("update_seller_saving_campaign_statistic"),
 | 
					 | 
				
			||||||
	GenerateVoucherPromotion:            getSellyValue("generate_voucher_promotion"),
 | 
					 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -43,14 +43,3 @@ type RequestCondition struct {
 | 
				
			||||||
	Page  int64 `json:"page"`
 | 
						Page  int64 `json:"page"`
 | 
				
			||||||
	Limit int64 `json:"limit"`
 | 
						Limit int64 `json:"limit"`
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					 | 
				
			||||||
type UpdatePayload struct {
 | 
					 | 
				
			||||||
	Conditions interface{}              `json:"conditions"`
 | 
					 | 
				
			||||||
	Payload    interface{}              `json:"payload"`
 | 
					 | 
				
			||||||
	Opts       []*options.UpdateOptions `json:"opts"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
type WebhookPayloadV2 struct {
 | 
					 | 
				
			||||||
	Path string `json:"path"` // request URL path from external
 | 
					 | 
				
			||||||
	Data string `json:"data"` // request body
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -5,9 +5,6 @@ type CommunicationRequestHttp struct {
 | 
				
			||||||
	ResponseImmediately bool        `json:"responseImmediately"`
 | 
						ResponseImmediately bool        `json:"responseImmediately"`
 | 
				
			||||||
	Authentication      string      `json:"authentication"`
 | 
						Authentication      string      `json:"authentication"`
 | 
				
			||||||
	Payload             HttpRequest `json:"payload"`
 | 
						Payload             HttpRequest `json:"payload"`
 | 
				
			||||||
 | 
					 | 
				
			||||||
	// collection to store log data, will be prepended with log-, default it stored in logs collections
 | 
					 | 
				
			||||||
	LogTarget string `json:"logTarget"`
 | 
					 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// HttpRequest ...
 | 
					// HttpRequest ...
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -28,17 +28,10 @@ type (
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	// LocationWard ...
 | 
						// LocationWard ...
 | 
				
			||||||
	LocationWard struct {
 | 
						LocationWard struct {
 | 
				
			||||||
		ID       string       `json:"id"`
 | 
							ID   string `json:"id"`
 | 
				
			||||||
		Name     string       `json:"name"`
 | 
							Name string `json:"name"`
 | 
				
			||||||
		Code     int          `json:"code"`
 | 
							Code int    `json:"code"`
 | 
				
			||||||
		Slug     string       `json:"slug"`
 | 
							Slug string `json:"slug"`
 | 
				
			||||||
		Location *GEOLocation `json:"location"`
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	// GEOLocation ...
 | 
					 | 
				
			||||||
	GEOLocation struct {
 | 
					 | 
				
			||||||
		Type        string    `bson:"type" json:"type"`
 | 
					 | 
				
			||||||
		Coordinates []float64 `bson:"coordinates" json:"coordinates"`
 | 
					 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	// LocationProvinceResponse ...
 | 
						// LocationProvinceResponse ...
 | 
				
			||||||
| 
						 | 
					@ -83,13 +76,12 @@ type (
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	// LocationWardDetailResponse ...
 | 
						// LocationWardDetailResponse ...
 | 
				
			||||||
	LocationWardDetailResponse struct {
 | 
						LocationWardDetailResponse struct {
 | 
				
			||||||
		ID           string       `json:"_id"`
 | 
							ID           string   `json:"_id"`
 | 
				
			||||||
		Name         string       `json:"name"`
 | 
							Name         string   `json:"name"`
 | 
				
			||||||
		OldSlugs     []string     `json:"oldSlugs"`
 | 
							OldSlugs     []string `json:"oldSlugs"`
 | 
				
			||||||
		Slug         string       `json:"slug"`
 | 
							Slug         string   `json:"slug"`
 | 
				
			||||||
		Code         int          `json:"code"`
 | 
							Code         int      `json:"code"`
 | 
				
			||||||
		DistrictCode int          `json:"districtCode"`
 | 
							DistrictCode int      `json:"districtCode"`
 | 
				
			||||||
		ProvinceCode int          `json:"provinceCode"`
 | 
							ProvinceCode int      `json:"provinceCode"`
 | 
				
			||||||
		Location     *GEOLocation `json:"location"`
 | 
					 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
)
 | 
					)
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -49,7 +49,3 @@ type OrderSupplierQuery struct {
 | 
				
			||||||
	SupplierID   string   `json:"supplierId"`
 | 
						SupplierID   string   `json:"supplierId"`
 | 
				
			||||||
	WarehouseIDs []string `json:"warehouseIDs"`
 | 
						WarehouseIDs []string `json:"warehouseIDs"`
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					 | 
				
			||||||
type OrderGetTotalWarningPayload struct {
 | 
					 | 
				
			||||||
	UserID string `json:"userId"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -33,10 +33,3 @@ type SupplierOrderDelivery struct {
 | 
				
			||||||
	Status  string `json:"status" enums:"waiting_to_confirm,waiting_to_pick,picking,picked,delay_pickup,pickup_failed,delivering,delay_delivery,delivered,cancelled,delivery_failed,waiting_to_return,returning,delay_return,compensation,returned"`
 | 
						Status  string `json:"status" enums:"waiting_to_confirm,waiting_to_pick,picking,picked,delay_pickup,pickup_failed,delivering,delay_delivery,delivered,cancelled,delivery_failed,waiting_to_return,returning,delay_return,compensation,returned"`
 | 
				
			||||||
	TPLCode string `json:"tplCode" enums:"SLY,GHTK,GHN,SSC,SPY,VTP,SE,NTL,BEST"`
 | 
						TPLCode string `json:"tplCode" enums:"SLY,GHTK,GHN,SSC,SPY,VTP,SE,NTL,BEST"`
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					 | 
				
			||||||
// OrderGetTotalWarningRes ...
 | 
					 | 
				
			||||||
type OrderGetTotalWarningRes struct {
 | 
					 | 
				
			||||||
	UserID            string     `json:"userId"`
 | 
					 | 
				
			||||||
	TotalWarningOrder int64      `json:"totalWarningOrder"`
 | 
					 | 
				
			||||||
	Action            ActionType `json:"action"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -1,14 +0,0 @@
 | 
				
			||||||
package model
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
type ProductApplyRequestPayload struct {
 | 
					 | 
				
			||||||
	RequestID string `json:"requestId"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
type ProductCreateStepsPayload struct {
 | 
					 | 
				
			||||||
	RequestID string `json:"requestId"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
type ProductRequestChangeStatus struct {
 | 
					 | 
				
			||||||
	RequestID string `json:"requestId"`
 | 
					 | 
				
			||||||
	Status    string `json:"status"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
| 
						 | 
					@ -1,20 +0,0 @@
 | 
				
			||||||
package model
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
import "go.mongodb.org/mongo-driver/bson/primitive"
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
type GenerateVoucherPromotionRequest struct {
 | 
					 | 
				
			||||||
	Cash       float64                         `json:"cash"`
 | 
					 | 
				
			||||||
	TargetID   primitive.ObjectID              `json:"targetId"`
 | 
					 | 
				
			||||||
	TargetType string                          `json:"targetType"`
 | 
					 | 
				
			||||||
	Options    GenerateVoucherPromotionOptions `json:"options"`
 | 
					 | 
				
			||||||
	Seller     primitive.ObjectID              `json:"seller"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
type GenerateVoucherPromotionOptions struct {
 | 
					 | 
				
			||||||
	Title string `json:"title"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
type ResponseGenerateVoucherPromotion struct {
 | 
					 | 
				
			||||||
	Success bool   `json:"success"`
 | 
					 | 
				
			||||||
	Error   string `json:"error"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
| 
						 | 
					@ -1,8 +0,0 @@
 | 
				
			||||||
package model
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
type QueueScheduleTaskRequest struct {
 | 
					 | 
				
			||||||
	ID          string `json:"id"`
 | 
					 | 
				
			||||||
	NatsSubject string `json:"natsSubject"`
 | 
					 | 
				
			||||||
	Data        string `json:"data"`
 | 
					 | 
				
			||||||
	StartAt     int64  `json:"startAt"` // unix
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
| 
						 | 
					@ -2,73 +2,17 @@ package model
 | 
				
			||||||
 | 
					
 | 
				
			||||||
import "go.mongodb.org/mongo-driver/bson/primitive"
 | 
					import "go.mongodb.org/mongo-driver/bson/primitive"
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// GetSellerByIDRequest ...
 | 
				
			||||||
type GetSellerByIDRequest struct {
 | 
					type GetSellerByIDRequest struct {
 | 
				
			||||||
	SellerID primitive.ObjectID `json:"sellerId"`
 | 
						SellerID primitive.ObjectID `json:"sellerId"`
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// GetListSellerByIDsRequest ...
 | 
				
			||||||
type GetListSellerByIDsRequest struct {
 | 
					type GetListSellerByIDsRequest struct {
 | 
				
			||||||
	SellerIDs []primitive.ObjectID `json:"sellerIds"`
 | 
						SellerIDs []primitive.ObjectID `json:"sellerIds"`
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// GetListSellerSupportChatByIDsRequest ...
 | 
				
			||||||
type GetListSellerSupportChatByIDsRequest struct {
 | 
					type GetListSellerSupportChatByIDsRequest struct {
 | 
				
			||||||
	SellerIDs []primitive.ObjectID `json:"sellerIds"`
 | 
						SellerIDs []primitive.ObjectID `json:"sellerIds"`
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					 | 
				
			||||||
type CheckAndInsertCashflowsRequest struct {
 | 
					 | 
				
			||||||
	SellerID string           `json:"sellerId"`
 | 
					 | 
				
			||||||
	List     []CashflowSeller `json:"list"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
type CashflowSeller struct {
 | 
					 | 
				
			||||||
	Value      float64          `json:"value"`
 | 
					 | 
				
			||||||
	Action     string           `json:"action"`
 | 
					 | 
				
			||||||
	Category   string           `json:"category"`
 | 
					 | 
				
			||||||
	TargetID   string           `json:"targetId"`
 | 
					 | 
				
			||||||
	TargetType string           `json:"targetType"`
 | 
					 | 
				
			||||||
	Options    *CashFlowOptions `json:"options"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
type CashFlowOptions struct {
 | 
					 | 
				
			||||||
	AffiliateTransactionCode string `json:"affiliateTransactionCode,omitempty"`
 | 
					 | 
				
			||||||
	AffiliateCampaignID      string `json:"affiliateCampaignId,omitempty"`
 | 
					 | 
				
			||||||
	AffiliateCampaignName    string `json:"affiliateCampaignName,omitempty"`
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
	// Campaign
 | 
					 | 
				
			||||||
	CampaignID   string `json:"campaignId,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"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
type UpdateSellerAffiliateStatisticRequest struct {
 | 
					 | 
				
			||||||
	SellerID  string                   `json:"sellerId"`
 | 
					 | 
				
			||||||
	Statistic SellerAffiliateStatistic `json:"statistic"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
type SellerAffiliateStatistic struct {
 | 
					 | 
				
			||||||
	TransactionTotal              int     `json:"transactionTotal"`
 | 
					 | 
				
			||||||
	TransactionCashback           int     `json:"transactionCashback"`
 | 
					 | 
				
			||||||
	TransactionPending            int     `json:"transactionPending"`
 | 
					 | 
				
			||||||
	TransactionApproved           int     `json:"transactionApproved"`
 | 
					 | 
				
			||||||
	TransactionRejected           int     `json:"transactionRejected"`
 | 
					 | 
				
			||||||
	CommissionTransactionTotal    float64 `json:"commissionTransactionTotal"`
 | 
					 | 
				
			||||||
	CommissionTransactionCashback float64 `json:"commissionTransactionCashback"`
 | 
					 | 
				
			||||||
	CommissionTransactionApproved float64 `json:"commissionTransactionApproved"`
 | 
					 | 
				
			||||||
	CommissionTransactionPending  float64 `json:"commissionTransactionPending"`
 | 
					 | 
				
			||||||
	CommissionTransactionRejected float64 `json:"commissionTransactionRejected"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
type UpdateSellerSavingCampaignStatisticRequest struct {
 | 
					 | 
				
			||||||
	SellerID  string                        `json:"sellerId"`
 | 
					 | 
				
			||||||
	Statistic SellerSavingCampaignStatistic `json:"statistic"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
type SellerSavingCampaignStatistic struct {
 | 
					 | 
				
			||||||
	SavingCampaignCashPending   float64 `json:"savingCampaignCashPending"`
 | 
					 | 
				
			||||||
	SavingCampaignCashCompleted float64 `json:"savingCampaignCashCompleted"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -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 ...
 | 
				
			||||||
| 
						 | 
					@ -90,18 +88,3 @@ type SellerMembershipInfo struct {
 | 
				
			||||||
	Level int    `json:"level"`
 | 
						Level int    `json:"level"`
 | 
				
			||||||
	Name  string `json:"name"`
 | 
						Name  string `json:"name"`
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					 | 
				
			||||||
type ResponseCheckAndInsertCashflows struct {
 | 
					 | 
				
			||||||
	Success bool   `json:"success"`
 | 
					 | 
				
			||||||
	Error   string `json:"error"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
type ResponseUpdateSellerAffiliateStatistic struct {
 | 
					 | 
				
			||||||
	Success bool   `json:"success"`
 | 
					 | 
				
			||||||
	Error   string `json:"error"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
type ResponseUpdateSellerSavingCampaignStatistic struct {
 | 
					 | 
				
			||||||
	Success bool   `json:"success"`
 | 
					 | 
				
			||||||
	Error   string `json:"error"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -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"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
| 
						 | 
					@ -5,7 +5,6 @@ type ResponseSupplierInfo struct {
 | 
				
			||||||
	ID           string `json:"id"`
 | 
						ID           string `json:"id"`
 | 
				
			||||||
	Name         string `json:"name"`
 | 
						Name         string `json:"name"`
 | 
				
			||||||
	BusinessType string `json:"businessType"`
 | 
						BusinessType string `json:"businessType"`
 | 
				
			||||||
	IsSellyMall  bool   `json:"isSellyMall"`
 | 
					 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// ResponseSupplierContract ...
 | 
					// ResponseSupplierContract ...
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -37,12 +37,11 @@ type InsuranceOpts struct {
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// OutboundRequestItem ...
 | 
					// OutboundRequestItem ...
 | 
				
			||||||
type OutboundRequestItem struct {
 | 
					type OutboundRequestItem struct {
 | 
				
			||||||
	SupplierSKU        string  `json:"supplierSKU"`
 | 
						SupplierSKU string  `json:"supplierSKU"`
 | 
				
			||||||
	Quantity           int64   `json:"quantity"`
 | 
						Quantity    int64   `json:"quantity"`
 | 
				
			||||||
	UnitCode           string  `json:"unitCode"`
 | 
						UnitCode    string  `json:"unitCode"`
 | 
				
			||||||
	Price              float64 `json:"price"`
 | 
						Price       float64 `json:"price"`
 | 
				
			||||||
	Name               string  `json:"name"`
 | 
						Name        string  `json:"name"`
 | 
				
			||||||
	PartnerProductCode string  `json:"partnerProductCode"`
 | 
					 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// CustomerInfo ...
 | 
					// CustomerInfo ...
 | 
				
			||||||
| 
						 | 
					@ -64,12 +63,11 @@ type AddressDetail struct {
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// UpdateOutboundRequestLogisticInfoPayload ...
 | 
					// UpdateOutboundRequestLogisticInfoPayload ...
 | 
				
			||||||
type UpdateOutboundRequestLogisticInfoPayload struct {
 | 
					type UpdateOutboundRequestLogisticInfoPayload struct {
 | 
				
			||||||
	ShippingLabel  string `json:"shippingLabel,omitempty"`
 | 
						ShippingLabel string `json:"shippingLabel"`
 | 
				
			||||||
	TrackingCode   string `json:"trackingCode,omitempty"`
 | 
						TrackingCode  string `json:"trackingCode"`
 | 
				
			||||||
	ORCode         string `json:"orCode,omitempty"`
 | 
						ORCode        string `json:"orCode"`
 | 
				
			||||||
	TPLCode        string `json:"tplCode,omitempty"`
 | 
						TPLCode       string `json:"tplCode"`
 | 
				
			||||||
	OrderID        string `json:"orderId"`
 | 
						OrderID       string `json:"orderId"`
 | 
				
			||||||
	DeliveryStatus string `json:"deliveryStatus,omitempty"`
 | 
					 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// CancelOutboundRequest ...
 | 
					// CancelOutboundRequest ...
 | 
				
			||||||
| 
						 | 
					@ -99,11 +97,10 @@ type SupplierIsClosed struct {
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// GetWarehousesRequest ...
 | 
					// GetWarehousesRequest ...
 | 
				
			||||||
type GetWarehousesRequest struct {
 | 
					type GetWarehousesRequest struct {
 | 
				
			||||||
	Keyword      string   `json:"keyword"`
 | 
						Keyword      string `json:"keyword"`
 | 
				
			||||||
	Status       string   `json:"status"`
 | 
						Status       string `json:"status"`
 | 
				
			||||||
	Supplier     string   `json:"supplier"`
 | 
						Supplier     string `json:"supplier"`
 | 
				
			||||||
	BusinessType string   `json:"businessType"`
 | 
						BusinessType string `json:"businessType"`
 | 
				
			||||||
	IDs          []string `json:"ids"`
 | 
					 | 
				
			||||||
 | 
					
 | 
				
			||||||
	Page  int64 `json:"page"`
 | 
						Page  int64 `json:"page"`
 | 
				
			||||||
	Limit int64 `json:"limit"`
 | 
						Limit int64 `json:"limit"`
 | 
				
			||||||
| 
						 | 
					@ -116,24 +113,3 @@ type WarehouseORUpdateDeliveryStatus struct {
 | 
				
			||||||
	OrderID        string `json:"orderId"`
 | 
						OrderID        string `json:"orderId"`
 | 
				
			||||||
	DeliveryStatus string `json:"deliveryStatus"`
 | 
						DeliveryStatus string `json:"deliveryStatus"`
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					 | 
				
			||||||
// UpdateStatusWarehousePendingInactiveRequest ...
 | 
					 | 
				
			||||||
type UpdateStatusWarehousePendingInactiveRequest struct {
 | 
					 | 
				
			||||||
	Warehouses []UpdateStatusWarehousePendingInactive `json:"warehouses"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
// UpdateIsSellyMallRequest ...
 | 
					 | 
				
			||||||
type UpdateIsSellyMallRequest struct {
 | 
					 | 
				
			||||||
	SupplierID string `json:"supplier"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
// UpdateStatusWarehousePendingInactive ...
 | 
					 | 
				
			||||||
type UpdateStatusWarehousePendingInactive struct {
 | 
					 | 
				
			||||||
	WarehouseID     string `json:"warehouse"`
 | 
					 | 
				
			||||||
	PendingInactive bool   `json:"pendingInactive"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
type GetListWarehouseConfigReq struct {
 | 
					 | 
				
			||||||
	PartnerCode         string `json:"partnerCode"`
 | 
					 | 
				
			||||||
	PartnerIdentityCode string `json:"partnerIdentityCode"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -61,28 +61,16 @@ type WarehouseSupplier struct {
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// WarehouseOrder ...
 | 
					// WarehouseOrder ...
 | 
				
			||||||
type WarehouseOrder struct {
 | 
					type WarehouseOrder struct {
 | 
				
			||||||
	MinimumValue                   float64                         `json:"minimumValue"`
 | 
						MinimumValue             float64                `json:"minimumValue"`
 | 
				
			||||||
	PaymentMethod                  WarehousePaymentMethod          `json:"paymentMethod"`
 | 
						PaymentMethod            WarehousePaymentMethod `json:"paymentMethod"`
 | 
				
			||||||
	IsLimitNumberOfPurchases       bool                            `json:"isLimitNumberOfPurchases"`
 | 
						IsLimitNumberOfPurchases bool                   `json:"isLimitNumberOfPurchases"`
 | 
				
			||||||
	LimitNumberOfPurchases         int64                           `json:"limitNumberOfPurchases"`
 | 
						LimitNumberOfPurchases   int64                  `json:"limitNumberOfPurchases"`
 | 
				
			||||||
	NotifyOnNewOrder               WarehouseConfigNotifyOnNewOrder `json:"notifyOnNewOrder"`
 | 
					 | 
				
			||||||
	LabelSize                      string                          `json:"labelSize"`
 | 
					 | 
				
			||||||
	MaximumOrderValue              float64                         `json:"maximumOrderValue"`
 | 
					 | 
				
			||||||
	MaximumNumberPerBuyerEachMonth int64                           `json:"maximumNumberPerBuyerEachMonth"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
// WarehouseConfigNotifyOnNewOrder ...
 | 
					 | 
				
			||||||
type WarehouseConfigNotifyOnNewOrder struct {
 | 
					 | 
				
			||||||
	Enable  bool   `bson:"enable" json:"enable"`
 | 
					 | 
				
			||||||
	Channel string `bson:"channel" json:"channel"`
 | 
					 | 
				
			||||||
	RoomID  string `bson:"roomId" json:"roomId"`
 | 
					 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// WarehousePaymentMethod ...
 | 
					// WarehousePaymentMethod ...
 | 
				
			||||||
type WarehousePaymentMethod struct {
 | 
					type WarehousePaymentMethod struct {
 | 
				
			||||||
	Cod          bool `json:"cod"`
 | 
						Cod          bool `json:"cod"`
 | 
				
			||||||
	BankTransfer bool `json:"bankTransfer"`
 | 
						BankTransfer bool `json:"bankTransfer"`
 | 
				
			||||||
	Fundiin      bool `json:"fundiin"`
 | 
					 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// WarehouseDelivery ...
 | 
					// WarehouseDelivery ...
 | 
				
			||||||
| 
						 | 
					@ -156,8 +144,6 @@ type WarehouseNatsResponse struct {
 | 
				
			||||||
	UpdatedAt             time.Time                 `json:"updatedAt"`
 | 
						UpdatedAt             time.Time                 `json:"updatedAt"`
 | 
				
			||||||
	ReasonPendingInactive string                    `json:"reasonPendingInactive"`
 | 
						ReasonPendingInactive string                    `json:"reasonPendingInactive"`
 | 
				
			||||||
	IsPendingInactive     bool                      `json:"isPendingInactive"`
 | 
						IsPendingInactive     bool                      `json:"isPendingInactive"`
 | 
				
			||||||
	IsFromInternational   bool                      `json:"isFromInternational"`
 | 
					 | 
				
			||||||
	StoreCode             string                    `json:"storeCode"`
 | 
					 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// WarehouseInfo ...
 | 
					// WarehouseInfo ...
 | 
				
			||||||
| 
						 | 
					@ -186,9 +172,3 @@ type GetWarehousesResponse struct {
 | 
				
			||||||
	Limit int64           `json:"limit"`
 | 
						Limit int64           `json:"limit"`
 | 
				
			||||||
	List  []WarehouseInfo `json:"list"`
 | 
						List  []WarehouseInfo `json:"list"`
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					 | 
				
			||||||
type GetListWarehouseConfigRes struct {
 | 
					 | 
				
			||||||
	Total int64                    `json:"total"`
 | 
					 | 
				
			||||||
	Limit int64                    `json:"limit"`
 | 
					 | 
				
			||||||
	List  []WarehouseConfiguration `json:"list"`
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -14,12 +14,8 @@ var prefixes = struct {
 | 
				
			||||||
	SocialPost    string
 | 
						SocialPost    string
 | 
				
			||||||
	Staff         string
 | 
						Staff         string
 | 
				
			||||||
	Segment       string
 | 
						Segment       string
 | 
				
			||||||
	Product       string
 | 
					 | 
				
			||||||
	Queue         string
 | 
					 | 
				
			||||||
	Campaign      string
 | 
						Campaign      string
 | 
				
			||||||
	Affiliate     string
 | 
						Affiliate     string
 | 
				
			||||||
	Socket        string
 | 
					 | 
				
			||||||
	Promotion     string
 | 
					 | 
				
			||||||
}{
 | 
					}{
 | 
				
			||||||
	Communication: "communication",
 | 
						Communication: "communication",
 | 
				
			||||||
	Order:         "order",
 | 
						Order:         "order",
 | 
				
			||||||
| 
						 | 
					@ -34,10 +30,6 @@ var prefixes = struct {
 | 
				
			||||||
	SocialPost:    "social_post",
 | 
						SocialPost:    "social_post",
 | 
				
			||||||
	Staff:         "staff",
 | 
						Staff:         "staff",
 | 
				
			||||||
	Segment:       "segment",
 | 
						Segment:       "segment",
 | 
				
			||||||
	Product:       "product",
 | 
					 | 
				
			||||||
	Queue:         "queue",
 | 
					 | 
				
			||||||
	Campaign:      "campaign",
 | 
						Campaign:      "campaign",
 | 
				
			||||||
	Affiliate:     "affiliate",
 | 
						Affiliate:     "affiliate",
 | 
				
			||||||
	Socket:        "socket",
 | 
					 | 
				
			||||||
	Promotion:     "promotion",
 | 
					 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -9,7 +9,6 @@ func getLocationValue(val string) string {
 | 
				
			||||||
var Location = struct {
 | 
					var Location = struct {
 | 
				
			||||||
	GetLocationByCode                      string
 | 
						GetLocationByCode                      string
 | 
				
			||||||
	GetLocationByCodeFromLocationService   string
 | 
						GetLocationByCodeFromLocationService   string
 | 
				
			||||||
	GetLocationByWardCode                  string
 | 
					 | 
				
			||||||
	GetProvincesByCodes                    string
 | 
						GetProvincesByCodes                    string
 | 
				
			||||||
	GetProvincesByCodesFromLocationService string
 | 
						GetProvincesByCodesFromLocationService string
 | 
				
			||||||
	GetDistrictsByCodes                    string
 | 
						GetDistrictsByCodes                    string
 | 
				
			||||||
| 
						 | 
					@ -29,7 +28,6 @@ var Location = struct {
 | 
				
			||||||
}{
 | 
					}{
 | 
				
			||||||
	GetLocationByCode:                      getLocationValue("get_location_warehouse"),
 | 
						GetLocationByCode:                      getLocationValue("get_location_warehouse"),
 | 
				
			||||||
	GetLocationByCodeFromLocationService:   getLocationValue("get_location_warehouse_from_location_service"),
 | 
						GetLocationByCodeFromLocationService:   getLocationValue("get_location_warehouse_from_location_service"),
 | 
				
			||||||
	GetLocationByWardCode:                  getLocationValue("get_location_by_ward_code"),
 | 
					 | 
				
			||||||
	GetProvincesByCodes:                    getLocationValue("get_provinces_by_codes"),
 | 
						GetProvincesByCodes:                    getLocationValue("get_provinces_by_codes"),
 | 
				
			||||||
	GetProvincesByCodesFromLocationService: getLocationValue("get_provinces_by_codes_from_location_service"),
 | 
						GetProvincesByCodesFromLocationService: getLocationValue("get_provinces_by_codes_from_location_service"),
 | 
				
			||||||
	GetDistrictsByCodes:                    getLocationValue("get_districts_by_codes"),
 | 
						GetDistrictsByCodes:                    getLocationValue("get_districts_by_codes"),
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -7,19 +7,17 @@ func getOrderValue(val string) string {
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
var Order = struct {
 | 
					var Order = struct {
 | 
				
			||||||
	UpdateORStatus            string
 | 
						UpdateORStatus           string
 | 
				
			||||||
	GetUserTotalWarningOrders string
 | 
						CancelDelivery           string
 | 
				
			||||||
	CancelDelivery            string
 | 
						ChangeDeliveryStatus     string
 | 
				
			||||||
	ChangeDeliveryStatus      string
 | 
						UpdateLogisticInfoFailed string
 | 
				
			||||||
	UpdateLogisticInfoFailed  string
 | 
						ORNotUpdateStatus        string
 | 
				
			||||||
	ORNotUpdateStatus         string
 | 
						GetSupplierOrders        string
 | 
				
			||||||
	GetSupplierOrders         string
 | 
					 | 
				
			||||||
}{
 | 
					}{
 | 
				
			||||||
	UpdateORStatus:            getOrderValue("update_outbound_request_status"),
 | 
						UpdateORStatus:           getOrderValue("update_outbound_request_status"),
 | 
				
			||||||
	GetUserTotalWarningOrders: getOrderValue("get_user_total_warning_orders"),
 | 
						CancelDelivery:           getOrderValue("cancel_delivery"),
 | 
				
			||||||
	CancelDelivery:            getOrderValue("cancel_delivery"),
 | 
						ChangeDeliveryStatus:     getOrderValue("change_delivery_status"),
 | 
				
			||||||
	ChangeDeliveryStatus:      getOrderValue("change_delivery_status"),
 | 
						UpdateLogisticInfoFailed: getOrderValue("update_logistic_info_failed"),
 | 
				
			||||||
	UpdateLogisticInfoFailed:  getOrderValue("update_logistic_info_failed"),
 | 
						ORNotUpdateStatus:        getOrderValue("outbound_request_not_update_status"),
 | 
				
			||||||
	ORNotUpdateStatus:         getOrderValue("outbound_request_not_update_status"),
 | 
						GetSupplierOrders:        getOrderValue("get_supplier_orders"),
 | 
				
			||||||
	GetSupplierOrders:         getOrderValue("get_supplier_orders"),
 | 
					 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -1,26 +0,0 @@
 | 
				
			||||||
package subject
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
import "fmt"
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
// getSegmentValue ...
 | 
					 | 
				
			||||||
func getProductValue(val string) string {
 | 
					 | 
				
			||||||
	return fmt.Sprintf("%s.%s", prefixes.Product, val)
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
var Product = struct {
 | 
					 | 
				
			||||||
	ApplyRequest                                        string
 | 
					 | 
				
			||||||
	CreateRequestStep                                   string
 | 
					 | 
				
			||||||
	ProcessApplyRequest                                 string
 | 
					 | 
				
			||||||
	RequestChangeStatus                                 string
 | 
					 | 
				
			||||||
	WebhookStockUpdate                                  string // WebhookStockUpdate Kiotviet queue
 | 
					 | 
				
			||||||
	OPWebhookStockUpdate                                string // OPWebhookStockUpdate Onpoint queue
 | 
					 | 
				
			||||||
	OrderPaymentBankTransferWebhookCheckAndUpdateStatus string
 | 
					 | 
				
			||||||
}{
 | 
					 | 
				
			||||||
	ApplyRequest:         getProductValue("apply_request"),
 | 
					 | 
				
			||||||
	CreateRequestStep:    getProductValue("create_request_step"),
 | 
					 | 
				
			||||||
	ProcessApplyRequest:  getProductValue("process_apply_request"),
 | 
					 | 
				
			||||||
	RequestChangeStatus:  getProductValue("request_change_status"),
 | 
					 | 
				
			||||||
	WebhookStockUpdate:   getProductValue("webhook_stock_update"),
 | 
					 | 
				
			||||||
	OPWebhookStockUpdate: getProductValue("op_webhook_stock_update"),
 | 
					 | 
				
			||||||
	OrderPaymentBankTransferWebhookCheckAndUpdateStatus: getProductValue("order_payment_bank_transfer_webhook_check_and_update_status"),
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
| 
						 | 
					@ -1,13 +0,0 @@
 | 
				
			||||||
package subject
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
import "fmt"
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
func getPromotionValue(val string) string {
 | 
					 | 
				
			||||||
	return fmt.Sprintf("%s.%s", prefixes.Promotion, val)
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
var Promotion = struct {
 | 
					 | 
				
			||||||
	GenerateVoucherPromotion string
 | 
					 | 
				
			||||||
}{
 | 
					 | 
				
			||||||
	GenerateVoucherPromotion: getPromotionValue("generate_voucher_promotion"),
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
| 
						 | 
					@ -1,13 +0,0 @@
 | 
				
			||||||
package subject
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
import "fmt"
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
func getQueueValue(val string) string {
 | 
					 | 
				
			||||||
	return fmt.Sprintf("%s.%s", prefixes.Queue, val)
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
var Queue = struct {
 | 
					 | 
				
			||||||
	ScheduleTask string
 | 
					 | 
				
			||||||
}{
 | 
					 | 
				
			||||||
	ScheduleTask: getQueueValue("schedule_task"),
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
| 
						 | 
					@ -8,17 +8,11 @@ func getSellerValue(val string) string {
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// Seller ...
 | 
					// Seller ...
 | 
				
			||||||
var Seller = struct {
 | 
					var Seller = struct {
 | 
				
			||||||
	GetSellerInfoByID                   string
 | 
						GetSellerInfoByID      string
 | 
				
			||||||
	GetListSellerInfoByIDs              string
 | 
						GetListSellerInfoByIDs string
 | 
				
			||||||
	CheckAndInsertCashflows             string
 | 
					 | 
				
			||||||
	UpdateSellerAffiliateStatistic      string
 | 
					 | 
				
			||||||
	UpdateSellerSavingCampaignStatistic string
 | 
					 | 
				
			||||||
}{
 | 
					}{
 | 
				
			||||||
	GetSellerInfoByID:                   getSellerValue("get_seller_info_by_id"),
 | 
						GetSellerInfoByID:      getSellerValue("get_seller_info_by_id"),
 | 
				
			||||||
	GetListSellerInfoByIDs:              getSellerValue("get_list_seller_info_by_ids"),
 | 
						GetListSellerInfoByIDs: getSellerValue("get_list_seller_info_by_ids"),
 | 
				
			||||||
	CheckAndInsertCashflows:             getSellerValue("check_and_insert_cashflows"),
 | 
					 | 
				
			||||||
	UpdateSellerAffiliateStatistic:      getSellerValue("update_seller_affiliate_statistic"),
 | 
					 | 
				
			||||||
	UpdateSellerSavingCampaignStatistic: getSellerValue("update_seller_saving_campaign_statistic"),
 | 
					 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// SupportChat ...
 | 
					// SupportChat ...
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -1,16 +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
 | 
					 | 
				
			||||||
	EmitEventToUser string
 | 
					 | 
				
			||||||
}{
 | 
					 | 
				
			||||||
	EmitEventReward: getSocketValue("emit_event_reward"),
 | 
					 | 
				
			||||||
	EmitEventToUser: "send_message_to_socket",
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
| 
						 | 
					@ -1,63 +1,49 @@
 | 
				
			||||||
package subject
 | 
					package subject
 | 
				
			||||||
 | 
					
 | 
				
			||||||
import (
 | 
					import "fmt"
 | 
				
			||||||
	"fmt"
 | 
					 | 
				
			||||||
)
 | 
					 | 
				
			||||||
 | 
					
 | 
				
			||||||
func getWarehouseValue(val string) string {
 | 
					func getWarehouseValue(val string) string {
 | 
				
			||||||
	return fmt.Sprintf("%s.%s", prefixes.Warehouse, val)
 | 
						return fmt.Sprintf("%s.%s", prefixes.Warehouse, val)
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
var Warehouse = struct {
 | 
					var Warehouse = struct {
 | 
				
			||||||
	CreateWarehouseIntoServiceSupplier   string
 | 
						CreateWarehouseIntoServiceSupplier string
 | 
				
			||||||
	UpdateWarehouseIntoServiceSupplier   string
 | 
						UpdateWarehouseIntoServiceSupplier string
 | 
				
			||||||
	CreateOutboundRequest                string
 | 
						CreateOutboundRequest              string
 | 
				
			||||||
	UpdateOutboundRequestLogistic        string
 | 
						UpdateOutboundRequestLogistic      string
 | 
				
			||||||
	CancelOutboundRequest                string
 | 
						CancelOutboundRequest              string
 | 
				
			||||||
	GetConfiguration                     string
 | 
						GetConfiguration                   string
 | 
				
			||||||
	SyncORStatus                         string
 | 
						SyncORStatus                       string
 | 
				
			||||||
	WebhookTNC                           string
 | 
						WebhookTNC                         string
 | 
				
			||||||
	WebhookGlobalCare                    string
 | 
						WebhookGlobalCare                  string
 | 
				
			||||||
	WebhookOnPoint                       string
 | 
						WebhookOnPoint                     string
 | 
				
			||||||
	WebhookViettelFFM                    string
 | 
						FindOne                            string
 | 
				
			||||||
	FindOne                              string
 | 
						FindByCondition                    string
 | 
				
			||||||
	FindByCondition                      string
 | 
						Distinct                           string
 | 
				
			||||||
	Distinct                             string
 | 
						Count                              string
 | 
				
			||||||
	Count                                string
 | 
						AfterUpdateWarehouse               string
 | 
				
			||||||
	AfterUpdateWarehouse                 string
 | 
						AfterCreateWarehouse               string
 | 
				
			||||||
	AfterCreateWarehouse                 string
 | 
						UpdateIsClosedSupplier             string
 | 
				
			||||||
	UpdateIsClosedSupplier               string
 | 
						GetWarehouses                      string
 | 
				
			||||||
	GetWarehouses                        string
 | 
						UpdateORDeliveryStatus             string
 | 
				
			||||||
	UpdateORDeliveryStatus               string
 | 
					 | 
				
			||||||
	UpdateStatusWarehousePendingInactive string
 | 
					 | 
				
			||||||
	UpdateIsSellyMall                    string
 | 
					 | 
				
			||||||
	UpdateWarehouseConfig                string
 | 
					 | 
				
			||||||
	BulkWriteWarehouseConfig             string
 | 
					 | 
				
			||||||
	GetListWarehouseConfig               string
 | 
					 | 
				
			||||||
}{
 | 
					}{
 | 
				
			||||||
	CreateWarehouseIntoServiceSupplier:   getWarehouseValue("create_warehouse_into_service_supplier"),
 | 
						CreateWarehouseIntoServiceSupplier: getWarehouseValue("create_warehouse_into_service_supplier"),
 | 
				
			||||||
	UpdateWarehouseIntoServiceSupplier:   getWarehouseValue("update_warehouse_into_service_supplier"),
 | 
						UpdateWarehouseIntoServiceSupplier: getWarehouseValue("update_warehouse_into_service_supplier"),
 | 
				
			||||||
	AfterCreateWarehouse:                 getWarehouseValue("after_create_warehouse"),
 | 
						AfterCreateWarehouse:               getWarehouseValue("after_create_warehouse"),
 | 
				
			||||||
	AfterUpdateWarehouse:                 getWarehouseValue("after_update_warehouse"),
 | 
						AfterUpdateWarehouse:               getWarehouseValue("after_update_warehouse"),
 | 
				
			||||||
	CreateOutboundRequest:                getWarehouseValue("create_outbound_request"),
 | 
						CreateOutboundRequest:              getWarehouseValue("create_outbound_request"),
 | 
				
			||||||
	UpdateOutboundRequestLogistic:        getWarehouseValue("update_outbound_request_logistic_info"),
 | 
						UpdateOutboundRequestLogistic:      getWarehouseValue("update_outbound_request_logistic_info"),
 | 
				
			||||||
	CancelOutboundRequest:                getWarehouseValue("cancel_outbound_request"),
 | 
						CancelOutboundRequest:              getWarehouseValue("cancel_outbound_request"),
 | 
				
			||||||
	GetConfiguration:                     getWarehouseValue("get_configuration"),
 | 
						GetConfiguration:                   getWarehouseValue("get_configuration"),
 | 
				
			||||||
	SyncORStatus:                         getWarehouseValue("sync_or_status"),
 | 
						SyncORStatus:                       getWarehouseValue("sync_or_status"),
 | 
				
			||||||
	WebhookTNC:                           getWarehouseValue("webhook_tnc"),
 | 
						WebhookTNC:                         getWarehouseValue("webhook_tnc"),
 | 
				
			||||||
	WebhookGlobalCare:                    getWarehouseValue("webhook_global_care"),
 | 
						WebhookGlobalCare:                  getWarehouseValue("webhook_global_care"),
 | 
				
			||||||
	WebhookOnPoint:                       getWarehouseValue("webhook_on_point"),
 | 
						WebhookOnPoint:                     getWarehouseValue("webhook_on_point"),
 | 
				
			||||||
	WebhookViettelFFM:                    getWarehouseValue("webhook_viettel_ffm"),
 | 
						FindOne:                            getWarehouseValue("find_one"),
 | 
				
			||||||
	FindOne:                              getWarehouseValue("find_one"),
 | 
						FindByCondition:                    getWarehouseValue("find_all_by_condition"),
 | 
				
			||||||
	FindByCondition:                      getWarehouseValue("find_all_by_condition"),
 | 
						Distinct:                           getWarehouseValue("distinct"),
 | 
				
			||||||
	Distinct:                             getWarehouseValue("distinct"),
 | 
						Count:                              getWarehouseValue("count"),
 | 
				
			||||||
	Count:                                getWarehouseValue("count"),
 | 
						UpdateIsClosedSupplier:             getWarehouseValue("update_is_closed_supplier"),
 | 
				
			||||||
	UpdateIsClosedSupplier:               getWarehouseValue("update_is_closed_supplier"),
 | 
						GetWarehouses:                      getWarehouseValue("get_warehouses"),
 | 
				
			||||||
	GetWarehouses:                        getWarehouseValue("get_warehouses"),
 | 
						UpdateORDeliveryStatus:             getWarehouseValue("update_or_delivery_status"),
 | 
				
			||||||
	UpdateORDeliveryStatus:               getWarehouseValue("update_or_delivery_status"),
 | 
					 | 
				
			||||||
	UpdateStatusWarehousePendingInactive: getWarehouseValue("update_status_warehouse_pending_inactive"),
 | 
					 | 
				
			||||||
	UpdateIsSellyMall:                    getWarehouseValue("update_is_selly_mall"),
 | 
					 | 
				
			||||||
	UpdateWarehouseConfig:                getWarehouseValue("update_warehouse_config"),
 | 
					 | 
				
			||||||
	BulkWriteWarehouseConfig:             getWarehouseValue("bulk_write_warehouse_config"),
 | 
					 | 
				
			||||||
	GetListWarehouseConfig:               getWarehouseValue("get_list_warehouse_config"),
 | 
					 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
		Loading…
	
		Reference in New Issue