mirror of
http://git.coreshop.cn/jianweie/coreshoppro.git
synced 2025-12-06 18:13:26 +08:00
2354 lines
86 KiB
C#
2354 lines
86 KiB
C#
/***********************************************************************
|
||
* Project: CoreCms
|
||
* ProjectName: 核心内容管理系统
|
||
* Web: https://www.corecms.net
|
||
* Author: 大灰灰
|
||
* Email: jianweie@163.com
|
||
* CreateTime: 2021/1/31 21:45:10
|
||
* Description: 暂无
|
||
***********************************************************************/
|
||
|
||
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.Globalization;
|
||
using System.IdentityModel.Tokens.Jwt;
|
||
using System.Linq;
|
||
using System.Security.Claims;
|
||
using System.Threading;
|
||
using System.Threading.Tasks;
|
||
using CoreCms.Net.Auth.HttpContextUser;
|
||
using CoreCms.Net.Auth.Policys;
|
||
using CoreCms.Net.Caching.AccressToken;
|
||
using CoreCms.Net.Caching.AutoMate.RedisCache;
|
||
using CoreCms.Net.Configuration;
|
||
using CoreCms.Net.IServices;
|
||
using CoreCms.Net.Loging;
|
||
using CoreCms.Net.Model.Entities;
|
||
using CoreCms.Net.Model.Entities.Expression;
|
||
using CoreCms.Net.Model.FromBody;
|
||
using CoreCms.Net.Model.ViewModels.DTO;
|
||
using CoreCms.Net.Model.ViewModels.UI;
|
||
using CoreCms.Net.Utility.Extensions;
|
||
using CoreCms.Net.Utility.Helper;
|
||
using CoreCms.Net.WeChat.Service.Enums;
|
||
using CoreCms.Net.WeChat.Service.HttpClients;
|
||
using CoreCms.Net.WeChat.Service.Models;
|
||
using CoreCms.Net.WeChat.Service.Options;
|
||
using CoreCms.Net.WeChat.Service.Utilities;
|
||
using DotLiquid.Util;
|
||
using Essensoft.Paylink.Alipay.Domain;
|
||
using Microsoft.AspNetCore.Authentication.JwtBearer;
|
||
using Microsoft.AspNetCore.Authorization;
|
||
using Microsoft.AspNetCore.Http;
|
||
using Microsoft.AspNetCore.Mvc;
|
||
using Microsoft.Extensions.Options;
|
||
using Newtonsoft.Json;
|
||
using Nito.AsyncEx;
|
||
using NLog;
|
||
using SKIT.FlurlHttpClient.Wechat.Api;
|
||
using SKIT.FlurlHttpClient.Wechat.Api.Models;
|
||
using SqlSugar;
|
||
|
||
namespace CoreCms.Net.Web.WebApi.Controllers
|
||
{
|
||
/// <summary>
|
||
/// 用户操作事件
|
||
/// </summary>
|
||
[Route("api/[controller]/[action]")]
|
||
[ApiController]
|
||
public class UserController : ControllerBase
|
||
{
|
||
|
||
private readonly ICoreCmsUserWeChatInfoServices _userWeChatInfoServices;
|
||
private readonly ICoreCmsUserServices _userServices;
|
||
private readonly PermissionRequirement _permissionRequirement;
|
||
private readonly ICoreCmsSmsServices _smsServices;
|
||
private readonly ICoreCmsUserGradeServices _userGradeServices;
|
||
private readonly IHttpContextUser _user;
|
||
private readonly ICoreCmsUserLogServices _userLogServices;
|
||
private readonly IHttpContextAccessor _httpContextAccessor;
|
||
private readonly ICoreCmsGoodsServices _goodsServices;
|
||
private readonly ICoreCmsGoodsBrowsingServices _goodsBrowsingServices;
|
||
private readonly ICoreCmsCartServices _cartServices;
|
||
private readonly ICoreCmsGoodsCollectionServices _goodsCollectionServices;
|
||
private readonly ICoreCmsUserShipServices _userShipServices;
|
||
private readonly ICoreCmsAreaServices _areaServices;
|
||
private readonly ICoreCmsBillPaymentsServices _billPaymentsServices;
|
||
private readonly ICoreCmsGoodsCommentServices _goodsCommentServices;
|
||
private readonly ICoreCmsUserBankCardServices _userBankCardServices;
|
||
private readonly ICoreCmsUserTocashServices _userTocashServices;
|
||
private readonly ICoreCmsUserBalanceServices _userBalanceServices;
|
||
private readonly ICoreCmsInvoiceServices _invoiceServices;
|
||
private readonly ICoreCmsUserPointLogServices _userPointLogServices;
|
||
private readonly ICoreCmsShareServices _shareServices;
|
||
private readonly ICoreCmsSettingServices _settingServices;
|
||
private readonly ICoreCmsServicesServices _servicesServices;
|
||
private readonly ICoreCmsUserServicesOrderServices _userServicesOrderServices;
|
||
private readonly ICoreCmsUserServicesTicketServices _userServicesTicketServices;
|
||
private readonly ICoreCmsStoreServices _storeServices;
|
||
private readonly ICoreCmsCouponServices _couponServices;
|
||
private readonly ICoreCmsOrderServices _orderServices;
|
||
private readonly IWeChatApiHttpClientFactory _weChatApiHttpClientFactory;
|
||
private readonly WeChatOptions _weChatOptions;
|
||
private readonly IRedisOperationRepository _redisOperationRepository;
|
||
|
||
/// <summary>
|
||
/// 构造函数
|
||
/// </summary>
|
||
public UserController(
|
||
IHttpContextUser user
|
||
, ICoreCmsUserWeChatInfoServices userWeChatInfoServices
|
||
, ICoreCmsUserServices userServices
|
||
, PermissionRequirement permissionRequirement
|
||
, ICoreCmsSmsServices smsServices
|
||
, ICoreCmsUserGradeServices userGradeServices
|
||
, ICoreCmsUserLogServices userLogServices
|
||
, IHttpContextAccessor httpContextAccessor
|
||
, ICoreCmsGoodsServices goodsServices
|
||
, ICoreCmsGoodsBrowsingServices goodsBrowsingServices
|
||
, ICoreCmsCartServices cartServices
|
||
, ICoreCmsGoodsCollectionServices goodsCollectionServices
|
||
, ICoreCmsUserShipServices userShipServices
|
||
, ICoreCmsAreaServices areaServices
|
||
, ICoreCmsBillPaymentsServices billPaymentsServices
|
||
, ICoreCmsGoodsCommentServices goodsCommentServices
|
||
, ICoreCmsUserBankCardServices userBankCardServices
|
||
, ICoreCmsUserTocashServices userTocashServices
|
||
, ICoreCmsUserBalanceServices userBalanceServices
|
||
, ICoreCmsInvoiceServices invoiceServices
|
||
, ICoreCmsUserPointLogServices userPointLogServices
|
||
, ICoreCmsShareServices shareServices
|
||
, ICoreCmsSettingServices settingServices
|
||
, ICoreCmsServicesServices servicesServices
|
||
, IOptions<WeChatOptions> weChatOptions
|
||
, ICoreCmsUserServicesOrderServices userServicesOrderServices, ICoreCmsUserServicesTicketServices userServicesTicketServices, ICoreCmsStoreServices storeServices, ICoreCmsCouponServices couponServices, ICoreCmsOrderServices orderServices, IWeChatApiHttpClientFactory weChatApiHttpClientFactory, IRedisOperationRepository redisOperationRepository)
|
||
{
|
||
_user = user;
|
||
_userWeChatInfoServices = userWeChatInfoServices;
|
||
_userServices = userServices;
|
||
_permissionRequirement = permissionRequirement;
|
||
_smsServices = smsServices;
|
||
_userGradeServices = userGradeServices;
|
||
_userLogServices = userLogServices;
|
||
_httpContextAccessor = httpContextAccessor;
|
||
_goodsServices = goodsServices;
|
||
_goodsBrowsingServices = goodsBrowsingServices;
|
||
_cartServices = cartServices;
|
||
_goodsCollectionServices = goodsCollectionServices;
|
||
_userShipServices = userShipServices;
|
||
_areaServices = areaServices;
|
||
_billPaymentsServices = billPaymentsServices;
|
||
_goodsCommentServices = goodsCommentServices;
|
||
_userBankCardServices = userBankCardServices;
|
||
_userTocashServices = userTocashServices;
|
||
_userBalanceServices = userBalanceServices;
|
||
_invoiceServices = invoiceServices;
|
||
_userPointLogServices = userPointLogServices;
|
||
_shareServices = shareServices;
|
||
_settingServices = settingServices;
|
||
_servicesServices = servicesServices;
|
||
_userServicesOrderServices = userServicesOrderServices;
|
||
_userServicesTicketServices = userServicesTicketServices;
|
||
_storeServices = storeServices;
|
||
_couponServices = couponServices;
|
||
_orderServices = orderServices;
|
||
_weChatApiHttpClientFactory = weChatApiHttpClientFactory;
|
||
_redisOperationRepository = redisOperationRepository;
|
||
_weChatOptions = weChatOptions.Value;
|
||
|
||
}
|
||
|
||
#region wx.login登陆成功之后发送的请求=========================================================
|
||
|
||
/// <summary>
|
||
/// wx.login登陆成功之后发送的请求
|
||
/// </summary>
|
||
/// <param name="entity"></param>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task<WebApiCallBack> OnLogin([FromBody] FMWxPost entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
var lockKey = "LOCK_OnLogin:user_" + entity.code;
|
||
var lockHolder = Guid.NewGuid().ToString("N"); //锁持有者
|
||
var redisUserLock = await _redisOperationRepository.LockTakeAsync(lockKey, lockHolder, TimeSpan.FromSeconds(10));
|
||
if (redisUserLock)
|
||
{
|
||
try
|
||
{
|
||
|
||
if (entity.type == (int)GlobalEnumVars.UserAccountTypes.微信小程序)
|
||
{
|
||
var client = _weChatApiHttpClientFactory.CreateWxOpenClient();
|
||
var accessToken = WeChatCacheAccessTokenHelper.GetWxOpenAccessToken();
|
||
var request = new SnsJsCode2SessionRequest
|
||
{
|
||
JsCode = entity.code,
|
||
AccessToken = accessToken
|
||
};
|
||
|
||
var response = await client.ExecuteSnsJsCode2SessionAsync(request, HttpContext.RequestAborted);
|
||
if (response.ErrorCode == (int)WeChatReturnCode.ReturnCode.请求成功)
|
||
{
|
||
var userInfo = await _userWeChatInfoServices.QueryByClauseAsync(p => p.openid == response.OpenId);
|
||
if (userInfo == null)
|
||
{
|
||
userInfo = new CoreCmsUserWeChatInfo
|
||
{
|
||
openid = response.OpenId,
|
||
type = (int)GlobalEnumVars.UserAccountTypes.微信小程序,
|
||
sessionKey = response.SessionKey,
|
||
gender = 1,
|
||
createTime = DateTime.Now,
|
||
unionId = response.UnionId
|
||
};
|
||
await _userWeChatInfoServices.InsertAsync(userInfo);
|
||
}
|
||
else
|
||
{
|
||
if (userInfo.sessionKey != response.SessionKey)
|
||
{
|
||
await _userWeChatInfoServices.UpdateAsync(
|
||
p => new CoreCmsUserWeChatInfo() { sessionKey = response.SessionKey, updateTime = DateTime.Now },
|
||
p => p.openid == userInfo.openid);
|
||
}
|
||
}
|
||
|
||
if (userInfo is { userId: > 0 })
|
||
{
|
||
var user = await _userServices.QueryByClauseAsync(p => p.id == userInfo.userId);
|
||
if (user != null)
|
||
{
|
||
if (user.status == (int)GlobalEnumVars.UserStatus.停用)
|
||
{
|
||
jm.status = false;
|
||
jm.msg = "您的账号已经被禁用。";
|
||
return jm;
|
||
}
|
||
|
||
if (user.isDelete == true)
|
||
{
|
||
jm.status = false;
|
||
jm.msg = "您的账号已经被禁用。";
|
||
return jm;
|
||
}
|
||
|
||
var claims = new List<Claim> {
|
||
new Claim(ClaimTypes.Name, user.nickName),
|
||
new Claim(JwtRegisteredClaimNames.Jti, user.id.ToString()),
|
||
new Claim(ClaimTypes.Expiration, DateTime.Now.AddSeconds(_permissionRequirement.Expiration.TotalSeconds).ToString(CultureInfo.InvariantCulture)) };
|
||
|
||
//用户标识
|
||
var identity = new ClaimsIdentity(JwtBearerDefaults.AuthenticationScheme);
|
||
identity.AddClaims(claims);
|
||
jm.status = true;
|
||
jm.data = new
|
||
{
|
||
auth = JwtToken.BuildJwtToken(claims.ToArray(), _permissionRequirement),
|
||
user
|
||
};
|
||
jm.otherData = response.OpenId;
|
||
|
||
//录入登录日志
|
||
var log = new CoreCmsUserLog
|
||
{
|
||
userId = user.id,
|
||
state = (int)GlobalEnumVars.UserLogTypes.登录,
|
||
ip = _httpContextAccessor.HttpContext?.Connection.RemoteIpAddress != null ? _httpContextAccessor.HttpContext.Connection.RemoteIpAddress.MapToIPv4().ToString() : "127.0.0.1",
|
||
createTime = DateTime.Now,
|
||
parameters = GlobalEnumVars.UserLogTypes.登录.ToString()
|
||
};
|
||
await _userLogServices.InsertAsync(log);
|
||
|
||
return jm;
|
||
}
|
||
}
|
||
//注意：生产环境下SessionKey属于敏感信息，不能进行传输！
|
||
//return new JsonResult(new { success = true, msg = "OK", sessionAuthId = sessionBag.Key, sessionKey = sessionBag.SessionKey, data = jsonResult, sessionBag = sessionBag });
|
||
jm.status = true;
|
||
jm.data = response.OpenId;
|
||
jm.otherData = response.OpenId;
|
||
//jm.methodDescription = JsonConvert.SerializeObject(sessionBag);
|
||
jm.msg = "OK";
|
||
}
|
||
else
|
||
{
|
||
jm.msg = response.ErrorMessage;
|
||
}
|
||
}
|
||
else if (entity.type == (int)GlobalEnumVars.UserAccountTypes.微信公众号)
|
||
{
|
||
var client = _weChatApiHttpClientFactory.CreateWeXinClient();
|
||
var accessToken = WeChatCacheAccessTokenHelper.GetWeChatAccessToken();
|
||
|
||
|
||
|
||
var request = new SnsOAuth2AccessTokenRequest()
|
||
{
|
||
Code = entity.code,
|
||
AccessToken = accessToken,
|
||
GrantType = "authorization_code"
|
||
};
|
||
|
||
var response = await client.ExecuteSnsOAuth2AccessTokenAsync(request, HttpContext.RequestAborted);
|
||
if (response.ErrorCode == (int)WeChatReturnCode.ReturnCode.请求成功)
|
||
{
|
||
var userInfo = await _userWeChatInfoServices.QueryByClauseAsync(p => p.openid == response.OpenId);
|
||
if (userInfo == null)
|
||
{
|
||
userInfo = new CoreCmsUserWeChatInfo
|
||
{
|
||
openid = response.OpenId,
|
||
type = (int)GlobalEnumVars.UserAccountTypes.微信公众号,
|
||
sessionKey = response.AccessToken,
|
||
gender = 1,
|
||
createTime = DateTime.Now,
|
||
unionId = response.UnionId
|
||
};
|
||
await _userWeChatInfoServices.InsertAsync(userInfo);
|
||
}
|
||
else
|
||
{
|
||
if (userInfo.sessionKey != response.AccessToken)
|
||
{
|
||
await _userWeChatInfoServices.UpdateAsync(
|
||
p => new CoreCmsUserWeChatInfo() { sessionKey = response.AccessToken, updateTime = DateTime.Now },
|
||
p => p.openid == userInfo.openid);
|
||
}
|
||
}
|
||
|
||
if (userInfo is { userId: > 0 })
|
||
{
|
||
var user = await _userServices.QueryByClauseAsync(p => p.id == userInfo.userId);
|
||
if (user != null)
|
||
{
|
||
if (user.status == (int)GlobalEnumVars.UserStatus.停用)
|
||
{
|
||
jm.status = false;
|
||
jm.msg = "您的账号已经被禁用。";
|
||
return jm;
|
||
}
|
||
|
||
if (user.isDelete == true)
|
||
{
|
||
jm.status = false;
|
||
jm.msg = "您的账号已经被禁用。";
|
||
return jm;
|
||
}
|
||
|
||
var claims = new List<Claim> {
|
||
new Claim(ClaimTypes.Name, user.nickName),
|
||
new Claim(JwtRegisteredClaimNames.Jti, user.id.ToString()),
|
||
new Claim(ClaimTypes.Expiration, DateTime.Now.AddSeconds(_permissionRequirement.Expiration.TotalSeconds).ToString(CultureInfo.InvariantCulture)) };
|
||
|
||
//用户标识
|
||
var identity = new ClaimsIdentity(JwtBearerDefaults.AuthenticationScheme);
|
||
identity.AddClaims(claims);
|
||
jm.status = true;
|
||
jm.data = new
|
||
{
|
||
auth = JwtToken.BuildJwtToken(claims.ToArray(), _permissionRequirement),
|
||
user
|
||
};
|
||
jm.otherData = response.OpenId;
|
||
|
||
//录入登录日志
|
||
var log = new CoreCmsUserLog
|
||
{
|
||
userId = user.id,
|
||
state = (int)GlobalEnumVars.UserLogTypes.登录,
|
||
ip = _httpContextAccessor.HttpContext?.Connection.RemoteIpAddress != null ? _httpContextAccessor.HttpContext.Connection.RemoteIpAddress.MapToIPv4().ToString() : "127.0.0.1",
|
||
createTime = DateTime.Now,
|
||
parameters = GlobalEnumVars.UserLogTypes.登录.ToString()
|
||
};
|
||
await _userLogServices.InsertAsync(log);
|
||
|
||
return jm;
|
||
}
|
||
}
|
||
//注意：生产环境下SessionKey属于敏感信息，不能进行传输！
|
||
//return new JsonResult(new { success = true, msg = "OK", sessionAuthId = sessionBag.Key, sessionKey = sessionBag.SessionKey, data = jsonResult, sessionBag = sessionBag });
|
||
jm.status = true;
|
||
jm.data = response.OpenId;
|
||
jm.otherData = response.OpenId;
|
||
//jm.methodDescription = JsonConvert.SerializeObject(sessionBag);
|
||
jm.msg = "OK";
|
||
}
|
||
else
|
||
{
|
||
jm.msg = response.ErrorMessage;
|
||
}
|
||
|
||
}
|
||
|
||
}
|
||
catch (Exception e)
|
||
{
|
||
jm.msg = "数据处理异常";
|
||
jm.otherData = e;
|
||
}
|
||
finally
|
||
{
|
||
await _redisOperationRepository.LockReleaseAsync(lockKey, lockHolder);
|
||
}
|
||
}
|
||
else
|
||
{
|
||
jm.msg = "当前请求太频繁_请稍后再试";
|
||
}
|
||
|
||
return jm;
|
||
}
|
||
#endregion
|
||
|
||
#region 微信核验数据并获取用户详细资料=====================================================
|
||
/// <summary>
|
||
/// 核验数据并获取用户详细资料
|
||
/// </summary>
|
||
/// <param name="entity"></param>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task<WebApiCallBack> DecodeEncryptedData([FromBody] FMWxLoginDecodeEncryptedData entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
var userInfo = await _userWeChatInfoServices.QueryByClauseAsync(p => p.openid == entity.sessionAuthId);
|
||
if (userInfo == null)
|
||
{
|
||
jm.status = false;
|
||
jm.msg = "用户信息获取失败";
|
||
return jm;
|
||
}
|
||
|
||
var decodedEntity = EncryptHelper.DecodeUserInfoBySessionId(userInfo.sessionKey, entity.encryptedData, entity.iv);
|
||
var token = string.Empty;
|
||
var userWxId = entity.sessionAuthId;
|
||
//检验水印
|
||
if (decodedEntity != null)
|
||
{
|
||
var checkWatermark = decodedEntity.CheckWatermark(_weChatOptions.WxOpenAppId);
|
||
jm.status = checkWatermark;
|
||
|
||
//保存用户信息（可选）
|
||
if (checkWatermark && decodedEntity is { } decodedUserInfo)
|
||
{
|
||
//更新数据库讯息
|
||
userInfo.gender = decodedUserInfo.gender;
|
||
userInfo.city = decodedUserInfo.city;
|
||
userInfo.avatar = decodedUserInfo.avatarUrl;
|
||
userInfo.country = decodedUserInfo.country;
|
||
userInfo.nickName = decodedUserInfo.nickName;
|
||
userInfo.province = decodedUserInfo.province;
|
||
userInfo.unionId = decodedUserInfo.unionId;
|
||
userInfo.updateTime = DateTime.Now;
|
||
|
||
await _userWeChatInfoServices.UpdateAsync(userInfo);
|
||
|
||
if (userInfo.userId > 0)
|
||
{
|
||
var user = await _userServices.QueryByClauseAsync(p => p.id == userInfo.userId);
|
||
if (user != null)
|
||
{
|
||
var claims = new List<Claim> {
|
||
new Claim(ClaimTypes.Name, user.nickName),
|
||
new Claim(JwtRegisteredClaimNames.Jti, user.id.ToString()),
|
||
new Claim(ClaimTypes.Expiration, DateTime.Now.AddSeconds(_permissionRequirement.Expiration.TotalSeconds).ToString(CultureInfo.InvariantCulture)) };
|
||
|
||
//用户标识
|
||
var identity = new ClaimsIdentity(JwtBearerDefaults.AuthenticationScheme);
|
||
identity.AddClaims(claims);
|
||
jm.status = true;
|
||
jm.data = JwtToken.BuildJwtToken(claims.ToArray(), _permissionRequirement);
|
||
|
||
//录入登录日志
|
||
var log = new CoreCmsUserLog();
|
||
log.userId = user.id;
|
||
log.state = (int)GlobalEnumVars.UserLogTypes.登录;
|
||
log.ip = _httpContextAccessor.HttpContext?.Connection.RemoteIpAddress != null ? _httpContextAccessor.HttpContext.Connection.RemoteIpAddress.MapToIPv4().ToString() : "127.0.0.1";
|
||
log.createTime = DateTime.Now;
|
||
log.parameters = GlobalEnumVars.UserLogTypes.登录.ToString();
|
||
await _userLogServices.InsertAsync(log);
|
||
|
||
//更新手机号码标识
|
||
if (!string.IsNullOrEmpty(userInfo.mobile))
|
||
{
|
||
await _userWeChatInfoServices.UpdateAsync(p => new CoreCmsUserWeChatInfo() { mobile = user.mobile }, p => p.id == userInfo.id);
|
||
}
|
||
|
||
return jm;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
jm.data = new
|
||
{
|
||
token,
|
||
sessionAuthId = userWxId
|
||
};
|
||
return jm;
|
||
}
|
||
#endregion
|
||
|
||
#region 用户短信发送===================================================================
|
||
/// <summary>
|
||
/// 用户短信发送
|
||
/// </summary>
|
||
/// <param name="entity"></param>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task<WebApiCallBack> SendSms([FromBody] FMWxSendSMS entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
if (!CommonHelper.IsMobile(entity.mobile))
|
||
{
|
||
jm.msg = "请输入合法的手机号码";
|
||
return jm;
|
||
}
|
||
if (string.IsNullOrEmpty(entity.code))
|
||
{
|
||
jm.msg = "请提交合法的短信类型";
|
||
return jm;
|
||
}
|
||
//此验证貌似没意义。
|
||
//if (entity.code == "login")
|
||
//{
|
||
// var shave = await _userServices.ExistsAsync(p => p.mobile == entity.mobile && p.userWx > 0);
|
||
// if (shave)
|
||
// {
|
||
// jm.msg = "手机号码已被绑定,请更换";
|
||
// return jm;
|
||
// }
|
||
//}
|
||
jm = await _smsServices.DoSendSms(entity.code, entity.mobile);
|
||
return jm;
|
||
}
|
||
#endregion
|
||
|
||
#region 手机短信验证码登陆，同时兼有手机短信注册的功能，还有第三方账户绑定的功能======================================================
|
||
/// <summary>
|
||
/// 手机短信验证码登陆，同时兼有手机短信注册的功能，还有第三方账户绑定的功能
|
||
/// </summary>
|
||
/// <param name="entity"></param>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task<WebApiCallBack> SmsLogin([FromBody] FMWxAccountCreate entity)
|
||
{
|
||
var jm = await _userServices.SmsLogin(entity, (int)GlobalEnumVars.LoginType.Sms, entity.platform);
|
||
return jm;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 微信小程序授权拉取手机号码
|
||
|
||
/// <summary>
|
||
/// 微信小程序授权拉取手机号码
|
||
/// </summary>
|
||
/// <param name="entity"></param>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task<WebApiCallBack> DecryptPhoneNumber([FromBody] FMWxLoginDecryptPhoneNumber entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
var userInfo = await _userWeChatInfoServices.QueryByClauseAsync(p => p.openid == entity.sessionAuthId);
|
||
if (userInfo == null)
|
||
{
|
||
jm.status = false;
|
||
jm.msg = "用户信息获取失败";
|
||
return jm;
|
||
}
|
||
DecodedPhoneNumber phoneNumber;
|
||
try
|
||
{
|
||
phoneNumber = EncryptHelper.DecryptPhoneNumber(userInfo.sessionKey, entity.encryptedData, entity.iv);
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
jm.status = false;
|
||
jm.code = 500;
|
||
NLogUtil.WriteAll(LogLevel.Error, LogType.Web, "小程序接口", "微信小程序授权拉取手机号码", ex);
|
||
return jm;
|
||
}
|
||
|
||
var data = new FMWxAccountCreate
|
||
{
|
||
mobile = phoneNumber.phoneNumber,
|
||
invitecode = entity.invitecode,
|
||
sessionAuthId = entity.sessionAuthId
|
||
};
|
||
|
||
jm = await _userServices.SmsLogin(data);
|
||
|
||
return jm;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 用户短信注册并返回jwt token(弃用)======================================================
|
||
/// <summary>
|
||
/// 用户短信注册并返回jwt token(弃用)
|
||
/// </summary>
|
||
/// <param name="entity"></param>
|
||
/// <returns></returns>
|
||
[Obsolete]
|
||
[HttpPost]
|
||
public async Task<WebApiCallBack> SmsLogin2([FromBody] FMWxAccountCreate entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
if (!CommonHelper.IsMobile(entity.mobile))
|
||
{
|
||
jm.msg = "请输入合法的手机号码";
|
||
return jm;
|
||
}
|
||
|
||
var user = await _userServices.QueryByClauseAsync(p => p.mobile == entity.mobile);
|
||
if (user != null)
|
||
{
|
||
jm.msg = "此号码已经绑定,请更换";
|
||
return jm;
|
||
}
|
||
var wxUserInfo = new CoreCmsUserWeChatInfo();
|
||
//1就是h5登陆（h5端和微信公众号端），2就是微信小程序登陆，3是支付宝小程序，4是app，5是pc
|
||
if (entity.platform == 2)
|
||
{
|
||
if (string.IsNullOrEmpty(entity.sessionAuthId))
|
||
{
|
||
jm.msg = "用户未正确登陆";
|
||
return jm;
|
||
}
|
||
wxUserInfo = await _userWeChatInfoServices.QueryByClauseAsync(p => p.openid == entity.sessionAuthId);
|
||
}
|
||
var sms = await _smsServices.QueryByClauseAsync(p => p.parameters == entity.code && p.mobile == entity.mobile);
|
||
if (sms == null)
|
||
{
|
||
jm.msg = "验证码核验失败";
|
||
return jm;
|
||
}
|
||
if (sms.isUsed)
|
||
{
|
||
jm.msg = "验证码已被使用";
|
||
return jm;
|
||
}
|
||
var dt = DateTime.Now;
|
||
var endDt = sms.createTime.AddMinutes(10);
|
||
if (dt > endDt)
|
||
{
|
||
jm.msg = "验证码已过期，请重新获取";
|
||
return jm;
|
||
}
|
||
user = new CoreCmsUser();
|
||
user.mobile = entity.mobile;
|
||
user.sex = wxUserInfo?.gender ?? 3;
|
||
user.avatarImage = wxUserInfo != null ? wxUserInfo.avatar : "";
|
||
user.nickName = wxUserInfo != null ? wxUserInfo.nickName : entity.mobile;
|
||
user.balance = 0;
|
||
user.parentId = 0;
|
||
user.point = 0;
|
||
//获取用户等级
|
||
var userGrade = await _userGradeServices.QueryByClauseAsync(p => p.isDefault);
|
||
user.grade = userGrade?.id ?? 0;
|
||
user.createTime = DateTime.Now;
|
||
user.status = 1;
|
||
user.userWx = wxUserInfo?.id ?? 0;
|
||
user.isDelete = false;
|
||
|
||
if (entity.invitecode > 0)
|
||
{
|
||
var parentId = UserHelper.GetUserIdByShareCode(entity.invitecode);
|
||
if (parentId > 0 && await _userServices.ExistsAsync(p => p.id == parentId))
|
||
{
|
||
user.parentId = parentId;
|
||
}
|
||
}
|
||
|
||
var id = await _userServices.InsertAsync(user);
|
||
if (id > 0)
|
||
{
|
||
var claims = new List<Claim> {
|
||
new Claim(ClaimTypes.Name, user.nickName),
|
||
new Claim(JwtRegisteredClaimNames.Jti, id.ToString()),
|
||
new Claim(ClaimTypes.Expiration, DateTime.Now.AddSeconds(_permissionRequirement.Expiration.TotalSeconds).ToString(CultureInfo.InvariantCulture)) };
|
||
//用户标识
|
||
var identity = new ClaimsIdentity(JwtBearerDefaults.AuthenticationScheme);
|
||
identity.AddClaims(claims);
|
||
jm.status = true;
|
||
jm.msg = "注册成功";
|
||
jm.data = JwtToken.BuildJwtToken(claims.ToArray(), _permissionRequirement);
|
||
//录入登录日志
|
||
var log = new CoreCmsUserLog();
|
||
log.userId = id;
|
||
log.state = (int)GlobalEnumVars.UserLogTypes.注册;
|
||
log.ip = _httpContextAccessor.HttpContext?.Connection.RemoteIpAddress != null ? _httpContextAccessor.HttpContext.Connection.RemoteIpAddress.MapToIPv4().ToString() : "127.0.0.1";
|
||
log.createTime = DateTime.Now;
|
||
log.parameters = GlobalEnumVars.UserLogTypes.注册.ToString();
|
||
await _userLogServices.InsertAsync(log);
|
||
//标识短信是否可用
|
||
sms.isUsed = true;
|
||
await _smsServices.UpdateAsync(sms);
|
||
}
|
||
else
|
||
{
|
||
jm.msg = "注册失败";
|
||
}
|
||
|
||
return jm;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 获取区域ID
|
||
/// <summary>
|
||
/// 获取区域ID
|
||
/// </summary>
|
||
/// <param name="entity"></param>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task<WebApiCallBack> GetAreaId([FromBody] GetAreaIdPost entity)
|
||
{
|
||
var jm = await _areaServices.GetAreaId(entity.provinceName, entity.cityName, entity.countyName, entity.postalCode);
|
||
|
||
return jm;
|
||
}
|
||
#endregion
|
||
|
||
#region 根据三级联动名称获取城市id信息
|
||
/// <summary>
|
||
/// 根据三级联动名称获取城市id信息
|
||
/// </summary>
|
||
/// <param name="entity"></param>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task<WebApiCallBack> GetAreaIdByName([FromBody] GetAreaIdPost entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
if (string.IsNullOrEmpty(entity.cityName))
|
||
{
|
||
jm.msg = "市数据未传送。";
|
||
return jm;
|
||
}
|
||
if (string.IsNullOrEmpty(entity.provinceName))
|
||
{
|
||
jm.msg = "省份数据未传送。";
|
||
return jm;
|
||
}
|
||
if (string.IsNullOrEmpty(entity.countyName))
|
||
{
|
||
jm.msg = "县数据未传送。";
|
||
return jm;
|
||
}
|
||
|
||
var cache = await _areaServices.GetCaChe();
|
||
var provinceObj = cache.Find(p => p.name == entity.provinceName && p.depth == 1);
|
||
if (provinceObj == null)
|
||
{
|
||
jm.msg = "省份获取失败。";
|
||
return jm;
|
||
}
|
||
var cityObj = cache.Find(p => p.depth == 2 && p.parentId == provinceObj.id && p.name == entity.cityName);
|
||
|
||
//可能存在库里面的二级城市和腾讯地图的二级城市不匹配（不得已的办法，最好是同步到腾讯地图的所有三级联动数据）
|
||
var dataArea = cityObj != null ? cache.Find(p => p.name == entity.countyName && p.depth == 3 && p.parentId == cityObj.id) : cache.Find(p => p.name == entity.countyName && p.depth == 3);
|
||
if (dataArea == null)
|
||
{
|
||
return jm;
|
||
}
|
||
|
||
var fullName = await _areaServices.GetAreaFullName(dataArea.id);
|
||
jm.status = true;
|
||
jm.data = new
|
||
{
|
||
areaId = dataArea.id,
|
||
fullName = fullName.data
|
||
};
|
||
return jm;
|
||
}
|
||
#endregion
|
||
|
||
#region 注销登录
|
||
/// <summary>
|
||
/// 注销登录
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public WebApiCallBack LogOut()
|
||
{
|
||
var jm = new WebApiCallBack
|
||
{
|
||
status = true,
|
||
data = new
|
||
{
|
||
token = "", //直接前端删除token-无为而治
|
||
}
|
||
};
|
||
|
||
return jm;
|
||
}
|
||
#endregion
|
||
|
||
#region 判断是否开启积分
|
||
/// <summary>
|
||
/// 判断是否开启积分
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task<WebApiCallBack> IsPoint()
|
||
{
|
||
var jm = new WebApiCallBack { status = true, msg = "获取成功" };
|
||
|
||
var allConfigs = await _settingServices.GetConfigDictionaries();
|
||
jm.data = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.PointSwitch).ObjectToInt(2);
|
||
|
||
return jm;
|
||
}
|
||
#endregion
|
||
|
||
#region 统一分享url处理
|
||
|
||
/// <summary>
|
||
/// 统一分享url处理
|
||
/// 新的分享，不管是二维码，还是地址，都走这个
|
||
/// page 场景值 1店铺首页，2商品详情页，3拼团详情页,4邀请好友（店铺页面,params里需要传store）,5文章页面,6参团页面，7自定义页面，8智能表单，9团购，10秒杀，11代理，12接龙
|
||
/// url：前端地址
|
||
/// params：参数，根据场景值不一样而内容不一样
|
||
/// 1
|
||
/// 2 goodsId:商品ID
|
||
/// 3 goodsId:商品ID，teamId:拼团ID
|
||
/// 4 store:店铺code
|
||
/// 5 articleId:文章ID，articleType:文章类型
|
||
/// 6 goodsId:商品ID，groupId:参团ID，teamId:拼团ID
|
||
/// 7 pageCode:自定义页面code
|
||
/// 8 id：智能表单ID
|
||
/// 9 goodsId:商品ID，groupId:团购秒杀ID
|
||
/// type 类型，1url，2二维码，3海报
|
||
/// token 可以保存推荐人的信息
|
||
/// client 终端，1普通h5，2微信小程序，3微信公众号（h5），4头条系小程序,5pc，6阿里小程序
|
||
/// 10 store:店铺code
|
||
/// </summary>
|
||
/// <param name="entity"></param>
|
||
/// <returns>array</returns>
|
||
[HttpPost]
|
||
public async Task<WebApiCallBack> Share([FromBody] FMShare entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
var userShareCode = 0;
|
||
if (_user is { ID: > 0 })
|
||
{
|
||
userShareCode = UserHelper.GetShareCodeByUserId(_user.ID);
|
||
}
|
||
if (entity.type == (int)GlobalEnumVars.ShareType.Url) //链接分享
|
||
{
|
||
jm = _shareServices.UrlShare(entity.client, entity.page, userShareCode, entity.url, entity.@params);
|
||
}
|
||
else if (entity.type == (int)GlobalEnumVars.ShareType.QrCode) //二维码
|
||
{
|
||
jm = await _shareServices.QrShare(entity.client, entity.page, userShareCode, entity.url, entity.@params);
|
||
}
|
||
else if (entity.type == (int)GlobalEnumVars.ShareType.Poster) //海报
|
||
{
|
||
//取消海报后台生成渲染，统一改成生成二维码，前端渲染
|
||
jm = await _shareServices.QrShare(entity.client, entity.page, userShareCode, entity.url, entity.@params);
|
||
}
|
||
|
||
return jm;
|
||
|
||
}
|
||
#endregion
|
||
|
||
#region 统一分享解码
|
||
/// <summary>
|
||
/// 统一分享解码
|
||
/// </summary>
|
||
/// <param name="entity"></param>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public WebApiCallBack DeShare([FromBody] FMDeShare entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
if (string.IsNullOrEmpty(entity.code))
|
||
{
|
||
jm.msg = GlobalErrorCodeVars.Code10000;
|
||
}
|
||
jm = _shareServices.de_url(entity.code);
|
||
|
||
return jm;
|
||
}
|
||
|
||
#endregion
|
||
|
||
//验证接口====================================================================================================
|
||
|
||
#region 同步微信用户数据=====================================================
|
||
/// <summary>
|
||
/// 同步微信用户数据
|
||
/// </summary>
|
||
/// <param name="entity"></param>
|
||
/// <returns></returns>
|
||
[Authorize]
|
||
[HttpPost]
|
||
public async Task<WebApiCallBack> SyncWeChatInfo([FromBody] FMWxSync entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
var user = await _userServices.QueryByClauseAsync(p => p.id == _user.ID);
|
||
if (user != null)
|
||
{
|
||
user.avatarImage = entity.avatarUrl;
|
||
user.nickName = entity.nickName;
|
||
user.sex = entity.gender;
|
||
|
||
//更新
|
||
await _userServices.UpdateAsync(p => new CoreCmsUser()
|
||
{
|
||
avatarImage = entity.avatarUrl,
|
||
nickName = entity.nickName,
|
||
sex = entity.gender,
|
||
}, p => p.id == user.id);
|
||
}
|
||
else
|
||
{
|
||
jm.msg = "用户信息获取失败";
|
||
}
|
||
|
||
if (user is { userWx: > 0 })
|
||
{
|
||
var userInfo = await _userWeChatInfoServices.QueryByClauseAsync(p => p.id == user.userWx);
|
||
if (userInfo != null)
|
||
{
|
||
userInfo.avatar = entity.avatarUrl;
|
||
userInfo.city = entity.city;
|
||
userInfo.country = entity.country;
|
||
userInfo.gender = entity.gender;
|
||
userInfo.nickName = entity.nickName;
|
||
userInfo.province = entity.province;
|
||
userInfo.updateTime = DateTime.Now;
|
||
await _userWeChatInfoServices.UpdateAsync(userInfo);
|
||
}
|
||
}
|
||
|
||
jm.status = true;
|
||
jm.data = user;
|
||
return jm;
|
||
}
|
||
#endregion
|
||
|
||
#region 获取用户信息
|
||
/// <summary>
|
||
/// 获取用户信息
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> GetUserInfo()
|
||
{
|
||
var jm = new WebApiCallBack() { status = true };
|
||
var user = await _userServices.QueryByIdAsync(_user.ID);
|
||
if (user == null)
|
||
{
|
||
jm.status = false;
|
||
jm.msg = "用户信息获取失败";
|
||
jm.code = 14007;
|
||
return jm;
|
||
}
|
||
|
||
if (user.status == (int)GlobalEnumVars.UserStatus.停用)
|
||
{
|
||
jm.status = false;
|
||
jm.msg = "您的账号已经被禁用。";
|
||
return jm;
|
||
}
|
||
|
||
if (user.isDelete == true)
|
||
{
|
||
jm.status = false;
|
||
jm.msg = "您的账号已经被禁用。";
|
||
return jm;
|
||
}
|
||
|
||
//获取用户等级
|
||
var userGrade = await _userGradeServices.QueryByClauseAsync(p => p.id == user.grade);
|
||
//获取优惠券
|
||
var userCouponCount = await _couponServices.GetMyCouponCount(user.id);
|
||
//订单数量
|
||
var orderCount = await _orderServices.OrderCount(0, user.id);
|
||
//足迹
|
||
var footPrintCount = await _goodsBrowsingServices.GetUserCountAsync(user.id);
|
||
//收藏
|
||
var collectionCount = await _goodsCollectionServices.GetUserCountAsync(user.id);
|
||
|
||
if (user.sex != (int)GlobalEnumVars.UserSexTypes.女 && user.sex != (int)GlobalEnumVars.UserSexTypes.男 && user.sex != (int)GlobalEnumVars.UserSexTypes.未知)
|
||
{
|
||
user.sex = (int)GlobalEnumVars.UserSexTypes.未知;
|
||
}
|
||
|
||
jm.data = new
|
||
{
|
||
user.id,
|
||
user.userName,
|
||
user.mobile,
|
||
user.sex,
|
||
user.birthday,
|
||
user.avatarImage,
|
||
user.nickName,
|
||
user.balance,
|
||
user.point,
|
||
user.grade,
|
||
user.createTime,
|
||
user.updataTime,
|
||
user.status,
|
||
user.parentId,
|
||
user.passWord,
|
||
gradeName = userGrade != null ? userGrade.title : "",
|
||
userCouponCount,
|
||
orderCount,
|
||
footPrintCount,
|
||
collectionCount
|
||
};
|
||
return jm;
|
||
}
|
||
#endregion
|
||
|
||
#region 获取购物车商品数量
|
||
/// <summary>
|
||
/// 获取购物车商品数量
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> GetCartNumber()
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
var count = await _cartServices.GetCountAsync(_user.ID);
|
||
jm.status = true;
|
||
jm.msg = jm.status ? GlobalConstVars.GetDataSuccess : GlobalConstVars.GetDataFailure;
|
||
jm.data = count;
|
||
|
||
return jm;
|
||
}
|
||
#endregion
|
||
|
||
#region 获取购物车商品数量
|
||
/// <summary>
|
||
/// 获取购物车商品数量
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> GetCartNumberAndMoney()
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
var count = await _cartServices.GetCountAsync(_user.ID);
|
||
var money = await _cartServices.GetMoneyAsync(_user.ID);
|
||
jm.status = true;
|
||
jm.msg = jm.status ? GlobalConstVars.GetDataSuccess : GlobalConstVars.GetDataFailure;
|
||
jm.data = new
|
||
{
|
||
count,
|
||
money
|
||
};
|
||
|
||
return jm;
|
||
}
|
||
#endregion
|
||
|
||
#region 商品取消/添加收藏
|
||
/// <summary>
|
||
/// 商品取消/添加收藏
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> GoodsCollectionCreateOrDelete([FromBody] FMIntId entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
var collection = await _goodsCollectionServices.QueryByClauseAsync(p => p.goodsId == entity.id && p.userId == _user.ID);
|
||
if (collection == null)
|
||
{
|
||
var goods = await _goodsServices.QueryByIdAsync(entity.id);
|
||
if (goods == null)
|
||
{
|
||
jm.msg = GlobalErrorCodeVars.Code17001;
|
||
return jm;
|
||
}
|
||
|
||
collection = new CoreCmsGoodsCollection()
|
||
{
|
||
goodsId = goods.id,
|
||
userId = _user.ID,
|
||
goodsName = goods.name,
|
||
createTime = DateTime.Now,
|
||
};
|
||
await _goodsCollectionServices.InsertAsync(collection);
|
||
jm.msg = GlobalErrorCodeVars.Code17002;
|
||
}
|
||
else
|
||
{
|
||
await _goodsCollectionServices.DeleteAsync(collection);
|
||
jm.msg = GlobalErrorCodeVars.Code17003;
|
||
}
|
||
jm.status = true;
|
||
|
||
return jm;
|
||
}
|
||
|
||
|
||
#endregion
|
||
|
||
#region 获取用户获取用户默认收货地址
|
||
/// <summary>
|
||
/// 获取用户获取用户默认收货地址
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> GetUserDefaultShip()
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
var ship = await _userShipServices.QueryByClauseAsync(p => p.isDefault && p.userId == _user.ID) ?? await _userShipServices.QueryByClauseAsync(p => p.userId == _user.ID, p => p.id, OrderByType.Desc);
|
||
|
||
if (ship != null)
|
||
{
|
||
var fullName = await _areaServices.GetAreaFullName(ship.areaId);
|
||
if (fullName.status)
|
||
{
|
||
ship.areaName = fullName.data.ToString();
|
||
}
|
||
}
|
||
|
||
jm.status = true;
|
||
jm.data = ship;
|
||
|
||
return jm;
|
||
}
|
||
#endregion
|
||
|
||
#region 设置默认地址
|
||
/// <summary>
|
||
/// 设置默认地址
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> SetDefShip([FromBody] FMIntId entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
var ship = await _userShipServices.QueryByClauseAsync(p => p.id == entity.id && p.userId == _user.ID);
|
||
if (ship != null)
|
||
{
|
||
//没有默认的直接设置为默认
|
||
ship.isDefault = true;
|
||
var result = await _userShipServices.UpdateAsync(ship);
|
||
jm.status = result.code == 0;
|
||
jm.msg = jm.status ? "保存成功" : "保存失败";
|
||
}
|
||
else
|
||
{
|
||
jm.msg = "该地址不存在";
|
||
}
|
||
|
||
return jm;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 判断用户下单可以使用多少积分
|
||
/// <summary>
|
||
/// 判断用户下单可以使用多少积分
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> GetUserPoint([FromBody] GetUserPointPost entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
var ids = CommonHelper.StringToIntArray(entity.ids);
|
||
if (!ids.Any())
|
||
{
|
||
jm.status = false;
|
||
jm.msg = "请提交货品信息";
|
||
return jm;
|
||
}
|
||
var ship = await _userServices.GetUserPoint(_user.ID, entity.orderMoney, ids, entity.cartType);
|
||
jm.status = true;
|
||
jm.data = ship;
|
||
|
||
return jm;
|
||
}
|
||
#endregion
|
||
|
||
#region 获取用户的收货地址列表
|
||
/// <summary>
|
||
/// 获取用户的收货地址列表
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> GetUserShip()
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
var ship = await _userShipServices.QueryListByClauseAsync(p => p.userId == _user.ID, p => p.isDefault, OrderByType.Desc);
|
||
if (ship.Any())
|
||
{
|
||
ship.ForEach(Action);
|
||
}
|
||
jm.status = true;
|
||
jm.data = ship;
|
||
|
||
return jm;
|
||
}
|
||
|
||
private async void Action(CoreCmsUserShip p)
|
||
{
|
||
var fullName = await _areaServices.GetAreaFullName(p.areaId);
|
||
if (fullName.status)
|
||
{
|
||
p.areaName = fullName.data.ToString();
|
||
}
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 保存用户地址
|
||
/// <summary>
|
||
/// 保存用户地址
|
||
/// </summary>
|
||
/// <param name="entity"></param>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> SaveUserShip([FromBody] SaveUserShipPost entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
if (entity.id > 0)
|
||
{
|
||
//判断是否存在默认数据
|
||
if (entity.isDefault != 1)
|
||
{
|
||
if (await _userShipServices.ExistsAsync(p => p.userId == _user.ID && p.isDefault == true && p.id != entity.id) == false) entity.isDefault = 1;
|
||
}
|
||
var userShip = new CoreCmsUserShip();
|
||
userShip.id = entity.id;
|
||
userShip.userId = _user.ID;
|
||
userShip.areaId = entity.areaId;
|
||
userShip.isDefault = entity.isDefault == 1;
|
||
userShip.name = entity.name;
|
||
userShip.address = entity.address;
|
||
userShip.mobile = entity.mobile;
|
||
userShip.updateTime = DateTime.Now;
|
||
|
||
userShip.longitude = entity.longitude;
|
||
userShip.latitude = entity.latitude;
|
||
userShip.street = entity.street;
|
||
|
||
|
||
var ship = await _userShipServices.UpdateAsync(userShip);
|
||
jm.status = true;
|
||
jm.data = ship;
|
||
jm.msg = "地址保存成功";
|
||
}
|
||
else
|
||
{
|
||
//判断是否存在默认数据
|
||
if (entity.isDefault != 1)
|
||
{
|
||
if (await _userShipServices.ExistsAsync(p => p.userId == _user.ID && p.isDefault == true) == false) entity.isDefault = 1;
|
||
}
|
||
var userShip = new CoreCmsUserShip();
|
||
userShip.userId = _user.ID;
|
||
userShip.areaId = entity.areaId;
|
||
userShip.isDefault = entity.isDefault == 1;
|
||
userShip.name = entity.name;
|
||
userShip.address = entity.address;
|
||
userShip.mobile = entity.mobile;
|
||
userShip.createTime = DateTime.Now;
|
||
|
||
userShip.longitude = entity.longitude;
|
||
userShip.latitude = entity.latitude;
|
||
userShip.street = entity.street;
|
||
|
||
var ship = await _userShipServices.InsertAsync(userShip);
|
||
jm.status = true;
|
||
jm.data = ship;
|
||
jm.msg = "地址保存成功";
|
||
}
|
||
|
||
return jm;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 获取用户单个地址详情
|
||
/// <summary>
|
||
/// 获取用户单个地址详情
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> GetShipDetail([FromBody] FMIntId entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
var ship = await _userShipServices.QueryByClauseAsync(p => p.userId == _user.ID && p.id == entity.id);
|
||
if (ship != null)
|
||
{
|
||
//var areas = _areaServices.FindListAsync();
|
||
var fullName = await _areaServices.GetAreaFullName(ship.areaId);
|
||
if (fullName.status)
|
||
{
|
||
ship.areaName = fullName.data.ToString();
|
||
}
|
||
}
|
||
jm.status = true;
|
||
jm.data = ship;
|
||
|
||
return jm;
|
||
}
|
||
#endregion
|
||
|
||
#region 收货地址删除
|
||
/// <summary>
|
||
/// 收货地址删除
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> RemoveShip([FromBody] FMIntId entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
jm.status = await _userShipServices.DeleteAsync(p => p.userId == _user.ID && p.id == entity.id);
|
||
jm.msg = jm.status ? GlobalConstVars.DeleteSuccess : GlobalConstVars.DeleteFailure;
|
||
|
||
if (jm.status)
|
||
{
|
||
//如果只有一个地址了，默认将最后一个剩余的地址设置为默认。
|
||
var anySum = await _userShipServices.GetCountAsync(p => p.userId == _user.ID);
|
||
if (anySum == 1)
|
||
{
|
||
await _userShipServices.UpdateAsync(p => new CoreCmsUserShip() { isDefault = true }, p => p.userId == _user.ID);
|
||
}
|
||
}
|
||
return jm;
|
||
}
|
||
#endregion
|
||
|
||
#region 支付
|
||
|
||
/// <summary>
|
||
/// 支付
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> Pay([FromBody] PayPost entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
var lockKey = "LOCK_Pay:user_" + _user.ID;
|
||
var lockHolder = Guid.NewGuid().ToString("N"); //锁持有者
|
||
var redisUserLock = await _redisOperationRepository.LockTakeAsync(lockKey, lockHolder, TimeSpan.FromSeconds(10));
|
||
if (redisUserLock)
|
||
{
|
||
try
|
||
{
|
||
if (string.IsNullOrEmpty(entity.ids))
|
||
{
|
||
jm.code = 13100;
|
||
jm.msg = GlobalErrorCodeVars.Code13100;
|
||
}
|
||
else if (string.IsNullOrEmpty(entity.payment_code))
|
||
{
|
||
jm.code = 10055;
|
||
jm.msg = GlobalErrorCodeVars.Code10055;
|
||
}
|
||
else if (entity.payment_type == 0)
|
||
{
|
||
jm.code = 10051;
|
||
jm.msg = GlobalErrorCodeVars.Code10051;
|
||
}
|
||
//生成支付单,并发起支付
|
||
jm = await _billPaymentsServices.Pay(entity.ids, entity.payment_code, _user.ID, entity.payment_type, entity.@params);
|
||
}
|
||
catch (Exception e)
|
||
{
|
||
jm.msg = "数据处理异常";
|
||
jm.otherData = e;
|
||
NLogUtil.WriteFileLog(NLog.LogLevel.Error, LogType.ApiRequest, "用户支付支付", JsonConvert.SerializeObject(jm));
|
||
}
|
||
finally
|
||
{
|
||
await _redisOperationRepository.LockReleaseAsync(lockKey, lockHolder);
|
||
}
|
||
}
|
||
else
|
||
{
|
||
jm.msg = "当前请求太频繁_请稍后再试";
|
||
}
|
||
return jm;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 订单评价
|
||
|
||
/// <summary>
|
||
/// 订单评价
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> OrderEvaluate([FromBody] OrderEvaluatePost entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
if (string.IsNullOrEmpty(entity.orderId))
|
||
{
|
||
jm.code = 13100;
|
||
jm.msg = GlobalErrorCodeVars.Code13100;
|
||
}
|
||
else if (entity.items == null || entity.items.Count == 0)
|
||
{
|
||
jm.code = 10051;
|
||
jm.msg = GlobalErrorCodeVars.Code10051;
|
||
}
|
||
jm = await _goodsCommentServices.AddComment(entity.orderId, entity.items, _user.ID);
|
||
jm.otherData = entity;
|
||
return jm;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 我的银行卡列表
|
||
/// <summary>
|
||
/// 我的银行卡列表
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> GetMyBankcardsList()
|
||
{
|
||
var jm = await _userBankCardServices.GetMyBankcardsList(_user.ID);
|
||
return jm;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 添加银行卡
|
||
/// <summary>
|
||
/// 添加银行卡
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> AddBankCards([FromBody] CoreCmsUserBankCard entity)
|
||
{
|
||
entity.userId = _user.ID;
|
||
var jm = await _userBankCardServices.AddBankCards(entity);
|
||
return jm;
|
||
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 设置默认银行卡
|
||
/// <summary>
|
||
/// 设置默认银行卡
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> SetDefaultBankCard([FromBody] FMIntId entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
if (entity.id == 0)
|
||
{
|
||
jm.msg = GlobalErrorCodeVars.Code10051;
|
||
return jm;
|
||
}
|
||
|
||
jm = await _userBankCardServices.SetDefault(_user.ID, entity.id);
|
||
return jm;
|
||
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 获取银行卡信息
|
||
/// <summary>
|
||
/// 获取银行卡信息
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> GetBankCardInfo([FromBody] FMIntId entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
if (entity.id == 0)
|
||
{
|
||
jm.msg = GlobalErrorCodeVars.Code10051;
|
||
return jm;
|
||
}
|
||
|
||
jm = await _userBankCardServices.GetBankcardInfo(_user.ID, entity.id);
|
||
return jm;
|
||
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 获取用户默认银行卡信息
|
||
/// <summary>
|
||
/// 获取用户默认银行卡信息
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> GetDefaultBankCard()
|
||
{
|
||
var jm = await _userBankCardServices.GetDefaultBankCard(_user.ID);
|
||
return jm;
|
||
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 删除银行卡信息
|
||
/// <summary>
|
||
/// 删除银行卡信息
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> Removebankcard([FromBody] FMIntId entity)
|
||
{
|
||
var jm = await _userBankCardServices.Removebankcard(entity.id, _user.ID);
|
||
return jm;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 获取银行卡组织信息
|
||
/// <summary>
|
||
/// 获取银行卡组织信息
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> GetBankCardsOrganization([FromBody] FMStringId entity)
|
||
{
|
||
var jm = await _userBankCardServices.BankCardsOrganization(entity.id);
|
||
return jm;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 提现申请
|
||
/// <summary>
|
||
/// 提现申请
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> Cash([FromBody] FMIntId entity)
|
||
{
|
||
var money = entity.data.ObjectToDecimal(0);
|
||
var jm = await _userTocashServices.Tocash(_user.ID, money, entity.id);
|
||
return jm;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 提现记录列表
|
||
/// <summary>
|
||
/// 提现记录列表
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> CashList([FromBody] FMPageByIntId entity)
|
||
{
|
||
var jm = await _userTocashServices.UserToCashList(_user.ID, entity.page, entity.limit, entity.id);
|
||
return jm;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 获取我的余额明细列表
|
||
/// <summary>
|
||
/// 获取我的余额明细列表
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> UserBalance([FromBody] FMGetBalancePost entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
var where = PredicateBuilder.True<CoreCmsUserBalance>();
|
||
where = where.And(p => p.userId == _user.ID);
|
||
if (entity.id > 0)
|
||
{
|
||
where = where.And(p => p.type == entity.id);
|
||
}
|
||
|
||
if (!string.IsNullOrEmpty(entity.propsDate))
|
||
{
|
||
if (entity.propsDate.Contains("至"))
|
||
{
|
||
var dts = entity.propsDate.Split("至");
|
||
if (dts.Length == 2)
|
||
{
|
||
var dt = dts[0].ObjectToDate(DateTime.Now);
|
||
var startTime = new DateTime(dt.Year, dt.Month, dt.Day, 0, 0, 0);
|
||
var dt2 = dts[1].ObjectToDate(DateTime.Now);
|
||
var endTime = new DateTime(dt2.Year, dt2.Month, dt2.Day, 23, 59, 59);
|
||
where = where.And(p => p.createTime > startTime && p.createTime < endTime);
|
||
}
|
||
}
|
||
else
|
||
{
|
||
var dt = entity.propsDate.ObjectToDate(DateTime.Now);
|
||
var startTime = new DateTime(dt.Year, dt.Month, dt.Day, 0, 0, 0);
|
||
var endTime = new DateTime(dt.Year, dt.Month, dt.Day, 23, 59, 59);
|
||
where = where.And(p => p.createTime > startTime && p.createTime < endTime);
|
||
}
|
||
}
|
||
|
||
var data = await _userBalanceServices.QueryPageAsync(where, p => p.createTime, OrderByType.Desc,
|
||
entity.page, entity.limit);
|
||
if (data.Any())
|
||
{
|
||
foreach (var item in data)
|
||
{
|
||
item.typeName = EnumHelper.GetEnumDescriptionByValue<GlobalEnumVars.UserBalanceSourceTypes>(item.type);
|
||
}
|
||
}
|
||
|
||
var sunMoney = await _userBalanceServices.GetSumAsync(where, p => p.money);
|
||
|
||
jm.status = true;
|
||
jm.data = data;
|
||
jm.otherData = new
|
||
{
|
||
data.TotalPages,
|
||
sunMoney
|
||
};
|
||
return jm;
|
||
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 我的发票列表
|
||
/// <summary>
|
||
/// 我的发票列表
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> UserInvoiceList([FromBody] FMPageByIntId entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
var where = PredicateBuilder.True<CoreCmsInvoice>();
|
||
where = where.And(p => p.userId == _user.ID);
|
||
if (entity.id > 0)
|
||
{
|
||
where = where.And(p => p.id == entity.id);
|
||
}
|
||
var status = entity.otherData.ObjectToInt(0);
|
||
if (status > 0)
|
||
{
|
||
where = where.And(p => p.status == status);
|
||
|
||
}
|
||
var data = await _invoiceServices.QueryPageAsync(where, p => p.createTime, OrderByType.Desc,
|
||
entity.page, entity.limit);
|
||
if (data.Any())
|
||
{
|
||
foreach (var item in data)
|
||
{
|
||
item.categoryName = EnumHelper.GetEnumDescriptionByValue<GlobalEnumVars.OrderTaxCategory>(item.category);
|
||
item.typeName = EnumHelper.GetEnumDescriptionByValue<GlobalEnumVars.OrderTaxType>(item.type);
|
||
item.statusName = EnumHelper.GetEnumDescriptionByValue<GlobalEnumVars.OrderTaxStatus>(item.status);
|
||
}
|
||
}
|
||
jm.status = true;
|
||
jm.data = data;
|
||
jm.otherData = new
|
||
{
|
||
data.TotalCount,
|
||
data.TotalPages
|
||
};
|
||
return jm;
|
||
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 我的积分列表
|
||
/// <summary>
|
||
/// 我的积分列表
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> UserPointLog([FromBody] FMPageByIntId entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
var where = PredicateBuilder.True<CoreCmsUserPointLog>();
|
||
where = where.And(p => p.userId == _user.ID);
|
||
|
||
var data = await _userPointLogServices.QueryPageAsync(where, p => p.createTime, OrderByType.Desc, entity.page, entity.limit);
|
||
if (data.Any())
|
||
{
|
||
foreach (var item in data)
|
||
{
|
||
item.typeName = EnumHelper.GetEnumDescriptionByValue<GlobalEnumVars.UserPointSourceTypes>(item.type);
|
||
}
|
||
}
|
||
jm.status = true;
|
||
jm.data = data;
|
||
jm.otherData = new
|
||
{
|
||
data.TotalCount,
|
||
data.TotalPages
|
||
};
|
||
return jm;
|
||
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 取得商品收藏记录（关注）
|
||
/// <summary>
|
||
/// 取得商品收藏记录（关注）
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> GoodsCollectionList([FromBody] FMPageByIntId entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
var data = await _goodsCollectionServices.QueryPageAsync(p => p.userId == _user.ID, p => p.createTime, OrderByType.Desc, entity.page, entity.limit);
|
||
|
||
jm.status = true;
|
||
jm.data = new
|
||
{
|
||
list = data,
|
||
count = data.TotalCount,
|
||
|
||
};
|
||
return jm;
|
||
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 添加商品收藏（关注）
|
||
/// <summary>
|
||
/// 添加商品收藏（关注）
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> GoodsCollection([FromBody] FMIntId entity)
|
||
{
|
||
var jm = await _goodsCollectionServices.ToAdd(_user.ID, entity.id);
|
||
return jm;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 取得商品浏览足迹
|
||
/// <summary>
|
||
/// 取得商品浏览足迹
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> Goodsbrowsing([FromBody] FMPageByIntId entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
var data = await _goodsBrowsingServices.QueryPageAsync(p => p.userId == _user.ID, p => p.createTime, OrderByType.Desc, entity.page, entity.limit);
|
||
|
||
jm.status = true;
|
||
jm.data = new
|
||
{
|
||
list = data,
|
||
count = data.TotalCount,
|
||
|
||
};
|
||
return jm;
|
||
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 添加商品浏览足迹
|
||
/// <summary>
|
||
/// 添加商品浏览足迹
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> AddGoodsBrowsing([FromBody] FMIntId entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
|
||
//获取数据
|
||
var goods = await _goodsServices.QueryByIdAsync(entity.id);
|
||
if (goods == null)
|
||
{
|
||
jm.msg = GlobalConstVars.DataisNo;
|
||
return jm;
|
||
}
|
||
var goodsBrowsing = new CoreCmsGoodsBrowsing
|
||
{
|
||
goodsId = goods.id,
|
||
userId = _user.ID,
|
||
goodsName = goods.name,
|
||
createTime = DateTime.Now,
|
||
isdel = false
|
||
};
|
||
jm.status = await _goodsBrowsingServices.InsertAsync(goodsBrowsing) > 0;
|
||
jm.msg = jm.status ? GlobalConstVars.InsertSuccess : GlobalConstVars.InsertFailure;
|
||
|
||
return jm;
|
||
}
|
||
|
||
|
||
#endregion
|
||
|
||
#region 删除商品浏览足迹
|
||
/// <summary>
|
||
/// 删除商品浏览足迹
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> DelGoodsBrowsing([FromBody] FMIntId entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
jm.status = await _goodsBrowsingServices.DeleteAsync(p => p.userId == _user.ID && p.id == entity.id);
|
||
jm.msg = jm.status ? GlobalConstVars.DeleteSuccess : GlobalConstVars.DeleteFailure;
|
||
|
||
return jm;
|
||
}
|
||
#endregion
|
||
|
||
#region 更换头像
|
||
/// <summary>
|
||
/// 更换头像
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> ChangeAvatar([FromBody] FMStringId entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
if (string.IsNullOrEmpty(entity.id))
|
||
{
|
||
jm.data = GlobalErrorCodeVars.Code11003;
|
||
return jm;
|
||
}
|
||
|
||
var up = await _userServices.UpdateAsync(p => new CoreCmsUser() { avatarImage = entity.id },
|
||
p => p.id == _user.ID);
|
||
|
||
jm.status = up;
|
||
jm.msg = jm.status ? "设置头像成功" : "设置头像失败";
|
||
jm.data = entity.id;
|
||
|
||
return jm;
|
||
}
|
||
#endregion
|
||
|
||
#region 编辑用户信息
|
||
/// <summary>
|
||
/// 编辑用户信息
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> EditInfo([FromBody] EditInfoPost entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
if (entity.birthday == null)
|
||
{
|
||
jm.msg = GlobalErrorCodeVars.Code11027;
|
||
return jm;
|
||
}
|
||
|
||
if (string.IsNullOrEmpty(entity.nickname))
|
||
{
|
||
jm.msg = GlobalErrorCodeVars.Code11028;
|
||
return jm;
|
||
}
|
||
|
||
if (entity.sex <= 0)
|
||
{
|
||
jm.msg = GlobalErrorCodeVars.Code11029;
|
||
return jm;
|
||
}
|
||
|
||
var up = await _userServices.UpdateAsync(p => new CoreCmsUser() { birthday = entity.birthday, nickName = entity.nickname, sex = entity.sex },
|
||
p => p.id == _user.ID);
|
||
|
||
jm.status = up;
|
||
jm.msg = jm.status ? "资料保存成功" : "资料保存失败";
|
||
|
||
return jm;
|
||
}
|
||
|
||
|
||
#endregion
|
||
|
||
#region 修改用户密码
|
||
/// <summary>
|
||
/// 修改用户密码
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> EditPwd([FromBody] EditPwdPost entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
if (string.IsNullOrEmpty(entity.repwd))
|
||
{
|
||
jm.msg = GlobalErrorCodeVars.Code11014;
|
||
return jm;
|
||
}
|
||
if (string.IsNullOrEmpty(entity.newpwd))
|
||
{
|
||
jm.msg = GlobalErrorCodeVars.Code11013;
|
||
return jm;
|
||
}
|
||
if (entity.repwd != entity.newpwd)
|
||
{
|
||
jm.msg = GlobalErrorCodeVars.Code11025;
|
||
return jm;
|
||
}
|
||
jm = await _userServices.ChangePassword(_user.ID, entity.newpwd, entity.pwd);
|
||
|
||
return jm;
|
||
}
|
||
#endregion
|
||
|
||
#region 邀请好友(获取我的要求相关信息)
|
||
/// <summary>
|
||
/// 邀请好友(获取我的要求相关信息)
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> MyInvite()
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
jm.status = true;
|
||
|
||
//我的邀请码
|
||
var code = UserHelper.GetShareCodeByUserId(_user.ID);
|
||
//我邀请的人数
|
||
var number = await _userServices.GetCountAsync(p => p.parentId == _user.ID);
|
||
//邀请赚的佣金
|
||
var money = await _userBalanceServices.GetInviteCommission(_user.ID);
|
||
//是否有上级
|
||
var userInfo = await _userServices.QueryByIdAsync(_user.ID);
|
||
bool isSuperior = userInfo != null && userInfo.parentId > 0;
|
||
|
||
jm.data = new
|
||
{
|
||
code,
|
||
number,
|
||
money,
|
||
isSuperior
|
||
};
|
||
return jm;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 设置我的上级邀请人
|
||
/// <summary>
|
||
/// 设置我的上级邀请人
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> SetMyInvite([FromBody] FMIntId entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
if (entity.id == 0)
|
||
{
|
||
jm.msg = "请输入推荐人邀请码！";
|
||
return jm;
|
||
}
|
||
var code = UserHelper.GetUserIdByShareCode(entity.id);
|
||
jm = await _userServices.SetMyInvite(code, _user.ID);
|
||
|
||
return jm;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 获取我的上级邀请人
|
||
/// <summary>
|
||
/// 获取我的上级邀请人
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> GetMyInvite()
|
||
{
|
||
return await _userServices.GetMyInvite(_user.ID);
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 获取我的下级用户数量
|
||
/// <summary>
|
||
/// 获取我的下级用户数量
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> GetMyChildSum()
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
var first = await _userServices.QueryChildCountAsync(_user.ID);
|
||
var second = await _userServices.QueryChildCountAsync(_user.ID, 2);
|
||
|
||
var monthFirst = await _userServices.QueryChildCountAsync(_user.ID, 1, true);
|
||
|
||
var monthSecond = await _userServices.QueryChildCountAsync(_user.ID, 2, true);
|
||
|
||
jm.status = true;
|
||
jm.data = new
|
||
{
|
||
count = first + second,
|
||
first,
|
||
second,
|
||
monthCount = monthFirst + monthSecond,
|
||
monthFirst,
|
||
monthSecond
|
||
};
|
||
|
||
return jm;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 获取用户推荐列表
|
||
/// <summary>
|
||
/// 获取用户推荐列表
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> Recommend([FromBody] FMPageByIntId entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
var where = PredicateBuilder.True<CoreCmsUser>();
|
||
where = where.And(p => p.parentId == _user.ID);
|
||
|
||
var data = await _userServices.QueryPageAsync(where, p => p.createTime, OrderByType.Desc, entity.page, entity.limit);
|
||
|
||
jm.status = true;
|
||
jm.data = data.Select(async p => new
|
||
{
|
||
p.nickName,
|
||
p.avatarImage,
|
||
mobile = UserHelper.FormatMobile(p.mobile),
|
||
p.createTime,
|
||
childNum = await _userServices.GetCountAsync(p => p.parentId == p.id)
|
||
});
|
||
jm.otherData = new
|
||
{
|
||
data.TotalCount,
|
||
data.TotalPages
|
||
};
|
||
|
||
return jm;
|
||
|
||
}
|
||
#endregion
|
||
|
||
#region 获取用户邀请码
|
||
/// <summary>
|
||
/// 获取用户邀请码
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public WebApiCallBack ShareCode()
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
jm.status = true;
|
||
jm.data = UserHelper.GetShareCodeByUserId(_user.ID);
|
||
|
||
return jm;
|
||
|
||
}
|
||
#endregion
|
||
|
||
#region 判断是否签到
|
||
/// <summary>
|
||
/// 判断是否签到
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> IsSign()
|
||
{
|
||
var jm = await _userPointLogServices.IsSign(_user.ID);
|
||
return jm;
|
||
}
|
||
#endregion
|
||
|
||
#region 用户签到
|
||
/// <summary>
|
||
/// 用户签到
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> Sign()
|
||
{
|
||
var jm = await _userPointLogServices.Sign(_user.ID);
|
||
return jm;
|
||
}
|
||
#endregion
|
||
|
||
#region 用户找回密码
|
||
/// <summary>
|
||
/// 用户找回密码
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> ForgetPwd([FromBody] FMForgetPwdPost entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
if (string.IsNullOrEmpty(entity.mobile))
|
||
{
|
||
jm.msg = GlobalErrorCodeVars.Code10051;
|
||
return jm;
|
||
}
|
||
if (string.IsNullOrEmpty(entity.code))
|
||
{
|
||
jm.msg = GlobalErrorCodeVars.Code10013;
|
||
return jm;
|
||
}
|
||
if (string.IsNullOrEmpty(entity.newpwd))
|
||
{
|
||
jm.msg = GlobalErrorCodeVars.Code11013;
|
||
return jm;
|
||
}
|
||
if (string.IsNullOrEmpty(entity.repwd))
|
||
{
|
||
jm.msg = GlobalErrorCodeVars.Code11014;
|
||
return jm;
|
||
}
|
||
if (entity.newpwd != entity.repwd)
|
||
{
|
||
jm.msg = GlobalErrorCodeVars.Code11025;
|
||
return jm;
|
||
}
|
||
jm = await _userServices.ForgetPassword(entity.mobile, entity.code, entity.newpwd);
|
||
|
||
return jm;
|
||
}
|
||
#endregion
|
||
|
||
#region 取得服务卡列表信息
|
||
/// <summary>
|
||
/// 取得服务卡列表信息
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> GetServicesPageList([FromBody] FMPageByIntId entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
var where = PredicateBuilder.True<CoreCmsUserServicesOrder>();
|
||
//where = where.And(p => p.status == (int)GlobalEnumVars.ServicesStatus.Shelve);
|
||
where = where.And(p => p.userId == _user.ID);
|
||
where = where.And(p => p.isPay == true);
|
||
|
||
var orders = await _userServicesOrderServices.QueryPageAsync(where, p => p.payTime, OrderByType.Desc, entity.page, entity.limit);
|
||
|
||
if (orders.Any())
|
||
{
|
||
var services = await _servicesServices.QueryAsync();
|
||
foreach (var item in orders)
|
||
{
|
||
item.service = services.Find(p => p.id == item.servicesId);
|
||
var entityModel = EnumHelper.GetEnumberEntity<GlobalEnumVars.ServicesOrderStatus>(item.status);
|
||
item.statusStr = entityModel.title;
|
||
}
|
||
}
|
||
|
||
jm.status = true;
|
||
jm.data = new
|
||
{
|
||
list = orders,
|
||
count = orders.TotalCount,
|
||
};
|
||
return jm;
|
||
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 获取单个服务订单
|
||
/// <summary>
|
||
/// 获取单个服务订单
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> GetServicesById([FromBody] FMStringId entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
|
||
var order = await _userServicesOrderServices.QueryByClauseAsync(p => p.serviceOrderId == entity.id && p.userId == _user.ID);
|
||
if (order == null)
|
||
{
|
||
jm.msg = "订单信息获取失败";
|
||
return jm;
|
||
}
|
||
var model = await _servicesServices.QueryByClauseAsync(p => p.id == order.servicesId);
|
||
if (model != null)
|
||
{
|
||
var dt = DateTime.Now;
|
||
TimeSpan ts = model.endTime.Subtract(dt);
|
||
model.timestamp = (int)ts.TotalSeconds;
|
||
|
||
if (!string.IsNullOrEmpty(model.consumableStore))
|
||
{
|
||
var consumableStoreStr = CommonHelper.GetCaptureInterceptedText(model.consumableStore, ",");
|
||
var consumableStoreIds = CommonHelper.StringToIntArray(consumableStoreStr);
|
||
if (consumableStoreIds.Any())
|
||
{
|
||
var stores = await _storeServices.QueryListByClauseAsync(p => consumableStoreIds.Contains(p.id));
|
||
model.consumableStores = stores.Select(p => p.storeName).ToList();
|
||
}
|
||
}
|
||
if (!string.IsNullOrEmpty(model.allowedMembership))
|
||
{
|
||
var allowedMembershipStr = CommonHelper.GetCaptureInterceptedText(model.allowedMembership, ",");
|
||
var allowedMembershipIds = CommonHelper.StringToIntArray(allowedMembershipStr);
|
||
if (allowedMembershipIds.Any())
|
||
{
|
||
var userGrades = await _userGradeServices.QueryListByClauseAsync(p => allowedMembershipIds.Contains(p.id));
|
||
model.allowedMemberships = userGrades.Select(p => p.title).ToList();
|
||
}
|
||
}
|
||
}
|
||
|
||
jm.status = true;
|
||
jm.data = model;
|
||
return jm;
|
||
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 取得服务卡列表信息
|
||
/// <summary>
|
||
/// 取得服务卡列表信息
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
[Authorize]
|
||
public async Task<WebApiCallBack> GetServicesTickets([FromBody] FMPageByStringIdWhitStatus entity)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
var order = await _userServicesOrderServices.QueryByClauseAsync(p => p.serviceOrderId == entity.id && p.userId == _user.ID);
|
||
if (order == null)
|
||
{
|
||
jm.msg = "订单信息获取失败";
|
||
return jm;
|
||
}
|
||
|
||
var service = await _servicesServices.QueryByClauseAsync(p => p.id == order.servicesId, true);
|
||
if (service == null)
|
||
{
|
||
jm.msg = "服务商品获取失败";
|
||
return jm;
|
||
}
|
||
|
||
var status = entity.status switch
|
||
{
|
||
(int)GlobalEnumVars.ServicesTicketStatus.过期 => (int)GlobalEnumVars.ServicesTicketStatus.过期,
|
||
(int)GlobalEnumVars.ServicesTicketStatus.作废 => (int)GlobalEnumVars.ServicesTicketStatus.作废,
|
||
(int)GlobalEnumVars.ServicesTicketStatus.已核销 => (int)GlobalEnumVars.ServicesTicketStatus.已核销,
|
||
_ => (int)GlobalEnumVars.ServicesTicketStatus.正常
|
||
};
|
||
|
||
var where = PredicateBuilder.True<CoreCmsUserServicesTicket>();
|
||
where = where.And(p => p.serviceOrderId == entity.id);
|
||
|
||
var dt = DateTime.Now;
|
||
if (service.validityType == 2 && status == (int)GlobalEnumVars.ServicesTicketStatus.过期)
|
||
{
|
||
where = where.And(p => dt > p.validityEndTime);
|
||
}
|
||
else if (service.validityType == 2 && status != (int)GlobalEnumVars.ServicesTicketStatus.过期)
|
||
{
|
||
where = where.And(p => p.validityStartTime < dt && p.validityEndTime > dt && p.status == status);
|
||
}
|
||
|
||
|
||
var tickets = await _userServicesTicketServices.QueryPageAsync(where, p => p.createTime, OrderByType.Asc, entity.page, entity.limit);
|
||
if (tickets.Any())
|
||
{
|
||
foreach (var item in tickets)
|
||
{
|
||
var entityModel = EnumHelper.GetEnumberEntity<GlobalEnumVars.ServicesTicketStatus>(item.status);
|
||
item.statusStr = entityModel.title;
|
||
}
|
||
}
|
||
|
||
jm.status = true;
|
||
jm.data = tickets;
|
||
return jm;
|
||
|
||
}
|
||
|
||
#endregion
|
||
|
||
}
|
||
} |