# 短信即时推送接口开发

hzims-service/message/src/main/java/com/hnac/hzims/message/controller/MessagePushRecordController.java

@@ -114,4 +114,11 @@ public class MessagePushRecordController extends BladeController {
         List<UnreadMessageVO> personalUnreadMessage = messagePushRecordService.getPersonalAppUnreadMessage();
         return R.data(personalUnreadMessage);
     }
+
+    @PostMapping("/sendMessage")
+    @ApiOperation("消息推送")
+    @ApiOperationSupport(order = 10)
+    public R sendMessage(@RequestBody MessagePushRecordEntity request) {
+        return R.status(messagePushRecordService.saveAndSend(request));
+    }
 }

hzims-service/message/src/main/java/com/hnac/hzims/message/fegin/MessageClient.java

@@ -131,6 +131,7 @@ public class MessageClient extends BladeController implements IMessageClient{
 				record.setPlanTime(LocalDateTime.now());
 				record.setType(messageType);
 				record.setCreateDept(record.getDeptId());
+				record.setStatus(MessageConstants.NOT_PUSH);
 				return record;
 			});
 		}).collect(Collectors.toList());
@@ -148,4 +149,21 @@ public class MessageClient extends BladeController implements IMessageClient{
 		}
 	}
 
+	@Override
+	@PostMapping(SEND_SMS_IMMEDIATELY_MSG)
+	public R<Boolean> sendSmsImmediatelyMsg(@RequestBody SmsImmediatelyPushDTO smsImmediatelyPushDTO) {
+		MessagePushRecordEntity record = BeanUtil.copy(smsImmediatelyPushDTO,MessagePushRecordEntity.class);
+		record.setMessageId(IdWorker.getId());
+		String pusherName = Optional.ofNullable(smsImmediatelyPushDTO.getPusher()).map(Func::toLong).map(UserCache::getUser).map(User::getName).orElse(null);
+		record.setPusherName(pusherName);
+		record.setPushType(MessageConstants.IMMEDIATELY);
+		record.setPlanTime(LocalDateTime.now());
+		record.setType(MessageConstants.SMS_PUSH);
+		record.setCreateDept(record.getDeptId());
+		record.setUpdateUser(smsImmediatelyPushDTO.getCreateUser());
+		record.setStatus(MessageConstants.NOT_PUSH);
+		record.setSmsParam(JSON.toJSONString(smsImmediatelyPushDTO.getParams()));
+		return R.data(recordService.sendSmsImmediatelyMsg(record));
+	}
+
 }

hzims-service/message/src/main/java/com/hnac/hzims/message/schedule/MessagePushSchedule.java

@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.core.toolkit.IdWorker;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.google.common.collect.Lists;
 import com.hnac.hzims.common.utils.DateUtil;
 import com.hnac.hzims.message.MessageConstants;
 import com.hnac.hzims.message.config.MessageFactory;
@@ -14,11 +15,18 @@ import com.hnac.hzims.message.entity.config.MessageTemplateEntity;
 import com.hnac.hzims.message.service.IMessagePushRecordService;
 import com.hnac.hzims.message.service.IMessageService;
 import com.hnac.hzims.message.service.IMessageTemplateService;
+import com.hnac.hzims.message.service.impl.PushMessageServiceImpl;
 import com.xxl.job.core.biz.model.ReturnT;
 import com.xxl.job.core.handler.annotation.XxlJob;
+import com.xxl.job.core.log.XxlJobLogger;
 import lombok.AllArgsConstructor;
+import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springblade.core.tool.utils.CollectionUtil;
+import org.springblade.core.tool.utils.Func;
+import org.springblade.core.tool.utils.SpringUtil;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Component;
 
 import java.time.LocalDate;
@@ -29,6 +37,7 @@ import java.util.*;
 import java.util.stream.Collectors;
 
 import static com.hnac.hzims.message.constants.XxlJobConstants.PUSH_MESSAGE_BY_NOTICE;
+import static com.hnac.hzims.message.constants.XxlJobConstants.PUSH_APP_MESSAGE;
 
 /**
  * @ClassName MessagePushSchedule
@@ -38,18 +47,21 @@ import static com.hnac.hzims.message.constants.XxlJobConstants.PUSH_MESSAGE_BY_N
  * @Version 4.0
  **/
 @Component
