HEGII.gt.mes.api/wwwroot/api/plc/plc_led_data.ashx

<%@ WebHandler Language="C#" Class="plc_led_data" %>

using System;
using System.Web;
using System.Collections.Generic;
using Curtain.Net.Sockets;
using DK.XuWei.WebMes;
using Curtain.DataAccess;
using Curtain.Log;
using System.Data;
using Newtonsoft.Json.Linq;
using System.Collections;

/// <summary>
/// 对接LED看板，用于成检显示产品属性信息
/// xuwei
/// 2023-08-08
/// </summary>
public class plc_led_data : IHttpHandler
{
    public struct LedData
    {
        public int goodscode;
        public int goodsspecification;
        public int goodstype;
        public string barcode;
    }

    //输入参数 【条码】
    public string barCode = "";

    string procedure_no;
    string procedure_in;
    string road_no;
    string rack;
    string position;
    //返回失败提示
    public string message = "";

    public void ProcessRequest(HttpContext context)
    {
        try
        {
            context.Response.ContentType = "text/plain";
            //输入输出参数初始化 计件
            barCode = context.Request["barcode"] is object ? context.Request["barcode"] : "";
            procedure_no = context.Request["procedure_no"] is object ? context.Request["procedure_no"] : "1_1_1";

            procedure_in = "1";
            road_no = "0";
            rack = "";
            position = "";

            DataTable infoDt = new DataTable();
            //写入PLC
            //SiemensS7.Open("172.19.26.244", 102);
            //正式
            SiemensS7.Open("172.19.26.152", 102);

            if (context.Request["barcode"] is object)
            {
                using (IDataAccess conn = DataAccess.Create())
                {
                    infoDt = conn.ExecuteDatatable(@"
                            SELECT g.seatcovercode
                                    ,CASE
                                        WHEN instr(g.goodsspecification, '305') = 1 THEN 1
                                        WHEN instr(g.goodsspecification, '400') = 1 THEN 2
                                        WHEN instr(g.goodsspecification, '地排') = 1 THEN 3
                                        WHEN instr(g.goodsspecification, '横排') = 1 THEN 4
                                        WHEN instr(g.goodsspecification, '295') = 1 THEN 5
                                        WHEN instr(g.goodsspecification, '220') = 1 THEN 6
                                    END AS goodsspecification
                                    ,CASE
                                        WHEN instr(gt.goodstypename, '连体') = 1 THEN 1
                                        WHEN instr(gt.goodstypename, '智能') = 1 THEN 2
                                    END AS goodstypename
                                    ,gdd.barcode
                                    ,g.goodscode
                                FROM tp_pm_groutingdailydetail gdd
                                LEFT JOIN tp_mst_goods g
                                ON gdd.goodsid = g.goodsid
                                LEFT JOIN tp_mst_goodstype gt  
                                ON gt.goodstypeid = g.goodstypeid

                                WHERE gdd.barcode = @barcode@
                            ",
                        new CDAParameter("barcode", context.Request["barcode"])
                    );
                    if (infoDt != null && infoDt.Rows.Count > 0 && infoDt.Rows[0] != null)
                    {

                        SiemensS7.Write<short>("400.2", Convert.ToInt16(infoDt.Rows[0]["seatcovercode"]));
                        SiemensS7.Write<short>("400.4", Convert.ToInt16(infoDt.Rows[0]["goodsspecification"]));
                        SiemensS7.Write<short>("400.6", Convert.ToInt16(infoDt.Rows[0]["goodstypename"]));
                        SiemensS7.Write<string>("400.10", infoDt.Rows[0]["barcode"].ToString());
                        SiemensS7.Write<string>("400.24", infoDt.Rows[0]["goodscode"].ToString());

                        //写标识位-扫描结果
                        //写标识位-扫描结果
                        SiemensS7.Write<short>("400.0", Convert.ToInt16(1));
                    }

                    context.Response.Write(SiemensS7.Read<short>("400.0"));
                    context.Response.Write(SiemensS7.Read<short>("400.2"));
                    context.Response.Write(SiemensS7.Read<short>("400.4"));
                    context.Response.Write(SiemensS7.Read<short>("400.6"));
                    context.Response.Write(SiemensS7.Read<string>("400.24", 11));


                    if (Convert.ToInt16(infoDt.Rows[0]["seatcovercode"]) != Convert.ToInt16(SiemensS7.Read<short>("400.2"))
                            || Convert.ToInt16(infoDt.Rows[0]["goodsspecification"]) != Convert.ToInt16(SiemensS7.Read<short>("400.4"))
                            || Convert.ToInt16(infoDt.Rows[0]["goodstypename"]) != Convert.ToInt16(SiemensS7.Read<short>("400.6"))
                            || Convert.ToInt16(1) != Convert.ToInt16(SiemensS7.Read<short>("400.0")))
                    {
                        SiemensS7.Write<short>("400.2", Convert.ToInt16(infoDt.Rows[0]["seatcovercode"]));
                        SiemensS7.Write<short>("400.4", Convert.ToInt16(infoDt.Rows[0]["goodsspecification"]));
                        SiemensS7.Write<short>("400.6", Convert.ToInt16(infoDt.Rows[0]["goodstypename"]));
                        SiemensS7.Write<string>("400.10", infoDt.Rows[0]["barcode"].ToString());
                        SiemensS7.Write<string>("400.24", infoDt.Rows[0]["goodscode"].ToString());

                        //写标识位-扫描结果
                        SiemensS7.Write<short>("400.0", Convert.ToInt16(1));
                    }
                    Logger.Info("写入数据完成！barcode：" + context.Request["barcode"].ToString() + "五位数据位：" + SiemensS7.Read<short>("400.0") + "," + SiemensS7.Read<short>("400.2")
                        + "," + SiemensS7.Read<short>("400.4") + "," + SiemensS7.Read<short>("400.6") + "," + SiemensS7.Read<short>("400.10") + "," + SiemensS7.Read<string>("400.24", 11) + ";数据：" + new JsonResult(infoDt).ToJson());
                }
                //调用标准计件方法===============================
                WCF wcf = new WCF();
                wcf.Para.Add(new JProperty("barcode", barCode.ToString()));
                wcf.Para.Add(new JProperty("procedure_no", procedure_no));
                wcf.Para.Add(new JProperty("road_no", road_no));
                wcf.Para.Add(new JProperty("rack", rack));
                wcf.Para.Add(new JProperty("position", position));
                wcf.Para.Add(new JProperty("procedure_in", procedure_in));
                string jsonStr = wcf.Get("/DKService/ExHGS3QR/AddWorkInfoHGS3_QR");

                //这个接口很小的机率会带出html标签===============================================
                if (jsonStr.IndexOf("<html>") > 0) jsonStr = jsonStr.Substring(0, jsonStr.IndexOf("<html>"));
                if (jsonStr.IndexOf("<!DOCTYPEhtml>") > 0) jsonStr = jsonStr.Substring(0, jsonStr.IndexOf("<!DOCTYPEhtml>"));
                //xuwei fix 2022-05-28 有时会带出 DOCTYPEhtml标签
                jsonStr = jsonStr.Replace("<!DOCTYPEhtml>", "");

                jsonStr = jsonStr.Replace("\\u000d\\u000a", "")
                        .Replace("\\n", "").Replace("\\", "").Replace(" ", "")
                        .Replace("产品编码:", " 产品编码 ")
                        .Replace("当前工序:", " 当前工序 ")
                        .Replace("可到工序:", " 可到工序 ")
                        .Replace("{\"d\":\"", "")
                        .Replace("\"}\"}", "\"}")
                        .Replace("<!DOCTYPEhtml>", "")
                        ;

                Curtain.Log.Logger.Debug(context.Request.UserHostAddress + "\r\n" + context.Request.Url + "\r\n" + jsonStr);

                string apiResult = "";
                //处理输出结果 OK开头成功 NOK开头失败
                JObject json = JObject.Parse(jsonStr);
                bool apiStatus = false;
                apiStatus = Convert.ToBoolean(json["success"]);
                apiResult = jsonStr;
                //HttpContext.Current.Response.Write(apiResult);

                //记录接口调用日志
                Hashtable ht = new Hashtable();
                ht.Add("barcode", barCode.ToString());
                ht.Add("procedure_no", procedure_no);
                ht.Add("road_no", road_no);
                ht.Add("rack", rack);
                ht.Add("position", position);
                ht.Add("procedure_in", procedure_in);

                int apiId = Convert.ToInt32(procedure_no.Replace("_", "") + road_no + Math.Abs(Convert.ToInt32(procedure_in)));
                barCode = barCode.Replace("2c%", ",");
                int apiBarcodeCount = barCode.Split(',').Length;
                string apiUrl = "http://" + HttpContext.Current.Request.Url.Host + ":" + HttpContext.Current.Request.Url.Port.ToString() + "/api/DKService/ExHGS3QR/AddWorkInfoHGS3_QR/?" + JsonClient.ParaToString(ht);
                ApiLog.WriteApiLog("PLC_扫码", apiUrl, apiStatus, apiResult, apiId, apiBarcodeCount);
                //===============================================
                int i = 0;
                //包装打印是否成功
                if (Convert.ToBoolean(json["success"]) == true)
                {
                    SiemensS7.Write<short>("420.0", Convert.ToInt16(1));
                }
                else
                {
                    SiemensS7.Write<short>("420.0", Convert.ToInt16(2));
                }
                context.Response.Write(SiemensS7.Read<short>("420.0"));
                i = Convert.ToInt16(SiemensS7.Read<short>("420.0"));
                if (i == 2)
                {
                    //PLC补推
                    SiemensS7.Write<short>("420.0", Convert.ToInt16(2));
                }
                else if(i==1){
                    //PLC补推
                    SiemensS7.Write<short>("420.0", Convert.ToInt16(1));
                }
                Logger.Info("写入数据完成！barcode：" + context.Request["barcode"].ToString() + "一位数据位：" + SiemensS7.Read<short>("420.0"));
            }
            else
            {
                //写标识位-扫描结果
                SiemensS7.Write<short>("400.0", Convert.ToInt16(2));
                context.Response.Write(SiemensS7.Read<short>("400.0"));
                Logger.Info("无条码！");
            }

            context.Response.Write(new JsonResult(infoDt).ToJson());
            SiemensS7.Close();
        }
        catch (Exception ex )
        {
            Logger.Info("异常！："+ex);
            throw ex ;
        }
    }

    public bool IsReusable
    {
        get
        {
            return false;
        }
    }

}