KP_SyncService.cs 29 KB

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