BZJ_SyncService.cs 30 KB

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