|
|
@@ -4,10 +4,13 @@ import (
|
|
|
"dashoo.cn/backend/api/business/audithistory"
|
|
|
"dashoo.cn/backend/api/business/auditsetting"
|
|
|
msg2 "dashoo.cn/backend/api/business/msg"
|
|
|
+ "dashoo.cn/backend/api/business/oilsupplier/infochange"
|
|
|
"dashoo.cn/backend/api/business/oilsupplier/oilcostmanage"
|
|
|
+ "dashoo.cn/backend/api/business/oilsupplier/qualchange"
|
|
|
"dashoo.cn/backend/api/business/oilsupplier/supplier"
|
|
|
"dashoo.cn/backend/api/business/oilsupplier/suppliercertsub"
|
|
|
"dashoo.cn/backend/api/business/oilsupplier/supplierfile"
|
|
|
+ "dashoo.cn/backend/api/business/oilsupplier/tableheader"
|
|
|
"dashoo.cn/backend/api/business/organize"
|
|
|
"dashoo.cn/backend/api/business/paymentinfo"
|
|
|
"dashoo.cn/backend/api/business/register"
|
|
|
@@ -1088,4 +1091,122 @@ func (this *OilSupplierCertAppendController) updatesupplier(supname string, supp
|
|
|
}
|
|
|
|
|
|
return err
|
|
|
+}
|
|
|
+
|
|
|
+// @Title 添加资金
|
|
|
+// @Description 添加资金
|
|
|
+// @Success 200 {object}
|
|
|
+// @router /addqualchange/:id [post]
|
|
|
+func (this *OilSupplierCertAppendController) AddAppChange() {
|
|
|
+ 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 qualchange.OilQualChangeDetail
|
|
|
+ var jsonblob = this.Ctx.Input.RequestBody
|
|
|
+ json.Unmarshal(jsonblob, &model)
|
|
|
+
|
|
|
+ svc := qualchange.GetQualChangeService(utils.DBE)
|
|
|
+
|
|
|
+ var supplierfile supplierfile.OilSupplierFile
|
|
|
+ where := "SupplierId = '" + strconv.Itoa(model.SupplierId) + "' and NeedFileType='" + model.NeedFileType + "'"
|
|
|
+ has := svc.GetEntity(&supplierfile, where)
|
|
|
+
|
|
|
+ var tableHeader tableheader.BaseTableheader
|
|
|
+ where1 := "Name = '" + model.NeedFileType + "'"
|
|
|
+ svc.GetEntityByWhere(BaseTableHeader, where1, &tableHeader)
|
|
|
+
|
|
|
+ if has {
|
|
|
+ errinfo.Message = "操作失败!不能重复添加"
|
|
|
+ errinfo.Code = -1
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ supplierfile.SupplierId = model.SupplierId
|
|
|
+ supplierfile.SupplierTypeCode = model.SupplierTypeCode
|
|
|
+ supplierfile.IsManuf = tableHeader.IsManuf
|
|
|
+ supplierfile.NeedFileType = model.NeedFileType
|
|
|
+ supplierfile.FileType = 0
|
|
|
+ supplierfile.SupType = 2
|
|
|
+ supplierfile.CreateOn = time.Now()
|
|
|
+ supplierfile.CreateUserId, _ = strconv.Atoi(this.User.Id)
|
|
|
+ supplierfile.CreateBy = this.User.Realname
|
|
|
+
|
|
|
+ svc.InsertEntity(&supplierfile)
|
|
|
+
|
|
|
+ model.ParentId, _ = strconv.Atoi(id)
|
|
|
+ model.FileId = supplierfile.Id
|
|
|
+ model.FileUrl = strings.Trim(model.FileUrl, "$")
|
|
|
+ model.FileName = strings.Trim(model.FileName, "$")
|
|
|
+
|
|
|
+ var err error
|
|
|
+ var qualdetaimodel []qualchange.OilQualChangeDetail
|
|
|
+
|
|
|
+ qdwhere := " SupplierId = " + utils.ToStr(model.SupplierId) + " and FileId = " + utils.ToStr(supplierfile.Id) + " and ParentId=" + id
|
|
|
+ svc.GetEntitysByWhere(OilAppendChangeDetailName, qdwhere, &qualdetaimodel)
|
|
|
+ if len(qualdetaimodel) == 0 {
|
|
|
+ model.CreateOn = time.Now()
|
|
|
+ model.CreateBy = this.User.Realname
|
|
|
+ model.CreateUserId, _ = utils.StrTo(this.User.Id).Int()
|
|
|
+ _, err = svc.InsertEntityBytbl(OilAppendChangeDetailName, &model)
|
|
|
+ } else {
|
|
|
+ err = svc.UpdateEntityBywheretbl(OilAppendChangeDetailName, &model, []string{"OldEffectDate", "FileUrl", "FileName", "OtherRemark"}, qdwhere)
|
|
|
+ }
|
|
|
+
|
|
|
+ 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 /deletenewfile/:Id [delete]
|
|
|
+func (this *OilSupplierCertAppendController) DeleteNewFile() {
|
|
|
+ Id := this.Ctx.Input.Param(":Id")
|
|
|
+ var errinfo ErrorInfo
|
|
|
+ if Id == "" {
|
|
|
+ errinfo.Message = "操作失败!请求信息不完整"
|
|
|
+ errinfo.Code = -2
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ svc := infochange.GetInfoChangeService(utils.DBE)
|
|
|
+
|
|
|
+ where := "FileId=" + Id
|
|
|
+ err := svc.DeleteEntityBytbl(OilAppendChangeDetailName, where)
|
|
|
+
|
|
|
+ where1 := "Id=" + Id
|
|
|
+ err = svc.DeleteEntityBytbl(OilSupplierFileName, where1)
|
|
|
+
|
|
|
+
|
|
|
+ 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()
|
|
|
+ }
|
|
|
}
|