mooncakes.io

mldong/jeeflow-core/model does not have a README file

CcInstance

pub(all) struct CcInstance {
  id : Int64
  process_instance_id : Int64
  actor_id : String
  state : Int
  create_time : String?
  create_user : String?
  update_time : String?
  update_user : String?
} derive(Eq)

CountersignType

source

pub(all) enum CountersignType {
  Parallel
  Sequential
} derive(Eq, Show)

CountersignType::from_str_name

source

fn CountersignType::from_str_name(s : String) -> CountersignType

DefineRow

source

pub(all) struct DefineRow {
  id : Int64
  name : String
  display_name : String
  define_type : String
  state : Int
  version : Int
  create_time : String?
  create_user : String?
  update_time : String?
  update_user : String?
} derive(Eq)

定义行

DefineRow::new_empty

source

fn DefineRow::new_empty() -> DefineRow

DefineState

source

pub(all) enum DefineState {
  Disable
  Enable
} derive(Eq, Show)

DefineState::code

source

fn DefineState::code(self : DefineState) -> Int

DefineState::from_code

source

fn DefineState::from_code(code : Int) -> DefineState

FilterOp

source

pub(all) enum FilterOp {
  Eq
  Ne
  Like
  Gt
  Lt
  Ge
  Le
  In
  Nin
  Bt
} derive(Eq, Show)

m_ 三段式过滤操作符（spec/06 §2.2）

FilterOp::from_str

source

fn FilterOp::from_str(s : String) -> FilterOp?

InstanceRow

source

pub(all) struct InstanceRow {
  id : Int64
  parent_id : Int64?
  process_define_id : Int64
  state : Int
  parent_node_name : String?
  business_no : String?
  operator : String
  expire_time : String?
  variable : String?
  create_time : String?
  create_user : String?
  update_time : String?
  update_user : String?
  define_name : String?
  define_display_name : String?
  define_version : Int?
} derive(Eq)

实例行

InstanceRow::new_empty

source

fn InstanceRow::new_empty() -> InstanceRow

InstanceState

source

pub(all) enum InstanceState {
  Doing
  Finished
  Withdraw
  Interrupt
  Reject
  Pending
  Abandon
} derive(Eq, Show)

InstanceState::code

source

fn InstanceState::code(self : InstanceState) -> Int

InstanceState::from_code

source

fn InstanceState::from_code(code : Int) -> InstanceState?

PageQuery

source

pub(all) struct PageQuery {
  page_num : Int64
  page_size : Int64
  order_by : String?
  operator : String?
  conditions : Map[String, Json]
  filters : Array[QueryFilter]
}

PageQuery::add_condition

source

fn PageQuery::add_condition(self : PageQuery, key : String, value : Json) -> Unit

PageQuery::add_filter

source

fn PageQuery::add_filter(self : PageQuery, f : QueryFilter) -> Unit

PageQuery::conditions

source

fn PageQuery::conditions(self : PageQuery) -> Map[String, Json]

PageQuery::filters

source

fn PageQuery::filters(self : PageQuery) -> Array[QueryFilter]

PageQuery::new

source

fn PageQuery::new(page_num : Int64, page_size : Int64) -> PageQuery

PageQuery::operator

source

fn PageQuery::operator(self : PageQuery) -> String?

PageQuery::order_by

source

fn PageQuery::order_by(self : PageQuery) -> String?

PageQuery::page_num

source

fn PageQuery::page_num(self : PageQuery) -> Int64

PageQuery::page_size

source

fn PageQuery::page_size(self : PageQuery) -> Int64

PageQuery::set_operator

source

fn PageQuery::set_operator(self : PageQuery, op : String?) -> Unit

PageQuery::set_order_by

source

fn PageQuery::set_order_by(self : PageQuery, s : String) -> Unit

PageQuery::set_page_num

source

fn PageQuery::set_page_num(self : PageQuery, n : Int64) -> Unit

PageQuery::set_page_size

source

fn PageQuery::set_page_size(self : PageQuery, n : Int64) -> Unit

