新增违章查询接口

xx-order/xx-order-api/src/main/java/com/xxfc/platform/order/entity/OrderViolation.java

@@ -35,6 +35,21 @@ public class OrderViolation {
     @Column(name = "picture")
     private String picture;
 
+    /**
+     * 违章日期
+     */
+    @Column(name = "violate_date")
+    private Long violateDate;
+
+    /**
+     * 违章地点
+     */
+    private String area;
+
+    /**
+     * 违章行为
+     */
+    private String act;
 
     /**
      * 创建人id

xx-order/xx-order-api/src/main/java/com/xxfc/platform/order/pojo/OrderViolateVo.java

+package com.xxfc.platform.order.pojo;
+
+import lombok.Data;
+
+import java.util.Date;
+
+/**
+ * @ClassName : OrderViolateVo
+ * @Description : 车辆违章信息
+ * @Author : jiaoruizhen
+ * @Date: 2020-11-19 17:19
+ */
+@Data
+public class OrderViolateVo {
+
+	//违章时间
+	Date date;
+
+	//违章地点
+	String area;
+
+	//违章行为
+	String act;
+
+	//违章代码(仅供参考，不一定有值)
+	String code;
+
+	//违章扣分(仅供参考，不一定有值)
+	String fen;
+
+	//违章城市(不一定有值)
+	String wzcity;
+
+	//	违章罚款(仅供参考，不一定有值)
+	String money;
+
+	//	处理状态。0-未处理未交费，1-已处理未交费，默认不返回已处理已缴费的违章
+	String handled;
+
+	//文书编号(不一定会获取到)
+	String archiveno;
+}

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/biz/OrderVehicleCrosstownBiz.java

@@ -29,8 +29,6 @@ import com.xxfc.platform.order.pojo.mq.OrderMQDTO;
 import com.xxfc.platform.order.pojo.order.CheckUserInfoDto;
 import com.xxfc.platform.order.pojo.order.OrderPageVO;
 import com.xxfc.platform.order.pojo.order.OrderVehicleCrosstownDto;
-import com.xxfc.platform.universal.constant.DictionaryKey;
-import com.xxfc.platform.universal.entity.Dictionary;
 import com.xxfc.platform.universal.feign.ThirdFeign;
 import com.xxfc.platform.vehicle.common.RestResponse;
 import com.xxfc.platform.vehicle.constant.ResCode.ResCode;
@@ -51,13 +49,12 @@ import org.springframework.transaction.annotation.Transactional;
 import tk.mybatis.mapper.entity.Example;
 
 import java.math.BigDecimal;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.TimeZone;
 import java.util.stream.Collectors;
 
-import static com.xxfc.platform.universal.constant.DictionaryKey.APP_ORDER;
-
 @Service
 @Slf4j
 public class OrderVehicleCrosstownBiz extends BaseBiz<OrderVehicaleCrosstownMapper, OrderVehicleCrosstown> implements UserRestInterface {
@@ -542,6 +539,15 @@ public class OrderVehicleCrosstownBiz extends BaseBiz<OrderVehicaleCrosstownMapp
         }
     }
 
+    public List<OrderVehicleCrosstown> selectOrderList(List<Integer> orderIdList, Integer type, Integer time) {
+        Map<String, Object> params = new HashMap<>();
+        params.put("orderIdList", orderIdList);
+        params.put("type", type);
+        params.put("time", time);
+        return mapper.selectOrderList(params);
+    }
+
+
 //    public BigDecimal getAmount() {
 //        //设置保留金
 //        Map<String, Dictionary> dictionaryMap = thirdFeign.dictionaryGetAll4Map().getData();

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/biz/OrderViolationBiz.java

@@ -32,6 +32,7 @@ import org.springframework.web.multipart.MultipartFile;
 import java.io.File;
 import java.io.IOException;
 import java.math.BigInteger;
+import java.util.List;
 import java.util.Map;
 import java.util.concurrent.TimeUnit;
 
@@ -184,4 +185,9 @@ public class OrderViolationBiz extends BaseBiz<OrderViolationMapper, OrderViolat
     public OrderViolation getOneByDetailId(Integer detailId) {
         return mapper.getOneByDetailId(detailId);
     }
+
+
+    public void batchSave(List<OrderViolation> list) {
+        mapper.batchSave(list);
+    }
 }

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/mapper/OrderVehicaleCrosstownMapper.java

