- 平台活动创建，初步OK

business/partner/purchase/mtwm/act.go

@@ -74,6 +74,7 @@ func createOneShopAct(act *model.Act2, vendorStoreID string, actStoreSku []*mode
 	if len(actData) > 0 {
 		if globals.EnableMtwmStoreWrite {
 			actResult, err2 := api.MtwmAPI.RetailDiscountBatchSave(vendorStoreID, actData)
+			globals.SugarLogger.Debugf("mtwm createOneShopAct err2:%v", err2)
 			if err = err2; err != nil {
 				return err
 			}
@@ -118,7 +119,7 @@ func createSkuAct(ctx *jxcontext.Context, parentTask tasksch.ITask, act *model.A
 	task := tasksch.NewParallelTask("mtwm createSkuAct", nil, ctx,
 		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
 			list := batchItemList[0].([]*model.ActStoreSku2)
-			if err = createOneShopAct(act, utils.Int2Str(list[0].StoreID), list); err == nil {
+			if err = createOneShopAct(act, list[0].VendorStoreID, list); err == nil {
 				retVal = []interface{}{list}
 			}
 			return retVal, err
@@ -188,9 +189,11 @@ func (c *PurchaseHandler) SyncAct(ctx *jxcontext.Context, parentTask tasksch.ITa
 					return err
 				}
 			}
-			updateItems = append(updateItems, partner.Act2Update(act, model.SyncFlagModifiedMask))
+			if err == nil {
+				updateItems = append(updateItems, partner.Act2Update(act, model.SyncFlagModifiedMask))
+			}
 		}
-		return nil
+		return err
 	}()
 	db := dao.GetDB()
 	_, err2 := dao.BatchUpdateEntityByKV(db, updateItems)