后端代码位置

image.png

后端代码解析

查询自定义菜单模块详情

根据菜单URL中的菜单id，查询菜单详情规则，在vue前端首页，展示指定的规则信息，如：列表展示、查询字段、状态等等。

  1.     /**
  2.      * @title findVMenuInfo
  3.      * @description 查询模块菜单信息
  4.      * @author Administrator
  5.      * @updateTime 2021/10/2 0002 22:11
  6.      */
  7.     @GetMapping("/findVMenuInfo")
  8.     public void findVMenuInfo(HttpServletRequest request, HttpServletResponse response) throws Exception {
  9.         PageData pd = new PageData(request);
  10.         Vmenu vmenu = vmenuService.getById(pd.get("menu_id").toString());
  11.         Vform vform = vformService.getById(vmenu.getTable_id());
  12.         vmenu.setVform(vform);
  13.         pd.put("type","0");
  14.         pd.put("table_id",vmenu.getTable_id());
  15.         List<PageData> vmenuTfields = vmenuTfieldService.findFieldList(pd);
  16.         vmenu.setFieldPdList(vmenuTfields);
  17.         this.writeJson(response,vmenu);
  18.     }

查询自定义表单详情

根据菜单模块id查询对应的拖拽表单信息，用于vue编辑页面的表单初始化及内容展示。

  1.  /**
  2.      * @title findVFormInfo
  3.      * @description 查询自定义表单信息
  4.      * @author Administrator
  5.      * @updateTime 2021/10/3 0003 10:21
  6.      */
  7.     @GetMapping("/findVFormInfo")
  8.     public void findVFormInfo(HttpServletRequest request, HttpServletResponse response) throws Exception {
  9.         PageData pd = new PageData(request);
  10.         Vmenu vmenu = vmenuService.getById(pd.get("menu_id").toString());
  11.         Vform vform = vformService.getById(vmenu.getTable_id());
  12.         QueryWrapper queryWrapper = new QueryWrapper();
  13.         queryWrapper.eq("table_id",vform.getId());
  14.         List<Vfield> vfields = vfieldService.list(queryWrapper);
  15.         vform.setVfields(vfields);
  16.         this.writeJson(response,vform);
  17.     }

查询关联表单详情

  1.  /**
  2.      * @title findLinkFormList
  3.      * @description 查询关联表信息
  4.      * @author Administrator
  5.      * @updateTime 2021/10/3 0003 12:31
  6.      */
  7.     @GetMapping("/findLinkFormList")
  8.     public void findLinkFormList(HttpServletRequest request, HttpServletResponse response) throws Exception {
  9.         PageData pd = new PageData(request);
  10.         QueryWrapper formWrapper = new QueryWrapper();
  11.         formWrapper.eq("main_id",pd.get("table_id").toString());
  12.         List<Vform> list = vformService.list(formWrapper);
  13.         for (Vform vform:list) {
  14.             QueryWrapper queryWrapper = new QueryWrapper();
  15.             queryWrapper.eq("table_id",vform.getId());
  16.             List<Vfield> vfields = vfieldService.list(queryWrapper);
  17.             vform.setVfields(vfields);
  18.         }
  19.         this.writeJson(response,list);
  20.     }

