FKGL_SyncService.cs 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413
  1. using HH.YiDaSyncNC.Dtos;
  2. using HH.YiDaSyncNC.Dtos.NC;
  3. using HH.YiDaSyncNC.Dtos.YIDA;
  4. using HH.YiDaSyncNC.Helper;
  5. using HH.YiDaSyncNC.Models;
  6. using Newtonsoft.Json;
  7. using SqlSugar;
  8. using System;
  9. using System.Collections.Generic;
  10. using System.Configuration;
  11. using System.Linq;
  12. using System.Reflection;
  13. using System.Runtime.Remoting.Messaging;
  14. using System.Text;
  15. using System.Threading.Tasks;
  16. using System.Xml.Linq;
  17. namespace HH.YiDaSyncNC.DataSync
  18. {
  19. public class FKGL_SyncService
  20. {
  21. public string _AppType;
  22. public string _SystemToken;
  23. public string _UserId;
  24. public string _FormId;
  25. public SqlSugarClient _db;
  26. public SqlSugarClient _db_nc;
  27. public string _NCApiUrl;
  28. public static string _Static_PK_bd_project = ConfigurationManager.AppSettings["bd_project"];
  29. public static string _Static_pk_org_jt = ConfigurationManager.AppSettings["pk_org_jt"];
  30. public FKGL_SyncService(string AppType, string SystemToken, string UserId, string FormId, SqlSugarClient db, SqlSugarClient db_nc, string NCApiUrl)
  31. {
  32. _AppType = AppType;
  33. _SystemToken = SystemToken;
  34. _UserId = UserId;
  35. _FormId = FormId;
  36. _db = db;
  37. _db_nc = db_nc;
  38. _NCApiUrl = NCApiUrl;
  39. }
  40. public void DataSync()
  41. {
  42. //try
  43. //{
  44. // DingTalkService _dingTalkService = new DingTalkService(_AppType, _SystemToken, _UserId, _FormId);
  45. // // 宜搭全量数据Id
  46. // var serchKeyListJson = new
  47. // {
  48. // radioField_lycrvvtk = "Y",
  49. // selectField_lrnh633d = "预付",
  50. // };
  51. // var idList = _dingTalkService.GetFormIdList(JsonConvert.SerializeObject(serchKeyListJson));
  52. // //LogHelper.WriteLog(JsonConvert.SerializeObject(idList.Count), "idList");
  53. // #region 获取NC中选项数据的Id
  54. // var bd_customerDic = _db_nc.Queryable<bd_customer>().ToList();
  55. // var bd_incomeDic = _db_nc.Queryable<bd_income>().ToList();
  56. // var org_orgsDic = _db_nc.Queryable<org_orgs>().ToList();
  57. // var bd_projectDic = _db_nc.Queryable<bd_project>().ToList();
  58. // var bd_materialDic = _db_nc.Queryable<bd_material>().ToList();
  59. // var bd_measdocDic = _db_nc.Queryable<bd_measdoc>().ToList();
  60. // var org_deptDic = _db_nc.Queryable<org_dept>().ToList();
  61. // var bd_psndocDic = _db_nc.Queryable<bd_psndoc>().ToList();
  62. // var sm_userDic = _db_nc.Queryable<sm_user>().ToList();
  63. // var org_accountingbookDic = _db_nc.Queryable<org_accountingbook>().ToList();
  64. // #endregion
  65. // foreach (var item in idList)
  66. // {
  67. // string createTime = "";
  68. // string modifyTime = "";
  69. // var ydDataSource = _dingTalkService.GetFormDataById(item, out createTime, out modifyTime);
  70. // string jsonData = JsonConvert.SerializeObject(ydDataSource);
  71. // YiDa_SKDNC thisYiDaData = JsonConvert.DeserializeObject<YiDa_SKDNC>(jsonData);
  72. // if (string.IsNullOrWhiteSpace(thisYiDaData.selectField_lvywoqmb)) continue;
  73. // //取值 宜搭表单的某个字段当作凭证日期 如果 支付完成时间 为null,就用 提交时间
  74. // DateTime 凭证日期 = DateTime.Now;
  75. // //thisYiDaData.dateField_lwitiobz is null
  76. // // ? UnixTimeHelper.ConvertMillisecondsToDateTime(thisYiDaData.dateField_lviv4sfy)
  77. // // : UnixTimeHelper.ConvertMillisecondsToDateTime((long)thisYiDaData.dateField_lwitiobz);
  78. // string 组织 = "";
  79. // if (!string.IsNullOrWhiteSpace(thisYiDaData.selectField_lvywoqmb))
  80. // {
  81. // var tempData = org_orgsDic.FirstOrDefault(f => f.name == thisYiDaData.selectField_lvywoqmb);
  82. // if (tempData != null)
  83. // {
  84. // 组织 = tempData.code; // 组织
  85. // }
  86. // }
  87. // string 账簿 = "";
  88. // if (!string.IsNullOrWhiteSpace(thisYiDaData.selectField_lvywoqmb))
  89. // {
  90. // var tempData = org_accountingbookDic.FirstOrDefault(f => f.name == thisYiDaData.selectField_lvywoqmb + "-蓝云账簿");
  91. // if (tempData != null)
  92. // {
  93. // 账簿 = tempData.code; // 账簿
  94. // }
  95. // }
  96. // string 制单人 = "OA-NC";
  97. // // 表头
  98. // var headModel = new FKGL_SyncServiceModel.DataModel.voucher_header()
  99. // {
  100. // year = 凭证日期.ToString("yyyy"),//会计年度
  101. // prepareddate = 凭证日期.ToString("yyyy-MM-dd"),//制单日期
  102. // period = 凭证日期.ToString("MM"),//会计期间
  103. // pk_prepared = 制单人,//凭证制单人--操作员工工号
  104. // no = "",//凭证号
  105. // pk_accountingbook = 账簿,//账簿
  106. // org = 组织,//组织编码
  107. // pk_vouchertype = "03",//凭证类别 : 01-记账凭证 ,02-收款凭证 ,03-付款凭证 ,04-转账凭证 要确定
  108. // };
  109. // //表体
  110. // var detailList = new List<FKGL_SyncServiceModel.DataModel.voucher_body>();
  111. // #region 例子
  112. // //if (thisYiDaData.tableField_lrngrtgu != null)
  113. // //{
  114. // ////循环内是借方分录赋值
  115. // //foreach (var objItem in detailObjList1)
  116. // //{
  117. // // var detailItem = new FKGL_SyncServiceModel.DataModel.voucher_body()
  118. // // {
  119. // // detailindex = index,
  120. // // accsubjcode = objItem.textField_lwitioce,//科目编码 要确定
  121. // // pk_accasoa = objItem.textField_lwitioce,//科目编码 要确定
  122. // // explanation = objItem.textField_lvxa4v05,//摘要 要确定
  123. // // verifydate = 凭证日期.ToString("yyyy-MM-dd"),
  124. // // price = "0.00000000",
  125. // // excrate2 = "1",
  126. // // debitquantity = "0.00000000",
  127. // // debitamount = objItem.numberField_lvxa4v09.ToString(),//借方金额 要确定
  128. // // groupdebitamount = "0.00000000",
  129. // // globaldebitamount = "0.00000000",
  130. // // localdebitamount = objItem.numberField_lvxa4v09.ToString(),//借方金额 要确定
  131. // // creditquantity = "0.00000000",
  132. // // creditamount = "0.00000000",
  133. // // groupcreditamount = "0.00000000",
  134. // // globalcreditamount = "0.00000000",
  135. // // localcreditamount = "0.00000000",
  136. // // billtype = "",
  137. // // bankaccount = "",
  138. // // checkstyle = "",
  139. // // checkno = "",
  140. // // checkdate = "",
  141. // // bill_id = "",
  142. // // bill_date = "",
  143. // // pk_currtype = "CNY",
  144. // // cash_flow = new FKGL_SyncServiceModel.DataModel.cash_flow()//现金流 要确定
  145. // // {
  146. // // m_pk_currtype = "CNY",
  147. // // money = objItem.numberField_lvxa4v09.ToString(),//金额 要确定
  148. // // moneymain = objItem.numberField_lvxa4v09.ToString(),//金额 要确定
  149. // // moneygroup = "",
  150. // // moneyglobal = "",
  151. // // pk_cashflow = "1124",//写死目前 要确定
  152. // // pk_innercorp = "",
  153. // // },
  154. // // ass = new List<FKGL_SyncServiceModel.DataModel.ass>()//要确定
  155. // // {
  156. // // new FKGL_SyncServiceModel.DataModel.ass()
  157. // // {
  158. // // pk_Checktype ="0010",//0010-项目辅助核算 要确定
  159. // // pk_Checkvalue = "XM00368",//项目编码 目前写死 要确定
  160. // // }
  161. // // },
  162. // // };
  163. // // detailList.Add(detailItem);
  164. // // //销项税分录 要确认
  165. // // detailList.Add(
  166. // // new FKGL_SyncServiceModel.DataModel.voucher_body()
  167. // // {
  168. // // detailindex = index + 1,
  169. // // accsubjcode = "22210103",//科目编码 要确定
  170. // // pk_accasoa = "22210103",//科目编码 要确定
  171. // // explanation = objItem.textField_lvxa4v05,//摘要 要确定
  172. // // verifydate = 凭证日期.ToString("yyyy-MM-dd"),
  173. // // price = "0.00000000",
  174. // // excrate2 = "1",
  175. // // debitquantity = "0.00000000",
  176. // // debitamount = objItem.numberField_lvxa4v08.ToString(),//借方金额 要确定
  177. // // groupdebitamount = "0.00000000",
  178. // // globaldebitamount = "0.00000000",
  179. // // localdebitamount = objItem.numberField_lvxa4v08.ToString(),//借方金额 要确定
  180. // // creditquantity = "0.00000000",
  181. // // creditamount = "0.00000000",//贷方金额
  182. // // groupcreditamount = "0.00000000",
  183. // // globalcreditamount = "0.00000000",
  184. // // localcreditamount = "0.00000000",//贷方金额
  185. // // billtype = "",
  186. // // bankaccount = "",
  187. // // checkstyle = "",
  188. // // checkno = "",
  189. // // checkdate = "",
  190. // // bill_id = "",
  191. // // bill_date = "",
  192. // // pk_currtype = "CNY",
  193. // // cash_flow = new FKGL_SyncServiceModel.DataModel.cash_flow()//现金流 要确定
  194. // // {
  195. // // m_pk_currtype = "CNY",
  196. // // money = objItem.numberField_lvxa4v08.ToString(),//金额 要确定
  197. // // moneymain = objItem.numberField_lvxa4v08.ToString(),//金额 要确定
  198. // // moneygroup = "",
  199. // // moneyglobal = "",
  200. // // pk_cashflow = "1124",//写死目前 要确定
  201. // // pk_innercorp = "",
  202. // // },
  203. // // ass = new List<FKGL_SyncServiceModel.DataModel.ass>()
  204. // // {
  205. // // },
  206. // // }
  207. // // );
  208. // // index++;
  209. // //}
  210. // ////销项税分录 要确认
  211. // ////贷方
  212. // //detailList.Add(
  213. // // new FKGL_SyncServiceModel.DataModel.voucher_body()
  214. // // {
  215. // // detailindex = index,
  216. // // accsubjcode = "100204",//科目编码 要确定 用哪个贷方科目? 100204-光大银行
  217. // // pk_accasoa = "100204",//科目编码 要确定 用哪个贷方科目?
  218. // // explanation = "贷方摘要",//摘要 要确定
  219. // // verifydate = 凭证日期.ToString("yyyy-MM-dd"),
  220. // // price = "0.00000000",
  221. // // excrate2 = "1",
  222. // // debitquantity = "0.00000000",
  223. // // debitamount = "0.00000000",
  224. // // groupdebitamount = "0.00000000",
  225. // // globaldebitamount = "0.00000000",
  226. // // localdebitamount = "0.00000000",
  227. // // creditquantity = "0.00000000",
  228. // // creditamount = thisYiDaData.numberField_lvua3j18.ToString(),//贷方金额 要确定
  229. // // groupcreditamount = "0.00000000",
  230. // // globalcreditamount = "0.00000000",
  231. // // localcreditamount = thisYiDaData.numberField_lvua3j18.ToString(),//贷方金额 要确定
  232. // // billtype = "",
  233. // // bankaccount = "",
  234. // // checkstyle = "",
  235. // // checkno = "",
  236. // // checkdate = "",
  237. // // bill_id = "",
  238. // // bill_date = "",
  239. // // pk_currtype = "CNY",
  240. // // cash_flow = new FKGL_SyncServiceModel.DataModel.cash_flow()
  241. // // {
  242. // // },
  243. // // ass = new List<FKGL_SyncServiceModel.DataModel.ass>()//辅助核算 要确定
  244. // // {
  245. // // new FKGL_SyncServiceModel.DataModel.ass()
  246. // // {
  247. // // pk_Checktype ="0011",//0011-银行账户辅助核算 要确定
  248. // // pk_Checkvalue = "36640188000164043",//银行账户 目前写死(36640188000164043:上海蓝云环境科技有限公司(光大银行)) 要确定
  249. // // }
  250. // // },
  251. // // }
  252. // //);
  253. // //}
  254. // #endregion
  255. // //借方分录
  256. // detailList.Add(new FKGL_SyncServiceModel.DataModel.voucher_body()
  257. // {
  258. // detailindex = 1,
  259. // accsubjcode = "1123",//科目编码 预付账款
  260. // pk_accasoa = "1123",//科目编码
  261. // explanation = "借方摘要",//摘要
  262. // verifydate = 凭证日期.ToString("yyyy-MM-dd"),
  263. // price = "0.00000000",
  264. // excrate2 = "1",
  265. // debitquantity = "0.00000000",
  266. // debitamount = thisYiDaData.numberField_lvua3j18.ToString(),//借方金额
  267. // groupdebitamount = "0.00000000",
  268. // globaldebitamount = "0.00000000",
  269. // localdebitamount = thisYiDaData.numberField_lvua3j18.ToString(),//借方金额
  270. // creditquantity = "0.00000000",
  271. // creditamount = "0.00000000",
  272. // groupcreditamount = "0.00000000",
  273. // globalcreditamount = "0.00000000",
  274. // localcreditamount = "0.00000000",
  275. // billtype = "",
  276. // bankaccount = "",
  277. // checkstyle = "",
  278. // checkno = "",
  279. // checkdate = "",
  280. // bill_id = "",
  281. // bill_date = "",
  282. // pk_currtype = "CNY",
  283. // cash_flow = new FKGL_SyncServiceModel.DataModel.cash_flow()//现金流
  284. // {
  285. // m_pk_currtype = "CNY",
  286. // money = thisYiDaData.numberField_lvua3j18.ToString(),//金额
  287. // moneymain = thisYiDaData.numberField_lvua3j18.ToString(),//金额
  288. // moneygroup = "",
  289. // moneyglobal = "",
  290. // pk_cashflow = "1124",//现金流编码
  291. // pk_innercorp = "",
  292. // },
  293. // ass = new List<FKGL_SyncServiceModel.DataModel.ass>()//
  294. // {
  295. // new FKGL_SyncServiceModel.DataModel.ass()
  296. // {
  297. // pk_Checktype ="0019",//0019-供应商辅助核算
  298. // pk_Checkvalue = thisYiDaData.textField_lwitiobt,//供应商编码
  299. // }
  300. // },
  301. // });
  302. // //贷方
  303. // detailList.Add(
  304. // new FKGL_SyncServiceModel.DataModel.voucher_body()
  305. // {
  306. // detailindex = 2,
  307. // accsubjcode = thisYiDaData.textField_lyodct8u,//科目编码
  308. // pk_accasoa = thisYiDaData.textField_lyodct8u,//科目编码
  309. // explanation = "贷方摘要",//摘要
  310. // verifydate = 凭证日期.ToString("yyyy-MM-dd"),
  311. // price = "0.00000000",
  312. // excrate2 = "1",
  313. // debitquantity = "0.00000000",
  314. // debitamount = "0.00000000",
  315. // groupdebitamount = "0.00000000",
  316. // globaldebitamount = "0.00000000",
  317. // localdebitamount = "0.00000000",
  318. // creditquantity = "0.00000000",
  319. // creditamount = thisYiDaData.numberField_lvua3j18.ToString(),//贷方金额
  320. // groupcreditamount = "0.00000000",
  321. // globalcreditamount = "0.00000000",
  322. // localcreditamount = thisYiDaData.numberField_lvua3j18.ToString(),//贷方金额
  323. // billtype = "",
  324. // bankaccount = "",
  325. // checkstyle = "",
  326. // checkno = "",
  327. // checkdate = "",
  328. // bill_id = "",
  329. // bill_date = "",
  330. // pk_currtype = "CNY",
  331. // cash_flow = new FKGL_SyncServiceModel.DataModel.cash_flow()
  332. // {
  333. // },
  334. // ass = new List<FKGL_SyncServiceModel.DataModel.ass>()//辅助核算
  335. // {
  336. // new FKGL_SyncServiceModel.DataModel.ass()
  337. // {
  338. // pk_Checktype ="0011",//0011-银行账户辅助核算
  339. // pk_Checkvalue = thisYiDaData.textField_lrngrtgj,//银行账户
  340. // }
  341. // },
  342. // }
  343. // );
  344. // XElement xElement = FKGL_SyncServiceModel.ImportXml_凭证.TemplateHeade(headModel);
  345. // xElement.Add(FKGL_SyncServiceModel.ImportXml_凭证.Header(headModel));//添加表头数据
  346. // xElement.Element("voucher").Element("voucher_head").Element("details").Add(FKGL_SyncServiceModel.ImportXml_凭证.Bodydebit(detailList));
  347. // //生成凭证
  348. // var results_凭证 = NCImportFunc.NCImport2(xElement, _NCApiUrl + "?account=01&groupcode=0");
  349. // LogHelper.WriteLog(JsonConvert.SerializeObject(results_凭证), "results_凭证");
  350. // XElement xE = XElement.Parse(results_凭证);
  351. // string resultcode = xE.Element("sendresult").Element("resultcode").Value;
  352. // string content = xE.Element("sendresult").Element("content")?.Value;
  353. // string resultdescription = xE.Element("sendresult").Element("resultdescription")?.Value;
  354. // var ncResData = new YiDaResDto();
  355. // if (resultcode == "1")
  356. // {
  357. // ncResData = (new YiDaResDto()
  358. // {
  359. // bSuccess = true,
  360. // syncTime = DateTime.Now,
  361. // ncNo = resultdescription,//xE.Element("sendresult").Element("content").Value,
  362. // log = "同步成功!"
  363. // });
  364. // }
  365. // else
  366. // {
  367. // ncResData = (new YiDaResDto()
  368. // {
  369. // bSuccess = false,
  370. // syncTime = DateTime.Now,
  371. // ncNo = "",
  372. // log = "同步失败!原因为【" + resultdescription + "】!"
  373. // });
  374. // }
  375. // //更新同步标识
  376. // var ydRes = _dingTalkService.UpdateFormDataSyncDataById(ncResData, item);
  377. // }
  378. //}
  379. //catch (Exception ex)
  380. //{
  381. // throw;
  382. //}
  383. }
  384. }
  385. }