CyclecountDetailApp.cs 5.47 KB
using Infrastructure;
using Microsoft.AspNetCore.Hosting;
using Microsoft.AspNetCore.Http;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using WebRepository;

namespace WebApp
{
    /// <summary>
	/// 盘点明细表
	/// </summary>
    
    public partial class CyclecountDetailApp
    {
        private IUnitWork _unitWork;
        public IRepository<CyclecountDetail> _app;
        private static IHostingEnvironment _hostingEnvironment;
        ExcelHelper imp = new ExcelHelper(_hostingEnvironment);

        public CyclecountDetailApp(IUnitWork unitWork, IRepository<CyclecountDetail> repository, IHostingEnvironment hostingEnvironment)
        {
            _unitWork = unitWork;
            _app = repository;
            _hostingEnvironment = hostingEnvironment;
        }
        
        public CyclecountDetailApp SetLoginInfo(LoginInfo loginInfo)
        {
            _app._loginInfo = loginInfo;
            return this;
        }
        
        public TableData Load(PageReq pageRequest, CyclecountDetail entity)
        {
            return _app.Load(pageRequest, entity);
        }

        public void Ins(CyclecountDetail entity)
        {
            _app.Add(entity);
        }

        public void BatchIns(List<CyclecountDetail> entitys)
        {
            _app.BatchAdd(entitys.ToArray());
        }

        public void Upd(CyclecountDetail entity)
        {
            _app.Update(entity);
        }

        public void DelByIds(int[] ids)
        {
            //删除盘点明细,更新库存的盘点状态
            foreach(var item in ids)
            {
                var detail = _app.FindSingle(u => u.Id == item);

                Inventory inventory = _unitWork.Find<Inventory>(u => u.Id == detail.InventoryId).FirstOrDefault();
                inventory.TaskStatus = "-1";
                _unitWork.Update(inventory);
            }

            _app.Delete(u => ids.Contains(u.Id.Value));
        }
        
        public CyclecountDetail FindSingle(Expression<Func<CyclecountDetail, bool>> exp)
        {
            return _app.FindSingle(exp);
        }

        public IQueryable<CyclecountDetail> Find(Expression<Func<CyclecountDetail, bool>> exp)
        {
            return _app.Find(exp);
        }

        public Response ImportIn(IFormFile excelfile)
        {
            Response result = new Infrastructure.Response();
            List<CyclecountDetail> exp = imp.ConvertToModel<CyclecountDetail>(excelfile);
            string sErrorMsg = "";

            for (int i = 0; i < exp.Count; i++)
            {
                try
                {
                    CyclecountDetail e = exp[i];
                    e.Id = null;
                    _app.Add(e);
                }
                catch (Exception ex)
                {
                    sErrorMsg += "第" + (i + 2) + "行:" + ex.Message + "<br>";
                    result.Message = sErrorMsg;
                    break;
                }
            }
            if (sErrorMsg.Equals(string.Empty))
            {
                if (exp.Count == 0)
                {
                    sErrorMsg += "没有发现有效数据, 请确定模板是否正确, 或是否有填充数据!";
                    result.Message = sErrorMsg;
                }
                else
                {
                    result.Message = "导入完成";
                }
            }
            else
            {
                result.Status = false;
                result.Message = result.Message;
            }
            return result;
        }

        public TableData ExportData(CyclecountDetail entity)
        {
            return _app.ExportData(entity);
        }

        public TableData Query(CyclecountDetail entity)
        {
            var result = new TableData();
            var data = _app.Find(EntityToExpression<CyclecountDetail>.GetExpressions(entity));

            GetData(data, result);
            result.count = data.Count();

            return result;
        }

        public void GetData(IQueryable<CyclecountDetail> data, TableData result, PageReq pageRequest = null)
        {
            _app.GetData(data, result, pageRequest);
        }

        public void Insert(CyclecountDetail entity)
        {
            string containerCode = entity.ContainerCode;
            string materialCode = entity.MaterialCode;

            if(containerCode != null && materialCode != null)
            {
                Inventory inventory = _unitWork.Find<Inventory>(u => u.ContainerCode == containerCode && u.MaterialCode == materialCode).FirstOrDefault();
                inventory.TaskStatus = "1";
                _unitWork.Update(inventory);

                entity.SystemQty = inventory.Qty;
                _app.Add(entity);
            }
        }

        public void BatchInsert(List<CyclecountDetail> entitys)
        {
            foreach (var item in entitys)
            {
                string containerCode = item.ContainerCode;
                string materialCode = item.MaterialCode;

                if (containerCode != null && materialCode != null)
                {
                    Inventory inventory = _unitWork.Find<Inventory>(u => u.ContainerCode == containerCode && u.MaterialCode == materialCode).FirstOrDefault();
                    inventory.TaskStatus = "1";
                    _unitWork.Update(inventory);

                    item.SystemQty = inventory.Qty;
                    _app.Add(item);
                }
            }
        }
    }
}