|
|
@@ -531,63 +531,6 @@ public class AsyncSopTestService {
|
|
|
|
|
|
}
|
|
|
|
|
|
- @Async("scheduledExecutorService")
|
|
|
- public void asyncSendMsgBySopAppTxtNormalIM(List<QwSopTempSetting.Content.Setting> setting,String cropId,Long companyUserId,Long fsUserId){
|
|
|
-
|
|
|
- setting.forEach(item->{
|
|
|
- try {
|
|
|
- log.info("执行发送app文本消息:{}",item);
|
|
|
- OpenImMsgDTO openImMsgDTO = new OpenImMsgDTO();
|
|
|
- openImMsgDTO.setSendID("C"+companyUserId);
|
|
|
- openImMsgDTO.setRecvID("U"+fsUserId);
|
|
|
- openImMsgDTO.setContentType(101);
|
|
|
- openImMsgDTO.setSessionType(1);
|
|
|
- OpenImMsgDTO.Content imContent = new OpenImMsgDTO.Content();
|
|
|
- imContent.setContent(item.getValue());
|
|
|
- openImMsgDTO.setContent(imContent);
|
|
|
- openIMService.openIMSendMsg(openImMsgDTO);
|
|
|
- } catch (Exception e) {
|
|
|
- throw new RuntimeException(e);
|
|
|
- }
|
|
|
- });
|
|
|
-
|
|
|
- }
|
|
|
-
|
|
|
- @Async("scheduledExecutorService")
|
|
|
- public void asyncSendMsgBySopAppMP3NormalIM(List<QwSopTempSetting.Content.Setting> setting,String cropId,Long companyUserId,Long fsUserId){
|
|
|
-
|
|
|
- setting.forEach(item->{
|
|
|
- try {
|
|
|
- if(StrUtil.isEmpty(item.getVoiceUrl())){
|
|
|
- log.info("执行发送app文本消息:{}",item);
|
|
|
- OpenImMsgDTO openImMsgDTO = new OpenImMsgDTO();
|
|
|
- openImMsgDTO.setSendID("C"+companyUserId);
|
|
|
- openImMsgDTO.setRecvID("U"+fsUserId);
|
|
|
- openImMsgDTO.setContentType(101);
|
|
|
- openImMsgDTO.setSessionType(1);
|
|
|
- OpenImMsgDTO.Content imContent = new OpenImMsgDTO.Content();
|
|
|
- imContent.setContent(item.getValue());
|
|
|
- openImMsgDTO.setContent(imContent);
|
|
|
- openIMService.openIMSendMsg(openImMsgDTO);
|
|
|
- }else {
|
|
|
- log.info("执行发送app语音消息:{}",item);
|
|
|
- OpenImMsgDTO openImMsgDTO = new OpenImMsgDTO();
|
|
|
- openImMsgDTO.setSendID("C"+companyUserId);
|
|
|
- openImMsgDTO.setRecvID("U"+fsUserId);
|
|
|
- openImMsgDTO.setContentType(103);
|
|
|
- openImMsgDTO.setSessionType(1);
|
|
|
- OpenImMsgDTO.Content imContent = new OpenImMsgDTO.Content();
|
|
|
- imContent.setSourceUrl(item.getVoiceUrl());
|
|
|
- imContent.setDuration(Integer.parseInt(item.getVoiceDuration()));
|
|
|
- openImMsgDTO.setContent(imContent);
|
|
|
- openIMService.openIMSendMsg(openImMsgDTO);
|
|
|
- }
|
|
|
- } catch (Exception e) {
|
|
|
- throw new RuntimeException(e);
|
|
|
- }
|
|
|
- });
|
|
|
-
|
|
|
- }
|
|
|
|
|
|
/**
|
|
|
* 异步录入 发送有app的客户 之 正常sop版
|
|
|
@@ -601,8 +544,6 @@ public class AsyncSopTestService {
|
|
|
|
|
|
}
|
|
|
|
|
|
- @Autowired
|
|
|
- private OpenIMService openIMService;
|
|
|
@Async("scheduledExecutorService")
|
|
|
public void asyncSendMsgBySopAppTxtNormalIM(List<QwSopTempSetting.Content.Setting> setting,String cropId,Long companyUserId,Long fsUserId){
|
|
|
|