From c4ebb18dbe5440cca49be542982f356d2dfbb044 Mon Sep 17 00:00:00 2001
From: yl <ykxkd@outlook.com>
Date: 星期一, 14 十一月 2022 11:33:10 +0800
Subject: [PATCH] 设备保养项,设备保养标准导入接口开发

---
 VueWebApi/DLL/DAL/AppDeviceManageDAL.cs |   47 +++++++++++++++++++++++++++--------------------
 1 files changed, 27 insertions(+), 20 deletions(-)

diff --git a/VueWebApi/DLL/DAL/AppDeviceManageDAL.cs b/VueWebApi/DLL/DAL/AppDeviceManageDAL.cs
index 12d211a..3c15a46 100644
--- a/VueWebApi/DLL/DAL/AppDeviceManageDAL.cs
+++ b/VueWebApi/DLL/DAL/AppDeviceManageDAL.cs
@@ -383,8 +383,8 @@
             var dynamicParams = new DynamicParameters();
             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)
@@ -607,7 +607,7 @@
                         string imgPath1 = "", imgPath2 = "", AbsolutePath = "";
                         HttpPostedFile file = files[i];
                         string imgName = DateTime.Now.ToString("yyyyMMddhhmmss") + i.ToString();
-                        string keyname = files.AllKeys[i].ToString();
+                        string keyname = files.AllKeys[i].ToString().Substring(0, files.AllKeys[i].ToString().IndexOf(";"));
                         if (keyname == "files1")
                         {
                             imgPath1 = "/DeviceImage/image1/" + imgName + file.FileName;     //閫氳繃姝ゅ璞¤幏鍙栨枃浠跺悕
@@ -618,7 +618,6 @@
                             imgPath2 = "/DeviceImage/image2/" + imgName + file.FileName;     //閫氳繃姝ゅ璞¤幏鍙栨枃浠跺悕
                             AbsolutePath = System.Web.HttpContext.Current.Server.MapPath(imgPath2);
                         }
-
                         file.SaveAs(AbsolutePath); //灏嗕笂浼犵殑涓滆タ淇濆瓨
                                                    //寰幆鍐欑淮淇褰曞搴斿浘鐗囪〃
                         sql = @"insert into  TEqp_RepairImage(source_wo,wo_type,img1url,img2url) 
@@ -655,12 +654,12 @@
                         repair_part = replaceparts,
                         failure_descript = faultdescr,
                         is_shutdown = is_stoprepair,
-                        source_wo= docu_code
+                        source_wo = docu_code
                     }
                 });
                 //鏇存柊缁翠慨鐢宠鍗曠姸鎬�
                 sql = @"update TEqp_RepairRequest set status=@status  where docu_code=@docu_code and wksp_code=@wkshpcode  and eqp_code=@eqpcode";
-                list.Add(new { str = sql, parm = new { docu_code = docu_code, wkshpcode = wkshpcode, eqpcode= eqpcode, status= "COMP" } });
+                list.Add(new { str = sql, parm = new { docu_code = docu_code, wkshpcode = wkshpcode, eqpcode = eqpcode, status = "COMP" } });
 
                 //鍥炲啓瀛楀吀琛�,鏇存柊褰撳墠娴佹按鍙�
                 sql = @"update T_CodeRules set value=@cunm2  where rightcode=@RightCode";
@@ -735,7 +734,7 @@
         #endregion
 
         #region[缁翠慨楠岃瘉璇︽儏淇℃伅]
