添加机构信息管理功能

2019-03-07 15:00:18 +08:00
parent 5892199127
commit 23e9cb356e
14 changed files with 1007 additions and 5 deletions
--- a/src/main/java/com/jsh/erp/service/organization/OrganizationComponent.java
+++ b/src/main/java/com/jsh/erp/service/organization/OrganizationComponent.java
@@ -0,0 +1,66 @@
+package com.jsh.erp.service.organization;
+
+import com.jsh.erp.service.ICommonQuery;
+import com.jsh.erp.utils.Constants;
+import com.jsh.erp.utils.QueryUtils;
+import com.jsh.erp.utils.StringUtil;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * Description
+ *
+ * @Author: cjl
+ * @Date: 2019/3/6 15:09
+ */
+@Service(value = "organization_component")
+@OrganizationResource
+public class OrganizationComponent implements ICommonQuery {
+    @Resource
+    private OrganizationService organizationService;
+    @Override
+    public Object selectOne(String condition) {
+        return null;
+    }
+
+    @Override
+    public List<?> select(Map<String, String> parameterMap) {
+        return getOrganizationList(parameterMap);
+    }
+    private List<?> getOrganizationList(Map<String, String> map) {
+        return null;
+    }
+    @Override
+    public Long counts(Map<String, String> parameterMap) {
+        return null;
+    }
+
+    @Override
+    public int insert(String beanJson, HttpServletRequest request) {
+        return organizationService.insertOrganization(beanJson,request);
+    }
+
+    @Override
+    public int update(String beanJson, Long id) {
+        return organizationService.updateOrganization(beanJson,id);
+    }
+
+    @Override
+    public int delete(Long id) {
+        return organizationService.deleteOrganization(id);
+    }
+
+    @Override
+    public int batchDelete(String ids) {
+        return organizationService.batchDeleteOrganization(ids);
+    }
+
+    @Override
+    public int checkIsNameExist(Long id, String name) {
+        return 0;
+    }
+}
--- a/src/main/java/com/jsh/erp/service/organization/OrganizationResource.java
+++ b/src/main/java/com/jsh/erp/service/organization/OrganizationResource.java
@@ -0,0 +1,18 @@
+package com.jsh.erp.service.organization;
+
+import com.jsh.erp.service.ResourceInfo;
+
+import java.lang.annotation.*;
+
+/**
+ * Description
+ *  机构
+ * @Author: cjl
+ * @Date: 2019/3/6 15:10
+ */
+@ResourceInfo(value = "organization", type = 110)
+@Inherited
+@Target(ElementType.TYPE)
+@Retention(RetentionPolicy.RUNTIME)
+public @interface OrganizationResource {
+}
--- a/src/main/java/com/jsh/erp/service/organization/OrganizationService.java
+++ b/src/main/java/com/jsh/erp/service/organization/OrganizationService.java
@@ -0,0 +1,188 @@
+package com.jsh.erp.service.organization;
+
+import com.alibaba.fastjson.JSONObject;
+import com.jsh.erp.constants.BusinessConstants;
+import com.jsh.erp.constants.ExceptionConstants;
+import com.jsh.erp.datasource.entities.Organization;
+import com.jsh.erp.datasource.entities.OrganizationExample;
+import com.jsh.erp.datasource.entities.User;
+import com.jsh.erp.datasource.mappers.OrganizationMapper;
+import com.jsh.erp.datasource.mappers.OrganizationMapperEx;
+import com.jsh.erp.datasource.vo.TreeNode;
+import com.jsh.erp.exception.BusinessRunTimeException;
+import com.jsh.erp.service.user.UserService;
+import com.jsh.erp.utils.StringUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * Description
+ *
+ * @Author: cjl
+ * @Date: 2019/3/6 15:10
+ */
+@Service
+public class OrganizationService {
+    private Logger logger = LoggerFactory.getLogger(OrganizationService.class);
+
+    @Resource
+    private OrganizationMapper organizationMapper;
+    @Resource
+    private OrganizationMapperEx organizationMapperEx;
+    @Resource
+    private UserService userService;
+    @Transactional(value = "transactionManager", rollbackFor = Exception.class)
+    public int insertOrganization(String beanJson, HttpServletRequest request) {
+        Organization organization = JSONObject.parseObject(beanJson, Organization.class);
+        return organizationMapper.insertSelective(organization);
+    }
+    @Transactional(value = "transactionManager", rollbackFor = Exception.class)
+    public int updateOrganization(String beanJson, Long id) {
+        Organization organization = JSONObject.parseObject(beanJson, Organization.class);
+        organization.setId(id);
+        return organizationMapper.updateByPrimaryKeySelective(organization);
+    }
+    @Transactional(value = "transactionManager", rollbackFor = Exception.class)
+    public int deleteOrganization(Long id) {
+        return organizationMapper.deleteByPrimaryKey(id);
+    }
+    @Transactional(value = "transactionManager", rollbackFor = Exception.class)
+    public int batchDeleteOrganization(String ids) {
+        List<Long> idList = StringUtil.strToLongList(ids);
+        OrganizationExample example = new OrganizationExample();
+        example.createCriteria().andIdIn(idList);
+        return organizationMapper.deleteByExample(example);
+    }
+    @Transactional(value = "transactionManager", rollbackFor = Exception.class)
+    public int addOrganization(Organization org) throws Exception{
+        //新增时间
+        Date date=new Date();
+        User userInfo=userService.getCurrentUser();
+        org.setCreateTime(date);
+        //新增人
+        org.setCreator(userInfo==null?null:userInfo.getId());
+        //修改时间
+        org.setUpdateTime(date);
+        //修改人
+        org.setUpdater(userInfo==null?null:userInfo.getId());
+        /**
+         *添加的时候检测机构编号是否已存在
+         * */
+        if(StringUtil.isNotEmpty(org.getOrgNo())){
+            checkOrgNoIsExists(org.getOrgNo(),null);
+        }
+        /**
+         * 未指定父级机构的时候默认放在根机构下
+         * */
+        if(StringUtil.isEmpty(org.getOrgParentNo())){
+            org.setOrgParentNo(BusinessConstants.ORGANIZATION_ROOT_NO);
+        }
+        return organizationMapperEx.addOrganization(org);
+    }
+    @Transactional(value = "transactionManager", rollbackFor = Exception.class)
+    public int editOrganization(Organization org)throws Exception {
+        //修改时间
+        org.setUpdateTime(new Date());
+        User userInfo=userService.getCurrentUser();
+        //修改人
+        org.setUpdater(userInfo==null?null:userInfo.getId());
+        /**
+         * 修改的时候检测机构编号是否已存在
+         * */
+        if(StringUtil.isNotEmpty(org.getOrgNo())){
+            checkOrgNoIsExists(org.getOrgNo(),org.getId());
+        }
+        /**
+         * 未指定父级机构的时候默认放在根机构下
+         * */
+        if(StringUtil.isEmpty(org.getOrgParentNo())){
+            org.setOrgParentNo(BusinessConstants.ORGANIZATION_ROOT_NO);
+        }
+        /**
+         * 添加一个限制，根机构不允许修改
+         * */
+        if(BusinessConstants.ORGANIZATION_ROOT_NO.equals(org.getOrgNo())){
+            logger.error("异常码[{}],异常提示[{}],参数,orgNo[{}]",
+                    ExceptionConstants.ORGANIZATION_ROOT_NOT_ALLOWED_EDIT_CODE,ExceptionConstants.ORGANIZATION_ROOT_NOT_ALLOWED_EDIT_MSG,org.getOrgNo());
+            throw new BusinessRunTimeException(ExceptionConstants.ORGANIZATION_ROOT_NOT_ALLOWED_EDIT_CODE,
+                    ExceptionConstants.ORGANIZATION_ROOT_NOT_ALLOWED_EDIT_MSG);
+        }
+        return organizationMapperEx.editOrganization(org);
+    }
+
+    public List<TreeNode> getOrganizationTree()throws Exception {
+        return organizationMapperEx.getNodeTree();
+    }
+
+    public List<Organization> findById(Long id) throws Exception{
+        OrganizationExample example = new OrganizationExample();
+        example.createCriteria().andIdEqualTo(id);
+        return organizationMapper.selectByExample(example);
+    }
+
+    public List<Organization> findByOrgNo(String orgNo)throws Exception {
+        OrganizationExample example = new OrganizationExample();
+        example.createCriteria().andOrgNoEqualTo(orgNo).andOrgStcdNotEqualTo(BusinessConstants.ORGANIZATION_STCD_REMOVED);
+        return organizationMapper.selectByExample(example);
+    }
+    /**
+     * create by: cjl
+     * description:
+     *  检查机构编号是否已经存在
+     * create time: 2019/3/7 10:01
+     * @Param: orgNo
+     * @return void
+     */
+    public void checkOrgNoIsExists(String orgNo,Long id)throws Exception {
+        List<Organization> orgList=findByOrgNo(orgNo);
+        if(orgList!=null&&orgList.size()>0){
+            if(orgList.size()>1){
+                logger.error("异常码[{}],异常提示[{}],参数,orgNo[{}]",
+                        ExceptionConstants.ORGANIZATION_NO_ALREADY_EXISTS_CODE,ExceptionConstants.ORGANIZATION_NO_ALREADY_EXISTS_MSG,orgNo);
+                //获取的数据条数大于1，机构编号已存在
+                throw new BusinessRunTimeException(ExceptionConstants.ORGANIZATION_NO_ALREADY_EXISTS_CODE,
+                        ExceptionConstants.ORGANIZATION_NO_ALREADY_EXISTS_MSG);
+            }
+            if(id!=null){
+                if(!orgList.get(0).getId().equals(id)){
+                    //数据条数等于1，但是和编辑的数据的id不相同
+                    logger.error("异常码[{}],异常提示[{}],参数,orgNo[{}],id[{}]",
+                            ExceptionConstants.ORGANIZATION_NO_ALREADY_EXISTS_CODE,ExceptionConstants.ORGANIZATION_NO_ALREADY_EXISTS_MSG,orgNo,id);
+                    throw new BusinessRunTimeException(ExceptionConstants.ORGANIZATION_NO_ALREADY_EXISTS_CODE,
+                            ExceptionConstants.ORGANIZATION_NO_ALREADY_EXISTS_MSG);
+                }
+            }else{
+                logger.error("异常码[{}],异常提示[{}],参数,orgNo[{}]",
+                        ExceptionConstants.ORGANIZATION_NO_ALREADY_EXISTS_CODE,ExceptionConstants.ORGANIZATION_NO_ALREADY_EXISTS_MSG,orgNo);
+                //数据条数等于1，但此时是新增
+                throw new BusinessRunTimeException(ExceptionConstants.ORGANIZATION_NO_ALREADY_EXISTS_CODE,
+                        ExceptionConstants.ORGANIZATION_NO_ALREADY_EXISTS_MSG);
+            }
+        }
+
+    }
+    @Transactional(value = "transactionManager", rollbackFor = Exception.class)
+    public int batchDeleteOrganizationByIds(String ids) throws Exception{
+        User userInfo=userService.getCurrentUser();
+        String [] idArray=ids.split(",");
+        /**
+         * 添加一个限制，根机构不允许删除
+         * */
+        List<Organization> orgRootList=organizationMapperEx.getOrganizationRootByIds(idArray);
+        if(orgRootList!=null&&orgRootList.size()>0){
+            logger.error("异常码[{}],异常提示[{}],参数,ids[{}]",
+                    ExceptionConstants.ORGANIZATION_ROOT_NOT_ALLOWED_DELETE_CODE,ExceptionConstants.ORGANIZATION_ROOT_NOT_ALLOWED_DELETE_MSG,ids);
+            throw new BusinessRunTimeException(ExceptionConstants.ORGANIZATION_ROOT_NOT_ALLOWED_DELETE_CODE,
+                    ExceptionConstants.ORGANIZATION_ROOT_NOT_ALLOWED_DELETE_MSG);
+        }
+
+        return organizationMapperEx.batchDeleteOrganizationByIds(new Date(),userInfo==null?null:userInfo.getId(),idArray);
+    }
+}