package com.ruoyi.system.service.impl; import cn.hutool.crypto.SecureUtil; import cn.hutool.http.HttpRequest; import cn.hutool.http.HttpResponse; import cn.hutool.http.HttpUtil; import com.alibaba.fastjson2.JSON; import com.alibaba.fastjson2.JSONArray; import com.alibaba.fastjson2.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ruoyi.common.core.domain.R; import com.ruoyi.common.core.redis.RedisCache; import com.ruoyi.common.exception.ServiceException; import com.ruoyi.system.domain.*; import com.ruoyi.system.mapper.*; import com.ruoyi.system.pojo.dto.FinanceFlowsDTO; import com.ruoyi.system.pojo.dto.OrderPageDTO; import com.ruoyi.system.pojo.model.DailyStatistics; import com.ruoyi.system.pojo.vo.*; import com.ruoyi.system.service.CompanyTypeService; import com.ruoyi.system.service.OrderService; import com.ruoyi.system.wx.RefundCallbackResult; import com.ruoyi.system.wx.WechatPayService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.security.provisioning.UserDetailsManager; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.math.BigDecimal; import java.time.LocalDate; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.*; import java.util.concurrent.TimeUnit; @Slf4j @Service public class OrderServiceImpl extends ServiceImpl implements OrderService { @Resource private PermitMapper permitMapper; @Resource private OpeningBankMapper openingBankMapper; @Resource private BuyerCompanyInfoMapper buyerCompanyInfoMapper; @Resource private ShareholderMapper shareholderMapper; @Resource private ScheduleMapper scheduleMapper; @Resource private CompanyMapper companyMapper; @Autowired private AppUserMapper appUserMapper; @Resource private RedisCache redisCache; @Resource private QichachaMapper qichachaMapper; @Resource private CompanyTypeService companyTypeService; @Resource private AccountDetailMapper accountDetailMapper; @Override public IPage getOrderPage(OrderPageDTO dto) { IPage page = new Page<>(dto.getPageNum(), dto.getPageSize()); return this.baseMapper.getOrderPage(page,dto); } @Override public OrderDetailVO detail(String id) { OrderDetailVO vo = this.baseMapper.getDetailById(id); if (null == vo) { throw new ServiceException("该公司不存在"); } //许可证集合 List permits = permitMapper.selectList(new LambdaQueryWrapper().eq(Permit::getCompanyId, id)); List permitVOs = new ArrayList<>(); LocalDateTime now = LocalDateTime.now(); for (Permit permit : permits) { DateTimeFormatter dateFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd"); LocalDate expireDate = LocalDate.parse(permit.getExpireTime(), dateFormatter); // 如果需要转为 LocalDateTime（添加默认时间） LocalDateTime expireTime = expireDate.atTime(23,59,59); // 默认00:00:00 if (now.isAfter(expireTime)) { //过滤 未过期的 PermitVO permitVO = new PermitVO(); permitVO.setName(permit.getName()); permitVO.setLevel(permit.getLevel()); permitVOs.add(permitVO); } } vo.setPermitVOList(permitVOs); //开户行信息集合 List openingBanks = openingBankMapper.selectList(new LambdaQueryWrapper().eq(OpeningBank::getCompanyId, id)); List openingBankVOs = new ArrayList<>(); for (OpeningBank openingBank : openingBanks) { OpeningBankVO openingBankVO = new OpeningBankVO(); BeanUtils.copyProperties(openingBank, openingBankVO); openingBankVOs.add(openingBankVO); } vo.setOpeningBankVOList(openingBankVOs); if (vo.getStatus() != 4 && vo.getStatus() != 5&& vo.getStatus() != 6) { return vo; } //状态为办理中和已完成 //客户信息 BuyerCompanyInfo buyerCompanyInfo = buyerCompanyInfoMapper.selectOne(new LambdaQueryWrapper().eq(BuyerCompanyInfo::getOrderId, vo.getOrderId())); copyProperties(vo,buyerCompanyInfo); //股东占比 List shareholders = shareholderMapper.selectList(new LambdaQueryWrapper().eq(Shareholder::getOrderId, vo.getOrderId())); vo.setShareholderList(shareholders); //进度汇报 List schedules = scheduleMapper.selectList(new LambdaQueryWrapper().eq(Schedule::getOrderId, vo.getOrderId())); //构建进度汇报结构 List scheduleVOList = new ArrayList<>(); for (Schedule schedule : schedules) { if (schedule.getParentId() == null) { scheduleVOList.add(schedule); }else { //查找到父类的集合 for (Schedule schedule1 : scheduleVOList) { if (schedule1.getId().equals(schedule.getParentId())) { schedule1.setSchedule(schedule); } } } } vo.setScheduleList(scheduleVOList); return vo; } private static void copyProperties(OrderDetailVO vo,BuyerCompanyInfo info){ vo.setLegalPersonImg(info.getLegalPersonImg()); vo.setNewName(info.getNewName()); vo.setBackupsName(info.getBackupsName()); vo.setBackupsNameOne(info.getBackupsNameOne()); vo.setBackupsNameTwo(info.getBackupsNameTwo()); vo.setNewRegisteredCapital(info.getRegisteredCapital()); vo.setAccount(info.getAccount()); vo.setAddress(info.getAddress()); vo.setPassword(info.getPassword()); vo.setTenancyAgreement(info.getTenancyAgreement()); vo.setPropertyOwnershipCertificate(info.getPropertyOwnershipCertificate()); vo.setBusinessScope(info.getBusinessScope()); } @Override public BusinessVO business(String id) { //先查询数据库中的 Company company = companyMapper.selectById(id); if (null == company || company.getIsDelete() != 0) { throw new ServiceException("公司不存在"); } BusinessVO vo = new BusinessVO(); // 先查企业工商信息 更新数据 JSONObject jsonObject = getQiChaChaBasicDetailsCompany(company.getCompanyName()); company.setOperName(jsonObject.getString("OperName")); company.setBelongOrg(jsonObject.getString("BelongOrg")); company.setRegistrationStatus(jsonObject.getString("Status")); company.setRegisteredCapital(jsonObject.getString("RegisteredCapital")); company.setPaidInFunds(jsonObject.getString("PaidUpCapital")); companyMapper.updateById(company); BeanUtils.copyProperties(company, vo); vo.setNewRegisteredCapital(company.getRealRegisteredCapital()); vo.setPlace(company.getCity()+company.getProvince()+company.getArea()); JSONObject area = jsonObject.getJSONObject("Area"); if (null != area) { vo.setPlace(area.getString("Province")+"-"+area.getString("City")+"-"+area.getString("County")); }else { vo.setPlace(company.getCity() + "-" + company.getProvince() + "-" + company.getArea()); } vo.setCompanyCategoryName(jsonObject.getString("EconKind")); String name = companyTypeService.getById(company.getCompanyCategory()).getName(); vo.setCompanyCategoryName(name); return vo; } @Override public R error(String id) { ErrorVO errorVO = new ErrorVO(); Company company = companyMapper.selectById(id); if (null == company || company.getIsDelete() != 0) { throw new ServiceException("公司不存在"); } JSONObject result = getQiChaChaCompanyExceptionCheck(company.getCompanyName()); if("200".equals(result.get("Status"))){ //查询成功 JSONObject data = (JSONObject) result.get("Result"); Integer verifyResult = (Integer) data.get("VerifyResult"); errorVO.setVerifyResult(verifyResult); if (verifyResult==1){ //该企业有异常数据 JSONArray list = (JSONArray) data.get("Data"); errorVO.setData(list); } return R.ok(errorVO); }else { //查询失败 return R.fail(result.get("Message")); } } /** * 查询工商信息 */ public JSONObject getQiChaChaBasicDetailsCompany(String companyName){ Object cacheObject = redisCache.getCacheObject("qichacha_" +"basic_"+ companyName); if(cacheObject != null){ JSONObject jsonObject = JSONObject.parseObject(cacheObject.toString()); return jsonObject; } String url = "https://api.qichacha.com/ECIV4/GetBasicDetailsByName?key=642987ca3faf4a7daeac70463ae22695&keyword="+companyName; HttpRequest get = HttpUtil.createGet(url); String timeStr = String.valueOf(System.currentTimeMillis() / 1000); get.header("Token", SecureUtil.md5("642987ca3faf4a7daeac70463ae22695"+timeStr+"AC776F2957291EAE3B4161702E89A9F3").toUpperCase()); get.header("Timespan", timeStr); HttpResponse execute = get.execute(); String body = execute.body(); JSONObject jsonObject = JSONObject.parseObject(body); if("200".equals(jsonObject.get("Status"))){ //查询成功 String string = jsonObject.toString(); redisCache.setCacheObject("qichacha_"+"basic_"+companyName,string,24, TimeUnit.HOURS); //统计调用次数 Qichacha qichacha = new Qichacha(); qichacha.setTime(LocalDateTime.now()); qichacha.setType(1);//企业异常查询 qichachaMapper.insert(qichacha); return jsonObject; } return jsonObject; } /** * 经营异常核查 * @param companyName * @return * VerifyResult int 数据是否存在(1-存在，0-不存在) * Data List 数据信息 * Data:[{ * AddReason 列入经营异常名录原因 * AddDate 列入日期 * RomoveReason 移出经营异常名录原因（保留字段） * RemoveDate 移出日期（保留字段） * DecisionOffice 作出决定机关 * RemoveDecisionOffice 移出决定机关（保留字段） * }] * Status * Message * OrderNumber */ public JSONObject getQiChaChaCompanyExceptionCheck(String companyName){ Object cacheObject = redisCache.getCacheObject("qichacha_" + companyName); if(cacheObject != null){ JSONObject jsonObject = JSONObject.parseObject(cacheObject.toString()); return jsonObject; } String url = "https://api.qichacha.com/ExceptionCheck/GetList?key=642987ca3faf4a7daeac70463ae22695&searchKey="+companyName; HttpRequest get = HttpUtil.createGet(url); String timeStr = String.valueOf(System.currentTimeMillis() / 1000); get.header("Token", SecureUtil.md5("642987ca3faf4a7daeac70463ae22695"+timeStr+"AC776F2957291EAE3B4161702E89A9F3").toUpperCase()); get.header("Timespan", timeStr); HttpResponse execute = get.execute(); String body = execute.body(); JSONObject jsonObject = JSONObject.parseObject(body); if("200".equals(jsonObject.get("Status"))){ //查询成功 String string = jsonObject.toString(); redisCache.setCacheObject("qichacha_"+companyName,string,24, TimeUnit.HOURS); //统计调用次数 Qichacha qichacha = new Qichacha(); qichacha.setTime(LocalDateTime.now()); qichacha.setType(2);//企业异常查询 qichachaMapper.insert(qichacha); return jsonObject; } return jsonObject; } private JSONObject getReport(String sign){ Object cacheObject = redisCache.getCacheObject("shuimu_" + sign); if(cacheObject != null){ JSONObject jsonObject = JSONObject.parseObject(cacheObject.toString()); return jsonObject; } HttpRequest post = HttpUtil.createPost("https://shuimui.szsmjr.com/index/index/result"); HashMap stringStringHashMap = new HashMap<>(); stringStringHashMap.put("Origin","https://shuimui.szsmjr.com"); post.addHeaders(stringStringHashMap); post.body("{\"sn\":\""+sign+"\"}"); HttpResponse execute = post.execute(); String body = execute.body(); JSONObject jsonObject = JSONObject.parseObject(body); if("1001".equals(jsonObject.get("code"))){ //查询成功 String string = jsonObject.toString(); redisCache.setCacheObject("shuimu_"+sign,string,1, TimeUnit.MINUTES); return jsonObject; } return jsonObject; } @Override public R change(String id) { // System.err.println(getReport("ZZD20250508017232394218445")); ChangeVO changeVO = new ChangeVO(); Company companyInfo = companyMapper.selectById(id); if (null == companyInfo || companyInfo.getIsDelete() != 0) { throw new ServiceException("公司不存在"); } JSONObject jsonObject=getReport(companyInfo.getLink().split("=")[1]); // JSONObject jsonObject=getReport("ZZD20250508017232394218445"); if (!"1001".equals(jsonObject.getString("code"))){ return R.fail(jsonObject.get("msg")); } JSONObject data1 = (JSONObject) jsonObject.get("data"); JSONObject data2 = (JSONObject) data1.get("data"); JSONObject company = (JSONObject) data2.get("company"); // 银税互动 JSONArray bankAndTaxInteractive = (JSONArray) company.get("bankAndTaxInteractive"); changeVO.setBankAndTaxInteractive(bankAndTaxInteractive); //股东明细 JSONArray sharesRatioList = (JSONArray) company.get("sharesRatioList"); changeVO.setSharesRatioList(sharesRatioList); //法人/股东变更 JSONArray legalPersonGdChange = (JSONArray) company.get("legalPersonGdChange"); changeVO.setLegalPersonGdChange(legalPersonGdChange); return R.ok(changeVO); } @Override public R tax(String id) { TaxVO taxVO = new TaxVO(); Company companyInfo = companyMapper.selectById(id); if (null == companyInfo || companyInfo.getIsDelete() != 0) { throw new ServiceException("公司不存在"); } JSONObject jsonObject=getReport(companyInfo.getLink().split("=")[1]); // JSONObject jsonObject=getReport("ZZD20250508017232394218445"); if (!"1001".equals(jsonObject.getString("code"))){ return R.fail(jsonObject.get("msg")); } JSONObject data1 = (JSONObject) jsonObject.get("data"); JSONObject data2 = (JSONObject) data1.get("data"); JSONObject taxInfo = (JSONObject) data2.get("taxInfo"); //税务处罚 JSONArray enterprise = data2.getJSONArray("enterprise"); taxVO.setEnterprise(enterprise); //滞纳金情况 JSONArray overdueFineDetailsList = (JSONArray) taxInfo.get("overdueFineDetailsList"); taxVO.setOverdueFineDetailsList(overdueFineDetailsList); //近四年纳税信息完税表 JSONArray taxPrev4yearsTaxInfoDict = (JSONArray) taxInfo.get("taxPrev4yearsTaxInfoDict"); taxVO.setTaxPrev4yearsTaxInfoDict(taxPrev4yearsTaxInfoDict); //纳税信用等级 String taxCreditRating = (String) taxInfo.get("taxCreditRating"); taxVO.setTaxCreditRating(taxCreditRating); //纳税人种类 String taxpayerType = (String) taxInfo.get("taxpayerType"); taxVO.setTaxpayerType(taxpayerType); //近12月增税销售额 JSONObject taxPrevMnMthsAllTaxDclrPrjInfoDict = taxInfo.getJSONObject("taxPrevMnMthsAllTaxDclrPrjInfoDict"); if (null != taxPrevMnMthsAllTaxDclrPrjInfoDict){ JSONObject taxPrev12mthsAllTaxDclrPrjInfoDict = taxPrevMnMthsAllTaxDclrPrjInfoDict.getJSONObject("taxPrev12mthsAllTaxDclrPrjInfoDict"); if (null != taxPrev12mthsAllTaxDclrPrjInfoDict){ // 使用 getBigDecimal 方法，自动处理类型转换 BigDecimal vatTaxValue = taxPrev12mthsAllTaxDclrPrjInfoDict.getBigDecimal("vatTaxShouldsaleAmt"); taxVO.setVatTaxShouldsaleAmt12(vatTaxValue); // 自动处理 null } //近24月增税销售额 JSONObject taxPrev24mthsAllTaxDclrPrjInfoDict = taxPrevMnMthsAllTaxDclrPrjInfoDict.getJSONObject("taxPrev24mthsAllTaxDclrPrjInfoDict"); if(null != taxPrev24mthsAllTaxDclrPrjInfoDict){ taxVO.setVatTaxShouldsaleAmt24( (BigDecimal) taxPrev24mthsAllTaxDclrPrjInfoDict.get("vatTaxShouldsaleAmt")); } //近12月增税应纳额(元) taxVO.setVatTaxShouldpay(taxPrev12mthsAllTaxDclrPrjInfoDict.getBigDecimal("vatTaxShouldpay")); } JSONObject taxPrevMnMthsTaxInfoDict = taxInfo.getJSONObject("taxPrevMnMthsTaxInfoDict"); if (null!=taxPrevMnMthsTaxInfoDict){ //近12月纳税总额(元) JSONObject taxPrev12mthsTaxInfo = taxPrevMnMthsTaxInfoDict.getJSONObject("taxPrev12mthsTaxInfo"); taxVO.setTaxAmt12( (BigDecimal) taxPrev12mthsTaxInfo.get("taxAmt")); //近24月纳税总额(元) JSONObject taxPrev24mthsTaxInfo = taxPrevMnMthsTaxInfoDict.getJSONObject("taxPrev24mthsTaxInfo"); if (null != taxPrev24mthsTaxInfo){ taxVO.setTaxAmt24( (BigDecimal) taxPrev24mthsTaxInfo.get("taxAmt")); } } //近12个月滞纳金金额(元) 次数 JSONObject taxPrevMnMthsOverdueFineInfoDict = taxInfo.getJSONObject("taxPrevMnMthsOverdueFineInfoDict"); if (null != taxPrevMnMthsOverdueFineInfoDict){ JSONObject taxPrev12mthsOverdueFineInfo = taxPrevMnMthsOverdueFineInfoDict.getJSONObject("taxPrev12mthsOverdueFineInfo"); if (null!= taxPrev12mthsOverdueFineInfo){ taxVO.setOverdueFineInfoAmt12( (BigDecimal) taxPrev12mthsOverdueFineInfo.get("overdueFineInfoAmt")); taxVO.setOverdueFineInfoCnt12( (Integer) taxPrev12mthsOverdueFineInfo.get("overdueFineInfoCnt")); } // 近3个月滞纳金金额(元) JSONObject taxPrev3mthsOverdueFineInfo = taxPrevMnMthsOverdueFineInfoDict.getJSONObject("taxPrev3mthsOverdueFineInfo"); if (null != taxPrev3mthsOverdueFineInfo){ taxVO.setOverdueFineInfoCnt3( (Integer) taxPrev3mthsOverdueFineInfo.get("overdueFineInfoCnt")); } } //近12月0申报月数（月数） JSONObject taxPrevMnMthsAllTaxDclrInfoDict = taxInfo.getJSONObject("taxPrevMnMthsAllTaxDclrInfoDict"); if (null != taxPrevMnMthsAllTaxDclrInfoDict){ JSONObject taxPrev12mthsAllTaxDclrInfoDict = (JSONObject) taxPrevMnMthsAllTaxDclrInfoDict.get("taxPrev12mthsAllTaxDclrInfoDict"); taxVO.setVatTax0dclrMonCnt( (Integer) taxPrev12mthsAllTaxDclrInfoDict.get("vatTax0dclrMonCnt")); } return R.ok(taxVO); } @Override public R invoice(String id) { InvoiceVO vo = new InvoiceVO(); Company companyInfo = companyMapper.selectById(id); if (null == companyInfo || companyInfo.getIsDelete() != 0) { throw new ServiceException("公司不存在"); } JSONObject jsonObject=getReport(companyInfo.getLink().split("=")[1]); // JSONObject jsonObject=getReport("ZZD20250508017232394218445"); if (!"1001".equals(jsonObject.getString("code"))){ return R.fail(jsonObject.get("msg")); } JSONObject data1 = (JSONObject) jsonObject.get("data"); JSONObject data2 = (JSONObject) data1.get("data"); JSONObject invoiceInfo = (JSONObject) data2.get("invoiceInfo"); //近45日是否有开票记录 vo.setAnyPre45daysFpRcd((Boolean) invoiceInfo.get("anyPre45daysFpRcd")); //近一个月开票金额(元) JSONArray f4yPer1mDownFpInfoList = (JSONArray) invoiceInfo.get("f4yPer1mDownFpInfoList"); JSONObject f4yPer1mDownFpInfo1 = (JSONObject) f4yPer1mDownFpInfoList.get(1); vo.setHjjeZc1( ObjectToBigDecimal(f4yPer1mDownFpInfo1.get("hjjeZc")) ); JSONObject fpPrevMnMthsDownFpInfoList = (JSONObject) invoiceInfo.get("fpPrevMnMthsDownFpInfoList"); JSONObject fpPrev3mthsDownFpInfoList = (JSONObject) fpPrevMnMthsDownFpInfoList.get("fpPrev3mthsDownFpInfoList"); //近3个月开票环比增长率 vo.setAvgMonJshjYxMomRate3( ObjectToBigDecimal(fpPrev3mthsDownFpInfoList.get("avgMonJshjYxMomRate")) ); //近3个月开票金额(元) vo.setHjjeZc3( ObjectToBigDecimal( fpPrev3mthsDownFpInfoList.get("hjjeZc") )); JSONObject fpPrev6mthsDownFpInfoList = (JSONObject) fpPrevMnMthsDownFpInfoList.get("fpPrev6mthsDownFpInfoList"); //近6个月开票环比增长率 vo.setAvgMonJshjYxMomRate6( ObjectToBigDecimal(fpPrev6mthsDownFpInfoList.get("avgMonJshjYxMomRate")) ); //近6月开票金额(元) vo.setHjjeZc6( ObjectToBigDecimal(fpPrev6mthsDownFpInfoList.get("hjjeZc")) ); JSONObject fpPrev12mthsDownFpInfoList = (JSONObject) fpPrevMnMthsDownFpInfoList.get("fpPrev12mthsDownFpInfoList"); //近12个月开票环比增长率 vo.setAvgMonJshjYxMomRate12( ObjectToBigDecimal(fpPrev12mthsDownFpInfoList.get("avgMonJshjYxMomRate")) ); //近12月开票金额(元) vo.setHjjeZc12( ObjectToBigDecimal(fpPrev12mthsDownFpInfoList.get("hjjeZc")) ); //近24个月开票金额(元) JSONObject fpPrev24mthsDownFpInfoList = (JSONObject) fpPrevMnMthsDownFpInfoList.get("fpPrev24mthsDownFpInfoList"); vo.setHjjeZc24( ObjectToBigDecimal(fpPrev24mthsDownFpInfoList.get("hjjeZc") )); //近12个月下游客户统计 vo.setDownCusCnt3( (Integer) fpPrev3mthsDownFpInfoList.get("downCusCnt")); //近12个月下游客户统计 vo.setDownCusCnt12( (Integer) fpPrev12mthsDownFpInfoList.get("downCusCnt")); //近12个月下游开票张数 vo.setKpslQb( (Integer) fpPrev12mthsDownFpInfoList.get("kpslQb")); //近12月作废发票数量占比 vo.setKpslFpRatio(ObjectToBigDecimal(fpPrev12mthsDownFpInfoList.get("kpslFpRatio"))); //近12月月均开票金额增长率 vo.setAvgMonJshjYxYoyRate(ObjectToBigDecimal(fpPrev12mthsDownFpInfoList.get("avgMonJshjYxYoyRate")) ); //近12月红冲发票张数占比 vo.setKpslHpRatio(ObjectToBigDecimal(fpPrev12mthsDownFpInfoList.get("kpslHpRatio"))); //近12个月红冲金额占比 vo.setHjjeHpRatio(ObjectToBigDecimal(fpPrev12mthsDownFpInfoList.get("hjjeHpRatio")) ); //近12个月最大连续未开票间隔天数（销项） vo.setNokpslYxMaxdayCnt((Integer) fpPrev12mthsDownFpInfoList.get("nokpslYxMaxdayCnt")); //近三年开票信息报表（元） vo.setF4yPer1mDownFpInfoList(f4yPer1mDownFpInfoList); return R.ok(vo); } private BigDecimal ObjectToBigDecimal(Object o) { // 处理不同类型的情况 if ( o instanceof BigDecimal) { return (BigDecimal) o; } else if (o instanceof Number) { // 将其他数字类型（如 Integer、Double）转换为 BigDecimal return BigDecimal.valueOf(((Number) o).doubleValue()); } return BigDecimal.ZERO; } @Transactional @Override public void delete(String id) { Company company = companyMapper.selectById(id); if (null == company || company.getIsDelete() != 0) { throw new ServiceException("公司不存在"); } if (company.getStatus().equals(3)){//已完成 throw new ServiceException("状态错误,已完成订单不能删除"); } if (company.getStatus().equals(4)){//锁定中 //查看订单状态是否为待确认 Order order = this.baseMapper.selectOne(new LambdaQueryWrapper() .eq(Order::getCompanyId, company.getId()) .eq(Order::getIsRefund,0) .ne(Order::getStatus,-1));//取消的订单不要 if (null == order) { throw new ServiceException("订单不存在"); } if (!order.getStatus().equals(2)) {//不在待确认状态的 throw new ServiceException("状态错误,不能删除"); } //删除订单 this.baseMapper.deleteById(order.getId()); } //删除公司 company.setIsDelete(1); companyMapper.updateById(company); } /** * 上下架 */ @Override public void shelves(String id) { Company company = companyMapper.selectById(id); if (null == company || company.getIsDelete() != 0) { throw new ServiceException("公司不存在"); } if (company.getStatus().equals(3)){//已完成 throw new ServiceException("状态错误,已完成订单不能修改"); } if (company.getStatus().equals(4)){//锁定中 //查看订单状态是否为待确认 Order order = this.baseMapper.selectOne(new LambdaQueryWrapper() .eq(Order::getCompanyId, company.getId()) .ne(Order::getStatus,-1)//取消的不要 ); if (null == order) { throw new ServiceException("订单不存在"); } if (!order.getStatus().equals(2)) {//不在待确认状态的 throw new ServiceException("状态错误,不能修改"); } //删除订单 this.baseMapper.deleteById(order.getId()); } //上下架 if (company.getStatus().equals(1)||company.getStatus().equals(4)){//1-上架中 4-锁定中（待确认） company.setStatus(2);//2-下架中 }else if (company.getStatus().equals(2)){ company.setStatus(1); } companyMapper.updateById(company); } @Transactional @Override public void cancel(String id) { Company company = companyMapper.selectById(id); if (null == company || company.getIsDelete() != 0) { throw new ServiceException("公司不存在"); } if (!company.getStatus().equals(4)){// 4-锁定中 throw new ServiceException("订单状态错误，不能操作"); } //查看订单 Order order = this.baseMapper.selectOne(new LambdaQueryWrapper() .eq(Order::getCompanyId, company.getId()) .ne(Order::getStatus,-1)); if (null == order) { throw new ServiceException("订单不存在"); } //检查状态 3已确认(未付款) 4办理中 5卖家已完成 if (!order.getStatus().equals(3)&&!order.getStatus().equals(4)&&!order.getStatus().equals(5)) { throw new ServiceException("订单状态错误，不能操作"); } if (order.getStatus().equals(3)){ //未付款 直接取消订单 order.setStatus(-1); this.baseMapper.updateById(order); //将分佣次数加回 User user = appUserMapper.selectById(order.getUserId()); user.setInviteNum(user.getInviteNum()+1); appUserMapper.updateById(user); //商品状态修改 company.setStatus(1); order.setIsRefund(1); order.setRefundTime(LocalDateTime.now()); companyMapper.updateById(company); }else{ // 判断是否能退 if(order.getShareUserId()!=null){ User user = appUserMapper.selectById(order.getShareUserId()); if(user.getBalance().doubleValue()().eq(Order::getOrderNo, result.getOrderNo())); if (null == order || order.getStatus() == -1) { return R.ok(); } order.setStatus(-1); order.setIsRefund(1); order.setRefundTime(LocalDateTime.now()); this.updateById(order); //查找公司 Company company = companyMapper.selectById(order.getCompanyId()); //取消订单 order.setStatus(-1); order.setIsRefund(1); order.setRefundTime(LocalDateTime.now()); this.baseMapper.updateById(order); //将分佣次数加回 User user = appUserMapper.selectById(order.getUserId()); User inviter = appUserMapper.selectById(user.getInviteId()); if (inviter!=null && inviter.getIsDelete()==0){ inviter.setInviteNum(inviter.getInviteNum()+1); appUserMapper.updateById(inviter); } //商品状态修改 company.setStatus(1); companyMapper.updateById(company); return R.ok(); } /** * 返回订单支付金额 */ @Autowired private WechatPayService wechatPayService; @Transactional public R refundPayMoney(Order order) { //开始退款 if (BigDecimal.ZERO.compareTo(order.getPrice()) < 0) {//支付的金额是否大于0 //微信退款 Map map = wechatPayService.refund(order.getOrderNo(), order.getOrderNo(), order.getPrice().toString(), order.getPrice().toString(), "平台取消订单", "/system/order/refundPayMoneyCallback"); if (!"SUCCESS".equals(map.get("return_code"))) { return R.fail(map.get("return_msg"));//退款失败 } } //查找公司 Company company = companyMapper.selectById(order.getCompanyId()); //取消订单 order.setStatus(-1); order.setIsRefund(1); order.setRefundTime(LocalDateTime.now()); this.baseMapper.updateById(order); //将分佣次数加回 User inviter = appUserMapper.selectById(company.getUserId()); if (inviter!=null && inviter.getIsDelete()==0){ inviter.setInviteNum(inviter.getInviteNum()+1); appUserMapper.updateById(inviter); } // 分佣退回 if(order.getShareUserId()!=null && order.getCommissionPrice().doubleValue()>0){ User user = appUserMapper.selectById(order.getShareUserId()); user.setBalance(user.getBalance().subtract(order.getCommissionPrice())); appUserMapper.updateById(user); AccountDetail accountDetail = new AccountDetail(); accountDetail.setUserId(order.getShareUserId()); accountDetail.setType(2); accountDetail.setCategory(4); accountDetail.setSourceId(order.getId()); accountDetail.setMoney(order.getCommissionPrice()); accountDetail.setRemark("订单取消分佣退回"); accountDetailMapper.insert(accountDetail); } //商品状态修改 company.setStatus(1); companyMapper.updateById(company); return R.ok(); } @Override public TodayStatisticsVO today() { LocalDateTime startTime = LocalDate.now().atStartOfDay(); LocalDateTime endTime =LocalDate.now().atTime(23, 59, 59); return this.baseMapper.today(startTime, endTime); } @Override public IndexLineChartVO chart(LocalDate startDate, LocalDate endDate) { // 查询数据库 List statisticsList = this.baseMapper.getDailyStatistics( startDate.atStartOfDay(), endDate.atTime(23, 59, 59) ); // 构建返回对象 IndexLineChartVO vo = new IndexLineChartVO(); vo.setDays(new ArrayList<>()); vo.setTotalList(new ArrayList<>()); vo.setProfitList(new ArrayList<>()); // 按日期顺序填充数据 LocalDate currentDate = startDate; while (!currentDate.isAfter(endDate)) { String dateStr = currentDate.format(DateTimeFormatter.ISO_LOCAL_DATE); vo.getDays().add(currentDate); // 查找当天数据，若无则默认为0 Optional statOptional = statisticsList.stream() .filter(s -> s.getDate().equals(dateStr)) .findFirst(); DailyStatistics stat = statOptional.orElse( new DailyStatistics(dateStr, BigDecimal.ZERO, BigDecimal.ZERO) ); vo.getTotalList().add(stat.getTotalPrice()); vo.getProfitList().add(stat.getPlatformCommission()); currentDate = currentDate.plusDays(1); } return vo; } @Override public FinanceFlowsTopVO financeTop(FinanceFlowsDTO dto) { FinanceFlowsTopVO financeFlowsTopVO = this.baseMapper.financeTop(dto); return financeFlowsTopVO; } @Override public IPage flowsPage(FinanceFlowsDTO dto) { IPage page = new Page<>(dto.getPageNum(), dto.getPageSize()); Long total = this.baseMapper.countFlowsPage(dto); //分页处理 dto.setOffset((dto.getPageNum()-1)*dto.getPageSize()); IPage financeFlowsPageVOIPage = this.baseMapper.flowsPage(page, dto); financeFlowsPageVOIPage.setTotal(total); return financeFlowsPageVOIPage; } }