BZJ_SyncService.cs 32 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636
  1. using HH.YiDaSyncNC.Dtos;
  2. using HH.YiDaSyncNC.Dtos.NC;
  3. using HH.YiDaSyncNC.Helper;
  4. using HH.YiDaSyncNC.Models;
  5. using Newtonsoft.Json;
  6. using SqlSugar;
  7. using System;
  8. using System.Collections.Generic;
  9. using System.Configuration;
  10. using System.Linq;
  11. using System.Text;
  12. using System.Threading.Tasks;
  13. using System.Xml.Linq;
  14. namespace HH.YiDaSyncNC.DataSync
  15. {
  16. class BZJ_SyncService
  17. {
  18. public string _AppType;
  19. public string _SystemToken;
  20. public string _UserId;
  21. public string _FormId;
  22. public SqlSugarClient _db;
  23. public SqlSugarClient _db_nc;
  24. public string _NCApiUrl;
  25. public static string _Static_PK_ct_bondapply = ConfigurationManager.AppSettings["ct_bondapply"];
  26. public static string _Static_PK_ct_bondapply_b = ConfigurationManager.AppSettings["ct_bondapply_b"];
  27. public static string _Static_pk_org_jt = ConfigurationManager.AppSettings["pk_org_jt"];
  28. public BZJ_SyncService(string AppType, string SystemToken, string UserId, string FormId, SqlSugarClient db, SqlSugarClient db_nc, string NCApiUrl)
  29. {
  30. _AppType = AppType;
  31. _SystemToken = SystemToken;
  32. _UserId = UserId;
  33. _FormId = FormId;
  34. _db = db;
  35. _db_nc = db_nc;
  36. _NCApiUrl = NCApiUrl;
  37. }
  38. public class IdCodeModel
  39. {
  40. public int sourceId { get; set; }
  41. public string Id { get; set; }
  42. }
  43. public class FormItem
  44. {
  45. public string title { get; set; }
  46. }
  47. public void DataSync()
  48. {
  49. DingTalkService _dingTalkService = new DingTalkService(_AppType, _SystemToken, _UserId, _FormId);
  50. var codeList = new string[] { "TB_202503050022", "02130200", "04010192", "04010193" };
  51. var ncNo = new string[] { "QKD2025030701", "1001G1100000000EMRSK", "1001G1100000000EMRSR", "1001G1100000000EMRST" };
  52. for (int i = 0; i < codeList.Count(); i++)
  53. {
  54. var idList1 = _dingTalkService.GetFormIdList("{\"textField_lr3axfje\":\"" + codeList[i] + "\"}");
  55. var ncResData1 = new YiDaResDto()
  56. {
  57. syncTime = DateTime.Now,
  58. };
  59. ncResData1.bSuccess = true;
  60. ncResData1.ncNo = ncNo[i];
  61. ncResData1.log = "同步成功!";
  62. var ydRes1 = _dingTalkService.UpdateFormDataSyncDataById(ncResData1, idList1.FirstOrDefault());
  63. }
  64. // 宜搭全量数据Id
  65. //var idList = _dingTalkService.GetFormIdList("{\"radioField_lycrvvtk\":\"Y\",\"selectField_lvituew9\":\"正常\"}");
  66. //var idList = _dingTalkService.GetFormIdList("{\"textField_lvdosccc\":\"KP_2024071700252\"}");
  67. //var idList = _dingTalkService.GetFormIdList("{\"radioField_lycrvvtk\":\"Y\"}");
  68. //LogHelper.WriteLog(JsonConvert.SerializeObject(idList.Count), "idList");
  69. //// 获取当前最大Id
  70. //var newId = 100000001;
  71. //var maxData = _db_nc.Queryable<bd_project>().OrderByDescending(obd => obd.pk_project).First();
  72. //if (maxData != null && maxData.pk_project.Contains(_Static_PK_ct_bondapply))
  73. //{
  74. // newId = Convert.ToInt32(maxData.pk_project.Replace(_Static_PK_ct_bondapply, "")) + 1;
  75. //}
  76. //#region 获取NC中选项数据的Id
  77. //var bd_customerDic = _db_nc.Queryable<bd_customer>().ToList();
  78. //var bd_incomeDic = _db_nc.Queryable<bd_income>().ToList();
  79. //var org_orgsDic = _db_nc.Queryable<org_orgs>().ToList();
  80. //var bd_projectDic = _db_nc.Queryable<bd_project>().ToList();
  81. //var bd_materialDic = _db_nc.Queryable<bd_material>().ToList();
  82. //var bd_measdocDic = _db_nc.Queryable<bd_measdoc>().ToList();
  83. //var org_deptDic = _db_nc.Queryable<org_dept>().ToList();
  84. //var bd_psndocDic = _db_nc.Queryable<bd_psndoc>().ToList();
  85. //var sm_userDic = _db_nc.Queryable<sm_user>().ToList();
  86. //var bd_defdoc_kplx = _db_nc.Queryable<bd_defdoc>().Where(w => w.pk_defdoclist == "1001G1100000000016FV").ToList(); // 开票类型
  87. //var bd_defdoc_htywlx = _db_nc.Queryable<bd_defdoc>().Where(w => w.pk_defdoclist == "1001G1100000000010PV").ToList(); // 合同业务类型
  88. //#endregion
  89. //#region 接口方式
  90. //// 向NC插入数据
  91. //foreach (var item in idList)
  92. //{
  93. // string createTime = "";
  94. // string modifyTime = "";
  95. // var ydDataSource = _dingTalkService.GetFormDataById(item, out createTime, out modifyTime);
  96. // // 如果NC单据号为空,说明没有传入过NC,此时需要走此逻辑去创建销售订单等
  97. // if (ydDataSource.FirstOrDefault(f => f.Key == "textField_ltxyt75m").Value != null && !string.IsNullOrWhiteSpace(ydDataSource["textField_ltxyt75m"].ToString()))
  98. // {
  99. // continue;
  100. // }
  101. // var ncResData = new List<YiDaResDto>();
  102. // #region 表头
  103. // // 表头
  104. // var dataSource = new KP_SyncServiceModel.DataModel();
  105. // if (ydDataSource.FirstOrDefault(f => f.Key == "selectField_lvc9x4vo").Value != null)
  106. // {
  107. // if (!string.IsNullOrWhiteSpace(ydDataSource["selectField_lvc9x4vo"].ToString()))
  108. // {
  109. // var tempData = org_orgsDic.FirstOrDefault(f => f.name == ydDataSource["selectField_lvc9x4vo"].ToString());
  110. // if (tempData != null)
  111. // {
  112. // dataSource.组织 = tempData.code; // 组织
  113. // }
  114. // }
  115. // }
  116. // dataSource.单据日期 = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  117. // if (!string.IsNullOrWhiteSpace(ydDataSource["dateField_lw5ud9bk"].ToString()))
  118. // {
  119. // dataSource.单据日期 = UnixTimeHelper.ConvertMillisecondsToDateTime(Convert.ToInt64(ydDataSource["dateField_lw5ud9bk"].ToString())).ToString("yyyy-MM-dd HH:mm:ss");
  120. // }
  121. // if (ydDataSource.FirstOrDefault(f => f.Key == "textField_lvdojfuj").Value != null)
  122. // {
  123. // if (!string.IsNullOrWhiteSpace(ydDataSource["textField_lvdojfuj"].ToString()))
  124. // {
  125. // var tempData = bd_customerDic.FirstOrDefault(f => f.code == ydDataSource["textField_lvdojfuj"].ToString());
  126. // if (tempData != null)
  127. // {
  128. // dataSource.客户 = tempData.code; // 客户
  129. // }
  130. // }
  131. // }
  132. // if (ydDataSource.FirstOrDefault(f => f.Key == "selectField_lvc9x4vq").Value != null)
  133. // {
  134. // if (!string.IsNullOrWhiteSpace(ydDataSource["selectField_lvc9x4vq"].ToString()))
  135. // {
  136. // var tempData = bd_incomeDic.FirstOrDefault(f => f.name == ydDataSource["selectField_lvc9x4vq"].ToString());
  137. // if (tempData != null)
  138. // {
  139. // dataSource.收款协议 = tempData.code; // 收款协议
  140. // }
  141. // }
  142. // }
  143. // if (ydDataSource.FirstOrDefault(f => f.Key == "departmentSelectField_lvc7mi3w").Value != null)
  144. // {
  145. // if (!string.IsNullOrWhiteSpace(ydDataSource["departmentSelectField_lvc7mi3w"].ToString()))
  146. // {
  147. // var tempData = org_deptDic.FirstOrDefault(f => f.name == JsonConvert.DeserializeObject<List<string>>(JsonConvert.SerializeObject(ydDataSource["departmentSelectField_lvc7mi3w"]))[0]);
  148. // if (tempData != null)
  149. // {
  150. // dataSource.部门 = tempData.code; // 部门
  151. // }
  152. // }
  153. // }
  154. // dataSource.审批人 = "OA-NC";
  155. // dataSource.制单人 = "OA-NC";
  156. // dataSource.创建人 = "OA-NC";
  157. // dataSource.审批时间 = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  158. // dataSource.制单时间 = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  159. // dataSource.创建时间 = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  160. // if (ydDataSource.FirstOrDefault(f => f.Key == "textField_lvdntzul").Value != null)
  161. // {
  162. // if (!string.IsNullOrWhiteSpace(ydDataSource["textField_lvdntzul"].ToString()))
  163. // {
  164. // var tempData = bd_projectDic.FirstOrDefault(f => f.project_code == ydDataSource["textField_lvdntzul"].ToString());
  165. // if (tempData != null)
  166. // {
  167. // dataSource.项目 = tempData.project_code; // 项目
  168. // }
  169. // }
  170. // }
  171. // dataSource.发票号 = ydDataSource["textField_lvd8pp35"].ToString();
  172. // dataSource.客户打印名称 = ydDataSource["selectField_lvdojfui"].ToString();
  173. // if (ydDataSource.FirstOrDefault(f => f.Key == "selectField_lvc9x4vp").Value != null)
  174. // {
  175. // if (!string.IsNullOrWhiteSpace(ydDataSource["selectField_lvc9x4vp"].ToString()))
  176. // {
  177. // var tempName = ydDataSource["selectField_lvc9x4vp"].ToString();
  178. // if (ydDataSource["selectField_lvc9x4vp"].ToString() == "增值税专票")
  179. // {
  180. // tempName = "增值税专用发票";
  181. // }
  182. // if (ydDataSource["selectField_lvc9x4vp"].ToString() == "增值税普票")
  183. // {
  184. // tempName = "增值税普通发票";
  185. // }
  186. // var tempData = bd_defdoc_kplx.FirstOrDefault(f => f.name == tempName);
  187. // if (tempData != null)
  188. // {
  189. // dataSource.开票类型 = tempData.pk_defdoc; // 开票类型
  190. // }
  191. // }
  192. // }
  193. // dataSource.OA单据号 = ydDataSource["textField_lvdosccc"].ToString();
  194. // if (ydDataSource.FirstOrDefault(f => f.Key == "selectField_lvc9x4vn").Value != null)
  195. // {
  196. // if (!string.IsNullOrWhiteSpace(ydDataSource["selectField_lvc9x4vn"].ToString()))
  197. // {
  198. // if (ydDataSource["selectField_lvc9x4vn"].ToString().Contains("一次性") || ydDataSource["selectField_lvc9x4vn"].ToString().Contains("工程订单"))
  199. // {
  200. // dataSource.合同业务类型 = "1001G11000000000113F";
  201. // }
  202. // else
  203. // {
  204. // var tempData = bd_defdoc_htywlx.FirstOrDefault(f => f.name == ydDataSource["selectField_lvc9x4vn"].ToString());
  205. // if (tempData != null)
  206. // {
  207. // dataSource.合同业务类型 = tempData.pk_defdoc; // 合同业务类型
  208. // }
  209. // }
  210. // }
  211. // }
  212. // dataSource.年份 = DateTime.Now.ToString("yyyy");
  213. // dataSource.月份 = DateTime.Now.ToString("MM");
  214. // #endregion
  215. // var detailList = new List<KP_SyncServiceModel.DataModel.OrderB>();
  216. // #region 大业主开票明细
  217. // if (ydDataSource.FirstOrDefault(f => f.Key == "tableField_lvc9x4vt").Value != null)
  218. // {
  219. // if (ydDataSource.FirstOrDefault(f => f.Key == "tableField_lvc9x4vt").Value != null)
  220. // {
  221. // var detailObjList1 = (List<object>)ydDataSource["tableField_lvc9x4vt"]; // 大业主开票明细
  222. // if (detailObjList1.Count() > 0 && !string.IsNullOrWhiteSpace(((Dictionary<string, object>)detailObjList1.FirstOrDefault())["textField_lvdojfup"].ToString()))
  223. // {
  224. // foreach (var objItem in detailObjList1)
  225. // {
  226. // var detailItem = new KP_SyncServiceModel.DataModel.OrderB();
  227. // if (!string.IsNullOrWhiteSpace(((Dictionary<string, object>)objItem)["associationFormField_lvynhq7p_id"].ToString()))
  228. // {
  229. // var sourceStr = ((Dictionary<string, object>)objItem)["associationFormField_lvynhq7p_id"].ToString().Replace("\\", "");
  230. // var a = sourceStr = sourceStr.Substring(1, sourceStr.Length - 2);
  231. // var b = JsonConvert.DeserializeObject<List<FormItem>>(a);
  232. // var materialData = bd_materialDic.FirstOrDefault(f => f.name == b[0].title);
  233. // detailItem.物料 = materialData.code; // 物料
  234. // var unitCode = bd_measdocDic.FirstOrDefault(f => f.pk_measdoc == materialData.pk_measdoc);
  235. // detailItem.计量单位 = unitCode.code; // 计量单位
  236. // }
  237. // var hsdj = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp2v"].ToString());
  238. // var se = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp2z"].ToString());
  239. // var wsdj = hsdj - se;
  240. // var sl = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp2w"].ToString());
  241. // var wsje = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp30"].ToString());
  242. // var jshj = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp2y"].ToString());
  243. // // 含税单价
  244. // detailItem.含税单价 = hsdj.ToString();
  245. // // 无税单价
  246. // detailItem.无税单价 = wsdj.ToString();
  247. // // 含税净价
  248. // detailItem.含税净价 = hsdj.ToString();
  249. // // 无税净价
  250. // detailItem.无税净价 = wsdj.ToString();
  251. // // 税额
  252. // detailItem.税额 = se.ToString();
  253. // // 无税金额
  254. // detailItem.无税金额 = wsje.ToString();
  255. // // 数量
  256. // detailItem.数量 = sl.ToString();
  257. // // 价税合计
  258. // detailItem.价税合计 = jshj.ToString();
  259. // detailItem.换算率 = "1.00/1.00";
  260. // detailItem.税码 = "CN04"; // 税率码
  261. // detailItem.税率 = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp2x"].ToString()).ToString(); // 税率
  262. // detailItem.开票内容 = ((Dictionary<string, object>)objItem)["textField_lvd8pp2t"].ToString();
  263. // detailItem.行id = ((Dictionary<string, object>)objItem)["textField_lvdojfup"].ToString();
  264. // detailList.Add(detailItem);
  265. // }
  266. // }
  267. // }
  268. // }
  269. // #endregion
  270. // #region 工程订单开票明细
  271. // if (ydDataSource.FirstOrDefault(f => f.Key == "tableField_lvd8pp44").Value != null)
  272. // {
  273. // var detailObjList2 = (List<object>)ydDataSource["tableField_lvd8pp44"]; // 工程订单开票明细
  274. // if (ydDataSource.FirstOrDefault(f => f.Key == "tableField_lvd8pp44").Value != null)
  275. // {
  276. // if (detailObjList2.Count() > 0 && !string.IsNullOrWhiteSpace(((Dictionary<string, object>)detailObjList2.FirstOrDefault())["textField_lvdojfur"].ToString()))
  277. // {
  278. // dataSource.项目 = "PM99001";
  279. // foreach (var objItem in detailObjList2)
  280. // {
  281. // var detailItem = new KP_SyncServiceModel.DataModel.OrderB();
  282. // if (!string.IsNullOrWhiteSpace(((Dictionary<string, object>)objItem)["associationFormField_lvynrr6a_id"].ToString()))
  283. // {
  284. // var sourceStr = ((Dictionary<string, object>)objItem)["associationFormField_lvynrr6a_id"].ToString().Replace("\\", "");
  285. // var a = sourceStr = sourceStr.Substring(1, sourceStr.Length - 2);
  286. // var b = JsonConvert.DeserializeObject<List<FormItem>>(a);
  287. // var materialData = bd_materialDic.FirstOrDefault(f => f.name == b[0].title);
  288. // detailItem.物料 = materialData.code; // 物料
  289. // var unitCode = bd_measdocDic.FirstOrDefault(f => f.pk_measdoc == materialData.pk_measdoc);
  290. // detailItem.计量单位 = unitCode.code; // 计量单位
  291. // }
  292. // var hsdj = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp3y"].ToString());
  293. // var se = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp42"].ToString());
  294. // var wsdj = hsdj - se;
  295. // var sl = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp3z"].ToString());
  296. // var wsje = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp43"].ToString());
  297. // var jshj = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp41"].ToString());
  298. // // 含税单价
  299. // detailItem.含税单价 = hsdj.ToString();
  300. // // 无税单价
  301. // detailItem.无税单价 = wsdj.ToString();
  302. // // 含税净价
  303. // detailItem.含税净价 = hsdj.ToString();
  304. // // 无税净价
  305. // detailItem.无税净价 = wsdj.ToString();
  306. // // 税额
  307. // detailItem.税额 = se.ToString();
  308. // // 无税金额
  309. // detailItem.无税金额 = wsje.ToString();
  310. // // 数量
  311. // detailItem.数量 = sl.ToString();
  312. // // 价税合计
  313. // detailItem.价税合计 = jshj.ToString();
  314. // detailItem.换算率 = "1.00/1.00";
  315. // detailItem.税码 = "CN04"; // 税率码
  316. // detailItem.税率 = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp40"].ToString()).ToString(); // 税率
  317. // detailItem.开票内容 = ((Dictionary<string, object>)objItem)["textField_lvd8pp3w"].ToString();
  318. // detailItem.行id = ((Dictionary<string, object>)objItem)["textField_lvdojfur"].ToString();
  319. // detailList.Add(detailItem);
  320. // }
  321. // }
  322. // }
  323. // }
  324. // #endregion
  325. // #region 小业主开票明细
  326. // if (ydDataSource.FirstOrDefault(f => f.Key == "tableField_lvdnme13").Value != null)
  327. // {
  328. // var detailObjList3 = (List<object>)ydDataSource["tableField_lvdnme13"]; // 小业主
  329. // if (ydDataSource.FirstOrDefault(f => f.Key == "tableField_lvdnme13").Value != null)
  330. // {
  331. // if (detailObjList3.Count() > 0 && !string.IsNullOrWhiteSpace(((Dictionary<string, object>)detailObjList3.FirstOrDefault())["textField_lvdojfus"].ToString()))
  332. // {
  333. // foreach (var objItem in detailObjList3)
  334. // {
  335. // var detailItem = new KP_SyncServiceModel.DataModel.OrderB();
  336. // if (!string.IsNullOrWhiteSpace(((Dictionary<string, object>)objItem)["associationFormField_lvynrr6c_id"].ToString()))
  337. // {
  338. // var sourceStr = ((Dictionary<string, object>)objItem)["associationFormField_lvynrr6c_id"].ToString().Replace("\\", "");
  339. // var a = sourceStr = sourceStr.Substring(1, sourceStr.Length - 2);
  340. // var b = JsonConvert.DeserializeObject<List<FormItem>>(a);
  341. // var materialData = bd_materialDic.FirstOrDefault(f => f.name == b[0].title);
  342. // detailItem.物料 = materialData.code; // 物料
  343. // var unitCode = bd_measdocDic.FirstOrDefault(f => f.pk_measdoc == materialData.pk_measdoc);
  344. // detailItem.计量单位 = unitCode.code; // 计量单位
  345. // }
  346. // var hsdj = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvdnme0w"].ToString());
  347. // var se = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvdnme10"].ToString());
  348. // var wsdj = hsdj - se;
  349. // var sl = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvdnme0x"].ToString());
  350. // var wsje = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvdnme11"].ToString());
  351. // var jshj = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvdnme0z"].ToString());
  352. // // 含税单价
  353. // detailItem.含税单价 = hsdj.ToString();
  354. // // 无税单价
  355. // detailItem.无税单价 = wsdj.ToString();
  356. // // 含税净价
  357. // detailItem.含税净价 = hsdj.ToString();
  358. // // 无税净价
  359. // detailItem.无税净价 = wsdj.ToString();
  360. // // 税额
  361. // detailItem.税额 = se.ToString();
  362. // // 无税金额
  363. // detailItem.无税金额 = wsje.ToString();
  364. // // 数量
  365. // detailItem.数量 = sl.ToString();
  366. // // 价税合计
  367. // detailItem.价税合计 = jshj.ToString();
  368. // detailItem.换算率 = "1.00/1.00";
  369. // detailItem.税码 = "CN04"; // 税率码
  370. // detailItem.税率 = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvdnme0y"].ToString()).ToString(); // 税率
  371. // detailItem.开票内容 = ((Dictionary<string, object>)objItem)["textField_lvdnme0u"].ToString();
  372. // detailItem.行id = ((Dictionary<string, object>)objItem)["textField_lvdojfus"].ToString();
  373. // detailList.Add(detailItem);
  374. // }
  375. // }
  376. // }
  377. // }
  378. // #endregion
  379. // dataSource.明细 = detailList;
  380. // dataSource.数量 = dataSource.明细.Sum(s => Convert.ToDecimal(s.数量)).ToString();
  381. // dataSource.价税合计 = dataSource.明细.Sum(s => Convert.ToDecimal(s.价税合计)).ToString();
  382. // var results_销售订单 = NCImportFunc.NCImport(KP_SyncServiceModel.ImportXml_销售订单.TemplateHeade(), KP_SyncServiceModel.ImportXml_销售订单.Header(dataSource, item + DateTime.Now.ToString("MMddHHmmss")), _NCApiUrl + "?account=LY01&groupcode=0");
  383. // LogHelper.WriteLog(JsonConvert.SerializeObject(results_销售订单), "results_销售订单");
  384. // XElement xE_销售订单 = XElement.Parse(results_销售订单);
  385. // string resultcode_销售订单 = xE_销售订单.Element("sendresult").Element("resultcode").Value;
  386. // string resultdescription_销售订单 = xE_销售订单.Element("sendresult").Element("resultdescription")?.Value;
  387. // if (resultcode_销售订单 == "1")
  388. // {
  389. // ncResData.Add(new YiDaResDto()
  390. // {
  391. // bSuccess = true,
  392. // ncNo = xE_销售订单.Element("sendresult").Element("content").Value,
  393. // log = "同步成功!"
  394. // });
  395. // }
  396. // else
  397. // {
  398. // ncResData.Add(new YiDaResDto()
  399. // {
  400. // bSuccess = false,
  401. // ncNo = "",
  402. // log = "同步失败!原因为【" + resultdescription_销售订单 + "】!"
  403. // });
  404. // continue;
  405. // }
  406. // // -------------------------------销售订单同步完,开始同步销售发票
  407. // var saleorderData = _db_nc.Queryable<so_saleorder>().First(f => f.csaleorderid == xE_销售订单.Element("sendresult").Element("content").Value);
  408. // var saleorderbData = _db_nc.Queryable<so_saleorder_b>().Where(f => f.csaleorderid == xE_销售订单.Element("sendresult").Element("content").Value).ToList();
  409. // dataSource.销售订单单据号 = saleorderData.vbillcode;
  410. // dataSource.销售订单主表id = saleorderData.csaleorderid;
  411. // foreach (var detailItem in dataSource.明细)
  412. // {
  413. // detailItem.销售订单子表id = saleorderbData.FirstOrDefault(f => f.vbdef10 == detailItem.行id).csaleorderbid;
  414. // }
  415. // var results_销售发票 = NCImportFunc.NCImport(KP_SyncServiceModel.ImportXml_销售发票.TemplateHeade(), KP_SyncServiceModel.ImportXml_销售发票.Header(dataSource, item + DateTime.Now.ToString("MMddHHmmss")), _NCApiUrl + "?account=LY01&groupcode=0");
  416. // LogHelper.WriteLog(JsonConvert.SerializeObject(results_销售发票), "results_销售发票");
  417. // XElement xE_销售发票 = XElement.Parse(results_销售发票);
  418. // string resultcode_销售发票 = xE_销售发票.Element("sendresult").Element("resultcode").Value;
  419. // string resultdescription_销售发票 = xE_销售发票.Element("sendresult").Element("resultdescription")?.Value;
  420. // if (resultcode_销售发票 == "1")
  421. // {
  422. // ncResData.Add(new YiDaResDto()
  423. // {
  424. // bSuccess = true,
  425. // ncNo = xE_销售发票.Element("sendresult").Element("content").Value,
  426. // log = "同步成功!"
  427. // });
  428. // }
  429. // else
  430. // {
  431. // ncResData.Add(new YiDaResDto()
  432. // {
  433. // bSuccess = false,
  434. // ncNo = "",
  435. // log = "同步失败!原因为【" + resultdescription_销售发票 + "】!"
  436. // });
  437. // }
  438. // // -------------------------------销售发票同步完,开始同步应收
  439. // var saleinvoicebData = _db_nc.Queryable<so_saleinvoice_b>().Where(f => f.csaleinvoiceid == xE_销售发票.Element("sendresult").Element("content").Value).ToList();
  440. // var squareinvbData = _db_nc.Queryable<so_squareinv_d>().Where(f => f.csquarebillid == xE_销售发票.Element("sendresult").Element("content").Value).ToList();
  441. // dataSource.销售发票主表id = xE_销售发票.Element("sendresult").Element("content").Value;
  442. // //foreach (var detailItem in dataSource.明细)
  443. // //{
  444. // // var a = saleinvoicebData.FirstOrDefault(f => f.vbdef10 == detailItem.行id).csaleinvoicebid;
  445. // // var b = squareinvbData.FirstOrDefault(f => f.csquarebillbid == a);
  446. // // detailItem.销售发票子表id = b.csalesquaredid;
  447. // //}
  448. // var results_应收单 = NCImportFunc.NCImport(KP_SyncServiceModel.ImportXml_应收单.TemplateHeade(), KP_SyncServiceModel.ImportXml_应收单.Header(dataSource, item + "02"), _NCApiUrl + "?account=01&groupcode=0");
  449. // LogHelper.WriteLog(JsonConvert.SerializeObject(results_应收单), "results_应收单");
  450. // XElement xE_应收单 = XElement.Parse(results_应收单);
  451. // string resultcode_应收单 = xE_应收单.Element("sendresult").Element("resultcode").Value;
  452. // string resultdescription_应收单 = xE_应收单.Element("sendresult").Element("resultdescription")?.Value;
  453. // var recitemData = _db_nc.Queryable<ar_recitem>().Where(w => w.pk_recbill == xE_应收单.Element("sendresult").Element("content").Value).ToList();
  454. // foreach (var recitem in recitemData)
  455. // {
  456. // recitem.scomment = recitem.def1;
  457. // _db_nc.Updateable(recitem).ExecuteCommand();
  458. // }
  459. // if (resultcode_应收单 == "1")
  460. // {
  461. // ncResData.Add(new YiDaResDto()
  462. // {
  463. // bSuccess = true,
  464. // ncNo = xE_应收单.Element("sendresult").Element("content").Value,
  465. // log = "同步成功!"
  466. // });
  467. // }
  468. // else
  469. // {
  470. // ncResData.Add(new YiDaResDto()
  471. // {
  472. // bSuccess = false,
  473. // ncNo = "",
  474. // log = "同步失败!原因为【" + resultdescription_应收单 + "】!"
  475. // });
  476. // }
  477. // var finalResData = new YiDaResDto();
  478. // if (ncResData.FirstOrDefault(f => !f.bSuccess) != null)
  479. // {
  480. // finalResData.bSuccess = false;
  481. // finalResData.syncTime = DateTime.Now;
  482. // finalResData.ncNo = xE_销售订单.Element("sendresult").Element("content").Value;
  483. // finalResData.log = string.Join(" || ", ncResData.Select(s => s.log));
  484. // }
  485. // else
  486. // {
  487. // finalResData.bSuccess = true;
  488. // finalResData.syncTime = DateTime.Now;
  489. // finalResData.ncNo = xE_销售订单.Element("sendresult").Element("content").Value;
  490. // finalResData.log = string.Join(" || ", ncResData.Select(s => s.log));
  491. // }
  492. // var ydRes = _dingTalkService.UpdateFormDataSyncDataById(finalResData, item);
  493. //}
  494. //#endregion
  495. }
  496. }
  497. }