using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data;
using DevComponents.DotNetBar.Controls;
using System.Windows.Forms;
using System.Drawing;
using System.Data.SqlClient;
using com.force.json;

namespace WCS
{
    public class WcsUpdate
    {
        /// <summary>
        /// 添加ListView界面显示
        /// </summary>
        /// <param name="le">listview</param>
        /// <param name="seq">需要</param>
        /// <param name="Errif">异常信息</param>
        /// <param name="arg_string">显示内容</param>
        public static void add_dw_log(ListViewEx le, string seq, string Errif, string arg_string)
        {
            try
            {
                ListViewItem lvi = new ListViewItem();
                lvi.SubItems[0].Text = "【" + DateTime.Now.ToString() + "】" + seq + arg_string;
                if (Errif == "N")
                {
                    lvi.ForeColor = Color.Black;
                }
                else if (Errif == "E")
                {
                    lvi.ForeColor = Color.Red;
                }
                else if (Errif == "P")
                {
                    lvi.ForeColor = Color.Blue;
                }
                le.Items.Add(lvi);
                le.EnsureVisible(le.Items.Count - 1);
            }
            catch (Exception em)
            {
                ListViewItem lvi = new ListViewItem();
                lvi.SubItems[0].Text = "【" + DateTime.Now.ToString() + "】" + seq + arg_string + "异常：" + em.Message;
                le.Items.Add(lvi);
            }
        }

        /// <summary>
        /// 读取wms命令档wms_command表，生成出库工作档
        /// </summary>
        /// <param name="le"></param>
        /// <param name="seq"></param>
        /// <returns></returns>
        public static void ProcOutToWorkData(ListViewEx le, string seq)
        {         
            string s_wmsId = "", s_boxId = "", s_location = "", s_locno = "";
            string ls_error_memo = "", sql = "";
            int i_station = 0, i_wrkno = 0;
            DateTime ldt_date = System.DateTime.Now;

            add_dw_log(le, seq, "N", "--处理WMS命令档，生成出库工作档......");

            try
            {
                //sql = "select * from asr_wrk_masp where wrk_sts<5 or (wrk_sts>10 and wrk_sts<14)";
                //int count = Common.ExecAsrsSelect1(sql);
                //if (Common.GetWrkOutCount() > 0 || Common.GetWrkInCount() > 0)
                if (Common.plc_s_loading[0, 0] == "Y" || Common.plc_s_loading[0, 1] == "Y")
                {
                    add_dw_log(le, seq, "N", "--站点有物，无法生成出库工作档......");
                    return;
                }
                if (Common.GetWrkCount() > 0)
                {
                    add_dw_log(le, seq, "N", "--工作档中存在未完成资料，无法生成出库工作档......");
                    return;
                }

                sql = "select top 1 wmsId,boxId,station,loc_no from wms_command ";
                sql += " where messageName='StackerStoreOut' and status<>'Y' order by status";
                DataView dv = Common.ExecAsrsSelect(sql);
                if (dv.Count <= 0)
                {
                    return;
                }
                foreach (DataRowView drow in dv)
                {
                    s_wmsId = drow[0].ToString();
                    s_boxId = drow[1].ToString();
                    i_station = Int32.Parse(drow[2].ToString());
                    s_location = drow[3].ToString();
                }
                add_dw_log(le, "", "P", "   " + seq + ".1 正在处理周转箱单号:" + s_boxId);

                sql = "select loc_no from asr_stk_mast where boxId='" + s_boxId + "' and loc_sts='D'";
                dv = Common.ExecAsrsSelect(sql);
                if (dv.Count <= 0)
                {
                    ls_error_memo = "   " + seq + ".2 编号" + s_boxId + "的周转箱不存在或非在库状态，请检查";
                    add_dw_log(le, "", "E", ls_error_memo);                    
                    goto re;
                }
                foreach (DataRowView drow in dv)
                {                    
                    s_locno = drow[0].ToString();
                }
                if (s_location != s_locno && s_location != "")
                {
                    ls_error_memo = "   " + seq + ".3 WMS下发的周转箱编号(" + s_boxId + ")出库库位(" + s_location + ")与ASRS库存库位(" + s_locno + ")不符";
                    add_dw_log(le, "", "E", ls_error_memo); 
                    goto re;
                }

                i_wrkno = Common.GetWrkno(2);
                sql = "insert into asr_wrk_masp(wrk_no,wrk_sts,io_type,crn_no,io_pri,source_loc_no,sta_no,source_sta_no,wmsId,boxId) ";
                sql += " values(" + i_wrkno + ",11,110,1,13.5,'" + s_locno + "',1,2,'" + s_wmsId + "','" + s_boxId + "'); ";
                sql += " update asr_stk_mast set loc_sts='R' where loc_no='" + s_locno + "'; ";
                sql += " update wms_command set status='Y' where wmsId='" + s_wmsId + "' and boxId='" + s_boxId + "';";
                SqlConnection sqlconn = new SqlConnection(Common.sqlcon);
                sqlconn.Open();
                SqlTransaction sqltrans = sqlconn.BeginTransaction();                
                SqlCommand sqlcmd = new SqlCommand(sql, sqlconn);
                sqlcmd.Transaction = sqltrans;
                try
                {
                    sqlcmd.ExecuteNonQuery();
                    sqltrans.Commit();
                }
                catch (SqlException t)
                {
                    sqltrans.Rollback();
                    //sqlcommon.Close();
                    ls_error_memo = "   " + seq + ".4 插入工作主档[asr_wrk_masp]错误 !单号:" + s_boxId + " 异常:" + t.Message;
                    add_dw_log(le, "", "E", ls_error_memo);
                    goto re;
                }
                finally
                {
                    sqlcmd.Dispose();
                    sqlconn.Dispose();
                }
                return;

                re:
                sql = "update wms_command set status='X' where wmsId='" + s_wmsId + "' and boxId='" + s_boxId + "'";
                bool result = Common.ExecAsrsModify(sql);
                if (!result)
                {
                    ls_error_memo = "   " + seq + ".5 更新wms命令档失败!wmsId：" + s_wmsId + "boxId：" + s_boxId;
                    add_dw_log(le, "", "E", ls_error_memo);
                }
            }
            catch (Exception em)
            {
                ls_error_memo = "   " + seq + ".6 处理待处理档生成出库工作档失败：" + em.Message;
                add_dw_log(le, "", "E", ls_error_memo);
            }
        }

