新增美度正式环境配置

jyy

2021-07-10 ff2531da1476f6fcc3993097c9e852ec4b7ab1c7

 zq-erp/src/main/java/com/matrix/system/common/service/impl/SysCompanyServiceImpl.java

@@ -1,245 +1,250 @@
package com.matrix.system.common.service.impl;

import com.matrix.core.constance.MatrixConstance;
import com.matrix.core.constance.SystemErrorCode;
import com.matrix.core.exception.GlobleException;
import com.matrix.core.pojo.PaginationVO;
import com.matrix.core.tools.ModelUtils;
import com.matrix.core.tools.StringUtils;
import com.matrix.core.tools.WebUtil;
import com.matrix.system.common.bean.*;
import com.matrix.system.common.dao.SysCompanyDao;
import com.matrix.system.common.dao.SysRoleDao;
import com.matrix.system.common.dao.SysRolePwoerFnDao;
import com.matrix.system.common.service.SysCompanyService;
import com.matrix.system.hive.bean.SysShopInfo;
import com.matrix.system.hive.bean.Warehouse;
import com.matrix.system.hive.dao.SysShopInfoDao;
import com.matrix.system.hive.dao.WarehouseDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;

/**
 * 公司管理
 * 
 * @author JIANGYOUYAO
 * @email 935090232@qq.com
 * @date Dec 11, 2017
 */
@Service
public class SysCompanyServiceImpl implements SysCompanyService {

   @Autowired
   private SysCompanyDao sysCompanyDao;
   @Autowired
   private SysRoleDao sysRoleDao;
   @Autowired
   private SysRolePwoerFnDao rolePwoerFnDao;

   @Autowired
   private SysShopInfoDao shopInfoDao;


   @Autowired
   private InitCustomerDataDictionaryService initCustomerDataDictionaryService;


   @Autowired
   private InitShoppingGoodsCategoryService initShoppingGoodsCategoryService;


   @Autowired
   private InitRolePowerService initRolePowerService;

   @Autowired
   private InitGoodsTypeService initGoodsTypeService;

   @Autowired
   private InitShopProductCateService initShopProductCateService;


   @Transactional
   @Override
   public int add(SysCompany sysCompany) {
      SysUsers user = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);
      sysCompany.setCreateBy(user.getSuName());
      sysCompany.setUpdateBy(user.getSuName());
      int i= sysCompanyDao.insert(sysCompany);
      SysShopInfo zbShop=   addZbShop(sysCompany);
      initCustomerDataDictionaryService.initCustomerDataDictionary(sysCompany);
      initShoppingGoodsCategoryService.initShoppingGoodsCategory(sysCompany,zbShop);
      initRolePowerService.initRolePower(sysCompany);
      initGoodsTypeService.initRolePower(sysCompany);
      initShopProductCateService.initShopProductCate(sysCompany);

