| | |
| | | package com.doumee.service.business.impl; |
| | | |
| | | import com.doumee.biz.system.SystemDictDataBiz; |
| | | import com.doumee.core.constants.ResponseStatus; |
| | | import com.doumee.core.exception.BusinessException; |
| | | import com.doumee.core.model.LoginUserInfo; |
| | |
| | | import com.doumee.core.model.PageWrap; |
| | | import com.doumee.core.utils.Constants; |
| | | import com.doumee.core.utils.Utils; |
| | | import com.doumee.dao.business.CompanyMapper; |
| | | import com.doumee.dao.business.CompanyPermissionMapper; |
| | | import com.doumee.dao.business.model.Company; |
| | | import com.doumee.dao.business.model.CompanyPermission; |
| | | import com.doumee.dao.business.model.Insurance; |
| | | import com.doumee.dao.business.*; |
| | | import com.doumee.dao.business.join.CompanySolutionJoinMapper; |
| | | import com.doumee.dao.business.model.*; |
| | | import com.doumee.dao.system.SystemUserMapper; |
| | | import com.doumee.dao.system.model.SystemUser; |
| | | import com.doumee.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 com.doumee.service.business.third.SignService; |
| | | import com.github.yulichang.wrapper.MPJLambdaWrapper; |
| | | import lombok.Synchronized; |
| | | import org.apache.commons.lang3.RandomStringUtils; |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.apache.shiro.SecurityUtils; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.scheduling.annotation.Async; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | import org.springframework.util.CollectionUtils; |
| | | |
| | | import java.util.List; |
| | | import java.io.File; |
| | | import java.lang.reflect.Array; |
| | | import java.net.URI; |
| | | import java.util.*; |
| | | |
| | | /** |
| | | * ä¼ä¸ä¿¡æ¯è¡¨Serviceå®ç° |
| | |
| | | @Autowired |
| | | private CompanyMapper companyMapper; |
| | | @Autowired |
| | | private SystemUserMapper systemUserMapper; |
| | | @Autowired |
| | | private SignService signService; |
| | | @Autowired |
| | | private SolutionsMapper solutionsMapper; |
| | | @Autowired |
| | | private CompanySolutionJoinMapper companySolutionJoinMapper; |
| | | @Autowired |
| | | private CompanyPermissionMapper companyPermissionMapper; |
| | | @Autowired |
| | | private MultifileMapper multifileMapper; |
| | | @Autowired |
| | | private SmsEmailMapper smsEmailMapper; |
| | | @Autowired |
| | | private SystemDictDataBiz systemDictDataBiz; |
| | | |
| | | @Override |
| | | public Integer create(Company company) { |
| | | |
| | | @Transactional |
| | | public Company create(Company company) { |
| | | isValidCreateParam(company); |
| | | if(companyMapper.selectCount(new QueryWrapper<Company>().lambda() |
| | | .eq(Company::getCode,company.getCode()) |
| | | .or().eq(Company::getPhone,company.getPhone()) |
| | | .or().eq(Company::getUsername,company.getUsername()) |
| | | .or().eq(Company::getName,company.getName()))>0){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对ä¸èµ·ï¼è¯¥ä¼ä¸ãåç§°ããç»ä¸ä¿¡ç¨ä»£ç æè
ãææºå·ãå·²åå¨ï¼è¯·ç¡®è®¤åéæ°æäº¤ï¼"); |
| | | } |
| | | LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); |
| | | company.setCreator(user.getId()); |
| | | company.setCreateDate(new Date()); |
| | | company.setIsdeleted(Constants.ZERO); |
| | | company.setStatus(Constants.ZERO); |
| | | company.setType(Constants.ZERO); |
| | | company.setSignStatus(Constants.ZERO); |
| | | company.setSignIdStatus(Constants.ZERO); |
| | | companyMapper.insert(company); |
| | | return company.getId(); |
| | | company.setEditDate(company.getCreateDate()); |
| | | company.setEditor(user.getId()); |
| | | //å¤çç»éè´¦å·ä¿¡æ¯ |
| | | dealSystemUserData(company); |
| | | //å¤çéä»¶ä¿¡æ¯ |
| | | dealFileData(company); |
| | | //å¤çå
³èæ¹æ¡ |
| | | dealSolutionsData(company); |
| | | return company; |
| | | } |
| | | |
| | | private void dealSystemUserData(Company company) { |
| | | if(systemUserMapper.selectCount(new QueryWrapper<SystemUser>().lambda() |
| | | .eq(SystemUser::getDeleted,Boolean.TRUE) |
| | | .eq(SystemUser::getUsername,company.getUsername()))>0){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对ä¸èµ·ï¼è¯¥ç»å½è´¦å·å·²åå¨ï¼è¯·æ´æ°éè¯~"); |
| | | } |
| | | SystemUser user = new SystemUser(); |
| | | user.setUsername(company.getUsername()); |
| | | // çæå¯ç ç |
| | | String salt = RandomStringUtils.randomAlphabetic(6); |
| | | // çæå¯ç |
| | | user.setPassword(Utils.Secure.encryptPassword(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.DEFAULT_PASSWORD).getCode(), salt)); |
| | | user.setSalt(salt); |
| | | user.setType(Constants.ONE); |
| | | user.setFixed(Boolean.TRUE); |
| | | user.setDeleted(Boolean.FALSE); |
| | | user.setCompanyId(company.getId()); |
| | | user.setMobile(company.getPhone()); |
| | | user.setCreateUser(company.getCreator()); |
| | | user.setCreateTime(company.getCreateDate()); |
| | | user.setStatus(Constants.ZERO); |
| | | systemUserMapper.insert(user); |
| | | } |
| | | private void dealSystemUserDataForUpdate (Company company,String oldUserName) { |
| | | if(systemUserMapper.selectCount(new QueryWrapper<SystemUser>().lambda() |
| | | .eq(SystemUser::getDeleted,Boolean.TRUE) |
| | | .eq(SystemUser::getUsername,company.getUsername()))>0){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对ä¸èµ·ï¼è¯¥ç»å½è´¦å·å·²åå¨ï¼è¯·æ´æ°éè¯~"); |
| | | } |
| | | SystemUser model = systemUserMapper.selectOne(new QueryWrapper<SystemUser>().lambda() |
| | | .eq(SystemUser::getDeleted,Boolean.TRUE) |
| | | .eq(SystemUser::getUsername,oldUserName).last("limit 1")); |
| | | if(model ==null){ |
| | | SystemUser user = new SystemUser(); |
| | | user.setUsername(company.getUsername()); |
| | | // çæå¯ç ç |
| | | String salt = RandomStringUtils.randomAlphabetic(6); |
| | | // çæå¯ç |
| | | user.setPassword(Utils.Secure.encryptPassword(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.DEFAULT_PASSWORD).getCode(), salt)); |
| | | user.setSalt(salt); |
| | | user.setType(Constants.ONE); |
| | | user.setFixed(Boolean.TRUE); |
| | | user.setDeleted(Boolean.FALSE); |
| | | user.setCompanyId(company.getId()); |
| | | user.setMobile(company.getPhone()); |
| | | user.setCreateUser(company.getCreator()); |
| | | user.setCreateTime(company.getCreateDate()); |
| | | user.setStatus(Constants.ZERO); |
| | | systemUserMapper.insert(user);//æå
¥æ°ç管çåè´¦å· |
| | | }else{ |
| | | model.setUsername(company.getUsername()); |
| | | model.setCreateUser(company.getCreator()); |
| | | model.setCreateTime(company.getCreateDate()); |
| | | systemUserMapper.updateById(model);//ä¿®æ¹åæ¥çè¶
级管çåè´¦å· |
| | | } |
| | | |
| | | } |
| | | |
| | | |
| | | /** |
| | | * æ°å¢å
³èæ¹æ¡ |
| | | * @param company |
| | | */ |
| | | private void dealSolutionsData(Company company) { |
| | | List<Integer> sIds = new ArrayList<>(); |
| | | List<CompanySolution> list = new ArrayList<>(); |
| | | int num =0; |
| | | for(CompanySolution s :company.getSolutionList()){ |
| | | if(s.getSolutionBaseId() == null){ |
| | | continue; |
| | | } |
| | | sIds.add(s.getSolutionBaseId()); |
| | | s.setCompanyId(company.getId()); |
| | | s.setIsdeleted(Constants.ZERO); |
| | | s.setCanAdd(Constants.formatIntegerNum(s.getCanAdd())); |
| | | s.setCanReduce(Constants.formatIntegerNum(s.getCanReduce())); |
| | | s.setCreateDate(company.getCreateDate()); |
| | | s.setCreator(company.getCreator()); |
| | | s.setSortnum(num++); |
| | | s.setStatus(Constants.ZERO); |
| | | list.add(s); |
| | | } |
| | | if(list.size() ==0){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"è¯·æ·»å ææçä¿é©æ¹æ¡ä¿¡æ¯ï¼"); |
| | | } |
| | | List<Solutions> solutionsList = solutionsMapper.selectList(new QueryWrapper<Solutions>().lambda() |
| | | .in(Solutions::getId,sIds) |
| | | .eq(Solutions::getIsdeleted,Constants.ZERO)); |
| | | if(solutionsList.size()!= list.size()){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"è¯·æ·»å ææçä¿é©æ¹æ¡ä¿¡æ¯å¦"); |
| | | } |
| | | for(Solutions s:solutionsList){ |
| | | if(Constants.equalsInteger(s.getStatus(),Constants.ONE)){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"ä¿é©æ¹æ¡ã"+s.getName()+"ã已被ç¦ç¨ï¼ä¸è½è¿è¡è¯¥æä½"); |
| | | } |
| | | } |
| | | companySolutionJoinMapper.insertBatchSomeColumn(list); |
| | | } |
| | | |
| | | private void isValidCreateParam(Company company) { |
| | | if(StringUtils.isBlank(company.getPhone()) |
| | | ||StringUtils.isBlank(company.getName()) |
| | | ||StringUtils.isBlank(company.getUsername()) |
| | | ||StringUtils.isBlank(company.getCode()) |
| | | ||StringUtils.isBlank(company.getCaptche()) |
| | | ||StringUtils.isBlank(company.getLegalName()) |
| | | ||StringUtils.isBlank(company.getEmail()) |
| | | ||company.getSolutionList() == null |
| | | ||company.getSolutionList().size() == 0 |
| | | ||StringUtils.isBlank(company.getEmail())){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST); |
| | | } |
| | | //ææºéªè¯ç æ ¡éª |
| | | SmsEmailServiceImpl.isCaptcheValide(smsEmailMapper,company.getPhone(),company.getCaptche()); |
| | | |
| | | } |
| | | |
| | | private void dealFileData(Company company ) { |
| | | |
| | | List<Multifile> multifileList = new ArrayList<>(); |
| | | if(company.getBusinessImg()!=null && StringUtils.isNotBlank(company.getBusinessImg().getFileurl())){ |
| | | multifileList.add(initMultiFileByCompay(company,company.getBusinessImg(),Constants.MultiFile.COM_BUSINESS_LICENSE.getKey())); |
| | | }else { |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"请ä¸ä¼ è¥ä¸æ§ç
§ï¼"); |
| | | } |
| | | if(company.getSignImg()!=null && StringUtils.isNotBlank(company.getSignImg().getFileurl())){ |
| | | multifileList.add(initMultiFileByCompay(company,company.getSignImg(),Constants.MultiFile.COM_SING_IMG.getKey())); |
| | | }else { |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"请ä¸ä¼ çµåç¾ç« ï¼"); |
| | | } |
| | | if(company.getIdcardImgList()!=null && company.getIdcardImgList()!=null&& company.getIdcardImgList().size()>0){ |
| | | for(Multifile f : company.getIdcardImgList()){ |
| | | multifileList.add(initMultiFileByCompay(company,f,Constants.MultiFile.COM_IDCARD_IMG.getKey())); |
| | | } |
| | | }else { |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"请ä¸ä¼ èº«ä»½è¯æ«æä»¶ï¼"); |
| | | } |
| | | multifileMapper.insertBatchSomeColumn(multifileList); |
| | | } |
| | | private void dealFileDataForUpdate(Company company ) { |
| | | |
| | | List<Multifile> multifileList = new ArrayList<>(); |
| | | List<Integer> objList = new ArrayList<>(); |
| | | if(company.getBusinessImg()!=null && StringUtils.isNotBlank(company.getBusinessImg().getFileurl())){ |
| | | multifileList.add(initMultiFileByCompay(company,company.getBusinessImg(),Constants.MultiFile.COM_BUSINESS_LICENSE.getKey())); |
| | | objList.add(Constants.MultiFile.COM_BUSINESS_LICENSE.getKey()); |
| | | }else { |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"请ä¸ä¼ è¥ä¸æ§ç
§ï¼"); |
| | | } |
| | | if(company.getSignImg()!=null && StringUtils.isNotBlank(company.getSignImg().getFileurl())){ |
| | | multifileList.add(initMultiFileByCompay(company,company.getSignImg(),Constants.MultiFile.COM_SING_IMG.getKey())); |
| | | objList.add(Constants.MultiFile.COM_SING_IMG.getKey()); |
| | | company.setSignIdStatus(Constants.ZERO);//æ è®°çµåç¾ç« æªä¸ä¼ |
| | | } |
| | | if(company.getIdcardImgList()!=null && company.getIdcardImgList()!=null){ |
| | | for(Multifile f : company.getIdcardImgList()){ |
| | | multifileList.add(initMultiFileByCompay(company,f,Constants.MultiFile.COM_IDCARD_IMG.getKey())); |
| | | } |
| | | objList.add(Constants.MultiFile.COM_IDCARD_IMG.getKey()); |
| | | } |
| | | if(objList.size()>0){ |
| | | multifileMapper.update(null,new UpdateWrapper<Multifile>().lambda() |
| | | .set(Multifile::getIsdeleted,Constants.ONE) |
| | | .set(Multifile::getEditDate,company.getEditDate()) |
| | | .set(Multifile::getEditor,company.getEditor()) |
| | | .eq(Multifile::getObjId,company.getId()) |
| | | .eq(Multifile::getIsdeleted,Constants.ZERO) |
| | | .in(Multifile::getObjType,objList) |
| | | ); |
| | | multifileMapper.insertBatchSomeColumn(multifileList); |
| | | } |
| | | } |
| | | |
| | | private Multifile initMultiFileByCompay(Company company, Multifile file, int key) { |
| | | file.setCompanyId(company.getId()); |
| | | file.setIsdeleted(Constants.ZERO); |
| | | file.setCreateDate(company.getEditDate()); |
| | | file.setCreator(company.getEditor()); |
| | | file.setObjId(company.getId()); |
| | | file.setObjType(key); |
| | | file.setType(Constants.formatIntegerNum(file.getType())); |
| | | if(file.getFileurl().endsWith(".mp4")){ |
| | | file.setType(Constants.TWO); |
| | | } |
| | | return file; |
| | | } |
| | | |
| | | @Override |
| | | public void deleteById(Integer id) { |
| | | companyMapper.deleteById(id); |
| | | } |
| | | @Override |
| | | public void updateStatus(Company company){ |
| | | if(company.getId() == null || company.getStatus()==null || company.getStatus()<0||company.getStatus()>1){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST ); |
| | | } |
| | | Company model = companyMapper.selectById(company.getId()); |
| | | if(model == null || !Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO) ){ |
| | | throw new BusinessException(ResponseStatus.DATA_EMPTY ); |
| | | } |
| | | if(Constants.equalsInteger(model.getStatus(),company.getStatus())){ |
| | | //å¦æç¶æä¸åçæ¹åï¼ç´æ¥è¿å |
| | | return; |
| | | } |
| | | LoginUserInfo user= (LoginUserInfo)SecurityUtils.getSubject().getPrincipal(); |
| | | //æ´æ°æ°æ®ç¶æ |
| | | companyMapper.update(null,new UpdateWrapper<Company>() |
| | | .lambda() |
| | | .eq(Company::getId,model.getId()) |
| | | .set(Company::getEditDate,new Date()) |
| | | .set(Company::getEditor,user.getId()) |
| | | .set(Company::getStatus,company.getStatus()) |
| | | ); |
| | | } |
| | | @Override |
| | | public void updatePhone(Company company){ |
| | | if(company.getId() == null ||StringUtils.isBlank(company.getPhone()) |
| | | || StringUtils.isBlank(company.getCaptche())){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST ); |
| | | } |
| | | SmsEmailServiceImpl.isCaptcheValide(smsEmailMapper,company.getPhone(),company.getCaptche()); |
| | | Company model = companyMapper.selectById(company.getId()); |
| | | if(model == null || StringUtils.equals(model.getPhone(),company.getPhone()) ){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"ææºå·æªåçæ¹å~" ); |
| | | } |
| | | |
| | | if(companyMapper.selectCount(new QueryWrapper<Company>().lambda() |
| | | .eq(Company::getPhone,company.getPhone()) |
| | | .eq(Company::getIsdeleted,Constants.ZERO))>0){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对ä¸èµ·ï¼è¯¥ä¼ä¸ãææºå·ãå·²åå¨ï¼è¯·ç¡®è®¤åéæ°æäº¤ï¼"); |
| | | } |
| | | |
| | | LoginUserInfo user= (LoginUserInfo)SecurityUtils.getSubject().getPrincipal(); |
| | | //æ´æ¢ææºå· |
| | | companyMapper.update(null,new UpdateWrapper<Company>() |
| | | .lambda() |
| | | .eq(Company::getId,model.getId()) |
| | | .set(Company::getEditDate,new Date()) |
| | | .set(Company::getEditor,user.getId()) |
| | | .set(Company::getPhone,company.getPhone()) |
| | | ); |
| | | } |
| | | |
| | | @Override |
| | |
| | | } |
| | | companyMapper.deleteBatchIds(ids); |
| | | } |
| | | private void isValidUpdateParam(Company company) { |
| | | if( StringUtils.isBlank(company.getName()) |
| | | ||StringUtils.isBlank(company.getUsername()) |
| | | ||StringUtils.isBlank(company.getCode()) |
| | | ||StringUtils.isBlank(company.getCaptche()) |
| | | ||StringUtils.isBlank(company.getLegalName()) |
| | | ||StringUtils.isBlank(company.getEmail()) ){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST); |
| | | } |
| | | |
| | | } |
| | | @Override |
| | | public void updateById(Company company) { |
| | | public Company updateById(Company company) { |
| | | isValidUpdateParam(company); |
| | | Company model = findById(company.getId()); |
| | | if(model == null || !Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO) ){ |
| | | throw new BusinessException(ResponseStatus.DATA_EMPTY ); |
| | | } |
| | | if(StringUtils.equals(company.getEmail(),model.getEmail())){ |
| | | company.setEmail(null); |
| | | } |
| | | if(StringUtils.equals(company.getUsername(),model.getUsername())){ |
| | | company.setUsername(null); |
| | | } |
| | | |
| | | if(companyMapper.selectCount(new QueryWrapper<Company>().lambda() |
| | | .ne(Company::getId,company.getId()) |
| | | .and(w->w.eq(Company::getCode,company.getCode()) |
| | | .or().eq(Company::getUsername,company.getUsername()) |
| | | .or().eq(Company::getName,company.getName())) |
| | | )>0){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对ä¸èµ·ï¼è¯¥ä¼ä¸ãåç§°ããç»ä¸ä¿¡ç¨ä»£ç æè
ãä¼ä¸è´¦å·ãå·²åå¨ï¼è¯·ç¡®è®¤åéæ°æäº¤ï¼"); |
| | | } |
| | | LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); |
| | | |
| | | dealFileDataForUpdate(company); |
| | | |
| | | Company update = new Company(); |
| | | update.setIsdeleted(company.getId()); |
| | | update.setName(company.getName()); |
| | | update.setCode(company.getCode()); |
| | | update.setEditDate(new Date()); |
| | | update.setEditor(user.getId()); |
| | | update.setUsername(company.getUsername()); |
| | | update.setTaxAccount(company.getTaxAccount()); |
| | | update.setTaxAddr(company.getTaxAddr()); |
| | | update.setTaxCode(company.getTaxCode()); |
| | | update.setTaxBank(company.getTaxBank()); |
| | | update.setEmail(company.getEmail()); |
| | | update.setInvoiceAddr(company.getInvoiceAddr()); |
| | | update.setSignIdStatus(company.getSignIdStatus()); |
| | | update.setInvoiceEmail(company.getInvoiceEmail()); |
| | | if(StringUtils.isNotBlank(company.getEmail())){ |
| | | //妿é®ç®±åçæ¹å |
| | | update.setSignStatus(Constants.ZERO); |
| | | } |
| | | companyMapper.updateById(company); |
| | | company.setCreator(update.getEditor()); |
| | | company.setCreateDate(update.getEditDate()); |
| | | if(StringUtils.isNotBlank(company.getUsername())){ |
| | | //å¤çç»éè´¦å·ä¿¡æ¯ |
| | | dealSystemUserDataForUpdate(company,model.getUsername()); |
| | | } |
| | | |
| | | return company; |
| | | } |
| | | |
| | | @Override |
| | |
| | | |
| | | @Override |
| | | public Company findById(Integer id) { |
| | | return companyMapper.selectById(id); |
| | | Company model = findById(id); |
| | | if(model == null ||Constants.equalsInteger(model.getIsdeleted(),Constants.ONE)){ |
| | | throw new BusinessException(ResponseStatus.DATA_EMPTY); |
| | | } |
| | | MPJLambdaWrapper<CompanySolution> csWrapper = new MPJLambdaWrapper<>(); |
| | | csWrapper.selectAll(CompanySolution.class); |
| | | csWrapper.selectAs(Solutions::getName,CompanySolution::getSolutionName); |
| | | csWrapper.leftJoin(Solutions.class,Solutions::getId,CompanySolution::getSolutionBaseId); |
| | | csWrapper.eq(CompanySolution::getCompanyId,id); |
| | | csWrapper.eq(CompanySolution::getIsdeleted,Constants.ZERO); |
| | | csWrapper.orderByAsc(CompanySolution::getSortnum); |
| | | model.setSolutionList(companySolutionJoinMapper.selectJoinList(CompanySolution.class,csWrapper)); |
| | | |
| | | initImgData(model); |
| | | return model; |
| | | } |
| | | |
| | | private void initImgData(Company model) { |
| | | List<Multifile> multifiles = multifileMapper.selectList(new QueryWrapper<Multifile>().lambda() |
| | | .eq(Multifile::getCompanyId,model.getId()) |
| | | .eq(Multifile::getIsdeleted,Constants.ZERO)); |
| | | if(multifiles!=null){ |
| | | String path = systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode()+systemDictDataBiz.queryByCode(Constants.OSS,Constants.COMPANY_FILE).getCode(); |
| | | for(Multifile f : multifiles){ |
| | | if(StringUtils.isBlank(f.getFileurl())){ |
| | | continue; |
| | | } |
| | | f.setFileurlFull(path+f.getFileurl()); |
| | | if(Constants.equalsInteger(f.getObjType(),Constants.MultiFile.COM_BUSINESS_LICENSE.getKey())){ |
| | | //è¥ä¸æ§ç
§ |
| | | model.setBusinessImg(f); |
| | | }else if(Constants.equalsInteger(f.getObjType(),Constants.MultiFile.COM_SING_IMG.getKey())){ |
| | | //ä¼ä¸çµåç« |
| | | model.setSignImg(f); |
| | | }else if(Constants.equalsInteger(f.getObjType(),Constants.MultiFile.COM_IDCARD_IMG.getKey())){ |
| | | //æ³äººèº«ä»½è¯ |
| | | if(model.getIdcardImgList()==null){ |
| | | model.setIdcardImgList(new ArrayList<>()); |
| | | } |
| | | model.getIdcardImgList().add(f); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | |
| | | @Override |
| | |
| | | QueryWrapper<Company> wrapper = new QueryWrapper<>(company); |
| | | return companyMapper.selectOne(wrapper); |
| | | } |
| | | /** |
| | | * çµåç¾è®¤è¯ |
| | | * public boolean organizationCreate (String fullname,String creditCode,String legalName,String email,File businessimg,String notifyUrl){ |
| | | */ |
| | | @Override |
| | | public void startSignAuth(Integer id){ |
| | | Company company = companyMapper.selectById(id); |
| | | Multifile f = multifileMapper.selectOne(new QueryWrapper<Multifile>().lambda() |
| | | .eq(Multifile::getIsdeleted,Constants.ZERO) |
| | | .eq(Multifile::getObjType,Constants.MultiFile.COM_BUSINESS_LICENSE.getKey()) |
| | | .eq(Multifile::getObjId,company.getId()) |
| | | .last("limit 1")); |
| | | if(f == null){ |
| | | return; |
| | | } |
| | | String path = systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode()+systemDictDataBiz.queryByCode(Constants.OSS,Constants.COMPANY_FILE).getCode(); |
| | | boolean status = signService.organizationCreate(company.getName(),company.getCode(),company.getLegalName(),company.getEmail(), path + f.getFileurl(),null); |
| | | Company update = new Company(); |
| | | update.setId(company.getId()); |
| | | update.setSignStatus(status?Constants.ONE:Constants.TWO); |
| | | update.setSignDate(new Date()); |
| | | //æ´æ°è®¤è¯ç¶æ |
| | | companyMapper.updateById(update); |
| | | } |
| | | /** |
| | | * çµåç¾è®¤è¯ |
| | | * public boolean organizationCreate (String fullname,String creditCode,String legalName,String email,File businessimg,String notifyUrl){ |
| | | */ |
| | | @Override |
| | | @Synchronized//å便§è¡ |
| | | public void dealSignAuthStatus(){ |
| | | List<Company> companyList = companyMapper.selectList(new QueryWrapper<Company>().lambda() |
| | | .eq(Company::getIsdeleted,Constants.ZERO) |
| | | .eq(Company::getSignStatus,Constants.ONE)); |
| | | if(companyList!=null && companyList.size()>0){ |
| | | for(Company company :companyList){ |
| | | //æ¥è¯¢ä¼ä¸ç¾çº¦ç¶æ 审æ¹ç¶æ,0æ£å¨ç³è¯·1éè¿2驳å |
| | | int status = signService.organizationAuditStatus(company.getEmail()); |
| | | if(status == 1){ |
| | | Company update = new Company(); |
| | | update.setId(company.getId()); |
| | | update.setSignStatus( Constants.THREE); |
| | | update.setSignDate(new Date()); |
| | | //æ´æ°è®¤è¯ç¶æ |
| | | companyMapper.updateById(update); |
| | | }else{ |
| | | Company update = new Company(); |
| | | update.setId(company.getId()); |
| | | update.setSignStatus(Constants.TWO); |
| | | update.setSignDate(new Date()); |
| | | //æ´æ°è®¤è¯ç¶æ |
| | | companyMapper.updateById(update); |
| | | } |
| | | |
| | | } |
| | | } |
| | | |
| | | } |
| | | /** |
| | | * çµåå°ç« èªå¨ä¸ä¼ |
| | | * public boolean organizationCreate (String fullname,String creditCode,String legalName,String email,File businessimg,String notifyUrl){ |
| | | */ |
| | | @Override |
| | | @Synchronized//å便§è¡ |
| | | public void dealSignIdStatus(){ |
| | | List<Company> companyList = companyMapper.selectList(new QueryWrapper<Company>().lambda() |
| | | .eq(Company::getIsdeleted,Constants.ZERO) |
| | | .eq(Company::getSignStatus,Constants.ONE) |
| | | .eq(Company::getSignIdStatus,Constants.ZERO)); |
| | | if(companyList!=null && companyList.size()>0){ |
| | | for(Company company :companyList){ |
| | | //æ¥è¯¢ä¼ä¸ç¾çº¦ç¶æ 审æ¹ç¶æ,0æ£å¨ç³è¯·1éè¿2驳å |
| | | Multifile f = multifileMapper.selectOne(new QueryWrapper<Multifile>().lambda() |
| | | .eq(Multifile::getIsdeleted,Constants.ZERO) |
| | | .eq(Multifile::getObjType,Constants.MultiFile.COM_SING_IMG.getKey()) |
| | | .eq(Multifile::getObjId,company.getId()) |
| | | .last("limit 1")); |
| | | if(f !=null &&StringUtils.isNotBlank(f.getFileurl())){ |
| | | String path = systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode()+systemDictDataBiz.queryByCode(Constants.OSS,Constants.COMPANY_FILE).getCode(); |
| | | String signId = signService.uploadEntSign(company.getName(),path+f.getFileurl(),company.getEmail()); |
| | | Company update = new Company(); |
| | | update.setId(company.getId()); |
| | | if(StringUtils.isNotBlank(signId)){ |
| | | update.setSignIdStatus( Constants.ONE); |
| | | update.setSignId(signId); |
| | | //æ´æ°è®¤è¯ç¶æ |
| | | companyMapper.updateById(update); |
| | | }else{ |
| | | update.setSignIdStatus(Constants.TWO); |
| | | //æ´æ°è®¤è¯ç¶æ |
| | | companyMapper.updateById(update); |
| | | } |
| | | |
| | | } |
| | | |
| | | } |
| | | } |
| | | |
| | | } |
| | | |
| | | @Override |
| | | public List<Company> findList(Company company) { |