测试好哒

AppStart/HaoDa/HaoDaExtHelper.cs

@@ -0,0 +1,125 @@
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+using System.Linq;
+using Microsoft.Extensions.Hosting;
+using MySystem;
+using MySystem.Models;
+using LitJson;
+using Library;
+
+public class HaoDaExtHelper
+{
+    public readonly static HaoDaExtHelper Instance = new HaoDaExtHelper();
+    private HaoDaExtHelper()
+    {
+    }
+    
+    public void StartWeChat()
+    {
+        Thread th = new Thread(StartWeChatDo);
+        th.IsBackground = true;
+        th.Start();
+    }
+
+    private void StartWeChatDo()
+    {
+        while (true)
+        {
+            string content = RedisDbconn.Instance.RPop<string>("WeChatForHaoDaQueue");
+            if (!string.IsNullOrEmpty(content))
+            {
+                WeChatAddInfo(int.Parse(content));
+            }
+            else
+            {
+                Thread.Sleep(10000);
+            }
+        }
+    }
+
+    public void WeChatAddInfo(int Id)
+    {
+        try
+        {
+            WebCMSEntities db = new WebCMSEntities();
+            MerchantAddInfo info = db.MerchantAddInfo.FirstOrDefault(m => m.Id == Id) ?? new MerchantAddInfo();
+            string result = WeChatFunctionForHD.Instance.MerchantApply(info);
+            if (result.Contains("\"applyment_id\":"))
+            {
+                JsonData json = JsonMapper.ToObject(result);
+                string applyment_id = json["applyment_id"].ToString();
+                RedisDbconn.Instance.AddList("WeChatResultForHaoDaQueue", "{\"MerchantId\":\"" + Id + "\",\"ApplymentId\":\"" + applyment_id + "\"}");
+            }
+            else if (result.Contains("\"message\":"))
+            {
+                MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == Id) ?? new MerchantInfo();
+                JsonData jsonObj = JsonMapper.ToObject(result);
+                info.Status = -1;
+                merchant.Status = -1;
+                info.WeChatRemark = jsonObj["message"].ToString();
+                db.SaveChanges();
+            }
+            db.Dispose();
+        }
+        catch(Exception ex)
+        {
+            function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "微信开户意愿申请异常");
+        }
+    }
+
+
+
+    public void StartAlipay()
+    {
+        Thread th = new Thread(StartAlipayDo);
+        th.IsBackground = true;
+        th.Start();
+    }
+
+    private void StartAlipayDo()
+    {
+        while (true)
+        {
+            string content = RedisDbconn.Instance.RPop<string>("AlipayForHaoDaQueue");
+            if (!string.IsNullOrEmpty(content))
+            {
+                AlipayAddInfo(int.Parse(content));
+            }
+            else
+            {
+                Thread.Sleep(10000);
+            }
+        }
+    }
+
+    public void AlipayAddInfo(int Id)
+    {
+        try
+        {
+            WebCMSEntities db = new WebCMSEntities();
+            MerchantAddInfo info = db.MerchantAddInfo.FirstOrDefault(m => m.Id == Id) ?? new MerchantAddInfo();
+            string result = AlipayFunctionForHD.Instance.AuthOrderCreate(info, info.AlipayAuthToken);
+            JsonData jsonObj = JsonMapper.ToObject(result);
+            if (jsonObj["alipay_merchant_indirect_authorder_create_response"]["code"].ToString() == "10000")
+            {
+                string order_no = jsonObj["alipay_merchant_indirect_authorder_create_response"]["order_no"].ToString();
+                RedisDbconn.Instance.AddList("AlipayResultForHaoDaQueue", "{\"MerchantId\":\"" + Id + "\",\"order_no\":\"" + order_no + "\"}");
+            }
+            else
+            {
+                MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == Id) ?? new MerchantInfo();
+                info.QueryCount = -1;
+                merchant.QueryCount = -1;
+                info.AlipayRemark = jsonObj["alipay_merchant_indirect_authorder_create_response"]["msg"].ToString();
+                db.SaveChanges();
+            }
+            db.Dispose();
+        }
+        catch(Exception ex)
+        {
+            function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "支付宝开户意愿申请异常");
+        }
+    }
+}

