Commit bd7fcfee authored by jiaorz's avatar jiaorz

Merge branch 'master-alipay-change' into base-modify

# Conflicts:
#	xx-vehicle/xx-vehicle-server/src/main/resources/mapper/VehicleMapper.xml
parents 6160727c f05baad0
...@@ -25,7 +25,16 @@ public class AppUserPositionTempDTO { ...@@ -25,7 +25,16 @@ public class AppUserPositionTempDTO {
private String name; private String name;
@ApiModelProperty(value = "职位id") @ApiModelProperty(value = "身份id")
private Integer positionId; private Integer positionId;
@ApiModelProperty(value = "员工职位id")
private Integer jobId;
@ApiModelProperty(value = "分公司id")
private Integer companyId;
@ApiModelProperty(value = "分公司")
private String companyName;
} }
...@@ -14,4 +14,5 @@ public class AppUserPositionTempFindDTO extends PageParam { ...@@ -14,4 +14,5 @@ public class AppUserPositionTempFindDTO extends PageParam {
private String phone; private String phone;
private String name; private String name;
private Integer status; private Integer status;
private Integer companyId;
} }
package com.github.wxiaoqi.security.admin.entity;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import javax.persistence.Column;
import javax.persistence.GeneratedValue;
import javax.persistence.Id;
import javax.persistence.Table;
import java.io.Serializable;
/**
* 用户职位表
*
* @author libin
* @email 18178966185@163.com
* @date 2019-07-09 10:00:42
*/
@Data
@Table(name = "app_user_job_level")
public class AppUserJobLevel implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 主键id
*/
@Id
@GeneratedValue(generator = "JDBC")
@ApiModelProperty("主键id")
private Integer id;
/**
* 角色名称
*/
@Column(name = "name")
@ApiModelProperty(value = "角色名称")
private String name;
/**
* 等级
*/
@Column(name = "level")
@ApiModelProperty(value = "等级")
private Integer level;
/**
* 状态:0-正常;1-禁用
*/
@Column(name = "status")
@ApiModelProperty(value = "状态:0-正常;1-禁用")
private Integer status;
/**
* 创建时间
*/
@Column(name = "crt_time")
@ApiModelProperty(value = "创建时间", hidden = true )
private Long crtTime;
/**
* 更新时间
*/
@Column(name = "upd_time")
@ApiModelProperty(value = "更新时间", hidden = true )
private Long updTime;
/**
* 是否删除:0-正常;1-删除
*/
@Column(name = "is_del")
@ApiModelProperty(value = "是否删除:0-正常;1-删除")
private Integer isDel;
}
...@@ -43,6 +43,19 @@ public class AppUserPositionTemp implements Serializable { ...@@ -43,6 +43,19 @@ public class AppUserPositionTemp implements Serializable {
@ApiModelProperty(value = "职位id") @ApiModelProperty(value = "职位id")
private Integer positionId; private Integer positionId;
@Column(name = "job_id")
@ApiModelProperty(value = "员工职位id")
private Integer jobId;
@Column(name = "company_id")
@ApiModelProperty(value = "分公司id")
private Integer companyId;
@Column(name = "company_name")
@ApiModelProperty(value = "分公司名称")
private String companyName;
@Column(name = "name") @Column(name = "name")
@ApiModelProperty(value = "姓名") @ApiModelProperty(value = "姓名")
private String name; private String name;
...@@ -51,6 +64,11 @@ public class AppUserPositionTemp implements Serializable { ...@@ -51,6 +64,11 @@ public class AppUserPositionTemp implements Serializable {
@Column(name = "crt_time") @Column(name = "crt_time")
@ApiModelProperty(value = "创建时间", hidden = true ) @ApiModelProperty(value = "创建时间", hidden = true )
private Long crtTime; private Long crtTime;
@Column(name = "upd_time")
@ApiModelProperty(value = "更新时间", hidden = true )
private Long updTime;
@Column(name = "is_del") @Column(name = "is_del")
......
...@@ -37,4 +37,18 @@ public class AppUserPositionTempVo { ...@@ -37,4 +37,18 @@ public class AppUserPositionTempVo {
@ApiModelProperty(value = "创建时间", hidden = true ) @ApiModelProperty(value = "创建时间", hidden = true )
private Long crtTime; private Long crtTime;
@ApiModelProperty(value = "员工职位id")
private Integer jobId;
@ApiModelProperty(value = "员工职位名称")
private String jobName;
@ApiModelProperty(value = "分公司id")
private Integer companyId;
@ApiModelProperty(value = "分公司名称")
private String companyName;
} }
package com.github.wxiaoqi.security.admin.biz;
import com.github.wxiaoqi.security.admin.dto.UserPostionDTO;
import com.github.wxiaoqi.security.admin.entity.AppUserJobLevel;
import com.github.wxiaoqi.security.admin.entity.AppUserPosition;
import com.github.wxiaoqi.security.admin.mapper.AppUserJobLevelMapper;
import com.github.wxiaoqi.security.admin.mapper.AppUserPositionMapper;
import com.github.wxiaoqi.security.admin.vo.WalletPostionVo;
import com.github.wxiaoqi.security.common.biz.BaseBiz;
import org.apache.commons.collections.CollectionUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.function.Function;
import java.util.stream.Collectors;
/**
* 用户身份职位表
*
* @author libin
* @email 18178966185@163.com
* @date 2019-07-09 10:00:42
*/
@Transactional
@Service
public class AppUserJobLevelBiz extends BaseBiz<AppUserJobLevelMapper, AppUserJobLevel> {
public Map<Integer, AppUserJobLevel> findJobIdAndJobMapByIds(List<Integer> jobIds) {
Map<Integer,AppUserJobLevel> postionMap = new HashMap<>();
List<AppUserJobLevel> data= mapper.selectByIdList(jobIds);
if(CollectionUtils.isEmpty(data)){
return postionMap;
}
postionMap = data.stream().collect(Collectors.toMap(AppUserJobLevel::getId, Function.identity()));
return postionMap;
}
public Map<Integer, String> findJobIdAndNameMap() {
List<AppUserJobLevel> postions = selectListAll();
return postions.stream().collect(Collectors.toMap(AppUserJobLevel::getId,AppUserJobLevel::getName));
}
}
\ No newline at end of file
...@@ -3,15 +3,12 @@ package com.github.wxiaoqi.security.admin.biz; ...@@ -3,15 +3,12 @@ package com.github.wxiaoqi.security.admin.biz;
import com.github.wxiaoqi.security.admin.dto.UserPostionDTO; import com.github.wxiaoqi.security.admin.dto.UserPostionDTO;
import com.github.wxiaoqi.security.admin.vo.WalletPostionVo; import com.github.wxiaoqi.security.admin.vo.WalletPostionVo;
import org.apache.commons.collections.CollectionUtils; import org.apache.commons.collections.CollectionUtils;
import org.jsoup.select.Collector;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import com.github.wxiaoqi.security.admin.entity.AppUserPosition; import com.github.wxiaoqi.security.admin.entity.AppUserPosition;
import com.github.wxiaoqi.security.admin.mapper.AppUserPositionMapper; import com.github.wxiaoqi.security.admin.mapper.AppUserPositionMapper;
import com.github.wxiaoqi.security.common.biz.BaseBiz; import com.github.wxiaoqi.security.common.biz.BaseBiz;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import java.util.*; import java.util.*;
import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicInteger;
import java.util.function.Function; import java.util.function.Function;
......
...@@ -2,6 +2,7 @@ package com.github.wxiaoqi.security.admin.biz; ...@@ -2,6 +2,7 @@ package com.github.wxiaoqi.security.admin.biz;
import com.github.wxiaoqi.security.admin.dto.AppUserPositionTempDTO; import com.github.wxiaoqi.security.admin.dto.AppUserPositionTempDTO;
import com.github.wxiaoqi.security.admin.dto.AppUserPositionTempFindDTO; import com.github.wxiaoqi.security.admin.dto.AppUserPositionTempFindDTO;
import com.github.wxiaoqi.security.admin.entity.AppUserJobLevel;
import com.github.wxiaoqi.security.admin.entity.AppUserLogin; import com.github.wxiaoqi.security.admin.entity.AppUserLogin;
import com.github.wxiaoqi.security.admin.entity.AppUserPosition; import com.github.wxiaoqi.security.admin.entity.AppUserPosition;
import com.github.wxiaoqi.security.admin.entity.AppUserPositionTemp; import com.github.wxiaoqi.security.admin.entity.AppUserPositionTemp;
...@@ -13,6 +14,8 @@ import com.github.wxiaoqi.security.common.msg.ObjectRestResponse; ...@@ -13,6 +14,8 @@ import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
import com.github.wxiaoqi.security.common.util.process.ResultCode; import com.github.wxiaoqi.security.common.util.process.ResultCode;
import com.github.wxiaoqi.security.common.vo.PageDataVO; import com.github.wxiaoqi.security.common.vo.PageDataVO;
import com.google.common.collect.Lists; import com.google.common.collect.Lists;
import com.xxfc.platform.vehicle.entity.BranchCompany;
import com.xxfc.platform.vehicle.feign.VehicleFeign;
import org.apache.commons.collections.CollectionUtils; import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
...@@ -51,12 +54,28 @@ public class AppUserPositionTempBiz extends BaseBiz<AppUserPositionTempMapper, A ...@@ -51,12 +54,28 @@ public class AppUserPositionTempBiz extends BaseBiz<AppUserPositionTempMapper, A
private Map<Integer, String> postionIdAndNameMap; private Map<Integer, String> postionIdAndNameMap;
@Autowired
private VehicleFeign vehicleFeign;
@Autowired
AppUserJobLevelBiz jobLevelBiz;
public ObjectRestResponse add(AppUserPositionTempDTO appUserPositionTempDTO) { public ObjectRestResponse add(AppUserPositionTempDTO appUserPositionTempDTO) {
if (appUserPositionTempDTO == null || StringUtils.isBlank(appUserPositionTempDTO.getPhone()) || StringUtils.isBlank(appUserPositionTempDTO.getName()) if (appUserPositionTempDTO == null || StringUtils.isBlank(appUserPositionTempDTO.getPhone()) || StringUtils.isBlank(appUserPositionTempDTO.getName())
|| appUserPositionTempDTO.getPositionId() == null || appUserPositionTempDTO.getPositionId() == 0) { || appUserPositionTempDTO.getPositionId() == null || appUserPositionTempDTO.getPositionId() == 0) {
return ObjectRestResponse.createFailedResult(ResultCode.NOTEXIST_CODE, "参数不能为空"); return ObjectRestResponse.createFailedResult(ResultCode.NOTEXIST_CODE, "参数不能为空");
} }
Integer companyId=appUserPositionTempDTO.getCompanyId();
String companyName=appUserPositionTempDTO.getCompanyName();
if (!(companyId!=null&&companyId>0&&StringUtils.isNotBlank(companyName)))
return ObjectRestResponse.createFailedResult(ResultCode.NOTEXIST_CODE, "分公司不存在");
BranchCompany branchCompany=vehicleFeign.companyId(companyName);
if (branchCompany==null){
return ObjectRestResponse.createFailedResult(ResultCode.NOTEXIST_CODE, "分公司不存在");
}
companyId=branchCompany.getId();
companyName=branchCompany.getName();
String phone = appUserPositionTempDTO.getPhone(); String phone = appUserPositionTempDTO.getPhone();
Integer id = appUserPositionTempDTO.getId() == null ? 0 : appUserPositionTempDTO.getId(); Integer id = appUserPositionTempDTO.getId() == null ? 0 : appUserPositionTempDTO.getId();
Example example = new Example(AppUserPositionTemp.class); Example example = new Example(AppUserPositionTemp.class);
...@@ -73,6 +92,8 @@ public class AppUserPositionTempBiz extends BaseBiz<AppUserPositionTempMapper, A ...@@ -73,6 +92,8 @@ public class AppUserPositionTempBiz extends BaseBiz<AppUserPositionTempMapper, A
AppUserPositionTemp userPositionTemp = new AppUserPositionTemp(); AppUserPositionTemp userPositionTemp = new AppUserPositionTemp();
BeanUtils.copyProperties(appUserPositionTempDTO, userPositionTemp); BeanUtils.copyProperties(appUserPositionTempDTO, userPositionTemp);
userPositionTemp.setUserId(userId); userPositionTemp.setUserId(userId);
userPositionTemp.setCompanyId(companyId);
userPositionTemp.setCompanyName(companyName);
//编辑 //编辑
if (id == null || id == 0) { if (id == null || id == 0) {
insertSelective(userPositionTemp); insertSelective(userPositionTemp);
...@@ -103,14 +124,18 @@ public class AppUserPositionTempBiz extends BaseBiz<AppUserPositionTempMapper, A ...@@ -103,14 +124,18 @@ public class AppUserPositionTempBiz extends BaseBiz<AppUserPositionTempMapper, A
if (StringUtils.isNotEmpty(appUserPositionTempFindDTO.getPhone())) { if (StringUtils.isNotEmpty(appUserPositionTempFindDTO.getPhone())) {
criteria.andEqualTo("phone", appUserPositionTempFindDTO.getPhone()); criteria.andEqualTo("phone", appUserPositionTempFindDTO.getPhone());
} }
if (Objects.nonNull(appUserPositionTempFindDTO.getCompanyId())) {
criteria.andEqualTo("companyId", appUserPositionTempFindDTO.getCompanyId());
}
if(Objects.nonNull(appUserPositionTempFindDTO.getStatus())) { if(Objects.nonNull(appUserPositionTempFindDTO.getStatus())) {
if (DataStatus.USERED.code == appUserPositionTempFindDTO.getStatus()) { if (DataStatus.USERED.code == appUserPositionTempFindDTO.getStatus()) {
criteria.andIsNotNull("userId"); criteria.andNotEqualTo("userId",0);
} }
if (DataStatus.NO_USERED.code == appUserPositionTempFindDTO.getStatus()) { if (DataStatus.NO_USERED.code == appUserPositionTempFindDTO.getStatus()) {
criteria.andIsNull("userId"); criteria.andEqualTo("userId",0);
} }
} }
example.setOrderByClause("upd_time desc");
PageDataVO<AppUserPositionTemp> pageDataVO = PageDataVO.pageInfo(appUserPositionTempFindDTO.getPage(), appUserPositionTempFindDTO.getLimit(), () -> mapper.selectByExample(example)); PageDataVO<AppUserPositionTemp> pageDataVO = PageDataVO.pageInfo(appUserPositionTempFindDTO.getPage(), appUserPositionTempFindDTO.getLimit(), () -> mapper.selectByExample(example));
List<AppUserPositionTemp> data = pageDataVO.getData(); List<AppUserPositionTemp> data = pageDataVO.getData();
if (CollectionUtils.isEmpty(data)) { if (CollectionUtils.isEmpty(data)) {
...@@ -122,14 +147,17 @@ public class AppUserPositionTempBiz extends BaseBiz<AppUserPositionTempMapper, A ...@@ -122,14 +147,17 @@ public class AppUserPositionTempBiz extends BaseBiz<AppUserPositionTempMapper, A
List<Integer> postionIds = data.stream().map(AppUserPositionTemp::getPositionId).collect(Collectors.toList()); List<Integer> postionIds = data.stream().map(AppUserPositionTemp::getPositionId).collect(Collectors.toList());
Map<Integer, AppUserPosition> postionMap = appUserPositionBiz.findPostionIdAndPostionMapByIds(postionIds); Map<Integer, AppUserPosition> postionMap = appUserPositionBiz.findPostionIdAndPostionMapByIds(postionIds);
List<Integer> jobIds = data.stream().map(AppUserPositionTemp::getJobId).collect(Collectors.toList());
Map<Integer, AppUserJobLevel> jobMap = jobLevelBiz.findJobIdAndJobMapByIds(jobIds);
List<AppUserPositionTempVo> appUserPositionTempVos = new ArrayList<>(); List<AppUserPositionTempVo> appUserPositionTempVos = new ArrayList<>();
AppUserPositionTempVo appUserPositionTempVo; AppUserPositionTempVo appUserPositionTempVo;
for (AppUserPositionTemp appUserPositionTemp : data) { for (AppUserPositionTemp appUserPositionTemp : data) {
appUserPositionTempVo = new AppUserPositionTempVo(); appUserPositionTempVo = new AppUserPositionTempVo();
BeanUtils.copyProperties(appUserPositionTemp, appUserPositionTempVo); BeanUtils.copyProperties(appUserPositionTemp, appUserPositionTempVo);
String postionName = postionMap == null ? "" : postionMap.get(appUserPositionTemp.getPositionId())==null?"":postionMap.get(appUserPositionTemp.getPositionId()).getName(); String postionName = postionMap == null ? "" : postionMap.get(appUserPositionTemp.getPositionId())==null?"":postionMap.get(appUserPositionTemp.getPositionId()).getName();
String jobName = jobMap == null ? "" : jobMap.get(appUserPositionTemp.getJobId())==null?"":jobMap.get(appUserPositionTemp.getJobId()).getName();
appUserPositionTempVo.setPositionName(postionName); appUserPositionTempVo.setPositionName(postionName);
appUserPositionTempVo.setJobName(jobName);
appUserPositionTempVo.setStatus(appUserPositionTemp.getUserId() == null ? DataStatus.NO_USERED.code : appUserPositionTemp.getUserId()==0?DataStatus.NO_USERED.code:DataStatus.USERED.code); appUserPositionTempVo.setStatus(appUserPositionTemp.getUserId() == null ? DataStatus.NO_USERED.code : appUserPositionTemp.getUserId()==0?DataStatus.NO_USERED.code:DataStatus.USERED.code);
appUserPositionTempVos.add(appUserPositionTempVo); appUserPositionTempVos.add(appUserPositionTempVo);
} }
...@@ -165,26 +193,67 @@ public class AppUserPositionTempBiz extends BaseBiz<AppUserPositionTempMapper, A ...@@ -165,26 +193,67 @@ public class AppUserPositionTempBiz extends BaseBiz<AppUserPositionTempMapper, A
if (StringUtils.isEmpty(postionName)){ if (StringUtils.isEmpty(postionName)){
throw new BaseException("身份为空"); throw new BaseException("身份为空");
} }
//根据手机号查询userId if (StringUtils.isNotBlank(name)){
AppUserLogin userLogin = loginBiz.checkeUserLogin(phone); name.replaceAll(" ","");
}
Example example = new Example(AppUserPositionTemp.class);
example.createCriteria().andEqualTo("phone", phone).andEqualTo("isDel", 0);
List<AppUserPositionTemp> list = selectByExample(example);
Integer id=0;
Integer userId=0;
if (list.size()>0){
AppUserPositionTemp appUserPositionTemp1= list.get(0);
id=appUserPositionTemp1.getId();
userId=appUserPositionTemp1.getUserId();
}
if (userId==null||userId==0){
//根据手机号查询userId
AppUserLogin userLogin = loginBiz.checkeUserLogin(phone);
if (Objects.nonNull(userLogin)) {
userId=userLogin.getId();
}
}
for (Map.Entry<Integer, String> integerStringEntry : entrySet) { for (Map.Entry<Integer, String> integerStringEntry : entrySet) {
if (integerStringEntry.getValue().contains(postionName)) { if (integerStringEntry.getValue().contains(postionName)) {
postionId = integerStringEntry.getKey(); postionId = integerStringEntry.getKey();
break; break;
} }
} }
String companyName=data[3];
Integer companyId=0;
if (StringUtils.isNotBlank(companyName)){
BranchCompany branchCompany=vehicleFeign.companyId(companyName);
if (branchCompany!=null){
companyId=branchCompany.getId();
companyName=branchCompany.getName();
}else {
companyName=null;
}
}
String jobName=data[4];
Integer jobId=2;
if (StringUtils.isNotBlank(jobName)&&jobName.contains("销售")){
jobId=1;
}
appUserPositionTemp = new AppUserPositionTemp(); appUserPositionTemp = new AppUserPositionTemp();
appUserPositionTemp.setCrtTime(Instant.now().toEpochMilli());
appUserPositionTemp.setName(name); appUserPositionTemp.setName(name);
appUserPositionTemp.setPositionId(postionId); appUserPositionTemp.setPositionId(postionId);
appUserPositionTemp.setPhone(phone); appUserPositionTemp.setPhone(phone);
appUserPositionTemp.setUserId(0); appUserPositionTemp.setCompanyId(companyId);
if (Objects.nonNull(userLogin)) { appUserPositionTemp.setCompanyName(companyName);
appUserPositionTemp.setJobId(jobId);
if (userId!=null&&userId>0) {
//更新用户身份信息 //更新用户身份信息
detailBiz.updateUserPositionByUserId(userLogin.getId(), postionId); detailBiz.updateUserPositionByUserId(userId, postionId);
appUserPositionTemp.setUserId(userLogin.getId()); appUserPositionTemp.setUserId(userId);
}
if (id!=null&&id>0){
appUserPositionTemp.setId(id);
updateSelectiveById(appUserPositionTemp);
}else {
insertSelective(appUserPositionTemp);
} }
mapper.insertWithIgnoreRepeat(appUserPositionTemp);
} catch (BaseException ex) { } catch (BaseException ex) {
errorResultMap = new HashMap<>(1); errorResultMap = new HashMap<>(1);
errorResultMap.put("num", i); errorResultMap.put("num", i);
...@@ -229,4 +298,5 @@ public class AppUserPositionTempBiz extends BaseBiz<AppUserPositionTempMapper, A ...@@ -229,4 +298,5 @@ public class AppUserPositionTempBiz extends BaseBiz<AppUserPositionTempMapper, A
postionIdAndNameMap = appUserPositionBiz.findPostionIdAndNameMap() == null ? Collections.EMPTY_MAP : appUserPositionBiz.findPostionIdAndNameMap(); postionIdAndNameMap = appUserPositionBiz.findPostionIdAndNameMap() == null ? Collections.EMPTY_MAP : appUserPositionBiz.findPostionIdAndNameMap();
} }
} }
package com.github.wxiaoqi.security.admin.biz; package com.github.wxiaoqi.security.admin.biz;
import com.ace.cache.annotation.Cache; import com.ace.cache.annotation.Cache;
import com.ace.cache.annotation.CacheClear;
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.common.biz.BaseBiz; import com.github.wxiaoqi.security.common.biz.BaseBiz;
...@@ -52,6 +53,7 @@ public class UserMemberLevelBiz extends BaseBiz<BaseUserMemberLevelMapper,BaseUs ...@@ -52,6 +53,7 @@ public class UserMemberLevelBiz extends BaseBiz<BaseUserMemberLevelMapper,BaseUs
return levelAndDiscountMap; return levelAndDiscountMap;
} }
@CacheClear(key = "member")
public void updateMemberBaseInfo(BaseUserMemberLevel baseUserMemberLevel) { public void updateMemberBaseInfo(BaseUserMemberLevel baseUserMemberLevel) {
int affectRows = mapper.updateByPrimaryKeySelective(baseUserMemberLevel); int affectRows = mapper.updateByPrimaryKeySelective(baseUserMemberLevel);
if (affectRows==0){ if (affectRows==0){
......
package com.github.wxiaoqi.security.admin.mapper;
import com.github.wxiaoqi.security.admin.entity.AppUserJobLevel;
import tk.mybatis.mapper.additional.idlist.IdListMapper;
import tk.mybatis.mapper.common.Mapper;
/**
* 用户身份职位表
*
* @author libin
* @email 18178966185@163.com
* @date 2019-07-09 10:00:42
*/
public interface AppUserJobLevelMapper extends Mapper<AppUserJobLevel>, IdListMapper<AppUserJobLevel,Integer> {
}
package com.github.wxiaoqi.security.admin.rest.admin; package com.github.wxiaoqi.security.admin.rest.admin;
import com.github.wxiaoqi.security.admin.biz.AppUserJobLevelBiz;
import com.github.wxiaoqi.security.admin.biz.AppUserPositionBiz; import com.github.wxiaoqi.security.admin.biz.AppUserPositionBiz;
import com.github.wxiaoqi.security.admin.biz.AppUserPositionTempBiz; import com.github.wxiaoqi.security.admin.biz.AppUserPositionTempBiz;
import com.github.wxiaoqi.security.admin.dto.AppUserPositionTempDTO; import com.github.wxiaoqi.security.admin.dto.AppUserPositionTempDTO;
...@@ -30,9 +31,17 @@ public class AppUserPositionController { ...@@ -30,9 +31,17 @@ public class AppUserPositionController {
@Autowired @Autowired
private AppUserPositionBiz appUserPositionBiz; private AppUserPositionBiz appUserPositionBiz;
@Autowired
private AppUserJobLevelBiz jobLevelBiz;
@Autowired @Autowired
private AppUserPositionTempBiz appUserPositionTempBiz; private AppUserPositionTempBiz appUserPositionTempBiz;
@GetMapping("/jobs")
public ObjectRestResponse findAllJobs() {
return ObjectRestResponse.succ(jobLevelBiz.selectListAll());
}
@GetMapping("/postions") @GetMapping("/postions")
public ObjectRestResponse<List<WalletPostionVo>> findAllPostions() { public ObjectRestResponse<List<WalletPostionVo>> findAllPostions() {
List<WalletPostionVo> walletPostionVos = appUserPositionBiz.findAllPostions(); List<WalletPostionVo> walletPostionVos = appUserPositionBiz.findAllPostions();
...@@ -50,10 +59,19 @@ public class AppUserPositionController { ...@@ -50,10 +59,19 @@ public class AppUserPositionController {
* 新增或编辑身份信息 * 新增或编辑身份信息
* @return * @return
*/ */
@PostMapping("/add") @PostMapping("/addUserPostion")
public ObjectRestResponse<Void> addUserPostion(@RequestBody AppUserPositionTempDTO appUserPositionTempDTO){ public ObjectRestResponse<Void> addUserPostion(@RequestBody AppUserPositionTempDTO appUserPositionTempDTO){
appUserPositionTempBiz.add(appUserPositionTempDTO); return appUserPositionTempBiz.add(appUserPositionTempDTO);
return ObjectRestResponse.succ(); }
/**
* 新增或编辑身份信息
* @return
*/
@PostMapping("/updUserPostion")
public ObjectRestResponse<Void> updUserPostion(@RequestBody AppUserPositionTempDTO appUserPositionTempDTO){
return appUserPositionTempBiz.add(appUserPositionTempDTO);
} }
/** /**
......
...@@ -279,4 +279,18 @@ public class BaseOrder implements Serializable { ...@@ -279,4 +279,18 @@ public class BaseOrder implements Serializable {
@ApiModelProperty(value = "返回的优惠券") @ApiModelProperty(value = "返回的优惠券")
@Column(name = "back_coupon") @Column(name = "back_coupon")
String backCoupon; String backCoupon;
/**
* 促成人后台管理系统用户id
*/
@ApiModelProperty(value = "促成人后台管理系统用户id")
@Column(name = "facilitate_id")
Integer facilitateId;
/**
* 促成人联系方式
*/
@ApiModelProperty(value = "促成人联系方式")
@Column(name = "facilitate_phone")
String facilitatePhone;
} }
...@@ -33,4 +33,12 @@ public interface OrderDetail extends OrderItemInter { ...@@ -33,4 +33,12 @@ public interface OrderDetail extends OrderItemInter {
public void setAppUserDTO(AppUserDTO appUserDTO); public void setAppUserDTO(AppUserDTO appUserDTO);
// public Integer getFacilitateId();
//
// public void setFacilitateId(Integer facilitateId);
public String getFacilitatePhone();
public void setFacilitatePhone(String facilitatePhone);
} }
...@@ -11,6 +11,7 @@ import com.xxfc.platform.order.entity.OrderTourDetail; ...@@ -11,6 +11,7 @@ import com.xxfc.platform.order.entity.OrderTourDetail;
import com.xxfc.platform.order.entity.inter.OrderDetail; import com.xxfc.platform.order.entity.inter.OrderDetail;
import com.xxfc.platform.tour.entity.TourGood; import com.xxfc.platform.tour.entity.TourGood;
import com.xxfc.platform.tour.entity.TourUser; import com.xxfc.platform.tour.entity.TourUser;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data; import lombok.Data;
import java.util.List; import java.util.List;
...@@ -20,6 +21,12 @@ public class MemberBO extends OrderMemberDetail implements OrderDetail { ...@@ -20,6 +21,12 @@ public class MemberBO extends OrderMemberDetail implements OrderDetail {
private BaseOrder order; private BaseOrder order;
private BaseUserMemberLevel baseUserMemberLevel; private BaseUserMemberLevel baseUserMemberLevel;
AppUserDTO appUserDTO; AppUserDTO appUserDTO;
/**
* 促成人联系方式
*/
@ApiModelProperty(value = "促成人联系方式")
String facilitatePhone;
/** /**
* 下单来源,1--app;2--小程序 * 下单来源,1--app;2--小程序
*/ */
......
...@@ -25,6 +25,12 @@ public class RentVehicleBO extends OrderRentVehicleDetail implements OrderDetail ...@@ -25,6 +25,12 @@ public class RentVehicleBO extends OrderRentVehicleDetail implements OrderDetail
private Integer rentFreeDay; private Integer rentFreeDay;
private AppUserDTO appUserDTO; private AppUserDTO appUserDTO;
/**
* 促成人联系方式
*/
@ApiModelProperty(value = "促成人联系方式")
String facilitatePhone;
/** /**
* 下单来源,1--app;2--小程序 * 下单来源,1--app;2--小程序
*/ */
......
...@@ -11,6 +11,7 @@ import com.xxfc.platform.order.entity.inter.OrderDetail; ...@@ -11,6 +11,7 @@ import com.xxfc.platform.order.entity.inter.OrderDetail;
import com.xxfc.platform.tour.entity.TourGood; import com.xxfc.platform.tour.entity.TourGood;
import com.xxfc.platform.tour.entity.TourUser; import com.xxfc.platform.tour.entity.TourUser;
import com.xxfc.platform.vehicle.entity.VehicleModel; import com.xxfc.platform.vehicle.entity.VehicleModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data; import lombok.Data;
import java.util.List; import java.util.List;
...@@ -21,6 +22,11 @@ public class TourBO extends OrderTourDetail implements OrderDetail { ...@@ -21,6 +22,11 @@ public class TourBO extends OrderTourDetail implements OrderDetail {
TourGood tourGood; TourGood tourGood;
List<TourUser> tourUsers; List<TourUser> tourUsers;
AppUserDTO appUserDTO; AppUserDTO appUserDTO;
/**
* 促成人联系方式
*/
@ApiModelProperty(value = "促成人联系方式")
String facilitatePhone;
/** /**
* 下单来源,1--app;2--小程序 * 下单来源,1--app;2--小程序
......
...@@ -3,6 +3,8 @@ package com.xxfc.platform.order.pojo.order.add; ...@@ -3,6 +3,8 @@ package com.xxfc.platform.order.pojo.order.add;
import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiModelProperty;
import lombok.Data; import lombok.Data;
import javax.persistence.Column;
@Data @Data
public class AddOrderCommonDTO { public class AddOrderCommonDTO {
/** /**
...@@ -17,4 +19,16 @@ public class AddOrderCommonDTO { ...@@ -17,4 +19,16 @@ public class AddOrderCommonDTO {
*/ */
@ApiModelProperty(value = "优惠券ids") @ApiModelProperty(value = "优惠券ids")
private String couponIds; private String couponIds;
// /**
// * 促成人后台管理系统用户id
// */
// @ApiModelProperty(value = "促成人后台管理系统用户id")
// Integer facilitateId;
/**
* 促成人联系方式
*/
@ApiModelProperty(value = "促成人联系方式")
String facilitatePhone;
} }
...@@ -283,9 +283,11 @@ public class OrderMsgBiz { ...@@ -283,9 +283,11 @@ public class OrderMsgBiz {
if(null != orvd.getEndCompanyId() && !SYS_FALSE.equals(orvd.getEndCompanyId())) { if(null != orvd.getEndCompanyId() && !SYS_FALSE.equals(orvd.getEndCompanyId())) {
//新的账单 记录 OUT_ORDER_FUND 返回订单款取消订单 //新的账单 记录 OUT_ORDER_FUND 返回订单款取消订单
//查询 201, "取消订单退款" 并且状态为真
OrderAccount orderAccount = orderAccountBiz.selectOne(new OrderAccount(){{ OrderAccount orderAccount = orderAccountBiz.selectOne(new OrderAccount(){{
setOrderId(baseOrder.getId()); setOrderId(baseOrder.getId());
setAccountType(AccountTypeEnum.OUT_ORDER_FUND.getCode()); setAccountType(AccountTypeEnum.OUT_ORDER_FUND.getCode());
setAccountStatus(SYS_TRUE);
}}); }});
if(BigDecimal.ZERO.equals(orderAccount.getDeductAmount())) { if(BigDecimal.ZERO.equals(orderAccount.getDeductAmount())) {
...@@ -311,8 +313,6 @@ public class OrderMsgBiz { ...@@ -311,8 +313,6 @@ public class OrderMsgBiz {
sms2RefundAppUser(BigDecimal.ZERO, orderAccount.getDeductAmount(), orderAccount.getAccountAmount(), BigDecimal.ZERO, baseOrder, appUserDTO, smstype, smsParams); sms2RefundAppUser(BigDecimal.ZERO, orderAccount.getDeductAmount(), orderAccount.getAccountAmount(), BigDecimal.ZERO, baseOrder, appUserDTO, smstype, smsParams);
} }
//后台发送消息(出车人) //后台发送消息(出车人)
smsParams.clear(); smsParams.clear();
sms2BgUser(startCompanyDetail.getVehiceServicePhone(), startCompanyDetail, endCompanyDetail, orvd, otd, baseOrder, appUserDTO, SmsTemplateDTO.CANCEL_E, smsParams); sms2BgUser(startCompanyDetail.getVehiceServicePhone(), startCompanyDetail, endCompanyDetail, orvd, otd, baseOrder, appUserDTO, SmsTemplateDTO.CANCEL_E, smsParams);
...@@ -422,9 +422,11 @@ public class OrderMsgBiz { ...@@ -422,9 +422,11 @@ public class OrderMsgBiz {
OrderAccount orderAccount; OrderAccount orderAccount;
if(RefundStatusEnum.RESIDUE_ILLEGAL.getCode().equals(baseOrder.getRefundStatus())) { if(RefundStatusEnum.RESIDUE_ILLEGAL.getCode().equals(baseOrder.getRefundStatus())) {
smstype = SmsTemplateDTO.REFUND_A; smstype = SmsTemplateDTO.REFUND_A;
//查询 203, "部分押金(扣除该扣除的 + 保留违章预备金)" 并且状态为真
orderAccount = orderAccountBiz.selectOne(new OrderAccount(){{ orderAccount = orderAccountBiz.selectOne(new OrderAccount(){{
setOrderId(baseOrder.getId()); setOrderId(baseOrder.getId());
setAccountType(AccountTypeEnum.OUT_PART_DEPOSIT.getCode()); setAccountType(AccountTypeEnum.OUT_PART_DEPOSIT.getCode());
setAccountStatus(SYS_TRUE);
}}); }});
OrderAccountDetail oad = JSONUtil.toBean(orderAccount.getAccountDetail(), OrderAccountDetail.class); OrderAccountDetail oad = JSONUtil.toBean(orderAccount.getAccountDetail(), OrderAccountDetail.class);
...@@ -447,9 +449,11 @@ public class OrderMsgBiz { ...@@ -447,9 +449,11 @@ public class OrderMsgBiz {
residueAmount = orvd.getReturnPayResidue(); residueAmount = orvd.getReturnPayResidue();
}else if(RefundStatusEnum.REFUND_DEPOSIT.getCode().equals(baseOrder.getRefundStatus())){ }else if(RefundStatusEnum.REFUND_DEPOSIT.getCode().equals(baseOrder.getRefundStatus())){
smstype = SmsTemplateDTO.REFUND_B; smstype = SmsTemplateDTO.REFUND_B;
//查询 204, "剩余押金(扣除该扣除的)" 并且状态为真
orderAccount = orderAccountBiz.selectOne(new OrderAccount(){{ orderAccount = orderAccountBiz.selectOne(new OrderAccount(){{
setOrderId(baseOrder.getId()); setOrderId(baseOrder.getId());
setAccountType(AccountTypeEnum.OUT_RESIDUE_DEPOSIT.getCode()); setAccountType(AccountTypeEnum.OUT_RESIDUE_DEPOSIT.getCode());
setAccountStatus(SYS_TRUE);
}}); }});
originalAmount = orderAccount.getOriginalAmount(); originalAmount = orderAccount.getOriginalAmount();
violateAmount = orderAccount.getDeductAmount(); violateAmount = orderAccount.getDeductAmount();
......
...@@ -328,6 +328,7 @@ public class BackStageOrderController extends CommonBaseController implements Us ...@@ -328,6 +328,7 @@ public class BackStageOrderController extends CommonBaseController implements Us
//查询列表数据 //查询列表数据
Query query = baseOrderBiz.initQuery(dto.getNo()); Query query = baseOrderBiz.initQuery(dto.getNo());
query.put("crtUser", null); query.put("crtUser", null);
query.put("userId", null);
PageDataVO<OrderPageVO> page = PageDataVO.pageInfo(query, () -> baseOrderBiz.pageByParm(query.getSuper())); PageDataVO<OrderPageVO> page = PageDataVO.pageInfo(query, () -> baseOrderBiz.pageByParm(query.getSuper()));
OrderPageVO orderPageVO = page.getData().get(0); OrderPageVO orderPageVO = page.getData().get(0);
if(null == orderPageVO) { if(null == orderPageVO) {
......
...@@ -75,7 +75,7 @@ public class OrderRentVehicleController extends CommonBaseController { ...@@ -75,7 +75,7 @@ public class OrderRentVehicleController extends CommonBaseController {
bo.setAppUserDTO(userFeign.userDetailById(dto.getAppUserId()).getData()); bo.setAppUserDTO(userFeign.userDetailById(dto.getAppUserId()).getData());
bo.setCrtUser("-1"+ BaseContextHandler.getUserID()); bo.setCrtUser("-1"+ BaseContextHandler.getUserID());
//设置-1表示查询所有的车 //设置-1表示查询所有的车
bo.setUseType(-1); //bo.setUseType(-1);
orderRentVehicleService.createOrder(bo); orderRentVehicleService.createOrder(bo);
return ObjectRestResponse.succ(bo.getOrder()); return ObjectRestResponse.succ(bo.getOrder());
} }
......
...@@ -2,6 +2,7 @@ package com.xxfc.platform.order.service; ...@@ -2,6 +2,7 @@ package com.xxfc.platform.order.service;
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.github.wxiaoqi.security.admin.entity.AppUserLogin;
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.rest.UserRestInterface; import com.github.wxiaoqi.security.admin.feign.rest.UserRestInterface;
...@@ -25,6 +26,7 @@ import org.springframework.beans.factory.annotation.Autowired; ...@@ -25,6 +26,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.stream.Collectors; import java.util.stream.Collectors;
...@@ -66,12 +68,21 @@ public abstract class AbstractOrderHandle<Biz extends BaseBiz, Detail extends Or ...@@ -66,12 +68,21 @@ public abstract class AbstractOrderHandle<Biz extends BaseBiz, Detail extends Or
* 创建基础订单 * 创建基础订单
* @return * @return
*/ */
public BaseOrder createBaseOrder(Integer orderOrigin, AppUserDTO appUserDTO) { public BaseOrder createBaseOrder(Integer orderOrigin, String facilitatePhone, AppUserDTO appUserDTO) {
BaseOrder baseOrder = new BaseOrder(); BaseOrder baseOrder = new BaseOrder();
//设置下单来源 //设置下单来源
baseOrder.setOrderOrigin(orderOrigin); baseOrder.setOrderOrigin(orderOrigin);
//根据facilitatePhone 查询后台管理系统人员 未完成
if(StrUtil.isNotBlank(facilitatePhone)) {
baseOrder.setFacilitatePhone(facilitatePhone);
List<AppUserLogin> appUserDTOList = userFeign.getOne(facilitatePhone, null);
if(null != appUserDTOList && appUserDTOList.size() > 0) {
baseOrder.setFacilitateId(appUserDTOList.get(0).getId());
}
}
//设置订单号 //设置订单号
baseOrder.setNo(OrderUtil.GetOrderNumber("", OrderUtil.APP_MID)); baseOrder.setNo(OrderUtil.GetOrderNumber("", OrderUtil.APP_MID));
//设置订单类型 //设置订单类型
...@@ -89,12 +100,13 @@ public abstract class AbstractOrderHandle<Biz extends BaseBiz, Detail extends Or ...@@ -89,12 +100,13 @@ public abstract class AbstractOrderHandle<Biz extends BaseBiz, Detail extends Or
//设置用户id //设置用户id
baseOrder.setUserId(appUserDTO.getUserid()); baseOrder.setUserId(appUserDTO.getUserid());
baseOrder.setMemberLevel(appUserDTO.getMemberLevel()); baseOrder.setMemberLevel(appUserDTO.getMemberLevel());
return baseOrder; return baseOrder;
} }
public void initDetail(Detail detail) { public void initDetail(Detail detail) {
// Integer appUserId = (null == detail.getAppUserDTO())? Integer.valueOf(BaseContextHandler.getUserID()): detail.getAppUserDTO().getUserid(); // Integer appUserId = (null == detail.getAppUserDTO())? Integer.valueOf(BaseContextHandler.getUserID()): detail.getAppUserDTO().getUserid();
BaseOrder order = createBaseOrder(detail.getOrderOrigin(), detail.getAppUserDTO()); BaseOrder order = createBaseOrder(detail.getOrderOrigin(), detail.getFacilitatePhone(), detail.getAppUserDTO());
detail.setOrder(order); detail.setOrder(order);
} }
......
package com.xxfc.platform.tour.comstnt;
public enum WebsiteTourType {
POPULAR(1,"热门路线"),CHARACTERISTIC(2,"特色旅游"),
NEW(3,"新开辟路线"),RECOMMEND(4,"推荐路线");
private Integer code;
private String msg;
WebsiteTourType(Integer code, String msg) {
this.code = code;
this.msg = msg;
}
public Integer getCode() {
return code;
}
public String getMsg() {
return msg;
}
}
package com.xxfc.platform.tour.entity;
import lombok.Data;
import java.util.List;
@Data
public class WebsiteQuery {
private Integer limit=6;
private Integer type = 1;
private List<Integer> tagIds;
}
...@@ -13,6 +13,7 @@ import com.github.wxiaoqi.security.common.util.RandomUtil; ...@@ -13,6 +13,7 @@ import com.github.wxiaoqi.security.common.util.RandomUtil;
import com.github.wxiaoqi.security.common.util.process.ResultCode; import com.github.wxiaoqi.security.common.util.process.ResultCode;
import com.github.wxiaoqi.security.common.vo.GoodDataVO; import com.github.wxiaoqi.security.common.vo.GoodDataVO;
import com.github.wxiaoqi.security.common.vo.PageDataVO; import com.github.wxiaoqi.security.common.vo.PageDataVO;
import com.google.common.collect.Lists;
import com.xxfc.platform.tour.dto.*; import com.xxfc.platform.tour.dto.*;
import com.xxfc.platform.tour.entity.*; import com.xxfc.platform.tour.entity.*;
import com.xxfc.platform.tour.mapper.*; import com.xxfc.platform.tour.mapper.*;
...@@ -20,8 +21,12 @@ import com.xxfc.platform.tour.vo.TourGoodVo; ...@@ -20,8 +21,12 @@ import com.xxfc.platform.tour.vo.TourGoodVo;
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.collections.CollectionUtils; import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import tk.mybatis.mapper.entity.Example;
import java.lang.reflect.InvocationTargetException; import java.lang.reflect.InvocationTargetException;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.math.RoundingMode; import java.math.RoundingMode;
...@@ -38,6 +43,11 @@ import java.util.*; ...@@ -38,6 +43,11 @@ import java.util.*;
@Slf4j @Slf4j
public class TourGoodBiz extends BaseBiz<TourGoodMapper, TourGood> { public class TourGoodBiz extends BaseBiz<TourGoodMapper, TourGood> {
@Value("${officialWebsite.popular}")
private String popular;
@Value("${officialWebsite.characteristic}")
private String characteristic;
@Autowired @Autowired
private TourGoodBannerBiz bannerBiz; private TourGoodBannerBiz bannerBiz;
@Autowired @Autowired
...@@ -322,7 +332,7 @@ public class TourGoodBiz extends BaseBiz<TourGoodMapper, TourGood> { ...@@ -322,7 +332,7 @@ public class TourGoodBiz extends BaseBiz<TourGoodMapper, TourGood> {
*/ */
public List<GoodDataVO> getAllByHome(Integer page, Integer limit){ public List<GoodDataVO> getAllByHome(Integer page, Integer limit){
return mapper.findAllByHome((page-1)*limit,limit); return mapper.findAllByHome((page-1)*limit,limit);
}; }
/** /**
* 获取指定数量的随机旅游路线 * 获取指定数量的随机旅游路线
...@@ -345,6 +355,48 @@ public class TourGoodBiz extends BaseBiz<TourGoodMapper, TourGood> { ...@@ -345,6 +355,48 @@ public class TourGoodBiz extends BaseBiz<TourGoodMapper, TourGood> {
} }
return ObjectRestResponse.succ(resultList); return ObjectRestResponse.succ(resultList);
} }
public List homePageTour(WebsiteQuery query) {
if (Objects.isNull(query)) {
return new ArrayList();
}
setQueryTagIds(query);
List<TourGood> list = mapper.getList(query);
return CollectionUtils.isNotEmpty(list)?list:new ArrayList<>();
}
private void setQueryTagIds(WebsiteQuery query) {
if (CollectionUtils.isEmpty(query.getTagIds())) {
List<Integer> list=new ArrayList<>();
Integer type = query.getType();
if (type==1) {
if (StringUtils.isNotBlank(popular)) {
String[] popularIds = popular.split(",");
for (String id : popularIds) {
list.add(Integer.parseInt(id));
}
}
}
if (type==2) {
if (StringUtils.isNotBlank(characteristic)) {
String[] characteristicIds = characteristic.split(",");
for (String id : characteristicIds) {
list.add(Integer.parseInt(id));
}
}
}
query.setTagIds(list);
}
}
public List newTour(Integer limit) {
List list = mapper.newTour(limit);
return CollectionUtils.isNotEmpty(list)?list:new ArrayList<>();
}
} }
...@@ -3,6 +3,7 @@ package com.xxfc.platform.tour.mapper; ...@@ -3,6 +3,7 @@ package com.xxfc.platform.tour.mapper;
import com.github.wxiaoqi.security.common.vo.GoodDataVO; import com.github.wxiaoqi.security.common.vo.GoodDataVO;
import com.xxfc.platform.tour.dto.GoodSearchDTO; import com.xxfc.platform.tour.dto.GoodSearchDTO;
import com.xxfc.platform.tour.entity.TourGood; import com.xxfc.platform.tour.entity.TourGood;
import com.xxfc.platform.tour.entity.WebsiteQuery;
import com.xxfc.platform.tour.vo.TourGoodVo; import com.xxfc.platform.tour.vo.TourGoodVo;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
import tk.mybatis.mapper.common.Mapper; import tk.mybatis.mapper.common.Mapper;
...@@ -36,4 +37,8 @@ public interface TourGoodMapper extends Mapper<TourGood> { ...@@ -36,4 +37,8 @@ public interface TourGoodMapper extends Mapper<TourGood> {
* @return * @return
*/ */
List<GoodDataVO> findAllByHome(@Param("start") Integer start, @Param("size") Integer size); List<GoodDataVO> findAllByHome(@Param("start") Integer start, @Param("size") Integer size);
List<TourGood> getList(WebsiteQuery query);
List newTour(Integer limit);
} }
package com.xxfc.platform.tour.rest.officialWebsite;
import com.github.wxiaoqi.security.auth.client.annotation.IgnoreClientToken;
import com.github.wxiaoqi.security.auth.client.annotation.IgnoreUserToken;
import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
import com.github.wxiaoqi.security.common.rest.BaseController;
import com.xxfc.platform.tour.biz.TourGoodBiz;
import com.xxfc.platform.tour.comstnt.WebsiteTourType;
import com.xxfc.platform.tour.entity.TourGood;
import com.xxfc.platform.tour.entity.WebsiteQuery;
import io.swagger.annotations.Api;
import org.springframework.web.bind.annotation.*;
@RestController
@RequestMapping("website")
@IgnoreClientToken
@IgnoreUserToken
@Api(tags = {"官网"})
public class OfficialWebsiteTourController extends BaseController<TourGoodBiz, TourGood> {
@PostMapping("/app/unauth/tour")
public ObjectRestResponse homePageTour(@RequestBody WebsiteQuery query) throws Exception {
return ObjectRestResponse.succ(baseBiz.homePageTour(query));
}
@GetMapping("/app/unauth/tour/new")
public ObjectRestResponse newTour(@RequestParam(value = "limit", defaultValue = "6") Integer limit) {
return ObjectRestResponse.succ(baseBiz.newTour(limit));
}
}
\ No newline at end of file
...@@ -4,4 +4,4 @@ logging: ...@@ -4,4 +4,4 @@ logging:
com.github.wxiaoqi: com.github.wxiaoqi:
debug debug
com.xxfc.platform: com.xxfc.platform:
debug debug
\ No newline at end of file
...@@ -3,7 +3,7 @@ ...@@ -3,7 +3,7 @@
<mapper namespace="com.xxfc.platform.tour.mapper.TourGoodMapper"> <mapper namespace="com.xxfc.platform.tour.mapper.TourGoodMapper">
<!-- 可根据自己的需求,是否要使用 --> <!-- 可根据自己的需求,是否要使用 -->
<resultMap type="com.xxfc.platform.tour.entity.TourGood" id="tourGoodMap"> <resultMap type="com.xxfc.platform.tour.entity.TourGood" id="tourGoodMap">
<result property="id" column="id"/> <result property="id" column="id"/>
<result property="name" column="name"/> <result property="name" column="name"/>
...@@ -53,26 +53,28 @@ ...@@ -53,26 +53,28 @@
<!--查询旅游路线列表--> <!--查询旅游路线列表-->
<select id="getCoordinateList" parameterType="java.util.Map" resultMap="tourGoodMap"> <select id="getCoordinateList" parameterType="java.util.Map" resultMap="tourGoodMap">
SELECT t.* from tour_good t SELECT t.* from tour_good t
left join ( left join (
select good_id, select good_id,
IFNULL(ROUND(( (2 * ASIN( SQRT( POW( SIN((latitude * PI() / 180.0- #{params.latitude}* PI() / 180.0)/2), 2)+COS( latitude * PI() / 180.0)*COS( #{params.latitude} * PI() / 180.0) IFNULL(ROUND(( (2 * ASIN( SQRT( POW( SIN((latitude * PI() / 180.0- #{params.latitude}* PI() / 180.0)/2), 2)+COS(
*POW(SIN((longitude * PI() / 180.0 - #{params.longitude}* PI() /180.0)/2),2))))*6378.137)*10000)/10000 ,0 ) AS distance latitude * PI() / 180.0)*COS( #{params.latitude} * PI() / 180.0)
FROM tour_good_site WHERE type=2 ) gs ON t.id=gs.good_id *POW(SIN((longitude * PI() / 180.0 - #{params.longitude}* PI() /180.0)/2),2))))*6378.137)*10000)/10000 ,0 ) AS
where t.is_del=0 AND t.status=1 distance
FROM tour_good_site WHERE type=2 ) gs ON t.id=gs.good_id
where t.is_del=0 AND t.status=1
<if test="params.distance != null and params.distance != ''and params.distance >0"> <if test="params.distance != null and params.distance != ''and params.distance >0">
and gs.distance &lt; #{params.distance} and gs.distance &lt; #{params.distance}
</if> </if>
<if test="params.query != null and params.query != ''"> <if test="params.query != null and params.query != ''">
and (t.`name` like CONCAT('%',#{params.query},'%') or t.introduce like CONCAT('%',#{params.query},'%')) and (t.`name` like CONCAT('%',#{params.query},'%') or t.introduce like CONCAT('%',#{params.query},'%'))
</if> </if>
order by gs.distance order by gs.distance
</select> </select>
<!--查询旅游路线列表--> <!--查询旅游路线列表-->
<select id="getGoodList" parameterType="java.util.Map" resultMap="tourGoodMap"> <select id="getGoodList" parameterType="java.util.Map" resultMap="tourGoodMap">
SELECT * from tour_good t SELECT * from tour_good t
where t.is_del=0 AND t.status=1 where t.is_del=0 AND t.status=1
<if test="params.query != null and params.query != ''"> <if test="params.query != null and params.query != ''">
and (t.`name` like CONCAT('%',#{params.query},'%') or t.introduce like CONCAT('%',#{params.query},'%')) and (t.`name` like CONCAT('%',#{params.query},'%') or t.introduce like CONCAT('%',#{params.query},'%'))
</if> </if>
...@@ -103,22 +105,63 @@ ...@@ -103,22 +105,63 @@
<!--后台查询旅游路线列表--> <!--后台查询旅游路线列表-->
<select id="findGoodList" resultMap="tourGoodVoMap"> <select id="findGoodList" resultMap="tourGoodVoMap">
SELECT g.*,REPLACE(GROUP_CONCAT( DISTINCT t.`name`),',','|')as tagNames from tour_good g SELECT g.*,REPLACE(GROUP_CONCAT( DISTINCT t.`name`),',','|')as tagNames from tour_good g
LEFT JOIN (SELECT * FROM tour_good_tag WHERE is_del=0) tag ON g.id=tag.good_id LEFT JOIN (SELECT * FROM tour_good_tag WHERE is_del=0) tag ON g.id=tag.good_id
LEFT JOIN (SELECT * FROM tour_tag WHERE is_del=0) t ON tag.tag_id=t.id LEFT JOIN (SELECT * FROM tour_tag WHERE is_del=0) t ON tag.tag_id=t.id
<where> <where>
g.is_del=0 g.is_del=0
<if test="params.name != null and params.name != ''"> <if test="params.name != null and params.name != ''">
and (g.`name` like CONCAT('%',#{params.name},'%') or g.introduce like CONCAT('%',#{params.name},'%')) and (g.`name` like CONCAT('%',#{params.name},'%') or g.introduce like CONCAT('%',#{params.name},'%'))
</if> </if>
<if test="params.tagId != null and params.tagId != '' "> <if test="params.tagId != null and params.tagId != '' ">
and g.id in (SELECT good_id from tour_good_tag and g.id in (SELECT good_id from tour_good_tag
where tag_id = #{params.tagId} and is_del=0 ) where tag_id = #{params.tagId} and is_del=0 )
</if> </if>
</where> </where>
GROUP BY g.id GROUP BY g.id
ORDER BY g.rank DESC ,g.id DESC ORDER BY g.rank DESC ,g.id DESC
</select> </select>
<select id="getList" resultType="com.github.wxiaoqi.security.common.vo.GoodDataVO">
SELECT
g.id AS `id`,
g. NAME AS `name`,
g.cover AS `imgUrl`,
g.price
FROM
tour_good g,
tour_good_tag t
WHERE
g.id = t.good_id
AND g.is_del = 0
AND t.is_del = 0
AND g.status = 1
AND t.tag_id IN
<foreach collection="tagIds" index="index" item="item" open="(" separator="," close=")">
#{item}
</foreach>
GROUP BY g.id
ORDER BY
g.rank ASC,
g.crt_time DESC
LIMIT #{limit}
</select>
<select id="newTour" resultType="com.github.wxiaoqi.security.common.vo.GoodDataVO">
SELECT
id,
name,
cover AS imgUrl,
price
FROM
tour_good
WHERE
is_del = 0
AND
status = 1
ORDER BY
crt_time DESC
LIMIT #{limit}
</select>
</mapper> </mapper>
\ No newline at end of file
...@@ -107,8 +107,8 @@ public class ArticleBiz extends BaseBiz<ArticleMapper, Article> { ...@@ -107,8 +107,8 @@ public class ArticleBiz extends BaseBiz<ArticleMapper, Article> {
* @param type * @param type
* @return * @return
*/ */
public List getHomePageArticle(Integer type) { public List getHomePageArticle(Integer type,Integer limit) {
List<Article> articleList = mapper.getArticleList(type,HOME_PAGE_NUMBER,null,null); List<Article> articleList = mapper.getArticleList(type,limit,null,null);
// if (Objects.isNull(articleList)) { // if (Objects.isNull(articleList)) {
// return new ArrayList(); // return new ArrayList();
// } else { // } else {
......
...@@ -55,8 +55,9 @@ public class ArticleController extends BaseController<ArticleBiz, Article> { ...@@ -55,8 +55,9 @@ public class ArticleController extends BaseController<ArticleBiz, Article> {
@GetMapping("/app/unauth/homePage/{type}") @GetMapping("/app/unauth/homePage/{type}")
@ApiOperation(value = "获取首页文章列表") @ApiOperation(value = "获取首页文章列表")
public ObjectRestResponse getHomePageArticle(@PathVariable Integer type){ public ObjectRestResponse getHomePageArticle(@PathVariable Integer type
return ObjectRestResponse.succ(baseBiz.getHomePageArticle(type)); ,@RequestParam(value = "limit",defaultValue = "9") Integer limit){
return ObjectRestResponse.succ(baseBiz.getHomePageArticle(type,limit));
} }
@Override @Override
......
...@@ -4,12 +4,17 @@ import com.github.wxiaoqi.security.auth.client.annotation.IgnoreClientToken; ...@@ -4,12 +4,17 @@ import com.github.wxiaoqi.security.auth.client.annotation.IgnoreClientToken;
import com.github.wxiaoqi.security.auth.client.annotation.IgnoreUserToken; import com.github.wxiaoqi.security.auth.client.annotation.IgnoreUserToken;
import com.github.wxiaoqi.security.common.msg.ObjectRestResponse; import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
import com.github.wxiaoqi.security.common.rest.CommonBaseController; import com.github.wxiaoqi.security.common.rest.CommonBaseController;
import com.xxfc.platform.tour.entity.TourTag;
import com.xxfc.platform.tour.feign.TourFeign; import com.xxfc.platform.tour.feign.TourFeign;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j; 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.Comparator;
import java.util.List;
import java.util.stream.Collectors;
@RestController @RestController
@RequestMapping("app/unauth/tour") @RequestMapping("app/unauth/tour")
@Slf4j @Slf4j
...@@ -47,8 +52,9 @@ public class GwTourController extends CommonBaseController { ...@@ -47,8 +52,9 @@ public class GwTourController extends CommonBaseController {
@GetMapping("/tagList") @GetMapping("/tagList")
@IgnoreUserToken @IgnoreUserToken
public ObjectRestResponse getTagList(@RequestParam(value = "isHot", defaultValue = "0") Integer isHot) { public ObjectRestResponse getTagList(@RequestParam(value = "isHot", defaultValue = "0") Integer isHot) {
List<TourTag> tourTags = tourFeign.tagList(isHot);
return ObjectRestResponse.succ(tourFeign.tagList(isHot)); tourTags = tourTags.stream().filter(x -> !x.getName().contains("全部")).sorted(Comparator.comparing(TourTag::getRank)).collect(Collectors.toList());
return ObjectRestResponse.succ(tourTags);
} }
} }
package com.xxfc.platform.uccn.rest;
import com.github.wxiaoqi.security.admin.entity.BaseUserMemberLevel;
import com.github.wxiaoqi.security.admin.feign.UserFeign;
import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
/**
* @author libin
* @version 1.0
* @description
* @data 2019/10/17 9:37
*/
@RestController
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
@RequestMapping("/member_level/app/unauth")
public class MemberLevelController {
private final UserFeign userFeign;
@GetMapping("/list")
public ObjectRestResponse<BaseUserMemberLevel> listMemberLevels(){
List<BaseUserMemberLevel> levels = userFeign.levels();
return ObjectRestResponse.succ(levels);
}
}
...@@ -5,7 +5,7 @@ import com.xxfc.platform.universal.biz.UserMessage; ...@@ -5,7 +5,7 @@ import com.xxfc.platform.universal.biz.UserMessage;
import java.util.Map; import java.util.Map;
/** /**
* 用户认证 * 用户认证接口 (使用@Primary实现的优先级提升优先级)
* @author Administrator * @author Administrator
*/ */
public interface UserAuthentication { public interface UserAuthentication {
......
...@@ -25,7 +25,7 @@ import java.util.Map; ...@@ -25,7 +25,7 @@ import java.util.Map;
*/ */
@Service @Service
@Slf4j @Slf4j
@Primary //@Primary
public class BJCYAuthentication implements UserAuthentication { public class BJCYAuthentication implements UserAuthentication {
private final String host = "http://aliyunverifyidcard.haoservice.com"; private final String host = "http://aliyunverifyidcard.haoservice.com";
private final String path = "/idcard/VerifyIdcardv2"; private final String path = "/idcard/VerifyIdcardv2";
...@@ -39,7 +39,8 @@ public class BJCYAuthentication implements UserAuthentication { ...@@ -39,7 +39,8 @@ public class BJCYAuthentication implements UserAuthentication {
private final String ret="error_code"; private final String ret="error_code";
@Override @Override
public boolean certificate(UserMessage message) { public boolean certificate(UserMessage message) {
Map<String, String> headers = new HashMap<String, String>(); return true;
/*Map<String, String> headers = new HashMap<String, String>();
headers.put(tokenHead, token); headers.put(tokenHead, token);
Map<String, String> querys = new HashMap<String, String>(); Map<String, String> querys = new HashMap<String, String>();
querys.put(cardNo, message.getIdNumber()); querys.put(cardNo, message.getIdNumber());
...@@ -66,7 +67,7 @@ public class BJCYAuthentication implements UserAuthentication { ...@@ -66,7 +67,7 @@ public class BJCYAuthentication implements UserAuthentication {
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }
return false; return false;*/
} }
} }
......
...@@ -12,6 +12,7 @@ import org.apache.commons.lang.StringUtils; ...@@ -12,6 +12,7 @@ import org.apache.commons.lang.StringUtils;
import org.apache.http.HttpResponse; import org.apache.http.HttpResponse;
import org.apache.http.StatusLine; import org.apache.http.StatusLine;
import org.apache.http.util.EntityUtils; import org.apache.http.util.EntityUtils;
import org.springframework.context.annotation.Primary;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.HashMap; import java.util.HashMap;
...@@ -24,6 +25,7 @@ import java.util.Map; ...@@ -24,6 +25,7 @@ import java.util.Map;
*/ */
@Service @Service
@Slf4j @Slf4j
@Primary
public class XCFQAuthentication implements UserAuthentication { public class XCFQAuthentication implements UserAuthentication {
private String cAppcode="acea1c8811f748b3a65815f11db357c4"; private String cAppcode="acea1c8811f748b3a65815f11db357c4";
...@@ -33,10 +35,8 @@ public class XCFQAuthentication implements UserAuthentication { ...@@ -33,10 +35,8 @@ public class XCFQAuthentication implements UserAuthentication {
*/ */
private String cHost = "https://idcert.market.alicloudapi.com"; private String cHost = "https://idcert.market.alicloudapi.com";
private String cPath = "/idcard"; private String cPath = "/idcard";
private String cMethod = "GET"; private String cMethod = "GET";
//响应:认证错误码字段名 //响应:认证错误码字段名
...@@ -45,7 +45,6 @@ public class XCFQAuthentication implements UserAuthentication { ...@@ -45,7 +45,6 @@ public class XCFQAuthentication implements UserAuthentication {
//响应:认证通过码 //响应:认证通过码
private String certifResultCode = "01"; private String certifResultCode = "01";
//请求:身份证号字段名 //请求:身份证号字段名
private String idCardName = "idCard"; private String idCardName = "idCard";
...@@ -55,11 +54,9 @@ public class XCFQAuthentication implements UserAuthentication { ...@@ -55,11 +54,9 @@ public class XCFQAuthentication implements UserAuthentication {
@Override @Override
public boolean certificate(UserMessage message) { public boolean certificate(UserMessage message) {
//map携带身份证和姓名进行认证 //map携带身份证和姓名进行认证
Map<String, String> querys = new HashMap<>(); Map<String, String> querys = new HashMap<>();
querys.put(idCardName, message.getIdNumber()); querys.put(idCardName, message.getIdNumber());
querys.put(cName, message.getName()); querys.put(cName, message.getName());
Map<String, String> headers = new HashMap<String, String>(); Map<String, String> headers = new HashMap<String, String>();
headers.put("Authorization", "APPCODE " + cAppcode); headers.put("Authorization", "APPCODE " + cAppcode);
try { try {
......
...@@ -30,7 +30,7 @@ public interface VehicleFeign { ...@@ -30,7 +30,7 @@ public interface VehicleFeign {
public ObjectRestResponse<Vehicle> get(@PathVariable(value = "id") String id); public ObjectRestResponse<Vehicle> get(@PathVariable(value = "id") String id);
@RequestMapping(value = "/vehicleInfo/findById", method = RequestMethod.GET) @RequestMapping(value = "/vehicleInfo/findById", method = RequestMethod.GET)
public RestResponse<Vehicle> findById(@RequestParam(value = "id")String id); public RestResponse<Vehicle> findById(@RequestParam(value = "id") String id);
@RequestMapping(value = "/vehicleInfo/getByIds", method = RequestMethod.GET) @RequestMapping(value = "/vehicleInfo/getByIds", method = RequestMethod.GET)
public RestResponse< List<Vehicle>> getByIds(@RequestParam(value = "ids") List<String> id); public RestResponse< List<Vehicle>> getByIds(@RequestParam(value = "ids") List<String> id);
...@@ -44,11 +44,11 @@ public interface VehicleFeign { ...@@ -44,11 +44,11 @@ public interface VehicleFeign {
public RestResponse arrivalBySmall(@RequestBody VehicleArrivalVo arrivalVo); public RestResponse arrivalBySmall(@RequestBody VehicleArrivalVo arrivalVo);
@GetMapping(value = "/vehicleModel/app/unauth/findRandomVehicle") @GetMapping(value = "/vehicleModel/app/unauth/findRandomVehicle")
public ObjectRestResponse findRandomVehicle(@RequestParam(value="number")Integer number); public ObjectRestResponse findRandomVehicle(@RequestParam(value = "number") Integer number);
//修改评分 //修改评分
@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);
@RequestMapping(value = "/vehicleInfo/rent/book/vehicle", method = RequestMethod.POST) @RequestMapping(value = "/vehicleInfo/rent/book/vehicle", method = RequestMethod.POST)
public ObjectRestResponse<VehicleBookRecord> rentApplyVehicle(@RequestBody RentVehicleBookDTO rentVehicleBookDTO); public ObjectRestResponse<VehicleBookRecord> rentApplyVehicle(@RequestBody RentVehicleBookDTO rentVehicleBookDTO);
...@@ -71,25 +71,29 @@ public interface VehicleFeign { ...@@ -71,25 +71,29 @@ public interface VehicleFeign {
//获取分公司列表 //获取分公司列表
@GetMapping("/branchCompany/all") @GetMapping("/branchCompany/all")
public List<BranchCompany> companyAll( public List<BranchCompany> companyAll(
@RequestParam(value = "dataAll")Integer dataAll, @RequestParam(value = "dataAll") Integer dataAll,
@RequestParam(value = "dataCompany")String dataCompany, @RequestParam(value = "dataCompany") String dataCompany,
@RequestParam(value = "dataZone")String dataZone); @RequestParam(value = "dataZone") String dataZone);
//获取分公司列表
@GetMapping("/company/base/app/unauth/companyId")
public BranchCompany companyId(@RequestParam(value = "name") String name);
@GetMapping("/branchCompany/entityList") @GetMapping("/branchCompany/entityList")
public ObjectRestResponse<List<BranchCompany>> branchCompanyEntityList(@RequestParam("entity") Map<String, Object> entity); public ObjectRestResponse<List<BranchCompany>> branchCompanyEntityList(@RequestParam("entity") Map<String, Object> entity);
@RequestMapping(value = "/user/license/one", method = RequestMethod.GET) @RequestMapping(value = "/user/license/one", method = RequestMethod.GET)
public RestResponse<VehicleUserLicense> one(@RequestParam(value="id",defaultValue="0")Integer id) throws Exception; public RestResponse<VehicleUserLicense> one(@RequestParam(value = "id", defaultValue = "0") Integer id) throws Exception;
@RequestMapping(value = "/user/license/company/getOne", method = RequestMethod.GET) @RequestMapping(value = "/user/license/company/getOne", method = RequestMethod.GET)
public RestResponse<VehicleUserLicense> getOne( public RestResponse<VehicleUserLicense> getOne(
@RequestParam(value="id",defaultValue="0")Integer id) throws Exception ; @RequestParam(value = "id", defaultValue = "0") Integer id) throws Exception ;
@RequestMapping(value = "/user/license/multi", method = RequestMethod.GET) @RequestMapping(value = "/user/license/multi", method = RequestMethod.GET)
public ObjectRestResponse<List<VehicleUserLicense>> multi(@RequestBody QueryMultiDTO dto) throws Exception; public ObjectRestResponse<List<VehicleUserLicense>> multi(@RequestBody QueryMultiDTO dto) throws Exception;
@GetMapping("/user/license/getVehicleLicenseList") @GetMapping("/user/license/getVehicleLicenseList")
public ObjectRestResponse<List<VehicleUserLicense>> getVehicleLicenseList(@RequestParam(value="ids") String ids); public ObjectRestResponse<List<VehicleUserLicense>> getVehicleLicenseList(@RequestParam(value = "ids") String ids);
/** /**
* 获取优质车型接口 * 获取优质车型接口
...@@ -122,8 +126,8 @@ public interface VehicleFeign { ...@@ -122,8 +126,8 @@ public interface VehicleFeign {
* @return * @return
*/ */
@GetMapping("/city/corporationCity") @GetMapping("/city/corporationCity")
ObjectRestResponse<Set<Integer>> corporationCity( @RequestParam(value = "zoneList") String zoneList, ObjectRestResponse<Set<Integer>> corporationCity(@RequestParam(value = "zoneList") String zoneList,
@RequestParam(value = "companyList") String companyList); @RequestParam(value = "companyList") String companyList);
@GetMapping("/accompanyingItem/app/unauth/items") @GetMapping("/accompanyingItem/app/unauth/items")
...@@ -163,7 +167,7 @@ public interface VehicleFeign { ...@@ -163,7 +167,7 @@ public interface VehicleFeign {
PageDataVO<BranchCompanyListVO> findBranchCompanyWithPage(@RequestBody BranchCompanyFindDTO branchCompanyFindDTO); PageDataVO<BranchCompanyListVO> findBranchCompanyWithPage(@RequestBody BranchCompanyFindDTO branchCompanyFindDTO);
@GetMapping("/vehicleInfo/findVehicleIds") @GetMapping("/vehicleInfo/findVehicleIds")
List<String> findbyPlateNumberAndVehicleCod(@RequestParam(value = "plateNumber") String plateNumber,@RequestParam(value = "vehicleCode") String vehicleCode); List<String> findbyPlateNumberAndVehicleCod(@RequestParam(value = "plateNumber") String plateNumber, @RequestParam(value = "vehicleCode") String vehicleCode);
@RequestMapping(value = "/vehicleInfo/bookRecord/update", method = RequestMethod.POST) @RequestMapping(value = "/vehicleInfo/bookRecord/update", method = RequestMethod.POST)
public ObjectRestResponse update(@RequestBody BookRecordUpdateLog bookRecordUpdateLog); public ObjectRestResponse update(@RequestBody BookRecordUpdateLog bookRecordUpdateLog);
......
...@@ -59,4 +59,6 @@ public class VehicleBookRecordQueryVo extends PageParam { ...@@ -59,4 +59,6 @@ public class VehicleBookRecordQueryVo extends PageParam {
private List<Integer> companyIds; private List<Integer> companyIds;
private String upkeepIds; private String upkeepIds;
private Integer userCompany; private Integer userCompany;
private Integer zoneId;
} }
\ No newline at end of file
...@@ -20,6 +20,7 @@ public class BranchCompanyListDTO { ...@@ -20,6 +20,7 @@ public class BranchCompanyListDTO {
*/ */
@ApiModelProperty("分公司名称") @ApiModelProperty("分公司名称")
private String name; private String name;
private String companyName;
/** /**
* 公司封面 * 公司封面
*/ */
......
...@@ -20,6 +20,7 @@ public class BranchCompanyListVO { ...@@ -20,6 +20,7 @@ public class BranchCompanyListVO {
*/ */
@ApiModelProperty("分公司名称") @ApiModelProperty("分公司名称")
private String name; private String name;
private String companyName;
/** /**
* 公司封面 * 公司封面
*/ */
......
...@@ -198,6 +198,35 @@ public class CompanyBaseBiz extends BaseBiz<CompanyBaseMapper, CompanyBase> { ...@@ -198,6 +198,35 @@ public class CompanyBaseBiz extends BaseBiz<CompanyBaseMapper, CompanyBase> {
return ObjectRestResponse.succ(); return ObjectRestResponse.succ();
} }
//临时数据同步6
public ObjectRestResponse synchro6(){
List<CompanyBase> list= mapper.getBaseList();
if (list.size()>0){
int num=0;
for (CompanyBase companyBase:list){
String name=companyBase.getName();
BranchCompany branchCompany=new BranchCompany();
branchCompany.setCompanyBaseId(companyBase.getId());
name= name.substring(name.indexOf("(")+1,name.indexOf(")"));
name+="分公司";
log.info("----name=="+name);
branchCompany.setName(name);
branchCompany.setAddrProvince(companyBase.getAddrProvince());
branchCompany.setProvinceName(companyBase.getProvinceName());
branchCompany.setAddrCity(companyBase.getAddrCity());
branchCompany.setCityName(companyBase.getCityName());
branchCompany.setAddrTown(companyBase.getAddrTown());
branchCompany.setTownName(companyBase.getTownName());
branchCompany.setZoneId(companyBase.getZoneId());
branchCompany.setStatus(1);
branchCompanyBiz.insertSelective(branchCompany);
num++;
log.info("----成功---num=="+num+"---companyBaseId==="+companyBase.getId());
}
}
return ObjectRestResponse.succ();
}
//临时数据同步3 //临时数据同步3
public ObjectRestResponse synchro3(){ public ObjectRestResponse synchro3(){
List<BranchCompanyStockInfo> list= stockInfoMapper.selectAll(); List<BranchCompanyStockInfo> list= stockInfoMapper.selectAll();
...@@ -434,4 +463,8 @@ public class CompanyBaseBiz extends BaseBiz<CompanyBaseMapper, CompanyBase> { ...@@ -434,4 +463,8 @@ public class CompanyBaseBiz extends BaseBiz<CompanyBaseMapper, CompanyBase> {
return companyBaseVo; return companyBaseVo;
} }
public BranchCompany getCompanyId(String name){
return mapper.getCompanyId(name);
}
} }
package com.xxfc.platform.vehicle.mapper; package com.xxfc.platform.vehicle.mapper;
import com.xxfc.platform.vehicle.entity.BranchCompany;
import com.xxfc.platform.vehicle.entity.CompanyBase; import com.xxfc.platform.vehicle.entity.CompanyBase;
import com.xxfc.platform.vehicle.pojo.dto.CompanyBaseDetailDTO; import com.xxfc.platform.vehicle.pojo.dto.CompanyBaseDetailDTO;
import com.xxfc.platform.vehicle.pojo.vo.CompanyVo; import com.xxfc.platform.vehicle.pojo.vo.CompanyVo;
...@@ -25,4 +26,8 @@ public interface CompanyBaseMapper extends Mapper<CompanyBase> { ...@@ -25,4 +26,8 @@ public interface CompanyBaseMapper extends Mapper<CompanyBase> {
CompanyBaseDetailDTO findCompanyBaseById(@Param("id") Integer id); CompanyBaseDetailDTO findCompanyBaseById(@Param("id") Integer id);
List<CompanyBase> getList(CompanyVo companyVo); List<CompanyBase> getList(CompanyVo companyVo);
List<CompanyBase> getBaseList();
BranchCompany getCompanyId(@Param("name") String name);
} }
\ No newline at end of file
...@@ -142,7 +142,7 @@ public class RentVehicleController extends BaseController<VehicleBiz> implements ...@@ -142,7 +142,7 @@ public class RentVehicleController extends BaseController<VehicleBiz> implements
} }
//设置显示是否有车 //设置显示是否有车
dto.setYearNo4Where(Boolean.TRUE); dto.setYearNo4Where(Boolean.TRUE);
dto.setUseType(null); //dto.setUseType(null);
return ObjectRestResponse.succ(vehicleBiz.searchUsableModelBackStage(dto)); return ObjectRestResponse.succ(vehicleBiz.searchUsableModelBackStage(dto));
} }
......
...@@ -5,6 +5,7 @@ import com.github.wxiaoqi.security.auth.client.annotation.IgnoreUserToken; ...@@ -5,6 +5,7 @@ import com.github.wxiaoqi.security.auth.client.annotation.IgnoreUserToken;
import com.github.wxiaoqi.security.common.msg.ObjectRestResponse; import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
import com.xxfc.platform.vehicle.biz.CompanyBaseBiz; import com.xxfc.platform.vehicle.biz.CompanyBaseBiz;
import com.xxfc.platform.vehicle.common.BaseController; import com.xxfc.platform.vehicle.common.BaseController;
import com.xxfc.platform.vehicle.entity.BranchCompany;
import com.xxfc.platform.vehicle.pojo.vo.CompanyVo; import com.xxfc.platform.vehicle.pojo.vo.CompanyVo;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
...@@ -34,7 +35,7 @@ public class CompanyController extends BaseController<CompanyBaseBiz> { ...@@ -34,7 +35,7 @@ public class CompanyController extends BaseController<CompanyBaseBiz> {
@ApiOperation("同步股权3") @ApiOperation("同步股权3")
@PostMapping("synchro3") @PostMapping("synchro3")
public ObjectRestResponse synchro3() { public ObjectRestResponse synchro3() {
return baseBiz.synchro5(); return baseBiz.synchro6();
} }
...@@ -91,6 +92,12 @@ public class CompanyController extends BaseController<CompanyBaseBiz> { ...@@ -91,6 +92,12 @@ public class CompanyController extends BaseController<CompanyBaseBiz> {
return baseBiz.importExcel(multipartfile,request); return baseBiz.importExcel(multipartfile,request);
} }
@ApiOperation("获取分公司")
@GetMapping("app/unauth/companyId")
public BranchCompany companyId(@RequestParam(value = "name") String name) {
return baseBiz.getCompanyId(name);
}
......
...@@ -73,6 +73,7 @@ ...@@ -73,6 +73,7 @@
cb.town_name AS `townName`, cb.town_name AS `townName`,
bc.addr_detail AS `address`, bc.addr_detail AS `address`,
bc.NAME AS `name`, bc.NAME AS `name`,
cb.name AS `companyName`,
cb.cover, cb.cover,
bc.leader, bc.leader,
bc.leader_contact_info AS `leaderContactInfo`, bc.leader_contact_info AS `leaderContactInfo`,
...@@ -91,6 +92,6 @@ ...@@ -91,6 +92,6 @@
<if test="cityCode != null"> <if test="cityCode != null">
AND `addr_city`=#{cityCode} AND `addr_city`=#{cityCode}
</if> </if>
) AS `cb` ON cb.id = bc.company_base_id ) AS `cb` ON cb.id = bc.company_base_id ORDER BY bc.id
</select> </select>
</mapper> </mapper>
\ No newline at end of file
...@@ -55,4 +55,17 @@ ...@@ -55,4 +55,17 @@
</where> </where>
order by b.upd_time desc order by b.upd_time desc
</select> </select>
<select id="getBaseList" resultType="com.xxfc.platform.vehicle.entity.CompanyBase">
SELECT b.id,b.`name`,b.addr_province as addrProvince,b.province_name as provinceName,b.addr_city as addrCity,b.city_name as cityName,b.zone_id as zoneId FROM company_base b LEFT JOIN branch_company c ON b.id=c.company_base_id
WHERE c.id IS NULL
</select>
<select id="getCompanyId" resultType="com.xxfc.platform.vehicle.entity.BranchCompany">
SELECT b.id,b.`name` FROM branch_company b LEFT JOIN company_base c ON b.company_base_id=c.id
WHERE c.`name` LIKE concat('%',#{name},'%') or b.`name` LIKE concat('%',#{name},'%')
LIMIT 1
</select>
</mapper> </mapper>
\ No newline at end of file
...@@ -41,7 +41,7 @@ ...@@ -41,7 +41,7 @@
SELECT r.* FROM ( SELECT r.* FROM (
select DISTINCT v.`id`, select DISTINCT v.`id`,
v.`code`, v.`code`,
(CASE WHEN #{status} != 0 THEN #{status} (CASE WHEN #{status} is not null THEN #{status}
ELSE v.status END) status , ELSE v.status END) status ,
v.number_plate, v.number_plate,
v.brand, v.brand,
...@@ -182,7 +182,7 @@ ...@@ -182,7 +182,7 @@
SELECT r.* FROM ( SELECT r.* FROM (
select DISTINCT v.`id`, select DISTINCT v.`id`,
v.`code`, v.`code`,
(CASE WHEN #{status} != 0 THEN #{status} (CASE WHEN #{status} is not null THEN #{status}
ELSE v.status END) status , ELSE v.status END) status ,
v.number_plate, v.number_plate,
v.brand, v.brand,
......
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