supplier_system/src/dashoo.cn/backend/api/controllers/oilsupplier/supplierfile.go

package oilsupplier

import (
	"dashoo.cn/backend/api/business/oilsupplier/suppliercertsub"
	"dashoo.cn/business2/parameter"
	"encoding/json"
	"strconv"
	"strings"

	//"strings"

	//"time"
	//"fmt"

	"dashoo.cn/backend/api/business/oilsupplier/supplierfile"
	. "dashoo.cn/backend/api/controllers"
	"dashoo.cn/utils"
)

type SupplierfileController struct {
	BaseController
}

// @Title 文件上传
// @Description get user by tokenaddsubfile
// @Success 200 {object} models.Userblood
// @router /filelistall [get]
func (this *SupplierfileController) AllFileList() {
	page := this.GetPageInfoForm()
	var list []supplierfile.OilSupplierFile
	svc := supplierfile.GetSupplierfileService(utils.DBE)
	where := " 1=1"
	orderby := "Id"
	asc := true
	Order := this.GetString("Order")
	Prop := this.GetString("Prop")
	if Order != "" && Prop != "" {
		orderby = Prop
		if Order == "asc" {
			asc = true
		}
	}
	SupplierId := this.GetString("SupplierId")
	if SupplierId != "" {
		where = where + " and SupplierId = '" + SupplierId + "'"
	}
	SupplierTypeCode := this.GetString("SupplierTypeCode")
	AppendId := this.GetString("AppendId")
	if SupplierTypeCode != "" {
		where = where + " and SupplierCertSubId= "+ AppendId +" and SupplierTypeCode in ( '000', '" + SupplierTypeCode + "')"
	}
	total := svc.GetPagingEntitiesWithoutAccCode(page.CurrentPage, page.Size, orderby, asc, &list, where)
	var datainfo DataInfo
	datainfo.Items = list
	datainfo.CurrentItemCount = total
	this.Data["json"] = &datainfo
	this.ServeJSON()
}

// @Title 文件上传
// @Description get user by tokenaddsubfile
// @Success 200 {object} models.Userblood
// @router /filelistappend [get]
func (this *SupplierfileController) FileListAppend() {
	page := this.GetPageInfoForm()
	var list []supplierfile.OilSupplierFile
	svc := supplierfile.GetSupplierfileService(utils.DBE)
	where := " 1=1"
	orderby := "Id"
	asc := true
	Order := this.GetString("Order")
	Prop := this.GetString("Prop")
	if Order != "" && Prop != "" {
		orderby = Prop
		if Order == "asc" {
			asc = true
		}
	}
	SupplierId := this.GetString("SupplierId")
	if SupplierId != "" {
		where = where + " and SupplierId = '" + SupplierId + "'"
	}
	SupplierTypeCode := this.GetString("SupplierTypeCode")
	AppendId := this.GetString("AppendId")
	if SupplierTypeCode != "" {
		where = where + " and SupplierCertSubId= "+ AppendId +" and SupplierTypeCode in ( '000', '" + SupplierTypeCode + "')"
	}
	where = where + " and SupType != 1"
	total := svc.GetPagingEntitiesWithoutAccCode(page.CurrentPage, page.Size, orderby, asc, &list, where)
	var datainfo DataInfo
	datainfo.Items = list
	datainfo.CurrentItemCount = total
	this.Data["json"] = &datainfo
	this.ServeJSON()
}

// @Title 文件上传
// @Description get user by tokenaddsubfile
// @Success 200 {object} models.Userblood
// @router /filelist [get]
func (this *SupplierfileController) FileList() {
	page := this.GetPageInfoForm()
	var list []supplierfile.OilSupplierFile
	svc := supplierfile.GetSupplierfileService(utils.DBE)
	where := " 1=1"
	orderby := "Id"
	asc := true
	Order := this.GetString("Order")
	Prop := this.GetString("Prop")

	if Order != "" && Prop != "" {
		orderby = Prop
		if Order == "asc" {
			asc = true
		}
	}
	SupplierId := this.GetString("SupplierId")
	if SupplierId != "" {
		where = where + " and SupplierId = '" + SupplierId + "'"
	}
	SupplierTypeCode := this.GetString("SupplierTypeCode")
	if SupplierTypeCode != "" {
		where = where + " and SupplierTypeCode in ( '000', '" + SupplierTypeCode + "')"
	}
	InStyle := this.GetString("InStyle")
	if InStyle != "4" {
		//paramSvc := baseparameter.GetBaseparameterService(utils.DBE)
		//var needFileType string
		//needFileType = paramSvc.GetBaseparameterMessage("GFGL", "paramset", "CooperationFile")
		where = where + " and NeedFileType not like  '%战略%' "
	}
	where = where + " and SupType != 2"

	SubClassIds := this.GetString("SubClassIds")
	if SubClassIds!=""{
		inWhere:="("+SubClassIds+")"
		sql:=" SupplierId="+SupplierId+" and SubClassId in "+inWhere
		var result []suppliercertsub.OilSupplierCert2File
		svc.GetEntities(&result,sql)
		str:=""
		if result!=nil{

			for i:=0;i<len(result);i++{
				str = str + "'"+result[i].NeedFileType+"',"
			}

		}
		where=where +" and NeedFileType in ("+str[0:len(str)-1]+")"
	}


	total := svc.GetPagingEntitiesWithoutAccCode(page.CurrentPage, page.Size, orderby, asc, &list, where)
	var datainfo DataInfo
	datainfo.Items = list
	datainfo.CurrentItemCount = total
	this.Data["json"] = &datainfo
	this.ServeJSON()
}

