From 1bd2237b161e519c340052916c8e941a16595ba3 Mon Sep 17 00:00:00 2001 From: LSH Date: 星期一, 31 七月 2023 02:06:41 +0800 Subject: [PATCH] #售前规划申请单上传文件预览 --- src/main/java/com/zy/crm/manager/controller/PlanController.java | 163 ++++++++++++++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 157 insertions(+), 6 deletions(-) diff --git a/src/main/java/com/zy/crm/manager/controller/PlanController.java b/src/main/java/com/zy/crm/manager/controller/PlanController.java index 95381bb..335d9c9 100644 --- a/src/main/java/com/zy/crm/manager/controller/PlanController.java +++ b/src/main/java/com/zy/crm/manager/controller/PlanController.java @@ -12,7 +12,10 @@ import com.core.common.R; import com.core.domain.KeyValueVo; import com.core.exception.CoolException; +import com.zy.crm.common.entity.RouteCollectCountType; import com.zy.crm.common.model.SettleDto; +import com.zy.crm.common.utils.FileSaveExampleUtil; +import com.zy.crm.common.utils.SetOfUtils; import com.zy.crm.common.web.BaseController; import com.zy.crm.manager.controller.result.FollowerTableVo; import com.zy.crm.manager.entity.Plan; @@ -35,9 +38,12 @@ import org.springframework.web.multipart.MultipartFile; import javax.servlet.http.HttpServletResponse; +import java.io.File; import java.io.IOException; import java.io.InputStream; import java.util.*; + +import static java.util.stream.Collectors.toList; @RestController public class PlanController extends BaseController { @@ -144,12 +150,45 @@ @RequestMapping(value = "/plan/update/auth") @ManagerAuth + @Transactional public R update(@RequestParam Map<String, Object> param){ +// String planNeed = null; +// Integer id = null; +// for (Map.Entry<String, Object> entry : param.entrySet()){ +// String val = String.valueOf(entry.getValue()); +// if (Cools.isEmpty(val)){ +// continue; +// } +// if (entry.getKey().equals("planNeed")){ +// planNeed = val; +// } +// if (entry.getKey().equals("id")){ +// try{ +// id = Integer.parseInt(val); +// }catch (Exception e){ +// return R.error(); +// } +// } +// } if (Cools.isEmpty(param) || Cools.isEmpty(param.get("id"))){ return R.error(); } +// List<String> planNeedbs = new ArrayList<>(Arrays.asList(planNeed.split("-"))); +// if (planNeedbs.get(0).equals("[object Object]")){ +// planNeedbs.remove(0); +// Plan plan1 = planService.selectById(id); +// List<String> planNeedas = Arrays.asList(plan1.getPlanNeed().split("-")); +// List<String> routeIntersectionString = SetOfUtils.getRouteIntersectionString(planNeedas, planNeedbs, RouteCollectCountType.DEDUPLICATIONUNION); +// planNeed=""; +// for (String planNeedss:routeIntersectionString){ +// planNeed=planNeed==""? planNeedss:planNeed + "-" + planNeedss; +// } +// } + + // pre Plan plan = JSON.parseObject(JSON.toJSONString(param), Plan.class); +// plan.setPlanNeed(planNeed); param.entrySet().removeIf(next -> this.fields.contains(next.getKey())); plan.setUpdateBy(getUserId()); plan.setUpdateTime(new Date()); @@ -170,6 +209,53 @@ } return R.ok(); } + + @RequestMapping(value = "/plan/insert/file/auth") +// @ManagerAuth + public R insertFile(@RequestParam("planId") String planId,@RequestParam MultipartFile file){ + planId="涓婁紶鏂囦欢-20"; + String[] split = planId.split("-"); + int id = Integer.parseInt(split[1]); + System.out.println("---寮�濮�---"); + String savePath = "D:/crm/plan/file/"+id+"/"; // 鎸囧畾淇濆瓨鏂囦欢鐨勮矾寰� + try{ + FileSaveExampleUtil.saveFile(file, savePath); + }catch (Exception e){ + return R.error(); + } + return R.ok(); + } + + @RequestMapping(value = "/plan/delete/file/auth") +// @ManagerAuth + public R deleteFile(@RequestParam("planId") String planId,@RequestParam MultipartFile file){ + planId="涓婁紶鏂囦欢-20"; + String[] split = planId.split("-"); + int id = Integer.parseInt(split[1]); + System.out.println("---寮�濮�---"); + String savePath = "D:/crm/plan/file/"+id+"/"+file.getName(); // 鎸囧畾淇濆瓨鏂囦欢鐨勮矾寰� + try{ + FileSaveExampleUtil.deleteFilesInDirectory(savePath); + }catch (Exception e){ + return R.error(); + } + return R.ok(); + } + + @RequestMapping(value = "/plan/view/file/auth") +// @ManagerAuth + public R viewFile(@RequestParam("planId") String planId){ + int id = Integer.parseInt(planId); + String savePath = "D:/crm/plan/file/"+id+"/"; // 鎸囧畾淇濆瓨鏂囦欢鐨勮矾寰� + try{ + List<FileSaveExampleUtil.FileDTO> fileDTOS = FileSaveExampleUtil.viewFileList(savePath); + return R.ok(fileDTOS); + }catch (Exception e){ + return R.error(); + } + } + + @PostMapping(value = "/plan/approval/auth") @ManagerAuth @@ -261,8 +347,6 @@ break; case 3: dto.setCurr(Boolean.TRUE); - dto.setUserId(planLeader.getId()); - dto.setUsername(planLeader.getNickname()); dto.setMsg("鍞墠缁勯暱" + planLeader.getNickname() + "瀹℃壒閫氳繃"); dto.setTime(DateUtils.convert(new Date())); break; @@ -285,18 +369,85 @@ throw new CoolException("瀹℃牳澶辫触锛岃鑱旂郴绠$悊鍛�"); } - // 娣诲姞瑙勫垝缁勯暱璺熻繘浜� + // 娣诲姞瑙勫垝鍛樿窡杩涗汉 PlanFoll planFoll = new PlanFoll(); - planFoll.setPlanId(planner.getId()); - planFoll.setUserId(planLeader.getId()); + planFoll.setPlanId(plan.getId()); + planFoll.setUserId(planner.getId()); if (!planFollService.insert(planFoll)) { throw new CoolException("瀹℃牳澶辫触锛岃鑱旂郴绠$悊鍛�"); } - break; case 3: + User plannerUser = userService.selectById(plan.getPlanner()); + if (Cools.isEmpty(plannerUser)) { + return R.error("鏈壘鍒拌鍒掑憳"); + } + if (!getUserId().equals(plannerUser.getId())) { + return R.error("鎶辨瓑锛屾偍娌℃湁瀹℃牳鐨勬潈闄�"); + } + // 涓氬姟鍛� + User salesman = userService.selectById(plan.getUserId()); + // 淇敼 settle 姝ラ鏁版嵁 + List<SettleDto> list0 = JSON.parseArray(plan.getSettleMsg(), SettleDto.class); + for (SettleDto dto : list0) { + switch (dto.getStep()) { + case 3: + dto.setCurr(Boolean.FALSE); + break; + case 4: + dto.setCurr(Boolean.TRUE); + dto.setMsg("瑙勫垝鍛�" + plannerUser.getNickname() + "瀹℃壒閫氳繃"); + dto.setTime(DateUtils.convert(new Date())); + break; + case 5: + dto.setUserId(salesman.getId()); + dto.setUsername(salesman.getNickname()); + break; + default: + break; + } + } + plan.setSettleMsg(JSON.toJSONString(list0)); + // 淇敼瑙勫垝鍗曠姸鎬� + plan.setSettle(4); // 瀹℃壒閫氳繃 + plan.setUpdateBy(getUserId()); + plan.setUpdateTime(new Date()); + + if (!planService.updateById(plan)) { + throw new CoolException("瀹℃牳澶辫触锛岃鑱旂郴绠$悊鍛�"); + } break; case 4: + // 涓氬姟鍛� + User salesman0 = userService.selectById(plan.getUserId()); + if (!getUserId().equals(salesman0.getId())) { + return R.error("鎶辨瓑锛屾偍娌℃湁瀹℃牳鐨勬潈闄�"); + } + // 淇敼 settle 姝ラ鏁版嵁 + List<SettleDto> list1 = JSON.parseArray(plan.getSettleMsg(), SettleDto.class); + for (SettleDto dto : list1) { + switch (dto.getStep()) { + case 4: + dto.setCurr(Boolean.TRUE); + break; + case 5: + dto.setCurr(Boolean.TRUE); + dto.setMsg("涓氬姟鍛�" + salesman0.getNickname() + "瀹℃壒閫氳繃"); + dto.setTime(DateUtils.convert(new Date())); + break; + default: + break; + } + } + plan.setSettleMsg(JSON.toJSONString(list1)); + // 淇敼瑙勫垝鍗曠姸鎬� + plan.setSettle(5); // 瀹℃壒閫氳繃 + plan.setUpdateBy(getUserId()); + plan.setUpdateTime(new Date()); + + if (!planService.updateById(plan)) { + throw new CoolException("瀹℃牳澶辫触锛岃鑱旂郴绠$悊鍛�"); + } break; default: return R.error(); -- Gitblit v1.9.1