From 823e5cae379ee1a259f79060ca0015d381c61f79 Mon Sep 17 00:00:00 2001
From: xwt <2740516069@qq.com>
Date: 星期六, 16 八月 2025 08:32:11 +0800
Subject: [PATCH] 入库检，来料检显示权限
---
StandardInterface/MES.Service/Dto/service/XJPageResult.cs | 2
StandardInterface/MESApplication/Controllers/QcIssueResult/QcIssueResultController.cs | 4
StandardInterface/MES.Service/Modes/QsItemOqcReq.cs | 24 ++
StandardInterface/MES.Service/service/QC/LljService.cs | 2
StandardInterface/MES.Service/service/QcIssueResult/QcIssueResultManager.cs | 8
StandardInterface/MES.Service/service/QC/RKJService.cs | 304 ++++++++++++++++++++++++++++++
StandardInterface/MESApplication/Controllers/QC/RKJController.cs | 194 +++++++++++++++++++
StandardInterface/MES.Service/Dto/service/RKJDto.cs | 12 +
StandardInterface/MESApplication/appsettings.json | 2
9 files changed, 546 insertions(+), 6 deletions(-)
diff --git a/StandardInterface/MES.Service/Dto/service/RKJDto.cs b/StandardInterface/MES.Service/Dto/service/RKJDto.cs
index 56f1425..73bcbbd 100644
--- a/StandardInterface/MES.Service/Dto/service/RKJDto.cs
+++ b/StandardInterface/MES.Service/Dto/service/RKJDto.cs
@@ -23,6 +23,18 @@
// 閫佹鏁伴噺
public decimal? quantity { get; set; }
+ // 涓嶈壇鍘熷洜
+ public string? BLYY { get; set; }
+
+ // 璇勫鐘舵��
+ public string? PSZT { get; set; }
+
+ // 鎵�灞炶溅闂�
+ public string? SSCJ { get; set; }
+
+ // 妫�楠屽崟鍙�
+ public string? releaseNo { get; set; }
+
//==========================================
//宸℃涓诲瓙琛ㄩ渶瑕佺殑鏁版嵁
public QsItemOqcReq? from { get; set; }
diff --git a/StandardInterface/MES.Service/Dto/service/XJPageResult.cs b/StandardInterface/MES.Service/Dto/service/XJPageResult.cs
index 4acaf9d..71220c0 100644
--- a/StandardInterface/MES.Service/Dto/service/XJPageResult.cs
+++ b/StandardInterface/MES.Service/Dto/service/XJPageResult.cs
@@ -13,4 +13,6 @@
public string? UserIndex { get; set; }
+ public string? fsubmit { get; set; }
+
}
\ No newline at end of file
diff --git a/StandardInterface/MES.Service/Modes/QsItemOqcReq.cs b/StandardInterface/MES.Service/Modes/QsItemOqcReq.cs
index 7a4d22f..0d76abf 100644
--- a/StandardInterface/MES.Service/Modes/QsItemOqcReq.cs
+++ b/StandardInterface/MES.Service/Modes/QsItemOqcReq.cs
@@ -161,4 +161,28 @@
/// </summary>
[SugarColumn(ColumnName = "QUANTITY")]
public decimal? Quantity { get; set; }
+
+ /// <summary>
+ /// 涓嶈壇鍘熷洜
+ /// </summary>
+ [SugarColumn(ColumnName = "BLYY")]
+ public string? Blyy { get; set; }
+
+ /// <summary>
+ /// 璇勫鐘舵��
+ /// </summary>
+ [SugarColumn(ColumnName = "PSZT")]
+ public string? Pszt { get; set; }
+
+ /// <summary>
+ /// 鎵�灞炶溅闂�
+ /// </summary>
+ [SugarColumn(ColumnName = "SSCJ")]
+ public string? Sscj { get; set; }
+
+ /// <summary>
+ /// 涓嶈壇鎻忚堪
+ /// </summary>
+ [SugarColumn(ColumnName = "FNG_DESC")]
+ public string? FngDesc { get; set; }
}
\ No newline at end of file
diff --git a/StandardInterface/MES.Service/service/QC/LljService.cs b/StandardInterface/MES.Service/service/QC/LljService.cs
index 78ba1fb..2e9fae5 100644
--- a/StandardInterface/MES.Service/service/QC/LljService.cs
+++ b/StandardInterface/MES.Service/service/QC/LljService.cs
@@ -45,7 +45,7 @@
e, f, g, i) => a.FcheckResu != null)
.WhereIF(id > 0, (a, b,
e, f, g, i) => a.Id == id)
- .WhereIF(queryObj.createUser != "PL017" && queryObj.UserIndex == "0", (a, b,
+ .WhereIF(queryObj.createUser != "PL017" && queryObj.createUser != "HMLYY" && queryObj.UserIndex == "0", (a, b,
e, f, g, i) => (g.Fcode == queryObj.createUser || i.Fcode == queryObj.createUser ||
(g.Fcode == null && i.Fcode == null)))//鍒ゆ柇姝ゅ崟鐨勬楠屽憳锛屾垨鑰呮楠屼负绌哄氨鏄剧ず姝ゅ崟鎹�
diff --git a/StandardInterface/MES.Service/service/QC/RKJService.cs b/StandardInterface/MES.Service/service/QC/RKJService.cs
index 06e7a22..1365909 100644
--- a/StandardInterface/MES.Service/service/QC/RKJService.cs
+++ b/StandardInterface/MES.Service/service/QC/RKJService.cs
@@ -1,10 +1,14 @@
锘縰sing MES.Service.DB;
using MES.Service.Dto.service;
using MES.Service.Modes;
+using MES.Service.Modes.QcIssueResult;
+using MES.Service.service.QcIssueResult;
using MES.Service.util;
using SqlSugar;
using System.Linq;
using System.Data;
+using System.Net;
+using System.Web;
namespace MES.Service.service.QC;
@@ -624,6 +628,13 @@
!"鏈畬鎴�".Equals(queryObj.result),
(a, da, b) => a.FcheckResu != null && a.FcheckResu != "")
.WhereIF(id > 0, (a, da, b) => a.Id == id)
+ // 娣诲姞fsubmit瀛楁杩囨护閫昏緫
+ .WhereIF(
+ StringUtil.IsNotNullOrEmpty(queryObj.fsubmit) && queryObj.fsubmit == "1",
+ (a, da, b) => a.Fsubmit == 1)
+ .WhereIF(
+ StringUtil.IsNullOrEmpty(queryObj.fsubmit) || queryObj.fsubmit == "0",
+ (a, da, b) => a.Fsubmit == 0 || a.Fsubmit == null)
.Select((a, da, b) => new QsItemOqcReq
{
Id = a.Id,
@@ -641,6 +652,11 @@
Remarks = a.Remarks,
WorkShop = a.WorkShop,
DepartmentId = a.DepartmentId,
+ Fsubmit = a.Fsubmit, // 娣诲姞fsubmit瀛楁鍒拌繑鍥炵粨鏋�
+ Blyy = a.Blyy, // 娣诲姞涓嶈壇鍘熷洜瀛楁
+ Pszt = a.Pszt, // 娣诲姞璇勫鐘舵�佸瓧娈�
+ Sscj = a.Sscj, // 娣诲姞鎵�灞炶溅闂村瓧娈�
+ FngDesc = a.FngDesc, // 娣诲姞涓嶈壇鎻忚堪瀛楁
// 浠庡叧鑱旇〃鑾峰彇鐨勫瓧娈�
ItemName = b.ItemName,
ItemModel = b.ItemModel,
@@ -811,6 +827,78 @@
{
return SqlSugarHelper.UseTransactionWithOracle(db =>
{
+ // 鑾峰彇妫�楠屽崟璇︾粏淇℃伅
+ var inspectionData = db.Queryable<QsItemOqcReq>()
+ .Where(it => it.Id == id)
+ .First();
+
+ if (inspectionData == null)
+ {
+ throw new Exception("妫�楠屽崟涓嶅瓨鍦�");
+ }
+
+ // 妫�鏌ラ拤閽夋帹閫佹潯浠讹細PSZT涓哄緟鍒わ紝涓斾笉鑹師鍥犮�佷笉鑹弿杩般�佹墍灞炶溅闂翠笉涓虹┖
+ bool shouldPushToDingTalk = inspectionData.Pszt == "寰呭垽" &&
+ !string.IsNullOrEmpty(inspectionData.Blyy) &&
+ !string.IsNullOrEmpty(inspectionData.FngDesc) &&
+ !string.IsNullOrEmpty(inspectionData.Sscj);
+
+ // 濡傛灉婊¤冻鎺ㄩ�佹潯浠讹紝鍒欐帹閫佸埌閽夐拤
+ if (shouldPushToDingTalk)
+ {
+ try
+ {
+ // 鏋勫缓閽夐拤鎺ㄩ�佹暟鎹�
+ var dingTalkData = new GetQcIssueResultDetail
+ {
+ FbatchQty = inspectionData.Quantity?.ToString(), // 閫佹鏁伴噺
+ ItemName = inspectionData.ItemName,
+ ItemNo = inspectionData.ItemNo,
+ SuppName = "鐢熶骇鍏ュ簱", // 鍥哄畾鍊�
+ AppicationReason = inspectionData.FngDesc, // 涓嶈壇鎻忚堪
+ BadReason = inspectionData.Blyy, // 涓嶈壇鍘熷洜
+ remark = inspectionData.Remarks,
+ ReleaseNo = inspectionData.ReleaseNo,
+ StaffNo = userNo,
+ IqcStatus = inspectionData.Pszt, // 璇勫鐘舵��
+ Department = inspectionData.Sscj, // 浣跨敤鎵�灞炶溅闂翠綔涓洪儴闂�
+ WorkShop = inspectionData.Sscj, // 鎵�灞炶溅闂�
+ EMERGENCY = "0" // 鍥哄畾鍊间负0
+ };
+
+ // 璋冪敤閽夐拤鎺ㄩ�佹湇鍔�
+ var qcIssueResultManager = new QcIssueResultManager();
+ string dingTalkResult = qcIssueResultManager.GetProcessNo(dingTalkData, "RKJ");
+
+ // 瑙ｆ瀽閽夐拤杩斿洖缁撴灉锛岃幏鍙栨祦绋嬪疄渚婭D
+ if (dingTalkResult.Contains("閽夐拤宸ヤ綔娴佸疄渚嬪惎鍔ㄦ垚鍔�"))
+ {
+ // 鎻愬彇instanceId
+ int startIndex = dingTalkResult.IndexOf("\"InstanceId\":\"") + 14;
+ int endIndex = dingTalkResult.IndexOf("\"", startIndex);
+ if (startIndex > 13 && endIndex > startIndex)
+ {
+ string instanceId = dingTalkResult.Substring(startIndex, endIndex - startIndex);
+
+ // 淇濆瓨閽夐拤娴佺▼淇℃伅
+ qcIssueResultManager.SaveProcessNo(
+ inspectionData.ReleaseNo,
+ instanceId,
+ userNo,
+ inspectionData.Sscj,
+ inspectionData.Pszt
+ );
+ }
+ }
+ }
+ catch (Exception ex)
+ {
+ // 閽夐拤鎺ㄩ�佸け璐ヤ笉褰卞搷妫�楠屾彁浜わ紝鍙褰曟棩蹇�
+ Console.WriteLine($"閽夐拤鎺ㄩ�佸け璐�: {ex.Message}");
+ }
+ }
+
+ // 鏇存柊妫�楠屽崟鐘舵��
return db.Updateable<QsItemOqcReq>()
.SetColumns(it => it.Fsubmit == 1) // 璁剧疆鎻愪氦鐘舵�佷负1锛堝凡鎻愪氦锛�
.SetColumns(it => it.FcheckBy == userNo) // 璁剧疆妫�楠屼汉
@@ -851,4 +939,220 @@
return (result, message);
}
+
+ /// <summary>
+ /// 鑾峰彇闄勪欢淇℃伅
+ /// </summary>
+ /// <param name="ItemNo">鐗╂枡缂栫爜</param>
+ /// <returns>闄勪欢鍒楄〃</returns>
+ public List<QamftpDto> GetAttachments(string ItemNo)
+ {
+ var db = SqlSugarHelper.GetInstance();
+ try
+ {
+ return db.Queryable<MesQamftp>()
+ .Where(x => x.ItemNo == ItemNo)
+ .OrderBy(x => x.Fdate, OrderByType.Desc)
+ .Select(x => new QamftpDto
+ {
+ Id = x.Id,
+ itemNo = x.ItemNo,
+ Ftype = x.Ftype,
+ Fattach = x.Fattach,
+ Fversion = x.Fversion,
+ Fdate = x.Fdate,
+ CreateBy = x.CreateBy,
+ CreateDate = x.CreateDate,
+ Company = x.Company,
+ Factory = x.Factory,
+ F_type = x.F_type,
+ LastupdateBy = x.LastupdateBy,
+ LastupdateDate = x.LastupdateDate,
+ ItemId = x.ItemId
+ }).ToList();
+ }
+ catch (Exception ex)
+ {
+ throw new Exception($"鏌ヨ闄勪欢淇℃伅澶辫触: {ex.Message}");
+ }
+ }
+
+ /// <summary>
+ /// 浠嶧TP鏈嶅姟鍣ㄨ幏鍙栨枃浠�
+ /// </summary>
+ /// <param name="itemNo">鐗╂枡缂栫爜</param>
+ /// <param name="fileName">鏂囦欢鍚�</param>
+ /// <param name="ftpServer">FTP鏈嶅姟鍣ㄥ湴鍧�</param>
+ /// <returns>鏂囦欢瀛楄妭鏁扮粍</returns>
+ public byte[] GetFtpFile(string itemNo, string fileName, string ftpServer)
+ {
+ // 鍙傛暟楠岃瘉
+ if (string.IsNullOrEmpty(itemNo) || string.IsNullOrEmpty(fileName) || string.IsNullOrEmpty(ftpServer))
+ {
+ throw new ArgumentException("鍙傛暟涓嶈兘涓虹┖: itemNo, fileName, ftpServer");
+ }
+
+ string ftpUser = "hm_ftp";
+ string ftpPwd = "dell_123";
+
+ // 鏍囧噯鍖朏TP鏈嶅姟鍣ㄥ湴鍧�
+ string normalizedServer = NormalizeFtpServer(ftpServer);
+
+ // 鏋勫缓FTP鏂囦欢璺緞 - RKJ浣跨敤FQC鏂囦欢澶�
+ string ftpPath = $"{normalizedServer}/FQC/{itemNo}/{fileName}";
+
+ try
+ {
+ var request = (System.Net.FtpWebRequest)System.Net.WebRequest.Create(ftpPath);
+ request.Method = System.Net.WebRequestMethods.Ftp.DownloadFile;
+ request.Credentials = new System.Net.NetworkCredential(ftpUser, ftpPwd);
+ request.UseBinary = true;
+ request.UsePassive = false;
+ request.Timeout = 30000; // 30绉掕秴鏃�
+ request.ReadWriteTimeout = 30000;
+
+ using (var response = (System.Net.FtpWebResponse)request.GetResponse())
+ using (var ftpStream = response.GetResponseStream())
+ using (var ms = new System.IO.MemoryStream())
+ {
+ if (ftpStream == null)
+ {
+ throw new Exception("FTP鍝嶅簲娴佷负绌�");
+ }
+
+ ftpStream.CopyTo(ms);
+ var fileBytes = ms.ToArray();
+
+ if (fileBytes.Length == 0)
+ {
+ return null; // 鏂囦欢涓虹┖鎴栦笉瀛樺湪
+ }
+
+ return fileBytes;
+ }
+ }
+ catch (System.Net.WebException ex)
+ {
+ if (ex.Response is System.Net.FtpWebResponse ftpResponse)
+ {
+ switch (ftpResponse.StatusCode)
+ {
+ case System.Net.FtpStatusCode.ActionNotTakenFileUnavailable:
+ return null; // 鏂囦欢涓嶅瓨鍦�
+ case System.Net.FtpStatusCode.NotLoggedIn:
+ throw new Exception("FTP璁よ瘉澶辫触锛岃妫�鏌ョ敤鎴峰悕鍜屽瘑鐮�");
+ case System.Net.FtpStatusCode.ActionNotTakenFilenameNotAllowed:
+ throw new Exception("鏂囦欢鍚嶄笉琚厑璁告垨璺緞鏃犳晥");
+ default:
+ throw new Exception($"FTP閿欒 ({ftpResponse.StatusCode}): {ftpResponse.StatusDescription}");
+ }
+ }
+
+ // 澶勭悊瓒呮椂鍜岀綉缁滈敊璇�
+ if (ex.Status == System.Net.WebExceptionStatus.Timeout)
+ {
+ throw new Exception("FTP杩炴帴瓒呮椂锛岃绋嶅悗閲嶈瘯");
+ }
+
+ throw new Exception($"FTP杩炴帴澶辫触: {ex.Message}");
+ }
+ catch (Exception ex)
+ {
+ throw new Exception($"鑾峰彇FTP鏂囦欢澶辫触: {ex.Message}");
+ }
+ }
+
+ /// <summary>
+ /// 鑾峰彇鏂囦欢鍐呭绫诲瀷
+ /// </summary>
+ /// <param name="fileName">鏂囦欢鍚�</param>
+ /// <returns>鍐呭绫诲瀷</returns>
+ public string GetContentType(string fileName)
+ {
+ if (string.IsNullOrEmpty(fileName))
+ return "application/octet-stream";
+
+ var extension = System.IO.Path.GetExtension(fileName).ToLowerInvariant();
+ return extension switch
+ {
+ ".pdf" => "application/pdf",
+ ".jpg" or ".jpeg" => "image/jpeg",
+ ".png" => "image/png",
+ ".gif" => "image/gif",
+ ".bmp" => "image/bmp",
+ ".txt" => "text/plain",
+ ".doc" => "application/msword",
+ ".docx" => "application/vnd.openxmlformats-officedocument.wordprocessingml.document",
+ ".xls" => "application/vnd.ms-excel",
+ ".xlsx" => "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet",
+ ".ppt" => "application/vnd.ms-powerpoint",
+ ".pptx" => "application/vnd.openxmlformats-officedocument.presentationml.presentation",
+ _ => "application/octet-stream"
+ };
+ }
+
+ /// <summary>
+ /// 鏍囧噯鍖朏TP鏈嶅姟鍣ㄥ湴鍧�
+ /// </summary>
+ /// <param name="ftpServer">FTP鏈嶅姟鍣ㄥ湴鍧�</param>
+ /// <returns>鏍囧噯鍖栧悗鐨勫湴鍧�</returns>
+ private string NormalizeFtpServer(string ftpServer)
+ {
+ if (string.IsNullOrEmpty(ftpServer))
+ throw new ArgumentException("FTP鏈嶅姟鍣ㄥ湴鍧�涓嶈兘涓虹┖");
+
+ // 绉婚櫎鍙兘鐨勫崗璁墠缂�
+ var normalized = ftpServer.Trim();
+ if (normalized.StartsWith("ftp://", StringComparison.OrdinalIgnoreCase))
+ {
+ normalized = normalized.Substring(6);
+ }
+ else if (normalized.StartsWith("ftps://", StringComparison.OrdinalIgnoreCase))
+ {
+ normalized = normalized.Substring(7);
+ }
+
+ // 纭繚浠tp://寮�澶�
+ if (!normalized.StartsWith("ftp://", StringComparison.OrdinalIgnoreCase))
+ {
+ normalized = "ftp://" + normalized;
+ }
+
+ return normalized;
+ }
+
+ /// <summary>
+ /// 淇濆瓨涓嬫媺妗嗗瓧娈碉紙涓嶈壇鍘熷洜銆佽瘎瀹＄姸鎬併�佹墍灞炶溅闂达級
+ /// </summary>
+ /// <param name="dto">鍖呭惈瀛楁鏁版嵁鐨凞TO</param>
+ /// <returns>鏇存柊缁撴灉</returns>
+ public int SaveDropdownFields(RKJDto dto)
+ {
+ return SqlSugarHelper.UseTransactionWithOracle(db =>
+ {
+ return db.Updateable<QsItemOqcReq>()
+ .SetColumns(it => it.Blyy == dto.BLYY)
+ .SetColumns(it => it.Pszt == dto.PSZT)
+ .SetColumns(it => it.Sscj == dto.SSCJ)
+ .Where(it => it.ReleaseNo == dto.releaseNo)
+ .ExecuteCommand();
+ });
+ }
+
+ /// <summary>
+ /// 淇濆瓨涓嶈壇鎻忚堪
+ /// </summary>
+ /// <param name="gid">妫�楠屽崟ID</param>
+ /// <param name="fngDesc">涓嶈壇鎻忚堪</param>
+ /// <returns>鏇存柊缁撴灉</returns>
+ public int SaveFngDesc(decimal gid, string fngDesc)
+ {
+ return SqlSugarHelper.UseTransactionWithOracle(db =>
+ {
+ return db.Updateable<QsItemOqcReq>()
+ .SetColumns(it => it.FngDesc == fngDesc)
+ .Where(it => it.Id == gid)
+ .ExecuteCommand();
+ });
+ }
}
\ No newline at end of file
diff --git a/StandardInterface/MES.Service/service/QcIssueResult/QcIssueResultManager.cs b/StandardInterface/MES.Service/service/QcIssueResult/QcIssueResultManager.cs
index e65234b..a6dff30 100644
--- a/StandardInterface/MES.Service/service/QcIssueResult/QcIssueResultManager.cs
+++ b/StandardInterface/MES.Service/service/QcIssueResult/QcIssueResultManager.cs
@@ -213,7 +213,7 @@
* @return string 杩斿洖鍚姩缁撴灉
*/
- public string GetProcessNo(GetQcIssueResultDetail getQcIssueResultDetail)
+ public string GetProcessNo(GetQcIssueResultDetail getQcIssueResultDetail, string processType = "LLJ")
{
var db = SqlSugarHelper.GetInstance();
@@ -247,6 +247,10 @@
AlibabaCloud.SDK.Dingtalkworkflow_1_0.Models.StartProcessInstanceHeaders startProcessInstanceHeaders = new AlibabaCloud.SDK.Dingtalkworkflow_1_0.Models.StartProcessInstanceHeaders();
Debug.WriteLine(accessToken);
startProcessInstanceHeaders.XAcsDingtalkAccessToken = accessToken; // 浣跨敤鑾峰彇鍒扮殑 Access Token
+
+ // 鏍规嵁娴佺▼绫诲瀷閫夋嫨涓嶅悓鐨凱rocessCode
+ string processCode = "PROC-4F4B3976-BA15-47EF-9A3C-3A07AC07DFEA"; // 缁熶竴浣跨敤鏉ユ枡妫�娴佺▼缂栫爜
+
AlibabaCloud.SDK.Dingtalkworkflow_1_0.Models.StartProcessInstanceRequest.StartProcessInstanceRequestFormComponentValues formComponentValues1 = new AlibabaCloud.SDK.Dingtalkworkflow_1_0.Models.StartProcessInstanceRequest.StartProcessInstanceRequestFormComponentValues
{
Name = "TextField_K5AVR59BD28",
@@ -359,7 +363,7 @@
AlibabaCloud.SDK.Dingtalkworkflow_1_0.Models.StartProcessInstanceRequest startProcessInstanceRequest = new AlibabaCloud.SDK.Dingtalkworkflow_1_0.Models.StartProcessInstanceRequest
{
OriginatorUserId = UserId,
- ProcessCode = "PROC-4F4B3976-BA15-47EF-9A3C-3A07AC07DFEA",
+ ProcessCode = processCode,
DeptId = 1,
FormComponentValues = new List<AlibabaCloud.SDK.Dingtalkworkflow_1_0.Models.StartProcessInstanceRequest.StartProcessInstanceRequestFormComponentValues>
{
diff --git a/StandardInterface/MESApplication/Controllers/QC/RKJController.cs b/StandardInterface/MESApplication/Controllers/QC/RKJController.cs
index d6e231d..2f8057f 100644
--- a/StandardInterface/MESApplication/Controllers/QC/RKJController.cs
+++ b/StandardInterface/MESApplication/Controllers/QC/RKJController.cs
@@ -5,6 +5,7 @@
using MES.Service.util;
using Microsoft.AspNetCore.Mvc;
using Newtonsoft.Json.Linq;
+using System.Web;
namespace MESApplication.Controllers.QC;
@@ -514,4 +515,197 @@
return ResponseResult.ResponseError(ex);
}
}
+
+ /// <summary>
+ /// 淇濆瓨涓嬫媺妗嗗瓧娈碉紙涓嶈壇鍘熷洜銆佽瘎瀹＄姸鎬併�佹墍灞炶溅闂达級
+ /// </summary>
+ /// <param name="rkjDto">鍖呭惈瀛楁鏁版嵁鐨凞TO</param>
+ /// <returns>淇濆瓨缁撴灉</returns>
+ [HttpPost("saveDropdownFields")]
+ public ResponseResult SaveDropdownFields([FromBody] RKJDto rkjDto)
+ {
+ try
+ {
+ dynamic resultInfos = new ExpandoObject();
+ var tbBillList = new RKJService().SaveDropdownFields(rkjDto);
+ resultInfos.tbBillList = tbBillList;
+ return new ResponseResult
+ {
+ status = 0,
+ message = "OK",
+ data = resultInfos
+ };
+ }
+ catch (Exception ex)
+ {
+ return ResponseResult.ResponseError(ex);
+ }
+ }
+
+ /// <summary>
+ /// 淇濆瓨涓嶈壇鎻忚堪
+ /// </summary>
+ /// <param name="data">鍖呭惈gid鍜宖ngDesc鐨凧SON瀵硅薄</param>
+ /// <returns>淇濆瓨缁撴灉</returns>
+ [HttpPost("saveFngDesc")]
+ public ResponseResult SaveFngDesc([FromBody] JObject data)
+ {
+ try
+ {
+ var gid = Convert.ToDecimal(data["gid"]?.ToString());
+ var fngDesc = data["fngDesc"]?.ToString();
+
+ dynamic resultInfos = new ExpandoObject();
+ var tbBillList = new RKJService().SaveFngDesc(gid, fngDesc);
+ resultInfos.tbBillList = tbBillList;
+ return new ResponseResult
+ {
+ status = 0,
+ message = "OK",
+ data = resultInfos
+ };
+ }
+ catch (Exception ex)
+ {
+ return ResponseResult.ResponseError(ex);
+ }
+ }
+
+ /// <summary>
+ /// 鑾峰彇闄勪欢淇℃伅
+ /// </summary>
+ /// <param name="data">鍖呭惈itemNo鐨凧SON瀵硅薄</param>
+ /// <returns>闄勪欢鍒楄〃</returns>
+ [HttpPost("getAttachments")]
+ public ResponseResult GetAttachments([FromBody] JObject data)
+ {
+ var itemNo = data["itemNo"]?.ToString();
+ try
+ {
+ dynamic resultInfos = new System.Dynamic.ExpandoObject();
+ var tbBillList = new RKJService().GetAttachments(itemNo);
+ if (tbBillList == null || tbBillList.Count == 0)
+ {
+ return new ResponseResult
+ {
+ status = 1,
+ message = "璇ユ楠屽崟鏈笂浼犻檮浠朵俊鎭紒",
+ data = null
+ };
+ }
+ resultInfos.tbBillList = tbBillList;
+ return new ResponseResult
+ {
+ status = 0,
+ message = "OK",
+ data = resultInfos
+ };
+ }
+ catch (Exception ex)
+ {
+ return ResponseResult.ResponseError(ex);
+ }
+ }
+
+ /// <summary>
+ /// 棰勮FTP鏂囦欢
+ /// </summary>
+ /// <param name="itemNo">鐗╂枡缂栫爜</param>
+ /// <param name="fileName">鏂囦欢鍚�</param>
+ /// <param name="ftpServer">FTP鏈嶅姟鍣ㄥ湴鍧�</param>
+ /// <returns>鏂囦欢鍐呭</returns>
+ [HttpGet("PreviewFtpFile")]
+ public IActionResult PreviewFtpFile([FromQuery] string itemNo, [FromQuery] string fileName, [FromQuery] string ftpServer)
+ {
+ try
+ {
+ // 娣诲姞CORS鍝嶅簲澶�
+ Response.Headers.Add("Access-Control-Allow-Origin", "*");
+ Response.Headers.Add("Access-Control-Allow-Methods", "GET, OPTIONS");
+ Response.Headers.Add("Access-Control-Allow-Headers", "Content-Type");
+ Response.Headers.Add("Access-Control-Expose-Headers", "Content-Type, Content-Length");
+
+ var service = new RKJService();
+ var fileBytes = service.GetFtpFile(itemNo, fileName, ftpServer);
+
+ if (fileBytes == null || fileBytes.Length == 0)
+ {
+ return NotFound("鏂囦欢鍦‵TP鏈嶅姟鍣ㄤ笂涓嶅瓨鍦�");
+ }
+
+ var contentType = service.GetContentType(fileName);
+ fileName = fileName?.Trim().Replace("\r", "").Replace("\n", "");
+
+ return File(fileBytes, contentType);
+ }
+ catch (Exception ex)
+ {
+ return StatusCode(500, $"棰勮鏂囦欢澶辫触锛歿ex.Message}");
+ }
+ }
+
+ /// <summary>
+ /// 涓嬭浇FTP鏂囦欢
+ /// </summary>
+ /// <param name="itemNo">鐗╂枡缂栫爜</param>
+ /// <param name="fileName">鏂囦欢鍚�</param>
+ /// <param name="ftpServer">FTP鏈嶅姟鍣ㄥ湴鍧�</param>
+ /// <returns>鏂囦欢涓嬭浇</returns>
+ [HttpGet("DownloadFtpFile")]
+ public IActionResult DownloadFtpFile([FromQuery] string itemNo, [FromQuery] string fileName, [FromQuery] string ftpServer)
+ {
+ try
+ {
+ // 娣诲姞CORS鍝嶅簲澶� - 鍏抽敭閰嶇疆鐢ㄤ簬瑙ｅ喅璺ㄥ煙闂
+ Response.Headers.Add("Access-Control-Allow-Origin", "*");
+ Response.Headers.Add("Access-Control-Allow-Methods", "GET, OPTIONS");
+ Response.Headers.Add("Access-Control-Allow-Headers", "Content-Type, Authorization");
+ Response.Headers.Add("Access-Control-Expose-Headers", "Content-Disposition, Content-Length, Content-Type");
+
+ var service = new RKJService();
+ var fileBytes = service.GetFtpFile(itemNo, fileName, ftpServer);
+
+ if (fileBytes == null || fileBytes.Length == 0)
+ {
+ return NotFound("鏂囦欢鍦‵TP鏈嶅姟鍣ㄤ笂涓嶅瓨鍦�");
+ }
+
+ var contentType = service.GetContentType(fileName);
+ fileName = fileName?.Trim().Replace("\r", "").Replace("\n", "");
+
+ // 璁剧疆姝ｇ‘鐨凜ontent-Disposition鍝嶅簲澶翠互鏀寔鏂囦欢涓嬭浇
+ var result = File(fileBytes, "application/octet-stream", fileName);
+
+ // 纭繚Content-Disposition澶存纭缃紝鏀寔涓枃鏂囦欢鍚�
+ if (!string.IsNullOrEmpty(fileName))
+ {
+ var encodedFileName = System.Web.HttpUtility.UrlEncode(fileName, System.Text.Encoding.UTF8);
+ Response.Headers.Add("Content-Disposition", $"attachment; filename*=UTF-8''{encodedFileName}");
+ }
+
+ return result;
+ }
+ catch (Exception ex)
+ {
+ return StatusCode(500, $"涓嬭浇鏂囦欢澶辫触锛歿ex.Message}");
+ }
+ }
+
+ /// <summary>
+ /// 澶勭悊CORS棰勬璇锋眰
+ /// </summary>
+ /// <returns>OK</returns>
+ [HttpOptions("PreviewFtpFile")]
+ [HttpOptions("DownloadFtpFile")]
+ public IActionResult HandleOptions()
+ {
+ // 澶勭悊CORS棰勬璇锋眰
+ Response.Headers.Add("Access-Control-Allow-Origin", "*");
+ Response.Headers.Add("Access-Control-Allow-Methods", "GET, OPTIONS");
+ Response.Headers.Add("Access-Control-Allow-Headers", "Content-Type, Authorization");
+ Response.Headers.Add("Access-Control-Expose-Headers", "Content-Disposition, Content-Length, Content-Type");
+ Response.Headers.Add("Access-Control-Max-Age", "86400");
+
+ return Ok();
+ }
}
\ No newline at end of file
diff --git a/StandardInterface/MESApplication/Controllers/QcIssueResult/QcIssueResultController.cs b/StandardInterface/MESApplication/Controllers/QcIssueResult/QcIssueResultController.cs
index bfad3ad..319a217 100644
--- a/StandardInterface/MESApplication/Controllers/QcIssueResult/QcIssueResultController.cs
+++ b/StandardInterface/MESApplication/Controllers/QcIssueResult/QcIssueResultController.cs
@@ -33,7 +33,7 @@
[HttpPost("GetProcessNo")]
- public IActionResult StartDingtalkProcess([FromBody] GetQcIssueResultDetail getQcIssueResultDetail)
+ public IActionResult StartDingtalkProcess([FromBody] GetQcIssueResultDetail getQcIssueResultDetail, [FromQuery] string processType = "LLJ")
{
try
@@ -42,7 +42,7 @@
DecodeUrlEncodedProperties(getQcIssueResultDetail);
// 璋冪敤 QcIssueResultManager 涓殑 GetProcessNo 鏂规硶鏉ュ惎鍔ㄩ拤閽夊伐浣滄祦瀹炰緥
- string result = m.GetProcessNo(getQcIssueResultDetail);
+ string result = m.GetProcessNo(getQcIssueResultDetail, processType);
string getLaboratoryDetailsJson = JsonConvert.SerializeObject(getQcIssueResultDetail, Formatting.Indented);
Debug.WriteLine("getQcIssueResultDetail: " + getLaboratoryDetailsJson);
diff --git a/StandardInterface/MESApplication/appsettings.json b/StandardInterface/MESApplication/appsettings.json
index 28cfc2a..59a3601 100644
--- a/StandardInterface/MESApplication/appsettings.json
+++ b/StandardInterface/MESApplication/appsettings.json
@@ -10,6 +10,6 @@
"AppSettings": {
"TestErpUrl": "http://192.168.11.120:8098/WebService1.asmx/mesToErpinfo",
"ProductionErpUrl": "http://192.168.11.120:8098/WebService1.asmx/mesToErpinfoFormal",
- "DataBaseConn": "Data Source = (DESCRIPTION = (ADDRESS = (PROTOCOL = TCP)(HOST = 192.168.1.22)(PORT = 1521))(CONNECT_DATA = (SERVICE_NAME = ORCL))); Persist Security Info=True;User ID = hm_prd; Password=hmprd"
+ "DataBaseConn": "Data Source = (DESCRIPTION = (ADDRESS = (PROTOCOL = TCP)(HOST = 192.168.1.22)(PORT = 1521))(CONNECT_DATA = (SERVICE_NAME = ORCL))); Persist Security Info=True;User ID = test_dev; Password=hmprd"
}
}
--
Gitblit v1.9.3