~zhoushihao/YiWuProject.git

			@@ -18,8 +18,10 @@
			import com.mes.pp.entity.ReportingWorkDetail;
			import com.mes.work_assignment.entity.WorkAssignment;
			import com.mes.work_assignment.mapper.WorkAssignmentMapper;
			import lombok.extern.slf4j.Slf4j;
			import org.springframework.beans.BeanUtils;
			import org.springframework.stereotype.Service;
			import org.springframework.web.client.RestTemplate;

			import javax.annotation.Resource;
			import java.io.BufferedReader;
			@@ -43,6 +45,7 @@
			* @author wu
			* @since 2024-06-13
			*/
			@Slf4j
			@Service
			public class DamageServiceImpl extends MPJBaseServiceImpl<DamageMapper, Damage> implements DamageService {

			@@ -51,10 +54,9 @@
			@Resource
			WorkAssignmentMapper workAssignmentMapper;

			@Override
			public List<Damage> selectDamage(String startTime, String endTime, int type, String workingProcedure) {
			return null;
			}
			@Resource
			RestTemplate restTemplate;


			/**
			* 查询报工信息
			@@ -86,7 +88,7 @@
			@Override
			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()));
			+ e.getWorkingProcedure() + ":" + e.getDeviceName() + ":" + e.getTeamsGroupsName() + ":" + e.getOrderNumber() + ":" + e.getTechnologyNumber()));
			for (Map.Entry<String, List<Damage>> entry : firstMap.entrySet()) {
			ReportingWork reportingWork = new ReportingWork();
			List<ReportingWorkDetail> reportingWorkDetails = new ArrayList<>();
			@@ -109,7 +111,7 @@
			reportingWorkDetail.setOrderNumber(damages.get(0).getOrderNumber());
			reportingWorkDetail.setCompletedQuantity(0);
			reportingWorkDetail.setBreakageQuantity(0);
			reportingWorkDetails.add(reportingWorkDetail);


			Map<String, List<Damage>> secondMap = damages.stream().collect(Collectors.groupingBy(e -> e.getProcessId() + ":"
			+ e.getWorkingProcedure() + ":" + e.getDeviceName() + ":" + e.getTeamsGroupsName()));
			@@ -123,6 +125,7 @@
			reportingWork.setThisCompletedQuantity(damagesdetails.size() + reportingWork.getThisCompletedQuantity());
			} else {
			reportingWork.setThisWornQuantity(damagesdetails.size() + reportingWork.getThisWornQuantity());
			reportingWorkDetail.setBreakageQuantity(damagesdetails.size());
			DamageDetails damageDetails = new DamageDetails();
			damageDetails.setBreakageQuantity(damagesdetails.size());
			damageDetails.setBreakageType(damagesdetails.get(0).getBreakageType());
			@@ -134,6 +137,7 @@
			damageDetailses.add(damageDetails);
			}
			}
			reportingWorkDetails.add(reportingWorkDetail);
			reportingWorkDetail.setDamageDetailsList(damageDetailses);
			sendToERP(reportingWork, reportingWorkDetails);
			}
			@@ -165,18 +169,38 @@
			return sendToERP(reportingWork, reportingWorkDetails);
			}

			@Override
			public void autoSubmitReport(String glassId, int deviceId, String workingProcedure, String remark,int type) {
			Damage damage = new Damage();
			damage.setGlassId(glassId);
			damage.setWorkingProcedure(workingProcedure);
			damage.setLine(deviceId);
			damage.setType(type);
			damage.setRemark(remark);
			damage.setStatus(0);
			this.insertDamage(damage);
			}
			/**
			* 添加报工信息
			*/
			@Override
			public void insertDamage(Damage damage) {
			List<Damage> damage1 = baseMapper.selectList(
			new LambdaQueryWrapper<Damage>()
			.ne(Damage::getType, Const.GLASS_STATE_DAMAGE)
			.ne(Damage::getType, Const.GLASS_STATE_TAKE)
			.eq(Damage::getLine, damage.getLine())
			.eq(Damage::getWorkingProcedure, damage.getWorkingProcedure())
			);
			List<Damage> damage1 = null;
			if (Const.GLASS_STATE_DAMAGE.equals(damage.getType()) \|\| Const.GLASS_STATE_TAKE.equals(damage.getType())) {
			damage1 = baseMapper.selectList(
			new LambdaQueryWrapper<Damage>()
			.in(Damage::getType, Const.GLASS_STATE_DAMAGE, Const.GLASS_STATE_TAKE)
			.eq(Damage::getGlassId, damage.getGlassId())
			);
			} else {
			damage1 = baseMapper.selectList(
			new LambdaQueryWrapper<Damage>()
			.notIn(Damage::getType, Const.GLASS_STATE_DAMAGE, Const.GLASS_STATE_TAKE)
			.eq(Damage::getLine, damage.getLine())
			.eq(Damage::getWorkingProcedure, damage.getWorkingProcedure())
			.eq(Damage::getGlassId, damage.getGlassId())
			);
			}
			if (damage1 == null \|\| damage1.size() == 0) {
			LambdaQueryWrapper<GlassInfo> glassInfoSelectWrapper = new LambdaQueryWrapper<>();
			glassInfoSelectWrapper.eq(GlassInfo::getGlassId, damage.getGlassId());
			@@ -201,7 +225,9 @@
			}
			if (damage.getType() == 1) {
			if (submitReport(damage)) {
			damage.setStatus(2);
			damage.setStatus(3);
			} else {
			damage.setStatus(1);
			}
			}
			baseMapper.insert(damage);
			@@ -272,15 +298,16 @@
			baseMapper.delete(
			new LambdaQueryWrapper<Damage>()
			.eq(Damage::getGlassId, glassId)
			.in(Damage::getType, Const.GLASS_STATE_DAMAGE, Const.GLASS_STATE_TAKE)
			.in(Damage::getType, Const.GLASS_STATE_DAMAGE_TAKE)
			);
			}

			@Override
			public Boolean sendToERP(ReportingWork reportingWork, List<ReportingWorkDetail> reportingWorkDetails) {
			log.info("报工数据reportingWork：{}，reportingWorkDetails：{}", reportingWork, reportingWorkDetails);
			try {
			// 目标系统的API URL
			String url = "http://192.168.1.199:8086/reportingWork/mesSaveReportingWorkWorn";
			String url = "http://192.168.2.100:8086/reportingWork/mesSaveReportingWorkWorn";
			URL obj = new URL(url);
			HttpURLConnection con = (HttpURLConnection) obj.openConnection();

			@@ -335,11 +362,83 @@
			// 提取 code 和 message
			int code = jsonResponse.getInt("code");
			String message = jsonResponse.getStr("data");

			log.info("报工失败：{},{}", code, message);
			if (code == 200 && message.equals("true")) {
			return true;
			} else {
			return false;
			}
			}

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

			public Boolean sendToERPRest(ReportingWork reportingWork, List<ReportingWorkDetail> reportingWorkDetails) {
			log.info("报工数据reportingWork：{}，reportingWorkDetails：{}", reportingWork, reportingWorkDetails);
			try {
			// 目标系统的API URL
			String url = "http://192.168.2.100: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);
			}
			// 解析响应内容
			JSONObject jsonResponse = new JSONObject(response.toString());

			// 提取 code 和 message
			int code = jsonResponse.getInt("code");
			String message = jsonResponse.getStr("data");
			log.info("报工失败：{},{}", code, message);
			if (code == 200 && message.equals("true")) {
			return true;
			} else {
			return false;
			}
			}