Middleware/msgpush
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

微调

Browse Source
This commit is contained in:
caozehui
2026-03-04 20:37:48 +08:00
parent cfa3f1759c
commit b048ecfc53
4 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/client/sender/impl/TelecomSmsSender.java
View File

@@ -127,7 +127,7 @@ public class TelecomSmsSender implements SmsSender {
this.getDownInfo(mid); this.getDownInfo(mid);
this.scheduledExecutorService.shutdown(); this.scheduledExecutorService.shutdown();
this.scheduledExecutorService = null; this.scheduledExecutorService = null;
}, 2, TimeUnit.SECONDS); }, 10, TimeUnit.SECONDS);
return true; return true;
} else { } else {
ProviderErrorCodeMappingDO providerErrorCodeMappingDO = this.sender.providerErrorCodeMappingService.getByProviderErrorCode(message.getProviderType(), message.getChannel(), telecomSmsSendResponse.list.get(0).result + ""); ProviderErrorCodeMappingDO providerErrorCodeMappingDO = this.sender.providerErrorCodeMappingService.getByProviderErrorCode(message.getProviderType(), message.getChannel(), telecomSmsSendResponse.list.get(0).result + "");
@@ -217,7 +217,7 @@ public class TelecomSmsSender implements SmsSender {
headers, headers,
String.class String.class
); );
System.out.println(JSON.toJSONString(response.getBody())); System.out.println(JSON.toJSONString(JSON.toJSONString(response)));
if (response.getStatusCode() == HttpStatus.OK) { if (response.getStatusCode() == HttpStatus.OK) {
TelecomSmsSelectResponse telecomSmsSelectResponse = JSON.parseObject(response.getBody(), TelecomSmsSelectResponse.class); TelecomSmsSelectResponse telecomSmsSelectResponse = JSON.parseObject(response.getBody(), TelecomSmsSelectResponse.class);

1
msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/controller/admin/channel/ChannelProviderConfigController.java
View File

@@ -31,6 +31,7 @@ import java.util.Map;
import static com.njcn.msgpush.framework.common.pojo.CommonResult.success; import static com.njcn.msgpush.framework.common.pojo.CommonResult.success;
@Tag(name = "管理后台 - 渠道服务商") @Tag(name = "管理后台 - 渠道服务商")
@Slf4j @Slf4j
@Validated @Validated

2
msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/dal/dataobject/retry/MessageRetryHistoryDO.java
View File

@@ -12,7 +12,7 @@ import java.time.LocalDateTime;
* @data 2026-03-04 * @data 2026-03-04
*/ */
@Data @Data
@TableName("push_message_retry_queue") @TableName("push_message_retry_history")
@EqualsAndHashCode(callSuper = true) @EqualsAndHashCode(callSuper = true)
public class MessageRetryHistoryDO extends BaseDO { public class MessageRetryHistoryDO extends BaseDO {
private Integer id; private Integer id;

2
msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/service/retry/MessageRetryHistoryServiceImpl.java
View File

@@ -14,7 +14,7 @@ import org.springframework.stereotype.Service;
public class MessageRetryHistoryServiceImpl extends ServiceImpl<MessageRetryHistoryMapper, MessageRetryHistoryDO> implements MessageRetryHistoryService { public class MessageRetryHistoryServiceImpl extends ServiceImpl<MessageRetryHistoryMapper, MessageRetryHistoryDO> implements MessageRetryHistoryService {
@Override @Override
public boolean add(MessageRetryHistoryDO messageRetryHistoryDO) { public boolean add(MessageRetryHistoryDO messageRetryHistoryDO) {
return this.add(messageRetryHistoryDO); return this.save(messageRetryHistoryDO);
} }
public Integer getMaxRetrySequence(String messageId) { public Integer getMaxRetrySequence(String messageId) {