主数据计量单位分发初始化

niying

2024-01-24 3c49f1e5c375801f546eb7e0736280693f7187cf

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
package com.itstyle.mdm.job;
 
import com.itstyle.mdm.utils.MdmUtils;
import com.itstyle.Application;
import org.quartz.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
 
import java.io.Serializable;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
 
/**
 * MDM主数据获取
 */
@DisallowConcurrentExecution
public class MdmJob implements Job, Serializable, ApplicationContextAware {
    private static final Logger logger = LoggerFactory.getLogger(Application.class);
    private static final long serialVersionUID = 1L;
    private static ApplicationContext applicationContext;
    private static MdmUtils mdmUtils;
 
 
    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        JobDetail jobDetail = context.getJobDetail();
        JobDataMap dataMap = jobDetail.getJobDataMap();
        /**
         * 获取任务中保存的方法名字，动态调用方法
         */
        String methodName = dataMap.getString("jobMethodName");
        try {
            MdmJob job = new MdmJob();
            Method method = job.getClass().getMethod(methodName);
            method.invoke(job);
        } catch (NoSuchMethodException e) {
            e.printStackTrace();
        } catch (IllegalAccessException e) {
            e.printStackTrace();
        } catch (InvocationTargetException e) {
            e.printStackTrace();
        }
    }
 
 
    /**
     * 调用MDM接口进行数据获取物料
     * @return
     */
    public String obtainMdmData(){
        mdmUtils = (MdmUtils) applicationContext.getBean("mdmUtils");
        logger.info("MDM数据获取开始");
        mdmUtils.queryMaterial();
        return "";
    }
 
    /**
     * 调用MDM计量单位数据获取
     * @throws BeansException
     */
    public String obtainMdmUnitData(){
        mdmUtils = (MdmUtils) applicationContext.getBean("mdmUtils");
        logger.info("MDM计量单位数据获取开始");
        mdmUtils.queryMaterial();
        return "";
    }
 
    @Override
    public void setApplicationContext(ApplicationContext context) throws BeansException {
        applicationContext = context;
    }
}