PageResult

source

pub(all) struct PageResult[T] {
  page_num : Int64
  page_size : Int64
  record_count : Int64
  total_page : Int64
  rows : Array[T]
}

分页结果：恒五键契约（C22：pageNum/pageSize/recordCount/totalPage/rows）

PageResult::new

source

fn[T] PageResult::new(page_num : Int64, page_size : Int64, record_count : Int64, rows : Array[T]) -> PageResult[T]

PageResult::page_num

source

fn[T] PageResult::page_num(self : PageResult[T]) -> Int64

PageResult::page_size

source

fn[T] PageResult::page_size(self : PageResult[T]) -> Int64

PageResult::record_count

source

fn[T] PageResult::record_count(self : PageResult[T]) -> Int64

PageResult::rows

source

fn[T] PageResult::rows(self : PageResult[T]) -> Array[T]

PageResult::total_page

source

fn[T] PageResult::total_page(self : PageResult[T]) -> Int64

PerformType

source

pub(all) enum PerformType {
  Normal
  Countersign
} derive(Eq, Show)

PerformType::code

source

fn PerformType::code(self : PerformType) -> Int

PerformType::from_code

source

fn PerformType::from_code(code : Int) -> PerformType

ProcessDefine

source

pub(all) struct ProcessDefine {
  id : Int64
  name : String
  display_name : String
  define_type : String
  state : Int
  content : String
  version : Int
  create_time : String?
  create_user : String?
  update_time : String?
  update_user : String?
} derive(Eq)

ProcessDefine::clone

source

fn ProcessDefine::clone(self : ProcessDefine) -> ProcessDefine

ProcessDesign

source

pub(all) struct ProcessDesign {
  id : Int64
  name : String
  display_name : String
  design_type : String
  icon : String?
  is_deployed : Int
  remark : String?
  create_time : String?
  create_user : String?
  update_time : String?
  update_user : String?
} derive(Eq)

ProcessDesign::clone

source

fn ProcessDesign::clone(self : ProcessDesign) -> ProcessDesign

ProcessDesignHis

source

pub(all) struct ProcessDesignHis {
  id : Int64
  process_design_id : Int64
  content : String
  create_time : String?
  create_user : String?
} derive(Eq)

ProcessDesignHis::clone

source

fn ProcessDesignHis::clone(self : ProcessDesignHis) -> ProcessDesignHis

ProcessInstance

source

pub(all) struct ProcessInstance {
  instance_id : Int64
  parent_id : Int64?
  define_id : Int64
  state : Int
  parent_node_name : String?
  business_no : String?
  operator : String
  expire_time : String?
  variables : @mldong/jeeflow-core/json.FlowData
FlowData
  tasks : Array[ProcessTask]
  create_time : String?
  create_user : String?
  update_time : String?
  update_user : String?
  define : ProcessDefine?
}

ProcessInstance —— DDD 聚合根

ProcessInstance::abandon_all_doing

source

fn ProcessInstance::abandon_all_doing(self : ProcessInstance) -> Unit

ProcessInstance::abandon_task

source

fn ProcessInstance::abandon_task(self : ProcessInstance, task_id : Int64) -> Unit raise @mldong/jeeflow-core/error.JeeflowError
JeeflowError

ProcessInstance::add_variable

source

fn ProcessInstance::add_variable(self : ProcessInstance, args : @mldong/jeeflow-core/json.FlowData
FlowData) -> Unit

ProcessInstance::clone

source

fn ProcessInstance::clone(self : ProcessInstance) -> ProcessInstance

ProcessInstance::complete_task

source

fn ProcessInstance::complete_task(self : ProcessInstance, task_id : Int64, operator : String, args : @mldong/jeeflow-core/json.FlowData
FlowData) -> Unit raise @mldong/jeeflow-core/error.JeeflowError
JeeflowError

完成任务：finish 任务 + 合并 f_ 变量（rust complete_task）

ProcessInstance::create

source

