彩票走势图

最后就考虑下如何持久化业务对象的数据。在上面业务类的设计中，我们尽量的保持业务类的干净------只包含业务逻辑，关系和业务的数据。至于数据从何而来，最后如何保存，我们都委托给了一个Repository的接口IBankAccountRepository

public interface IBankAccountRepository
{
void Add(BankAccount bankAccount);
void Save(BankAccount bankAccount);
IEnumerable<BankAccount> FindAll();
BankAccount FindBy(Guid AccountId);
}

　　本系统是一个银行转账的系统，转账的操作不是一个业务对象就能够独立的完成的，往往需要多个业务类，以及数据持久化类的一些相互配合，这些操作放在任何一个业务类中都会把职责搞乱，而且后期的维护还得到处去找这个方法。所以我们在业务层中又剥离一层service，其中service中的每个方法其实和需求中的用例有个对象关系，例如在需求中就有转账的一个用例，那么在service中就有一个Transfer转账的方法，这个方法把很多的业务对象组合在一起完成这个转账的流程，也就是说，在每个业务类中的业务方法都是原子性的，细颗粒度的，可以被重用，而在业务层的service的方法就是粗颗粒度的，目的是为调用者提供简化的API。

public class BankAccountService
{
private IBankAccountRepository _bankAccountRepository;

public BankAccountService(IBankAccountRepository bankAccountRepository)
{
_bankAccountRepository = bankAccountRepository;
}

public&nbsp;void Transfer(Guid accountNoTo, 

Guid accountNoFrom, decimal amount)
{
BankAccount bankAccountTo = _

bankAccountRepository.FindBy(accountNoTo);
BankAccount bankAccountFrom = _

bankAccountRepository.FindBy(accountNoFrom);

if (bankAccountFrom.CanWithdraw(amount))
{
bankAccountTo.Deposit(amount, "From&nbsp;Acc " +

 bankAccountFrom.CustomerRef + " ");
bankAccountFrom.Withdraw(amount, "Transfer To&nbsp;Acc " ;+ 

bankAccountTo.CustomerRef + " ");

_bankAccountRepository.Save(bankAccountTo);
_bankAccountRepository.Save(bankAccountFrom);
}
else
{
throw new InsufficientFundsException();
}
}      
}

　　清楚了上面的之后，我们就把Repository那层实现，其实因为我们在业务层中使用的只是Repository的接口，至于采用哪种数据持久化方法可以替换的，例如如果用数据库来保存数据，我们可以选择用Linq To Sql，ADO.NET，EF等。业务层不用关心这些的。

　　在下面，就用了最原始的ADO.NET来实现的，大家可以任意替换实现策略：（下面的代码大家过过就行了，可以不用细看）

