| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893 |
- package lims
- import (
- "dashoo.cn/backend/api/business/auditsetting"
- "dashoo.cn/backend/api/business/limscreatereport"
- "encoding/base64"
- "encoding/json"
- "fmt"
- "os"
- "reflect"
- "strconv"
- "strings"
- "time"
- "dashoo.cn/business2/organize"
- "dashoo.cn/business2/userRole"
- "dashoo.cn/backend/api/business/codecsequence"
- "dashoo.cn/backend/api/business/limsbalance"
- "dashoo.cn/backend/api/business/limsdataentry"
- "dashoo.cn/backend/api/business/limsdoctemplate"
- "dashoo.cn/backend/api/business/limsentrust"
- "dashoo.cn/backend/api/business/workflow"
- "github.com/360EntSecGroup-Skylar/excelize"
- . "github.com/linxGnu/goseaweedfs"
- "dashoo.cn/backend/api/business/Limsreportyyaqf"
- "dashoo.cn/backend/api/business/Limsreportzuhq"
- "dashoo.cn/backend/api/business/limsreportbeampumpingunits"
- "dashoo.cn/backend/api/business/limsreportelecground"
- "dashoo.cn/backend/api/business/limsreportequipotent"
- "dashoo.cn/backend/api/business/limsreporthuxf"
- "dashoo.cn/backend/api/business/limsreportkqpm"
- "dashoo.cn/backend/api/business/limsreportldbh"
- "dashoo.cn/backend/api/business/limsreportlp"
- "dashoo.cn/backend/api/business/limsreportnobeampumpingunits"
- . "dashoo.cn/backend/api/controllers"
- "dashoo.cn/utils"
- )
- type CreateReportController struct {
- BaseController
- }
- type RequestModel struct {
- ReportUrl string
- ReportAddress string
- ReportName string
- ReportId int
- }
- type ShenHeModel struct {
- ReportId int
- SuccessStatus int
- AuditorRemark string
- }
- type ReportCallback struct {
- Id string `json:"Id"`
- DocUrl string `json:"DocUrl"`
- }
- // @Title 获取报告分页列表
- // @Description 获取报告分页列表
- // @Success 200 {object} []createreport.LimsCreateReport
- // @router /list [get]
- func (this *CreateReportController) GetCreateReportList() {
- //获取分页信息
- page := this.GetPageInfoForm()
- orderby := "Id"
- asc := false
- Order := this.GetString("Order")
- Prop := this.GetString("Prop")
- if Order != "" && Prop != "" {
- orderby = Prop
- if Order == "asc" {
- asc = true
- }
- }
- ReportCode := this.GetString("ReportCode")
- ReportStatus := this.GetString("ReportStatus")
- CreateOn := this.GetString("CreateOn")
- TemplateName := this.GetString("TemplateName")
- ConUserBy := this.GetString("ConUserBy")
- where := " ReportStatus in (1,2,3,5) and CreateUserId = '" + this.User.Id + "'"
- if ReportCode != "" {
- where = where + " and ReportCode like '%" + ReportCode + "%'"
- }
- if ReportStatus != "" {
- where = where + " a nd ReportStatus = '" + ReportStatus + "'"
- }
- if TemplateName != "" {
- where = where + " and TemplateName like '%" + TemplateName + "%'"
- }
- if ConUserBy != "" {
- where = where + " and ConUserBy like '%" + ConUserBy + "%'"
- }
- if CreateOn != "" {
- dates := strings.Split(CreateOn, ",")
- if len(dates) == 2 {
- minDate := dates[0]
- maxDate := dates[1]
- where = where + " and CreateOn>='" + minDate + "' and CreateOn<='" + maxDate + "'"
- }
- }
- var list []limscreatereport.LimsCreateReport
- svc := limscreatereport.GetCreateReportService(utils.DBE)
- total := svc.GetPagingEntitiesWithOrderBytbl(this.User.AccCode, page.CurrentPage, page.Size, orderby, asc, &list, where)
- var datainfo DataInfo
- datainfo.Items = list
- datainfo.CurrentItemCount = total
- this.Data["json"] = &datainfo
- this.ServeJSON()
- }
- // @Title 获取全部列表
- // @Description 获取全部列表
- // @Success 200 {object} []createreport.LimsCreateReport
- // @router /todolist [get]
- func (this *CreateReportController) GetCreateReportToDoList() {
- //获取分页信息
- page := this.GetPageInfoForm()
- orderby := "Id"
- asc := false
- Order := this.GetString("Order")
- Prop := this.GetString("Prop")
- if Order != "" && Prop != "" {
- orderby = Prop
- if Order == "asc" {
- asc = true
- }
- }
- ReportCode := this.GetString("ReportCode")
- ReportStatus := this.GetString("ReportStatus")
- CreateOn := this.GetString("CreateOn")
- TemplateName := this.GetString("TemplateName")
- ConUserBy := this.GetString("ConUserBy")
- //userSvc := userRole.GetUserService(utils.DBE)
- //organizeSvc := organize.GetOrganizeService(utils.DBE)
- //departList := organizeSvc.GetChildByTopId(this.User.DepartmentId)
- //工作流获取代办事务
- svcActiviti := workflow.GetActivitiService(utils.DBE)
- var processInstanceId string
- var RoleSet auditsetting.Base_OilAuditSetting
- rsvc := auditsetting.GetOilAuditSettingService(utils.DBE)
- rsvc.GetAuditStepRoleEntity(OilAuditSettingName,this.User.DepartmentId,workflow.REPORTAUDIT, &RoleSet)
- processInstanceId = svcActiviti.GetMyTasks(RoleSet.WorkFlowCord, this.User.Id)
- //switch this.User.DepartmentId {
- //case "100000150":
- // processInstanceId = svcActiviti.GetMyTasks(workflow.TJZ_PROCESS_KEY, this.User.Id)
- //case "100000151":
- // processInstanceId = svcActiviti.GetMyTasks(workflow.YX_PROCESS_KEY, this.User.Id)
- //}
- ////取出当前部门及下级部门的所有用户列表
- //var subUserList []userRole.Base_User
- //whereUser := " 1=1 "
- //whereUser += " and Id in (" + processInstanceId + ")"
- //whereUser += " and DepartmentId in (" + departList + ")"
- //userSvc.GetEntities(&subUserList, whereUser)
- //var userIds string
- //
- //for _, tmpUser := range subUserList {
- // userIds += strconv.Itoa(tmpUser.Id) + ","
- //}
- //userIds = strings.Trim(userIds, ",")
- where := " 1=1 "
- where += " AND Id in (" + processInstanceId + ")"
- if ReportCode != "" {
- where = where + " and ReportCode like '%" + ReportCode + "%'"
- }
- if ReportStatus != "" {
- where = where + " and ReportStatus = '" + ReportStatus + "'"
- }
- if TemplateName != "" {
- where = where + " and TemplateName like '%" + TemplateName + "%'"
- }
- if ConUserBy != "" {
- where = where + " and ConUserBy like '%" + ConUserBy + "%'"
- }
- if CreateOn != "" {
- dates := strings.Split(CreateOn, ",")
- if len(dates) == 2 {
- minDate := dates[0]
- maxDate := dates[1]
- where = where + " and CreateOn>='" + minDate + "' and CreateOn<='" + maxDate + "'"
- }
- }
- var list []limscreatereport.LimsCreateReport
- svc := limscreatereport.GetCreateReportService(utils.DBE)
- total := svc.GetPagingEntitiesWithOrderBytbl(this.User.AccCode, page.CurrentPage, page.Size, orderby, asc, &list, where)
- var datainfo DataInfo
- datainfo.Items = list
- datainfo.CurrentItemCount = total
- this.Data["json"] = &datainfo
- this.ServeJSON()
- }
- // @Title 获取全部列表
- // @Description 获取全部列表
- // @Success 200 {object} []createreport.LimsCreateReport
- // @router /alllist [get]
- func (this *CreateReportController) GetCreateReportAllList() {
- //获取分页信息
- page := this.GetPageInfoForm()
- orderby := "Id"
- asc := false
- Order := this.GetString("Order")
- Prop := this.GetString("Prop")
- if Order != "" && Prop != "" {
- orderby = Prop
- if Order == "asc" {
- asc = true
- }
- }
- ReportCode := this.GetString("ReportCode")
- ReportStatus := this.GetString("ReportStatus")
- CreateOn := this.GetString("CreateOn")
- TemplateName := this.GetString("TemplateName")
- ConUserBy := this.GetString("ConUserBy")
- userSvc := userRole.GetUserService(utils.DBE)
- organizeSvc := organize.GetOrganizeService(utils.DBE)
- departList := organizeSvc.GetChildByTopId(this.User.DepartmentId)
- //取出当前部门及下级部门的所有用户列表
- var subUserList []userRole.Base_User
- whereUser := " 1=1 "
- whereUser += " and DepartmentId in (" + departList + ")"
- userSvc.GetEntities(&subUserList, whereUser)
- var userIds string
- for _, tmpUser := range subUserList {
- userIds += strconv.Itoa(tmpUser.Id) + ","
- }
- userIds = strings.Trim(userIds, ",")
- where := " 1=1 "
- where += " AND CreateUserId in (" + userIds + ")"
- if ReportCode != "" {
- where = where + " and ReportCode like '%" + ReportCode + "%'"
- }
- if ReportStatus != "" {
- where = where + " and ReportStatus = '" + ReportStatus + "'"
- }
- if TemplateName != "" {
- where = where + " and TemplateName like '%" + TemplateName + "%'"
- }
- if ConUserBy != "" {
- where = where + " and ConUserBy like '%" + ConUserBy + "%'"
- }
- if CreateOn != "" {
- dates := strings.Split(CreateOn, ",")
- if len(dates) == 2 {
- minDate := dates[0]
- maxDate := dates[1]
- where = where + " and CreateOn>='" + minDate + "' and CreateOn<='" + maxDate + "'"
- }
- }
- var list []limscreatereport.LimsCreateReport
- svc := limscreatereport.GetCreateReportService(utils.DBE)
- total := svc.GetPagingEntitiesWithOrderBytbl(this.User.AccCode, page.CurrentPage, page.Size, orderby, asc, &list, where)
- var datainfo DataInfo
- datainfo.Items = list
- datainfo.CurrentItemCount = total
- this.Data["json"] = &datainfo
- this.ServeJSON()
- }
- // @Title 获取报告数量
- // @Description 获取报告数量
- // @Success 200 {object} []createreport.LimsCreateReport
- // @router /getreporttotal/:id [get]
- func (this *CreateReportController) GetReportTotal() {
- Id := this.Ctx.Input.Param(":id")
- where := "EId = '" + Id + "'"
- svc := limscreatereport.GetCreateReportService(utils.DBE)
- total := svc.GetReportCount(this.User.AccCode+LimsCreateReportName, where)
- var errinfo ErrorInfo
- errinfo.Code = total
- this.Data["json"] = &errinfo
- this.ServeJSON()
- }
- // @Title 获取报告Url
- // @Description 获取报告Url
- // @Success 200 {object} []createreport.LimsCreateReport
- // @router /getreporturl/:id [get]
- func (this *CreateReportController) GetReportUrl() {
- var reportlist []limscreatereport.ReportModel
- var reportrequest RequestModel
- var ReportUrl string
- Id := this.Ctx.Input.Param(":id")
- where := "a.Id = '" + Id + "'"
- order := " b.CreateOn desc"
- svc := limscreatereport.GetCreateReportService(utils.DBE)
- reportlist = svc.GetReportUrl(this.User.AccCode+LimsCreateReportName, this.User.AccCode+LimsReportHistoryName, order, where)
- if reportlist[0].UnHGReportUrl == "" {
- ReportUrl = reportlist[0].ReportUrl
- } else {
- ReportUrl = reportlist[0].UnHGReportUrl
- }
- reportrequest.ReportAddress = "http://" + ReportUrl
- reportrequest.ReportId = reportlist[0].Id
- reportrequest.ReportUrl = base64.RawURLEncoding.EncodeToString(quickStringByte(ReportUrl))
- reportname := strconv.Itoa(reportlist[0].Id) + "_" + reportlist[0].TemplateName + ".xlsx"
- reportrequest.ReportName = base64.RawURLEncoding.EncodeToString(quickStringByte(reportname))
- var errinfo ErrorDataInfo
- errinfo.Item = reportrequest
- this.Data["json"] = &errinfo
- this.ServeJSON()
- }
- // @Title 获取新增报告列表
- // @Description 获取新增报告列表
- // @Success 200 {object} []createreport.LimsCreateReport
- // @router /repoertentrustlist/ [get]
- func (this *CreateReportController) GetReportEntrustList() {
- //获取分页信息
- page := this.GetPageInfoForm()
- entrustno := this.GetString("entrustno")
- EntrustTypeId := this.GetString("EntrustTypeId")
- CustomerId := this.GetString("CustomerId")
- detectsampleId := this.GetString("DetectSampleId")
- EntrustStatus := this.GetString("EntrustStatus")
- EntrustTime := this.GetString("EntrustTime")
- ProjectTypeId := this.GetString("ProjectTypeId")
- orderby := "a.Id desc"
- userSvc := userRole.GetUserService(utils.DBE)
- organizeSvc := organize.GetOrganizeService(utils.DBE)
- departList := organizeSvc.GetChildByTopId(this.User.DepartmentId)
- //取出当前部门及下级部门的所有用户列表
- var subUserList []userRole.Base_User
- whereUser := " 1=1 "
- whereUser += " and DepartmentId in (" + departList + ")"
- userSvc.GetEntities(&subUserList, whereUser)
- var userIds string
- for _, tmpUser := range subUserList {
- userIds += strconv.Itoa(tmpUser.Id) + ","
- }
- userIds = strings.Trim(userIds, ",")
- where := " 1=1 "
- where += " and a.CreateUserId in (" + userIds + ")"
- where += " AND c.CheckStatus = 4 and (a.ReportStatus = 0 or a.ReportStatus is NULL) and c.CreateReportStatus = 0 "
- if entrustno != "" {
- where = where + " and a.EntrustNo like '%" + entrustno + "%'"
- }
- if EntrustTypeId != "" {
- where = where + " and a.EntrustTypeId = '" + EntrustTypeId + "'"
- }
- if ProjectTypeId != "" {
- where = where + " and a.ProjectTypeId = '" + ProjectTypeId + "'"
- }
- if CustomerId != "" {
- where = where + " and a.CustomerId = '" + CustomerId + "'"
- }
- if detectsampleId != "" {
- where = where + " and a.DetectSampleId = '" + detectsampleId + "'"
- }
- if EntrustStatus != "" {
- where = where + " and a.EntrustStatus = '" + EntrustStatus + "'"
- }
- if EntrustTime != "" {
- dates := strings.Split(EntrustTime, ",")
- if len(dates) == 2 {
- minDate := dates[0]
- maxDate := dates[1]
- where = where + " and a.EntrustTime>='" + minDate + "' and a.EntrustTime<='" + maxDate + "'"
- }
- }
- var list []limscreatereport.DataEntryEntrustModel
- svc := limscreatereport.GetCreateReportService(utils.DBE)
- total, list := svc.GetDataEntryEntrust(this.User.AccCode+LimsDateEntryName, this.User.AccCode+LimsTaskBalanceName, this.User.AccCode+LimsEntrustMainName, page.CurrentPage, page.Size, orderby, where)
- var datainfo DataInfo
- datainfo.Items = list
- datainfo.CurrentItemCount = total
- this.Data["json"] = &datainfo
- this.ServeJSON()
- }
- // @Title 获取委托表详情
- // @Description 获取委托单详情
- // @Success 200 {object} []createreport.CreateReport
- // @router /dictlist/ [get]
- func (this *CreateReportController) GetDictOptions() {
- svc := limscreatereport.GetCreateReportService(utils.DBE)
- tableNameList := make(map[string]string)
- tableNameList["CustomerName"] = CustomerName
- tableNameList["TestPackageTypesName"] = TestPackageTypesName
- dictList := svc.GetDictList(this.User.AccCode, tableNameList)
- var datainfo DataInfo
- datainfo.Items = dictList
- this.Data["json"] = &datainfo
- this.ServeJSON()
- }
- // @Title 数据录入时生成报告
- // @Description 生成报告
- // @Success 200 {object} controllers.Request
- // @router /datatoexcelreport/ [post]
- func (this *CreateReportController) DataToExcelReport() {
- var jsonblob = this.Ctx.Input.RequestBody
- var reportlist limsdataentry.LimsDateEntryModel
- var datalist limscreatereport.DataEntryEntrustModel
- json.Unmarshal(jsonblob, &reportlist)
- datalist.Id = reportlist.EId
- datalist.EId = reportlist.EId
- datalist.DataEntryId = reportlist.Id
- datalist.TaskId = reportlist.TaskId
- datareportlist := []limscreatereport.DataEntryEntrustModel{
- datalist,
- }
- this.CreateReportN(datareportlist, 1)
- }
- // @Title 复检
- // @Description 报告复检生成数据录入
- // @Success 200 {object} controllers.Request
- // @router /recheck/[post]
- func (this *CreateReportController) Recheck() {
- ReCheckUser := this.GetString("ReCheckUser")
- RecheckUserId := this.GetString("ReCheckUserId")
- var jsonblob = this.Ctx.Input.RequestBody
- var errinfo ErrorDataInfo
- svcEntrust := limsentrust.GetLimsEnturstService(utils.DBE)
- var reportmodel limscreatereport.LimsCreateReport
- json.Unmarshal(jsonblob, &reportmodel)
- //获取模板的URL
- var docTemplate limsdataentry.LimsDocTemplate
- docTemplateList := svcEntrust.GetReportTemplateUrl(
- this.User.AccCode+LimsEntrustMainName,
- this.User.AccCode+TestPackageTypesName,
- this.User.AccCode+LimsDocTemplateName,
- strconv.Itoa(reportmodel.EId))
- if !reflect.ValueOf(docTemplateList).IsNil() && len(docTemplateList) > 0 {
- docTemplate = docTemplateList[0]
- } else {
- errinfo.Message = "报告模板不存在!"
- errinfo.Code = -1
- this.Data["json"] = &errinfo
- this.ServeJSON()
- return
- }
- svc := limscreatereport.GetCreateReportService(utils.DBE)
- var dataentrylist []limsdataentry.LimsDateEntry
- svc.GetEntitysByWhere(this.User.AccCode+LimsDateEntryName, "EId = '"+utils.ToStr(reportmodel.EId)+"'", &dataentrylist)
- dataentryId,TaskId:=svc.CreateDataentry(this.User.DepartmentId, this.User.AccCode, this.User.AccCode+LimsTaskBalanceName, this.User.AccCode+LimsEntrustMainName, this.User.AccCode+LimsDateEntryName,this.User.AccCode+LimsDocTemplateName,this.User.AccCode+LimsDocTemplateDetailName, reportmodel, dataentrylist[0].DataEntryCode, this.User.DepartmentId,RecheckUserId,ReCheckUser)
- //新增数据录入记录 开始工作流
- //更新报告状态
- var emptyEntity limscreatereport.LimsCreateReport
- emptyEntity.ReportStatus = 5
- svc.UpdateEntityBytbl(this.User.AccCode+LimsCreateReportName, reportmodel.Id, &emptyEntity, []string{"ReportStatus"})
- //不合格的录入数据写入新生成的数据录入
- switch docTemplate.TemplateCode {
- //防雷装置报告
- case limsdoctemplate.DAYT_LIGHTPROTECT_REPORT:
- var lplist []limsreportlp.LimsReportLightProtect
- lpwhere := "EId = '" + utils.ToStr(reportmodel.EId) + "' and CheckResult = '×'"
- svc.GetEntitysByWhere(this.User.AccCode+LimsReportLightProtectName, lpwhere, &lplist)
- if len(lplist) == 0 {
- var errinfo ErrorDataInfo
- errinfo.Message = "数据为空"
- errinfo.Code = -1
- this.Data["json"] = &errinfo
- this.ServeJSON()
- return
- } else {
- for i := 0; i < len(lplist); i++ {
- var entity limsreportlp.LimsReportLightProtect
- entity = lplist[i]
- entity.CheckResult = ""
- entity.CreateOn = time.Now()
- entity.CreateBy = this.User.Realname
- entity.CreateUserId, _ = utils.StrTo(this.User.Id).Int()
- entity.EId, _ = utils.StrTo(reportmodel.EId).Int()
- entity.DataEntryId, _ = utils.StrTo(dataentryId).Int()
- entity.TaskBalanceId, _ = utils.StrTo(TaskId).Int()
- _, err := svc.InsertEntityBytbl(this.User.AccCode+LimsReportLightProtectName, &entity)
- var errinfo ErrorDataInfo
- if err == nil {
- errinfo.Item = dataentryId
- 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()
- }
- }
- }
- //防雷装置(等电位)报告
- case limsdoctemplate.DAYT_EQUIPOTENT_REPORT:
- var eqlist []limsreportequipotent.LimsReportEquipotent
- eqwhere := "EId = '" + utils.ToStr(reportmodel.EId) + "' and CheckResult = '×'"
- svc.GetEntitysByWhere(this.User.AccCode+LimsReportEquipotentName, eqwhere, &eqlist)
- if len(eqlist) == 0 {
- var errinfo ErrorDataInfo
- errinfo.Message = "数据为空"
- errinfo.Code = -1
- this.Data["json"] = &errinfo
- this.ServeJSON()
- return
- } else {
- for i := 0; i < len(eqlist); i++ {
- var entity limsreportequipotent.LimsReportEquipotent
- entity = eqlist[i]
- entity.CheckResult = ""
- entity.CreateOn = time.Now()
- entity.CreateBy = this.User.Realname
- entity.CreateUserId, _ = utils.StrTo(this.User.Id).Int()
- entity.EId, _ = utils.StrTo(reportmodel.EId).Int()
- entity.DataEntryId, _ = utils.StrTo(dataentryId).Int()
- entity.TaskBalanceId, _ = utils.StrTo(TaskId).Int()
- _, err := svc.InsertEntityBytbl(this.User.AccCode+LimsReportEquipotentName, &entity)
- var errinfo ErrorDataInfo
- if err == nil {
- errinfo.Item = dataentryId
- 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()
- }
- }
- }
- //电气接地装置报告
- case limsdoctemplate.DAYT_ELECGROUND_REPORT:
- var eglist []limsreportelecground.LimsReportElecGround
- egwhere := "EId = '" + utils.ToStr(reportmodel.EId) + "' and CheckResult = '×'"
- svc.GetEntitysByWhere( this.User.AccCode+LimsReportElecGroundName, egwhere, &eglist)
- if len(eglist) == 0 {
- var errinfo ErrorDataInfo
- errinfo.Message = "数据为空"
- errinfo.Code = -1
- this.Data["json"] = &errinfo
- this.ServeJSON()
- return
- } else {
- for i := 0; i < len(eglist); i++ {
- var entity limsreportelecground.LimsReportElecGround
- entity = eglist[i]
- entity.CheckResult = ""
- entity.CreateOn = time.Now()
- entity.CreateBy = this.User.Realname
- entity.CreateUserId, _ = utils.StrTo(this.User.Id).Int()
- entity.EId, _ = utils.StrTo(reportmodel.EId).Int()
- entity.DataEntryId, _ = utils.StrTo(dataentryId).Int()
- entity.TaskBalanceId, _ = utils.StrTo(TaskId).Int()
- _, err := svc.InsertEntityBytbl(this.User.AccCode+LimsReportElecGroundName, &entity)
- var errinfo ErrorDataInfo
- if err == nil {
- errinfo.Item = dataentryId
- 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()
- }
- }
- }
- //漏电保护检测报告
- case limsdoctemplate.DAYT_LEAKPROTECT_REPORT:
- var ldbhlist []limsreportldbh.LimsReportLeakProtect
- ldbhwhere := "EId = '" + utils.ToStr(reportmodel.EId) + "' and CheckResult = '×'"
- svc.GetEntitysByWhere(this.User.AccCode+LimsReportLeakProtectName, ldbhwhere, &ldbhlist)
- if len(ldbhlist) == 0 {
- var errinfo ErrorDataInfo
- errinfo.Message = "数据为空"
- errinfo.Code = -1
- this.Data["json"] = &errinfo
- this.ServeJSON()
- return
- } else {
- for i := 0; i < len(ldbhlist); i++ {
- var entity limsreportldbh.LimsReportLeakProtect
- entity = ldbhlist[i]
- entity.CheckResult = ""
- entity.CreateOn = time.Now()
- entity.CreateBy = this.User.Realname
- entity.CreateUserId, _ = utils.StrTo(this.User.Id).Int()
- entity.EId, _ = utils.StrTo(reportmodel.EId).Int()
- entity.DataEntryId, _ = utils.StrTo(dataentryId).Int()
- entity.TaskBalanceId, _ = utils.StrTo(TaskId).Int()
- _, err := svc.InsertEntityBytbl(this.User.AccCode+LimsReportLeakProtectName, &entity)
- var errinfo ErrorDataInfo
- if err == nil {
- errinfo.Item = dataentryId
- 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 /datatoexcelreportn/ [post]
- func (this *CreateReportController) DataToExcelReportN() {
- var jsonblob = this.Ctx.Input.RequestBody
- var datalist []limscreatereport.DataEntryEntrustModel
- json.Unmarshal(jsonblob, &datalist)
- var errinfo ErrorInfo
- taskid := datalist[0].TaskId
- if len(datalist) > 1 {
- for i := 1; i < len(datalist); i++ {
- if datalist[i].TaskId != taskid {
- errinfo.Message = "请选择相同的检测任务生成报告!"
- errinfo.Code = -1
- this.Data["json"] = &errinfo
- this.ServeJSON()
- return
- } else {
- this.CreateReportN(datalist, 0)
- break
- }
- }
- } else {
- this.CreateReportN(datalist, 0)
- }
- }
- /**
- * 选择多条记录生成报告
- */
- func (this *CreateReportController) CreateReportN(datalist []limscreatereport.DataEntryEntrustModel, datareportshow int) {
- var reportId int64
- var errinfo ErrorDataInfo
- var reportUrl string
- var UnHGReportUrl string
- var err error
- svcReport := limscreatereport.GetCreateReportService(utils.DBE)
- svcEntrust := limsentrust.GetLimsEnturstService(utils.DBE)
- //生成dataentryidlist
- var dataentryIds string
- for _, tmpUser := range datalist {
- dataentryIds += strconv.Itoa(tmpUser.DataEntryId) + ","
- }
- dataentryIds = strings.Trim(dataentryIds, ",")
- //获取模板的URL
- var docTemplate limsdataentry.LimsDocTemplate
- docTemplateList := svcEntrust.GetReportTemplateUrl(
- this.User.AccCode+LimsEntrustMainName,
- this.User.AccCode+TestPackageTypesName,
- this.User.AccCode+LimsDocTemplateName,
- strconv.Itoa(datalist[0].Id))
- if !reflect.ValueOf(docTemplateList).IsNil() && len(docTemplateList) > 0 {
- docTemplate = docTemplateList[0]
- } else {
- errinfo.Message = "报告模板不存在!"
- errinfo.Code = -1
- errinfo.Item = reportId
- this.Data["json"] = &errinfo
- this.ServeJSON()
- return
- }
- //判断是否有可生成的数据
- for _, listdata := range datalist {
- if listdata.CreateReportStatus == 1 {
- errinfo.Message = "此数据已生成报告,不能再生成!"
- errinfo.Code = -1
- errinfo.Item = reportId
- this.Data["json"] = &errinfo
- this.ServeJSON()
- return
- }
- }
- //获取任务委托实体
- var entrustMains []limsentrust.LimsEntrustMain
- var model limscreatereport.ReportTemplateModel
- whereStr := "id='" + strconv.Itoa(datalist[0].Id) + "'"
- svcEntrust.GetEntitysByWhere(this.User.AccCode+LimsEntrustMainName, whereStr, &entrustMains)
- wheretem := "a.id='" + strconv.Itoa(datalist[0].Id) + "'"
- model = svcReport.GetTemplate(this.User.AccCode+LimsEntrustMainName, this.User.AccCode+TestPackageTypesName, wheretem)
- //生成报告文档,返回URL地址
- reportUrl, UnHGReportUrl, err = this.generateExcelReportN(entrustMains[0], docTemplate, strconv.Itoa(datalist[0].Id), dataentryIds)
- fmt.Println(UnHGReportUrl)
- if len(reportUrl) > 0 && err == nil {
- this.ReportCreateThen(reportUrl, "", datalist, entrustMains, model, datareportshow, reportId, err)
- }
- if len(UnHGReportUrl) > 0 && err == nil {
- this.ReportCreateThen("", UnHGReportUrl, datalist, entrustMains, model, datareportshow, reportId, err)
- }
- }
- /**
- * 生成报告处理
- */
- func (this *CreateReportController) ReportCreateThen(reportUrl string, UnHGReportUrl string, datalist []limscreatereport.DataEntryEntrustModel, entrustMains []limsentrust.LimsEntrustMain, model limscreatereport.ReportTemplateModel, datareportshow int, reportId int64, err error) {
- var errinfo ErrorDataInfo
- svcReport := limscreatereport.GetCreateReportService(utils.DBE)
- //生成报告数据
- var reportEntity limscreatereport.LimsCreateReport
- reportEntity.ReportUrl = reportUrl
- reportEntity.UnHGReportUrl = UnHGReportUrl
- reportEntity.DocName = datalist[0].DocName
- reportEntity.EId, _ = utils.StrTo(strconv.Itoa(datalist[0].Id)).Int()
- reportEntity.CreateUserId, _ = utils.StrTo(this.User.Id).Int()
- reportEntity.CreateBy = this.User.Realname
- reportEntity.CreateOn = time.Now()
- //reportEntity.ConUserOn = new(time.Time)
- //reportEntity.SignUserOn =new()
- reportEntity.TemplateId = model.TemplateId
- reportEntity.TestDetail = model.FullName
- reportEntity.CustomerId = model.CustomerId
- reportEntity.EntrustNo = model.EntrustNo
- reportEntity.CustomerName = model.CustomerName
- reportEntity.ReportCode = entrustMains[0].EntrustNo
- var emptyEntity limscreatereport.LimsCreateReport
- svc := limsdataentry.GetLimsDataEntryService(utils.DBE)
- var users []userRole.Base_RoleList
- if datareportshow == 0 {
- reportId, err = svcReport.InsertEntityBytbl(this.User.AccCode+LimsCreateReportName, &reportEntity)
- //启动数据录入工作流
- svcActiviti := workflow.GetActivitiService(utils.DBE)
- var processInstanceId string
- var receiveVal string
- users = svc.GetUserByRole("10000184", this.User.AccCode)
- var userIds string
- for _, tmpUser := range users {
- userIds += strconv.FormatInt(tmpUser.Id, 10) + ","
- }
- userIds = strings.Trim(userIds, ",")
- var RoleSet auditsetting.Base_OilAuditSetting
- rsvc := auditsetting.GetOilAuditSettingService(utils.DBE)
- rsvc.GetAuditStepRoleEntity(OilAuditSettingName,this.User.DepartmentId,workflow.REPORTAUDIT, &RoleSet)
- processInstanceId = svcActiviti.StartProcess(RoleSet.WorkFlowCord, strconv.Itoa(reportEntity.Id), this.User.Id)
- emptyEntity.FlowKey = processInstanceId
- err = svcReport.UpdateEntityBytbl(this.User.AccCode+LimsCreateReportName, reportEntity.Id, &emptyEntity, []string{"FlowKey"})
- if UnHGReportUrl == "" {
- receiveVal = svcActiviti.TaskComplete(RoleSet.WorkFlowCord, strconv.Itoa(reportEntity.Id), userIds, this.User.Id, "1", "合格报告审核")
- } else {
- receiveVal = svcActiviti.TaskComplete(RoleSet.WorkFlowCord, strconv.Itoa(reportEntity.Id), userIds, this.User.Id, "1", "不合格报告审核")
- }
- if receiveVal == "true" {
- //报告生成将标志位变1
- for _, listdata := range datalist {
- listdata.CreateReportStatus = 1
- err = svcReport.UpdateEntityBytbl(this.User.AccCode+LimsDateEntryName, listdata.DataEntryId, &listdata, []string{"CreateReportStatus"})
- }
- if err == nil {
- errinfo.Message = "报告生成成功"
- errinfo.Code = 0
- errinfo.Item = reportEntity
- this.Data["json"] = &errinfo
- this.ServeJSON()
- } else {
- errinfo.Message = "报告生成发生错误!"
- errinfo.Code = -1
- this.Data["json"] = &errinfo
- this.ServeJSON()
- }
- } else {
- errinfo.Message = "工作流异常,请联系管理员!"
- errinfo.Code = -1
- this.Data["json"] = &errinfo
- this.ServeJSON()
- return
- }
- //switch this.User.DepartmentId {
- //case "100000150":
- // users = svc.GetUserByRole("10000184", this.User.AccCode)
- // var userIds string
- // for _, tmpUser := range users {
- // userIds += strconv.FormatInt(tmpUser.Id, 10) + ","
- // }
- // userIds = strings.Trim(userIds, ",")
- //
- // var RoleSet auditsetting.Base_OilAuditSetting
- // rsvc := auditsetting.GetOilAuditSettingService(utils.DBE)
- // rsvc.GetAuditStepRoleEntity(OilAuditSettingName,this.User.DepartmentId,workflow.REPORTAUDIT, &RoleSet)
- //
- // processInstanceId = svcActiviti.StartProcess(RoleSet.WorkFlowCord, strconv.Itoa(reportEntity.Id), this.User.Id)
- // emptyEntity.FlowKey = processInstanceId
- // err = svcReport.UpdateEntityBytbl(this.User.AccCode+LimsCreateReportName, reportEntity.Id, &emptyEntity, []string{"FlowKey"})
- // if UnHGReportUrl == "" {
- // receiveVal = svcActiviti.TaskComplete(RoleSet.WorkFlowCord, strconv.Itoa(reportEntity.Id), userIds, this.User.Id, "1", "特检合格报告审核")
- // } else {
- // receiveVal = svcActiviti.TaskComplete(RoleSet.WorkFlowCord, strconv.Itoa(reportEntity.Id), userIds, this.User.Id, "1", "特检不合格报告审核")
- // }
- // if receiveVal == "true" {
- // //报告生成将标志位变1
- // for _, listdata := range datalist {
- // listdata.CreateReportStatus = 1
- // err = svcReport.UpdateEntityBytbl(this.User.AccCode+LimsDateEntryName, listdata.DataEntryId, &listdata, []string{"CreateReportStatus"})
- // }
- // if err == nil {
- // errinfo.Message = "报告生成成功"
- // errinfo.Code = 0
- // errinfo.Item = reportEntity
- // this.Data["json"] = &errinfo
- // this.ServeJSON()
- // } else {
- // errinfo.Message = "报告生成发生错误!"
- // errinfo.Code = -1
- // this.Data["json"] = &errinfo
- // this.ServeJSON()
- // }
- // } else {
- // errinfo.Message = "工作流异常,请联系管理员!"
- // errinfo.Code = -1
- // this.Data["json"] = &errinfo
- // this.ServeJSON()
- // return
- // }
- //case "100000151":
- // users = svc.GetUserByRole("10000182", this.User.AccCode)
- // var userIds string
- // for _, tmpUser := range users {
- // userIds += strconv.FormatInt(tmpUser.Id, 10) + ","
- // }
- // userIds = strings.Trim(userIds, ",")
- // processInstanceId = svcActiviti.StartProcess(workflow.YX_PROCESS_KEY, strconv.Itoa(reportEntity.Id), this.User.Id)
- // var emptyEntity limscreatereport.LimsCreateReport
- // emptyEntity.FlowKey = processInstanceId
- // err = svcReport.UpdateEntityBytbl(this.User.AccCode+LimsCreateReportName, reportEntity.Id, &emptyEntity, []string{"FlowKey"})
- // receiveVal = svcActiviti.TaskComplete(workflow.YX_PROCESS_KEY, strconv.Itoa(reportEntity.Id), userIds, this.User.Id, "1", "宇信报告审核")
- // if receiveVal == "true" {
- // //报告生成将标志位变1
- // for _, listdata := range datalist {
- // listdata.CreateReportStatus = 1
- // err = svcReport.UpdateEntityBytbl(this.User.AccCode+LimsDateEntryName, listdata.DataEntryId, &listdata, []string{"CreateReportStatus"})
- // }
- // if err == nil {
- // errinfo.Message = "报告生成成功"
- // errinfo.Code = 0
- // errinfo.Item = reportEntity
- // this.Data["json"] = &errinfo
- // this.ServeJSON()
- // } else {
- // errinfo.Message = "报告生成发生错误!"
- // errinfo.Code = -1
- // this.Data["json"] = &errinfo
- // this.ServeJSON()
- // }
- // } else {
- // errinfo.Message = "工作流异常,请联系管理员!"
- // errinfo.Code = -1
- // this.Data["json"] = &errinfo
- // this.ServeJSON()
- // return
- // }
- //}
- } else {
- if err == nil {
- errinfo.Message = "报告生成成功"
- errinfo.Code = 0
- errinfo.Item = reportEntity
- this.Data["json"] = &errinfo
- this.ServeJSON()
- } else {
- errinfo.Message = "报告生成发生错误!"
- errinfo.Code = -1
- this.Data["json"] = &errinfo
- this.ServeJSON()
- }
- }
- }
- /**
- * 新加的报告模板在这个方法添加(选择多条生成报告)
- */
- func (this *CreateReportController) generateExcelReportN(entrustMain limsentrust.LimsEntrustMain,
- docTemplate limsdataentry.LimsDocTemplate, entrustId string, dataentryIds string) (reportUrl string, UnHGReportUrl string, err error) {
- switch docTemplate.TemplateCode {
- //呼吸阀检测报告
- case limsdoctemplate.DAYT_ATMOSVALVE_REPORT:
- //获取序列号
- codecSvc := codecsequence.GetCodecSequenceService(utils.DBE)
- seqStr := codecSvc.GetReportHuxfSequence(this.User.AccCode)
- svc := limsreporthuxf.GetLimsReportHuxfService(utils.DBE)
- reportUrl, err = svc.DataToExcelReport(entrustMain, this.User.AccCode+LimsReportHuxfName, this.User.AccCode+LimsSpecifyStandardName, this.User.AccCode+LimsDateEntryName, this.User.AccCode+LimsCreateReportName, BaseUserName, seqStr, docTemplate.FileURL, entrustId, this.User.Description, dataentryIds)
- //阻火器报告
- case limsdoctemplate.DAYT_BACKFIRE_REPORT:
- codecSvc := codecsequence.GetCodecSequenceService(utils.DBE)
- seqStr := codecSvc.GetReportZuhqSequence(this.User.AccCode)
- svc := Limsreportzuhq.GetLimsreportzuhqService(utils.DBE)
- reportUrl, err = svc.DataToExcelReport(entrustMain, this.User.AccCode+LimsReportZuhqName, this.User.AccCode+LimsPressureLeakName, this.User.AccCode+LimsSpecifyStandardName, this.User.AccCode+LimsDateEntryName, this.User.AccCode+LimsCreateReportName, BaseUserName, seqStr, docTemplate.FileURL, entrustId, this.User.Description, dataentryIds)
- //空气泡沫产生器
- case limsdoctemplate.DAYT_AIRFOAMGENERATOR_REPORT:
- codecSvc := codecsequence.GetCodecSequenceService(utils.DBE)
- seqStr := codecSvc.GetReportKqpmSequence(this.User.AccCode)
- svc := limsreportkqpm.GetLimsReportkqpmService(utils.DBE)
- reportUrl, err = svc.DataToExcelReport(entrustMain, this.User.AccCode+LimsReportKqpmName, this.User.AccCode+LimsDateEntryName, this.User.AccCode+LimsCreateReportName, BaseUserName, seqStr, docTemplate.FileURL, entrustId, this.User.Description, dataentryIds)
- //液压安全阀报告
- case limsdoctemplate.DAYT_HYDRAULICSAFE_REPORT:
- codecSvc := codecsequence.GetCodecSequenceService(utils.DBE)
- seqStr := codecSvc.GetReportYyaqfSequence(this.User.AccCode)
- svc := limsreportyyaqf.GetLimsReportYyaqfService(utils.DBE)
- reportUrl, err = svc.DataToExcelReport(entrustMain, this.User.AccCode+LimsReportYeyaqfName, this.User.AccCode+LimsSpecifyStandardName, this.User.AccCode+LimsDateEntryName, this.User.AccCode+LimsCreateReportName, BaseUserName, seqStr, docTemplate.FileURL, entrustId, this.User.Description, dataentryIds)
- //游梁式抽油机检测报告
- case limsdoctemplate.DAYT_BEAMPUMPINGUNIT_REPORT:
- codecSvc := codecsequence.GetCodecSequenceService(utils.DBE)
- seqStr := codecSvc.GetDetailBeamPumpingUnitsSequence(this.User.AccCode)
- svc := limsreportbeampumpingunits.GetLimsReportBeamPumpingUnitsService(utils.DBE)
- reportUrl, err = svc.DataToExcelReport(entrustMain, this.User.AccCode+LimsReportBeamPumpingUnitName, this.User.AccCode+LimsDateEntryName, this.User.AccCode+LimsCreateReportName, BaseUserName, seqStr, docTemplate.FileURL, entrustId, this.User.Description, dataentryIds)
- //无游梁式抽油机检测报告
- case limsdoctemplate.DAYT_NOBEAMPUMPINGUNIT_REPORT:
- codecSvc := codecsequence.GetCodecSequenceService(utils.DBE)
- seqStr := codecSvc.GetDetailNoBeamPumpingUnitsSequence(this.User.AccCode)
- svc := limsreportnobeampumpingunits.GetLimsReportNoBeamPumpingUnitsService(utils.DBE)
- reportUrl, err = svc.DataToExcelReport(entrustMain, this.User.AccCode+LimsReportNoBeamPumpingUnitName, this.User.AccCode+LimsDateEntryName, this.User.AccCode+LimsCreateReportName, BaseUserName, seqStr, docTemplate.FileURL, entrustId, this.User.Description, dataentryIds)
- //防雷装置报告
- case limsdoctemplate.DAYT_LIGHTPROTECT_REPORT:
- seqStr := entrustMain.EntrustNo
- svc := limsreportlp.GetLimsReportLpService(utils.DBE)
- //数据写入excel 报告生成合格不合格两种
- reportUrl, err = svc.DataToExcelReport("○", entrustMain, this.User.AccCode+LimsReportLightProtectName, this.User.AccCode+LimsDateEntryName, this.User.AccCode+LimsCreateReportName, BaseUserName, seqStr, docTemplate.FileURL, entrustId, this.User.Description, dataentryIds)
- UnHGReportUrl, err = svc.DataToExcelReport("×", entrustMain, this.User.AccCode+LimsReportLightProtectName, this.User.AccCode+LimsDateEntryName, this.User.AccCode+LimsCreateReportName, BaseUserName, seqStr, docTemplate.FileURL, entrustId, this.User.Description, dataentryIds)
- //防雷装置(等电位)报告
- case limsdoctemplate.DAYT_EQUIPOTENT_REPORT:
- seqStr := entrustMain.EntrustNo
- svc := limsreportequipotent.GetLimsReportEquipotentService(utils.DBE)
- reportUrl, err = svc.DataToExcelReport("○",entrustMain, this.User.AccCode+LimsReportEquipotentName, this.User.AccCode+LimsDateEntryName, this.User.AccCode+LimsCreateReportName, BaseUserName, seqStr, docTemplate.FileURL, entrustId, this.User.Description, dataentryIds)
- UnHGReportUrl, err = svc.DataToExcelReport("×",entrustMain, this.User.AccCode+LimsReportEquipotentName, this.User.AccCode+LimsDateEntryName,this.User.AccCode+LimsCreateReportName,BaseUserName,seqStr, docTemplate.FileURL, entrustId, this.User.Description,dataentryIds)
- //电气接地装置报告
- case limsdoctemplate.DAYT_ELECGROUND_REPORT:
- seqStr := entrustMain.EntrustNo
- svc := limsreportelecground.GetLimsReportElecGroundService(utils.DBE)
- reportUrl, err = svc.DataToExcelReport("○",entrustMain, this.User.AccCode+LimsReportElecGroundName, this.User.AccCode+LimsDateEntryName, this.User.AccCode+LimsCreateReportName, BaseUserName, seqStr, docTemplate.FileURL, entrustId, this.User.Description, dataentryIds)
- UnHGReportUrl, err = svc.DataToExcelReport("×",entrustMain, this.User.AccCode+LimsReportElecGroundName,this.User.AccCode+LimsDateEntryName,this.User.AccCode+LimsCreateReportName,BaseUserName, seqStr, docTemplate.FileURL, entrustId, this.User.Description,dataentryIds)
- //漏电保护检测报告
- case limsdoctemplate.DAYT_LEAKPROTECT_REPORT:
- seqStr := entrustMain.EntrustNo
- svc := limsreportldbh.GetLimsReportldbhService(utils.DBE)
- reportUrl, err = svc.DataToExcelReport("○",entrustMain, this.User.AccCode+LimsReportLeakProtectName, this.User.AccCode+LimsDateEntryName, this.User.AccCode+LimsCreateReportName, BaseUserName, seqStr, docTemplate.FileURL, entrustId, this.User.Description, dataentryIds)
- UnHGReportUrl, err = svc.DataToExcelReport("×",entrustMain, this.User.AccCode+LimsReportLeakProtectName,this.User.AccCode+LimsDateEntryName,this.User.AccCode+LimsCreateReportName,BaseUserName, seqStr, docTemplate.FileURL, entrustId, this.User.Description,dataentryIds)
- }
- return reportUrl, UnHGReportUrl, err
- }
- // @Title 生成报告
- // @Description 判断是否已经生成了报告
- // @Success 200 {object} controllers.Request
- // @router /datatoexcelreport/:id [post]
- //func (this *CreateReportController) DataToExcelReport() {
- // entrustId := this.Ctx.Input.Param(":id")
- // svcReport := limscreatereport.GetCreateReportService(utils.DBE)
- // //判断同一个委托单是否已生成报告
- // where := "EId = '" + entrustId + "'"
- // total := svcReport.GetReportCount(this.User.AccCode+LimsCreateReportName, where)
- // if total == 0 {
- // //生成报告
- // this.CreateReport(entrustId)
- // } else {
- // err := svcReport.DeleteEntityBytbl(this.User.AccCode+LimsCreateReportName, where)
- // if err == nil {
- // //生成报告
- // this.CreateReport(entrustId)
- // } else {
- // fmt.Println("报告删除失败")
- // }
- // }
- //}
- // @Title 审核数字签名
- // @Description 审核数字签名
- // @Success 200 {object} controllers.Request
- // @router /signature [put]
- func (this *CreateReportController) Signature() {
- var reportmodel limscreatereport.LimsCreateReport
- var jsonblob = this.Ctx.Input.RequestBody
- var dataother limscreatereport.ShenheModel
- json.Unmarshal(jsonblob, &dataother)
- //审核成功
- if dataother.SuccessStatus == 1 {
- //循环选中的审核列表
- for i := 0; i < len(dataother.ApplyList); i++ {
- //通过模板Id查模板表
- svc := limscreatereport.GetCreateReportService(utils.DBE)
- var templateentity limsdoctemplate.LimsDocTemplate
- svc.GetEntityByIdBytbl(this.User.AccCode+LimsDocTemplateName, dataother.ApplyList[i].TemplateId, &templateentity)
- _dir := "./static/limsdoc/dataentry/doc/Report_" + strconv.Itoa(dataother.ApplyList[i].Id)
- //从文件服务器下载文件到_dir
- utils.DownloadFile("http://"+dataother.ApplyList[i].ReportUrl, strconv.Itoa(dataother.ApplyList[i].Id)+".xlsx", _dir)
- xlsx, err := excelize.OpenFile(_dir + "/" + strconv.Itoa(dataother.ApplyList[i].Id) + ".xlsx")
- if err != nil {
- fmt.Println(err)
- }
- //根据不同的模板进行不同的签名操作
- switch templateentity.TemplateCode {
- //呼吸阀检测报告
- case limsdoctemplate.DAYT_ATMOSVALVE_REPORT:
- //插入审核人签名
- pictureerr := xlsx.AddPicture("sheet3", "D22", "./"+this.User.Description, "")
- if pictureerr != nil {
- fmt.Println(pictureerr)
- }
- savedir := "./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList[i].Id)
- direrr := dexist(savedir)
- if direrr == nil {
- xlsx.SaveAs("./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList[i].Id) + "/" + strconv.Itoa(dataother.ApplyList[i].Id) + ".xlsx")
- }
- //阻火器报告
- case limsdoctemplate.DAYT_BACKFIRE_REPORT:
- //插入审核人签名
- pictureerr := xlsx.AddPicture("sheet3", "E36", "./"+this.User.Description, "")
- if pictureerr != nil {
- fmt.Println(pictureerr)
- }
- savedir := "./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList[i].Id)
- direrr := dexist(savedir)
- if direrr == nil {
- xlsx.SaveAs("./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList[i].Id) + "/" + strconv.Itoa(dataother.ApplyList[i].Id) + ".xlsx")
- }
- //防雷装置报告
- case limsdoctemplate.DAYT_LIGHTPROTECT_REPORT:
- //插入审核人签名
- pictureerr := xlsx.AddPicture("sheet5", "E30", "./"+this.User.Description, "")
- if pictureerr != nil {
- fmt.Println(pictureerr)
- }
- savedir := "./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList[i].Id)
- direrr := dexist(savedir)
- if direrr == nil {
- xlsx.SaveAs("./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList[i].Id) + "/" + strconv.Itoa(dataother.ApplyList[i].Id) + ".xlsx")
- }
- //防雷装置(等电位)报告
- case limsdoctemplate.DAYT_EQUIPOTENT_REPORT:
- //插入审核人签名
- pictureerr := xlsx.AddPicture("sheet5", "E26", "./"+this.User.Description, "")
- if pictureerr != nil {
- fmt.Println(pictureerr)
- }
- savedir := "./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList[i].Id)
- direrr := dexist(savedir)
- if direrr == nil {
- xlsx.SaveAs("./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList[i].Id) + "/" + strconv.Itoa(dataother.ApplyList[i].Id) + ".xlsx")
- }
- //电气接地装置报告
- case limsdoctemplate.DAYT_ELECGROUND_REPORT:
- //插入审核人签名
- pictureerr := xlsx.AddPicture("sheet5", "E28", "./"+this.User.Description, "")
- if pictureerr != nil {
- fmt.Println(pictureerr)
- }
- savedir := "./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList[i].Id)
- direrr := dexist(savedir)
- if direrr == nil {
- xlsx.SaveAs("./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList[i].Id) + "/" + strconv.Itoa(dataother.ApplyList[i].Id) + ".xlsx")
- }
- //电流表检测报告
- case limsdoctemplate.DAYT_AMMETER_REPORT:
- //插入审核人签名
- pictureerr := xlsx.AddPicture("sheet6", "F37", "./"+this.User.Description, "")
- if pictureerr != nil {
- fmt.Println(pictureerr)
- }
- savedir := "./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList[i].Id)
- direrr := dexist(savedir)
- if direrr == nil {
- xlsx.SaveAs("./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList[i].Id) + "/" + strconv.Itoa(dataother.ApplyList[i].Id) + ".xlsx")
- }
- //空气泡沫产生器
- case limsdoctemplate.DAYT_AIRFOAMGENERATOR_REPORT:
- //插入审核人签名
- pictureerr := xlsx.AddPicture("sheet2", "D35", "./"+this.User.Description, "")
- if pictureerr != nil {
- fmt.Println(pictureerr)
- }
- savedir := "./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList[i].Id)
- direrr := dexist(savedir)
- if direrr == nil {
- xlsx.SaveAs("./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList[i].Id) + "/" + strconv.Itoa(dataother.ApplyList[i].Id) + ".xlsx")
- }
- //液压安全阀报告
- case limsdoctemplate.DAYT_HYDRAULICSAFE_REPORT:
- //插入审核人签名
- pictureerr := xlsx.AddPicture("sheet2", "E35", "./"+this.User.Description, "")
- if pictureerr != nil {
- fmt.Println(pictureerr)
- }
- savedir := "./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList[i].Id)
- direrr := dexist(savedir)
- if direrr == nil {
- xlsx.SaveAs("./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList[i].Id) + "/" + strconv.Itoa(dataother.ApplyList[i].Id) + ".xlsx")
- }
- //游梁式抽油机检测报告
- case limsdoctemplate.DAYT_NOBEAMPUMPINGUNIT_REPORT:
- //插入审核人签名
- pictureerr := xlsx.AddPicture("sheet2", "E35", "./"+this.User.Description, "")
- if pictureerr != nil {
- fmt.Println(pictureerr)
- }
- savedir := "./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList[i].Id)
- direrr := dexist(savedir)
- if direrr == nil {
- xlsx.SaveAs("./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList[i].Id) + "/" + strconv.Itoa(dataother.ApplyList[i].Id) + ".xlsx")
- }
- //漏电保护检测报告
- case limsdoctemplate.DAYT_LEAKPROTECT_REPORT:
- //插入审核人签名
- pictureerr := xlsx.AddPicture("sheet5", "F37", "./"+this.User.Description, "")
- if pictureerr != nil {
- fmt.Println(pictureerr)
- }
- savedir := "./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList[i].Id)
- direrr := dexist(savedir)
- if direrr == nil {
- xlsx.SaveAs("./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList[i].Id) + "/" + strconv.Itoa(dataother.ApplyList[i].Id) + ".xlsx")
- }
- }
- DocFilePath := "./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList[i].Id) + "/" + strconv.Itoa(dataother.ApplyList[i].Id) + ".xlsx"
- //文件保存上传文件到服务器
- var sw *Seaweed
- var filer []string
- if _filer := os.Getenv("GOSWFS_FILER_URL"); _filer != "" {
- filer = []string{_filer}
- }
- sw = NewSeaweed("http", "weed1.labsop.cn:9333", filer, 2*1024*1024, 5*time.Minute)
- _, _, fID, err := sw.UploadFile(DocFilePath, "", "")
- if err != nil {
- fmt.Println(err)
- } else {
- fmt.Println("-------Fid------", fID)
- }
- var entrustmodel limsentrust.LimsEntrustMain
- //Daddress := "http://" + utils.Cfg.MustValue("file", "downFileHost") + "/" + fID
- var entrustcols []string = []string{"ReportStatus"}
- var cols []string = []string{"ReportStatus", "ConUserId", "ConUserBy", "ConUserOn"}
- reportmodel.ReportStatus = dataother.SuccessStatus
- reportmodel.ConUserId, _ = utils.StrTo(this.User.Id).Int()
- reportmodel.ConUserBy = this.User.Realname
- reportmodel.ConUserOn = time.Now()
- entrustmodel.ReportStatus = dataother.SuccessStatus
- svc.UpdateEntityBytbl(this.User.AccCode+LimsCreateReportName, dataother.ApplyList[i].Id, reportmodel, cols)
- where := "Id= '" + strconv.Itoa(dataother.ApplyList[i].EId) + "'"
- svc.UpdateEntityBywheretbl(this.User.AccCode+LimsEntrustMainName, &entrustmodel, entrustcols, where)
- var errinfo ErrorInfo
- if err == nil {
- errinfo.Message = "审核成功!"
- errinfo.Code = 0
- this.Data["json"] = &errinfo
- this.ServeJSON()
- } else {
- errinfo.Message = "审核错误!"
- errinfo.Code = -1
- this.Data["json"] = &errinfo
- this.ServeJSON()
- }
- }
- }
- }
- /**
- * 报告生成
- */
- //func (this *CreateReportController) CreateReport(entrustId string) {
- // var reportId int64
- // var errinfo ErrorDataInfo
- // var reportUrl string
- // var seqStr string
- // var err error
- // svcReport := limscreatereport.GetCreateReportService(utils.DBE)
- // svcEntrust := limsentrust.GetLimsEnturstService(utils.DBE)
- // //获取模板的URL
- // var docTemplate limsdataentry.LimsDocTemplate
- // docTemplateList := svcEntrust.GetReportTemplateUrl(
- // this.User.AccCode+LimsEntrustMainName,
- // this.User.AccCode+TestPackageTypesName,
- // this.User.AccCode+LimsDocTemplateName,
- // entrustId)
- // if !reflect.ValueOf(docTemplateList).IsNil() && len(docTemplateList) > 0 {
- // docTemplate = docTemplateList[0]
- // } else {
- // errinfo.Message = "报告模板不存在!"
- // errinfo.Code = -1
- // errinfo.Item = reportId
- // this.Data["json"] = &errinfo
- // this.ServeJSON()
- // return
- // }
- // //获取任务委托实体
- // var entrustMains []limsentrust.LimsEntrustMain
- // var model limscreatereport.ReportTemplateModel
- // whereStr := "id='" + entrustId + "'"
- // svcEntrust.GetEntitysByWhere(this.User.AccCode+LimsEntrustMainName, whereStr, &entrustMains)
- // wheretem := "a.id='" + entrustId + "'"
- // model = svcReport.GetTemplate(this.User.AccCode+LimsEntrustMainName, this.User.AccCode+TestPackageTypesName, wheretem)
- // //生成报告文档,返回URL地址
- // reportUrl, seqStr, err = this.generateExcelReport(entrustMains[0], docTemplate, entrustId)
- // if len(reportUrl) > 0 && err == nil {
- // //生成报告数据
- // var reportEntity limscreatereport.LimsCreateReport
- // reportEntity.ReportUrl = reportUrl
- // reportEntity.EId, _ = utils.StrTo(entrustId).Int()
- // reportEntity.CreateUserId, _ = utils.StrTo(this.User.Id).Int()
- // reportEntity.CreateBy = this.User.Realname
- // reportEntity.CreateOn = time.Now()
- // //reportEntity.ConUserOn = new(time.Time)
- // //reportEntity.SignUserOn =new()
- // reportEntity.TemplateId = model.TemplateId
- // reportEntity.TemplateName = model.FullName
- // reportEntity.CustomerId = model.CustomerId
- // reportEntity.EntrustNo = model.EntrustNo
- // reportEntity.CustomerName = model.CustomerName
- // reportEntity.ReportCode = seqStr
- // reportId, err = svcReport.InsertEntityBytbl(this.User.AccCode+LimsCreateReportName, &reportEntity)
- // if err == nil {
- // errinfo.Message = "报告生成成功"
- // errinfo.Code = 0
- // errinfo.Item = reportEntity
- // this.Data["json"] = &errinfo
- // this.ServeJSON()
- // }
- // //生成工作流事件
- // /*svc := workflow.GetWorkflowService(utils.DBE)
- // userSvc := baseUser.GetBaseUserService(utils.DBE)
- // var userEntity userRole.Base_User
- // userSvc.GetEntityById(this.User.Id, &userEntity)
- // _, eventList, docID := svc.ReportDocumentCreate(
- // userEntity.Email,
- // reportEntity.TemplateName,
- // strconv.Itoa(reportEntity.Id) )
- // wfsvc := wfdocuemntevents.GetWfdocuemnteventsService(utils.DBE)
- // var wfdocuemntevents wfdocuemntevents.WFDocuemntEvents
- // wfdocuemntevents.BusType = "大港油田:报告审批"
- // wfdocuemntevents.BusId = int(reportEntity.Id)
- // wfdocuemntevents.DocumentId = int(docID)
- // wfdocuemntevents.DoceventList = eventList
- // wfdocuemntevents.CreateBy = this.User.Realname
- // wfdocuemntevents.CreateUserId = this.User.Id
- // wfdocuemntevents.CreateOn = time.Now()
- // wfsvc.InsertEntity(wfdocuemntevents)*/
- // }
- // if err != nil {
- // errinfo.Message = "报告生成失败!"
- // errinfo.Code = -1
- // this.Data["json"] = &errinfo
- // this.ServeJSON()
- // }
- //}
- /**
- * 新加的报告模板在这个方法添加
- */
- //func (this *CreateReportController) generateExcelReport(entrustMain limsentrust.LimsEntrustMain,
- // docTemplate limsdataentry.LimsDocTemplate, entrustId string) (reportUrl string, seqStr string, err error) {
- //
- // codecSvc := codecsequence.GetCodecSequenceService(utils.DBE)
- // fmt.Println("-----code---", docTemplate.TemplateCode)
- // switch docTemplate.TemplateCode {
- // //呼吸阀检测报告
- // case limsdoctemplate.DAYT_ATMOSVALVE_REPORT:
- // //获取序列号
- // seqStr = codecSvc.GetReportHuxfSequence(this.User.AccCode)
- // svc := limsreporthuxf.GetLimsReportHuxfService(utils.DBE)
- // reportUrl, err = svc.DataToExcelReport(entrustMain, this.User.AccCode+LimsReportHuxfName,this.User.AccCode+LimsSpecifyStandardName, seqStr, docTemplate.FileURL, entrustId, this.User.Description)
- // //阻火器报告
- // case limsdoctemplate.DAYT_BACKFIRE_REPORT:
- // seqStr = codecSvc.GetReportZuhqSequence(this.User.AccCode)
- // svc := Limsreportzuhq.GetLimsreportzuhqService(utils.DBE)
- // reportUrl, err = svc.DataToExcelReport(entrustMain, this.User.AccCode+LimsReportZuhqName, this.User.AccCode+LimsPressureLeakName,this.User.AccCode+LimsSpecifyStandardName, seqStr, docTemplate.FileURL, entrustId, this.User.Description)
- // //防雷装置报告
- // //case limsdoctemplate.DAYT_LIGHTPROTECT_REPORT:
- // // seqStr = codecSvc.GetReportLightProtectSequence(this.User.AccCode)
- // // svc := limsreportlp.GetLimsReportLpService(utils.DBE)
- // // reportUrl, err = svc.DataToExcelReport(entrustMain, this.User.AccCode+LimsReportLightProtectName, seqStr, docTemplate.FileURL, entrustId, this.User.Description)
- //
- // //防雷装置(等电位)报告
- // case limsdoctemplate.DAYT_EQUIPOTENT_REPORT:
- // seqStr = codecSvc.GetReportEquipotentSequence(this.User.AccCode)
- // svc := limsreportequipotent.GetLimsReportEquipotentService(utils.DBE)
- // reportUrl, err = svc.DataToExcelReport(entrustMain, this.User.AccCode+LimsReportEquipotentName, seqStr, docTemplate.FileURL, entrustId, this.User.Description)
- //
- // //电气接地装置报告
- // case limsdoctemplate.DAYT_ELECGROUND_REPORT:
- // seqStr = codecSvc.GetReportElecGroundSequence(this.User.AccCode)
- // svc := limsreportelecground.GetLimsReportElecGroundService(utils.DBE)
- // reportUrl, err = svc.DataToExcelReport(entrustMain, this.User.AccCode+LimsReportElecGroundName, seqStr, docTemplate.FileURL, entrustId, this.User.Description)
- //
- // //电流表检测报告
- // case limsdoctemplate.DAYT_AMMETER_REPORT:
- // seqStr = codecSvc.GetReportAmmeterSequence(this.User.AccCode)
- // svc := limsreportammeter.GetLimsReportAmmeterService(utils.DBE)
- // reportUrl, err = svc.DataToExcelReport(entrustMain, this.User.AccCode+LimsReportAmmeterName, seqStr, docTemplate.FileURL, entrustId, this.User.Description)
- //
- // //空气泡沫产生器
- // case limsdoctemplate.DAYT_AIRFOAMGENERATOR_REPORT:
- // seqStr = codecSvc.GetReportKqpmSequence(this.User.AccCode)
- // svc := limsreportkqpm.GetLimsReportkqpmService(utils.DBE)
- // reportUrl, err = svc.DataToExcelReport(entrustMain, this.User.AccCode+LimsReportKqpmName, seqStr, docTemplate.FileURL, entrustId, this.User.Description)
- // //液压安全阀报告
- // case limsdoctemplate.DAYT_HYDRAULICSAFE_REPORT:
- // seqStr = codecSvc.GetReportYyaqfSequence(this.User.AccCode)
- // svc := limsreportyyaqf.GetLimsReportYyaqfService(utils.DBE)
- // reportUrl, err = svc.DataToExcelReport(entrustMain, this.User.AccCode+LimsReportYeyaqfName,this.User.AccCode+LimsSpecifyStandardName, seqStr, docTemplate.FileURL, entrustId, this.User.Description)
- // //游梁式抽油机检测报告
- // case limsdoctemplate.DAYT_BEAMPUMPINGUNIT_REPORT:
- // seqStr = codecSvc.GetReportBeamPumpingUnitsSequence(this.User.AccCode)
- // svc := limsreportbeampumpingunits.GetLimsReportBeamPumpingUnitsService(utils.DBE)
- // reportUrl, err = svc.DataToExcelReport(entrustMain, this.User.AccCode+LimsReportBeamPumpingUnitName, seqStr, docTemplate.FileURL, entrustId, this.User.Description)
- //
- // //漏电保护检测报告
- // case limsdoctemplate.DAYT_LEAKPROTECT_REPORT:
- // seqStr = codecSvc.GetReportLeakProtectSequence(this.User.AccCode)
- // svc := limsreportldbh.GetLimsReportldbhService(utils.DBE)
- // reportUrl, err = svc.DataToExcelReport(entrustMain, this.User.AccCode+LimsReportLeakProtectName, seqStr, docTemplate.FileURL, entrustId, this.User.Description)
- //
- // //无游梁式抽油机检测报告
- // case limsdoctemplate.DAYT_NOBEAMPUMPINGUNIT_REPORT:
- // seqStr = codecSvc.GetReportNoBeamPumpingUnitsSequence(this.User.AccCode)
- // svc := limsreportnobeampumpingunits.GetLimsReportNoBeamPumpingUnitsService(utils.DBE)
- // reportUrl, err = svc.DataToExcelReport(entrustMain, this.User.AccCode+LimsReportNoBeamPumpingUnitName, seqStr, docTemplate.FileURL, entrustId, this.User.Description)
- // }
- // return reportUrl, seqStr, err
- //}
- //文件是否存在判断
- func dexist(_dir string) error {
- //判断是否已经有文件路径
- exist, patherr := utils.PathExists(_dir)
- if patherr != nil {
- fmt.Println(patherr)
- }
- var dirErr error
- if !exist {
- // 创建文件夹
- dirErr = os.Mkdir(_dir, os.ModePerm)
- }
- return dirErr
- }
- // @Title 签发数字签名
- // @Description 签发数字签名
- // @Success 200 {object} controllers.Request
- // @router /signtrans [put]
- func (this *CreateReportController) SignTrans() {
- var reportmodel limscreatereport.LimsCreateReport
- var jsonblob = this.Ctx.Input.RequestBody
- var dataother limscreatereport.QianfaModel
- json.Unmarshal(jsonblob, &dataother)
- //审核成功
- if dataother.SuccessStatus == 2 {
- //通过模板Id查模板表
- svc := limscreatereport.GetCreateReportService(utils.DBE)
- var templateentity limsdoctemplate.LimsDocTemplate
- svc.GetEntityByIdBytbl(this.User.AccCode+LimsDocTemplateName, dataother.ApplyList.TemplateId, &templateentity)
- _dir := "./static/limsdoc/dataentry/doc/Report_" + strconv.Itoa(dataother.ApplyList.Id)
- //从文件服务器下载文件到_dir
- utils.DownloadFile("http://"+dataother.ApplyList.ReportUrl, strconv.Itoa(dataother.ApplyList.Id)+".xlsx", _dir)
- xlsx, err := excelize.OpenFile(_dir + "/" + strconv.Itoa(dataother.ApplyList.Id) + ".xlsx")
- if err != nil {
- fmt.Println(err)
- }
- //根据不同的模板进行不同的签名操作
- switch templateentity.TemplateCode {
- //呼吸阀检测报告
- case limsdoctemplate.DAYT_ATMOSVALVE_REPORT:
- //插入审核人签名
- pictureerr := xlsx.AddPicture("sheet3", "D22", "./"+this.User.Description, "")
- if pictureerr != nil {
- fmt.Println(pictureerr)
- }
- savedir := "./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList.Id)
- direrr := dexist(savedir)
- if direrr == nil {
- xlsx.SaveAs("./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList.Id) + "/" + strconv.Itoa(dataother.ApplyList.Id) + ".xlsx")
- }
- //阻火器报告
- case limsdoctemplate.DAYT_BACKFIRE_REPORT:
- //插入批准人签名
- pictureerr := xlsx.AddPicture("sheet3", "E36", "./"+this.User.Description, "")
- if pictureerr != nil {
- fmt.Println(pictureerr)
- }
- savedir := "./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList.Id)
- direrr := dexist(savedir)
- if direrr == nil {
- xlsx.SaveAs("./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList.Id) + "/" + strconv.Itoa(dataother.ApplyList.Id) + ".xlsx")
- }
- //防雷装置报告
- case limsdoctemplate.DAYT_LIGHTPROTECT_REPORT:
- //插入批准人签名
- pictureerr := xlsx.AddPicture("sheet5", "E30", "./"+this.User.Description, "")
- if pictureerr != nil {
- fmt.Println(pictureerr)
- }
- savedir := "./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList.Id)
- direrr := dexist(savedir)
- if direrr == nil {
- xlsx.SaveAs("./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList.Id) + "/" + strconv.Itoa(dataother.ApplyList.Id) + ".xlsx")
- }
- //防雷装置(等电位)报告
- case limsdoctemplate.DAYT_EQUIPOTENT_REPORT:
- //插入批准人签名
- pictureerr := xlsx.AddPicture("sheet5", "E26", "./"+this.User.Description, "")
- if pictureerr != nil {
- fmt.Println(pictureerr)
- }
- savedir := "./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList.Id)
- direrr := dexist(savedir)
- if direrr == nil {
- xlsx.SaveAs("./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList.Id) + "/" + strconv.Itoa(dataother.ApplyList.Id) + ".xlsx")
- }
- //电气接地装置报告
- case limsdoctemplate.DAYT_ELECGROUND_REPORT:
- //插入批准人签名
- pictureerr := xlsx.AddPicture("sheet5", "E28", "./"+this.User.Description, "")
- if pictureerr != nil {
- fmt.Println(pictureerr)
- }
- savedir := "./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList.Id)
- direrr := dexist(savedir)
- if direrr == nil {
- xlsx.SaveAs("./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList.Id) + "/" + strconv.Itoa(dataother.ApplyList.Id) + ".xlsx")
- }
- //电流表检测报告
- case limsdoctemplate.DAYT_AMMETER_REPORT:
- //插入批准人签名
- pictureerr := xlsx.AddPicture("sheet6", "F37", "./"+this.User.Description, "")
- if pictureerr != nil {
- fmt.Println(pictureerr)
- }
- savedir := "./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList.Id)
- direrr := dexist(savedir)
- if direrr == nil {
- xlsx.SaveAs("./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList.Id) + "/" + strconv.Itoa(dataother.ApplyList.Id) + ".xlsx")
- }
- //空气泡沫产生器
- case limsdoctemplate.DAYT_AIRFOAMGENERATOR_REPORT:
- //插入批准人签名
- pictureerr := xlsx.AddPicture("sheet2", "D35", "./"+this.User.Description, "")
- if pictureerr != nil {
- fmt.Println(pictureerr)
- }
- savedir := "./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList.Id)
- direrr := dexist(savedir)
- if direrr == nil {
- xlsx.SaveAs("./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList.Id) + "/" + strconv.Itoa(dataother.ApplyList.Id) + ".xlsx")
- }
- //液压安全阀报告
- case limsdoctemplate.DAYT_HYDRAULICSAFE_REPORT:
- //插入批准人签名
- pictureerr := xlsx.AddPicture("sheet2", "E35", "./"+this.User.Description, "")
- if pictureerr != nil {
- fmt.Println(pictureerr)
- }
- savedir := "./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList.Id)
- direrr := dexist(savedir)
- if direrr == nil {
- xlsx.SaveAs("./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList.Id) + "/" + strconv.Itoa(dataother.ApplyList.Id) + ".xlsx")
- }
- //游梁式抽油机检测报告
- case limsdoctemplate.DAYT_NOBEAMPUMPINGUNIT_REPORT:
- //插入批准人签名
- pictureerr := xlsx.AddPicture("sheet2", "E35", "./"+this.User.Description, "")
- if pictureerr != nil {
- fmt.Println(pictureerr)
- }
- savedir := "./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList.Id)
- direrr := dexist(savedir)
- if direrr == nil {
- xlsx.SaveAs("./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList.Id) + "/" + strconv.Itoa(dataother.ApplyList.Id) + ".xlsx")
- }
- //漏电保护检测报告
- case limsdoctemplate.DAYT_LEAKPROTECT_REPORT:
- //插入批准人签名
- pictureerr := xlsx.AddPicture("sheet5", "C37", "./"+this.User.Description, "")
- if pictureerr != nil {
- fmt.Println(pictureerr)
- }
- savedir := "./static/limsdoc/dataentry/doc/SignReport_" + strconv.Itoa(dataother.ApplyList.Id)
- direrr := dexist(savedir)
- if direrr == nil {
- xlsx.SaveAs("./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList.Id) + "/" + strconv.Itoa(dataother.ApplyList.Id) + ".xlsx")
- }
- }
- DocFilePath := "./static/limsdoc/dataentry/doc/LastReport_" + strconv.Itoa(dataother.ApplyList.Id) + "/" + strconv.Itoa(dataother.ApplyList.Id) + ".xlsx"
- //文件保存上传文件到服务器
- var sw *Seaweed
- var filer []string
- if _filer := os.Getenv("GOSWFS_FILER_URL"); _filer != "" {
- filer = []string{_filer}
- }
- sw = NewSeaweed("http", "weed1.labsop.cn:9333", filer, 2*1024*1024, 5*time.Minute)
- _, _, fID, err := sw.UploadFile(DocFilePath, "", "")
- if err != nil {
- fmt.Println(err)
- } else {
- fmt.Println("-------Fid------", fID)
- }
- var entrustmodel limsentrust.LimsEntrustMain
- var signmodel limscreatereport.LimsReportSign
- Daddress := utils.Cfg.MustValue("file", "downFileHost") + "/" + fID
- var entrustcols []string = []string{"ReportStatus"}
- var cols []string = []string{"ReportStatus", "ReportUrl", "SignUserId", "SignUserBy", "SignUserOn"}
- reportmodel.ReportStatus = dataother.SuccessStatus
- reportmodel.ReportUrl = Daddress
- reportmodel.SignUserId, _ = utils.StrTo(this.User.Id).Int()
- reportmodel.SignUserBy = this.User.Realname
- reportmodel.SignUserOn = time.Now()
- entrustmodel.ReportStatus = dataother.SuccessStatus
- signmodel.ReportStatus = dataother.SuccessStatus
- signmodel.ReportId = dataother.ApplyList.Id
- signmodel.ReportName = dataother.ApplyList.ReportName
- signmodel.SignTrans = dataother.ApplyList.SignTrans
- signmodel.ReceiveBy = dataother.ApplyList.ReceiveBy
- signmodel.Remark = dataother.AuditorRemark
- signmodel.TransTime = dataother.ApplyList.TransTime
- signmodel.CreateUserId, _ = utils.StrTo(this.User.Id).Int()
- signmodel.CreateBy = this.User.Realname
- signmodel.CreateOn = time.Now()
- svc.UpdateEntityBytbl(this.User.AccCode+LimsCreateReportName, dataother.ApplyList.Id, reportmodel, cols)
- where := "Id= '" + strconv.Itoa(dataother.ApplyList.EId) + "'"
- svc.UpdateEntityBywheretbl(this.User.AccCode+LimsEntrustMainName, &entrustmodel, entrustcols, where)
- _, err = svc.InsertEntityBytbl(this.User.AccCode+LimsReportSignName, &signmodel)
- var errinfo ErrorInfo
- if err == nil {
- errinfo.Message = "发送成功!"
- errinfo.Code = 0
- this.Data["json"] = &errinfo
- this.ServeJSON()
- } else {
- errinfo.Message = "发送错误!"
- errinfo.Code = -1
- this.Data["json"] = &errinfo
- this.ServeJSON()
- }
- }
- }
- // @Title 审核
- // @Description 审核
- // @Success 200 {object} controllers.Request
- // @router /reportnumcheck/ [put]
- func (this *CreateReportController) ShenHeReportCheck() {
- svc := limsdataentry.GetLimsDataEntryService(utils.DBE)
- var jsonblob= this.Ctx.Input.RequestBody
- var dataother ShenHeModel
- var errinfo ErrorInfo
- json.Unmarshal(jsonblob, &dataother)
- var list []limscreatereport.LimsCreateReport
- where := " Id = '" + strconv.Itoa(dataother.ReportId) + "'"
- svc.GetEntitysByWhere(this.User.AccCode+LimsCreateReportName, where, &list)
- var reportlistall []limscreatereport.LimsCreateReport
- svc.GetEntitysByWhere(this.User.AccCode+LimsCreateReportName," EId=" + utils.ToStr(list[0].EId) + "",&reportlistall)
- if len(reportlistall)>1{
- errinfo.Message = "确认报告审核不通过?"
- errinfo.Code = 0
- this.Data["json"] = &errinfo
- this.ServeJSON()
- }
- }
- // @Title 审核
- // @Description 审核
- // @Success 200 {object} controllers.Request
- // @router /shenhereport/ [put]
- func (this *CreateReportController) ShenHeReport() {
- svc := limsdataentry.GetLimsDataEntryService(utils.DBE)
- var jsonblob = this.Ctx.Input.RequestBody
- var dataother ShenHeModel
- json.Unmarshal(jsonblob, &dataother)
- var list []limscreatereport.LimsCreateReport
- var users []userRole.Base_RoleList
- //审核状态判断进行的操作
- if dataother.SuccessStatus == 1 {
- where := " Id = '" + strconv.Itoa(dataother.ReportId) + "'"
- svc.GetEntitysByWhere(this.User.AccCode+LimsCreateReportName, where, &list)
- var entityempty limscreatereport.LimsCreateReport
- var errinfo ErrorInfo
- var cols []string = []string{"ReportStatus", "ConUserOn", "ConUserId", "ConUserBy", "CheckRemark"}
- entityempty.ReportStatus = dataother.SuccessStatus
- entityempty.ConUserOn = time.Now()
- entityempty.ConUserId, _ = utils.StrTo(this.User.Id).Int()
- entityempty.ConUserBy = this.User.Realname
- entityempty.CheckRemark = dataother.AuditorRemark
- //提交审核工作流
- svcActiviti := workflow.GetActivitiService(utils.DBE)
- var receiveVal string
- var RoleSet auditsetting.Base_OilAuditSetting
- rsvc := auditsetting.GetOilAuditSettingService(utils.DBE)
- rsvc.GetAuditStepRoleEntity(OilAuditSettingName,this.User.DepartmentId,workflow.REPORTISSUE, &RoleSet)
- users = svc.GetUserByRole(strconv.Itoa(RoleSet.RoleId), this.User.AccCode)
- var userIds string
- for _, tmpUser := range users {
- userIds += strconv.FormatInt(tmpUser.Id, 10) + ","
- }
- userIds = strings.Trim(userIds, ",")
- receiveVal = svcActiviti.TaskComplete(RoleSet.WorkFlowCord, strconv.Itoa(dataother.ReportId), userIds, this.User.Id, "1", dataother.AuditorRemark)
- if receiveVal == "true" {
- err := svc.UpdateEntityBytbl(this.User.AccCode+LimsCreateReportName, list[0].Id, entityempty, cols)
- if err == nil {
- errinfo.Message = "通过审核!"
- errinfo.Code = 0
- this.Data["json"] = &errinfo
- this.ServeJSON()
- } else {
- errinfo.Message = "审核错误!"
- errinfo.Code = -1
- this.Data["json"] = &errinfo
- this.ServeJSON()
- }
- } else {
- errinfo.Message = "工作流异常,请联系管理员!"
- errinfo.Code = -1
- this.Data["json"] = &errinfo
- this.ServeJSON()
- return
- }
- } else {
- var errinfo ErrorInfo
- where := " Id = '" + strconv.Itoa(dataother.ReportId) + "'"
- svc.GetEntitysByWhere(this.User.AccCode+LimsCreateReportName, where, &list)
- var reportlistall []limscreatereport.LimsCreateReport
- svc.GetEntitysByWhere(this.User.AccCode+LimsCreateReportName," EId=" + utils.ToStr(list[0].EId) + "",&reportlistall)
- var entityempty limscreatereport.LimsCreateReport
- entityempty.ReportStatus = dataother.SuccessStatus
- entityempty.ConUserOn = time.Now()
- entityempty.ConUserId, _ = utils.StrTo(this.User.Id).Int()
- entityempty.ConUserBy = this.User.Realname
- entityempty.CheckRemark = dataother.AuditorRemark
- var cols []string = []string{"ReportStatus", "ConUserOn", "ConUserId", "ConUserBy", "CheckRemark"}
- //提交审核工作流
- svcActiviti := workflow.GetActivitiService(utils.DBE)
- var receiveVal string
- var RoleSet auditsetting.Base_OilAuditSetting
- rsvc := auditsetting.GetOilAuditSettingService(utils.DBE)
- rsvc.GetAuditStepRoleEntity(OilAuditSettingName,this.User.DepartmentId,workflow.REPORTISSUE, &RoleSet)
- for j:=0;j<len(reportlistall);j++{
- receiveVal = svcActiviti.TaskComplete(RoleSet.WorkFlowCord, strconv.Itoa(reportlistall[j].Id), strconv.Itoa(reportlistall[j].CreateUserId), this.User.Id, "0", dataother.AuditorRemark)
- if receiveVal == "true" {
- for i:=0;i<len(reportlistall);i++{
- err := svc.UpdateEntityBytbl(this.User.AccCode+LimsCreateReportName, reportlistall[i].Id, entityempty, cols)
- if err == nil {
- errinfo.Message = "未通过审核!"
- errinfo.Code = 0
- this.Data["json"] = &errinfo
- this.ServeJSON()
- } else {
- errinfo.Message = "审核错误!"
- errinfo.Code = -1
- this.Data["json"] = &errinfo
- this.ServeJSON()
- }
- }
- } else {
- errinfo.Message = "工作流异常,请联系管理员!"
- errinfo.Code = -1
- this.Data["json"] = &errinfo
- this.ServeJSON()
- return
- }
- }
- var balanceentity limsbalance.LimsTaskBalance
- var dataentryentity []limsdataentry.LimsDateEntry
- var balanceentityempty limsbalance.LimsTaskBalance
- var dataentryentityempty limsdataentry.LimsDateEntry
- svc.GetEntityByWhere(this.User.AccCode+LimsTaskBalanceName," EId=" + utils.ToStr(list[0].EId) + "",&balanceentity)
- var balancecols []string = []string{"DataEntryStatus"}
- balanceentityempty.DataEntryStatus = 0
- err := svc.UpdateEntityBytbl(this.User.AccCode+LimsTaskBalanceName, balanceentity.Id, balanceentityempty, balancecols)
- fmt.Println(err)
- svc.GetEntitysByWhere(this.User.AccCode+LimsDateEntryName," EId=" + utils.ToStr(list[0].EId) + "",&dataentryentity)
- for i:=0; i<len(dataentryentity) ;i++ {
- var dataentrycols []string = []string{"CheckStatus","DocKey"}
- dataentryentityempty.CheckStatus = 0
- dataentryentityempty.CreateOn=time.Now()
- //启动数据录入工作流
- svcActiviti := workflow.GetActivitiService(utils.DBE)
- var processInstanceId string
- processInstanceId=svcActiviti.StartProcess(RoleSet.WorkFlowCord, strconv.Itoa(dataentryentity[i].Id), strconv.Itoa(dataentryentity[i].CheckUserId))
- dataentryentityempty.DocKey=processInstanceId
- svc.UpdateEntityBytbl(this.User.AccCode+LimsDateEntryName, dataentryentity[i].Id, dataentryentityempty, dataentrycols)
- }
- }
- }
- // @Title 签发
- // @Description 签发
- // @Success 200 {object} controllers.Request
- // @router /qianfareport/ [put]
- func (this *CreateReportController) QianfaReport() {
- svc := limsdataentry.GetLimsDataEntryService(utils.DBE)
- var jsonblob = this.Ctx.Input.RequestBody
- var dataother ShenHeModel
- json.Unmarshal(jsonblob, &dataother)
- var list []limscreatereport.LimsCreateReport
- var RoleSet auditsetting.Base_OilAuditSetting
- rsvc := auditsetting.GetOilAuditSettingService(utils.DBE)
- rsvc.GetAuditStepRoleEntity(OilAuditSettingName,this.User.DepartmentId,workflow.REPORTISSUE, &RoleSet)
- //审核状态判断进行的操作
- if dataother.SuccessStatus == 3 {
- where := " Id = '" + strconv.Itoa(dataother.ReportId) + "'"
- svc.GetEntitysByWhere(this.User.AccCode+LimsCreateReportName, where, &list)
- var entityempty limscreatereport.LimsCreateReport
- var errinfo ErrorInfo
- var cols []string = []string{"ReportStatus", "SignUserOn", "SignUserId", "SignUserBy", "SignRemark"}
- entityempty.ReportStatus = dataother.SuccessStatus
- entityempty.SignUserOn = time.Now()
- entityempty.SignUserId, _ = utils.StrTo(this.User.Id).Int()
- entityempty.SignUserBy = this.User.Realname
- entityempty.SignRemark = dataother.AuditorRemark
- //提交审核工作流
- svcActiviti := workflow.GetActivitiService(utils.DBE)
- var receiveVal string
- receiveVal = svcActiviti.TaskComplete(RoleSet.WorkFlowCord, strconv.Itoa(dataother.ReportId), "", this.User.Id, "1", dataother.AuditorRemark)
- if receiveVal == "true" {
- err := svc.UpdateEntityBytbl(this.User.AccCode+LimsCreateReportName, list[0].Id, entityempty, cols)
- if err == nil {
- errinfo.Message = "签发成功!"
- errinfo.Code = 0
- this.Data["json"] = &errinfo
- this.ServeJSON()
- } else {
- errinfo.Message = "签发错误!"
- errinfo.Code = -1
- this.Data["json"] = &errinfo
- this.ServeJSON()
- }
- } else {
- errinfo.Message = "工作流异常,请联系管理员!"
- errinfo.Code = -1
- this.Data["json"] = &errinfo
- this.ServeJSON()
- return
- }
- } else {
- where := " Id = '" + strconv.Itoa(dataother.ReportId) + "'"
- svc.GetEntitysByWhere(this.User.AccCode+LimsCreateReportName, where, &list)
- var entityempty limscreatereport.LimsCreateReport
- var errinfo ErrorInfo
- entityempty.ReportStatus = dataother.SuccessStatus
- entityempty.SignUserOn = time.Now()
- entityempty.SignUserId, _ = utils.StrTo(this.User.Id).Int()
- entityempty.SignUserBy = this.User.Realname
- entityempty.SignRemark = dataother.AuditorRemark
- var cols []string = []string{"ReportStatus", "SignUserOn", "SignUserId", "SignUserBy", "SignRemark"}
- //提交审核工作流
- svcActiviti := workflow.GetActivitiService(utils.DBE)
- var receiveVal string
- receiveVal = svcActiviti.TaskComplete(RoleSet.WorkFlowCord, strconv.Itoa(dataother.ReportId), strconv.Itoa(list[0].CreateUserId), this.User.Id, "0", dataother.AuditorRemark)
- if receiveVal == "true" {
- err := svc.UpdateEntityBytbl(this.User.AccCode+LimsCreateReportName, list[0].Id, entityempty, cols)
- if err == nil {
- errinfo.Message = "签发未通过!"
- errinfo.Code = 0
- this.Data["json"] = &errinfo
- this.ServeJSON()
- } else {
- errinfo.Message = "签发错误!"
- errinfo.Code = -1
- this.Data["json"] = &errinfo
- this.ServeJSON()
- }
- } else {
- errinfo.Message = "工作流异常,请联系管理员!"
- errinfo.Code = -1
- this.Data["json"] = &errinfo
- this.ServeJSON()
- return
- }
- }
- }
- // @Title 报告修改回调
- // @Description 报告修改回调
- // @Success 200 {object} controllers.Request
- // @router /reporteditcallback [post]
- func (this *CreateReportController) ReportEditCallback() {
- var callback ReportCallback
- var jsonblob = this.Ctx.Input.RequestBody
- json.Unmarshal(jsonblob, &callback)
- fmt.Println("------reportcallback---", callback)
- currentTime := time.Now().Format("060102150405") //当前时间
- svc := limscreatereport.GetCreateReportService(utils.DBE)
- var list []limscreatereport.LimsCreateReport
- //dataentryid, _ := utils.StrTo(callback.Id).Int()
- where := "Id= '" + callback.Id + "'"
- svc.GetEntitysByWhere(this.User.AccCode+LimsCreateReportName, where, &list)
- //生成文档历史表
- var historylist []limscreatereport.LimsReportHistory
- where2 := "ParentId= '" + callback.Id + "'"
- svc.GetEntitysByOrderbyWhere(this.User.AccCode+LimsReportHistoryName, where2, " SaveTime asc ", &historylist)
- var historyentity limscreatereport.LimsReportHistory
- historyentity.ParentId, _ = utils.StrTo(callback.Id).Int()
- historyentity.SaveTime = time.Now()
- historyentity.CreateOn = time.Now()
- historyentity.Version = "v" + currentTime
- historyentity.CreateUserId, _ = utils.StrTo(this.User.Id).Int()
- historyentity.CreateBy = this.User.Realname
- historyentity.ModifiedUserId, _ = utils.StrTo(this.User.Id).Int()
- historyentity.ModifiedBy = this.User.Realname
- historyentity.Address = "http://" + callback.DocUrl
- if len(historylist) >= 4 {
- //删除历史数据
- where3 := " Version = '" + historylist[0].Version + "'"
- delerr := svc.DeleteEntityBytbl(this.User.AccCode+LimsReportHistoryName, where3)
- if delerr != nil {
- fmt.Println(delerr)
- }
- deldoc := os.Remove("././static/limsdoc/dataentry/doc" + historylist[0].Address)
- if deldoc != nil {
- fmt.Println(deldoc)
- }
- svc.InsertEntityBytbl(this.User.AccCode+LimsReportHistoryName, &historyentity)
- } else {
- svc.InsertEntityBytbl(this.User.AccCode+LimsReportHistoryName, &historyentity)
- }
- }
- // @Title 报告删除回到数据录入初始状态
- // @Description
- // @Success 200 {object} ErrorInfo
- // @Failure 403 :id 为空
- // @router /reportdelect/:Id [delete]
- func (this *CreateReportController) DelReport() {
- Id := this.Ctx.Input.Param(":Id")
- var errinfo ErrorInfo
- svc := limscreatereport.GetCreateReportService(utils.DBE)
- if Id == "" {
- errinfo.Message = "操作失败!请求信息不完整"
- errinfo.Code = -2
- this.Data["json"] = &errinfo
- this.ServeJSON()
- return
- }
- var reportlist []limscreatereport.LimsCreateReport
- where := " Id= " + Id
- svc.GetEntitysByWhere(this.User.AccCode+LimsCreateReportName, where, &reportlist)
- //修改数据录入状态
- for i := 0; i < len(reportlist); i++ {
- var dataentrymodel limsdataentry.LimsDateEntry
- dataentrymodel.CreateReportStatus = 0
- dataentrymodel.CheckStatus = 0
- dawhere := " EId = '" + utils.ToStr(reportlist[i].EId) + "'"
- svc.UpdateEntityBywheretbl(this.User.AccCode+LimsDateEntryName, &dataentrymodel, []string{"CreateReportStatus", "CheckStatus"}, dawhere)
- }
- //修改balance表
- var balancemodel limsbalance.LimsTaskBalance
- balancemodel.DataEntryStatus = 0
- bawhere := " EId = '" + utils.ToStr(reportlist[0].EId) + "'"
- svc.UpdateEntityBywheretbl(this.User.AccCode+LimsTaskBalanceName, &balancemodel, []string{"DataEntryStatus"}, bawhere)
- //删除报告表数据
- err := svc.DeleteEntityBytbl(this.User.AccCode+LimsCreateReportName, where)
- if err == nil {
- //提交审核工作流
- svcActiviti := workflow.GetActivitiService(utils.DBE)
- var receiveVal string
- var RoleSet auditsetting.Base_OilAuditSetting
- rsvc := auditsetting.GetOilAuditSettingService(utils.DBE)
- rsvc.GetAuditStepRoleEntity(OilAuditSettingName,this.User.DepartmentId,workflow.REPORTISSUE, &RoleSet)
- receiveVal = svcActiviti.TaskComplete(RoleSet.WorkFlowCord, Id, "", this.User.Id, "0", "特检删除报告")
- if receiveVal == "true" {
- errinfo.Message = "删除成功"
- errinfo.Code = 0
- this.Data["json"] = &errinfo
- this.ServeJSON()
- } else {
- errinfo.Message = "工作流异常,请联系管理员!"
- errinfo.Code = -1
- this.Data["json"] = &errinfo
- this.ServeJSON()
- return
- }
-
- } else {
- errinfo.Message = "删除失败!" + utils.AlertProcess(err.Error())
- errinfo.Code = -1
- this.Data["json"] = &errinfo
- this.ServeJSON()
- }
- }
|