AppStart/HaoDa/HaoDaExtQueryHelper.cs

@@ -0,0 +1,154 @@
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+using System.Linq;
+using Microsoft.Extensions.Hosting;
+using MySystem;
+using MySystem.Models;
+using LitJson;
+using Library;
+
+public class HaoDaExtQueryHelper
+{
+    public readonly static HaoDaExtQueryHelper Instance = new HaoDaExtQueryHelper();
+    private HaoDaExtQueryHelper()
+    {
+    }
+    
+    public void StartWeChat()
+    {
+        Thread th = new Thread(StartWeChatDo);
+        th.IsBackground = true;
+        th.Start();
+    }
+
+    private void StartWeChatDo()
+    {
+        while (true)
+        {
+            string content = RedisDbconn.Instance.RPop<string>("WeChatResultForHaoDaQueue");
+            if (!string.IsNullOrEmpty(content))
+            {
+                JsonData json = JsonMapper.ToObject(content);
+                WeChatAddInfo(int.Parse(json["MerchantId"].ToString()), json["ApplymentId"].ToString());
+            }
+            else
+            {
+                Thread.Sleep(10000);
+            }
+        }
+    }
+
+    public void WeChatAddInfo(int Id, string ApplymentId)
+    {
+        try
+        {
+            WebCMSEntities db = new WebCMSEntities();
+            MerchantAddInfo info = db.MerchantAddInfo.FirstOrDefault(m => m.Id == Id) ?? new MerchantAddInfo();
+            string result = WeChatFunctionForHD.Instance.QueryMerchant(ApplymentId);
+            JsonData jsonObj = JsonMapper.ToObject(result);
+            if (jsonObj["applyment_state"].ToString() == "APPLYMENT_STATE_FINISHED")
+            {
+                MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == Id) ?? new MerchantInfo();
+                info.Status = 1;
+                merchant.Status = 1;
+                info.WeChatRemark = "";
+                info.WeChatSignUrl = jsonObj["sign_url"].ToString();
+                db.SaveChanges();
+            }
+            else if (jsonObj["applyment_state"].ToString() == "APPLYMENT_STATE_REJECTED")
+            {
+                MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == Id) ?? new MerchantInfo();
+                info.Status = -1;
+                merchant.Status = -1;
+                info.WeChatRemark = jsonObj["reject_reason"].ToString();
+                db.SaveChanges();
+            }
+            else
+            {
+                RedisDbconn.Instance.AddList("WeChatResultForHaoDaQueue", "{\"MerchantId\":\"" + Id + "\",\"ApplymentId\":\"" + ApplymentId + "\"}");
+            }
+            db.Dispose();
+        }
+        catch(Exception ex)
+        {
+            function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "微信开户意愿申请异常");
+        }
+    }
+
+
+
+    public void StartAlipay()
+    {
+        Thread th = new Thread(StartAlipayDo);
+        th.IsBackground = true;
+        th.Start();
+    }
+
+    private void StartAlipayDo()
+    {
+        while (true)
+        {
+            string content = RedisDbconn.Instance.RPop<string>("AlipayResultForHaoDaQueue");
+            if (!string.IsNullOrEmpty(content))
+            {
+                JsonData json = JsonMapper.ToObject(content);
+                AlipayAddInfo(int.Parse(json["MerchantId"].ToString()), json["order_no"].ToString());
+            }
+            else
+            {
+                Thread.Sleep(10000);
+            }
+        }
+    }
+
+    public void AlipayAddInfo(int Id, string OrderNo)
+    {
+        try
+        {
+            WebCMSEntities db = new WebCMSEntities();
+            MerchantAddInfo info = db.MerchantAddInfo.FirstOrDefault(m => m.Id == Id) ?? new MerchantAddInfo();
+            string result = AlipayFunctionForHD.Instance.AuthOrderQuery(OrderNo);
+            JsonData jsonObj = JsonMapper.ToObject(result);
+            if (jsonObj["alipay_merchant_indirect_authorder_querystatus_response"]["code"].ToString() == "10000")
+            {
+                string order_status = jsonObj["alipay_merchant_indirect_authorder_querystatus_response"]["order_status"].ToString();
+                if (order_status == "CONTACT_CONFIRM")
+                {
+                    MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == Id) ?? new MerchantInfo();
+                    info.QueryCount = 1;
+                    merchant.QueryCount = 1;
+                    info.AlipayRemark = "";
+                    info.AlipaySignUrl = jsonObj["alipay_merchant_indirect_authorder_querystatus_response"]["qr_code"].ToString();
+                    db.SaveChanges();
+                }
+                else if (order_status == "AUDIT_PASS" || order_status == "AUDIT_REJECT" || order_status == "AUDIT_FREEZE")
+                {
+                    MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == Id) ?? new MerchantInfo();
+                    info.QueryCount = -1;
+                    merchant.QueryCount = -1;
+                    info.AlipayRemark = jsonObj["alipay_merchant_indirect_authorder_querystatus_response"]["msg"].ToString();
+                    db.SaveChanges();
+                }
+                else
+                {
+                    RedisDbconn.Instance.AddList("AlipayResultForHaoDaQueue", "{\"MerchantId\":\"" + Id + "\",\"order_no\":\"" + OrderNo + "\"}");
+                }
+            }
+            else
+            {
+                MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == Id) ?? new MerchantInfo();
+                info.QueryCount = -1;
+                merchant.QueryCount = -1;
+                info.AlipayRemark = jsonObj["alipay_merchant_indirect_authorder_querystatus_response"]["msg"].ToString();
+                db.SaveChanges();
+            }
+            db.Dispose();
+        }
+        catch(Exception ex)
+        {
+            function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "支付宝开户意愿申请异常");
+        }
+    }
+}

