Task.java 4.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111
  1. package cn.com.qmth.dp.examcloud.oe;
  2. import java.io.*;
  3. import java.util.ArrayList;
  4. import java.util.Arrays;
  5. import java.util.List;
  6. import java.util.Map;
  7. import cn.com.qmth.dp.examcloud.oe.modules.get_student_answer_detail.GetStduentAnswerDetailService;
  8. import cn.com.qmth.dp.examcloud.oe.modules.update_correct_answer.FixCorrectAnswerAndResetScoreService;
  9. import cn.com.qmth.examcloud.commons.util.FileUtil;
  10. import org.apache.commons.io.FileUtils;
  11. import org.apache.commons.lang3.ClassPathUtils;
  12. import org.apache.commons.lang3.RandomUtils;
  13. import org.bson.Document;
  14. import org.springframework.core.io.ClassPathResource;
  15. import org.springframework.data.mongodb.core.MongoTemplate;
  16. import org.springframework.jdbc.core.JdbcTemplate;
  17. import org.springframework.stereotype.Component;
  18. import com.mongodb.client.FindIterable;
  19. import com.mongodb.client.MongoCollection;
  20. import com.mongodb.client.MongoCursor;
  21. import cn.com.qmth.dp.examcloud.oe.modules.export_data.ExportData;
  22. import cn.com.qmth.examcloud.commons.logging.ExamCloudLog;
  23. import cn.com.qmth.examcloud.commons.logging.ExamCloudLogFactory;
  24. import cn.com.qmth.examcloud.commons.util.JsonUtil;
  25. import cn.com.qmth.examcloud.web.support.SpringContextHolder;
  26. import cn.com.qmth.examcloud.web.upyun.UpYunPathInfo;
  27. import cn.com.qmth.examcloud.web.upyun.UpyunPathEnvironmentInfo;
  28. import cn.com.qmth.examcloud.web.upyun.UpyunService;
  29. /**
  30. * 任务
  31. *
  32. * @author WANGWEI
  33. * @date 2019年9月6日
  34. * @Copyright (c) 2018-? http://qmth.com.cn All Rights Reserved.
  35. */
  36. @Component
  37. public class Task {
  38. private static ExamCloudLog log = ExamCloudLogFactory.getLog(Task.class);
  39. /**
  40. * 方法注释
  41. *
  42. * @author WANGWEI
  43. */
  44. public void start() {
  45. try {
  46. FixCorrectAnswerAndResetScoreService bean = SpringContextHolder.getBean(FixCorrectAnswerAndResetScoreService.class);
  47. bean.start();
  48. /*// ExportData bean = SpringContextHolder.getBean(ExportData.class);
  49. GetStduentAnswerDetailService bean = SpringContextHolder.getBean(GetStduentAnswerDetailService.class);
  50. // bean.start(1173L,"9999");
  51. bean.start(1191L, "100", "200", "101", "201");
  52. bean.start(1193L, "302", "303", "304", "305","306");
  53. bean.start(1192L, "300", "301", "102", "202",
  54. "103","203","104","204","105","205","106","206","401");
  55. // bean.start(764L, "A149","A150","A154");
  56. // bean.start(765L, "C149","C150","C154");
  57. // bean.start(766L, "B149","B150","B154");*/
  58. } catch (Exception e) {
  59. log.error("unexpected", e);
  60. throw new RuntimeException(e);
  61. }
  62. }
  63. /**
  64. * 连接测试
  65. *
  66. * @author WANGWEI
  67. */
  68. public static void test() {
  69. UpyunService upyunService = SpringContextHolder.getBean(UpyunService.class);
  70. UpyunPathEnvironmentInfo env = new UpyunPathEnvironmentInfo();
  71. env.setFileSuffix(".jpg");
  72. env.setRootOrgId(String.valueOf(RandomUtils.nextLong()));
  73. UpYunPathInfo upYunPathInfo = upyunService.writeFile("test", env,
  74. new File("D:/Temp/111111X.jpg"), true);
  75. System.out.println("upYunPathInfo: " + JsonUtil.toPrettyJson(upYunPathInfo));
  76. JdbcTemplate jdbcTemplate = SpringContextHolder.getBean(JdbcTemplate.class);
  77. List<Map<String, Object>> list = jdbcTemplate.queryForList("select now() from dual");
  78. System.out.println(JsonUtil.toJson(list));
  79. MongoTemplate mongoTemplate = SpringContextHolder.getBean(MongoTemplate.class);
  80. String dbName = mongoTemplate.getDb().getName();
  81. System.out.println("mongo.db=" + dbName);
  82. MongoCollection<Document> collection = mongoTemplate.getCollection("examRecordQuestions");
  83. Document filter = new Document();
  84. filter.append("examRecordDataId", 101373L);
  85. FindIterable<Document> iterable = collection.find(filter);
  86. MongoCursor<Document> iterator = iterable.iterator();
  87. while (iterator.hasNext()) {
  88. Document next = iterator.next();
  89. System.out.println("_id=" + next.getObjectId("_id"));
  90. System.out.println(JsonUtil.toPrettyJson(next));
  91. }
  92. }
  93. }