Compare commits

...

21 Commits

Author SHA1 Message Date
ASUS 2f49fd4856 新增修改 2023-12-19 19:25:33 +08:00
fangzhe 7f9b6b7f12 Merge remote-tracking branch 'origin/master' 2023-12-19 19:00:56 +08:00
fangzhe 057d634b12 解决冲突02 2023-12-19 19:00:33 +08:00
lijiayao 69159dceb2 销售日志 2023-12-19 17:14:53 +08:00
fangzhe 20fd5df7ba 解决冲突02 2023-12-19 16:59:33 +08:00
fangzhe 155705ba83 解决冲突 2023-12-19 16:57:16 +08:00
fangzhe 4aa014098e Merge remote-tracking branch 'origin/master'
# Conflicts:
#	.idea/encodings.xml
#	bwie-common/src/main/java/com/bwie/common/pojo/DTO/DTOGoods.java
#	bwie-common/src/main/java/com/bwie/common/pojo/Facility.java
#	bwie-common/src/main/java/com/bwie/common/pojo/Goods.java
#	bwie-common/src/main/java/com/bwie/common/pojo/Shop.java
#	bwie-common/src/main/java/com/bwie/common/pojo/VO/VOGoods.java
#	bwie-models/pom.xml
2023-12-19 16:47:53 +08:00
ASUS 67157de6ad Merge branch 'master' of https://gitea.qinmian.online/FiveTeam/ShopManage
# Conflicts:
#	bwie-models/bwie-shopList/src/main/java/com/bwie/list/controller/ShopController.java
2023-12-19 16:35:26 +08:00
syl f6b4b2842f 更新 bwie-common/src/main/java/com/bwie/common/pojo/Shop.java 2023-12-19 16:28:25 +08:00
ASUS a3e27f0f2c Merge branch 'blue' 2023-12-19 16:25:42 +08:00
ASUS 7757177af6 上下架+进货 2023-12-19 16:25:05 +08:00
ASUS 6894770e6f 修改shop实体类 2023-12-19 16:20:42 +08:00
fangzhe 72adb54ab7 Merge branch 'FangShiBa' 2023-12-19 15:01:18 +08:00
rxh 8915037779 Merge remote-tracking branch 'origin/master' 2023-12-19 14:41:13 +08:00
rxh 0ef66c37fe Merge pull request 'blue' (#1) from blue into master
Reviewed-on: #1
2023-12-19 14:18:13 +08:00
syl 1269067243 Merge pull request 'blue' (#1) from blue into master
Reviewed-on: #1
2023-12-19 09:08:24 +08:00
ASUS b7e8563b10 展示商品设备表 2023-12-18 21:28:27 +08:00
syl ab3e986879 Merge pull request 'blue' (#1) from blue into master
Reviewed-on: #1
2023-12-18 09:47:40 +08:00
ASUS b1cc202f06 添加图片(类型搜索, 商品列表, 添加商品, 上传图片) 2023-12-18 09:45:50 +08:00
ASUS 6d4c584e41 添加实体类 2023-12-17 14:05:13 +08:00
ASUS e22a86ba7c 新增list框架 2023-12-17 11:07:56 +08:00
85 changed files with 5632 additions and 28 deletions

7
.gitignore vendored
View File

@ -35,4 +35,9 @@ build/
.vscode/
### Mac OS ###
.DS_Store
.DS_Store
.idea
target/

View File

@ -5,6 +5,9 @@
<file url="file://$PROJECT_DIR$/bwie-common/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/bwie-gateway/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/bwie-models/bwie-buy/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/bwie-models/bwie-sell/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/bwie-models/bwie-shopList/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/bwie-models/bwie-user/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/bwie-models/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/bwie-models/src/main/resources" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/bwie-mq/src/main/java" charset="UTF-8" />

View File

@ -0,0 +1,17 @@
<component name="InspectionProjectProfileManager">
<profile version="1.0">
<option name="myName" value="Project Default" />
<inspection_tool class="AliAccessStaticViaInstance" enabled="true" level="WARNING" enabled_by_default="true" />
<inspection_tool class="AliArrayNamingShouldHaveBracket" enabled="true" level="WARNING" enabled_by_default="true" />
<inspection_tool class="AliControlFlowStatementWithoutBraces" enabled="true" level="WARNING" enabled_by_default="true" />
<inspection_tool class="AliDeprecation" enabled="true" level="WARNING" enabled_by_default="true" />
<inspection_tool class="AliEqualsAvoidNull" enabled="true" level="WARNING" enabled_by_default="true" />
<inspection_tool class="AliLongLiteralsEndingWithLowercaseL" enabled="true" level="WARNING" enabled_by_default="true" />
<inspection_tool class="AliMissingOverrideAnnotation" enabled="true" level="WARNING" enabled_by_default="true" />
<inspection_tool class="AliWrapperTypeEquality" enabled="true" level="WARNING" enabled_by_default="true" />
<inspection_tool class="AutoCloseableResource" enabled="true" level="WARNING" enabled_by_default="true">
<option name="METHOD_MATCHER_CONFIG" value="java.util.Formatter,format,java.io.Writer,append,com.google.common.base.Preconditions,checkNotNull,org.hibernate.Session,close,java.io.PrintWriter,printf,java.io.PrintStream,printf,com.github.pagehelper.page.PageMethod,startPage" />
</inspection_tool>
<inspection_tool class="MapOrSetKeyShouldOverrideHashCodeEquals" enabled="true" level="WARNING" enabled_by_default="true" />
</profile>
</component>

View File

@ -5,6 +5,8 @@
<option name="originalFiles">
<list>
<option value="$PROJECT_DIR$/pom.xml" />
<option value="$PROJECT_DIR$/bwie-models/bwie-buy/pom.xml" />
<option value="$PROJECT_DIR$/bwie-models/bwie-shopList/pom.xml" />
</list>
</option>
</component>

View File

@ -4,17 +4,15 @@ import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;
import javax.swing.*;
/**
* @author FangShiBa
* @date 2023/12/17
* @apiNote
* @author 86175
*/
@SpringBootApplication
@EnableFeignClients
public class AuthApplication {
public static void main(String[] args) {
SpringApplication.run(AuthApplication.class,args);
}
}

View File

@ -0,0 +1,65 @@
package com.bwie.auth.controller;
import com.alibaba.fastjson.JSON;
import com.bwie.auth.service.AuthService;
import com.bwie.common.pojo.DTO.DTOUser;
import com.bwie.common.pojo.User;
import com.bwie.common.pojo.VO.VOUser;
import com.bwie.common.result.Result;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletRequest;
/**
* @author 86175
*/
@RestController
@RequestMapping("/auth")
@Log4j2
public class AuthController {
@Autowired
private AuthService authService;
@Autowired
private HttpServletRequest request;
/**
*
*/
@PostMapping("/sendCode/{phone}")
public Result sendCode(@PathVariable String phone){
log.info("功能描述:发送验证码,请求URI:{},请求方式:{},请求参数:{}",request.getServletPath(),request.getMethod(),phone);
Result result = authService.sendCode(phone);
log.info("功能描述:发送验证码,请求URI:{},请求方式:{},响应结果:{}",request.getServletPath(),request.getMethod(), JSON.toJSONString(result));
return result;
}
/**
*
*/
@PostMapping("/users")
public Result<DTOUser> user(@RequestBody VOUser voUser){
log.info("功能描述:登录验证,请求URI:{},请求方式:{},请求参数:{}",request.getServletPath(),request.getMethod(),voUser);
Result result=authService.users(voUser);
log.info("功能描述:登录验证,请求URI:{},请求方式:{},响应结果:{}",request.getServletPath(),request.getMethod(), JSON.toJSONString(result));
return result;
}
/**
*
*/
@PostMapping("/regUser")
public Result regUser(@RequestBody User user){
log.info("功能描述:注册,请求URI:{},请求方式:{},请求参数:{}",request.getServletPath(),request.getMethod(),user);
Result result =authService.regUser(user);
log.info("功能描述:注册,请求URI:{},请求方式:{},响应结果:{}",request.getServletPath(),request.getMethod(), JSON.toJSONString(result));
return result;
}
}

View File

@ -0,0 +1,32 @@
package com.bwie.auth.feign;
import com.bwie.common.pojo.User;
import com.bwie.common.result.Result;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
/**
* @author 86175
*/
@FeignClient("bwie-user")
public interface UserFeignService {
/**
*
* @param phone
* @return
*/
@PostMapping("/user/findByPhone/{phone}")
public Result<User> findByPhone(@PathVariable String phone);
/**
*
* @param user
* @return
*/
@PostMapping("/user/reg")
public Result<Integer> regLogin(@RequestBody User user);
}

View File

@ -0,0 +1,29 @@
package com.bwie.auth.service;
import com.bwie.common.pojo.User;
import com.bwie.common.pojo.VO.VOUser;
import com.bwie.common.result.Result;
public interface AuthService {
/**
*
* @param phone
* @return
*/
Result sendCode(String phone);
/**
*
* @param voUser
* @return
*/
Result users(VOUser voUser);
/**
*
* @param user
* @return
*/
Result regUser(User user);
}

View File

@ -0,0 +1,118 @@
package com.bwie.auth.service;
import com.alibaba.fastjson.JSON;
import com.bwie.auth.feign.UserFeignService;
import com.bwie.common.constants.JwtConstants;
import com.bwie.common.constants.TokenConstants;
import com.bwie.common.pojo.DTO.DTOUser;
import com.bwie.common.pojo.User;
import com.bwie.common.pojo.VO.VOUser;
import com.bwie.common.result.Result;
import com.bwie.common.utils.JwtUtils;
import org.apache.commons.lang.RandomStringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;
import java.util.HashMap;
import java.util.Random;
import java.util.UUID;
import java.util.concurrent.TimeUnit;
/**
* @author 86175
*/
@Service
public class AuthServiceImpl implements AuthService{
@Autowired
private UserFeignService userFeignService;
@Autowired
private StringRedisTemplate redisTemplate;
/**
*
* @param phone
* @return
*/
@Override
public Result sendCode(String phone) {
Result<User> byPhone = userFeignService.findByPhone(phone);
User user = byPhone.getData();
if (user==null){
return Result.error("手机号不存在,请先注册");
}
String code="";
for (int i = 0; i < 4; i++) {
code+=new Random().nextInt(10);
}
redisTemplate.opsForValue().set(phone,code,20, TimeUnit.MINUTES);
return Result.success(code,"发送成功");
}
/**
*
* @param voUser
* @return
*/
@Override
public Result<DTOUser> users(VOUser voUser) {
Result<User> byPhone = userFeignService.findByPhone(voUser.getPhone());
User user = byPhone.getData();
/**
*
*/
if (user==null){
return Result.error("手机号不存在,请先注册");
}
/**
*
*/
String code = redisTemplate.opsForValue().get(voUser.getPhone());
if (!voUser.getCode().equals(code)){
return Result.error("密码错误");
}
HashMap<String, Object> map = new HashMap<>();
/**
*
*/
String userKey = UUID.randomUUID().toString();
map.put(JwtConstants.USER_KEY,userKey);
/**
*
*/
String token = JwtUtils.createToken(map);
/**
* userredis
*/
redisTemplate.opsForValue().set(TokenConstants.LOGIN_TOKEN_KEY+userKey, JSON.toJSONString(user),59,TimeUnit.MINUTES);
/**
*
*/
DTOUser dtoUser = new DTOUser();
dtoUser.setToken(token);
dtoUser.setExpiredTime("存储时长为59分钟");
if (1==user.userRole){
return Result.success(dtoUser,"登录成功");
}
return Result.success(dtoUser,"欢迎"+user.userName+"登录");
}
/**
*
* @param user
* @return
*/
@Override
public Result regUser(User user) {
Result<Integer> result = userFeignService.regLogin(user);
Integer data = result.getData();
return Result.success(data>0?"添加成功":"添加失败");
}
}

View File

@ -90,10 +90,10 @@ spring:
nacos:
discovery:
# 服务注册地址
server-addr: 110.42.214.8:8848
server-addr: 111.229.234.119:8848
config:
# 配置中心地址
server-addr: 110.42.214.8:8848
server-addr: 111.229.234.119:8848
# 配置文件格式
file-extension: yml
# 共享配置

View File

@ -105,6 +105,20 @@
</dependency>
<!--fastDfs文件上传-->
<dependency>
<groupId>com.github.tobato</groupId>
<artifactId>fastdfs-client</artifactId>
<version>1.26.5</version>
</dependency>
<!-- oss 图片上传 -->
<dependency>
<groupId>com.aliyun.oss</groupId>
<artifactId>aliyun-sdk-oss</artifactId>
<version>3.12.0</version>
</dependency>
<!--短信依赖 5条依赖-->
<dependency>
<groupId>com.alibaba</groupId>
@ -132,6 +146,30 @@
<version>9.3.7.v20160115</version>
</dependency>
<!-- poi导入导出依赖 -->
<!-- excel2007+使用的包 -->
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi-ooxml</artifactId>
<version>3.17</version>
</dependency>
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi-ooxml-schemas</artifactId>
<version>3.17</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.12.0</version>
</dependency>
<!--合并单元格-->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>easyexcel</artifactId>
<version>2.2.7</version>
</dependency>
</dependencies>

View File

@ -5,11 +5,15 @@ import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;
/**
* @author FangShiBa
* @date 2023/12/17
* @apiNote
*/
import java.util.List;
@Data
@AllArgsConstructor
@NoArgsConstructor
@ -30,4 +34,15 @@ public class DTOGoods {
private String facilityStatic; //设备状态
private Integer delId; //删除状态
//商品类型名称
private String typeName;
//图片
private List<String> pictureUrl;
}

View File

@ -0,0 +1,33 @@
package com.bwie.common.pojo.DTO;
import com.bwie.common.pojo.Picture;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;
import java.util.List;
@Data
@AllArgsConstructor
@NoArgsConstructor
@ToString
public class DTOShop {
//商品id
private Integer shopId;
//商品名称
private String shopName;
//商品价格
private double shopPrice;
//商品类型id
private Integer typeId;
//商品类型名称
private String typeName;
//图片
private List<String> pictureUrl;
}

View File

@ -3,18 +3,27 @@ package com.bwie.common.pojo.DTO;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;
/**
* @author FangShiBa
* @date 2023/12/16
* @apiNote
*
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@ToString
public class DTOUser {
/**
* token
*/
private String token;
/**
*
*/
private String expiredTime;
private Integer userId;

View File

@ -5,11 +5,13 @@ import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;
/**
* @author FangShiBa
* @date 2023/12/17
* @apiNote
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@ -23,6 +25,4 @@ public class Facility {
private String facilityStatic; //设备状态
private Integer delId; //删除状态
}

View File

@ -5,11 +5,13 @@ import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;
/**
* @author FangShiBa
* @date 2023/12/17
* @apiNote
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@ -20,4 +22,5 @@ public class Goods {
private Integer facilityId; //设备id
private Integer goodsNum; //库存
private Integer goodsIsDelete; //上下架(逻辑字段: 0上架, 1下架)
}

View File

@ -0,0 +1,23 @@
package com.bwie.common.pojo;
import com.alibaba.nacos.shaded.org.checkerframework.checker.units.qual.A;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;
@Data
@AllArgsConstructor
@NoArgsConstructor
@ToString
public class Picture {
//图片id
private Integer pictureId;
//图片路径
private String pictureUrl;
//商品id
private Integer shopId;
}

View File

@ -1,31 +1,114 @@
package com.bwie.common.pojo;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.alibaba.excel.annotation.ExcelIgnore;
import com.bwie.common.utils.poi.annotation.Excel;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;
import org.springframework.format.annotation.DateTimeFormat;
import java.util.Date;
/**
* @author FangShiBa
* @date 2023/12/18
* @apiNote
* @author 86175
*
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@ToString
public class Sell {
/**
*
*/
@ExcelIgnore
private Integer sellId;
/**
*
*/
@ExcelIgnore
private Integer shopId;
/**
*
*/
@Excel(name = "卖出商品的时间")
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
private Date sellTime;
/**
*
*/
@ExcelIgnore
private Integer userId;
/**
*
*/
@ExcelIgnore
private Integer facilityId;
/**
*
*/
@Excel(name = "设备类型")
private String facilityType;
/**
*
*/
@Excel(name = "设备地址")
private String facilitySite;
/**
*
*/
@Excel(name = "补货员工")
private Integer replenishmentUserId;
/**
*
*/
@Excel(name = "维修员工")
private Integer maintainUserId;
/**
*
*/
@Excel(name = "设备状态")
private String facilityStatic;
/**
*
*/
@ExcelIgnore
private Integer delId;
/**
*
*/
@Excel(name = "商品名称")
private String shopName;
/**
*
*/
@Excel(name = "商品价格")
private Double shopPrice;
/**
*
*/
@ExcelIgnore
private Integer typeId;
/**
*
*/
@Excel(name = "商品类型")
private String typeName;
/**
*
*/
@Excel(name = "用户名")
public String userName;
/**
*
*/
@Excel(name = "手机号")
public String phone;
/**
*
*/
@Excel(name = "邮箱")
public String email;
}

View File

@ -5,11 +5,13 @@ import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;
/**
* @author FangShiBa
* @date 2023/12/17
* @apiNote
*/
@Data
@AllArgsConstructor
@NoArgsConstructor

View File

@ -0,0 +1,21 @@
package com.bwie.common.pojo;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;
@Data
@AllArgsConstructor
@NoArgsConstructor
@ToString
public class Type {
//类型id
private Integer typeId;
//类型名称
private String typeName;
}

View File

@ -1,9 +1,45 @@
package com.bwie.common.pojo;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @author FangShiBa
* @date 2023/12/16
* @apiNote
*
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class User {
/**
*
*/
public Integer userId;
/**
*
*/
public String userName;
/**
*
*/
public String phone;
/**
*
*/
public String email;
/**
* 1 2:
*/
public Integer userRole;
}

View File

@ -5,11 +5,13 @@ import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;
/**
* @author FangShiBa
* @date 2023/12/17
* @apiNote
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@ -24,4 +26,5 @@ public class VOGoods {
private Integer pageNum=1;
private Integer pageSize=3;
}

View File

@ -0,0 +1,31 @@
package com.bwie.common.pojo.VO;
import lombok.Data;
import org.springframework.format.annotation.DateTimeFormat;
import java.util.Date;
/**
*
* @author 86175
*/
@Data
public class VOSell {
/**
*
*/
private Integer shopId;
/**
*
*/
@DateTimeFormat(pattern = "yyyy-MM-dd")
private Date sellTime;
/**
*
*/
private Integer userId;
}

View File

@ -0,0 +1,35 @@
package com.bwie.common.pojo.VO;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;
import java.util.List;
@Data
@AllArgsConstructor
@NoArgsConstructor
@ToString
public class VOShop {
//类型id
private Integer typeId;
//商品id
private Integer shopId;
//商品名称
private String shopName;
//商品价格
private double shopPrice;
//商品类型名称
private String typeName;
//图片
private List<String> pictureUrl;
//分页
private Integer pageNum=1;
private Integer pageSize=3;
}

View File

@ -1,9 +1,27 @@
package com.bwie.common.pojo.VO;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @author FangShiBa
* @date 2023/12/16
* @apiNote
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class VOUser {
/**
*
*/
public String phone;
/**
*
*/
public String code;
}

View File

@ -73,4 +73,28 @@ public class Result<T> implements Serializable {
apiResult.setMsg(msg);
return apiResult;
}
public int getCode() {
return code;
}
public void setCode(int code) {
this.code = code;
}
public String getMsg() {
return msg;
}
public void setMsg(String msg) {
this.msg = msg;
}
public T getData() {
return data;
}
public void setData(T data) {
this.data = data;
}
}

View File

@ -0,0 +1,55 @@
package com.bwie.common.utils;
import org.springframework.stereotype.Component;
import com.github.tobato.fastdfs.domain.fdfs.StorePath;
import com.github.tobato.fastdfs.service.FastFileStorageClient;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.util.StringUtils;
import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource;
/**
* @BelongsProject: 0107day02
* @BelongsPackage: com.bw.config
* @Author: zhupengfei
* @CreateTime: 2023-02-01 08:52
*/
@Component
public class FastUtil {
private static final Logger log = LoggerFactory.getLogger(FastUtil.class);
@Resource
private FastFileStorageClient storageClient ;
/**
*
*/
public String upload(MultipartFile multipartFile) throws Exception{
String originalFilename = multipartFile.getOriginalFilename().
substring(multipartFile.getOriginalFilename().
lastIndexOf(".") + 1);
StorePath storePath = this.storageClient.uploadImageAndCrtThumbImage(
multipartFile.getInputStream(),
multipartFile.getSize(),originalFilename , null);
return storePath.getFullPath();
}
/**
*
*/
public String deleteFile(String fileUrl) {
if (StringUtils.isEmpty(fileUrl)) {
log.info("fileUrl == >>文件路径为空...");
return "文件路径不能为空";
}
try {
StorePath storePath = StorePath.parseFromUrl(fileUrl);
storageClient.deleteFile(storePath.getGroup(), storePath.getPath());
} catch (Exception e) {
log.error(e.getMessage());
}
return "删除成功";
}
}

View File

@ -0,0 +1,87 @@
package com.bwie.common.utils;
import java.util.Random;
/**
* @author DongZl
* @description:
* @Date 2023-5-11 10:09
*/
public class GenCodeUtils {
/**
*
*/
private static final String NUMBER_STR = "0123456789";
/**
*
*/
private static final String LETTERS_STR = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ";
/**
*
*/
private static final Integer SMS_CODE_LENGTH = 4;
/**
*
* @return
*/
public static String genLetterStrSms(){
return genCode(LETTERS_STR, SMS_CODE_LENGTH);
}
/**
*
* @return
*/
public static String genNumberCodeSms(){
return genCode(NUMBER_STR, SMS_CODE_LENGTH);
}
/**
*
* @param codeLength
* @return
*/
public static String genLetterStr(int codeLength){
return genCode(LETTERS_STR, codeLength);
}
/**
*
* @param codeLength
* @return
*/
public static String genNumberCode( int codeLength){
return genCode(NUMBER_STR, codeLength);
}
/**
*
* @param str
* @param codeLength
* @return
*/
public static String genCode (String str, int codeLength){
//将字符串转换为一个新的字符数组。
char[] verificationCodeArray = str.toCharArray();
Random random = new Random();
//计数器
int count = 0;
StringBuilder stringBuilder = new StringBuilder();
do {
//随机生成一个随机数
int index = random.nextInt(verificationCodeArray.length);
char c = verificationCodeArray[index];
//限制四位不重复数字
if (stringBuilder.indexOf(String.valueOf(c)) == -1) {
stringBuilder.append(c);
//计数器加1
count++;
}
//当count等于4时结束随机生成四位数的验证码
} while (count != codeLength);
return stringBuilder.toString();
}
}

View File

@ -0,0 +1,153 @@
package com.bwie.common.utils;
import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.model.GetObjectRequest;
import com.aliyun.oss.model.PutObjectRequest;
import lombok.extern.log4j.Log4j2;
import org.springframework.web.multipart.MultipartFile;
import java.io.*;
import java.time.LocalDateTime;
import java.util.UUID;
/**
* Oss
*/
@Log4j2
public class OssUtil {
/**
* Endpoint AccessKeyaccessKeySecretAPI访 访
*/
private static String endPoint = "oss-cn-shanghai.aliyuncs.com";
private static String accessKeyId = "LTAI5tD2tppzLQ4Rb6yKYyph";
private static String accessKeySecret = "KEKNKwVvDq7PZLjE63NPBouqHXox4Q";
private static String accessPre = "https://dzlmuyu.oss-cn-shanghai.aliyuncs.com/";
/**
* bucket
* @return
*/
private static String bucketName = "dzlmuyu";
private static OSS ossClient ;
static {
ossClient = new OSSClientBuilder().build(
endPoint,
accessKeyId,
accessKeySecret);
log.info("oss服务连接成功");
}
/**
*
* @param filePath
*/
public static String uploadFile(String filePath){
return uploadFileForBucket(bucketName,getOssFilePath(filePath) ,filePath);
}
/**
* multipartFile
* @param multipartFile
*/
public static String uploadMultipartFile(MultipartFile multipartFile) {
return uploadMultipartFile(bucketName,getOssFilePath(multipartFile.getOriginalFilename()),multipartFile);
}
/**
* multipartFile
* @param bucketName
* @param ossPath
* @param multipartFile
*/
public static String uploadMultipartFile(String bucketName , String ossPath , MultipartFile multipartFile){
InputStream inputStream = null;
try {
inputStream = multipartFile.getInputStream();
} catch (IOException e) {
e.printStackTrace();
}
uploadFileInputStreamForBucket(bucketName, ossPath, inputStream);
return accessPre+ossPath;
}
/**
* 使FilePutObject ** 使
* @param bucketName
* @param ossPath oss
* @param filePath
*/
public static String uploadFileForBucket(String bucketName , String ossPath , String filePath) {
// 创建PutObjectRequest对象。
PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, ossPath, new File(filePath));
// 上传
ossClient.putObject(putObjectRequest);
return accessPre+ossPath;
}
/**
* 使bucket
* @param bucketName
* @param ossPath oss
* @param filePath
*/
public static String uploadFileInputStreamForBucket(String bucketName , String ossPath , String filePath){
// 填写本地文件的完整路径。如果未指定本地路径,则默认从示例程序所属项目对应本地路径中上传文件流。
InputStream inputStream = null;
try {
inputStream = new FileInputStream(filePath);
} catch (FileNotFoundException e) {
e.printStackTrace();
}
// 填写Bucket名称和Object完整路径。Object完整路径中不能包含Bucket名称。
uploadFileInputStreamForBucket(bucketName, ossPath, inputStream);
return accessPre+ossPath;
}
public static void uploadFileInputStreamForBucket(String bucketName , String ossPath , InputStream inputStream ){
ossClient.putObject(bucketName, ossPath, inputStream);
}
/**
*
* @param ossFilePath
* @param filePath
*/
public static void downloadFile(String ossFilePath , String filePath ){
downloadFileForBucket(bucketName , ossFilePath , filePath);
}
/**
*
* @param bucketName
* @param ossFilePath oss
* @param filePath
*/
public static void downloadFileForBucket(String bucketName , String ossFilePath , String filePath ){
ossClient.getObject(new GetObjectRequest(bucketName, ossFilePath), new File(filePath));
}
/**
*
* @return
*/
public static String getOssDefaultPath(){
LocalDateTime now = LocalDateTime.now();
String url =
now.getYear()+"/"+
now.getMonth()+"/"+
now.getDayOfMonth()+"/"+
now.getHour()+"/"+
now.getMinute()+"/";
return url;
}
public static String getOssFilePath(String filePath){
String fileSuf = filePath.substring(filePath.indexOf(".") + 1);
return getOssDefaultPath() + UUID.randomUUID().toString() + "." + fileSuf;
}
}

