From edf3066724ad442d6929210c830cb67c17277690 Mon Sep 17 00:00:00 2001
From: yinbentan <yinbentan@live.com>
Date: 星期四, 01 八月 2024 11:46:33 +0800
Subject: [PATCH] 添加工资计算自动任务

---
 controllers/fineness.go |  382 +++++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 372 insertions(+), 10 deletions(-)

diff --git a/controllers/fineness.go b/controllers/fineness.go
index 55428b6..0eaa33d 100644
--- a/controllers/fineness.go
+++ b/controllers/fineness.go
@@ -1,47 +1,166 @@
 package controllers
 
 import (
+	"errors"
 	"github.com/gin-gonic/gin"
+	"github.com/shopspring/decimal"
+	"gorm.io/gorm"
 	"silkserver/controllers/request"
+	"silkserver/controllers/response"
 	"silkserver/extend/code"
 	"silkserver/extend/util"
 	"silkserver/models"
 	"silkserver/pkg/convertx"
+	"silkserver/pkg/logx"
+	"silkserver/pkg/structx"
+	"silkserver/service"
+	"strings"
 )
 
 type FinenessController struct{}
 
-// List
+// RegisterAdd
+// @Tags      绾ゅ害鐧昏
+// @Summary   绾ゅ害鐧昏娣诲姞
+// @Produce   application/json
+// @Param     object  body  request.AddFinenessRegister true  "瀛楀吀淇℃伅"
+// @Param     Authorization	header string true "token"
+// @Success   200 {object} util.Response "鎴愬姛"
+// @Router    /api-jl/v1/fineness/register [post]
+func (slf FinenessController) RegisterAdd(c *gin.Context) {
+	var reqParams request.AddFinenessRegister
+	var params models.FinenessRegister
+	if err := c.BindJSON(&reqParams); err != nil {
+		logx.Errorf("RegisterAdd 鍙傛暟瑙f瀽澶辫触:%v", err.Error())
+		util.ResponseFormat(c, code.RequestParamError, "鍙傛暟瑙f瀽澶辫触锛屾暟鎹被鍨嬮敊璇�")
+		return
+	}
+	if err := structx.AssignTo(reqParams, &params); err != nil {
+		logx.Errorf("RegisterAdd 鏁版嵁杞崲閿欒:%v", err.Error())
+		util.ResponseFormat(c, code.RequestParamError, "鏁版嵁杞崲閿欒")
+		return
+	}
+
+	if err := slf.ParamsCheck(params); err != nil {
+		util.ResponseFormat(c, code.RequestParamError, err.Error())
+		return
+	}
+
+	specArr := strings.Split(params.Spec, "/")
+	start, _ := decimal.NewFromString(specArr[0])
+	end, _ := decimal.NewFromString(specArr[1])
+	silkStandard, err := service.GetSilkRankStandard(start, end)
+	if err != nil {
+		util.ResponseFormat(c, code.RequestParamError, err.Error())
+		return
+	}
+
+	endCarMap, err := service.GetWorkshopEndCarMap(params.WorkshopNumber, params.WorkshopGroup)
+	if len(endCarMap) == 0 {
+		util.ResponseFormat(c, code.RequestParamError, "璇ヨ溅闂存湭閰嶇疆杞﹀彿锛岃鍦ㄨ溅闂寸鐞嗕腑閰嶇疆!")
+		return
+	}
+
+	isNew := params.ID == 0
+
+	err = models.WithTransaction(func(db *gorm.DB) error {
+		search := models.NewFinenessRegisterSearch().SetOrm(db)
+
+		if !isNew { // id涓嶄负绌�
+			if err := models.NewFinenessItemSearch().SetOrm(db).SetFinenessRegisterID(params.ID).Delete(); err != nil {
+				return err
+			}
+			return search.Save(&params)
+		}
+		return search.Create(&params)
+	})
+	if err != nil {
+		util.ResponseFormat(c, code.RequestParamError, "淇濆瓨澶辫触")
+		return
+	}
+
+	err = service.FinenessCheck(&params, silkStandard, endCarMap, isNew)
+	if err != nil {
+		logx.Errorf("service.FinenessCheck err:%v, finenessRegister:%+v", err, params)
+		util.ResponseFormat(c, code.RequestParamError, "鐢熸垚妫�楠岃〃澶辫触")
+		return
+	}
+
+	util.ResponseFormat(c, code.Success, params)
+}
+
+func (slf FinenessController) ParamsCheck(params models.FinenessRegister) (err error) {
+	if params.Spec == "" || !strings.Contains(params.Spec, "/") {
+		return errors.New("瑙勬牸鏍煎紡涓嶆纭�")
+	}
+
+	specArr := strings.Split(params.Spec, "/")
+
+	_, err = decimal.NewFromString(specArr[0])
+	if err != nil {
+		return errors.New("瑙勬牸鏍煎紡涓嶆纭�")
+	}
+	_, err = decimal.NewFromString(specArr[1])
+	if err != nil {
+		return errors.New("瑙勬牸鏍煎紡涓嶆纭�")
+	}
+
+	if params.WorkshopNumber == "" || params.WorkshopGroup == 0 {
+		return errors.New("杞﹂棿杞︾粍鍙傛暟缂哄け")
+	}
+
+	if len(params.FinenessList) == 0 {
+		return errors.New("绾ゅ害鍒楄〃缂哄け")
+	}
+
+	if params.ID == 0 {
+		_, err = models.NewFinenessRegisterSearch().SetNumber(params.Number).First()
+		if err != gorm.ErrRecordNotFound {
+			return errors.New("缂栫爜閲嶅")
+		}
+	} else {
+		old, err := models.NewFinenessRegisterSearch().SetID(params.ID).First()
+		if err != nil {
+			return errors.New("璁板綍涓嶅瓨鍦�")
+		}
+		if old.Number != params.Number {
+			return errors.New("缂栫爜涓嶈兘淇敼")
+		}
+	}
+	return nil
+}
+
+// RegisterList
 // @Tags      绾ゅ害鐧昏
 // @Summary   绾ゅ害鐧昏鍒楄〃
 // @Produce   application/json
 // @Param     object  query    request.GetFinenessRegisterList true  "鏌ヨ鍙傛暟"
 // @Success   200   {object}  util.ResponseList{data=[]models.FinenessRegister}  "鎴愬姛"
 // @Router    /api-jl/v1/fineness/register [get]
