db/job.go

@@ -128,3 +128,46 @@ func GetJobDetail(ctx context.Context, req *http_model.JobDetailRequest) (*http_
 	}
 	return subaccountInfolist, nil
 }
+
+func GetJobdDetail(ctx context.Context, req *http_model.JobShowRequest) (*http_model.GetJobshowData, error) {
+	db := GetReadDB(ctx)
+	var jobdetail gorm_model.YounggeeJob
+	err := db.Model(gorm_model.YounggeeJob{}).Where("job_id = ?", req.JobId).Find(&jobdetail).Error
+	if err != nil {
+		return nil, err
+	}
+	response := &http_model.GetJobshowData{
+		JobId:                jobdetail.JobId,
+		JobName:              jobdetail.JobName,
+		JobDetail:            jobdetail.JobDetail,
+		WorkshopPermission:   jobdetail.WorkshopPermission,
+		TaskcenterPermission: jobdetail.TaskcenterPermission,
+		SectaskPermisson:     jobdetail.SectaskPermisson,
+		FinancialPermission:  jobdetail.FinancialPermission,
+		UsercenterPermission: jobdetail.UsercenterPermission,
+		OperatePermission:    jobdetail.OperatePermission,
+	}
+	return response, nil
+}
+
+func GetJobList(ctx context.Context, req *http_model.JobListRequest) (*http_model.JobListResponse, error) {
+	db := GetReadDB(ctx)
+	var jobs []gorm_model.YounggeeJob
+	if err := db.Find(&jobs).Error; err != nil {
+		return nil, err
+	}
+
+	response := &http_model.JobListResponse{
+		Jobs: make([]http_model.JoBInfo, 0, len(jobs)), // 预分配空间
+	}
+
+	// 遍历并映射每个 Job
+	for _, job := range jobs {
+		response.Jobs = append(response.Jobs, http_model.JoBInfo{
+			JobId:   job.JobId,
+			JobName: job.JobName,
+		})
+	}
+
+	return response, nil
+}

db/set_serveratio.go

@@ -14,3 +14,13 @@ func SetServeratio(ctx context.Context, req *http_model.SetServeratioRequest) er
 	}
 	return nil
 }
+
+func GetServeratio(ctx context.Context, req *http_model.GetServeratioRequest) (*http_model.GetServeratioResponse, error) {
+	db := GetReadDB(ctx)
+	var serve_ratio gorm_model.YounggeeServeRatio
+	err := db.First(&serve_ratio).Error
+	if err != nil {
+		return nil, err
+	}
+	return &http_model.GetServeratioResponse{Ratio: serve_ratio.Ratio}, nil
+}

db/subaccount.go

@@ -103,11 +103,8 @@ func GetSubAccountDetail(ctx context.Context, req *http_model.SubAccountDetailRe
 	if req.AccountStatus != nil {
 		query = query.Where("account_status = ?", *req.AccountStatus)
 	}
-	if req.PhoneNumber != nil {
-		query = query.Where("phone_number = ?", *req.PhoneNumber)
-	}
-	if req.SubAccountName != nil {
-		query = query.Where("account_name = ?", *req.SubAccountName)
+	if req.Others != "" {
+		query = query.Where("phone_number LIKE ? OR sub_account_name LIKE ?", "%"+req.Others+"%", "%"+req.Others+"%")
 	}
 
 	// 查询总数
@@ -224,3 +221,18 @@ func DeleteSubAccount(ctx context.Context, req *http_model.DeleteSubAccountReque
 	tx.Commit()
 	return nil
 }
+
+func GetSubAccdDetail(ctx context.Context, req *http_model.SubAccShowRequest) (*http_model.GetSubAccountData, error) {
+	db := GetReadDB(ctx)
+	var subaccount gorm_model.YounggeeSubAccount
+	err := db.Model(gorm_model.YounggeeSubAccount{}).Where("sub_account_id = ?", req.SubaccountId).Find(&subaccount).Error
+	if err != nil {
+		return nil, err
+	}
+	response := &http_model.GetSubAccountData{
+		SubAccountName: subaccount.SubAccountName,
+		Phonenumber:    subaccount.PhoneNumber,
+		JobId:          subaccount.JobId,
+	}
+	return response, nil
+}

db/talent.go

@@ -208,3 +208,14 @@ func UpdateKuaishouUserInfoByTalentID(ctx context.Context, talentInfo gorm_model
 	}
 	return err
 }
+
+// UpdateKuaishouUserInfoById 根据platform_user_id更新
+func UpdateKuaishouUserInfoById(ctx context.Context, talentInfo gorm_model.PlatformKuaishouUserInfo) error {
+	db6 := GetReadDB(ctx)
+	whereCondition := gorm_model.PlatformKuaishouUserInfo{Id: talentInfo.Id}
+	err := db6.Model(gorm_model.PlatformKuaishouUserInfo{}).Where(whereCondition).Updates(talentInfo).Error
+	if err != nil {
+		return err
+	}
+	return err
+}

handler/create_job.go

@@ -37,6 +37,7 @@ func (c CreateJobHandler) run() {
 	}
 	c.resp.Message = "成功创建岗位"
 	c.resp.Data = res
+	c.resp.Status = consts.ErrorSuccess
 
 }
 func (c CreateJobHandler) checkParam() error {

handler/create_sub_account.go

@@ -49,12 +49,9 @@ func (c CreateSubAccountHandler) run() {
 		c.resp.Message = "创建成功"
 		// 4. 返回ok
 		c.resp.Data = res
+		c.resp.Status = consts.ErrorSuccess
 	} else if message == "手机号已存在" {
-		c.resp.Message = message
-		c.resp.Status = 1
-	} else {
-		c.resp.Message = message
-		c.resp.Status = 2
+		c.resp.Status = consts.ErrorInternal
 	}
 
 }

handler/delete_job.go

@@ -36,6 +36,7 @@ func (c DeleteJobHandler) run() {
 		return
 	}
 	c.resp.Message = "成功删除岗位"
