From fc9f00a2295cd4b491e51dd1a0d0677d6743bc86 Mon Sep 17 00:00:00 2001 From: zuevav Date: Tue, 22 Sep 2026 21:27:29 +0300 Subject: [PATCH] =?UTF-8?q?DEPO:=20BJ=5FRECEIVED=20=D0=B8=20BJ=5FSENT=20?= =?UTF-8?q?=D0=BF=D0=BE=20=D1=81=D1=82=D1=80=D0=BE=D0=BA=D0=B0=D0=BC=20(RE?= =?UTF-8?q?FERENCE)=20=E2=80=94=20=D0=B4=D0=B6=D0=BE=D0=B1=D0=B0=20bj2depo?= =?UTF-8?q?=20=D0=B8=D1=89=D0=B5=D1=82=20=D1=81=D1=82=D1=80=D0=BE=D0=BA?= =?UTF-8?q?=D1=83=20=D0=BF=D0=BE=20GUID+REFERENCE=20=D0=B4=D0=BB=D1=8F=20?= =?UTF-8?q?=D0=BB=D1=8E=D0=B1=D0=BE=D0=B3=D0=BE=20=D1=81=D0=BE=D0=B1=D1=8B?= =?UTF-8?q?=D1=82=D0=B8=D1=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-Authored-By: Claude Fable 5.1 Claude-Session: https://claude.ai/code/session_01Q4YVo4UMopqT5DzicqpPjL --- internal/lkgateway/depoevents.go | 13 ++++++++++--- 1 file changed, 10 insertions(+), 3 deletions(-) diff --git a/internal/lkgateway/depoevents.go b/internal/lkgateway/depoevents.go index 9d3cffd..3f77d9b 100644 --- a/internal/lkgateway/depoevents.go +++ b/internal/lkgateway/depoevents.go @@ -316,7 +316,10 @@ func depoOnIncomingReceived(rc *RuntimeConfig, it *IncomingTransfer) { name := strings.TrimSpace(strings.Join([]string{it.InvestorLast, it.InvestorFirst, it.InvestorMiddle}, " ")) doc := strings.TrimSpace(it.DocSeries + " " + it.DocNumber) if depoUpsertOrder(rc, it.GUID, "IN", it.SenderCode, name, doc, it.DocSeries, it.DocNumber, lines, "входящий перевод M2M от "+it.SenderCode) { - depoEvent(rc, it.GUID, "", "BJ_RECEIVED", "", "") + // по строкам: джоба bj2depo ищет строку по GUID+REFERENCE для любого события (22.09.2026) + for _, s := range it.Securities { + depoEvent(rc, it.GUID, s.ReferenceID, "BJ_RECEIVED", "", "") + } } } @@ -341,7 +344,9 @@ func depoOnOutgoingSent(rc *RuntimeConfig, req *m2m.M2MTransferRequest) { name := strings.TrimSpace(strings.Join([]string{inv.LastName, inv.FirstName, inv.MiddleName}, " ")) guid := string(req.Header.GUID) if depoUpsertOrder(rc, guid, "OUT", cp, name, strings.TrimSpace(ser+" "+num), ser, num, lines, "исходящий перевод M2M, получатель ИНН "+inn) { - depoEvent(rc, guid, "", "BJ_SENT", "", "") + for _, s := range req.Data.TransferredSecurities.Securities { + depoEvent(rc, guid, string(s.ReferenceID), "BJ_SENT", "", "") + } } } @@ -1019,7 +1024,9 @@ func depoSimulateIncoming(ctx context.Context, rc *RuntimeConfig, it *IncomingTr return "", fmt.Errorf("не удалось записать шапку в FTV_M2M") } now := time.Now() - depoEventAt(rc, now, guid, "", "BJ_RECEIVED", "", "") + for _, s := range it.Securities { + depoEventAt(rc, now, guid, s.ReferenceID, "BJ_RECEIVED", "", "") + } anyConfirmed := false for _, s := range it.Securities { switch s.Decision {