From 746f963f3c12f9b4c7c41bc6b61b1631170096b3 Mon Sep 17 00:00:00 2001
From: A0010407 <KHD@202305>
Date: Wed, 17 Jul 2024 11:28:09 +0800
Subject: [PATCH] =?UTF-8?q?2024-07-17=20=E8=AE=BE=E5=A4=87-=E6=89=8B?=
 =?UTF-8?q?=E6=8C=81-=E7=82=B9=E6=A3=80=E5=B7=A1=E6=A3=80=E4=BF=9D?=
 =?UTF-8?q?=E5=85=BB=E6=8F=90=E4=BA=A4=E5=90=8E=E5=BE=AE=E4=BF=A1=E6=8F=90?=
 =?UTF-8?q?=E9=86=92?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/DevicePDAServiceImpl.java    | 72 +++++++++++++++++++
 1 file changed, 72 insertions(+)

diff --git a/op-modules/op-device/src/main/java/com/op/device/service/impl/DevicePDAServiceImpl.java b/op-modules/op-device/src/main/java/com/op/device/service/impl/DevicePDAServiceImpl.java
index 5ca46a7c..8c0dcd63 100644
--- a/op-modules/op-device/src/main/java/com/op/device/service/impl/DevicePDAServiceImpl.java
+++ b/op-modules/op-device/src/main/java/com/op/device/service/impl/DevicePDAServiceImpl.java
@@ -396,6 +396,78 @@ public class DevicePDAServiceImpl implements IDevicePDAService {
             String key = "#header.poolName";
             equRepairOrder.setFactoryCode(request.getHeader(key.substring(8)).replace("ds_", ""));
             equRepairOrderMapper.insertEquRepairOrder(equRepairOrder);
+
+            //微信提醒
+            //PDA企业微信报修审核提醒
+            //发企业微信--------------------开始（跟班组有关）
+            SimpleDateFormat myFmt=new SimpleDateFormat("yyyy年MM月dd日 HH时mm分ss秒");                          //规范时间格式
+            SysNoticeGroup noticeQo = new SysNoticeGroup();
+            noticeQo.setNoticeId(10L);
+            List<SysNoticeGroup> notices = equRepairOrderMapper.getNoticesGroup(noticeQo);
+            if(!CollectionUtils.isEmpty(notices)) {
+                List<WechartDTO> wecharts = new ArrayList<>();
+                List<String> userCodes = notices.stream()
+                        .map(SysNoticeGroup::getUserCode)
+                        .collect(Collectors.toList());
+                for (SysNoticeGroup noticeDto : notices) {
+                    WechartDTO wechart0 = new WechartDTO();
+                    wechart0.setUserId(noticeDto.getWxId());
+                    String contentInfo = noticeDto.getNoticeContent();
+                    //在前端填的时候，需要判空！！！！！！
+                    contentInfo = contentInfo
+                            .replace("${message}", "\n")
+                            .replace("${equipmentCode}", equOrder.getEquipmentCode()+"\n")
+                            .replace("${orderCode}", equOrder.getOrderCode()+"\n")
+                            .replace("${orderDesc}", equRepairOrder.getOrderSource() + "存在不达标检查项"+"\n")
+                    ;
+                    //故障开始时间
+                    if(equOrder.getOrderStart() != null){
+                        contentInfo = contentInfo.replace("${orderBreakdownTime}", myFmt.format(equOrder.getOrderStart())+"\n");
+                    }else{
+                        contentInfo = contentInfo.replace("${orderBreakdownTime}", "无"+"\n");
+                    }
+
+                    //报修人equOrder
+                    if(equOrder.getPlanPersonName() != null){
+                        contentInfo = contentInfo.replace("${orderRepairmanName}", equOrder.getPlanPersonName()+"\n");
+                    }else{
+                        contentInfo = contentInfo.replace("${orderRepairmanName}", "无"+"\n");
+                    }
+
+                    //查询设备相关信息
+                    //设备名称
+                    EquEquipment equ = equEquipmentMapper.selectEquEquipmentByEquEquipmentCode(equOrder.getEquipmentCode());
+                    if(StringUtils.isNotEmpty(equ.getEquipmentName())){
+                        contentInfo = contentInfo.replace("${equipmentName}", equ.getEquipmentName()+"\n");
+                    }else{
+                        contentInfo = contentInfo.replace("${equipmentName}", "无"+"\n");
+                    }
+                    //设备位置
+                    if(StringUtils.isNotEmpty(equ.getEquipmentLocation())){
+                        contentInfo = contentInfo.replace("${equipmentLocation}", equ.getEquipmentLocation()+"\n");
+                    }else{
+                        contentInfo = contentInfo.replace("${equipmentLocation}", "无"+"\n");
+                    }
+
+                    Pattern p= Pattern.compile("<[^>]+>");
+                    Matcher m = p.matcher(contentInfo);
+                    contentInfo = m.replaceAll("");
+                    System.out.println(contentInfo);
+
+                    wechart0.setText(contentInfo);
+                    wecharts.add(wechart0);
+                }
+                logger.info("PDA端"+ equRepairOrder.getOrderSource() + "报修企业微信提醒请求：" + JSONObject.toJSONString(wecharts));
+                if (!CollectionUtils.isEmpty(wecharts)) {
+
+                    new Thread(() -> {
+                        AjaxResult wxresult = remoteOpenService.sendWeChartMessage(wecharts);
+                        logger.info("PDA端报修企业微信提醒结果：" + JSONObject.toJSONString(wxresult));
+
+                    }).start();
+                }
+                //发企业微信--------------------结束
+            }
         }
 
         // 如果不存在未达标信息