feat (resume): wip
This commit is contained in:
@@ -0,0 +1,432 @@
|
||||
<html>
|
||||
|
||||
<head>
|
||||
<meta charset="UTF-8" />
|
||||
<title>General Consent</title>
|
||||
<style>
|
||||
body {
|
||||
padding: 2rem 3rem;
|
||||
}
|
||||
table {
|
||||
width: 100%;
|
||||
border-collapse: collapse
|
||||
}
|
||||
td {
|
||||
vertical-align: top;
|
||||
}
|
||||
.border-table, .border-table td, .border-table th {
|
||||
border: 1px solid black;
|
||||
}
|
||||
.section-title {
|
||||
margin-top: 1rem;
|
||||
margin-bottom: 0rem;
|
||||
}
|
||||
.data-label {
|
||||
width: 9rem;
|
||||
}
|
||||
.data-colon {
|
||||
width: 0.1234rem;
|
||||
}
|
||||
</style>
|
||||
</head>
|
||||
|
||||
<body style="font-family: Arial, sans-serif; line-height: 1.4">
|
||||
<table style="width: 100%; border-collapse: collapse">
|
||||
<tr>
|
||||
<td style="text-align: center">
|
||||
<img src="logo-1.png" alt="logo" style="height: 70px" />
|
||||
</td>
|
||||
<td style="text-align: center">
|
||||
<div style="font-size: 14px; font-weight: bold">
|
||||
PEMERINTAH PROVINSI JAWA TIMUR
|
||||
</div>
|
||||
<div style="font-size: 14px; font-weight: bold">
|
||||
RUMAH SAKIT UMUM DAERAH Dr. SAIFUL ANWAR
|
||||
</div>
|
||||
<div style="font-size: 13px">
|
||||
TERAKREDITASI KARS VERSI 2012 TINGKAT PARIPURNA
|
||||
</div>
|
||||
<div style="margin-top: 8px">
|
||||
Jl. Jaksa Agung Suprapto No. 2 MALANG 65111
|
||||
</div>
|
||||
<div>Telp. (0341) 362101, Fax. (0341) 362110</div>
|
||||
<div>Email: rsu-drsaifulanwar@jatimprov.go.id</div>
|
||||
<div>Website: www.rsudsaifulanwar.jatimprov.go.id</div>
|
||||
</td>
|
||||
<td style="text-align: center">
|
||||
<img src="logo-rssa.png" alt="logo" style="height: 70px" />
|
||||
</td>
|
||||
</tr>
|
||||
</table>
|
||||
|
||||
<hr style="margin: 20px 0" />
|
||||
|
||||
<div style="
|
||||
text-align: center;
|
||||
font-weight: bold;
|
||||
font-size: 1rem;
|
||||
">
|
||||
IDENTITAS PASIEN
|
||||
</div>
|
||||
|
||||
|
||||
<table style="
|
||||
width: 100%;
|
||||
margin-top: 20px;
|
||||
border-collapse: collapse;
|
||||
">
|
||||
<tr>
|
||||
<td style="width: 10rem;">
|
||||
No. RM
|
||||
</td>
|
||||
<td class="data-colon">: </td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
<td style="width: 7rem;">
|
||||
Kelas
|
||||
</td>
|
||||
<td class="data-colon">: </td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
<tr>
|
||||
<td>
|
||||
NIK
|
||||
</td>
|
||||
<td class="data-colon">: </td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
<td>
|
||||
Ruang/Klinik
|
||||
</td>
|
||||
<td class="data-colon">: </td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
<tr>
|
||||
<td>
|
||||
Nama
|
||||
</td>
|
||||
<td class="data-colon">: </td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
<td>
|
||||
DPJP
|
||||
</td>
|
||||
<td class="data-colon">: </td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
|
||||
<tr />
|
||||
<td style="padding: 5px 0"></td>
|
||||
</tr>
|
||||
|
||||
<tr>
|
||||
<td>
|
||||
Tempat/Tanggal Lahir
|
||||
</td>
|
||||
<td class="data-colon">: </td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
<tr>
|
||||
<td>
|
||||
Jenis Kelamin
|
||||
</td>
|
||||
<td class="data-colon">: </td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
<tr>
|
||||
<td>
|
||||
No. Telepon
|
||||
</td>
|
||||
<td class="data-colon">: </td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
</table>
|
||||
|
||||
<hr style="margin: 20px 0" />
|
||||
<h1 style="
|
||||
text-align: center;
|
||||
font-weight: bold;
|
||||
font-size: 1rem;
|
||||
margin: 0;
|
||||
">
|
||||
RESUME MEDIS
|
||||
</h1>
|
||||
<p style="
|
||||
font-size: 0.7rem;
|
||||
margin: 0;
|
||||
text-align: center;
|
||||
"><i>Medical Discharge Summary</i></p>
|
||||
|
||||
|
||||
<p style="
|
||||
font-size: 0.7rem;
|
||||
margin-top: 1rem;
|
||||
"><i>(Diisi oleh Dokter Penanggung Jawab Pelayanan)</i></p>
|
||||
<table>
|
||||
<tr>
|
||||
<td class="data-label">
|
||||
Tanggal Masuk
|
||||
</td>
|
||||
<td class="data-colon">: </td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
<tr>
|
||||
<td class="data-label">
|
||||
Tanggal Keluar
|
||||
</td>
|
||||
<td class="data-colon">: </td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
<tr>
|
||||
<td class="data-label">
|
||||
Diagnosis Masuk
|
||||
</td>
|
||||
<td class="data-colon">: </td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
<tr>
|
||||
<td class="data-label">
|
||||
Diagnosis Keluar
|
||||
</td>
|
||||
<td class="data-colon">: </td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
</table>
|
||||
|
||||
<table class="border-table" style="margin-top: 0.7rem;">
|
||||
<tr>
|
||||
<th style="width: 1rem;">
|
||||
No
|
||||
</th>
|
||||
<th>
|
||||
Diagnosa
|
||||
</th>
|
||||
<th>
|
||||
Dasar Diagnosa
|
||||
</th>
|
||||
<th>
|
||||
Kode ICD-10
|
||||
</th>
|
||||
</tr>
|
||||
<tr>
|
||||
<td>
|
||||
1
|
||||
</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
<tr>
|
||||
<td>
|
||||
2
|
||||
</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
<tr>
|
||||
<td>
|
||||
3
|
||||
</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
</table>
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
<h4 class="section-title">Kajian Awal Medis</i></h4>
|
||||
<p style="
|
||||
font-size: 0.7rem;
|
||||
margin-top: 0rem;
|
||||
margin-bottom: 0.4rem;
|
||||
"><i>(Diisi oleh Dokter Penanggung Jawab Pelayanan)</i></p>
|
||||
|
||||
<table>
|
||||
<tr>
|
||||
<td class="data-label">
|
||||
Keluhan Utama
|
||||
</td>
|
||||
<td class="data-colon">: </td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
<tr>
|
||||
<td class="data-label">
|
||||
Riwayat Penyakit
|
||||
</td>
|
||||
<td class="data-colon">: </td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
<tr>
|
||||
<td class="data-label">
|
||||
Pemeriksaan Fisik & Keadaan Umum
|
||||
</td>
|
||||
<td class="data-colon">: </td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
</table>
|
||||
|
||||
<h4 class="section-title">Pemeriksaan Penunjang</i></h4>
|
||||
<table>
|
||||
<tr>
|
||||
<td class="data-label">
|
||||
Pemeriksaan
|
||||
</td>
|
||||
<td class="data-colon">: </td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
</table>
|
||||
|
||||
<h4 class="section-title">Tindakan Medis</i></h4>
|
||||
<table class="border-table" style="margin-top: 0.4rem;">
|
||||
<tr>
|
||||
<th style="width: 1rem;">
|
||||
No
|
||||
</th>
|
||||
<th>
|
||||
Tindakan
|
||||
</th>
|
||||
<th>
|
||||
Dasar Tindakan
|
||||
</th>
|
||||
<th>
|
||||
Kode ICD 9-CM
|
||||
</th>
|
||||
</tr>
|
||||
<tr>
|
||||
<td>
|
||||
1
|
||||
</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
<tr>
|
||||
<td>
|
||||
2
|
||||
</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
<tr>
|
||||
<td>
|
||||
3
|
||||
</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
</table>
|
||||
|
||||
<table style="margin: 0.7rem 0;">
|
||||
<tr>
|
||||
<td class="data-label">
|
||||
Keluhan Utama
|
||||
</td>
|
||||
<td class="data-colon">: </td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
</table>
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
<h4 class="section-title">Konsultasi</i></h4>
|
||||
<table class="border-table" style="margin-top: 0.4rem;">
|
||||
<tr>
|
||||
<th style="width: 1rem;">
|
||||
No
|
||||
</th>
|
||||
<th>
|
||||
Konsultasi
|
||||
</th>
|
||||
<th>
|
||||
Jawaban Konsultasi
|
||||
</th>
|
||||
</tr>
|
||||
<tr>
|
||||
<td>
|
||||
1
|
||||
</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
<tr>
|
||||
<td>
|
||||
2
|
||||
</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
<tr>
|
||||
<td>
|
||||
3
|
||||
</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
</table>
|
||||
|
||||
<h4 class="section-title">Terapi</i></h4>
|
||||
<table>
|
||||
<tr>
|
||||
<td class="data-label">
|
||||
Alergi
|
||||
</td>
|
||||
<td class="data-colon">: </td>
|
||||
<td>
|
||||
Replace
|
||||
</td>
|
||||
</tr>
|
||||
</table>
|
||||
|
||||
|
||||
|
||||
<h4 class="section-title" style="margin-top: 3rem;">Obat yang diberikan</i></h4>
|
||||
<table class="border-table" style="margin-top: 0.4rem;">
|
||||
<tr>
|
||||
<th>
|
||||
Terapi (Farmakologi & Non Farmakologi) Selawa Perawatan
|
||||
</th>
|
||||
<th>
|
||||
Terapi (Farmakologi & Non Farmakologi) Selawa Pulang
|
||||
</th>
|
||||
</tr>
|
||||
<tr>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
<tr>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
<tr>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
</table>
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
<h4 class="section-title">Kondisi saat Pulang</i></h4>
|
||||
<table>
|
||||
<tr>
|
||||
<td class="data-label">
|
||||
Keluhan Utama
|
||||
</td>
|
||||
<td class="data-colon">: </td>
|
||||
<td>{{ .Repalcable }}</td>
|
||||
</tr>
|
||||
</table>
|
||||
|
||||
<div style="height: 3rem;"></div>
|
||||
</body>
|
||||
|
||||
</html>
|
||||
@@ -0,0 +1,295 @@
|
||||
package resume
|
||||
|
||||
import (
|
||||
"errors"
|
||||
"strconv"
|
||||
|
||||
// main entities
|
||||
e "simrs-vx/internal/domain/main-entities/resume"
|
||||
|
||||
ue "simrs-vx/internal/use-case/main-use-case/encounter"
|
||||
|
||||
pl "simrs-vx/pkg/logger"
|
||||
pu "simrs-vx/pkg/use-case-helper"
|
||||
|
||||
dg "github.com/karincake/apem/db-gorm-pg"
|
||||
d "github.com/karincake/dodol"
|
||||
"gorm.io/gorm"
|
||||
)
|
||||
|
||||
const source = "resume"
|
||||
|
||||
func Create(input e.CreateDto) (*d.Data, error) {
|
||||
data := e.Resume{}
|
||||
|
||||
event := pl.Event{
|
||||
Feature: "Create",
|
||||
Source: source,
|
||||
}
|
||||
|
||||
// Start log
|
||||
pl.SetLogInfo(&event, input, "started", "create")
|
||||
|
||||
err := dg.I.Transaction(func(tx *gorm.DB) error {
|
||||
mwRunner := newMiddlewareRunner(&event, tx)
|
||||
mwRunner.setMwType(pu.MWTPre)
|
||||
// Run pre-middleware
|
||||
if err := mwRunner.RunCreateMiddleware(createPreMw, &input, &data); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
// check if encounter is done
|
||||
if ue.IsDone(*input.Encounter_Id, &event, tx) {
|
||||
return errors.New("encounter is already done")
|
||||
}
|
||||
|
||||
if resData, err := CreateData(input, &event, tx); err != nil {
|
||||
return err
|
||||
} else {
|
||||
data = *resData
|
||||
}
|
||||
|
||||
mwRunner.setMwType(pu.MWTPost)
|
||||
// Run post-middleware
|
||||
if err := mwRunner.RunCreateMiddleware(createPostMw, &input, &data); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
pl.SetLogInfo(&event, nil, "complete")
|
||||
|
||||
return nil
|
||||
})
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &d.Data{
|
||||
Meta: d.II{
|
||||
"source": source,
|
||||
"structure": "single-data",
|
||||
"status": "created",
|
||||
},
|
||||
Data: data.ToResponse(),
|
||||
}, nil
|
||||
}
|
||||
|
||||
func ReadList(input e.ReadListDto) (*d.Data, error) {
|
||||
var data *e.Resume
|
||||
var dataList []e.Resume
|
||||
var metaList *e.MetaDto
|
||||
var err error
|
||||
|
||||
event := pl.Event{
|
||||
Feature: "ReadList",
|
||||
Source: source,
|
||||
}
|
||||
|
||||
// Start log
|
||||
pl.SetLogInfo(&event, input, "started", "readList")
|
||||
|
||||
err = dg.I.Transaction(func(tx *gorm.DB) error {
|
||||
mwRunner := newMiddlewareRunner(&event, tx)
|
||||
mwRunner.setMwType(pu.MWTPre)
|
||||
// Run pre-middleware
|
||||
if err := mwRunner.RunReadListMiddleware(readListPreMw, &input, data); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
if dataList, metaList, err = ReadListData(input, &event, tx); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
mwRunner.setMwType(pu.MWTPost)
|
||||
// Run post-middleware
|
||||
if err := mwRunner.RunReadListMiddleware(readListPostMw, &input, data); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return nil
|
||||
})
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &d.Data{
|
||||
Meta: d.IS{
|
||||
"source": source,
|
||||
"structure": "list-data",
|
||||
"status": "fetched",
|
||||
"page_number": strconv.Itoa(metaList.PageNumber),
|
||||
"page_size": strconv.Itoa(metaList.PageSize),
|
||||
"record_totalCount": strconv.Itoa(metaList.Count),
|
||||
"record_currentCount": strconv.Itoa(len(dataList)),
|
||||
},
|
||||
Data: e.ToResponseList(dataList),
|
||||
}, nil
|
||||
}
|
||||
|
||||
func ReadDetail(input e.ReadDetailDto) (*d.Data, error) {
|
||||
var data *e.Resume
|
||||
var err error
|
||||
|
||||
event := pl.Event{
|
||||
Feature: "ReadDetail",
|
||||
Source: source,
|
||||
}
|
||||
|
||||
// Start log
|
||||
pl.SetLogInfo(&event, input, "started", "readDetail")
|
||||
|
||||
err = dg.I.Transaction(func(tx *gorm.DB) error {
|
||||
mwRunner := newMiddlewareRunner(&event, tx)
|
||||
mwRunner.setMwType(pu.MWTPre)
|
||||
// Run pre-middleware
|
||||
if err := mwRunner.RunReadDetailMiddleware(readDetailPreMw, &input, data); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
if data, err = ReadDetailData(input, &event, tx); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
mwRunner.setMwType(pu.MWTPost)
|
||||
// Run post-middleware
|
||||
if err := mwRunner.RunReadDetailMiddleware(readDetailPostMw, &input, data); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return nil
|
||||
})
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &d.Data{
|
||||
Meta: d.IS{
|
||||
"source": source,
|
||||
"structure": "single-data",
|
||||
"status": "fetched",
|
||||
},
|
||||
Data: data.ToResponse(),
|
||||
}, nil
|
||||
}
|
||||
|
||||
func Update(input e.UpdateDto) (*d.Data, error) {
|
||||
rdDto := e.ReadDetailDto{Id: input.Id}
|
||||
var data *e.Resume
|
||||
var err error
|
||||
|
||||
event := pl.Event{
|
||||
Feature: "Update",
|
||||
Source: source,
|
||||
}
|
||||
|
||||
// Start log
|
||||
pl.SetLogInfo(&event, input, "started", "update")
|
||||
|
||||
err = dg.I.Transaction(func(tx *gorm.DB) error {
|
||||
pl.SetLogInfo(&event, rdDto, "started", "DBReadDetail")
|
||||
if data, err = ReadDetailData(rdDto, &event, tx); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
mwRunner := newMiddlewareRunner(&event, tx)
|
||||
mwRunner.setMwType(pu.MWTPre)
|
||||
// Run pre-middleware
|
||||
if err := mwRunner.RunUpdateMiddleware(readDetailPreMw, &rdDto, data); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
// check if encounter is done
|
||||
if ue.IsDone(*input.Encounter_Id, &event, tx) {
|
||||
return errors.New("encounter is already done")
|
||||
}
|
||||
|
||||
if err := UpdateData(input, data, &event, tx); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
// Get Updated Data
|
||||
if data, err = ReadDetailData(rdDto, &event, tx); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
pl.SetLogInfo(&event, nil, "complete")
|
||||
|
||||
mwRunner.setMwType(pu.MWTPost)
|
||||
// Run post-middleware
|
||||
if err := mwRunner.RunUpdateMiddleware(readDetailPostMw, &rdDto, data); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return nil
|
||||
})
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &d.Data{
|
||||
Meta: d.IS{
|
||||
"source": source,
|
||||
"structure": "single-data",
|
||||
"status": "updated",
|
||||
},
|
||||
Data: data.ToResponse(),
|
||||
}, nil
|
||||
|
||||
}
|
||||
|
||||
func Delete(input e.DeleteDto) (*d.Data, error) {
|
||||
rdDto := e.ReadDetailDto{Id: uint(input.Id)}
|
||||
var data *e.Resume
|
||||
var err error
|
||||
|
||||
event := pl.Event{
|
||||
Feature: "Delete",
|
||||
Source: source,
|
||||
}
|
||||
|
||||
// Start log
|
||||
pl.SetLogInfo(&event, input, "started", "delete")
|
||||
|
||||
err = dg.I.Transaction(func(tx *gorm.DB) error {
|
||||
pl.SetLogInfo(&event, rdDto, "started", "DBReadDetail")
|
||||
if data, err = ReadDetailData(rdDto, &event, tx); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
mwRunner := newMiddlewareRunner(&event, tx)
|
||||
mwRunner.setMwType(pu.MWTPre)
|
||||
// Run pre-middleware
|
||||
if err := mwRunner.RunDeleteMiddleware(readDetailPreMw, &rdDto, data); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
if err := DeleteData(data, &event, tx); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
mwRunner.setMwType(pu.MWTPost)
|
||||
// Run post-middleware
|
||||
if err := mwRunner.RunDeleteMiddleware(readDetailPostMw, &rdDto, data); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return nil
|
||||
})
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &d.Data{
|
||||
Meta: d.IS{
|
||||
"source": source,
|
||||
"structure": "single-data",
|
||||
"status": "deleted",
|
||||
},
|
||||
Data: data.ToResponse(),
|
||||
}, nil
|
||||
|
||||
}
|
||||
@@ -0,0 +1,22 @@
|
||||
/*
|
||||
DESCRIPTION:
|
||||
Any functions that are used internally by the use-case
|
||||
*/
|
||||
package resume
|
||||
|
||||
import (
|
||||
e "simrs-vx/internal/domain/main-entities/resume"
|
||||
)
|
||||
|
||||
func setData[T *e.CreateDto | *e.UpdateDto](input T, data *e.Resume) {
|
||||
var inputSrc *e.CreateDto
|
||||
if inputT, ok := any(input).(*e.CreateDto); ok {
|
||||
inputSrc = inputT
|
||||
} else {
|
||||
inputTemp := any(input).(*e.UpdateDto)
|
||||
inputSrc = &inputTemp.CreateDto
|
||||
}
|
||||
|
||||
data.Encounter_Id = inputSrc.Encounter_Id
|
||||
data.Value = inputSrc.Value
|
||||
}
|
||||
@@ -0,0 +1,140 @@
|
||||
package resume
|
||||
|
||||
import (
|
||||
"errors"
|
||||
e "simrs-vx/internal/domain/main-entities/resume"
|
||||
plh "simrs-vx/pkg/lib-helper"
|
||||
pl "simrs-vx/pkg/logger"
|
||||
pu "simrs-vx/pkg/use-case-helper"
|
||||
|
||||
dg "github.com/karincake/apem/db-gorm-pg"
|
||||
gh "github.com/karincake/getuk"
|
||||
"gorm.io/gorm"
|
||||
)
|
||||
|
||||
func CreateData(input e.CreateDto, event *pl.Event, dbx ...*gorm.DB) (*e.Resume, error) {
|
||||
pl.SetLogInfo(event, nil, "started", "DBCreate")
|
||||
|
||||
data := e.Resume{}
|
||||
setData(&input, &data)
|
||||
|
||||
var tx *gorm.DB
|
||||
if len(dbx) > 0 {
|
||||
tx = dbx[0]
|
||||
} else {
|
||||
tx = dg.I
|
||||
}
|
||||
|
||||
if err := tx.Create(&data).Error; err != nil {
|
||||
return nil, plh.HandleCreateError(input, event, err)
|
||||
}
|
||||
|
||||
pl.SetLogInfo(event, nil, "complete")
|
||||
return &data, nil
|
||||
}
|
||||
|
||||
func ReadListData(input e.ReadListDto, event *pl.Event, dbx ...*gorm.DB) ([]e.Resume, *e.MetaDto, error) {
|
||||
pl.SetLogInfo(event, input, "started", "DBReadList")
|
||||
data := []e.Resume{}
|
||||
pagination := gh.Pagination{}
|
||||
count := int64(0)
|
||||
meta := e.MetaDto{}
|
||||
|
||||
var tx *gorm.DB
|
||||
if len(dbx) > 0 {
|
||||
tx = dbx[0]
|
||||
} else {
|
||||
tx = dg.I
|
||||
}
|
||||
|
||||
tx = tx.
|
||||
Model(&e.Resume{}).
|
||||
Scopes(gh.Preload(input.Includes)).
|
||||
Scopes(gh.Filter(input.FilterDto)).
|
||||
Count(&count).
|
||||
Scopes(gh.Paginate(input, &pagination)).
|
||||
Order("\"CreatedAt\" DESC")
|
||||
|
||||
if err := tx.Find(&data).Error; err != nil {
|
||||
if errors.Is(err, gorm.ErrRecordNotFound) {
|
||||
return nil, &meta, nil
|
||||
}
|
||||
return nil, nil, plh.HandleListError(input, event, err)
|
||||
}
|
||||
|
||||
meta.Count = int(count)
|
||||
meta.PageNumber = pagination.PageNumber
|
||||
meta.PageSize = pagination.PageSize
|
||||
|
||||
pl.SetLogInfo(event, nil, "complete")
|
||||
return data, &meta, nil
|
||||
}
|
||||
|
||||
func ReadDetailData(input e.ReadDetailDto, event *pl.Event, dbx ...*gorm.DB) (*e.Resume, error) {
|
||||
pl.SetLogInfo(event, input, "started", "DBReadDetail")
|
||||
data := e.Resume{}
|
||||
|
||||
var tx *gorm.DB
|
||||
if len(dbx) > 0 {
|
||||
tx = dbx[0]
|
||||
} else {
|
||||
tx = dg.I
|
||||
}
|
||||
|
||||
if err := tx.First(&data, input.Id).Error; err != nil {
|
||||
if processedErr := pu.HandleReadError(err, event, source, input.Id, data); processedErr != nil {
|
||||
return nil, processedErr
|
||||
}
|
||||
}
|
||||
|
||||
pl.SetLogInfo(event, nil, "complete")
|
||||
return &data, nil
|
||||
}
|
||||
|
||||
func UpdateData(input e.UpdateDto, data *e.Resume, event *pl.Event, dbx ...*gorm.DB) error {
|
||||
pl.SetLogInfo(event, data, "started", "DBUpdate")
|
||||
setData(&input, data)
|
||||
|
||||
var tx *gorm.DB
|
||||
if len(dbx) > 0 {
|
||||
tx = dbx[0]
|
||||
} else {
|
||||
tx = dg.I
|
||||
}
|
||||
|
||||
if err := tx.Save(&data).Error; err != nil {
|
||||
event.Status = "failed"
|
||||
event.ErrInfo = pl.ErrorInfo{
|
||||
Code: "data-update-fail",
|
||||
Detail: "Database update failed",
|
||||
Raw: err,
|
||||
}
|
||||
return pl.SetLogError(event, input)
|
||||
}
|
||||
|
||||
pl.SetLogInfo(event, nil, "complete")
|
||||
return nil
|
||||
}
|
||||
|
||||
func DeleteData(data *e.Resume, event *pl.Event, dbx ...*gorm.DB) error {
|
||||
pl.SetLogInfo(event, data, "started", "DBDelete")
|
||||
var tx *gorm.DB
|
||||
if len(dbx) > 0 {
|
||||
tx = dbx[0]
|
||||
} else {
|
||||
tx = dg.I
|
||||
}
|
||||
|
||||
if err := tx.Delete(&data).Error; err != nil {
|
||||
event.Status = "failed"
|
||||
event.ErrInfo = pl.ErrorInfo{
|
||||
Code: "data-delete-fail",
|
||||
Detail: "Database delete failed",
|
||||
Raw: err,
|
||||
}
|
||||
return pl.SetLogError(event, data)
|
||||
}
|
||||
|
||||
pl.SetLogInfo(event, nil, "complete")
|
||||
return nil
|
||||
}
|
||||
@@ -0,0 +1,103 @@
|
||||
package resume
|
||||
|
||||
import (
|
||||
e "simrs-vx/internal/domain/main-entities/resume"
|
||||
pl "simrs-vx/pkg/logger"
|
||||
pu "simrs-vx/pkg/use-case-helper"
|
||||
|
||||
"gorm.io/gorm"
|
||||
)
|
||||
|
||||
type middlewareRunner struct {
|
||||
Event *pl.Event
|
||||
Tx *gorm.DB
|
||||
MwType pu.MWType
|
||||
}
|
||||
|
||||
// NewMiddlewareExecutor creates a new middleware executor
|
||||
func newMiddlewareRunner(event *pl.Event, tx *gorm.DB) *middlewareRunner {
|
||||
return &middlewareRunner{
|
||||
Event: event,
|
||||
Tx: tx,
|
||||
}
|
||||
}
|
||||
|
||||
// ExecuteCreateMiddleware executes create middleware
|
||||
func (me *middlewareRunner) RunCreateMiddleware(middlewares []createMw, input *e.CreateDto, data *e.Resume) error {
|
||||
for _, middleware := range middlewares {
|
||||
logData := pu.GetLogData(input, data)
|
||||
|
||||
pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
|
||||
|
||||
if err := middleware.Func(input, data, me.Tx); err != nil {
|
||||
return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
|
||||
}
|
||||
|
||||
pl.SetLogInfo(me.Event, nil, "complete")
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (me *middlewareRunner) RunReadListMiddleware(middlewares []readListMw, input *e.ReadListDto, data *e.Resume) error {
|
||||
for _, middleware := range middlewares {
|
||||
logData := pu.GetLogData(input, data)
|
||||
|
||||
pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
|
||||
|
||||
if err := middleware.Func(input, data, me.Tx); err != nil {
|
||||
return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
|
||||
}
|
||||
|
||||
pl.SetLogInfo(me.Event, nil, "complete")
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (me *middlewareRunner) RunReadDetailMiddleware(middlewares []readDetailMw, input *e.ReadDetailDto, data *e.Resume) error {
|
||||
for _, middleware := range middlewares {
|
||||
logData := pu.GetLogData(input, data)
|
||||
|
||||
pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
|
||||
|
||||
if err := middleware.Func(input, data, me.Tx); err != nil {
|
||||
return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
|
||||
}
|
||||
|
||||
pl.SetLogInfo(me.Event, nil, "complete")
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (me *middlewareRunner) RunUpdateMiddleware(middlewares []readDetailMw, input *e.ReadDetailDto, data *e.Resume) error {
|
||||
for _, middleware := range middlewares {
|
||||
logData := pu.GetLogData(input, data)
|
||||
|
||||
pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
|
||||
|
||||
if err := middleware.Func(input, data, me.Tx); err != nil {
|
||||
return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
|
||||
}
|
||||
|
||||
pl.SetLogInfo(me.Event, nil, "complete")
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (me *middlewareRunner) RunDeleteMiddleware(middlewares []readDetailMw, input *e.ReadDetailDto, data *e.Resume) error {
|
||||
for _, middleware := range middlewares {
|
||||
logData := pu.GetLogData(input, data)
|
||||
|
||||
pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
|
||||
|
||||
if err := middleware.Func(input, data, me.Tx); err != nil {
|
||||
return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
|
||||
}
|
||||
|
||||
pl.SetLogInfo(me.Event, nil, "complete")
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (me *middlewareRunner) setMwType(mwType pu.MWType) {
|
||||
me.MwType = mwType
|
||||
}
|
||||
@@ -0,0 +1,9 @@
|
||||
package resume
|
||||
|
||||
// example of middleware
|
||||
// func init() {
|
||||
// createPreMw = append(createPreMw,
|
||||
// CreateMw{Name: "modif-input", Func: pm.ModifInput},
|
||||
// CreateMw{Name: "check-data", Func: pm.CheckData},
|
||||
// )
|
||||
// }
|
||||
@@ -0,0 +1,44 @@
|
||||
/*
|
||||
DESCRIPTION:
|
||||
A sample, part of the package that contains type, constants, and/or variables.
|
||||
|
||||
In this sample it also provides type and variable regarding the needs of the
|
||||
middleware to separate from main use-case which has the basic CRUD
|
||||
functionality. The purpose of this is to make the code more maintainable.
|
||||
*/
|
||||
package resume
|
||||
|
||||
import (
|
||||
"gorm.io/gorm"
|
||||
|
||||
e "simrs-vx/internal/domain/main-entities/resume"
|
||||
)
|
||||
|
||||
type createMw struct {
|
||||
Name string
|
||||
Func func(input *e.CreateDto, data *e.Resume, tx *gorm.DB) error
|
||||
}
|
||||
|
||||
type readListMw struct {
|
||||
Name string
|
||||
Func func(input *e.ReadListDto, data *e.Resume, tx *gorm.DB) error
|
||||
}
|
||||
|
||||
type readDetailMw struct {
|
||||
Name string
|
||||
Func func(input *e.ReadDetailDto, data *e.Resume, tx *gorm.DB) error
|
||||
}
|
||||
|
||||
type UpdateMw = readDetailMw
|
||||
type DeleteMw = readDetailMw
|
||||
|
||||
var createPreMw []createMw // preprocess middleware
|
||||
var createPostMw []createMw // postprocess middleware
|
||||
var readListPreMw []readListMw // ..
|
||||
var readListPostMw []readListMw // ..
|
||||
var readDetailPreMw []readDetailMw
|
||||
var readDetailPostMw []readDetailMw
|
||||
var updatePreMw []readDetailMw
|
||||
var updatePostMw []readDetailMw
|
||||
var deletePreMw []readDetailMw
|
||||
var deletePostMw []readDetailMw
|
||||
@@ -290,7 +290,7 @@ func Delete(input e.DeleteDto) (*d.Data, error) {
|
||||
|
||||
func validateForeignKey(input e.CreateDto) error {
|
||||
// validate installation_id
|
||||
if _, err := uu.ReadDetail(eu.ReadDetailDto{Code: &input.Code}); err != nil {
|
||||
if _, err := uu.ReadDetail(eu.ReadDetailDto{Code: input.Unit_Code}); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user