CheckWeChatSignService.cs 2.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using MySystem.Models;
  5. using Library;
  6. using LitJson;
  7. namespace MySystem
  8. {
  9. public class CheckWeChatSignService
  10. {
  11. public readonly static CheckWeChatSignService Instance = new CheckWeChatSignService();
  12. private CheckWeChatSignService()
  13. { }
  14. public void Start(JobMqMsg jobInfo)
  15. {
  16. try
  17. {
  18. WebCMSEntities db = new WebCMSEntities();
  19. List<MerchantSign> deletes = new List<MerchantSign>();
  20. List<MerchantSign> signs = TendisDbconn.Instance.GetList<MerchantSign>("WeChatSignList", 1, 10000000);
  21. foreach (MerchantSign sign in signs)
  22. {
  23. Dictionary<string, object> dic = new WeChatFunction().QueryMerchant(sign.BusinessCode);
  24. if (dic["applyment_state"].ToString() == "APPLYMENT_STATE_TO_BE_CONFIRMED")
  25. {
  26. string sign_url = dic["sign_url"].ToString();
  27. MerchantAddInfo merchantadd = db.MerchantAddInfo.FirstOrDefault(m => m.Id == sign.MerchantAddInfoId);
  28. if (merchantadd != null)
  29. {
  30. merchantadd.SeoKeyword = sign_url;
  31. db.SaveChanges();
  32. deletes.Add(sign);
  33. }
  34. }
  35. }
  36. if (deletes.Count > 0)
  37. {
  38. foreach (MerchantSign delete in deletes)
  39. {
  40. signs.Remove(delete);
  41. }
  42. TendisDbconn.Instance.Clear("WeChatSignList");
  43. TendisDbconn.Instance.AddList("WeChatSignList", deletes.ToArray());
  44. }
  45. }
  46. catch (Exception ex)
  47. {
  48. TendisDbconn.Instance.AddList("public:merchant:signerr", DateTime.Now.ToString() + ":" + ex.ToString());
  49. }
  50. }
  51. }
  52. }