using BBWY.Client.APIServices;
using BBWY.Client.Extensions;
using BBWY.Client.Models;
using BBWY.Common.Models;
using GalaSoft.MvvmLight.Command;
using Microsoft.Win32;
using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Data;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows;
using System.Windows.Input;
namespace BBWY.Client.ViewModels
{
public class ProcurementAuditViewModel : BaseVM, IDenpendency
{
private AuditFile selectAuditFile;
private bool isLoading;
private bool isAudited;
private bool isShowPayBillPanel;
//private bool isShowPurchaseOrderPanel;
//private bool isShowShopOrderPanel;
private bool onlyException;
private ShopService shopService;
private PurchaseOrderService purchaseOrderService;
private Department selectedDepartment;
private DateTime startDate;
private DateTime endDate;
public Department SelectedDepartment
{
get => selectedDepartment; set
{
if (Set(ref selectedDepartment, value))
{
foreach (var s in value.ShopList)
s.IsSelected = false;
}
}
}
public DateTime StartDate { get => startDate; set { Set(ref startDate, value); } }
public DateTime EndDate { get => endDate; set { Set(ref endDate, value); } }
public IList<AuditFile> AuditFileList { get; set; }
public IList<AuditPayBill> AuditPayBillList { get; set; }
public IList<Department> DepartmentList { get; set; }
//public IList<AuditPurchaseOrder> AuditPurchaseOrderList { get; set; }
//public IList<AuditShopOrder> AuditShopOrderList { get; set; }
public IList<AuditPayBill> ShowAuditPayBillList { get; set; }
//public IList<AuditPurchaseOrder> ShowAuditPurchaseOrderList { get; set; }
//public IList<AuditShopOrder> ShowAuditShopOrderList { get; set; }
public AuditFile SelectAuditFile
{
get => selectAuditFile; set
{
if (Set(ref selectAuditFile, value))
OnSelectAuditFileChanged();
}
}
public bool IsLoading { get => isLoading; set { Set(ref isLoading, value); } }
public bool IsAudited { get => isAudited; set { Set(ref isAudited, value); } }
public bool IsShowPayBillPanel
{
get => isShowPayBillPanel; set
{
Set(ref isShowPayBillPanel, value);
//if (Set(ref isShowPayBillPanel, value))
//{
// if (value)
// {
// IsShowPurchaseOrderPanel = false;
// IsShowShopOrderPanel = false;
// }
//}
}
}
//public bool IsShowPurchaseOrderPanel
//{
// get => isShowPurchaseOrderPanel; set
// {
// if (Set(ref isShowPurchaseOrderPanel, value))
// {
// if (value)
// {
// IsShowPayBillPanel = false;
// IsShowShopOrderPanel = false;
// }
// }
// }
//}
//public bool IsShowShopOrderPanel
//{
// get => isShowShopOrderPanel; set
// {
// if (Set(ref isShowShopOrderPanel, value))
// {
// if (value)
// {
// IsShowPayBillPanel = false;
// IsShowPurchaseOrderPanel = false;
// }
// }
// }
//}
public bool OnlyException
{
get => onlyException; set
{
if (Set(ref onlyException, value))
OnOnlyExceptionChanged();
}
}
public ICommand AuditCommand { get; set; }
public ICommand ClearAuditCommand { get; set; }
public ICommand ImportAliPayBillCommand { get; set; }
public ICommand Import1688PurchaseOrderCommand { get; set; }
public ICommand ImportJDShopOrderCommand { get; set; }
public ProcurementAuditViewModel(ShopService shopService, PurchaseOrderService purchaseOrderService)
{
AuditFileList = new ObservableCollection<AuditFile>();
AuditCommand = new RelayCommand(Audit);
ClearAuditCommand = new RelayCommand(ClearAudit);
ImportAliPayBillCommand = new RelayCommand(ImportAliPayBill);
this.shopService = shopService;
this.purchaseOrderService = purchaseOrderService;
DepartmentList = new ObservableCollection<Department>();
AuditFileList = new ObservableCollection<AuditFile>();
AuditPayBillList = new List<AuditPayBill>();
//AuditPurchaseOrderList = new List<AuditPurchaseOrder>();
//AuditShopOrderList = new List<AuditShopOrder>();
ShowAuditPayBillList = new ObservableCollection<AuditPayBill>();
//ShowAuditPurchaseOrderList = new ObservableCollection<AuditPurchaseOrder>();
//ShowAuditShopOrderList = new ObservableCollection<AuditShopOrder>();
//AuditFileList.Add(new AuditFile() { FileName = "支付宝账单20220527.csv", AuditFileType = AuditFileType.账单 });
//AuditFileList.Add(new AuditFile() { FileName = "1688采购单20220527.csv", AuditFileType = AuditFileType.采购单 });
//AuditFileList.Add(new AuditFile() { FileName = "支付宝账单20220527.csv", AuditFileType = AuditFileType.销售订单 });
LoadDepartment();
StartDate = DateTime.Now.Date;
EndDate = DateTime.Now.Date;
}
private void LoadDepartment()
{
Task.Factory.StartNew(() => shopService.GetDepartmentList()).ContinueWith(t =>
{
var response = t.Result;
if (!response.Success)
{
App.Current.Dispatcher.Invoke(() => MessageBox.Show(response.Msg, "提示"));
return;
}
App.Current.Dispatcher.Invoke(() =>
{
foreach (var d in response.Data)
DepartmentList.Add(d);
SelectedDepartment = DepartmentList[0];
});
});
}
private void Audit()
{
if (IsLoading)
return;
if (AuditPayBillList.Count() == 0 || !SelectedDepartment.ShopList.Any(s => s.IsSelected))
{
MessageBox.Show("审核数据不全", "提示");
return;
}
var waitList = new List<EventWaitHandle>()
{
new ManualResetEvent(false)
};
IsLoading = true;
var shopList = SelectedDepartment.ShopList.Where(s => s.IsSelected).ToList();
var sDate = StartDate.AddDays(-5);
var eDate = EndDate;
Task.Factory.StartNew(() =>
{
AuditByPayBill(waitList[0], shopList, sDate, eDate);
//AuditByPurchaseOrder(waitList[1]);
}).ContinueWith(t =>
{
WaitHandle.WaitAll(waitList.ToArray(), -1);
IsLoading = false;
IsAudited = true;
App.Current.Dispatcher.BeginInvoke((Action)delegate
{
SelectAuditFile = AuditFileList.FirstOrDefault(f => f.AuditFileType == AuditFileType.账单);
});
});
}
private void AuditByPayBill(EventWaitHandle ewh, IList<SimpleShop> shopList, DateTime startDate, DateTime endDate)
{
try
{
var auditPurchaseOrderResponse = purchaseOrderService.GetAuditPurchaseOrderList(shopList.Select(s => s.Id).ToList(), startDate, endDate);
if (!auditPurchaseOrderResponse.Success)
throw new Exception($"获取采购单失败,{auditPurchaseOrderResponse.Msg}");
foreach (var payBill in AuditPayBillList)
{
payBill.ErrorMessage = String.Empty;
#region 匹配采购单
var relationPurchaseOrder = auditPurchaseOrderResponse.Data.FirstOrDefault(p => p.PurchaseOrderId == payBill.MerchantOrderNo);
if (relationPurchaseOrder == null)
{
payBill.ErrorMessage = "未匹配采购单";
continue;
}
payBill.RelationPurchaseOrderId = relationPurchaseOrder.PurchaseOrderId;
payBill.RelationShopOrderId = relationPurchaseOrder.OrderId;
payBill.BelongShopId = relationPurchaseOrder.ShopId;
payBill.BelongShop = shopList.FirstOrDefault(s => s.Id == relationPurchaseOrder.ShopId)?.Name;
#endregion
}
}
catch (Exception ex)
{
App.Current.Dispatcher.Invoke(() => MessageBox.Show(ex.Message, "账单匹配"));
}
finally
{
ewh.Set();
}
}
//private void AuditByPurchaseOrder(EventWaitHandle ewh)
//{
// try
// {
// foreach (var purchaseOrder in AuditPurchaseOrderList)
// {
// #region 匹配账单
// var relationPayBill = AuditPayBillList.FirstOrDefault(b => b.MerchantOrderNo == purchaseOrder.PurchaseOrderId);
// if (relationPayBill == null)
// {
// //未通过商户订单号找到采购单,则通过账单金额和日期匹配
// relationPayBill = AuditPayBillList.FirstOrDefault(b => purchaseOrder.PayAmount == b.ExpenditureAmount &&
// purchaseOrder.PayTime != null && b.PayTime != null &&
// Math.Abs((b.PayTime.Value - purchaseOrder.PayTime.Value).TotalSeconds) <= 60);
// }
// if (relationPayBill == null)
// {
// purchaseOrder.ErrorMessage = "未匹配支付账单";
// continue;
// }
// purchaseOrder.RelationPayBillNo = relationPayBill.PayBillNo;
// #endregion
// #region 匹配销售单
// var relationShopOrder = AuditShopOrderList.FirstOrDefault(o => (!string.IsNullOrEmpty(o.VenderRemark) && o.VenderRemark.Contains(purchaseOrder.PurchaseOrderId)) ||
// (o.Phone == purchaseOrder.Phone &&
// o.ContactName == purchaseOrder.ContactName &&
// o.PayTime != null && purchaseOrder.PayTime != null &&
// (purchaseOrder.PayTime.Value - o.PayTime.Value).TotalDays <= 2));
// if (relationShopOrder == null)
// {
// purchaseOrder.ErrorMessage = "未匹配销售订单";
// continue;
// }
// purchaseOrder.RelationShopOrderId = relationShopOrder.OrderId;
// #endregion
// }
// var relationShopOrderIds = AuditPurchaseOrderList.Where(p => !string.IsNullOrEmpty(p.RelationShopOrderId)).Select(p => p.RelationShopOrderId).ToList();
// var belongResponse = shopService.GetOrderBelongShop(relationShopOrderIds);
// if (!belongResponse.Success || belongResponse.Data.Count() == 0)
// return;
// foreach (var purchaseOrder in AuditPurchaseOrderList)
// {
// if (string.IsNullOrEmpty(purchaseOrder.RelationShopOrderId))
// continue;
// var belongShop = belongResponse.Data.FirstOrDefault(x => x.OrderIdList.Contains(purchaseOrder.RelationShopOrderId));
// if (belongShop != null)
// purchaseOrder.BelongShop = belongShop.ShopName;
// }
// }
// catch (Exception ex)
// {
// App.Current.Dispatcher.Invoke(() => MessageBox.Show(ex.Message, "采购单匹配"));
// }
// finally
// {
// ewh.Set();
// }
//}
private void ClearAudit()
{
SelectAuditFile = null;
AuditFileList.Clear();
AuditPayBillList.Clear();
//AuditPurchaseOrderList.Clear();
//AuditShopOrderList.Clear();
ShowAuditPayBillList.Clear();
//ShowAuditPurchaseOrderList.Clear();
//ShowAuditShopOrderList.Clear();
IsAudited = false;
IsShowPayBillPanel = false;
//IsShowPurchaseOrderPanel = false;
//IsShowShopOrderPanel = false;
OnlyException = false;
}
private (string ErrorMessage, string FileName, List<string> Lines) ImportAuditFile(AuditFileType auditFileType)
{
var ofd = new OpenFileDialog() { Filter = "CSV Files (*.csv)|*.csv" };
if (ofd.ShowDialog() != true)
return (string.Empty, string.Empty, null);
var fileName = ofd.FileName.Substring(ofd.FileName.LastIndexOf("\\") + 1);
var filePath = ofd.FileName;
if (AuditFileList.Any(f => f.FileName == fileName))
return ("文件已存在", string.Empty, null);
try
{
//var dt = new DataTable();
//using (var reader = File.OpenText(filePath))
//{
// using (var csv = new CsvHelper.CsvReader(reader, CultureInfo.InvariantCulture))
// using (var dataReader = new CsvHelper.CsvDataReader(csv))
// {
// dt.Load(dataReader);
// }
//}
var lines = File.ReadAllLines(filePath, Encoding.GetEncoding("GB2312")).ToList();
AuditFileList.Add(new AuditFile() { FileName = fileName, AuditFileType = auditFileType });
return (string.Empty, fileName, lines);
}
catch (Exception ex)
{
return (ex.Message, string.Empty, null);
}
}
/// <summary>
/// 导入支付宝账单
/// </summary>
private void ImportAliPayBill()
{
var importResult = ImportAuditFile(AuditFileType.账单);
if (!string.IsNullOrEmpty(importResult.ErrorMessage))
{
MessageBox.Show(importResult.ErrorMessage, "导入支付宝账单");
return;
}
if (importResult.Lines == null || importResult.Lines.Count == 0)
return;
//忽略前5行
/*
#支付宝账务明细查询
#账号：[20883422054731100156]
#起始日期：[2022年04月01日 00:00:00] 终止日期：[2022年05月01日 00:00:00]
#-----------------------------------------账务明细列表----------------------------------------
账务流水号 业务流水号 商户订单号 商品名称 发生时间 对方账号 收入金额（+元） 支出金额（-元） 账户余额（元） 交易渠道 业务类型 备注
*/
for (var i = 0; i < 5; i++)
importResult.Lines.RemoveAt(0);
//忽略后4行
/*
#-----------------------------------------账务明细列表结束------------------------------------
#支出合计：681笔，共-39623.27元
#收入合计：85笔，共43889.26元
#导出时间：[2022年05月01日 10:13:45]
*/
for (var i = 0; i < 4; i++)
{
importResult.Lines.RemoveAt(importResult.Lines.Count() - 1);
}
var payBillNo = "";
try
{
foreach (var line in importResult.Lines)
{
var array = line.CSVstrToArry();
var sourceMerchantOrderNo = array[2].FormatString();
//if (!string.IsNullOrEmpty(sourceMerchantOrderNo))
// continue; //暂时不支持此类商户单号
var expenditureAmount = decimal.Parse(array[7].FormatString());
if (expenditureAmount == 0) //支出为0的账单不参与审计
continue;
payBillNo = array[0].FormatString();
if (AuditPayBillList.Any(p => p.PayBillNo == payBillNo))
continue;
var payBill = new AuditPayBill()
{
BelongFileName = importResult.FileName,
PayBillNo = payBillNo,
PayBillType = PayBillType.AliPay,
SourceMerchantOrderNo = sourceMerchantOrderNo,
ProductName = array[3].FormatString(),
PayTime = DateTime.Parse(array[4].FormatString()),
OppositeAccount = array[5].FormatString(),
ExpenditureAmount = Math.Abs(expenditureAmount),
Remark = array[11]
};
payBill.MerchantOrderNo = payBill.SourceMerchantOrderNo;
if (payBill.SourceMerchantOrderNo.StartsWith("T50060NP"))
payBill.MerchantOrderNo = payBill.SourceMerchantOrderNo.Substring(8);
AuditPayBillList.Add(payBill);
}
}
catch (Exception ex)
{
MessageBox.Show($"问题账单号{payBillNo} {ex.Message}", "导入支付宝账单");
}
}
/// <summary>
/// 采购审计文件对象改变事件
/// </summary>
private void OnSelectAuditFileChanged()
{
if (SelectAuditFile == null)
return;
if (SelectAuditFile.AuditFileType == AuditFileType.账单)
{
IsShowPayBillPanel = true;
ShowAuditPayBillList.Clear();
var where = AuditPayBillList.Where(b => b.BelongFileName == SelectAuditFile.FileName);
if (OnlyException)
where = where.Where(b => !string.IsNullOrEmpty(b.ErrorMessage));
var list = where.ToList();
foreach (var b in list)
ShowAuditPayBillList.Add(b);
}
}
private void OnOnlyExceptionChanged()
{
if (SelectAuditFile == null || AuditFileList.Count() == 0)
return;
var f = SelectAuditFile;
SelectAuditFile = null;
SelectAuditFile = f;
}
}
}