gengxinyixia

db/selection.go

@@ -0,0 +1,19 @@
+package db
+
+import (
+	"context"
+	"youngee_m_api/model/gorm_model"
+	"youngee_m_api/model/http_model"
+)
+
+func SelectionReviewNumber(ctx context.Context) (*http_model.ReviewNums, error) {
+	var reviewNums int64
+	db := GetReadDB(ctx)
+	err := db.Model(gorm_model.YounggeeSelectionInfo{}).Where("selection_status = 2").Count(&reviewNums).Error
+	if err != nil {
+		return nil, err
+	}
+	ReviewNums := new(http_model.ReviewNums)
+	ReviewNums.ReviewNums = reviewNums
+	return ReviewNums, err
+}

handler/reviewnumber.go

@@ -0,0 +1,55 @@
+package handler
+
+import (
+	"github.com/gin-gonic/gin"
+	"github.com/sirupsen/logrus"
+	"youngee_m_api/consts"
+	"youngee_m_api/db"
+	"youngee_m_api/model/http_model"
+	"youngee_m_api/util"
+)
+
+func WrapSelectionReviewNumberHandler(ctx *gin.Context) {
+	handler := newSelectionReviewNumberHandler(ctx)
+	BaseRun(handler)
+}
+
+type SelectionReviewNumberHandler struct {
+	ctx  *gin.Context
+	req  *http_model.SelectionReviewNumberRequest
+	resp *http_model.CommonResponse
+}
+
+func (g SelectionReviewNumberHandler) getContext() *gin.Context {
+	return g.ctx
+}
+
+func (g SelectionReviewNumberHandler) getResponse() interface{} {
+	return g.resp
+}
+
+func (g SelectionReviewNumberHandler) getRequest() interface{} {
+	return g.req
+}
+
+func (g SelectionReviewNumberHandler) run() {
+	data, err := db.SelectionReviewNumber(g.ctx)
+	if err != nil {
+		logrus.WithContext(g.ctx).Errorf("[SelectionReviewNumberHandler] error SelectionReviewNumber, err:%+v", err)
+		util.HandlerPackErrorResp(g.resp, consts.ErrorInternal, consts.DefaultToast)
+		return
+	}
+	g.resp.Data = data
+}
+
+func (g SelectionReviewNumberHandler) checkParam() error {
+	return nil
+}
+
+func newSelectionReviewNumberHandler(ctx *gin.Context) *SelectionReviewNumberHandler {
+	return &SelectionReviewNumberHandler{
+		ctx:  ctx,
+		req:  http_model.NewSelectionReviewNumberRequest(),
+		resp: http_model.NewSelectionReviewNumberResponse(),
+	}
+}

model/gorm_model/selection_info.go

@@ -0,0 +1,42 @@
+package gorm_model
+
+import (
+	"time"
+)
+
+type YounggeeSelectionInfo struct {
+	SelectionID      string    `gorm:"column:selection_id;primary_key"` // 选品项目id
+	SelectionName    string    `gorm:"column:selection_name"`           // 选品项目名称
+	EnterpriseID     string    `gorm:"column:enterprise_id"`            // 所属企业id
+	ProductID        int       `gorm:"column:product_id"`               // 关联商品id
+	ContentType      int       `gorm:"column:content_type"`             // 内容形式，1代表图文，2代表视频
+	SelectionStatus  int       `gorm:"column:selection_status"`         // 选品项目状态，1-8分别代表创建中、待审核、审核通过、待支付、已支付、执行中、失效、已结案
+	TaskMode         int       `gorm:"column:task_mode"`                // 任务形式，1、2分别表示悬赏任务、纯佣带货
+	Platform         int       `gorm:"column:platform"`                 // 项目平台，1-7分别代表小红书、抖音、微博、快手、b站、大众点评、知乎
+	SampleMode       int       `gorm:"column:sample_mode"`              // 领样形式，1、2分别表示免费领样、垫付领样
+	ProductUrl       string    `gorm:"column:product_url"`              // 带货链接
+	SampleNum        int       `gorm:"column:sample_num"`               // 样品数量
+	RemainNum        int       `gorm:"column:remain_num"`               // 剩余数量
+	CommissionRate   int       `gorm:"column:commission_rate"`          // 佣金比例
+	EstimatedCost    string    `gorm:"column:estimated_cost"`           // 预估成本
+	TaskReward       string    `gorm:"column:task_reward"`              // 任务悬赏
+	SampleCondition  string    `gorm:"column:sample_condition"`         // 领样条件
+	RewardCondition  string    `gorm:"column:reward_condition"`         // 返现悬赏条件
+	SettlementAmount string    `gorm:"column:settlement_amount"`        // 结算金额
+	TaskDdl          time.Time `gorm:"column:task_ddl"`                 // 招募截止时间
+	Detail           string    `gorm:"column:detail"`                   // 卖点总结
+	ProductSnap      string    `gorm:"column:product_snap"`             // 商品信息快照
+	ProductPhotoSnap string    `gorm:"column:product_photo_snap"`       // 商品图片快照
+	CreatedAt        time.Time `gorm:"column:created_at"`               // 创建时间
+	UpdatedAt        time.Time `gorm:"column:updated_at"`               // 修改时间
+	SubmitAt         time.Time `gorm:"column:submit_at"`                // 提交审核时间
+	PassAt           time.Time `gorm:"column:pass_at"`                  // 审核通过时间
+	FailReason       int       `gorm:"column:fail_reason"`              // 失效原因，1、2分别表示逾期未支付、项目存在风险
+	PayAt            time.Time `gorm:"column:pay_at"`                   // 支付时间
+	FinishAt         time.Time `gorm:"column:finish_at"`                // 结案时间
+	IsRead           int       `gorm:"column:is_read"`                  // 是否已读
+}
+
+func (m *YounggeeSelectionInfo) TableName() string {
+	return "younggee_selection_info"
+}

