大岛的登陆接口存redis加企业区分

yl

2022-11-21 b166c0f80252ab4e1af4136789cb976364b779b2

 VueWebApi/DLL/DAL/AppDeviceManageDAL.cs

@@ -384,7 +384,7 @@
            try
            {
                //获取当前扫码设备是否申请维修记录
                sql = @"select *  from TEqp_RepairRequest where eqp_code=@eqpcode and status='REPA' or status='COMP'";
                sql = @"select *  from TEqp_RepairRequest where eqp_code=@eqpcode and status<>'CONFIR'";
                dynamicParams.Add("@eqpcode", eqpcode);
                var data0 = DapperHelper.selectdata(sql, dynamicParams);
                if (data0.Rows.Count > 0)
@@ -973,16 +973,18 @@
        public static ToMessage AppDeviceAnDengCallSave(string username, string eqpcode, string wkshpcode, List<AnDnDate> json)
        {
            string sql = "";
            int AnDnID = 0; //最大id
            var dynamicParams = new DynamicParameters();
            List<object> list = new List<object>();
            ChatHub chthub = new ChatHub();
            try
            {
                list.Clear();
                //执行消息推送
                chthub.SendByGroupList(username, wkshpcode, eqpcode, json);
                for (int i = 1; i <= json.Count; i++)
                //获取主表最大ID
                AnDnID = DapperHelper.insertReturnId("TAnDon_Task_Info");
                for (int i = 0; i < json.Count; i++)
                {
                    AnDnID = AnDnID + 1;//自增1
                    string code = json[i].code.ToString();
                    string name = json[i].name.ToString();
                    sql = @"select *   from TAnDon_Task_Info where wkshp_code=@wkshpcode and eqp_code=@eqpcode and type=@typecode and status='START'";
@@ -999,10 +1001,6 @@
                    }
                    else
                    {
                        //获取主表最大ID
                        sql = @"select ISNULL(IDENT_CURRENT('TK_Wrk_Record')+@num,1) as id";
                        dynamicParams.Add("@num", i);
                        var dt = DapperHelper.selectdata(sql, dynamicParams);
                        //写入安灯呼叫表
                        sql = @"insert into TAnDon_Task_Info(wkshp_code,eqp_code,type,start_date,start_user,status) 
                        values(@wkshp_code,@eqp_code,@type,@start_date,@start_user,@status)";
@@ -1019,6 +1017,7 @@
                                status = "START"
                            }
                        });

                        for (int j = 0; j < json[i].children.Count; j++)
                        {
                            //写入安灯记录推送人员表
@@ -1029,11 +1028,12 @@
                                str = sql,
                                parm = new
                                {
                                    m_id = int.Parse(dt.Rows[0]["ID"].ToString()),
                                    m_id = AnDnID,
                                    //m_id = int.Parse(dt.Rows[0]["ID"].ToString()),
                                    wkshp_code = wkshpcode,
                                    eqp_code = eqpcode,
                                    type = code,
                                    resp_user = json[i].children[i].usercode,
                                    resp_user = json[i].children[j].usercode,
                                    status = "N"
                                }
                            });
@@ -1120,7 +1120,7 @@
            try
            {
                list.Clear();
                for (int i = 1; i <= json.Count; i++)
                for (int i = 0; i <json.Count; i++)
                {
                    string code = json[i].code.ToString();
                    string name = json[i].name.ToString();