using Dapper;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Web;

namespace VueWebApi.Tools
{
    public class AutosCloseOrder
    {
        public static string sql;
        public static DynamicParameters dynamicParams = new DynamicParameters();

        /// <summary>
        /// 判断是否自动关单
        /// </summary>
        /// <param name="mesordercode">工单号</param>
        /// <param name="partcode">产品编码</param>
        /// <param name="stepseq">工序序号</param>
        /// <param name="stepcode">工序编码</param>
        /// <param name="reportqty">报工合格数量</param>
        /// <param name="ngqty">报工不良数量</param>
        /// <returns></returns>
        public static List<object> AutosColseOrderReport(List<object> list, string mesordercode,string partcode, string stepseq, string stepcode, string reportqty, string ngqty)
        {
            //根据当前工单号查询任务单中末道工序编码及报工数量
            sql = @"select  seq,step_code,plan_qty,good_qty,ng_qty   from TK_Wrk_Step 
                    where wo_code=@wo_code and isend='Y'";
            dynamicParams.Add("@wo_code", mesordercode);
            var data = DapperHelper.selectdata(sql, dynamicParams);
            if (data.Rows.Count > 0)
            {
                //获取末道工序当次累计报工数量
                decimal sumreport_qty = decimal.Parse(reportqty) + decimal.Parse(data.Rows[0]["good_qty"].ToString());
                //判断末道工序当次累计报工数量是否>=任务数量
                if (sumreport_qty >= decimal.Parse(data.Rows[0]["plan_qty"].ToString()))
                {
                    //关闭工序任务单
                    sql = @"update TK_Wrk_Step set status='CLOSED'  where wo_code=@mesordercode";
                    list.Add(new { str = sql, parm = new { mesordercode = mesordercode} });
                    //关闭工单
                    sql = @"update TK_Wrk_Man set status='CLOSED'  where wo_code=@mesordercode";
                    list.Add(new { str = sql, parm = new { mesordercode = mesordercode} });

                    //根据工单号、产品编码查询所属订单编号
                    sql = @"select  sourceid,m_po   from TK_Wrk_Man 
                    where wo_code=@wo_code and materiel_code=@partcode";
                    dynamicParams.Add("@wo_code", mesordercode);
                    dynamicParams.Add("@partcode", partcode);
                    var data1 = DapperHelper.selectdata(sql, dynamicParams);
                    if (data1.Rows.Count > 0 && data1.Rows[0]["m_po"].ToString() != null) 
                    {
                        //根据订单号查询非当前工单的所有工单数量及工单状态
                        sql = @"select  plan_qty,status   from TK_Wrk_Man 
                                where m_po=@m_po and materiel_code=@partcode and wo_code<>@wo_code";
                        dynamicParams.Add("@m_po", data1.Rows[0]["m_po"].ToString());
                        dynamicParams.Add("@partcode", partcode);
                        dynamicParams.Add("@wo_code", mesordercode);
                        var data2 = DapperHelper.selectdata(sql, dynamicParams);
                        if (data2.Rows.Count > 0) 
                        {
                            //获取非当前工单(同物料)任务总数+当前工单的任务数量
                            decimal sumplanqty = data2.AsEnumerable().Select(d => d.Field<decimal>("plan_qty")).Sum()+ decimal.Parse(data.Rows[0]["plan_qty"].ToString());  //任务总数
                            //判断非当前工单(同物料)单据状态是否全部为关闭状态
                            if (data2.AsEnumerable().Select(d => d.Field<string>("status")).Distinct().Count()==1) 
                            {
                                //根据订单号、物料编码查询订单数量
                                sql = @"select  isnull(qty,0) as qty  from TKimp_Ewo 
                                where wo=@m_po and materiel_code=@partcode and id=@sourceid";
                                dynamicParams.Add("@m_po", data1.Rows[0]["m_po"].ToString());
                                dynamicParams.Add("@partcode", partcode);
                                dynamicParams.Add("@sourceid", data1.Rows[0]["sourceid"].ToString());
                                var data3 = DapperHelper.selectdata(sql, dynamicParams);
                                if (decimal.Parse(data3.Rows[0]["qty"].ToString()) == sumplanqty) 
                                {
                                    //关闭订单
                                    sql = @"update TKimp_Ewo set status='CLOSED'  where wo=@mesordercode and materiel_code=@materiel_code and id=@sourceid";
                                    list.Add(new { str = sql, parm = new { mesordercode = mesordercode, materiel_code = partcode, sourceid= data1.Rows[0]["sourceid"].ToString() } });
                                }
                            }
                        }
                    }
                }

            }
            return list;
        }
    }
}