智云MES后端API代码
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
yangle
2024-05-15 02033f7cf126f09573052b539671bd0821ed8f18 
 WebAPI/Controllers/Sc_ProcessMangementController.cs


@@ -482,6 +482,8 @@


        {


            try


            {


                LogService.Write("生产汇报单进入同步方法，汇报单号：" + BillNo);




                string sErr = "";


                oSystemParameter.ShowBill(ref sErr);




@@ -495,6 +497,7 @@


                DataSet ds = oCN.RunProcReturn("select * from h_v_MES_StationOutBillList_LastProc where HInterID=" + InterID, "h_v_MES_StationOutBillList_LastProc");


                if (ds.Tables[0].Rows.Count <= 0)


                {


                    LogService.Write("生产汇报单回滚，汇报单号：" + BillNo + "   原因：生成生产汇报单过程中没有查询到出站单");


                    objJsonResult.code = "0";


                    objJsonResult.count = 0;


                    objJsonResult.Message = "生成生产汇报单过程中没有查询到出站单";


@@ -505,9 +508,10 @@




                //保存


                oCN.BeginTran();


                DataSet DsTable = oCN.RunProcReturn($"select * from Sc_ICMOReportBillMain where HBillNo='{HBillNo}'", "Sc_ICMOReportBillMain");


                DataSet DsTable = oCN.RunProcReturn($"select * from Sc_ICMOReportBillMain with(nolock) where HBillNo='{HBillNo}'", "Sc_ICMOReportBillMain");


                if (DsTable.Tables[0].Rows.Count > 0)


                {


                    LogService.Write("生产汇报单回滚，汇报单号：" + BillNo + "   原因：已入库,请不要重复入库");


                    objJsonResult.code = "0";


                    objJsonResult.count = 0;


                    objJsonResult.Message = "已入库,请不要重复入库";


@@ -550,6 +554,7 @@


                var isSuccess = JObject.Parse(loginRet)["LoginResultType"].Value<int>();


                if (isSuccess == 0)


                {


                    LogService.Write("生产汇报单回滚，汇报单号：" + BillNo + "   原因：操作失败,金蝶账号登录异常");


                    objJsonResult.code = "0";


                    objJsonResult.count = 0;


                    objJsonResult.Message = "操作失败,金蝶账号登录异常。" + loginRet;


@@ -643,6 +648,7 @@


                if (JObject.Parse(result)["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper() != "TRUE")


                {


                    LogService.Write("工序汇报单入库错误jsonRoot:" + jsonRoot);


                    LogService.Write("生产汇报单保存失败，汇报单号：" + BillNo + "   原因：" + result);


                    oCN.RollBack();


                    objJsonResult.code = "0";


                    objJsonResult.count = 0;


@@ -663,10 +669,11 @@


                result2 = InvokeHelper.Audit("PRD_MORPT", JsonConvert.SerializeObject(json));//提交


                if (JObject.Parse(result1)["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper() != "TRUE")


                {


                    LogService.Write("生产汇报单提交失败，汇报单号：" + BillNo + "   原因：" + result1);


                    oCN.RollBack();


                    objJsonResult.code = "0";


                    objJsonResult.count = 0;


                    objJsonResult.Message = $"生产汇报单单号：{fBillNo}，提交失败" + result;


                    objJsonResult.Message = $"生产汇报单单号：{fBillNo}，提交失败" + result1;


                    objJsonResult.data = null;


                    return objJsonResult;


                }


@@ -674,6 +681,9 @@


                oCN.RunProc("update Sc_StationOutBillMain set HRelationQty=1 where  HBillNo='" + BillNo + "'");




                oCN.Commit();




                LogService.Write("生产汇报单保存成功，汇报单号：" + BillNo );




                objJsonResult.code = "0";


                objJsonResult.count = 1;


                objJsonResult.Message = "保存成功！";


@@ -682,6 +692,7 @@


            }


            catch (Exception e)


            {


                LogService.Write("生产汇报单同步发生异常，汇报单号：" + BillNo + "    " + e.ToString());


                oCN.RollBack();


                objJsonResult.code = "0";


                objJsonResult.count = 0;


@@ -768,6 +779,7 @@


        {


            try


            {


                LogService.Write("生产入库单进入同步方法:" + "  入库单号：" + BillNo);


                //获取生产汇报单最大InterID和单据号


                Int64 HInterID = DBUtility.ClsPub.CreateBillID("1202", ref DBUtility.ClsPub.sExeReturnInfo);


                string HBillNo = DBUtility.ClsPub.CreateBillCode("1202", ref DBUtility.ClsPub.sExeReturnInfo, true);


@@ -778,10 +790,11 @@


                //DataRow dr = ds.Tables[0].Rows[0];




                //判断入库的合格数量是否为0


                var DTable = oCN.RunProcReturn("select * from  Sc_StationOutBillMain where HBillNo='" + BillNo + "' ", "Sc_StationOutBillMain").Tables[0];


                var DTable = oCN.RunProcReturn("select * from Sc_StationOutBillMain with(nolock) where HBillNo='" + BillNo + "' ", "Sc_StationOutBillMain").Tables[0];




                if (double.Parse(DTable.Rows[0]["HQty"].ToString()) == 0)


                {


                    LogService.Write("同步金蝶生产生产入库单回滚--出站单号：" + BillNo + "  回滚原因：合格数量为0,不需要入库！");


                    objJsonResult.code = "1";


                    objJsonResult.count = 2;


                    objJsonResult.Message = "合格数量为0,不需要入库！";


@@ -827,6 +840,7 @@


                var isSuccess = JObject.Parse(loginRet)["LoginResultType"].Value<int>();


                if (isSuccess == 0)


                {


                    LogService.Write("同步金蝶生产入库单回滚--出站单号：" + BillNo + "  回滚原因：操作失败,金蝶账号登录异常");


                    objJsonResult.code = "0";


                    objJsonResult.count = 0;


                    objJsonResult.Message = "操作失败,金蝶账号登录异常。" + loginRet;


@@ -839,6 +853,7 @@




                if (ds1 == null || ds1.Tables[0].Rows.Count == 0)


                {


                    LogService.Write("同步金蝶生产入库单回滚--出站单号：" + BillNo + "  回滚原因：未找到对应的本地或金蝶云生产汇报单记录;1.未查询到对应的生产汇报单；2.请确保当前工序是末道工序3.汇报单对应的入库数量已满 请在金蝶云查看入库记录！");


                    objJsonResult.code = "0";


                    objJsonResult.count = 0;


                    objJsonResult.Message = "未找到对应的本地或金蝶云生产汇报单记录;1.未查询到对应的生产汇报单；2.请确保当前工序是末道工序3.汇报单对应的入库数量已满 请在金蝶云查看入库记录！";


@@ -849,6 +864,7 @@


                DataRow dr1 = ds1.Tables[0].Rows[0];


                if (double.Parse(dr1[0].ToString()) <= 0)


                {


                    LogService.Write("同步金蝶生产入库单回滚--出站单号：" + BillNo + "  回滚原因：未找到对应的生产汇报单记录;1.未查询到对应的生产汇报单；2.请确保当前工序是末道工序3.汇报单对应的入库数量已满 请在金蝶云查看入库记录！");


                    objJsonResult.code = "0";


                    objJsonResult.count = 0;


                    objJsonResult.Message = "未找到对应的生产汇报单记录;1.未查询到对应的生产汇报单；2.请确保当前工序是末道工序3.汇报单对应的入库数量已满 请在金蝶云查看入库记录！";


@@ -868,6 +884,7 @@




                        if (ds.Tables[0].Rows.Count > 0)


                        {


                            LogService.Write("同步金蝶生产入库单回滚--出站单号：" + BillNo + "  回滚原因：当前出站单号已入库,请不要重新入库!");


                            objJsonResult.code = "0";


                            objJsonResult.count = 0;


                            objJsonResult.Message = "当前出站单号已入库,请不要重新入库!";


@@ -876,7 +893,7 @@


                        }




                        //判断金蝶云生产汇报单 数量 是否 大于 末道出站数量


                        ds = oCN.RunProcReturn($@"select sum(FFinishQty)-sum(FSTOCKINQUASELQTY)-(select HQty from Sc_StationOutBillMain where HBillNo='{BillNo}') 


                        ds = oCN.RunProcReturn($@"select sum(FFinishQty)-sum(FSTOCKINQUASELQTY)-(select HQty from Sc_StationOutBillMain with(nolock) where HBillNo='{BillNo}') 


                        from  AIS20220308151944..T_PRD_MORPT rpt3 


                        left join AIS20220308151944..T_PRD_MORPTENTRY  rpt2 on rpt3.FID = rpt2.FID


                        left join AIS20220308151944..T_PRD_MORPTENTRY_A  rpt1 on rpt2.FID = rpt1.FID


@@ -884,6 +901,7 @@




                        if (double.Parse(ds.Tables[0].Rows[0][0].ToString()) < 0)


                        {


                            LogService.Write("同步金蝶生产入库单回滚--出站单号：" + BillNo + "  回滚原因：金蝶云汇报数量小于本地出站数量!");


                            objJsonResult.code = "0";


                            objJsonResult.count = 0;


                            objJsonResult.Message = "金蝶云汇报数量小于本地出站数量!";


@@ -896,6 +914,7 @@


                        {


                            if (item["HWYID"].ToString() == null || item["HWYID"].ToString() == "" || item["HWYID"].ToString() == "undefined")


                            {


                                LogService.Write("同步金蝶生产入库单回滚--出站单号：" + BillNo + "  回滚原因：唯一ID为空，请重新手动入库或联系管理员！");


                                objJsonResult.code = "0";


                                objJsonResult.count = 0;


                                objJsonResult.Message = "唯一ID为空，请重新手动入库或联系管理员！";


@@ -1045,8 +1064,8 @@


                string result = InvokeHelper.Save("PRD_INSTOCK", JsonConvert.SerializeObject(jsonRoot));//保存


                //判断保存是否成功


                if (JObject.Parse(result)["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper() != "TRUE")


                {


                    LogService.Write("生产入库错误jsonRoot:" + jsonRoot);


                {                  


                    LogService.Write("生产入库保存错误jsonRoot:" + jsonRoot + "  入库单号：" + BillNo);


                    oCN.RollBack();


                    objJsonResult.code = "0";


                    objJsonResult.count = 0;


@@ -1067,6 +1086,7 @@


                //result2 = InvokeHelper.Audit("PRD_INSTOCK", JsonConvert.SerializeObject(json));//提交


                if (JObject.Parse(result1)["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper() != "TRUE")


                {


                    LogService.Write("生产入库提交错误jsonRoot:" + jsonRoot + "  入库单号：" + BillNo);


                    oCN.RollBack();


                    objJsonResult.code = "0";


                    objJsonResult.count = 0;


@@ -1076,7 +1096,7 @@


                }




                oCN.RunProc("update Sc_StationOutBillMain set HRelationQty=1 where  HBillNo='" + BillNo + "'");




                LogService.Write("生产入库同步成功:" + "  入库单号：" + BillNo);


                oCN.Commit();


                objJsonResult.code = "0";


                objJsonResult.count = 1;


@@ -1086,6 +1106,7 @@


            }


            catch (Exception e)


            {


                LogService.Write("生产入库同步发生异常:" + "  入库单号：" + BillNo + "    " + e.ToString());


                oCN.RollBack();


                objJsonResult.code = "0";


                objJsonResult.count = 0;