KP_SyncService.cs 30 KB

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