| | |
| | | * clientId:客户ID |
| | | * |
| | | */ |
| | | public bool UpdateClientAmount(int AddBalance, int payAmount, string clientId ) |
| | | public bool UpdateClientAmount(Int64 AddBalance, Int64 payAmount, string clientId ) |
| | | { |
| | | return OracleHelper.ExecuteSql("UPDATE GW_CLIENT SET BALANCE=(BALANCE + :BALANCE), TOP_UP_AMOUNT_TOTAL=(TOP_UP_AMOUNT_TOTAL + :TOP_UP_AMOUNT_TOTAL) WHERE CLIENT_ID=:CLIENT_ID", OracleHelper.Connection, new OracleParameter(":BALANCE", (object)AddBalance), new OracleParameter(":TOP_UP_AMOUNT_TOTAL", (object)payAmount), new OracleParameter(":CLIENT_ID", (object)clientId)) > 0; |
| | | } |
| | |
| | | |
| | | //更新个性分配客户集长度大于0时 |
| | | string key2 = "UPDATE GW_PRODUCT SET CLIENT_IDS=:CLIENT_ID || ',' || CLIENT_IDS WHERE (CLIENT_IDS IS NOT NULL AND LENGTH(CLIENT_IDS) > 0) AND ID=:PRODUCT_ID "; |
| | | |
| | | list = new List<KeyValuePair<string, OracleParameter[]>>(); |
| | | foreach (string str in productIdArray) |
| | | { |
| | | OracleParameter[] oracleParameterArray2 = new OracleParameter[2] |
| | |
| | | new OracleParameter(":PRODUCT_ID", (object) str) |
| | | }; |
| | | |
| | | list = new List<KeyValuePair<string, OracleParameter[]>>(); |
| | | list.Add(new KeyValuePair<string, OracleParameter[]>(key2, oracleParameterArray2)); |
| | | } |
| | | OracleHelper.ExecuteSqlTran(list, OracleHelper.Connection); |
| | |
| | | |
| | | //更新个性分配客户集长度为0时 |
| | | string key3 = "UPDATE GW_PRODUCT SET CLIENT_IDS=:CLIENT_ID WHERE (CLIENT_IDS IS NULL OR LENGTH(CLIENT_IDS) <= 0) AND ID=:PRODUCT_ID "; |
| | | |
| | | list = new List<KeyValuePair<string, OracleParameter[]>>(); |
| | | foreach (string str in productIdArray) |
| | | { |
| | | OracleParameter[] oracleParameterArray2 = new OracleParameter[2] |
| | |
| | | new OracleParameter(":CLIENT_ID", (object) clientId), |
| | | new OracleParameter(":PRODUCT_ID", (object) str) |
| | | }; |
| | | |
| | | list = new List<KeyValuePair<string, OracleParameter[]>>(); |
| | | |
| | | list.Add(new KeyValuePair<string, OracleParameter[]>(key3, oracleParameterArray2)); |
| | | } |
| | | OracleHelper.ExecuteSqlTran(list, OracleHelper.Connection); |