111

k94314517

2024-01-23 8a7797cf8ba37fa1beec625209a6964a3668b994

111

 server/company/src/main/java/com/doumee/api/business/InsuranceApplyController.java

@@ -76,6 +76,13 @@
        return ApiResponse.success(insuranceApplyService.findPage(pageWrap));
    }

    @ApiOperation("列表")
    @PostMapping("/findListByDTO")
    @RequiresPermissions("business:insuranceapply:query")
    public ApiResponse<List<InsuranceApply>> findListByDTO (@RequestBody InsuranceApplyQueryDTO insuranceApplyQueryDTO) {
        return ApiResponse.success(insuranceApplyService.findListByDTO(insuranceApplyQueryDTO));
    }

    @ApiOperation("导出Excel")
    @PostMapping("/exportExcel")
    @RequiresPermissions("business:insuranceapply:exportExcel")

 server/company/src/main/java/com/doumee/api/business/TaxesController.java

@@ -3,14 +3,20 @@
import com.doumee.api.BaseController;
import com.doumee.core.annotation.excel.ExcelExporter;
import com.doumee.core.annotation.pr.PreventRepeat;
import com.doumee.core.constants.ResponseStatus;
import com.doumee.core.exception.BusinessException;
import com.doumee.core.model.ApiResponse;
import com.doumee.core.model.LoginUserInfo;
import com.doumee.core.model.PageWrap;
import com.doumee.core.model.PageData;
import com.doumee.core.utils.Constants;
import com.doumee.dao.business.dto.EntrustInvoicingDTO;
import com.doumee.dao.business.model.Taxes;
import com.doumee.service.business.TaxesService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.apache.shiro.authz.annotation.RequiresPermissions;    
import org.apache.shiro.SecurityUtils;
import org.apache.shiro.authz.annotation.RequiresPermissions;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletResponse;
@@ -71,7 +77,7 @@
    @PostMapping("/page")
    @RequiresPermissions("business:taxes:query")
    public ApiResponse<PageData<Taxes>> findPage (@RequestBody PageWrap<Taxes> pageWrap) {
        return ApiResponse.success(taxesService.findPage(pageWrap));
        return ApiResponse.success(taxesService.findPageForCompany(pageWrap));
    }

    @ApiOperation("导出Excel")
@@ -81,10 +87,22 @@
        ExcelExporter.build(Taxes.class).export(taxesService.findPage(pageWrap).getRecords(), "发票信息表", response);
    }

    @ApiOperation("根据ID查询")
    @GetMapping("/{id}")
    @ApiOperation("获取企业信息")
    @GetMapping("/getCompanyDetail")
    @RequiresPermissions("business:taxes:query")
    public ApiResponse findById(@PathVariable Integer id) {
        return ApiResponse.success(taxesService.findById(id));
    public ApiResponse getCompanyDetail() {
        LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        if(!loginUserInfo.getType().equals(Constants.ONE)){
            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非企业类用户无法进行该操作");
        }
        return ApiResponse.success(taxesService.findById(loginUserInfo.getCompanyId()));
    }

    @ApiOperation("提交委托投报开票")
    @PostMapping("/entrustInvoicing")
    public ApiResponse entrustInvoicing(@RequestBody EntrustInvoicingDTO entrustInvoicingDTOs) {
        taxesService.entrustInvoicing(entrustInvoicingDTOs);
        return ApiResponse.success(null);
    }

}

 server/service/src/main/java/com/doumee/dao/business/dto/EntrustInvoicingDTO.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,32 @@
package com.doumee.dao.business.dto;

import com.doumee.dao.business.model.TaxDetial;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

import java.math.BigDecimal;
import java.util.List;

/**
 * Created by IntelliJ IDEA.
 *
 * @Author : Rk
 * @create 2024/1/23 16:01
 */
@Data
public class EntrustInvoicingDTO {

    @ApiModelProperty(value = "开票金额")
    private BigDecimal invoicingMoney;

    @ApiModelProperty(value = "接收方式 0电子发票 1纸质发票")
    private Integer type;

    @ApiModelProperty(value = "发票接收地址")
    private String address;

    @ApiModelProperty(value = "投保主键列表" ,notes = "insuranceApplyId ã€ fee  ã€applyCode  ")
    private List<TaxDetial> taxDetialList;


}

 server/service/src/main/java/com/doumee/dao/business/dto/InsuranceApplyQueryDTO.java