-@AllArgsConstructor
+@RequiredArgsConstructor
 @Slf4j
 public class MessagePushSchedule {
 	private final IMessageTemplateService templateService;
 	private final IMessagePushRecordService recordService;
 	private final MessageStrategy messageStrategy;
+	private final RedisTemplate redisTemplate;
+
+	@Value("${hzims.message.redis-key.app-push}")
+	private String appPushRedisKey;
 
 	@XxlJob(PUSH_MESSAGE_BY_NOTICE)
 	public ReturnT pushSmsMessageByNotice(String params) {
 		// 获取消息模板
 		List<MessageTemplateEntity> templateList = templateService.list();
-		LocalDateTime now = LocalDateTime.now();
 		templateList.forEach(template -> {
 			LocalDateTime endTime = DateUtil.plus(LocalDateTime.now(), messageStrategy.getConcentrateDuration(), messageStrategy.getConcentrateUnit());
 			endTime = DateUtil.plus(endTime, template.getAdvanceDuration(), template.getAdvanceTimeUnit());
@@ -67,6 +79,45 @@ public class MessagePushSchedule {
 		return ReturnT.SUCCESS;
 	}
 
+	@XxlJob(PUSH_APP_MESSAGE)
+	public ReturnT pushAppMessage(String params) {
+		Set<String> appPushKeys = redisTemplate.keys(appPushRedisKey + "*");
+		PushMessageServiceImpl pushMessageService = SpringUtil.getBean(PushMessageServiceImpl.class);
+		appPushKeys.forEach(appPushKey -> {
+			// 从redis-key中拆分出消息推送人
+			Long pusher = Optional.ofNullable(appPushKey.replace(appPushRedisKey+":","")).map(Func::toLong).orElse(null);
+			if(Func.isNotEmpty(pusher)) {
+				List<MessagePushRecordEntity> records = (List<MessagePushRecordEntity>) redisTemplate.opsForList().range(appPushKey,0,-1);
+				if(CollectionUtil.isNotEmpty(records)) {
+					Map<String, List<MessagePushRecordEntity>> listMap = records.stream().filter(record -> Func.isNotEmpty(record.getSubject()))
+							.collect(Collectors.groupingBy(MessagePushRecordEntity::getSubject));
+					listMap.forEach((subject,list) -> {
+						try {
+							boolean pushFlag = pushMessageService.sendByUsers(
+									subject,
+									list.stream().map(MessagePushRecordEntity::getContent).collect(Collectors.joining("\r\n")),
+									Lists.newArrayList(pusher.toString()),
+									"200000"
+							);
+							if(pushFlag) {
+								XxlJobLogger.log("消息推送失败，subject为"+subject+";list为："+JSON.toJSONString(list));
+							}
+							LambdaUpdateWrapper<MessagePushRecordEntity> updateWrapper = Wrappers.<MessagePushRecordEntity>lambdaUpdate()
+									.set(MessagePushRecordEntity::getStatus, MessageConstants.PUSH_SUCCESS)
+									.in(MessagePushRecordEntity::getId, list.stream().map(MessagePushRecordEntity::getId).collect(Collectors.toList()));
+							recordService.update(updateWrapper);
+						} catch (Exception e) {
+							throw new RuntimeException(e);
+						}
+					});
+				}
+				// redisTemplate.opsForList().remove(appPushKey,0,records);
+			}
+		});
+		return ReturnT.SUCCESS;
+	}
+
+
 	/** @Author hx
 	 * @Description 消息集中推送
 	 * @Date 2023/4/4 15:31

hzims-service/message/src/main/java/com/hnac/hzims/message/service/IMessagePushRecordService.java

@@ -102,8 +102,19 @@ public interface IMessagePushRecordService extends BaseService<MessagePushRecord
 	 **/
 	List<UnreadMessageVO> getPersonalAppUnreadMessage();
 
+	/**
+	 * App多人推送消息
+	 * @param request 消息内容
+	 * @param records 消息记录
+	 * @return 推送结果
+	 */
 	Boolean sendAppMsgByUsers(BusinessMessageDTO request,List<MessagePushRecordEntity> records);
 
+	/**
+	 * web多人推送消息
+	 * @param request 消息记录
+	 * @return 推送结果
+	 */
 	Boolean sendWsMsgByUsers(List<MessagePushRecordEntity> request);
 
 
@@ -113,4 +124,6 @@ public interface IMessagePushRecordService extends BaseService<MessagePushRecord
 	 * @return
 	 */
 	UserPushStatTypeResponseVo newUserPushStat(MessagePushRecordEntityVo vo);
+
+	Boolean sendSmsImmediatelyMsg(MessagePushRecordEntity record);
 }

hzims-service/message/src/main/java/com/hnac/hzims/message/service/impl/MessagePushRecordServiceImpl.java

@@ -50,6 +50,7 @@ import java.util.stream.Collectors;
 public class MessagePushRecordServiceImpl extends BaseServiceImpl<MessagePushRecordMapper, MessagePushRecordEntity> implements IMessagePushRecordService {
 
     private final MprNoAurhScopeMapper noAurhScopeMapper;
+    private final IMessageService smsMessageService;
 
     @Override
     public List<MessagePushRecordEntity> list(MessagePushRecordEntity request) {
@@ -290,6 +291,23 @@ public class MessagePushRecordServiceImpl extends BaseServiceImpl<MessagePushRec
         return pushStatList;
     }
 
+    @Override
+    public Boolean sendSmsImmediatelyMsg(MessagePushRecordEntity record) {
+        // 完善推送Account
+        record.setAccount(smsMessageService.getAccountByPusher(Long.parseLong(record.getPusher()),record.getType()));
+        if(this.save(record)) {
+            if(smsMessageService.send(record)) {
+                this.update(
+                        Wrappers.<MessagePushRecordEntity>lambdaUpdate()
+                        .set(MessagePushRecordEntity::getStatus,MessageConstants.PUSH_SUCCESS)
+                        .set(MessagePushRecordEntity::getPushTime,LocalDateTime.now())
+                        .eq(MessagePushRecordEntity::getId,record.getId())
+                );
+            }
+        }
+        return true;
+    }
+
 
     /**
      * 推送成功失败统计

hzims-service/message/src/main/java/com/hnac/hzims/message/service/impl/PushMessageServiceImpl.java

@@ -16,6 +16,7 @@ import com.hnac.hzinfo.core.push.model.PushInfo;
 import com.hnac.hzinfo.core.push.model.PushPlatform;
 import com.hnac.hzinfo.core.push.model.PushResponse;
 import lombok.AllArgsConstructor;
+import lombok.RequiredArgsConstructor;
 import org.springblade.core.log.exception.ServiceException;
 import org.springblade.core.log.logger.BladeLogger;
 import org.springblade.core.secure.utils.AuthUtil;
@@ -24,6 +25,8 @@ import org.springblade.core.tool.utils.Func;
 import org.springblade.core.tool.utils.ObjectUtil;
 import org.springblade.resource.feign.IPushClient;
 import org.springblade.resource.vo.PushInfoVO;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Service;
 import org.springframework.util.Assert;
 
@@ -38,12 +41,15 @@ import java.util.concurrent.atomic.AtomicReference;
  * @author hx
  */
 @Service("pushMessageService")
-@AllArgsConstructor
+@RequiredArgsConstructor
 public class PushMessageServiceImpl implements IMessageService {
 
 	private final IPushClient pushClient;
 	private final BladeLogger logger;
 	private final ExecutorService appMessagePushExecutor;
+	private final RedisTemplate redisTemplate;
+	@Value("${hzims.message.redis-key.app-push}")
+	private String appPushRedisKey;
 
 	@Override
 	@SaveLog(type = MessageConstants.APP_NAME)
@@ -90,13 +96,16 @@ public class PushMessageServiceImpl implements IMessageService {
 
 	@Override
 	public boolean send(MessagePushRecordEntity request) {
-		String tenantId = Func.isNotEmpty(AuthUtil.getTenantId()) ? AuthUtil.getTenantId() : request.getTenantId();
-		try {
-			return this.sendByUsers(request.getSubject(), request.getContent(), Func.toStrList(",",request.getPusher()),tenantId);
-		}
-		catch (Exception e) {
-			throw new ServiceException(e.getMessage());
-		}
+		// App消息推送因腾讯云推送限制同一标签一段时间内无法推送多条消息，现将app推送改造成由redis定时推送
+		Long pushResult = redisTemplate.opsForList().leftPush(appPushRedisKey.concat(":").concat(request.getPusher()), request);
+		return Func.isNotEmpty(pushResult);
+//		String tenantId = Func.isNotEmpty(AuthUtil.getTenantId()) ? AuthUtil.getTenantId() : request.getTenantId();
+//		try {
+//			return this.sendByUsers(request.getSubject(), request.getContent(), Func.toStrList(",",request.getPusher()),tenantId);
+//		}
+//		catch (Exception e) {
+//			throw new ServiceException(e.getMessage());
+//		}
 	}
 
 	/**

hzims-service/message/src/main/resources/application.yml

@@ -34,3 +34,9 @@ spring:
           url: jdbc:mysql://175.6.40.67:5816/dev_hzims_message?useSSL=false&useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&transformedBitIsBoolean=true&serverTimezone=GMT%2B8&nullCatalogMeansCurrent=true&allowPublicKeyRetrieval=true
           username: root
           password: 123
+
+hzims:
+  message:
+    redis-key:
+      # APP消息推送记录存入redis的key
+      app-push: hzims:message:appPush