|
|
@@ -0,0 +1,63 @@
|
|
|
+package nckd.fi.er.task;
|
|
|
+
|
|
|
+import kd.bos.context.RequestContext;
|
|
|
+import kd.bos.dataentity.entity.DynamicObject;
|
|
|
+import kd.bos.exception.KDException;
|
|
|
+import kd.bos.orm.query.QCP;
|
|
|
+import kd.bos.orm.query.QFilter;
|
|
|
+import kd.bos.schedule.executor.AbstractTask;
|
|
|
+import kd.bos.servicehelper.BusinessDataServiceHelper;
|
|
|
+import nckd.base.common.utils.OperationUtils;
|
|
|
+import org.apache.commons.lang3.ObjectUtils;
|
|
|
+
|
|
|
+import java.util.Arrays;
|
|
|
+import java.util.List;
|
|
|
+import java.util.Map;
|
|
|
+import java.util.stream.Collectors;
|
|
|
+
|
|
|
+/**
|
|
|
+ * Created with IntelliJ IDEA.
|
|
|
+ *
|
|
|
+ * @Author: 赵嘉琪
|
|
|
+ * @Date: 2026/01/08
|
|
|
+ * @Description:差旅标准基础资料推送
|
|
|
+ */
|
|
|
+public class TravelStandardPushTask extends AbstractTask {
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public void execute(RequestContext requestContext, Map<String, Object> map) throws KDException {
|
|
|
+ //单据状态 已审核
|
|
|
+ QFilter baseQFOne = new QFilter("status", QCP.equals, "C").and("enable", QCP.equals, "1");
|
|
|
+
|
|
|
+ //报销级别
|
|
|
+ DynamicObject[] reimburselevelCol = BusinessDataServiceHelper.load("er_reimburselevel", "id", baseQFOne.toArray());
|
|
|
+ if (ObjectUtils.isNotEmpty(reimburselevelCol)) {
|
|
|
+ List<Object> ids = Arrays.stream(reimburselevelCol).map(dynamicObject -> dynamicObject.getPkValue()).collect(Collectors.toList());
|
|
|
+ //调用后台操作推送
|
|
|
+ OperationUtils.operationDoSave("er_reimburselevel", ids);
|
|
|
+ }
|
|
|
+ //出差地域
|
|
|
+ DynamicObject[] tripareatListCol = BusinessDataServiceHelper.load("er_triparea", "id", baseQFOne.toArray());
|
|
|
+ if (ObjectUtils.isNotEmpty(tripareatListCol)) {
|
|
|
+ List<Object> ids = Arrays.stream(tripareatListCol).map(dynamicObject -> dynamicObject.getPkValue()).collect(Collectors.toList());
|
|
|
+ //调用后台操作推送
|
|
|
+ OperationUtils.operationDoSave("er_triparea", ids);
|
|
|
+ }
|
|
|
+
|
|
|
+ //交通工具标准
|
|
|
+ DynamicObject[] vehicleApplyBillCol = BusinessDataServiceHelper.load("er_tripstandard_vehicle", "id", baseQFOne.toArray());
|
|
|
+ if (ObjectUtils.isNotEmpty(vehicleApplyBillCol)) {
|
|
|
+ List<Object> ids = Arrays.stream(vehicleApplyBillCol).map(dynamicObject -> dynamicObject.getPkValue()).collect(Collectors.toList());
|
|
|
+ //调用后台操作推送
|
|
|
+ OperationUtils.operationDoSave("er_tripstandard_vehicle", ids);
|
|
|
+ }
|
|
|
+
|
|
|
+ //住宿补助标准
|
|
|
+ DynamicObject[] accmodationBillCol = BusinessDataServiceHelper.load("er_tripstand_accmodation", "id", baseQFOne.toArray());
|
|
|
+ if (ObjectUtils.isNotEmpty(accmodationBillCol)) {
|
|
|
+ List<Object> ids = Arrays.stream(accmodationBillCol).map(dynamicObject -> dynamicObject.getPkValue()).collect(Collectors.toList());
|
|
|
+ //调用后台操作推送
|
|
|
+ OperationUtils.operationDoSave("er_tripstand_accmodation", ids);
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|