@@ -8,8 +8,10 @@
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import org.springframework.format.annotation.DateTimeFormat;

import java.util.Date;
import java.util.List;

/**
 * @author RenKang
@@ -35,13 +37,23 @@
    @ApiModelProperty(value = "单号")
    private String code;

    @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm")
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm")
    @ApiModelProperty(value = "提交日期开始")
    private Date createTimeS;

    @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm")
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm")
    @ApiModelProperty(value = "提交日期结束")
    private Date createTimeE;

    @ApiModelProperty(value = "状态 0待审核 1平台退回保单（已退回） 2已上传代签申请表待企业签章（待签署）  3已签章待上传保险单（待出单） 4保单出具失败退回（已退回） 5已上传保单（保障中）6企业申请退回中 7平台同意退回（已退回） 8企业关闭  ï¼ˆå·²å…³é—­ï¼‰", example = "1")
    private Integer status;

    @ApiModelProperty(value = "类型 0直保 1委托投保")
    private Integer type;

    @ApiModelProperty(value = "主键列表")
    private List<Integer> ids;

}

 server/service/src/main/java/com/doumee/dao/business/join/TaxDetailJoinMapper.java

@@ -1,5 +1,6 @@
package com.doumee.dao.business.join;

import com.doumee.dao.business.model.CompanySolution;
import com.doumee.dao.business.model.TaxDetial;
import com.doumee.dao.business.model.Taxes;
import com.github.yulichang.base.mapper.MPJJoinMapper;
@@ -12,4 +13,5 @@
 */
public interface TaxDetailJoinMapper extends MPJJoinMapper<TaxDetial> {

    void insertBatchSomeColumn(List<TaxDetial> taxDetialList);
}

 server/service/src/main/java/com/doumee/dao/business/join/TaxesJoinMapper.java

@@ -11,5 +11,4 @@
 * @date 2024/01/16 10:03
 */
public interface TaxesJoinMapper extends MPJJoinMapper<Taxes> {
    void insertBatchSomeColumn(List<Taxes> list);
}

 server/service/src/main/java/com/doumee/dao/business/model/InsuranceApply.java

@@ -10,6 +10,7 @@
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import com.fasterxml.jackson.annotation.JsonFormat;
import org.springframework.format.annotation.DateTimeFormat;

import java.math.BigDecimal;
import java.util.Date;
@@ -133,6 +134,17 @@
    @TableField(exist = false)
    private Integer insureNum;

    @ApiModelProperty(value = "开票金额")
    @TableField(exist = false)
    private BigDecimal taxesMoney;

    @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm")
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm")
    @ApiModelProperty(value = "最后一次开票时间")
    @TableField(exist = false)
    private Date taxesLast;


    @ApiModelProperty(value = "服务天数")
    @TableField(exist = false)
    private Integer serviceDays;

 server/service/src/main/java/com/doumee/dao/business/model/Taxes.java

@@ -61,7 +61,7 @@
    private String remark;

    @ApiModelProperty(value = "状态 0待处理 1已开票 2平台撤回 3已冲红", example = "1")
    @ExcelColumn(name="状态 0待处理 1已开票 2平台撤回3已冲红")
    @ExcelColumn(name="状态 0待处理 1已开票 2平台撤回 3已冲红")
    private Integer status;

    @ApiModelProperty(value = "企业编码（关联company）", example = "1")
@@ -121,7 +121,6 @@

    @ApiModelProperty(value = "平台撤回时间")
    @ExcelColumn(name="平台撤回时间")

    private Date cancelDate;

    @ApiModelProperty(value = "撤回备注")
@@ -143,6 +142,9 @@
    @ExcelColumn(name="冲红操作人员编码")
    private Integer  delUserId;

    @ApiModelProperty(value = "单据申请编码（关联insurance_apply）", example = "1")
    @ExcelColumn(name="单据申请编码（关联insurance_apply）")
    private Integer insuranceApplyId;

    @ApiModelProperty(value = "申请人")
    @TableField(exist = false)

 server/service/src/main/java/com/doumee/service/business/InsuranceApplyService.java

