V2Method.cs 49 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047
  1. using CCWin.SkinControl;
  2. using Newtonsoft.Json;
  3. using Newtonsoft.Json.Linq;
  4. using SufeiUtil;
  5. using SXLibrary;
  6. using System;
  7. using System.Collections.Generic;
  8. using System.Data.SQLite;
  9. using System.Diagnostics;
  10. using System.IO;
  11. using System.Linq;
  12. using System.Text;
  13. using System.Threading.Tasks;
  14. using System.Web;
  15. using System.Windows.Forms;
  16. using HttpHelper = SufeiUtil.HttpHelper;
  17. namespace MOKA_Factory_Tools
  18. {
  19. internal class V2Method
  20. {
  21. private static string url_getDSNFromSmes = "http://smes-app-prod.tclking.com:9006/api/xm/GetXMTVParts?TVSN=";
  22. public static MidList midList { get; set; }
  23. private static string url_getMessage = "https://cn.uc.qhmoka.com/scbc-server/clientType/getMessage.do";
  24. public static void SetMexicanConfig(bool bMexican = false)
  25. {
  26. if (bMexican)
  27. url_getMessage = "http://10.138.96.32:81/IDManage/v1/order/getMessage";
  28. else
  29. url_getMessage = "https://cn.uc.qhmoka.com/scbc-server/clientType/getMessage.do";
  30. if ( TestMode.testMode)
  31. url_getMessage = "http://test.scbc.qhmoka.com/scbc-server/clientType/getMessage.do";
  32. }
  33. public static void SetGetMessageUrl(string url = "https://cn.uc.qhmoka.com/scbc-server/clientType/getMessage.do")
  34. {
  35. url_getMessage = url;
  36. }
  37. public static RokuCustomer GetRokuInfo(string strRokuInfo)
  38. {
  39. try
  40. {
  41. JObject jObject = JObject.Parse(strRokuInfo);
  42. RokuCustomer rokuCustomer = new RokuCustomer();
  43. rokuCustomer.id = jObject["id"].ToString().Trim();
  44. rokuCustomer.ordernum = jObject["ordernum"].ToString().Trim();
  45. rokuCustomer.brand = jObject["brand"].ToString().Trim();
  46. rokuCustomer.oemmodel = jObject["oemmodel"].ToString().Trim();
  47. rokuCustomer.productiondate = jObject["productiondate"].ToString().Trim();
  48. rokuCustomer.remotetype = jObject["remotetype"].ToString().Trim();
  49. rokuCustomer.updatetime = jObject["updatetime"].ToString().Trim();
  50. rokuCustomer.createtime = jObject["createtime"].ToString().Trim();
  51. rokuCustomer.isdelete = jObject["isdelete"].ToString().Trim();
  52. if (jObject["data"] != null)
  53. {
  54. rokuCustomer.data = new List<RokuData>();
  55. foreach (var item in jObject["data"])
  56. {
  57. RokuData rokuData = new RokuData();
  58. rokuData.region = item["region"].Value<string>();
  59. rokuData.supporturl = item["supporturl"].Value<string>();
  60. rokuData.supportphone = item["supportphone"].Value<string>();
  61. rokuCustomer.data.Add(rokuData);
  62. }
  63. }
  64. return rokuCustomer;
  65. }
  66. catch (Exception ex)
  67. {
  68. Log.WriteErrorLog(string.Format("解析json失败:{0}", strRokuInfo));
  69. }
  70. return null;
  71. }
  72. public static RokuCustomer GetRokuFileInfo()
  73. {
  74. string fileName = LocalPath.localpath + "roku.info";
  75. if (File.Exists(fileName))
  76. {
  77. Log.WriteInfoLog(string.Format("using roku.info = {0}", fileName));
  78. StreamReader file = File.OpenText(fileName);
  79. RokuCustomer roku = GetRokuInfo(file.ReadToEnd());
  80. file.Close();
  81. return roku;
  82. }
  83. return null;
  84. }
  85. /// <summary>
  86. ///
  87. /// </summary>
  88. /// <param name="url"></param>
  89. /// <param name="order"></param>
  90. /// <param name="pcmac"></param>
  91. /// <param name="sqliteConn"></param>
  92. /// <param name="mid"></param>
  93. /// <returns></returns>
  94. public static bool GetMidInfo(string order, string pcmac, SQLiteConnection sqliteConn, out MidList mid)
  95. {
  96. mid = new MidList();
  97. string postData = string.Format("{{\"bid\":\"{0}\",\"mac\":\"{1}\"}}", order, pcmac);
  98. HttpHelper http = new HttpHelper();
  99. HttpItem item = new HttpItem()
  100. {
  101. URL = url_getMessage,//URL这里都是测试URl必需项
  102. Encoding = Encoding.UTF8,//编码格式(utf-8,gb2312,gbk)可选项 默认类会自动识别//Encoding = Encoding.Default,
  103. Method = "post",
  104. Postdata = postData,
  105. PostEncoding = Encoding.UTF8,
  106. KeepAlive = false
  107. };
  108. item.ContentType = "application/json;charset=utf-8";
  109. System.Diagnostics.Stopwatch stopwatch = new System.Diagnostics.Stopwatch();
  110. stopwatch.Start();
  111. HttpResult result = http.GetHtml(item);
  112. stopwatch.Stop();
  113. string usingtime = stopwatch.ElapsedMilliseconds.ToString();
  114. stopwatch.Reset();
  115. string ParseText = result.Html;
  116. if (result.StatusCode == System.Net.HttpStatusCode.OK)
  117. {
  118. Log.WriteGetKeyLog("\r\nGet MID info\r\nUsing time:" + usingtime + "ms\r\n" + ParseText + "\r\nAddress:" + url_getMessage + "\r\nPostdata:" + postData);
  119. }
  120. else
  121. {
  122. Log.WriteErrorLog("\r\nFail to GetMidInfo:" + result.StatusDescription + result.Html + "\r\nAddress:" + url_getMessage + "\r\nPostdata:" + postData);
  123. CommonMethod.ReportErrormsg("Fail to GetMidInfo", result.StatusDescription + result.Html + "\r\nAddress:" + url_getMessage + "\r\nPostdata:" + postData, sqliteConn);
  124. return false;
  125. }
  126. try
  127. {
  128. JObject jObject = JObject.Parse(ParseText);
  129. mid.message = jObject["message"].Value<string>();
  130. mid.code = jObject["code"].Value<string>();
  131. mid.factoryname = jObject["factoryName"].Value<string>();
  132. mid.factoryNum = jObject["factoryNum"].Value<string>();
  133. mid.version = jObject["version"].Value<string>();
  134. mid.quantity = jObject["quantity"].Value<string>();
  135. mid.projectid = jObject["projectId"].Value<string>();
  136. mid.clienttype = jObject["clientType"].Value<string>();
  137. mid.host = jObject["host"].Value<string>();
  138. mid.whiteType = jObject["whiteType"].Value<string>();
  139. string aesEncrypt = jObject["aesEncrypt"] == null ? null : jObject["aesEncrypt"].Value<string>();
  140. mid.isSmt = jObject["isSmt"] == null ? "0" : jObject["isSmt"].Value<string>();
  141. if (aesEncrypt != null)
  142. mid.aesEncrypt = aesEncrypt.Equals("yes", StringComparison.OrdinalIgnoreCase);
  143. object a = jObject["rokuCustomer"];
  144. if (jObject["rokuCustomer"].ToString().Length > 0)
  145. {
  146. mid.rokuCustomer = GetRokuInfo(jObject["rokuCustomer"].ToString());
  147. }
  148. //如果订单是整机订单
  149. mid.keytype = new Dictionary<string, string>();
  150. if ( mid.isSmt.Equals("0") )
  151. {// 整机;
  152. foreach (var ss in jObject["obj"]) //查找某个字段与值
  153. {
  154. mid.keytype.Add(ss["name"].Value<string>(), ss["type"].Value<string>());
  155. }
  156. }
  157. else
  158. {// 整机+板卡;
  159. if ( Main.Is_Smt == "1" )
  160. {
  161. foreach (var ss in jObject["obj_smt"]) //查找isSmt某个字段与值
  162. {
  163. mid.keytype.Add(ss["name"].Value<string>(), ss["type"].Value<string>());
  164. }
  165. }
  166. else
  167. {
  168. foreach (var ss in jObject["obj"]) //查找某个字段与值
  169. {
  170. mid.keytype.Add(ss["name"].Value<string>(), ss["type"].Value<string>());
  171. }
  172. }
  173. }
  174. if (mid.code == "1000")
  175. {
  176. midList = mid;
  177. return true;
  178. }
  179. }
  180. catch (Exception ex)
  181. {
  182. Log.WriteErrorLog("\r\nFail to parse MID info," + ex.Message + ":" + ParseText + "\r\nAddress:" + url_getMessage + "\r\nPostdata:" + postData);
  183. CommonMethod.ReportErrormsg("Fail to parse MID info", ex.Message + ":" + ParseText + "\r\nAddress:" + url_getMessage + "\r\nPostdata:" + postData, sqliteConn);
  184. MessageBox.Show("Fail to parse MID info\r\n " + ex.Message);
  185. }
  186. return false;
  187. }
  188. public static bool GetMidKey(string url, string sn, string order, string psn, string firetv_device_code, List<KeyType> key2Write, SQLiteConnection connection, ref KeyInfo keys, out string msg)
  189. {
  190. msg = "";
  191. string code;
  192. bool result = false;
  193. HttpHelper http = new HttpHelper();
  194. HttpItem item = new HttpItem()
  195. {
  196. Encoding = Encoding.UTF8,
  197. Method = "post",
  198. ContentType = "application/json",
  199. KeepAlive = false
  200. };
  201. // 计算函数耗时;
  202. Stopwatch watch = new Stopwatch();
  203. watch.Start();
  204. item.URL = url + "/bind/order";
  205. item.Postdata = string.Format("{{\"orderNum\":\"{0}\",\"sn\":\"{1}\",\"psn\":\"{2}\",\"orderCode\":\"{3}\",\"clientType\":\"{4}\",\"isSmt\":\"{5}\",\"skipKey\":{6}}}", order, sn, psn, firetv_device_code, midList.clienttype,
  206. midList.isSmt.Equals("0") ? "0" : Main.Is_Smt , key2Write == null ? "[]" : JsonConvert.SerializeObject(key2Write).ToString());
  207. HttpResult httpResult = http.GetHtml(item);
  208. if (httpResult.StatusCode == System.Net.HttpStatusCode.OK)
  209. {
  210. try
  211. {
  212. JObject jObject = JObject.Parse(httpResult.Html);
  213. msg = CommonMethod.JSON_SeleteNode(jObject, "msg");
  214. code = CommonMethod.JSON_SeleteNode(jObject, "code");
  215. if (code == "0")
  216. {
  217. //需要解密
  218. if (midList != null && midList.aesEncrypt)
  219. {
  220. AES_DES Aes = new AES_DES();
  221. //data解密
  222. string plainText = CommonMethod.JSON_SeleteNode(jObject, "data");
  223. string key = AES_DES.AESKey;
  224. byte[] IV = AES_DES.AESIV;
  225. string str = AES_DES.DecryptStringFromBytes_Aes(plainText, key, IV);
  226. Log.WriteInfoLog("解密后:" + str);
  227. jObject["data"] = str;
  228. }
  229. Dictionary<string, string> data = JsonConvert.DeserializeObject<Dictionary<string, string>>(jObject["data"].ToString());
  230. if (data != null)
  231. {
  232. Func<string, string, bool> CheckMD5 = (data, md5) =>
  233. {
  234. if (data == null)
  235. return true;
  236. if (!GetMD5.GetStrMd5(data).Equals(md5, StringComparison.OrdinalIgnoreCase))
  237. return false;
  238. return true;
  239. };
  240. if (data.ContainsKey("mac") && data.ContainsKey("mac_md5"))
  241. {
  242. keys.Mac.data = data["mac"];
  243. keys.Mac.md5 = data["mac_md5"];
  244. if (!CheckMD5(keys.Mac.data, keys.Mac.md5))
  245. {
  246. msg = string.Format("Mac Key Value md5 Is Incorrect: data={0}, md5={1}", keys.Mac.data, keys.Mac.md5);
  247. goto end;
  248. }
  249. }
  250. if (data.ContainsKey("btMac") && data.ContainsKey("btMac_md5"))
  251. {
  252. keys.BT_MAC.data = data["btMac"];
  253. keys.BT_MAC.md5 = data["btMac_md5"];
  254. if (!CheckMD5(keys.BT_MAC.data, keys.BT_MAC.md5))
  255. {
  256. msg = string.Format("BT_MAC Key Value md5 Is Incorrect: data={0}, md5={1}", keys.BT_MAC.data, keys.BT_MAC.md5);
  257. goto end;
  258. }
  259. }
  260. if (data.ContainsKey("wifiMac") && data.ContainsKey("wifiMac_md5"))
  261. {
  262. keys.WiFi_MAC.data = data["wifiMac"];
  263. keys.WiFi_MAC.md5 = data["wifiMac_md5"];
  264. if (!CheckMD5(keys.WiFi_MAC.data, keys.WiFi_MAC.md5))
  265. {
  266. msg = string.Format("WiFi_MAC Key Value md5 Is Incorrect: data={0}, md5={1}", keys.WiFi_MAC.data, keys.WiFi_MAC.md5);
  267. goto end;
  268. }
  269. }
  270. if (data.ContainsKey("deviceid") && data.ContainsKey("deviceid_md5"))
  271. {
  272. keys.DID.data = data["deviceid"];
  273. keys.DID.md5 = data["deviceid_md5"];
  274. if (!CheckMD5(keys.DID.data, keys.DID.md5))
  275. {
  276. msg = string.Format("DID Key Value md5 Is Incorrect: data={0}, md5={1}", keys.DID.data, keys.DID.md5);
  277. goto end;
  278. }
  279. }
  280. if (data.ContainsKey("hdcp") && data.ContainsKey("hdcp_md5"))
  281. {
  282. keys.HDCP.data = data["hdcp"];
  283. keys.HDCP.md5 = data["hdcp_md5"];
  284. if (!CheckMD5(keys.HDCP.data, keys.HDCP.md5))
  285. {
  286. msg = string.Format("HDCP Key Value md5 Is Incorrect: data={0}, md5={1}", keys.HDCP.data, keys.HDCP.md5);
  287. goto end;
  288. }
  289. }
  290. if (data.ContainsKey("hdcp2") && data.ContainsKey("hdcp2_md5"))
  291. {
  292. keys.HDCP22.data = data["hdcp2"];
  293. keys.HDCP22.md5 = data["hdcp2_md5"];
  294. if (!CheckMD5(keys.HDCP22.data, keys.HDCP22.md5))
  295. {
  296. msg = string.Format("HDCP22 Key Value md5 Is Incorrect: data={0}, md5={1}", keys.HDCP22.data, keys.HDCP22.md5);
  297. goto end;
  298. }
  299. }
  300. if (data.ContainsKey("ci") && data.ContainsKey("ci_md5"))
  301. {
  302. keys.CI_plus.data = data["ci"];
  303. keys.CI_plus.md5 = data["ci_md5"];
  304. if (!CheckMD5(keys.CI_plus.data, keys.CI_plus.md5))
  305. {
  306. msg = string.Format("CI_plus Key Value md5 Is Incorrect: data={0}, md5={1}", keys.CI_plus.data, keys.CI_plus.md5);
  307. goto end;
  308. }
  309. }
  310. if (data.ContainsKey("ecp") && data.ContainsKey("ecp_md5"))
  311. {
  312. keys.ECP.data = data["ecp"];
  313. keys.ECP.md5 = data["ecp_md5"];
  314. if (!CheckMD5(keys.ECP.data, keys.ECP.md5))
  315. {
  316. msg = string.Format("ECP Key Value md5 Is Incorrect: data={0}, md5={1}", keys.ECP.data, keys.ECP.md5);
  317. goto end;
  318. }
  319. }
  320. if (data.ContainsKey("acas") && data.ContainsKey("acas_md5"))
  321. {
  322. keys.ACASKey_Data.data = data["acas"];
  323. keys.ACASKey_Data.md5 = data["acas_md5"];
  324. if (!CheckMD5(keys.ACASKey_Data.data, keys.ACASKey_Data.md5))
  325. {
  326. msg = string.Format("ACASKey_Data Key Value md5 Is Incorrect: data={0}, md5={1}", keys.ACASKey_Data.data, keys.ACASKey_Data.md5);
  327. goto end;
  328. }
  329. }
  330. if (data.ContainsKey("lek") && data.ContainsKey("lek_md5"))
  331. {
  332. keys.LEK.data = data["lek"];
  333. keys.LEK.md5 = data["lek_md5"];
  334. if (!CheckMD5(keys.LEK.data, keys.LEK.md5))
  335. {
  336. msg = string.Format("LEK Key Value md5 Is Incorrect: data={0}, md5={1}", keys.LEK.data, keys.LEK.md5);
  337. goto end;
  338. }
  339. }
  340. if (data.ContainsKey("pek") && data.ContainsKey("pek_md5"))
  341. {
  342. keys.PEK.data = data["pek"];
  343. keys.PEK.md5 = data["pek_md5"];
  344. if (!CheckMD5(keys.PEK.data, keys.PEK.md5))
  345. {
  346. msg = string.Format("PEK Key Value md5 Is Incorrect: data={0}, md5={1}", keys.PEK.data, keys.PEK.md5);
  347. goto end;
  348. }
  349. }
  350. if (data.ContainsKey("playready") && data.ContainsKey("playready_md5"))
  351. {
  352. keys.Playready.data = data["playready"];
  353. keys.Playready.md5 = data["playready_md5"];
  354. if (!CheckMD5(keys.Playready.data, keys.Playready.md5))
  355. {
  356. msg = string.Format("Playready Key Value md5 Is Incorrect: data={0}, md5={1}", keys.Playready.data, keys.Playready.md5);
  357. goto end;
  358. }
  359. }
  360. if (data.ContainsKey("netfilx") && data.ContainsKey("netfilx_md5"))
  361. {
  362. keys.ESN.data = data["netfilx"];
  363. keys.ESN.md5 = data["netfilx_md5"];
  364. if (!CheckMD5(keys.ESN.data, keys.ESN.md5))
  365. {
  366. msg = string.Format("ESN Key Value md5 Is Incorrect: data={0}, md5={1}", keys.ESN.data, keys.ESN.md5);
  367. goto end;
  368. }
  369. }
  370. if (data.ContainsKey("hash") && data.ContainsKey("hash_md5"))
  371. {
  372. keys.Hashkey.data = data["hash"];
  373. keys.Hashkey.md5 = data["hash_md5"];
  374. if (!CheckMD5(keys.Hashkey.data, keys.Hashkey.md5))
  375. {
  376. msg = string.Format("Hashkey Key Value md5 Is Incorrect: data={0}, md5={1}", keys.Hashkey.data, keys.Hashkey.md5);
  377. goto end;
  378. }
  379. }
  380. if (data.ContainsKey("mgk") && data.ContainsKey("mgk_md5"))
  381. {
  382. keys.MGK.data = data["mgk"];
  383. keys.MGK.md5 = data["mgk_md5"];
  384. if (!CheckMD5(keys.MGK.data, keys.MGK.md5))
  385. {
  386. msg = string.Format("MGK Key Value md5 Is Incorrect: data={0}, md5={1}", keys.MGK.data, keys.MGK.md5);
  387. goto end;
  388. }
  389. }
  390. if (data.ContainsKey("youtube") && data.ContainsKey("youtube_md5"))
  391. {
  392. keys.YouTube_KEY.data = data["youtube"];
  393. keys.YouTube_KEY.md5 = data["youtube_md5"];
  394. if (!CheckMD5(keys.YouTube_KEY.data, keys.YouTube_KEY.md5))
  395. {
  396. msg = string.Format("YouTube_KEY Key Value md5 Is Incorrect: data={0}, md5={1}", keys.YouTube_KEY.data, keys.YouTube_KEY.md5);
  397. goto end;
  398. }
  399. }
  400. if (data.ContainsKey("fairplay") && data.ContainsKey("fairplay_md5"))
  401. {
  402. keys.Fairplay.data = data["fairplay"];
  403. keys.Fairplay.md5 = data["fairplay_md5"];
  404. if (!CheckMD5(keys.Fairplay.data, keys.Fairplay.md5))
  405. {
  406. msg = string.Format("Fairplay Key Value md5 Is Incorrect: data={0}, md5={1}", keys.Fairplay.data, keys.Fairplay.md5);
  407. goto end;
  408. }
  409. }
  410. if (data.ContainsKey("widevine") && data.ContainsKey("widevine_md5"))
  411. {
  412. keys.Widevine.data = data["widevine"];
  413. keys.Widevine.md5 = data["widevine_md5"];
  414. if (!CheckMD5(keys.Widevine.data, keys.Widevine.md5))
  415. {
  416. msg = string.Format("Widevine Key Value md5 Is Incorrect: data={0}, md5={1}", keys.Widevine.data, keys.Widevine.md5);
  417. goto end;
  418. }
  419. }
  420. if (data.ContainsKey("attention") && data.ContainsKey("attention_md5"))
  421. {
  422. keys.Attestation.data = data["attention"];
  423. keys.Attestation.md5 = data["attention_md5"];
  424. if (!CheckMD5(keys.Attestation.data, keys.Attestation.md5))
  425. {
  426. msg = string.Format("Attestation Key Value md5 Is Incorrect: data={0}, md5={1}", keys.Attestation.data, keys.Attestation.md5);
  427. goto end;
  428. }
  429. }
  430. if (data.ContainsKey("dsn") && data.ContainsKey("dsn_md5"))
  431. {
  432. keys.DSN.data = data["dsn"];
  433. keys.DSN.md5 = data["dsn_md5"];
  434. if (!CheckMD5(keys.DSN.data, keys.DSN.md5))
  435. {
  436. msg = string.Format("DSN Key Value md5 Is Incorrect: data={0}, md5={1}", keys.DSN.data, keys.DSN.md5);
  437. goto end;
  438. }
  439. }
  440. if (data.ContainsKey("dak") && data.ContainsKey("dak_md5"))
  441. {
  442. keys.DAK.data = data["dak"];
  443. keys.DAK.md5 = data["dak_md5"];
  444. if (!CheckMD5(keys.DAK.data, keys.DAK.md5))
  445. {
  446. msg = string.Format("DAK Key Value md5 Is Incorrect: data={0}, md5={1}", keys.DAK.data, keys.DAK.md5);
  447. goto end;
  448. }
  449. }
  450. if (data.ContainsKey("kfp") && data.ContainsKey("kfp_md5"))
  451. {
  452. keys.KFP.data = data["kfp"];
  453. keys.KFP.md5 = data["kfp_md5"];
  454. if (!CheckMD5(keys.KFP.data, keys.KFP.md5))
  455. {
  456. msg = string.Format("KFP Key Value md5 Is Incorrect: data={0}, md5={1}", keys.KFP.data, keys.KFP.md5);
  457. goto end;
  458. }
  459. }
  460. result = true;
  461. }
  462. }
  463. }
  464. catch(Exception ex)
  465. {
  466. msg = ex.Message;
  467. }
  468. }
  469. end:
  470. watch.Stop();
  471. Log.WriteInfoLog(string.Format("[GetIDMKeys] order={0},sn={1},Elapsed={2} GetKeys={3}", order, sn, watch.Elapsed.TotalMilliseconds, result ? "成功" : "失败"));
  472. if (!result)
  473. CommonMethod.ReportErrormsg("Fail to GetIDMKeys ", msg + "\r\n" + item.URL + "\r\n" + item.Postdata + "\r\n" + httpResult.Html, connection);
  474. return result;
  475. }
  476. public static string GetReportJson(string order, string sn, bool isNodid, string clientType, string swVer, string pid, ref KeyInfo keyinfo, bool bMIEnable, ref MIKey mIKey)
  477. {
  478. Func<string, string, JObject, bool> AddJsonItem = (name, value, jobj) =>
  479. {
  480. if (name == null || name.Length == 0)
  481. return false;
  482. if (value == null || value.Length == 0)
  483. return false;
  484. if (jobj == null)
  485. return false;
  486. jobj.Add(name, (JToken)value);
  487. return true;
  488. };
  489. Func<KeyData, JObject, bool> AddKeyJson = (keydata, jobj) =>
  490. {
  491. if (keydata == null || jobj == null || keydata.data == null)
  492. return false;
  493. if (keydata.keyfrom == KEY_FROM.FROM_IDM && keydata.enable)
  494. {
  495. jobj.Add(keydata.name, (JToken)keydata.data);
  496. }
  497. return true;
  498. };
  499. Func<KeyData, JObject, string, bool> AddKeyJson2 = (keydata, jobj, name) =>
  500. {
  501. if (keydata == null || jobj == null || keydata.data == null)
  502. return false;
  503. if (keydata.keyfrom == KEY_FROM.FROM_IDM && keydata.enable)
  504. {
  505. jobj.Add(name, (JToken)keydata.data);
  506. }
  507. return true;
  508. };
  509. try
  510. {
  511. JObject postJson = new JObject();
  512. AddJsonItem("ordernum", order, postJson);
  513. AddJsonItem("sn", sn, postJson);
  514. AddJsonItem("nodid", isNodid.ToString().ToLower(), postJson);
  515. AddJsonItem("toolVersion", System.Reflection.Assembly.GetExecutingAssembly().GetName().Version.ToString(), postJson);
  516. AddJsonItem("clienttype", clientType, postJson);
  517. AddJsonItem("sversionid", swVer, postJson);
  518. AddJsonItem("projectid", pid, postJson);
  519. //上报时增加smtpsn 字段
  520. //读取PSN
  521. AddJsonItem("smtPsn",OperationPanel.smtPsn,postJson);
  522. if (keyinfo != null)
  523. {
  524. AddKeyJson2(keyinfo.DID, postJson, "deviceid");
  525. if ( !bMIEnable || (mIKey != null && mIKey.EthernetMac == null))
  526. AddKeyJson2(keyinfo.Mac, postJson, "mac");
  527. AddKeyJson2(keyinfo.HDCP, postJson, "hdcpkey");
  528. AddKeyJson2(keyinfo.HDCP22, postJson, "hdcpkey2");
  529. AddKeyJson2(keyinfo.ESN, postJson, "netfilxesn");
  530. AddKeyJson2(keyinfo.Widevine, postJson, "widevine");
  531. AddKeyJson2(keyinfo.CI_plus, postJson, "cikey");
  532. AddKeyJson2(keyinfo.Attestation, postJson, "attestation");
  533. AddKeyJson2(keyinfo.MGK, postJson, "mgk");
  534. AddKeyJson2(keyinfo.Fairplay, postJson, "fairplay");
  535. if (!bMIEnable || ( mIKey != null && mIKey.DSN == null))
  536. AddKeyJson2(keyinfo.DSN, postJson, "dsn");
  537. if (!bMIEnable || (mIKey != null && mIKey.WIFIMAC == null))
  538. AddKeyJson2(keyinfo.WiFi_MAC, postJson, "wifimac");
  539. if (!bMIEnable || (mIKey != null && mIKey.BTMac == null))
  540. AddKeyJson2(keyinfo.BT_MAC, postJson, "btmac");
  541. AddKeyJson2(keyinfo.LEK, postJson, "lek");
  542. AddKeyJson2(keyinfo.PEK, postJson, "pek");
  543. AddKeyJson2(keyinfo.Playready, postJson, "playready");
  544. AddKeyJson2(keyinfo.Hashkey, postJson, "hash");
  545. AddKeyJson2(keyinfo.ECP, postJson, "ecp");
  546. AddKeyJson2(keyinfo.YouTube_KEY, postJson, "youtubekey");
  547. AddKeyJson2(keyinfo.ACASKey_Data, postJson, "acas_data");
  548. AddKeyJson2(keyinfo.DAK, postJson, "dak");
  549. AddKeyJson2(keyinfo.KFP, postJson, "kfp");
  550. }
  551. string postData = postJson.ToString();
  552. //需要加密上报的话
  553. if (midList != null && midList.aesEncrypt)
  554. {
  555. AES_DES AES_DES = new AES_DES();
  556. string key = AES_DES.AESKey;
  557. byte[] IV = AES_DES.AESIV;
  558. postData = AES_DES.EncryptStringToBytes_Aes(postData, key, IV);
  559. //json
  560. string Data = string.Format("{{\"reportData\":\"{0}\"}}", postData);
  561. JObject jo = JObject.Parse(Data);
  562. postData = jo.ToString();
  563. }
  564. return postData;
  565. }
  566. catch (Exception ex)
  567. {
  568. Log.WriteErrorLog("\r\nFail to GetReportJson," + ex.Message + ":" + "\r\nOrder:" + order + "\r\nSN:" + sn);
  569. }
  570. return "";
  571. }
  572. /// <summary>
  573. /// 在线抄写完成上报 Key
  574. /// </summary>
  575. /// <param name="url"></param>
  576. /// <param name="order"></param>
  577. /// <param name="sn"></param>
  578. /// <param name="isNodid"></param>
  579. /// <param name="keyinfo"></param>
  580. /// <param name="sqliteConn"></param>
  581. /// <param name="msg"></param>
  582. /// <returns></returns>
  583. public static bool ReportOnlineData(string url, string order, string postData, SQLiteConnection sqliteConn, bool repeatupload, string id, int timeout, bool background = false)
  584. {
  585. if ( background )
  586. {
  587. return SQLiteHelper.AddReportOnlineData(sqliteConn, url + "/reportData/report", postData);
  588. }
  589. if (timeout < 5000)
  590. timeout = 5000;
  591. HttpHelper http = new HttpHelper();
  592. HttpItem item = new HttpItem()
  593. {
  594. Encoding = Encoding.UTF8,//编码格式(utf-8,gb2312,gbk)可选项 默认类会自动识别//Encoding = Encoding.Default,
  595. Method = "post",
  596. Postdata = postData,
  597. PostEncoding = Encoding.UTF8,
  598. Timeout = timeout,
  599. KeepAlive = false
  600. };
  601. item.URL = url + "/reportData/report";
  602. item.ContentType = "application/json;charset=utf-8";
  603. Stopwatch stopwatch = new Stopwatch();
  604. stopwatch.Start();
  605. HttpResult result = http.GetHtml(item);
  606. stopwatch.Stop();
  607. string usingtime = stopwatch.ElapsedMilliseconds.ToString();
  608. stopwatch.Reset();
  609. string ParseText = result.Html;
  610. if (result.StatusCode == System.Net.HttpStatusCode.OK)
  611. {
  612. Log.WriteGetKeyLog("\r\nReportOnlineData info\r\nUsing time:" + usingtime + "ms\r\n" + ParseText + "\r\nAddress:" + url + "\r\nPostdata:" + item.Postdata);
  613. try
  614. {
  615. JObject jObject = JObject.Parse(ParseText);
  616. string msg = jObject["msg"].Value<string>();
  617. string code = jObject["code"].Value<string>();
  618. if (code == "0")
  619. return true;
  620. }
  621. catch (Exception ex)
  622. {
  623. Log.WriteErrorLog("\r\nFail to ReportOnlineData," + ex.Message + ":" + ParseText + "\r\nAddress:" + url + "\r\nPostdata:" + item.Postdata);
  624. CommonMethod.ReportErrormsg("Fail to ReportOnlineData", ex.Message + ":" + ParseText + "\r\nAddress:" + url + "\r\nPostdata:" + item.Postdata, sqliteConn);
  625. }
  626. if (repeatupload)
  627. {// 删除记录;
  628. SQLiteHelper.DeleteDelayCopyReport(sqliteConn, id);
  629. }
  630. }
  631. else
  632. {
  633. Log.WriteErrorLog("\r\nFail to ReportOnlineData:" + result.StatusDescription + result.Html + "\r\nAddress:" + url + "\r\nPostdata:" + item.Postdata);
  634. if (!repeatupload)
  635. {
  636. if (CommonMethod.HTTPChecker(item.URL))
  637. SQLiteHelper.InsertDelayCopyReport(sqliteConn, new object[] { order, url, item.Postdata });
  638. }
  639. CommonMethod.ReportErrormsg("Fail to ReportOnlineData", result.StatusDescription + result.Html + "\r\nAddress:" + url + "\r\nPostdata:" + item.Postdata, sqliteConn);
  640. }
  641. return false;
  642. }
  643. public static bool ReportOnlineDataSQL(string url, string postData, int timeout)
  644. {
  645. if (timeout < 5000)
  646. timeout = 5000;
  647. HttpHelper http = new HttpHelper();
  648. HttpItem item = new HttpItem()
  649. {
  650. Encoding = Encoding.UTF8,//编码格式(utf-8,gb2312,gbk)可选项 默认类会自动识别//Encoding = Encoding.Default,
  651. Method = "post",
  652. Postdata = postData,
  653. PostEncoding = Encoding.UTF8,
  654. Timeout = timeout,
  655. KeepAlive = false
  656. };
  657. item.URL = url;
  658. item.ContentType = "application/json;charset=utf-8";
  659. HttpResult result = http.GetHtml(item);
  660. string ParseText = result.Html;
  661. if (result.StatusCode == System.Net.HttpStatusCode.OK)
  662. {
  663. Log.WriteGetKeyLog("\r\nReportOnlineDataSQL info\r\n" + ParseText + "\r\nAddress:" + url + "\r\nPostdata:" + item.Postdata);
  664. try
  665. {
  666. JObject jObject = JObject.Parse(ParseText);
  667. string msg = jObject["msg"].Value<string>();
  668. string code = jObject["code"].Value<string>();
  669. if (code == "0")
  670. return true;
  671. }
  672. catch (Exception ex)
  673. {
  674. Log.WriteErrorLog("\r\nFail to ReportOnlineDataSQL," + ex.Message + ":" + ParseText + "\r\nAddress:" + url + "\r\nPostdata:" + item.Postdata);
  675. }
  676. }
  677. else
  678. {
  679. Log.WriteErrorLog("\r\nFail to ReportOnlineDataSQL:" + result.StatusDescription + result.Html + "\r\nAddress:" + url + "\r\nPostdata:" + item.Postdata);
  680. }
  681. return false;
  682. }
  683. //reportData/reportList
  684. /// <summary>
  685. /// 离线抄写上报
  686. /// </summary>
  687. /// <param name="url"></param>
  688. /// <param name="copydate"></param>
  689. /// <param name="SN"></param>
  690. /// <param name="localDBNow"></param>
  691. /// <param name="sqliteConn"></param>
  692. /// <param name="repeatupload"></param>
  693. /// <param name="id"></param>
  694. /// <param name="timeout"></param>
  695. /// <returns></returns>
  696. public static bool ReportOfflineData(string url, string copydate, string SN, SQLiteConnection localDBNow, SQLiteConnection sqliteConn, bool repeatupload, string id)
  697. {
  698. HttpHelper http = new HttpHelper();
  699. HttpItem item = new HttpItem()
  700. {
  701. Encoding = Encoding.UTF8,
  702. Method = "post",
  703. Postdata = string.Format("{{\"sn\":\"{0}\",\"date\":\"{1}\"}}", SN, copydate),
  704. PostEncoding = Encoding.UTF8,
  705. KeepAlive = false
  706. };
  707. item.URL = url + "/reportData/reportList";
  708. item.ContentType = "application/json;charset=utf-8";
  709. System.Diagnostics.Stopwatch stopwatch = new System.Diagnostics.Stopwatch();
  710. stopwatch.Start();
  711. HttpResult result = http.GetHtml(item);
  712. stopwatch.Stop();
  713. string usingtime = stopwatch.ElapsedMilliseconds.ToString();
  714. stopwatch.Reset();
  715. string ParseText = result.Html;
  716. if (result.StatusCode == System.Net.HttpStatusCode.OK)
  717. {
  718. Log.WriteGetKeyLog("\r\nReportOfflineData info\r\nUsing time:" + usingtime + "ms\r\n" + ParseText + "\r\nAddress:" + url + "\r\nPostdata:" + item.Postdata);
  719. }
  720. else
  721. {
  722. Log.WriteErrorLog("\r\nFail to ReportOfflineData:" + result.StatusDescription + result.Html + "\r\nAddress:" + url + "\r\nPostdata:" + item.Postdata);
  723. CommonMethod.ReportErrormsg("Fail to ReportOfflineData", result.StatusDescription + result.Html + "\r\nAddress:" + url + "\r\nPostdata:" + item.Postdata, sqliteConn);
  724. if (repeatupload)
  725. return false;
  726. if (CommonMethod.HTTPChecker(url))
  727. SQLiteHelper.InsertDelayCopyReport(sqliteConn, new object[] { "preload_mode", url, SN + "@" + copydate });
  728. return false;
  729. }
  730. try
  731. {
  732. JObject jObject = JObject.Parse(ParseText);
  733. string msg = jObject["msg"].Value<string>();
  734. string code = jObject["code"].Value<string>();
  735. if (code == "0")
  736. {
  737. //更新上报内容
  738. if (SQLiteHelper.UpdateReportStatus(localDBNow, SN))
  739. {
  740. //更新成功
  741. Log.WriteGetKeyLog("\r\nUpdateReportStatus success:\r\n" + url + "/reportlist.do?\r\n" + "sn=" + SN + "\r\ndate=" + copydate + "\r\n" + ParseText);
  742. return true;
  743. }
  744. else
  745. {
  746. Log.WriteErrorLog("\r\nFail to UpdateReportStatus: " + SN);
  747. return false;
  748. }
  749. }
  750. else
  751. {
  752. CommonMethod.ReportErrormsg("Fail to UploadPreloadCopyResult", "Address: " + url + "/reportlist.do?" + "\r\nPostdata: " + "sn=" + SN + "\r\ndate=" + copydate + "\r\n" + ParseText, sqliteConn);
  753. Log.WriteErrorLog("\r\nUpdateReportStatus code return error,should be 1000 " + "\r\n" + SN + ":" + ParseText + "\r\nAddress:" + url + "/reportlist.do?" + "\r\nPostdata: " + "sn=" + SN + "\r\ndate=" + copydate);
  754. if (repeatupload)
  755. {
  756. SQLiteHelper.DeleteDelayCopyReport(sqliteConn, id);
  757. }
  758. }
  759. }
  760. catch (Exception ex)
  761. {
  762. Log.WriteErrorLog("\r\nFail to ReportOfflineData," + ex.Message + ":" + ParseText + "\r\nAddress:" + url + "\r\nPostdata:" + item.Postdata);
  763. CommonMethod.ReportErrormsg("Fail to ReportOfflineData", ex.Message + ":" + ParseText + "\r\nAddress:" + url + "\r\nPostdata:" + item.Postdata, sqliteConn);
  764. }
  765. return false;
  766. }
  767. public static bool GetOfflineData(string url, string order, SQLiteConnection sqliteConn, out List<MidAddress> midAddressList)
  768. {
  769. midAddressList = new List<MidAddress>();
  770. HttpHelper http = new HttpHelper();
  771. HttpItem item = new HttpItem()
  772. {
  773. Encoding = Encoding.UTF8,
  774. Method = "post",
  775. Postdata = string.Format("{{\"ordernum\":\"{0}\",\"mac\":\"{1}\"}}", order, TestMode.MAC),
  776. KeepAlive = false
  777. };
  778. item.URL = url + "/offline/getofflinelist";
  779. item.ContentType = "application/json;charset=utf-8";
  780. HttpResult result = http.GetHtml(item);
  781. string ParseText = result.Html;
  782. if (result.StatusCode == System.Net.HttpStatusCode.OK)
  783. {
  784. }
  785. else
  786. {
  787. Log.WriteErrorLog("\r\nFail to GetOfflineData:" + result.StatusDescription + "\r\n" + result.Html + "\r\nAddress:" + item.URL + "\r\nPostdata:" + item.Postdata);
  788. CommonMethod.ReportErrormsg("Fail to GetOfflineData", result.StatusDescription + "\r\n" + result.Html + "\r\nAddress:" + item.URL + "\r\nPostdata:" + item.Postdata, sqliteConn);
  789. return false;
  790. }
  791. try
  792. {
  793. JObject jObject = JObject.Parse(ParseText);
  794. if (jObject["data"] != null)
  795. {
  796. foreach (var data in jObject["data"])
  797. {
  798. midAddressList.Add(new MidAddress()
  799. {
  800. des = CommonMethod.JSON_SeleteNode(jObject, "des"),
  801. code = CommonMethod.JSON_SeleteNode(jObject, "code"),
  802. order = data["order_number"].ToObject<string>(),
  803. number = data["order_quantity"].ToObject<string>(),
  804. pid = data["project_id"].ToObject<string>(),
  805. ctype = data["client_type"].ToObject<string>(),
  806. purl = data["packet_url"].ToObject<string>(),
  807. psize = data["packet_size"].ToObject<string>(),
  808. pmd5 = data["packet_md5"].ToObject<string>(),
  809. version = data["soft_version"].ToObject<string>(),
  810. host = url
  811. });
  812. }
  813. Log.WriteGetKeyLog("\r\nGet GetOfflineData success:" + "\r\n" + result.Html + "\r\nAddress:" + item.URL + "\r\nPostdata:" + item.Postdata);
  814. return true;
  815. }
  816. Log.WriteErrorLog("\r\nFail to GetOfflineData," + ParseText + "\r\nAddress:" + item.URL + "\r\nPostdata:" + item.Postdata);
  817. }
  818. catch (Exception ex)
  819. {
  820. Log.WriteErrorLog("\r\nFail to GetOfflineData," + ex.Message + ":" + ParseText + "\r\nAddress:" + item.URL + "\r\nPostdata:" + item.Postdata);
  821. CommonMethod.ReportErrormsg("Fail to GetOfflineData", ex.Message + "\r\n" + ParseText + "\r\nAddress:" + item.URL + "\r\nPostdata:" + item.Postdata, sqliteConn);
  822. MessageBox.Show("Fail to GetOfflineData info\r\n " + ex.Message);
  823. return false;
  824. }
  825. return false;
  826. }
  827. public static bool ReportDownloadStatus(string url, string order, SQLiteConnection sqliteConn)
  828. {
  829. HttpHelper http = new HttpHelper();
  830. HttpItem item = new HttpItem()
  831. {
  832. Encoding = null,
  833. Method = "post",
  834. Postdata = string.Format("{{\"ordernum\":\"{0}\"}}", order),
  835. KeepAlive = false
  836. };
  837. item.URL = url += "/offline/getreportofflinesn";
  838. item.ContentType = "application/json;charset=utf-8";
  839. HttpResult result = http.GetHtml(item);
  840. string ParseText = result.Html;
  841. if (result.StatusCode != System.Net.HttpStatusCode.OK)
  842. {
  843. Log.WriteErrorLog("\r\nFail to report download status:" + result.StatusDescription + result.Html + "\r\nAddress:" + url + "/offline/getreportofflinesn" + "\r\nPostdata:" + ("ordernum=" + order));
  844. CommonMethod.ReportErrormsg("Fail to report download status", result.StatusDescription + result.Html + "\r\nAddress:" + url + "/offline/getreportofflinesn" + "\r\nPostdata:" + ("ordernum=" + order), sqliteConn);
  845. return false;
  846. }
  847. try
  848. {
  849. JObject jObject = JObject.Parse(ParseText);
  850. string msg = CommonMethod.JSON_SeleteNode(jObject, "msg");
  851. string code = CommonMethod.JSON_SeleteNode(jObject, "code");
  852. if (code != "0")
  853. {
  854. Log.WriteErrorLog("\r\nError report download status,should be 1000:" + result.StatusDescription + result.Html + "\r\nAddress:" + url + "/offline/getreportofflinesn" + "\r\nPostdata:" + ("ordernum=" + order));
  855. CommonMethod.ReportErrormsg("Error download status code return", result.StatusDescription + result.Html + "\r\nAddress:" + url + "/offline/getreportofflinesn" + "\r\nPostdata:" + ("ordernum=" + order), sqliteConn);
  856. return false;
  857. }
  858. }
  859. catch (Exception ex)
  860. {
  861. MessageBox.Show(ex.Message);
  862. Log.WriteErrorLog("\r\n" + ex.Message + ":" + result.StatusDescription + result.Html + "\r\nAddress:" + url + "/offline/getreportofflinesn" + "\r\nPostdata:" + ("ordernum=" + order));
  863. CommonMethod.ReportErrormsg("Error parse download status return", result.StatusDescription + result.Html + "\r\nAddress:" + url + "/offline/getreportofflinesn" + "\r\nPostdata:" + ("ordernum=" + order), sqliteConn);
  864. return false;
  865. }
  866. return true;
  867. }
  868. //北美项目,不抄从idm上获取的DSN,用smse上的
  869. public static bool GetDSNFromSmes(string SN, out string DSN)
  870. {
  871. string msg;
  872. DSN = "";
  873. HttpHelper http = new HttpHelper();
  874. HttpItem item = new HttpItem()
  875. {
  876. Encoding = Encoding.UTF8,
  877. Method = "post",
  878. ContentType = "application/x-www-form-urlencoded",
  879. KeepAlive = false
  880. };
  881. item.URL = url_getDSNFromSmes + SN;
  882. HttpResult hResult = http.GetHtml(item);
  883. if (hResult.StatusCode == System.Net.HttpStatusCode.OK)
  884. {
  885. try
  886. {
  887. using (JsonTextReader reader = new JsonTextReader(new StringReader(hResult.Html)))
  888. {
  889. JObject jObject = (JObject)JToken.ReadFrom(reader);
  890. reader.Close();
  891. foreach (var ss in jObject["Tvparts"]) //查找某个字段与值
  892. {
  893. //如果里面的TypeCode为MA(主板),读出他的PSN
  894. if (ss["PartTypeCode"].Value<string>().Equals("DSN-T", StringComparison.OrdinalIgnoreCase))
  895. {
  896. DSN = ss["PartSN"].Value<string>();
  897. break;
  898. }
  899. }
  900. if (DSN == "" || DSN == null)
  901. {
  902. MessageBox.Show("查不到该SN对应的主板DSN号");
  903. return false;
  904. }
  905. Log.WriteInfoLog("PartSN" + DSN);
  906. return true;
  907. }
  908. }
  909. catch (Exception e)
  910. {
  911. msg = e.Message;
  912. Log.WriteErrorLog("IsCuringBOM Json-error:" + hResult.StatusDescription + "\r\n" + hResult.Html + "\r\nAddress: " + item.URL + "\r\nPostdata: " + item.Postdata);
  913. }
  914. }
  915. else
  916. {
  917. msg = hResult.StatusDescription;
  918. Log.WriteInfoLog("IsCuringBOM Http-error:" + hResult.StatusDescription + "\r\n" + hResult.Html + "\r\nAddress: " + item.URL + "\r\nPostdata: " + item.Postdata);
  919. }
  920. return false;
  921. }
  922. };
  923. };