|
|
@@ -0,0 +1,461 @@
|
|
|
+package metering
|
|
|
+
|
|
|
+import (
|
|
|
+ "encoding/json"
|
|
|
+
|
|
|
+ "dashoo.cn/backend/api/business/limsdataentry"
|
|
|
+ "dashoo.cn/backend/api/business/limsreportalertor"
|
|
|
+ "dashoo.cn/backend/api/business/limsreportben"
|
|
|
+
|
|
|
+ "time"
|
|
|
+
|
|
|
+ . "dashoo.cn/backend/api/controllers"
|
|
|
+ "dashoo.cn/utils"
|
|
|
+)
|
|
|
+
|
|
|
+type LimsReportBenController struct {
|
|
|
+ BaseController
|
|
|
+}
|
|
|
+
|
|
|
+// @Title 获取列表
|
|
|
+// @Description get user by token
|
|
|
+// @Success 200 {object}
|
|
|
+// @router /list [get]
|
|
|
+//func (this *LimsBenController) GetEntityList() {
|
|
|
+// //获取分页信息
|
|
|
+// page := this.GetPageInfoForm()
|
|
|
+// where := " 1=1 "
|
|
|
+// orderby := "Id"
|
|
|
+// asc := false
|
|
|
+// Order := this.GetString("Order")
|
|
|
+// Prop := this.GetString("Prop")
|
|
|
+// if Order != "" && Prop != "" {
|
|
|
+// orderby = Prop
|
|
|
+// if Order == "asc" {
|
|
|
+// asc = true
|
|
|
+// }
|
|
|
+// }
|
|
|
+// Id := this.GetString("Id")
|
|
|
+//EId := this.GetString("EId")
|
|
|
+//TaskBalanceId := this.GetString("TaskBalanceId")
|
|
|
+//DataEntryId := this.GetString("DataEntryId")
|
|
|
+//RelativeHumanity := this.GetString("RelativeHumanity")
|
|
|
+//ManuCompany := this.GetString("ManuCompany")
|
|
|
+//Spec := this.GetString("Spec")
|
|
|
+//FactoryNum := this.GetString("FactoryNum")
|
|
|
+//AudibleAlarm := this.GetString("AudibleAlarm")
|
|
|
+//AlarmConcentration := this.GetString("AlarmConcentration")
|
|
|
+//InstrumentLevel := this.GetString("InstrumentLevel")
|
|
|
+//DielecStrength := this.GetString("DielecStrength")
|
|
|
+//Remark := this.GetString("Remark")
|
|
|
+//CreateOn := this.GetString("CreateOn")
|
|
|
+//CreateUserId := this.GetString("CreateUserId")
|
|
|
+//CreateBy := this.GetString("CreateBy")
|
|
|
+//ModifiedOn := this.GetString("ModifiedOn")
|
|
|
+//ModifiedUserId := this.GetString("ModifiedUserId")
|
|
|
+//ModifiedBy := this.GetString("ModifiedBy")
|
|
|
+//if Id != "" {
|
|
|
+// where = where + " and Id like '%" + Id + "%'"
|
|
|
+//}
|
|
|
+
|
|
|
+//if EId != "" {
|
|
|
+// where = where + " and EId like '%" + EId + "%'"
|
|
|
+//}
|
|
|
+//
|
|
|
+//if TaskBalanceId != "" {
|
|
|
+// where = where + " and TaskBalanceId like '%" + TaskBalanceId + "%'"
|
|
|
+//}
|
|
|
+//
|
|
|
+//if DataEntryId != "" {
|
|
|
+// where = where + " and DataEntryId =" + DataEntryId
|
|
|
+//} else {
|
|
|
+// where = where + " and DataEntryId =" + "0"
|
|
|
+//}
|
|
|
+//
|
|
|
+//if RelativeHumanity != "" {
|
|
|
+// where = where + " and RelativeHumanity like '%" + RelativeHumanity + "%'"
|
|
|
+//}
|
|
|
+//
|
|
|
+//if ManuCompany != "" {
|
|
|
+// where = where + " and ManuCompany like '%" + ManuCompany + "%'"
|
|
|
+//}
|
|
|
+//
|
|
|
+//if FactoryNum != "" {
|
|
|
+// where = where + " and FactoryNum like '%" + FactoryNum + "%'"
|
|
|
+//}
|
|
|
+//
|
|
|
+//if Spec != "" {
|
|
|
+// where = where + " and Spec like '%" + Spec + "%'"
|
|
|
+//}
|
|
|
+//
|
|
|
+//if AudibleAlarm != "" {
|
|
|
+// where = where + " and AudibleAlarm like '%" + AudibleAlarm + "%'"
|
|
|
+//}
|
|
|
+//
|
|
|
+//if AlarmConcentration != "" {
|
|
|
+// where = where + " and AlarmConcentration like '%" + AlarmConcentration + "%'"
|
|
|
+//}
|
|
|
+//
|
|
|
+//if InstrumentLevel != "" {
|
|
|
+// where = where + " and InstrumentLevel like '%" + InstrumentLevel + "%'"
|
|
|
+//}
|
|
|
+//
|
|
|
+//if DielecStrength != "" {
|
|
|
+// where = where + " and DielecStrength like '%" + DielecStrength + "%'"
|
|
|
+//}
|
|
|
+//if Remark != "" {
|
|
|
+// where = where + " and Remark like '%" + Remark + "%'"
|
|
|
+//}
|
|
|
+//
|
|
|
+//if CreateOn != "" {
|
|
|
+// where = where + " and CreateOn like '%" + CreateOn + "%'"
|
|
|
+//}
|
|
|
+//
|
|
|
+//if CreateUserId != "" {
|
|
|
+// where = where + " and CreateUserId like '%" + CreateUserId + "%'"
|
|
|
+//}
|
|
|
+//
|
|
|
+//if CreateBy != "" {
|
|
|
+// where = where + " and CreateBy like '%" + CreateBy + "%'"
|
|
|
+//}
|
|
|
+//
|
|
|
+//if ModifiedOn != "" {
|
|
|
+// where = where + " and ModifiedOn like '%" + ModifiedOn + "%'"
|
|
|
+//}
|
|
|
+//
|
|
|
+//if ModifiedUserId != "" {
|
|
|
+// where = where + " and ModifiedUserId like '%" + ModifiedUserId + "%'"
|
|
|
+//}
|
|
|
+//
|
|
|
+//if ModifiedBy != "" {
|
|
|
+// where = where + " and ModifiedBy like '%" + ModifiedBy + "%'"
|
|
|
+//}
|
|
|
+//
|
|
|
+//if CreateOn != "" {
|
|
|
+// dates := strings.Split(CreateOn, ",")
|
|
|
+// if len(dates) == 2 {
|
|
|
+// minDate := dates[0]
|
|
|
+// maxDate := dates[1]
|
|
|
+// where = where + " and CreateOn>='" + minDate + "' and CreateOn<='" + maxDate + "'"
|
|
|
+// }
|
|
|
+//}
|
|
|
+//
|
|
|
+// svc := limsreportben.GetLimsReportBenService(utils.DBE)
|
|
|
+// var list []limsreportben.LimsReportBenModel
|
|
|
+// total,list :=svc.GetAllPagingEntitiesWithOrderBytbl(this.User.AccCode, ,page.CurrentPage, page.Size, orderby, asc, &list, where)
|
|
|
+// var datainfo DataInfo
|
|
|
+// datainfo.Items = list
|
|
|
+// datainfo.CurrentItemCount = total
|
|
|
+// datainfo.PageIndex = page.CurrentPage
|
|
|
+// datainfo.ItemsPerPage = page.Size
|
|
|
+// this.Data["json"] = &datainfo
|
|
|
+// this.ServeJSON()
|
|
|
+//}
|
|
|
+
|
|
|
+// @Title 获取实体
|
|
|
+// @Description 获取实体
|
|
|
+// @Success 200 {object} limss5ovelimsreportalertor.LimsS5OVELimsReportAlertor
|
|
|
+// @router /get/:id [get]
|
|
|
+//func (this *LimsBenController) GetEntity() {
|
|
|
+// Id := this.Ctx.Input.Param(":id")
|
|
|
+// var dataentrylist []limsdataentry.LimsDateEntry
|
|
|
+// var alertorlist []limsreportalertor.LimsReportAlertor
|
|
|
+// var alertvaluelist []limsreportalertor.LimsReportAlertorValue
|
|
|
+// var alertdeviationlist []limsreportalertor.LimsReportAlertorDeviation
|
|
|
+// var alertresponsetimelist []limsreportalertor.LimsReportAlertorResponseTime
|
|
|
+// var alertrepeatlist []limsreportalertor.LimsReportAlertorRepeat
|
|
|
+// var alertshiftlist []limsreportalertor.LimsReportAlertorShift
|
|
|
+// svc := limsreportben.GetLimsReportBenService(utils.DBE)
|
|
|
+// svc.GetListEntityByIdBytbl(this.User.AccCode+LimsDateEntryName, this.User.AccCode+LimsReportAlertorName, this.User.AccCode+LimsReportAlertorValueName, this.User.AccCode+LimsReportAlertorDeviationName, this.User.AccCode+LimsReportAlertorRepeatName,this.User.AccCode+LimsReportAlertorShiftName,Id, &model)
|
|
|
+//
|
|
|
+// this.Data["json"] = &model
|
|
|
+// this.ServeJSON()
|
|
|
+//}
|
|
|
+
|
|
|
+// @Title 添加
|
|
|
+// @Description 新增
|
|
|
+// @Success 200 {object} controllers.Request
|
|
|
+// @router /add/:TypeId [post]
|
|
|
+func (this *LimsReportBenController) AddEntity() {
|
|
|
+ TypeId := this.Ctx.Input.Param(":TypeId")
|
|
|
+ switch TypeId {
|
|
|
+ case "0":
|
|
|
+ //主表和扩展表
|
|
|
+ var dataentrymodel limsdataentry.LimsDateEntry
|
|
|
+ var almodel limsreportalertor.LimsReportAlertor
|
|
|
+ var jsonBlob = this.Ctx.Input.RequestBody
|
|
|
+ svc := limsreportben.GetLimsReportBenService(utils.DBE)
|
|
|
+
|
|
|
+ json.Unmarshal(jsonBlob, &dataentrymodel)
|
|
|
+ dataentrymodel.CreateOn = time.Now()
|
|
|
+ dataentrymodel.CreateBy = this.User.Realname
|
|
|
+ dataentrymodel.CreateUserId, _ = utils.StrTo(this.User.Id).Int()
|
|
|
+
|
|
|
+ json.Unmarshal(jsonBlob, &almodel)
|
|
|
+ almodel.CreateOn = time.Now()
|
|
|
+ almodel.CreateBy = this.User.Realname
|
|
|
+ almodel.CreateUserId, _ = utils.StrTo(this.User.Id).Int()
|
|
|
+
|
|
|
+ _, err := svc.InsertEntityBytbl(this.User.AccCode+LimsDateEntryName, &dataentrymodel)
|
|
|
+ _, err = svc.InsertEntityBytbl(this.User.AccCode+LimsReportAlertorName, &almodel)
|
|
|
+
|
|
|
+ var errinfo ErrorDataInfo
|
|
|
+ if err == nil {
|
|
|
+ //新增
|
|
|
+ errinfo.Message = "添加成功！"
|
|
|
+ errinfo.Code = 0
|
|
|
+ errinfo.Item = dataentrymodel.Id
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ } else {
|
|
|
+ errinfo.Message = "添加失败！" + utils.AlertProcess(err.Error())
|
|
|
+ errinfo.Code = -1
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ }
|
|
|
+ case "1":
|
|
|
+ //证书表
|
|
|
+ var cermodel limsreportalertor.LimsReportAlertorCertificate
|
|
|
+ var jsonBlob = this.Ctx.Input.RequestBody
|
|
|
+ svc := limsreportben.GetLimsReportBenService(utils.DBE)
|
|
|
+
|
|
|
+ json.Unmarshal(jsonBlob, &cermodel)
|
|
|
+ cermodel.Createon = time.Now()
|
|
|
+ cermodel.Createby = this.User.Realname
|
|
|
+ cermodel.Createuserid, _ = utils.StrTo(this.User.Id).Int()
|
|
|
+
|
|
|
+ _, err := svc.InsertEntityBytbl(this.User.AccCode+LimsReportBeamPumpingUnitName, &cermodel)
|
|
|
+
|
|
|
+ var errinfo ErrorDataInfo
|
|
|
+ if err == nil {
|
|
|
+ //新增
|
|
|
+ errinfo.Message = "添加成功！"
|
|
|
+ errinfo.Code = 0
|
|
|
+ errinfo.Item = cermodel.Id
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ } else {
|
|
|
+ errinfo.Message = "添加失败！" + utils.AlertProcess(err.Error())
|
|
|
+ errinfo.Code = -1
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ }
|
|
|
+ case "2":
|
|
|
+ //报警功能表
|
|
|
+ var alermodel limsreportalertor.LimsReportAlertorValue
|
|
|
+ var jsonBlob = this.Ctx.Input.RequestBody
|
|
|
+ svc := limsreportben.GetLimsReportBenService(utils.DBE)
|
|
|
+
|
|
|
+ json.Unmarshal(jsonBlob, &alermodel)
|
|
|
+ alermodel.Createon = time.Now()
|
|
|
+ alermodel.Createby = this.User.Realname
|
|
|
+ alermodel.Createuserid, _ = utils.StrTo(this.User.Id).Int()
|
|
|
+
|
|
|
+ _, err := svc.InsertEntityBytbl(this.User.AccCode+LimsReportBeamPumpingUnitName, &alermodel)
|
|
|
+
|
|
|
+ var errinfo ErrorDataInfo
|
|
|
+ if err == nil {
|
|
|
+ //新增
|
|
|
+ errinfo.Message = "添加成功！"
|
|
|
+ errinfo.Code = 0
|
|
|
+ errinfo.Item = alermodel.Id
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ } else {
|
|
|
+ errinfo.Message = "添加失败！" + utils.AlertProcess(err.Error())
|
|
|
+ errinfo.Code = -1
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ }
|
|
|
+ case "3":
|
|
|
+ //示值误差表
|
|
|
+ var deviamodel limsreportalertor.LimsReportAlertorDeviation
|
|
|
+ var jsonBlob = this.Ctx.Input.RequestBody
|
|
|
+ svc := limsreportben.GetLimsReportBenService(utils.DBE)
|
|
|
+
|
|
|
+ json.Unmarshal(jsonBlob, &deviamodel)
|
|
|
+ deviamodel.Createon = time.Now()
|
|
|
+ deviamodel.Createby = this.User.Realname
|
|
|
+ deviamodel.Createuserid, _ = utils.StrTo(this.User.Id).Int()
|
|
|
+
|
|
|
+ _, err := svc.InsertEntityBytbl(this.User.AccCode+LimsReportBeamPumpingUnitName, &deviamodel)
|
|
|
+
|
|
|
+ var errinfo ErrorDataInfo
|
|
|
+ if err == nil {
|
|
|
+ //新增
|
|
|
+ errinfo.Message = "添加成功！"
|
|
|
+ errinfo.Code = 0
|
|
|
+ errinfo.Item = deviamodel.Id
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ } else {
|
|
|
+ errinfo.Message = "添加失败！" + utils.AlertProcess(err.Error())
|
|
|
+ errinfo.Code = -1
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ }
|
|
|
+ case "4":
|
|
|
+ //响应时间表
|
|
|
+ var responmodel limsreportalertor.LimsReportAlertorResponseTime
|
|
|
+ var jsonBlob = this.Ctx.Input.RequestBody
|
|
|
+ svc := limsreportben.GetLimsReportBenService(utils.DBE)
|
|
|
+
|
|
|
+ json.Unmarshal(jsonBlob, &responmodel)
|
|
|
+ responmodel.Createon = time.Now()
|
|
|
+ responmodel.Createby = this.User.Realname
|
|
|
+ responmodel.Createuserid, _ = utils.StrTo(this.User.Id).Int()
|
|
|
+
|
|
|
+ _, err := svc.InsertEntityBytbl(this.User.AccCode+LimsReportBeamPumpingUnitName, &responmodel)
|
|
|
+
|
|
|
+ var errinfo ErrorDataInfo
|
|
|
+ if err == nil {
|
|
|
+ //新增
|
|
|
+ errinfo.Message = "添加成功！"
|
|
|
+ errinfo.Code = 0
|
|
|
+ errinfo.Item = responmodel.Id
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ } else {
|
|
|
+ errinfo.Message = "添加失败！" + utils.AlertProcess(err.Error())
|
|
|
+ errinfo.Code = -1
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ }
|
|
|
+ case "5":
|
|
|
+ //重复性表
|
|
|
+ var repemodel limsreportalertor.LimsReportAlertorRepeat
|
|
|
+ var jsonBlob = this.Ctx.Input.RequestBody
|
|
|
+ svc := limsreportben.GetLimsReportBenService(utils.DBE)
|
|
|
+
|
|
|
+ json.Unmarshal(jsonBlob, &repemodel)
|
|
|
+ repemodel.Createon = time.Now()
|
|
|
+ repemodel.Createby = this.User.Realname
|
|
|
+ repemodel.Createuserid, _ = utils.StrTo(this.User.Id).Int()
|
|
|
+
|
|
|
+ _, err := svc.InsertEntityBytbl(this.User.AccCode+LimsReportBeamPumpingUnitName, &repemodel)
|
|
|
+
|
|
|
+ var errinfo ErrorDataInfo
|
|
|
+ if err == nil {
|
|
|
+ //新增
|
|
|
+ errinfo.Message = "添加成功！"
|
|
|
+ errinfo.Code = 0
|
|
|
+ errinfo.Item = repemodel.Id
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ } else {
|
|
|
+ errinfo.Message = "添加失败！" + utils.AlertProcess(err.Error())
|
|
|
+ errinfo.Code = -1
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ }
|
|
|
+ case "6":
|
|
|
+ //漂移表
|
|
|
+ var shiftmodel limsreportalertor.LimsReportAlertorShift
|
|
|
+ var jsonBlob = this.Ctx.Input.RequestBody
|
|
|
+ svc := limsreportben.GetLimsReportBenService(utils.DBE)
|
|
|
+
|
|
|
+ json.Unmarshal(jsonBlob, &shiftmodel)
|
|
|
+ shiftmodel.Createon = time.Now()
|
|
|
+ shiftmodel.Createby = this.User.Realname
|
|
|
+ shiftmodel.Createuserid, _ = utils.StrTo(this.User.Id).Int()
|
|
|
+
|
|
|
+ _, err := svc.InsertEntityBytbl(this.User.AccCode+LimsReportBeamPumpingUnitName, &shiftmodel)
|
|
|
+
|
|
|
+ var errinfo ErrorDataInfo
|
|
|
+ if err == nil {
|
|
|
+ //新增
|
|
|
+ errinfo.Message = "添加成功！"
|
|
|
+ errinfo.Code = 0
|
|
|
+ errinfo.Item = shiftmodel.Id
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ } else {
|
|
|
+ errinfo.Message = "添加失败！" + utils.AlertProcess(err.Error())
|
|
|
+ errinfo.Code = -1
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+// @Title 删除数据录入信息
|
|
|
+// @Description
|
|
|
+// @Success 200 {object} ErrorInfo
|
|
|
+// @Failure 403 :id 为空
|
|
|
+// @router /dataentrydelect/:Id [delete]
|
|
|
+func (this *LimsReportBenController) DelDataEntry() {
|
|
|
+ Id := this.Ctx.Input.Param(":Id")
|
|
|
+ var errinfo ErrorInfo
|
|
|
+ if Id == "" {
|
|
|
+ errinfo.Message = "操作失败！请求信息不完整"
|
|
|
+ errinfo.Code = -2
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ where := " Id= " + Id
|
|
|
+ svc := limsreportben.GetLimsReportBenService(utils.DBE)
|
|
|
+ err := svc.DeleteEntityBytbl(this.User.AccCode+LimsDateEntryName, where)
|
|
|
+ if err == nil {
|
|
|
+ errinfo.Message = "删除成功"
|
|
|
+ errinfo.Code = 0
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ } else {
|
|
|
+ errinfo.Message = "删除失败！" + utils.AlertProcess(err.Error())
|
|
|
+ errinfo.Code = -1
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+// @Title 修改数据录入表
|
|
|
+// @Description 修改数据录入表
|
|
|
+// @Success 200 {object} controllers.Request
|
|
|
+// @router /updateEntity/:id [post]
|
|
|
+func (this *LimsReportBenController) UpdateEntity() {
|
|
|
+ id := this.Ctx.Input.Param(":id")
|
|
|
+ var errinfo ErrorInfo
|
|
|
+ if id == "" {
|
|
|
+ errinfo.Message = "操作失败！请求信息不完整"
|
|
|
+ errinfo.Code = -2
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ var model limsdataentry.LimsDateEntry
|
|
|
+ svc := limsreportben.GetLimsReportBenService(utils.DBE)
|
|
|
+
|
|
|
+ var jsonBlob = this.Ctx.Input.RequestBody
|
|
|
+ json.Unmarshal(jsonBlob, &model)
|
|
|
+ model.ModifiedOn = time.Now()
|
|
|
+ model.ModifiedBy = this.User.Realname
|
|
|
+ model.ModifiedUserId, _ = utils.StrTo(this.User.Id).Int()
|
|
|
+
|
|
|
+ cols := []string{
|
|
|
+ "TestDepartId",
|
|
|
+ "TestDepart",
|
|
|
+ "PositionCheckId",
|
|
|
+ "PositionCheck",
|
|
|
+ "Instrument1",
|
|
|
+ "Instrument2",
|
|
|
+ "Instrument3",
|
|
|
+ "Temperature",
|
|
|
+ "DetectBasis",
|
|
|
+ "StandardDesc",
|
|
|
+ "CheckDate",
|
|
|
+ }
|
|
|
+ err := svc.UpdateEntityBytbl(this.User.AccCode+LimsDateEntryName, id, &model, cols)
|
|
|
+ if err == nil {
|
|
|
+ errinfo.Message = "保存成功！"
|
|
|
+ errinfo.Code = 0
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ } else {
|
|
|
+ errinfo.Message = "保存失败！" + utils.AlertProcess(err.Error())
|
|
|
+ errinfo.Code = -1
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ }
|
|
|
+}
|
huahaiyan