ecology
/
ebu_ecology_dev1
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 3 Wiki Activity

保时捷人事保存流程触发流程转数据、丰田纺织流程名称可以根据字段配置

main
youHong.ai 2022-12-09 23:10:13 +08:00
parent 76beae6bfc
commit b7af6ffe34
10 changed files with 638 additions and 62 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

141
javascript/common/Utils.js Normal file
View File

@ -0,0 +1,141 @@
window.Utils = {
/**
* @author youhong.ai
* @desc 发起请求
*/
request: function (url, type = "GET", data, isAsync = true, success = () => {
}, error = () => {
}, complete = () => {
}, contentType = 'application/json', beforeSend = () => {
}) {
let options = {
url,
type,
dataType: "json",
contentType,
async: isAsync,
data,
beforeSend,
success,
error,
complete,
}
if (contentType == 'application/json') {
options.data = JSON.stringify(data)
}
return $.ajax(options)
},
/**
* @author youhong.ai
* @desc 发起请求
*/
api: function (requestOptions = {
url: "",
type: "GET",
data: "",
isAsync: true,
success: () => {
},
error: () => {
},
complete: () => {
},
contentType: 'application/json',
beforeSend: () => {
}
}) {
let options = Object.assign({
url: "",
type: "GET",
data: "",
isAsync: true,
success: () => {
},
error: () => {
},
complete: () => {
},
contentType: 'application/json',
beforeSend: () => {
}
}, requestOptions)
return $.ajax(options)
},
/**
* @author youhong.ai
* @desc 获取react组件实例
*/
findReact: function (dom, traverseUp = 0) {
const key = Object.keys(dom).find(key => {
return key.startsWith("__reactFiber$") // react 17+
|| key.startsWith("__reactInternalInstance$")
|| key.startsWith("__reactEventHandlers$"); // react <17
});
const domFiber = dom[key];
if (domFiber == null) return null;
// react <16
if (domFiber._currentElement) {
let compFiber = domFiber._currentElement._owner;
for (let i = 0; i < traverseUp; i++) {
compFiber = compFiber._currentElement._owner;
}
return compFiber._instance;
}
// react 16+
const GetCompFiber = fiber => {
let parentFiber = fiber.return;
while (typeof parentFiber.type == "string") {
parentFiber = parentFiber.return;
}
return parentFiber;
};
let compFiber = GetCompFiber(domFiber);
for (let i = 0; i < traverseUp; i++) {
compFiber = GetCompFiber(compFiber);
}
return compFiber.stateNode;
},
/**
* 转换字段名为字段ID
* @param fieldName 字段名称
* @returns {*|string}
*/
convertNameToIdUtil: function (fieldName) {
let fieldIds = [];
if (fieldName instanceof Array) {
fieldName.forEach(item => {
fieldIds.push(Utils.convertNameObjToId(item))
})
return fieldIds.join(',')
}
return Utils.convertNameObjToId(fieldName)
},
/**
* 将字段名称转为字段id
* @param fieldObj 字段名称对象 {string|object}
* @returns {*}
*/
convertNameObjToId: function (fieldObj = {fieldName: '', table: 'main'}) {
if (typeof fieldObj === 'object') {
return WfForm.convertFieldNameToId(fieldObj.fieldName, fieldObj.table)
}
return WfForm.convertFieldNameToId(fieldObj)
},
/**
* 根据字段名称查询字段值
* @param fieldName 字段名称
* @param rowIndex 明细行下表（明细获取才传递）
* @returns {*} 字段值
*/
getFiledValueByName: function (fieldName, rowIndex) {
return WfForm.getFieldValue(Utils.convertNameObjToId(fieldName) + rowIndex ? '_' + rowIndex : '')
}
}

64
javascript/youhong.ai/pcn/dev.js → javascript/common/dev.js
View File

