package com.ruoyi.web.controller.api;
|
|
|
import cn.afterturn.easypoi.excel.ExcelExportUtil;
|
import cn.afterturn.easypoi.excel.ExcelImportUtil;
|
import cn.afterturn.easypoi.excel.entity.ExportParams;
|
import cn.afterturn.easypoi.excel.entity.ImportParams;
|
import cn.hutool.json.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.ruoyi.common.annotation.Log;
|
import com.ruoyi.common.core.domain.R;
|
import com.ruoyi.common.core.domain.model.LoginUser;
|
import com.ruoyi.common.core.exception.ServiceException;
|
import com.ruoyi.common.enums.BusinessType;
|
import com.ruoyi.common.utils.WebUtils;
|
import com.ruoyi.framework.web.service.TokenService;
|
import com.ruoyi.system.export.BigGiftPackageImport;
|
import com.ruoyi.system.export.TPhysicalGoodsImport;
|
import com.ruoyi.system.model.TBigGiftPackage;
|
import com.ruoyi.system.model.THtmlConfig;
|
import com.ruoyi.system.model.TPhysicalGoods;
|
import com.ruoyi.system.query.BigGiftPackageQuery;
|
import com.ruoyi.system.service.THtmlConfigService;
|
import com.ruoyi.system.service.TPhysicalGoodsService;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import org.apache.poi.ss.usermodel.Workbook;
|
import org.springframework.transaction.annotation.Propagation;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.CollectionUtils;
|
import org.springframework.util.StringUtils;
|
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.multipart.MultipartFile;
|
|
import javax.servlet.ServletOutputStream;
|
import javax.servlet.http.HttpServletResponse;
|
import java.io.IOException;
|
import java.io.InputStream;
|
import java.math.BigDecimal;
|
import java.net.URLEncoder;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Objects;
|
|
import static net.sf.jsqlparser.parser.feature.Feature.update;
|
|
/**
|
* <p>
|
* 实物商品 前端控制器
|
* </p>
|
*
|
* @author xiaochen
|
* @since 2025-12-08
|
*/
|
@RestController
|
@RequestMapping("/t-physical-goods")
|
@Api(tags = "（嘉视达）实物商品")
|
public class TPhysicalGoodsController {
|
|
private final TPhysicalGoodsService tPhysicalGoodsService;
|
private final TokenService tokenService;
|
private final THtmlConfigService tHtmlConfigService;
|
|
public TPhysicalGoodsController(TPhysicalGoodsService tPhysicalGoodsService, TokenService tokenService, THtmlConfigService tHtmlConfigService) {
|
this.tPhysicalGoodsService = tPhysicalGoodsService;
|
this.tokenService = tokenService;
|
this.tHtmlConfigService = tHtmlConfigService;
|
|
}
|
|
@ApiOperation(value = "实物商品分页列表")
|
@PostMapping(value = "/pageList")
|
public R<Page<TPhysicalGoods>> pageList(@RequestBody BigGiftPackageQuery query) {
|
Page<TPhysicalGoods> tPhysicalGoodsPage = new Page<>(query.getPageNum(), query.getPageSize());
|
LambdaQueryWrapper<TPhysicalGoods> wrapper = new LambdaQueryWrapper<>();
|
wrapper.eq(TPhysicalGoods::getStatus,0);
|
wrapper.like(Objects.nonNull(query.getName()), TPhysicalGoods::getName, query.getName());
|
wrapper.orderByDesc(TPhysicalGoods::getCreateTime);
|
Page<TPhysicalGoods> pageInfo = tPhysicalGoodsService.page(tPhysicalGoodsPage, wrapper);
|
return R.ok(pageInfo);
|
}
|
|
@ApiOperation(value = "实物商品详情")
|
@GetMapping(value = "/detail/{id}")
|
public R<TPhysicalGoods> detail(@PathVariable Integer id ) {
|
TPhysicalGoods tPhysicalGoods = tPhysicalGoodsService.getById(id);
|
return R.ok(tPhysicalGoods);
|
}
|
|
@ApiOperation(value = "实物商品添加")
|
@PostMapping(value = "/add")
|
@Log(title = "实物商品-添加", businessType = BusinessType.INSERT)
|
public R<String> add(@RequestBody TPhysicalGoods tPhysicalGoods) {
|
LoginUser loginUser = tokenService.getLoginUser();
|
tPhysicalGoods.setCreateUserId(loginUser.getUserId());
|
boolean save = tPhysicalGoodsService.save(tPhysicalGoods);
|
return save ? R.ok() : R.fail();
|
}
|
|
@ApiOperation(value = "实物商品修改")
|
@PostMapping(value = "/update")
|
@Log(title = "实物商品-修改", businessType = BusinessType.UPDATE)
|
public R<String> update(@RequestBody TPhysicalGoods tPhysicalGoods) {
|
LoginUser loginUser = tokenService.getLoginUser();
|
tPhysicalGoods.setUpdateUserId(loginUser.getUserId());
|
boolean update = tPhysicalGoodsService.updateById(tPhysicalGoods);
|
return update ? R.ok() : R.fail();
|
}
|
|
@ApiOperation(value = "实物商品删除")
|
@DeleteMapping(value = "/delete/{id}")
|
@Log(title = "实物商品-删除", businessType = BusinessType.DELETE)
|
public R<String> delete(@PathVariable Integer id ) {
|
boolean remove = tPhysicalGoodsService.update(new LambdaUpdateWrapper<TPhysicalGoods>().eq(TPhysicalGoods::getId, id).set(TPhysicalGoods::getStatus, 1).set(TPhysicalGoods::getUpdateUserId,tokenService.getLoginUser().getUserId()));
|
return remove ? R.ok() : R.fail();
|
}
|
|
@ApiOperation(value = "实物商品是否展示(0不展示 1展示)")
|
@PostMapping(value = "/isShow")
|
@Log(title = "实物商品-展示", businessType = BusinessType.UPDATE)
|
public R<?> isShow(@RequestParam String isShow) {
|
THtmlConfig config = tHtmlConfigService.getById(8);
|
config.setContent(isShow);
|
boolean update = tHtmlConfigService.updateById(config);
|
return update ? R.ok() : R.fail();
|
}
|
|
|
|
@ApiOperation(value = "实物商品导入模板下载")
|
@GetMapping("/import-template")
|
public void importTemplate() {
|
List<TPhysicalGoodsImport> physicalGoodsImports = new ArrayList<>();
|
TPhysicalGoodsImport physicalGoodsImport = new TPhysicalGoodsImport();
|
physicalGoodsImports.add(physicalGoodsImport);
|
Workbook workbook = ExcelExportUtil.exportExcel(new ExportParams(), TPhysicalGoodsImport.class, physicalGoodsImports);
|
HttpServletResponse response = WebUtils.response();
|
ServletOutputStream outputStream = null;
|
try {
|
String fileName = URLEncoder.encode("实物商品导入模板.xls", "utf-8");
|
response.setHeader("Content-Disposition", "attachment;filename=" + fileName);
|
response.setHeader("content-Type", "application/vnd.ms-excel");
|
response.setHeader("Pragma", "no-cache");
|
response.setHeader("Cache-Control", "no-cache");
|
outputStream = response.getOutputStream();
|
workbook.write(outputStream);
|
} catch (IOException e) {
|
e.printStackTrace();
|
System.out.println("实物商品导入模板下载失败!");
|
} finally {
|
try {
|
outputStream.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
@Log(title = "实物商品-导入", businessType = BusinessType.IMPORT)
|
@ApiOperation(value = "实物商品-导入")
|
@Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRES_NEW)
|
@PostMapping("/import")
|
public R<String> importInfo(@RequestPart("file") MultipartFile file) {
|
List<TPhysicalGoodsImport> physicalGoodsImports = new ArrayList<>();
|
ImportParams params = new ImportParams();
|
params.setHeadRows(1); //表头行数
|
InputStream inputStream = null;
|
List<TPhysicalGoods> physicalGoods = new ArrayList<>();
|
try {
|
inputStream = file.getInputStream();
|
physicalGoodsImports = ExcelImportUtil.importExcel(inputStream,
|
TPhysicalGoodsImport.class, params);
|
} catch (Exception e) {
|
e.printStackTrace();
|
throw new ServiceException("实物商品导入失败!");
|
} finally {
|
try {
|
inputStream.close();
|
} catch (IOException e) {
|
throw new ServiceException(e.getMessage());
|
}
|
}
|
if (CollectionUtils.isEmpty(physicalGoodsImports)) {
|
throw new ServiceException("实物商品数据为空!");
|
}
|
JSONObject result = new JSONObject();
|
int i = 1;
|
for (TPhysicalGoodsImport physicalGoodsImport : physicalGoodsImports) {
|
if (!StringUtils.hasLength(physicalGoodsImport.getName())){
|
result.append("第"+i+"行：[", "商品名称"+"]不能为空");
|
continue;
|
}
|
if (!StringUtils.hasLength(physicalGoodsImport.getTotalPrice())){
|
result.append("第"+i+"行：[", "商品价格"+"]不能为空");
|
continue;
|
}
|
if (!StringUtils.hasLength(physicalGoodsImport.getIntroduction())){
|
result.append("第"+i+"行：[", "商品简介"+"]不能为空");
|
continue;
|
}
|
if (!StringUtils.hasLength(physicalGoodsImport.getSales())){
|
result.append("第"+i+"行：[", "销量"+"]不能为空");
|
continue;
|
}
|
TPhysicalGoods goods = new TPhysicalGoods();
|
goods.setName(physicalGoodsImport.getName());
|
goods.setIntroduction(physicalGoodsImport.getIntroduction());
|
try {
|
BigDecimal totalPrice = new BigDecimal(physicalGoodsImport.getTotalPrice());
|
goods.setTotalPrice(totalPrice);
|
} catch (Exception e) {
|
result.append("第"+i+"行：[", "商品价格"+"]格式错误");
|
continue;
|
}
|
|
|
try {
|
Integer sales = Integer.parseInt(physicalGoodsImport.getSales());
|
goods.setSales(sales);
|
} catch (Exception e) {
|
result.append("第"+i+"行：[", "销量"+"]格式错误");
|
continue;
|
}
|
|
|
physicalGoods.add(goods);
|
i++;
|
}
|
tPhysicalGoodsService.saveBatch(physicalGoods);
|
if(!result.isEmpty()){
|
return R.fail(result.toString());
|
}
|
return R.ok();
|
}
|
|
|
@ApiOperation(value = "实物导出")
|
@PostMapping(value = "/export")
|
@Log(title = "实物-导出", businessType = BusinessType.EXPORT)
|
public void exportRegistration(@RequestBody BigGiftPackageQuery query){
|
|
LambdaQueryWrapper<TPhysicalGoods> wrapper = new LambdaQueryWrapper<>();
|
wrapper.eq(TPhysicalGoods::getStatus,0);
|
wrapper.like(Objects.nonNull(query.getName()), TPhysicalGoods::getName, query.getName());
|
wrapper.orderByDesc(TPhysicalGoods::getCreateTime);
|
List<TPhysicalGoods> list = tPhysicalGoodsService.list(wrapper);
|
ArrayList<TPhysicalGoodsImport> physicalGoodsImports = new ArrayList<>();
|
for (TPhysicalGoods goods : list) {
|
TPhysicalGoodsImport physicalGoodsImport = new TPhysicalGoodsImport();
|
physicalGoodsImport.setName(goods.getName());
|
physicalGoodsImport.setTotalPrice(goods.getTotalPrice().toString());
|
physicalGoodsImport.setIntroduction(goods.getIntroduction());
|
physicalGoodsImport.setSales(goods.getSales().toString());
|
physicalGoodsImports.add(physicalGoodsImport);
|
}
|
|
|
Workbook workbook = ExcelExportUtil.exportExcel(new ExportParams(), TPhysicalGoodsImport.class, physicalGoodsImports);
|
HttpServletResponse response = WebUtils.response();
|
assert response != null;
|
response.setContentType("application/vnd.ms-excel");
|
response.setCharacterEncoding("utf-8");
|
ServletOutputStream outputStream = null;
|
try {
|
String fileName = URLEncoder.encode("实物导出信息.xls", "utf-8");
|
response.setHeader("Content-Disposition", "attachment;filename=" + fileName);
|
response.setContentType("application/vnd.ms-excel;charset=UTF-8");
|
response.setHeader("Pragma", "no-cache");
|
response.setHeader("Cache-Control", "no-cache");
|
outputStream = response.getOutputStream();
|
workbook.write(outputStream);
|
} catch (IOException e) {
|
e.printStackTrace();
|
} finally {
|
try {
|
outputStream.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
}
|
