mldong/jeeflow-core/model

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)

CcInstance::equal

source

fn CcInstance::equal(CcInstance, CcInstance) -> Bool

automatically derived

CcInstance::not_equal

source

fn CcInstance::not_equal(x : CcInstance, y : CcInstance) -> Bool

CountersignType

source

pub(all) enum CountersignType {
  Parallel
  Sequential
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

CountersignType::equal

source

fn CountersignType::equal(CountersignType, CountersignType) -> Bool

automatically derived

CountersignType::from_str_name

source

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

CountersignType::not_equal

source

fn CountersignType::not_equal(x : CountersignType, y : CountersignType) -> Bool

CountersignType::to_repr

source

fn CountersignType::to_repr(CountersignType) -> @moonbitlang/core/debug.Repr
Repr

automatically derived

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::equal

source

fn DefineRow::equal(DefineRow, DefineRow) -> Bool

automatically derived

DefineRow::new_empty

source

fn DefineRow::new_empty() -> DefineRow

DefineRow::not_equal

source

fn DefineRow::not_equal(x : DefineRow, y : DefineRow) -> Bool

DefineState

source

pub(all) enum DefineState {
  Disable
  Enable
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

DefineState::code

source

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

DefineState::equal

source

fn DefineState::equal(DefineState, DefineState) -> Bool

automatically derived

DefineState::from_code

source

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

DefineState::not_equal

source

fn DefineState::not_equal(x : DefineState, y : DefineState) -> Bool

DefineState::to_repr

source

fn DefineState::to_repr(DefineState) -> @moonbitlang/core/debug.Repr
Repr

automatically derived

FilterOp

source

pub(all) enum FilterOp {
  Eq
  Ne
  Like
  Gt
  Lt
  Ge
  Le
  In
  Nin
  Bt
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

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

FilterOp::equal

source

fn FilterOp::equal(FilterOp, FilterOp) -> Bool

automatically derived

FilterOp::from_str

source

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

FilterOp::not_equal

source

fn FilterOp::not_equal(x : FilterOp, y : FilterOp) -> Bool

FilterOp::to_repr

source

fn FilterOp::to_repr(FilterOp) -> @moonbitlang/core/debug.Repr
Repr

automatically derived

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::equal

source

fn InstanceRow::equal(InstanceRow, InstanceRow) -> Bool

automatically derived

InstanceRow::new_empty

source

fn InstanceRow::new_empty() -> InstanceRow

InstanceRow::not_equal

source

fn InstanceRow::not_equal(x : InstanceRow, y : InstanceRow) -> Bool

InstanceState

source

pub(all) enum InstanceState {
  Doing
  Finished
  Withdraw
  Interrupt
  Reject
  Pending
  Abandon
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

InstanceState::code

source

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

InstanceState::equal

source

fn InstanceState::equal(InstanceState, InstanceState) -> Bool

automatically derived

InstanceState::from_code

source

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

InstanceState::not_equal

source

fn InstanceState::not_equal(x : InstanceState, y : InstanceState) -> Bool

InstanceState::to_repr

source

fn InstanceState::to_repr(InstanceState) -> @moonbitlang/core/debug.Repr
Repr

automatically derived

OrderTerm

source

pub(all) struct OrderTerm {
  column : String
  desc : Bool
}

排序子句单项：列名（可能带别名前缀，由调用方剥）＋是否降序

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, @moonbitlang/core/debug.Debug
Debug)

PerformType::code

source

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

PerformType::equal

source

fn PerformType::equal(PerformType, PerformType) -> Bool

automatically derived

PerformType::from_code

source

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

PerformType::not_equal

source

fn PerformType::not_equal(x : PerformType, y : PerformType) -> Bool

PerformType::to_repr

source

fn PerformType::to_repr(PerformType) -> @moonbitlang/core/debug.Repr
Repr

automatically derived

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

ProcessDefine::equal

source

fn ProcessDefine::equal(ProcessDefine, ProcessDefine) -> Bool

automatically derived

ProcessDefine::not_equal

source

fn ProcessDefine::not_equal(x : ProcessDefine, y : ProcessDefine) -> Bool

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

ProcessDesign::equal

source

fn ProcessDesign::equal(ProcessDesign, ProcessDesign) -> Bool

automatically derived

ProcessDesign::not_equal

source

fn ProcessDesign::not_equal(x : ProcessDesign, y : ProcessDesign) -> Bool

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

ProcessDesignHis::equal

source

fn ProcessDesignHis::equal(ProcessDesignHis, ProcessDesignHis) -> Bool

automatically derived

ProcessDesignHis::not_equal

source

fn ProcessDesignHis::not_equal(x : ProcessDesignHis, y : ProcessDesignHis) -> Bool

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_info : 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

仅任务级（不连带实例置 99）——spec 04 与 go/py/node 对齐，issues/180

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

submitType/表单值又能覆盖转办留下的槽位（反噬方向已被合并序挡住）。

ProcessInstance::create

source

fn ProcessInstance::create(define_info : 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

i137b_zero_caller_create_test.mbt 逐字段钉住（该用例跟着本裁定改判）。

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_info : 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

owner 2026-09-29 拍板不删。

ProcessInstance::remove_variables

source

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

ProcessInstance::resume_from_interrupt

source

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

ProcessInstance::withdraw

source

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

（spec/06「已完成(20)/已终止(40) 的任务行不得被撤回改写」）保持原样。

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

ProcessSurrogate::equal

source

fn ProcessSurrogate::equal(ProcessSurrogate, ProcessSurrogate) -> Bool

automatically derived

ProcessSurrogate::is_effective

source

fn ProcessSurrogate::is_effective(self : ProcessSurrogate, operator : String, time : String) -> Bool

（issues/120 已拍定「MoonBit 暂不注入时钟基准、对拍对 MoonBit 豁免」，非本轮缺陷）。

ProcessSurrogate::not_equal

source

fn ProcessSurrogate::not_equal(x : ProcessSurrogate, y : ProcessSurrogate) -> Bool

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

本方法只置状态与办理人列 + update_user/update_time 审计列（对齐 java finish）。

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_from_interrupt

source

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

ProcessTask::withdraw

source

fn ProcessTask::withdraw(self : ProcessTask, operator : String) -> Unit

随实例撤回：任务态 30 + update_user 回写真实撤回人（issues/114，spec/06 §withdraw）

QueryFilter

source

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

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

QueryFilter::column

source

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

QueryFilter::equal

source

fn QueryFilter::equal(QueryFilter, QueryFilter) -> Bool

automatically derived

QueryFilter::make

source

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

QueryFilter::not_equal

source

fn QueryFilter::not_equal(x : QueryFilter, y : QueryFilter) -> Bool

QueryFilter::op

source

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

QueryFilter::table_alias

source

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

QueryFilter::value

source

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

SubmitType

source

pub(all) enum SubmitType {
  Apply
  Agree
  Reject
  Rollback
  Jump
  ReApply
  RollbackToOperator
  Transfer
  CountersignDisagree
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

SubmitType::code

source

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

SubmitType::equal

source

fn SubmitType::equal(SubmitType, SubmitType) -> Bool

automatically derived

SubmitType::from_code

source

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

SubmitType::message

source

fn SubmitType::message(self : SubmitType) -> String

中文可读名（spec/07 字典 label 同源；转办文案 "A 转办给 B" 用）

SubmitType::not_equal

source

fn SubmitType::not_equal(x : SubmitType, y : SubmitType) -> Bool

SubmitType::to_repr

source

fn SubmitType::to_repr(SubmitType) -> @moonbitlang/core/debug.Repr
Repr

automatically derived

TaskActor

source

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

TaskActor::equal

source

fn TaskActor::equal(TaskActor, TaskActor) -> Bool

automatically derived

TaskActor::not_equal

source

fn TaskActor::not_equal(x : TaskActor, y : TaskActor) -> Bool

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::equal

source

fn TaskRow::equal(TaskRow, TaskRow) -> Bool

automatically derived

TaskRow::new_empty

source

fn TaskRow::new_empty() -> TaskRow

TaskRow::not_equal

source

fn TaskRow::not_equal(x : TaskRow, y : TaskRow) -> Bool

TaskState

source

pub(all) enum TaskState {
  Doing
  Finished
  Withdraw
  Interrupt
  Pending
  Abandon
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

TaskState::code

source

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

TaskState::equal

source

fn TaskState::equal(TaskState, TaskState) -> Bool

automatically derived

TaskState::from_code

source

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

TaskState::not_equal

source

fn TaskState::not_equal(x : TaskState, y : TaskState) -> Bool

TaskState::to_repr

source

fn TaskState::to_repr(TaskState) -> @moonbitlang/core/debug.Repr
Repr

automatically derived

TaskType

source

pub(all) enum TaskType {
  Major
  Assistant
  Record
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

TaskType::code

source

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

TaskType::equal

source

fn TaskType::equal(TaskType, TaskType) -> Bool

automatically derived

TaskType::from_code

source

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

TaskType::not_equal

source

fn TaskType::not_equal(x : TaskType, y : TaskType) -> Bool

TaskType::to_repr

source

fn TaskType::to_repr(TaskType) -> @moonbitlang/core/debug.Repr
Repr

automatically derived

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::equal

source

fn UserInfo::equal(UserInfo, UserInfo) -> Bool

automatically derived

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::not_equal

source

fn UserInfo::not_equal(x : UserInfo, y : UserInfo) -> Bool

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

actor_delete_forms

source

fn actor_delete_forms(raw : Array[String]) -> Array[String]

返回空数组 ⇒ 调用方一条 DELETE 都不发（早退，不得退化成"清空该任务全部参与者"）。

add_days

source

fn add_days(secs : Int64, n : Int) -> Int64

（启动词 §1：d 走日历加天，不乘 86400 秒）。

apply_expire_time

source

fn apply_expire_time(task : ProcessTask, expr : String?, args : @mldong/jeeflow-core/json.FlowData
FlowData) -> Unit

回退/跳转新建＝随行拷贝那份变量 ＝ boot2 的 hisVariable

cc_fresh_subset

source

fn cc_fresh_subset(existing : Array[String], requested : Array[String]) -> Array[String]

门面手动 createCCInstance）一律拿这个子集去 fire，子集为空 ⇒ 整支不发。

cc_ownership_operator

source

fn cc_ownership_operator(query : PageQuery) -> String?

非归属列（m_ 可选过滤）的空值放行不在本函数管辖内，维持既有通用放行不变。

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

当前墙钟秒

expire_time_prop

source

let expire_time_prop : String

（对齐 boot2 TaskParser.EXPIRE_TIME_KEY ← 设计器 JSON 的 properties.expireTime）

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）

normalize_actor

source

fn normalize_actor(raw : String) -> String?

「缺参数」错误信封报错（§2.11 要求③：不新造错误码与文案）。

normalize_actors

source

fn normalize_actors(raw : Array[String]) -> Array[String]

" " 纯空白按本条丢弃（与 §2.10 逐字同源）。

normalize_cc_actors

source

fn normalize_cc_actors(raw : Array[String]) -> Array[String]

的公开成员，既有调用方与既有测试不破；判据不在这里复制。

normalize_comma_actors

source

fn normalize_comma_actors(s : String) -> Array[String]

数字/布尔等非字符串元素不在这一档（那是 Json 形态的事，走 @engine.parse_actors 的形状适配）。

order_column_bare

source

fn order_column_bare(column : String) -> String

剥排序列的别名前缀：t.version / pd.version → version。门面沿 java 习惯写 t.，而本栈定义表在 SQL 腿里的别名是 pd ⇒ 两条腿各自把裸列名映射回去。

parse_order_by

source

fn parse_order_by(s : String) -> Array[OrderTerm]

解析 order_by：逗号分子句、空格分「列名方向」；方向缺省升序，desc 大小写不敏感。

与 java 的一处刻意差别：java 把 kv[1].toUpperCase() 原样拼进 SQL（列名有白名单、方向词没有），本函数只产出布尔值 ⇒ order_by 原文永不进 SQL 串，注入面为零。空串／全空白／只有方向词 ⇒ 空数组，由调用方各自回落缺省序。

parse_time_secs

source

fn parse_time_secs(s : String) -> Int64?

任一条不满足 ⇒ None（不是 now）。

process_time

source

fn process_time(expr : String?, args : @mldong/jeeflow-core/json.FlowData
FlowData) -> String?

  go/C# 一致按**严格**日历校验 ⇒ NULL。

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 承载）

surrogate_ownership_operator

source

fn surrogate_ownership_operator(query : PageQuery) -> String?

issues/152 ②（spec 06-facade §4.5「processSurrogate/page 归属不变式」）：委托台账分页归属列 t.operator 的有效条件判定——取值通道与 ccList（issues/141 G1）同形＝PageQuery.operator （门面 page 恒挂这条；SQL 仓拿它拼 AND operator = ?，内存仓拿它比对 s.operator）： · 缺键（None）／空串／去空白后为空 ⇒ 无效，两仓储的 page_surrogates 一律返回空页，严禁退化成"这条不加"= 读全库台账（空串行不是死行报错，是把「我是谁」整个丢了）； · 其余 ⇒ 有效，返回原值（不空白化，比对语义与逐字匹配一致）。判据只有这一份：core/memory/memory_ext.mbt 与 repository-mysql/repo/repository_ext.mbt 的 page_surrogates 都调它 ⇒ 内存仓与 SQL 仓同答案由构造堵死（spec 06 §4.5 条款 6）。非归属列（m_ 可选过滤）的"空值当没填"通用放行不在本函数管辖内，维持既有行为不变。

surrogate_scope_hit

source

fn surrogate_scope_hit(sg : ProcessSurrogate?, operator : String, time : String) -> Bool

内存仓与 SQL 仓共用，保证两仓对同一份数据给出同一答案（条款 6）。

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

#CcInstance::equal

#CcInstance::not_equal

#CountersignType

#CountersignType::equal

#CountersignType::from_str_name

#CountersignType::not_equal

#CountersignType::to_repr

#DefineRow

#DefineRow::equal

#DefineRow::new_empty

#DefineRow::not_equal

#DefineState

#DefineState::code

#DefineState::equal

#DefineState::from_code

#DefineState::not_equal

#DefineState::to_repr

#FilterOp

#FilterOp::equal

#FilterOp::from_str

#FilterOp::not_equal

#FilterOp::to_repr

#InstanceRow

#InstanceRow::equal

#InstanceRow::new_empty

#InstanceRow::not_equal

#InstanceState

#InstanceState::code

#InstanceState::equal

#InstanceState::from_code

#InstanceState::not_equal

#InstanceState::to_repr

#OrderTerm

#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::equal

#PerformType::from_code

#PerformType::not_equal

#PerformType::to_repr

#ProcessDefine

#ProcessDefine::clone

#ProcessDefine::equal

#ProcessDefine::not_equal

#ProcessDesign

#ProcessDesign::clone

#ProcessDesign::equal

#ProcessDesign::not_equal

#ProcessDesignHis

#ProcessDesignHis::clone

#ProcessDesignHis::equal

#ProcessDesignHis::not_equal

#ProcessInstance

#ProcessInstance::abandon_all_doing

#ProcessInstance::abandon_task

#ProcessInstance::add_variable

#ProcessInstance::clone

#ProcessInstance::complete_task

#ProcessInstance::create

CcInstance

CcInstance::equal

CcInstance::not_equal

CountersignType

CountersignType::equal

CountersignType::from_str_name

CountersignType::not_equal

CountersignType::to_repr

DefineRow

DefineRow::equal

DefineRow::new_empty

DefineRow::not_equal

DefineState

DefineState::code

DefineState::equal

DefineState::from_code

DefineState::not_equal

DefineState::to_repr

FilterOp

FilterOp::equal

FilterOp::from_str

FilterOp::not_equal

FilterOp::to_repr

InstanceRow

InstanceRow::equal

InstanceRow::new_empty

InstanceRow::not_equal

InstanceState

InstanceState::code

InstanceState::equal

InstanceState::from_code

InstanceState::not_equal

InstanceState::to_repr

OrderTerm

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::equal

PerformType::from_code

PerformType::not_equal

PerformType::to_repr

ProcessDefine

ProcessDefine::clone

ProcessDefine::equal

ProcessDefine::not_equal

ProcessDesign

ProcessDesign::clone

ProcessDesign::equal

ProcessDesign::not_equal

ProcessDesignHis

ProcessDesignHis::clone

ProcessDesignHis::equal

ProcessDesignHis::not_equal

ProcessInstance

ProcessInstance::abandon_all_doing

ProcessInstance::abandon_task

ProcessInstance::add_variable

ProcessInstance::clone

ProcessInstance::complete_task

ProcessInstance::create