Merge remote-tracking branch 'origin/master'

master
wanghao
commit 87715ec818

@ -0,0 +1,117 @@
package org.dromara.mes.controller;
import java.util.List;
import lombok.RequiredArgsConstructor;
import jakarta.servlet.http.HttpServletResponse;
import jakarta.validation.constraints.*;
import cn.dev33.satoken.annotation.SaCheckPermission;
import org.springframework.web.bind.annotation.*;
import org.springframework.validation.annotation.Validated;
import org.dromara.common.idempotent.annotation.RepeatSubmit;
import org.dromara.common.log.annotation.Log;
import org.dromara.common.web.core.BaseController;
import org.dromara.common.mybatis.core.page.PageQuery;
import org.dromara.common.core.domain.R;
import org.dromara.common.core.validate.AddGroup;
import org.dromara.common.core.validate.EditGroup;
import org.dromara.common.log.enums.BusinessType;
import org.dromara.common.excel.utils.ExcelUtil;
import org.dromara.mes.domain.vo.ProdBaseMachineProcessVo;
import org.dromara.mes.domain.bo.ProdBaseMachineProcessBo;
import org.dromara.mes.service.IProdBaseMachineProcessService;
import org.dromara.common.mybatis.core.page.TableDataInfo;
/**
*
* 访:/mes/baseMachineProcess
*
* @author Yinq
* @date 2025-03-04
*/
@Validated
@RequiredArgsConstructor
@RestController
@RequestMapping("/baseMachineProcess")
public class ProdBaseMachineProcessController extends BaseController {
private final IProdBaseMachineProcessService prodBaseMachineProcessService;
/**
*
*/
@SaCheckPermission("mes:baseMachineProcess:list")
@GetMapping("/list")
public TableDataInfo<ProdBaseMachineProcessVo> list(ProdBaseMachineProcessBo bo, PageQuery pageQuery) {
return prodBaseMachineProcessService.queryPageList(bo, pageQuery);
}
/**
*
*/
@SaCheckPermission("mes:baseMachineProcess:export")
@Log(title = "机台关联工序", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(ProdBaseMachineProcessBo bo, HttpServletResponse response) {
List<ProdBaseMachineProcessVo> list = prodBaseMachineProcessService.queryList(bo);
ExcelUtil.exportExcel(list, "机台关联工序", ProdBaseMachineProcessVo.class, response);
}
/**
*
*
* @param machineId
*/
@SaCheckPermission("mes:baseMachineProcess:query")
@GetMapping("/{machineId}")
public R<ProdBaseMachineProcessVo> getInfo(@NotNull(message = "主键不能为空")
@PathVariable Long machineId) {
return R.ok(prodBaseMachineProcessService.queryById(machineId));
}
/**
*
*/
@SaCheckPermission("mes:baseMachineProcess:add")
@Log(title = "机台关联工序", businessType = BusinessType.INSERT)
@RepeatSubmit()
@PostMapping()
public R<Void> add(@Validated(AddGroup.class) @RequestBody ProdBaseMachineProcessBo bo) {
return toAjax(prodBaseMachineProcessService.insertByBo(bo));
}
/**
*
*/
@SaCheckPermission("mes:baseMachineProcess:edit")
@Log(title = "机台关联工序", businessType = BusinessType.UPDATE)
@RepeatSubmit()
@PutMapping()
public R<Void> edit(@Validated(EditGroup.class) @RequestBody ProdBaseMachineProcessBo bo) {
return toAjax(prodBaseMachineProcessService.updateByBo(bo));
}
/**
*
*
* @param machineIds
*/
@SaCheckPermission("mes:baseMachineProcess:remove")
@Log(title = "机台关联工序", businessType = BusinessType.DELETE)
@DeleteMapping("/{machineIds}")
public R<Void> remove(@NotEmpty(message = "主键不能为空")
@PathVariable Long[] machineIds) {
return toAjax(prodBaseMachineProcessService.deleteWithValidByIds(List.of(machineIds), true));
}
/**
*
*/
@GetMapping("/getProdBaseMachineProcessList")
public R<List<ProdBaseMachineProcessVo>> getProdBaseMachineProcessList(ProdBaseMachineProcessBo bo) {
List<ProdBaseMachineProcessVo> list = prodBaseMachineProcessService.queryList(bo);
return R.ok(list);
}
}

@ -0,0 +1,80 @@
package org.dromara.mes.controller;
import jakarta.servlet.http.HttpServletResponse;
import lombok.RequiredArgsConstructor;
import org.dromara.common.excel.utils.ExcelUtil;
import org.dromara.common.mybatis.core.page.PageQuery;
import org.dromara.common.mybatis.core.page.TableDataInfo;
import org.dromara.common.web.core.BaseController;
import org.dromara.mes.domain.vo.*;
import org.dromara.mes.service.IProdReportService;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import java.util.List;
import java.util.Map;
/**
* MESController
*
* @author Yinq
* @date 2025-02-27
*/
@Validated
@RequiredArgsConstructor
@RestController
@RequestMapping("/prodReport")
public class ProdReportController extends BaseController {
private final IProdReportService prodReportService;
/**
*
*
* @param hashMap
* @return
*/
@GetMapping("/planCompletionRateReport")
public TableDataInfo<PlanCompletionRateReportVo> planCompletionRateReportList(@RequestParam(required = false) Map hashMap, PageQuery pageQuery) {
return prodReportService.planCompletionRateReportVoList(hashMap, pageQuery);
}
/**
*
*
* @param hashMap
* @return
*/
@PostMapping("/planCompletionRateReport/export")
public void planCompletionRateReportListExport(@RequestParam(required = false) Map hashMap, HttpServletResponse response) {
List<PlanCompletionRateReportVo> list = prodReportService.planCompletionRateReportVoList(hashMap);
ExcelUtil.exportExcel(list, "生产计划完成率报表", PlanCompletionRateReportVo.class, response);
}
/**
*
*
* @param hashMap
* @return
*/
@GetMapping("/planCompletionContrastReport")
public TableDataInfo<PlanCompletionContrastReportVo> planCompletionContrastReportVoList(@RequestParam(required = false) Map hashMap, PageQuery pageQuery) {
return prodReportService.planCompletionContrastReportVoList(hashMap, pageQuery);
}
/**
*
*
* @param hashMap
* @return
*/
@PostMapping("/planCompletionContrastReport/export")
public void planCompletionContrastReportExport(@RequestParam(required = false) Map hashMap, HttpServletResponse response) {
List<PlanCompletionContrastReportVo> list = prodReportService.planCompletionContrastReportVoList(hashMap);
ExcelUtil.exportExcel(list, "生产计划完成率对比报表", PlanCompletionContrastReportVo.class, response);
}
}

@ -72,5 +72,14 @@ public class ProdBaseMachineInfo extends TenantEntity {
*/
private String remark;
/**
* ID
*/
private Long workshopId;
/**
*
*/
@TableField(exist = false)
private String workshopName;
}

@ -0,0 +1,46 @@
package org.dromara.mes.domain;
import org.dromara.common.tenant.core.TenantEntity;
import com.baomidou.mybatisplus.annotation.*;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.io.Serial;
import java.util.Date;
/**
* prod_base_machine_process
*
* @author Yinq
* @date 2025-03-04
*/
@Data
@TableName("prod_base_machine_process")
public class ProdBaseMachineProcess extends TenantEntity {
@Serial
private static final long serialVersionUID = 1L;
/**
* ID
*/
private Long machineId;
/**
* ID
*/
private Long processId;
/**
*
*/
@TableField(exist = false)
private Long updateBy;
/**
*
*/
@TableField(exist = false)
private Date updateTime;
}

@ -8,6 +8,9 @@ import io.github.linpeilie.annotations.AutoMapper;
import lombok.Data;
import lombok.EqualsAndHashCode;
import jakarta.validation.constraints.*;
import org.dromara.mes.domain.ProdBaseMachineProcess;
import java.util.List;
/**
* prod_base_machine_info
@ -77,4 +80,10 @@ public class ProdBaseMachineInfoBo extends BaseEntity {
*/
private Long processId;
/**
* ID
*/
private Long workshopId;
private List<ProdBaseMachineProcess> baseMachineProcessList;
}

