|
|
@@ -0,0 +1,409 @@
|
|
|
+package oilsupplier
|
|
|
+
|
|
|
+import (
|
|
|
+ "dashoo.cn/backend/api/business/oilsupplier/qualchange"
|
|
|
+ "encoding/json"
|
|
|
+ "strings"
|
|
|
+ "time"
|
|
|
+
|
|
|
+ "dashoo.cn/backend/api/business/oilsupplier/annualaudit"
|
|
|
+ "dashoo.cn/backend/api/business/oilsupplier/supplier"
|
|
|
+ "dashoo.cn/backend/api/business/workflow"
|
|
|
+
|
|
|
+ "dashoo.cn/backend/api/business/baseUser"
|
|
|
+ "dashoo.cn/business/userRole"
|
|
|
+
|
|
|
+ . "dashoo.cn/backend/api/controllers"
|
|
|
+ "dashoo.cn/utils"
|
|
|
+)
|
|
|
+
|
|
|
+type QualChangeController struct {
|
|
|
+ BaseController
|
|
|
+}
|
|
|
+
|
|
|
+// @Title 获取列表
|
|
|
+// @Description get user by token
|
|
|
+// @Success 200 {object} []supplier.OilSupplierView
|
|
|
+// @router /list [get]
|
|
|
+func (this *QualChangeController) GetEntityList() {
|
|
|
+
|
|
|
+ //获取分页信息
|
|
|
+ page := this.GetPageInfoForm()
|
|
|
+ where := " b.Status >= 7 "
|
|
|
+ orderby := "a.CreateOn desc"
|
|
|
+ Order := this.GetString("Order")
|
|
|
+ Prop := this.GetString("Prop")
|
|
|
+ if Order != "" && Prop != "" {
|
|
|
+ orderby = Prop + " " + Order
|
|
|
+ }
|
|
|
+ CommercialNo := this.GetString("CommercialNo")
|
|
|
+ AccessCardNo := this.GetString("AccessCardNo")
|
|
|
+ SupplierName := this.GetString("SupplierName")
|
|
|
+ CreateOn := this.GetString("CreateOn")
|
|
|
+
|
|
|
+
|
|
|
+ if CommercialNo != "" {
|
|
|
+ where = where + " and a.CommercialNo like '%" + CommercialNo + "%'"
|
|
|
+ }
|
|
|
+
|
|
|
+ if AccessCardNo != "" {
|
|
|
+ where = where + " and b.AccessCardNo like '%" + AccessCardNo + "%'"
|
|
|
+ }
|
|
|
+
|
|
|
+ if SupplierName != "" {
|
|
|
+ where = where + " and a.SupplierName like '%" + SupplierName + "%'"
|
|
|
+ }
|
|
|
+
|
|
|
+ if CreateOn != "" {
|
|
|
+ dates := strings.Split(CreateOn, ",")
|
|
|
+ if len(dates) == 2 {
|
|
|
+ minDate := dates[0]
|
|
|
+ maxDate := dates[1]
|
|
|
+ where = where + " and a.CreateOn>='" + minDate + "' and a.CreateOn<='" + maxDate + "'"
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ svc := qualchange.GetQualChangeService(utils.DBE)
|
|
|
+ var list []supplier.OilSupplierView
|
|
|
+ total, list:= svc.GetQualPagingEntitiesWithOrderBytbl(OilSupplierName, OilSupplierCertName, OilSupplierFileName, orderby, where, page.CurrentPage, page.Size)
|
|
|
+ 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 get user by token
|
|
|
+// @Success 200 {object} []annualaudit.OilAnnualAudit
|
|
|
+// @router /mytasks [get]
|
|
|
+func (this *QualChangeController) GetMyTaskEntityList() {
|
|
|
+
|
|
|
+ //获取分页信息
|
|
|
+ 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
|
|
|
+ }
|
|
|
+ }
|
|
|
+ SupplierTypeName := this.GetString("SupplierTypeName")
|
|
|
+ RecUnitId := this.GetString("RecUnitId")
|
|
|
+ AccessCardNo := this.GetString("AccessCardNo")
|
|
|
+ SupplierName := this.GetString("SupplierName")
|
|
|
+ CreateOn := this.GetString("CreateOn")
|
|
|
+
|
|
|
+ if SupplierTypeName != "" {
|
|
|
+ where = where + " and SupplierTypeName like '%" + SupplierTypeName + "%'"
|
|
|
+ }
|
|
|
+
|
|
|
+ if RecUnitId != "" {
|
|
|
+ where = where + " and RecUnitId like '%" + RecUnitId + "%'"
|
|
|
+ }
|
|
|
+
|
|
|
+ if AccessCardNo != "" {
|
|
|
+ where = where + " and AccessCardNo like '%" + AccessCardNo + "%'"
|
|
|
+ }
|
|
|
+
|
|
|
+ if SupplierName != "" {
|
|
|
+ where = where + " and SupplierName like '%" + SupplierName + "%'"
|
|
|
+ }
|
|
|
+
|
|
|
+ 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 := annualaudit.GetOilAnnualAuditService(utils.DBE)
|
|
|
+ var list []annualaudit.OilAnnualAudit
|
|
|
+ //找出待办任务
|
|
|
+ actisvc := workflow.GetActivitiService(utils.DBE)
|
|
|
+ certIdList := actisvc.GetMyTasks(workflow.OIL_AUDIT_APPLY, this.User.Id)
|
|
|
+ where += " and Id in (" + certIdList + ")"
|
|
|
+ //根据部门查询待办任务
|
|
|
+
|
|
|
+ total := svc.GetPagingEntitiesWithOrderBytbl("", page.CurrentPage, page.Size,orderby,asc, &list, where)
|
|
|
+ //total := svc.GetMyPagingEntitiesWithOrderBytbl(OilSupplierName, OilSupplierCertName, 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} annualaudit.OilAnnualAudit
|
|
|
+// @router /supplierlist [get]
|
|
|
+func (this *QualChangeController) GetSupplierList() {
|
|
|
+ svc := annualaudit.GetOilAnnualAuditService(utils.DBE)
|
|
|
+ var supplierlist []annualaudit.Suppliername
|
|
|
+ supplierlist = svc.GetSupplierList(""+OilSupplierName, ""+OilAnnualAuditName)
|
|
|
+ var datainfo DataInfo
|
|
|
+ datainfo.Items = supplierlist
|
|
|
+ this.Data["json"] = &datainfo
|
|
|
+ this.ServeJSON()
|
|
|
+}
|
|
|
+
|
|
|
+// @Title 获取字典列表
|
|
|
+// @Description get user by token
|
|
|
+// @Success 200 {object} map[string]interface{}
|
|
|
+// @router /dictlist [get]
|
|
|
+func (this *QualChangeController) GetDictList() {
|
|
|
+ dictList := make(map[string]interface{})
|
|
|
+ //dictSvc := items.GetItemsService(utils.DBE)
|
|
|
+ userSvc := baseUser.GetBaseUserService(utils.DBE)
|
|
|
+ //customerSvc := svccustomer.GetCustomerService(utils.DBE)
|
|
|
+ //dictList["WellNo"] = dictSvc.GetKeyValueItems("WellNo", "")
|
|
|
+ var userEntity userRole.Base_User
|
|
|
+ userSvc.GetEntityById(this.User.Id, &userEntity)
|
|
|
+ dictList["Supervisers"] = userSvc.GetUserListByDepartmentId("", userEntity.Departmentid)
|
|
|
+
|
|
|
+ //var dictCustomer []svccustomer.Customer
|
|
|
+ //customerSvc.GetEntitysByWhere("" + CustomerName, "", &dictCustomer)
|
|
|
+ //dictList["EntrustCorp"] = &dictCustomer
|
|
|
+
|
|
|
+ var datainfo DataInfo
|
|
|
+ datainfo.Items = dictList
|
|
|
+ this.Data["json"] = &datainfo
|
|
|
+ this.ServeJSON()
|
|
|
+}
|
|
|
+
|
|
|
+// @Title 获取实体
|
|
|
+// @Description 获取实体
|
|
|
+// @Success 200 {object} annualaudit.OilAnnualAudit
|
|
|
+// @router /get/:id [get]
|
|
|
+func (this *QualChangeController) GetEntity() {
|
|
|
+ Id := this.Ctx.Input.Param(":id")
|
|
|
+
|
|
|
+ var model annualaudit.OilAnnualAudit
|
|
|
+ svc := annualaudit.GetOilAnnualAuditService(utils.DBE)
|
|
|
+ svc.GetEntityByIdBytbl(""+OilAnnualAuditName, Id, &model)
|
|
|
+
|
|
|
+ this.Data["json"] = &model
|
|
|
+ this.ServeJSON()
|
|
|
+}
|
|
|
+
|
|
|
+// @Title 添加
|
|
|
+// @Description 新增
|
|
|
+// @Success 200 {object} controllers.Request
|
|
|
+// @router /add [post]
|
|
|
+func (this *QualChangeController) AddEntity() {
|
|
|
+ var model annualaudit.OilAnnualAudit
|
|
|
+ var errinfo ErrorDataInfo
|
|
|
+ var jsonBlob = this.Ctx.Input.RequestBody
|
|
|
+ svc := annualaudit.GetOilAnnualAuditService(utils.DBE)
|
|
|
+ json.Unmarshal(jsonBlob, &model)
|
|
|
+ where := "SupplierId = " + utils.ToStr(model.SupplierId) + " and SupplierTypeName = " + model.SupplierTypeName
|
|
|
+ var auditentity []annualaudit.OilAnnualAudit
|
|
|
+ svc.GetEntitysByWhere(""+OilAnnualAuditName, where, &auditentity)
|
|
|
+ if len(auditentity) == 1 {
|
|
|
+ errinfo.Message = "已提交年审,请勿重复提交!"
|
|
|
+ errinfo.Code = -1
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ supwhere := "a.Id = " + utils.ToStr(model.SupplierId) + " and b.SupplierTypeCode = " + model.SupplierTypeName
|
|
|
+ supsvc := supplier.GetOilSupplierService(utils.DBE)
|
|
|
+ var list []supplier.OilSupplierView
|
|
|
+ total := supsvc.GetMyPagingEntitiesWithOrderBytbl(OilSupplierName, OilSupplierCertName, 1, 1, "a.Id", true, &list, supwhere)
|
|
|
+ if total == 0 {
|
|
|
+ errinfo.Message = "请先提交准入申请再提交年审!"
|
|
|
+ errinfo.Code = -1
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ var suppliermodel supplier.OilSupplierView
|
|
|
+ suppliermodel = list[0]
|
|
|
+ model.RecUnitId = suppliermodel.RecUnitId
|
|
|
+ model.CerId = suppliermodel.CertId
|
|
|
+ model.Status = 0
|
|
|
+ model.BackReason = suppliermodel.BackReason
|
|
|
+ //svc.GetEntitysByWhere(""+OilSupplierName, supwhere, &supplierlist)
|
|
|
+ model.CreateOn = time.Now()
|
|
|
+ model.CreateBy = this.User.Realname
|
|
|
+ model.CreateUserId, _ = utils.StrTo(this.User.Id).Int()
|
|
|
+ //model.OrganizeId, _ = utils.StrTo(this.User.DepartmentId).Int()
|
|
|
+ _, err := svc.InsertEntityBytbl(""+OilAnnualAuditName, &model)
|
|
|
+ annualId := model.Id
|
|
|
+ //工作流开始
|
|
|
+ processInstanceId := svc.SubmitOrgAudit(model.WorkflowId, utils.ToStr(model.CerId), utils.ToStr(model.Id), workflow.OIL_AUDIT_APPLY, workflow.FIRST_TRIAL, this.User.Id, "1", "提交给二级单位初审", OilSupplierCertSubName, OilClassOrgSettingName)
|
|
|
+ var auditmodel annualaudit.OilAnnualAudit
|
|
|
+ auditmodel.WorkflowId = processInstanceId
|
|
|
+ cols := []string{
|
|
|
+ "Id",
|
|
|
+ "WorkflowId",
|
|
|
+ }
|
|
|
+ svc.UpdateEntityByIdCols(annualId, auditmodel, cols)
|
|
|
+ if err == nil {
|
|
|
+ //新增
|
|
|
+ errinfo.Message = "添加成功!"
|
|
|
+ errinfo.Code = 0
|
|
|
+ errinfo.Item = model.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} controllers.Request
|
|
|
+// @router /update/:id [post]
|
|
|
+func (this *QualChangeController) 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 annualaudit.OilAnnualAudit
|
|
|
+ svc := annualaudit.GetOilAnnualAuditService(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{
|
|
|
+
|
|
|
+ "Id",
|
|
|
+
|
|
|
+ "Code",
|
|
|
+
|
|
|
+ "Name",
|
|
|
+
|
|
|
+ "F01",
|
|
|
+
|
|
|
+ "F02",
|
|
|
+
|
|
|
+ "F03",
|
|
|
+
|
|
|
+ "F04",
|
|
|
+
|
|
|
+ "F05",
|
|
|
+
|
|
|
+ "F06",
|
|
|
+
|
|
|
+ "F07",
|
|
|
+
|
|
|
+ "F25",
|
|
|
+
|
|
|
+ "Remark",
|
|
|
+
|
|
|
+ "DeletionStateCode",
|
|
|
+
|
|
|
+ "CreateOn",
|
|
|
+
|
|
|
+ "CreateUserId",
|
|
|
+
|
|
|
+ "CreateBy",
|
|
|
+
|
|
|
+ "ModifiedOn",
|
|
|
+
|
|
|
+ "ModifiedUserId",
|
|
|
+
|
|
|
+ "ModifiedBy",
|
|
|
+ }
|
|
|
+ err := svc.UpdateEntityBytbl(""+OilAnnualAuditName, 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()
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+// @Title 删除单条信息
|
|
|
+// @Description
|
|
|
+// @Success 200 {object} ErrorInfo
|
|
|
+// @Failure 403 :id 为空
|
|
|
+// @router /delete/:Id [delete]
|
|
|
+func (this *QualChangeController) DeleteEntity() {
|
|
|
+ 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 annualaudit.OilAnnualAudit
|
|
|
+ var entityempty annualaudit.OilAnnualAudit
|
|
|
+ svc := annualaudit.GetOilAnnualAuditService(utils.DBE)
|
|
|
+ opdesc := "删除-" + Id
|
|
|
+ err := svc.DeleteOperationAndWriteLogBytbl(""+OilAnnualAuditName, BaseOperationLogName, Id, &model, &entityempty, utils.ToStr(this.User.Id), this.User.Username, opdesc, "", "钻井日报")
|
|
|
+ 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 get user by token
|
|
|
+// @Success 200 {object} models.Userblood
|
|
|
+// @router /basiclist [get]
|
|
|
+func (this *QualChangeController) BasicList() {
|
|
|
+ page := this.GetPageInfoForm()
|
|
|
+ var list []annualaudit.OilAnnualAudit
|
|
|
+ svc := annualaudit.GetOilAnnualAuditService(utils.DBE)
|
|
|
+ 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
|
|
|
+ }
|
|
|
+ }
|
|
|
+ keyword := this.GetString("keyword")
|
|
|
+ if keyword != "" {
|
|
|
+ where = where + " and Name like '%" + keyword + "%'"
|
|
|
+ }
|
|
|
+ total := svc.GetPagingEntitiesWithoutAccCode(page.CurrentPage, page.Size, orderby, asc, &list, where)
|
|
|
+ var datainfo DataInfo
|
|
|
+ datainfo.Items = list
|
|
|
+ datainfo.CurrentItemCount = total
|
|
|
+ this.Data["json"] = &datainfo
|
|
|
+ this.ServeJSON()
|
|
|
+}
|