public class GoodsStorgeProvider : IStorageProvider{public Logger Log{get; set;}public string Name{get; set;}public Task ClearStateAsync(string grainType, GrainReference grainReference, IGrainState grainState){return TaskDone.Done;}public Task Close(){return TaskDone.Done;}public Task Init(string name, IProviderRuntime providerRuntime, IProviderConfiguration config){this.Name = nameof(GoodsStorgeProvider);this.Log = providerRuntime.GetLogger(this.Name);return TaskDone.Done;}public async Task ReadStateAsync(string grainType, GrainReference grainReference, IGrainState grainState){Console.WriteLine("获取商品信息");var goodsNo = grainReference.GetPrimaryKeyString();using (var context = EntityContext.Factory()){grainState.State = context.GoodsInfo.AsNoTracking().FirstOrDefault(o => o.GoodsNo.Equals(goodsNo));}await TaskDone.Done;}public async Task WriteStateAsync(string grainType, GrainReference grainReference, IGrainState grainState){var model = grainState.State as GoodsInfo;using (var context = EntityContext.Factory()){var entity = context.GoodsInfo.FirstOrDefault(o => o.GoodsNo.Equals(model.GoodsNo));entity.Stock = model.Stock;await context.SaveChangesAsync();}}}

    [StorageProvider(ProviderName = "GoodsStorgeProvider")]public class GoodsInfoGrain : Grain<GoodsInfo>, IGoodsInfoGrain{public Task<List<GoodsInfo>> GetAllGoods(){using (var context = EntityContext.Factory()){return Task.FromResult(context.GoodsInfo.AsNoTracking().ToList());}}public async Task<bool> BuyGoods(int count, string buyerUser){Console.WriteLine(buyerUser + ":购买商品--" + this.State.GoodsName + "    " + count + "个");if (count>0 && this.State.Stock >= count){this.State.Stock -= count;OrdersInfo ordersInfo = new OrdersInfo();ordersInfo.OrderNo = Guid.NewGuid().ToString("n");ordersInfo.BuyCount = count;ordersInfo.BuyerNo = buyerUser;ordersInfo.GoodsNo = this.State.GoodsNo;ordersInfo.InTime = DateTime.Now;using (var context = EntityContext.Factory()){context.OrdersInfo.Add(ordersInfo);await context.SaveChangesAsync();}await this.WriteStateAsync();Console.WriteLine("购买完成");return await Task.FromResult(true);}else{Console.WriteLine("库存不足--剩余库存:" + this.State.Stock);return await Task.FromResult(false);}}}

　　　　　　　var grain = GrainClient.GrainFactory.GetGrain<IGoodsInfoGrain>(goods.GoodsNo);bool result = grain.BuyGoods(count, buyerUser).Result;if (result){Addmsg(buyerUser + "--购买商品" + goods.GoodsName + "    " + count + "个");}else{Addmsg(buyerUser + "--购买商品" + goods.GoodsName + "    库存不足");}