/***********************************************************************
|
* Project: baifenBinfa
|
* ProjectName: 百分兵法管理系统
|
* Web: http://chuanyin.com
|
* Author:
|
* Email:
|
* CreateTime: 202403/02
|
* Description: 暂无
|
***********************************************************************/
|
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Linq.Expressions;
|
using System.Threading.Tasks;
|
using CoreCms.Net.Auth;
|
using CoreCms.Net.Configuration;
|
using CoreCms.Net.IRepository;
|
using CoreCms.Net.IRepository.UnitOfWork;
|
using CoreCms.Net.IServices;
|
using CoreCms.Net.Model.Entities;
|
using CoreCms.Net.Model.FromBody;
|
using CoreCms.Net.Model.ViewModels.Basics;
|
using CoreCms.Net.Model.ViewModels.UI;
|
using CoreCms.Net.Utility.Extensions;
|
using CoreCms.Net.Utility.Helper;
|
using Microsoft.AspNetCore.Http;
|
using Microsoft.AspNetCore.Http.Extensions;
|
using Newtonsoft.Json;
|
using Newtonsoft.Json.Linq;
|
using SqlSugar;
|
|
|
namespace CoreCms.Net.Services
|
{
|
/// <summary>
|
/// 表单 接口实现
|
/// </summary>
|
public class CoreCmsFormServices : BaseServices<CoreCmsForm>, ICoreCmsFormServices
|
{
|
private readonly ICoreCmsFormRepository _dal;
|
private readonly ICoreCmsFormItemRepository _itemRepository;
|
private readonly ICoreCmsFormSubmitServices _formSubmitServices;
|
private readonly ICoreCmsFormSubmitDetailServices _formSubmitDetailServices;
|
private readonly ICoreCmsProductsServices _productsServices;
|
private readonly ICoreCmsAreaServices _areaServices;
|
|
private IHttpContextAccessor _httpContextAccessor;
|
|
private readonly ICoreCmsGoodsServices _goodsServices;
|
private readonly IUnitOfWork _unitOfWork;
|
public CoreCmsFormServices(IUnitOfWork unitOfWork, ICoreCmsFormRepository dal, ICoreCmsFormItemRepository itemRepository, ICoreCmsGoodsServices goodsServices, ICoreCmsFormSubmitServices formSubmitServices, IHttpContextAccessor httpContextAccessor, ICoreCmsAreaServices areaServices, ICoreCmsFormSubmitDetailServices formSubmitDetailServices, ICoreCmsProductsServices productsServices)
|
{
|
this._dal = dal;
|
_itemRepository = itemRepository;
|
_goodsServices = goodsServices;
|
_formSubmitServices = formSubmitServices;
|
_httpContextAccessor = httpContextAccessor;
|
_areaServices = areaServices;
|
_formSubmitDetailServices = formSubmitDetailServices;
|
_productsServices = productsServices;
|
base.BaseDal = dal;
|
_unitOfWork = unitOfWork;
|
}
|
|
|
/// <summary>
|
/// 重写异步插入方法
|
/// </summary>
|
/// <param name="entity">实体数据</param>
|
/// <returns></returns>
|
public async Task<AdminUiCallBack> InsertAsync(FMForm entity)
|
{
|
return await _dal.InsertAsync(entity);
|
}
|
|
|
/// <summary>
|
/// 重写异步更新方法方法
|
/// </summary>
|
/// <param name="entity"></param>
|
/// <returns></returns>
|
public async Task<AdminUiCallBack> UpdateAsync(FMForm entity)
|
{
|
return await _dal.UpdateAsync(entity);
|
}
|
|
/// <summary>
|
/// 重写删除指定ID的数据
|
/// </summary>
|
/// <param name="id"></param>
|
/// <returns></returns>
|
public async Task<AdminUiCallBack> DeleteByIdAsync(int id)
|
{
|
return await _dal.DeleteByIdAsync(id);
|
}
|
|
/// <summary>
|
/// 重写根据条件查询分页数据
|
/// </summary>
|
/// <param name="predicate">判断集合</param>
|
/// <param name="orderByType">排序方式</param>
|
/// <param name="pageIndex">当前页面索引</param>
|
/// <param name="pageSize">分布大小</param>
|
/// <param name="orderByExpression"></param>
|
/// <param name="blUseNoLock">是否使用WITH(NOLOCK)</param>
|
/// <returns></returns>
|
public async Task<IPageList<CoreCmsForm>> QueryPageAsync(Expression<Func<CoreCmsForm, bool>> predicate,
|
Expression<Func<CoreCmsForm, object>> orderByExpression, OrderByType orderByType, int pageIndex = 1,
|
int pageSize = 20, bool blUseNoLock = false)
|
{
|
return await _dal.QueryPageAsync(predicate, orderByExpression, orderByType, pageIndex, pageSize, blUseNoLock);
|
}
|
|
/// <summary>
|
/// 获取form表单详情
|
/// </summary>
|
/// <param name="id"></param>
|
/// <param name="token"></param>
|
/// <param name="noToken"></param>
|
/// <returns></returns>
|
public async Task<WebApiCallBack> GetFormInfo(int id, string token, bool noToken = false)
|
{
|
var jm = new WebApiCallBack();
|
|
if (id == 0)
|
{
|
jm.msg = GlobalErrorCodeVars.Code10051;
|
jm.status = false;
|
return jm;
|
}
|
var formModel = await _dal.QueryByIdAsync(id);
|
if (formModel == null)
|
{
|
jm.msg = GlobalErrorCodeVars.Code18008;
|
return jm;
|
}
|
|
var dt = DateTime.Now;
|
//检查过期时间
|
if (formModel.endDateTime < dt && noToken == false)
|
{
|
jm.msg = GlobalErrorCodeVars.Code18002;
|
jm.data = new
|
{
|
isExpires = true,
|
needLogin = false
|
};
|
return jm;
|
}
|
|
//如果是后台，则不验证token
|
if (noToken)
|
{
|
formModel.isLogin = false;
|
}
|
if (formModel.isLogin && string.IsNullOrEmpty(token))
|
{
|
jm.msg = GlobalErrorCodeVars.Code14006;
|
jm.data = new
|
{
|
needLogin = true,
|
isExpires = false,
|
};
|
return jm;
|
}
|
else if (formModel.isLogin && !string.IsNullOrEmpty(token))
|
{
|
var userId = TokenHelper.GetUserIdBySecurityToken(token);
|
jm.otherData = userId;
|
if (userId <= 0)
|
{
|
jm.msg = GlobalErrorCodeVars.Code14006;
|
jm.data = new
|
{
|
needLogin = true,
|
isExpires = false,
|
};
|
return jm;
|
}
|
}
|
|
|
var items = await _itemRepository.QueryListByClauseAsync(p => p.formId == formModel.id, p => p.sort, OrderByType.Asc);
|
foreach (var item in items)
|
{
|
|
if (item.type == GlobalEnumVars.FormFieldTypes.goods.ToString())
|
{
|
if (noToken == false)
|
{
|
var goodId = Convert.ToInt32(item.value);
|
if (goodId > 0)
|
{
|
item.good = await _goodsServices.GetGoodsDetail(goodId, 0, false, "goods", 0, true);
|
}
|
}
|
}
|
else if (item.type == GlobalEnumVars.FormFieldTypes.radio.ToString())
|
{
|
item.radioValue = item.value.Split(",").ToList();
|
}
|
else if (item.type == GlobalEnumVars.FormFieldTypes.checbox.ToString())
|
{
|
var valueArray = item.value.Split(",");
|
var defaultArray = item.defaultValue.Split(",");
|
|
var tempCheckbox = new List<TempCheckbox>();
|
foreach (var v in valueArray)
|
{
|
var t = new TempCheckbox { @checked = defaultArray.Contains(v), value = v };
|
tempCheckbox.Add(t);
|
}
|
item.checkboxValue = tempCheckbox;
|
}
|
else if (item.type == GlobalEnumVars.FormFieldTypes.date.ToString())
|
{
|
//没有值的时候设置下默认值
|
if (string.IsNullOrEmpty(item.defaultValue))
|
{
|
item.defaultValue = dt.ToString("yyyy-MM-hh");
|
}
|
}
|
else if (item.type == GlobalEnumVars.FormFieldTypes.time.ToString())
|
{
|
//没有值的时候设置下默认值
|
if (string.IsNullOrEmpty(item.defaultValue))
|
{
|
item.defaultValue = dt.ToString("HH:mm");
|
}
|
}
|
}
|
formModel.Items = items;
|
|
|
jm.status = true;
|
jm.code = 0;
|
jm.data = formModel;
|
jm.msg = "获取成功";
|
|
return jm;
|
}
|
|
|
/// <summary>
|
/// 重写删除指定ID集合的数据(批量删除)
|
/// </summary>
|
/// <param name="entity"></param>
|
/// <returns></returns>
|
public async Task<WebApiCallBack> AddSubmit(FmAddSubmit entity)
|
{
|
var jm = new WebApiCallBack();
|
jm.msg = GlobalErrorCodeVars.Code18001;
|
|
var formModel = await _dal.QueryByIdAsync(entity.id);
|
if (formModel == null)
|
{
|
jm.msg = GlobalErrorCodeVars.Code18008;
|
return jm;
|
}
|
|
if (formModel.isLogin && string.IsNullOrEmpty(entity.token))
|
{
|
jm.msg = GlobalErrorCodeVars.Code14006;
|
jm.data = new
|
{
|
needLogin = true
|
};
|
return jm;
|
}
|
|
var dt = DateTime.Now;
|
//检查过期时间
|
if (formModel.endDateTime < dt)
|
{
|
jm.msg = GlobalErrorCodeVars.Code18002;
|
return jm;
|
}
|
|
decimal money = 0;
|
|
//todo 金额促销
|
//付款码
|
if (formModel.type == (int)GlobalEnumVars.FormTypes.付款码)
|
{
|
var items = await _itemRepository.QueryListByClauseAsync(p => p.formId == formModel.id && p.type == GlobalEnumVars.FormFieldTypes.money.ToString());
|
if (items.Any())
|
{
|
items.ForEach(p =>
|
{
|
var post = entity.data.Find(o => o.key == p.id);
|
money += (decimal)(post?.value.ObjectToFloat(0) ?? 0);
|
});
|
}
|
}
|
|
var userId = 0;
|
if (!string.IsNullOrEmpty(entity.token))
|
{
|
userId = TokenHelper.GetUserIdBySecurityToken(entity.token);
|
}
|
//判断提交次数
|
if (formModel.times > 0 && !string.IsNullOrEmpty(entity.token))
|
{
|
if (userId <= 0)
|
{
|
jm.msg = GlobalErrorCodeVars.Code18012;
|
return jm;
|
}
|
|
var count = await _formSubmitServices.GetCountAsync(p => p.userId == userId && p.formId == formModel.id);
|
if (count >= formModel.times)
|
{
|
jm.msg = GlobalErrorCodeVars.Code18003;
|
return jm;
|
}
|
}
|
|
try
|
{
|
_unitOfWork.BeginTran();
|
var formSubmitModel = new CoreCmsFormSubmit();
|
formSubmitModel.formId = formModel.id;
|
formSubmitModel.formName = formModel.name;
|
formSubmitModel.userId = userId;
|
formSubmitModel.money = money;
|
formSubmitModel.payStatus = false;
|
formSubmitModel.status = false;
|
formSubmitModel.createTime = DateTime.Now;
|
formSubmitModel.ip = _httpContextAccessor.HttpContext.Connection.RemoteIpAddress.ToString();
|
|
var formSubmitId = await _formSubmitServices.InsertReturnIdentityAsync(formSubmitModel);
|
|
if (formSubmitId <= 0)
|
{
|
_unitOfWork.RollbackTran();
|
jm.msg = GlobalErrorCodeVars.Code18005;
|
return jm;
|
}
|
|
if (entity.data.Count > 0)
|
{
|
//根据提交的数据取字段列表（已废弃）
|
//var formitemIds = entity.data.Select(p => p.key).ToList();
|
//var formItems = await _itemRepository.QueryListByClauseAsync(p => formitemIds.Contains(p.id));
|
|
//查询表单展示字段
|
var formItems = await _itemRepository.QueryListByClauseAsync(p => p.formId == formModel.id, p => p.sort, OrderByType.Asc);
|
|
var sDetails = new List<CoreCmsFormSubmitDetail>();
|
|
//遍历表单字段项
|
foreach (var item in formItems)
|
{
|
//获取提交的哪些
|
var postItem = entity.data.Find(p => p.key == item.id);
|
if (postItem == null)
|
{
|
_unitOfWork.RollbackTran();
|
jm.msg = item.name + GlobalErrorCodeVars.Code18020;
|
return jm;
|
}
|
string value = postItem.value;
|
|
//验证数据格式
|
if (FormHelper.ValidateField(item.validationType, postItem.value))
|
{
|
_unitOfWork.RollbackTran();
|
}
|
//如果必填但数据为空。
|
if (item.required && string.IsNullOrEmpty(postItem.value))
|
{
|
_unitOfWork.RollbackTran();
|
jm.msg = GlobalErrorCodeVars.Code18006 + item.name;
|
return jm;
|
}
|
//验证地区
|
if (item.type == GlobalEnumVars.FormFieldTypes.area.ToString() && !string.IsNullOrEmpty(postItem.value))
|
{
|
//var arr = postItem.value.Split(" ");
|
|
//var countyName = arr[2];
|
//var cityName = arr[1];
|
//var provinceName = arr[0];
|
|
//var areaId = await _areaServices.GetThreeAreaId(provinceName, cityName, countyName, "");
|
//value = areaId.ToString();
|
|
value = postItem.value;
|
}
|
|
if (item.type == GlobalEnumVars.FormFieldTypes.goods.ToString() && !string.IsNullOrEmpty(postItem.value))
|
{
|
var goods = JsonConvert.DeserializeObject<List<FmAddSubmitItemGoods>>(postItem.value);
|
if (goods.Any())
|
{
|
foreach (var good in goods)
|
{
|
var product = await _productsServices.GetProductInfo(good.productId, false, 0);
|
if (product == null)
|
{
|
_unitOfWork.RollbackTran();
|
jm.msg = GlobalErrorCodeVars.Code12501;
|
return jm;
|
}
|
|
var formItemName = !string.IsNullOrEmpty(product.spesDesc)
|
? product.spesDesc + "/" + product.sn
|
: product.sn;
|
|
money += product.price * good.nums;
|
var sDetail = new CoreCmsFormSubmitDetail();
|
sDetail.submitId = formSubmitId;
|
sDetail.formId = formModel.id;
|
sDetail.formItemId = item.id;
|
sDetail.formItemName = formItemName;
|
sDetail.formItemValue = good.nums.ToString();
|
sDetails.Add(sDetail);
|
}
|
}
|
}
|
else
|
{
|
var sDetail = new CoreCmsFormSubmitDetail();
|
sDetail.submitId = formSubmitId;
|
sDetail.formId = formModel.id;
|
sDetail.formItemId = item.id;
|
sDetail.formItemName = item.name;
|
sDetail.formItemValue = value;
|
sDetails.Add(sDetail);
|
}
|
}
|
var sDetailResult = await _formSubmitDetailServices.InsertAsync(sDetails);
|
if (sDetailResult <= 0)
|
{
|
_unitOfWork.RollbackTran();
|
jm.msg = GlobalErrorCodeVars.Code18007;
|
return jm;
|
}
|
}
|
|
if (formModel.type == (int)GlobalEnumVars.FormTypes.订单)
|
{
|
//订单类型时，更新提交表单金额
|
await _formSubmitServices.UpdateAsync(p => new CoreCmsFormSubmit() { money = money }, p => p.id == formSubmitId);
|
}
|
|
jm.data = new
|
{
|
formSubmitId,
|
money
|
};
|
|
_unitOfWork.CommitTran();
|
|
jm.status = true;
|
jm.msg = "提交成功";
|
|
}
|
catch (Exception e)
|
{
|
_unitOfWork.RollbackTran();
|
jm.status = false;
|
jm.msg = "操作异常";
|
jm.data = e;
|
}
|
|
return jm;
|
}
|
|
|
}
|
}
|
