|
@@ -15,7 +15,6 @@ import cn.com.qmth.multithread.Producer;
|
|
|
|
|
|
|
|
public class MyProducer extends Producer {
|
|
public class MyProducer extends Producer {
|
|
|
private static Logger logger = LogManager.getLogger(MyProducer.class);
|
|
private static Logger logger = LogManager.getLogger(MyProducer.class);
|
|
|
- private static String sourceDir = "d:/yunkai/";
|
|
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
protected void produce(Map<String, Object> param) throws Exception {
|
|
protected void produce(Map<String, Object> param) throws Exception {
|
|
@@ -27,7 +26,7 @@ public class MyProducer extends Producer {
|
|
|
String token=param.get("token").toString();
|
|
String token=param.get("token").toString();
|
|
|
String batch=param.get("batch").toString();
|
|
String batch=param.get("batch").toString();
|
|
|
// List<Course> cs = readSubject();
|
|
// List<Course> cs = readSubject();
|
|
|
- Map<String,ImportCourse> ics=readSubjectCodes();
|
|
|
|
|
|
|
+ Map<String,ImportCourse> ics=readSubjectCodes(sourceDir);
|
|
|
if (ics.size()==0) {
|
|
if (ics.size()==0) {
|
|
|
logger.debug("无数据导入");
|
|
logger.debug("无数据导入");
|
|
|
return;
|
|
return;
|
|
@@ -40,7 +39,7 @@ public class MyProducer extends Producer {
|
|
|
logger.info("***************************任务生产结束");
|
|
logger.info("***************************任务生产结束");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- private static Map<String,ImportCourse> readSubjectCodes() {
|
|
|
|
|
|
|
+ private static Map<String,ImportCourse> readSubjectCodes(String sourceDir) {
|
|
|
Map<String,ImportCourse> map=new LinkedHashMap<>();
|
|
Map<String,ImportCourse> map=new LinkedHashMap<>();
|
|
|
XSSFWorkbook wb = null;
|
|
XSSFWorkbook wb = null;
|
|
|
try {
|
|
try {
|
