Merge remote-tracking branch 'origin/master'

doum

2025-09-15 82735e4d46ac7b9969facef2acc8f8e793b68f71

 server/services/src/main/java/com/doumee/config/wx/SendWxMessage.java

@@ -56,7 +56,7 @@
     */
    public  void  identityInfoMessage(String openid, IdentityInfo identityInfo){
        try{
            RestTemplate restTemplate = new RestTemplate();

            String accessToken = WxMiniConfig.wxMaService.getAccessToken();
            log.info("微信小程序->微信消息通知 - 认证信息  -> accessToken：{}",accessToken);
            //这里简单起见我们每次都获取最新的access_token（时间开发中，应该在access_token快过期时再重新获取）
@@ -66,12 +66,11 @@
            //用户的openid（要发送给那个用户）
            wxMsgVO.setTouser(openid);
            //订阅消息模板id
            wxMsgVO.setTemplate_id("VJho7-lf-4_WZFfOzenDndgwNDIA0EvCiE6vqBnExpQ");
            wxMsgVO.setTemplate_id("VJho7-lf-4_WZFfOzenDnX6sOhYBJWwkLExVjBB563U");
            Map<String, TemplateData> m = new HashMap<>(4);
            m.put("thing2", new TemplateData(Constants.equalsInteger(identityInfo.getType(),Constants.ZERO)?"实名认证":Constants.equalsInteger(identityInfo.getType(),Constants.ONE)?"运货认证":"供餐认证"));
            m.put("thing2", new TemplateData(Constants.equalsInteger(identityInfo.getType(),Constants.ZERO)?"用工认证":Constants.equalsInteger(identityInfo.getType(),Constants.ONE)?"运货认证":"供餐认证"));
            m.put("phrase6", new TemplateData(Constants.equalsInteger(identityInfo.getAuditStatus(),Constants.TWO)?"通过":"未通过"));
            m.put("time12", new TemplateData(DateUtil.formatDate(identityInfo.getAuditTime(),"yyyy-MM-dd HH:mm")));
            m.put("thing14", new TemplateData(identityInfo.getAuditRemark()));
            wxMsgVO.setPage(mineUrl);
            wxMsgVO.setData(m);
            log.error("微信小程序->微信消息通知 认证信息：{}", JSONObject.toJSONString(wxMsgVO));
@@ -94,7 +93,7 @@
     * @throws WxErrorException
     */
    public  void  cancelMessage(List<String> openidList, Orders orders,Integer cancelType ){
        RestTemplate restTemplate = new RestTemplate();

        try{
            String accessToken = WxMiniConfig.wxMaService.getAccessToken();
            log.error("微信小程序->微信消息通知 - 订单取消业务  -> accessToken：{}",accessToken);
@@ -109,7 +108,7 @@
            m.put("character_string3", new TemplateData(orders.getCode()));
            m.put("thing2", new TemplateData(Constants.orderType.getName(orders.getType())));
            m.put("thing1", new TemplateData(orders.getLocation() + (StringUtils.isNotBlank(orders.getLocationRemark())?orders.getLocationRemark():"")));
            m.put("date8", new TemplateData(DateUtil.getFomartDate(orders.getCancelTime(),"yyyy-MM-dd HH:mm:ss")));
            m.put("date8", new TemplateData(DateUtil.formatDate(orders.getCancelTime(),"yyyy-MM-dd HH:mm:ss")));
            m.put("thing6", new TemplateData(Constants.equalsInteger(cancelType,Constants.ZERO)?"平台取消":Constants.equalsInteger(cancelType,Constants.ONE)?"发单方取消":"接单方取消"));
            String pageUrl = Constants.equalsInteger(orders.getType(),Constants.orderType.hyd.getKey())?orderDetailFreight:
                    Constants.equalsInteger(orders.getType(),Constants.orderType.scd.getKey())?orderDetailFood:orderDetail;
@@ -145,7 +144,7 @@
     * @throws WxErrorException
     */
    public  void  acceptMessage(String openid, Orders orders,String memberName,String memberPhone){
        RestTemplate restTemplate = new RestTemplate();

        try{
            String accessToken = WxMiniConfig.wxMaService.getAccessToken();
            log.error("微信小程序->微信消息通知 - 接单业务  -> accessToken：{}",accessToken);
@@ -180,7 +179,7 @@


    public  void  orderUpdMessage(String openid, Orders orders){
        RestTemplate restTemplate = new RestTemplate();

        try{
            String accessToken = WxMiniConfig.wxMaService.getAccessToken();
            log.error("微信小程序->微信消息通知 - 订单变更通知  -> accessToken：{}",accessToken);
@@ -218,7 +217,7 @@

    public  void  withdrawalMessage(String openid, WithdrawalOrders withdrawalOrders){
        try{
            RestTemplate restTemplate = new RestTemplate();

            String accessToken = WxMiniConfig.wxMaService.getAccessToken();
            log.error("微信小程序->微信消息通知 - 提现成功通知  -> accessToken：{}",accessToken);
            //这里简单起见我们每次都获取最新的access_token（时间开发中，应该在access_token快过期时再重新获取）
@@ -249,7 +248,7 @@

    public  void  revenueMessage(String openid, Orders orders){
        try{
            RestTemplate restTemplate = new RestTemplate();

            String accessToken = WxMiniConfig.wxMaService.getAccessToken();
            log.error("微信小程序->微信消息通知 - 订单收益通知  -> accessToken：{}",accessToken);
            //这里简单起见我们每次都获取最新的access_token（时间开发中，应该在access_token快过期时再重新获取）
@@ -281,7 +280,7 @@

    public  void  autoDispatchMessage(String openid, Orders orders,double distance){
        try{
            RestTemplate restTemplate = new RestTemplate();

            String accessToken = WxMiniConfig.wxMaService.getAccessToken();
            log.error("微信小程序->微信消息通知 - 服务派单  -> accessToken：{}",accessToken);
            //这里简单起见我们每次都获取最新的access_token（时间开发中，应该在access_token快过期时再重新获取）
@@ -296,7 +295,7 @@
            m.put("thing3", new TemplateData(orders.getOrderContent()));
            m.put("phrase4", new TemplateData("此地距离您"+distance+"公里"));
            m.put("amount28", new TemplateData(orders.getEstimatedAccount().toString()));
            m.put("thing12", new TemplateData("工单将于"+DateUtil.getFomartDate(orders.getStartDate(),"MM-dd")+"开始"));
            m.put("thing12", new TemplateData("工单将于"+DateUtil.formatDate(orders.getStartDate(),"MM-dd")+"开始"));
            String pageUrl = Constants.equalsInteger(orders.getType(),Constants.orderType.hyd.getKey())?orderDetailFreight:
                    Constants.equalsInteger(orders.getType(),Constants.orderType.scd.getKey())?orderDetailFood:orderDetail;
            pageUrl = pageUrl.replace("{id}",orders.getId().toString());
@@ -311,8 +310,35 @@
        }catch (WxErrorException wxErrorException){

        }

    }

    public  void  waitPayMessage(String openid, Orders orders){
        try{

            String accessToken = WxMiniConfig.wxMaService.getAccessToken();
            log.error("微信小程序->微信消息通知 - 订单金额确认待支付  -> accessToken：{}",accessToken);
            //这里简单起见我们每次都获取最新的access_token（时间开发中，应该在access_token快过期时再重新获取）
            String url = "https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token="+accessToken;
            //拼接推送的模版
            WxMsgVO wxMsgVO = new WxMsgVO();
            wxMsgVO.setTouser(openid);
            //订阅消息模板id
            wxMsgVO.setTemplate_id("3rOz7DAnawrkKDM8b5_XW4FLivISWYov6d7QSC4ORsg");
            Map<String, TemplateData> m = new HashMap<>(5);
            m.put("character_string1", new TemplateData(orders.getCode()));
            m.put("thing7", new TemplateData( Constants.getOrderInfo(orders)));
            m.put("amount14", new TemplateData(new BigDecimal(orders.getPayAccount().toString()).divide(new BigDecimal("100"),2,BigDecimal.ROUND_HALF_UP).toString()));
            String pageUrl = Constants.equalsInteger(orders.getType(),Constants.orderType.hyd.getKey())?orderDetailFreight:
                    Constants.equalsInteger(orders.getType(),Constants.orderType.scd.getKey())?orderDetailFood:orderDetail;
            pageUrl = pageUrl.replace("{id}",orders.getId().toString());
            wxMsgVO.setPage(pageUrl);
            wxMsgVO.setData(m);
            log.error("微信小程序->微信消息通知 订单金额确认待支付：{}", JSONObject.toJSONString(wxMsgVO));
            //用户的openid（要发送给那个用户）
            String responseEntity  = HttpsUtil.postJson(url,JSONObject.toJSONString(wxMsgVO));
            log.error("微信小程序->微信消息通知 订单金额确认待支付：{}", JSONObject.toJSONString(responseEntity));
        }catch (WxErrorException wxErrorException){

        }
    }
}