Merge branch 'early_warning2422' into uat

# Conflicts:
#	suishenbang-quartz/src/main/java/com/dgtly/quartz/task/RyTask.java

suishenbang-quartz/src/main/java/com/dgtly/quartz/task/RyTask.java

@@ -171,4 +171,18 @@ public class RyTask
   /*  public void  salesOrderBaseByCreditStatus(){
         HanaSalesOrderService.updateSalesOrderBaseNoCrditStatus();
     }*/
+    }
+
+    /**
+     * @description: 业绩进度指标预警邮件/企微消息通知
+     * @param:
+     * @return:
+     * @author: njs
+     * @date: 2024/2/4 9:21
+     */
+    public void sendMailAndWxEarlyTucMessage(){
+        wxSendMessageService.sendMailAndWxEarlyTucMessage();
+    }
+
+
 }

suishenbang-system/src/main/java/com/dgtly/system/domain/OrderTucEarlyWarning.java

@@ -0,0 +1,128 @@
+package com.dgtly.system.domain;
+
+import org.apache.commons.lang3.builder.ToStringBuilder;
+import org.apache.commons.lang3.builder.ToStringStyle;
+import com.dgtly.common.annotation.Excel;
+import com.dgtly.common.core.domain.BaseEntity;
+
+/**
+ * 预警业绩进度指标对象 order_tuc_early_warning
+ * 
+ * @author njs
+ * @date 2024-02-04
+ */
+public class OrderTucEarlyWarning extends BaseEntity
+{
+    private static final long serialVersionUID = 1L;
+
+    /** id */
+    private Long earlyId;
+
+    /** 是否删除 */
+    @Excel(name = "是否删除")
+    private Long isDelete;
+
+    /** 组织级别 */
+    @Excel(name = "组织级别")
+    private String salesLevel;
+
+    /** 组织机构 */
+    @Excel(name = "组织机构")
+    private String orgCode;
+
+    /** 组织名称 */
+    @Excel(name = "组织名称")
+    private String orgName;
+
+    /** 已复核 */
+    @Excel(name = "已复核")
+    private String orgNetValue;
+
+    /** 预算 */
+    @Excel(name = "预算")
+    private String orgTarget;
+
+
+
+    public void setEarlyId(Long earlyId) 
+    {
+        this.earlyId = earlyId;
+    }
+
+    public Long getEarlyId() 
+    {
+        return earlyId;
+    }
+    public void setIsDelete(Long isDelete) 
+    {
+        this.isDelete = isDelete;
+    }
+
+    public Long getIsDelete() 
+    {
+        return isDelete;
+    }
+    public void setSalesLevel(String salesLevel) 
+    {
+        this.salesLevel = salesLevel;
+    }
+
+    public String getSalesLevel() 
+    {
+        return salesLevel;
+    }
+    public void setOrgCode(String orgCode) 
+    {
+        this.orgCode = orgCode;
+    }
+
+    public String getOrgCode() 
+    {
+        return orgCode;
+    }
+    public void setOrgName(String orgName) 
+    {
+        this.orgName = orgName;
+    }
+
+    public String getOrgName() 
+    {
+        return orgName;
+    }
+    public void setOrgNetValue(String orgNetValue) 
+    {
+        this.orgNetValue = orgNetValue;
+    }
+
+    public String getOrgNetValue() 
+    {
+        return orgNetValue;
+    }
+    public void setOrgTarget(String orgTarget) 
+    {
+        this.orgTarget = orgTarget;
+    }
+
+    public String getOrgTarget() 
+    {
+        return orgTarget;
+    }
+
+
+    @Override
+    public String toString() {
+        return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE)
+            .append("earlyId", getEarlyId())
+            .append("createBy", getCreateBy())
+            .append("createTime", getCreateTime())
+            .append("updateBy", getUpdateBy())
+            .append("updateTime", getUpdateTime())
+            .append("isDelete", getIsDelete())
+            .append("salesLevel", getSalesLevel())
+            .append("orgCode", getOrgCode())
+            .append("orgName", getOrgName())
+            .append("orgNetValue", getOrgNetValue())
+            .append("orgTarget", getOrgTarget())
+            .toString();
+    }
+}

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

