| | |
| | | // 2. 获取访问令牌 |
| | | var tokenResult = ApplyTokenAsync(secret, spk); |
| | | var token = tokenResult["token"].ToString(); |
| | | string oaUserId = ""; |
| | | using (var conn = new SqlConnection(DbHelperSQL.strConn)) |
| | | { |
| | | using (var cmd = new SqlCommand("select_oa_userid", conn)) |
| | | { |
| | | |
| | | try |
| | | { |
| | | conn.Open(); |
| | | cmd.CommandType = CommandType.StoredProcedure; |
| | | cmd.Parameters.Add(new SqlParameter("@guid", SqlDbType.VarChar, 100) { Value = queryObj.qcczdGuid.ToString() }); |
| | | |
| | | using (var reader = cmd.ExecuteReader()) |
| | | { |
| | | if (reader.Read()) |
| | | { |
| | | oaUserId = reader["result"]?.ToString(); |
| | | } |
| | | } |
| | | } |
| | | catch (Exception logEx) |
| | | { |
| | | Console.WriteLine($"获取OA用户ID失败: {logEx.Message}"); |
| | | } |
| | | finally |
| | | { |
| | | conn.Close(); |
| | | } |
| | | } |
| | | } |
| | | |
| | | // 3. 准备请求头(移除Content-Type设置) |
| | | _httpClient.DefaultRequestHeaders.Clear(); |
| | | _httpClient.DefaultRequestHeaders.Add("token", token); |
| | | _httpClient.DefaultRequestHeaders.Add("appid", AppId); |
| | | _httpClient.DefaultRequestHeaders.Add("userid", RSAEncrypt("1268", spk)); |
| | | _httpClient.DefaultRequestHeaders.Add("userid", RSAEncrypt(oaUserId, spk)); |
| | | |
| | | // 4. 构建请求体 |
| | | var requestData = BuildRequestData(queryObj); |
| | |
| | | { |
| | | {"mainData", BuildMainData(queryObj)}, |
| | | {"requestName", $"IQC异常处置单流程-{DateTime.Now:yyyyMMddHHmmss}"}, |
| | | {"workflowId", "600"},//测试:379 正式:600 |
| | | {"workflowId", "602"},//测试:379 正式:600->602 |
| | | //{"otherParams", BuildOtherParams()}, |
| | | {"detailData", BuildDetailData(queryObj)} |
| | | }; |