From 1776f84639c7b6d747de68e6a34c36e1169cdec0 Mon Sep 17 00:00:00 2001 From: lsh <lsh@163.com> Date: 星期三, 15 一月 2025 16:05:14 +0800 Subject: [PATCH] * --- src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java | 21 +++++ src/main/java/com/zy/asrs/utils/PostMesDataUtils.java | 163 ++++++++++++++++++++++++++++++++++++++++ 2 files changed, 183 insertions(+), 1 deletions(-) diff --git a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java index 40d6c8c..5947e0a 100644 --- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java @@ -11,6 +11,8 @@ import com.zy.asrs.service.BasDevpPositionService; import com.zy.asrs.service.WrkMastService; import com.zy.asrs.task.core.ReturnT; +import com.zy.asrs.task.escalationParam.RgvTaskReportingParam; +import com.zy.asrs.utils.PostMesDataUtils; import com.zy.asrs.utils.SortTheExecutionOfTheCarUtil; import com.zy.asrs.utils.TimeCalculatorUtils; import com.zy.common.CodeRes; @@ -370,7 +372,24 @@ break; } wrkMast.setWrkSts(3L); - wrkMast.setAppeTime(new Date()); + Date now = new Date(); + wrkMast.setAppeTime(now); + try{ + try{ + RgvTaskReportingParam rgvTaskReportingParam = new RgvTaskReportingParam(wrkMast); + ReturnT<String> result = new PostMesDataUtils().postMesDataWcs("", "", rgvTaskReportingParam); + if (result.getCode()==200){ + wrkMast.setWrkSts(4L); + wrkMast.setAppeTime(now); + wrkMastService.updateById(wrkMast); + continue; + }else { + log.error("宸ヤ綔鍙�"+wrkMast.getWrkNo()+"浠诲姟瀹屾垚淇℃伅涓婁紶澶勭悊澶辫触"); + } + } catch (Exception e){ + log.error("宸ヤ綔鍙�"+wrkMast.getWrkNo()+"浠诲姟瀹屾垚淇℃伅涓婁紶澶勭悊澶辫触锛屽紓甯镐俊鎭細"+e); + } + } catch (Exception e){} wrkMastService.updateById(wrkMast); } } diff --git a/src/main/java/com/zy/asrs/utils/PostMesDataUtils.java b/src/main/java/com/zy/asrs/utils/PostMesDataUtils.java new file mode 100644 index 0000000..c95f069 --- /dev/null +++ b/src/main/java/com/zy/asrs/utils/PostMesDataUtils.java @@ -0,0 +1,163 @@ +package com.zy.asrs.utils; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import com.core.common.SpringUtils; +import com.core.exception.CoolException; +import com.zy.asrs.service.ApiLogService; +import com.zy.asrs.task.AbstractHandler; +import com.zy.asrs.task.core.ReturnT; +import com.zy.common.utils.HttpHandler; +import lombok.extern.slf4j.Slf4j; + +import java.util.Map; + +@Slf4j +public class PostMesDataUtils extends AbstractHandler<String> { + + public ReturnT<String> postMesDataWcs(String URL,String erpPath,Object combParam){ + if(combParam != null){ + String response = ""; + boolean success = false; + try { + response = new HttpHandler.Builder() + .setUri(URL) + .setPath(erpPath) + .setJson(JSON.toJSONString(combParam)) + .build() + .doPost(); + JSONObject jsonObject = JSON.parseObject(response); + if (jsonObject.getInteger("code")==200) { + success = true; + } else { + log.error("浠诲姟瀹屾垚淇℃伅涓婁紶璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}"+URL+erpPath, JSON.toJSONString(combParam), response); + throw new CoolException("涓婃姤wcs绯荤粺澶辫触"); + } + } catch (Exception e) { + log.error("fail:涓婃姤wcs绯荤粺澶辫触==>", e); +// TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); + return FAIL.setMsg(e.getMessage()); + } finally { + try { + // 淇濆瓨鎺ュ彛鏃ュ織 + ApiLogService apiLogService = SpringUtils.getBean(ApiLogService.class); + + apiLogService.save( + "涓婃姤wcs绯荤粺", + URL + erpPath, + null, + URL, + JSON.toJSONString(combParam), + response, + success + ); + } catch (Exception e) { + log.error("浠诲姟瀹屾垚淇℃伅涓婁紶淇濆瓨鎺ュ彛鏃ュ織寮傚父锛屽紓甯镐俊鎭細", e); + } + } + } + return SUCCESS; + } + + public ReturnT<String> postMesData(String name, String URL, String mesPath, Object combParam){ +// if (true){ +// System.out.println("name:"+name+",URL:"+URL+",mesPath:"+mesPath+",combParam:"+combParam); +// return SUCCESS; +// } + if(combParam != null){ + String response = ""; + boolean success = false; + try { +// Map<String, Object> map = new HashMap<>() +// map.put("appkey","ea1f0459efc02a79f046f982767939ae"); + response = new HttpHandler.Builder() +// .setHeaders(map) + .setUri(URL) + .setPath(mesPath) + .setJson(JSON.toJSONString(combParam)) + .build() + .doPost(); + System.out.println("response:"+response); + JSONObject jsonObject = JSON.parseObject(response); + + if (jsonObject.getInteger("code").equals(200)) { + success = true; + } else { + log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", URL+"/"+mesPath, JSON.toJSONString(combParam), response); + throw new CoolException("涓婃姤"+name); + } + } catch (Exception e) { + log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", URL+"/"+mesPath, JSON.toJSONString(combParam), response); +// TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); + return FAIL.setMsg(e.getMessage()); + } finally { + try { + // 淇濆瓨鎺ュ彛鏃ュ織 + ApiLogService apiLogService = SpringUtils.getBean(ApiLogService.class); + apiLogService.save( + "涓婃姤"+name, + URL +"/"+ mesPath, + null, + "127.0.0.1", + JSON.toJSONString(combParam), + response, + success + ); + } catch (Exception e) { + log.error("", e); } + } + } + return SUCCESS; + } + + public ReturnT<String> postMesData(String name, String URL, String mesPath, Object combParam,Map<String, Object> map){ +// if (true){ +// System.out.println("name:"+name+",URL:"+URL+",mesPath:"+mesPath+",combParam:"+combParam); +// return SUCCESS; +// } + if(combParam != null){ + String response = ""; + boolean success = false; + try { +// Map<String, Object> map = new HashMap<>(); +// map.put("appkey","ea1f0459efc02a79f046f982767939ae"); + response = new HttpHandler.Builder() + .setHeaders(map) + .setUri(URL) + .setPath(mesPath) + .setJson(JSON.toJSONString(combParam)) + .build() + .doPost(); + System.out.println("response:"+response); + JSONObject jsonObject = JSON.parseObject(response); + + if (jsonObject.getInteger("code").equals(200)) { + success = true; + } else { + log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", URL+"/"+mesPath, JSON.toJSONString(combParam), response); + throw new CoolException("涓婃姤"+name); + } + } catch (Exception e) { + log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", URL+"/"+mesPath, JSON.toJSONString(combParam), response); +// TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); + return FAIL.setMsg(e.getMessage()); + } finally { + try { + // 淇濆瓨鎺ュ彛鏃ュ織 + ApiLogService apiLogService = SpringUtils.getBean(ApiLogService.class); + apiLogService.save( + "涓婃姤"+name, + URL +"/"+ mesPath, + null, + "127.0.0.1", + JSON.toJSONString(combParam), + response, + success + ); + } catch (Exception e) { + log.error("", e); } + } + } + return SUCCESS; + } +} -- Gitblit v1.9.1