From e0bba3069615e1c33253db0e631e91b942785b4f Mon Sep 17 00:00:00 2001
From: suyl <770236076@qq.com>
Date: Thu, 3 Jun 2021 17:24:36 +0800
Subject: [PATCH] aa

---
 business/jxstore/cms/store.go         | 14 +++++++--
 business/model/dao/store.go           | 45 +++++++++++++++++++++++++++
 controllers/cms_store.go              |  7 +++++
 routers/commentsRouter_controllers.go |  9 ++++++
 4 files changed, 73 insertions(+), 2 deletions(-)

diff --git a/business/jxstore/cms/store.go b/business/jxstore/cms/store.go
index 49b3da14f..ad59d1278 100644
--- a/business/jxstore/cms/store.go
+++ b/business/jxstore/cms/store.go
@@ -4901,8 +4901,14 @@ func AuditStoreMap(ctx *jxcontext.Context, ID int, vendorOrgCode, vendorStoreID
 		if vendorStoreID == "" {
 			return fmt.Errorf("请输入绑定的平台门店ID！")
 		}
-		storeMap := &model.StoreMap{}
-		AddStoreVendorMap(ctx, db, storeMapAudit.VendorID, vendorOrgCode, storeMapAudit.StoreID, storeMap)
+		storeMap := &model.StoreMap{
+			VendorStoreID:       vendorStoreID,
+			IsSync:              0,
+			AutoPickup:          1,
+			DeliveryCompetition: 1,
+			PricePercentage:     100,
+		}
+		_, err = AddStoreVendorMap(ctx, db, storeMapAudit.VendorID, vendorOrgCode, storeMapAudit.StoreID, storeMap)
 	} else {
 		if comment == "" {
 			fmt.Errorf("审核不通过请输入原因！")
@@ -4914,3 +4920,7 @@ func AuditStoreMap(ctx *jxcontext.Context, ID int, vendorOrgCode, vendorStoreID
 	dao.UpdateEntity(db, storeMapAudit, "AuditStatus", "AuditAt", "AuditOperator")
 	return err
 }
+
+func GetStoreMapAudit(ctx *jxcontext.Context, storeIDs, vendorIDs, auditStatuss []int, fromTime, toTime string, offset, pageSize int) (page *model.PagedInfo, err error) {
+	return dao.GetStoreMapAudit(dao.GetDB(), storeIDs, vendorIDs, auditStatuss, utils.Str2Time(fromTime), utils.Str2Time(toTime), offset, pageSize)
+}
diff --git a/business/model/dao/store.go b/business/model/dao/store.go
index 16cdbff1f..637a4bbc0 100644
--- a/business/model/dao/store.go
+++ b/business/model/dao/store.go
@@ -1283,3 +1283,48 @@ func GetStoreManageStateSimple(db *DaoDB, storeIDs, brandIDs []int, vendorID int
 	err = GetRows(db, &pagedInfo, sql, sqlParams...)
 	return pagedInfo, err
 }
+
+func GetStoreMapAudit(db *DaoDB, storeIDs, vendorIDs, auditStatuss []int, fromTime, toTime time.Time, offset, pageSize int) (page *model.PagedInfo, err error) {
+	var (
+		storeMapAudits []*model.StoreMapAudit
+	)
+	sql := `
+		SELECT SQL_CALC_FOUND_ROWS *
+		  FROM store_map_audit
+         WHERE 1 = 1
+	`
+	sqlParams := []interface{}{}
+	if len(storeIDs) > 0 {
+		sql += " AND store_id IN (" + GenQuestionMarks(len(storeIDs)) + ")"
+		sqlParams = append(sqlParams, storeIDs)
+	}
+	if len(vendorIDs) > 0 {
+		sql += " AND vendor_id IN (" + GenQuestionMarks(len(vendorIDs)) + ")"
+		sqlParams = append(sqlParams, vendorIDs)
+	}
+	if len(auditStatuss) > 0 {
+		sql += " AND audit_status IN (" + GenQuestionMarks(len(auditStatuss)) + ")"
+		sqlParams = append(sqlParams, auditStatuss)
+	}
+	if fromTime != utils.ZeroTimeValue {
+		sql += " AND a.created_at > ?"
+		sqlParams = append(sqlParams, fromTime)
+	}
+	if toTime != utils.ZeroTimeValue {
+		sql += " AND a.created_at < ?"
+		sqlParams = append(sqlParams, toTime)
+	}
+	sql += " LIMIT ? OFFSET ?"
+	pageSize = jxutils.FormalizePageSize(pageSize)
+	offset = jxutils.FormalizePageOffset(offset)
+	sqlParams = append(sqlParams, pageSize, offset)
+	txDB, _ := Begin(db)
+	defer Commit(db, txDB)
+	if err = GetRowsTx(txDB, &storeMapAudits, sql, sqlParams...); err == nil {
+		page = &model.PagedInfo{
+			TotalCount: GetLastTotalRowCount2(db, txDB),
+			Data:       storeMapAudits,
+		}
+	}
+	return page, err
+}
diff --git a/controllers/cms_store.go b/controllers/cms_store.go
index 8f3f68af4..9b05cf9f3 100644
--- a/controllers/cms_store.go
+++ b/controllers/cms_store.go
@@ -1152,6 +1152,13 @@ func (c *StoreController) AuditStoreMap() {
 // @router /GetStoreMapAudit [get]
 func (c *StoreController) GetStoreMapAudit() {
 	c.callGetStoreMapAudit(func(params *tStoreGetStoreMapAuditParams) (retVal interface{}, errCode string, err error) {
+		var (
+			storeIDs     []int
+			vendorIDs    []int
+			auditStatuss []int
+		)
+		jxutils.Strings2Objs(params.StoreIDs, &storeIDs, params.VendorIDs, &vendorIDs, params.AuditStatuss, &auditStatuss)
+		retVal, err = cms.GetStoreMapAudit(params.Ctx, storeIDs, vendorIDs, auditStatuss, params.FromTime, params.ToTime, params.Offset, params.PageSize)
 		return retVal, "", err
 	})
 }
diff --git a/routers/commentsRouter_controllers.go b/routers/commentsRouter_controllers.go
index 2cbff3cb3..bdac6a73f 100644
--- a/routers/commentsRouter_controllers.go
+++ b/routers/commentsRouter_controllers.go
@@ -2115,6 +2115,15 @@ func init() {
 			Filters:          nil,
 			Params:           nil})
 
+	web.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:StoreController"] = append(web.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:StoreController"],
+		web.ControllerComments{
+			Method:           "GetStoreMapAudit",
+			Router:           `/GetStoreMapAudit`,
+			AllowHTTPMethods: []string{"get"},
+			MethodParams:     param.Make(),
+			Filters:          nil,
+			Params:           nil})
+
 	web.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:StoreController"] = append(web.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:StoreController"],
 		web.ControllerComments{
 			Method:           "AddStoreCategoryMap",