Commit 44b42b01 authored by hezhen's avatar hezhen

Merge branch 'base-modify' of http://113.105.137.151:22280/youjj/cloud-platform into base-modify

# Conflicts:
#	ace-modules/ace-admin-api/src/main/java/com/github/wxiaoqi/security/admin/feign/UserFeign.java
#	ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/biz/AppUserDetailBiz.java
parents 9a2e9989 39114f9c
package com.github.wxiaoqi.security.admin.feign; package com.github.wxiaoqi.security.admin.feign;
import com.github.wxiaoqi.security.admin.entity.BaseUserMemberLevel; import com.github.wxiaoqi.security.admin.entity.BaseUserMemberLevel;
import com.github.wxiaoqi.security.admin.feign.dto.AppUserDTO; import com.github.wxiaoqi.security.admin.feign.dto.AppUserDTO;
import com.github.wxiaoqi.security.admin.feign.dto.UserDTO; import com.github.wxiaoqi.security.admin.feign.dto.UserDTO;
...@@ -12,7 +11,6 @@ import org.springframework.web.bind.annotation.RequestMethod; ...@@ -12,7 +11,6 @@ import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RequestParam;
import java.util.List; import java.util.List;
import java.util.Map;
/** /**
* ${DESCRIPTION} * ${DESCRIPTION}
...@@ -40,9 +38,6 @@ public interface UserFeign { ...@@ -40,9 +38,6 @@ public interface UserFeign {
@RequestMapping(value = "/member/levels", method = RequestMethod.GET) @RequestMapping(value = "/member/levels", method = RequestMethod.GET)
public List<BaseUserMemberLevel> levels(); public List<BaseUserMemberLevel> levels();
@RequestMapping(value = "/public/app/userinfo-by-id") @RequestMapping(value = "/app/user/getByUserIds", method = RequestMethod.GET)
public Map<Integer, AppUserVo> userDetailById(List<Integer> userids); public ObjectRestResponse<List<AppUserVo>> getByUserIds(@RequestParam("ids")List<Integer> ids);
} }
package com.github.wxiaoqi.security.admin.rest; package com.github.wxiaoqi.security.admin.rest;
import com.ace.cache.annotation.Cache;
import com.github.wxiaoqi.security.admin.biz.AppUserBiz; import com.github.wxiaoqi.security.admin.biz.AppUserBiz;
import com.github.wxiaoqi.security.admin.biz.AppUserDetailBiz; import com.github.wxiaoqi.security.admin.biz.AppUserDetailBiz;
import com.github.wxiaoqi.security.admin.entity.AppUser; import com.github.wxiaoqi.security.admin.entity.AppUser;
...@@ -20,6 +21,7 @@ import lombok.extern.slf4j.Slf4j; ...@@ -20,6 +21,7 @@ import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
...@@ -128,5 +130,13 @@ public class AppUserController extends CommonBaseController { ...@@ -128,5 +130,13 @@ public class AppUserController extends CommonBaseController {
return ObjectRestResponse.succ(); return ObjectRestResponse.succ();
} }
@GetMapping("/findByUserId")
public ObjectRestResponse<AppUserDetail> findByUserId(Integer id) {
if(id == null || id < 0) {
return ObjectRestResponse.createFailedResult(500, "参数id为空");
}
AppUserDetail appUserDetail = userDetailBiz.getUserByUserid(id);
return ObjectRestResponse.succ(appUserDetail);
}
} }
...@@ -27,6 +27,7 @@ import org.springframework.beans.factory.annotation.Autowired; ...@@ -27,6 +27,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity; import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import java.util.ArrayList;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
...@@ -84,22 +85,18 @@ public class PublicController { ...@@ -84,22 +85,18 @@ public class PublicController {
return new ObjectRestResponse<AppUserDetail>().rel(true).data(user); return new ObjectRestResponse<AppUserDetail>().rel(true).data(user);
} }
//批量获取用户信息 @GetMapping("/getByUserIds")
@RequestMapping(value = "/app/userinfo-by-id", method = RequestMethod.GET) public ObjectRestResponse<List<AppUserVo>> getByUserIds(@RequestParam("ids") List<Integer> ids) {
public @ResponseBody if(ids == null) {
Map<Integer,AppUserVo> userDetailById(List<Integer> userids) throws Exception { return ObjectRestResponse.createFailedResult(500, "参数id为空");
Map<Integer,AppUserVo> map=new HashMap<>();
for (Integer userid:userids) {
AppUserVo userVo = detailBiz.getUserInfoById(userid);
if (userVo == null) {
userVo=new AppUserVo();
userVo.setHeadimgurl(SystemConfig.USER_HEADER_URL_DEFAULT);
userVo.setUserid(userid);
} }
List<AppUserVo> appUserVos = new ArrayList<>();
map.put(userid,userVo); for (Integer id : ids) {
AppUserVo userVo = detailBiz.getUserInfoById(id);
appUserVos.add(userVo);
} }
return map;
return ObjectRestResponse.succ(appUserVos);
} }
......
...@@ -104,6 +104,7 @@ public class UserController extends CommonBaseController { ...@@ -104,6 +104,7 @@ public class UserController extends CommonBaseController {
} }
} }
@RequestMapping(value = "/front/menus", method = RequestMethod.GET) @RequestMapping(value = "/front/menus", method = RequestMethod.GET)
public @ResponseBody public @ResponseBody
List<MenuTree> getMenusByUsername(String token) throws Exception { List<MenuTree> getMenusByUsername(String token) throws Exception {
......
...@@ -194,7 +194,7 @@ public class BaseOrder implements Serializable { ...@@ -194,7 +194,7 @@ public class BaseOrder implements Serializable {
*/ */
@Column(name = "has_discount") @Column(name = "has_discount")
@ApiModelProperty(value = "是否有优惠") @ApiModelProperty(value = "是否有优惠")
private Integer hasDiscount; private Long hasDiscount;
/** /**
* 是否已支付 * 是否已支付
...@@ -202,4 +202,11 @@ public class BaseOrder implements Serializable { ...@@ -202,4 +202,11 @@ public class BaseOrder implements Serializable {
@Column(name = "has_pay") @Column(name = "has_pay")
@ApiModelProperty(value = "是否已支付") @ApiModelProperty(value = "是否已支付")
private Integer hasPay; private Integer hasPay;
@Transient
private String username;
@Transient
private String vehicalNumberPlat;
} }
...@@ -2,7 +2,6 @@ package com.xxfc.platform.order.entity; ...@@ -2,7 +2,6 @@ package com.xxfc.platform.order.entity;
import java.io.Serializable; import java.io.Serializable;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.util.Date;
import javax.persistence.*; import javax.persistence.*;
import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiModelProperty;
import lombok.Data; import lombok.Data;
......
package com.xxfc.platform.order.entity;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.RequiredArgsConstructor;
import javax.persistence.*;
@Table(name = "order_vehicle_crosstown")
@Data
@RequiredArgsConstructor
public class OrderVehicaleCrosstown {
/**
* 主键id
*/
@Id
private Integer id;
/**
* 订单id
*/
@Column(name = "order_id")
private Integer orderId;
/**
* 订单号
*/
@Column(name = "order_no")
private String orderNo;
/**
* 驾驶人
*/
@Column(name = "license_name")
private String licenseName;
/**
* 驾驶人手机号
*/
@Column(name = "license_phone")
private String licensePhone;
/**
* 驾驶证照
*/
@Column(name = "license_img")
private String licenseImg;
/**
* 公里数(公里)
*/
private Integer mileage;
/**
* 公里数取证照
*/
@Column(name = "mileage_img")
private String mileageImg;
/**
* 审核状态;0-未审核;1-已审核
*/
private Boolean status;
/**
* 审核时间
*/
@Column(name = "status_time")
private Long statusTime;
/**
* 审核名称
*/
@Column(name = "status_name")
private String statusName;
/**
* 审核人id
*/
@Column(name = "status_id")
private Integer statusId;
/**
* 是否删除;0-正常;1-删除
*/
@Column(name = "is_del")
private Boolean isDel;
/**
* 取证图片
*/
private String imgs;
/**
* 备注
*/
private String remak;
/**
* 创建时间
*/
private Long crtTime;
/**
* 更新时间
*/
private Long updTime;
/**
* 钥匙图片
*/
private String vehicleKey;
/**
* 是否有扣除项
*/
private Boolean isDed;
/**
* 扣除项明细
*/
private String dedDetail;
/**
* 驾驶人身份证号
*/
private String licenseIdCard;
/**
* 1、交车, 2、还车
*/
private Integer type;
}
\ No newline at end of file
...@@ -25,7 +25,6 @@ ...@@ -25,7 +25,6 @@
<version>2.0-SNAPSHOT</version> <version>2.0-SNAPSHOT</version>
<scope>compile</scope> <scope>compile</scope>
</dependency> </dependency>
</dependencies> </dependencies>
<build> <build>
...@@ -50,6 +49,11 @@ ...@@ -50,6 +49,11 @@
<version>5.1.30</version> <version>5.1.30</version>
<scope>runtime</scope> <scope>runtime</scope>
</dependency> </dependency>
<dependency>
<groupId>commons-beanutils</groupId>
<artifactId>commons-beanutils</artifactId>
<version>1.9.3</version>
</dependency>
<dependency> <dependency>
<groupId>tk.mybatis</groupId> <groupId>tk.mybatis</groupId>
<artifactId>mapper</artifactId> <artifactId>mapper</artifactId>
......
...@@ -48,6 +48,9 @@ public class BaseOrderBiz extends BaseBiz<BaseOrderMapper,BaseOrder> { ...@@ -48,6 +48,9 @@ public class BaseOrderBiz extends BaseBiz<BaseOrderMapper,BaseOrder> {
public List<OrderPageVO> listOrder(Map<String, Object> paramMap){ public List<OrderPageVO> listOrder(Map<String, Object> paramMap){
return mapper.listOrder(paramMap); return mapper.listOrder(paramMap);
} }
public List<OrderPageVO> getRentVehicle (Map<String, Object> paramMap) {
return mapper.getRentVehicle(paramMap);
}
private static Map<Integer, List<Integer>> cancelAble; private static Map<Integer, List<Integer>> cancelAble;
static { static {
cancelAble = new HashMap<Integer, List<Integer>>(); cancelAble = new HashMap<Integer, List<Integer>>();
......
package com.xxfc.platform.order.biz;
import com.ace.cache.annotation.Cache;
import com.github.wxiaoqi.security.common.biz.BaseBiz;
import com.xxfc.platform.order.entity.OrderVehicaleCrosstown;
import com.xxfc.platform.order.mapper.OrderVehicaleCrosstownMapper;
import org.springframework.stereotype.Service;
import java.util.List;
@Service
public class OrderVehicalCrosstownBiz extends BaseBiz<OrderVehicaleCrosstownMapper, OrderVehicaleCrosstown> {
public OrderVehicaleCrosstown get(Integer id){
return selectById(id);
}
public List<OrderVehicaleCrosstown> selectByOrderId(OrderVehicaleCrosstown orderVehicaleCrosstown) {
return mapper.selectByOrderId(orderVehicaleCrosstown);
}
}
package com.xxfc.platform.order.config;
import feign.RequestInterceptor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
import javax.servlet.http.HttpServletRequest;
import java.util.Enumeration;
/**
* 自定义的请求头处理类,处理服务发送时的请求头;
* 将服务接收到的请求头中的uniqueId和token字段取出来,并设置到新的请求头里面去转发给下游服务
* 比如A服务收到一个请求,请求头里面包含uniqueId和token字段,A处理时会使用Feign客户端调用B服务
* 那么uniqueId和token这两个字段就会添加到请求头中一并发给B服务;
*
* @author mozping
* @version 1.0
* @date 2018/6/27 14:13
* @see FeignHeadConfiguration
* @since JDK1.8
*/
@Configuration
@Slf4j
public class FeignHeadConfiguration {
@Bean
public RequestInterceptor requestInterceptor() {
return requestTemplate -> {
ServletRequestAttributes attrs = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
if (attrs != null) {
HttpServletRequest request = attrs.getRequest();
Enumeration<String> headerNames = request.getHeaderNames();
if (headerNames != null) {
while (headerNames.hasMoreElements()) {
String name = headerNames.nextElement();
String value = request.getHeader(name);
/**
* 遍历请求头里面的属性字段,将logId和token添加到新的请求头中转发到下游服务
* */
if ("Authorization".equalsIgnoreCase(name)) {
log.debug("添加自定义请求头key:" + name + ",value:" + value);
requestTemplate.header(name, value);
} else {
log.debug("FeignHeadConfiguration", "非自定义请求头key:" + name + ",value:" + value + "不需要添加!");
}
}
} else {
log.warn("FeignHeadConfiguration", "获取请求头失败!");
}
}
};
}
}
...@@ -17,4 +17,5 @@ import java.util.Map; ...@@ -17,4 +17,5 @@ import java.util.Map;
public interface BaseOrderMapper extends Mapper<BaseOrder> { public interface BaseOrderMapper extends Mapper<BaseOrder> {
public List<OrderPageVO> pageByParm(Map<String, Object> paramMap); public List<OrderPageVO> pageByParm(Map<String, Object> paramMap);
public List<OrderPageVO> listOrder(Map<String, Object> paramMap); public List<OrderPageVO> listOrder(Map<String, Object> paramMap);
public List<OrderPageVO> getRentVehicle(Map<String, Object> paramMap);
} }
package com.xxfc.platform.order.mapper;
import com.xxfc.platform.order.entity.OrderVehicaleCrosstown;
import tk.mybatis.mapper.common.Mapper;
import java.util.List;
public interface OrderVehicaleCrosstownMapper extends Mapper<OrderVehicaleCrosstown> {
List<OrderVehicaleCrosstown> selectByOrderId(OrderVehicaleCrosstown orderVehicaleCrosstown);
}
\ No newline at end of file
...@@ -3,7 +3,7 @@ package com.xxfc.platform.order.rest; ...@@ -3,7 +3,7 @@ package com.xxfc.platform.order.rest;
import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONUtil; import cn.hutool.json.JSONUtil;
import com.github.pagehelper.PageHelper; import com.github.wxiaoqi.security.admin.entity.AppUserDetail;
import com.github.wxiaoqi.security.admin.feign.UserFeign; import com.github.wxiaoqi.security.admin.feign.UserFeign;
import com.github.wxiaoqi.security.admin.feign.dto.UserDTO; import com.github.wxiaoqi.security.admin.feign.dto.UserDTO;
import com.github.wxiaoqi.security.auth.client.annotation.IgnoreClientToken; import com.github.wxiaoqi.security.auth.client.annotation.IgnoreClientToken;
...@@ -26,7 +26,9 @@ import com.xxfc.platform.order.pojo.pay.RentVehicleOrderPayVO; ...@@ -26,7 +26,9 @@ import com.xxfc.platform.order.pojo.pay.RentVehicleOrderPayVO;
import com.xxfc.platform.universal.constant.enumerate.PayChannelEnum; import com.xxfc.platform.universal.constant.enumerate.PayChannelEnum;
import com.xxfc.platform.universal.feign.ThirdFeign; import com.xxfc.platform.universal.feign.ThirdFeign;
import com.xxfc.platform.universal.vo.OrderPayVo; import com.xxfc.platform.universal.vo.OrderPayVo;
import com.xxfc.platform.universal.vo.OrderRefundVo; import com.xxfc.platform.vehicle.common.RestResponse;
import com.xxfc.platform.vehicle.entity.Vehicle;
import com.xxfc.platform.vehicle.feign.VehicleFeign;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiModelProperty;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
...@@ -38,42 +40,42 @@ import org.springframework.beans.factory.annotation.Value; ...@@ -38,42 +40,42 @@ import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Controller; import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;
import static com.github.wxiaoqi.security.common.constant.CommonConstants.SYS_TRUE; import static com.github.wxiaoqi.security.common.constant.CommonConstants.SYS_TRUE;
@Controller @Controller
@RequestMapping("baseOrder") @RequestMapping("baseOrder")
@Api(value="订单",tags={"订单"}) @Api(value = "订单", tags = {"订单"})
@Slf4j @Slf4j
public class BaseOrderController extends CommonBaseController { public class BaseOrderController extends CommonBaseController {
public static final Integer STATUS_SUCCESS = 1;
@Autowired @Autowired
BaseOrderBiz baseOrderBiz; BaseOrderBiz baseOrderBiz;
@Autowired @Autowired
ThirdFeign thirdFeign; ThirdFeign thirdFeign;
@Autowired @Autowired
UserFeign userFeign; UserFeign userFeign;
@Resource
VehicleFeign vehicleFeign;
@Value("${gateway.host}") @Value("${gateway.host}")
String host; String host;
@Value("${gateway.order}") @Value("${gateway.order}")
String order; String order;
String notifyUrl = "/baseOrder/app/unauth/notifyUrl"; String notifyUrl = "/baseOrder/app/unauth/notifyUrl";
public static final Integer STATUS_SUCCESS = 1; @RequestMapping(value = "/page", method = RequestMethod.GET)
@RequestMapping(value = "/page",method = RequestMethod.GET)
@ResponseBody @ResponseBody
@ApiOperation(value = "订单列表") @ApiOperation(value = "订单列表")
@IgnoreClientToken @IgnoreClientToken
public ObjectRestResponse<PageDataVO<OrderPageVO>> list(QueryOrderDTO dto){ public ObjectRestResponse<PageDataVO<OrderPageVO>> list(QueryOrderDTO dto) {
//查询列表数据 //查询列表数据
if(StringUtils.isBlank(BaseContextHandler.getUserID())) { if (StringUtils.isBlank(BaseContextHandler.getUserID())) {
throw new BaseException(ResultCode.AJAX_WECHAT_NOTEXIST_CODE); throw new BaseException(ResultCode.AJAX_WECHAT_NOTEXIST_CODE);
} }
dto.setCrtUser(Integer.valueOf(BaseContextHandler.getUserID())); dto.setCrtUser(Integer.valueOf(BaseContextHandler.getUserID()));
...@@ -81,24 +83,81 @@ public class BaseOrderController extends CommonBaseController { ...@@ -81,24 +83,81 @@ public class BaseOrderController extends CommonBaseController {
return new ObjectRestResponse<>().data(PageDataVO.pageInfo(query, () -> baseOrderBiz.pageByParm(query.getSuper()))); return new ObjectRestResponse<>().data(PageDataVO.pageInfo(query, () -> baseOrderBiz.pageByParm(query.getSuper())));
} }
@RequestMapping(value = "/list",method = RequestMethod.GET) @RequestMapping(value = "/list", method = RequestMethod.GET)
@ResponseBody @ResponseBody
@ApiOperation(value = "订单列表") @ApiOperation(value = "订单列表")
@IgnoreClientToken @IgnoreClientToken
public ObjectRestResponse<PageDataVO<OrderPageVO>> getOrderList(QueryOrderDTO dto){ public ObjectRestResponse<PageDataVO<OrderPageVO>> getOrderList(QueryOrderDTO dto) {
Query query = new Query(dto); Query query = new Query(dto);
return new ObjectRestResponse<>().data(PageDataVO.pageInfo(query, () -> baseOrderBiz.selectListAll())); return new ObjectRestResponse<>().data(PageDataVO.pageInfo(query, () -> baseOrderBiz.selectListAll()));
} }
@RequestMapping(value = "/selectByUser",method = RequestMethod.GET) @RequestMapping(value = "/getOrderList", method = RequestMethod.GET)
@ResponseBody @ResponseBody
@ApiOperation(value = "订单列表") @ApiOperation(value = "订单列表")
@IgnoreClientToken @IgnoreClientToken
public ObjectRestResponse<PageDataVO<OrderPageVO>> selectByUser(QueryOrderList dto){ public ObjectRestResponse<PageDataVO<OrderPageVO>> selectByUser(QueryOrderList dto) {
if (dto.getStartTime() != null) {
if (dto.getEndTime() == null) {
dto.setEndTime(new Date().getTime());
}
}
Query query = new Query(dto);
PageDataVO pageDataVO = PageDataVO.pageInfo(query, () -> baseOrderBiz.listOrder(query.getSuper()));
List<OrderPageVO> list = pageDataVO.getData();
List<Integer> userIds = list.stream().map(OrderPageVO::getUserId).distinct().collect(Collectors.toList());
ObjectRestResponse<List<AppUserDetail>> objectRestResponse = userFeign.getByUserIds(userIds);
for (OrderPageVO orderPageVO : list) {
if (objectRestResponse.getData() != null && objectRestResponse.getData().size() > 0) {
for (AppUserDetail appUserDetail : objectRestResponse.getData()) {
if (appUserDetail != null && appUserDetail.getUserid() == orderPageVO.getUserId()) {
orderPageVO.setUsername(appUserDetail.getNickname());
}
}
}
if (orderPageVO.getOrderRentVehicleDetail() != null && orderPageVO.getOrderRentVehicleDetail().getVehicleId() != null) {
RestResponse<Vehicle> restResponse = vehicleFeign.findById(orderPageVO.getOrderRentVehicleDetail().getVehicleId());
log.info("获取车辆信息返回消息:{}", restResponse.getMessage());
if (restResponse.getData() != null) {
orderPageVO.setVehicalNumberPlat(restResponse.getData().getNumberPlate());
}
}
}
return new ObjectRestResponse<>().data(pageDataVO);
}
@RequestMapping(value = "/getVehicleList", method = RequestMethod.GET)
@ResponseBody
@ApiOperation(value = "交还车订单列表")
@IgnoreClientToken
public ObjectRestResponse<List<OrderPageVO>> getVehicleList(QueryOrderList dto) {
if (dto.getStartTime() != null) {
if (dto.getEndTime() == null) {
dto.setEndTime(new Date().getTime());
}
}
dto.setType(1);
Query query = new Query(dto); Query query = new Query(dto);
return new ObjectRestResponse<>().data(PageDataVO.pageInfo(query, () -> baseOrderBiz.listOrder(query.getSuper()))); PageDataVO pageDataVO = PageDataVO.pageInfo(query, () -> baseOrderBiz.listOrder(query.getSuper()));
return new ObjectRestResponse<>().data(pageDataVO);
} }
@RequestMapping(value = "/getTourList", method = RequestMethod.GET)
@ResponseBody
@ApiOperation(value = "交还车订单列表")
@IgnoreClientToken
public ObjectRestResponse<List<OrderPageVO>> getTourList(QueryOrderList dto) {
if (dto.getStartTime() != null) {
if (dto.getEndTime() == null) {
dto.setEndTime(new Date().getTime());
}
}
dto.setType(2);
Query query = new Query(dto);
PageDataVO pageDataVO = PageDataVO.pageInfo(query, () -> baseOrderBiz.listOrder(query.getSuper()));
return new ObjectRestResponse<>().data(pageDataVO);
}
// @RequestMapping(value = "/company/page",method = RequestMethod.GET) // @RequestMapping(value = "/company/page",method = RequestMethod.GET)
// @ResponseBody // @ResponseBody
...@@ -115,36 +174,36 @@ public class BaseOrderController extends CommonBaseController { ...@@ -115,36 +174,36 @@ public class BaseOrderController extends CommonBaseController {
// } // }
@ApiOperation("订单详情") @ApiOperation("订单详情")
@RequestMapping(value = "/{no}",method = RequestMethod.GET) @RequestMapping(value = "/{no}", method = RequestMethod.GET)
@IgnoreClientToken @IgnoreClientToken
@ResponseBody @ResponseBody
public ObjectRestResponse<OrderPageVO> get(@PathVariable String no){ public ObjectRestResponse<OrderPageVO> get(@PathVariable String no) {
//查询列表数据 //查询列表数据
if(StringUtils.isBlank(BaseContextHandler.getUserID())) { if (StringUtils.isBlank(BaseContextHandler.getUserID())) {
throw new BaseException(ResultCode.AJAX_WECHAT_NOTEXIST_CODE); throw new BaseException(ResultCode.AJAX_WECHAT_NOTEXIST_CODE);
} }
Query query = initQuery(no); Query query = initQuery(no);
PageDataVO<OrderPageVO> page = PageDataVO.pageInfo(query, () -> baseOrderBiz.pageByParm(query.getSuper())); PageDataVO<OrderPageVO> page = PageDataVO.pageInfo(query, () -> baseOrderBiz.pageByParm(query.getSuper()));
if(page.getData().isEmpty()) { if (page.getData().isEmpty()) {
throw new BaseException(ResultCode.NOTEXIST_CODE); throw new BaseException(ResultCode.NOTEXIST_CODE);
} }
return new ObjectRestResponse<>().data(page.getData().get(0)); return new ObjectRestResponse<>().data(page.getData().get(0));
} }
@ApiOperation("结合后台人员所属公司查询订单详情") @ApiOperation("结合后台人员所属公司查询订单详情")
@RequestMapping(value = "/company/{no}",method = RequestMethod.GET) @RequestMapping(value = "/company/{no}", method = RequestMethod.GET)
@IgnoreClientToken @IgnoreClientToken
@ResponseBody @ResponseBody
public ObjectRestResponse<OrderPageVO> companyGet(@PathVariable String no){ public ObjectRestResponse<OrderPageVO> companyGet(@PathVariable String no) {
//查询列表数据 //查询列表数据
if(StringUtils.isBlank(BaseContextHandler.getUserID())) { if (StringUtils.isBlank(BaseContextHandler.getUserID())) {
throw new BaseException(ResultCode.AJAX_WECHAT_NOTEXIST_CODE); throw new BaseException(ResultCode.AJAX_WECHAT_NOTEXIST_CODE);
} }
Query query = initCompanyQuery(no); Query query = initCompanyQuery(no);
PageDataVO<OrderPageVO> page = PageDataVO.pageInfo(query, () -> baseOrderBiz.pageByParm(query.getSuper())); PageDataVO<OrderPageVO> page = PageDataVO.pageInfo(query, () -> baseOrderBiz.pageByParm(query.getSuper()));
if(page.getData().isEmpty()) { if (page.getData().isEmpty()) {
throw new BaseException(ResultCode.NOTEXIST_CODE); throw new BaseException(ResultCode.NOTEXIST_CODE);
} }
return new ObjectRestResponse<>().data(page.getData().get(0)); return new ObjectRestResponse<>().data(page.getData().get(0));
...@@ -189,23 +248,23 @@ public class BaseOrderController extends CommonBaseController { ...@@ -189,23 +248,23 @@ public class BaseOrderController extends CommonBaseController {
return query; return query;
} }
@RequestMapping(value = "/pay",method = RequestMethod.POST) @RequestMapping(value = "/pay", method = RequestMethod.POST)
@ResponseBody @ResponseBody
@ApiOperation(value = "订单支付") @ApiOperation(value = "订单支付")
@IgnoreClientToken @IgnoreClientToken
public ObjectRestResponse pay(@RequestBody RentVehicleOrderPayVO vo){ public ObjectRestResponse pay(@RequestBody RentVehicleOrderPayVO vo) {
//查询列表数据 //查询列表数据
if(StringUtils.isBlank(BaseContextHandler.getUserID())) { if (StringUtils.isBlank(BaseContextHandler.getUserID())) {
throw new BaseException(ResultCode.AJAX_WECHAT_NOTEXIST_CODE); throw new BaseException(ResultCode.AJAX_WECHAT_NOTEXIST_CODE);
} }
OrderPayVo orderPayVo = BeanUtil.toBean(vo, OrderPayVo.class); OrderPayVo orderPayVo = BeanUtil.toBean(vo, OrderPayVo.class);
BaseOrder baseOrder = baseOrderBiz.selectOne(new BaseOrder(){{ BaseOrder baseOrder = baseOrderBiz.selectOne(new BaseOrder() {{
setNo(vo.getOrderNo()); setNo(vo.getOrderNo());
}}); }});
if(null == baseOrder || !OrderStatusEnum.ORDER_UNPAY.getCode().equals(baseOrder.getStatus())) { if (null == baseOrder || !OrderStatusEnum.ORDER_UNPAY.getCode().equals(baseOrder.getStatus())) {
throw new BaseException("订单不可支付", ResultCode.EXCEPTION_CODE); throw new BaseException("订单不可支付", ResultCode.EXCEPTION_CODE);
} }
...@@ -213,26 +272,26 @@ public class BaseOrderController extends CommonBaseController { ...@@ -213,26 +272,26 @@ public class BaseOrderController extends CommonBaseController {
orderPayVo.setBody(baseOrder.getName()); orderPayVo.setBody(baseOrder.getName());
orderPayVo.setBuyerIp(StringUtils.defaultIfBlank(request.getHeader("userHost"), ClientUtil.getClientIp(request))); orderPayVo.setBuyerIp(StringUtils.defaultIfBlank(request.getHeader("userHost"), ClientUtil.getClientIp(request)));
orderPayVo.setChannel(PayChannelEnum.ORDER_CRT.getCode()); orderPayVo.setChannel(PayChannelEnum.ORDER_CRT.getCode());
orderPayVo.setNotifyUrl(host+ order+ notifyUrl+ "?orderNo="+ baseOrder.getNo()); orderPayVo.setNotifyUrl(host + order + notifyUrl + "?orderNo=" + baseOrder.getNo());
orderPayVo.setSubject(baseOrder.getName()); orderPayVo.setSubject(baseOrder.getName());
orderPayVo.setUserId(baseOrder.getUserId()); orderPayVo.setUserId(baseOrder.getUserId());
ObjectRestResponse response = BeanUtil.toBean(thirdFeign.wx(orderPayVo), ObjectRestResponse.class); ObjectRestResponse response = BeanUtil.toBean(thirdFeign.wx(orderPayVo), ObjectRestResponse.class);
return response; return response;
} }
@RequestMapping(value = "/cancel/{no}",method = RequestMethod.POST) @RequestMapping(value = "/cancel/{no}", method = RequestMethod.POST)
@ResponseBody @ResponseBody
@ApiOperation(value = "取消订单") @ApiOperation(value = "取消订单")
@IgnoreClientToken @IgnoreClientToken
public ObjectRestResponse cancel(@PathVariable String no, @RequestBody CancelOrderDTO cancelOrderDto){ public ObjectRestResponse cancel(@PathVariable String no, @RequestBody CancelOrderDTO cancelOrderDto) {
//查询列表数据 //查询列表数据
if(StringUtils.isBlank(BaseContextHandler.getUserID())) { if (StringUtils.isBlank(BaseContextHandler.getUserID())) {
throw new BaseException(ResultCode.AJAX_WECHAT_NOTEXIST_CODE); throw new BaseException(ResultCode.AJAX_WECHAT_NOTEXIST_CODE);
} }
BaseOrder dbBaseOrder = baseOrderBiz.selectOne(new BaseOrder(){{ BaseOrder dbBaseOrder = baseOrderBiz.selectOne(new BaseOrder() {{
setNo(no); setNo(no);
}}); }});
if(null == dbBaseOrder || !BaseContextHandler.getUserID().equals(dbBaseOrder.getUserId().toString())) { if (null == dbBaseOrder || !BaseContextHandler.getUserID().equals(dbBaseOrder.getUserId().toString())) {
throw new BaseException(ResultCode.NOTEXIST_CODE); throw new BaseException(ResultCode.NOTEXIST_CODE);
} }
dbBaseOrder.setCancelReason(cancelOrderDto.getCancelReason()); dbBaseOrder.setCancelReason(cancelOrderDto.getCancelReason());
...@@ -240,20 +299,25 @@ public class BaseOrderController extends CommonBaseController { ...@@ -240,20 +299,25 @@ public class BaseOrderController extends CommonBaseController {
return ObjectRestResponse.succ(); return ObjectRestResponse.succ();
} }
@RequestMapping(value = "/app/unauth/notifyUrl",method = RequestMethod.GET) @RequestMapping(value = "/app/unauth/notifyUrl", method = RequestMethod.GET)
@ResponseBody @ResponseBody
@ApiOperation(value = "订单支付回调") @ApiOperation(value = "订单支付回调")
@IgnoreClientToken @IgnoreClientToken
@IgnoreUserToken @IgnoreUserToken
public ObjectRestResponse notifyUrl(NotifyUrlDTO dto){ public ObjectRestResponse notifyUrl(NotifyUrlDTO dto) {
//判断是否成功,并且订单是未支付状态,则添加支付编号和修改状态 //判断是否成功,并且订单是未支付状态,则添加支付编号和修改状态
if(StrUtil.isNotBlank(dto.getOrderNo())){ if (StrUtil.isNotBlank(dto.getOrderNo())) {
BaseOrder baseOrder = baseOrderBiz.selectOne(new BaseOrder(){{ BaseOrder baseOrder = baseOrderBiz.selectOne(new BaseOrder() {{
setNo(dto.getOrderNo()); setNo(dto.getOrderNo());
}}); }});
if(OrderStatusEnum.ORDER_UNPAY.getCode().equals(baseOrder.getStatus())) { if (OrderStatusEnum.ORDER_UNPAY.getCode().equals(baseOrder.getStatus())) {
BaseOrder updateOrder = new BaseOrder(){{ baseOrder.setStatus(OrderStatusEnum.ORDER_TOSTART.getCode());
baseOrder.setOutTradeNo(dto.getTradeNo());
baseOrderBiz.updateById(baseOrder);
} else {
if (OrderStatusEnum.ORDER_UNPAY.getCode().equals(baseOrder.getStatus())) {
BaseOrder updateOrder = new BaseOrder() {{
setNo(dto.getOrderNo()); setNo(dto.getOrderNo());
setStatus(OrderStatusEnum.ORDER_TOSTART.getCode()); setStatus(OrderStatusEnum.ORDER_TOSTART.getCode());
setOutTradeNo(dto.getTradeNo()); setOutTradeNo(dto.getTradeNo());
...@@ -261,15 +325,15 @@ public class BaseOrderController extends CommonBaseController { ...@@ -261,15 +325,15 @@ public class BaseOrderController extends CommonBaseController {
setPayTime(System.currentTimeMillis()); setPayTime(System.currentTimeMillis());
}}; }};
baseOrderBiz.updateSelectiveById(updateOrder); baseOrderBiz.updateSelectiveById(updateOrder);
}else { } else {
log.error(" exception notifyUrl : " + JSONUtil.toJsonStr(dto)); log.error(" exception notifyUrl : " + JSONUtil.toJsonStr(dto));
} }
}else { }
}else{
log.error(" exception notifyUrl : " + JSONUtil.toJsonStr(dto)); log.error(" exception notifyUrl : " + JSONUtil.toJsonStr(dto));
} }
return new ObjectRestResponse().rel(true); return new ObjectRestResponse().rel(true);
} }
/** /**
* 订单查询类 * 订单查询类
*/ */
...@@ -309,10 +373,16 @@ public class BaseOrderController extends CommonBaseController { ...@@ -309,10 +373,16 @@ public class BaseOrderController extends CommonBaseController {
private Long endTime; private Long endTime;
private Integer startCompanyId; private Integer startCompanyId;
private Integer startZoneId;
private Integer userId;
private Integer type;
} }
@Data @Data
public class NotifyUrlDTO{ public class NotifyUrlDTO {
//订单号 //订单号
@ApiModelProperty(value = "订单号") @ApiModelProperty(value = "订单号")
private String orderNo; private String orderNo;
...@@ -321,4 +391,4 @@ public class BaseOrderController extends CommonBaseController { ...@@ -321,4 +391,4 @@ public class BaseOrderController extends CommonBaseController {
@ApiModelProperty(value = "支付订单(流水)号") @ApiModelProperty(value = "支付订单(流水)号")
private String tradeNo; private String tradeNo;
} }
} }
\ No newline at end of file
package com.xxfc.platform.order.rest;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.bean.copier.CopyOptions;
import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
import com.xxfc.platform.order.biz.OrderVehicalCrosstownBiz;
import com.xxfc.platform.order.entity.OrderVehicaleCrosstown;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.List;
@RestController
@RequestMapping(value = "/orderVehicle")
@Api(value = "交还车记录", tags = {"交还车记录"})
@Slf4j
public class OrderVehicleCrosstownController {
@Autowired
OrderVehicalCrosstownBiz orderVehicalCrosstownBiz;
@PostMapping(value = "/add")
@ApiOperation(value = "添加交还车记录")
public ObjectRestResponse<?> add(OrderVehicaleCrosstown orderVehicaleCrosstown) {
log.info("添加的参数:orderVehicaleCrosstown = {}", orderVehicaleCrosstown);
if (orderVehicaleCrosstown == null) {
return ObjectRestResponse.createFailedResult(500, "参数为空!");
}
if (orderVehicaleCrosstown.getId() != null) {
OrderVehicaleCrosstown oldValue = orderVehicalCrosstownBiz.get(orderVehicaleCrosstown.getId());
if (oldValue != null) {
BeanUtil.copyProperties(orderVehicaleCrosstown, oldValue, CopyOptions.create().setIgnoreNullValue(true).setIgnoreError(true));
orderVehicalCrosstownBiz.updateSelectiveById(oldValue);
return ObjectRestResponse.succ();
}
orderVehicalCrosstownBiz.insertSelective(orderVehicaleCrosstown);
return ObjectRestResponse.succ();
} else {
orderVehicalCrosstownBiz.insertSelective(orderVehicaleCrosstown);
return ObjectRestResponse.succ();
}
}
@GetMapping(value = "/{id}")
@ApiOperation(value = "查询记录信息")
public ObjectRestResponse<OrderVehicaleCrosstown> get(@PathVariable Integer id) {
return ObjectRestResponse.succ(orderVehicalCrosstownBiz.get(id));
}
@GetMapping(value = "/getByOrderId")
@ApiOperation(value = "根据订单Id获取所有记录信息")
public ObjectRestResponse<List<OrderVehicaleCrosstown>> getByOrderId(OrderVehicaleCrosstown orderVehicaleCrosstown) {
if (orderVehicaleCrosstown == null) {
return ObjectRestResponse.createFailedResult(500, "参数orderId为空");
}
return ObjectRestResponse.succ(orderVehicalCrosstownBiz.selectByOrderId(orderVehicaleCrosstown));
}
}
...@@ -27,7 +27,7 @@ ...@@ -27,7 +27,7 @@
<javaClientGenerator targetPackage="${targetMapperPackage}" targetProject="${targetJavaProject}" <javaClientGenerator targetPackage="${targetMapperPackage}" targetProject="${targetJavaProject}"
type="XMLMAPPER"/> type="XMLMAPPER"/>
<!-- <table tableName="vehicle" domainObjectName="Vehicle">--> <!-- <table tableName="order_vehicle_crosstown" domainObjectName="Vehicle">-->
<!-- </table>--> <!-- </table>-->
<!-- <table tableName="vehicle_book_info" domainObjectName="VehicleBookInfo">--> <!-- <table tableName="vehicle_book_info" domainObjectName="VehicleBookInfo">-->
<!-- </table>--> <!-- </table>-->
...@@ -37,7 +37,7 @@ ...@@ -37,7 +37,7 @@
<!-- </table>--> <!-- </table>-->
<!-- <table tableName="branch_company_stock_info" domainObjectName="BranchCompanyStockInfo"></table>--> <!-- <table tableName="branch_company_stock_info" domainObjectName="BranchCompanyStockInfo"></table>-->
<!-- <table tableName="branch_company_stock_apply_info" domainObjectName="BranchCompanyStockApplyInfo"></table>--> <!-- <table tableName="branch_company_stock_apply_info" domainObjectName="BranchCompanyStockApplyInfo"></table>-->
<table tableName="base_order" domainObjectName="baseOrder"></table> <table tableName="order_vehicle_crosstown" domainObjectName="OrderVehicaleCrosstown"></table>
<!-- <table tableName="vehicle_upkeep_log" domainObjectName="VehicleUpkeepLog"></table>--> <!-- <table tableName="vehicle_upkeep_log" domainObjectName="VehicleUpkeepLog"></table>-->
</context> </context>
</generatorConfiguration> </generatorConfiguration>
\ No newline at end of file
...@@ -68,6 +68,9 @@ ...@@ -68,6 +68,9 @@
</if> </if>
<if test="status != null"> <if test="status != null">
and b.status = #{status} and b.status = #{status}
</if>
<if test="type != null">
and b.type = #{type}
</if> </if>
<if test="no != null"> <if test="no != null">
and no like CONCAT ("%", #{no}, "%") and no like CONCAT ("%", #{no}, "%")
...@@ -80,6 +83,34 @@ ...@@ -80,6 +83,34 @@
and r.start_company_id = #{startCompanyId} and r.start_company_id = #{startCompanyId}
or t.start_company_id = #{startCompanyId} or t.start_company_id = #{startCompanyId}
</if> </if>
<if test="startZoneId != null">
and r.start_zone_id = #{startZoneId}
or t.start_zone_id = #{startZoneId}
</if>
</where>
order by b.crt_time desc
</select>
<select id="getRentVehicle" parameterType="Map" resultMap="orderPageMap">
select b.*
from base_order b
LEFT JOIN order_rent_vehicle_detail r on r.order_id = b.id
<where>
<if test="userId != null">
and b.user_id = #{userId}
</if>
<if test="status != null">
and b.status = #{status}
</if>
<if test="no != null">
and no like CONCAT ("%", #{no}, "%")
</if>
<if test="startTime != null">
and r.start_time between #{startTime} and #{endTime}
</if>
<if test="startCompanyId != null">
and r.start_company_id = #{startCompanyId}
</if>
</where> </where>
order by b.crt_time desc order by b.crt_time desc
</select> </select>
......
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.xxfc.platform.order.mapper.OrderVehicaleCrosstownMapper">
<resultMap id="BaseResultMap" type="com.xxfc.platform.order.entity.OrderVehicaleCrosstown">
<!--
WARNING - @mbg.generated
-->
<id column="id" jdbcType="INTEGER" property="id" />
<result column="order_id" jdbcType="INTEGER" property="orderId" />
<result column="order_no" jdbcType="VARCHAR" property="orderNo" />
<result column="license_name" jdbcType="VARCHAR" property="licenseName" />
<result column="license_phone" jdbcType="VARCHAR" property="licensePhone" />
<result column="license_img" jdbcType="VARCHAR" property="licenseImg" />
<result column="mileage" jdbcType="INTEGER" property="mileage" />
<result column="mileage_img" jdbcType="VARCHAR" property="mileageImg" />
<result column="status" jdbcType="BIT" property="status" />
<result column="status_time" jdbcType="BIGINT" property="statusTime" />
<result column="status_name" jdbcType="VARCHAR" property="statusName" />
<result column="status_id" jdbcType="INTEGER" property="statusId" />
<result column="is_del" jdbcType="BIT" property="isDel" />
<result column="imgs" jdbcType="LONGVARCHAR" property="imgs" />
<result column="remak" jdbcType="LONGVARCHAR" property="remak" />
<result column="crt_time" jdbcType="BIGINT" property="crtTime" />
<result column="upd_time" jdbcType="BIGINT" property="updTime" />
<result column="vehicle_key" jdbcType="LONGVARCHAR" property="vehicleKey"/>
<result column="license_id_card" jdbcType="VARCHAR" property="licenseIdCard"/>
<result column="is_ded" jdbcType="BIT" property="isDeD" />
<result column="ded_detail" jdbcType="LONGVARCHAR" property="dedDetail" />
<result column="type" jdbcType="INTEGER" property="type"/>
</resultMap>
<select id="selectByOrderId" parameterType="com.xxfc.platform.order.entity.OrderVehicaleCrosstown" resultMap="BaseResultMap">
select *
from order_vehicle_crosstown
<where>
<if test="status != null">
and status = #{status}
</if>
<if test="type != null">
and type = #{type}
</if>
<if test="orderId != null">
and order_id = #{orderId}
</if>
<if test="orderNo != null">
and order_no = #{orderNo}
</if>
</where>
</select>
</mapper>
\ No newline at end of file
...@@ -2,14 +2,15 @@ package com.xxfc.platform.vehicle.feign; ...@@ -2,14 +2,15 @@ package com.xxfc.platform.vehicle.feign;
import com.github.wxiaoqi.security.common.msg.ObjectRestResponse; import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
import com.xxfc.platform.vehicle.common.RestResponse; import com.xxfc.platform.vehicle.common.RestResponse;
import com.xxfc.platform.vehicle.entity.Vehicle;
import com.xxfc.platform.vehicle.entity.VehicleModel; import com.xxfc.platform.vehicle.entity.VehicleModel;
import com.xxfc.platform.vehicle.pojo.BookVehicleVO;
import com.xxfc.platform.vehicle.pojo.CompanyDetail; import com.xxfc.platform.vehicle.pojo.CompanyDetail;
import com.xxfc.platform.vehicle.pojo.RentVehicleBookDTO; import com.xxfc.platform.vehicle.pojo.RentVehicleBookDTO;
import io.swagger.annotations.ApiOperation;
import org.springframework.cloud.openfeign.FeignClient; import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import java.util.List;
/** /**
* Created by ace on 2017/9/15. * Created by ace on 2017/9/15.
*/ */
...@@ -18,6 +19,15 @@ public interface VehicleFeign { ...@@ -18,6 +19,15 @@ public interface VehicleFeign {
@GetMapping(value = "/vehicleModel/{id}") @GetMapping(value = "/vehicleModel/{id}")
public ObjectRestResponse<VehicleModel> get(@PathVariable("id") int id); public ObjectRestResponse<VehicleModel> get(@PathVariable("id") int id);
@GetMapping(value = "/vehicleInfo/{id}")
public ObjectRestResponse<Vehicle> get(@PathVariable("id") String id);
@RequestMapping(value = "/vehicleInfo/findById", method = RequestMethod.GET)
public RestResponse<Vehicle> findById(@RequestParam("id")String id);
@RequestMapping(value = "/vehicleInfo/getByIds", method = RequestMethod.GET)
public RestResponse< List<Vehicle>> getByIds(@RequestParam("ids") List<String> id);
//修改评分 //修改评分
@RequestMapping(value = "/vehicleModel/app/addScore", method = RequestMethod.GET) @RequestMapping(value = "/vehicleModel/app/addScore", method = RequestMethod.GET)
public RestResponse addScore(@RequestParam(value="id")Integer id, @RequestParam(value="score")Integer score); public RestResponse addScore(@RequestParam(value="id")Integer id, @RequestParam(value="score")Integer score);
......
...@@ -2,6 +2,7 @@ package com.xxfc.platform.vehicle.biz; ...@@ -2,6 +2,7 @@ package com.xxfc.platform.vehicle.biz;
import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.StrUtil;
import com.ace.cache.annotation.Cache;
import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import com.github.wxiaoqi.security.common.biz.BaseBiz; import com.github.wxiaoqi.security.common.biz.BaseBiz;
...@@ -121,6 +122,7 @@ public class VehicleBiz extends BaseBiz<VehicleMapper, Vehicle> { ...@@ -121,6 +122,7 @@ public class VehicleBiz extends BaseBiz<VehicleMapper, Vehicle> {
return new ResponseEntity<byte[]>(FileUtils.readFileToByteArray(file),headers, HttpStatus.CREATED); return new ResponseEntity<byte[]>(FileUtils.readFileToByteArray(file),headers, HttpStatus.CREATED);
} }
@Cache(key = "vehical")
public Vehicle get(String id){ public Vehicle get(String id){
return mapper.selectByPrimaryKey(id); return mapper.selectByPrimaryKey(id);
} }
......
package com.xxfc.platform.vehicle.rest; package com.xxfc.platform.vehicle.rest;
import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.bean.BeanUtil;
import com.ace.cache.annotation.Cache;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONException; import com.alibaba.fastjson.JSONException;
import com.github.wxiaoqi.security.admin.feign.UserFeign; import com.github.wxiaoqi.security.admin.feign.UserFeign;
...@@ -94,6 +95,26 @@ public class VehicleController extends BaseController<VehicleBiz> { ...@@ -94,6 +95,26 @@ public class VehicleController extends BaseController<VehicleBiz> {
return baseBiz.discard(idList); return baseBiz.discard(idList);
} }
@RequestMapping(value = "/findById", method = RequestMethod.GET)
public RestResponse<Vehicle> findById(String id) {
Vehicle vehicle = baseBiz.get(id);
return RestResponse.data(vehicle);
}
@RequestMapping(value = "/vehicleInfo/getByIds", method = RequestMethod.GET)
public RestResponse< List<Vehicle>> getByIds(@RequestParam("ids") List<String> ids){
if(ids == null) {
return RestResponse.codeAndMessage(500, "参数为空!");
}
List<Vehicle> vehicles = new ArrayList<>();
for(String id : ids) {
log.info("查询车辆信息Id:{}",id);
Vehicle vehicle = baseBiz.get(id);
vehicles.add(vehicle);
}
return RestResponse.suc(vehicles);
}
@RequestMapping(value = "/page", method = RequestMethod.GET) @RequestMapping(value = "/page", method = RequestMethod.GET)
public RestResponse<PageDataVO<QueryVehicleVo>> getByPage(@RequestParam String vehiclePageQueryVoJson) throws Exception { public RestResponse<PageDataVO<QueryVehicleVo>> getByPage(@RequestParam String vehiclePageQueryVoJson) throws Exception {
VehiclePageQueryVo vehiclePageQueryVo = null; VehiclePageQueryVo vehiclePageQueryVo = null;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment