| | |
| | | } |
| | | List<Damage> damageList = baseMapper.selectList(damageSelectWrapper); |
| | | |
| | | for (Damage damage : damageList) { |
| | | damage.setStatus(2); |
| | | } |
| | | return baseMapper.selectList(damageSelectWrapper); |
| | | // for (Damage damage : damageList) { |
| | | // damage.setStatus(2); |
| | | // } |
| | | return damageList; |
| | | } |
| | | |
| | | /** |
| | |
| | | reportingWork.setProductionId(damages.get(0).getProcessId().substring(0, 11)); |
| | | reportingWork.setProcessId(damages.get(0).getProcessId() + "/" + damages.get(0).getTechnologyNumber()); |
| | | // reportingWork.setDeviceName(damages.get(0).getDeviceName()); |
| | | if (StringUtils.isBlank(damages.get(0).getDeviceName())){ |
| | | if (StringUtils.isBlank(damages.get(0).getDeviceName())) { |
| | | reportingWork.setDeviceName("auto"); |
| | | }else{ |
| | | } else { |
| | | reportingWork.setDeviceName(damages.get(0).getDeviceName()); |
| | | } |
| | | reportingWork.setThisProcess(damages.get(0).getWorkingProcedure()); |
| | |
| | | damageDetails.setResponsibleEquipment(damagesdetails.get(0).getResponsibleEquipment()); |
| | | damageDetails.setResponsibleTeam(damagesdetails.get(0).getResponsibleTeam()); |
| | | damageDetails.setResponsiblePersonnel(null); |
| | | if (damagesdetails.get(0).getStatus() == 7) { |
| | | damageDetails.setQualityInspector("auto"); |
| | | damageDetails.setPatchStatus(1); |
| | | damageDetails.setQualityInsStatus(2); |
| | | } else { |
| | | damageDetails.setQualityInspector(""); |
| | | damageDetails.setPatchStatus(0); |
| | | damageDetails.setQualityInsStatus(0); |
| | | } |
| | | damageDetailses.add(damageDetails); |
| | | } |
| | | } |
| | | reportingWorkDetails.add(reportingWorkDetail); |
| | | reportingWorkDetail.setDamageDetailsList(damageDetailses); |
| | | sendToERP(reportingWork, reportingWorkDetails); |
| | | reportingWorkDetail.setDamageDetails(damageDetailses); |
| | | sendToERP(reportingWork, reportingWorkDetails, Boolean.FALSE); |
| | | } |
| | | } |
| | | |
| | |
| | | reportingWork.setOrderId(damage.getProcessId().substring(0, 10)); |
| | | reportingWork.setProductionId(damage.getProcessId().substring(0, 11)); |
| | | reportingWork.setProcessId(damage.getProcessId() + "/" + damage.getTechnologyNumber()); |
| | | if (StringUtils.isBlank(damage.getDeviceName())){ |
| | | if (StringUtils.isBlank(damage.getDeviceName())) { |
| | | reportingWork.setDeviceName("auto"); |
| | | }else{ |
| | | } else { |
| | | reportingWork.setDeviceName(damage.getDeviceName()); |
| | | } |
| | | reportingWork.setThisProcess(damage.getWorkingProcedure()); |
| | |
| | | reportingWorkDetail.setCompletedQuantity(1); |
| | | reportingWorkDetail.setBreakageQuantity(0); |
| | | reportingWorkDetails.add(reportingWorkDetail); |
| | | return sendToERP(reportingWork, reportingWorkDetails); |
| | | return sendToERP(reportingWork, reportingWorkDetails, Boolean.TRUE); |
| | | } |
| | | |
| | | @Override |
| | |
| | | damage.setLine(deviceId); |
| | | damage.setType(type); |
| | | damage.setRemark(remark); |
| | | damage.setStatus(0); |
| | | this.insertDamage(damage); |
| | | } |
| | | |
| | |
| | | damage1 = baseMapper.selectList( |
| | | new LambdaQueryWrapper<Damage>() |
| | | .in(Damage::getType, Const.GLASS_STATE_DAMAGE, Const.GLASS_STATE_TAKE) |
| | | .notIn(Damage::getStatus, 7, 8) |
| | | .lt(Damage::getStatus, 7) |
| | | .eq(Damage::getGlassId, damage.getGlassId()) |
| | | ); |
| | | } else { |
| | |
| | | if (damage.getType() == null) { |
| | | damage.setType(1); |
| | | } |
| | | if (damage.getType() == 1) { |
| | | if (submitReport(damage)) { |
| | | damage.setStatus(3); |
| | | } else { |
| | | damage.setStatus(1); |
| | | } |
| | | if (damage.getType() == 1 && submitReport(damage)) { |
| | | damage.setStatus(3); |
| | | } else { |
| | | damage.setStatus(1); |
| | | } |
| | | baseMapper.insert(damage); |
| | | } |
| | |
| | | new LambdaQueryWrapper<Damage>() |
| | | .eq(Damage::getGlassId, glassId) |
| | | .in(Damage::getType, Const.GLASS_STATE_DAMAGE_TAKE) |
| | | .lt(Damage::getStatus, 7) |
| | | ); |
| | | } |
| | | |
| | | @Override |
| | | public Boolean sendToERP(ReportingWork reportingWork, List<ReportingWorkDetail> reportingWorkDetails) { |
| | | public Boolean sendToERP(ReportingWork reportingWork, List<ReportingWorkDetail> reportingWorkDetails, Boolean type) { |
| | | log.info("报工数据reportingWork:{},reportingWorkDetails:{}", reportingWork, reportingWorkDetails); |
| | | try { |
| | | // 目标系统的API URL |
| | | // String url = ERP_URL + "/reportingWork/mesReportingWork"; |
| | | String url = ERP_URL + "/reportingWork/mesSaveReportingWorkWorn"; |
| | | |
| | | |
| | | String url1 = ERP_URL + "/reportingWork/mesReportingWork"; |
| | | String url2 = ERP_URL + "/reportingWork/mesSaveReportingWorkWorn"; |
| | | String url; |
| | | if (type) { |
| | | url = url1; |
| | | } else { |
| | | url = url2; |
| | | } |
| | | URL obj = new URL(url); |
| | | HttpURLConnection con = (HttpURLConnection) obj.openConnection(); |
| | | |
| | |
| | | ObjectMapper objectMapper = new ObjectMapper(); |
| | | |
| | | // 将 ReportingWork 转换为 JSONObject |
| | | |
| | | // 将 ReportingWorkDetail 列表转换为 JSONArray |
| | | |
| | | if (type) { |
| | | JSONObject detailsJsonObject = new JSONObject(objectMapper.writeValueAsString(reportingWorkDetails.get(0))); |
| | | result.put("detail", detailsJsonObject); |
| | | reportingWork.setProcessId(reportingWork.getProcessId().substring(0, 14)); |
| | | } else { |
| | | JSONArray detailsJsonArray = new JSONArray(objectMapper.writeValueAsString(reportingWorkDetails)); |
| | | result.put("detail", detailsJsonArray); |
| | | } |
| | | JSONObject reportingWorkJson = new JSONObject(objectMapper.writeValueAsString(reportingWork)); |
| | | reportingWorkJson.put("reportingWorkTime", reportingWork.getReportingWorkTime().format(DateTimeFormatter.ISO_LOCAL_DATE_TIME)); |
| | | // 将 ReportingWorkDetail 列表转换为 JSONArray |
| | | JSONArray detailsJsonArray = new JSONArray(objectMapper.writeValueAsString(reportingWorkDetails)); |
| | | |
| | | // 将 JSON 对象和数组添加到结果对象中 |
| | | result.put("title", reportingWorkJson); |
| | | result.put("detail", detailsJsonArray); |
| | | |
| | | result.put("type", 0); |
| | | if (reportingWorkDetails.get(0).getDamageDetails() != null) { |
| | | if (reportingWorkDetails.get(0).getDamageDetails().get(0).getPatchStatus() == 1) { |
| | | result.put("isPatch", 1); |
| | | } else { |
| | | result.put("isPatch", 0); |
| | | } |
| | | } |
| | | result.put("userId", "admin"); |
| | | result.put("userName", "admin"); |
| | | result.put("qualityInsStatus", 0); |
| | | |
| | | // 将 result 对象转换为字符串 |
| | | String jsonInputString = result.toString(); |
| | | System.out.println("jsonInputString : " + result); |
| | |
| | | // 提取 code 和 message |
| | | int code = jsonResponse.getInt("code"); |
| | | String message = jsonResponse.getStr("data"); |
| | | log.info("报工失败:{},{}", code, message); |
| | | log.info("报工情况:{},{}", code, message); |
| | | if (code == 200 && message.equals("true")) { |
| | | return true; |
| | | } else { |