Commit bd41a363 by 泽锋 李

新增现金流报表的刷新

parent d07c0ea0
using AutoTurnOver.Models;
using Dapper;
using System;
using System.Collections.Generic;
using System.Linq;
using AutoTurnOver.Models.ApiDto;
using AutoTurnOver.Models.Base;
using AutoTurnOver.DB.Base;
namespace AutoTurnOver.DB
{
public class base_sku_dao : connectionHelper
{
public static Page<dc_base_sku> GetPage(dc_base_sku_search_dto search)
{
var sql = " select t1.* from dc_base_sku as t1 where 1=1 ";
DynamicParameters parameters = new DynamicParameters();
if (!string.IsNullOrWhiteSpace(search.bailun_sku))
{
sql += " and t1.bailun_sku = @bailun_sku ";
parameters.Add("bailun_sku", search.bailun_sku);
}
if (!string.IsNullOrWhiteSpace(search.buyer_name))
{
sql += " and t1.buyer_name = @buyer_name ";
parameters.Add("buyer_name", search.buyer_name);
}
if (!string.IsNullOrWhiteSpace(search.product_inner_code))
{
sql += " and t1.product_inner_code = @product_inner_code ";
parameters.Add("product_inner_code", search.product_inner_code);
}
if (!string.IsNullOrWhiteSpace(search.product_code))
{
sql += " and t1.product_code = @product_code ";
parameters.Add("product_code", search.product_code);
}
return _connection.Page<dc_base_sku>(sql, search, parameters);
}
}
}
...@@ -618,7 +618,7 @@ where 1=1 "; ...@@ -618,7 +618,7 @@ where 1=1 ";
/// <param name="sku"></param> /// <param name="sku"></param>
/// <param name="warehouse_code"></param> /// <param name="warehouse_code"></param>
/// <returns></returns> /// <returns></returns>
public static IEnumerable<dc_base_oms_sku> OutOfStockOrderList(string sku, string warehouse_code) public static IEnumerable<dc_base_oms_sku_dto> OutOfStockOrderList(string sku, string warehouse_code)
{ {
var sql = @" var sql = @"
SELECT SELECT
...@@ -636,7 +636,7 @@ where 1=1 "; ...@@ -636,7 +636,7 @@ where 1=1 ";
DynamicParameters parameters = new DynamicParameters(); DynamicParameters parameters = new DynamicParameters();
parameters.Add("bailun_sku", sku); parameters.Add("bailun_sku", sku);
parameters.Add("warehouse_code", warehouse_code); parameters.Add("warehouse_code", warehouse_code);
return _connection.Query<dc_base_oms_sku>(sql, parameters); return _connection.Query<dc_base_oms_sku_dto>(sql, parameters);
} }
public static IEnumerable<product_api_dto> GetSkus(string skus) public static IEnumerable<product_api_dto> GetSkus(string skus)
......
...@@ -1637,5 +1637,69 @@ and start_date<=@end_date and end_date>=@start_date ...@@ -1637,5 +1637,69 @@ and start_date<=@end_date and end_date>=@start_date
_connection.Execute(" update dc_auto_sales_forecast_config set is_delete=1,delete_time=now() where id=@id and is_delete=0 ", new { id = id}); _connection.Execute(" update dc_auto_sales_forecast_config set is_delete=1,delete_time=now() where id=@id and is_delete=0 ", new { id = id});
} }
#endregion #endregion
#region 现金流结算方式
public static List<dc_report_cash_flow_config_dto> CashFlowList(dc_report_cash_flow_config_search_dto m, int offset, int limit, ref int total)
{
var list = new List<dc_report_cash_flow_config_dto>();
try
{
var sql = @"select t1.* from dc_report_cash_flow_config as t1 where 1 = 1 ";
if (!string.IsNullOrWhiteSpace(m.data_type))
{
sql += " and t1.data_type=" + $"'{m.data_type}'";
}
total = _connection.ExecuteScalar<int>("select count(0) from (" + sql + ") tb1");
var obj = _connection.Query<dc_report_cash_flow_config_dto>(sql + " limit " + offset + "," + limit);
return obj.AsList();
}
catch (Exception)
{
return list;
}
}
public static string SaveCashFlow(Models.dc_report_cash_flow_config m)
{
try
{
m.platform_type = (m.platform_type??"");
if (m.id > 0)
{
var result = _connection.Update<Models.dc_report_cash_flow_config>(m);
return result > 0 ? "" : "保存异常,请重试!";
}
else
{
var result = _connection.Insert<Models.dc_report_cash_flow_config>(m);
return result.HasValue && result.Value > 0 ? "" : "提交异常,请重试!";
}
}
catch (Exception ex)
{
return ex.Message;
}
}
public static dc_report_cash_flow_config GetCashFlowById(int id)
{
return _connection.QueryFirstOrDefault<dc_report_cash_flow_config>("select * from dc_report_cash_flow_config where id=" + id);
}
#endregion
} }
} }
using System;
using System.Collections.Generic;
using System.Text;
namespace AutoTurnOver.Models.Report
{
public class dc_base_crm_refund
{
/// <summary>
///
/// </summary>
public int id { get; set; }
/// <summary>
/// 平台类型
/// </summary>
public string platform_type { get; set; }
/// <summary>
/// 百伦账号
/// </summary>
public string bailun_account { get; set; }
/// <summary>
/// 百伦账号id
/// </summary>
public int bailun_account_id { get; set; }
/// <summary>
/// 站点
/// </summary>
public string website { get; set; }
/// <summary>
/// 平台订单号
/// </summary>
public string origin_order_id { get; set; }
/// <summary>
/// 百伦SKU
/// </summary>
public string bailun_sku { get; set; }
/// <summary>
/// 平台SKU
/// </summary>
public string platform_sku { get; set; }
/// <summary>
/// 退款金额-原币种
/// </summary>
public decimal amount_refund { get; set; }
/// <summary>
/// 订单币种
/// </summary>
public string order_currency { get; set; }
/// <summary>
/// 订单退款时间
/// </summary>
public DateTime? refund_time { get; set; }
/// <summary>
/// 百伦SKU退货数量
/// </summary>
public int bailun_sku_quantity_refund { get; set; }
/// <summary>
/// 百伦SKU单价
/// </summary>
public decimal bailun_sku_unit_price { get; set; }
/// <summary>
/// 数据中心-创建时间
/// </summary>
public DateTime gmt_create { get; set; }
/// <summary>
/// 数据中心-更新时间
/// </summary>
public DateTime gmt_modified { get; set; }
/// <summary>
/// 是否与订单关联
/// </summary>
public int linked { get; set; }
/// <summary>
/// 退款转人民币
/// </summary>
public decimal amount_refund_rmb { get; set; }
/// <summary>
/// CRM的唯一主键
/// </summary>
public int crm_id { get; set; }
/// <summary>
/// 退款转美元
/// </summary>
public decimal amount_refund_usd { get; set; }
/// <summary>
/// 公司Id,0和1是百伦
/// </summary>
public int company_id { get; set; }
/// <summary>
/// 订单总金额(本币)
/// </summary>
public decimal order_total_amount { get; set; }
/// <summary>
/// 订单总金额(美金)
/// </summary>
public decimal usd_order_total_amount { get; set; }
/// <summary>
/// sku总售价(美金)
/// </summary>
public decimal product_sale_amount { get; set; }
/// <summary>
/// 是否删除
/// </summary>
public int is_deleted { get; set; }
/// <summary>
/// 是否冻结
/// </summary>
public int is_freeze { get; set; }
/// <summary>
/// 订单状态
/// </summary>
public string order_status { get; set; }
/// <summary>
/// 发货状态
/// </summary>
public string shipping_status { get; set; }
/// <summary>
/// 是否平台退款
/// </summary>
public string refund_type { get; set; }
}
}
using System;
using System.Collections.Generic;
using System.Text;
namespace AutoTurnOver.Models.Report
{
public class dc_base_purchase_details
{
/// <summary>
///
/// </summary>
public int id { get; set; }
/// <summary>
/// 采购单号
/// </summary>
public string purchase_id { get; set; }
/// <summary>
/// 状态-1:作废,0:待确认,1:已确认 4:已完成
/// </summary>
public int? status { get; set; }
/// <summary>
/// 采购类型
/// </summary>
public string purchase_category_name { get; set; }
/// <summary>
/// 采购系统的供应商ID
/// </summary>
public int deliver_id { get; set; }
/// <summary>
/// 采购系统的供应商名称
/// </summary>
public string deliver_name { get; set; }
/// <summary>
/// 供应商value值
/// </summary>
public int deliver_value { get; set; }
/// <summary>
/// 采购员名称
/// </summary>
public string buyer_name { get; set; }
/// <summary>
/// 采购仓库编码
/// </summary>
public string warehouse_from_code { get; set; }
/// <summary>
/// 采购仓库名称
/// </summary>
public string warehouse_from_name { get; set; }
/// <summary>
/// 目的仓库编码
/// </summary>
public string warehouse_into_code { get; set; }
/// <summary>
/// 目的仓库名称
/// </summary>
public string warehouse_into_name { get; set; }
/// <summary>
///
/// </summary>
public string bailun_sku { get; set; }
/// <summary>
/// 采购数量
/// </summary>
public int quantity_purchase { get; set; }
/// <summary>
/// 采购单价
/// </summary>
public decimal unit_price { get; set; }
/// <summary>
/// 采购总价
/// </summary>
public decimal amount_paid { get; set; }
/// <summary>
/// 币种编码
/// </summary>
public string currency_code { get; set; }
/// <summary>
/// 币种名称
/// </summary>
public string currency_name { get; set; }
/// <summary>
/// 退货数量
/// </summary>
public int quantity_return { get; set; }
/// <summary>
/// 入库数量
/// </summary>
public int quantity_inbound { get; set; }
/// <summary>
/// 发货数量
/// </summary>
public int quantity_deliver { get; set; }
/// <summary>
/// 未发货数量
/// </summary>
public int quantity_not_deliver { get; set; }
/// <summary>
/// 到货数量
/// </summary>
public int quantity_arrival { get; set; }
/// <summary>
/// 未到货数量
/// </summary>
public int quantity_not_arrival { get; set; }
/// <summary>
/// 质检数量
/// </summary>
public int quantity_inspect { get; set; }
/// <summary>
/// 质检合格数量
/// </summary>
public int quantity_qualified_inspect { get; set; }
/// <summary>
/// 质检不合格数量
/// </summary>
public int quantity_unqualified_inspect { get; set; }
/// <summary>
/// 待调拨数量
/// </summary>
public int quantity_wait_transfer { get; set; }
/// <summary>
/// 换货数量
/// </summary>
public int quantity_exchange { get; set; }
/// <summary>
/// 入库丢失数量
/// </summary>
public int quantity_lose_inbound { get; set; }
/// <summary>
/// 采购系统创建时间
/// </summary>
public DateTime? create_time { get; set; }
/// <summary>
/// 采购系统更新时间
/// </summary>
public DateTime? update_time { get; set; }
/// <summary>
///
/// </summary>
public DateTime gmt_create { get; set; }
/// <summary>
///
/// </summary>
public DateTime gmt_modified { get; set; }
/// <summary>
/// 未入库数量
/// </summary>
public int quantity_not_inbound { get; set; }
/// <summary>
/// 阿里巴巴单号
/// </summary>
public string alibaba_order_id { get; set; }
/// <summary>
/// 物流单号
/// </summary>
public string logistics_order_id { get; set; }
/// <summary>
/// 物流公司
/// </summary>
public string logistics_company_name { get; set; }
/// <summary>
/// 公司Id,0和1是百伦
/// </summary>
public int company_id { get; set; }
/// <summary>
/// 0:无需推送,1:未推送,2:推送成功,3:推送失败
/// </summary>
public int ispush { get; set; }
/// <summary>
/// 1:调拨,0:非调拨
/// </summary>
public int isallot { get; set; }
/// <summary>
///
/// </summary>
public int? isaims { get; set; }
/// <summary>
/// 付款方式 1先款后货,2先货后款,3无需付款
/// </summary>
public int pay_type { get; set; }
/// <summary>
/// 付款状态 0:未付款,1:部分付款,2:已付款,3无需付款
/// </summary>
public int pay_status { get; set; }
/// <summary>
/// 最后签收时间
/// </summary>
public DateTime? last_signtime { get; set; }
/// <summary>
/// 到货状态 0:未到货,1:部分到货,2:全部到货,3:部分到货不等待剩余
/// </summary>
public int arrival_status { get; set; }
/// <summary>
/// 采购单采购总金额
/// </summary>
public decimal? amount_buy { get; set; }
/// <summary>
/// 采购单已付款总金额
/// </summary>
public decimal? amount_payed { get; set; }
/// <summary>
/// 采购单快递费
/// </summary>
public decimal? amount_express { get; set; }
/// <summary>
/// 创建人
/// </summary>
public string createusername { get; set; }
}
public class dc_base_purchase_details_dto: dc_base_purchase_details
{
public DateTime? pay_time { get; set; }
}
}
using System;
using System.Collections.Generic;
using System.Text;
namespace AutoTurnOver.Models.Report
{
public class dc_base_transfer_verify
{
/// <summary>
///
/// </summary>
public int id { get; set; }
/// <summary>
/// 数据中心创建时间
/// </summary>
public DateTime gmt_create { get; set; }
/// <summary>
/// 数据中心更新时间
/// </summary>
public DateTime gmt_modified { get; set; }
/// <summary>
/// 百伦SKU
/// </summary>
public string bailun_sku { get; set; }
/// <summary>
/// 调拨单号
/// </summary>
public string transfer_order_id { get; set; }
/// <summary>
/// 调拨目的仓库编码
/// </summary>
public string warehouse_code { get; set; }
/// <summary>
/// 调拨目的仓库名称
/// </summary>
public string warehouse_name { get; set; }
/// <summary>
/// 打包状态
/// </summary>
public string status { get; set; }
/// <summary>
/// 调拨系统创建时间
/// </summary>
public DateTime create_time { get; set; }
/// <summary>
/// 调拨数量
/// </summary>
public int count { get; set; }
/// <summary>
/// SKU标题
/// </summary>
public string sku_title { get; set; }
/// <summary>
/// 调拨系统主键
/// </summary>
public int transfer_key { get; set; }
/// <summary>
/// 是否被删除
/// </summary>
public int deleted { get; set; }
/// <summary>
/// 预计到达时间
/// </summary>
public DateTime? estimated_arrival_time { get; set; }
/// <summary>
/// 公司Id,0和1是百伦
/// </summary>
public int company_id { get; set; }
/// <summary>
/// 是否异常
/// </summary>
public int? isexception { get; set; }
}
public class dc_base_transfer_verify_dto: dc_base_transfer_verify
{
public DateTime? complete_time { get; set; }
public decimal cost_first { get; set; }
}
}
...@@ -7,7 +7,7 @@ namespace AutoTurnOver.Models ...@@ -7,7 +7,7 @@ namespace AutoTurnOver.Models
/// <summary> /// <summary>
/// 百伦OMS 订单明细 /// 百伦OMS 订单明细
/// </summary> /// </summary>
public class dc_base_oms_sku public class dc_base_oms_sku_dto
{ {
public int id { get; set; } public int id { get; set; }
...@@ -42,12 +42,12 @@ namespace AutoTurnOver.Models ...@@ -42,12 +42,12 @@ namespace AutoTurnOver.Models
public decimal amount_sales { get; set; } public decimal amount_sales { get; set; }
} }
public class dc_base_oms_sku_label : dc_base_oms_sku public class dc_base_oms_sku_label : dc_base_oms_sku_dto
{ {
public string label { get; set; } public string label { get; set; }
} }
public class dc_base_oms_sku_goods_dto : dc_base_oms_sku public class dc_base_oms_sku_goods_dto : dc_base_oms_sku_dto
{ {
public string product_inner_code { get; set; } public string product_inner_code { get; set; }
......
using System; using AutoTurnOver.Models.Base;
using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Text; using System.Text;
...@@ -10,5 +11,23 @@ namespace AutoTurnOver.Models ...@@ -10,5 +11,23 @@ namespace AutoTurnOver.Models
public string bailun_sku { get; set; } public string bailun_sku { get; set; }
public string sku_title_cn { get; set; } public string sku_title_cn { get; set; }
public string category_name { get; set; }
public string unit_price { get; set; }
public string seller_name { get; set; }
public string suppliers_name { get; set; }
public string buyer_name { get; set; }
public string product_code { get; set; }
public string product_inner_code { get; set; }
public string bailun_category_name { get; set; }
public string product_type_desc { get; set; }
}
public class dc_base_sku_search_dto: page_search_dto
{
public string buyer_name { get; set; }
public string bailun_sku { get; set; }
public int? source { get; set; }
public string product_inner_code { get; set; }
public string product_code { get; set; }
} }
} }
using System;
using System.Collections.Generic;
using System.Text;
namespace AutoTurnOver.Models
{
/// <summary>
/// 现金流
/// </summary>
public class dc_report_cash_flow_log
{
public int id { get; set; }
public string warehouse_code { get; set; }
public string platform_type { get; set; }
public string bailun_sku { get; set; }
/// <summary>
/// 1 = 销售数量 2 = 售金额 3 = 退款 4 = 利润 5 =平台费用 6=释放销售成本 7 = 释放头程费用 8 = 尾程费用 9 = 新增采购费用 10 = 新增头程费用
/// </summary>
public int data_type { get; set; }
/// <summary>
/// 1 = 实时 2 = 后付 3 = 后收 4 =预付
/// </summary>
public int pay_type { get; set; }
/// <summary>
/// 发送数值
/// </summary>
public decimal val { get; set; }
/// <summary>
/// 发送时间
/// </summary>
public DateTime occur_time { get; set; }
/// <summary>
/// 支付时间
/// </summary>
public DateTime pay_time { get; set; }
/// <summary>
/// 相关单号
/// </summary>
public string no { get; set; }
/// <summary>
/// 项目
/// </summary>
public string item { get; set; }
/// <summary>
/// 项目编号
/// </summary>
public string item_no { get; set; }
/// <summary>
/// 备注
/// </summary>
public string remarks { get; set; }
/// <summary>
/// 是否作废
/// </summary>
public int is_delete { get; set; }
}
/// <summary>
/// 1 = 销售数量 2 = 销售金额 3 = 退款 4 = 利润 5 =平台费用 6=释放销售成本 7 = 释放头程费用 8 = 尾程费用 9 = 新增采购费用 10 = 新增头程费用
/// </summary>
public enum dc_report_cash_flow_log_data_type_enum
{
销售数量 = 1,
销售金额 =2,
退款 = 3,
利润 = 4,
平台费用 = 5,
释放销售成本 = 6,
释放头程费用 = 7,
尾程费用 =8,
新增采购费用 = 9,
新增头程费用 = 10
}
public enum dc_report_cash_flow_log_pay_type_enum
{
实时 = 1,
后付 = 2,
后收 = 3,
预付 = 4,
}
public enum dc_report_cash_flow_settlement_type_enum
{
等长顺延 = 1,
月度固定 = 2
}
/// <summary>
/// 现金流配置
/// </summary>
public class dc_report_cash_flow_config
{
public int id { get; set; }
/// <summary>
/// 平台类型
/// </summary>
public string platform_type { get; set; }
/// <summary>
/// 数据类型
/// </summary>
public int data_type { get; set; }
/// <summary>
/// 结算方式
/// </summary>
public int settlement_type { get; set; }
public int settlement_val { get; set; }
}
public class dc_report_cash_flow_config_dto: dc_report_cash_flow_config
{
public string data_type_str { get {
return ((dc_report_cash_flow_log_data_type_enum)data_type).ToString();
} }
public string settlement_type_str { get {
return ((dc_report_cash_flow_settlement_type_enum)settlement_type).ToString();
} }
}
public class dc_report_cash_flow_config_search_dto
{
public string data_type { get; set; }
}
}
...@@ -816,5 +816,27 @@ namespace AutoTurnOver.Services ...@@ -816,5 +816,27 @@ namespace AutoTurnOver.Services
} }
#endregion #endregion
#region 现金流结算方式
public List<dc_report_cash_flow_config_dto> CashFlowList(dc_report_cash_flow_config_search_dto m, int offset, int limit, ref int total)
{
return DB.db_config.CashFlowList(m, offset, limit, ref total);
}
public string SaveCashFlow(Models.dc_report_cash_flow_config m, string username)
{
return DB.db_config.SaveCashFlow(m);
}
public dc_report_cash_flow_config GetCashFlowById(int id)
{
return DB.db_config.GetCashFlowById(id);
}
#endregion
} }
} }
...@@ -130,7 +130,7 @@ namespace AutoTurnOver.Services ...@@ -130,7 +130,7 @@ namespace AutoTurnOver.Services
/// <param name="warehouse_code"></param> /// <param name="warehouse_code"></param>
/// <param name="index"></param> /// <param name="index"></param>
/// <returns></returns> /// <returns></returns>
public IEnumerable<dc_base_oms_sku> OutOfStockOrderList(string sku, string warehouse_code) public IEnumerable<dc_base_oms_sku_dto> OutOfStockOrderList(string sku, string warehouse_code)
{ {
return DB.daily.OutOfStockOrderList(sku, warehouse_code); return DB.daily.OutOfStockOrderList(sku, warehouse_code);
} }
......
...@@ -777,7 +777,12 @@ namespace AutoTurnOver.Services ...@@ -777,7 +777,12 @@ namespace AutoTurnOver.Services
return report.GetWipStockPage(search); return report.GetWipStockPage(search);
} }
public Page<dc_base_sku> GetSkuPage(dc_base_sku_search_dto search)
{
return base_sku_dao.GetPage(search);
}
} }
} }
...@@ -804,5 +804,45 @@ namespace AutoTurnOver.Controllers ...@@ -804,5 +804,45 @@ namespace AutoTurnOver.Controllers
#endregion #endregion
#endregion #endregion
#region 现金流结算方式
[HttpGet]
public JsonResult CashFlowList(int limit, int offset, string order, string sort, string data_type)
{
var m = new dc_report_cash_flow_config_search_dto
{
data_type = data_type
};
var total = 0;
var service = new Services.ConfigServices();
var list = service.CashFlowList(m, offset, limit, ref total);
return new JsonResult(new
{
rows = list,
total = total,
});
}
[HttpPost]
public JsonResult SaveCashFlow([FromBody]dc_report_cash_flow_config m)
{
var result = new Services.ConfigServices().SaveCashFlow(m, "");
return new JsonResult(result);
}
[HttpGet]
public JsonResult GetCashFlowById(int id)
{
var m = new Services.ConfigServices().GetCashFlowById(id);
return new JsonResult(m);
}
#endregion
} }
} }
\ No newline at end of file
...@@ -833,6 +833,40 @@ namespace AutoTurnOver.Controllers ...@@ -833,6 +833,40 @@ namespace AutoTurnOver.Controllers
} }
} }
public JsonResult GetSkuPage(string buyer_name, string bailun_sku, string product_inner_code, string product_code, int offset, int limit, string order, string sort)
{
try
{
var m = new dc_base_sku_search_dto
{
product_code = product_code,
buyer_name = buyer_name,
bailun_sku = bailun_sku,
product_inner_code = product_inner_code,
page = (offset / limit) + 1,
rows = limit,
sidx = sort,
sord = order,
};
var services = new ReportServices();
var page_data = services.GetSkuPage(m);
return new JsonResult(new
{
rows = page_data.Items,
total = page_data.TotalItems
});
}
catch (Exception ex)
{
return new JsonResult(new
{
message = ex.Message,
stack_trace = ex.StackTrace
});
}
}
public JsonResult GetInventoryStockSumFooter(string warehousetype, int offset, int limit, string order, string sort, int? warehousearea, string warehouse_code) public JsonResult GetInventoryStockSumFooter(string warehousetype, int offset, int limit, string order, string sort, int? warehousearea, string warehouse_code)
{ {
......
using AutoTurnOver.DB;
using Microsoft.Extensions.Hosting;
using System;
using System.Collections.Generic;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
namespace ResetOutofstock
{
public class CaseFlowBackgrounService : BackgroundService
{
private Timer _timer;
protected override Task ExecuteAsync(CancellationToken stoppingToken)
{
_timer = new Timer(DoWork, null, TimeSpan.Zero, TimeSpan.FromMinutes(1));
return Task.CompletedTask;
}
private void DoWork(object state)
{
var now = DateTime.Now;
if (now.Hour == 01 && now.Minute == 01)
{
Console.WriteLine($"开始 刷新现金流 订单数据,线程Id:{Thread.CurrentThread.ManagedThreadId}{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
report_cash_flow_dao.CalculationOrder(now.AddMonths(-3),DateTime.Parse(now.AddDays(-1).ToString("yyyy-MM-dd 23:59:59")));
Console.WriteLine($"结束刷新现金流 订单数据,线程Id:{Thread.CurrentThread.ManagedThreadId}{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
}
if (now.Hour == 01 && now.Minute == 02)
{
Console.WriteLine($"开始 刷新现金流 采购数据,线程Id:{Thread.CurrentThread.ManagedThreadId}{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
report_cash_flow_dao.CalculationPurchaseOrder(now.AddMonths(-3), DateTime.Parse(now.AddDays(-1).ToString("yyyy-MM-dd 23:59:59")));
Console.WriteLine($"结束刷新现金流 采购数据,线程Id:{Thread.CurrentThread.ManagedThreadId}{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
}
if (now.Hour == 01 && now.Minute == 03)
{
Console.WriteLine($"开始 刷新现金流 调拨数据,线程Id:{Thread.CurrentThread.ManagedThreadId}{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
report_cash_flow_dao.CalculationTransferOrder(now.AddMonths(-3), DateTime.Parse(now.AddDays(-1).ToString("yyyy-MM-dd 23:59:59")));
Console.WriteLine($"结束刷新现金流 调拨数据,线程Id:{Thread.CurrentThread.ManagedThreadId}{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
}
if (now.Hour == 01 && now.Minute == 04)
{
Console.WriteLine($"开始 刷新现金流 退款数据,线程Id:{Thread.CurrentThread.ManagedThreadId}{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
report_cash_flow_dao.CalculationRefundOrder(now.AddMonths(-3), DateTime.Parse(now.AddDays(-1).ToString("yyyy-MM-dd 23:59:59")));
Console.WriteLine($"结束刷新现金流 退款数据,线程Id:{Thread.CurrentThread.ManagedThreadId}{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
}
}
public override void Dispose()
{
base.Dispose();
_timer?.Dispose();
}
}
}
...@@ -13,10 +13,12 @@ namespace ResetOutofstock ...@@ -13,10 +13,12 @@ namespace ResetOutofstock
static async Task Main(string[] args) static async Task Main(string[] args)
{ {
Console.WriteLine("刷新缺货数据任务启动..."); Console.WriteLine("刷新缺货数据任务启动...");
var now = DateTime.Now;
//report_cash_flow_dao.CalculationTransferOrder(now.AddMonths(-3), DateTime.Parse(now.AddDays(-1).ToString("yyyy-MM-dd 23:59:59")));
var builder = new HostBuilder().ConfigureServices((hostContext, services) => var builder = new HostBuilder().ConfigureServices((hostContext, services) =>
{ {
services.AddHostedService<ResetOutofstockBackgrounService>(); services.AddHostedService<ResetOutofstockBackgrounService>();
services.AddHostedService<CaseFlowBackgrounService>();
}); });
await builder.RunConsoleAsync(); await builder.RunConsoleAsync();
......
...@@ -90,6 +90,7 @@ namespace ResetOutofstock ...@@ -90,6 +90,7 @@ namespace ResetOutofstock
Thread.Sleep(30 * 60 * 1000); Thread.Sleep(30 * 60 * 1000);
} }
}); });
return Task.CompletedTask; return Task.CompletedTask;
} }
......
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