Merge remote-tracking branch 'origin/master'

fs-service/src/main/java/com/fs/company/service/impl/CompanyServiceImpl.java

@@ -342,6 +342,9 @@ public class CompanyServiceImpl implements ICompanyService
             company.setUserId(user.getUserId());
             companyMapper.updateCompany(company);
             bindMiniApp(company);
+            // 红包余额缓存
+            String companyMoneyKey = FsConstants.COMPANY_MONEY_KEY + company.getCompanyId();
+            redisCache.setCacheObject(companyMoneyKey, new BigDecimal(0.00).toString());
             return R.ok();
         }
         else

fs-service/src/main/java/com/fs/live/service/impl/LiveAfterSalesServiceImpl.java

@@ -24,6 +24,7 @@ import com.fs.common.utils.StringUtils;
 import com.fs.common.utils.spring.SpringUtils;
 import com.fs.company.service.ICompanyService;
 import com.fs.config.cloud.CloudHostProper;
+import com.fs.core.utils.OrderCodeUtils;
 import com.fs.erp.constant.AfterSalesOrderStatusEnum;
 import com.fs.erp.domain.FsJstAftersalePush;
 import com.fs.erp.dto.BaseResponse;
@@ -313,7 +314,7 @@ public class LiveAfterSalesServiceImpl implements ILiveAfterSalesService {
             if (storeAfterSales.getOrderStatus().equals(OrderInfoEnum.STATUS_1.getValue()) ) {
                 if(StringUtils.isNotEmpty(order.getExtendOrderId())){
                     //更新订单code
-                    String orderSn = IdUtil.getSnowflake(0, 0).nextIdStr();
+                    String orderSn = OrderCodeUtils.getOrderSn();
                     LiveOrder orderMap=new LiveOrder();
                     orderMap.setOrderId(order.getOrderId());
                     orderMap.setOrderCode(orderSn);
@@ -911,7 +912,7 @@ public class LiveAfterSalesServiceImpl implements ILiveAfterSalesService {
         if (storeAfterSales.getOrderStatus().equals(1)) {
             if (StringUtils.isNotEmpty(order.getExtendOrderId())) {
                 //更新订单code
-                String orderSn = IdUtil.getSnowflake(0, 0).nextIdStr();
+                String orderSn = OrderCodeUtils.getOrderSn();
                 if (StringUtils.isEmpty(orderSn)) {
                     return R.error("订单生成失败，请重试");
                 }

fs-service/src/main/java/com/fs/live/service/impl/LiveOrderServiceImpl.java

@@ -3034,7 +3034,7 @@ public class LiveOrderServiceImpl implements ILiveOrderService {
                 }
                 baseMapper.updateLiveOrder(order);
             }
-            String payCode = IdUtil.getSnowflake(0, 0).nextIdStr();
+            String payCode = OrderCodeUtils.getOrderSn();
 //            order.setOrderCode(orderCode);
 //            if(order.getPayType().equals("1")||order.getPayType().equals("2")){
             if((order.getPayType().equals("1")||order.getPayType().equals("2")||order.getPayType().equals("3")) && order.getPayMoney().compareTo(new BigDecimal(0))>0){
@@ -3512,7 +3512,7 @@ public class LiveOrderServiceImpl implements ILiveOrderService {
         liveOrder.setCompanyId(liveUserFirstEntry.getCompanyId());
         liveOrder.setCompanyUserId(liveUserFirstEntry.getCompanyUserId());
         liveOrder.setTuiUserId(liveUserFirstEntry.getCompanyUserId());
-        String orderSn = IdUtil.getSnowflake(0, 0).nextIdStr();
+        String orderSn = OrderCodeUtils.getOrderSn();
         log.info("订单生成："+orderSn);
         liveOrder.setOrderCode(orderSn);
         BigDecimal payPrice = fsStoreProduct.getPrice().multiply(new BigDecimal(liveOrder.getTotalNum()));
@@ -3704,7 +3704,7 @@ public class LiveOrderServiceImpl implements ILiveOrderService {
 
     @Override
     public R confirmOrder(LiveOrderConfirmParam param) {
-        String uuid = IdUtil.randomUUID();
+        String uuid = OrderCodeUtils.getOrderSn();
         redisCache.setCacheObject("orderKey:"+uuid,uuid,200, TimeUnit.MINUTES);
         return R.ok().put("orderKey",uuid);
     }

fs-service/src/main/java/com/fs/wxcid/dto/admin/GenAuthKey1Request.java

@@ -0,0 +1,9 @@
+package com.fs.wxcid.dto.admin;
+
+import lombok.Data;
+
+@Data
+public class GenAuthKey1Request {
+    private Integer Count = 1;
+    private Integer Days = 30;
+}

fs-service/src/main/java/com/fs/wxcid/dto/admin/GenAuthKey3Request.java

@@ -0,0 +1,13 @@
+package com.fs.wxcid.dto.admin;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+@Data
+public class GenAuthKey3Request {
+    @JsonProperty("Count")
+    private Integer Count;
+
+    @JsonProperty("Type")
+    private Integer Type;
+}

fs-service/src/main/java/com/fs/wxcid/dto/callback/CallbackConfigRequest.java

@@ -0,0 +1,21 @@
+package com.fs.wxcid.dto.callback;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+/**
+ * 设置消息回调地址的请求参数
+ * <p>对应接口：POST /message/SetCallback</p>
+ */
+@Data
+public class CallbackConfigRequest {
+    /** 回调服务器的 URL 地址，例如：https://yourdomain.com/wechat/callback
+     *  微信客户端收到消息后，会将消息以 JSON 形式 POST 到该地址 */
+    @JsonProperty("CallbackURL")
+    private String CallbackURL;
+
+    /** 是否启用消息回调功能：
+     *  true：启用，消息将实时推送到 CallbackURL
+     *  false：禁用，不推送 */
+    @JsonProperty("Enabled")
+    private Boolean Enabled;
+}

fs-service/src/main/java/com/fs/wxcid/dto/callback/CallbackMessage.java

@@ -0,0 +1,66 @@
+package com.fs.wxcid.dto.callback;
+
+import lombok.Data;
+
+/**
+ * 回调中的具体消息内容
+ */
+@Data
+public class CallbackMessage {
+
+    /** 消息 ID（整型） */
+    private Long msg_id;
+
+    /** 发送者 wxid（嵌套结构） */
+    private StringWrapper from_user_name;
+
+    /** 接收者 wxid（通常是当前账号） */
+    private StringWrapper to_user_name;
+
+    /** 消息类型：
+     *  1 = 文本，
+     *  3 = 图片，
+     *  34 = 语音，
+     *  43 = 视频，
+     *  47 = 表情/动画，
+     *  49 = App消息（链接、文件等），
+     *  51 = 系统通知（如 lastMessage）等 */
+    private Integer msg_type;
+
+    /** 消息内容（文本或 XML） */
+    private StringWrapper content;
+
+    /** 消息状态（通常为 3） */
+    private Integer status;
+
+    /** 图片状态（通常为 1） */
+    private Integer img_status;
+
+    /** 图片缓冲区（长度为 0 表示无图） */
+    private ImgBuf img_buf;
+
+    /** 消息创建时间戳（秒） */
+    private Long create_time;
+
+    /** 消息来源 XML（包含签名、扩展信息等） */
+    private String msg_source;
+
+    /** 推送通知内容（如 "昵称 : 消息文本"） */
+    private String push_content;
+
+    /** 新版消息 ID（64位整数字符串） */
+    private String new_msg_id;
+
+
+    public String getFromWxId() {
+        return from_user_name != null ? from_user_name.getStr() : null;
+    }
+
+    public String getToWxId() {
+        return to_user_name != null ? to_user_name.getStr() : null;
+    }
+
+    public String getContentText() {
+        return content != null ? content.getStr() : null;
+    }
+}

fs-service/src/main/java/com/fs/wxcid/dto/callback/ImgBuf.java

@@ -0,0 +1,11 @@
+package com.fs.wxcid.dto.callback;
+
+import lombok.Data;
+
+/**
+ * 图片缓冲区信息
+ */
+@Data
+public class ImgBuf {
+    private Integer len; // 长度，通常为 0
+}

fs-service/src/main/java/com/fs/wxcid/dto/callback/MessageCallbackRequest.java

@@ -0,0 +1,19 @@
+package com.fs.wxcid.dto.callback;
+
+import lombok.Data;
+
+/**
+ * 微信消息回调顶层请求对象
+ */
+@Data
+public class MessageCallbackRequest {
+
+    /** 账号唯一标识（与发送时的 key 一致） */
+    private String key;
+
+    /** 回调类型，目前为 "message" */
+    private String type;
+
+    /** 具体消息内容 */
+    private CallbackMessage message;
+}

fs-service/src/main/java/com/fs/wxcid/dto/callback/ReturnMessage.java

@@ -0,0 +1,11 @@
+package com.fs.wxcid.dto.callback;
+
+import lombok.Data;
+
+@Data
+public class ReturnMessage {
+    //消息来源Id
+    private String fromWxId;
+    //消息内容
+    private String text;
+}

fs-service/src/main/java/com/fs/wxcid/dto/callback/StringWrapper.java

@@ -0,0 +1,17 @@
+package com.fs.wxcid.dto.callback;
+
+import lombok.Data;
+
+/**
+ * 包装字符串的结构，用于 from_user_name / content 等字段
+ * 对应 JSON: { "str": "实际值" }
+ */
+@Data
+public class StringWrapper {
+    private String str;
+
+    @Override
+    public String toString() {
+        return str != null ? str : "";
+    }
+}

fs-service/src/main/java/com/fs/wxcid/dto/common/ApiResponse.java

@@ -0,0 +1,37 @@
+package com.fs.wxcid.dto.common;
+import com.alibaba.fastjson.annotation.JSONField;
+import lombok.Data;
+
+/**
+ *
+ * 通用响应结构
+ */
+@Data
+public class ApiResponse {
+    @JSONField(name = "Code")
+    private int code;
+
+    @JSONField(name = "Data")
+    private Object data;
+
+    @JSONField(name = "Text")
+    private String text;
+
+    @JSONField(name = "Success")
+    private boolean success;
+
+    @JSONField(name = "Data62")
+    private String data62;
+
+    @JSONField(name = "Ticket")
+    private String ticket;
+
+    @Override
+    public String toString() {
+        return "ApiResponse{" +
+                "code=" + code +
+                ", text='" + text + '\'' +
+                ", success=" + success +
+                '}';
+    }
+}

fs-service/src/main/java/com/fs/wxcid/dto/friend/AgreeAddRequest.java

@@ -0,0 +1,35 @@
+package com.fs.wxcid.dto.friend;
+
+import lombok.Data;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * 同意好友请求 或 验证添加好友 的请求参数
+ * 对应接口：/friend/AgreeAdd 和 /friend/VerifyUser
+ */
+@Data
+public class AgreeAddRequest {
+    /** 群聊用户名（当通过群聊添加时使用） */
+    @JsonProperty("ChatRoomUserName")
+    private String ChatRoomUserName;
+
+    /** 操作码，通常为 2 表示同意 */
+    @JsonProperty("OpCode")
+    private Integer OpCode;
+
+    /** 添加场景，例如 3 表示通过二维码 */
+    @JsonProperty("Scene")
+    private Integer Scene;
+
+    /** 微信内部加密参数 V3（来自好友请求） */
+    @JsonProperty("V3")
+    private String V3;
+
+    /** 微信内部加密参数 V4（来自好友请求） */
+    @JsonProperty("V4")
+    private String V4;
+
+    /** 验证附言（可选） */
+    @JsonProperty("VerifyContent")
+    private String VerifyContent;
+}

fs-service/src/main/java/com/fs/wxcid/dto/friend/DelContactRequest.java

@@ -0,0 +1,15 @@
+package com.fs.wxcid.dto.friend;
+
+import lombok.Data;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * 删除好友请求参数
+ * 对应接口：/friend/DelContact
+ */
+@Data
+public class DelContactRequest {
+    /** 要删除的好友用户名（wxid 或其他唯一标识） */
+    @JsonProperty("DelUserName")
+    private String DelUserName;
+}

fs-service/src/main/java/com/fs/wxcid/dto/friend/GetContactDetailsListRequest.java

@@ -0,0 +1,21 @@
+package com.fs.wxcid.dto.friend;
+
+import lombok.Data;
+import java.util.List;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * 获取联系人详情列表的请求参数
+ * 支持同时查询多个用户和群聊
+ * 对应接口：/friend/GetContactDetailsList
+ */
+@Data
+public class GetContactDetailsListRequest {
+    /** 要查询的群聊 wxid 列表 */
+    @JsonProperty("RoomWxIDList")
+    private List<String> RoomWxIDList;
+
+    /** 要查询的用户 wxid 列表 */
+    @JsonProperty("UserNames")
+    private List<String> UserNames;
+}

fs-service/src/main/java/com/fs/wxcid/dto/friend/GetContactListRequest.java

@@ -0,0 +1,19 @@
+package com.fs.wxcid.dto.friend;
+
+import lombok.Data;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * 分页获取全部联系人（含群聊）的请求参数
+ * 对应接口：/friend/GetContactList
+ */
+@Data
+public class GetContactListRequest {
+    /** 当前群聊联系人的序列号（用于分页） */
+    @JsonProperty("CurrentChatRoomContactSeq")
+    private Long CurrentChatRoomContactSeq;
+
+    /** 当前普通联系人的序列号（用于分页） */
+    @JsonProperty("CurrentWxcontactSeq")
+    private Long CurrentWxcontactSeq;
+}

fs-service/src/main/java/com/fs/wxcid/dto/friend/GetFriendRelationRequest.java

@@ -0,0 +1,15 @@
+package com.fs.wxcid.dto.friend;
+
+import lombok.Data;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * 查询与指定用户的好友关系状态
+ * 对应接口：/friend/GetFriendRelation
+ */
+@Data
+public class GetFriendRelationRequest {
+    /** 目标用户的用户名（wxid） */
+    @JsonProperty("UserName")
+    private String UserName;
+}

fs-service/src/main/java/com/fs/wxcid/dto/friend/SearchContactRequest.java

@@ -0,0 +1,27 @@
+package com.fs.wxcid.dto.friend;
+
+import lombok.Data;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * 搜索联系人请求参数
+ * 对应接口：/friend/SearchContact
+ */
+@Data
+public class SearchContactRequest {
+    /** 来源场景（如 0 表示通用搜索） */
+    @JsonProperty("FromScene")
+    private Integer FromScene;
+
+    /** 操作码（通常为 0） */
+    @JsonProperty("OpCode")
+    private Integer OpCode;
+
+    /** 搜索场景（如 0 表示按昵称/微信号搜索） */
+    @JsonProperty("SearchScene")
+    private Integer SearchScene;
+
+    /** 要搜索的用户名、昵称或微信号 */
+    @JsonProperty("UserName")
+    private String UserName;
+}

fs-service/src/main/java/com/fs/wxcid/dto/friend/UploadMContactRequest.java

@@ -0,0 +1,24 @@
+package com.fs.wxcid.dto.friend;
+
+import lombok.Data;
+import java.util.List;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * 上传手机通讯录以匹配微信好友
+ * 对应接口：/friend/UploadMContact
+ */
+@Data
+public class UploadMContactRequest {
+    /** 当前手机号（可选） */
+    @JsonProperty("Mobile")
+    private String Mobile;
+
+    /** 手机通讯录中的号码列表 */
+    @JsonProperty("MobileList")
+    private List<String> MobileList;
+
+    /** 操作码（通常为 0） */
+    @JsonProperty("Opcode") // 注意：此处是 Opcode（大写 O），非 OpCode
+    private Integer Opcode;
+}

fs-service/src/main/java/com/fs/wxcid/dto/friend/VerifyUserRequest.java

@@ -0,0 +1,7 @@
+package com.fs.wxcid.dto.friend;
+
+/**
+ * 验证/添加好友请求，结构与 AgreeAddRequest 完全一致
+ * 可复用或单独定义以增强语义
+ */
+public class VerifyUserRequest extends AgreeAddRequest {}

fs-service/src/main/java/com/fs/wxcid/dto/login/DeviceInfo.java

@@ -0,0 +1,21 @@
+package com.fs.wxcid.dto.login;
+import lombok.Data;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * 设备信息，用于模拟 Android 设备登录
+ */
+@Data
+public class DeviceInfo {
+    @JsonProperty("AndroidId")
+    private String androidId;         // Android 设备 ID
+
+    @JsonProperty("ImeI")
+    private String imei;              // IMEI 号（可伪造）
+
+    @JsonProperty("Manufacturer")
+    private String manufacturer;      // 厂商，如 "HUAWEI"
+
+    @JsonProperty("Model")
+    private String model;             // 型号，如 "P40"
+}

fs-service/src/main/java/com/fs/wxcid/dto/login/LoginRequest.java

@@ -0,0 +1,32 @@
+package com.fs.wxcid.dto.login;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+/**
+ * A16 数据登录 或 62账号密码登录 的通用请求参数
+ * <p>两者结构完全一致，可复用</p>
+ */
+@Data
+public class LoginRequest {
+
+    @JsonProperty("DeviceInfo")
+    private DeviceInfo deviceInfo;    // 模拟设备信息
+
+    @JsonProperty("LoginData")
+    private String loginData;         // 62数据 或 A16数据（Base64 编码）
+
+    @JsonProperty("Password")
+    private String password;          // 微信密码（部分登录方式需要）
+
+    @JsonProperty("Proxy")
+    private String proxy;             // 代理地址，格式：socks5://user:pass@ip:port
+
+    @JsonProperty("Ticket")
+    private String ticket;            // 登录票据（如扫码后的 ticket）
+
+    @JsonProperty("Type")
+    private Integer type;             // 登录类型，0 表示普通登录
+
+    @JsonProperty("UserName")
+    private String userName;          // 微信号 或 手机号
+}

fs-service/src/main/java/com/fs/wxcid/dto/login/QrCodeRequest.java

@@ -0,0 +1,19 @@
+package com.fs.wxcid.dto.login;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+/**
+ * 获取二维码请求（Car / Mac / iPad / Direct）
+ * */
+@Data
+public class QrCodeRequest {
+
+    @JsonProperty("Check")
+    private Boolean check;            // 是否检查环境（通常 false）
+
+    @JsonProperty("IpadOrmac")
+    private String ipadOrmac;         // 设备标识，如 "iPad" 或 "Mac"
+
+    @JsonProperty("Proxy")//"socks5://username:password@ipv4:port";
+    private String proxy="socks5://t16517392102382:1dhye1x5@d247.kdltpspro.com:15818";             // 代理地址（异地 IP 必填）
+}

fs-service/src/main/java/com/fs/wxcid/dto/login/SlideVerifyRequest.java

@@ -0,0 +1,21 @@
+package com.fs.wxcid.dto.login;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+/**
+ * 滑块验证
+ * */
+@Data
+public class SlideVerifyRequest {
+    @JsonProperty("data62")
+    private String data62;            // 62 数据
+
+    @JsonProperty("randstr")
+    private String randstr;           // 随机字符串（来自滑块验证）
+
+    @JsonProperty("slideticket")
+    private String slideTicket;       // 滑块验证票据
+
+    @JsonProperty("ticket")
+    private String ticket;            // 主登录票据
+}

fs-service/src/main/java/com/fs/wxcid/dto/login/VerifyCodeRequest.java

@@ -0,0 +1,20 @@
+package com.fs.wxcid.dto.login;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+/**
+ * iPad 登录时输入验证码的请求
+ */
+@Data
+public class VerifyCodeRequest {
+
+    @JsonProperty("code")
+    private String code;              // 用户输入的 6 位数字验证码
+
+    @JsonProperty("data62")
+    private String data62;            // 62 数据（用于恢复会话）
+
+    @JsonProperty("ticket")
+    private String ticket;            // 登录票据
+}

fs-service/src/main/java/com/fs/wxcid/dto/message/AddMessageMgrRequest.java

@@ -0,0 +1,16 @@
+package com.fs.wxcid.dto.message;
+
+import lombok.Data;
+import java.util.List;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * 添加消息到发送管理器（用于批量或延迟发送）
+ */
+@Data
+public class AddMessageMgrRequest {
+
+    /** 消息项列表 */
+    @JsonProperty("MsgItem")
+    private List<MsgItem> msgItemList;
+}

fs-service/src/main/java/com/fs/wxcid/dto/message/AppMessageItem.java

@@ -0,0 +1,16 @@
+package com.fs.wxcid.dto.message;
+
+import lombok.Data;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+@Data
+public class AppMessageItem {
+    @JsonProperty("ContentType")
+    private Integer ContentType;
+
+    @JsonProperty("ContentXML")
+    private String ContentXML;
+
+    @JsonProperty("ToUserName")
+    private String ToUserName;
+}

fs-service/src/main/java/com/fs/wxcid/dto/message/CdnUploadVideoRequest.java

@@ -0,0 +1,17 @@
+package com.fs.wxcid.dto.message;
+
+import lombok.Data;
+import java.util.List;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+@Data
+public class CdnUploadVideoRequest {
+    @JsonProperty("ThumbData")
+    private List<Integer> ThumbData; // 实际应为 byte[]，但 Swagger 写 [0]，先用 List<Integer>
+
+    @JsonProperty("ToUserName")
+    private String ToUserName;
+
+    @JsonProperty("VideoData")
+    private List<Integer> VideoData;
+}

fs-service/src/main/java/com/fs/wxcid/dto/message/DownloadEmojiGifRequest.java

@@ -0,0 +1,16 @@
+package com.fs.wxcid.dto.message;
+
+import lombok.Data;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * 下载表情 GIF 动图
+ * <p>需提供表情的 XML 描述内容</p>
+ */
+@Data
+public class DownloadEmojiGifRequest {
+
+    /** 表情的 XML 内容（来自消息体） */
+    @JsonProperty("xml_content")
+    private String xmlContent;
+}

fs-service/src/main/java/com/fs/wxcid/dto/message/EmojiItem.java

@@ -0,0 +1,23 @@
+package com.fs.wxcid.dto.message;
+
+import lombok.Data;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * 表情信息项（用于发送或转发）
+ */
+@Data
+public class EmojiItem {
+
+    /** 表情 MD5 值（唯一标识） */
+    @JsonProperty("EmojiMd5")
+    private String emojiMd5;
+
+    /** 表情文件大小（字节） */
+    @JsonProperty("EmojiSize")
+    private Long emojiSize;
+
+    /** 接收者 wxid */
+    @JsonProperty("ToUserName")
+    private String toUserName;
+}

fs-service/src/main/java/com/fs/wxcid/dto/message/ForwardEmojiRequest.java

@@ -0,0 +1,15 @@
+package com.fs.wxcid.dto.message;
+
+import lombok.Data;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * 转发表情（支持动图）
+ */
+@Data
+public class ForwardEmojiRequest {
+
+    /** 表情列表 */
+    @JsonProperty("EmojiList")
+    private java.util.List<EmojiItem> emojiList;
+}

fs-service/src/main/java/com/fs/wxcid/dto/message/ForwardImageItem.java

@@ -0,0 +1,25 @@
+package com.fs.wxcid.dto.message;
+
+import lombok.Data;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * 转发图片项
+ */
+@Data
+public class ForwardImageItem {
+    @JsonProperty("AesKey")
+    private String aesKey;
+
+    @JsonProperty("CdnMidImgSize")
+    private Long cdnMidImgSize;
+
+    @JsonProperty("CdnMidImgUrl")
+    private String cdnMidImgUrl;
+
+    @JsonProperty("CdnThumbImgSize")
+    private Long cdnThumbImgSize;
+
+    @JsonProperty("ToUserName")
+    private String toUserName;
+}

fs-service/src/main/java/com/fs/wxcid/dto/message/ForwardImageMessageRequest.java

@@ -0,0 +1,16 @@
+package com.fs.wxcid.dto.message;
+
+import lombok.Data;
+import java.util.List;
+import com.fasterxml.jackson.annotation.JsonProperty;
+/**
+ * 转发图片消息请求（结构与视频转发相同）
+ */
+@Data
+public class ForwardImageMessageRequest {
+    @JsonProperty("ForwardImageList")
+    private List<ForwardImageItem> ForwardImageList;
+
+    @JsonProperty("ForwardVideoList")
+    private List<ForwardVideoItem> ForwardVideoList;
+}

fs-service/src/main/java/com/fs/wxcid/dto/message/ForwardVideoItem.java

@@ -0,0 +1,27 @@
+package com.fs.wxcid.dto.message;
+
+import lombok.Data;
+import com.fasterxml.jackson.annotation.JsonProperty;
+/**
+ * 转发视频项
+ */
+@Data
+public class ForwardVideoItem {
+    @JsonProperty("AesKey")
+    private String AesKey;
+
+    @JsonProperty("CdnThumbLength")
+    private Integer CdnThumbLength;
+
+    @JsonProperty("CdnVideoUrl")
+    private String CdnVideoUrl;
+
+    @JsonProperty("Length")
+    private Integer Length;
+
+    @JsonProperty("PlayLength")
+    private Integer PlayLength;
+
+    @JsonProperty("ToUserName")
+    private String ToUserName;
+}

fs-service/src/main/java/com/fs/wxcid/dto/message/ForwardVideoMessageRequest.java

@@ -0,0 +1,5 @@
+package com.fs.wxcid.dto.message;
+/**
+ * 转发视频消息请求（结构与视频转发相同）
+ */
+public class ForwardVideoMessageRequest extends ForwardImageMessageRequest {}

fs-service/src/main/java/com/fs/wxcid/dto/message/GetMsgBigImgRequest.java

@@ -0,0 +1,34 @@
+package com.fs.wxcid.dto.message;
+
+import lombok.Data;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * 获取高清图片（分片下载）
+ */
+@Data
+public class GetMsgBigImgRequest {
+    // 压缩类型，通常
+    @JsonProperty("CompressType")
+    private Integer compressType;
+
+    // 消息发送者
+    @JsonProperty("FromUserName")
+    private String fromUserName;
+
+    // 消息 ID
+    @JsonProperty("MsgId")
+    private Long msgId;
+
+    // 分片信息
+    @JsonProperty("Section")
+    private Section section;
+
+    // 当前账号 wxid
+    @JsonProperty("ToUserName")
+    private String toUserName;
+
+    // 文件总长度
+    @JsonProperty("TotalLen")
+    private Long totalLen;
+}

fs-service/src/main/java/com/fs/wxcid/dto/message/GetMsgVideoRequest.java

@@ -0,0 +1,3 @@
+package com.fs.wxcid.dto.message;
+
+public class GetMsgVideoRequest extends GetMsgBigImgRequest {}

fs-service/src/main/java/com/fs/wxcid/dto/message/GetMsgVoiceRequest.java

@@ -0,0 +1,19 @@
+package com.fs.wxcid.dto.message;
+
+import lombok.Data;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+@Data
+public class GetMsgVoiceRequest {
+    @JsonProperty("Bufid")
+    private String Bufid;
+
+    @JsonProperty("Length")
+    private Integer Length;
+
+    @JsonProperty("NewMsgId")
+    private String NewMsgId;
+
+    @JsonProperty("ToUserName")
+    private String ToUserName;
+}

fs-service/src/main/java/com/fs/wxcid/dto/message/GroupMassMsgImageRequest.java

@@ -0,0 +1,14 @@
+package com.fs.wxcid.dto.message;
+
+import lombok.Data;
+import java.util.List;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+@Data
+public class GroupMassMsgImageRequest {
+    @JsonProperty("ImageBase64")
+    private String ImageBase64;
+
+    @JsonProperty("ToUserName")
+    private List<String> ToUserName;
+}

fs-service/src/main/java/com/fs/wxcid/dto/message/GroupMassMsgTextRequest.java

@@ -0,0 +1,14 @@
+package com.fs.wxcid.dto.message;
+
+import lombok.Data;
+import java.util.List;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+@Data
+public class GroupMassMsgTextRequest {
+    @JsonProperty("Content")
+    private String Content;
+
+    @JsonProperty("ToUserName")
+    private List<String> ToUserName;
+}

fs-service/src/main/java/com/fs/wxcid/dto/message/HttpSyncMsgRequest.java

@@ -0,0 +1,10 @@
+package com.fs.wxcid.dto.message;
+
+import lombok.Data;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+@Data
+public class HttpSyncMsgRequest {
+    @JsonProperty("Count")
+    private Integer Count;
+}

fs-service/src/main/java/com/fs/wxcid/dto/message/MsgItem.java

@@ -0,0 +1,37 @@
+package com.fs.wxcid.dto.message;
+
+import lombok.Data;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+import java.util.List;
+
+/**
+ * 通用消息项，用于发送文本、图片等
+ * <p>注意：不同接口中字段含义可能略有差异</p>
+ */
+@Data
+public class MsgItem {
+
+    /** 要 @ 的用户 wxid 列表（仅群聊有效） */
+    @JsonProperty("AtWxIDList")
+    private List<String> AtWxIDList;
+
+    /** 图片内容（Base64 编码），用于 SendImageMessage 等 */
+    @JsonProperty("ImageContent")
+    private String ImageContent;
+
+    /** 消息类型：
+     *  1 = 文本，
+     *  2 = 图片
+     *  其他值请参考协议文档 */
+    @JsonProperty("MsgType")
+    private Integer MsgType;
+
+    /** 文本消息内容 */
+    @JsonProperty("TextContent")
+    private String TextContent;
+
+    /** 接收者 wxid（好友或群） */
+    @JsonProperty("ToUserName")
+    private String ToUserName;
+}

fs-service/src/main/java/com/fs/wxcid/dto/message/RevokeMsgNewRequest.java

@@ -0,0 +1,3 @@
+package com.fs.wxcid.dto.message;
+
+public class RevokeMsgNewRequest extends RevokeMsgRequest {}

fs-service/src/main/java/com/fs/wxcid/dto/message/RevokeMsgRequest.java

@@ -0,0 +1,25 @@
+package com.fs.wxcid.dto.message;
+
+import lombok.Data;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+@Data
+public class RevokeMsgRequest {
+    @JsonProperty("ClientImgIdStr")
+    private String ClientImgIdStr;
+
+    @JsonProperty("ClientMsgId")
+    private Long ClientMsgId;
+
+    @JsonProperty("CreateTime")
+    private Long CreateTime;
+
+    @JsonProperty("IsImage")
+    private Boolean IsImage;
+
+    @JsonProperty("NewMsgId")
+    private String NewMsgId;
+
+    @JsonProperty("ToUserName")
+    private String ToUserName;
+}

fs-service/src/main/java/com/fs/wxcid/dto/message/Section.java

@@ -0,0 +1,18 @@
+package com.fs.wxcid.dto.message;
+
+import lombok.Data;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * 文件分片信息（用于高清图/视频下载）
+ */
+@Data
+public class Section {
+    // 本次请求的数据长度
+    @JsonProperty("DataLen")
+    private Long dataLen;
+
+    // 起始偏移位置
+    @JsonProperty("StartPos")
+    private Long startPos;
+}

fs-service/src/main/java/com/fs/wxcid/dto/message/SendAppMessageRequest.java

@@ -0,0 +1,11 @@
+package com.fs.wxcid.dto.message;
+
+import lombok.Data;
+import java.util.List;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+@Data
+public class SendAppMessageRequest {
+    @JsonProperty("AppList")
+    private List<AppMessageItem> AppList;
+}

fs-service/src/main/java/com/fs/wxcid/dto/message/SendEmojiMessageRequest.java

@@ -0,0 +1,11 @@
+package com.fs.wxcid.dto.message;
+
+import lombok.Data;
+import java.util.List;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+@Data
+public class SendEmojiMessageRequest {
+    @JsonProperty("EmojiList")
+    private List<EmojiItem> EmojiList;
+}

fs-service/src/main/java/com/fs/wxcid/dto/message/SendImageMessageRequest.java

@@ -0,0 +1,3 @@
+package com.fs.wxcid.dto.message;
+
+public class SendImageMessageRequest extends SendTextMessageRequest {}

fs-service/src/main/java/com/fs/wxcid/dto/message/SendImageNewMessageRequest.java

@@ -0,0 +1,3 @@
+package com.fs.wxcid.dto.message;
+
+public class SendImageNewMessageRequest extends SendTextMessageRequest {}

fs-service/src/main/java/com/fs/wxcid/dto/message/SendTextMessageRequest.java

@@ -0,0 +1,11 @@
+package com.fs.wxcid.dto.message;
+
+import lombok.Data;
+import java.util.List;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+@Data
+public class SendTextMessageRequest {
+    @JsonProperty("MsgItem")
+    private List<MsgItem> MsgItem;
+}

fs-service/src/main/java/com/fs/wxcid/dto/message/SendVoiceRequest.java

@@ -0,0 +1,19 @@
+package com.fs.wxcid.dto.message;
+
+import lombok.Data;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+@Data
+public class SendVoiceRequest {
+    @JsonProperty("ToUserName")
+    private String ToUserName;
+
+    @JsonProperty("VoiceData")
+    private String VoiceData; // Base64 or binary string
+
+    @JsonProperty("VoiceFormat")
+    private Integer VoiceFormat;
+
+    @JsonProperty("VoiceSecond,") // 注意：Swagger 有逗号 typo！
+    private Integer VoiceSecond;
+}

fs-service/src/main/java/com/fs/wxcid/dto/message/ShareCardMessageRequest.java

@@ -0,0 +1,22 @@
+package com.fs.wxcid.dto.message;
+
+import lombok.Data;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+@Data
+public class ShareCardMessageRequest {
+    @JsonProperty("CardAlias")
+    private String CardAlias;
+
+    @JsonProperty("CardFlag")
+    private Integer CardFlag;
+
+    @JsonProperty("CardNickName")
+    private String CardNickName;
+
+    @JsonProperty("CardWxId")
+    private String CardWxId;
+
+    @JsonProperty("ToUserName")
+    private String ToUserName;
+}

fs-service/src/main/java/com/fs/wxcid/dto/user/DelayAuthKeyRequest.java

@@ -0,0 +1,10 @@
+package com.fs.wxcid.dto.user;
+
+import lombok.Data;
+
+@Data
+public class DelayAuthKeyRequest {
+    private Integer Days;
+    private String ExpiryDate; // 可为空
+    private String Key;
+}

fs-service/src/main/java/com/fs/wxcid/dto/user/DeleteAuthKeyRequest.java

@@ -0,0 +1,9 @@
+package com.fs.wxcid.dto.user;
+
+import lombok.Data;
+
+@Data
+public class DeleteAuthKeyRequest {
+    private String Key;
+    private Integer Opt; // 0 或其他
+}

fs-service/src/main/java/com/fs/wxcid/dto/user/DisableAuthKeyRequest.java

@@ -0,0 +1,9 @@
+package com.fs.wxcid.dto.user;
+
+import lombok.Data;
+
+@Data
+public class DisableAuthKeyRequest {
+    private Integer IsBanned; // 0=不禁用, 1=禁用？
+    private String Key;
+}

fs-service/src/main/java/com/fs/wxcid/service/AdminLicenseService.java

@@ -0,0 +1,39 @@
+package com.fs.wxcid.service;
+
+
+import com.fs.wxcid.dto.common.ApiResponse;
+import com.fs.wxcid.dto.admin.GenAuthKey1Request;
+import com.fs.wxcid.dto.admin.GenAuthKey3Request;
+import com.fs.wxcid.dto.user.DelayAuthKeyRequest;
+import com.fs.wxcid.dto.user.DeleteAuthKeyRequest;
+import com.fs.wxcid.dto.user.DisableAuthKeyRequest;
+
+public interface AdminLicenseService {
+
+    // 授权码延期
+    ApiResponse delayAuthKey(String key, DelayAuthKeyRequest request);
+
+    // 删除授权码
+    ApiResponse deleteAuthKey(String key, DeleteAuthKeyRequest request);
+
+    // 禁用授权码
+    ApiResponse disableAuthKey(String key, DisableAuthKeyRequest request);
+
+    // 生成授权码（新设备）- POST 版本
+    ApiResponse genAuthKey1(String key, GenAuthKey1Request request);
+
+    // 生成授权码（新设备）- GET 版本（无参）
+    ApiResponse genAuthKey2(String key);
+
+    // 生成授权码（按类型：日/周/月...）
+    ApiResponse genAuthKey3(String key, GenAuthKey3Request request);
+
+    // 查询所有激活状态的卡密
+    ApiResponse getActiveLicenseKeys(String key);
+
+    // 获取代理映射列表
+    ApiResponse getProxyMappingList(String key);
+
+    // 同步卡密激活状态（HTTP 轮询）
+    ApiResponse httpSyncLicenseKey(String key);
+}

fs-service/src/main/java/com/fs/wxcid/service/FriendService.java

@@ -0,0 +1,158 @@
+// 文件路径：src/main/java/com/fs/wxcid/service/FriendService.java
+
+package com.fs.wxcid.service;
+
+import com.fs.wxcid.dto.common.ApiResponse;
+import com.fs.wxcid.dto.friend.*;
+
+/**
+ * 好友管理服务接口
+ * <p>
+ * 本接口封装了微信私有协议中 /friend 路径下的所有好友相关操作，
+ * 包括：添加/同意好友、删除好友、查询联系人、搜索、上传通讯录等。
+ * 所有方法均需传入账号唯一标识 key，并返回统一格式的 ApiResponse。
+ * </p>
+ */
+public interface FriendService {
+
+    /**
+     * 同意好友请求
+     * <p>
+     * 对应接口：POST /friend/AgreeAdd
+     * 通常用于处理来自他人的加好友申请，需提供 V3/V4 等加密参数。
+     * </p>
+     *
+     * @param key    账号唯一标识（query 参数）
+     * @param request 同意请求参数（包含 V3、V4、Scene 等）
+     * @return 统一响应结果
+     */
+    ApiResponse agreeAdd(String key, AgreeAddRequest request);
+
+    /**
+     * 删除好友
+     * <p>
+     * 对应接口：POST /friend/DelContact
+     * 从联系人列表中移除指定用户。
+     * </p>
+     *
+     * @param key    账号唯一标识
+     * @param request 删除请求参数（含 DelUserName）
+     * @return 统一响应结果
+     */
+    ApiResponse delContact(String key, DelContactRequest request);
+
+    /**
+     * 批量获取联系人详细信息
+     * <p>
+     * 对应接口：POST /friend/GetContactDetailsList
+     * 可同时查询多个用户或群聊的详细资料。
+     * </p>
+     *
+     * @param key    账号唯一标识
+     * @param request 查询参数（支持 UserNames 和 RoomWxIDList）
+     * @return 统一响应结果
+     */
+    ApiResponse getContactDetailsList(String key, GetContactDetailsListRequest request);
+
+    /**
+     * 分页获取全部联系人（包括好友和群聊）
+     * <p>
+     * 对应接口：POST /friend/GetContactList
+     * 通过序列号实现分页加载，避免一次性拉取过多数据。
+     * </p>
+     *
+     * @param key    账号唯一标识
+     * @param request 分页参数（CurrentWxcontactSeq / CurrentChatRoomContactSeq）
+     * @return 统一响应结果
+     */
+    ApiResponse getContactList(String key, GetContactListRequest request);
+
+    /**
+     * 查询与指定用户的好友关系状态
+     * <p>
+     * 对应接口：POST /friend/GetFriendRelation
+     * 可判断是否为单向/双向好友、是否被拉黑等。
+     * </p>
+     *
+     * @param key    账号唯一标识
+     * @param request 目标用户名（UserName）
+     * @return 统一响应结果（含关系状态码）
+     */
+    ApiResponse getFriendRelation(String key, GetFriendRelationRequest request);
+
+    /**
+     * 获取已关注的公众号列表
+     * <p>
+     * 对应接口：GET /friend/GetGHList
+     * 返回当前账号关注的所有公众号信息。
+     * </p>
+     *
+     * @param key 账号唯一标识
+     * @return 统一响应结果
+     */
+    ApiResponse getGHList(String key);
+
+    /**
+     * 获取手机通讯录中匹配的微信好友
+     * <p>
+     * 对应接口：GET /friend/GetMFriend
+     * 需提前上传通讯录（UploadMContact），否则可能返回空。
+     * </p>
+     *
+     * @param key 账号唯一标识
+     * @return 统一响应结果
+     */
+    ApiResponse getMFriend(String key);
+
+    /**
+     * 获取已保存的群聊列表
+     * <p>
+     * 对应接口：GET /friend/GroupList
+     * 返回当前账号参与并保存的所有群聊。
+     * </p>
+     *
+     * @param key 账号唯一标识
+     * @return 统一响应结果
+     */
+    ApiResponse getGroupList(String key);
+
+    /**
+     * 搜索联系人
+     * <p>
+     * 对应接口：POST /friend/SearchContact
+     * 支持按昵称、微信号、手机号等模糊搜索。
+     * </p>
+     *
+     * @param key    账号唯一标识
+     * @param request 搜索参数（UserName + 场景配置）
+     * @return 统一响应结果
+     */
+    ApiResponse searchContact(String key, SearchContactRequest request);
+
+    /**
+     * 上传手机通讯录用于匹配微信好友
+     * <p>
+     * 对应接口：POST /friend/UploadMContact
+     * 上传后可调用 GetMFriend 获取匹配结果。
+     * </p>
+     *
+     * @param key    账号唯一标识
+     * @param request 通讯录号码列表（MobileList）
+     * @return 统一响应结果
+     */
+    ApiResponse uploadMContact(String key, UploadMContactRequest request);
+
+    /**
+     * 发起好友验证或添加请求
+     * <p>
+     * 对应接口：POST /friend/VerifyUser
+     * 用于主动添加他人，需提供对方的 V3/V4（通常来自扫码或推荐）。
+     * 若无 V3/V4，部分场景可能无法添加。
+     * </p>
+     *
+     * @param key    账号唯一标识
+     * @param request 添加请求参数（含 V3、V4、Scene、验证语等）
+     * @return 统一响应结果
+     */
+    ApiResponse verifyUser(String key, VerifyUserRequest request);
+}

fs-service/src/main/java/com/fs/wxcid/service/LoginService.java

@@ -0,0 +1,39 @@
+package com.fs.wxcid.service;
+
+import com.fs.wxcid.dto.common.ApiResponse;
+import com.fs.wxcid.dto.login.LoginRequest;
+import com.fs.wxcid.dto.login.QrCodeRequest;
+import com.fs.wxcid.dto.login.SlideVerifyRequest;
+import com.fs.wxcid.dto.login.VerifyCodeRequest;
+/**
+ * 微信登录服务接口
+ * <p>封装所有 /login/* 接口，支持多种登录方式</p>
+ */
+public interface LoginService {
+
+    // —————— 账号密码 / 62 / A16 登录 ——————
+    ApiResponse a16Login(String key, LoginRequest request);
+    ApiResponse deviceLogin(String key, LoginRequest request);
+
+    // —————— 二维码登录（iPad / Mac / 车载） ——————
+    ApiResponse getLoginQrCodeNew(String key, QrCodeRequest request);// iPad
+    ApiResponse getLoginQrCodeNewDirect(String key, QrCodeRequest request); // 直登
+    ApiResponse macLogin(String key, QrCodeRequest request);// Mac
+    ApiResponse carLogin(String key, QrCodeRequest request);// iPad
+
+    // ------------------ 状态检测 ------------------
+    ApiResponse checkCanSetAlias(String key);// 检测是否可设昵称（判断登录环境）
+    ApiResponse checkLoginStatus(String key);// 检测扫码是否完成
+    ApiResponse getLoginStatus(String key);// 获取当前在线状态
+
+    // —————— 数据管理 ——————
+    ApiResponse get62Data(String key);            // 提取 62 数据（用于免密登录）
+
+    // —————— 验证码与滑块 ——————
+    ApiResponse verifyCode(String key, VerifyCodeRequest request);
+    ApiResponse verifyCodeSlide(String key, SlideVerifyRequest request);
+
+    // —————— 控制 ——————
+    ApiResponse wakeUpLogin(String key, QrCodeRequest request); // 唤醒扫码登录
+    ApiResponse logOut(String key);                // 退出登录
+}

fs-service/src/main/java/com/fs/wxcid/service/MessageCallbackService.java

@@ -0,0 +1,47 @@
+package com.fs.wxcid.service;
+
+import com.fs.wxcid.dto.callback.ReturnMessage;
+import com.fs.wxcid.dto.common.ApiResponse;
+import com.fs.wxcid.dto.callback.CallbackConfigRequest;
+
+import java.util.Map;
+
+public interface MessageCallbackService {
+
+    /**
+     * 接收消息回调内容
+     * <p>对应接口：POST /message/Callback</p>
+     *
+     * @param callback 回调内容
+     * @return 统一响应结果
+     */
+    ReturnMessage returnMessage(Map<String, Object> callback);
+    /**
+     * 设置消息回调地址并启用/禁用推送
+     * <p>对应接口：POST /message/SetCallback</p>
+     *
+     * @param key     账号唯一标识
+     * @param config 回调配置（URL + 启用状态）
+     * @return 统一响应结果
+     */
+    ApiResponse setCallback(String key, CallbackConfigRequest config);
+
+    /**
+     * 获取当前账号的消息回调配置
+     * <p>对应接口：GET /message/GetCallback</p>
+     *
+     * @param key 账号唯一标识
+     * @return 包含 CallbackURL 和 Enabled 状态的响应
+     */
+    ApiResponse getCallback(String key);
+
+    /**
+     * 删除（清空）消息回调配置
+     * <p>执行后将不再推送任何消息到原回调地址</p>
+     * <p>对应接口：GET /message/DeleteCallback</p>
+     *
+     * @param key 账号唯一标识
+     * @return 操作结果
+     */
+    ApiResponse deleteCallback(String key);
+}

fs-service/src/main/java/com/fs/wxcid/service/MessageService.java

@@ -0,0 +1,32 @@
+package com.fs.wxcid.service;
+
+
+import com.fs.wxcid.dto.common.ApiResponse;
+import com.fs.wxcid.dto.message.GetMsgBigImgRequest;
+import com.fs.wxcid.dto.message.*;
+
+public interface MessageService {
+
+    ApiResponse addMessageMgr(String key, AddMessageMgrRequest request);
+    ApiResponse cdnUploadVideo(String key, CdnUploadVideoRequest request);
+    ApiResponse downloadEmojiGif(String key, DownloadEmojiGifRequest request);
+    ApiResponse forwardEmoji(String key, ForwardEmojiRequest request);
+    ApiResponse forwardImageMessage(String key, ForwardImageMessageRequest request);
+    ApiResponse forwardVideoMessage(String key, ForwardVideoMessageRequest request);
+    ApiResponse getMsgBigImg(String key, GetMsgBigImgRequest request);
+    ApiResponse getMsgVideo(String key, GetMsgVideoRequest request);
+    ApiResponse getMsgVoice(String key, GetMsgVoiceRequest request);
+    ApiResponse groupMassMsgImage(String key, GroupMassMsgImageRequest request);
+    ApiResponse groupMassMsgText(String key, GroupMassMsgTextRequest request);
+    ApiResponse httpSyncMsg(String key, HttpSyncMsgRequest request);
+    ApiResponse newSyncHistoryMessage(String key); // 无 body
+    ApiResponse revokeMsg(String key, RevokeMsgRequest request);
+    ApiResponse revokeMsgNew(String key, RevokeMsgNewRequest request);
+    ApiResponse sendAppMessage(String key, SendAppMessageRequest request);
+    ApiResponse sendEmojiMessage(String key, SendEmojiMessageRequest request);
+    ApiResponse sendImageMessage(String key, SendImageMessageRequest request);
+    ApiResponse sendImageNewMessage(String key, SendImageNewMessageRequest request);
+    ApiResponse sendTextMessage(String key, SendTextMessageRequest request);
+    ApiResponse sendVoice(String key, SendVoiceRequest request);
+    ApiResponse shareCardMessage(String key, ShareCardMessageRequest request);
+}

fs-service/src/main/java/com/fs/wxcid/service/impl/AdminLicenseServiceImpl.java

@@ -0,0 +1,96 @@
+package com.fs.wxcid.service.impl;
+
+import com.fs.wxcid.dto.common.ApiResponse;
+import com.fs.wxcid.dto.admin.GenAuthKey1Request;
+import com.fs.wxcid.dto.admin.GenAuthKey3Request;
+import com.fs.wxcid.dto.user.DelayAuthKeyRequest;
+import com.fs.wxcid.dto.user.DeleteAuthKeyRequest;
+import com.fs.wxcid.dto.user.DisableAuthKeyRequest;
+import com.fs.wxcid.service.AdminLicenseService;
+import com.fs.wxwork.utils.WxWorkHttpUtil;
+import com.alibaba.fastjson.TypeReference;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@Service
+public class AdminLicenseServiceImpl implements AdminLicenseService {
+
+    private static final String BASE_URL = "http://114.117.215.244:7006";
+
+
+    @Override
+    public ApiResponse delayAuthKey(String key, DelayAuthKeyRequest request) {
+        return post("/admin/DelayAuthKey", key, request);
+    }
+
+    @Override
+    public ApiResponse deleteAuthKey(String key, DeleteAuthKeyRequest request) {
+        return post("/admin/DeleteAuthKey", key, request);
+    }
+
+    @Override
+    public ApiResponse disableAuthKey(String key, DisableAuthKeyRequest request) {
+        return post("/admin/DisableAuthKey", key, request);
+    }
+
+    @Override
+    public ApiResponse genAuthKey1(String key, GenAuthKey1Request request) {
+        return get("/admin/GenAuthKey1", key);
+    }
+
+    @Override
+    public ApiResponse genAuthKey2(String key) {
+        return get("/admin/GenAuthKey2", key);
+    }
+
+    @Override
+    public ApiResponse genAuthKey3(String key, GenAuthKey3Request request) {
+        return post("/admin/GenAuthKey3", key, request);
+    }
+
+    @Override
+    public ApiResponse getActiveLicenseKeys(String key) {
+        return get("/admin/GetActiveLicenseKeys", key);
+    }
+
+    @Override
+    public ApiResponse getProxyMappingList(String key) {
+        return get("/admin/GetProxyMappingList", key);
+    }
+
+    @Override
+    public ApiResponse httpSyncLicenseKey(String key) {
+        return get("/admin/HttpSyncLicenseKey", key);
+    }
+
+    // ------------------ 工具方法 ------------------
+    /**
+     * 通用 POST 请求方法
+     *
+     * @param path   接口路径，如 "/friend/AgreeAdd"
+     * @param key    账号唯一标识（query 参数）
+     * @param request 请求体对象
+     * @return 统一响应结果
+     */
+    private ApiResponse post(String path, String key, Object request) {
+        String url = BASE_URL + path + "?key=" + key;
+        return WxWorkHttpUtil.postWithType(url, request, new TypeReference<ApiResponse>() {});
+    }
+
+    /**
+     * 通用 GET 请求方法（无请求体）
+     *
+     * @param path 接口路径
+     * @param key  账号唯一标识
+     * @return 统一响应结果
+     */
+    private ApiResponse get(String path, String key) {
+        String url = BASE_URL + path;
+        Map<String, Object> params = new HashMap<>();
+        params.put("key", key);
+        String resp = WxWorkHttpUtil.get(url, params);
+        return com.alibaba.fastjson.JSON.parseObject(resp, ApiResponse.class);
+    }
+}

fs-service/src/main/java/com/fs/wxcid/service/impl/FriendServiceImpl.java

@@ -0,0 +1,107 @@
+package com.fs.wxcid.service.impl;
+
+import com.fs.wxcid.dto.common.ApiResponse;
+import com.fs.wxcid.dto.friend.*;
+import com.fs.wxcid.service.FriendService;
+import com.fs.wxwork.utils.WxWorkHttpUtil;
+import com.alibaba.fastjson.TypeReference;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * 好友管理服务实现类
+ * 调用微信私有 API 的 /friend 模块
+ */
+@Service
+public class FriendServiceImpl implements FriendService {
+
+    /** 微信接口基础 URL */
+    private static final String BASE_URL = "http://114.117.215.244:7006";
+
+
+    @Override
+    public ApiResponse agreeAdd(String key, AgreeAddRequest request) {
+        return post("/friend/AgreeAdd", key, request);
+    }
+
+    @Override
+    public ApiResponse delContact(String key, DelContactRequest request) {
+        return post("/friend/DelContact", key, request);
+    }
+
+    @Override
+    public ApiResponse getContactDetailsList(String key, GetContactDetailsListRequest request) {
+        return post("/friend/GetContactDetailsList", key, request);
+    }
+
+    @Override
+    public ApiResponse getContactList(String key, GetContactListRequest request) {
+        return post("/friend/GetContactList", key, request);
+    }
+
+    @Override
+    public ApiResponse getFriendRelation(String key, GetFriendRelationRequest request) {
+        return post("/friend/GetFriendRelation", key, request);
+    }
+
+    @Override
+    public ApiResponse getGHList(String key) {
+        return get("/friend/GetGHList", key);
+    }
+
+    @Override
+    public ApiResponse getMFriend(String key) {
+        return get("/friend/GetMFriend", key);
+    }
+
+    @Override
+    public ApiResponse getGroupList(String key) {
+        return get("/friend/GroupList", key);
+    }
+
+    @Override
+    public ApiResponse searchContact(String key, SearchContactRequest request) {
+        return post("/friend/SearchContact", key, request);
+    }
+
+    @Override
+    public ApiResponse uploadMContact(String key, UploadMContactRequest request) {
+        return post("/friend/UploadMContact", key, request);
+    }
+
+    @Override
+    public ApiResponse verifyUser(String key, VerifyUserRequest request) {
+        return post("/friend/VerifyUser", key, request);
+    }
+
+    // ------------------ 工具方法 ------------------
+    /**
+     * 通用 POST 请求方法
+     *
+     * @param path   接口路径，如 "/friend/AgreeAdd"
+     * @param key    账号唯一标识（query 参数）
+     * @param request 请求体对象
+     * @return 统一响应结果
+     */
+    private ApiResponse post(String path, String key, Object request) {
+        String url = BASE_URL + path + "?key=" + key;
+        return WxWorkHttpUtil.postWithType(url, request, new TypeReference<ApiResponse>() {});
+    }
+
+    /**
+     * 通用 GET 请求方法（无请求体）
+     *
+     * @param path 接口路径
+     * @param key  账号唯一标识
+     * @return 统一响应结果
+     */
+    private ApiResponse get(String path, String key) {
+        String url = BASE_URL + path;
+        Map<String, Object> params = new HashMap<>();
+        params.put("key", key);
+        String resp = WxWorkHttpUtil.get(url, params);
+        return com.alibaba.fastjson.JSON.parseObject(resp, ApiResponse.class);
+    }
+}

fs-service/src/main/java/com/fs/wxcid/service/impl/LoginServiceImpl.java

@@ -0,0 +1,113 @@
+package com.fs.wxcid.service.impl;
+
+import com.fs.wxcid.dto.common.ApiResponse;
+import com.fs.wxcid.dto.login.LoginRequest;
+import com.fs.wxcid.dto.login.QrCodeRequest;
+import com.fs.wxcid.dto.login.SlideVerifyRequest;
+import com.fs.wxcid.dto.login.VerifyCodeRequest;
+import com.fs.wxcid.service.LoginService;
+import com.fs.wxwork.utils.WxWorkHttpUtil;
+import com.alibaba.fastjson.TypeReference;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@Service
+public class LoginServiceImpl implements LoginService {
+
+    private static final String BASE_URL = "http://114.117.215.244:7006";
+
+    // ------------------ 账号密码登录 ------------------
+
+    public ApiResponse a16Login(String key, LoginRequest request) {
+        return post("/login/A16Login", key, request);
+    }
+
+    public ApiResponse deviceLogin(String key, LoginRequest request) {
+        return post("/login/DeviceLogin", key, request);
+    }
+
+    // ------------------ 二维码登录 ------------------
+
+    public ApiResponse getLoginQrCodeNew(String key, QrCodeRequest request) {
+        return post("/login/GetLoginQrCodeNew", key, request);
+    }
+
+    public ApiResponse getLoginQrCodeNewDirect(String key, QrCodeRequest request) {
+        return post("/login/GetLoginQrCodeNewDirect", key, request);
+    }
+
+    public ApiResponse macLogin(String key, QrCodeRequest request) {
+        return post("/login/MacLogin", key, request);
+    }
+
+    public ApiResponse carLogin(String key, QrCodeRequest request) {
+        return post("/login/CarLogin", key, request);
+    }
+
+    public ApiResponse wakeUpLogin(String key, QrCodeRequest request) {
+        return post("/login/WakeUpLogin", key, request);
+    }
+
+    // ------------------ 状态检测 ------------------
+
+    public ApiResponse checkCanSetAlias(String key) {
+        return get("/login/CheckCanSetAlias", key);
+    }
+
+    public ApiResponse checkLoginStatus(String key) {
+        return get("/login/CheckLoginStatus", key);
+    }
+
+    public ApiResponse getLoginStatus(String key) {
+        return get("/login/GetLoginStatus", key);
+    }
+
+    public ApiResponse get62Data(String key) {
+        return get("/login/Get62Data", key);
+    }
+
+    public ApiResponse logOut(String key) {
+        return get("/login/LogOut", key);
+    }
+
+    // ------------------ 验证 ------------------
+
+    public ApiResponse verifyCode(String key, VerifyCodeRequest request) {
+        return post("/login/VerifyCode", key, request);
+    }
+
+    public ApiResponse verifyCodeSlide(String key, SlideVerifyRequest request) {
+        return post("/login/VerifyCodeSlide", key, request);
+    }
+
+    // ------------------ 工具方法 ------------------
+    /**
+     * 通用 POST 请求方法
+     *
+     * @param path   接口路径，如 "/friend/AgreeAdd"
+     * @param key    账号唯一标识（query 参数）
+     * @param request 请求体对象
+     * @return 统一响应结果
+     */
+    private ApiResponse post(String path, String key, Object request) {
+        String url = BASE_URL + path + "?key=" + key;
+        return WxWorkHttpUtil.postWithType(url, request, new TypeReference<ApiResponse>() {});
+    }
+
+    /**
+     * 通用 GET 请求方法（无请求体）
+     *
+     * @param path 接口路径
+     * @param key  账号唯一标识
+     * @return 统一响应结果
+     */
+    private ApiResponse get(String path, String key) {
+        String url = BASE_URL + path;
+        Map<String, Object> params = new HashMap<>();
+        params.put("key", key);
+        String resp = WxWorkHttpUtil.get(url, params);
+        return com.alibaba.fastjson.JSON.parseObject(resp, ApiResponse.class);
+    }
+}

fs-service/src/main/java/com/fs/wxcid/service/impl/MessageCallbackServiceImpl.java

@@ -0,0 +1,95 @@
+package com.fs.wxcid.service.impl;
+
+
+import com.fs.wxcid.dto.callback.ReturnMessage;
+import com.fs.wxcid.dto.common.ApiResponse;
+import com.fs.wxcid.dto.callback.CallbackConfigRequest;
+import com.fs.wxcid.service.MessageCallbackService;
+import com.fs.wxwork.utils.WxWorkHttpUtil;
+import com.alibaba.fastjson.TypeReference;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.Map;
+@Slf4j
+@Service
+public class MessageCallbackServiceImpl implements MessageCallbackService {
+
+    private static final String BASE_URL = "http://114.117.215.244:7006";
+
+    @Override
+    public ReturnMessage returnMessage(Map<String, Object> callback) {
+        // 安全地获取 key
+        String key = (String) callback.get("key");
+
+        // 获取 message 子对象（也是一个 Map）
+        Map<String, Object> message = (Map<String, Object>) callback.get("message");
+        ReturnMessage returnMessage=new ReturnMessage();
+        if (message != null) {
+            // 获取嵌套的 from_user_name -> str
+            Map<String, String> fromUser = (Map<String, String>) message.get("from_user_name");
+            String fromWxId = fromUser != null ? fromUser.get("str") : null;
+
+            // 获取 content
+            Map<String, String> contentWrapper = (Map<String, String>) message.get("content");
+            String text = contentWrapper != null ? contentWrapper.get("str") : null;
+
+            returnMessage.setFromWxId(fromWxId);
+            returnMessage.setText(text);
+        }
+        log.info("接收到回调消息,发送者id:{},发送内容:{}", returnMessage.getFromWxId(),returnMessage.getText());
+        return returnMessage;
+    }
+
+    /**
+     * 设置消息回调
+     */
+    public ApiResponse setCallback(String key, CallbackConfigRequest config) {
+        return post("/message/SetCallback", key, config);
+    }
+
+    /**
+     * 获取消息回调配置
+     */
+    public ApiResponse getCallback(String key) {
+        return get("/message/GetCallback", key);
+    }
+
+    /**
+     * 删除消息回调配置
+     */
+    public ApiResponse deleteCallback(String key) {
+        return get("/message/DeleteCallback", key);
+    }
+
+
+    // ------------------ 工具方法 ------------------
+    /**
+     * 通用 POST 请求方法
+     *
+     * @param path   接口路径，如 "/friend/AgreeAdd"
+     * @param key    账号唯一标识（query 参数）
+     * @param request 请求体对象
+     * @return 统一响应结果
+     */
+    private ApiResponse post(String path, String key, Object request) {
+        String url = BASE_URL + path + "?key=" + key;
+        return WxWorkHttpUtil.postWithType(url, request, new TypeReference<ApiResponse>() {});
+    }
+
+    /**
+     * 通用 GET 请求方法（无请求体）
+     *
+     * @param path 接口路径
+     * @param key  账号唯一标识
+     * @return 统一响应结果
+     */
+    private ApiResponse get(String path, String key) {
+        String url = BASE_URL + path;
+        Map<String, Object> params = new HashMap<>();
+        params.put("key", key);
+        String resp = WxWorkHttpUtil.get(url, params);
+        return com.alibaba.fastjson.JSON.parseObject(resp, ApiResponse.class);
+    }
+}

fs-service/src/main/java/com/fs/wxcid/service/impl/MessageServiceImpl.java

@@ -0,0 +1,158 @@
+package com.fs.wxcid.service.impl;
+
+import com.fs.wxcid.dto.common.ApiResponse;
+import com.fs.wxcid.dto.message.GetMsgBigImgRequest;
+import com.fs.wxcid.dto.message.*;
+import com.fs.wxcid.service.MessageService;
+import com.fs.wxwork.utils.WxWorkHttpUtil;
+import com.alibaba.fastjson.TypeReference;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@Service
+public class MessageServiceImpl implements MessageService {
+
+    private static final String BASE_URL = "http://114.117.215.244:7006";
+
+
+    @Override
+    public ApiResponse addMessageMgr(String key, AddMessageMgrRequest request) {
+        return post("/message/AddMessageMgr", key, request);
+    }
+
+    @Override
+    public ApiResponse cdnUploadVideo(String key, CdnUploadVideoRequest request) {
+        return post("/message/CdnUploadVideo", key, request);
+    }
+
+    @Override
+    public ApiResponse downloadEmojiGif(String key, DownloadEmojiGifRequest request) {
+        return post("/message/DownloadEmojiGif", key, request);
+    }
+
+    @Override
+    public ApiResponse forwardEmoji(String key, ForwardEmojiRequest request) {
+        return post("/message/ForwardEmoji", key, request);
+    }
+
+    @Override
+    public ApiResponse forwardImageMessage(String key, ForwardImageMessageRequest request) {
+        return post("/message/ForwardImageMessage", key, request);
+    }
+
+    @Override
+    public ApiResponse forwardVideoMessage(String key, ForwardVideoMessageRequest request) {
+        return post("/message/ForwardVideoMessage", key, request);
+    }
+
+    @Override
+    public ApiResponse getMsgBigImg(String key, GetMsgBigImgRequest request) {
+        return post("/message/GetMsgBigImg", key, request);
+    }
+
+    @Override
+    public ApiResponse getMsgVideo(String key, GetMsgVideoRequest request) {
+        return post("/message/GetMsgVideo", key, request);
+    }
+
+    @Override
+    public ApiResponse getMsgVoice(String key, GetMsgVoiceRequest request) {
+        return post("/message/GetMsgVoice", key, request);
+    }
+
+    @Override
+    public ApiResponse groupMassMsgImage(String key, GroupMassMsgImageRequest request) {
+        return post("/message/GroupMassMsgImage", key, request);
+    }
+
+    @Override
+    public ApiResponse groupMassMsgText(String key, GroupMassMsgTextRequest request) {
+        return post("/message/GroupMassMsgText", key, request);
+    }
+
+    @Override
+    public ApiResponse httpSyncMsg(String key, HttpSyncMsgRequest request) {
+        return post("/message/HttpSyncMsg", key, request);
+    }
+
+    @Override
+    public ApiResponse newSyncHistoryMessage(String key) {
+        return post("/message/NewSyncHistoryMessage", key, new Object()); // 无 body，传空对象或自定义
+    }
+
+    @Override
+    public ApiResponse revokeMsg(String key, RevokeMsgRequest request) {
+        return post("/message/RevokeMsg", key, request);
+    }
+
+    @Override
+    public ApiResponse revokeMsgNew(String key, RevokeMsgNewRequest request) {
+        return post("/message/RevokeMsgNew", key, request);
+    }
+
+    @Override
+    public ApiResponse sendAppMessage(String key, SendAppMessageRequest request) {
+        return post("/message/SendAppMessage", key, request);
+    }
+
+    @Override
+    public ApiResponse sendEmojiMessage(String key, SendEmojiMessageRequest request) {
+        return post("/message/SendEmojiMessage", key, request);
+    }
+
+    @Override
+    public ApiResponse sendImageMessage(String key, SendImageMessageRequest request) {
+        return post("/message/SendImageMessage", key, request);
+    }
+
+    @Override
+    public ApiResponse sendImageNewMessage(String key, SendImageNewMessageRequest request) {
+        return post("/message/SendImageNewMessage", key, request);
+    }
+
+    @Override
+    public ApiResponse sendTextMessage(String key, SendTextMessageRequest request) {
+        return post("/message/SendTextMessage", key, request);
+    }
+
+    @Override
+    public ApiResponse sendVoice(String key, SendVoiceRequest request) {
+        return post("/message/SendVoice", key, request);
+    }
+
+    @Override
+    public ApiResponse shareCardMessage(String key, ShareCardMessageRequest request) {
+        return post("/message/ShareCardMessage", key, request);
+    }
+
+    // ------------------ 工具方法 ------------------
+    /**
+     * 通用 POST 请求方法
+     *
+     * @param path   接口路径，如 "/friend/AgreeAdd"
+     * @param key    账号唯一标识（query 参数）
+     * @param request 请求体对象
+     * @return 统一响应结果
+     */
+    private ApiResponse post(String path, String key, Object request) {
+        String url = BASE_URL + path + "?key=" + key;
+        return WxWorkHttpUtil.postWithType(url, request, new TypeReference<ApiResponse>() {});
+    }
+
+    /**
+     * 通用 GET 请求方法（无请求体）
+     *
+     * @param path 接口路径
+     * @param key  账号唯一标识
+     * @return 统一响应结果
+     */
+    private ApiResponse get(String path, String key) {
+        String url = BASE_URL + path;
+        Map<String, Object> params = new HashMap<>();
+        params.put("key", key);
+        String resp = WxWorkHttpUtil.get(url, params);
+        return com.alibaba.fastjson.JSON.parseObject(resp, ApiResponse.class);
+    }
+}

fs-service/src/main/resources/application-config-druid-bjzm.yml

@@ -10,16 +10,16 @@ logging:
 wx:
   miniapp:
     configs:
-      - appid: wx94951f52d3ac5e25   #北京存在文化
-        secret: bfe27b20c6e3c4232a1d4ef36228e84b #北京存在文化
+      - appid: wx94951f52d3ac5e25   #北京卓美
+        secret: bfe27b20c6e3c4232a1d4ef36228e84b #北京卓美
         token: Ncbnd7lJvkripxxna6NAWCxCrvC
         aesKey: HlEiBB55eaWUaeBVAQO3cWKWPYv1vOVQSq7nFNICw4E
         msgDataFormat: JSON
   cp:
-    corpId: wwa46ffb9ff6ac35b8 #企业ID北京存在文化
+    corpId: wwa46ffb9ff6ac35b8 #企业ID北京卓美
     appConfigs:
-      - agentId: 1000070       #北京存在文化
-        secret: pu2EFz6gY2Fo2K-aRUxLPaAkKIaMJJRp8ES9JdpHkp4 #北京存在文化
+      - agentId: 1000070       #北京卓美
+        secret: pu2EFz6gY2Fo2K-aRUxLPaAkKIaMJJRp8ES9JdpHkp4 #北京卓美
         token: PPKOdAlCoMO
         aesKey: PKvaxtpSv8NGpfTDm7VUHIK8Wok2ESyYX24qpXJAdMP
   pay:

fs-service/src/main/resources/application-config-druid-cfryt.yml

@@ -60,8 +60,8 @@ watch:
   password3: v9xsKuqn_$d2y
 
 fs :
-  commonApi: http://159.75.111.224:8010
-  h5CommonApi: http://159.75.111.224:8010
+  commonApi: http://172.26.180.67:7771
+  h5CommonApi: http://172.26.180.67:7771
 nuonuo:
   key: 10924508
   secret: A2EB20764D304D16