- sku man.

business/jxstore/cms/cms.go

@@ -1,78 +1,14 @@
 package cms
 
 import (
-	"errors"
-
-	"git.rosy.net.cn/baseapi/utils"
 	"git.rosy.net.cn/jx-callback/business/jxcallback/scheduler/basesch"
-	"git.rosy.net.cn/jx-callback/business/model"
-	"git.rosy.net.cn/jx-callback/business/model/dao"
 	"git.rosy.net.cn/jx-callback/business/partner"
 )
 
-type VendorSync struct {
-}
-
 var (
 	CurVendorSync VendorSync
 )
 
-var (
-	ErrHaveNotImplementedYet = errors.New("还没有实现")
-	ErrEntityNotExist        = errors.New("找不到相应实体")
-)
-
 func GetPurchaseHandler(vendorID int) partner.IPurchasePlatformHandler {
 	return basesch.FixedBaseScheduler.GetPurchasePlatformFromVendorID(vendorID)
 }
-
-func (v *VendorSync) SyncCategory(categoryID int, isForce bool, userName string) (err error) {
-	db := dao.GetDB()
-	cats := []*model.SkuCategory{}
-	cond := make(map[string]interface{})
-	if categoryID != 0 {
-		cond["ID"] = categoryID
-	}
-	err = dao.GetEntities(db, &cats, cond, true)
-	for _, cat := range cats {
-		if (cat.JdSyncStatus & model.SyncFlagNewMask) != 0 { // 新增
-			err = GetPurchaseHandler(model.VendorIDJD).CreateCategory(cat, userName)
-		} else if (cat.JdSyncStatus&model.SyncFlagModifiedMask) != 0 || isForce { // 修改
-			err = GetPurchaseHandler(model.VendorIDJD).UpdateCategory(cat, userName)
-		} else if (cat.JdSyncStatus & model.SyncFlagDeletedMask) != 0 {
-			err = GetPurchaseHandler(model.VendorIDJD).DeleteCategory(cat, userName)
-		}
-		if err == nil {
-			cat.JdSyncStatus = 0
-			_, err = dao.UpdateEntity(db, cat, model.FieldJdSyncStatus)
-		}
-		if err != nil {
-			break
-		}
-	}
-	return err
-}
-
-func (v *VendorSync) SyncStore(db *dao.DaoDB, vendorID int, store *model.Store, isForce bool, userName string) (err error) {
-	var (
-		storeMaps []*model.StoreMap
-	)
-	if db == nil {
-		db = dao.GetDB()
-	}
-	err = dao.GetEntities(db, &storeMaps, utils.Params2Map(model.FieldStoreID, store.ID), true)
-	if err == nil {
-		// globals.SugarLogger.Debug(utils.Format4Output(store, false))
-		copiedStore := *store
-		for _, storeMap := range storeMaps {
-			if (vendorID == -1 || storeMap.VendorID == vendorID) && (isForce || storeMap.SyncStatus != 0) {
-				copiedStore.Status = mergeStoreStatus(store.Status, storeMap.Status)
-				if err = GetPurchaseHandler(storeMap.VendorID).UpdateStore(storeMap.VendorStoreID, &copiedStore, userName); err == nil {
-					storeMap.SyncStatus = 0
-					dao.UpdateEntity(db, storeMap, model.FieldSyncStatus)
-				}
-			}
-		}
-	}
-	return err
-}

business/jxstore/cms/sku.go

@@ -55,7 +55,7 @@ func AddCategory(cat *model.SkuCategory, userName string) (outCat *model.SkuCate
 	cat.JdSyncStatus = model.SyncFlagNewMask
 	if err = dao.CreateEntity(nil, cat); err == nil {
 		outCat = cat
-		err = CurVendorSync.SyncCategory(cat.ID, false, userName)
+		err = CurVendorSync.SyncCategory(nil, cat.ID, false, userName)
 	}
 	return outCat, err
 }