View File

@ -0,0 +1,22 @@
//package com.bwie.common.utils;
//
//import org.springframework.context.annotation.Configuration;
//import org.springframework.http.converter.HttpMessageConverter;
//import org.springframework.stereotype.Component;
//import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
//
//import java.util.List;
//
///**
// * @author 86175
// * 消息转换器
// */
//@Configuration
//public class WebMvcConfig implements WebMvcConfigurer {
//
// @Override
// public void configureMessageConverters(List<HttpMessageConverter<?>> converters) {
//// converters.add(new ExcelMessageConverter());
// }
//
//}

View File

@ -0,0 +1,137 @@
package com.bwie.common.utils.core.date;
import org.apache.commons.lang3.time.DateFormatUtils;
import java.io.File;
import java.lang.management.ManagementFactory;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
/**
*
*
* @author markGuo
*/
public class DateUtils extends org.apache.commons.lang3.time.DateUtils
{
public static String YYYY = "yyyy";
public static String YYYY_MM = "yyyy-MM";
public static String YYYY_MM_DD = "yyyy-MM-dd";
public static String YYYYMMDDHHMMSS = "yyyyMMddHHmmss";
public static String YYYY_MM_DD_HH_MM_SS = "yyyy-MM-dd HH:mm:ss";
private static String[] parsePatterns = {
"yyyy-MM-dd", "yyyy-MM-dd HH:mm:ss", "yyyy-MM-dd HH:mm", "yyyy-MM",
"yyyy/MM/dd", "yyyy/MM/dd HH:mm:ss", "yyyy/MM/dd HH:mm", "yyyy/MM",
"yyyy.MM.dd", "yyyy.MM.dd HH:mm:ss", "yyyy.MM.dd HH:mm", "yyyy.MM"};
/**
* Date
*
* @return Date()
*/
public static Date getNowDate() {
return new Date();
}
/**
* , yyyy-MM-dd
*
* @return String
*/
public static String getDate() {
return dateTimeNow(YYYY_MM_DD);
}
public static final String getTime() {
return dateTimeNow(YYYY_MM_DD_HH_MM_SS);
}
public static final String dateTimeNow() {
return dateTimeNow(YYYYMMDDHHMMSS);
}
public static final String dateTimeNow(final String format) {
return parseDateToStr(format, new Date());
}
public static final String dateTime(final Date date) {
return parseDateToStr(YYYY_MM_DD, date);
}
public static final String parseDateToStr(final String format, final Date date) {
return new SimpleDateFormat(format).format(date);
}
public static final Date dateTime(final String format, final String ts) {
try {
return new SimpleDateFormat(format).parse(ts);
} catch (ParseException e) {
throw new RuntimeException(e);
}
}
/**
* // 2018/08/08
*/
public static final String datePath() {
Date now = new Date();
return DateFormatUtils.format(now, "yyyy"+File.separator+"MM"+ File.separator +"dd");
}
/**
* // 20180808
*/
public static final String dateTime() {
Date now = new Date();
return DateFormatUtils.format(now, "yyyyMMdd");
}
/**
*
*/
public static Date parseDate(Object str) {
if (str == null) {
return null;
}
try {
return parseDate(str.toString(), parsePatterns);
} catch (ParseException e) {
return null;
}
}
/**
*
*/
public static Date getServerStartDate() {
long time = ManagementFactory.getRuntimeMXBean().getStartTime();
return new Date(time);
}
/**
*
*/
public static String getDatePoor(Date endDate, Date nowDate) {
long nd = 1000 * 24 * 60 * 60;
long nh = 1000 * 60 * 60;
long nm = 1000 * 60;
// long ns = 1000;
// 获得两个时间的毫秒时间差异
long diff = endDate.getTime() - nowDate.getTime();
// 计算差多少天
long day = diff / nd;
// 计算差多少小时
long hour = diff % nd / nh;
// 计算差多少分钟
long min = diff % nd % nh / nm;
// 计算差多少秒//输出结果
// long sec = diff % nd % nh % nm / ns;
return day + "天" + hour + "小时" + min + "分钟";
}
}

View File

