364 lines
13 KiB
C#
364 lines
13 KiB
C#
using Gatedge.K3Cloud.Utils.Exceptions;
|
||
using Gatedge.K3Cloud.Utils.Model.K3Request;
|
||
using Gatedge.K3Cloud.Utils.Model.K3Result;
|
||
using Gatedge.K3Cloud.Utils.Model.K3Result.Model;
|
||
using Gatedge.K3Cloud.Utils.Option;
|
||
using Kingdee.CDP.WebApi.SDK;
|
||
using Kingdee.CDP.WebApi.SDK.DataEntity;
|
||
using System.Text.Json;
|
||
|
||
namespace Gatedge.K3Cloud.Utils
|
||
{
|
||
/// <summary>
|
||
/// K3CloudApi帮助类
|
||
/// </summary>
|
||
public class K3CloudApiUtils
|
||
{
|
||
private List<K3CloudOption> _options;
|
||
private K3CloudApi _cloudApi;
|
||
private LoginInfo _userInfo;
|
||
|
||
/// <summary>
|
||
/// 构造K3CloudApiUtils，option、env是从ICO容器中拿到的对象
|
||
/// </summary>
|
||
/// <param name="option">金蝶配置</param>
|
||
public K3CloudApiUtils(List<K3CloudOption> option)
|
||
{
|
||
_options = option;
|
||
}
|
||
/// <summary>
|
||
/// 获取Kingdee配置信息
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public List<K3CloudOption> GetKingdeeOptions()
|
||
{
|
||
return _options;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 根据Token中的信息创建K3CloudApi对象
|
||
/// </summary>
|
||
/// <param name="User"></param>
|
||
/// <returns></returns>
|
||
public void InitCloudApi(LoginInfo User)
|
||
{
|
||
var userName = User.UserName;
|
||
var lcId = User.LCId;
|
||
var orgNum = User.OrgNum;
|
||
var DBID = User.DBID;
|
||
var serverUrl = User.ServerUrl;
|
||
K3CloudOption? kingdeeOption = _options
|
||
.Where(n => n.AcctID == DBID && n.ServerUrl.ToUpperInvariant() == serverUrl.ToUpperInvariant())
|
||
.FirstOrDefault();
|
||
if (kingdeeOption == null)
|
||
{
|
||
throw new Exception("配置文件没有对应的第三方授权登录信息！");
|
||
}
|
||
_cloudApi = new K3CloudApi(serverUrl);
|
||
|
||
_cloudApi.InitClient(
|
||
acctID: DBID,
|
||
appID: kingdeeOption?.AppID,
|
||
appSec: kingdeeOption?.AppSec,
|
||
serverUrl: serverUrl,
|
||
userName: userName,
|
||
lcid: lcId,
|
||
orgNum: orgNum
|
||
);
|
||
this._userInfo = User;
|
||
}
|
||
|
||
|
||
|
||
/// <summary>
|
||
/// 获取默认用户的api
|
||
/// </summary>
|
||
/// <param name="loginInfo"></param>
|
||
/// <returns></returns>
|
||
public K3CloudApi CreateDefaultK3CloudApi(LoginInfo loginInfo)
|
||
{
|
||
K3CloudOption? kingdeeOption = _options
|
||
.Where(n => n.AcctID == loginInfo.DBID && n.ServerUrl.ToUpperInvariant() == loginInfo.ServerUrl.ToUpperInvariant())
|
||
.FirstOrDefault();
|
||
if (kingdeeOption == null)
|
||
{
|
||
throw new Exception("配置文件没有对应的第三方授权登录信息！");
|
||
}
|
||
// 默认登录信息从配置文件appsetting.json获取AppID、AppSec，其余从前端传参
|
||
ThirdPassPortInfo thirdPassPortInfo = new ThirdPassPortInfo();
|
||
thirdPassPortInfo.CloudDbId = loginInfo.DBID;
|
||
thirdPassPortInfo.ApiAppId = kingdeeOption?.AppID;
|
||
thirdPassPortInfo.AppSec = kingdeeOption?.AppSec;
|
||
thirdPassPortInfo.CloudUrl = loginInfo.ServerUrl;
|
||
thirdPassPortInfo.Language = loginInfo.LCId.ToString();
|
||
thirdPassPortInfo.CloudUser = loginInfo.UserName;
|
||
_cloudApi = new K3CloudApi(thirdPassPortInfo, 30);
|
||
return _cloudApi;
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 创建金蝶云API SDK
|
||
/// </summary>
|
||
/// <param name="loginInfo"></param>
|
||
/// <returns></returns>
|
||
public K3CloudApiUtils GetDefaultK3CloudApiUtil(LoginInfo loginInfo)
|
||
{
|
||
K3CloudOption? kingdeeOption = _options
|
||
.Where(n => n.AcctID == loginInfo.DBID && n.ServerUrl.ToUpperInvariant() == loginInfo.ServerUrl.ToUpperInvariant())
|
||
.FirstOrDefault();
|
||
if (kingdeeOption == null)
|
||
{
|
||
throw new Exception("配置文件没有对应的第三方授权登录信息！");
|
||
}
|
||
// 默认登录信息从配置文件appsetting.json获取AppID、AppSec，其余从前端传参
|
||
var logInfo = new LoginInfo()
|
||
{
|
||
UserName = kingdeeOption.UserName,
|
||
LCId = kingdeeOption.LCID,
|
||
OrgNum = kingdeeOption.OrgNumber,
|
||
DBID = kingdeeOption.AcctID,
|
||
ServerUrl = kingdeeOption.ServerUrl,
|
||
};
|
||
var k3CloudApiUtil = new K3CloudApiUtils(_options);
|
||
k3CloudApiUtil.InitCloudApi(logInfo);
|
||
return k3CloudApiUtil;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 创建金蝶云API SDK
|
||
/// </summary>
|
||
/// <param name="loginInfo"></param>
|
||
/// <returns></returns>
|
||
public K3CloudApiUtils GetDefaultK3CloudApiUtil()
|
||
{
|
||
|
||
if (this._userInfo == null)
|
||
{
|
||
throw new Exception("当前工具类没有，初始化用户信息");
|
||
}
|
||
return GetDefaultK3CloudApiUtil(_userInfo);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获取金蝶云星空SDK实例
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public K3CloudApi GetApiClient()
|
||
{
|
||
return _cloudApi;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 查询列表
|
||
/// </summary>
|
||
/// <param name="queryParam"></param>
|
||
/// <returns></returns>
|
||
public ListResult QueryList(Query queryParam)
|
||
{
|
||
var datastr = queryParam.ToString();
|
||
var resultString = _cloudApi.BillQuery(datastr);
|
||
// 包含ErrorCode认定为失败
|
||
if (resultString.Contains("ErrorCode"))
|
||
{
|
||
var errorResult = JsonSerializer.Deserialize<KingdeeResult>(resultString);
|
||
var responseStatus = errorResult?.Result?.ResponseStatus;
|
||
Exception error = new K3CloudException("查看单据列表出错", responseStatus);
|
||
throw error;
|
||
}
|
||
List<Dictionary<string, object>>? result = JsonSerializer.Deserialize<List<Dictionary<string, object>>>(resultString);
|
||
return new ListResult(result);
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 查询单据
|
||
/// </summary>
|
||
/// <param name="formId">表单ID</param>
|
||
/// <param name="viewBill">参数</param>
|
||
/// <returns></returns>
|
||
/// <exception cref="Exception"></exception>
|
||
public object Query(string formId, View viewBill)
|
||
{
|
||
var jsonData = viewBill.ToString();
|
||
var resultString = _cloudApi.View(formId, jsonData);
|
||
var result = JsonSerializer.Deserialize<KingdeeResult>(resultString);
|
||
if (result?.Result?.ResponseStatus?.IsSuccess != true)
|
||
{
|
||
var responseStatus = result?.Result?.ResponseStatus;
|
||
Exception error = new K3CloudException("查看单据出错", responseStatus);
|
||
throw error;
|
||
}
|
||
var data = result?.Result?.Result;
|
||
return data;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 查询单据
|
||
/// </summary>
|
||
/// <param name="formId">表单ID</param>
|
||
/// <param name="viewBill">参数</param>
|
||
/// <returns></returns>
|
||
/// <exception cref="Exception"></exception>
|
||
public T Query<T>(string formId, View viewBill)
|
||
{
|
||
var jsonData = viewBill.ToString();
|
||
var resultString = _cloudApi.View(formId, jsonData);
|
||
var result = JsonSerializer.Deserialize<KingdeeResult>(resultString);
|
||
if (result?.Result?.ResponseStatus?.IsSuccess != true)
|
||
{
|
||
var responseStatus = result?.Result?.ResponseStatus;
|
||
Exception error = new K3CloudException("查看单据出错", responseStatus);
|
||
throw error;
|
||
}
|
||
var data = result?.Result?.Result;
|
||
var dataString = JsonSerializer.Serialize(data);
|
||
return JsonSerializer.Deserialize<T>(dataString);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 下推接口
|
||
/// </summary>
|
||
/// <param name="formId">表单ID</param>
|
||
/// <param name="billPush">参数</param>
|
||
/// <returns></returns>
|
||
public K3CloudResponseStatus Push(string formId, Push billPush)
|
||
{
|
||
var pushString = billPush.ToString();
|
||
var resultString = _cloudApi.Push(formId, pushString);
|
||
var result = JsonSerializer.Deserialize<KingdeeResult>(resultString);
|
||
var data = result?.Result?.ResponseStatus;
|
||
return data;
|
||
}
|
||
|
||
|
||
|
||
/// <summary>
|
||
/// 保存接口
|
||
/// </summary>
|
||
/// <param name="formId"></param>
|
||
/// <param name="billSave"></param>
|
||
/// <returns></returns>
|
||
public K3CloudResponseStatus Save<T>(string formId, Save<T> billSave)
|
||
{
|
||
var requestString = billSave.ToString();
|
||
var resultString = _cloudApi.Save(formId, requestString);
|
||
var result = JsonSerializer.Deserialize<KingdeeResult>(resultString);
|
||
if (result?.Result?.ResponseStatus?.IsSuccess != true)
|
||
{
|
||
var responseStatus = result?.Result?.ResponseStatus;
|
||
Exception error = new K3CloudException("单据保存出错", responseStatus);
|
||
throw error;
|
||
}
|
||
var data = result?.Result?.ResponseStatus;
|
||
return data;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 批量保存接口
|
||
/// </summary>
|
||
/// <param name="formId"></param>
|
||
/// <param name="patchSave"></param>
|
||
/// <returns></returns>
|
||
public K3CloudResponseStatus BatchSave<T>(string formId, PatchSave<T> patchSave)
|
||
{
|
||
var requestString = patchSave.ToString();
|
||
var resultString = _cloudApi.BatchSave(formId, requestString);
|
||
var result = JsonSerializer.Deserialize<KingdeeResult>(resultString);
|
||
if (result?.Result?.ResponseStatus?.IsSuccess != true)
|
||
{
|
||
var responseStatus = result?.Result?.ResponseStatus;
|
||
Exception error = new K3CloudException("单据批量保存出错", responseStatus);
|
||
throw error;
|
||
}
|
||
var data = result?.Result?.ResponseStatus;
|
||
return data;
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 删除接口
|
||
/// </summary>
|
||
/// <param name="formId"></param>
|
||
/// <param name="billdelete"></param>
|
||
/// <returns></returns>
|
||
public K3CloudResponseStatus Delete(string formId, Delete billdelete)
|
||
{
|
||
var paramStr = billdelete.ToString();
|
||
var resultString = _cloudApi.Delete(formId, paramStr);
|
||
var result = JsonSerializer.Deserialize<KingdeeResult>(resultString);
|
||
if (result?.Result?.ResponseStatus?.IsSuccess != true)
|
||
{
|
||
var responseStatus = result?.Result?.ResponseStatus;
|
||
Exception error = new K3CloudException("单据删除出错", responseStatus);
|
||
throw error;
|
||
}
|
||
var data = result?.Result?.ResponseStatus;
|
||
return data;
|
||
}
|
||
|
||
|
||
|
||
/// <summary>
|
||
/// 提交接口
|
||
/// </summary>
|
||
/// <param name="formId"></param>
|
||
/// <param name="billSubmit"></param>
|
||
/// <returns></returns>
|
||
public K3CloudResponseStatus Submit(string formId, Submit billSubmit)
|
||
{
|
||
var resultString = _cloudApi.Submit(formId, billSubmit.ToString());
|
||
var result = JsonSerializer.Deserialize<KingdeeResult>(resultString);
|
||
var data = result?.Result?.ResponseStatus;
|
||
return data;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 提交接口
|
||
/// </summary>
|
||
/// <param name="formId"></param>
|
||
/// <param name="billSubmit"></param>
|
||
/// <returns></returns>
|
||
public K3CloudResponseStatus CancelAssign(string formId, CancelAssign billSubmit)
|
||
{
|
||
var resultString = _cloudApi.CancelAssign(formId, billSubmit.ToString());
|
||
var result = JsonSerializer.Deserialize<KingdeeResult>(resultString);
|
||
var data = result?.Result?.ResponseStatus;
|
||
return data;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 审核接口
|
||
/// </summary>
|
||
/// <param name="formId"></param>
|
||
/// <param name="billAudit"></param>
|
||
/// <returns></returns>
|
||
public K3CloudResponseStatus Audit(string formId, Audit billAudit)
|
||
{
|
||
var resultString = _cloudApi.Audit(formId, billAudit.ToString());
|
||
var result = JsonSerializer.Deserialize<KingdeeResult>(resultString);
|
||
var data = result?.Result?.ResponseStatus;
|
||
return data;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 文件系统
|
||
/// </summary>
|
||
/// <param name="fileParam"></param>
|
||
/// <returns></returns>
|
||
public Model.K3Result.Model.K3CloudResult FileDonwload(FileParam fileParam)
|
||
{
|
||
var resultString = _cloudApi.AttachmentDownLoad(fileParam.ToString());
|
||
|
||
var result = JsonSerializer.Deserialize<KingdeeResult>(resultString);
|
||
if (result?.Result?.ResponseStatus?.IsSuccess != true)
|
||
{
|
||
var responseStatus = result?.Result?.ResponseStatus;
|
||
Exception error = new K3CloudException("附件下载出错", responseStatus);
|
||
throw error;
|
||
}
|
||
return result?.Result;
|
||
}
|
||
}
|
||
}
|