erp/SiteCore/taobao/dataHelper.cs

using BizCom;
using Castle.ActiveRecord.Framework.Internal;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using NHibernate.Mapping;
using NPOI.POIFS.Properties;
using NPOI.SS.Formula.Functions;
using NPOI.SS.UserModel;
using SiteCore.Handler;
using SiteCore.Redis;
using SiteCore.taobao;
using SiteCore.taoObj;
using SQLData;
using System;
using System.Collections;
using System.Collections.Generic;
using System.Collections.Specialized;
using System.Data;
using System.Diagnostics;
using System.Linq;
using System.Net;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Reflection;
using System.Runtime.Remoting.Messaging;
using System.Runtime.Remoting.Metadata.W3cXsd2001;
using System.Security.Cryptography;
using System.Security.Policy;
using System.Security.Principal;
using System.Text;
using System.Threading.Tasks;
using System.Web;
using System.Web.Routing;
using Utils.Serialization;
using static SiteCore.taoObj.dataShopResponseVo;
using static SiteCore.taoObj.dataSpuInfoResponseVo;
using static SiteCore.taoObj.work_core_vo;

namespace SiteCore.Handler
{
    public class dataHelper : BaseHandler, IHttpHandler
    {
        public void ProcessRequest(HttpContext context)
        {
            if (UrlParmsCheck("t"))
            {
                String tname = GetString("t");
                MethodInfo method;
                Type type = this.GetType();
                method = type.GetMethod(tname);
                con = context;
                if (method == null)
                {
                    conError("找不到对应方法,服务器返回错误");
                    return;
                }
                successFlag = false;
                context.Response.ContentType = "application/json";
                context.Response.Headers.Set("Access-Control-Allow-Origin", "*");
                try
                {
                    method.Invoke(this, null);
                }
                catch (Exception ex)
                {
                    conError("处理接口错误，服务器返回错误");
                }
                finally
                {
                }
            }
        }
        public static string GetMD5Hash(string input)
        {
            // 创建一个MD5对象
            using (MD5 md5 = MD5.Create())
            {
                // 将输入字符串转换为字节数组
                byte[] inputBytes = Encoding.UTF8.GetBytes(input);
                // 计算输入字节数组的哈希值
                byte[] hashBytes = md5.ComputeHash(inputBytes);
                // 将字节数组转换为字符串
                StringBuilder hashString = new StringBuilder();
                foreach (byte b in hashBytes)
                {
                    hashString.AppendFormat("{0:x2}", b);
                }
                return hashString.ToString();
            }
        }

        Dictionary<string, string> keysMap = new Dictionary<string, string>()
        {
            {"UzJwXAhiD9","GFyIeZLRIATXMJYnsc5nZPAwK9" },
        };

        public void productInfo()
        {
            bool result = checkParams();
            if (!result)
            {
                return;
            }
            string productName = GetPostString("productName");
            string id = GetPostString("id");
            if (string.IsNullOrEmpty(productName))
            {
                returnErrorMsg("参数没有产品名称");
                return;
            }
            if (string.IsNullOrEmpty(id))
            {
                returnErrorMsg("参数没有产品id");
                return;
            }
            CeErpProduct ceErpProduct = CeErpProduct.GetByName(id);
            bool isCreate = false;
            if (ceErpProduct == null)
            {
                ceErpProduct = new CeErpProduct();
                isCreate = true;
            }
            ceErpProduct.uuid = id;
            ceErpProduct.PType = productName;
            ceErpProduct.UpdateTime = DateTime.Now;
            ceErpProduct.UpdateUserName = "朱义义";
            if (!isCreate)
            {
                ceErpProduct.Update();
            }
            else
            {
                ceErpProduct.CreateTime = ceErpProduct.UpdateTime;
                ceErpProduct.CreateUserName = ceErpProduct.UpdateUserName;
                ceErpProduct.Create();
            }
            returnSuccessMsg("创建成功！");
        }