@ -0,0 +1,386 @@
package com.bwie.common.utils.core.reflect;
import com.bwie.common.utils.core.date.DateUtils;
import com.bwie.common.utils.core.text.Convert;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.Validate;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.lang.reflect.*;
import java.util.Date;
/**
* . getter/setter, 访, , Class, AOP.
*
* @author markGuo
*/
@SuppressWarnings("rawtypes")
public class ReflectUtils {
/**
* set
*/
private static final String SETTER_PREFIX = "set";
/**
* get
*/
private static final String GETTER_PREFIX = "get";
/**
* CGLIB
*/
private static final String CGLIB_CLASS_SEPARATOR = "$$";
/**
*
*/
private static Logger logger = LoggerFactory.getLogger(ReflectUtils.class);
/**
* Getter.
* ..
* @param obj
* @param propertyName
* @param <E>
* @return
*/
@SuppressWarnings("unchecked")
public static <E> E invokeGetter(Object obj, String propertyName) {
Object object = obj;
for (String name : StringUtils.split(propertyName, ".")) {
String getterMethodName = GETTER_PREFIX + StringUtils.capitalize(name);
object = invokeMethod(object, getterMethodName, new Class[] {}, new Object[] {});
}
return (E) object;
}
/**
* Setter,
* ..
* @param obj
* @param propertyName
* @param value
* @param <E>
*/
public static <E> void invokeSetter(Object obj, String propertyName, E value) {
Object object = obj;
String[] names = StringUtils.split(propertyName, ".");
for (int i = 0; i < names.length; i++) {
if (i < names.length - 1) {
String getterMethodName = GETTER_PREFIX + StringUtils.capitalize(names[i]);
object = invokeMethod(object, getterMethodName, new Class[] {}, new Object[] {});
} else {
String setterMethodName = SETTER_PREFIX + StringUtils.capitalize(names[i]);
invokeMethodByName(object, setterMethodName, new Object[] { value });
}
}
}
/**
* , private/protected, getter.
* @param obj
* @param fieldName
* @param <E>
* @return
*/
@SuppressWarnings("unchecked")
public static <E> E getFieldValue(final Object obj, final String fieldName) {
Field field = getAccessibleField(obj, fieldName);
if (field == null) {
logger.debug("在 [" + obj.getClass() + "] 中,没有找到 [" + fieldName + "] 字段 ");
return null;
}
E result = null;
try {
result = (E) field.get(obj);
} catch (IllegalAccessException e) {
logger.error("不可能抛出的异常{}", e.getMessage());
}
return result;
}
/**
* , private/protected, setter.
* @param obj
* @param fieldName
* @param value
* @param <E>
*/
public static <E> void setFieldValue(final Object obj, final String fieldName, final E value) {
Field field = getAccessibleField(obj, fieldName);
if (field == null) {
// throw new IllegalArgumentException("在 [" + obj.getClass() + "] 中,没有找到 [" + fieldName + "] 字段 ");
logger.debug("在 [" + obj.getClass() + "] 中,没有找到 [" + fieldName + "] 字段 ");
return;
}
try {
field.set(obj, value);
} catch (IllegalAccessException e) {
logger.error("不可能抛出的异常: {}", e.getMessage());
}
}
/**
* , private/protected.
* 使getAccessibleMethod()Method.
* +
* @param obj
* @param methodName
* @param parameterTypes
* @param args
* @param <E>
* @return
*/
@SuppressWarnings("unchecked")
public static <E> E invokeMethod(final Object obj, final String methodName, final Class<?>[] parameterTypes,
final Object[] args) {
if (obj == null || methodName == null) {
return null;
}
Method method = getAccessibleMethod(obj, methodName, parameterTypes);
if (method == null) {
logger.debug("在 [" + obj.getClass() + "] 中,没有找到 [" + methodName + "] 方法 ");
return null;
}
try {
return (E) method.invoke(obj, args);
} catch (Exception e) {
String msg = "method: " + method + ", obj: " + obj + ", args: " + args + "";
throw convertReflectionExceptionToUnchecked(msg, e);
}
}
/**
* , private/protected
* 使getAccessibleMethodByName()Method.
*
* @param obj
* @param methodName
* @param args
* @param <E>
* @return
*/
@SuppressWarnings("unchecked")
public static <E> E invokeMethodByName(final Object obj, final String methodName, final Object[] args) {
Method method = getAccessibleMethodByName(obj, methodName, args.length);
if (method == null) {
// 如果为空不报错,直接返回空。
logger.debug("在 [" + obj.getClass() + "] 中,没有找到 [" + methodName + "] 方法 ");
return null;
}
try {
// 类型转换(将参数数据类型转换为目标方法参数类型)
Class<?>[] cs = method.getParameterTypes();
for (int i = 0; i < cs.length; i++) {
if (args[i] != null && !args[i].getClass().equals(cs[i])) {
if (cs[i] == String.class) {
args[i] = Convert.toStr(args[i]);
if (StringUtils.endsWith((String) args[i], ".0")) {
args[i] = StringUtils.substringBefore((String) args[i], ".0");
}
} else if (cs[i] == Integer.class) {
args[i] = Convert.toInt(args[i]);
} else if (cs[i] == Long.class) {
args[i] = Convert.toLong(args[i]);
} else if (cs[i] == Double.class) {
args[i] = Convert.toDouble(args[i]);
} else if (cs[i] == Float.class) {
args[i] = Convert.toFloat(args[i]);
} else if (cs[i] == Date.class) {
if (args[i] instanceof String) {
args[i] = DateUtils.parseDate(args[i]);
}
}
}
}
return (E) method.invoke(obj, args);
} catch (Exception e) {
String msg = "method: " + method + ", obj: " + obj + ", args: " + args + "";
throw convertReflectionExceptionToUnchecked(msg, e);
}
}
/**
* , DeclaredField, 访.
* Object, null.
* @param obj
* @param fieldName
* @return
*/
public static Field getAccessibleField(final Object obj, final String fieldName) {
// 为空不报错。直接返回 null
if (obj == null) {
return null;
}
Validate.notBlank(fieldName, "fieldName can't be blank");
for (Class<?> superClass = obj.getClass(); superClass != Object.class; superClass = superClass.getSuperclass()) {
try {
Field field = superClass.getDeclaredField(fieldName);
makeAccessible(field);
return field;
}
catch (NoSuchFieldException e) {
continue;
}
}
return null;
}
/**
* , DeclaredMethod,访.
* Object, null.
* +
* . 使Method,Method.invoke(Object obj, Object... args)
* @param obj
* @param methodName
* @param parameterTypes
* @return
*/
public static Method getAccessibleMethod(final Object obj, final String methodName,
final Class<?>... parameterTypes) {
// 为空不报错。直接返回 null
if (obj == null) {
return null;
}
Validate.notBlank(methodName, "methodName can't be blank");
for (Class<?> searchType = obj.getClass(); searchType != Object.class; searchType = searchType.getSuperclass()) {
try {
Method method = searchType.getDeclaredMethod(methodName, parameterTypes);
makeAccessible(method);
return method;
} catch (NoSuchMethodException e) {
continue;
}
}
return null;
}
/**
* , DeclaredMethod,访.
* Object, null.
*
* . 使Method,Method.invoke(Object obj, Object... args)
* @param obj
* @param methodName
* @param argsNum
* @return
*/
public static Method getAccessibleMethodByName(final Object obj, final String methodName, int argsNum) {
// 为空不报错。直接返回 null
if (obj == null) {
return null;
}
Validate.notBlank(methodName, "methodName can't be blank");
for (Class<?> searchType = obj.getClass(); searchType != Object.class; searchType = searchType.getSuperclass()) {
Method[] methods = searchType.getDeclaredMethods();
for (Method method : methods) {
if (method.getName().equals(methodName) && method.getParameterTypes().length == argsNum) {
makeAccessible(method);
return method;
}
}
}
return null;
}
/**
* private/protectedpublicJDKSecurityManager
* @param method
*/
public static void makeAccessible(Method method) {
if ((!Modifier.isPublic(method.getModifiers()) || !Modifier.isPublic(method.getDeclaringClass().getModifiers()))
&& !method.isAccessible()) {
method.setAccessible(true);
}
}
/**
* private/protectedpublicJDKSecurityManager
* @param field
*/
public static void makeAccessible(Field field) {
if ((!Modifier.isPublic(field.getModifiers()) || !Modifier.isPublic(field.getDeclaringClass().getModifiers())
|| Modifier.isFinal(field.getModifiers())) && !field.isAccessible()) {
field.setAccessible(true);
}
}
/**
* , Class,
* , Object.class.
* @param clazz
* @param <T>
* @return
*/
@SuppressWarnings("unchecked")
public static <T> Class<T> getClassGenricType(final Class clazz) {
return getClassGenricType(clazz, 0);
}
/**
* , Class.
* , Object.class.
* @param clazz
* @param index
* @return
*/
public static Class getClassGenricType(final Class clazz, final int index) {
Type genType = clazz.getGenericSuperclass();
if (!(genType instanceof ParameterizedType)) {
logger.debug(clazz.getSimpleName() + "'s superclass not ParameterizedType");
return Object.class;
}
Type[] params = ((ParameterizedType) genType).getActualTypeArguments();
if (index >= params.length || index < 0) {
logger.debug("Index: " + index + ", Size of " + clazz.getSimpleName() + "'s Parameterized Type: "
+ params.length);
return Object.class;
}
if (!(params[index] instanceof Class)) {
logger.debug(clazz.getSimpleName() + " not set the actual class on superclass generic parameter");
return Object.class;
}
return (Class) params[index];
}
/**
*
* @param instance
* @return
*/
public static Class<?> getUserClass(Object instance) {
if (instance == null) {
throw new RuntimeException("Instance must not be null");
}
Class clazz = instance.getClass();
if (clazz != null && clazz.getName().contains(CGLIB_CLASS_SEPARATOR)) {
Class<?> superClass = clazz.getSuperclass();
if (superClass != null && !Object.class.equals(superClass)) {
return superClass;
}
}
return clazz;
}
/**
* checked exceptionunchecked exception.
* @param msg
* @param e
* @return
*/
public static RuntimeException convertReflectionExceptionToUnchecked(String msg, Exception e) {
if (e instanceof IllegalAccessException || e instanceof IllegalArgumentException
|| e instanceof NoSuchMethodException) {
return new IllegalArgumentException(msg, e);
} else if (e instanceof InvocationTargetException) {
return new RuntimeException(msg, ((InvocationTargetException) e).getTargetException());
}
return new RuntimeException(msg, e);
}
}

View File

@ -0,0 +1,106 @@
package com.bwie.common.utils.core.spring;
import org.springframework.aop.framework.AopContext;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.NoSuchBeanDefinitionException;
import org.springframework.beans.factory.config.BeanFactoryPostProcessor;
import org.springframework.beans.factory.config.ConfigurableListableBeanFactory;
import org.springframework.stereotype.Component;
/**
* spring 便springbean
*
* @author markGuo
*/
@Component
public final class SpringUtils implements BeanFactoryPostProcessor
{
/** Spring应用上下文环境 */
private static ConfigurableListableBeanFactory beanFactory;
@Override
public void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) throws BeansException {
SpringUtils.beanFactory = beanFactory;
}
/**
*
*
* @param name
* @return Object bean
* @throws BeansException
*
*/
@SuppressWarnings("unchecked")
public static <T> T getBean(String name) throws BeansException {
return (T) beanFactory.getBean(name);
}
/**
* requiredType
*
* @param clz
* @return
* @throws BeansException
*
*/
public static <T> T getBean(Class<T> clz) throws BeansException {
T result = beanFactory.getBean(clz);
return result;
}
/**
* BeanFactorybeantrue
*
* @param name
* @return boolean
*/
public static boolean containsBean(String name) {
return beanFactory.containsBean(name);
}
/**
* beansingletonprototype beanNoSuchBeanDefinitionException
*
* @param name
* @return boolean
* @throws NoSuchBeanDefinitionException
*
*/
public static boolean isSingleton(String name) throws NoSuchBeanDefinitionException {
return beanFactory.isSingleton(name);
}
/**
* @param name
* @return Class
* @throws NoSuchBeanDefinitionException
*
*/
public static Class<?> getType(String name) throws NoSuchBeanDefinitionException {
return beanFactory.getType(name);
}
/**
* beanbean
*
* @param name
* @return
* @throws NoSuchBeanDefinitionException
*
*/
public static String[] getAliases(String name) throws NoSuchBeanDefinitionException {
return beanFactory.getAliases(name);
}
/**
* aop
*
* @param invoker
* @return
*/
@SuppressWarnings("unchecked")
public static <T> T getAopProxy(T invoker) {
return (T) AopContext.currentProxy();
}
}

View File

@ -0,0 +1,78 @@
package com.bwie.common.utils.core.text;
import org.apache.commons.lang3.StringUtils;
import java.nio.charset.Charset;
import java.nio.charset.StandardCharsets;
/**
*
*
* @author markGuo
*/
public class CharsetKit
{
/** ISO-8859-1 */
public static final String ISO_8859_1 = "ISO-8859-1";
/** UTF-8 */
public static final String UTF_8 = "UTF-8";
/** GBK */
public static final String GBK = "GBK";
/** ISO-8859-1 */
public static final Charset CHARSET_ISO_8859_1 = Charset.forName(ISO_8859_1);
/** UTF-8 */
public static final Charset CHARSET_UTF_8 = Charset.forName(UTF_8);
/** GBK */
public static final Charset CHARSET_GBK = Charset.forName(GBK);
/**
* Charset
*
* @param charset
* @return Charset
*/
public static Charset charset(String charset) {
return StringUtils.isEmpty(charset) ? Charset.defaultCharset() : Charset.forName(charset);
}
/**
*
*
* @param source
* @param srcCharset ISO-8859-1
* @param destCharset UTF-8
* @return
*/
public static String convert(String source, String srcCharset, String destCharset) {
return convert(source, Charset.forName(srcCharset), Charset.forName(destCharset));
}
/**
*
*
* @param source
* @param srcCharset ISO-8859-1
* @param destCharset UTF-8
* @return
*/
public static String convert(String source, Charset srcCharset, Charset destCharset) {
if (null == srcCharset) {
srcCharset = StandardCharsets.ISO_8859_1;
}
if (null == destCharset) {
srcCharset = StandardCharsets.UTF_8;
}
if (StringUtils.isEmpty(source) || srcCharset.equals(destCharset)) {
return source;
}
return new String(source.getBytes(srcCharset), destCharset);
}
/**
* @return
*/
public static String systemCharset() {
return Charset.defaultCharset().name();
}
}

View File