fn ProcessInstance::create(define : ProcessDefine, operator : String, args : @mldong/jeeflow-core/json.FlowData
FlowData) -> ProcessInstance

工厂：新建实例（state=DOING=10）

ProcessInstance::create_countersign_tasks

source

fn ProcessInstance::create_countersign_tasks(self : ProcessInstance, task_name : String, display_name : String, actor_ids : Array[String], operator : String, task_type : TaskType, form_key : String?, parent_task_id : Int64?) -> Array[ProcessTask]

会签任务：每人一个独立任务（C9：串行一次只建一个由引擎控制；此处为并行建全入口）

ProcessInstance::create_history_task

source

fn ProcessInstance::create_history_task(self : ProcessInstance, task_name : String, display_name : String, operator : String, task_type : TaskType) -> ProcessTask

历史任务（custom 节点用，直接 FINISHED）

ProcessInstance::create_task

source

fn ProcessInstance::create_task(self : ProcessInstance, task_name : String, display_name : String, actor_ids : Array[String], operator : String, task_type : TaskType, perform_type : PerformType, form_key : String?, parent_task_id : Int64?) -> ProcessTask

建任务（子实体工厂；task_id=0 由 ID 生成器赋值——rust 91b：原片赋 id 再克隆返回）

ProcessInstance::create_with_parent

source

fn ProcessInstance::create_with_parent(define : ProcessDefine, operator : String, args : @mldong/jeeflow-core/json.FlowData
FlowData, parent_id : Int64, parent_node_name : String) -> ProcessInstance

工厂（子流程）：带父实例

ProcessInstance::finish

source

fn ProcessInstance::finish(self : ProcessInstance) -> Unit

ProcessInstance::get_doing_tasks

source

fn ProcessInstance::get_doing_tasks(self : ProcessInstance) -> Array[ProcessTask]

ProcessInstance::get_doing_tasks_by_names

source

fn ProcessInstance::get_doing_tasks_by_names(self : ProcessInstance, names : Array[String]) -> Array[ProcessTask]

ProcessInstance::get_done_tasks_by_names

source

fn ProcessInstance::get_done_tasks_by_names(self : ProcessInstance, names : Array[String]) -> Array[ProcessTask]

ProcessInstance::get_finished_tasks

source

fn ProcessInstance::get_finished_tasks(self : ProcessInstance) -> Array[ProcessTask]

ProcessInstance::get_history_tasks

source

fn ProcessInstance::get_history_tasks(self : ProcessInstance) -> Array[ProcessTask]

ProcessInstance::interrupt

source

fn ProcessInstance::interrupt(self : ProcessInstance) -> Unit

ProcessInstance::is_all_tasks_finished

source

fn ProcessInstance::is_all_tasks_finished(self : ProcessInstance) -> Bool

ProcessInstance::is_doing

source

fn ProcessInstance::is_doing(self : ProcessInstance) -> Bool

ProcessInstance::is_finished

source

fn ProcessInstance::is_finished(self : ProcessInstance) -> Bool

ProcessInstance::pending

source

fn ProcessInstance::pending(self : ProcessInstance) -> Unit

ProcessInstance::reject

source

fn ProcessInstance::reject(self : ProcessInstance) -> Unit

ProcessInstance::reject_task

source

fn ProcessInstance::reject_task(self : ProcessInstance, task_name : String, display_name : String, actor_ids : Array[String], operator : String, parent_task_id : Int64) -> ProcessTask

退回上一步：为新节点建待办任务

ProcessInstance::remove_variables

source

fn ProcessInstance::remove_variables(self : ProcessInstance, keys : Array[String]) -> Unit

ProcessInstance::resume

source

fn ProcessInstance::resume(self : ProcessInstance) -> Unit

ProcessInstance::withdraw

source

fn ProcessInstance::withdraw(self : ProcessInstance) -> Unit

撤回：实例 30 WITHDRAW + 全部 DOING 任务 30（C28：任务 30 非 45）

ProcessSurrogate

source

