Commit 4b00bea3 authored by libin's avatar libin

Merge remote-tracking branch 'origin/dev' into dev

parents 92c04da1 a2f72f21
...@@ -10,7 +10,7 @@ ace-modules/ace-tool/src/main/resources/application-dev.yml ...@@ -10,7 +10,7 @@ ace-modules/ace-tool/src/main/resources/application-dev.yml
**/src/test **/src/test
**/logs **/logs
xx-order/xx-order-server/logs/** xx-order/xx-order-server/logs/**
xx-order/xx-order-server/src/test/java/** xx-order/xx-order-server/src/test/**
*.log *.log
logs/** logs/**
/src/main/test/** /src/main/test/**
......
...@@ -40,6 +40,15 @@ public class GlobalExceptionHandler extends ResponseEntityExceptionHandler { ...@@ -40,6 +40,15 @@ public class GlobalExceptionHandler extends ResponseEntityExceptionHandler {
private Logger logger = LoggerFactory.getLogger(GlobalExceptionHandler.class); private Logger logger = LoggerFactory.getLogger(GlobalExceptionHandler.class);
@Value("${spring.application.name}") @Value("${spring.application.name}")
private String applicationName; private String applicationName;
@Value("${email.log.account}")
private String emailLogAccount;
@Value("${email.log.title}")
private String emailLogTitle;
@Value("${email.log.host}")
private String emailLogHost;
/** /**
* 在controller里面内容执行之前,校验一些参数不匹配啊,Get post方法不对啊之类的 * 在controller里面内容执行之前,校验一些参数不匹配啊,Get post方法不对啊之类的
*/ */
...@@ -77,15 +86,6 @@ public class GlobalExceptionHandler extends ResponseEntityExceptionHandler { ...@@ -77,15 +86,6 @@ public class GlobalExceptionHandler extends ResponseEntityExceptionHandler {
if(0 == ex.getStatus()) { if(0 == ex.getStatus()) {
response.setStatus(500); response.setStatus(500);
} }
Map<String, String> map = new HashMap<>();
map.put("toUser", "jiaoruizhen@126.com");
map.put("subject", "服务器异常");
map.put("content", ex.toString() + ":" +ex.getMessage());
try {
HttpUtils.doPost("http://10.5.52.3:8765","/api/universal/mail/app/unauth/send", map);
} catch (Exception e) {
logger.error(e.getMessage());
}
return new BaseResponse(ex.getStatus(), ex.getMessage()); return new BaseResponse(ex.getStatus(), ex.getMessage());
} }
...@@ -99,22 +99,22 @@ public class GlobalExceptionHandler extends ResponseEntityExceptionHandler { ...@@ -99,22 +99,22 @@ public class GlobalExceptionHandler extends ResponseEntityExceptionHandler {
cause.printStackTrace(new PrintWriter(stringWriter)); cause.printStackTrace(new PrintWriter(stringWriter));
logger.error(cause.getMessage(), ex); logger.error(cause.getMessage(), ex);
Map<String, String> map = new HashMap<>(); Map<String, String> map = new HashMap<>();
map.put("toUser", "jiaoruizhen@126.com"); map.put("toUser", emailLogAccount);
map.put("subject", "服务器异常"); map.put("subject", emailLogTitle);
map.put("content", initCommonLogPrePart()+ ":" +stringWriter.toString()); map.put("content", initCommonLogPrePart()+ ":" +stringWriter.toString());
try { try {
HttpUtils.doPost("http://10.5.52.3:8765","/api/universal/mail/app/unauth/send", map); HttpUtils.doPost(emailLogHost,"/api/universal/mail/app/unauth/send", map);
} catch (Exception e) { } catch (Exception e) {
logger.error(e.getMessage()); logger.error(e.getMessage());
} }
return new BaseResponse(5000, "Server exception: " + ex.getMessage()); return new BaseResponse(5000, "Server exception: " + ex.getMessage());
} }
Map<String, String> map = new HashMap<>(); Map<String, String> map = new HashMap<>();
map.put("toUser", "jiaoruizhen@126.com"); map.put("toUser", emailLogAccount);
map.put("subject", "服务器异常"); map.put("subject", emailLogTitle);
map.put("content", initCommonLogPrePart()+ ":" + ex.toString() + ":" + ex.getMessage()); map.put("content", initCommonLogPrePart()+ ":" + ex.toString() + ":" + ex.getMessage());
try { try {
HttpUtils.doPost("http://10.5.52.3:8765","/api/universal/mail/app/unauth/send", map); HttpUtils.doPost(emailLogHost,"/api/universal/mail/app/unauth/send", map);
} catch (Exception e) { } catch (Exception e) {
logger.error(e.getMessage()); logger.error(e.getMessage());
} }
......
...@@ -26,6 +26,15 @@ public class PlatformExceptionHandler { ...@@ -26,6 +26,15 @@ public class PlatformExceptionHandler {
@Value("${spring.application.name}") @Value("${spring.application.name}")
private String applicationName; private String applicationName;
@Value("${email.log.account}")
private String emailLogAccount;
@Value("${email.log.title}")
private String emailLogTitle;
@Value("${email.log.host}")
private String emailLogHost;
@ExceptionHandler(value = {BaseException.class}) @ExceptionHandler(value = {BaseException.class})
public BaseResponse baseExceptionHandler(Exception e) { public BaseResponse baseExceptionHandler(Exception e) {
if (e instanceof BaseException){ if (e instanceof BaseException){
...@@ -45,11 +54,11 @@ public class PlatformExceptionHandler { ...@@ -45,11 +54,11 @@ public class PlatformExceptionHandler {
cause.printStackTrace(new PrintWriter(stringWriter)); cause.printStackTrace(new PrintWriter(stringWriter));
log.error(cause.getMessage(), e); log.error(cause.getMessage(), e);
Map<String, String> map = new HashMap<>(); Map<String, String> map = new HashMap<>();
map.put("toUser", "jiaoruizhen@126.com"); map.put("toUser", emailLogAccount);
map.put("subject", "服务器异常"); map.put("subject", emailLogTitle);
map.put("content", initCommonLogPrePart()+ ":" +stringWriter.toString()); map.put("content", initCommonLogPrePart()+ ":" +stringWriter.toString());
try { try {
HttpUtils.doPost("http://10.5.52.3:8765","/api/universal/mail/app/unauth/send", map); HttpUtils.doPost(emailLogHost,"/api/universal/mail/app/unauth/send", map);
} catch (Exception ex) { } catch (Exception ex) {
log.error(ex.getMessage()); log.error(ex.getMessage());
} }
...@@ -57,11 +66,11 @@ public class PlatformExceptionHandler { ...@@ -57,11 +66,11 @@ public class PlatformExceptionHandler {
} }
log.error("Server exception: ", e); log.error("Server exception: ", e);
Map<String, String> map = new HashMap<>(); Map<String, String> map = new HashMap<>();
map.put("toUser", "jiaoruizhen@126.com"); map.put("toUser", emailLogAccount);
map.put("subject", "服务器异常"); map.put("subject", emailLogTitle);
map.put("content", initCommonLogPrePart()+ ":" + e.toString() + ":" + e.getMessage()); map.put("content", initCommonLogPrePart()+ ":" + e.toString() + ":" + e.getMessage());
try { try {
HttpUtils.doPost("http://10.5.52.3:8765","/api/universal/mail/app/unauth/send", map); HttpUtils.doPost(emailLogHost,"/api/universal/mail/app/unauth/send", map);
} catch (Exception ex) { } catch (Exception ex) {
log.error(ex.getMessage()); log.error(ex.getMessage());
} }
...@@ -83,7 +92,6 @@ public class PlatformExceptionHandler { ...@@ -83,7 +92,6 @@ public class PlatformExceptionHandler {
HttpServletRequest request = servletRequestAttributes.getRequest();//获取request HttpServletRequest request = servletRequestAttributes.getRequest();//获取request
StringBuilder stringBuilder = new StringBuilder(); StringBuilder stringBuilder = new StringBuilder();
//request 获得头部 //request 获得头部
stringBuilder.append(request.getHeader("app"));
LocalDateTime startTime= LocalDateTime.now();//开始时间 LocalDateTime startTime= LocalDateTime.now();//开始时间
stringBuilder.append("》》" +startTime.toString()); stringBuilder.append("》》" +startTime.toString());
stringBuilder.append("》》" +request.getServletPath()); stringBuilder.append("》》" +request.getServletPath());
...@@ -91,4 +99,5 @@ public class PlatformExceptionHandler { ...@@ -91,4 +99,5 @@ public class PlatformExceptionHandler {
return stringBuilder.toString(); return stringBuilder.toString();
} }
} }
...@@ -36,4 +36,11 @@ public class UserMemberSaveDTO { ...@@ -36,4 +36,11 @@ public class UserMemberSaveDTO {
*/ */
@ApiModelProperty(value = "剩余天数") @ApiModelProperty(value = "剩余天数")
private Integer rentFreeDays; private Integer rentFreeDays;
/**
* 剩余天数
*/
@ApiModelProperty(value = "剩余天数")
private Integer source;
} }
package com.github.wxiaoqi.security.admin.entity; package com.github.wxiaoqi.security.admin.entity;
import lombok.AllArgsConstructor; import lombok.*;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import javax.persistence.Column; import javax.persistence.Column;
import javax.persistence.Table; import javax.persistence.Table;
...@@ -20,6 +17,7 @@ import java.io.Serializable; ...@@ -20,6 +17,7 @@ import java.io.Serializable;
@NoArgsConstructor @NoArgsConstructor
@AllArgsConstructor @AllArgsConstructor
@Table(name = "base_user_member_export") @Table(name = "base_user_member_export")
@ToString
public class BaseUserMemberExport implements Serializable { public class BaseUserMemberExport implements Serializable {
private static final long serialVersionUID = 1L; private static final long serialVersionUID = 1L;
private Integer id; private Integer id;
...@@ -42,5 +40,12 @@ public class BaseUserMemberExport implements Serializable { ...@@ -42,5 +40,12 @@ public class BaseUserMemberExport implements Serializable {
private Integer crtId; private Integer crtId;
@Column(name = "member_name") @Column(name = "member_name")
private String memberName; private String memberName;
@Column(name = "before_membe_level")
private Integer beforeMemberLevel;
@Column(name = "before_discount")
private Integer beforeDiscount;
@Column(name = "source")
private Integer source;
} }
...@@ -4,18 +4,20 @@ import com.ace.cache.annotation.Cache; ...@@ -4,18 +4,20 @@ import com.ace.cache.annotation.Cache;
import com.ace.cache.annotation.CacheClear; import com.ace.cache.annotation.CacheClear;
import com.github.wxiaoqi.security.admin.dto.BaseUserMemberVO; import com.github.wxiaoqi.security.admin.dto.BaseUserMemberVO;
import com.github.wxiaoqi.security.admin.dto.UserMemberDTO; import com.github.wxiaoqi.security.admin.dto.UserMemberDTO;
import com.github.wxiaoqi.security.admin.entity.BaseUserMemberExport;
import com.github.wxiaoqi.security.admin.entity.BaseUserMemberLevel; import com.github.wxiaoqi.security.admin.entity.BaseUserMemberLevel;
import com.github.wxiaoqi.security.admin.mapper.BaseUserMemberLevelMapper; import com.github.wxiaoqi.security.admin.mapper.BaseUserMemberLevelMapper;
import com.github.wxiaoqi.security.admin.vo.AppUserVo; import com.github.wxiaoqi.security.admin.vo.AppUserVo;
import com.github.wxiaoqi.security.admin.vo.UserMemberVo; import com.github.wxiaoqi.security.admin.vo.UserMemberVo;
import com.github.wxiaoqi.security.auth.client.config.UserAuthConfig;
import com.github.wxiaoqi.security.auth.client.jwt.UserAuthUtil;
import com.github.wxiaoqi.security.auth.common.util.jwt.IJWTInfo;
import com.github.wxiaoqi.security.common.exception.BaseException; import com.github.wxiaoqi.security.common.exception.BaseException;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.beanutils.BeanUtils; import org.apache.commons.beanutils.BeanUtils;
import org.apache.commons.beanutils.BeanUtilsBean;
import org.apache.commons.collections.CollectionUtils; import org.apache.commons.collections.CollectionUtils;
import org.springframework.aop.framework.AopContext; import org.springframework.aop.framework.AopContext;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.task.TaskExecutor;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import com.github.wxiaoqi.security.admin.entity.BaseUserMember; import com.github.wxiaoqi.security.admin.entity.BaseUserMember;
import com.github.wxiaoqi.security.admin.mapper.BaseUserMemberMapper; import com.github.wxiaoqi.security.admin.mapper.BaseUserMemberMapper;
...@@ -23,12 +25,14 @@ import com.github.wxiaoqi.security.common.biz.BaseBiz; ...@@ -23,12 +25,14 @@ import com.github.wxiaoqi.security.common.biz.BaseBiz;
import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import tk.mybatis.mapper.entity.Example; import tk.mybatis.mapper.entity.Example;
import tk.mybatis.mapper.weekend.WeekendSqls;
import javax.servlet.http.HttpServletRequest;
import java.lang.reflect.InvocationTargetException; import java.lang.reflect.InvocationTargetException;
import java.util.Collection; import java.util.Collection;
import java.util.List; import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/** /**
* 用户会员表 * 用户会员表
...@@ -43,11 +47,26 @@ import java.util.List; ...@@ -43,11 +47,26 @@ import java.util.List;
public class BaseUserMemberBiz extends BaseBiz<BaseUserMemberMapper, BaseUserMember> { public class BaseUserMemberBiz extends BaseBiz<BaseUserMemberMapper, BaseUserMember> {
@Autowired @Autowired
AppUserDetailBiz detailBiz; private AppUserDetailBiz detailBiz;
@Autowired @Autowired
private BaseUserMemberLevelMapper BaseUserMemberLevelMapper; private BaseUserMemberLevelMapper BaseUserMemberLevelMapper;
@Autowired
private AppUserLoginBiz appUserLoginBiz;
private ExecutorService executorService = Executors.newCachedThreadPool();
@Autowired
private UserAuthUtil userAuthUtil;
@Autowired
private UserAuthConfig userAuthConfig;
@Autowired
private BaseUserMemberExportBiz baseUserMemberExportBiz;
// @Autowired // @Autowired
// private TaskExecutor taskExecutor; // private TaskExecutor taskExecutor;
// //
...@@ -224,7 +243,7 @@ public class BaseUserMemberBiz extends BaseBiz<BaseUserMemberMapper, BaseUserMem ...@@ -224,7 +243,7 @@ public class BaseUserMemberBiz extends BaseBiz<BaseUserMemberMapper, BaseUserMem
* @param userMemberDTO * @param userMemberDTO
*/ */
@Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRED) @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRED)
public void UpdateUserMember(UserMemberDTO userMemberDTO) throws InvocationTargetException, IllegalAccessException { public void UpdateUserMember(UserMemberDTO userMemberDTO,HttpServletRequest request) throws Exception {
Integer userId = userMemberDTO.getUserId(); Integer userId = userMemberDTO.getUserId();
BaseUserMember baseUserMember = new BaseUserMember(); BaseUserMember baseUserMember = new BaseUserMember();
...@@ -234,7 +253,6 @@ public class BaseUserMemberBiz extends BaseBiz<BaseUserMemberMapper, BaseUserMem ...@@ -234,7 +253,6 @@ public class BaseUserMemberBiz extends BaseBiz<BaseUserMemberMapper, BaseUserMem
if (totalNumber < freeDays) { if (totalNumber < freeDays) {
freeDays = totalNumber; freeDays = totalNumber;
} }
if (userMemberDTO.getMemberLevel() != null) { if (userMemberDTO.getMemberLevel() != null) {
Example exa = new Example(BaseUserMemberLevel.class); Example exa = new Example(BaseUserMemberLevel.class);
Example.Criteria criteria = exa.createCriteria(); Example.Criteria criteria = exa.createCriteria();
...@@ -254,6 +272,8 @@ public class BaseUserMemberBiz extends BaseBiz<BaseUserMemberMapper, BaseUserMem ...@@ -254,6 +272,8 @@ public class BaseUserMemberBiz extends BaseBiz<BaseUserMemberMapper, BaseUserMem
Integer buyCount = userMemberDTO.getBuyCount() == null ? 1 : userMemberDTO.getBuyCount(); Integer buyCount = userMemberDTO.getBuyCount() == null ? 1 : userMemberDTO.getBuyCount();
UserMemberVo userMemberVo = getMemberInfoByUserId(userMemberDTO.getUserId()); UserMemberVo userMemberVo = getMemberInfoByUserId(userMemberDTO.getUserId());
//保存修改记录
setModifyData(userMemberVo,userMemberDTO,request);
if (userMemberVo == null) { if (userMemberVo == null) {
baseUserMember.setRentFreeDays(freeDays); baseUserMember.setRentFreeDays(freeDays);
baseUserMember.setBuyCount(buyCount); baseUserMember.setBuyCount(buyCount);
...@@ -286,4 +306,34 @@ public class BaseUserMemberBiz extends BaseBiz<BaseUserMemberMapper, BaseUserMem ...@@ -286,4 +306,34 @@ public class BaseUserMemberBiz extends BaseBiz<BaseUserMemberMapper, BaseUserMem
criteria.andIn("userId", userIds); criteria.andIn("userId", userIds);
mapper.deleteByExample(example); mapper.deleteByExample(example);
} }
private void setModifyData(UserMemberVo beforeMember, UserMemberDTO aftereMember,HttpServletRequest request) throws Exception {
IJWTInfo infoFromToken = userAuthUtil.getInfoFromToken(userAuthConfig.getToken(request));
executorService.submit(()->{
try {
AppUserVo qppUser = detailBiz.getUserInfoById(beforeMember.getUserId());
BaseUserMemberExport baseUserMemberExport = BaseUserMemberExport
.builder()
.username(qppUser.getUsername())
.beforeMemberLevel(beforeMember.getMemberLevel())
.totalNumber(aftereMember.getTotalNumber() - beforeMember.getTotalNumber())
.rentFreeDays(aftereMember.getRentFreeDays() - beforeMember.getRentFreeDays())
.beforeDiscount(beforeMember.getDiscount())
.discount(aftereMember.getDiscount())
.status(1)
.crtTime(System.currentTimeMillis())
.crtId(Integer.valueOf(infoFromToken.getId()))
.crtName(infoFromToken.getUniqueName())
.memberName(qppUser.getRealname())
.source(1)
.build();
baseUserMemberExportBiz.insertSelective(baseUserMemberExport);
System.out.println(baseUserMemberExport);
} catch (Exception e) {
e.printStackTrace();
log.error(e.getMessage());
}
});
}
} }
\ No newline at end of file
...@@ -52,6 +52,7 @@ public class BaseUserMemberExportBiz extends BaseBiz<BaseUserMemberExportMapper, ...@@ -52,6 +52,7 @@ public class BaseUserMemberExportBiz extends BaseBiz<BaseUserMemberExportMapper,
private ThreadPoolTaskExecutor threadPoolTaskExecutor; private ThreadPoolTaskExecutor threadPoolTaskExecutor;
private final int BORDER_NUM=250; private final int BORDER_NUM=250;
private BaseUserMemberExport baseUserMemberExport;
public void saveUserMember(UserMemberSaveDTO userMemberSaveDTO, Integer userId, String name) { public void saveUserMember(UserMemberSaveDTO userMemberSaveDTO, Integer userId, String name) {
...@@ -256,4 +257,9 @@ public class BaseUserMemberExportBiz extends BaseBiz<BaseUserMemberExportMapper, ...@@ -256,4 +257,9 @@ public class BaseUserMemberExportBiz extends BaseBiz<BaseUserMemberExportMapper,
public void updateUserMemberExportDataStatus(Integer id) { public void updateUserMemberExportDataStatus(Integer id) {
mapper.updateUserMemberExportDataStatusById(id, 1); mapper.updateUserMemberExportDataStatusById(id, 1);
} }
@Override
public void insertSelective(BaseUserMemberExport baseUserMemberExport){
mapper.insertSelective(baseUserMemberExport);
}
} }
...@@ -101,7 +101,7 @@ public class BaseUserMemberController extends BaseController<BaseUserMemberBiz, ...@@ -101,7 +101,7 @@ public class BaseUserMemberController extends BaseController<BaseUserMemberBiz,
return ObjectRestResponse.createDefaultFail(); return ObjectRestResponse.createDefaultFail();
} }
baseBiz.UpdateUserMember(userMemberDTO); baseBiz.UpdateUserMember(userMemberDTO,request);
return ObjectRestResponse.succ(); return ObjectRestResponse.succ();
} }
} }
...@@ -20,7 +20,8 @@ ...@@ -20,7 +20,8 @@
</update> </update>
<select id="findExportDataPage" resultType="com.github.wxiaoqi.security.admin.dto.BaseUserMemberExportDTO"> <select id="findExportDataPage" resultType="com.github.wxiaoqi.security.admin.dto.BaseUserMemberExportDTO">
select `id`,`member_level` as `memberLevel`,`member_name` as `memberName`,`rent_free_days` as `rentFreeDays`,`total_number` as `totalNumber`,`username`,`status`,`crt_name` as `crtName`,`crt_time`as `crtTime` from `base_user_member_export` where `is_del`=0 select `id`,`member_level` as `memberLevel`,`member_name` as `memberName`,`rent_free_days` as `rentFreeDays`,`total_number` as `totalNumber`,`username`,`status`,`crt_name` as `crtName`,`crt_time`as `crtTime` from `base_user_member_export`
where `is_del`=0 and source = 0
<if test="username != null and username != ''"> <if test="username != null and username != ''">
and `username`=#{username} and `username`=#{username}
</if> </if>
......
...@@ -297,6 +297,7 @@ public class BaseOrderBiz extends BaseBiz<BaseOrderMapper, BaseOrder> implements ...@@ -297,6 +297,7 @@ public class BaseOrderBiz extends BaseBiz<BaseOrderMapper, BaseOrder> implements
orderPageVo.setIllegalReserve(illegalReserve); orderPageVo.setIllegalReserve(illegalReserve);
orderPageVo.setItems(orderItemBiz.selectList(new OrderItem(){{ orderPageVo.setItems(orderItemBiz.selectList(new OrderItem(){{
setOrderId(orderPageVo.getId()); setOrderId(orderPageVo.getId());
setType(104);
}})); }}));
return ObjectRestResponse.succ(orderPageVo); return ObjectRestResponse.succ(orderPageVo);
} }
......
...@@ -108,17 +108,18 @@ public class BackStageOrderController extends CommonBaseController implements Us ...@@ -108,17 +108,18 @@ public class BackStageOrderController extends CommonBaseController implements Us
@IgnoreClientToken @IgnoreClientToken
@CrossOrigin @CrossOrigin
public ObjectRestResponse<PageDataVO<OrderListVo>> selectByUser(BaseOrderController.QueryOrderList dto) { public ObjectRestResponse<PageDataVO<OrderListVo>> selectByUser(BaseOrderController.QueryOrderList dto) {
if (dto.getStartTime() != null) { UserDTO userDTO = getAdminUserInfo();
if (dto.getEndTime() == null) { if (userDTO == null) {
dto.setEndTime(new Date().getTime()); return ObjectRestResponse.succ(new PageDataVO<>());
} }
}
//车辆排班表查询订单详情 //车辆排班表查询订单详情
if (dto.getOneNo()!=null) { if (dto.getOneNo()!=null) {
dto.setPage(1); dto.setPage(1);
dto.setLimit(1); dto.setLimit(1);
dto.setType(1); dto.setType(1);
} }
if (StringUtils.isNotBlank(dto.getPhone()) || StringUtils.isNotBlank(dto.getRealName())) { if (StringUtils.isNotBlank(dto.getPhone()) || StringUtils.isNotBlank(dto.getRealName())) {
List<AppUserLogin> appUserLoins = userFeign.getOne(dto.getPhone(), dto.getRealName()); List<AppUserLogin> appUserLoins = userFeign.getOne(dto.getPhone(), dto.getRealName());
if (CollectionUtil.isNotEmpty(appUserLoins)) { if (CollectionUtil.isNotEmpty(appUserLoins)) {
...@@ -128,19 +129,11 @@ public class BackStageOrderController extends CommonBaseController implements Us ...@@ -128,19 +129,11 @@ public class BackStageOrderController extends CommonBaseController implements Us
return ObjectRestResponse.succ(new PageDataVO<>()); return ObjectRestResponse.succ(new PageDataVO<>());
} }
} }
//获取权限公司列表
List<BranchCompany> branchCompanies = vehicleFeign.companyAll(userDTO.getDataAll(), userDTO.getDataCompany(), userDTO.getDataZone());
UserDTO userDTO = getAdminUserInfo(); List<Integer> companyId = branchCompanies.stream().map(BranchCompany::getId).collect(Collectors.toList());
if (userDTO == null) { dto.setCompanyIds(companyId);
return ObjectRestResponse.succ(new PageDataVO<>()); //大区搜索
}
//权限
if (userDTO.getDataAll()!=1&&dto.getType() != null && dto.getType() != 3) {
List<BranchCompany> branchCompanies = vehicleFeign.companyAll(userDTO.getDataAll(), userDTO.getDataCompany(), userDTO.getDataZone());
List<Integer> companyIds = branchCompanies.stream().map(BranchCompany::getId).collect(Collectors.toList());
dto.setCompanyIds(companyIds);
}
//大区查询
if (dto.getZoneId() != null) { if (dto.getZoneId() != null) {
if (userDTO.getDataAll() != 1 && !dto.getZoneId().equals(userDTO.getZoneId())) { if (userDTO.getDataAll() != 1 && !dto.getZoneId().equals(userDTO.getZoneId())) {
return ObjectRestResponse.succ(new PageDataVO<>()); return ObjectRestResponse.succ(new PageDataVO<>());
...@@ -167,11 +160,11 @@ public class BackStageOrderController extends CommonBaseController implements Us ...@@ -167,11 +160,11 @@ public class BackStageOrderController extends CommonBaseController implements Us
dto.setVehicleIds(vehicleIds); dto.setVehicleIds(vehicleIds);
} }
// //
// if (dto.getStartTime() != null) { if (dto.getStartTime() != null) {
// if (dto.getEndTime() == null) { if (dto.getEndTime() == null) {
// dto.setEndTime(new Date().getTime()); dto.setEndTime(new Date().getTime());
// } }
// } }
Query query = new Query(dto); Query query = new Query(dto);
PageDataVO pageDataVO = PageDataVO.pageInfo(query, () -> baseOrderBiz.listOrder(query.getSuper())); PageDataVO pageDataVO = PageDataVO.pageInfo(query, () -> baseOrderBiz.listOrder(query.getSuper()));
...@@ -457,7 +450,6 @@ public class BackStageOrderController extends CommonBaseController implements Us ...@@ -457,7 +450,6 @@ public class BackStageOrderController extends CommonBaseController implements Us
return backgroundBaseOrderBiz.getAllOrderList(dto); return backgroundBaseOrderBiz.getAllOrderList(dto);
} }
@Data @Data
public static class ChangeVehicleDTO { public static class ChangeVehicleDTO {
String no; String no;
......
...@@ -47,6 +47,8 @@ import java.util.*; ...@@ -47,6 +47,8 @@ import java.util.*;
@Service @Service
@Slf4j @Slf4j
public class CertificationService { public class CertificationService {
@Value("${certification.frequency:2}")
private Integer FREQUENCY;
@Autowired @Autowired
private UserAuthentication authentication; private UserAuthentication authentication;
...@@ -78,14 +80,14 @@ public class CertificationService { ...@@ -78,14 +80,14 @@ public class CertificationService {
} }
//判断是否有填写身份证号 //判断是否有填写身份证号
if (StringUtils.isBlank(idInformation.getIdNumber())) { if (StringUtils.isBlank(idInformation.getIdNumber())) {
return ObjectRestResponse.createFailedResult(ResultCode.INCOMPLETE_DATA, "填写证件号"); return ObjectRestResponse.createFailedResult(ResultCode.INCOMPLETE_DATA, "填写证件号");
} }
if (!Validation.isIdCard(idInformation.getIdNumber())) { if (!Validation.isIdCard(idInformation.getIdNumber())) {
return ObjectRestResponse.createFailedResult(ResultCode.WRONG_FORMAT_OF_ID_CARD, "填写的证件格式错误"); return ObjectRestResponse.createFailedResult(ResultCode.WRONG_FORMAT_OF_ID_CARD, "证件格式错误");
} }
//判断是有否填写名字 //判断是有否填写名字
if (StringUtils.isBlank(idInformation.getName())) { if (StringUtils.isBlank(idInformation.getName())) {
return ObjectRestResponse.createFailedResult(ResultCode.INCOMPLETE_DATA, "填写姓名"); return ObjectRestResponse.createFailedResult(ResultCode.INCOMPLETE_DATA, "填写姓名");
} }
//判断是否有正面照片 //判断是否有正面照片
if (StringUtils.isBlank(idInformation.getFrontUrl())) { if (StringUtils.isBlank(idInformation.getFrontUrl())) {
...@@ -100,20 +102,19 @@ public class CertificationService { ...@@ -100,20 +102,19 @@ public class CertificationService {
//验证证件信息是否和填入的客户信息一致 //验证证件信息是否和填入的客户信息一致
String name = credentialsData.getName(); String name = credentialsData.getName();
String number = credentialsData.getCode(); String number = credentialsData.getCode();
if (idInformation.getName().equals(name)) { if (!idInformation.getName().replaceAll(" ","").equals(name)) {
ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE, "姓名不一致"); return ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE, "姓名不一致");
} }
if (idInformation.getIdNumber().equals(number)) { if (!idInformation.getIdNumber().replaceAll(" ","").equals(number)) {
ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE, "证件号不一致"); return ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE, "证件号不一致");
} }
//判断是否超过认证次数
Example exa = new Example(IdInformation.class); Example exa = new Example(IdInformation.class);
Example.Criteria criteria = exa.createCriteria(); exa.createCriteria().andEqualTo("idNumber", number);
criteria.andEqualTo("idNumber", idInformation.getIdNumber());
List<IdInformation> idInformatics = idInformationMapper.selectByExample(exa); List<IdInformation> idInformatics = idInformationMapper.selectByExample(exa);
if (CollectionUtil.isNotEmpty(idInformatics)) { if (CollectionUtils.isNotEmpty(idInformatics) && idInformatics.size() > FREQUENCY) {
log.error("该身份证已存在,不要重复认证"); log.error("该身份证已超过最大认证次数");
log.info("图片已解析,未认证"); return ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE, "该身份证已超过最大认证次数");
return ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE, "该身份证已存在,不要重复认证");
} }
//3.验证 //3.验证
boolean result = authentication.certificate(new UserMessage() {{ boolean result = authentication.certificate(new UserMessage() {{
...@@ -181,8 +182,8 @@ public class CertificationService { ...@@ -181,8 +182,8 @@ public class CertificationService {
return ObjectRestResponse.succ(idInformation.getId()); return ObjectRestResponse.succ(idInformation.getId());
} catch (Exception e) { } catch (Exception e) {
log.error(e.getMessage(), e); log.error(e.getMessage(), e);
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); TransactionAspectSupport.currentTransactionStatus();
return ObjectRestResponse.createFailedResult(ResultCode.INCOMPLETE_DATA, "认证失败,请重新认证"); return ObjectRestResponse.createFailedResult(ResultCode.INCOMPLETE_DATA, "无法识别,请重新上传");
} }
} }
......
...@@ -151,4 +151,19 @@ public class AddOrUpdateVehicleVo { ...@@ -151,4 +151,19 @@ public class AddOrUpdateVehicleVo {
* 车辆状态 * 车辆状态
*/ */
private Integer travelStatus; private Integer travelStatus;
/**
* 终端号
*/
private String terminalNumber;
/**
* SIM卡号
*/
private String simNumber;
/**
* 通讯类型
*/
private String communicationType;
} }
\ No newline at end of file
...@@ -534,7 +534,7 @@ ...@@ -534,7 +534,7 @@
and book_end_date &gt;= now() and book_end_date &gt;= now()
</if> </if>
<!--增加时间限制,已审核的未出车小于当前时间的不显示, 已出车的结束时间延后两天小于当前时间的不显示--> <!--增加时间限制,已审核的未出车小于当前时间的不显示, 已出车的结束时间延后两天小于当前时间的不显示-->
<if test="flag == true and status == 2"> <if test="flag == true and (status == 3 or status == 5 or status == 2)">
and ( (v4.id IS NOT NULL and DATE_ADD(v1.book_end_date,INTERVAL '2' DAY) >= now()) OR (v4.id IS NULL AND v1.book_end_date &gt;= now())) and ( (v4.id IS NOT NULL and DATE_ADD(v1.book_end_date,INTERVAL '2' DAY) >= now()) OR (v4.id IS NULL AND v1.book_end_date &gt;= now()))
</if> </if>
<if test="flag == true"> <if test="flag == true">
......
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