implementation "org.springframework.boot:spring-boot-starter-data-redis" | implementation "org.springframework.boot:spring-boot-starter-data-redis" | ||||
implementation "com.alibaba:easyexcel:3.2.1" | implementation "com.alibaba:easyexcel:3.2.1" | ||||
implementation "org.redisson:redisson-spring-boot-starter:3.14.0" | implementation "org.redisson:redisson-spring-boot-starter:3.14.0" | ||||
implementation group: 'cn.jpush.api', name: 'jpush-client', version: '3.6.6' | |||||
//定时器相关 | //定时器相关 | ||||
implementation 'org.springframework.boot:spring-boot-starter-quartz' | implementation 'org.springframework.boot:spring-boot-starter-quartz' | ||||
implementation(group: 'io.springfox', name: 'springfox-boot-starter', version: '3.0.0') { | implementation(group: 'io.springfox', name: 'springfox-boot-starter', version: '3.0.0') { |
import org.springframework.web.bind.annotation.RequestMapping; | import org.springframework.web.bind.annotation.RequestMapping; | ||||
import org.springframework.web.bind.annotation.RestController; | import org.springframework.web.bind.annotation.RestController; | ||||
import cn.com.taiji.ias.manager.handler.htl.HltSendShortManager; | |||||
import cn.com.taiji.ias.manager.handler.jpush.JpushAllAppManager; | |||||
import cn.com.taiji.ias.manager.handler.qtkPush.QtkPushGetSendManager; | |||||
import cn.com.taiji.ias.manager.handler.qtzlEmail.QtzlEmailSendManager; | |||||
import cn.com.taiji.ias.manager.qtkPush.QtkPushGetSendManager; | |||||
import cn.com.taiji.ias.manager.qtzlEmail.QtzlEmailSendManager; | |||||
import cn.com.taiji.common.manager.ManagerException; | import cn.com.taiji.common.manager.ManagerException; | ||||
import cn.com.taiji.common.web.ApiResponse; | import cn.com.taiji.common.web.ApiResponse; | ||||
@Autowired | @Autowired | ||||
private QtkPushGetSendManager qtkPushGetSendManager; | private QtkPushGetSendManager qtkPushGetSendManager; | ||||
@Autowired | @Autowired | ||||
private HltSendShortManager hltSendShortManager; | |||||
@Autowired | |||||
private QtzlEmailSendManager qtzlEmailSendManager; | private QtzlEmailSendManager qtzlEmailSendManager; | ||||
@Autowired | |||||
private JpushAllAppManager jpushAllAppManager; | |||||
@ApiOperation(value = "qtkPush-web消息发送") | @ApiOperation(value = "qtkPush-web消息发送") | ||||
@PostMapping(value = "/qtkPushSendMessage") | @PostMapping(value = "/qtkPushSendMessage") | ||||
QtkPushSendMessageResponse response = qtkPushGetSendManager.sendMessageHandler(request); | QtkPushSendMessageResponse response = qtkPushGetSendManager.sendMessageHandler(request); | ||||
return ApiResponse.of(response); | return ApiResponse.of(response); | ||||
} | } | ||||
@ApiOperation(value = "汇联通-短信发送") | |||||
@PostMapping(value = "/hlxShort") | |||||
public ApiResponse<HltSendShortResponse> hlxShort(@RequestBody @Valid HltSendShortRequest request) throws ManagerException { | |||||
HltSendShortResponse response = hltSendShortManager.hltSendShortHandler(request); | |||||
return ApiResponse.of(response); | |||||
} | |||||
@ApiOperation(value = "黔通智联-电子邮件消息发送") | @ApiOperation(value = "黔通智联-电子邮件消息发送") | ||||
@PostMapping(value = "/qtzlEmailSend") | @PostMapping(value = "/qtzlEmailSend") | ||||
return ApiResponse.of(response); | return ApiResponse.of(response); | ||||
} | } | ||||
@ApiOperation(value = "极光推送-指定registrationId(android/ios)-App通知栏通知和自定义消息") | |||||
@PostMapping(value = "/jpuShallRidnm") | |||||
public ApiResponse<JpushAllRidNotificationMessageResponse> jpuShallRidnm(@RequestBody @Valid JpushAllRidNotificationMessageRequest request) throws ManagerException { | |||||
JpushAllRidNotificationMessageResponse response = jpushAllAppManager.jpushAllRidNotificationMessageHandler(request); | |||||
return ApiResponse.of(response); | |||||
} | |||||
} | } |
import cn.com.taiji.core.model.comm.protocol.ias.IasServiceType; | import cn.com.taiji.core.model.comm.protocol.ias.IasServiceType; | ||||
import cn.com.taiji.core.model.comm.protocol.ias.message.ChannelServiceCmd; | import cn.com.taiji.core.model.comm.protocol.ias.message.ChannelServiceCmd; | ||||
import cn.com.taiji.core.model.comm.protocol.ias.message.HltSendShortRequest; | import cn.com.taiji.core.model.comm.protocol.ias.message.HltSendShortRequest; | ||||
import cn.com.taiji.core.model.comm.protocol.ias.message.JpushAllRidNotificationMessageRequest; | |||||
import cn.com.taiji.core.model.comm.protocol.ias.message.QtkPushSendMessageRequest; | import cn.com.taiji.core.model.comm.protocol.ias.message.QtkPushSendMessageRequest; | ||||
import cn.com.taiji.core.model.comm.protocol.ias.message.QtzlEmailSendRequest; | import cn.com.taiji.core.model.comm.protocol.ias.message.QtzlEmailSendRequest; | ||||
import cn.com.taiji.ias.manager.handler.htl.HltSendShortManager; | |||||
import cn.com.taiji.ias.manager.handler.jpush.JpushAllAppManager; | |||||
import cn.com.taiji.ias.manager.handler.qtkPush.QtkPushGetSendManager; | |||||
import cn.com.taiji.ias.manager.handler.qtzlEmail.QtzlEmailSendManager; | |||||
import cn.com.taiji.ias.manager.htl.HltSendShortManager; | |||||
import cn.com.taiji.ias.manager.qtkPush.QtkPushGetSendManager; | |||||
import cn.com.taiji.ias.manager.qtzlEmail.QtzlEmailSendManager; | |||||
@Service | @Service | ||||
public class ChannelSendHandler extends AbstractIasServiceHandler<ChannelServiceCmd> { | public class ChannelSendHandler extends AbstractIasServiceHandler<ChannelServiceCmd> { | ||||
private HltSendShortManager hltSendShortManager; | private HltSendShortManager hltSendShortManager; | ||||
@Autowired | @Autowired | ||||
private QtzlEmailSendManager qtzlEmailSendManager; | private QtzlEmailSendManager qtzlEmailSendManager; | ||||
@Autowired | |||||
private JpushAllAppManager jpushAllAppManager;; | |||||
public ChannelSendHandler() { | public ChannelSendHandler() { | ||||
super(IasServiceType.PROVINCE); | super(IasServiceType.PROVINCE); | ||||
switch (cmd) { | switch (cmd) { | ||||
case HLTSENDSHORT: | case HLTSENDSHORT: | ||||
return hltSendShortManager.hltSendShortHandler((HltSendShortRequest) request); | return hltSendShortManager.hltSendShortHandler((HltSendShortRequest) request); | ||||
case JPUSHALLRIDNOTIFICATION: | |||||
return jpushAllAppManager.jpushAllRidNotificationMessageHandler((JpushAllRidNotificationMessageRequest) request); | |||||
case QTZLEMAILSEND: | case QTZLEMAILSEND: | ||||
return qtzlEmailSendManager.qtzlEmailSendHandler((QtzlEmailSendRequest) request); | return qtzlEmailSendManager.qtzlEmailSendHandler((QtzlEmailSendRequest) request); | ||||
case QTKPUSHSEND: | case QTKPUSHSEND: |
package cn.com.taiji.ias.manager.handler.jpush; | |||||
import cn.com.taiji.common.manager.net.http.ServiceHandleException; | |||||
import cn.com.taiji.core.model.comm.protocol.ias.message.JpushAllRidNotificationMessageRequest; | |||||
import cn.com.taiji.core.model.comm.protocol.ias.message.JpushAllRidNotificationMessageResponse; | |||||
/** | |||||
* @Author ChenChao | |||||
* @Date 2024/10/6 9:37 | |||||
* @Description 旧系统com.qtk.push.manager.handler.clientConfig.channel.jpush路径下 | |||||
* 多个handler放在一起组成一个manager | |||||
*/ | |||||
public interface JpushAllAppManager { | |||||
JpushAllRidNotificationMessageResponse jpushAllRidNotificationMessageHandler(JpushAllRidNotificationMessageRequest request) throws ServiceHandleException; | |||||
} |
package cn.com.taiji.ias.manager.handler.htl; | |||||
package cn.com.taiji.ias.manager.htl; | |||||
import cn.com.taiji.common.manager.ManagerException; | |||||
import cn.com.taiji.common.manager.net.http.ServiceHandleException; | import cn.com.taiji.common.manager.net.http.ServiceHandleException; | ||||
import cn.com.taiji.core.model.comm.protocol.ias.message.HltSendShortRequest; | import cn.com.taiji.core.model.comm.protocol.ias.message.HltSendShortRequest; | ||||
import cn.com.taiji.core.model.comm.protocol.ias.message.HltSendShortResponse; | import cn.com.taiji.core.model.comm.protocol.ias.message.HltSendShortResponse; | ||||
/** | |||||
* @Author ChenChao | |||||
* @Date 2024/10/6 11:45 | |||||
* @Description 旧系统com.qtk.push.manager.handler.clientConfig.channel.hlt路径下 | |||||
* 多个handler放在一起组成一个manager | |||||
*/ | |||||
public interface HltSendShortManager { | public interface HltSendShortManager { | ||||
HltSendShortResponse hltSendShortHandler(HltSendShortRequest request) throws ServiceHandleException; | HltSendShortResponse hltSendShortHandler(HltSendShortRequest request) throws ServiceHandleException; |
package cn.com.taiji.ias.manager.handler.htl; | |||||
package cn.com.taiji.ias.manager.htl; | |||||
import static cn.com.taiji.ias.api.TokenHelper.logger; | import static cn.com.taiji.ias.api.TokenHelper.logger; | ||||
import cn.com.taiji.core.model.comm.protocol.ias.portal.SendCodeRequest; | import cn.com.taiji.core.model.comm.protocol.ias.portal.SendCodeRequest; | ||||
import cn.com.taiji.core.model.comm.protocol.ias.portal.SendCodeResponse; | import cn.com.taiji.core.model.comm.protocol.ias.portal.SendCodeResponse; | ||||
import cn.com.taiji.core.model.comm.protocol.valid.GlyServiceError; | import cn.com.taiji.core.model.comm.protocol.valid.GlyServiceError; | ||||
import cn.com.taiji.ias.manager.handler.htl.HltSendShortManager; | |||||
import cn.com.taiji.ias.manager.htl.HltSendShortManager; | |||||
import org.springframework.beans.factory.annotation.Autowired; | import org.springframework.beans.factory.annotation.Autowired; | ||||
import org.springframework.stereotype.Service; | import org.springframework.stereotype.Service; | ||||
package cn.com.taiji.ias.manager.handler.qtkPush; | |||||
package cn.com.taiji.ias.manager.qtkPush; | |||||
import cn.com.taiji.common.manager.net.http.ServiceHandleException; | import cn.com.taiji.common.manager.net.http.ServiceHandleException; | ||||
import cn.com.taiji.core.model.comm.protocol.ias.message.QtkPushSendMessageRequest; | import cn.com.taiji.core.model.comm.protocol.ias.message.QtkPushSendMessageRequest; |
package cn.com.taiji.ias.manager.handler.qtkPush; | |||||
package cn.com.taiji.ias.manager.qtkPush; | |||||
import static com.zgglyun.common.model.SignOperation.logger; | import static com.zgglyun.common.model.SignOperation.logger; |
package cn.com.taiji.ias.manager.handler.qtzlEmail; | |||||
package cn.com.taiji.ias.manager.qtzlEmail; | |||||
import cn.com.taiji.common.manager.net.http.ServiceHandleException; | import cn.com.taiji.common.manager.net.http.ServiceHandleException; | ||||
import cn.com.taiji.core.model.comm.protocol.ias.message.QtzlEmailSendRequest; | import cn.com.taiji.core.model.comm.protocol.ias.message.QtzlEmailSendRequest; |
package cn.com.taiji.ias.manager.handler.qtzlEmail; | |||||
package cn.com.taiji.ias.manager.qtzlEmail; | |||||
import static cn.com.taiji.ias.api.TokenHelper.logger; | import static cn.com.taiji.ias.api.TokenHelper.logger; | ||||