FP 结果校验,添加日志记录

services/om/implments/SerialOrder.service.impl.go

@@ -11,9 +11,11 @@ import (
 	"LAPP_ACURA_MOM_BACKEND/grmi"
 	meMeta "LAPP_ACURA_MOM_BACKEND/meta/me"
 	meta "LAPP_ACURA_MOM_BACKEND/meta/om"
+	omMeta "LAPP_ACURA_MOM_BACKEND/meta/om"
 	baseModel "LAPP_ACURA_MOM_BACKEND/models/base"
 	meModel "LAPP_ACURA_MOM_BACKEND/models/me"
 	model "LAPP_ACURA_MOM_BACKEND/models/om"
+	"errors"
 	"strconv"
 	"strings"
 	"time"
@@ -332,12 +334,40 @@ func (impl *SerialOrderServiceImplement) UpdatePfOne(user *global.User, entity *
 	engine := db.Eloquent.Master()
 	session := engine.NewSession()
 	defer session.Close()
-	engine.ShowSQL(true)
 	dao := dal.NewSerialOrderInspectionItemDAO(session, user.PlantNr, user.UserId)
-	err := dao.Updatepf(entity)
+	recDao := dal.NewSerialOrderInspectionItemRecLstDAO(session, user.PlantNr, user.UserId)
+	//查询订单信息是否存在
+	itemList, err := dao.Select([]grmi.Predicate{
+		omMeta.SerialOrderInspectionItem_SerialOrderId.NewPredicate(grmi.Equal, entity.SerialOrderId),
+	}, []grmi.Field{omMeta.SerialOrderInspectionItem_Pos})
 	if err != nil {
 		return err
 	}
+	if len(itemList) <= 0 {
+		return errors.New("订单的信息不存在!")
+	}
+	err = session.Begin()
+	if err != nil {
+		return err
+	}
+	err = dao.Updatepf(entity)
+	if err != nil {
+		_ = session.Rollback()
+		return err
+	}
+	nowTime := time.Now()
+	recordTab := model.SerialOrderInspectionItemRecLst{
+		PlantNr:       user.PlantNr,
+		SerialOrderId: entity.SerialOrderId,
+		PersonID:      user.UserId,
+		OrderDate:     grmi.DateTime(nowTime),
+	}
+	err = recDao.InsertOne(&recordTab)
+	if err != nil {
+		_ = session.Rollback()
+		return err
+	}
+	_ = session.Commit()
 	return nil
 }
 

web/controllers/om/om.go

@@ -456,6 +456,27 @@ func RegisterRoutes() {
 		// RegisterUpdateOneSerialOrderPOStatusRecLst(serialorderpostatusreclst, "/updateone", serviceOfSerialOrderPOStatusRecLst.UpdateOne)
 		// SerialOrderPOStatusRecLst修改多条
 		// RegisterUpdateSerialOrderPOStatusRecLst(serialorderpostatusreclst, "/update", serviceOfSerialOrderPOStatusRecLst.Update)
+
+		// SerialOrderInspectionItemRecLst的路由组
+		serialorderinspectionitemreclst := party.Party("/serialorderinspectionitemreclst")
+		// SerialOrderInspectionItemRecLst的服务实例
+		var serviceOfSerialOrderInspectionItemRecLst = svr.NewSerialOrderInspectionItemRecLstService()
+		// SerialOrderInspectionItemRecLst插入一条
+		// RegisterInsertOneSerialOrderInspectionItemRecLst(serialorderinspectionitemreclst, "/insertone", serviceOfSerialOrderInspectionItemRecLst.InsertOne)
+		// SerialOrderInspectionItemRecLst插入多条
+		// RegisterInsertSerialOrderInspectionItemRecLst(serialorderinspectionitemreclst, "/insert", serviceOfSerialOrderInspectionItemRecLst.Insert)
+		// SerialOrderInspectionItemRecLst删除一条
+		// RegisterDeleteOneSerialOrderInspectionItemRecLst(serialorderinspectionitemreclst, "/deleteone", serviceOfSerialOrderInspectionItemRecLst.DeleteOne)
+		// SerialOrderInspectionItemRecLst删除多条
+		// RegisterDeleteSerialOrderInspectionItemRecLst(serialorderinspectionitemreclst, "/delete", serviceOfSerialOrderInspectionItemRecLst.Delete)
+		// SerialOrderInspectionItemRecLst查询多条
+		RegisterSelectSerialOrderInspectionItemRecLst(serialorderinspectionitemreclst, "/query", serviceOfSerialOrderInspectionItemRecLst.Select)
+		// SerialOrderInspectionItemRecLst查询一条
+		RegisterSelectOneSerialOrderInspectionItemRecLst(serialorderinspectionitemreclst, "/get", serviceOfSerialOrderInspectionItemRecLst.SelectOne)
+		// SerialOrderInspectionItemRecLst修改一条
+		// RegisterUpdateOneSerialOrderInspectionItemRecLst(serialorderinspectionitemreclst, "/updateone", serviceOfSerialOrderInspectionItemRecLst.UpdateOne)
+		// SerialOrderInspectionItemRecLst修改多条
+		// RegisterUpdateSerialOrderInspectionItemRecLst(serialorderinspectionitemreclst, "/update", serviceOfSerialOrderInspectionItemRecLst.Update)
 	})
 }