diff --git a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/impl/AbnormalBillServiceImpl.java b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/impl/AbnormalBillServiceImpl.java index d74d7842..31a3d3d1 100644 --- a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/impl/AbnormalBillServiceImpl.java +++ b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/impl/AbnormalBillServiceImpl.java @@ -207,6 +207,8 @@ public class AbnormalBillServiceImpl extends ServiceImpl queryWrapper = new QueryWrapper<>(); + routerStep.setRouterBo(abnormalBillDispose.getRouterBo()); + routerStep.setSequence(Long.parseLong("1")); + queryWrapper.setEntity(routerStep); + routerStep=routerStepService.getOne(queryWrapper); + String[] items = abnormalBill.getItemBo().split(","); + String item=items[1]; + + if (StringUtil.notBlank(routerStep.getDescription())){ + String disRouterfirtOperation = routerStep.getDescription().substring(0, routerStep.getDescription().indexOf("_")); + if (StringUtil.notBlank(abnormalBill.getOperation()) && StringUtil.notBlank(abnormalBill.getSfc()) && StringUtil.notBlank(abnormalBill.getStepId())){ + /** + * 在产的找 + */ + String abnormalOperation = abnormalBill.getOperation().substring(0, abnormalBill.getOperation().indexOf("_")); + if (!disRouterfirtOperation.equals(abnormalOperation)){ + //生成返修物流周转任务 + LogisticsTurnover logisticsTurnover = new LogisticsTurnover(); + logisticsTurnover.setHandle("LogisticsBO:1000" + "," + UUID.randomUUID().toString()); + logisticsTurnover.setSfcDispatchBo(HandleEnum.SFC_DISPATCH.getHandle(site, abnormalBill.getSfc()+"-"+abnormalBill.getStepId())); + logisticsTurnover.setStatus(Constants.LOGISTICS_NEW); + logisticsTurnover.setCreatedDateTime(LocalDateTime.now()); + logisticsTurnover.setOther1(routerStep.getDescription()); + logisticsTurnover.setOther2(abnormalBill.getStepId()); + logisticsTurnover.setIsReceive("N"); + logisticsTurnover.setTurnoverWorkCenter(disRouterfirtOperation); + logisticsTurnover.setTurnoutItem(item); + logisticsTurnover.setTurnoutWorkcenter(abnormalOperation); + try { + logisticsTurnoverService.save(logisticsTurnover); + } catch (Exception e) { + throw new BaseException("返修件周转任务生成失败"); + } + + } + } + + } + //判断返修工单是否正确 if(!StringUtil.isBlank(abnormalBillDispose.getResolveShopOrder())){ ShopOrder shopOrder = shopOrderMapper.selectById(HandleEnum.SHOP_ORDER.getHandle(site, abnormalBillDispose.getResolveShopOrder())); @@ -1670,10 +1732,12 @@ public class AbnormalBillServiceImpl extends ServiceImpl abnormalBills) { boolean flag=this.updateBatchById(abnormalBills); + String site=CommonMethods.getSite(); if (flag){ //发送维修完成的消息给相关人员 for (AbnormalBill abnormalBill : abnormalBills){ abnormalBill.setType("S"); + abnormalBill.setSite(site); abnormalBill.setReportSendUserGroup("SBYCSB-REPAIRCOMPLETE"); this.sendMessageToDeviceRepairComplete(abnormalBill); } diff --git a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/impl/AbnormalPlanServiceImpl.java b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/impl/AbnormalPlanServiceImpl.java index 2ba64b64..9032262e 100644 --- a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/impl/AbnormalPlanServiceImpl.java +++ b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/impl/AbnormalPlanServiceImpl.java @@ -201,17 +201,19 @@ public class AbnormalPlanServiceImpl extends ServiceImpl> result =routerStepcontentService.selectDisRouterInfo(map); - String ReapirContent=""; - if(result!=null&&result.size()!=0){ - for (int j = 0; j < result.size(); j++) { - ReapirContent=ReapirContent+"【"+(String) result.get(j).get("STEP_ID")+"】"+ - (String) result.get(j).get("ROUTER_STEP_CONTENT"); + if(StringUtil.notBlank(routerBo)){ + //map.put("abnormalBo",abnormalBo); + map.put("routerBo",routerBo); + List> result =routerStepcontentService.selectDisRouterInfo(map); + String ReapirContent=""; + if(result!=null&&result.size()!=0){ + for (int j = 0; j < result.size(); j++) { + ReapirContent=ReapirContent+"【"+(String) result.get(j).get("STEP_ID")+"】"+ + (String) result.get(j).get("ROUTER_STEP_CONTENT"); + } } + findAbnormalPlan.get(i).setReapirContent(ReapirContent); } - findAbnormalPlan.get(i).setReapirContent(ReapirContent); } // for (AbnormalPlanDto planDto:findAbnormalPlan){ diff --git a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/impl/ReportServiceImpl.java b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/impl/ReportServiceImpl.java index 1986f6fb..3c342cb6 100644 --- a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/impl/ReportServiceImpl.java +++ b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/impl/ReportServiceImpl.java @@ -8,6 +8,7 @@ import com.foreverwin.mesnac.anomaly.service.ReportService; import com.foreverwin.mesnac.anomaly.utils.DateReportUtils; import com.foreverwin.mesnac.common.enums.HandleEnum; import com.foreverwin.mesnac.common.util.DateUtil; +import com.foreverwin.mesnac.common.util.StringUtil; import com.foreverwin.mesnac.meapi.mapper.DataFieldListMapper; import com.foreverwin.mesnac.meapi.mapper.ItemMapper; import com.foreverwin.mesnac.meapi.mapper.ShopOrderMapper; @@ -238,17 +239,22 @@ public class ReportServiceImpl implements ReportService { Map temporaryMap = qualityInspectionReport.get(i); String abnormalBo = (String) temporaryMap.get("ABNORMAL_NO"); String routerBo = (String) temporaryMap.get("ROUTER_BO"); - // map.put("abnormalBo", abnormalBo); - map.put("routerBo", routerBo); - List> result = routerStepcontentService.selectDisRouterInfo(map); - String ReapirContent = ""; - if (result != null && result.size() != 0) { - for (int j = 0; j < result.size(); j++) { - ReapirContent = ReapirContent + "【" + (String) result.get(j).get("STEP_ID") + "】" + - (String) result.get(j).get("ROUTER_STEP_CONTENT"); + + + if(StringUtil.notBlank(routerBo)){ + // map.put("abnormalBo", abnormalBo); + map.put("routerBo", routerBo); + List> result = routerStepcontentService.selectDisRouterInfo(map); + String ReapirContent = ""; + if (result != null && result.size() != 0) { + for (int j = 0; j < result.size(); j++) { + ReapirContent = ReapirContent + "【" + (String) result.get(j).get("STEP_ID") + "】" + + (String) result.get(j).get("ROUTER_STEP_CONTENT"); + } } + qualityInspectionReport.get(i).put("ROUTER_STEP_CONTENT", ReapirContent); } - qualityInspectionReport.get(i).put("ROUTER_STEP_CONTENT", ReapirContent); + } diff --git a/anomaly/src/main/resources/mapper/ReportMapper.xml b/anomaly/src/main/resources/mapper/ReportMapper.xml index 803464ea..4c01d176 100644 --- a/anomaly/src/main/resources/mapper/ReportMapper.xml +++ b/anomaly/src/main/resources/mapper/ReportMapper.xml @@ -441,7 +441,7 @@ diff --git a/common/src/main/java/com/foreverwin/mesnac/common/ftp/WorkmanshipCardFtpClient.java b/common/src/main/java/com/foreverwin/mesnac/common/ftp/WorkmanshipCardFtpClient.java index 93096923..cf772b66 100644 --- a/common/src/main/java/com/foreverwin/mesnac/common/ftp/WorkmanshipCardFtpClient.java +++ b/common/src/main/java/com/foreverwin/mesnac/common/ftp/WorkmanshipCardFtpClient.java @@ -348,6 +348,7 @@ public class WorkmanshipCardFtpClient { } public FTPClient login() throws IOException{ this.ftp=new FTPClient(); + this.ftp.connect(address,port); this.ftp.setFileType(FTP.BINARY_FILE_TYPE); if(FTPReply.isPositiveCompletion(this.ftp.getReplyCode())){ diff --git a/common/src/main/resources/mapper/ReportDataMapper.xml b/common/src/main/resources/mapper/ReportDataMapper.xml index 682b5111..cc449511 100644 --- a/common/src/main/resources/mapper/ReportDataMapper.xml +++ b/common/src/main/resources/mapper/ReportDataMapper.xml @@ -792,6 +792,69 @@ diff --git a/meapi/src/main/resources/mapper/LogisticsTurnoverMapper.xml b/meapi/src/main/resources/mapper/LogisticsTurnoverMapper.xml index 822dadc8..8d851a33 100644 --- a/meapi/src/main/resources/mapper/LogisticsTurnoverMapper.xml +++ b/meapi/src/main/resources/mapper/LogisticsTurnoverMapper.xml @@ -595,8 +595,7 @@ Z_LOGISTICS_TURNOVER ZLT LEFT JOIN WORK_CENTER WC ON WC.WORK_CENTER = ZLT.TURNOVER_WORK_CENTER LEFT JOIN WORK_CENTER_T WCT ON WCT.WORK_CENTER_BO = WC.HANDLE - LEFT JOIN Z_INSPECTION_TASK ZIT ON ZLT.OTHER3 = ZIT.HANDLE - LEFT JOIN Z_SFC_DISPATCH ZSD ON ZIT.SFC = ZSD.SFC AND ZIT.STEP_ID=ZSD.STEP_ID + LEFT JOIN Z_SFC_DISPATCH ZSD ON ZLT.SFC_DISPATCH_BO = ZSD.HANDLE LEFT JOIN OPERATION O1 ON O1.OPERATION = ZSD.OPERATION LEFT JOIN OPERATION_T OT1 ON OT1.OPERATION_BO = O1.HANDLE LEFT JOIN OPERATION O ON O.OPERATION = ZLT.OTHER1 @@ -744,7 +743,7 @@ AND STATUS=#{status} - AND TURNOUT_WORKCENTER=#{turnoutWorkcenter} + AND TURNOUT_WORKCENTER=#{turnoutWorkcenter} AND TURNOVER_WORK_CENTER=#{nextWorkCenter} AND IS_RECEIVE=#{isReceive} AND TURNOUT_ITEM=#{turnoutItem} diff --git a/quality/src/main/java/com/foreverwin/mesnac/quality/service/impl/InspectionTaskManageServiceImpl.java b/quality/src/main/java/com/foreverwin/mesnac/quality/service/impl/InspectionTaskManageServiceImpl.java index e1aa7490..a2084bd0 100644 --- a/quality/src/main/java/com/foreverwin/mesnac/quality/service/impl/InspectionTaskManageServiceImpl.java +++ b/quality/src/main/java/com/foreverwin/mesnac/quality/service/impl/InspectionTaskManageServiceImpl.java @@ -237,6 +237,8 @@ public class InspectionTaskManageServiceImpl implements InspectionTaskManageServ */ InspectionTaskManageRequest request=new InspectionTaskManageRequest(); request.setSfcdispatchBo(inspectionTaskManage.getSfcdispatchBo()); + request.setSfc(inspectionTaskManage.getSfc()); + request.setStepId(inspectionTaskManage.getStepId()); this.CreateLogisticsTask(request); } inspectionTaskModel.setStatus("SAVE".equals(type) ? Constants.INSPECTION_TASK_STATUS_DOING : Constants.INSPECTION_TASK_STATUS_COMPLETE); @@ -274,6 +276,7 @@ public class InspectionTaskManageServiceImpl implements InspectionTaskManageServ public void CreateLogisticsTask(InspectionTaskManageRequest request) { SfcDispatch sfcDispatchById = sfcDispatchService.getById(request.getSfcdispatchBo()); Router router = routerService.getById(sfcDispatchById.getRouterBo()); + String site=CommonMethods.getSite(); //找下道工序 (返修工序除外) if (!router.getRouterType().equals("C")) { QueryWrapper queryWrapper = new QueryWrapper<>(); @@ -281,16 +284,17 @@ public class InspectionTaskManageServiceImpl implements InspectionTaskManageServ queryWrapper.eq(SfcDispatch.SHOP_ORDER, sfcDispatchById.getShopOrder()); queryWrapper.eq(SfcDispatch.DISPATCH_SEQ, String.valueOf(Integer.parseInt(sfcDispatchById.getDispatchSeq()) + 1)); SfcDispatch nextsfcDispatch = sfcDispatchService.getOne(queryWrapper); + String dispatchNo = request.getSfc() + "-" + request.getStepId(); //判断下道工序是否为空 if (nextsfcDispatch != null && !nextsfcDispatch.getOperation().equals("HJ_6106JYGX") && !nextsfcDispatch.getOperation().equals("HJ_6106JRGX")) { - logger.error("质检工序合格" + sfcDispatchById.getOperation() + "的下道工序不为空,下道工序为" + nextsfcDispatch.getOperation()); //如果不等于空,判断下道工序的工作中心和质检完的工作中心是否一致 if (!sfcDispatchById.getWorkCenter().equals(nextsfcDispatch.getWorkCenter())) { - logger.error("下道工序和质检工序的工作中心不相同"); //如果不相等的话 插入周转任务表 LogisticsTurnover logisticsTurnover = new LogisticsTurnover(); logisticsTurnover.setHandle("LogisticsBO:1000" + "," + UUID.randomUUID().toString()); - logisticsTurnover.setSfcDispatchBo(request.getSfcdispatchBo()); + //HandleEnum.SFC_DISPATCH.getHandle(site, dispatchNo) + logisticsTurnover.setSfcDispatchBo(HandleEnum.SFC_DISPATCH.getHandle(site, dispatchNo)); + // logisticsTurnover.setSfcDispatchBo(request.getSfcdispatchBo()); logisticsTurnover.setStatus(Constants.LOGISTICS_NEW); logisticsTurnover.setCreatedDateTime(LocalDateTime.now()); logisticsTurnover.setOther1(nextsfcDispatch.getOperation()); @@ -309,15 +313,15 @@ public class InspectionTaskManageServiceImpl implements InspectionTaskManageServ } //如果下道工序不为空且下道工序是检验,继续找下道工序 else if (nextsfcDispatch != null && nextsfcDispatch.getOperation().equals("HJ_6106JYGX")) { - QueryWrapper queryWrappers = new QueryWrapper<>(); - queryWrappers.eq(SfcDispatch.SFC, sfcDispatchById.getSfc()); - queryWrappers.eq(SfcDispatch.SHOP_ORDER, sfcDispatchById.getShopOrder()); - queryWrappers.eq(SfcDispatch.DISPATCH_SEQ, String.valueOf(Integer.parseInt(nextsfcDispatch.getDispatchSeq()) + 1)); - SfcDispatch nextssfcDispatch = sfcDispatchService.getOne(queryWrappers); + QueryWrapper queryWrappers = new QueryWrapper<>(); + queryWrappers.eq(SfcDispatch.SFC, sfcDispatchById.getSfc()); + queryWrappers.eq(SfcDispatch.SHOP_ORDER, sfcDispatchById.getShopOrder()); + queryWrappers.eq(SfcDispatch.DISPATCH_SEQ, String.valueOf(Integer.parseInt(nextsfcDispatch.getDispatchSeq()) + 1)); + SfcDispatch nextssfcDispatch = sfcDispatchService.getOne(queryWrappers); if (nextssfcDispatch != null && !nextssfcDispatch.getWorkCenter().equals(sfcDispatchById.getWorkCenter())) { LogisticsTurnover logisticsTurnover = new LogisticsTurnover(); logisticsTurnover.setHandle("LogisticsBO:1000" + "," + UUID.randomUUID().toString()); - logisticsTurnover.setSfcDispatchBo(request.getSfcdispatchBo()); + logisticsTurnover.setSfcDispatchBo(HandleEnum.SFC_DISPATCH.getHandle(site, dispatchNo)); logisticsTurnover.setStatus(Constants.LOGISTICS_NEW); logisticsTurnover.setCreatedDateTime(LocalDateTime.now()); logisticsTurnover.setOther1(nextssfcDispatch.getOperation()); @@ -335,7 +339,7 @@ public class InspectionTaskManageServiceImpl implements InspectionTaskManageServ }else if (Constants.RK.equals(nextsfcDispatch.getOther2())){ LogisticsTurnover logisticsTurnover = new LogisticsTurnover(); logisticsTurnover.setHandle("LogisticsBO:1000" + "," + UUID.randomUUID().toString()); - logisticsTurnover.setSfcDispatchBo(request.getSfcdispatchBo()); + logisticsTurnover.setSfcDispatchBo(HandleEnum.SFC_DISPATCH.getHandle(site, dispatchNo)); logisticsTurnover.setStatus(Constants.LOGISTICS_NEW); logisticsTurnover.setCreatedDateTime(LocalDateTime.now()); logisticsTurnover.setOther1(nextsfcDispatch.getOperation()); @@ -358,7 +362,7 @@ public class InspectionTaskManageServiceImpl implements InspectionTaskManageServ //下工序为空,本工序为检入工序生成转序任务 LogisticsTurnover logisticsTurnover = new LogisticsTurnover(); logisticsTurnover.setHandle("LogisticsBO:1000" + "," + UUID.randomUUID().toString()); - logisticsTurnover.setSfcDispatchBo(request.getSfcdispatchBo()); + logisticsTurnover.setSfcDispatchBo(HandleEnum.SFC_DISPATCH.getHandle(site, dispatchNo)); logisticsTurnover.setStatus(Constants.LOGISTICS_NEW); logisticsTurnover.setCreatedDateTime(LocalDateTime.now()); logisticsTurnover.setOther2(sfcDispatchById.getStepId()); @@ -373,7 +377,7 @@ public class InspectionTaskManageServiceImpl implements InspectionTaskManageServ //如果为空值 则判断入库标识 LogisticsTurnover logisticsTurnover = new LogisticsTurnover(); logisticsTurnover.setHandle("LogisticsBO:1000" + "," + UUID.randomUUID().toString()); - logisticsTurnover.setSfcDispatchBo(request.getSfcdispatchBo()); + logisticsTurnover.setSfcDispatchBo(HandleEnum.SFC_DISPATCH.getHandle(site, dispatchNo)); logisticsTurnover.setStatus(Constants.LOGISTICS_NEW); logisticsTurnover.setCreatedDateTime(LocalDateTime.now()); logisticsTurnover.setOther2(sfcDispatchById.getStepId()); @@ -387,4 +391,5 @@ public class InspectionTaskManageServiceImpl implements InspectionTaskManageServ } } + }