三元财务API

archives.cs 30KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795
  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. /// 根据微信openid获取客户名称
  357. /// </summary>
  358. /// <param name="openid"></param>
  359. /// <returns></returns>
  360. public string GetCustomerName(string openid)
  361. {
  362. string name = "";
  363. StringBuilder strSql = new StringBuilder();
  364. strSql.Append("select * from T_Cus_CustomerBaseNew");
  365. strSql.Append(" where F_WxOpenId=@F_WxOpenId");
  366. SqlParameter[] parameters = {
  367. new SqlParameter("@F_WxOpenId", SqlDbType.NVarChar ,300)
  368. };
  369. parameters[0].Value = openid;
  370. var ds = DbHelperSQL.Query(strSql.ToString(), parameters);
  371. Model.T_Cus_CustomerBaseNew ar = new Model.T_Cus_CustomerBaseNew();
  372. if (ds.Tables[0].Rows.Count > 0)
  373. {
  374. ar = DataRowT_Cus_CustomerBaseNew(ds.Tables[0].Rows[0]);
  375. name = ar.F_CustomerCode;
  376. }
  377. return name;
  378. }
  379. /// <summary>
  380. /// 得到一个物资状态对象实体
  381. /// </summary>
  382. public CallCenterApi.Model.T_Cus_CustomerBaseNew DataRowT_Cus_CustomerBaseNew(DataRow row)
  383. {
  384. Model.T_Cus_CustomerBaseNew model = new Model.T_Cus_CustomerBaseNew();//主表字段
  385. if (row != null)
  386. {
  387. if (row["F_CustomerCode"] != null)
  388. {
  389. model.F_CustomerCode = row["F_CustomerCode"].ToString();
  390. }
  391. }
  392. return model;
  393. return model;
  394. }
  395. /// <summary>
  396. /// 外部客户操作信息添加
  397. /// </summary>
  398. /// <returns></returns>
  399. public int AddCustomerBorrow(CallCenterApi.Model.customerBorrow model)
  400. {
  401. StringBuilder strSql = new StringBuilder();
  402. strSql.Append("insert into customerBorrow(");
  403. strSql.Append("archivesid,BorrowOreturn,BorrowDate,BorrowPeople)");
  404. strSql.Append(" values (");
  405. strSql.Append("@archivesid,@BorrowOreturn,@BorrowDate,@BorrowPeople)");
  406. strSql.Append(";select @@IDENTITY");
  407. SqlParameter[] parameters = {
  408. new SqlParameter("@archivesid", SqlDbType.Int ,4),
  409. new SqlParameter("@BorrowOreturn", SqlDbType.NVarChar,20),
  410. new SqlParameter("@BorrowDate", SqlDbType.DateTime),
  411. new SqlParameter("@BorrowPeople", SqlDbType.NVarChar,50) };
  412. parameters[0].Value = model.archivesid;
  413. parameters[1].Value = model.BorrowOreturn;
  414. parameters[2].Value = model.BorrowDate;
  415. parameters[3].Value = model.BorrowPeople;
  416. object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
  417. if (obj == null)
  418. {
  419. return 0;
  420. }
  421. else
  422. {
  423. return Convert.ToInt32(obj);
  424. }
  425. }
  426. /// <summary>
  427. /// 修改客户操作信息
  428. /// </summary>
  429. /// <returns></returns>
  430. public bool UpCustomerBorrow(CallCenterApi.Model.customerBorrow model)
  431. {
  432. StringBuilder strSql = new StringBuilder();
  433. strSql.Append("update customerBorrow set ");
  434. strSql.Append("archivesid=@archivesid,");
  435. strSql.Append("BorrowOreturn=@BorrowOreturn,");
  436. strSql.Append("BorrowDate=@BorrowDate,");
  437. strSql.Append("BorrowPeople=@BorrowPeople");
  438. strSql.Append(" where id=@id");
  439. SqlParameter[] parameters = {
  440. new SqlParameter("@archivesid", SqlDbType.Int ,4),
  441. new SqlParameter("@BorrowOreturn", SqlDbType.NVarChar,20),
  442. new SqlParameter("@BorrowDate", SqlDbType.DateTime),
  443. new SqlParameter("@BorrowPeople", SqlDbType.NVarChar,50),
  444. new SqlParameter("@id", SqlDbType.Int,4)};
  445. parameters[0].Value = model.archivesid;
  446. parameters[1].Value = model.BorrowOreturn;
  447. parameters[2].Value = model.BorrowDate;
  448. parameters[3].Value = model.BorrowPeople;
  449. parameters[4].Value = model.id;
  450. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  451. if (rows > 0)
  452. {
  453. return true;
  454. }
  455. else
  456. {
  457. return false;
  458. }
  459. }
  460. /// <summary>
  461. /// 获取客户操作表实体
  462. /// </summary>
  463. /// <param name="id"></param>
  464. /// <returns></returns>
  465. public CallCenterApi.Model.customerBorrow GetCustomerModel(int id)
  466. {
  467. StringBuilder strSql = new StringBuilder();
  468. strSql.Append("select top 1 id,archivesid,BorrowOreturn,BorrowDate,BorrowPeople from customerBorrow ");
  469. strSql.Append(" where id=@id");
  470. SqlParameter[] parameters = {
  471. new SqlParameter("@id", SqlDbType.Int,4)};
  472. parameters[0].Value = id;
  473. DataSet ds = DbHelperSQL.Query(strSql.ToString(), parameters);
  474. if (ds.Tables[0].Rows.Count > 0)
  475. {
  476. return DataRowToModelcustomerBorrow(ds.Tables[0].Rows[0]);
  477. }
  478. else
  479. {
  480. return null;
  481. }
  482. }
  483. /// <summary>
  484. /// 获取客户操作表实体
  485. /// </summary>
  486. /// <param name="id"></param>
  487. /// <returns></returns>
  488. public Model.customerBorrow DataRowToModelcustomerBorrow(DataRow row)
  489. {
  490. Model.customerBorrow model = new Model.customerBorrow();//主表字段
  491. if (row != null)
  492. {
  493. #region 主表信息======================
  494. //利用反射获得属性的所有公共属性
  495. Type modelType = model.GetType();
  496. for (int i = 0; i < row.Table.Columns.Count; i++)
  497. {
  498. PropertyInfo proInfo = modelType.GetProperty(row.Table.Columns[i].ColumnName);
  499. if (proInfo != null && row[i] != DBNull.Value)
  500. {
  501. //用索引值设置属性值
  502. proInfo.SetValue(model, row[i], null);
  503. }
  504. }
  505. #endregion
  506. }
  507. return model;
  508. }
  509. /// <summary>
  510. /// 删除一条客户操作信息
  511. /// </summary>
  512. /// <param name="id"></param>
  513. /// <returns></returns>
  514. public bool delCustomerBorrow(int id)
  515. {
  516. StringBuilder strSql = new StringBuilder();
  517. strSql.Append("delete from customerBorrow ");
  518. strSql.Append(" where id=@id");
  519. SqlParameter[] parameters = {
  520. new SqlParameter("@id", SqlDbType.Int,4)
  521. };
  522. parameters[0].Value = id;
  523. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  524. if (rows > 0)
  525. {
  526. return true;
  527. }
  528. else
  529. {
  530. return false;
  531. }
  532. }
  533. /// <summary>
  534. /// 获取内部操作表信息
  535. /// </summary>
  536. /// <returns></returns>
  537. public DataSet GetinsideOperation()
  538. {
  539. StringBuilder strSql = new StringBuilder();
  540. strSql.Append("select ");
  541. strSql.Append(" * ");
  542. strSql.Append(" FROM insideOperation ");
  543. var ds = DbHelperSQL.Query(strSql.ToString());
  544. return ds;
  545. }
  546. /// <summary>
  547. /// 内部员工操作信息添加
  548. /// </summary>
  549. /// <returns></returns>
  550. public int AddinsideOperation(CallCenterApi.Model.insideOperation model)
  551. {
  552. StringBuilder strSql = new StringBuilder();
  553. strSql.Append("insert into insideOperation(");
  554. strSql.Append("archivesid,Warehousing,WarehousingDate,Operator)");
  555. strSql.Append(" values (");
  556. strSql.Append("@archivesid,@Warehousing,@WarehousingDate,@Operator)");
  557. strSql.Append(";select @@IDENTITY");
  558. SqlParameter[] parameters = {
  559. new SqlParameter("@archivesid", SqlDbType.Int ,4),
  560. new SqlParameter("@Warehousing", SqlDbType.NVarChar,20),
  561. new SqlParameter("@WarehousingDate", SqlDbType.DateTime),
  562. new SqlParameter("@Operator", SqlDbType.NVarChar,50) };
  563. parameters[0].Value = model.archivesid;
  564. parameters[1].Value = model.Warehousing;
  565. parameters[2].Value = model.WarehousingDate;
  566. parameters[3].Value = model.Operator;
  567. object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
  568. if (obj == null)
  569. {
  570. return 0;
  571. }
  572. else
  573. {
  574. return Convert.ToInt32(obj);
  575. }
  576. }
  577. /// <summary>
  578. /// 修改内部员工操作信息
  579. /// </summary>
  580. /// <returns></returns>
  581. public bool UpinsideOperation(CallCenterApi.Model.insideOperation model)
  582. {
  583. StringBuilder strSql = new StringBuilder();
  584. strSql.Append("update insideOperation set ");
  585. strSql.Append("archivesid=@archivesid,");
  586. strSql.Append("Warehousing=@Warehousing,");
  587. strSql.Append("WarehousingDate=@WarehousingDate,");
  588. strSql.Append("Operator=@Operator,");
  589. strSql.Append(" where id=@id");
  590. SqlParameter[] parameters = {
  591. new SqlParameter("@archivesid", SqlDbType.Int ,4),
  592. new SqlParameter("@Warehousing", SqlDbType.NVarChar,20),
  593. new SqlParameter("@WarehousingDate", SqlDbType.DateTime),
  594. new SqlParameter("@Operator", SqlDbType.NVarChar,50),
  595. new SqlParameter("@id", SqlDbType.Int,4)};
  596. parameters[0].Value = model.archivesid;
  597. parameters[1].Value = model.Warehousing;
  598. parameters[2].Value = model.WarehousingDate;
  599. parameters[3].Value = model.Operator;
  600. parameters[4].Value = model.id;
  601. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  602. if (rows > 0)
  603. {
  604. return true;
  605. }
  606. else
  607. {
  608. return false;
  609. }
  610. }
  611. /// <summary>
  612. /// 获取内部员工操作表实体
  613. /// </summary>
  614. /// <param name="id"></param>
  615. /// <returns></returns>
  616. public CallCenterApi.Model.insideOperation GetinsideOperationModel(int id)
  617. {
  618. StringBuilder strSql = new StringBuilder();
  619. strSql.Append("select top 1 id,archivesid,Warehousing,WarehousingDate,Operator from insideOperation ");
  620. strSql.Append(" where id=@id");
  621. SqlParameter[] parameters = {
  622. new SqlParameter("@id", SqlDbType.Int,4)};
  623. parameters[0].Value = id;
  624. DataSet ds = DbHelperSQL.Query(strSql.ToString(), parameters);
  625. if (ds.Tables[0].Rows.Count > 0)
  626. {
  627. return DataRowToModelinsideOperation(ds.Tables[0].Rows[0]);
  628. }
  629. else
  630. {
  631. return null;
  632. }
  633. }
  634. /// <summary>
  635. /// 获取内部员工操作表实体
  636. /// </summary>
  637. /// <param name="id"></param>
  638. /// <returns></returns>
  639. public Model.insideOperation DataRowToModelinsideOperation(DataRow row)
  640. {
  641. Model.insideOperation model = new Model.insideOperation();//主表字段
  642. if (row != null)
  643. {
  644. #region 主表信息======================
  645. //利用反射获得属性的所有公共属性
  646. Type modelType = model.GetType();
  647. for (int i = 0; i < row.Table.Columns.Count; i++)
  648. {
  649. PropertyInfo proInfo = modelType.GetProperty(row.Table.Columns[i].ColumnName);
  650. if (proInfo != null && row[i] != DBNull.Value)
  651. {
  652. //用索引值设置属性值
  653. proInfo.SetValue(model, row[i], null);
  654. }
  655. }
  656. #endregion
  657. }
  658. return model;
  659. }
  660. /// <summary>
  661. /// 删除一条内部员工操作信息
  662. /// </summary>
  663. /// <param name="id"></param>
  664. /// <returns></returns>
  665. public bool delinsideOperation(int id)
  666. {
  667. StringBuilder strSql = new StringBuilder();
  668. strSql.Append("delete from insideOperation ");
  669. strSql.Append(" where id=@id");
  670. SqlParameter[] parameters = {
  671. new SqlParameter("@id", SqlDbType.Int,4)
  672. };
  673. parameters[0].Value = id;
  674. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  675. if (rows > 0)
  676. {
  677. return true;
  678. }
  679. else
  680. {
  681. return false;
  682. }
  683. }
  684. /// <summary>
  685. /// 获取操作日志表信息
  686. /// </summary>
  687. /// <returns></returns>
  688. public DataSet GetOperationlog()
  689. {
  690. StringBuilder strSql = new StringBuilder();
  691. strSql.Append("select ");
  692. strSql.Append(" * ");
  693. strSql.Append(" FROM Operationlog ");
  694. var ds = DbHelperSQL.Query(strSql.ToString());
  695. return ds;
  696. }
  697. /// <summary>
  698. /// 操作日志信息添加
  699. /// </summary>
  700. /// <returns></returns>
  701. public int AddOperationlog(CallCenterApi.Model.Operationlog model)
  702. {
  703. StringBuilder strSql = new StringBuilder();
  704. strSql.Append("insert into Operationlog(");
  705. strSql.Append("archivesid,Operator,OperationContent,OperationDate)");
  706. strSql.Append(" values (");
  707. strSql.Append("@archivesid,@Operator,@OperationContent,@OperationDate)");
  708. strSql.Append(";select @@IDENTITY");
  709. SqlParameter[] parameters = {
  710. new SqlParameter("@archivesid", SqlDbType.Int,50),
  711. new SqlParameter("@Operator", SqlDbType.NVarChar,50),
  712. new SqlParameter("@OperationContent", SqlDbType.NVarChar,100),
  713. new SqlParameter("@OperationDate", SqlDbType.DateTime)};
  714. parameters[0].Value = model.archivesid;
  715. parameters[1].Value = model.Operator;//操作人
  716. parameters[2].Value = model.OperationContent;//操作内容
  717. parameters[3].Value = model.OperationDate;//操作时间
  718. object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
  719. if (obj == null)
  720. {
  721. return 0;
  722. }
  723. else
  724. {
  725. return Convert.ToInt32(obj);
  726. }
  727. }
  728. /// <summary>
  729. /// 获取操作日志信息的实体
  730. /// </summary>
  731. /// <param name="row"></param>
  732. /// <returns></returns>
  733. public Model.Operationlog DataRowToModelOperationlog(DataRow row)
  734. {
  735. Model.Operationlog model = new Model.Operationlog();//主表字段
  736. if (row != null)
  737. {
  738. #region 主表信息======================
  739. //利用反射获得属性的所有公共属性
  740. Type modelType = model.GetType();
  741. for (int i = 0; i < row.Table.Columns.Count; i++)
  742. {
  743. PropertyInfo proInfo = modelType.GetProperty(row.Table.Columns[i].ColumnName);
  744. if (proInfo != null && row[i] != DBNull.Value)
  745. {
  746. //用索引值设置属性值
  747. proInfo.SetValue(model, row[i], null);
  748. }
  749. }
  750. #endregion
  751. }
  752. return model;
  753. }
  754. }
  755. }