AppStart/WeChatFunctionForHD.cs

@@ -131,72 +131,24 @@ namespace MySystem
 
         #endregion
 
+        #region 间连商户开户意愿确认（提交申请单）查询申请单状态
 
-        #region 服务商平台查询申请单状态API
-
-        public Dictionary<string, object> QueryMerchant(string BusinessCode)
+        public string QueryMerchant(string BusinessCode)
         {
-            Dictionary<string, object> return_result = new Dictionary<string, object>();
+            string result = "";
             try
             {
-                string result = postJson("https://api.mch.weixin.qq.com/v3/apply4subject/applyment?applyment_id=" + BusinessCode, "", "GET");
+                result = postJson("https://api.mch.weixin.qq.com/v3/apply4subject/applyment?applyment_id=" + BusinessCode, "", "GET");
                 //"{\"applyment_state\":\"APPLYMENT_STATE_REJECTED\",\"reject_param\":\"licence_valid_date|cert_valid_date\",\"reject_reason\":\"有效期开始日期填写有误，请填写与营业执照上一致的开始日期，如影印件上无开始日期请填写成立日期/注册日期;有效期结束日期填写有误，请填写与营业执照上一致的日期，如影印件上无结束日期请填写“长期”\"}"
-
-
                 
                 //{\"applyment_id\":2000002247709762,\"applyment_state\":\"APPLYMENT_STATE_FINISHED\",\"applyment_state_msg\":\"商户入驻申请已完成\",\"audit_detail\":[],\"business_code\":\"0123456789\",\"sign_url\":\"https://mp.weixin.qq.com/cgi-bin/showqrcode?ticket=gQFv7zwAAAAAAAAAAS5odHRwOi8vd2VpeGluLnFxLmNvbS9xLzAyUXE1czkzb3JlUjIxZHpXbTF5Y2YAAgRjbe9hAwQAjScA\",\"sub_mchid\":\"1619775262\"}
-                JsonData jsonObj = JsonMapper.ToObject(result);
-                bool logFlag = true;
-                if (jsonObj["applyment_state"].ToString() == "APPLYMENT_STATE_AUDITING" || jsonObj["applyment_state"].ToString() == "APPLYMENT_STATE_TO_BE_SIGNED" || jsonObj["applyment_state"].ToString() == "APPLYMENT_STATE_TO_BE_CONFIRMED")
-                {
-                    string check = RedisDbconn.Instance.Get<string>("WeChatQueryMerchant:" + BusinessCode + ":" + jsonObj["applyment_state"].ToString());
-                    if(!string.IsNullOrEmpty(check))
-                    {
-                        logFlag = false;
-                    }
-                    else
-                    {
-                        RedisDbconn.Instance.Set("WeChatQueryMerchant:" + BusinessCode + ":" + jsonObj["applyment_state"].ToString(), result);
-                        RedisDbconn.Instance.SetExpire("WeChatQueryMerchant:" + BusinessCode + ":" + jsonObj["applyment_state"].ToString(), 7200);
-                    }
-                }
-                if(logFlag)
-                {
-                    function.WriteLog(BusinessCode, "服务商平台商户进件提交申请单API");
-                    function.WriteLog(result + "\n\n", "服务商平台查询申请单状态API");
-                }
-                return_result.Add("applyment_id", jsonObj["applyment_id"].ToString()); //微信支付申请单号
-                return_result.Add("applyment_state", jsonObj["applyment_state"].ToString()); //申请单状态
-                return_result.Add("applyment_state_msg", jsonObj["applyment_state_msg"].ToString()); //申请状态描述
-                if (jsonObj["applyment_state"].ToString() == "APPLYMENT_STATE_TO_BE_SIGNED" || jsonObj["applyment_state"].ToString() == "APPLYMENT_STATE_FINISHED")
-                {
-                    return_result.Add("sub_mchid", jsonObj["sub_mchid"].ToString());
-                }
-                if (jsonObj["applyment_state"].ToString() == "APPLYMENT_STATE_REJECTED")
-                {
-                    List<Dictionary<string, string>> audit_detail = new List<Dictionary<string, string>>();
-                    JsonData auditObj = jsonObj["audit_detail"]; //驳回原因详情
-                    // for (int i = 0; i < auditObj.Count; i++)
-                    // {
-                    //     Dictionary<string, string> row = new Dictionary<string, string>();
-                    //     // row.Add("field", auditObj[i]["field"].ToString()); //字段名
-                    //     // row.Add("field_name", auditObj[i]["field_name"].ToString()); //字段名称
-                    //     row.Add("reject_reason", auditObj[i]["reject_reason"].ToString()); //驳回原因
-                    //     audit_detail.Add(row);
-                    // }
-                    return_result.Add("reject_reason", auditObj[0]["reject_reason"].ToString());
-                    return_result.Add("audit_detail", audit_detail); //申请状态描述
-                }
-                if (result.Contains("\"sign_url\":"))
-                { 
-                    return_result.Add("sign_url", jsonObj["sign_url"].ToString()); //进件通过申请，待商家签约的地址
-                }
+                
             }
             catch (Exception ex)
             {
-                function.WriteLog(DateTime.Now.ToString() + "\r\n" + ex.ToString(), "服务商平台查询申请单状态API异常");
+                function.WriteLog(DateTime.Now.ToString() + "\r\n" + ex.ToString(), "间连商户开户意愿确认（提交申请单）查询申请单状态异常");
             }
-            return return_result;
+            return result;
         }
         #endregion
         

Startup.cs

@@ -189,6 +189,10 @@ namespace MySystem
             // {
             //     ProfitHelper.Instance.StartListenProfit();
             // }
+            HaoDaExtHelper.Instance.StartWeChat();
+            HaoDaExtHelper.Instance.StartAlipay();
+            HaoDaExtQueryHelper.Instance.StartWeChat();
+            HaoDaExtQueryHelper.Instance.StartAlipay();
             //必须打开的