// @Title 文件上传
// @Description 文件上传
// @Success	200	{object} controllers.Request
// @router /addsubfile [post]
func (this *SupplierfileController) AddSubfile() {
	var model supplierfile.OilSupplierFile
	svc := supplierfile.GetSupplierfileService(utils.DBE)

	var jsonblob = this.Ctx.Input.RequestBody
	json.Unmarshal(jsonblob, &model)
	model.FileUrl = strings.Trim(model.FileUrl, "$")
	model.FileName = strings.Trim(model.FileName, "$")
	model.CreateBy = this.User.Realname
	model.CreateUserId, _ = utils.StrTo(this.User.Id).Int()

	var list []supplierfile.OilSupplierFile
	where := "SupplierId = '" + strconv.Itoa(model.SupplierId) + "'"
	svc.GetEntitysByWhere(OilSupplierFileName, where, &list)
	hasField := ""
	for i := 0; i < len(list); i++ {
		hasField += list[i].NeedFileType + ","
	}

	var errinfo ErrorDataInfo
	if strings.Contains(hasField, model.NeedFileType+",") {
		//已存在，不能重复添加
		errinfo.Message = "操作失败！不能重复添加"
		errinfo.Code = -1
		this.Data["json"] = &errinfo
		this.ServeJSON()
		return
	}

	_, err := svc.InsertEntityBytbl(OilSupplierFileName, &model)
	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 get user by token
// @Success 200 {object} map[string]interface{}
// @router /dictlist [get]
func (this *SupplierfileController) GetDictList() {
	dictList := make(map[string]interface{})
	var ysname string
	paramSvc := baseparameter.GetBaseparameterService(utils.DBE)
	ysname = paramSvc.GetBaseparameterMessage("", "paramset", "YaSuoBao")
	dictList["YaSuoName"] = ysname

	var datainfo DataInfo
	datainfo.Items = dictList
	this.Data["json"] = &datainfo
	this.ServeJSON()
}

// @Title 更新文件上传
// @Description 更新文件上传
// @Param	id	path	string	true
// @Success	200	{object}
// @router /editsubfile/:id [put]
func (this *SupplierfileController) EditSubfile() {
	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 supplierfile.OilSupplierFile
	var jsonblob = this.Ctx.Input.RequestBody
	json.Unmarshal(jsonblob, &model)
	svc := supplierfile.GetSupplierfileService(utils.DBE)

	var list []supplierfile.OilSupplierFile
	where := "SupplierId = '" + strconv.Itoa(model.SupplierId) + "'"
	svc.GetEntitysByWhere(OilSupplierFileName, where, &list)

	var entity supplierfile.OilSupplierFile
	model.FileUrl = strings.Trim(model.FileUrl, "$")
	model.FileName = strings.Trim(model.FileName, "$")
	model.ModifiedBy = this.User.Realname
	model.ModifiedUserId, _ = utils.StrTo(this.User.Id).Int()

	opdesc := "编辑文件上传-" + model.NeedFileType
	var cols []string = []string{"SupplierCertSubId", "CertSubName", "NeedFileType", "NeedFileCode", "FileName", "EffectDate", "FileUrl", "OtherRemark", "Remark", "IsDelete", "ModifiedBy", "ModifiedUserId"}
	err := svc.UpdateOperationAndWriteLogBytbl(OilSupplierFileName, BaseOperationLogName, id, &model, &entity, cols, 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} ErrorInfo
// @Failure 403 :id 为空
// @router /subfiledelete/:Id [delete]
func (this *SupplierfileController) SubfileDelete() {
	Id := this.Ctx.Input.Param(":Id")
	var errinfo ErrorInfo
	if Id == "" {
		errinfo.Message = "操作失败！请求信息不完整"
		errinfo.Code = -2
		this.Data["json"] = &errinfo
		this.ServeJSON()
		return
	}
	where := " Id= " + Id
	svc := supplierfile.GetSupplierfileService(utils.DBE)
	err := svc.DeleteEntityBytbl(OilSupplierFileName, 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()
	}
}