KP_SyncService.cs 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606
  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. LogHelper.WriteLog(JsonConvert.SerializeObject(detailObjList1.FirstOrDefault()), "大业主0");
  202. if (detailObjList1.Count() > 0 && !string.IsNullOrWhiteSpace(((Dictionary<string, object>)detailObjList1.FirstOrDefault())["textField_lvdojfup"].ToString())
  203. && !string.IsNullOrWhiteSpace(((Dictionary<string, object>)detailObjList1.FirstOrDefault())["textField_lvynhq7q"].ToString()))
  204. {
  205. LogHelper.WriteLog(JsonConvert.SerializeObject(dataSource), "大业主1");
  206. foreach (var objItem in detailObjList1)
  207. {
  208. var detailItem = new KP_SyncServiceModel.DataModel.OrderB();
  209. if (!string.IsNullOrWhiteSpace(((Dictionary<string, object>)objItem)["associationFormField_lvynhq7p_id"].ToString()))
  210. {
  211. var sourceStr = ((Dictionary<string, object>)objItem)["associationFormField_lvynhq7p_id"].ToString().Replace("\\", "");
  212. var a = sourceStr = sourceStr.Substring(1, sourceStr.Length - 2);
  213. var b = JsonConvert.DeserializeObject<List<FormItem>>(a);
  214. var materialData = bd_materialDic.FirstOrDefault(f => f.name == b[0].title);
  215. detailItem.物料 = materialData.code; // 物料
  216. var unitCode = bd_measdocDic.FirstOrDefault(f => f.pk_measdoc == materialData.pk_measdoc);
  217. detailItem.计量单位 = unitCode.code; // 计量单位
  218. }
  219. var hsdj = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp2v"].ToString());
  220. var se = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp2z"].ToString());
  221. var wsdj = hsdj - se;
  222. var sl = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp2w"].ToString());
  223. var wsje = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp30"].ToString());
  224. var jshj = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp2y"].ToString());
  225. // 含税单价
  226. detailItem.含税单价 = hsdj.ToString();
  227. // 无税单价
  228. detailItem.无税单价 = wsdj.ToString();
  229. // 含税净价
  230. detailItem.含税净价 = hsdj.ToString();
  231. // 无税净价
  232. detailItem.无税净价 = wsdj.ToString();
  233. // 税额
  234. detailItem.税额 = se.ToString();
  235. // 无税金额
  236. detailItem.无税金额 = wsje.ToString();
  237. // 数量
  238. detailItem.数量 = sl.ToString();
  239. // 价税合计
  240. detailItem.价税合计 = jshj.ToString();
  241. detailItem.换算率 = "1.00/1.00";
  242. detailItem.税码 = ydDataSource["selectField_lvc9x4vp"].ToString() == "增值税普票" ? "CN11" : "CN04"; // 税率码
  243. detailItem.税率 = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp2x"].ToString()).ToString(); // 税率
  244. detailItem.开票内容 = ((Dictionary<string, object>)objItem)["textField_lvd8pp2t"].ToString();
  245. detailItem.行id = ((Dictionary<string, object>)objItem)["textField_lvdojfup"].ToString();
  246. detailList.Add(detailItem);
  247. }
  248. }
  249. }
  250. }
  251. #endregion
  252. #region 工程订单开票明细
  253. if (ydDataSource.FirstOrDefault(f => f.Key == "tableField_lvd8pp44").Value != null)
  254. {
  255. var detailObjList2 = (List<object>)ydDataSource["tableField_lvd8pp44"]; // 工程订单开票明细
  256. if (ydDataSource.FirstOrDefault(f => f.Key == "tableField_lvd8pp44").Value != null)
  257. {
  258. LogHelper.WriteLog(JsonConvert.SerializeObject(detailObjList2.FirstOrDefault()), "gc0");
  259. if (detailObjList2.Count() > 0 && !string.IsNullOrWhiteSpace(((Dictionary<string, object>)detailObjList2.FirstOrDefault())["textField_lvdojfur"].ToString())
  260. && !string.IsNullOrWhiteSpace(((Dictionary<string, object>)detailObjList2.FirstOrDefault())["numberField_lvd8pp3y_value"].ToString()))
  261. {
  262. LogHelper.WriteLog(JsonConvert.SerializeObject(detailObjList2.FirstOrDefault()), "gc1");
  263. dataSource.项目 = "PM99001";
  264. foreach (var objItem in detailObjList2)
  265. {
  266. var detailItem = new KP_SyncServiceModel.DataModel.OrderB();
  267. if (!string.IsNullOrWhiteSpace(((Dictionary<string, object>)objItem)["associationFormField_lvynrr6a_id"].ToString()))
  268. {
  269. var sourceStr = ((Dictionary<string, object>)objItem)["associationFormField_lvynrr6a_id"].ToString().Replace("\\", "");
  270. var a = sourceStr = sourceStr.Substring(1, sourceStr.Length - 2);
  271. var b = JsonConvert.DeserializeObject<List<FormItem>>(a);
  272. var materialData = bd_materialDic.FirstOrDefault(f => f.name == b[0].title);
  273. detailItem.物料 = materialData.code; // 物料
  274. var unitCode = bd_measdocDic.FirstOrDefault(f => f.pk_measdoc == materialData.pk_measdoc);
  275. detailItem.计量单位 = unitCode.code; // 计量单位
  276. }
  277. var hsdj = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp3y"].ToString());
  278. var se = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp42"].ToString());
  279. var wsdj = hsdj - se;
  280. var sl = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp3z"].ToString());
  281. var wsje = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp43"].ToString());
  282. var jshj = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp41"].ToString());
  283. // 含税单价
  284. detailItem.含税单价 = hsdj.ToString();
  285. // 无税单价
  286. detailItem.无税单价 = wsdj.ToString();
  287. // 含税净价
  288. detailItem.含税净价 = hsdj.ToString();
  289. // 无税净价
  290. detailItem.无税净价 = wsdj.ToString();
  291. // 税额
  292. detailItem.税额 = se.ToString();
  293. // 无税金额
  294. detailItem.无税金额 = wsje.ToString();
  295. // 数量
  296. detailItem.数量 = sl.ToString();
  297. // 价税合计
  298. detailItem.价税合计 = jshj.ToString();
  299. detailItem.换算率 = "1.00/1.00";
  300. detailItem.税码 = ydDataSource["selectField_lvc9x4vp"].ToString() == "增值税普票" ? "CN11" : "CN04"; // 税率码
  301. detailItem.税率 = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp40"].ToString()).ToString(); // 税率
  302. detailItem.开票内容 = ((Dictionary<string, object>)objItem)["textField_lvd8pp3w"].ToString();
  303. detailItem.行id = ((Dictionary<string, object>)objItem)["textField_lvdojfur"].ToString();
  304. detailList.Add(detailItem);
  305. }
  306. }
  307. }
  308. }
  309. #endregion
  310. #region 小业主开票明细
  311. if (ydDataSource.FirstOrDefault(f => f.Key == "tableField_lvdnme13").Value != null)
  312. {
  313. var detailObjList3 = (List<object>)ydDataSource["tableField_lvdnme13"]; // 小业主
  314. if (ydDataSource.FirstOrDefault(f => f.Key == "tableField_lvdnme13").Value != null)
  315. {
  316. LogHelper.WriteLog(JsonConvert.SerializeObject(detailObjList3.FirstOrDefault()), "x0");
  317. if (detailObjList3.Count() > 0 && !string.IsNullOrWhiteSpace(((Dictionary<string, object>)detailObjList3.FirstOrDefault())["textField_lvdojfus"].ToString())
  318. && !string.IsNullOrWhiteSpace(((Dictionary<string, object>)detailObjList3.FirstOrDefault())["numberField_lvdnme0w_value"].ToString()))
  319. {
  320. LogHelper.WriteLog(JsonConvert.SerializeObject(detailObjList3.FirstOrDefault()), "x1");
  321. foreach (var objItem in detailObjList3)
  322. {
  323. var detailItem = new KP_SyncServiceModel.DataModel.OrderB();
  324. if (!string.IsNullOrWhiteSpace(((Dictionary<string, object>)objItem)["associationFormField_lvynrr6c_id"].ToString()))
  325. {
  326. var sourceStr = ((Dictionary<string, object>)objItem)["associationFormField_lvynrr6c_id"].ToString().Replace("\\", "");
  327. var a = sourceStr = sourceStr.Substring(1, sourceStr.Length - 2);
  328. var b = JsonConvert.DeserializeObject<List<FormItem>>(a);
  329. var materialData = bd_materialDic.FirstOrDefault(f => f.name == b[0].title);
  330. detailItem.物料 = materialData.code; // 物料
  331. var unitCode = bd_measdocDic.FirstOrDefault(f => f.pk_measdoc == materialData.pk_measdoc);
  332. detailItem.计量单位 = unitCode.code; // 计量单位
  333. }
  334. var hsdj = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvdnme0w"].ToString());
  335. var se = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvdnme10"].ToString());
  336. var wsdj = hsdj - se;
  337. var sl = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvdnme0x"].ToString());
  338. var wsje = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvdnme11"].ToString());
  339. var jshj = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvdnme0z"].ToString());
  340. // 含税单价
  341. detailItem.含税单价 = hsdj.ToString();
  342. // 无税单价
  343. detailItem.无税单价 = wsdj.ToString();
  344. // 含税净价
  345. detailItem.含税净价 = hsdj.ToString();
  346. // 无税净价
  347. detailItem.无税净价 = wsdj.ToString();
  348. // 税额
  349. detailItem.税额 = se.ToString();
  350. // 无税金额
  351. detailItem.无税金额 = wsje.ToString();
  352. // 数量
  353. detailItem.数量 = sl.ToString();
  354. // 价税合计
  355. detailItem.价税合计 = jshj.ToString();
  356. detailItem.换算率 = "1.00/1.00";
  357. detailItem.税码 = ydDataSource["selectField_lvc9x4vp"].ToString() == "增值税普票" ? "CN11" : "CN04"; // 税率码
  358. detailItem.税率 = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvdnme0y"].ToString()).ToString(); // 税率
  359. detailItem.开票内容 = ((Dictionary<string, object>)objItem)["textField_lvdnme0u"].ToString();
  360. detailItem.行id = ((Dictionary<string, object>)objItem)["textField_lvdojfus"].ToString();
  361. detailList.Add(detailItem);
  362. }
  363. }
  364. }
  365. }
  366. #endregion
  367. dataSource.明细 = detailList;
  368. dataSource.数量 = dataSource.明细.Sum(s => Convert.ToDecimal(s.数量)).ToString();
  369. dataSource.价税合计 = dataSource.明细.Sum(s => Convert.ToDecimal(s.价税合计)).ToString();
  370. var results_销售订单 = NCImportFunc.NCImport(KP_SyncServiceModel.ImportXml_销售订单.TemplateHeade(), KP_SyncServiceModel.ImportXml_销售订单.Header(dataSource, item + DateTime.Now.ToString("MMddHHmmss")), _NCApiUrl + "?account=LY01&groupcode=0");
  371. LogHelper.WriteLog(JsonConvert.SerializeObject(results_销售订单), "results_销售订单");
  372. XElement xE_销售订单 = XElement.Parse(results_销售订单);
  373. string resultcode_销售订单 = xE_销售订单.Element("sendresult").Element("resultcode").Value;
  374. string resultdescription_销售订单 = xE_销售订单.Element("sendresult").Element("resultdescription")?.Value;
  375. if (resultcode_销售订单 == "1")
  376. {
  377. ncResData.Add(new YiDaResDto()
  378. {
  379. bSuccess = true,
  380. ncNo = xE_销售订单.Element("sendresult").Element("content").Value,
  381. log = "同步成功!"
  382. });
  383. }
  384. else
  385. {
  386. ncResData.Add(new YiDaResDto()
  387. {
  388. bSuccess = false,
  389. ncNo = "",
  390. log = "同步失败!原因为【" + resultdescription_销售订单 + "】!"
  391. });
  392. continue;
  393. }
  394. // -------------------------------销售订单同步完,开始同步销售发票
  395. var saleorderData = _db_nc.Queryable<so_saleorder>().First(f => f.csaleorderid == xE_销售订单.Element("sendresult").Element("content").Value);
  396. var saleorderbData = _db_nc.Queryable<so_saleorder_b>().Where(f => f.csaleorderid == xE_销售订单.Element("sendresult").Element("content").Value).ToList();
  397. dataSource.销售订单单据号 = saleorderData.vbillcode;
  398. dataSource.销售订单主表id = saleorderData.csaleorderid;
  399. foreach (var detailItem in dataSource.明细)
  400. {
  401. detailItem.销售订单子表id = saleorderbData.FirstOrDefault(f => f.vbdef10 == detailItem.行id).csaleorderbid;
  402. }
  403. var results_销售发票 = NCImportFunc.NCImport(KP_SyncServiceModel.ImportXml_销售发票.TemplateHeade(), KP_SyncServiceModel.ImportXml_销售发票.Header(dataSource, item + DateTime.Now.ToString("MMddHHmmss")), _NCApiUrl + "?account=LY01&groupcode=0");
  404. LogHelper.WriteLog(JsonConvert.SerializeObject(results_销售发票), "results_销售发票");
  405. XElement xE_销售发票 = XElement.Parse(results_销售发票);
  406. string resultcode_销售发票 = xE_销售发票.Element("sendresult").Element("resultcode").Value;
  407. string resultdescription_销售发票 = xE_销售发票.Element("sendresult").Element("resultdescription")?.Value;
  408. if (resultcode_销售发票 == "1")
  409. {
  410. ncResData.Add(new YiDaResDto()
  411. {
  412. bSuccess = true,
  413. ncNo = xE_销售发票.Element("sendresult").Element("content").Value,
  414. log = "同步成功!"
  415. });
  416. }
  417. else
  418. {
  419. ncResData.Add(new YiDaResDto()
  420. {
  421. bSuccess = false,
  422. ncNo = "",
  423. log = "同步失败!原因为【" + resultdescription_销售发票 + "】!"
  424. });
  425. }
  426. // -------------------------------销售发票同步完,开始同步应收 (新版)应收不同步,改为调用审核接口,让NC自动取生成应收单
  427. var results_销售发票审核 = HttpRequestHelper.ApporeNCCSOBill(xE_销售发票.Element("sendresult").Element("content").Value);
  428. LogHelper.WriteLog(JsonConvert.SerializeObject(results_销售发票审核), "results_销售发票审核");
  429. if (results_销售发票审核.state == 0)
  430. {
  431. ncResData.Add(new YiDaResDto()
  432. {
  433. bSuccess = true,
  434. ncNo = "",
  435. log = "同步成功!"
  436. });
  437. if (ydDataSource["selectField_lvc9x4vp"].ToString() == "增值税普票")
  438. {
  439. _db_nc.Ado.ExecuteCommand($"UPDATE SO_SALEINVOICE SET VTRANTYPECODE='32-Cxx-01',CTRANTYPEID='1001G11000000000036J' WHERE CSALEINVOICEID='{xE_销售发票.Element("sendresult").Element("content").Value}'");
  440. LogHelper.WriteLog("执行更新sql", "results_销售发票");
  441. }
  442. }
  443. else
  444. {
  445. ncResData.Add(new YiDaResDto()
  446. {
  447. bSuccess = false,
  448. ncNo = "",
  449. log = "同步失败!原因为【" + results_销售发票审核.msg + "】!"
  450. });
  451. }
  452. var finalResData = new YiDaResDto();
  453. if (ncResData.FirstOrDefault(f => !f.bSuccess) != null)
  454. {
  455. finalResData.bSuccess = false;
  456. finalResData.syncTime = DateTime.Now;
  457. finalResData.ncNo = xE_销售订单.Element("sendresult").Element("content").Value;
  458. finalResData.log = string.Join(" || ", ncResData.Select(s => s.log));
  459. }
  460. else
  461. {
  462. finalResData.bSuccess = true;
  463. finalResData.syncTime = DateTime.Now;
  464. finalResData.ncNo = xE_销售订单.Element("sendresult").Element("content").Value;
  465. finalResData.log = string.Join(" || ", ncResData.Select(s => s.log));
  466. }
  467. if (ydDataSource["selectField_lvituew9"].ToString() == "已红冲" && finalResData.bSuccess)
  468. {
  469. finalResData.bNeedSync = "Y";
  470. }
  471. var ydRes = _dingTalkService.UpdateFormDataSyncDataById(finalResData, item);
  472. }
  473. #endregion
  474. }
  475. }
  476. }