344 lines
12 KiB
Go
344 lines
12 KiB
Go
package dao
|
||
|
||
import (
|
||
"fmt"
|
||
|
||
"git.rosy.net.cn/baseapi/utils"
|
||
"git.rosy.net.cn/jx-callback/business/model"
|
||
"git.rosy.net.cn/jx-callback/globals"
|
||
)
|
||
|
||
var (
|
||
imgFieldMap = map[int]string{
|
||
model.VendorIDWSC: "img_weimob",
|
||
model.VendorIDEBAI: "img_ebai",
|
||
}
|
||
descImgFieldMap = map[int]string{
|
||
model.VendorIDEBAI: "desc_img_ebai",
|
||
}
|
||
)
|
||
|
||
type SkuStoreCatInfo struct {
|
||
model.SkuCategory
|
||
MapID int `orm:"column(map_id)"` // 这个主要用于判断是否有store_sku_category_map
|
||
VendorCatID string `orm:"column(vendor_cat_id)"`
|
||
CatSyncStatus int8
|
||
|
||
ParentCatName string
|
||
ParentMapID int `orm:"column(parent_map_id)"` // 这个主要用于判断是否有父store_sku_category_map
|
||
ParentVendorCatID string `orm:"column(parent_vendor_cat_id)"`
|
||
ParentCatSyncStatus int8
|
||
}
|
||
|
||
type StoreCatSyncInfo struct {
|
||
CatName string
|
||
Seq int `json:"seq"`
|
||
model.StoreSkuCategoryMap
|
||
|
||
ParentCatName string
|
||
ParentCatID int `orm:"column(parent_cat_id)"` // 这个主要用于判断是否有父store_sku_category_map
|
||
ParentVendorCatID string `orm:"column(parent_vendor_cat_id)"`
|
||
ParentCatSyncStatus int8
|
||
}
|
||
|
||
type StoreSkuSyncInfo struct {
|
||
// 平台无关的store sku信息
|
||
BindID int `orm:"column(bind_id)"` // 换名的原因是与Sku.ID同名区别
|
||
StoreID int `orm:"column(store_id)"`
|
||
SkuID int `orm:"column(sku_id)"` // 这个与Sku.ID的区别是SkuID是必然存在的
|
||
Price int64
|
||
UnitPrice int64
|
||
|
||
// 平台相关的store sku信息
|
||
StoreSkuStatus int
|
||
StoreSkuSyncStatus int8
|
||
VendorSkuID string `orm:"column(vendor_sku_id)"`
|
||
|
||
model.Sku
|
||
|
||
// sku_name
|
||
Prefix string
|
||
NameID int `orm:"column(name_id)"`
|
||
VendorNameID string `orm:"column(vendor_name_id)"`
|
||
Name string
|
||
Unit string
|
||
Upc string
|
||
|
||
// 平台相关的图片信息
|
||
Img string
|
||
DescImg string
|
||
|
||
VendorVendorCatID int64 `orm:"column(vendor_vendor_cat_id)"` // 平台商品分类
|
||
|
||
// sku的商家分类信息
|
||
SkuCatSyncStatus int8
|
||
SkuVendorCatID string `orm:"column(sku_vendor_cat_id)"`
|
||
|
||
// sku_name的商家分类信息
|
||
CatSyncStatus int8
|
||
VendorCatID string `orm:"column(vendor_cat_id)"`
|
||
|
||
CatPricePercentage int
|
||
}
|
||
|
||
// 单门店模式厂商适用
|
||
func GetSkusCategories(db *DaoDB, vendorID, storeID int, skuIDs []int, level int) (cats []*SkuStoreCatInfo, err error) {
|
||
sql := `
|
||
SELECT DISTINCT t4.*, t5.id map_id, t5.%s_id vendor_cat_id, t5.%s_sync_status cat_sync_status, t4p.name parent_cat_name, t5p.id parent_map_id, t5p.%s_id parent_vendor_cat_id, t5p.%s_sync_status parent_cat_sync_status
|
||
FROM store_sku_bind t1
|
||
JOIN sku t2 ON t1.sku_id = t2.id AND t2.deleted_at = ? AND t2.status = ?
|
||
JOIN sku_name t3 ON t2.name_id = t3.id AND t3.deleted_at = ? AND t3.status = ?
|
||
`
|
||
if level == 2 {
|
||
sql += `
|
||
JOIN sku_category t4 ON (t3.category_id = t4.id OR t2.category_id = t4.id) AND t4.level = 2 AND t4.deleted_at = ?
|
||
`
|
||
} else {
|
||
sql += `
|
||
LEFT JOIN sku_category t4c ON (t3.category_id = t4c.id OR t2.category_id = t4c.id)
|
||
JOIN sku_category t4 ON (t4.id = t4c.parent_id OR (t3.category_id = t4.id OR t2.category_id = t4.id)) AND t4.level = 1 AND t4.deleted_at = ?
|
||
`
|
||
}
|
||
sql += `
|
||
LEFT JOIN store_sku_category_map t5 ON t4.id = t5.category_id AND t5.store_id = t1.store_id AND t5.deleted_at = ?
|
||
LEFT JOIN sku_category t4p ON t4.parent_id = t4p.id
|
||
LEFT JOIN store_sku_category_map t5p ON t4p.id = t5p.category_id AND t5p.store_id = t1.store_id AND t5p.deleted_at = ?
|
||
WHERE t1.deleted_at = ? AND t1.store_id = ?
|
||
`
|
||
sqlParams := []interface{}{
|
||
utils.DefaultTimeValue,
|
||
model.SkuStatusNormal,
|
||
utils.DefaultTimeValue,
|
||
model.SkuStatusNormal,
|
||
utils.DefaultTimeValue,
|
||
utils.DefaultTimeValue,
|
||
utils.DefaultTimeValue,
|
||
utils.DefaultTimeValue,
|
||
storeID,
|
||
}
|
||
if len(skuIDs) > 0 {
|
||
sql += " AND t1.sku_id IN (" + GenQuestionMarks(len(skuIDs)) + ")"
|
||
sqlParams = append(sqlParams, skuIDs)
|
||
}
|
||
fieldPrefix := ConvertDBFieldPrefix(model.VendorNames[vendorID])
|
||
sql = fmt.Sprintf(sql, fieldPrefix, fieldPrefix, fieldPrefix, fieldPrefix)
|
||
if err = GetRows(db, &cats, sql, sqlParams...); err != nil {
|
||
return nil, err
|
||
}
|
||
return cats, err
|
||
}
|
||
|
||
// 单门店模式厂商适用
|
||
func GetStoreCategories(db *DaoDB, vendorID, storeID int, level int) (cats []*StoreCatSyncInfo, err error) {
|
||
fieldPrefix := ConvertDBFieldPrefix(model.VendorNames[vendorID])
|
||
sql := fmt.Sprintf(`
|
||
SELECT t5.*,
|
||
t4.name cat_name, t4.seq,
|
||
t4p.name parent_cat_name,
|
||
t5p.category_id parent_cat_id, t5p.%s_id parent_vendor_cat_id, t5p.%s_sync_status parent_cat_sync_status
|
||
FROM store_sku_category_map t5
|
||
JOIN sku_category t4 ON t5.category_id = t4.id AND t4.deleted_at = ?
|
||
LEFT JOIN sku_category t4p ON t4.parent_id = t4p.id
|
||
LEFT JOIN store_sku_category_map t5p ON t4p.id = t5p.category_id AND t5.store_id = t5p.store_id AND t5p.deleted_at = ?
|
||
WHERE t5.store_id = ? AND t4.level = ? AND t5.%s_sync_status <> 0 AND t5.deleted_at = ?
|
||
`, fieldPrefix, fieldPrefix, fieldPrefix)
|
||
if err = GetRows(db, &cats, sql, utils.DefaultTimeValue, utils.DefaultTimeValue, storeID, level, utils.DefaultTimeValue); err != nil {
|
||
return nil, err
|
||
}
|
||
return cats, err
|
||
}
|
||
|
||
// 以store_sku_bind为基础来做同步，正常情况下使用
|
||
// 单多门店模式厂商通用
|
||
func GetStoreSkus(db *DaoDB, vendorID, storeID int, skuIDs []int) (skus []*StoreSkuSyncInfo, err error) {
|
||
isSingleStorePF := model.MultiStoresVendorMap[vendorID] != 1
|
||
tableName := "t1"
|
||
if !isSingleStorePF {
|
||
tableName = "t2"
|
||
}
|
||
vendorSkuNameField := "0"
|
||
if vendorID == model.VendorIDWSC {
|
||
vendorSkuNameField = "t1.wsc_id2"
|
||
}
|
||
fieldPrefix := ConvertDBFieldPrefix(model.VendorNames[vendorID])
|
||
sql := `
|
||
SELECT t1.id bind_id, t1.sku_id, t1.price, t1.unit_price, t1.status store_sku_status, %s.%s_id vendor_sku_id, t1.%s_sync_status store_sku_sync_status, %s vendor_name_id, t1.store_id,
|
||
t2.*,
|
||
t3.id name_id, t3.prefix, t3.name, t3.unit, IF(t3.%s <> '', t3.%s, t3.img) img, t3.upc, t3.%s desc_img,
|
||
t4.%s_category_id vendor_vendor_cat_id, t4.%s_price_percentage cat_price_percentage
|
||
`
|
||
fmtParams := []interface{}{
|
||
tableName, fieldPrefix, fieldPrefix, vendorSkuNameField, GetImgFieldName(vendorID), GetImgFieldName(vendorID), GetDescImgFieldName(vendorID),
|
||
fieldPrefix, fieldPrefix,
|
||
}
|
||
if isSingleStorePF {
|
||
sql += `,
|
||
t5.%s_sync_status cat_sync_status, t5.%s_id vendor_cat_id,
|
||
t5sku.%s_sync_status sku_cat_sync_status, t5sku.%s_id sku_vendor_cat_id`
|
||
fmtParams = append(fmtParams, fieldPrefix, fieldPrefix, fieldPrefix, fieldPrefix)
|
||
}
|
||
sql += `
|
||
FROM store_sku_bind t1
|
||
LEFT JOIN sku t2 ON t1.sku_id = t2.id AND t2.deleted_at = ? AND t2.status = ?
|
||
LEFT JOIN sku_name t3 ON t2.name_id = t3.id AND t3.deleted_at = ? AND t3.status = ?
|
||
LEFT JOIN sku_category t4 ON t3.category_id = t4.id AND t4.deleted_at = ?`
|
||
sqlParams := []interface{}{
|
||
utils.DefaultTimeValue,
|
||
model.SkuStatusNormal,
|
||
utils.DefaultTimeValue,
|
||
model.SkuStatusNormal,
|
||
utils.DefaultTimeValue,
|
||
}
|
||
if isSingleStorePF {
|
||
sql += `
|
||
LEFT JOIN store_sku_category_map t5 ON t4.id = t5.category_id AND t5.store_id = t1.store_id AND t5.deleted_at = ?
|
||
LEFT JOIN store_sku_category_map t5sku ON t2.category_id = t5sku.category_id AND t5sku.store_id = t1.store_id AND t5sku.deleted_at = ?`
|
||
sqlParams = append(sqlParams, utils.DefaultTimeValue, utils.DefaultTimeValue)
|
||
}
|
||
sql += " WHERE t1.store_id = ? AND (t1.%s_sync_status <> 0 OR (%s.%s_id <> 0 AND t3.id IS NULL))"
|
||
fmtParams = append(fmtParams, fieldPrefix, tableName, fieldPrefix)
|
||
sqlParams = append(sqlParams, storeID)
|
||
if len(skuIDs) > 0 {
|
||
sql += " AND t1.sku_id IN (" + GenQuestionMarks(len(skuIDs)) + ")"
|
||
sqlParams = append(sqlParams, skuIDs)
|
||
}
|
||
sql = fmt.Sprintf(sql, fmtParams...)
|
||
sql += " ORDER BY t1.price"
|
||
// globals.SugarLogger.Debug(sql)
|
||
if err = GetRows(db, &skus, sql, sqlParams...); err != nil {
|
||
return nil, err
|
||
}
|
||
return skus, err
|
||
}
|
||
|
||
// 以sku为基础来做全同步，
|
||
// 多门店模式厂商适用
|
||
func GetFullStoreSkus(db *DaoDB, vendorID, storeID int) (skus []*StoreSkuSyncInfo, err error) {
|
||
globals.SugarLogger.Debugf("GetFullStoreSkus, storeID:%d, vendorID:%d", storeID, vendorID)
|
||
|
||
sql := `
|
||
SELECT t1.id bind_id, t1.price, t1.unit_price, t1.status store_sku_status, t2.%s_id vendor_sku_id, t1.%s_sync_status store_sku_sync_status, t1.store_id,
|
||
t2.*, t2.id sku_id,
|
||
t3.id name_id, t3.prefix, t3.name, t3.unit, IF(t3.%s <> '', t3.%s, t3.img) img,
|
||
t4.%s_category_id vendor_vendor_cat_id,
|
||
t4.%s_sync_status cat_sync_status, t4.%s_id vendor_cat_id,
|
||
t5sku.%s_sync_status sku_cat_sync_status, t5sku.%s_id sku_vendor_cat_id
|
||
FROM sku t2
|
||
LEFT JOIN store_sku_bind t1 ON t1.sku_id = t2.id AND t1.store_id = ? AND t1.deleted_at = ?
|
||
JOIN sku_name t3 ON t2.name_id = t3.id AND t3.deleted_at = ? AND t3.status = ?
|
||
JOIN sku_category t4 ON t3.category_id = t4.id AND t4.deleted_at = ?
|
||
LEFT JOIN sku_category t5sku ON t2.category_id = t5sku.id
|
||
WHERE t2.deleted_at = ? AND t2.status = ?
|
||
`
|
||
sqlParams := []interface{}{
|
||
storeID,
|
||
utils.DefaultTimeValue,
|
||
utils.DefaultTimeValue,
|
||
model.SkuStatusNormal,
|
||
utils.DefaultTimeValue,
|
||
utils.DefaultTimeValue,
|
||
model.SkuStatusNormal,
|
||
}
|
||
fieldPrefix := ConvertDBFieldPrefix(model.VendorNames[vendorID])
|
||
sql = fmt.Sprintf(sql, fieldPrefix, fieldPrefix, GetImgFieldName(vendorID), GetImgFieldName(vendorID),
|
||
fieldPrefix, fieldPrefix, fieldPrefix, fieldPrefix, fieldPrefix)
|
||
// globals.SugarLogger.Debug(sql)
|
||
// globals.SugarLogger.Debug(utils.Format4Output(sqlParams, false))
|
||
if err = GetRows(db, &skus, sql, sqlParams...); err != nil {
|
||
return nil, err
|
||
}
|
||
return skus, err
|
||
}
|
||
|
||
func SetStoreSkuSyncStatus(db *DaoDB, vendorID int, storeIDs []int, skuIDs []int, syncStatus int) (num int64, err error) {
|
||
globals.SugarLogger.Debugf("SetStoreSkuSyncStatus, storeIDs:%v, vendorID:%d", storeIDs, vendorID)
|
||
|
||
isSingleStorePF := model.MultiStoresVendorMap[vendorID] != 1
|
||
fieldPrefix := ConvertDBFieldPrefix(model.VendorNames[vendorID])
|
||
sql := `
|
||
UPDATE store_sku_bind t1
|
||
SET t1.%s_sync_status = IF(t1.deleted_at = ?, t1.%s_sync_status | ?, 0)
|
||
`
|
||
fmtParams := []interface{}{
|
||
fieldPrefix,
|
||
fieldPrefix,
|
||
}
|
||
sqlParams := []interface{}{
|
||
utils.DefaultTimeValue,
|
||
syncStatus,
|
||
}
|
||
if isSingleStorePF && (syncStatus&model.SyncFlagNewMask) != 0 {
|
||
sql += `,
|
||
t1.%s_id = 0
|
||
`
|
||
fmtParams = append(fmtParams, fieldPrefix)
|
||
}
|
||
sql += " WHERE (t1.deleted_at = ? OR t1.%s_sync_status <> 0)"
|
||
fmtParams = append(fmtParams, fieldPrefix)
|
||
sqlParams = append(sqlParams, utils.DefaultTimeValue)
|
||
if len(storeIDs) > 0 {
|
||
sql += " AND t1.store_id IN (" + GenQuestionMarks(len(storeIDs)) + ")"
|
||
sqlParams = append(sqlParams, storeIDs)
|
||
}
|
||
if len(skuIDs) > 0 {
|
||
sql += " AND t1.sku_id IN (" + GenQuestionMarks(len(skuIDs)) + ")"
|
||
sqlParams = append(sqlParams, skuIDs)
|
||
}
|
||
sql = fmt.Sprintf(sql, fmtParams...)
|
||
return ExecuteSQL(db, sql, sqlParams...)
|
||
}
|
||
|
||
func SetStoreCategorySyncStatus(db *DaoDB, vendorID int, storeIDs []int, catIDs []int, syncStatus int) (num int64, err error) {
|
||
globals.SugarLogger.Debugf("SetStoreCategorySyncStatus, storeIDs:%v, vendorID:%d", storeIDs, vendorID)
|
||
|
||
isSingleStorePF := model.MultiStoresVendorMap[vendorID] != 1
|
||
fieldPrefix := ConvertDBFieldPrefix(model.VendorNames[vendorID])
|
||
sql := `
|
||
UPDATE store_sku_category_map t1
|
||
SET t1.%s_sync_status = IF(t1.deleted_at = ?, t1.%s_sync_status | ?, 0)
|
||
`
|
||
fmtParams := []interface{}{
|
||
fieldPrefix,
|
||
fieldPrefix,
|
||
}
|
||
sqlParams := []interface{}{
|
||
utils.DefaultTimeValue,
|
||
syncStatus,
|
||
}
|
||
if isSingleStorePF && (syncStatus&model.SyncFlagNewMask) != 0 {
|
||
sql += `,
|
||
t1.%s_id = 0
|
||
`
|
||
fmtParams = append(fmtParams, fieldPrefix)
|
||
}
|
||
sql += " WHERE (t1.deleted_at = ? OR t1.%s_sync_status <> 0)"
|
||
fmtParams = append(fmtParams, fieldPrefix)
|
||
sqlParams = append(sqlParams, utils.DefaultTimeValue)
|
||
if len(storeIDs) > 0 {
|
||
sql += " AND t1.store_id IN (" + GenQuestionMarks(len(storeIDs)) + ")"
|
||
sqlParams = append(sqlParams, storeIDs)
|
||
}
|
||
if len(catIDs) > 0 {
|
||
sql += " AND t1.category_id IN (" + GenQuestionMarks(len(catIDs)) + ")"
|
||
sqlParams = append(sqlParams, catIDs)
|
||
}
|
||
sql = fmt.Sprintf(sql, fmtParams...)
|
||
return ExecuteSQL(db, sql, sqlParams...)
|
||
}
|
||
|
||
func GetImgFieldName(vendorID int) (fieldName string) {
|
||
fieldName = imgFieldMap[vendorID]
|
||
if fieldName == "" {
|
||
fieldName = "img"
|
||
}
|
||
return fieldName
|
||
}
|
||
|
||
func GetDescImgFieldName(vendorID int) (fieldName string) {
|
||
fieldName = descImgFieldMap[vendorID]
|
||
if fieldName == "" {
|
||
fieldName = "desc_img"
|
||
}
|
||
return fieldName
|
||
}
|