+	c.resp.Status = consts.ErrorSuccess
 }
 func (c DeleteJobHandler) checkParam() error {
 	return nil

handler/delete_ks.go

@@ -36,6 +36,7 @@ func (c DeleteKsauthorizationHandler) run() {
 		return
 	}
 	c.resp.Message = "成功删除授权"
+	c.resp.Status = consts.ErrorSuccess
 }
 func (c DeleteKsauthorizationHandler) checkParam() error {
 	return nil

handler/delete_subaccount.go

@@ -41,6 +41,7 @@ func (d DeleteSubAccount) run() {
 		return
 	}
 	d.resp.Message = "删除成功"
+	d.resp.Status = consts.ErrorSuccess
 }
 
 func (d DeleteSubAccount) checkParam() error {

handler/get_serveraio.go

@@ -0,0 +1,53 @@
+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 WrapGetServeratioHandler(ctx *gin.Context) {
+	handler := newGetServeratioHandler(ctx)
+	BaseRun(handler)
+}
+
+type GetServeratioHandler struct {
+	ctx  *gin.Context
+	req  *http_model.GetServeratioRequest
+	resp *http_model.CommonResponse
+}
+
+func (c GetServeratioHandler) getContext() *gin.Context { return c.ctx }
+func (c GetServeratioHandler) getResponse() interface{} { return c.resp }
+func (c GetServeratioHandler) getRequest() interface{} {
+	return c.req
+}
+func (c GetServeratioHandler) run() {
+	data := http_model.GetServeratioRequest{}
+	data = *c.req
+	res, err := db.GetServeratio(c.ctx, &data)
+	if err != nil {
+		logrus.Errorf("[GetServeratioHandler] call GetServeratio err:%+v\n", err)
+		util.HandlerPackErrorResp(c.resp, consts.ErrorInternal, "")
+		logrus.Info("GetServeratioHandler fail,req:%+v", c.req)
+		return
+	}
+	c.resp.Message = "成功获取服务费率"
+	c.resp.Status = consts.ErrorSuccess
+	c.resp.Data = res
+
+}
+func (c GetServeratioHandler) checkParam() error {
+	return nil
+}
+
+func newGetServeratioHandler(ctx *gin.Context) *GetServeratioHandler {
+	return &GetServeratioHandler{
+		ctx:  ctx,
+		req:  http_model.NewGetServeratioRequest(),
+		resp: http_model.NewGetServeratioResponse(),
+	}
+}

handler/getauthorization.go

@@ -37,6 +37,7 @@ func (c GetAuthorizationHandler) run() {
 	}
 	c.resp.Message = "成功查询"
 	c.resp.Data = res
+	c.resp.Status = consts.ErrorSuccess
 }
 func (c GetAuthorizationHandler) checkParam() error {
 	return nil

handler/joblist.go

@@ -0,0 +1,60 @@
+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 WrapJobListHandler(ctx *gin.Context) {
+	handler := newJobListHandler(ctx)
+	BaseRun(handler)
+}
+
+type JobList struct {
+	ctx  *gin.Context
+	req  *http_model.JobListRequest
+	resp *http_model.CommonResponse
+}
+
+func (c JobList) getContext() *gin.Context {
+	return c.ctx
+}
+
+func (c JobList) getResponse() interface{} {
+	return c.resp
+}
+
+func (c JobList) getRequest() interface{} {
+	return c.req
+}
+
+func (c JobList) run() {
+	data := http_model.JobListRequest{}
+	data = *c.req
+	res, err := db.GetJobList(c.ctx, &data)
+	if err != nil {
+		logrus.Errorf("[JobList] call JobList err:%+v\n", err)
+		util.HandlerPackErrorResp(c.resp, consts.ErrorParamCheck, "")
+		logrus.Info("JobList fail,req:%+v", c.req)
+		return
+	}
+	c.resp.Message = "成功查询岗位"
+	c.resp.Data = res
+	c.resp.Status = consts.ErrorSuccess
+}
+
+func (c JobList) checkParam() error {
+	return nil
+}
+
+func newJobListHandler(ctx *gin.Context) *JobList {
+	return &JobList{
+		ctx:  ctx,
+		req:  http_model.NewJobListRequest(),
+		resp: http_model.NewJobListResponse(),
+	}
+}

handler/jobshow.go

@@ -0,0 +1,52 @@
+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 WrapJobShowHandler(ctx *gin.Context) {
+	handler := newJobShowHandler(ctx)
+	BaseRun(handler)
+}
+
+type JobShowHandler struct {
+	ctx  *gin.Context
+	req  *http_model.JobShowRequest
+	resp *http_model.CommonResponse
+}
+
+func (c JobShowHandler) getContext() *gin.Context { return c.ctx }
+func (c JobShowHandler) getResponse() interface{} { return c.resp }
+func (c JobShowHandler) getRequest() interface{} {
+	return c.req
+}
+func (c JobShowHandler) run() {
+	data := http_model.JobShowRequest{}
+	data = *c.req
+	res, err := db.GetJobdDetail(c.ctx, &data)
+	if err != nil {
+		logrus.Errorf("[JobShowHandler] call JobShow err:%+v\n", err)
+		util.HandlerPackErrorResp(c.resp, consts.ErrorInternal, "")
+		logrus.Info("JobShowHandler fail,req:%+v", c.req)
+		return
+	}
+	c.resp.Message = "成功查询"
+	c.resp.Data = res
+	c.resp.Status = consts.ErrorSuccess
+}
+func (c JobShowHandler) checkParam() error {
+	return nil
+}
+
+func newJobShowHandler(ctx *gin.Context) *JobShowHandler {
+	return &JobShowHandler{
+		ctx:  ctx,
+		req:  http_model.NewJobShowRequest(),
+		resp: http_model.NewJobShowResponse(),
+	}
+}

handler/kuaishouauthorization.go

@@ -36,6 +36,7 @@ func (c AuthkuaishouHandler) run() {
 		return
 	}
 	c.resp.Message = "成功创建授权账号"
+	c.resp.Status = consts.ErrorSuccess
 
 }
 func (c AuthkuaishouHandler) checkParam() error {

handler/send_code.go

@@ -72,6 +72,7 @@ func (h *SendCodeHandler) run() {
 		return
 	}
 	h.resp.Message = "验证码发送成功，请注意查收"
+	h.resp.Status = consts.ErrorSuccess
 }
 func (h *SendCodeHandler) checkParam() error {
 	return nil

handler/set_serveratio.go

@@ -36,6 +36,7 @@ func (c SetServeratioHandler) run() {
 		return
 	}
 	c.resp.Message = "成功设置服务费率"
+	c.resp.Status = consts.ErrorSuccess
 
 }
 func (c SetServeratioHandler) checkParam() error {

handler/stop_subaccount.go

@@ -44,6 +44,7 @@ func (s StopSubAccountHandler) run() {
 	}
 	s.resp.Message = "成功停用岗位"
 	s.resp.Data = res
+	s.resp.Status = consts.ErrorSuccess
 
 }
 

