blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
sunpengfei
2025-11-20 fb245f04af0c848128da7d14c61694736b4afde7 
 ApiTools.Core/Utils/WxmpUtils/WxmpUtils.cs


@@ -1,6 +1,7 @@


using Aliyun.OSS;


using Azure.Core;


using Aop.Api.Domain;


using ApiTools.Core.Utils.WxmpUtils;


using Azure.Core;


using Furion.FriendlyException;


using Furion.HttpRemote;


using Mapster;


@@ -124,5 +125,42 @@


            var result = AliyunOSSUtils.Upload(command.OssScene, stream, command.OssFileName);


            return result.Url;


        }




        /// <summary>


        /// 该接口用于发送订阅消息


        /// </summary>


        /// <param name="command"></param>


        /// <returns></returns>


        public async Task<string> WxSend(SendRequest command)


        {


            var option = options.Value.Items.FirstOrDefault(it => it.Code == command.WxmpCode);


            if (option == null || option.AppId.IsNull() || option.AppSecret.IsNull())


                throw Oops.Oh(EnumErrorCodeType.s400, "获取小程序码失败，缺失配置：WxmpOptions");


            command.EnvVersion = option.EnvVersion;


            var accessToken = await GetAccessToken(command.WxmpCode);


            var request = command.Adapt<SendRequest>();


            var jsonContent = JsonConvert.SerializeObject(request, new JsonSerializerSettings


            {


                NullValueHandling = NullValueHandling.Ignore


            });


            var response = await httpRemoteService.PostAsync("https://api.weixin.qq.com/cgi-bin/message/subscribe/send",


                builder => builder


                .WithQueryParameter("access_token", accessToken)


                .SetJsonContent(jsonContent));


            response.EnsureSuccessStatusCode();


            if (response.Content.Headers.ContentType.ToString() == "application/json; charset=UTF-8")


            {


                var jsonResult = await response.Content.ReadAsStringAsync();


                var callback = jsonResult.JsonTo<SendResponse>();


                if (callback == null || callback.ErrorCode != 0)


                    //throw Oops.Oh(EnumErrorCodeType.s510, $"获取小程序码失败：{callback.errmsg}，请联系管理员");


                return jsonResult;


            }


            //var stream = await response.Content.ReadAsStreamAsync();


            //var result = AliyunOSSUtils.Upload(command, stream, command.OssFileName);


            return "";


        }






    }


}