增加通知

blade-common/src/main/java/org/springblade/common/constant/LauncherConstant.java

@@ -12,9 +12,9 @@ public interface LauncherConstant {
     /**
      * nacos 命名空间
      */
-//	String NACOS_NAMESPACE = "feaf627f-a847-463b-8b73-24a0538f526e";
+	String NACOS_NAMESPACE = "feaf627f-a847-463b-8b73-24a0538f526e";
 	// 生产环境
-	String NACOS_NAMESPACE = "db3f4da1-ae19-4104-8c17-6d9b8f069401";
+//	String NACOS_NAMESPACE = "db3f4da1-ae19-4104-8c17-6d9b8f069401";
 	// 测试环境
 //	String NACOS_NAMESPACE = "6cdd0310-0d61-4f54-891a-7fb06224d9b8";
 

blade-service/blade-desk/src/main/java/org/springblade/desk/dashboard/service/IDsPartService.java

@@ -100,7 +100,7 @@ public interface IDsPartService extends BaseService<DsPartEntity> {
 
 	/**
 	 * 零件失效预警定时任务
-	 * todo 定时任务
+	 *
 	 * @return
 	 */
 	boolean partLoseEfficacy();

blade-service/blade-desk/src/main/java/org/springblade/desk/dashboard/service/impl/DsPartServiceImpl.java

@@ -12,6 +12,8 @@ import org.springblade.core.secure.utils.AuthUtil;
 import org.springblade.core.tool.api.R;
 import org.springblade.core.tool.utils.Func;
 import org.springblade.core.tool.utils.SpringUtil;
+import org.springblade.desk.common.constant.BizTypeConstant;
+import org.springblade.desk.common.service.IMesNotifyMessageService;
 import org.springblade.desk.dashboard.constant.TaskingConstant;
 import org.springblade.desk.dashboard.excel.DsPartExcel;
 import org.springblade.desk.dashboard.mapper.DsPartMapper;
@@ -95,6 +97,9 @@ public class DsPartServiceImpl extends BaseServiceImpl<DsPartMapper, DsPartEntit
 	@Autowired
 	IPrReworkProcessService prReworkProcessService;
 
+	@Autowired
+	IMesNotifyMessageService mesNotifyMessageService;
+
 	@Override
 	public IPage<DsPartVO> selectDsPartPage(IPage<DsPartVO> page, DsPartVO dsPart) {
 
@@ -250,7 +255,20 @@ public class DsPartServiceImpl extends BaseServiceImpl<DsPartMapper, DsPartEntit
 		for (DsPartEntity partEntity : dsPartEntityList) {
 			//获取工艺员
 			String technician = partEntity.getTechnician();
-			//todo 推送相关负责人待办
+
+			UserInfo craftUserInfo = userClient.userInfo(Func.toLong(partEntity.getTechnician())).getData();
+			if (craftUserInfo == null || craftUserInfo.getUser() == null) {
+				log.error("零件失效预警，工艺员查询失败:{}",partEntity.getPartCode());
+			}
+			Long craftManId = craftUserInfo.getUser().getId();
+
+			// 推送相关负责人待办
+			mesNotifyMessageService.saveMsg(
+					BizTypeConstant.CRAFT_TASK_REDEPLOY,
+					"零件即将过期",
+					"零件即将过期，请及时处理，零件号："+partEntity.getPartCode(),
+					craftManId
+			);
 		}
 		return true;
 	}
@@ -394,9 +412,7 @@ public class DsPartServiceImpl extends BaseServiceImpl<DsPartMapper, DsPartEntit
 		updateById(dsPart);
 		if (!TaskingConstant.IS_SINTERING.equals(dsPart.getIsSintering())) {
 			if ((org.apache.commons.lang3.StringUtils.isNotBlank(dsPart.getCraftWay()) && dsPart.getCraftWay().contains("4"))) {
-
-
-				//	todo			getErpDataPartClient().sendingPartGiveErp(dsPart);
+				//	todo getErpDataPartClient().sendingPartGiveErp(dsPart);
 			}
 		}
 		if (!CollectionUtils.isEmpty(zPartList)) {

blade-service/blade-desk/src/main/java/org/springblade/desk/dashboard/service/impl/DsSpecialProServiceImpl.java

@@ -113,7 +113,7 @@ public class DsSpecialProServiceImpl extends BaseServiceImpl<DsSpecialProMapper,
 				throw new ServiceException("工艺员: "+dsSpecialProExcel.getProMan()+" 不存在");
 			}
 
-			//todo 验证产线是否存在
+			//验证产线是否存在
 			DsSpecialProEntity dsSpecialProEntity = new DsSpecialProEntity();
 			dsSpecialProEntity.setWcId(workCenterEntity.getId());
 			dsSpecialProEntity.setEquipmentCode(dsSpecialProExcel.getEquipmentCode());

blade-service/blade-desk/src/main/java/org/springblade/desk/dashboard/service/impl/DsTaskBillServiceImpl.java

@@ -28,6 +28,8 @@ import com.alibaba.druid.sql.visitor.functions.Function;
 import com.google.common.base.Strings;
 import lombok.extern.slf4j.Slf4j;
 import org.springblade.core.tool.utils.Func;
+import org.springblade.desk.common.constant.BizTypeConstant;
+import org.springblade.desk.common.service.IMesNotifyMessageService;
 import org.springblade.desk.dashboard.pojo.entity.BsFillingDetailEntity;
 import org.springblade.desk.dashboard.pojo.entity.DsSpecialProEntity;
 import org.springblade.desk.dashboard.pojo.entity.DsTaskBillEntity;
@@ -73,6 +75,9 @@ public class DsTaskBillServiceImpl extends BaseServiceImpl<DsTaskBillMapper, DsT
 	@Autowired
 	IUserClient userClient;
 
+	@Autowired
+	IMesNotifyMessageService mesNotifyMessageService;
+
 	@Override
 	public IPage<DsTaskBillVO> selectDsTaskBillPage(IPage<DsTaskBillVO> page, DsTaskBillVO dsTaskBill) {
 		List<DsTaskBillVO> dsTaskBillVOS = baseMapper.selectDsTaskBillPage(page, dsTaskBill);
@@ -140,9 +145,13 @@ public class DsTaskBillServiceImpl extends BaseServiceImpl<DsTaskBillMapper, DsT
 				log.error("特殊过程项修改失败");
 			}
 			next++;
-			//todo 发消息到工艺员
-//			pfMessageService.sendMessage("产线：" + dsSpecialPro.getBsWorkCenter().getWcName() + "，已生成新的工艺任务，请及时处理！",
-//					dsSpecialPro.getProMan().getUserId(), PfMessageType.MTCODE_0200, null, Boolean.FALSE, null);
+			// 发消息到工艺员
+			mesNotifyMessageService.saveMsg(
+					BizTypeConstant.CRAFT_TASK_REDEPLOY,
+					"产线",
+					"已生成新的工艺任务，请及时处理！"+dsTaskBill.getTbCode(),
+					dsSpecialPro.getProMan()
+			);
 		}
 	}
 

