java-insagent-pc/src/main/java/com/ydtech/modules/admin/controller/SysUserAccountController.java

package com.ydtech.modules.admin.controller;


import com.baomidou.mybatisplus.core.metadata.IPage;
import com.ydtech.core.page.HttpResult;
import com.ydtech.modules.admin.model.dto.*;
import com.ydtech.modules.admin.model.po.SysUserAccount;
import com.ydtech.modules.admin.model.vo.SubOrder;
import com.ydtech.modules.admin.model.vo.SysUserAccountVo;
import com.ydtech.modules.admin.service.SysUserAccountService;
import com.ydtech.modules.base.controller.BaseController;
import com.ydtech.modules.order.entity.BasePageResult;
import com.ydtech.utils.ExcelUtils;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.*;

import javax.validation.Valid;
import java.math.BigDecimal;
import java.util.List;

@Api(tags = "账户余额")
@RequestMapping("/sysUserAccount")
@RestController
public class SysUserAccountController extends BaseController {
    @Autowired
    private SysUserAccountService sysUserAccountService;

    @Value("${upload.file.path}")
    private String uploadPath;

    private String EXCEL_PATH = "excel//";

    private String UPLOAD_PATH = "/upload//excel//";

    @PostMapping("/queryPage")
    @ApiOperation(value = "用户账户表分页")
    public HttpResult<BasePageResult<SysUserAccount>> queryPageOrder(@RequestBody @Valid SysUserAccountVo sysUserAccountVo ) {
        BasePageResult<SysUserAccount> result = sysUserAccountService.queryByVo(sysUserAccountVo);
        return HttpResult.ok("success", result);
    }

    @PostMapping("/queryPageList")
    @ApiOperation(value = "用户账户表分页2")
    public HttpResult<IPage<SysUserAccount>> queryPageList(@RequestBody SysUserAccountVo sysUserAccountVo ) {
            IPage<SysUserAccount> result = sysUserAccountService.queryByVo1(sysUserAccountVo);
        return HttpResult.ok("success", result);
    }