@@ -11,4 +11,6 @@ public interface OrderVehicaleCrosstownMapper extends Mapper<OrderVehicleCrossto
 
     List<OrderVehicleCrosstownDto> selectByOrderId(OrderVehicleCrosstownDto orderVehicleCrosstownDto);
     OrderVehicleCrosstownDto selectByOrderNo(Map<String, Object> map);
+
+    List<OrderVehicleCrosstown> selectOrderList(Map<String, Object> map);
 }
\ No newline at end of file

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/mapper/OrderViolationMapper.java

@@ -4,6 +4,7 @@ import com.xxfc.platform.order.entity.OrderViolation;
 import org.apache.ibatis.annotations.Param;
 import tk.mybatis.mapper.common.Mapper;
 
+import java.util.List;
 import java.util.Map;
 
 /**
@@ -14,4 +15,6 @@ public interface OrderViolationMapper extends Mapper<OrderViolation> {
     Map<String,Object> getOrderAndVehicleStatus(@Param("vId") Integer detailId);
 
     OrderViolation getOneByDetailId(Integer detailId);
+
+    void batchSave(List<OrderViolation> list);
 }

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/rest/OrderViolationController.java

@@ -2,6 +2,7 @@ package com.xxfc.platform.order.rest;
 
 
 import com.github.wxiaoqi.security.admin.feign.UserFeign;
+import com.github.wxiaoqi.security.auth.client.annotation.IgnoreUserToken;
 import com.github.wxiaoqi.security.common.exception.BaseException;
 import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
 import com.github.wxiaoqi.security.common.rest.BaseController;
@@ -9,6 +10,7 @@ import com.github.wxiaoqi.security.common.util.process.ResultCode;
 import com.xxfc.platform.order.biz.OrderDepositRefundRecordBiz;
 import com.xxfc.platform.order.biz.OrderViolationBiz;
 import com.xxfc.platform.order.entity.OrderViolation;
+import com.xxfc.platform.order.service.OrderViolateService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.ResponseEntity;
@@ -36,6 +38,9 @@ public class OrderViolationController extends BaseController<OrderViolationBiz,
 	@Autowired
 	OrderDepositRefundRecordBiz orderDepositRefundRecordBiz;
 
+	@Autowired
+	OrderViolateService orderViolateService;
+
 
 
 	private Long MAX_DRIVING_LICENSE_SIZE = 1024 * 1024 * 50L;
@@ -103,4 +108,11 @@ public class OrderViolationController extends BaseController<OrderViolationBiz,
 	public ResponseEntity<byte[]> downloadViolation(@RequestParam("realFileRelPath") String realFileRelPath) throws Exception {
 		return baseBiz.downloadViolation(realFileRelPath);
 	}
+
+	@GetMapping(value = "/app/unauth/get")
+	@IgnoreUserToken
+	public void get() {
+		orderViolateService.generateData();
+	}
+
 }

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/service/OrderViolateService.java

+package com.xxfc.platform.order.service;
+
+import com.alibaba.fastjson.JSONArray;
+import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
+import com.xxfc.platform.order.biz.BaseOrderBiz;
+import com.xxfc.platform.order.biz.OrderVehicleCrosstownBiz;
+import com.xxfc.platform.order.biz.OrderViolationBiz;
+import com.xxfc.platform.order.entity.OrderRentVehicleDetail;
+import com.xxfc.platform.order.entity.OrderVehicleCrosstown;
+import com.xxfc.platform.order.entity.OrderViolation;
+import com.xxfc.platform.order.mapper.OrderRentVehicleDetailMapper;
+import com.xxfc.platform.order.pojo.OrderViolateVo;
+import com.xxfc.platform.order.pojo.order.OrderPageVO;
+import com.xxfc.platform.universal.constant.DictionaryKey;
+import com.xxfc.platform.universal.dto.VehicleViolateDto;
+import com.xxfc.platform.universal.entity.Dictionary;
+import com.xxfc.platform.universal.feign.ThirdFeign;
+import com.xxfc.platform.vehicle.entity.Vehicle;
+import com.xxfc.platform.vehicle.feign.VehicleFeign;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections.CollectionUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import tk.mybatis.mapper.entity.Example;
+
+import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+/**
+ * @ClassName : OrderViolateService
+ * @Description : 查询订单车辆违章
+ * @Author : jiaoruizhen
+ * @Date: 2020-11-19 11:23
+ */
+@Service
+@Slf4j
+public class OrderViolateService {
+
+	@Autowired
+	BaseOrderBiz baseOrderBiz;
+
+	@Autowired
+	OrderVehicleCrosstownBiz orderVehicleCrosstownBiz;
+
+	@Autowired
+	ThirdFeign thirdFeign;
+
+	@Autowired
+	OrderRentVehicleDetailMapper orderRentVehicleDetailMapper;
+
+	@Autowired
+	VehicleFeign vehicleFeign;
+
+	@Autowired
+	OrderViolationBiz orderViolationBiz;
+
+
+	//查询所有符合条件的订单，已交车，未扣押金
+	private List<OrderPageVO> getOrderList() {
+		Map<String, Object> params = new HashMap<>();
+		params.put("refundStatus", 2);
+		params.put("status", 6);
+		return baseOrderBiz.getRentVehicle(params);
+	}
+
+	//过滤时间，根据还车时间，符合几天后的订单执行查询违章操作
+	private List<OrderRentVehicleDetail> getAllVehicleCrosstown() {
+		List<OrderPageVO> orderPageVOList = getOrderList();
+		List<OrderRentVehicleDetail> orderRentVehicleDetailList = new ArrayList<>();
+		if (orderPageVOList != null && orderPageVOList.size() > 0) {
+			List<OrderVehicleCrosstown> arrayList = new ArrayList<>();
+			List<Integer> orderIdList = orderPageVOList.stream().map(OrderPageVO::getId).collect(Collectors.toList());
+			List<Integer> time = getTimeList();
+			if (time != null && time.size() > 0) {
+				time.parallelStream().forEach(time1-> {
+					List<OrderVehicleCrosstown> orderVehicleCrosstownList = orderVehicleCrosstownBiz.selectOrderList(orderIdList, 1, time1);
+					if (orderVehicleCrosstownList != null && orderVehicleCrosstownList.size() > 0) {
+						arrayList.addAll(orderVehicleCrosstownList);
+					}
+				});
+			} else {
+				List<OrderVehicleCrosstown> orderVehicleCrosstownList = orderVehicleCrosstownBiz.selectOrderList(orderIdList, 1, 0);
+				if (orderVehicleCrosstownList != null && orderVehicleCrosstownList.size() > 0) {
+					arrayList.addAll(orderVehicleCrosstownList);
+				}
+			}
+			List<Integer> idList = arrayList.stream().map(OrderVehicleCrosstown::getOrderId).collect(Collectors.toList());
+			if (CollectionUtils.isNotEmpty(idList)) {
+				Example example = new Example(OrderRentVehicleDetail.class);
+				example.createCriteria().andIn("orderId", idList);
+				orderRentVehicleDetailList.addAll(orderRentVehicleDetailMapper.selectByExample(example));
+			}
+		}
+		return orderRentVehicleDetailList;
+	}
+
+	//获取所有车辆信息
+	private List<Vehicle> getAllVehicleInfo() {
+		List<OrderRentVehicleDetail> orderRentVehicleDetailList = getAllVehicleCrosstown();
+		if (CollectionUtils.isNotEmpty(orderRentVehicleDetailList)) {
+			String idString = orderRentVehicleDetailList.stream().map(OrderRentVehicleDetail::getVehicleId).collect(Collectors.joining(","));
+			ObjectRestResponse<List<Vehicle>> restResponse = vehicleFeign.getAllVehicleById(idString);
+			return restResponse.getData();
+		}
+		return new ArrayList<>();
+	}
+
+
+	//获取查询时间列表
+	private List<Integer> getTimeList() {
+		Dictionary dictionary = thirdFeign.findDictionaryByTypeAndCode(DictionaryKey.VEHICLE, DictionaryKey.VEHICLE_VIOLATE_TIME);
+		if (dictionary != null && StringUtils.isNotBlank(dictionary.getDetail())) {
+			return JSONArray.parseArray(dictionary.getDetail(), Integer.class);
+		}
+		return new ArrayList<>();
+	}
+
+	//讲查询结果存入违章信息表中
+	public void generateData() {
+		List<Vehicle> vehicleList = getAllVehicleInfo();
+		List<OrderRentVehicleDetail> orderRentVehicleDetailList = getAllVehicleCrosstown();
+		List<OrderViolation> orderViolationList = new ArrayList<>();
+		Map<String, List<OrderRentVehicleDetail>> orderRentVehicleMap = orderRentVehicleDetailList.stream().collect(Collectors.groupingBy(OrderRentVehicleDetail::getVehicleId));
+		if (vehicleList != null && vehicleList.size() > 0) {
+			vehicleList.parallelStream().forEach(vehicle -> {
+				List<OrderRentVehicleDetail> orderRentVehicleDetail = orderRentVehicleMap.get(vehicle.getId());
+				requestViolate(vehicle, orderRentVehicleDetail, orderViolationList);
+			});
+		}
+
+		if (orderViolationList.size() > 0) {
+			orderViolationBiz.batchSave(orderViolationList);
+		}
+
+	}
+
+
+	private void requestViolate(Vehicle vehicle, List<OrderRentVehicleDetail> orderRentVehicleDetailList, List<OrderViolation> orderViolationList) {
+		ObjectRestResponse response = thirdFeign.getVehicleViolate(new VehicleViolateDto(){{
+			setNumberPlate(vehicle.getNumberPlate());
+			setEngineNo(vehicle.getEngineNum());
+			setClassNo(vehicle.getVin());
+		}});
+		if (response.isRel() && response.getData() != null) {
+			List<OrderViolateVo>  list = JSONArray.parseArray(response.getData().toString(), OrderViolateVo.class);
+			if (list != null) {
+				list.parallelStream().forEach(orderViolateVo -> {
+					if (orderRentVehicleDetailList.size() > 0) {
+						orderRentVehicleDetailList.parallelStream().forEach(orderRentVehicleDetail -> {
+							OrderViolation orderViolation = new OrderViolation();
+							orderViolation.setDetailId(orderRentVehicleDetail.getId());
+							orderViolation.setViolateDate(orderViolateVo.getDate().getTime());
+							orderViolation.setArea(orderViolateVo.getArea());
+							orderViolation.setAct(orderViolateVo.getAct());
+							orderViolation.setPrice(new BigDecimal(orderViolateVo.getMoney()));
+							orderViolationList.add(orderViolation);
+						});
+					}
+
+				});
+			}
+		}
+		log.error("违章查询失败: {}", response.getMessage());
+	}
+}

