add feature tambah data

services/dev/md.natunit.services.go

@@ -6,7 +6,10 @@ import (
 	dbx "cpone/package/database"
 	"fmt"
 	"math"
+	"strconv"
 	"strings"
+
+	"go.uber.org/zap"
 )
 
 func NewMdNatUnitServices(uStore db.AppStore) *MdNatUnitServices {
@@ -104,3 +107,74 @@ func (nu *MdNatUnitServices) GetMdNatUnitBreadCrumb(title string) (models.BreadC
 
 	return ret, nil
 }
+
+func (nu *MdNatUnitServices) GetMdNatUnitByID(id string) (models.NatUnit, error) {
+	logger, _ := zap.NewProduction()
+
+	var data models.NatUnit
+	err := dbx.Handlex.Get(&data, `SELECT * FROM nat_unit
+	WHERE Nat_UnitID = ?`, id)
+
+	if err != nil {
+		defer logger.Sync()
+		logger.Error("Error get data unit by id",
+			zap.String("ID", id),
+			zap.Error(err),
+		)
+		return data, fmt.Errorf("QUERY_FAILED")
+	}
+	return data, nil
+}
+
+func (nu *MdNatUnitServices) AddMdNatUnit(code string, name string) (models.NatUnit, error) {
+	logger, _ := zap.NewProduction()
+	var data models.NatUnit
+	var datacek []models.NatUnit
+
+	qryCek := `SELECT Nat_UnitCode FROM nat_unit
+		WHERE Nat_UnitCode = ? AND Nat_UnitIsActive = 'Y'`
+	err := dbx.Handlex.Select(&datacek, qryCek, code)
+
+	if err != nil {
+		defer logger.Sync()
+		logger.Error("Error cek data by code",
+			zap.String("code", code),
+			zap.Any("datacek", datacek),
+		)
+		return data, fmt.Errorf("QUERY_FAILED")
+	}
+
+	if len(datacek) > 0 {
+		defer logger.Sync()
+		logger.Error("Code already taken by another data",
+			zap.String("code", code),
+		)
+		return data, fmt.Errorf("code sudah dipakai")
+	}
+
+	qry := `INSERT INTO nat_unit
+		(Nat_UnitCode,
+		Nat_UnitName) VALUES(?,?)`
+	rst := dbx.Handlex.MustExec(qry, code, name)
+	insertedID, err := rst.LastInsertId()
+	if err != nil {
+		defer logger.Sync()
+		logger.Error("Error Insert natunit",
+			zap.String("code", code),
+			zap.String("name", name),
+		)
+		return data, fmt.Errorf("QUERY_FAILED")
+	}
+
+	s := strconv.Itoa(int(insertedID))
+	data, err = nu.GetMdNatUnitByID(s)
+	if err != nil {
+		defer logger.Sync()
+		logger.Error("Error get natunit by id",
+			zap.String("code", code),
+			zap.String("name", name),
+		)
+		return data, fmt.Errorf("QUERY_FAILED")
+	}
+	return data, nil
+}