| | |
| | | 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) { |
| | |
| | | * 调用MDM接口进行数据获取物料 |
| | | * @return |
| | | */ |
| | | public String obtainMdmData(){ |
| | | public String obtainMdmData(String name){ |
| | | mdmUtils = (MdmUtils) applicationContext.getBean("mdmUtils"); |
| | | logger.info("MDM数据获取开始"); |
| | | mdmUtils.queryMaterial(); |
| | | mdmUtils.queryMaterial(name); |
| | | return ""; |
| | | } |
| | | |
| | | /** |
| | | * 调用MDM计量单位数据获取 |
| | | * @throws BeansException |
| | | */ |
| | | public String obtainMdmUnitData(String name){ |
| | | mdmUtils = (MdmUtils) applicationContext.getBean("mdmUtils"); |
| | | logger.info("MDM计量单位数据获取开始"); |
| | | mdmUtils.queryUnit(name); |
| | | return ""; |
| | | } |
| | | |