guoyuepeng
/
qa-prevention-gwj
1
0
Fork 3
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/czks1.0' into czks1.0

pull/14/head
zhaoyu 2024-01-09 16:40:37 +08:00
parent e432c116f9 8ee622cdf2
commit fc7c6d7a55
6 changed files with 166 additions and 13 deletions

21
src/main/java/com/zcloud/mapper/datasource/mq/MqProductionErrorLogMapper.java Normal file
View File

@ -0,0 +1,21 @@
package com.zcloud.mapper.datasource.mq;
import com.zcloud.entity.PageData;
/**
* 说明：mq生产者动作错误记录表
* 作者：LLX
* 时间：2024-01-09
* 官网：www.zcloudchina.com
*/
public interface MqProductionErrorLogMapper {
/**新增
* @param pd
* @throws Exception
*/
void save(PageData pd);
}

20
src/main/java/com/zcloud/mapper/datasource/mq/MqProductionLogMapper.java Normal file
View File

@ -0,0 +1,20 @@
package com.zcloud.mapper.datasource.mq;
import com.zcloud.entity.PageData;
/**
* 说明：mq消费者动作记录表
* 作者：LLX
* 时间：2024-01-09
* 官网：www.zcloudchina.com
*/
public interface MqProductionLogMapper {
/**新增
* @param pd
* @throws Exception
*/
void save(PageData pd);
}

102
src/main/java/com/zcloud/service/mq/impl/DockSendMessageServiceImpl.java
View File

