package com.ruoyi.account.controller;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.ruoyi.account.api.dto.VinAppletBindDTO;
|
import com.ruoyi.account.api.dto.VinManagementAllocateDTO;
|
import com.ruoyi.account.api.dto.VinManagementExcelDTO;
|
import com.ruoyi.account.api.dto.VinManagementQueryDTO;
|
import com.ruoyi.account.api.dto.VinManagementSaveDTO;
|
import com.ruoyi.account.api.model.TVinManagement;
|
import com.ruoyi.account.api.vo.VinManagementAllocateVO;
|
import com.ruoyi.account.service.TVinManagementService;
|
import com.ruoyi.common.core.domain.R;
|
import com.ruoyi.common.core.utils.poi.ExcelUtil;
|
import com.ruoyi.common.core.web.controller.BaseController;
|
import com.ruoyi.common.security.annotation.Logical;
|
import com.ruoyi.common.security.annotation.RequiresPermissions;
|
import com.ruoyi.common.security.service.TokenService;
|
import io.swagger.annotations.ApiOperation;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.*;
|
|
import java.math.BigDecimal;
|
import org.springframework.web.multipart.MultipartFile;
|
import javax.servlet.http.HttpServletResponse;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Objects;
|
import java.util.stream.Collectors;
|
|
@RestController
|
@RequestMapping("/t-vin-management")
|
public class TVinManagementController extends BaseController {
|
@Autowired private TVinManagementService service;
|
@Autowired private TokenService tokenService;
|
@RequiresPermissions(value = "/vinManagement/list", logical = Logical.OR)
|
@PostMapping("/page") public R<IPage<?>> page(@RequestBody VinManagementQueryDTO query) { return R.ok(service.selectPageList(query)); }
|
@RequiresPermissions(value = "/vinManagement/add", logical = Logical.OR)
|
@PostMapping public R<Boolean> add(@RequestBody VinManagementSaveDTO dto) { return R.ok(service.saveVin(dto)); }
|
@RequiresPermissions(value = "/vinManagement/edit", logical = Logical.OR)
|
@PutMapping public R<Boolean> edit(@RequestBody VinManagementSaveDTO dto) { return R.ok(service.updateVin(dto)); }
|
@RequiresPermissions(value = "/vinManagement/delete", logical = Logical.OR)
|
@DeleteMapping public R<Boolean> delete(@RequestBody List<Long> ids) { return R.ok(service.deleteVins(ids)); }
|
@ApiOperation(value = "批量解绑车队（清空VIN车队归属，返回实际解绑数量）")
|
@RequiresPermissions(value = {"/vinManagement/unbind"}, logical = Logical.OR)
|
@PutMapping("/unbind-fleet") public R<Integer> unbindFleet(@RequestBody List<Long> ids) { return R.ok(service.unbindFleet(ids)); }
|
@RequiresPermissions(value = "/vinManagement/status", logical = Logical.OR)
|
@PutMapping("/status") public R<Boolean> status(@RequestBody VinManagementSaveDTO dto) { return R.ok(service.updateStatus(dto.getId(), dto.getStatus())); }
|
@RequiresPermissions(value = "/vinManagement/export", logical = Logical.OR)
|
@PutMapping("/export") public void export(HttpServletResponse response, @RequestBody VinManagementQueryDTO query) { new ExcelUtil<>(VinManagementExcelDTO.class).exportExcel(response, service.selectExportList(query), "VIN码数据"); }
|
@RequiresPermissions(value = "/vinManagement/import", logical = Logical.OR)
|
@GetMapping("/import-template") public void template(HttpServletResponse response) { new ExcelUtil<>(VinManagementExcelDTO.class).importTemplateExcel(response, "VIN码导入模板"); }
|
@RequiresPermissions(value = "/vinManagement/import", logical = Logical.OR)
|
@PostMapping("/import") public R<String> importData(@RequestPart("file") MultipartFile file) throws Exception { List<VinManagementExcelDTO> items = new ExcelUtil<>(VinManagementExcelDTO.class).importExcel(file.getInputStream()); return R.ok(service.importVins(items)); }
|
|
@GetMapping("/applet/vehicles")
|
public R<List<TVinManagement>> appletVehicles() {
|
return R.ok(service.selectAppletVehicleList(tokenService.getLoginUserApplet().getUserId()));
|
}
|
|
@PostMapping("/applet/bind")
|
public R<Boolean> bindAppletVehicle(@RequestBody VinAppletBindDTO dto) {
|
return R.ok(service.bindAppletVehicle(tokenService.getLoginUserApplet().getUserId(),
|
dto == null ? null : dto.getKeyword()));
|
}
|
|
@DeleteMapping("/applet/unbind/{id}")
|
public R<Boolean> unbindAppletVehicle(@PathVariable Long id) {
|
return R.ok(service.unbindAppletVehicle(id, tokenService.getLoginUserApplet().getUserId()));
|
}
|
|
@ApiOperation(value = "额度分配概览（公司总账户余额、可分配余额）")
|
@RequiresPermissions(value = {"/vinManagement/allocate"}, logical = Logical.OR)
|
@GetMapping("/allocate-overview")
|
public R<VinManagementAllocateVO> allocateOverview(@RequestParam("companyId") Integer companyId) {
|
return R.ok(service.getAllocateOverview(companyId));
|
}
|
|
@ApiOperation(value = "VIN码额度分配（公司可用余额划入VIN初始分配额度）")
|
@RequiresPermissions(value = {"/vinManagement/allocate"}, logical = Logical.OR)
|
@PostMapping("/allocate")
|
public R<VinManagementAllocateVO> allocate(@RequestBody VinManagementAllocateDTO dto) {
|
return R.ok(service.allocateQuota(dto));
|
}
|
|
/**
|
* 内部接口：根据VIN码查询未删除的VIN记录（订单侧VIN鉴权使用）
|
*/
|
@GetMapping("/inner/get-by-vin")
|
public R<TVinManagement> getByVin(@RequestParam("vin") String vin) {
|
return R.ok(service.getByVin(vin));
|
}
|
|
@GetMapping("/inner/ids-by-app-user")
|
public R<List<Long>> getVinIdsByAppUserId(@RequestParam Long appUserId) {
|
return R.ok(service.getVinIdsByAppUserId(appUserId));
|
}
|
|
/**
|
* 内部接口：根据VIN记录ID批量查询（订单侧列表/详情回填VIN码、车牌号、手机号使用）
|
*/
|
@PostMapping("/inner/list-by-ids")
|
public R<List<TVinManagement>> listByIds(@RequestBody List<Long> ids) {
|
if (ids == null || ids.isEmpty()) {
|
return R.ok(new ArrayList<>());
|
}
|
List<Long> distinctIds = ids.stream().filter(Objects::nonNull).distinct().collect(Collectors.toList());
|
return R.ok(distinctIds.isEmpty() ? new ArrayList<>() : service.listByIds(distinctIds));
|
}
|
|
/**
|
* 内部接口：按车队分页查询VIN码车辆（车队管理-查看车队抽屉使用，含车队名称回填）
|
*/
|
@PostMapping("/inner/page-by-fleet")
|
public R<IPage<TVinManagement>> pageByFleet(@RequestBody VinManagementQueryDTO query) {
|
return R.ok(service.selectPageList(query));
|
}
|
|
/**
|
* 内部接口：按公司查询未删除的VIN码列表（公司详情-充电用户信息聚合使用）
|
*/
|
@GetMapping("/inner/list-by-company")
|
public R<List<TVinManagement>> listByCompany(@RequestParam("companyId") Integer companyId) {
|
return R.ok(service.listByCompany(companyId));
|
}
|
|
/**
|
* 内部接口：按车队统计未删除的VIN车辆数（车队管理-列表"VIN码车辆数"使用）
|
*/
|
@GetMapping("/inner/count-by-fleet")
|
public R<Long> countByFleet(@RequestParam("fleetId") Integer fleetId) {
|
return R.ok(service.countByFleet(fleetId));
|
}
|
|
/**
|
* 内部接口：锁定VIN账户余额（VIN码充电申请，分配模式实扣冻结：余额立即扣减并计入锁定金额）
|
*/
|
@PostMapping("/inner/lock-balance")
|
public R<BigDecimal> lockBalance(@RequestParam("vinId") Long vinId, @RequestParam("amount") BigDecimal amount) {
|
try {
|
return R.ok(service.lockBalance(vinId, amount));
|
} catch (RuntimeException ex) {
|
return R.fail(ex.getMessage());
|
}
|
}
|
|
/**
|
* 内部接口：结算VIN账户余额（解锁锁定额并按实际消费扣减，允许扣成负数）
|
* <p>orderCode 非空时按订单号幂等（余额变更与消费流水同事务），补偿重试不会重复结算</p>
|
*/
|
@PostMapping("/inner/settle-balance")
|
public R<BigDecimal> settleBalance(@RequestParam("vinId") Long vinId,
|
@RequestParam("lockedAmount") BigDecimal lockedAmount,
|
@RequestParam("actualAmount") BigDecimal actualAmount,
|
@RequestParam(value = "orderCode", required = false) String orderCode,
|
@RequestParam(value = "userInfo", required = false) String userInfo,
|
@RequestParam(value = "userName", required = false) String userName,
|
@RequestParam(value = "remark", required = false) String remark) {
|
try {
|
return R.ok(service.settleBalance(vinId, lockedAmount, actualAmount, orderCode, userInfo, userName, remark));
|
} catch (RuntimeException ex) {
|
return R.fail(ex.getMessage());
|
}
|
}
|
|
/**
|
* 内部接口：释放VIN锁定金额（未产生消费时使用）
|
*/
|
@PostMapping("/inner/unlock-balance")
|
public R<BigDecimal> unlockBalance(@RequestParam("vinId") Long vinId, @RequestParam("amount") BigDecimal amount) {
|
try {
|
return R.ok(service.unlockBalance(vinId, amount));
|
} catch (RuntimeException ex) {
|
return R.fail(ex.getMessage());
|
}
|
}
|
}
|
