From 3414e42ae766b0457a03fb97995abf07e2d074c2 Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期四, 18 一月 2024 10:38:46 +0800
Subject: [PATCH] 调整
---
server/service/src/main/java/com/doumee/service/business/impl/CompanyServiceImpl.java | 507 +++++++++++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 496 insertions(+), 11 deletions(-)
diff --git a/server/service/src/main/java/com/doumee/service/business/impl/CompanyServiceImpl.java b/server/service/src/main/java/com/doumee/service/business/impl/CompanyServiceImpl.java
index 0204f3e..641ceeb 100644
--- a/server/service/src/main/java/com/doumee/service/business/impl/CompanyServiceImpl.java
+++ b/server/service/src/main/java/com/doumee/service/business/impl/CompanyServiceImpl.java
@@ -1,5 +1,6 @@
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;
@@ -7,22 +8,32 @@
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.*;
/**
* 浼佷笟淇℃伅琛⊿ervice瀹炵幇
@@ -35,18 +46,294 @@
@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
@@ -62,14 +349,71 @@
}
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
@@ -84,7 +428,49 @@
@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
@@ -92,6 +478,105 @@
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) {
--
Gitblit v1.9.3