mp_consumerap/Areas/Api/Controllers/v1/MainServer/ConsumersController.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Data;
using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Options;
using Microsoft.AspNetCore.Authorization;
using MySystem.MainModels;
using LitJson;
using Library;
using System.Security.Cryptography;
using System.Text;
using Aliyun.OSS;

namespace MySystem.Areas.Api.Controllers.v1
{
    [Area("Api")]
    [Route("/v1/QrCodePlateMain/[controller]/[action]")]
    public class ConsumersController : BaseController
    {
        public ConsumersController(IHttpContextAccessor accessor, ILogger<BaseController> logger, IOptions<Setting> setting) : base(accessor, logger, setting)
        {
        }


        #region 首页-首页-个人信息-返现金额
        // [Authorize]
        public JsonResult AmountInfo(string value)
        {
            value = DesDecrypt(value);
            JsonData data = JsonMapper.ToObject(value);
            Dictionary<string, object> Obj = AmountInfoDo(value);
            return Json(new AppResultJson() { Status = "1", Info = "", Data = Obj });
        }
        public Dictionary<string, object> AmountInfoDo(string value)
        {
            JsonData data = JsonMapper.ToObject(value);
            string OpenId = data["OpenId"].ToString(); //微信或支付宝Id
            int Kind = int.Parse(data["Kind"].ToString()); //类型(1 支付宝 2 微信)
            if (Kind == 1)
            {
                OpenId = AlipayMiniOpenIdDo(OpenId);
            }
            if (Kind == 2)
            {
                OpenId = WeChatMiniOpenIdDo(OpenId);
            }
            Dictionary<string, object> Obj = new Dictionary<string, object>();
            var ConsumerId = 0;
            var HeadPhoto = "";
            var NickName = "";
            var TotalAmount = 0.00M;
            var Amount = 0.00M;
            var Amount2 = 0.00M;
            var consumer = Services.Main.ConsumersService.Query(" and WechatOpenId='" + OpenId + "'");
            var consumer2 = Services.Main2.ConsumersService.Query(" and WechatOpenId='" + OpenId + "'");
            if (consumer.Id > 0 && !string.IsNullOrEmpty(consumer.WechatOpenId)) Amount = Services.Main.ConsumerProfitService.Sum(" and ConsumerId=" + consumer.Id + "", "GetMoney");
            if (consumer2.Id > 0 && !string.IsNullOrEmpty(consumer2.WechatOpenId)) Amount2 = Services.Main2.ConsumerProfitService.Sum(" and ConsumerId=" + consumer2.Id + "", "GetMoney");
            TotalAmount = Amount + Amount2;
            if (consumer.Id > 0)
            {
                ConsumerId = consumer.Id;
                HeadPhoto = consumer.HeadPhoto;
                NickName = consumer.NickName;
            }
            else
            {
                if (consumer2.Id > 0)
                {
                    ConsumerId = consumer2.Id;
                    HeadPhoto = consumer2.HeadPhoto;
                    NickName = consumer2.NickName;
                }
            }
            var token = PublicFunction.AppToken(ConsumerId, JwtSecret, JwtIss);
            // Obj.Add("Amount", 0.00); //累计返现金额
            Obj.Add("Amount", TotalAmount); //累计返现金额
            Obj.Add("HeadPhoto", HeadPhoto); //头像
            Obj.Add("NickName", NickName); //昵称
            Obj.Add("Token", token); //token
            Obj.Add("OpenId", OpenId);
            Obj.Add("ConsumerId", ConsumerId); //用户Id

            return Obj;
        }
        #endregion


        #region 首页-首页-oss信息
        [Authorize]
        public JsonResult OssInfo()
        {
            Dictionary<string, object> Obj = new Dictionary<string, object>();
            var time = DateTime.Now.ToString("yyyyMMdd");
            var dir = "/miniappHeadPhoto/" + time.Substring(0, 4) + "/" + time.Substring(4, 2) + "/" + time.Substring(6, 2) + "/";
            var OssUrl = "https://laikeba.oss-cn-chengdu.aliyuncs.com";
            // https://laikeba.oss-cn-chengdu.aliyuncs.com/miniappHeadPhoto/2024/01/17/lkb-1705458639623.jpg
            var AccessKeyId = "LTAI5tJsPaNzqCSMCPwb8zfz";
            var AccessKeySecret = "efM31Up75fQcgZ32U6xvAciagceQae";

            // 构造OssClient实例。 endpoint 格式:https://oss-cn-beijing.aliyuncs.com
            var ossClient = new OssClient(OssUrl, AccessKeyId, AccessKeySecret);
            var config = new PolicyConditions();
            config.AddConditionItem(PolicyConditions.CondContentLengthRange, 1, 1024L * 1024 * 1024 * 5);// 文件大小范围：单位byte
            config.AddConditionItem(MatchMode.StartWith, PolicyConditions.CondKey, dir);
            // config.AddConditionItem(PolicyConditions.CondSuccessActionStatus, "200");
            var expire = DateTimeOffset.Now.AddMinutes(30);// 过期时间
            // 生成 Policy，并进行 Base64 编码
            var policy = ossClient.GeneratePostPolicy(expire.LocalDateTime, config);
            var policyBase64 = Convert.ToBase64String(Encoding.UTF8.GetBytes(policy));
            // 计算签名
            var hmac = new HMACSHA1(Encoding.UTF8.GetBytes(AccessKeySecret));
            var bytes = hmac.ComputeHash(Encoding.UTF8.GetBytes(policyBase64));
            var Signature = Convert.ToBase64String(bytes);

            Obj.Add("OssUrl", OssUrl + dir);
            Obj.Add("AccessKeyId", AccessKeyId);
            Obj.Add("AccessKeySecret", AccessKeySecret);
            Obj.Add("Policy", policyBase64);
            Obj.Add("Expiration", expire);
            Obj.Add("Signature", Signature);
            return Json(new AppResultJson() { Status = "1", Info = "", Data = Obj });
        }
        #endregion