        /// <summary>
        /// 处理工作档中工作状态为4和14、6的资料，更新库存档、待处理档，并添加上报wms任务队列commandQueue
        /// </summary>
        public static void ProcWorkMast(ListViewEx le, string seq)
        {
            string ls_error_memo = "" ,sql = "";
            int li_wrk_no = 0, li_wrk_sts = 0, li_io_type = 0, li_sta_no = 0, li_source_sta_no = 0, li_wrk_model = 1;
            string ls_loc_no = "", ls_source_loc_no = "", ls_wmsId = "", ls_boxId = "";
            DateTime ldt_date = System.DateTime.Now;
            add_dw_log(le, seq, "N", "--处理工作档 (status=4,14)......");
            try
            {
                try
                {
                    DataView dv = Common.ExecAsrsSelect("select getdate() from sys_dual");
                    foreach (System.Data.DataRowView drow in dv)
                    {
                        ldt_date = Convert.ToDateTime(drow[0]);
                    }
                }
                catch (SqlException)
                {
                    return;
                }

                sql = "select wrk_no,wrk_sts,io_type,loc_no,sta_no,source_sta_no,source_loc_no,wmsId,boxId,wrk_model ";
                sql += " from asr_wrk_masp where (((wrk_sts = 4 Or wrk_sts = 14 ) and io_type <> 103 and io_type <> 104 and io_type <> 107 ) or (wrk_sts = 2 and io_type=6)) ";
                sql += " order by upd_mk,io_time,wrk_no";
                DataView dv_wrkmast = Common.ExecAsrsSelect(sql);
                if (dv_wrkmast==null || dv_wrkmast.Count < 1)
                {
                    add_dw_log(le, "", "N", "   " + seq + ".1 工作档 [asr_wrk_masp] 没有资料!");
                    return;
                }
                foreach (DataRowView drow_wrkmast in dv_wrkmast)
                {
                    li_wrk_no = Convert.ToInt32(drow_wrkmast[0]);
                    li_wrk_sts = Convert.ToInt32(drow_wrkmast[1]);
                    li_io_type = Convert.ToInt32(drow_wrkmast[2]);
                    ls_loc_no = drow_wrkmast[3].ToString();
                    li_sta_no = Convert.ToInt32(drow_wrkmast[4]);
                    li_source_sta_no = Convert.ToInt32(drow_wrkmast[5]);
                    ls_source_loc_no = drow_wrkmast[6].ToString();
                    ls_wmsId = drow_wrkmast[7].ToString();
                    ls_boxId = drow_wrkmast[8].ToString();
                    li_wrk_model = Convert.ToInt32(drow_wrkmast[9].ToString());

                    add_dw_log(le, "", "P", "   " + seq + ".2 处理工作档:" + li_wrk_no.ToString());
                    SqlConnection sqlconn = new SqlConnection(Common.sqlcon);
                    sqlconn.Open();
                    SqlTransaction sqltrans = sqlconn.BeginTransaction();
                    if (li_wrk_sts == 4)
                    {
                        switch (li_io_type)
                        {
                            case 10:
                                sql = "update asr_stk_mast set loc_sts='D',io_time='" + ldt_date + "',wmsId='" + ls_wmsId + "',boxId='" + ls_boxId + "'";
                                sql += " where loc_no='" + ls_loc_no + "' and (loc_sts = 'S' Or loc_sts = 'Q')";
                                SqlCommand cmd_10 = new SqlCommand(sql, sqlconn);
                                cmd_10.Transaction = sqltrans;
                                try
                                {
                                    cmd_10.ExecuteNonQuery();
                                }
                                catch (SqlException t)
                                {
                                    sqltrans.Rollback();
                                    cmd_10.Dispose();
                                    sqlconn.Dispose();
                                    ls_error_memo = "   " + seq + ".2.1 入库－更新库位状态异常 [asr_stk_mast] !工作号:" + li_wrk_no.ToString() + "  库位号:" + ls_loc_no + " 异常:" + t.Message;
                                    add_dw_log(le, "", "E", ls_error_memo);
                                    goto re;
                                }
                                break;
                        }

                        sql = "update asr_wrk_masp set wrk_sts=5,modi_time='" + ldt_date + "' where wrk_no=" + li_wrk_no + "; ";
                        if (li_wrk_model == 1)
                        {
                            sql += " update wms_command set Io_status='Y',upd_mk='Y' where wmsId='" + ls_wmsId + "' and boxId='" + ls_boxId + "';";
                        }
                        SqlCommand cmd_wrk = new SqlCommand(sql, sqlconn);
                        cmd_wrk.Transaction = sqltrans;
                        try
                        {
                            cmd_wrk.ExecuteNonQuery();
                        }
                        catch (SqlException t)
                        {
                            sqltrans.Rollback();
                            cmd_wrk.Dispose();
                            sqlconn.Dispose();
                            ls_error_memo = "   " + seq + ".2.2 更新工作状态异常 [asr_wrk_masp] !工作号:" + li_wrk_no.ToString() + " 时间:" + ldt_date.ToString() + " 异常:" + t.Message;
                            add_dw_log(le, "", "E", ls_error_memo);
                            goto re;
                        }
                        //向WMS上报状态
                        JSONObject json = new JSONObject();
                        json.put("messageName", "StackerTaskState");
                        json.put("boxId", ls_boxId);
                        json.put("wmsId", ls_wmsId);
                        json.put("type", "STACKER");
                        json.put("flashId", "1");
                        if (li_wrk_model == 1)
                        {
                            json.put("isInit", 1);
                        }
                        else
                        {
                            json.put("isInit", 0);
                        }
                        json.put("station", "2");
                        JSONObject obj_location = new JSONObject();
                        obj_location.put("s_level", 1);
                        obj_location.put("s_location", 10011);
                        int e_level = int.Parse(ls_loc_no.Substring(6,1));
                        obj_location.put("e_level", e_level);
                        int e_location = int.Parse("1" + ls_loc_no.Substring(2, 3) + ls_loc_no.Substring(1, 1));
                        obj_location.put("e_location", e_location);
                        obj_location.put("r_level", 0);
                        obj_location.put("r_location", 0);
                        json.put("state", 3);
                        json.put("location", obj_location);
                    }
                    else if (li_wrk_sts == 14)
                    {
                        switch (li_io_type)
                        {
                            case 110:
                                sql = "update asr_stk_mast set loc_sts='O',io_time='" + ldt_date + "',wmsId='',boxId=''";
                                sql += " where loc_no='" + ls_source_loc_no + "' and loc_sts = 'R'";
                                SqlCommand cmd_110 = new SqlCommand(sql, sqlconn);
                                cmd_110.Transaction = sqltrans;
                                try
                                {
                                    cmd_110.ExecuteNonQuery();
                                }
                                catch (SqlException t)
                                {
                                    sqltrans.Rollback();
                                    cmd_110.Dispose();
                                    sqlconn.Dispose();
                                    ls_error_memo = "   " + seq + ".2.3 出库－更新库位状态异常[asr_stk_mast] !库位号:" + ls_source_loc_no + " 异常:" + t.Message;
                                    add_dw_log(le, "", "E", ls_error_memo);
                                    goto re;
                                }
                                break;
                        }

                        sql = "update asr_wrk_masp set wrk_sts=15,modi_time='" + ldt_date + "' where wrk_no=" + li_wrk_no + "; ";
                        if (li_wrk_model == 1)
                        {
                            sql += " update wms_command set Io_status='Y',upd_mk='Y' where wmsId='" + ls_wmsId + "' and boxId='" + ls_boxId + "';";
                        }
                        SqlCommand cmd_wrk1 = new SqlCommand(sql, sqlconn);
                        cmd_wrk1.Transaction = sqltrans;
                        try
                        {
                            cmd_wrk1.ExecuteNonQuery();
                        }
                        catch (SqlException t)
                        {
                            sqltrans.Rollback();
                            cmd_wrk1.Dispose();
                            sqltrans.Dispose();
                            ls_error_memo = "   " + seq + ".2.4 更新工作状态异常 [asr_wrk_masp] !工作号:" + li_wrk_no.ToString() + " 异常:" + t.Message;
                            add_dw_log(le, "", "E", ls_error_memo);
                            goto re;
                        }
                        JSONObject obj_location = new JSONObject();
                        int s_level = int.Parse(ls_source_loc_no.Substring(6, 1));
                        obj_location.put("s_level", s_level);
                        int s_location = int.Parse("1" + ls_source_loc_no.Substring(2, 3) + ls_source_loc_no.Substring(1, 1));
                        obj_location.put("s_location", s_location);
                        obj_location.put("e_level", 1);
                        obj_location.put("e_location", 10011);                        
                        obj_location.put("r_level", 0);
                        obj_location.put("r_location", 0);
                    }
                    sqltrans.Commit();
                    sqlconn.Dispose();
                }
            }
            catch (SqlException t)
            {
                ls_error_memo = "   " + seq + ".2.5 处理工作档数据失败! 异常:" + t.Message;
                add_dw_log(le, "", "E", ls_error_memo);
            }

            re:
            if (ls_error_memo != "")
            {
                try
                {
                    bool bl = Common.ExecAsrsModify("update dbo.asr_wrk_masp set upd_mk ='X',error_time='" + ldt_date + "',error_memo='" + ls_error_memo + "'  where wrk_no =" + li_wrk_no + "");
                }
                catch (SqlException t)
                {
                    ls_error_memo = "   " + seq + ".3.6 更新工作主档状态 [asr_wrk_masp] 异常! 工作号:" + li_wrk_no.ToString() + " 时间:" + ldt_date.ToString();
                    add_dw_log(le, "", "E", ls_error_memo);
                    return;
                }

            }
        }