model/http_model/SelectionReviewNumberRequest.go

@@ -0,0 +1,17 @@
+package http_model
+
+type SelectionReviewNumberRequest struct {
+}
+
+type ReviewNums struct {
+	ReviewNums int64 `json:"review_nums"` // 选品待审核数量
+}
+
+func NewSelectionReviewNumberRequest() *SelectionReviewNumberRequest {
+	return new(SelectionReviewNumberRequest)
+}
+func NewSelectionReviewNumberResponse() *CommonResponse {
+	resp := new(CommonResponse)
+	resp.Data = new(ReviewNums)
+	return resp
+}

route/init.go

@@ -34,7 +34,7 @@ func InitRoute(r *gin.Engine) {
 			c.JSON(200, resp)
 		})
 		m.GET("/product/getEnterpriseIds", handler.WrapGetEnterpriseIdsHandler)                    // 获取所有企业用户id
-		m.POST("/product/list", handler.WrapFullProjectListHandler)                                // 查询项目列表
+		m.POST("/product/list", handler.WrapFullProjectListHandler)                                // 查询项目（全流程）列表
 		m.POST("/project/show", handler.WrapShowProjectHandler)                                    // 项目展示查询
 		m.POST("/project/handle", handler.WrapProjectHandleHandler)                                // 项目线索处理
 		m.POST("/product/findall", handler.WrapFindEnterpriseAllProductHandler)                    // 企业用户详情所有产品
@@ -170,9 +170,9 @@ func InitRoute(r *gin.Engine) {
 		f.Use(middleware.LoginAuthMiddleware)
 		f.POST("/withdrawalRecords", handler.WrapWithdrawalRecordsHandler)     // 搜索提现记录
 		f.POST("/getWithdrawalRecord", handler.WrapGetWithdrawalRecordHandler) // 查看提现记录
-		f.GET("/getWithdrawNums", handler.WrapGetWithdrawNumsHandler)          // 获取待提现的数量
-		f.GET("/getInvoiceNums", handler.WrapGetInvoiceNumsHandler)            // 获取待提现的数量
-		f.GET("/getRechargeNums", handler.WrapGetRechargeNumsHandler)          // 获取待开票的数量
+		f.GET("/getWithdrawNums", handler.WrapGetWithdrawNumsHandler)          // 获取提现待确认的数量
+		f.GET("/getInvoiceNums", handler.WrapGetInvoiceNumsHandler)            // 获取待开票的数量
+		f.GET("/getRechargeNums", handler.WrapGetRechargeNumsHandler)          // 获取充值待确认的数量
 		f.POST("/ConfirmWithdrawal", handler.WrapConfirmWithdrawalHandler)     // 确认提现
 		f.POST("/getBankInfo", handler.WrapGetBankInfoHandler)                 // 获取银行开户地信息
 		f.POST("/getCodeUrl", handler.WrapGetCodeUrlHandler)                   // 获取微信支付链接
@@ -180,5 +180,12 @@ func InitRoute(r *gin.Engine) {
 		f.POST("/confirmInvoice", handler.WrapConfirmInvoiceHandler)           // 确认开票
 		f.POST("/rechargeRecords", handler.WrapRechargeRecordsHandler)         // 搜索充值记录
 		f.POST("/operateRecharge", handler.WrapOperateRechargeHandler)         // 充值记录的修改和确认操作
+
+	}
+	// 选品广场相关接口
+	s := r.Group("/youngee/m/selection")
+	{
+		s.Use(middleware.LoginAuthMiddleware)
+		s.GET("/reviewnumber", handler.WrapSelectionReviewNumberHandler) //查询选品待审核的数量
 	}
 }