|
@@ -7,12 +7,8 @@ import (
|
|
|
"time"
|
|
"time"
|
|
|
|
|
|
|
|
"dashoo.cn/backend/api/business/oilsupplier/annualaudit"
|
|
"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/workflow"
|
|
|
|
|
|
|
|
- "dashoo.cn/backend/api/business/baseUser"
|
|
|
|
|
- "dashoo.cn/business/userRole"
|
|
|
|
|
-
|
|
|
|
|
. "dashoo.cn/backend/api/controllers"
|
|
. "dashoo.cn/backend/api/controllers"
|
|
|
"dashoo.cn/utils"
|
|
"dashoo.cn/utils"
|
|
|
)
|
|
)
|
|
@@ -21,12 +17,27 @@ type InfoChangeController struct {
|
|
|
BaseController
|
|
BaseController
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+// @Title 获取实体
|
|
|
|
|
+// @Description 获取实体
|
|
|
|
|
+// @Success 200 {object} annualaudit.OilAnnualAudit
|
|
|
|
|
+// @router /get/:id [get]
|
|
|
|
|
+func (this *InfoChangeController) GetEntity() {
|
|
|
|
|
+ CertId := this.Ctx.Input.Param(":id")
|
|
|
|
|
+ var model []infochange.OilInfoChangeItem
|
|
|
|
|
+ svc := infochange.GetInfoChangeService(utils.DBE)
|
|
|
|
|
+ where := " SupplierId = "+CertId
|
|
|
|
|
+ svc.GetEntitysByWhere(OilInfoChangeItemName,where,&model)
|
|
|
|
|
+ var datainfo DataInfo
|
|
|
|
|
+ datainfo.Items = model
|
|
|
|
|
+ this.Data["json"] = &datainfo
|
|
|
|
|
+ this.ServeJSON()
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
// @Title 获取列表
|
|
// @Title 获取列表
|
|
|
// @Description get user by token
|
|
// @Description get user by token
|
|
|
// @Success 200 {object} []infochange.OilInfoChange
|
|
// @Success 200 {object} []infochange.OilInfoChange
|
|
|
// @router /list [get]
|
|
// @router /list [get]
|
|
|
func (this *InfoChangeController) GetEntityList() {
|
|
func (this *InfoChangeController) GetEntityList() {
|
|
|
-
|
|
|
|
|
//获取分页信息
|
|
//获取分页信息
|
|
|
page := this.GetPageInfoForm()
|
|
page := this.GetPageInfoForm()
|
|
|
where := " 1=1 "
|
|
where := " 1=1 "
|
|
@@ -83,6 +94,20 @@ func (this *InfoChangeController) GetEntityList() {
|
|
|
this.ServeJSON()
|
|
this.ServeJSON()
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+// @Title 获取实体
|
|
|
|
|
+// @Description 获取实体
|
|
|
|
|
+// @Success 200 {object} annualaudit.OilAnnualAudit
|
|
|
|
|
+// @router /getinfoforitem [get]
|
|
|
|
|
+func (this *InfoChangeController) GetInfoForItem() {
|
|
|
|
|
+ certId := this.GetString("certId")
|
|
|
|
|
+ selctitem := this.GetString("selctitem")
|
|
|
|
|
+ svc := infochange.GetInfoChangeService(utils.DBE)
|
|
|
|
|
+ where := "Id ="+ utils.ToStr(certId)
|
|
|
|
|
+ var selecteditem = svc.GetInfoforItem(""+OilSupplierName, selctitem, where)
|
|
|
|
|
+ this.Data["json"] = &selecteditem
|
|
|
|
|
+ this.ServeJSON()
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
// @Title 获取列表
|
|
// @Title 获取列表
|
|
|
// @Description get user by token
|
|
// @Description get user by token
|
|
|
// @Success 200 {object} []annualaudit.OilAnnualAudit
|
|
// @Success 200 {object} []annualaudit.OilAnnualAudit
|
|
@@ -153,205 +178,6 @@ func (this *InfoChangeController) GetMyTaskEntityList() {
|
|
|
this.ServeJSON()
|
|
this.ServeJSON()
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-// @Title 获取年审企业名称
|
|
|
|
|
-// @Description 获取实体
|
|
|
|
|
-// @Success 200 {object} annualaudit.OilAnnualAudit
|
|
|
|
|
-// @router /supplierlist [get]
|
|
|
|
|
-func (this *InfoChangeController) 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 *InfoChangeController) 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 *InfoChangeController) 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 *InfoChangeController) 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 *InfoChangeController) 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 删除单条信息
|
|
// @Title 删除单条信息
|
|
|
// @Description
|
|
// @Description
|
|
|
// @Success 200 {object} ErrorInfo
|
|
// @Success 200 {object} ErrorInfo
|
|
@@ -367,11 +193,11 @@ func (this *InfoChangeController) DeleteEntity() {
|
|
|
this.ServeJSON()
|
|
this.ServeJSON()
|
|
|
return
|
|
return
|
|
|
}
|
|
}
|
|
|
- var model annualaudit.OilAnnualAudit
|
|
|
|
|
- var entityempty annualaudit.OilAnnualAudit
|
|
|
|
|
- svc := annualaudit.GetOilAnnualAuditService(utils.DBE)
|
|
|
|
|
|
|
+ var model infochange.OilInfoChangeItem
|
|
|
|
|
+ var entityempty infochange.OilInfoChangeItem
|
|
|
|
|
+ svc := infochange.GetInfoChangeService(utils.DBE)
|
|
|
opdesc := "删除-" + Id
|
|
opdesc := "删除-" + Id
|
|
|
- err := svc.DeleteOperationAndWriteLogBytbl(""+OilAnnualAuditName, BaseOperationLogName, Id, &model, &entityempty, utils.ToStr(this.User.Id), this.User.Username, opdesc, "", "钻井日报")
|
|
|
|
|
|
|
+ err := svc.DeleteOperationAndWriteLogBytbl(""+OilInfoChangeItemName, BaseOperationLogName, Id, &model, &entityempty, utils.ToStr(this.User.Id), this.User.Username, opdesc, "", "信息变更")
|
|
|
if err == nil {
|
|
if err == nil {
|
|
|
errinfo.Message = "删除成功"
|
|
errinfo.Message = "删除成功"
|
|
|
errinfo.Code = 0
|
|
errinfo.Code = 0
|
|
@@ -385,33 +211,32 @@ func (this *InfoChangeController) DeleteEntity() {
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-// @Title 基建类业务
|
|
|
|
|
-// @Description get user by token
|
|
|
|
|
-// @Success 200 {object} models.Userblood
|
|
|
|
|
-// @router /basiclist [get]
|
|
|
|
|
-func (this *InfoChangeController) 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 + "%'"
|
|
|
|
|
|
|
+// @Title 添加
|
|
|
|
|
+// @Description 新增
|
|
|
|
|
+// @Success 200 {object} controllers.Request
|
|
|
|
|
+// @router /addinfochangeitem [post]
|
|
|
|
|
+func (this *InfoChangeController) AddInfoChangeItem() {
|
|
|
|
|
+ var model infochange.OilInfoChangeItem
|
|
|
|
|
+ var jsonBlob= this.Ctx.Input.RequestBody
|
|
|
|
|
+ svc := infochange.GetInfoChangeService(utils.DBE)
|
|
|
|
|
+ json.Unmarshal(jsonBlob, &model)
|
|
|
|
|
+ model.CreateOn = time.Now()
|
|
|
|
|
+ model.CreateBy = this.User.Realname
|
|
|
|
|
+ model.CreateUserId, _ = utils.StrTo(this.User.Id).Int()
|
|
|
|
|
+ _, err := svc.InsertEntityBytbl(""+OilInfoChangeItemName, &model)
|
|
|
|
|
+
|
|
|
|
|
+ var errinfo ErrorDataInfo
|
|
|
|
|
+ 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()
|
|
|
}
|
|
}
|
|
|
- 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()
|
|
|
|
|
}
|
|
}
|