@@ -113,5 +113,7 @@

     InsuranceApply  findDetailForExport(InsuranceApply model);

    List<InsuranceApply> findListByDTO(InsuranceApplyQueryDTO model);

    Integer editBaoxiandan(InsuranceApply param);
}

 server/service/src/main/java/com/doumee/service/business/TaxesService.java

@@ -2,6 +2,7 @@

import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.dao.business.dto.EntrustInvoicingDTO;
import com.doumee.dao.business.model.Taxes;
import java.util.List;

@@ -87,6 +88,7 @@
     */
    PageData<Taxes> findPage(PageWrap<Taxes> pageWrap);

    PageData<Taxes> findPageForCompany(PageWrap<Taxes> pageWrap);
    /**
     * æ¡ä»¶ç»Ÿè®¡
     *
@@ -96,5 +98,14 @@
    long count(Taxes taxes);

    void doneApply(Taxes taxes);

    void backApply(Taxes taxes);


    /**
     * å§”托投保提交
     * @param entrustInvoicingDTO
     */
    void entrustInvoicing(EntrustInvoicingDTO entrustInvoicingDTO);

}

 server/service/src/main/java/com/doumee/service/business/impl/InsuranceApplyServiceImpl.java

@@ -551,6 +551,10 @@
        queryWrapper.selectAll(InsuranceApply.class);
        queryWrapper.selectAs(Company::getName,InsuranceApply::getCompanyName);
        queryWrapper.selectAs(Solutions::getName,InsuranceApply::getSolutionsName);
        queryWrapper.select(" ( select sum(td.fee) from taxes ts inner join tax_detial td on ts.TAX_ID = ts.id  where ts.status != 2 and td.INSURANCE_APPLY_ID = t.id ) as taxesMoney");
        queryWrapper.select(" ( select td.CREATE_DATE from taxes ts inner join tax_detial td on ts.TAX_ID = ts.id  where ts.status != 2 and td.INSURANCE_APPLY_ID = t.id order by td.CREATE_DATE desc limit 1 ) as taxesLast ");
        queryWrapper.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId);
        queryWrapper.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId);
        queryWrapper.eq(InsuranceApply::getIsdeleted,Constants.ZERO);
        //企业人员查看本企业数据
        if(loginUserInfo.getType().equals(Constants.ONE)){
@@ -577,7 +581,9 @@
        if (pageWrap.getModel().getCreateTimeE() != null) {
            queryWrapper.le(InsuranceApply::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateTimeE()));
        }

        if (pageWrap.getModel().getType() != null) {
            queryWrapper.eq(Solutions::getType, pageWrap.getModel().getType());
        }
        if (pageWrap.getModel().getCode() != null) {
            queryWrapper.eq(InsuranceApply::getCode, pageWrap.getModel().getCode());
        }
