门店归属订单不漏

business/model/dao/dao_order.go

@@ -918,3 +918,39 @@ func GetOrders(db *DaoDB, ids []int64, isIncludeSku, isIncludeFake bool, fromDat
 	}
 	return orders, totalCount, err
 }
+
+func UpdateOrdersWithoutJxStoreID(db *DaoDB, fromDate, toDate time.Time) (count int64, err error) {
+	sql := `
+		UPDATE goods_order t1
+		JOIN store_map a ON a.vendor_store_id = t1.vendor_store_id
+		SET t1.jx_store_id = a.store_id
+		WHERE t1.jx_store_id = 0 
+		AND t1.status != ?
+		AND t1.vendor_store_id != ?
+		AND a.status = ?
+	`
+	sqlParams := []interface{}{
+		model.OrderStatusCanceled,
+		2523687, //测试门店
+		model.StoreStatusOpened,
+	}
+	sql += " AND t1.order_created_at >= ?"
+	sql += " AND t1.order_created_at <= ?"
+	if !utils.IsTimeZero(fromDate) {
+		sqlParams = append(sqlParams, fromDate)
+		if !utils.IsTimeZero(toDate) {
+			sqlParams = append(sqlParams, toDate)
+		} else {
+			sqlParams = append(sqlParams, time.Now())
+		}
+	} else {
+		if !utils.IsTimeZero(toDate) {
+			sqlParams = append(sqlParams, toDate.AddDate(0, 0, -5))
+			sqlParams = append(sqlParams, toDate)
+		} else {
+			sqlParams = append(sqlParams, time.Now().AddDate(0, 0, -5))
+			sqlParams = append(sqlParams, time.Now())
+		}
+	}
+	return ExecuteSQL(db, sql, sqlParams)
+}