| | |
| | | public class RyTask |
| | | { |
| | | private static final Logger log = LoggerFactory.getLogger(RyTask.class); |
| | | |
| | | |
| | | |
| | | // 添加状态映射字典 |
| | | private static final Map<String, String> ORDER_STATUS_MAP = new HashMap<String, String>() {{ |
| | |
| | | |
| | | @Autowired |
| | | private ITbCallbackLogService tbCallbackLogService; |
| | | |
| | | @Autowired |
| | | private ITbVehicleOrderService tbVehicleOrderService; |
| | | |
| | | public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i) |
| | | { |
| | |
| | | |
| | | |
| | | //获取车牌号 |
| | | String carLicense = ""; |
| | | String carLicense = "-"; |
| | | StringBuilder driverNames = new StringBuilder(); |
| | | StringBuilder driverMobiles = new StringBuilder(); |
| | | try{ |
| | |
| | | } |
| | | } |
| | | } |
| | | |
| | | //如果车牌号不为空 |
| | | if(carLicense!=null && carLicense.length()>0){ |
| | | log.info("更新订单-车牌号关联表,【" + tbOrders.getOrderID() + "】车牌号:" + carLicense); |
| | | |
| | | //查询是否存在关联记录 |
| | | TbVehicleOrder tbVehicleOrder = tbVehicleOrderService.selectTbVehicleOrderById(tbOrders.getOrderID()); |
| | | if(tbVehicleOrder==null){ |
| | | //不存在关联记录 |
| | | //创建关联记录 |
| | | tbVehicleOrder = new TbVehicleOrder(); |
| | | tbVehicleOrder.setOrderId(tbOrders.getOrderID()); |
| | | tbVehicleOrder.setServiceOrdId(tbOrders.getServiceOrdID()); |
| | | tbVehicleOrder.setVehicle(carLicense); |
| | | tbVehicleOrder.setStatus("0"); |
| | | tbVehicleOrderService.insertTbVehicleOrder(tbVehicleOrder); |
| | | } |
| | | else{ |
| | | //存在关联记录 |
| | | //更新关联记录 |
| | | if(orderStatus.getMsg().contains("已返回")) |
| | | { |
| | | tbVehicleOrder.setStatus("1"); |
| | | tbVehicleOrderService.updateTbVehicleOrder(tbVehicleOrder); |
| | | } |
| | | else if(orderStatus.getMsg().contains("取消")) |
| | | { |
| | | tbVehicleOrder.setStatus("2"); |
| | | tbVehicleOrderService.updateTbVehicleOrder(tbVehicleOrder); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | } |
| | | catch (Exception e) |
| | |
| | | SysClientApp clientApp = sysClientAppService.selectSysClientAppByAppKey(tbOrders.getAppId()); |
| | | if(clientApp==null){ |
| | | log.error("回调地址不存在"); |
| | | return; |
| | | orderStatusService.updateAOrderStatusFlag(orderStatus.getId()); |
| | | continue; |
| | | } |
| | | |
| | | String callbackUrl = clientApp.getCallbackUrl(); |
| | | try { |
| | | |
| | | String carLicenseStr = "-"; |
| | | if(carLicense!=null && carLicense.length()>0){ |
| | | carLicenseStr = carLicense; |
| | | } |
| | | |
| | | |
| | | // 构建请求参数 |
| | | Map<String, String> map = new HashMap<>(); |
| | | map.put("orderID", tbOrders.getOrderID().toString()); |
| | |
| | | .findFirst() |
| | | .orElse("0")); |
| | | map.put("orderRemark", orderStatus.getMsg()); |
| | | map.put("plateNo",carLicense); |
| | | map.put("plateNo",carLicenseStr); |
| | | map.put("driverMobile",driverMobiles.toString()); |
| | | map.put("driverName", driverNames.toString()); |
| | | map.put("appId", tbOrders.getAppId()); |
| | | |
| | | log.info("【监测】[" + tbOrders.getOrderID() + "]车牌号:" + carLicenseStr); |
| | | //打印map |
| | | log.info("【监测】[" + tbOrders.getOrderID() + "]回调请求参数:" + map); |
| | | |
| | | // 第一次尝试 |
| | | String response = sendCallback(callbackUrl, map); |