pub(all) struct ProcessSurrogate {
  id : Int64
  process_name : String
  operator : String
  surrogate : String
  start_time : String?
  end_time : String?
  enabled : Int
  create_time : String?
  create_user : String?
  update_time : String?
  update_user : String?
} derive(Eq)

ProcessSurrogate::clone

source

fn ProcessSurrogate::clone(self : ProcessSurrogate) -> ProcessSurrogate

ProcessTask

source

pub(all) struct ProcessTask {
  task_id : Int64
  process_instance_id : Int64
  task_name : String
  display_name : String
  task_type : Int
  perform_type : Int
  task_state : Int
  actor_id : String?
  actor_ids : Array[String]
  finish_time : String?
  expire_time : String?
  form_key : String?
  parent_task_id : Int64?
  variables : @mldong/jeeflow-core/json.FlowData
FlowData
  create_time : String?
  create_user : String?
  update_time : String?
  update_user : String?
}

ProcessTask —— 子实体

ProcessTask::abandon

source

fn ProcessTask::abandon(self : ProcessTask) -> Unit raise @mldong/jeeflow-core/error.JeeflowError
JeeflowError

ProcessTask::clone

source

fn ProcessTask::clone(self : ProcessTask) -> ProcessTask

ProcessTask::finish

source

fn ProcessTask::finish(self : ProcessTask, operator : String) -> Unit raise @mldong/jeeflow-core/error.JeeflowError
JeeflowError

完成（state→FINISHED=20）；守卫：仅 DOING + 处理人可办（并发语义 §6.2）

ProcessTask::interrupt

source

fn ProcessTask::interrupt(self : ProcessTask) -> Unit raise @mldong/jeeflow-core/error.JeeflowError
JeeflowError

ProcessTask::is_allowed

source

fn ProcessTask::is_allowed(self : ProcessTask, operator : String) -> Bool

处理人校验："flow.auto"/"flow.admin" 直通

ProcessTask::is_doing

source

fn ProcessTask::is_doing(self : ProcessTask) -> Bool

ProcessTask::is_finished

source

fn ProcessTask::is_finished(self : ProcessTask) -> Bool

ProcessTask::pending

source

fn ProcessTask::pending(self : ProcessTask) -> Unit raise @mldong/jeeflow-core/error.JeeflowError
JeeflowError

ProcessTask::resume

source

fn ProcessTask::resume(self : ProcessTask) -> Unit

ProcessTask::withdraw

source

fn ProcessTask::withdraw(self : ProcessTask) -> Unit

QueryFilter

source

pub(all) struct QueryFilter {
  alias : String
  op : FilterOp
  column : String
  value : String
} derive(Eq)

m_ 过滤条件（spec/06 §2.2）

QueryFilter::alias

source

fn QueryFilter::alias(self : QueryFilter) -> String

QueryFilter::column

source

fn QueryFilter::column(self : QueryFilter) -> String

QueryFilter::make

source

fn QueryFilter::make(alias : String, op : FilterOp, column : String, value : String) -> QueryFilter

QueryFilter::op

source

fn QueryFilter::op(self : QueryFilter) -> FilterOp

QueryFilter::value

source

fn QueryFilter::value(self : QueryFilter) -> String

SubmitType

source

pub(all) enum SubmitType {
  Apply
  Agree
  Reject
  Rollback
  Jump
  ReApply
  RollbackToOperator
  CountersignDisagree
} derive(Eq, Show)

SubmitType::code

source

fn SubmitType::code(self : SubmitType) -> Int64

SubmitType::from_code

source

fn SubmitType::from_code(code : Int64) -> SubmitType?

TaskActor

source

pub(all) struct TaskActor {
  id : Int64
  process_task_id : Int64
  actor_id : String
  create_time : String?
  create_user : String?
} derive(Eq)

TaskRow

source

