You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
469 lines
23 KiB
469 lines
23 KiB
using BBWY.Common.Extensions;
|
|
using BBWY.Common.Http;
|
|
using BBWY.Common.Models;
|
|
using BBWY.Server.Model;
|
|
using BBWY.Server.Model.Db;
|
|
using BBWY.Server.Model.Dto;
|
|
using FreeSql;
|
|
using Microsoft.Extensions.Options;
|
|
using Newtonsoft.Json;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Net.Http;
|
|
using Yitter.IdGenerator;
|
|
|
|
namespace BBWY.Server.Business
|
|
{
|
|
public class EvaluationAssistantBusiness : BasePlatformRelayBusiness, IDenpendency
|
|
{
|
|
private IFreeSql fsql;
|
|
|
|
private IIdGenerator idGenerator;
|
|
|
|
public EvaluationAssistantBusiness(RestApiService restApiService, IOptions<GlobalConfig> options, YunDingBusiness yunDingBusiness, IFreeSql fsql, IIdGenerator idGenerator) : base(restApiService, options, yunDingBusiness)
|
|
{
|
|
this.fsql = fsql;
|
|
this.idGenerator = idGenerator;
|
|
}
|
|
|
|
#region 赠品模板
|
|
public void AddOrEditGiftTemplate(AddOrEditGiftTemplateRequest request)
|
|
{
|
|
if (string.IsNullOrEmpty(request.TemplateName))
|
|
throw new BusinessException("缺少模板名称");
|
|
if (request.GiftSkuList == null || request.GiftSkuList.Count() == 0)
|
|
throw new BusinessException("缺少赠品SKU");
|
|
|
|
IInsert<GiftTemplate> insert = null;
|
|
IUpdate<GiftTemplate> update = null;
|
|
|
|
IDelete<GiftTemplateSku> delete = null;
|
|
List<GiftTemplateSku> inserList = null;
|
|
|
|
long giftTemplateId = request.Id;
|
|
if (giftTemplateId == 0)
|
|
{
|
|
giftTemplateId = idGenerator.NewLong();
|
|
var giftTemplate = new GiftTemplate()
|
|
{
|
|
Id = giftTemplateId,
|
|
CreateTime = DateTime.Now,
|
|
TemplateName = request.TemplateName,
|
|
Platform = Enums.Platform.京东,
|
|
ShopId = request.ShopId,
|
|
TemplateSpu = request.TemplateSpu,
|
|
GiftCount = request.GiftSkuList.Count()
|
|
};
|
|
insert = fsql.Insert(giftTemplate);
|
|
}
|
|
else
|
|
{
|
|
update = fsql.Update<GiftTemplate>(giftTemplateId).Set(g => g.TemplateName, request.TemplateName)
|
|
.Set(g => g.TemplateSpu, request.TemplateSpu)
|
|
.Set(g => g.GiftCount, request.GiftSkuList.Count());
|
|
delete = fsql.Delete<GiftTemplateSku>().Where(gs => gs.GiftTemplateId == giftTemplateId);
|
|
}
|
|
|
|
inserList = request.GiftSkuList.Select(gs => new GiftTemplateSku()
|
|
{
|
|
Id = idGenerator.NewLong(),
|
|
CreateTime = DateTime.Now,
|
|
GiftTemplateId = giftTemplateId,
|
|
Logo = gs.Logo,
|
|
Price = gs.Price,
|
|
Title = gs.Title,
|
|
ShopId = request.ShopId,
|
|
SkuId = gs.SkuId,
|
|
SpuId = request.TemplateSpu
|
|
}).ToList();
|
|
|
|
fsql.Transaction(() =>
|
|
{
|
|
insert?.ExecuteAffrows();
|
|
update?.ExecuteAffrows();
|
|
delete?.ExecuteAffrows();
|
|
fsql.Insert(inserList).ExecuteAffrows();
|
|
});
|
|
}
|
|
|
|
public IList<GiftTemplateResponse> GetGiftTemplateList(long shopId)
|
|
{
|
|
var templateList = fsql.Select<GiftTemplate>().Where(g => g.ShopId == shopId).ToList<GiftTemplateResponse>();
|
|
var templateIdList = templateList.Select(g => g.Id).ToList();
|
|
var templateSkuList = fsql.Select<GiftTemplateSku>().Where(gs => templateIdList.Contains(gs.GiftTemplateId.Value)).ToList<GiftTemplateSkuResponse>();
|
|
foreach (var template in templateList)
|
|
{
|
|
template.GiftSkuList = templateSkuList.Where(gs => gs.GiftTemplateId == template.Id).ToList();
|
|
}
|
|
return templateList;
|
|
}
|
|
|
|
public void DeleteGiftTemplate(long giftTemplateId)
|
|
{
|
|
fsql.Transaction(() =>
|
|
{
|
|
fsql.Delete<GiftTemplate>(giftTemplateId).ExecuteAffrows();
|
|
fsql.Delete<GiftTemplateSku>().Where(gs => gs.GiftTemplateId == giftTemplateId).ExecuteAffrows();
|
|
});
|
|
|
|
}
|
|
#endregion
|
|
|
|
#region 评价助手任务
|
|
public void AddOrEditPromotionTask(AddOrEditPromotionTaskRequest request)
|
|
{
|
|
if (string.IsNullOrEmpty(request.MainProductSpu))
|
|
throw new BusinessException("缺少主商品SPU");
|
|
|
|
if (request.MotherTemplateId == 0 && string.IsNullOrEmpty(request.MainProductSku) && string.IsNullOrEmpty(request.CustomMotherSku))
|
|
throw new BusinessException("奶妈模板,奶妈自定义SKU,主商品SKU至少具备一个");
|
|
|
|
if (request.GiftTemplateId == 0 && string.IsNullOrEmpty(request.MainProductGiftSku))
|
|
throw new BusinessException("赠品模板和主商品赠品SKU至少具备一个");
|
|
|
|
if (string.IsNullOrEmpty(request.FullTitle))
|
|
throw new BusinessException("缺少完整标题");
|
|
|
|
if (string.IsNullOrEmpty(request.ActivityName))
|
|
throw new BusinessException("缺少任务名称");
|
|
|
|
if (request.ActivityName.Length > 10)
|
|
throw new BusinessException("任务名称不能超过10个字");
|
|
|
|
if (request.TaskCount == 0)
|
|
throw new BusinessException("任务量不能为0");
|
|
|
|
if (request.Id == 0)
|
|
{
|
|
var relayAPIHost = GetPlatformRelayAPIHost(Enums.Platform.京东);
|
|
var restApiResult_spu = restApiService.SendRequest(relayAPIHost, "api/PlatformSDK/GetProductList", new SearchProductRequest()
|
|
{
|
|
AppKey = request.AppKey,
|
|
AppSecret = request.AppSecret,
|
|
AppToken = request.AppToken,
|
|
PageIndex = 1,
|
|
PageSize = 10,
|
|
Platform = Enums.Platform.京东,
|
|
Spu = request.MainProductSpu
|
|
}, GetYunDingRequestHeader(), HttpMethod.Post);
|
|
if (restApiResult_spu.StatusCode != System.Net.HttpStatusCode.OK)
|
|
throw new BusinessException(restApiResult_spu.Content) { Code = (int)restApiResult_spu.StatusCode };
|
|
var spuResponse = JsonConvert.DeserializeObject<ApiResponse<ProductListResponse>>(restApiResult_spu.Content);
|
|
if (!spuResponse.Success)
|
|
throw new BusinessException(spuResponse.Msg) { Code = spuResponse.Code };
|
|
|
|
var sort = fsql.Select<PromotionTask>().ToAggregate(p => p.Max(p.Key.Sort));
|
|
var promotionTask = new PromotionTask()
|
|
{
|
|
Id = idGenerator.NewLong(),
|
|
ActivityName = request.ActivityName,
|
|
CreateTime = DateTime.Now,
|
|
FullTitle = request.FullTitle,
|
|
ShopId = request.ShopId,
|
|
SimpleTitle = request.SimpleTitle,
|
|
GiftTemplateId = request.GiftTemplateId,
|
|
MainProductGiftSku = request.MainProductGiftSku,
|
|
MainProductSku = request.MainProductSku,
|
|
MainProductSpu = request.MainProductSpu,
|
|
MotherTemplateId = request.MotherTemplateId,
|
|
IsEnabled = true,
|
|
Status = Enums.PromitionTaskStatus.等待,
|
|
PromotionId = 0,
|
|
Sort = sort + 1,
|
|
UpdateSortTime = DateTime.Now,
|
|
SpuLogo = spuResponse.Data.Items[0].Logo,
|
|
SpuPublishTime = spuResponse.Data.Items[0].CreateTime,
|
|
TaskCount = request.TaskCount,
|
|
CustomMotherSku = request.CustomMotherSku
|
|
};
|
|
fsql.Insert(promotionTask).ExecuteAffrows();
|
|
}
|
|
else
|
|
{
|
|
var dbPromotionTask = fsql.Select<PromotionTask>(request.Id).ToOne();
|
|
if (dbPromotionTask == null)
|
|
throw new BusinessException("任务不存在");
|
|
if (dbPromotionTask.Status != Enums.PromitionTaskStatus.等待)
|
|
throw new BusinessException("只能在任务处于等待状态时才能修改");
|
|
|
|
request.Map(dbPromotionTask);
|
|
fsql.Update<PromotionTask>().SetSource(dbPromotionTask)
|
|
.IgnoreColumns(new string[]
|
|
{
|
|
"UpdateSortTime",
|
|
"Sort", "Status",
|
|
"CreateTime",
|
|
"SpuLogo",
|
|
"SpuPublishTime",
|
|
"StartTime",
|
|
"EndTime",
|
|
"StopTime",
|
|
"CompletedTaskCount"
|
|
})
|
|
.ExecuteAffrows();
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 获取任务列表
|
|
/// </summary>
|
|
/// <param name="request"></param>
|
|
/// <returns></returns>
|
|
public PromotionTaskResponse GetPromotionTaskList(QueryPromotionTaskRequest request)
|
|
{
|
|
var list = fsql.Select<PromotionTask>().Where(pt => pt.ShopId == request.ShopId)
|
|
.OrderByDescending(pt => pt.Sort)
|
|
.OrderByDescending(pt => pt.UpdateSortTime)
|
|
.Page(request.PageIndex, request.PageSize)
|
|
.Count(out long count)
|
|
.ToList<PromotionTaskItemResponse>();
|
|
return new PromotionTaskResponse()
|
|
{
|
|
Count = count,
|
|
ItemList = list
|
|
};
|
|
}
|
|
|
|
/// <summary>
|
|
/// 修改任务排序
|
|
/// </summary>
|
|
/// <param name="request"></param>
|
|
public void EditPromotionTaskSort(EditPromotionTaskSortRequest request)
|
|
{
|
|
var dbPromotionTask = fsql.Select<PromotionTask>(request.Id).ToOne();
|
|
PromotionTask oldDbPromotionTask = null;
|
|
if (request.MoveType == 1)
|
|
oldDbPromotionTask = fsql.Select<PromotionTask>().Where(pt => pt.Sort > dbPromotionTask.Sort).OrderBy(pt => pt.Sort).ToOne();
|
|
else
|
|
oldDbPromotionTask = fsql.Select<PromotionTask>().Where(pt => pt.Sort < dbPromotionTask.Sort).OrderByDescending(pt => pt.Sort).ToOne();
|
|
|
|
|
|
if (oldDbPromotionTask != null)
|
|
{
|
|
fsql.Transaction(() =>
|
|
{
|
|
fsql.Update<PromotionTask>(dbPromotionTask.Id).Set(pt => pt.Sort, oldDbPromotionTask.Sort)
|
|
.Set(pt => pt.UpdateSortTime, DateTime.Now)
|
|
.ExecuteAffrows();
|
|
fsql.Update<PromotionTask>(oldDbPromotionTask.Id).Set(pt => pt.Sort, dbPromotionTask.Sort)
|
|
.Set(pt => pt.UpdateSortTime, DateTime.Now)
|
|
.ExecuteAffrows();
|
|
});
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 检查任务重复sku
|
|
/// </summary>
|
|
/// <param name="runingTaskList"></param>
|
|
/// <param name="skuIds"></param>
|
|
private void CheckRepeatSkuInRuningTask(IList<PromotionTask> runingTaskList, string skuIds)
|
|
{
|
|
var skuIdList = skuIds.Split(new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries);
|
|
foreach (var pt in runingTaskList)
|
|
{
|
|
foreach (var sku in skuIdList)
|
|
{
|
|
//判断奶妈模板sku重复
|
|
|
|
//判断自定义奶妈sku重复
|
|
if ((!string.IsNullOrEmpty(pt.CustomMotherSku) && pt.CustomMotherSku.Contains(sku)) ||
|
|
(!string.IsNullOrEmpty(pt.MainProductSku) && pt.MainProductSku.Contains(sku)))
|
|
{
|
|
throw new BusinessException($"sku[{sku}]已存在于任务[{pt.ActivityName}]的奶妈sku中,请删除该sku或等待任务结束");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 开始任务
|
|
/// </summary>
|
|
/// <param name="request"></param>
|
|
public void StartPromotionTask(StartPromotionTaskRequest request)
|
|
{
|
|
var dbPromotionTask = fsql.Select<PromotionTask>(request.Id).ToOne();
|
|
|
|
if (dbPromotionTask == null)
|
|
throw new BusinessException("任务不存在");
|
|
if (dbPromotionTask.Status != Enums.PromitionTaskStatus.等待)
|
|
throw new BusinessException("只能在任务处于等待状态时才能开始");
|
|
|
|
|
|
IList<GiftTemplateSkuRequest> giftTemplateSkuList = null; //赠品模板sku
|
|
var motherTemplateSku = string.Empty; //奶妈模板的sku
|
|
|
|
if (dbPromotionTask.GiftTemplateId != null && dbPromotionTask.GiftTemplateId != 0)
|
|
{
|
|
giftTemplateSkuList = fsql.Select<GiftTemplateSku>().Where(gs => gs.GiftTemplateId == dbPromotionTask.GiftTemplateId).ToList(gs => new GiftTemplateSkuRequest()
|
|
{
|
|
Logo = gs.Logo,
|
|
Price = gs.Price,
|
|
SkuId = gs.SkuId,
|
|
Title = gs.Title
|
|
});
|
|
if (giftTemplateSkuList == null || giftTemplateSkuList.Count() == 0)
|
|
throw new BusinessException("赠品模板不存在");
|
|
}
|
|
|
|
var runingTaskList = fsql.Select<PromotionTask>().Where(pt => pt.ShopId == dbPromotionTask.ShopId && pt.Status == Enums.PromitionTaskStatus.进行中).ToList();
|
|
|
|
|
|
if (dbPromotionTask.MotherTemplateId != null && dbPromotionTask.MotherTemplateId != 0)
|
|
{
|
|
|
|
}
|
|
|
|
if (!string.IsNullOrEmpty(dbPromotionTask.CustomMotherSku))
|
|
CheckRepeatSkuInRuningTask(runingTaskList, dbPromotionTask.CustomMotherSku);
|
|
|
|
if (!string.IsNullOrEmpty(motherTemplateSku))
|
|
CheckRepeatSkuInRuningTask(runingTaskList, motherTemplateSku);
|
|
|
|
if (!string.IsNullOrEmpty(dbPromotionTask.MainProductSku))
|
|
CheckRepeatSkuInRuningTask(runingTaskList, dbPromotionTask.MainProductSku);
|
|
|
|
var host = GetPlatformRelayAPIHost(Enums.Platform.京东);
|
|
var httpApiResult = restApiService.SendRequest(host, "api/PlatformSDK/StartJDPromotionTask", new StartPromotionTaskRequest2()
|
|
{
|
|
Id = dbPromotionTask.Id,
|
|
ActivityName = dbPromotionTask.ActivityName,
|
|
AppKey = request.AppKey,
|
|
AppSecret = request.AppSecret,
|
|
AppToken = request.AppToken,
|
|
SimpleTitle = dbPromotionTask.SimpleTitle,
|
|
FullTitle = dbPromotionTask.FullTitle,
|
|
GiftTemplateSkuList = giftTemplateSkuList,
|
|
MainProductGiftSku = dbPromotionTask.MainProductGiftSku,
|
|
MainProductSku = dbPromotionTask.MainProductSku,
|
|
MotherTemplateSku = motherTemplateSku,
|
|
CustomMotherSku = dbPromotionTask.CustomMotherSku,
|
|
MainProductSpu = dbPromotionTask.MainProductSpu,
|
|
Platform = Enums.Platform.京东,
|
|
ShopId = dbPromotionTask.ShopId.Value
|
|
}, GetYunDingRequestHeader(), HttpMethod.Post);
|
|
|
|
if (httpApiResult.StatusCode != System.Net.HttpStatusCode.OK)
|
|
throw new BusinessException(httpApiResult.Content);
|
|
var response = JsonConvert.DeserializeObject<ApiResponse<long?>>(httpApiResult.Content);
|
|
if (!response.Success)
|
|
throw new BusinessException(response.Msg);
|
|
var promotionId = response.Data;
|
|
if (promotionId == null || promotionId == 0)
|
|
return;
|
|
fsql.Update<PromotionTask>(request.Id).Set(pt => pt.PromotionId, promotionId)
|
|
.Set(pt => pt.StartTime, DateTime.Now)
|
|
.Set(pt => pt.EndTime, DateTime.Now.AddDays(180))
|
|
.Set(pt => pt.Status, Enums.PromitionTaskStatus.进行中)
|
|
.ExecuteAffrows();
|
|
}
|
|
|
|
/// <summary>
|
|
/// 删除任务和京东任务
|
|
/// </summary>
|
|
/// <param name="request"></param>
|
|
public void DeletePromotionTaskAndJDTask(DeletePromotionTaskRequest request)
|
|
{
|
|
var dbPromotionTask = fsql.Select<PromotionTask>(request.TaskId).ToOne();
|
|
if (dbPromotionTask.Status != Enums.PromitionTaskStatus.等待)
|
|
{
|
|
var httpResult = restApiService.SendRequest(GetPlatformRelayAPIHost(Enums.Platform.京东),
|
|
"api/platformsdk/DeleteJDPromotionTask",
|
|
new DeleteJDPromotionTaskRequest()
|
|
{
|
|
AppKey = request.AppKey,
|
|
AppSecret = request.AppSecret,
|
|
AppToken = request.AppToken,
|
|
Platform = Enums.Platform.京东,
|
|
PromotionId = dbPromotionTask.PromotionId.Value
|
|
},
|
|
GetYunDingRequestHeader(),
|
|
HttpMethod.Post);
|
|
if (httpResult.StatusCode != System.Net.HttpStatusCode.OK)
|
|
throw new BusinessException(httpResult.Content);
|
|
var response = JsonConvert.DeserializeObject<ApiResponse>(httpResult.Content);
|
|
if (!response.Success)
|
|
throw new BusinessException(response.Msg);
|
|
}
|
|
|
|
fsql.Delete<PromotionTask>(request.TaskId).ExecuteAffrows();
|
|
|
|
}
|
|
|
|
/// <summary>
|
|
/// 删除任务和奶妈SKU
|
|
/// </summary>
|
|
/// <param name="request"></param>
|
|
public void DeletePromotionTaskAndMotherSku(DeletePromotionTaskRequest request)
|
|
{
|
|
var dbPromotionTask = fsql.Select<PromotionTask>(request.TaskId).ToOne();
|
|
if (dbPromotionTask.Status != Enums.PromitionTaskStatus.等待)
|
|
{
|
|
List<string> motherSkuIdList = new List<string>();
|
|
if (dbPromotionTask.MotherTemplateId != null)
|
|
{
|
|
|
|
}
|
|
|
|
if (!string.IsNullOrEmpty(dbPromotionTask.CustomMotherSku))
|
|
motherSkuIdList.AddRange(dbPromotionTask.CustomMotherSku.Split(new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries));
|
|
|
|
var httpResult = restApiService.SendRequest(GetPlatformRelayAPIHost(Enums.Platform.京东),
|
|
"api/platformsdk/DeleteJDPromotionTaskSku",
|
|
new DeleteJDPromotionTaskSkuRequest()
|
|
{
|
|
AppKey = request.AppKey,
|
|
AppSecret = request.AppSecret,
|
|
AppToken = request.AppToken,
|
|
Platform = Enums.Platform.京东,
|
|
PromotionId = dbPromotionTask.PromotionId.Value,
|
|
SkuId = string.Join(",", motherSkuIdList)
|
|
},
|
|
GetYunDingRequestHeader(),
|
|
HttpMethod.Post);
|
|
if (httpResult.StatusCode != System.Net.HttpStatusCode.OK)
|
|
throw new BusinessException(httpResult.Content);
|
|
var response = JsonConvert.DeserializeObject<ApiResponse>(httpResult.Content);
|
|
if (!response.Success)
|
|
throw new BusinessException(response.Msg);
|
|
}
|
|
fsql.Delete<PromotionTask>(request.TaskId).ExecuteAffrows();
|
|
}
|
|
|
|
/// <summary>
|
|
/// 停止任务
|
|
/// </summary>
|
|
/// <param name="request"></param>
|
|
/// <exception cref="BusinessException"></exception>
|
|
public void StopPromotionTask(StopPromotionTaskRequest request)
|
|
{
|
|
var dbPromotionTask = fsql.Select<PromotionTask>(request.Id).ToOne();
|
|
|
|
if (dbPromotionTask == null)
|
|
throw new BusinessException("任务不存在");
|
|
if (dbPromotionTask.Status != Enums.PromitionTaskStatus.进行中)
|
|
throw new BusinessException("只能在任务处于进行中时才能停止");
|
|
|
|
var httpResult = restApiService.SendRequest(GetPlatformRelayAPIHost(Enums.Platform.京东),
|
|
"api/platformsdk/SuspendJDPromotionTask",
|
|
new SuspendDPromotionTaskRequest()
|
|
{
|
|
AppKey = request.AppKey,
|
|
AppSecret = request.AppSecret,
|
|
AppToken = request.AppToken,
|
|
Platform = Enums.Platform.京东,
|
|
PromotionId = dbPromotionTask.PromotionId.Value
|
|
},
|
|
GetYunDingRequestHeader(),
|
|
HttpMethod.Post);
|
|
if (httpResult.StatusCode != System.Net.HttpStatusCode.OK)
|
|
throw new BusinessException(httpResult.Content);
|
|
var response = JsonConvert.DeserializeObject<ApiResponse>(httpResult.Content);
|
|
if (!response.Success)
|
|
throw new BusinessException(response.Msg);
|
|
fsql.Update<PromotionTask>(request.Id).Set(pt => pt.Status, Enums.PromitionTaskStatus.已停止).ExecuteAffrows();
|
|
}
|
|
#endregion
|
|
}
|
|
}
|
|
|