YiWuProject.git

			@@ -1,6 +1,9 @@
			package com.mes.damage.service.impl;

			import cn.hutool.json.JSONArray;
			import cn.hutool.json.JSONObject;
			import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
			import com.fasterxml.jackson.databind.ObjectMapper;
			import com.github.yulichang.base.MPJBaseServiceImpl;
			import com.github.yulichang.query.MPJQueryWrapper;
			import com.mes.common.config.Const;
			@@ -10,15 +13,23 @@
			import com.mes.damage.service.DamageService;
			import com.mes.glassinfo.entity.GlassInfo;
			import com.mes.glassinfo.mapper.GlassInfoMapper;
			import com.mes.pp.entity.ReportingWork;
			import com.mes.pp.entity.ReportingWorkDetail;
			import com.mes.work_assignment.entity.WorkAssignment;
			import com.mes.work_assignment.mapper.WorkAssignmentMapper;
			import org.springframework.beans.BeanUtils;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.stereotype.Service;

			import javax.annotation.Resource;
			import java.io.BufferedReader;
			import java.io.InputStreamReader;
			import java.io.OutputStream;
			import java.net.HttpURLConnection;
			import java.net.URL;
			import java.sql.Timestamp;
			import java.time.LocalDateTime;
			import java.time.format.DateTimeFormatter;
			import java.util.ArrayList;
			import java.util.List;
			import java.util.Map;
			import java.util.stream.Collectors;
			@@ -38,22 +49,20 @@
			GlassInfoMapper glassInfoMapper;
			@Resource
			WorkAssignmentMapper workAssignmentMapper;
			@Autowired
			private DamageMapper damageMapper;

			/**
			* 查询报工信息
			*/
			@Override
			public List<Damage> selectDamage(String startTime, String endTime, int type, String workingProcedure) {
			public List<Damage> selectDamage(String startTime, String endTime, int type, int status, String workingProcedure) {
			LambdaQueryWrapper<Damage> damageSelectWrapper = new LambdaQueryWrapper<>();
			damageSelectWrapper.between(Damage::getDamageTime, startTime, endTime);
			if (type != 0) {
			damageSelectWrapper.eq(Damage::getType, type);
			}
			// if (status != 0) {
			// damageSelectWrapper.eq(Damage::getStatus, status);
			// }
			if (status != 0) {
			damageSelectWrapper.eq(Damage::getStatus, status);
			}
			if (!"0".equals(workingProcedure)) {
			damageSelectWrapper.eq(Damage::getWorkingProcedure, workingProcedure);
			}
			@@ -72,22 +81,74 @@
			public void submitDamage(List<Damage> damageList) {
			Map<String, List<Damage>> firstMap = damageList.stream().collect(Collectors.groupingBy(e -> e.getProcessId() + ":"
			+ e.getWorkingProcedure() + ":" + e.getDeviceName() + ":" + e.getTeamsGroupsName()));

			for (Map.Entry<String, List<Damage>> entry : firstMap.entrySet()) {
			ReportingWork reportingWork = new ReportingWork();
			List<ReportingWorkDetail> reportingWorkDetails = new ArrayList<>();
			String key = entry.getKey();
			List<Damage> damages = entry.getValue();
			for (Damage damage:damages
			) {
			reportingWork.setOrderId(damage.getProcessId().substring(0, 10));
			reportingWork.setProductionId(damage.getProcessId().substring(0,11));
			reportingWork.setProcessId(damage.getProcessId()+"/"+damage.getTechnologyNumber());
			reportingWork.setDeviceName(damage.getDeviceName());
			reportingWork.setThisProcess(damage.getWorkingProcedure());
			reportingWork.setThisCompletedQuantity(1);
			reportingWork.setThisWornQuantity(0);
			reportingWork.setClasses("早班");
			reportingWork.setReportingWorkTime(LocalDateTime.now());
			reportingWork.setTeamsGroupsName(damage.getTeamsGroupsName());
			reportingWork.setCreator("auto");
			System.out.println("Key: " + key);
			}

			System.out.println("Key: " + key);

			Map<String, List<Damage>> secondMap = damageList.stream().collect(Collectors.groupingBy(e -> e.getProcessId() + ":"
			+ e.getWorkingProcedure() + ":" + e.getDeviceName() + ":" + e.getTeamsGroupsName()));

			for (Map.Entry<String, List<Damage>> entrys : secondMap.entrySet()) {
			List<Damage> damagesdetail = entrys.getValue();


			for (Damage damage:damagesdetail
			) {
			ReportingWorkDetail reportingWorkDetail = new ReportingWorkDetail();
			reportingWorkDetail.setTechnologyNumber(damage.getTechnologyNumber());
			reportingWorkDetail.setOrderNumber(damage.getOrderNumber());
			reportingWorkDetail.setCompletedQuantity(1);
			reportingWorkDetail.setBreakageQuantity(0);
			reportingWorkDetails.add(reportingWorkDetail);

			}
			}
			sendToERP(reportingWork,reportingWorkDetails);
			}
			}

			@Override
			public void submitReport(Damage damage) {
			ReportingWork reportingWork = new ReportingWork();
			reportingWork.setOrderId(damage.getProcessId().substring(0, 10));
			reportingWork.setProductionId(damage.getProcessId().substring(0,11));
			reportingWork.setProcessId(damage.getProcessId()+"/"+damage.getTechnologyNumber());
			reportingWork.setDeviceName(damage.getDeviceName());
			reportingWork.setThisProcess(damage.getWorkingProcedure());
			// reportingWork.setNextProcess("磨边");
			reportingWork.setThisCompletedQuantity(1);
			reportingWork.setThisWornQuantity(0);
			reportingWork.setClasses("早班");
			reportingWork.setReportingWorkTime(LocalDateTime.now());
			reportingWork.setTeamsGroupsName(damage.getTeamsGroupsName());
			reportingWork.setCreator("auto");

			List<ReportingWorkDetail> reportingWorkDetails = new ArrayList<>();
			ReportingWorkDetail reportingWorkDetail = new ReportingWorkDetail();
			reportingWorkDetail.setTechnologyNumber(damage.getTechnologyNumber());
			reportingWorkDetail.setOrderNumber(damage.getOrderNumber());
			reportingWorkDetail.setCompletedQuantity(1);
			reportingWorkDetail.setBreakageQuantity(0);
			reportingWorkDetails.add(reportingWorkDetail);
			sendToERP(reportingWork,reportingWorkDetails);
			}

			/**
			@@ -113,6 +174,13 @@
			damage.setOrderNumber(glassInfo.getGlassType());
			damage.setTechnologyNumber(glassInfo.getLayer());
			damage.setDamageTime(Timestamp.valueOf(LocalDateTime.now()));
			if (damage.getType() == null) {
			damage.setType(1);
			}
			if (damage.getType() == 1) {
			damage.setStatus(2);
			submitReport(damage);
			}
			baseMapper.insert(damage);
			}

			@@ -157,7 +225,7 @@
			if (damage.getEngineerId() != null) {
			listDamage.eq("t.engineer_id", damage.getEngineerId());
			}
			return damageMapper.selectJoinList(DamagePrint.class, listDamage);
			return baseMapper.selectJoinList(DamagePrint.class, listDamage);
			}

			/**
			@@ -165,7 +233,7 @@
			*/
			@Override
			public List<DamagePrint> selectDamagePrintDetails(Damage damage) {
			List<DamagePrint> listDamage = damageMapper.selectJoinList(DamagePrint.class, new MPJQueryWrapper<Damage>()
			List<DamagePrint> listDamage = baseMapper.selectJoinList(DamagePrint.class, new MPJQueryWrapper<Damage>()
			.select("b.flow_card_id,b.layer,t.engineer_id,b.tempering_layout_id,b.tempering_feed_sequence,t.glass_id,b.width,b.height,b.thickness")
			.leftJoin("glass_info as b on t.glass_id=b.glass_id")
			.eq("t.working_procedure", damage.getWorkingProcedure())
			@@ -183,4 +251,65 @@
			.in(Damage::getType, Const.GLASS_STATE_DAMAGE, Const.GLASS_STATE_TAKE)
			);
			}

			@Override
			public void sendToERP(ReportingWork reportingWork, List<ReportingWorkDetail> reportingWorkDetails){
			try {
			// 目标系统的API URL
			String url = "http://192.168.3.119:8086/reportingWork/mesSaveReportingWorkWorn";
			URL obj = new URL(url);
			HttpURLConnection con = (HttpURLConnection) obj.openConnection();

			// 设置请求方法和请求头
			con.setRequestMethod("POST");
			con.setRequestProperty("Content-Type", "application/json; utf-8");
			con.setRequestProperty("Accept", "application/json");
			con.setDoOutput(true);

			// 创建 JSON 对象
			JSONObject result = new JSONObject();

			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");
			os.write(input, 0, input.length);
			}

			// 获取响应码
			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();
			String inputLine;
			while ((inputLine = in.readLine()) != null) {
			response.append(inputLine);
			}
			System.out.println("Response Body: " + response.toString());
			}

			} catch (Exception e) {
			e.printStackTrace();
			}
			}
			}