@ -0,0 +1,818 @@
package com.bwie.common.utils.core.text;
import org.apache.commons.lang3.StringUtils;
import java.math.BigDecimal;
import java.math.BigInteger;
import java.nio.ByteBuffer;
import java.nio.charset.Charset;
import java.text.NumberFormat;
import java.util.Set;
/**
*
*
* @author markGuo
*/
public class Convert {
/**
* <br>
* null<br>
*
*
* @param value
* @param defaultValue
* @return
*/
public static String toStr(Object value, String defaultValue) {
if (null == value) {
return defaultValue;
}
if (value instanceof String) {
return (String) value;
}
return value.toString();
}
/**
* <br>
* <code>null</code><code>null</code><br>
*
*
* @param value
* @return
*/
public static String toStr(Object value) {
return toStr(value, null);
}
/**
* <br>
* null<br>
*
*
* @param value
* @param defaultValue
* @return
*/
public static Character toChar(Object value, Character defaultValue) {
if (null == value) {
return defaultValue;
}
if (value instanceof Character) {
return (Character) value;
}
final String valueStr = toStr(value, null);
return StringUtils.isEmpty(valueStr) ? defaultValue : valueStr.charAt(0);
}
/**
* <br>
* <code>null</code><code>null</code><br>
*
*
* @param value
* @return
*/
public static Character toChar(Object value) {
return toChar(value, null);
}
/**
* byte<br>
* <code>null</code><br>
*
*
* @param value
* @param defaultValue
* @return
*/
public static Byte toByte(Object value, Byte defaultValue) {
if (value == null) {
return defaultValue;
} else if (value instanceof Byte) {
return (Byte) value;
}else if (value instanceof Number) {
return ((Number) value).byteValue();
}
final String valueStr = toStr(value, null);
if (StringUtils.isEmpty(valueStr)) {
return defaultValue;
}
try {
return Byte.parseByte(valueStr);
} catch (Exception e) {
return defaultValue;
}
}
/**
* byte<br>
* <code>null</code><code>null</code><br>
*
*
* @param value
* @return
*/
public static Byte toByte(Object value) {
return toByte(value, null);
}
/**
* Short<br>
* <code>null</code><br>
*
*
* @param value
* @param defaultValue
* @return
*/
public static Short toShort(Object value, Short defaultValue) {
if (value == null) {
return defaultValue;
}else if (value instanceof Short) {
return (Short) value;
} else if (value instanceof Number) {
return ((Number) value).shortValue();
}
final String valueStr = toStr(value, null);
if (StringUtils.isEmpty(valueStr)) {
return defaultValue;
}
try {
return Short.parseShort(valueStr.trim());
} catch (Exception e) {
return defaultValue;
}
}
/**
* Short<br>
* <code>null</code><code>null</code><br>
*
*
* @param value
* @return
*/
public static Short toShort(Object value) {
return toShort(value, null);
}
/**
* Number<br>
* <br>
*
*
* @param value
* @param defaultValue
* @return
*/
public static Number toNumber(Object value, Number defaultValue) {
if (value == null) {
return defaultValue;
} else if (value instanceof Number) {
return (Number) value;
}
final String valueStr = toStr(value, null);
if (StringUtils.isEmpty(valueStr)) {
return defaultValue;
}
try {
return NumberFormat.getInstance().parse(valueStr);
} catch (Exception e) {
return defaultValue;
}
}
/**
* Number<br>
* <code>null</code><br>
*
*
* @param value
* @return
*/
public static Number toNumber(Object value) {
return toNumber(value, null);
}
/**
* int<br>
* <br>
*
*
* @param value
* @param defaultValue
* @return
*/
public static Integer toInt(Object value, Integer defaultValue) {
if (value == null) {
return defaultValue;
} else if (value instanceof Integer) {
return (Integer) value;
} else if (value instanceof Number) {
return ((Number) value).intValue();
}
final String valueStr = toStr(value, null);
if (StringUtils.isEmpty(valueStr)) {
return defaultValue;
}
try {
return Integer.parseInt(valueStr.trim());
} catch (Exception e) {
return defaultValue;
}
}
/**
* int<br>
* <code>null</code><code>null</code><br>
*
*
* @param value
* @return
*/
public static Integer toInt(Object value) {
return toInt(value, null);
}
/**
* Integer<br>
*
* @param str
* @return
*/
public static Integer[] toIntArray(String str) {
return toIntArray(",", str);
}
/**
* Long<br>
*
* @param str
* @return
*/
public static Long[] toLongArray(String str) {
return toLongArray(",", str);
}
/**
* Integer<br>
*
* @param split
* @param split
* @return
*/
public static Integer[] toIntArray(String split, String str) {
if (StringUtils.isEmpty(str)) {
return new Integer[] {};
}
String[] arr = str.split(split);
final Integer[] ints = new Integer[arr.length];
for (int i = 0; i < arr.length; i++) {
final Integer v = toInt(arr[i], 0);
ints[i] = v;
}
return ints;
}
/**
* Long<br>
*
* @param split
* @param str
* @return
*/
public static Long[] toLongArray(String split, String str) {
if (StringUtils.isEmpty(str)) {
return new Long[] {};
}
String[] arr = str.split(split);
final Long[] longs = new Long[arr.length];
for (int i = 0; i < arr.length; i++) {
final Long v = toLong(arr[i], null);
longs[i] = v;
}
return longs;
}
/**
* String<br>
*
* @param str
* @return
*/
public static String[] toStrArray(String str) {
return toStrArray(",", str);
}
/**
* String<br>
*
* @param split
* @param split
* @return
*/
public static String[] toStrArray(String split, String str) {
return str.split(split);
}
/**
* long<br>
* <br>
*
*
* @param value
* @param defaultValue
* @return
*/
public static Long toLong(Object value, Long defaultValue) {
if (value == null) {
return defaultValue;
} else if (value instanceof Long) {
return (Long) value;
} else if (value instanceof Number) {
return ((Number) value).longValue();
}
final String valueStr = toStr(value, null);
if (StringUtils.isEmpty(valueStr)) {
return defaultValue;
}
try {
// 支持科学计数法
return new BigDecimal(valueStr.trim()).longValue();
} catch (Exception e) {
return defaultValue;
}
}
/**
* long<br>
* <code>null</code><code>null</code><br>
*
*
* @param value
* @return
*/
public static Long toLong(Object value) {
return toLong(value, null);
}
/**
* double<br>
* <br>
*
*
* @param value
* @param defaultValue
* @return
*/
public static Double toDouble(Object value, Double defaultValue) {
if (value == null) {
return defaultValue;
} else if (value instanceof Double) {
return (Double) value;
} else if (value instanceof Number) {
return ((Number) value).doubleValue();
}
final String valueStr = toStr(value, null);
if (StringUtils.isEmpty(valueStr)) {
return defaultValue;
}
try {
// 支持科学计数法
return new BigDecimal(valueStr.trim()).doubleValue();
} catch (Exception e) {
return defaultValue;
}
}
/**
* double<br>
* <code>null</code><br>
*
*
* @param value
* @return
*/
public static Double toDouble(Object value) {
return toDouble(value, null);
}
/**
* Float<br>
* <br>
*
*
* @param value
* @param defaultValue
* @return
*/
public static Float toFloat(Object value, Float defaultValue) {
if (value == null) {
return defaultValue;
} else if (value instanceof Float) {
return (Float) value;
} else if (value instanceof Number) {
return ((Number) value).floatValue();
}
final String valueStr = toStr(value, null);
if (StringUtils.isEmpty(valueStr)) {
return defaultValue;
}
try {
return Float.parseFloat(valueStr.trim());
} catch (Exception e) {
return defaultValue;
}
}
/**
* Float<br>
* <code>null</code><br>
*
*
* @param value
* @return
*/
public static Float toFloat(Object value) {
return toFloat(value, null);
}
/**
* boolean<br>
* Stringtruefalseyesokno1,0 <br>
*
*
* @param value
* @param defaultValue
* @return
*/
public static Boolean toBool(Object value, Boolean defaultValue) {
if (value == null) {
return defaultValue;
} else if (value instanceof Boolean) {
return (Boolean) value;
}
String valueStr = toStr(value, null);
if (StringUtils.isEmpty(valueStr)) {
return defaultValue;
}
valueStr = valueStr.trim().toLowerCase();
switch (valueStr) {
case "true":
return true;
case "false":
return false;
case "yes":
return true;
case "ok":
return true;
case "no":
return false;
case "1":
return true;
case "0":
return false;
default:
return defaultValue;
}
}
/**
* boolean<br>
* <code>null</code><br>
*
*
* @param value
* @return
*/
public static Boolean toBool(Object value) {
return toBool(value, null);
}
/**
* Enum<br>
* <br>
*
* @param clazz EnumClass
* @param value
* @param defaultValue
* @return Enum
*/
public static <E extends Enum<E>> E toEnum(Class<E> clazz, Object value, E defaultValue) {
if (value == null) {
return defaultValue;
} else if (clazz.isAssignableFrom(value.getClass())) {
@SuppressWarnings("unchecked")
E myE = (E) value;
return myE;
}
final String valueStr = toStr(value, null);
if (StringUtils.isEmpty(valueStr)) {
return defaultValue;
}
try {
return Enum.valueOf(clazz, valueStr);
} catch (Exception e) {
return defaultValue;
}
}
/**
* Enum<br>
* <code>null</code><br>
*
* @param clazz EnumClass
* @param value
* @return Enum
*/
public static <E extends Enum<E>> E toEnum(Class<E> clazz, Object value) {
return toEnum(clazz, value, null);
}
/**
* BigInteger<br>
* <br>
*
*
* @param value
* @param defaultValue
* @return
*/
public static BigInteger toBigInteger(Object value, BigInteger defaultValue) {
if (value == null) {
return defaultValue;
} else if (value instanceof BigInteger) {
return (BigInteger) value;
} else if (value instanceof Long) {
return BigInteger.valueOf((Long) value);
}
final String valueStr = toStr(value, null);
if (StringUtils.isEmpty(valueStr)) {
return defaultValue;
}
try {
return new BigInteger(valueStr);
} catch (Exception e) {
return defaultValue;
}
}
/**
* BigInteger<br>
* <code>null</code><br>
*
*
* @param value
* @return
*/
public static BigInteger toBigInteger(Object value) {
return toBigInteger(value, null);
}
/**
* BigDecimal<br>
* <br>
*
*
* @param value
* @param defaultValue
* @return
*/
public static BigDecimal toBigDecimal(Object value, BigDecimal defaultValue) {
if (value == null) {
return defaultValue;
} else if (value instanceof BigDecimal) {
return (BigDecimal) value;
} else if (value instanceof Long) {
return new BigDecimal((Long) value);
} else if (value instanceof Double) {
return new BigDecimal((Double) value);
} else if (value instanceof Integer) {
return new BigDecimal((Integer) value);
}
final String valueStr = toStr(value, null);
if (StringUtils.isEmpty(valueStr)) {
return defaultValue;
}
try {
return new BigDecimal(valueStr);
} catch (Exception e) {
return defaultValue;
}
}
/**
* BigDecimal<br>
* <br>
*
*
* @param value
* @return
*/
public static BigDecimal toBigDecimal(Object value) {
return toBigDecimal(value, null);
}
/**
* <br>
* 1ByteByteBuffer 2Arrays.toString
*
* @param obj
* @return
*/
public static String utf8Str(Object obj) {
return str(obj, CharsetKit.CHARSET_UTF_8);
}
/**
* <br>
* 1ByteByteBuffer 2Arrays.toString
*
* @param obj
* @param charsetName
* @return
*/
public static String str(Object obj, String charsetName) {
return str(obj, Charset.forName(charsetName));
}
/**
* <br>
* 1ByteByteBuffer 2Arrays.toString
*
* @param obj
* @param charset
* @return
*/
public static String str(Object obj, Charset charset) {
if (null == obj) {
return null;
} else if (obj instanceof String) {
return (String) obj;
} else if (obj instanceof byte[] || obj instanceof Byte[]) {
return str(obj, charset);
} else if (obj instanceof ByteBuffer) {
return str((ByteBuffer) obj, charset);
}
return obj.toString();
}
/**
* byte
*
* @param bytes byte
* @param charset
* @return
*/
public static String str(byte[] bytes, String charset) {
return str(bytes, StringUtils.isEmpty(charset) ? Charset.defaultCharset() : Charset.forName(charset));
}
/**
*
*
* @param data
* @param charset
* @return
*/
public static String str(byte[] data, Charset charset) {
if (data == null) {
return null;
} else if (null == charset) {
return new String(data);
}
return new String(data, charset);
}
/**
* byteBuffer
*
* @param data
* @param charset 使
* @return
*/
public static String str(ByteBuffer data, String charset) {
if (data == null) {
return null;
}
return str(data, Charset.forName(charset));
}
/**
* byteBuffer
*
* @param data
* @param charset 使
* @return
*/
public static String str(ByteBuffer data, Charset charset) {
if (null == charset) {
charset = Charset.defaultCharset();
}
return charset.decode(data).toString();
}
// ----------------------------------------------------------------------- 全角半角转换
/**
*
*
* @param input String.
* @return .
*/
public static String toSBC(String input) {
return toSBC(input, null);
}
/**
*
*
* @param input String
* @param notConvertSet
* @return .
*/
public static String toSBC(String input, Set<Character> notConvertSet) {
char c[] = input.toCharArray();
for (int i = 0; i < c.length; i++) {
if (null != notConvertSet && notConvertSet.contains(c[i])) {
// 跳过不替换的字符
continue;
} else if (c[i] == ' ') {
c[i] = '\u3000';
} else if (c[i] < '\177') {
c[i] = (char) (c[i] + 65248);
}
}
return new String(c);
}
/**
*
*
* @param input String.
* @return
*/
public static String toDBC(String input) {
return toDBC(input, null);
}
/**
*
*
* @param text
* @param notConvertSet
* @return
*/
public static String toDBC(String text, Set<Character> notConvertSet) {
char c[] = text.toCharArray();
for (int i = 0; i < c.length; i++) {
if (null != notConvertSet && notConvertSet.contains(c[i])) {
// 跳过不替换的字符
continue;
} else if (c[i] == '\u3000') {
c[i] = ' ';
} else if (c[i] > '\uFF00' && c[i] < '\uFF5F') {
c[i] = (char) (c[i] - 65248);
}
}
return new String(c);
}
/**
*
*
* @param n
* @return
*/
public static String digitUppercase(double n) {
String[] fraction = { "角", "分" };
String[] digit = { "零", "壹", "贰", "叁", "肆", "伍", "陆", "柒", "捌", "玖" };
String[][] unit = { { "元", "万", "亿" }, { "", "拾", "佰", "仟" } };
String head = n < 0 ? "负" : "";
n = Math.abs(n);
String s = "";
for (int i = 0; i < fraction.length; i++) {
s += (digit[(int) (Math.floor(n * 10 * Math.pow(10, i)) % 10)] + fraction[i]).replaceAll("(零.)+", "");
}
if (s.length() < 1) {
s = "整";
}
int integerPart = (int) Math.floor(n);
for (int i = 0; i < unit[0].length && integerPart > 0; i++) {
String p = "";
for (int j = 0; j < unit[1].length && n > 0; j++) {
p = digit[integerPart % 10] + unit[1][j] + p;
integerPart = integerPart / 10;
}
s = p.replaceAll("(零.)*零$", "").replaceAll("^$", "零") + unit[0][i] + s;
}
return head + s.replaceAll("(零.)*零元", "元").replaceFirst("(零.)+", "").replaceAll("(零.)+", "零").replaceAll("^整$", "零元整");
}
}

View File