      return i;

   }


   @Autowired
   private WarehouseDao warehouseDao;
   /**
    * 为新公司创建一个总部
    * @param sysCompany
    */
   private SysShopInfo addZbShop(SysCompany sysCompany) {
      SysShopInfo zbShopInfo=new SysShopInfo();
      zbShopInfo.setShopType(SysShopInfo.SHOP_TYPE_ZONGBU);
      zbShopInfo.setShopName(sysCompany.getComName()+"(总部)");
      zbShopInfo.setCompanyId(sysCompany.getComId());
      zbShopInfo.setShopTel(sysCompany.getComTel());
      zbShopInfo.setShopShortName("总部");
      zbShopInfo.setIsOpenNet(SysShopInfo.CLOSE_NET);
      zbShopInfo.setShopNo(StringUtils.getRandomString(10));
      shopInfoDao.insert(zbShopInfo);

      //新增一个总部仓库
      Warehouse warehouse=new Warehouse();
      warehouse.setCompanyId(sysCompany.getComId());
      warehouse.setName("总部仓库");
      warehouse.setShopId(zbShopInfo.getId());
      warehouse.setSort("1");
      warehouseDao.insert(warehouse);
      return  zbShopInfo;
   }

   @Transactional(rollbackFor = Exception.class)
   @Override
   public int modifyByMap(SysCompany oldSysCompany, SysCompany newSysCompany) {
      SysUsers user = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);
      newSysCompany.setUpdateBy(user.getSuName());

      updatePower(newSysCompany);
      Map<String, Object> modifyMap = null;
      try {
         if (!ModelUtils.isModified(oldSysCompany, newSysCompany)) {
            return MatrixConstance.DML_SUCCESSS;
         }

         modifyMap = ModelUtils.comparePojo2Map(oldSysCompany, newSysCompany);
      } catch (Exception e) {
         throw new GlobleException(SystemErrorCode.DATA_UPDATE_FAIL, e, newSysCompany.getComName());
      }
      if (modifyMap.size() > 0) {
         modifyMap.put("comId", oldSysCompany.getComId());
         return sysCompanyDao.updateByMap(modifyMap);
      }
      return MatrixConstance.DML_SUCCESSS;
   }

   /**
    * 更新公司员工权限
    * 
    * @author JIANGYOUYAO
    * @email 935090232@qq.com
    * @date 2017年12月5日
    * @param newSysCompany
    */
   private void updatePower(SysCompany newSysCompany) {
      List<String> oldFunctions = null;
      String functions = sysCompanyDao.selectById(newSysCompany.getComId()).getComFunctions();
      if (functions == null || functions.equals("")) {
         oldFunctions = new ArrayList<>();
      } else {
         oldFunctions = StringUtils
               .strToCollToString(sysCompanyDao.selectById(newSysCompany.getComId()).getComFunctions(), ",");
      }
      List<String> newFunctions = new ArrayList<>();
      if (StringUtils.isNotBlank(newSysCompany.getComFunctions())) {
         newFunctions = StringUtils.strToCollToString(newSysCompany.getComFunctions(), ",");
      }

      for (String old : oldFunctions) {
         // 如果新权限中不包含这个老的功能，则要更新改企业下所有的角色权限
         if (!newFunctions.contains(old)) {
            SysRole role = new SysRole();
            role.setCompanyId(newSysCompany.getComId());
            List<SysRole> roles = sysRoleDao.selectByModel(role);
            // 获取该公司下所有的权限信息
            List<SysRolePwoerFn> compalyRolePwoer = new ArrayList<>();
            for (SysRole tempRole : roles) {
               SysRolePwoerFn r = new SysRolePwoerFn();
               r.setRoleId(tempRole.getRoleId());
               compalyRolePwoer.addAll(rolePwoerFnDao.selectByModel(r));
            }
            // 记录要删除的id
            List<String> delRolePwoer = new ArrayList<>();
            for (SysRolePwoerFn rolePwoer : compalyRolePwoer) {
               // 如果有一个老权限则删除这个权限
               if (rolePwoer.getFnId() != null && rolePwoer.getFnId().equals(old)) {
                  delRolePwoer.add(rolePwoer.getRpfId()+"");
               }
            }
            // 如果获取到了就删除
            if (!delRolePwoer.isEmpty()) {
               rolePwoerFnDao.deleteByIds(delRolePwoer);
            }
         }
      }
   }

   @Override
   public int modifyByModel(SysCompany sysCompany) {

      return sysCompanyDao.updateByModel(sysCompany);

   }

   @Override
   public int remove(List<String> list) {

      return sysCompanyDao.deleteByIds(list);

   }

   @Override
   public int removeById(String comId) {

      return sysCompanyDao.deleteById(Long.parseLong(comId));

   }

   @Override
   public int removeByModel(SysCompany sysCompany) {

      return sysCompanyDao.deleteByModel(sysCompany);

   }

   @Override
   public List<SysCompany> findInPage(SysCompany sysCompany, PaginationVO pageVo) {

      return sysCompanyDao.selectInPage(sysCompany, pageVo);

   }

   @Override
   public List<SysCompany> findByModel(SysCompany sysCompany) {

      return sysCompanyDao.selectByModel(sysCompany);

   }

   @Override
   public int findTotal(SysCompany sysCompany) {

      return sysCompanyDao.selectTotalRecord(sysCompany);

   }

   @Override
   public SysCompany findById(String comId) {

      return sysCompanyDao.selectById(Long.parseLong(comId));

   }