@@ -0,0 +1,85 @@
+package com.dgtly.system.mapper;
+
+import com.dgtly.system.domain.OrderTucEarlyWarning;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+/**
+ * 预警业绩进度指标Mapper接口
+ * 
+ * @author njs
+ * @date 2024-02-04
+ */
+public interface OrderTucEarlyWarningMapper 
+{
+    /**
+     * 查询预警业绩进度指标
+     * 
+     * @param earlyId 预警业绩进度指标ID
+     * @return 预警业绩进度指标
+     */
+    public OrderTucEarlyWarning selectOrderTucEarlyWarningById(Long earlyId);
+
+    /**
+     * 查询预警业绩进度指标列表
+     * 
+     * @param orderTucEarlyWarning 预警业绩进度指标
+     * @return 预警业绩进度指标集合
+     */
+    public List<OrderTucEarlyWarning> selectOrderTucEarlyWarningList(OrderTucEarlyWarning orderTucEarlyWarning);
+
+    /**
+     * 新增预警业绩进度指标
+     * 
+     * @param orderTucEarlyWarning 预警业绩进度指标
+     * @return 结果
+     */
+    public int insertOrderTucEarlyWarning(OrderTucEarlyWarning orderTucEarlyWarning);
+
+    public int batchInsert(@Param("list") List<OrderTucEarlyWarning> list);
+
+    /**
+     * 修改预警业绩进度指标
+     * 
+     * @param orderTucEarlyWarning 预警业绩进度指标
+     * @return 结果
+     */
+    public int updateOrderTucEarlyWarning(OrderTucEarlyWarning orderTucEarlyWarning);
+
+    /**
+     * 删除预警业绩进度指标
+     * 
+     * @param earlyId 预警业绩进度指标ID
+     * @return 结果
+     */
+    public int deleteOrderTucEarlyWarningById(Long earlyId);
+
+    /**
+     * 批量删除预警业绩进度指标
+     * 
+     * @param earlyIds 需要删除的数据ID
+     * @return 结果
+     */
+    public int deleteOrderTucEarlyWarningByIds(String[] earlyIds);
+
+    /**
+     * @description:
+     * @param:
+     * @return:
+     * @author: njs
+     * @date: 2024/2/4 9:48
+     */
+    public OrderTucEarlyWarning selectOrderTucEarlyWarning(@Param("orgCode") String orgCode);
+
+    /**
+     * @description: TUC业绩指标
+     * @param: [startTime, endTime]
+     * @return: java.util.List<com.dgtly.system.domain.OrderTucEarlyWarning>
+     * @author: njs     
+     * @date: 2024/2/4 14:57
+     */
+    public List<OrderTucEarlyWarning> selectTucGroupSales(@Param("startTime") String startTime,@Param("endTime") String endTime);
+
+    int deleteOrderTucEarlyWarning();
+}

suishenbang-system/src/main/java/com/dgtly/system/service/IOrderTucEarlyWarningService.java

@@ -0,0 +1,72 @@
+package com.dgtly.system.service;
+
+import com.dgtly.system.domain.OrderTucEarlyWarning;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+/**
+ * 预警业绩进度指标Service接口
+ * 
+ * @author njs
+ * @date 2024-02-04
+ */
+public interface IOrderTucEarlyWarningService 
+{
+    /**
+     * 查询预警业绩进度指标
+     * 
+     * @param earlyId 预警业绩进度指标ID
+     * @return 预警业绩进度指标
+     */
+    public OrderTucEarlyWarning selectOrderTucEarlyWarningById(Long earlyId);
+
+    /**
+     * 查询预警业绩进度指标列表
+     * 
+     * @param orderTucEarlyWarning 预警业绩进度指标
+     * @return 预警业绩进度指标集合
+     */
+    public List<OrderTucEarlyWarning> selectOrderTucEarlyWarningList(OrderTucEarlyWarning orderTucEarlyWarning);
+
+    /**
+     * 新增预警业绩进度指标
+     * 
+     * @param orderTucEarlyWarning 预警业绩进度指标
+     * @return 结果
+     */
+    public int insertOrderTucEarlyWarning(OrderTucEarlyWarning orderTucEarlyWarning);
+
+    /**
+     * 修改预警业绩进度指标
+     * 
+     * @param orderTucEarlyWarning 预警业绩进度指标
+     * @return 结果
+     */
+    public int updateOrderTucEarlyWarning(OrderTucEarlyWarning orderTucEarlyWarning);
+
+    /**
+     * 批量删除预警业绩进度指标
+     * 
+     * @param ids 需要删除的数据ID
+     * @return 结果
+     */
+    public int deleteOrderTucEarlyWarningByIds(String ids);
+
+    /**
+     * 删除预警业绩进度指标信息
+     * 
+     * @param earlyId 预警业绩进度指标ID
+     * @return 结果
+     */
+    public int deleteOrderTucEarlyWarningById(Long earlyId);
+    
+    /**
+     * @description: 根据组织编码查业绩指标
+     * @param: [orgCode]
+     * @return: com.dgtly.system.domain.OrderTucEarlyWarning
+     * @author: njs     
+     * @date: 2024/2/4 9:53
+     */
+    public OrderTucEarlyWarning selectOrderTucEarlyWarning(@Param("orgCode") String orgCode);
+}

