KP_TP_SyncService.cs 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597
  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_TP_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_TP_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. 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. // 如果NC单据号不为空,说明正数发票及销售订单已经传入NC,此时按照此流程传输红票
  75. if (ydDataSource.FirstOrDefault(f => f.Key == "textField_ltxyt75m").Value != null && !string.IsNullOrWhiteSpace(ydDataSource["textField_ltxyt75m"].ToString()))
  76. {
  77. }
  78. else
  79. {
  80. continue;
  81. }
  82. var ncResData = new List<YiDaResDto>();
  83. LogHelper.WriteLog(JsonConvert.SerializeObject("1"), "1");
  84. #region 表头
  85. // 表头
  86. var dataSource = new KP_SyncServiceModel.DataModel();
  87. if (ydDataSource.FirstOrDefault(f => f.Key == "selectField_lvc9x4vo").Value != null)
  88. {
  89. if (!string.IsNullOrWhiteSpace(ydDataSource["selectField_lvc9x4vo"].ToString()))
  90. {
  91. var tempData = org_orgsDic.FirstOrDefault(f => f.name == ydDataSource["selectField_lvc9x4vo"].ToString());
  92. if (tempData != null)
  93. {
  94. dataSource.组织 = tempData.code; // 组织
  95. }
  96. }
  97. }
  98. LogHelper.WriteLog("2", "状态log");
  99. dataSource.单据日期 = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  100. //if (!string.IsNullOrWhiteSpace(ydDataSource["dateField_lw5ud9bk"].ToString()))
  101. //{
  102. // dataSource.单据日期 = UnixTimeHelper.ConvertMillisecondsToDateTime(Convert.ToInt64(ydDataSource["dateField_lw5ud9bk"].ToString())).ToString("yyyy-MM-dd HH:mm:ss");
  103. //}
  104. if (ydDataSource.FirstOrDefault(f => f.Key == "textField_lvdojfuj").Value != null)
  105. {
  106. if (!string.IsNullOrWhiteSpace(ydDataSource["textField_lvdojfuj"].ToString()))
  107. {
  108. var tempData = bd_customerDic.FirstOrDefault(f => f.code == ydDataSource["textField_lvdojfuj"].ToString());
  109. if (tempData != null)
  110. {
  111. dataSource.客户 = tempData.code; // 客户
  112. }
  113. }
  114. }
  115. if (ydDataSource.FirstOrDefault(f => f.Key == "selectField_lvc9x4vq").Value != null)
  116. {
  117. if (!string.IsNullOrWhiteSpace(ydDataSource["selectField_lvc9x4vq"].ToString()))
  118. {
  119. var tempData = bd_incomeDic.FirstOrDefault(f => f.name == ydDataSource["selectField_lvc9x4vq"].ToString());
  120. if (tempData != null)
  121. {
  122. dataSource.收款协议 = tempData.code; // 收款协议
  123. }
  124. }
  125. }
  126. if (ydDataSource.FirstOrDefault(f => f.Key == "departmentSelectField_lvc7mi3w").Value != null)
  127. {
  128. if (!string.IsNullOrWhiteSpace(ydDataSource["departmentSelectField_lvc7mi3w"].ToString()))
  129. {
  130. var tempData = org_deptDic.FirstOrDefault(f => f.name == JsonConvert.DeserializeObject<List<string>>(JsonConvert.SerializeObject(ydDataSource["departmentSelectField_lvc7mi3w"]))[0]);
  131. if (tempData != null)
  132. {
  133. dataSource.部门 = tempData.code; // 部门
  134. }
  135. }
  136. }
  137. LogHelper.WriteLog("3", "状态log");
  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_lwsth4o3"].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. LogHelper.WriteLog("4", "状态log");
  178. dataSource.OA单据号 = ydDataSource["textField_lvdosccc"].ToString();
  179. if (ydDataSource.FirstOrDefault(f => f.Key == "selectField_lvc9x4vn").Value != null)
  180. {
  181. if (!string.IsNullOrWhiteSpace(ydDataSource["selectField_lvc9x4vn"].ToString()))
  182. {
  183. if (ydDataSource["selectField_lvc9x4vn"].ToString().Contains("一次性") || ydDataSource["selectField_lvc9x4vn"].ToString().Contains("工程订单"))
  184. {
  185. dataSource.合同业务类型 = "1001G11000000000113F";
  186. }
  187. else
  188. {
  189. var tempData = bd_defdoc_htywlx.FirstOrDefault(f => f.name == ydDataSource["selectField_lvc9x4vn"].ToString());
  190. if (tempData != null)
  191. {
  192. dataSource.合同业务类型 = tempData.pk_defdoc; // 合同业务类型
  193. }
  194. }
  195. }
  196. }
  197. LogHelper.WriteLog("5", "状态log");
  198. dataSource.年份 = DateTime.Now.ToString("yyyy");
  199. dataSource.月份 = DateTime.Now.ToString("MM");
  200. #endregion
  201. var detailList = new List<KP_SyncServiceModel.DataModel.OrderB>();
  202. #region 大业主开票明细
  203. if (ydDataSource.FirstOrDefault(f => f.Key == "tableField_lvc9x4vt").Value != null)
  204. {
  205. if (ydDataSource.FirstOrDefault(f => f.Key == "tableField_lvc9x4vt").Value != null)
  206. {
  207. var detailObjList1 = (List<object>)ydDataSource["tableField_lvc9x4vt"]; // 大业主开票明细
  208. if (detailObjList1.Count() > 0 && !string.IsNullOrWhiteSpace(((Dictionary<string, object>)detailObjList1.FirstOrDefault())["textField_lvdojfup"].ToString()))
  209. {
  210. foreach (var objItem in detailObjList1)
  211. {
  212. var detailItem = new KP_SyncServiceModel.DataModel.OrderB();
  213. if (!string.IsNullOrWhiteSpace(((Dictionary<string, object>)objItem)["associationFormField_lvynhq7p_id"].ToString()))
  214. {
  215. var sourceStr = ((Dictionary<string, object>)objItem)["associationFormField_lvynhq7p_id"].ToString().Replace("\\", "");
  216. var a = sourceStr = sourceStr.Substring(1, sourceStr.Length - 2);
  217. var b = JsonConvert.DeserializeObject<List<FormItem>>(a);
  218. var materialData = bd_materialDic.FirstOrDefault(f => f.name == b[0].title);
  219. detailItem.物料 = materialData.code; // 物料
  220. var unitCode = bd_measdocDic.FirstOrDefault(f => f.pk_measdoc == materialData.pk_measdoc);
  221. detailItem.计量单位 = unitCode.code; // 计量单位
  222. }
  223. var hsdj = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp2v"].ToString());
  224. var se = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp2z"].ToString());
  225. var wsdj = hsdj - se;
  226. var sl = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp2w"].ToString());
  227. var wsje = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp30"].ToString());
  228. var jshj = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp2y"].ToString());
  229. // 含税单价
  230. detailItem.含税单价 = hsdj.ToString();
  231. // 无税单价
  232. detailItem.无税单价 = wsdj.ToString();
  233. // 含税净价
  234. detailItem.含税净价 = hsdj.ToString();
  235. // 无税净价
  236. detailItem.无税净价 = wsdj.ToString();
  237. // 税额
  238. detailItem.税额 = se.ToString();
  239. // 无税金额
  240. detailItem.无税金额 = wsje.ToString();
  241. // 数量
  242. detailItem.数量 = sl.ToString();
  243. // 价税合计
  244. detailItem.价税合计 = jshj.ToString();
  245. detailItem.换算率 = "1.00/1.00";
  246. detailItem.税码 = "CN04"; // 税率码
  247. detailItem.税率 = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp2x"].ToString()).ToString(); // 税率
  248. detailItem.开票内容 = ((Dictionary<string, object>)objItem)["textField_lvd8pp2t"].ToString();
  249. detailItem.行id = ((Dictionary<string, object>)objItem)["textField_lvdojfup"].ToString();
  250. detailList.Add(detailItem);
  251. }
  252. }
  253. }
  254. }
  255. #endregion
  256. #region 工程订单开票明细
  257. if (ydDataSource.FirstOrDefault(f => f.Key == "tableField_lvd8pp44").Value != null)
  258. {
  259. var detailObjList2 = (List<object>)ydDataSource["tableField_lvd8pp44"]; // 工程订单开票明细
  260. if (ydDataSource.FirstOrDefault(f => f.Key == "tableField_lvd8pp44").Value != null)
  261. {
  262. if (detailObjList2.Count() > 0 && !string.IsNullOrWhiteSpace(((Dictionary<string, object>)detailObjList2.FirstOrDefault())["textField_lvdojfur"].ToString()))
  263. {
  264. dataSource.项目 = "PM99001";
  265. foreach (var objItem in detailObjList2)
  266. {
  267. var detailItem = new KP_SyncServiceModel.DataModel.OrderB();
  268. if (!string.IsNullOrWhiteSpace(((Dictionary<string, object>)objItem)["associationFormField_lvynrr6a_id"].ToString()))
  269. {
  270. var sourceStr = ((Dictionary<string, object>)objItem)["associationFormField_lvynrr6a_id"].ToString().Replace("\\", "");
  271. var a = sourceStr = sourceStr.Substring(1, sourceStr.Length - 2);
  272. var b = JsonConvert.DeserializeObject<List<FormItem>>(a);
  273. var materialData = bd_materialDic.FirstOrDefault(f => f.name == b[0].title);
  274. detailItem.物料 = materialData.code; // 物料
  275. var unitCode = bd_measdocDic.FirstOrDefault(f => f.pk_measdoc == materialData.pk_measdoc);
  276. detailItem.计量单位 = unitCode.code; // 计量单位
  277. }
  278. var hsdj = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp3y"].ToString());
  279. var se = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp42"].ToString());
  280. var wsdj = hsdj - se;
  281. var sl = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp3z"].ToString());
  282. var wsje = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp43"].ToString());
  283. var jshj = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp41"].ToString());
  284. // 含税单价
  285. detailItem.含税单价 = hsdj.ToString();
  286. // 无税单价
  287. detailItem.无税单价 = wsdj.ToString();
  288. // 含税净价
  289. detailItem.含税净价 = hsdj.ToString();
  290. // 无税净价
  291. detailItem.无税净价 = wsdj.ToString();
  292. // 税额
  293. detailItem.税额 = se.ToString();
  294. // 无税金额
  295. detailItem.无税金额 = wsje.ToString();
  296. // 数量
  297. detailItem.数量 = sl.ToString();
  298. // 价税合计
  299. detailItem.价税合计 = jshj.ToString();
  300. detailItem.换算率 = "1.00/1.00";
  301. detailItem.税码 = "CN04"; // 税率码
  302. detailItem.税率 = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp40"].ToString()).ToString(); // 税率
  303. detailItem.开票内容 = ((Dictionary<string, object>)objItem)["textField_lvd8pp3w"].ToString();
  304. detailItem.行id = ((Dictionary<string, object>)objItem)["textField_lvdojfur"].ToString();
  305. detailList.Add(detailItem);
  306. }
  307. }
  308. }
  309. }
  310. #endregion
  311. #region 小业主开票明细
  312. if (ydDataSource.FirstOrDefault(f => f.Key == "tableField_lvdnme13").Value != null)
  313. {
  314. var detailObjList3 = (List<object>)ydDataSource["tableField_lvdnme13"]; // 小业主
  315. if (ydDataSource.FirstOrDefault(f => f.Key == "tableField_lvdnme13").Value != null)
  316. {
  317. if (detailObjList3.Count() > 0 && !string.IsNullOrWhiteSpace(((Dictionary<string, object>)detailObjList3.FirstOrDefault())["textField_lvdojfus"].ToString()))
  318. {
  319. foreach (var objItem in detailObjList3)
  320. {
  321. var detailItem = new KP_SyncServiceModel.DataModel.OrderB();
  322. if (!string.IsNullOrWhiteSpace(((Dictionary<string, object>)objItem)["associationFormField_lvynrr6c_id"].ToString()))
  323. {
  324. var sourceStr = ((Dictionary<string, object>)objItem)["associationFormField_lvynrr6c_id"].ToString().Replace("\\", "");
  325. var a = sourceStr = sourceStr.Substring(1, sourceStr.Length - 2);
  326. var b = JsonConvert.DeserializeObject<List<FormItem>>(a);
  327. var materialData = bd_materialDic.FirstOrDefault(f => f.name == b[0].title);
  328. detailItem.物料 = materialData.code; // 物料
  329. var unitCode = bd_measdocDic.FirstOrDefault(f => f.pk_measdoc == materialData.pk_measdoc);
  330. detailItem.计量单位 = unitCode.code; // 计量单位
  331. }
  332. var hsdj = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvdnme0w"].ToString());
  333. var se = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvdnme10"].ToString());
  334. var wsdj = hsdj - se;
  335. var sl = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvdnme0x"].ToString());
  336. var wsje = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvdnme11"].ToString());
  337. var jshj = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvdnme0z"].ToString());
  338. // 含税单价
  339. detailItem.含税单价 = hsdj.ToString();
  340. // 无税单价
  341. detailItem.无税单价 = wsdj.ToString();
  342. // 含税净价
  343. detailItem.含税净价 = hsdj.ToString();
  344. // 无税净价
  345. detailItem.无税净价 = wsdj.ToString();
  346. // 税额
  347. detailItem.税额 = se.ToString();
  348. // 无税金额
  349. detailItem.无税金额 = wsje.ToString();
  350. // 数量
  351. detailItem.数量 = sl.ToString();
  352. // 价税合计
  353. detailItem.价税合计 = jshj.ToString();
  354. detailItem.换算率 = "1.00/1.00";
  355. detailItem.税码 = "CN04"; // 税率码
  356. detailItem.税率 = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvdnme0y"].ToString()).ToString(); // 税率
  357. detailItem.开票内容 = ((Dictionary<string, object>)objItem)["textField_lvdnme0u"].ToString();
  358. detailItem.行id = ((Dictionary<string, object>)objItem)["textField_lvdojfus"].ToString();
  359. detailList.Add(detailItem);
  360. }
  361. }
  362. }
  363. }
  364. #endregion
  365. LogHelper.WriteLog("6", "状态log");
  366. var 旧发票号 = ydDataSource["textField_lvd8pp35"].ToString();
  367. var 新发票号 = ydDataSource["textField_lwsth4o3"].ToString();
  368. foreach (var detailItem in detailList)
  369. {
  370. // 替换明细中,开票内容字段中的发票号
  371. detailItem.开票内容 = detailItem.开票内容.Replace(旧发票号, 新发票号);
  372. // 将金额和数量都改为负数
  373. detailItem.数量 = "-" + detailItem.数量;
  374. detailItem.含税单价 = "-" + detailItem.含税单价;
  375. detailItem.无税单价 = "-" + detailItem.无税单价;
  376. detailItem.含税净价 = "-" + detailItem.含税净价;
  377. detailItem.无税净价 = "-" + detailItem.无税净价;
  378. detailItem.税额 = "-" + detailItem.税额;
  379. detailItem.无税金额 = "-" + detailItem.无税金额;
  380. detailItem.价税合计 = "-" + detailItem.价税合计;
  381. }
  382. dataSource.明细 = detailList;
  383. dataSource.数量 = dataSource.明细.Sum(s => Convert.ToDecimal(s.数量)).ToString();
  384. dataSource.价税合计 = dataSource.明细.Sum(s => Convert.ToDecimal(s.价税合计)).ToString();
  385. // 销售订单主表id
  386. var csaleorderid = ydDataSource["textField_ltxyt75m"].ToString();
  387. LogHelper.WriteLog("7", "状态log");
  388. // -------------------------------销售订单同步完,开始同步销售发票
  389. var saleorderData = _db_nc.Queryable<so_saleorder>().First(f => f.csaleorderid == csaleorderid);
  390. LogHelper.WriteLog(JsonConvert.SerializeObject(saleorderData), "saleorderData");
  391. var saleorderbData = _db_nc.Queryable<so_saleorder_b>().Where(f => f.csaleorderid == csaleorderid).ToList();
  392. LogHelper.WriteLog(JsonConvert.SerializeObject(saleorderbData), "saleorderbData");
  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. LogHelper.WriteLog(JsonConvert.SerializeObject("8"), "8");
  400. var results_销售发票 = NCImportFunc.NCImport(KP_SyncServiceModel.ImportXml_销售发票.TemplateHeade(), KP_SyncServiceModel.ImportXml_销售发票.Header(dataSource, item + "_tp"), _NCApiUrl + "?account=LY01&groupcode=0");
  401. LogHelper.WriteLog(JsonConvert.SerializeObject(results_销售发票), "results_销售发票");
  402. XElement xE_销售发票 = XElement.Parse(results_销售发票);
  403. string resultcode_销售发票 = xE_销售发票.Element("sendresult").Element("resultcode").Value;
  404. string resultdescription_销售发票 = xE_销售发票.Element("sendresult").Element("resultdescription")?.Value;
  405. if (resultcode_销售发票 == "1")
  406. {
  407. ncResData.Add(new YiDaResDto()
  408. {
  409. bSuccess = true,
  410. ncNo = xE_销售发票.Element("sendresult").Element("content").Value,
  411. log = "同步成功!"
  412. });
  413. }
  414. else
  415. {
  416. ncResData.Add(new YiDaResDto()
  417. {
  418. bSuccess = false,
  419. ncNo = "",
  420. log = "同步失败!原因为【" + resultdescription_销售发票 + "】!"
  421. });
  422. }
  423. // -------------------------------销售发票同步完,开始同步应收 (新版)应收不同步,改为调用审核接口,让NC自动取生成应收单
  424. var results_销售发票审核 = HttpRequestHelper.ApporeNCCSOBill(xE_销售发票.Element("sendresult").Element("content").Value);
  425. LogHelper.WriteLog(JsonConvert.SerializeObject(results_销售发票审核), "results_销售发票审核");
  426. if (results_销售发票审核.state == 0)
  427. {
  428. ncResData.Add(new YiDaResDto()
  429. {
  430. bSuccess = true,
  431. ncNo = "",
  432. log = "同步成功!"
  433. });
  434. }
  435. else
  436. {
  437. ncResData.Add(new YiDaResDto()
  438. {
  439. bSuccess = false,
  440. ncNo = "",
  441. log = "同步失败!原因为【" + results_销售发票审核.msg + "】!"
  442. });
  443. }
  444. var finalResData = new YiDaResDto();
  445. if (ncResData.FirstOrDefault(f => !f.bSuccess) != null)
  446. {
  447. finalResData.bSuccess = false;
  448. finalResData.syncTime = DateTime.Now;
  449. finalResData.ncNo = csaleorderid;
  450. finalResData.log = string.Join(" || ", ncResData.Select(s => s.log));
  451. }
  452. else
  453. {
  454. finalResData.bSuccess = true;
  455. finalResData.syncTime = DateTime.Now;
  456. finalResData.ncNo = csaleorderid;
  457. finalResData.log = string.Join(" || ", ncResData.Select(s => s.log));
  458. }
  459. var ydRes = _dingTalkService.UpdateFormDataSyncDataById(finalResData, item);
  460. }
  461. #endregion
  462. }
  463. }
  464. }