package com.matrix.system.common.service.impl;



import com.matrix.core.constance.MatrixConstance;

import com.matrix.core.constance.SystemErrorCode;

import com.matrix.core.exception.GlobleException;

import com.matrix.core.pojo.PaginationVO;

import com.matrix.core.tools.ModelUtils;

import com.matrix.core.tools.StringUtils;

import com.matrix.core.tools.WebUtil;

import com.matrix.system.common.bean.*;

import com.matrix.system.common.dao.SysCompanyDao;

import com.matrix.system.common.dao.SysRoleDao;

import com.matrix.system.common.dao.SysRolePwoerFnDao;

import com.matrix.system.common.service.SysCompanyService;

import com.matrix.system.hive.bean.SysShopInfo;

import com.matrix.system.hive.bean.Warehouse;

import com.matrix.system.hive.dao.SysShopInfoDao;

import com.matrix.system.hive.dao.WarehouseDao;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;



import java.util.ArrayList;

import java.util.List;

import java.util.Map;



/**

 * 公司管理

 * 
 * @author JIANGYOUYAO

 * @email 935090232@qq.com

 * @date Dec 11, 2017

 */

@Service

public class SysCompanyServiceImpl implements SysCompanyService {



   @Autowired

   private SysCompanyDao sysCompanyDao;

   @Autowired

   private SysRoleDao sysRoleDao;

   @Autowired

   private SysRolePwoerFnDao rolePwoerFnDao;



   @Autowired

   private SysShopInfoDao shopInfoDao;





   @Autowired

   private InitCustomerDataDictionaryService initCustomerDataDictionaryService;





   @Autowired

   private InitShoppingGoodsCategoryService initShoppingGoodsCategoryService;





   @Autowired

   private InitRolePowerService initRolePowerService;



   @Autowired

   private InitGoodsTypeService initGoodsTypeService;



   @Autowired

   private InitShopProductCateService initShopProductCateService;



   @Autowired

   private InitBusParameterSettingService initBusParameterSettingService;





   @Transactional

   @Override

   public int add(SysCompany sysCompany) {

      SysUsers user = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);

      sysCompany.setCreateBy(user.getSuName());

      sysCompany.setUpdateBy(user.getSuName());

      int i= sysCompanyDao.insert(sysCompany);

      SysShopInfo zbShop=   addZbShop(sysCompany);

      initCustomerDataDictionaryService.initCustomerDataDictionary(sysCompany);

      initShoppingGoodsCategoryService.initShoppingGoodsCategory(sysCompany,zbShop);

      initRolePowerService.initRolePower(sysCompany);

      initGoodsTypeService.initRolePower(sysCompany);

      initShopProductCateService.initShopProductCate(sysCompany);

      initBusParameterSettingService.initBusParameterSetting(sysCompany);

      initBusParameterSettingService.initBusParameterFenxiaoSetting(sysCompany);



