diff --git a/src/main/java/cn/van333/mt2ql/wxMessage/WXListener.java b/src/main/java/cn/van333/mt2ql/wxMessage/WXListener.java index 29703a8..4cf0e04 100644 --- a/src/main/java/cn/van333/mt2ql/wxMessage/WXListener.java +++ b/src/main/java/cn/van333/mt2ql/wxMessage/WXListener.java @@ -63,5 +63,12 @@ public class WXListener { wxMessageConsumer.consume(message); return "OK"; } + @RequestMapping("/test") + public String test(@RequestBody String requestBody) { + + System.out.println("测试接口收到数据："); + System.out.println(requestBody); + return "OK"; + } } diff --git a/src/main/java/cn/van333/mt2ql/wxMessage/enums/IEnumForString.java b/src/main/java/cn/van333/mt2ql/wxMessage/enums/IEnumForString.java new file mode 100644 index 0000000..7508845 --- /dev/null +++ b/src/main/java/cn/van333/mt2ql/wxMessage/enums/IEnumForString.java @@ -0,0 +1,14 @@ +package cn.van333.mt2ql.wxMessage.enums; + +/** + * @author Leo + * @version 1.0 + * @create 2023/12/19 0019 上午 10:33 + * @description： + */ +public interface IEnumForString { + + String getKey(); + + String getName(); +} diff --git a/src/main/java/cn/van333/mt2ql/wxMessage/enums/WXReqType.java b/src/main/java/cn/van333/mt2ql/wxMessage/enums/WXReqType.java new file mode 100644 index 0000000..0f2f9b7 --- /dev/null +++ b/src/main/java/cn/van333/mt2ql/wxMessage/enums/WXReqType.java @@ -0,0 +1,131 @@ +package cn.van333.mt2ql.wxMessage.enums; + +/** + * @author Leo + * @version 1.0 + * @create 2023/12/19 0019 上午 10:27 + * @description： + */ + +import com.fasterxml.jackson.annotation.JsonValue; + +import java.util.*; + +public enum WXReqType { + /** + * * 获取微信列表 (X0000) + * * 微信状态检测(Q0000) + * * 发送文本消息(Q0001) + * * 修改下载图片 (Q0002) + * * 获取个人信息 (Q0003) + * * 查询对象信(Q0004) + * * 获取好友列表(Q0005) + * * 获取群聊列表(Q0006) + * * 获取公众号列表(Q0007) + * * 获取群成员列表(Q0008) + * * 发送聊天记录(Q0009) + * * 发送图片 (Q0010) + * * 发送本地文件(Q0011) + * * 发送分享链接(Q0012) + * * 发送小程序(Q0013) + * * 发送音乐分享(Q0014) + * * 发送XML (Q0015) + * * 确认收款 (Q0016) + * * 同意好友请求(Q0017) + * * 添加好友通过v3(Q0018) + * * 添加好友_通过wxid (Q0019) + * * 查询陌生人信息(Q0020) + * * 邀请进群(Q0021) + * * 删除好友(Q0022) + * * 修改对象备注(Q0023) + * * 修改群聊名称(Q0024) + * * 发送名片(Q0025) + */ + GET_WX_LIST("X0000", "获取微信列表"), + GET_WX_STATUS("Q0000", "微信状态检测"), + SEND_TEXT_MESSAGE("Q0001", "发送文本消息"), + UPDATE_DOWNLOAD_IMAGE("Q0002", "修改下载图片"), + GET_USER_INFO("Q0003", "获取个人信息"), + QUERY_OBJECT_INFO("Q0004", "查询对象信"), + GET_FRIEND_LIST("Q0005", "获取好友列表"), + GET_GROUP_LIST("Q0006", "获取群聊列表"), + GET_MP_LIST("Q0007", "获取公众号列表"), + GET_GROUP_MEMBER_LIST("Q0008", "获取群成员列表"), + SEND_CHAT_RECORD("Q0009", "发送聊天记录"), + SEND_IMAGE("Q0010", "发送图片"), + SEND_LOCAL_FILE("Q0011", "发送本地文件"), + SEND_SHARE_LINK("Q0012", "发送分享链接"), + SEND_MINIPROGRAM("Q0013", "发送小程序"), + SEND_MUSIC_SHARE("Q0014", "发送音乐分享"), + SEND_XML("Q0015", "发送XML"), + CONFIRM_RECEIPT("Q0016", "确认收款"), + AGREE_FRIEND_REQUEST("Q0017", "同意好友请求"), + ADD_FRIEND_V3("Q0018", "添加好友通过v3"), + ADD_FRIEND_WXID("Q0019", "添加好友_通过wxid"), + QUERY_STRANGER_INFO("Q0020", "查询陌生人信息"), + INVITE_GROUP("Q0021", "邀请进群"), + DELETE_FRIEND("Q0022", "删除好友"), + MODIFY_OBJECT_REMARK("Q0023", "修改对象备注"), + MODIFY_GROUP_NAME("Q0024", "修改群聊名称"); + private final String key; + + private final String name; + + WXReqType(String key, String name) { + this.key = key; + this.name = name; + } + + public static WXReqType get(String key) { + for (WXReqType e : WXReqType.values()) { + if (Objects.equals(e.getKey(), key)) { + return e; + } + } + return null; + } + + public static String getName(String key) { + //if (Object.isNotEmpty(key)) { + WXReqType[] items = WXReqType.values(); + for (WXReqType item : items) { + if (Objects.equals(item.getKey(), key)) { + return item.getName(); + } + } + //} + return ""; + } + + public static Map getKeyVlue() { + Map map = new HashMap<>(); + WXReqType[] items = WXReqType.values(); + for (WXReqType item : items) { + map.put(item.getKey() + "", item.getName()); + } + return map; + } + + public static List> getSelectItems() { + List> result = new ArrayList>(); + WXReqType[] items = WXReqType.values(); + for (WXReqType item : items) { + Map map = new HashMap<>(); + map.put("label", item.getName()); + map.put("value", item.getKey()); + result.add(map); + } + return result; + } + + @JsonValue + public String getKey() { + return key; + } + + public String getName() { + return name; + } + +} + diff --git a/src/main/java/cn/van333/mt2ql/wxMessage/mapper/WxMessageDataForChatMapper.java b/src/main/java/cn/van333/mt2ql/wxMessage/mapper/WxMessageDataForChatMapper.java new file mode 100644 index 0000000..5ea10d0 --- /dev/null +++ b/src/main/java/cn/van333/mt2ql/wxMessage/mapper/WxMessageDataForChatMapper.java @@ -0,0 +1,18 @@ +package cn.van333.mt2ql.wxMessage.mapper; + +import cn.van333.mt2ql.wxMessage.model.WxMessageDataForChat; +import com.baomidou.mybatisplus.core.mapper.BaseMapper; + +/** +* @author 80787 +* @description 针对表【wx_message_data_for_chat】的数据库操作Mapper +* @createDate 2023-12-19 17:38:29 +* @Entity cn.van333.mt2ql.demos.model.WxMessageDataForChat +*/ +public interface WxMessageDataForChatMapper extends BaseMapper { + +} + + + + diff --git a/src/main/java/cn/van333/mt2ql/wxMessage/mapper/WxUserMapper.java b/src/main/java/cn/van333/mt2ql/wxMessage/mapper/WxUserMapper.java new file mode 100644 index 0000000..dcb7227 --- /dev/null +++ b/src/main/java/cn/van333/mt2ql/wxMessage/mapper/WxUserMapper.java @@ -0,0 +1,18 @@ +package cn.van333.mt2ql.wxMessage.mapper; + +import cn.van333.mt2ql.wxMessage.model.WxUser; +import com.baomidou.mybatisplus.core.mapper.BaseMapper; + +/** +* @author 80787 +* @description 针对表【wx_user】的数据库操作Mapper +* @createDate 2023-12-21 14:18:10 +* @Entity cn.van333.mt2ql.wxMessage.model.WxUser +*/ +public interface WxUserMapper extends BaseMapper { + +} + + + + diff --git a/src/main/java/cn/van333/mt2ql/wxMessage/model/WxMessageDataForChat.java b/src/main/java/cn/van333/mt2ql/wxMessage/model/WxMessageDataForChat.java new file mode 100644 index 0000000..e7c29b3 --- /dev/null +++ b/src/main/java/cn/van333/mt2ql/wxMessage/model/WxMessageDataForChat.java @@ -0,0 +1,169 @@ +package cn.van333.mt2ql.wxMessage.model; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableName; +import java.io.Serializable; +import lombok.Data; +/** + * @author Leo + * @version 1.0 + * @create 2023/12/19 0019 上午 11:46 + * @description： + * 收到群聊消息 (10008) + * 收到私聊消息 (10009) + * 自己发出消息 (10010) + */ +/** + * + * @TableName wx_message_data_for_chat + */ +@TableName(value ="wx_message_data_for_chat") +@Data +public class WxMessageDataForChat implements Serializable { + /** + * 收到这条消息的13位现行时间戳 + */ + private Long timestamp; + + /** + * 来源类型：1|私聊 2|群聊 3|公众号 + */ + private Integer fromtype; + + /** + * 消息类型：1|文本 3|图片 34|语音 42|名片 43|视频 47|动态表情 48|地理位置 49|分享链接或附件 2001|红包 2002|小程序 2003|群邀请 10000|系统消息 + */ + private Integer msgtype; + + /** + * 消息来源：0|别人发送 1|自己手机发送 + */ + private Integer msgsource; + + /** + * fromType=1时为好友wxid，fromType=2时为群wxid，fromType=3时公众号wxid + */ + private String fromwxid; + + /** + * 仅fromType=2时有效，为群内发言人wxid + */ + private String finalfromwxid; + + /** + * 仅fromType=2，且msgSource=0时有效，为消息中艾特人wxid列表 + */ + private String atwxidlist; + + /** + * 仅fromType=2时有效，0 + */ + private Integer silence; + + /** + * 仅fromType=2时有效，群成员数量 + */ + private Integer membercount; + + /** + * 消息签名 + */ + private String signature; + + /** + * 消息内容 + */ + private String msg; + + /** + * 消息内容的Base64 + */ + private String msgbase64; + + /** + * 消息的唯一标识 + */ + private String msgid; + + /** + * 消息类型的字符串表示 + */ + private String msgtypestr; + + @TableField(exist = false) + private static final long serialVersionUID = 1L; + + @Override + public boolean equals(Object that) { + if (this == that) { + return true; + } + if (that == null) { + return false; + } + if (getClass() != that.getClass()) { + return false; + } + WxMessageDataForChat other = (WxMessageDataForChat) that; + return (this.getTimestamp() == null ? other.getTimestamp() == null : this.getTimestamp().equals(other.getTimestamp())) + && (this.getFromtype() == null ? other.getFromtype() == null : this.getFromtype().equals(other.getFromtype())) + && (this.getMsgtype() == null ? other.getMsgtype() == null : this.getMsgtype().equals(other.getMsgtype())) + && (this.getMsgsource() == null ? other.getMsgsource() == null : this.getMsgsource().equals(other.getMsgsource())) + && (this.getFromwxid() == null ? other.getFromwxid() == null : this.getFromwxid().equals(other.getFromwxid())) + && (this.getFinalfromwxid() == null ? other.getFinalfromwxid() == null : this.getFinalfromwxid().equals(other.getFinalfromwxid())) + && (this.getAtwxidlist() == null ? other.getAtwxidlist() == null : this.getAtwxidlist().equals(other.getAtwxidlist())) + && (this.getSilence() == null ? other.getSilence() == null : this.getSilence().equals(other.getSilence())) + && (this.getMembercount() == null ? other.getMembercount() == null : this.getMembercount().equals(other.getMembercount())) + && (this.getSignature() == null ? other.getSignature() == null : this.getSignature().equals(other.getSignature())) + && (this.getMsg() == null ? other.getMsg() == null : this.getMsg().equals(other.getMsg())) + && (this.getMsgbase64() == null ? other.getMsgbase64() == null : this.getMsgbase64().equals(other.getMsgbase64())) + && (this.getMsgid() == null ? other.getMsgid() == null : this.getMsgid().equals(other.getMsgid())) + && (this.getMsgtypestr() == null ? other.getMsgtypestr() == null : this.getMsgtypestr().equals(other.getMsgtypestr())); + } + + @Override + public int hashCode() { + final int prime = 31; + int result = 1; + result = prime * result + ((getTimestamp() == null) ? 0 : getTimestamp().hashCode()); + result = prime * result + ((getFromtype() == null) ? 0 : getFromtype().hashCode()); + result = prime * result + ((getMsgtype() == null) ? 0 : getMsgtype().hashCode()); + result = prime * result + ((getMsgsource() == null) ? 0 : getMsgsource().hashCode()); + result = prime * result + ((getFromwxid() == null) ? 0 : getFromwxid().hashCode()); + result = prime * result + ((getFinalfromwxid() == null) ? 0 : getFinalfromwxid().hashCode()); + result = prime * result + ((getAtwxidlist() == null) ? 0 : getAtwxidlist().hashCode()); + result = prime * result + ((getSilence() == null) ? 0 : getSilence().hashCode()); + result = prime * result + ((getMembercount() == null) ? 0 : getMembercount().hashCode()); + result = prime * result + ((getSignature() == null) ? 0 : getSignature().hashCode()); + result = prime * result + ((getMsg() == null) ? 0 : getMsg().hashCode()); + result = prime * result + ((getMsgbase64() == null) ? 0 : getMsgbase64().hashCode()); + result = prime * result + ((getMsgid() == null) ? 0 : getMsgid().hashCode()); + result = prime * result + ((getMsgtypestr() == null) ? 0 : getMsgtypestr().hashCode()); + return result; + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder(); + sb.append(getClass().getSimpleName()); + sb.append(" ["); + sb.append("Hash = ").append(hashCode()); + sb.append(", timestamp=").append(timestamp); + sb.append(", fromtype=").append(fromtype); + sb.append(", msgtype=").append(msgtype); + sb.append(", msgsource=").append(msgsource); + sb.append(", fromwxid=").append(fromwxid); + sb.append(", finalfromwxid=").append(finalfromwxid); + sb.append(", atwxidlist=").append(atwxidlist); + sb.append(", silence=").append(silence); + sb.append(", membercount=").append(membercount); + sb.append(", signature=").append(signature); + sb.append(", msg=").append(msg); + sb.append(", msgbase64=").append(msgbase64); + sb.append(", msgid=").append(msgid); + sb.append(", msgtypestr=").append(msgtypestr); + sb.append(", serialVersionUID=").append(serialVersionUID); + sb.append("]"); + return sb.toString(); + } +} diff --git a/src/main/java/cn/van333/mt2ql/wxMessage/model/WxUser.java b/src/main/java/cn/van333/mt2ql/wxMessage/model/WxUser.java new file mode 100644 index 0000000..f1b9a71 --- /dev/null +++ b/src/main/java/cn/van333/mt2ql/wxMessage/model/WxUser.java @@ -0,0 +1,109 @@ +package cn.van333.mt2ql.wxMessage.model; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import java.io.Serializable; +import java.math.BigDecimal; +import lombok.Data; + +/** + * + * @TableName wx_user + */ +@TableName(value ="wx_user") +@Data +public class WxUser implements Serializable { + /** + * wxid + */ + @TableId + private String wxid; + + /** + * 累计充值 + */ + private BigDecimal moneyLeiji; + + /** + * 余额 + */ + private BigDecimal moneyShengyu; + + /** + * 累计充值次数 + */ + private BigDecimal countChongzhi; + + /** + * 累计消费次数 + */ + private BigDecimal countXiaofei; + + /** + * 微信昵称 + */ + private String name; + + /** + * 1 正常 2 拉黑 + */ + private Integer status; + + @TableField(exist = false) + private static final long serialVersionUID = 1L; + + @Override + public boolean equals(Object that) { + if (this == that) { + return true; + } + if (that == null) { + return false; + } + if (getClass() != that.getClass()) { + return false; + } + WxUser other = (WxUser) that; + return (this.getWxid() == null ? other.getWxid() == null : this.getWxid().equals(other.getWxid())) + && (this.getMoneyLeiji() == null ? other.getMoneyLeiji() == null : this.getMoneyLeiji().equals(other.getMoneyLeiji())) + && (this.getMoneyShengyu() == null ? other.getMoneyShengyu() == null : this.getMoneyShengyu().equals(other.getMoneyShengyu())) + && (this.getCountChongzhi() == null ? other.getCountChongzhi() == null : this.getCountChongzhi().equals(other.getCountChongzhi())) + && (this.getCountXiaofei() == null ? other.getCountXiaofei() == null : this.getCountXiaofei().equals(other.getCountXiaofei())) + && (this.getName() == null ? other.getName() == null : this.getName().equals(other.getName())) + && (this.getStatus() == null ? other.getStatus() == null : this.getStatus().equals(other.getStatus())); + } + + @Override + public int hashCode() { + final int prime = 31; + int result = 1; + result = prime * result + ((getWxid() == null) ? 0 : getWxid().hashCode()); + result = prime * result + ((getMoneyLeiji() == null) ? 0 : getMoneyLeiji().hashCode()); + result = prime * result + ((getMoneyShengyu() == null) ? 0 : getMoneyShengyu().hashCode()); + result = prime * result + ((getCountChongzhi() == null) ? 0 : getCountChongzhi().hashCode()); + result = prime * result + ((getCountXiaofei() == null) ? 0 : getCountXiaofei().hashCode()); + result = prime * result + ((getName() == null) ? 0 : getName().hashCode()); + result = prime * result + ((getStatus() == null) ? 0 : getStatus().hashCode()); + return result; + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder(); + sb.append(getClass().getSimpleName()); + sb.append(" ["); + sb.append("Hash = ").append(hashCode()); + sb.append(", wxid=").append(wxid); + sb.append(", moneyLeiji=").append(moneyLeiji); + sb.append(", moneyShengyu=").append(moneyShengyu); + sb.append(", countChongzhi=").append(countChongzhi); + sb.append(", countXiaofei=").append(countXiaofei); + sb.append(", name=").append(name); + sb.append(", status=").append(status); + sb.append(", serialVersionUID=").append(serialVersionUID); + sb.append("]"); + return sb.toString(); + } +} \ No newline at end of file diff --git a/src/main/java/cn/van333/mt2ql/wxMessage/service/WxMessageDataForChatService.java b/src/main/java/cn/van333/mt2ql/wxMessage/service/WxMessageDataForChatService.java new file mode 100644 index 0000000..4e4d09f --- /dev/null +++ b/src/main/java/cn/van333/mt2ql/wxMessage/service/WxMessageDataForChatService.java @@ -0,0 +1,13 @@ +package cn.van333.mt2ql.wxMessage.service; + +import cn.van333.mt2ql.wxMessage.model.WxMessageDataForChat; +import com.baomidou.mybatisplus.extension.service.IService; + +/** +* @author 80787 +* @description 针对表【wx_message_data_for_chat】的数据库操作Service +* @createDate 2023-12-19 17:38:29 +*/ +public interface WxMessageDataForChatService extends IService { + +} diff --git a/src/main/java/cn/van333/mt2ql/wxMessage/service/WxUserService.java b/src/main/java/cn/van333/mt2ql/wxMessage/service/WxUserService.java new file mode 100644 index 0000000..060bc42 --- /dev/null +++ b/src/main/java/cn/van333/mt2ql/wxMessage/service/WxUserService.java @@ -0,0 +1,13 @@ +package cn.van333.mt2ql.wxMessage.service; + +import cn.van333.mt2ql.wxMessage.model.WxUser; +import com.baomidou.mybatisplus.extension.service.IService; + +/** +* @author 80787 +* @description 针对表【wx_user】的数据库操作Service +* @createDate 2023-12-21 14:18:10 +*/ +public interface WxUserService extends IService { + +} diff --git a/src/main/java/cn/van333/mt2ql/wxMessage/service/impl/WxMessageDataForChatServiceImpl.java b/src/main/java/cn/van333/mt2ql/wxMessage/service/impl/WxMessageDataForChatServiceImpl.java new file mode 100644 index 0000000..cf27c4d --- /dev/null +++ b/src/main/java/cn/van333/mt2ql/wxMessage/service/impl/WxMessageDataForChatServiceImpl.java @@ -0,0 +1,22 @@ +package cn.van333.mt2ql.wxMessage.service.impl; + +import cn.van333.mt2ql.wxMessage.service.WxMessageDataForChatService; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import cn.van333.mt2ql.wxMessage.model.WxMessageDataForChat; +import cn.van333.mt2ql.wxMessage.mapper.WxMessageDataForChatMapper; +import org.springframework.stereotype.Service; + +/** +* @author 80787 +* @description 针对表【wx_message_data_for_chat】的数据库操作Service实现 +* @createDate 2023-12-19 17:38:29 +*/ +@Service +public class WxMessageDataForChatServiceImpl extends ServiceImpl + implements WxMessageDataForChatService { + +} + + + + diff --git a/src/main/java/cn/van333/mt2ql/wxMessage/service/impl/WxUserServiceImpl.java b/src/main/java/cn/van333/mt2ql/wxMessage/service/impl/WxUserServiceImpl.java new file mode 100644 index 0000000..b14b451 --- /dev/null +++ b/src/main/java/cn/van333/mt2ql/wxMessage/service/impl/WxUserServiceImpl.java @@ -0,0 +1,22 @@ +package cn.van333.mt2ql.wxMessage.service.impl; + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import cn.van333.mt2ql.wxMessage.model.WxUser; +import cn.van333.mt2ql.wxMessage.service.WxUserService; +import cn.van333.mt2ql.wxMessage.mapper.WxUserMapper; +import org.springframework.stereotype.Service; + +/** +* @author 80787 +* @description 针对表【wx_user】的数据库操作Service实现 +* @createDate 2023-12-21 14:18:10 +*/ +@Service +public class WxUserServiceImpl extends ServiceImpl + implements WxUserService{ + +} + + + + diff --git a/src/main/java/cn/van333/mt2ql/wxMessage/utils/QLUtil.java b/src/main/java/cn/van333/mt2ql/wxMessage/utils/QLUtil.java new file mode 100644 index 0000000..acf830f --- /dev/null +++ b/src/main/java/cn/van333/mt2ql/wxMessage/utils/QLUtil.java @@ -0,0 +1,313 @@ +package cn.van333.mt2ql.wxMessage.utils; + +import cn.hutool.core.util.ObjectUtil; +import cn.hutool.core.util.StrUtil; +import cn.hutool.extra.spring.SpringUtil; +import cn.hutool.http.HttpRequest; +import com.alibaba.fastjson2.JSON; +import com.alibaba.fastjson2.JSONObject; + +import java.util.HashMap; +import java.util.Objects; +import java.util.concurrent.TimeUnit; + +import static cn.hutool.core.thread.ThreadUtil.sleep; + +/** + * @author Leo + * @version 1.0 + * @create 2023/12/22 0022 上午 09:59 + * @description： + */ +public class QLUtil { + /** + * 1. 在系统设置 -> 应用设置 -> 添加应用，权限目前支持5个模块，可以选择多个模块。选择一个模块之后，可读写此模块的所有接口。 + * 2. 使用生成的 client_id 和 client_secret 请求获取token接口 http://localhost:5700/open/auth/token?client_id=xxxxxx&client_secret=xxxxxxxx + * 3. 上面接口返回的token有效期为30天，可用于请求青龙的接口 curl 'http://localhost:5700/open/envs?searchValue=&t=1630032278171' -H 'Authorization: Bearer + * 接口返回的token' + * 4. openapi的接口与系统正常接口的区别就是青龙里的是/api/envs，openapi是/open/envs，即就是青龙接口中的api换成open + */ + public static final String QL_BASE_URL = "http://134.175.126.60:45700"; + public static final String GET_TOKEN = QL_BASE_URL + "/open/auth/token"; + + // /open/envs + public static final String GET_ENV = QL_BASE_URL + "/open/envs"; + // /open/crons + public static final String GET_CRON = QL_BASE_URL + "/open/crons"; + + //client_id + public static final String CLIENT_ID = "Ouv_S9gk5LpV"; + //client_secret + public static final String CLIENT_SECRET = "1pLjAIfBBzu1_UA9q-hOj778"; + public static final String QL_TOKEN_KEY = "QL_TOKEN_KEY"; + + private static final RedisCache redisCache = SpringUtil.getBean(RedisCache.class); + + public String getToken() { + + String token = redisCache.getCacheObject(QL_TOKEN_KEY); + if (StrUtil.isNotEmpty(token)) { + return token; + } else { + //HashMap map = new HashMap<>(); + //map.put("client_id", CLIENT_ID); + //map.put("client_secret", CLIENT_SECRET); + //String jsonStr = JSON.toJSONString(map); + for (int i = 0; i < 3; i++) { + //* 2. 使用生成的 client_id 和 client_secret 请求获取token接口 http://localhost:5700/open/auth/token?client_id=xxxxxx&client_secret=xxxxxxxx + String responseStr = HttpRequest.get(GET_TOKEN + "?client_id=" + CLIENT_ID + "&client_secret=" + CLIENT_SECRET).execute().body(); + if (ObjectUtil.isNotEmpty(responseStr)) { + //{"code":200,"data":{"token":"950e3060-d714-4f6a-9839-c098a116f0a8","token_type":"Bearer","expiration":1705743778}} + JSONObject jsonObject = JSON.parseObject(responseStr); + + System.out.println(jsonObject.getString("code")); + if (Objects.equals(String.valueOf(jsonObject.getString("code")), "200")) { + JSONObject response = jsonObject.getJSONObject("data"); + redisCache.setCacheObject(QL_TOKEN_KEY, (String) response.get("token"), (int) response.get("expiration"), TimeUnit.SECONDS); + return (String) response.get("token"); + } + } + sleep(500); + } + return null; + } + } + + + // get /envs + + /** + * @return + * @throws + * @description 获取所有环境变量 + */ + public JSONObject getEnv() { + String token = getToken(); + if (StrUtil.isNotEmpty(token)) { + for (int i = 0; i < 3; i++) { + String responseStr = HttpRequest.get(GET_ENV + "?searchValue=&t=1630032278171").header("Authorization", "Bearer " + token).execute().body(); + if (ObjectUtil.isNotEmpty(responseStr)) { + QLResponse qlResponse = JSON.parseObject(responseStr, QLResponse.class); + if (Objects.equals(String.valueOf(qlResponse.getCode()), "200")) { + return qlResponse.getData(); + } + } + sleep(500); + } + } + return null; + } + + /** + * @param name + * @return + * @throws + * @description 检查是否存在环境变量，存在返回值，不存在返回null + */ + public String getEnvValue(String name) { + JSONObject jsonObject = getEnv(); + if (ObjectUtil.isNotEmpty(jsonObject)) { + return jsonObject.getJSONObject(name).getString("value"); + } + return null; + } + + // post /envs + // { + // "value": "123", + // "name": "test_add", + // "remarks": "新建测试" + //} + + /** + * @param name + * @param remarks + * @param value + * @return + * @throws + * @description 添加环境变量 + */ + public JSONObject addEnv(String value, String name, String remarks) { + String token = getToken(); + if (StrUtil.isNotEmpty(token)) { + for (int i = 0; i < 3; i++) { + String responseStr = HttpRequest.post(GET_ENV).header("Authorization", "Bearer " + token).body(JSON.toJSONString(new QLEnv(value, name, remarks))).execute().body(); + if (ObjectUtil.isNotEmpty(responseStr)) { + QLResponse qlResponse = JSON.parseObject(responseStr, QLResponse.class); + if (Objects.equals(String.valueOf(qlResponse.getCode()), "200")) { + return qlResponse.getData(); + } + } + sleep(500); + } + } + return null; + } + + // http://134.175.126.60:45700/api/crons?searchValue=&page=1&size=20&filters={}&queryString={%22filters%22:null,%22sorts%22:null,%22filterRelation%22:%22and%22}&t=1703148561868 + + /** + * @param queryString + * @return + * @throws + * @description 获取定时任务列表 + */ + public JSONObject getCron(String queryString) { + if (StrUtil.isNotEmpty(queryString)) { + for (int i = 0; i < 3; i++) { + String responseStr = HttpRequest.get(GET_CRON + "?" + queryString).execute().body(); + if (ObjectUtil.isNotEmpty(responseStr)) { + QLResponse qlResponse = JSON.parseObject(responseStr, QLResponse.class); + if (Objects.equals(String.valueOf(qlResponse.getCode()), "200")) { + return qlResponse.getData(); + } + } + sleep(500); + } + } else { + for (int i = 0; i < 3; i++) { + String responseStr = HttpRequest.get(GET_CRON).execute().body(); + if (ObjectUtil.isNotEmpty(responseStr)) { + QLResponse qlResponse = JSON.parseObject(responseStr, QLResponse.class); + if (Objects.equals(String.valueOf(qlResponse.getCode()), "200")) { + return qlResponse.getData(); + } + } + sleep(500); + } + } + return null; + } + + /* + * 请求网址: + * http://134.175.126.60:45700/api/crons/run?t=1703148561868 + * 请求方法: + * PUT*/ + public JSONObject runCron(String cronId) { + String token = getToken(); + if (StrUtil.isNotEmpty(token)) { + for (int i = 0; i < 3; i++) { + String responseStr = HttpRequest.put(GET_CRON + "?cronId=" + cronId).header("Authorization", "Bearer " + token).execute().body(); + if (ObjectUtil.isNotEmpty(responseStr)) { + QLResponse qlResponse = JSON.parseObject(responseStr, QLResponse.class); + if (Objects.equals(String.valueOf(qlResponse.getCode()), "200")) { + return qlResponse.getData(); + } + } + sleep(500); + } + } + return null; + } + + /** + * } + * async ["getLoginedUserInfo"](_0x4ef1fe = {}) { + * let _0x26ac1b = false; + * try { + * const _0x3daa7c = { + * "token": this.token + * }; + * const _0xe8bb64 = { + * "fn": "getLoginedUserInfo", + * "method": "get", + * "url": "https://i.meituan.com/wrapapi/getLoginedUserInfo", + * "searchParams": _0x3daa7c + * }; + * let { + * result: _0x48e5d7 + * } = await this.request(_0xe8bb64); + * if (_0x48e5d7?.["mobile"]) { + * _0x26ac1b = true; + * this.name = _0x48e5d7.nickName; + * this.userId = Number(_0x48e5d7.userId); + * this.log("登录成功"); + * } else { + * this.log("获取账号信息失败, ck可能失效");//, {"notify": true} + * await expireNotify(this.userId, this.index); + * } + * } catch (_0x232c57) { + * console.log(_0x232c57); + * } finally { + * return _0x26ac1b; + * } + * }*/ + + // 通过token 获取用户信息 + // url https://i.meituan.com/wrapapi/getLoginedUserInfo + // 参数 token + // get + public HashMap getLoginedUserInfo(String token) { + String responseStr = HttpRequest.get("https://i.meituan.com/wrapapi/getLoginedUserInfo"+"?token="+token).header("token", token).execute().body(); + HashMap result = new HashMap<>(); + if (ObjectUtil.isNotEmpty(responseStr)) { + JSONObject qlResponse = JSON.parseObject(responseStr); + //{"userId":"3822095266","nickName":"XLP200660795","growthValue":null,"growthLevel":null,"avatarUrl":"","mobile":"15817969021"} + if (qlResponse.containsKey("mobile")) { + result.put("mobile",qlResponse.getString("mobile")); + } + if (qlResponse.containsKey("nickName")) { + result.put("nickName",qlResponse.getString("nickName")); + } + } + return result; + } + // new QLEnv(value, name, remarks) + private static class QLEnv { + private String value; + private String name; + private String remarks; + + public QLEnv(String value, String name, String remarks) { + this.value = value; + this.name = name; + this.remarks = remarks; + } + + public String getValue() { + return value; + } + + public void setValue(String value) { + this.value = value; + } + + public String getName() { + return name; + } + + public void setName(String name) { + this.name = name; + } + + public String getRemarks() { + return remarks; + } + + public void setRemarks(String remarks) { + this.remarks = remarks; + } + } + + private static class QLResponse { + private String code; + private JSONObject data; + + public String getCode() { + return code; + } + + public void setCode(String code) { + this.code = code; + } + + public JSONObject getData() { + return data; + } + + public void setData(JSONObject data) { + this.data = data; + } + } +} diff --git a/src/main/java/cn/van333/mt2ql/wxMessage/utils/WXUtil.java b/src/main/java/cn/van333/mt2ql/wxMessage/utils/WXUtil.java new file mode 100644 index 0000000..52d4ac5 --- /dev/null +++ b/src/main/java/cn/van333/mt2ql/wxMessage/utils/WXUtil.java @@ -0,0 +1,262 @@ +package cn.van333.mt2ql.wxMessage.utils; + +import cn.hutool.core.util.ObjectUtil; +import cn.hutool.extra.spring.SpringUtil; +import cn.hutool.http.HttpRequest; +import cn.van333.mt2ql.wxMessage.enums.WXReqType; +import com.alibaba.fastjson2.JSON; +import com.alibaba.fastjson2.JSONObject; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +/** + * @author Leo + * @version 1.0 + * @create 2023/12/22 0022 上午 09:59 + * @description： + */ +public class WXUtil { + /** + * url http://127.0.0.1:7777/DaenWxHook/httpapi/ + * 获取微信列表 (X0000) + * 微信状态检测(Q0000) + * 发送文本消息(Q0001) + * 修改下载图片 (Q0002) + * 获取个人信息 (Q0003) + * 查询对象信(Q0004) + * 获取好友列表(Q0005) + * 获取群聊列表(Q0006) + * 获取公众号列表(Q0007) + * 获取群成员列表(Q0008) + * 发送聊天记录(Q0009) + * 发送图片 (Q0010) + * 发送本地文件(Q0011) + * 发送分享链接(Q0012) + * 发送小程序(Q0013) + * 发送音乐分享(Q0014) + * 发送XML (Q0015) + * 确认收款 (Q0016) + * 同意好友请求(Q0017) + * 添加好友通过v3(Q0018) + * 添加好友_通过wxid (Q0019) + * 查询陌生人信息(Q0020) + * 邀请进群(Q0021) + * 删除好友(Q0022) + * 修改对象备注(Q0023) + * 修改群聊名称(Q0024) + * 发送名片(Q0025) + */ + public static final String WX_BASE_URL = "http://134.175.126.60:47777/DaenWxHook/httpapi/"; + private static final RedisCache redisCache = SpringUtil.getBean(RedisCache.class); + private static final Logger logger = LoggerFactory.getLogger(WXUtil.class); + + + // 获取微信列表 + public JSONObject getWxList() { + WxReqDate wxReqDate = createWxReqData(WXReqType.GET_WX_LIST); + String responseStr = HttpRequest.post(WX_BASE_URL).body(JSON.toJSONString(wxReqDate)).execute().body(); + if (ObjectUtil.isNotEmpty(responseStr)) { + return JSON.parseObject(responseStr); + } else { + return null; + } + + } + + // 发送文本消息 + public JSONObject sendTextMessage(String wxid, String content) { + String botWxid = ""; + JSONObject wxList = getWxList(); + JSONObject wxBotInfo = (JSONObject) wxList.getJSONArray("result").get(0); + botWxid = wxBotInfo.getString("wxid"); + + // + WxReqDate wxReqDate = createWxReqData(WXReqType.SEND_TEXT_MESSAGE); + JSONObject jsonObject = new JSONObject(); + jsonObject.put("wxid", wxid); + //[@,wxid=对象wxid,nick=对象昵称,isAuto=true] + content = "[@,wxid=" + wxid + ",nick=6,isAuto=true] " + content; + jsonObject.put("msg", content); + wxReqDate.setData(jsonObject); + while (Util.isNotEmpty(botWxid)) { + String responseStr = HttpRequest.post(WX_BASE_URL + "?wxid=" + botWxid).body(JSON.toJSONString(wxReqDate)).execute().body(); + if (ObjectUtil.isNotEmpty(responseStr)) { + JSONObject response = JSON.parseObject(responseStr); + //WxResponse wxResponse = JSON.parseObject(responseStr, WxResponse.class); + //System.out.println(wxResponse); + //if (Objects.equals(String.valueOf(wxResponse.getCode()), "200")) { + // return wxResponse.getData(); + //} + //JSONObject jsonObject = HttpUtil.sendPost(url, wxReqDate.getData()); + return response; + } + } + return null; + } + + //private JSONObject sendWxReq(WxReqDate wxReqDate) { + // if (wxReqDate == null) { + // return null; + // } else { + // logger.info("wxReqDate: {}", wxReqDate); + // + // String responseStr = HttpRequest.post(WX_BASE_URL).body(JSON.toJSONString(wxReqDate)).execute().body(); + // if (ObjectUtil.isNotEmpty(responseStr)) { + // JSONObject jsonObject = JSON.parseObject(responseStr); + // //WxResponse wxResponse = JSON.parseObject(responseStr, WxResponse.class); + // //System.out.println(wxResponse); + // //if (Objects.equals(String.valueOf(wxResponse.getCode()), "200")) { + // // return wxResponse.getData(); + // //} + // //JSONObject jsonObject = HttpUtil.sendPost(url, wxReqDate.getData()); + // return jsonObject; + // } + // } + // + // return null; + // } + //} + + public WxReqDate createWxReqData(WXReqType wxReqType) { + + WxReqDate wxReqDate = new WxReqDate(wxReqType.getKey(), null); + + return wxReqDate; + } + + private class WxResponse { + /** + * { + * "code": 200, + * "msg": "操作成功", + * "result": {}, + * "wxid": "wxid_3sq4tklb6c3121", + * "port": 7305, + * "pid": 12384, + * "flag": "7777", + * "timestamp": "1657462661814" + * } + */ + private Integer code; + private String msg; + private JSONObject result; + private String wxid; + private Integer port; + private Integer pid; + private String flag; + private String timestamp; + + public WxResponse(Integer code, String msg, JSONObject result, String wxid, Integer port, Integer pid, String flag, String timestamp) { + this.code = code; + this.msg = msg; + this.result = result; + this.wxid = wxid; + this.port = port; + this.pid = pid; + this.flag = flag; + this.timestamp = timestamp; + } + + public WxResponse() { + } + + public Integer getCode() { + return code; + } + + public void setCode(Integer code) { + this.code = code; + } + + public String getMsg() { + return msg; + } + + public void setMsg(String msg) { + this.msg = msg; + } + + public JSONObject getResult() { + return result; + } + + public void setResult(JSONObject result) { + this.result = result; + } + + public String getWxid() { + return wxid; + } + + public void setWxid(String wxid) { + this.wxid = wxid; + } + + public Integer getPort() { + return port; + } + + public void setPort(Integer port) { + this.port = port; + } + + public Integer getPid() { + return pid; + } + + public void setPid(Integer pid) { + this.pid = pid; + } + + public String getFlag() { + return flag; + } + + public void setFlag(String flag) { + this.flag = flag; + } + + public String getTimestamp() { + return timestamp; + } + + public void setTimestamp(String timestamp) { + this.timestamp = timestamp; + } + } + + private class WxReqDate { + //{ + // "type": "X0000", + // "data": {} + //} + private String type; + private JSONObject data; + + public WxReqDate(String type, JSONObject data) { + this.type = type; + this.data = data; + } + + public WxReqDate() { + } + + public String getType() { + return type; + } + + public void setType(String type) { + this.type = type; + } + + public Object getData() { + return data; + } + + public void setData(JSONObject data) { + this.data = data; + } + } + + +} diff --git a/src/main/java/cn/van333/mt2ql/wxMessage/utils/WxMessageConsumer.java b/src/main/java/cn/van333/mt2ql/wxMessage/utils/WxMessageConsumer.java index 72543f6..a0b0180 100644 --- a/src/main/java/cn/van333/mt2ql/wxMessage/utils/WxMessageConsumer.java +++ b/src/main/java/cn/van333/mt2ql/wxMessage/utils/WxMessageConsumer.java @@ -1,16 +1,13 @@ package cn.van333.mt2ql.wxMessage.utils; -import cn.hutool.core.util.ObjectUtil; -import cn.hutool.core.util.StrUtil; import cn.hutool.extra.spring.SpringUtil; -import cn.hutool.http.HttpRequest; import cn.van333.mt2ql.wxMessage.enums.EventType; import cn.van333.mt2ql.wxMessage.model.WxMessage; import cn.van333.mt2ql.wxMessage.model.WxMessageDataForChat; import cn.van333.mt2ql.wxMessage.model.WxUser; import cn.van333.mt2ql.wxMessage.service.WxMessageDataForChatService; import cn.van333.mt2ql.wxMessage.service.WxUserService; -import com.alibaba.fastjson2.JSON; +import com.alibaba.fastjson2.JSONArray; import com.alibaba.fastjson2.JSONObject; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import org.slf4j.Logger; @@ -22,10 +19,6 @@ import org.springframework.stereotype.Component; import java.math.BigDecimal; import java.util.HashMap; -import java.util.Objects; -import java.util.concurrent.TimeUnit; - -import static cn.hutool.core.thread.ThreadUtil.sleep; /** * @author Leo @@ -35,18 +28,10 @@ import static cn.hutool.core.thread.ThreadUtil.sleep; */ @Component public class WxMessageConsumer { - public static final String QL_BASE_URL = "http://134.175.126.60:45700"; - public static final String GET_TOKEN = QL_BASE_URL + "/open/auth/token"; - - //client_id - public static final String CLIENT_ID = "Ouv_S9gk5LpV"; - //client_secret - public static final String CLIENT_SECRET = "1pLjAIfBBzu1_UA9q-hOj778"; - public static final String QL_TOKEN_KEY = "QL_TOKEN_KEY"; + public static final String meituanCookie = "meituanCookie"; /**/ private static final Logger logger = LoggerFactory.getLogger(WxMessageConsumer.class); - private static final RedisCache redisCache = SpringUtil.getBean(RedisCache.class); /** * 临时参数 @@ -62,9 +47,9 @@ public class WxMessageConsumer { this.wxUserService = wxUserService; } - @Async("threadPoolTaskExecutor") + //@Async("threadPoolTaskExecutor") public void consume(WxMessage wxMessage) { - logger.info("接收到消息 : {}", wxMessage); + //logger.info("接收到消息 : {}", wxMessage); if (wxMessage.getEvent() == null) { return; } @@ -96,9 +81,6 @@ public class WxMessageConsumer { return; } - - System.out.println("+++++++++++"+getToken()); - /**{"type":"D0003","des":"收到消息","data":{"timeStamp":"1702957325031","fromType":1,"msgType":1,"msgSource":0,"fromWxid":"wxid_ytpc72mdoskt22","finalFromWxid":"","atWxidList":[],"silence":0,"membercount":0,"signature":"v1_OJXJYpvM","msg":"在不","msgBase64":"5Zyo5LiN"},"timestamp":"1702957325041","wxid":"wxid_kr145nk7l0an31","port":16888,"pid":10468,"flag":"7777"} * */ WxMessageDataForChat wxMessageDataForChat = data.to(WxMessageDataForChat.class); @@ -126,24 +108,25 @@ public class WxMessageConsumer { } String msg = wxMessageDataForChat.getMsg(); - /** - * https://i.meituan.com/mttouch/page/account - * ?userId=3822095266 - * &token=AgHdIkm2tAGHc9SQSiG7M8xCx1LbTue9D2HPOAun2eYl3ou7BeEw1uGrGZH-DxmEiUgsbA1v9SM4DQAAAAC6HAAAz0rTXmkB_CIHin08hCu68mFv5k6nUc2q6_CfZqEdBcngRK_xD8Sx5fE4rfdq-yAJ - * */ +//美团 20-7 + https://i.meituan.com/mttouch/page/account?userId=3822095266&token=AgHdIkm2tAGHc9SQSiG7M8xCx1LbTue9D2HPOAun2eYl3ou7BeEw1uGrGZH-DxmEiUgsbA1v9SM4DQAAAAC6HAAAz0rTXmkB_CIHin08hCu68mFv5k6nUc2q6_CfZqEdBcngRK_xD8Sx5fE4rfdq-yAJ, msgbase64=576O5ZuiIDIwLTcgKyBodHRwczovL2kubWVpdHVhbi5jb20vbXR0b3VjaC9wYWdlL2FjY291bnQ/dXNlcklkPTM4MjIwOTUyNjYmdG9rZW49QWdIZElrbTJ0QUdIYzlTUVNpRzdNOHhDeDFMYlR1ZTlEMkhQT0F1bjJlWWwzb3U3QmVFdzF1R3JHWkgtRHhtRWlVZ3NiQTF2OVNNNERRQUFBQUM2SEFBQXowclRYbWtCX0NJSGluMDhoQ3U2OG1GdjVrNm5VYzJxNl9DZlpxRWRCY25nUktfeEQ4U3g1ZkU0cmZkcS15QUo= if (msg.startsWith("美团 20-7 ")) { logger.info("处理美团的消息"); - if (msg.contains("https://i.meituan.com/mttouch/page/account")) { + msg = msg.substring(msg.indexOf("https://i.meituan.com/mttouch/page/account")); + String[] all = msg.split("\\?"); + + if (all.length == 2) { String wxid = null; if (wxMessageDataForChat.getFromtype() == 1) { wxid = wxMessageDataForChat.getFromwxid(); } else if (wxMessageDataForChat.getFromtype() == 2) { wxid = wxMessageDataForChat.getFinalfromwxid(); } - String token = msg.substring(msg.indexOf("token=") + 6, msg.indexOf("&")); - String userId = msg.substring(msg.indexOf("userId=") + 7); - logger.info("token: {}, userId: {}", token, userId); - mt20(wxid, userId, token); + String httpData = all[1]; + String[] httpDataArr = httpData.split("&"); + if (httpDataArr.length == 2) { + mt20(wxid, httpDataArr[0].split("=")[1], httpDataArr[1].split("=")[1]); + } + //mt20(wxid, userId, token); //if (runResult) { // logger.info("领券成功"); // String newMsg = msg.replace("https://i.meituan.com/mttouch/page/account", "https://i.meituan.com/mttouch/page/account?userId=" + userId + "&token=" + token); @@ -179,6 +162,7 @@ public class WxMessageConsumer { Boolean isRun = (Boolean) checkYuE.get("isRun"); String info = (String) checkYuE.get("info"); BigDecimal yuE = (BigDecimal) checkYuE.get("yuE"); + isRun = true; // 余额可以支持一次扣费 if (isRun) { @@ -208,17 +192,19 @@ public class WxMessageConsumer { WxUser wxUser = wxUserService.getOne(Wrappers.query(new WxUser()).eq("wxid", wxid)); if (Util.isEmpty(wxUser)) { info = "未进行过充值，请先充值后使用。"; - } - // 如果余额小于等于零 - if (wxUser.getMoneyShengyu().compareTo(BigDecimal.ZERO) <= 0) { - info = "账户余额不足，请先充值后使用。"; + } else { + // 如果余额小于等于零 + if (wxUser.getMoneyShengyu().compareTo(BigDecimal.ZERO) <= 0) { + info = "账户余额不足，请先充值后使用。"; + } + + if (wxUser.getMoneyShengyu().compareTo(priceOfMT20) < 0) { + info = "剩余余额不足以支持本次扣费，请先充值后使用。"; + } else { + isRun = true; + } } - if (wxUser.getMoneyShengyu().compareTo(priceOfMT20) < 0) { - info = "剩余余额不足以支持本次扣费，请先充值后使用。"; - } else { - isRun = true; - } // 返回结果 result.put("yuE", yuE); result.put("info", info); @@ -234,7 +220,7 @@ public class WxMessageConsumer { * @throws * @description */ - private String runQL(String token, String remark, Integer time) { + private String runQL(String token, String wxid, Integer time) { /** * 1. 在系统设置 -> 应用设置 -> 添加应用，权限目前支持5个模块，可以选择多个模块。选择一个模块之后，可读写此模块的所有接口。 @@ -244,46 +230,41 @@ public class WxMessageConsumer { * 4. openapi的接口与系统正常接口的区别就是青龙里的是/api/envs，openapi是/open/envs，即就是青龙接口中的api换成open * */ - //String responseStr = HttpRequest.post(QL_BASE_URL + getToken()) // .body(JSON.toJSONString(jsonMap))//头信息，多个头信息多次调用此方法即可 // .execute().body(); - System.out.println("+++++++++++"+getToken()); + /* + * 1.查询有没有这个环境变量 + * 2.没有就创建 + * 3.有就修改 环境变量名 需要 wxid + 手机号 + * 4.执行crons + * 5.如果是一次性的，time = 1 ，就删除环境变量（考虑改成禁用） + * 6.拿到青龙的结果 + * */ + //new QLUtil().getEnv(remark) + QLUtil qlUtil = new QLUtil(); + WXUtil wxUtil = new WXUtil(); + + + HashMap loginedUserInfo = qlUtil.getLoginedUserInfo(token); + if (Util.isNotEmpty(loginedUserInfo)) { + String mobile = loginedUserInfo.get("mobile"); + String nickName = loginedUserInfo.get("nickName"); + String remark = nickName + "+" + mobile; + //qlUtil.addEnv(token, meituanCookie, remark); + wxUtil.sendTextMessage(wxid, remark); + + } else { + wxUtil.sendTextMessage(wxid, "获取用户信息失败"); + + return "获取用户信息失败"; + } + + return null; } - private String getToken() { - - String token = redisCache.getCacheObject(QL_TOKEN_KEY); - if (StrUtil.isNotEmpty(token)) { - return token; - } else { - //HashMap map = new HashMap<>(); - //map.put("client_id", CLIENT_ID); - //map.put("client_secret", CLIENT_SECRET); - //String jsonStr = JSON.toJSONString(map); - for (int i = 0; i < 3; i++) { - //* 2. 使用生成的 client_id 和 client_secret 请求获取token接口 http://localhost:5700/open/auth/token?client_id=xxxxxx&client_secret=xxxxxxxx - String responseStr = HttpRequest.get(GET_TOKEN+"?client_id="+CLIENT_ID+"&client_secret="+CLIENT_SECRET) - .execute().body(); - if (ObjectUtil.isNotEmpty(responseStr)) { - //{"code":200,"data":{"token":"950e3060-d714-4f6a-9839-c098a116f0a8","token_type":"Bearer","expiration":1705743778}} - JSONObject jsonObject = JSON.parseObject(responseStr); - - System.out.println(jsonObject.getString("code")); - if (Objects.equals(String.valueOf(jsonObject.getString("code")), "200")) { - JSONObject response = jsonObject.getJSONObject("data"); - redisCache.setCacheObject(QL_TOKEN_KEY, (String)response.get("token"), (int)response.get("expiration"), TimeUnit.SECONDS); - return (String) response.get("token"); - } - } - sleep(500); - } - return null; - } - } - } diff --git a/src/main/resources/mapper/WxMessageDataForChatMapper.xml b/src/main/resources/mapper/WxMessageDataForChatMapper.xml new file mode 100644 index 0000000..529fe58 --- /dev/null +++ b/src/main/resources/mapper/WxMessageDataForChatMapper.xml @@ -0,0 +1,31 @@ + + + + + + + + + + + + + + + + + + + + + + + timeStamp,fromType,msgType, + msgSource,fromWxid,finalFromWxid, + atWxidList,silence,membercount, + signature,msg,msgBase64, + msgId,msgTypeStr + + diff --git a/src/main/resources/mapper/WxUserMapper.xml b/src/main/resources/mapper/WxUserMapper.xml new file mode 100644 index 0000000..1bb769e --- /dev/null +++ b/src/main/resources/mapper/WxUserMapper.xml @@ -0,0 +1,22 @@ + + + + + + + + + + + + + + + + wxid,money_leiji,money_shengyu, + count_chongzhi,count_xiaofei,name, + status + +