-func (slf FinenessController) List(c *gin.Context) {
+func (slf FinenessController) RegisterList(c *gin.Context) {
 	var params request.GetFinenessRegisterList
 	if err := c.ShouldBindQuery(&params); err != nil {
 		util.ResponseFormat(c, code.RequestParamError, err.Error())
 		return
 	}
 
-	list, total, err := models.NewFinenessRegisterSearch().Find()
+	list, total, err := models.NewFinenessRegisterSearch().SetKeyword(params.Keyword).SetPage(params.Page, params.PageSize).SetOrder("id desc").Find()
 	if err != nil {
 		util.ResponseFormat(c, code.RequestParamError, "鏌ユ壘澶辫触")
 		return
 	}
 
-	util.ResponseFormatList(c, code.Success, list, int(total))
+	util.ResponseFormatList(c, code.Success, list, total)
 }
 
-// Delete
+// RegisterInfo
 // @Tags      绾ゅ害鐧昏
-// @Summary   绾ゅ害鐧昏鍒犻櫎
+// @Summary   绾ゅ害鐧昏璇︽儏
 // @Produce   application/json
 // @Param     id  path string true  "瀛楀吀淇℃伅"
-// @Success   200 {object} util.Response "鎴愬姛"
-// @Router    /api-jl/v1/fineness/register/{id} [delete]
-func (slf FinenessController) Delete(c *gin.Context) {
+// @Success   200 {object} util.ResponseList{data=models.FinenessRegister} "鎴愬姛"
+// @Router    /api-jl/v1/fineness/register/{id} [get]
+func (slf FinenessController) RegisterInfo(c *gin.Context) {
 	idStr := c.Param("id")
 	if idStr == "0" || idStr == "" {
 		util.ResponseFormat(c, code.RequestParamError, "绌虹殑璁板綍id")
@@ -54,10 +173,253 @@
 		return
 	}
 
-	err := models.NewFinenessRegisterSearch().SetID(id).Delete()
+	info, err := models.NewFinenessRegisterSearch().SetID(id).SetPreload().First()
+	if err != nil {
+		util.ResponseFormat(c, code.RequestParamError, "鏌ユ壘澶辫触")
+		return
+	}
+	util.ResponseFormat(c, code.Success, info)
+}
+
+// RegisterDelete
+// @Tags      绾ゅ害鐧昏
+// @Summary   绾ゅ害鐧昏鍒犻櫎
+// @Produce   application/json
+// @Param     id  path string true  "瀛楀吀淇℃伅"
+// @Success   200 {object} util.Response "鎴愬姛"
+// @Router    /api-jl/v1/fineness/register/{id} [delete]
+func (slf FinenessController) RegisterDelete(c *gin.Context) {
+	idStr := c.Param("id")
+	if idStr == "0" || idStr == "" {
+		util.ResponseFormat(c, code.RequestParamError, "绌虹殑璁板綍id")
+		return
+	}
+
+	id := convertx.StringToUInt(idStr)
+	if id == 0 {
+		util.ResponseFormat(c, code.RequestParamError, "绌虹殑璁板綍id")
+		return
+	}
+	err := models.WithTransaction(func(db *gorm.DB) error {
+		if err := models.NewFinenessItemSearch().SetOrm(db).SetFinenessRegisterID(id).Delete(); err != nil {
+			return err
+		}
+		return models.NewFinenessRegisterSearch().SetOrm(db).SetID(id).Delete()
+	})
+	if err != nil {
+		util.ResponseFormat(c, code.RequestParamError, "鍒犻櫎澶辫触")
+		return
+	}
+
+	util.ResponseFormat(c, code.UpdateSuccess, "鍒犻櫎鎴愬姛")
+}
+
+// CheckList
+// @Tags      绾ゅ害妫�楠�
+// @Summary   绾ゅ害妫�楠屽垪琛�
+// @Produce   application/json
+// @Param     object  query    request.GetFinenessRegisterList true  "鏌ヨ鍙傛暟"
+// @Success   200   {object}  util.ResponseList{data=[]models.FinenessCheck}  "鎴愬姛"
+// @Router    /api-jl/v1/fineness/check [get]
+func (slf FinenessController) CheckList(c *gin.Context) {
+	var params request.GetFinenessRegisterList
+	if err := c.ShouldBindQuery(&params); err != nil {
+		util.ResponseFormat(c, code.RequestParamError, err.Error())
+		return
+	}
+
+	list, total, err := models.NewFinenessCheckSearch().SetPage(params.Page, params.PageSize).SetPreload().SetOrder("id desc").Find()
+	if err != nil {
+		util.ResponseFormat(c, code.RequestParamError, "鏌ユ壘澶辫触")
+		return
+	}
+
+	util.ResponseFormatList(c, code.Success, list, total)
+}
+
+// CheckInfo
+// @Tags      绾ゅ害妫�楠�
+// @Summary   绾ゅ害妫�楠岃鎯�
+// @Produce   application/json
+// @Param     id  path string true  "绾ゅ害妫�楠孖D"
+// @Success   200 {object} util.ResponseList{data=response.FinenessCheckInfo} "鎴愬姛"
+// @Router    /api-jl/v1/fineness/check/{id} [get]
+func (slf FinenessController) CheckInfo(c *gin.Context) {
+	idStr := c.Param("id")
+	if idStr == "0" || idStr == "" {
+		util.ResponseFormat(c, code.RequestParamError, "绌虹殑璁板綍id")
+		return
+	}
+
+	id := convertx.StringToUInt(idStr)
+	if id == 0 {
+		util.ResponseFormat(c, code.RequestParamError, "绌虹殑璁板綍id")
+		return
+	}
+
+	info, err := models.NewFinenessCheckSearch().SetID(id).SetPreload().First()
+	if err != nil {
+		util.ResponseFormat(c, code.RequestParamError, "鏌ユ壘澶辫触")
+		return
+	}
+	resp := new(response.FinenessCheckInfo)
+	resp.Info = info
+	resp.Items, err = models.NewFinenessCheckItemSearch().SetFinenessRegisterID(info.FinenessRegisterID).FindAll()
+	if err != nil {
+		util.ResponseFormat(c, code.RequestParamError, "鏌ユ壘澶辫触")
+		return
+	}
+
+	util.ResponseFormat(c, code.Success, resp)
+}
+
+// CheckInfoByFinenessID
+// @Tags      绾ゅ害妫�楠�
+// @Summary   鏍规嵁绾ゅ害鐧昏ID鑾峰彇绾ゅ害妫�楠岃鎯�
+// @Produce   application/json
+// @Param     id  path string true  "绾ゅ害鐧昏ID"
+// @Success   200 {object} util.ResponseList{data=response.FinenessCheckInfo} "鎴愬姛"
+// @Router    /api-jl/v1/fineness/checkFinenessID/{id} [get]
+func (slf FinenessController) CheckInfoByFinenessID(c *gin.Context) {
+	idStr := c.Param("id")
+	if idStr == "0" || idStr == "" {
+		util.ResponseFormat(c, code.RequestParamError, "绌虹殑璁板綍id")
+		return
+	}
+
+	id := convertx.StringToUInt(idStr)
+	if id == 0 {
+		util.ResponseFormat(c, code.RequestParamError, "绌虹殑璁板綍id")
+		return
+	}
+
+	info, err := models.NewFinenessCheckSearch().SetFinenessRegisterID(id).SetPreload().First()
+	if err != nil {
+		util.ResponseFormat(c, code.RequestParamError, "妫�鏌ヨ〃鏌ユ壘澶辫触")
+		return
+	}
+	resp := new(response.FinenessCheckInfo)
+	resp.Info = info
+	resp.Items, err = models.NewFinenessCheckItemSearch().SetFinenessRegisterID(info.FinenessRegisterID).FindAll()
+	if err != nil {
+		util.ResponseFormat(c, code.RequestParamError, "妫�鏌ヨ鎯呰〃鏌ユ壘澶辫触")
+		return
+	}
+
+	util.ResponseFormat(c, code.Success, resp)
+}
+
+// CheckDelete
+// @Tags      绾ゅ害妫�楠�
+// @Summary   绾ゅ害妫�楠屽垹闄�
+// @Produce   application/json
+// @Param     id  path string true  "瀛楀吀淇℃伅"
+// @Success   200 {object} util.Response "鎴愬姛"
+// @Router    /api-jl/v1/fineness/check/{id} [delete]
+func (slf FinenessController) CheckDelete(c *gin.Context) {
+	idStr := c.Param("id")
+	if idStr == "0" || idStr == "" {
+		util.ResponseFormat(c, code.RequestParamError, "绌虹殑璁板綍id")
+		return
+	}
+
+	id := convertx.StringToUInt(idStr)
+	if id == 0 {
+		util.ResponseFormat(c, code.RequestParamError, "绌虹殑璁板綍id")
+		return
+	}
+
+	check, err := models.NewFinenessCheckSearch().SetID(id).First()
+	if err != nil {
+		util.ResponseFormat(c, code.RequestParamError, "妫�楠岃褰曚笉瀛樺湪")
+		return
+	}
+
+	err = models.WithTransaction(func(db *gorm.DB) error {
+		err := models.NewFinenessCheckSearch().SetOrm(db).SetID(id).Delete()
+		if err != nil {
+			return err
+		}
+		return models.NewFinenessCheckItemSearch().SetOrm(db).SetFinenessRegisterID(check.FinenessRegisterID).Delete()
+	})
+
 	if err != nil {
 		util.ResponseFormat(c, code.RequestParamError, "鍒犻櫎澶辫触")
 		return
 	}
 	util.ResponseFormat(c, code.UpdateSuccess, "鍒犻櫎鎴愬姛")
 }
+
+// CheckEdit
+// @Tags      绾ゅ害妫�楠�
+// @Summary   绾ゅ害妫�楠屼慨鏀�
+// @Produce   application/json
+// @Param     object  body   response.FinenessCheckInfo true  "鍙傛暟"
+// @Param     Authorization	header string true "token"
+// @Success   200 {object} util.Response "鎴愬姛"
+// @Router    /api-jl/v1/fineness/check [PUT]
+func (slf FinenessController) CheckEdit(c *gin.Context) {
+	var params response.FinenessCheckInfo
+	if err := c.BindJSON(&params); err != nil {
+		util.ResponseFormat(c, code.RequestParamError, "鍙傛暟瑙f瀽澶辫触锛屾暟鎹被鍨嬮敊璇�")
+		return
+	}
+	if params.Info == nil || params.Info.FinenessRegisterID == 0 || len(params.Items) == 0 {
+		util.ResponseFormat(c, code.RequestParamError, "鍙傛暟缂哄け")
+		return
+	}
+
+	_, err := models.NewFinenessCheckSearch().SetID(params.Info.ID).First()
+	if err != nil {
+		util.ResponseFormat(c, code.RequestParamError, "妫�楠岃褰曚笉瀛樺湪")
+		return
+	}
+	check := params.Info
+	finenessRegister, err := models.NewFinenessRegisterSearch().SetID(check.FinenessRegisterID).First()
+	if err != nil {
+		util.ResponseFormat(c, code.RequestParamError, "绾ゅ害鐧昏涓嶅瓨鍦�")
+		return
+	}
+	specArr := strings.Split(finenessRegister.Spec, "/")
+	start, _ := decimal.NewFromString(specArr[0])
+	end, _ := decimal.NewFromString(specArr[1])
+	standardMap, err := service.GetSilkRankStandard(start, end)
+	if err != nil {
+		util.ResponseFormat(c, code.RequestParamError, err.Error())
+		return
+	}
+	check.FinenessGrade = service.CalcFinenessGrade(check.Deviation, check.TotalDeviation, check.Cleanliness, check.Purity, check.TwiceChange, standardMap)
+
+	items := params.Items
+
+	for _, item := range items {
+		if item.FinenessGrade != "" {
+			item.FinenessGrade = service.CalcFinenessGrade(item.Deviation, item.TotalDeviation, item.Cleanliness, item.Purity, item.TwiceChange, standardMap)
+		}
+	}
+
+	err = models.WithTransaction(func(db *gorm.DB) error {
+		err = models.NewFinenessCheckSearch().SetOrm(db).Save(params.Info)
+		if err != nil {
+			return err
+		}
+
+		for _, item := range items {
+			if item.FinenessGrade == "" {
+				continue
+			}
+			err = models.NewFinenessCheckItemSearch().SetOrm(db).SetID(item.ID).UpdateByMap(map[string]interface{}{"fineness_grade": item.FinenessGrade})
+			if err != nil {
+				return err
+			}
+		}
+		return nil
+	})
+
+	if err != nil {
+		util.ResponseFormat(c, code.SaveFail, "淇濆瓨澶辫触")
+		return
+	}
+
+	util.ResponseFormat(c, code.Success, "淇濆瓨鎴愬姛")
+}

--
Gitblit v1.8.0