modal with func add data

2024-05-29 14:25:42 +07:00
parent 42f24d1c77
commit f2d0db174e
10 changed files with 1115 additions and 103 deletions
--- a/services/dev/md.samplestation.services.go
+++ b/services/dev/md.samplestation.services.go
@@ -6,7 +6,10 @@ import (
 	dbx "cpone/package/database"
 	"fmt"
 	"math"
+	"strconv"
 	"strings"
+
+	"go.uber.org/zap"
 )

 func NewMDSampleStationServices(uStore db.AppStore) *MDSampleStationServices {
@@ -87,3 +90,184 @@ func (ss *MDSampleStationServices) GetListSampleStation(search string, currentPa

 	return sampleStationList, totalPage, nil
 }
+
+func (ss *MDSampleStationServices) GetMDSampleStationByID(id string) (models.MDSampleStation, error) {
+	logger, _ := zap.NewProduction()
+
+	var ret models.MDSampleStation
+	q := `
+		SELECT
+		T_SampleStationID,
+		T_SampleStationCode,
+		T_SampleStationName,
+		T_SampleStationNat_GroupID,
+		T_SampleStationIsNonLab,
+		T_SampleStationIsActive		
+		FROM t_samplestation 
+		WHERE T_SampleStationID = ?`
+
+	err := dbx.Handlex.Get(&ret, q, id)
+	if err != nil {
+		defer logger.Sync()
+		logger.Error("Error get data by ID", zap.String("ID", id), zap.Error(err))
+		return ret, fmt.Errorf("query failed")
+	}
+
+	if len(ret.T_SampleStationIsNonLab) == 0 {
+		ret.T_SampleStationIsNonLab = "LAB"
+	}
+
+	return ret, nil
+}
+
+func (ss *MDSampleStationServices) GetListGroupSampleStation() ([]models.MDSampleStationGroup, error) {
+	data := []models.MDSampleStationGroup{
+		{
+			ID:    1,
+			Group: "RADIODIAGNOSTIC",
+		},
+		{
+			ID:    2,
+			Group: "ELEKTROMEDIS",
+		},
+		{
+			ID:    3,
+			Group: "LAB",
+		},
+		{
+			ID:    4,
+			Group: "OTHERS",
+		},
+	}
+	return data, nil
+}
+
+func (ss *MDSampleStationServices) AddMDSampleStation(code string, name string, group string) (models.MDSampleStation, error) {
+	logger, _ := zap.NewProduction()
+	var data models.MDSampleStation
+
+	if strings.ToUpper(group) == "LAB" {
+		group = " "
+	}
+
+	// cek existing code & name
+	var count int
+	var prmCode = "%" + code + "%"
+	var prmName = "%" + name + "%"
+	q := `
+		SELECT COUNT(*)
+		FROM t_samplestation
+		WHERE (T_SampleStationCode LIKE ? OR T_SampleStationName LIKE ?) 
+		AND T_SampleStationIsActive = 'Y'
+	`
+	err := dbx.Handlex.Get(&count, q, prmCode, prmName)
+	if err != nil {
+		defer logger.Sync()
+		logger.Error("cek duplicate", zap.Any("code", prmCode), zap.Any("name", prmName))
+		return data, fmt.Errorf("query failed")
+	}
+	if count > 0 {
+		defer logger.Sync()
+		logger.Error("duplicate data", zap.Any("code", code), zap.Any("name", name))
+		return data, fmt.Errorf("query failed")
+	}
+
+	q = `
+		INSERT INTO t_samplestation (
+			T_SampleStationCode,
+			T_SampleStationName,
+			T_SampleStationIsNonLab,
+			T_SampleStationCreated,
+			T_SampleStationCreatedUserID
+		) VALUES (?,?,?,NOW(),1);
+	`
+	rst := dbx.Handlex.MustExec(q, code, name, group)
+	insertedID, err := rst.LastInsertId()
+	if err != nil {
+		defer logger.Sync()
+		logger.Error("error insert data", zap.Any("code", code), zap.Any("name", name), zap.Any("group", group))
+		return data, fmt.Errorf("query failed")
+	}
+
+	s := strconv.Itoa(int(insertedID))
+
+	return ss.GetMDSampleStationByID(s)
+}
+
+func (ss *MDSampleStationServices) EditMDSampleStation(id string, code string, name string, group string) (models.MDSampleStation, error) {
+	logger, _ := zap.NewProduction()
+	var ret models.MDSampleStation
+
+	// cek existeing code & name
+	var count int
+	var prmCode = "%" + code + "%"
+	var prmName = "%" + name + "%"
+	q := `
+		SELECT COUNT(*)
+		FROM t_samplestation
+		WHERE (T_SampleStationCode LIKE ? OR T_SampleStationName LIKE ?) 
+		AND T_SampleStationIsActive = 'Y'
+		AND T_SampleStationID <> ?
+	`
+	err := dbx.Handlex.Get(count, q, prmCode, prmName, id)
+	if err != nil {
+		defer logger.Sync()
+		logger.Error("cek duplicate", zap.Any("code", code), zap.Any("name", name))
+		return ret, fmt.Errorf("query failed")
+	}
+	if count > 0 {
+		defer logger.Sync()
+		logger.Error("duplicate data", zap.Any("code", code), zap.Any("name", name))
+		return ret, fmt.Errorf("query failed")
+	}
+
+	// update data
+	q = `
+		UPDATE t_samplestation SET 
+			T_SampleStationCode = ?,
+			T_SampleStationName = ?,
+			T_SampleStationIsNonLab = ?,
+			T_SampleStationLastUpdated = NOW(),
+			T_SampleStationLastUpdatedUserID = 1
+		WHERE T_SampleStationID = ?;
+	`
+	updt := dbx.Handlex.MustExec(q, code, name, group, id)
+	_, err = updt.RowsAffected()
+	if err != nil {
+		defer logger.Sync()
+		logger.Error("error update data", zap.Any("code", code), zap.Any("name", name), zap.Any("group", group))
+		return ret, fmt.Errorf("query failed")
+	}
+
+	return ss.GetMDSampleStationByID(id)
+}
+
+func (ss *MDSampleStationServices) DeleteMDSampleStation(id string) (models.MDSampleStation, error) {
+	logger, _ := zap.NewProduction()
+	var ret models.MDSampleStation
+
+	q := `
+	UPDATE t_samplestation
+	SET 
+	T_SampleStationIsActive = 'N',
+	T_SampleStationDeleted = NOW(),
+	T_SampleStationDeletedUserID = '1'
+	WHERE T_SampleStationID = ?;
+	`
+	dlt := dbx.Handlex.MustExec(q, id)
+	_, err := dlt.RowsAffected()
+	if err != nil {
+		defer logger.Sync()
+		logger.Error("Error delete sample station", zap.String("id", id))
+		return ret, fmt.Errorf("query failed")
+	}
+
+	ret, err = ss.GetMDSampleStationByID(id)
+	if err != nil {
+		defer logger.Sync()
+		logger.Error("Error get sample station id", zap.String("id", id))
+		return ret, fmt.Errorf("query failed")
+	}
+
+	return ret, nil
+}