反算京西价bug，银豹平台，没玩刷新物料订单

business/partner/purchase/jx/localjx/order.go

@@ -1226,6 +1226,64 @@ func GetHalfHoursList() (strs []string) {
 	return strs
 }
 
+func RefreshAllMatterOrderStatus() (err error) {
+	var (
+		db        = dao.GetDB()
+		goodsList []*model.GoodsOrder
+		realTime  time.Time
+	)
+	realTime = time.Now().AddDate(0, 0, -3)
+	sql := `
+		SELECT * FROM goods_order WHERE store_id = 666666 AND order_created_at >= ? AND status <> ? AND vendor_id = ? AND eclp_out_id = '' AND LENGTH(vendor_order_id) = 14
+	`
+	sqlParams := []interface{}{realTime, model.OrderStatusFinished, model.VendorIDJX}
+	err = dao.GetRows(db, &goodsList, sql, sqlParams)
+	for _, v := range goodsList {
+		var (
+			goodsList2    []*model.GoodsOrder
+			finishedCount int
+		)
+		sql2 := "SELECT * FROM goods_order WHERE vendor_order_id LIKE ? OR vendor_order_id LIKE ? AND vendor_id = ? AND eclp_out_id <> '' AND LENGTH(vendor_order_id) = 16"
+		sqlParams2 := []interface{}{v.VendorOrderID + "0%", v.VendorOrderID + "1%", model.VendorIDJX}
+		err = dao.GetRows(db, &goodsList2, sql2, sqlParams2)
+		for _, vv := range goodsList2 {
+			if vv.Status != model.OrderStatusFinished {
+				queryOrderStatus, _ := api.JdEclpAPI.QueryOrderStatus(vv.EclpOutID)
+				if len(queryOrderStatus.OrderStatusList) > 0 {
+					if queryOrderStatus.OrderStatusList[len(queryOrderStatus.OrderStatusList)-1].SoStatusCode == jdeclpapi.SoStatusCode10034 {
+						dao.Begin(db)
+						defer func() {
+							if r := recover(); r != nil {
+								dao.Rollback(db)
+								panic(r)
+							}
+						}()
+						vv.Status = model.OrderStatusFinished
+						dao.UpdateEntity(db, vv, "Status")
+						finishedCount++
+						dao.Commit(db)
+					}
+				}
+			} else {
+				finishedCount++
+			}
+		}
+		if finishedCount == len(goodsList2) {
+			dao.Begin(db)
+			defer func() {
+				if r := recover(); r != nil {
+					dao.Rollback(db)
+					panic(r)
+				}
+			}()
+			v.Status = model.OrderStatusFinished
+			dao.UpdateEntity(db, v, "Status")
+			dao.Commit(db)
+		}
+	}
+	return err
+}
+
 func GetMatterOrderStatus(ctx *jxcontext.Context, vendorOrderID string) (result []*MatterOrderStatus, err error) {
 	var (
 		db = dao.GetDB()