@@ -64,10 +64,12 @@ func UpdateCategory(categoryID int, payload map[string]interface{}, userName str
 	cat := &model.SkuCategory{}
 	cat.ID = categoryID
 	valid := dao.NormalMakeMapByStructObject(payload, cat, userName)
-	valid[model.FieldJdSyncStatus] = model.SyncFlagModifiedMask
-	db := dao.GetDB()
-	if num, err = dao.UpdateEntityByKV(db, cat, valid, nil); err == nil {
-		err = CurVendorSync.SyncCategory(categoryID, false, userName)
+	if len(valid) > 0 {
+		valid[model.FieldJdSyncStatus] = model.SyncFlagModifiedMask
+		db := dao.GetDB()
+		if num, err = dao.UpdateEntityByKV(db, cat, valid, nil); err == nil {
+			err = CurVendorSync.SyncCategory(db, categoryID, false, userName)
+		}
 	}
 	return num, err
 }
@@ -107,7 +109,8 @@ func DeleteCategory(categoryID int, isForce bool, userName string) (num int64, e
 	cat := &model.SkuCategory{}
 	cat.ID = categoryID
 	var countInfos []*struct{ Ct int }
-	if err = dao.GetRows(nil, &countInfos, `
+	db := dao.GetDB()
+	if err = dao.GetRows(db, &countInfos, `
 	SELECT COUNT(*) ct
 	FROM sku t1
 	WHERE t1.category_id = ?
@@ -127,8 +130,8 @@ func DeleteCategory(categoryID int, isForce bool, userName string) (num int64, e
 		} else if countInfos[2].Ct != 0 {
 			return 0, errors.New("还有商品类别使用此类别，不能删除")
 		}
-		if num, err = dao.DeleteEntity(nil, cat, nil, userName, utils.Params2Map(model.FieldJdSyncStatus, model.SyncFlagDeletedMask)); err == nil && num == 1 {
-			err = CurVendorSync.SyncCategory(cat.ID, false, userName)
+		if num, err = dao.DeleteEntity(db, cat, nil, userName, utils.Params2Map(model.FieldJdSyncStatus, model.SyncFlagDeletedMask)); err == nil && num == 1 {
+			err = CurVendorSync.SyncCategory(db, cat.ID, false, userName)
 		}
 	}
 	return num, err
@@ -137,12 +140,12 @@ func DeleteCategory(categoryID int, isForce bool, userName string) (num int64, e
 func GetSkuNames(keyword string, params map[string]interface{}, offset, pageSize int) (skuNamesInfo *SkuNamesInfo, err error) {
 	sql := `
 	FROM sku_name t1
-	JOIN sku t2 ON t1.id = t2.name_id
-	WHERE`
+	LEFT JOIN sku t2 ON t1.id = t2.name_id AND t2.deleted_at = '1970-01-01 00:00:00'
+	WHERE t1.deleted_at = '1970-01-01 00:00:00'`
 	sqlParams := make([]interface{}, 0)
 	if keyword != "" {
 		keywordLike := "%" + keyword + "%"
-		sql += " (t1.name LIKE ? OR t1.prefix LIKE ? OR t1.comment LIKE ?"
+		sql += " AND (t1.name LIKE ? OR t1.prefix LIKE ? OR t1.comment LIKE ?"
 		sqlParams = append(sqlParams, keywordLike, keywordLike, keywordLike)
 
 		if keywordInt64, err2 := strconv.ParseInt(keyword, 10, 64); err2 == nil {
@@ -150,8 +153,6 @@ func GetSkuNames(keyword string, params map[string]interface{}, offset, pageSize
 			sqlParams = append(sqlParams, keywordInt64, keywordInt64, keywordInt64)
 		}
 		sql += ")"
-	} else {
-		sql += " 1 = 1"
 	}
 
 	if params["id"] != nil {
@@ -252,8 +253,10 @@ func GetSkuNames(keyword string, params map[string]interface{}, offset, pageSize
 		if err = dao.GetRow(db, countInfo, "SELECT FOUND_ROWS() ct"); err == nil {
 			skuNamesInfo.TotalCount = countInfo.Ct
 			for _, skuName := range skuNamesInfo.SkuNames {
-				if err = utils.UnmarshalUseNumber([]byte(skuName.SkusStr), &skuName.Skus); err != nil {
-					break
+				if skuName.SkusStr != "" {
+					if err = utils.UnmarshalUseNumber([]byte(skuName.SkusStr), &skuName.Skus); err != nil {
+						break
+					}
 				}
 			}
 		}
@@ -262,6 +265,9 @@ func GetSkuNames(keyword string, params map[string]interface{}, offset, pageSize
 }
 
 func AddSkuName(skuNameExt *SkuNameExt, userName string) (outSkuNameExt *SkuNameExt, err error) {
+	if skuNameExt.CategoryID == 0 {
+		return nil, errors.New("CategoryID不能为空")
+	}
 	db := dao.GetDB()
 	dao.Begin(db)
 	dao.WrapAddIDCULDEntity(&skuNameExt.SkuName, userName)
@@ -271,6 +277,8 @@ func AddSkuName(skuNameExt *SkuNameExt, userName string) (outSkuNameExt *SkuName
 	}
 	for _, sku := range skuNameExt.Skus {
 		dao.WrapAddIDCULDEntity(sku, userName)
+		sku.NameID = skuNameExt.ID
+		sku.JdSyncStatus = model.SyncFlagNewMask
 		if err = dao.CreateEntity(db, sku); err != nil {
 			dao.Rollback(db)
 			return nil, err
@@ -285,9 +293,25 @@ func AddSkuName(skuNameExt *SkuNameExt, userName string) (outSkuNameExt *SkuName
 		return nil, ErrEntityNotExist
 	}
 	outSkuNameExt = tmpInfo.SkuNames[0]
+	err = CurVendorSync.SyncSku(db, &outSkuNameExt.SkuName, -1, false, userName)
 	return outSkuNameExt, err
 }
 
-func UpdateSkuName(skuNameID int, payload map[string]interface{}) (num int64, err error) {
+func UpdateSkuName(nameID int, payload map[string]interface{}, userName string) (num int64, err error) {
+	skuName := &model.SkuName{}
+	skuName.ID = nameID
+	valid := dao.NormalMakeMapByStructObject(payload, skuName, userName)
+	if len(valid) > 0 {
+		db := dao.GetDB()
+		if num, err = dao.UpdateEntityByKV(db, skuName, valid, nil); err == nil && num == 1 {
+			sku := &model.Sku{}
+			_, err2 := dao.UpdateEntityByKV(db, sku, utils.Params2Map(model.FieldSyncStatus, model.SyncFlagModifiedMask), utils.Params2Map(model.FieldNameID, skuName.ID))
+			if err = err2; err == nil {
+				if err = dao.GetEntity(db, skuName); err == nil {
+					err = CurVendorSync.SyncSku(db, skuName, -1, false, userName)
+				}
+			}
+		}
+	}
 	return num, err
 }

business/jxstore/cms/store.go

@@ -8,7 +8,6 @@ import (
 	"git.rosy.net.cn/baseapi/utils"
 	"git.rosy.net.cn/jx-callback/business/model"
 	"git.rosy.net.cn/jx-callback/business/model/dao"
-	"git.rosy.net.cn/jx-callback/globals"
 )
 
 type StoreExt struct {
@@ -201,13 +200,15 @@ func UpdateStore(storeID int, payload map[string]interface{}, userName string) (
 	store := &model.Store{}
 	store.ID = storeID
 	valid := dao.NormalMakeMapByStructObject(payload, store, userName)
-	db := dao.GetDB()
-	if num, err = dao.UpdateEntityByKV(db, store, valid, nil); err == nil {
-		dummy := &model.StoreMap{}
-		_, err2 := dao.UpdateEntityByKV(db, dummy, utils.Params2Map(model.FieldSyncStatus, model.SyncFlagModifiedMask), utils.Params2Map(model.FieldStoreID, store.ID))
-		if err = err2; err == nil {
-			if err = dao.GetEntity(db, store); err == nil {
-				err = CurVendorSync.SyncStore(db, -1, store, false, userName)
+	if len(valid) > 0 {
+		db := dao.GetDB()
+		if num, err = dao.UpdateEntityByKV(db, store, valid, nil); err == nil && num == 1 {
+			dummy := &model.StoreMap{}
+			_, err2 := dao.UpdateEntityByKV(db, dummy, utils.Params2Map(model.FieldSyncStatus, model.SyncFlagModifiedMask), utils.Params2Map(model.FieldStoreID, store.ID))
+			if err = err2; err == nil {
+				if err = dao.GetEntity(db, store); err == nil {
+					err = CurVendorSync.SyncStore(db, -1, store, false, userName)
+				}
 			}
 		}
 	}
@@ -232,13 +233,15 @@ func GetStoreVendorMaps(db *dao.DaoDB, storeID int, vendorID int) (storeMaps []*
 	return storeMaps, dao.GetEntities(db, &storeMaps, cond, false)
 }
 
-func AddStoreVendorMap(db *dao.DaoDB, storeMap *model.StoreMap, userName string) (outStoreMap *model.StoreMap, err error) {
+func AddStoreVendorMap(db *dao.DaoDB, storeID, vendorID int, storeMap *model.StoreMap, userName string) (outStoreMap *model.StoreMap, err error) {
 	store, err := GetPurchaseHandler(storeMap.VendorID).ReadStore(storeMap.VendorStoreID)
 	if err == nil {
 		dao.WrapAddIDCULEntity(storeMap, userName)
+		storeMap.StoreID = storeID
+		storeMap.VendorID = vendorID
 		storeMap.DeliveryType = store.DeliveryType
 		storeMap.Status = store.Status
-		storeMap.SyncStatus = model.SyncFlagModifiedMask
+		storeMap.SyncStatus = model.SyncFlagModifiedMask // 新增绑定门店是修改的概念
 		if err = dao.CreateEntity(db, storeMap); err == nil {
 			outStoreMap = storeMap
 			err = CurVendorSync.SyncStore(db, storeMap.VendorID, store, true, userName)
@@ -265,16 +268,17 @@ func UpdateStoreVendorMap(db *dao.DaoDB, storeID, vendorID int, payload map[stri
 	if err == nil {
 		dummyStoreMap := &model.StoreMap{}
 		valid := dao.NormalMakeMapByStructObject(payload, dummyStoreMap, userName)
-		if valid["status"] != nil { // 对于store vendor map，只有Status改变才需要同步到厂商
-			valid[model.FieldSyncStatus] = model.SyncFlagModifiedMask
-		}
-		globals.SugarLogger.Debug(utils.Format4Output(valid, false))
-		if num, err = dao.UpdateEntityByKV(db, dummyStoreMap, valid, utils.Params2Map(model.FieldStoreID, storeID, model.FieldVendorID, vendorID)); err == nil {
-			if valid["status"] != nil {
-				store := &model.Store{}
-				store.ID = storeID
-				if err = dao.GetEntity(db, store); err == nil {
-					err = CurVendorSync.SyncStore(db, vendorID, store, true, userName)
+		if len(valid) > 0 {
+			if valid["status"] != nil { // 对于store vendor map，只有Status改变才需要同步到厂商
+				valid[model.FieldSyncStatus] = model.SyncFlagModifiedMask
+			}
+			if num, err = dao.UpdateEntityByKV(db, dummyStoreMap, valid, utils.Params2Map(model.FieldStoreID, storeID, model.FieldVendorID, vendorID)); err == nil {
+				if valid["status"] != nil {
+					store := &model.Store{}
+					store.ID = storeID
+					if err = dao.GetEntity(db, store); err == nil {
+						err = CurVendorSync.SyncStore(db, vendorID, store, false, userName)
+					}
 				}
 			}
 		}

business/jxstore/cms/sync.go

@@ -0,0 +1,92 @@
+package cms
+
+import (
+	"errors"
+
+	"git.rosy.net.cn/baseapi/utils"
+	"git.rosy.net.cn/jx-callback/business/model"
+	"git.rosy.net.cn/jx-callback/business/model/dao"
+)
+
+type VendorSync struct {
+}
+
+var (
+	ErrHaveNotImplementedYet = errors.New("还没有实现")
+	ErrEntityNotExist        = errors.New("找不到相应实体")
+)
+
+func (v *VendorSync) SyncCategory(db *dao.DaoDB, categoryID int, isForce bool, userName string) (err error) {
+	if db == nil {
+		db = dao.GetDB()
+	}
+	var cats []*model.SkuCategory
+	cond := make(map[string]interface{})
+	if categoryID > 0 {
+		cond[model.FieldID] = categoryID
+	}
+	if err = dao.GetEntities(db, &cats, cond, true); err == nil {
+		for _, cat := range cats {
+			if (cat.JdSyncStatus & model.SyncFlagDeletedMask) != 0 { //删除
+				err = GetPurchaseHandler(model.VendorIDJD).DeleteCategory(cat, userName)
+			} else if (cat.JdSyncStatus&model.SyncFlagNewMask) != 0 || isForce { // 新增
+				err = GetPurchaseHandler(model.VendorIDJD).CreateCategory(cat, userName)
+			} else if (cat.JdSyncStatus & model.SyncFlagModifiedMask) != 0 { // 修改
+				err = GetPurchaseHandler(model.VendorIDJD).UpdateCategory(cat, userName)
+			}
+			if err == nil {
+				cat.JdSyncStatus = 0
+				_, err = dao.UpdateEntity(db, cat, model.FieldJdSyncStatus)
+			}
+			if err != nil {
+				break
+			}
+		}
+	}
+	return err
+}
+
+func (v *VendorSync) SyncStore(db *dao.DaoDB, vendorID int, store *model.Store, isForce bool, userName string) (err error) {
+	if db == nil {
+		db = dao.GetDB()
+	}
+	var storeMapList []*model.StoreMap
+	if err = dao.GetEntities(db, &storeMapList, utils.Params2Map(model.FieldStoreID, store.ID), true); err == nil {
+		copiedStore := *store
+		for _, storeMap := range storeMapList {
+			if (vendorID == -1 || vendorID == storeMap.VendorID) && (isForce || storeMap.SyncStatus != 0) { // 对于门店，当前只有修改标记
+				copiedStore.Status = mergeStoreStatus(store.Status, storeMap.Status)
+				if err = GetPurchaseHandler(storeMap.VendorID).UpdateStore(storeMap.VendorStoreID, &copiedStore, userName); err == nil {
+					storeMap.SyncStatus = 0
+					dao.UpdateEntity(db, storeMap, model.FieldSyncStatus)
+				}
+			}
+		}
+	}
+	return err
+}
+
+func (v *VendorSync) SyncSku(db *dao.DaoDB, skuName *model.SkuName, skuID int, isForce bool, userName string) (err error) {
+	if db == nil {
+		db = dao.GetDB()
+	}
+	var skuList []*model.Sku
+	if err = dao.GetEntities(db, &skuList, utils.Params2Map(model.FieldNameID, skuName.ID), true); err == nil {
+		for _, sku := range skuList {
+			if (skuID == -1 || skuID == sku.ID) && (isForce || sku.JdSyncStatus != 0) {
+				if sku.JdSyncStatus&model.SyncFlagDeletedMask != 0 { // 删除
+					err = GetPurchaseHandler(model.VendorIDJD).CreateSku(sku, userName)
+				} else if sku.JdSyncStatus&model.SyncFlagNewMask != 0 { // 新增
+					err = GetPurchaseHandler(model.VendorIDJD).DeleteSku(sku, userName)
+				} else if sku.JdSyncStatus&model.SyncFlagModifiedMask != 0 { // 修改
+					err = GetPurchaseHandler(model.VendorIDJD).UpdateSku(sku, userName)
+				}
+				if err == nil {
+					sku.JdSyncStatus = 0
+					dao.UpdateEntity(db, sku, model.FieldSyncStatus)
+				}
+			}
+		}
+	}
+	return err
+}

business/jxstore/cms/validation.go

@@ -0,0 +1,35 @@
+package cms
+
+import (
+	"fmt"
+
+	"git.rosy.net.cn/jx-callback/business/jxutils"
+	"git.rosy.net.cn/jx-callback/business/model"
+)
+
+var (
+	unitNamesMap     map[string]int
+	specUnitNamesMap map[string]int
+)
+
+func init() {
+	unitNamesMap = jxutils.MakeValidationMapFromSlice(model.UnitNames, 1)
+	specUnitNamesMap = jxutils.MakeValidationMapFromSlice(model.SpecUnitNames, 1)
+}
+
+func validateStringInMap(name string, value interface{}, flagMap map[string]int) (err error) {
+	if strValue, ok := value.(string); ok {
+		if flagMap[strValue] == 1 {
+			return nil
+		}
+	}
+	return fmt.Errorf("属性%s类型或取值不合法，要求string", name)
+}
+
+func ValidateUnit(value interface{}) (err error) {
+	return validateStringInMap("Unit", value, unitNamesMap)
+}
+
+func ValidateSpecUnit(value interface{}) (err error) {
+	return validateStringInMap("SpecUnit", value, specUnitNamesMap)
+}