@ -0,0 +1,874 @@
package com.bwie.common.utils.poi;
import com.bwie.common.utils.core.date.DateUtils;
import com.bwie.common.utils.core.reflect.ReflectUtils;
import com.bwie.common.utils.core.spring.SpringUtils;
import com.bwie.common.utils.core.text.Convert;
import com.bwie.common.utils.poi.annotation.Excel;
import com.bwie.common.utils.poi.annotation.Excel.Type;
import com.bwie.common.utils.poi.annotation.Excels;
import com.bwie.common.utils.poi.exception.PoiException;
import lombok.extern.log4j.Log4j2;
import org.apache.commons.lang3.StringUtils;
import org.apache.poi.hssf.usermodel.HSSFDateUtil;
import org.apache.poi.ss.usermodel.*;
import org.apache.poi.ss.util.CellRangeAddressList;
import org.apache.poi.util.IOUtils;
import org.apache.poi.xssf.streaming.SXSSFWorkbook;
import org.apache.poi.xssf.usermodel.XSSFDataValidation;
import javax.servlet.http.HttpServletResponse;
import java.io.*;
import java.lang.reflect.Field;
import java.lang.reflect.Method;
import java.math.BigDecimal;
import java.text.DecimalFormat;
import java.util.*;
/**
* Excel
*
* @author
*/
@Log4j2
public class ExcelUtil<T>
{
/**
*
*/
private static final String[] TEMPLATE_COLUMNS = {
"员工编号","员工姓名","员工性别","员工年龄","员工薪资","薪资范围"
};
/**
* 0 1
*/
private static final Integer[] DATA_TYPE_COLUMNS = {
0,1,1,0,0,1
};
/**
* Excel sheet65536
*/
public static final int sheetSize = 65536;
/**
*
*/
private String sheetName;
/**
* EXPORT:IMPORT
*/
private Type type;
/**
*
*/
private Workbook wb;
/**
*
*/
private Sheet sheet;
/**
*
*/
private Map<String, CellStyle> styles;
/**
*
*/
private List<T> list;
/**
*
*/
private List<Object[]> fields;
/**
*
*/
public Class<T> clazz;
public ExcelUtil(Class<T> clazz) {
this.clazz = clazz;
}
public void init(List<T> list, String sheetName, Type type) {
if (list == null) {
list = new ArrayList<T>();
}
this.list = list;
this.sheetName = sheetName;
this.type = type;
createExcelField();
createWorkbook();
}
/**
* excellist
*
* @param is
* @return
*/
public List<T> importExcel(InputStream is) throws Exception {
return importExcel(StringUtils.EMPTY, is);
}
/**
* excellist
*
* @param sheetName
* @param is
* @return
*/
public List<T> importExcel(String sheetName, InputStream is) throws Exception {
this.type = Type.IMPORT;
this.wb = WorkbookFactory.create(is);
List<T> list = new ArrayList<T>();
Sheet sheet = null;
if (StringUtils.isNotEmpty(sheetName)) {
// 如果指定sheet名,则取指定sheet中的内容.
sheet = wb.getSheet(sheetName);
} else {
// 如果传入的sheet名不存在则默认指向第1个sheet.
sheet = wb.getSheetAt(0);
}
if (sheet == null) {
throw new IOException("文件sheet不存在");
}
int rows = sheet.getPhysicalNumberOfRows();
if (rows > 0) {
// 定义一个map用于存放excel列的序号和field.
Map<String, Integer> cellMap = new HashMap<String, Integer>();
// 获取表头
Row heard = sheet.getRow(0);
/**
*
*/
if (!checkTemplate(heard)) {
System.out.println("模板错误,请检查列名是否正确");
return null;
}
for (int i = 0; i < heard.getPhysicalNumberOfCells(); i++) {
Cell cell = heard.getCell(i);
if (cell != null) {
String value = this.getCellValue(heard, i).toString();
cellMap.put(value, i);
}
else {
cellMap.put(null, i);
}
}
// 有数据时才处理 得到类的所有field.
Field[] allFields = clazz.getDeclaredFields();
// 定义一个map用于存放列的序号和field.
Map<Integer, Field> fieldsMap = new HashMap<Integer, Field>();
for (int col = 0; col < allFields.length; col++) {
Field field = allFields[col];
Excel attr = field.getAnnotation(Excel.class);
if (attr != null && (attr.type() == Type.ALL || attr.type() == type)) {
// 设置类的私有字段属性可访问.
field.setAccessible(true);
Integer column = cellMap.get(attr.name());
fieldsMap.put(column, field);
}
}
/**
*
*/
List<String> errorMessages = new ArrayList<>();
for (int i = 1; i < rows; i++) {
// 从第2行开始取数据,默认第一行是表头.
Row row = sheet.getRow(i);
/**
*
*/
int nums = row.getPhysicalNumberOfCells();
for (int j = 0; j < nums; j++) {
if (!checkDataType(row,j)){
String errorMessage = String.format("第%d行%d列数据类型错误", i + 1,j+1);
errorMessages.add(errorMessage);
}
}
T entity = null;
for (Map.Entry<Integer, Field> entry : fieldsMap.entrySet()) {
if (entry.getKey() == null){
continue;
}
Object val = this.getCellValue(row, entry.getKey());
// 如果不存在实例则新建.
entity = (entity == null ? clazz.newInstance() : entity);
// 从map中得到对应列的field.
Field field = fieldsMap.get(entry.getKey());
// 取得类型,并根据对象类型设置值.
Class<?> fieldType = field.getType();
if (String.class == fieldType) {
String s = Convert.toStr(val);
if (StringUtils.endsWith(s, ".0")) {
val = StringUtils.substringBefore(s, ".0");
} else {
String dateFormat = field.getAnnotation(Excel.class).dateFormat();
if (StringUtils.isNotEmpty(dateFormat)) {
val = DateUtils.parseDateToStr(dateFormat, (Date) val);
} else {
val = Convert.toStr(val);
}
}
} else if ((Integer.TYPE == fieldType) || (Integer.class == fieldType)) {
val = Convert.toInt(val);
} else if ((Long.TYPE == fieldType) || (Long.class == fieldType)) {
val = Convert.toLong(val);
} else if ((Double.TYPE == fieldType) || (Double.class == fieldType)) {
val = Convert.toDouble(val);
} else if ((Float.TYPE == fieldType) || (Float.class == fieldType)) {
val = Convert.toFloat(val);
} else if (BigDecimal.class == fieldType) {
val = Convert.toBigDecimal(val);
} else if (Date.class == fieldType) {
if (val instanceof String) {
val = DateUtils.parseDate(val);
} else if (val instanceof Double) {
val = DateUtil.getJavaDate((Double) val);
}
}
if (fieldType != null) {
Excel attr = field.getAnnotation(Excel.class);
String propertyName = field.getName();
if (StringUtils.isNotEmpty(attr.targetAttr())) {
propertyName = field.getName() + "." + attr.targetAttr();
} else if (StringUtils.isNotEmpty(attr.readConverterExp())) {
val = reverseByExp(String.valueOf(val), attr.readConverterExp());
}
ReflectUtils.invokeSetter(entity, propertyName, val);
}
}
list.add(entity);
}
//打印所有错误信息
System.out.println("-------------------------错误信息如下:--------------------------");
for (String errorMessage : errorMessages) {
System.out.println(errorMessage);
}
}
return list;
}
/**
*
* @param heard
* @return
*/
private boolean checkTemplate(Row heard) {
int numberOfCells = heard.getPhysicalNumberOfCells();
if (numberOfCells!=TEMPLATE_COLUMNS.length){
return false;
}
for (int i = 0; i < numberOfCells; i++) {
if (!heard.getCell(i).getStringCellValue().equals(TEMPLATE_COLUMNS[i])){
return false;
}
}
return true;
}
/**
*
* @param row
* @return
*/
private boolean checkDataType(Row row,Integer column) {
try {
//设置数据类型
if (1==DATA_TYPE_COLUMNS[column]){
String stringCellValue = row.getCell(column).getStringCellValue();
}else {
/*String numericCellValue = row.getCell(column).getStringCellValue();
double v = Double.parseDouble(numericCellValue);*/
double numericCellValue = row.getCell(column).getNumericCellValue();
}
return true;
} catch (Exception e) {
return false;
}
}
/**
* listexcel
*
* @param response
* @param list
* @param sheetName
* @return
* @throws IOException
*/
public void exportExcel(HttpServletResponse response, List<T> list, String sheetName){
response.setContentType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");
response.setCharacterEncoding("utf-8");
this.init(list, sheetName, Type.EXPORT);
writeSheet();
exportExcel(response);
}
/**
* listexcel
*
* @return
*/
public void exportExcel(HttpServletResponse response){
try{
wb.write(response.getOutputStream());
} catch (Exception e){
log.error("导出Excel异常{}", e.getMessage());
} finally {
IOUtils.closeQuietly(wb);
}
}
/**
* listexcel
*
* @param list
* @param sheetName
* @return
*/
public String exportExcel(List<T> list, String sheetName) {
this.init(list, sheetName, Type.EXPORT);
return exportExcel();
}
/**
* listexcel
*
* @param sheetName
* @return
*/
public String importTemplateExcel(String sheetName) {
this.init(null, sheetName, Type.IMPORT);
return exportExcel();
}
/**
* sheet
*/
public void writeSheet(){
// 取出一共有多少个sheet.
double sheetNo = Math.ceil(list.size() / sheetSize);
for (int index = 0; index <= sheetNo; index++) {
createSheet(sheetNo, index);
// 产生一行
Row row = sheet.createRow(0);
int column = 0;
// 写入各个字段的列头名称
for (Object[] os : fields) {
Excel excel = (Excel) os[1];
this.createCell(excel, row, column++);
}
if (Type.EXPORT.equals(type)) {
fillExcelData(index, row);
}
}
}
/**
* listexcel
*
* @return
*/
public String exportExcel() {
OutputStream out = null;
try {
writeSheet();
String filename = encodingFilename(sheetName);
out = new FileOutputStream(getAbsoluteFile(filename));
wb.write(out);
return filename;
} catch (Exception e) {
log.error("导出Excel异常{}", e.getMessage());
throw new PoiException("导出Excel失败请联系管理员");
} finally {
try {
if (wb != null) {
wb.close();
}
if (out != null) {
out.close();
}
} catch (IOException e1) {
e1.printStackTrace();
}
}
}
/**
* excel
*
* @param index
* @param row
*/
public void fillExcelData(int index, Row row) {
int startNo = index * sheetSize;
int endNo = Math.min(startNo + sheetSize, list.size());
for (int i = startNo; i < endNo; i++) {
row = sheet.createRow(i + 1 - startNo);
// 得到导出对象.
T vo = (T) list.get(i);
int column = 0;
for (Object[] os : fields) {
Field field = (Field) os[0];
Excel excel = (Excel) os[1];
// 设置实体类私有属性可访问
field.setAccessible(true);
this.addCell(excel, row, vo, field, column++);
}
}
}
/**
*
*
* @param wb
* @return
*/
private Map<String, CellStyle> createStyles(Workbook wb) {
// 写入各条记录,每条记录对应excel表中的一行
Map<String, CellStyle> styles = new HashMap<String, CellStyle>();
CellStyle style = wb.createCellStyle();
style.setAlignment(HorizontalAlignment.CENTER);
style.setVerticalAlignment(VerticalAlignment.CENTER);
style.setBorderRight(BorderStyle.THIN);
style.setRightBorderColor(IndexedColors.GREY_50_PERCENT.getIndex());
style.setBorderLeft(BorderStyle.THIN);
style.setLeftBorderColor(IndexedColors.GREY_50_PERCENT.getIndex());
style.setBorderTop(BorderStyle.THIN);
style.setTopBorderColor(IndexedColors.GREY_50_PERCENT.getIndex());
style.setBorderBottom(BorderStyle.THIN);
style.setBottomBorderColor(IndexedColors.GREY_50_PERCENT.getIndex());
Font dataFont = wb.createFont();
dataFont.setFontName("Arial");
dataFont.setFontHeightInPoints((short) 10);
style.setFont(dataFont);
styles.put("data", style);
style = wb.createCellStyle();
style.cloneStyleFrom(styles.get("data"));
style.setAlignment(HorizontalAlignment.CENTER);
style.setVerticalAlignment(VerticalAlignment.CENTER);
style.setFillForegroundColor(IndexedColors.GREY_50_PERCENT.getIndex());
style.setFillPattern(FillPatternType.SOLID_FOREGROUND);
Font headerFont = wb.createFont();
headerFont.setFontName("Arial");
headerFont.setFontHeightInPoints((short) 10);
headerFont.setBold(true);
headerFont.setColor(IndexedColors.WHITE.getIndex());
style.setFont(headerFont);
styles.put("header", style);
return styles;
}
/**
*
*/
public Cell createCell(Excel attr, Row row, int column) {
// 创建列
Cell cell = row.createCell(column);
// 写入列信息
cell.setCellValue(attr.name());
setDataValidation(attr, row, column);
cell.setCellStyle(styles.get("header"));
return cell;
}
/**
*
*
* @param value
* @param attr
* @param cell
*/
public void setCellVo(Object value, Excel attr, Cell cell) {
if (Excel.ColumnType.STRING == attr.cellType()) {
cell.setCellType(CellType.NUMERIC);
cell.setCellValue(value == null ? attr.defaultValue() : value + attr.suffix());
} else if (Excel.ColumnType.NUMERIC == attr.cellType()) {
cell.setCellType(CellType.NUMERIC);
cell.setCellValue(Integer.parseInt(value + ""));
}
}
/**
*
*/
public void setDataValidation(Excel attr, Row row, int column) {
if (attr.name().indexOf("注:") >= 0) {
sheet.setColumnWidth(column, 6000);
} else {
// 设置列宽
sheet.setColumnWidth(column, (int) ((attr.width() + 0.72) * 256));
row.setHeight((short) (attr.height() * 20));
}
// 如果设置了提示信息则鼠标放上去提示.
if (StringUtils.isNotEmpty(attr.prompt())) {
// 这里默认设了2-101列提示.
setXSSFPrompt(sheet, "", attr.prompt(), 1, 100, column, column);
}
// 如果设置了combo属性则本列只能选择不能输入
if (attr.combo().length > 0) {
// 这里默认设了2-101列只能选择不能输入.
setXSSFValidation(sheet, attr.combo(), 1, 100, column, column);
}
}
/**
*
*/
public Cell addCell(Excel attr, Row row, T vo, Field field, int column) {
Cell cell = null;
try {
// 设置行高
row.setHeight((short) (attr.height() * 20));
// 根据Excel中设置情况决定是否导出,有些情况需要保持为空,希望用户填写这一列.
if (attr.isExport()) {
// 创建cell
cell = row.createCell(column);
cell.setCellStyle(styles.get("data"));
// 用于读取对象中的属性
Object value = getTargetValue(vo, field, attr);
//时间类型格式化
String dateFormat = attr.dateFormat();
//读取表达式
String readConverterExp = attr.readConverterExp();
//分隔符
String splitStr = attr.splitStr();
//反射对象
Class<?> invokeClass = attr.invokeClass();
//反射方法名称
String invokeMethod = attr.invokeMethod();
if (StringUtils.isNotEmpty(dateFormat) && value != null) {
cell.setCellValue(DateUtils.parseDateToStr(dateFormat, (Date) value));
} else if (StringUtils.isNotEmpty(readConverterExp) && value != null) {
// 判断是否有分隔符
if (StringUtils.isNotEmpty(splitStr)){
StringBuilder cellValue = new StringBuilder();
String valueStr = String.valueOf(value);
String[] valueStrSplit = valueStr.split(splitStr);
int valueStrSplitLength = valueStrSplit.length;
for (int i = 0; ; i++) {
cellValue.append(convertByExp(valueStrSplit[i], readConverterExp));
if (i == valueStrSplitLength-1){
break;
}
cellValue.append(",");
}
cell.setCellValue(cellValue.toString());
} else {
cell.setCellValue(convertByExp(String.valueOf(value), readConverterExp));
}
}
// 判断是否需要取值
else if((!invokeClass.getName().equals(String.class.getName())) && StringUtils.isNotEmpty(invokeMethod)){
Object bean = SpringUtils.getBean(invokeClass);
Method thisMethod = null;
Method[] methods = invokeClass.getMethods();
for (Method method : methods) {
if (method.getName().equals(invokeMethod)){
thisMethod = method;
continue;
}
}
cell.setCellValue(thisMethod.invoke(bean,value).toString());
} else {
// 设置列类型
setCellVo(value, attr, cell);
}
}
} catch (Exception e) {
log.error("导出Excel失败{}", e);
}
return cell;
}
/**
* POI XSSFSheet
*
* @param sheet
* @param promptTitle
* @param promptContent
* @param firstRow
* @param endRow
* @param firstCol
* @param endCol
*/
public void setXSSFPrompt(Sheet sheet, String promptTitle, String promptContent, int firstRow, int endRow,
int firstCol, int endCol) {
DataValidationHelper helper = sheet.getDataValidationHelper();
DataValidationConstraint constraint = helper.createCustomConstraint("DD1");
CellRangeAddressList regions = new CellRangeAddressList(firstRow, endRow, firstCol, endCol);
DataValidation dataValidation = helper.createValidation(constraint, regions);
dataValidation.createPromptBox(promptTitle, promptContent);
dataValidation.setShowPromptBox(true);
sheet.addValidationData(dataValidation);
}
/**
* ,.
*
* @param sheet sheet.
* @param textlist
* @param firstRow
* @param endRow
* @param firstCol
* @param endCol
* @return sheet.
*/
public void setXSSFValidation(Sheet sheet, String[] textlist, int firstRow, int endRow, int firstCol, int endCol) {
DataValidationHelper helper = sheet.getDataValidationHelper();
// 加载下拉列表内容
DataValidationConstraint constraint = helper.createExplicitListConstraint(textlist);
// 设置数据有效性加载在哪个单元格上,四个参数分别是:起始行、终止行、起始列、终止列
CellRangeAddressList regions = new CellRangeAddressList(firstRow, endRow, firstCol, endCol);
// 数据有效性对象
DataValidation dataValidation = helper.createValidation(constraint, regions);
// 处理Excel兼容性问题
if (dataValidation instanceof XSSFDataValidation) {
dataValidation.setSuppressDropDownArrow(true);
dataValidation.setShowErrorBox(true);
} else {
dataValidation.setSuppressDropDownArrow(false);
}
sheet.addValidationData(dataValidation);
}
/**
* 0=,1=,2=
*
* @param propertyValue
* @param converterExp
* @return
* @throws Exception
*/
public static String convertByExp(String propertyValue, String converterExp) throws Exception {
try {
String[] convertSource = converterExp.split(",");
for (String item : convertSource) {
String[] itemArray = item.split("=");
if (itemArray[0].equals(propertyValue)) {
return itemArray[1];
}
}
} catch (Exception e) {
throw e;
}
return propertyValue;
}
/**
* =0,=1,=2
*
* @param propertyValue
* @param converterExp
* @return
* @throws Exception
*/
public static String reverseByExp(String propertyValue, String converterExp) throws Exception {
try {
String[] convertSource = converterExp.split(",");
for (String item : convertSource) {
String[] itemArray = item.split("=");
if (itemArray[1].equals(propertyValue)) {
return itemArray[0];
}
}
} catch (Exception e) {
throw e;
}
return propertyValue;
}
/**
*
*/
public String encodingFilename(String filename) {
filename = UUID.randomUUID().toString() + "_" + filename + ".xlsx";
return filename;
}
/**
*
*
* @param filename
*/
public String getAbsoluteFile(String filename) {
String downloadPath = System.getProperty("user.dir") + File.separator + filename;
File desc = new File(downloadPath);
if (!desc.getParentFile().exists()) {
desc.getParentFile().mkdirs();
}
return downloadPath;
}
/**
* bean
*
* @param vo
* @param field
* @param excel
* @return
* @throws Exception
*/
private Object getTargetValue(T vo, Field field, Excel excel) throws Exception {
Object o = field.get(vo);
if (StringUtils.isNotEmpty(excel.targetAttr())) {
String target = excel.targetAttr();
if (target.indexOf(".") > -1) {
String[] targets = target.split("[.]");
for (String name : targets) {
o = getValue(o, name);
}
} else {
o = getValue(o, target);
}
}
return o;
}
/**
* get
*
* @param o
* @param name
* @return value
* @throws Exception
*/
private Object getValue(Object o, String name) throws Exception {
if (StringUtils.isNotEmpty(name)) {
Class<?> clazz = o.getClass();
String methodName = "get" + name.substring(0, 1).toUpperCase() + name.substring(1);
Method method = clazz.getMethod(methodName);
o = method.invoke(o);
}
return o;
}
/**
*
*/
private void createExcelField() {
this.fields = new ArrayList<>();
List<Field> tempFields = new ArrayList<>();
tempFields.addAll(Arrays.asList(clazz.getSuperclass().getDeclaredFields()));
tempFields.addAll(Arrays.asList(clazz.getDeclaredFields()));
for (Field field : tempFields) {
// 单注解
if (field.isAnnotationPresent(Excel.class)) {
putToField(field, field.getAnnotation(Excel.class));
}
// 多注解
if (field.isAnnotationPresent(Excels.class)) {
Excels attrs = field.getAnnotation(Excels.class);
Excel[] excels = attrs.value();
for (Excel excel : excels) {
putToField(field, excel);
}
}
}
}
/**
*
*/
private void putToField(Field field, Excel attr) {
if (attr != null && (attr.type() == Type.ALL || attr.type() == type)) {
this.fields.add(new Object[] { field, attr });
}
}
/**
* 簿
*/
public void createWorkbook() {
this.wb = new SXSSFWorkbook(500);
}
/**
*
*
* @param sheetNo sheet
* @param index
*/
public void createSheet(double sheetNo, int index) {
this.sheet = wb.createSheet();
this.styles = createStyles(wb);
// 设置工作表的名称.
if (sheetNo == 0) {
wb.setSheetName(index, sheetName);
} else {
wb.setSheetName(index, sheetName + index);
}
}
/**
*
*
* @param row
* @param column
* @return
*/
public Object getCellValue(Row row, int column) {
if (row == null) {
return row;
}
Object val = "";
try {
Cell cell = row.getCell(column);
if (cell != null) {
if (cell.getCellTypeEnum() == CellType.NUMERIC || cell.getCellTypeEnum() == CellType.FORMULA) {
val = cell.getNumericCellValue();
if (HSSFDateUtil.isCellDateFormatted(cell)) {
val = DateUtil.getJavaDate((Double) val); // POI Excel 日期格式转换
} else {
if ((Double) val % 1 > 0) {
val = new DecimalFormat("0.00").format(val);
} else {
val = new DecimalFormat("0").format(val);
}
}
} else if (cell.getCellTypeEnum() == CellType.STRING) {
val = cell.getStringCellValue();
} else if (cell.getCellTypeEnum() == CellType.BOOLEAN) {
val = cell.getBooleanCellValue();
} else if (cell.getCellTypeEnum() == CellType.ERROR) {
val = cell.getErrorCellValue();
}
}
} catch (Exception e) {
return val;
}
return val;
}
}

View File

@ -0,0 +1,122 @@
package com.bwie.common.utils.poi.annotation;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
/**
* Excel
*
* @author
*/
@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.FIELD)
public @interface Excel
{
/**
* Excel.
*/
public String name() default "";
/**
* , : yyyy-MM-dd
*/
public String dateFormat() default "";
/**
* (: 0=,1=,2=)
*/
public String readConverterExp() default "";
/**
*
*/
public String splitStr() default "";
/**
* 1
*/
public String invokeMethod() default "";
/**
* SpringIoc
*/
public Class<?> invokeClass() default String.class;
/**
* 0 1
*/
public ColumnType cellType() default ColumnType.STRING;
/**
* excel
*/
public double height() default 14;
/**
* excel
*/
public double width() default 16;
/**
* ,% 90 90%
*/
public String suffix() default "";
/**
* ,
*/
public String defaultValue() default "";
/**
*
*/
public String prompt() default "";
/**
* .
*/
public String[] combo() default {};
/**
* ,:,.
*/
public boolean isExport() default true;
/**
* ,,
*/
public String targetAttr() default "";
/**
* 012
*/
Type type() default Type.ALL;
public enum Type {
ALL(0), EXPORT(1), IMPORT(2);
private final int value;
Type(int value) {
this.value = value;
}
public int value() {
return this.value;
}
}
public enum ColumnType {
NUMERIC(0), STRING(1);
private final int value;
ColumnType(int value) {
this.value = value;
}
public int value() {
return this.value;
}
}
}

View File

@ -0,0 +1,18 @@
package com.bwie.common.utils.poi.annotation;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
/**
* Excel
*
* @author
*/
@Target(ElementType.FIELD)
@Retention(RetentionPolicy.RUNTIME)
public @interface Excels
{
Excel[] value();
}

View File

@ -0,0 +1,27 @@
package com.bwie.common.utils.poi.exception;
/**
*
*
* @author
*/
public class PoiException extends RuntimeException
{
private static final long serialVersionUID = 1L;
protected final String message;
public PoiException(String message) {
this.message = message;
}
public PoiException(String message, Throwable e) {
super(message, e);
this.message = message;
}
@Override
public String getMessage() {
return message;
}
}

View File

@ -0,0 +1,79 @@
package com.bwie.common.utils.poi3;
import com.alibaba.excel.metadata.CellData;
import com.alibaba.excel.metadata.Head;
import com.alibaba.excel.write.handler.CellWriteHandler;
import com.alibaba.excel.write.metadata.holder.WriteSheetHolder;
import com.alibaba.excel.write.metadata.holder.WriteTableHolder;
import com.alibaba.excel.write.metadata.style.WriteCellStyle;
import com.alibaba.excel.write.metadata.style.WriteFont;
import com.alibaba.excel.write.style.HorizontalCellStyleStrategy;
import org.apache.poi.ss.usermodel.*;
import java.util.List;
public class CustomCellStyle implements CellWriteHandler {
@Override
public void beforeCellCreate(WriteSheetHolder writeSheetHolder, WriteTableHolder writeTableHolder, Row row, Head head, Integer columnIndex, Integer relativeRowIndex, Boolean isHead) {
}
@Override
public void afterCellCreate(WriteSheetHolder writeSheetHolder, WriteTableHolder writeTableHolder, Cell cell, Head head, Integer relativeRowIndex, Boolean isHead) {
}
@Override
public void afterCellDataConverted(WriteSheetHolder writeSheetHolder, WriteTableHolder writeTableHolder, CellData cellData, Cell cell, Head head, Integer relativeRowIndex, Boolean isHead) {
}
@Override
public void afterCellDispose(WriteSheetHolder writeSheetHolder, WriteTableHolder writeTableHolder, List<CellData> cellDataList, Cell cell, Head head, Integer relativeRowIndex, Boolean isHead) {
//获取工作簿
Workbook workbook = writeSheetHolder.getSheet().getWorkbook();
//获取单元格样式
CellStyle cellStyle = workbook.createCellStyle();
//判断非首行
if(!isHead && cell.getColumnIndex()==2){
String stringCellValue = cell.getStringCellValue();
//double numericCellValue = cell.getNumericCellValue();
if("女".equals(stringCellValue)){
//填充背景色
cellStyle.setFillPattern(FillPatternType.SOLID_FOREGROUND);
cellStyle.setFillForegroundColor(IndexedColors.RED.index);
//设置字体
Font font = workbook.createFont();
font.setBold(true);
font.setColor(IndexedColors.BLACK.getIndex());
cellStyle.setFont(font);
}
}else{}
//设置边框
cellStyle.setBorderTop(BorderStyle.THIN);
cellStyle.setTopBorderColor(IndexedColors.BLACK.getIndex());
cellStyle.setBorderRight(BorderStyle.THIN);
cellStyle.setRightBorderColor(IndexedColors.BLACK.getIndex());
cellStyle.setBorderBottom(BorderStyle.THIN);
cellStyle.setBottomBorderColor(IndexedColors.BLACK.getIndex());
cellStyle.setBorderLeft(BorderStyle.THIN);
cellStyle.setLeftBorderColor(IndexedColors.BLACK.getIndex());
cell.setCellStyle(cellStyle);
}
}