suishenbang-system/src/main/java/com/dgtly/system/service/impl/OrderTucEarlyWarningServiceImpl.java

@@ -0,0 +1,110 @@
+package com.dgtly.system.service.impl;
+
+import java.util.List;
+import com.dgtly.common.utils.DateUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import com.dgtly.system.mapper.OrderTucEarlyWarningMapper;
+import com.dgtly.system.domain.OrderTucEarlyWarning;
+import com.dgtly.system.service.IOrderTucEarlyWarningService;
+import com.dgtly.common.core.text.Convert;
+
+/**
+ * 预警业绩进度指标Service业务层处理
+ * 
+ * @author njs
+ * @date 2024-02-04
+ */
+@Service
+public class OrderTucEarlyWarningServiceImpl implements IOrderTucEarlyWarningService 
+{
+    @Autowired
+    private OrderTucEarlyWarningMapper orderTucEarlyWarningMapper;
+
+    /**
+     * 查询预警业绩进度指标
+     * 
+     * @param earlyId 预警业绩进度指标ID
+     * @return 预警业绩进度指标
+     */
+    @Override
+    public OrderTucEarlyWarning selectOrderTucEarlyWarningById(Long earlyId)
+    {
+        return orderTucEarlyWarningMapper.selectOrderTucEarlyWarningById(earlyId);
+    }
+
+    /**
+     * 查询预警业绩进度指标列表
+     * 
+     * @param orderTucEarlyWarning 预警业绩进度指标
+     * @return 预警业绩进度指标
+     */
+    @Override
+    public List<OrderTucEarlyWarning> selectOrderTucEarlyWarningList(OrderTucEarlyWarning orderTucEarlyWarning)
+    {
+        return orderTucEarlyWarningMapper.selectOrderTucEarlyWarningList(orderTucEarlyWarning);
+    }
+
+    /**
+     * 新增预警业绩进度指标
+     * 
+     * @param orderTucEarlyWarning 预警业绩进度指标
+     * @return 结果
+     */
+    @Override
+    public int insertOrderTucEarlyWarning(OrderTucEarlyWarning orderTucEarlyWarning)
+    {
+        orderTucEarlyWarning.setCreateTime(DateUtils.getNowDate());
+        return orderTucEarlyWarningMapper.insertOrderTucEarlyWarning(orderTucEarlyWarning);
+    }
+
+    /**
+     * 修改预警业绩进度指标
+     * 
+     * @param orderTucEarlyWarning 预警业绩进度指标
+     * @return 结果
+     */
+    @Override
+    public int updateOrderTucEarlyWarning(OrderTucEarlyWarning orderTucEarlyWarning)
+    {
+        orderTucEarlyWarning.setUpdateTime(DateUtils.getNowDate());
+        return orderTucEarlyWarningMapper.updateOrderTucEarlyWarning(orderTucEarlyWarning);
+    }
+
+    /**
+     * 删除预警业绩进度指标对象
+     * 
+     * @param ids 需要删除的数据ID
+     * @return 结果
+     */
+    @Override
+    public int deleteOrderTucEarlyWarningByIds(String ids)
+    {
+        return orderTucEarlyWarningMapper.deleteOrderTucEarlyWarningByIds(Convert.toStrArray(ids));
+    }
+
+    /**
+     * 删除预警业绩进度指标信息
+     * 
+     * @param earlyId 预警业绩进度指标ID
+     * @return 结果
+     */
+    @Override
+    public int deleteOrderTucEarlyWarningById(Long earlyId)
+    {
+        return orderTucEarlyWarningMapper.deleteOrderTucEarlyWarningById(earlyId);
+    }
+
+    /**
+     * @param orgCode
+     * @description: 根据组织编码查业绩指标
+     * @param: [orgCode]
+     * @return: com.dgtly.system.domain.OrderTucEarlyWarning
+     * @author: njs
+     * @date: 2024/2/4 9:50
+     */
+    @Override
+    public OrderTucEarlyWarning selectOrderTucEarlyWarning(String orgCode) {
+        return orderTucEarlyWarningMapper.selectOrderTucEarlyWarning(orgCode);
+    }
+}

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

