+ * 保存上线文中数据库路由
+ */
+@UtilityClass
+public class DynamicDataSourceContextHolder {
+ private final ThreadLocal CONTEXT_HOLDER = new ThreadLocal<>();
+
+ public void setDataSourceType(Integer dataSourceType) {
+ CONTEXT_HOLDER.set(dataSourceType);
+ }
+
+ public Integer getDataSourceType() {
+ return CONTEXT_HOLDER.get();
+ }
+
+ public void clearDataSourceType() {
+ CONTEXT_HOLDER.remove();
+ }
+}
\ No newline at end of file
diff --git a/pigx-visual/pigx-codegen/src/main/resources/template/index.vue.vm b/pigx-visual/pigx-codegen/src/main/resources/template/index.vue.vm
index 6fd88767a..c27431e56 100755
--- a/pigx-visual/pigx-codegen/src/main/resources/template/index.vue.vm
+++ b/pigx-visual/pigx-codegen/src/main/resources/template/index.vue.vm
@@ -62,10 +62,6 @@
tableOption: tableOption
}
},
- created() {
- },
- mounted: function () {
- },
computed: {
...mapGetters(['permissions']),
permissionList() {
@@ -98,11 +94,7 @@
return delObj(row.$pk.lowerAttrName)
}).then(data => {
_this.tableData.splice(index, 1)
- _this.$message({
- showClose: true,
- message: '删除成功',
- type: 'success'
- })
+ _this.$message.success('删除成功')
this.getList(this.page)
}).catch(function (err) {
})
@@ -117,11 +109,7 @@
handleUpdate: function (row, index, done) {
putObj(row).then(data => {
this.tableData.splice(index, 1, Object.assign({}, row))
- this.$message({
- showClose: true,
- message: '修改成功',
- type: 'success'
- })
+ _this.$message.success('修改成功')
done()
this.getList(this.page)
})
@@ -135,11 +123,7 @@
handleSave: function (row, done) {
addObj(row).then(data => {
this.tableData.push(Object.assign({}, row))
- this.$message({
- showClose: true,
- message: '添加成功',
- type: 'success'
- })
+ _this.$message.success('添加成功')
done()
this.getList(this.page)
})
diff --git a/pigx-visual/pigx-daemon-elastic-job/pom.xml b/pigx-visual/pigx-daemon-elastic-job/pom.xml
index d1111705c..47a291a04 100644
--- a/pigx-visual/pigx-daemon-elastic-job/pom.xml
+++ b/pigx-visual/pigx-daemon-elastic-job/pom.xml
@@ -23,7 +23,7 @@
com.pig4cloudpigx-visual
- 2.7.0
+ 2.8.0pigx-daemon-elastic-job
diff --git a/pigx-visual/pigx-daemon-elastic-job/src/main/java/com/pig4cloud/pigx/daemon/elastic/entity/ExecutionLog.java b/pigx-visual/pigx-daemon-elastic-job/src/main/java/com/pig4cloud/pigx/daemon/elastic/entity/ExecutionLog.java
index df7f52671..e1bc379af 100644
--- a/pigx-visual/pigx-daemon-elastic-job/src/main/java/com/pig4cloud/pigx/daemon/elastic/entity/ExecutionLog.java
+++ b/pigx-visual/pigx-daemon-elastic-job/src/main/java/com/pig4cloud/pigx/daemon/elastic/entity/ExecutionLog.java
@@ -17,7 +17,7 @@ import java.time.LocalDateTime;
*/
@Data
@EqualsAndHashCode(callSuper = true)
-@TableName("job_execution_log")
+@TableName("JOB_EXECUTION_LOG")
public class ExecutionLog extends Model {
private static final long serialVersionUID = 1L;
diff --git a/pigx-visual/pigx-daemon-elastic-job/src/main/java/com/pig4cloud/pigx/daemon/elastic/entity/StatusTraceLog.java b/pigx-visual/pigx-daemon-elastic-job/src/main/java/com/pig4cloud/pigx/daemon/elastic/entity/StatusTraceLog.java
index dcf1acc38..2e071cea3 100644
--- a/pigx-visual/pigx-daemon-elastic-job/src/main/java/com/pig4cloud/pigx/daemon/elastic/entity/StatusTraceLog.java
+++ b/pigx-visual/pigx-daemon-elastic-job/src/main/java/com/pig4cloud/pigx/daemon/elastic/entity/StatusTraceLog.java
@@ -16,7 +16,7 @@ import java.time.LocalDateTime;
*/
@Data
@EqualsAndHashCode(callSuper = true)
-@TableName("job_status_trace_log")
+@TableName("JOB_STATUS_TRACE_LOG")
public class StatusTraceLog extends Model {
private static final long serialVersionUID = 1L;
diff --git a/pigx-visual/pigx-daemon-quartz/pom.xml b/pigx-visual/pigx-daemon-quartz/pom.xml
index 36fcd37f5..0f6b1860f 100644
--- a/pigx-visual/pigx-daemon-quartz/pom.xml
+++ b/pigx-visual/pigx-daemon-quartz/pom.xml
@@ -5,7 +5,7 @@
com.pig4cloudpigx-visual
- 2.7.0
+ 2.8.04.0.0
diff --git a/pigx-visual/pigx-monitor/pom.xml b/pigx-visual/pigx-monitor/pom.xml
index dd41f551d..bf2432ce0 100644
--- a/pigx-visual/pigx-monitor/pom.xml
+++ b/pigx-visual/pigx-monitor/pom.xml
@@ -24,7 +24,7 @@
com.pig4cloudpigx-visual
- 2.7.0
+ 2.8.0pigx-monitor
@@ -36,7 +36,7 @@
com.pig4cloudpigx-common-core
- 2.7.0
+ 2.8.0org.springframework.boot
diff --git a/pigx-visual/pigx-mp-manager/Dockerfile b/pigx-visual/pigx-mp-manager/Dockerfile
new file mode 100644
index 000000000..702a7171c
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/Dockerfile
@@ -0,0 +1,15 @@
+FROM anapsix/alpine-java:8_server-jre_unlimited
+
+MAINTAINER wangiegie@gmail.com
+
+RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
+
+RUN mkdir -p /pigx-mp-manager
+
+WORKDIR /pigx-mp-manager
+
+EXPOSE 5003
+
+ADD ./pigx-visual/pigx-mp-manager/target/pigx-mp-manager.jar ./
+
+CMD java -Djava.security.egd=file:/dev/./urandom -jar pigx-mp-manager.jar
diff --git a/pigx-visual/pigx-mp-manager/pom.xml b/pigx-visual/pigx-mp-manager/pom.xml
new file mode 100755
index 000000000..60be05627
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/pom.xml
@@ -0,0 +1,85 @@
+
+
+ 4.0.0
+
+
+ com.pig4cloud
+ pigx-visual
+ 2.8.0
+
+
+ pigx-mp-manager
+ jar
+
+ 微信公众号管理模块
+
+
+
+
+ org.springframework.cloud
+ spring-cloud-starter-config
+
+
+
+ com.pig4cloud
+ pigx-common-data
+
+
+
+ com.baomidou
+ mybatis-plus-boot-starter
+
+
+ mysql
+ mysql-connector-java
+
+
+
+ com.pig4cloud
+ pigx-common-core
+
+
+
+ com.pig4cloud
+ pigx-common-swagger
+
+
+
+ com.pig4cloud
+ pigx-common-security
+
+
+ com.pig4cloud
+ pigx-common-log
+
+
+
+ com.github.binarywang
+ weixin-java-mp
+
+
+
+ org.springframework.boot
+ spring-boot-starter-web
+
+
+
+ org.springframework.boot
+ spring-boot-starter-undertow
+
+
+
+
+
+
+ org.springframework.boot
+ spring-boot-maven-plugin
+
+
+ com.spotify
+ docker-maven-plugin
+
+
+
+
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/PigxMpManagerApplication.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/PigxMpManagerApplication.java
new file mode 100755
index 000000000..ee64a45b6
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/PigxMpManagerApplication.java
@@ -0,0 +1,40 @@
+/*
+ * Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the pig4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+
+package com.pig4cloud.pigx.mp;
+
+import com.pig4cloud.pigx.common.security.annotation.EnablePigxFeignClients;
+import com.pig4cloud.pigx.common.security.annotation.EnablePigxResourceServer;
+import com.pig4cloud.pigx.common.swagger.annotation.EnablePigxSwagger2;
+import org.springframework.boot.SpringApplication;
+import org.springframework.cloud.client.SpringCloudApplication;
+
+/**
+ * @author lengleng
+ * @date 2019/03/25
+ * 代码生成模块
+ */
+@EnablePigxSwagger2
+@SpringCloudApplication
+@EnablePigxFeignClients
+@EnablePigxResourceServer
+public class PigxMpManagerApplication {
+
+ public static void main(String[] args) {
+ SpringApplication.run(PigxMpManagerApplication.class, args);
+ }
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/builder/AbstractBuilder.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/builder/AbstractBuilder.java
new file mode 100755
index 000000000..7a94beb73
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/builder/AbstractBuilder.java
@@ -0,0 +1,21 @@
+package com.pig4cloud.pigx.mp.builder;
+
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage;
+
+/**
+ * @author Binary Wang(https://github.com/binarywang)
+ */
+public abstract class AbstractBuilder {
+ /**
+ * 构建返回微信消息报文
+ *
+ * @param content
+ * @param wxMessage
+ * @param service
+ * @return
+ */
+ public abstract WxMpXmlOutMessage build(String content,
+ WxMpXmlMessage wxMessage, WxMpService service);
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/builder/ImageBuilder.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/builder/ImageBuilder.java
new file mode 100755
index 000000000..07d8686f6
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/builder/ImageBuilder.java
@@ -0,0 +1,24 @@
+package com.pig4cloud.pigx.mp.builder;
+
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlOutImageMessage;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage;
+
+/**
+ * @author Binary Wang(https://github.com/binarywang)
+ */
+public class ImageBuilder extends AbstractBuilder {
+
+ @Override
+ public WxMpXmlOutMessage build(String content, WxMpXmlMessage wxMessage,
+ WxMpService service) {
+
+ WxMpXmlOutImageMessage m = WxMpXmlOutMessage.IMAGE().mediaId(content)
+ .fromUser(wxMessage.getToUser()).toUser(wxMessage.getFromUser())
+ .build();
+
+ return m;
+ }
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/builder/TextBuilder.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/builder/TextBuilder.java
new file mode 100755
index 000000000..a212ddc27
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/builder/TextBuilder.java
@@ -0,0 +1,22 @@
+package com.pig4cloud.pigx.mp.builder;
+
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlOutTextMessage;
+
+/**
+ * @author Binary Wang(https://github.com/binarywang)
+ */
+public class TextBuilder extends AbstractBuilder {
+
+ @Override
+ public WxMpXmlOutMessage build(String content, WxMpXmlMessage wxMessage,
+ WxMpService service) {
+ WxMpXmlOutTextMessage m = WxMpXmlOutMessage.TEXT().content(content)
+ .fromUser(wxMessage.getToUser()).toUser(wxMessage.getFromUser())
+ .build();
+ return m;
+ }
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/config/WxMpConfiguration.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/config/WxMpConfiguration.java
new file mode 100755
index 000000000..6211b502a
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/config/WxMpConfiguration.java
@@ -0,0 +1,149 @@
+package com.pig4cloud.pigx.mp.config;
+
+import com.google.common.collect.Maps;
+import com.pig4cloud.pigx.mp.handler.*;
+import com.pig4cloud.pigx.mp.service.WxAccountService;
+import me.chanjar.weixin.mp.api.WxMpMessageRouter;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.api.impl.WxMpServiceImpl;
+import me.chanjar.weixin.mp.constant.WxMpEventConstants;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.core.RedisTemplate;
+
+import javax.annotation.PostConstruct;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+import static me.chanjar.weixin.common.api.WxConsts.*;
+
+/**
+ * @author Binary Wang
+ * @author lengleng
+ *
+ * 微信公众号基础配置，初始化配置
+ */
+@Configuration
+public class WxMpConfiguration {
+ public static Map getRouters() {
+ return routers;
+ }
+
+ public static Map getMpServices() {
+ return mpServices;
+ }
+
+ private WxAccountService accountService;
+ private LogHandler logHandler;
+ private NullHandler nullHandler;
+ private KfSessionHandler kfSessionHandler;
+ private StoreCheckNotifyHandler storeCheckNotifyHandler;
+ private LocationHandler locationHandler;
+ private MenuHandler menuHandler;
+ private MsgHandler msgHandler;
+ private UnsubscribeHandler unsubscribeHandler;
+ private SubscribeHandler subscribeHandler;
+ private ScanHandler scanHandler;
+ private RedisTemplate redisTemplate;
+
+ private static Map routers = Maps.newHashMap();
+ private static Map mpServices = Maps.newHashMap();
+
+ @Autowired
+ public WxMpConfiguration(WxAccountService accountService, LogHandler logHandler, NullHandler nullHandler
+ , KfSessionHandler kfSessionHandler, StoreCheckNotifyHandler storeCheckNotifyHandler
+ , LocationHandler locationHandler, MenuHandler menuHandler
+ , MsgHandler msgHandler, UnsubscribeHandler unsubscribeHandler
+ , SubscribeHandler subscribeHandler, ScanHandler scanHandler
+ , RedisTemplate pigxRedisTemplate) {
+ this.accountService = accountService;
+ this.logHandler = logHandler;
+ this.nullHandler = nullHandler;
+ this.kfSessionHandler = kfSessionHandler;
+ this.storeCheckNotifyHandler = storeCheckNotifyHandler;
+ this.locationHandler = locationHandler;
+ this.menuHandler = menuHandler;
+ this.msgHandler = msgHandler;
+ this.unsubscribeHandler = unsubscribeHandler;
+ this.subscribeHandler = subscribeHandler;
+ this.scanHandler = scanHandler;
+ this.redisTemplate = pigxRedisTemplate;
+ }
+
+ @PostConstruct
+ public void initServices() {
+ mpServices = accountService.list().stream().map(a -> {
+ WxMpInRedisConfigStorage configStorage = new WxMpInRedisConfigStorage(redisTemplate);
+ configStorage.setAppId(a.getAppid());
+ configStorage.setSecret(a.getAppsecret());
+ configStorage.setToken(a.getToken());
+ configStorage.setAesKey(a.getAeskey());
+
+ WxMpService service = new WxMpServiceImpl();
+ service.setWxMpConfigStorage(configStorage);
+ routers.put(a.getAppid(), this.newRouter(service));
+ return service;
+ }).collect(Collectors.toMap(s -> s.getWxMpConfigStorage().getAppId(), a -> a));
+ }
+
+ private WxMpMessageRouter newRouter(WxMpService wxMpService) {
+ final WxMpMessageRouter newRouter = new WxMpMessageRouter(wxMpService);
+
+ // 记录所有事件的日志 （异步执行）
+ newRouter.rule().handler(this.logHandler).next();
+
+ // 接收客服会话管理事件
+ newRouter.rule().async(false).msgType(XmlMsgType.EVENT)
+ .event(WxMpEventConstants.CustomerService.KF_CREATE_SESSION)
+ .handler(this.kfSessionHandler).end();
+ newRouter.rule().async(false).msgType(XmlMsgType.EVENT)
+ .event(WxMpEventConstants.CustomerService.KF_CLOSE_SESSION)
+ .handler(this.kfSessionHandler)
+ .end();
+ newRouter.rule().async(false).msgType(XmlMsgType.EVENT)
+ .event(WxMpEventConstants.CustomerService.KF_SWITCH_SESSION)
+ .handler(this.kfSessionHandler).end();
+
+ // 门店审核事件
+ newRouter.rule().async(false).msgType(XmlMsgType.EVENT)
+ .event(WxMpEventConstants.POI_CHECK_NOTIFY)
+ .handler(this.storeCheckNotifyHandler).end();
+
+ // 自定义菜单事件
+ newRouter.rule().async(false).msgType(XmlMsgType.EVENT)
+ .event(MenuButtonType.CLICK).handler(this.menuHandler).end();
+
+ // 点击菜单连接事件
+ newRouter.rule().async(false).msgType(XmlMsgType.EVENT)
+ .event(MenuButtonType.VIEW).handler(this.nullHandler).end();
+
+ // 关注事件
+ newRouter.rule().async(false).msgType(XmlMsgType.EVENT)
+ .event(EventType.SUBSCRIBE).handler(this.subscribeHandler)
+ .end();
+
+ // 取消关注事件
+ newRouter.rule().async(false).msgType(XmlMsgType.EVENT)
+ .event(EventType.UNSUBSCRIBE)
+ .handler(this.unsubscribeHandler).end();
+
+ // 上报地理位置事件
+ newRouter.rule().async(false).msgType(XmlMsgType.EVENT)
+ .event(EventType.LOCATION).handler(this.locationHandler)
+ .end();
+
+ // 接收地理位置消息
+ newRouter.rule().async(false).msgType(XmlMsgType.LOCATION)
+ .handler(this.locationHandler).end();
+
+ // 扫码事件
+ newRouter.rule().async(false).msgType(XmlMsgType.EVENT)
+ .event(EventType.SCAN).handler(this.scanHandler).end();
+
+ // 默认
+ newRouter.rule().async(false).handler(this.msgHandler).end();
+
+ return newRouter;
+ }
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/config/WxMpContextHolder.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/config/WxMpContextHolder.java
new file mode 100644
index 000000000..9f73e4a01
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/config/WxMpContextHolder.java
@@ -0,0 +1,55 @@
+/*
+ * Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the pig4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+
+package com.pig4cloud.pigx.mp.config;
+
+import com.alibaba.ttl.TransmittableThreadLocal;
+import lombok.experimental.UtilityClass;
+
+/**
+ * @author lengleng
+ * @date 2019/03/27
+ * 微信上下文工具类
+ */
+@UtilityClass
+public class WxMpContextHolder {
+
+ private final ThreadLocal THREAD_LOCAL_APPID = new TransmittableThreadLocal<>();
+
+
+ /**
+ * TTL 设置appId
+ *
+ * @param appId
+ */
+ public void setAppId(String appId) {
+ THREAD_LOCAL_APPID.set(appId);
+ }
+
+ /**
+ * 获取TTL中的appId
+ *
+ * @return
+ */
+ public String getAppId() {
+ return THREAD_LOCAL_APPID.get();
+ }
+
+ public void clear() {
+ THREAD_LOCAL_APPID.remove();
+ }
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/config/WxMpInRedisConfigStorage.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/config/WxMpInRedisConfigStorage.java
new file mode 100644
index 000000000..a045b6ca5
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/config/WxMpInRedisConfigStorage.java
@@ -0,0 +1,120 @@
+/*
+ * Copyright (c) 2018-2025, 云集汇通 All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the yunjihuitong.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ */
+
+package com.pig4cloud.pigx.mp.config;
+
+import me.chanjar.weixin.mp.api.WxMpInMemoryConfigStorage;
+import me.chanjar.weixin.mp.enums.TicketType;
+import org.springframework.data.redis.core.RedisTemplate;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * @author lengleng
+ * @date 2019/03/26
+ *
+ * 微信SDK redis扩展
+ */
+public class WxMpInRedisConfigStorage extends WxMpInMemoryConfigStorage {
+
+ private final static String ACCESS_TOKEN_KEY = "wechat:access_token_";
+
+ private final static String JSAPI_TICKET_KEY = "wechat:jsapi_ticket_";
+
+ private final static String CARDAPI_TICKET_KEY = "wechat:cardapi_ticket_";
+
+ private final RedisTemplate redisTemplate;
+
+ private String accessTokenKey;
+
+ private String jsapiTicketKey;
+
+ private String cardapiTicketKey;
+
+ public WxMpInRedisConfigStorage(RedisTemplate redisTemplate) {
+ this.redisTemplate = redisTemplate;
+ }
+
+ /**
+ * 每个公众号生成独有的存储key
+ *
+ * @param appId
+ */
+ @Override
+ public void setAppId(String appId) {
+ super.setAppId(appId);
+ this.accessTokenKey = ACCESS_TOKEN_KEY.concat(appId);
+ this.jsapiTicketKey = JSAPI_TICKET_KEY.concat(appId);
+ this.cardapiTicketKey = CARDAPI_TICKET_KEY.concat(appId);
+ }
+
+ @Override
+ public String getAccessToken() {
+ return redisTemplate.opsForValue().get(this.accessTokenKey);
+ }
+
+ @Override
+ public boolean isAccessTokenExpired() {
+ return redisTemplate.getExpire(accessTokenKey) < 2L;
+ }
+
+ @Override
+ public synchronized void updateAccessToken(String accessToken, int expiresInSeconds) {
+ redisTemplate.opsForValue().set(accessTokenKey, accessToken, expiresInSeconds - 200, TimeUnit.SECONDS);
+ }
+
+ @Override
+ public void expireAccessToken() {
+ redisTemplate.expire(this.accessTokenKey, 0, TimeUnit.SECONDS);
+ }
+
+ @Override
+ public String getJsapiTicket() {
+ return redisTemplate.opsForValue().get(this.jsapiTicketKey);
+ }
+
+
+ @Override
+ public String getCardApiTicket() {
+ return redisTemplate.opsForValue().get(cardapiTicketKey);
+ }
+
+
+ @Override
+ public String getTicket(TicketType type) {
+ return redisTemplate.opsForValue().get(getTicketRedisKey(type));
+ }
+
+ @Override
+ public boolean isTicketExpired(TicketType type) {
+ return redisTemplate.getExpire(this.getTicketRedisKey(type)) < 2;
+ }
+
+ @Override
+ public synchronized void updateTicket(TicketType type, String jsapiTicket, int expiresInSeconds) {
+ redisTemplate.opsForValue().set(getTicketRedisKey(type), jsapiTicket, expiresInSeconds - 200, TimeUnit.SECONDS);
+ }
+
+ @Override
+ public void expireTicket(TicketType type) {
+ redisTemplate.expire(getTicketRedisKey(type), 0, TimeUnit.SECONDS);
+ }
+
+ private String getTicketRedisKey(TicketType type) {
+ return String.format("wechat:ticket:key:%s:%s", this.appId, type.getCode());
+ }
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/controller/WxAccountController.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/controller/WxAccountController.java
new file mode 100755
index 000000000..e6806732e
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/controller/WxAccountController.java
@@ -0,0 +1,147 @@
+/*
+ * Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the pig4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.pig4cloud.pigx.mp.controller;
+
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.pig4cloud.pigx.common.core.util.R;
+import com.pig4cloud.pigx.common.log.annotation.SysLog;
+import com.pig4cloud.pigx.mp.config.WxMpConfiguration;
+import com.pig4cloud.pigx.mp.entity.WxAccount;
+import com.pig4cloud.pigx.mp.service.WxAccountService;
+import lombok.AllArgsConstructor;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.web.bind.annotation.*;
+
+
+/**
+ * 公众号账户
+ *
+ * @author lengleng
+ * @date 2019-03-26 22:07:53
+ */
+@RestController
+@AllArgsConstructor
+@RequestMapping("/wxaccount")
+public class WxAccountController {
+ private final WxMpConfiguration wxMpConfiguration;
+ private final WxAccountService wxAccountService;
+
+ /**
+ * 分页查询
+ *
+ * @param page 分页对象
+ * @param wxAccount 公众号账户
+ * @return
+ */
+ @GetMapping("/page")
+ public R getWxAccountPage(Page page, WxAccount wxAccount) {
+ return new R<>(wxAccountService.page(page, Wrappers.query(wxAccount)));
+ }
+
+
+ /**
+ * 通过id查询公众号账户
+ *
+ * @param id id
+ * @return R
+ */
+ @GetMapping("/{id}")
+ public R getById(@PathVariable("id") Integer id) {
+ return new R<>(wxAccountService.getById(id));
+ }
+
+ /**
+ * 新增公众号账户
+ *
+ * @param wxAccount 公众号账户
+ * @return R
+ */
+ @SysLog("新增公众号账户")
+ @PostMapping
+ @PreAuthorize("@pms.hasPermission('mp_wxaccount_add')")
+ public R save(@RequestBody WxAccount wxAccount) {
+ wxAccountService.save(wxAccount);
+ wxMpConfiguration.initServices();
+ return new R<>();
+ }
+
+ /**
+ * 修改公众号账户
+ *
+ * @param wxAccount 公众号账户
+ * @return R
+ */
+ @SysLog("修改公众号账户")
+ @PutMapping
+ @PreAuthorize("@pms.hasPermission('mp_wxaccount_edit')")
+ public R updateById(@RequestBody WxAccount wxAccount) {
+ wxAccountService.updateById(wxAccount);
+ wxMpConfiguration.initServices();
+ return new R<>();
+ }
+
+ /**
+ * 通过id删除公众号账户
+ *
+ * @param id id
+ * @return R
+ */
+ @SysLog("删除公众号账户")
+ @DeleteMapping("/{id}")
+ @PreAuthorize("@pms.hasPermission('mp_wxaccount_del')")
+ public R removeById(@PathVariable Integer id) {
+ wxAccountService.removeById(id);
+ wxMpConfiguration.initServices();
+ return new R<>();
+ }
+
+ /**
+ * 生成公众号二维码
+ *
+ * @param appId
+ * @return
+ */
+ @SysLog("生成公众号二维码")
+ @PostMapping("/qr/{appId}")
+ @PreAuthorize("@pms.hasPermission('mp_wxaccount_add')")
+ public R qr(@PathVariable String appId) {
+ return wxAccountService.generateQr(appId);
+ }
+
+ /**
+ * 获取公众号列表
+ *
+ * @return
+ */
+ @GetMapping("/list")
+ public R list() {
+ return new R<>(wxAccountService.list());
+ }
+
+ /**
+ * 获取公众号接口数据
+ *
+ * @param appId 公众号
+ * @param interval 时间间隔
+ * @return
+ */
+ @GetMapping("/statistics")
+ public R statistics(String appId, String interval) {
+ return wxAccountService.statistics(appId, interval);
+ }
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/controller/WxAccountFansController.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/controller/WxAccountFansController.java
new file mode 100755
index 000000000..5ec3ec169
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/controller/WxAccountFansController.java
@@ -0,0 +1,117 @@
+/*
+ * Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the pig4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.pig4cloud.pigx.mp.controller;
+
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.pig4cloud.pigx.common.core.util.R;
+import com.pig4cloud.pigx.common.log.annotation.SysLog;
+import com.pig4cloud.pigx.mp.entity.WxAccountFans;
+import com.pig4cloud.pigx.mp.service.WxAccountFansService;
+import lombok.AllArgsConstructor;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.web.bind.annotation.*;
+
+
+/**
+ * 微信公众号粉丝管理
+ *
+ * @author lengleng
+ * @date 2019-03-26 22:08:08
+ */
+@RestController
+@AllArgsConstructor
+@RequestMapping("/wxaccountfans")
+public class WxAccountFansController {
+
+ private final WxAccountFansService wxAccountFansService;
+
+ /**
+ * 分页查询
+ *
+ * @param page 分页对象
+ * @param wxAccountFans 微信公众号粉丝
+ * @return
+ */
+ @GetMapping("/page")
+ public R getWxAccountFansPage(Page page, WxAccountFans wxAccountFans) {
+ return new R<>(wxAccountFansService.page(page, Wrappers.query(wxAccountFans)));
+ }
+
+
+ /**
+ * 通过id查询微信公众号粉丝
+ *
+ * @param id id
+ * @return R
+ */
+ @GetMapping("/{id}")
+ public R getById(@PathVariable("id") Integer id) {
+ return new R<>(wxAccountFansService.getById(id));
+ }
+
+ /**
+ * 新增微信公众号粉丝
+ *
+ * @param wxAccountFans 微信公众号粉丝
+ * @return R
+ */
+ @SysLog("新增微信公众号粉丝")
+ @PostMapping
+ @PreAuthorize("@pms.hasPermission('mp_wxaccountfans_add')")
+ public R save(@RequestBody WxAccountFans wxAccountFans) {
+ return new R<>(wxAccountFansService.save(wxAccountFans));
+ }
+
+ /**
+ * 修改微信公众号粉丝
+ *
+ * @param wxAccountFans 微信公众号粉丝
+ * @return R
+ */
+ @SysLog("修改微信公众号粉丝")
+ @PutMapping
+ @PreAuthorize("@pms.hasPermission('mp_wxaccountfans_edit')")
+ public R updateById(@RequestBody WxAccountFans wxAccountFans) {
+ return new R<>(wxAccountFansService.updateById(wxAccountFans));
+ }
+
+ /**
+ * 通过id删除微信公众号粉丝
+ *
+ * @param id id
+ * @return R
+ */
+ @SysLog("删除微信公众号粉丝")
+ @DeleteMapping("/{id}")
+ @PreAuthorize("@pms.hasPermission('mp_wxaccountfans_del')")
+ public R removeById(@PathVariable Integer id) {
+ return new R<>(wxAccountFansService.removeById(id));
+ }
+
+ /**
+ * 同步粉丝
+ *
+ * @param appId
+ * @return
+ */
+ @PostMapping("/sync/{appId}")
+ public R sync(@PathVariable String appId) {
+ return new R(wxAccountFansService.syncAccountFans(appId));
+ }
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/controller/WxFansMsgController.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/controller/WxFansMsgController.java
new file mode 100755
index 000000000..d1200085c
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/controller/WxFansMsgController.java
@@ -0,0 +1,106 @@
+/*
+ * Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the pig4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.pig4cloud.pigx.mp.controller;
+
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.pig4cloud.pigx.common.core.util.R;
+import com.pig4cloud.pigx.common.log.annotation.SysLog;
+import com.pig4cloud.pigx.mp.entity.WxFansMsg;
+import com.pig4cloud.pigx.mp.service.WxFansMsgService;
+import lombok.AllArgsConstructor;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.web.bind.annotation.*;
+
+
+/**
+ * 微信粉丝消息管理
+ *
+ * @author lengleng
+ * @date 2019-03-27 20:45:27
+ */
+@RestController
+@AllArgsConstructor
+@RequestMapping("/wxfansmsg")
+public class WxFansMsgController {
+
+ private final WxFansMsgService wxFansMsgService;
+
+ /**
+ * 分页查询
+ *
+ * @param page 分页对象
+ * @param wxFansMsg 消息
+ * @return
+ */
+ @GetMapping("/page")
+ public R getWxFansMsgPage(Page page, WxFansMsg wxFansMsg) {
+ return new R<>(wxFansMsgService.page(page, Wrappers.query(wxFansMsg)));
+ }
+
+
+ /**
+ * 通过id查询消息
+ *
+ * @param id id
+ * @return R
+ */
+ @GetMapping("/{id}")
+ public R getById(@PathVariable("id") Integer id) {
+ return new R<>(wxFansMsgService.getById(id));
+ }
+
+ /**
+ * 新增消息
+ *
+ * @param wxFansMsg 消息
+ * @return R
+ */
+ @SysLog("新增消息")
+ @PostMapping
+ @PreAuthorize("@pms.hasPermission('mp_wxfansmsg_add')")
+ public R save(@RequestBody WxFansMsg wxFansMsg) {
+ return new R<>(wxFansMsgService.save(wxFansMsg));
+ }
+
+ /**
+ * 修改消息
+ *
+ * @param wxFansMsg 消息
+ * @return R
+ */
+ @SysLog("修改消息")
+ @PutMapping
+ @PreAuthorize("@pms.hasPermission('mp_wxfansmsg_edit')")
+ public R updateById(@RequestBody WxFansMsg wxFansMsg) {
+ return new R<>(wxFansMsgService.updateById(wxFansMsg));
+ }
+
+ /**
+ * 通过id删除消息
+ *
+ * @param id id
+ * @return R
+ */
+ @SysLog("删除消息")
+ @DeleteMapping("/{id}")
+ @PreAuthorize("@pms.hasPermission('mp_wxfansmsg_del')")
+ public R removeById(@PathVariable Integer id) {
+ return new R<>(wxFansMsgService.removeById(id));
+ }
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/controller/WxFansMsgResController.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/controller/WxFansMsgResController.java
new file mode 100755
index 000000000..9213af46f
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/controller/WxFansMsgResController.java
@@ -0,0 +1,106 @@
+/*
+ * Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the pig4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.pig4cloud.pigx.mp.controller;
+
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.pig4cloud.pigx.common.core.util.R;
+import com.pig4cloud.pigx.common.log.annotation.SysLog;
+import com.pig4cloud.pigx.mp.entity.WxFansMsgRes;
+import com.pig4cloud.pigx.mp.service.WxFansMsgResService;
+import lombok.AllArgsConstructor;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.web.bind.annotation.*;
+
+
+/**
+ * 微信粉丝消息回复管理
+ *
+ * @author lengleng
+ * @date 2019-03-27 20:45:48
+ */
+@RestController
+@AllArgsConstructor
+@RequestMapping("/wxfansmsgres")
+public class WxFansMsgResController {
+
+ private final WxFansMsgResService wxFansMsgResService;
+
+ /**
+ * 分页查询
+ *
+ * @param page 分页对象
+ * @param wxFansMsgRes 回复
+ * @return
+ */
+ @GetMapping("/page")
+ public R getWxFansMsgResPage(Page page, WxFansMsgRes wxFansMsgRes) {
+ return new R<>(wxFansMsgResService.page(page, Wrappers.query(wxFansMsgRes)));
+ }
+
+
+ /**
+ * 通过id查询回复
+ *
+ * @param id id
+ * @return R
+ */
+ @GetMapping("/{id}")
+ public R getById(@PathVariable("id") Integer id) {
+ return new R<>(wxFansMsgResService.getById(id));
+ }
+
+ /**
+ * 新增回复
+ *
+ * @param wxFansMsgRes 回复
+ * @return R
+ */
+ @SysLog("新增回复")
+ @PostMapping
+ @PreAuthorize("@pms.hasPermission('mp_wxfansmsgres_add')")
+ public R save(@RequestBody WxFansMsgRes wxFansMsgRes) {
+ return wxFansMsgResService.saveAndSend(wxFansMsgRes);
+ }
+
+ /**
+ * 修改回复
+ *
+ * @param wxFansMsgRes 回复
+ * @return R
+ */
+ @SysLog("修改回复")
+ @PutMapping
+ @PreAuthorize("@pms.hasPermission('mp_wxfansmsgres_edit')")
+ public R updateById(@RequestBody WxFansMsgRes wxFansMsgRes) {
+ return new R<>(wxFansMsgResService.updateById(wxFansMsgRes));
+ }
+
+ /**
+ * 通过id删除回复
+ *
+ * @param id id
+ * @return R
+ */
+ @SysLog("删除回复")
+ @DeleteMapping("/{id}")
+ @PreAuthorize("@pms.hasPermission('mp_wxfansmsgres_del')")
+ public R removeById(@PathVariable Integer id) {
+ return new R<>(wxFansMsgResService.removeById(id));
+ }
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/controller/WxMenuController.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/controller/WxMenuController.java
new file mode 100755
index 000000000..978264153
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/controller/WxMenuController.java
@@ -0,0 +1,94 @@
+/*
+ * Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the pig4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.pig4cloud.pigx.mp.controller;
+
+import cn.hutool.json.JSONObject;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.pig4cloud.pigx.common.core.util.R;
+import com.pig4cloud.pigx.common.log.annotation.SysLog;
+import com.pig4cloud.pigx.mp.entity.WxMpMenu;
+import com.pig4cloud.pigx.mp.service.WxMenuService;
+import lombok.AllArgsConstructor;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.web.bind.annotation.*;
+
+
+/**
+ * 微信菜单管理
+ *
+ * @author lengleng
+ * @date 2019-03-27 20:45:18
+ */
+@RestController
+@AllArgsConstructor
+@RequestMapping("/wxmenu")
+public class WxMenuController {
+
+ private final WxMenuService wxMenuService;
+
+ /**
+ * 分页查询
+ *
+ * @param page 分页对象
+ * @param WxMpMenu lengleng
+ * @return
+ */
+ @GetMapping("/page")
+ public R getWxMpMenuPage(Page page, WxMpMenu WxMpMenu) {
+ return new R<>(wxMenuService.page(page, Wrappers.query(WxMpMenu)));
+ }
+
+
+ /**
+ * 通过appid查询微信菜单
+ *
+ * @param appId 公众号
+ * @return R
+ */
+ @GetMapping("/{appId}")
+ public R getById(@PathVariable("appId") String appId) {
+ return wxMenuService.getByAppId(appId);
+ }
+
+ /**
+ * 新增微信菜单
+ *
+ * @param WxMpMenus 微信菜单列表
+ * @return R
+ */
+ @SysLog("新增微信菜单")
+ @PostMapping("/{appId}")
+ @PreAuthorize("@pms.hasPermission('mp_wxmenu_add')")
+ public R save(@RequestBody JSONObject WxMpMenus, @PathVariable String appId) {
+ return new R(wxMenuService.save(WxMpMenus, appId));
+ }
+
+ /**
+ * 发布微信菜单
+ *
+ * @param appId 公众号
+ * @return R
+ */
+ @SysLog("发布微信菜单")
+ @PutMapping("/{appId}")
+ @PreAuthorize("@pms.hasPermission('mp_wxmenu_push')")
+ public R updateById(@PathVariable String appId) {
+ return wxMenuService.push(appId);
+ }
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/controller/WxPortalController.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/controller/WxPortalController.java
new file mode 100755
index 000000000..583f530d5
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/controller/WxPortalController.java
@@ -0,0 +1,123 @@
+package com.pig4cloud.pigx.mp.controller;
+
+import cn.hutool.core.util.StrUtil;
+import com.pig4cloud.pigx.common.core.constant.SecurityConstants;
+import com.pig4cloud.pigx.mp.config.WxMpConfiguration;
+import com.pig4cloud.pigx.mp.config.WxMpContextHolder;
+import lombok.extern.slf4j.Slf4j;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * @author Binary Wang
+ * @author lengleng
+ *
+ * 微信接入入口
+ */
+@Slf4j
+@RestController
+@RequestMapping("/{appId}/portal")
+public class WxPortalController {
+
+ /**
+ * 微信接入校验处理
+ *
+ * @param appId 多公众号标志位
+ * @param signature 微信签名
+ * @param timestamp 时间戳
+ * @param nonce 随机数
+ * @param echostr 随机字符串
+ * @return
+ */
+ @GetMapping(produces = "text/plain;charset=utf-8")
+ public String authGet(@PathVariable("appId") String appId,
+ @RequestParam(name = "signature", required = false) String signature,
+ @RequestParam(name = "timestamp", required = false) String timestamp,
+ @RequestParam(name = "nonce", required = false) String nonce,
+ @RequestParam(name = "echostr", required = false) String echostr) {
+
+ log.info("接收到来自微信服务器的认证消息：[{}, {}, {}, {}]", signature, timestamp, nonce, echostr);
+
+ if (StringUtils.isAnyBlank(signature, timestamp, nonce, echostr)) {
+ throw new IllegalArgumentException("请求参数非法，请核实!");
+ }
+
+ final WxMpService wxService = WxMpConfiguration.getMpServices().get(appId);
+
+ if (wxService == null) {
+ throw new IllegalArgumentException(String.format("未找到对应appid=[%d]的配置，请核实！", appId));
+ }
+
+ if (wxService.checkSignature(timestamp, nonce, signature)) {
+ return echostr;
+ }
+
+ return "非法请求";
+ }
+
+ /**
+ * 微信消息处理
+ *
+ * @param appId 多公众号标志位
+ * @param requestBody 请求报文体
+ * @param signature 微信签名
+ * @param encType 加签方式
+ * @param msgSignature 微信签名
+ * @param timestamp 时间戳
+ * @param nonce 随机数
+ * @return
+ */
+ @PostMapping(produces = "application/xml; charset=UTF-8")
+ public String post(@PathVariable("appId") String appId,
+ @RequestBody String requestBody,
+ @RequestParam("signature") String signature,
+ @RequestParam("timestamp") String timestamp,
+ @RequestParam("nonce") String nonce,
+ @RequestParam("openid") String openid,
+ @RequestParam(name = "encrypt_type", required = false) String encType,
+ @RequestParam(name = "msg_signature", required = false) String msgSignature) {
+
+ WxMpContextHolder.setAppId(appId);
+ final WxMpService wxService = WxMpConfiguration.getMpServices().get(appId);
+
+ log.info("接收微信请求：[openid=[{}], [signature=[{}], encType=[{}], msgSignature=[{}],"
+ + " timestamp=[{}], nonce=[{}], requestBody=[{}] ",
+ openid, signature, encType, msgSignature, timestamp, nonce, requestBody);
+
+ if (!wxService.checkSignature(timestamp, nonce, signature)) {
+ throw new IllegalArgumentException("非法请求，可能属于伪造的请求！");
+ }
+
+ String out = null;
+
+ // 明文模式
+ if (StrUtil.isBlank(encType)) {
+ WxMpXmlMessage inMessage = WxMpXmlMessage.fromXml(requestBody);
+ WxMpXmlOutMessage outMessage = WxMpConfiguration.getRouters().get(appId).route(inMessage);
+ if (outMessage != null) {
+ out = outMessage.toXml();
+ }
+ }
+
+ // aes加密模式
+ if (SecurityConstants.AES.equalsIgnoreCase(encType)) {
+ WxMpXmlMessage inMessage = WxMpXmlMessage.fromEncryptedXml(requestBody, wxService.getWxMpConfigStorage(),
+ timestamp, nonce, msgSignature);
+
+ log.debug("消息解密后内容为：{} ", inMessage.toString());
+
+ WxMpXmlOutMessage outMessage = WxMpConfiguration.getRouters().get(appId).route(inMessage);
+ if (outMessage != null) {
+ out = outMessage.toEncryptedXml(wxService.getWxMpConfigStorage());
+ }
+ }
+
+ log.debug("组装回复信息：{}", out);
+ WxMpContextHolder.clear();
+ return out;
+ }
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/controller/WxRedirectController.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/controller/WxRedirectController.java
new file mode 100755
index 000000000..e0c48c36b
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/controller/WxRedirectController.java
@@ -0,0 +1,37 @@
+package com.pig4cloud.pigx.mp.controller;
+
+import com.pig4cloud.pigx.mp.config.WxMpConfiguration;
+import me.chanjar.weixin.common.error.WxErrorException;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.bean.result.WxMpOAuth2AccessToken;
+import me.chanjar.weixin.mp.bean.result.WxMpUser;
+import org.springframework.stereotype.Controller;
+import org.springframework.ui.ModelMap;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+
+/**
+ * @author Edward
+ */
+@Controller
+@RequestMapping("/wx/redirect/{appid}")
+public class WxRedirectController {
+
+
+ @RequestMapping("/greet")
+ public String greetUser(@PathVariable String appid, @RequestParam String code, ModelMap map) {
+
+ WxMpService mpService = WxMpConfiguration.getMpServices().get(appid);
+
+ try {
+ WxMpOAuth2AccessToken accessToken = mpService.oauth2getAccessToken(code);
+ WxMpUser user = mpService.oauth2getUserInfo(accessToken, null);
+ map.put("user", user);
+ } catch (WxErrorException e) {
+ e.printStackTrace();
+ }
+
+ return "greet_user";
+ }
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/entity/WxAccount.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/entity/WxAccount.java
new file mode 100755
index 000000000..76b94ca73
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/entity/WxAccount.java
@@ -0,0 +1,96 @@
+/*
+ * Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the pig4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.pig4cloud.pigx.mp.entity;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableLogic;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.time.LocalDateTime;
+
+/**
+ * 公众号账户
+ *
+ * @author lengleng
+ * @date 2019-03-26 22:07:53
+ */
+@Data
+@TableName("t_wx_account")
+@EqualsAndHashCode(callSuper = true)
+public class WxAccount extends Model {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 主键
+ */
+ @TableId
+ private Integer id;
+ /**
+ * 公众号名称
+ */
+ private String name;
+ /**
+ * 公众号账户
+ */
+ private String account;
+ /**
+ * 公众号appid
+ */
+ private String appid;
+ /**
+ * 公众号密钥
+ */
+ private String appsecret;
+ /**
+ * 公众号url
+ */
+ private String url;
+ /**
+ * 公众号token
+ */
+ private String token;
+ /**
+ * 加密密钥
+ */
+ private String aeskey;
+ /**
+ * 二维码图片URL
+ */
+ private String qrUrl;
+ /**
+ * 创建时间
+ */
+ private LocalDateTime createTime;
+ /**
+ * 更新时间
+ */
+ private LocalDateTime updateTime;
+
+ /**
+ * 是否删除 -1：已删除 0：正常
+ */
+ @TableLogic
+ private String delFlag;
+
+ /**
+ * 租户
+ */
+ private Integer tenantId;
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/entity/WxAccountFans.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/entity/WxAccountFans.java
new file mode 100755
index 000000000..a6da434e1
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/entity/WxAccountFans.java
@@ -0,0 +1,116 @@
+/*
+ * Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the pig4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.pig4cloud.pigx.mp.entity;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableLogic;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.time.LocalDateTime;
+
+/**
+ * 微信公众号粉丝
+ *
+ * @author lengleng
+ * @date 2019-03-26 22:08:08
+ */
+@Data
+@TableName("t_wx_account_fans")
+@EqualsAndHashCode(callSuper = true)
+public class WxAccountFans extends Model {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 主键
+ */
+ @TableId
+ private Integer id;
+ /**
+ * 用户标识
+ */
+ private String openid;
+ /**
+ * 订阅状态，0未关注，1已关注
+ */
+ private String subscribeStatus;
+ /**
+ * 订阅时间
+ */
+ private LocalDateTime subscribeTime;
+ /**
+ * 昵称
+ */
+ private String nickname;
+ /**
+ * 性别，1男，2女，0未知
+ */
+ private String gender;
+ /**
+ * 语言
+ */
+ private String language;
+ /**
+ * 国家
+ */
+ private String country;
+ /**
+ * 省份
+ */
+ private String province;
+ /**
+ * 城市
+ */
+ private String city;
+ /**
+ * 头像地址
+ */
+ private String headimgUrl;
+ /**
+ * 备注
+ */
+ private String remark;
+ /**
+ * 微信公众号ID
+ */
+ private Integer wxAccountId;
+ /**
+ * 微信公众号appid
+ */
+ private String wxAccountAppid;
+
+ /**
+ * 微信公众号名
+ */
+ private String wxAccountName;
+ /**
+ * 创建时间
+ */
+ private LocalDateTime createTime;
+ /**
+ * 更新时间
+ */
+ private LocalDateTime updateTime;
+ /**
+ * 是否删除 -1：已删除 0：正常
+ */
+ @TableLogic
+ private String delFlag;
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/entity/WxFansMsg.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/entity/WxFansMsg.java
new file mode 100755
index 000000000..e892019c5
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/entity/WxFansMsg.java
@@ -0,0 +1,125 @@
+/*
+ * Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the pig4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.pig4cloud.pigx.mp.entity;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableLogic;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.time.LocalDateTime;
+
+/**
+ * 微信消息
+ *
+ * @author lengleng
+ * @date 2019-03-27 20:45:27
+ */
+@Data
+@TableName("t_wx_fans_msg")
+@EqualsAndHashCode(callSuper = true)
+public class WxFansMsg extends Model {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 主键
+ */
+ @TableId
+ private Integer id;
+ /**
+ * 用户标识
+ */
+ private String openid;
+ /**
+ * 昵称
+ */
+ private String nickname;
+ /**
+ * 头像地址
+ */
+ private String headimgUrl;
+ /**
+ * 微信账号ID
+ */
+ private Integer wxAccountId;
+
+ /**
+ * 微信公众号appid
+ */
+ private String wxAccountAppid;
+
+ /**
+ * 微信公众号名
+ */
+ private String wxAccountName;
+
+ /**
+ * 消息ID
+ */
+ private Long msgId;
+
+ /**
+ * 消息类型
+ */
+ private String msgType;
+ /**
+ * 内容
+ */
+ private String content;
+ /**
+ * 最近一条回复内容
+ */
+ private String resContent;
+ /**
+ * 是否已回复
+ */
+ private String isRes;
+ /**
+ * 微信素材ID
+ */
+ private String mediaId;
+ /**
+ * 微信图片URL
+ */
+ private String picUrl;
+ /**
+ * 本地图片路径
+ */
+ private String picPath;
+ /**
+ * 创建时间
+ */
+ private LocalDateTime createTime;
+ /**
+ * 更新时间
+ */
+ private LocalDateTime updateTime;
+
+ /**
+ * 是否删除 -1：已删除 0：正常
+ */
+ @TableLogic
+ private String delFlag;
+
+ /**
+ * 租户
+ */
+ private Integer tenantId;
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/entity/WxFansMsgRes.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/entity/WxFansMsgRes.java
new file mode 100755
index 000000000..31e853e91
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/entity/WxFansMsgRes.java
@@ -0,0 +1,69 @@
+/*
+ * Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the pig4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.pig4cloud.pigx.mp.entity;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.time.LocalDateTime;
+
+/**
+ * 微信粉丝消息回复表
+ *
+ * @author lengleng
+ * @date 2019-03-27 20:45:48
+ */
+@Data
+@TableName("t_wx_fans_msg_res")
+@EqualsAndHashCode(callSuper = true)
+public class WxFansMsgRes extends Model {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 主键
+ */
+ @TableId
+ private Integer id;
+ /**
+ * 粉丝消息ID
+ */
+ private Integer fansMsgId;
+ /**
+ * 回复内容
+ */
+ private String resContent;
+ /**
+ * 用户ID
+ */
+ private Integer userId;
+ /**
+ * 用户名
+ */
+ private String userName;
+ /**
+ * 创建时间
+ */
+ private LocalDateTime createTime;
+ /**
+ * 更新时间
+ */
+ private LocalDateTime updateTime;
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/entity/WxMpMenu.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/entity/WxMpMenu.java
new file mode 100755
index 000000000..97fbd79fc
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/entity/WxMpMenu.java
@@ -0,0 +1,85 @@
+/*
+ * Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the pig4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.pig4cloud.pigx.mp.entity;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableLogic;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.time.LocalDateTime;
+
+/**
+ * 微信菜单表
+ *
+ * @author lengleng
+ * @date 2019-03-27 20:45:18
+ */
+@Data
+@TableName("t_wx_menu")
+@EqualsAndHashCode(callSuper = true)
+public class WxMpMenu extends Model {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 主键
+ */
+ @TableId
+ private Integer id;
+
+ /**
+ * 菜单
+ */
+ private String menu;
+
+ /**
+ * 微信公众号ID
+ */
+ private Integer wxAccountId;
+ /**
+ * 微信公众号appid
+ */
+ private String wxAccountAppid;
+
+ /**
+ * 微信公众号名
+ */
+ private String wxAccountName;
+
+ /**
+ * 创建时间
+ */
+ private LocalDateTime createTime;
+ /**
+ * 更新时间
+ */
+ private LocalDateTime updateTime;
+
+ /**
+ * 是否删除 -1：已删除 0：正常
+ */
+ @TableLogic
+ private String delFlag;
+
+ /**
+ * 是否发布 0 未发布 1 已发布
+ */
+ private String pubFlag;
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/AbstractHandler.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/AbstractHandler.java
new file mode 100755
index 000000000..c59c54c4e
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/AbstractHandler.java
@@ -0,0 +1,9 @@
+package com.pig4cloud.pigx.mp.handler;
+
+import me.chanjar.weixin.mp.api.WxMpMessageHandler;
+
+/**
+ * @author Binary Wang(https://github.com/binarywang)
+ */
+public abstract class AbstractHandler implements WxMpMessageHandler {
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/KfSessionHandler.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/KfSessionHandler.java
new file mode 100755
index 000000000..a6792b40c
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/KfSessionHandler.java
@@ -0,0 +1,24 @@
+package com.pig4cloud.pigx.mp.handler;
+
+import me.chanjar.weixin.common.session.WxSessionManager;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+/**
+ * @author Binary Wang(https://github.com/binarywang)
+ */
+@Component
+public class KfSessionHandler extends AbstractHandler {
+
+ @Override
+ public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage,
+ Map context, WxMpService wxMpService,
+ WxSessionManager sessionManager) {
+ return null;
+ }
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/LocationHandler.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/LocationHandler.java
new file mode 100755
index 000000000..76c442ce0
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/LocationHandler.java
@@ -0,0 +1,34 @@
+package com.pig4cloud.pigx.mp.handler;
+
+import com.pig4cloud.pigx.mp.builder.TextBuilder;
+import lombok.extern.slf4j.Slf4j;
+import me.chanjar.weixin.common.session.WxSessionManager;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+/**
+ * @author Binary Wang(https://github.com/binarywang)
+ */
+@Slf4j
+@Component
+public class LocationHandler extends AbstractHandler {
+
+ @Override
+ public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage,
+ Map context, WxMpService wxMpService,
+ WxSessionManager sessionManager) {
+ //上报地理位置事件
+ log.info("上报地理位置，纬度 : {}，经度 : {}，精度 : {}",
+ wxMessage.getLatitude(), wxMessage.getLongitude(), wxMessage.getPrecision());
+
+ //TODO 可以将用户地理位置信息保存到本地数据库，以便以后使用
+
+ String content = "感谢反馈，您的的地理位置已收到！";
+ return new TextBuilder().build(content, wxMessage, null);
+ }
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/LogHandler.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/LogHandler.java
new file mode 100755
index 000000000..f5d65d103
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/LogHandler.java
@@ -0,0 +1,62 @@
+package com.pig4cloud.pigx.mp.handler;
+
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.pig4cloud.pigx.mp.entity.WxAccount;
+import com.pig4cloud.pigx.mp.entity.WxFansMsg;
+import com.pig4cloud.pigx.mp.service.WxAccountService;
+import com.pig4cloud.pigx.mp.service.WxFansMsgService;
+import lombok.AllArgsConstructor;
+import lombok.SneakyThrows;
+import lombok.extern.slf4j.Slf4j;
+import me.chanjar.weixin.common.session.WxSessionManager;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage;
+import me.chanjar.weixin.mp.bean.result.WxMpUser;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+/**
+ * @author lengleng
+ *
+ * 保存微信消息
+ */
+@Slf4j
+@Component
+@AllArgsConstructor
+public class LogHandler extends AbstractHandler {
+ private final WxFansMsgService wxFansMsgService;
+ private final WxAccountService wxAccountService;
+
+ @Override
+ @SneakyThrows
+ public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage,
+ Map context, WxMpService wxMpService,
+ WxSessionManager sessionManager) {
+ log.debug("接收到请求消息，内容：{}", wxMessage.getContent());
+
+ WxAccount wxAccount = wxAccountService.getOne(Wrappers.lambdaQuery()
+ .eq(WxAccount::getAccount, wxMessage.getToUser()));
+
+
+ WxMpUser wxmpUser = wxMpService.getUserService()
+ .userInfo(wxMessage.getFromUser());
+
+ WxFansMsg wxFansMsg = new WxFansMsg();
+ wxFansMsg.setOpenid(wxmpUser.getOpenId());
+ wxFansMsg.setNickname(wxmpUser.getNickname());
+ wxFansMsg.setHeadimgUrl(wxmpUser.getHeadImgUrl());
+ wxFansMsg.setWxAccountId(wxAccount.getId());
+ wxFansMsg.setWxAccountName(wxAccount.getName());
+ wxFansMsg.setWxAccountAppid(wxAccount.getAppid());
+ wxFansMsg.setMsgType(wxMessage.getMsgType());
+ wxFansMsg.setMsgId(wxMessage.getMsgId());
+ wxFansMsg.setContent(wxMessage.getContent());
+ wxFansMsg.setTenantId(wxAccount.getTenantId());
+ wxFansMsgService.save(wxFansMsg);
+
+ log.debug("保存微信用户信息成功 {}", wxFansMsg);
+ return null;
+ }
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/MenuHandler.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/MenuHandler.java
new file mode 100755
index 000000000..630c33535
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/MenuHandler.java
@@ -0,0 +1,36 @@
+package com.pig4cloud.pigx.mp.handler;
+
+import me.chanjar.weixin.common.session.WxSessionManager;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+import static me.chanjar.weixin.common.api.WxConsts.MenuButtonType;
+
+/**
+ * @author Binary Wang(https://github.com/binarywang)
+ */
+@Component
+public class MenuHandler extends AbstractHandler {
+
+ @Override
+ public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage,
+ Map context, WxMpService weixinService,
+ WxSessionManager sessionManager) {
+
+ String msg = String.format("type:%s, event:%s, key:%s",
+ wxMessage.getMsgType(), wxMessage.getEvent(),
+ wxMessage.getEventKey());
+ if (MenuButtonType.VIEW.equals(wxMessage.getEvent())) {
+ return null;
+ }
+
+ return WxMpXmlOutMessage.TEXT().content(msg)
+ .fromUser(wxMessage.getToUser()).toUser(wxMessage.getFromUser())
+ .build();
+ }
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/MsgHandler.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/MsgHandler.java
new file mode 100755
index 000000000..21feece52
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/MsgHandler.java
@@ -0,0 +1,49 @@
+package com.pig4cloud.pigx.mp.handler;
+
+import com.pig4cloud.pigx.mp.builder.TextBuilder;
+import lombok.SneakyThrows;
+import me.chanjar.weixin.common.session.WxSessionManager;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+import static me.chanjar.weixin.common.api.WxConsts.XmlMsgType;
+
+/**
+ * @author Binary Wang(https://github.com/binarywang)
+ */
+@Component
+public class MsgHandler extends AbstractHandler {
+
+ @Override
+ @SneakyThrows
+ public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage,
+ Map context, WxMpService weixinService,
+ WxSessionManager sessionManager) {
+
+ if (!wxMessage.getMsgType().equals(XmlMsgType.EVENT)) {
+ //TODO 可以选择将消息保存到本地
+ }
+
+ //当用户输入关键词如“你好”，“客服”等，并且有客服在线时，把消息转发给在线客服
+ if (StringUtils.startsWithAny(wxMessage.getContent(), "你好", "客服")
+ && weixinService.getKefuService().kfOnlineList()
+ .getKfOnlineList().size() > 0) {
+ return WxMpXmlOutMessage.TRANSFER_CUSTOMER_SERVICE()
+ .fromUser(wxMessage.getToUser())
+ .toUser(wxMessage.getFromUser()).build();
+ }
+
+
+ //TODO 组装回复消息
+ String content = "收到信息内容：" + wxMessage.getContent();
+
+ return new TextBuilder().build(content, wxMessage, weixinService);
+
+ }
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/NullHandler.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/NullHandler.java
new file mode 100755
index 000000000..5f961b871
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/NullHandler.java
@@ -0,0 +1,24 @@
+package com.pig4cloud.pigx.mp.handler;
+
+import me.chanjar.weixin.common.session.WxSessionManager;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+/**
+ * @author Binary Wang(https://github.com/binarywang)
+ */
+@Component
+public class NullHandler extends AbstractHandler {
+
+ @Override
+ public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage,
+ Map context, WxMpService wxMpService,
+ WxSessionManager sessionManager) {
+ return null;
+ }
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/ScanHandler.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/ScanHandler.java
new file mode 100755
index 000000000..0173764f6
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/ScanHandler.java
@@ -0,0 +1,24 @@
+package com.pig4cloud.pigx.mp.handler;
+
+import me.chanjar.weixin.common.error.WxErrorException;
+import me.chanjar.weixin.common.session.WxSessionManager;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+/**
+ * @author Binary Wang(https://github.com/binarywang)
+ */
+@Component
+public class ScanHandler extends AbstractHandler {
+
+ @Override
+ public WxMpXmlOutMessage handle(WxMpXmlMessage wxMpXmlMessage, Map map,
+ WxMpService wxMpService, WxSessionManager wxSessionManager) throws WxErrorException {
+ // 扫码事件处理
+ return null;
+ }
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/StoreCheckNotifyHandler.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/StoreCheckNotifyHandler.java
new file mode 100755
index 000000000..1d75ea153
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/StoreCheckNotifyHandler.java
@@ -0,0 +1,27 @@
+package com.pig4cloud.pigx.mp.handler;
+
+import me.chanjar.weixin.common.session.WxSessionManager;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+/**
+ * 门店审核事件处理
+ *
+ * @author Binary Wang(https://github.com/binarywang)
+ */
+@Component
+public class StoreCheckNotifyHandler extends AbstractHandler {
+
+ @Override
+ public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage,
+ Map context, WxMpService wxMpService,
+ WxSessionManager sessionManager) {
+ // TODO 处理门店审核事件
+ return null;
+ }
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/SubscribeHandler.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/SubscribeHandler.java
new file mode 100755
index 000000000..a90c174d3
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/SubscribeHandler.java
@@ -0,0 +1,72 @@
+package com.pig4cloud.pigx.mp.handler;
+
+import com.pig4cloud.pigx.mp.builder.TextBuilder;
+import lombok.extern.slf4j.Slf4j;
+import me.chanjar.weixin.common.error.WxErrorException;
+import me.chanjar.weixin.common.session.WxSessionManager;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage;
+import me.chanjar.weixin.mp.bean.result.WxMpUser;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+/**
+ * @author Binary Wang(https://github.com/binarywang)
+ */
+@Slf4j
+@Component
+public class SubscribeHandler extends AbstractHandler {
+
+ @Override
+ public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage,
+ Map context, WxMpService weixinService,
+ WxSessionManager sessionManager) throws WxErrorException {
+
+ log.info("新关注用户 OPENID: " + wxMessage.getFromUser());
+
+ // 获取微信用户基本信息
+ try {
+ WxMpUser userWxInfo = weixinService.getUserService()
+ .userInfo(wxMessage.getFromUser(), null);
+ if (userWxInfo != null) {
+ // TODO 可以添加关注用户到本地数据库
+ }
+ } catch (WxErrorException e) {
+ if (e.getError().getErrorCode() == 48001) {
+ log.info("该公众号没有获取用户信息权限！");
+ }
+ }
+
+
+ WxMpXmlOutMessage responseResult = null;
+ try {
+ responseResult = this.handleSpecial(wxMessage);
+ } catch (Exception e) {
+ log.error(e.getMessage(), e);
+ }
+
+ if (responseResult != null) {
+ return responseResult;
+ }
+
+ try {
+ return new TextBuilder().build("感谢关注", wxMessage, weixinService);
+ } catch (Exception e) {
+ log.error(e.getMessage(), e);
+ }
+
+ return null;
+ }
+
+ /**
+ * 处理特殊请求，比如如果是扫码进来的，可以做相应处理
+ */
+ private WxMpXmlOutMessage handleSpecial(WxMpXmlMessage wxMessage)
+ throws Exception {
+ //TODO
+ return null;
+ }
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/UnsubscribeHandler.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/UnsubscribeHandler.java
new file mode 100755
index 000000000..7dde34f32
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/handler/UnsubscribeHandler.java
@@ -0,0 +1,29 @@
+package com.pig4cloud.pigx.mp.handler;
+
+import lombok.extern.slf4j.Slf4j;
+import me.chanjar.weixin.common.session.WxSessionManager;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+/**
+ * @author Binary Wang(https://github.com/binarywang)
+ */
+@Slf4j
+@Component
+public class UnsubscribeHandler extends AbstractHandler {
+
+ @Override
+ public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage,
+ Map context, WxMpService wxMpService,
+ WxSessionManager sessionManager) {
+ String openId = wxMessage.getFromUser();
+ log.info("取消关注用户 OPENID: " + openId);
+ // TODO 可以更新本地数据库为取消关注状态
+ return null;
+ }
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/mapper/WxAccountFansMapper.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/mapper/WxAccountFansMapper.java
new file mode 100755
index 000000000..010329ea7
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/mapper/WxAccountFansMapper.java
@@ -0,0 +1,30 @@
+/*
+ * Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the pig4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.pig4cloud.pigx.mp.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.pig4cloud.pigx.mp.entity.WxAccountFans;
+
+/**
+ * 微信公众号粉丝
+ *
+ * @author lengleng
+ * @date 2019-03-26 22:08:08
+ */
+public interface WxAccountFansMapper extends BaseMapper {
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/mapper/WxAccountMapper.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/mapper/WxAccountMapper.java
new file mode 100755
index 000000000..899c95124
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/mapper/WxAccountMapper.java
@@ -0,0 +1,30 @@
+/*
+ * Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the pig4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.pig4cloud.pigx.mp.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.pig4cloud.pigx.mp.entity.WxAccount;
+
+/**
+ * 公众号账户
+ *
+ * @author lengleng
+ * @date 2019-03-26 22:07:53
+ */
+public interface WxAccountMapper extends BaseMapper {
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/mapper/WxFansMsgMapper.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/mapper/WxFansMsgMapper.java
new file mode 100755
index 000000000..2719ed380
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/mapper/WxFansMsgMapper.java
@@ -0,0 +1,30 @@
+/*
+ * Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the pig4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.pig4cloud.pigx.mp.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.pig4cloud.pigx.mp.entity.WxFansMsg;
+
+/**
+ * lengleng
+ *
+ * @author pigx code generator
+ * @date 2019-03-27 20:45:27
+ */
+public interface WxFansMsgMapper extends BaseMapper {
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/mapper/WxFansMsgResMapper.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/mapper/WxFansMsgResMapper.java
new file mode 100755
index 000000000..c6f790868
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/mapper/WxFansMsgResMapper.java
@@ -0,0 +1,30 @@
+/*
+ * Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the pig4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.pig4cloud.pigx.mp.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.pig4cloud.pigx.mp.entity.WxFansMsgRes;
+
+/**
+ * lengleng
+ *
+ * @author pigx code generator
+ * @date 2019-03-27 20:45:48
+ */
+public interface WxFansMsgResMapper extends BaseMapper {
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/mapper/WxMenuMapper.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/mapper/WxMenuMapper.java
new file mode 100755
index 000000000..7013f4fbd
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/mapper/WxMenuMapper.java
@@ -0,0 +1,30 @@
+/*
+ * Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the pig4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.pig4cloud.pigx.mp.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.pig4cloud.pigx.mp.entity.WxMpMenu;
+
+/**
+ * lengleng
+ *
+ * @author pigx code generator
+ * @date 2019-03-27 20:45:18
+ */
+public interface WxMenuMapper extends BaseMapper {
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/service/WxAccountFansService.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/service/WxAccountFansService.java
new file mode 100755
index 000000000..5094ba7dd
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/service/WxAccountFansService.java
@@ -0,0 +1,37 @@
+/*
+ * Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the pig4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.pig4cloud.pigx.mp.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.pig4cloud.pigx.mp.entity.WxAccountFans;
+
+/**
+ * 微信公众号粉丝
+ *
+ * @author lengleng
+ * @date 2019-03-26 22:08:08
+ */
+public interface WxAccountFansService extends IService {
+
+ /**
+ * 同步指定公众号粉丝
+ *
+ * @param appId
+ * @return
+ */
+ Boolean syncAccountFans(String appId);
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/service/WxAccountService.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/service/WxAccountService.java
new file mode 100755
index 000000000..ab59a9601
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/service/WxAccountService.java
@@ -0,0 +1,47 @@
+/*
+ * Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the pig4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.pig4cloud.pigx.mp.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.pig4cloud.pigx.common.core.util.R;
+import com.pig4cloud.pigx.mp.entity.WxAccount;
+
+/**
+ * 公众号账户
+ *
+ * @author lengleng
+ * @date 2019-03-26 22:07:53
+ */
+public interface WxAccountService extends IService {
+
+ /**
+ * 生成公众号二维码
+ *
+ * @param appId
+ * @return
+ */
+ R generateQr(String appId);
+
+ /**
+ * 获取公众号统计数据
+ *
+ * @param appId
+ * @param interval
+ * @return
+ */
+ R statistics(String appId, String interval);
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/service/WxFansMsgResService.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/service/WxFansMsgResService.java
new file mode 100755
index 000000000..6b28b69fc
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/service/WxFansMsgResService.java
@@ -0,0 +1,38 @@
+/*
+ * Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the pig4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.pig4cloud.pigx.mp.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.pig4cloud.pigx.common.core.util.R;
+import com.pig4cloud.pigx.mp.entity.WxFansMsgRes;
+
+/**
+ * 微信消息回复业务
+ *
+ * @author lengleng
+ * @date 2019-03-27 20:45:48
+ */
+public interface WxFansMsgResService extends IService {
+
+ /**
+ * 保存并发送回复
+ *
+ * @param wxFansMsgRes
+ * @return
+ */
+ R saveAndSend(WxFansMsgRes wxFansMsgRes);
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/service/WxFansMsgService.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/service/WxFansMsgService.java
new file mode 100755
index 000000000..b3aa4b860
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/service/WxFansMsgService.java
@@ -0,0 +1,30 @@
+/*
+ * Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the pig4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.pig4cloud.pigx.mp.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.pig4cloud.pigx.mp.entity.WxFansMsg;
+
+/**
+ * 微信消息业务
+ *
+ * @author lengleng
+ * @date 2019-03-27 20:45:27
+ */
+public interface WxFansMsgService extends IService {
+
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/service/WxMenuService.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/service/WxMenuService.java
new file mode 100755
index 000000000..967ac499e
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/service/WxMenuService.java
@@ -0,0 +1,56 @@
+/*
+ * Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the pig4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.pig4cloud.pigx.mp.service;
+
+import cn.hutool.json.JSONObject;
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.pig4cloud.pigx.common.core.util.R;
+import com.pig4cloud.pigx.mp.entity.WxMpMenu;
+
+/**
+ * 微信菜单业务
+ *
+ * @author lengleng
+ * @date 2019-03-27 20:45:18
+ */
+public interface WxMenuService extends IService {
+
+ /**
+ * 新增微信公众号按钮
+ *
+ * @param wxMenus json
+ * @param appId 公众号信息
+ * @return
+ */
+ Boolean save(JSONObject wxMenus, String appId);
+
+ /**
+ * 发布到微信
+ *
+ * @param appId 公众号信息
+ * @return
+ */
+ R push(String appId);
+
+ /**
+ * 通过appid 查询菜单信息
+ *
+ * @param appId
+ * @return
+ */
+ R getByAppId(String appId);
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/service/impl/WxAccountFansServiceImpl.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/service/impl/WxAccountFansServiceImpl.java
new file mode 100755
index 000000000..494b7daf9
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/service/impl/WxAccountFansServiceImpl.java
@@ -0,0 +1,139 @@
+/*
+ * Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the pig4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.pig4cloud.pigx.mp.service.impl;
+
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.pig4cloud.pigx.mp.config.WxMpConfiguration;
+import com.pig4cloud.pigx.mp.entity.WxAccount;
+import com.pig4cloud.pigx.mp.entity.WxAccountFans;
+import com.pig4cloud.pigx.mp.mapper.WxAccountFansMapper;
+import com.pig4cloud.pigx.mp.mapper.WxAccountMapper;
+import com.pig4cloud.pigx.mp.service.WxAccountFansService;
+import lombok.AllArgsConstructor;
+import lombok.SneakyThrows;
+import lombok.extern.slf4j.Slf4j;
+import me.chanjar.weixin.common.error.WxErrorException;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.api.WxMpUserService;
+import me.chanjar.weixin.mp.bean.result.WxMpUserList;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.time.Instant;
+import java.time.LocalDateTime;
+import java.time.ZoneId;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @author lengleng
+ * @date 2019-03-26 22:08:08
+ *
+ * 微信公众号粉丝
+ */
+@Slf4j
+@Service
+@AllArgsConstructor
+public class WxAccountFansServiceImpl extends ServiceImpl implements WxAccountFansService {
+ private static final int SIZE = 100;
+ private final WxAccountMapper wxAccountMapper;
+
+ /**
+ * 获取公众号粉丝，生产建议异步
+ *
+ * @param appId
+ * @return
+ */
+ @Async
+ @Override
+ @SneakyThrows
+ @Transactional(rollbackFor = Exception.class)
+ public Boolean syncAccountFans(String appId) {
+ WxAccount wxAccount = wxAccountMapper
+ .selectOne(Wrappers.query().lambda()
+ .eq(WxAccount::getAppid, appId));
+
+ WxMpService wxMpService = WxMpConfiguration.getMpServices().get(appId);
+ WxMpUserService wxMpUserService = wxMpService.getUserService();
+ fetchUser(null, wxAccount, wxMpUserService);
+ return Boolean.TRUE;
+ }
+
+ /**
+ * 获取微信用户
+ *
+ * @param nextOpenid
+ * @param wxAccount
+ * @param wxMpUserService
+ * @throws WxErrorException
+ */
+ private void fetchUser(String nextOpenid, WxAccount wxAccount, WxMpUserService wxMpUserService) throws WxErrorException {
+ WxMpUserList wxMpUserList = wxMpUserService.userList(nextOpenid);
+
+ // openId 分组 每组 100个 openid
+ CollUtil.split(wxMpUserList.getOpenids(), SIZE)
+ .stream().filter(CollUtil::isNotEmpty)
+ .forEach(openIdList -> {
+ log.info("开始批量获取用户信息 {}", openIdList);
+ List wxAccountFansList = new ArrayList<>();
+ try {
+ wxMpUserService.userInfoList(openIdList).forEach(wxMpUser -> {
+ WxAccountFans wxAccountFans = baseMapper
+ .selectOne(Wrappers.query().lambda()
+ .eq(WxAccountFans::getOpenid, wxMpUser.getOpenId()));
+ // 为空初始化一个新的对象
+ if (wxAccountFans == null) {
+ wxAccountFans = new WxAccountFans();
+ }
+
+ wxAccountFans.setOpenid(wxMpUser.getOpenId());
+ wxAccountFans.setSubscribeStatus(wxMpUser.getSubscribe() ? "1" : "0");
+ wxAccountFans.setSubscribeTime(LocalDateTime
+ .ofInstant(Instant.ofEpochMilli(wxMpUser.getSubscribeTime() * 1000L)
+ , ZoneId.systemDefault()));
+ wxAccountFans.setNickname(wxMpUser.getNickname());
+ wxAccountFans.setGender(String.valueOf(wxMpUser.getSex()));
+ wxAccountFans.setLanguage(wxMpUser.getLanguage());
+ wxAccountFans.setCountry(wxMpUser.getCountry());
+ wxAccountFans.setProvince(wxMpUser.getProvince());
+ wxAccountFans.setCity(wxMpUser.getCity());
+ wxAccountFans.setHeadimgUrl(wxMpUser.getHeadImgUrl());
+ wxAccountFans.setRemark(wxMpUser.getRemark());
+ wxAccountFans.setWxAccountId(wxAccount.getId());
+ wxAccountFans.setWxAccountAppid(wxAccount.getAppid());
+ wxAccountFans.setWxAccountName(wxAccount.getName());
+ wxAccountFansList.add(wxAccountFans);
+ });
+ this.saveOrUpdateBatch(wxAccountFansList);
+ log.info("批量插入用户信息完成 {}", openIdList);
+ } catch (WxErrorException e) {
+ log.error("批量同步粉丝失败", e);
+ }
+ });
+
+ // 如果nextOpenId 不为空，则继续获取
+ if (StrUtil.isNotBlank(wxMpUserList.getNextOpenid())) {
+ fetchUser(wxMpUserList.getNextOpenid(), wxAccount, wxMpUserService);
+ }
+
+ log.info("批量同步微信用户信息完成");
+ }
+}
diff --git a/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/service/impl/WxAccountServiceImpl.java b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/service/impl/WxAccountServiceImpl.java
new file mode 100755
index 000000000..1f9b6bbb6
--- /dev/null
+++ b/pigx-visual/pigx-mp-manager/src/main/java/com/pig4cloud/pigx/mp/service/impl/WxAccountServiceImpl.java
@@ -0,0 +1,136 @@
+/*
+ * Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the pig4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.pig4cloud.pigx.mp.service.impl;
+
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.pig4cloud.pigx.common.core.constant.CommonConstants;
+import com.pig4cloud.pigx.common.core.util.R;
+import com.pig4cloud.pigx.mp.config.WxMpConfiguration;
+import com.pig4cloud.pigx.mp.entity.WxAccount;
+import com.pig4cloud.pigx.mp.mapper.WxAccountMapper;
+import com.pig4cloud.pigx.mp.service.WxAccountService;
+import lombok.extern.slf4j.Slf4j;
+import me.chanjar.weixin.common.error.WxErrorException;
+import me.chanjar.weixin.mp.api.WxMpDataCubeService;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.bean.datacube.WxDataCubeArticleResult;
+import me.chanjar.weixin.mp.bean.datacube.WxDataCubeInterfaceResult;
+import me.chanjar.weixin.mp.bean.datacube.WxDataCubeMsgResult;
+import me.chanjar.weixin.mp.bean.datacube.WxDataCubeUserCumulate;
+import me.chanjar.weixin.mp.bean.result.WxMpQrCodeTicket;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ * 公众号账户
+ *
+ * @author lengleng
+ * @date 2019-03-26 22:07:53
+ */
+@Slf4j
+@Service
+public class WxAccountServiceImpl extends ServiceImpl implements WxAccountService {
+
+ /**
+ * 生成公众号二维码
+ *
+ * @param appId
+ * @return
+ */
+
+ @Override
+ public R generateQr(String appId) {
+ WxMpService wxMpService = WxMpConfiguration.getMpServices().get(appId);
+ try {
+ WxMpQrCodeTicket ticket = wxMpService.getQrcodeService().qrCodeCreateLastTicket(1);
+ String url = wxMpService.getQrcodeService().qrCodePictureUrl(ticket.getTicket());
+
+ WxAccount wxAccount = baseMapper
+ .selectOne(Wrappers.query().lambda()
+ .eq(WxAccount::getAppid, appId));
+ wxAccount.setQrUrl(url);
+ baseMapper.updateById(wxAccount);
+ } catch (WxErrorException e) {
+ log.error(" 获取公众号二维码失败", e);
+ return R.builder().code(CommonConstants.FAIL).msg("更新公众号二维码失败").build();
+ }
+
+ return R.builder().build();
+ }
+
+ /**
+ * 获取公众号统计数据
+ *
+ * @param appId 公众号信息
+ * @param interval 时间间隔
+ * @return
+ */
+ @Override
+ public R statistics(String appId, String interval) {
+ String[] split = interval.split(StrUtil.DASHED);
+ Date start = new Date(Long.parseLong(split[0]));
+ Date end = new Date(Long.parseLong(split[1]));
+
+ WxMpService wxMpService = WxMpConfiguration.getMpServices().get(appId);
+ WxMpDataCubeService cubeService = wxMpService.getDataCubeService();
+
+ List> result = new ArrayList<>();
+ try {
+ // 获取累计用户数据
+ List