数据源预警邮件，企业微信通知

suishenbang-system/src/main/java/com/dgtly/system/mapper/OrderTucEarlyWarningMapper.java

@@ -80,4 +80,6 @@ public interface OrderTucEarlyWarningMapper
      * @date: 2024/2/4 14:57
      */
     public List<OrderTucEarlyWarning> selectTucGroupSales(@Param("startTime") String startTime,@Param("endTime") String endTime);
+
+    int deleteOrderTucEarlyWarning();
 }

suishenbang-system/src/main/resources/mapper/system/OrderTucEarlyWarningMapper.xml

@@ -115,9 +115,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 
     <select id="selectTucGroupSales" resultType="com.dgtly.system.domain.OrderTucEarlyWarning">
         SELECT
-            'TUC' AS org_code,
-            'TUC' AS org_name,
-            'TUC' AS sales_level,
+            'TUC' AS orgCode,
+            'TUC' AS orgName,
+            'TUC' AS salesLevel,
             sum(
                     CONVERT (
                                 now_year_act / 1000,
@@ -134,9 +134,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
                 AND  #{endTime}
           AND BUSINESS_UNIT NOT IN ( '其中-公装事业部', '其中-家装事业部' ) UNION ALL
         SELECT
-            BUSINESS_UNIT AS org_code,
-            BUSINESS_UNIT AS org_name,
-            BUSINESS_UNIT AS sales_level,
+            BUSINESS_UNIT AS orgCode,
+            BUSINESS_UNIT AS orgName,
+            BUSINESS_UNIT AS salesLevel,
             sum(
                     CONVERT (
                                 now_year_act / 1000,
@@ -154,9 +154,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         GROUP BY
             BUSINESS_UNIT UNION ALL
         SELECT
-            company_code AS org_code,
-            company_name AS org_name,
-            'company_level' AS sales_level,
+            company_code AS orgCode,
+            company_name AS orgName,
+            'company_level' AS salesLevel,
             sum(
                     CONVERT (
                                 now_year_act / 1000,
@@ -175,5 +175,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         GROUP BY
             company_code
     </select>
+
+    <delete id="deleteOrderTucEarlyWarning" parameterType="Long">
+        delete from order_tuc_early_warning
+    </delete>
     
 </mapper>

suishenbang-wxportal/suishenbang-wxportal-common/src/main/java/com/dgtly/wxportal/service/impl/WxSendMessageServiceImpl.java

@@ -232,6 +232,7 @@ public class WxSendMessageServiceImpl implements IWxSendMessageService
                     if (tucNetValue.compareTo(earlyNetValue) == -1) {
                         sendQw(tucNetValue,earlyNetValue,1,early.getOrgCode(),early.getOrgName());
                         sendMail(tucNetValue,earlyNetValue,1,early.getOrgCode(),early.getOrgName());
+                        tucEarlyWarningMapper.deleteOrderTucEarlyWarning();
                         break;
                     }
                     BigDecimal tucTarget = new BigDecimal(0);
@@ -247,9 +248,12 @@ public class WxSendMessageServiceImpl implements IWxSendMessageService
                     if (tucTarget.compareTo(earlyTarget) == -1) {
                         sendQw(tucTarget,earlyTarget,2,early.getOrgCode(),early.getOrgName());
                         sendMail(tucTarget,earlyTarget,2,early.getOrgCode(),early.getOrgName());
+                        tucEarlyWarningMapper.deleteOrderTucEarlyWarning();
                         break;
                     }
+                    early.setUpdateTime(DateUtils.getNowDate());
                     tucEarlyWarningMapper.updateOrderTucEarlyWarning(early);
+
                 }
             }else{
                 tucEarlyWarningMapper.batchInsert(tucSales);
@@ -274,7 +278,7 @@ public class WxSendMessageServiceImpl implements IWxSendMessageService
                 if(i == 0){
                     res = dictDatas.get(0).getDictValue();
                 }else{
-                    res = res+dictDatas.get(i).getDictValue();
+                    res = res+"|"+dictDatas.get(i).getDictValue();
                 }
             }
         }
@@ -284,12 +288,12 @@ public class WxSendMessageServiceImpl implements IWxSendMessageService
         String sendQwUser = getConfigValueUserAccount("sendQwEarlyWarning");
         if(sendQwUser !=null && !("").equals(sendQwUser) ){
             if(type == 1 ){
-                String messageDetail="原已复核："+oldValue+"本次已复核："+tucValue+"已复核累计减少，请排查是否有误，该组织名称："+orgName+"组织编码："+orgCode;
-                qyWxSendMessageUtil.sendMsgSelfToCustomer(sendQwUser,messageDetail, "10086");
+                String messageDetail="数据源业绩指标预警：原已复核："+oldValue+"  本次已复核："+tucValue+"  已复核累计减少，请排查是否有误，该组织名称："+orgName+"  组织编码："+orgCode;
+                qyWxSendMessageUtil.sendMsgSelfToCustomer(sendQwUser,messageDetail, "66");
             }
             if(type == 2){
-                String messageDetail="原预算目标："+oldValue+"本次预算目标："+tucValue+"预算目标累计减少，请排查是否有误，该组织名称："+orgName+"组织编码："+orgCode;
-                qyWxSendMessageUtil.sendMsgSelfToCustomer(sendQwUser,messageDetail, "10086");
+                String messageDetail="数据源业绩指标预警：原预算目标："+oldValue+"  本次预算目标："+tucValue+"   预算目标累计减少，请排查是否有误，该组织名称："+orgName+"  组织编码："+orgCode;
+                qyWxSendMessageUtil.sendMsgSelfToCustomer(sendQwUser,messageDetail, "66");
             }
         }