From 66ba2b5e829bc4f1fa431600fda0d887a1d34326 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Tue, 20 Oct 2020 15:10:45 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AF=BC=E5=85=A5=E7=BE=8E=E5=9B=A2=E7=BB=98?=
 =?UTF-8?q?=E5=9B=BE=E9=82=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 business/jxstore/cms/job.go   | 21 ++++++++++++++++++++-
 business/model/job.go         |  2 ++
 controllers/job_controller.go |  5 +++++
 3 files changed, 27 insertions(+), 1 deletion(-)

diff --git a/business/jxstore/cms/job.go b/business/jxstore/cms/job.go
index 53386deaf..2890fb85d 100644
--- a/business/jxstore/cms/job.go
+++ b/business/jxstore/cms/job.go
@@ -221,7 +221,7 @@ func AcceptJob(ctx *jxcontext.Context, jobID int) (err error) {
 		// Status:     model.JobOrderStatusAccept,
 	}
 	//美团会员任务
-	if jobID == 1 {
+	if jobID == model.JobIDMtMembers {
 		jobOrder.Status = model.JobOrderStatusSpec
 	} else {
 		jobOrder.Status = model.JobOrderStatusAccept
@@ -447,3 +447,22 @@ func RefreshJobStatus(ctx *jxcontext.Context) (err error) {
 	globals.SugarLogger.Debugf("RefreshJobStatus end...")
 	return err
 }
+
+func ImprotMtMembers(ctx *jxcontext.Context, mtMembers []*model.MtMember) (err error) {
+	var (
+		db = dao.GetDB()
+	)
+	for _, v := range mtMembers {
+		dao.WrapAddIDCULDEntity(v, ctx.GetUserName())
+	}
+	if err = dao.CreateMultiEntities(db, mtMembers); err == nil {
+		job := &model.Job{}
+		job.ID = model.JobIDMtMembers
+		dao.GetEntity(db, job)
+		if job != nil {
+			job.Count += len(mtMembers)
+			dao.UpdateEntity(db, job, "Count")
+		}
+	}
+	return err
+}
diff --git a/business/model/job.go b/business/model/job.go
index 95035b3c8..0dcc76d11 100644
--- a/business/model/job.go
+++ b/business/model/job.go
@@ -20,6 +20,8 @@ const (
 	JobOrderStatusAuditUnPass = 20
 	JobOrderStatusFinish      = 110
 	JobOrderStatusCancel      = 115
+
+	JobIDMtMembers = 1
 )
 
 type Job struct {
diff --git a/controllers/job_controller.go b/controllers/job_controller.go
index 787944a98..462dc5705 100644
--- a/controllers/job_controller.go
+++ b/controllers/job_controller.go
@@ -190,11 +190,16 @@ func (c *JobController) AuditJob() {
 // @Title 导入美团会员
 // @Description 导入美团会员
 // @Param	token			header		string	true	"认证token"
+// @Param	payload			formData	string	true	"mtmembers struct"
 // @Success 200 {object} controllers.CallResult
 // @Failure 200 {object} controllers.CallResult
 // @router /ImprotMtMembers [post]
 func (c *JobController) ImprotMtMembers() {
 	c.callImprotMtMembers(func(params *tJobImprotMtMembersParams) (retVal interface{}, errCode string, err error) {
+		var mtMembers []*model.MtMember
+		if err = jxutils.Strings2Objs(params.Payload, &mtMembers); err == nil {
+
+		}
 		return retVal, "", err
 	})
 }