        #region 首页-首页-个人信息-修改个人信息
        [Authorize]
        public JsonResult EditPersonalInfo(string value)
        {
            value = DesDecrypt(value);
            JsonData data = JsonMapper.ToObject(value);
            AppResultJson result = EditPersonalInfoDo(value);
            return Json(new AppResultJson() { Status = result.Status, Info = result.Info, Data = result.Data });
        }
        private AppResultJson EditPersonalInfoDo(string value)
        {
            JsonData data = JsonMapper.ToObject(value);
            int ConsumerId = int.Parse(function.CheckInt(data["ConsumerId"].ToString())); //用户Id
            string HeadPhoto = data["HeadPhoto"].ToString(); //头像
            string NickName = data["NickName"].ToString(); //昵称
            Dictionary<string, object> Obj = new Dictionary<string, object>();
            var consumer = maindb.Consumers.FirstOrDefault(m => m.Id == ConsumerId) ?? new Consumers();
            var consumer2 = maindb2.Consumers.FirstOrDefault(m => m.Id == ConsumerId) ?? new MainModels2.Consumers();
            if (consumer.Id > 0)
            {
                if (!string.IsNullOrEmpty(HeadPhoto))
                {
                    consumer.HeadPhoto = HeadPhoto;
                }
                if (!string.IsNullOrEmpty(NickName))
                {
                    consumer.NickName = NickName;
                }
            }
            if (consumer2.Id > 0)
            {
                if (!string.IsNullOrEmpty(HeadPhoto))
                {
                    consumer2.HeadPhoto = HeadPhoto;
                }
                if (!string.IsNullOrEmpty(NickName))
                {
                    consumer2.NickName = NickName;
                }
            }
            maindb.SaveChanges();
            maindb2.SaveChanges();
            return new AppResultJson() { Status = "1", Info = "", Data = Obj };
        }
        #endregion


        #region 消费者-微信小程序通过code获取openid
        public string WeChatMiniOpenIdDo(string code)
        {
            string url = "https://api.weixin.qq.com/sns/jscode2session?appid=" + new WeChatFunction().AppId + "&secret=" + new WeChatFunction().AppSecret + "&js_code=" + code + "&grant_type=authorization_code";
            function.WriteLog(url, "微信小程序通过code获取openid");
            string result = function.GetWebRequest(url);
            function.WriteLog(result + "\n", "微信小程序通过code获取openid");
            JsonData jsonObj = JsonMapper.ToObject(result);
            string openid = jsonObj["openid"].ToString();
            return openid;
        }

        public Dictionary<string, string> getPhoneNumber(string encryptedData, string iv, string session_key)
        {
            Dictionary<string, string> Obj = new Dictionary<string, string>();
            try
            {
                byte[] encryData = Convert.FromBase64String(encryptedData);
                RijndaelManaged rijndaelCipher = new RijndaelManaged();
                rijndaelCipher.Key = Convert.FromBase64String(session_key);
                rijndaelCipher.IV = Convert.FromBase64String(iv);
                rijndaelCipher.Mode = CipherMode.CBC;
                rijndaelCipher.Padding = PaddingMode.PKCS7;
                ICryptoTransform transform = rijndaelCipher.CreateDecryptor();
                byte[] plainText = transform.TransformFinalBlock(encryData, 0, encryData.Length);
                string result = Encoding.Default.GetString(plainText);

                dynamic model = Newtonsoft.Json.Linq.JToken.Parse(result) as dynamic;
                string phoneNumber = model.phoneNumber;
                //return model.phoneNumber;
                if (string.IsNullOrEmpty(phoneNumber))
                {
                    phoneNumber = "";
                }
                Obj.Add("Mobile", phoneNumber);
            }
            catch (Exception ex)
            {
                Obj.Add("Mobile", "err");
                function.WriteLog(DateTime.Now.ToString(), "微信小程序获取手机号异常");
                function.WriteLog(encryptedData, "微信小程序获取手机号异常");
                function.WriteLog(iv, "微信小程序获取手机号异常");
                function.WriteLog(session_key, "微信小程序获取手机号异常");
                function.WriteLog(ex.ToString(), "微信小程序获取手机号异常");
                function.WriteLog("\r\n\r\n", "微信小程序获取手机号异常");
            }
            return Obj;
        }
        public string filterEmoji(string str)
        {
            string origin = str;
            try
            {
                //关键代码
                foreach (var a in str)
                {
                    byte[] bts = System.Text.Encoding.UTF32.GetBytes(a.ToString());
                    if (bts[0].ToString() == "253" && bts[1].ToString() == "255")
                    {
                        str = str.Replace(a.ToString(), "");
                    }
                }
            }
            catch
            {
                str = origin;
            }
            return str;
        }
        #endregion


        #region 消费者-支付宝通过code获取openid
        public string AlipayMiniOpenIdDo(string code)
        {
            string openid = new AlipayFunction(_accessor.HttpContext).GetAlipayUserId(code);
            return openid;
        }
        #endregion

    }
}