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

package oilsupplier

import (
	"dashoo.cn/backend/api/business/audithistory"
	"dashoo.cn/backend/api/business/codecsequence"
	msg2 "dashoo.cn/backend/api/business/msg"
	"dashoo.cn/backend/api/business/oilsupplier/oilcostmanage"
	"dashoo.cn/backend/api/business/oilsupplier/supplier"
	"dashoo.cn/backend/api/business/oilsupplier/suppliercertsub"
	"dashoo.cn/backend/api/business/organize"
	"dashoo.cn/backend/api/business/paymentinfo"
	"dashoo.cn/business2/parameter"
	"encoding/json"
	"fmt"
	"strconv"
	"strings"
	"time"

	"dashoo.cn/backend/api/business/auditsetting"

	"dashoo.cn/backend/api/business/workflow"

	"dashoo.cn/backend/api/business/baseUser"
	"dashoo.cn/backend/api/business/oilsupplier/suppliercert"
	. "dashoo.cn/backend/api/controllers"
	"dashoo.cn/business2/userRole"
	"dashoo.cn/utils"
)

type OilSupplierCertController struct {
	BaseController
}

// @Title 获取列表
// @Description get user by token
// @Success 200 {object} []suppliercert.OilSupplierCert
// @router /list [get]
func (this *OilSupplierCertController) 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")
	AccessCardNo := this.GetString("AccessCardNo")
	SupplierTypeCode := this.GetString("SupplierTypeCode")
	SupplierTypeName := this.GetString("SupplierTypeName")
	RecUnitReason := this.GetString("RecUnitReason")
	RecUnitPerson := this.GetString("RecUnitPerson")
	RecDate := this.GetString("RecDate")
	RecUnitId := this.GetString("RecUnitId")
	RecUnitName := this.GetString("RecUnitName")
	StatusA := this.GetString("StatusA")
	BackReason := this.GetString("BackReason")
	InFlag := this.GetString("InFlag")
	EffectStartTime := this.GetString("EffectStartTime")
	EffectEndTime := this.GetString("EffectEndTime")
	AuditProcessNote := this.GetString("AuditProcessNote")
	AuditDate := this.GetString("AuditDate")
	PayNotice := this.GetString("PayNotice")
	SupplierStatus := this.GetString("SupplierStatus")
	MgrType := this.GetString("MgrType")
	Type := this.GetString("Type")
	MgrUnit := this.GetString("MgrUnit")
	AddinTime := this.GetString("AddinTime")
	EffectTime := this.GetString("EffectTime")
	ApplyTime := this.GetString("ApplyTime")
	SupplierNo := this.GetString("SupplierNo")
	MDMFlag := this.GetString("MDMFlag")
	InternalFlag := this.GetString("InternalFlag")
	ImportFlag := this.GetString("ImportFlag")
	OutsideFlog := this.GetString("OutsideFlog")
	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 AccessCardNo != "" {
		where = where + " and AccessCardNo like '%" + AccessCardNo + "%'"
	}

	if SupplierTypeCode != "" {
		where = where + " and SupplierTypeCode like '%" + SupplierTypeCode + "%'"
	}

	if SupplierTypeName != "" {
		where = where + " and SupplierTypeName like '%" + SupplierTypeName + "%'"
	}

	if RecUnitReason != "" {
		where = where + " and RecUnitReason like '%" + RecUnitReason + "%'"
	}

	if RecUnitPerson != "" {
		where = where + " and RecUnitPerson like '%" + RecUnitPerson + "%'"
	}

	if RecDate != "" {
		where = where + " and RecDate like '%" + RecDate + "%'"
	}

	if RecUnitId != "" {
		where = where + " and RecUnitId like '%" + RecUnitId + "%'"
	}

	if RecUnitName != "" {
		where = where + " and RecUnitName like '%" + RecUnitName + "%'"
	}

	if StatusA != "" {
		where = where + " and StatusA like '%" + StatusA + "%'"
	}

	if BackReason != "" {
		where = where + " and BackReason like '%" + BackReason + "%'"
	}

	if InFlag != "" {
		where = where + " and InFlag like '%" + InFlag + "%'"
	}

	if EffectStartTime != "" {
		where = where + " and EffectStartTime like '%" + EffectStartTime + "%'"
	}

	if EffectEndTime != "" {
		where = where + " and EffectEndTime like '%" + EffectEndTime + "%'"
	}

	if AuditProcessNote != "" {
		where = where + " and AuditProcessNote like '%" + AuditProcessNote + "%'"
	}

	if AuditDate != "" {
		where = where + " and AuditDate like '%" + AuditDate + "%'"
	}

	if PayNotice != "" {
		where = where + " and PayNotice like '%" + PayNotice + "%'"
	}

	if SupplierStatus != "" {
		where = where + " and SupplierStatus like '%" + SupplierStatus + "%'"
	}

	if MgrType != "" {
		where = where + " and MgrType like '%" + MgrType + "%'"
	}

	if Type != "" {
		where = where + " and Type like '%" + Type + "%'"
	}

	if MgrUnit != "" {
		where = where + " and MgrUnit like '%" + MgrUnit + "%'"
	}

	if AddinTime != "" {
		where = where + " and AddinTime like '%" + AddinTime + "%'"
	}

	if EffectTime != "" {
		where = where + " and EffectTime like '%" + EffectTime + "%'"
	}

	if ApplyTime != "" {
		where = where + " and ApplyTime like '%" + ApplyTime + "%'"
	}

	if SupplierNo != "" {
		where = where + " and SupplierNo like '%" + SupplierNo + "%'"
	}

	if MDMFlag != "" {
		where = where + " and MDMFlag like '%" + MDMFlag + "%'"
	}

	if InternalFlag != "" {
		where = where + " and InternalFlag like '%" + InternalFlag + "%'"
	}

	if ImportFlag != "" {
		where = where + " and ImportFlag like '%" + ImportFlag + "%'"
	}

	if OutsideFlog != "" {
		where = where + " and OutsideFlog like '%" + OutsideFlog + "%'"
	}

	if Remark != "" {
		where = where + " and Remark like '%" + Remark + "%'"
	}

	if IsDelete != "" {
		where = where + " and IsDelete like '%" + IsDelete + "%'"
	}

	if CreateOn != "" {
		where = where + " and CreateOn like '%" + CreateOn + "%'"
	}

	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 + "'"
		}
	}

	svc := suppliercert.GetOilSupplierCertService(utils.DBE)
	var list []suppliercert.OilSupplierCert
	total := svc.GetPagingEntitiesWithOrderBytbl(this.User.AccCode, 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 *OilSupplierCertController) 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} suppliercert.OilSupplierCert
