|
@@ -1,11 +1,8 @@
|
|
package com.rongwei.bscommon.sys.service.impl;
|
|
package com.rongwei.bscommon.sys.service.impl;
|
|
|
|
|
|
-import cn.hutool.json.JSONArray;
|
|
|
|
-import cn.hutool.json.JSONUtil;
|
|
|
|
import com.rongwei.bscommon.sys.service.EquLubricationTaskManagementService;
|
|
import com.rongwei.bscommon.sys.service.EquLubricationTaskManagementService;
|
|
import com.rongwei.bscommon.sys.service.EquMaintenanceTaskService;
|
|
import com.rongwei.bscommon.sys.service.EquMaintenanceTaskService;
|
|
import com.rongwei.bscommon.sys.service.EquipmentSendNotifyService;
|
|
import com.rongwei.bscommon.sys.service.EquipmentSendNotifyService;
|
|
-import com.rongwei.bscommon.sys.utils.StringUtil;
|
|
|
|
import com.rongwei.bsentity.domain.EquLubricationTaskManagementDo;
|
|
import com.rongwei.bsentity.domain.EquLubricationTaskManagementDo;
|
|
import com.rongwei.bsentity.domain.EquMaintenanceTaskDo;
|
|
import com.rongwei.bsentity.domain.EquMaintenanceTaskDo;
|
|
import com.rongwei.rwadmincommon.system.domain.SysDictDo;
|
|
import com.rongwei.rwadmincommon.system.domain.SysDictDo;
|
|
@@ -18,7 +15,11 @@ import org.apache.commons.lang.StringUtils;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
-import java.util.*;
|
|
|
|
|
|
+import java.text.SimpleDateFormat;
|
|
|
|
+import java.util.ArrayList;
|
|
|
|
+import java.util.Arrays;
|
|
|
|
+import java.util.List;
|
|
|
|
+import java.util.Map;
|
|
import java.util.stream.Collectors;
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
import static com.rongwei.safecommon.utils.SaveConstans.NotifyContent.*;
|
|
import static com.rongwei.safecommon.utils.SaveConstans.NotifyContent.*;
|
|
@@ -87,17 +88,10 @@ public class EquipmentSendNotifyServiceImpl implements EquipmentSendNotifyServic
|
|
String context = String.format(MAINTAIN_SYSTEM_CONTENT, maintenanceTaskDo.getPlanyear() + "-" + maintenanceTaskDo.getMonth(),
|
|
String context = String.format(MAINTAIN_SYSTEM_CONTENT, maintenanceTaskDo.getPlanyear() + "-" + maintenanceTaskDo.getMonth(),
|
|
maintenanceTaskDo.getWorkshop(), maintenanceTaskDo.getEquipmentname(), maintenanceTaskDo.getEquipmentnumber(),
|
|
maintenanceTaskDo.getWorkshop(), maintenanceTaskDo.getEquipmentname(), maintenanceTaskDo.getEquipmentnumber(),
|
|
maintenanceTaskDo.getMaintenancesite(), maintenanceTaskDo.getPrincipal(), maintenanceTaskDo.getOtherengineers());
|
|
maintenanceTaskDo.getMaintenancesite(), maintenanceTaskDo.getPrincipal(), maintenanceTaskDo.getOtherengineers());
|
|
|
|
+ //删除提醒
|
|
|
|
+ CXCommonUtils.deleteSendNotify("maintain",id);
|
|
|
|
|
|
- JSONArray data = JSONUtil.parseArray(commonFeginClient.list(new HashMap<String, Object>() {{
|
|
|
|
- this.put("NOTIFYTYPE", "maintain");
|
|
|
|
- this.put("ROPTION", id);
|
|
|
|
- }}).getData());
|
|
|
|
-
|
|
|
|
- if (!data.isEmpty()) {
|
|
|
|
- List<String> ids = data.stream().map(info -> JSONUtil.parseObj(info).get("id").toString()).collect(Collectors.toList());
|
|
|
|
- commonFeginClient.delete(ids);
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
|
|
+ //发送提醒
|
|
CXCommonUtils.sendNotify(title, context, null, userId.stream().distinct().collect(Collectors.toList()),
|
|
CXCommonUtils.sendNotify(title, context, null, userId.stream().distinct().collect(Collectors.toList()),
|
|
maintenanceTaskDo.getId(), MAINTAIN, false);
|
|
maintenanceTaskDo.getId(), MAINTAIN, false);
|
|
return R.ok();
|
|
return R.ok();
|
|
@@ -125,25 +119,17 @@ public class EquipmentSendNotifyServiceImpl implements EquipmentSendNotifyServic
|
|
log.info("id为{}的任务无提醒人", id);
|
|
log.info("id为{}的任务无提醒人", id);
|
|
return R.ok();
|
|
return R.ok();
|
|
}
|
|
}
|
|
|
|
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
// 发送内容
|
|
// 发送内容
|
|
- String title = ACCEPTANCE_SYSTEM_TITLE;
|
|
|
|
- // 发送标题
|
|
|
|
String context = String.format(ACCEPTANCE_SYSTEM_CONTENT, maintenanceTaskDo.getPlanyear() + "-" + maintenanceTaskDo.getMonth(),
|
|
String context = String.format(ACCEPTANCE_SYSTEM_CONTENT, maintenanceTaskDo.getPlanyear() + "-" + maintenanceTaskDo.getMonth(),
|
|
maintenanceTaskDo.getWorkshop(), maintenanceTaskDo.getEquipmentname(), maintenanceTaskDo.getEquipmentnumber(),
|
|
maintenanceTaskDo.getWorkshop(), maintenanceTaskDo.getEquipmentname(), maintenanceTaskDo.getEquipmentnumber(),
|
|
- maintenanceTaskDo.getMaintenancesite(), maintenanceTaskDo.getTaskendtime(), maintenanceTaskDo.getPrincipal(),
|
|
|
|
|
|
+ maintenanceTaskDo.getMaintenancesite(), simpleDateFormat.format(maintenanceTaskDo.getTaskendtime()), maintenanceTaskDo.getPrincipal(),
|
|
maintenanceTaskDo.getOtherengineers());
|
|
maintenanceTaskDo.getOtherengineers());
|
|
|
|
|
|
- JSONArray data = JSONUtil.parseArray(commonFeginClient.list(new HashMap<String, Object>() {{
|
|
|
|
- this.put("NOTIFYTYPE", "maintain");
|
|
|
|
- this.put("ROPTION", id);
|
|
|
|
- }}).getData());
|
|
|
|
|
|
+ //删除提醒
|
|
|
|
+ CXCommonUtils.deleteSendNotify("maintain",id);
|
|
|
|
|
|
- if (!data.isEmpty()) {
|
|
|
|
- List<String> ids = data.stream().map(info -> JSONUtil.parseObj(info).get("id").toString()).collect(Collectors.toList());
|
|
|
|
- commonFeginClient.delete(ids);
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- CXCommonUtils.sendNotify(title, context, null, userId.stream().distinct().collect(Collectors.toList()),
|
|
|
|
|
|
+ CXCommonUtils.sendNotify(ACCEPTANCE_SYSTEM_TITLE, context, null, userId.stream().distinct().collect(Collectors.toList()),
|
|
maintenanceTaskDo.getId(), ACCEPTMAINTAINTASK, false);
|
|
maintenanceTaskDo.getId(), ACCEPTMAINTAINTASK, false);
|
|
return R.ok();
|
|
return R.ok();
|
|
}
|
|
}
|