#region
|
|
using System;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.ServiceModel;
|
using CSFrameworkV5.Common;
|
using CSFrameworkV5.Core;
|
using CSFrameworkV5.Interfaces;
|
using CSFrameworkV5.Interfaces.InterfaceModels;
|
using CSFrameworkV5.WCFContract;
|
|
///*************************************************************************/
|
///*
|
///* 文件名 ：WinService_CommonData.cs
|
///*
|
///* 程序说明 : 公共数据桥接类定义
|
///* 原创作者 ：www.csframework.com
|
///*
|
///* Copyright 2006-2021 C/S框架网 www.csframework.com
|
///*
|
///**************************************************************************/
|
|
#endregion
|
|
namespace CSFrameworkV5.WebRef.CommonService
|
{
|
/// <summary>
|
/// 公共方法的Windows Service策略层
|
/// </summary>
|
public class WCF_CommonData : WCF_Base<ICommonService>, IBridge_CommonData
|
{
|
public List<DbTableModel> GetDbTableFields(string DBName,
|
string TableName)
|
{
|
return Excute(client =>
|
{
|
var loginTicket =
|
WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
|
return client.GetDbTableFields(loginTicket, DBName, TableName);
|
});
|
}
|
|
public List<DbTableModel> GetDbTables()
|
{
|
return Excute(client =>
|
{
|
var loginTicket =
|
WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
|
return client.GetDbTables(loginTicket);
|
});
|
}
|
|
public int GetUpgraderPackages(string currentVersionID)
|
{
|
return Excute(client =>
|
{
|
var loginTicket =
|
WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
|
return client.GetUpgraderPackages(loginTicket,
|
currentVersionID);
|
});
|
}
|
|
/// <summary>
|
/// 测试客户端访问WCF接口
|
/// </summary>
|
private void TestCommonService()
|
{
|
var uri = "net.tcp://localhost:8585/CommonService";
|
|
//创建透明代理
|
var svc =
|
WCFInvokeContext.CreateWCFService<ICommonService>(uri,
|
BindingType.NetTcpBinding);
|
try
|
{
|
(svc as ICommunicationObject).Open(); //打开WCF通道
|
|
//模拟用户登陆信息
|
byte[] loginTicket = { 22, 141, 34, 123, 55, 2, 23, 73, 22 };
|
|
//调用WCF接口
|
var bs = svc.GetAttachedFiles(loginTicket, "PO201805130002");
|
|
//将byte数组转换为DataSet
|
var ds = ZipTools.DecompressionDataSet(bs);
|
}
|
finally
|
{
|
(svc as ICommunicationObject).Close(); //关闭通道
|
}
|
}
|
|
#region IBridge_CommonDAL Members
|
|
public bool ApprovalBusiness(QueryApproval P)
|
{
|
return Excute(client =>
|
{
|
var loginTicket = WebServiceSecurity.GetLoginTicket();
|
return client.ApprovalBusiness(loginTicket, P);
|
});
|
}
|
|
public DataTable GetEmptyTable(string DBID, string tableName)
|
{
|
return Excute(client =>
|
{
|
var loginTicket = WebServiceSecurity.GetLoginTicket();
|
return client.GetEmptyTable(loginTicket, DBID, tableName);
|
});
|
}
|
|
public string TestConnection()
|
{
|
return Excute(client =>
|
{
|
var validationTicket = WebServiceSecurity.GetLoginTicket();
|
return client.TestConnection(validationTicket);
|
});
|
}
|
|
public DataTable GetSystemDataSet()
|
{
|
return Excute(client =>
|
{
|
var validationTicket = WebServiceSecurity.GetLoginTicket();
|
var receivedData = client.GetSystemDataSet(validationTicket);
|
return ZipTools.DecompressionDataSet(receivedData).Tables[0];
|
});
|
}
|
|
public DataTable GetSystemDataSet(string user, string password)
|
{
|
return Excute(client =>
|
{
|
var loginTicket = WebServiceSecurity.GetLoginTicket();
|
var bs = client.GetSystemDataSetEx(loginTicket, user, password);
|
return ZipTools.DecompressionDataSet(bs).Tables[0];
|
});
|
}
|
|
public DataTable GetTableFieldsDef(string tableName,
|
bool onlyDisplayField)
|
{
|
return Excute(client =>
|
{
|
var loginTicket =
|
WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
|
var receivedData = client.GetTableFieldsDef(loginTicket,
|
tableName, onlyDisplayField);
|
return ZipTools.DecompressionDataSet(receivedData).Tables[0];
|
});
|
}
|
|
public DataTable GetTableFields(string tableName)
|
{
|
return Excute(client =>
|
{
|
var loginTicket =
|
WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
|
var receivedData =
|
client.GetTableFields(loginTicket, tableName);
|
return ZipTools.DecompressionDataSet(receivedData).Tables[0];
|
});
|
}
|
|
public DataTable GetBusinessTables()
|
{
|
return Excute(client =>
|
{
|
var loginTicket =
|
WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
|
var receivedData = client.GetBusinessTables(loginTicket);
|
return ZipTools.DecompressionDataSet(receivedData).Tables[0];
|
});
|
}
|
|
public DataTable GetModules()
|
{
|
return Excute(client =>
|
{
|
var loginTicket =
|
WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
|
var receivedData = client.GetModules(loginTicket);
|
return ZipTools.DecompressionDataSet(receivedData).Tables[0];
|
});
|
}
|
|
public string GetDataSN(string dataCode, bool asHeader)
|
{
|
return Excute(client =>
|
{
|
var loginTicket =
|
WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
|
return client.GetDataSN(loginTicket, dataCode, asHeader);
|
});
|
}
|
|
public string GetDocNo(string DocNoName)
|
{
|
return Excute(client =>
|
{
|
var loginTicket =
|
WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
|
return client.GetDocNo(loginTicket, DocNoName);
|
});
|
}
|
|
public DataSet SearchOutstandingByPage(string invoiceNo,
|
string customer,
|
DateTime dateFrom, DateTime dateTo, DateTime dateEnd,
|
string outstandingType, int pageNo, int pageSize)
|
{
|
return Excute(client =>
|
{
|
var loginTicket =
|
WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
|
var bs = client.SearchOutstanding_ByPage(loginTicket, invoiceNo,
|
customer, dateFrom, dateTo, dateEnd,
|
outstandingType, pageNo, pageSize);
|
return ZipTools.DecompressionDataSet(bs);
|
});
|
}
|
|
public DataTable SearchOutstanding(string invoiceNo, string customer,
|
DateTime dateFrom, DateTime dateTo, DateTime dateEnd,
|
string outstandingType)
|
{
|
return Excute(client =>
|
{
|
var loginTicket =
|
WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
|
var bs = client.SearchOutstanding(loginTicket, invoiceNo,
|
customer, dateFrom, dateTo, dateEnd,
|
outstandingType);
|
return ZipTools.DecompressionDataSet(bs).Tables[0];
|
});
|
}
|
|
public DateTime GetServerTime()
|
{
|
return Excute(client =>
|
{
|
//byte[] loginTicket = WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
|
var loginTicket = WebServiceSecurity.GetLoginTicket();
|
return client.GetServerTime(loginTicket);
|
});
|
}
|
|
public bool UploadUpgrader(string upgraderName, byte[] body,
|
string version,
|
DateTime uploadTime, string user)
|
{
|
return Excute(client =>
|
{
|
var loginTicket =
|
WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
|
return client.UploadUpgrader(loginTicket, upgraderName, body,
|
version, uploadTime, user);
|
});
|
}
|
|
public string GetUpgraderVersion(string upgraderName)
|
{
|
return Excute(client =>
|
{
|
var loginTicket =
|
WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
|
return client.GetUpgraderVersion(loginTicket, upgraderName);
|
});
|
}
|
|
public byte[] GetUpgrader(string upgraderName, string serverVer)
|
{
|
return Excute(client =>
|
{
|
var loginTicket =
|
WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
|
return client.GetUpgrader(loginTicket, upgraderName, serverVer);
|
});
|
}
|
|
public DataTable GetSystemSettingsEx(string ParamName, string ParamType)
|
{
|
return Excute(client =>
|
{
|
var loginTicket =
|
WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
|
var receivedData =
|
client.GetSystemSettingsEx(loginTicket, ParamName,
|
ParamType);
|
return ZipTools.DecompressionDataSet(receivedData).Tables[0];
|
});
|
}
|
|
public DataTable GetSystemSettingsByUser(string DataSetID,
|
string UserID)
|
{
|
return Excute(client =>
|
{
|
var loginTicket =
|
WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
|
var receivedData =
|
client.GetSystemSettingsByUser(loginTicket, DataSetID,
|
UserID);
|
return ZipTools.DecompressionDataSet(receivedData).Tables[0];
|
});
|
}
|
|
public DataTable GetSystemSettings4Program(string DataSetID,
|
string UserID)
|
{
|
return Excute(client =>
|
{
|
var loginTicket = WebServiceSecurity.GetLoginTicket();
|
var receivedData =
|
client.GetSystemSettings4Program(loginTicket, DataSetID,
|
UserID);
|
return ZipTools.DecompressionDataSet(receivedData).Tables[0];
|
});
|
}
|
|
public void PostUserSettings(Loginer currentUser, string paramKey,
|
string paramValue)
|
{
|
Excute(client =>
|
{
|
var loginTicket =
|
WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
|
client.PostUserSettings(loginTicket, paramKey, paramValue);
|
});
|
}
|
|
public DataTable GetUpgraderVersionData()
|
{
|
throw new NotImplementedException();
|
}
|
|
public DataTable GetReports(string ReportsName)
|
{
|
throw new NotImplementedException();
|
}
|
|
#endregion
|
}
|
}
|
