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..ccde7db9 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 @@ -185,13 +185,12 @@ public class AbnormalBillController { /** * 初始化 - * @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)); } 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..4a72966f 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 @@ -57,7 +57,7 @@ public interface AbnormalBillService extends IService { /** * 初始化 */ - HashMap init(String messageType, String type); + HashMap init( String type); /** * 待办事项 * @param abnormalBillDto 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..3f06a845 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; @@ -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,7 +212,9 @@ public class AbnormalBillServiceImpl extends ServiceImpl 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; } @@ -470,6 +467,15 @@ public class AbnormalBillServiceImpl extends ServiceImpl operationQueryWrapper = new QueryWrapper(); operationQueryWrapper.eq("OPERATION",abnormalBill.getOperation()) @@ -554,7 +560,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("不良代码传递有误"); } @@ -876,7 +882,6 @@ public class AbnormalBillServiceImpl extends ServiceImpl wrapper = new QueryWrapper<>(); Message abnormalMessage1 = new Message(); abnormalMessage1.setSite(site); @@ -920,39 +933,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())){ @@ -972,12 +993,7 @@ public class AbnormalBillServiceImpl extends ServiceImpl nwaUsers = nwaUserService.checkUserGroup(site,abnormalMessage.getSendUserGroup()); StringBuilder sendUsers = new StringBuilder(); for (int i = 0; i < nwaUsers.size(); i++) { 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