        public bool checkParams()
        {
            string appKey = GetPostString("appKey");
            string appSecret = "";
            if (!keysMap.ContainsKey(appKey))
            {
                returnErrorMsg("appKey不存在");
                return false;
            }
            keysMap.TryGetValue(appKey, out appSecret);
            if (appSecret == "")
            {
                returnErrorMsg("appSecret不存在");
                return false;
            }

            double timestamp = GetPostDouble("timestamp");//秒级时间戳
            if (timestamp == 0)
            {
                returnErrorMsg("时间戳不存在");
                return false;
            }
            DateTime dtDateTime = new DateTime(1970, 1, 1, 0, 0, 0, 0, DateTimeKind.Utc);
            dtDateTime = dtDateTime.AddSeconds(timestamp).ToLocalTime();
            if (dtDateTime != null && dtDateTime.CompareTo(DateTime.Now.AddMinutes(-5)) < 0)
            {
                returnErrorMsg("请求失效");
                return false;
            }
            string sign = GetPostString("sign");
            if (string.IsNullOrEmpty(sign))
            {
                returnErrorMsg("签名不存在");
                return false;
            }

            string param = appKey + timestamp + appSecret;
            string localSign = GetMD5Hash(param);
            if (!localSign.Equals(sign))
            {
                returnErrorMsg("签名错误");
                return false;
            }
            return true;
        }
        //http://47.114.150.226:88/Handler/dataHelper.ashx?t=get_order_info   post请求参数(参数放body中):string tid(淘宝订单号)
        public void get_order_info()
        {
            bool result = checkParams();
            if (!result)
            {
                return;
            }
            string code = GetPostString("code");
            if (string.IsNullOrEmpty(code))
            {
                returnErrorMsg("参数错误");
                return;
            }

            CeErpTradeCell ceErpTradeCell = CeErpTradeCell.GetByCode(code);
            if (ceErpTradeCell == null)
            {
                returnErrorMsg("查无订单");
                return;
            }
            CeErpTrade ceErpTrade = CeErpTrade.Get(ceErpTradeCell.tid);
            Dictionary<string, object> data = new Dictionary<string, object>();
            data.Add("ctid", ceErpTradeCell.ctid);
            data.Add("isSF", ceErpTradeCell.IsSF);
            if (ceErpTrade != null)
            {
                data.Add("province", ceErpTrade.receiver_state);
            }
            ReturnSuccess(JsonConvert.SerializeObject(data));
            return;
        }
        //http://47.114.150.226:88/Handler/dataHelper.ashx?t=get_cell_info   post请求参数(参数放body中):string tid(淘宝订单号)
        public void get_shop_code()
        {
            bool result = checkParams();
            if (!result)
            {
                return;
            }
            string name = GetPostString("name");
            if (string.IsNullOrEmpty(name))
            {
                returnErrorMsg("参数错误");
                return;
            }
            string code = "";
            string key = "shopName_code_" + name;
            if (RedisHelper.HasKey(key))
            {
                code = RedisHelper.StringGet(key).ToString();

            }
            if (code == "")
            {
                CeErpShop shop = CeErpShop.GetShopIdByName(name);
                if (shop == null)
                {
                    returnErrorMsg("无店铺");
                    return;
                }
                code = shop.SName;
                RedisHelper.StringSet(key, code);
            }
            Dictionary<string, object> data = new Dictionary<string, object>();
            data.Add("code", code);
            ReturnSuccess(JsonConvert.SerializeObject(data));
            return;
        }
        public void getOrderInfo()
        {
            string ctid = GetPostString("ctid");
            if (string.IsNullOrEmpty(ctid))
            {
                returnErrorMsg("参数错误");
                return;
            }
            CeErpTradeCell ceErpTradeCell = CeErpTradeCell.GetByCtid(ctid);
            if (ceErpTradeCell == null)
            {
                returnErrorMsg("查无订单");
                return;
            }
            CeErpTrade ceErpTrade = CeErpTrade.Get(ceErpTradeCell.tid);
            CeErpProduct ceErpProduct = CeErpProduct.Get(ceErpTradeCell.ProductId);
            Dictionary<string, object> data = new Dictionary<string, object>();
            data.Add("orderNumber", ctid);
            data.Add("customerName", ceErpTrade.buyer_nick);
            DateTime dateTime = (DateTime)ceErpTradeCell.pay_time;
            data.Add("orderTime", dateTime.ToString("yyyy-MM-dd HH:mm:ss"));
            data.Add("commodityName", ceErpProduct.PType);
            data.Add("storeName", ceErpTrade.seller_nick);
            data.Add("orderRemark", ceErpTradeCell.seller_memo);

            string sql = string.Format("SELECT tid FROM [dbo].[view_ErpTradeCell] WITH(NOLOCK) WHERE (buyer_id = '{0}') and seller_nick = '{1}' and OrderState < 5 and IsSample = 0 ", ceErpTrade.buyer_id, ceErpTrade.seller_nick);
            DataTable dataTable = DbHelper.DbConn.ExecuteDataset(sql).Tables[0];
            int orderCount = 1;
            if (dataTable != null && dataTable.Rows != null && dataTable.Rows.Count > 0)
            {
                orderCount = dataTable.Rows.Count;
            }
            data.Add("orderCount", orderCount);
            ReturnSuccess(JsonConvert.SerializeObject(data));
            return;
        }