      return i;



   }





   @Autowired

   private WarehouseDao warehouseDao;

   /**

    * 为新公司创建一个总部

    * @param sysCompany

    */

   private SysShopInfo addZbShop(SysCompany sysCompany) {

      SysShopInfo zbShopInfo=new SysShopInfo();

      zbShopInfo.setShopType(SysShopInfo.SHOP_TYPE_ZONGBU);

      zbShopInfo.setShopName(sysCompany.getComName()+"(总部)");

      zbShopInfo.setCompanyId(sysCompany.getComId());

      zbShopInfo.setShopTel(sysCompany.getComTel());

      zbShopInfo.setShopShortName("总部");

      zbShopInfo.setIsOpenNet(SysShopInfo.CLOSE_NET);

      zbShopInfo.setShopNo(StringUtils.getRandomString(10));

      shopInfoDao.insert(zbShopInfo);



      //新增一个总部仓库

      Warehouse warehouse=new Warehouse();

      warehouse.setCompanyId(sysCompany.getComId());

      warehouse.setName("总部仓库");

      warehouse.setShopId(zbShopInfo.getId());

      warehouse.setSort("1");

      warehouseDao.insert(warehouse);

      return  zbShopInfo;

   }



   @Transactional(rollbackFor = Exception.class)

   @Override

   public int modifyByMap(SysCompany oldSysCompany, SysCompany newSysCompany) {

      SysUsers user = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);

      newSysCompany.setUpdateBy(user.getSuName());



      updatePower(newSysCompany);

      Map<String, Object> modifyMap = null;

      try {

         if (!ModelUtils.isModified(oldSysCompany, newSysCompany)) {

            return MatrixConstance.DML_SUCCESSS;

         }



         modifyMap = ModelUtils.comparePojo2Map(oldSysCompany, newSysCompany);

      } catch (Exception e) {

         throw new GlobleException(SystemErrorCode.DATA_UPDATE_FAIL, e, newSysCompany.getComName());

      }

      if (modifyMap.size() > 0) {

         modifyMap.put("comId", oldSysCompany.getComId());

         return sysCompanyDao.updateByMap(modifyMap);

      }

      return MatrixConstance.DML_SUCCESSS;

   }



   /**

    * 更新公司员工权限

    * 
    * @author JIANGYOUYAO

    * @email 935090232@qq.com

    * @date 2017年12月5日

    * @param newSysCompany

    */

   private void updatePower(SysCompany newSysCompany) {

      List<String> oldFunctions = null;

      String functions = sysCompanyDao.selectById(newSysCompany.getComId()).getComFunctions();

      if (functions == null || functions.equals("")) {

         oldFunctions = new ArrayList<>();

      } else {

         oldFunctions = StringUtils

               .strToCollToString(sysCompanyDao.selectById(newSysCompany.getComId()).getComFunctions(), ",");

      }

      List<String> newFunctions = new ArrayList<>();

      if (StringUtils.isNotBlank(newSysCompany.getComFunctions())) {

         newFunctions = StringUtils.strToCollToString(newSysCompany.getComFunctions(), ",");

      }



      for (String old : oldFunctions) {

         // 如果新权限中不包含这个老的功能，则要更新改企业下所有的角色权限

         if (!newFunctions.contains(old)) {

            SysRole role = new SysRole();

            role.setCompanyId(newSysCompany.getComId());

            List<SysRole> roles = sysRoleDao.selectByModel(role);

            // 获取该公司下所有的权限信息

            List<SysRolePwoerFn> compalyRolePwoer = new ArrayList<>();

            for (SysRole tempRole : roles) {

               SysRolePwoerFn r = new SysRolePwoerFn();

               r.setRoleId(tempRole.getRoleId());

               compalyRolePwoer.addAll(rolePwoerFnDao.selectByModel(r));

            }

            // 记录要删除的id

            List<String> delRolePwoer = new ArrayList<>();

            for (SysRolePwoerFn rolePwoer : compalyRolePwoer) {

               // 如果有一个老权限则删除这个权限

               if (rolePwoer.getFnId() != null && rolePwoer.getFnId().equals(old)) {

                  delRolePwoer.add(rolePwoer.getRpfId()+"");

               }

            }

            // 如果获取到了就删除

            if (!delRolePwoer.isEmpty()) {

               rolePwoerFnDao.deleteByIds(delRolePwoer);

            }

         }

      }

   }



   @Override

   public int modifyByModel(SysCompany sysCompany) {



      return sysCompanyDao.updateByModel(sysCompany);



   }



   @Override

   public int remove(List<String> list) {



      return sysCompanyDao.deleteByIds(list);



   }



   @Override

   public int removeById(String comId) {



      return sysCompanyDao.deleteById(Long.parseLong(comId));



   }



   @Override

   public int removeByModel(SysCompany sysCompany) {



      return sysCompanyDao.deleteByModel(sysCompany);



   }



   @Override

   public List<SysCompany> findInPage(SysCompany sysCompany, PaginationVO pageVo) {



      return sysCompanyDao.selectInPage(sysCompany, pageVo);



   }



   @Override

   public List<SysCompany> findByModel(SysCompany sysCompany) {



      return sysCompanyDao.selectByModel(sysCompany);



   }



   @Override

   public int findTotal(SysCompany sysCompany) {



      return sysCompanyDao.selectTotalRecord(sysCompany);



   }



   @Override

   public SysCompany findById(String comId) {



      return sysCompanyDao.selectById(Long.parseLong(comId));



   }







}