package oilsupplier import ( "dashoo.cn/backend/api/business/oilsupplier/supplier" "dashoo.cn/backend/api/business/oilsupplier/suppliercert" "dashoo.cn/business/parameter" "encoding/json" //"fmt" "strconv" "strings" "time" "dashoo.cn/backend/api/business/baseUser" "dashoo.cn/backend/api/business/oilsupplier/suppliercertsub" "dashoo.cn/backend/api/business/oilsupplier/supplierfile" // "dashoo.cn/backend/api/business/oilsupplier/technologyservice" . "dashoo.cn/backend/api/controllers" "dashoo.cn/business/userRole" "dashoo.cn/utils" ) type OilSupplierCertSubController struct { BaseController } // @Title 获取列表 // @Description get user by token // @Success 200 {object} []suppliercertsub.OilSupplierCertSub // @router /list [get] func (this *OilSupplierCertSubController) 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 } } Id := this.GetString("Id") SupplierId := this.GetString("SupplierId") SupplierCertId := this.GetString("SupplierCertId") SupplierTypeCode := this.GetString("SupplierTypeCode") Code := this.GetString("Code") Name := this.GetString("Name") Remark := this.GetString("Remark") IsDelete := this.GetString("IsDelete") CreateOn := this.GetString("CreateOn") CreateUserId := this.GetString("CreateUserId") CreateBy := this.GetString("CreateBy") ModifiedOn := this.GetString("ModifiedOn") ModifiedUserId := this.GetString("ModifiedUserId") ModifiedBy := this.GetString("ModifiedBy") if Id != "" { where = where + " and Id like '%" + Id + "%'" } if SupplierId != "" { where = where + " and SupplierId like '%" + SupplierId + "%'" } if SupplierCertId != "" { where = where + " and SupplierCertId = '" + SupplierCertId + "'" } if SupplierTypeCode != "" { where = where + " and SupplierTypeCode = '" + SupplierTypeCode + "'" } if Code != "" { where = where + " and Code like '%" + Code + "%'" } if Name != "" { where = where + " and Name like '%" + Name + "%'" } if Remark != "" { where = where + " and Remark like '%" + Remark + "%'" } if IsDelete != "" { where = where + " and IsDelete like '%" + IsDelete + "%'" } if CreateUserId != "" { where = where + " and CreateUserId like '%" + CreateUserId + "%'" } if CreateBy != "" { where = where + " and CreateBy like '%" + CreateBy + "%'" } if ModifiedOn != "" { where = where + " and ModifiedOn like '%" + ModifiedOn + "%'" } if ModifiedUserId != "" { where = where + " and ModifiedUserId like '%" + ModifiedUserId + "%'" } if ModifiedBy != "" { where = where + " and ModifiedBy like '%" + ModifiedBy + "%'" } if CreateOn != "" { dates := strings.Split(CreateOn, ",") if len(dates) == 2 { minDate := dates[0] maxDate := dates[1] where = where + " and CreateOn>='" + minDate + "' and CreateOn<='" + maxDate + "'" } } where = where + " and Type = '1'" svc := suppliercertsub.GetOilSupplierCertSubService(utils.DBE) var list []suppliercertsub.OilSupplierCertSub total := svc.GetPagingEntitiesWithoutAccCode(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 *OilSupplierCertSubController) 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", this.User.AccCode) var userEntity userRole.Base_User userSvc.GetEntityById(this.User.Id, &userEntity) dictList["Supervisers"] = userSvc.GetUserListByDepartmentId(this.User.AccCode, userEntity.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} suppliercertsub.OilSupplierCertSub // @router /get/:id [get] func (this *OilSupplierCertSubController) GetEntity() { Id := this.Ctx.Input.Param(":id") var model suppliercertsub.OilSupplierCertSub svc := suppliercertsub.GetOilSupplierCertSubService(utils.DBE) svc.GetEntityByIdBytbl(OilSupplierCertSubName, Id, &model) this.Data["json"] = &model this.ServeJSON() } // @Title 添加 // @Description 新增 // @Success 200 {object} controllers.Request // @router /add [post] func (this *OilSupplierCertSubController) AddEntity() { var model suppliercertsub.OilSupplierCertSub var jsonBlob = this.Ctx.Input.RequestBody svc := suppliercertsub.GetOilSupplierCertSubService(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(OilSupplierCertSubName, &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 修改实体 // @Success 200 {object} controllers.Request // @router /update/:id [post] func (this *OilSupplierCertSubController) 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 suppliercertsub.OilSupplierCertSub svc := suppliercertsub.GetOilSupplierCertSubService(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", "SupplierId", "SupplierCertId", "SubClassId", "Code", "Name", "Remark", "IsDelete", "CreateOn", "CreateUserId", "CreateBy", "ModifiedOn", "ModifiedUserId", "ModifiedBy", } err := svc.UpdateEntityBytbl(OilSupplierCertSubName, 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 *OilSupplierCertSubController) 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 suppliercertsub.OilSupplierCertSub var entityempty suppliercertsub.OilSupplierCertSub svc := suppliercertsub.GetOilSupplierCertSubService(utils.DBE) opdesc := "删除-" + Id err := svc.DeleteOperationAndWriteLogBytbl(OilSupplierCertSubName, 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() } } // @Title 批量添加准入范围--物资类 // @Description 批量添加准入范围 // @Success 200 {object} business.device.DeviceChannels // @router /addgoodsbus [post] func (this *OilSupplierCertSubController) AddGoodsBus() { var jsonblob = this.Ctx.Input.RequestBody var datamain suppliercertsub.OilSupplierCertSub var dataother suppliercertsub.SupplierCertSubModel json.Unmarshal(jsonblob, &datamain) json.Unmarshal(jsonblob, &dataother) var supplierCertModel suppliercert.OilSupplierCert svcCert := suppliercert.GetOilSupplierCertService(utils.DBE) svcCert.GetEntityById(datamain.SupplierCertId, &supplierCertModel) var supplierModel supplier.OilSupplier svcSupplier := supplier.GetOilSupplierService(utils.DBE) svcSupplier.GetEntityById(datamain.SupplierCertId, &supplierModel) for n := 0; n < len(dataother.CheckList); n++ { where_sub := "SupplierTypeCode = 01 and SupplierId = '" + strconv.Itoa(dataother.SupplierId) + "'" where_sub += " and SupplierCertId = '" + strconv.Itoa(dataother.SupplierCertId) + "'" where_sub += " and SubClassId = '" + dataother.CheckList[n].Id + "'" var model suppliercertsub.OilSupplierCertSub svc := suppliercertsub.GetOilSupplierCertSubService(utils.DBE) has := svc.GetEntityByWhere(OilSupplierCertSubName, where_sub, &model) if !has { datamain.SubClassId, _ = utils.StrTo(dataother.CheckList[n].Id).Int() datamain.Code = dataother.CheckList[n].Code datamain.Name = dataother.CheckList[n].Name datamain.Remark = dataother.Remark datamain.IsDelete = 0 datamain.CreateBy = this.User.Realname datamain.CreateUserId, _ = utils.StrTo(this.User.Id).Int() svc.InsertEntityBytbl(OilSupplierCertSubName, &datamain) paramSvc := baseparameter.GetBaseparameterService(utils.DBE) filesvc := supplierfile.GetSupplierfileService(utils.DBE) needList := filesvc.GetGoodsNeedFileList(dataother.CheckList[n].Id) if supplierCertModel.InStyle == "4" { var needFile supplierfile.FileList //战略合作协议扫描件 needFile.FileName = paramSvc.GetBaseparameterMessage("GFGL", "paramset", "CooperationFile") needList = append(needList, needFile) } var list []supplierfile.OilSupplierFile where := "SupplierId = '" + strconv.Itoa(dataother.SupplierId) + "'" svc.GetEntitysByWhere(OilSupplierFileName, where, &list) //三证合一或五证合一不需要的字段 mergerCertSkipField := paramSvc.GetBaseparameterMessage("GFGL", "paramset", "MergerCertSkipFieldName") //"营业执照,组织代码,组织机构代码证,税务登记证,税务登记,开户许可,银行开户许可证,承诺书,诚信合规承诺书,企业信息系统截图,战略合作协议扫描件," mustField := paramSvc.GetBaseparameterMessage("GFGL", "paramset", "MustFieldName") for i := 0; i < len(needList); i++ { var entity supplierfile.OilSupplierFile entity.SupplierId = dataother.SupplierId if (supplierModel.CredentialFlag == "1" || supplierModel.CredentialFlag == "2") && strings.Contains(mergerCertSkipField, needList[i].FileName+",") { //三证合一或五证合一了 continue } //加入对应表OilSupplierCert2File var cert2File suppliercertsub.OilSupplierCert2File //创建结构体 cert2File.SupplierId = dataother.SupplierId cert2File.SupplierCertId = dataother.SupplierCertId cert2File.SupplierTypeCode = dataother.SupplierTypeCode cert2File.SubClassId, _ = utils.StrTo(dataother.CheckList[n].Id).Int() cert2File.Code = dataother.CheckList[n].Code cert2File.Name = dataother.CheckList[n].Name cert2File.NeedFileType = needList[i].FileName svc.InsertEntityBytbl(OilSupplierCert2FileName, &cert2File) if strings.Contains(mustField, needList[i].FileName+",") { entity.SupplierTypeCode = "000" } else { entity.SupplierTypeCode = dataother.SupplierTypeCode } entity.NeedFileType = needList[i].FileName entity.FileType = 1 entity.EffectDate = time.Now() entity.CreateBy = this.User.Realname entity.CreateUserId, _ = utils.StrTo(this.User.Id).Int() entity.SupType = 1 isRepeat := false for j := 0; j < len(list); j++ { if list[j].NeedFileType == needList[i].FileName{ isRepeat = true break } } if isRepeat == true { continue } svc.InsertEntityBytbl(OilSupplierFileName, &entity) } } } var errinfo ErrorDataInfo errinfo.Message = "操作成功!" errinfo.Code = 0 this.Data["json"] = &errinfo this.ServeJSON() } // @Title 批量添加准入范围--技术服务类 // @Description 批量添加准入范围 // @Success 200 {object} business.device.DeviceChannels // @router /addtechbus [post] func (this *OilSupplierCertSubController) AddTechBus() { var jsonblob = this.Ctx.Input.RequestBody var datamain suppliercertsub.OilSupplierCertSub var dataother suppliercertsub.TechnologySubModel json.Unmarshal(jsonblob, &datamain) json.Unmarshal(jsonblob, &dataother) var supplierCertModel suppliercert.OilSupplierCert svcCert := suppliercert.GetOilSupplierCertService(utils.DBE) svcCert.GetEntityById(datamain.SupplierCertId, &supplierCertModel) var supplierModel supplier.OilSupplier svcSupplier := supplier.GetOilSupplierService(utils.DBE) svcSupplier.GetEntityById(datamain.SupplierCertId, &supplierModel) for n := 0; n < len(dataother.CheckList); n++ { where_sub := "SupplierTypeCode = 03 and SupplierId = '" + strconv.Itoa(dataother.SupplierId) + "'" where_sub += " and SupplierCertId = '" + strconv.Itoa(dataother.SupplierCertId) + "'" where_sub += " and SubClassId = '" + strconv.Itoa(dataother.CheckList[n].Id) + "'" var model suppliercertsub.OilSupplierCertSub svc := suppliercertsub.GetOilSupplierCertSubService(utils.DBE) has := svc.GetEntityByWhere(OilSupplierCertSubName, where_sub, &model) if !has { datamain.SubClassId = dataother.CheckList[n].Id datamain.Code = dataother.CheckList[n].Code datamain.Name = dataother.CheckList[n].Name datamain.Remark = dataother.Remark datamain.IsDelete = 0 datamain.CreateBy = this.User.Realname datamain.CreateUserId, _ = utils.StrTo(this.User.Id).Int() svc.InsertEntityBytbl(OilSupplierCertSubName, &datamain) paramSvc := baseparameter.GetBaseparameterService(utils.DBE) filesvc := supplierfile.GetSupplierfileService(utils.DBE) needList := filesvc.GetTechNeedFileList(dataother.CheckList[n].Id) if supplierCertModel.InStyle == "4" { var needFile supplierfile.FileList needFile.FileName = paramSvc.GetBaseparameterMessage("GFGL", "paramset", "CooperationFile") needList = append(needList, needFile) } var list []supplierfile.OilSupplierFile where := "SupplierId = '" + strconv.Itoa(dataother.SupplierId) + "'" svc.GetEntitysByWhere(OilSupplierFileName, where, &list) //三证合一或五证合一不需要的字段 mergerCertSkipField := paramSvc.GetBaseparameterMessage("GFGL", "paramset", "MergerCertSkipFieldName") //"营业执照,组织代码,组织机构代码证,税务登记证,税务登记,开户许可,银行开户许可证,承诺书,诚信合规承诺书,企业信息系统截图,战略合作协议扫描件," mustField := paramSvc.GetBaseparameterMessage("GFGL", "paramset", "MustFieldName") for i := 0; i < len(needList); i++ { var entity supplierfile.OilSupplierFile entity.SupplierId = dataother.SupplierId if (supplierModel.CredentialFlag == "1" || supplierModel.CredentialFlag == "2") && strings.Contains(mergerCertSkipField, needList[i].FileName+",") { //三证合一或五证合一了 continue } //加入对应表OilSupplierCert2File var cert2File suppliercertsub.OilSupplierCert2File //创建结构体 cert2File.SupplierId = dataother.SupplierId cert2File.SupplierCertId = dataother.SupplierCertId cert2File.SupplierTypeCode = dataother.SupplierTypeCode cert2File.SubClassId= dataother.CheckList[n].Id cert2File.Code = dataother.CheckList[n].Code cert2File.Name = dataother.CheckList[n].Name cert2File.NeedFileType = needList[i].FileName svc.InsertEntityBytbl(OilSupplierCert2FileName, &cert2File) if strings.Contains(mustField, needList[i].FileName+",") { entity.SupplierTypeCode = "000" } else { entity.SupplierTypeCode = dataother.SupplierTypeCode } entity.NeedFileType = needList[i].FileName entity.FileType = 1 entity.EffectDate = time.Now() entity.CreateBy = this.User.Realname entity.CreateUserId, _ = utils.StrTo(this.User.Id).Int() entity.SupType = 1 isRepeat := false for j := 0; j < len(list); j++ { if list[j].NeedFileType == needList[i].FileName{ isRepeat = true break } } if isRepeat == true { continue } svc.InsertEntityBytbl(OilSupplierFileName, &entity) } } } var errinfo ErrorDataInfo errinfo.Message = "操作成功!" errinfo.Code = 0 this.Data["json"] = &errinfo this.ServeJSON() } // @Title 新增准入范围 // @Description 新增准入范围 // @Success 200 {object} controllers.Request // @router /addbusiness [post] func (this *OilSupplierCertSubController) AddBusiness() { var model suppliercertsub.OilSupplierCertSub var err error var jsonblob = this.Ctx.Input.RequestBody json.Unmarshal(jsonblob, &model) model.CreateBy = this.User.Realname model.CreateUserId, _ = utils.StrTo(this.User.Id).Int() svc := suppliercertsub.GetOilSupplierCertSubService(utils.DBE) var submodel suppliercertsub.OilSupplierCertSub where_certsub := " SupplierCertId = "+ utils.ToStr(model.SupplierCertId) + " and SupplierTypeCode = 02" where_certsub += " and SubClassId = '" + utils.ToStr(model.SubClassId) + "'" has := svc.GetEntityByWhere(OilSupplierCertSubName, where_certsub, &submodel) if !has{ //添加到准入分类表中 _, err = svc.InsertEntityBytbl(OilSupplierCertSubName, &model) }else{ model.Id = submodel.Id } var supplierCertModel suppliercert.OilSupplierCert svcCert := suppliercert.GetOilSupplierCertService(utils.DBE) svcCert.GetEntityById(model.SupplierCertId, &supplierCertModel) var supplierModel supplier.OilSupplier svcSupplier := supplier.GetOilSupplierService(utils.DBE) svcSupplier.GetEntityById(model.SupplierCertId, &supplierModel) paramSvc := baseparameter.GetBaseparameterService(utils.DBE) filesvc := supplierfile.GetSupplierfileService(utils.DBE) var needList []supplierfile.FileList if model.SupplierTypeCode == "01" { // needList = filesvc.GetGoodsNeedFileList(model.SubClassId) } else if model.SupplierTypeCode == "02" { needList = filesvc.GetBasicNeedFileList(model.SubClassId) } else { // needList = filesvc.GetTechNeedFileList(model.SubClassId) } if supplierCertModel.InStyle == "4" { var needFile supplierfile.FileList needFile.FileName = paramSvc.GetBaseparameterMessage("GFGL", "paramset", "CooperationFile") needList = append(needList, needFile) } if err == nil { var list []supplierfile.OilSupplierFile where := "SupplierId = '" + strconv.Itoa(model.SupplierId) + "'" svc.GetEntitysByWhere(OilSupplierFileName, where, &list) //三证合一或五证合一不需要的字段 mergerCertSkipField := paramSvc.GetBaseparameterMessage("GFGL", "paramset", "MergerCertSkipFieldName") //"营业执照,组织代码,组织机构代码证,税务登记证,税务登记,开户许可,银行开户许可证,承诺书,诚信合规承诺书,企业信息系统截图,战略合作协议扫描件," mustField := paramSvc.GetBaseparameterMessage("GFGL", "paramset", "MustFieldName") for i := 0; i < len(needList); i++ { var entity supplierfile.OilSupplierFile entity.SupplierId = model.SupplierId //加入对应表OilSupplierCert2File var cert2File suppliercertsub.OilSupplierCert2File //创建结构体 cert2File.SupplierId = model.SupplierId cert2File.SupplierCertId = model.SupplierCertId cert2File.SupplierTypeCode = model.SupplierTypeCode cert2File.SubClassId= model.SubClassId cert2File.Code = model.Code cert2File.Name = model.Name cert2File.NeedFileType = needList[i].FileName svc.InsertEntityBytbl(OilSupplierCert2FileName, &cert2File) if (supplierModel.CredentialFlag == "1" || supplierModel.CredentialFlag == "2") && strings.Contains(mergerCertSkipField, needList[i].FileName+",") { //三证合一或五证合一了 continue } if strings.Contains(mustField, needList[i].FileName+",") { entity.SupplierTypeCode = "000" } else { entity.SupplierTypeCode = model.SupplierTypeCode } entity.NeedFileType = needList[i].FileName entity.FileType = 1 entity.EffectDate = time.Now() entity.CreateBy = this.User.Realname entity.CreateUserId, _ = utils.StrTo(this.User.Id).Int() entity.SupType = 1 isRepeat := false for j := 0; j < len(list); j++ { if list[j].NeedFileType == needList[i].FileName{ isRepeat = true break } } if isRepeat == true { continue } svc.InsertEntityBytbl(OilSupplierFileName, &entity) } } 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 // @Success 200 {object} ErrorInfo // @Failure 403 :id 为空 // @router /businessdelete/:Id [delete] func (this *OilSupplierCertSubController) BusinessDelete() { Id := this.Ctx.Input.Param(":Id") var errinfo ErrorInfo if Id == "" { errinfo.Message = "操作失败!请求信息不完整" errinfo.Code = -2 this.Data["json"] = &errinfo this.ServeJSON() return } Ids := strings.Split(Id, ",") //根据Id查出OilSupplierCertSub的SubClassId svc := suppliercertsub.GetOilSupplierCertSubService(utils.DBE) //获得数据库引擎 filesvc := supplierfile.GetSupplierfileService(utils.DBE) paramSvc := baseparameter.GetBaseparameterService(utils.DBE) for i:=0;i