package com.zy.crm.manager.controller; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.baomidou.mybatisplus.mapper.Wrapper; import com.baomidou.mybatisplus.plugins.Page; import com.core.annotations.ManagerAuth; import com.core.common.BaseRes; import com.core.common.Cools; import com.core.common.DateUtils; import com.core.common.R; import com.core.domain.KeyValueVo; import com.core.exception.CoolException; import com.zy.crm.common.model.SettleDto; import com.zy.crm.common.web.BaseController; import com.zy.crm.manager.entity.*; import com.zy.crm.manager.service.*; import com.zy.crm.system.entity.User; import com.zy.crm.system.service.UserService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.core.io.ClassPathResource; import org.springframework.util.ClassUtils; import org.springframework.web.bind.annotation.*; import org.springframework.web.multipart.MultipartFile; import javax.servlet.http.HttpServletResponse; import java.io.*; import java.text.SimpleDateFormat; import java.util.*; @RestController public class PriOnline2Controller extends BaseController { @Autowired private PriOnline2Service priOnline2Service; @Autowired private PriService priService; @Autowired private PlanService planService; @Autowired private PlanTypeService planTypeService; @Autowired private ProcessPermissionsService processPermissionsService; @Autowired private PriQuoteService priQuoteService; @Autowired private CstmrService cstmrService; @Autowired private UserService userService; @RequestMapping(value = "/priOnline2/{id}/auth") @ManagerAuth public R get(@PathVariable("id") String id) { PriOnline2 priOnline2 = priOnline2Service.selectById(String.valueOf(id)); assert priOnline2 != null; JSONObject resultObj = JSON.parseObject(JSON.toJSONString(priOnline2)); // 步骤条相关 resultObj.put("step", priOnline2.getSettle() == 4 ? 0 : priOnline2.getSettle() + 1); return R.ok().add(resultObj); } @RequestMapping(value = "/priOnline2/viewCheck/{id}/auth") @ManagerAuth(memo = "查看询价") public R viewCheck(@PathVariable("id") String id) { PriOnline2 priOnline = priOnline2Service.selectById(String.valueOf(id)); if (Cools.isEmpty(priOnline.getCheckData())) { return R.error("请先上传询价"); } return R.ok(priOnline); } @RequestMapping(value = "/priOnline2/list/auth") @ManagerAuth public R list(@RequestParam(defaultValue = "1")Integer curr, @RequestParam(defaultValue = "10")Integer limit, @RequestParam(required = false)String orderByField, @RequestParam(required = false)String orderByType, @RequestParam(required = false)String condition, @RequestParam Map param){ EntityWrapper wrapper = new EntityWrapper<>(); wrapper.setSqlSelect("id,title,create_time as createTime,filepath,settle,item_id as itemId,order_num as orderNum,template_name as templateName,user_id as userId,dept_id as deptId,status,update_time as updateTime,check_data as checkData,update_user_id as updateUserId,member_id as memberId"); // wrapper.in("member_id", getUserRoleBelongsToUserId("allopen")); excludeTrash(param); convert(param, wrapper); allLike(PriOnline2.class, param.keySet(), wrapper, condition); wrapper.or().eq("member_id",getUserId()); if (!Cools.isEmpty(orderByField)){wrapper.orderBy(humpToLine(orderByField), "asc".equals(orderByType));} return R.ok(priOnline2Service.selectPage(new Page<>(curr, limit), wrapper)); } private void convert(Map map, EntityWrapper wrapper){ boolean signUserId = false; boolean signDeptId = false; boolean signHostId = false; for (Map.Entry entry : map.entrySet()){ if (entry.getKey().equals("dept_id")){ signDeptId = true; if (String.valueOf(entry.getValue()).equals("19")){ signHostId = true; } } } for (Map.Entry entry : map.entrySet()){ String val = String.valueOf(entry.getValue()); if (val.contains(RANGE_TIME_LINK)){ String[] dates = val.split(RANGE_TIME_LINK); wrapper.ge(entry.getKey(), DateUtils.convert(dates[0])); wrapper.le(entry.getKey(), DateUtils.convert(dates[1])); } else if (entry.getKey().equals("dept_id")){ if (!val.equals("19")){ wrapper.eq(entry.getKey(), val); } } else if (entry.getKey().equals("user_id") && !signDeptId){ signUserId = true; wrapper.eq(entry.getKey(), val); } else { wrapper.like(entry.getKey(), val); } } if (!signUserId && !signDeptId){ wrapper.eq("user_id", getUserId()); } if (signHostId){ wrapper.or().eq("host_id",1); } } @RequestMapping(value = "/priOnline2/add/auth") @ManagerAuth(memo = "添加核价管理") public R add(@RequestBody Map map) { PriOnline2 priOnline2 = new PriOnline2(); priOnline2.setCreateTime(new Date()); priOnline2.setTitle(map.get("title").toString()); // priOnline2.setTemplateName(map.get("title").toString()); priOnline2.setSheetData(map.get("sheetData").toString()); priOnline2.setItemId(Long.parseLong(map.get("itemId").toString())); SimpleDateFormat format = new SimpleDateFormat("yyyyMMddHHmmss"); priOnline2.setOrderNum(format.format(new Date())); //创建人员 priOnline2.setUserId(getUserId()); //创建人员部门 priOnline2.setDeptId(getDeptId()); //更新时间 priOnline2.setUpdateTime(new Date()); //更新人员 priOnline2.setUpdateUserId(getUserId()); //状态,未完成 priOnline2.setStatus(0); //业务员 // Item item = itemService.selectById(priOnline.getItemId()); Plan plan = planService.selectById(priOnline2.getItemId()); if (plan.getStatus()!=1){ return R.error("此规划单状态改变,请刷新页面重新选择!"); } priOnline2.setMemberId(plan.getUserId()); Cstmr cstmr = cstmrService.selectById(plan.getCstmrId()); priOnline2.setTemplateName(cstmr.getName()); //甲方单位名称 priOnline2.setSettle(0); // User manager = new User(); // try{ // manager = userService.getDeptManager(getHostId(), getUser().getDeptId()); // 获取部门领导 // }catch (Exception e){ // manager = getUser(); // } String node="2-"; PlanType planType = planTypeService.selectById(plan.getPlanType()); node = node+planType.getType(); ProcessPermissions processPermissions = processPermissionsService.selectOne(new EntityWrapper().eq("process_memo", 5).eq("process", node));//2:报价流程 User manager = userService.selectById(processPermissions.getUserId()); // 获取报价流程节点2确认人 User userUp = userService.selectById(plan.getUserId()); // 获取业务员 List initNames = new ArrayList<>(); initNames.add("接取核价任务"); initNames.add("完成核价"); initNames.add("经理审核"); initNames.add("业务员确认"); priOnline2.setSettleMsg(JSON.toJSONString(SettleDto.initSalesPricing(manager,getUser(),userUp,initNames,3))); //设置项目流程 plan.setStep(2); plan.setStatus(2); planService.updateById(plan); priOnline2Service.insert(priOnline2); return R.ok(); } @RequestMapping(value = "/priOnline2/addOther/auth") @ManagerAuth(memo = "另存核价管理") public R addOther(@RequestBody Map map) { PriOnline2 online = priOnline2Service.selectById(Long.parseLong(map.get("id").toString())); PriOnline2 priOnline2 = new PriOnline2(); priOnline2.setCreateTime(new Date()); priOnline2.setTitle(map.get("title").toString()); priOnline2.setTemplateName(online.getTemplateName()); priOnline2.setSheetData(map.get("sheetData").toString()); priOnline2.setItemId(online.getItemId()); SimpleDateFormat format = new SimpleDateFormat("yyyyMMddHHmmss"); priOnline2.setOrderNum(format.format(new Date())); //创建人员 priOnline2.setUserId(getUserId()); //更新时间 priOnline2.setUpdateTime(new Date()); //更新人员 priOnline2.setUpdateUserId(getUserId()); //状态,未完成 priOnline2.setStatus(0); priOnline2.setDeptId(getDeptId()); //业务员 // Item item = itemService.selectById(priOnline.getItemId()); Plan plan = planService.selectById(priOnline2.getItemId()); priOnline2.setMemberId(plan.getUserId()); priOnline2Service.insert(priOnline2); return R.ok(); } @RequestMapping(value = "/priOnline2/update/auth") @ManagerAuth(memo = "更新核价管理") public R update(@RequestBody Map map){ PriOnline2 priOnline2 = priOnline2Service.selectById(Long.parseLong(map.get("id").toString())); if (priOnline2.getStatus() == 1) { return R.error("核价已完成,禁止保存"); } priOnline2.setTitle(map.get("title").toString()); priOnline2.setSheetData(map.get("sheetData").toString()); //更新人员 priOnline2.setUpdateUserId(getUserId()); //更新时间 priOnline2.setUpdateTime(new Date()); priOnline2Service.updateById(priOnline2); return R.ok(); } //更新状态 @RequestMapping(value = "/priOnline2/updateForm/auth") @ManagerAuth(memo = "更新核价管理状态") public R updateForm(Long id,Integer status,String title,String templateName){ PriOnline2 priOnline2 = priOnline2Service.selectById(id); priOnline2.setStatus(status); priOnline2.setUpdateTime(new Date()); priOnline2.setTitle(title); priOnline2.setTemplateName(templateName); priOnline2Service.updateById(priOnline2); return R.ok(); } @RequestMapping(value = "/priOnline2/uploadCheck/auth") @ManagerAuth(memo = "上传询价文件") public R uploadCheck(@RequestParam("id") Integer id, @RequestParam("checkData") String checkData, @RequestParam("file") MultipartFile[] files){ PriOnline2 priOnline2 = priOnline2Service.selectById(id); if (priOnline2.getStatus() == 1) { return R.error("核价已完成,禁止上传"); } priOnline2.setCheckData(checkData); MultipartFile file = files[0]; SimpleDateFormat format = new SimpleDateFormat("yyyyMMdd_HHmmss"); String path = ClassUtils.getDefaultClassLoader().getResource("excel/uploadCheckData").getPath(); //文件后缀名 String suffix = file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf(".")); //上传文件名 String filename = format.format(new Date()) + suffix; //最终文件路径 String filepath = path + "/" + filename; //服务器端保存的文件对象 File serverFile = new File(filepath); if(!serverFile.exists()) { try { //创建文件 serverFile.createNewFile(); //将上传的文件写入到服务器端文件内 file.transferTo(serverFile); } catch (IOException e) { e.printStackTrace(); } } //保存文件名 priOnline2.setCheckDataFile(filename); priOnline2Service.updateById(priOnline2); return R.ok(); } @GetMapping("/priOnline2/checkDataDownload/{filename}") public void download(@PathVariable String filename, HttpServletResponse response) { try { ClassPathResource pathResource = new ClassPathResource("excel/uploadCheckData/" + filename); File file = pathResource.getFile(); InputStream inputStream = pathResource.getInputStream(); //输出文件 InputStream fis = new BufferedInputStream(inputStream); byte[] buffer = new byte[fis.available()]; fis.read(buffer); fis.close(); response.reset(); //获取文件的名字再浏览器下载页面 String name = file.getName(); response.addHeader("Content-Disposition", "attachment;filename=" + new String(name.getBytes(), "iso-8859-1")); response.addHeader("Content-Length", "" + file.length()); OutputStream out = new BufferedOutputStream(response.getOutputStream()); response.setContentType("application/octet-stream"); out.write(buffer); out.flush(); out.close(); } catch (Exception e) { e.printStackTrace(); } } @RequestMapping(value = "/priOnline2/delete/auth") @ManagerAuth(memo = "删除核价管理") public R delete(Long[] ids){ try{ if (Cools.isEmpty(ids) || ids.length==0){ return R.error(); } for (Long id : ids){ int priQuote= priQuoteService.selectCount(new EntityWrapper().eq("pri_online_id", id)); if (priQuote!=0){ return R.error("存在关联的报价单,禁止删除!!!"); } // int priSales = priSalesService.selectCount(new EntityWrapper().eq("pri_online2_id", id)); // if (priSales!=0){ // return R.error("存在关联的产品费用明细,禁止删除!!!"); // } } for (Long id : ids) { PriOnline2 priOnline2 = priOnline2Service.selectById(id); Plan plan = planService.selectById(priOnline2.getItemId()); plan.setStatus(1); planService.updateById(plan); } priOnline2Service.deleteBatchIds(Arrays.asList(ids)); return R.ok(); }catch (Exception e){ return R.error(e.getMessage()); } } @RequestMapping(value = "/priOnline2/export/auth") @ManagerAuth public R export(@RequestBody JSONObject param){ EntityWrapper wrapper = new EntityWrapper<>(); List fields = JSONObject.parseArray(param.getJSONArray("fields").toJSONString(), String.class); Map map = excludeTrash(param.getJSONObject("priOnline")); convert(map, wrapper); List list = priOnline2Service.selectList(wrapper); return R.ok(exportSupport(list, fields)); } @RequestMapping(value = "/priOnline2Query/auth") @ManagerAuth public R query(String condition) { EntityWrapper wrapper = new EntityWrapper<>(); wrapper.like("order_num", condition); wrapper.in("user_id", getUserRoleBelongsToUserId("allopen")); Page page = priOnline2Service.selectPage(new Page<>(0, 10), wrapper); List> result = new ArrayList<>(); for (PriOnline2 priOnline2 : page.getRecords()){ Map map = new HashMap<>(); map.put("id", priOnline2.getId()); // map.put("value", priOnline2.getOrderNum() + "/" + priOnline2.getPlanId$() + "/" + priOnline2.getMemberId$()); map.put("value", priOnline2.getOrderNum() + "/" + priOnline2.getTemplateName()); result.add(map); } return R.ok(result); } @RequestMapping(value = "/priOnline2Query2/auth") @ManagerAuth public R query2(String condition) { EntityWrapper wrapper = new EntityWrapper<>(); wrapper.like("order_num", condition); wrapper.in("user_id", getUserRoleBelongsToUserId("allopen")); Page page = priOnline2Service.selectPage(new Page<>(0, 10), wrapper); List> result = new ArrayList<>(); for (PriOnline2 priOnline2 : page.getRecords()){ Map map = new HashMap<>(); map.put("id", priOnline2.getId()); // map.put("value", priOnline2.getOrderNum() + "/" + priOnline2.getPlanId$() + "/" + priOnline2.getMemberId$()); // map.put("value", priOnline2.getOrderNum() + "/" + priOnline2.getTemplateName()); map.put("value", priOnline2.getOrderNum() + "/" + priOnline2.getPlanId$() + "/" + priOnline2.getMemberId$() + "/" + priOnline2.getTemplateName()); result.add(map); } return R.ok(result); } @RequestMapping(value = "/priOnline2/check/column/auth") @ManagerAuth public R query(@RequestBody JSONObject param) { Wrapper wrapper = new EntityWrapper().eq(humpToLine(String.valueOf(param.get("key"))), param.get("val")); if (null != priOnline2Service.selectOne(wrapper)){ return R.parse(BaseRes.REPEAT).add(getComment(PriOnline2.class, String.valueOf(param.get("key")))); } return R.ok(); } @RequestMapping("/priOnline2/all/get/kv") @ManagerAuth public R getDataKV(@RequestParam(required = false) String condition) { List vos = new ArrayList<>(); Wrapper wrapper = new EntityWrapper().andNew().like("id", condition).orderBy("create_time", false); priOnline2Service.selectPage(new Page<>(1, 30), wrapper).getRecords().forEach(item -> vos.add(new KeyValueVo(String.valueOf(item.getId()), item.getId()))); return R.ok().add(vos); } @PostMapping(value = "/priOnline2/approval/auth") @ManagerAuth public R approvalBusinessTrip(@RequestParam Long priOnlineId, @RequestParam(required = false) Long plannerId){ PriOnline2 priOnline2 = priOnline2Service.selectById(priOnlineId); assert priOnline2 != null; Date now = new Date(); switch (priOnline2.getSettle()) { case 0: // 本部门经理审核 节点负责人 Plan plan1 = planService.selectById(priOnline2.getItemId()); PlanType planType1 = planTypeService.selectById(plan1.getPlanType()); ProcessPermissions processPermissions1 = processPermissionsService.selectOne(new EntityWrapper().eq("process_memo", 5).eq("process", "2-"+planType1.getType()));//2:报价流程 User manager1 = userService.selectById(processPermissions1.getUserId()); // 获取报价流程节点2确认人 if (Cools.isEmpty(getUser())) { return R.error("抱歉,您没有提交的权限"); } if (!getUserId().equals(getUser().getId())) { return R.error("抱歉,您没有提交的权限"); } // 修改 settle 步骤数据 List list1 = JSON.parseArray(priOnline2.getSettleMsg(), SettleDto.class); for (SettleDto dto : list1) { switch (dto.getStep()) { case 0: dto.setCurr(Boolean.FALSE); break; case 1: dto.setCurr(Boolean.TRUE); dto.setMsg(getUser().getNickname() + "提交完成"); dto.setTime(DateUtils.convert(now)); break; default: break; } } priOnline2.setSettleMsg(JSON.toJSONString(list1)); // 修改规划单状态 priOnline2.setSettle(1); priOnline2.setUpdateUserId(getUserId()); priOnline2.setUpdateTime(now); priOnline2.setMemberId(manager1.getId()); if (!priOnline2Service.updateById(priOnline2)) { throw new CoolException("提交失败,请联系管理员"); } break; case 1: // 本部门经理审核 节点负责人 Plan plan = planService.selectById(priOnline2.getItemId()); PlanType planType = planTypeService.selectById(plan.getPlanType()); ProcessPermissions processPermissions = processPermissionsService.selectOne(new EntityWrapper().eq("process_memo", 5).eq("process", "2-"+planType.getType()));//2:报价流程 User manager = userService.selectById(processPermissions.getUserId()); // 获取报价流程节点2确认人 // User manager = new User(); // try{ // manager = userService.getDeptManager(getHostId(), getUser().getDeptId()); // 获取部门领导 // }catch (Exception e){ // manager = user; // } if (manager.getId().equals(getUserId())) { // 修改 settle 步骤数据 List list = JSON.parseArray(priOnline2.getSettleMsg(), SettleDto.class); for (SettleDto dto : list) { switch (dto.getStep()) { case 1: dto.setCurr(Boolean.FALSE); break; case 2: dto.setCurr(Boolean.TRUE); dto.setMsg(manager.getNickname() + "审批通过"); dto.setTime(DateUtils.convert(now)); break; default: break; } } priOnline2.setSettleMsg(JSON.toJSONString(list)); // 修改规划单状态 priOnline2.setSettle(2); // 申请通过 priOnline2.setUpdateTime(now); if (!priOnline2Service.updateById(priOnline2)) { throw new CoolException("审核失败,请联系管理员"); } } else { return R.error("抱歉,您没有审核的权限!!!"); } break; case 2: // 业务员 User salesman0 = userService.selectById(priOnline2.getUserId()); if (!getUserId().equals(salesman0.getId())) { return R.error("抱歉,您无需确认!!!"); } // 修改 settle 步骤数据 List list2 = JSON.parseArray(priOnline2.getSettleMsg(), SettleDto.class); for (SettleDto dto : list2) { switch (dto.getStep()) { case 2: dto.setCurr(Boolean.TRUE); break; case 3: dto.setCurr(Boolean.TRUE); dto.setMsg("业务员" + salesman0.getNickname() + "以确认"); dto.setTime(DateUtils.convert(new Date())); break; default: break; } } priOnline2.setSettleMsg(JSON.toJSONString(list2)); // 修改规划单状态 priOnline2.setSettle(3); // 审批通过 priOnline2.setStatus(1); priOnline2.setUpdateTime(new Date()); if (!priOnline2Service.updateById(priOnline2)) { throw new CoolException("确认失败,请联系管理员"); } try{ priQuoteAdd(priOnline2.getId(),plannerId); }catch (Exception e){ return R.error("自动生成报价单失败"); } break; default: return R.error(); } return R.ok("审批成功"); } public void priQuoteAdd(Long priOnlineId,Long priType){ Pri pri = null; if (priType==1L){ pri = priService.selectById(114); }else { pri = priService.selectById(115); } PriOnline2 priOnline2 = priOnline2Service.selectById(priOnlineId); PriQuote priQuote = new PriQuote(); priQuote.setCreateTime(new Date()); priQuote.setTitle(pri.getTitle()); priQuote.setTemplateName(priOnline2.getTemplateName()); priQuote.setSheetData(pri.getSheetData()); priQuote.setPriOnlineId(priOnlineId); priQuote.setItemId(priOnline2.getItemId()); priQuote.setOrderNum(priOnline2.getOrderNum()); SimpleDateFormat format = new SimpleDateFormat("yyyyMMddHHmmss"); priQuote.setInOrderNum(format.format(new Date())); //创建人员 priQuote.setUserId(getUserId()); //更新人员 priQuote.setUpdateUserId(getUserId()); //所属部门 priQuote.setDeptId(getDeptId()); //更新时间 priQuote.setUpdateTime(new Date()); //模板 Integer i = priType == 1L ? 1 : 2; priQuote.setTemplate(i.toString()); //业务员 Plan plan = planService.selectById(priQuote.getItemId()); priQuote.setMemberId(plan.getUserId()); //设置项目流程 plan.setStep(5); // priQuote.setForm(JSON.toJSONString(map)); // 自定义表单内容 priQuote.setSettle(1); // 1.开始 User manager = new User(); try{ manager = userService.getDeptManager(getHostId(), getUser().getDeptId()); // 获取部门领导 }catch (Exception e){ manager = getUser(); } ProcessPermissions processPermissions = processPermissionsService.selectOne(new EntityWrapper().eq("process_memo", 2).eq("process", "3-1"));//2:报价流程 User president = userService.selectById(processPermissions.getUserId()); // 获取报价流程节点3-1确认人 priQuote.setSettleMsg(JSON.toJSONString(SettleDto.initPriQuote(plan, manager,president,getUser()))); planService.updateById(plan); priQuoteService.insert(priQuote); } @PostMapping(value = "/priOnline2/priQuoteAdd/list/auth") @ManagerAuth public R priOnline2priQuoteAdd(@RequestParam Long planId){ List vos = new ArrayList<>(); vos.add(new KeyValueVo("报价模板1", 1L)); vos.add(new KeyValueVo("报价模板2", 2L)); return R.ok().add(vos); } }