三元财务API

archivesNew.cs 33KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5. using System.Threading.Tasks;
  6. using System.Data.SqlClient;
  7. using System.Data;
  8. using CallCenterApi.DB;
  9. using System.Reflection;
  10. namespace CallCenterApi.DAL
  11. {
  12. public class archivesNew
  13. {
  14. /// <summary>
  15. /// 查询物资档案表信息
  16. /// </summary>
  17. /// <returns></returns>
  18. public DataSet GetList()
  19. {
  20. StringBuilder strSql = new StringBuilder();
  21. strSql.Append("select ");
  22. strSql.Append(" * ");
  23. strSql.Append(" FROM archivesnew ");
  24. var ds = DbHelperSQL.Query(strSql.ToString());
  25. return ds;
  26. }
  27. /// <summary>
  28. /// 是否存在该记录
  29. /// </summary>
  30. public bool IfHave(int id)
  31. {
  32. StringBuilder strSql = new StringBuilder();
  33. strSql.Append("select count(1) from archivestate");
  34. strSql.Append(" where id=@id");
  35. SqlParameter[] parameters = {
  36. new SqlParameter("@id", SqlDbType.Int,4)
  37. };
  38. parameters[0].Value = id;
  39. return DbHelperSQL.Exists(strSql.ToString(), parameters);
  40. }
  41. /// <summary>
  42. /// 增加一条档案物资数据
  43. /// </summary>
  44. /// <param name="model"></param>
  45. /// <returns></returns>
  46. public int Add(CallCenterApi.Model.archivesNew model)
  47. {
  48. StringBuilder strSql = new StringBuilder();
  49. strSql.Append("insert into archivesnew(");
  50. strSql.Append("A_archiveCode,A_archiveName,A_archiveState,A_archivePeople,A_CompanyName,fileid)");
  51. strSql.Append(" values (");
  52. strSql.Append("@A_archiveCode,@A_archiveName,@A_archiveState,@A_archivePeople,@A_CompanyName,@fileid)");
  53. strSql.Append(";select @@IDENTITY");
  54. SqlParameter[] parameters = {
  55. new SqlParameter("@A_archiveCode", SqlDbType.NVarChar,100),
  56. new SqlParameter("@A_archiveName", SqlDbType.NVarChar,100),
  57. new SqlParameter("@A_archiveState", SqlDbType.Int,4),
  58. new SqlParameter("@A_archivePeople", SqlDbType.NVarChar,50),
  59. new SqlParameter("@A_CompanyName", SqlDbType.NVarChar,100),
  60. new SqlParameter("@fileid", SqlDbType.Int,4)
  61. };
  62. parameters[0].Value = model.A_archiveCode;
  63. parameters[1].Value = model.A_archiveName;
  64. parameters[2].Value = model.A_archiveState;
  65. parameters[3].Value = model.A_archivePeople;
  66. parameters[4].Value = model.A_CompanyName;
  67. parameters[5].Value = model.fileid;
  68. object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
  69. if (obj == null)
  70. {
  71. return 0;
  72. }
  73. else
  74. {
  75. return Convert.ToInt32(obj);
  76. }
  77. }
  78. /// <summary>
  79. /// 得到一个档案物资对象实体
  80. /// </summary>
  81. public CallCenterApi.Model.archivesNew GetModel(int id)
  82. {
  83. StringBuilder strSql = new StringBuilder();
  84. //strSql.Append("select top 1 a.*,s.stateName as stateName,o.OperationContent,o.OperationDate from archives as a left join archivestate as s on a.A_archiveState = s.id left join Operationlog as o on a.id = o.archivesid ");
  85. strSql.Append(" SELECT * ,dbo.GetstateName(A_archiveState) AS stateName FROM archivesnew ");
  86. strSql.Append(" where id=@id");
  87. SqlParameter[] parameters = {
  88. new SqlParameter("@id", SqlDbType.BigInt)
  89. };
  90. parameters[0].Value = id;
  91. DataSet ds = DbHelperSQL.Query(strSql.ToString(), parameters);
  92. if (ds.Tables[0].Rows.Count > 0)
  93. {
  94. return DataRowToModelarchives(ds.Tables[0].Rows[0]);
  95. }
  96. else
  97. {
  98. return null;
  99. }
  100. }
  101. /// <summary>
  102. /// 得到一个档案物资对象实体
  103. /// </summary>
  104. public CallCenterApi.Model.archivesNew DataRowToModelarchives(DataRow row)
  105. {
  106. #region 之前的
  107. //CallCenterApi.Model.archives model = new CallCenterApi.Model.archives();
  108. //if (row != null)
  109. //{
  110. // if (row["id"] != null && row["id"].ToString() != "")
  111. // {
  112. // model.id = int.Parse(row["id"].ToString());
  113. // }
  114. // if (row["A_archiveCode"] != null)
  115. // {
  116. // model.A_archiveCode = row["A_archiveCode"].ToString();
  117. // }
  118. // if (row["A_archiveName"] != null && row["A_archiveName"].ToString() != "")
  119. // {
  120. // model.A_archiveName = row["A_archiveName"].ToString();
  121. // }
  122. // if (row["A_archiveState"] != null)
  123. // {
  124. // model.A_archiveState = int.Parse(row["A_archiveState"].ToString());
  125. // }
  126. // if (row["A_archivePeople"] != null)
  127. // {
  128. // model.A_archivePeople = row["A_archivePeople"].ToString();
  129. // }
  130. // if (row["stateName"] != null && row["stateName"].ToString() != "")
  131. // {
  132. // model.stateName = row["stateName"].ToString();
  133. // }
  134. //}
  135. //return model;
  136. #endregion
  137. Model.archivesNew model = new Model.archivesNew();//主表字段
  138. if (row != null)
  139. {
  140. #region 主表信息======================
  141. //利用反射获得属性的所有公共属性
  142. Type modelType = model.GetType();
  143. for (int i = 0; i < row.Table.Columns.Count; i++)
  144. {
  145. PropertyInfo proInfo = modelType.GetProperty(row.Table.Columns[i].ColumnName);
  146. if (proInfo != null && row[i] != DBNull.Value)
  147. {
  148. //用索引值设置属性值
  149. proInfo.SetValue(model, row[i], null);
  150. }
  151. }
  152. #endregion
  153. }
  154. return model;
  155. }
  156. /// <summary>
  157. /// 更新一条档案物资数据
  158. /// </summary>
  159. public bool Update(CallCenterApi.Model.archivesNew model)
  160. {
  161. StringBuilder strSql = new StringBuilder();
  162. strSql.Append("update archivesNew set ");
  163. strSql.Append("A_archiveCode=@A_archiveCode,");
  164. strSql.Append("A_archiveName=@A_archiveName,");
  165. strSql.Append("A_archiveState=@A_archiveState,");
  166. strSql.Append("A_archivePeople=@A_archivePeople");
  167. strSql.Append(" where id=@id");
  168. SqlParameter[] parameters = {
  169. new SqlParameter("@A_archiveCode", SqlDbType.NVarChar,100),
  170. new SqlParameter("@A_archiveName", SqlDbType.NVarChar,100),
  171. new SqlParameter("@A_archiveState", SqlDbType.Int,4),
  172. new SqlParameter("@A_archivePeople", SqlDbType.NVarChar,50),
  173. new SqlParameter("@id", SqlDbType.Int,4)};
  174. parameters[0].Value = model.A_archiveCode;
  175. parameters[1].Value = model.A_archiveName;
  176. parameters[2].Value = model.A_archiveState;
  177. // parameters[3].Value = model.A_archiveRecord;
  178. parameters[3].Value = model.A_archivePeople;
  179. parameters[4].Value = model.id;
  180. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  181. if (rows > 0)
  182. {
  183. return true;
  184. }
  185. else
  186. {
  187. return false;
  188. }
  189. }
  190. /// <summary>
  191. /// 根据id 修改档案物资的状态
  192. /// </summary>
  193. /// <returns></returns>
  194. public bool updateState(int id,int stateid)
  195. {
  196. StringBuilder strSql = new StringBuilder();
  197. strSql.Append("update archivesNew set ");
  198. strSql.Append("A_archiveState=@A_archiveState");
  199. strSql.Append(" where id=@id");
  200. SqlParameter[] parameters = {
  201. new SqlParameter("@A_archiveState", SqlDbType.Int,4),
  202. new SqlParameter("@id", SqlDbType.Int,4)};
  203. parameters[0].Value = stateid;
  204. parameters[1].Value = id;
  205. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  206. if (rows > 0)
  207. {
  208. return true;
  209. }
  210. else
  211. {
  212. return false;
  213. }
  214. }
  215. /// <summary>
  216. /// 删除一条档案物资数据
  217. /// </summary>
  218. public bool Delete(int id)
  219. {
  220. StringBuilder strSql = new StringBuilder();
  221. strSql.Append("delete from archives ");
  222. strSql.Append(" where id=@id");
  223. SqlParameter[] parameters = {
  224. new SqlParameter("@id", SqlDbType.Int,4)
  225. };
  226. parameters[0].Value = id;
  227. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  228. if (rows > 0)
  229. {
  230. return true;
  231. }
  232. else
  233. {
  234. return false;
  235. }
  236. }
  237. /// <summary>
  238. /// 获取物资状态信息 用作可选的下拉框选项
  239. /// </summary>
  240. /// <returns></returns>
  241. public DataSet GetArchivestate()
  242. {
  243. StringBuilder strSql = new StringBuilder();
  244. strSql.Append("select ");
  245. strSql.Append(" * ");
  246. strSql.Append(" FROM archivestate ");
  247. var ds = DbHelperSQL.Query(strSql.ToString());
  248. return ds;
  249. }
  250. /// <summary>
  251. /// 得到一个物资状态对象实体
  252. /// </summary>
  253. public CallCenterApi.Model.archivestate DataRowToModelarchives1(DataRow row)
  254. {
  255. CallCenterApi.Model.archivestate model = new CallCenterApi.Model.archivestate();
  256. if (row != null)
  257. {
  258. if (row["id"] != null && row["id"].ToString() != "")
  259. {
  260. model.id = int.Parse(row["id"].ToString());
  261. }
  262. if (row["stateName"] != null)
  263. {
  264. model.stateName = row["stateName"].ToString();
  265. }
  266. }
  267. return model;
  268. }
  269. /// <summary>
  270. /// 增加物资状态数据
  271. /// </summary>
  272. /// <param name="model"></param>
  273. /// <returns></returns>
  274. public int Addarchivestate(CallCenterApi.Model.archivestate model)
  275. {
  276. StringBuilder strSql = new StringBuilder();
  277. strSql.Append("insert into archivestate(");
  278. strSql.Append("stateName)");
  279. strSql.Append(" values (");
  280. strSql.Append("@stateName)");
  281. strSql.Append(";select @@IDENTITY");
  282. SqlParameter[] parameters = {
  283. new SqlParameter("@stateName", SqlDbType.NVarChar,20)};
  284. parameters[0].Value = model.stateName;
  285. object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
  286. if (obj == null)
  287. {
  288. return 0;
  289. }
  290. else
  291. {
  292. return Convert.ToInt32(obj);
  293. }
  294. }
  295. /// <summary>
  296. /// 删除一条物资状态信息
  297. /// </summary>
  298. /// <param name="id"></param>
  299. /// <returns></returns>
  300. public bool delarchivestate(int id)
  301. {
  302. StringBuilder strSql = new StringBuilder();
  303. strSql.Append("delete from archivestate ");
  304. strSql.Append(" where id=@id");
  305. SqlParameter[] parameters = {
  306. new SqlParameter("@id", SqlDbType.Int,4)
  307. };
  308. parameters[0].Value = id;
  309. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  310. if (rows > 0)
  311. {
  312. return true;
  313. }
  314. else
  315. {
  316. return false;
  317. }
  318. }
  319. /// <summary>
  320. /// 根据档案名称获取档案状态id
  321. /// </summary>
  322. /// <param name="statename"></param>
  323. /// <returns></returns>
  324. public int GetStateid(string stateName)
  325. {
  326. StringBuilder strSql = new StringBuilder();
  327. strSql.Append("select * from archivestate");
  328. strSql.Append(" where stateName=@stateName");
  329. SqlParameter[] parameters = {
  330. new SqlParameter("@stateName", SqlDbType.NVarChar ,20)
  331. };
  332. parameters[0].Value = stateName;
  333. var stateid = 0;
  334. var ds = DbHelperSQL.Query(strSql.ToString(),parameters);
  335. Model.archivestate ar = new Model.archivestate();
  336. if (ds.Tables[0].Rows.Count > 0)
  337. {
  338. ar= DataRowToModelarchives1(ds.Tables[0].Rows[0]);
  339. stateid = ar.id;
  340. }
  341. return stateid;
  342. }
  343. /// <summary>
  344. /// 获取外部客户操作表信息
  345. /// </summary>
  346. /// <returns></returns>
  347. public DataSet GetCustomerBorrow()
  348. {
  349. StringBuilder strSql = new StringBuilder();
  350. strSql.Append("select ");
  351. strSql.Append(" * ");
  352. strSql.Append(" FROM customerBorrow ");
  353. var ds = DbHelperSQL.Query(strSql.ToString());
  354. return ds;
  355. }
  356. /// <summary>
  357. /// 根据微信openid获取客户名称
  358. /// </summary>
  359. /// <param name="openid"></param>
  360. /// <returns></returns>
  361. public string GetCustomerName(string openid)
  362. {
  363. string name = "";
  364. StringBuilder strSql = new StringBuilder();
  365. strSql.Append("select * from T_Cus_CustomerBaseNew");
  366. strSql.Append(" where F_WxOpenId=@F_WxOpenId");
  367. SqlParameter[] parameters = {
  368. new SqlParameter("@F_WxOpenId", SqlDbType.NVarChar ,300)
  369. };
  370. parameters[0].Value = openid;
  371. var ds = DbHelperSQL.Query(strSql.ToString(), parameters);
  372. Model.T_Cus_CustomerBaseNew ar = new Model.T_Cus_CustomerBaseNew();
  373. if (ds.Tables[0].Rows.Count > 0)
  374. {
  375. ar = DataRowT_Cus_CustomerBaseNew(ds.Tables[0].Rows[0]);
  376. name = ar.F_CustomerCode;
  377. }
  378. return name;
  379. }
  380. /// <summary>
  381. /// 得到一个物资状态对象实体
  382. /// </summary>
  383. public CallCenterApi.Model.T_Cus_CustomerBaseNew DataRowT_Cus_CustomerBaseNew(DataRow row)
  384. {
  385. Model.T_Cus_CustomerBaseNew model = new Model.T_Cus_CustomerBaseNew();//主表字段
  386. if (row != null)
  387. {
  388. if (row["F_CustomerCode"] != null)
  389. {
  390. model.F_CustomerCode = row["F_CustomerCode"].ToString();
  391. }
  392. }
  393. return model;
  394. }
  395. /// <summary>
  396. /// 外部操作记录表
  397. /// </summary>
  398. /// <param name="model"></param>
  399. /// <returns></returns>
  400. public int AddexternalOperator(CallCenterApi.Model.externalOperator model)
  401. {
  402. StringBuilder strSql = new StringBuilder();
  403. strSql.Append("insert into externalOperator(");
  404. strSql.Append(" archivesid,Warehousing,WarehousingDate,Operator,remark,fieldId,companyName)");
  405. strSql.Append(" values (");
  406. strSql.Append("@archivesid,@Warehousing,@WarehousingDate,@Operator,@remark,@fieldId,@companyName)");
  407. strSql.Append(";select @@IDENTITY");
  408. SqlParameter[] parameters = {
  409. new SqlParameter("@archivesid", SqlDbType.NVarChar,-1),
  410. new SqlParameter("@Warehousing", SqlDbType.NVarChar,-1),
  411. new SqlParameter("@WarehousingDate", SqlDbType.DateTime),
  412. new SqlParameter("@Operator", SqlDbType.NVarChar,50),
  413. new SqlParameter("@remark", SqlDbType.NVarChar,-1),
  414. new SqlParameter("@fieldId", SqlDbType.NVarChar,500),
  415. new SqlParameter("@companyName", SqlDbType.NVarChar,500)};
  416. parameters[0].Value = model.archivesid;
  417. parameters[1].Value = model.Warehousing;
  418. parameters[2].Value = model.WarehousingDate;
  419. parameters[3].Value = model.Operator;
  420. parameters[4].Value = model.remark;
  421. parameters[5].Value = model.fieldId;
  422. parameters[6].Value = model.companyName;
  423. object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
  424. if (obj == null)
  425. {
  426. return 0;
  427. }
  428. else
  429. {
  430. return Convert.ToInt32(obj);
  431. }
  432. }
  433. public int AddinternalOperator(CallCenterApi.Model.internalOperator model)
  434. {
  435. StringBuilder strSql = new StringBuilder();
  436. strSql.Append("insert into internalOperator(");
  437. strSql.Append(" archivesid,Warehousing,WarehousingDate,Operator,remark,fieldId,companyName)");
  438. strSql.Append(" values (");
  439. strSql.Append("@archivesid,@Warehousing,@WarehousingDate,@Operator,@remark,@fieldId,@companyName)");
  440. strSql.Append(";select @@IDENTITY");
  441. SqlParameter[] parameters = {
  442. new SqlParameter("@archivesid", SqlDbType.NVarChar,-1),
  443. new SqlParameter("@Warehousing", SqlDbType.NVarChar,-1),
  444. new SqlParameter("@WarehousingDate", SqlDbType.DateTime),
  445. new SqlParameter("@Operator", SqlDbType.NVarChar,50),
  446. new SqlParameter("@remark", SqlDbType.NVarChar,-1),
  447. new SqlParameter("@fieldId", SqlDbType.NVarChar,500),
  448. new SqlParameter("@companyName", SqlDbType.NVarChar,500)};
  449. parameters[0].Value = model.archivesid;
  450. parameters[1].Value = model.Warehousing;
  451. parameters[2].Value = model.WarehousingDate;
  452. parameters[3].Value = model.Operator;
  453. parameters[4].Value = model.remark;
  454. parameters[5].Value = model.fieldId;
  455. parameters[6].Value = model.companyName;
  456. object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
  457. if (obj == null)
  458. {
  459. return 0;
  460. }
  461. else
  462. {
  463. return Convert.ToInt32(obj);
  464. }
  465. }
  466. /// <summary>
  467. /// 外部客户操作信息添加
  468. /// </summary>
  469. /// <returns></returns>
  470. public int AddCustomerBorrow(CallCenterApi.Model.customerBorrow model)
  471. {
  472. StringBuilder strSql = new StringBuilder();
  473. strSql.Append("insert into customerBorrow(");
  474. strSql.Append("archivesid,BorrowOreturn,BorrowDate,BorrowPeople)");
  475. strSql.Append(" values (");
  476. strSql.Append("@archivesid,@BorrowOreturn,@BorrowDate,@BorrowPeople)");
  477. strSql.Append(";select @@IDENTITY");
  478. SqlParameter[] parameters = {
  479. new SqlParameter("@archivesid", SqlDbType.Int ,4),
  480. new SqlParameter("@BorrowOreturn", SqlDbType.NVarChar,20),
  481. new SqlParameter("@BorrowDate", SqlDbType.DateTime),
  482. new SqlParameter("@BorrowPeople", SqlDbType.NVarChar,50) };
  483. parameters[0].Value = model.archivesid;
  484. parameters[1].Value = model.BorrowOreturn;
  485. parameters[2].Value = model.BorrowDate;
  486. parameters[3].Value = model.BorrowPeople;
  487. object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
  488. if (obj == null)
  489. {
  490. return 0;
  491. }
  492. else
  493. {
  494. return Convert.ToInt32(obj);
  495. }
  496. }
  497. /// <summary>
  498. /// 修改客户操作信息
  499. /// </summary>
  500. /// <returns></returns>
  501. public bool UpCustomerBorrow(CallCenterApi.Model.customerBorrow model)
  502. {
  503. StringBuilder strSql = new StringBuilder();
  504. strSql.Append("update customerBorrow set ");
  505. strSql.Append("archivesid=@archivesid,");
  506. strSql.Append("BorrowOreturn=@BorrowOreturn,");
  507. strSql.Append("BorrowDate=@BorrowDate,");
  508. strSql.Append("BorrowPeople=@BorrowPeople");
  509. strSql.Append(" where id=@id");
  510. SqlParameter[] parameters = {
  511. new SqlParameter("@archivesid", SqlDbType.Int ,4),
  512. new SqlParameter("@BorrowOreturn", SqlDbType.NVarChar,20),
  513. new SqlParameter("@BorrowDate", SqlDbType.DateTime),
  514. new SqlParameter("@BorrowPeople", SqlDbType.NVarChar,50),
  515. new SqlParameter("@id", SqlDbType.Int,4)};
  516. parameters[0].Value = model.archivesid;
  517. parameters[1].Value = model.BorrowOreturn;
  518. parameters[2].Value = model.BorrowDate;
  519. parameters[3].Value = model.BorrowPeople;
  520. parameters[4].Value = model.id;
  521. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  522. if (rows > 0)
  523. {
  524. return true;
  525. }
  526. else
  527. {
  528. return false;
  529. }
  530. }
  531. /// <summary>
  532. /// 获取客户操作表实体
  533. /// </summary>
  534. /// <param name="id"></param>
  535. /// <returns></returns>
  536. public CallCenterApi.Model.customerBorrow GetCustomerModel(int id)
  537. {
  538. StringBuilder strSql = new StringBuilder();
  539. strSql.Append("select top 1 id,archivesid,BorrowOreturn,BorrowDate,BorrowPeople from customerBorrow ");
  540. strSql.Append(" where id=@id");
  541. SqlParameter[] parameters = {
  542. new SqlParameter("@id", SqlDbType.Int,4)};
  543. parameters[0].Value = id;
  544. DataSet ds = DbHelperSQL.Query(strSql.ToString(), parameters);
  545. if (ds.Tables[0].Rows.Count > 0)
  546. {
  547. return DataRowToModelcustomerBorrow(ds.Tables[0].Rows[0]);
  548. }
  549. else
  550. {
  551. return null;
  552. }
  553. }
  554. /// <summary>
  555. /// 获取客户操作表实体
  556. /// </summary>
  557. /// <param name="id"></param>
  558. /// <returns></returns>
  559. public Model.customerBorrow DataRowToModelcustomerBorrow(DataRow row)
  560. {
  561. Model.customerBorrow model = new Model.customerBorrow();//主表字段
  562. if (row != null)
  563. {
  564. #region 主表信息======================
  565. //利用反射获得属性的所有公共属性
  566. Type modelType = model.GetType();
  567. for (int i = 0; i < row.Table.Columns.Count; i++)
  568. {
  569. PropertyInfo proInfo = modelType.GetProperty(row.Table.Columns[i].ColumnName);
  570. if (proInfo != null && row[i] != DBNull.Value)
  571. {
  572. //用索引值设置属性值
  573. proInfo.SetValue(model, row[i], null);
  574. }
  575. }
  576. #endregion
  577. }
  578. return model;
  579. }
  580. /// <summary>
  581. /// 删除一条客户操作信息
  582. /// </summary>
  583. /// <param name="id"></param>
  584. /// <returns></returns>
  585. public bool delCustomerBorrow(int id)
  586. {
  587. StringBuilder strSql = new StringBuilder();
  588. strSql.Append("delete from customerBorrow ");
  589. strSql.Append(" where id=@id");
  590. SqlParameter[] parameters = {
  591. new SqlParameter("@id", SqlDbType.Int,4)
  592. };
  593. parameters[0].Value = id;
  594. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  595. if (rows > 0)
  596. {
  597. return true;
  598. }
  599. else
  600. {
  601. return false;
  602. }
  603. }
  604. /// <summary>
  605. /// 获取内部操作表信息
  606. /// </summary>
  607. /// <returns></returns>
  608. public DataSet GetinsideOperation()
  609. {
  610. StringBuilder strSql = new StringBuilder();
  611. strSql.Append("select ");
  612. strSql.Append(" * ");
  613. strSql.Append(" FROM insideOperation ");
  614. var ds = DbHelperSQL.Query(strSql.ToString());
  615. return ds;
  616. }
  617. /// <summary>
  618. /// 内部员工操作信息添加
  619. /// </summary>
  620. /// <returns></returns>
  621. public int AddinsideOperation(CallCenterApi.Model.insideOperation model)
  622. {
  623. StringBuilder strSql = new StringBuilder();
  624. strSql.Append("insert into insideOperation(");
  625. strSql.Append("archivesid,Warehousing,WarehousingDate,Operator)");
  626. strSql.Append(" values (");
  627. strSql.Append("@archivesid,@Warehousing,@WarehousingDate,@Operator)");
  628. strSql.Append(";select @@IDENTITY");
  629. SqlParameter[] parameters = {
  630. new SqlParameter("@archivesid", SqlDbType.Int ,4),
  631. new SqlParameter("@Warehousing", SqlDbType.NVarChar,20),
  632. new SqlParameter("@WarehousingDate", SqlDbType.DateTime),
  633. new SqlParameter("@Operator", SqlDbType.NVarChar,50) };
  634. parameters[0].Value = model.archivesid;
  635. parameters[1].Value = model.Warehousing;
  636. parameters[2].Value = model.WarehousingDate;
  637. parameters[3].Value = model.Operator;
  638. object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
  639. if (obj == null)
  640. {
  641. return 0;
  642. }
  643. else
  644. {
  645. return Convert.ToInt32(obj);
  646. }
  647. }
  648. /// <summary>
  649. /// 修改内部员工操作信息
  650. /// </summary>
  651. /// <returns></returns>
  652. public bool UpinsideOperation(CallCenterApi.Model.insideOperation model)
  653. {
  654. StringBuilder strSql = new StringBuilder();
  655. strSql.Append("update insideOperation set ");
  656. strSql.Append("archivesid=@archivesid,");
  657. strSql.Append("Warehousing=@Warehousing,");
  658. strSql.Append("WarehousingDate=@WarehousingDate,");
  659. strSql.Append("Operator=@Operator,");
  660. strSql.Append(" where id=@id");
  661. SqlParameter[] parameters = {
  662. new SqlParameter("@archivesid", SqlDbType.Int ,4),
  663. new SqlParameter("@Warehousing", SqlDbType.NVarChar,20),
  664. new SqlParameter("@WarehousingDate", SqlDbType.DateTime),
  665. new SqlParameter("@Operator", SqlDbType.NVarChar,50),
  666. new SqlParameter("@id", SqlDbType.Int,4)};
  667. parameters[0].Value = model.archivesid;
  668. parameters[1].Value = model.Warehousing;
  669. parameters[2].Value = model.WarehousingDate;
  670. parameters[3].Value = model.Operator;
  671. parameters[4].Value = model.id;
  672. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  673. if (rows > 0)
  674. {
  675. return true;
  676. }
  677. else
  678. {
  679. return false;
  680. }
  681. }
  682. /// <summary>
  683. /// 获取内部员工操作表实体
  684. /// </summary>
  685. /// <param name="id"></param>
  686. /// <returns></returns>
  687. public CallCenterApi.Model.insideOperation GetinsideOperationModel(int id)
  688. {
  689. StringBuilder strSql = new StringBuilder();
  690. strSql.Append("select top 1 id,archivesid,Warehousing,WarehousingDate,Operator from insideOperation ");
  691. strSql.Append(" where id=@id");
  692. SqlParameter[] parameters = {
  693. new SqlParameter("@id", SqlDbType.Int,4)};
  694. parameters[0].Value = id;
  695. DataSet ds = DbHelperSQL.Query(strSql.ToString(), parameters);
  696. if (ds.Tables[0].Rows.Count > 0)
  697. {
  698. return DataRowToModelinsideOperation(ds.Tables[0].Rows[0]);
  699. }
  700. else
  701. {
  702. return null;
  703. }
  704. }
  705. /// <summary>
  706. /// 获取内部员工操作表实体
  707. /// </summary>
  708. /// <param name="id"></param>
  709. /// <returns></returns>
  710. public Model.insideOperation DataRowToModelinsideOperation(DataRow row)
  711. {
  712. Model.insideOperation model = new Model.insideOperation();//主表字段
  713. if (row != null)
  714. {
  715. #region 主表信息======================
  716. //利用反射获得属性的所有公共属性
  717. Type modelType = model.GetType();
  718. for (int i = 0; i < row.Table.Columns.Count; i++)
  719. {
  720. PropertyInfo proInfo = modelType.GetProperty(row.Table.Columns[i].ColumnName);
  721. if (proInfo != null && row[i] != DBNull.Value)
  722. {
  723. //用索引值设置属性值
  724. proInfo.SetValue(model, row[i], null);
  725. }
  726. }
  727. #endregion
  728. }
  729. return model;
  730. }
  731. /// <summary>
  732. /// 删除一条内部员工操作信息
  733. /// </summary>
  734. /// <param name="id"></param>
  735. /// <returns></returns>
  736. public bool delinsideOperation(int id)
  737. {
  738. StringBuilder strSql = new StringBuilder();
  739. strSql.Append("delete from insideOperation ");
  740. strSql.Append(" where id=@id");
  741. SqlParameter[] parameters = {
  742. new SqlParameter("@id", SqlDbType.Int,4)
  743. };
  744. parameters[0].Value = id;
  745. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  746. if (rows > 0)
  747. {
  748. return true;
  749. }
  750. else
  751. {
  752. return false;
  753. }
  754. }
  755. /// <summary>
  756. /// 获取操作日志表信息
  757. /// </summary>
  758. /// <returns></returns>
  759. public DataSet GetOperationlog()
  760. {
  761. StringBuilder strSql = new StringBuilder();
  762. strSql.Append("select ");
  763. strSql.Append(" * ");
  764. strSql.Append(" FROM Operationlog ");
  765. var ds = DbHelperSQL.Query(strSql.ToString());
  766. return ds;
  767. }
  768. /// <summary>
  769. /// 操作日志信息添加
  770. /// </summary>
  771. /// <returns></returns>
  772. public int AddOperationlog(CallCenterApi.Model.addupdatelog model)
  773. {
  774. StringBuilder strSql = new StringBuilder();
  775. strSql.Append("insert into addupdatelog(");
  776. strSql.Append("archivesid,Operator,OperationContent,OperationDate,type,companyName)");
  777. strSql.Append(" values (");
  778. strSql.Append("@archivesid,@Operator,@OperationContent,@OperationDate,@type,@companyName)");
  779. strSql.Append(";select @@IDENTITY");
  780. SqlParameter[] parameters = {
  781. new SqlParameter("@archivesid", SqlDbType.Int,50),
  782. new SqlParameter("@Operator", SqlDbType.NVarChar,50),
  783. new SqlParameter("@OperationContent", SqlDbType.NVarChar,100),
  784. new SqlParameter("@OperationDate", SqlDbType.DateTime),
  785. new SqlParameter("@type", SqlDbType.Int,50),
  786. new SqlParameter("@companyName", SqlDbType.NVarChar,500)
  787. };
  788. parameters[0].Value = model.archivesid;
  789. parameters[1].Value = model.Operator;//操作人
  790. parameters[2].Value = model.OperationContent;//操作内容
  791. parameters[3].Value = model.OperationDate;//操作时间
  792. parameters[4].Value = model.type;//操作时间
  793. parameters[5].Value = model.companyName ;//操作时间
  794. object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
  795. if (obj == null)
  796. {
  797. return 0;
  798. }
  799. else
  800. {
  801. return Convert.ToInt32(obj);
  802. }
  803. }
  804. /// <summary>
  805. /// 获取操作日志信息的实体
  806. /// </summary>
  807. /// <param name="row"></param>
  808. /// <returns></returns>
  809. public Model.Operationlog DataRowToModelOperationlog(DataRow row)
  810. {
  811. Model.Operationlog model = new Model.Operationlog();//主表字段
  812. if (row != null)
  813. {
  814. #region 主表信息======================
  815. //利用反射获得属性的所有公共属性
  816. Type modelType = model.GetType();
  817. for (int i = 0; i < row.Table.Columns.Count; i++)
  818. {
  819. PropertyInfo proInfo = modelType.GetProperty(row.Table.Columns[i].ColumnName);
  820. if (proInfo != null && row[i] != DBNull.Value)
  821. {
  822. //用索引值设置属性值
  823. proInfo.SetValue(model, row[i], null);
  824. }
  825. }
  826. #endregion
  827. }
  828. return model;
  829. }
  830. }
  831. }