@ -27,7 +27,7 @@ WfForm.OPER_SAVECOMPLETE = '保存后页面跳转前 KB900210501'
WfForm.OPER_WITHDRAW = '撤回 KB900201101' WfForm.OPER_WITHDRAW = '撤回 KB900201101'
WfForm.OPER_CLOSE = '页面关闭' WfForm.OPER_CLOSE = '页面关闭'
WfForm.registerCheckEvent = (type, callback) => { WfForm.registerCheckEvent = (type, callback = (callback) = {}) => {
// WfForm.registerCheckEvent(WfForm.OPER_SAVE+","+WfForm.OPER_SUBMIT,function(callback){ // WfForm.registerCheckEvent(WfForm.OPER_SAVE+","+WfForm.OPER_SUBMIT,function(callback){
// //... 执行自定义逻辑 // //... 执行自定义逻辑
// callback(); // callback();
@ -66,7 +66,8 @@ WfForm.getFieldValue = function (fieldMark) {
// var fieldvalue = WfForm.getFieldValue("field110"); // var fieldvalue = WfForm.getFieldValue("field110");
} }
WfForm.bindFieldChangeEvent = function (fieldMarkStr, funobj) { WfForm.bindFieldChangeEvent = function (fieldMarkStr, funobj = (obj, id, value) => {
}) {
// fieldMarkStr String 是 绑定字段标示，可多个拼接逗号隔开，例如：field110(主字段),field111_2(明细字段)…… // fieldMarkStr String 是 绑定字段标示，可多个拼接逗号隔开，例如：field110(主字段),field111_2(明细字段)……
// funobj Function 是 字段值变化触发的自定义函数，函数默认传递以下三个参数，参数1：触发字段的DOM对象，参数2：触发字段的标示(field27555等)，参数3：修改后的值 // funobj Function 是 字段值变化触发的自定义函数，函数默认传递以下三个参数，参数1：触发字段的DOM对象，参数2：触发字段的标示(field27555等)，参数3：修改后的值
// WfForm.bindFieldChangeEvent("field27555,field27556", function (obj, id, value) { // WfForm.bindFieldChangeEvent("field27555,field27556", function (obj, id, value) {
@ -74,5 +75,64 @@ WfForm.bindFieldChangeEvent = function (fieldMarkStr, funobj) {
// }); // });
} }
WfForm.controlBtnDisabled = function (isDisabled) {
// isDisabled boolean 是 true：按钮全部置灰不可操作,false：恢复按钮可操作状态
// function subimtForm(params){
// WfForm.controlBtnDisabled(true); //操作按钮置灰
// ...
// WfForm.controlBtnDisabled(false);
// }
}
WfForm.showMessage = function (msg, type, duration) {
// 参数 参数类型 必须 说明
// msg String true 提示信息内容
// type int false 提示类型，1(警告)、2(错误)、3(成功)、4(一般)，默认为1，不同类型提示信息效果不同
// duration Float false 多长时间自动消失，单位秒，默认为1.5秒
// WfForm.showMessage("结束时间需大于开始时间"); //警告信息，1.5s后自动消失
// WfForm.showMessage("运算错误", 2, 10); //错误信息，10s后消失
}
WfForm.getBaseInfo = function () {
// console.log(WfForm.getBaseInfo()); //返回当前请求基础信息
// //输出对象说明：
return {
f_weaver_belongto_userid: "5240", //用户信息
f_weaver_belongto_usertype: "0",
formid: -2010, //表单id
isbill: "1", //新表单/老表单
nodeid: 19275, //节点id
requestid: 4487931, //请求id
workflowid: 16084, //路径id
}
}
WfForm.changeFieldValue = function (fieldMark, valueInfo) {
// fieldMark String 是 字段标示，格式field${字段ID}_${明细行号}
// valueInfo JSON 是 字段值信息，非浏览按钮字段格式为{value:”修改的值”};specialobj为浏览按钮信息，数组格式;showhtml属性只在单行文本类型且只读情况下生效；
//修改文本框、多行文本、选择框等字段类型
// WfForm.changeFieldValue("field123", {value:"1.234"});
// //修改浏览框字段的值，必须有specialobj数组结构对象
// WfForm.changeFieldValue("field11_2", {
// value: "2,3",
// specialobj:[
// {id:"2",name:"张三"},
// {id:"3",name:"李四"}
// ]
// });
// //修改check框字段(0不勾选、1勾选)
// WfForm.changeFieldValue("field123", {value:"1"});
// //针对单行文本框字段类型，只读情况，支持显示值跟入库值不一致
// WfForm.changeFieldValue("field123", {
// value: "入库真实值",
// specialobj: {
// showhtml: "界面显示值"
// }
// });
}

158
javascript/youhong.ai/fentian/ecode/workflow_controller.js Normal file
View File

@ -0,0 +1,158 @@
/* ******************* 丰田纺织流程代码块 可选择流程中的字段配置流程标题生成规则******************* */
class ConfigWorkflowTitle {
constructor(config) {
this.config = config
console.log(config)
}
/**
* 初始化参数
*/
init = () => {
console.log("init")
let baseInfo = WfForm.getBaseInfo();
if (baseInfo.workflowid != this.config.workflowId) {
return
}
let filedArr = []
console.log("jahh")
this.config.rules.filter(item => item.type === RulesType.FIELD_VALUE
|| item.type === RulesType.SELECT_VALUE
|| item.type === RulesType.RADIO_VALUE).forEach(item => filedArr.push(item.fieldName))
console.log("bind", filedArr)
this.addListenerEvent(filedArr)
}
/**
* 修改流程标题字段值
*/
changeWorkflowTitle = () => {
let workflowTitle = []
this.config.rules.forEach(item => {
workflowTitle.push(item.type.run(item))
})
WfForm.changeFieldValue(this.config.titleFieldName === 'field-1' ? 'field-1' :
Utils.convertNameToIdUtil(this.config.titleFieldName), {
value: workflowTitle.join("")
})
}
/**
* 添加监听方法
* @param fileNameArr 需要监听的字段数组
*/
addListenerEvent = (fileNameArr) => {
console.log(Utils.convertNameToIdUtil(fileNameArr))
WfForm.bindFieldChangeEvent(Utils.convertNameToIdUtil(fileNameArr), (obj, id, value) => {
this.changeWorkflowTitle()
})
}
}
class RulesType {
// 固定值
static FIX_STRING = {
value: 0,
run: item => item.value
}
// 字段值
static FIELD_VALUE = {
value: 1,
run: item => Utils.getFiledValueByName(item.fieldName)
}
// 下拉框显示值
static SELECT_VALUE = {
value: 2,
run: item => $(`div[data-fieldname='${item.fieldName}'] .ant-select-selection-selected-value`).text()
}
// 单选按钮
static RADIO_VALUE = {
value: 3,
run: item => $(`div[data-fieldname='${item.fieldName}'] .ant-radio.ant-radio.ant-radio-checked.ant-radio-checked`).next().text()
}
// 当前日期 yyyy-mm-dd
static CURRENT_DATE = {
value: 4,
run: () => {
const date = new Date();
let year = date.getFullYear();
let month = date.getMonth() + 1;
let day = date.getDay();
return year + "-" + month + "-" + day
}
}
// 当前时间 HH:mm:ss
static CURRENT_TIME = {
value: 5,
run: () => {
const date = new Date();
let hours = date.getHours();
let minutes = date.getMinutes();
let seconds = date.getSeconds();
return hours + ":" + minutes + ":" + seconds
}
}
// 当前年份
static CURRENT_YEAR = {
value: 6,
run: () => new Date().getFullYear()
}
// 当前月份
static CURRENT_MONTH = {
value: 7,
run: () => new Date().getMonth() + 1
}
// 当前天数
static CURRENT_DAY = {
value: 8,
run: () => new Date().getDay()
}
// 当前小时
static CURRENT_HOUR = {
value: 9,
run: () => new Date().getHours()
}
// 当前分钟
static CURRENT_MINUTE = {
value: 10,
run: () => new Date().getMinutes()
}
// 当前秒数
static CURRENT_SECOND = {
value: 11,
run: () => new Date().getSeconds()
}
// 当前时间戳
static CURRENT_TIME_STAMP = {
value: 12,
run: () => new Date().getTime()
}
// 流水号
static RANDOM = {
value: 13,
run: item => {
let result = []
let range = [1, 2, 3, 4, 5, 6, 7, 8, 9, 0]
for (let i = 0; i < item.length; i++) {
let index = parseInt(Math.random(0, 10) * 10)
result.push(range[index])
}
return result.join("")
}
}
}
window.RulesType = RulesType
window.ConfigWorkflowTitle = ConfigWorkflowTitle
/* ******************* 可选择流程中的字段配置流程标题生成规则 end ******************* */

29
javascript/youhong.ai/fentian/workflow_code_block.js Normal file
View File

@ -0,0 +1,29 @@
/* ******************* youhong.ai 丰田纺织流程代码块 可选择流程中的字段配置流程标题生成规则******************* */
$(() => {
let workflowTitleConfig = {
workflowId: '44',
titleFieldName: 'field-1',
rules: [{
type: RulesType.CURRENT_DATE
},
{
type: RulesType.FIX_STRING,
value: '-'
}, {
type: RulesType.FIELD_VALUE,
fieldName: 'mc'
}, {
type: RulesType.FIELD_VALUE,
fieldName: 'sjid'
}, {
type: RulesType.RANDOM,
length: 5
}, {
type: RulesType.RANDOM,
length: 5
}]
}
new ConfigWorkflowTitle(workflowTitleConfig).init()
})
/* ******************* 可选择流程中的字段配置流程标题生成规则 end ******************* */

40
javascript/youhong.ai/pcn/Utils.js
View File

@ -1,40 +0,0 @@
$(() => {
/**
* @author youhong.ai
* @desc 获取react组件实例
*/
function findReact(dom, traverseUp = 0) {
const key = Object.keys(dom).find(key => {
return key.startsWith("__reactFiber$") // react 17+
|| key.startsWith("__reactInternalInstance$") // react <17
});
const domFiber = dom[key];
if (domFiber == null) return null;
// react <16
if (domFiber._currentElement) {
let compFiber = domFiber._currentElement._owner;
for (let i = 0; i < traverseUp; i++) {
compFiber = compFiber._currentElement._owner;
}
return compFiber._instance;
}
// react 16+
const GetCompFiber = fiber => {
let parentFiber = fiber.return;
while (typeof parentFiber.type == "string") {
parentFiber = parentFiber.return;
}
return parentFiber;
};
let compFiber = GetCompFiber(domFiber);
for (let i = 0; i < traverseUp; i++) {
compFiber = GetCompFiber(compFiber);
}
return compFiber.stateNode;
}
window.Utils = {
findReact,
}
})

72
javascript/youhong.ai/pcn/workflow_code_block.js
View File

@ -13,9 +13,13 @@ function doNotClickSubmit() {
} }
if (submitButton.length !== 0) { if (submitButton.length !== 0) {
let buttonReact = window.Utils.findReact(submitButton[0]) let buttonReact = window.Utils.findReact(submitButton[0])
console.log(buttonReact) let rightBtn = Utils.findReact($(".ant-menu-item.text-elli[ecid='_Route@vmt0lk_Comp@upn4fo_WeaRightMenu@1ok9r0_Item@eu37n0_li@zyccqn']")[0])
buttonReact.props.disabled = true setTimeout(() => {
buttonReact.setState({disabled: true}) buttonReact.props.disabled = true
buttonReact.setState({})
rightBtn.props.disabled = true
rightBtn.setState({})
}, 100)
} }
} }
@ -32,21 +36,21 @@ function allowClickSubmit() {
submitButton = $("#weareqtop_9v5e5i_1670481049632 div.ant-row.wea-new-top-req div.ant-col-xs-18.ant-col-sm-18.ant-col-md-16.ant-col-lg-14 button[title='提交'],[title='Submit '],[title='Submit']") submitButton = $("#weareqtop_9v5e5i_1670481049632 div.ant-row.wea-new-top-req div.ant-col-xs-18.ant-col-sm-18.ant-col-md-16.ant-col-lg-14 button[title='提交'],[title='Submit '],[title='Submit']")
} }
if (submitButton.length !== 0) { if (submitButton.length !== 0) {
WfForm.controlBtnDisabled(false)
let buttonReact = window.Utils.findReact(submitButton[0]) let buttonReact = window.Utils.findReact(submitButton[0])
console.log(buttonReact)
buttonReact.props.disabled = false buttonReact.props.disabled = false
buttonReact.setState({disabled: false}) buttonReact.setState({})
} }
} }
/** /**
* 监听qzhj字段值改变 * 监听qzhj字段值改变
* @author youhong.ai
* @param id 字段id * @param id 字段id
* @param value 字段值 * @param value 字段值
* @param obj 字段值对象 * @param obj 字段值对象
*/ */
function onQzhjFieldChangeValue(id, value, obj) { function onQzhjFieldChangeValue(obj, id, value) {
console.log(value)
if (value != '100') { if (value != '100') {
doNotClickSubmit() doNotClickSubmit()
} else { } else {
@ -56,18 +60,70 @@ function onQzhjFieldChangeValue(id, value, obj) {
/** /**
* 检查qzhj字段值 * 检查qzhj字段值
* @author youhong.ai
* @param fieldId qzhj字段id * @param fieldId qzhj字段id
*/ */
function checkOnQzhJfiedlChangeValue(fieldId) { function checkOnQzhJfiedlChangeValue(fieldId) {
let value = WfForm.getFieldValue(fieldId); let value = WfForm.getFieldValue(fieldId);
onQzhjFieldChangeValue(null, value) onQzhjFieldChangeValue(null, null, value)
}
/**
* 检查提交按钮是否符合条件
* @author youhong.ai
* @param fieldId 字段id
* @returns {(function(function()=): void)|*}
*/
function checkClickSubmit(fieldId) {
return (callback = () => {
}) => {
let value = WfForm.getFieldValue(fieldId);
if (value != 100) {
WfForm.showMessage("~`~`7 目标设定的总值必须是100%，请检查并修改后提交。 " + "`~`8 The total value of target setting must be 100%,please check to submit after modification! " + "`~`9 目标设定的总值必须是100%，请检查并修改后提交。`~`~", 2, 5);
} else {
callback()
}
}
}
/**
* 保存按钮触发流程转数据
* @author youhong.ai
* @param callback 保存后页面跳转前回调
*/
async function saveTriggerWorkflowToModel() {
let baseInfo = WfForm.getBaseInfo()
if (baseInfo && baseInfo.requestid != '-1') {
let result = await Utils.api({
url: "/api/aiyh/workflow/target-setting/save-trigger",
type: "POST",
contentType: "application/json",
data: JSON.stringify({requestId: baseInfo.requestid})
})
if (result && result.code === 200) {
localStorage.setItem("saveTriggerWorkflowToModel", "false")
}
}
}
function saveAfterCallback(callback) {
localStorage.setItem("saveTriggerWorkflowToModel", "true")
callback()
} }
$(() => { $(() => {
let qzhjFieldId = WfForm.convertFieldNameToId("qzhj") let qzhjFieldId = WfForm.convertFieldNameToId("qzhj")
checkOnQzhJfiedlChangeValue(qzhjFieldId) checkOnQzhJfiedlChangeValue(qzhjFieldId)
WfForm.registerCheckEvent(WfForm.OPER_SUBMIT, checkClickSubmit(qzhjFieldId))
WfForm.registerCheckEvent(WfForm.OPER_SAVECOMPLETE, saveAfterCallback)
WfForm.bindFieldChangeEvent(qzhjFieldId, onQzhjFieldChangeValue) WfForm.bindFieldChangeEvent(qzhjFieldId, onQzhjFieldChangeValue)
let flag = localStorage.getItem("saveTriggerWorkflowToModel")
if (flag === "true") {
saveTriggerWorkflowToModel()
}
}) })
/* ******************* 保时捷target setting流程提交控制 end ******************* */ /* ******************* 保时捷target setting流程提交控制 end ******************* */

49
src/main/java/com/api/youhong/ai/pcn/workflow/doworkflowtomodel/controller/TriggerWorkflowToModelController.java Normal file
View File

@ -0,0 +1,49 @@
package com.api.youhong.ai.pcn.workflow.doworkflowtomodel.controller;
import aiyh.utils.ApiResult;
import aiyh.utils.Util;
import com.api.youhong.ai.pcn.workflow.doworkflowtomodel.service.TriggerWorkflowToModelService;
import io.swagger.v3.oas.annotations.parameters.RequestBody;
import org.apache.log4j.Logger;
import weaver.hrm.HrmUserVarify;
import weaver.hrm.User;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.ws.rs.Consumes;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.core.Context;
import javax.ws.rs.core.MediaType;
import java.util.Map;
/**
* <h1>保存按钮流程转数据接口</h1>
*
* <p>create: 2022-12-08 18:09</p>
*
* @author youHong.ai
*/
@Path("/aiyh/workflow/target-setting")
public class TriggerWorkflowToModelController {
private final TriggerWorkflowToModelService service = new TriggerWorkflowToModelService();
private final Logger logger = Util.getLogger();
@Path("/save-trigger")
@POST
@Consumes(MediaType.APPLICATION_JSON)
@Produces(MediaType.APPLICATION_JSON)
public String saveTriggerWorkflowToModel(@RequestBody Map<String, Object> params,
@Context HttpServletRequest request, @Context HttpServletResponse response) {
try {
User user = HrmUserVarify.getUser(request, response);
return ApiResult.success(service.saveTriggerWorkflowToModel(params, request, user));
} catch (Exception e) {
logger.error("save trigger workflow to mode data error ! \n" + Util.getErrString(e));
return ApiResult.error(e.getMessage());
}
}
}

35
src/main/java/com/api/youhong/ai/pcn/workflow/doworkflowtomodel/mapper/TriggerWorkflowToModelMapper.java Normal file
View File

@ -0,0 +1,35 @@
package com.api.youhong.ai.pcn.workflow.doworkflowtomodel.mapper;
import aiyh.utils.annotation.recordset.ParamMapper;
import aiyh.utils.annotation.recordset.Select;
import aiyh.utils.annotation.recordset.SqlMapper;
import java.util.List;
/**
* <h1>查询数据库</h1>
*
* <p>create: 2022-12-09 22:26</p>
*
* @author youHong.ai
*/
@SqlMapper
public interface TriggerWorkflowToModelMapper {
/**
* <h2>查询当前节点上的流程转数据acitonId</h2>
* <i>2022/12/9 22:29</i>
* ******************************************
*
* @param nodeId 当前节点id
* @return List<Integer> 流程转数据的actionId
* @author youHong.ai ******************************************
*/
@Select("select ACTIONID from mode_workflowtomodeset where TRIGGERNODEID = #{nodeId} " +
" and isenable = 1 and workflowid = #{workflowId}")
List<Integer> selectActionId(@ParamMapper("nodeId") String nodeId,
@ParamMapper("workflowId") String workflowId);
}

58
src/main/java/com/api/youhong/ai/pcn/workflow/doworkflowtomodel/service/TriggerWorkflowToModelService.java Normal file
View File

@ -0,0 +1,58 @@
package com.api.youhong.ai.pcn.workflow.doworkflowtomodel.service;
import aiyh.utils.Util;
import com.api.youhong.ai.pcn.workflow.doworkflowtomodel.mapper.TriggerWorkflowToModelMapper;
import weaver.formmode.interfaces.action.WorkflowToMode;
import weaver.hrm.User;
import weaver.soa.workflow.request.RequestInfo;
import weaver.soa.workflow.request.RequestService;
import weaver.workflow.request.RequestManager;
import javax.servlet.http.HttpServletRequest;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Objects;
/**
* <h1></h1>
*
* <p>create: 2022-12-09 10:49</p>
*
* @author youHong.ai
*/
public class TriggerWorkflowToModelService {
private final RequestService service = new RequestService();
private final TriggerWorkflowToModelMapper mapper = Util.getMapper(TriggerWorkflowToModelMapper.class);
public String saveTriggerWorkflowToModel(Map<String, Object> params, HttpServletRequest request, User user) {
String requestId = String.valueOf(params.get("requestId"));
String nodeId = String.valueOf(params.get("nodeId"));
String isBill = String.valueOf(params.get("isBill"));
String formId = String.valueOf(params.get("formId"));
String workflowId = String.valueOf(params.get("workflowId"));
RequestInfo requestInfo = service.getRequest(Integer.parseInt(requestId));
RequestManager requestManager = requestInfo.getRequestManager();
requestManager.setRequest(request);
requestManager.setUser(user);
requestManager.setNodeid(Integer.parseInt(nodeId));
requestManager.setIsbill(Integer.parseInt(isBill));
requestManager.setFormid(Integer.parseInt(formId));
WorkflowToMode workflowToMode = new WorkflowToMode();
workflowToMode.setNodeid(Integer.parseInt(nodeId));
List<Integer> actionIds = mapper.selectActionId(nodeId, workflowId);
if (Objects.isNull(actionIds) || actionIds.isEmpty()) {
return "can not query actionIds;";
}
List<Integer> failAction = new ArrayList<>();
for (Integer actionId : actionIds) {
workflowToMode.setActionid(actionId);
if ("0".equals(workflowToMode.execute(requestInfo))) {
failAction.add(actionId);
}
}
return "action execute finish! " + Util.intJoin(failAction, ",") + "execute fail!";
}
}

54
src/test/java/youhong/ai/pcn/TestOrganization.java
View File

@ -16,8 +16,12 @@ import org.apache.http.HttpResponse;
import org.apache.http.NameValuePair; import org.apache.http.NameValuePair;
import org.junit.Test; import org.junit.Test;
import weaver.conn.RecordSet; import weaver.conn.RecordSet;
import weaver.formmode.interfaces.action.WorkflowToMode;
import weaver.general.GCONST; import weaver.general.GCONST;
import weaver.hrm.User; import weaver.hrm.User;
import weaver.soa.workflow.request.RequestInfo;
import weaver.soa.workflow.request.RequestService;
import weaver.workflow.request.RequestManager;
import weaver.xiao.commons.config.entity.MultipartFile; import weaver.xiao.commons.config.entity.MultipartFile;
import weaver.xiao.commons.config.entity.RequestMappingConfig; import weaver.xiao.commons.config.entity.RequestMappingConfig;
import weaver.xiao.commons.config.service.DealWithMapping; import weaver.xiao.commons.config.service.DealWithMapping;
@ -154,16 +158,16 @@ public class TestOrganization extends BaseTest {
@Test @Test
public void testReadCsv() { public void testReadCsv() {
String srcPath = GCONST.getSysFilePath() + "HRIS_PositionExport20221120" + ".csv"; String srcPath = GCONST.getSysFilePath() + "HRIS_PositionExport20221120" + ".csv";
// String charset = "utf-8"; // String charset = "utf-8";
// try (CSVReader csvReader = new CSVReaderBuilder(new BufferedReader(new InputStreamReader(new FileInputStream(new File(srcPath)), charset))).build()) { // try (CSVReader csvReader = new CSVReaderBuilder(new BufferedReader(new InputStreamReader(new FileInputStream(new File(srcPath)), charset))).build()) {
// Iterator<String[]> iterator = csvReader.iterator(); // Iterator<String[]> iterator = csvReader.iterator();
// while (iterator.hasNext()) { // while (iterator.hasNext()) {
// Arrays.stream(iterator.next()).forEach(System.out::print); // Arrays.stream(iterator.next()).forEach(System.out::print);
// System.out.println(); // System.out.println();
// } // }
// } catch (Exception e) { // } catch (Exception e) {
// e.printStackTrace(); // e.printStackTrace();
// } // }
BufferedReader reader = null; BufferedReader reader = null;
String line = null; String line = null;
@ -176,8 +180,8 @@ public class TestOrganization extends BaseTest {
String[] fieldsArr = null; String[] fieldsArr = null;
int lineNum = 0; int lineNum = 0;
int insertResult = 0; int insertResult = 0;
// TableInfo tableInfo = new TableInfo(); // TableInfo tableInfo = new TableInfo();
// tableInfo.setTableName(tableName); // tableInfo.setTableName(tableName);
try { try {
List<List<String>> listField = new ArrayList<>(); List<List<String>> listField = new ArrayList<>();
while ((line = reader.readLine()) != null) { while ((line = reader.readLine()) != null) {
@ -222,4 +226,30 @@ public class TestOrganization extends BaseTest {
List<OrgChartNodeVo> orgChartTree = orgChartService.getOrgChartTree(user); List<OrgChartNodeVo> orgChartTree = orgChartService.getOrgChartTree(user);
System.out.println(JSON.toJSONString(orgChartTree)); System.out.println(JSON.toJSONString(orgChartTree));
} }
@Test
public void testWorkflowToMode() {
RequestService service = new RequestService();
RequestInfo requestInfo = service.getRequest(18028);
requestInfo.setIspreadd("1");
RequestManager requestManager = requestInfo.getRequestManager();
requestManager.setUser(new User(1));
requestManager.setNodeid(181);
requestManager.setIsbill(1);
requestManager.setWorkflowid(44);
requestInfo.setWorkflowid("44");
requestManager.setFormid(-20);
// Util.actionTest(WorkflowToMode.class, 18020);
WorkflowToMode workflowToMode = new WorkflowToMode();
workflowToMode.setIp("10.0.0.1");
workflowToMode.setNodeid(181);
// requestManager.setNextNodeid(182);
// workflowToMode.setNodelinkid(199);
workflowToMode.setActionid(8);
String execute = workflowToMode.execute(requestInfo);
System.out.println(requestManager.getMessage());
System.out.println(requestManager.getMessagecontent());
System.out.println(execute);
}
} }