新增同步商品库错误返回（测试）

business/jxstore/cms/sync.go

@@ -621,23 +621,7 @@ func (v *VendorSync) LoopStoresMap2(ctx *jxcontext.Context, parentTask tasksch.I
 	}
 	task = tasksch.NewParallelTask(taskName, tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, handler, loopInfoList)
 	if isAsync {
-		task.SetFinishHook(func(task tasksch.ITask) {
+		buildSetFinishHook(task, ctx)
-			var noticeMsg string
-			if ctx.GetUserName() != "jxadmin" {
-				if len(task.GetFailedList()) > 10 {
-					downloadURL, _, _ := WirteToExcelBySyncFailed(task)
-					noticeMsg = "您此次的同步任务错误详情返回如下：  "
-					noticeMsg += fmt.Sprintf("[详情点我]%s/billshow/?normal=true&path=%s  \n", globals.BackstageHost, downloadURL)
-				} else if len(task.GetFailedList()) > 0 && len(task.GetFailedList()) <= 10 {
-					if task.GetErr() != nil {
-						noticeMsg = utils.Format4Output(buildErrMsgJson(task), true)
-					}
-				}
-				if authInfo, err := ctx.GetV2AuthInfo(); err == nil {
-					ddmsg.SendUserMessage(dingdingapi.MsgTyeText, authInfo.UserID, "同步错误返回", noticeMsg)
-				}
-			}
-		})
 	}
 	tasksch.HandleTask(task, parentTask, isManageIt).Run()
 	if !isAsync {
@@ -658,6 +642,26 @@ func (v *VendorSync) LoopStoresMap2(ctx *jxcontext.Context, parentTask tasksch.I
 	return task, hint, err
 }
 
+func buildSetFinishHook(task tasksch.ITask, ctx *jxcontext.Context) {
+	task.SetFinishHook(func(task tasksch.ITask) {
+		var noticeMsg string
+		if ctx.GetUserName() != "jxadmin" {
+			if len(task.GetFailedList()) > 10 {
+				downloadURL, _, _ := WirteToExcelBySyncFailed(task)
+				noticeMsg = "您此次的同步任务错误详情返回如下：  "
+				noticeMsg += fmt.Sprintf("[详情点我]%s/billshow/?normal=true&path=%s  \n", globals.BackstageHost, downloadURL)
+			} else if len(task.GetFailedList()) > 0 && len(task.GetFailedList()) <= 10 {
+				if task.GetErr() != nil {
+					noticeMsg = utils.Format4Output(buildErrMsgJson(task), true)
+				}
+			}
+			if authInfo, err := ctx.GetV2AuthInfo(); err == nil {
+				ddmsg.SendUserMessage(dingdingapi.MsgTyeText, authInfo.UserID, "同步错误返回", noticeMsg)
+			}
+		}
+	})
+}
+
 func buildErrMsg(task tasksch.ITask) (err error) {
 	err = fmt.Errorf(utils.Format4Output(buildErrMsgJson(task), true))
 	return makeSpecSyncError(err)

business/jxstore/cms/sync2.go

@@ -137,6 +137,7 @@ func SyncSkus(ctx *jxcontext.Context, parentTask tasksch.ITask, vendorIDs []int,
 		task := tasksch.NewParallelTask(fmt.Sprintf("同步商品:%v,%v", nameIDs, skuIDs), tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
 			func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
 				skuVendorInfo := batchItemList[0].(*dao.StoreSkuSyncInfo)
+				var failedList []*partner.StoreSkuInfoWithErr
 				if skuVendorInfo.VendorCatID == "" {
 					return nil, fmt.Errorf("商品:%d的商家分类没有同步", skuVendorInfo.SkuID)
 				}
@@ -150,25 +151,43 @@ func SyncSkus(ctx *jxcontext.Context, parentTask tasksch.ITask, vendorIDs []int,
 						if !dao.IsVendorThingIDEmpty(skuVendorInfo.VendorSkuID) &&
 							model.IsSyncStatusNeedDelete(skuVendorInfo.SkuSyncStatus) {
 							err = multiStoresHandler.DeleteSku2(ctx, skuVendorInfo.VendorOrgCode, storeSkuSyncInfo2Bare(skuVendorInfo))
+							if err != nil {
+								failedList = putils.GetErrMsg2FailedSingleList(skuVendorInfo, err, 0, skuVendorInfo.VendorID, "删除商品")
+							}
 						}
 					} else if model.IsSyncStatusNew(skuVendorInfo.SkuSyncStatus) { // 新增
 						err = multiStoresHandler.CreateSku2(ctx, skuVendorInfo)
+						if err != nil {
+							failedList = putils.GetErrMsg2FailedSingleList(skuVendorInfo, err, 0, skuVendorInfo.VendorID, "新增商品")
+						}
 					} else if model.IsSyncStatusUpdate(skuVendorInfo.SkuSyncStatus) { // 修改
 						err = multiStoresHandler.UpdateSku2(ctx, skuVendorInfo)
+						if err != nil {
+							failedList = putils.GetErrMsg2FailedSingleList(skuVendorInfo, err, 0, skuVendorInfo.VendorID, "修改商品")
+						}
 					}
 				} else {
 					err = fmt.Errorf("平台:%d不合法", skuVendorInfo.VendorID)
 				}
+				if len(failedList) > 0 {
+					task.AddFailedList(failedList)
+				}
 				if err = OnThingSync(ctx, dao.GetDB(), SkuVendor2ThingMap(skuVendorInfo), err); err == nil {
 					retVal = []int{1}
 				}
 				return retVal, err
 			}, skuList)
+		if isAsync {
+			buildSetFinishHook(task, ctx)
+		}
 		tasksch.HandleTask(task, parentTask, len(skuList) == 0 || len(skuList) > 10).Run()
 		if isAsync {
 			hint = task.GetID()
 		} else {
 			resultList, err2 := task.GetResult(0)
+			if len(task.GetFailedList()) > 0 {
+				err2 = buildErrMsg(task)
+			}
 			if err = err2; err == nil {
 				hint = utils.Int2Str(len(resultList))
 			}