同步商品前缀和图片修改

business/jxstore/cms/sync.go

@@ -1254,11 +1254,17 @@ func SyncSkuExperfixAndWatermark(ctx *jxcontext.Context) (err error) {
 	task := tasksch.NewParallelTask("SyncSkuExperfixAndWatermark", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
 		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
 			skuExinfo := batchItemList[0].(*model.SkuExinfoMap)
-			if time.Now().Sub(skuExinfo.EndAt) > 0 {
+			if utils.Time2Date(time.Now().Add(6*time.Hour)).Sub(skuExinfo.EndAt) > 0 {
 				skuExinfo.DeletedAt = time.Now()
 				dao.UpdateEntity(db, skuExinfo, "DeletedAt")
+				goto setModifiyFlag
 			}
-			skus, err := dao.GetSkus(db, nil, []int{skuExinfo.NameID}, nil, nil, nil)
+			if utils.Time2Date(time.Now().Add(6*time.Hour)).Sub(skuExinfo.BeginAt) == 0 {
+				goto setModifiyFlag
+			}
+		setModifiyFlag:
+			{
+				skus, _ := dao.GetSkus(db, nil, []int{skuExinfo.NameID}, nil, nil, nil)
 				var skuIDs []int
 				for _, v := range skus {
 					skuIDs = append(skuIDs, v.ID)
@@ -1272,6 +1278,7 @@ func SyncSkuExperfixAndWatermark(ctx *jxcontext.Context) (err error) {
 						SetStoreSkuSyncStatus2(db, nil, []int{skuExinfo.VendorID}, skuIDs, model.SyncFlagModifiedMask)
 					}
 				}
+			}
 			return retVal, err
 		}, skuExinfos)
 	tasksch.HandleTask(task, nil, true).Run()

business/jxstore/misc/misc.go

@@ -43,7 +43,7 @@ var (
 		"09:00:00",
 	}
 	dailyWorkTimeList = []string{
-		"20:00:00",
+		"20:30:00",
 	}
 	dailyWorkTimeList2 = []string{
 		"02:00:00",