考察任务自动带出考察人
This commit is contained in:
parent
d23dad6142
commit
956996f819
|
|
@ -0,0 +1,219 @@
|
|||
package shkd.repc.resm.formplugin;
|
||||
|
||||
import kd.bos.bill.AbstractBillPlugIn;
|
||||
import kd.bos.dataentity.OperateOption;
|
||||
import kd.bos.dataentity.entity.DynamicObject;
|
||||
import kd.bos.dataentity.entity.DynamicObjectCollection;
|
||||
import kd.bos.dataentity.utils.StringUtils;
|
||||
import kd.bos.form.control.Control;
|
||||
import kd.bos.logging.Log;
|
||||
import kd.bos.logging.LogFactory;
|
||||
import kd.bos.orm.query.QCP;
|
||||
import kd.bos.orm.query.QFilter;
|
||||
import kd.bos.servicehelper.BusinessDataServiceHelper;
|
||||
import kd.bos.servicehelper.botp.BFTrackerServiceHelper;
|
||||
import kd.bos.servicehelper.operation.SaveServiceHelper;
|
||||
import kd.bos.servicehelper.org.OrgUnitServiceHelper;
|
||||
import kd.bos.servicehelper.org.OrgViewType;
|
||||
import kd.scm.bid.common.constant.entity.BidTemplateMangeEntity;
|
||||
import kd.sdk.plugin.Plugin;
|
||||
|
||||
import java.math.BigDecimal;
|
||||
import java.math.RoundingMode;
|
||||
import java.util.ArrayList;
|
||||
import java.util.EventObject;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.stream.Collectors;
|
||||
|
||||
/**
|
||||
* 自动设置考察任务考察对象
|
||||
*/
|
||||
public class AutomaticallySetObjectPlugin extends AbstractBillPlugIn implements Plugin {
|
||||
|
||||
private static final Log logger = LogFactory.getLog(AutomaticallySetObjectPlugin.class);
|
||||
|
||||
@Override
|
||||
public void afterBindData(EventObject e) {
|
||||
super.afterBindData(e);
|
||||
|
||||
DynamicObject dataEntity = this.getModel().getDataEntity();
|
||||
DynamicObjectCollection entry = dataEntity.getDynamicObjectCollection("entry_evaldetail");
|
||||
|
||||
if (entry == null || entry.isEmpty()) return;
|
||||
|
||||
String object = entry.get(0).getString("entryevaluatorstr");
|
||||
|
||||
// 状态暂存且分录考察人为空
|
||||
if ("A".equals(this.getModel().getValue("billstatus")) && "".equals(object)) {
|
||||
|
||||
// 获取取值逻辑
|
||||
DynamicObject dataModel = BusinessDataServiceHelper.loadSingle("qeug_datamodel",
|
||||
(new QFilter("qeug_projectsource", QCP.equals, "考察计划")).toArray());
|
||||
|
||||
if (dataModel == null) return;
|
||||
|
||||
String projectSource = dataModel.getString("qeug_projectsource");
|
||||
Long orgId;
|
||||
if ("考察计划".equals(projectSource)) {
|
||||
|
||||
// 获取考察详情
|
||||
QFilter qFilter = new QFilter("plandetails.evaltask", QCP.equals, dataEntity.getPkValue());
|
||||
DynamicObject plane = BusinessDataServiceHelper.loadSingle("resm_investigationplan", qFilter.toArray());
|
||||
|
||||
if (plane == null) return;
|
||||
|
||||
DynamicObject project = plane.getDynamicObject("qeug_project");
|
||||
if (project == null) return;
|
||||
|
||||
// 获取项目-所属组织
|
||||
QFilter qFilter1 = new QFilter("id", QCP.equals, project.get("id"));
|
||||
DynamicObject dynamicObject1 = BusinessDataServiceHelper.loadSingle("repmd_projectbill", qFilter1.toArray());
|
||||
if (dynamicObject1 == null) return;
|
||||
|
||||
DynamicObject org = dynamicObject1.getDynamicObject("org");
|
||||
if (org == null) return;
|
||||
|
||||
orgId = org.getLong("id");
|
||||
DynamicObjectCollection dataModelEntry = dataModel.getDynamicObjectCollection("entryentity");
|
||||
|
||||
// 使用 Stream API 获取所有匹配的 role 对象
|
||||
List<DynamicObject> matchingRoles = dataModelEntry.stream()
|
||||
.map(modelEntry -> modelEntry.getString("qeug_rolenumber"))
|
||||
.filter(roleNumber -> roleNumber != null)
|
||||
.map(roleNumber -> BusinessDataServiceHelper.loadSingle("wf_role", new QFilter("number", QCP.equals, roleNumber).toArray()))
|
||||
.filter(roleDynamic -> roleDynamic != null)
|
||||
.filter(roleDynamic -> roleDynamic.getDynamicObjectCollection("roleentry") != null && !roleDynamic.getDynamicObjectCollection("roleentry").isEmpty()) // 跳过 roleentry 为空的情况
|
||||
.flatMap(roleDynamic -> roleDynamic.getDynamicObjectCollection("roleentry").stream())
|
||||
.filter(role -> {
|
||||
Long roleOrgId = role.getLong("org.id");
|
||||
return roleOrgId != null && roleOrgId.compareTo(orgId) == 0; // 筛选符合条件的 role
|
||||
})
|
||||
.collect(Collectors.toList());
|
||||
// 如果有匹配项
|
||||
if (!((List<?>) matchingRoles).isEmpty()) {
|
||||
creatExamData(matchingRoles, entry);
|
||||
} else {
|
||||
findParentOrgMatch(entry, orgId, dataModelEntry);
|
||||
}
|
||||
SaveServiceHelper.saveOperate("resm_exam_task", new DynamicObject[]{dataEntity}, OperateOption.create());
|
||||
}
|
||||
}
|
||||
this.getView().updateView("entry_evaldetail");
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 递归查找上级组织
|
||||
*
|
||||
* @param entry 考察任务分录
|
||||
* @param orgId 当前工作流角色组织
|
||||
* @param dataModelEntry 取数模板
|
||||
*/
|
||||
private void findParentOrgMatch(DynamicObjectCollection entry, Long orgId, DynamicObjectCollection dataModelEntry) {
|
||||
if (orgId == null) return;
|
||||
//取上级组织.
|
||||
List<Long> dptIds = new ArrayList<>();
|
||||
dptIds.add(orgId);
|
||||
Map<Long, Long> orgParentMap = OrgUnitServiceHelper.getDirectSuperiorOrg(OrgViewType.Admin, dptIds);
|
||||
if (orgParentMap != null) {
|
||||
Long parentId = orgParentMap.get(orgId);
|
||||
DynamicObject parentOrg = BusinessDataServiceHelper.loadSingle(parentId, "bos_adminorg");
|
||||
if (parentOrg != null) {
|
||||
orgId = parentOrg.getLong("id");
|
||||
// 使用 Stream API 获取所有匹配的 role 对象
|
||||
Long finalOrgId = orgId;
|
||||
List<DynamicObject> matchingRoles = dataModelEntry.stream()
|
||||
.map(modelEntry -> modelEntry.getString("qeug_rolenumber"))
|
||||
.filter(roleNumber -> roleNumber != null)
|
||||
.map(roleNumber -> BusinessDataServiceHelper.loadSingle("wf_role", new QFilter("number", QCP.equals, roleNumber).toArray()))
|
||||
.filter(roleDynamic -> roleDynamic != null)
|
||||
.filter(roleDynamic -> roleDynamic.getDynamicObjectCollection("roleentry") != null && !roleDynamic.getDynamicObjectCollection("roleentry").isEmpty()) // 跳过 roleentry 为空的情况
|
||||
.flatMap(roleDynamic -> roleDynamic.getDynamicObjectCollection("roleentry").stream())
|
||||
.filter(role -> {
|
||||
Long roleOrgId = role.getLong("org.id");
|
||||
return roleOrgId != null && roleOrgId.compareTo(finalOrgId) == 0; // 筛选符合条件的 role
|
||||
})
|
||||
.collect(Collectors.toList());
|
||||
// 如果有匹配项，则返回；否则递归查找上级组织
|
||||
if (!matchingRoles.isEmpty()) {
|
||||
creatExamData(matchingRoles, entry);
|
||||
} else {
|
||||
findParentOrgMatch(entry, orgId, dataModelEntry); // 没有匹配项，递归调用上级组织
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 生成考察人
|
||||
* @param matchingRoles 收集符合条件的人员
|
||||
* @param entry 考察任务分录
|
||||
*/
|
||||
private void creatExamData(List<DynamicObject> matchingRoles, DynamicObjectCollection entry) {
|
||||
for (DynamicObject dynamicObject : entry) {
|
||||
StringBuilder objectText = new StringBuilder();
|
||||
DynamicObject examuator = BusinessDataServiceHelper.newDynamicObject("resm_examuator");
|
||||
String pkValue = dynamicObject.getString("id");
|
||||
examuator.set("evalentryid", pkValue);
|
||||
|
||||
DynamicObjectCollection entryCollection = examuator.getDynamicObjectCollection("entry_evaluator");
|
||||
|
||||
boolean isSingleRole = matchingRoles.size() == 1;
|
||||
|
||||
for (int i = 0; i < matchingRoles.size(); i++) {
|
||||
DynamicObject matchingRole = matchingRoles.get(i);
|
||||
DynamicObject evaluator = entryCollection.addNew();
|
||||
evaluator.set("user", matchingRole.getLong("user.id"));
|
||||
evaluator.set("userposition", matchingRole.getLong("userposition.id"));
|
||||
|
||||
String name = matchingRole.getString("user.name");
|
||||
BigDecimal weight = calculateWeight(matchingRoles.size(), i);
|
||||
String weightPercentage = formatWeight(weight);
|
||||
|
||||
if (isSingleRole) {
|
||||
objectText.append(name).append("（").append(weightPercentage).append("）");
|
||||
} else {
|
||||
if (i > 0) objectText.append(";");
|
||||
objectText.append(name).append("（").append(weightPercentage).append("）");
|
||||
}
|
||||
|
||||
evaluator.set("weight", weight);
|
||||
evaluator.set("seq", i + 1);
|
||||
}
|
||||
dynamicObject.set("entryevaluatorstr", objectText);
|
||||
try {
|
||||
SaveServiceHelper.saveOperate("resm_examuator", new DynamicObject[]{examuator}, OperateOption.create());
|
||||
} catch (Exception ex) {
|
||||
logger.error("保存考察人数据失败", ex);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 权重计算
|
||||
* @param totalRoles 人员列表
|
||||
* @param currentIndex 行数
|
||||
* @return 权重
|
||||
*/
|
||||
private BigDecimal calculateWeight(int totalRoles, int currentIndex) {
|
||||
BigDecimal weight = new BigDecimal(1.0 / totalRoles).setScale(2, RoundingMode.HALF_UP);
|
||||
if (totalRoles % 2 == 1 && currentIndex == totalRoles - 1 && totalRoles != 1) {
|
||||
weight = weight.add(new BigDecimal(0.01));
|
||||
}
|
||||
return weight;
|
||||
}
|
||||
|
||||
/**
|
||||
* 权重转百分比
|
||||
* @param weight 权重
|
||||
* @return 百分比字符串
|
||||
*/
|
||||
private String formatWeight(BigDecimal weight) {
|
||||
return weight.multiply(new BigDecimal(100)).setScale(0, RoundingMode.HALF_UP) + "%";
|
||||
}
|
||||
|
||||
|
||||
|
||||
}
|
||||
Loading…
Reference in New Issue