using System;
using System.Collections.Generic;
using System.Configuration;
using System.Data;
using System.Linq;
using System.Web;
using System.Web.Management;
using Newtonsoft.Json.Linq;
using OperatingData.SDK;

namespace TableDataService.Method
{
    public class DownloadMethod
    {
        #region 方法 -> 数据下发子项 (分页分发)
        public static string DataGeneration(OracleHelper _OracleHelper, string tableName,
            string jsonString, string[] codes, string lastTime, int maxDataQuantity = 4)
        {
            string strBack = string.Empty;
            string strIsServerPart = string.Empty;
            bool isReplaceColumnName = false;
            try
            {
                strIsServerPart = ConfigurationManager.AppSettings["IsServerPart"].ToString();
            }
            catch
            {
                strIsServerPart = "1";
            }
            int minimum = (string.IsNullOrWhiteSpace(codes[5]) ? 0 : (int.Parse(codes[5]) - 1)) * 100 * maxDataQuantity; //默认分页启始值
            int maximum = (string.IsNullOrWhiteSpace(codes[5]) ? 1 : int.Parse(codes[5])) * 100 * maxDataQuantity;       //默认分页结束值
            DataSet _Data = null;
            //从Cache中读取服务区门店信息数据
            List<Model.ServerpartShopModel> _ServerpartShopList =
                (List<Model.ServerpartShopModel>)WebService.SDK.CacheHelper.Get("ServerpartShopList");
            if (_ServerpartShopList == null)
            {
                _ServerpartShopList = new List<Model.ServerpartShopModel>();
            }
            //检查当前服务区门店参数是否存在于Cache
            if (_ServerpartShopList.FindAll(p => p.ServerpartCode == codes[0] && p.ShopCode == codes[1]).Count == 0)
            {
                //不存在时从数据库读取一次信息并保存至Cache，并设定每30分钟刷新一次
                _ServerpartShopList = Newtonsoft.Json.JsonConvert.DeserializeObject<List<Model.ServerpartShopModel>>(
                    Newtonsoft.Json.JsonConvert.SerializeObject(_OracleHelper.ExcuteSqlGetDataSet(
                        @"SELECT TO_CHAR(A.PROVINCE_CODE) as ProvinceCode,
                            A.SERVERPART_CODE as ServerpartCode,
                            TO_CHAR(B.SERVERPARTSHOP_ID) as ServerpartShopID,
                            B.SHOPCODE as ShopCode,B.BUSINESSTYPE as BusinessType,
                            TO_CHAR(NVL(B.UNIFORM_TYPE,1)) as UniformType,
                            TO_CHAR(B.SERVERPARTSHOP_STATE) as ServerpartShopState
                        FROM HIGHWAY_EXCHANGE.T_SERVERPART A,
                            HIGHWAY_EXCHANGE.T_SHOPMESSAGE_EX B
                        WHERE A.SERVERPART_CODE = B.SERVERPART_CODE AND 
                            B.SHOPCODE IS NOT NULL").Tables[0]));
                if (_ServerpartShopList.Count == 0)
                {
                    _ServerpartShopList = Newtonsoft.Json.JsonConvert.DeserializeObject<List<Model.ServerpartShopModel>>(
                        Newtonsoft.Json.JsonConvert.SerializeObject(_OracleHelper.ExcuteSqlGetDataSet(
                            @"SELECT TO_CHAR(A.PROVINCE_CODE) as ProvinceCode,
                                A.SERVERPARTCODE as ServerpartCode,
                                TO_CHAR(B.SERVERPARTSHOP_ID) as ServerpartShopID,
                                B.SHOPCODE as ShopCode,B.BUSINESSTYPE as BusinessType,
                                '1' as UniformType,TO_CHAR(B.VALID) as ServerpartShopState
                            FROM HIGHWAY_EXCHANGE.T_SYSCODE A,
                                HIGHWAY_EXCHANGE.T_SHOPMESSAGE B
                            WHERE A.SERVERPARTCODE = B.SERVERPARTCODE AND 
                                B.SHOPCODE IS NOT NULL").Tables[0]));
                }
                WebService.SDK.CacheHelper.Set("ServerpartShopList", _ServerpartShopList, DateTime.Now.AddMinutes(30));
            }
            //从Cache读取当前门店参数，用于获取数据使用
            Model.ServerpartShopModel _ServerpartShop = _ServerpartShopList.Find(p => p.ServerpartCode == codes[0] && p.ShopCode == codes[1]);
            try
            {
                switch (tableName)
                {
                    case "HIGHWAY_EXCHANGE.T_DOWNUPDATE"://单表更新检查

                        #region HIGHWAY_EXCHANGE.T_DOWNUPDATE
                        if (!string.IsNullOrWhiteSpace(codes[6]))
                        {
                            string _TableName = codes[6];
                            switch (_TableName)
                            {
                                case "HIGHWAY_EXCHANGE.T_COMMODITYEX_UNIT":
                                case "HIGHWAY_EXCHANGE.T_COMMODITYEX_INEFFECTIVE_UNIT":
                                    _TableName = "HIGHWAY_EXCHANGE.T_COMMODITYEX_UNIT";
                                    break;
                                case "HIGHWAY_EXCHANGE.T_COMMODITYEX_CLOUD":
                                case "HIGHWAY_EXCHANGE.T_COMMODITYEX_INEFFECTIVE_CLOUD":
                                    _TableName = "HIGHWAY_EXCHANGE.T_COMMODITYEX_CLOUD";
                                    break;
                            }
                            //_Data = _OracleHelper.ExcuteSqlGetDataSet(
                            //    $@"SELECT * FROM HIGHWAY_EXCHANGE.T_DOWNUPDATE 
                            //        WHERE  {(codes[6] == "HIGHWAY_EXCHANGE.T_COMMODITYEX" ? " 1 = 0" :
                            //        $" SERVERPARTCODE = '{codes[0]}' AND TABLENAME = '{_TableName}'")}");
                            _Data = _OracleHelper.ExcuteSqlGetDataSet(
                                $@"SELECT B.SERVERPART_CODE AS SERVERPARTCODE,A.TABLENAME,
                                    MAX(A.VERSIONUPDATE_DATE) AS VERSIONUPDATE_DATE 
                                FROM HIGHWAY_EXCHANGE.T_DOWNUPDATE A,
                                    HIGHWAY_EXCHANGE.T_SERVERPART B
                                WHERE (A.SERVERPARTCODE = B.SERVERPART_CODE OR 
                                    A.SERVERPARTCODE = B.PROVINCE_CODE) AND 
	                                B.SERVERPART_CODE = '{codes[0]}' AND A.TABLENAME = '{_TableName}'
                                GROUP BY B.SERVERPART_CODE,A.TABLENAME");
                            if (_Data != null && _Data.Tables[0].Rows.Count == 0)
                            {
                                DataRow _DataRow = _Data.Tables[0].NewRow();
                                _DataRow["SERVERPARTCODE"] = codes[0];
                                _DataRow["TABLENAME"] = codes[6];
                                if (codes[6] == "HIGHWAY_EXCHANGE.T_COMMODITYEX")
                                {
                                    try
                                    {
                                        _DataRow["VERSIONUPDATE_DATE"] = _OracleHelper.ExcuteSqlGetDataSet(
                                            $@"SELECT MAX(DOWNLOADDATE) AS DOWNLOADDATE
                                            FROM HIGHWAY_EXCHANGE.T_COMMODITYEX 
                                            WHERE SERVERPARTSHOP_ID = {codes[2]}").Tables[0].Rows[0]["DOWNLOADDATE"].ToString();
                                    }
                                    catch
                                    {
                                        _DataRow["VERSIONUPDATE_DATE"] = DateTime.Now;
                                    }
                                }
                                else
                                {
                                    _DataRow["VERSIONUPDATE_DATE"] = DateTime.Now;
                                }
                                _Data.Tables[0].Rows.Add(_DataRow);
                            }
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"缺少预下发表名\",\"rows\":[]}";
                            break;
                        }

                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_DOWNUPDATE_ALL"://批量更新检查
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT B.SERVERPART_CODE AS SERVERPARTCODE,A.TABLENAME,
                                    MAX(A.VERSIONUPDATE_DATE) AS VERSIONUPDATE_DATE 
                                FROM HIGHWAY_EXCHANGE.T_DOWNUPDATE A,
                                    HIGHWAY_EXCHANGE.T_SERVERPART B
                                WHERE (A.SERVERPARTCODE = B.SERVERPART_CODE OR 
                                    A.SERVERPARTCODE = B.PROVINCE_CODE) AND 
	                                B.SERVERPART_CODE = '{_ServerpartShop.ServerpartCode}' 
                                GROUP BY B.SERVERPART_CODE,A.TABLENAME");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        break;
                    case "HIGHWAY_EXCHANGE.T_ADVERTISING":
                        #region HIGHWAY_EXCHANGE.T_ADVERTISING
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(string.Format(
                            @"SELECT * FROM (SELECT ROWNUM AS rowno,t.*
                                    FROM HIGHWAY_EXCHANGE.T_ADVERTISING t
                                    WHERE SERVERPARTCODE = '{0}' AND SHOPCODE = '{1}' AND ROWNUM <= {2}) table_alias
                                WHERE table_alias.rowno > {3}", codes[0], codes[1], maximum, minimum));
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_CONFIGURATION":

                        #region HIGHWAY_EXCHANGE.T_CONFIGURATION
                        //优先通过新的门店表数据源读取收银机配置数据
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT CONFIGURATION_ID,CONFIGURATION_DATE,SERVERPARTCODE,
                                    SHOPCODE,MACHINECODE,MACADDRESS,CONFIGURATION_NAME,
                                    CONFIGURATION_VALUES,CONFIGURATION_DESC,FLAG
                                FROM (SELECT ROWNUM AS RN,T.* 
                                    FROM (SELECT D.* FROM (
                                        SELECT A.BUSINESSCONFIG_ID AS CONFIGURATION_ID,A.CONFIGURATION_DATE,
                                            A.SERVERPARTCODE,B.SHOPCODE,'{codes[3]}' AS MACHINECODE,
                                            '{codes[4]}' AS MACADDRESS,A.CONFIGURATION_NAME,
                                            A.CONFIGURATION_VALUES,NULL AS CONFIGURATION_DESC,NULL AS FLAG
                                        FROM HIGHWAY_EXCHANGE.T_BUSINESSCONFIG A,
                                            HIGHWAY_EXCHANGE.T_SHOPMESSAGE_EX B
                                        WHERE A.BUSINESSTYPE = B.BUSINESSTYPE AND A.SERVERPARTCODE = B.SERVERPART_CODE AND 
                                            B.SERVERPART_CODE = '{codes[0]}' AND B.SERVERPARTSHOP_ID = {codes[2]}
                                    UNION ALL
                                        SELECT C.CONFIGURATION_ID,C.CONFIGURATION_DATE,C.SERVERPARTCODE,
                                            C.SHOPCODE,C.MACHINECODE,C.MACADDRESS,C.CONFIGURATION_NAME,
                                            C.CONFIGURATION_VALUES,C.CONFIGURATION_DESC,C.FLAG
                                        FROM HIGHWAY_EXCHANGE.T_CONFIGURATION C
                                        WHERE UPPER(C.CONFIGURATION_NAME) NOT IN ('SERVER_CONNAME',
                                            'SERVER_DBPASS','SERVER_DBUSER','SERVER_DBNAME','SERVER_DBPORT',
                                            'SERVER_IP','SERVICE_PORT','SERVICE_PORT2','SERVICE_PORT3',
                                            'SERVICE_PORT4','SERVICE_PORT5','MOBILEPAYOPERATORS','DATASERVICEPORT') AND 
                                            C.MACADDRESS = '{codes[4]}' AND NOT EXISTS (SELECT 1
                                            FROM HIGHWAY_EXCHANGE.T_BUSINESSCONFIG A,
                                                HIGHWAY_EXCHANGE.T_SHOPMESSAGE_EX B
                                            WHERE A.BUSINESSTYPE = B.BUSINESSTYPE AND 
                                                UPPER(A.CONFIGURATION_NAME) = UPPER(C.CONFIGURATION_NAME) AND 
                                                B.SERVERPART_CODE = '{codes[0]}' AND B.SERVERPARTSHOP_ID = {codes[2]})) D
                                        ORDER BY D.CONFIGURATION_NAME )T
                                    WHERE ROWNUM < {maximum})
                                WHERE RN > {minimum}");
                        //判断新数据源是否正常读取数据，如果没有读取到数据，代表当前服务区未更换接口传输模式，仍使用原数据源获取信息
                        if (_Data == null || _Data.Tables[0].Rows.Count == 0)
                        {
                            try
                            {
                                if (_OracleHelper.ExcuteSqlGetDataSet(
                                    @"SELECT 1 FROM ALL_TAB_COLUMNS 
                                    WHERE OWNER = 'HIGHWAY_EXCHANGE' AND 
                                        TABLE_NAME = 'T_SHOPMESSAGE' AND 
                                        COLUMN_NAME = 'SERVERPART_CODE'").Tables[0].Rows.Count > 0)
                                {
                                    isReplaceColumnName = true;
                                }
                            }
                            catch { }
                            if (isReplaceColumnName)
                            {
                                _Data = _OracleHelper.ExcuteSqlGetDataSet(
                                    $@"SELECT CONFIGURATION_ID,CONFIGURATION_DATE,SERVERPARTCODE,
                                        SHOPCODE,MACHINECODE,MACADDRESS,CONFIGURATION_NAME,
                                        CONFIGURATION_VALUES,CONFIGURATION_DESC,FLAG
                                    FROM (SELECT ROWNUM AS RN,T.* 
                                        FROM (SELECT D.* FROM (
                                            SELECT A.BUSINESSCONFIG_ID AS CONFIGURATION_ID,A.CONFIGURATION_DATE,
                                                A.SERVERPARTCODE,B.SHOPCODE,'{codes[3]}' AS MACHINECODE,
                                                '{codes[4]}' AS MACADDRESS,A.CONFIGURATION_NAME,
                                                A.CONFIGURATION_VALUES,NULL AS CONFIGURATION_DESC,NULL AS FLAG
                                            FROM HIGHWAY_EXCHANGE.T_BUSINESSCONFIG A,
                                                HIGHWAY_EXCHANGE.T_SHOPMESSAGE B
                                            WHERE A.BUSINESSTYPE = B.BUSINESSTYPE AND A.SERVERPARTCODE = B.SERVERPART_CODE AND 
                                                B.SERVERPART_CODE = '{codes[0]}' AND B.SERVERPARTSHOP_ID = {codes[2]}
                                        UNION ALL
                                            SELECT C.CONFIGURATION_ID,C.CONFIGURATION_DATE,C.SERVERPARTCODE,
                                                C.SHOPCODE,C.MACHINECODE,C.MACADDRESS,C.CONFIGURATION_NAME,
                                                C.CONFIGURATION_VALUES,C.CONFIGURATION_DESC,C.FLAG
                                            FROM HIGHWAY_EXCHANGE.T_CONFIGURATION C
                                            WHERE UPPER(C.CONFIGURATION_NAME) NOT IN ('SERVER_CONNAME',
                                                'SERVER_DBPASS','SERVER_DBUSER','SERVER_DBNAME','SERVER_DBPORT',
                                                'SERVER_IP','SERVICE_PORT','SERVICE_PORT2','SERVICE_PORT3',
                                                'SERVICE_PORT4','SERVICE_PORT5','MOBILEPAYOPERATORS','DATASERVICEPORT') AND 
                                                C.MACADDRESS = '{codes[4]}' AND NOT EXISTS (SELECT 1
                                                FROM HIGHWAY_EXCHANGE.T_BUSINESSCONFIG A,
                                                    HIGHWAY_EXCHANGE.T_SHOPMESSAGE B
                                                WHERE A.BUSINESSTYPE = B.BUSINESSTYPE AND 
                                                    UPPER(A.CONFIGURATION_NAME) = UPPER(C.CONFIGURATION_NAME) AND 
                                                    B.SERVERPART_CODE = '{codes[0]}' AND B.SERVERPARTSHOP_ID = {codes[2]})) D
                                            ORDER BY D.CONFIGURATION_NAME )T
                                        WHERE ROWNUM < {maximum})
                                    WHERE RN > {minimum}");
                            }
                            else
                            {
                                _Data = _OracleHelper.ExcuteSqlGetDataSet(
                                    $@"SELECT CONFIGURATION_ID,CONFIGURATION_DATE,SERVERPARTCODE,
                                        SHOPCODE,MACHINECODE,MACADDRESS,CONFIGURATION_NAME,
                                        CONFIGURATION_VALUES,CONFIGURATION_DESC,FLAG
                                    FROM (SELECT ROWNUM AS RN,T.* 
                                        FROM (SELECT D.* FROM (
                                            SELECT A.BUSINESSCONFIG_ID AS CONFIGURATION_ID,A.CONFIGURATION_DATE,
                                                A.SERVERPARTCODE,B.SHOPCODE,'{codes[3]}' AS MACHINECODE,
                                                '{codes[4]}' AS MACADDRESS,A.CONFIGURATION_NAME,
                                                A.CONFIGURATION_VALUES,NULL AS CONFIGURATION_DESC,NULL AS FLAG
                                            FROM HIGHWAY_EXCHANGE.T_BUSINESSCONFIG A,
                                                HIGHWAY_EXCHANGE.T_SHOPMESSAGE B
                                            WHERE A.BUSINESSTYPE = B.BUSINESSTYPE AND A.SERVERPARTCODE = B.SERVERPARTCODE AND 
                                                B.SERVERPARTCODE = '{codes[0]}' AND B.SERVERPARTSHOP_ID = {codes[2]}
                                        UNION ALL
                                            SELECT C.CONFIGURATION_ID,C.CONFIGURATION_DATE,C.SERVERPARTCODE,
                                                C.SHOPCODE,C.MACHINECODE,C.MACADDRESS,C.CONFIGURATION_NAME,
                                                C.CONFIGURATION_VALUES,C.CONFIGURATION_DESC,C.FLAG
                                            FROM HIGHWAY_EXCHANGE.T_CONFIGURATION C
                                            WHERE UPPER(C.CONFIGURATION_NAME) NOT IN ('SERVER_CONNAME',
                                                'SERVER_DBPASS','SERVER_DBUSER','SERVER_DBNAME','SERVER_DBPORT',
                                                'SERVER_IP','SERVICE_PORT','SERVICE_PORT2','SERVICE_PORT3',
                                                'SERVICE_PORT4','SERVICE_PORT5','MOBILEPAYOPERATORS','DATASERVICEPORT') AND 
                                                C.MACADDRESS = '{codes[4]}' AND NOT EXISTS (SELECT 1
                                                FROM HIGHWAY_EXCHANGE.T_BUSINESSCONFIG A,
                                                    HIGHWAY_EXCHANGE.T_SHOPMESSAGE B
                                                WHERE A.BUSINESSTYPE = B.BUSINESSTYPE AND 
                                                    UPPER(A.CONFIGURATION_NAME) = UPPER(C.CONFIGURATION_NAME) AND 
                                                    B.SERVERPARTCODE = '{codes[0]}' AND B.SERVERPARTSHOP_ID = {codes[2]})) D
                                            ORDER BY D.CONFIGURATION_NAME )T
                                        WHERE ROWNUM < {maximum})
                                    WHERE RN > {minimum}");
                            }
                        }
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;

                    case "HIGHWAY_EXCHANGE.T_USERDEFINEDTYPE":

                        #region HIGHWAY_EXCHANGE.T_USERDEFINEDTYPE（已被新的下发规则替代，因兼容未更新的系统版本，此部分暂时保留）

                        _Data = _OracleHelper.ExcuteSqlGetDataSet(string.Format(
                            @"SELECT * FROM (SELECT ROWNUM AS rowno, t.* 
                                FROM HIGHWAY_EXCHANGE.T_USERDEFINEDTYPE t 
                                WHERE SERVERPARTCODE = '{0}' AND BUSINESSTYPE IN 
                                    ( SELECT BUSINESSTYPE FROM HIGHWAY_EXCHANGE.T_SHOPMESSAGE 
                                    WHERE SERVERPARTSHOP_ID = {1} ) AND ROWNUM <= {2}) table_alias
                             WHERE table_alias.rowno > {3} ", codes[0], codes[2], maximum, minimum));
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_USERDEFINEDTYPE_UNIT":
                        #region 数据源：HIGHWAY_EXCHANGE.T_USERDEFINEDTYPE_UNIT中 DATA_SOURCE=0的数据
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT USERDEFINEDTYPE_ID,USERDEFINEDTYPE_PID,
                                USERDEFINEDTYPE_NAME,SERVERPARTCODE,SERVERPARTSHOP_ID,
                                BUSINESSTYPE,USERDEFINEDTYPE_DATE,USERDEFINEDTYPE_INDEX
                            FROM (SELECT ROWNUM AS RN,T.*
                                FROM (SELECT A.USERDEFINEDTYPE_ID,A.USERDEFINEDTYPE_PID,
                                        A.USERDEFINEDTYPE_NAME,A.SERVERPARTCODE,A.SERVERPARTSHOP_ID,
                                        A.BUSINESSTYPE,A.USERDEFINEDTYPE_DATE,A.USERDEFINEDTYPE_INDEX
                                    FROM HIGHWAY_EXCHANGE.T_USERDEFINEDTYPE A
                                    WHERE A.SERVERPARTCODE = '{_ServerpartShop.ServerpartCode}' AND 
                                        A.BUSINESSTYPE = '{_ServerpartShop.BusinessType}' AND A.DATA_SOURCE = 0 
                                    ORDER BY A.USERDEFINEDTYPE_ID) T
                                WHERE ROWNUM <= {maximum} )
                            WHERE RN > {minimum} ");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_USERDEFINEDTYPE_CLOUD":
                        #region 数据源：HIGHWAY_EXCHANGE.T_USERDEFINEDTYPE_UNIT中 DATA_SOURCE=1的数据
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT USERDEFINEDTYPE_ID,USERDEFINEDTYPE_PID,
                                USERDEFINEDTYPE_NAME,SERVERPARTCODE,SERVERPARTSHOP_ID,
                                BUSINESSTYPE,USERDEFINEDTYPE_DATE,USERDEFINEDTYPE_INDEX
                            FROM (SELECT ROWNUM AS RN,T.*
                                FROM (SELECT A.USERDEFINEDTYPE_ID,A.USERDEFINEDTYPE_PID,
                                        A.USERDEFINEDTYPE_NAME,A.SERVERPARTCODE,A.SERVERPARTSHOP_ID,
                                        A.BUSINESSTYPE,A.USERDEFINEDTYPE_DATE,A.USERDEFINEDTYPE_INDEX
                                    FROM HIGHWAY_EXCHANGE.T_USERDEFINEDTYPE A
                                    WHERE A.SERVERPARTCODE = '{_ServerpartShop.ServerpartCode}' AND 
                                        A.BUSINESSTYPE = '{_ServerpartShop.BusinessType}' AND A.DATA_SOURCE = 1 
                                    ORDER BY A.USERDEFINEDTYPE_ID) T
                                WHERE ROWNUM <= {maximum} )
                            WHERE RN > {minimum} ");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_COMMODITYEX":

                        #region HIGHWAY_EXCHANGE.T_COMMODITYEX
                        //_Data = _OracleHelper.ExcuteSqlGetDataSet(string.Format(
                        //    @"SELECT COMMODITYEX_ID,SERVERPARTCODE,COMMODITY_TYPE,
                        //        COMMODITY_CODE,COMMODITY_BARCODE,COMMODITY_NAME,
                        //        COMMODITY_RULE,COMMODITY_UNIT,COMMODITY_RETAILPRICE,
                        //        COMMODITY_MEMBERPRICE,CANCHANGEPRICE,ISVALID,COMMODITY_EN,
                        //        ISBULK,METERINGMETHOD,DOWNLOADDATE,FLAG,BUSINESSTYPE,
                        //        SERVERPARTSHOP_ID,GUARANTEE_DAY,REMINDER_DAY,COMMODITY_SYMBOL,
                        //        COMMODITY_HOTKEY,USERDEFINEDTYPE_ID,0 AS TRANSFER_STATE,CONTAINER_CODE
                        //    FROM (SELECT ROWNUM AS rowno, t.* FROM  HIGHWAY_EXCHANGE.T_COMMODITYEX t
                        //        WHERE SERVERPARTCODE = '{0}' AND SERVERPARTSHOP_ID = {1} AND ROWNUM <= {2}) table_alias
                        //WHERE table_alias.rowno > {3} ", codes[0], codes[2], maximum, minimum));
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT COMMODITYEX_ID,SERVERPARTCODE,COMMODITY_TYPE,
	                            COMMODITY_CODE,COMMODITY_BARCODE,COMMODITY_NAME,
	                            COMMODITY_RULE,COMMODITY_UNIT,COMMODITY_RETAILPRICE,
	                            COMMODITY_MEMBERPRICE,CANCHANGEPRICE,ISVALID,COMMODITY_EN,
	                            ISBULK,METERINGMETHOD,DOWNLOADDATE,FLAG,BUSINESSTYPE,
	                            SERVERPARTSHOP_ID,GUARANTEE_DAY,REMINDER_DAY,COMMODITY_SYMBOL,
	                            COMMODITY_HOTKEY,USERDEFINEDTYPE_ID,0 AS TRANSFER_STATE,CONTAINER_CODE
                            FROM (	SELECT ROWNUM AS RN, T.* 
	                            FROM (SELECT A.COMMODITYEX_ID,A.SERVERPARTCODE,A.COMMODITY_TYPE,
		                                A.COMMODITY_CODE,A.COMMODITY_BARCODE,A.COMMODITY_NAME,
		                                A.COMMODITY_RULE,A.COMMODITY_UNIT,A.COMMODITY_RETAILPRICE,
		                                A.COMMODITY_MEMBERPRICE,A.CANCHANGEPRICE,A.ISVALID,A.COMMODITY_EN,
		                                A.ISBULK,A.METERINGMETHOD,A.DOWNLOADDATE,A.FLAG,A.BUSINESSTYPE,
		                                A.SERVERPARTSHOP_ID,A.GUARANTEE_DAY,A.REMINDER_DAY,A.COMMODITY_SYMBOL,
		                                NVL(B.HOTKEY,A.COMMODITY_HOTKEY) AS COMMODITY_HOTKEY,
                                        A.USERDEFINEDTYPE_ID,A.CONTAINER_CODE 
	                                FROM HIGHWAY_EXCHANGE.T_COMMODITYEX A
                                        LEFT JOIN HIGHWAY_EXCHANGE.T_HOTKEYSET B 
                                        ON A.SERVERPARTCODE = B.SERVERPARTCODE AND 
                                            A.BUSINESSTYPE = B.BUSINESSTYPE AND 
                                            A.COMMODITY_BARCODE = B.COMMODITY_BARCODE AND B.VALID = 1
	                                WHERE A.SERVERPARTCODE = '{codes[0]}' AND A.SERVERPARTSHOP_ID = {codes[2]} 
                                    ORDER BY A.COMMODITYEX_ID) T
                                WHERE  ROWNUM <= {maximum} )
                            WHERE RN > {minimum} ");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_COMMODITYEX_UNIT":
                        #region 数据源：HIGHWAY_EXCHANGE.T_COMMODITYEX_EX 中 DATA_SOURCE=0 的数据
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT COMMODITYEX_ID,SERVERPARTCODE,COMMODITY_TYPE,
                                COMMODITY_CODE,COMMODITY_BARCODE,COMMODITY_NAME,
                                COMMODITY_RULE,COMMODITY_UNIT,COMMODITY_RETAILPRICE,
                                COMMODITY_MEMBERPRICE,CANCHANGEPRICE,ISVALID,
                                COMMODITY_EN,ISBULK,METERINGMETHOD,DOWNLOADDATE,
                                FLAG,BUSINESSTYPE,SERVERPARTSHOP_ID,COMMODITY_SYMBOL,
                                COMMODITY_HOTKEY,USERDEFINEDTYPE_ID,REMINDER_DAY,
                                GUARANTEE_DAY,COMMODITY_TYPECODE,0 AS TRANSFER_STATE,CONTAINER_CODE
                            FROM (SELECT ROWNUM AS RN,T.*
                                FROM (SELECT A.COMMODITY_ID AS COMMODITYEX_ID,'{codes[0]}' AS SERVERPARTCODE,
                                        A.COMMODITY_TYPENAME AS COMMODITY_TYPE,A.COMMODITY_CODE,
                                        A.COMMODITY_BARCODE,A.COMMODITY_NAME,A.COMMODITY_RULE,
                                        A.COMMODITY_UNIT,A.COMMODITY_RETAILPRICE,A.COMMODITY_MEMBERPRICE,
                                        A.CANCHANGEPRICE,A.COMMODITY_STATE AS ISVALID,A.COMMODITY_EN,
                                        1 AS ISBULK,A.METERINGMETHOD,A.OPERATE_DATE AS DOWNLOADDATE,
                                        0 AS FLAG,A.BUSINESSTYPE,'{codes[2]}' AS SERVERPARTSHOP_ID,
                                        A.COMMODITY_SYMBOL,A.COMMODITY_HOTKEY,A.USERDEFINEDTYPE_ID,
                                        A.REMINDER_DAY,A.GUARANTEE_DAY,A.COMMODITY_TYPECODE,A.CONTAINER_CODE
                                    FROM HIGHWAY_EXCHANGE.T_COMMODITYEX_EX A
                                    WHERE A.DATA_SOURCE = 0 AND TRUNC(A.OPERATE_DATE) <= TRUNC(SYSDATE) AND 
                                        A.BUSINESSTYPE = {_ServerpartShop.BusinessType} AND A.COMMODITY_CODE IS NOT NULL AND
                                        (A.SERVERPARTCODE = '{codes[0]}' {(_ServerpartShop.UniformType == "1" ?
                                        $" OR A.SERVERPARTCODE = '{_ServerpartShop.ProvinceCode}'" : "")} )
                                    ORDER BY COMMODITY_ID) T
                                WHERE ROWNUM <= {maximum} )
                            WHERE RN > {minimum} ");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;

                    case "HIGHWAY_EXCHANGE.T_COMMODITYEX_CLOUD":
                        #region 数据源：HIGHWAY_EXCHANGE.T_COMMODITYEX_EX 中 DATA_SOURCE=1 的数据
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT COMMODITYEX_ID,SERVERPARTCODE,COMMODITY_TYPE,
                                COMMODITY_CODE,COMMODITY_BARCODE,COMMODITY_NAME,
                                COMMODITY_RULE,COMMODITY_UNIT,COMMODITY_RETAILPRICE,
                                COMMODITY_MEMBERPRICE,CANCHANGEPRICE,ISVALID,
                                COMMODITY_EN,ISBULK,METERINGMETHOD,DOWNLOADDATE,
                                FLAG,BUSINESSTYPE,SERVERPARTSHOP_ID,COMMODITY_SYMBOL,
                                COMMODITY_HOTKEY,USERDEFINEDTYPE_ID,REMINDER_DAY,
                                GUARANTEE_DAY,COMMODITY_TYPECODE,0 AS TRANSFER_STATE,CONTAINER_CODE
                            FROM (SELECT ROWNUM AS RN,T.*
                                FROM (SELECT A.COMMODITY_ID AS COMMODITYEX_ID,'{codes[0]}' AS SERVERPARTCODE,
                                        A.COMMODITY_TYPENAME AS COMMODITY_TYPE,A.COMMODITY_CODE,
                                        A.COMMODITY_BARCODE,A.COMMODITY_NAME,A.COMMODITY_RULE,
                                        A.COMMODITY_UNIT,A.COMMODITY_RETAILPRICE,A.COMMODITY_MEMBERPRICE,
                                        A.CANCHANGEPRICE,A.COMMODITY_STATE AS ISVALID,A.COMMODITY_EN,
                                        1 AS ISBULK,A.METERINGMETHOD,A.OPERATE_DATE AS DOWNLOADDATE,
                                        0 AS FLAG,A.BUSINESSTYPE,'{codes[2]}' AS SERVERPARTSHOP_ID,
                                        A.COMMODITY_SYMBOL,A.COMMODITY_HOTKEY,A.USERDEFINEDTYPE_ID,
                                        A.REMINDER_DAY,A.GUARANTEE_DAY,A.COMMODITY_TYPECODE,A.CONTAINER_CODE
                                    FROM HIGHWAY_EXCHANGE.T_COMMODITYEX_EX A
                                    WHERE A.DATA_SOURCE = 1 AND TRUNC(A.OPERATE_DATE) <= TRUNC(SYSDATE) AND 
                                        A.BUSINESSTYPE = {_ServerpartShop.BusinessType} AND A.COMMODITY_CODE IS NOT NULL AND
                                        (A.SERVERPARTCODE = '{codes[0]}' {(_ServerpartShop.UniformType == "1" ?
                                        $" OR A.SERVERPARTCODE = '{_ServerpartShop.ProvinceCode}'" : "")} )
                                    ORDER BY COMMODITY_ID) T
                                WHERE ROWNUM <= {maximum} )
                            WHERE RN > {minimum} ");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;

                    case "HIGHWAY_EXCHANGE.T_COMMODITYEX_INEFFECTIVE_UNIT":
                        #region 数据源：HIGHWAY_EXCHANGE.T_COMMODITYEX_EX 中 DATA_SOURCE=0 且生效时间大于当天的数据
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT COMMODITYEX_ID,SERVERPARTCODE,COMMODITY_TYPE,
                                COMMODITY_CODE,COMMODITY_BARCODE,COMMODITY_NAME,
                                COMMODITY_RULE,COMMODITY_UNIT,COMMODITY_RETAILPRICE,
                                COMMODITY_MEMBERPRICE,CANCHANGEPRICE,ISVALID,
                                COMMODITY_EN,ISBULK,METERINGMETHOD,DOWNLOADDATE,
                                FLAG,BUSINESSTYPE,SERVERPARTSHOP_ID,COMMODITY_SYMBOL,
                                COMMODITY_HOTKEY,USERDEFINEDTYPE_ID,REMINDER_DAY,
                                GUARANTEE_DAY,COMMODITY_TYPECODE,0 AS TRANSFER_STATE,CONTAINER_CODE
                            FROM (SELECT ROWNUM AS RN,T.*
                                FROM (SELECT A.COMMODITY_ID AS COMMODITYEX_ID,'{codes[0]}' AS SERVERPARTCODE,
                                        A.COMMODITY_TYPENAME AS COMMODITY_TYPE,A.COMMODITY_CODE,
                                        A.COMMODITY_BARCODE,A.COMMODITY_NAME,A.COMMODITY_RULE,
                                        A.COMMODITY_UNIT,A.COMMODITY_RETAILPRICE,A.COMMODITY_MEMBERPRICE,
                                        A.CANCHANGEPRICE,A.COMMODITY_STATE AS ISVALID,A.COMMODITY_EN,
                                        1 AS ISBULK,A.METERINGMETHOD,A.OPERATE_DATE AS DOWNLOADDATE,
                                        0 AS FLAG,A.BUSINESSTYPE,'{codes[2]}' AS SERVERPARTSHOP_ID,
                                        A.COMMODITY_SYMBOL,A.COMMODITY_HOTKEY,A.USERDEFINEDTYPE_ID,
                                        A.REMINDER_DAY,A.GUARANTEE_DAY,A.COMMODITY_TYPECODE,A.CONTAINER_CODE
                                    FROM HIGHWAY_EXCHANGE.T_COMMODITYEX_EX A
                                    WHERE A.DATA_SOURCE = 0 AND {(string.IsNullOrWhiteSpace(lastTime) ? " " :
                                    $" A.OPERATE_DATE > TO_DATE('{lastTime}','YYYY/MM/DD HH24:MI:SS') AND ")}
                                        A.BUSINESSTYPE = {_ServerpartShop.BusinessType} AND A.COMMODITY_CODE IS NOT NULL AND
                                        (A.SERVERPARTCODE = '{codes[0]}' {(_ServerpartShop.UniformType == "1" ?
                                        $" OR A.SERVERPARTCODE = '{_ServerpartShop.ProvinceCode}'" : "")} )
                                    ORDER BY COMMODITY_ID) T
                                WHERE ROWNUM <= {maximum} )
                            WHERE RN > {minimum} ");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;

                    case "HIGHWAY_EXCHANGE.T_COMMODITYEX_INEFFECTIVE_CLOUD":
                        #region 数据源：HIGHWAY_EXCHANGE.T_COMMODITYEX_EX 中 DATA_SOURCE=1 且生效时间大于当天的数据
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT COMMODITYEX_ID,SERVERPARTCODE,COMMODITY_TYPE,
                                COMMODITY_CODE,COMMODITY_BARCODE,COMMODITY_NAME,
                                COMMODITY_RULE,COMMODITY_UNIT,COMMODITY_RETAILPRICE,
                                COMMODITY_MEMBERPRICE,CANCHANGEPRICE,ISVALID,
                                COMMODITY_EN,ISBULK,METERINGMETHOD,DOWNLOADDATE,
                                FLAG,BUSINESSTYPE,SERVERPARTSHOP_ID,COMMODITY_SYMBOL,
                                COMMODITY_HOTKEY,USERDEFINEDTYPE_ID,REMINDER_DAY,
                                GUARANTEE_DAY,COMMODITY_TYPECODE,0 AS TRANSFER_STATE,CONTAINER_CODE
                            FROM (SELECT ROWNUM AS RN,T.*
                                FROM (SELECT A.COMMODITY_ID AS COMMODITYEX_ID,'{codes[0]}' AS SERVERPARTCODE,
                                        A.COMMODITY_TYPENAME AS COMMODITY_TYPE,A.COMMODITY_CODE,
                                        A.COMMODITY_BARCODE,A.COMMODITY_NAME,A.COMMODITY_RULE,
                                        A.COMMODITY_UNIT,A.COMMODITY_RETAILPRICE,A.COMMODITY_MEMBERPRICE,
                                        A.CANCHANGEPRICE,A.COMMODITY_STATE AS ISVALID,A.COMMODITY_EN,
                                        1 AS ISBULK,A.METERINGMETHOD,A.OPERATE_DATE AS DOWNLOADDATE,
                                        0 AS FLAG,A.BUSINESSTYPE,'{codes[2]}' AS SERVERPARTSHOP_ID,
                                        A.COMMODITY_SYMBOL,A.COMMODITY_HOTKEY,A.USERDEFINEDTYPE_ID,
                                        A.REMINDER_DAY,A.GUARANTEE_DAY,A.COMMODITY_TYPECODE,A.CONTAINER_CODE
                                    FROM HIGHWAY_EXCHANGE.T_COMMODITYEX_EX A
                                    WHERE A.DATA_SOURCE = 1 AND {(string.IsNullOrWhiteSpace(lastTime) ? " " :
                                    $" A.OPERATE_DATE > TO_DATE('{lastTime}','YYYY/MM/DD HH24:MI:SS') AND ")} 
                                        A.BUSINESSTYPE = {_ServerpartShop.BusinessType} AND A.COMMODITY_CODE IS NOT NULL AND
                                        (A.SERVERPARTCODE = '{codes[0]}' {(_ServerpartShop.UniformType == "1" ?
                                        $" OR A.SERVERPARTCODE = '{_ServerpartShop.ProvinceCode}'" : "")} )
                                    ORDER BY COMMODITY_ID) T
                                WHERE ROWNUM <= {maximum} )
                            WHERE RN > {minimum} ");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_ICCARDINFO":

                        #region HIGHWAY_EXCHANGE.T_ICCARDINFO

                        _Data = _OracleHelper.ExcuteSqlGetDataSet(string.Format(
                            @"SELECT * FROM (SELECT ROWNUM AS rowno, t.* 
                                     FROM HIGHWAY_EXCHANGE.T_ICCARDINFO t
                                     WHERE ROWNUM <= {0}) table_alias
                             WHERE table_alias.rowno > {1}", maximum, minimum));
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;

                    case "HIGHWAY_EXCHANGE.T_MEMBERSHIP":

                        #region HIGHWAY_EXCHANGE.T_MEMBERSHIP
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(string.Format(
                            @"SELECT * FROM (SELECT ROWNUM AS rowno, t.* 
                                     FROM HIGHWAY_EXCHANGE.T_MEMBERSHIP t
                                     WHERE ROWNUM <= {0}) table_alias
                             WHERE table_alias.rowno > {1}", maximum, minimum));
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_SALESPROMOTE":

                        #region HIGHWAY_EXCHANGE.T_SALESPROMOTE（已被新表替代，为兼容未更新的系统版本，此处暂时保留）
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(string.Format(
                            @"SELECT SALESPROMOTE_ID,SERVERPARTCODE,SHOPCODE,MACHINECODE,
                                SALESPROMOTE_STARTDATE,SALESPROMOTE_ENDDATE,SALESPROMOTE_TYPE,
                                SALESPROMOTE_NAME,THRESHOLD_AMOUNT,DISCOUNT_RATE,SALESPROMOTE_VIP,
                                FLAG,TICKET_PREFIX,SALESPROMOTE_DATE,SALESPROMOTE_DESC,PROMOTION_ID,
                                RTMEMBERSHIP_ID,COMMODITY_CODE,CONDITION_SKU
                            FROM (SELECT ROWNUM AS RN,T.*
                                FROM (SELECT A.SALESPROMOTE_ID,A.SERVERPARTCODE,A.SHOPCODE,A.MACHINECODE,
                                        A.SALESPROMOTE_STARTDATE,A.SALESPROMOTE_ENDDATE,A.SALESPROMOTE_TYPE,
                                        A.SALESPROMOTE_NAME,A.THRESHOLD_AMOUNT,A.DISCOUNT_RATE,A.SALESPROMOTE_VIP,
                                        A.FLAG,A.TICKET_PREFIX,A.SALESPROMOTE_DATE,A.SALESPROMOTE_DESC,A.PROMOTION_ID,
                                        A.RTMEMBERSHIP_ID,A.COMMODITY_CODE,A.CONDITION_SKU
                                    FROM HIGHWAY_EXCHANGE.T_SALESPROMOTE A
                                    WHERE A.SERVERPARTCODE = '{0}' AND A.SHOPCODE = '{1}') T
                                WHERE ROWNUM <= {2})
                            WHERE RN > {3}", codes[0], codes[1], maximum, minimum));
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_SALESPROMOTE_EX"://促销活动新表
                        #region 数据源：HIGHWAY_EXCHANGE.T_SALESPROMOTE_EX
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT SALESPROMOTE_ID,SERVERPARTCODE,SHOPCODE,MACHINECODE,
                                SALESPROMOTE_STARTDATE,SALESPROMOTE_ENDDATE,SALESPROMOTE_TYPE,
                                SALESPROMOTE_NAME,THRESHOLD_AMOUNT,DISCOUNT_RATE,SALESPROMOTE_VIP,
                                FLAG,TICKET_PREFIX,SALESPROMOTE_DATE,SALESPROMOTE_DESC,PROMOTION_ID,
                                RTMEMBERSHIP_ID,COMMODITY_CODE,CONDITION_SKU
                            FROM (SELECT ROWNUM AS RN,T.*
                                FROM (SELECT A.SALESPROMOTE_EX_ID AS SALESPROMOTE_ID,A.SERVERPARTCODE,
                                        A.SHOPCODE,A.MACHINECODE,A.SALESPROMOTE_STARTDATE,
                                        A.SALESPROMOTE_ENDDATE,A.SALESPROMOTE_TYPE,A.SALESPROMOTE_NAME,
                                        A.THRESHOLD_AMOUNT,A.DISCOUNT_RATE,A.SALESPROMOTE_VIP,
                                        A.SALESPROMOTE_STATE AS FLAG,A.TICKET_PREFIX,A.SALESPROMOTE_DATE,
                                        A.SALESPROMOTE_DESC,A.PROMOTION_ID,A.RTMEMBERSHIP_ID,
                                        A.COMMODITY_CODE,A.CONDITION_SKU
                                    FROM HIGHWAY_EXCHANGE.T_SALESPROMOTE_EX A
                                    WHERE A.SERVERPARTCODE = '{_ServerpartShop.ServerpartCode}' AND 
                                        A.SHOPCODE = '{_ServerpartShop.ShopCode}'
                                    ORDER BY SALESPROMOTE_EX_ID) T
                                WHERE ROWNUM <= {maximum})
                            WHERE RN > {minimum}");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_PROMOTION"://新促销活动表
                        #region 数据源：HIGHWAY_EXCHANGE.T_PROMOTION
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT PROMOTION_ID,SERVERPARTCODE,SHOPCODE,PROMOTION_STARTDATE,
                                PROMOTION_ENDDATE,PROMOTION_TYPE,PROMOTION_NAME,TICKET_PREFIX,
                                COMMODITY_MAIN,COMMODITY_MAINAMOUNT,COMMODITY_AUXILIARY,
                                COMMODITY_AUXILIARYAMOUNT,PROMOTION_EXPLAIN,PROMOTION_STATE,
                                PROMOTION_DATE,PROMOTION_DESC
                            FROM (SELECT ROWNUM AS RN,T.*
                                FROM (SELECT A.PROMOTION_ID,A.SERVERPARTCODE,A.SHOPCODE,A.PROMOTION_STARTDATE,
                                        A.PROMOTION_ENDDATE,A.PROMOTION_TYPE,A.PROMOTION_NAME,A.TICKET_PREFIX,
                                        A.COMMODITY_MAIN,A.COMMODITY_MAINAMOUNT,A.COMMODITY_AUXILIARY,
                                        A.COMMODITY_AUXILIARYAMOUNT,A.PROMOTION_EXPLAIN,A.PROMOTION_STATE,
                                        A.PROMOTION_DATE,A.PROMOTION_DESC
                                    FROM HIGHWAY_EXCHANGE.T_PROMOTION A
                                    WHERE A.SERVERPARTCODE = '{_ServerpartShop.ServerpartCode}' AND 
                                        A.SHOPCODE = '{_ServerpartShop.ShopCode}'
                                    ORDER BY PROMOTION_ID) T
                                WHERE ROWNUM <= {maximum})
                            WHERE RN > {minimum}");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_SHOPMESSAGE":

                        #region HIGHWAY_EXCHANGE.T_SHOPMESSAGE（已被新表替换，为兼容未更新的系统版本，此处暂时保留）
                        try
                        {
                            if (_OracleHelper.ExcuteSqlGetDataSet(
                                @"SELECT 1 FROM ALL_TAB_COLUMNS 
                                WHERE OWNER = 'HIGHWAY_EXCHANGE' AND 
                                    TABLE_NAME = 'T_SHOPMESSAGE' AND 
                                    COLUMN_NAME = 'SERVERPART_CODE'").Tables[0].Rows.Count > 0)
                            {
                                isReplaceColumnName = true;
                            }
                        }
                        catch { }
                        if (isReplaceColumnName)
                        {
                            _Data = _OracleHelper.ExcuteSqlGetDataSet(string.Format(
                                @"SELECT SHOPMESSAGE_ID,SERVERPARTSHOP_ID,SERVERPARTCODE,
                                    SHOPCODE,SHOPNAME,BUSINESSTYPE,DOWNLOADDATE,FLAG,VALID
                                FROM (SELECT ROWNUM AS RN,T.*
                                    FROM (SELECT A.SHOPMESSAGE_ID,A.SERVERPARTSHOP_ID,
                                            A.SERVERPART_CODE AS SERVERPARTCODE,A.SHOPCODE,
                                            A.SHOPNAME,A.BUSINESSTYPE,A.DOWNLOADDATE,A.FLAG,A.VALID
                                        FROM HIGHWAY_EXCHANGE.T_SHOPMESSAGE A
                                        WHERE A.SERVERPART_CODE = '{0}' AND A.SHOPCODE = '{1}' ) T
                                    WHERE ROWNUM <= {2})
                                WHERE RN > {3}", codes[0], codes[1], maximum, minimum));
                        }
                        else
                        {
                            _Data = _OracleHelper.ExcuteSqlGetDataSet(string.Format(
                                @"SELECT SHOPMESSAGE_ID,SERVERPARTSHOP_ID,SERVERPARTCODE,
                                    SHOPCODE,SHOPNAME,BUSINESSTYPE,DOWNLOADDATE,FLAG,VALID
                                FROM (SELECT ROWNUM AS RN,T.*
                                    FROM (SELECT A.SHOPMESSAGE_ID,A.SERVERPARTSHOP_ID,A.SERVERPARTCODE,
                                            A.SHOPCODE,A.SHOPNAME,A.BUSINESSTYPE,A.DOWNLOADDATE,A.FLAG,A.VALID
                                        FROM HIGHWAY_EXCHANGE.T_SHOPMESSAGE A
                                        WHERE A.SERVERPARTCODE = '{0}' AND A.SHOPCODE = '{1}' ) T
                                    WHERE ROWNUM <= {2})
                                WHERE RN > {3}", codes[0], codes[1], maximum, minimum));
                        }
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_SHOPMESSAGE_EX"://门店信息新表
                        #region 数据源：HIGHWAY_EXCHANGE.T_SHOPMESSAGE_EX
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT SHOPMESSAGE_ID,SERVERPARTSHOP_ID,
                                SERVERPARTCODE,SHOPCODE,SHOPNAME,BUSINESSTYPE,
                                DOWNLOADDATE,FLAG,VALID 
                            FROM (SELECT ROWNUM AS RN,T.* 
                                FROM (SELECT A.SHOPMESSAGE_EX_ID AS SHOPMESSAGE_ID,
                                     A.SERVERPARTSHOP_ID,A.SERVERPART_CODE AS SERVERPARTCODE,
                                        A.SHOPCODE,A.SHOPNAME,A.BUSINESSTYPE,A.DOWNLOADDATE,
                                        0 AS FLAG,A.SERVERPARTSHOP_STATE AS VALID
                                    FROM HIGHWAY_EXCHANGE.T_SHOPMESSAGE_EX A 
                                    WHERE A.SERVERPART_CODE = '{_ServerpartShop.ServerpartCode}' AND 
                                        A.SHOPCODE = '{_ServerpartShop.ShopCode}'
                                    ORDER BY A.SHOPMESSAGE_EX_ID ) T 
                                WHERE ROWNUM <= {maximum}) 
                            WHERE RN > {minimum}");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_SELLWORKER":
                        #region HIGHWAY_EXCHANGE.T_SELLWORKER(已被新表替换，为兼容未更新的系统，此处暂时保留)
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(string.Format(
                            @"SELECT SELLWORKER_ID,SERVERPARTCODE,SELLWORKERCODE,
                                SELLWORKERNAME,PROWERRIGHT,SHOPCODE,DOWNLOADDATE,
                                FLAG,VALID,SELLWORKERPASSWORD,DISCOUNT_RATE
                            FROM (SELECT ROWNUM AS RN,T.*
                                FROM (SELECT A.SELLWORKER_ID,
                                        A.SERVERPARTCODE,A.SELLWORKERCODE,A.SELLWORKERNAME,
                                        A.PROWERRIGHT,A.SHOPCODE,A.DOWNLOADDATE,A.FLAG,A.VALID,
                                        A.SELLWORKERPASSWORD,A.DISCOUNT_RATE
                                    FROM HIGHWAY_EXCHANGE.T_SELLWORKER A
                                    WHERE A.SERVERPARTCODE = '{0}' {3}) T
                                WHERE ROWNUM <= {1})
                            WHERE RN > {2}", codes[0], maximum, minimum,
                            strIsServerPart == "0" ? string.Format(" AND A.SHOPCODE = '{0}'", codes[1]) : " "));
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_SELLWORKER_UNIT"://收银工号新表，业主数据源
                        #region HIGHWAY_EXCHANGE.T_SELLWORKER_EX 中 DATA_SOURCE=0 且生效时间大于当天的数据
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT SELLWORKER_ID,SERVERPARTCODE,SELLWORKERCODE,
                                SELLWORKERNAME,PROWERRIGHT,SHOPCODE,DOWNLOADDATE,
                                FLAG,VALID,SELLWORKERPASSWORD,DISCOUNT_RATE
                            FROM (SELECT ROWNUM AS RN,T.* 
                                FROM (SELECT A.SELLWORKER_EX_ID AS SELLWORKER_ID,
                                        A.SERVERPARTCODE,A.SELLWORKERCODE,A.SELLWORKERNAME,
                                        A.PROWERRIGHT,A.SHOPCODE,A.DOWNLOADDATE,A.FLAG,A.VALID,
                                        A.SELLWORKERPASSWORD,A.DISCOUNT_RATE 
                                    FROM HIGHWAY_EXCHANGE.T_SELLWORKER_EX A
                                    WHERE A.DATA_SOURCE = 0 AND 
                                        A.SERVERPARTCODE = '{_ServerpartShop.ServerpartCode}'
                                    ORDER BY A.SELLWORKER_EX_ID ) T 
                                WHERE ROWNUM < {maximum} ) 
                            WHERE RN > {minimum}");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_SELLWORKER_CLOUD"://收银工号新表，云平台数据源
                        #region HIGHWAY_EXCHANGE.T_SELLWORKER_EX 中 DATA_SOURCE=1 且生效时间大于当天的数据
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT SELLWORKER_ID,SERVERPARTCODE,SELLWORKERCODE,
                                SELLWORKERNAME,PROWERRIGHT,SHOPCODE,DOWNLOADDATE,
                                FLAG,VALID,SELLWORKERPASSWORD,DISCOUNT_RATE
                            FROM (SELECT ROWNUM AS RN,T.* 
                                FROM (SELECT A.SELLWORKER_EX_ID AS SELLWORKER_ID,
                                        A.SERVERPARTCODE,A.SELLWORKERCODE,A.SELLWORKERNAME,
                                        A.PROWERRIGHT,A.SHOPCODE,A.DOWNLOADDATE,A.FLAG,A.VALID,
                                        A.SELLWORKERPASSWORD,A.DISCOUNT_RATE 
                                    FROM HIGHWAY_EXCHANGE.T_SELLWORKER_EX A
                                    WHERE A.DATA_SOURCE = 1 AND 
                                        A.SERVERPARTCODE = '{_ServerpartShop.ServerpartCode}'
                                    ORDER BY SELLWORKER_EX_ID ) T 
                                WHERE ROWNUM < {maximum}) 
                            WHERE RN > {minimum}");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_COMMODITYMULTI":

                        #region HIGHWAY_EXCHANGE.T_COMMODITYMULTI
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT COMMODITYMULTI_ID,SERVERPARTCODE,BUSINESSTYPE,
                                BUSINESSTYPE_NAME,COMMODITYMULTI_CODE,COMMODITYMULTI_NAME,
                                COMMODITY_CODE,USERDEFINEDTYPE_ID,USERDEFINEDTYPE_NAME,
                                ISVALID,OPERATE_DATE,COMMODITY_DESC
                            FROM (	SELECT ROWNUM AS RN,T.* 
	                            FROM ( SELECT COMMODITYMULTI_ID,SERVERPARTCODE,
                                        BUSINESSTYPE,BUSINESSTYPE_NAME,COMMODITYMULTI_CODE,
                                        COMMODITYMULTI_NAME,COMMODITY_CODE,USERDEFINEDTYPE_ID,
                                        USERDEFINEDTYPE_NAME,ISVALID,OPERATE_DATE,COMMODITY_DESC
		                            FROM HIGHWAY_EXCHANGE.T_COMMODITYMULTI 
		                            WHERE SERVERPARTCODE = '{codes[0]}' AND 
                                        BUSINESSTYPE IN ( SELECT BUSINESSTYPE 
				                            FROM HIGHWAY_EXCHANGE.T_SHOPMESSAGE 
	                                        WHERE SERVERPARTSHOP_ID = {codes[2]})
		                            ORDER BY COMMODITYMULTI_ID) T 
	                            WHERE ROWNUM <= {maximum} ) 
                            WHERE RN > {minimum}");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;

                    case "HIGHWAY_EXCHANGE.T_RECHARGERECORD.DOWN":

                        #region HIGHWAY_EXCHANGE.T_RECHARGERECORD_DOWN
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(string.Format(
                           @"SELECT * FROM (SELECT ROWNUM AS rowno, t.* 
                                     FROM HIGHWAY_EXCHANGE.T_RECHARGERECORD t
                                     WHERE RECODE_TYPE IN (1000,1010,2000,2010,3010) AND 
                                        SERVERPARTCODE = '{0}' AND ROWNUM <= {1}) table_alias
                             WHERE table_alias.rowno > {2}", codes[0], maximum, minimum));
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_COMMODITYANALYSISSET":

                        #region HIGHWAY_EXCHANGE.T_COMMODITYANALYSISSET
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT COMMODITYANALYSISSET_ID,PROVINCE_ID,
                                PROVINCE_CODE,PROVINCE_NAME,SERVERPART_ID,
                                SERVERPART_CODE,SERVERPART_NAME,BUSINESSTYPE,
                                COMMODITY_CODE,COMMODITY_BARCODE,COMMODITY_NAME,
                                COMMODITYANALYSISSET_DATE,COMMODITYANALYSISSET_DESC
                            FROM (	SELECT ROWNUM AS RN,T.* 
	                            FROM ( SELECT COMMODITYANALYSISSET_ID,PROVINCE_ID,
                                        PROVINCE_CODE,PROVINCE_NAME,SERVERPART_ID,
                                        SERVERPART_CODE,SERVERPART_NAME,BUSINESSTYPE,
                                        COMMODITY_CODE,COMMODITY_BARCODE,COMMODITY_NAME,
                                        COMMODITYANALYSISSET_DATE,COMMODITYANALYSISSET_DESC
		                            FROM HIGHWAY_EXCHANGE.T_COMMODITYANALYSISSET 
		                            WHERE SERVERPART_CODE = '{codes[0]}' AND 
                                        BUSINESSTYPE IN ( SELECT BUSINESSTYPE 
				                            FROM HIGHWAY_EXCHANGE.T_SHOPMESSAGE 
	                                        WHERE SERVERPARTSHOP_ID = {codes[2]})
		                            ORDER BY COMMODITYANALYSISSET_ID) T 
	                            WHERE ROWNUM <= {maximum} ) 
                            WHERE RN > {minimum}");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_AUDITTASKS":

                        #region HIGHWAY_EXCHANGE.T_AUDITTASKS
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT AUDITTASKS_ID,SERVERPART_ID,SERVERPARTCODE,
                                SERVERPART_NAME,SERVERPARTSHOP_ID,SHOPCODE,SHOPNAME,
                                BUSINESSTYPE,BUSINESSTYPE_NAME,AUDITTASKS_STARTDATE,
                                AUDITTASKS_ENDDATE,AUDITTASKS_DURATION,AUDITTASKS_COUNT,
                                AUDITTASKS_INTERVAL,AUDITTASKS_ISVALID,AUDITTASKS_TYPE,
                                AUDITTASKS_FIRSTTIME,AUDITTASKS_SECONDTIME,AUDITTASKS_THIRDTIME,
                                OPERATE_DATE,STAFF_ID,STAFF_NAME,AUDITTASKS_DESC,STRATTIME,ENDTIME
                            FROM (SELECT ROWNUM AS RN,T.*
                                FROM (SELECT A.AUDITTASKS_ID,A.SERVERPART_ID,A.SERVERPARTCODE,
                                        A.SERVERPART_NAME,A.SERVERPARTSHOP_ID,A.SHOPCODE,
                                        A.SHOPNAME,A.BUSINESSTYPE,A.BUSINESSTYPE_NAME,
                                        A.AUDITTASKS_STARTDATE,A.AUDITTASKS_ENDDATE,
                                        A.AUDITTASKS_DURATION,A.AUDITTASKS_COUNT,
                                        A.AUDITTASKS_INTERVAL,A.AUDITTASKS_ISVALID,
                                        A.AUDITTASKS_TYPE,A.AUDITTASKS_FIRSTTIME,A.STRATTIME,A.ENDTIME,
                                        A.AUDITTASKS_SECONDTIME,A.AUDITTASKS_THIRDTIME,
                                        A.OPERATE_DATE,A.STAFF_ID,A.STAFF_NAME,A.AUDITTASKS_DESC 
                                    FROM HIGHWAY_EXCHANGE.T_AUDITTASKS A
                                    WHERE A.SERVERPARTCODE = {_ServerpartShop.ServerpartCode} AND 
                                        A.BUSINESSTYPE = {_ServerpartShop.BusinessType}
                                    ORDER BY A.AUDITTASKS_ID) T
                                WHERE ROWNUM <= {maximum} )
                            WHERE RN > {minimum}");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }

                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_COMPANYAUTHORIZE":

                        #region HIGHWAY_EXCHANGE.T_COMPANYAUTHORIZE
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT COMPANYAUTHORIZE_ID,COMPANY_ID,PROVINCE_CODE,
                                SERVERPART_ID,SERVERPART_CODE,SERVERPART_NAME,
                                SERVERPARTSHOP_ID,SHOPCODE,SHOPNAME,OPERATE_DATE
                            FROM (SELECT ROWNUM AS RN,T.*
                                FROM (SELECT A.COMPANYAUTHORIZE_ID,A.COMPANY_ID,
                                        A.PROVINCE_CODE,A.SERVERPART_ID,A.SERVERPART_CODE,
                                        A.SERVERPART_NAME,A.SERVERPARTSHOP_ID,A.SHOPCODE,
                                        A.SHOPNAME,A.OPERATE_DATE
                                    FROM HIGHWAY_EXCHANGE.T_COMPANYAUTHORIZE A
                                    WHERE A.SERVERPART_CODE = '{codes[0]}' AND 
                                        A.SHOPCODE = '{codes[1]}'
                                    ORDER BY A.COMPANYAUTHORIZE_ID ) T
                                WHERE ROWNUM <= {maximum} )
                            WHERE RN > {minimum}");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发成功\",\"rows\":" + JsonHelper.DataSetToJson(_Data) + "}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    default:
                        strBack = "{\"error\": -1 ,\"msg\": \"数据下发表类型不正确\",\"rows\":[]}";
                        break;
                }
            }
            catch (Exception ex)
            {
                strBack = "{\"error\": -1 ,\"msg\": \"获取数据分发失败：" + ex.Message + "\",\"rows\":[]}";
            }

            return strBack;
        }
        #endregion

        #region 方法 -> 数据下发子项 (获取总数)
        public static string TotalCount(OracleHelper _OracleHelper, string tableName,
            string jsonString, string[] codes, string lastTime, int maxDataQuantity = 4)
        {
            bool isReplaceColumnName = false;
            string strBack = string.Empty;
            int numCount;
            int numPage;
            DataSet _Data = null;
            //从Cache中读取服务区门店信息数据
            List<Model.ServerpartShopModel> _ServerpartShopList =
                (List<Model.ServerpartShopModel>)WebService.SDK.CacheHelper.Get("ServerpartShopList");
            if (_ServerpartShopList == null)
            {
                _ServerpartShopList = new List<Model.ServerpartShopModel>();
            }
            //检查当前服务区门店参数是否存在于Cache
            if (_ServerpartShopList.FindAll(p => p.ServerpartCode == codes[0] && p.ShopCode == codes[1]).Count == 0)
            {
                //不存在时从数据库读取一次信息并保存至Cache，并设定每30分钟刷新一次
                _ServerpartShopList = Newtonsoft.Json.JsonConvert.DeserializeObject<List<Model.ServerpartShopModel>>(
                    Newtonsoft.Json.JsonConvert.SerializeObject(_OracleHelper.ExcuteSqlGetDataSet(
                        @"SELECT TO_CHAR(A.PROVINCE_CODE) as ProvinceCode,
                            A.SERVERPART_CODE as ServerpartCode,
                            TO_CHAR(B.SERVERPARTSHOP_ID) as ServerpartShopID,
                            B.SHOPCODE as ShopCode,B.BUSINESSTYPE as BusinessType,
                            TO_CHAR(B.UNIFORM_TYPE) as UniformType,
                            TO_CHAR(B.SERVERPARTSHOP_STATE) as ServerpartShopState
                        FROM HIGHWAY_EXCHANGE.T_SERVERPART A,
                            HIGHWAY_EXCHANGE.T_SHOPMESSAGE_EX B
                        WHERE A.SERVERPART_CODE = B.SERVERPART_CODE AND 
                            B.SHOPCODE IS NOT NULL").Tables[0]));
                WebService.SDK.CacheHelper.Set("ServerpartShopList", _ServerpartShopList, DateTime.Now.AddMinutes(30));
            }
            //从Cache读取当前门店参数，用于获取数据使用
            Model.ServerpartShopModel _ServerpartShop = _ServerpartShopList.Find(p => p.ServerpartCode == codes[0] && p.ShopCode == codes[1]);
            try
            {
                switch (tableName)
                {
                    case "HIGHWAY_EXCHANGE.T_ADVERTISING":

                        #region HIGHWAY_EXCHANGE.T_ADVERTISING
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(string.Format(
                            @"SELECT 1 FROM HIGHWAY_EXCHANGE.T_ADVERTISING WHERE SERVERPARTCODE = '{0}' AND SHOPCODE = '{1}'", codes[0], codes[1]));
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            numCount = _Data.Tables[0].Rows.Count;
                            numPage = (numCount % (100 * maxDataQuantity) == 0 ? 0 : 1) + numCount / (100 * maxDataQuantity);
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发总数成功\",\"rows\":[{\"numcount\":" + numCount + ",\"numpage\":" + numPage + "}]}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"分发总数暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_CONFIGURATION":

                        #region HIGHWAY_EXCHANGE.T_CONFIGURATION
                        //_Data = _OracleHelper.ExcuteSqlGetDataSet(string.Format(
                        //    @"SELECT 1 FROM HIGHWAY_EXCHANGE.T_CONFIGURATION WHERE MACADDRESS = '{0}' ", codes[4]));
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT 1 FROM HIGHWAY_EXCHANGE.T_BUSINESSCONFIG A,
                                    HIGHWAY_EXCHANGE.T_SHOPMESSAGE B
                                WHERE A.BUSINESSTYPE = B.BUSINESSTYPE AND A.SERVERPARTCODE = B.SERVERPARTCODE AND 
                                    B.SERVERPARTCODE = '{codes[0]}' AND B.SERVERPARTSHOP_ID = {codes[2]}
                            UNION ALL
                                SELECT 1 FROM HIGHWAY_EXCHANGE.T_CONFIGURATION C
                                WHERE UPPER(C.CONFIGURATION_NAME) NOT IN ('SERVER_CONNAME',
                                    'SERVER_DBPASS','SERVER_DBUSER','SERVER_DBNAME','SERVER_DBPORT',
                                    'SERVER_IP','SERVICE_PORT','SERVICE_PORT2','SERVICE_PORT3',
                                    'SERVICE_PORT4','SERVICE_PORT5','MOBILEPAYOPERATORS') AND 
                                    C.MACADDRESS = '{codes[4]}' AND NOT EXISTS (SELECT 1
                                    FROM HIGHWAY_EXCHANGE.T_BUSINESSCONFIG A,
                                        HIGHWAY_EXCHANGE.T_SHOPMESSAGE B
                                    WHERE A.BUSINESSTYPE = B.BUSINESSTYPE AND 
                                        UPPER(A.CONFIGURATION_NAME) = UPPER(C.CONFIGURATION_NAME) AND 
                                        B.SERVERPARTSHOP_ID = {codes[2]})");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            numCount = _Data.Tables[0].Rows.Count;
                            numPage = (numCount % (100 * maxDataQuantity) == 0 ? 0 : 1) + numCount / (100 * maxDataQuantity);
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发总数成功\",\"rows\":[{\"numcount\":" + numCount + ",\"numpage\":" + numPage + "}]}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"分发总数暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;

                    case "HIGHWAY_EXCHANGE.T_USERDEFINEDTYPE":

                        #region HIGHWAY_EXCHANGE.T_USERDEFINEDTYPE

                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                              string.Format(@"SELECT 1 FROM HIGHWAY_EXCHANGE.T_USERDEFINEDTYPE 
                                WHERE SERVERPARTCODE = '{0}' AND BUSINESSTYPE IN 
                                ( SELECT BUSINESSTYPE FROM HIGHWAY_EXCHANGE.T_SHOPMESSAGE 
                                WHERE SERVERPARTSHOP_ID = {1} )", codes[0], codes[2]));
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            numCount = _Data.Tables[0].Rows.Count;
                            numPage = (numCount % (100 * maxDataQuantity) == 0 ? 0 : 1) + numCount / (100 * maxDataQuantity);
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发总数成功\",\"rows\":[{\"numcount\":" + numCount + ",\"numpage\":" + numPage + "}]}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"分发总数暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_USERDEFINEDTYPE_UNIT"://用户自定义类别表（业主平台）

                        #region 数据源：HIGHWAY_EXCHANGE.T_USERDEFINEDTYPE 中 DATA_SOURCE=0 的数据
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT 1 FROM HIGHWAY_EXCHANGE.T_USERDEFINEDTYPE A
                            WHERE A.SERVERPARTCODE = '{_ServerpartShop.ServerpartCode}' AND 
                                A.BUSINESSTYPE = '{_ServerpartShop.BusinessType}' AND A.DATA_SOURCE = 0 ");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            numCount = _Data.Tables[0].Rows.Count;
                            numPage = (numCount % (100 * maxDataQuantity) == 0 ? 0 : 1) + numCount / (100 * maxDataQuantity);
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发总数成功\",\"rows\":[{\"numcount\":" + numCount + ",\"numpage\":" + numPage + "}]}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"分发总数暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_USERDEFINEDTYPE_CLOUD"://用户自定义类别表（合作商户平台）

                        #region 数据源：HIGHWAY_EXCHANGE.T_USERDEFINEDTYPE 中 DATA_SOURCE=1 的数据
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT 1 FROM HIGHWAY_EXCHANGE.T_USERDEFINEDTYPE A
                            WHERE A.SERVERPARTCODE = '{_ServerpartShop.ServerpartCode}' AND 
                                A.BUSINESSTYPE = '{_ServerpartShop.BusinessType}' AND A.DATA_SOURCE = 1 ");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            numCount = _Data.Tables[0].Rows.Count;
                            numPage = (numCount % (100 * maxDataQuantity) == 0 ? 0 : 1) + numCount / (100 * maxDataQuantity);
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发总数成功\",\"rows\":[{\"numcount\":" + numCount + ",\"numpage\":" + numPage + "}]}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"分发总数暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_COMMODITYEX":

                        #region HIGHWAY_EXCHANGE.T_COMMODITYEX
                        //_OracleHelper.ExcuteSqlGetDataSet(string.Format(@"SELECT "))
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT 1 FROM HIGHWAY_EXCHANGE.T_COMMODITYEX 
                            WHERE SERVERPARTCODE = '{codes[0]}' AND SERVERPARTSHOP_ID = {codes[2]}");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            numCount = _Data.Tables[0].Rows.Count;
                            numPage = (numCount % (100 * maxDataQuantity) == 0 ? 0 : 1) + numCount / (100 * maxDataQuantity);
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发总数成功\",\"rows\":[{\"numcount\":" + numCount + ",\"numpage\":" + numPage + "}]}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"分发总数暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_COMMODITYEX_UNIT":
                        #region 数据源：HIGHWAY_EXCHANGE.T_COMMODITYEX_EX 中 DATA_SOURCE=0 的数据
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT 1 FROM HIGHWAY_EXCHANGE.T_COMMODITYEX_EX A
                            WHERE A.DATA_SOURCE = 0 AND TRUNC(A.OPERATE_DATE) <= TRUNC(SYSDATE) AND 
                                A.BUSINESSTYPE = {_ServerpartShop.BusinessType} AND 
                                (A.SERVERPARTCODE = '{codes[0]}' {(_ServerpartShop.UniformType == "1" ?
                                $" OR A.SERVERPARTCODE = '{_ServerpartShop.ProvinceCode}'" : "")} )");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            numCount = _Data.Tables[0].Rows.Count;
                            numPage = (numCount % (100 * maxDataQuantity) == 0 ? 0 : 1) + numCount / (100 * maxDataQuantity);
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发总数成功\",\"rows\":[{\"numcount\":" + numCount + ",\"numpage\":" + numPage + "}]}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"分发总数暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_COMMODITYEX_CLOUD":
                        #region 数据源：HIGHWAY_EXCHANGE.T_COMMODITYEX_EX 中 DATA_SOURCE=1 的数据
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT 1 FROM HIGHWAY_EXCHANGE.T_COMMODITYEX_EX A
                            WHERE A.DATA_SOURCE = 1 AND TRUNC(A.OPERATE_DATE) <= TRUNC(SYSDATE) AND 
                                A.BUSINESSTYPE = {_ServerpartShop.BusinessType} AND 
                                (A.SERVERPARTCODE = '{codes[0]}' {(_ServerpartShop.UniformType == "1" ?
                                $" OR A.SERVERPARTCODE = '{_ServerpartShop.ProvinceCode}'" : "")} )");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            numCount = _Data.Tables[0].Rows.Count;
                            numPage = (numCount % (100 * maxDataQuantity) == 0 ? 0 : 1) + numCount / (100 * maxDataQuantity);
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发总数成功\",\"rows\":[{\"numcount\":" + numCount + ",\"numpage\":" + numPage + "}]}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"分发总数暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_COMMODITYEX_INEFFECTIVE_UNIT":
                        #region 数据源：HIGHWAY_EXCHANGE.T_COMMODITYEX_EX 中 DATA_SOURCE=0 的数据
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT 1 FROM HIGHWAY_EXCHANGE.T_COMMODITYEX_EX A
                            WHERE A.DATA_SOURCE = 0 AND {(string.IsNullOrWhiteSpace(lastTime) ? " " :
                            $" A.OPERATE_DATE > TO_DATE('{lastTime}','YYYY/MM/DD HH24:MI:SS') AND ")}
                                A.BUSINESSTYPE = {_ServerpartShop.BusinessType} AND A.COMMODITY_CODE IS NOT NULL AND
                                (A.SERVERPARTCODE = '{codes[0]}' {(_ServerpartShop.UniformType == "1" ?
                                $" OR A.SERVERPARTCODE = '{_ServerpartShop.ProvinceCode}'" : "")} )");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            numCount = _Data.Tables[0].Rows.Count;
                            numPage = (numCount % (100 * maxDataQuantity) == 0 ? 0 : 1) + numCount / (100 * maxDataQuantity);
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发总数成功\",\"rows\":[{\"numcount\":" + numCount + ",\"numpage\":" + numPage + "}]}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"分发总数暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_COMMODITYEX_INEFFECTIVE_CLOUD":
                        #region 数据源：HIGHWAY_EXCHANGE.T_COMMODITYEX_EX 中 DATA_SOURCE=1 的数据
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT 1 FROM HIGHWAY_EXCHANGE.T_COMMODITYEX_EX A
                            WHERE A.DATA_SOURCE = 1 AND {(string.IsNullOrWhiteSpace(lastTime) ? " " :
                            $" A.OPERATE_DATE > TO_DATE('{lastTime}','YYYY/MM/DD HH24:MI:SS') AND ")}
                                A.BUSINESSTYPE = {_ServerpartShop.BusinessType} AND 
                                (A.SERVERPARTCODE = '{codes[0]}' {(_ServerpartShop.UniformType == "1" ?
                                $" OR A.SERVERPARTCODE = '{_ServerpartShop.ProvinceCode}'" : "")} )");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            numCount = _Data.Tables[0].Rows.Count;
                            numPage = (numCount % (100 * maxDataQuantity) == 0 ? 0 : 1) + numCount / (100 * maxDataQuantity);
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发总数成功\",\"rows\":[{\"numcount\":" + numCount + ",\"numpage\":" + numPage + "}]}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"分发总数暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_ICCARDINFO":

                        #region HIGHWAY_EXCHANGE.T_ICCARDINFO

                        _Data = _OracleHelper.ExcuteSqlGetDataSet("SELECT 1 FROM HIGHWAY_EXCHANGE.T_ICCARDINFO");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            numCount = _Data.Tables[0].Rows.Count;
                            numPage = (numCount % (100 * maxDataQuantity) == 0 ? 0 : 1) + numCount / (100 * maxDataQuantity);
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发总数成功\",\"rows\":[{\"numcount\":" + numCount + ",\"numpage\":" + numPage + "}]}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"分发总数暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;

                    case "HIGHWAY_EXCHANGE.T_MEMBERSHIP":
                        #region HIGHWAY_EXCHANGE.T_MEMBERSHIP
                        _Data = _OracleHelper.ExcuteSqlGetDataSet("SELECT 1 FROM HIGHWAY_EXCHANGE.T_MEMBERSHIP");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            numCount = _Data.Tables[0].Rows.Count;
                            numPage = (numCount % (100 * maxDataQuantity) == 0 ? 0 : 1) + numCount / (100 * maxDataQuantity);
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发总数成功\",\"rows\":[{\"numcount\":" + numCount + ",\"numpage\":" + numPage + "}]}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"分发总数暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_COMPANYAUTHORIZE"://饭卡单位门店消费限制表
                        #region 数据源：HIGHWAY_EXCHANGE.T_COMPANYAUTHORIZE
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT 1 FROM HIGHWAY_EXCHANGE.T_COMPANYAUTHORIZE 
                            WHERE SERVERPART_CODE = '{codes[0]}' AND SHOPCODE = '{codes[1]}'");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            numCount = _Data.Tables[0].Rows.Count;
                            numPage = (numCount % (100 * maxDataQuantity) == 0 ? 0 : 1) + numCount / (100 * maxDataQuantity);
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发总数成功\",\"rows\":[{\"numcount\":" + numCount + ",\"numpage\":" + numPage + "}]}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"分发总数暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_SALESPROMOTE":

                        #region HIGHWAY_EXCHANGE.T_SALESPROMOTE
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(string.Format(
                            "SELECT 1 FROM HIGHWAY_EXCHANGE.T_SALESPROMOTE WHERE SERVERPARTCODE = '{0}' AND SHOPCODE = '{1}' ",
                            codes[0], codes[1]));
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            numCount = _Data.Tables[0].Rows.Count;
                            numPage = (numCount % (100 * maxDataQuantity) == 0 ? 0 : 1) + numCount / (100 * maxDataQuantity);
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发总数成功\",\"rows\":[{\"numcount\":" + numCount + ",\"numpage\":" + numPage + "}]}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"分发总数暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_SALESPROMOTE_EX":
                        #region 数据源：HIGHWAY_EXCHANGE.T_SALESPROMOTE_EX
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT 1 FROM HIGHWAY_EXCHANGE.T_SALESPROMOTE_EX 
                            WHERE SERVERPARTCODE = '{_ServerpartShop.ServerpartCode}' AND 
                                SHOPCODE = '{_ServerpartShop.ShopCode}' ");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            numCount = _Data.Tables[0].Rows.Count;
                            numPage = (numCount % (100 * maxDataQuantity) == 0 ? 0 : 1) + numCount / (100 * maxDataQuantity);
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发总数成功\",\"rows\":[{\"numcount\":" + numCount + ",\"numpage\":" + numPage + "}]}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"分发总数暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_PROMOTION":
                        #region 数据源：HIGHWAY_EXCHANGE.T_PROMOTION
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT 1 FROM HIGHWAY_EXCHANGE.T_PROMOTION 
                            WHERE SERVERPARTCODE = '{_ServerpartShop.ServerpartCode}' AND 
                                SHOPCODE = '{_ServerpartShop.ShopCode}' ");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            numCount = _Data.Tables[0].Rows.Count;
                            numPage = (numCount % (100 * maxDataQuantity) == 0 ? 0 : 1) + numCount / (100 * maxDataQuantity);
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发总数成功\",\"rows\":[{\"numcount\":" + numCount + ",\"numpage\":" + numPage + "}]}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"分发总数暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_SHOPMESSAGE":

                        #region HIGHWAY_EXCHANGE.T_SHOPMESSAGE
                        try
                        {
                            _OracleHelper.ExcuteSqlGetDataSet(@"SELECT SERVERPART_CODE 
                                FROM HIGHWAY_EXCHANGE.T_SHOPMESSAGE WHERE 1 = 0");
                            isReplaceColumnName = true;
                        }
                        catch { }
                        if (isReplaceColumnName)
                        {
                            _Data = _OracleHelper.ExcuteSqlGetDataSet(string.Format(
                                @"SELECT 1 FROM HIGHWAY_EXCHANGE.T_SHOPMESSAGE 
                                WHERE SERVERPART_CODE = '{0}' AND SHOPCODE = '{1}'",
                                codes[0], codes[1]));
                        }
                        else
                        {
                            _Data = _OracleHelper.ExcuteSqlGetDataSet(string.Format(
                               @"SELECT 1 FROM HIGHWAY_EXCHANGE.T_SHOPMESSAGE 
                                WHERE SERVERPARTCODE = '{0}' AND SHOPCODE = '{1}'",
                               codes[0], codes[1]));
                        }
                        //_Data = _OracleHelper.ExcuteSqlGetDataSet(string.Format(
                        //       @"SELECT 1 FROM HIGHWAY_EXCHANGE.T_SHOPMESSAGE_EX 
                        //        WHERE SERVERPART_CODE = '{0}' AND SHOPCODE = '{1}'",
                        //       codes[0], codes[1]));
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            numCount = _Data.Tables[0].Rows.Count;
                            numPage = (numCount % (100 * maxDataQuantity) == 0 ? 0 : 1) + numCount / (100 * maxDataQuantity);
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发总数成功\",\"rows\":[{\"numcount\":" + numCount + ",\"numpage\":" + numPage + "}]}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"分发总数暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_SHOPMESSAGE_EX":
                        #region 数据源：HIGHWAY_EXCHANGE.T_SHOPMESSAGE_EX
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT 1 FROM HIGHWAY_EXCHANGE.T_SHOPMESSAGE_EX A 
                            WHERE A.SERVERPART_CODE = '{_ServerpartShop.ServerpartCode}' AND 
                                A.SHOPCODE = '{_ServerpartShop.ShopCode}'");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            numCount = _Data.Tables[0].Rows.Count;
                            numPage = (numCount % (100 * maxDataQuantity) == 0 ? 0 : 1) + numCount / (100 * maxDataQuantity);
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发总数成功\",\"rows\":[{\"numcount\":" + numCount + ",\"numpage\":" + numPage + "}]}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"分发总数暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;

                    case "HIGHWAY_EXCHANGE.T_SELLWORKER":

                        #region HIGHWAY_EXCHANGE.T_SELLWORKER
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(string.Format(
                            "SELECT 1 FROM HIGHWAY_EXCHANGE.T_SELLWORKER WHERE SERVERPARTCODE = '{0}'", codes[0]));
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            numCount = _Data.Tables[0].Rows.Count;
                            numPage = (numCount % (100 * maxDataQuantity) == 0 ? 0 : 1) + numCount / (100 * maxDataQuantity);
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发总数成功\",\"rows\":[{\"numcount\":" + numCount + ",\"numpage\":" + numPage + "}]}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"分发总数暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_SELLWORKER_UNIT":
                        #region HIGHWAY_EXCHANGE.T_SELLWORKER_EX 中 DATA_SOURCE=0 
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT 1 FROM HIGHWAY_EXCHANGE.T_SELLWORKER_EX A
                            WHERE A.DATA_SOURCE = 0 AND A.SERVERPARTCODE = '{_ServerpartShop.ServerpartCode}'");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            numCount = _Data.Tables[0].Rows.Count;
                            numPage = (numCount % (100 * maxDataQuantity) == 0 ? 0 : 1) + numCount / (100 * maxDataQuantity);
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发总数成功\",\"rows\":[{\"numcount\":" + numCount + ",\"numpage\":" + numPage + "}]}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"分发总数暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_SELLWORKER_CLOUD":
                        #region HIGHWAY_EXCHANGE.T_SELLWORKER_EX 中 DATA_SOURCE=1 
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT 1 FROM HIGHWAY_EXCHANGE.T_SELLWORKER_EX A
                            WHERE A.DATA_SOURCE = 1 AND A.SERVERPARTCODE = '{_ServerpartShop.ServerpartCode}'");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            numCount = _Data.Tables[0].Rows.Count;
                            numPage = (numCount % (100 * maxDataQuantity) == 0 ? 0 : 1) + numCount / (100 * maxDataQuantity);
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发总数成功\",\"rows\":[{\"numcount\":" + numCount + ",\"numpage\":" + numPage + "}]}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"分发总数暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_COMMODITYMULTI":

                        #region HIGHWAY_EXCHANGE.T_COMMODITYMULTI
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT 1 FROM HIGHWAY_EXCHANGE.T_COMMODITYMULTI 
                            WHERE SERVERPARTCODE = '{codes[0]}' AND BUSINESSTYPE IN 
                                ( SELECT BUSINESSTYPE FROM HIGHWAY_EXCHANGE.T_SHOPMESSAGE 
                                WHERE SERVERPARTSHOP_ID = {codes[2]} )");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            numCount = _Data.Tables[0].Rows.Count;
                            numPage = (numCount % (100 * maxDataQuantity) == 0 ? 0 : 1) + numCount / (100 * maxDataQuantity);
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发总数成功\",\"rows\":[{\"numcount\":" + numCount + ",\"numpage\":" + numPage + "}]}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"分发总数暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_RECHARGERECORD.DOWN":

                        #region HIGHWAY_EXCHANGE.T_RECHARGERECORD_DOWN
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT 1 FROM HIGHWAY_EXCHANGE.T_RECHARGERECORD 
                            WHERE SERVERPARTCODE = '{codes[0]}' AND RECODE_TYPE IN (1000,1010,2000,2010,3010)");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            numCount = _Data.Tables[0].Rows.Count;
                            numPage = (numCount % (100 * maxDataQuantity) == 0 ? 0 : 1) + numCount / (100 * maxDataQuantity);
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发总数成功\",\"rows\":[{\"numcount\":" + numCount + ",\"numpage\":" + numPage + "}]}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"分发总数暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_COMMODITYANALYSISSET":
                        #region HIGHWAY_EXCHANGE.T_COMMODITYANALYSISSET
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT 1 FROM HIGHWAY_EXCHANGE.T_COMMODITYANALYSISSET 
                            WHERE SERVERPART_CODE = '{codes[0]}' AND BUSINESSTYPE IN 
                                ( SELECT BUSINESSTYPE FROM HIGHWAY_EXCHANGE.T_SHOPMESSAGE 
                                WHERE SERVERPARTSHOP_ID = {codes[2]} )");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            numCount = _Data.Tables[0].Rows.Count;
                            numPage = (numCount % (100 * maxDataQuantity) == 0 ? 0 : 1) + numCount / (100 * maxDataQuantity);
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发总数成功\",\"rows\":[{\"numcount\":" + numCount + ",\"numpage\":" + numPage + "}]}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"分发总数暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    case "HIGHWAY_EXCHANGE.T_AUDITTASKS":
                        #region HIGHWAY_EXCHANGE.T_AUDITTASKS
                        _Data = _OracleHelper.ExcuteSqlGetDataSet(
                            $@"SELECT 1 FROM HIGHWAY_EXCHANGE.T_AUDITTASKS A
                            WHERE A.SERVERPARTCODE = {_ServerpartShop.ServerpartCode} AND 
                                A.BUSINESSTYPE = {_ServerpartShop.BusinessType} ");
                        if (_Data != null && _Data.Tables[0].Rows.Count > 0)
                        {
                            numCount = _Data.Tables[0].Rows.Count;
                            numPage = (numCount % (100 * maxDataQuantity) == 0 ? 0 : 1) + numCount / (100 * maxDataQuantity);
                            strBack = "{\"error\": 1 ,\"msg\": \"获取数据分发总数成功\",\"rows\":[{\"numcount\":" + numCount + ",\"numpage\":" + numPage + "}]}";
                        }
                        else
                        {
                            strBack = "{\"error\": -1 ,\"msg\": \"分发总数暂无数据\",\"rows\":[]}";
                        }
                        #endregion
                        break;
                    default:
                        strBack = "{\"error\": -1 ,\"msg\": \"数据下发表类型不正确\",\"rows\":[]}";
                        break;
                }
            }
            catch (Exception ex)
            {
                strBack = "{\"error\": -1 ,\"msg\": \"获取数据分发总数失败：" + ex.Message + "\",\"rows\":[]}";
            }
            return strBack;
        }
        #endregion
    }
}