查询自定义模块分页列表

  1.    /**
  2.      * @title findListPage
  3.      * @description 查询数据列表
  4.      * @author Administrator
  5.      * @updateTime 2021/10/1 0001 22:28
  6.      */
  7.     @GetMapping("/findListPage")
  8. //    @PreAuthorize("hasAnyAuthority('vdata:info')")
  9.     public MyResponse findListPage(QueryRequest queryRequest,HttpServletRequest request) throws Exception {
  10.         PageData pd = new PageData(request);
  11.         String userParams = SecurityContextHolder.getContext().getAuthentication().getName();
  12.         //处理数据权限
  13.         String user_id = userParams.split(":")[1];
  14.         UserOrganize uoParam = new UserOrganize();
  15.         uoParam.setUser_id(user_id);
  16.         UserOrganize userOrganize = userOrganizeService.findUserOrganizeInfo(uoParam);
  17.         List<String> auth_organize_ids = new ArrayList<String>();
  18.         if(Verify.verifyIsNotNull(userOrganize)){
  19.             if(Verify.verifyIsNotNull(userOrganize.getAuthOrgIds())){
  20.                 auth_organize_ids = Arrays.asList(userOrganize.getAuthOrgIds().split(","));
  21.             }
  22.         }
  23.         pd.put("auth_user",user_id);
  24.         pd.put("auth_organize_ids",auth_organize_ids);
  25.         Vmenu vmenu = vmenuService.getById(pd.get("menu_id").toString());
  26.         QueryWrapper queryWrapper = new QueryWrapper();
  27.         queryWrapper.eq("menu_id",vmenu.getId());
  28.         pd.put("type","0");
  29.         pd.put("table_id",vmenu.getTable_id());
  30.         List<PageData> vmenuTfields = vmenuTfieldService.findFieldList(pd);
  31.         StringBuffer field = new StringBuffer();
  32.         StringBuffer query_field = new StringBuffer();
  33.         for (PageData mPd : vmenuTfields) {
  34.             field.append("a." + mPd.get("field_name")).append(",");
  35.             if (mPd.get("field_query").equals("true") && pd.containsKey(mPd.get("field_name"))) {//查询字段
  36.                 if(Verify.verifyIsNotNull(pd.get(mPd.get("field_name")))){
  37.                     if (mPd.get("query_type").equals("like")) {
  38.                         query_field.append(" and a." + mPd.get("field_name") + " like '%" + pd.get(mPd.get("field_name")) + "%'");
  39.                     } else if (mPd.get("query_type").equals("=") || mPd.get("query_type").equals(">") || mPd.get("query_type").equals(">=") || mPd.get("query_type").equals("!=")) {
  40.                         query_field.append(" and a." + mPd.get("field_name") + " " + mPd.get("query_type") + " '" + pd.get(mPd.get("field_name")) + "'");
  41.                     } else if (mPd.get("query_type").equals("<") || mPd.get("query_type").equals("<=")) {
  42.                         query_field.append(" and a." + mPd.get("field_name") + " " + mPd.get("query_type") + " '" + pd.get(mPd.get("field_name")) + "'");
  43.                     } else if (mPd.get("query_type").equals("is null") || mPd.get("query_type").equals("is not null")) {
  44.                         query_field.append(" and a." + mPd.get("field_name") + " " + mPd.get("query_type"));
  45.                     }
  46.                 }
  47.             }
  48.         }
  49.         //是否开启创建时间段查询
  50.         if(vmenu.getOpen_timequery().equals("0")){
  51.             if(Verify.verifyIsNotNull(pd.get("start_time"))){
  52.                 query_field.append(" and a.create_time >='" + pd.get("start_time")+"'");
  53.             }
  54.             if(Verify.verifyIsNotNull(pd.get("end_time"))){
  55.                 query_field.append(" and a.create_time <='" + pd.get("end_time")+"'");
  56.             }
  57.         }
  58.         //处理排序
  59.         if(Verify.verifyIsNotNull(vmenu.getMain_order())){
  60.             pd.put("order_by",vmenu.getMain_order());
  61.         }else{
  62.             pd.put("order_by"," order by a.create_time desc ");
  63.         }
  64.         //处理约束条件
  65.         if(Verify.verifyIsNotNull(vmenu.getQuery_cond())){
  66.             query_field.append(" "+vmenu.getQuery_cond()+" ");
  67.         }
  68.         Vform vform = vformService.getById(vmenu.getTable_id());
  69.         pd.put("table_name", vform.getTable_name());
  70.         pd.put("field", field.toString());
  71.         pd.put("query_field", query_field.toString());
  72.         IPage<PageData> list = dataService.findListPage(pd, queryRequest);
  73.         for (PageData p:list.getRecords()) {
  74.             QueryWrapper cformWrapper = new QueryWrapper();
  75.             cformWrapper.eq("main_id",vmenu.getTable_id());
  77.             List<Vform> vforms = vformService.list(cformWrapper);
  78.             for (Vform form:vforms) {
  79.                 QueryWrapper cfieldWrapper = new QueryWrapper();
  80.                 cfieldWrapper.eq("table_id",form.getId());
  81.                 List<Vfield> vfs = vfieldService.list(cfieldWrapper);
  82.                 StringBuffer cQueryField = new StringBuffer();
  83.                 for (Vfield vfield : vfs) {
  84.                     cQueryField.append("a." + vfield.getField_name()).append(",");
  85.                 }
  86.                 pd.put("field", cQueryField.toString());
  87.                 pd.put("table_name",form.getTable_name());
  88.                 pd.put("main_id",p.get("id"));
  89.                 List<PageData> childList = dataService.findList(pd);
  90.                 p.put(form.getTable_name(),childList);
  91.             }
  92.             //处理流程信息
  93.             if(vmenu.getOpen_process().equals("0")){
  94.                 String businessKey = "business:customize:"+vmenu.getId()+":"+p.get("id");
  95.                 p.put("businessKey",businessKey);
  96.                 List<Task> taskList = taskService.createTaskQuery().processInstanceBusinessKeyLike(businessKey).orderByTaskCreateTime().desc().list();
  97.                 if(Verify.verifyIsNotNull(taskList)&&taskList.size()>0){
  98.                     StringBuffer blr = new StringBuffer();
  99.                     StringBuffer blzt = new StringBuffer();
  100.                     for (Task task:taskList) {
  101.                         if(Verify.verifyIsNotNull(task.getAssignee())){
  102.                             pd.put("user_id",task.getAssignee());
  103.                             PageData userPd = userService.findUserInfo(pd);
  104.                             blr.append(userPd.get("name")).append(",");
  105.                         }else{
  106.                             blr.append("任务未认领").append(",");
  107.                         }
  108.                         blzt.append(task.getName()).append(",");
  109.                     }
  110.                     if(blr.length()>0){
  111.                         p.put("assignee",blr.substring(0,blr.length()-1));
  112.                     }
  113.                     if(blzt.length()>0){
  114.                         p.put("dealStatus",blzt.substring(0,blzt.length()-1));
  115.                     }
  116.                     p.put("processStatus","1");
  117.                     p.put("dealTime",DateTimeUtil.getDateTimeStr(taskList.get(0).getCreateTime()));
  118.                 }else{
  119.                     List<HistoricProcessInstance> piList = historyService.createHistoricProcessInstanceQuery().processInstanceBusinessKey(businessKey).list();
  120.                     if(piList.size()>0){
  121.                         p.put("dealStatus","流程已结束");
  122.                         p.put("processStatus","2");
  123.                     }else{
  124.                         p.put("dealStatus","流程未启动");
  125.                         p.put("processStatus","0");
  126.                     }
  127.                 }
  128.                 if(!p.get("processStatus").equals("0")){
  129.                     ProcessInstance processInstance = runtimeService.createProcessInstanceQuery().processInstanceBusinessKey(businessKey).singleResult();
  130.                     if(Verify.verifyIsNotNull(processInstance)){
  131.                         p.put("processInstanceId",processInstance.getId());
  132.                     }
  133.                 }
  134.             }
  135.         }
  136.         Map<String, Object> dataTable = MyUtil.getDataTable(list);
  137.         MyResponse myResponse = new MyResponse();
  138.         myResponse.data(dataTable);
  139.         return myResponse;
  140.     }