// @router /get/:id [get]
func (this *OilSupplierCertController) GetEntity() {
	Id := this.Ctx.Input.Param(":id")

	var model suppliercert.OilSupplierCert
	svc := suppliercert.GetOilSupplierCertService(utils.DBE)
	svc.GetEntityByIdBytbl(OilSupplierCertName, Id, &model)

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

// @Title 获取实体
// @Description 获取实体
// @Success 200 {object} suppliercert.OilSupplierCert
// @router /getbycreatorandtype/:typecode [get]
func (this *OilSupplierCertController) GetEntityByCreatorId() {
	creatorId := this.User.Id
	typeCode := this.Ctx.Input.Param(":typecode")

	var model suppliercert.OilSupplierCert
	svc := suppliercert.GetOilSupplierCertService(utils.DBE)
	where := " CreateUserId = '" + creatorId + "'"
	where += " and SupplierTypeCode = '" + typeCode + "'"
	svc.GetEntityByWhere(OilSupplierCertName, where, &model)

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

// @Title 添加
// @Description 新增
// @Success	200	{object} controllers.Request
// @router /add [post]
func (this *OilSupplierCertController) AddEntity() {
	var model suppliercert.OilSupplierCert
	var jsonBlob = this.Ctx.Input.RequestBody
	svc := suppliercert.GetOilSupplierCertService(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(OilSupplierCertName, &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 *OilSupplierCertController) 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 suppliercert.OilSupplierCert
	svc := suppliercert.GetOilSupplierCertService(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",

		"AccessCardNo",

		"SupplierTypeCode",

		"SupplierTypeName",

		"RecUnitReason",

		"RecUnitPerson",

		"RecDate",

		"RecUnitId",

		"RecUnitName",

		"Status",

		"BackReason",

		"InFlag",

		"EffectStartTime",

		"EffectEndTime",

		"AuditProcessNote",

		"AuditDate",

		"PayNotice",

		"SupplierStatus",

		"MgrType",

		"Type",

		"MgrUnit",

		"AddinTime",

		"EffectTime",

		"ApplyTime",

		"SupplierNo",

		"MDMFlag",

		"InternalFlag",

		"ImportFlag",

		"OutsideFlog",

		"Remark",

		"IsDelete",

		"CreateOn",

		"CreateUserId",

		"CreateBy",

		"ModifiedOn",

		"ModifiedUserId",

		"ModifiedBy",
	}
	err := svc.UpdateEntityBytbl(OilSupplierCertName, 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} controllers.Request
// @router /updatestorage/:id [post]
func (this *OilSupplierCertController) UpdateStorage() {
	id := this.Ctx.Input.Param(":id")
	status := this.GetString("Status")
	var errinfo ErrorInfo
	if id == "" {
		errinfo.Message = "操作失败！请求信息不完整"
		errinfo.Code = -2
		this.Data["json"] = &errinfo
		this.ServeJSON()
		return
	}

	var model suppliercert.OilSupplierCert
	svc := suppliercert.GetOilSupplierCertService(utils.DBE)

	//var jsonBlob = this.Ctx.Input.RequestBody
	//json.Unmarshal(jsonBlob, &model)
	var err error
	if status == suppliercert.NO_CENT_AUDIT_STATUS {
		model.Status = suppliercert.DRAFT_STATUS
		cols := []string{
			"Status",
		}
		err = svc.UpdateEntityBytbl(OilSupplierCertName, id, &model, cols)
	} else {
		model.Status = suppliercert.STORE_STATUS
		model.Step = 7
		model.StorageOn = time.Now()
		model.ApplyTime = time.Now().AddDate(1, 0 ,0)
		model.InFlag = "1"
		model.ModifiedOn = time.Now()
		model.ModifiedBy = this.User.Realname
		model.ModifiedUserId, _ = utils.StrTo(this.User.Id).Int()

		cols := []string{
			"Step",
			"Status",
			"ApplyTime",
			"InFlag",
			"StorageOn",
			"ModifiedOn",
			"ModifiedUserId",
			"ModifiedBy",
		}
		err = svc.UpdateEntityBytbl(OilSupplierCertName, 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 *OilSupplierCertController) 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 suppliercert.OilSupplierCert
	var entityempty suppliercert.OilSupplierCert
	svc := suppliercert.GetOilSupplierCertService(utils.DBE)
	opdesc := "删除-" + Id
	err := svc.DeleteOperationAndWriteLogBytbl(OilSupplierCertName, 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} controllers.Request
// @router /audit/:id [post]
func (this *OilSupplierCertController) AuditEntity() {
	certId := this.Ctx.Input.Param(":id")
	firstAudit := this.GetString("FirstAuditName")
	AuditRemark := this.GetString("AuditRemark")
	secondAudit := this.GetString("SecondAudit")
	thirdAudit := this.GetString("ThirdAudit")

	var setting auditsetting.Base_OilAuditSetting
	var userlist []userRole.Base_User
	usvc := userRole.GetUserService(utils.DBE)
	if this.User.IsCompanyUser == 1 {
		where := "AuditStepCode='" + workflow.SUB_OFFICE + "'"
		usvc.GetEntity(&setting, where)
		ids := usvc.GetUserIdsByRoleId(strconv.Itoa(setting.RoleId))
		tempstr := strings.Join(ids, ",")
		uids := strings.Replace(tempstr, "uid_", "", -1)
		uids = strings.Trim(uids, ",")
		if uids != "" {
			where := "Id in (" + uids + ")" + " and UnitId=" + firstAudit
			usvc.GetEntities(&userlist, where)
		}
		userIds := ""
		for _, tmpUser := range userlist {
			userIds += strconv.Itoa(tmpUser.Id) + ","
		}
		firstAudit = strings.Trim(userIds, ",")
	}
	//取出审批列表
	certSrv := suppliercert.GetOilSupplierCertService(utils.DBE)
	var supplierCertEntity suppliercert.OilSupplierCert
	certSrv.GetEntityById(certId, &supplierCertEntity)

	svc := organize.GetOrganizeService(utils.DBE)
	unitId := svc.GetMyUnitDepartmentId(this.User.DepartmentId)

	var errinfo ErrorDataInfo
	defer func() { //finally处理失败的异常
		if err := recover(); err != nil {
			errinfo.Message = "提交失败，" + err.(string)
			errinfo.Code = -1
			this.Data["json"] = &errinfo
			this.ServeJSON()
		} else {
			//返回正确结果
			errinfo.Message = "审核提交成功"
			errinfo.Code = 0
			this.Data["json"] = &errinfo
			this.ServeJSON()
		}
	}()

	////判断当前部门是否企业用户
	//result := "1"
	//if this.User.IsCompanyUser == 1 {
	//	result = "0"
	//}

	svcActiviti := workflow.GetActivitiService(utils.DBE)
	////获得有审核权限的人员
	//var users []userRole.Base_RoleList
	//var userIds string
	//var auditWorkflow auditsetting.Base_OilAuditSetting
	//rsvc := auditsetting.GetOilAuditSettingService(utils.DBE)
	//rsvc.GetAuditStepRoleEntity(OilAuditSettingName, firstAudit, workflow.FIRST_TRIAL, &auditWorkflow)
	//users = rsvc.GetUserByRole(strconv.Itoa(auditWorkflow.RoleId), this.User.AccCode) //

	processInstanceId := ""
	businessKey := ""
	if supplierCertEntity.WorkflowId == "0" || len(supplierCertEntity.WorkflowId) <= 0 {
		//启动工作流
		businessKey = certId + "-" +  strconv.Itoa(supplierCertEntity.AuditIndex)
		if this.User.IsCompanyUser == 1 {
			if supplierCertEntity.InStyle == "2" {
				processInstanceId = svcActiviti.StartProcess(workflow.OIL_FIRST_ENUSER_SUPPLIER_APPLY, businessKey, this.User.Id)
			} else if supplierCertEntity.InStyle == "3" {
				processInstanceId = svcActiviti.StartProcess(workflow.OIL_SECOND_ENUSER_SUPPLIER_APPLY, businessKey, this.User.Id)
			} else {
				processInstanceId = svcActiviti.StartProcess(workflow.OIL_ENUSER_SUPPLIER_APPLY, businessKey, this.User.Id)
			}
		}else if this.User.IsCompanyUser == 0 {
			if supplierCertEntity.InStyle == "2" {
				processInstanceId = svcActiviti.StartProcess(workflow.OIL_FIRST_SUPPLIER_APPLY, businessKey, this.User.Id)
			} else if supplierCertEntity.InStyle == "3" {
				processInstanceId = svcActiviti.StartProcess(workflow.OIL_SECOND_SUPPLIER_APPLY, businessKey, this.User.Id)
			} else {
				processInstanceId = svcActiviti.StartProcess(workflow.OIL_SUPPLIER_APPLY, businessKey, this.User.Id)
			}
		}

	} else {
		processInstanceId = supplierCertEntity.WorkflowId
	}

	//processInstanceId,_ := certSrv.SubmitOrgAudit(certId, workflow.OIL_SUPPLIER_APPLY, workflow.FIRST_TRIAL, this.User.Id, result, "提交给二级单位初审", OilSupplierCertSubName, OilClassOrgSettingName, "", "")
	//for _, tmpUser := range users {
	//	userIds += strconv.FormatInt(tmpUser.Id, 10) + ","
	//}
	//userIds = strings.Trim(userIds, ",")
	var ActiComplete workflow.ActiCompleteVM
	if this.User.IsCompanyUser == 1 {
		if supplierCertEntity.InStyle == "2" {
			ActiComplete.ProcessKey = workflow.OIL_FIRST_ENUSER_SUPPLIER_APPLY
		} else if supplierCertEntity.InStyle == "3" {
			ActiComplete.ProcessKey = workflow.OIL_SECOND_ENUSER_SUPPLIER_APPLY
		} else {
			ActiComplete.ProcessKey = workflow.OIL_ENUSER_SUPPLIER_APPLY
		}
	}else if this.User.IsCompanyUser == 0 {
		if supplierCertEntity.InStyle == "2" {
			ActiComplete.ProcessKey = workflow.OIL_FIRST_SUPPLIER_APPLY
		} else if supplierCertEntity.InStyle == "3" {
			ActiComplete.ProcessKey = workflow.OIL_SECOND_SUPPLIER_APPLY
		} else {
			ActiComplete.ProcessKey = workflow.OIL_SUPPLIER_APPLY
		}
	}

	ActiComplete.BusinessKey = businessKey
	ActiComplete.UserNames = firstAudit
	ActiComplete.UserId = this.User.Id
	ActiComplete.Result = "1"
	ActiComplete.Remarks = AuditRemark
	ActiComplete.CallbackUrl = ""
	receiveVal := svcActiviti.TaskComplete(ActiComplete)

	if receiveVal == "true" {
		errinfo.Message = "提交成功！"
		errinfo.Code = 0
		this.Data["json"] = &errinfo
		this.ServeJSON()
	} else {
		errinfo.Message = "工作流异常，请联系管理员！"
		errinfo.Code = -1
		this.Data["json"] = &errinfo
		this.ServeJSON()
		return
	}

	fmt.Println("-----------processInstanceId------------")
	//记下workflowID(首次提交时才会记录，中间状态请忽略) 及审批状态

	supplierCertEntity.WorkflowId = processInstanceId
	if this.User.IsCompanyUser == 1 {
		supplierCertEntity.Status = suppliercert.FEN_TRIAL_STATUS //分办
	}else if this.User.IsCompanyUser == 0 {
		supplierCertEntity.Status = suppliercert.FIRST_TRIAL_STATUS //二级单位初审
	}

	supplierCertEntity.Step = 2
	supplierCertEntity.FirstAudit, _ = strconv.Atoi(firstAudit)
	supplierCertEntity.AuditIndex = supplierCertEntity.AuditIndex + 1
	supplierCertEntity.BusinessKey = ActiComplete.BusinessKey
	supplierCertEntity.SecondAudit,_ = strconv.Atoi(secondAudit)
	supplierCertEntity.ThirdAudit,_ = strconv.Atoi(thirdAudit)
	supplierCertEntity.ProcessKey = ActiComplete.ProcessKey
	supplierCertEntity.CommitComId = unitId
	cols := []string{
		"Id",
		"WorkflowId",
		"Status",
		"Step",
		"FirstAudit",
		"AuditIndex",
		"BusinessKey",
		"SecondAudit",
		"ThirdAudit",
		"ProcessKey",
		"CommitComId",
	}
	certSrv.UpdateEntityByIdCols(certId, supplierCertEntity, cols)

	//var model classorgsetting.OilClassOrgSetting
	//var jsonBlob = this.Ctx.Input.RequestBody
	//svc := suppliercert.GetOilSupplierCertService(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()
	//
	//svc.InsertEntityBytbl(OilSupplierCertName, &model)
	//fmt.Println(model)

}

// @Title 专业审批
// @Description 准入初审提交审批
// @Success	200	{object} controllers.Request
// @router /admission/:id [post]
func (this *OilSupplierCertController) AuditEntityadmission() {
	certId := this.Ctx.Input.Param(":id")
	var errinfo ErrorDataInfo
	defer func() { //finally处理失败的异常
		if err := recover(); err != nil {
			errinfo.Message = "提交失败，" + err.(string)
			errinfo.Code = -1
			this.Data["json"] = &errinfo
			this.ServeJSON()
		} else {
			//返回正确结果
			errinfo.Message = "审核提交成功"
			errinfo.Code = 0
			this.Data["json"] = &errinfo
			this.ServeJSON()
		}
	}()
	//取出审批列表
	certSrv := suppliercert.GetOilSupplierCertService(utils.DBE)
	certSrv.SubmitOrgAudit(certId, workflow.OIL_SUPPLIER_APPLY, workflow.PROF_AUDIT, this.User.Id, "1", "提交给专业科室审核", OilSupplierCertSubName, OilClassOrgSettingName, "", "")
	//记下workflowID(首次提交时才会记录，中间状态请忽略) 及审批状态
	var supplierCertEntity suppliercert.OilSupplierCert
	certSrv.GetEntityById(certId, supplierCertEntity)
	supplierCertEntity.Status = suppliercert.PROF_AUDIT_STATUS //二级单位初审
	cols := []string{
		"Id",
		"Status",
	}
	certSrv.UpdateEntityByIdCols(certId, supplierCertEntity, cols)
}


// @Title 审批
// @Description 审批
// @Param 	body body suppliercert.OilSupplierCert
// @Success	200	{object} controllers.Request
// @router /auditEntityFir/:id [post]
func (this *OilSupplierCertController) AuditEntityFir() {
	var dataother ShenHeModel
	certId := this.Ctx.Input.Param(":id")
	auditer := this.GetString("auditer")
	firstAudit := this.GetString("FirstAuditName")
	AuditRemark := this.GetString("AuditRemark")
	secondAudit := this.GetString("SecondAudit")
	thirdAudit := this.GetString("ThirdAudit")
	//majorDept := this.GetString("majorDept")


	//取出审批列表
	certSrv := suppliercert.GetOilSupplierCertService(utils.DBE)
	var supplierCertEntity suppliercert.OilSupplierCert
	var supplierEntity supplier.OilSupplier
	certSrv.GetEntityById(certId, &supplierCertEntity)
	wheresup := "Id=" + strconv.Itoa(supplierCertEntity.SupplierId)
	certSrv.GetEntity(&supplierEntity, wheresup)
	var jsonblob = this.Ctx.Input.RequestBody
	json.Unmarshal(jsonblob, &dataother)
	if AuditRemark != "" {
		dataother.AuditorRemark = AuditRemark
	}
	var errinfo ErrorDataInfo
	defer func() { //finally处理失败的异常
		if err := recover(); err != nil {
			errinfo.Message = "提交失败，" + err.(string)
			errinfo.Code = -1
			this.Data["json"] = &errinfo
			this.ServeJSON()
		} else {
			//返回正确结果
			errinfo.Message = "审核提交成功"
			errinfo.Code = 0
			this.Data["json"] = &errinfo
			this.ServeJSON()
		}
	}()

	//remarks := ""
	step := 2
	status := ""
	backstatus := "0"
	var userIds string

	if supplierCertEntity.Status == suppliercert.FEN_TRIAL_STATUS {
		userIds = firstAudit
		status = suppliercert.FIRST_TRIAL_STATUS
		step = 2
		supplierCertEntity.Step = 2
		supplierCertEntity.FirstAudit, _ = strconv.Atoi(firstAudit)
		supplierCertEntity.SecondAudit,_ = strconv.Atoi(secondAudit)
		supplierCertEntity.ThirdAudit,_ = strconv.Atoi(thirdAudit)
		cols := []string{
			"Id",
			"Step",
			"FirstAudit",
			"SecondAudit",
			"ThirdAudit",
		}
		certSrv.UpdateEntityByIdCols(certId, supplierCertEntity, cols)
	}
	if supplierCertEntity.Status == suppliercert.FIRST_TRIAL_STATUS {
		userIds = utils.ToStr(supplierCertEntity.SecondAudit)
		status = suppliercert.SECOND_TRIAL_STATUS
		backstatus = suppliercert.NOPASS_STATUS
		step = 2
		//supplierCertEntity.ThirdAudit,_ = strconv.Atoi(majorDept)
		//cols := []string{
		//	"ThirdAudit",
		//}
		//certSrv.UpdateEntityByIdCols(certId, supplierCertEntity, cols)
	} else if supplierCertEntity.Status == suppliercert.SECOND_TRIAL_STATUS {
		step = 2
		backstatus = suppliercert.NO_SECOND_TRIAL_STATUS

		svc := organize.GetOrganizeService(utils.DBE)
		unitId := svc.GetMyUnitDepartmentId(strconv.Itoa(supplierCertEntity.ThirdAudit))
		var userlist []userRole.Base_User
		var setting auditsetting.Base_OilAuditSetting
		usvc := userRole.GetUserService(utils.DBE)

		if supplierCertEntity.InStyle == "2" {
			status = suppliercert.CENT_AUDIT_STATUS
			where := "AuditStepCode='" + workflow.PROF_REGULATION + "'"
			usvc.GetEntity(&setting, where)
			paramSvc := baseparameter.GetBaseparameterService(utils.DBE)
			topid := paramSvc.GetBaseparameterMessage("", "paramset", "CENT_AUDIT")
			ids := usvc.GetUserIdsByRoleId(strconv.Itoa(setting.RoleId))
			tempstr := strings.Join(ids, ",")
			uids := strings.Replace(tempstr, "uid_", "", -1)
			uids = strings.Trim(uids, ",")
			if uids != "" {
				where := "Id in (" + uids + ")" + " and UnitId=" + topid
				usvc.GetEntities(&userlist, where)
			}
		} else {
			status = suppliercert.THIRD_TRIAL_STATUS
			where := "AuditStepCode='" + workflow.PROF_RECE + "'"
			svc.GetEntity(&setting, where)

			ids := usvc.GetUserIdsByRoleId(strconv.Itoa(setting.RoleId))
			tempstr := strings.Join(ids, ",")
			uids := strings.Replace(tempstr, "uid_", "", -1)
			uids = strings.Trim(uids, ",")
			if uids != "" {
				where := "Id in (" + uids + ")" + " and UnitId=" + unitId
				svc.GetEntities(&userlist, where)
			}
		}

		//var users []userRole.Base_RoleList
		//certSrv.GetAuditUser(strconv.Itoa(supplierCertEntity.ThirdAudit), workflow.PROF_RECE, &users)


		for _, tmpUser := range userlist {
			userIds += strconv.Itoa(tmpUser.Id) + "," //strconv.FormatInt(tmpUser.Id, 10) + ","
		}
		userIds = strings.Trim(userIds, ",")

		step = 2
		backstatus = suppliercert.NO_SECOND_TRIAL_STATUS

	} else if supplierCertEntity.Status == suppliercert.THIRD_TRIAL_STATUS {
		userIds = auditer
		status = suppliercert.PROF_AUDIT_STATUS
		step = 2
		backstatus = suppliercert.NO_THIRD_TRIAL_STATUS
	} else if supplierCertEntity.Status == suppliercert.PROF_AUDIT_STATUS {
		if supplierCertEntity.InStyle == "3" {
			userIds = auditer
			status = suppliercert.PAYING_AUDIT_STATUS
			step = 3
			backstatus = suppliercert.NO_CENT_AUDIT_STATUS
		} else {
			status = suppliercert.CENT_AUDIT_STATUS
			step = 2
			backstatus = suppliercert.NO_PROF_AUDIT_STATUS

			paramSvc := baseparameter.GetBaseparameterService(utils.DBE)
			topid := paramSvc.GetBaseparameterMessage("", "paramset", "CENT_AUDIT")

			var userlist []userRole.Base_User
			var setting auditsetting.Base_OilAuditSetting
			usvc := userRole.GetUserService(utils.DBE)
			where := "AuditStepCode='" + workflow.PROF_REGULATION + "'"
			usvc.GetEntity(&setting, where)

			ids := usvc.GetUserIdsByRoleId(strconv.Itoa(setting.RoleId))
			tempstr := strings.Join(ids, ",")
			uids := strings.Replace(tempstr, "uid_", "", -1)
			uids = strings.Trim(uids, ",")
			if uids != "" {
				where := "Id in (" + uids + ")" + " and UnitId=" + topid
				usvc.GetEntities(&userlist, where)
			}
			for _, tmpUser := range userlist {
				userIds += strconv.Itoa(tmpUser.Id) + ","
			}

			userIds = strings.Trim(userIds, ",")
		}

	} else if supplierCertEntity.Status == suppliercert.CENT_AUDIT_STATUS {
		userIds = auditer
		status = suppliercert.PAYING_AUDIT_STATUS
		step = 3
		backstatus = suppliercert.NO_CENT_AUDIT_STATUS
	}

	svcActiviti := workflow.GetActivitiService(utils.DBE)
	var ActiComplete workflow.ActiCompleteVM
	ActiComplete.ProcessKey = supplierCertEntity.ProcessKey
	ActiComplete.BusinessKey = supplierCertEntity.BusinessKey
	ActiComplete.UserNames = userIds
	ActiComplete.UserId = this.User.Id
	ActiComplete.Remarks = dataother.AuditorRemark
	ActiComplete.CallbackUrl = ""
	if dataother.SuccessStatus == 1 {
		ActiComplete.Result = "1"

		receiveVal := svcActiviti.TaskComplete(ActiComplete)

		if receiveVal == "true" {
			if supplierCertEntity.Status == suppliercert.CENT_AUDIT_STATUS {
				if supplierCertEntity.InStyle == "1" {
					paysvc := paymentinfo.GetPaymentService(utils.DBE)
					var Amount float64
					asvc := oilcostmanage.GetOilCostManageService(utils.DBE)
					Amount = asvc.GetAmount("ZHUNRU",supplierCertEntity.SupplierTypeCode)
					//if supplierCertEntity.SupplierTypeCode == suppliercert.DOOGS_TYPECODE {
					//	Amount = 6000
					//} else if supplierCertEntity.SupplierTypeCode == suppliercert.BASIS_TYPECODE {
					//	Amount = 7000
					//} else if supplierCertEntity.SupplierTypeCode == suppliercert.TECH_TYPECODE {
					//	Amount = 8000
					//}
					var payinfo paymentinfo.OilPaymentInfo
					payinfo.SupplierId = supplierCertEntity.SupplierId
					payinfo.SrcId = supplierCertEntity.Id
					payinfo.SupplierCertId = supplierCertEntity.Id
					payinfo.USCCode = supplierEntity.CommercialNo
					payinfo.SupplierName = supplierEntity.SupplierName
					payinfo.PayType = "1"
					payinfo.Amount = strconv.FormatFloat(Amount,'E',-1,64)
					payinfo.IsPay = "0"
					payinfo.CreateUserId = supplierCertEntity.CreateUserId
					payinfo.CreateBy = supplierCertEntity.CreateBy
					payinfo.CreateOn = time.Now()

					wheresup := " SupplierCertId=" + strconv.Itoa(supplierCertEntity.Id)
					var sup []suppliercertsub.OilSupplierCertSub
					total := paysvc.GetPagingEntitiesWithOrder(1,10,"Id",true,&sup,wheresup)

					if supplierCertEntity.SupplierTypeCode == "01" && total <= 50 {

					} else {
						paysvc.InsertEntity(&payinfo)
						//发短信
						toMobile := supplierEntity.Mobile
						msg:= "您的"+supplierCertEntity.SupplierTypeName + "准入审核通过，请及时确认缴费信息！"
						msgService := msg2.GetMsgService(utils.DBE)
						msgService.HandleMsg(toMobile,msg,"3-1",supplierCertEntity.CreateBy,supplierEntity.ContactName,strconv.Itoa(supplierCertEntity.CreateUserId))
					}

					//paysvc.AddPaymentinfo(supplierCertEntity.SupplierId, supplierCertEntity.Id, Amount, "1")
					supplierCertEntity.Status = status
					supplierCertEntity.Step = step
					cols := []string{
						"Status",
						"Step",
					}
					certSrv.UpdateEntityByIdCols(certId, supplierCertEntity, cols)
				} else {
					supplierCertEntity.Status = suppliercert.STOREING_STATUS
					supplierCertEntity.Step = step
					cols := []string{
						"Status",
						"Step",
					}
					certSrv.UpdateEntityByIdCols(certId, supplierCertEntity, cols)
				}
			} else if supplierCertEntity.Status == suppliercert.PROF_AUDIT_STATUS && supplierCertEntity.InStyle == "3" {
				//if supplierCertEntity.InStyle == "3" {
					supplierCertEntity.Status = suppliercert.STOREING_STATUS
					supplierCertEntity.Step = 3
					cols := []string{
						"Status",
						"Step",
					}
					certSrv.UpdateEntityByIdCols(certId, supplierCertEntity, cols)
				//} else {
				//	supplierCertEntity.Status = status
				//	supplierCertEntity.Step = step
				//	cols := []string{
				//		"Status",
				//		"Step",
				//	}
				//	certSrv.UpdateEntityByIdCols(certId, supplierCertEntity, cols)
				//}
			} else {
				supplierCertEntity.Status = status
				supplierCertEntity.Step = step
				cols := []string{
					"Status",
					"Step",
				}
				certSrv.UpdateEntityByIdCols(certId, supplierCertEntity, cols)
			}
			errinfo.Message = "提交成功！"
			errinfo.Code = 0
			this.Data["json"] = &errinfo
			this.ServeJSON()
		} else {
			errinfo.Message = "工作流异常，请联系管理员！"
			errinfo.Code = -1
			this.Data["json"] = &errinfo
			this.ServeJSON()
			return
		}
	} else {

		ActiComplete.Result = "0"
		receiveVal := svcActiviti.TaskComplete(ActiComplete)

		if receiveVal == "true" {
			// 审批历史
			var audithistoryentity audithistory.Base_AuditHistory
			audithistoryentity.EntityId = supplierCertEntity.Id
			audithistoryentity.WorkflowId = supplierCertEntity.WorkflowId
			audithistoryentity.Process = ActiComplete.ProcessKey
			audithistoryentity.BusinessKey = ActiComplete.BusinessKey
			audithistoryentity.Type = supplierCertEntity.SupplierTypeCode
			audithistoryentity.BackStep = supplierCertEntity.Status
			audithistoryentity.Index = supplierCertEntity.AuditIndex
			audithistoryentity.CreateOn = time.Now()
			audithistoryentity.CreateBy = this.User.Realname
			audithistoryentity.CreateUserId, _ = utils.StrTo(this.User.Id).Int()
			certSrv.InsertEntity(audithistoryentity)
			if supplierCertEntity.Status == suppliercert.CENT_AUDIT_STATUS {
				supplierCertEntity.Status = suppliercert.NO_CENT_AUDIT_STATUS
				supplierCertEntity.BackReason = dataother.AuditorRemark
				cols := []string{
					"BackReason",
				}
				certSrv.UpdateEntityByIdCols(certId, supplierCertEntity, cols)
			} else {
				supplierCertEntity.Status = backstatus
			}
			supplierCertEntity.Step = 1
			supplierCertEntity.WorkflowId = ""
			cols := []string{
				"Status",
				"Step",
				"WorkflowId",
			}
			certSrv.UpdateEntityByIdCols(certId, supplierCertEntity, cols)

			toMobile := supplierEntity.Mobile
			msg:= "您的"+supplierCertEntity.SupplierTypeName + "准入审核未通过，请及时查看！"
			msgService := msg2.GetMsgService(utils.DBE)
			msgService.HandleMsg(toMobile,msg,"4-1",supplierCertEntity.CreateBy,supplierEntity.ContactName,strconv.Itoa(supplierCertEntity.CreateUserId))
			errinfo.Message = "提交成功！"
			errinfo.Code = 0
			this.Data["json"] = &errinfo
			this.ServeJSON()
		} else {
			errinfo.Message = "工作流异常，请联系管理员！"
			errinfo.Code = -1
			this.Data["json"] = &errinfo
			this.ServeJSON()
			return
		}
	}
}

// @Title 审核
// @Description 审核
// @Success	200	{object} controllers.Request
// @router /auditcallback [get]
func (this *OilSupplierCertController) AuditCallback() {
	id := this.GetString("Id")
	status := this.GetString("status")
	step := this.GetString("step")
	var supplierCertEntity suppliercert.OilSupplierCert
	svc := suppliercert.GetOilSupplierCertService(utils.DBE)
	supplierCertEntity.Status = status
	supplierCertEntity.Step, _ = strconv.Atoi(step)
	cols := []string{
		"Id",
		"Status",
		"step",
	}
	svc.UpdateEntityByIdCols(id, supplierCertEntity, cols)
	fmt.Println(id, status, step)
}

// @Title 获取实体
// @Description 获取实体
// @Success 200 {object} controllers.Request
// @router /isaccess [get]
func (this *OilSupplierCertController) IsAccess() {
	auditstepcode := this.GetString("auditstepcode")
	processkey := this.GetString("processkey")
	id := this.GetString("id")
	//var users []userRole.Base_RoleList
	//var auditWorkflow auditsetting.Base_OilAuditSetting
	//rsvc := auditsetting.GetOilAuditSettingService(utils.DBE)
	res := false

	if auditstepcode == workflow.PROF_CONCENT { // 集中审批
		//rsvc.GetAuditStepRoleEntity(OilAuditSettingName, this.User.DepartmentId, workflow.PROF_AUDIT, &auditWorkflow)
		//users = rsvc.GetUserByRole("10000204", this.User.AccCode)
		//for _, user := range users {
		//	if this.User.Id == strconv.Itoa(int(user.Id))  {
		//		res = true
		//		break
		//	}
		//}
		var setting auditsetting.Base_OilAuditSetting
		svc := organize.GetOrganizeService(utils.DBE)
		where := "AuditStepCode='" + auditstepcode + "'"
		svc.GetEntity(&setting, where)
		res = svc.UserInRoleById(this.User.Id, strconv.Itoa(setting.RoleId))
	} else {
		//var users []suppliercert.UserList
		//where := "OrganizeId=" + this.User.DepartmentId + " and AuditStepCode='" + auditstepcode + "'"
		//rsvc.GetEntitysByWhere(OilAuditSettingName,where, &users)
		//rsvc.GetAuditStepRoleEntity(OilAuditSettingName, this.User.DepartmentId, auditstepcode, &auditWorkflow)
		//users = rsvc.GetUserByRole(strconv.Itoa(auditWorkflow.RoleId), this.User.AccCode)
		//var users []userRole.Base_RoleList
		//certSrv := suppliercert.GetOilSupplierCertService(utils.DBE)
		//certSrv.GetAuditUser(this.User.DepartmentId, auditstepcode, &users)

		var setting auditsetting.Base_OilAuditSetting
		svc := organize.GetOrganizeService(utils.DBE)
		where := "AuditStepCode='" + auditstepcode + "'"
		svc.GetEntity(&setting, where)
		res = svc.UserInRoleById(this.User.Id, strconv.Itoa(setting.RoleId))

		if res {
			actisvc := workflow.GetActivitiService(utils.DBE)
			ids := actisvc.GetMyTasks(processkey, this.User.Id)
			res = strings.Contains(ids,id)
		}

		//for _, user := range users {
		//	if this.User.Id == strconv.Itoa(int(user.Id))  {
		//		res = true
		//		break
		//	}
		//}
	}

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

// @Title 获取准入编码
// @Description 获取准入编码
// @Success 200 {object} controllers.Request
// @router /createaccesscardno/:type [get]
func (this *OilSupplierCertController) CreateAccessCardNo() {
	Id := this.GetString("Id")
	certId := this.GetString(("SupplierCertId"))
	typeCode := this.Ctx.Input.Param(":type")
	codecSvc := codecsequence.GetCodecSequenceService(utils.DBE)

	var entitycert suppliercert.OilSupplierCert
	var entity supplier.OilSupplier
	//where := "Id = " + Id
	//codecSvc.GetEntities(&model, "")
	seqStr := ""
	cols := []string{}
	if (typeCode == "01") {  // 物质
		has := true
		for has {
			seqStr = codecSvc.GetWZAccessCardNo(this.User.AccCode)
			where := "SupplierTypeCode='" + typeCode + "' and AccessCardNo='" + seqStr + "'"
			has = codecSvc.GetEntity(&entitycert, where)
		}
		cols = []string{"WZAccessCardNo"}
		entity.WZAccessCardNo = seqStr
	} else if typeCode == "03" { //技术服务
		has := true
		for has {
			seqStr = codecSvc.GetJFAccessCardNo(this.User.AccCode)
			where := "SupplierTypeCode='" + typeCode + "' and AccessCardNo='" + seqStr + "'"
			has = codecSvc.GetEntity(&entitycert, where)
		}
		cols = []string{"JFAccessCardNo"}
		entity.JFAccessCardNo = seqStr
	} else if typeCode == "02" { // 基建
		has := true
		for has {
			seqStr = codecSvc.GetJSAccessCardNo(this.User.AccCode)
			where := "SupplierTypeCode='" + typeCode + "' and AccessCardNo='" + seqStr + "'"
			has = codecSvc.GetEntity(&entitycert, where)
		}
		cols = []string{"JSAccessCardNo"}
		entity.JSAccessCardNo = seqStr
	}
	codecSvc.UpdateEntityByIdCols(Id, &entity, cols)
	var cert suppliercert.OilSupplierCert
	certcols := []string{"AccessCardNo"}
	cert.AccessCardNo = seqStr
	codecSvc.UpdateEntityByIdCols(certId, &cert, certcols)
	this.Data["json"] = seqStr
	this.ServeJSON()
}

// @Title 修改准入标识
// @Description 修改准入标识
// @Success 200 {object} controllers.Request
// @router /updatainflag/ [get]
func (this *OilSupplierCertController) UpdataInFlag() {
	t := time.Now()
	session := utils.DBE.NewSession()
	var certentitys []suppliercert.OilSupplierCert
	svc := suppliercert.GetOilSupplierCertSession(session)
	defer func() {
		session.Close()
	}()
	err := session.Begin()
	svc.GetEntities(&certentitys, "InFlag!='3'")
	currenttime := time.Now()
	//.Format("2006-01-02")
	for i := 0; i < len(certentitys); i++ {
		if currenttime.After(certentitys[i].ApplyTime) && !currenttime.After(certentitys[i].ApplyTime.AddDate(1,0,0)) && certentitys[i].InFlag != "2" {
			var certentity suppliercert.OilSupplierCert
			certentity.InFlag = "2"
			cols := []string{"InFlag"}
			_,err = svc.UpdateEntityByIdCols(certentitys[i].Id, &certentity, cols)
			if err != nil {
				session.Rollback()
			}
		}
		if currenttime.After(certentitys[i].ApplyTime.AddDate(1, 0, 0)) {
			fmt.Println(time.Now().Format("2006-01-02"), certentitys[i].ApplyTime.AddDate(1, 0, 0).Format("2006-01-02"))
			var certentity suppliercert.OilSupplierCert
			certentity.InFlag = "3"
			cols := []string{"InFlag"}
			_,err = svc.UpdateEntityByIdCols(certentitys[i].Id, &certentity, cols)
			if err != nil {
				session.Rollback()
			}
		}
	}
	err = session.Commit()
	fmt.Println(err)
	elapsed := time.Since(t)
	fmt.Println(elapsed, "更新准入标识")
}

// @Title 保存准入编码
// @Description 保存准入编码
// @Success 200 {object} controllers.Request
// @router /saveaccesscardno/:Id [get]
func (this *OilSupplierCertController) SaveAccessCardNo() {
	id := this.Ctx.Input.Param(":Id")
	certId := this.GetString(("SupplierCertId"))
	typeCode := this.GetString("typeCode")
	accessCardNo := this.GetString("AccessCardNo")

	var model []suppliercert.OilSupplierCert
	var supplier supplier.OilSupplier
	svc := suppliercert.GetOilSupplierCertService(utils.DBE)
	where := "AccessCardNo='" + accessCardNo + "'"
	svc.GetEntities(&model, where)
	supcols := []string{}
	if model == nil || len(model) == 0 {
		if (typeCode == "01") {  // 物质
			supplier.WZAccessCardNo = accessCardNo
			supcols = []string{"WZAccessCardNo"}
		} else if typeCode == "03" { //技术服务
			supplier.JFAccessCardNo = accessCardNo
			supcols = []string{"JFAccessCardNo"}
		} else if typeCode == "02" { // 基建
			supplier.JSAccessCardNo = accessCardNo
			supcols = []string{"JSAccessCardNo"}
		}
		svc.UpdateEntityByIdCols(id, &supplier, supcols)
		var cert suppliercert.OilSupplierCert
		certcols := []string{"AccessCardNo"}
		cert.AccessCardNo = accessCardNo
		svc.UpdateEntityByIdCols(certId, &cert, certcols)
		var errinfo ErrorDataInfo
		errinfo.Message = "保存成功！"
		errinfo.Code = 0
		this.Data["json"] = &errinfo
		this.ServeJSON()
	} else {
		var errinfo ErrorDataInfo
		errinfo.Message = "准入编码已经存在！"
		errinfo.Code = -1
		this.Data["json"] = &errinfo
		this.ServeJSON()
	}
}

// @Title 快到期短信通知
// @Description 修改准入标识
// @Success 200 {object} controllers.Request
// @router /sendingSMS/ [get]
func (this *OilSupplierCertController) SendingSMS() {
	t := time.Now()
	svcsupp := supplier.GetOilSupplierService(utils.DBE)
	var list []supplier.OilSupplierView
	where := "b.InFlag = '1'"
	svcsupp.GetMyPagingEntitiesWithOrderBytbl(OilSupplierName, OilSupplierCertName, 0, 0, "Id", true, &list, where)
	currenttime := time.Now()

	for _,item := range list {
		if currenttime.AddDate(0,3,0).Format("2006-01-02") == (item.ApplyTime.Format("2006-01-02")) {
			toMobile := "15288965998,15863081686,15563862958"//item.Mobile
			msg:= "您的" + item.SupplierTypeName + "准入还有3个月到期"
			msgService := msg2.GetMsgService(utils.DBE)
			msgService.HandleMsg(toMobile,msg,"1-1",item.CreateBy,item.ContactName,strconv.Itoa(item.CreateUserId))
		}
		if currenttime.AddDate(0,2,0).Format("2006-01-02") == (item.ApplyTime.Format("2006-01-02")) {
			toMobile := "15288965998,15863081686,15563862958"//item.Mobile
			msg:= "您的" + item.SupplierTypeName + "准入还有2个月到期"
			msgService := msg2.GetMsgService(utils.DBE)
			msgService.HandleMsg(toMobile,msg,"1-1",item.CreateBy,item.ContactName,strconv.Itoa(item.CreateUserId))
		}
		if currenttime.AddDate(0,1,0).Format("2006-01-02") == (item.ApplyTime.Format("2006-01-02")) {
			toMobile := ",15863081686,15863081686,15563862958"//item.Mobile
			msg:= "您的" + item.SupplierTypeName + "准入还有1个月到期"
			msgService := msg2.GetMsgService(utils.DBE)
			msgService.HandleMsg(toMobile,msg,"1-1",item.CreateBy,item.ContactName,strconv.Itoa(item.CreateUserId))
		}
	}
	elapsed := time.Since(t)
	fmt.Println(elapsed, "快到期提醒")


}