aa

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
+}