// OaApiService.cs
|
using System;
|
using System.Collections.Generic;
|
using System.Dynamic;
|
using System.IO;
|
using System.Net.Http;
|
using System.Security.Cryptography;
|
using System.Text;
|
using System.Threading.Tasks;
|
using Newtonsoft.Json;
|
using Newtonsoft.Json.Linq;
|
using Org.BouncyCastle.Crypto.Parameters;
|
using Org.BouncyCastle.Security;
|
|
public class OaApiService : IDisposable
|
{
|
private readonly HttpClient _httpClient;
|
private const string AppId = "303233EF-AC39-40C1-8364-AC989C6258A5";
|
private const string BaseUrl = "http://192.168.1.149:8099/api/ec/dev/auth/";
|
private const string WorkflowUrl = "http://192.168.1.149:8099/api/workflow/paService/doCreateRequest";
|
|
public OaApiService()
|
{
|
_httpClient = new HttpClient();
|
_httpClient.Timeout = TimeSpan.FromSeconds(30);
|
}
|
|
public async Task<dynamic> SubmitIQCToOA(dynamic queryObj)
|
{
|
|
//if (unity.userName.IsNullOrEmpty()) throw new Exception("用户名不允许为空");
|
//if (unity.sectionCode.IsNullOrEmpty()) throw new Exception("库位编号不允许为空");
|
//if (unity.barcode.IsNullOrEmpty()) throw new Exception("条码不允许为空");
|
//if (unity.billNo.IsNullOrEmpty()) throw new Exception("申请单号不允许为空");
|
|
try
|
{
|
// 解析请求参数
|
var query = queryObj;
|
//var query = JObject.FromObject(queryObj);
|
|
// 1. 注册获取凭证
|
var registResult = await GetRegistAsync();
|
var secret = registResult["secrit"].ToString();
|
var spk = registResult["spk"].ToString();
|
|
// 2. 获取访问令牌
|
var tokenResult = await ApplyTokenAsync(secret, spk);
|
var token = tokenResult["token"].ToString();
|
|
// 3. 准备请求头（移除Content-Type设置）
|
_httpClient.DefaultRequestHeaders.Clear();
|
_httpClient.DefaultRequestHeaders.Add("token", token);
|
_httpClient.DefaultRequestHeaders.Add("appid", AppId);
|
_httpClient.DefaultRequestHeaders.Add("userid", RSAEncrypt("1268", spk));
|
|
// 4. 构建请求体
|
var requestData = BuildRequestData();
|
|
// 5. 发送请求
|
var response = await PostFormAsync(WorkflowUrl, requestData);
|
return JObject.Parse(response);
|
}
|
catch (Exception ex)
|
{
|
dynamic error = new ExpandoObject();
|
error.Error = true;
|
error.Message = ex.Message;
|
return error;
|
}
|
}
|
|
private Dictionary<string, object> BuildRequestData()
|
{
|
// 从query参数中获取实际业务数据
|
return new Dictionary<string, object>
|
{
|
{"mainData", BuildMainData()},
|
{"requestName", $"IQC流程-{DateTime.Now:yyyyMMddHHmmss}"},
|
{"workflowId", "379"},
|
//{"otherParams", BuildOtherParams()},
|
//{"detailData", BuildDetailData(query)}
|
};
|
}
|
|
private JArray BuildMainData()
|
{
|
// 示例字段，根据实际业务需求调整
|
return new JArray
|
{
|
new JObject
|
{
|
["fieldName"] = "wlbm",
|
["fieldValue"] = "1.01.01.001"
|
},
|
new JObject
|
{
|
["fieldName"] = "khgys",
|
["fieldValue"] = "陈雪年"
|
},
|
new JObject
|
{
|
["fieldName"] = "bhgpqxms",
|
["fieldValue"] = "外观不合格，尺寸不合格，颜色不符合"
|
},
|
new JObject
|
{
|
["fieldName"] = "dhdhmes",
|
["fieldValue"] = "MES001"
|
}
|
};
|
}
|
|
private JArray BuildAttachments(JToken attachments)
|
{
|
var array = new JArray();
|
|
if (attachments != null)
|
{
|
foreach (var att in attachments)
|
{
|
array.Add(new JObject
|
{
|
["filePath"] = att["url"]?.ToString(),
|
["fileName"] = att["fileName"]?.ToString()
|
});
|
}
|
}
|
return array;
|
}
|
|
private JArray BuildDetailData(JObject query)
|
{
|
// 示例明细数据，根据实际业务调整
|
return new JArray
|
{
|
new JObject
|
{
|
["tableDBName"] = "formtable_main_24_dt1",
|
["workflowRequestTableRecords"] = new JArray
|
{
|
new JObject
|
{
|
["recordOrder"] = "0",
|
["workflowRequestTableFields"] = new JArray
|
{
|
new JObject { ["fieldName"] = "xm", ["fieldValue"] = query["inspector"] ?? "默认检验员" },
|
new JObject { ["fieldName"] = "bh", ["fieldValue"] = query["batchNo"] ?? "默认批次号" },
|
new JObject { ["fieldName"] = "dz", ["fieldValue"] = query["location"] ?? "默认地点" }
|
}
|
}
|
}
|
}
|
};
|
}
|
|
private JObject BuildOtherParams()
|
{
|
return new JObject
|
{
|
["isnextflow"] = "1",
|
["delReqFlowFaild"] = "1"
|
};
|
}
|
|
private async Task<JObject> GetRegistAsync()
|
{
|
using var rsa = new RSACryptoServiceProvider(2048);
|
var cpk = Convert.ToBase64String(rsa.ExportRSAPublicKey());
|
|
_httpClient.DefaultRequestHeaders.Clear();
|
_httpClient.DefaultRequestHeaders.Add("appid", AppId);
|
_httpClient.DefaultRequestHeaders.Add("cpk", cpk);
|
|
var response = await _httpClient.PostAsync(BaseUrl + "regist", null);
|
return JObject.Parse(await response.Content.ReadAsStringAsync());
|
}
|
|
private async Task<JObject> ApplyTokenAsync(string secret, string spk)
|
{
|
_httpClient.DefaultRequestHeaders.Clear();
|
_httpClient.DefaultRequestHeaders.Add("appid", AppId);
|
_httpClient.DefaultRequestHeaders.Add("secret", RSAEncrypt(secret, spk));
|
|
var response = await _httpClient.PostAsync(BaseUrl + "applytoken", null);
|
return JObject.Parse(await response.Content.ReadAsStringAsync());
|
}
|
|
private string RSAEncrypt(string data, string publicKey)
|
{
|
//using var rsa = new RSACryptoServiceProvider();
|
//rsa.ImportRSAPublicKey(Convert.FromBase64String(publicKey), out _);
|
|
//var dataBytes = Encoding.UTF8.GetBytes(data);
|
//var encrypted = rsa.Encrypt(dataBytes, RSAEncryptionPadding.Pkcs1);
|
//return Convert.ToBase64String(encrypted);
|
RsaKeyParameters publicKeyParam = (RsaKeyParameters)PublicKeyFactory.CreateKey(Convert.FromBase64String(publicKey));
|
string XML = string.Format("<RSAKeyValue><Modulus>{0}</Modulus><Exponent>{1}</Exponent></RSAKeyValue>",
|
Convert.ToBase64String(publicKeyParam.Modulus.ToByteArrayUnsigned()),
|
Convert.ToBase64String(publicKeyParam.Exponent.ToByteArrayUnsigned()));
|
string encryptedContent = string.Empty;
|
using (RSACryptoServiceProvider rsa = new RSACryptoServiceProvider())
|
{
|
rsa.FromXmlString(XML);
|
byte[] encryptedData = rsa.Encrypt(Encoding.Default.GetBytes(data), false);
|
encryptedContent = Convert.ToBase64String(encryptedData);
|
}
|
return encryptedContent;
|
}
|
|
private async Task<string> PostFormAsync(string url, Dictionary<string, object> data)
|
{
|
// 改用FormUrlEncodedContent并正确设置Content-Type
|
var formData = new List<KeyValuePair<string, string>>();
|
foreach (var item in data)
|
{
|
formData.Add(new KeyValuePair<string, string>(item.Key, item.Value.ToString()));
|
}
|
|
var content = new FormUrlEncodedContent(formData);
|
content.Headers.ContentType = new System.Net.Http.Headers.MediaTypeHeaderValue("application/x-www-form-urlencoded");
|
|
var response = await _httpClient.PostAsync(url, content);
|
var responseString = await response.Content.ReadAsStringAsync();
|
|
// 添加响应元数据
|
var responseInfo = new JObject
|
{
|
["StatusCode"] = (int)response.StatusCode,
|
["ReasonPhrase"] = response.ReasonPhrase,
|
["Headers"] = JToken.FromObject(response.Headers),
|
["Content"] = responseString
|
};
|
|
// 调试输出完整响应信息
|
Console.WriteLine($"完整响应：\n{responseInfo.ToString(Formatting.Indented)}");
|
|
return responseInfo.ToString();
|
}
|
|
public void Dispose()
|
{
|
_httpClient?.Dispose();
|
}
|
}
|
