supplier_system/src/dashoo.cn/backend/api/controllers/workflow/workflow.go

package workflow

import (
	"dashoo.cn/backend/api/business/oilsupplier/suppliercert"
	"dashoo.cn/backend/api/business/paymentinfo"
	"dashoo.cn/backend/api/business/workflow"
	. "dashoo.cn/backend/api/controllers"
	"dashoo.cn/business2/permission"
	"dashoo.cn/business2/userRole"
	"dashoo.cn/utils"
	"fmt"
	"sort"
)

// 动作接口说明
type WorkflowController struct {
	BaseController
}


// @Title get
// @Description get workflow by token
// @Success 200 {object} historicTasks
// @router /historytask [get]
func (this *WorkflowController) GetHistoricTask() {
	businessKey := this.GetString("business")
	processKey := this.GetString("process")
	processInstanceId := this.GetString("instance")

	var historicTasks []workflow.ActiHistoricTask
	svcActiviti := workflow.GetActivitiService(utils.DBE)
	historicTasks = svcActiviti.GetHistoricTasks(processKey, businessKey, processInstanceId)
	sort.Slice(historicTasks, func(i, j int) bool {
		return historicTasks[i].StartTime < historicTasks[j].StartTime
	})
	var datainfo DataInfo
	datainfo.Items = historicTasks
	this.Data["json"] = &datainfo
	this.ServeJSON()
}

// @Title get
// @Description get workflow by token
// @Success 200 {object} historicTasks
// @router /historymultitask [get]
func (this *WorkflowController) GetHistoricMultiTask() {
	businessKey := this.GetString("business")
	processKey := this.GetString("process")
	processInstanceId := this.GetString("instance")

	var historicTasks []workflow.ActiHistoricTask
	svcActiviti := workflow.GetActivitiService(utils.DBE)
	historicTasks = svcActiviti.GetHistoricMultiTasks(processKey, businessKey, processInstanceId)
	sort.Slice(historicTasks, func(i, j int) bool {
		return historicTasks[i].StartTime < historicTasks[j].StartTime
	})
	var datainfo DataInfo
	datainfo.Items = historicTasks
	this.Data["json"] = &datainfo
	this.ServeJSON()
}

// @Title 获取所有用户
// @Description get user by token
// @Success 200 {object} models.User
// @router /userlist [get]
func (this *WorkflowController) UserList() {
	keyword := this.GetString("keyword")
	svc := permission.GetPermissionService(utils.DBE)
	var users []userRole.Base_User



	where := "IsVisible=1"
	if keyword != "" {
		where = where + " and Realname like '%" + keyword + "%'"
	}
	total := svc.GetPagingEntitiesWithOrder(1, 1000, "Id", false, &users, where)

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

// @Title 获取所有用户Post
// @Description get user by token
// @Success 200 {object} models.User
// @router /userlist_post [post]
func (this *WorkflowController) UserListByPost() {
	userIds :=  this.GetString("userids")//this.Ctx.Input.Param(":userIds")
	svc := permission.GetPermissionService(utils.DBE)
	var users []userRole.Base_User



	where := "IsVisible=1"
	if userIds != "" {
		where = where + " and Id in (" + userIds + ")"
	}
	total := svc.GetPagingEntitiesWithOrder(1, 1000, "Id", false, &users, where)

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

// @Title get
// @Description get SampleType by token
// @Success 200 {object} samplesubpackage.SampleSubpackage
// @router /historyimg/:id [get]
func (this *WorkflowController) GetHistoricImg() {
	processInstanceId := this.Ctx.Input.Param(":id")
	svcActiviti := workflow.GetActivitiService(utils.DBE)
	entity := svcActiviti.GetActivitiProccessImage(processInstanceId)
	this.Ctx.Output.Body(entity)
}

// @Title 获取实体by SrcId
// @Description 获取实体by SrcId
// @Success 200 {object} paymentinfo.PaymentinfoList
// @router /getWorkflowNodeBySrcId [get]
func (this *WorkflowController) GetWorkflowNodeBySrcId() {
	srcid := this.GetString("srcid")
	var model paymentinfo.OilPaymentInfo
	svc := paymentinfo.GetPaymentService(utils.DBE)
	where := "SrcId=" + srcid
	has := svc.GetEntity(&model, where)

	fmt.Println(has)

	var historicTasks []workflow.ActiHistoricTask


	if has {
		var historicTask workflow.ActiHistoricTask
		historicTask.TaskName = "缴费"
		historicTask.StartTime = model.CreateOn.Unix() * 1000
		historicTask.EndTime = model.ModifiedOn.Unix() * 1000
		historicTask.Assignee = "--"
		if model.IsPay == "0" {
			historicTask.Remarks = "未确认"
		} else if model.IsPay == "1" {
			historicTask.Remarks = "已确认"
		} else if model.IsPay == "2" {
			historicTask.Remarks = "已缴费"
		}
		historicTasks = append(historicTasks, historicTask)
	}

	if model.IsPay == "2" {
		var cert suppliercert.OilSupplierCert
		has := svc.GetEntity(&cert, "Id=" + srcid)
		if has {
			var historicTask workflow.ActiHistoricTask
			historicTask.StartTime = 0
			historicTask.EndTime = 0
			historicTask.TaskName = "入库"
			historicTask.Assignee = "--"
			if cert.Status == "7" {
				historicTask.Remarks = "待入库"
			} else {
				historicTask.Remarks = "已入库"
			}
			historicTasks = append(historicTasks, historicTask)
		}
	}

	this.Data["json"] = &historicTasks
	this.ServeJSON()
}