View File

@ -0,0 +1,208 @@
//package com.bwie.common.utils.poi3;
//
//import com.alibaba.excel.EasyExcel;
//import com.alibaba.excel.ExcelWriter;
//import com.alibaba.excel.metadata.Head;
//import com.alibaba.excel.support.ExcelTypeEnum;
//import com.alibaba.excel.util.CollectionUtils;
//import com.alibaba.excel.write.builder.ExcelWriterSheetBuilder;
//import com.alibaba.excel.write.merge.AbstractMergeStrategy;
//import com.alibaba.excel.write.metadata.WriteSheet;
//import com.alibaba.excel.write.metadata.style.WriteCellStyle;
//import com.alibaba.excel.write.metadata.style.WriteFont;
//import com.alibaba.excel.write.style.HorizontalCellStyleStrategy;
//import lombok.Data;
//import lombok.NoArgsConstructor;
//import org.apache.poi.ss.formula.functions.T;
//import org.apache.poi.ss.usermodel.Cell;
//import org.apache.poi.ss.usermodel.FillPatternType;
//import org.apache.poi.ss.usermodel.IndexedColors;
//import org.apache.poi.ss.usermodel.Sheet;
//import org.apache.poi.ss.util.CellRangeAddress;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Component;
//
//import javax.security.sasl.SaslServer;
//import javax.servlet.http.HttpServletResponse;
//import java.io.IOException;
//import java.io.UnsupportedEncodingException;
//import java.net.URLEncoder;
//import java.util.ArrayList;
//import java.util.Arrays;
//import java.util.List;
//import java.util.stream.Collectors;
//
//// 自定义合并策略 该类继承了AbstractMergeStrategy抽象合并策略需要重写merge()方法
//@Component
//@Data
//@NoArgsConstructor
//public class EasyExcelUtil extends AbstractMergeStrategy {
//
//
// @Autowired
// private SaslServer saslServer;
//
// /**
// * 分组,每几行合并一次
// */
// private List<Integer> exportFieldGroupCountList;
//
// /**
// * 目标合并列index
// */
// private Integer targetColumnIndex;
//
// // 需要开始合并单元格的首行index
// private Integer rowIndex;
//
// // exportDataList为待合并目标列的值
// public EasyExcelUtil(List<String> exportDataList, Integer targetColumnIndex) {
// this.exportFieldGroupCountList = getGroupCountList(exportDataList);
// this.targetColumnIndex = targetColumnIndex;
// }
//
//
// @Override
// protected void merge(Sheet sheet, Cell cell, Head head, Integer relativeRowIndex) {
//
// if (null == rowIndex) {
// rowIndex = cell.getRowIndex();
// }
// // 仅从首行以及目标列的单元格开始合并,忽略其他
// if (cell.getRowIndex() == rowIndex && cell.getColumnIndex() == targetColumnIndex) {
// mergeGroupColumn(sheet);
// }
// }
//
// private void mergeGroupColumn(Sheet sheet) {
// int rowCount = rowIndex;
// for (Integer count : exportFieldGroupCountList) {
// if(count == 1) {
// rowCount += count;
// continue ;
// }
// // 合并单元格
// CellRangeAddress cellRangeAddress = new CellRangeAddress(rowCount, rowCount + count - 1, targetColumnIndex, targetColumnIndex);
// sheet.addMergedRegionUnsafe(cellRangeAddress);
// rowCount += count;
// }
// }
//
// // 该方法将目标列根据值是否相同连续可合并,存储可合并的行数
// private List<Integer> getGroupCountList(List<String> exportDataList){
// if (CollectionUtils.isEmpty(exportDataList)) {
// return new ArrayList<>();
// }
//
// List<Integer> groupCountList = new ArrayList<>();
// int count = 1;
//
// for (int i = 1; i < exportDataList.size(); i++) {
// if (exportDataList.get(i).equals(exportDataList.get(i - 1))) {
// count++;
// } else {
// groupCountList.add(count);
// count = 1;
// }
// }
// // 处理完最后一条后
// groupCountList.add(count);
// return groupCountList;
// }
//
//
// // 修改WriteSheet的代码如下
// public void writeExcel(HttpServletResponse response,String fileName,Integer mergeIndex,String firstTitle,String [] secondTile,Integer sheetSize) {
// // 这里注意 有同学反应使用swagger 会导致各种问题请直接用浏览器或者用postman
// response.setContentType("application/vnd.ms-excel");
// response.setCharacterEncoding("utf-8");
// // 这里URLEncoder.encode可以防止中文乱码 当然和easyexcel没有关系
// try {
// String name = URLEncoder.encode(fileName, "UTF-8");
//
// response.setHeader("Content-disposition", "attachment;filename=" + name + ".xlsx");
//
// List<List<String>> heads = new ArrayList<>();
// for (int i = 0; i < secondTile.length; i++) {
// heads.add(Arrays.asList(firstTitle,secondTile[i]));
// }
//
//
//
//
// ExcelWriter excelWriter = EasyExcel.write(response.getOutputStream())
// .build();
//
// List<Student> studentListAll = studentService.findStudentListAll();
// //select * from t_student limit 0,2 1 (pageNum-1)*pageSize
// //select * from t_student limit 2,2 2
// //select * from t_student limit 4,2 3
// //select * from t_student limit 6,2 4
//
// Integer count = studentListAll.size();
// Integer sheets = (int)Math.ceil((double)count/sheetSize);
//
//
//
// for (int i = 0; i < sheets; i++) {
// PageInfo<Student> studentList = studentService.findStudentList(i + 1, sheetSize);
// WriteSheet sheet1 = EasyExcel.writerSheet(i, "模版"+(i+1)).head(Student.class)
// .head(heads).registerWriteHandler(new EasyExcelUtil(studentList.getList().stream().map(Student::getSex).collect(Collectors.toList()), mergeIndex))
// .registerWriteHandler(new CustomCellStyle()).build();
//
//
// excelWriter.write(studentList.getList(),sheet1);
// }
//
//
// excelWriter.finish();
// response.flushBuffer();
//
//
//
//
//
// } catch (UnsupportedEncodingException e) {
// e.printStackTrace();
// } catch (IOException e) {
// e.printStackTrace();
// }
//
// }
//
//
// // 修改WriteSheet的代码如下
// public void writeExcel(HttpServletResponse response,String fileName, List<Student> list,String [] secondTile) {
// // 这里注意 有同学反应使用swagger 会导致各种问题请直接用浏览器或者用postman
// response.setContentType("application/vnd.ms-excel");
// response.setCharacterEncoding("utf-8");
// // 这里URLEncoder.encode可以防止中文乱码 当然和easyexcel没有关系
// try {
// String name = URLEncoder.encode(fileName, "UTF-8");
//
// response.setHeader("Content-disposition", "attachment;filename=" + name + ".xlsx");
//
// List<List<String>> heads = new ArrayList<>();
// for (int i = 0; i < secondTile.length; i++) {
// heads.add(Arrays.asList(secondTile[i]));
// }
//
//
// EasyExcel.write(response.getOutputStream(),Student.class).sheet("模板").head(Student.class)
// .head(heads)
// //.registerWriteHandler(new EasyExcelUtil(list.stream().map(Student::getName).collect(Collectors.toList()), mergeIndex))
// //.registerWriteHandler(new CustomCellStyle()) //设置单元格颜色样式
// .doWrite(list);
//
//
// } catch (UnsupportedEncodingException e) {
// e.printStackTrace();
// } catch (IOException e) {
// e.printStackTrace();
// }
//
// }
//
//
//
//}

View File

@ -17,7 +17,6 @@
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<!-- 公共模块 -->
<dependency>
@ -42,5 +41,4 @@
</dependency>
</dependencies>
</project>

View File

@ -0,0 +1,16 @@
package com.bwie.gateway;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
/**
* @author 86175
*/
@SpringBootApplication
public class GateApplication {
public static void main(String[] args) {
SpringApplication.run(GateApplication.class,args);
}
}

View File

@ -18,10 +18,10 @@ spring:
nacos:
discovery:
# 服务注册地址
server-addr: 110.42.214.8:8848
server-addr: 111.229.234.119:8848
config:
# 配置中心地址
server-addr: 110.42.214.8:8848
server-addr: 111.229.234.119:8848
# 配置文件格式
file-extension: yml
# 共享配置

View File

@ -0,0 +1,38 @@
target/
!.mvn/wrapper/maven-wrapper.jar
!**/src/main/**/target/
!**/src/test/**/target/
### IntelliJ IDEA ###
.idea/modules.xml
.idea/jarRepositories.xml
.idea/compiler.xml
.idea/libraries/
*.iws
*.iml
*.ipr
### Eclipse ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
build/
!**/src/main/**/build/
!**/src/test/**/build/
### VS Code ###
.vscode/
### Mac OS ###
.DS_Store

View File

@ -0,0 +1,90 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.bwie</groupId>
<artifactId>bwie-models</artifactId>
<version>1.0-SNAPSHOT</version>
</parent>
<artifactId>bwie-sell</artifactId>
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<!-- 系统公共 依赖 -->
<dependency>
<groupId>com.bwie</groupId>
<artifactId>bwie-common</artifactId>
</dependency>
<!-- SpringBoot Web-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- Druid -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.2.8</version>
</dependency>
<!-- Mysql Connector -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<!-- Mybatis 依赖配置 -->
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>2.2.2</version>
</dependency>
<!-- Pagehelper -->
<dependency>
<groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper-spring-boot-starter</artifactId>
<version>1.4.1</version>
</dependency>
<!-- test -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.github.tobato</groupId>
<artifactId>fastdfs-client</artifactId>
<version>1.26.5</version>
</dependency>
<!-- poi导入导出依赖 -->
<!-- excel2007+使用的包 -->
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi-ooxml</artifactId>
<version>3.17</version>
</dependency>
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi-ooxml-schemas</artifactId>
<version>3.17</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.12.0</version>
</dependency>
<!-- 合并单元格 -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>easyexcel</artifactId>
<version>2.2.7</version>
</dependency>
</dependencies>
</project>

View File

@ -0,0 +1,16 @@
package com.bwie.sell;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
/**
* @author 86175
*/
@SpringBootApplication
public class SellApplication {
public static void main(String[] args) {
SpringApplication.run(SellApplication.class,args);
}
}

View File

@ -0,0 +1,73 @@
package com.bwie.sell.controller;
import com.alibaba.fastjson.JSON;
import com.bwie.common.pojo.Sell;
import com.bwie.common.result.Result;
import com.bwie.sell.service.SellService;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.List;
import static org.bouncycastle.asn1.cmc.CMCStatus.success;
/**
* @author 86175
*/
@RestController
@RequestMapping("/sell")
@Log4j2
public class SellController {
@Autowired
public SellService sellService;
@Autowired
public HttpServletRequest request;
/**
*
*
*/
@PostMapping("/shopStatistics")
public Result<List<Sell>> listResult (){
log.info("功能描述:销售日志统计,请求URI:{},请求方式:{}",request.getServletPath(),request.getMethod());
List<Sell> sell=sellService.list();
Result<List<Sell>> success = Result.success(sell);
log.info("功能描述:销售日志统计,请求URI:{},请求方式:{},响应结果:{}",request.getServletPath(),request.getMethod(), JSON.toJSONString(success));
return success;
}
/**
*
*/
@PostMapping("/salesStatistics")
public Result<List<Sell>> salesStatistics (){
log.info("功能描述:销售金额统计,请求URI:{},请求方式:{}",request.getServletPath(),request.getMethod());
List<Sell> sell=sellService.sellList();
Result<List<Sell>> success = Result.success(sell);
log.info("功能描述:销售金额统计,请求URI:{},请求方式:{},响应结果:{}",request.getServletPath(),request.getMethod(), JSON.toJSONString(success));
return success;
}
/**
*
*/
@PostMapping("/exportSell")
public Result exportSell(HttpServletResponse response){
// Result success =
//先查询数据
System.out.println(response);
log.info("功能描述:销售导出查询,请求URI:{},请求方式:{},请求参数{}",request.getServletPath(),request.getMethod(),response);
Result success =sellService.exportSell(response);
log.info("功能描述:销售导出查询,请求URI:{},请求方式:{},响应结果:{}",request.getServletPath(),request.getMethod(), JSON.toJSONString(success));
return success;
}
}

View File

@ -0,0 +1,28 @@
package com.bwie.sell.mapper;
import com.bwie.common.pojo.Sell;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
/**
* @author 86175
*/
@Mapper
public interface SellMapper {
/**
*
* @return
*/
List<Sell> shopList();
/**
*
* @return
*/
List<Sell> sellList();
}

View File

@ -0,0 +1,29 @@
package com.bwie.sell.service;
import com.bwie.common.pojo.Sell;
import com.bwie.common.result.Result;
import com.github.pagehelper.PageInfo;
import javax.servlet.http.HttpServletResponse;
import java.util.List;
/**
* @author 86175
*/
public interface SellService {
List<Sell> list();
List<Sell> sellList();
Result exportSell(HttpServletResponse response);
List<Sell> findStudentListAll();
PageInfo<Sell> findStudentList(int i, Integer sheetSize);
}

View File

@ -0,0 +1,68 @@
package com.bwie.sell.service.impl;
import com.bwie.common.pojo.Sell;
import com.bwie.common.result.Result;
import com.bwie.common.utils.poi.ExcelUtil;
import com.bwie.sell.mapper.SellMapper;
import com.bwie.sell.service.SellService;
import com.bwie.sell.util.poi3.EasyExcelUtil;
import com.github.pagehelper.PageInfo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import javax.servlet.http.HttpServletResponse;
import java.util.List;
/**
* @author 86175
*/
@Service
public class SellServiceImpl implements SellService {
@Autowired
public SellMapper sellMapper;
@Autowired
public EasyExcelUtil easyExcelUtil;
@Override
public List<Sell> list() {
return sellMapper.shopList();
}
@Override
public List<Sell> sellList() {
return sellMapper.sellList();
}
@Override
public Result exportSell(HttpServletResponse response) {
List<Sell> sells = sellMapper.sellList();
//是以流的方式把数据传给用户
ExcelUtil<Sell> sellExcelUtil = new ExcelUtil<>(Sell.class);
/**
* sellExcelUtil
*
*
* list
*
* sheet
*
*/
String s = sellExcelUtil.exportExcel(sells, "商品销售统计");
// return Result.success();
return Result.success(s);
}
@Override
public List<Sell> findStudentListAll() {
return null;
}
@Override
public PageInfo<Sell> findStudentList(int i, Integer sheetSize) {
return null;
}
}

View File

@ -0,0 +1,55 @@
package com.bwie.sell.util;
import org.springframework.stereotype.Component;
import com.github.tobato.fastdfs.domain.fdfs.StorePath;
import com.github.tobato.fastdfs.service.FastFileStorageClient;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.util.StringUtils;
import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource;
/**
* @BelongsProject: 0107day02
* @BelongsPackage: com.bw.config
* @Author: zhupengfei
* @CreateTime: 2023-02-01 08:52
*/
@Component
public class FastUtil {
private static final Logger log = LoggerFactory.getLogger(FastUtil.class);
@Resource
private FastFileStorageClient storageClient ;
/**
*
*/
public String upload(MultipartFile multipartFile) throws Exception{
String originalFilename = multipartFile.getOriginalFilename().
substring(multipartFile.getOriginalFilename().
lastIndexOf(".") + 1);
StorePath storePath = this.storageClient.uploadImageAndCrtThumbImage(
multipartFile.getInputStream(),
multipartFile.getSize(),originalFilename , null);
return storePath.getFullPath() ;
}
/**
*
*/
public String deleteFile(String fileUrl) {
if (StringUtils.isEmpty(fileUrl)) {
log.info("fileUrl == >>文件路径为空...");
return "文件路径不能为空";
}
try {
StorePath storePath = StorePath.parseFromUrl(fileUrl);
storageClient.deleteFile(storePath.getGroup(), storePath.getPath());
} catch (Exception e) {
log.error(e.getMessage());
}
return "删除成功";
}
}

View File

