js-ojus / flow Goto Github PK

dtID1, err := flow.DocTypes.New(tx, "图纸设计") //dtID1
	if err != nil {
		fmt.Println(err)
	}
	// dtID2, err := flow.DocTypes.New(tx, "图纸校核") //dtID1
	// if err != nil {
	// 	fmt.Println(err)
	// }
	_, err = flow.DocTypes.New(tx, "变更立项") //dtID2
	if err != nil {
		fmt.Println(err)
	}
	dsID1, err := flow.DocStates.New(tx, "设计中...") //初始化
	if err != nil {
		fmt.Println(err)
	}
	dsID2, err := flow.DocStates.New(tx, "校核中...") //委托创建
	if err != nil {
		fmt.Println(err)
	}
	_, err = flow.DocStates.New(tx, "审查中...")
	if err != nil {
		fmt.Println(err)
	}
	flow.DocStates.New(tx, "批注中...")
	flow.DocStates.New(tx, "申报中...")
	flow.DocStates.New(tx, "评估中...")
	flow.DocStates.New(tx, "审批中...")
	// flow.DocStates.New(tx, "DataApproved")
	// flow.DocStates.New(tx, "ReportGen")
	// flow.DocStates.New(tx, "ReportApproved")

	daID1, err := flow.DocActions.New(tx, "提交设计", false) //改变状态设计中...为校核中...
	if err != nil {
		fmt.Println(err)
	}
	daID2, err := flow.DocActions.New(tx, "校核", false)
	if err != nil {
		fmt.Println(err)
	}
	daID3, err := flow.DocActions.New(tx, "审查", false)
	if err != nil {
		fmt.Println(err)
	}
	daID4, err := flow.DocActions.New(tx, "核定", true)
	if err != nil {
		fmt.Println(err)
	}
	daID5, err := flow.DocActions.New(tx, "评估", true)
	if err != nil {
		fmt.Println(err)
	}
	daID6, err := flow.DocActions.New(tx, "审批", false)
	if err != nil {
		fmt.Println(err)
	}
	daID7, err := flow.DocActions.New(tx, "立项", false)
	if err != nil {
		fmt.Println(err)
	}

	workflowID1, err := flow.Workflows.New(tx, "图纸设计流程", dtID1, dsID1) //初始状态是“设计中...”
	if err != nil {
		fmt.Println(err)
	}
	// workflowID2, err := flow.Workflows.New(tx, "图纸校核流程", dtID2, dsID2) //初始状态是“设计中...”
	// if err != nil {
	// 	fmt.Println(err)
	// }

	accessContextID1, err := flow.AccessContexts.New(tx, "Context")
	if err != nil {
		beego.Error(err)
	}
	// AddNode maps the given document state to the specified node.  This
	// map is consulted by the workflow when performing a state transition
	// of the system.nodeID1
	// _, err = flow.Workflows.AddNode(tx, dtID1, dsID1, accessContextID1, workflowID1, "图纸三角校审流程-设计", flow.NodeTypeLinear)
	// if err != nil {
	// 	fmt.Println(err)
	// }
	_, err = flow.Workflows.AddNode(tx, dtID1, dsID2, accessContextID1, workflowID1, "图纸三角校审流程-校核", flow.NodeTypeEnd)
	if err != nil {
		fmt.Println(err)
	}

	res, err := tx.Exec(`INSERT INTO users_master(first_name, last_name, email, active)
			VALUES('秦', '晓川-1', '[email protected]', 1)`)
	if err != nil {
		log.Fatalf("%v\n", err)
	}
	uid, _ := res.LastInsertId()
	uID1 := flow.UserID(uid)
	_, err = flow.Groups.NewSingleton(tx, uID1)

	res, err = tx.Exec(`INSERT INTO users_master(first_name, last_name, email, active)
			VALUES('秦', '晓川-2', '[email protected]', 1)`)
	if err != nil {
		log.Fatalf("%v\n", err)
	}
	uid, _ = res.LastInsertId()
	uID2 := flow.UserID(uid)
	_, err = flow.Groups.NewSingleton(tx, uID2)

	res, err = tx.Exec(`INSERT INTO users_master(first_name, last_name, email, active)
			VALUES('秦', '晓川-3', '[email protected]', 1)`)
	if err != nil {
		log.Fatalf("%v\n", err)
	}
	uid, _ = res.LastInsertId()
	uID3 := flow.UserID(uid)
	_, err = flow.Groups.NewSingleton(tx, uID3)

	res, err = tx.Exec(`INSERT INTO users_master(first_name, last_name, email, active)
			VALUES('秦', '晓川-4', '[email protected]', 1)`)
	if err != nil {
		log.Fatalf("%v\n", err)
	}
	uid, _ = res.LastInsertId()
	uID4 := flow.UserID(uid)
	_, err = flow.Groups.NewSingleton(tx, uID4)

	gID1 := fatal1(flow.Groups.New(tx, "设计人员组", "G")).(flow.GroupID)
	gID2 := fatal1(flow.Groups.New(tx, "校核人员组", "G")).(flow.GroupID)
	fatal0(flow.Groups.AddUser(tx, gID1, uID1))
	fatal0(flow.Groups.AddUser(tx, gID1, uID2))
	fatal0(flow.Groups.AddUser(tx, gID1, uID3))

	fatal0(flow.Groups.AddUser(tx, gID2, uID2))
	fatal0(flow.Groups.AddUser(tx, gID2, uID3))
	fatal0(flow.Groups.AddUser(tx, gID2, uID4))
	roleID1 := fatal1(flow.Roles.New(tx, "设计人员角色")).(flow.RoleID)
	roleID2 := fatal1(flow.Roles.New(tx, "校核人员角色")).(flow.RoleID)
	//给角色赋予action权限
	fatal0(flow.Roles.AddPermissions(tx, roleID1, dtID1, []flow.DocActionID{daID1, daID2, daID3, daID4}))
	fatal0(flow.Roles.AddPermissions(tx, roleID2, dtID1, []flow.DocActionID{daID1, daID2, daID3, daID4, daID5, daID6, daID7}))
	//给用户组赋予角色
	err = flow.AccessContexts.AddGroupRole(tx, accessContextID1, gID1, roleID1)
	if err != nil {
		beego.Error(err)
	}
	err = flow.AccessContexts.AddGroupRole(tx, accessContextID1, gID2, roleID2)
	if err != nil {
		beego.Error(err) 
	}

	tx.Commit()

