diff --git a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/controller/AbnormalBillController.java b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/controller/AbnormalBillController.java index dcb03f33..4e4aab9c 100644 --- a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/controller/AbnormalBillController.java +++ b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/controller/AbnormalBillController.java @@ -10,7 +10,6 @@ import com.foreverwin.mesnac.anomaly.service.FileUploadedService; import com.foreverwin.mesnac.common.dto.SfcDispatchDto; import com.foreverwin.mesnac.common.service.SfcDispatchCommonService; import com.foreverwin.mesnac.meapi.service.NcCodeService; -import com.foreverwin.modular.core.util.CommonMethods; import com.foreverwin.modular.core.util.FrontPage; import com.foreverwin.modular.core.util.R; import org.springframework.beans.factory.annotation.Autowired; @@ -22,8 +21,8 @@ import java.util.List; /** * - * @author 赵嘉伟 - * @since 2021-07-22 + * @author zjw + * @since 2021-08-16 */ @RestController @RequestMapping("/Z-ABNORMAL-BILL") @@ -38,12 +37,9 @@ public class AbnormalBillController { @Autowired private FileUploadedService fileUploadedService; - - @Autowired private NcCodeService ncCodeService; - /** * 根据id查询 * @@ -71,19 +67,6 @@ public class AbnormalBillController { return R.ok(result); } - /** - * 拆分弹出框 - * - * @return - */ - @ResponseBody - @GetMapping("getQCAbnormal") - public R getQCAbnormal(){ - List result; - result = abnormalBillService.getQCAbnormal(); - return R.ok(result); - } - /** * 分页查询数据 * @@ -95,8 +78,6 @@ public class AbnormalBillController { public R page(FrontPage frontPage, AbnormalBill abnormalBill){ IPage result; QueryWrapper queryWrapper = new QueryWrapper<>(); - String site = CommonMethods.getSite(); - abnormalBill.setSite(site); queryWrapper.setEntity(abnormalBill); if (frontPage.getGlobalQuery() != null && !"".equals(frontPage.getGlobalQuery().trim())) { //TODO modify global query @@ -105,6 +86,8 @@ public class AbnormalBillController { .or().like(AbnormalBill::getSite, frontPage.getGlobalQuery()) .or().like(AbnormalBill::getAbnormalNo, frontPage.getGlobalQuery()) .or().like(AbnormalBill::getStatus, frontPage.getGlobalQuery()) + .or().like(AbnormalBill::getCorrection, frontPage.getGlobalQuery()) + .or().like(AbnormalBill::getProgram, frontPage.getGlobalQuery()) .or().like(AbnormalBill::getType, frontPage.getGlobalQuery()) .or().like(AbnormalBill::getItemBo, frontPage.getGlobalQuery()) .or().like(AbnormalBill::getSfc, frontPage.getGlobalQuery()) @@ -183,15 +166,29 @@ public class AbnormalBillController { } + /** + * 拆分弹出框 + * + * @return + */ + @ResponseBody + @GetMapping("getQCAbnormal") + public R getQCAbnormal(){ + List result; + result = abnormalBillService.getQCAbnormal(); + return R.ok(result); + } + + + /** * 初始化 - * @param messageType 暂时不用 * @param type 异常的类型 * @return */ @GetMapping("/init") - public R init(String messageType,String type){ - return R.ok(abnormalBillService.init(messageType,type)); + public R init(String type){ + return R.ok(abnormalBillService.init(type)); } @@ -354,7 +351,6 @@ public class AbnormalBillController { } - @GetMapping("/findNcCodeDescriptionByNcCode") public R findNcCodeDescriptionByNcCode(String ncCode){ return R.ok(ncCodeService.findNcCodeDescriptionByNcCode(ncCode)); diff --git a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/dto/AbnormalBillDisposeDto.java b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/dto/AbnormalBillDisposeDto.java index bb627590..fbfe96c5 100644 --- a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/dto/AbnormalBillDisposeDto.java +++ b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/dto/AbnormalBillDisposeDto.java @@ -169,6 +169,16 @@ public class AbnormalBillDisposeDto extends AbnormalBillDispose { */ private String reportSendUserGroup; + /** + * 纠防确认 + */ + private String correction; + + /** + * 方案确认 + */ + private String program; + /** * * @return @@ -438,4 +448,20 @@ public class AbnormalBillDisposeDto extends AbnormalBillDispose { public void setReportSendUserGroup(String reportSendUserGroup) { this.reportSendUserGroup = reportSendUserGroup; } + + public String getCorrection() { + return correction; + } + + public void setCorrection(String correction) { + this.correction = correction; + } + + public String getProgram() { + return program; + } + + public void setProgram(String program) { + this.program = program; + } } diff --git a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/mapper/AbnormalBillMapper.java b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/mapper/AbnormalBillMapper.java index 35743388..2d7a019f 100644 --- a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/mapper/AbnormalBillMapper.java +++ b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/mapper/AbnormalBillMapper.java @@ -14,12 +14,13 @@ import java.util.List; * 异常单 Mapper 接口 *

* - * @author 赵嘉伟 - * @since 2021-07-22 + * @author zjw + * @since 2021-08-16 */ @Repository public interface AbnormalBillMapper extends BaseMapper { + List backLog(@Param("abnormalBill")AbnormalBillDto abnormalBillDto, @Param("language")String language); /** @@ -37,4 +38,6 @@ public interface AbnormalBillMapper extends BaseMapper { List findScrapDtoBySfc(@Param("site")String site, @Param("sfc")String sfc); List getQCAbnormalList(@Param("site") String site); + + } \ No newline at end of file diff --git a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/model/AbnormalBill.java b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/model/AbnormalBill.java index c7f32b2b..5f53504a 100644 --- a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/model/AbnormalBill.java +++ b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/model/AbnormalBill.java @@ -14,8 +14,8 @@ import java.time.LocalDateTime; * 异常单 *

* - * @author 赵嘉伟 - * @since 2021-07-22 + * @author zjw + * @since 2021-08-16 */ @TableName("Z_ABNORMAL_BILL") @@ -44,6 +44,16 @@ public class AbnormalBill extends Model { */ @TableField("STATUS") private String status; + /** + * 纠防确认 + */ + @TableField("CORRECTION") + private String correction; + /** + * 方案确认 + */ + @TableField("PROGRAM") + private String program; /** * 异常类型 Q|其他,Z|质量,S|设备 */ @@ -226,7 +236,6 @@ public class AbnormalBill extends Model { - public String getHandle() { return handle; } @@ -259,6 +268,22 @@ public class AbnormalBill extends Model { this.status = status; } + public String getCorrection() { + return correction; + } + + public void setCorrection(String correction) { + this.correction = correction; + } + + public String getProgram() { + return program; + } + + public void setProgram(String program) { + this.program = program; + } + public String getType() { return type; } @@ -563,6 +588,10 @@ public static final String ABNORMAL_NO = "ABNORMAL_NO"; public static final String STATUS = "STATUS"; +public static final String CORRECTION = "CORRECTION"; + +public static final String PROGRAM = "PROGRAM"; + public static final String TYPE = "TYPE"; public static final String ITEM_BO = "ITEM_BO"; @@ -644,6 +673,8 @@ public static final String MODIFIED_DATE_TIME = "MODIFIED_DATE_TIME"; ", site = " + site + ", abnormalNo = " + abnormalNo + ", status = " + status + + ", correction = " + correction + + ", program = " + program + ", type = " + type + ", itemBo = " + itemBo + ", sfc = " + sfc + diff --git a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/AbnormalBillService.java b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/AbnormalBillService.java index df5ab507..23049682 100644 --- a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/AbnormalBillService.java +++ b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/AbnormalBillService.java @@ -17,8 +17,8 @@ import java.util.List; * 异常单 服务类 *

* - * @author 赵嘉伟 - * @since 2021-07-22 + * @author zjw + * @since 2021-08-16 */ public interface AbnormalBillService extends IService { @@ -31,6 +31,7 @@ public interface AbnormalBillService extends IService { List selectList(AbnormalBill abnormalBill); + String anomalyReportOther(AbnormalBill abnormalBill, AbnormalBillDispose abnormalBillDispose, List dutyCauseType, @@ -57,7 +58,7 @@ public interface AbnormalBillService extends IService { /** * 初始化 */ - HashMap init(String messageType, String type); + HashMap init(String type); /** * 待办事项 * @param abnormalBillDto @@ -135,4 +136,5 @@ public interface AbnormalBillService extends IService { String formatMessage(AbnormalBill abnormalBill,String messageType, String site); List getQCAbnormal(); + } \ No newline at end of file diff --git a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/impl/AbnormalBillServiceImpl.java b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/impl/AbnormalBillServiceImpl.java index bd139b91..ccd6611f 100644 --- a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/impl/AbnormalBillServiceImpl.java +++ b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/impl/AbnormalBillServiceImpl.java @@ -12,19 +12,23 @@ import com.foreverwin.mesnac.anomaly.model.*; import com.foreverwin.mesnac.anomaly.service.*; import com.foreverwin.mesnac.common.constant.Constants; import com.foreverwin.mesnac.common.dto.ScrapDto; +import com.foreverwin.mesnac.common.dto.UsrDto; import com.foreverwin.mesnac.common.enums.HandleEnum; import com.foreverwin.mesnac.common.helper.NextNumberHelper; import com.foreverwin.mesnac.common.mapper.MessageMapper; import com.foreverwin.mesnac.common.model.Message; import com.foreverwin.mesnac.common.service.AnomalyService; import com.foreverwin.mesnac.common.service.MessageService; +import com.foreverwin.mesnac.common.service.UserService; import com.foreverwin.mesnac.common.util.ActiveMQUtil; import com.foreverwin.mesnac.common.util.StringUtil; import com.foreverwin.mesnac.meapi.mapper.*; import com.foreverwin.mesnac.meapi.model.*; -import com.foreverwin.mesnac.meapi.service.*; +import com.foreverwin.mesnac.meapi.service.DataFieldListService; +import com.foreverwin.mesnac.meapi.service.NwaUserService; +import com.foreverwin.mesnac.meapi.service.RouterService; +import com.foreverwin.mesnac.meapi.service.WorkCenterService; import com.foreverwin.mesnac.meapi.util.StringUtils; -import com.foreverwin.mesnac.production.mapper.SfcScrapMapper; import com.foreverwin.mesnac.quality.service.SelfReportService; import com.foreverwin.modular.core.exception.BaseException; import com.foreverwin.modular.core.exception.BusinessException; @@ -43,8 +47,8 @@ import java.util.*; * 异常单 服务实现类 *

* - * @author 赵嘉伟 - * @since 2021-07-22 + * @author zjw + * @since 2021-08-16 */ @Service @Transactional(rollbackFor = Exception.class) @@ -57,9 +61,6 @@ public class AbnormalBillServiceImpl extends ServiceImpl ncCode = new ArrayList<>(); List ncGroup = new ArrayList<>(); StringBuilder ncCodes = new StringBuilder(); @@ -202,7 +190,7 @@ public class AbnormalBillServiceImpl extends ServiceImpl abnormalNcCodes1 = abnormalNcCodeService.selectList(abnormalNcCode); - if(abnormalNcCodes1.size() != 0){ + if(abnormalNcCodes1.size() > 0){ QueryWrapper abnormalNcCodeQueryWrapper = new QueryWrapper<>(); abnormalNcCodeQueryWrapper.setEntity(abnormalNcCode); abnormalNcCodeService.remove(abnormalNcCodeQueryWrapper); @@ -224,15 +212,19 @@ public class AbnormalBillServiceImpl extends ServiceImpl status = new ArrayList<>(); -// status.add(Constants.PROGRAM_CONFIRM); -// status.add(Constants.CANCEL); -// status.add(Constants.SHUT_DOWN); -// List abnormalBillList = abnormalBillMapper.findCountBySfc(abnormalBill.getSite(), abnormalBill.getType(), abnormalBill.getSfc(), status); -// if(abnormalBillList.size() >= 1 ){ -// throw BusinessException.build("设备异常有未处理完成的sfc"); -// } -// } abnormalBillDisposeService.saveOrUpdate(abnormalBillDispose); this.saveOrUpdate(abnormalBill); //发送消息 - this.anomalyCreatedAndSendMessage(abnormalBill,null); + if(Constants.NEW.equals(abnormalBill.getStatus())){ + this.anomalyCreatedAndSendMessage(abnormalBill,null); + } return message; } @Override - public HashMap init(String messageType, String type) { + public HashMap init(String type) { HashMap hashMap = new HashMap<>(); String site = CommonMethods.getSite(); - //消息类型 -// if("Z".equals(type)){ -// List category = ncCodeService.findNcByCategory(messageType,null); -// hashMap.put("ncByNG",category); -// } + //工作中心 WorkCenter workCenter = new WorkCenter(); workCenter.setWcCategory("LEVEL4"); workCenter.setSite(site); List workCenterList = workCenterService.selectList(workCenter); hashMap.put("workCenter",workCenterList); + + //原因分类 DataField ncCode = new DataField(); ncCode.setSite(site); ncCode.setDataField("REASON_CATEGORY"); List ncCodeList = dataFieldListService.findDataFieldListById(ncCode); hashMap.put("causeType",ncCodeList); + + //责任部门 DataField dataField = new DataField(); dataField.setSite(site); dataField.setDataField("RESPONSIBILITY_DEPARTMENT"); List dutyDepartList = dataFieldListService.findDataFieldListById(dataField); hashMap.put("dutyDepart",dutyDepartList); + + //责任分类 dataField.setDataField("RESPONSIBILITY_TYPE"); List dutyTypeList = dataFieldListService.findDataFieldListById(dataField); hashMap.put("dutyType",dutyTypeList); + + //当前登录用户的fullName - NwaUser nwaUser = new NwaUser(); - nwaUser.setSite(site); - nwaUser.setUserName(CommonMethods.getUser()); - List nwaUsers = nwaUserService.selectList(nwaUser); - if(nwaUsers != null && nwaUsers.size() > 0){ - hashMap.put("currentUser",nwaUsers.get(0).getFullName()); + List list = userService.findList(CommonMethods.getUser()); + if(list != null && list.size() > 0){ + hashMap.put("currentUser",list.get(0).getFullName()); + } //初始化异常单号 if(!StringUtil.isBlank(type)){ hashMap.put("abnormalNo",this.getNextNumber(type)); } + return hashMap; } @@ -363,6 +349,11 @@ public class AbnormalBillServiceImpl extends ServiceImpl operationQueryWrapper = new QueryWrapper(); operationQueryWrapper.eq("OPERATION",abnormalBill.getOperation()) @@ -554,7 +546,7 @@ public class AbnormalBillServiceImpl extends ServiceImpl ncCodes = Arrays.asList(abnormalBill.getNcCode().split(",")); - Integer length = ncCodeMapper.checkNcCode(ncCodes,site,"FAILURE"); + Integer length = ncCodeMapper.checkNcCode(ncCodes,site); if(ncCodes.size() != length){ throw BusinessException.build("不良代码传递有误"); } @@ -672,7 +664,7 @@ public class AbnormalBillServiceImpl extends ServiceImpl abnormalBillList = abnormalBillMapper.findCountBySfc(abnormalBill.getSite(), abnormalBill.getType(), abnormalBill.getSfc(), status); String abnormalType = abnormalBill.getType().equals(Constants.ABNORMAL_QUALITY) ? "质量异常" : - abnormalBill.getType().equals(Constants.ABNORMAL_OTHER) ? "其他异常" : "设备异常" ; + abnormalBill.getType().equals(Constants.ABNORMAL_OTHER) ? "其他异常" : "设备异常" ; if(abnormalBillList.size() >= 1 ){ throw BusinessException.build(abnormalType + "有未处理完成的产品条码(SFC)"); } @@ -876,7 +868,6 @@ public class AbnormalBillServiceImpl extends ServiceImpl wrapper = new QueryWrapper<>(); Message abnormalMessage1 = new Message(); abnormalMessage1.setSite(site); @@ -920,39 +919,47 @@ public class AbnormalBillServiceImpl extends ServiceImpl messageTypeUpdateWrapper = new UpdateWrapper<>(); -// messageTypeUpdateWrapper.eq("SITE",site); -// messageTypeUpdateWrapper.eq("ABNORMAL_BILL_BO",abnormalMessage.getAbnormalBillBo()); Message abnormalMessage2 = new Message(); - // abnormalMessage2.setAbnormalBillBo(abnormalMessage.getAbnormalBillBo()); abnormalMessage2.setStatus("Y"); messageTypeUpdateWrapper.eq("STATUS","N"); messageTypeUpdateWrapper.eq("OBJECT_BO",abnormalMessage.getObjectBo()); messageService.update(abnormalMessage2,messageTypeUpdateWrapper); break; + default: abnormalMessage.setSendUser(abnormalBillDispose.getResolveSendUserGroup()); abnormalMessage.setNode(Constants.ABNORMAL_MESSAGE_CANCEL); break; } + //格式化消息 String message = this.formatMessage(abnormalBill, abnormalMessage.getMessageType(), site); + //得到消息触发的时间 abnormalMessage.setResponseDateTime(now); + //得到要发送的消息 abnormalMessage.setContent(message); + //得到升级的用户组 //新建有、响应没有、纠防确认有、方案确认没有、取消没有、关闭没有 if(Constants.NEW.equals(abnormalBill.getStatus()) || Constants.CORRECTION_CONFIRM.equals(abnormalBill.getStatus())){ @@ -971,13 +978,7 @@ public class AbnormalBillServiceImpl extends ServiceImpl nwaUsers = nwaUserService.checkUserGroup(site,abnormalMessage.getSendUserGroup()); + StringBuilder sendUsers = new StringBuilder(); + for (int i = 0; i < nwaUsers.size(); i++) { if(i == (nwaUsers.size() - 1)){ sendUsers.append(nwaUsers.get(i)); @@ -1009,7 +1009,6 @@ public class AbnormalBillServiceImpl extends ServiceImpl + + @@ -709,7 +711,8 @@ ZABD.DUTY_SEND_USER_GROUP DUTY_SEND_USER_GROUP,ZABD.DUTY_TYPE DUTY_TYPE,ZABD.PRINCIPAL_USER PRINCIPAL_USER,ZABD.ABNORMAL_METHOD ABNORMAL_METHOD, R.ROUTER ROUTER,ZABD.RESOLVE_SHOP_ORDER RESOLVE_SHOP_ORDER,ZABD.RESOLVE_REMARK RESOLVE_REMARK,ZABD.RESOLVE_SEND_USER_GROUP RESOLVE_SEND_USER_GROUP, ZABD.ABNORMAL_REASON ABNORMAL_REASON,ZABD.BEFORE_MEASURE BEFORE_MEASURE,"MAP".VALUE "MAP",listagg(ZANC.NC_CODE_GROUP || '/'||ZANC.NC_CODE || ',') within GROUP(ORDER BY zab.ABNORMAL_NO) NC_CODE, - ZABD.ROUTER_BO ROUTER_BO,ZAB.OPERATION OPERATION,I.HANDLE ITEM_BO,ZAB.REPORT_SEND_USER_GROUP REPORT_SEND_USER_GROUP + ZABD.ROUTER_BO ROUTER_BO,ZAB.OPERATION OPERATION,I.HANDLE ITEM_BO,ZAB.REPORT_SEND_USER_GROUP REPORT_SEND_USER_GROUP, + ZAB.CORRECTION CORRECTION,ZAB.PROGRAM PROGRAM FROM Z_ABNORMAL_BILL ZAB LEFT JOIN Z_ABNORMAL_BILL_DISPOSE ZABD ON ZAB.HANDLE = ZABD.ABNORMAL_BILL_BO INNER JOIN ITEM I ON I.HANDLE = ZAB.ITEM_BO @@ -746,7 +749,7 @@ ZABD.DUTY_SEND_USER_GROUP ,ZABD.DUTY_TYPE ,ZABD.PRINCIPAL_USER ,ZABD.ABNORMAL_METHOD , R.ROUTER ,ZABD.RESOLVE_SHOP_ORDER ,ZABD.RESOLVE_REMARK ,ZABD.RESOLVE_SEND_USER_GROUP , ZABD.ABNORMAL_REASON ,ZABD.BEFORE_MEASURE ,"MAP".VALUE,ZABD.ROUTER_BO,ZAB.OPERATION,I.HANDLE, - ZAB.REPORT_SEND_USER_GROUP + ZAB.REPORT_SEND_USER_GROUP,ZAB.CORRECTION,ZAB.PROGRAM diff --git a/anomaly/src/main/resources/mapper/AbnormalBillMapper.xml b/anomaly/src/main/resources/mapper/AbnormalBillMapper.xml index ed19ce64..7e24585f 100644 --- a/anomaly/src/main/resources/mapper/AbnormalBillMapper.xml +++ b/anomaly/src/main/resources/mapper/AbnormalBillMapper.xml @@ -8,6 +8,8 @@ + + @@ -44,6 +46,8 @@ + + @@ -72,9 +76,10 @@ + - HANDLE, SITE, ABNORMAL_NO, STATUS, TYPE, ITEM_BO, SFC, OPERATION, WORK_CENTER, SHOP_ORDER, MESSAGE_TYPE, RESRCE, NC_CODE, SHUT_DOWN, RESPONSE_USER, RESPONSE_DATE_TIME, PB_DESCRIPTION, NC_QTY, PB_GRADE, PB_USER, PB_QTY, REPAIR_DATE_TIME, DISCOVER, INSPECTOR, ENTITY_LOCATION, REPORT_FROM, OBJECT_BO, PB_PHOTOSHOP, CANCEL_CODE, CANCEL_REASON, CANCEL_DATE_TIME, CANCEL_USER, REPORT_SEND_USER_GROUP, CANCEL_SEND_USER_GROUP, CREATED_USER, CREATED_DATE_TIME, MODIFIED_USER, MODIFIED_DATE_TIME + HANDLE, SITE, ABNORMAL_NO, STATUS, CORRECTION, PROGRAM, TYPE, ITEM_BO, SFC, OPERATION, WORK_CENTER, SHOP_ORDER, MESSAGE_TYPE, RESRCE, NC_CODE, SHUT_DOWN, RESPONSE_USER, RESPONSE_DATE_TIME, PB_DESCRIPTION, NC_QTY, PB_GRADE, PB_USER, PB_QTY, REPAIR_DATE_TIME, DISCOVER, INSPECTOR, ENTITY_LOCATION, REPORT_FROM, OBJECT_BO, PB_PHOTOSHOP, CANCEL_CODE, CANCEL_REASON, CANCEL_DATE_TIME, CANCEL_USER, REPORT_SEND_USER_GROUP, CANCEL_SEND_USER_GROUP, CREATED_USER, CREATED_DATE_TIME, MODIFIED_USER, MODIFIED_DATE_TIME @@ -112,6 +117,8 @@ AND SITE=#{ew.entity.site} AND ABNORMAL_NO=#{ew.entity.abnormalNo} AND STATUS=#{ew.entity.status} + AND CORRECTION=#{ew.entity.correction} + AND PROGRAM=#{ew.entity.program} AND TYPE=#{ew.entity.type} AND ITEM_BO=#{ew.entity.itemBo} AND SFC=#{ew.entity.sfc} @@ -160,6 +167,8 @@ AND SITE=#{ew.entity.site} AND ABNORMAL_NO=#{ew.entity.abnormalNo} AND STATUS=#{ew.entity.status} + AND CORRECTION=#{ew.entity.correction} + AND PROGRAM=#{ew.entity.program} AND TYPE=#{ew.entity.type} AND ITEM_BO=#{ew.entity.itemBo} AND SFC=#{ew.entity.sfc} @@ -216,6 +225,8 @@ AND SITE=#{ew.entity.site} AND ABNORMAL_NO=#{ew.entity.abnormalNo} AND STATUS=#{ew.entity.status} + AND CORRECTION=#{ew.entity.correction} + AND PROGRAM=#{ew.entity.program} AND TYPE=#{ew.entity.type} AND ITEM_BO=#{ew.entity.itemBo} AND SFC=#{ew.entity.sfc} @@ -252,7 +263,7 @@ AND MODIFIED_DATE_TIME=#{ew.entity.modifiedDateTime} - ${ew.sqlSegment} + ${ew.sqlSegment} @@ -272,6 +283,8 @@ AND SITE=#{ew.entity.site} AND ABNORMAL_NO=#{ew.entity.abnormalNo} AND STATUS=#{ew.entity.status} + AND CORRECTION=#{ew.entity.correction} + AND PROGRAM=#{ew.entity.program} AND TYPE=#{ew.entity.type} AND ITEM_BO=#{ew.entity.itemBo} AND SFC=#{ew.entity.sfc} @@ -328,6 +341,8 @@ AND SITE=#{ew.entity.site} AND ABNORMAL_NO=#{ew.entity.abnormalNo} AND STATUS=#{ew.entity.status} + AND CORRECTION=#{ew.entity.correction} + AND PROGRAM=#{ew.entity.program} AND TYPE=#{ew.entity.type} AND ITEM_BO=#{ew.entity.itemBo} AND SFC=#{ew.entity.sfc} @@ -384,6 +399,8 @@ AND SITE=#{ew.entity.site} AND ABNORMAL_NO=#{ew.entity.abnormalNo} AND STATUS=#{ew.entity.status} + AND CORRECTION=#{ew.entity.correction} + AND PROGRAM=#{ew.entity.program} AND TYPE=#{ew.entity.type} AND ITEM_BO=#{ew.entity.itemBo} AND SFC=#{ew.entity.sfc} @@ -420,12 +437,12 @@ AND MODIFIED_DATE_TIME=#{ew.entity.modifiedDateTime} - AND ${ew.sqlSegment} + ${ew.sqlSegment} - AND ${ew.sqlSegment} + ${ew.sqlSegment} @@ -440,6 +457,8 @@ AND SITE=#{ew.entity.site} AND ABNORMAL_NO=#{ew.entity.abnormalNo} AND STATUS=#{ew.entity.status} + AND CORRECTION=#{ew.entity.correction} + AND PROGRAM=#{ew.entity.program} AND TYPE=#{ew.entity.type} AND ITEM_BO=#{ew.entity.itemBo} AND SFC=#{ew.entity.sfc} @@ -492,6 +511,8 @@ SITE, ABNORMAL_NO, STATUS, + CORRECTION, + PROGRAM, TYPE, ITEM_BO, SFC, @@ -532,6 +553,8 @@ #{site}, #{abnormalNo}, #{status}, + #{correction}, + #{program}, #{type}, #{itemBo}, #{sfc}, @@ -579,6 +602,8 @@ #{site}, #{abnormalNo}, #{status}, + #{correction}, + #{program}, #{type}, #{itemBo}, #{sfc}, @@ -622,6 +647,8 @@ SITE=#{et.site}, ABNORMAL_NO=#{et.abnormalNo}, STATUS=#{et.status}, + CORRECTION=#{et.correction}, + PROGRAM=#{et.program}, TYPE=#{et.type}, ITEM_BO=#{et.itemBo}, SFC=#{et.sfc}, @@ -665,6 +692,8 @@ SITE=#{et.site}, ABNORMAL_NO=#{et.abnormalNo}, STATUS=#{et.status}, + CORRECTION=#{et.correction}, + PROGRAM=#{et.program}, TYPE=#{et.type}, ITEM_BO=#{et.itemBo}, SFC=#{et.sfc}, @@ -708,6 +737,8 @@ SITE=#{et.site}, ABNORMAL_NO=#{et.abnormalNo}, STATUS=#{et.status}, + CORRECTION=#{et.correction}, + PROGRAM=#{et.program}, TYPE=#{et.type}, ITEM_BO=#{et.itemBo}, SFC=#{et.sfc}, @@ -750,6 +781,8 @@ AND SITE=#{ew.entity.site} AND ABNORMAL_NO=#{ew.entity.abnormalNo} AND STATUS=#{ew.entity.status} + AND CORRECTION=#{ew.entity.correction} + AND PROGRAM=#{ew.entity.program} AND TYPE=#{ew.entity.type} AND ITEM_BO=#{ew.entity.itemBo} AND SFC=#{ew.entity.sfc} @@ -823,6 +856,8 @@ AND SITE=#{ew.entity.site} AND ABNORMAL_NO=#{ew.entity.abnormalNo} AND STATUS=#{ew.entity.status} + AND CORRECTION=#{ew.entity.correction} + AND PROGRAM=#{ew.entity.program} AND TYPE=#{ew.entity.type} AND ITEM_BO=#{ew.entity.itemBo} AND SFC=#{ew.entity.sfc} @@ -992,8 +1027,8 @@ CASE WHEN R.ROUTER != 'NULL' THEN R.ROUTER || '/' || R.REVISION END ROUTER , CASE WHEN B.BOM != 'NULL' THEN B.BOM || '/' || B.REVISION END BOM, CASE WHEN ZSS.HANDLE != 'NULL' THEN ZSS.REASON - ELSE ZABV.PB_DESCRIPTION - END REASON, + ELSE ZABV.PB_DESCRIPTION + END REASON, ZSS.TYPE TYPE FROM SFC S INNER JOIN SFC_ROUTING SR ON SR.SFC_BO = S.HANDLE @@ -1002,17 +1037,17 @@ INNER JOIN STATUS S2 ON S2.HANDLE = S.STATUS_BO INNER JOIN Z_SFC_DISPATCH ZSD ON ZSD.DISPATCH_NO = S.SFC || '-' || SS.STEP_ID LEFT JOIN Z_SFC_DISPATCH ZSD2 ON ZSD2.DISPATCH_NO = S.SFC || '-' || SS.STEP_ID - AND ZSD2.DISPATCH_STATUS IN ('START','COMPLETE') + AND ZSD2.DISPATCH_STATUS IN ('START','COMPLETE') LEFT JOIN SHOP_ORDER SO ON SO.SHOP_ORDER = ZSD.SHOP_ORDER AND SO.SITE = S.SITE LEFT JOIN ITEM I ON I.HANDLE = SO.PLANNED_ITEM_BO LEFT JOIN ROUTER R ON R.HANDLE = ZSD.ROUTER_BO LEFT JOIN Z_SFC_SCRAP ZSS ON ZSS.SFC = S.SFC AND ZSS.SITE = S.SITE LEFT JOIN BOM B ON B.HANDLE = SO.PLANNED_BOM_BO INNER JOIN ( SELECT * FROM Z_ABNORMAL_BILL_VIEW ZABV WHERE ZABV.HANDLE = (SELECT MAX(HANDLE) FROM Z_ABNORMAL_BILL_VIEW ZABV2 - - ZABV2.SFC = #{sfc} - - )) ZABV ON ZABV.SFC = S.SFC AND ZABV.SITE= S.SITE + + ZABV2.SFC = #{sfc} + + )) ZABV ON ZABV.SFC = S.SFC AND ZABV.SITE= S.SITE S.SITE = #{site} AND S.SFC = #{sfc} @@ -1020,8 +1055,9 @@ + diff --git a/dispatch/src/main/java/com/foreverwin/mesnac/dispatch/controller/SfcDispatchController.java b/dispatch/src/main/java/com/foreverwin/mesnac/dispatch/controller/SfcDispatchController.java index cc086aec..31524af4 100644 --- a/dispatch/src/main/java/com/foreverwin/mesnac/dispatch/controller/SfcDispatchController.java +++ b/dispatch/src/main/java/com/foreverwin/mesnac/dispatch/controller/SfcDispatchController.java @@ -1,19 +1,17 @@ package com.foreverwin.mesnac.dispatch.controller; import cn.hutool.core.date.DateUtil; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; import com.foreverwin.mesnac.common.dto.SfcDispatchDto; import com.foreverwin.mesnac.common.enums.DispatchStatusEnum; import com.foreverwin.mesnac.common.util.StringUtil; -import com.foreverwin.mesnac.dispatch.dto.WorkCenterWorkTimeDTO; -import com.foreverwin.mesnac.dispatch.model.ShopOrderRelease; -import com.foreverwin.modular.core.exception.BusinessException; -import com.foreverwin.modular.core.util.R; -import com.foreverwin.modular.core.util.FrontPage; -import com.foreverwin.modular.core.util.CommonMethods; -import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; -import com.baomidou.mybatisplus.core.metadata.IPage; import com.foreverwin.mesnac.dispatch.model.SfcDispatch; import com.foreverwin.mesnac.dispatch.service.SfcDispatchService; +import com.foreverwin.modular.core.exception.BusinessException; +import com.foreverwin.modular.core.util.CommonMethods; +import com.foreverwin.modular.core.util.FrontPage; +import com.foreverwin.modular.core.util.R; import org.apache.ibatis.annotations.Param; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; @@ -161,35 +159,10 @@ public class SfcDispatchController { if (frontPage.getGlobalQuery() != null && !"".equals(frontPage.getGlobalQuery().trim())) { //TODO modify global query queryWrapper.lambda().and(wrapper -> wrapper - .like(SfcDispatch::getHandle, frontPage.getGlobalQuery()) - .or().like(SfcDispatch::getSite, frontPage.getGlobalQuery()) .or().like(SfcDispatch::getShopOrder, frontPage.getGlobalQuery()) .or().like(SfcDispatch::getSfc, frontPage.getGlobalQuery()) - .or().like(SfcDispatch::getBlankingSize, frontPage.getGlobalQuery()) - .or().like(SfcDispatch::getDispatchSeq, frontPage.getGlobalQuery()) .or().like(SfcDispatch::getDispatchNo, frontPage.getGlobalQuery()) .or().like(SfcDispatch::getDispatchStatus, frontPage.getGlobalQuery()) - .or().like(SfcDispatch::getDrawingsNo, frontPage.getGlobalQuery()) - .or().like(SfcDispatch::getDrawingsRevision, frontPage.getGlobalQuery()) - .or().like(SfcDispatch::getIsLock, frontPage.getGlobalQuery()) - .or().like(SfcDispatch::getRouterBo, frontPage.getGlobalQuery()) - .or().like(SfcDispatch::getStepId, frontPage.getGlobalQuery()) - .or().like(SfcDispatch::getOperation, frontPage.getGlobalQuery()) - .or().like(SfcDispatch::getResourceType, frontPage.getGlobalQuery()) - .or().like(SfcDispatch::getWorkCenter, frontPage.getGlobalQuery()) - .or().like(SfcDispatch::getResrce, frontPage.getGlobalQuery()) - .or().like(SfcDispatch::getEmployee, frontPage.getGlobalQuery()) - .or().like(SfcDispatch::getTurnOperation, frontPage.getGlobalQuery()) - .or().like(SfcDispatch::getIsDispatch, frontPage.getGlobalQuery()) - .or().like(SfcDispatch::getIsImport, frontPage.getGlobalQuery()) - .or().like(SfcDispatch::getRemark, frontPage.getGlobalQuery()) - .or().like(SfcDispatch::getCreateUser, frontPage.getGlobalQuery()) - .or().like(SfcDispatch::getModifyUser, frontPage.getGlobalQuery()) - .or().like(SfcDispatch::getOther1, frontPage.getGlobalQuery()) - .or().like(SfcDispatch::getOther2, frontPage.getGlobalQuery()) - .or().like(SfcDispatch::getOther3, frontPage.getGlobalQuery()) - .or().like(SfcDispatch::getOther4, frontPage.getGlobalQuery()) - .or().like(SfcDispatch::getOther5, frontPage.getGlobalQuery()) ); } result = sfcDispatchService.page(frontPage.getPagePlus(), queryWrapper); diff --git a/dispatch/src/main/resources/mapper/SfcDispatchMapper.xml b/dispatch/src/main/resources/mapper/SfcDispatchMapper.xml index b4cf9612..cace586f 100644 --- a/dispatch/src/main/resources/mapper/SfcDispatchMapper.xml +++ b/dispatch/src/main/resources/mapper/SfcDispatchMapper.xml @@ -1072,10 +1072,10 @@ UPDATE Z_SFC_DISPATCH SET DISPATCH_STATUS = #{dispatchStatus}, MODIFY_USER = #{modifyUser}, MODIFIED_DATE_TIME = #{modifiedDateTime} - + , ACTUAL_COMPLETE_DATE = #{modifiedDateTime} - + , ACTUAL_START_DATE = #{modifiedDateTime} WHERE SITE = #{site} AND DISPATCH_NO = #{dispatchNo} diff --git a/meapi/src/main/java/com/foreverwin/mesnac/meapi/controller/ShopOrderController.java b/meapi/src/main/java/com/foreverwin/mesnac/meapi/controller/ShopOrderController.java index 6032f4d1..7ee201fa 100644 --- a/meapi/src/main/java/com/foreverwin/mesnac/meapi/controller/ShopOrderController.java +++ b/meapi/src/main/java/com/foreverwin/mesnac/meapi/controller/ShopOrderController.java @@ -71,12 +71,13 @@ public class ShopOrderController { /** * 根据handle找到对应的工单并且该工单是下达的 - * @param handle + * @param shopOrder + * @param plannedItemBo * @return */ @GetMapping("/findById") - public R findById(String handle,String plannedItemBo){ - return R.ok(shopOrderService.findById(handle,plannedItemBo)); + public R findById(String shopOrder,String plannedItemBo){ + return R.ok(shopOrderService.findById(shopOrder,plannedItemBo)); } /** diff --git a/meapi/src/main/java/com/foreverwin/mesnac/meapi/mapper/NcCodeMapper.java b/meapi/src/main/java/com/foreverwin/mesnac/meapi/mapper/NcCodeMapper.java index 75c9502d..19878a13 100644 --- a/meapi/src/main/java/com/foreverwin/mesnac/meapi/mapper/NcCodeMapper.java +++ b/meapi/src/main/java/com/foreverwin/mesnac/meapi/mapper/NcCodeMapper.java @@ -41,7 +41,7 @@ public interface NcCodeMapper extends BaseMapper { * 判断不良代码是否正确 * @return */ - Integer checkNcCode(@Param("NcCodeList")List ncCodes,@Param("site")String site,@Param("category")String category); + Integer checkNcCode(@Param("NcCodeList")List ncCodes,@Param("site")String site); List findNcCodeByNcGroup(@Param("ncGroup")NcGroup ncGroup); diff --git a/meapi/src/main/java/com/foreverwin/mesnac/meapi/mapper/ShopOrderMapper.java b/meapi/src/main/java/com/foreverwin/mesnac/meapi/mapper/ShopOrderMapper.java index e7d4e1b8..0a4fc192 100644 --- a/meapi/src/main/java/com/foreverwin/mesnac/meapi/mapper/ShopOrderMapper.java +++ b/meapi/src/main/java/com/foreverwin/mesnac/meapi/mapper/ShopOrderMapper.java @@ -17,7 +17,7 @@ import org.springframework.stereotype.Repository; @Repository public interface ShopOrderMapper extends BaseMapper { - ShopOrder findById(@Param("handle")String handle,@Param("status501")String status501,@Param("plannedItemBo")String plannedItemBo); + ShopOrder findById(@Param("site")String site,@Param("shopOrder")String shopOrder,@Param("status501")String status501,@Param("plannedItemBo")String plannedItemBo); ShopOrderDto findByShopOrderBo(@Param("handle")String handle); } \ No newline at end of file diff --git a/meapi/src/main/java/com/foreverwin/mesnac/meapi/service/ShopOrderService.java b/meapi/src/main/java/com/foreverwin/mesnac/meapi/service/ShopOrderService.java index 7554f661..ea0ef5d5 100644 --- a/meapi/src/main/java/com/foreverwin/mesnac/meapi/service/ShopOrderService.java +++ b/meapi/src/main/java/com/foreverwin/mesnac/meapi/service/ShopOrderService.java @@ -29,10 +29,10 @@ public interface ShopOrderService extends IService { /** * 根据handle找到对应的可下达的工单 - * @param handle + * @param shopOrder * @return */ - ShopOrder findById(String handle,String plannedItemBo); + ShopOrder findById(String shopOrder,String plannedItemBo); ShopOrderDto findByShopOrderBo(String handle); diff --git a/meapi/src/main/java/com/foreverwin/mesnac/meapi/service/impl/ShopOrderServiceImpl.java b/meapi/src/main/java/com/foreverwin/mesnac/meapi/service/impl/ShopOrderServiceImpl.java index 20d6e2d8..b888036b 100644 --- a/meapi/src/main/java/com/foreverwin/mesnac/meapi/service/impl/ShopOrderServiceImpl.java +++ b/meapi/src/main/java/com/foreverwin/mesnac/meapi/service/impl/ShopOrderServiceImpl.java @@ -47,20 +47,20 @@ public class ShopOrderServiceImpl extends ServiceImpl @@ -106,6 +108,7 @@ AND CREATED_DATE_TIME=#{ew.entity.createdDateTime} AND MODIFY_USER=#{ew.entity.modifyUser} AND MODIFIED_DATE_TIME=#{ew.entity.modifiedDateTime} + AND NC_CODE_DESC=#{ew.entity.ncCodeDesc} ${ew.sqlSegment} @@ -142,6 +145,7 @@ AND CREATED_DATE_TIME=#{ew.entity.createdDateTime} AND MODIFY_USER=#{ew.entity.modifyUser} AND MODIFIED_DATE_TIME=#{ew.entity.modifiedDateTime} + AND NC_CODE_DESC=#{ew.entity.ncCodeDesc} ${ew.sqlSegment} @@ -152,46 +156,6 @@ ${ew.sqlSegment} - + SELECT ZSR.HANDLE, ZSR.SITE, ZSR.TASK_NO, ZSR.WORK_CENTER,ZSR.NC_CODE_DESC, ZSR.SHOP_ORDER, ZSR.ITEM, ZSR.OP_STEP, ZSR.RESRCE, ZSR.SFC, ZSR.NC_CODE, ZSR.NC_QTY, ZSR.LOCATION, ZSR.STATE, ZSR.REMARK, B.FULL_NAME CREATE_USER,ZSR. CREATED_DATE_TIME,IT.DESCRIPTION FROM Z_SELF_REPORT ZSR + JOIN ITEM I ON I.ITEM = ZSR.ITEM AND I.CURRENT_REVISION='true' + LEFT JOIN ITEM_T IT ON I.HANDLE = IT.ITEM_BO AND IT.LOCALE = #{locale} + LEFT JOIN Z_NWA_USER B ON ZSR.SITE = B.SITE AND ZSR.CREATE_USER = B.USER_NAME + + + + + HANDLE=#{ew.entity.handle} + + AND ZSR.SITE=#{ew.entity.site} + AND ZSR.TASK_NO=#{ew.entity.taskNo} + AND ZSR.WORK_CENTER=#{ew.entity.workCenter} + AND ZSR.SHOP_ORDER=#{ew.entity.shopOrder} + AND ZSR.ITEM=#{ew.entity.item} + AND ZSR.OP_STEP=#{ew.entity.opStep} + AND ZSR.RESRCE=#{ew.entity.resrce} + AND ZSR.SFC=#{ew.entity.sfc} + AND ZSR.NC_CODE=#{ew.entity.ncCode} + AND ZSR.NC_QTY=#{ew.entity.ncQty} + AND ZSR.LOCATION=#{ew.entity.location} + AND ZSR.STATE=#{ew.entity.state} + AND ZSR.REMARK=#{ew.entity.remark} + AND ZSR.CREATE_USER=#{ew.entity.createUser} + AND ZSR.CREATED_DATE_TIME=#{ew.entity.createdDateTime} + AND ZSR.MODIFY_USER=#{ew.entity.modifyUser} + AND ZSR.MODIFIED_DATE_TIME=#{ew.entity.modifiedDateTime} + + AND ZSR.CREATED_DATE_TIME >=#{startTime} + AND ZSR.CREATED_DATE_TIME <=#{endTime} + + ${ew.sqlSegment} + + + + + ${ew.sqlSegment} + +