三元财务API

archives.cs 30KB

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