京东商城创建门店

business/jxstore/cms/store.go

@@ -1177,29 +1177,34 @@ func AddStoreVendorMap(ctx *jxcontext.Context, db *dao.DaoDB, vendorID int, vend
 	} else if vendorID == model.VendorIDJDShop {
 		storeMap.SyncStatus = model.SyncFlagNewMask //京东商城要去建店
 	}
-	if err == nil {
-		dao.WrapAddIDCULDEntity(storeMap, userName)
-		if db == nil {
-			db = dao.GetDB()
-		}
-		dao.Begin(db)
-		defer func() {
-			if r := recover(); r != nil {
+	storeMapList, err := dao.GetStoresMapList2(db, []int{vendorID}, []int{storeID}, nil, model.StoreStatusAll, model.StoreIsSyncAll, "", true)
+	if len(storeMapList) > 0 {
+		_, err = CurVendorSync.SyncStore(ctx, db, storeMap.VendorID, storeID, false, userName)
+	} else {
+		if err == nil {
+			dao.WrapAddIDCULDEntity(storeMap, userName)
+			if db == nil {
+				db = dao.GetDB()
+			}
+			dao.Begin(db)
+			defer func() {
+				if r := recover(); r != nil {
+					dao.Rollback(db)
+					panic(r)
+				}
+			}()
+			if err = dao.CreateEntity(db, storeMap); err == nil {
+				dao.Commit(db)
+				outStoreMap = storeMap
+				_, err = CurVendorSync.SyncStore(ctx, db, storeMap.VendorID, storeID, false, userName)
+			} else {
 				dao.Rollback(db)
-				panic(r)
 			}
-		}()
-		if err = dao.CreateEntity(db, storeMap); err == nil {
-			if globals.IsAddEvent {
-				err = AddEventDetail(db, ctx, model.OperateAdd, vendorID, model.ThingTypeStore, storeID, "", `{"VendorID":`+utils.Int2Str(vendorID)+`}`)
-			}
-			dao.Commit(db)
-			outStoreMap = storeMap
-			_, err = CurVendorSync.SyncStore(ctx, db, storeMap.VendorID, storeID, false, userName)
-		} else {
-			dao.Rollback(db)
 		}
 	}
+	if globals.IsAddEvent {
+		err = AddEventDetail(db, ctx, model.OperateAdd, vendorID, model.ThingTypeStore, storeID, "", `{"VendorID":`+utils.Int2Str(vendorID)+`}`)
+	}
 	return outStoreMap, err
 }