xx-order/xx-order-server/src/main/resources/mapper/OrderVehicaleCrosstownMapper.xml

@@ -69,5 +69,14 @@
         where order_no = #{no} and type = #{type}
     </select>
 
+    <select id="selectOrderList" resultType="com.xxfc.platform.order.entity.OrderVehicleCrosstown">
+        select order_id from order_vehicle_crosstown
+        where order_id in
+            <foreach collection="orderIdList" item="orderId" index="index" open="(" separator="," close=")">
+                #{orderId}
+            </foreach>
+        and type &gt; #{type}
+        and ((UNIX_TIMESTAMP(NOW()) - crt_time/1000)/(60*60*24)) > #{time}
+    </select>
 
 </mapper>
\ No newline at end of file

xx-order/xx-order-server/src/main/resources/mapper/orderViolationMapper.xml

@@ -19,4 +19,27 @@
         select * from order_violation
         where detail_id = #{detailId}
     </select>
+
+    <insert id="batchSave" parameterType="list">
+        insert into order_violation ( price, detail_id,  violate_date, area, act, is_del)
+        VALUES
+        <foreach collection="list" item="emp" index="index" separator=",">
+            (
+            #{emp.price,jdbcType=DECIMAL},
+            #{emp.detailId,jdbcType=INTEGER},
+            #{emp.violateDate,jdbcType=BIGINT},
+            #{emp.area,jdbcType=VARCHAR},
+            #{emp.act,jdbcType=VARCHAR},
+            #{emp.isDel,jdbcType=INTEGER}
+         )
+        </foreach>
+        ON DUPLICATE KEY UPDATE
+        price = values(price),
+        detail_id = values(detail_id),
+        violate_date = values(violate_date),
+        area = values(area),
+        act = values(act),
+        is_del = values(is_del)
+    </insert>
+
 </mapper>
