From eb852430ce781189ca5f9f6abcf3da539464c79e Mon Sep 17 00:00:00 2001 From: ZengTao <2773468879@qq.com> Date: 星期五, 01 十一月 2024 14:57:24 +0800 Subject: [PATCH] 修改大理片为按工程数分前后两块进片 --- hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/test/java/com/mes/CacheVerticalGlassModuleApplicationTest.java | 79 +++++++++++++++++++++++++++++++++++---- 1 files changed, 71 insertions(+), 8 deletions(-) diff --git a/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/test/java/com/mes/CacheVerticalGlassModuleApplicationTest.java b/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/test/java/com/mes/CacheVerticalGlassModuleApplicationTest.java index fe4b12c..bd6e1b0 100644 --- a/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/test/java/com/mes/CacheVerticalGlassModuleApplicationTest.java +++ b/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/test/java/com/mes/CacheVerticalGlassModuleApplicationTest.java @@ -1,8 +1,13 @@ package com.mes; +import cn.hutool.json.JSONArray; +import cn.hutool.json.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; +import com.fasterxml.jackson.databind.ObjectMapper; import com.mes.bigstorage.entity.BigStorageCage; +import com.mes.bigstorage.entity.BigStorageCageDetails; import com.mes.bigstorage.service.BigStorageCageDetailsService; import com.mes.bigstorage.service.BigStorageCageService; import com.mes.bigstoragetask.mapper.BigStorageCageFeedTaskMapper; @@ -28,9 +33,8 @@ import java.net.HttpURLConnection; import java.net.URL; import java.time.LocalDateTime; -import java.util.ArrayList; -import java.util.Arrays; -import java.util.List; +import java.time.format.DateTimeFormatter; +import java.util.*; /** * @Author : zhoush @@ -192,10 +196,45 @@ } @Test + public void deleteByGlassId(){ + damageService.deleteByGlassId("P24081203|2|5"); + } + + @Test + public void testttt(){ + List<Integer> deviceUsedList = bigStorageCageService.queryFreeDeviceByUsed(6); + List<Integer> deviceUseds = deviceUsedList; + List<BigStorageCageDetails> engineerCount1 = bigStorageCageDetailsService.list( + new LambdaQueryWrapper<BigStorageCageDetails>() + .notIn(BigStorageCageDetails::getState, Const.GLASS_STATE_OUT,Const.GLASS_STATE_DAMAGE,Const.GLASS_STATE_TAKE) + .select(BigStorageCageDetails::getEngineerId) + .groupBy(BigStorageCageDetails::getEngineerId) + .between(BigStorageCageDetails::getDeviceId, 1, 5) + ); + List<BigStorageCageDetails> engineerCount2 = bigStorageCageDetailsService.list( + new LambdaQueryWrapper<BigStorageCageDetails>() + .notIn(BigStorageCageDetails::getState, Const.GLASS_STATE_OUT,Const.GLASS_STATE_DAMAGE,Const.GLASS_STATE_TAKE) + .select(BigStorageCageDetails::getEngineerId) + .groupBy(BigStorageCageDetails::getEngineerId) + .between(BigStorageCageDetails::getDeviceId, 6, 8) + ); + if (engineerCount1.size() > engineerCount2.size()) { + deviceUsedList.removeIf(device -> device < 6); + } else { + deviceUsedList.removeIf(device -> device > 5); + } + if (CollectionUtils.isEmpty(deviceUsedList)) { + deviceUsedList = deviceUseds; + } + log.info("zhi:{}",deviceUsedList); + } + + + @Test public void ca(){ try { // 鐩爣绯荤粺鐨凙PI URL - String url = "http://192.168.3.119:8086/reportingWork/mesSave"; + String url = "http://192.168.3.119:8086/reportingWork/mesSaveReportingWorkWorn"; URL obj = new URL(url); HttpURLConnection con = (HttpURLConnection) obj.openConnection(); @@ -205,9 +244,10 @@ con.setRequestProperty("Accept", "application/json"); con.setDoOutput(true); - // 鍒涘缓娑堟伅浣� - String jsonInputString = "灏忓粬"; - ReportingWork reportingWork=new ReportingWork(); + // 鍒涘缓 JSON 瀵硅薄 + JSONObject result = new JSONObject(); + + ReportingWork reportingWork = new ReportingWork(); reportingWork.setOrderId("NG24042301"); reportingWork.setProductionId("NG24042301A"); reportingWork.setProcessId("NG24042301A001"); @@ -221,11 +261,33 @@ reportingWork.setTeamsGroupsName("灏忓粬涓�鍙�"); reportingWork.setCreator("灏忓粬"); - ReportingWorkDetail reportingWorkDetail=new ReportingWorkDetail(); + List<ReportingWorkDetail> reportingWorkDetails = new ArrayList<>(); + ReportingWorkDetail reportingWorkDetail = new ReportingWorkDetail(); reportingWorkDetail.setTechnologyNumber(1); reportingWorkDetail.setOrderNumber(1); reportingWorkDetail.setCompletedQuantity(1); reportingWorkDetail.setBreakageQuantity(0); + reportingWorkDetails.add(reportingWorkDetail); + + ObjectMapper objectMapper = new ObjectMapper(); + + // 灏� ReportingWork 杞崲涓� JSONObject + 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); + result.put("userId", "admin"); + result.put("userName", "admin"); + result.put("qualityInsStatus", 0); + + // 灏� result 瀵硅薄杞崲涓哄瓧绗︿覆 + String jsonInputString = result.toString(); + System.out.println("jsonInputString : " + result); // 鍙戦�佽姹� try (OutputStream os = con.getOutputStream()) { byte[] input = jsonInputString.getBytes("utf-8"); @@ -235,6 +297,7 @@ // 鑾峰彇鍝嶅簲鐮� int responseCode = con.getResponseCode(); System.out.println("Response Code : " + responseCode); + // 鑾峰彇鍝嶅簲鍐呭 try (BufferedReader in = new BufferedReader(new InputStreamReader(con.getInputStream(), "utf-8"))) { StringBuilder response = new StringBuilder(); -- Gitblit v1.8.0