@@ -596,6 +602,59 @@
    }


    @Override
    public List<InsuranceApply> findListByDTO(InsuranceApplyQueryDTO model) {
        LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        MPJLambdaWrapper<InsuranceApply> queryWrapper = new MPJLambdaWrapper<>();
        queryWrapper.selectAll(InsuranceApply.class);
        queryWrapper.selectAs(Company::getName,InsuranceApply::getCompanyName);
        queryWrapper.selectAs(Solutions::getName,InsuranceApply::getSolutionsName);
        queryWrapper.select(" ( select sum(td.fee) from taxes ts inner join tax_detial td on ts.TAX_ID = ts.id  where ts.status != 2 and td.INSURANCE_APPLY_ID = t.id ) as taxesMoney ");
        queryWrapper.select(" ( select td.CREATE_DATE from taxes ts inner join tax_detial td on ts.TAX_ID = ts.id  where ts.status != 2 and td.INSURANCE_APPLY_ID = t.id order by td.CREATE_DATE desc limit 1 ) as taxesLast ");
        queryWrapper.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId);
        queryWrapper.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId);
        queryWrapper.eq(InsuranceApply::getIsdeleted,Constants.ZERO);
        //企业人员查看本企业数据
        if(loginUserInfo.getType().equals(Constants.ONE)){
            queryWrapper.eq(InsuranceApply::getCompanyId, loginUserInfo.getCompanyId());
        }
        if (model.getSolutionId() != null) {
            queryWrapper.eq(InsuranceApply::getSolutionId, model.getSolutionId());
        }
        if (model.getEndTimeS() != null) {
            queryWrapper.ge(InsuranceApply::getEndTime, Utils.Date.getStart(model.getEndTimeS()));
        }
        if (model.getEndTimeE() != null) {
            queryWrapper.le(InsuranceApply::getEndTime, Utils.Date.getEnd(model.getEndTimeE()));
        }
        if (model.getStartTimeS() != null) {
            queryWrapper.ge(InsuranceApply::getStartTime, Utils.Date.getStart(model.getStartTimeS()));
        }
        if (model.getStartTimeE() != null) {
            queryWrapper.le(InsuranceApply::getStartTime, Utils.Date.getEnd(model.getStartTimeE()));
        }
        if (model.getCreateTimeS() != null) {
            queryWrapper.ge(InsuranceApply::getCreateDate, Utils.Date.getStart(model.getCreateTimeS()));
        }
        if (model.getCreateTimeE() != null) {
            queryWrapper.le(InsuranceApply::getCreateDate, Utils.Date.getEnd(model.getCreateTimeE()));
        }
        if (model.getType() != null) {
            queryWrapper.eq(Solutions::getType, model.getType());
        }
        if (model.getCode() != null) {
            queryWrapper.eq(InsuranceApply::getCode, model.getCode());
        }
        if (model.getStatus() != null) {
            queryWrapper.eq(InsuranceApply::getStatus, model.getStatus());
        }
        if (CollectionUtils.isNotEmpty(model.getIds())) {
            queryWrapper.in(InsuranceApply::getId, model.getIds());
        }
        List<InsuranceApply> list = insuranceApplyJoinMapper.selectJoinList(InsuranceApply.class, queryWrapper);
        return list;
    }


    @Override
    public long count(InsuranceApply insuranceApply) {

 server/service/src/main/java/com/doumee/service/business/impl/TaxesServiceImpl.java

@@ -8,8 +8,11 @@
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.TaxDetialMapper;
import com.doumee.dao.business.TaxesMapper;
import com.doumee.dao.business.dto.EntrustInvoicingDTO;
import com.doumee.dao.business.join.InsuranceApplyJoinMapper;
import com.doumee.dao.business.join.TaxDetailJoinMapper;
import com.doumee.dao.business.join.TaxesJoinMapper;
import com.doumee.dao.business.model.*;
@@ -30,6 +33,7 @@
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Objects;

/**
 * å‘票信息表Service实现
@@ -49,6 +53,10 @@
    private TaxDetailJoinMapper taxDetailJoinMapper;
    @Autowired
    private SystemDictDataBiz systemDictDataBiz;
    @Autowired
    private CompanyMapper companyMapper;
    @Autowired
    private InsuranceApplyJoinMapper insuranceApplyJoinMapper;

    @Override
    public Integer create(Taxes taxes) {
@@ -305,4 +313,111 @@
        QueryWrapper<Taxes> wrapper = new QueryWrapper<>(taxes);
        return taxesMapper.selectCount(wrapper);
    }


    @Override
    public PageData<Taxes> findPageForCompany(PageWrap<Taxes> pageWrap) {
        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        IPage<Taxes> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
        MPJLambdaWrapper<Taxes> queryWrapper = new MPJLambdaWrapper<>();
        queryWrapper.selectAll(Taxes.class);
        queryWrapper.selectAs(SystemUser::getRealname,Taxes::getCreatorName);
        queryWrapper.leftJoin(SystemUser.class,SystemUser::getId,Taxes::getCreator);
        Utils.MP.blankToNull(pageWrap.getModel());
        queryWrapper.eq(Taxes::getIsdeleted, Constants.ZERO);
        Taxes queryModel = pageWrap.getModel();
        if(!user.getType().equals(Constants.ONE)){
            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非企业用户无法进行该业务查询");
        }
        if(!Objects.isNull(queryModel)){
            queryWrapper.ge(pageWrap.getModel().getStartDate() != null,Taxes::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getStartDate()));
            queryWrapper.le(SignRecord::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getEndDate()));
            queryWrapper.eq(!Objects.isNull(queryModel.getInsuranceApplyId()),Taxes::getInsuranceApplyId,queryModel.getInsuranceApplyId());
            queryWrapper.eq(!Objects.isNull(queryModel.getStatus()),Taxes::getStatus,queryModel.getStatus());
        }

        queryWrapper.orderByAsc(Taxes::getCreateDate);
        PageData<Taxes>  result =PageData.from(taxesJoinMapper.selectJoinPage(page,Taxes.class, queryWrapper));
        if(result!=null && result.getRecords()!=null){
            String path =systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode()+systemDictDataBiz.queryByCode(Constants.OSS,Constants.TAXES_FILE).getCode();
            for(Taxes t : result.getRecords()){
                if(StringUtils.isNotBlank(t.getImgurl())){
                    t.setImgurlFull(path + t.getImgurl());
                }
            }
        }
        return result;
    }





    @Override
    @Transactional(rollbackFor = {BusinessException.class,Exception.class})
    public void entrustInvoicing(EntrustInvoicingDTO entrustInvoicingDTO){
        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        if(Objects.isNull(entrustInvoicingDTO)
            || Objects.isNull(entrustInvoicingDTO.getInvoicingMoney())
            || Objects.isNull(entrustInvoicingDTO.getType())
            || Objects.isNull(entrustInvoicingDTO.getTaxDetialList())
            || StringUtils.isNotBlank(entrustInvoicingDTO.getAddress())
        ){
            throw new BusinessException(ResponseStatus.BAD_REQUEST);
        }
        if(!user.getType().equals(Constants.ONE)){
            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非企业用户无法进行该业务查询");
        }
        Company company = companyMapper.selectById(user.getCompanyId());
        if(Objects.isNull(company)){
            throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到企业信息");
        }
        Taxes taxes = new Taxes();
        taxes.setCreator(user.getId());
        taxes.setCreateDate(new Date());
        taxes.setIsdeleted(Constants.ZERO);
        taxes.setStatus(Constants.ZERO);
        taxes.setCompanyId(company.getId());
        taxes.setPrice(entrustInvoicingDTO.getInvoicingMoney());
        taxes.setType(entrustInvoicingDTO.getType());
        taxes.setTaxCode(company.getTaxCode());
        taxes.setTaxAccount(company.getTaxAccount());
        taxes.setTaxAddr(company.getTaxAddr());
        taxes.setAddr(entrustInvoicingDTO.getAddress());
        taxes.setCompanyName(company.getName());
        taxes.setApplyType(Constants.ZERO);
        taxesMapper.insert(taxes);

        List<TaxDetial> taxDetialList = entrustInvoicingDTO.getTaxDetialList();
        for (TaxDetial taxDetial:taxDetialList) {
            if(Objects.isNull(taxDetial)
                    || Objects.isNull(taxDetial.getInsuranceApplyId())
                    || Objects.isNull(taxDetial.getFee())
            ){
                throw new BusinessException(ResponseStatus.BAD_REQUEST);
            }
            //查询每个保单下可以投保的金额
            InsuranceApply insuranceApply = insuranceApplyJoinMapper.selectJoinOne(InsuranceApply.class,new MPJLambdaWrapper<InsuranceApply>()
                    .selectAll(InsuranceApply.class)
                    .select(" ( select sum(td.fee) from taxes ts inner join tax_detial td on ts.TAX_ID = ts.id  where ts.status != 2 and td.INSURANCE_APPLY_ID = t.id ) as taxesMoney ")
                    .eq(InsuranceApply::getId,taxDetial.getInsuranceApplyId())
            );
            if(Objects.isNull(insuranceApply)){
                throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"保单号【"+taxDetial.getApplyCode()+"】未查询到保单信息");
            }
            if(insuranceApply.getCurrentFee().subtract(insuranceApply.getTaxesMoney()).compareTo(taxDetial.getFee())!=Constants.ZERO){
                throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"保单号【"+taxDetial.getApplyCode()+"】可报销金额错误【"+insuranceApply.getCurrentFee().subtract(insuranceApply.getTaxesMoney())+"】");
            }
            taxDetial.setCreator(user.getId());
            taxDetial.setCreateDate(new Date());
            taxDetial.setIsdeleted(Constants.ZERO);
            taxDetial.setTaxId(taxes.getId());
            taxDetial.setTotalFee(insuranceApply.getCurrentFee());
            taxDetial.setType(Constants.ZERO);
        }
        taxDetailJoinMapper.insertBatchSomeColumn(taxDetialList);
    }



}