增加日志
This commit is contained in:
@@ -36,7 +36,7 @@ public class QiWeiCorpusJob {
|
|||||||
/**
|
/**
|
||||||
* 企微语料处理
|
* 企微语料处理
|
||||||
*/
|
*/
|
||||||
@XxlJob("QiWeiCorpusTask")
|
@XxlJob("qiWeiCorpusTask")
|
||||||
public ResultMsg qiWeiCorpusTask(@RequestBody String paramJson) {
|
public ResultMsg qiWeiCorpusTask(@RequestBody String paramJson) {
|
||||||
try {
|
try {
|
||||||
// 获取任务参数
|
// 获取任务参数
|
||||||
|
|||||||
@@ -92,6 +92,7 @@ public class TmOdsVdqwMessagearchivingServiceImpl extends ServiceImpl<TmOdsVdqwM
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void runQiWeiCorpusDify(String paramJson) {
|
public void runQiWeiCorpusDify(String paramJson) {
|
||||||
|
long startTime = System.currentTimeMillis();
|
||||||
log.info("runQiWeiCorpusDify paramJson {}", paramJson);
|
log.info("runQiWeiCorpusDify paramJson {}", paramJson);
|
||||||
// 获取当前日期
|
// 获取当前日期
|
||||||
LocalDate today = LocalDate.now();
|
LocalDate today = LocalDate.now();
|
||||||
@@ -142,7 +143,7 @@ public class TmOdsVdqwMessagearchivingServiceImpl extends ServiceImpl<TmOdsVdqwM
|
|||||||
}
|
}
|
||||||
// 关闭线程池
|
// 关闭线程池
|
||||||
executor.shutdown();
|
executor.shutdown();
|
||||||
|
log.info("企微数据跑批结束 耗时:{}",System.currentTimeMillis()-startTime);
|
||||||
}
|
}
|
||||||
|
|
||||||
private void processItem(OdsVdqwMessageOTD item, String statTime, String endTime) {
|
private void processItem(OdsVdqwMessageOTD item, String statTime, String endTime) {
|
||||||
|
|||||||
Reference in New Issue
Block a user