1、查询菜单模块规则

image.png

2、拼接查询条件信息image.png

3、处理排序和约束条件

image.png

4、执行查询主表数据列表image.png

5、处理关联流程

如果是流程表单，则查询关联的流程信息。
image.png

保存数据信息

更新数据和保存数据类似，可参考报数数据信息。
保存方法的核心代码在：VDataServiceImpl

  1. public void saveVData(PageData pd){
  2.         Vform vform = vformService.getById(pd.get("table_id").toString());
  3.         QueryWrapper queryWrapper = new QueryWrapper();
  4.         queryWrapper.eq("table_id",vform.getId());
  5.         List<Vfield> vfields = vfieldService.list(queryWrapper);
  7.         StringBuffer paramKeyField = new StringBuffer();
  8.         StringBuffer paramValueField = new StringBuffer();
  9.         for (Vfield vfield : vfields) {
  10.             if(!vfield.getField_type().equals("batch")){
  11.                 paramKeyField.append(vfield.getField_name()).append(",");
  12.                 paramValueField.append("#{"+vfield.getField_name()+"}").append(",");
  13.             }
  14.             //处理图片
  15.             if(vfield.getField_type().equals("uploadFile")||vfield.getField_type().equals("uploadImg")){
  16.                 System.out.println("------------开始处理附件");
  17.                 System.out.println();
  18.                 List<PageData> list = (List<PageData>)pd.get(vfield.getField_name());
  19.                 pd.put(vfield.getField_name(), JsonToMap.list2json(list));
  20.             }
  21.         }
  22.         String id = GuidUtil.getUuid();
  23.         String time = DateTimeUtil.getDateTimeStr();
  24.         String authParams = SecurityContextHolder.getContext().getAuthentication().getName();
  25.         pd.put("id",id);
  26.         pd.put("type","0");
  27.         pd.put("status","0");
  28.         pd.put("create_time",time);
  29.         pd.put("create_user",authParams.split(":")[1]);
  30.         pd.put("create_organize",authParams.split(":")[2]);
  31.         pd.put("param_key", paramKeyField);
  32.         pd.put("param_value", paramValueField);
  33.         pd.put("table_name", vform.getTable_name());
  34.         this.baseMapper.saveData(pd);
  35.         //处理子表
  36.         QueryWrapper formWrapper = new QueryWrapper();
  37.         formWrapper.eq("main_id",pd.get("table_id").toString());
  38.         List<Vform> vforms = vformService.list(formWrapper);
  39.         for (Vform form:vforms) {
  40.             QueryWrapper fieldWrapper = new QueryWrapper();
  41.             fieldWrapper.eq("table_id",form.getId());
  42.             List<Vfield> fields = vfieldService.list(fieldWrapper);
  43.             StringBuffer field_k = new StringBuffer();
  44.             StringBuffer field_v = new StringBuffer();
  45.             List<String> uploadFiledName = new ArrayList<String>();
  46.             for (Vfield field : fields) {
  47.                 field_k.append(field.getField_name()).append(",");
  48.                 field_v.append("#{"+field.getField_name()+"}").append(",");
  49.                 //处理图片
  50.                 if(field.getField_type().equals("uploadFile")||field.getField_type().equals("uploadImg")){
  51.                     uploadFiledName.add(field.getField_name());
  52.                 }
  53.             }
  55.             List<Map> dataList = (List<Map>)pd.get(form.getTable_name());
  56.             for (Map map:dataList) {
  57.                 PageData p = PageData.getInstance().map2Pd(map);
  58.                 uploadFiledName.forEach(field_name->{
  59.                     List<PageData> list = (List<PageData>)p.get(field_name);
  60.                     p.put(field_name, JsonToMap.list2json(list));
  61.                 });
  62.                 p.put("main_id",id);
  63.                 p.put("table_name", form.getTable_name());
  64.                 p.put("param_key", field_k);
  65.                 p.put("param_value", field_v);
  66.                 p.put("id", GuidUtil.getUuid());
  67.                 p.put("type","0");
  68.                 p.put("status","0");
  69.                 p.put("create_time",time);
  70.                 p.put("create_user",authParams.split(":")[1]);
  71.                 p.put("create_organize",authParams.split(":")[2]);
  72.                 p.put("menu_id",pd.get("menu_id"));
  73.                 this.baseMapper.saveData(p);
  74.             }
  75.         }
  76.         //流程提报
  77.         Vmenu vmenu = vmenuService.getById(pd.get("menu_id").toString());
  78.         if(vmenu.getOpen_process().equals("0")){
  79.             String process_key = vmenu.getProcess_id();
  80.             if(pd.get("submitType").equals("2")){
  81.                 //处理流程上报
  82.                 String businessKey = "business:customize:"+pd.get("menu_id")+":"+id;
  83.                 //获取当前用户
  84.                 String userParams = SecurityContextHolder.getContext().getAuthentication().getName();
  85.                 Authentication.setAuthenticatedUserId(userParams.split(":")[2]+"_"+userParams.split(":")[1]);
  87.                 runtimeService.startProcessInstanceByKey(process_key,businessKey,pd);
  88.                 System.out.println("============================");
  89.                 System.out.println("流程启动成功");
  90.                 //当前任务
  91.                 List<Task> list = taskService.createTaskQuery().processDefinitionKey(process_key).processInstanceBusinessKey(businessKey).orderByTaskCreateTime().desc().list();
  92.                 for (Task task:list) {
  93.                     //根据流程定义id获取bpmnModel对象
  94.                     BpmnModel bpmnModel = repositoryService.getBpmnModel(task.getProcessDefinitionId());
  95.                     //获取当前节点信息
  96.                     FlowNode flowNode = (FlowNode) bpmnModel.getFlowElement(task.getTaskDefinitionKey());
  97.                     if(flowNode instanceof UserTask){
  98.                         List<Map> nodeData = (List<Map>)pd.get("nodeData");
  99.                         nodeData.forEach(item -> {
  100.                             if (item.get("node_id").equals(flowNode.getId())&&item.get("type").equals("1")) {//设置代办人
  101.                                 //判断多实例
  102.                                 UserTask userTask = (UserTask) flowNode;
  103.                                 if (!(userTask.getBehavior() instanceof ParallelMultiInstanceBehavior) && !(userTask.getBehavior() instanceof SequentialMultiInstanceBehavior)) {//不是多实例需要设置下一节点办理人
  104.                                     String deal_ids = item.get("deal_ids").toString();
  105.                                     if (item.get("assign_mode").equals("10")) {
  106.                                         String[] userIds = deal_ids.split(",");
  107.                                         for (int i = 0; i < userIds.length; i++) {
  108.                                             if (Verify.verifyIsNotNull(userIds[i])) {
  109.                                                 taskService.addCandidateUser(task.getId(), userIds[i]);
  110.                                             }
  111.                                         }
  112.                                     }else if (item.get("assign_mode").equals("11")) {
  113.                                         String[] organizeIds = deal_ids.split(",");
  114.                                         for (int i = 0; i < organizeIds.length; i++) {
  115.                                             if (Verify.verifyIsNotNull(organizeIds[i])) {
  116.                                                 taskService.addCandidateGroup(task.getId(), organizeIds[i]);
  117.                                             }
  118.                                         }
  119.                                     } else {
  120.                                         if (Verify.verifyIsNotNull(deal_ids)) {
  121.                                             taskService.setAssignee(task.getId(), deal_ids);
  122.                                         }
  123.                                     }
  125.                                 }
  126.                             }
  127.                         });
  128.                     }
  129.                 }
  130.             }
  131.         }
  132.     }

1、查询拖拽表单及规则-组织字段信息

image.png

2、处理基础参数信息及保存

image.png

3、处理子表信息，组织子表字段

image.png

4、数据转换及保存子表

image.png

5、如果是流程表单-启动流程

image.png
image.png

删除数据

  1.  //删除数据
  2.     public void delData(PageData pd){
  3.         Vform vform = vformService.getById(pd.get("table_id").toString());
  4.         String[] del_ids = pd.get("ids").toString().split(StringPool.COMMA);
  5.         pd.put("ids", Arrays.asList(del_ids));
  6.         pd.put("table_name",vform.getTable_name());
  7.         this.baseMapper.delData(pd);
  8.         //处理子表
  9.         QueryWrapper formWrapper = new QueryWrapper();
  10.         formWrapper.eq("main_id",pd.get("table_id").toString());
  11.         List<Vform> vforms = vformService.list(formWrapper);
  12.         for (Vform form:vforms) {
  13.             pd.put("main_ids", Arrays.asList(del_ids));
  14.             pd.put("table_name",form.getTable_name());
  15.             this.baseMapper.delChildData(pd);
  16.         }
  17.     }