@ -0,0 +1,36 @@
package org.dromara.mes.domain.bo;
import org.dromara.mes.domain.ProdBaseMachineProcess;
import org.dromara.common.mybatis.core.domain.BaseEntity;
import org.dromara.common.core.validate.AddGroup;
import org.dromara.common.core.validate.EditGroup;
import io.github.linpeilie.annotations.AutoMapper;
import lombok.Data;
import lombok.EqualsAndHashCode;
import jakarta.validation.constraints.*;
/**
* prod_base_machine_process
*
* @author Yinq
* @date 2025-03-04
*/
@Data
@EqualsAndHashCode(callSuper = true)
@AutoMapper(target = ProdBaseMachineProcess.class, reverseConvertGenerate = false)
public class ProdBaseMachineProcessBo extends BaseEntity {
/**
* ID
*/
@NotNull(message = "机台ID不能为空", groups = {AddGroup.class, EditGroup.class})
private Long machineId;
/**
* ID
*/
@NotNull(message = "工序ID不能为空", groups = {AddGroup.class, EditGroup.class})
private Long processId;
}

@ -0,0 +1,103 @@
package org.dromara.mes.domain.vo;
import com.alibaba.excel.annotation.ExcelIgnoreUnannotated;
import com.alibaba.excel.annotation.ExcelProperty;
import lombok.Data;
import java.io.Serial;
import java.io.Serializable;
import java.math.BigDecimal;
/**
*
*
* @author Yinq
* @date 2025-02-28
*/
@Data
@ExcelIgnoreUnannotated
public class PlanCompletionContrastReportVo implements Serializable {
@Serial
private static final long serialVersionUID = 1L;
/**
*
*/
@ExcelProperty(value = "物料名称")
private String materialName;
/**
*
*/
@ExcelProperty(value = "当日计划")
private BigDecimal dayPlanNumber;
/**
*
*/
@ExcelProperty(value = "当日实际")
private BigDecimal dayActualNumber;
/**
*
*/
@ExcelProperty(value = "当日差异")
private BigDecimal dayDeviationNumber;
/**
*
*/
@ExcelProperty(value = "日完成率")
private String dayCompletionRate;
/**
*
*/
@ExcelProperty(value = "当月计划")
private BigDecimal monthPlanNumber;
/**
*
*/
@ExcelProperty(value = "当月实际")
private BigDecimal monthActualNumber;
/**
*
*/
@ExcelProperty(value = "当月差异")
private BigDecimal monthDeviationNumber;
/**
*
*/
@ExcelProperty(value = "月完成率")
private String monthCompletionRate;
/**
*
*/
@ExcelProperty(value = "当年计划")
private BigDecimal yearPlanNumber;
/**
*
*/
@ExcelProperty(value = "当年实际")
private BigDecimal yearActualNumber;
/**
*
*/
@ExcelProperty(value = "当年差异")
private BigDecimal yearDeviationNumber;
/**
*
*/
@ExcelProperty(value = "年完成率")
private String yearCompletionRate;
}

