|
@@ -179,6 +179,7 @@ func (this *OilAuditSettingController) AddEntity() {
|
|
|
auditIds := strings.Split(audits, ",")
|
|
auditIds := strings.Split(audits, ",")
|
|
|
fmt.Println(audits)
|
|
fmt.Println(audits)
|
|
|
var model auditsetting.Base_OilAuditSetting
|
|
var model auditsetting.Base_OilAuditSetting
|
|
|
|
|
+ var audituser auditsetting.OilAuditUser
|
|
|
var jsonBlob = this.Ctx.Input.RequestBody
|
|
var jsonBlob = this.Ctx.Input.RequestBody
|
|
|
svc := auditsetting.GetOilAuditSettingService(utils.DBE)
|
|
svc := auditsetting.GetOilAuditSettingService(utils.DBE)
|
|
|
|
|
|
|
@@ -188,17 +189,37 @@ func (this *OilAuditSettingController) AddEntity() {
|
|
|
model.CreateUserId, _ = utils.StrTo(this.User.Id).Int()
|
|
model.CreateUserId, _ = utils.StrTo(this.User.Id).Int()
|
|
|
model.OrganizeId, _ = utils.StrTo(this.User.DepartmentId).Int()
|
|
model.OrganizeId, _ = utils.StrTo(this.User.DepartmentId).Int()
|
|
|
|
|
|
|
|
|
|
+ var errinfo ErrorDataInfo
|
|
|
|
|
+ var modelsele auditsetting.Base_OilAuditSetting
|
|
|
|
|
+ where := "OrganizeId=" + this.User.DepartmentId + " and AuditStepCode='" + model.AuditStepCode + "'"
|
|
|
|
|
+ has := svc.GetEntity(&modelsele, where)
|
|
|
|
|
+ if (has) {
|
|
|
|
|
+ errinfo.Message = "审批步骤已经存在,不允许重复添加!"
|
|
|
|
|
+ errinfo.Code = -1
|
|
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
|
|
+ this.ServeJSON()
|
|
|
|
|
+ return
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
var err error
|
|
var err error
|
|
|
- for _, Id := range auditIds {
|
|
|
|
|
- var user userRole.Base_User
|
|
|
|
|
- svc.GetEntityById(Id, &user)
|
|
|
|
|
- model.Id = 0
|
|
|
|
|
- model.UserId,_ = strconv.Atoi(Id)
|
|
|
|
|
- model.UserName = user.Realname
|
|
|
|
|
- _, err = svc.InsertEntityBytbl(OilAuditSettingName, &model)
|
|
|
|
|
|
|
+ _, err = svc.InsertEntityBytbl(OilAuditSettingName, &model)
|
|
|
|
|
+ if (err == nil) {
|
|
|
|
|
+ for _, Id := range auditIds {
|
|
|
|
|
+ var user userRole.Base_User
|
|
|
|
|
+ svc.GetEntityById(Id, &user)
|
|
|
|
|
+ audituser.Id = 0
|
|
|
|
|
+ audituser.SettingId = model.Id
|
|
|
|
|
+ audituser.UserId,_ = strconv.Atoi(Id)
|
|
|
|
|
+ audituser.UserName = user.Realname
|
|
|
|
|
+ audituser.CreateOn = time.Now()
|
|
|
|
|
+ audituser.CreateBy = this.User.Realname
|
|
|
|
|
+ audituser.CreateUserId, _ = utils.StrTo(this.User.Id).Int()
|
|
|
|
|
+ _, err = svc.InsertEntityBytbl(OilAuditUserName, &audituser)
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- var errinfo ErrorDataInfo
|
|
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
if err == nil {
|
|
if err == nil {
|
|
|
//新增
|
|
//新增
|
|
|
errinfo.Message = "添加成功!"
|
|
errinfo.Message = "添加成功!"
|
|
@@ -250,6 +271,8 @@ func (this *OilAuditSettingController) UpdateEntity() {
|
|
|
"RoleName",
|
|
"RoleName",
|
|
|
"WorkFlowCord",
|
|
"WorkFlowCord",
|
|
|
"WorkFlowName",
|
|
"WorkFlowName",
|
|
|
|
|
+ "UserId",
|
|
|
|
|
+ "UserName",
|
|
|
"Remark",
|
|
"Remark",
|
|
|
"IsDelete",
|
|
"IsDelete",
|
|
|
"CreateOn",
|
|
"CreateOn",
|
|
@@ -260,6 +283,24 @@ func (this *OilAuditSettingController) UpdateEntity() {
|
|
|
"ModifiedBy",
|
|
"ModifiedBy",
|
|
|
}
|
|
}
|
|
|
err := svc.UpdateEntityBytbl(OilAuditSettingName, id, &model, cols)
|
|
err := svc.UpdateEntityBytbl(OilAuditSettingName, id, &model, cols)
|
|
|
|
|
+ auditIds := strings.Split(model.UserId, ",")
|
|
|
|
|
+ var audituser auditsetting.OilAuditUser
|
|
|
|
|
+ if err == nil {
|
|
|
|
|
+ where := "SettingId=" + id
|
|
|
|
|
+ err = svc.DeleteEntityBytbl(OilAuditUserName, where)
|
|
|
|
|
+ for _, Id := range auditIds {
|
|
|
|
|
+ var user userRole.Base_User
|
|
|
|
|
+ svc.GetEntityById(Id, &user)
|
|
|
|
|
+ audituser.Id = 0
|
|
|
|
|
+ audituser.SettingId = model.Id
|
|
|
|
|
+ audituser.UserId,_ = strconv.Atoi(Id)
|
|
|
|
|
+ audituser.UserName = user.Realname
|
|
|
|
|
+ audituser.CreateOn = time.Now()
|
|
|
|
|
+ audituser.CreateBy = this.User.Realname
|
|
|
|
|
+ audituser.CreateUserId, _ = utils.StrTo(this.User.Id).Int()
|
|
|
|
|
+ _, err = svc.InsertEntityBytbl(OilAuditUserName, &audituser)
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
if err == nil {
|
|
if err == nil {
|
|
|
errinfo.Message = "修改成功!"
|
|
errinfo.Message = "修改成功!"
|
|
|
errinfo.Code = 0
|
|
errinfo.Code = 0
|
|
@@ -288,9 +329,12 @@ func (this *OilAuditSettingController) DeleteEntity() {
|
|
|
this.ServeJSON()
|
|
this.ServeJSON()
|
|
|
return
|
|
return
|
|
|
}
|
|
}
|
|
|
|
|
+
|
|
|
var model auditsetting.Base_OilAuditSetting
|
|
var model auditsetting.Base_OilAuditSetting
|
|
|
var entityempty auditsetting.Base_OilAuditSetting
|
|
var entityempty auditsetting.Base_OilAuditSetting
|
|
|
svc := auditsetting.GetOilAuditSettingService(utils.DBE)
|
|
svc := auditsetting.GetOilAuditSettingService(utils.DBE)
|
|
|
|
|
+ where := "SettingId=" + Id
|
|
|
|
|
+ svc.DeleteEntityBytbl(OilAuditUserName, where)
|
|
|
opdesc := "删除-" + Id
|
|
opdesc := "删除-" + Id
|
|
|
err := svc.DeleteOperationAndWriteLogBytbl(OilAuditSettingName, BaseOperationLogName, Id, &model, &entityempty, utils.ToStr(this.User.Id), this.User.Username, opdesc, this.User.AccCode, "钻井日报")
|
|
err := svc.DeleteOperationAndWriteLogBytbl(OilAuditSettingName, BaseOperationLogName, Id, &model, &entityempty, utils.ToStr(this.User.Id), this.User.Username, opdesc, this.User.AccCode, "钻井日报")
|
|
|
if err == nil {
|
|
if err == nil {
|
|
@@ -337,10 +381,10 @@ func (this *OilAuditSettingController) IsAccess() {
|
|
|
func (this *OilAuditSettingController) GetAuditerByDept() {
|
|
func (this *OilAuditSettingController) GetAuditerByDept() {
|
|
|
Id := this.Ctx.Input.Param(":deptId")
|
|
Id := this.Ctx.Input.Param(":deptId")
|
|
|
|
|
|
|
|
- var users []userRole.Base_User
|
|
|
|
|
- svcRole := userRole.GetRoleService(utils.DBE)
|
|
|
|
|
|
|
+ var users []userRole.Base_RoleList
|
|
|
|
|
+ rsvc := auditsetting.GetOilAuditSettingService(utils.DBE)
|
|
|
where := "DepartmentId=" + Id
|
|
where := "DepartmentId=" + Id
|
|
|
- svcRole.GetEntities(&users, where)
|
|
|
|
|
|
|
+ rsvc.GetEntitysByWhere(BaseUserName, where, &users)
|
|
|
|
|
|
|
|
var datainfo ErrorDataInfo
|
|
var datainfo ErrorDataInfo
|
|
|
if users == nil {
|
|
if users == nil {
|
|
@@ -352,4 +396,22 @@ func (this *OilAuditSettingController) GetAuditerByDept() {
|
|
|
datainfo.Item = users
|
|
datainfo.Item = users
|
|
|
this.Data["json"] = &datainfo
|
|
this.Data["json"] = &datainfo
|
|
|
this.ServeJSON()
|
|
this.ServeJSON()
|
|
|
-}
|
|
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
|
|
+// @Title 获取审核人列表
|
|
|
|
|
+// @Description 获取审核人列表
|
|
|
|
|
+// @Success 200 {object} auditsetting.Base_OilAuditSetting
|
|
|
|
|
+// @router /getaudituserlist/:id [get]
|
|
|
|
|
+func (this *OilAuditSettingController) GetAuditUserList() {
|
|
|
|
|
+ Id := this.Ctx.Input.Param(":id")
|
|
|
|
|
+
|
|
|
|
|
+ var users []userRole.Base_RoleList
|
|
|
|
|
+ rsvc := auditsetting.GetOilAuditSettingService(utils.DBE)
|
|
|
|
|
+ rsvc.GetAuditUserList(Id, &users)
|
|
|
|
|
+ ////where := "SettingId=" + Id
|
|
|
|
|
+ ////sql := "SELECT UserId Id, UserName RealName FROM " + OilAuditUserName + " where " + where
|
|
|
|
|
+ //rsvc.DBE.SQL(sql).Find(&users)
|
|
|
|
|
+
|
|
|
|
|
+ this.Data["json"] = &users
|
|
|
|
|
+ this.ServeJSON()
|
|
|
|
|
+}
|