        //http://47.114.150.226:88/Handler/dataHelper.ashx?t=get_cell_info   post请求参数(参数放body中):string tid(淘宝订单号)
        public void get_cell_info()
        {

            string tid = GetPostString("tid");
            string name = GetPostString("nickName");

            string where = "";
            List<string> rows = new List<string>();
            if (!string.IsNullOrEmpty(tid))
            {
                rows.Add(string.Format(" tid = '{0}' ", tid));
            }
            if (!string.IsNullOrEmpty(name))
            {
                rows.Add(string.Format(" buyer_nick = '{0}' ", name));
            }
            where = string.Join("and", rows);
            if (where == "")
            {
                returnErrorMsg("缺少必要参数");
                return;
            }
            string sql = string.Format("SELECT tid,ctid,payment,ProductName,OrderState,Material,Craft,ProductSize,ShopId,ProductCount,posCode,seller_nick,buyer_nick,buyer_id,FinishDesignTime FROM [dbo].[view_ErpTradeCell] WHERE {0}", where);

            DataTable dataTable = DbHelper.DbConn.ExecuteDataset(sql).Tables[0];

            List<Dictionary<string, object>> list = new List<Dictionary<string, object>>();
            if (dataTable != null && dataTable.Rows.Count > 0)
            {
                string shopCode = "";
                Dictionary<string, object> data = new Dictionary<string, object>();
                foreach (DataRow row in dataTable.Rows)
                {
                    int OrderState = Convert.ToInt32(row["OrderState"]);
                    string state = "";
                    if (OrderState < 7)
                    {
                        state = "待发货";
                    }
                    else if (OrderState == 7)
                    {
                        state = "已发货";
                    }
                    else if (OrderState == 8)
                    {
                        state = "交易完成";
                    }
                    else if (OrderState == 9)
                    {
                        state = "交易关闭";
                    }
                    data = new Dictionary<string, object>();
                    data.Add("tid", row["tid"]);
                    data.Add("OrderState", state);
                    data.Add("state", OrderState);
                    data.Add("shopCode", row["posCode"]);
                    data.Add("buyerNick", row["buyer_nick"]);
                    data.Add("buyerId", row["buyer_id"]);
                    data.Add("shopName", row["seller_nick"]);
                    data.Add("ctid", row["ctid"]);
                    data.Add("payment", row["payment"]);
                    data.Add("Material", row["Material"]);
                    data.Add("Craft", row["Craft"]);
                    data.Add("ProductSize", row["ProductSize"]);
                    data.Add("ProductCount", row["ProductCount"]);
                    data.Add("ProductName", row["ProductName"]);
                    data.Add("FinishDesignTime", row["FinishDesignTime"]);
                    if (string.IsNullOrEmpty(row["posCode"].ToString()) && !string.IsNullOrEmpty(shopCode))
                    {
                        data["shopCode"] = shopCode;
                    }

                    if (!string.IsNullOrEmpty(row["ShopId"].ToString()) && string.IsNullOrEmpty(shopCode) && string.IsNullOrEmpty(row["posCode"].ToString()))
                    {
                        string shopsql = string.Format("SELECT top 1 tid FROM [dbo].[CE_ErpTradeCell] WHERE ShopId = {0} AND OrderState = 8 and IsOffLineOrder =0", row["ShopId"]);

                        DataTable shopData = DbHelper.DbConn.ExecuteDataset(shopsql).Tables[0];
                        if (shopData != null && shopData.Rows.Count > 0)
                        {
                            CeErpTrade ceErpTrade = CeErpTrade.Get(shopData.Rows[0]["tid"].ToString());
                            if (ceErpTrade != null)
                            {
                                data["shopCode"] = ceErpTrade.posCode;

                            }
                        }
                    }
                    shopCode = data["shopCode"].ToString();
                    list.Add(data);
                }
            }
            ReturnSuccess(JsonConvert.SerializeObject(list));
            return;

        }
        //http://47.114.150.226:88/Handler/dataHelper.ashx?t=set_sys_price   post请求参数(参数放body中):string tid(淘宝订单号)
        public void set_sys_price()
        {
            string data = GetPostString("data");
            if (!string.IsNullOrEmpty(data))
            {
                List<SysPriceResponseVo> list = JsonConvert.DeserializeObject<List<SysPriceResponseVo>>(data);
                foreach (SysPriceResponseVo item in list)
                {
                    string ordersn = item.ordersn;
                    double price = item.price;
                    string sysPriceContent = item.sysContent;


                    CeErpTradeCell ceErpTradeCell = CeErpTradeCell.GetByCode(ordersn);
                    if (ceErpTradeCell == null)
                    {
                        ceErpTradeCell = CeErpTradeCell.GetByCtid(ordersn);
                    }
                    if (ceErpTradeCell == null)
                    {
                        returnErrorMsg("查无订单");
                        return;
                    }
                    CeErpTradeCellExtend ce = CeErpTradeCellExtend.getByTid(ceErpTradeCell.ctid);
                    if (ce == null)
                    {
                        ce = new CeErpTradeCellExtend();
                        ce.ctid = ceErpTradeCell.ctid;
                    }
                    ce.sysPrice = price;
                    ce.sysPriceContent = sysPriceContent;

                    string sql = string.Format("select ptid,payment from CE_ErpTradeCell where ptid ='{0}' and  IsSample = 2", ceErpTradeCell.tid);
                    DataTable dt_price = DbHelper.DbConn.ExecuteDataset(sql).Tables[0];
                    if (dt_price != null && dt_price.Rows.Count > 0)
                    {
                        double diffPirce = 0;
                        foreach (DataRow dr in dt_price.Rows)
                        {
                            if (Convert.IsDBNull(dr["payment"]))
                            {
                                diffPirce += Convert.ToDouble(dr["payment"]);
                            }
                        }
                        ce.differentAmount = diffPirce;
                    }
                    ce.sysDiffPrice = ce.differentAmount + ceErpTradeCell.payment - price;
                    if (price != 0)
                    {
                        ce.sysPriceRate = Math.Round((ce.differentAmount + ceErpTradeCell.payment) / price * 100, 2);
                    }
                    if (ce.ID != 0)
                    {
                        ce.Update();
                    }
                    else
                    {
                        ce.Create();
                    }
                }
                returnSuccessMsg("修改成功！");
                return;
            }

            returnErrorMsg("缺少必要参数");
        }

