添加获取流程已审批节点信息，优化获取下级节点方法

LICENSE

@@ -19,3 +19,62 @@ AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 SOFTWARE.
+
+GFast工作流流插件协议
+GFast在此特别提醒您（用户）在购买使用插件之前，请认真阅读本《GFast插件协议》（以下简称“协议”），确保您充分理解本协议中各条款。请您审慎阅读并选择接受或不接受本协议。您收到本插件的源代码即表示您接受本协议所有条款，否则您无权使用本协议所涉服务。您在部署Gfast、使用等行为将视为对本协议的接受，并同意接受本协议各项条款的约束。
+
+一、付费插件购买
+1、用户以GFast官网允许的支付方式购买GFast付费插件时，用户应当是具备完全民事权利能力和完全民事行为能力的自然人、法人或其他组织。若用户不具备前述主体资格，则用户及用户的监护人应承担因此而导致的一切后果，同时GFast官网将保留追究用户及其监护人民事、刑事责任等权利，且GFast有权向用户及用户的监护人索赔。
+2、用户承诺接受并遵守本协议的约定。如果用户不同意本协议的约定，应立即停止购买使用GFast付费插件。
+
+二、付费插件使用
+1、GFast插件(包含免费和付费插件)禁止用于分发平台进行二次分发。
+
+2、GFast插件仅限自己学习使用，一切商业行业和本站无关。
+
+3、GFast插件禁止分享、复制、转售和传播。
+
+4、用户不得利用GFast插件制作、上载、复制、发布、传播如下法律、法规和政策禁止的内容：
+ (1) 反对宪法所确定的基本原则的；
+ (2) 危害国家安全，泄露国家秘密，颠覆国家政权，破坏国家统一的；
+ (3) 损害国家荣誉和利益的；
+ (4) 煽动民族仇恨、民族歧视，破坏民族团结的；
+ (5) 破坏国家宗教政策，宣扬邪教和封建迷信的；
+ (6) 散布谣言，扰乱社会秩序，破坏社会稳定的；
+ (7) 散布淫秽、色情、赌博、暴力、凶杀、恐怖或者教唆犯罪的；
+ (8) 侮辱或者诽谤他人，侵害他人合法权益的；
+ (9) 不遵守法律法规底线、社会主义制度底线、国家利益底线、公民合法权益底线、社会公共秩序底线、道德风尚底线和信息真实性底线的“七条底线”要求的；
+ (10) 含有法律、行政法规禁止的其他内容的信息。
+
+如果用户违反相关上述相关使用条例，GFast官网有权利收回用户购买的付费插件，如果有违反法律、法规和政策禁用的内容进行使用的，GFast官网有权向公安机关举报并配合公安机关提供用户相关隐私个人信息。
+
+三、付费插件授权
+1、GFast付费插件标准授权仅限用于个人或企业自营网站、应用或客户定制开发，禁止二次转售插件源码。
+
+四、知识产权声明
+1、GFast插件源代码所有权归云南奇讯科技有限公司所有。
+
+2、除另有特别声明外，GFast插件所依托的代码、文字、图片等著作权、专利权及其他知识产权均归云南奇讯科技有限公司所有。
+
+五、法律责任
+1、如果GFast官网发现或收到他人举报或投诉用户违反本协议约定的，GFast官网有权不经通知随时对相关内容，包括但不限于用户资料、聊天记录进行审查、删除，并视情节轻重对违规帐号处以包括但不限于警告、设备封禁、功能封禁的处罚。
+
+2、用户理解并同意，GFast官网有权依合理判断对违反有关法律法规或本协议规定的行为进行处罚，对违法违规的任何用户采取适当的法律行动，并依据法律法规保存有关信息向有关部门报告等，用户应承担由此而产生的一切法律责任。
+
+3、用户理解并同意，因用户违反本协议约定，导致或产生的任何第三方主张的任何索赔、要求或损失，包括合理的律师费，用户应当赔偿GFast官网与合作公司、关联公司，并使之免受损害。
+
+六、服务的变更、中断、终止
+1、鉴于网络服务的特殊性，用户同意GFast官网有权随时变更、中断或终止部分或全部的服务（包括收费服务）。GFast官网变更、中断或终止的服务，GFast官网应当在变更、中断或终止之前通知用户。
+
+2、如发生下列任何一种情形，GFast官网有权变更、中断或终止向用户提供的免费服务或收费服务，而无需对用户或任何第三方承担任何责任：
+ (1) 根据法律规定用户应提交真实信息，而用户提供的个人资料不真实、又未能提供合理证明；
+ (2) 用户违反相关法律法规或本协议的约定；
+ (3) 按照法律规定或有权机关的要求；
+ (4) 出于安全的原因或其他必要的情形。
+
+七、其他
+1、GFast官网郑重提醒用户注意本协议中免除GFast官网责任和限制用户权利的条款，请用户仔细阅读，自主考虑风险。未成年人应在法定监护人的陪同下阅读本协议。
+
+2、本协议的效力、解释及纠纷的解决，适用于中华人民共和国法律。若用户和GFast官网之间发生任何纠纷或争议，首先应友好协商解决，协商不成的，用户同意将纠纷或争议提交GFast官网住所地有管辖权的人民法院管辖。
+
+3、本协议的任何条款无论因何种原因无效或不具可执行性，其余条款仍有效，对双方具有约束力。

