add stock workshop and feeding record

plp
chenshuichuan 2 years ago
parent 24ad57c7d9
commit 1cbc8bb3a2

@ -40,14 +40,14 @@ public class FrpsServerController {
@PostMapping("/create")
@Operation(summary = "创建代理服务器")
@PreAuthorize("@ss.hasPermission('iot:frps-server:create')")
@PreAuthorize("@ss.hasPermission('iot:frpc-proxy-server:create')")
public CommonResult<Long> createFrpsServer(@Valid @RequestBody FrpsServerSaveReqVO createReqVO) {
return success(frpsServerService.createFrpsServer(createReqVO));
}
@PutMapping("/update")
@Operation(summary = "更新代理服务器")
@PreAuthorize("@ss.hasPermission('iot:frps-server:update')")
@PreAuthorize("@ss.hasPermission('iot:frpc-proxy-server:update')")
public CommonResult<Boolean> updateFrpsServer(@Valid @RequestBody FrpsServerSaveReqVO updateReqVO) {
frpsServerService.updateFrpsServer(updateReqVO);
return success(true);
@ -56,7 +56,7 @@ public class FrpsServerController {
@DeleteMapping("/delete")
@Operation(summary = "删除代理服务器")
@Parameter(name = "id", description = "编号", required = true)
@PreAuthorize("@ss.hasPermission('iot:frps-server:delete')")
@PreAuthorize("@ss.hasPermission('iot:frpc-proxy-server:delete')")
public CommonResult<Boolean> deleteFrpsServer(@RequestParam("id") Long id) {
frpsServerService.deleteFrpsServer(id);
return success(true);
@ -65,7 +65,7 @@ public class FrpsServerController {
@GetMapping("/get")
@Operation(summary = "获得代理服务器")
@Parameter(name = "id", description = "编号", required = true, example = "1024")
@PreAuthorize("@ss.hasPermission('iot:frps-server:query')")
@PreAuthorize("@ss.hasPermission('iot:frpc-proxy-server:query')")
public CommonResult<FrpsServerRespVO> getFrpsServer(@RequestParam("id") Long id) {
FrpsServerDO frpsServer = frpsServerService.getFrpsServer(id);
return success(BeanUtils.toBean(frpsServer, FrpsServerRespVO.class));
@ -73,7 +73,7 @@ public class FrpsServerController {
@GetMapping("/page")
@Operation(summary = "获得代理服务器分页")
@PreAuthorize("@ss.hasPermission('iot:frps-server:query')")
@PreAuthorize("@ss.hasPermission('iot:frpc-proxy-server:query')")
public CommonResult<PageResult<FrpsServerRespVO>> getFrpsServerPage(@Valid FrpsServerPageReqVO pageReqVO) {
PageResult<FrpsServerDO> pageResult = frpsServerService.getFrpsServerPage(pageReqVO);
return success(BeanUtils.toBean(pageResult, FrpsServerRespVO.class));
@ -81,7 +81,7 @@ public class FrpsServerController {
@GetMapping("/export-excel")
@Operation(summary = "导出代理服务器 Excel")
@PreAuthorize("@ss.hasPermission('iot:frps-server:export')")
@PreAuthorize("@ss.hasPermission('iot:frpc-proxy-server:export')")
@ApiAccessLog(operateType = EXPORT)
public void exportFrpsServerExcel(@Valid FrpsServerPageReqVO pageReqVO,
HttpServletResponse response) throws IOException {

@ -46,5 +46,8 @@ public interface ErrorCodeConstants {
ErrorCode MACHINE_COMPONENT_NAME_DUPLICATE = new ErrorCode(5_0081, "生产报工明细不存在");
ErrorCode SALE_ORDER_NOT_EXISTS = new ErrorCode(5_0081, "生产报工明细不存在");
ErrorCode SALE_ORDER_ITEMS_NOT_EXISTS = new ErrorCode(5_0081, "生产报工明细不存在");
ErrorCode STOCK_WORKSHOP_DETAIL_NOT_EXISTS = new ErrorCode(5_0081, "生产报工明细不存在");
ErrorCode STOCK_WORKSHOP_NOT_EXISTS = new ErrorCode(5_0081, "生产报工明细不存在");
ErrorCode FEEDING_RECORD_NOT_EXISTS = new ErrorCode(5_0081, "生产报工明细不存在");
}

@ -0,0 +1,95 @@
package cn.iocoder.yudao.module.mes.controller.admin.feedingrecord;
import org.springframework.web.bind.annotation.*;
import org.springframework.validation.annotation.Validated;
import org.springframework.security.access.prepost.PreAuthorize;
import io.swagger.v3.oas.annotations.tags.Tag;
import io.swagger.v3.oas.annotations.Parameter;
import io.swagger.v3.oas.annotations.Operation;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletResponse;
import javax.validation.Valid;
import java.util.*;
import java.io.IOException;
import cn.iocoder.yudao.framework.common.pojo.PageParam;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.pojo.CommonResult;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
import cn.iocoder.yudao.framework.excel.core.util.ExcelUtils;
import cn.iocoder.yudao.framework.apilog.core.annotation.ApiAccessLog;
import static cn.iocoder.yudao.framework.apilog.core.enums.OperateTypeEnum.*;
import cn.iocoder.yudao.module.mes.controller.admin.feedingrecord.vo.*;
import cn.iocoder.yudao.module.mes.dal.dataobject.feedingrecord.FeedingRecordDO;
import cn.iocoder.yudao.module.mes.service.feedingrecord.FeedingRecordService;
@Tag(name = "管理后台 - 投料记录")
@RestController
@RequestMapping("/mes/feeding-record")
@Validated
public class FeedingRecordController {
@Resource
private FeedingRecordService feedingRecordService;
@PostMapping("/create")
@Operation(summary = "创建投料记录")
@PreAuthorize("@ss.hasPermission('mes:feeding-record:create')")
public CommonResult<Long> createFeedingRecord(@Valid @RequestBody FeedingRecordSaveReqVO createReqVO) {
return success(feedingRecordService.createFeedingRecord(createReqVO));
}
@PutMapping("/update")
@Operation(summary = "更新投料记录")
@PreAuthorize("@ss.hasPermission('mes:feeding-record:update')")
public CommonResult<Boolean> updateFeedingRecord(@Valid @RequestBody FeedingRecordSaveReqVO updateReqVO) {
feedingRecordService.updateFeedingRecord(updateReqVO);
return success(true);
}
@DeleteMapping("/delete")
@Operation(summary = "删除投料记录")
@Parameter(name = "id", description = "编号", required = true)
@PreAuthorize("@ss.hasPermission('mes:feeding-record:delete')")
public CommonResult<Boolean> deleteFeedingRecord(@RequestParam("id") Long id) {
feedingRecordService.deleteFeedingRecord(id);
return success(true);
}
@GetMapping("/get")
@Operation(summary = "获得投料记录")
@Parameter(name = "id", description = "编号", required = true, example = "1024")
@PreAuthorize("@ss.hasPermission('mes:feeding-record:query')")
public CommonResult<FeedingRecordRespVO> getFeedingRecord(@RequestParam("id") Long id) {
FeedingRecordDO feedingRecord = feedingRecordService.getFeedingRecord(id);
return success(BeanUtils.toBean(feedingRecord, FeedingRecordRespVO.class));
}
@GetMapping("/page")
@Operation(summary = "获得投料记录分页")
@PreAuthorize("@ss.hasPermission('mes:feeding-record:query')")
public CommonResult<PageResult<FeedingRecordRespVO>> getFeedingRecordPage(@Valid FeedingRecordPageReqVO pageReqVO) {
PageResult<FeedingRecordDO> pageResult = feedingRecordService.getFeedingRecordPage(pageReqVO);
return success(BeanUtils.toBean(pageResult, FeedingRecordRespVO.class));
}
@GetMapping("/export-excel")
@Operation(summary = "导出投料记录 Excel")
@PreAuthorize("@ss.hasPermission('mes:feeding-record:export')")
@ApiAccessLog(operateType = EXPORT)
public void exportFeedingRecordExcel(@Valid FeedingRecordPageReqVO pageReqVO,
HttpServletResponse response) throws IOException {
pageReqVO.setPageSize(PageParam.PAGE_SIZE_NONE);
List<FeedingRecordDO> list = feedingRecordService.getFeedingRecordPage(pageReqVO).getList();
// 导出 Excel
ExcelUtils.write(response, "投料记录.xls", "数据", FeedingRecordRespVO.class,
BeanUtils.toBean(list, FeedingRecordRespVO.class));
}
}

@ -0,0 +1,57 @@
package cn.iocoder.yudao.module.mes.controller.admin.feedingrecord.vo;
import lombok.*;
import java.util.*;
import io.swagger.v3.oas.annotations.media.Schema;
import cn.iocoder.yudao.framework.common.pojo.PageParam;
import java.math.BigDecimal;
import org.springframework.format.annotation.DateTimeFormat;
import java.time.LocalDateTime;
import static cn.iocoder.yudao.framework.common.util.date.DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND;
@Schema(description = "管理后台 - 投料记录分页 Request VO")
@Data
@EqualsAndHashCode(callSuper = true)
@ToString(callSuper = true)
public class FeedingRecordPageReqVO extends PageParam {
@Schema(description = "单号")
private String feedingRecordCode;
@Schema(description = "产品id", example = "9099")
private Long productId;
@Schema(description = "计划id", example = "4922")
private Long planId;
@Schema(description = "原料id", example = "26352")
private Long itemId;
@Schema(description = "制浆线")
private String feedingPipeline;
@Schema(description = "投料类型", example = "2")
private String feedingType;
@Schema(description = "重量")
private BigDecimal weight;
@Schema(description = "投料时间")
@DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)
private LocalDateTime[] feedingTime;
@Schema(description = "记录人", example = "13784")
private Long userId;
@Schema(description = "备注", example = "随便")
private String remark;
@Schema(description = "状态", example = "1")
private String recordStatus;
@Schema(description = "创建时间")
@DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)
private LocalDateTime[] createTime;
}

@ -0,0 +1,73 @@
package cn.iocoder.yudao.module.mes.controller.admin.feedingrecord.vo;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.*;
import java.util.*;
import java.util.*;
import java.math.BigDecimal;
import org.springframework.format.annotation.DateTimeFormat;
import java.time.LocalDateTime;
import com.alibaba.excel.annotation.*;
import cn.iocoder.yudao.framework.excel.core.annotations.DictFormat;
import cn.iocoder.yudao.framework.excel.core.convert.DictConvert;
@Schema(description = "管理后台 - 投料记录 Response VO")
@Data
@ExcelIgnoreUnannotated
public class FeedingRecordRespVO {
@Schema(description = "id", requiredMode = Schema.RequiredMode.REQUIRED, example = "30794")
@ExcelProperty("id")
private Long id;
@Schema(description = "单号")
@ExcelProperty("单号")
private String feedingRecordCode;
@Schema(description = "产品id", example = "9099")
@ExcelProperty("产品id")
private Long productId;
@Schema(description = "计划id", example = "4922")
@ExcelProperty("计划id")
private Long planId;
@Schema(description = "原料id", example = "26352")
@ExcelProperty("原料id")
private Long itemId;
@Schema(description = "制浆线")
@ExcelProperty(value = "制浆线", converter = DictConvert.class)
@DictFormat("mes_feeding_pipeline") // TODO 代码优化:建议设置到对应的 DictTypeConstants 枚举类中
private String feedingPipeline;
@Schema(description = "投料类型", example = "2")
@ExcelProperty(value = "投料类型", converter = DictConvert.class)
@DictFormat("mes_feeding_type") // TODO 代码优化:建议设置到对应的 DictTypeConstants 枚举类中
private String feedingType;
@Schema(description = "重量")
@ExcelProperty("重量")
private BigDecimal weight;
@Schema(description = "投料时间")
@ExcelProperty("投料时间")
private LocalDateTime feedingTime;
@Schema(description = "记录人", example = "13784")
@ExcelProperty("记录人")
private Long userId;
@Schema(description = "备注", example = "随便")
@ExcelProperty("备注")
private String remark;
@Schema(description = "状态", example = "1")
@ExcelProperty("状态")
private String recordStatus;
@Schema(description = "创建时间", requiredMode = Schema.RequiredMode.REQUIRED)
@ExcelProperty("创建时间")
private LocalDateTime createTime;
}

@ -0,0 +1,49 @@
package cn.iocoder.yudao.module.mes.controller.admin.feedingrecord.vo;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.*;
import java.math.BigDecimal;
import org.springframework.format.annotation.DateTimeFormat;
import java.time.LocalDateTime;
@Schema(description = "管理后台 - 投料记录新增/修改 Request VO")
@Data
public class FeedingRecordSaveReqVO {
@Schema(description = "id", requiredMode = Schema.RequiredMode.REQUIRED, example = "30794")
private Long id;
@Schema(description = "单号")
private String feedingRecordCode;
@Schema(description = "产品id", example = "9099")
private Long productId;
@Schema(description = "计划id", example = "4922")
private Long planId;
@Schema(description = "原料id", example = "26352")
private Long itemId;
@Schema(description = "制浆线")
private String feedingPipeline;
@Schema(description = "投料类型", example = "2")
private String feedingType;
@Schema(description = "重量")
private BigDecimal weight;
@Schema(description = "投料时间")
private LocalDateTime feedingTime;
@Schema(description = "记录人", example = "13784")
private Long userId;
@Schema(description = "备注", example = "随便")
private String remark;
@Schema(description = "状态", example = "1")
private String recordStatus;
}

@ -0,0 +1,95 @@
package cn.iocoder.yudao.module.mes.controller.admin.stockworkshop;
import org.springframework.web.bind.annotation.*;
import org.springframework.validation.annotation.Validated;
import org.springframework.security.access.prepost.PreAuthorize;
import io.swagger.v3.oas.annotations.tags.Tag;
import io.swagger.v3.oas.annotations.Parameter;
import io.swagger.v3.oas.annotations.Operation;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletResponse;
import javax.validation.Valid;
import java.util.*;
import java.io.IOException;
import cn.iocoder.yudao.framework.common.pojo.PageParam;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.pojo.CommonResult;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
import cn.iocoder.yudao.framework.excel.core.util.ExcelUtils;
import cn.iocoder.yudao.framework.apilog.core.annotation.ApiAccessLog;
import static cn.iocoder.yudao.framework.apilog.core.enums.OperateTypeEnum.*;
import cn.iocoder.yudao.module.mes.controller.admin.stockworkshop.vo.*;
import cn.iocoder.yudao.module.mes.dal.dataobject.stockworkshop.StockWorkshopDO;
import cn.iocoder.yudao.module.mes.service.stockworkshop.StockWorkshopService;
@Tag(name = "管理后台 - 车间仓库存")
@RestController
@RequestMapping("/mes/stock-workshop")
@Validated
public class StockWorkshopController {
@Resource
private StockWorkshopService stockWorkshopService;
@PostMapping("/create")
@Operation(summary = "创建车间仓库存")
@PreAuthorize("@ss.hasPermission('mes:stock-workshop:create')")
public CommonResult<Long> createStockWorkshop(@Valid @RequestBody StockWorkshopSaveReqVO createReqVO) {
return success(stockWorkshopService.createStockWorkshop(createReqVO));
}
@PutMapping("/update")
@Operation(summary = "更新车间仓库存")
@PreAuthorize("@ss.hasPermission('mes:stock-workshop:update')")
public CommonResult<Boolean> updateStockWorkshop(@Valid @RequestBody StockWorkshopSaveReqVO updateReqVO) {
stockWorkshopService.updateStockWorkshop(updateReqVO);
return success(true);
}
@DeleteMapping("/delete")
@Operation(summary = "删除车间仓库存")
@Parameter(name = "id", description = "编号", required = true)
@PreAuthorize("@ss.hasPermission('mes:stock-workshop:delete')")
public CommonResult<Boolean> deleteStockWorkshop(@RequestParam("id") Long id) {
stockWorkshopService.deleteStockWorkshop(id);
return success(true);
}
@GetMapping("/get")
@Operation(summary = "获得车间仓库存")
@Parameter(name = "id", description = "编号", required = true, example = "1024")
@PreAuthorize("@ss.hasPermission('mes:stock-workshop:query')")
public CommonResult<StockWorkshopRespVO> getStockWorkshop(@RequestParam("id") Long id) {
StockWorkshopDO stockWorkshop = stockWorkshopService.getStockWorkshop(id);
return success(BeanUtils.toBean(stockWorkshop, StockWorkshopRespVO.class));
}
@GetMapping("/page")
@Operation(summary = "获得车间仓库存分页")
@PreAuthorize("@ss.hasPermission('mes:stock-workshop:query')")
public CommonResult<PageResult<StockWorkshopRespVO>> getStockWorkshopPage(@Valid StockWorkshopPageReqVO pageReqVO) {
PageResult<StockWorkshopDO> pageResult = stockWorkshopService.getStockWorkshopPage(pageReqVO);
return success(BeanUtils.toBean(pageResult, StockWorkshopRespVO.class));
}
@GetMapping("/export-excel")
@Operation(summary = "导出车间仓库存 Excel")
@PreAuthorize("@ss.hasPermission('mes:stock-workshop:export')")
@ApiAccessLog(operateType = EXPORT)
public void exportStockWorkshopExcel(@Valid StockWorkshopPageReqVO pageReqVO,
HttpServletResponse response) throws IOException {
pageReqVO.setPageSize(PageParam.PAGE_SIZE_NONE);
List<StockWorkshopDO> list = stockWorkshopService.getStockWorkshopPage(pageReqVO).getList();
// 导出 Excel
ExcelUtils.write(response, "车间仓库存.xls", "数据", StockWorkshopRespVO.class,
BeanUtils.toBean(list, StockWorkshopRespVO.class));
}
}

@ -0,0 +1,95 @@
package cn.iocoder.yudao.module.mes.controller.admin.stockworkshop;
import org.springframework.web.bind.annotation.*;
import org.springframework.validation.annotation.Validated;
import org.springframework.security.access.prepost.PreAuthorize;
import io.swagger.v3.oas.annotations.tags.Tag;
import io.swagger.v3.oas.annotations.Parameter;
import io.swagger.v3.oas.annotations.Operation;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletResponse;
import javax.validation.Valid;
import java.util.*;
import java.io.IOException;
import cn.iocoder.yudao.framework.common.pojo.PageParam;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.pojo.CommonResult;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
import cn.iocoder.yudao.framework.excel.core.util.ExcelUtils;
import cn.iocoder.yudao.framework.apilog.core.annotation.ApiAccessLog;
import static cn.iocoder.yudao.framework.apilog.core.enums.OperateTypeEnum.*;
import cn.iocoder.yudao.module.mes.controller.admin.stockworkshop.vo.*;
import cn.iocoder.yudao.module.mes.dal.dataobject.stockworkshop.StockWorkshopDetailDO;
import cn.iocoder.yudao.module.mes.service.stockworkshop.StockWorkshopDetailService;
@Tag(name = "管理后台 - 车间仓明细")
@RestController
@RequestMapping("/mes/stock-workshop-detail")
@Validated
public class StockWorkshopDetailController {
@Resource
private StockWorkshopDetailService stockWorkshopDetailService;
@PostMapping("/create")
@Operation(summary = "创建车间仓明细")
@PreAuthorize("@ss.hasPermission('mes:stock-workshop-detail:create')")
public CommonResult<Long> createStockWorkshopDetail(@Valid @RequestBody StockWorkshopDetailSaveReqVO createReqVO) {
return success(stockWorkshopDetailService.createStockWorkshopDetail(createReqVO));
}
@PutMapping("/update")
@Operation(summary = "更新车间仓明细")
@PreAuthorize("@ss.hasPermission('mes:stock-workshop-detail:update')")
public CommonResult<Boolean> updateStockWorkshopDetail(@Valid @RequestBody StockWorkshopDetailSaveReqVO updateReqVO) {
stockWorkshopDetailService.updateStockWorkshopDetail(updateReqVO);
return success(true);
}
@DeleteMapping("/delete")
@Operation(summary = "删除车间仓明细")
@Parameter(name = "id", description = "编号", required = true)
@PreAuthorize("@ss.hasPermission('mes:stock-workshop-detail:delete')")
public CommonResult<Boolean> deleteStockWorkshopDetail(@RequestParam("id") Long id) {
stockWorkshopDetailService.deleteStockWorkshopDetail(id);
return success(true);
}
@GetMapping("/get")
@Operation(summary = "获得车间仓明细")
@Parameter(name = "id", description = "编号", required = true, example = "1024")
@PreAuthorize("@ss.hasPermission('mes:stock-workshop-detail:query')")
public CommonResult<StockWorkshopDetailRespVO> getStockWorkshopDetail(@RequestParam("id") Long id) {
StockWorkshopDetailDO stockWorkshopDetail = stockWorkshopDetailService.getStockWorkshopDetail(id);
return success(BeanUtils.toBean(stockWorkshopDetail, StockWorkshopDetailRespVO.class));
}
@GetMapping("/page")
@Operation(summary = "获得车间仓明细分页")
@PreAuthorize("@ss.hasPermission('mes:stock-workshop-detail:query')")
public CommonResult<PageResult<StockWorkshopDetailRespVO>> getStockWorkshopDetailPage(@Valid StockWorkshopDetailPageReqVO pageReqVO) {
PageResult<StockWorkshopDetailDO> pageResult = stockWorkshopDetailService.getStockWorkshopDetailPage(pageReqVO);
return success(BeanUtils.toBean(pageResult, StockWorkshopDetailRespVO.class));
}
@GetMapping("/export-excel")
@Operation(summary = "导出车间仓明细 Excel")
@PreAuthorize("@ss.hasPermission('mes:stock-workshop-detail:export')")
@ApiAccessLog(operateType = EXPORT)
public void exportStockWorkshopDetailExcel(@Valid StockWorkshopDetailPageReqVO pageReqVO,
HttpServletResponse response) throws IOException {
pageReqVO.setPageSize(PageParam.PAGE_SIZE_NONE);
List<StockWorkshopDetailDO> list = stockWorkshopDetailService.getStockWorkshopDetailPage(pageReqVO).getList();
// 导出 Excel
ExcelUtils.write(response, "车间仓明细.xls", "数据", StockWorkshopDetailRespVO.class,
BeanUtils.toBean(list, StockWorkshopDetailRespVO.class));
}
}

@ -0,0 +1,51 @@
package cn.iocoder.yudao.module.mes.controller.admin.stockworkshop.vo;
import lombok.*;
import java.util.*;
import io.swagger.v3.oas.annotations.media.Schema;
import cn.iocoder.yudao.framework.common.pojo.PageParam;
import java.math.BigDecimal;
import org.springframework.format.annotation.DateTimeFormat;
import java.time.LocalDateTime;
import static cn.iocoder.yudao.framework.common.util.date.DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND;
@Schema(description = "管理后台 - 车间仓明细分页 Request VO")
@Data
@EqualsAndHashCode(callSuper = true)
@ToString(callSuper = true)
public class StockWorkshopDetailPageReqVO extends PageParam {
@Schema(description = "原料id", example = "7505")
private Long itemId;
@Schema(description = "数量", example = "28845")
private BigDecimal count;
@Schema(description = "明细类别", example = "2")
private String detailType;
@Schema(description = "领料单")
private String itemRequisitionCode;
@Schema(description = "领料明细id", example = "877")
private Long itemRequisitionDetailId;
@Schema(description = "投料单")
private String feedingRecordCode;
@Schema(description = "投料id", example = "19286")
private Long feedingRecordId;
@Schema(description = "操作人员", example = "26362")
private Long userId;
@Schema(description = "单据时间")
@DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)
private LocalDateTime[] operateTime;
@Schema(description = "创建时间")
@DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)
private LocalDateTime[] createTime;
}

@ -0,0 +1,64 @@
package cn.iocoder.yudao.module.mes.controller.admin.stockworkshop.vo;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.*;
import java.util.*;
import java.util.*;
import java.math.BigDecimal;
import org.springframework.format.annotation.DateTimeFormat;
import java.time.LocalDateTime;
import com.alibaba.excel.annotation.*;
import cn.iocoder.yudao.framework.excel.core.annotations.DictFormat;
import cn.iocoder.yudao.framework.excel.core.convert.DictConvert;
@Schema(description = "管理后台 - 车间仓明细 Response VO")
@Data
@ExcelIgnoreUnannotated
public class StockWorkshopDetailRespVO {
@Schema(description = "id", requiredMode = Schema.RequiredMode.REQUIRED, example = "24842")
@ExcelProperty("id")
private Long id;
@Schema(description = "原料id", requiredMode = Schema.RequiredMode.REQUIRED, example = "7505")
@ExcelProperty("原料id")
private Long itemId;
@Schema(description = "数量", requiredMode = Schema.RequiredMode.REQUIRED, example = "28845")
@ExcelProperty("数量")
private BigDecimal count;
@Schema(description = "明细类别", example = "2")
@ExcelProperty(value = "明细类别", converter = DictConvert.class)
@DictFormat("mes_stock_workshop_detail_type") // TODO 代码优化:建议设置到对应的 DictTypeConstants 枚举类中
private String detailType;
@Schema(description = "领料单")
@ExcelProperty("领料单")
private String itemRequisitionCode;
@Schema(description = "领料明细id", example = "877")
@ExcelProperty("领料明细id")
private Long itemRequisitionDetailId;
@Schema(description = "投料单")
@ExcelProperty("投料单")
private String feedingRecordCode;
@Schema(description = "投料id", example = "19286")
@ExcelProperty("投料id")
private Long feedingRecordId;
@Schema(description = "操作人员", requiredMode = Schema.RequiredMode.REQUIRED, example = "26362")
@ExcelProperty("操作人员")
private Long userId;
@Schema(description = "单据时间")
@ExcelProperty("单据时间")
private LocalDateTime operateTime;
@Schema(description = "创建时间", requiredMode = Schema.RequiredMode.REQUIRED)
@ExcelProperty("创建时间")
private LocalDateTime createTime;
}

@ -0,0 +1,48 @@
package cn.iocoder.yudao.module.mes.controller.admin.stockworkshop.vo;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.*;
import java.math.BigDecimal;
import org.springframework.format.annotation.DateTimeFormat;
import javax.validation.constraints.NotNull;
import java.time.LocalDateTime;
@Schema(description = "管理后台 - 车间仓明细新增/修改 Request VO")
@Data
public class StockWorkshopDetailSaveReqVO {
@Schema(description = "id", requiredMode = Schema.RequiredMode.REQUIRED, example = "24842")
private Long id;
@Schema(description = "原料id", requiredMode = Schema.RequiredMode.REQUIRED, example = "7505")
@NotNull(message = "原料id不能为空")
private Long itemId;
@Schema(description = "数量", requiredMode = Schema.RequiredMode.REQUIRED, example = "28845")
@NotNull(message = "数量不能为空")
private BigDecimal count;
@Schema(description = "明细类别", example = "2")
private String detailType;
@Schema(description = "领料单")
private String itemRequisitionCode;
@Schema(description = "领料明细id", example = "877")
private Long itemRequisitionDetailId;
@Schema(description = "投料单")
private String feedingRecordCode;
@Schema(description = "投料id", example = "19286")
private Long feedingRecordId;
@Schema(description = "操作人员", requiredMode = Schema.RequiredMode.REQUIRED, example = "26362")
@NotNull(message = "操作人员不能为空")
private Long userId;
@Schema(description = "单据时间")
private LocalDateTime operateTime;
}

@ -0,0 +1,32 @@
package cn.iocoder.yudao.module.mes.controller.admin.stockworkshop.vo;
import lombok.*;
import java.util.*;
import io.swagger.v3.oas.annotations.media.Schema;
import cn.iocoder.yudao.framework.common.pojo.PageParam;
import java.math.BigDecimal;
import org.springframework.format.annotation.DateTimeFormat;
import java.time.LocalDateTime;
import static cn.iocoder.yudao.framework.common.util.date.DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND;
@Schema(description = "管理后台 - 车间仓库存分页 Request VO")
@Data
@EqualsAndHashCode(callSuper = true)
@ToString(callSuper = true)
public class StockWorkshopPageReqVO extends PageParam {
@Schema(description = "原料编号", example = "25972")
private Long itemId;
@Schema(description = "库存数量", example = "30971")
private BigDecimal count;
@Schema(description = "分类", example = "2548")
private Long categoryId;
@Schema(description = "创建时间")
@DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)
private LocalDateTime[] createTime;
}

@ -0,0 +1,37 @@
package cn.iocoder.yudao.module.mes.controller.admin.stockworkshop.vo;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.*;
import java.util.*;
import java.util.*;
import java.math.BigDecimal;
import org.springframework.format.annotation.DateTimeFormat;
import java.time.LocalDateTime;
import com.alibaba.excel.annotation.*;
@Schema(description = "管理后台 - 车间仓库存 Response VO")
@Data
@ExcelIgnoreUnannotated
public class StockWorkshopRespVO {
@Schema(description = "id", requiredMode = Schema.RequiredMode.REQUIRED, example = "20864")
@ExcelProperty("id")
private Long id;
@Schema(description = "原料编号", requiredMode = Schema.RequiredMode.REQUIRED, example = "25972")
@ExcelProperty("原料编号")
private Long itemId;
@Schema(description = "库存数量", requiredMode = Schema.RequiredMode.REQUIRED, example = "30971")
@ExcelProperty("库存数量")
private BigDecimal count;
@Schema(description = "分类", example = "2548")
@ExcelProperty("分类")
private Long categoryId;
@Schema(description = "创建时间", requiredMode = Schema.RequiredMode.REQUIRED)
@ExcelProperty("创建时间")
private LocalDateTime createTime;
}

@ -0,0 +1,27 @@
package cn.iocoder.yudao.module.mes.controller.admin.stockworkshop.vo;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.*;
import javax.validation.constraints.NotNull;
import java.math.BigDecimal;
@Schema(description = "管理后台 - 车间仓库存新增/修改 Request VO")
@Data
public class StockWorkshopSaveReqVO {
@Schema(description = "id", requiredMode = Schema.RequiredMode.REQUIRED, example = "20864")
private Long id;
@Schema(description = "原料编号", requiredMode = Schema.RequiredMode.REQUIRED, example = "25972")
@NotNull(message = "原料编号不能为空")
private Long itemId;
@Schema(description = "库存数量", requiredMode = Schema.RequiredMode.REQUIRED, example = "30971")
@NotNull(message = "库存数量不能为空")
private BigDecimal count;
@Schema(description = "分类", example = "2548")
private Long categoryId;
}

@ -0,0 +1,81 @@
package cn.iocoder.yudao.module.mes.dal.dataobject.feedingrecord;
import lombok.*;
import java.util.*;
import java.math.BigDecimal;
import java.time.LocalDateTime;
import java.time.LocalDateTime;
import java.time.LocalDateTime;
import com.baomidou.mybatisplus.annotation.*;
import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
/**
* DO
*
* @author
*/
@TableName("mes_feeding_record")
@KeySequence("mes_feeding_record_seq") // 用于 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库的主键自增。如果是 MySQL 等数据库,可不写。
@Data
@EqualsAndHashCode(callSuper = true)
@ToString(callSuper = true)
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class FeedingRecordDO extends BaseDO {
/**
* id
*/
@TableId
private Long id;
/**
*
*/
private String feedingRecordCode;
/**
* id
*/
private Long productId;
/**
* id
*/
private Long planId;
/**
* id
*/
private Long itemId;
/**
* 线
*
* {@link TODO mes_feeding_pipeline }
*/
private String feedingPipeline;
/**
*
*
* {@link TODO mes_feeding_type }
*/
private String feedingType;
/**
*
*/
private BigDecimal weight;
/**
*
*/
private LocalDateTime feedingTime;
/**
*
*/
private Long userId;
/**
*
*/
private String remark;
/**
*
*/
private String recordStatus;
}

@ -0,0 +1,44 @@
package cn.iocoder.yudao.module.mes.dal.dataobject.stockworkshop;
import lombok.*;
import java.util.*;
import java.math.BigDecimal;
import java.time.LocalDateTime;
import java.time.LocalDateTime;
import com.baomidou.mybatisplus.annotation.*;
import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
/**
* DO
*
* @author
*/
@TableName("mes_stock_workshop")
@KeySequence("mes_stock_workshop_seq") // 用于 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库的主键自增。如果是 MySQL 等数据库,可不写。
@Data
@EqualsAndHashCode(callSuper = true)
@ToString(callSuper = true)
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class StockWorkshopDO extends BaseDO {
/**
* id
*/
@TableId
private Long id;
/**
*
*/
private Long itemId;
/**
*
*/
private BigDecimal count;
/**
*
*/
private Long categoryId;
}

@ -0,0 +1,71 @@
package cn.iocoder.yudao.module.mes.dal.dataobject.stockworkshop;
import lombok.*;
import java.util.*;
import java.math.BigDecimal;
import java.time.LocalDateTime;
import java.time.LocalDateTime;
import java.time.LocalDateTime;
import com.baomidou.mybatisplus.annotation.*;
import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
/**
* DO
*
* @author
*/
@TableName("mes_stock_workshop_detail")
@KeySequence("mes_stock_workshop_detail_seq") // 用于 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库的主键自增。如果是 MySQL 等数据库,可不写。
@Data
@EqualsAndHashCode(callSuper = true)
@ToString(callSuper = true)
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class StockWorkshopDetailDO extends BaseDO {
/**
* id
*/
@TableId
private Long id;
/**
* id
*/
private Long itemId;
/**
*
*/
private BigDecimal count;
/**
*
*
* {@link TODO mes_stock_workshop_detail_type }
*/
private String detailType;
/**
*
*/
private String itemRequisitionCode;
/**
* id
*/
private Long itemRequisitionDetailId;
/**
*
*/
private String feedingRecordCode;
/**
* id
*/
private Long feedingRecordId;
/**
*
*/
private Long userId;
/**
*
*/
private LocalDateTime operateTime;
}

@ -0,0 +1,37 @@
package cn.iocoder.yudao.module.mes.dal.mysql.feedingrecord;
import java.util.*;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
import cn.iocoder.yudao.module.mes.dal.dataobject.feedingrecord.FeedingRecordDO;
import org.apache.ibatis.annotations.Mapper;
import cn.iocoder.yudao.module.mes.controller.admin.feedingrecord.vo.*;
/**
* Mapper
*
* @author
*/
@Mapper
public interface FeedingRecordMapper extends BaseMapperX<FeedingRecordDO> {
default PageResult<FeedingRecordDO> selectPage(FeedingRecordPageReqVO reqVO) {
return selectPage(reqVO, new LambdaQueryWrapperX<FeedingRecordDO>()
.eqIfPresent(FeedingRecordDO::getFeedingRecordCode, reqVO.getFeedingRecordCode())
.eqIfPresent(FeedingRecordDO::getProductId, reqVO.getProductId())
.eqIfPresent(FeedingRecordDO::getPlanId, reqVO.getPlanId())
.eqIfPresent(FeedingRecordDO::getItemId, reqVO.getItemId())
.eqIfPresent(FeedingRecordDO::getFeedingPipeline, reqVO.getFeedingPipeline())
.eqIfPresent(FeedingRecordDO::getFeedingType, reqVO.getFeedingType())
.eqIfPresent(FeedingRecordDO::getWeight, reqVO.getWeight())
.betweenIfPresent(FeedingRecordDO::getFeedingTime, reqVO.getFeedingTime())
.eqIfPresent(FeedingRecordDO::getUserId, reqVO.getUserId())
.eqIfPresent(FeedingRecordDO::getRemark, reqVO.getRemark())
.eqIfPresent(FeedingRecordDO::getRecordStatus, reqVO.getRecordStatus())
.betweenIfPresent(FeedingRecordDO::getCreateTime, reqVO.getCreateTime())
.orderByDesc(FeedingRecordDO::getId));
}
}

@ -0,0 +1,35 @@
package cn.iocoder.yudao.module.mes.dal.mysql.stockworkshop;
import java.util.*;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
import cn.iocoder.yudao.module.mes.dal.dataobject.stockworkshop.StockWorkshopDetailDO;
import org.apache.ibatis.annotations.Mapper;
import cn.iocoder.yudao.module.mes.controller.admin.stockworkshop.vo.*;
/**
* Mapper
*
* @author
*/
@Mapper
public interface StockWorkshopDetailMapper extends BaseMapperX<StockWorkshopDetailDO> {
default PageResult<StockWorkshopDetailDO> selectPage(StockWorkshopDetailPageReqVO reqVO) {
return selectPage(reqVO, new LambdaQueryWrapperX<StockWorkshopDetailDO>()
.eqIfPresent(StockWorkshopDetailDO::getItemId, reqVO.getItemId())
.eqIfPresent(StockWorkshopDetailDO::getCount, reqVO.getCount())
.eqIfPresent(StockWorkshopDetailDO::getDetailType, reqVO.getDetailType())
.eqIfPresent(StockWorkshopDetailDO::getItemRequisitionCode, reqVO.getItemRequisitionCode())
.eqIfPresent(StockWorkshopDetailDO::getItemRequisitionDetailId, reqVO.getItemRequisitionDetailId())
.eqIfPresent(StockWorkshopDetailDO::getFeedingRecordCode, reqVO.getFeedingRecordCode())
.eqIfPresent(StockWorkshopDetailDO::getFeedingRecordId, reqVO.getFeedingRecordId())
.eqIfPresent(StockWorkshopDetailDO::getUserId, reqVO.getUserId())
.betweenIfPresent(StockWorkshopDetailDO::getOperateTime, reqVO.getOperateTime())
.betweenIfPresent(StockWorkshopDetailDO::getCreateTime, reqVO.getCreateTime())
.orderByDesc(StockWorkshopDetailDO::getId));
}
}

@ -0,0 +1,29 @@
package cn.iocoder.yudao.module.mes.dal.mysql.stockworkshop;
import java.util.*;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
import cn.iocoder.yudao.module.mes.dal.dataobject.stockworkshop.StockWorkshopDO;
import org.apache.ibatis.annotations.Mapper;
import cn.iocoder.yudao.module.mes.controller.admin.stockworkshop.vo.*;
/**
* Mapper
*
* @author
*/
@Mapper
public interface StockWorkshopMapper extends BaseMapperX<StockWorkshopDO> {
default PageResult<StockWorkshopDO> selectPage(StockWorkshopPageReqVO reqVO) {
return selectPage(reqVO, new LambdaQueryWrapperX<StockWorkshopDO>()
.eqIfPresent(StockWorkshopDO::getItemId, reqVO.getItemId())
.eqIfPresent(StockWorkshopDO::getCount, reqVO.getCount())
.eqIfPresent(StockWorkshopDO::getCategoryId, reqVO.getCategoryId())
.betweenIfPresent(StockWorkshopDO::getCreateTime, reqVO.getCreateTime())
.orderByDesc(StockWorkshopDO::getId));
}
}

@ -0,0 +1,56 @@
package cn.iocoder.yudao.module.mes.service.feedingrecord;
import java.util.*;
import cn.iocoder.yudao.module.mes.controller.admin.feedingrecord.vo.*;
import cn.iocoder.yudao.module.mes.dal.dataobject.feedingrecord.FeedingRecordDO;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.pojo.PageParam;
import javax.validation.Valid;
/**
* Service
*
* @author
*/
public interface FeedingRecordService {
/**
*
*
* @param createReqVO
* @return
*/
Long createFeedingRecord(@Valid FeedingRecordSaveReqVO createReqVO);
/**
*
*
* @param updateReqVO
*/
void updateFeedingRecord(@Valid FeedingRecordSaveReqVO updateReqVO);
/**
*
*
* @param id
*/
void deleteFeedingRecord(Long id);
/**
*
*
* @param id
* @return
*/
FeedingRecordDO getFeedingRecord(Long id);
/**
*
*
* @param pageReqVO
* @return
*/
PageResult<FeedingRecordDO> getFeedingRecordPage(FeedingRecordPageReqVO pageReqVO);
}

@ -0,0 +1,75 @@
package cn.iocoder.yudao.module.mes.service.feedingrecord;
import org.springframework.stereotype.Service;
import org.springframework.validation.annotation.Validated;
import org.springframework.transaction.annotation.Transactional;
import java.util.*;
import cn.iocoder.yudao.module.mes.controller.admin.feedingrecord.vo.*;
import cn.iocoder.yudao.module.mes.dal.dataobject.feedingrecord.FeedingRecordDO;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.pojo.PageParam;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.module.mes.dal.mysql.feedingrecord.FeedingRecordMapper;
import javax.annotation.Resource;
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.*;
/**
* Service
*
* @author
*/
@Service
@Validated
public class FeedingRecordServiceImpl implements FeedingRecordService {
@Resource
private FeedingRecordMapper feedingRecordMapper;
@Override
public Long createFeedingRecord(FeedingRecordSaveReqVO createReqVO) {
// 插入
FeedingRecordDO feedingRecord = BeanUtils.toBean(createReqVO, FeedingRecordDO.class);
feedingRecordMapper.insert(feedingRecord);
// 返回
return feedingRecord.getId();
}
@Override
public void updateFeedingRecord(FeedingRecordSaveReqVO updateReqVO) {
// 校验存在
validateFeedingRecordExists(updateReqVO.getId());
// 更新
FeedingRecordDO updateObj = BeanUtils.toBean(updateReqVO, FeedingRecordDO.class);
feedingRecordMapper.updateById(updateObj);
}
@Override
public void deleteFeedingRecord(Long id) {
// 校验存在
validateFeedingRecordExists(id);
// 删除
feedingRecordMapper.deleteById(id);
}
private void validateFeedingRecordExists(Long id) {
if (feedingRecordMapper.selectById(id) == null) {
throw exception(FEEDING_RECORD_NOT_EXISTS);
}
}
@Override
public FeedingRecordDO getFeedingRecord(Long id) {
return feedingRecordMapper.selectById(id);
}
@Override
public PageResult<FeedingRecordDO> getFeedingRecordPage(FeedingRecordPageReqVO pageReqVO) {
return feedingRecordMapper.selectPage(pageReqVO);
}
}

@ -0,0 +1,56 @@
package cn.iocoder.yudao.module.mes.service.stockworkshop;
import java.util.*;
import cn.iocoder.yudao.module.mes.controller.admin.stockworkshop.vo.*;
import cn.iocoder.yudao.module.mes.dal.dataobject.stockworkshop.StockWorkshopDetailDO;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.pojo.PageParam;
import javax.validation.Valid;
/**
* Service
*
* @author
*/
public interface StockWorkshopDetailService {
/**
*
*
* @param createReqVO
* @return
*/
Long createStockWorkshopDetail(@Valid StockWorkshopDetailSaveReqVO createReqVO);
/**
*
*
* @param updateReqVO
*/
void updateStockWorkshopDetail(@Valid StockWorkshopDetailSaveReqVO updateReqVO);
/**
*
*
* @param id
*/
void deleteStockWorkshopDetail(Long id);
/**
*
*
* @param id
* @return
*/
StockWorkshopDetailDO getStockWorkshopDetail(Long id);
/**
*
*
* @param pageReqVO
* @return
*/
PageResult<StockWorkshopDetailDO> getStockWorkshopDetailPage(StockWorkshopDetailPageReqVO pageReqVO);
}

@ -0,0 +1,75 @@
package cn.iocoder.yudao.module.mes.service.stockworkshop;
import org.springframework.stereotype.Service;
import org.springframework.validation.annotation.Validated;
import org.springframework.transaction.annotation.Transactional;
import java.util.*;
import cn.iocoder.yudao.module.mes.controller.admin.stockworkshop.vo.*;
import cn.iocoder.yudao.module.mes.dal.dataobject.stockworkshop.StockWorkshopDetailDO;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.pojo.PageParam;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.module.mes.dal.mysql.stockworkshop.StockWorkshopDetailMapper;
import javax.annotation.Resource;
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.*;
/**
* Service
*
* @author
*/
@Service
@Validated
public class StockWorkshopDetailServiceImpl implements StockWorkshopDetailService {
@Resource
private StockWorkshopDetailMapper stockWorkshopDetailMapper;
@Override
public Long createStockWorkshopDetail(StockWorkshopDetailSaveReqVO createReqVO) {
// 插入
StockWorkshopDetailDO stockWorkshopDetail = BeanUtils.toBean(createReqVO, StockWorkshopDetailDO.class);
stockWorkshopDetailMapper.insert(stockWorkshopDetail);
// 返回
return stockWorkshopDetail.getId();
}
@Override
public void updateStockWorkshopDetail(StockWorkshopDetailSaveReqVO updateReqVO) {
// 校验存在
validateStockWorkshopDetailExists(updateReqVO.getId());
// 更新
StockWorkshopDetailDO updateObj = BeanUtils.toBean(updateReqVO, StockWorkshopDetailDO.class);
stockWorkshopDetailMapper.updateById(updateObj);
}
@Override
public void deleteStockWorkshopDetail(Long id) {
// 校验存在
validateStockWorkshopDetailExists(id);
// 删除
stockWorkshopDetailMapper.deleteById(id);
}
private void validateStockWorkshopDetailExists(Long id) {
if (stockWorkshopDetailMapper.selectById(id) == null) {
throw exception(STOCK_WORKSHOP_DETAIL_NOT_EXISTS);
}
}
@Override
public StockWorkshopDetailDO getStockWorkshopDetail(Long id) {
return stockWorkshopDetailMapper.selectById(id);
}
@Override
public PageResult<StockWorkshopDetailDO> getStockWorkshopDetailPage(StockWorkshopDetailPageReqVO pageReqVO) {
return stockWorkshopDetailMapper.selectPage(pageReqVO);
}
}

@ -0,0 +1,56 @@
package cn.iocoder.yudao.module.mes.service.stockworkshop;
import java.util.*;
import cn.iocoder.yudao.module.mes.controller.admin.stockworkshop.vo.*;
import cn.iocoder.yudao.module.mes.dal.dataobject.stockworkshop.StockWorkshopDO;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.pojo.PageParam;
import javax.validation.Valid;
/**
* Service
*
* @author
*/
public interface StockWorkshopService {
/**
*
*
* @param createReqVO
* @return
*/
Long createStockWorkshop(@Valid StockWorkshopSaveReqVO createReqVO);
/**
*
*
* @param updateReqVO
*/
void updateStockWorkshop(@Valid StockWorkshopSaveReqVO updateReqVO);
/**
*
*
* @param id
*/
void deleteStockWorkshop(Long id);
/**
*
*
* @param id
* @return
*/
StockWorkshopDO getStockWorkshop(Long id);
/**
*
*
* @param pageReqVO
* @return
*/
PageResult<StockWorkshopDO> getStockWorkshopPage(StockWorkshopPageReqVO pageReqVO);
}

@ -0,0 +1,75 @@
package cn.iocoder.yudao.module.mes.service.stockworkshop;
import org.springframework.stereotype.Service;
import org.springframework.validation.annotation.Validated;
import org.springframework.transaction.annotation.Transactional;
import java.util.*;
import cn.iocoder.yudao.module.mes.controller.admin.stockworkshop.vo.*;
import cn.iocoder.yudao.module.mes.dal.dataobject.stockworkshop.StockWorkshopDO;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.pojo.PageParam;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.module.mes.dal.mysql.stockworkshop.StockWorkshopMapper;
import javax.annotation.Resource;
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.*;
/**
* Service
*
* @author
*/
@Service
@Validated
public class StockWorkshopServiceImpl implements StockWorkshopService {
@Resource
private StockWorkshopMapper stockWorkshopMapper;
@Override
public Long createStockWorkshop(StockWorkshopSaveReqVO createReqVO) {
// 插入
StockWorkshopDO stockWorkshop = BeanUtils.toBean(createReqVO, StockWorkshopDO.class);
stockWorkshopMapper.insert(stockWorkshop);
// 返回
return stockWorkshop.getId();
}
@Override
public void updateStockWorkshop(StockWorkshopSaveReqVO updateReqVO) {
// 校验存在
validateStockWorkshopExists(updateReqVO.getId());
// 更新
StockWorkshopDO updateObj = BeanUtils.toBean(updateReqVO, StockWorkshopDO.class);
stockWorkshopMapper.updateById(updateObj);
}
@Override
public void deleteStockWorkshop(Long id) {
// 校验存在
validateStockWorkshopExists(id);
// 删除
stockWorkshopMapper.deleteById(id);
}
private void validateStockWorkshopExists(Long id) {
if (stockWorkshopMapper.selectById(id) == null) {
throw exception(STOCK_WORKSHOP_NOT_EXISTS);
}
}
@Override
public StockWorkshopDO getStockWorkshop(Long id) {
return stockWorkshopMapper.selectById(id);
}
@Override
public PageResult<StockWorkshopDO> getStockWorkshopPage(StockWorkshopPageReqVO pageReqVO) {
return stockWorkshopMapper.selectPage(pageReqVO);
}
}

@ -0,0 +1,12 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="cn.iocoder.yudao.module.mes.dal.mysql.feedingrecord.FeedingRecordMapper">
<!--
一般情况下,尽可能使用 Mapper 进行 CRUD 增删改查即可。
无法满足的场景,例如说多表关联查询,才使用 XML 编写 SQL。
代码生成器暂时只生成 Mapper XML 文件本身,更多推荐 MybatisX 快速开发插件来生成查询。
文档可见https://www.iocoder.cn/MyBatis/x-plugins/
-->
</mapper>

@ -0,0 +1,12 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="cn.iocoder.yudao.module.mes.dal.mysql.stockworkshop.StockWorkshopDetailMapper">
<!--
一般情况下,尽可能使用 Mapper 进行 CRUD 增删改查即可。
无法满足的场景,例如说多表关联查询,才使用 XML 编写 SQL。
代码生成器暂时只生成 Mapper XML 文件本身,更多推荐 MybatisX 快速开发插件来生成查询。
文档可见https://www.iocoder.cn/MyBatis/x-plugins/
-->
</mapper>

@ -0,0 +1,12 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="cn.iocoder.yudao.module.mes.dal.mysql.stockworkshop.StockWorkshopMapper">
<!--
一般情况下,尽可能使用 Mapper 进行 CRUD 增删改查即可。
无法满足的场景,例如说多表关联查询,才使用 XML 编写 SQL。
代码生成器暂时只生成 Mapper XML 文件本身,更多推荐 MybatisX 快速开发插件来生成查询。
文档可见https://www.iocoder.cn/MyBatis/x-plugins/
-->
</mapper>

@ -0,0 +1,173 @@
package cn.iocoder.yudao.module.mes.service.feedingrecord;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.mock.mockito.MockBean;
import cn.iocoder.yudao.framework.test.core.ut.BaseDbUnitTest;
import cn.iocoder.yudao.module.mes.controller.admin.feedingrecord.vo.*;
import cn.iocoder.yudao.module.mes.dal.dataobject.feedingrecord.FeedingRecordDO;
import cn.iocoder.yudao.module.mes.dal.mysql.feedingrecord.FeedingRecordMapper;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import org.springframework.context.annotation.Import;
import javax.annotation.Resource;
import java.util.*;
import java.time.LocalDateTime;
import static cn.hutool.core.util.RandomUtil.*;
import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.*;
import static cn.iocoder.yudao.framework.test.core.util.AssertUtils.*;
import static cn.iocoder.yudao.framework.test.core.util.RandomUtils.*;
import static cn.iocoder.yudao.framework.common.util.date.LocalDateTimeUtils.*;
import static cn.iocoder.yudao.framework.common.util.object.ObjectUtils.*;
import static cn.iocoder.yudao.framework.common.util.date.DateUtils.*;
import static org.junit.jupiter.api.Assertions.*;
import static org.mockito.Mockito.*;
/**
* {@link FeedingRecordServiceImpl}
*
* @author
*/
@Import(FeedingRecordServiceImpl.class)
public class FeedingRecordServiceImplTest extends BaseDbUnitTest {
@Resource
private FeedingRecordServiceImpl feedingRecordService;
@Resource
private FeedingRecordMapper feedingRecordMapper;
@Test
public void testCreateFeedingRecord_success() {
// 准备参数
FeedingRecordSaveReqVO createReqVO = randomPojo(FeedingRecordSaveReqVO.class).setId(null);
// 调用
Long feedingRecordId = feedingRecordService.createFeedingRecord(createReqVO);
// 断言
assertNotNull(feedingRecordId);
// 校验记录的属性是否正确
FeedingRecordDO feedingRecord = feedingRecordMapper.selectById(feedingRecordId);
assertPojoEquals(createReqVO, feedingRecord, "id");
}
@Test
public void testUpdateFeedingRecord_success() {
// mock 数据
FeedingRecordDO dbFeedingRecord = randomPojo(FeedingRecordDO.class);
feedingRecordMapper.insert(dbFeedingRecord);// @Sql: 先插入出一条存在的数据
// 准备参数
FeedingRecordSaveReqVO updateReqVO = randomPojo(FeedingRecordSaveReqVO.class, o -> {
o.setId(dbFeedingRecord.getId()); // 设置更新的 ID
});
// 调用
feedingRecordService.updateFeedingRecord(updateReqVO);
// 校验是否更新正确
FeedingRecordDO feedingRecord = feedingRecordMapper.selectById(updateReqVO.getId()); // 获取最新的
assertPojoEquals(updateReqVO, feedingRecord);
}
@Test
public void testUpdateFeedingRecord_notExists() {
// 准备参数
FeedingRecordSaveReqVO updateReqVO = randomPojo(FeedingRecordSaveReqVO.class);
// 调用, 并断言异常
assertServiceException(() -> feedingRecordService.updateFeedingRecord(updateReqVO), FEEDING_RECORD_NOT_EXISTS);
}
@Test
public void testDeleteFeedingRecord_success() {
// mock 数据
FeedingRecordDO dbFeedingRecord = randomPojo(FeedingRecordDO.class);
feedingRecordMapper.insert(dbFeedingRecord);// @Sql: 先插入出一条存在的数据
// 准备参数
Long id = dbFeedingRecord.getId();
// 调用
feedingRecordService.deleteFeedingRecord(id);
// 校验数据不存在了
assertNull(feedingRecordMapper.selectById(id));
}
@Test
public void testDeleteFeedingRecord_notExists() {
// 准备参数
Long id = randomLongId();
// 调用, 并断言异常
assertServiceException(() -> feedingRecordService.deleteFeedingRecord(id), FEEDING_RECORD_NOT_EXISTS);
}
@Test
@Disabled // TODO 请修改 null 为需要的值,然后删除 @Disabled 注解
public void testGetFeedingRecordPage() {
// mock 数据
FeedingRecordDO dbFeedingRecord = randomPojo(FeedingRecordDO.class, o -> { // 等会查询到
o.setFeedingRecordCode(null);
o.setProductId(null);
o.setPlanId(null);
o.setItemId(null);
o.setFeedingPipeline(null);
o.setFeedingType(null);
o.setWeight(null);
o.setFeedingTime(null);
o.setUserId(null);
o.setRemark(null);
o.setRecordStatus(null);
o.setCreateTime(null);
});
feedingRecordMapper.insert(dbFeedingRecord);
// 测试 feedingRecordCode 不匹配
feedingRecordMapper.insert(cloneIgnoreId(dbFeedingRecord, o -> o.setFeedingRecordCode(null)));
// 测试 productId 不匹配
feedingRecordMapper.insert(cloneIgnoreId(dbFeedingRecord, o -> o.setProductId(null)));
// 测试 planId 不匹配
feedingRecordMapper.insert(cloneIgnoreId(dbFeedingRecord, o -> o.setPlanId(null)));
// 测试 itemId 不匹配
feedingRecordMapper.insert(cloneIgnoreId(dbFeedingRecord, o -> o.setItemId(null)));
// 测试 feedingPipeline 不匹配
feedingRecordMapper.insert(cloneIgnoreId(dbFeedingRecord, o -> o.setFeedingPipeline(null)));
// 测试 feedingType 不匹配
feedingRecordMapper.insert(cloneIgnoreId(dbFeedingRecord, o -> o.setFeedingType(null)));
// 测试 weight 不匹配
feedingRecordMapper.insert(cloneIgnoreId(dbFeedingRecord, o -> o.setWeight(null)));
// 测试 feedingTime 不匹配
feedingRecordMapper.insert(cloneIgnoreId(dbFeedingRecord, o -> o.setFeedingTime(null)));
// 测试 userId 不匹配
feedingRecordMapper.insert(cloneIgnoreId(dbFeedingRecord, o -> o.setUserId(null)));
// 测试 remark 不匹配
feedingRecordMapper.insert(cloneIgnoreId(dbFeedingRecord, o -> o.setRemark(null)));
// 测试 recordStatus 不匹配
feedingRecordMapper.insert(cloneIgnoreId(dbFeedingRecord, o -> o.setRecordStatus(null)));
// 测试 createTime 不匹配
feedingRecordMapper.insert(cloneIgnoreId(dbFeedingRecord, o -> o.setCreateTime(null)));
// 准备参数
FeedingRecordPageReqVO reqVO = new FeedingRecordPageReqVO();
reqVO.setFeedingRecordCode(null);
reqVO.setProductId(null);
reqVO.setPlanId(null);
reqVO.setItemId(null);
reqVO.setFeedingPipeline(null);
reqVO.setFeedingType(null);
reqVO.setWeight(null);
reqVO.setFeedingTime(buildBetweenTime(2023, 2, 1, 2023, 2, 28));
reqVO.setUserId(null);
reqVO.setRemark(null);
reqVO.setRecordStatus(null);
reqVO.setCreateTime(buildBetweenTime(2023, 2, 1, 2023, 2, 28));
// 调用
PageResult<FeedingRecordDO> pageResult = feedingRecordService.getFeedingRecordPage(reqVO);
// 断言
assertEquals(1, pageResult.getTotal());
assertEquals(1, pageResult.getList().size());
assertPojoEquals(dbFeedingRecord, pageResult.getList().get(0));
}
}

@ -0,0 +1,166 @@
package cn.iocoder.yudao.module.mes.service.stockworkshop;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.mock.mockito.MockBean;
import cn.iocoder.yudao.framework.test.core.ut.BaseDbUnitTest;
import cn.iocoder.yudao.module.mes.controller.admin.stockworkshop.vo.*;
import cn.iocoder.yudao.module.mes.dal.dataobject.stockworkshop.StockWorkshopDetailDO;
import cn.iocoder.yudao.module.mes.dal.mysql.stockworkshop.StockWorkshopDetailMapper;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import org.springframework.context.annotation.Import;
import javax.annotation.Resource;
import java.util.*;
import java.time.LocalDateTime;
import static cn.hutool.core.util.RandomUtil.*;
import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.*;
import static cn.iocoder.yudao.framework.test.core.util.AssertUtils.*;
import static cn.iocoder.yudao.framework.test.core.util.RandomUtils.*;
import static cn.iocoder.yudao.framework.common.util.date.LocalDateTimeUtils.*;
import static cn.iocoder.yudao.framework.common.util.object.ObjectUtils.*;
import static cn.iocoder.yudao.framework.common.util.date.DateUtils.*;
import static org.junit.jupiter.api.Assertions.*;
import static org.mockito.Mockito.*;
/**
* {@link StockWorkshopDetailServiceImpl}
*
* @author
*/
@Import(StockWorkshopDetailServiceImpl.class)
public class StockWorkshopDetailServiceImplTest extends BaseDbUnitTest {
@Resource
private StockWorkshopDetailServiceImpl stockWorkshopDetailService;
@Resource
private StockWorkshopDetailMapper stockWorkshopDetailMapper;
@Test
public void testCreateStockWorkshopDetail_success() {
// 准备参数
StockWorkshopDetailSaveReqVO createReqVO = randomPojo(StockWorkshopDetailSaveReqVO.class).setId(null);
// 调用
Long stockWorkshopDetailId = stockWorkshopDetailService.createStockWorkshopDetail(createReqVO);
// 断言
assertNotNull(stockWorkshopDetailId);
// 校验记录的属性是否正确
StockWorkshopDetailDO stockWorkshopDetail = stockWorkshopDetailMapper.selectById(stockWorkshopDetailId);
assertPojoEquals(createReqVO, stockWorkshopDetail, "id");
}
@Test
public void testUpdateStockWorkshopDetail_success() {
// mock 数据
StockWorkshopDetailDO dbStockWorkshopDetail = randomPojo(StockWorkshopDetailDO.class);
stockWorkshopDetailMapper.insert(dbStockWorkshopDetail);// @Sql: 先插入出一条存在的数据
// 准备参数
StockWorkshopDetailSaveReqVO updateReqVO = randomPojo(StockWorkshopDetailSaveReqVO.class, o -> {
o.setId(dbStockWorkshopDetail.getId()); // 设置更新的 ID
});
// 调用
stockWorkshopDetailService.updateStockWorkshopDetail(updateReqVO);
// 校验是否更新正确
StockWorkshopDetailDO stockWorkshopDetail = stockWorkshopDetailMapper.selectById(updateReqVO.getId()); // 获取最新的
assertPojoEquals(updateReqVO, stockWorkshopDetail);
}
@Test
public void testUpdateStockWorkshopDetail_notExists() {
// 准备参数
StockWorkshopDetailSaveReqVO updateReqVO = randomPojo(StockWorkshopDetailSaveReqVO.class);
// 调用, 并断言异常
assertServiceException(() -> stockWorkshopDetailService.updateStockWorkshopDetail(updateReqVO), STOCK_WORKSHOP_DETAIL_NOT_EXISTS);
}
@Test
public void testDeleteStockWorkshopDetail_success() {
// mock 数据
StockWorkshopDetailDO dbStockWorkshopDetail = randomPojo(StockWorkshopDetailDO.class);
stockWorkshopDetailMapper.insert(dbStockWorkshopDetail);// @Sql: 先插入出一条存在的数据
// 准备参数
Long id = dbStockWorkshopDetail.getId();
// 调用
stockWorkshopDetailService.deleteStockWorkshopDetail(id);
// 校验数据不存在了
assertNull(stockWorkshopDetailMapper.selectById(id));
}
@Test
public void testDeleteStockWorkshopDetail_notExists() {
// 准备参数
Long id = randomLongId();
// 调用, 并断言异常
assertServiceException(() -> stockWorkshopDetailService.deleteStockWorkshopDetail(id), STOCK_WORKSHOP_DETAIL_NOT_EXISTS);
}
@Test
@Disabled // TODO 请修改 null 为需要的值,然后删除 @Disabled 注解
public void testGetStockWorkshopDetailPage() {
// mock 数据
StockWorkshopDetailDO dbStockWorkshopDetail = randomPojo(StockWorkshopDetailDO.class, o -> { // 等会查询到
o.setItemId(null);
o.setCount(null);
o.setDetailType(null);
o.setItemRequisitionCode(null);
o.setItemRequisitionDetailId(null);
o.setFeedingRecordCode(null);
o.setFeedingRecordId(null);
o.setUserId(null);
o.setOperateTime(null);
o.setCreateTime(null);
});
stockWorkshopDetailMapper.insert(dbStockWorkshopDetail);
// 测试 itemId 不匹配
stockWorkshopDetailMapper.insert(cloneIgnoreId(dbStockWorkshopDetail, o -> o.setItemId(null)));
// 测试 count 不匹配
stockWorkshopDetailMapper.insert(cloneIgnoreId(dbStockWorkshopDetail, o -> o.setCount(null)));
// 测试 detailType 不匹配
stockWorkshopDetailMapper.insert(cloneIgnoreId(dbStockWorkshopDetail, o -> o.setDetailType(null)));
// 测试 itemRequisitionCode 不匹配
stockWorkshopDetailMapper.insert(cloneIgnoreId(dbStockWorkshopDetail, o -> o.setItemRequisitionCode(null)));
// 测试 itemRequisitionDetailId 不匹配
stockWorkshopDetailMapper.insert(cloneIgnoreId(dbStockWorkshopDetail, o -> o.setItemRequisitionDetailId(null)));
// 测试 feedingRecordCode 不匹配
stockWorkshopDetailMapper.insert(cloneIgnoreId(dbStockWorkshopDetail, o -> o.setFeedingRecordCode(null)));
// 测试 feedingRecordId 不匹配
stockWorkshopDetailMapper.insert(cloneIgnoreId(dbStockWorkshopDetail, o -> o.setFeedingRecordId(null)));
// 测试 userId 不匹配
stockWorkshopDetailMapper.insert(cloneIgnoreId(dbStockWorkshopDetail, o -> o.setUserId(null)));
// 测试 operateTime 不匹配
stockWorkshopDetailMapper.insert(cloneIgnoreId(dbStockWorkshopDetail, o -> o.setOperateTime(null)));
// 测试 createTime 不匹配
stockWorkshopDetailMapper.insert(cloneIgnoreId(dbStockWorkshopDetail, o -> o.setCreateTime(null)));
// 准备参数
StockWorkshopDetailPageReqVO reqVO = new StockWorkshopDetailPageReqVO();
reqVO.setItemId(null);
reqVO.setCount(null);
reqVO.setDetailType(null);
reqVO.setItemRequisitionCode(null);
reqVO.setItemRequisitionDetailId(null);
reqVO.setFeedingRecordCode(null);
reqVO.setFeedingRecordId(null);
reqVO.setUserId(null);
reqVO.setOperateTime(buildBetweenTime(2023, 2, 1, 2023, 2, 28));
reqVO.setCreateTime(buildBetweenTime(2023, 2, 1, 2023, 2, 28));
// 调用
PageResult<StockWorkshopDetailDO> pageResult = stockWorkshopDetailService.getStockWorkshopDetailPage(reqVO);
// 断言
assertEquals(1, pageResult.getTotal());
assertEquals(1, pageResult.getList().size());
assertPojoEquals(dbStockWorkshopDetail, pageResult.getList().get(0));
}
}

@ -0,0 +1,142 @@
package cn.iocoder.yudao.module.mes.service.stockworkshop;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.mock.mockito.MockBean;
import cn.iocoder.yudao.framework.test.core.ut.BaseDbUnitTest;
import cn.iocoder.yudao.module.mes.controller.admin.stockworkshop.vo.*;
import cn.iocoder.yudao.module.mes.dal.dataobject.stockworkshop.StockWorkshopDO;
import cn.iocoder.yudao.module.mes.dal.mysql.stockworkshop.StockWorkshopMapper;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import org.springframework.context.annotation.Import;
import javax.annotation.Resource;
import java.util.*;
import java.time.LocalDateTime;
import static cn.hutool.core.util.RandomUtil.*;
import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.*;
import static cn.iocoder.yudao.framework.test.core.util.AssertUtils.*;
import static cn.iocoder.yudao.framework.test.core.util.RandomUtils.*;
import static cn.iocoder.yudao.framework.common.util.date.LocalDateTimeUtils.*;
import static cn.iocoder.yudao.framework.common.util.object.ObjectUtils.*;
import static cn.iocoder.yudao.framework.common.util.date.DateUtils.*;
import static org.junit.jupiter.api.Assertions.*;
import static org.mockito.Mockito.*;
/**
* {@link StockWorkshopServiceImpl}
*
* @author
*/
@Import(StockWorkshopServiceImpl.class)
public class StockWorkshopServiceImplTest extends BaseDbUnitTest {
@Resource
private StockWorkshopServiceImpl stockWorkshopService;
@Resource
private StockWorkshopMapper stockWorkshopMapper;
@Test
public void testCreateStockWorkshop_success() {
// 准备参数
StockWorkshopSaveReqVO createReqVO = randomPojo(StockWorkshopSaveReqVO.class).setId(null);
// 调用
Long stockWorkshopId = stockWorkshopService.createStockWorkshop(createReqVO);
// 断言
assertNotNull(stockWorkshopId);
// 校验记录的属性是否正确
StockWorkshopDO stockWorkshop = stockWorkshopMapper.selectById(stockWorkshopId);
assertPojoEquals(createReqVO, stockWorkshop, "id");
}
@Test
public void testUpdateStockWorkshop_success() {
// mock 数据
StockWorkshopDO dbStockWorkshop = randomPojo(StockWorkshopDO.class);
stockWorkshopMapper.insert(dbStockWorkshop);// @Sql: 先插入出一条存在的数据
// 准备参数
StockWorkshopSaveReqVO updateReqVO = randomPojo(StockWorkshopSaveReqVO.class, o -> {
o.setId(dbStockWorkshop.getId()); // 设置更新的 ID
});
// 调用
stockWorkshopService.updateStockWorkshop(updateReqVO);
// 校验是否更新正确
StockWorkshopDO stockWorkshop = stockWorkshopMapper.selectById(updateReqVO.getId()); // 获取最新的
assertPojoEquals(updateReqVO, stockWorkshop);
}
@Test
public void testUpdateStockWorkshop_notExists() {
// 准备参数
StockWorkshopSaveReqVO updateReqVO = randomPojo(StockWorkshopSaveReqVO.class);
// 调用, 并断言异常
assertServiceException(() -> stockWorkshopService.updateStockWorkshop(updateReqVO), STOCK_WORKSHOP_NOT_EXISTS);
}
@Test
public void testDeleteStockWorkshop_success() {
// mock 数据
StockWorkshopDO dbStockWorkshop = randomPojo(StockWorkshopDO.class);
stockWorkshopMapper.insert(dbStockWorkshop);// @Sql: 先插入出一条存在的数据
// 准备参数
Long id = dbStockWorkshop.getId();
// 调用
stockWorkshopService.deleteStockWorkshop(id);
// 校验数据不存在了
assertNull(stockWorkshopMapper.selectById(id));
}
@Test
public void testDeleteStockWorkshop_notExists() {
// 准备参数
Long id = randomLongId();
// 调用, 并断言异常
assertServiceException(() -> stockWorkshopService.deleteStockWorkshop(id), STOCK_WORKSHOP_NOT_EXISTS);
}
@Test
@Disabled // TODO 请修改 null 为需要的值,然后删除 @Disabled 注解
public void testGetStockWorkshopPage() {
// mock 数据
StockWorkshopDO dbStockWorkshop = randomPojo(StockWorkshopDO.class, o -> { // 等会查询到
o.setItemId(null);
o.setCount(null);
o.setCategoryId(null);
o.setCreateTime(null);
});
stockWorkshopMapper.insert(dbStockWorkshop);
// 测试 itemId 不匹配
stockWorkshopMapper.insert(cloneIgnoreId(dbStockWorkshop, o -> o.setItemId(null)));
// 测试 count 不匹配
stockWorkshopMapper.insert(cloneIgnoreId(dbStockWorkshop, o -> o.setCount(null)));
// 测试 categoryId 不匹配
stockWorkshopMapper.insert(cloneIgnoreId(dbStockWorkshop, o -> o.setCategoryId(null)));
// 测试 createTime 不匹配
stockWorkshopMapper.insert(cloneIgnoreId(dbStockWorkshop, o -> o.setCreateTime(null)));
// 准备参数
StockWorkshopPageReqVO reqVO = new StockWorkshopPageReqVO();
reqVO.setItemId(null);
reqVO.setCount(null);
reqVO.setCategoryId(null);
reqVO.setCreateTime(buildBetweenTime(2023, 2, 1, 2023, 2, 28));
// 调用
PageResult<StockWorkshopDO> pageResult = stockWorkshopService.getStockWorkshopPage(reqVO);
// 断言
assertEquals(1, pageResult.getTotal());
assertEquals(1, pageResult.getList().size());
assertPojoEquals(dbStockWorkshop, pageResult.getList().get(0));
}
}

@ -34,6 +34,12 @@ DELETE FROM "mes_produce_report_detail";
-- 将该删表 SQL 语句,添加到 yudao-module-mes-biz 模块的 test/resources/sql/clean.sql 文件里
DELETE FROM "mes_machine_component";
-- 将该删表 SQL 语句,添加到 yudao-module-mes-biz 模块的 test/resources/sql/clean.sql 文件里
DELETE FROM "mes_stock_workshop_detail";
-- 将该删表 SQL 语句,添加到 yudao-module-mes-biz 模块的 test/resources/sql/clean.sql 文件里
DELETE FROM "mes_stock_workshop";
-- 将该删表 SQL 语句,添加到 yudao-module-mes-biz 模块的 test/resources/sql/clean.sql 文件里
DELETE FROM "mes_feeding_record";

@ -228,7 +228,7 @@ CREATE TABLE IF NOT EXISTS "mes_record_suijiang"
"updater" varchar DEFAULT '',
"update_time" datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
"deleted" bit NOT NULL DEFAULT FALSE,
"tenant_id" bigint ,
"tenant_id" bigint,
PRIMARY KEY ("id")
) COMMENT '碎浆记录表';
@ -330,9 +330,68 @@ CREATE TABLE IF NOT EXISTS "mes_machine_component"
"updater" varchar DEFAULT '',
"update_time" datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
"deleted" bit NOT NULL DEFAULT FALSE,
"tenant_id" bigint ,
"tenant_id" bigint,
"status" int NOT NULL,
"component_type" int NOT NULL,
"machine_type" varchar,
PRIMARY KEY ("id")
) COMMENT '机台组织表';
CREATE TABLE IF NOT EXISTS "mes_feeding_record"
(
"id" bigint NOT NULL GENERATED BY DEFAULT AS IDENTITY,
"feeding_record_code" varchar,
"product_id" bigint,
"plan_id" bigint,
"item_id" bigint,
"feeding_pipeline" varchar,
"feeding_type" varchar,
"weight" varchar,
"feeding_time" varchar,
"user_id" bigint,
"remark" varchar,
"record_status" varchar,
"creator" varchar DEFAULT '',
"create_time" datetime NOT NULL DEFAULT CURRENT_TIMESTAMP,
"updater" varchar DEFAULT '',
"update_time" datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
"deleted" bit NOT NULL DEFAULT FALSE,
"tenant_id" bigint ,
PRIMARY KEY ("id")
) COMMENT '投料记录';
CREATE TABLE IF NOT EXISTS "mes_stock_workshop"
(
"id" bigint NOT NULL GENERATED BY DEFAULT AS IDENTITY,
"item_id" bigint NOT NULL,
"count" varchar NOT NULL,
"category_id" bigint,
"creator" varchar DEFAULT '',
"create_time" datetime NOT NULL DEFAULT CURRENT_TIMESTAMP,
"updater" varchar DEFAULT '',
"update_time" datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
"deleted" bit NOT NULL DEFAULT FALSE,
"tenant_id" bigint ,
PRIMARY KEY ("id")
) COMMENT '车间仓库存';
CREATE TABLE IF NOT EXISTS "mes_stock_workshop_detail"
(
"id" bigint NOT NULL GENERATED BY DEFAULT AS IDENTITY,
"item_id" bigint NOT NULL,
"count" varchar NOT NULL,
"detail_type" varchar,
"item_requisition_code" varchar,
"item_requisition_detail_id" bigint,
"feeding_record_code" varchar,
"feeding_record_id" bigint,
"user_id" bigint NOT NULL,
"operate_time" varchar,
"creator" varchar DEFAULT '',
"create_time" datetime NOT NULL DEFAULT CURRENT_TIMESTAMP,
"updater" varchar DEFAULT '',
"update_time" datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
"deleted" bit NOT NULL DEFAULT FALSE,
"tenant_id" bigint ,
PRIMARY KEY ("id")
) COMMENT '车间仓出入库明细';

Loading…
Cancel
Save