        public static void get_sys_price(CeErpTradeCell ceErpTradeCell)
        {
            CeErpProduct product = CeErpProduct.GetById(ceErpTradeCell.ProductId);
            string param = "[{ \"product_type\": \"" + product.PType + "\",        \"remark\": \"" + ceErpTradeCell.seller_memo + "\"    }]";
            string result = sysHttpClient(param);
        }

        public static string sysHttpClient(string param)
        {
            var client = new HttpClient();
            var request = new HttpRequestMessage
            {
                Method = HttpMethod.Post,
                RequestUri = new Uri("http://47.122.57.102:11004/quotations/batch"),
                Content = new StringContent(param)
                {
                    Headers =
                    {
                        ContentType = new MediaTypeHeaderValue("application/json")
                    }
                }
            };
            var task = Task.Run(() =>
            {
                try
                {
                    var response = client.SendAsync(request).Result;
                    response.EnsureSuccessStatusCode();
                    return response.Content.ReadAsStringAsync().Result;
                }
                catch (Exception e)
                {
                    return "";
                }


            });
            return task.Result;
        }

        public void getOrderInvoiceInfo()
        {
            string tids = GetPostString("tids");
            List<string> list = tids.Split(',').ToList();

            return;
        }

        //http://47.114.150.226:88/Handler/dataHelper.ashx?t=update_spu_info   post请求参数(参数放body中):string spuId(淘宝订单号)
        public void update_spu_info()
        {

            string spuId = GetPostString("spuId");
            string category = GetPostString("category");
            string serialNumber = GetPostString("serialNumber");
            string operate = GetPostString("operate");
            string designer = GetPostString("designer");
            string atta = GetPostString("atta");
            string upTime = GetPostString("upTime");
            int shopId = GetPostInt("shopId");
            if (!string.IsNullOrEmpty(spuId))
            {
                CeErpTradeSpu spu = CeErpTradeSpu.GetBySpuId(spuId);
                if (spu == null)
                {
                    returnErrorMsg("找不到对应id");
                    return;
                }
                spu.category = category;
                spu.serialNumber = serialNumber;
                spu.operate = operate;
                spu.designer = designer;
                spu.atta = atta;
                spu.shopId = shopId;
                spu.upTime = DateTime.Parse(upTime);
                spu.Update();
                returnSuccess("修改成功！");
                return;
            }
            returnErrorMsg("缺少必要参数");
        }

        static string pUrl = "http://36.140.138.139:688/api/";

        static string CLIENT_Id = "xclient";
        static string CLIENT_SECRET = "0a417ecce58c31b32364ce19ca8fcd15";
        static string USER_ID = "ca2d316357fa4e09b9c2aa9f7b2ca3d9";

        public static string getSaleOrderSn()
        {
            string orderSn = "";
            string post_url = "http://api.presales.lingtao8.com/open/order/generateSplitOrderUniqueNos/1";
            try
            {
                string remoteInfo = httpSaleContent(HttpMethod.Get, post_url, new Dictionary<string, string>());
                saleOrderResponse dataTokenBean = JsonConvert.DeserializeObject<saleOrderResponse>(remoteInfo);
                if ("200".Equals(dataTokenBean.code))
                {
                    orderSn = dataTokenBean.data[0];
                }
            }
            catch (Exception ex)
            {
                XLog.SaveLog(0, "getSaleOrderSn:" + ex.Message);
            }
            return orderSn;
        }

        public static void api_orderBack(string orderNumber, string state, string content)
        {
            string post_url = "http://api.presales.lingtao8.com/open/order/orderProcessReturn";
            //string post_url = "http://admin.lingtao.zmht888.com/prod-api/open/order/orderProcessReturn";
            string remoteInfo = "";
            string param = JsonConvert.SerializeObject(new
            {
                orderSplitNo = orderNumber,
                errorStatus = state,
                reason = content
            });
            Dictionary<string, string> map = new Dictionary<string, string>();
            map.Add("orderSplitNo", orderNumber);
            map.Add("errorStatus", state);
            map.Add("reason", content);
            try
            {
                remoteInfo = httpSaleContent(HttpMethod.Post, post_url, map);
            }
            catch (Exception ex)
            {
                XLog.SaveLog(0, "api_orderBack:" + ex.Message);
            }
        }
        public static long GetTimeStamp()
        {
            return DateTimeOffset.Now.ToUnixTimeSeconds();
        }