@ -0,0 +1,55 @@
package org.dromara.mes.domain.vo;
import com.alibaba.excel.annotation.ExcelIgnoreUnannotated;
import com.alibaba.excel.annotation.ExcelProperty;
import lombok.Data;
import java.io.Serial;
import java.io.Serializable;
import java.math.BigDecimal;
/**
*
*
* @author Yinq
* @date 2025-02-28
*/
@Data
@ExcelIgnoreUnannotated
public class PlanCompletionRateReportVo implements Serializable {
@Serial
private static final long serialVersionUID = 1L;
/**
*
*/
@ExcelProperty(value = "物料名称")
private String materialName;
/**
*
*/
@ExcelProperty(value = "计划数")
private BigDecimal planNumber;
/**
*
*/
@ExcelProperty(value = "实际数量")
private BigDecimal actualNumber;
/**
*
*/
@ExcelProperty(value = "偏差数")
private BigDecimal deviationNumber;
/**
*
*/
@ExcelProperty(value = "完成率")
private String completionRate;
}

@ -7,11 +7,12 @@ import org.dromara.common.excel.annotation.ExcelDictFormat;
import org.dromara.common.excel.convert.ExcelDictConvert;
import io.github.linpeilie.annotations.AutoMapper;
import lombok.Data;
import org.dromara.mes.domain.ProdBaseMachineProcess;
import java.io.Serial;
import java.io.Serializable;
import java.util.Date;
import java.util.List;
/**
@ -125,5 +126,17 @@ public class ProdBaseMachineInfoVo implements Serializable {
@ExcelProperty(value = "更新时间")
private Date updateTime;
/**
* ID
*/
private Long workshopId;
/**
*
*/
@ExcelProperty(value = "车间名称")
private String workshopName;
private List<ProdBaseMachineProcess> baseMachineProcessList;
}

@ -0,0 +1,44 @@
package org.dromara.mes.domain.vo;
import org.dromara.mes.domain.ProdBaseMachineProcess;
import com.alibaba.excel.annotation.ExcelIgnoreUnannotated;
import com.alibaba.excel.annotation.ExcelProperty;
import org.dromara.common.excel.annotation.ExcelDictFormat;
import org.dromara.common.excel.convert.ExcelDictConvert;
import io.github.linpeilie.annotations.AutoMapper;
import lombok.Data;
import java.io.Serial;
import java.io.Serializable;
import java.util.Date;
/**
* prod_base_machine_process
*
* @author Yinq
* @date 2025-03-04
*/
@Data
@ExcelIgnoreUnannotated
@AutoMapper(target = ProdBaseMachineProcess.class)
public class ProdBaseMachineProcessVo implements Serializable {
@Serial
private static final long serialVersionUID = 1L;
/**
* ID
*/
@ExcelProperty(value = "机台ID")
private Long machineId;
/**
* ID
*/
@ExcelProperty(value = "工序ID")
private Long processId;
}

@ -0,0 +1,15 @@
package org.dromara.mes.mapper;
import org.dromara.mes.domain.ProdBaseMachineProcess;
import org.dromara.mes.domain.vo.ProdBaseMachineProcessVo;
import org.dromara.common.mybatis.core.mapper.BaseMapperPlus;
/**
* Mapper
*
* @author Yinq
* @date 2025-03-04
*/
public interface ProdBaseMachineProcessMapper extends BaseMapperPlus<ProdBaseMachineProcess, ProdBaseMachineProcessVo> {
}

@ -0,0 +1,56 @@
package org.dromara.mes.mapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import org.apache.ibatis.annotations.Param;
import org.dromara.mes.domain.vo.PlanCompletionContrastReportVo;
import org.dromara.mes.domain.vo.PlanCompletionRateReportVo;
import java.util.List;
import java.util.Map;
/**
* MESMapper
*
* @author Yinq
* @date 2025-02-27
*/
public interface ProdReportMapper {
/**
*
*
* @param hashMap
* @param page
* @param tableName
* @return
*/
Page<PlanCompletionRateReportVo> planCompletionRateReportVoList(@Param("map") Map hashMap, @Param("page") Page<PlanCompletionRateReportVo> page, @Param("tableName") String tableName);
/**
*
*
* @param hashMap
* @return
*/
List<PlanCompletionRateReportVo> planCompletionRateReportVoList(@Param("map") Map hashMap, @Param("tableName") String tableName);
/**
*
*
* @param hashMap
* @param page
* @param tableName
* @return
*/
Page<PlanCompletionContrastReportVo> planCompletionContrastReportVoList(@Param("map") Map hashMap, @Param("page") Page<PlanCompletionContrastReportVo> page, @Param("tableName") String tableName);
/**
*
*
* @param hashMap
* @param tableName
* @return
*/
List<PlanCompletionContrastReportVo> planCompletionContrastReportVoList(@Param("map") Map hashMap, @Param("tableName") String tableName);
}

