|
|
@@ -0,0 +1,51 @@
|
|
|
+package com.uas.erp.schedular.init;
|
|
|
+
|
|
|
+import com.uas.erp.schedular.entity.MasterTaskConfigEntity;
|
|
|
+import com.uas.erp.schedular.service.ScheduledTaskService;
|
|
|
+import com.uas.erp.schedular.task.support.TaskConfig;
|
|
|
+import com.uas.erp.schedular.task.support.TaskMapping;
|
|
|
+import org.slf4j.Logger;
|
|
|
+import org.slf4j.LoggerFactory;
|
|
|
+import org.springframework.beans.BeansException;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.beans.factory.config.BeanPostProcessor;
|
|
|
+import org.springframework.boot.CommandLineRunner;
|
|
|
+import org.springframework.stereotype.Component;
|
|
|
+
|
|
|
+import java.lang.reflect.Method;
|
|
|
+import java.util.ArrayList;
|
|
|
+import java.util.HashSet;
|
|
|
+import java.util.List;
|
|
|
+import java.util.Set;
|
|
|
+
|
|
|
+/**
|
|
|
+ * Created by Pro1 on 2017/7/26.
|
|
|
+ */
|
|
|
+@Component
|
|
|
+public class ReplyInitializer implements CommandLineRunner {
|
|
|
+
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private ScheduledTaskService scheduledTaskService;
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public void run(String... strings) throws Exception {
|
|
|
+ MasterTaskConfigEntity entity = new MasterTaskConfigEntity();
|
|
|
+ entity.setBeanName("purchaseTask");
|
|
|
+ entity.setBeanTitle("采购");
|
|
|
+ entity.setCron("");
|
|
|
+ entity.setEnabled(false);
|
|
|
+ entity.setFixedDelay(60000L);
|
|
|
+ entity.setFixedRate(-1L);
|
|
|
+ entity.setBeanName("purchaseTask");
|
|
|
+ entity.setMasterName("UAS");
|
|
|
+ entity.setMethodName("uploadPurchaseReply");
|
|
|
+ entity.setMethodTitle("上传主动回复的记录到平台");
|
|
|
+ entity.setModule("b2b");
|
|
|
+ entity.setRole("BUYER");
|
|
|
+ entity.setTransferMethod("UPLOAD");
|
|
|
+ List<MasterTaskConfigEntity> entities = new ArrayList<>();
|
|
|
+ scheduledTaskService.save(entities);
|
|
|
+ scheduledTaskService.refreshTasks();
|
|
|
+ }
|
|
|
+}
|