MsystechandClaude Opus 5
3af7b3a071
ModifyDesign 은 운영 테이블에 쓰는데 한 번도 실행해 본 적이 없었다.
저장 경로에는 이 검증이 있고(RunSaveSmoke) 수정 경로에만 없었다 —
"코드는 맞아 보이는데" 상태이고, 이 저장소에서 그건 여러 번 틀렸다.
--db-modify-smoke <서식코드> <리포트>. 단정 8건:
① 활성 SdgKey 가 바뀌지 않는다 — EMR 이 참조하는 키 유지가 이 동작의 존재 이유다
② 활성 행이 새 디자인으로 갱신된다 (문구를 실제로 바꿔서 본다 —
무변경 재저장으로는 "갱신됐다"를 증명할 수 없다)
③ 이력 행이 하나 생기고, SdgDelYon='Y' 이고, <b>옛</b> XML 을 담는다
(저장과 방향이 반대다. 뒤집혔으면 ③-c 가 잡는다)
④ 감사 컬럼이 활성 행에 기록된다 — 레거시는 이걸 이력 행에 썼다(버그, 미복제)
⑤ E_SctMst 를 건드리지 않는다
+ 원복 2건
S999 실측: SdgKey 52451 유지, 버전 511 → 512 → 511, 감사 202608120855 → 202608180917.
<b>DB 를 원상태로 되돌린다.</b> 활성 행의 XML·감사값을 원문으로 UPDATE 하고
이 진단이 만든 이력 행을 지운다. DELETE 에 SdgDelYon='Y' 를 함께 걸어
<b>SdgKey 를 잘못 짚어도 활성 행은 어떤 경우에도 지워지지 않게</b> 했다.
<b>⑤ 가 공허하게 통과하고 있었다.</b> S999·P062 둘 다 E_SctMst 가 0건이라
"0 → 0" 을 비교했는데 PASS 로 찍혔다. 읽는 사람은 검증됐다고 믿는다.
행이 0건이면 SKIP 으로 적고 "행이 있는 서식으로 다시 돌려야 한다"를 남긴다.
이번 세션에만 같은 함정에 네 번 걸렸다 — 대조군 없는 0 은 증거가 아니다.
<b>남은 것</b>: ⑤ 를 실제로 재려면 E_SctMst 행이 있는 서식이 필요하다.
테스트 접속에서 아직 못 찾았다.
게이트: --db-modify-smoke 8/8(⑤ SKIP), 테스트 298/298, --edit-smoke 0실패,
--db-smoke 1271건 diff 0, --db-render P062 md5 8d683835f5d81e7bb41c79071d6bf954 동일.
Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
698 lines
33 KiB
C#
698 lines
33 KiB
C#
using Oracle.ManagedDataAccess.Client;
|
|
using SheetMe.Core.Models;
|
|
using SheetMe.Core.Serialization;
|
|
|
|
namespace SheetMe.Data.Stores;
|
|
|
|
/// <summary>서식 목록 1건(열기 대화상자)</summary>
|
|
/// <param name="DesignAllowed">서식생성기 사용 허용(E_ShtMst.ShtUsrDesYon) — 목록 잠금 표시용</param>
|
|
/// <param name="ClassCode">분류 코드(E_ShtMst.ShtClsCod) — 그룹 정렬 키</param>
|
|
/// <param name="ClassName">분류 한글명(M_DtlMst.DtlCodNam) — 그룹 헤더 표시</param>
|
|
public sealed record SheetSummary(
|
|
string ShtCod,
|
|
string Name,
|
|
bool HasDesign,
|
|
bool DesignAllowed,
|
|
string ClassCode,
|
|
string ClassName);
|
|
|
|
/// <summary>서식생성기 사용 권한 판정 결과</summary>
|
|
public enum SheetDesignPermission
|
|
{
|
|
/// <summary>E_ShtMst 에 서식 코드가 없음</summary>
|
|
NotRegistered,
|
|
|
|
/// <summary>허용 — ShtUsrDesYon 이 'Y' 또는 미설정</summary>
|
|
Allowed,
|
|
|
|
/// <summary>거부 — ShtUsrDesYon 이 'N' 등</summary>
|
|
Denied,
|
|
}
|
|
|
|
/// <summary>디자인 버전 1건</summary>
|
|
public sealed record DesignVersionInfo(decimal SdgKey, string UpdDtm, string UpdUid, bool Deleted);
|
|
|
|
/// <summary>
|
|
/// 레거시 테이블(E_ShtMst/E_SdgMst/E_SctMst) 기반 서식 저장소 — 레거시 디자이너와 동일 저장 의미론.
|
|
/// 저장 흐름(bzSaveSheetDesignNControlInfo 이식, 단일 트랜잭션):
|
|
/// ShtCneYon='Y'+활성행 존재 → 제자리 갱신(E_SctMst 는 신규 이름만 추가 + 기존 행 SctObjTxt 갱신),
|
|
/// 그 외 → 기존 활성행 SdgDelYon='Y' 후 신규 행 INSERT + E_SctMst 전체 재생성.
|
|
/// 채번: 전용 시퀀스 NEXTVAL 우선, 부재 시 MAX+1 폴백(트랜잭션 내 — [200]SheetMe 검증 방식).
|
|
/// </summary>
|
|
public sealed class OracleLegacyFormStore
|
|
{
|
|
#region Member Fields
|
|
/// <summary>Spread AsTemplate 항목 행의 SctObjTyp — 이 행은 ObjName 이 항목 텍스트라 컨트롤 이름과 구분해야 한다</summary>
|
|
private const string SpreadItemType = "ItemOfSpreadAsTemplate";
|
|
|
|
private readonly string connectionString;
|
|
private readonly LegacyXmlSerializer serializer = new();
|
|
#endregion
|
|
|
|
#region Constructors
|
|
public OracleLegacyFormStore(string connectionString)
|
|
{
|
|
this.connectionString = connectionString;
|
|
}
|
|
#endregion
|
|
|
|
#region Methods - 조회
|
|
/// <summary>
|
|
/// 서식 목록 검색 — 공백제거 UPPER LIKE 토큰 AND 매칭, 스캔서식(ShtTyp='S') 제외.
|
|
///
|
|
/// 분류(ShtClsCod)를 함께 읽어 목록을 묶는다. 코드→한글명은 <c>M_DtlMst</c> 의
|
|
/// <c>DtlTblCod='EMR_SHEET_GROUP'</c> 행이 소유하며, EMR 뷰어 트리가 쓰는 것과 같은 조인이라
|
|
/// (`[200]SheetMe/src/Data/SheetMe.Data/EmrTreeDataBusiness.cs:55`) 사용자가 이미 아는 분류가 그대로 나온다.
|
|
/// TRIM 비교 필수 — 두 컬럼 다 고정폭 잔여 공백이 섞여 있다.
|
|
/// 실측(운영 1,628건): 코드 24종 전부 마스터에 존재, 미분류는 1건뿐.
|
|
/// </summary>
|
|
public List<SheetSummary> ListSheets(string? keyword, int max = 300)
|
|
{
|
|
using var connection = Open();
|
|
using var command = connection.CreateCommand();
|
|
command.BindByName = true;
|
|
|
|
var where = "WHERE NVL(s.ShtTyp,' ') <> 'S'";
|
|
var tokens = (keyword ?? string.Empty)
|
|
.Split(' ', StringSplitOptions.RemoveEmptyEntries | StringSplitOptions.TrimEntries);
|
|
for (var i = 0; i < tokens.Length; i++)
|
|
{
|
|
// 분류명도 검색 대상 — 헤더에 보이는 '간호기록'을 그대로 쳤는데 0건이면 배신감이 크다
|
|
where += $" AND (UPPER(REPLACE(s.ShtKorNam,' ','')) LIKE :k{i} OR UPPER(s.ShtCod) LIKE :k{i}" +
|
|
$" OR UPPER(REPLACE(dtl.DtlCodNam,' ','')) LIKE :k{i})";
|
|
command.Parameters.Add(new OracleParameter($"k{i}", $"%{tokens[i].ToUpperInvariant()}%"));
|
|
}
|
|
|
|
command.CommandText =
|
|
"SELECT * FROM (" +
|
|
" SELECT s.ShtCod, s.ShtKorNam," +
|
|
" (SELECT COUNT(*) FROM E_SdgMst d WHERE d.SdgShtCod = s.ShtCod AND NVL(d.SdgDelYon,' ') <> 'Y') AS DesignCount," +
|
|
" NVL(TRIM(s.ShtUsrDesYon),' ') AS UsrDesYon," +
|
|
" NVL(TRIM(s.ShtClsCod),' ') AS ClsCod," +
|
|
" NVL(dtl.DtlCodNam,' ') AS ClsNam" +
|
|
" FROM E_ShtMst s" +
|
|
// 코드당 1행으로 접어서 조인한다 — M_DtlMst 는 PK 에 DtlStrDte 가 들어가 같은 분류 코드가
|
|
// 기간별 다중행일 수 있고, 그대로 조인하면 서식이 목록에 두 번 뜬다(운영 실측은 현재 증식 0건이지만
|
|
// 스키마상 가능하므로 데이터 운에 기대지 않는다). 적용일 최신 행을 택한다.
|
|
" LEFT JOIN (SELECT TRIM(DtlCod) AS Cod, DtlCodNam, DtlDspSeq," +
|
|
" ROW_NUMBER() OVER (PARTITION BY TRIM(DtlCod) ORDER BY DtlStrDte DESC) AS Rn" +
|
|
" FROM M_DtlMst WHERE DtlTblCod = 'EMR_SHEET_GROUP') dtl" +
|
|
" ON dtl.Cod = TRIM(s.ShtClsCod) AND dtl.Rn = 1" +
|
|
// 그룹 순서는 이 정렬이 그대로 정한다(CollectionView 는 등장 순서로 그룹을 만든다).
|
|
// 병원이 정한 표시순서(DtlDspSeq)를 1순위로 — 레거시 기록지정보 분류 탭이 이 순서다
|
|
// (`[002]Master/[024]기록지정보/M.MST.ShtMst/dtShtMst.vb:361-368`). 이 병원은 DspSeq 가 전부
|
|
// 비어 있어 결과적으로 코드순이 되지만, 채워 쓰는 병원에서 순서가 어긋나지 않는다.
|
|
// LPAD 는 레거시(2자리)보다 넉넉한 4자리 — '100' 과 '99' 가 뒤집히는 것을 막는다.
|
|
$" {where} ORDER BY CASE WHEN TRIM(s.ShtClsCod) IS NULL THEN 1 ELSE 0 END," +
|
|
" LPAD(NVL(dtl.DtlDspSeq,'9999'), 4, '0'), s.ShtClsCod, s.ShtCod" +
|
|
$") WHERE ROWNUM <= {max}";
|
|
|
|
var result = new List<SheetSummary>();
|
|
using var reader = command.ExecuteReader();
|
|
while (reader.Read())
|
|
{
|
|
var classCode = reader.GetString(4).Trim();
|
|
var className = reader.GetString(5).Trim();
|
|
result.Add(new SheetSummary(
|
|
reader.GetString(0),
|
|
reader.IsDBNull(1) ? string.Empty : reader.GetString(1),
|
|
reader.GetDecimal(2) > 0,
|
|
IsDesignAllowed(reader.GetString(3)),
|
|
classCode,
|
|
// 마스터에 없는 코드는 코드 자체를 헤더로 — 사이트가 코드를 추가했는데 마스터를 안 채운 경우
|
|
// '(미분류)'로 뭉뚱그리면 서로 다른 분류가 한 덩어리가 된다.
|
|
className.Length > 0 ? className : classCode));
|
|
}
|
|
return result;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 서식생성기 사용 허용 여부(E_ShtMst.ShtUsrDesYon) — 레거시 frmSheetDesigner.vb:71-84 규칙.
|
|
/// 'Y' 또는 빈 문자열/NULL(미설정 = 레거시 데이터 호환)이면 허용, 그 외('N' 등)만 거부한다.
|
|
/// </summary>
|
|
public SheetDesignPermission GetDesignPermission(string shtCod)
|
|
{
|
|
using var connection = Open();
|
|
var value = Scalar(connection, null,
|
|
"SELECT NVL(TRIM(ShtUsrDesYon),' ') FROM E_ShtMst WHERE ShtCod = :s",
|
|
new OracleParameter("s", shtCod)) as string;
|
|
if (value is null)
|
|
{
|
|
return SheetDesignPermission.NotRegistered;
|
|
}
|
|
return IsDesignAllowed(value) ? SheetDesignPermission.Allowed : SheetDesignPermission.Denied;
|
|
}
|
|
|
|
/// <summary>ShtUsrDesYon 판정 — CHAR 패딩을 흡수하려 TRIM 후 비교(레거시보다 관대한 방향이라 오탐만 줄인다)</summary>
|
|
private static bool IsDesignAllowed(string flag)
|
|
{
|
|
var trimmed = flag.Trim();
|
|
return trimmed is "Y" or "";
|
|
}
|
|
|
|
/// <summary>활성(비삭제 최신) 디자인 로드 — 없으면 null. FormId/Title/SourceSdgKey 채움</summary>
|
|
public FormDocument? LoadActiveDesign(string shtCod)
|
|
{
|
|
using var connection = Open();
|
|
|
|
var sdgKey = ResolveActiveSdgKey(connection, null, shtCod);
|
|
if (sdgKey == 0)
|
|
{
|
|
return null;
|
|
}
|
|
|
|
using var command = connection.CreateCommand();
|
|
command.BindByName = true;
|
|
command.CommandText = "SELECT SdgDesign FROM E_SdgMst WHERE SdgKey = :k";
|
|
command.Parameters.Add(new OracleParameter("k", sdgKey));
|
|
var xml = command.ExecuteScalar() as string;
|
|
if (string.IsNullOrWhiteSpace(xml))
|
|
{
|
|
return null;
|
|
}
|
|
|
|
var document = serializer.Read(xml);
|
|
document.FormId = shtCod;
|
|
document.Title = QueryTitle(connection, shtCod) ?? shtCod;
|
|
document.Meta.SourceSdgKey = sdgKey;
|
|
return document;
|
|
}
|
|
|
|
/// <summary>활성 디자인 원문 XML — (SdgKey, XML), 없으면 null (일괄 왕복 스모크용)</summary>
|
|
public (decimal SdgKey, string Xml)? LoadActiveDesignRaw(string shtCod)
|
|
{
|
|
using var connection = Open();
|
|
var sdgKey = ResolveActiveSdgKey(connection, null, shtCod);
|
|
if (sdgKey == 0)
|
|
{
|
|
return null;
|
|
}
|
|
using var command = connection.CreateCommand();
|
|
command.BindByName = true;
|
|
command.CommandText = "SELECT SdgDesign FROM E_SdgMst WHERE SdgKey = :k";
|
|
command.Parameters.Add(new OracleParameter("k", sdgKey));
|
|
return command.ExecuteScalar() is string xml && !string.IsNullOrWhiteSpace(xml)
|
|
? (sdgKey, xml)
|
|
: null;
|
|
}
|
|
|
|
/// <summary>디자인 버전의 E_SctMst 행 수(검증용)</summary>
|
|
public int CountSctRows(decimal sdgKey)
|
|
{
|
|
using var connection = Open();
|
|
return Convert.ToInt32(Scalar(connection, null,
|
|
"SELECT COUNT(*) FROM E_SctMst WHERE SctSdgKey = :k", new OracleParameter("k", sdgKey))!);
|
|
}
|
|
|
|
/// <summary>서식의 제자리 갱신 여부(ShtCneYon)</summary>
|
|
public string GetShtCneYon(string shtCod)
|
|
{
|
|
using var connection = Open();
|
|
return Scalar(connection, null,
|
|
"SELECT NVL(ShtCneYon,' ') FROM E_ShtMst WHERE ShtCod = :s",
|
|
new OracleParameter("s", shtCod)) as string ?? " ";
|
|
}
|
|
|
|
/// <summary>특정 버전(SdgKey) 디자인 로드 — 이력 열람/복원용. 없으면 null</summary>
|
|
/// <summary>특정 버전의 원문 XML — 이력 행이 옛 내용을 담았는지 확인하는 데 쓴다</summary>
|
|
public string? LoadDesignRawByKey(string shtCod, decimal sdgKey)
|
|
{
|
|
using var connection = Open();
|
|
using var command = connection.CreateCommand();
|
|
command.BindByName = true;
|
|
command.CommandText = "SELECT SdgDesign FROM E_SdgMst WHERE SdgKey = :k";
|
|
command.Parameters.Add(new OracleParameter("k", sdgKey));
|
|
return command.ExecuteScalar() as string;
|
|
}
|
|
|
|
public FormDocument? LoadDesignByKey(string shtCod, decimal sdgKey)
|
|
{
|
|
using var connection = Open();
|
|
using var command = connection.CreateCommand();
|
|
command.BindByName = true;
|
|
command.CommandText = "SELECT SdgDesign FROM E_SdgMst WHERE SdgKey = :k";
|
|
command.Parameters.Add(new OracleParameter("k", sdgKey));
|
|
if (command.ExecuteScalar() is not string xml || string.IsNullOrWhiteSpace(xml))
|
|
{
|
|
return null;
|
|
}
|
|
|
|
var document = serializer.Read(xml);
|
|
document.FormId = shtCod;
|
|
document.Title = QueryTitle(connection, shtCod) ?? shtCod;
|
|
document.Meta.SourceSdgKey = sdgKey;
|
|
return document;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 서식의 Spread 디자인들(E_SpdMst) — 컨트롤명(SpdName) → FarPoint XML.
|
|
/// SpdShtCod 는 CHAR 패딩 컬럼이라 TRIM 비교(실측).
|
|
/// </summary>
|
|
public Dictionary<string, string> LoadSpreadDesigns(string shtCod)
|
|
{
|
|
var result = new Dictionary<string, string>(StringComparer.Ordinal);
|
|
using var connection = Open();
|
|
using var command = connection.CreateCommand();
|
|
command.BindByName = true;
|
|
command.CommandText =
|
|
"SELECT TRIM(SpdName), SpdDesign FROM E_SpdMst " +
|
|
"WHERE TRIM(SpdShtCod) = :s AND NVL(SpdDelYon,' ') <> 'Y'";
|
|
command.Parameters.Add(new OracleParameter("s", shtCod));
|
|
using var reader = command.ExecuteReader();
|
|
while (reader.Read())
|
|
{
|
|
if (!reader.IsDBNull(1))
|
|
{
|
|
result[reader.GetString(0)] = reader.GetString(1);
|
|
}
|
|
}
|
|
return result;
|
|
}
|
|
|
|
/// <summary>디자인 버전 이력(본문 제외)</summary>
|
|
public List<DesignVersionInfo> ListVersions(string shtCod)
|
|
{
|
|
using var connection = Open();
|
|
using var command = connection.CreateCommand();
|
|
command.BindByName = true;
|
|
command.CommandText =
|
|
"SELECT SdgKey, NVL(SdgUpdDtm,' '), NVL(SdgUidCod,' '), NVL(SdgDelYon,' ') " +
|
|
"FROM E_SdgMst WHERE SdgShtCod = :s ORDER BY SdgKey DESC";
|
|
command.Parameters.Add(new OracleParameter("s", shtCod));
|
|
|
|
var result = new List<DesignVersionInfo>();
|
|
using var reader = command.ExecuteReader();
|
|
while (reader.Read())
|
|
{
|
|
result.Add(new DesignVersionInfo(
|
|
reader.GetDecimal(0), reader.GetString(1).Trim(), reader.GetString(2).Trim(),
|
|
reader.GetString(3) == "Y"));
|
|
}
|
|
return result;
|
|
}
|
|
#endregion
|
|
|
|
#region Methods - 저장
|
|
/// <summary>
|
|
/// 디자인 저장 — 레거시 동일 의미론(제자리 갱신 vs 버저닝), 단일 트랜잭션.
|
|
/// 반환: 저장된 SdgKey.
|
|
/// </summary>
|
|
/// <summary>
|
|
/// 지금 쓰이는 버전을 <b>제자리에서</b> 정정한다 — 레거시 <c>TK_MODIFY</c>(3-인자 오버로드).
|
|
///
|
|
/// <b>저장과 이력 방향이 반대다.</b> 저장은 옛 행을 <c>SdgDelYon='Y'</c> 로 내리고 새 행이 활성이 된다.
|
|
/// 수정은 <b>활성 행이 제자리에서 갱신되고, 옛 XML 을 담은 새 행이 이력</b>으로 들어간다.
|
|
/// 그래서 <c>SdgKey</c> 가 바뀌지 않는다 — EMR 이 참조하던 키가 그대로 유지된다.
|
|
///
|
|
/// <b><c>E_SctMst</c> 를 건드리지 않는다.</b> 레거시가 그 부분을 주석 처리해 두었고
|
|
/// (<c>bzSaveSheetDesignNControlInfo.vb:170-174</c>), 그것이 "글자만 수정 가능"이라는 경고문의
|
|
/// 기술적 근거다. SdgKey 가 그대로라 기존 매핑 행은 유효하지만 <b>새 컨트롤은 매핑 행이 안 생긴다</b>.
|
|
/// 호출부가 <see cref="NewControlNames"/> 로 먼저 막는다.
|
|
///
|
|
/// <b>레거시 버그 둘은 복제하지 않는다.</b>
|
|
/// ① 감사 컬럼이 뒤집혀 있었다 — 활성 행에는 아무것도 안 쓰고
|
|
/// <b>옛 디자인을 담은 이력 행</b>이 현재 사용자·시각을 받았다(<c>:162-163</c>).
|
|
/// 그러면 이력 패널이 "누가 언제 이 버전을 만들었는가"를 거꾸로 보여 준다.
|
|
/// 여기서는 활성 행에 기록하고, 이력 행은 원래 값을 지킨다.
|
|
/// ② <c>Rows(0)</c> 을 개수 검사보다 먼저 읽어 활성 행이 없으면 예외였다(<c>:150</c>).
|
|
/// 여기서는 먼저 확인하고 뜻이 통하는 오류를 낸다.
|
|
/// </summary>
|
|
public decimal ModifyDesign(FormDocument document, string uid)
|
|
{
|
|
if (string.IsNullOrWhiteSpace(document.FormId))
|
|
{
|
|
throw new InvalidOperationException("서식 코드(FormId)가 없습니다.");
|
|
}
|
|
var mergedXml = serializer.Write(document);
|
|
|
|
using var connection = Open();
|
|
using var transaction = connection.BeginTransaction();
|
|
try
|
|
{
|
|
var now = ServerClock.Read(connection, transaction).Minute12;
|
|
var activeSdgKey = ResolveActiveSdgKey(connection, transaction, document.FormId);
|
|
if (activeSdgKey <= 0)
|
|
{
|
|
throw new InvalidOperationException(
|
|
$"서식 [{document.FormId}] 에 지금 쓰이는 디자인이 없습니다. 수정 대신 저장을 쓰세요.");
|
|
}
|
|
|
|
// 옛 디자인과 그 감사 값을 먼저 떠 둔다 — 이력 행이 그 값을 그대로 가져가야
|
|
// "그 버전을 누가 언제 만들었는지"가 보존된다.
|
|
string oldXml = string.Empty, oldUid = uid, oldStamp = now;
|
|
using (var read = connection.CreateCommand())
|
|
{
|
|
read.Transaction = transaction;
|
|
read.BindByName = true;
|
|
read.CommandText =
|
|
"SELECT SdgDesign, NVL(SdgUidCod,' '), NVL(SdgUpdDtm,' ') FROM E_SdgMst WHERE SdgKey = :k";
|
|
read.Parameters.Add(new OracleParameter("k", activeSdgKey));
|
|
using var reader = read.ExecuteReader();
|
|
if (reader.Read())
|
|
{
|
|
oldXml = reader.IsDBNull(0) ? string.Empty : reader.GetString(0);
|
|
oldUid = reader.GetString(1).Trim();
|
|
oldStamp = reader.GetString(2).Trim();
|
|
}
|
|
}
|
|
|
|
NonQuery(connection, transaction,
|
|
"UPDATE E_SdgMst SET SdgDesign = :d, SdgUidCod = :u, SdgUpdDtm = :t WHERE SdgKey = :k",
|
|
new OracleParameter("d", OracleDbType.Clob) { Value = mergedXml },
|
|
new OracleParameter("u", uid),
|
|
new OracleParameter("t", now),
|
|
new OracleParameter("k", activeSdgKey));
|
|
|
|
var historyKey = Convert.ToDecimal(Scalar(connection, transaction,
|
|
"SELECT NVL(MAX(SdgKey),0)+1 FROM E_SdgMst"));
|
|
NonQuery(connection, transaction,
|
|
"INSERT INTO E_SdgMst (SdgKey, SdgShtCod, SdgDesign, SdgUidCod, SdgUpdDtm,"
|
|
+ " SdgDelYon, SdgDelUid, SdgDelDtm)"
|
|
+ " VALUES (:k, :s, :d, :u, :t, 'Y', '', '')",
|
|
new OracleParameter("k", historyKey),
|
|
new OracleParameter("s", document.FormId),
|
|
new OracleParameter("d", OracleDbType.Clob) { Value = oldXml },
|
|
new OracleParameter("u", oldUid.Length > 0 ? oldUid : uid),
|
|
new OracleParameter("t", oldStamp.Length > 0 ? oldStamp : now));
|
|
|
|
transaction.Commit();
|
|
return activeSdgKey;
|
|
}
|
|
catch
|
|
{
|
|
transaction.Rollback();
|
|
throw;
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 이 문서에 있는데 지금 활성 버전의 <c>E_SctMst</c> 에는 없는 컨트롤 이름들.
|
|
///
|
|
/// 수정은 <c>E_SctMst</c> 를 안 쓰므로 이 이름들은 <b>매핑 행 없이</b> 저장되고
|
|
/// EMR 에서 조용히 값이 안 채워진다. 그래서 호출부가 수정을 막는 근거로 쓴다.
|
|
/// 판정 근거를 <see cref="SctMstXmlWalker"/> 로 통일한다 — 저장이 행을 만드는 규칙과 같은 것이라
|
|
/// "행이 원래 안 생기는 종류"를 새 컨트롤로 오인하지 않는다.
|
|
/// </summary>
|
|
public List<string> NewControlNames(FormDocument document)
|
|
{
|
|
var names = new List<string>();
|
|
using var connection = Open();
|
|
var activeSdgKey = ResolveActiveSdgKey(connection, null, document.FormId);
|
|
if (activeSdgKey <= 0)
|
|
{
|
|
return names;
|
|
}
|
|
var existing = new HashSet<string>(StringComparer.Ordinal);
|
|
using (var query = connection.CreateCommand())
|
|
{
|
|
query.BindByName = true;
|
|
query.CommandText = "SELECT SctObjNam FROM E_SctMst WHERE SctSdgKey = :k";
|
|
query.Parameters.Add(new OracleParameter("k", activeSdgKey));
|
|
using var reader = query.ExecuteReader();
|
|
while (reader.Read())
|
|
{
|
|
existing.Add(reader.GetString(0));
|
|
}
|
|
}
|
|
foreach (var row in SctMstXmlWalker.Walk(serializer.Write(document)))
|
|
{
|
|
if (!string.Equals(row.ObjType, SpreadItemType, StringComparison.OrdinalIgnoreCase)
|
|
&& !existing.Contains(row.ObjName) && !names.Contains(row.ObjName))
|
|
{
|
|
names.Add(row.ObjName);
|
|
}
|
|
}
|
|
return names;
|
|
}
|
|
|
|
public decimal SaveDesign(FormDocument document, string uid)
|
|
{
|
|
if (string.IsNullOrWhiteSpace(document.FormId))
|
|
{
|
|
throw new InvalidOperationException("서식 코드(FormId)가 없습니다.");
|
|
}
|
|
|
|
var mergedXml = serializer.Write(document);
|
|
|
|
using var connection = Open();
|
|
using var transaction = connection.BeginTransaction();
|
|
try
|
|
{
|
|
// 레거시 SystemDateTime 과 동일하게 DB 서버 시각을 쓴다 — 단말 시계가 밀리면
|
|
// ResolveActiveSdgKey 의 ORDER BY SdgUpdDtm 이 활성 버전을 잘못 고를 수 있다.
|
|
var now = ServerClock.Read(connection, transaction).Minute12;
|
|
|
|
var shtCneYon = Scalar(connection, transaction,
|
|
"SELECT NVL(ShtCneYon,' ') FROM E_ShtMst WHERE ShtCod = :s",
|
|
new OracleParameter("s", document.FormId)) as string;
|
|
if (shtCneYon is null)
|
|
{
|
|
throw new InvalidOperationException($"E_ShtMst 에 서식이 없습니다: {document.FormId}");
|
|
}
|
|
|
|
var activeSdgKey = ResolveActiveSdgKey(connection, transaction, document.FormId);
|
|
var updateInPlace = shtCneYon == "Y" && activeSdgKey > 0;
|
|
|
|
decimal sdgKey;
|
|
if (updateInPlace)
|
|
{
|
|
// 제자리 갱신 — 레거시 ShtCneYon='Y' 경로
|
|
sdgKey = activeSdgKey;
|
|
NonQuery(connection, transaction,
|
|
"UPDATE E_SdgMst SET SdgDesign = :d, SdgUidCod = :u, SdgUpdDtm = :t WHERE SdgKey = :k",
|
|
new OracleParameter("d", OracleDbType.Clob) { Value = mergedXml },
|
|
new OracleParameter("u", uid),
|
|
new OracleParameter("t", now),
|
|
new OracleParameter("k", sdgKey));
|
|
}
|
|
else
|
|
{
|
|
// 기존 활성행 히스토리 처리 후 신규 행
|
|
if (activeSdgKey > 0)
|
|
{
|
|
NonQuery(connection, transaction,
|
|
"UPDATE E_SdgMst SET SdgDelYon = 'Y' WHERE SdgKey = :k",
|
|
new OracleParameter("k", activeSdgKey));
|
|
}
|
|
sdgKey = NextVal(connection, transaction, "E_SDGMST_SDGKEY",
|
|
"SELECT NVL(MAX(SdgKey),0)+1 FROM E_SdgMst");
|
|
NonQuery(connection, transaction,
|
|
"INSERT INTO E_SdgMst (SdgKey, SdgShtCod, SdgDesign, SdgUidCod, SdgUpdDtm, SdgDelYon, SdgDelUid, SdgDelDtm) " +
|
|
"VALUES (:k, :s, :d, :u, :t, '', '', '')",
|
|
new OracleParameter("k", sdgKey),
|
|
new OracleParameter("s", document.FormId),
|
|
new OracleParameter("d", OracleDbType.Clob) { Value = mergedXml },
|
|
new OracleParameter("u", uid),
|
|
new OracleParameter("t", now));
|
|
}
|
|
|
|
SaveSctMst(connection, transaction, sdgKey, mergedXml, updateInPlace);
|
|
|
|
transaction.Commit();
|
|
document.Meta.SourceSdgKey = sdgKey;
|
|
document.Meta.UpdatedBy = uid;
|
|
document.Meta.UpdatedAt = now;
|
|
return sdgKey;
|
|
}
|
|
catch
|
|
{
|
|
transaction.Rollback();
|
|
throw;
|
|
}
|
|
}
|
|
|
|
/// <summary>E_ShtMst 존재 여부</summary>
|
|
public bool SheetExists(string shtCod)
|
|
{
|
|
using var connection = Open();
|
|
return Convert.ToInt32(Scalar(connection, null,
|
|
"SELECT COUNT(*) FROM E_ShtMst WHERE ShtCod = :s", new OracleParameter("s", shtCod))!) > 0;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 신규 서식 최소 등록 — 실DB 디자이너 서식 관행값(ShtTyp='D', 사용/디자인/컨트롤/EMR 'Y', 열람권한 'A' 등).
|
|
/// 상세 속성(권한/출력 등)은 레거시 기록지정보 마스터에서 후속 설정.
|
|
/// </summary>
|
|
public void RegisterSheet(string shtCod, string korName, string? clsCod, string uid)
|
|
{
|
|
if (shtCod.Length is 0 or > 10)
|
|
{
|
|
throw new ArgumentException("서식 코드는 1~10자여야 합니다.");
|
|
}
|
|
|
|
using var connection = Open();
|
|
using var transaction = connection.BeginTransaction();
|
|
try
|
|
{
|
|
var stamp = ServerClock.Read(connection, transaction);
|
|
// ShtUsrDesYon='Y' 하드코딩 — 여기서 만든 서식은 서식생성기가 만든 것이므로 열기 게이트를 자동 통과한다
|
|
//
|
|
// ShtExpDte='29991231' / ShtHspYon='Y' 는 빼면 안 되는 값이다(--db-shtmst 실측).
|
|
// · 운영 E_ShtMst 1,737행 중 두 컬럼이 NULL 인 행은 0건 — 비워 두면 우리 행만 예외가 된다.
|
|
// · ShtExpDte 는 dtEMRLoader.vb:1229 가 NVL(ShtExpDte,' ')='29991231' 로 못박아 걸러내고,
|
|
// 여러 조회가 sysdate BETWEEN ShtAdpDte AND ShtExpDte 를 쓴다 — NULL 이면 BETWEEN 이 거짓이라
|
|
// 등록은 성공했는데 EMR 어디에서도 안 보이는 서식이 된다(29991231 이 1,718행 98.9%).
|
|
// · ShtHspYon 은 기록지정보·자동생성 등 목록이 ShtHspYon='Y' 로 거르며,
|
|
// 디자이너가 만든 서식(ShtUsrDesYon='Y') 169건 중 160건이 'Y' 다.
|
|
NonQuery(connection, transaction,
|
|
"INSERT INTO E_ShtMst (ShtCod, ShtAdpDte, ShtExpDte, ShtKorNam, ShtClsCod, ShtTyp, ShtUseYon, " +
|
|
"ShtHspYon, ShtUsrDesYon, ShtUseSdg, ShtUseSct, ShtUseEmr, ShtRedAth, ShtWrtTyp, ShtCneYon, ShtTraSto, " +
|
|
"ShtEleSig, ShtUpdUid, ShtUpdDtm) " +
|
|
"VALUES (:cod, :adp, '29991231', :nam, :cls, 'D', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'A', '9A', 'N', 'N', 'N', :uid, :dtm)",
|
|
new OracleParameter("cod", shtCod),
|
|
new OracleParameter("adp", stamp.Date8),
|
|
new OracleParameter("nam", korName),
|
|
new OracleParameter("cls", string.IsNullOrWhiteSpace(clsCod) ? (object)DBNull.Value : clsCod),
|
|
new OracleParameter("uid", uid),
|
|
new OracleParameter("dtm", stamp.Minute12));
|
|
transaction.Commit();
|
|
}
|
|
catch
|
|
{
|
|
transaction.Rollback();
|
|
throw;
|
|
}
|
|
}
|
|
|
|
private void SaveSctMst(OracleConnection connection, OracleTransaction transaction,
|
|
decimal sdgKey, string mergedXml, bool updateInPlace)
|
|
{
|
|
var rows = SctMstXmlWalker.Walk(mergedXml);
|
|
|
|
// 제자리 갱신일 때만 기존 행을 읽는다. 컨트롤 행은 SctKey 로 갱신해야 하므로 키까지 가져오고,
|
|
// Spread AsTemplate 항목 행은 ObjName 이 항목 텍스트라 컨트롤 이름과 섞이면 안 되므로 따로 담는다.
|
|
Dictionary<string, decimal>? existingControls = null;
|
|
HashSet<string>? existingSpreadItems = null;
|
|
if (updateInPlace)
|
|
{
|
|
existingControls = new Dictionary<string, decimal>(StringComparer.Ordinal);
|
|
existingSpreadItems = new HashSet<string>(StringComparer.Ordinal);
|
|
using var query = connection.CreateCommand();
|
|
query.Transaction = transaction;
|
|
query.BindByName = true;
|
|
query.CommandText =
|
|
"SELECT SctKey, SctObjNam, NVL(SctObjTyp,' ') FROM E_SctMst WHERE SctSdgKey = :k ORDER BY SctKey";
|
|
query.Parameters.Add(new OracleParameter("k", sdgKey));
|
|
using var reader = query.ExecuteReader();
|
|
while (reader.Read())
|
|
{
|
|
var key = reader.GetDecimal(0);
|
|
var name = reader.GetString(1);
|
|
var type = reader.GetString(2).Trim();
|
|
if (string.Equals(type, SpreadItemType, StringComparison.OrdinalIgnoreCase))
|
|
{
|
|
existingSpreadItems.Add(name);
|
|
}
|
|
else if (!existingControls.ContainsKey(name))
|
|
{
|
|
// 동명 행이 이미 중복된 오염 데이터에서는 레거시 Select(...)(0) 과 동일하게 최초 1건만 채택
|
|
existingControls[name] = key;
|
|
}
|
|
}
|
|
}
|
|
|
|
foreach (var row in rows)
|
|
{
|
|
if (updateInPlace)
|
|
{
|
|
if (string.Equals(row.ObjType, SpreadItemType, StringComparison.OrdinalIgnoreCase))
|
|
{
|
|
// 레거시(bzSaveSheetDesignNControlInfo.vb:355-370)는 존재 검사 없이 매 저장마다 항목 행을
|
|
// 중복 INSERT 한다. 런타임은 개수를 세지 않으므로 그 버그는 복제하지 않고 행 수를 안정시킨다.
|
|
if (existingSpreadItems!.Contains(row.ObjName))
|
|
{
|
|
continue;
|
|
}
|
|
}
|
|
else if (existingControls!.TryGetValue(row.ObjName, out var existingKey))
|
|
{
|
|
// 레거시 bzSaveSheetDesignNControlInfo.vb:378 — 기존 행은 SctObjTxt 만 덮어쓴다.
|
|
// SctObjTyp/SctParObj/SctObjSeq/SctObjID 는 의도적으로 갱신하지 않는다(SctKey 보존 의미론).
|
|
// 삭제된 컨트롤의 잔존 행도 레거시와 동일하게 지우지 않는다.
|
|
NonQuery(connection, transaction,
|
|
"UPDATE E_SctMst SET SctObjTxt = :txt WHERE SctKey = :k",
|
|
new OracleParameter("txt", row.ObjText.Length == 0 ? (object)DBNull.Value : row.ObjText),
|
|
new OracleParameter("k", existingKey));
|
|
continue;
|
|
}
|
|
}
|
|
|
|
var sctKey = NextVal(connection, transaction, "E_SCTMST_SCTKEY",
|
|
"SELECT NVL(MAX(SctKey),0)+1 FROM E_SctMst");
|
|
NonQuery(connection, transaction,
|
|
"INSERT INTO E_SctMst (SctKey, SctSdgKey, SctObjNam, SctObjID, SctObjTyp, SctParObj, SctObjSeq, SctObjTxt) " +
|
|
"VALUES (:k, :sdg, :nam, :oid, :typ, :par, :seq, :txt)",
|
|
new OracleParameter("k", sctKey),
|
|
new OracleParameter("sdg", sdgKey),
|
|
new OracleParameter("nam", row.ObjName),
|
|
new OracleParameter("oid", row.ObjId),
|
|
new OracleParameter("typ", row.ObjType),
|
|
new OracleParameter("par", row.ParentId),
|
|
new OracleParameter("seq", row.ObjSeq.Length == 0 ? "0" : row.ObjSeq),
|
|
new OracleParameter("txt", row.ObjText.Length == 0 ? (object)DBNull.Value : row.ObjText));
|
|
}
|
|
}
|
|
#endregion
|
|
|
|
#region Methods - Private
|
|
private OracleConnection Open()
|
|
{
|
|
var connection = new OracleConnection(connectionString);
|
|
connection.Open();
|
|
return connection;
|
|
}
|
|
|
|
/// <summary>활성(비삭제 최신) SdgKey — 없으면 0 ([200] SdgKeyResolver 의미론)</summary>
|
|
private static decimal ResolveActiveSdgKey(OracleConnection connection, OracleTransaction? transaction, string shtCod)
|
|
{
|
|
var value = Scalar(connection, transaction,
|
|
"SELECT NVL((SELECT SdgKey FROM (SELECT SdgKey FROM E_SdgMst " +
|
|
"WHERE SdgShtCod = :s AND NVL(SdgDelYon,' ') <> 'Y' ORDER BY SdgUpdDtm DESC, SdgKey DESC) " +
|
|
"WHERE ROWNUM = 1), 0) FROM DUAL",
|
|
new OracleParameter("s", shtCod));
|
|
return value is null or DBNull ? 0m : Convert.ToDecimal(value);
|
|
}
|
|
|
|
private static string? QueryTitle(OracleConnection connection, string shtCod)
|
|
=> Scalar(connection, null,
|
|
"SELECT ShtKorNam FROM E_ShtMst WHERE ShtCod = :s", new OracleParameter("s", shtCod)) as string;
|
|
|
|
/// <summary>채번 — 전용 시퀀스 NEXTVAL 우선, 시퀀스 부재(ORA-02289/00942) 시 MAX+1 폴백</summary>
|
|
private static decimal NextVal(OracleConnection connection, OracleTransaction transaction, string sequence, string fallbackSql)
|
|
{
|
|
try
|
|
{
|
|
return Convert.ToDecimal(Scalar(connection, transaction, $"SELECT {sequence}.NEXTVAL FROM DUAL")!);
|
|
}
|
|
catch (OracleException ex) when (ex.Number is 2289 or 942)
|
|
{
|
|
return Convert.ToDecimal(Scalar(connection, transaction, fallbackSql)!);
|
|
}
|
|
}
|
|
|
|
private static object? Scalar(OracleConnection connection, OracleTransaction? transaction, string sql, params OracleParameter[] parameters)
|
|
{
|
|
using var command = connection.CreateCommand();
|
|
if (transaction is not null)
|
|
{
|
|
command.Transaction = transaction;
|
|
}
|
|
command.BindByName = true;
|
|
command.CommandText = sql;
|
|
command.Parameters.AddRange(parameters);
|
|
return command.ExecuteScalar();
|
|
}
|
|
|
|
/// <summary>DML 실행 — 영향 행 수 반환(호출부가 무시해도 무방)</summary>
|
|
private static int NonQuery(OracleConnection connection, OracleTransaction transaction, string sql, params OracleParameter[] parameters)
|
|
{
|
|
using var command = connection.CreateCommand();
|
|
command.Transaction = transaction;
|
|
command.BindByName = true;
|
|
command.CommandText = sql;
|
|
command.Parameters.AddRange(parameters);
|
|
return command.ExecuteNonQuery();
|
|
}
|
|
#endregion
|
|
}
|