@ -0,0 +1,69 @@
package org.dromara.mes.service;
import org.dromara.mes.domain.ProdBaseMachineProcess;
import org.dromara.mes.domain.vo.ProdBaseMachineProcessVo;
import org.dromara.mes.domain.bo.ProdBaseMachineProcessBo;
import org.dromara.common.mybatis.core.page.TableDataInfo;
import org.dromara.common.mybatis.core.page.PageQuery;
import java.util.Collection;
import java.util.List;
/**
* Service
*
* @author Yinq
* @date 2025-03-04
*/
public interface IProdBaseMachineProcessService {
/**
*
*
* @param machineId
* @return
*/
ProdBaseMachineProcessVo queryById(Long machineId);
/**
*
*
* @param bo
* @param pageQuery
* @return
*/
TableDataInfo<ProdBaseMachineProcessVo> queryPageList(ProdBaseMachineProcessBo bo, PageQuery pageQuery);
/**
*
*
* @param bo
* @return
*/
List<ProdBaseMachineProcessVo> queryList(ProdBaseMachineProcessBo bo);
/**
*
*
* @param bo
* @return
*/
Boolean insertByBo(ProdBaseMachineProcessBo bo);
/**
*
*
* @param bo
* @return
*/
Boolean updateByBo(ProdBaseMachineProcessBo bo);
/**
*
*
* @param ids
* @param isValid
* @return
*/
Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid);
}

@ -0,0 +1,52 @@
package org.dromara.mes.service;
import org.dromara.common.mybatis.core.page.PageQuery;
import org.dromara.common.mybatis.core.page.TableDataInfo;
import org.dromara.mes.domain.vo.PlanCompletionContrastReportVo;
import org.dromara.mes.domain.vo.PlanCompletionRateReportVo;
import java.util.List;
import java.util.Map;
/**
* MESService
*
* @author Yinq
* @date 2025-02-27
*/
public interface IProdReportService {
/**
*
*
* @param hashMap
* @param pageQuery
* @return
*/
TableDataInfo<PlanCompletionRateReportVo> planCompletionRateReportVoList(Map hashMap, PageQuery pageQuery);
/**
*
*
* @param hashMap
* @return
*/
List<PlanCompletionRateReportVo> planCompletionRateReportVoList(Map hashMap);
/**
*
* @param hashMap
* @param pageQuery
* @return
*/
TableDataInfo<PlanCompletionContrastReportVo> planCompletionContrastReportVoList(Map hashMap, PageQuery pageQuery);
/**
*
*
* @param hashMap
* @return
*/
List<PlanCompletionContrastReportVo> planCompletionContrastReportVoList(Map hashMap);
}