@ -5,9 +5,12 @@ import com.zcloud.dto.TenCorpDto;
import com.zcloud.entity.PageData;
import com.zcloud.mapper.datasource.mq.MqErrorMessageLogMapper;
import com.zcloud.mapper.datasource.mq.MqMessageLogMapper;
import com.zcloud.mapper.datasource.mq.MqProductionErrorLogMapper;
import com.zcloud.mapper.datasource.mq.MqProductionLogMapper;
import com.zcloud.service.mq.DockSendMessageService;
import com.zcloud.service.mq.LogService;
import com.zcloud.util.DateUtil;
import com.zcloud.util.StackTraceUtils;
import com.zcloud.util.Warden;
import com.zcloud.util.mq.MqUtil;
import org.apache.rocketmq.client.producer.SendResult;
@ -18,7 +21,6 @@ import org.springframework.messaging.support.GenericMessage;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.Date;
@Service
public class DockSendMessageServiceImpl implements DockSendMessageService {
@ -39,8 +41,22 @@ public class DockSendMessageServiceImpl implements DockSendMessageService {
@Resource
private MqMessageLogMapper mqMessageLogMapper;
@Resource
MqProductionErrorLogMapper mqProductionErrorLogMapper;
@Resource
MqProductionLogMapper mqProductionLogMapper;
@Override
public void sendMessage(TenCorpDto tenCorpDto) throws Exception {
public void sendMessage(TenCorpDto tenCorpDto) {
PageData productionPD = tenCorpDto.getPd();
productionPD.put("PRODUCTION_ID", Warden.get32UUID());
productionPD.put("MESSAGE_LOG_ID", tenCorpDto.getMessageLogId());
productionPD.put("PRODUCTION_TYPE", "DockSendMessageServiceImpl.sendMessage(TenCorpDto tenCorpDto)");
productionPD.put("PRODUCTION_TIME", DateUtil.getTime());
productionPD.put("CREATE_TIME", tenCorpDto.getCREATE_TIME());
productionPD.put("MARK", tenCorpDto.getMark());
productionPD.putAll(tenCorpDto.getPd());
try {
PageData log = tenCorpDto.getPd();
mqMessageLogMapper.save(log);
@ -48,6 +64,9 @@ public class DockSendMessageServiceImpl implements DockSendMessageService {
if (!sendResult.getSendStatus().equals(SendStatus.SEND_OK)) {
throw new RuntimeException("产品入栈失败");
}
productionPD.put("SUCCESS",'1');
productionPD.put("ERROR_MESSAGE","SUCCESS");
mqProductionLogMapper.save(productionPD);
} catch (Exception e) {
e.printStackTrace();
PageData log = tenCorpDto.getPd();
@ -57,11 +76,23 @@ public class DockSendMessageServiceImpl implements DockSendMessageService {
log.put("TYPE", "0");
log.put("TIME", tenCorpDto.getCREATE_TIME());
mqErrorMessageLogMapper.save(log);
productionPD.put("SUCCESS",'0');
productionPD.put("ERROR_MESSAGE", StackTraceUtils.printStackTraceToString(e));
mqProductionErrorLogMapper.save(productionPD);
}
}
@Override
public void sendMessagePicture(TenCorpDto tenCorpDto) throws Exception {
public void sendMessagePicture(TenCorpDto tenCorpDto) {
PageData productionPD = tenCorpDto.getPd();
productionPD.put("PRODUCTION_ID", Warden.get32UUID());
productionPD.put("MESSAGE_LOG_ID", tenCorpDto.getMessageLogId());
productionPD.put("PRODUCTION_TYPE", "DockSendMessageServiceImpl.sendMessagePicture(TenCorpDto tenCorpDto)");
productionPD.put("PRODUCTION_TIME", DateUtil.getTime());
productionPD.put("CREATE_TIME", tenCorpDto.getCREATE_TIME());
productionPD.put("MARK", tenCorpDto.getMark());
productionPD.putAll(tenCorpDto.getPd());
try {
PageData log = tenCorpDto.getPd();
log.put("MESSAGE_LOG_ID", Warden.get32UUID());
@ -72,6 +103,9 @@ public class DockSendMessageServiceImpl implements DockSendMessageService {
if (!sendResult.getSendStatus().equals(SendStatus.SEND_OK)) {
throw new RuntimeException("产品入栈失败");
}
productionPD.put("SUCCESS",'1');
productionPD.put("ERROR_MESSAGE","SUCCESS");
mqProductionLogMapper.save(productionPD);
} catch (Exception e) {
e.printStackTrace();
PageData log = tenCorpDto.getPd();
@ -80,11 +114,24 @@ public class DockSendMessageServiceImpl implements DockSendMessageService {
log.put("TYPE", "0");
log.put("TIME", DateUtil.getTime());
mqErrorMessageLogMapper.save(log);
productionPD.put("SUCCESS",'0');
productionPD.put("ERROR_MESSAGE", StackTraceUtils.printStackTraceToString(e));
mqProductionErrorLogMapper.save(productionPD);
}
}
@Override
public void sendMessagePictureDelete(TenCorpDto tenCorpDto) throws Exception {
public void sendMessagePictureDelete(TenCorpDto tenCorpDto) {
PageData productionPD = tenCorpDto.getPd();
productionPD.put("PRODUCTION_ID", Warden.get32UUID());
productionPD.put("MESSAGE_LOG_ID", tenCorpDto.getMessageLogId());
productionPD.put("PRODUCTION_TYPE", "DockSendMessageServiceImpl.sendMessagePictureDelete(TenCorpDto tenCorpDto)");
productionPD.put("PRODUCTION_TIME", DateUtil.getTime());
productionPD.put("CREATE_TIME", tenCorpDto.getCREATE_TIME());
productionPD.put("MARK", tenCorpDto.getMark());
productionPD.put("DATA", tenCorpDto.getData());
productionPD.putAll(tenCorpDto.getPd());
try {
PageData log = tenCorpDto.getPd();
log.put("MESSAGE_LOG_ID", Warden.get32UUID());
@ -95,6 +142,9 @@ public class DockSendMessageServiceImpl implements DockSendMessageService {
if (!sendResult.getSendStatus().equals(SendStatus.SEND_OK)) {
throw new RuntimeException("产品入栈失败");
}
productionPD.put("SUCCESS",'1');
productionPD.put("ERROR_MESSAGE","SUCCESS");
mqProductionLogMapper.save(productionPD);
} catch (Exception e) {
e.printStackTrace();
PageData log = tenCorpDto.getPd();
@ -103,11 +153,23 @@ public class DockSendMessageServiceImpl implements DockSendMessageService {
log.put("TYPE", "0");
log.put("TIME", DateUtil.getTime());
mqErrorMessageLogMapper.save(log);
productionPD.put("SUCCESS",'0');
productionPD.put("ERROR_MESSAGE", StackTraceUtils.printStackTraceToString(e));
mqProductionErrorLogMapper.save(productionPD);
}
}
@Override
public void SendDelayQueue(TenCorpDto tenCorpDto) {
PageData productionPD = tenCorpDto.getPd();
productionPD.put("PRODUCTION_ID", Warden.get32UUID());
productionPD.put("MESSAGE_LOG_ID", tenCorpDto.getMessageLogId());
productionPD.put("PRODUCTION_TYPE", "DockSendMessageServiceImpl.SendDelayQueue(TenCorpDto tenCorpDto)");
productionPD.put("PRODUCTION_TIME", DateUtil.getTime());
productionPD.put("CREATE_TIME", tenCorpDto.getCREATE_TIME());
productionPD.put("MARK", tenCorpDto.getMark());
productionPD.put("DATA", tenCorpDto.getData());
productionPD.putAll(tenCorpDto.getPd());
PageData log = tenCorpDto.getPd();
log.put("MESSAGE_LOG_ID", Warden.get32UUID());
try {
@ -127,6 +189,9 @@ public class DockSendMessageServiceImpl implements DockSendMessageService {
if (!sendResult.getSendStatus().equals(SendStatus.SEND_OK)) {
throw new RuntimeException("产品入栈失败");
}
productionPD.put("SUCCESS",'1');
productionPD.put("ERROR_MESSAGE","SUCCESS");
mqProductionLogMapper.save(productionPD);
} catch (Exception e) {
e.printStackTrace();
log.put("ERROR_MESSAGE", e.getMessage());
@ -134,12 +199,26 @@ public class DockSendMessageServiceImpl implements DockSendMessageService {
log.put("TYPE", "0");
log.put("TIME", DateUtil.getTime());
mqErrorMessageLogMapper.save(log);
productionPD.put("SUCCESS",'0');
productionPD.put("ERROR_MESSAGE", StackTraceUtils.printStackTraceToString(e));
mqProductionErrorLogMapper.save(productionPD);
}
}
@Override
public void SendDelayQueue(String message) {
TenCorpDto tenCorpDto = JSONObject.parseObject(message,TenCorpDto.class);
PageData productionPD = tenCorpDto.getPd();
productionPD.put("PRODUCTION_ID", Warden.get32UUID());
productionPD.put("MESSAGE_LOG_ID", tenCorpDto.getMessageLogId());
productionPD.put("PRODUCTION_TYPE", "DockSendMessageServiceImpl.SendDelayQueue(TenCorpDto tenCorpDto)");
productionPD.put("PRODUCTION_TIME", DateUtil.getTime());
productionPD.put("CREATE_TIME", tenCorpDto.getCREATE_TIME());
productionPD.put("MARK", tenCorpDto.getMark());
productionPD.put("DATA", tenCorpDto.getData());
productionPD.putAll(tenCorpDto.getPd());
try {
PageData log = tenCorpDto.getPd();
log.put("CREATE_TIME", DateUtil.getTime());
@ -157,20 +236,17 @@ public class DockSendMessageServiceImpl implements DockSendMessageService {
if (!sendResult.getSendStatus().equals(SendStatus.SEND_OK)) {
throw new RuntimeException("产品入栈失败");
}
productionPD.put("SUCCESS",'1');
productionPD.put("ERROR_MESSAGE","SUCCESS");
mqProductionLogMapper.save(productionPD);
} catch (Exception e) {
PageData log = tenCorpDto.getPd();
logService.saveErrorMessage(log,e.getMessage());
e.printStackTrace();
productionPD.put("SUCCESS",'0');
productionPD.put("ERROR_MESSAGE", StackTraceUtils.printStackTraceToString(e));
mqProductionErrorLogMapper.save(productionPD);
}
}
public static void main(String[] args) {
try {
System.out.println(MqUtil.analysisTime("2023-06-30 14:30:00:000"));
}catch (Exception e){
e.printStackTrace();
}
}
}

12
src/main/java/com/zcloud/util/StackTraceUtils.java Normal file
View File

@ -0,0 +1,12 @@
package com.zcloud.util;
import java.io.PrintWriter;
import java.io.StringWriter;
public class StackTraceUtils {
public static String printStackTraceToString(Throwable t) {
StringWriter sw = new StringWriter();
t.printStackTrace(new PrintWriter(sw, true));
return sw.getBuffer().toString();
}
}

12
src/main/resources/mybatis/datasource/mq/MqProductionErrorLogMapper.xml Normal file
View File

@ -0,0 +1,12 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.zcloud.mapper.datasource.mq.MqProductionErrorLogMapper">
<insert id="save">
INSERT INTO
`qa-czks-prevention`.`mq_production_error_log`
(`PRODUCTION_ID`, `MARK`, `DATA`, `MESSAGE_LOG_ID`, `SUCCESS`, `CREATE_TIME`, `PRODUCTION_TIME`, `PRODUCTION_TYPE`, `ERROR_MESSAGE`)
VALUES (#{PRODUCTION_ID}, #{MARK}, #{DATA}, #{MESSAGE_LOG_ID}, #{SUCCESS}, #{CREATE_TIME}, #{PRODUCTION_TIME},#{PRODUCTION_TYPE}, #{ERROR_MESSAGE})
</insert>
</mapper>

12
src/main/resources/mybatis/datasource/mq/MqProductionLogMapper.xml Normal file
View File

@ -0,0 +1,12 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.zcloud.mapper.datasource.mq.MqProductionLogMapper">
<insert id="save">
INSERT INTO
`qa-czks-prevention`.`mq_production_log`
(`PRODUCTION_ID`, `MARK`, `DATA`, `MESSAGE_LOG_ID`, `SUCCESS`, `CREATE_TIME`, `PRODUCTION_TIME`, `PRODUCTION_TYPE`, `ERROR_MESSAGE`)
VALUES (#{PRODUCTION_ID}, #{MARK}, #{DATA}, #{MESSAGE_LOG_ID}, #{SUCCESS}, #{CREATE_TIME}, #{PRODUCTION_TIME},#{PRODUCTION_TYPE}, #{ERROR_MESSAGE})
</insert>
</mapper>