Commit 1c047011 authored by 周健威's avatar 周健威

核销相关

parent ae9c84d9
...@@ -43,4 +43,5 @@ public class CommonBaseController { ...@@ -43,4 +43,5 @@ public class CommonBaseController {
return null; return null;
} }
} }
} }
...@@ -43,6 +43,10 @@ public interface UserFeign { ...@@ -43,6 +43,10 @@ public interface UserFeign {
@RequestMapping(value = "/public/v2/userinfo-by-appUserId") @RequestMapping(value = "/public/v2/userinfo-by-appUserId")
ObjectRestResponse<UserDTO> userinfoByAppUserIdV2(@RequestParam("appUserId") Integer appUserId); ObjectRestResponse<UserDTO> userinfoByAppUserIdV2(@RequestParam("appUserId") Integer appUserId);
@RequestMapping(value = "/public/business/userinfo-by-mobilePhone", method = RequestMethod.GET)
@ResponseBody
public ObjectRestResponse<UserDTO> businessUserinfoByMobilePhone(@RequestParam("mobilePhone") String mobilePhone);
@RequestMapping(value = "/public/userinfo-by-uid") @RequestMapping(value = "/public/userinfo-by-uid")
public ObjectRestResponse<UserDTO> userinfoByUid(@RequestParam("uid") Integer uid); public ObjectRestResponse<UserDTO> userinfoByUid(@RequestParam("uid") Integer uid);
...@@ -63,6 +67,14 @@ public interface UserFeign { ...@@ -63,6 +67,14 @@ public interface UserFeign {
@RequestMapping(value = "/public/app/userinfo-by-id") @RequestMapping(value = "/public/app/userinfo-by-id")
public ObjectRestResponse<AppUserDTO> userDetailById(@RequestParam("id") Integer id); public ObjectRestResponse<AppUserDTO> userDetailById(@RequestParam("id") Integer id);
/**
* username获取用户信息
* @param name
* @return
*/
@RequestMapping(value = "/public/app/business/userinfo-by-username")
public ObjectRestResponse<AppUserDTO> userDetailByUsernameBusiness(@RequestParam("name") String name);
@GetMapping("/app/user/app/unauth/getUserIdByUsername") @GetMapping("/app/user/app/unauth/getUserIdByUsername")
public List<Integer> getUserIdByUsername(@RequestParam(value="keywords")String keywords); public List<Integer> getUserIdByUsername(@RequestParam(value="keywords")String keywords);
......
package com.github.wxiaoqi.security.admin.feign.rest; package com.github.wxiaoqi.security.admin.feign.rest;
import cn.hutool.core.util.StrUtil;
import com.github.wxiaoqi.security.admin.feign.UserFeign; import com.github.wxiaoqi.security.admin.feign.UserFeign;
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;
...@@ -109,4 +110,19 @@ public interface UserRestInterface { ...@@ -109,4 +110,19 @@ public interface UserRestInterface {
return null; return null;
} }
default List<Integer> getBusinessUserCompanyIds(){
//Integer currentUserIdInt = getCurrentUserIdInt();
String currentUserName = BaseContextHandler.getUsername();
if (StrUtil.isNotBlank(currentUserName)){
ObjectRestResponse<UserDTO> restResponse = getUserFeign().businessUserinfoByMobilePhone(currentUserName);
if (restResponse.getData() != null){
UserDTO userDTO =restResponse.getData();
if (userDTO != null){
return userDTO.getCompanyIds();
}
}
}
return null;
}
} }
...@@ -64,7 +64,8 @@ public class WebConfiguration implements WebMvcConfigurer { ...@@ -64,7 +64,8 @@ public class WebConfiguration implements WebMvcConfigurer {
"/api/permissions", "/api/permissions",
"/api/user/un/**", "/api/user/un/**",
"/app/**", "/app/**",
"/backstage/**", "/backstage/**"
// ,"/chw/**"
// "/api/app/**" // "/api/app/**"
}; };
Collections.addAll(list, urls); Collections.addAll(list, urls);
......
...@@ -25,6 +25,9 @@ import java.util.Arrays; ...@@ -25,6 +25,9 @@ import java.util.Arrays;
import java.util.List; import java.util.List;
import java.util.stream.Collectors; import java.util.stream.Collectors;
import static com.github.wxiaoqi.security.common.constant.CommonConstants.SYS_FALSE;
import static com.github.wxiaoqi.security.common.constant.CommonConstants.SYS_TRUE;
/** /**
* ${DESCRIPTION} * ${DESCRIPTION}
* *
...@@ -105,10 +108,36 @@ public class PublicController { ...@@ -105,10 +108,36 @@ public class PublicController {
} }
@RequestMapping(value = "v2/userinfo-by-appUserId", method = RequestMethod.GET) // @RequestMapping(value = "v2/userinfo-by-appUserId", method = RequestMethod.GET)
public @ResponseBody // public @ResponseBody
ObjectRestResponse userinfoByAppUserIdV2(Integer appUserId){ // ObjectRestResponse userinfoByAppUserIdV2(Integer appUserId){
User user = userBiz.getUserByAppUserId(appUserId); // User user = userBiz.getUserByAppUserId(appUserId);
// if (user == null) {
// return ObjectRestResponse.createFailedResult(ResultCode.USER_NOTEXIST_CODE, ResultCode.getMsg(ResultCode.USER_NOTEXIST_CODE));
// }
// if (user.getDataCorporation() != null){
// com.github.wxiaoqi.security.admin.dto.CompanySearchDTO companySearchDTO =new com.github.wxiaoqi.security.admin.dto.CompanySearchDTO();
// companySearchDTO.setDataCorporationIds(Arrays.asList(user.getDataCorporation().split(",")).parallelStream().map(s -> Integer.valueOf(s)).collect(Collectors.toList()));
// List<com.github.wxiaoqi.security.admin.vo.CompanySearchVO> companySearchVOList=branchCompanyBiz.getList(companySearchDTO);
// if(companySearchVOList != null && companySearchVOList.size() > 0){
// List<Integer> companyIds = companySearchVOList.stream().map(com.github.wxiaoqi.security.admin.vo.CompanySearchVO::getId).distinct().collect(Collectors.toList());
// user.setCompanyIds(companyIds);
// }
// }else if (user.getDataCompany() != null ){
// List<Integer> companyIds = Arrays.asList(user.getDataCompany().split(",")).parallelStream().map(s -> Integer.valueOf(s)).collect(Collectors.toList());
// user.setCompanyIds(companyIds);
// }
// return new ObjectRestResponse<User>().rel(true).data(user);
// }
@RequestMapping(value = "business/userinfo-by-mobilePhone", method = RequestMethod.GET)
@ResponseBody
public ObjectRestResponse userinfoByAppUserIdV2(String mobilePhone){
User user = userBiz.selectOne(new User(){{
setMobilePhone(mobilePhone);
setIsDel(SYS_FALSE);
setStatus(SYS_TRUE);
}});
if (user == null) { if (user == null) {
return ObjectRestResponse.createFailedResult(ResultCode.USER_NOTEXIST_CODE, ResultCode.getMsg(ResultCode.USER_NOTEXIST_CODE)); return ObjectRestResponse.createFailedResult(ResultCode.USER_NOTEXIST_CODE, ResultCode.getMsg(ResultCode.USER_NOTEXIST_CODE));
} }
...@@ -162,6 +191,25 @@ public class PublicController { ...@@ -162,6 +191,25 @@ public class PublicController {
return ObjectRestResponse.succ(getAppUserInfoById(appUserLogin.getId())); return ObjectRestResponse.succ(getAppUserInfoById(appUserLogin.getId()));
} }
@RequestMapping(value = "/app/business/userinfo-by-username", method = RequestMethod.GET)
public @ResponseBody
ObjectRestResponse<AppUserDTO> userDetailByUsernameBusiness(String name) throws Exception {
AppUserLogin appUserLogin;
if (StrUtil.isBlank(name)) {
return ObjectRestResponse.paramIsEmpty();
}else {
appUserLogin = appUserLoginBiz.selectOne(new AppUserLogin(){{
setUsername(name);
setIsdel(SYS_FALSE);
setStatus(SYS_TRUE);
}});
if(null == appUserLogin) {
return ObjectRestResponse.createFailedResult(ResultCode.USER_NOTEXIST_CODE, ResultCode.getMsg(ResultCode.USER_NOTEXIST_CODE));
}
}
return ObjectRestResponse.succ(getAppUserInfoById(appUserLogin.getId()));
}
private AppUserDTO getAppUserInfoById(Integer userid) throws IllegalAccessException, InvocationTargetException { private AppUserDTO getAppUserInfoById(Integer userid) throws IllegalAccessException, InvocationTargetException {
AppUserDTO userDTO=new AppUserDTO(); AppUserDTO userDTO=new AppUserDTO();
//获取用户基础信息 //获取用户基础信息
......
...@@ -9,6 +9,7 @@ import com.alibaba.fastjson.JSONObject; ...@@ -9,6 +9,7 @@ import com.alibaba.fastjson.JSONObject;
import com.github.wxiaoqi.security.admin.feign.UserFeign; import com.github.wxiaoqi.security.admin.feign.UserFeign;
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;
import com.github.wxiaoqi.security.admin.feign.rest.UserRestInterface;
import com.github.wxiaoqi.security.common.biz.BaseBiz; import com.github.wxiaoqi.security.common.biz.BaseBiz;
import com.github.wxiaoqi.security.common.exception.BaseException; import com.github.wxiaoqi.security.common.exception.BaseException;
import com.github.wxiaoqi.security.common.msg.ObjectRestResponse; import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
...@@ -59,7 +60,7 @@ import static com.xxfc.platform.universal.constant.DictionaryKey.APP_ORDER; ...@@ -59,7 +60,7 @@ import static com.xxfc.platform.universal.constant.DictionaryKey.APP_ORDER;
@Service @Service
@Slf4j @Slf4j
public class OrderVehicleCrosstownBiz extends BaseBiz<OrderVehicaleCrosstownMapper, OrderVehicleCrosstown> { public class OrderVehicleCrosstownBiz extends BaseBiz<OrderVehicaleCrosstownMapper, OrderVehicleCrosstown> implements UserRestInterface {
@Autowired @Autowired
OrderVehicleCrosstownBiz orderVehicleCrosstownBiz; OrderVehicleCrosstownBiz orderVehicleCrosstownBiz;
...@@ -87,6 +88,10 @@ public class OrderVehicleCrosstownBiz extends BaseBiz<OrderVehicaleCrosstownMapp ...@@ -87,6 +88,10 @@ public class OrderVehicleCrosstownBiz extends BaseBiz<OrderVehicaleCrosstownMapp
@Autowired @Autowired
OrderAccountBiz orderAccountBiz; OrderAccountBiz orderAccountBiz;
@Override
public UserFeign getUserFeign() {
return userFeign;
}
public OrderVehicleCrosstown get(Integer id) { public OrderVehicleCrosstown get(Integer id) {
return selectById(id); return selectById(id);
...@@ -222,7 +227,13 @@ public class OrderVehicleCrosstownBiz extends BaseBiz<OrderVehicaleCrosstownMapp ...@@ -222,7 +227,13 @@ public class OrderVehicleCrosstownBiz extends BaseBiz<OrderVehicaleCrosstownMapp
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public ObjectRestResponse<OrderVehicleCrosstownDto> add(OrderVehicleCrosstownDto orderVehicleCrosstownDto) { public ObjectRestResponse<OrderVehicleCrosstownDto> add(OrderVehicleCrosstownDto orderVehicleCrosstownDto) {
log.info("交还车参数:orderVehicleCrosstown = {}", orderVehicleCrosstownDto); log.info("交还车参数:orderVehicleCrosstown = {}", orderVehicleCrosstownDto);
//获取app用户信息 根据用户名(手机号)定位后台商家用户
UserDTO userDTO = userInfoBiz.getAdminUserInfo(); UserDTO userDTO = userInfoBiz.getAdminUserInfo();
if(null == userDTO && null != getAppUser()) {
userDTO = userFeign.businessUserinfoByMobilePhone(getAppUser().getUsername()).getData();
}
if (userDTO == null) { if (userDTO == null) {
return ObjectRestResponse.createFailedResult(ResultCode.RSTOKEN_EXPIRED_CODE, "token is null or invalid"); return ObjectRestResponse.createFailedResult(ResultCode.RSTOKEN_EXPIRED_CODE, "token is null or invalid");
} }
......
...@@ -62,6 +62,7 @@ public class WebConfiguration implements WebMvcConfigurer { ...@@ -62,6 +62,7 @@ public class WebConfiguration implements WebMvcConfigurer {
"/orderVehicle/**", "/orderVehicle/**",
"/shuntApply/**", "/shuntApply/**",
"/admin/**", "/admin/**",
"/chw/**",
}; };
Collections.addAll(list, urls); Collections.addAll(list, urls);
return list; return list;
......
package com.xxfc.platform.order.rest;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.json.JSONUtil;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.github.wxiaoqi.security.admin.entity.AppUserLogin;
import com.github.wxiaoqi.security.admin.feign.UserFeign;
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.rest.UserRestInterface;
import com.github.wxiaoqi.security.admin.vo.AppUserVo;
import com.github.wxiaoqi.security.auth.client.annotation.IgnoreClientToken;
import com.github.wxiaoqi.security.common.context.BaseContextHandler;
import com.github.wxiaoqi.security.common.exception.BaseException;
import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
import com.github.wxiaoqi.security.common.rest.CommonBaseController;
import com.github.wxiaoqi.security.common.util.AssertUtils;
import com.github.wxiaoqi.security.common.util.Query;
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.xxfc.platform.activity.entity.Coupon;
import com.xxfc.platform.activity.feign.ActivityFeign;
import com.xxfc.platform.order.biz.*;
import com.xxfc.platform.order.biz.inner.OrderCalculateBiz;
import com.xxfc.platform.order.biz.inner.OrderDelayBiz;
import com.xxfc.platform.order.contant.enumerate.ItemTypeEnum;
import com.xxfc.platform.order.contant.enumerate.OrderTypeEnum;
import com.xxfc.platform.order.entity.OrderItem;
import com.xxfc.platform.order.entity.OrderRentVehicleDetail;
import com.xxfc.platform.order.pojo.OrderAccompanyDTO;
import com.xxfc.platform.order.pojo.order.*;
import com.xxfc.platform.order.pojo.price.RentVehiclePriceVO;
import com.xxfc.platform.order.service.OrderRentVehicleService;
import com.xxfc.platform.tour.entity.TourUser;
import com.xxfc.platform.tour.feign.TourFeign;
import com.xxfc.platform.universal.feign.ThirdFeign;
import com.xxfc.platform.vehicle.common.RestResponse;
import com.xxfc.platform.vehicle.constant.VehicleBookRecordStatus;
import com.xxfc.platform.vehicle.entity.BranchCompany;
import com.xxfc.platform.vehicle.entity.Vehicle;
import com.xxfc.platform.vehicle.entity.VehicleUserLicense;
import com.xxfc.platform.vehicle.feign.VehicleFeign;
import com.xxfc.platform.vehicle.pojo.BookVehicleVO;
import com.xxfc.platform.vehicle.pojo.CompanyDetail;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import jodd.util.StringUtil;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.mockito.internal.util.collections.Sets;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import java.io.IOException;
import java.time.Instant;
import java.time.LocalDateTime;
import java.time.ZoneOffset;
import java.util.*;
import java.util.stream.Collectors;
import static com.github.wxiaoqi.security.common.constant.CommonConstants.DATE_TIME_LINE_FORMATTER;
import static com.github.wxiaoqi.security.common.constant.CommonConstants.YMR_SLASH_FORMATTER;
@Controller
@RequestMapping("/chw/appOrder")
@Api(value = "订单后台相关", tags = {"订单后台相关"})
@Slf4j
public class AppOrderController extends CommonBaseController implements UserRestInterface {
@Autowired
UserFeign userFeign;
@Autowired
VehicleFeign vehicleFeign;
@Autowired
BaseOrderBiz baseOrderBiz;
@Autowired
OrderVehicleCrosstownBiz orderVehicleCrosstownBiz;
@Override
public UserFeign getUserFeign() {
return userFeign;
}
@RequestMapping(value = "/getVehicleList", method = RequestMethod.GET)
@ResponseBody
@ApiOperation(value = "交还车租车订单列表")
public ObjectRestResponse<List<OrderPageVO>> getVehicleList(BaseOrderController.QueryOrderList dto) {
log.info("交还车租车订单列表请求参数:dto = {}", dto);
if (dto.getStartTime() != null) {
if (dto.getEndTime() == null) {
dto.setEndTime(new Date().getTime());
}
}
List<Integer> userIds = new ArrayList<>();
if (StringUtils.isNotBlank(dto.getKeywords())) {
List<Integer> list = userFeign.getUserIdByUsername(dto.getKeywords());
if (list != null) {
userIds.addAll(list);
}
if (userIds.size() <= 0) {
return ObjectRestResponse.succ(new PageDataVO<>());
}
}
//获取app用户信息 根据用户名(手机号)定位后台商家用户
// UserDTO userDTO = userFeign.businessUserinfoByMobilePhone(currentAppUser.getUsername()).getData();
// getBusinessUserCompanyIds();
//
//// UserDTO userDTO = getAdminUserInfo();
// if (userDTO == null) {
// return ObjectRestResponse.succ(new PageDataVO<>());
// }
//List<BranchCompany> branchCompanies = vehicleFeign.companyAll(userDTO.getDataAll(), userDTO.getDataCompany(), userDTO.getDataZone());
//List<Integer> companyIds = branchCompanies.stream().map(BranchCompany::getId).collect(Collectors.toList());
List<Integer> companyIds = getBusinessUserCompanyIds();
if(null == companyIds) {
return ObjectRestResponse.succ(new PageDataVO<>());
}
if (dto.getStartCompanyId() != null) {
if (companyIds.size() > 0) {
if (companyIds.contains(dto.getStartCompanyId())) {
companyIds.clear();
companyIds.add(dto.getStartCompanyId());
} else {
return ObjectRestResponse.succ();
}
} else {
companyIds.add(dto.getStartCompanyId());
}
}
dto.setCompanyIds(companyIds);
Query query = new Query(dto);
PageDataVO<OrderPageVO> pageDataVO = PageDataVO.pageInfo(query, () -> baseOrderBiz.getRentVehicle(query.getSuper()));
for (OrderPageVO orderPageVO : pageDataVO.getData()) {
if (orderPageVO.getOrderRentVehicleDetail() != null && orderPageVO.getOrderRentVehicleDetail().getVehicleId() != null) {
ObjectRestResponse<Vehicle> restResponse = vehicleFeign.get(orderPageVO.getOrderRentVehicleDetail().getVehicleId());
log.info("获取车辆信息返回消息:{}", restResponse.getMessage());
if (restResponse.getData() != null) {
orderPageVO.setVehicalNumberPlat(restResponse.getData().getNumberPlate());
orderPageVO.setCode(restResponse.getData().getCode());
}
}
if (orderPageVO.getUserId() != null) {
AppUserDTO appUserDTO = userFeign.userDetailById(orderPageVO.getUserId()).getData();
if (appUserDTO != null) {
orderPageVO.setUsername(appUserDTO.getUsername());
orderPageVO.setRealName(appUserDTO.getRealname());
}
}
}
return new ObjectRestResponse<>().data(pageDataVO);
}
@GetMapping(value = "/vehicleCrosstown/getByOrderId")
@ApiOperation(value = "根据订单Id获取所有记录信息")
public ObjectRestResponse<List<OrderVehicleCrosstownDto>> getByOrderId(OrderVehicleCrosstownDto orderVehicleCrosstownDto) {
UserDTO userDTO = getAdminUserInfo();
AppUserDTO appUserDTO = getAppUser();
if (userDTO == null && appUserDTO == null) {
return ObjectRestResponse.createFailedResult(508, "token is null or invalid");
}
if (orderVehicleCrosstownDto == null) {
return ObjectRestResponse.createFailedResult(500, "参数orderId为空");
}
return ObjectRestResponse.succ(orderVehicleCrosstownBiz.selectByOrderId(orderVehicleCrosstownDto));
}
}
...@@ -387,6 +387,9 @@ public class BackStageOrderController extends CommonBaseController implements Us ...@@ -387,6 +387,9 @@ public class BackStageOrderController extends CommonBaseController implements Us
@ResponseBody @ResponseBody
public ObjectRestResponse<OrderPageVO> getOrderDetail(String orderNo, Boolean flag) { public ObjectRestResponse<OrderPageVO> getOrderDetail(String orderNo, Boolean flag) {
UserDTO userDTO = getAdminUserInfo(); UserDTO userDTO = getAdminUserInfo();
if(null == userDTO && null != getAppUser()) {
userDTO = userFeign.businessUserinfoByMobilePhone(getAppUser().getUsername()).getData();
}
if (userDTO == null) { if (userDTO == null) {
return ObjectRestResponse.succ(new PageDataVO<>()); return ObjectRestResponse.succ(new PageDataVO<>());
} }
......
...@@ -5,6 +5,7 @@ import com.github.pagehelper.PageHelper; ...@@ -5,6 +5,7 @@ import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
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.admin.feign.rest.UserRestInterface;
import com.github.wxiaoqi.security.auth.client.config.UserAuthConfig; import com.github.wxiaoqi.security.auth.client.config.UserAuthConfig;
import com.github.wxiaoqi.security.common.biz.BaseBiz; import com.github.wxiaoqi.security.common.biz.BaseBiz;
import com.github.wxiaoqi.security.common.msg.ObjectRestResponse; import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
...@@ -29,7 +30,7 @@ import java.util.List; ...@@ -29,7 +30,7 @@ import java.util.List;
*/ */
@Service @Service
@Slf4j @Slf4j
public class VehicleDispatchInfoBiz extends BaseBiz<VehicleDispatchInfoMapper,VehicleDispatchInfo> { public class VehicleDispatchInfoBiz extends BaseBiz<VehicleDispatchInfoMapper,VehicleDispatchInfo> implements UserRestInterface {
@Autowired @Autowired
UserFeign userFeign; UserFeign userFeign;
...@@ -40,6 +41,10 @@ public class VehicleDispatchInfoBiz extends BaseBiz<VehicleDispatchInfoMapper,Ve ...@@ -40,6 +41,10 @@ public class VehicleDispatchInfoBiz extends BaseBiz<VehicleDispatchInfoMapper,Ve
@Autowired @Autowired
VehicleBiz vehicleBiz; VehicleBiz vehicleBiz;
@Override
public UserFeign getUserFeign() {
return userFeign;
}
//提交调度申请表单 //提交调度申请表单
public ObjectRestResponse addDisspatchInfo(VehicleDispatchInfo vehicleDispatchInfo){ public ObjectRestResponse addDisspatchInfo(VehicleDispatchInfo vehicleDispatchInfo){
...@@ -52,7 +57,11 @@ public class VehicleDispatchInfoBiz extends BaseBiz<VehicleDispatchInfoMapper,Ve ...@@ -52,7 +57,11 @@ public class VehicleDispatchInfoBiz extends BaseBiz<VehicleDispatchInfoMapper,Ve
//获取申请列表 //获取申请列表
public ObjectRestResponse getInfoList(VehicleDispatchInfoDto dispatchInfoDto, HttpServletRequest request){ public ObjectRestResponse getInfoList(VehicleDispatchInfoDto dispatchInfoDto, HttpServletRequest request){
UserDTO userDTO = userFeign.userinfoByToken(userAuthConfig.getToken(request)).getData(); // UserDTO userDTO = userFeign.userinfoByToken(userAuthConfig.getToken(request)).getData();
UserDTO userDTO = getAdminUserInfo();
if(null == userDTO && null != getAppUser()) {
userDTO = userFeign.businessUserinfoByMobilePhone(getAppUser().getUsername()).getData();
}
List<VehicleDispatchInfoVo> list=new ArrayList<>(); List<VehicleDispatchInfoVo> list=new ArrayList<>();
Integer pageSize=dispatchInfoDto.getPage()==null?1:dispatchInfoDto.getPage(); Integer pageSize=dispatchInfoDto.getPage()==null?1:dispatchInfoDto.getPage();
Integer pageNo=dispatchInfoDto.getPage()==null?10:dispatchInfoDto.getLimit(); Integer pageNo=dispatchInfoDto.getPage()==null?10:dispatchInfoDto.getLimit();
...@@ -65,21 +74,21 @@ public class VehicleDispatchInfoBiz extends BaseBiz<VehicleDispatchInfoMapper,Ve ...@@ -65,21 +74,21 @@ public class VehicleDispatchInfoBiz extends BaseBiz<VehicleDispatchInfoMapper,Ve
}else { }else {
companyList = vehicleBiz.dataCompany(userDTO.getDataZone(), userDTO.getDataCompany()); companyList = vehicleBiz.dataCompany(userDTO.getDataZone(), userDTO.getDataCompany());
} }
dispatchInfoDto.setCompanyList(companyList); dispatchInfoDto.setCompanyList(companyList);
list=mapper.getInfoList(dispatchInfoDto); list=mapper.getInfoList(dispatchInfoDto);
if (list.size()>0){ if (list.size()>0){
for (VehicleDispatchInfoVo vehicleDispatchInfoVo:list){ for (VehicleDispatchInfoVo vehicleDispatchInfoVo:list){
String recordIds=vehicleDispatchInfoVo.getRecordIds(); String recordIds=vehicleDispatchInfoVo.getRecordIds();
if (StringUtils.isBlank(recordIds)){ if (StringUtils.isBlank(recordIds)){
continue; continue;
} }
String[] ids=recordIds.split(","); String[] ids=recordIds.split(",");
List<VehiclDispatchRecordVo> recordVos= mapper.getRecordList(Arrays.asList(ids)); List<VehiclDispatchRecordVo> recordVos= mapper.getRecordList(Arrays.asList(ids));
if (recordVos.size()>0) { if (recordVos.size()>0) {
vehicleDispatchInfoVo.setDispatchRecords(recordVos); vehicleDispatchInfoVo.setDispatchRecords(recordVos);
} }
} }
} }
} }
PageHelper.startPage(pageNo,pageSize); PageHelper.startPage(pageNo,pageSize);
PageInfo<VehicleDispatchInfoVo> pageInfo = new PageInfo<>(list); PageInfo<VehicleDispatchInfoVo> pageInfo = new PageInfo<>(list);
......
...@@ -28,7 +28,7 @@ public class AppVehicleApplyController extends BaseController<VehicleApplyBiz> { ...@@ -28,7 +28,7 @@ public class AppVehicleApplyController extends BaseController<VehicleApplyBiz> {
@ApiModelProperty("商家入驻申请") @ApiModelProperty("商家入驻申请")
public ObjectRestResponse apply(@RequestBody Vehicle vehicle) { public ObjectRestResponse apply(@RequestBody Vehicle vehicle) {
if (vehicle.getSubordinateBranch() == null || vehicle.getSubordinateBranch() == 0){ if (vehicle.getSubordinateBranch() == null || vehicle.getSubordinateBranch() == 0){
List<Integer> companyIds = getCompanyIds(); List<Integer> companyIds = getBusinessUserCompanyIds();
if (companyIds != null && companyIds.size() > 0){ if (companyIds != null && companyIds.size() > 0){
vehicle.setSubordinateBranch(companyIds.get(0)); vehicle.setSubordinateBranch(companyIds.get(0));
} }
...@@ -41,7 +41,7 @@ public class AppVehicleApplyController extends BaseController<VehicleApplyBiz> { ...@@ -41,7 +41,7 @@ public class AppVehicleApplyController extends BaseController<VehicleApplyBiz> {
@GetMapping("apply/selectList") @GetMapping("apply/selectList")
@ApiModelProperty("商品审核列表") @ApiModelProperty("商品审核列表")
public ObjectRestResponse selectList(VehicleApplyFindDTO vehicleApplyFindDTO) { public ObjectRestResponse selectList(VehicleApplyFindDTO vehicleApplyFindDTO) {
List<Integer> companyIds = getCompanyIds(); List<Integer> companyIds = getBusinessUserCompanyIds();
if (companyIds == null && companyIds.size() == 0){ if (companyIds == null && companyIds.size() == 0){
return ObjectRestResponse.succ(); return ObjectRestResponse.succ();
} }
......
...@@ -32,7 +32,7 @@ public class AppVehicleController extends BaseController<VehicleBiz> { ...@@ -32,7 +32,7 @@ public class AppVehicleController extends BaseController<VehicleBiz> {
@ApiModelProperty("商品列表") @ApiModelProperty("商品列表")
public ObjectRestResponse selectList(VehicleFindDTO vehicleFindDTO) { public ObjectRestResponse selectList(VehicleFindDTO vehicleFindDTO) {
if (vehicleFindDTO.getBranchId() == null || vehicleFindDTO.getBranchId() == 0){ if (vehicleFindDTO.getBranchId() == null || vehicleFindDTO.getBranchId() == 0){
List<Integer> companyIds = getCompanyIds(); List<Integer> companyIds = getBusinessUserCompanyIds();
if (companyIds != null && companyIds.size() > 0){ if (companyIds != null && companyIds.size() > 0){
vehicleFindDTO.setBranchId(companyIds.get(0)); vehicleFindDTO.setBranchId(companyIds.get(0));
} }
......
package com.xxfc.platform.vehicle.rest; package com.xxfc.platform.vehicle.rest;
import cn.hutool.core.util.StrUtil;
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.admin.feign.rest.UserRestInterface;
import com.github.wxiaoqi.security.auth.client.config.UserAuthConfig; import com.github.wxiaoqi.security.auth.client.config.UserAuthConfig;
import com.github.wxiaoqi.security.auth.client.jwt.UserAuthUtil; import com.github.wxiaoqi.security.auth.client.jwt.UserAuthUtil;
import com.github.wxiaoqi.security.common.biz.BaseBiz; import com.github.wxiaoqi.security.common.biz.BaseBiz;
...@@ -14,7 +16,7 @@ import org.springframework.beans.factory.annotation.Autowired; ...@@ -14,7 +16,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import java.util.List; import java.util.List;
@Slf4j @Slf4j
public class BaseController<Biz extends BaseBiz> extends CommonBaseController { public class BaseController<Biz extends BaseBiz> extends CommonBaseController implements UserRestInterface {
@Autowired @Autowired
protected Biz baseBiz; protected Biz baseBiz;
...@@ -28,8 +30,12 @@ public class BaseController<Biz extends BaseBiz> extends CommonBaseController { ...@@ -28,8 +30,12 @@ public class BaseController<Biz extends BaseBiz> extends CommonBaseController {
@Autowired @Autowired
UserFeign userFeign; UserFeign userFeign;
@Override
public UserFeign getUserFeign() {
return userFeign;
}
public String getUserName()throws Exception{ return userAuthUtil.getInfoFromToken(userAuthConfig.getToken(request)).getUniqueName(); } public String getUserName()throws Exception{ return userAuthUtil.getInfoFromToken(userAuthConfig.getToken(request)).getUniqueName(); }
public Biz getBaseBiz() { public Biz getBaseBiz() {
return baseBiz; return baseBiz;
...@@ -37,19 +43,4 @@ public class BaseController<Biz extends BaseBiz> extends CommonBaseController { ...@@ -37,19 +43,4 @@ public class BaseController<Biz extends BaseBiz> extends CommonBaseController {
public String getUserId()throws Exception{ return userAuthUtil.getInfoFromToken(userAuthConfig.getToken(request)).getId(); } public String getUserId()throws Exception{ return userAuthUtil.getInfoFromToken(userAuthConfig.getToken(request)).getId(); }
public List<Integer> getCompanyIds(){
Integer currentUserIdInt = getCurrentUserIdInt();
if (currentUserIdInt != null && currentUserIdInt > 0 ){
ObjectRestResponse<UserDTO> restResponse = userFeign.userinfoByAppUserIdV2(currentUserIdInt);
if (restResponse.getData() != null){
UserDTO userDTO =restResponse.getData();
if (userDTO != null){
return userDTO.getCompanyIds();
}
}
}
return null;
}
} }
...@@ -16,12 +16,15 @@ import com.xxfc.platform.vehicle.common.RestResponse; ...@@ -16,12 +16,15 @@ import com.xxfc.platform.vehicle.common.RestResponse;
import com.xxfc.platform.vehicle.constant.ResCode.ResCode; import com.xxfc.platform.vehicle.constant.ResCode.ResCode;
import com.xxfc.platform.vehicle.entity.Area; import com.xxfc.platform.vehicle.entity.Area;
import com.xxfc.platform.vehicle.entity.BranchCompany; import com.xxfc.platform.vehicle.entity.BranchCompany;
import com.xxfc.platform.vehicle.entity.Vehicle;
import com.xxfc.platform.vehicle.pojo.*; import com.xxfc.platform.vehicle.pojo.*;
import com.xxfc.platform.vehicle.pojo.dto.BranchCompanyAreaDTO; import com.xxfc.platform.vehicle.pojo.dto.BranchCompanyAreaDTO;
import com.xxfc.platform.vehicle.pojo.dto.BranchCompanyFindDTO; import com.xxfc.platform.vehicle.pojo.dto.BranchCompanyFindDTO;
import com.xxfc.platform.vehicle.pojo.dto.VehicleFindAppDTO;
import com.xxfc.platform.vehicle.pojo.vo.BranComanyLeaderVo; import com.xxfc.platform.vehicle.pojo.vo.BranComanyLeaderVo;
import com.xxfc.platform.vehicle.pojo.vo.BranchCompanyListVO; import com.xxfc.platform.vehicle.pojo.vo.BranchCompanyListVO;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiModelProperty;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
...@@ -34,6 +37,8 @@ import javax.servlet.http.HttpServletRequest; ...@@ -34,6 +37,8 @@ import javax.servlet.http.HttpServletRequest;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import static com.github.wxiaoqi.security.common.constant.CommonConstants.SYS_TRUE;
@RestController @RestController
@RequestMapping("/branchCompany") @RequestMapping("/branchCompany")
@Slf4j @Slf4j
......
...@@ -706,6 +706,15 @@ public class VehicleController extends BaseController<VehicleBiz> implements Use ...@@ -706,6 +706,15 @@ public class VehicleController extends BaseController<VehicleBiz> implements Use
return ObjectRestResponse.succ(baseBiz.appSelectList(vehicleFindAppDTO)); return ObjectRestResponse.succ(baseBiz.appSelectList(vehicleFindAppDTO));
} }
@GetMapping("app/unauth/shop/headSelectList")
@ApiModelProperty("店铺商品列表(头部输入框)")
@IgnoreUserToken
public ObjectRestResponse<PageDataVO<VehicleVO>> shopHeadSelectList(VehicleFindAppDTO vehicleFindAppDTO) {
vehicleFindAppDTO.setState(Vehicle.STATE_UP);
vehicleFindAppDTO.setIsMinPrice(SYS_TRUE);
return ObjectRestResponse.succ(baseBiz.appSelectList(vehicleFindAppDTO));
}
@Data @Data
static public class VehicleVO extends Vehicle { static public class VehicleVO extends Vehicle {
private VehicleModel vehicleModel; private VehicleModel vehicleModel;
......
...@@ -29,7 +29,7 @@ import java.util.stream.Collectors; ...@@ -29,7 +29,7 @@ import java.util.stream.Collectors;
@RestController @RestController
@RequestMapping("backstage/vehicle") @RequestMapping("backstage/vehicle")
@Api(tags = {"商品申请"}) @Api(tags = {"商品申请"})
public class AdminVehicleController extends BaseController<VehicleBiz> implements UserRestInterface { public class AdminVehicleController extends BaseController<VehicleBiz>{
......
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