Commit 703fa953 authored by 李驰骋's avatar 李驰骋

Merge remote-tracking branch 'origin/dev' into dev

# Conflicts:
#	mes/src/main/java/com/ximai/mes/pro/mapper/task/ProTaskWorkunitMapper.java
parents 478fb472 3cc641d9
...@@ -229,4 +229,5 @@ md.workUnit.error.workunitCode.unique = \u5DE5\u5355\u5355\u5143\u7F16\u7801\u5D ...@@ -229,4 +229,5 @@ md.workUnit.error.workunitCode.unique = \u5DE5\u5355\u5355\u5143\u7F16\u7801\u5D
delete.data.error.occupied = \u8be5\u6570\u636e\u5df2\u7ecf\u88ab\u5173\u8054\u4f7f\u7528\uff0c\u65e0\u6cd5\u5220\u9664 delete.data.error.occupied = \u8be5\u6570\u636e\u5df2\u7ecf\u88ab\u5173\u8054\u4f7f\u7528\uff0c\u65e0\u6cd5\u5220\u9664
#权限复制,复制用户和被复制用户重叠 #权限复制,复制用户和被复制用户重叠
user.copyuser.repeat = \u590d\u5236\u7528\u6237\u4e2d\u5b58\u5728\u60a8\u52fe\u9009\u7684\u88ab\u590d\u5236\u7528\u6237\uff0c\u7528\u6237\u540d :{0} user.copyuser.repeat = \u590d\u5236\u7528\u6237\u4e2d\u5b58\u5728\u60a8\u52fe\u9009\u7684\u88ab\u590d\u5236\u7528\u6237\uff0c\u7528\u6237\u540d :{0}
user.lack.of.permissions = \u5c97\u4f4d\u8d44\u6e90\u6216\u89d2\u8272\u4e3a\u7a7a\uff0c\u60a8\u786e\u5b9a\u9700\u8981\u590d\u5236\u5417\uff1f user.lack.of.permissions = \u5c97\u4f4d\u8d44\u6e90\u6216\u89d2\u8272\u4e3a\u7a7a\uff0c\u60a8\u786e\u5b9a\u9700\u8981\u590d\u5236\u5417\uff1f
\ No newline at end of file rollback.schedule.status.err = \u4efb\u52a1\u7ec4\u5408\u5df2\u7ecf\u6709\u5904\u4e8e\u5f00\u5de5\u6216\u8005\u62a5\u5de5\u8bb0\u5f55:{0}
\ No newline at end of file
...@@ -219,4 +219,5 @@ md.workUnit.error.workunitCode.unique = unique workunitCode. ...@@ -219,4 +219,5 @@ md.workUnit.error.workunitCode.unique = unique workunitCode.
delete.data.error.occupied = The data that needs to be deleted has been used delete.data.error.occupied = The data that needs to be deleted has been used
user.copyuser.repeat = The employee with copied permission exists among the employees with copied permission :{0} user.copyuser.repeat = The employee with copied permission exists among the employees with copied permission :{0}
user.lack.of.permissions = Job resources or roles are empty, are you sure you need to copy them? user.lack.of.permissions = Job resources or roles are empty, are you sure you need to copy them?
\ No newline at end of file rollback.schedule.status.err = The order task has started :{0};
\ No newline at end of file
...@@ -228,4 +228,5 @@ md.workUnit.error.workunitCode.unique = \u0E2B\u0E21\u0E32\u0E22\u0E40\u0E25\u0E ...@@ -228,4 +228,5 @@ md.workUnit.error.workunitCode.unique = \u0E2B\u0E21\u0E32\u0E22\u0E40\u0E25\u0E
#被删除数据已被使用错误 #被删除数据已被使用错误
delete.data.error.occupied = \u0e02\u0e49\u0e2d\u0e21\u0e39\u0e25\u0e17\u0e35\u0e48\u0e15\u0e49\u0e2d\u0e07\u0e01\u0e32\u0e23\u0e25\u0e1a\u0e44\u0e14\u0e49\u0e16\u0e39\u0e01\u0e43\u0e0a\u0e49\u0e44\u0e1b\u0e41\u0e25\u0e49\u0e27 delete.data.error.occupied = \u0e02\u0e49\u0e2d\u0e21\u0e39\u0e25\u0e17\u0e35\u0e48\u0e15\u0e49\u0e2d\u0e07\u0e01\u0e32\u0e23\u0e25\u0e1a\u0e44\u0e14\u0e49\u0e16\u0e39\u0e01\u0e43\u0e0a\u0e49\u0e44\u0e1b\u0e41\u0e25\u0e49\u0e27
user.copyuser.repeat = \u0e1e\u0e19\u0e31\u0e01\u0e07\u0e32\u0e19\u0e17\u0e35\u0e48\u0e16\u0e39\u0e01\u0e04\u0e31\u0e14\u0e25\u0e2d\u0e01\u0e2a\u0e34\u0e17\u0e18\u0e34\u0e4c\u0e21\u0e35\u0e2d\u0e22\u0e39\u0e48\u0e43\u0e19\u0e1e\u0e19\u0e31\u0e01\u0e07\u0e32\u0e19\u0e17\u0e35\u0e48\u0e16\u0e39\u0e01\u0e04\u0e31\u0e14\u0e25\u0e2d\u0e01\u0e2a\u0e34\u0e17\u0e18\u0e34\u0e4c :{0} user.copyuser.repeat = \u0e1e\u0e19\u0e31\u0e01\u0e07\u0e32\u0e19\u0e17\u0e35\u0e48\u0e16\u0e39\u0e01\u0e04\u0e31\u0e14\u0e25\u0e2d\u0e01\u0e2a\u0e34\u0e17\u0e18\u0e34\u0e4c\u0e21\u0e35\u0e2d\u0e22\u0e39\u0e48\u0e43\u0e19\u0e1e\u0e19\u0e31\u0e01\u0e07\u0e32\u0e19\u0e17\u0e35\u0e48\u0e16\u0e39\u0e01\u0e04\u0e31\u0e14\u0e25\u0e2d\u0e01\u0e2a\u0e34\u0e17\u0e18\u0e34\u0e4c :{0}
user.lack.of.permissions = \u0e17\u0e23\u0e31\u0e1e\u0e22\u0e32\u0e01\u0e23\u0e42\u0e1e\u0e2a\u0e15\u0e4c\u0e2b\u0e23\u0e37\u0e2d\u0e1a\u0e17\u0e1a\u0e32\u0e17\u0e27\u0e48\u0e32\u0e07\u0e40\u0e1b\u0e25\u0e48\u0e32\u0e04\u0e38\u0e13\u0e41\u0e19\u0e48\u0e43\u0e08\u0e2b\u0e23\u0e37\u0e2d\u0e44\u0e21\u0e48\u0e27\u0e48\u0e32\u0e04\u0e38\u0e13\u0e08\u0e33\u0e40\u0e1b\u0e47\u0e19\u0e15\u0e49\u0e2d\u0e07\u0e04\u0e31\u0e14\u0e25\u0e2d\u0e01\u003f user.lack.of.permissions = \u0e17\u0e23\u0e31\u0e1e\u0e22\u0e32\u0e01\u0e23\u0e42\u0e1e\u0e2a\u0e15\u0e4c\u0e2b\u0e23\u0e37\u0e2d\u0e1a\u0e17\u0e1a\u0e32\u0e17\u0e27\u0e48\u0e32\u0e07\u0e40\u0e1b\u0e25\u0e48\u0e32\u0e04\u0e38\u0e13\u0e41\u0e19\u0e48\u0e43\u0e08\u0e2b\u0e23\u0e37\u0e2d\u0e44\u0e21\u0e48\u0e27\u0e48\u0e32\u0e04\u0e38\u0e13\u0e08\u0e33\u0e40\u0e1b\u0e47\u0e19\u0e15\u0e49\u0e2d\u0e07\u0e04\u0e31\u0e14\u0e25\u0e2d\u0e01\u003f
\ No newline at end of file rollback.schedule.status.err = \u0e20\u0e32\u0e23\u0e01\u0e34\u0e08\u0e01\u0e32\u0e23\u0e2a\u0e31\u0e48\u0e07\u0e0b\u0e37\u0e49\u0e2d\u0e44\u0e14\u0e49\u0e40\u0e23\u0e34\u0e48\u0e21\u0e02\u0e36\u0e49\u0e19\u0e41\u0e25\u0e49\u0e27:{0}
\ No newline at end of file
...@@ -222,4 +222,5 @@ md.workUnit.error.workunitCode.unique = \u5de5\u5355\u5355\u5143\u7f16\u7801\u5d ...@@ -222,4 +222,5 @@ md.workUnit.error.workunitCode.unique = \u5de5\u5355\u5355\u5143\u7f16\u7801\u5d
delete.data.error.occupied = \u8be5\u6570\u636e\u5df2\u7ecf\u88ab\u5173\u8054\u4f7f\u7528\uff0c\u65e0\u6cd5\u5220\u9664 delete.data.error.occupied = \u8be5\u6570\u636e\u5df2\u7ecf\u88ab\u5173\u8054\u4f7f\u7528\uff0c\u65e0\u6cd5\u5220\u9664
user.copyuser.repeat = \u590d\u5236\u7528\u6237\u4e2d\u5b58\u5728\u60a8\u52fe\u9009\u7684\u88ab\u590d\u5236\u7528\u6237\uff0c\u7528\u6237\u540d :{0} user.copyuser.repeat = \u590d\u5236\u7528\u6237\u4e2d\u5b58\u5728\u60a8\u52fe\u9009\u7684\u88ab\u590d\u5236\u7528\u6237\uff0c\u7528\u6237\u540d :{0}
user.lack.of.permissions = \u5c97\u4f4d\u8d44\u6e90\u6216\u89d2\u8272\u4e3a\u7a7a\uff0c\u60a8\u786e\u5b9a\u9700\u8981\u590d\u5236\u5417\uff1f user.lack.of.permissions = \u5c97\u4f4d\u8d44\u6e90\u6216\u89d2\u8272\u4e3a\u7a7a\uff0c\u60a8\u786e\u5b9a\u9700\u8981\u590d\u5236\u5417\uff1f
\ No newline at end of file rollback.schedule.status.err = \u4efb\u52a1\u7ec4\u5408\u5df2\u7ecf\u6709\u5904\u4e8e\u5f00\u5de5\u6216\u8005\u62a5\u5de5\u8bb0\u5f55:{0}
\ No newline at end of file
...@@ -17,6 +17,7 @@ import com.ximai.mes.pro.domain.proWorkOrder.ProWorkorder; ...@@ -17,6 +17,7 @@ import com.ximai.mes.pro.domain.proWorkOrder.ProWorkorder;
import com.ximai.mes.pro.domain.task.ProTask; import com.ximai.mes.pro.domain.task.ProTask;
import com.ximai.mes.pro.domain.task.ProTaskWorkunit; import com.ximai.mes.pro.domain.task.ProTaskWorkunit;
import com.ximai.mes.pro.domain.task.WorkorderScheduleParams; import com.ximai.mes.pro.domain.task.WorkorderScheduleParams;
import com.ximai.mes.pro.domain.task.WorkorderScheduleParamsRollBACK;
import com.ximai.mes.pro.domain.vo.ProTaskVo; import com.ximai.mes.pro.domain.vo.ProTaskVo;
import com.ximai.mes.pro.mapper.task.ProTaskMapper; import com.ximai.mes.pro.mapper.task.ProTaskMapper;
import com.ximai.mes.pro.service.proWorkOrder.IProWorkorderService; import com.ximai.mes.pro.service.proWorkOrder.IProWorkorderService;
...@@ -321,6 +322,13 @@ public class ProTaskController extends BaseController { ...@@ -321,6 +322,13 @@ public class ProTaskController extends BaseController {
return AjaxResult.success(); return AjaxResult.success();
} }
@ApiOperation("生产任务排产")
@PreAuthorize("@ss.hasPermi('mes:pro:protask:schedule')")
@Log(title = "回滚删除生产任务排产", businessType = BusinessType.OTHER)
@PostMapping("/rollBACKschedule")
public AjaxResult rollBACKschedule(@ApiParam(value = "任务", required = true) @RequestBody WorkorderScheduleParamsRollBACK params) {
proTaskService.rollBACKschedule(params);
return AjaxResult.success();
}
} }
...@@ -75,5 +75,5 @@ public class ProProductQrcodeRecord extends BaseEntity { ...@@ -75,5 +75,5 @@ public class ProProductQrcodeRecord extends BaseEntity {
* 模板类型 * 模板类型
*/ */
private String templateType; private String templateType;
private String taskBatch;
} }
...@@ -261,6 +261,7 @@ public class ProTask extends BaseEntity { ...@@ -261,6 +261,7 @@ public class ProTask extends BaseEntity {
* 任务批次号 * 任务批次号
*/ */
private String taskBatch; private String taskBatch;
@TableField(exist = false)
private String taskBatchStr; private String taskBatchStr;
@ApiModelProperty("是否最后工序") @ApiModelProperty("是否最后工序")
......
package com.ximai.mes.pro.domain.task;
import lombok.Data;
import java.lang.reflect.Array;
import java.util.ArrayList;
import java.util.List;
import java.util.Set;
@Data
public class WorkorderScheduleParamsRollBACK {
private List<String> taskBatchList;
}
...@@ -70,6 +70,7 @@ public class ProProductQrcodeRecordCreate { ...@@ -70,6 +70,7 @@ public class ProProductQrcodeRecordCreate {
*/ */
private String templateCode; private String templateCode;
private String taskBatch;
/** /**
* 模板类型 * 模板类型
*/ */
......
...@@ -103,4 +103,6 @@ public class ProProductQrcodeRecordDto { ...@@ -103,4 +103,6 @@ public class ProProductQrcodeRecordDto {
private String specification; private String specification;
private String qrcodeSub; private String qrcodeSub;
private String taskBatch;
} }
...@@ -78,5 +78,5 @@ public class ProProductQrcodeRuleCreate { ...@@ -78,5 +78,5 @@ public class ProProductQrcodeRuleCreate {
private String templateType; private String templateType;
private String taskBatch;
} }
...@@ -137,4 +137,6 @@ public interface ProFeedbackMapper { ...@@ -137,4 +137,6 @@ public interface ProFeedbackMapper {
List<FeedbackResponse> getListByProcess(FeedbackRequest feedbackRequest); List<FeedbackResponse> getListByProcess(FeedbackRequest feedbackRequest);
List<FeedbackResponse> getListByUser(FeedbackRequest feedbackRequest); List<FeedbackResponse> getListByUser(FeedbackRequest feedbackRequest);
int selectCount(@Param("taskIds")List<Long> taskIds);
} }
...@@ -8,6 +8,7 @@ import com.ximai.mes.pro.dto.ProProductQrcodeRecordDto; ...@@ -8,6 +8,7 @@ import com.ximai.mes.pro.dto.ProProductQrcodeRecordDto;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select; import org.apache.ibatis.annotations.Select;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import org.springframework.security.core.parameters.P;
/** /**
* 产品序列号打印记录Mapper接口 * 产品序列号打印记录Mapper接口
...@@ -75,4 +76,9 @@ public interface ProProductQrcodeRecordMapper extends BaseMapper<ProProductQrcod ...@@ -75,4 +76,9 @@ public interface ProProductQrcodeRecordMapper extends BaseMapper<ProProductQrcod
public int deleteProProductQrcodeRecordByRecordIds(Long[] recordIds); public int deleteProProductQrcodeRecordByRecordIds(Long[] recordIds);
int addPrintTime(@Param("ids") List<Long> collect,@Param("userName") String userName); int addPrintTime(@Param("ids") List<Long> collect,@Param("userName") String userName);
public int deleteProProductQrcodeRecordByTaskBatch(@Param("taskBatch")String taskBatch);
} }
...@@ -3,10 +3,12 @@ package com.ximai.mes.pro.mapper.proWorkOrder; ...@@ -3,10 +3,12 @@ package com.ximai.mes.pro.mapper.proWorkOrder;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.ximai.mes.pro.domain.proWorkOrder.ProWorkorder; import com.ximai.mes.pro.domain.proWorkOrder.ProWorkorder;
import com.ximai.mes.pro.domain.task.ProTask;
import com.ximai.mes.pro.domain.vo.*; import com.ximai.mes.pro.domain.vo.*;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select; import org.apache.ibatis.annotations.Select;
import java.math.BigDecimal;
import java.util.Date; import java.util.Date;
import java.util.List; import java.util.List;
...@@ -146,4 +148,6 @@ public interface ProWorkorderMapper extends BaseMapper<ProWorkorder> { ...@@ -146,4 +148,6 @@ public interface ProWorkorderMapper extends BaseMapper<ProWorkorder> {
Date maxErpUpdateTime(); Date maxErpUpdateTime();
int updateProductionSolution(@Param("productionSolutionId") Long productionSolutionId, @Param("productionSolutionCode")String productionSolutionCode, @Param("productionSolutionName")String productionSolutionName,@Param("workorderId")Long workorderId); int updateProductionSolution(@Param("productionSolutionId") Long productionSolutionId, @Param("productionSolutionCode")String productionSolutionCode, @Param("productionSolutionName")String productionSolutionName,@Param("workorderId")Long workorderId);
void rollBACKschedule(@Param("workorderCode")String workorderCode, @Param("quantity")BigDecimal quantity, @Param("username")String username);
} }
...@@ -195,4 +195,6 @@ public interface ProTaskMapper extends BaseMapper<ProTask> { ...@@ -195,4 +195,6 @@ public interface ProTaskMapper extends BaseMapper<ProTask> {
List<ProTask> selectByTaskIds(@Param("taskIds")List<Long> taskIds); List<ProTask> selectByTaskIds(@Param("taskIds")List<Long> taskIds);
List<ProTask> selectByTaskBatch(@Param("taskBatch")String taskBatch); List<ProTask> selectByTaskBatch(@Param("taskBatch")String taskBatch);
void deleteByTaskBatch(@Param("taskBatch")String taskBatch);
} }
...@@ -97,4 +97,6 @@ public interface ProTaskWorkorderMapper ...@@ -97,4 +97,6 @@ public interface ProTaskWorkorderMapper
@Select(value = "select * from pro_task_workorder where task_id=#{taskId} ") @Select(value = "select * from pro_task_workorder where task_id=#{taskId} ")
List<ProTaskWorkorder> selectProTaskWorkorderTaskId(@Param("taskId") Long taskId); List<ProTaskWorkorder> selectProTaskWorkorderTaskId(@Param("taskId") Long taskId);
void deleteByTaskIds(@Param("taskIds")List<Long> taskIds);
} }
...@@ -13,7 +13,6 @@ import org.apache.ibatis.annotations.Param; ...@@ -13,7 +13,6 @@ import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select; import org.apache.ibatis.annotations.Select;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.util.Date;
import java.util.List; import java.util.List;
/** /**
...@@ -216,6 +215,7 @@ public interface ProTaskWorkunitMapper extends BaseMapper<ProTaskWorkunit> { ...@@ -216,6 +215,7 @@ public interface ProTaskWorkunitMapper extends BaseMapper<ProTaskWorkunit> {
"${ew.customSqlSegment} ") "${ew.customSqlSegment} ")
List<ProTaskWorkunitDto> selectTaskWorkUnitWithKanban(@Param("ew") QueryWrapper<ProTaskWorkunit> query); List<ProTaskWorkunitDto> selectTaskWorkUnitWithKanban(@Param("ew") QueryWrapper<ProTaskWorkunit> query);
void deleteByTaskIds(@Param("taskIds")List<Long> taskIds);
/** /**
* 物料综合看板专用 * 物料综合看板专用
* @param startDate 开始时间 * @param startDate 开始时间
......
...@@ -29,36 +29,14 @@ public class ProductQrcodeBuild implements ScheduleBusiProcess{ ...@@ -29,36 +29,14 @@ public class ProductQrcodeBuild implements ScheduleBusiProcess{
private IProProductQrcodeRuleService proProductQrcodeRuleService; private IProProductQrcodeRuleService proProductQrcodeRuleService;
@Override @Override
public void execute(List<JobResult> jobResults) { public void execute(List<JobResult> jobResults) {
jobResults.forEach(job->{ jobResults.forEach(job->{
String taskBatch = job.taskResultList != null && job.taskResultList.size() > 0 ? job.taskResultList.get(0).getProTask().getTaskBatch() : null;
job.getWorkorderList().forEach(workorder->{ job.getWorkorderList().forEach(workorder->{
ProProductQrcodeRule rule = productQrcodeRuleService.selectProProductQrcodeRuleNewest(workorder.getProductId(), workorder.getClientCode()); ProProductQrcodeRule rule = productQrcodeRuleService.selectProProductQrcodeRuleNewest(workorder.getProductId(), workorder.getClientCode());
if(rule ==null){ if(rule ==null){
return; return;
} }
// //wzc修改 有客户优先按照产品+客户匹配序列号规则绑定的最新打印模板,如果没有匹配到 按照产品匹配序列号规则绑定的最新打印模板(客户字段为空的)
// ProProductQrcodeRuleDto proProductQrcodeRuleDto= null;
// List<ProProductQrcodeRuleDto> list = null;
// if(StringUtils.isNotEmpty(workorder.getClientCode())){
// QueryWrapper<ProProductQrcodeRule> query = new QueryWrapper<>();
// query.eq("m.item_id", workorder.getProductId());
// query.eq( "m.client_code", workorder.getClientCode());
// query.orderByDesc("m.rule_id");
// list = proProductQrcodeRuleService.selectProProductQrcodeRuleDtoList(query);
// }else{
// QueryWrapper<ProProductQrcodeRule> query = new QueryWrapper<>();
// query.eq("m.item_id", workorder.getProductId());
// query.isNull( "m.client_code");
// query.orderByDesc("m.rule_id");
// list = proProductQrcodeRuleService.selectProProductQrcodeRuleDtoList(query);
// }
// if(list != null && list.size() > 0){
// proProductQrcodeRuleDto = list.get(0);
// }
// if (proProductQrcodeRuleDto == null || StringUtils.isEmpty(proProductQrcodeRuleDto.getTemplateName())){
// //后续再看是否需要报错
//// ExceptionUtil.checkTrueThrowException(true,
//// "未能匹配到打印模板,请先到产品二维码规则维护");
// }
List<String> qrcodes = productQrcodeRuleService.buildQrcode(rule, job.getQuantity().intValue()); List<String> qrcodes = productQrcodeRuleService.buildQrcode(rule, job.getQuantity().intValue());
for(String qrcode : qrcodes){ for(String qrcode : qrcodes){
ProProductQrcodeRecordCreate create = new ProProductQrcodeRecordCreate(); ProProductQrcodeRecordCreate create = new ProProductQrcodeRecordCreate();
...@@ -70,6 +48,7 @@ public class ProductQrcodeBuild implements ScheduleBusiProcess{ ...@@ -70,6 +48,7 @@ public class ProductQrcodeBuild implements ScheduleBusiProcess{
create.setTemplateCode(rule != null ? rule.getTemplateCode() : null); create.setTemplateCode(rule != null ? rule.getTemplateCode() : null);
create.setTemplateName(rule != null ? rule.getTemplateName() : null); create.setTemplateName(rule != null ? rule.getTemplateName() : null);
create.setTemplateType(rule != null ? rule.getTemplateType() : null); create.setTemplateType(rule != null ? rule.getTemplateType() : null);
create.setTaskBatch(taskBatch);
productQrcodeRecordService.insertProProductQrcodeRecord(create); productQrcodeRecordService.insertProProductQrcodeRecord(create);
} }
}); });
......
...@@ -31,10 +31,7 @@ import com.ximai.mes.pro.domain.vo.*; ...@@ -31,10 +31,7 @@ import com.ximai.mes.pro.domain.vo.*;
import com.ximai.mes.pro.domain.vo.task.FeedbackValidateSerialNoParams; import com.ximai.mes.pro.domain.vo.task.FeedbackValidateSerialNoParams;
import com.ximai.mes.pro.dto.ProProductQrcodeRecordDto; import com.ximai.mes.pro.dto.ProProductQrcodeRecordDto;
import com.ximai.mes.pro.dto.task.ProTaskLinkFile; import com.ximai.mes.pro.dto.task.ProTaskLinkFile;
import com.ximai.mes.pro.mapper.ProProcessMapper; import com.ximai.mes.pro.mapper.*;
import com.ximai.mes.pro.mapper.ProProductQrcodeRecordMapper;
import com.ximai.mes.pro.mapper.ProProductionLogMapper;
import com.ximai.mes.pro.mapper.ProRouteMapper;
import com.ximai.mes.pro.mapper.proWorkOrder.ProWorkOrderProcessMapper; import com.ximai.mes.pro.mapper.proWorkOrder.ProWorkOrderProcessMapper;
import com.ximai.mes.pro.mapper.proWorkOrder.ProWorkOrderProcessToolMapper; import com.ximai.mes.pro.mapper.proWorkOrder.ProWorkOrderProcessToolMapper;
import com.ximai.mes.pro.mapper.proWorkOrder.ProWorkorderMapper; import com.ximai.mes.pro.mapper.proWorkOrder.ProWorkorderMapper;
...@@ -143,6 +140,8 @@ public class ProTaskServiceImpl implements IProTaskService { ...@@ -143,6 +140,8 @@ public class ProTaskServiceImpl implements IProTaskService {
private ProWorkOrderProcessToolMapper proWorkOrderProcessToolMapper; private ProWorkOrderProcessToolMapper proWorkOrderProcessToolMapper;
@Autowired @Autowired
private IProFeedbackService proFeedbackService; private IProFeedbackService proFeedbackService;
@Autowired
private ProFeedbackMapper proFeedbackMapper;
@Resource @Resource
private SysUserMapper sysUserMapper; private SysUserMapper sysUserMapper;
@Autowired @Autowired
...@@ -1456,4 +1455,30 @@ public class ProTaskServiceImpl implements IProTaskService { ...@@ -1456,4 +1455,30 @@ public class ProTaskServiceImpl implements IProTaskService {
return null; return null;
} }
@Override
@Transactional
public void rollBACKschedule(WorkorderScheduleParamsRollBACK params) {
if(params.getTaskBatchList() == null || params.getTaskBatchList().size() < 1)
return;
params.setTaskBatchList(params.getTaskBatchList().stream().distinct().collect(Collectors.toList()));
//1.pro_task 2.pro_task_workorder ,3.pro_task_workunit 4.pro_product_qrcode_record 5.pro_workorder
//获取该批次下所有数据
for (String taskBatch : params.getTaskBatchList()){
ProTask proTaskCheck = new ProTask();
proTaskCheck.setTaskBatch(taskBatch);
List<ProTask> proTasks = proTaskMapper.selectProTaskList(proTaskCheck);
if(proTasks.size() < 1)
continue;
ExceptionUtil.checkTrueThrowException(proTasks.stream().filter(proTask -> !proTask.getStatus().equals("NORMARL")).count() > 0, MessageUtils.message("rollback.schedule.status.err",taskBatch));
ExceptionUtil.checkTrueThrowException(proFeedbackMapper.selectCount(proTasks.stream().map(proTask -> proTask.getTaskId()).collect(Collectors.toList())) > 0, MessageUtils.message("rollback.schedule.status.err",taskBatch));
proTaskMapper.deleteByTaskBatch(taskBatch);
proTaskWorkunitMapper.deleteByTaskIds(proTasks.stream().map(proTask -> proTask.getTaskId()).collect(Collectors.toList()));
proTaskWorkorderMapper.deleteByTaskIds(proTasks.stream().map(proTask -> proTask.getTaskId()).collect(Collectors.toList()));
proProductQrcodeRecordMapper.deleteProProductQrcodeRecordByTaskBatch(taskBatch);
proWorkorderMapper.rollBACKschedule(proTasks.get(0).getArrangeCode(),proTasks.get(0).getQuantity(),SecurityUtils.getUsername());
}
}
} }
...@@ -6,6 +6,7 @@ import com.ximai.mes.pro.domain.ProFeedback; ...@@ -6,6 +6,7 @@ import com.ximai.mes.pro.domain.ProFeedback;
import com.ximai.mes.pro.domain.task.ProTask; import com.ximai.mes.pro.domain.task.ProTask;
import com.ximai.mes.pro.domain.task.ProTaskWorkunit; import com.ximai.mes.pro.domain.task.ProTaskWorkunit;
import com.ximai.mes.pro.domain.task.WorkorderScheduleParams; import com.ximai.mes.pro.domain.task.WorkorderScheduleParams;
import com.ximai.mes.pro.domain.task.WorkorderScheduleParamsRollBACK;
import com.ximai.mes.pro.domain.vo.ProPackagePrintResult; import com.ximai.mes.pro.domain.vo.ProPackagePrintResult;
import com.ximai.mes.pro.domain.vo.ProTaskQuery; import com.ximai.mes.pro.domain.vo.ProTaskQuery;
import com.ximai.mes.pro.domain.vo.ProTaskVo; import com.ximai.mes.pro.domain.vo.ProTaskVo;
...@@ -192,4 +193,5 @@ public interface IProTaskService { ...@@ -192,4 +193,5 @@ public interface IProTaskService {
List<ProTaskLinkFile> getTaskLinkFile(ProTaskQuery proTask); List<ProTaskLinkFile> getTaskLinkFile(ProTaskQuery proTask);
void rollBACKschedule(WorkorderScheduleParamsRollBACK params);
} }
...@@ -430,6 +430,13 @@ ...@@ -430,6 +430,13 @@
f.user_name, f.user_name,
f.nick_name f.nick_name
</select> </select>
<select id="selectCount" resultType="java.lang.Integer">
select count(1) from pro_feedback
where task_Id in
<foreach collection="taskIds" open="(" item="taskId" close=")" separator=",">
#{taskId}
</foreach>
</select>
<insert id="insertProFeedback" parameterType="ProFeedback" useGeneratedKeys="true" keyProperty="recordId"> <insert id="insertProFeedback" parameterType="ProFeedback" useGeneratedKeys="true" keyProperty="recordId">
insert into pro_feedback insert into pro_feedback
......
...@@ -42,7 +42,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" ...@@ -42,7 +42,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
select record_id, item_id, item_code, work_order_id, work_order_no, select record_id, item_id, item_code, work_order_id, work_order_no,
print_time, qrcode, client_code, client_name, item_desc, create_by, print_time, qrcode, client_code, client_name, item_desc, create_by,
create_time, update_by, update_time ,template_id,template_type, create_time, update_by, update_time ,template_id,template_type,
template_code,template_name template_code,template_name,task_batch
from pro_product_qrcode_record from pro_product_qrcode_record
</sql> </sql>
...@@ -94,6 +94,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" ...@@ -94,6 +94,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
<if test="templateType != null"> <if test="templateType != null">
template_type, template_type,
</if> </if>
<if test="taskBatch != null">
task_batch,
</if>
</trim> </trim>
<trim prefix="values (" suffix=")" suffixOverrides=","> <trim prefix="values (" suffix=")" suffixOverrides=",">
<if test="itemId != null">#{itemId},</if> <if test="itemId != null">#{itemId},</if>
...@@ -121,6 +124,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" ...@@ -121,6 +124,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
<if test="templateType != null"> <if test="templateType != null">
#{templateType,jdbcType=VARCHAR}, #{templateType,jdbcType=VARCHAR},
</if> </if>
<if test="taskBatch != null">
#{taskBatch,jdbcType=VARCHAR},
</if>
</trim> </trim>
</insert> </insert>
<update id="addPrintTime"> <update id="addPrintTime">
...@@ -161,4 +167,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" ...@@ -161,4 +167,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
#{recordId} #{recordId}
</foreach> </foreach>
</delete> </delete>
<delete id="deleteProProductQrcodeRecordByTaskBatch" parameterType="String">
delete from pro_product_qrcode_record where task_batch =#{taskBatch}
</delete>
</mapper> </mapper>
\ No newline at end of file
...@@ -440,6 +440,9 @@ ...@@ -440,6 +440,9 @@
update pro_workorder set production_solution_id = #{productionSolutionId},production_solution_code = #{productionSolutionCode} ,production_solution_name = #{productionSolutionName} update pro_workorder set production_solution_id = #{productionSolutionId},production_solution_code = #{productionSolutionCode} ,production_solution_name = #{productionSolutionName}
where workorder_id = #{workorderId} where workorder_id = #{workorderId}
</update> </update>
<update id="rollBACKschedule">
update pro_workorder set quantity_scheduled = quantity_scheduled - #{quantity} , update_By = #{quantity}, update_time = now() where workorder_code = #{workorderCode}
</update>
<delete id="deleteProWorkorderByWorkorderId" parameterType="Long"> <delete id="deleteProWorkorderByWorkorderId" parameterType="Long">
delete delete
......
...@@ -296,7 +296,9 @@ ...@@ -296,7 +296,9 @@
<if test="taskBatchStr != null and taskBatchStr != ''">and t.task_batch like concat('%', #{taskBatchStr}, <if test="taskBatchStr != null and taskBatchStr != ''">and t.task_batch like concat('%', #{taskBatchStr},
'%') '%')
</if> </if>
<if test="taskBatch != null and taskBatch != ''">
and t.task_batch= #{taskBatch}
</if>
<if test="itemId != null ">and t.item_id = #{itemId}</if> <if test="itemId != null ">and t.item_id = #{itemId}</if>
<if test="itemCode != null and itemCode != ''">and i.item_code = #{itemCode}</if> <if test="itemCode != null and itemCode != ''">and i.item_code = #{itemCode}</if>
<if test="itemName != null and itemName != ''">and i.item_name like concat('%', #{itemName}, '%')</if> <if test="itemName != null and itemName != ''">and i.item_name like concat('%', #{itemName}, '%')</if>
...@@ -506,4 +508,7 @@ ...@@ -506,4 +508,7 @@
#{taskId} #{taskId}
</foreach> </foreach>
</delete> </delete>
<delete id="deleteByTaskBatch">
delete from pro_task where task_batch = #{taskBatch}
</delete>
</mapper> </mapper>
...@@ -63,4 +63,10 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" ...@@ -63,4 +63,10 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
#{taskWorkorderId} #{taskWorkorderId}
</foreach> </foreach>
</delete> </delete>
<delete id="deleteByTaskIds">
delete from pro_task_workorder where task_id in
<foreach item="taskId" collection="taskIds" open="(" separator="," close=")">
#{taskId}
</foreach>
</delete>
</mapper> </mapper>
...@@ -199,4 +199,10 @@ ...@@ -199,4 +199,10 @@
#{taskWorkunitId} #{taskWorkunitId}
</foreach> </foreach>
</delete> </delete>
<delete id="deleteByTaskIds">
delete from pro_task_workunit where task_id in
<foreach item="taskId" collection="taskIds" open="(" separator="," close=")">
#{taskId}
</foreach>
</delete>
</mapper> </mapper>
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment