Commit bc6b9c26 authored by 黄奎's avatar 黄奎

导入修改

parent a7c185f0
using NPOI.SS.Formula.Eval;
using NPOI.SS.UserModel;
using NPOI.XWPF.UserModel;
using System;
using System.Collections.Generic;
using System.Data;
......@@ -161,7 +162,7 @@ namespace Mall.Common.Plugin
case CellType.Numeric:
if (DateUtil.IsCellDateFormatted(row.GetCell(j)))
{
dataRow[j] = DateTime.FromOADate(row.GetCell(j).NumericCellValue);
dataRow[j] = row.GetCell(j).DateCellValue.ToString("yyyy-MM-dd HH:mm:ss");
}
else
{
......
......@@ -41,10 +41,10 @@ WHERE 1=1
{
builder.AppendFormat(" AND A.{0}={1} ", nameof(RB_Building_Carrier_Extend.MallBaseId), query.MallBaseId);
}
if (query.BuildingCarrierType > 0)
{
builder.AppendFormat(" AND A.{0}={1} ", nameof(RB_Building_Carrier_Extend.BuildingCarrierType), query.BuildingCarrierType);
}
//if (query.BuildingCarrierType > 0)
//{
// builder.AppendFormat(" AND A.{0}={1} ", nameof(RB_Building_Carrier_Extend.BuildingCarrierType), query.BuildingCarrierType);
//}
if (!string.IsNullOrEmpty(query.CarrierName))
{
builder.AppendFormat(" AND A.{0} LIKE @CarrierName ", nameof(RB_Building_Carrier_Extend.CarrierName));
......@@ -133,10 +133,10 @@ WHERE 1=1
{
builder.AppendFormat(" AND A.{0} in ({1}) ", nameof(RB_Building_Carrier_Extend.ID), query.SelectIds);
}
if (query.BuildingCarrierType > 0)
{
builder.AppendFormat(" AND A.{0}={1} ", nameof(RB_Building_Carrier_Extend.BuildingCarrierType), query.BuildingCarrierType);
}
//if (query.BuildingCarrierType > 0)
//{
// builder.AppendFormat(" AND A.{0}={1} ", nameof(RB_Building_Carrier_Extend.BuildingCarrierType), query.BuildingCarrierType);
//}
if (!string.IsNullOrEmpty(query.CarrierName))
{
builder.AppendFormat(" AND A.{0} LIKE @CarrierName ", nameof(RB_Building_Carrier_Extend.CarrierName));
......
......@@ -23,10 +23,26 @@ namespace TestCore
/// 品牌仓储层
/// </summary>
private static RB_Brand_EnterpriseRepository brand_EnterpriseRepository = new RB_Brand_EnterpriseRepository();
/// <summary>
/// 载体仓储层
/// </summary>
private static RB_Building_CarrierRepository building_CarrierRepository = new RB_Building_CarrierRepository();
/// <summary>
/// 楼宇仓储层
/// </summary>
private static RB_BuildingRepository buildingRepository = new RB_BuildingRepository();
/// <summary>
/// 企业服务仓储层
/// </summary>
private static RB_EnterpriseServicesRepository enterpriseServicesRepository = new RB_EnterpriseServicesRepository();
static void Main(string[] args)
{
Console.WriteLine("开始.." );
int Type = 2;
int Type = 4;
if (Type == 1)
{
BrandImport();
......@@ -57,6 +73,7 @@ namespace TestCore
var brandList = BrandHelper.ImportYBBrandData(brandFile, tempPath);
Console.WriteLine("End解析品牌文件...");
var categoryList = brandClassRepository.GetBrandClassListRepository(new Mall.Model.Extend.TradePavilion.RB_BrandClass_Extend() { });
Console.WriteLine("开始导入品牌数据...");
foreach (var item in brandList)
{
item.BrandEnterpriseType = 1;
......@@ -116,9 +133,43 @@ namespace TestCore
/// </summary>
static void CarrierImport()
{
Console.WriteLine("Start 解析载体文件...");
string carrierFile = rootPath + @"\商业载体导入.xlsx";
Console.WriteLine("End 解析载体文件...");
var carrierList = CarrierHelper.ImportYBCarrierData(carrierFile, tempPath);
Console.WriteLine("CarrierImport::{0}", Mall.Common.Plugin.JsonHelper.Serialize(carrierList));
var categoryList = brandClassRepository.GetBrandClassListRepository(new Mall.Model.Extend.TradePavilion.RB_BrandClass_Extend() { });
Console.WriteLine("开始导入载体数据...");
foreach (var item in carrierList)
{
item.BuildingCarrierType = 1;
if (!string.IsNullOrEmpty(item.Logo))
{
OssResult logoObj = SaveImg(item.Logo);
if (logoObj != null && logoObj.resultCode == 1)
{
item.Logo = ViewFileSiteUrl + logoObj.data;
}
}
if (!string.IsNullOrEmpty(item.CategoryName))
{
var tempCategory = categoryList.FirstOrDefault(qitem => qitem.ClassName.Trim() == item.CategoryName.Trim());
item.CategoryId = tempCategory?.ID ?? 0;
}
item.TenantId = 30;
item.MallBaseId = 20;
item.CreateBy = 30;
item.CreateDate = DateTime.Now;
item.UpdateBy = 30;
item.UpdateDate = DateTime.Now;
}
bool flag = false;
if (carrierList != null && carrierList.Count > 0)
{
flag= building_CarrierRepository.InsertBatch(carrierList);
}
Console.WriteLine("CarrierImport::flag_{0} params_{1}",flag, Mall.Common.Plugin.JsonHelper.Serialize(carrierList));
}
/// <summary>
......@@ -126,9 +177,52 @@ namespace TestCore
/// </summary>
static void BuildingImport()
{
Console.WriteLine("Start 解析楼宇文件...");
string buildingFile = rootPath + @"\活力楼宇导入.xlsx";
var buildingList = BuildingHelper.ImportYBuildingData(buildingFile, tempPath);
Console.WriteLine("BuildingImport::{0}", Mall.Common.Plugin.JsonHelper.Serialize(buildingList));
var categoryList = brandClassRepository.GetBrandClassListRepository(new Mall.Model.Extend.TradePavilion.RB_BrandClass_Extend() { });
Console.WriteLine("End 解析楼宇文件...");
Console.WriteLine("开始导入楼宇数据...");
foreach (var item in buildingList)
{
if (!string.IsNullOrEmpty(item.Banner))
{
List<string> bannerList = new List<string>();
var tempArray = item.Banner.Split(',');
if (tempArray != null && tempArray.Length > 0)
{
foreach (var tItem in tempArray)
{
if (!string.IsNullOrEmpty(tItem))
{
OssResult bObj = SaveImg(tItem);
if (bObj.resultCode == 1)
{
bannerList.Add(ViewFileSiteUrl + bObj.data);
}
}
}
}
item.Banner = Mall.Common.Plugin.JsonHelper.Serialize(bannerList);
}
if (!string.IsNullOrEmpty(item.CategoryName))
{
var tempCategory = categoryList.FirstOrDefault(qitem => qitem.ClassName.Trim() == item.CategoryName.Trim());
item.CategoryId = tempCategory?.ID ?? 0;
}
item.TenantId = 30;
item.MallBaseId = 20;
item.CreateBy = 30;
item.CreateDate = DateTime.Now;
item.UpdateBy = 30;
item.UpdateDate = DateTime.Now;
}
bool flag = false;
if (buildingList != null && buildingList.Count > 0)
{
flag= buildingRepository.InsertBatch(buildingList);
}
Console.WriteLine("BuildingImport::Flag_{0} params:{1}", flag, Mall.Common.Plugin.JsonHelper.Serialize(buildingList));
}
/// <summary>
......@@ -136,9 +230,57 @@ namespace TestCore
/// </summary>
static void EnterpriseImport()
{
Console.WriteLine("Start 解析企业服务文件...");
string enterpriseFile = rootPath + @"\企业服务导入.xlsx";
var enterpriseList = EnterpriseServiceHelper.ImportYBEnterpriseData(enterpriseFile, tempPath);
Console.WriteLine("EnterpriseImport::{0}", Mall.Common.Plugin.JsonHelper.Serialize(enterpriseList));
var categoryList = brandClassRepository.GetBrandClassListRepository(new Mall.Model.Extend.TradePavilion.RB_BrandClass_Extend() { });
Console.WriteLine("End 解析企业服务文件...");
Console.WriteLine("开始导入企业服务文件...");
foreach (var item in enterpriseList)
{
if (!string.IsNullOrEmpty(item.Banner))
{
List<string> bannerList = new List<string>();
var tempArray = item.Banner.Split(',');
if (tempArray != null && tempArray.Length > 0)
{
foreach (var tItem in tempArray)
{
if (!string.IsNullOrEmpty(tItem))
{
OssResult bObj = SaveImg(tItem);
if (bObj.resultCode == 1)
{
bannerList.Add(ViewFileSiteUrl + bObj.data);
}
}
}
}
item.Banner = Mall.Common.Plugin.JsonHelper.Serialize(bannerList);
}
if (!string.IsNullOrEmpty(item.CategoryName))
{
var tempCategory = categoryList.FirstOrDefault(qitem => qitem.ClassName.Trim() == item.CategoryName.Trim());
item.CategoryId = tempCategory?.ID ?? 0;
}
if (!string.IsNullOrEmpty(item.ETypeName))
{
var tempCategory = categoryList.FirstOrDefault(qitem => qitem.ClassName.Trim() == item.ETypeName.Trim());
item.EType = tempCategory?.ID ?? 0;
}
item.TenantId = 30;
item.MallBaseId = 20;
item.CreateBy = 30;
item.CreateDate = DateTime.Now;
item.UpdateBy = 30;
item.UpdateDate = DateTime.Now;
}
bool flag = false;
if(enterpriseList!=null && enterpriseList.Count > 0)
{
flag= enterpriseServicesRepository.InsertBatch(enterpriseList);
}
Console.WriteLine("EnterpriseImport::flag_{0} params:{1}",flag, Mall.Common.Plugin.JsonHelper.Serialize(enterpriseList));
}
/// <summary>
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment