|
@@ -0,0 +1,293 @@
|
|
|
|
|
+package oilsupplier
|
|
|
|
|
+
|
|
|
|
|
+import (
|
|
|
|
|
+ "dashoo.cn/backend/api/business/baseUser"
|
|
|
|
|
+ "dashoo.cn/backend/api/business/items"
|
|
|
|
|
+ "dashoo.cn/backend/api/business/oilsupplier/auditsetting"
|
|
|
|
|
+ "dashoo.cn/backend/api/business/organize"
|
|
|
|
|
+ "dashoo.cn/backend/api/business/role"
|
|
|
|
|
+ . "dashoo.cn/backend/api/controllers"
|
|
|
|
|
+ "dashoo.cn/business2/userRole"
|
|
|
|
|
+ "dashoo.cn/utils"
|
|
|
|
|
+ "encoding/json"
|
|
|
|
|
+ "strings"
|
|
|
|
|
+ "time"
|
|
|
|
|
+)
|
|
|
|
|
+
|
|
|
|
|
+type OilAuditSettingController struct {
|
|
|
|
|
+ BaseController
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
|
|
+// @Title 获取列表
|
|
|
|
|
+// @Description get user by token
|
|
|
|
|
+// @Success 200 {object} []auditsetting.OilAuditSetting
|
|
|
|
|
+// @router /list [get]
|
|
|
|
|
+func (this *OilAuditSettingController) GetEntityList() {
|
|
|
|
|
+
|
|
|
|
|
+ //获取分页信息
|
|
|
|
|
+ page := this.GetPageInfoForm()
|
|
|
|
|
+ where := " 1=1 "
|
|
|
|
|
+ orderby := "Id"
|
|
|
|
|
+ asc := false
|
|
|
|
|
+ Order := this.GetString("Order")
|
|
|
|
|
+ Prop := this.GetString("Prop")
|
|
|
|
|
+ if Order != "" && Prop != "" {
|
|
|
|
|
+ orderby = Prop
|
|
|
|
|
+ if Order == "asc" {
|
|
|
|
|
+ asc = true
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ OrganizeId := this.GetString("OrganizeId")
|
|
|
|
|
+ OrganizeName := this.GetString("OrganizeName")
|
|
|
|
|
+ AuditStepCode := this.GetString("AuditStepCode")
|
|
|
|
|
+ AuditStepName := this.GetString("AuditStepName")
|
|
|
|
|
+ RoleId := this.GetString("RoleId")
|
|
|
|
|
+ RoleName := this.GetString("RoleName")
|
|
|
|
|
+ Remark := this.GetString("Remark")
|
|
|
|
|
+ CreateOn := this.GetString("CreateOn")
|
|
|
|
|
+
|
|
|
|
|
+ OrganizeId = this.User.DepartmentId //无权限看所有时,只看当前部门的数据
|
|
|
|
|
+ if OrganizeId != "" {
|
|
|
|
|
+ where = where + " and OrganizeId = '" + OrganizeId + "'"
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
|
|
+ if OrganizeName != "" {
|
|
|
|
|
+ where = where + " and OrganizeName like '%" + OrganizeName + "%'"
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
|
|
+ if AuditStepCode != "" {
|
|
|
|
|
+ where = where + " and AuditStepCode like '%" + AuditStepCode + "%'"
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
|
|
+ if AuditStepName != "" {
|
|
|
|
|
+ where = where + " and AuditStepName like '%" + AuditStepName + "%'"
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
|
|
+ if RoleId != "" {
|
|
|
|
|
+ where = where + " and RoleId like '%" + RoleId + "%'"
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
|
|
+ if RoleName != "" {
|
|
|
|
|
+ where = where + " and RoleName like '%" + RoleName + "%'"
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
|
|
+ if Remark != "" {
|
|
|
|
|
+ where = where + " and Remark like '%" + Remark + "%'"
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
|
|
+ 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 := auditsetting.GetOilAuditSettingService(utils.DBE)
|
|
|
|
|
+ var list []auditsetting.OilAuditSetting
|
|
|
|
|
+ total := svc.GetPagingEntitiesWithOrderBytbl("", 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 get user by token
|
|
|
|
|
+// @Success 200 {object} map[string]interface{}
|
|
|
|
|
+// @router /dictlist [get]
|
|
|
|
|
+func (this *OilAuditSettingController) GetDictList() {
|
|
|
|
|
+ dictList := make(map[string]interface{})
|
|
|
|
|
+ dictSvc := items.GetItemsService(utils.DBE)
|
|
|
|
|
+ userSvc := baseUser.GetBaseUserService(utils.DBE)
|
|
|
|
|
+ dictList["AuditStep"] = dictSvc.GetKeyValueItems("AuditStep", this.User.AccCode)
|
|
|
|
|
+ var userEntity userRole.Base_User
|
|
|
|
|
+ userSvc.GetEntityById(this.User.Id, &userEntity)
|
|
|
|
|
+ dictList["Supervisers"] = userSvc.GetUserListByDepartmentId(this.User.AccCode, userEntity.Departmentid)
|
|
|
|
|
+
|
|
|
|
|
+ svcRole := role.GetRoleService(utils.DBE)
|
|
|
|
|
+ var roles []userRole.Base_Role
|
|
|
|
|
+ where := "IsVisible=1"
|
|
|
|
|
+ svcRole.GetMyRoleList("CreateOn", utils.ToStr(this.User.Id), &roles, where)
|
|
|
|
|
+ dictList["RoleList"] = roles
|
|
|
|
|
+
|
|
|
|
|
+ svcOrgan := organize.GetOrganizeService(utils.DBE)
|
|
|
|
|
+ dictList["OrganizeId"] = this.User.DepartmentId
|
|
|
|
|
+ dictList["OrganizeName"] = svcOrgan.GetNameById(this.User.DepartmentId)
|
|
|
|
|
+
|
|
|
|
|
+ //var dictCustomer []svccustomer.Customer
|
|
|
|
|
+ //customerSvc.GetEntitysByWhere(this.User.AccCode + CustomerName, "", &dictCustomer)
|
|
|
|
|
+ //dictList["EntrustCorp"] = &dictCustomer
|
|
|
|
|
+
|
|
|
|
|
+ var datainfo DataInfo
|
|
|
|
|
+ datainfo.Items = dictList
|
|
|
|
|
+ this.Data["json"] = &datainfo
|
|
|
|
|
+ this.ServeJSON()
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
|
|
+// @Title 获取实体
|
|
|
|
|
+// @Description 获取实体
|
|
|
|
|
+// @Success 200 {object} auditsetting.OilAuditSetting
|
|
|
|
|
+// @router /get/:id [get]
|
|
|
|
|
+func (this *OilAuditSettingController) GetEntity() {
|
|
|
|
|
+ Id := this.Ctx.Input.Param(":id")
|
|
|
|
|
+
|
|
|
|
|
+ var model auditsetting.OilAuditSetting
|
|
|
|
|
+ svc := auditsetting.GetOilAuditSettingService(utils.DBE)
|
|
|
|
|
+ svc.GetEntityByIdBytbl(OilAuditSettingName, Id, &model)
|
|
|
|
|
+
|
|
|
|
|
+ this.Data["json"] = &model
|
|
|
|
|
+ this.ServeJSON()
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
|
|
+// @Title 添加
|
|
|
|
|
+// @Description 新增
|
|
|
|
|
+// @Param body body auditsetting.OilAuditSetting
|
|
|
|
|
+// @Success 200 {object} controllers.Request
|
|
|
|
|
+// @router /add [post]
|
|
|
|
|
+func (this *OilAuditSettingController) AddEntity() {
|
|
|
|
|
+ var model auditsetting.OilAuditSetting
|
|
|
|
|
+ var jsonBlob = this.Ctx.Input.RequestBody
|
|
|
|
|
+ svc := auditsetting.GetOilAuditSettingService(utils.DBE)
|
|
|
|
|
+
|
|
|
|
|
+ json.Unmarshal(jsonBlob, &model)
|
|
|
|
|
+ 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(OilAuditSettingName, &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()
|
|
|
|
|
+ }
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
|
|
+// @Title 修改实体
|
|
|
|
|
+// @Description 修改实体
|
|
|
|
|
+// @Param body body auditsetting.OilAuditSetting
|
|
|
|
|
+// @Success 200 {object} controllers.Request
|
|
|
|
|
+// @router /update/:id [post]
|
|
|
|
|
+func (this *OilAuditSettingController) 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 auditsetting.OilAuditSetting
|
|
|
|
|
+ svc := auditsetting.GetOilAuditSettingService(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",
|
|
|
|
|
+
|
|
|
|
|
+ "OrganizeId",
|
|
|
|
|
+
|
|
|
|
|
+ "OrganizeName",
|
|
|
|
|
+
|
|
|
|
|
+ "AuditStepCode",
|
|
|
|
|
+
|
|
|
|
|
+ "AuditStepName",
|
|
|
|
|
+
|
|
|
|
|
+ "RoleId",
|
|
|
|
|
+
|
|
|
|
|
+ "RoleName",
|
|
|
|
|
+
|
|
|
|
|
+ "Remark",
|
|
|
|
|
+
|
|
|
|
|
+ "IsDelete",
|
|
|
|
|
+
|
|
|
|
|
+ "CreateOn",
|
|
|
|
|
+
|
|
|
|
|
+ "CreateUserId",
|
|
|
|
|
+
|
|
|
|
|
+ "CreateBy",
|
|
|
|
|
+
|
|
|
|
|
+ "ModifiedOn",
|
|
|
|
|
+
|
|
|
|
|
+ "ModifiedUserId",
|
|
|
|
|
+
|
|
|
|
|
+ "ModifiedBy",
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
|
|
+ }
|
|
|
|
|
+ err := svc.UpdateEntityBytbl(OilAuditSettingName, 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 *OilAuditSettingController) 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 auditsetting.OilAuditSetting
|
|
|
|
|
+ var entityempty auditsetting.OilAuditSetting
|
|
|
|
|
+ svc := auditsetting.GetOilAuditSettingService(utils.DBE)
|
|
|
|
|
+ opdesc := "删除-" + Id
|
|
|
|
|
+ err := svc.DeleteOperationAndWriteLogBytbl(OilAuditSettingName, BaseOperationLogName, Id, &model, &entityempty, utils.ToStr(this.User.Id), this.User.Username, opdesc, this.User.AccCode, "钻井日报")
|
|
|
|
|
+ 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()
|
|
|
|
|
+ }
|
|
|
|
|
+}
|