Skip to content

J
jyzb_platformV2
Commit 39f51752 by 赵剑炜
Options

添加触发器方法

parent ce3b3217
正在显示 包含 340 行增加 和 619 行删除
jyzb-api/src/main/java/com/junmp/jyzb/api/bean/dto/TriggerDto.java 0 → 100644
package com.junmp.jyzb.api.bean.dto;
import lombok.Data;
import java.util.Date;
@Data
public class TriggerDto {
private String id;
private String triggerName;
private String actionClass;
private String delFlag;
private String contacts;
private String remark;
private Date createTime;
private Date updateTime;
private String createUser;
private String updateUser;
}
jyzb-api/src/main/java/com/junmp/jyzb/api/bean/query/QueryTriggerReq.java 0 → 100644
package com.junmp.jyzb.api.bean.query;
import com.junmp.v2.common.bean.request.BaseRequest;
import lombok.Data;
import javax.validation.constraints.NotNull;
import java.math.BigDecimal;
@Data
public class QueryTriggerReq extends BaseRequest {
private String id;
private String triggerName;
private String delFlag;
}
jyzb-api/src/main/java/com/junmp/jyzb/api/bean/req/UpdateTriggerReq.java 0 → 100644
package com.junmp.jyzb.api.bean.req;
import com.junmp.v2.common.bean.request.ValidationApi;
import lombok.Data;
import javax.validation.constraints.NotBlank;
@Data
public class UpdateTriggerReq {
@NotBlank(message = "触发器主键不能为空", groups = {ValidationApi.edit.class, ValidationApi.delete.class, ValidationApi.detail.class})
private String id;
private String triggerName;
private String actionClass;
private Integer delFlag;
private String remark;
}
jyzb-api/src/main/java/com/junmp/jyzb/api/exception/enums/TriggerExceptionEnum.java 0 → 100644
package com.junmp.jyzb.api.exception.enums;
import com.junmp.jyzb.api.constant.JYZBConstant;
import com.junmp.v2.common.constant.CommonConstant;
import com.junmp.v2.common.exception.IExceptionEnum;
import lombok.Getter;
@Getter
public enum TriggerExceptionEnum implements IExceptionEnum {
/**
*
*/
TRIGGER_NOT_EXIST(CommonConstant.DEFAULT_USER_ERROR_CODE + JYZBConstant.JYZB_EXCEPTION_STEP_CODE + 12, "触发器不存在"),
/**
*
*/
TRIGGER_IS_EXISTS(CommonConstant.DEFAULT_USER_ERROR_CODE,"触发器已存在");
/**
* 错误编码
*/
private final Integer code;
/**
* 提示用户信息
*/
private final String message;
TriggerExceptionEnum(Integer code, String message) {
this.code = code;
this.message = message;
}
}
jyzb-biz/src/main/java/com/junmp/jyzb/controller/TriggerController.java 0 → 100644
package com.junmp.jyzb.controller;
import com.junmp.jyzb.api.bean.query.QueryTriggerReq;
import com.junmp.jyzb.api.bean.req.UpdateTriggerReq;
import com.junmp.jyzb.entity.Trigger;
import com.junmp.jyzb.service.TriggerService;
import com.junmp.v2.common.bean.request.ValidationApi;
import com.junmp.v2.common.bean.response.ApiRes;
import com.junmp.v2.db.api.page.PageResult;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
@RestController
@Slf4j
@RequestMapping("/Trigger")
@Api(tags = "触发器模块")
public class TriggerController {
@Resource
public TriggerService triggerService;
@PostMapping("/AddTrigger")
@ApiOperation("添加触发器")
public ApiRes<String> AddTrigger(@RequestBody @Validated(ValidationApi.add.class) UpdateTriggerReq req) {
return ApiRes.success(triggerService.addTrigger(req));
}
@PostMapping("/UpdateTrigger")
@ApiOperation("修改触发器")
public ApiRes<Boolean> UpdateTrigger(@RequestBody @Validated(ValidationApi.edit.class) UpdateTriggerReq req) {
return ApiRes.success(triggerService.updateTrigger(req));
}
@PostMapping("/DeleteTrigger")
@ApiOperation("删除触发器")
public ApiRes<Boolean> DeleteTrigger(@RequestBody @Validated(ValidationApi.delete.class) UpdateTriggerReq req) {
return ApiRes.success(triggerService.deleteTrigger(req));
}
@PostMapping("/ChangeTriggerState")
@ApiOperation("禁用启用触发器")
public ApiRes<Boolean> ChangeTriggerState(@RequestBody @Validated(ValidationApi.updateStatus.class) UpdateTriggerReq req) {
return ApiRes.success(triggerService.changeTriggerState(req));
}
@PostMapping("/GetTriggerList")
@ApiOperation("查询触发器列表")
public ApiRes<PageResult<Trigger>> GetTriggerList(@RequestBody @Validated(ValidationApi.updateStatus.class) QueryTriggerReq req) {
return ApiRes.success(triggerService.getTriggerList(req));
}
}
jyzb-biz/src/main/java/com/junmp/jyzb/entity/Trigger.java 0 → 100644
package com.junmp.jyzb.entity;
import com.baomidou.mybatisplus.annotation.*;
import io.swagger.annotations.ApiModel;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
import java.util.Date;
@Data
@AllArgsConstructor
@NoArgsConstructor
@TableName("sys_trigger")
public class Trigger implements Serializable {
/**
* 供应商ID
*/
@TableId(value = "id")
private String id;
/**
* 触发器名称
*/
@TableField(value = "trigger_name")
private String triggerName;
/**
* 地址
*/
@TableField(value = "action_class")
private String actionClass;
/**
* 删除标识
*/
@TableField(value = "del_flag")
private String delFlag;
/**
* 备注
*/
@TableField(value = "remark")
private String remark;
@TableField(fill = FieldFill.INSERT_UPDATE, value = "create_time")
private Date createTime;
@TableField(fill = FieldFill.INSERT_UPDATE, value = "update_time")
private Date updateTime;
/**
* 更新人ID
*/
@TableField(value = "update_user")
private String updateUser;
}
jyzb-biz/src/main/java/com/junmp/jyzb/mapper/InventoryMapper.java.orig deleted 100644 → 0
package com.junmp.jyzb.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
<<<<<<< HEAD
import com.junmp.jyzb.entity.Inventory;
=======
import com.junmp.jyzb.entity.EquipmentSize;
import com.junmp.jyzb.entity.Inventory;
>>>>>>> develop
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
import java.util.Map;
@Mapper
<<<<<<< HEAD
public interface InventoryMapper extends BaseMapper<Inventory> {
=======
public interface InventoryMapper extends BaseMapper<Inventory> {
>>>>>>> develop
Map<String, Object> getSum(String queryType, String typeId);
Map<String, Object> getOrgNum(String typeId);
List<Map<String, Object>> getLocationInventory(@Param("queryType")String queryType, @Param("idMsg")String idMsg);
void deleteAllMsg();
void setOrgInventory();
void setCabinetInventory();
void setWarehouseInventory();
List<Map<String, Object>> getInventoryList(@Param("queryType")String queryType,@Param("typeCode") String typeCode,@Param("typeId") String typeId,@Param("sizeId") String sizeId);
List<Map<String, Object>> getInventoryByOrgId(String orgId);
}
\ No newline at end of file
jyzb-biz/src/main/java/com/junmp/jyzb/mapper/TriggerMapper.java 0 → 100644
package com.junmp.jyzb.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.junmp.jyzb.entity.Trigger;
import com.junmp.jyzb.entity.User;
public interface TriggerMapper extends BaseMapper<Trigger> {
}
jyzb-biz/src/main/java/com/junmp/jyzb/service/TriggerService.java 0 → 100644
package com.junmp.jyzb.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.junmp.jyzb.api.bean.dto.TriggerDto;
import com.junmp.jyzb.api.bean.dto.WarehouseAreaDto;
import com.junmp.jyzb.api.bean.query.QueryTriggerReq;
import com.junmp.jyzb.api.bean.query.WarehouseAreaReq;
import com.junmp.jyzb.api.bean.req.UpdateTriggerReq;
import com.junmp.jyzb.api.bean.req.UpdateWarehouseAreaReq;
import com.junmp.jyzb.entity.ProductTag;
import com.junmp.jyzb.entity.Trigger;
import com.junmp.jyzb.entity.User;
import com.junmp.v2.db.api.page.PageResult;
import java.util.List;
public interface TriggerService extends IService<Trigger> {
String addTrigger(UpdateTriggerReq req);
Boolean updateTrigger(UpdateTriggerReq msg);
Boolean deleteTrigger(UpdateTriggerReq msg);
boolean changeTriggerState(UpdateTriggerReq msg);
PageResult<Trigger> getTriggerList(QueryTriggerReq req);
}
jyzb-biz/src/main/java/com/junmp/jyzb/service/impl/TriggerServiceImpl.java 0 → 100644
package com.junmp.jyzb.service.impl;
import cn.hutool.core.util.ObjectUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.junmp.jyzb.api.bean.dto.TriggerDto;
import com.junmp.jyzb.api.bean.query.ProductTagReq;
import com.junmp.jyzb.api.bean.query.QueryTriggerReq;
import com.junmp.jyzb.api.bean.req.UpdateSupplierReq;
import com.junmp.jyzb.api.bean.req.UpdateTriggerReq;
import com.junmp.jyzb.api.exception.enums.SupplierExceptionEnum;
import com.junmp.jyzb.api.exception.enums.TriggerExceptionEnum;
import com.junmp.jyzb.api.exception.enums.WarehouseAreaExceptionEnum;
import com.junmp.jyzb.entity.ProductTag;
import com.junmp.jyzb.entity.Supplier;
import com.junmp.jyzb.entity.Trigger;
import com.junmp.jyzb.entity.WarehouseArea;
import com.junmp.jyzb.mapper.TriggerMapper;
import com.junmp.jyzb.mapper.WarehouseAreaMapper;
import com.junmp.jyzb.service.TriggerService;
import com.junmp.jyzb.service.WarehouseAreaService;
import com.junmp.v2.common.exception.base.ServiceException;
import com.junmp.v2.common.util.BeanPlusUtil;
import com.junmp.v2.db.api.factory.PageFactory;
import com.junmp.v2.db.api.factory.PageResultFactory;
import com.junmp.v2.db.api.page.PageResult;
import org.springframework.stereotype.Service;
import java.util.UUID;
@Service
public class TriggerServiceImpl extends ServiceImpl<TriggerMapper, Trigger> implements TriggerService {
@Override
public String addTrigger(UpdateTriggerReq req) {
Trigger trigger = new Trigger();
String ID= UUID.randomUUID().toString();
req.setId(ID);
BeanPlusUtil.copyProperties(req, trigger);
this.save(trigger);
return ID;
}
@Override
public Boolean updateTrigger(UpdateTriggerReq req) {
Trigger trigger = this.Query(req);
BeanPlusUtil.copyProperties(req, trigger);
return this.updateById(trigger);
}
private Trigger Query(UpdateTriggerReq req) {
Trigger app = this.getById(req.getId());
if (ObjectUtil.isNull(app)) {
throw new ServiceException(TriggerExceptionEnum.TRIGGER_NOT_EXIST);
}
return app;
}
@Override
public Boolean deleteTrigger(UpdateTriggerReq req) {
TriggerExist(req.getId());
Trigger trigger = new Trigger();
BeanPlusUtil.copyProperties(req,trigger);
return this.removeById(trigger.getId());
}
private Trigger TriggerExist(String id){
Trigger trigger = this.getById(id);
if (ObjectUtil.isNull(trigger)){
throw new ServiceException(TriggerExceptionEnum.TRIGGER_NOT_EXIST);
}
return trigger;
}
@Override
public boolean changeTriggerState(UpdateTriggerReq req) {
Trigger trigger = this.Query(req);
BeanPlusUtil.copyProperties(req, trigger);
return this.updateById(trigger);
}
public PageResult<Trigger> getTriggerList(QueryTriggerReq req)
{
LambdaQueryWrapper<Trigger> wrapper = createWrapper(req);
Page<Trigger> page = this.page(PageFactory.getDefaultPage(), wrapper);
return PageResultFactory.createPageResult(page);
}
private LambdaQueryWrapper<Trigger> createWrapper(QueryTriggerReq req) {
LambdaQueryWrapper<Trigger> wrapper = new LambdaQueryWrapper<>();
if (ObjectUtil.isEmpty(req)) {
return wrapper;
}
//根据业务编码查询
wrapper.like(ObjectUtil.isNotEmpty(req.getTriggerName()), Trigger::getTriggerName, req.getTriggerName());
wrapper.eq(ObjectUtil.isNotEmpty(req.getId()), Trigger::getId, req.getId());
wrapper.eq(ObjectUtil.isNotEmpty(req.getDelFlag()), Trigger::getDelFlag, req.getDelFlag());
wrapper.orderByDesc(Trigger::getCreateTime);
wrapper.orderByDesc(Trigger::getUpdateTime);
return wrapper;
}
}
jyzb-process/src/main/java/com/junmp/junmpProcess/service/Bussiness/SettingService.java deleted 100644 → 0
//package com.junmp.junmpProcess.service.Bussiness;
//
//import com.junmp.junmpProcess.dto.FlowEngineDTO;
//import com.junmp.junmpProcess.entity.ProcessTemplates;
//import com.junmp.junmpProcess.vo.TemplateGroupVo;
//
//import java.lang.reflect.InvocationTargetException;
//import java.util.List;
//
///**
// * @author : willian fu
// * @date : 2020/9/21
// */
//public interface SettingService {
//
// /**
// * 查询表单组
// *
// * @return 表单组数据
// */
// Object getFormGroups(String token, String name);
//
// /**
// * 表单及分组排序
// *
// * @param groups 分组数据
// * @return 排序结果
// */
// Object formGroupsSort(List<TemplateGroupVo> groups);
//
// /**
// * 查询表单模板数据
// *
// * @param templateId 模板id
// * @return 模板详情数据
// */
// Object getFormTemplateById(String templateId);
//
// /**
// * 修改分组
// *
// * @param id 分组ID
// * @param name 分组名
// * @return 修改结果
// */
// Object updateFormGroupName(Integer id, String name);
//
// /**
// * 新增表单分组
// *
// * @param name 分组名
// * @return 添加结果
// */
// Object createFormGroup(String name);
//
// /**
// * 删除分组
// *
// * @param id 分组ID
// * @return 删除结果
// */
// Object deleteFormGroup(Integer id);
//
// /**
// * 编辑表单
// *
// * @param templateId 摸板ID
// * @param type 类型 stop using delete
// * @return 操作结果
// */
// Object updateForm(String templateId, String type, Integer groupId);
//
// /**
// * 编辑表单详情
// *
// * @param template 表单模板信息
// * @return 修改结果
// */
// Object updateFormDetail(ProcessTemplates template);
//
//
// /**
// * 保存表单
// *
// * @param
// * @throws InvocationTargetException
// * @throws IllegalAccessException
// */
// void jsonToBpmn(FlowEngineDTO flowEngineDTO) throws InvocationTargetException, IllegalAccessException;
//}
jyzb-process/src/main/java/com/junmp/junmpProcess/service/Bussiness/impl/OrgUserServicelmpl.java deleted 100644 → 0
package com.junmp.junmpProcess.service.Bussiness.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.junmp.v2.sys.api.UserServiceApi;
import com.junmp.v2.sys.api.bean.user.OnlineUserDto;
import com.junmp.v2.sys.api.bean.user.SysUserDto;
import com.junmp.v2.sys.api.bean.user.UserLoginInfoDto;
import com.junmp.v2.sys.api.bean.user.dto.RoleUserDto;
import com.junmp.v2.sys.api.bean.user.req.OnlineUserReq;
import com.junmp.v2.sys.api.bean.user.req.SysUserReq;
import com.junmp.v2.sys.api.bean.user.vo.QueryUserInfoVo;
import java.util.Date;
import java.util.List;
import java.util.Set;
public class OrgUserServicelmpl implements UserServiceApi {
@Override
public UserLoginInfoDto getUserLoginInfo(String account) {
return null;
}
@Override
public void updateUserLoginInfo(Long userId, Date date, String ip) {
}
@Override
public Boolean userExist(Long userId) {
return null;
}
@Override
public List<Long> getUserRoleIdList(Long userId) {
return null;
}
@Override
public void deleteUserDataScopeListByOrgIdList(Set<Long> organizationIds) {
}
@Override
public void deleteUserRoleListByRoleId(Long roleId) {
}
@Override
public List<Long> getUserBindDataScope(Long userId) {
return null;
}
@Override
public List<OnlineUserDto> onlineUserList(OnlineUserReq req) {
return null;
}
@Override
public SysUserDto getUserInfoByUserId(Long userId) {
return null;
}
@Override
public List<Long> queryAllUserIdList(SysUserReq req) {
return null;
}
@Override
public List<String> queryAppByUserId(Long userId) {
return null;
}
@Override
public RoleUserDto queryUserByRoleId(Long roleId) {
return null;
}
@Override
public List<QueryUserInfoVo> queryUserByRoleAndOrg(Long roleId, Long orgId) {
return null;
}
}
jyzb-process/src/main/java/com/junmp/junmpProcess/service/Bussiness/impl/SettingServiceImpl.java deleted 100644 → 0
//package com.junmp.junmpProcess.service.Bussiness.impl;
//
//import cn.hutool.core.collection.CollectionUtil;
//import cn.hutool.core.util.ObjectUtil;
//import com.alibaba.fastjson.JSONObject;
//import com.alibaba.fastjson.TypeReference;
//import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
//import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
//import com.google.common.collect.Lists;
//import com.junmp.junmpProcess.exception.WorkFlowException;
//import com.junmp.junmpProcess.mapper.TemplateGroupMapper;
//import com.junmp.junmpProcess.service.Bussiness.SettingService;
//import com.junmp.junmpProcess.service.Repository.FormGroupService;
//import com.junmp.junmpProcess.service.Repository.ProcessTemplateService;
//import com.junmp.junmpProcess.service.Repository.TemplateGroupService;
//import org.apache.commons.lang3.time.DateFormatUtils;
//import org.flowable.bpmn.BpmnAutoLayout;
//import org.flowable.bpmn.model.*;
//import org.flowable.bpmn.model.Process;
//import org.flowable.engine.RepositoryService;
//import org.flowable.engine.delegate.ExecutionListener;
//import com.junmp.junmpProcess.common.R;
//import com.junmp.junmpProcess.common.WorkFlowConstants;
//import com.junmp.junmpProcess.dto.FlowEngineDTO;
//import com.junmp.junmpProcess.dto.json.ChildNode;
//import com.junmp.junmpProcess.dto.json.SettingsInfo;
//import com.junmp.junmpProcess.entity.FormGroups;
//import com.junmp.junmpProcess.entity.ProcessTemplates;
//import com.junmp.junmpProcess.entity.TemplateGroup;
//import com.junmp.junmpProcess.entity.TemplateGroupBo;
//import com.junmp.junmpProcess.utils.IdWorker;
//import com.junmp.junmpProcess.utils.SpringContextHolder;
//import com.junmp.junmpProcess.vo.TemplateGroupVo;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Service;
//import org.springframework.transaction.annotation.Transactional;
//import org.springframework.transaction.interceptor.TransactionAspectSupport;
//
//import javax.annotation.Resource;
//import java.lang.reflect.InvocationTargetException;
//import java.util.*;
//
//import static com.junmp.junmpProcess.utils.BpmnModelUtils.*;
//
///**
// * @author : willian fu
// * @date : 2020/9/21
// */
//@Service
//public class SettingServiceImpl implements SettingService {
//
// @Autowired
// private ProcessTemplateService processTemplateService;
//
// @Autowired
// private TemplateGroupService templateGroupService;
//
// @Autowired
// private FormGroupService formGroupService;
// @Resource
// private IdWorker idWorker;
// @Resource
// private RepositoryService repositoryService;
//
// /**
// * 查询表单组
// *
// * @return 表单组数据
// */
// @Override
// public Object getFormGroups(String token, String name) {
// TemplateGroupMapper templateGroupMapper = SpringContextHolder.getBean(TemplateGroupMapper.class);
// List<TemplateGroupBo> allformAndGroups = templateGroupMapper.getAllFormAndGroups();
// Map<Integer, List<TemplateGroupBo>> coverMap = new LinkedHashMap<>();
// allformAndGroups.forEach(fg -> {
// List<TemplateGroupBo> bos = coverMap.get(fg.getGroupId());
// if (CollectionUtil.isEmpty(bos)) {
// List<TemplateGroupBo> list = new ArrayList<>();
// list.add(fg);
// coverMap.put(fg.getGroupId(), list);
// } else {
// bos.add(fg);
// }
// });
// List<TemplateGroupVo> results = new ArrayList<>();
// coverMap.forEach((key, val) -> {
// List<TemplateGroupVo.Template> templates = new ArrayList<>();
// val.forEach(v -> {
// if (ObjectUtil.isNotNull(v.getTemplateId())) {
// templates.add(TemplateGroupVo.Template.builder()
// .formId(v.getTemplateId())
// .tgId(v.getId())
// .remark(v.getRemark())
// .formName(v.getTemplateName())
// .icon(v.getIcon())
// .isStop(v.getIsStop())
// .updated(DateFormatUtils.format(v.getUpdated(), "yyyy年MM月dd日 HH时:mm分:ss秒"))
// .background(v.getBackground())
// .templateId(v.getTemplateId())
// .logo(JSONObject.parseObject(v.getBackground(), new TypeReference<JSONObject>() {
// }))
// .build());
// }
// });
// results.add(TemplateGroupVo.builder().id(key).name(val.get(0).getGroupName()).items(templates).build());
// });
// return R.ok(results);
// }
//
// /**
// * 表单及分组排序
// *
// * @param groups 分组数据
// * @return 排序结果
// */
// @Override
// @Transactional
// public Object formGroupsSort(List<TemplateGroupVo> groups) {
// int i = 0, j = 0;
// try {
// for (TemplateGroupVo group : groups) {
// formGroupService.updateById(FormGroups.builder()
// .groupId(group.getId())
// .sortNum(group.getId().equals(0) ? 999999 : i + 2)
// .build());
// for (TemplateGroupVo.Template item : group.getItems()) {
// templateGroupService.updateById(
// TemplateGroup.builder()
// .id(item.getTgId())
// .groupId(group.getId())
// .templateId(item.getFormId())
// .sortNum(j + 1).build());
// j++;
// }
// i++;
// j = 0;
// }
// } catch (Exception e) {
// TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
// return R.badRequest("排序异常 " + e.getMessage());
// }
// return R.ok("排序成功");
// }
//
// /**
// * 查询表单模板数据
// *
// * @param templateId 模板id
// * @return 模板详情数据
// */
// @Override
// public Object getFormTemplateById(String templateId) {
// ProcessTemplates processTemplates = processTemplateService.getById(templateId);
// processTemplates.setLogo(processTemplates.getIcon());
// processTemplates.setFormId(processTemplates.getTemplateId());
// processTemplates.setFormName(processTemplates.getTemplateName());
// return R.ok(processTemplates);
// }
//
// /**
// * 修改分组
// *
// * @param id 分组ID
// * @param name 分组名
// * @return 修改结果
// */
// @Override
// public Object updateFormGroupName(Integer id, String name) {
// if (id < 2) {
// return R.badRequest("基础分组不允许修改");
// }
// formGroupService.updateById(FormGroups.builder()
// .groupId(id).groupName(name.trim()).build());
// return R.ok("修改成功");
// }
//
// /**
// * 新增表单分组
// *
// * @param name 分组名
// * @return 添加结果
// */
// @Override
// public Object createFormGroup(String name) {
// LambdaQueryWrapper<FormGroups> lambdaQueryWrapper = new LambdaQueryWrapper<>();
// lambdaQueryWrapper.eq(FormGroups::getGroupName, name);
// if (formGroupService.count(lambdaQueryWrapper) > 0) {
// return R.badRequest("分组名称 [" + name + "] 已存在");
// }
// Date date = new Date();
// FormGroups formGroups = FormGroups.builder().groupName(name)
// .sortNum(1).created(date)
// .updated(date).build();
// formGroupService.save(
// formGroups);
// return R.ok("添加分组 " + name + " 成功");
// }
//
// /**
// * 删除分组
// *
// * @param id 分组ID
// * @return 删除结果
// */
// @Override
// @Transactional
// public Object deleteFormGroup(Integer id) {
// if (id < 2) {
// return R.badRequest("基础分组不允许删除");
// }
// LambdaUpdateWrapper<TemplateGroup> lambdaUpdateWrapper = new LambdaUpdateWrapper<>();
// lambdaUpdateWrapper.set(TemplateGroup::getGroupId, 1);
// lambdaUpdateWrapper.eq(TemplateGroup::getGroupId, id);
// templateGroupService.update(lambdaUpdateWrapper);
// formGroupService.removeById(id);
// return R.ok("删除分组成功");
// }
//
// /**
// * 编辑表单
// *
// * @param templateId 摸板ID
// * @param type 类型 stop using delete
// * @return 操作结果
// */
// @Override
// @Transactional
// public Object updateForm(String templateId, String type, Integer groupId) {
// boolean isStop = "stop".equals(type);
//
//
// ProcessTemplates build = ProcessTemplates.builder().templateId(templateId).isStop(isStop)
// .build();
// if ("using".equals(type) || isStop) {
// processTemplateService.updateById(
// ProcessTemplates.builder().templateId(templateId).isStop(isStop).build());
// LambdaUpdateWrapper<TemplateGroup> lambdaUpdateWrapper = new LambdaUpdateWrapper<>();
// lambdaUpdateWrapper.eq(TemplateGroup::getTemplateId, templateId);
// lambdaUpdateWrapper.set(TemplateGroup::getGroupId, isStop ? 0 : 1);
// templateGroupService
// .update(lambdaUpdateWrapper);
// } else if ("delete".equals(type)) {
// processTemplateService.removeById(templateId);
// LambdaQueryWrapper<TemplateGroup> lambdaQueryWrapper = new LambdaQueryWrapper<>();
// lambdaQueryWrapper.eq(TemplateGroup::getTemplateId, templateId);
// templateGroupService.remove(lambdaQueryWrapper);
// } else if ("move".equals(type)) {
// if (ObjectUtil.isNull(groupId)) {
// return R.badRequest("分组ID必传");
// }
//
// LambdaUpdateWrapper<TemplateGroup> lambdaUpdateWrapper = new LambdaUpdateWrapper<>();
// lambdaUpdateWrapper.eq(TemplateGroup::getTemplateId, templateId);
// lambdaUpdateWrapper.set(TemplateGroup::getGroupId, groupId);
// templateGroupService.update(lambdaUpdateWrapper);
// } else {
// return R.badRequest("不支持的操作");
// }
// return R.ok("操作成功");
// }
//
// /**
// * 编辑表单详情
// *
// * @param template 表单模板信息
// * @return 修改结果
// */
// @Override
// @Transactional(rollbackFor = Exception.class)
// public Object updateFormDetail(ProcessTemplates template) {
// SettingsInfo settingsInfo = JSONObject.parseObject(template.getSettings(), new TypeReference<SettingsInfo>() {
// });
// ProcessTemplates processTemplates = processTemplateService.getById(template.getFormId());
// processTemplates.setTemplateName(template.getFormName());
// processTemplates.setGroupId(template.getGroupId());
// processTemplates.setFormItems(template.getFormItems());
// processTemplates.setSettings(template.getSettings());
// processTemplates.setProcess(template.getProcess());
// processTemplates.setIcon(template.getIcon());
// processTemplates.setBackground(template.getBackground());
// processTemplates.setNotify(settingsInfo.getNotify().toJSONString());
// String adminInfo = JSONObject.toJSONString(settingsInfo.getAdmin());
// processTemplates.setWhoCommit(adminInfo);
//
// processTemplates.setWhoEdit(adminInfo);
// processTemplates.setWhoExport(adminInfo);
// processTemplates.setRemark(template.getRemark());
// processTemplates.setUpdated(new Date());
// processTemplateService.updateById(processTemplates);
// ChildNode childNode = JSONObject.parseObject(template.getProcess(), new TypeReference<ChildNode>() {
// });
// JSONObject jsonObject = new JSONObject();
// jsonObject.put("processJson", template.getProcess());
// jsonObject.put("formJson", template.getFormItems());
// BpmnModel bpmnModel = assemBpmnModel(jsonObject, childNode, template.getRemark(),
// template.getFormName(), template.getGroupId(), template.getFormId());
// repositoryService.createDeployment()
// .addBpmnModel(template.getFormName() + ".bpmn", bpmnModel)
// .name(template.getFormName())
// .category(template.getGroupId() + "")
// .deploy();
// return R.ok("发布更新后的表单成功");
// }
//
// @Transactional(rollbackFor = Exception.class)
// @Override
// public void jsonToBpmn(FlowEngineDTO flowEngineDTO) throws InvocationTargetException, IllegalAccessException {
// String processJson = flowEngineDTO.getProcess();
// ChildNode childNode = JSONObject.parseObject(processJson, new TypeReference<ChildNode>() {
// });
// String settingsJson = flowEngineDTO.getSettings();
// SettingsInfo settingsInfo = JSONObject.parseObject(settingsJson, new TypeReference<SettingsInfo>() {
// });
// String remark = flowEngineDTO.getRemark();
// String formItems = flowEngineDTO.getFormItems();
// String formName = flowEngineDTO.getFormName();
// String logo = flowEngineDTO.getLogo();
// Integer groupId = flowEngineDTO.getGroupId();
// String templateId = idWorker.nextId() + "";
//
// ProcessTemplates processTemplates = ProcessTemplates.builder().build();
// processTemplates.setTemplateId(templateId);
// processTemplates.setTemplateName(formName);
// processTemplates.setGroupId(groupId);
// processTemplates.setFormItems(formItems);
// processTemplates.setProcess(processJson);
// processTemplates.setIcon(logo);
// processTemplates.setBackground(logo);
// processTemplates.setNotify(settingsInfo.getNotify().toJSONString());
// String adminInfo = JSONObject.toJSONString(settingsInfo.getAdmin());
// processTemplates.setSettings(settingsJson);
// processTemplates.setWhoCommit(adminInfo);
// processTemplates.setWhoEdit(adminInfo);
// processTemplates.setWhoExport(adminInfo);
// processTemplates.setRemark(flowEngineDTO.getRemark());
// processTemplates.setIsStop(false);
// Date date = new Date();
// processTemplates.setCreated(date);
// processTemplates.setUpdated(date);
// processTemplateService.save(processTemplates);
// TemplateGroup templateGroup = new TemplateGroup();
// templateGroup.setTemplateId(processTemplates.getTemplateId());
// templateGroup.setGroupId(groupId);
// templateGroup.setSortNum(0);
// templateGroup.setCreated(date);
// templateGroupService.save(templateGroup);
//
// JSONObject jsonObject = new JSONObject();
// jsonObject.put("processJson", processJson);
// jsonObject.put("formJson", formItems);
// BpmnModel bpmnModel = assemBpmnModel(jsonObject, childNode, remark, formName, groupId,
// templateId);
// repositoryService.createDeployment()
// .addBpmnModel(formName + ".bpmn", bpmnModel)
// .name(formName)
// .category(groupId + "")
// .deploy();
//
//
// }
//
// private BpmnModel assemBpmnModel(JSONObject jsonObject, ChildNode childNode, String remark,
// String formName, Integer groupId, String templateId) {
// BpmnModel bpmnModel = new BpmnModel();
// List<SequenceFlow> sequenceFlows = Lists.newArrayList();
// Map<String, ChildNode> childNodeMap = new HashMap<>();
// bpmnModel.setTargetNamespace(groupId + "");
// ExtensionAttribute extensionAttribute = new ExtensionAttribute();
// extensionAttribute.setName("DingDing");
// extensionAttribute.setNamespace("http://flowable.org/bpmn");
// extensionAttribute.setValue(jsonObject.toJSONString());
// Process process = new Process();
// process.setId(WorkFlowConstants.PROCESS_PREFIX + templateId);
// process.setName(formName);
// process.setDocumentation(remark);
// process.addAttribute(extensionAttribute);
// bpmnModel.addProcess(process);
//
// StartEvent startEvent = createStartEvent();
// process.addFlowElement(startEvent);
// String lastNode = null;
// try {
// lastNode = create(startEvent.getId(), childNode, process, bpmnModel, sequenceFlows, childNodeMap);
// } catch (InvocationTargetException e) {
// e.printStackTrace();
// throw new WorkFlowException("操作失败");
// } catch (IllegalAccessException e) {
// e.printStackTrace();
// throw new WorkFlowException("操作失败");
// }
// EndEvent endEvent = createEndEvent();
// process.addFlowElement(endEvent);
// process.addFlowElement(connect(lastNode, endEvent.getId(), sequenceFlows, childNodeMap, process));
// List<FlowableListener> executionListeners = new ArrayList<>();
// FlowableListener flowableListener = new FlowableListener();
// flowableListener.setEvent(ExecutionListener.EVENTNAME_END);
// flowableListener.setImplementationType(ImplementationType.IMPLEMENTATION_TYPE_DELEGATEEXPRESSION);
// flowableListener.setImplementation("${processListener}");
// executionListeners.add(flowableListener);
// process.setExecutionListeners(executionListeners);
// new BpmnAutoLayout(bpmnModel).execute();
// return bpmnModel;
// }
//}
Markdown 格式
0% 或
您添加了 0 人 到此讨论。请谨慎行事。
请先完成此评论的编辑！
请 注册 或者 后发表评论