        public static string getToken()
        {
            //return "eyJhbGciOiJSUzI1NiIsInR5cCI6IkpXVCJ9.eyJhdWQiOlsiYXBpIl0sInNjb3BlIjpbInJlYWQiLCJ3cml0ZSJdLCJleHAiOjE3MzU5NjU0ODAsImF1dGhvcml0aWVzIjpbIm9wZW5hcGkiXSwianRpIjoiYjY4NTRhZjctZjNmMy00OTU0LTk4ZmUtZDRlZTE4ZDllNzQyIiwiY2xpZW50X2lkIjoieGNsaWVudCJ9.E6U0NVMZPcUypl4P7L5718J1X8UxSJg9R7vZX_oMkuEJ-yelNXuYwu7-eAi1JTgIJ0GuuviQu-KEAH-W7sHb7t-JJJc-wLPMsLKmpwQDG2EpiRK5hW5ZmyUgL8rPuTUawKVP5k8SGrN60sVyXA2zKm4ztEQ39EGudXnam1Lld2w";
            string token = "";
            if (RedisHelper.HasKey("xclient_token"))
            {
                token = RedisHelper.StringGet("xclient_token").ToString();
                if (RedisHelper.HasKey("token_end"))
                {
                    string token_end = RedisHelper.StringGet("token_end").ToString();
                    long token_endtime = Convert.ToInt64(token_end);
                    long currentTime = GetTimeStamp();
                    if (currentTime <= token_endtime)
                    {
                        return token;
                    }
                }
            }
            string post_url = pUrl + "oauth/token";
            WebClient wc = new WebClient();
            wc.Encoding = Encoding.GetEncoding("utf-8");
            List<string> headers = new List<string>();
            headers.Add("grant_type=client_credentials");
            headers.Add("client_id=" + CLIENT_Id);
            headers.Add("client_secret=" + CLIENT_SECRET);
            post_url += "?" + string.Join("&", headers);
            NameValueCollection PostVars = new NameValueCollection();
            string remoteInfo = "";
            try
            {
                byte[] ret = wc.UploadValues(post_url, "POST", PostVars);
                remoteInfo = Encoding.GetEncoding("utf-8").GetString(ret);
                //remoteInfo = "{\"access_token\":\"eyJhbGciOiJSUzI1NiIsInR5cCI6IkpXVCJ9.eyJhdWQiOlsiYXBpIl0sInNjb3BlIjpbInJlYWQiLCJ3cml0ZSJdLCJleHAiOjE3MjM3OTk0MTUsImF1dGhvcml0aWVzIjpbIm9wZW5hcGkiXSwianRpIjoiZjdhOGVjNmMtOWUyMS00MDZhLWEzNzktYjI0MTU3OTE0ODJmIiwiY2xpZW50X2lkIjoieGNsaWVudCJ9.EL-El6M9AVXvH_hp9E4wqM17sHwynyJBDcZJHYw4AYdJrYAWHEu78-Gn3Hj4FyfDaIkqNk641XSAfVpTiH_sFeTSl8-glSJEeD7OFKSkoJjrj0_Ft7kFZZs0XAhbgo4m5rI3Qbeq_87_0K5wKqRcygjUee82MFcIDueTcUg3p9c\",\"token_type\":\"bearer\",\"expires_in\":2052,\"scope\":\"read write\",\"jti\":\"f7a8ec6c-9e21-406a-a379-b2415791482f\",\"aud\":[\"api\"],\"exp\":1723799415,\"authorities\":[\"openapi\"],\"client_id\":\"xclient\"}";
                dataTokenBean dataTokenBean = JsonConvert.DeserializeObject<dataTokenBean>(remoteInfo);
                token = dataTokenBean.access_token;
                string timeEnd = dataTokenBean.exp;
                RedisHelper.StringSet("xclient_token", token);
                RedisHelper.StringSet("token_end", timeEnd);
            }
            catch (Exception ex)
            {
            }
            return token;
        }
        /// <summary>
        /// 获取店铺信息
        /// </summary>
        /// <param name="shopId"></param>
        /// <returns></returns>
        public static shopInfo getShopDataInfo(string shopId)
        {
            try
            {
                string post_url = pUrl + "openapi/v3/bo/list";
                string param = JsonConvert.SerializeObject(new
                {
                    schemaCode = "Store_01",
                    userId = USER_ID,
                    queryCondition = new
                    {
                        operatorType = 1,
                        propertyCode = "ErpshopId",
                        propertyValue = shopId
                    }
                });
                string data = httpContent(post_url, param);
                dataShopResponseVo dataResponseVos = JsonConvert.DeserializeObject<dataShopResponseVo>(data);
                if (dataResponseVos != null && "0".Equals(dataResponseVos.errcode))
                {
                    if (dataResponseVos.data.bizObjectPage.content.Count > 0)
                    {
                        return dataResponseVos.data.bizObjectPage.content[0].data;
                    }
                }
            }
            catch (Exception ex)
            {

            }
            return null;
        }
        /// <summary>
        /// 获取spu信息
        /// </summary>
        /// <param name="spuId"></param>
        /// <returns></returns>
        public static spuInfo getSpuInfo(string spuId)
        {
            try
            {
                string post_url = pUrl + "openapi/v3/bo/list";
                string param = JsonConvert.SerializeObject(new
                {
                    schemaCode = "lianjieku_01_01",
                    userId = USER_ID,
                    queryCondition = new
                    {
                        operatorType = 1,
                        propertyCode = "ShortText1728890649488",
                        propertyValue = spuId
                    }
                });
                string data = httpContent(post_url, param);
                dataSpuInfoResponseVo dataResponseVos = JsonConvert.DeserializeObject<dataSpuInfoResponseVo>(data);
                if (dataResponseVos != null && "0".Equals(dataResponseVos.errcode))
                {
                    if (dataResponseVos.data.bizObjectPage.content.Count > 0)
                    {
                        return dataResponseVos.data.bizObjectPage.content[0].data;
                    }
                }
            }
            catch (Exception ex)
            {

            }
            return null;
        }
        /// <summary>
        /// 订单发货是否存在
        /// </summary>
        /// <param name="dataSendOrderBean"></param>
        /// <returns></returns>
        public static string checkOrderAlready(dataSendOrderBean dataSendOrderBean)
        {
            try
            {
                string post_url = pUrl + "openapi/v3/bo/list";
                string param = JsonConvert.SerializeObject(new
                {
                    schemaCode = "dingdanfahuo_01",
                    userId = USER_ID,
                    queryCondition = new
                    {
                        operatorType = 1,
                        propertyCode = "ShortText1723707899761",
                        propertyValue = dataSendOrderBean.ShortText1723707899761
                    }
                });
                string data = httpContent(post_url, param);
                dataShopResponseVo dataResponseVos = JsonConvert.DeserializeObject<dataShopResponseVo>(data);
                if (dataResponseVos != null && "0".Equals(dataResponseVos.errcode))
                {
                    if (dataResponseVos.data.bizObjectPage.content.Count > 0)
                    {
                        return dataResponseVos.data.bizObjectPage.content[0].bizObjectId;
                    }
                    return "";
                }
            }
            catch (Exception ex)
            {
            }
            return "";
        }
        /// <summary>
        /// 车间id获取信息
        /// </summary>
        /// <param name="supplerId"></param>
        /// <returns></returns>
        public static string getSupplerDataInfo(string supplerId)
        {
            try
            {
                string post_url = pUrl + "openapi/v3/bo/list";
                string param = JsonConvert.SerializeObject(new
                {
                    schemaCode = "gongyingshang_01",
                    userId = USER_ID,
                    queryCondition = new
                    {
                        operatorType = 1,
                        propertyCode = "ErpSupplierId",
                        propertyValue = supplerId
                    }
                });
                string data = httpContent(post_url, param);
                dataShopResponseVo dataResponseVos = JsonConvert.DeserializeObject<dataShopResponseVo>(data);
                if (dataResponseVos != null && "0".Equals(dataResponseVos.errcode))
                {
                    if (dataResponseVos.data.bizObjectPage.content.Count > 0)
                    {
                        return dataResponseVos.data.bizObjectPage.content[0].data.id;
                    }
                }
            }
            catch (Exception ex)
            {

            }
            return "";
        }
        /// <summary>
        /// 推送发货信息
        /// </summary>
        /// <param name="dataSendOrderBean"></param>
        /// <returns></returns>
        public static dataResponseVo CreateBoFahuo(dataSendOrderBean dataSendOrderBean)
        {
            string post_url = pUrl + "openapi/v3/bo/create";
            shopInfo shop = getShopDataInfo(dataSendOrderBean.RelevanceForm1723191239149);
            if (shop != null)
            {
                dataSendOrderBean.RelevanceForm1723191239149 = shop.id;
            }
            dataSendOrderBean.RelevanceForm1723191634028 = getSupplerDataInfo(dataSendOrderBean.RelevanceForm1723191634028);
            string bizObjectId = checkOrderAlready(dataSendOrderBean);
            if (!string.IsNullOrEmpty(bizObjectId))
            {
                post_url = pUrl + "openapi/v3/bo/update";
                dataSendOrderBean.id = bizObjectId;
            }
            string param = JsonConvert.SerializeObject(new
            {
                schemaCode = "dingdanfahuo_01",
                userId = USER_ID,
                data = dataSendOrderBean
            });
            dataResponseVo dataResponseVos = null;


            try
            {
                string data = httpContent(post_url, param);
                dataResponseVos = JsonConvert.DeserializeObject<dataResponseVo>(data);
                return dataResponseVos;
            }
            catch (Exception ex)
            {
                dataResponseVos = new dataResponseVo();
                dataResponseVos.errcode = "1";
                dataResponseVos.errmsg = ex.Message;
            }
            return dataResponseVos;
        }
        /// <summary>
        /// 推送spu信息
        /// </summary>
        /// <param name="bean"></param>
        /// <returns></returns>
        public static dataResponseVo sendSpuInfo(dataSendSpuBean bean)
        {
            string post_url = pUrl + "openapi/v3/bo/create";
            shopInfo shop = getShopDataInfo(bean.shopId);
            if (shop != null)
            {
                bean.RelevanceForm1728891053364 = shop.id;
                bean.operation = shop.operation;
            }
            spuInfo info = getSpuInfo(bean.ShortText1728890649488);
            if (info != null)
            {
                return null;
                bean.StaffSingle1728891078584 = info.StaffSingle1728891078584;
                bean.Date1728891021647 = info.Date1728891021647;
                bean.ShortText1729677042659 = info.ShortText1729677067460;
                bean.ShortText1728891031267 = info.ShortText1728891031267;
            }
            string param = JsonConvert.SerializeObject(new
            {
                schemaCode = "lianjieku_01",
                userId = USER_ID,
                data = bean
            });
            dataResponseVo dataResponseVos = null;

            try
            {
                string data = httpContent(post_url, param);
                dataResponseVos = JsonConvert.DeserializeObject<dataResponseVo>(data);
                return dataResponseVos;
            }
            catch (Exception ex)
            {
                dataResponseVos = new dataResponseVo();
                dataResponseVos.errcode = "1";
                dataResponseVos.errmsg = ex.Message;
            }
            return dataResponseVos;
        }
        /// <summary>
        /// 主订单数据
        /// </summary>
        /// <param name="bean"></param>
        /// <returns></returns>
        public static dataResponseVo sendErpTradeInfo(dataSendTradeBean bean)
        {
            string post_url = pUrl + "openapi/v3/bo/create";

            string bizObjectId = checkErpTradeAlready(bean);
            if (!string.IsNullOrEmpty(bizObjectId))
            {
                post_url = pUrl + "openapi/v3/bo/update";
                bean.id = bizObjectId;
            }

            string param = JsonConvert.SerializeObject(new
            {
                schemaCode = "zhudingdan_01",
                userId = USER_ID,
                data = bean
            });
            dataResponseVo dataResponseVos = null;

            try
            {
                string data = httpContent(post_url, param);
                dataResponseVos = JsonConvert.DeserializeObject<dataResponseVo>(data);
                return dataResponseVos;
            }
            catch (Exception ex)
            {
                dataResponseVos = new dataResponseVo();
                dataResponseVos.errcode = "1";
                dataResponseVos.errmsg = ex.Message;
            }
            return dataResponseVos;
        }
        /// <summary>
        /// 校验主订单是否存在
        /// </summary>
        /// <param name="dataSendOrderBean"></param>
        /// <returns></returns>
        public static string checkErpTradeAlready(dataSendTradeBean dataSendOrderBean)
        {
            try
            {
                string post_url = pUrl + "openapi/v3/bo/list";
                string param = JsonConvert.SerializeObject(new
                {
                    schemaCode = "zhudingdan_01",
                    userId = USER_ID,
                    queryCondition = new
                    {
                        operatorType = 1,
                        propertyCode = "ShortText1724739958776",
                        propertyValue = dataSendOrderBean.ShortText1724739958776
                    }
                });
                string data = httpContent(post_url, param);
                dataShopResponseVo dataResponseVos = JsonConvert.DeserializeObject<dataShopResponseVo>(data);
                if (dataResponseVos != null && "0".Equals(dataResponseVos.errcode))
                {
                    if (dataResponseVos.data.bizObjectPage.content.Count > 0)
                    {
                        return dataResponseVos.data.bizObjectPage.content[0].bizObjectId;
                    }
                    return "";
                }
            }
            catch (Exception ex)
            {
            }
            return "";
        }

