|
@@ -2,6 +2,7 @@ package com.fs.company.controller.qw;
|
|
|
|
|
|
|
|
import com.alibaba.fastjson.JSON;
|
|
import com.alibaba.fastjson.JSON;
|
|
|
import com.alibaba.fastjson.TypeReference;
|
|
import com.alibaba.fastjson.TypeReference;
|
|
|
|
|
+import com.fs.common.annotation.DataSource;
|
|
|
import com.fs.common.annotation.Log;
|
|
import com.fs.common.annotation.Log;
|
|
|
import com.fs.common.annotation.RepeatSubmit;
|
|
import com.fs.common.annotation.RepeatSubmit;
|
|
|
import com.fs.common.core.controller.BaseController;
|
|
import com.fs.common.core.controller.BaseController;
|
|
@@ -9,6 +10,7 @@ import com.fs.common.core.domain.AjaxResult;
|
|
|
import com.fs.common.core.domain.R;
|
|
import com.fs.common.core.domain.R;
|
|
|
import com.fs.common.core.page.TableDataInfo;
|
|
import com.fs.common.core.page.TableDataInfo;
|
|
|
import com.fs.common.enums.BusinessType;
|
|
import com.fs.common.enums.BusinessType;
|
|
|
|
|
+import com.fs.common.enums.DataSourceType;
|
|
|
import com.fs.common.exception.CustomException;
|
|
import com.fs.common.exception.CustomException;
|
|
|
import com.fs.common.exception.ServiceException;
|
|
import com.fs.common.exception.ServiceException;
|
|
|
import com.fs.common.utils.ServletUtils;
|
|
import com.fs.common.utils.ServletUtils;
|
|
@@ -185,6 +187,7 @@ public class QwMsgController extends BaseController
|
|
|
//根据会话获取消息
|
|
//根据会话获取消息
|
|
|
@GetMapping("/getQwMessageListBySession")
|
|
@GetMapping("/getQwMessageListBySession")
|
|
|
@ApiOperation("根据会话获取消息")
|
|
@ApiOperation("根据会话获取消息")
|
|
|
|
|
+ @DataSource(DataSourceType.SHARDING)
|
|
|
public R getQwMessageListBySession(QwSessionParam param){
|
|
public R getQwMessageListBySession(QwSessionParam param){
|
|
|
PageHelper.startPage(param.getPageNum(), param.getPageSize());
|
|
PageHelper.startPage(param.getPageNum(), param.getPageSize());
|
|
|
List<QwMsg> list = qwMsgService.selectQwMsgBySession(param);
|
|
List<QwMsg> list = qwMsgService.selectQwMsgBySession(param);
|
|
@@ -197,6 +200,7 @@ public class QwMsgController extends BaseController
|
|
|
|
|
|
|
|
@ApiOperation("发送企微消息")
|
|
@ApiOperation("发送企微消息")
|
|
|
@PostMapping("/sendMsg")
|
|
@PostMapping("/sendMsg")
|
|
|
|
|
+ @DataSource(DataSourceType.SHARDING)
|
|
|
public R sendMsg(@RequestBody QwMsgSendParam param){
|
|
public R sendMsg(@RequestBody QwMsgSendParam param){
|
|
|
return qwMsgService.sendMsg(param);
|
|
return qwMsgService.sendMsg(param);
|
|
|
}
|
|
}
|
|
@@ -204,6 +208,7 @@ public class QwMsgController extends BaseController
|
|
|
|
|
|
|
|
//获取用户单条会话
|
|
//获取用户单条会话
|
|
|
@GetMapping("/getSession")
|
|
@GetMapping("/getSession")
|
|
|
|
|
+ @DataSource(DataSourceType.SHARDING)
|
|
|
public R getSession(QwSessionParam param){
|
|
public R getSession(QwSessionParam param){
|
|
|
QwContactListVO data = qwMsgService.selectQwSessionBycId(param.getConversationId(),param.getUserId());
|
|
QwContactListVO data = qwMsgService.selectQwSessionBycId(param.getConversationId(),param.getUserId());
|
|
|
return R.ok().put("data",data);
|
|
return R.ok().put("data",data);
|
|
@@ -381,6 +386,7 @@ public class QwMsgController extends BaseController
|
|
|
return getDataTable(logList);
|
|
return getDataTable(logList);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ @DataSource(DataSourceType.SHARDING)
|
|
|
@ApiOperation("获取外部联系人访问记录列表")
|
|
@ApiOperation("获取外部联系人访问记录列表")
|
|
|
@GetMapping("/getQwExternalContactVisitList")
|
|
@GetMapping("/getQwExternalContactVisitList")
|
|
|
public TableDataInfo getQwExternalContactVisitList(@RequestParam(value = "qwExternalContactId") Long qwExternalContactId) {
|
|
public TableDataInfo getQwExternalContactVisitList(@RequestParam(value = "qwExternalContactId") Long qwExternalContactId) {
|