511 lines
19 KiB
C#
511 lines
19 KiB
C#
|
|
using New_College.IServices;
|
|
using New_College.Model.Models;
|
|
using New_College.Services.BASE;
|
|
using New_College.IRepository.Base;
|
|
using New_College.Model.ViewModels;
|
|
using System.Threading.Tasks;
|
|
using New_College.Common;
|
|
using static New_College.Common.AliyunSmsSender;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using New_College.Common.Helper;
|
|
using New_College.Model;
|
|
using LinqKit;
|
|
using New_College.Model.Request;
|
|
using New_College.IRepository;
|
|
using NPOI.SS.Formula.Functions;
|
|
using System.Net.Http;
|
|
using System.Text;
|
|
using Newtonsoft.Json;
|
|
|
|
namespace New_College.Services
|
|
{
|
|
public class V_CustomerInfoServices : BaseServices<V_CustomerInfo>, IV_CustomerInfoServices
|
|
{
|
|
private readonly IBaseRepository<V_CustomerInfo> _dal;
|
|
private readonly IT_BatchlineRepository t_BatchlineRepository;
|
|
private readonly ICasdoorUserRepository _casdoorUserRepository;
|
|
public V_CustomerInfoServices(IBaseRepository<V_CustomerInfo> dal, IT_BatchlineRepository t_Batchline, ICasdoorUserRepository casdoorUserRepository)
|
|
{
|
|
this._dal = dal;
|
|
base.BaseDal = dal;
|
|
t_BatchlineRepository = t_Batchline;
|
|
_casdoorUserRepository = casdoorUserRepository;
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// 同步修改密码
|
|
/// </summary>
|
|
/// <param name="query"></param>
|
|
private async void UpdateCasdoorPwd(CasDoorUpdatePwdDto query)
|
|
{
|
|
try
|
|
{
|
|
DingHookHelper.DingTalkHookMessage("UpdateCasdoorPwd", JsonConvert.SerializeObject(query));
|
|
var list = await _casdoorUserRepository.Query(e => e.id == query.openId);
|
|
if (list != null && list.Count() > 0)
|
|
{
|
|
var updatemodels = list.FirstOrDefault();
|
|
updatemodels.password = query.newPassword;
|
|
var up = await _casdoorUserRepository.Update(updatemodels);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
DingHookHelper.DingTalkHookMessage("UpdateCasdoorPwd", ex.Message);
|
|
}
|
|
//获取access_token
|
|
}
|
|
/// <summary>
|
|
/// 修改用户信息
|
|
/// </summary>
|
|
/// <param name="query"></param>
|
|
/// <returns></returns>
|
|
public async Task<CustomerInfoResult> UpdateCustomerInfo(UpdateCustomerQuery query)
|
|
{
|
|
DingHookHelper.DingTalkHookMessage("UpdateCustomerInfo", JsonConvert.SerializeObject(query));
|
|
var info = await _dal.QueryById(query.Id);
|
|
if (info == null)
|
|
return new CustomerInfoResult() { Status = 3 };
|
|
info.NickName = query.NickName;
|
|
//info.Phone = query.Phone;
|
|
info.Gender = query.Gender;
|
|
info.AvatarUrl = query.AvatarUrl;
|
|
DingHookHelper.DingTalkHookMessage("CasDoorUpdate", query.service_token);
|
|
|
|
if (!string.IsNullOrWhiteSpace(query.UserPwd))
|
|
{
|
|
UpdateCasdoorPwd(new CasDoorUpdatePwdDto()
|
|
{
|
|
newPassword = query.UserPwd,
|
|
openId = info.OpenId,
|
|
service_token = query.service_token
|
|
});
|
|
var salt = RadomHelper.RandCode(6);
|
|
info.UserPwd = MD5Helper.MD5Encrypt16(query.UserPwd + salt);
|
|
}
|
|
var result = await _dal.Update(info);
|
|
return new CustomerInfoResult()
|
|
{
|
|
Status = 1,
|
|
AvatarUrl = info.AvatarUrl,
|
|
Gender = info.Gender,
|
|
Id = info.Id,
|
|
OpenId = info.OpenId,
|
|
NickName = info.NickName,
|
|
AreaId = info.AreaId,
|
|
AreaName = info.AreaName,
|
|
Datainit = info.Datainit,
|
|
Expectedscore = info.Expectedscore,
|
|
IsVIP = info.IsVIP,
|
|
Subject = info.Subject,
|
|
Subjectgroup = info.Subjectgroup,
|
|
subjectgroupName = info.subjectgroupName,
|
|
VipCode = info.VipCode,
|
|
IsUpdateScore = info.IsUpdateScore,
|
|
Year = info.Year
|
|
};
|
|
}
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
/// 更改分数和学科
|
|
/// </summary>
|
|
/// <param name="query"></param>
|
|
/// <returns></returns>
|
|
public async Task<CustomerInfoResult> UpdateScore(UpdateScoreQuery query)
|
|
{
|
|
var info = await _dal.QueryById(query.StudentId);
|
|
if (info == null)
|
|
return new CustomerInfoResult() { Status = 3 };
|
|
info.IsUpdateScore += 1;
|
|
info.Expectedscore = query.Score;
|
|
info.Subject = query.Subject;
|
|
info.Subjectgroup = query.Subjectgroup;
|
|
info.subjectgroupName = query.subjectgroupName;
|
|
var result = await _dal.Update(info);
|
|
if (result)
|
|
{
|
|
return new CustomerInfoResult()
|
|
{
|
|
Status = 1,
|
|
AvatarUrl = info.AvatarUrl,
|
|
Gender = info.Gender,
|
|
Id = info.Id,
|
|
OpenId = info.OpenId,
|
|
NickName = info.NickName,
|
|
AreaId = info.AreaId,
|
|
AreaName = info.AreaName,
|
|
Datainit = info.Datainit,
|
|
Expectedscore = info.Expectedscore,
|
|
IsVIP = info.IsVIP,
|
|
Subject = info.Subject,
|
|
Subjectgroup = info.Subjectgroup,
|
|
subjectgroupName = info.subjectgroupName,
|
|
VipCode = info.VipCode,
|
|
IsUpdateScore = info.IsUpdateScore,
|
|
Year = info.Year
|
|
};
|
|
}
|
|
else
|
|
{
|
|
return new CustomerInfoResult() { Status = 3 };
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/// <summary>
|
|
/// 完善用户信息
|
|
/// </summary>
|
|
/// <param name="query"></param>
|
|
/// <returns></returns>
|
|
public async Task<CustomerInfoResult> UpdateCustomer(CustomerUpdateQuery query)
|
|
{
|
|
var info = await _dal.QueryById(query.StudentId);
|
|
if (info == null)
|
|
return new CustomerInfoResult() { Status = 3 };
|
|
|
|
if (query.AreaId > 0)
|
|
{
|
|
info.AreaId = query.AreaId;
|
|
}
|
|
if (query.Gender.HasValue && query.Gender > 0)
|
|
{
|
|
info.Gender = query.Gender.Value;
|
|
}
|
|
if (!string.IsNullOrEmpty(query.AreaName))
|
|
{
|
|
info.AreaName = query.AreaName;
|
|
}
|
|
if (query.Subject >= 0)
|
|
{
|
|
info.Subject = query.Subject;
|
|
}
|
|
if (!string.IsNullOrEmpty(query.NickName))
|
|
{
|
|
info.NickName = query.NickName;
|
|
}
|
|
|
|
if (!string.IsNullOrEmpty(query.Subjectgroup))
|
|
{
|
|
info.Subjectgroup = query.Subjectgroup;
|
|
}
|
|
if (!string.IsNullOrEmpty(query.subjectgroupName))
|
|
{
|
|
info.subjectgroupName = query.subjectgroupName;
|
|
}
|
|
if (query.Expectedscore > 0)
|
|
{
|
|
|
|
info.Expectedscore = query.Expectedscore;
|
|
}
|
|
if (query.Year > 0)
|
|
{
|
|
info.Datainit = true;
|
|
info.Year = query.Year;
|
|
}
|
|
if (!string.IsNullOrEmpty(query.SchoolName))
|
|
{
|
|
info.SchoolName = query.SchoolName;
|
|
}
|
|
if (!string.IsNullOrEmpty(query.ClassName))
|
|
{
|
|
info.ClassName = query.ClassName;
|
|
}
|
|
|
|
if (!string.IsNullOrEmpty(query.Phone))
|
|
{
|
|
info.Phone = query.Phone;
|
|
}
|
|
if (!string.IsNullOrEmpty(query.AvatarUrl))
|
|
{
|
|
info.AvatarUrl = query.AvatarUrl;
|
|
}
|
|
var result = await _dal.Update(info);
|
|
if (result)
|
|
{
|
|
return new CustomerInfoResult()
|
|
{
|
|
Status = 1,
|
|
AvatarUrl = info.AvatarUrl,
|
|
Gender = info.Gender,
|
|
Id = info.Id,
|
|
OpenId = info.OpenId,
|
|
NickName = info.NickName,
|
|
AreaId = info.AreaId,
|
|
AreaName = info.AreaName,
|
|
Datainit = info.Datainit,
|
|
Expectedscore = info.Expectedscore,
|
|
IsVIP = info.IsVIP,
|
|
Subject = info.Subject,
|
|
Subjectgroup = info.Subjectgroup,
|
|
subjectgroupName = info.subjectgroupName,
|
|
VipCode = info.VipCode,
|
|
IsUpdateScore = info.IsUpdateScore,
|
|
CustomerType = info.CustomerType,
|
|
Phone = info.Phone,
|
|
SchoolName = info.SchoolName,
|
|
ClassName = info.ClassName,
|
|
Year = info.Year
|
|
};
|
|
}
|
|
else
|
|
{
|
|
return new CustomerInfoResult() { Status = 3 };
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 根绝Id获取用户信息
|
|
/// </summary>
|
|
/// <param name="query"></param>
|
|
/// <returns></returns>
|
|
public async Task<MessageModel<CustomerInfoResult>> GetCustomerInfoById(IdQuery query)
|
|
{
|
|
var info = await _dal.QueryById(query.Id);
|
|
if (info == null || info.IsDelete)
|
|
return new MessageModel<CustomerInfoResult>() { success = false, msg = "获取失败，用户信息为空" };
|
|
var years = info.Year > 2023 ? 2023 : info.Year;
|
|
var batchlist = await t_BatchlineRepository.Query(c => c.Year == years && c.AreaName == info.AreaName && c.Type_name == "综合");
|
|
|
|
return new MessageModel<CustomerInfoResult>()
|
|
{
|
|
success = true,
|
|
msg = "获取成功",
|
|
response = new CustomerInfoResult()
|
|
{
|
|
AvatarUrl = info.AvatarUrl,
|
|
UserCode = info.UserCode,
|
|
Gender = info.Gender,
|
|
Id = info.Id,
|
|
OpenId = info.OpenId,
|
|
NickName = info.NickName,
|
|
AreaId = info.AreaId,
|
|
AreaName = info.AreaName,
|
|
Datainit = info.Datainit,
|
|
Expectedscore = info.Expectedscore,
|
|
Phone = info.Phone,
|
|
Rank = info.Rank,
|
|
IsVIP = info.IsVIP,
|
|
Subject = info.Subject,
|
|
Subjectgroup = info.Subjectgroup,
|
|
subjectgroupName = info.subjectgroupName,
|
|
VipCode = info.VipCode,
|
|
IsUpdateScore = info.IsUpdateScore,
|
|
Year = info.Year,
|
|
SchoolName = info.SchoolName,
|
|
ClassName = info.ClassName,
|
|
BatchName = batchlist.Where(c => c.Batch_name == "普通类一段" && c.Average <= info.Expectedscore).Any() ? "普通类一段" : "普通类二段"
|
|
}
|
|
};
|
|
}
|
|
|
|
/// <summary>
|
|
/// 查询CustomerInfo表信息
|
|
/// </summary>
|
|
/// <param name="query"></param>
|
|
/// <returns></returns>
|
|
public async Task<MessageModel<PageModel<CustomerInfoListResult>>> GetCustomerInfoListByPage(CustomerSeachQuery query)
|
|
{
|
|
var wheres = PredicateBuilder.New<V_CustomerInfo>();
|
|
wheres = wheres.And(x => x.IsDelete == false);
|
|
if (!string.IsNullOrWhiteSpace(query.Phone))
|
|
wheres = wheres.And(x => x.Phone.Contains(query.Phone));
|
|
if (query.Subject != 2)
|
|
wheres = wheres.And(x => (int)x.Subject == query.Subject);
|
|
if (!string.IsNullOrWhiteSpace(query.VipCode))
|
|
wheres = wheres.And(x => x.VipCode.Contains(query.VipCode));
|
|
var info = await _dal.QueryPage(wheres, query.PageIndex, query.PageSize);
|
|
if (info.data.Count <= 0)
|
|
return new MessageModel<PageModel<CustomerInfoListResult>>()
|
|
{
|
|
success = false,
|
|
msg = "获取失败"
|
|
};
|
|
//var regioninfo = await sysRegionRepository.Query(x => x.ParentCode == "100000");
|
|
PageModel<CustomerInfoListResult> pageModel = new PageModel<CustomerInfoListResult>() { };
|
|
List<CustomerInfoListResult> list = new List<CustomerInfoListResult>() { };
|
|
foreach (var item in info.data)
|
|
{
|
|
list.Add(new CustomerInfoListResult()
|
|
{
|
|
Id = item.Id,
|
|
Phone = item.Phone,
|
|
Subject = item.Subject,
|
|
Subjectgroup = item.Subjectgroup,
|
|
AreaName = item.AreaName,
|
|
Expectedscore = item.Expectedscore,
|
|
VipCode = item.VipCode,
|
|
NickName = item.NickName
|
|
});
|
|
}
|
|
pageModel.data = list;
|
|
pageModel.dataCount = info.dataCount;
|
|
pageModel.page = info.page;
|
|
pageModel.pageCount = info.pageCount;
|
|
pageModel.PageSize = info.PageSize;
|
|
return new MessageModel<PageModel<CustomerInfoListResult>>()
|
|
{
|
|
success = true,
|
|
msg = "获取成功",
|
|
response = pageModel
|
|
};
|
|
}
|
|
|
|
public Weixinauthinfo AuthCode2Session(string Code)
|
|
{
|
|
var result = WeixinHelper.AuthCode2Session<Weixinauthinfo>(WeixinConfig.Appid, WeixinConfig.Secret, Code);
|
|
return result;
|
|
|
|
}
|
|
|
|
/// <summary>
|
|
/// 获取accesstoken
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
public Access_Token access_Token()
|
|
{
|
|
return WeixinHelper.GetAccessToken<Access_Token>(WeixinConfig.Appid, WeixinConfig.Secret);
|
|
}
|
|
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
/// <param name="request"></param>
|
|
/// <returns></returns>
|
|
public WxaBusinessGetUserPhoneNumberResponse WxaBusinessGetUserPhoneNumber(WxaBusinessGetUserPhoneNumberRequest request)
|
|
{
|
|
return WeixinHelper.WxaBusinessGetUserPhoneNumber<WxaBusinessGetUserPhoneNumberResponse>(request.access_Token, request.code);
|
|
}
|
|
public string GetWeixinPhone(GetPhoneInfo phoneInfo)
|
|
{
|
|
string phone = string.Empty;
|
|
try
|
|
{
|
|
phone = WeixinHelper.getPhoneNumber(phoneInfo.encryptedData, phoneInfo.iv, phoneInfo.session_key);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
}
|
|
return phone;
|
|
}
|
|
|
|
public async Task<Tuple<bool, CustomerInfoResult>> Logined(LoginQuery query)
|
|
{
|
|
|
|
var userinfo = (await _dal.Query(w => w.OpenId == query.openId && w.IsDelete == false)).ToList().FirstOrDefault();
|
|
if (userinfo != null)
|
|
{
|
|
return new Tuple<bool, CustomerInfoResult>(true, new CustomerInfoResult()
|
|
{
|
|
AreaId = userinfo.AreaId,
|
|
AreaName = userinfo.AreaName,
|
|
AvatarUrl = userinfo.AvatarUrl,
|
|
CustomerType = userinfo.CustomerType,
|
|
NickName = userinfo.NickName,
|
|
OpenId = userinfo.OpenId,
|
|
Phone = userinfo.Phone,
|
|
Gender = userinfo.Gender,
|
|
Datainit = userinfo.Datainit,
|
|
Expectedscore = userinfo.Expectedscore,
|
|
IsVIP = userinfo.IsVIP,
|
|
Subject = userinfo.Subject,
|
|
Subjectgroup = userinfo.Subjectgroup,
|
|
subjectgroupName = userinfo.subjectgroupName,
|
|
ClassName = userinfo.ClassName,
|
|
SchoolName = userinfo.SchoolName,
|
|
Year = userinfo.Year,
|
|
Id = userinfo.Id
|
|
});
|
|
}
|
|
else
|
|
{
|
|
return new Tuple<bool, CustomerInfoResult>(false, null);
|
|
}
|
|
}
|
|
|
|
public async Task<Tuple<bool, CustomerInfoResult>> GetUserInfo(LoginQuery query)
|
|
{
|
|
var userinfo = (await _dal.Query(w => w.OpenId == query.openId && w.IsDelete == false)).ToList().First();
|
|
if (userinfo != null)
|
|
{
|
|
return new Tuple<bool, CustomerInfoResult>(true, new CustomerInfoResult()
|
|
{
|
|
|
|
AreaId = userinfo.AreaId,
|
|
AreaName = userinfo.AreaName,
|
|
AvatarUrl = userinfo.AvatarUrl,
|
|
CustomerType = userinfo.CustomerType,
|
|
NickName = userinfo.NickName,
|
|
OpenId = userinfo.OpenId,
|
|
Phone = userinfo.Phone,
|
|
Gender = userinfo.Gender,
|
|
Datainit = userinfo.Datainit,
|
|
Expectedscore = userinfo.Expectedscore,
|
|
IsVIP = userinfo.IsVIP,
|
|
Subject = userinfo.Subject,
|
|
Subjectgroup = userinfo.Subjectgroup,
|
|
subjectgroupName = userinfo.subjectgroupName,
|
|
Year = userinfo.Year,
|
|
Id = userinfo.Id,
|
|
});
|
|
}
|
|
else
|
|
{
|
|
return new Tuple<bool, CustomerInfoResult>(false, null);
|
|
}
|
|
}
|
|
|
|
public async Task<int> GetCustomerId(string OpenId)
|
|
{
|
|
var customerinfo = await _dal.Query(x => x.IsDelete == false && x.OpenId == OpenId);
|
|
if (customerinfo.Count == 0)
|
|
return -1;
|
|
return customerinfo.FirstOrDefault().Id;
|
|
}
|
|
|
|
public async Task<string> GetOpenId(int CustomerId)
|
|
{
|
|
var customerinfo = await _dal.QueryById(CustomerId);
|
|
if (customerinfo == null)
|
|
return "";
|
|
return customerinfo.OpenId;
|
|
}
|
|
|
|
public async Task<int> CustomerSave(DecryptUserInfoRequest register)
|
|
{
|
|
var i = await _dal.Add(new V_CustomerInfo()
|
|
{
|
|
OpenId = register.openid,
|
|
CustomerType = CustomerTypeEnum.General
|
|
});
|
|
return i;
|
|
}
|
|
|
|
public Task<CustomerInfoResult> Login(CustomerInfoQuery query)
|
|
{
|
|
throw new NotImplementedException();
|
|
}
|
|
|
|
public Task<bool> SendLogin(PhoneQuery query)
|
|
{
|
|
throw new NotImplementedException();
|
|
}
|
|
|
|
public Task<int> ResetPwd(ResetPwdQuery query)
|
|
{
|
|
throw new NotImplementedException();
|
|
}
|
|
|
|
public Task<bool> SendReset(PhoneQuery query)
|
|
{
|
|
throw new NotImplementedException();
|
|
}
|
|
}
|
|
} |