\ No newline at end of file

xx-universal/xx-universal-api/src/main/java/com/xxfc/platform/universal/constant/DictionaryKey.java

@@ -78,6 +78,9 @@ public class DictionaryKey {
     public static final String VEHICLE_MANUFACTURER = "VEHICLE_MANUFACTURER";
 
     public static final String VEHICLE = "VEHICLE";
+
+    public static final String VEHICLE_VIOLATE_TIME = "VEHICLE_VIOLATE_TIME";
+
     /**
      * 支付价格减低
      */

xx-universal/xx-universal-server/src/main/java/com/xxfc/platform/universal/service/VehicleViolateService.java

@@ -72,7 +72,7 @@ public class VehicleViolateService {
 			JSONObject object = JSONObject.parseObject(result);
 			if (object.getInteger("error_code") == 0) {
 				JSONObject resultObj = object.getJSONObject("result");
-				return ObjectRestResponse.succ(resultObj.getJSONArray("lists"));
+				return ObjectRestResponse.succ(resultObj.getString("lists"));
 			} else {
 				return ObjectRestResponse.createFailedResult(500, object.getString("reason"));
 			}

xx-vehicle/xx-vehicle-api/src/main/java/com/xxfc/platform/vehicle/feign/VehicleFeign.java

@@ -6,17 +6,16 @@ import com.github.wxiaoqi.security.common.vo.PageDataVO;
 import com.xxfc.platform.vehicle.common.RestResponse;
 import com.xxfc.platform.vehicle.entity.*;
 import com.xxfc.platform.vehicle.pojo.*;
-import com.xxfc.platform.vehicle.pojo.dto.BranchCompanyAreaDTO;
-import com.xxfc.platform.vehicle.pojo.dto.BranchCompanyFindDTO;
-import com.xxfc.platform.vehicle.pojo.dto.CompanyInfoFindDTO;
-import com.xxfc.platform.vehicle.pojo.dto.VehicleModelCalendarPriceDTO;
+import com.xxfc.platform.vehicle.pojo.dto.*;
 import com.xxfc.platform.vehicle.pojo.vo.*;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.http.MediaType;
 import org.springframework.web.bind.annotation.*;
 
-import java.util.*;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
 
 /**
  * Created by ace on 2017/9/15.
@@ -38,6 +37,9 @@ public interface VehicleFeign {
     @RequestMapping(value = "/vehicleInfo/getByIds", method = RequestMethod.GET)
     public RestResponse<List<Vehicle>> getByIds(@RequestParam(value = "ids") List<String> id);
 
+    @GetMapping(value = "/vehicleInfo/app/unauth/getAllVehicleById")
+    public ObjectRestResponse<List<Vehicle>> getAllVehicleById(@RequestParam(value = "vehicleFindAppDTO") String vehicleFindAppDTO);
+
     //提车
     @PostMapping("/backstage/vehicle/unauth/app/updVehicleFeign")
     public ObjectRestResponse updVehicleFeign(@RequestBody Vehicle vehicle);

xx-vehicle/xx-vehicle-api/src/main/java/com/xxfc/platform/vehicle/pojo/dto/VehicleFindDTO.java

@@ -59,4 +59,6 @@ public class VehicleFindDTO extends PageParam implements DataInter {
 
     @ApiModelProperty("店铺状态：1-上架中；2-下架中；3-已调出")
     private Integer  goodStatus;
+
+    private List<String> vehicleIdList;
 }

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/biz/VehicleBiz.java

@@ -1787,6 +1787,12 @@ public class VehicleBiz extends BaseBiz<VehicleMapper, Vehicle> implements UserR
 
     }
 
+    public ObjectRestResponse<List<Vehicle>> getAllVehicleById(String vehicleFindAppDTO) {
+        Example example = new Example(Vehicle.class);
+        example.createCriteria().andIn("id", Arrays.asList(vehicleFindAppDTO.split(",")));
+        return ObjectRestResponse.succ(mapper.selectByExample(example));
+    }
+
 
     public  Long  countByCompanyId(Integer companyId){
         return  mapper.countByCompamyId(companyId);

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/rest/VehicleController.java

@@ -3,7 +3,6 @@ package com.xxfc.platform.vehicle.rest;
 import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.date.DateUtil;
-import cn.hutool.core.util.ArrayUtil;
 import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONException;
@@ -17,7 +16,6 @@ import com.github.wxiaoqi.security.common.context.BaseContextHandler;
 import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
 import com.github.wxiaoqi.security.common.util.process.ResultCode;
 import com.github.wxiaoqi.security.common.vo.PageDataVO;
-import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
 import com.xxfc.platform.vehicle.biz.*;
 import com.xxfc.platform.vehicle.common.BaseController;
@@ -715,6 +713,12 @@ public class VehicleController extends BaseController<VehicleBiz> implements Use
         return  ObjectRestResponse.succ(baseBiz.appSelectList(vehicleFindAppDTO));
     }
 
+    @GetMapping(value = "/app/unauth/getAllVehicleById")
+    @IgnoreUserToken
+    public ObjectRestResponse<List<Vehicle>> getAllVehicleById(@RequestParam("vehicleFindAppDTO") String vehicleFindAppDTO) {
+        return baseBiz.getAllVehicleById(vehicleFindAppDTO);
+    }
+
     @Data
     static public class VehicleVO extends Vehicle {
         private VehicleModel vehicleModel;