From 1ad2f74f3c8c6872d57c285809d2384bd3946aa3 Mon Sep 17 00:00:00 2001 From: renkang <8417338+k94314517@user.noreply.gitee.com> Date: 星期一, 13 一月 2025 09:16:35 +0800 Subject: [PATCH] 客户资料 巡检任务业务 --- server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwContractBillServiceImpl.java | 283 ++++++++++++++++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 273 insertions(+), 10 deletions(-) diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwContractBillServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwContractBillServiceImpl.java index 5d59968..e941edb 100644 --- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwContractBillServiceImpl.java +++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwContractBillServiceImpl.java @@ -2,6 +2,7 @@ import com.doumee.biz.system.SystemDictDataBiz; import com.doumee.core.constants.ResponseStatus; +import com.doumee.core.excel.ExcelReplaceCommon; import com.doumee.core.exception.BusinessException; import com.doumee.core.model.LoginUserInfo; import com.doumee.core.model.PageData; @@ -10,6 +11,7 @@ import com.doumee.core.utils.DateUtil; import com.doumee.core.utils.Utils; import com.doumee.dao.business.*; +import com.doumee.dao.business.dto.YwSmsEmailBillCallDTO; import com.doumee.dao.business.model.*; import com.doumee.dao.business.vo.YwContractBillCallDataVO; import com.doumee.dao.business.vo.YwContractBillDataVO; @@ -22,13 +24,18 @@ import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.github.yulichang.wrapper.MPJLambdaWrapper; +import lombok.extern.java.Log; import org.apache.commons.lang3.StringUtils; import org.checkerframework.checker.units.qual.C; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; +import javax.servlet.http.HttpServletResponse; +import java.io.File; import java.math.BigDecimal; +import java.net.URLEncoder; +import java.nio.charset.Charset; import java.util.*; import java.util.stream.Collectors; @@ -61,6 +68,8 @@ @Autowired private MemberMapper memberMapper; + @Autowired + private YwTempConfigMapper ywTempConfigMapper; @Override @@ -642,6 +651,7 @@ ){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"璐﹀崟鏁版嵁閿欒锛岃鍒锋柊閲嶈瘯"); } + this.dealRoomDetail(ywContractBillList); for (YwContractBill ywContractBill:ywContractBillList) { YwContractBillCallDataVO ywContractBillCallDataVO = new YwContractBillCallDataVO(); ywContractBillCallDataVO.setBillId(ywContractBill.getId()); @@ -658,16 +668,269 @@ } - public void downloadCallFeeDoc(List<Integer> billIds){ - List<YwContractBill> ywContractBillList = ywContractBillMapper.selectJoinList(YwContractBill.class,new MPJLambdaWrapper<YwContractBill>() - .selectAll(YwContractBill.class) - .selectAs(YwCustomer::getName,YwContractBill::getCustomerName) - .selectAs(YwCustomer::getUserId,YwContractBill::getCustomerUserId) - .selectAs(YwCustomer::getId,YwContractBill::getCustomerId) - .leftJoin(YwContract.class,YwContract::getId,YwContractBill::getContractId) - .leftJoin(YwCustomer.class,YwCustomer::getId,YwContract::getRenterId) - .in(YwContractBill::getId,billIds) - ); + @Override + public void downloadCallFeeDoc(List<Integer> billIds, LoginUserInfo loginUserInfo,HttpServletResponse response){ + try { + List<YwContractBill> ywContractBillList = ywContractBillMapper.selectJoinList(YwContractBill.class,new MPJLambdaWrapper<YwContractBill>() + .selectAll(YwContractBill.class) + .selectAs(YwCustomer::getName,YwContractBill::getCustomerName) + .selectAs(YwCustomer::getUserId,YwContractBill::getCustomerUserId) + .selectAs(YwCustomer::getId,YwContractBill::getCustomerId) + .selectAs(YwContractDetail::getPrice,YwContractBill::getPrice) + .selectAs(YwContract::getCompanyId,YwContractBill::getCompanyId) + .selectAs(YwContractDetail::getCircleType,YwContractBill::getCircleType) + .selectAs(YwContractDetail::getType,YwContractBill::getDetailType) + .selectAs(YwContract::getZlPayType,YwContractBill::getZlPayType) + .selectAs(YwContract::getWyPayType,YwContractBill::getWyPayType) + .select(" ( select ifnull(sum(r.rent_area),0) from yw_room y left join yw_contract_room yr on y.id = yr.room_id where yr.contract_id = t.contract_id and y.IS_INVESTMENT = 0 and yr.type = 0 ) " , YwContractBill::getTotalArea) + .leftJoin(YwContract.class,YwContract::getId,YwContractBill::getContractId) + .leftJoin(YwCustomer.class,YwCustomer::getId,YwContract::getRenterId) + .leftJoin(YwContractDetail.class,YwContractDetail::getId,YwContractBill::getDetailId) + .in(YwContractBill::getId,billIds) + ); + List<YwTempConfig> ywTempConfigList = ywTempConfigMapper.selectList(new QueryWrapper<YwTempConfig>().lambda().eq(YwTempConfig::getIsdeleted,Constants.ZERO)); + if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isEmpty(ywTempConfigList)){ + throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鏈煡璇㈠埌妯℃澘閰嶇疆椤�,璇疯仈绯荤鐞嗗憳"); + } + List<YwTempConfig> tempList = ywTempConfigList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.FOUR)|| + Constants.equalsInteger(i.getType(),Constants.FIVE)|| + Constants.equalsInteger(i.getType(),Constants.SIX)).collect(Collectors.toList()); + if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isEmpty(tempList)){ + throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鏈煡璇㈠埌妯℃澘閰嶇疆椤�,璇疯仈绯荤鐞嗗憳"); + } + List<File> fileList = new ArrayList<>(); + for (YwContractBill ywContractBill:ywContractBillList) { + this.dealTempData(tempList,ywContractBill,loginUserInfo); + String fileName = "鍌垂閫氱煡鍗昣" +ywContractBill.getCode() +"_" + System.currentTimeMillis()+".docx"; + YwTempConfig ywTempConfig = new YwTempConfig(); + if(Constants.equalsInteger(ywContractBill.getType(),Constants.ZERO)){ + Optional<YwTempConfig> optional = ywTempConfigList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.TWO)).findAny(); + if (optional.isPresent()) { + ywTempConfig = optional.get(); + } + }else{ + Optional<YwTempConfig> optional = ywTempConfigList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.THREE)).findAny(); + if (optional.isPresent()) { + ywTempConfig = optional.get(); + } + } + if(Objects.isNull(ywTempConfig)){ + throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"妯℃澘淇℃伅寮傚父,璇疯仈绯荤鐞嗗憳"); + } + String path = ExcelReplaceCommon.modifyWordTemplate(ywTempConfig.getUrl(),tempList,fileName); + File f = new File(path); + if(f !=null && f.isFile()){ + fileList.add(f); + } + if(fileList == null || fileList.size() == 0){ + throw new BusinessException(ResponseStatus.DATA_EMPTY); + } + } + String fileName = "鍌垂閫氱煡鍗�-" +System.currentTimeMillis(); + String encodeFileName = URLEncoder.encode(fileName, Charset.forName("UTF-8").toString())+".zip"; + response.setHeader("Content-Disposition","attachment;filename=" + encodeFileName); + response.setContentType("application/octet-stream"); + response.setHeader("eva-opera-type", "download"); + response.setHeader("eva-download-filename", encodeFileName); + Constants.packFilesToZip(fileList,response.getOutputStream()); + } catch (Exception e) { + throw new BusinessException(ResponseStatus.EXPORT_EXCEL_ERROR, e); + } } + + public void dealTempData(List<YwTempConfig> ywTempConfigList , YwContractBill ywContractBill, LoginUserInfo loginUserInfo){ + //鏌ヨ鏀舵敮璐﹀彿鏁版嵁 + + for (YwTempConfig y:ywTempConfigList) { + if(y.getTitle().equals("${璐圭敤鍚嶇О}")&&Objects.nonNull(ywContractBill.getCostType())){ + //璐圭敤绫诲瀷锛�0=绉熻祦璐癸紱1=鐗╀笟璐癸紱2=绉熻祦鎶奸噾锛�3=鐗╀笟鎶奸噾锛�4=姘寸數璐癸紱5=鏉傞」璐癸紱6=鍏朵粬; 7=淇濊瘉閲� + if(Constants.equalsInteger(ywContractBill.getCostType(),Constants.ZERO)){ + y.setUrl("绉熻祦璐�"); + }else if(Constants.equalsInteger(ywContractBill.getCostType(),Constants.ONE)){ + y.setUrl("鐗╀笟璐�"); + }else if(Constants.equalsInteger(ywContractBill.getCostType(),Constants.TWO)){ + y.setUrl("绉熻祦鎶奸噾"); + }else if(Constants.equalsInteger(ywContractBill.getCostType(),Constants.THREE)){ + y.setUrl("鐗╀笟鎶奸噾"); + }else if(Constants.equalsInteger(ywContractBill.getCostType(),Constants.FOUR)){ + y.setUrl("姘寸數璐�"); + }else if(Constants.equalsInteger(ywContractBill.getCostType(),Constants.FIVE)){ + y.setUrl("鏉傞」璐�"); + }else if(Constants.equalsInteger(ywContractBill.getCostType(),Constants.SIX)){ + y.setUrl("鍏朵粬"); + }else if(Constants.equalsInteger(ywContractBill.getCostType(),Constants.SEVEN)){ + y.setUrl("淇濊瘉閲�"); + } + }else if(y.getTitle().equals("${璁¤垂鍛ㄦ湡}")&&Objects.nonNull(ywContractBill.getDetailType())){ + if(Constants.equalsInteger(ywContractBill.getDetailType(),Constants.ZERO)){ + //绉熻祦鏀粯鏂瑰紡 0=涓�娆℃�т粯娆撅紱1=姣忎笁涓湀涓�浠橈紱2=鍏釜鏈堜竴浠橈紱3=涓�骞翠竴浠� + if(Objects.nonNull(ywContractBill.getZlPayType())){ + if(Constants.equalsInteger(ywContractBill.getZlPayType(),Constants.ZERO)){ + y.setUrl("涓�娆℃�т粯娆�"); + }else if(Constants.equalsInteger(ywContractBill.getZlPayType(),Constants.ONE)){ + y.setUrl("姣忎笁涓湀涓�浠�"); + }else if(Constants.equalsInteger(ywContractBill.getZlPayType(),Constants.TWO)){ + y.setUrl("鍏釜鏈堜竴浠�"); + }else if(Constants.equalsInteger(ywContractBill.getZlPayType(),Constants.THREE)){ + y.setUrl("涓�骞翠竴浠�"); + } + } + }else{ + //鐗╀笟鏀粯鏂瑰紡 0=涓�娆℃�т粯娆撅紱1=姣忎笁涓湀涓�浠橈紱2=鍏釜鏈堜竴浠橈紱3=涓�骞翠竴浠� + if(Objects.nonNull(ywContractBill.getWyPayType())){ + if(Constants.equalsInteger(ywContractBill.getWyPayType(),Constants.ZERO)){ + y.setUrl("涓�娆℃�т粯娆�"); + }else if(Constants.equalsInteger(ywContractBill.getWyPayType(),Constants.ONE)){ + y.setUrl("姣忎笁涓湀涓�浠�"); + }else if(Constants.equalsInteger(ywContractBill.getWyPayType(),Constants.TWO)){ + y.setUrl("鍏釜鏈堜竴浠�"); + }else if(Constants.equalsInteger(ywContractBill.getWyPayType(),Constants.THREE)){ + y.setUrl("涓�骞翠竴浠�"); + } + } + } + }else if(y.getTitle().equals("${鍗曚环}")&&Objects.nonNull(ywContractBill.getPrice())){ + y.setUrl(ywContractBill.getPrice().toString()); + }else if(y.getTitle().equals("${鍗曚綅}")&&Objects.nonNull(ywContractBill.getCircleType())){ + //浠樻鍛ㄦ湡绫诲瀷 0=鍏冩瘡骞崇背澶�;1=鍏冩瘡骞崇背鏈�;2=鍏冩瘡骞崇背骞�;3=鍏冩瘡澶�;4=鍏冩瘡鏈�;5=鍏冩瘡骞�;6=鍏冩瘡鍦�; + if(Constants.equalsInteger(ywContractBill.getCircleType(),Constants.ZERO)){ + y.setUrl("鍏冩瘡骞崇背澶�"); + }else if(Constants.equalsInteger(ywContractBill.getCircleType(),Constants.ONE)){ + y.setUrl("鍏冩瘡骞崇背鏈�"); + }else if(Constants.equalsInteger(ywContractBill.getCircleType(),Constants.ONE)){ + y.setUrl("鍏冩瘡骞崇背骞�"); + } else if(Constants.equalsInteger(ywContractBill.getCircleType(),Constants.ONE)){ + y.setUrl("鍏冩瘡澶�"); + } else if(Constants.equalsInteger(ywContractBill.getCircleType(),Constants.ONE)){ + y.setUrl("鍏冩瘡鏈�"); + } else if(Constants.equalsInteger(ywContractBill.getCircleType(),Constants.ONE)){ + y.setUrl("鍏冩瘡骞�"); + } else if(Constants.equalsInteger(ywContractBill.getCircleType(),Constants.ONE)){ + y.setUrl("鍏冩瘡鍦�"); + } + }else if(y.getTitle().equals("${搴旀敹鏃ユ湡}")&&Objects.nonNull(ywContractBill.getPlanPayDate())){ + y.setUrl(DateUtil.formatDate(ywContractBill.getPlanPayDate(),"yyyy-MM-dd")); + }else if(y.getTitle().equals("${搴旀敹閲戦}")&&Objects.nonNull(ywContractBill.getReceivableFee())){ + y.setUrl(ywContractBill.getReceivableFee().toString()); + }else if(y.getTitle().equals("${璐﹀崟澶囨敞}")){ + if(StringUtils.isNotBlank(ywContractBill.getRemark())){ + y.setUrl(ywContractBill.getRemark()); + }else{ + y.setUrl(""); + } + }else if(y.getTitle().equals("${绉熷鍚嶇О}")&&StringUtils.isNotBlank(ywContractBill.getCustomerName())){ + y.setUrl(ywContractBill.getCustomerName()); + }else if(y.getTitle().equals("${妤煎畤/妤煎眰/鎴挎簮}")){ + if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ywContractBill.getYwContractRoomList())){ + StringBuilder roomPathName = new StringBuilder(); + for (YwContractRoom ywContractRoom:ywContractBill.getYwContractRoomList()) { + if(StringUtils.isNotBlank(ywContractRoom.getProjectName())){ + roomPathName.append(ywContractRoom.getProjectName()+"/"); + } + if(StringUtils.isNotBlank(ywContractRoom.getBuildingName())){ + roomPathName.append(ywContractRoom.getBuildingName()+"/"); + } + if(StringUtils.isNotBlank(ywContractRoom.getFloorName())){ + roomPathName.append(ywContractRoom.getFloorName()+"/"); + } + if(StringUtils.isNotBlank(ywContractRoom.getRoomName())){ + roomPathName.append(ywContractRoom.getRoomName()); + } + if(StringUtils.isNotBlank(roomPathName)){ + roomPathName.append(";"); + } + } + y.setUrl(roomPathName.toString()); + } + }else if(y.getTitle().equals("${绉熻祦闈㈢Н}")&&Objects.nonNull(ywContractBill.getTotalArea())){ + y.setUrl(ywContractBill.getTotalArea().toString()); + }else if(y.getTitle().equals("${鎵�灞炲叕鍙歌处鎴峰悕绉皚")){ + y.setUrl("鎵�灞炲叕鍙歌处鎴峰悕绉�"); + }else if(y.getTitle().equals("${鎵�灞炲叕鍙搁摱琛岃处鍙穧")){ + y.setUrl("鎵�灞炲叕鍙搁摱琛岃处鍙�"); + }else if(y.getTitle().equals("${鎵�灞炲叕鍙稿紑鎴烽摱琛寎")){ + y.setUrl("鎵�灞炲叕鍙稿紑鎴烽摱琛�"); + }else if(y.getTitle().equals("${閫氱煡鍗曠敓鎴愭棩鏈焳")){ + y.setUrl(DateUtil.formatDate(new Date(),"yyyy-MM-dd")); + }else if(y.getTitle().equals("${褰撳墠鐢ㄦ埛濮撳悕}")){ + y.setUrl(loginUserInfo.getRealname()); + } + } + } + + + public void sendSmsEmail(List<YwSmsEmailBillCallDTO> ywSmsEmailBillCallDTOList,LoginUserInfo loginUserInfo){ + if(CollectionUtils.isEmpty(ywSmsEmailBillCallDTOList)){ + throw new BusinessException(ResponseStatus.BAD_REQUEST); + } + List<YwTempConfig> ywTempConfigList = ywTempConfigMapper.selectList(new QueryWrapper<YwTempConfig>().lambda().eq(YwTempConfig::getIsdeleted,Constants.ZERO)); + if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isEmpty(ywTempConfigList)){ + throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鏈煡璇㈠埌妯℃澘閰嶇疆椤�,璇疯仈绯荤鐞嗗憳"); + } + List<YwTempConfig> tempList = ywTempConfigList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.FOUR)|| + Constants.equalsInteger(i.getType(),Constants.FIVE)|| + Constants.equalsInteger(i.getType(),Constants.SIX)).collect(Collectors.toList()); + if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isEmpty(tempList)){ + throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鏈煡璇㈠埌妯℃澘閰嶇疆椤�,璇疯仈绯荤鐞嗗憳"); + } + for (YwSmsEmailBillCallDTO ywSmsEmailBillCallDTO:ywSmsEmailBillCallDTOList) { + if(Objects.isNull(ywSmsEmailBillCallDTO) + || Objects.isNull(ywSmsEmailBillCallDTO.getBillId()) + || Objects.isNull(ywSmsEmailBillCallDTO.getUserId()) + ||Objects.isNull(ywSmsEmailBillCallDTO.getSendEmail()) + || Objects.isNull(ywSmsEmailBillCallDTO.getSendSms())){ + throw new BusinessException(ResponseStatus.BAD_REQUEST); + } + + YwContractBill ywContractBill = ywContractBillMapper.selectJoinOne(YwContractBill.class,new MPJLambdaWrapper<YwContractBill>() + .selectAll(YwContractBill.class) + .selectAs(YwCustomer::getName,YwContractBill::getCustomerName) + .selectAs(YwCustomer::getUserId,YwContractBill::getCustomerUserId) + .selectAs(YwCustomer::getId,YwContractBill::getCustomerId) + .selectAs(YwContractDetail::getPrice,YwContractBill::getPrice) + .selectAs(YwContract::getCompanyId,YwContractBill::getCompanyId) + .selectAs(YwContractDetail::getCircleType,YwContractBill::getCircleType) + .selectAs(YwContractDetail::getType,YwContractBill::getDetailType) + .selectAs(YwContract::getZlPayType,YwContractBill::getZlPayType) + .selectAs(YwContract::getWyPayType,YwContractBill::getWyPayType) + .select(" ( select ifnull(sum(r.rent_area),0) from yw_room y left join yw_contract_room yr on y.id = yr.room_id where yr.contract_id = t.contract_id and y.IS_INVESTMENT = 0 and yr.type = 0 ) " , YwContractBill::getTotalArea) + .leftJoin(YwContract.class,YwContract::getId,YwContractBill::getContractId) + .leftJoin(YwCustomer.class,YwCustomer::getId,YwContract::getRenterId) + .leftJoin(YwContractDetail.class,YwContractDetail::getId,YwContractBill::getDetailId) + .eq(YwContractBill::getId,ywSmsEmailBillCallDTO.getBillId()) + .last( "limit 1" ) + ); + this.dealTempData(tempList,ywContractBill,loginUserInfo); + Member member = memberMapper.selectById(ywSmsEmailBillCallDTO.getUserId()); + if(Objects.isNull(member)){ + throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"瀛樺湪鏈煡璇㈠埌鐨勪汉鍛樹俊鎭�"); + } + + + } + + + for (YwSmsEmailBillCallDTO ywSmsEmailBillCallDTO:ywSmsEmailBillCallDTOList) { + + + + + + } + + + + + + + + + + + + } + + + } -- Gitblit v1.9.3