|
|
@@ -4,6 +4,7 @@ import (
|
|
|
"dashoo.cn/backend/api/business/audithistory"
|
|
|
"dashoo.cn/backend/api/business/auditsetting"
|
|
|
"dashoo.cn/backend/api/business/oilsupplier/infochange"
|
|
|
+ "dashoo.cn/backend/api/business/oilsupplier/qualchange"
|
|
|
"dashoo.cn/backend/api/business/oilsupplier/supplier"
|
|
|
"dashoo.cn/backend/api/business/oilsupplier/suppliercert"
|
|
|
"dashoo.cn/backend/api/business/oilsupplier/suppliercertsub"
|
|
|
@@ -14,6 +15,7 @@ import (
|
|
|
"dashoo.cn/business2/userRole"
|
|
|
"encoding/json"
|
|
|
"fmt"
|
|
|
+ "log"
|
|
|
"reflect"
|
|
|
"strconv"
|
|
|
"strings"
|
|
|
@@ -589,7 +591,7 @@ func (this *InfoChangeController) GetChangeEntity() {
|
|
|
floatchangeinfo, _ := strconv.ParseFloat(info.ChangeInfo, 64)
|
|
|
elem.FieldByName(info.SelectItem).SetFloat(floatchangeinfo)
|
|
|
} else if elem.FieldByName(info.SelectItem).Type().String() == "time.Time" {
|
|
|
- t, _ := time.Parse("2006-01-02", info.ChangeInfo)
|
|
|
+ t, _ := time.Parse("2006-01-02", info.ChangeInfo[0 : 10])
|
|
|
elem.FieldByName(info.SelectItem).Set(reflect.ValueOf(t))
|
|
|
} else {
|
|
|
elem.FieldByName(info.SelectItem).SetString(info.ChangeInfo)
|
|
|
@@ -725,7 +727,7 @@ func (this *InfoChangeController) DelInfoChangech() {
|
|
|
svc := infochange.GetInfoChangeService(utils.DBE)
|
|
|
var infoChange infochange.OilInfoChange
|
|
|
where := "Id=" + Id + " and Status <= '0'"
|
|
|
- has1 := svc.GetEntity(infoChange, where)
|
|
|
+ has1 := svc.GetEntity(&infoChange, where)
|
|
|
if !has1 {
|
|
|
errinfo.Message = "删除失败"
|
|
|
errinfo.Code = -1
|
|
|
@@ -740,6 +742,8 @@ func (this *InfoChangeController) DelInfoChangech() {
|
|
|
svc.DeleteEntityBytbl(OilInfoChangeItemName, where)
|
|
|
where = "Id=" + Id
|
|
|
err := svc.DeleteEntityBytbl(OilInfoChangeName, where)
|
|
|
+ where = "SupplierId=" + strconv.Itoa(infoChange.SupplierId) + " and FileName=''"
|
|
|
+ err = svc.DeleteEntityBytbl(OilSupplierFileName, where)
|
|
|
|
|
|
if err == nil {
|
|
|
errinfo.Message = "删除成功"
|
|
|
@@ -754,6 +758,123 @@ func (this *InfoChangeController) DelInfoChangech() {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+// @Title 删除资质
|
|
|
+// @Description
|
|
|
+// @Success 200 {object} ErrorInfo
|
|
|
+// @Failure 403 :id 为空
|
|
|
+// @router /delfile/:Id [delete]
|
|
|
+func (this *InfoChangeController) DelFile() {
|
|
|
+ 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)
|
|
|
+ var file supplierfile.OilSupplierFile
|
|
|
+ where := "Id=" + Id
|
|
|
+ has1 := svc.GetEntity(&file, where)
|
|
|
+ if !has1 {
|
|
|
+ errinfo.Message = "删除失败"
|
|
|
+ errinfo.Code = -1
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 之前的资质改状态, 新增资质删除
|
|
|
+ var err error
|
|
|
+ if file.FileUrl != "" {
|
|
|
+ cols := []string{"IsDelete"}
|
|
|
+ file.IsDelete = 1
|
|
|
+ _, err = svc.UpdateEntityByIdCols(Id, &file, cols)
|
|
|
+ } else {
|
|
|
+ where := "FileId=" + Id
|
|
|
+ err = svc.DeleteEntityBytbl(OilQualChangeDetailName, where)
|
|
|
+ err = svc.DeleteEntityById(Id, &file)
|
|
|
+ }
|
|
|
+
|
|
|
+ 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 *InfoChangeController) 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(OilQualChangeDetailName, where)
|
|
|
+
|
|
|
+ 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 /recall [post]
|
|
|
+func (this *InfoChangeController) Recall() {
|
|
|
+ SupplierId := this.GetString("SupplierId")
|
|
|
+ SupplierTypeCode := this.GetString("SupplierTypeCode")
|
|
|
+ var errinfo ErrorInfo
|
|
|
+
|
|
|
+ svc := infochange.GetInfoChangeService(utils.DBE)
|
|
|
+ var file supplierfile.OilSupplierFile
|
|
|
+ where := "SupplierId=" + SupplierId + " and SupplierTypeCode in ('000', '" + SupplierTypeCode + "')" + " and IsDelete=1"
|
|
|
+ cols := []string{"IsDelete"}
|
|
|
+ file.IsDelete = 0
|
|
|
+ err := svc.UpdateEntityBywheretbl(OilSupplierFileName, &file, cols, where)
|
|
|
+ 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} controllers.Request
|
|
|
@@ -898,7 +1019,7 @@ func (this *InfoChangeController) AddInfoMain() {
|
|
|
var suppliermodel supplier.OilSupplier
|
|
|
var errinfo ErrorDataInfo
|
|
|
svc := infochange.GetInfoChangeService(utils.DBE)
|
|
|
- where := " SupplierId = " + SupplierId + " and Status < 4"
|
|
|
+ where := " SupplierId = " + SupplierId + " and Status < 11"
|
|
|
svc.GetEntitysByWhere(OilInfoChangeName, where, &infochm)
|
|
|
if len(infochm) > 0 {
|
|
|
errinfo.Message = "有已提交在申请中的信息变更,请审批完成后再提交!"
|
|
|
@@ -1192,6 +1313,7 @@ func (this *InfoChangeController) AuditEntity() {
|
|
|
// @Success 200 {object} controllers.Request
|
|
|
// @router /infoaudit [post]
|
|
|
func (this *InfoChangeController) InfoAudit() {
|
|
|
+ t := time.Now()
|
|
|
svc := infochange.GetInfoChangeService(utils.DBE)
|
|
|
var jsonblob = this.Ctx.Input.RequestBody
|
|
|
var dataother InfoShenHeModel
|
|
|
@@ -1304,10 +1426,10 @@ func (this *InfoChangeController) InfoAudit() {
|
|
|
myerr = svc.UpdateEntityBywheretbl(OilInfoChangeItemName, &infochangeitemmodel, []string{"ChangeStatus"}, itemswhere)
|
|
|
myerr = this.updatesupplier(OilSupplierName, dataother.SuppId, infoitems, supmodel)
|
|
|
//资质更新
|
|
|
- where := "SupplierId = " + utils.ToStr(dataother.SuppId) + " and SupType = 2"
|
|
|
- var supfilemodel supplierfile.OilSupplierFile
|
|
|
- supfilemodel.SupType = 3
|
|
|
- svc.UpdateEntityBywheretbl(OilSupplierFileName, &supfilemodel, []string{"SupType"}, where)
|
|
|
+ //where := "SupplierId = " + utils.ToStr(dataother.SuppId) + " and SupType = 2"
|
|
|
+ //var supfilemodel supplierfile.OilSupplierFile
|
|
|
+ //supfilemodel.SupType = 3
|
|
|
+ //svc.UpdateEntityBywheretbl(OilSupplierFileName, &supfilemodel, []string{"SupType"}, where)
|
|
|
|
|
|
// 级别 一级变二级 删除不符合的准入项和资质
|
|
|
for _, item := range infoitems {
|
|
|
@@ -1316,20 +1438,22 @@ func (this *InfoChangeController) InfoAudit() {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- //var qualdetail []qualchange.OilQualChangeDetail
|
|
|
- //svc.UpdateEntityBytbl(OilSupplierFileName, qualdetail[i].FileId, &supfilemodel, []string{"SupType"})
|
|
|
- //where := "SupplierId = " + utils.ToStr(dataother.SuppId)
|
|
|
- //svc.GetEntities(&qualdetail, where)
|
|
|
- //if len(qualdetail) > 0 {
|
|
|
- // for i := 0; i < len(qualdetail); i++ {
|
|
|
- // var supfilemodel supplierfile.OilSupplierFile
|
|
|
- // supfilemodel.FileName = qualdetail[i].FileName
|
|
|
- // supfilemodel.FileUrl = qualdetail[i].FileUrl
|
|
|
- // supfilemodel.EffectDate = qualdetail[i].EffectDate
|
|
|
- // supfilemodel.SupType = 3
|
|
|
- // svc.UpdateEntityBytbl(OilSupplierFileName, qualdetail[i].FileId, &supfilemodel, []string{"FileName", "FileUrl", "EffectDate","SupType"})
|
|
|
- // }
|
|
|
- //}
|
|
|
+ // 删除资质及准入项
|
|
|
+ this.FileDelete(strconv.Itoa(dataother.SuppId))
|
|
|
+ s := time.Since(t)
|
|
|
+ log.Println(s, "============================")
|
|
|
+ var qualdetail []qualchange.OilQualChangeDetail
|
|
|
+ where := "SupplierId = " + utils.ToStr(dataother.SuppId)
|
|
|
+ svc.GetEntities(&qualdetail, where)
|
|
|
+ if len(qualdetail) > 0 {
|
|
|
+ for i := 0; i < len(qualdetail); i++ {
|
|
|
+ var supfilemodel supplierfile.OilSupplierFile
|
|
|
+ supfilemodel.FileName = qualdetail[i].FileName
|
|
|
+ supfilemodel.FileUrl = qualdetail[i].FileUrl
|
|
|
+ supfilemodel.EffectDate = qualdetail[i].EffectDate
|
|
|
+ svc.UpdateEntityBytbl(OilSupplierFileName, qualdetail[i].FileId, &supfilemodel, []string{"FileName", "FileUrl", "EffectDate"})
|
|
|
+ }
|
|
|
+ }
|
|
|
}
|
|
|
infomodel.Status = status
|
|
|
infomodel.Step = step
|
|
|
@@ -1421,7 +1545,11 @@ func (this *InfoChangeController) updatesupplier(supname string, suppid int, inf
|
|
|
//cols = append(cols, infoitems[i].SelectItem)
|
|
|
where := " Id = " + utils.ToStr(suppid)
|
|
|
var sql string
|
|
|
- sql = `UPDATE ` + supname + ` set ` + infoitems[i].SelectItem + ` = '` + infoitems[i].ChangeInfo + `' where ` + where
|
|
|
+ if infoitems[i].SelectItem == "SetupTime" {
|
|
|
+ sql = `UPDATE ` + supname + ` set ` + infoitems[i].SelectItem + ` = '` + infoitems[i].ChangeInfo[0: 10] + `' where ` + where
|
|
|
+ } else {
|
|
|
+ sql = `UPDATE ` + supname + ` set ` + infoitems[i].SelectItem + ` = '` + infoitems[i].ChangeInfo + `' where ` + where
|
|
|
+ }
|
|
|
_, err = svc.DBE.Exec(sql)
|
|
|
//err = svc.UpdateEntityBytbl(OilSupplierName, suppid, &supmodel, cols)
|
|
|
}
|
|
|
@@ -1552,4 +1680,34 @@ func (this *InfoChangeController) BusinessDelete(SupplierId string) {
|
|
|
|
|
|
}
|
|
|
}
|
|
|
+}
|
|
|
+
|
|
|
+func (this *InfoChangeController) FileDelete(supplierId string) {
|
|
|
+ s := time.Now()
|
|
|
+ where := "SupplierId=" + supplierId + " and IsDelete=1"
|
|
|
+ svc := infochange.GetInfoChangeService(utils.DBE)
|
|
|
+ var delfiles []supplierfile.OilSupplierFile
|
|
|
+ svc.GetEntities(&delfiles, where)
|
|
|
+ delfilenames := ""
|
|
|
+ for _, delfile := range delfiles {
|
|
|
+ delfilenames += delfile.NeedFileType + ","
|
|
|
+ }
|
|
|
+ fmt.Println("del==" + delfilenames)
|
|
|
+ var sub []suppliercertsub.OilSupplierCertSub
|
|
|
+ weresup := "SupplierId=" + supplierId
|
|
|
+ svc.GetEntitysByWhere(OilSupplierCertSubName, weresup, &sub)
|
|
|
+ for _, item := range sub {
|
|
|
+ filesvc := supplierfile.GetSupplierfileService(utils.DBE)
|
|
|
+ needList := filesvc.GetGoodsNeedFileList(strconv.Itoa(item.SubClassId))
|
|
|
+ for _, needfile := range needList {
|
|
|
+ if strings.Index(delfilenames, needfile.FileName) > -1 {
|
|
|
+ where := "Id=" + strconv.Itoa(item.Id)
|
|
|
+ svc.DeleteEntityBytbl(OilSupplierCertSubName, where)
|
|
|
+ break
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ svc.DeleteEntityBytbl(OilSupplierFileName, where)
|
|
|
+ sp := time.Since(s)
|
|
|
+ log.Println(sp, "++++++++++++++++++++")
|
|
|
}
|