package com.doumee.service.business.impl;
|
|
import com.doumee.core.annotation.excel.ExcelImporter;
|
import com.doumee.core.constants.ResponseStatus;
|
import com.doumee.core.exception.BusinessException;
|
import com.doumee.core.model.LoginUserInfo;
|
import com.doumee.core.model.PageData;
|
import com.doumee.core.model.PageWrap;
|
import com.doumee.core.utils.Constants;
|
import com.doumee.core.utils.Utils;
|
import com.doumee.dao.business.CmmDataMapper;
|
import com.doumee.dao.business.CmmMapper;
|
import com.doumee.dao.business.model.*;
|
import com.doumee.dao.business.vo.bs.*;
|
import com.doumee.service.business.AreasService;
|
import com.doumee.service.business.CmmService;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.shiro.SecurityUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.CollectionUtils;
|
import org.springframework.web.multipart.MultipartFile;
|
|
import java.lang.reflect.Field;
|
import java.math.BigDecimal;
|
import java.math.RoundingMode;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.UUID;
|
|
/**
|
* 企业能力成熟度数据信息Service实现
|
* @author 江蹄蹄
|
* @date 2023/10/24 15:57
|
*/
|
@Service
|
public class CmmServiceImpl implements CmmService {
|
|
@Autowired
|
private CmmMapper cmmMapper;
|
@Autowired
|
private AreasService areasService;
|
@Autowired
|
private CmmDataMapper cmmDataMapper;
|
|
@Override
|
public String create(Cmm cmm) {
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
if(StringUtils.isBlank(cmm.getAreaname())
|
||StringUtils.isBlank(cmm.getDiagnoseType())
|
||StringUtils.isBlank(cmm.getName())
|
||StringUtils.isBlank(cmm.getData8())//总得分
|
||StringUtils.isBlank(cmm.getLevel()) //成熟度等级
|
|| cmm.getRevenue() == null
|
||StringUtils.isBlank(cmm.getIndustry())){
|
}
|
Cmm m = new Cmm();
|
m.setIsdeleted(Constants.ZERO);
|
m.setName(cmm.getName());
|
if(findOne(m) != null){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起， 企业名称重复！");
|
}
|
cmm.setId(UUID.randomUUID().toString());
|
cmm.setIsdeleted(Constants.ZERO);
|
cmm.setEditor(user.getId());
|
cmm.setEditDate(new Date());
|
cmm.setCreator(cmm.getEditor());
|
cmm.setCreateDate(cmm.getEditDate());
|
cmmMapper.insert(cmm);
|
List<CmmData> cmmDataList = initDataModelByParam(cmm);
|
if(cmmDataList!=null && cmmDataList.size()>0){
|
cmmMapper.insertDataBatch(cmmDataList);
|
}
|
return cmm.getId();
|
}
|
|
@Override
|
public void deleteById(String id) {
|
cmmMapper.deleteById(id);
|
}
|
|
@Override
|
public void delete(Cmm cmm) {
|
UpdateWrapper<Cmm> deleteWrapper = new UpdateWrapper<>(cmm);
|
cmmMapper.delete(deleteWrapper);
|
}
|
|
@Override
|
public void deleteByIdInBatch(List<String> ids) {
|
if (CollectionUtils.isEmpty(ids)) {
|
return;
|
}
|
cmmMapper.deleteBatchIds(ids);
|
}
|
|
@Override
|
public void updateById(Cmm cmm) {
|
if(StringUtils.isBlank(cmm.getAreaname())
|
||StringUtils.isBlank(cmm.getId())
|
||StringUtils.isBlank(cmm.getDiagnoseType())
|
||StringUtils.isBlank(cmm.getName())
|
||StringUtils.isBlank(cmm.getData8())//总得分
|
||StringUtils.isBlank(cmm.getLevel()) //成熟度等级
|
|| cmm.getRevenue() == null
|
||StringUtils.isBlank(cmm.getIndustry())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起， 数据不完整，请检查确认修改后重试！");
|
}
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
Cmm model = cmmMapper.selectById(cmm.getId());
|
if(model == null){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
if(cmm.getAreaId()!=null){
|
Areas areas = areasService.findById(cmm.getAreaId(), Constants.TWO);
|
if(areas == null){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起， 区域信息不存在！");
|
}
|
cmm.setAreaname(areas.getName());
|
}
|
cmm.setIsdeleted(Constants.ZERO);
|
cmm.setEditor(user.getId());
|
cmm.setEditDate(new Date());
|
cmm.setCreator(cmm.getEditor());
|
cmm.setCreateDate(cmm.getEditDate());
|
// cmmMapper.updateById(cmm);
|
|
List<CmmData> cmmDataList = initDataModelByParam(cmm);
|
UpdateWrapper<CmmData> updateWrapper = new UpdateWrapper<>();
|
updateWrapper.lambda().eq(CmmData::getCmmId, cmm.getId());
|
cmmDataMapper.delete(updateWrapper);
|
if(cmmDataList!=null && cmmDataList.size()>0){
|
cmmMapper.insertDataBatch(cmmDataList);
|
}
|
|
cmmMapper.updateById(cmm);
|
}
|
|
@Override
|
public void updateByIdInBatch(List<Cmm> cmms) {
|
if (CollectionUtils.isEmpty(cmms)) {
|
return;
|
}
|
for (Cmm cmm: cmms) {
|
this.updateById(cmm);
|
}
|
}
|
|
@Override
|
public Cmm findById(String id) {
|
Cmm model =cmmMapper.selectById(id);
|
if(model!=null){
|
model.setRevenueStr(Constants.formatBigdecimal(model.getRevenue()).intValue()+"");
|
initCmmModelByData(model );
|
if(model.getAreaId() != null){
|
Areas area = areasService.findById(model.getAreaId(),Constants.TWO);
|
if(area!=null){
|
model.setCityName(area.getCityName());
|
model.setCityId(area.getCityId());
|
}
|
}
|
}
|
return model;
|
}
|
|
@Override
|
public Cmm findOne(Cmm cmm) {
|
QueryWrapper<Cmm> wrapper = new QueryWrapper<>(cmm);
|
return cmmMapper.selectOne(wrapper.last(" limit 1"));
|
}
|
|
@Override
|
public List<Cmm> findList(Cmm cmm) {
|
QueryWrapper<Cmm> wrapper = new QueryWrapper<>(cmm);
|
return cmmMapper.selectList(wrapper);
|
}
|
|
@Override
|
public PageData<Cmm> findPage(PageWrap<Cmm> pageWrap) {
|
IPage<Cmm> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
|
QueryWrapper<Cmm> queryWrapper = new QueryWrapper<>();
|
Utils.MP.blankToNull(pageWrap.getModel());
|
if (pageWrap.getModel().getId() != null) {
|
queryWrapper.lambda().eq(Cmm::getId, pageWrap.getModel().getId());
|
}
|
if (pageWrap.getModel().getCreator() != null) {
|
queryWrapper.lambda().eq(Cmm::getCreator, pageWrap.getModel().getCreator());
|
}
|
if (pageWrap.getModel().getCreateDate() != null) {
|
queryWrapper.lambda().ge(Cmm::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate()));
|
queryWrapper.lambda().le(Cmm::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate()));
|
}
|
if (pageWrap.getModel().getEditor() != null) {
|
queryWrapper.lambda().eq(Cmm::getEditor, pageWrap.getModel().getEditor());
|
}
|
if (pageWrap.getModel().getEditDate() != null) {
|
queryWrapper.lambda().ge(Cmm::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate()));
|
queryWrapper.lambda().le(Cmm::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate()));
|
}
|
if (pageWrap.getModel().getIsdeleted() != null) {
|
queryWrapper.lambda().eq(Cmm::getIsdeleted, pageWrap.getModel().getIsdeleted());
|
}
|
if (pageWrap.getModel().getRemark() != null) {
|
queryWrapper.lambda().eq(Cmm::getRemark, pageWrap.getModel().getRemark());
|
}
|
if (pageWrap.getModel().getName() != null) {
|
queryWrapper.lambda().like(Cmm::getName, pageWrap.getModel().getName());
|
}
|
if (pageWrap.getModel().getServeOrg() != null) {
|
queryWrapper.lambda().eq(Cmm::getServeOrg, pageWrap.getModel().getServeOrg());
|
}
|
if (pageWrap.getModel().getIndustry() != null) {
|
queryWrapper.lambda().eq(Cmm::getIndustry, pageWrap.getModel().getIndustry());
|
}
|
if (pageWrap.getModel().getAreaId() != null) {
|
queryWrapper.lambda().eq(Cmm::getAreaId, pageWrap.getModel().getAreaId());
|
}
|
if (pageWrap.getModel().getAreaname() != null) {
|
queryWrapper.lambda().eq(Cmm::getAreaname, pageWrap.getModel().getAreaname());
|
}
|
if (pageWrap.getModel().getRevenue() != null) {
|
queryWrapper.lambda().eq(Cmm::getRevenue, pageWrap.getModel().getRevenue());
|
}
|
if (pageWrap.getModel().getDiagnoseType() != null) {
|
queryWrapper.lambda().eq(Cmm::getDiagnoseType, pageWrap.getModel().getDiagnoseType());
|
}
|
if (pageWrap.getModel().getLevel() != null) {
|
queryWrapper.lambda().eq(Cmm::getLevel, pageWrap.getModel().getLevel());
|
}
|
for(PageWrap.SortData sortData: pageWrap.getSorts()) {
|
if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
|
queryWrapper.orderByDesc(sortData.getProperty());
|
} else {
|
queryWrapper.orderByAsc(sortData.getProperty());
|
}
|
}
|
queryWrapper.lambda().orderByDesc(Cmm::getCreateDate);
|
queryWrapper.lambda().orderByAsc(Cmm::getRemark);
|
IPage<Cmm> result = cmmMapper.selectPage(page, queryWrapper);
|
if(result.getRecords()!=null ){
|
int num =1;
|
for(Cmm model : result.getRecords()){
|
model.setRevenueStr(Constants.formatBigdecimal(model.getRevenue()).intValue()+"");
|
model.setRemark(num+"");
|
initCmmModelByData(model );
|
|
if(model.getAreaId() != null){
|
Areas area = areasService.findById(model.getAreaId(),Constants.TWO);
|
if(area!=null){
|
model.setCityName(area.getCityName());
|
model.setCityId(area.getCityId());
|
}
|
}
|
num++;
|
}
|
}
|
return PageData.from(result);
|
}
|
|
private void initCmmModelByData(Cmm model ) {
|
//查询数据行数据信息
|
CmmData d = new CmmData();
|
d.setIsdeleted(Constants.ZERO);
|
d.setCmmId(model.getId());
|
List<CmmData> dataList = cmmDataMapper.selectList(new QueryWrapper<>(d));
|
if(dataList!=null){
|
for(CmmData data : dataList){
|
try {
|
Field field = model.getClass().getDeclaredField("data"+data.getType());
|
if(field!=null){
|
field.setAccessible(true);
|
field.set(model,Constants.formatBigdecimal(data.getVal()).doubleValue()+"");
|
}
|
} catch (Exception e) {
|
throw new RuntimeException(e);
|
}
|
|
}
|
}
|
}
|
|
@Override
|
public CmmNumVo levelCount(Cmm cmm) {
|
CmmNumVo result = new CmmNumVo();
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
validUserType(user);
|
if(Constants.formatIntegerNum(user.getType()) == Constants.UserType.AREA.getKey()){
|
//如果是县区用户，只能查看当前县区下的数据
|
if(user.getAreaId() == null){
|
return result;
|
}
|
cmm.setAreaId(user.getAreaId());
|
}
|
QueryWrapper<Cmm> wrapper = new QueryWrapper<>(cmm);
|
wrapper.select("level as level,count(id) as num");
|
wrapper.lambda().eq(cmm.getAreaId() != null, Cmm::getAreaId, cmm.getAreaId());
|
wrapper.lambda().eq(cmm.getIndustry() != null, Cmm::getIndustry, cmm.getIndustry());
|
wrapper.lambda().eq( Cmm::getIsdeleted, Constants.ZERO);
|
wrapper.lambda().groupBy(Cmm::getLevel);
|
List<Cmm> list= cmmMapper.selectList(wrapper);
|
if(list !=null){
|
for(Cmm m : list){
|
result.setCompanyNum(result.getCompanyNum()+ Constants.formatIntegerNum(m.getNum()));
|
if(StringUtils.equals(m.getLevel(), "一级")){
|
result.setOneNum(result.getOneNum()+ Constants.formatIntegerNum(m.getNum()));
|
}else if(StringUtils.equals(m.getLevel(), "二级")){
|
result.setTwoNum(result.getTwoNum()+ Constants.formatIntegerNum(m.getNum()));
|
}else if(StringUtils.equals(m.getLevel(), "三级")){
|
result.setThreeNum(result.getThreeNum()+ Constants.formatIntegerNum(m.getNum()));
|
}else if(StringUtils.equals(m.getLevel(), "四级")){
|
result.setFourNum(result.getFourNum()+ Constants.formatIntegerNum(m.getNum()));
|
}else{//未达标
|
result.setZeroNum(result.getZeroNum()+ Constants.formatIntegerNum(m.getNum()));
|
}
|
}
|
}
|
return result;
|
}
|
@Override
|
public List<CmmIndustryVo> industryDataCount(Cmm cmm){
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
validUserType(user);
|
if(Constants.formatIntegerNum(user.getType()) == Constants.UserType.AREA.getKey()){
|
//如果是县区用户，只能查看当前县区下的数据
|
if(user.getAreaId() == null){
|
return new ArrayList<>();
|
}
|
cmm.setAreaId(user.getAreaId());
|
}
|
if(cmm.getType() == null || cmm.getType()<0 || cmm.getType()>8){
|
cmm.setType(8);//默认总得分
|
}
|
List<CmmIndustryVo> result= cmmMapper.industryDataCount(cmm);
|
if(result !=null){
|
for (CmmIndustryVo m : result){
|
cmm.setIndustry(m.getIndustry());
|
m.setLevel(levelCount(cmm));
|
}
|
}
|
return result;
|
}
|
@Override
|
public List<CmmAreaVo> areasDataCount(Cmm cmm) {
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
if (!(Constants.formatIntegerNum(user.getType()) == Constants.UserType.SJ.getKey()
|
||Constants.formatIntegerNum(user.getType()) == Constants.UserType.SD_ADMIN.getKey()
|
||Constants.formatIntegerNum(user.getType()) == Constants.UserType.SD_CHILD.getKey()
|
||Constants.formatIntegerNum(user.getType()) == Constants.UserType.SYSTEM.getKey()
|
||Constants.formatIntegerNum(user.getType()) == Constants.UserType.SJ_CHILD.getKey()
|
)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED);
|
}
|
|
List<CmmAreaVo> result= cmmMapper.dataCountByAreas(cmm);
|
return result;
|
}
|
@Override
|
public List<CmmAreaLevelVo> areasLevelDataCount(Cmm cmm) {
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
if (!(Constants.formatIntegerNum(user.getType()) == Constants.UserType.SJ.getKey()
|
||Constants.formatIntegerNum(user.getType()) == Constants.UserType.SD_ADMIN.getKey()
|
||Constants.formatIntegerNum(user.getType()) == Constants.UserType.SD_CHILD.getKey()
|
||Constants.formatIntegerNum(user.getType()) == Constants.UserType.SJ_CHILD.getKey()
|
||Constants.formatIntegerNum(user.getType()) == Constants.UserType.SYSTEM.getKey()
|
)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED);
|
}
|
|
List<Cmm> list= cmmMapper.dataCountByAreasLevel(cmm);
|
List<CmmAreaLevelVo> result = new ArrayList<>();
|
if(list!=null){
|
for(Cmm model: list ){
|
CmmAreaLevelVo t = getFromListByAreaId(model.getAreaId(),result);
|
if(t == null){
|
//如果没加入过
|
t = new CmmAreaLevelVo();
|
t.setAreaId(model.getAreaId());
|
t.setAreaname(model.getAreaname());
|
for(Cmm mm: list ){
|
//先统计企业总数量
|
if(Constants.formatIntegerNum(t.getAreaId()) ==Constants.formatIntegerNum(mm.getAreaId())){
|
t.setCompanyNum(t.getCompanyNum()+Constants.formatIntegerNum(mm.getNum()));
|
}
|
}
|
|
t.setLevel(initAreaLevelModel(t.getAreaId(),t.getCompanyNum(),list));
|
result.add(t);
|
}
|
}
|
}
|
return result;
|
}
|
|
private CmmRateVo initAreaLevelModel(Integer areaId,int total,List<Cmm> list) {
|
|
|
CmmRateVo result = new CmmRateVo();
|
result.setOneRate(new BigDecimal(0.00));
|
result.setTwoRate(new BigDecimal(0.00));
|
result.setThreeRate(new BigDecimal(0.00));
|
result.setFourRate(new BigDecimal(0.00));
|
result.setZeroRate(new BigDecimal(0.00));
|
if(total > 0){
|
for(Cmm m: list ){
|
//再次循环获取各个等级的数据
|
if(Constants.formatIntegerNum(areaId) == Constants.formatIntegerNum(m.getAreaId())){
|
if(StringUtils.equals(m.getLevel(), "一级")){
|
result.setOneRate(new BigDecimal(Constants.formatIntegerNum(m.getNum())).multiply(new BigDecimal(100)).divide(new BigDecimal(total), 2, RoundingMode.FLOOR) );
|
}else if(StringUtils.equals(m.getLevel(), "二级")){
|
result.setTwoRate(new BigDecimal(Constants.formatIntegerNum(m.getNum())).multiply(new BigDecimal(100)).divide(new BigDecimal(total), 2, RoundingMode.FLOOR) );
|
}else if(StringUtils.equals(m.getLevel(), "三级")){
|
result.setThreeRate(new BigDecimal(Constants.formatIntegerNum(m.getNum())).multiply(new BigDecimal(100)).divide(new BigDecimal(total), 2, RoundingMode.FLOOR) );
|
}else if(StringUtils.equals(m.getLevel(), "四级")){
|
result.setFourRate(new BigDecimal(Constants.formatIntegerNum(m.getNum())).multiply(new BigDecimal(100)).divide(new BigDecimal(total), 2, RoundingMode.FLOOR) );
|
}else{//未达标
|
result.setZeroRate(new BigDecimal(Constants.formatIntegerNum(m.getNum())).multiply(new BigDecimal(100)).divide(new BigDecimal(total), 2, RoundingMode.FLOOR) );
|
}
|
}
|
}
|
|
}
|
return result;
|
}
|
|
private CmmAreaLevelVo getFromListByAreaId(Integer areaId, List<CmmAreaLevelVo> result ) {
|
if(result !=null){
|
for(CmmAreaLevelVo model :result){
|
if(Constants.formatIntegerNum(areaId) ==Constants.formatIntegerNum(model.getAreaId())){
|
|
return model;
|
}
|
}
|
}
|
return null;
|
}
|
|
@Override
|
public List<CmmAreaVo> parentAreaCount(Cmm cmm) {
|
List<CmmAreaVo> result =getAreaCountList(0,7,cmm);
|
return result;
|
}
|
@Override
|
public List<CmmAreaVo> industryAreaDataCount(Cmm cmm) {
|
if(cmm.getIndustryList() == null || cmm.getIndustryList().size()==0){
|
//行业数据不能为空
|
return new ArrayList<>();
|
}
|
List<CmmAreaVo> result =getAreaCountList(0,7,cmm);
|
return result;
|
}
|
|
@Override
|
public List<BigDecimal> industryNdDataCount(Cmm cmm) {
|
if(cmm.getIndustryList() == null || cmm.getIndustryList().size()==0){
|
//行业数据不能为空
|
return new ArrayList<>();
|
}
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
validUserType(user);
|
if(Constants.formatIntegerNum(user.getType()) == Constants.UserType.AREA.getKey()){
|
//如果是县区用户，只能查看当前县区下的数据
|
if(user.getAreaId() == null){
|
return new ArrayList<>();
|
}
|
cmm.setAreaId(user.getAreaId());
|
}
|
if(cmm.getType() == null || cmm.getType()<0 || cmm.getType()>8){
|
cmm.setType(8);//默认总得分
|
}
|
List<BigDecimal> result= cmmMapper.selectScoreByType(cmm);
|
return result;
|
}
|
@Override
|
public List<BigDecimal> ndDataCount(Cmm cmm) {
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
validUserType(user);
|
if(Constants.formatIntegerNum(user.getType()) == Constants.UserType.AREA.getKey()){
|
//如果是县区用户，只能查看当前县区下的数据
|
if(user.getAreaId() == null){
|
return new ArrayList<>();
|
}
|
cmm.setAreaId(user.getAreaId());
|
}
|
if(cmm.getType() == null || cmm.getType()<0 || cmm.getType()>8){
|
cmm.setType(8);//默认总得分
|
}
|
List<BigDecimal> result= cmmMapper.selectScoreByType(cmm);
|
return result;
|
}
|
@Override
|
public List<CmmAreaVo> childAreaCount(Cmm cmm) {
|
|
List<CmmAreaVo> result =getAreaCountList(9,28,cmm);
|
return result;
|
}
|
|
private List<CmmAreaVo> getAreaCountList(int start, int end, Cmm cmm) {
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
validUserType(user);
|
if(Constants.formatIntegerNum(user.getType()) == Constants.UserType.AREA.getKey()){
|
//如果是县区用户，只能查看当前县区下的数据
|
if(user.getAreaId() == null){
|
return new ArrayList<>();
|
}
|
cmm.setAreaId(user.getAreaId());
|
}
|
cmm.setTypeList(new ArrayList<>());
|
// 0人员 1技术 2资源 3设计4生产 5物流 6销售 7服务
|
for(int i=start;i<=end;i++){
|
cmm.getTypeList().add(i);
|
}
|
List<CmmAreaVo> list= cmmMapper.areaDataCount(cmm);
|
List<CmmAreaVo> result = new ArrayList<>();
|
for(int i=start;i<=end;i++){
|
CmmAreaVo t = getFromListByType(i,list);
|
if(t ==null){
|
t = new CmmAreaVo();
|
}
|
t.setLabelName(getLableNameByType(i));
|
t.setAvgScore(Constants.formatBigdecimal(t.getAvgScore()));
|
t.setMaxScore(Constants.formatBigdecimal(t.getMaxScore()));
|
t.setMinScore(Constants.formatBigdecimal(t.getMinScore()));
|
result.add(t);
|
}
|
|
return result;
|
}
|
|
|
private CmmAreaVo getFromListByType(int i, List<CmmAreaVo> list) {
|
if(list!=null){
|
for(CmmAreaVo model :list){
|
if(i == Constants.formatIntegerNum(model.getType())){
|
return model;
|
}
|
}
|
}
|
return null;
|
}
|
|
/**
|
* '数据类型 0人员 1技术 2资源 3设计4生产 5物流 6销售 7服务 8总得分 9组织战略 10人员技能 11数据 12集成 14信息安全
|
* 14装备 15网络 16产品设计 17工艺设计 18采购 19计划与调度 20生产作业 21设备管理 22安全与环保 23仓储与配送 24能源管理
|
* 25物流(子域) 26销售(子域) 27客户服务 28产品服务 ',
|
* @param type
|
* @return
|
*/
|
public static String getLableNameByType(int type){
|
String[] lables = new String[]{"人员","技术","资源","设计","生产","物流","销售","服务","总得分","组织战略","人员技能","数据","集成","信息安全",
|
"装备","网络","产品设计","工艺设计","采购","计划与调度","生产作业","设备管理","安全与环保","仓储与配送","能源管理","物流","销售","客户服务","产品服务"};
|
if(type < lables.length){
|
return lables[type];
|
}
|
return null;
|
}
|
private void validUserType(LoginUserInfo user) {
|
if (!(Constants.formatIntegerNum(user.getType()) == Constants.UserType.AREA.getKey()
|
||Constants.formatIntegerNum(user.getType()) == Constants.UserType.SJ.getKey()
|
||Constants.formatIntegerNum(user.getType()) == Constants.UserType.SD_ADMIN.getKey()
|
||Constants.formatIntegerNum(user.getType()) == Constants.UserType.SJ_CHILD.getKey()
|
||Constants.formatIntegerNum(user.getType()) == Constants.UserType.SD_CHILD.getKey()
|
||Constants.formatIntegerNum(user.getType()) == Constants.UserType.SYSTEM.getKey()
|
)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED);
|
}
|
}
|
|
@Override
|
public long count(Cmm cmm) {
|
QueryWrapper<Cmm> wrapper = new QueryWrapper<>(cmm);
|
return cmmMapper.selectCount(wrapper);
|
}
|
|
@Transactional(rollbackFor = {Exception.class, BusinessException.class})
|
@Override
|
public Integer importBatch(MultipartFile file){
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
ExcelImporter ie = null;
|
List<Cmm> dataList =null;
|
try {
|
ie = new ExcelImporter(file,2,0);
|
dataList = ie.getDataList(Cmm.class,null);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
if(dataList == null || dataList.size() ==0){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，录入数据为空！");
|
}
|
List<Cmm> addList = new ArrayList<>();
|
List<String> updateIdList = new ArrayList<>();
|
List<Cmm> updateList = new ArrayList<>();
|
List<CmmData> cmmDataList = new ArrayList<>();
|
for(int i=0;i<dataList.size();i++){
|
Cmm cmm = dataList.get(i);
|
if(StringUtils.isBlank(cmm.getAreaname())
|
||StringUtils.isBlank(cmm.getDiagnoseType())
|
||StringUtils.isBlank(cmm.getName())
|
||StringUtils.isBlank(cmm.getData8())//总得分
|
||StringUtils.isBlank(cmm.getLevel()) //成熟度等级
|
||StringUtils.isBlank(cmm.getRevenueStr())
|
||StringUtils.isBlank(cmm.getIndustry())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，第【"+(i+4)+"】行数据不完整，请检查确认修改后重试！");
|
}
|
BigDecimal val = getDecimalByStr(cmm.getRevenueStr());
|
if(val == null){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，第【"+(i+4)+"】行数据【"+cmm.getRevenueStr()+"】不正确，请检查确认修改后重试！");
|
}
|
//营业收入
|
cmm.setRevenue(val);
|
Integer cityId = 340200;//匹配芜湖市
|
Areas areas = areasService.findByNameAndParentId(cmm.getAreaname(), Constants.TWO,cityId);
|
if(areas ==null){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，第【"+(i+4)+"】行区域【"+cmm.getAreaname()+"】不存在，请检查确认修改后重试！");
|
}
|
cmm.setAreaId(areas.getId());
|
Cmm param = new Cmm();
|
param.setName(cmm.getName());
|
param =findOne(param);
|
if(param == null){
|
//新增
|
cmm.setId(UUID.randomUUID().toString());
|
cmm.setCreator(user.getId());
|
cmm.setCreateDate(new Date());
|
cmm.setEditor(user.getId());
|
cmm.setEditDate(new Date());
|
cmm.setIsdeleted(Constants.ZERO);
|
addList.add(cmm);
|
}else {
|
//修改
|
cmm.setEditor(user.getId());
|
cmm.setEditDate(new Date());
|
cmm.setId(param.getId());
|
updateIdList.add(param.getId());
|
updateList.add(cmm);
|
}
|
//生成数据行集合
|
cmmDataList.addAll(initDataModelByParam(cmm));
|
}
|
if(addList.size()>0){
|
cmmMapper.insertBatch(addList);
|
}
|
if(updateList.size()>0){
|
if(updateIdList.size()>0){
|
//删除原有的数据信息
|
UpdateWrapper<CmmData> updateWrapper = new UpdateWrapper<>();
|
updateWrapper.lambda().in(CmmData::getCmmId, updateIdList);
|
cmmDataMapper.delete(updateWrapper);
|
}
|
//遍历更新所有新数据
|
for(Cmm cmm:updateList){
|
cmmMapper.updateById(cmm);
|
}
|
}
|
if(cmmDataList.size()>0){
|
//批量插入数据行集合
|
cmmMapper.insertDataBatch(cmmDataList);
|
}
|
return 0;
|
|
}
|
|
private List<CmmData> initDataModelByParam(Cmm cmm) {
|
List<CmmData> dataList = new ArrayList<>();
|
for (int i=0;i<=28;i++){
|
dataListAddModel(i,dataList,cmm);
|
}
|
// dataListAddModel(1,cmm.getData1(),dataList,cmm);
|
// dataListAddModel(2,cmm.getData2(),dataList,cmm);
|
// dataListAddModel(3,cmm.getData3(),dataList,cmm);
|
// dataListAddModel(4,cmm.getData4(),dataList,cmm);
|
// dataListAddModel(5,cmm.getData5(),dataList,cmm);
|
// dataListAddModel(6,cmm.getData6(),dataList,cmm);
|
// dataListAddModel(7,cmm.getData7(),dataList,cmm);
|
// dataListAddModel(8,cmm.getData8(),dataList,cmm);
|
// dataListAddModel(9,cmm.getData9(),dataList,cmm);
|
// dataListAddModel(10,cmm.getData10(),dataList,cmm);
|
// dataListAddModel(11,cmm.getData11(),dataList,cmm);
|
// dataListAddModel(12,cmm.getData12(),dataList,cmm);
|
// dataListAddModel(13,cmm.getData13(),dataList,cmm);
|
// dataListAddModel(14,cmm.getData14(),dataList,cmm);
|
// dataListAddModel(15,cmm.getData15(),dataList,cmm);
|
// dataListAddModel(16,cmm.getData16(),dataList,cmm);
|
// dataListAddModel(17,cmm.getData17(),dataList,cmm);
|
// dataListAddModel(18,cmm.getData18(),dataList,cmm);
|
// dataListAddModel(19,cmm.getData19(),dataList,cmm);
|
// dataListAddModel(20,cmm.getData20(),dataList,cmm);
|
// dataListAddModel(21,cmm.getData21(),dataList,cmm);
|
// dataListAddModel(22,cmm.getData22(),dataList,cmm);
|
// dataListAddModel(23,cmm.getData23(),dataList,cmm);
|
// dataListAddModel(24,cmm.getData24(),dataList,cmm);
|
// dataListAddModel(25,cmm.getData25(),dataList,cmm);
|
// dataListAddModel(26,cmm.getData26(),dataList,cmm);
|
// dataListAddModel(27,cmm.getData27(),dataList,cmm);
|
// dataListAddModel(28,cmm.getData28(),dataList,cmm);
|
return dataList;
|
}
|
|
private BigDecimal getDecimalByStr(String str){
|
BigDecimal val = null;
|
try {
|
val = BigDecimal.valueOf(Double.parseDouble(str));
|
}catch (Exception e){
|
|
}
|
return val;
|
}
|
private void dataListAddModel(int i, String data0, List<CmmData> dataList,Cmm cmm) {
|
BigDecimal val = null;
|
try {
|
val = BigDecimal.valueOf(Double.parseDouble(data0));
|
}catch (Exception e){
|
|
}
|
if(val!=null){
|
CmmData model = new CmmData();
|
model.setId(UUID.randomUUID().toString());
|
model.setIsdeleted(Constants.ZERO);
|
model.setCmmId(cmm.getId());
|
model.setCreator(cmm.getEditor());
|
model.setCreateDate(new Date());
|
model.setType(i);
|
model.setVal(val);
|
dataList.add(model);
|
}
|
}
|
private void dataListAddModel(int i, List<CmmData> dataList,Cmm cmm) {
|
BigDecimal val = null;
|
String data0 = null;
|
|
try {
|
Field field = cmm.getClass().getDeclaredField("data"+i);
|
if(field!=null){
|
field.setAccessible(true);
|
data0 = (String) field.get(cmm);
|
}
|
val = BigDecimal.valueOf(Double.parseDouble(data0));
|
}catch (Exception e){
|
// e.printStackTrace();
|
|
}
|
if(val!=null){
|
CmmData model = new CmmData();
|
model.setId(UUID.randomUUID().toString());
|
model.setIsdeleted(Constants.ZERO);
|
model.setCmmId(cmm.getId());
|
model.setCreator(cmm.getEditor());
|
model.setCreateDate(new Date());
|
model.setType(i);
|
model.setVal(val);
|
dataList.add(model);
|
}
|
}
|
}
|