handler/sub_account_detail.go

@@ -43,6 +43,9 @@ func (s SubAccountDetailHandler) run() {
 		return
 	}
 	s.resp.Data = res
+	s.resp.Status = consts.ErrorSuccess
+	s.resp.Message = "成功查询子账号列表" +
+		""
 
 }
 

handler/subaccshow.go

@@ -0,0 +1,52 @@
+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 WrapSubAccShowHandler(ctx *gin.Context) {
+	handler := newSubAccShowHandler(ctx)
+	BaseRun(handler)
+}
+
+type SubAccShowHandler struct {
+	ctx  *gin.Context
+	req  *http_model.SubAccShowRequest
+	resp *http_model.CommonResponse
+}
+
+func (c SubAccShowHandler) getContext() *gin.Context { return c.ctx }
+func (c SubAccShowHandler) getResponse() interface{} { return c.resp }
+func (c SubAccShowHandler) getRequest() interface{} {
+	return c.req
+}
+func (c SubAccShowHandler) run() {
+	data := http_model.SubAccShowRequest{}
+	data = *c.req
+	res, err := db.GetSubAccdDetail(c.ctx, &data)
+	if err != nil {
+		logrus.Errorf("[SubAccShowHandler] call SubAccShow err:%+v\n", err)
+		util.HandlerPackErrorResp(c.resp, consts.ErrorInternal, "")
+		logrus.Info("SubAccShowHandler fail,req:%+v", c.req)
+		return
+	}
+	c.resp.Message = "成功查询"
+	c.resp.Data = res
+	c.resp.Status = consts.ErrorSuccess
+}
+func (c SubAccShowHandler) checkParam() error {
+	return nil
+}
+
+func newSubAccShowHandler(ctx *gin.Context) *SubAccShowHandler {
+	return &SubAccShowHandler{
+		ctx:  ctx,
+		req:  http_model.NewSubAccShowRequest(),
+		resp: http_model.NewSubAccShowResponse(),
+	}
+}

handler/update_job_info.go

@@ -47,6 +47,7 @@ func (u UpdateJobInfoHandler) run() {
 	}
 	u.resp.Message = "编辑创建岗位"
 	u.resp.Data = res
