From 507d193d16bc32a7cacfd2bf2c19e1db24390414 Mon Sep 17 00:00:00 2001
From: 倪影Alone <8315454+ni-ying-alone@user.noreply.gitee.com>
Date: 星期二, 03 九月 2024 18:13:12 +0800
Subject: [PATCH] 物料业务数据分发功能实现
---
src/main/java/com/itstyle/mdm/job/MdmJob.java | 14 ++++++++------
1 files changed, 8 insertions(+), 6 deletions(-)
diff --git a/src/main/java/com/itstyle/mdm/job/MdmJob.java b/src/main/java/com/itstyle/mdm/job/MdmJob.java
index a754a98..729f48f 100644
--- a/src/main/java/com/itstyle/mdm/job/MdmJob.java
+++ b/src/main/java/com/itstyle/mdm/job/MdmJob.java
@@ -28,14 +28,16 @@
public void execute(JobExecutionContext context) throws JobExecutionException {
JobDetail jobDetail = context.getJobDetail();
JobDataMap dataMap = jobDetail.getJobDataMap();
+ JobKey key = jobDetail.getKey();
+ String name = key.getName();//鏁版嵁鑾峰彇鍚嶇О
/**
* 鑾峰彇浠诲姟涓繚瀛樼殑鏂规硶鍚嶅瓧锛屽姩鎬佽皟鐢ㄦ柟娉�
*/
String methodName = dataMap.getString("jobMethodName");
try {
MdmJob job = new MdmJob();
- Method method = job.getClass().getMethod(methodName);
- method.invoke(job);
+ Method method = job.getClass().getMethod(methodName,String.class);
+ method.invoke(job,name);
} catch (NoSuchMethodException e) {
e.printStackTrace();
} catch (IllegalAccessException e) {
@@ -50,10 +52,10 @@
* 璋冪敤MDM鎺ュ彛杩涜鏁版嵁鑾峰彇鐗╂枡
* @return
*/
- public String obtainMdmData(){
+ public String obtainMdmData(String name){
mdmUtils = (MdmUtils) applicationContext.getBean("mdmUtils");
logger.info("MDM鏁版嵁鑾峰彇寮�濮�");
- mdmUtils.queryMaterial();
+ mdmUtils.queryMaterial(name);
return "";
}
@@ -61,10 +63,10 @@
* 璋冪敤MDM璁￠噺鍗曚綅鏁版嵁鑾峰彇
* @throws BeansException
*/
- public String obtainMdmUnitData(){
+ public String obtainMdmUnitData(String name){
mdmUtils = (MdmUtils) applicationContext.getBean("mdmUtils");
logger.info("MDM璁￠噺鍗曚綅鏁版嵁鑾峰彇寮�濮�");
- mdmUtils.queryMaterial();
+ mdmUtils.queryUnit(name);
return "";
}
--
Gitblit v1.8.0