        /// <summary>
        /// 拆订单数据
        /// </summary>
        /// <param name="bean"></param>
        /// <returns></returns>
        public static dataResponseVo sendErpTradeCellInfo(dataSendTradeCellBean bean)
        {
            string post_url = pUrl + "openapi/v3/bo/create";

            string bizObjectId = checkErpTradeCellAlready(bean);
            if (!string.IsNullOrEmpty(bizObjectId))
            {
                post_url = pUrl + "openapi/v3/bo/update";
                bean.id = bizObjectId;
            }
            string tid_id = checkErpTradeAlready(new dataSendTradeBean(bean.tid));
            if (!string.IsNullOrEmpty(tid_id))
            {
                bean.RelevanceForm1724834153527 = tid_id;
            }
            shopInfo shop = getShopDataInfo(bean.shopId);
            if (shop != null)
            {
                bean.RelevanceForm1717742363336 = shop.id;
            }
            string param = JsonConvert.SerializeObject(new
            {
                schemaCode = "orders_01",
                userId = USER_ID,
                data = bean
            });
            dataResponseVo dataResponseVos = null;

            try
            {
                string data = httpContent(post_url, param);
                dataResponseVos = JsonConvert.DeserializeObject<dataResponseVo>(data);
                return dataResponseVos;
            }
            catch (Exception ex)
            {
                dataResponseVos = new dataResponseVo();
                dataResponseVos.errcode = "1";
                dataResponseVos.errmsg = ex.Message;
            }
            return dataResponseVos;
        }
        /// <summary>
        /// 校验拆订单是否存在
        /// </summary>
        /// <param name="dataSendOrderBean"></param>
        /// <returns></returns>
        public static string checkErpTradeCellAlready(dataSendTradeCellBean dataSendOrderBean)
        {
            try
            {
                string post_url = pUrl + "openapi/v3/bo/list";
                string param = JsonConvert.SerializeObject(new
                {
                    schemaCode = "orders_01",
                    userId = USER_ID,
                    queryCondition = new
                    {
                        operatorType = 1,
                        propertyCode = "ShortText1717720509648",
                        propertyValue = dataSendOrderBean.ShortText1717720509648
                    }
                });
                string data = httpContent(post_url, param);
                dataShopResponseVo dataResponseVos = JsonConvert.DeserializeObject<dataShopResponseVo>(data);
                if (dataResponseVos != null && "0".Equals(dataResponseVos.errcode))
                {
                    if (dataResponseVos.data.bizObjectPage.content.Count > 0)
                    {
                        return dataResponseVos.data.bizObjectPage.content[0].bizObjectId;
                    }
                    return "";
                }
            }
            catch (Exception ex)
            {
            }
            return "";
        }
        /// <summary>
        /// 更新数据
        /// </summary>
        /// <param name="map"></param>
        /// <param name="ctid"></param>
        /// <returns></returns>
        public static dataResponseVo updateErpTradeCell(Dictionary<string, string> map, string ctid)
        {
            return null;
            string post_url = pUrl + "openapi/v3/bo/update";
            dataResponseVo dataResponseVos = null;
            dataSendTradeCellBean bean = new dataSendTradeCellBean();
            if (string.IsNullOrEmpty(ctid))
            {
                dataResponseVos = new dataResponseVo();
                dataResponseVos.errcode = "1";
                dataResponseVos.errmsg = "未找到订单";
                return dataResponseVos;
            }
            bean.ShortText1717720509648 = ctid;
            string bizObjectId = checkErpTradeCellAlready(bean);

            if (string.IsNullOrEmpty(bizObjectId))
            {
                dataResponseVos = new dataResponseVo();
                dataResponseVos.errcode = "1";
                dataResponseVos.errmsg = "未找到订单";
                return dataResponseVos;
            }
            map.Add("id", bizObjectId);
            string param = JsonConvert.SerializeObject(new
            {
                schemaCode = "orders_01",
                userId = USER_ID,
                data = map
            });

            try
            {
                string data = httpContent(post_url, param);
                dataResponseVos = JsonConvert.DeserializeObject<dataResponseVo>(data);
                return dataResponseVos;
            }
            catch (Exception ex)
            {
                dataResponseVos = new dataResponseVo();
                dataResponseVos.errcode = "1";
                dataResponseVos.errmsg = ex.Message;
            }
            return dataResponseVos;
        }


