三元财务API

archives.cs 28KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751
  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 archives
  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 archives ");
  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.archives model)
  47. {
  48. StringBuilder strSql = new StringBuilder();
  49. strSql.Append("insert into archives(");
  50. strSql.Append("A_archiveCode,A_archiveName,A_archiveState,A_archivePeople,fileid)");
  51. strSql.Append(" values (");
  52. strSql.Append("@A_archiveCode,@A_archiveName,@A_archiveState,@A_archivePeople,@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("@fileid", SqlDbType.Int,4)};
  60. parameters[0].Value = model.A_archiveCode;
  61. parameters[1].Value = model.A_archiveName;
  62. parameters[2].Value = model.A_archiveState;
  63. //parameters[3].Value = model.A_archiveRecord;
  64. parameters[3].Value = model.A_archivePeople;
  65. parameters[4].Value = model.fileid;
  66. object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
  67. if (obj == null)
  68. {
  69. return 0;
  70. }
  71. else
  72. {
  73. return Convert.ToInt32(obj);
  74. }
  75. }
  76. /// <summary>
  77. /// 得到一个档案物资对象实体
  78. /// </summary>
  79. public CallCenterApi.Model.archives GetModel(int id)
  80. {
  81. StringBuilder strSql = new StringBuilder();
  82. //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 ");
  83. strSql.Append(" select* from (select * from((SELECT ROW_NUMBER() OVER(PARTITION BY archives.id ORDER BY Operationlog.OperationDate DESC) AS rid, archives.*, Operationlog.OperationContent, Operationlog.OperationDate, archivestate.stateName from archives left join Operationlog on Operationlog.archivesid = archives.id left join archivestate on archives.A_archiveState = archivestate.id )) t where rid = 1 ) a ");
  84. strSql.Append(" where id=@id");
  85. SqlParameter[] parameters = {
  86. new SqlParameter("@id", SqlDbType.BigInt)
  87. };
  88. parameters[0].Value = id;
  89. CallCenterApi.Model.T_Wo_WorkOrder model = new CallCenterApi.Model.T_Wo_WorkOrder();
  90. DataSet ds = DbHelperSQL.Query(strSql.ToString(), parameters);
  91. if (ds.Tables[0].Rows.Count > 0)
  92. {
  93. return DataRowToModelarchives(ds.Tables[0].Rows[0]);
  94. }
  95. else
  96. {
  97. return null;
  98. }
  99. }
  100. /// <summary>
  101. /// 得到一个档案物资对象实体
  102. /// </summary>
  103. public CallCenterApi.Model.archives DataRowToModelarchives(DataRow row)
  104. {
  105. #region 之前的
  106. //CallCenterApi.Model.archives model = new CallCenterApi.Model.archives();
  107. //if (row != null)
  108. //{
  109. // if (row["id"] != null && row["id"].ToString() != "")
  110. // {
  111. // model.id = int.Parse(row["id"].ToString());
  112. // }
  113. // if (row["A_archiveCode"] != null)
  114. // {
  115. // model.A_archiveCode = row["A_archiveCode"].ToString();
  116. // }
  117. // if (row["A_archiveName"] != null && row["A_archiveName"].ToString() != "")
  118. // {
  119. // model.A_archiveName = row["A_archiveName"].ToString();
  120. // }
  121. // if (row["A_archiveState"] != null)
  122. // {
  123. // model.A_archiveState = int.Parse(row["A_archiveState"].ToString());
  124. // }
  125. // if (row["A_archivePeople"] != null)
  126. // {
  127. // model.A_archivePeople = row["A_archivePeople"].ToString();
  128. // }
  129. // if (row["stateName"] != null && row["stateName"].ToString() != "")
  130. // {
  131. // model.stateName = row["stateName"].ToString();
  132. // }
  133. //}
  134. //return model;
  135. #endregion
  136. Model.archives model = new Model.archives();//主表字段
  137. if (row != null)
  138. {
  139. #region 主表信息======================
  140. //利用反射获得属性的所有公共属性
  141. Type modelType = model.GetType();
  142. for (int i = 0; i < row.Table.Columns.Count; i++)
  143. {
  144. PropertyInfo proInfo = modelType.GetProperty(row.Table.Columns[i].ColumnName);
  145. if (proInfo != null && row[i] != DBNull.Value)
  146. {
  147. //用索引值设置属性值
  148. proInfo.SetValue(model, row[i], null);
  149. }
  150. }
  151. #endregion
  152. }
  153. return model;
  154. }
  155. /// <summary>
  156. /// 更新一条档案物资数据
  157. /// </summary>
  158. public bool Update(CallCenterApi.Model.archives model)
  159. {
  160. StringBuilder strSql = new StringBuilder();
  161. strSql.Append("update archives set ");
  162. strSql.Append("A_archiveCode=@A_archiveCode,");
  163. strSql.Append("A_archiveName=@A_archiveName,");
  164. strSql.Append("A_archiveState=@A_archiveState,");
  165. strSql.Append("A_archivePeople=@A_archivePeople");
  166. strSql.Append(" where id=@id");
  167. SqlParameter[] parameters = {
  168. new SqlParameter("@A_archiveCode", SqlDbType.NVarChar,100),
  169. new SqlParameter("@A_archiveName", SqlDbType.NVarChar,100),
  170. new SqlParameter("@A_archiveState", SqlDbType.Int,4),
  171. new SqlParameter("@A_archivePeople", SqlDbType.NVarChar,50),
  172. new SqlParameter("@id", SqlDbType.Int,4)};
  173. parameters[0].Value = model.A_archiveCode;
  174. parameters[1].Value = model.A_archiveName;
  175. parameters[2].Value = model.A_archiveState;
  176. // parameters[3].Value = model.A_archiveRecord;
  177. parameters[3].Value = model.A_archivePeople;
  178. parameters[4].Value = model.id;
  179. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  180. if (rows > 0)
  181. {
  182. return true;
  183. }
  184. else
  185. {
  186. return false;
  187. }
  188. }
  189. /// <summary>
  190. /// 根据id 修改档案物资的状态
  191. /// </summary>
  192. /// <returns></returns>
  193. public bool updateState(int id,int stateid)
  194. {
  195. StringBuilder strSql = new StringBuilder();
  196. strSql.Append("update archives set ");
  197. strSql.Append("A_archiveState=@A_archiveState");
  198. strSql.Append(" where id=@id");
  199. SqlParameter[] parameters = {
  200. new SqlParameter("@A_archiveState", SqlDbType.Int,4),
  201. new SqlParameter("@id", SqlDbType.Int,4)};
  202. parameters[0].Value = stateid;
  203. parameters[1].Value = id;
  204. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  205. if (rows > 0)
  206. {
  207. return true;
  208. }
  209. else
  210. {
  211. return false;
  212. }
  213. }
  214. /// <summary>
  215. /// 删除一条档案物资数据
  216. /// </summary>
  217. public bool Delete(int id)
  218. {
  219. StringBuilder strSql = new StringBuilder();
  220. strSql.Append("delete from archives ");
  221. strSql.Append(" where id=@id");
  222. SqlParameter[] parameters = {
  223. new SqlParameter("@id", SqlDbType.Int,4)
  224. };
  225. parameters[0].Value = id;
  226. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  227. if (rows > 0)
  228. {
  229. return true;
  230. }
  231. else
  232. {
  233. return false;
  234. }
  235. }
  236. /// <summary>
  237. /// 获取物资状态信息 用作可选的下拉框选项
  238. /// </summary>
  239. /// <returns></returns>
  240. public DataSet GetArchivestate()
  241. {
  242. StringBuilder strSql = new StringBuilder();
  243. strSql.Append("select ");
  244. strSql.Append(" * ");
  245. strSql.Append(" FROM archivestate ");
  246. var ds = DbHelperSQL.Query(strSql.ToString());
  247. return ds;
  248. }
  249. /// <summary>
  250. /// 得到一个物资状态对象实体
  251. /// </summary>
  252. public CallCenterApi.Model.archivestate DataRowToModelarchives1(DataRow row)
  253. {
  254. CallCenterApi.Model.archivestate model = new CallCenterApi.Model.archivestate();
  255. if (row != null)
  256. {
  257. if (row["id"] != null && row["id"].ToString() != "")
  258. {
  259. model.id = int.Parse(row["id"].ToString());
  260. }
  261. if (row["stateName"] != null)
  262. {
  263. model.stateName = row["stateName"].ToString();
  264. }
  265. }
  266. return model;
  267. }
  268. /// <summary>
  269. /// 增加物资状态数据
  270. /// </summary>
  271. /// <param name="model"></param>
  272. /// <returns></returns>
  273. public int Addarchivestate(CallCenterApi.Model.archivestate model)
  274. {
  275. StringBuilder strSql = new StringBuilder();
  276. strSql.Append("insert into archivestate(");
  277. strSql.Append("stateName)");
  278. strSql.Append(" values (");
  279. strSql.Append("@stateName)");
  280. strSql.Append(";select @@IDENTITY");
  281. SqlParameter[] parameters = {
  282. new SqlParameter("@stateName", SqlDbType.NVarChar,20)};
  283. parameters[0].Value = model.stateName;
  284. object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
  285. if (obj == null)
  286. {
  287. return 0;
  288. }
  289. else
  290. {
  291. return Convert.ToInt32(obj);
  292. }
  293. }
  294. /// <summary>
  295. /// 删除一条物资状态信息
  296. /// </summary>
  297. /// <param name="id"></param>
  298. /// <returns></returns>
  299. public bool delarchivestate(int id)
  300. {
  301. StringBuilder strSql = new StringBuilder();
  302. strSql.Append("delete from archivestate ");
  303. strSql.Append(" where id=@id");
  304. SqlParameter[] parameters = {
  305. new SqlParameter("@id", SqlDbType.Int,4)
  306. };
  307. parameters[0].Value = id;
  308. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  309. if (rows > 0)
  310. {
  311. return true;
  312. }
  313. else
  314. {
  315. return false;
  316. }
  317. }
  318. /// <summary>
  319. /// 根据档案名称获取档案状态id
  320. /// </summary>
  321. /// <param name="statename"></param>
  322. /// <returns></returns>
  323. public int GetStateid(string stateName)
  324. {
  325. StringBuilder strSql = new StringBuilder();
  326. strSql.Append("select * from archivestate");
  327. strSql.Append(" where stateName=@stateName");
  328. SqlParameter[] parameters = {
  329. new SqlParameter("@stateName", SqlDbType.NVarChar ,20)
  330. };
  331. parameters[0].Value = stateName;
  332. var stateid = 0;
  333. var ds = DbHelperSQL.Query(strSql.ToString(),parameters);
  334. Model.archivestate ar = new Model.archivestate();
  335. if (ds.Tables[0].Rows.Count > 0)
  336. {
  337. ar= DataRowToModelarchives1(ds.Tables[0].Rows[0]);
  338. stateid = ar.id;
  339. }
  340. return stateid;
  341. }
  342. /// <summary>
  343. /// 获取外部客户操作表信息
  344. /// </summary>
  345. /// <returns></returns>
  346. public DataSet GetCustomerBorrow()
  347. {
  348. StringBuilder strSql = new StringBuilder();
  349. strSql.Append("select ");
  350. strSql.Append(" * ");
  351. strSql.Append(" FROM customerBorrow ");
  352. var ds = DbHelperSQL.Query(strSql.ToString());
  353. return ds;
  354. }
  355. /// <summary>
  356. /// 外部客户操作信息添加
  357. /// </summary>
  358. /// <returns></returns>
  359. public int AddCustomerBorrow(CallCenterApi.Model.customerBorrow model)
  360. {
  361. StringBuilder strSql = new StringBuilder();
  362. strSql.Append("insert into customerBorrow(");
  363. strSql.Append("archivesid,BorrowOreturn,BorrowDate,BorrowPeople)");
  364. strSql.Append(" values (");
  365. strSql.Append("@archivesid,@BorrowOreturn,@BorrowDate,@BorrowPeople)");
  366. strSql.Append(";select @@IDENTITY");
  367. SqlParameter[] parameters = {
  368. new SqlParameter("@archivesid", SqlDbType.Int ,4),
  369. new SqlParameter("@BorrowOreturn", SqlDbType.NVarChar,20),
  370. new SqlParameter("@BorrowDate", SqlDbType.DateTime),
  371. new SqlParameter("@BorrowPeople", SqlDbType.NVarChar,50) };
  372. parameters[0].Value = model.archivesid;
  373. parameters[1].Value = model.BorrowOreturn;
  374. parameters[2].Value = model.BorrowDate;
  375. parameters[3].Value = model.BorrowPeople;
  376. object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
  377. if (obj == null)
  378. {
  379. return 0;
  380. }
  381. else
  382. {
  383. return Convert.ToInt32(obj);
  384. }
  385. }
  386. /// <summary>
  387. /// 修改客户操作信息
  388. /// </summary>
  389. /// <returns></returns>
  390. public bool UpCustomerBorrow(CallCenterApi.Model.customerBorrow model)
  391. {
  392. StringBuilder strSql = new StringBuilder();
  393. strSql.Append("update customerBorrow set ");
  394. strSql.Append("archivesid=@archivesid,");
  395. strSql.Append("BorrowOreturn=@BorrowOreturn,");
  396. strSql.Append("BorrowDate=@BorrowDate,");
  397. strSql.Append("BorrowPeople=@BorrowPeople");
  398. strSql.Append(" where id=@id");
  399. SqlParameter[] parameters = {
  400. new SqlParameter("@archivesid", SqlDbType.Int ,4),
  401. new SqlParameter("@BorrowOreturn", SqlDbType.NVarChar,20),
  402. new SqlParameter("@BorrowDate", SqlDbType.DateTime),
  403. new SqlParameter("@BorrowPeople", SqlDbType.NVarChar,50),
  404. new SqlParameter("@id", SqlDbType.Int,4)};
  405. parameters[0].Value = model.archivesid;
  406. parameters[1].Value = model.BorrowOreturn;
  407. parameters[2].Value = model.BorrowDate;
  408. parameters[3].Value = model.BorrowPeople;
  409. parameters[4].Value = model.id;
  410. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  411. if (rows > 0)
  412. {
  413. return true;
  414. }
  415. else
  416. {
  417. return false;
  418. }
  419. }
  420. /// <summary>
  421. /// 获取客户操作表实体
  422. /// </summary>
  423. /// <param name="id"></param>
  424. /// <returns></returns>
  425. public CallCenterApi.Model.customerBorrow GetCustomerModel(int id)
  426. {
  427. StringBuilder strSql = new StringBuilder();
  428. strSql.Append("select top 1 id,archivesid,BorrowOreturn,BorrowDate,BorrowPeople from customerBorrow ");
  429. strSql.Append(" where id=@id");
  430. SqlParameter[] parameters = {
  431. new SqlParameter("@id", SqlDbType.Int,4)};
  432. parameters[0].Value = id;
  433. DataSet ds = DbHelperSQL.Query(strSql.ToString(), parameters);
  434. if (ds.Tables[0].Rows.Count > 0)
  435. {
  436. return DataRowToModelcustomerBorrow(ds.Tables[0].Rows[0]);
  437. }
  438. else
  439. {
  440. return null;
  441. }
  442. }
  443. /// <summary>
  444. /// 获取客户操作表实体
  445. /// </summary>
  446. /// <param name="id"></param>
  447. /// <returns></returns>
  448. public Model.customerBorrow DataRowToModelcustomerBorrow(DataRow row)
  449. {
  450. Model.customerBorrow model = new Model.customerBorrow();//主表字段
  451. if (row != null)
  452. {
  453. #region 主表信息======================
  454. //利用反射获得属性的所有公共属性
  455. Type modelType = model.GetType();
  456. for (int i = 0; i < row.Table.Columns.Count; i++)
  457. {
  458. PropertyInfo proInfo = modelType.GetProperty(row.Table.Columns[i].ColumnName);
  459. if (proInfo != null && row[i] != DBNull.Value)
  460. {
  461. //用索引值设置属性值
  462. proInfo.SetValue(model, row[i], null);
  463. }
  464. }
  465. #endregion
  466. }
  467. return model;
  468. }
  469. /// <summary>
  470. /// 删除一条客户操作信息
  471. /// </summary>
  472. /// <param name="id"></param>
  473. /// <returns></returns>
  474. public bool delCustomerBorrow(int id)
  475. {
  476. StringBuilder strSql = new StringBuilder();
  477. strSql.Append("delete from customerBorrow ");
  478. strSql.Append(" where id=@id");
  479. SqlParameter[] parameters = {
  480. new SqlParameter("@id", SqlDbType.Int,4)
  481. };
  482. parameters[0].Value = id;
  483. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  484. if (rows > 0)
  485. {
  486. return true;
  487. }
  488. else
  489. {
  490. return false;
  491. }
  492. }
  493. /// <summary>
  494. /// 获取内部操作表信息
  495. /// </summary>
  496. /// <returns></returns>
  497. public DataSet GetinsideOperation()
  498. {
  499. StringBuilder strSql = new StringBuilder();
  500. strSql.Append("select ");
  501. strSql.Append(" * ");
  502. strSql.Append(" FROM insideOperation ");
  503. var ds = DbHelperSQL.Query(strSql.ToString());
  504. return ds;
  505. }
  506. /// <summary>
  507. /// 内部员工操作信息添加
  508. /// </summary>
  509. /// <returns></returns>
  510. public int AddinsideOperation(CallCenterApi.Model.insideOperation model)
  511. {
  512. StringBuilder strSql = new StringBuilder();
  513. strSql.Append("insert into insideOperation(");
  514. strSql.Append("archivesid,Warehousing,WarehousingDate,Operator)");
  515. strSql.Append(" values (");
  516. strSql.Append("@archivesid,@Warehousing,@WarehousingDate,@Operator)");
  517. strSql.Append(";select @@IDENTITY");
  518. SqlParameter[] parameters = {
  519. new SqlParameter("@archivesid", SqlDbType.Int ,4),
  520. new SqlParameter("@Warehousing", SqlDbType.NVarChar,20),
  521. new SqlParameter("@WarehousingDate", SqlDbType.DateTime),
  522. new SqlParameter("@Operator", SqlDbType.NVarChar,50) };
  523. parameters[0].Value = model.archivesid;
  524. parameters[1].Value = model.Warehousing;
  525. parameters[2].Value = model.WarehousingDate;
  526. parameters[3].Value = model.Operator;
  527. object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
  528. if (obj == null)
  529. {
  530. return 0;
  531. }
  532. else
  533. {
  534. return Convert.ToInt32(obj);
  535. }
  536. }
  537. /// <summary>
  538. /// 修改内部员工操作信息
  539. /// </summary>
  540. /// <returns></returns>
  541. public bool UpinsideOperation(CallCenterApi.Model.insideOperation model)
  542. {
  543. StringBuilder strSql = new StringBuilder();
  544. strSql.Append("update insideOperation set ");
  545. strSql.Append("archivesid=@archivesid,");
  546. strSql.Append("Warehousing=@Warehousing,");
  547. strSql.Append("WarehousingDate=@WarehousingDate,");
  548. strSql.Append("Operator=@Operator,");
  549. strSql.Append(" where id=@id");
  550. SqlParameter[] parameters = {
  551. new SqlParameter("@archivesid", SqlDbType.Int ,4),
  552. new SqlParameter("@Warehousing", SqlDbType.NVarChar,20),
  553. new SqlParameter("@WarehousingDate", SqlDbType.DateTime),
  554. new SqlParameter("@Operator", SqlDbType.NVarChar,50),
  555. new SqlParameter("@id", SqlDbType.Int,4)};
  556. parameters[0].Value = model.archivesid;
  557. parameters[1].Value = model.Warehousing;
  558. parameters[2].Value = model.WarehousingDate;
  559. parameters[3].Value = model.Operator;
  560. parameters[4].Value = model.id;
  561. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  562. if (rows > 0)
  563. {
  564. return true;
  565. }
  566. else
  567. {
  568. return false;
  569. }
  570. }
  571. /// <summary>
  572. /// 获取内部员工操作表实体
  573. /// </summary>
  574. /// <param name="id"></param>
  575. /// <returns></returns>
  576. public CallCenterApi.Model.insideOperation GetinsideOperationModel(int id)
  577. {
  578. StringBuilder strSql = new StringBuilder();
  579. strSql.Append("select top 1 id,archivesid,Warehousing,WarehousingDate,Operator from insideOperation ");
  580. strSql.Append(" where id=@id");
  581. SqlParameter[] parameters = {
  582. new SqlParameter("@id", SqlDbType.Int,4)};
  583. parameters[0].Value = id;
  584. DataSet ds = DbHelperSQL.Query(strSql.ToString(), parameters);
  585. if (ds.Tables[0].Rows.Count > 0)
  586. {
  587. return DataRowToModelinsideOperation(ds.Tables[0].Rows[0]);
  588. }
  589. else
  590. {
  591. return null;
  592. }
  593. }
  594. /// <summary>
  595. /// 获取内部员工操作表实体
  596. /// </summary>
  597. /// <param name="id"></param>
  598. /// <returns></returns>
  599. public Model.insideOperation DataRowToModelinsideOperation(DataRow row)
  600. {
  601. Model.insideOperation model = new Model.insideOperation();//主表字段
  602. if (row != null)
  603. {
  604. #region 主表信息======================
  605. //利用反射获得属性的所有公共属性
  606. Type modelType = model.GetType();
  607. for (int i = 0; i < row.Table.Columns.Count; i++)
  608. {
  609. PropertyInfo proInfo = modelType.GetProperty(row.Table.Columns[i].ColumnName);
  610. if (proInfo != null && row[i] != DBNull.Value)
  611. {
  612. //用索引值设置属性值
  613. proInfo.SetValue(model, row[i], null);
  614. }
  615. }
  616. #endregion
  617. }
  618. return model;
  619. }
  620. /// <summary>
  621. /// 删除一条内部员工操作信息
  622. /// </summary>
  623. /// <param name="id"></param>
  624. /// <returns></returns>
  625. public bool delinsideOperation(int id)
  626. {
  627. StringBuilder strSql = new StringBuilder();
  628. strSql.Append("delete from insideOperation ");
  629. strSql.Append(" where id=@id");
  630. SqlParameter[] parameters = {
  631. new SqlParameter("@id", SqlDbType.Int,4)
  632. };
  633. parameters[0].Value = id;
  634. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  635. if (rows > 0)
  636. {
  637. return true;
  638. }
  639. else
  640. {
  641. return false;
  642. }
  643. }
  644. /// <summary>
  645. /// 获取操作日志表信息
  646. /// </summary>
  647. /// <returns></returns>
  648. public DataSet GetOperationlog()
  649. {
  650. StringBuilder strSql = new StringBuilder();
  651. strSql.Append("select ");
  652. strSql.Append(" * ");
  653. strSql.Append(" FROM Operationlog ");
  654. var ds = DbHelperSQL.Query(strSql.ToString());
  655. return ds;
  656. }
  657. /// <summary>
  658. /// 操作日志信息添加
  659. /// </summary>
  660. /// <returns></returns>
  661. public int AddOperationlog(CallCenterApi.Model.Operationlog model)
  662. {
  663. StringBuilder strSql = new StringBuilder();
  664. strSql.Append("insert into Operationlog(");
  665. strSql.Append("archivesid,Operator,OperationContent,OperationDate)");
  666. strSql.Append(" values (");
  667. strSql.Append("@archivesid,@Operator,@OperationContent,@OperationDate)");
  668. strSql.Append(";select @@IDENTITY");
  669. SqlParameter[] parameters = {
  670. new SqlParameter("@archivesid", SqlDbType.Int,50),
  671. new SqlParameter("@Operator", SqlDbType.NVarChar,50),
  672. new SqlParameter("@OperationContent", SqlDbType.NVarChar,100),
  673. new SqlParameter("@OperationDate", SqlDbType.DateTime)};
  674. parameters[0].Value = model.archivesid;
  675. parameters[1].Value = model.Operator;//操作人
  676. parameters[2].Value = model.OperationContent;//操作内容
  677. parameters[3].Value = model.OperationDate;//操作时间
  678. object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
  679. if (obj == null)
  680. {
  681. return 0;
  682. }
  683. else
  684. {
  685. return Convert.ToInt32(obj);
  686. }
  687. }
  688. /// <summary>
  689. /// 获取操作日志信息的实体
  690. /// </summary>
  691. /// <param name="row"></param>
  692. /// <returns></returns>
  693. public Model.Operationlog DataRowToModelOperationlog(DataRow row)
  694. {
  695. Model.Operationlog model = new Model.Operationlog();//主表字段
  696. if (row != null)
  697. {
  698. #region 主表信息======================
  699. //利用反射获得属性的所有公共属性
  700. Type modelType = model.GetType();
  701. for (int i = 0; i < row.Table.Columns.Count; i++)
  702. {
  703. PropertyInfo proInfo = modelType.GetProperty(row.Table.Columns[i].ColumnName);
  704. if (proInfo != null && row[i] != DBNull.Value)
  705. {
  706. //用索引值设置属性值
  707. proInfo.SetValue(model, row[i], null);
  708. }
  709. }
  710. #endregion
  711. }
  712. return model;
  713. }
  714. }
  715. }