/***********************************************************************
* Project: CoreCms
* ProjectName: 百分兵法管理系统
* Web: hhtp://chuanyin.com
* Author:
* Email:
* CreateTime: 202403/02
* 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
{
///
/// 用户操作事件
///
[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;
///
/// 构造函数
///
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
, 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登陆成功之后发送的请求=========================================================
///
/// wx.login登陆成功之后发送的请求
///
///
///
[HttpPost]
public async Task 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 {
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 {
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 微信核验数据并获取用户详细资料=====================================================
///
/// 核验数据并获取用户详细资料
///
///
///
[HttpPost]
public async Task 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 {
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 用户短信发送===================================================================
///
/// 用户短信发送
///
///
///
[HttpPost]
public async Task 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 手机短信验证码登陆，同时兼有手机短信注册的功能，还有第三方账户绑定的功能======================================================
///
/// 手机短信验证码登陆，同时兼有手机短信注册的功能，还有第三方账户绑定的功能
///
///
///
[HttpPost]
public async Task SmsLogin([FromBody] FMWxAccountCreate entity)
{
var jm = await _userServices.SmsLogin(entity, (int)GlobalEnumVars.LoginType.Sms, entity.platform);
return jm;
}
#endregion
#region 微信小程序授权拉取手机号码
///
/// 微信小程序授权拉取手机号码
///
///
///
[HttpPost]
public async Task 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(弃用)======================================================
///
/// 用户短信注册并返回jwt token(弃用)
///
///
///
[Obsolete]
[HttpPost]
public async Task 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 {
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
///
/// 获取区域ID
///
///
///
[HttpPost]
public async Task GetAreaId([FromBody] GetAreaIdPost entity)
{
var jm = await _areaServices.GetAreaId(entity.provinceName, entity.cityName, entity.countyName, entity.postalCode);
return jm;
}
#endregion
#region 根据三级联动名称获取城市id信息
///
/// 根据三级联动名称获取城市id信息
///
///
///
[HttpPost]
public async Task 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 注销登录
///
/// 注销登录
///
///
[HttpPost]
public WebApiCallBack LogOut()
{
var jm = new WebApiCallBack
{
status = true,
data = new
{
token = "", //直接前端删除token-无为而治
}
};
return jm;
}
#endregion
#region 判断是否开启积分
///
/// 判断是否开启积分
///
///
[HttpPost]
public async Task 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处理
///
/// 统一分享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
///
///
/// array
[HttpPost]
public async Task 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 统一分享解码
///
/// 统一分享解码
///
///
///
[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 同步微信用户数据=====================================================
///
/// 同步微信用户数据
///
///
///
[Authorize]
[HttpPost]
public async Task 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 获取用户信息
///
/// 获取用户信息
///
///
[HttpPost]
[Authorize]
public async Task 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 获取购物车商品数量
///
/// 获取购物车商品数量
///
///
[HttpPost]
[Authorize]
public async Task 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 获取购物车商品数量
///
/// 获取购物车商品数量
///
///
[HttpPost]
[Authorize]
public async Task 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 商品取消/添加收藏
///
/// 商品取消/添加收藏
///
///
[HttpPost]
[Authorize]
public async Task 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 获取用户获取用户默认收货地址
///
/// 获取用户获取用户默认收货地址
///
///
[HttpPost]
[Authorize]
public async Task 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 设置默认地址
///
/// 设置默认地址
///
///
[HttpPost]
[Authorize]
public async Task 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 判断用户下单可以使用多少积分
///
/// 判断用户下单可以使用多少积分
///
///
[HttpPost]
[Authorize]
public async Task 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 获取用户的收货地址列表
///
/// 获取用户的收货地址列表
///
///
[HttpPost]
[Authorize]
public async Task 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 保存用户地址
///
/// 保存用户地址
///
///
///
[HttpPost]
[Authorize]
public async Task 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 获取用户单个地址详情
///
/// 获取用户单个地址详情
///
///
[HttpPost]
[Authorize]
public async Task 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 收货地址删除
///
/// 收货地址删除
///
///
[HttpPost]
[Authorize]
public async Task 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 支付
///
/// 支付
///
///
[HttpPost]
[Authorize]
public async Task 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 订单评价
///
/// 订单评价
///
///
[HttpPost]
[Authorize]
public async Task 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 我的银行卡列表
///
/// 我的银行卡列表
///
///
[HttpPost]
[Authorize]
public async Task GetMyBankcardsList()
{
var jm = await _userBankCardServices.GetMyBankcardsList(_user.ID);
return jm;
}
#endregion
#region 添加银行卡
///
/// 添加银行卡
///
///
[HttpPost]
[Authorize]
public async Task AddBankCards([FromBody] CoreCmsUserBankCard entity)
{
entity.userId = _user.ID;
var jm = await _userBankCardServices.AddBankCards(entity);
return jm;
}
#endregion
#region 设置默认银行卡
///
/// 设置默认银行卡
///
///
[HttpPost]
[Authorize]
public async Task 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 获取银行卡信息
///
/// 获取银行卡信息
///
///
[HttpPost]
[Authorize]
public async Task 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 获取用户默认银行卡信息
///
/// 获取用户默认银行卡信息
///
///
[HttpPost]
[Authorize]
public async Task GetDefaultBankCard()
{
var jm = await _userBankCardServices.GetDefaultBankCard(_user.ID);
return jm;
}
#endregion
#region 删除银行卡信息
///
/// 删除银行卡信息
///
///
[HttpPost]
[Authorize]
public async Task Removebankcard([FromBody] FMIntId entity)
{
var jm = await _userBankCardServices.Removebankcard(entity.id, _user.ID);
return jm;
}
#endregion
#region 获取银行卡组织信息
///
/// 获取银行卡组织信息
///
///
[HttpPost]
[Authorize]
public async Task GetBankCardsOrganization([FromBody] FMStringId entity)
{
var jm = await _userBankCardServices.BankCardsOrganization(entity.id);
return jm;
}
#endregion
#region 提现申请
///
/// 提现申请
///
///
[HttpPost]
[Authorize]
public async Task Cash([FromBody] FMIntId entity)
{
var money = entity.data.ObjectToDecimal(0);
var jm = await _userTocashServices.Tocash(_user.ID, money, entity.id);
return jm;
}
#endregion
#region 提现记录列表
///
/// 提现记录列表
///
///
[HttpPost]
[Authorize]
public async Task CashList([FromBody] FMPageByIntId entity)
{
var jm = await _userTocashServices.UserToCashList(_user.ID, entity.page, entity.limit, entity.id);
return jm;
}
#endregion
#region 获取我的余额明细列表
///
/// 获取我的余额明细列表
///
///
[HttpPost]
[Authorize]
public async Task UserBalance([FromBody] FMGetBalancePost entity)
{
var jm = new WebApiCallBack();
var where = PredicateBuilder.True();
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(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 我的发票列表
///
/// 我的发票列表
///
///
[HttpPost]
[Authorize]
public async Task UserInvoiceList([FromBody] FMPageByIntId entity)
{
var jm = new WebApiCallBack();
var where = PredicateBuilder.True();
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(item.category);
item.typeName = EnumHelper.GetEnumDescriptionByValue(item.type);
item.statusName = EnumHelper.GetEnumDescriptionByValue(item.status);
}
}
jm.status = true;
jm.data = data;
jm.otherData = new
{
data.TotalCount,
data.TotalPages
};
return jm;
}
#endregion
#region 我的积分列表
///
/// 我的积分列表
///
///
[HttpPost]
[Authorize]
public async Task UserPointLog([FromBody] FMPageByIntId entity)
{
var jm = new WebApiCallBack();
var where = PredicateBuilder.True();
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(item.type);
}
}
jm.status = true;
jm.data = data;
jm.otherData = new
{
data.TotalCount,
data.TotalPages
};
return jm;
}
#endregion
#region 取得商品收藏记录（关注）
///
/// 取得商品收藏记录（关注）
///
///
[HttpPost]
[Authorize]
public async Task 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 添加商品收藏（关注）
///
/// 添加商品收藏（关注）
///
///
[HttpPost]
[Authorize]
public async Task GoodsCollection([FromBody] FMIntId entity)
{
var jm = await _goodsCollectionServices.ToAdd(_user.ID, entity.id);
return jm;
}
#endregion
#region 取得商品浏览足迹
///
/// 取得商品浏览足迹
///
///
[HttpPost]
[Authorize]
public async Task 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 添加商品浏览足迹
///
/// 添加商品浏览足迹
///
///
[HttpPost]
[Authorize]
public async Task 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 删除商品浏览足迹
///
/// 删除商品浏览足迹
///
///
[HttpPost]
[Authorize]
public async Task 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 更换头像
///
/// 更换头像
///
///
[HttpPost]
[Authorize]
public async Task 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 编辑用户信息
///
/// 编辑用户信息
///
///
[HttpPost]
[Authorize]
public async Task 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 修改用户密码
///
/// 修改用户密码
///
///
[HttpPost]
[Authorize]
public async Task 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 邀请好友(获取我的要求相关信息)
///
/// 邀请好友(获取我的要求相关信息)
///
///
[HttpPost]
[Authorize]
public async Task 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 设置我的上级邀请人
///
/// 设置我的上级邀请人
///
///
[HttpPost]
[Authorize]
public async Task 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 获取我的上级邀请人
///
/// 获取我的上级邀请人
///
///
[HttpPost]
[Authorize]
public async Task GetMyInvite()
{
return await _userServices.GetMyInvite(_user.ID);
}
#endregion
#region 获取我的下级用户数量
///
/// 获取我的下级用户数量
///
///
[HttpPost]
[Authorize]
public async Task 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 获取用户推荐列表
///
/// 获取用户推荐列表
///
///
[HttpPost]
[Authorize]
public async Task Recommend([FromBody] FMPageByIntId entity)
{
var jm = new WebApiCallBack();
var where = PredicateBuilder.True();
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(p => new
{
p.nickName,
p.avatarImage,
mobile = UserHelper.FormatMobile(p.mobile),
p.createTime,
childNum = _userServices.GetCount(p => p.parentId == p.id)
});
jm.otherData = new
{
data.TotalCount,
data.TotalPages
};
return jm;
}
#endregion
#region 获取用户邀请码
///
/// 获取用户邀请码
///
///
[HttpPost]
[Authorize]
public WebApiCallBack ShareCode()
{
var jm = new WebApiCallBack();
jm.status = true;
jm.data = UserHelper.GetShareCodeByUserId(_user.ID);
return jm;
}
#endregion
#region 判断是否签到
///
/// 判断是否签到
///
///
[HttpPost]
[Authorize]
public async Task IsSign()
{
var jm = await _userPointLogServices.IsSign(_user.ID);
return jm;
}
#endregion
#region 用户签到
///
/// 用户签到
///
///
[HttpPost]
[Authorize]
public async Task Sign()
{
var jm = await _userPointLogServices.Sign(_user.ID);
return jm;
}
#endregion
#region 用户找回密码
///
/// 用户找回密码
///
///
[HttpPost]
[Authorize]
public async Task 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 取得服务卡列表信息
///
/// 取得服务卡列表信息
///
///
[HttpPost]
[Authorize]
public async Task GetServicesPageList([FromBody] FMPageByIntId entity)
{
var jm = new WebApiCallBack();
var where = PredicateBuilder.True();
//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(item.status);
item.statusStr = entityModel.title;
}
}
jm.status = true;
jm.data = new
{
list = orders,
count = orders.TotalCount,
};
return jm;
}
#endregion
#region 获取单个服务订单
///
/// 获取单个服务订单
///
///
[HttpPost]
[Authorize]
public async Task 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 取得服务卡列表信息
///
/// 取得服务卡列表信息
///
///
[HttpPost]
[Authorize]
public async Task 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();
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(item.status);
item.statusStr = entityModel.title;
}
}
jm.status = true;
jm.data = tickets;
return jm;
}
#endregion
}
}