feat(0): [java]-[wechat-ferry-mvn]-VO层前缀统一
This commit is contained in:
chandler
parent
741b41e17f
commit
220e002f28
47
clients/java/wechat-ferry-mvn/README.MD
vendored
47
clients/java/wechat-ferry-mvn/README.MD
vendored
@ -132,13 +132,44 @@ wechat:
|
||||
dll-path: /dll/sdk.dll
|
||||
```
|
||||
|
||||
#### 生成proto文件
|
||||
### 缩写含义
|
||||
|
||||
首先特别通用的缩写，这里就不在重复了，比如DTO,PO这类
|
||||
|
||||
请求入参：req
|
||||
|
||||
请求出参：resp
|
||||
|
||||
微信：wx
|
||||
|
||||
个人微信：pp
|
||||
|
||||
企业微信：cp
|
||||
|
||||
微信公众号：mp
|
||||
|
||||
WeChatFerry框架：wcf
|
||||
|
||||
.gitkeep：占位文件，比如我们定义一个文件夹之后，为了避免文件夹下无内容，导致git未提交上，所以会建议此文件，阅读时直接忽略此类文件即可
|
||||
|
||||
### 生成proto文件
|
||||
|
||||
本程序已经集成了生成proto文件的maven插件，直接install即可生成proto文件，且会在打包程序中去除 src/main/resources/proto
|
||||
下面的内容，只保留实体类中的文件
|
||||
|
||||
默认install会重新根据.proto文件重新生成实体，如果不想被替换，请删除 src/main/resources/proto 下对应的.proto文件即可
|
||||
|
||||
#### 本项目自适配类型
|
||||
|
||||
有一些查询数据的自定义返回字段，定义了本项目自身的返回类型，所以 proto 文件不要从其他项目拷贝，不然缺失类型导致接口返回乱码自行负责
|
||||
|
||||
如：
|
||||
|
||||
```
|
||||
message RoomData
|
||||
|
||||
```
|
||||
|
||||
### 提交规范
|
||||
|
||||
本模块希望大家使用统一提交格式，便于区分
|
||||
@ -157,4 +188,18 @@ feat(0): [java]-[wechat-ferry-mvn]-基础类目录划分迁移及代码格式
|
||||
| fix | 缺陷 |
|
||||
| ... | 其他等git规范中的均可 |
|
||||
|
||||
### 说明
|
||||
|
||||
下面主要是针对一些合作开发者的咨询做统一回复，可以直接忽略。
|
||||
|
||||
#### 目录层级拆分太细
|
||||
|
||||
其实这个服务是底层服务，目录分细确实会增加开发量，但是针对于后面的拓展和维护上来说，个人感觉利大于弊，
|
||||
毕竟功能开发完之后，这个服务很少在变动，更多的是阅读，如果能让大家阅读、维护方便，开发时多花点时间能接受。
|
||||
|
||||
当然，如果觉得目录太多，可以自己删除点，这样可以少写点代码，目前本项目还是建议保必要的层级隔离
|
||||
|
||||
#### 文件名太长
|
||||
|
||||
出发点是为了名称进行统一规范化，便于阅读更加方便，只要了解了基础的缩写含义，其实跟自己平时命名一样，
|
||||
只不过加上了固定的前缀和后缀而已，这样单从文件名就能分析出功能模块及其含义
|
||||
|
||||
@ -10,28 +10,28 @@ import org.springframework.web.bind.annotation.RequestMapping;
|
||||
import org.springframework.web.bind.annotation.RestController;
|
||||
|
||||
import com.wechat.ferry.entity.TResponse;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpDatabaseSqlReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpDatabaseTableReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpGroupMemberReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpPatOnePatMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpSendEmojiMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpSendFileMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpSendImageMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpSendRichTextMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpSendTextMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpSendXmlMsgReq;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpContactsResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpDatabaseRowResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpGroupMemberResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpLoginInfoResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpMsgTypeResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpSendEmojiMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpSendFileMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpSendImageMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpSendPatOnePatMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpSendRichTextMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpSendTextMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpSendXmlMsgResp;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfDatabaseSqlReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfDatabaseTableReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfGroupMemberReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfPatOnePatMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfSendEmojiMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfSendFileMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfSendImageMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfSendRichTextMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfSendTextMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfSendXmlMsgReq;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfContactsResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfDatabaseRowResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfGroupMemberResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfLoginInfoResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfMsgTypeResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfSendEmojiMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfSendFileMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfSendImageMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfSendPatOnePatMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfSendRichTextMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfSendTextMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfSendXmlMsgResp;
|
||||
import com.wechat.ferry.enums.ResponseCodeEnum;
|
||||
import com.wechat.ferry.service.WeChatDllService;
|
||||
|
||||
@ -74,29 +74,29 @@ public class WeChatDllController {
|
||||
|
||||
@ApiOperation(value = "获取登录微信信息", notes = "queryLoginWeChatInfo")
|
||||
@PostMapping(value = "/loginWeChatInfo")
|
||||
public TResponse<WxPpLoginInfoResp> queryLoginWeChatInfo() {
|
||||
WxPpLoginInfoResp resp = weChatDllService.queryLoginWeChatInfo();
|
||||
public TResponse<WxPpWcfLoginInfoResp> queryLoginWeChatInfo() {
|
||||
WxPpWcfLoginInfoResp resp = weChatDllService.queryLoginWeChatInfo();
|
||||
return TResponse.ok(ResponseCodeEnum.SUCCESS, resp);
|
||||
}
|
||||
|
||||
@ApiOperation(value = "获取消息类型", notes = "queryMsgTypeList")
|
||||
@PostMapping(value = "/list/msgType")
|
||||
public TResponse<List<WxPpMsgTypeResp>> queryMsgTypeList() {
|
||||
List<WxPpMsgTypeResp> list = weChatDllService.queryMsgTypeList();
|
||||
public TResponse<List<WxPpWcfMsgTypeResp>> queryMsgTypeList() {
|
||||
List<WxPpWcfMsgTypeResp> list = weChatDllService.queryMsgTypeList();
|
||||
return TResponse.ok(ResponseCodeEnum.SUCCESS, list);
|
||||
}
|
||||
|
||||
@ApiOperation(value = "获取联系人", notes = "queryContactsList")
|
||||
@PostMapping(value = "/list/contacts")
|
||||
public TResponse<List<WxPpContactsResp>> queryContactsList() {
|
||||
List<WxPpContactsResp> list = weChatDllService.queryContactsList();
|
||||
public TResponse<List<WxPpWcfContactsResp>> queryContactsList() {
|
||||
List<WxPpWcfContactsResp> list = weChatDllService.queryContactsList();
|
||||
return TResponse.ok(ResponseCodeEnum.SUCCESS, list);
|
||||
}
|
||||
|
||||
@ApiOperation(value = "获取可查询数据库", notes = "queryDatabaseSql")
|
||||
@PostMapping(value = "/list/dbSql")
|
||||
public TResponse<List<WxPpDatabaseRowResp>> queryDatabaseSql(@Validated @RequestBody WxPpDatabaseSqlReq request) {
|
||||
List<WxPpDatabaseRowResp> list = weChatDllService.queryDatabaseSql(request);
|
||||
public TResponse<List<WxPpWcfDatabaseRowResp>> queryDatabaseSql(@Validated @RequestBody WxPpWcfDatabaseSqlReq request) {
|
||||
List<WxPpWcfDatabaseRowResp> list = weChatDllService.queryDatabaseSql(request);
|
||||
return TResponse.ok(ResponseCodeEnum.SUCCESS, list);
|
||||
}
|
||||
|
||||
@ -109,7 +109,7 @@ public class WeChatDllController {
|
||||
|
||||
@ApiOperation(value = "获取指定数据库中的表", notes = "queryDatabaseTable")
|
||||
@PostMapping(value = "/list/dbTable")
|
||||
public TResponse<List<String>> queryDatabaseTable(@Validated @RequestBody WxPpDatabaseTableReq request) {
|
||||
public TResponse<List<String>> queryDatabaseTable(@Validated @RequestBody WxPpWcfDatabaseTableReq request) {
|
||||
List<String> list = weChatDllService.queryDatabaseTable(request);
|
||||
return TResponse.ok(ResponseCodeEnum.SUCCESS, list);
|
||||
}
|
||||
@ -122,64 +122,64 @@ public class WeChatDllController {
|
||||
|
||||
@ApiOperation(value = "查询群成员", notes = "queryGroupMember")
|
||||
@PostMapping(value = "/list/groupMember")
|
||||
public TResponse<List<WxPpGroupMemberResp>> queryGroupMember(@Validated @RequestBody WxPpGroupMemberReq request) {
|
||||
List<WxPpGroupMemberResp> list = weChatDllService.queryGroupMember(request);
|
||||
public TResponse<List<WxPpWcfGroupMemberResp>> queryGroupMember(@Validated @RequestBody WxPpWcfGroupMemberReq request) {
|
||||
List<WxPpWcfGroupMemberResp> list = weChatDllService.queryGroupMember(request);
|
||||
return TResponse.ok(ResponseCodeEnum.SUCCESS, list);
|
||||
}
|
||||
|
||||
@ApiOperation(value = "发送消息汇总入口", notes = "sendMsgMaster")
|
||||
@PostMapping(value = "/send/msgMaster")
|
||||
public TResponse<WxPpSendTextMsgResp> sendMsgMaster(@Validated @RequestBody String jsonString) {
|
||||
public TResponse<WxPpWcfSendTextMsgResp> sendMsgMaster(@Validated @RequestBody String jsonString) {
|
||||
|
||||
return TResponse.ok(ResponseCodeEnum.SUCCESS);
|
||||
}
|
||||
|
||||
@ApiOperation(value = "发送文本消息（可 @）", notes = "sendTextMsg")
|
||||
@PostMapping(value = "/send/textMsg")
|
||||
public TResponse<WxPpSendTextMsgResp> sendTextMsg(@Validated @RequestBody WxPpSendTextMsgReq request) {
|
||||
WxPpSendTextMsgResp resp = weChatDllService.sendTextMsg(request);
|
||||
public TResponse<WxPpWcfSendTextMsgResp> sendTextMsg(@Validated @RequestBody WxPpWcfSendTextMsgReq request) {
|
||||
WxPpWcfSendTextMsgResp resp = weChatDllService.sendTextMsg(request);
|
||||
return TResponse.ok(ResponseCodeEnum.SUCCESS, resp);
|
||||
}
|
||||
|
||||
@ApiOperation(value = "发送图片消息", notes = "sendImageMsg")
|
||||
@PostMapping(value = "/send/imageMsg")
|
||||
public TResponse<WxPpSendImageMsgResp> sendImageMsg(@Validated @RequestBody WxPpSendImageMsgReq request) {
|
||||
WxPpSendImageMsgResp resp = weChatDllService.sendImageMsg(request);
|
||||
public TResponse<WxPpWcfSendImageMsgResp> sendImageMsg(@Validated @RequestBody WxPpWcfSendImageMsgReq request) {
|
||||
WxPpWcfSendImageMsgResp resp = weChatDllService.sendImageMsg(request);
|
||||
return TResponse.ok(ResponseCodeEnum.SUCCESS, resp);
|
||||
}
|
||||
|
||||
@ApiOperation(value = "发送文件消息", notes = "sendFileMsg")
|
||||
@PostMapping(value = "/send/fileMsg")
|
||||
public TResponse<WxPpSendFileMsgResp> sendFileMsg(@Validated @RequestBody WxPpSendFileMsgReq request) {
|
||||
WxPpSendFileMsgResp resp = weChatDllService.sendFileMsg(request);
|
||||
public TResponse<WxPpWcfSendFileMsgResp> sendFileMsg(@Validated @RequestBody WxPpWcfSendFileMsgReq request) {
|
||||
WxPpWcfSendFileMsgResp resp = weChatDllService.sendFileMsg(request);
|
||||
return TResponse.ok(ResponseCodeEnum.SUCCESS, resp);
|
||||
}
|
||||
|
||||
@ApiOperation(value = "发送XML消息", notes = "sendXmlMsg")
|
||||
@PostMapping(value = "/send/xmlMsg")
|
||||
public TResponse<WxPpSendXmlMsgResp> sendXmlMsg(@Validated @RequestBody WxPpSendXmlMsgReq request) {
|
||||
WxPpSendXmlMsgResp resp = weChatDllService.sendXmlMsg(request);
|
||||
public TResponse<WxPpWcfSendXmlMsgResp> sendXmlMsg(@Validated @RequestBody WxPpWcfSendXmlMsgReq request) {
|
||||
WxPpWcfSendXmlMsgResp resp = weChatDllService.sendXmlMsg(request);
|
||||
return TResponse.ok(ResponseCodeEnum.SUCCESS, resp);
|
||||
}
|
||||
|
||||
@ApiOperation(value = "发送表情消息", notes = "sendEmojiMsg")
|
||||
@PostMapping(value = "/send/emojiMsg")
|
||||
public TResponse<WxPpSendEmojiMsgResp> sendEmojiMsg(@Validated @RequestBody WxPpSendEmojiMsgReq request) {
|
||||
WxPpSendEmojiMsgResp resp = weChatDllService.sendEmojiMsg(request);
|
||||
public TResponse<WxPpWcfSendEmojiMsgResp> sendEmojiMsg(@Validated @RequestBody WxPpWcfSendEmojiMsgReq request) {
|
||||
WxPpWcfSendEmojiMsgResp resp = weChatDllService.sendEmojiMsg(request);
|
||||
return TResponse.ok(ResponseCodeEnum.SUCCESS, resp);
|
||||
}
|
||||
|
||||
@ApiOperation(value = "发送富文本消息", notes = "sendRichTextMsg")
|
||||
@PostMapping(value = "/send/richTextMsg")
|
||||
public TResponse<WxPpSendRichTextMsgResp> sendRichTextMsg(@Validated @RequestBody WxPpSendRichTextMsgReq request) {
|
||||
WxPpSendRichTextMsgResp resp = weChatDllService.sendRichTextMsg(request);
|
||||
public TResponse<WxPpWcfSendRichTextMsgResp> sendRichTextMsg(@Validated @RequestBody WxPpWcfSendRichTextMsgReq request) {
|
||||
WxPpWcfSendRichTextMsgResp resp = weChatDllService.sendRichTextMsg(request);
|
||||
return TResponse.ok(ResponseCodeEnum.SUCCESS, resp);
|
||||
}
|
||||
|
||||
@ApiOperation(value = "拍一拍群友", notes = "patOnePat")
|
||||
@PostMapping(value = "/patOnePat")
|
||||
public TResponse<WxPpSendPatOnePatMsgResp> patOnePat(@Validated @RequestBody WxPpPatOnePatMsgReq request) {
|
||||
WxPpSendPatOnePatMsgResp resp = weChatDllService.patOnePat(request);
|
||||
public TResponse<WxPpWcfSendPatOnePatMsgResp> patOnePat(@Validated @RequestBody WxPpWcfPatOnePatMsgReq request) {
|
||||
WxPpWcfSendPatOnePatMsgResp resp = weChatDllService.patOnePat(request);
|
||||
return TResponse.ok(ResponseCodeEnum.SUCCESS, resp);
|
||||
}
|
||||
|
||||
|
||||
@ -5,14 +5,14 @@ import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 请求入参-查询-个微数据库SQL查询
|
||||
* 请求入参-查询-个微WCF数据库SQL查询
|
||||
*
|
||||
* @author chandler
|
||||
* @date 2024-10-02 17:10
|
||||
*/
|
||||
@Data
|
||||
@ApiModel(value = "wxPpDatabaseSqlReq", description = "个微数据库SQL查询请求入参")
|
||||
public class WxPpDatabaseSqlReq {
|
||||
@ApiModel(value = "wxPpWcfDatabaseSqlReq", description = "个微WCF数据库SQL查询请求入参")
|
||||
public class WxPpWcfDatabaseSqlReq {
|
||||
|
||||
/**
|
||||
* 数据库名称
|
||||
@ -5,14 +5,14 @@ import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 请求入参-查询-个微数据库表查询
|
||||
* 请求入参-查询-个微WCF数据库表查询
|
||||
*
|
||||
* @author chandler
|
||||
* @date 2024-10-02 17:55
|
||||
*/
|
||||
@Data
|
||||
@ApiModel(value = "wxPpDatabaseTableReq", description = "个微数据库表查询请求入参")
|
||||
public class WxPpDatabaseTableReq {
|
||||
@ApiModel(value = "wxPpWcfDatabaseTableReq", description = "个微WCF数据库表查询请求入参")
|
||||
public class WxPpWcfDatabaseTableReq {
|
||||
|
||||
/**
|
||||
* 数据库名称
|
||||
@ -5,14 +5,14 @@ import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 请求入参-个微查询群成员
|
||||
* 请求入参-个微WCF查询群成员
|
||||
*
|
||||
* @author chandler
|
||||
* @date 2024-10-02 20:55
|
||||
*/
|
||||
@Data
|
||||
@ApiModel(value = "wxPpGroupMemberReq", description = "个微查询群成员请求入参")
|
||||
public class WxPpGroupMemberReq {
|
||||
@ApiModel(value = "wxPpWcfGroupMemberReq", description = "个微WCF查询群成员请求入参")
|
||||
public class WxPpWcfGroupMemberReq {
|
||||
|
||||
/**
|
||||
* 群编号
|
||||
@ -5,14 +5,14 @@ import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 请求入参-个微发送拍一拍消息
|
||||
* 请求入参-个微WCF发送拍一拍消息
|
||||
*
|
||||
* @author chandler
|
||||
* @date 2024-10-06 15:50
|
||||
*/
|
||||
@Data
|
||||
@ApiModel(value = "wxPpPatOnePatMsgReq", description = "个微发送拍一拍消息请求入参")
|
||||
public class WxPpPatOnePatMsgReq {
|
||||
@ApiModel(value = "wxPpWcfPatOnePatMsgReq", description = "个微WCF发送拍一拍消息请求入参")
|
||||
public class WxPpWcfPatOnePatMsgReq {
|
||||
|
||||
/**
|
||||
* 消息接收人
|
||||
@ -5,14 +5,14 @@ import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 请求入参-个微发送表情消息
|
||||
* 请求入参-个微WCF发送表情消息
|
||||
*
|
||||
* @author chandler
|
||||
* @date 2024-10-04 23:14
|
||||
*/
|
||||
@Data
|
||||
@ApiModel(value = "wxPpSendEmojiMsgReq", description = "个微发送表情消息请求入参")
|
||||
public class WxPpSendEmojiMsgReq {
|
||||
@ApiModel(value = "wxPpWcfSendEmojiMsgReq", description = "个微WCF发送表情消息请求入参")
|
||||
public class WxPpWcfSendEmojiMsgReq {
|
||||
|
||||
/**
|
||||
* 资源路径-本地表情路径
|
||||
@ -5,14 +5,14 @@ import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 请求入参-个微发送文件消息
|
||||
* 请求入参-个微WCF发送文件消息
|
||||
*
|
||||
* @author chandler
|
||||
* @date 2024-10-04 23:08
|
||||
*/
|
||||
@Data
|
||||
@ApiModel(value = "wxPpSendFileMsgReq", description = "个微发送文件消息请求入参")
|
||||
public class WxPpSendFileMsgReq {
|
||||
@ApiModel(value = "wxPpWcfSendFileMsgReq", description = "个微WCF发送文件消息请求入参")
|
||||
public class WxPpWcfSendFileMsgReq {
|
||||
|
||||
/**
|
||||
* 资源路径-本地文件路径
|
||||
@ -5,14 +5,14 @@ import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 请求入参-个微发送图片消息
|
||||
* 请求入参-个微WCF发送图片消息
|
||||
*
|
||||
* @author chandler
|
||||
* @date 2024-10-04 15:55
|
||||
*/
|
||||
@Data
|
||||
@ApiModel(value = "wxPpSendImageMsgReq", description = "个微发送图片消息请求入参")
|
||||
public class WxPpSendImageMsgReq {
|
||||
@ApiModel(value = "wxPpWcfSendImageMsgReq", description = "个微WCF发送图片消息请求入参")
|
||||
public class WxPpWcfSendImageMsgReq {
|
||||
|
||||
/**
|
||||
* 资源路径-本地图片地址
|
||||
@ -5,14 +5,14 @@ import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 请求入参-个微发送富文本消息
|
||||
* 请求入参-个微WCF发送富文本消息
|
||||
*
|
||||
* @author chandler
|
||||
* @date 2024-10-06 15:40
|
||||
*/
|
||||
@Data
|
||||
@ApiModel(value = "wxPpSendRichTextMsgReq", description = "个微发送富文本消息请求入参")
|
||||
public class WxPpSendRichTextMsgReq {
|
||||
@ApiModel(value = "wxPpWcfSendRichTextMsgReq", description = "个微WCF发送富文本消息请求入参")
|
||||
public class WxPpWcfSendRichTextMsgReq {
|
||||
|
||||
/**
|
||||
* 消息接收人
|
||||
@ -7,14 +7,14 @@ import lombok.Data;
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 请求入参-个微发送文本消息
|
||||
* 请求入参-个微WCF发送文本消息
|
||||
*
|
||||
* @author chandler
|
||||
* @date 2024-10-02 20:33
|
||||
*/
|
||||
@Data
|
||||
@ApiModel(value = "wxPpSendTextMsgReq", description = "个微发送文本消息请求入参")
|
||||
public class WxPpSendTextMsgReq {
|
||||
@ApiModel(value = "wxPpWcfSendTextMsgReq", description = "个微WCF发送文本消息请求入参")
|
||||
public class WxPpWcfSendTextMsgReq {
|
||||
|
||||
/**
|
||||
* 消息文本
|
||||
@ -5,14 +5,14 @@ import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 请求入参-个微发送XML消息
|
||||
* 请求入参-个微WCF发送XML消息
|
||||
*
|
||||
* @author chandler
|
||||
* @date 2024-10-04 23:11
|
||||
*/
|
||||
@Data
|
||||
@ApiModel(value = "wxPpSendXmlMsgReq", description = "个微发送XML消息请求入参")
|
||||
public class WxPpSendXmlMsgReq {
|
||||
@ApiModel(value = "wxPpWcfSendXmlMsgReq", description = "个微WCF发送XML消息请求入参")
|
||||
public class WxPpWcfSendXmlMsgReq {
|
||||
|
||||
/**
|
||||
* 消息接收人
|
||||
@ -5,14 +5,14 @@ import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 请求出参-个微联系人
|
||||
* 请求出参-个微WCF联系人
|
||||
*
|
||||
* @author chandler
|
||||
* @date 2024/10/02 17:01
|
||||
*/
|
||||
@Data
|
||||
@ApiModel(value = "wxPpContactsResp", description = "个微联系人查询请求出参")
|
||||
public class WxPpContactsResp {
|
||||
@ApiModel(value = "wxPpWcfContactsResp", description = "个微WCF联系人查询请求出参")
|
||||
public class WxPpWcfContactsResp {
|
||||
|
||||
/**
|
||||
* 微信内部识别号UID
|
||||
@ -5,14 +5,14 @@ import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 请求出参-个微数据库字段
|
||||
* 请求出参-个微WCF数据库字段
|
||||
*
|
||||
* @author chandler
|
||||
* @date 2024/10/02 17:15
|
||||
*/
|
||||
@Data
|
||||
@ApiModel(value = "wxPpDatabaseFieldResp", description = "个微数据库字段查询请求出参")
|
||||
public class WxPpDatabaseFieldResp {
|
||||
@ApiModel(value = "wxPpWcfDatabaseFieldResp", description = "个微WCF数据库字段查询请求出参")
|
||||
public class WxPpWcfDatabaseFieldResp {
|
||||
|
||||
/**
|
||||
* 字段类型
|
||||
@ -7,19 +7,19 @@ import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 请求出参-个微数据库记录
|
||||
* 请求出参-个微WCF数据库记录
|
||||
*
|
||||
* @author chandler
|
||||
* @date 2024/10/02 17:14
|
||||
*/
|
||||
@Data
|
||||
@ApiModel(value = "wxPpDatabaseRowResp", description = "个微数据库记录查询请求出参")
|
||||
public class WxPpDatabaseRowResp {
|
||||
@ApiModel(value = "wxPpWcfDatabaseRowResp", description = "个微WCF数据库记录查询请求出参")
|
||||
public class WxPpWcfDatabaseRowResp {
|
||||
|
||||
/**
|
||||
* 字段列表
|
||||
*/
|
||||
@ApiModelProperty(value = "字段列表")
|
||||
private List<WxPpDatabaseFieldResp> fieldList;
|
||||
private List<WxPpWcfDatabaseFieldResp> fieldList;
|
||||
|
||||
}
|
||||
@ -5,14 +5,14 @@ import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 请求出参-个微查询群成员
|
||||
* 请求出参-个微WCF查询群成员
|
||||
*
|
||||
* @author chandler
|
||||
* @date 2024/10/01 21:26
|
||||
*/
|
||||
@Data
|
||||
@ApiModel(value = "wxPpGroupMemberResp", description = "个微群成员查询请求出参")
|
||||
public class WxPpGroupMemberResp {
|
||||
@ApiModel(value = "wxPpWcfGroupMemberResp", description = "个微WCF群成员查询请求出参")
|
||||
public class WxPpWcfGroupMemberResp {
|
||||
|
||||
/**
|
||||
* 微信内部识别号UID
|
||||
@ -5,14 +5,14 @@ import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 请求出参-登录个微信息
|
||||
* 请求出参-登录WCF个微信息
|
||||
*
|
||||
* @author chandler
|
||||
* @date 2024/10/05 22:53
|
||||
*/
|
||||
@Data
|
||||
@ApiModel(value = "wxPpLoginInfoResp", description = "登录个微信息查询请求出参")
|
||||
public class WxPpLoginInfoResp {
|
||||
@ApiModel(value = "wxPpWcfLoginInfoResp", description = "登录WCF个微信息查询请求出参")
|
||||
public class WxPpWcfLoginInfoResp {
|
||||
|
||||
/**
|
||||
* 微信内部识别号UID
|
||||
@ -5,14 +5,14 @@ import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 请求出参-个微消息类型
|
||||
* 请求出参-个微WCF消息类型
|
||||
*
|
||||
* @author chandler
|
||||
* @date 2024/10/01 21:26
|
||||
*/
|
||||
@Data
|
||||
@ApiModel(value = "wxPpMsgTypeResp", description = "个微消息类型查询请求出参")
|
||||
public class WxPpMsgTypeResp {
|
||||
@ApiModel(value = "wxPpWcfMsgTypeResp", description = "个微WCF消息类型查询请求出参")
|
||||
public class WxPpWcfMsgTypeResp {
|
||||
|
||||
/**
|
||||
* 类型编号
|
||||
@ -5,14 +5,14 @@ import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 请求出参-个微发送GIF消息
|
||||
* 请求出参-个微WCF发送GIF消息
|
||||
*
|
||||
* @author chandler
|
||||
* @date 2024/10/04 23:13
|
||||
*/
|
||||
@Data
|
||||
@ApiModel(value = "wxPpSendEmojiMsgResp", description = "个微发送GIF消息请求出参")
|
||||
public class WxPpSendEmojiMsgResp {
|
||||
@ApiModel(value = "wxPpWcfSendEmojiMsgResp", description = "个微WCF发送GIF消息请求出参")
|
||||
public class WxPpWcfSendEmojiMsgResp {
|
||||
|
||||
/**
|
||||
* 类型编号
|
||||
@ -5,14 +5,14 @@ import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 请求出参-个微发送文件消息
|
||||
* 请求出参-个微WCF发送文件消息
|
||||
*
|
||||
* @author chandler
|
||||
* @date 2024/10/04 23:07
|
||||
*/
|
||||
@Data
|
||||
@ApiModel(value = "wxPpSendFileMsgResp", description = "个微发送文件消息请求出参")
|
||||
public class WxPpSendFileMsgResp {
|
||||
@ApiModel(value = "wxPpWcfSendFileMsgResp", description = "个微WCF发送文件消息请求出参")
|
||||
public class WxPpWcfSendFileMsgResp {
|
||||
|
||||
/**
|
||||
* 类型编号
|
||||
@ -5,14 +5,14 @@ import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 请求出参-个微发送图像消息
|
||||
* 请求出参-个微WCF发送图像消息
|
||||
*
|
||||
* @author chandler
|
||||
* @date 2024/10/03 10:17
|
||||
*/
|
||||
@Data
|
||||
@ApiModel(value = "wxPpSendImageMsgResp", description = "个微发送图像消息请求出参")
|
||||
public class WxPpSendImageMsgResp {
|
||||
@ApiModel(value = "wxPpWcfSendImageMsgResp", description = "个微WCF发送图像消息请求出参")
|
||||
public class WxPpWcfSendImageMsgResp {
|
||||
|
||||
/**
|
||||
* 状态码
|
||||
@ -5,14 +5,14 @@ import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 请求出参-个微发送拍一拍消息
|
||||
* 请求出参-个微WCF发送拍一拍消息
|
||||
*
|
||||
* @author chandler
|
||||
* @date 2024/10/06 15:52
|
||||
*/
|
||||
@Data
|
||||
@ApiModel(value = "wxPpSendPatOnePatMsgResp", description = "个微发送拍一拍消息请求出参")
|
||||
public class WxPpSendPatOnePatMsgResp {
|
||||
@ApiModel(value = "wxPpWcfSendPatOnePatMsgResp", description = "个微WCF发送拍一拍消息请求出参")
|
||||
public class WxPpWcfSendPatOnePatMsgResp {
|
||||
|
||||
/**
|
||||
* 类型编号
|
||||
@ -5,14 +5,14 @@ import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 请求出参-个微发送富文本消息
|
||||
* 请求出参-个微WCF发送富文本消息
|
||||
*
|
||||
* @author chandler
|
||||
* @date 2024/10/06 15:46
|
||||
*/
|
||||
@Data
|
||||
@ApiModel(value = "wxPpSendRichTextMsgResp", description = "个微发送富文本消息请求出参")
|
||||
public class WxPpSendRichTextMsgResp {
|
||||
@ApiModel(value = "wxPpWcfSendRichTextMsgResp", description = "个微WCF发送富文本消息请求出参")
|
||||
public class WxPpWcfSendRichTextMsgResp {
|
||||
|
||||
/**
|
||||
* 类型编号
|
||||
@ -5,14 +5,14 @@ import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 请求出参-个微发送文本消息
|
||||
* 请求出参-个微WCF发送文本消息
|
||||
*
|
||||
* @author chandler
|
||||
* @date 2024/10/03 10:17
|
||||
*/
|
||||
@Data
|
||||
@ApiModel(value = "wxPpSendTextMsgResp", description = "个微发送文本消息请求出参")
|
||||
public class WxPpSendTextMsgResp {
|
||||
@ApiModel(value = "wxPpWcfSendTextMsgResp", description = "个微WCF发送文本消息请求出参")
|
||||
public class WxPpWcfSendTextMsgResp {
|
||||
|
||||
/**
|
||||
* 类型编号
|
||||
@ -5,14 +5,14 @@ import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 请求出参-个微发送XML消息
|
||||
* 请求出参-个微WCF发送XML消息
|
||||
*
|
||||
* @author chandler
|
||||
* @date 2024/10/04 23:11
|
||||
*/
|
||||
@Data
|
||||
@ApiModel(value = "wxPpSendCardMsgResp", description = "个微发送XML消息请求出参")
|
||||
public class WxPpSendXmlMsgResp {
|
||||
@ApiModel(value = "wxPpWcfSendXmlMsgResp", description = "个微WCF发送XML消息请求出参")
|
||||
public class WxPpWcfSendXmlMsgResp {
|
||||
|
||||
/**
|
||||
* 类型编号
|
||||
@ -2,28 +2,28 @@ package com.wechat.ferry.service;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
import com.wechat.ferry.entity.vo.request.WxPpDatabaseSqlReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpDatabaseTableReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpGroupMemberReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpPatOnePatMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpSendEmojiMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpSendFileMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpSendImageMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpSendRichTextMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpSendTextMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpSendXmlMsgReq;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpContactsResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpDatabaseRowResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpGroupMemberResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpLoginInfoResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpMsgTypeResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpSendEmojiMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpSendFileMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpSendImageMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpSendPatOnePatMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpSendRichTextMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpSendTextMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpSendXmlMsgResp;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfDatabaseSqlReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfDatabaseTableReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfGroupMemberReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfPatOnePatMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfSendEmojiMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfSendFileMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfSendImageMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfSendRichTextMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfSendTextMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfSendXmlMsgReq;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfContactsResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfDatabaseRowResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfGroupMemberResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfLoginInfoResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfMsgTypeResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfSendEmojiMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfSendFileMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfSendImageMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfSendPatOnePatMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfSendRichTextMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfSendTextMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfSendXmlMsgResp;
|
||||
|
||||
/**
|
||||
* 业务接口-对接原本DLL的接口
|
||||
@ -61,7 +61,7 @@ public interface WeChatDllService {
|
||||
* @author chandler
|
||||
* @date 2024-10-05 22:54
|
||||
*/
|
||||
WxPpLoginInfoResp queryLoginWeChatInfo();
|
||||
WxPpWcfLoginInfoResp queryLoginWeChatInfo();
|
||||
|
||||
/**
|
||||
* 获取所有消息类型
|
||||
@ -71,7 +71,7 @@ public interface WeChatDllService {
|
||||
* @author chandler
|
||||
* @date 2024-10-01 21:22
|
||||
*/
|
||||
List<WxPpMsgTypeResp> queryMsgTypeList();
|
||||
List<WxPpWcfMsgTypeResp> queryMsgTypeList();
|
||||
|
||||
/**
|
||||
* 获取所有联系人
|
||||
@ -81,7 +81,7 @@ public interface WeChatDllService {
|
||||
* @author chandler
|
||||
* @date 2024-10-02 16:59
|
||||
*/
|
||||
List<WxPpContactsResp> queryContactsList();
|
||||
List<WxPpWcfContactsResp> queryContactsList();
|
||||
|
||||
/**
|
||||
* 获取可查询数据库
|
||||
@ -92,7 +92,7 @@ public interface WeChatDllService {
|
||||
* @author chandler
|
||||
* @date 2024-10-02 17:52
|
||||
*/
|
||||
List<WxPpDatabaseRowResp> queryDatabaseSql(WxPpDatabaseSqlReq request);
|
||||
List<WxPpWcfDatabaseRowResp> queryDatabaseSql(WxPpWcfDatabaseSqlReq request);
|
||||
|
||||
/**
|
||||
* 获取数据库所有表名称
|
||||
@ -113,7 +113,7 @@ public interface WeChatDllService {
|
||||
* @author chandler
|
||||
* @date 2024-10-02 17:52
|
||||
*/
|
||||
List<String> queryDatabaseTable(WxPpDatabaseTableReq request);
|
||||
List<String> queryDatabaseTable(WxPpWcfDatabaseTableReq request);
|
||||
|
||||
/**
|
||||
* 查询群成员
|
||||
@ -124,7 +124,7 @@ public interface WeChatDllService {
|
||||
* @author chandler
|
||||
* @date 2024-10-02 20:59
|
||||
*/
|
||||
List<WxPpGroupMemberResp> queryGroupMember(WxPpGroupMemberReq request);
|
||||
List<WxPpWcfGroupMemberResp> queryGroupMember(WxPpWcfGroupMemberReq request);
|
||||
|
||||
/**
|
||||
* 发送文本消息（可 @）
|
||||
@ -137,7 +137,7 @@ public interface WeChatDllService {
|
||||
* @author chandler
|
||||
* @date 2024-10-02 20:40
|
||||
*/
|
||||
WxPpSendTextMsgResp sendTextMsg(WxPpSendTextMsgReq request);
|
||||
WxPpWcfSendTextMsgResp sendTextMsg(WxPpWcfSendTextMsgReq request);
|
||||
|
||||
/**
|
||||
* 发送图片消息
|
||||
@ -148,7 +148,7 @@ public interface WeChatDllService {
|
||||
* @author chandler
|
||||
* @date 2024-10-04 23:06
|
||||
*/
|
||||
WxPpSendImageMsgResp sendImageMsg(WxPpSendImageMsgReq request);
|
||||
WxPpWcfSendImageMsgResp sendImageMsg(WxPpWcfSendImageMsgReq request);
|
||||
|
||||
/**
|
||||
* 发送文件消息
|
||||
@ -159,7 +159,7 @@ public interface WeChatDllService {
|
||||
* @author chandler
|
||||
* @date 2024-10-04 23:15
|
||||
*/
|
||||
WxPpSendFileMsgResp sendFileMsg(WxPpSendFileMsgReq request);
|
||||
WxPpWcfSendFileMsgResp sendFileMsg(WxPpWcfSendFileMsgReq request);
|
||||
|
||||
/**
|
||||
* 发送XML消息
|
||||
@ -170,7 +170,7 @@ public interface WeChatDllService {
|
||||
* @author chandler
|
||||
* @date 2024-10-04 23:15
|
||||
*/
|
||||
WxPpSendXmlMsgResp sendXmlMsg(WxPpSendXmlMsgReq request);
|
||||
WxPpWcfSendXmlMsgResp sendXmlMsg(WxPpWcfSendXmlMsgReq request);
|
||||
|
||||
/**
|
||||
* 发送表情消息
|
||||
@ -181,7 +181,7 @@ public interface WeChatDllService {
|
||||
* @author chandler
|
||||
* @date 2024-10-04 23:29
|
||||
*/
|
||||
WxPpSendEmojiMsgResp sendEmojiMsg(WxPpSendEmojiMsgReq request);
|
||||
WxPpWcfSendEmojiMsgResp sendEmojiMsg(WxPpWcfSendEmojiMsgReq request);
|
||||
|
||||
/**
|
||||
* 发送富文本消息
|
||||
@ -192,7 +192,7 @@ public interface WeChatDllService {
|
||||
* @author chandler
|
||||
* @date 2024-10-06 15:48
|
||||
*/
|
||||
WxPpSendRichTextMsgResp sendRichTextMsg(WxPpSendRichTextMsgReq request);
|
||||
WxPpWcfSendRichTextMsgResp sendRichTextMsg(WxPpWcfSendRichTextMsgReq request);
|
||||
|
||||
/**
|
||||
* 拍一拍
|
||||
@ -203,6 +203,6 @@ public interface WeChatDllService {
|
||||
* @author chandler
|
||||
* @date 2024-10-06 15:54
|
||||
*/
|
||||
WxPpSendPatOnePatMsgResp patOnePat(WxPpPatOnePatMsgReq request);
|
||||
WxPpWcfSendPatOnePatMsgResp patOnePat(WxPpWcfPatOnePatMsgReq request);
|
||||
|
||||
}
|
||||
|
||||
@ -17,29 +17,29 @@ import org.springframework.util.ObjectUtils;
|
||||
import com.google.protobuf.ByteString;
|
||||
import com.google.protobuf.InvalidProtocolBufferException;
|
||||
import com.wechat.ferry.entity.proto.Wcf;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpDatabaseSqlReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpDatabaseTableReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpGroupMemberReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpPatOnePatMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpSendEmojiMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpSendFileMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpSendImageMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpSendRichTextMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpSendTextMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpSendXmlMsgReq;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpContactsResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpDatabaseFieldResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpDatabaseRowResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpGroupMemberResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpLoginInfoResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpMsgTypeResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpSendEmojiMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpSendFileMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpSendImageMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpSendPatOnePatMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpSendRichTextMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpSendTextMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpSendXmlMsgResp;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfDatabaseSqlReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfDatabaseTableReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfGroupMemberReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfPatOnePatMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfSendEmojiMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfSendFileMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfSendImageMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfSendRichTextMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfSendTextMsgReq;
|
||||
import com.wechat.ferry.entity.vo.request.WxPpWcfSendXmlMsgReq;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfContactsResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfDatabaseFieldResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfDatabaseRowResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfGroupMemberResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfLoginInfoResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfMsgTypeResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfSendEmojiMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfSendFileMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfSendImageMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfSendPatOnePatMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfSendRichTextMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfSendTextMsgResp;
|
||||
import com.wechat.ferry.entity.vo.response.WxPpWcfSendXmlMsgResp;
|
||||
import com.wechat.ferry.enums.SexEnum;
|
||||
import com.wechat.ferry.enums.WxContactsTypeEnum;
|
||||
import com.wechat.ferry.handle.WeChatSocketClient;
|
||||
@ -79,8 +79,8 @@ public class WeChatDllServiceImpl implements WeChatDllService {
|
||||
}
|
||||
|
||||
@Override
|
||||
public WxPpLoginInfoResp queryLoginWeChatInfo() {
|
||||
WxPpLoginInfoResp resp = new WxPpLoginInfoResp();
|
||||
public WxPpWcfLoginInfoResp queryLoginWeChatInfo() {
|
||||
WxPpWcfLoginInfoResp resp = new WxPpWcfLoginInfoResp();
|
||||
Wcf.UserInfo userInfo = wechatSocketClient.getUserInfo();
|
||||
if (!ObjectUtils.isEmpty(userInfo)) {
|
||||
resp.setWeChatUid(userInfo.getWxid());
|
||||
@ -93,13 +93,13 @@ public class WeChatDllServiceImpl implements WeChatDllService {
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<WxPpMsgTypeResp> queryMsgTypeList() {
|
||||
List<WxPpMsgTypeResp> list = new ArrayList<>();
|
||||
public List<WxPpWcfMsgTypeResp> queryMsgTypeList() {
|
||||
List<WxPpWcfMsgTypeResp> list = new ArrayList<>();
|
||||
Map<Integer, String> msgTypeMap = wechatSocketClient.getMsgTypes();
|
||||
if (!CollectionUtils.isEmpty(msgTypeMap)) {
|
||||
WxPpMsgTypeResp resp;
|
||||
WxPpWcfMsgTypeResp resp;
|
||||
for (Map.Entry<Integer, String> entry : msgTypeMap.entrySet()) {
|
||||
resp = new WxPpMsgTypeResp();
|
||||
resp = new WxPpWcfMsgTypeResp();
|
||||
resp.setId(entry.getKey());
|
||||
resp.setName(entry.getValue());
|
||||
list.add(resp);
|
||||
@ -110,12 +110,12 @@ public class WeChatDllServiceImpl implements WeChatDllService {
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<WxPpContactsResp> queryContactsList() {
|
||||
List<WxPpContactsResp> list = new ArrayList<>();
|
||||
public List<WxPpWcfContactsResp> queryContactsList() {
|
||||
List<WxPpWcfContactsResp> list = new ArrayList<>();
|
||||
List<Wcf.RpcContact> rpcContactList = wechatSocketClient.getContacts();
|
||||
if (!CollectionUtils.isEmpty(rpcContactList)) {
|
||||
for (Wcf.RpcContact rpcContact : rpcContactList) {
|
||||
WxPpContactsResp vo = new WxPpContactsResp();
|
||||
WxPpWcfContactsResp vo = new WxPpWcfContactsResp();
|
||||
vo.setWeChatUid(rpcContact.getWxid());
|
||||
vo.setWeChatNo(rpcContact.getCode());
|
||||
vo.setFriendRemark(rpcContact.getRemark());
|
||||
@ -204,8 +204,8 @@ public class WeChatDllServiceImpl implements WeChatDllService {
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<WxPpDatabaseRowResp> queryDatabaseSql(WxPpDatabaseSqlReq request) {
|
||||
List<WxPpDatabaseRowResp> list = new ArrayList<>();
|
||||
public List<WxPpWcfDatabaseRowResp> queryDatabaseSql(WxPpWcfDatabaseSqlReq request) {
|
||||
List<WxPpWcfDatabaseRowResp> list = new ArrayList<>();
|
||||
List<Wcf.DbRow> wcfList = wechatSocketClient.querySql(request.getDatabaseName(), request.getSqlText());
|
||||
if (!CollectionUtils.isEmpty(wcfList)) {
|
||||
// List<Map<String, Object>> result = new ArrayList<>();
|
||||
@ -223,10 +223,10 @@ public class WeChatDllServiceImpl implements WeChatDllService {
|
||||
// }
|
||||
|
||||
for (Wcf.DbRow dbRow : wcfList) {
|
||||
WxPpDatabaseRowResp rowVo = new WxPpDatabaseRowResp();
|
||||
List<WxPpDatabaseFieldResp> fieldVoList = new ArrayList<>();
|
||||
WxPpWcfDatabaseRowResp rowVo = new WxPpWcfDatabaseRowResp();
|
||||
List<WxPpWcfDatabaseFieldResp> fieldVoList = new ArrayList<>();
|
||||
for (Wcf.DbField dbField : dbRow.getFieldsList()) {
|
||||
WxPpDatabaseFieldResp fieldVo = new WxPpDatabaseFieldResp();
|
||||
WxPpWcfDatabaseFieldResp fieldVo = new WxPpWcfDatabaseFieldResp();
|
||||
fieldVo.setType(String.valueOf(dbField.getType()));
|
||||
fieldVo.setColumn(dbField.getColumn());
|
||||
String value = (String)converterSqlVal(dbField.getType(), dbField.getContent());
|
||||
@ -249,7 +249,7 @@ public class WeChatDllServiceImpl implements WeChatDllService {
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<String> queryDatabaseTable(WxPpDatabaseTableReq request) {
|
||||
public List<String> queryDatabaseTable(WxPpWcfDatabaseTableReq request) {
|
||||
log.info("[查询]-[查询表]-request:{}", request);
|
||||
Map<String, String> wcfMap = wechatSocketClient.getDbTables(request.getDatabaseName());
|
||||
|
||||
@ -258,8 +258,8 @@ public class WeChatDllServiceImpl implements WeChatDllService {
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<WxPpGroupMemberResp> queryGroupMember(WxPpGroupMemberReq request) {
|
||||
List<WxPpGroupMemberResp> list = new ArrayList<>();
|
||||
public List<WxPpWcfGroupMemberResp> queryGroupMember(WxPpWcfGroupMemberReq request) {
|
||||
List<WxPpWcfGroupMemberResp> list = new ArrayList<>();
|
||||
// 查询群成员
|
||||
List<Wcf.DbRow> wcfList = new ArrayList<>();
|
||||
if (!ObjectUtils.isEmpty(request.getGroupNo())) {
|
||||
@ -273,10 +273,10 @@ public class WeChatDllServiceImpl implements WeChatDllService {
|
||||
for (Wcf.DbRow dbRow : dbList) {
|
||||
List<Wcf.DbField> dbFieldList = dbRow.getFieldsList();
|
||||
if (!ObjectUtils.isEmpty(dbFieldList)) {
|
||||
WxPpGroupMemberResp vo = new WxPpGroupMemberResp();
|
||||
WxPpWcfGroupMemberResp vo = new WxPpWcfGroupMemberResp();
|
||||
for (Wcf.DbField dbField : dbFieldList) {
|
||||
if ("UserName".equals(dbField.getColumn())) {
|
||||
vo = new WxPpGroupMemberResp();
|
||||
vo = new WxPpWcfGroupMemberResp();
|
||||
String content = (String)converterSqlVal(dbField.getType(), dbField.getContent());
|
||||
vo.setWeChatUid(content);
|
||||
}
|
||||
@ -295,14 +295,14 @@ public class WeChatDllServiceImpl implements WeChatDllService {
|
||||
for (Wcf.DbRow dbRow : wcfList) {
|
||||
List<Wcf.DbField> dbFieldList = dbRow.getFieldsList();
|
||||
if (!ObjectUtils.isEmpty(dbFieldList)) {
|
||||
WxPpGroupMemberResp vo = new WxPpGroupMemberResp();
|
||||
WxPpWcfGroupMemberResp vo = new WxPpWcfGroupMemberResp();
|
||||
for (Wcf.DbField dbField : dbFieldList) {
|
||||
if ("RoomData".equals(dbField.getColumn())) {
|
||||
try {
|
||||
byte[] roomDataBytes = dbField.getContent().toByteArray();
|
||||
Wcf.RoomData roomData = Wcf.RoomData.parseFrom(roomDataBytes);
|
||||
for (Wcf.RoomData.RoomMember member : roomData.getMembersList()) {
|
||||
vo = new WxPpGroupMemberResp();
|
||||
vo = new WxPpWcfGroupMemberResp();
|
||||
vo.setWeChatUid(member.getWxid());
|
||||
String nickName = member.getName();
|
||||
if (ObjectUtils.isEmpty(nickName)) {
|
||||
@ -326,7 +326,7 @@ public class WeChatDllServiceImpl implements WeChatDllService {
|
||||
}
|
||||
|
||||
@Override
|
||||
public WxPpSendTextMsgResp sendTextMsg(WxPpSendTextMsgReq request) {
|
||||
public WxPpWcfSendTextMsgResp sendTextMsg(WxPpWcfSendTextMsgReq request) {
|
||||
log.info("[发送消息]-[文本消息]-入参打印：{}", request);
|
||||
String atUser = "";
|
||||
if (request.getIsAtAll()) {
|
||||
@ -345,32 +345,32 @@ public class WeChatDllServiceImpl implements WeChatDllService {
|
||||
}
|
||||
|
||||
@Override
|
||||
public WxPpSendImageMsgResp sendImageMsg(WxPpSendImageMsgReq request) {
|
||||
WxPpSendImageMsgResp resp = new WxPpSendImageMsgResp();
|
||||
public WxPpWcfSendImageMsgResp sendImageMsg(WxPpWcfSendImageMsgReq request) {
|
||||
WxPpWcfSendImageMsgResp resp = new WxPpWcfSendImageMsgResp();
|
||||
int state = wechatSocketClient.sendImage(request.getResourcePath(), request.getRecipient());
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public WxPpSendFileMsgResp sendFileMsg(WxPpSendFileMsgReq request) {
|
||||
public WxPpWcfSendFileMsgResp sendFileMsg(WxPpWcfSendFileMsgReq request) {
|
||||
int state = wechatSocketClient.sendFile(request.getResourcePath(), request.getRecipient());
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public WxPpSendXmlMsgResp sendXmlMsg(WxPpSendXmlMsgReq request) {
|
||||
public WxPpWcfSendXmlMsgResp sendXmlMsg(WxPpWcfSendXmlMsgReq request) {
|
||||
int state = wechatSocketClient.sendXml(request.getRecipient(), request.getXmlContent(), request.getResourcePath(), request.getXmlType());
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public WxPpSendEmojiMsgResp sendEmojiMsg(WxPpSendEmojiMsgReq request) {
|
||||
public WxPpWcfSendEmojiMsgResp sendEmojiMsg(WxPpWcfSendEmojiMsgReq request) {
|
||||
int state = wechatSocketClient.sendEmotion(request.getResourcePath(), request.getRecipient());
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public WxPpSendRichTextMsgResp sendRichTextMsg(WxPpSendRichTextMsgReq request) {
|
||||
public WxPpWcfSendRichTextMsgResp sendRichTextMsg(WxPpWcfSendRichTextMsgReq request) {
|
||||
Wcf.RichText richTextMsg = Wcf.RichText.newBuilder().setName(request.getName()).setAccount(request.getAccount()).setTitle(request.getTitle())
|
||||
.setDigest(request.getDigest()).setUrl(request.getJumpUrl()).setThumburl(request.getThumbnailUrl()).setReceiver(request.getRecipient())
|
||||
.build();
|
||||
@ -380,7 +380,7 @@ public class WeChatDllServiceImpl implements WeChatDllService {
|
||||
}
|
||||
|
||||
@Override
|
||||
public WxPpSendPatOnePatMsgResp patOnePat(WxPpPatOnePatMsgReq request) {
|
||||
public WxPpWcfSendPatOnePatMsgResp patOnePat(WxPpWcfPatOnePatMsgReq request) {
|
||||
Wcf.PatMsg patMsg = Wcf.PatMsg.newBuilder().setRoomid(request.getRecipient()).setWxid(request.getPatUser()).build();
|
||||
Wcf.Request wcfReq = Wcf.Request.newBuilder().setFuncValue(Wcf.Functions.FUNC_SEND_PAT_MSG_VALUE).setPm(patMsg).build();
|
||||
Wcf.Response rsp = wechatSocketClient.sendCmd(wcfReq);
|
||||
|
||||
@ -4,7 +4,6 @@ import java.util.Map;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Service;
|
||||
import org.springframework.util.CollectionUtils;
|
||||
import org.springframework.util.ObjectUtils;
|
||||
@ -13,7 +12,6 @@ import com.alibaba.fastjson2.JSON;
|
||||
import com.alibaba.fastjson2.JSONObject;
|
||||
import com.wechat.ferry.config.WeChatFerryProperties;
|
||||
import com.wechat.ferry.entity.dto.WxPpMsgDTO;
|
||||
import com.wechat.ferry.service.WeChatExtService;
|
||||
import com.wechat.ferry.service.WeChatMsgService;
|
||||
import com.wechat.ferry.utils.HttpClientUtil;
|
||||
|
||||
@ -29,13 +27,6 @@ import lombok.extern.slf4j.Slf4j;
|
||||
@Service
|
||||
public class WeChatMsgServiceImpl implements WeChatMsgService {
|
||||
|
||||
private WeChatExtService weChatExtService;
|
||||
|
||||
@Autowired
|
||||
public void setWeChatExtService(WeChatExtService weChatExtService) {
|
||||
this.weChatExtService = weChatExtService;
|
||||
}
|
||||
|
||||
@Resource
|
||||
private WeChatFerryProperties weChatFerryProperties;
|
||||
|
||||
@ -49,7 +40,6 @@ public class WeChatMsgServiceImpl implements WeChatMsgService {
|
||||
if (!CollectionUtils.isEmpty(weChatFerryProperties.getOpenMsgGroups())) {
|
||||
// 指定处理的群聊
|
||||
if (weChatFerryProperties.getOpenMsgGroups().contains(dto.getRoomId())) {
|
||||
weChatExtService.instructSign(dto);
|
||||
// TODO 这里可以拓展自己需要的功能
|
||||
}
|
||||
}
|
||||
|
||||
Loading…
Reference in New Issue
Block a user