package doumeemes.service.business.impl;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.alibaba.fastjson.JSONValidator;
|
import doumeemes.core.constants.ResponseStatus;
|
import doumeemes.core.exception.BusinessException;
|
import doumeemes.core.model.LoginUserInfo;
|
import doumeemes.core.model.PageData;
|
import doumeemes.core.model.PageWrap;
|
import doumeemes.core.utils.Constants;
|
import doumeemes.core.utils.Utils;
|
import doumeemes.dao.business.CompanyMapper;
|
import doumeemes.dao.business.model.Company;
|
import doumeemes.dao.business.model.CompanyLog;
|
import doumeemes.dao.business.model.Multifiles;
|
import doumeemes.dao.ext.dto.DingDingConfig;
|
import doumeemes.dao.ext.vo.CompanyExtListVO;
|
import doumeemes.service.business.CompanyLogService;
|
import doumeemes.service.business.CompanyService;
|
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 doumeemes.service.business.MultifilesService;
|
import doumeemes.service.ext.DepartmentExtService;
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.shiro.SecurityUtils;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.context.annotation.Lazy;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.CollectionUtils;
|
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Objects;
|
|
/**
|
* 系统-企业信息表，记录用户认证公司时记录的营业执照（公司认证必须填写表）Service实现
|
* @author 江蹄蹄
|
* @date 2022/04/20 09:33
|
*/
|
@Service
|
public class CompanyServiceImpl implements CompanyService {
|
|
@Autowired
|
private CompanyMapper companyMapper;
|
|
@Autowired
|
private CompanyLogService companyLogService;
|
|
@Autowired
|
@Lazy
|
private DepartmentExtService departmentExtService;
|
|
|
@Override
|
public Integer create(Company company) {
|
companyMapper.insert(company);
|
return company.getId();
|
}
|
|
@Override
|
public void deleteById(Integer id) {
|
Company company =new Company();
|
company.setId(id);
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
company.setUpdateTime(new Date());
|
company.setUpdateUser(user.getId());
|
company.setDeleted(Constants.ONE);
|
companyMapper.updateById(company);
|
Company company1 = companyMapper.selectById(company.getId());
|
initRedisCache(company1);
|
}
|
|
@Override
|
public void delete(Company company) {
|
/*UpdateWrapper<Company> deleteWrapper = new UpdateWrapper<>(company);
|
companyMapper.delete(deleteWrapper);*/
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
company.setUpdateTime(new Date());
|
company.setUpdateUser(user.getId());
|
company.setDeleted(Constants.ONE);
|
companyMapper.updateById(company);
|
}
|
|
@Override
|
public void deleteByIdInBatch(List<Integer> ids) {
|
if (CollectionUtils.isEmpty(ids)) {
|
return;
|
}
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
Date now=new Date();
|
Company company=new Company();
|
for(int i=0;i<ids.size();i++){
|
Integer id=ids.get(i);
|
company.setDeleted(Constants.ONE);
|
company.setId(id);
|
company.setUpdateTime(now);
|
company.setUpdateUser(user.getId());
|
}
|
companyMapper.updateById(company);
|
// companyMapper.deleteBatchIds(ids);
|
}
|
|
@Override
|
public void updateById(Company company) {
|
companyMapper.updateById(company);
|
}
|
|
@Transactional(rollbackFor = {Exception.class,BusinessException.class})
|
@Override
|
public void update(Company company) {
|
|
LoginUserInfo principal = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
|
|
if (StringUtils.isNotEmpty(company.getDingdingInfo()) && !isParseObject(company.getDingdingInfo())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"钉钉内部应用参数配置错误");
|
}
|
Company update = new Company();
|
update.setId(company.getId());
|
update.setStatus(company.getStatus());
|
update.setDingdingInfo(company.getDingdingInfo());
|
companyMapper.updateById(update);
|
// 更新记录
|
CompanyLog companyLog = new CompanyLog();
|
companyLog.setDeleted((byte)Constants.ZERO);
|
companyLog.setUpdateUser(principal.getId());
|
companyLog.setCreateUser(principal.getId());
|
companyLog.setCreateTime(new Date());
|
companyLog.setUpdateTime(new Date());
|
companyLog.setCompanyId(company.getId());
|
if(Objects.nonNull(company.getStatus())){
|
companyLog.setRemark(company.getStatus() == 1 ? "数据启用" : "数据禁用");
|
companyLog.setUpdateType(company.getStatus() == 1 ? Constants.CompanyUpdateType.UPDATE_ENABLE.getKey()
|
: Constants.CompanyUpdateType.UPDATE_DISABLE.getKey());
|
companyLog.setDetail(company.getStatus() == 1 ? "数据启用" : "数据禁用");
|
}else {
|
companyLog.setRemark("更新企业数据");
|
companyLog.setUpdateType(Constants.CompanyUpdateType.UPDATE_CONTENT.getKey());
|
companyLog.setDetail("更新企业数据");
|
}
|
companyLogService.create(companyLog);
|
Company company1 = companyMapper.selectById(company.getId());
|
initRedisCache(company1);
|
}
|
|
|
private void initRedisCache(Company com) {
|
CompanyExtListVO c = new CompanyExtListVO();
|
BeanUtils.copyProperties(com,c);
|
departmentExtService.loadComDepart(c);
|
departmentExtService.initCompnayCodesByCom(com);
|
}
|
|
private Boolean isParseObject(String dingdingInfo){
|
try {
|
JSONValidator from = JSONValidator.from(dingdingInfo);
|
return from.validate();
|
}catch (Exception e){
|
return false;
|
}
|
|
}
|
|
@Override
|
public void updateByIdInBatch(List<Company> companys) {
|
if (CollectionUtils.isEmpty(companys)) {
|
return;
|
}
|
for (Company company: companys) {
|
this.updateById(company);
|
}
|
}
|
|
@Override
|
public Company findById(Integer id) {
|
return companyMapper.selectById(id);
|
}
|
|
@Override
|
public Company findOne(Company company) {
|
company.setDeleted(Constants.ZERO);
|
QueryWrapper<Company> wrapper = new QueryWrapper<>(company);
|
return companyMapper.selectOne(wrapper);
|
}
|
|
@Override
|
public List<Company> findList(Company company) {
|
company.setDeleted(Constants.ZERO);
|
QueryWrapper<Company> wrapper = new QueryWrapper<>(company);
|
return companyMapper.selectList(wrapper);
|
}
|
|
@Override
|
public PageData<Company> findPage(PageWrap<Company> pageWrap) {
|
IPage<Company> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
|
QueryWrapper<Company> queryWrapper = new QueryWrapper<>();
|
Utils.MP.blankToNull(pageWrap.getModel());
|
if (pageWrap.getModel().getId() != null) {
|
queryWrapper.lambda().eq(Company::getId, pageWrap.getModel().getId());
|
}
|
if (pageWrap.getModel().getDeleted() != null) {
|
queryWrapper.lambda().eq(Company::getDeleted, pageWrap.getModel().getDeleted());
|
}
|
if (pageWrap.getModel().getCreateUser() != null) {
|
queryWrapper.lambda().eq(Company::getCreateUser, pageWrap.getModel().getCreateUser());
|
}
|
if (pageWrap.getModel().getCreateTime() != null) {
|
queryWrapper.lambda().ge(Company::getCreateTime, Utils.Date.getStart(pageWrap.getModel().getCreateTime()));
|
queryWrapper.lambda().le(Company::getCreateTime, Utils.Date.getEnd(pageWrap.getModel().getCreateTime()));
|
}
|
if (pageWrap.getModel().getUpdateUser() != null) {
|
queryWrapper.lambda().eq(Company::getUpdateUser, pageWrap.getModel().getUpdateUser());
|
}
|
if (pageWrap.getModel().getUpdateTime() != null) {
|
queryWrapper.lambda().ge(Company::getUpdateTime, Utils.Date.getStart(pageWrap.getModel().getUpdateTime()));
|
queryWrapper.lambda().le(Company::getUpdateTime, Utils.Date.getEnd(pageWrap.getModel().getUpdateTime()));
|
}
|
if (pageWrap.getModel().getOrigin() != null) {
|
queryWrapper.lambda().eq(Company::getOrigin, pageWrap.getModel().getOrigin());
|
}
|
if (pageWrap.getModel().getName() != null) {
|
queryWrapper.lambda().eq(Company::getName, pageWrap.getModel().getName());
|
}
|
// if (pageWrap.getModel().getRemark() != null) {
|
// queryWrapper.lambda().eq(Company::getRemark, pageWrap.getModel().getRemark());
|
// }
|
if (pageWrap.getModel().getType() != null) {
|
queryWrapper.lambda().eq(Company::getType, pageWrap.getModel().getType());
|
}
|
if (pageWrap.getModel().getLegalPersonId() != null) {
|
queryWrapper.lambda().eq(Company::getLegalPersonId, pageWrap.getModel().getLegalPersonId());
|
}
|
if (pageWrap.getModel().getLegalPersonPhone() != null) {
|
queryWrapper.lambda().eq(Company::getLegalPersonPhone, pageWrap.getModel().getLegalPersonPhone());
|
}
|
if (pageWrap.getModel().getRegisterDate() != null) {
|
queryWrapper.lambda().ge(Company::getRegisterDate, Utils.Date.getStart(pageWrap.getModel().getRegisterDate()));
|
queryWrapper.lambda().le(Company::getRegisterDate, Utils.Date.getEnd(pageWrap.getModel().getRegisterDate()));
|
}
|
if (pageWrap.getModel().getAddr() != null) {
|
queryWrapper.lambda().eq(Company::getAddr, pageWrap.getModel().getAddr());
|
}
|
if (pageWrap.getModel().getBusinessScope() != null) {
|
queryWrapper.lambda().eq(Company::getBusinessScope, pageWrap.getModel().getBusinessScope());
|
}
|
if (pageWrap.getModel().getBusinessTerm() != null) {
|
queryWrapper.lambda().eq(Company::getBusinessTerm, pageWrap.getModel().getBusinessTerm());
|
}
|
if (pageWrap.getModel().getIssueDate() != null) {
|
queryWrapper.lambda().ge(Company::getIssueDate, Utils.Date.getStart(pageWrap.getModel().getIssueDate()));
|
queryWrapper.lambda().le(Company::getIssueDate, Utils.Date.getEnd(pageWrap.getModel().getIssueDate()));
|
}
|
if (pageWrap.getModel().getCreditCode() != null) {
|
queryWrapper.lambda().eq(Company::getCreditCode, pageWrap.getModel().getCreditCode());
|
}
|
if (pageWrap.getModel().getRegisterCapital() != null) {
|
queryWrapper.lambda().eq(Company::getRegisterCapital, pageWrap.getModel().getRegisterCapital());
|
}
|
if (pageWrap.getModel().getFileFormat() != null) {
|
queryWrapper.lambda().eq(Company::getFileFormat, pageWrap.getModel().getFileFormat());
|
}
|
if (pageWrap.getModel().getFileName() != null) {
|
queryWrapper.lambda().eq(Company::getFileName, pageWrap.getModel().getFileName());
|
}
|
if (pageWrap.getModel().getFileStoreAddr() != null) {
|
queryWrapper.lambda().eq(Company::getFileStoreAddr, pageWrap.getModel().getFileStoreAddr());
|
}
|
if (pageWrap.getModel().getAuthStatus() != null) {
|
queryWrapper.lambda().eq(Company::getAuthStatus, pageWrap.getModel().getAuthStatus());
|
}
|
if (pageWrap.getModel().getAuthId() != null) {
|
queryWrapper.lambda().eq(Company::getAuthId, pageWrap.getModel().getAuthId());
|
}
|
if (pageWrap.getModel().getDingdingId() != null) {
|
queryWrapper.lambda().eq(Company::getDingdingId, pageWrap.getModel().getDingdingId());
|
}
|
if (pageWrap.getModel().getOpenUserNum() != null) {
|
queryWrapper.lambda().eq(Company::getOpenUserNum, pageWrap.getModel().getOpenUserNum());
|
}
|
if (pageWrap.getModel().getOpenModules() != null) {
|
queryWrapper.lambda().eq(Company::getOpenModules, pageWrap.getModel().getOpenModules());
|
}
|
if (pageWrap.getModel().getOepnValidDate() != null) {
|
queryWrapper.lambda().ge(Company::getOepnValidDate, Utils.Date.getStart(pageWrap.getModel().getOepnValidDate()));
|
queryWrapper.lambda().le(Company::getOepnValidDate, Utils.Date.getEnd(pageWrap.getModel().getOepnValidDate()));
|
}
|
if (pageWrap.getModel().getOepnType() != null) {
|
queryWrapper.lambda().eq(Company::getOepnType, pageWrap.getModel().getOepnType());
|
}
|
if (pageWrap.getModel().getChannelId() != null) {
|
queryWrapper.lambda().eq(Company::getChannelId, pageWrap.getModel().getChannelId());
|
}
|
for(PageWrap.SortData sortData: pageWrap.getSorts()) {
|
if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
|
queryWrapper.orderByDesc(sortData.getProperty());
|
} else {
|
queryWrapper.orderByAsc(sortData.getProperty());
|
}
|
}
|
queryWrapper.lambda().eq(Company::getDeleted, Constants.ZERO);
|
return PageData.from(companyMapper.selectPage(page, queryWrapper));
|
}
|
|
@Override
|
public long count(Company company) {
|
company.setDeleted(Constants.ZERO);
|
QueryWrapper<Company> wrapper = new QueryWrapper<>(company);
|
return companyMapper.selectCount(wrapper);
|
}
|
}
|
