|
|
@@ -993,6 +993,38 @@ public class OrderInfoServiceImpl extends ServiceImpl<OrderInfoMapper, OrderInfo
|
|
|
if ("3".equals(ENV)) {
|
|
|
if (CollectionUtils.isNotEmpty(orderInfo.getOrderInfoList())) {
|
|
|
for (OrderInfo orderInfo1 : orderInfo.getOrderInfoList()) {
|
|
|
+ //车辆监测系统上报
|
|
|
+ HyDriverCarInfo hyDriverCarInfo1 = driverCarInfoService.selectOne(new EntityWrapper<HyDriverCarInfo>()
|
|
|
+ .eq("car_number",orderInfo1.getCarNumber()).eq("delete_flag","0"));
|
|
|
+ //查询车辆类型key值
|
|
|
+ HyCommonSysParameter hyCommonSysParameter = commonSysParameterService.selectOne(new EntityWrapper<HyCommonSysParameter>()
|
|
|
+ .eq("const_id", "CAR1").eq("const_value", hyDriverCarInfo1.getVehicleType()));
|
|
|
+ hyDriverCarInfo1.setVehicleTypeKey(hyCommonSysParameter.getConstKey());
|
|
|
+ //交管监测系统上报
|
|
|
+ new Thread(new Runnable() {
|
|
|
+ @Override
|
|
|
+ public void run() {
|
|
|
+ try {
|
|
|
+ String result = MonitoringSystemReporting.testVehicleRoot(hyDriverCarInfo1);
|
|
|
+ JSONObject jsonObject = JSONObject.fromObject(result);
|
|
|
+ //发送成功
|
|
|
+ if ("1001".equals(jsonObject.getString("code"))) {
|
|
|
+ hyDriverCarInfo1.setReportedStatusKey(StatusEnum.REPORTED_SUCESS.getFlag());
|
|
|
+ hyDriverCarInfo1.setReportedStatus(StatusEnum.REPORTED_SUCESS.getName());
|
|
|
+ }
|
|
|
+ //发送失败
|
|
|
+ else if ("3003".equals(jsonObject.getString("code"))) {
|
|
|
+ hyDriverCarInfo1.setReportedStatusKey(StatusEnum.REPORTED_FAIL.getFlag());
|
|
|
+ hyDriverCarInfo1.setReportedStatus(StatusEnum.REPORTED_FAIL.getName());
|
|
|
+ hyDriverCarInfo1.setReportedFailureReason(jsonObject.getString("data"));
|
|
|
+ }
|
|
|
+ driverCarInfoService.updateById(hyDriverCarInfo1);
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }).start();
|
|
|
+
|
|
|
//1.查询任务,获取业务类型代码
|
|
|
PublishTaskInfo publishTaskInfo = publishTaskInfoService.selectById(orderInfo1.getTaskId());
|
|
|
if (publishTaskInfo != null) {
|
