1609 lines
107 KiB
C#
1609 lines
107 KiB
C#
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
|
||
}
|
||
} |