UpdateJob

db/job.go

@@ -0,0 +1,27 @@
+package db
+
+import (
+	"context"
+	"youngee_b_api/model/gorm_model"
+)
+
+// CreateJob 新建岗位
+func CreateJob(ctx context.Context, job gorm_model.YounggeeJob) error {
+	db := GetWriteDB(ctx)
+	err := db.Create(&job).Error
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
+// UpdateJob 更新岗位
+func UpdateJob(ctx context.Context, job gorm_model.YounggeeJob) error {
+	db := GetWriteDB(ctx)
+	whereCondition := gorm_model.YounggeeJob{JobId: job.JobId}
+	err := db.Model(&gorm_model.YounggeeJob{}).Where(whereCondition).Updates(job).Error
+	if err != nil {
+		return err
+	}
+	return nil
+}

handler/addNewJob.go

@@ -4,6 +4,7 @@ import (
 	"fmt"
 	"github.com/gin-gonic/gin"
 	"youngee_b_api/model/http_model"
+	"youngee_b_api/service"
 )
 
 func WrapaddNewJobHandler(ctx *gin.Context) {
@@ -36,7 +37,14 @@ func (h *AddNewJobHandler) getResponse() interface{} {
 }
 func (h *AddNewJobHandler) run() {
 	fmt.Println("AddNewJobHandler Running")
-	fmt.Println("岗位信息：", h.req)
+	// fmt.Println("岗位信息：", h.req)
+	jobData := http_model.AddNewJobRequest{}
+	jobData = *h.req
+	err := service.Job.CreateJob(h.ctx, jobData)
+	if err != nil {
+		fmt.Println(err)
+	}
+	return
 }
 
 func (h *AddNewJobHandler) checkParam() error {

handler/updateJob.go

@@ -0,0 +1,50 @@
+package handler
+
+import (
+	"fmt"
+	"github.com/gin-gonic/gin"
+	"youngee_b_api/model/http_model"
+	"youngee_b_api/service"
+)
+
+func WrapupdateJobHandler(ctx *gin.Context) {
+	handler := newupdateJobHandler(ctx)
+	baseRun(handler)
+}
+
+func newupdateJobHandler(ctx *gin.Context) *UpdateNewJobHandler {
+	return &UpdateNewJobHandler{
+		req:  http_model.NewUpdateJobRequest(),
+		resp: http_model.NewUpdateJobResponse(),
+		ctx:  ctx,
+	}
+}
+
+type UpdateNewJobHandler struct {
+	req  *http_model.UpdateJobRequest
+	resp *http_model.CommonResponse
+	ctx  *gin.Context
+}
+
+func (h *UpdateNewJobHandler) getRequest() interface{} {
+	return h.req
+}
+func (h *UpdateNewJobHandler) getContext() *gin.Context {
+	return h.ctx
+}
+func (h *UpdateNewJobHandler) getResponse() interface{} {
+	return h.resp
+}
+func (h *UpdateNewJobHandler) run() {
+	jobData := http_model.UpdateJobRequest{}
+	jobData = *h.req
+	err := service.Job.UpdateJob(h.ctx, jobData)
+	if err != nil {
+		fmt.Println(err)
+	}
+	return
+}
+
+func (h *UpdateNewJobHandler) checkParam() error {
+	return nil
+}

model/gorm_model/job.go

@@ -1,14 +1,14 @@
 package gorm_model
 
 type YounggeeJob struct {
-	JobId                int    `gorm:"column:sub_account_id;primary_key;AUTO_INCREMENT"` // 子账号ID
-	JobName              string `gorm:"column:job_name"`                                  // 岗位名称
-	JobDetail            string `gorm:"column:job_detail"`                                // 岗位描述
-	WorkshopPermission   string `gorm:"column:workshop_permission"`                       // 工作台权限
-	TaskcenterPermission string `gorm:"column:taskcenter_permission"`                     // 任务中心权限
-	CoopratePermission   string `gorm:"column:cooprate_permission"`                       // 推广合作权限
-	FinancialPermission  string `gorm:"column:financial_permission"`                      // 财务结算权限
-	EnterpriseId         string `gorm:"column:enterprise_id"`                             // 岗位所属商家账号ID
+	JobId                int    `gorm:"column:job_id;primary_key;AUTO_INCREMENT"` // 岗位ID
+	JobName              string `gorm:"column:job_name"`                          // 岗位名称
+	JobDetail            string `gorm:"column:job_detail"`                        // 岗位描述
+	WorkshopPermission   string `gorm:"column:workshop_permission"`               // 工作台权限
+	TaskcenterPermission string `gorm:"column:taskcenter_permission"`             // 任务中心权限
+	CooperatePermission  string `gorm:"column:cooperate_permission"`              // 推广合作权限
+	FinancialPermission  string `gorm:"column:financial_permission"`              // 财务结算权限
+	EnterpriseId         string `gorm:"column:enterprise_id"`                     // 岗位所属商家账号ID
 }
 
 func (m *YounggeeJob) TableName() string {

model/http_model/addNewJob.go

@@ -5,7 +5,7 @@ type AddNewJobRequest struct {
 	JobName              string `json:"job_name"`              // 岗位名称
 	JobDetail            string `json:"job_detail"`            // 企业描述
 	WorkshopPermission   string `json:"workshop_permission"`   // 工作台权限
-	TaskCenterPermission string `json:"taskcenter_permission"` // 任务中心权限
+	TaskcenterPermission string `json:"taskcenter_permission"` // 任务中心权限
 	CooperatePermission  string `json:"cooperate_permission"`  // 推广合作中心权限
 	FinancialPermission  string `json:"financial_permission"`  // 财务结算权限
 }

model/http_model/updateJob.go

@@ -0,0 +1,25 @@
+package http_model
+
+type UpdateJobRequest struct {
+	JobId                int    `json:"job_id"`                // 岗位ID
+	EnterpriseId         string `json:"enterprise_id"`         // 企业ID
+	JobName              string `json:"job_name"`              // 岗位名称
+	JobDetail            string `json:"job_detail"`            // 企业描述
+	WorkshopPermission   string `json:"workshop_permission"`   // 工作台权限
+	TaskcenterPermission string `json:"taskcenter_permission"` // 任务中心权限
+	CooperatePermission  string `json:"cooperate_permission"`  // 推广合作中心权限
+	FinancialPermission  string `json:"financial_permission"`  // 财务结算权限
+}
+
+type UpdateJobData struct {
+}
+
+func NewUpdateJobRequest() *UpdateJobRequest {
+	return new(UpdateJobRequest)
+}
+
+func NewUpdateJobResponse() *CommonResponse {
+	resp := new(CommonResponse)
+	resp.Data = new(UpdateJobData)
+	return resp
+}

route/init.go

@@ -13,16 +13,13 @@ import (
 
 func InitRoute(r *gin.Engine) {
 	r.GET("/swagger/*any", ginSwagger.WrapHandler(swaggerFiles.Handler))
-	// 商家主账号注册
-	r.POST("/register", handler.WrapRegisterHandler)
-	// 商家子账号注册
-	r.POST("/addNewSubAccount", handler.WrapAddNewSubAccountHandler)
-	// 商家新增账号岗位
-	r.POST("/addNewJob", handler.WrapaddNewJobHandler)
-	// 发送登录验证码
-	r.POST("/sendCode", handler.WrapSendCodeHandler)
-	// 商家登录
-	r.POST("/login", handler.WrapCodeLoginHandler)
+	r.POST("/register", handler.WrapRegisterHandler)                 // 商家主账号注册
+	r.POST("/addNewSubAccount", handler.WrapAddNewSubAccountHandler) // 商家子账号注册
+	r.POST("/addNewJob", handler.WrapaddNewJobHandler)               // 商家新增岗位
+	r.POST("/updateJob", handler.WrapupdateJobHandler)               // 商家修改岗位
+	r.POST("/deleteJob", handler.WrapaddNewJobHandler)               // 商家删除岗位
+	r.POST("/sendCode", handler.WrapSendCodeHandler)                 // 发送登录验证码
+	r.POST("/login", handler.WrapCodeLoginHandler)                   // 商家登录
 	r.GET("/test/ping", func(c *gin.Context) {
 		resp := http_model.CommonResponse{
 			Status:  0,

service/job.go

@@ -2,14 +2,49 @@ package service
 
 import (
 	"context"
+	"youngee_b_api/db"
+	"youngee_b_api/model/gorm_model"
 	"youngee_b_api/model/http_model"
 )
 
-var Selection *job
+var Job *job
 
 type job struct {
 }
 
+// CreateJob 新增岗位
 func (*job) CreateJob(ctx context.Context, request http_model.AddNewJobRequest) error {
+	var newJob = gorm_model.YounggeeJob{
+		JobDetail:            request.JobDetail,
+		JobName:              request.JobName,
+		WorkshopPermission:   request.WorkshopPermission,
+		TaskcenterPermission: request.TaskcenterPermission,
+		CooperatePermission:  request.CooperatePermission,
+		FinancialPermission:  request.FinancialPermission,
+		EnterpriseId:         request.EnterpriseId,
+	}
+	err := db.CreateJob(ctx, newJob)
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
+// UpdateJob 修改岗位
+func (*job) UpdateJob(ctx context.Context, request http_model.UpdateJobRequest) error {
+	var newJob = gorm_model.YounggeeJob{
+		JobId:                request.JobId,
+		JobDetail:            request.JobDetail,
+		JobName:              request.JobName,
+		WorkshopPermission:   request.WorkshopPermission,
+		TaskcenterPermission: request.TaskcenterPermission,
+		CooperatePermission:  request.CooperatePermission,
+		FinancialPermission:  request.FinancialPermission,
+		EnterpriseId:         request.EnterpriseId,
+	}
+	err := db.UpdateJob(ctx, newJob)
+	if err != nil {
+		return err
+	}
 	return nil
 }