        /// <summary>
        /// 处理工作档中工作状态为5和15的资料，转历史档
        /// </summary>
        public static void ProcWorkToLog(ListViewEx le, string seq)
        {
            string ls_error_memo = "";
            add_dw_log(le, seq, "N", "--处理工作档转历史档......");
            int wrkno = 0;
            try
            {
                string sql = "select top 1 wrk_no from asr_wrk_masp where (wrk_sts=5 or wrk_sts=15)";
                DataView dv = Common.ExecAsrsSelect(sql);
                if (dv.Count <= 0)
                {
                    add_dw_log(le, "", "N", "   " + seq + ".1 工作档 [asr_wrk_masp] 没有资料处理!");
                    return;
                }
                foreach (DataRowView drow in dv)
                {
                    wrkno = int.Parse(drow[0].ToString());
                }
                add_dw_log(le, "", "P", "   " + seq + ".1 正在处理转历史档" + wrkno);

                sql = "insert into asr_wrk_masp_log select * from asr_wrk_masp where wrk_no=" + wrkno + "; ";
                //sql += " and wrk_no not in (select wrk_no from dbo.asr_bas_devp) ";
                //sql += " and wrk_no not in (select wrk_no from dbo.asr_bas_crnp);";
                sql += " delete from asr_wrk_masp where wrk_no=" + wrkno + "; ";
                //sql += " and wrk_no not in (select wrk_no from dbo.asr_bas_devp) ";
                //sql += " and wrk_no not in (select wrk_no from dbo.asr_bas_crnp);";
                SqlConnection sqlconn = new SqlConnection(Common.sqlcon);
                sqlconn.Open();
                SqlTransaction sqltrans = sqlconn.BeginTransaction();
                SqlCommand sqlcmd = new SqlCommand(sql, sqlconn);
                sqlcmd.Transaction = sqltrans;
                try
                {
                    int result = sqlcmd.ExecuteNonQuery();
                    sqltrans.Commit();                    
                }
                catch (SqlException t)
                {
                    sqltrans.Rollback();
                    //sqlcommon.Close();
                    ls_error_memo = "   " + seq + ".1 工作档[asr_wrk_masp]转历史档错误 ! 异常:" + t.Message;
                    add_dw_log(le, "", "E", ls_error_memo);
                }
                finally
                {
                    sqlcmd.Dispose();
                    sqlconn.Dispose();
                }
                return;
            }
            catch (Exception t)
            {
                ls_error_memo = "   " + seq + ".2 处理工作档转历史档失败! 异常:" + t.Message;
                add_dw_log(le, "", "E", ls_error_memo);
            }
        }