@@ -0,0 +1,183 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.dgtly.system.mapper.OrderTucEarlyWarningMapper">
+    
+    <resultMap type="com.dgtly.system.domain.OrderTucEarlyWarning" id="OrderTucEarlyWarningResult">
+        <result property="earlyId"    column="early_id"    />
+        <result property="createBy"    column="create_by"    />
+        <result property="createTime"    column="create_time"    />
+        <result property="updateBy"    column="update_by"    />
+        <result property="updateTime"    column="update_time"    />
+        <result property="isDelete"    column="is_delete"    />
+        <result property="salesLevel"    column="sales_level"    />
+        <result property="orgCode"    column="org_code"    />
+        <result property="orgName"    column="org_name"    />
+        <result property="orgNetValue"    column="org_net_value"    />
+        <result property="orgTarget"    column="org_target"    />
+    </resultMap>
+
+    <sql id="selectOrderTucEarlyWarningVo">
+        select early_id, create_by, create_time, update_by, update_time, is_delete, sales_level, org_code, org_name, org_net_value, org_target from order_tuc_early_warning
+    </sql>
+
+    <select id="selectOrderTucEarlyWarningList" parameterType="OrderTucEarlyWarning" resultMap="OrderTucEarlyWarningResult">
+        <include refid="selectOrderTucEarlyWarningVo"/>
+        <where>  
+            <if test="isDelete != null "> and is_delete = #{isDelete}</if>
+            <if test="salesLevel != null  and salesLevel != ''"> and sales_level = #{salesLevel}</if>
+            <if test="orgCode != null  and orgCode != ''"> and org_code = #{orgCode}</if>
+            <if test="orgName != null  and orgName != ''"> and org_name like concat('%', #{orgName}, '%')</if>
+            <if test="orgNetValue != null  and orgNetValue != ''"> and org_net_value = #{orgNetValue}</if>
+            <if test="orgTarget != null  and orgTarget != ''"> and org_target = #{orgTarget}</if>
+        </where>
+    </select>
+    
+    <select id="selectOrderTucEarlyWarningById" parameterType="Long" resultMap="OrderTucEarlyWarningResult">
+        <include refid="selectOrderTucEarlyWarningVo"/>
+        where early_id = #{earlyId}
+    </select>
+        
+    <insert id="insertOrderTucEarlyWarning" parameterType="OrderTucEarlyWarning" useGeneratedKeys="true" keyProperty="earlyId">
+        insert into order_tuc_early_warning
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="createBy != null  and createBy != ''">create_by,</if>
+            <if test="createTime != null ">create_time,</if>
+            <if test="updateBy != null  and updateBy != ''">update_by,</if>
+            <if test="updateTime != null ">update_time,</if>
+            <if test="isDelete != null ">is_delete,</if>
+            <if test="salesLevel != null  and salesLevel != ''">sales_level,</if>
+            <if test="orgCode != null  and orgCode != ''">org_code,</if>
+            <if test="orgName != null  and orgName != ''">org_name,</if>
+            <if test="orgNetValue != null  and orgNetValue != ''">org_net_value,</if>
+            <if test="orgTarget != null  and orgTarget != ''">org_target,</if>
+         </trim>
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="createBy != null  and createBy != ''">#{createBy},</if>
+            <if test="createTime != null ">#{createTime},</if>
+            <if test="updateBy != null  and updateBy != ''">#{updateBy},</if>
+            <if test="updateTime != null ">#{updateTime},</if>
+            <if test="isDelete != null ">#{isDelete},</if>
+            <if test="salesLevel != null  and salesLevel != ''">#{salesLevel},</if>
+            <if test="orgCode != null  and orgCode != ''">#{orgCode},</if>
+            <if test="orgName != null  and orgName != ''">#{orgName},</if>
+            <if test="orgNetValue != null  and orgNetValue != ''">#{orgNetValue},</if>
+            <if test="orgTarget != null  and orgTarget != ''">#{orgTarget},</if>
+         </trim>
+    </insert>
+
+    <insert id="batchInsert" parameterType="java.util.List">
+        insert into order_tuc_early_warning (create_time, update_time,sales_level,org_code,org_name,org_net_value,org_target) values
+        <foreach collection="list" item="model" index="index" separator=",">
+            (#{model.createTime}, #{model.updateTime},#{model.salesLevel},#{model.orgCode},#{model.orgName},#{model.orgNetValue},#{model.orgTarget})
+        </foreach>
+    </insert>
+
+
+
+    <update id="updateOrderTucEarlyWarning" parameterType="OrderTucEarlyWarning">
+        update order_tuc_early_warning
+        <trim prefix="SET" suffixOverrides=",">
+            <if test="createBy != null  and createBy != ''">create_by = #{createBy},</if>
+            <if test="createTime != null ">create_time = #{createTime},</if>
+            <if test="updateBy != null  and updateBy != ''">update_by = #{updateBy},</if>
+            <if test="updateTime != null ">update_time = #{updateTime},</if>
+            <if test="isDelete != null ">is_delete = #{isDelete},</if>
+            <if test="salesLevel != null  and salesLevel != ''">sales_level = #{salesLevel},</if>
+            <if test="orgCode != null  and orgCode != ''">org_code = #{orgCode},</if>
+            <if test="orgName != null  and orgName != ''">org_name = #{orgName},</if>
+            <if test="orgNetValue != null  and orgNetValue != ''">org_net_value = #{orgNetValue},</if>
+            <if test="orgTarget != null  and orgTarget != ''">org_target = #{orgTarget},</if>
+
+        </trim>
+        where org_code = #{orgCode}
+    </update>
+
+    <delete id="deleteOrderTucEarlyWarningById" parameterType="Long">
+        delete from order_tuc_early_warning where early_id = #{earlyId}
+    </delete>
+
+    <delete id="deleteOrderTucEarlyWarningByIds" parameterType="String">
+        delete from order_tuc_early_warning where early_id in 
+        <foreach item="earlyId" collection="array" open="(" separator="," close=")">
+            #{earlyId}
+        </foreach>
+    </delete>
+
+    <select id="selectOrderTucEarlyWarning"  resultMap="OrderTucEarlyWarningResult">
+        <include refid="selectOrderTucEarlyWarningVo"/>
+        <where>
+            <if test="orgCode != null  and orgCode != ''"> and org_code = #{orgCode}</if>
+        </where>
+        limit 1
+    </select>
+
+    <select id="selectTucGroupSales" resultType="com.dgtly.system.domain.OrderTucEarlyWarning">
+        SELECT
+            'TUC' AS orgCode,
+            'TUC' AS orgName,
+            'TUC' AS salesLevel,
+            sum(
+                    CONVERT (
+                                now_year_act / 1000,
+                                DECIMAL ( 18, 3 ))) AS orgNetValue,
+            sum(
+                    CONVERT (
+                                NONTAX_DISCOUNT_TARGET / 1000,
+                                DECIMAL ( 18, 3 ))) AS orgTarget
+
+        FROM
+            `order_sales_sum_tuc_group`
+        WHERE
+            cal_month BETWEEN #{startTime}
+                AND  #{endTime}
+          AND BUSINESS_UNIT NOT IN ( '其中-公装事业部', '其中-家装事业部' ) UNION ALL
+        SELECT
+            BUSINESS_UNIT AS orgCode,
+            BUSINESS_UNIT AS orgName,
+            BUSINESS_UNIT AS salesLevel,
+            sum(
+                    CONVERT (
+                                now_year_act / 1000,
+                                DECIMAL ( 18, 3 ))) AS orgNetValue,
+            sum(
+                    CONVERT (
+                                NONTAX_DISCOUNT_TARGET / 1000,
+                                DECIMAL ( 18, 3 ))) AS orgTarget
+
+        FROM
+            `order_sales_sum_tuc_group`
+        WHERE
+            cal_month BETWEEN #{startTime}
+                AND  #{endTime}
+        GROUP BY
+            BUSINESS_UNIT UNION ALL
+        SELECT
+            company_code AS orgCode,
+            company_name AS orgName,
+            'company_level' AS salesLevel,
+            sum(
+                    CONVERT (
+                                now_year_act / 1000,
+                                DECIMAL ( 18, 3 ))) AS orgNetValue,
+            sum(
+                    CONVERT (
+                                NONTAX_DISCOUNT_TARGET / 1000,
+                                DECIMAL ( 18, 3 ))) AS orgTarget
+
+        FROM
+            `order_sales_sum_tuc_group`
+        WHERE
+            cal_month BETWEEN #{startTime}
+                AND  #{endTime}
+          AND BUSINESS_UNIT = '零售'
+        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/IWxSendMessageService.java

@@ -67,4 +67,13 @@ public interface IWxSendMessageService
      * @date: 2023/5/15 11:27
      */
      void sendWxTmsMessage();
+
+     /**
+      * @description: 业绩进度指标预警邮件/企微消息通知
+      * @param:
+      * @return:
+      * @author: njs
+      * @date: 2024/2/4 9:21
+      */
+     void sendMailAndWxEarlyTucMessage();
 }

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

@@ -1,21 +1,38 @@
 package com.dgtly.wxportal.service.impl;
 
+import java.math.BigDecimal;
 import java.util.*;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
 import com.dgtly.common.utils.DateUtils;
+import com.dgtly.system.domain.Mail;
+import com.dgtly.system.domain.OrderTucEarlyWarning;
+import com.dgtly.system.domain.SysDictData;
+import com.dgtly.system.domain.UserVO;
+import com.dgtly.system.mapper.OrderTucEarlyWarningMapper;
 import com.dgtly.system.mapper.SysBatchSignForMapper;
 import com.dgtly.system.mapper.SysUserMapper;
+import com.dgtly.system.service.IOrderTucEarlyWarningService;
 import com.dgtly.system.service.ISysConfigService;
+import com.dgtly.system.service.ISysDictDataService;
+import com.dgtly.system.util.MailUtils;
 import com.dgtly.wxportal.utils.qywxutils.QyWxSendMessageUtil;
+import org.apache.commons.lang.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import com.dgtly.wxportal.mapper.WxSendMessageMapper;
 import com.dgtly.wxportal.domain.WxSendMessage;
 import com.dgtly.wxportal.service.IWxSendMessageService;
 import com.dgtly.common.core.text.Convert;
 
+import javax.mail.MessagingException;
+import javax.mail.NoSuchProviderException;
+import javax.mail.Session;
+import javax.mail.Transport;
+import javax.mail.internet.MimeMessage;
+
 /**
  * 企业微信发送消息历史记录Service业务层处理
  * 
@@ -35,6 +52,18 @@ public class WxSendMessageServiceImpl implements IWxSendMessageService
     private ISysConfigService configService;
     @Autowired
     private SysBatchSignForMapper batchSignForMapper;
+    @Autowired
+    private ISysDictDataService sysDictDataService;
+    @Autowired
+    private OrderTucEarlyWarningMapper tucEarlyWarningMapper;
+    @Autowired
+    private MailUtils mailUtils;
+    @Value(value = "${spring.mail.username}")
+    private String myEmailAccount;
+    @Value(value = "${spring.mail.password}")
+    public  String myEmailPassword;
+    @Value(value = "${spring.mail.host}")
+    public  String myEmailSMTPHost;
     /**
      * 查询企业微信发送消息历史记录
      * 
@@ -161,4 +190,207 @@ public class WxSendMessageServiceImpl implements IWxSendMessageService
         }
 
     }
+
+    /**
+     * @description: 业绩进度指标预警邮件/企微消息通知
+     * @param:
+     * @return:
+     * @author: njs
+     * @date: 2024/2/4 9:21
+     */
+    @Override
+    public void sendMailAndWxEarlyTucMessage() {
+        int year = Calendar.getInstance().get(Calendar.YEAR);
+        int month = Calendar.getInstance().get(Calendar.MONTH) + 1;
+        String MonthStr = "";
+        if(month < 10){
+            MonthStr = "0"+month;
+        } else {
+            MonthStr = String.valueOf(month);
+        }
+        String startTime = String.valueOf(year)+"01";
+        String endTime =  String.valueOf(year)+ MonthStr;
+        List<OrderTucEarlyWarning> tucSales = tucEarlyWarningMapper.selectTucGroupSales(startTime,endTime);
+        if(tucSales !=null && tucSales.size()>0){
+            OrderTucEarlyWarning warning = new OrderTucEarlyWarning();
+            List<OrderTucEarlyWarning> earlyWarnings = tucEarlyWarningMapper.selectOrderTucEarlyWarningList(warning);
+            if(earlyWarnings !=null && earlyWarnings.size()>0) {
+                //比较指标是否有误
+                for (OrderTucEarlyWarning early : tucSales
+                ) {
+                    OrderTucEarlyWarning earlyWarning = tucEarlyWarningMapper.selectOrderTucEarlyWarning(early.getOrgCode());
+                    BigDecimal tucNetValue = new BigDecimal(0);
+                    if (StringUtils.isNotBlank(early.getOrgNetValue())) {
+                        tucNetValue = new BigDecimal(early.getOrgNetValue());
+                        tucNetValue = tucNetValue.setScale(0, BigDecimal.ROUND_HALF_UP);
+                    }
+                    BigDecimal earlyNetValue = new BigDecimal(0);
+                    if (StringUtils.isNotBlank(earlyWarning.getOrgNetValue())) {
+                        earlyNetValue = new BigDecimal(earlyWarning.getOrgNetValue());
+                        earlyNetValue = earlyNetValue.setScale(0, BigDecimal.ROUND_HALF_UP);
+                    }
+                    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);
+                    if (StringUtils.isNotBlank(early.getOrgTarget())) {
+                        tucTarget = new BigDecimal(early.getOrgTarget());
+                        tucTarget = tucTarget.setScale(0, BigDecimal.ROUND_HALF_UP);
+                    }
+                    BigDecimal earlyTarget = new BigDecimal(0);
+                    if (StringUtils.isNotBlank(earlyWarning.getOrgTarget())) {
+                        earlyTarget = new BigDecimal(earlyWarning.getOrgTarget());
+                        earlyTarget = earlyTarget.setScale(0, BigDecimal.ROUND_HALF_UP);
+                    }
+                    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);
+            }
+        }
+    }
+
+    public Set<String> getConfigValueSet(String dictType){
+        Set<String> res = new HashSet<>();
+        List<SysDictData> dictDatas = sysDictDataService.selectSimpleDictDataByType(dictType);
+        for(SysDictData d: dictDatas){
+            res.add(d.getDictValue());
+        }
+        return res;
+    }
+
+    public String getConfigValueUserAccount(String dictType){
+        String res = "";
+        List<SysDictData> dictDatas = sysDictDataService.selectSimpleDictDataByType(dictType);
+        if(dictDatas !=null && dictDatas.size()>0){
+            for(int i=0;i<dictDatas.size();i++){
+                if(i == 0){
+                    res = dictDatas.get(0).getDictValue();
+                }else{
+                    res = res+"|"+dictDatas.get(i).getDictValue();
+                }
+            }
+        }
+        return res;
+    }
+    void sendQw(BigDecimal tucValue,BigDecimal oldValue,int type,String orgCode,String orgName){
+        String sendQwUser = getConfigValueUserAccount("sendQwEarlyWarning");
+        if(sendQwUser !=null && !("").equals(sendQwUser) ){
+            if(type == 1 ){
+                String messageDetail="数据源业绩指标预警：原已复核："+oldValue+"  本次已复核："+tucValue+"  已复核累计减少，请排查是否有误，该组织名称："+orgName+"  组织编码："+orgCode;
+                qyWxSendMessageUtil.sendMsgSelfToCustomer(sendQwUser,messageDetail, "66");
+            }
+            if(type == 2){
+                String messageDetail="数据源业绩指标预警：原预算目标："+oldValue+"  本次预算目标："+tucValue+"   预算目标累计减少，请排查是否有误，该组织名称："+orgName+"  组织编码："+orgCode;
+                qyWxSendMessageUtil.sendMsgSelfToCustomer(sendQwUser,messageDetail, "66");
+            }
+        }
+
+    }
+    void sendMail(BigDecimal tucValue,BigDecimal oldValue,int type,String orgCode,String orgName){
+        // 1. 创建参数配置, 用于连接邮件服务器的参数配置
+        Properties props = new Properties();                    // 参数配置
+        props.setProperty("mail.transport.protocol", "smtp");   // 使用的协议（JavaMail规范要求）
+        props.setProperty("mail.smtp.host", myEmailSMTPHost);   // 发件人的邮箱的 SMTP 服务器地址
+        props.setProperty("mail.smtp.port", "25");
+        props.setProperty("mail.smtp.auth", "true");            // 需要请求认证
+        props.setProperty("mail.smtp.starttls.enable", "false");            // 需要请求认证
+        props.setProperty("mail.smtp.ssl.enable", "false");            // 需要请求认证
+        Set<String> sendEmailUser = getConfigValueSet("sendMailEarlyWarning");
+        Session session = Session.getDefaultInstance(props);
+        session.setDebug(true);
+
+        for (String email : sendEmailUser
+        ) {
+            Mail mail = new Mail();
+            try {
+                mail.setFrom(myEmailAccount);
+                mail.setTo(email);
+                mail.setSubject("立邦随身邦业绩进度数据源预警");
+                mail.setContent(getHtmlUserContextList(tucValue,oldValue,type,orgCode,orgName));
+                //mailUtils.sendMailHtml(mailFromUsername, email, "用户账号重复通知", "您好，重复用户信息如下<br>" + userList);
+                MimeMessage message = mailUtils.createMimeMessage(session, myEmailAccount, email, mail);
+
+                // 4. 根据 Session 获取邮件传输对象
+                Transport transport = session.getTransport();
+
+                transport.connect(myEmailAccount, myEmailPassword);
+
+                // 6. 发送邮件, 发到所有的收件地址, message.getAllRecipients() 获取到的是在创建邮件对象时添加的所有收件人, 抄送人, 密送人
+                transport.sendMessage(message, message.getAllRecipients());
+
+                // 7. 关闭连接
+                transport.close();
+            } catch (NoSuchProviderException e) {
+                e.printStackTrace();
+            } catch (MessagingException e) {
+                e.printStackTrace();
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }
+
+}
+
+    public String getHtmlUserContextList(BigDecimal tucValue,BigDecimal oldValue,int type,String orgCode,String orgName) {
+
+        String str = "";
+        String html ="";
+        if(type == 1){
+            str += "<tr>" +
+                    "   <td>" + tucValue
+                    + "   </td><td>" + oldValue
+                    + "   </td><td>" + orgCode
+                    + "   </td><td>" + orgName
+                    + "   </td><td>" + "已复核累计减少，请排查是否有误"
+                    + "   </td>" +
+                    "</tr>";
+             html = "<table border='1'  Cellspacing='0'>" +
+                    "    <tr>" +
+                    "        <th>本次已复核</th>" +
+                    "        <th>上次已复核</th>" +
+                     "       <th>组织编码</th>" +
+                     "       <th>组织名称</th>" +
+                    "        <th>检测结果</th>" +
+                    "    </tr>" +
+                    str +
+                    "</table>";
+
+        }
+
+        if(type == 2){
+            str += "<tr>" +
+                    "   <td>" + tucValue
+                    + "   </td><td>" + oldValue
+                    + "   </td><td>" + orgCode
+                    + "   </td><td>" + orgName
+                    + "   </td><td>" + "预算目标累计减少，请排查是否有误"
+                    + "   </td>" +
+                    "</tr>";
+            html = "<table border='1'  Cellspacing='0'>" +
+                    "    <tr>" +
+                    "        <th>本次预算目标</th>" +
+                    "        <th>上次预算目标</th>" +
+                    "       <th>组织编码</th>" +
+                    "       <th>组织名称</th>" +
+                    "        <th>检测结果</th>" +
+                    "    </tr>" +
+                    str +
+                    "</table>";
+
+        }
+
+        return html;
+    }
 }