app/service/common/work_flow_service/process.go

@@ -418,23 +418,78 @@ func getFirstProcess(processes []*wf_flow_process.Entity) *wf_flow_process.Entit
 
 //获取步骤所有下级步骤
 func GetAllNextProcessIds(id uint) (ids []uint, err error) {
-	entity := (*wf_flow_process.Entity)(nil)
-	entity, err = wf_flow_process.GetProcessInfoById(id)
-	ids = make([]uint, 0, 100)
+	processData := ([]*wf_flow_process.ProcessData)(nil)
+	processData, err = GetAllProcessesByProcessId(id)
 	if err != nil {
 		return
 	}
-	if entity != nil && entity.ProcessTo != "" {
-		processTo := gstr.Split(entity.ProcessTo, ",")
-		for _, v := range processTo {
-			id := gconv.Uint(v)
+	ids = GetNextProcessesById(id, processData)
+	return
+}
+
+//获取步骤所有上级步骤
+func GetAllPreProcessIds(id uint) (ids []uint, err error) {
+	processData := ([]*wf_flow_process.ProcessData)(nil)
+	processData, err = GetAllProcessesByProcessId(id)
+	if err != nil {
+		return
+	}
+	ids = GetPreProcessesById(id, processData)
+	return
+}
+
+//获取对应步骤所属流程的所有步骤数据
+func GetAllProcessesByProcessId(id uint) (processData []*wf_flow_process.ProcessData, err error) {
+	process := (*wf_flow_process.Entity)(nil)
+	process, err = wf_flow_process.GetProcessInfoById(id)
+	if err != nil {
+		return
+	}
+	if process == nil {
+		err = gerror.New("流程步骤信息不存在")
+		return
+	}
+	//获取流程下所有步骤
+	_, processData, err = wf_flow_process.ProcessAll(gconv.Int64(process.FlowId))
+	return
+}
+
+//获取所有上级步骤切片id
+func GetPreProcessesById(id uint, processData []*wf_flow_process.ProcessData) (ids []uint) {
+	ids = make([]uint, 0, len(processData))
+	for _, v := range processData {
+		processTo := gstr.Split(v.ProcessTo, ",")
+		processToArr := garray.NewStrArrayFrom(processTo)
+		if processToArr.Contains(gconv.String(id)) {
+			id := gconv.Uint(v.Id)
 			ids = append(ids, id)
-			idsChd := make([]uint, 0, 100)
-			idsChd, err = GetAllNextProcessIds(id)
-			if err != nil {
-				return nil, err
+			idsChd := GetPreProcessesById(id, processData)
+			if len(idsChd) > 0 {
+				ids = append(ids, idsChd...)
+			}
+		}
+	}
+	return
+}
+
+//获取所有下级步骤id切片
+func GetNextProcessesById(id uint, processData []*wf_flow_process.ProcessData) (ids []uint) {
+	ids = make([]uint, 0, len(processData))
+	for _, v := range processData {
+		if id == gconv.Uint(v.Id) {
+			processTo := gstr.Split(v.ProcessTo, ",")
+			for _, v := range processTo {
+				id := gconv.Uint(v)
+				if id == 0 {
+					continue
+				}
+				ids = append(ids, id)
+				idsChd := make([]uint, 0, len(processData))
+				idsChd = GetNextProcessesById(id, processData)
+				if len(idsChd) > 0 {
+					ids = append(ids, idsChd...)
+				}
 			}
-			ids = append(ids, idsChd...)
 		}
 	}
 	return

app/service/common/work_flow_service/run_process.go

@@ -141,3 +141,11 @@ func GetBackTodo(req *wf_flow.BackTodoReq) (string, error) {
 	}
 	return todo, nil
 }
+
+func GetAllRunProcessByRunId(runId int) (runProcess []*wf_run_process.Entity, err error) {
+	runProcess, err = wf_run_process.GetProcessByMap(g.Map{
+		"run_id": runId,
+		"status": 2,
+	})
+	return
+}