        /// <summary>
        /// 处理wms命令档中已完结资料，转历史档
        /// </summary>
        public static void ProcWmsCommandToLog(ListViewEx le, string seq)
        {
            string ls_error_memo = "";
            add_dw_log(le, seq, "N", "--处理WMS命令档转历史档......");
            try
            {
                string sql = "insert into wms_command_log select * from wms_command where Io_status='Y' and upd_mk='Y';";
                sql += " delete from wms_command where Io_status='Y' and upd_mk='Y';";
                SqlConnection sqlconn = new SqlConnection(Common.sqlcon);
                sqlconn.Open();
                SqlTransaction sqltrans = sqlconn.BeginTransaction();
                SqlCommand sqlcmd = new SqlCommand(sql, sqlconn);
                sqlcmd.Transaction = sqltrans;
                try
                {
                    sqlcmd.ExecuteNonQuery();
                    sqltrans.Commit();
                }
                catch (SqlException t)
                {
                    sqltrans.Rollback();
                    //sqlcommon.Close();
                    ls_error_memo = "   " + seq + ".1 WMS命令档转历史档错误 ! 异常:" + t.Message;
                    add_dw_log(le, "", "E", ls_error_memo);
                }
                finally
                {
                    sqlcmd.Dispose();
                    sqlconn.Dispose();
                }
                return;
            }
            catch (Exception t)
            {
                ls_error_memo = "   " + seq + ".2 WMS命令档转历史档失败! 异常:" + t.Message;
                add_dw_log(le, "", "E", ls_error_memo);
            }
        }