@ -1,5 +1,6 @@
package org.dromara.mes.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import org.dromara.common.core.exception.ServiceException;
import org.dromara.common.core.utils.MapstructUtils;
import org.dromara.common.core.utils.StringUtils;
@ -10,12 +11,13 @@ import com.github.yulichang.toolkit.JoinWrappers;
import com.github.yulichang.wrapper.MPJLambdaWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import lombok.RequiredArgsConstructor;
import org.dromara.mes.domain.ProdBaseProcessInfo;
import org.dromara.mes.domain.ProdBaseStationInfo;
import org.dromara.mes.domain.*;
import org.dromara.mes.domain.bo.ProdBaseMouldInfoBo;
import org.dromara.mes.domain.vo.ProdBaseMouldInfoVo;
import org.dromara.mes.mapper.ProdBaseMachineProcessMapper;
import org.springframework.stereotype.Service;
import org.dromara.mes.domain.bo.ProdBaseMachineInfoBo;
import org.dromara.mes.domain.vo.ProdBaseMachineInfoVo;
import org.dromara.mes.domain.ProdBaseMachineInfo;
import org.dromara.mes.mapper.ProdBaseMachineInfoMapper;
import org.dromara.mes.service.IProdBaseMachineInfoService;
@ -35,6 +37,8 @@ public class ProdBaseMachineInfoServiceImpl implements IProdBaseMachineInfoServi
private final ProdBaseMachineInfoMapper baseMapper;
private final ProdBaseMachineProcessMapper prodBaseMachineProcessMapper;
/**
*
*
@ -42,8 +46,19 @@ public class ProdBaseMachineInfoServiceImpl implements IProdBaseMachineInfoServi
* @return
*/
@Override
public ProdBaseMachineInfoVo queryById(Long machineId){
return baseMapper.selectVoById(machineId);
public ProdBaseMachineInfoVo queryById(Long machineId) {
ProdBaseMachineInfoBo bo = new ProdBaseMachineInfoBo();
bo.setMachineId(machineId);
MPJLambdaWrapper<ProdBaseMachineInfo> lqw = buildQueryWrapper(bo);
ProdBaseMachineInfoVo prodBaseMachineInfoVo = baseMapper.selectVoOne(lqw);
//机台关联工序
MPJLambdaWrapper<ProdBaseMachineProcess> lqwRelation = JoinWrappers.lambda(ProdBaseMachineProcess.class)
.selectAll(ProdBaseMachineProcess.class)
.eq(bo.getMachineId() != null, ProdBaseMachineProcess::getMachineId, bo.getMachineId())
.orderByAsc(ProdBaseMachineProcess::getCreateTime);
List<ProdBaseMachineProcess> prodBaseMachineProcesses = prodBaseMachineProcessMapper.selectList(lqwRelation);
prodBaseMachineInfoVo.setBaseMachineProcessList(prodBaseMachineProcesses);
return prodBaseMachineInfoVo;
}
/**
@ -69,26 +84,29 @@ public class ProdBaseMachineInfoServiceImpl implements IProdBaseMachineInfoServi
@Override
public List<ProdBaseMachineInfoVo> queryList(ProdBaseMachineInfoBo bo) {
MPJLambdaWrapper<ProdBaseMachineInfo> lqw = buildQueryWrapper(bo);
if (StringUtils.isNotNull(bo.getProcessId())) {
lqw.leftJoin(ProdBaseMachineProcess.class, ProdBaseMachineProcess::getMachineId, ProdBaseMachineInfo::getMachineId)
.eq(StringUtils.isNotNull(bo.getProcessId()), ProdBaseMachineProcess::getProcessId, bo.getProcessId());
}
return baseMapper.selectVoList(lqw);
}
private MPJLambdaWrapper<ProdBaseMachineInfo> buildQueryWrapper(ProdBaseMachineInfoBo bo) {
Map<String, Object> params = bo.getParams();
MPJLambdaWrapper<ProdBaseMachineInfo> lqw = JoinWrappers.lambda(ProdBaseMachineInfo.class)
.selectAll(ProdBaseMachineInfo.class)
.leftJoin(ProdBaseStationInfo.class, ProdBaseStationInfo::getMachineId, ProdBaseMachineInfo::getMachineId)
.leftJoin(ProdBaseProcessInfo.class, ProdBaseProcessInfo::getProcessId, ProdBaseStationInfo::getProcessId)
.eq(bo.getMachineId() != null, ProdBaseMachineInfo::getMachineId, bo.getMachineId())
.like(StringUtils.isNotBlank(bo.getMachineCode()), ProdBaseMachineInfo::getMachineCode, bo.getMachineCode())
.like(StringUtils.isNotBlank(bo.getMachineName()), ProdBaseMachineInfo::getMachineName, bo.getMachineName())
.eq(StringUtils.isNotBlank(bo.getAssetNumber()), ProdBaseMachineInfo::getAssetNumber, bo.getAssetNumber())
.eq(StringUtils.isNotBlank(bo.getMachineLocation()), ProdBaseMachineInfo::getMachineLocation, bo.getMachineLocation())
.eq(StringUtils.isNotBlank(bo.getMachineType()), ProdBaseMachineInfo::getMachineType, bo.getMachineType())
.eq(StringUtils.isNotBlank(bo.getMachineSpec()), ProdBaseMachineInfo::getMachineSpec, bo.getMachineSpec())
.eq(StringUtils.isNotBlank(bo.getSupplierId()), ProdBaseMachineInfo::getSupplierId, bo.getSupplierId())
.eq(StringUtils.isNotBlank(bo.getMachineStatus()), ProdBaseMachineInfo::getMachineStatus, bo.getMachineStatus())
.eq(StringUtils.isNotNull(bo.getProcessId()), ProdBaseProcessInfo::getProcessId, bo.getProcessId())
.orderByAsc(ProdBaseMachineInfo::getCreateTime);
.selectAll(ProdBaseMachineInfo.class)
.select(ProdBaseWorkshopInfo::getWorkshopName)
.leftJoin(ProdBaseWorkshopInfo.class, ProdBaseWorkshopInfo::getWorkshopId, ProdBaseMachineInfo::getWorkshopId)
.eq(bo.getMachineId() != null, ProdBaseMachineInfo::getMachineId, bo.getMachineId())
.like(StringUtils.isNotBlank(bo.getMachineCode()), ProdBaseMachineInfo::getMachineCode, bo.getMachineCode())
.like(StringUtils.isNotBlank(bo.getMachineName()), ProdBaseMachineInfo::getMachineName, bo.getMachineName())
.eq(StringUtils.isNotBlank(bo.getMachineLocation()), ProdBaseMachineInfo::getMachineLocation, bo.getMachineLocation())
.eq(StringUtils.isNotBlank(bo.getMachineType()), ProdBaseMachineInfo::getMachineType, bo.getMachineType())
.eq(StringUtils.isNotBlank(bo.getMachineSpec()), ProdBaseMachineInfo::getMachineSpec, bo.getMachineSpec())
.eq(StringUtils.isNotBlank(bo.getSupplierId()), ProdBaseMachineInfo::getSupplierId, bo.getSupplierId())
.eq(StringUtils.isNotBlank(bo.getMachineStatus()), ProdBaseMachineInfo::getMachineStatus, bo.getMachineStatus())
.eq(StringUtils.isNotNull(bo.getWorkshopId()), ProdBaseMachineInfo::getWorkshopId, bo.getWorkshopId())
.orderByAsc(ProdBaseMachineInfo::getCreateTime);
return lqw;
}
@ -119,13 +137,22 @@ public class ProdBaseMachineInfoServiceImpl implements IProdBaseMachineInfoServi
public Boolean updateByBo(ProdBaseMachineInfoBo bo) {
ProdBaseMachineInfo update = MapstructUtils.convert(bo, ProdBaseMachineInfo.class);
validEntityBeforeSave(update);
List<ProdBaseMachineProcess> baseMachineProcessList = bo.getBaseMachineProcessList();
if (baseMachineProcessList.size() > 0) {
LambdaQueryWrapper<ProdBaseMachineProcess> lqw = Wrappers.lambdaQuery();
lqw.eq(StringUtils.isNotNull(bo.getMachineId()), ProdBaseMachineProcess::getMachineId, bo.getMachineId());
prodBaseMachineProcessMapper.delete(lqw);
for (ProdBaseMachineProcess relation : baseMachineProcessList) {
prodBaseMachineProcessMapper.insert(relation);
}
}
return baseMapper.updateById(update) > 0;
}
/**
*
*/
private void validEntityBeforeSave(ProdBaseMachineInfo entity){
private void validEntityBeforeSave(ProdBaseMachineInfo entity) {
//TODO 做一些数据校验,如唯一约束
if (StringUtils.isNotBlank(entity.getMachineCode())) {
ProdBaseMachineInfoBo query = new ProdBaseMachineInfoBo();
@ -148,7 +175,7 @@ public class ProdBaseMachineInfoServiceImpl implements IProdBaseMachineInfoServi
*/
@Override
public Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid) {
if(isValid){
if (isValid) {
//TODO 做一些业务上的校验,判断是否需要校验
}
return baseMapper.deleteByIds(ids) > 0;

@ -0,0 +1,133 @@
package org.dromara.mes.service.impl;
import org.dromara.common.core.utils.MapstructUtils;
import org.dromara.common.core.utils.StringUtils;
import org.dromara.common.mybatis.core.page.TableDataInfo;
import org.dromara.common.mybatis.core.page.PageQuery;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.github.yulichang.toolkit.JoinWrappers;
import com.github.yulichang.wrapper.MPJLambdaWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import org.dromara.mes.domain.bo.ProdBaseMachineProcessBo;
import org.dromara.mes.domain.vo.ProdBaseMachineProcessVo;
import org.dromara.mes.domain.ProdBaseMachineProcess;
import org.dromara.mes.mapper.ProdBaseMachineProcessMapper;
import org.dromara.mes.service.IProdBaseMachineProcessService;
import java.util.List;
import java.util.Map;
import java.util.Collection;
/**
* Service
*
* @author Yinq
* @date 2025-03-04
*/
@RequiredArgsConstructor
@Service
public class ProdBaseMachineProcessServiceImpl implements IProdBaseMachineProcessService {
private final ProdBaseMachineProcessMapper baseMapper;
/**
*
*
* @param machineId
* @return
*/
@Override
public ProdBaseMachineProcessVo queryById(Long machineId){
return baseMapper.selectVoById(machineId);
}
/**
*
*
* @param bo
* @param pageQuery
* @return
*/
@Override
public TableDataInfo<ProdBaseMachineProcessVo> queryPageList(ProdBaseMachineProcessBo bo, PageQuery pageQuery) {
MPJLambdaWrapper<ProdBaseMachineProcess> lqw = buildQueryWrapper(bo);
Page<ProdBaseMachineProcessVo> result = baseMapper.selectVoPage(pageQuery.build(), lqw);
return TableDataInfo.build(result);
}
/**
*
*
* @param bo
* @return
*/
@Override
public List<ProdBaseMachineProcessVo> queryList(ProdBaseMachineProcessBo bo) {
MPJLambdaWrapper<ProdBaseMachineProcess> lqw = buildQueryWrapper(bo);
return baseMapper.selectVoList(lqw);
}
private MPJLambdaWrapper<ProdBaseMachineProcess> buildQueryWrapper(ProdBaseMachineProcessBo bo) {
Map<String, Object> params = bo.getParams();
MPJLambdaWrapper<ProdBaseMachineProcess> lqw = JoinWrappers.lambda(ProdBaseMachineProcess.class)
.selectAll(ProdBaseMachineProcess.class)
.eq(bo.getMachineId() != null, ProdBaseMachineProcess::getMachineId, bo.getMachineId())
.eq(bo.getProcessId() != null, ProdBaseMachineProcess::getProcessId, bo.getProcessId())
.orderByDesc(ProdBaseMachineProcess::getCreateTime);
return lqw;
}
/**
*
*
* @param bo
* @return
*/
@Override
public Boolean insertByBo(ProdBaseMachineProcessBo bo) {
ProdBaseMachineProcess add = MapstructUtils.convert(bo, ProdBaseMachineProcess.class);
validEntityBeforeSave(add);
boolean flag = baseMapper.insert(add) > 0;
if (flag) {
bo.setMachineId(add.getMachineId());
}
return flag;
}
/**
*
*
* @param bo
* @return
*/
@Override
public Boolean updateByBo(ProdBaseMachineProcessBo bo) {
ProdBaseMachineProcess update = MapstructUtils.convert(bo, ProdBaseMachineProcess.class);
validEntityBeforeSave(update);
return baseMapper.updateById(update) > 0;
}
/**
*
*/
private void validEntityBeforeSave(ProdBaseMachineProcess entity){
//TODO 做一些数据校验,如唯一约束
}
/**
*
*
* @param ids
* @param isValid
* @return
*/
@Override
public Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid) {
if(isValid){
//TODO 做一些业务上的校验,判断是否需要校验
}
return baseMapper.deleteByIds(ids) > 0;
}
}

@ -0,0 +1,100 @@
package org.dromara.mes.service.impl;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import lombok.RequiredArgsConstructor;
import org.dromara.common.constant.DatabaseConstants;
import org.dromara.common.core.utils.StringUtils;
import org.dromara.common.mybatis.core.page.PageQuery;
import org.dromara.common.mybatis.core.page.TableDataInfo;
import org.dromara.mes.domain.vo.PlanCompletionContrastReportVo;
import org.dromara.mes.domain.vo.PlanCompletionRateReportVo;
import org.dromara.mes.mapper.ProdReportMapper;
import org.dromara.mes.service.IProdReportService;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Map;
/**
* MESService
*
* @author Yinq
* @date 2025-02-27
*/
@RequiredArgsConstructor
@Service
public class ProdReportServiceImpl implements IProdReportService {
private final ProdReportMapper prodReportMapper;
/**
*
*
* @param hashMap
* @return
*/
@Override
public TableDataInfo<PlanCompletionRateReportVo> planCompletionRateReportVoList(Map hashMap, PageQuery pageQuery) {
String tableName = getPlanInfoTableNameByProcessId(Long.parseLong(String.valueOf(hashMap.get("processId"))));
Page<PlanCompletionRateReportVo> page = prodReportMapper.planCompletionRateReportVoList(hashMap, pageQuery.build(), tableName);
return TableDataInfo.build(page);
}
/**
*
*
* @param hashMap
* @return
*/
@Override
public List<PlanCompletionRateReportVo> planCompletionRateReportVoList(Map hashMap) {
String tableName = getPlanInfoTableNameByProcessId(Long.parseLong(String.valueOf(hashMap.get("processId"))));
return prodReportMapper.planCompletionRateReportVoList(hashMap, tableName);
}
/**
*
*
* @param processId ID
* @return
*/
public String getPlanInfoTableNameByProcessId(Long processId) {
String tableName = null;
if (StringUtils.isNull(processId)) {
return null;
}
if (processId == 17L) {
tableName = DatabaseConstants.TABLE_NAME_PROD_PLAN_INFO_PREFIX + "_3";
} else if (processId == 18L) {
tableName = DatabaseConstants.TABLE_NAME_PROD_PLAN_INFO_PREFIX + "_4";
} else {
tableName = DatabaseConstants.TABLE_NAME_PROD_PLAN_INFO_PREFIX + "_2";
}
return tableName;
}
/**
*
* @param hashMap
* @param pageQuery
* @return
*/
@Override
public TableDataInfo<PlanCompletionContrastReportVo> planCompletionContrastReportVoList(Map hashMap, PageQuery pageQuery) {
String tableName = getPlanInfoTableNameByProcessId(Long.parseLong(String.valueOf(hashMap.get("processId"))));
Page<PlanCompletionContrastReportVo> page = prodReportMapper.planCompletionContrastReportVoList(hashMap, pageQuery.build(), tableName);
return TableDataInfo.build(page);
}
/**
*
* @param hashMap
* @return
*/
@Override
public List<PlanCompletionContrastReportVo> planCompletionContrastReportVoList(Map hashMap) {
String tableName = getPlanInfoTableNameByProcessId(Long.parseLong(String.valueOf(hashMap.get("processId"))));
return prodReportMapper.planCompletionContrastReportVoList(hashMap, tableName);
}
}

@ -0,0 +1,7 @@
<?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="org.dromara.mes.mapper.ProdBaseMachineProcessMapper">
</mapper>

@ -0,0 +1,107 @@
<?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="org.dromara.mes.mapper.ProdReportMapper">
<select id="planCompletionRateReportVoList" resultType="org.dromara.mes.domain.vo.PlanCompletionRateReportVo">
SELECT bmi.material_name materialName,
CAST(SUM(t.plan_amount) AS DECIMAL(10, 2)) planNumber,
CAST(SUM(t.complete_amount) AS DECIMAL(10, 2)) actualNumber,
CAST(SUM(t.complete_amount - t.plan_amount) AS DECIMAL(10, 2)) deviationNumber,
CONCAT(CAST((SUM(t.complete_amount) / SUM(t.plan_amount))
* 100 AS DECIMAL(10, 2)), '%') completionRate
FROM ${tableName} t
LEFT JOIN base_material_info bmi on bmi.material_id = t.material_id
<where>
<if test="map.beginDate != null and map.beginDate != '' and map.endDate != null and map.endDate != ''">
AND FORMAT(t.plan_begin_time, 'yyyy-MM-dd') BETWEEN #{map.beginDate} AND #{map.endDate}
</if>
<if test="map.processId != null and map.processId != ''">
AND t.process_id = #{map.processId}
</if>
<if test="map.machineId != null and map.machineId != ''">
AND t.release_id = #{map.machineId}
</if>
<if test="map.shiftId != null and map.shiftId != ''">
AND t.shift_id = #{map.shiftId}
</if>
<if test="map.classTeamId != null and map.classTeamId != ''">
AND t.class_team_id = #{map.classTeamId}
</if>
<if test="map.planCode != null and map.planCode != ''">
AND t.plan_code LIKE CONCAT('%', #{map.planCode}, '%')
</if>
<if test="map.materialName != null and map.materialName != ''">
AND bmi.material_name LIKE CONCAT('%', #{map.materialName}, '%')
</if>
</where>
GROUP BY bmi.material_name
ORDER BY materialName
</select>
<select id="planCompletionContrastReportVoList"
resultType="org.dromara.mes.domain.vo.PlanCompletionContrastReportVo">
WITH aggregated_data AS (SELECT t.tenant_id, bmi.material_name AS materialName,
SUM(IIF(FORMAT(t.plan_begin_time, 'yyyy-MM-dd') = FORMAT(CAST(#{map.beginDate} AS DATETIME), 'yyyy-MM-dd'), t.plan_amount, 0)) AS
dayPlanNumber,
SUM(IIF(FORMAT(t.plan_begin_time, 'yyyy-MM-dd') = FORMAT(CAST(#{map.beginDate} AS DATETIME), 'yyyy-MM-dd'), t.complete_amount, 0))
AS dayActualNumber,
SUM(IIF(FORMAT(t.plan_begin_time, 'yyyy-MM') = FORMAT(CAST(#{map.beginDate} AS DATETIME), 'yyyy-MM'), t.plan_amount, 0)) AS
monthPlanNumber,
SUM(IIF(FORMAT(t.plan_begin_time, 'yyyy-MM') = FORMAT(CAST(#{map.beginDate} AS DATETIME), 'yyyy-MM'), t.complete_amount, 0)) AS
monthActualNumber,
SUM(IIF(FORMAT(t.plan_begin_time, 'yyyy') = FORMAT(CAST(#{map.beginDate} AS DATETIME), 'yyyy'), t.plan_amount, 0)) AS
yearPlanNumber,
SUM(IIF(FORMAT(t.plan_begin_time, 'yyyy') = FORMAT(CAST(#{map.beginDate} AS DATETIME), 'yyyy'), t.complete_amount, 0)) AS
yearActualNumber
FROM ${tableName} t
LEFT JOIN base_material_info bmi ON bmi.material_id = t.material_id
<where>
<if test="map.beginDate != null and map.beginDate != ''">
AND FORMAT(t.plan_begin_time, 'yyyy-MM-dd') BETWEEN #{map.beginDate} AND #{map.beginDate}
</if>
<if test="map.processId != null and map.processId != ''">
AND t.process_id = #{map.processId}
</if>
<if test="map.machineId != null and map.machineId != ''">
AND t.release_id = #{map.machineId}
</if>
<if test="map.shiftId != null and map.shiftId != ''">
AND t.shift_id = #{map.shiftId}
</if>
<if test="map.classTeamId != null and map.classTeamId != ''">
AND t.class_team_id = #{map.classTeamId}
</if>
<if test="map.planCode != null and map.planCode != ''">
AND t.plan_code LIKE CONCAT('%', #{map.planCode}, '%')
</if>
<if test="map.materialName != null and map.materialName != ''">
AND bmi.material_name LIKE CONCAT('%', #{map.materialName}, '%')
</if>
</where>
GROUP BY t.tenant_id, bmi.material_name)
SELECT materialName,
-- 当天数据
CAST(dayPlanNumber AS DECIMAL(10, 2)) AS dayPlanNumber,
CAST(dayActualNumber AS DECIMAL(10, 2)) AS dayActualNumber,
CAST(dayActualNumber - dayPlanNumber AS DECIMAL(10, 2)) AS dayDeviationNumber,
CONCAT(CAST(IIF(dayPlanNumber = 0, 0, (dayActualNumber * 100.0 / dayPlanNumber)) AS DECIMAL(10, 2)),
'%') AS dayCompletionRate,
-- 当月数据
CAST(monthPlanNumber AS DECIMAL(10, 2)) AS monthPlanNumber,
CAST(monthActualNumber AS DECIMAL(10, 2)) AS monthActualNumber,
CAST(monthActualNumber - monthPlanNumber AS DECIMAL(10, 2)) AS monthDeviationNumber,
CONCAT(CAST(IIF(monthPlanNumber = 0, 0, (monthActualNumber * 100.0 / monthPlanNumber)) AS DECIMAL(10, 2)),
'%') AS monthCompletionRate,
-- 当年数据
CAST(yearPlanNumber AS DECIMAL(10, 2)) AS yearPlanNumber,
CAST(yearActualNumber AS DECIMAL(10, 2)) AS yearActualNumber,
CAST(yearActualNumber - yearPlanNumber AS DECIMAL(10, 2)) AS yearDeviationNumber,
CONCAT(CAST(IIF(yearPlanNumber = 0, 0, (yearActualNumber * 100.0 / yearPlanNumber)) AS DECIMAL(10, 2)),
'%') AS yearCompletionRate
FROM aggregated_data
ORDER BY materialName
</select>
</mapper>
Loading…
Cancel
Save