public class BankAccountRepository : IBankAccountRepository 
{
private string _connectionString;

public BankAccountRepository()
{
_connectionString = ConfigurationManager.ConnectionStrings["BankAccountConnectionString"].ConnectionString;
}

public void Add(BankAccount bankAccount)
{
string insertSql = "INSERT INTO BankAccounts " +
"(BankAccountID, Balance, CustomerRef) VALUES " +
"(@BankAccountID, @Balance, @CustomerRef)";

using (SqlConnection connection =
new SqlConnection(_connectionString))
{
SqlCommand command = connection.CreateCommand();
command.CommandText = insertSql;

SetCommandParametersForInsertUpdateTo(bankAccount, command);

connection.Open();

command.ExecuteNonQuery();
}

UpdateTransactionsFor(bankAccount);        
}

public void Save(BankAccount bankAccount)
{
string bankAccoutnUpdateSql = "UPDATE BankAccounts " +
"SET Balance = @Balance, CustomerRef= @CustomerRef " +
"WHERE BankAccountID = @BankAccountID;";

using (SqlConnection connection =
new SqlConnection(_connectionString))
{
SqlCommand command = connection.CreateCommand();
command.CommandText = bankAccoutnUpdateSql;

SetCommandParametersForInsertUpdateTo(bankAccount, command);

connection.Open();

command.ExecuteNonQuery();
}

UpdateTransactionsFor(bankAccount);       
}

private static void SetCommandParametersForInsertUpdateTo(BankAccount bankAccount, SqlCommand command)
{
command.Parameters.Add(new SqlParameter("@BankAccountID", bankAccount.AccountNo));                      
command.Parameters.Add(new SqlParameter

("@Balance", bankAccount.Balance));                                    
command.Parameters.Add(new SqlParameter("@CustomerRef", bankAccount.CustomerRef));                        
}

private void UpdateTransactionsFor(BankAccount bankAccount)
{
string deleteTransactionSQl = &quot;DELETE Transactions WHERE BankAccountId = 

@BankAccountId;";

using (SqlConnection connection =
new SqlConnection(_connectionString))
{
SqlCommand command = connection.CreateCommand();
command.CommandText = deleteTransactionSQl;
command.Parameters.Add(new SqlParameter

("@BankAccountID", bankAccount.AccountNo));                  
connection.Open();
command.ExecuteNonQuery();

}

string insertTransactionSql = "INSERT INTO Transactions " +
"(BankAccountID, Deposit, Withdraw, Reference, [Date]) VALUES " +
"(@BankAccountID, @Deposit,  @Withdraw,  @Reference, @Date)";

foreach (Transaction tran in bankAccount.GetTransactions())
{
using (SqlConnection connection =
new SqlConnection(_connectionString))
{
SqlCommand command = connection.CreateCommand();
command.CommandText = insertTransactionSql;

command.Parameters.Add(new SqlParameter("

@BankAccountID", bankAccount.AccountNo));
command.Parameters.Add(new SqlParameter("@Deposit", tran.Deposit));
command.Parameters.Add(new SqlParameter("@Withdraw", tran.Withdrawal));                    
command.Parameters.Add(new SqlParameter("@Reference", tran.Reference));
command.Parameters.Add(new SqlParameter("@Date", tran.Date));

connection.Open();
command.ExecuteNonQuery();
}
}
}

public IEnumerable<BankAccount> FindAll()
{
IList<BankAccount> accounts = new List<BankAccount>();

string queryString = "SELECT * FROM dbo.Transactions INNER JOIN " + 
&quot;dbo.BankAccounts ON dbo.Transactions.BankAccountId = 

dbo.BankAccounts.BankAccountId " +

"ORDER BY dbo.BankAccounts.BankAccountId;";

using (SqlConnection connection =
new SqlConnection(_connectionString))
{
SqlCommand command = connection.CreateCommand();
command.CommandText = queryString;

connection.Open();

using (SqlDataReader reader = command.ExecuteReader())
{
accounts = CreateListOfAccountsFrom(reader);
}                                                        
}

return accounts;
}

private IList<BankAccount> CreateListOfAccountsFrom(IDataReader datareader)
{
IList<BankAccount> accounts = new List<BankAccount>();
BankAccount bankAccount;
string id = "";
IList<Transaction> transactions = new List<Transaction>(); 

while (datareader.Read())
{
if (id != datareader["BankAccountId"].ToString())
{
id = datareader["BankAccountId"].ToString();
transactions = new List<Transaction>();
bankAccount =&nbsp;new BankAccount(new Guid(id), Decimal.Parse

(datareader["Balance"].ToString()), transactions,&nbsp;

datareader["CustomerRef"].ToString());                    
accounts.Add(bankAccount); 
}
transactions.Add(CreateTransactionFrom(datareader));
}

return accounts;
}

private Transaction CreateTransactionFrom(IDataRecord rawData)
{
return new Transaction(Decimal.Parse(rawData["Deposit"].ToString()),
Decimal.Parse(rawData["Withdraw"].ToString()),
rawData["Reference"].ToString(),
DateTime.Parse(rawData["Date"].ToString()));
}


public BankAccount FindBy(Guid AccountId)
{
BankAccount account;

string queryString = "SELECT * FROM dbo.Transactions INNER JOIN " +
"dbo.BankAccounts ON dbo.Transactions.BankAccountId =&nbsp;

dbo.BankAccounts.BankAccountId " +

"WHERE dbo.BankAccounts.BankAccountId = @BankAccountId;";

using (SqlConnection connection =
new SqlConnection(_connectionString))
{
SqlCommand command = connection.CreateCommand();
command.CommandText = queryString;

SqlParameter Idparam = new SqlParameter("

@BankAccountId", AccountId);              
command.Parameters.Add(Idparam);

connection.Open();

using (SqlDataReader reader = command.ExecuteReader())
{                                                            
account = CreateListOfAccountsFrom(reader)[0];                    
}
}
return account;
}        
}

　　到现在为止，数据访问，业务逻辑都已经完成了，最后的一步就是显示数据了。

　　我们知道：最后在界面显示的数据结构，很多的时候和我们业务对象的数据结构是不一致的，这个时候我们就要进行一定的转换，生成符合界面需要的数据结构，尽量少的让显示层出来过多的逻辑。此时就引入View Model来解决问题。

    &nbsp;&nbsp;   AppService就是一个门户：向显示层提供需要的数据。我们在AppService中就处理数据结构不一致的情况：添加两个View Model：

public class TransactionView
{
public string Deposit { get; set; }
public string Withdrawal { get; set; }
public string Reference { get; set; }
public DateTime Date { get; set; }
}

public class BankAccountView
{
public Guid AccountNo { get; set; }
public string Balance { get; set; }
public string CustomerRef { get; set; }
public IList<TransactionView> Transactions { get; set; } 
}

　　然后我们再添加一些辅助的方法来进行数据结构的转换，例如把Transaction转为TranactionViewModel