        /// <summary>
        /// 同步货位信息到WMS
        /// </summary>
        public static void ProcReportLocationsResult(ListViewEx le, string seq)
        {
            string ls_error_memo = "", sql = "";
            string ls_messageName = "", ls_areaIdx = "";
            int li_requestlength = 0, li_totallength = 0, li_currentlength = 0, li_resultlength = 0;
            string ls_loc_no = "", ls_loc_sts = "", ls_boxId = "";
            int li_row1 = 0, li_bay1 = 0, li_lev1 = 0;
            add_dw_log(le, seq, "N", "--处理WMS货位信息同步命令......");
            try
            {
                sql = "select messageName,requestlength,areaIdx,totallength,currentlength ";
                sql += " from wms_command where messageName='InquiryLocations' and Io_status<>'Y' and currentlength<totallength ";
                DataView dv = Common.ExecAsrsSelect(sql);
                if (dv.Count < 1)
                {
                    add_dw_log(le, "", "N", "   " + seq + ".1 命令档 [wms_command] 没有货位同步信息资料!");
                    return;
                }
                foreach (DataRowView drow in dv)
                {
                    ls_messageName = drow[0].ToString();
                    li_requestlength = Convert.ToInt32(drow[1]);
                    ls_areaIdx = drow[2].ToString();
                    li_totallength = Convert.ToInt32(drow[3]);
                    li_currentlength = Convert.ToInt32(drow[4]);
                }
                JSONArray array = new JSONArray(); 
                sql = " select top " + li_requestlength + " loc_no,loc_sts,row1,bay1,lev1,boxId from asr_stk_mast ";
                sql += " where loc_no not in (select top " + li_currentlength + " loc_no from asr_stk_mast order by lev1,bay1,row1) ";
                sql += " order by lev1,bay1,row1";
                DataView dv_stk = Common.ExecAsrsSelect(sql);                
                li_resultlength = dv_stk.Count;
                if (li_resultlength <= 0)
                {
                    return;
                }
                add_dw_log(le, "", "P", "   " + seq + ".2 正在处理货位信息同步，共" + li_resultlength + "笔数据");
                foreach (DataRowView drow in dv_stk)
                {
                    ls_loc_no = drow[0].ToString();
                    ls_loc_sts = drow[1].ToString();
                    li_row1 = Convert.ToInt32(drow[2]);
                    li_bay1 = Convert.ToInt32(drow[3]);
                    li_lev1 = Convert.ToInt32(drow[4]);
                    ls_boxId = drow[5].ToString();
                    JSONObject jsonres = new JSONObject();
                    jsonres.put("level", li_lev1);
                    string location = "1" + li_bay1.ToString().PadLeft(3, '0') + li_row1;
                    jsonres.put("location", long.Parse(location));
                    int li_state = -1;
                    switch (ls_loc_sts)
                    {
                        case "O":
                            li_state = 0;
                            break;
                        case "R":
                            li_state = 1;
                            break;
                        case "S":
                            li_state = 1;
                            break;
                        case "D":
                            li_state = 10;
                            break;
                        case "X":
                            li_state = -1;
                            break;
                    }
                    jsonres.put("state", li_state);
                    jsonres.put("boxId", ls_boxId);
                    array.put(jsonres);
                }

                sql = "update wms_command set currentlength=currentlength+" + li_resultlength + ", ";
                sql += " Io_status = case when (currentlength+" + li_resultlength + ">=totallength) then 'Y' else 'N' end ";
                sql += " ,upd_mk = case when (currentlength+" + li_resultlength + ">=totallength) then 'Y' else 'N' end ";
                sql += " where messageName='InquiryLocations' and Io_status<>'Y' and currentlength<totallength ";
                bool bl = Common.ExecAsrsModify(sql);
                if (!bl)
                {
                    ls_error_memo = "   " + seq + ".3 WMS处理货位信息同步失败! ";
                    add_dw_log(le, "", "E", ls_error_memo);
                }
            }
            catch (Exception t)
            {
                ls_error_memo = "   " + seq + ".4 WMS处理货位信息同步失败! 异常:" + t.Message;
                add_dw_log(le, "", "E", ls_error_memo);
            }
        }

    }
}