dtID1, err := flow.DocTypes.GetByName("图纸设计")
	if err != nil {
		beego.Error(err)
	}
	beego.Info(dtID1)
	//查询context
	accessContextID1, err := flow.AccessContexts.List("Context", 0, 0)
	if err != nil {
		beego.Error(err)
	}
	beego.Info(accessContextID1[0].ID)
	beego.Info(flow.GroupID(1))
	docNewInput := flow.DocumentsNewInput{
		DocTypeID:       dtID1.ID,
		AccessContextID: accessContextID1[0].ID,
		GroupID:         5, //groupId,
		Title:           "厂房布置图",
		Data:            "设计、制图: 秦晓川1, 校核: 秦晓川2",
	}
	// flow.Documents.New(tx, &docNewInput)
	DocumentID1, err := flow.Documents.New(tx, &docNewInput)
	if err != nil {
		beego.Error(err)
	}
	// tx.Commit() 
	beego.Info(DocumentID1)
	dsID2, err := flow.DocStates.GetByName("校核中...")
	if err != nil {
		fmt.Println(err)
	}
	beego.Info(dsID2)
	daID2, err := flow.DocActions.GetByName("提交设计")
	if err != nil {
		fmt.Println(err)
	}
	beego.Info(daID2)
	beego.Info(flow.GroupID(2))
	docEventInput := flow.DocEventsNewInput{
		DocTypeID:   dtID1.ID, //flow.DocTypeID(1),
		DocumentID:  DocumentID1,
		DocStateID:  dsID2.ID,
		DocActionID: daID2.ID, //flow.DocActionID(2),
		GroupID:     6,
		Text:        "校核",
	}

	docEventID1, err := flow.DocEvents.New(tx, &docEventInput)
	if err != nil {
		beego.Error(err)
	}
	tx.Commit() 
	beego.Info(docEventID1)
	myDocEvent, err := flow.DocEvents.Get(docEventID1)
	if err != nil {
		beego.Error(err)
	}
	beego.Info(myDocEvent)
	// myWorkflow, err := flow.Workflows.Get(workflowId.ID)
	// if err != nil {
	// 	beego.Error(err)
	// }
	myWorkflow, err := flow.Workflows.GetByName("图纸设计流程")
	if err != nil {
		beego.Error(err)
	}
	beego.Info(myWorkflow)
	//给出接受的组groupids
	groupIds := []flow.GroupID{flow.GroupID(6)}
	beego.Info(groupIds)
	newDocStateId, err := myWorkflow.ApplyEvent(tx, myDocEvent, groupIds)
	if err != nil {
		beego.Error(err)
	}
	tx.Commit() 
	fmt.Println("newDocStateId=", newDocStateId, err)

update or delete on table "wf_groups_master" violates foreign key constraint "wf_mailboxes_group_id_fkey" on table "wf_mailboxes"