基于Dubbo的CRM系统

package com.bjpowernode.workbench.controller; import com.alibaba.dubbo.config.annotation.Reference; import com.bjpowernode.entity.Page; import com.bjpowernode.entity.R; import com.bjpowernode.enums.State; import com.bjpowernode.settings.service.ActivityService; import com.bjpowernode.utils.DateTimeUtils; import com.bjpowernode.utils.IdUtils; import com.bjpowernode.utils.JwtUtils; import com.bjpowernode.workbench.domain.Activity; import com.bjpowernode.workbench.domain.ActivityRemark; import lombok.RequiredArgsConstructor; import org.apache.poi.hssf.usermodel.HSSFWorkbook; import org.apache.poi.ss.usermodel.Row; import org.apache.poi.ss.usermodel.Sheet; import org.apache.poi.ss.usermodel.Workbook; import org.apache.poi.xssf.usermodel.XSSFWorkbook; import org.springframework.http.HttpHeaders; import org.springframework.http.HttpStatus; import org.springframework.util.CollectionUtils; import org.springframework.web.bind.annotation.*; import org.springframework.web.multipart.MultipartFile; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletResponse; import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.ArrayList; import java.util.List; import java.util.UUID; @RestController @RequestMapping("/workbench/activity") @RequiredArgsConstructor public class ActivityController { private final JwtUtils jwtUtils; @Reference(interfaceClass = ActivityService.class,version = "1.0.0",check = false) private ActivityService activityService; @GetMapping("/page") public Page<Activity> page(@RequestParam("pageNo")Integer pageNo, @RequestParam("pageSize")Integer pageSize, @RequestParam(value = "name",required = false)String name, @RequestParam(value = "owner",required = false)String owner, @RequestParam(value = "startDate",required = false)String startDate, @RequestParam(value = "endDate",required = false)String endDate ){ //封装返回值结果并返回 return activityService.page( pageNo , pageSize, name, owner, startDate, endDate ); } @PostMapping public R<Boolean> saveActivity(@RequestBody Activity activity){ return R.ok( activityService.save( activity.setId(IdUtils.getId()) .setCreateBy(jwtUtils.getName()) .setCreateTime(DateTimeUtils.getTime19()) .setEditBy(jwtUtils.getName()) .setEditTime(DateTimeUtils.getTime19()) .setIsDelete("0") ), State.SAVE_ERROR ); } @GetMapping("/{activityId}") public R<Activity> getActivity(@PathVariable("activityId")String activityId){ return R.ok( activityService.getActivityById(activityId) ); } @PutMapping public R<Boolean> updateActivity(@RequestBody Activity activity){ return R.ok( activityService.update( activity.setEditBy(jwtUtils.getName()) .setEditTime(DateTimeUtils.getTime19()) ), State.UPDATE_ERROR ); } @DeleteMapping("/list") public R<Boolean> deleteActivityList(@RequestBody List<String> ids){ return R.ok( activityService.deleteList(ids,jwtUtils.getName(),DateTimeUtils.getTime19()), State.DELETE_ERROR ); } @PostMapping("/import") public R<Boolean> importActivity(@RequestParam("activityFile")MultipartFile activityFile) throws IOException { //获取文件后缀名 String suffix = activityFile.getOriginalFilename().substring( activityFile.getOriginalFilename().lastIndexOf(".") ); //生成新的文件名称 = 文件上传路径/日期/文件名称.后缀名 String url = "F:\\code\\crm\\settings\\src\\main\\resources\\datadir" + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMdd")) + "/" + UUID.randomUUID().toString() + suffix; //判断路径是否存在 if (!new File(url).exists()) //路径不存在 new File(url).mkdirs(); //文件上传操作 activityFile.transferTo( new File(url) ); //批量导入操作 //从文件上传的路径，读取成为输入流对象 InputStream in = new FileInputStream(url); //基于输入流对象，创建工作簿对象 Workbook workbook = null; if (suffix.contains("xls")) //低版本 workbook = new HSSFWorkbook(in); else //高版本 workbook = new XSSFWorkbook(in); //读取页码对象 Sheet sheet = workbook.getSheetAt(0); //读取行对象，第一行是表头数据 //获取最后的行号 int lastRowNum = sheet.getLastRowNum(); //获取所有者 创建人 创建时间 String owner = jwtUtils.getOwner(); String createBy = jwtUtils.getName(); String time = DateTimeUtils.getTime19(); //封装集合 List<Activity> activityList = new ArrayList<>(); //遍历最后的行号 for (int i = 0; i < lastRowNum; i++) { //跳过第一行表头数据 Row row = sheet.getRow(i + 1); String name = row.getCell(0).getStringCellValue(); String startDate = row.getCell(1).getStringCellValue(); String endDate = row.getCell(2).getStringCellValue(); String cost = row.getCell(3).getStringCellValue(); String description = row.getCell(4).getStringCellValue(); //封装市场活动对象 activityList.add( Activity.builder() .id(IdUtils.getId()) .owner(owner) .name(name) .startDate(startDate) .endDate(endDate) .cost(cost) .description(description) .createTime(time) .createBy(createBy) .editTime(time) .editBy(createBy) .isDelete("0") // .build() ); } //批量插入操作 return R.ok( activityService.saveActivityList(activityList), State.SAVE_ERROR ); } @GetMapping("/export") public void exportActivity(@RequestParam ("Authorization")String token, @RequestParam(value = "ids",required = false)List<String> ids, HttpServletResponse response){ //校验token的合法性 if (!JwtUtils.checkToken(token)) throw new RuntimeException(State.TOKEN_FAILED.getMsg()); //System.out.println("令牌校验通过"); //批量导出操作 //将数据从数据库中查询出来，根据ids(动态sql) List<Activity> activityList = activityService.getActivityListById(ids); if (CollectionUtils.isEmpty(activityList)) throw new RuntimeException(State.QUERY_ERROR.getMsg()); //创建工作簿对象 Workbook workbook = new HSSFWorkbook(); //创建页码对象 Sheet sheet = workbook.createShe