    @PostMapping("/insert")
    @ApiOperation("提交")
    public HttpResult<Object> submit(@RequestBody SysUserAccountVo sysUserAccountVo) {
        return sysUserAccountService.inert(sysUserAccountVo);
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/19 8:52
     *  @Description:  提现
     */
    @PostMapping("/withdraw")
    @ApiOperation("提现")
    public HttpResult withdraw(@RequestBody SysUserAccountVo sysUserAccountVo) {
        return sysUserAccountService.withdraw(sysUserAccountVo);
    }

    @GetMapping(value = "/getSysUserAmount")
    @ApiOperation("用户账户余额")
    public HttpResult<SysUserAccount> getSysUserAmount(@RequestParam String userid) {
        return HttpResult.ok(sysUserAccountService.getSysUserAmount(userid));
    }

    @GetMapping(value = "/getSysAllAmount")
    @ApiOperation("用户余额new")
    public HttpResult<SysUserAccountVo>  getSysAllAmount (){
        String   userId = BaseController.getUser().getId();
        SysUserAccountVo result = sysUserAccountService.getSysAllAmount(userId);
        return  HttpResult.ok("success", result);
    }
    @PostMapping("getInsOrders")
    @ApiOperation("获取预收实收列表数据")
    public HttpResult<SysUserAccountVo>  getInsOrders(@RequestBody SysUserAccountVo sysUserAccountVo){

        if(StringUtils.isBlank(sysUserAccountVo.getAmountType())){
            return HttpResult.error("金额类型（手续费金额1跟单金额2推广金额3）amountType不能为空");
        }
        //预收实收类型
        if(StringUtils.isBlank(sysUserAccountVo.getSearchType())){
            return HttpResult.error("预收实收类型（预收1实收2）searchType不能为空");
        }
        //查询时间
        if(StringUtils.isBlank(sysUserAccountVo.getTimeFiltering())){
            return HttpResult.error("查询时间timeFiltering不能为空");
        }
        try{
            SysUserAccountVo result =sysUserAccountService.getInsOrders(sysUserAccountVo);
            return  HttpResult.ok("success", result);
        }catch (Exception e){
            return HttpResult.error("查询失败"+e.getMessage());
        }
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/3 15:03
     *  @Description: 通过子订单编号查询订单的详情页面
     */
    @GetMapping("getSubOrderDetails")
    @ApiOperation("获取推广费订单详情")
    public HttpResult<SubOrder>  getSubOrderDetails(String subOrderId){
        if(StringUtils.isBlank(subOrderId)){
            return HttpResult.error("订单号subOrderId不能为空");
        }
        try{
            SubOrder subOrder =sysUserAccountService.getSubOrderDetails(subOrderId,BaseController.getUser().getId());
            return  HttpResult.ok("success", subOrder);
        }catch (Exception e){
            return HttpResult.error("操作失败"+e.getMessage());
        }
    }

    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/19 9:00
     *  @Description: 查询我的账户金额
     */
    @GetMapping("getUserSumAmountByUserId")
    @ApiOperation("查询我的账户总金额")
    public HttpResult<BigDecimal>  getUserSumAmountByUserId(String userId){
        try{
            BigDecimal sumAmount  =sysUserAccountService.getUserSumAmountByUserId(userId);
            return  HttpResult.ok("success", sumAmount);
        }catch (Exception e){
            return HttpResult.error("操作失败"+e.getMessage());
        }
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/19 9:14
     *  @Description: 查询我的预收明细
     */
    @PostMapping("findMyCollectInAdvanceByUserId")
    @ApiOperation("查询我的预收明细")
    public HttpResult<MyCollectInAdvanceAllDto>  findMyCollectInAdvanceByUserId(@RequestBody MyCollectInAdvanceQueryDto myCollectInAdvanceQueryDto){
       return  HttpResult.ok(sysUserAccountService.findMyCollectInAdvanceByUserId(myCollectInAdvanceQueryDto));
    }

    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/19 9:14
     *  @Description: 查询我的预收的数据
     */
    @PostMapping("findMyIncomeAndExpensesByUserId")
    @ApiOperation("查询我的收支明细")
    public HttpResult<MyCollectInAdvanceAllDto>  findIncomeAndExpensesByUserId(@RequestBody MyIncomeAndExpensesQueryDto myIncomeAndExpensesQueryDto){
      return  HttpResult.ok(sysUserAccountService.findIncomeAndExpensesByUserId(myIncomeAndExpensesQueryDto));
    }

    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/19 9:14
     *  @Description: 提现中、已提现的详情
     */
    @GetMapping("findDetailById")
    @ApiOperation("提现的详情")
    public HttpResult<WithdrawalDetalsDto>  findDetailById(String  id){
        return  HttpResult.ok(sysUserAccountService.findDetailById(id));
    }
    /**
    @PostMapping("findOrderDetailById")
    @ApiOperation("订单详情")
    public HttpResult<OrderDetalsDto>  findOrderDetailById(String subOrderId){
        return  HttpResult.ok(sysUserAccountService.findOrderDetailById(subOrderId));
    }
    **/

    @GetMapping("findRefundDetailById")
    @ApiOperation("退款详情")
    public HttpResult<RefundDetalsDto>  findRefundDetailById(String  id){
        return  HttpResult.ok(sysUserAccountService.findRefundDetailById(id));
    }

    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/30 19:14
     *  @Description: 查询我的车险明细
     */
    @PostMapping("findMyInsuranceByUserId")
    @ApiOperation("查询我的车险明细")
    public HttpResult<BasePageResult<ExportExpenditureTypeDetalsDto>>  findMyInsuranceByUserId(@RequestBody MyInsuranceQueryDto myInsuranceQueryDto){
        return  HttpResult.ok(sysUserAccountService.findMyInsuranceByUserId(myInsuranceQueryDto));
    }

    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/30 19:14
     *  @Description: 查询我的推广费明细
     */
    @PostMapping("findMyInsuranceTGByUserId")
    @ApiOperation("查询我的推广费明细")
    public HttpResult<BasePageResult<ExportExpenditureTypeDetalsTGDto>>  findMyInsuranceTGByUserId(@RequestBody MyInsuranceTgQueryDto myInsuranceTgQueryDto){
        return  HttpResult.ok(sysUserAccountService.findMyInsuranceTGByUserId(myInsuranceTgQueryDto));
    }


    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/30 19:14
     *  @Description:  查询导出车险明细
     */
    @PostMapping("exportMyInsuranceByUserId")
    @ApiOperation("查询导出车险明细")
    public HttpResult<List<ExportExpenditureTypeDetalsDto>>  exportMyInsuranceByUserId(@RequestBody MyInsuranceQueryDto myInsuranceQueryDto){
        List<ExportExpenditureTypeDetalsDto> exportIncomeTypeDetalsList = sysUserAccountService.exportMyInsuranceByUserId(myInsuranceQueryDto);
        ExcelUtils<ExportExpenditureTypeDetalsDto> excelUtils = new ExcelUtils<>(ExportExpenditureTypeDetalsDto.class);
        String fileName = "车险明细" + System.currentTimeMillis() + ".xlsx";
        String saveFilePath = uploadPath+"//" + EXCEL_PATH + fileName;
        String resultPath = UPLOAD_PATH + fileName;
        String sheetName = "车险明细表";
        try{
            excelUtils.writeExcelNew(saveFilePath,sheetName, exportIncomeTypeDetalsList);
            return HttpResult.ok(resultPath);
        }catch(Exception e){
            return HttpResult.error("导出车险明细表失败："+e.getMessage());
        }
    }

    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/30 19:14
     *  @Description:  查询导出推广费明细
     */
    @PostMapping("expeortMyInsuranceTGByUserId")
    @ApiOperation("查询导出推广费明细")
    public HttpResult<List<ExportExpenditureTypeDetalsTGDto>>  expeortMyInsuranceTGByUserId(@RequestBody MyInsuranceTgQueryDto myInsuranceTgQueryDto){
        List<ExportExpenditureTypeDetalsTGDto> exportIncomeTypeDetalsList = sysUserAccountService.exportMyInsuranceTGByUserId(myInsuranceTgQueryDto);
        ExcelUtils<ExportExpenditureTypeDetalsTGDto> excelUtils = new ExcelUtils<>(ExportExpenditureTypeDetalsTGDto.class);
        String fileName = "推广费明细" + System.currentTimeMillis() + ".xlsx";
        String saveFilePath = uploadPath+"//" + EXCEL_PATH + fileName;
        String resultPath = UPLOAD_PATH + fileName;
        String sheetName = "推广费明细表";
        try{
            excelUtils.writeExcelNew(saveFilePath,sheetName, exportIncomeTypeDetalsList);
            return HttpResult.ok(resultPath);
        }catch(Exception e){
            return HttpResult.error("导出推广费明细表失败："+e.getMessage());
        }
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/30 19:14
     *  @Description:  收支明细
     */
    @PostMapping("findMyIncomeAndExpensesNewByUserId")
    @ApiOperation("查询收支明细新")
    public HttpResult<BasePageResult<ExportExpenditureTypeDetalsSZDto>>  findMyIncomeAndExpensesNewByUserId(@RequestBody MyCollectInAdvanceQueryNewDto myCollectInAdvanceQueryNewDto){
        return  HttpResult.ok(sysUserAccountService.findMyIncomeAndExpensesNewByUserId(myCollectInAdvanceQueryNewDto));
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/7/1 8:57
     *  @Description: 导出收支明细新
     */
    @PostMapping("exportMyIncomeAndExpensesNewByUserId")
    @ApiOperation("导出收支明细新")
    public HttpResult<MyCollectInAdvanceAllDto>  exportMyIncomeAndExpensesNewByUserId(@RequestBody MyCollectInAdvanceQueryNewDto myCollectInAdvanceQueryNewDto){
        List<ExportExpenditureTypeDetalsSZDto> exportIncomeTypeDetalsList = sysUserAccountService.exportMyIncomeAndExpensesNewByUserId(myCollectInAdvanceQueryNewDto);
        ExcelUtils<ExportExpenditureTypeDetalsSZDto> excelUtils = new ExcelUtils<>(ExportExpenditureTypeDetalsSZDto.class);
        String fileName = "收支明细" + System.currentTimeMillis() + ".xlsx";
        String saveFilePath = uploadPath+"//" + EXCEL_PATH + fileName;
        String resultPath = UPLOAD_PATH + fileName;
        String sheetName = "收支明细表";
        try{
            excelUtils.writeExcelNew(saveFilePath,sheetName, exportIncomeTypeDetalsList);
            return HttpResult.ok(resultPath);
        }catch(Exception e){
            return HttpResult.error("导出收支明细表失败："+e.getMessage());
        }
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/30 18:43
     *  @Description: 我的账户页面的数据
     */
    @PostMapping("findMyAmount")
    @ApiOperation("我的账户页面的数据")
    public HttpResult<MySumAmountDto>  findMyAmount(@RequestBody MySumAmountQueryDto mySumAmountQueryDto){
        MySumAmountDto amountDto = sysUserAccountService.findMyAmount(mySumAmountQueryDto);
        return HttpResult.ok(amountDto);
    }
}