@ -0,0 +1,76 @@
package com.bwie.sell.util.poi3;
import com.alibaba.excel.metadata.CellData;
import com.alibaba.excel.metadata.Head;
import com.alibaba.excel.write.handler.CellWriteHandler;
import com.alibaba.excel.write.metadata.holder.WriteSheetHolder;
import com.alibaba.excel.write.metadata.holder.WriteTableHolder;
import org.apache.poi.ss.usermodel.*;
import java.util.List;
public class CustomCellStyle implements CellWriteHandler {
@Override
public void beforeCellCreate(WriteSheetHolder writeSheetHolder, WriteTableHolder writeTableHolder, Row row, Head head, Integer columnIndex, Integer relativeRowIndex, Boolean isHead) {
}
@Override
public void afterCellCreate(WriteSheetHolder writeSheetHolder, WriteTableHolder writeTableHolder, Cell cell, Head head, Integer relativeRowIndex, Boolean isHead) {
}
@Override
public void afterCellDataConverted(WriteSheetHolder writeSheetHolder, WriteTableHolder writeTableHolder, CellData cellData, Cell cell, Head head, Integer relativeRowIndex, Boolean isHead) {
}
@Override
public void afterCellDispose(WriteSheetHolder writeSheetHolder, WriteTableHolder writeTableHolder, List<CellData> cellDataList, Cell cell, Head head, Integer relativeRowIndex, Boolean isHead) {
//获取工作簿
Workbook workbook = writeSheetHolder.getSheet().getWorkbook();
//获取单元格样式
CellStyle cellStyle = workbook.createCellStyle();
//判断非首行
if(!isHead && cell.getColumnIndex()==2){
String stringCellValue = cell.getStringCellValue();
//double numericCellValue = cell.getNumericCellValue();
if("女".equals(stringCellValue)){
//填充背景色
cellStyle.setFillPattern(FillPatternType.SOLID_FOREGROUND);
cellStyle.setFillForegroundColor(IndexedColors.RED.index);
//设置字体
Font font = workbook.createFont();
font.setBold(true);
font.setColor(IndexedColors.BLACK.getIndex());
cellStyle.setFont(font);
}
}else{}
//设置边框
cellStyle.setBorderTop(BorderStyle.THIN);
cellStyle.setTopBorderColor(IndexedColors.BLACK.getIndex());
cellStyle.setBorderRight(BorderStyle.THIN);
cellStyle.setRightBorderColor(IndexedColors.BLACK.getIndex());
cellStyle.setBorderBottom(BorderStyle.THIN);
cellStyle.setBottomBorderColor(IndexedColors.BLACK.getIndex());
cellStyle.setBorderLeft(BorderStyle.THIN);
cellStyle.setLeftBorderColor(IndexedColors.BLACK.getIndex());
cell.setCellStyle(cellStyle);
}
}

View File