pub(all) struct TaskRow {
  id : Int64
  process_instance_id : Int64
  task_name : String
  display_name : String
  task_type : Int
  perform_type : Int
  task_state : Int
  operator : String?
  actor_id : String?
  finish_time : String?
  expire_time : String?
  form_key : String?
  task_parent_id : Int64?
  variable : String?
  create_time : String?
  create_user : String?
  update_time : String?
  update_user : String?
  process_define_id : Int64?
  instance_state : Int?
  instance_operator : String?
  business_no : String?
  instance_variable : String?
  instance_create_time : String?
  define_name : String?
  define_display_name : String?
  define_version : Int?
} derive(Eq)

待办/已办任务行

TaskRow::new_empty

source

fn TaskRow::new_empty() -> TaskRow

TaskState

source

pub(all) enum TaskState {
  Doing
  Finished
  Withdraw
  Interrupt
  Pending
  Abandon
} derive(Eq, Show)

TaskState::code

source

fn TaskState::code(self : TaskState) -> Int

TaskState::from_code

source

fn TaskState::from_code(code : Int) -> TaskState?

TaskType

source

pub(all) enum TaskType {
  Major
  Assistant
  Record
} derive(Eq, Show)

TaskType::code

source

fn TaskType::code(self : TaskType) -> Int

TaskType::from_code

source

fn TaskType::from_code(code : Int) -> TaskType

UserInfo

source

pub(all) struct UserInfo {
  user_id : String
  real_name : String
  dept_id : String
  dept_name : String
  post_id : String
  post_name : String
} derive(Eq)

用户信息（IUserProvider 返回）

UserInfo::dept_id

source

fn UserInfo::dept_id(self : UserInfo) -> String

UserInfo::dept_name

source

fn UserInfo::dept_name(self : UserInfo) -> String

UserInfo::make

source

fn UserInfo::make(user_id~ : String, real_name~ : String, dept_id? : String, dept_name? : String, post_id? : String, post_name? : String) -> UserInfo

UserInfo::post_id

source

fn UserInfo::post_id(self : UserInfo) -> String

UserInfo::post_name

source

fn UserInfo::post_name(self : UserInfo) -> String

UserInfo::real_name

source

fn UserInfo::real_name(self : UserInfo) -> String

UserInfo::user_id

source

fn UserInfo::user_id(self : UserInfo) -> String

cmp_str

source

fn cmp_str(a : String, b : String) -> Int

逐码位字典序比较——绕开 String::compare 在 wasm sort 内部的怪异行为（实测 core sort/sort_by 排 String 结果错误而 compare 直调正常；D-M3-2）

current_time_str

source

fn current_time_str() -> String

epoch_millis

source

fn epoch_millis() -> Int64

当前墙钟毫秒（@env.now() 的单位实测为 epoch 毫秒，见 model_test）

epoch_secs

source

fn epoch_secs() -> Int64

当前墙钟秒

format_time

source

fn format_time(s : String) -> String

format_unix_utc

source

fn format_unix_utc(secs : Int64) -> String

Format unix seconds (UTC) as yyyy-MM-dd HH:mm:ss（civil_from_days, Howard Hinnant）

set_clock

source

fn set_clock(f : () -> String?) -> Unit

sort_i64

source

fn sort_i64(arr : Array[Int64]) -> Unit

Int64 插入排序（数值序；防同款 core 排序问题扩散）

sort_int

source

fn sort_int(arr : Array[Int]) -> Unit

Int 插入排序

sort_strings

source

fn sort_strings(arr : Array[String]) -> Unit

String 插入排序（cmp_str 承载）

to_camel_case

source

fn to_camel_case(s : String) -> String

snake_case → camelCase

Source Files

Site source Report issue Packages Build queue Skills Statistics

#CcInstance

#CountersignType

#CountersignType::from_str_name

#DefineRow

#DefineRow::new_empty

#DefineState

#DefineState::code

#DefineState::from_code

#FilterOp

#FilterOp::from_str

#InstanceRow

#InstanceRow::new_empty

#InstanceState

#InstanceState::code

#InstanceState::from_code

#PageQuery

#PageQuery::add_condition

#PageQuery::add_filter

#PageQuery::conditions

#PageQuery::filters

#PageQuery::new

#PageQuery::operator

#PageQuery::order_by

