using Operater.DTO.System;
|
using System;
|
using System.Collections.Generic;
|
using System.Text;
|
using CommonUtil;
|
using Operater.DAL;
|
using YouZanSDKStandard.Api.Request;
|
using YouZanSDKStandard.Api;
|
using Operater.DbModel;
|
using ProductDistribution.Model;
|
using YouZanSDKStandard.Api.Domain;
|
using AlibabaSDK.Request;
|
using AlibabaSDK.Api;
|
using AlibabaSDK.Domain;
|
using System.Linq;
|
using Operater.Service.System;
|
|
namespace ProductDistribution.Handle
|
{
|
public class BatchUpdatePriceHandle
|
{
|
public static string _errFileName = "批量修改价格error";
|
public static void MainMethod(ProductDistributionMq msg)
|
{
|
try
|
{
|
var _Token = CommonHandle.GetToken();
|
//获取任务详情
|
var taskInfo = new BatchUpdateDAL().GetById(msg.TaskId);
|
if (taskInfo.IsNull() || taskInfo.TaskStatus != 0)
|
{
|
Console.WriteLine("未获取到可执行的任务");
|
return;
|
}
|
//修改任务执行中
|
BatchUpdate batchUpdate = new BatchUpdate()
|
{
|
TaskStatus = 1
|
};
|
new BatchUpdateDAL().Update(batchUpdate, i => new { i.TaskStatus }, t => t.Id == taskInfo.Id);
|
//执行规则
|
PriceUpdateRule rule = JSONUtil.JsonToObject<PriceUpdateRule>(taskInfo.TaskRule);
|
//获取有赞分类下的商品
|
string[] tagIds = taskInfo.Tagids.Split(',');
|
foreach (string tag in tagIds)
|
{//循环分组获取商品
|
if (tag.IsNullOrEmpty())
|
{
|
continue;
|
}
|
int totalPage = 1;
|
int currentPage = 0;
|
int pageSize = 50;
|
List<long> reqTag = new List<long>();
|
reqTag.Add(long.Parse(tag));
|
while (currentPage <= totalPage)
|
{
|
currentPage++;
|
YouZanItemCommonSearchRequest itemReq = new YouZanItemCommonSearchRequest()
|
{
|
page_size = pageSize,
|
page_no = currentPage,
|
tag_ids = reqTag
|
};
|
var itemRsp = YouZanClient.Execute(itemReq, _Token.YzToken);
|
if (itemRsp.IsNull() || !itemRsp.success)
|
{
|
string errMsg = "获取有赞商品失败：" + itemRsp.message;
|
Console.WriteLine(errMsg);
|
LogUtil.Info(errMsg, _errFileName);
|
continue;
|
}
|
//计算总页数
|
if (totalPage == 1)
|
{
|
totalPage = itemRsp.data.paginator.total_count % pageSize == 0 ? itemRsp.data.paginator.total_count / pageSize : (itemRsp.data.paginator.total_count / pageSize) + 1;
|
}
|
//计算有赞价格并更新
|
UpdateYzPrice(taskInfo, _Token, itemRsp.data.items, rule);
|
}
|
}
|
//修改任务状态
|
batchUpdate.TaskStatus = 2;
|
new BatchUpdateDAL().Update(batchUpdate, i => new { i.TaskStatus }, t => t.Id == taskInfo.Id);
|
}
|
catch (Exception e)
|
{
|
string errMsg = "主线程错误：" + e.ToString();
|
Console.WriteLine(errMsg);
|
LogUtil.Info(errMsg, _errFileName);
|
}
|
}
|
|
#region 修改有赞价格
|
private static void UpdateYzPrice(BatchUpdate taskInfo, TokenCach tokenInfo, List<YouZanItemCommonSearchDomainItems> yzItem, PriceUpdateRule rule)
|
{
|
try
|
{
|
foreach (var yzpro in yzItem)
|
{
|
try
|
{
|
//判断更新规则
|
if (rule.HistoryType == 0 && new BatchUpdatepriceHistoryDAL().IsExist(t => t.YzProductId == yzpro.item_id.ToString() && t.UpdateStatus == 1))
|
{//不覆盖历史改过的
|
LogUtil.Info($"{yzpro.item_id.ToString()}-不覆盖历史，任务id：[{taskInfo.Id}]", "批量修改价格log");
|
continue;
|
}
|
//根据有赞id获取关联的1688商品
|
var relation = new DistributionRelationDAL().ListGet(t => t.YzProduct == yzpro.item_id.ToString());
|
if (relation.IsNull() || relation.Count == 0)
|
{
|
LogUtil.Info($"{yzpro.item_id.ToString()}-未找到关联的1688商品", "批量修改价格log");
|
continue;
|
}
|
//获取1688商品详情
|
AliBatchItemInfo aliProductInfo = GetAliProductDetail(tokenInfo, relation[0].ProSource, relation[0].SourceProduct, yzpro.item_id.ToString());
|
if (aliProductInfo.IsNull() || aliProductInfo.SkuList.IsNull())
|
{
|
continue;
|
}
|
List<SkuInfosItem> aliProductSkuInfo = aliProductInfo.SkuList;
|
if (rule.RangeType == "1")
|
{ //判断价格区间
|
double aliMinPrice = relation[0].ProSource == 0 ? aliProductSkuInfo.Min(t => t.retailPrice) : aliProductSkuInfo.Min(t => t.consignPrice);
|
if (aliMinPrice <= rule.MinPrice || aliMinPrice > rule.MaxPrice)
|
{//不符合区间范围
|
LogUtil.Info($"taskid:{taskInfo.Id}-yzid:{yzpro.item_id}", "不符合区间");
|
continue;
|
}
|
}
|
//获取有赞商品详情
|
YouZanProductDetailGetRequest detailReq = new YouZanProductDetailGetRequest()
|
{
|
item_id = yzpro.item_id
|
};
|
var detailRs = YouZanClient.Execute(detailReq, tokenInfo.YzToken);
|
if (detailRs.IsNull() || !detailRs.success)
|
{
|
string errMsg = $"获取有赞商品详情错误[{yzpro.item_id.ToString()}]：" + detailRs.message;
|
Console.WriteLine(errMsg);
|
LogUtil.Info(errMsg, _errFileName);
|
continue;
|
}
|
//循环有赞商品sku修改价格
|
List<YouZanProductUpdateReqSkuList> skuList = new List<YouZanProductUpdateReqSkuList>();
|
|
foreach (var sku in detailRs.data.sku_list)
|
{
|
var aliSkuTar = aliProductSkuInfo.Where(t => t.skuId == long.Parse(sku.sku_no)).ToList();
|
if (aliSkuTar.IsNull() || aliSkuTar.Count == 0)
|
{
|
continue;
|
}
|
double finalPrice = relation[0].ProSource == 0 ? aliSkuTar[0].retailPrice : aliSkuTar[0].consignPrice;
|
//判断修改
|
switch (rule.UpType)
|
{
|
case "add_regular"://增加固定金额
|
finalPrice += rule.UpdateVale;
|
break;
|
case "add_scale"://按比例
|
finalPrice += Math.Round(finalPrice * Math.Round(rule.UpdateVale / 100, 2), 2);
|
break;
|
default:
|
continue;
|
}
|
if (!aliProductInfo.IsPost && rule.PostFee > 0)
|
{//不包邮 且 设置了邮费
|
finalPrice += rule.PostFee;
|
}
|
YouZanProductUpdateReqSkuList reqSkuItem = new YouZanProductUpdateReqSkuList()
|
{
|
price = long.Parse(Math.Round(finalPrice * 100, 0).ToString()),
|
sku_id = long.Parse(sku.sku_id)
|
};
|
skuList.Add(reqSkuItem);
|
|
}
|
if (skuList.IsNull() || skuList.Count == 0)
|
{
|
continue;
|
}
|
//增量修改有赞sku信息
|
YouZanProductUpdateReqDomain upDomain = new YouZanProductUpdateReqDomain()
|
{
|
item_id = yzpro.item_id
|
};
|
upDomain.sku_list = skuList;
|
YouZanProductUpdateRequest yzReq = new YouZanProductUpdateRequest()
|
{ param = upDomain };
|
var yzRsp = YouZanClient.Execute(yzReq, tokenInfo.YzToken);
|
if (yzRsp.IsNull() || !yzRsp.success)
|
{
|
string errMsg = $"有赞接口修改失败,请求参数：{JSONUtil.ObjectToJson(yzReq)}---" + yzRsp.message;
|
Console.WriteLine(errMsg);
|
LogUtil.Info(errMsg, _errFileName);
|
}
|
//修改成功记录日志
|
BatchUpdatepriceHistory batchUpdatepriceHistory = new BatchUpdatepriceHistory()
|
{
|
Id = Guid.NewGuid().ToString(),
|
YzProductId = yzpro.item_id.ToString(),
|
AliProductId = relation[0].SourceProduct,
|
UpdateTime = DateTime.Now,
|
UpdateStatus = 1,
|
TaskId = taskInfo.Id,
|
AliTxt = JSONUtil.ObjectToJson(aliProductSkuInfo),
|
YzTxt = "",
|
YzBeforeTxt = JSONUtil.ObjectToJson(detailRs.data.sku_list)
|
};
|
//获取有赞商品详情
|
var redetailRs = YouZanClient.Execute(detailReq, tokenInfo.YzToken);
|
if (!detailRs.IsNull() && detailRs.success)
|
{
|
string reYzSku = JSONUtil.ObjectToJson(redetailRs.data.sku_list);
|
batchUpdatepriceHistory.YzTxt = reYzSku;
|
//修改关系表里有赞sku信息
|
DistributionRelation distributionRelation = new DistributionRelation()
|
{
|
YzskuInfo = reYzSku
|
};
|
new DistributionRelationDAL().Update(distributionRelation, i => new { i.YzskuInfo }, t => t.Id == relation[0].Id);
|
}
|
new BatchUpdatepriceHistoryDAL().Insert(batchUpdatepriceHistory);
|
|
}
|
catch (Exception e)
|
{
|
string errMsg = "修改有赞价格循环错误：" + e.ToString();
|
Console.WriteLine(errMsg);
|
LogUtil.Info(errMsg, _errFileName);
|
}
|
}
|
}
|
catch (Exception e)
|
{
|
string errMsg = "修改有赞价格主线程错误：" + e.ToString();
|
Console.WriteLine(errMsg);
|
LogUtil.Info(errMsg, _errFileName);
|
}
|
}
|
|
#endregion
|
|
#region 获取1688/精选货源商品详情
|
private static AliBatchItemInfo GetAliProductDetail(TokenCach tokenInfo, int proSource, string aliProductId, string yzId)
|
{
|
AliBatchItemInfo aliBatchItemInfo = new AliBatchItemInfo()
|
{
|
IsPost = false
|
};
|
if (proSource == 0)
|
{//精选货源
|
List<string> ls = new List<string>();
|
ls.Add(aliProductId);
|
PFTProductDetailRequest request = new PFTProductDetailRequest()
|
{
|
offerIds = ls
|
};
|
var response = AliabaClient.Execute(request, tokenInfo.AliToken);
|
if (response.IsNull() || !response.result.success || response.result.result.Count == 0)
|
{//获取商品详情失败
|
string errMsg = $"获取精选货源详情失败[{aliProductId}]：" + response.result.message;
|
Console.WriteLine(errMsg);
|
LogUtil.Info(errMsg, _errFileName);
|
if (response.result.message.Contains("该商品不是团长商品"))
|
{//有赞下架
|
DelistingYz(yzId, tokenInfo.YzToken);
|
ProductUpdateLog productUpdateLog = new ProductUpdateLog()
|
{
|
Id = TopUtil.GetId().ToString(),
|
CreateTime = DateTime.Now,
|
UpdateContent = "批量修改-系统下架有赞",
|
Memo="已退出精选",
|
ProductId = aliProductId,
|
ProcessingStatus = 0,
|
YzProductId = yzId,
|
IsSystemDown = 2
|
};
|
new ProductUpdateLogDAL().Insert(productUpdateLog);
|
}
|
return null;
|
}
|
aliBatchItemInfo.IsPost = true;
|
aliBatchItemInfo.SkuList = response.result.result[0].productInfo.skuInfos;
|
return aliBatchItemInfo;
|
}
|
else
|
{//1688代发
|
FenXiaoProductInfoGetRequest request = new FenXiaoProductInfoGetRequest()
|
{
|
offerId = long.Parse(aliProductId)
|
};
|
var response = AliabaClient.Execute(request, tokenInfo.AliToken);
|
if (response.IsNull() || !response.Success)
|
{//获取商品详情失败
|
string errMsg = $"获取代发商品详情失败[{aliProductId}]：" + response.ErrorMsg;
|
Console.WriteLine(errMsg);
|
LogUtil.Info(errMsg, _errFileName);
|
if(response.ErrorMsg.Contains("已下架"))
|
{
|
ProductUpdateLog productUpdateLog = new ProductUpdateLog()
|
{
|
Id = TopUtil.GetId().ToString(),
|
CreateTime = DateTime.Now,
|
UpdateContent = "批量修改-系统下架有赞",
|
Memo = "1688商品已下架",
|
ProductId = aliProductId,
|
ProcessingStatus = 0,
|
YzProductId = yzId,
|
IsSystemDown = 2
|
};
|
new ProductUpdateLogDAL().Insert(productUpdateLog);
|
}
|
return null;
|
}
|
List<SkuInfosItem> res = JSONUtil.JsonToObject<List<SkuInfosItem>>(JSONUtil.ObjectToJson(response.productInfo.productSkuInfos));
|
//是否包邮
|
aliBatchItemInfo.IsPost = new ItemDistributionService().IsPost(response.productInfo);
|
aliBatchItemInfo.SkuList = res;
|
return aliBatchItemInfo;
|
}
|
}
|
|
#endregion
|
|
#region 下架有赞商品
|
private static void DelistingYz(string yzId, string yzToken)
|
{
|
//下架有赞商品
|
YouZanItemDelistingRequest delistingReq = new YouZanItemDelistingRequest()
|
{
|
item_id = long.Parse(yzId)
|
};
|
var delistingRsp = YouZanClient.Execute(delistingReq, yzToken);
|
if (delistingRsp.IsNull() || !delistingRsp.success)
|
{
|
LogUtil.Info($"下架有赞商品失败[{yzId}])：" + (delistingRsp.IsNull() ? "null" : delistingRsp.message), "下架有赞商品");
|
}
|
else
|
{
|
LogUtil.Info($"下架有赞商品成功[{yzId}]()", "下架有赞商品");
|
|
|
}
|
}
|
|
#endregion
|
|
public class AliBatchItemInfo
|
{
|
/// <summary>
|
/// 是否包邮
|
/// </summary>
|
public bool IsPost { get; set; }
|
public List<SkuInfosItem> SkuList { get; set; }
|
}
|
}
|
}
|
