unipush 新增测试人员信息

zhongrj

2023-07-26 c9b76e720d921b00b4481d6c94cf8d43f6354ec0

unipush 新增测试人员信息

 skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/push/service/impl/PushServiceImpl.java

@@ -9,6 +9,7 @@
import lombok.AllArgsConstructor;
import org.springblade.core.log.exception.ServiceException;
import org.springblade.core.redis.cache.BladeRedis;
import org.springblade.core.secure.utils.AuthUtil;
import org.springblade.core.tool.utils.Func;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
@@ -36,6 +37,8 @@

    @Override
    public Boolean pushMessageList(List<MessageRecord> messageRecordList) {
        // 加入测试人员
        addSendMsgTest(messageRecordList);
        PushVO pushVO = new PushVO();
        List<String> cIdList = new ArrayList<>();
        //相同的消息推送给多用户
@@ -51,6 +54,22 @@
        return geTuiUtils.pushMsg(pushVO.getCIds(),pushVO.getTitle(),pushVO.getContent());
    }

    /**
     * 新增测试信息
     * @param messageRecordList
     */
    private void addSendMsgTest(List<MessageRecord> messageRecordList) {
        MessageRecord messageRecord = new MessageRecord();
        messageRecord.setRecipient("1654164141753593858");
        messageRecord.setContent(messageRecordList.get(0).getContent());
        messageRecord.setTheme(messageRecordList.get(0).getTheme());
        messageRecord.setSender(AuthUtil.getUserId().toString());
        messageRecord.setSource("智能告警");
        messageRecord.setStatus(0);
        // 加入集合
        messageRecordList.add(messageRecord);
    }

    @Override
    public Boolean clearCId(String userId) {
        Boolean del = bladeRedis.del(PUSH_CLIENT_ID + userId);