        /// <summary>
        /// 子订单数据
        /// </summary>
        /// <param name="bean"></param>
        /// <returns></returns>
        public static dataResponseVo sendErpTradeOrderInfo(dataSendTradeOrderBean bean)
        {
            string post_url = pUrl + "openapi/v3/bo/create";

            string bizObjectId = checkErpTradeOrderAlready(bean);
            if (!string.IsNullOrEmpty(bizObjectId))
            {
                post_url = pUrl + "openapi/v3/bo/update";
                bean.id = bizObjectId;
            }
            string tid_id = checkErpTradeAlready(new dataSendTradeBean(bean.ShortText1724898549414));
            if (!string.IsNullOrEmpty(tid_id))
            {
                bean.RelevanceForm1724898561483 = tid_id;
            }
            string param = JsonConvert.SerializeObject(new
            {
                schemaCode = "zidingdan_01",
                userId = USER_ID,
                data = bean
            });
            dataResponseVo dataResponseVos = null;

            try
            {
                string data = httpContent(post_url, param);
                dataResponseVos = JsonConvert.DeserializeObject<dataResponseVo>(data);
                return dataResponseVos;
            }
            catch (Exception ex)
            {
                dataResponseVos = new dataResponseVo();
                dataResponseVos.errcode = "1";
                dataResponseVos.errmsg = ex.Message;
            }
            return dataResponseVos;
        }
        /// <summary>
        /// 校验子订单是否存在
        /// </summary>
        /// <param name="dataSendOrderBean"></param>
        /// <returns></returns>
        public static string checkErpTradeOrderAlready(dataSendTradeOrderBean dataSendOrderBean)
        {
            try
            {
                string post_url = pUrl + "openapi/v3/bo/list";
                string param = JsonConvert.SerializeObject(new
                {
                    schemaCode = "zidingdan_01",
                    userId = USER_ID,
                    queryCondition = new
                    {
                        operatorType = 1,
                        propertyCode = "ShortText1724898595268",
                        propertyValue = dataSendOrderBean.ShortText1724898595268
                    }
                });
                string data = httpContent(post_url, param);
                dataShopResponseVo dataResponseVos = JsonConvert.DeserializeObject<dataShopResponseVo>(data);
                if (dataResponseVos != null && "0".Equals(dataResponseVos.errcode))
                {
                    if (dataResponseVos.data.bizObjectPage.content.Count > 0)
                    {
                        return dataResponseVos.data.bizObjectPage.content[0].bizObjectId;
                    }
                    return "";
                }
            }
            catch (Exception ex)
            {
            }
            return "";
        }