-        public static ToMessage RepairVerificationScanDeviceDataSub(string repair_code,string eqpcode, string wkshpcode)
+        public static ToMessage RepairVerificationScanDeviceDataSub(string repair_code, string eqpcode, string wkshpcode)
         {
             string sql = "";
             var dynamicParams = new DynamicParameters();
@@ -914,7 +913,9 @@
                         from TAnDon_Roul_ConFig A
                         inner join TAnDonType B on A.andotype_code=B.code
                         inner  join TEqpInfo E on A.wkshp_code=e.wksp_code
-                        left join(select type,wkshp_code,eqp_code  from TAnDon_Task_Info where eqp_code=@eqpcode and wkshp_code=@wkshpcode and status='START') F on A.wkshp_code=F.wkshp_code and E.code=F.eqp_code
+                        left join(
+                        select type,wkshp_code,eqp_code  from TAnDon_Task_Info where eqp_code=@eqpcode and wkshp_code=@wkshpcode and status='START'
+                        ) F on A.wkshp_code=F.wkshp_code and E.code=F.eqp_code and B.code=F.type
                         where A.wkshp_code=@wkshpcode and E.code=@eqpcode and A.enable='N'";
                 dynamicParams.Add("@wkshpcode", wkshpcode);
                 dynamicParams.Add("@eqpcode", eqpcode);
@@ -929,7 +930,7 @@
                         mn.flag = data.Rows[i]["FLAG"].ToString();
                         mn.children = new List<AnDnDateSub>();
                         //鏍规嵁鍛煎彨绫诲瀷id鏌ユ壘缁戝畾浜哄憳
-                        sql = @"select U.usercode,U.username   
+                        sql = @"select U.usercode,U.username,U.rid   
                                 from TAnDon_Roul_ConFigUser A
                                 inner join TUser U on A.usercode=U.usercode
                                 where A.ando_cogfigid=@id";
@@ -940,6 +941,8 @@
                             for (int j = 0; j < data0.Rows.Count; j++)
                             {
                                 AnDnDateSub sn = new AnDnDateSub();
+                                sn.rid= data0.Rows[j]["RID"].ToString();//rid
+                                sn.alias = data0.Rows[j]["RID"].ToString() + data0.Rows[j]["USERCODE"].ToString();  //鍒悕
                                 sn.usercode = data0.Rows[j]["USERCODE"].ToString();
                                 sn.username = data0.Rows[j]["USERNAME"].ToString();
                                 mn.children.Add(sn);
@@ -973,16 +976,19 @@
         public static ToMessage AppDeviceAnDengCallSave(string username, string eqpcode, string wkshpcode, List<AnDnDate> json)
         {
             string sql = "";
+            int AnDnID = 0; //鏈�澶d
             var dynamicParams = new DynamicParameters();
             List<object> list = new List<object>();
+            List<string> list1 = new List<string>();
             ChatHub chthub = new ChatHub();
             try
             {
                 list.Clear();
-                //鎵ц娑堟伅鎺ㄩ��
-                chthub.SendByGroupList(username, wkshpcode, eqpcode, json);
-                for (int i = 1; i <= json.Count; i++)
+                //鑾峰彇涓昏〃鏈�澶D
+                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 +1005,6 @@
                     }
                     else
                     {
-                        //鑾峰彇涓昏〃鏈�澶D
-                        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 +1021,7 @@
                                 status = "START"
                             }
                         });
+                    
                         for (int j = 0; j < json[i].children.Count; j++)
                         {
                             //鍐欏叆瀹夌伅璁板綍鎺ㄩ�佷汉鍛樿〃
@@ -1029,17 +1032,21 @@
                                 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,
+                                    alias= json[i].children[j].alias,
                                     status = "N"
                                 }
                             });
                         }
                     }
                 }
+                //鏋佸厜鎺ㄩ��
+                mes = JPushManage.ExecutePushByUserId(username, wkshpcode, eqpcode, json);
                 bool aa = DapperHelper.DoTransaction(list);
                 if (aa)
                 {
@@ -1078,7 +1085,7 @@
             try
             {
                 //鑾峰彇瀵瑰簲璁惧鍙婃墍灞炶溅闂寸殑瀹夌伅鍛煎彨璁板綍
-                sql = @"select A.eqp_code,B.name as eqp_name,T.org_name,A.type as typecode,D.name as typename   
+                sql = @"select A.eqp_code,B.name as eqp_name,T.org_code as wksp_code,T.org_name as wksp_name,A.type as typecode,D.name as typename   
                         from TAnDon_Task_Info A
                         left join  TEqpInfo B on A.eqp_code=B.code
                         left join  TOrganization T on B.wksp_code=T.org_code
@@ -1120,7 +1127,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();

--
Gitblit v1.9.3