BZJ_SyncService.cs 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617
  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. //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. // 获取当前最大Id
  56. var newId = 100000001;
  57. var maxData = _db_nc.Queryable<bd_project>().OrderByDescending(obd => obd.pk_project).First();
  58. if (maxData != null && maxData.pk_project.Contains(_Static_PK_ct_bondapply))
  59. {
  60. newId = Convert.ToInt32(maxData.pk_project.Replace(_Static_PK_ct_bondapply, "")) + 1;
  61. }
  62. #region 获取NC中选项数据的Id
  63. var bd_customerDic = _db_nc.Queryable<bd_customer>().ToList();
  64. var bd_incomeDic = _db_nc.Queryable<bd_income>().ToList();
  65. var org_orgsDic = _db_nc.Queryable<org_orgs>().ToList();
  66. var bd_projectDic = _db_nc.Queryable<bd_project>().ToList();
  67. var bd_materialDic = _db_nc.Queryable<bd_material>().ToList();
  68. var bd_measdocDic = _db_nc.Queryable<bd_measdoc>().ToList();
  69. var org_deptDic = _db_nc.Queryable<org_dept>().ToList();
  70. var bd_psndocDic = _db_nc.Queryable<bd_psndoc>().ToList();
  71. var sm_userDic = _db_nc.Queryable<sm_user>().ToList();
  72. var bd_defdoc_kplx = _db_nc.Queryable<bd_defdoc>().Where(w => w.pk_defdoclist == "1001G1100000000016FV").ToList(); // 开票类型
  73. var bd_defdoc_htywlx = _db_nc.Queryable<bd_defdoc>().Where(w => w.pk_defdoclist == "1001G1100000000010PV").ToList(); // 合同业务类型
  74. #endregion
  75. //#region 接口方式
  76. //// 向NC插入数据
  77. //foreach (var item in idList)
  78. //{
  79. // string createTime = "";
  80. // string modifyTime = "";
  81. // var ydDataSource = _dingTalkService.GetFormDataById(item, out createTime, out modifyTime);
  82. // // 如果NC单据号为空,说明没有传入过NC,此时需要走此逻辑去创建销售订单等
  83. // if (ydDataSource.FirstOrDefault(f => f.Key == "textField_ltxyt75m").Value != null && !string.IsNullOrWhiteSpace(ydDataSource["textField_ltxyt75m"].ToString()))
  84. // {
  85. // continue;
  86. // }
  87. // var ncResData = new List<YiDaResDto>();
  88. // #region 表头
  89. // // 表头
  90. // var dataSource = new KP_SyncServiceModel.DataModel();
  91. // if (ydDataSource.FirstOrDefault(f => f.Key == "selectField_lvc9x4vo").Value != null)
  92. // {
  93. // if (!string.IsNullOrWhiteSpace(ydDataSource["selectField_lvc9x4vo"].ToString()))
  94. // {
  95. // var tempData = org_orgsDic.FirstOrDefault(f => f.name == ydDataSource["selectField_lvc9x4vo"].ToString());
  96. // if (tempData != null)
  97. // {
  98. // dataSource.组织 = tempData.code; // 组织
  99. // }
  100. // }
  101. // }
  102. // dataSource.单据日期 = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  103. // if (!string.IsNullOrWhiteSpace(ydDataSource["dateField_lw5ud9bk"].ToString()))
  104. // {
  105. // dataSource.单据日期 = UnixTimeHelper.ConvertMillisecondsToDateTime(Convert.ToInt64(ydDataSource["dateField_lw5ud9bk"].ToString())).ToString("yyyy-MM-dd HH:mm:ss");
  106. // }
  107. // if (ydDataSource.FirstOrDefault(f => f.Key == "textField_lvdojfuj").Value != null)
  108. // {
  109. // if (!string.IsNullOrWhiteSpace(ydDataSource["textField_lvdojfuj"].ToString()))
  110. // {
  111. // var tempData = bd_customerDic.FirstOrDefault(f => f.code == ydDataSource["textField_lvdojfuj"].ToString());
  112. // if (tempData != null)
  113. // {
  114. // dataSource.客户 = tempData.code; // 客户
  115. // }
  116. // }
  117. // }
  118. // if (ydDataSource.FirstOrDefault(f => f.Key == "selectField_lvc9x4vq").Value != null)
  119. // {
  120. // if (!string.IsNullOrWhiteSpace(ydDataSource["selectField_lvc9x4vq"].ToString()))
  121. // {
  122. // var tempData = bd_incomeDic.FirstOrDefault(f => f.name == ydDataSource["selectField_lvc9x4vq"].ToString());
  123. // if (tempData != null)
  124. // {
  125. // dataSource.收款协议 = tempData.code; // 收款协议
  126. // }
  127. // }
  128. // }
  129. // if (ydDataSource.FirstOrDefault(f => f.Key == "departmentSelectField_lvc7mi3w").Value != null)
  130. // {
  131. // if (!string.IsNullOrWhiteSpace(ydDataSource["departmentSelectField_lvc7mi3w"].ToString()))
  132. // {
  133. // var tempData = org_deptDic.FirstOrDefault(f => f.name == JsonConvert.DeserializeObject<List<string>>(JsonConvert.SerializeObject(ydDataSource["departmentSelectField_lvc7mi3w"]))[0]);
  134. // if (tempData != null)
  135. // {
  136. // dataSource.部门 = tempData.code; // 部门
  137. // }
  138. // }
  139. // }
  140. // dataSource.审批人 = "OA-NC";
  141. // dataSource.制单人 = "OA-NC";
  142. // dataSource.创建人 = "OA-NC";
  143. // dataSource.审批时间 = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  144. // dataSource.制单时间 = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  145. // dataSource.创建时间 = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  146. // if (ydDataSource.FirstOrDefault(f => f.Key == "textField_lvdntzul").Value != null)
  147. // {
  148. // if (!string.IsNullOrWhiteSpace(ydDataSource["textField_lvdntzul"].ToString()))
  149. // {
  150. // var tempData = bd_projectDic.FirstOrDefault(f => f.project_code == ydDataSource["textField_lvdntzul"].ToString());
  151. // if (tempData != null)
  152. // {
  153. // dataSource.项目 = tempData.project_code; // 项目
  154. // }
  155. // }
  156. // }
  157. // dataSource.发票号 = ydDataSource["textField_lvd8pp35"].ToString();
  158. // dataSource.客户打印名称 = ydDataSource["selectField_lvdojfui"].ToString();
  159. // if (ydDataSource.FirstOrDefault(f => f.Key == "selectField_lvc9x4vp").Value != null)
  160. // {
  161. // if (!string.IsNullOrWhiteSpace(ydDataSource["selectField_lvc9x4vp"].ToString()))
  162. // {
  163. // var tempName = ydDataSource["selectField_lvc9x4vp"].ToString();
  164. // if (ydDataSource["selectField_lvc9x4vp"].ToString() == "增值税专票")
  165. // {
  166. // tempName = "增值税专用发票";
  167. // }
  168. // if (ydDataSource["selectField_lvc9x4vp"].ToString() == "增值税普票")
  169. // {
  170. // tempName = "增值税普通发票";
  171. // }
  172. // var tempData = bd_defdoc_kplx.FirstOrDefault(f => f.name == tempName);
  173. // if (tempData != null)
  174. // {
  175. // dataSource.开票类型 = tempData.pk_defdoc; // 开票类型
  176. // }
  177. // }
  178. // }
  179. // dataSource.OA单据号 = ydDataSource["textField_lvdosccc"].ToString();
  180. // if (ydDataSource.FirstOrDefault(f => f.Key == "selectField_lvc9x4vn").Value != null)
  181. // {
  182. // if (!string.IsNullOrWhiteSpace(ydDataSource["selectField_lvc9x4vn"].ToString()))
  183. // {
  184. // if (ydDataSource["selectField_lvc9x4vn"].ToString().Contains("一次性") || ydDataSource["selectField_lvc9x4vn"].ToString().Contains("工程订单"))
  185. // {
  186. // dataSource.合同业务类型 = "1001G11000000000113F";
  187. // }
  188. // else
  189. // {
  190. // var tempData = bd_defdoc_htywlx.FirstOrDefault(f => f.name == ydDataSource["selectField_lvc9x4vn"].ToString());
  191. // if (tempData != null)
  192. // {
  193. // dataSource.合同业务类型 = tempData.pk_defdoc; // 合同业务类型
  194. // }
  195. // }
  196. // }
  197. // }
  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. // dataSource.明细 = detailList;
  366. // dataSource.数量 = dataSource.明细.Sum(s => Convert.ToDecimal(s.数量)).ToString();
  367. // dataSource.价税合计 = dataSource.明细.Sum(s => Convert.ToDecimal(s.价税合计)).ToString();
  368. // var results_销售订单 = NCImportFunc.NCImport(KP_SyncServiceModel.ImportXml_销售订单.TemplateHeade(), KP_SyncServiceModel.ImportXml_销售订单.Header(dataSource, item + DateTime.Now.ToString("MMddHHmmss")), _NCApiUrl + "?account=LY01&groupcode=0");
  369. // LogHelper.WriteLog(JsonConvert.SerializeObject(results_销售订单), "results_销售订单");
  370. // XElement xE_销售订单 = XElement.Parse(results_销售订单);
  371. // string resultcode_销售订单 = xE_销售订单.Element("sendresult").Element("resultcode").Value;
  372. // string resultdescription_销售订单 = xE_销售订单.Element("sendresult").Element("resultdescription")?.Value;
  373. // if (resultcode_销售订单 == "1")
  374. // {
  375. // ncResData.Add(new YiDaResDto()
  376. // {
  377. // bSuccess = true,
  378. // ncNo = xE_销售订单.Element("sendresult").Element("content").Value,
  379. // log = "同步成功!"
  380. // });
  381. // }
  382. // else
  383. // {
  384. // ncResData.Add(new YiDaResDto()
  385. // {
  386. // bSuccess = false,
  387. // ncNo = "",
  388. // log = "同步失败!原因为【" + resultdescription_销售订单 + "】!"
  389. // });
  390. // continue;
  391. // }
  392. // // -------------------------------销售订单同步完,开始同步销售发票
  393. // var saleorderData = _db_nc.Queryable<so_saleorder>().First(f => f.csaleorderid == xE_销售订单.Element("sendresult").Element("content").Value);
  394. // var saleorderbData = _db_nc.Queryable<so_saleorder_b>().Where(f => f.csaleorderid == xE_销售订单.Element("sendresult").Element("content").Value).ToList();
  395. // dataSource.销售订单单据号 = saleorderData.vbillcode;
  396. // dataSource.销售订单主表id = saleorderData.csaleorderid;
  397. // foreach (var detailItem in dataSource.明细)
  398. // {
  399. // detailItem.销售订单子表id = saleorderbData.FirstOrDefault(f => f.vbdef10 == detailItem.行id).csaleorderbid;
  400. // }
  401. // var results_销售发票 = NCImportFunc.NCImport(KP_SyncServiceModel.ImportXml_销售发票.TemplateHeade(), KP_SyncServiceModel.ImportXml_销售发票.Header(dataSource, item + DateTime.Now.ToString("MMddHHmmss")), _NCApiUrl + "?account=LY01&groupcode=0");
  402. // LogHelper.WriteLog(JsonConvert.SerializeObject(results_销售发票), "results_销售发票");
  403. // XElement xE_销售发票 = XElement.Parse(results_销售发票);
  404. // string resultcode_销售发票 = xE_销售发票.Element("sendresult").Element("resultcode").Value;
  405. // string resultdescription_销售发票 = xE_销售发票.Element("sendresult").Element("resultdescription")?.Value;
  406. // if (resultcode_销售发票 == "1")
  407. // {
  408. // ncResData.Add(new YiDaResDto()
  409. // {
  410. // bSuccess = true,
  411. // ncNo = xE_销售发票.Element("sendresult").Element("content").Value,
  412. // log = "同步成功!"
  413. // });
  414. // }
  415. // else
  416. // {
  417. // ncResData.Add(new YiDaResDto()
  418. // {
  419. // bSuccess = false,
  420. // ncNo = "",
  421. // log = "同步失败!原因为【" + resultdescription_销售发票 + "】!"
  422. // });
  423. // }
  424. // // -------------------------------销售发票同步完,开始同步应收
  425. // var saleinvoicebData = _db_nc.Queryable<so_saleinvoice_b>().Where(f => f.csaleinvoiceid == xE_销售发票.Element("sendresult").Element("content").Value).ToList();
  426. // var squareinvbData = _db_nc.Queryable<so_squareinv_d>().Where(f => f.csquarebillid == xE_销售发票.Element("sendresult").Element("content").Value).ToList();
  427. // dataSource.销售发票主表id = xE_销售发票.Element("sendresult").Element("content").Value;
  428. // //foreach (var detailItem in dataSource.明细)
  429. // //{
  430. // // var a = saleinvoicebData.FirstOrDefault(f => f.vbdef10 == detailItem.行id).csaleinvoicebid;
  431. // // var b = squareinvbData.FirstOrDefault(f => f.csquarebillbid == a);
  432. // // detailItem.销售发票子表id = b.csalesquaredid;
  433. // //}
  434. // var results_应收单 = NCImportFunc.NCImport(KP_SyncServiceModel.ImportXml_应收单.TemplateHeade(), KP_SyncServiceModel.ImportXml_应收单.Header(dataSource, item + "02"), _NCApiUrl + "?account=01&groupcode=0");
  435. // LogHelper.WriteLog(JsonConvert.SerializeObject(results_应收单), "results_应收单");
  436. // XElement xE_应收单 = XElement.Parse(results_应收单);
  437. // string resultcode_应收单 = xE_应收单.Element("sendresult").Element("resultcode").Value;
  438. // string resultdescription_应收单 = xE_应收单.Element("sendresult").Element("resultdescription")?.Value;
  439. // var recitemData = _db_nc.Queryable<ar_recitem>().Where(w => w.pk_recbill == xE_应收单.Element("sendresult").Element("content").Value).ToList();
  440. // foreach (var recitem in recitemData)
  441. // {
  442. // recitem.scomment = recitem.def1;
  443. // _db_nc.Updateable(recitem).ExecuteCommand();
  444. // }
  445. // if (resultcode_应收单 == "1")
  446. // {
  447. // ncResData.Add(new YiDaResDto()
  448. // {
  449. // bSuccess = true,
  450. // ncNo = xE_应收单.Element("sendresult").Element("content").Value,
  451. // log = "同步成功!"
  452. // });
  453. // }
  454. // else
  455. // {
  456. // ncResData.Add(new YiDaResDto()
  457. // {
  458. // bSuccess = false,
  459. // ncNo = "",
  460. // log = "同步失败!原因为【" + resultdescription_应收单 + "】!"
  461. // });
  462. // }
  463. // var finalResData = new YiDaResDto();
  464. // if (ncResData.FirstOrDefault(f => !f.bSuccess) != null)
  465. // {
  466. // finalResData.bSuccess = false;
  467. // finalResData.syncTime = DateTime.Now;
  468. // finalResData.ncNo = xE_销售订单.Element("sendresult").Element("content").Value;
  469. // finalResData.log = string.Join(" || ", ncResData.Select(s => s.log));
  470. // }
  471. // else
  472. // {
  473. // finalResData.bSuccess = true;
  474. // finalResData.syncTime = DateTime.Now;
  475. // finalResData.ncNo = xE_销售订单.Element("sendresult").Element("content").Value;
  476. // finalResData.log = string.Join(" || ", ncResData.Select(s => s.log));
  477. // }
  478. // var ydRes = _dingTalkService.UpdateFormDataSyncDataById(finalResData, item);
  479. //}
  480. //#endregion
  481. }
  482. }
  483. }