        static HttpClient client = new HttpClient();

        private static string httpSaleContent(HttpMethod httpMethod, string post_url, Dictionary<string, string> map)
        {
            var request = new HttpRequestMessage
            {
                Method = httpMethod,
                RequestUri = new Uri(post_url),
                Headers =
                {
                    { "token", "Zk2ncXqH8hFyA6Rj"},
                }
            };
            if (map.Keys.Count > 0)
            {
                request.Content = new FormUrlEncodedContent(map);
            }

            var task = Task.Run(() =>
            {
                try
                {
                    var response = client.SendAsync(request).Result;
                    response.EnsureSuccessStatusCode();
                    return response.Content.ReadAsStringAsync().Result;
                }
                catch (Exception ex)
                {
                    return "";
                }

            });

            return task.Result;
        }

        private static string httpContent(string post_url, string content)
        {
            string token = getToken();
            var request = new HttpRequestMessage
            {
                Method = HttpMethod.Post,
                RequestUri = new Uri(post_url),
                Headers =
                {
                    { "Authorization", "Bearer " + token },
                },
                Content = new StringContent(content)
                {
                    Headers =
                    {
                        ContentType = new MediaTypeHeaderValue("application/json")
                    }
                }
            };

            var task = Task.Run(() =>
            {
                try
                {
                    var response = client.SendAsync(request).Result;
                    response.EnsureSuccessStatusCode();
                    return response.Content.ReadAsStringAsync().Result;
                }
                catch (Exception e)
                {
                    return "";
                }


            });

            return task.Result;
        }

    }
}