+	u.resp.Status = consts.ErrorSuccess
 }
 func (u UpdateJobInfoHandler) checkParam() error {
 	return nil

handler/update_subaccount_info.go

@@ -57,8 +57,10 @@ func (u UpdateSubAccountInfoHandler) run() {
 		}
 		u.resp.Message = "编辑成功"
 		u.resp.Data = res
+		u.resp.Status = consts.ErrorSuccess
 	} else {
 		u.resp.Message = message
+		u.resp.Status = consts.ErrorInternal
 	}
 }
 func (u UpdateSubAccountInfoHandler) checkParam() error {

model/http_model/SubAccountDetail.go

@@ -3,12 +3,11 @@ package http_model
 import "youngee_m_api/model/gorm_model"
 
 type SubAccountDetailRequest struct {
-	PageSize       int     `json:"page_size"`
-	PageNum        int     `json:"page_num"`
-	JobId          *int    `json:"job_id,omitempty"`           // 可选的岗位类型
-	AccountStatus  *int    `json:"account_status,omitempty"`   // 可选的账号状态
-	PhoneNumber    *string `json:"phone_number,omitempty"`     // 可选的手机号
-	SubAccountName *string `json:"sub_account_name,omitempty"` // 可选的账号名称
+	PageSize      int    `json:"page_size"`
+	PageNum       int    `json:"page_num"`
+	JobId         *int   `json:"job_id,omitempty"`         // 可选的岗位类型
+	AccountStatus *int   `json:"account_status,omitempty"` // 可选的账号状态
+	Others        string `json:"others,omitempty"`         //手机号或账号名称
 }
 
 type SubAccountDetailResponse struct {

model/http_model/get_serveratio.go

@@ -0,0 +1,13 @@
+package http_model
+
+type GetServeratioRequest struct {
+}
+
+type GetServeratioResponse struct {
+	Ratio string `json:"ratio"`
+}
+
+func NewGetServeratioRequest() *GetServeratioRequest { return new(GetServeratioRequest) }
+func NewGetServeratioResponse() *CommonResponse {
+	return new(CommonResponse)
+}

model/http_model/joblistrequest.go

@@ -0,0 +1,23 @@
+package http_model
+
+type JobListRequest struct {
+}
+
+type JobListResponse struct {
+	Jobs []JoBInfo `json:"Jobs"`
+}
+
+type JoBInfo struct {
+	JobId   int    `json:"job_id"`
+	JobName string `json:"job_name"`
+}
+
+func NewJobListRequest() *JobListRequest {
+	return new(JobListRequest)
+}
+
+func NewJobListResponse() *CommonResponse {
+	resp := new(CommonResponse)
+	resp.Data = new(JobListResponse)
+	return resp
+}

model/http_model/jobshow.go

@@ -0,0 +1,26 @@
+package http_model
+
+type JobShowRequest struct {
+	JobId string `json:"job_id"`
+}
+
+type GetJobshowData struct {
+	JobId                int    `json:"job_id"`                //岗位ID
+	JobName              string `json:"job_name"`              //岗位名称
+	JobDetail            string `json:"ob_detail"`             //岗位描述
+	WorkshopPermission   string `json:"workshop_permission"`   //工作台权限
+	TaskcenterPermission string `json:"taskcenter_permission"` //任务中心权限
+	SectaskPermisson     string `json:"sectask_permisson"`     //商单中心权限
+	FinancialPermission  string `json:"financial_permission"`  //财务结算权限
+	UsercenterPermission string `json:"usercenter_permission"` //用户中心权限
+	OperatePermission    string `json:"operate_permission"`    //运营中心权限
+}
+
+func NewJobShowRequest() *JobShowRequest {
+	return new(JobShowRequest)
+}
+func NewJobShowResponse() *CommonResponse {
+	resp := new(CommonResponse)
+	resp.Data = new(GetJobshowData)
+	return resp
+}

model/http_model/subaccshowrequest.go

@@ -0,0 +1,20 @@
+package http_model
+
+type SubAccShowRequest struct {
+	SubaccountId string `json:"sub_account_id"`
+}
+
+type GetSubAccountData struct {
+	Phonenumber    string `json:"phonenumber"`
+	SubAccountName string `json:"sub_account_name"`
+	JobId          int    `json:"job_id"`
+}
+
+func NewSubAccShowRequest() *SubAccShowRequest {
+	return new(SubAccShowRequest)
+}
+func NewSubAccShowResponse() *CommonResponse {
+	resp := new(CommonResponse)
+	resp.Data = new(GetSubAccountData)
+	return resp
+}

route/init.go

@@ -11,8 +11,8 @@ import (
 
 func InitRoute(r *gin.Engine) {
 
-	r.POST("/login", handler.WrapCodeLoginHandler)
-	r.GET("/getLoginUser", handler.WrapGetLoginUserHandler)
+	r.POST("/youngee/m/login", handler.WrapCodeLoginHandler)
+	r.GET("/youngee/m/getLoginUser", handler.WrapGetLoginUserHandler)
 	r.POST("/userInfo", handler.WrapGetUserInfoHandler)
 	r.GET("/test/ping", func(c *gin.Context) {
 		resp := http_model.CommonResponse{
@@ -331,7 +331,7 @@ func InitRoute(r *gin.Engine) {
 		w.POST("/takegoods", handler.WrapGetTakegoodsDataHandler) //查询时间内带货量
 	}
 	//运营中心相关接口
-	n := r.Group("/youngee/run")
+	n := r.Group("/youngee/m/run")
 	{
 		n.Use(middleware.LoginAuthMiddleware)
 		n.POST("/sendCode", handler.WrapSendCodeHandler)                         //发送验证码
@@ -340,13 +340,17 @@ func InitRoute(r *gin.Engine) {
 		n.POST("/addnewjob", handler.WrapCreateJobHandler)                       //创建岗位
 		n.POST("/editjob", handler.WrapEditJobHandler)                           //编辑岗位
 		n.POST("/subaccountdetail", handler.WrapSubAccountDetailHandler)         //查询子账号列表
+		n.POST("/subaccshow", handler.WrapSubAccShowHandler)                     //查询子账号详情
 		n.POST("/stopsubaccount", handler.WrapStopSubAccountHandler)             //停用子账号
 		n.POST("/deletesubaccount", handler.WrapDeleteSubAccountHandler)         //删除子账号
 		n.POST("/deletejob", handler.WrapDeleteJobHandler)                       //删除岗位
+		n.POST("/joblist", handler.WrapJobListHandler)                           //获取所有岗位，名称
 		n.POST("/jobdetail", handler.WrapJobDetailHandler)                       //岗位列表
+		n.POST("/jobshow", handler.WrapJobShowHandler)                           //岗位详情
 		n.POST("/addauthorization", handler.WrapAuthkuaishouHandler)             //新增快手授权
 		n.POST("/KSauthorizationlist", handler.WrapGetAuthorizationListHandler)  //查询授权结果
 		n.POST("/deleteksauthorization", handler.WrapDeleteauthorizationHandler) //删除授权
 		n.POST("/serveratio", handler.WrapSetServeratioHandler)                  //设置服务费率
+		n.POST("/getserveratio", handler.WrapGetServeratioHandler)               //获取服务费率
 	}
 }

service/auto_task.go

@@ -7,13 +7,9 @@ import (
 	"github.com/lin-jim-leon/kuaishou"
 	"github.com/robfig/cron/v3"
 	"github.com/sirupsen/logrus"
-	"log"
-	"strconv"
-	"time"
 	"youngee_m_api/consts"
 	"youngee_m_api/db"
 	"youngee_m_api/model/gorm_model"
-	"youngee_m_api/model/http_model"
 )
 
 func AutoTask() error {
@@ -47,222 +43,226 @@ func AutoTask() error {
 		}
 	}
 
-	//	定时任务1 ，线下探店打卡的自动签收操作
-	task1 := func() {
-		DB := db.GetReadDB(context.Background())
-		autoTaskTime := gorm_model.InfoAutoTask{}
-		DB.Model(gorm_model.InfoAutoTask{}).Last(&autoTaskTime)
-		if autoTaskTime.SignInOffline != 0 {
-			err := db.GetSignInOfflineTask(3)
-			if err != nil {
-				logrus.Error("[GetSignInOfflineTask] in DB error %+v", err)
-				return
+	/*
+
+		//	定时任务1 ，线下探店打卡的自动签收操作
+		task1 := func() {
+			DB := db.GetReadDB(context.Background())
+			autoTaskTime := gorm_model.InfoAutoTask{}
+			DB.Model(gorm_model.InfoAutoTask{}).Last(&autoTaskTime)
+			if autoTaskTime.SignInOffline != 0 {
+				err := db.GetSignInOfflineTask(3)
+				if err != nil {
+					logrus.Error("[GetSignInOfflineTask] in DB error %+v", err)
+					return
+				}
 			}
+			log.Println("GetSignInOfflineTask is running ,Time :", time.Now())
 		}
-		log.Println("GetSignInOfflineTask is running ,Time :", time.Now())
-	}
 
-	// 定时任务2 ，虚拟产品测评的自动签收操作
-	task2 := func() {
-		DB := db.GetReadDB(context.Background())
-		autoTaskTime := gorm_model.InfoAutoTask{}
-		DB.Model(gorm_model.InfoAutoTask{}).Last(&autoTaskTime)
-		if autoTaskTime.SignInVirtual != 0 {
-			err := db.GetSignInOfflineTask(2)
-			if err != nil {
-				logrus.Error("[GetSignInVirtualTask] in DB error %+v", err)
-				return
+		// 定时任务2 ，虚拟产品测评的自动签收操作
+		task2 := func() {
+			DB := db.GetReadDB(context.Background())
+			autoTaskTime := gorm_model.InfoAutoTask{}
+			DB.Model(gorm_model.InfoAutoTask{}).Last(&autoTaskTime)
+			if autoTaskTime.SignInVirtual != 0 {
+				err := db.GetSignInOfflineTask(2)
+				if err != nil {
+					logrus.Error("[GetSignInVirtualTask] in DB error %+v", err)
+					return
+				}
 			}
+			log.Println("GetSignInVirtualTask is running ,Time :", time.Now())
 		}
-		log.Println("GetSignInVirtualTask is running ,Time :", time.Now())
-	}
 
-	// 定时任务3 ，视频形式的审稿处理
-	task3 := func() {
-		DB := db.GetReadDB(context.Background())
-		autoTaskTime := gorm_model.InfoAutoTask{}
-		DB.Model(gorm_model.InfoAutoTask{}).Last(&autoTaskTime)
-		if autoTaskTime.ReviewInMv != 0 {
-			err := db.GetAutoReviewTask(2)
-			if err != nil {
-				logrus.Error("[GetAutoReviewTask] in DB error %+v", err)
-				return
+		// 定时任务3 ，视频形式的审稿处理
+		task3 := func() {
+			DB := db.GetReadDB(context.Background())
+			autoTaskTime := gorm_model.InfoAutoTask{}
+			DB.Model(gorm_model.InfoAutoTask{}).Last(&autoTaskTime)
+			if autoTaskTime.ReviewInMv != 0 {
+				err := db.GetAutoReviewTask(2)
+				if err != nil {
+					logrus.Error("[GetAutoReviewTask] in DB error %+v", err)
+					return
+				}
 			}
+			log.Println("GetAutoReviewTask is running ,Time :", time.Now())
 		}
-		log.Println("GetAutoReviewTask is running ,Time :", time.Now())
-	}
 
-	// 定时任务4 ，不限形式的审稿处理
-	task4 := func() {
-		DB := db.GetReadDB(context.Background())
-		autoTaskTime := gorm_model.InfoAutoTask{}
-		DB.Model(gorm_model.InfoAutoTask{}).Last(&autoTaskTime)
-		if autoTaskTime.ReviewUnlimited != 0 {
-			err := db.GetAutoReviewTask(0)
-			if err != nil {
-				logrus.Error("[GetAutoReviewUnlimitedTask] in DB error %+v", err)
-				return
+		// 定时任务4 ，不限形式的审稿处理
+		task4 := func() {
+			DB := db.GetReadDB(context.Background())
+			autoTaskTime := gorm_model.InfoAutoTask{}
+			DB.Model(gorm_model.InfoAutoTask{}).Last(&autoTaskTime)
+			if autoTaskTime.ReviewUnlimited != 0 {
+				err := db.GetAutoReviewTask(0)
+				if err != nil {
+					logrus.Error("[GetAutoReviewUnlimitedTask] in DB error %+v", err)
+					return
+				}
 			}
+			log.Println("GetAutoReviewUnlimitedTask is running ,Time :", time.Now())
 		}
-		log.Println("GetAutoReviewUnlimitedTask is running ,Time :", time.Now())
-	}
 
-	// 定时任务5 ，发布审核自动处理
-	task5 := func() {
-		DB := db.GetReadDB(context.Background())
-		autoTaskTime := gorm_model.InfoAutoTask{}
-		DB.Model(gorm_model.InfoAutoTask{}).Last(&autoTaskTime)
-		if autoTaskTime.Postreview != 0 {
-			err := db.GetAutoPostReviewTask()
-			if err != nil {
-				logrus.Error("[GetAutoPostReviewTask] in DB error %+v", err)
-				return
+		// 定时任务5 ，发布审核自动处理
+		task5 := func() {
+			DB := db.GetReadDB(context.Background())
+			autoTaskTime := gorm_model.InfoAutoTask{}
+			DB.Model(gorm_model.InfoAutoTask{}).Last(&autoTaskTime)
+			if autoTaskTime.Postreview != 0 {
+				err := db.GetAutoPostReviewTask()
+				if err != nil {
+					logrus.Error("[GetAutoPostReviewTask] in DB error %+v", err)
+					return
+				}
 			}
+			log.Println("GetAutoPostReviewTask is running ,Time :", time.Now())
 		}
-		log.Println("GetAutoPostReviewTask is running ,Time :", time.Now())
-	}
 
-	// 定时任务6 ，项目结案自动处理
-	task6 := func() {
-		DB := db.GetReadDB(context.Background())
-		autoTaskTime := gorm_model.InfoAutoTask{}
-		DB.Model(gorm_model.InfoAutoTask{}).Last(&autoTaskTime)
-		if autoTaskTime.CaseClose != 0 {
-			err := db.GetAutoCaseCloseTask()
-			if err != nil {
-				logrus.Error("[GetAutoCaseCloseTask] in DB error %+v", err)
-				return
+		// 定时任务6 ，项目结案自动处理
+		task6 := func() {
+			DB := db.GetReadDB(context.Background())
+			autoTaskTime := gorm_model.InfoAutoTask{}
+			DB.Model(gorm_model.InfoAutoTask{}).Last(&autoTaskTime)
+			if autoTaskTime.CaseClose != 0 {
+				err := db.GetAutoCaseCloseTask()
+				if err != nil {
+					logrus.Error("[GetAutoCaseCloseTask] in DB error %+v", err)
+					return
+				}
 			}
+			log.Println("GetAutoCaseCloseTask is running ,Time :", time.Now())
 		}
-		log.Println("GetAutoCaseCloseTask is running ,Time :", time.Now())
-	}
 
-	// 定时任务7  全流程项目失效自动处理
-	task7 := func() {
-		DB := db.GetReadDB(context.Background())
-		autoTaskTime := gorm_model.InfoAutoTask{}
-		DB.Model(gorm_model.InfoAutoTask{}).Last(&autoTaskTime)
-		if autoTaskTime.Invalid != 0 {
-			err := db.GetAutoInvalidTask()
-			if err != nil {
-				logrus.Error("[GetAutoInvalidTask] in DB error %+v", err)
-				return
+		// 定时任务7  全流程项目失效自动处理
+		task7 := func() {
+			DB := db.GetReadDB(context.Background())
+			autoTaskTime := gorm_model.InfoAutoTask{}
+			DB.Model(gorm_model.InfoAutoTask{}).Last(&autoTaskTime)
+			if autoTaskTime.Invalid != 0 {
+				err := db.GetAutoInvalidTask()
+				if err != nil {
+					logrus.Error("[GetAutoInvalidTask] in DB error %+v", err)
+					return
+				}
 			}
+			log.Println("GetAutoInvalidTask is running ,Time :", time.Now())
 		}
-		log.Println("GetAutoInvalidTask is running ,Time :", time.Now())
-	}
 
-	// 定时任务8.图文形式的初稿违约自动处理
-	task8 := func() {
-		DB := db.GetReadDB(context.Background())
-		autoTaskTime := gorm_model.InfoAutoTask{}
-		DB.Model(gorm_model.InfoAutoTask{}).Last(&autoTaskTime)
-		if autoTaskTime.DraftDefaultInPic != 0 {
-			err := db.GetAutoDraftDefaultInPicTask()
-			if err != nil {
-				logrus.Error("[GetAutoDraftDefaultInPicTask] in DB error %+v", err)
-				return
+		// 定时任务8.图文形式的初稿违约自动处理
+		task8 := func() {
+			DB := db.GetReadDB(context.Background())
+			autoTaskTime := gorm_model.InfoAutoTask{}
+			DB.Model(gorm_model.InfoAutoTask{}).Last(&autoTaskTime)
+			if autoTaskTime.DraftDefaultInPic != 0 {
+				err := db.GetAutoDraftDefaultInPicTask()
+				if err != nil {
+					logrus.Error("[GetAutoDraftDefaultInPicTask] in DB error %+v", err)
+					return
+				}
 			}
+			log.Println("GetAutoDraftDefaultInPicTask is running ,Time :", time.Now())
 		}
-		log.Println("GetAutoDraftDefaultInPicTask is running ,Time :", time.Now())
-	}
 
-	// 定时任务9.视频形式的初稿违约自动处理
-	task9 := func() {
-		DB := db.GetReadDB(context.Background())
-		var DraftDefaultInMvTime int32
-		DB.Select("draft_default_in_mv").Model(gorm_model.InfoAutoTask{}).Last(&DraftDefaultInMvTime)
-		if DraftDefaultInMvTime != 0 {
-			err := db.GetAutoDraftDefaultInMvTask()
-			if err != nil {
-				logrus.Error("[GetAutoDraftDefaultInMvTask] in DB error %+v", err)
-				return
+		// 定时任务9.视频形式的初稿违约自动处理
+		task9 := func() {
+			DB := db.GetReadDB(context.Background())
+			var DraftDefaultInMvTime int32
+			DB.Select("draft_default_in_mv").Model(gorm_model.InfoAutoTask{}).Last(&DraftDefaultInMvTime)
+			if DraftDefaultInMvTime != 0 {
+				err := db.GetAutoDraftDefaultInMvTask()
+				if err != nil {
+					logrus.Error("[GetAutoDraftDefaultInMvTask] in DB error %+v", err)
+					return
+				}
 			}
+			log.Println("GetAutoDraftDefaultInMvTask is running ,Time :", time.Now())
 		}
-		log.Println("GetAutoDraftDefaultInMvTask is running ,Time :", time.Now())
-	}
 
-	// 定时任务10.视频形式的脚本违约自动处理
-	task10 := func() {
-		DB := db.GetReadDB(context.Background())
-		var scriptDefault int32
-		DB.Select("script_default").Model(gorm_model.InfoAutoTask{}).Last(&scriptDefault)
-		if scriptDefault != 0 {
-			err := db.GetAutoScriptDefaultTask()
-			if err != nil {
-				logrus.Error("[GetAutoScriptDefaultTask] in DB error %+v", err)
-				return
+		// 定时任务10.视频形式的脚本违约自动处理
+		task10 := func() {
+			DB := db.GetReadDB(context.Background())
+			var scriptDefault int32
+			DB.Select("script_default").Model(gorm_model.InfoAutoTask{}).Last(&scriptDefault)
+			if scriptDefault != 0 {
+				err := db.GetAutoScriptDefaultTask()
+				if err != nil {
+					logrus.Error("[GetAutoScriptDefaultTask] in DB error %+v", err)
+					return
+				}
 			}
+			log.Println("GetAutoScriptDefaultTask is running ,Time :", time.Now())
 		}
-		log.Println("GetAutoScriptDefaultTask is running ,Time :", time.Now())
-	}
 
-	// 定时任务11.链接违约自动处理
-	task11 := func() {
-		DB := db.GetReadDB(context.Background())
-		var LinkBreach int32
-		DB.Select("link_breach").Model(gorm_model.InfoAutoTask{}).Last(&LinkBreach)
-		if LinkBreach != 0 {
-			err := db.GetAutoLinkBreachTask()
-			if err != nil {
-				logrus.Error("[GetAutoLinkBreachTask] in DB error %+v", err)
-				return
+		// 定时任务11.链接违约自动处理
+		task11 := func() {
+			DB := db.GetReadDB(context.Background())
+			var LinkBreach int32
+			DB.Select("link_breach").Model(gorm_model.InfoAutoTask{}).Last(&LinkBreach)
+			if LinkBreach != 0 {
+				err := db.GetAutoLinkBreachTask()
+				if err != nil {
+					logrus.Error("[GetAutoLinkBreachTask] in DB error %+v", err)
+					return
+				}
 			}
+			log.Println("GetAutoLinkBreachTask is running ,Time :", time.Now())
 		}
-		log.Println("GetAutoLinkBreachTask is running ,Time :", time.Now())
-	}
 
-	// 定时任务12.数据违约自动处理
-	task12 := func() {
-		DB := db.GetReadDB(context.Background())
-		var LinkBreach int32
-		DB.Select("case_close_default").Model(gorm_model.InfoAutoTask{}).Last(&LinkBreach)
-		if LinkBreach != 0 {
-			err := db.GetAutoCaseCloseDefaultTask()
-			if err != nil {
-				logrus.Error("[GetAutoCaseCloseDefaultTask] in DB error %+v", err)
-				return
+		// 定时任务12.数据违约自动处理
+		task12 := func() {
+			DB := db.GetReadDB(context.Background())
+			var LinkBreach int32
+			DB.Select("case_close_default").Model(gorm_model.InfoAutoTask{}).Last(&LinkBreach)
+			if LinkBreach != 0 {
+				err := db.GetAutoCaseCloseDefaultTask()
+				if err != nil {
+					logrus.Error("[GetAutoCaseCloseDefaultTask] in DB error %+v", err)
+					return
+				}
 			}
+			log.Println("GetAutoCaseCloseDefaultTask is running ,Time :", time.Now())
+		}
+
+		// 定时任务13. 选品项目失效自动处理
+		task13 := func() {
+			// println("AWdawdawdawdawd")
+			DB := db.GetReadDB(context.Background())
+			autoTaskTime := gorm_model.InfoAutoTask{}
+			DB.Model(gorm_model.InfoAutoTask{}).Last(&autoTaskTime)
+			if autoTaskTime.SelectionInvalid != 0 {
+				err := db.GetAutoSelectionInvalidTask()
+				if err != nil {
+					logrus.Error("[GetAutoInvalidTask] in DB error %+v", err)
+					return
+				}
+			}
+			log.Println("GetAutoSelectionInvalidTask is running ,Time :", time.Now())
 		}
-		log.Println("GetAutoCaseCloseDefaultTask is running ,Time :", time.Now())
-	}
 
-	//定时任务13. 选品项目失效自动处理
-	task13 := func() {
-		// println("AWdawdawdawdawd")
-		DB := db.GetReadDB(context.Background())
-		autoTaskTime := gorm_model.InfoAutoTask{}
-		DB.Model(gorm_model.InfoAutoTask{}).Last(&autoTaskTime)
-		if autoTaskTime.SelectionInvalid != 0 {
-			err := db.GetAutoSelectionInvalidTask()
-			if err != nil {
-				logrus.Error("[GetAutoInvalidTask] in DB error %+v", err)
-				return
+		//定时任务14. 拉取快手平台达人实际销量
+		task14 := func() {
+			ctx := context.Background()
+			//筛选出所有执行中的Selection
+			selectionIds, _ := db.FindSelectionIdBySelectionStatus(ctx, 6)
+			for i := range len(selectionIds) {
+				var SelectionId string = selectionIds[i]
+				println("开始拉取快手平台达人实际销量")
+				err1 := SelectionTask.UpdateActualNumBySelectionId(ctx, SelectionId)
+				fmt.Println(err1)
+				println("完成拉取快手平台达人实际销量")
 			}
 		}
-		log.Println("GetAutoSelectionInvalidTask is running ,Time :", time.Now())
-	}
 
-	////定时任务14. 拉取快手平台达人实际销量
-	//task14 := func() {
-	//	ctx := context.Background()
-	//	//筛选出所有执行中的Selection
-	//	selectionIds, _ := db.FindSelectionIdBySelectionStatus(ctx, 6)
-	//	for i := range len(selectionIds) {
-	//		var SelectionId string = selectionIds[i]
-	//		println("开始拉取快手平台达人实际销量")
-	//		err1 := SelectionTask.UpdateActualNumBySelectionId(ctx, SelectionId)
-	//		fmt.Println(err1)
-	//		println("完成拉取快手平台达人实际销量")
-	//	}
-	//}
+	*/
 
 	//定时任务15 定时刷新AccessToken
 	task15 := func() {
 		println("开始自动刷新AccessToken")
+
 		//var refreshkey string = "ChJvYXV0aC5yZWZyZXNoVG9rZW4SsAGQCXElJ20T3HTrDjxxZV9rrR7R2YzBymWjhdwmxs7mtu4GWiT2cy6JIAq0CWpa7P235JMrzfkWGn0qkTENul1TDd2n-cKQsJkuzUTD19ju1X1MuTLGcAqAPLbdJNkta79MJAN6xbhLylkEgOp7xte4XxT1jhmUqKjB_nL5EkdujoJttqo4-uq_HrisXkoQVFX8BIHdyLrLayqcjTxHXSHQJTvQVCH1NE-kTyOqaPgtVBoS15q2jT8K34-pnrlOMxuV8Ep1IiDVSApx1ijnxstgKmdo6vTNOXLkVwwn1YMBy4Z0fZrnPSgFMAE"
 		var AppKey string = "ks651333097154138217"
-		//var SignSecret string = "dBt0rVRhTpUqcrOYGGpv0A"
 		var SignSecret string = "dBt0rVRhTpUqcrOYGGpv0A"
 		//re, err := kuaishou.RefreshAccessToken(refreshkey, AppKey, SignSecret)
 		//fmt.Println("AccessToken: ", re.AccessToken)
@@ -277,50 +277,53 @@ func AutoTask() error {
 			re, err := kuaishou.RefreshAccessToken(refreshkey, AppKey, SignSecret)
 			fmt.Println(err)
 			newKuaishouUserInfo := gorm_model.PlatformKuaishouUserInfo{
-				TalentId:     talentList[i].TalentId,
+				//TalentId:     talentList[i].TalentId,
+				Id:           talentList[i].Id,
 				RefreshToken: re.RefreshToken,
 				AccessToken:  re.AccessToken,
 			}
-
-			err1 := db.UpdateKuaishouUserInfoByTalentID(ctx, newKuaishouUserInfo)
+			err1 := db.UpdateKuaishouUserInfoById(ctx, newKuaishouUserInfo)
 			fmt.Println(err1)
 		}
+
 		println("完成自动刷新AccessToken")
 	}
+	/*
 
-	// 定时任务16 自动结算
-	task16 := func() {
-		ctx := context.Background()
-		//筛选出所有执行中的Selection
-		selectionIds, _ := db.FindSelectionIdBySelectionStatus(ctx, 6)
-		for i := range len(selectionIds) {
-			var SelectionId string = selectionIds[i]
+		// 定时任务16 自动结算
+		task16 := func() {
+			ctx := context.Background()
+			//筛选出所有执行中的Selection
+			selectionIds, _ := db.FindSelectionIdBySelectionStatus(ctx, 6)
+			for i := range len(selectionIds) {
+				var SelectionId string = selectionIds[i]
 
-			println("开始自动结算")
-			var SecTaskStatus = 9
-			var PageSize = int64(0)
-			var PageNum = int64(0)
-			var SearchValue = ""
-			secTaskList, total, err2 := db.GetSecTaskList(ctx, SelectionId, SecTaskStatus, SearchValue, PageSize, PageNum)
-			fmt.Println(err2)
-			fmt.Println("待自动结算的子任务数量: ", total)
-			selection_curr, _ := db.GetSelectionById(ctx, SelectionId)
-			rewardStrategy, _ := db.GetRewardStrategyBySelectionId(ctx, SelectionId)
-			for j, _ := range secTaskList {
-				var secTaskId = secTaskList[j].SecTaskId
-				settleData := http_model.SettleSecTaskRequest{
-					SelectionID:   SelectionId,
-					TaskID:        secTaskId,
-					EnterpriseId:  selection_curr.EnterpriseID,
-					TotalPayMoney: strconv.FormatFloat(rewardStrategy[0].PerReward, 'f', -1, 64),
-					IsPayReward:   1,
+				println("开始自动结算")
+				var SecTaskStatus = 9
+				var PageSize = int64(0)
+				var PageNum = int64(0)
+				var SearchValue = ""
+				secTaskList, total, err2 := db.GetSecTaskList(ctx, SelectionId, SecTaskStatus, SearchValue, PageSize, PageNum)
+				fmt.Println(err2)
+				fmt.Println("待自动结算的子任务数量: ", total)
+				selection_curr, _ := db.GetSelectionById(ctx, SelectionId)
+				rewardStrategy, _ := db.GetRewardStrategyBySelectionId(ctx, SelectionId)
+				for j, _ := range secTaskList {
+					var secTaskId = secTaskList[j].SecTaskId
+					settleData := http_model.SettleSecTaskRequest{
+						SelectionID:   SelectionId,
+						TaskID:        secTaskId,
+						EnterpriseId:  selection_curr.EnterpriseID,
+						TotalPayMoney: strconv.FormatFloat(rewardStrategy[0].PerReward, 'f', -1, 64),
+						IsPayReward:   1,
+					}
+					_, err3 := SelectionTask.Settle(ctx, selection_curr.EnterpriseID, settleData)
+					fmt.Println("结算报错: ", err3)
 				}
-				_, err3 := SelectionTask.Settle(ctx, selection_curr.EnterpriseID, settleData)
-				fmt.Println("结算报错: ", err3)
+				println("完成自动结算")
 			}
-			println("完成自动结算")
 		}
-	}
+	*/
 
 	//定时任务
 	spec := "*/30 * * * * ?" //cron表达式，每30秒一次
@@ -328,76 +331,75 @@ func AutoTask() error {
 	//spec := "0 0 * * * *" //每小时执行
 	// "0 0 12 * * ?" 每天中午12点执行
 	// 添加定时任务,
-	_, err := crontab.AddFunc("0 0 * * * *", taskKDStatus) //每小时执行一次快递是否签收的查询
-	//_, err := crontab.AddFunc("0 */1 * * * ?", taskKDStatus) //每分钟执行一次快递是否签收的查询
+	//_, err := crontab.AddFunc("0 0 * * * *", taskKDStatus) //每小时执行一次快递是否签收的查询
+	_, err := crontab.AddFunc("0 */1 * * * ?", taskKDStatus) //每分钟执行一次快递是否签收的查询
 	if err != nil {
 		return err
 	}
-	_, err1 := crontab.AddFunc(spec, task1)
-	if err1 != nil {
-		return err1
-	}
-	_, err2 := crontab.AddFunc(spec, task2)
-	if err2 != nil {
-		return err2
-	}
-	_, err3 := crontab.AddFunc(spec, task3)
-	if err3 != nil {
-		return err3
-	}
-	_, err4 := crontab.AddFunc(spec, task4)
-	if err4 != nil {
-		return err4
-	}
-	_, err5 := crontab.AddFunc(spec, task5)
-	if err5 != nil {
-		return err5
-	}
-	_, err6 := crontab.AddFunc(spec, task6)
-	if err6 != nil {
-		return err6
-	}
-	_, err7 := crontab.AddFunc(spec, task7)
-	if err7 != nil {
-		return err7
-	}
-	_, err8 := crontab.AddFunc(spec, task8)
-	if err8 != nil {
-		return err8
-	}
-	_, err9 := crontab.AddFunc(spec, task9)
-	if err9 != nil {
-		return err9
-	}
-	_, err10 := crontab.AddFunc(spec, task10)
-	if err10 != nil {
-		return err10
-	}
-	_, err11 := crontab.AddFunc(spec, task11)
-	if err11 != nil {
-		return err11
-	}
-	_, err12 := crontab.AddFunc(spec, task12)
-	if err12 != nil {
-		return err12
-	}
-	_, err13 := crontab.AddFunc(spec, task13)
-	if err13 != nil {
-		return err13
-	}
+	//_, err1 := crontab.AddFunc(spec, task1)
+	//if err1 != nil {
+	//	return err1
+	//}
+	//_, err2 := crontab.AddFunc(spec, task2)
+	//if err2 != nil {
+	//	return err2
+	//}
+	//_, err3 := crontab.AddFunc(spec, task3)
+	//if err3 != nil {
+	//	return err3
+	//}
+	//_, err4 := crontab.AddFunc(spec, task4)
+	//if err4 != nil {
+	//	return err4
+	//}
+	//_, err5 := crontab.AddFunc(spec, task5)
+	//if err5 != nil {
+	//	return err5
+	//}
+	//_, err6 := crontab.AddFunc(spec, task6)
+	//if err6 != nil {
+	//	return err6
+	//}
+	//_, err7 := crontab.AddFunc(spec, task7)
+	//if err7 != nil {
+	//	return err7
+	//}
+	//_, err8 := crontab.AddFunc(spec, task8)
+	//if err8 != nil {
+	//	return err8
+	//}
+	//_, err9 := crontab.AddFunc(spec, task9)
+	//if err9 != nil {
+	//	return err9
+	//}
+	//_, err10 := crontab.AddFunc(spec, task10)
+	//if err10 != nil {
+	//	return err10
+	//}
+	//_, err11 := crontab.AddFunc(spec, task11)
+	//if err11 != nil {
+	//	return err11
+	//}
+	//_, err12 := crontab.AddFunc(spec, task12)
+	//if err12 != nil {
+	//	return err12
+	//}
+	//_, err13 := crontab.AddFunc(spec, task13)
+	//if err13 != nil {
+	//	return err13
+	//}
 	//_, err14 := crontab.AddFunc(spec, task14)
 	//if err14 != nil {
 	//	return err14
 	//}
-	_, err15 := crontab.AddFunc("0 0 12 * * ?", task15)
-	//_, err15 := crontab.AddFunc(spec, task15)
+	_, err15 := crontab.AddFunc(spec, task15)
 	if err15 != nil {
 		return err15
 	}
-	_, err16 := crontab.AddFunc(spec, task16)
-	if err16 != nil {
-		return err16
-	}
+	//_, err16 := crontab.AddFunc(spec, task16)
+	//if err16 != nil {
+	//	return err16
+	//}
 	// 启动定时器
 	crontab.Start()
 	// 定时任务是另起协程执行的,这里使用 select 简单阻塞.需要根据实际情况进行控制