blade-service/blade-desk/src/main/java/org/springblade/desk/dashboard/service/impl/DsTaskingServiceImpl.java

@@ -650,7 +650,7 @@ public class DsTaskingServiceImpl extends BaseServiceImpl<DsTaskingMapper, DsTas
 		if (craftUserInfo == null || craftUserInfo.getUser() == null) {
 			throw new ServiceException("目标工艺员不存在");
 		}
-		String craftMan = craftUserInfo.getUser().getName();
+		String craftMan = craftUserInfo.getUser().getRealName();
 		Long craftManId = craftUserInfo.getUser().getId();
 
 		// 6. 记录转派前的信息（便于日志记录）
@@ -673,8 +673,8 @@ public class DsTaskingServiceImpl extends BaseServiceImpl<DsTaskingMapper, DsTas
 			// 通知新工艺员
 			mesNotifyMessageService.saveMsg(
 					BizTypeConstant.CRAFT_TASK_REDEPLOY,
-					"您有新的任务转派，请及时处理",
-					String.valueOf(tasking.getId()),
+					"工艺任务转派",
+					"您有新的任务转派，请及时处理，零件号："+tasking.getPartCode(),
 					craftManId
 			);
 
@@ -682,8 +682,8 @@ public class DsTaskingServiceImpl extends BaseServiceImpl<DsTaskingMapper, DsTas
 			if (!StringUtils.isEmpty(oldCraftMan)) {
 				mesNotifyMessageService.saveMsg(
 						BizTypeConstant.CRAFT_TASK_REDEPLOY,
-						"您的任务已被转派",
-						String.valueOf(tasking.getId()),
+						"工艺任务转派",
+						"您的工艺任务已被转派，零件号: "+tasking.getPartCode(),
 						Long.valueOf(oldCraftMan)
 				);
 			}
@@ -2145,7 +2145,7 @@ public class DsTaskingServiceImpl extends BaseServiceImpl<DsTaskingMapper, DsTas
 	}
 
 	private void markErpTaskProcessed(String redono) {
-		//todo 更新更新erp状态
+		// 更新更新erp状态
 //		String sql = "{call pro_rbredoroutstat(?, ?, ?)}";
 //		标记erp的分配状态
 //		dba_mgr.pro_rbredoroutstat@erp_mes_link(v_redono,v_excnote, v_excflag);