From a17aa1f87fd7e810951ea4a82f8521bc3e0a586f Mon Sep 17 00:00:00 2001 From: liyj <1617420630@qq.com> Date: Thu, 18 Sep 2025 16:46:52 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E5=B0=8F=E7=A8=8B=E5=BA=8F?= =?UTF-8?q?=E6=B6=88=E6=81=AF=E8=AE=A2=E9=98=85=E6=A8=A1=E6=9D=BF=E5=8A=9F?= =?UTF-8?q?=E8=83=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../modules/message/ShopMessageTemplate.java | 5 +- .../modules/wechat/ShopWechatTplmsg.java | 5 +- .../admin/ShopMessageTemplateController.java | 12 ++ .../ShopWechatTplmsgMolbieController.java | 63 ++++++++++ .../service/ShopMessageTemplateService.java | 2 + .../impl/ShopMessageTemplateServiceImpl.java | 110 ++++++++++++++++++ .../mall/shop/message/vo/WxXcxMsgPushVo.java | 55 +++++++++ sql/shop/dev/20250918_ddl.sql | 1 + sql/shop/dev/20250918_dml.sql | 3 + 9 files changed, 253 insertions(+), 3 deletions(-) create mode 100644 mall-shop/src/main/java/com/suisung/mall/shop/message/controller/mobile/ShopWechatTplmsgMolbieController.java create mode 100644 mall-shop/src/main/java/com/suisung/mall/shop/message/vo/WxXcxMsgPushVo.java create mode 100644 sql/shop/dev/20250918_ddl.sql create mode 100644 sql/shop/dev/20250918_dml.sql diff --git a/mall-common/src/main/java/com/suisung/mall/common/modules/message/ShopMessageTemplate.java b/mall-common/src/main/java/com/suisung/mall/common/modules/message/ShopMessageTemplate.java index a0568ac6..b9baf3ec 100644 --- a/mall-common/src/main/java/com/suisung/mall/common/modules/message/ShopMessageTemplate.java +++ b/mall-common/src/main/java/com/suisung/mall/common/modules/message/ShopMessageTemplate.java @@ -1,6 +1,7 @@ package com.suisung.mall.common.modules.message; import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; import io.swagger.annotations.ApiModel; @@ -95,5 +96,7 @@ public class ShopMessageTemplate implements Serializable { @ApiModelProperty(value = "华为签名管理-通道号") private String message_tpl_sender; - +// @ApiModelProperty(value = "微信通知(BOOL):0-禁用;1-启用") +// @TableField(exist = false) +// private Integer message_wechatxcx_enable; } diff --git a/mall-common/src/main/java/com/suisung/mall/common/modules/wechat/ShopWechatTplmsg.java b/mall-common/src/main/java/com/suisung/mall/common/modules/wechat/ShopWechatTplmsg.java index a963ee67..ba6db37c 100644 --- a/mall-common/src/main/java/com/suisung/mall/common/modules/wechat/ShopWechatTplmsg.java +++ b/mall-common/src/main/java/com/suisung/mall/common/modules/wechat/ShopWechatTplmsg.java @@ -35,7 +35,7 @@ public class ShopWechatTplmsg implements Serializable { @ApiModelProperty(value = "模版标题") private String tplmsg_title; - @ApiModelProperty(value = "模版类型(LIST):1-订单提醒; 2-支付提醒;3-发货提醒") + @ApiModelProperty(value = "模版类型(LIST):1-订单提醒; 2-支付提醒;3-发货提醒;4-活动通知") private Integer tplmsg_type_id; @ApiModelProperty(value = "微信消息模板标题") @@ -65,5 +65,6 @@ public class ShopWechatTplmsg implements Serializable { @ApiModelProperty(value = "消息模板id:关联消息模板") private String message_id; - + @ApiModelProperty(value = "微信公众号或者小程序跳转路径") + private String link_url; } diff --git a/mall-shop/src/main/java/com/suisung/mall/shop/message/controller/admin/ShopMessageTemplateController.java b/mall-shop/src/main/java/com/suisung/mall/shop/message/controller/admin/ShopMessageTemplateController.java index ebe572fd..65c65e31 100644 --- a/mall-shop/src/main/java/com/suisung/mall/shop/message/controller/admin/ShopMessageTemplateController.java +++ b/mall-shop/src/main/java/com/suisung/mall/shop/message/controller/admin/ShopMessageTemplateController.java @@ -91,5 +91,17 @@ public class ShopMessageTemplateController extends BaseControllerImpl { return CommonResult.success(shopMessageTemplateService.remove(message_id)); } + + /** + * 发送消息推送 + * @return + */ + @ApiOperation(value = "消息模板表-编辑", notes = "消息模板表-编辑") + @RequestMapping(value = "/sendToXcxUserMessage", method = RequestMethod.POST) + public CommonResult sendToXcxUserMessage(@RequestParam(name = "userId") Integer userId) { + return shopMessageTemplateService.sendToXcxUserMessage(userId); + } + + } diff --git a/mall-shop/src/main/java/com/suisung/mall/shop/message/controller/mobile/ShopWechatTplmsgMolbieController.java b/mall-shop/src/main/java/com/suisung/mall/shop/message/controller/mobile/ShopWechatTplmsgMolbieController.java new file mode 100644 index 00000000..f7fac85f --- /dev/null +++ b/mall-shop/src/main/java/com/suisung/mall/shop/message/controller/mobile/ShopWechatTplmsgMolbieController.java @@ -0,0 +1,63 @@ +package com.suisung.mall.shop.message.controller.mobile; + +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.suisung.mall.common.api.CommonResult; +import com.suisung.mall.common.domain.UserDto; +import com.suisung.mall.common.exception.ApiUserException; +import com.suisung.mall.common.modules.wechat.ShopWechatTplmsg; +import com.suisung.mall.common.service.impl.BaseControllerImpl; +import com.suisung.mall.common.utils.ContextUtil; +import com.suisung.mall.common.utils.I18nUtil; +import com.suisung.mall.shop.wechat.service.ShopWechatTplmsgService; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestMethod; +import org.springframework.web.bind.annotation.RestController; + +import java.util.ArrayList; +import java.util.List; + +/** + *

+ * 消息模板表 前端控制器 + *

+ * + * @author Xinze + * @since 2021-08-17 + */ +@Api(tags = "消息模板表") +@Slf4j +@RestController +@RequestMapping("/mobile/shop/shop-wechat-template") +public class ShopWechatTplmsgMolbieController extends BaseControllerImpl { + + @Autowired + private ShopWechatTplmsgService shopWechatTplmsgService; + + /** + * 小程序模板列表查询 + * @return + */ + @ApiOperation(value = "小程序模板列表查询", notes = "小程序模板列表查询") + @RequestMapping(value = "/xcxTplmList", method = RequestMethod.GET) + public CommonResult getWxXcxTplmList() { + UserDto user = ContextUtil.getCurrentUser(); + if (user == null) { + throw new ApiUserException(I18nUtil._("用户信息异常！")); + } + QueryWrapper wechatTplmsgQueryWrapper = new QueryWrapper<>(); + wechatTplmsgQueryWrapper.select("tplmsg_tpl_id"); + wechatTplmsgQueryWrapper.eq("tplmsg_type_id", 4); + List shopWechatTplmsgList= shopWechatTplmsgService.list(wechatTplmsgQueryWrapper); + List tempIdList = new ArrayList<>(); + shopWechatTplmsgList.forEach(shopWechatTplmsg -> { + tempIdList.add(shopWechatTplmsg.getTplmsg_tpl_id()); + }); + return CommonResult.success(tempIdList); + } + +} + diff --git a/mall-shop/src/main/java/com/suisung/mall/shop/message/service/ShopMessageTemplateService.java b/mall-shop/src/main/java/com/suisung/mall/shop/message/service/ShopMessageTemplateService.java index 26fea0cf..ddecfb2f 100644 --- a/mall-shop/src/main/java/com/suisung/mall/shop/message/service/ShopMessageTemplateService.java +++ b/mall-shop/src/main/java/com/suisung/mall/shop/message/service/ShopMessageTemplateService.java @@ -1,5 +1,6 @@ package com.suisung.mall.shop.message.service; +import com.suisung.mall.common.api.CommonResult; import com.suisung.mall.common.modules.message.ShopMessageTemplate; import com.suisung.mall.common.modules.wechat.ShopWechatTplmsg; import com.suisung.mall.core.web.service.IBaseService; @@ -43,4 +44,5 @@ public interface ShopMessageTemplateService extends IBaseService mobiles, String tmplCode, Map tmplParams); + CommonResult sendToXcxUserMessage(Integer user_id); } diff --git a/mall-shop/src/main/java/com/suisung/mall/shop/message/service/impl/ShopMessageTemplateServiceImpl.java b/mall-shop/src/main/java/com/suisung/mall/shop/message/service/impl/ShopMessageTemplateServiceImpl.java index 514ec790..b46b35e9 100644 --- a/mall-shop/src/main/java/com/suisung/mall/shop/message/service/impl/ShopMessageTemplateServiceImpl.java +++ b/mall-shop/src/main/java/com/suisung/mall/shop/message/service/impl/ShopMessageTemplateServiceImpl.java @@ -16,6 +16,7 @@ import com.aliyuncs.exceptions.ClientException; import com.aliyuncs.profile.DefaultProfile; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.suisung.mall.common.api.BindCode; +import com.suisung.mall.common.api.CommonResult; import com.suisung.mall.common.constant.CommonConstant; import com.suisung.mall.common.exception.ApiException; import com.suisung.mall.common.feignService.AccountService; @@ -40,6 +41,7 @@ import com.suisung.mall.shop.components.push.GeTuiUtil; import com.suisung.mall.shop.message.mapper.ShopMessageTemplateMapper; import com.suisung.mall.shop.message.service.ShopMessageTemplateService; import com.suisung.mall.shop.message.vo.WxTelMsgPushVo; +import com.suisung.mall.shop.message.vo.WxXcxMsgPushVo; import com.suisung.mall.shop.store.service.ShopStoreBaseService; import com.suisung.mall.shop.wechat.service.ShopWechatTplmsgService; import lombok.extern.slf4j.Slf4j; @@ -51,6 +53,8 @@ import org.springframework.scheduling.annotation.EnableAsync; import org.springframework.stereotype.Service; import java.text.SimpleDateFormat; +import java.time.LocalDateTime; +import java.time.format.DateTimeFormatter; import java.util.Date; import java.util.HashMap; import java.util.List; @@ -261,6 +265,7 @@ public class ShopMessageTemplateServiceImpl extends BaseServiceImpl 0 && !user_setting.isEmpty() && activeProfile.equals("prod")) { @@ -663,4 +668,109 @@ public class ShopMessageTemplateServiceImpl extends BaseServiceImpl queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("tplmsg_id", 1022);//todo 后期改为动态 + ShopWechatTplmsg wechatTplmsg = shopWechatTplmsgService.getOne(queryWrapper); + ShopStoreBase shopStoreBase= shopStoreBaseService.get(wechatTplmsg.getStore_id()); + args.put("storeName", shopStoreBase.getStore_name()); + if (wechatTplmsg != null) { + String wechatTplData = getXcxWechatTplData(open_id, wechatTplmsg, args); + log.info(wechatTplData); + String result = WxHttpUtil.request(WxHttpUtil.MethodType.POST, WxHttpUtil.WxType.XCX, accessToken, url, null, wechatTplData); + JSONObject resultJson = JSONUtil.parseObj(result); + Integer errcode = Convert.toInt(resultJson.get("errcode")); + String errmsg = Convert.toStr(resultJson.get("errmsg")); + if (errcode != 0) { + log.error("微信公众号推送失败，失败原因：{}", errmsg); + } + } + } + + return CommonResult.success(); + } + + + + /** + * 获取微信小程序模板数据 + * + * @param open_id + * @param wechatTplmsg + * @param args + * @return + */ + public String getXcxWechatTplData(String open_id, ShopWechatTplmsg wechatTplmsg, Map args) { + WxXcxMsgPushVo wxXcxMsgPushVo = new WxXcxMsgPushVo(); + wxXcxMsgPushVo.setTouser(open_id); + wxXcxMsgPushVo.setTemplate_id(wechatTplmsg.getTplmsg_tpl_id()); + wxXcxMsgPushVo.setPage(wechatTplmsg.getLink_url()); + + String evn=Convert.toStr(args.get("evn")); + String storeName=Convert.toStr(args.get("storeName")); + String miniprogram_state="trial";//默认为体验版 + if(evn.equals("prod")){ + miniprogram_state="formal"; + } + wxXcxMsgPushVo.setMiniprogram_state(miniprogram_state); + wxXcxMsgPushVo.setLang("zh_CN"); + + // 通用信息 + WxXcxMsgPushVo.BaseValue BaseValue = new WxXcxMsgPushVo.BaseValue(); + WxXcxMsgPushVo.DetailValue Thing1 = new WxXcxMsgPushVo.DetailValue(); + Thing1.setValue(storeName); + BaseValue.setThing1(Thing1);//商家名称 + + WxXcxMsgPushVo.DetailValue phrase3 = new WxXcxMsgPushVo.DetailValue();//活动类型 + WxXcxMsgPushVo.DetailValue amount4 = new WxXcxMsgPushVo.DetailValue();//商品价格 + WxXcxMsgPushVo.DetailValue time6 = new WxXcxMsgPushVo.DetailValue();//活动时间 + WxXcxMsgPushVo.DetailValue time9 = new WxXcxMsgPushVo.DetailValue();//活动截止 + + phrase3.setValue("秒杀特价"); + BaseValue.setPhrase3(phrase3); + + amount4.setValue("0.01元起"); + BaseValue.setAmount4(amount4); + + // 获取当前时间 + LocalDateTime now = LocalDateTime.now(); + + // 加上12小时 + LocalDateTime futureTime = now.plusHours(12); + + // 格式化输出 + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); + String formattedNow = now.format(formatter); + String formattedFuture = futureTime.format(formatter); + time6.setValue(formattedNow); + BaseValue.setTime6(time6); + time9.setValue(formattedFuture); + BaseValue.setTime9(time9); + + wxXcxMsgPushVo.setData(BaseValue); + return JSON.toJSONString(wxXcxMsgPushVo); + } + + } \ No newline at end of file diff --git a/mall-shop/src/main/java/com/suisung/mall/shop/message/vo/WxXcxMsgPushVo.java b/mall-shop/src/main/java/com/suisung/mall/shop/message/vo/WxXcxMsgPushVo.java new file mode 100644 index 00000000..a454055d --- /dev/null +++ b/mall-shop/src/main/java/com/suisung/mall/shop/message/vo/WxXcxMsgPushVo.java @@ -0,0 +1,55 @@ +package com.suisung.mall.shop.message.vo; + +import com.alibaba.fastjson.annotation.JSONField; +import lombok.Data; +import lombok.NoArgsConstructor; + +@Data +@NoArgsConstructor +public class WxXcxMsgPushVo { + + @JSONField(ordinal = 1) + private String touser; + + @JSONField(ordinal = 2) + private String template_id; + + @JSONField(ordinal = 3) + private String page; + + @JSONField(ordinal = 5) + private BaseValue data; + + @JSONField(ordinal = 6) + private String miniprogram_state;//跳转小程序类型：developer为开发版；trial为体验版；formal为正式版；默认为正式版 + + @JSONField(ordinal = 7) + private String lang;//进入小程序查看”的语言类型，支持zh_CN(简体中文)、en_US(英文)、zh_HK(繁体中文)、zh_TW(繁体中文)，默认为zh_CN + + @Data + public static class BaseValue { + + @JSONField(ordinal = 1) + private DetailValue thing1; + + @JSONField(ordinal = 2) + private DetailValue phrase3; + + @JSONField(ordinal = 3) + private DetailValue amount4; + + @JSONField(ordinal = 4) + private DetailValue time6; + + @JSONField(ordinal = 5) + private DetailValue time9; + + } + + @Data + public static class DetailValue { + @JSONField(ordinal = 1) + private String value; + } + +} \ No newline at end of file diff --git a/sql/shop/dev/20250918_ddl.sql b/sql/shop/dev/20250918_ddl.sql new file mode 100644 index 00000000..c04ac30e --- /dev/null +++ b/sql/shop/dev/20250918_ddl.sql @@ -0,0 +1 @@ +alter table shop_wechat_tplmsg add column link_url varchar(500) comment '微信公众号或者小程序跳转路径' ; \ No newline at end of file diff --git a/sql/shop/dev/20250918_dml.sql b/sql/shop/dev/20250918_dml.sql new file mode 100644 index 00000000..53eb052f --- /dev/null +++ b/sql/shop/dev/20250918_dml.sql @@ -0,0 +1,3 @@ +INSERT INTO shop_wechat_tplmsg +(tplmsg_id, tplmsg_title, tplmsg_type_id, tplmsg_name, tplmsg_number, tplmsg_tpl_id, tplmsg_enable, tplmsg_is_buildin, tplmsg_remark, tplmsg_sort, store_id, message_id) +VALUES(1022, '秒杀活动', 4, '新活动通知', '9797', 'kiDj_hSF_ASwD-Dlgxnypi6IJBQZ12a-hEpd3zZ-Uxc', 1, 0, '活动秒杀', 50, 58, '0'); \ No newline at end of file