NgRx：从商店获取数据但未定义

Question

亲爱的 Stackoverflow 社区。

我是 NgRx 的新手，并试图找出它是如何工作的。我创建了一个应用程序 - 基于 Angular 6、Firebase 和 NgRx 的简单商店列表。

我在名为的集合中添加了几个项目，Product并尝试通过 ngrx 模式获取它们。似乎我做得很好 - 我已经获取了项目作为有效载荷，GET_PRODUCTS_SUCCESS但我无法将它们放入视图中进行显示，产品未定义。我尝试通过两种方式进行：

this.store.select(getProducts).subscribe(products => {
  console.log('products', products); // undefined
});

和

 this.products = this.store.select(getProducts); // Store

在第二种方式中，我只是得到了一个完整的商店......下面的代码。

product.actions.ts

import { Action } from '@ngrx/store';
import { Product } from '../../models/product.model';

export const GET_PRODUCTS = 'Get_products';
export const GET_PRODUCTS_SUCCESS = 'Get_products_success';

export class GetProducts implements Action {
  readonly type = GET_PRODUCTS;
  constructor(public payload = '') {}
}

export class GetProductsSuccess implements Action {
  readonly type = GET_PRODUCTS_SUCCESS;
  constructor(public payload?: Product[]) {}
}

export type Actions = GetProducts | GetProductsSuccess;

product.reducer.ts

import { Product } from '../../models/product.model';
import * as productAction from './products.action';

export interface State {
  products: Product[];
  loading: boolean;
}

export const initialState: State = {
  products: [],
  loading: false,
};

export function ProductsReducer(state: State = initialState, action: productAction.Actions) {

  switch (action.type) {
    case productAction.GET_PRODUCTS:
      return {...state, loading: true};

    case productAction.GET_PRODUCTS_SUCCESS:
      const test = {...state, products: action.payload, loading: false};
      console.log("test", test);
      return test;

    default:
        return state;
  }
}

产品效果.ts

import { Injectable } from '@angular/core';
import { Action } from '@ngrx/store';
import { Effect, Actions } from '@ngrx/effects';
import { AngularFirestore } from '@angular/fire/firestore';

import { Product } from '../../models/product.model';
import * as productAction from './products.action';

import { Observable, of } from 'rxjs';
import { switchMap, map, mergeMap } from 'rxjs/operators';


@Injectable()
export class ProductEffects {

  constructor(private actions$: Actions, private db: AngularFirestore) {}

  @Effect()
  getProducts: Observable<Action> = this.actions$
    .ofType(productAction.GET_PRODUCTS).pipe(
      switchMap(() => {
        return this.db.collection<Product>('products').valueChanges()
        .pipe(
          map((payload) => {
            return {
              type: 'Get_products_success',
              payload: payload
            };
          })
        );
      })
    );
}

product.selector.ts

import { createSelector } from '@ngrx/store';

import { State } from './products.reducer';
import { Product } from '../../models/product.model';

export function getState(state: State): State {
    return state;
}

export function fetchProducts(state: State): Product[] {
    return state.products;
}

export const getProducts = createSelector(getState, fetchProducts);

list.component.ts - 获取并显示所有产品

import { Component, OnInit } from '@angular/core';
import { Store } from '@ngrx/store';
import { Product } from '../../models/product.model';
import * as productActions from '../../store/products/products.action';
import { State } from '../../store/products/products.reducer';
import { getProducts } from '../../store/products/products.selector';

import { Observable } from 'rxjs';

@Component({
  selector: 'app-list',
  templateUrl: './list.component.html',
  styleUrls: ['./list.component.scss']
})
export class ListComponent implements OnInit {

  products: Observable<Product[]>;

  constructor(private store: Store<State>) {}

  ngOnInit() {
    this.store.dispatch(new productActions.GetProducts);
    this.store.select(getProducts).subscribe(products => {
      console.log('products', products);
    });

  }

}

如果你发现我做错了什么 - 不要害羞告诉我。我真的需要你的帮助。谢谢。

Answer 1

我发现

我看着我还能如何从商店请求我的数据。我找到了一种方法，在我的应用程序上下文中，它看起来像：

 this.store.select(state => state).subscribe(data => {
  console.log('data', data);
});

我进入控制台对象：

{ message: { Products: Array[3], loading: false } }

这个消息是什么意思？我进行了全局搜索，发现我将减速器实现app.module.ts为：

StoreModule.forRoot({ message: ProductReducer }),

所以我index.ts在 reducers 文件夹中创建了一个reducer 并在下面导出了一个 reducer：

import { ActionReducerMap } from '@ngrx/store';

import * as fromProducts from './products.reducer';

export interface AppState {
    products: fromProducts.ProductState;
}

export const reducers: ActionReducerMap<AppState> = {
    products: fromProducts.productsReducer
};

现在在app.module.ts其中导入为：

    StoreModule.forRoot(reducers),

现在这段代码运行良好：

this.store.select(getProducts).subscribe(products => {
  console.log('products', products);
});