#PageQuery::page_num

#PageQuery::page_size

#PageQuery::set_operator

#PageQuery::set_order_by

#PageQuery::set_page_num

#PageQuery::set_page_size

#PageResult

#PageResult::new

#PageResult::page_num

#PageResult::page_size

#PageResult::record_count

#PageResult::rows

#PageResult::total_page

#PerformType

#PerformType::code

#PerformType::from_code

#ProcessDefine

#ProcessDefine::clone

#ProcessDesign

#ProcessDesign::clone

#ProcessDesignHis

#ProcessDesignHis::clone

#ProcessInstance

#ProcessInstance::abandon_all_doing

#ProcessInstance::abandon_task

#ProcessInstance::add_variable

#ProcessInstance::clone

#ProcessInstance::complete_task

#ProcessInstance::create

#ProcessInstance::create_countersign_tasks

#ProcessInstance::create_history_task

#ProcessInstance::create_task

#ProcessInstance::create_with_parent

#ProcessInstance::finish

#ProcessInstance::get_doing_tasks

#ProcessInstance::get_doing_tasks_by_names

#ProcessInstance::get_done_tasks_by_names

#ProcessInstance::get_finished_tasks

#ProcessInstance::get_history_tasks

#ProcessInstance::interrupt

#ProcessInstance::is_all_tasks_finished

#ProcessInstance::is_doing

#ProcessInstance::is_finished

#ProcessInstance::pending

#ProcessInstance::reject

#ProcessInstance::reject_task

#ProcessInstance::remove_variables

#ProcessInstance::resume

#ProcessInstance::withdraw

#ProcessSurrogate

#ProcessSurrogate::clone

#ProcessTask

#ProcessTask::abandon

#ProcessTask::clone

#ProcessTask::finish

#ProcessTask::interrupt

#ProcessTask::is_allowed

CcInstance

CountersignType

CountersignType::from_str_name

DefineRow

DefineRow::new_empty

DefineState

DefineState::code

DefineState::from_code

FilterOp

FilterOp::from_str

InstanceRow

InstanceRow::new_empty

InstanceState

InstanceState::code

InstanceState::from_code

PageQuery

PageQuery::add_condition

PageQuery::add_filter

PageQuery::conditions

PageQuery::filters

PageQuery::new

PageQuery::operator

PageQuery::order_by

PageQuery::page_num

PageQuery::page_size

PageQuery::set_operator

PageQuery::set_order_by

PageQuery::set_page_num

PageQuery::set_page_size

PageResult

PageResult::new

PageResult::page_num

PageResult::page_size

PageResult::record_count

PageResult::rows

PageResult::total_page

PerformType

PerformType::code

PerformType::from_code

ProcessDefine

ProcessDefine::clone

ProcessDesign

ProcessDesign::clone

ProcessDesignHis

ProcessDesignHis::clone

ProcessInstance

ProcessInstance::abandon_all_doing

ProcessInstance::abandon_task

ProcessInstance::add_variable

ProcessInstance::clone

ProcessInstance::complete_task

ProcessInstance::create

ProcessInstance::create_countersign_tasks

ProcessInstance::create_history_task

ProcessInstance::create_task

ProcessInstance::create_with_parent

ProcessInstance::finish

ProcessInstance::get_doing_tasks

ProcessInstance::get_doing_tasks_by_names

ProcessInstance::get_done_tasks_by_names

ProcessInstance::get_finished_tasks

ProcessInstance::get_history_tasks

ProcessInstance::interrupt

ProcessInstance::is_all_tasks_finished

ProcessInstance::is_doing

ProcessInstance::is_finished

ProcessInstance::pending

ProcessInstance::reject

ProcessInstance::reject_task

ProcessInstance::remove_variables

ProcessInstance::resume

ProcessInstance::withdraw

ProcessSurrogate

ProcessSurrogate::clone

ProcessTask

ProcessTask::abandon

ProcessTask::clone

ProcessTask::finish

ProcessTask::interrupt

ProcessTask::is_allowed