This commit is contained in:
PQZ 2024-09-27 17:38:39 +08:00
commit a7bb425eb3
19 changed files with 332 additions and 32 deletions

View File

@ -15,6 +15,14 @@
点亮业务基础库
</description>
<dependencies>
<!-- 百度富文本-->
<dependency>
<groupId>com.blingblingbang</groupId>
<artifactId>ueditor</artifactId>
<version>${ueditor.version}</version>
</dependency>
<dependency>
<groupId>cn.iocoder.boot</groupId>
<artifactId>yudao-module-system-biz</artifactId>

View File

@ -31,8 +31,13 @@ public class BannerAPI {
* @date 11:07 2024/9/27
* @param type type
**/
@GetMapping("/get")
public CommonResult<?> getBannerByType(@RequestParam("type") String type) {
return success(baseBannerService.getBannerByType(type));
@GetMapping("/list")
public CommonResult<?> getBannerByTypeList(@RequestParam("type") String type) {
return success(baseBannerService.getBannerByTypeList(type));
}
@GetMapping("/getById")
public CommonResult<?> getBannerById(@RequestParam("id") String id) {
return success(baseBannerService.getBannerById(id));
}
}

View File

@ -0,0 +1,90 @@
package cn.iocoder.yudao.module.banner.controller.admin;
import cn.iocoder.yudao.module.infra.api.file.FileApi;
import com.alibaba.fastjson.JSON;
import com.baidu.ueditor.ActionEnter;
import org.springframework.util.ClassUtils;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.PrintWriter;
import java.util.HashMap;
import java.util.Map;
@RestController
@RequestMapping("/ueditor")
public class UeditorController {
@Resource
private FileApi fileApi;
//配置ueditor后端上传接口的验证
@RequestMapping("/config")
public String config(HttpServletRequest request, HttpServletResponse response, String action, MultipartFile[] upfile) throws IOException {
//获取配置文件json内容返回给前端
if (action.equals("config")) {
request.setCharacterEncoding("utf-8");
response.setHeader("Content-Type", "text/html");
//注意path不能含有中文路径,确认该path能指向config.json
// String path = ClassUtils.getDefaultClassLoader().getResource("").getPath() + "config";
String path = "E:/Workspace/Work/lanan/lanan-system/dl-module-base/target/classes/config/ueditor/config";
System.out.println("path = " + path);
PrintWriter printWriter = response.getWriter();
printWriter.write(new ActionEnter(request, path).exec());
printWriter.flush();
printWriter.close();
}
//上传图片
else if (action.equals("uploadimage")) {
Map<String, Object> result = new HashMap<String, Object>();
for (MultipartFile multipartFile : upfile) {
//调用系统写好的文件上传方法并返回给前端上传后的文件路径组件需要拼接回显
String upload = fileApi.createFile(multipartFile.getBytes());
System.out.println("upload = " + upload);
System.out.println("upload.sub= " + upload.substring(upload.lastIndexOf("/")));
result.put("title", upload.substring(upload.lastIndexOf("/")+1));
result.put("original", multipartFile.getOriginalFilename());
result.put("state", "SUCCESS");
result.put("url", upload);
String jStr = JSON.toJSONString(result);
return jStr;
}
return null;
}
//上传视频
else if(action.equals("uploadvideo")){
Map<String, Object> result = new HashMap<String, Object>();
for (MultipartFile multipartFile : upfile) {
String upload = fileApi.createFile(multipartFile.getBytes());
System.out.println("upload = " + upload);
System.out.println("upload.sub = " + upload.substring(upload.lastIndexOf("/")));
result.put("title", upload.substring(upload.lastIndexOf("/")+1));
result.put("original", multipartFile.getOriginalFilename());
result.put("state", "SUCCESS");
result.put("url", upload);
String jStr = JSON.toJSONString(result);
return jStr;
}
}else{
Map<String, Object> result = new HashMap<String, Object>();
for (MultipartFile multipartFile : upfile) {
String upload = fileApi.createFile(multipartFile.getBytes());
System.out.println("upload = " + upload);
System.out.println("upload.sub= " + upload.substring(upload.lastIndexOf("/")));
result.put("title", upload.substring(upload.lastIndexOf("/")+1));
result.put("original", multipartFile.getOriginalFilename());
result.put("state", "SUCCESS");
result.put("url", upload);
String jStr = JSON.toJSONString(result);
return jStr;
}
}
return null;
}
}

View File

@ -45,4 +45,7 @@ public class DlBaseBanner extends TenantBaseDO {
/** 跳转链接 */
private String toUrl;
/** 页面内容 */
private String content;
}

View File

@ -8,6 +8,8 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* 针对表dl_base_banner(banner图基础库)的数据库操作Mapper
*
@ -25,6 +27,15 @@ public interface DlBaseBannerMapper extends BaseMapper<DlBaseBanner> {
* @param bannerReqVO 查询对象
**/
IPage<DlBaseBanner> queryByPage(@Param("map") DlBannerReqVO bannerReqVO, Page<DlBaseBanner> page);
/**
* 不同小程序用不同的banner用type分
*
* @param type type
* @author 小李
* @date 11:07 2024/9/27
**/
List<DlBaseBanner> getBannerByTypeList(@Param("type") String type);
}

View File

@ -59,5 +59,5 @@ public interface DlBaseBannerService extends IService<DlBaseBanner> {
* @date 11:07 2024/9/27
* @param type type
**/
List<DlBaseBanner> getBannerByType(String type);
List<DlBaseBanner> getBannerByTypeList(String type);
}

View File

@ -80,9 +80,8 @@ public class DlBaseBannerServiceImpl extends ServiceImpl<DlBaseBannerMapper, DlB
* @date 11:07 2024/9/27
**/
@Override
public List<DlBaseBanner> getBannerByType(String type) {
List<DlBaseBanner> dlBaseBanners = baseMapper.selectList(new LambdaQueryWrapper<DlBaseBanner>().eq(DlBaseBanner::getTypeId, type));
return dlBaseBanners.stream().sorted(Comparator.comparing(DlBaseBanner::getSort)).collect(Collectors.toList());
public List<DlBaseBanner> getBannerByTypeList(String type) {
return baseMapper.getBannerByTypeList(type);
}
}

View File

@ -51,6 +51,14 @@ public interface CustomerMainService extends IService<CustomerMain> {
**/
CustomerMainRespVO getCustomerById(String id);
/**
* 根据userID客户表信息
* @author vinjor-M
* @date 15:25 2024/9/27
* @param userId 用户id
**/
CustomerMain getCustomerByUserId(Long userId);
/**
* 获取当前登录用户的客户信息
* @author PQZ

View File

@ -213,6 +213,26 @@ public class CustomerMainServiceImpl extends ServiceImpl<CustomerMainMapper, Cus
return result;
}
/**
* 根据userID客户表信息
*
* @param userId 用户id
* @return cn.iocoder.yudao.module.custom.vo.CustomerMainRespVO
* @author vinjor-M
* @date 15:25 2024/9/27
**/
@Override
public CustomerMain getCustomerByUserId(Long userId) {
LambdaQueryWrapper<CustomerMain> queryWrapper = new LambdaQueryWrapper<CustomerMain>()
.eq(CustomerMain::getUserId,userId);
List<CustomerMain> customerList = this.list(queryWrapper);
if(customerList.isEmpty()){
return null;
}else{
return customerList.get(0);
}
}
/**
* 获取当前登录用户的客户信息
*
@ -222,7 +242,6 @@ public class CustomerMainServiceImpl extends ServiceImpl<CustomerMainMapper, Cus
**/
@Override
public CustomerMainRespVO getUserCustomer() {
LoginUser loginUser = SecurityFrameworkUtils.getLoginUser();
LambdaQueryWrapper<CustomerMain> lambdaQueryWrapper = new LambdaQueryWrapper<>();
lambdaQueryWrapper.eq(CustomerMain::getUserId,loginUser.getId()).eq(BaseDO::getDeleted,'0');

View File

@ -0,0 +1,69 @@
{
/* */
"imageActionName": "uploadimage", /* action */
"imageFieldName": "upfile", /* */
"imageMaxSize": 2048000, /* B */
"imageAllowFiles": [".png", ".jpg", ".jpeg", ".gif", ".bmp", '.webp'], /* */
"imageCompressEnable": true, /* ,true */
"imageCompressBorder": 1600, /* */
"imageInsertAlign": "none", /* */
"imageUrlPrefix": "http://122.51.230.86:9000/", /* 访 */
"imagePathFormat": "image/{yyyy}{mm}{dd}/{time}{rand:6}", /* , */
/* {filename} , */
/* {rand:6} , */
/* {time} */ /* {yyyy} */
/* {yy} */
/* {mm} */
/* {dd} */
/* {hh} */
/* {ii} */
/* {ss} */
/* \ : * ? " < > | */
/* 线: fex.baidu.com/ueditor/#use-format_upload_filename */
/* */
"scrawlActionName": "uploadscrawl", /* action */
"scrawlFieldName": "upfile", /* */
"scrawlPathFormat": "image/{yyyy}{mm}{dd}/{time}{rand:6}", /* , */
"scrawlMaxSize": 2048000, /* B */
"scrawlUrlPrefix": "", /* 访 */
"scrawlInsertAlign": "none", /* */
"snapscreenActionName": "uploadimage", /* action */
"snapscreenPathFormat": "image/{yyyy}{mm}{dd}/{time}{rand:6}", /* , */
"snapscreenUrlPrefix": "", /* 访 */
"snapscreenInsertAlign": "none", /* */
/* */
"catcherLocalDomain": ["127.0.0.1", "localhost", "img.baidu.com"],
"catcherActionName": "catchimage", /* action */
"catcherFieldName": "source", /* */
"catcherPathFormat": "image/{yyyy}{mm}{dd}/{time}{rand:6}", /* , */
"catcherUrlPrefix": "", /* 访 */
"catcherMaxSize": 2048000, /* B */
"catcherAllowFiles": [".png", ".jpg", ".jpeg", ".gif", ".bmp"], /* */
/* */
"videoActionName": "uploadvideo", /* action */
"videoFieldName": "upfile", /* */
"videoPathFormat": "video/{yyyy}{mm}{dd}/{time}{rand:6}", /* , */
"videoUrlPrefix": "http://122.51.230.86:9000/", /* 访 */
"videoMaxSize": 102400000, /* B100MB */
"videoAllowFiles": [ ".flv", ".swf", ".mkv", ".avi", ".rm", ".rmvb", ".mpeg", ".mpg", ".ogg", ".ogv", ".mov", ".wmv", ".mp4", ".webm", ".mp3", ".wav", ".mid"], /* */
/* */
"fileActionName": "uploadfile", /* controller,action */
"fileFieldName": "upfile", /* */
"filePathFormat": "file/{yyyy}{mm}{dd}/{time}{rand:6}", /* , */
"fileUrlPrefix": "http://122.51.230.86:9000/", /* 访 */
"fileMaxSize": 51200000, /* B50MB */
"fileAllowFiles": [ ".png", ".jpg", ".jpeg", ".gif", ".bmp", ".flv", ".swf", ".mkv", ".avi", ".rm", ".rmvb", ".mpeg", ".mpg", ".ogg", ".ogv", ".mov", ".wmv", ".mp4", ".webm", ".mp3", ".wav", ".mid", ".rar", ".zip", ".tar", ".gz", ".7z", ".bz2", ".cab", ".iso", ".doc", ".docx", ".xls", ".xlsx", ".ppt", ".pptx", ".pdf", ".txt", ".md", ".xml" ], /* */
/* */
"imageManagerActionName": "listimage", /* action */
"imageManagerListPath": "image/", /* */
"imageManagerListSize": 20, /* */
"imageManagerUrlPrefix": "http://122.51.230.86:9000/", /* 访 */
"imageManagerInsertAlign": "none", /* */
"imageManagerAllowFiles": [".png", ".jpg", ".jpeg", ".gif", ".bmp"], /* */
/* */
"fileManagerActionName": "listfile", /* action */
"fileManagerListPath": "file/", /* */
"fileManagerUrlPrefix": "http://122.51.230.86:9000/", /* 访 */
"fileManagerListSize": 20, /* */
"fileManagerAllowFiles": [ ".png", ".jpg", ".jpeg", ".gif", ".bmp", ".flv", ".swf", ".mkv", ".avi", ".rm", ".rmvb", ".mpeg", ".mpg", ".ogg", ".ogv", ".mov", ".wmv", ".mp4", ".webm", ".mp3", ".wav", ".mid", ".rar", ".zip", ".tar", ".gz", ".7z", ".bz2", ".cab", ".iso", ".doc", ".docx", ".xls", ".xlsx", ".ppt", ".pptx", ".pdf", ".txt", ".md", ".xml" ] /* */
}

View File

@ -11,6 +11,7 @@
<result property="sort" column="sort" jdbcType="VARCHAR"/>
<result property="typeId" column="type_id" jdbcType="VARCHAR"/>
<result property="toUrl" column="to_url" jdbcType="VARCHAR"/>
<result property="content" column="content"/>
</resultMap>
<sql id="Base_SQL">
@ -19,14 +20,22 @@
url,
sort,
type_id,
to_url
from dl_base_banner dbb where dbb.deleted = '0'
to_url,
content
from dl_base_banner dbb
where dbb.deleted = '0'
</sql>
<select id="queryByPage" resultMap="BaseResultMap">
<include refid="Base_SQL" />
<include refid="Base_SQL"/>
<if test="map.typeId != null and map.typeId != ''">
and dbb.type_id = #{map.typeId}
</if>
</select>
<select id="getBannerByTypeList" resultType="cn.iocoder.yudao.module.banner.entity.DlBaseBanner">
<include refid="Base_SQL" />
and dbb.type_id = #{type}
order by dbb.sort
</select>
</mapper>

View File

@ -11,6 +11,9 @@ import cn.iocoder.yudao.framework.security.core.util.SecurityFrameworkUtils;
import cn.iocoder.yudao.framework.tenant.core.aop.TenantIgnore;
import cn.iocoder.yudao.module.app.vo.WxLoginBody;
import cn.iocoder.yudao.module.custom.entity.CustomerMain;
import cn.iocoder.yudao.module.custom.service.CustomerMainService;
import cn.iocoder.yudao.module.custom.vo.CustomerMainRespVO;
import cn.iocoder.yudao.module.system.api.dict.DictDataApi;
import cn.iocoder.yudao.module.system.api.permission.PermissionApi;
import cn.iocoder.yudao.module.system.api.permission.RoleApi;
@ -32,6 +35,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.sun.org.apache.xerces.internal.impl.dv.util.Base64;
import io.swagger.v3.oas.annotations.Operation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.security.crypto.password.PasswordEncoder;
import org.springframework.util.StringUtils;
import org.springframework.web.bind.annotation.*;
@ -65,20 +69,14 @@ import static cn.iocoder.yudao.framework.common.pojo.CommonResult.*;
public class LoginController {
@Resource
private AdminAuthService loginService;
@Resource
private WechatPayConfig wxConfig;
@Resource
private RestTemplate restTemplate;
@Resource
private SecurityProperties securityProperties;
@Autowired
private CustomerMainService customerMainService;
@PostMapping("/wxLogin")
@TenantIgnore
@ -107,9 +105,12 @@ public class LoginController {
if (StringUtils.hasText(decryptResult)) {
//如果解析成功,获取token
AuthLoginRespVO loginVO = loginService.wxLoginJc(decryptResult,openId,wxLoginBody.getInviteId());
AuthLoginRespVO loginVO = loginService.wxLoginRepair(decryptResult,openId,wxLoginBody.getInviteId());
Map<String, Object> map = new HashMap<>();
map.put("token", loginVO.getAccessToken());
//查会员表里是否有数据
CustomerMain customerMain = customerMainService.getCustomerByUserId(loginVO.getUserId());
map.put("ifNeedFill", null==customerMain);
return success(map);
} else {
return error(500, "微信登录失败!");

View File

@ -51,6 +51,7 @@
<spring.boot.version>2.7.18</spring.boot.version>
<mapstruct.version>1.5.5.Final</mapstruct.version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<ueditor.version>1.1.2</ueditor.version>
</properties>
<dependencyManagement>

View File

@ -164,7 +164,7 @@ public class YudaoWebSecurityConfigurerAdapter {
.antMatchers("/admin-api/system/schoolRegistrationInfo/addWx","/admin-api/system/schoolInstructor/listWx","/admin-api/system/schoolAppointmentInfo/addWx").permitAll()
// 驾校
.antMatchers("/admin-api/drivingSchool/system/driveSchoolCourse/list","/admin-api/loginJx","/admin-api/loginSmsCodeJx"," /admin-api/jxInfo/payNotify","/admin-api/drivingSchool/text/list","/admin-api/drivingSchool/system/swiper/list","/admin-api/drivingSchool/system/schoolInfo/list").permitAll()
.antMatchers("/admin-api/ueditor/*").permitAll()
// 检测app首页
.antMatchers("/admin-api/appInspection/appHome/**").permitAll()
//检测小程序相关

View File

@ -105,4 +105,9 @@ public class UserSaveReqVO {
private Long balance;
/**
* 维修小程序openID
*/
private String repairOpenId;
}

View File

@ -85,4 +85,15 @@ public interface AdminAuthService {
* @return cn.iocoder.yudao.module.system.controller.admin.auth.vo.AuthLoginRespVO
**/
AuthLoginRespVO wxLoginByUserId(Long userId,String userName);
/**
* 微信小程序自动注册账号并登录
* @author vinjor-M
* @date 15:10 2024/9/27
* @param decryptResult
* @param openId openId
* @param inviteId
* @return cn.iocoder.yudao.module.system.controller.admin.auth.vo.AuthLoginRespVO
**/
AuthLoginRespVO wxLoginRepair(String decryptResult, String openId, Long inviteId);
}

View File

@ -375,7 +375,7 @@ public class AdminAuthServiceImpl implements AdminAuthService {
List<RoleDO> jcyh = roleService.getRoleListByCodes(Collections.singletonList("jcyh"));
Set<Long> ids = new HashSet<>();
ids.add(jcyh.get(0).getId());
// permissionService.assignUserRole(user.getId(),ids);
permissionService.assignUserRole(user.getId(),ids);
}else {
//更新
user.setId(wxUser.getId());
@ -410,4 +410,62 @@ public class AdminAuthServiceImpl implements AdminAuthService {
// 生成token
return createTokenAfterLoginSuccess(userId, userName, LoginLogTypeEnum.LOGIN_USERNAME);
}
/**
* 微信小程序自动注册账号并登录
*
* @param decryptResult
* @param openId openId
* @param inviteId
* @return cn.iocoder.yudao.module.system.controller.admin.auth.vo.AuthLoginRespVO
* @author vinjor-M
* @date 15:10 2024/9/27
**/
@Override
public AuthLoginRespVO wxLoginRepair(String decryptResult, String openId, Long inviteId) {
//字符串转json
JSONObject jsonObject = JSONObject.parseObject(decryptResult);
String phoneNumber = jsonObject.getString("phoneNumber");
//还可以获取其他信息
//根据手机号判断数据库中是否有该用户
AdminUserDO wxUser = userService.getUserByMobileWithoutTenant(phoneNumber);
//如果查不到则新增查到了则更新
UserSaveReqVO user = new UserSaveReqVO();
if (wxUser == null) {
// 新增
user.setUsername(phoneNumber);
user.setNickname(phoneNumber);
user.setMobile(phoneNumber);
user.setPassword(passwordEncoder.encode("123456"));
user.setRepairOpenId(openId);
user.setTenantId(180L);
if (null!=inviteId){
//绑定上级
user.setInviteId(inviteId);
//给上级进行积分奖励
// userBalanceService.inviteRewards(inviteId);
}
user.setDeptId(100L);
Long uid = userService.createUser(user);
wxUser = new AdminUserDO();
wxUser.setId(uid);
wxUser.setUsername(phoneNumber);
}else {
//更新
user.setId(wxUser.getId());
user.setNickname(phoneNumber);
user.setRepairOpenId(openId);
if (ObjectUtil.isEmpty(user.getInviteId())){
if (null!=inviteId){
//绑定上级
user.setInviteId(inviteId);
//给上级进行积分奖励
// userBalanceService.inviteRewards(inviteId);
}
}
userService.updateUser(user);
}
// 生成token
return createTokenAfterLoginSuccess(wxUser.getId(), wxUser.getUsername(), LoginLogTypeEnum.LOGIN_SOCIAL);
}
}

View File

@ -185,10 +185,10 @@ debug: false
--- #################### 微信公众号、小程序相关配置 ####################
wx:
mp: # 公众号配置(必填),参见 https://github.com/Wechat-Group/WxJava/blob/develop/spring-boot-starters/wx-java-mp-spring-boot-starter/README.md 文档
# app-id: wx8653afe16dffec37 # 蓝安
# secret: ab94673dd0cca78abd0a453d0aac9f98
app-id: wxb1f71e5e0c5f9ee7 # 点亮
secret: 2e9864a6b224feb6fba4ab73b70212cd
app-id: wx8653afe16dffec37 # 蓝安
secret: 0d13b60547b73d844fc95871d9b264dd
# app-id: wxb1f71e5e0c5f9ee7 # 点亮
# secret: 2e9864a6b224feb6fba4ab73b70212cd
# 存储配置,解决 AccessToken 的跨节点的共享
config-storage:
type: RedisTemplate # 采用 RedisTemplate 操作 Redis会自动从 Spring 中获取

View File

@ -231,6 +231,8 @@ yudao:
- /admin-api/system/tenant/getListByWebsite
- /admin-api/rescue/loginQx
- /userClient/repair/wxLogin
- /userClient/base/company/page #查询可提供服务的子公司,不需要登录
- /userClient/base/company/get #查询可提供服务的子公司详情,不需要登录
websocket:
enable: true # websocket的开关
path: /infra/ws # 路径
@ -286,6 +288,7 @@ yudao:
- /userClient/pay/**
- /userClient/weChat/**
- /userClient/**
- /admin-api/ueditor/**
ignore-tables:
- system_tenant