@ -0,0 +1,193 @@
package com.bwie.sell.util.poi3;
import com.alibaba.excel.EasyExcel;
import com.alibaba.excel.ExcelWriter;
import com.alibaba.excel.metadata.Head;
import com.alibaba.excel.util.CollectionUtils;
import com.alibaba.excel.write.merge.AbstractMergeStrategy;
import com.alibaba.excel.write.metadata.WriteSheet;
import com.bwie.common.pojo.Sell;
import com.bwie.sell.service.SellService;
import com.github.pagehelper.PageInfo;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.apache.poi.ss.usermodel.Cell;
import org.apache.poi.ss.usermodel.Sheet;
import org.apache.poi.ss.util.CellRangeAddress;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import javax.security.sasl.SaslServer;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;
// 自定义合并策略 该类继承了AbstractMergeStrategy抽象合并策略需要重写merge()方法
@Component
@Data
@NoArgsConstructor
public class EasyExcelUtil extends AbstractMergeStrategy {
@Autowired
private SellService sellService;
/**
*
*/
private List<Integer> exportFieldGroupCountList;
/**
* index
*/
private Integer targetColumnIndex;
// 需要开始合并单元格的首行index
private Integer rowIndex;
// exportDataList为待合并目标列的值
public EasyExcelUtil(List<String> exportDataList, Integer targetColumnIndex) {
this.exportFieldGroupCountList = getGroupCountList(exportDataList);
this.targetColumnIndex = targetColumnIndex;
}
@Override
protected void merge(Sheet sheet, Cell cell, Head head, Integer relativeRowIndex) {
if (null == rowIndex) {
rowIndex = cell.getRowIndex();
}
// 仅从首行以及目标列的单元格开始合并,忽略其他
if (cell.getRowIndex() == rowIndex && cell.getColumnIndex() == targetColumnIndex) {
mergeGroupColumn(sheet);
}
}
private void mergeGroupColumn(Sheet sheet) {
int rowCount = rowIndex;
for (Integer count : exportFieldGroupCountList) {
if(count == 1) {
rowCount += count;
continue ;
}
// 合并单元格
CellRangeAddress cellRangeAddress = new CellRangeAddress(rowCount, rowCount + count - 1, targetColumnIndex, targetColumnIndex);
sheet.addMergedRegionUnsafe(cellRangeAddress);
rowCount += count;
}
}
// 该方法将目标列根据值是否相同连续可合并,存储可合并的行数
private List<Integer> getGroupCountList(List<String> exportDataList){
if (CollectionUtils.isEmpty(exportDataList)) {
return new ArrayList<>();
}
List<Integer> groupCountList = new ArrayList<>();
int count = 1;
for (int i = 1; i < exportDataList.size(); i++) {
if (exportDataList.get(i).equals(exportDataList.get(i - 1))) {
count++;
} else {
groupCountList.add(count);
count = 1;
}
}
// 处理完最后一条后
groupCountList.add(count);
return groupCountList;
}
// 修改WriteSheet的代码如下
public void writeExcel(HttpServletResponse response,String fileName,Integer mergeIndex,String firstTitle,String [] secondTile,Integer sheetSize) {
// 这里注意 有同学反应使用swagger 会导致各种问题请直接用浏览器或者用postman
response.setContentType("application/vnd.ms-excel");
response.setCharacterEncoding("utf-8");
// 这里URLEncoder.encode可以防止中文乱码 当然和easyexcel没有关系
try {
String name = URLEncoder.encode(fileName, "UTF-8");
response.setHeader("Content-disposition", "attachment;filename=" + name + ".xlsx");
List<List<String>> heads = new ArrayList<>();
for (int i = 0; i < secondTile.length; i++) {
heads.add(Arrays.asList(firstTitle,secondTile[i]));
}
ExcelWriter excelWriter = EasyExcel.write(response.getOutputStream())
.build();
List<Sell> studentListAll = sellService.findStudentListAll();
//select * from t_student limit 0,2 1 (pageNum-1)*pageSize
//select * from t_student limit 2,2 2
//select * from t_student limit 4,2 3
//select * from t_student limit 6,2 4
Integer count = studentListAll.size();
Integer sheets = (int)Math.ceil((double)count/sheetSize);
for (int i = 0; i < sheets; i++) {
PageInfo<Sell> studentList = sellService.findStudentList(i + 1, sheetSize);
WriteSheet sheet1 = EasyExcel.writerSheet(i, "模版"+(i+1)).head(Sell.class)
.head(heads).registerWriteHandler(new EasyExcelUtil(studentList.getList().stream().map(Sell::getPhone).collect(Collectors.toList()), mergeIndex))
.registerWriteHandler(new CustomCellStyle()).build();
excelWriter.write(studentList.getList(),sheet1);
}
excelWriter.finish();
response.flushBuffer();
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
// 修改WriteSheet的代码如下
public void writeExcel(HttpServletResponse response,String fileName, List<Sell> list,String [] secondTile) {
// 这里注意 有同学反应使用swagger 会导致各种问题请直接用浏览器或者用postman
response.setContentType("application/vnd.ms-excel");
response.setCharacterEncoding("utf-8");
// 这里URLEncoder.encode可以防止中文乱码 当然和easyexcel没有关系
try {
String name = URLEncoder.encode(fileName, "UTF-8");
response.setHeader("Content-disposition", "attachment;filename=" + name + ".xlsx");
List<List<String>> heads = new ArrayList<>();
for (int i = 0; i < secondTile.length; i++) {
heads.add(Arrays.asList(secondTile[i]));
}
EasyExcel.write(response.getOutputStream(),Sell.class).sheet("模板").head(Sell.class)
.head(heads)
//.registerWriteHandler(new EasyExcelUtil(list.stream().map(Student::getName).collect(Collectors.toList()), mergeIndex))
//.registerWriteHandler(new CustomCellStyle()) //设置单元格颜色样式
.doWrite(list);
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}

View File

@ -0,0 +1,58 @@
# Tomcat
server:
port: 9004
# Spring
spring:
rabbitmq:
host: 111.229.234.119
port: 5672
userName: guest
password: guest
listener:
simple:
prefetch: 1
publisher-confirm-type: correlated
publisher-returns: true
main:
allow-circular-references: true
jackson:
date-format: yyyy-MM-dd HH:mm:ss
time-zone: GMT+8
application:
# 应用名称
name: bwie-sell
profiles:
# 环境配置
active: dev
cloud:
sentinel:
transport:
# 控制台地址
#sentinel 地址不需要改动
dashboard: 127.0.0.1:8080
# 指定sentinel控制台获取应用数据的端口被占用会端口号默认 +1
port: 8719
nacos:
discovery:
# 服务注册地址
server-addr: 111.229.234.119:8848
config:
# 配置中心地址
server-addr: 111.229.234.119:8848
# 配置文件格式
file-extension: yml
# 共享配置
shared-configs:
- application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
fdfs:
so-timeout: 1500 # socket 连接时长
connect-timeout: 600 # 连接 tracker 服务器超时时长
# 这两个是你服务器的 IP 地址,注意 23000 端口也要打开阿里云服务器记得配置安全组。tracker 要和 stroage 服务进行交流
tracker-list: 111.229.234.119:22122
web-server-url: 111.229.234.119:8888
pool:
jmx-enabled: false
# 生成缩略图
thumb-image:
height: 500
width: 500

View File

@ -0,0 +1,59 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.bwie.sell.mapper.SellMapper">
<select id="shopList" resultType="com.bwie.common.pojo.Sell">
SELECT sell_id,
p.shop_id,
sell_time,
s.user_id,
f.facility_id,
facility_type,
facility_site,
replenishment_user_id,
maintain_user_id,
facility_static,
del_id,
shop_price,
p.type_id,
type_name,
user_name,
phone,
email,
GROUP_CONCAT(shop_name) shopName
FROM t_sell s LEFT JOIN t_shop p on s.shop_id=p.shop_id
LEFT JOIN t_facility f on s.facility_id=f.facility_id
LEFT JOIN t_user u on u.user_id=s.user_id
LEFT JOIN t_type t on p.type_id=t.type_id
GROUP BY f.facility_id
</select>
<select id="sellList" resultType="com.bwie.common.pojo.Sell">
SELECT sell_id,
p.shop_id,
sell_time,
s.user_id,
f.facility_id,
facility_type,
facility_site,
replenishment_user_id,
maintain_user_id,
facility_static,
del_id,
shop_price,
p.type_id,
type_name,
user_name,
phone,
email,
GROUP_CONCAT(shop_name) shopName,
SUM(shop_price)
FROM t_sell s LEFT JOIN t_shop p on s.shop_id=p.shop_id
LEFT JOIN t_facility f on s.facility_id=f.facility_id
LEFT JOIN t_user u on u.user_id=s.user_id
LEFT JOIN t_type t on p.type_id=t.type_id
GROUP BY f.facility_id
</select>
</mapper>

View File

@ -0,0 +1,66 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.bwie</groupId>
<artifactId>bwie-models</artifactId>
<version>1.0-SNAPSHOT</version>
</parent>
<artifactId>bwie-shopList</artifactId>
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<!-- 系统公共 依赖 -->
<dependency>
<groupId>com.bwie</groupId>
<artifactId>bwie-common</artifactId>
</dependency>
<!-- SpringBoot Web-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- Druid -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.2.8</version>
</dependency>
<!-- Mysql Connector -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<!-- Mybatis 依赖配置 -->
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>2.2.2</version>
</dependency>
<!-- Pagehelper -->
<dependency>
<groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper-spring-boot-starter</artifactId>
<version>1.4.1</version>
</dependency>
<!-- test -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
</project>

View File

@ -0,0 +1,11 @@
package com.bwie;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class ListApplication {
public static void main(String[] args) {
SpringApplication.run(ListApplication.class);
}
}

View File

@ -0,0 +1,62 @@
package com.bwie.list.controller;
import com.alibaba.fastjson.JSONObject;
import com.bwie.common.pojo.VO.VOGoods;
import com.bwie.common.result.Result;
import com.bwie.list.service.GoodsService;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
import javax.servlet.http.HttpServletRequest;
@RestController
@Log4j2
public class GoodsController {
@Autowired
private GoodsService goodsService;
@Autowired
private HttpServletRequest request;
@PostMapping("/goodsList")
public Result goodsList(@RequestBody VOGoods voGoods){
log.info("功能名称:[查询商品设备表],请求URI:{},请求方式:{},请求参数:{}",
request.getRequestURI(),request.getMethod(),voGoods);
Result result = goodsService.goodsList(voGoods);
log.info("功能名称:[查询商品设备表],请求URI:{},请求方式:{},响应结果:{}",
request.getRequestURI(),request.getMethod(), JSONObject.toJSONString(result));
return result;
}
@PostMapping("/topShop")
public Result topShop(@RequestBody VOGoods voGoods){
log.info("功能名称:[上架],请求URI:{},请求方式:{},请求参数:{}",
request.getRequestURI(),request.getMethod(),voGoods);
Result result = goodsService.topShop(voGoods);
log.info("功能名称:[上架],请求URI:{},请求方式:{},响应结果:{}",
request.getRequestURI(),request.getMethod(), JSONObject.toJSONString(result));
return result;
}
@PostMapping("/bottomShop")
public Result bottomShop(@RequestBody VOGoods voGoods){
log.info("功能名称:[下架],请求URI:{},请求方式:{},请求参数:{}",
request.getRequestURI(),request.getMethod(),voGoods);
Result result = goodsService.bottomShop(voGoods);
log.info("功能名称:[下架],请求URI:{},请求方式:{},响应结果:{}",
request.getRequestURI(),request.getMethod(), JSONObject.toJSONString(result));
return result;
}
@PostMapping("/addGoodsNum")
public Result addGoodsNum(@RequestBody VOGoods voGoods){
return goodsService.addGoodsNum(voGoods);
}
}

View File

@ -0,0 +1,34 @@
package com.bwie.list.controller;
import com.bwie.common.pojo.VO.VOShop;
import com.bwie.common.result.Result;
import com.bwie.list.service.ShopService;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
@RestController
@Log4j2
public class ShopController {
@Autowired
private ShopService shopService;
//展示商品列表
@PostMapping("/shopList")
public Result shopList(@RequestBody VOShop voShop){
return shopService.shopList(voShop);
}
//上传图片
@PostMapping("/upImg")
public Result upImg(@RequestParam("file")MultipartFile myFile){
return shopService.upImg(myFile);
}
//添加商品
@PostMapping("/addShop")
public Result addShop(@RequestBody VOShop shop){
return shopService.addShop(shop);
}
}

View File

@ -0,0 +1,36 @@
package com.bwie.list.controller;
import com.alibaba.fastjson.JSONObject;
import com.bwie.common.result.Result;
import com.bwie.list.service.TypeService;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.servlet.http.HttpServletRequest;
@RestController
@Log4j2
public class TypeController {
@Autowired
private TypeService typeService;
@Autowired
private HttpServletRequest request;
// 根据商品类型查询商品的商品类型菜单栏
@GetMapping("/findType")
public Result findType(){
log.info("功能名称:[类型菜单栏],请求URI:{},请求方式:{},请求参数:{}",
request.getRequestURI(),request.getMethod(),"");
Result result = typeService.findType();
log.info("功能名称:[类型菜单栏],请求URI:{},请求方式:{},响应结果:{}",
request.getRequestURI(),request.getMethod(), JSONObject.toJSONString(result));
return result;
}
}

View File

@ -0,0 +1,26 @@
package com.bwie.list.mapper;
import com.bwie.common.pojo.DTO.DTOGoods;
import com.bwie.common.pojo.Goods;
import com.bwie.common.pojo.VO.VOGoods;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
@Mapper
public interface GoodsMapper {
List<DTOGoods> goodsList(VOGoods voGoods);
Goods findShopId(Integer shopId, Integer facilityId);
Integer addGoods(VOGoods voGoods);
Integer changeGoodsState(@Param("goodsId") Integer goodsId);
Integer updateGoodsState(@Param("goodsId") Integer goodsId);
Integer changeGoodsNum(VOGoods voGoods);
}

View File

@ -0,0 +1,16 @@
package com.bwie.list.mapper;
import com.bwie.common.pojo.DTO.DTOShop;
import com.bwie.common.pojo.VO.VOShop;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
@Mapper
public interface ShopMapper {
List<DTOShop> shopList(VOShop voShop);
Integer addShop(VOShop shop);
void addImg(VOShop shop);
}

View File

@ -0,0 +1,12 @@
package com.bwie.list.mapper;
import com.bwie.common.pojo.Type;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
@Mapper
public interface TypeMapper {
List<Type> findType();
}

View File

@ -0,0 +1,14 @@
package com.bwie.list.service;
import com.bwie.common.pojo.VO.VOGoods;
import com.bwie.common.result.Result;
public interface GoodsService {
Result goodsList(VOGoods voGoods);
Result topShop(VOGoods voGoods);
Result bottomShop(VOGoods voGoods);
Result addGoodsNum(VOGoods voGoods);
}

View File

@ -0,0 +1,14 @@
package com.bwie.list.service;
import com.bwie.common.pojo.VO.VOShop;
import com.bwie.common.result.Result;
import org.springframework.web.multipart.MultipartFile;
public interface ShopService {
Result shopList(VOShop voShop);
Result addShop(VOShop shop);
Result upImg(MultipartFile myFile);
}

View File

@ -0,0 +1,8 @@
package com.bwie.list.service;
import com.bwie.common.result.Result;
public interface TypeService {
Result findType();
}

View File

@ -0,0 +1,85 @@
package com.bwie.list.service.impl;
import com.bwie.common.pojo.DTO.DTOGoods;
import com.bwie.common.pojo.Goods;
import com.bwie.common.pojo.VO.VOGoods;
import com.bwie.common.result.Result;
import com.bwie.list.mapper.GoodsMapper;
import com.bwie.list.service.GoodsService;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
@Service
public class GoodsServiceImpl implements GoodsService {
@Autowired
private GoodsMapper goodsMapper;
@Override
public Result goodsList(VOGoods voGoods) {
PageHelper.startPage(voGoods.getPageNum(), voGoods.getPageSize());
List<DTOGoods> dtoGoodsList = goodsMapper.goodsList(voGoods);
PageInfo<DTOGoods> info = new PageInfo<>(dtoGoodsList);
return Result.success(info,"商品设备中间表");
}
@Override
public Result topShop(VOGoods voGoods) {
Goods goods = goodsMapper.findShopId(voGoods.getShopId(),voGoods.getFacilityId());
if (goods==null){
Integer i = goodsMapper.addGoods(voGoods);
if (i>0){
return Result.success(voGoods,"上架成功");
}
} else {
if (goods.getGoodsIsDelete() == 0){
Integer i = goodsMapper.changeGoodsState(goods.getGoodsId());
if (i>0){
return Result.success(voGoods,"上架成功");
}
}
}
return Result.error("商品已上架不能重复上架哦~~");
}
@Override
public Result bottomShop(VOGoods voGoods) {
Goods goods = goodsMapper.findShopId(voGoods.getShopId(),voGoods.getFacilityId());
if (goods==null){
return Result.error("商品还未上架");
}else {
if (goods.getGoodsIsDelete()==1){
Integer i = goodsMapper.updateGoodsState(goods.getGoodsId());
if (i>0){
return Result.success(voGoods,"下架成功");
}else {
return Result.error("下架失败");
}
}
}
return Result.error("商品已经下架");
}
@Override
public Result addGoodsNum(VOGoods voGoods) {
Integer i = goodsMapper.changeGoodsNum(voGoods);
if (i>0){
return Result.success(voGoods,"进货成功");
}
return Result.error("进货失败");
}
}

View File

@ -0,0 +1,66 @@
package com.bwie.list.service.impl;
import com.bwie.common.pojo.DTO.DTOShop;
import com.bwie.common.pojo.VO.VOShop;
import com.bwie.common.result.Result;
import com.bwie.common.utils.FastUtil;
import com.bwie.list.mapper.ShopMapper;
import com.bwie.list.service.ShopService;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;
import java.util.List;
@Service
public class ShopServiceImpl implements ShopService {
@Autowired
private ShopMapper shopMapper;
@Autowired
private FastUtil fastUtil;
@Override
public Result shopList(VOShop voShop) {
PageHelper.startPage(voShop.getPageNum(),voShop.getPageSize());
List<DTOShop> dtoShops = shopMapper.shopList(voShop);
PageInfo<DTOShop> info = new PageInfo<>(dtoShops);
return Result.success(info,"商品列表展示");
}
@Override
public Result addShop(VOShop shop) {
Integer i = shopMapper.addShop(shop);
if (i>0){
shopMapper.addImg(shop);
return Result.success(shop,"成功");
}
return Result.error("失败");
}
@Override
public Result upImg(MultipartFile myFile) {
String url = null;
try {
url = fastUtil.upload(myFile);
if (url==null || url.equals("")){
return Result.error("图片上传失败");
}
} catch (Exception e) {
throw new RuntimeException(e);
}
return Result.success("http://82.157.236.130:8888/"+url,"上传成功");
}
}

View File

@ -0,0 +1,23 @@
package com.bwie.list.service.impl;
import com.bwie.common.pojo.Type;
import com.bwie.common.result.Result;
import com.bwie.list.mapper.TypeMapper;
import com.bwie.list.service.TypeService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
@Service
public class TypeServiceImpl implements TypeService {
@Autowired
private TypeMapper typeMapper;
@Override
public Result findType() {
List<Type> typeList = typeMapper.findType();
return Result.success(typeList,"类型展示");
}
}

View File

@ -0,0 +1,41 @@
# Tomcat
server:
port: 9002
# Spring
spring:
main:
allow-circular-references: true
jackson:
date-format: yyyy-MM-dd HH:mm:ss
time-zone: GMT+8
application:
# 应用名称
name: bwie-list
profiles:
# 环境配置
active: dev
cloud:
nacos:
discovery:
# 服务注册地址
server-addr: 82.157.236.130:8848
config:
# 配置中心地址
server-addr: 82.157.236.130:8848
# 配置文件格式
file-extension: yml
# 共享配置
shared-configs:
- application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
fdfs:
so-timeout: 1500 # socket 连接时长
connect-timeout: 600 # 连接 tracker 服务器超时时长
# 这两个是你服务器的 IP 地址,注意 23000 端口也要打开阿里云服务器记得配置安全组。tracker 要和 stroage 服务进行交流
tracker-list: 82.157.236.130:22122
web-server-url: 82.157.236.130:8888
pool:
jmx-enabled: false
# 生成缩略图
thumb-image:
height: 500
width: 500

View File

@ -0,0 +1,64 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<!--
1.在mybats的开发中namespace有特殊的意思一定要是对应接口的全限定名
通过namespace可以简历mapper.xml和接口之间的关系(名字不重要,位置不重要)
-->
<mapper namespace="com.bwie.list.mapper.GoodsMapper">
<resultMap id="map" type="com.bwie.common.pojo.DTO.DTOGoods">
<id property="goodsId" column="goods_id"></id>
<result property="goodsNum" column="goods_num"></result>
<result property="goodsIsDelete" column="goods_isdelete"></result>
<result property="shopId" column="shop_id"></result>
<result property="shopPrice" column="shop_price"></result>
<result property="shopName" column="shop_name"></result>
<result property="typeId" column="type_id"></result>
<result property="typeName" column="type_name"></result>
<result property="facilityId" column="facility_id"></result>
<result property="facilityType" column="facility_type"></result>
<result property="facilitySite" column="facility_site"></result>
<collection property="pictureUrl" ofType="java.lang.String">
<result column="picture_url"></result>
</collection>
</resultMap>
<!-- 添加中间表 -->
<insert id="addGoods">
INSERT INTO `shop_manage`.`t_goods` (`shop_id`, `facility_id`, `goods_num`, `goods_isdelete`)
VALUES (#{shopId}, #{facilityId}, NULL, 1)
</insert>
<!-- 上架修改状态 -->
<update id="changeGoodsState">
UPDATE `shop_manage`.`t_goods` SET `goods_isdelete` = 1 WHERE `goods_id` = #{goodsId}
</update>
<!-- 下架修改状态 -->
<update id="updateGoodsState">
UPDATE `shop_manage`.`t_goods` SET `goods_isdelete` = 0 WHERE `goods_id` = #{goodsId}
</update>
<!-- 修改库存数 -->
<update id="changeGoodsNum">
UPDATE `shop_manage`.`t_goods` SET `goods_num` = (`goods_num` + #{goodsNum}) WHERE `goods_id` = #{goodsId}
</update>
<select id="goodsList" resultMap="map">
SELECT g.goods_id,g.shop_id,s.shop_name,s.shop_price,s.type_id,t.type_name,p.picture_url,
g.facility_id,f.facility_type,f.facility_site,g.goods_num,g.goods_isdelete
FROM t_goods g
LEFT JOIN t_shop s on g.shop_id = s.shop_id
LEFT JOIN t_type t on s.type_id=t.type_id
LEFT JOIN t_picture p on s.shop_id = p.shop_id
LEFT JOIN t_facility f on g.facility_id = f.facility_id
<where>
and g.goods_isdelete = 1
<if test="facilityId != null">
and g.facility_id = #{facilityId}
</if>
</where>
ORDER BY g.goods_id
</select>
<select id="findShopId" resultType="com.bwie.common.pojo.Goods">
SELECT * FROM t_goods WHERE shop_id=#{shopId} and facility_id=#{facilityId}
</select>
</mapper>

View File

@ -0,0 +1,42 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.bwie.list.mapper.ShopMapper">
<resultMap id="map" type="com.bwie.common.pojo.DTO.DTOShop">
<id property="shopId" column="shop_id"></id>
<result property="shopName" column="shop_name"></result>
<result property="shopPrice" column="shop_price"></result>
<result property="typeId" column="type_id"></result>
<result property="typeName" column="type_name"></result>
<collection property="pictureUrl" ofType="java.lang.String">
<result column="picture_url"></result>
</collection>
</resultMap>
<insert id="addShop" keyProperty="shopId" useGeneratedKeys="true">
INSERT INTO `shop_manage`.`t_shop` (`shop_name`, `shop_price`, `type_id`)
VALUES ( #{shopName}, #{shopPrice}, #{typeId});
</insert>
<insert id="addImg">
INSERT INTO `shop_manage`.`t_picture`(`picture_url`,`shop_id`)
VALUES
<foreach collection="pictureUrl" separator="," item="url">
(#{url},#{shopId})
</foreach>
</insert>
<select id="shopList" resultMap="map">
select s.shop_id,s.shop_name,s.shop_price,s.type_id,t.type_name,p.picture_id,p.picture_url
from t_shop s
left join t_type t on s.type_id=t.type_id
left join t_picture p on s.shop_id = p.shop_id
<where>
<if test="typeId != null">
and s.type_id = #{typeId}
</if>
</where>
</select>
</mapper>

View File

@ -0,0 +1,8 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.bwie.list.mapper.TypeMapper">
<select id="findType" resultType="com.bwie.common.pojo.Type">
select type_id,type_name from t_type
</select>
</mapper>

View File

@ -0,0 +1,38 @@
target/
!.mvn/wrapper/maven-wrapper.jar
!**/src/main/**/target/
!**/src/test/**/target/
### IntelliJ IDEA ###
.idea/modules.xml
.idea/jarRepositories.xml
.idea/compiler.xml
.idea/libraries/
*.iws
*.iml
*.ipr
### Eclipse ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
build/
!**/src/main/**/build/
!**/src/test/**/build/
### VS Code ###
.vscode/
### Mac OS ###
.DS_Store

View File

@ -0,0 +1,66 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.bwie</groupId>
<artifactId>bwie-models</artifactId>
<version>1.0-SNAPSHOT</version>
</parent>
<artifactId>bwie-user</artifactId>
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<!-- 系统公共 依赖 -->
<dependency>
<groupId>com.bwie</groupId>
<artifactId>bwie-common</artifactId>
</dependency>
<!-- SpringBoot Web-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- Druid -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.2.8</version>
</dependency>
<!-- Mysql Connector -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<!-- Mybatis 依赖配置 -->
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>2.2.2</version>
</dependency>
<!-- Pagehelper -->
<dependency>
<groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper-spring-boot-starter</artifactId>
<version>1.4.1</version>
</dependency>
<!-- test -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.github.tobato</groupId>
<artifactId>fastdfs-client</artifactId>
<version>1.26.5</version>
</dependency>
</dependencies>
</project>

View File

@ -0,0 +1,19 @@
package com.bwie.user;
import com.alibaba.nacos.shaded.org.checkerframework.checker.units.qual.min;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;
/**
* @author 86175
*/
@SpringBootApplication
@EnableFeignClients
public class UserApplication {
public static void main(String[] args) {
SpringApplication.run(UserApplication.class,args);
}
}

View File

@ -0,0 +1,54 @@
package com.bwie.user.controller;
import com.alibaba.fastjson.JSON;
import com.bwie.common.pojo.User;
import com.bwie.common.result.Result;
import com.bwie.user.service.UserService;
import lombok.extern.log4j.Log4j2;
import org.hibernate.validator.constraints.Length;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletRequest;
/**
* @author 86175
*/
@RestController
@RequestMapping("/user")
@Log4j2
public class UserController {
@Autowired
private HttpServletRequest request;
@Autowired
private UserService userService;
/**
*
*/
@PostMapping("/findByPhone/{phone}")
public Result<User> findByPhone(@PathVariable String phone){
log.info("功能描述:后台是否存在该手机号,请求URI:{},请求方式:{},请求参数:{}",request.getServletPath(),request.getMethod(),phone);
User user=userService.findByPhone(phone);
Result result=Result.success(user);
log.info("功能描述:查询是否存在该手机号,请求URI:{},请求方式:{},响应结果:{}",request.getServletPath(),request.getMethod(), JSON.toJSONString(result));
return result;
}
/**
*
*/
@PostMapping("/reg")
public Result<Integer> regLogin(@RequestBody User user){
log.info("功能描述:注册调用,请求URI:{},请求方式:{},请求参数:{}",request.getServletPath(),request.getMethod(),user);
Integer add =userService.reg(user);
Result<Integer> result = Result.success(add);
log.info("功能描述:注册调用,请求URI:{},请求方式:{},响应结果:{}",request.getServletPath(),request.getMethod(), JSON.toJSONString(result));
return result;
}
}

View File

@ -0,0 +1,22 @@
package com.bwie.user.mapper;
import com.bwie.common.pojo.User;
import org.apache.ibatis.annotations.Mapper;
/**
* @author 86175
*/
@Mapper
public interface UserMapper {
/**
* @param phone
* @return
*
*/
User findByPhone(String phone);
Integer reg(User user);
}

View File

@ -0,0 +1,11 @@
package com.bwie.user.service;
import com.bwie.common.pojo.User;
public interface UserService {
User findByPhone(String phone);
Integer reg(User user);
}

View File

@ -0,0 +1,27 @@
package com.bwie.user.service.impl;
import com.bwie.common.pojo.User;
import com.bwie.user.mapper.UserMapper;
import com.bwie.user.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.bwie.user.service.UserService;
@Service
public class UserServiceImpl implements UserService {
@Autowired
public UserMapper userMapper;
@Override
public User findByPhone(String phone) {
return userMapper.findByPhone(phone);
}
@Override
public Integer reg(User user) {
return userMapper.reg(user);
}
}

View File

@ -0,0 +1,55 @@
package com.bwie.user.util;
import org.springframework.stereotype.Component;
import com.github.tobato.fastdfs.domain.fdfs.StorePath;
import com.github.tobato.fastdfs.service.FastFileStorageClient;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.util.StringUtils;
import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource;
/**
* @BelongsProject: 0107day02
* @BelongsPackage: com.bw.config
* @Author: zhupengfei
* @CreateTime: 2023-02-01 08:52
*/
@Component
public class FastUtil {
private static final Logger log = LoggerFactory.getLogger(FastUtil.class);
@Resource
private FastFileStorageClient storageClient ;
/**
*
*/
public String upload(MultipartFile multipartFile) throws Exception{
String originalFilename = multipartFile.getOriginalFilename().
substring(multipartFile.getOriginalFilename().
lastIndexOf(".") + 1);
StorePath storePath = this.storageClient.uploadImageAndCrtThumbImage(
multipartFile.getInputStream(),
multipartFile.getSize(),originalFilename , null);
return storePath.getFullPath() ;
}
/**
*
*/
public String deleteFile(String fileUrl) {
if (StringUtils.isEmpty(fileUrl)) {
log.info("fileUrl == >>文件路径为空...");
return "文件路径不能为空";
}
try {
StorePath storePath = StorePath.parseFromUrl(fileUrl);
storageClient.deleteFile(storePath.getGroup(), storePath.getPath());
} catch (Exception e) {
log.error(e.getMessage());
}
return "删除成功";
}
}

View File

@ -0,0 +1,58 @@
# Tomcat
server:
port: 9002
# Spring
spring:
rabbitmq:
host: 111.229.234.119
port: 5672
userName: guest
password: guest
listener:
simple:
prefetch: 1
publisher-confirm-type: correlated
publisher-returns: true
main:
allow-circular-references: true
jackson:
date-format: yyyy-MM-dd HH:mm:ss
time-zone: GMT+8
application:
# 应用名称
name: bwie-user
profiles:
# 环境配置
active: dev
cloud:
sentinel:
transport:
# 控制台地址
#sentinel 地址不需要改动
dashboard: 127.0.0.1:8080
# 指定sentinel控制台获取应用数据的端口被占用会端口号默认 +1
port: 8719
nacos:
discovery:
# 服务注册地址
server-addr: 111.229.234.119:8848
config:
# 配置中心地址
server-addr: 111.229.234.119:8848
# 配置文件格式
file-extension: yml
# 共享配置
shared-configs:
- application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
fdfs:
so-timeout: 1500 # socket 连接时长
connect-timeout: 600 # 连接 tracker 服务器超时时长
# 这两个是你服务器的 IP 地址,注意 23000 端口也要打开阿里云服务器记得配置安全组。tracker 要和 stroage 服务进行交流
tracker-list: 111.229.234.119:22122
web-server-url: 111.229.234.119:8888
pool:
jmx-enabled: false
# 生成缩略图
thumb-image:
height: 500
width: 500

View File

@ -0,0 +1,15 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.bwie.user.mapper.UserMapper">
<insert id="reg">
INSERT INTO `shop_manage`.`t_user`
(`user_name`, `phone`, `email`, `user_role`)
VALUES
(#{userName}, #{phone}, #{email}, 2)
</insert>
<select id="findByPhone" resultType="com.bwie.common.pojo.User">
select * from t_user where phone=#{phone}
</select>
</mapper>

View File

@ -12,7 +12,10 @@
<artifactId>bwie-models</artifactId>
<packaging>pom</packaging>
<modules>
<module>bwie-user</module>
<module>bwie-sell</module>
<module>bwie-buy</module>
<module>bwie-shopList</module>
</modules>
<properties>
@ -23,6 +26,7 @@
<dependencies>
<!-- 系统公共 依赖 -->
<dependency>
@ -63,13 +67,10 @@
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.github.tobato</groupId>
<artifactId>fastdfs-client</artifactId>
<version>1.26.5</version>
</dependency>
</dependencies>
</project>