44 lines
1.1 KiB
Java
44 lines
1.1 KiB
Java
|
package com.zcloud.service.mq.impl;
|
||
|
|
|
||
|
|
import com.zcloud.entity.PageData;
|
||
|
|
import com.zcloud.mapper.datasource.mq.MqErrorMessageLogMapper;
|
||
|
|
import com.zcloud.mapper.datasource.mq.MqMessageLogMapper;
|
||
|
|
import com.zcloud.service.mq.LogService;
|
||
|
|
import com.zcloud.util.DateUtil;
|
||
|
|
import com.zcloud.util.Warden;
|
||
|
|
import org.springframework.scheduling.annotation.Async;
|
||
|
|
import org.springframework.stereotype.Service;
|
||
|
|
|
||
|
|
import javax.annotation.Resource;
|
||
|
|
|
||
|
|
@Service
|
||
|
|
public class LogServiceImpl implements LogService {
|
||
|
|
|
||
|
|
@Resource
|
||
|
|
private MqErrorMessageLogMapper mqErrorMessageLogMapper;
|
||
|
|
|
||
|
|
@Resource
|
||
|
|
private MqMessageLogMapper mqMessageLogMapper;
|
||
|
|
|
||
|
|
@Override
|
||
|
|
@Async
|
||
|
|
public void saveLog(PageData pageData) {
|
||
|
|
this.saveLog(pageData,"0");
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override
|
||
|
|
public void saveLog(PageData pageData, String type) {
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override
|
||
|
|
@Async
|
||
|
|
public void saveErrorMessage(PageData log,String errorMessage) {
|
||
|
|
log.put("ERROR_MESSAGE", errorMessage);
|
||
|
|
log.put("MESSAGE_ERROR_LOG_ID", Warden.get32UUID());
|
||
|
|
log.put("TYPE", "0");
|
||
|
|
log.put("TIME", DateUtil.getTime());
|
||
|
|
mqErrorMessageLogMapper.save(log);
|
||
|
|
}
|
||
|
|
}
|