BusCutplanHeadService.cs 7.89 KB
using Hh.Mes.Common.Infrastructure;
using Hh.Mes.Common.log;
using Hh.Mes.Common.Request;
using Hh.Mes.POJO.Entity;
using Hh.Mes.POJO.Response;
using Hh.Mes.Service.Repository;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using Hh.Mes.Pojo.System;

namespace Hh.Mes.Service.Material
{
    public class BusCutplanHeadService : RepositorySqlSugar<bus_cutplan_head>
    {
        public dynamic Load(PageReq pageReq, bus_cutplan_head entity)
        {
            return ExceptionsHelp.Instance.ExecuteT(() =>
            {
                var result = new Response<List<bus_cutplan_head>>();
                var expression = LinqWhere(entity);
                //先组合查询表达式
                var query = Context.Queryable<bus_cutplan_head, base_material>
                    ((x, c) => new JoinQueryInfos(JoinType.Left, x.materialCode == c.materialCode))
                    .Where(expression)
                    .Select((x, c) => new bus_cutplan_head {
                        id=x.id,
                        keys=x.keys,
                        lotNo=x.lotNo,
                        materialCode=x.materialCode,
                        pipeLength = x.pipeLength,
                        lossCount = x.lossCount,
                        oddmentsCode = x.oddmentsCode,
                        oddmentsLength = x.oddmentsLength,
                        lineCode = x.lineCode,
                        planStartTime = x.planStartTime,
                        level = x.level,
                        state = x.state,
                        actualStartTime = x.actualStartTime,
                        actualEndTime = x.actualEndTime,
                        dischargeStartTime = x.dischargeStartTime,
                        dischargeEndTime = x.dischargeEndTime,
                        measureStartTime = x.measureStartTime,
                        measureEndTime = x.measureEndTime,
                        cutStartTime = x.cutStartTime,
                        cutEndTime = x.cutEndTime,
                        createTime = x.createTime,
                        createBy = x.createBy,
                        materialName = c.materialName
                    })
                    .OrderBy(x=>x.createTime,OrderByType.Desc);

                
                
                //Exel为ture就不分页,因为导出的话是全部导出
                if (pageReq != null)
                {
                    int total = 0;
                    result.Result = query.ToOffsetPage(pageReq.page, pageReq.limit, ref total);
                    result.Count = total;
                }
                else
                {
                    result.Result = query.ToList();
                    result.Count = result.Result.Count();
                }
                return result;
            }, catchRetrunValue: "list");
        }

        /// <summary>
        /// //获取明细列表 支持导出查询
        /// </summary>
        public Response LoadDesc(bus_cutplan_head model)
        {

            return ExceptionsHelp.Instance.ExecuteT(() =>
            {
                var result = new Response<List<bus_cutplan_detail>>();
                var query = Context.Queryable<bus_cutplan_detail,base_work_order_head>((x,b)=>new JoinQueryInfos(JoinType.Left,x.iwpNo==b.workOrderCode && x.barCode ==b.workPieceNo)).Where(x => x.headKeys == model.keys).Select((x, b) => new bus_cutplan_detail
                {
                    id = x.id,
                    headKeys = x.headKeys,
                    iwpNo = x.iwpNo,
                    barCode = x.barCode,
                    cuttingLength = x.cuttingLength,
                    cutFlanConfig = x.cutFlanConfig,
                    cutState = x.cutState,
                    cutStartTime = x.cutStartTime,
                    cutEndTime = x.cutEndTime,
                    cutLevel = x.cutLevel,
                    extend1 = x.extend1,
                    extend2 = x.extend2,
                    extend3 = x.extend3,
                    extend4 = x.extend4,
                    createTime = x.createTime,
                    createBy = x.createBy,
                    updateTime = x.updateTime,
                    updateBy = x.updateBy,
                    isendproduct = x.isendproduct,
                    workOrderHeadKeys = x.workOrderHeadKeys,
                    workOrderDetailKeys = x.workOrderDetailKeys,
                    bodyKeys = x.bodyKeys,
                    paintPrintCode = x.paintPrintCode,
                    flowOrientation1 = x.flowOrientation1,
                    measureStartTime = x.measureStartTime,
                    measureEndTime = x.measureEndTime,
                    prompt = x.prompt,
                    pageNumber = b.extend1
                }).OrderBy(x => x.id);
                result.Result = query.ToList();
                result.Count = result.Result.Count();

                return result;
            }, catchRetrunValue: "list");
        }

        public dynamic Ins(bus_cutplan_head entity)
        {
            return ExceptionsHelp.Instance.ExecuteT(() =>
            {
                var response = new Response();
                //entity.createBy = sysWebUser?.Account;
                //entity.createTime = DateTime.Now;
                response.Status = Add(entity);
                if (!response.Status) response.Message = SystemVariable.dataActionError;
                return response;
            });
        }

        public dynamic Upd(bus_cutplan_head entity)
        {
            return ExceptionsHelp.Instance.ExecuteT(() =>
            {
                var response = new Response();
                //entity.updateBy = sysWebUser?.Account;
                //entity.updateTime = DateTime.Now;
                response.Status = Update(entity);
                if (!response.Status) response.Message = SystemVariable.dataActionError;
                return response;
            });
        }

        public dynamic DelByIds(int[] ids)
        {
            return ExceptionsHelp.Instance.ExecuteT(() =>
            {
                var response = new Response();
                Context.Deleteable<bus_cutplan_head>(t => ids.Contains(t.id)).ExecuteCommand();
                return response;
            });
        }

        public Response ExportData(bus_cutplan_head entity)
        {
            return Load(null, entity);
        }

        public Expression<Func<bus_cutplan_head, bool>> LinqWhere(bus_cutplan_head model)
        {
            try
            {
                var exp = Expressionable.Create<bus_cutplan_head>();
                //数据过滤条件
                //if (!string.IsNullOrWhiteSpace(model.XXX)) exp.And(x => x.XXX.Contains(model.XXX));
                if (!string.IsNullOrWhiteSpace(model.lotNo))
                {
                    exp.And(x => x.lotNo.Contains(model.lotNo));
                }
                if (!string.IsNullOrWhiteSpace(model.materialCode))
                {
                    exp.And(x => x.materialCode.Contains(model.materialCode));
                }
                if (!string.IsNullOrWhiteSpace(model.lineCode))
                {
                    exp.And(x => x.lineCode.Contains(model.lineCode));
                }
                if (!string.IsNullOrWhiteSpace(model.oddmentsCode))
                {
                    exp.And(x => x.oddmentsCode.Contains(model.oddmentsCode));
                }
                if (!string.IsNullOrWhiteSpace(model.planStartTime))
                {
                    exp.And(x => SqlSugar.SqlFunc.DateIsSame(DateTime.Parse(x.planStartTime), DateTime.Parse(model.planStartTime)));
                }
                if (model.state > 0)
                {
                    exp.And(x => x.state == model.state);
                }

                return exp.ToExpression();//拼接表达式
            }
            catch (Exception ex)
            {
                throw new Exception($"{ex.Message}");
            }
        }
    }
}