meidu2021/daju/target/classes/cn/com/lzt/message/send/util/MessageSendUtil.java

package cn.com.lzt.message.send.util;

import cn.com.lzt.message.send.entity.MMessageEntity;
import cn.com.lzt.message.send.entity.MMessageSendLogEntity;
import cn.com.lzt.message.send.entity.MessageSendCallBack;
import cn.com.lzt.message.send.entity.MessageWxTemplateConfig;
import cn.com.lzt.message.send.service.MMessageSendServiceI;
import cn.com.lzt.message.send.service.impl.MMessageSendServiceImpl;
import cn.com.lzt.warehouse.entity.WarehouseEntity;
import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.IAcsClient;
import com.aliyuncs.dysmsapi.model.v20170525.SendSmsRequest;
import com.aliyuncs.dysmsapi.model.v20170525.SendSmsResponse;
import com.aliyuncs.exceptions.ClientException;
import com.aliyuncs.http.MethodType;
import com.aliyuncs.profile.DefaultProfile;
import com.aliyuncs.profile.IClientProfile;
import com.xcgl.utils.XcglConstant;
import com.xcgl.weixin.service.WXServiceI;
import com.xcgl.weixin.service.WXServiceImpl;
import net.sf.json.JSONObject;
import org.apache.commons.lang3.StringUtils;
import org.apache.http.HttpResponse;
import org.apache.http.HttpStatus;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.log4j.Logger;
import org.jeecgframework.core.constant.Globals;
import org.jeecgframework.core.util.ApplicationContextUtil;
import org.jeecgframework.core.util.DateUtils;
import org.jeecgframework.core.util.ResourceUtil;
import org.jeecgframework.web.system.pojo.base.TSUser;
import org.jeecgframework.web.system.service.SystemService;

import java.nio.charset.Charset;
import java.util.*;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

public class MessageSendUtil
{

    private static final Logger logger = Logger.getLogger(MessageSendUtil.class);

    public static MMessageSendLogEntity sendSMS(String phone, String templateCode, Map<String,Object> params)  {
        MMessageSendLogEntity cb = new MMessageSendLogEntity();
        try {
            //设置超时时间-可自行调整
            System.setProperty("sun.net.client.defaultConnectTimeout", "10000");
            System.setProperty("sun.net.client.defaultReadTimeout", "10000");

            //初始化ascClient需要的几个参数
            final String product = "Dysmsapi";//短信API产品名称（短信产品名固定，无需修改）
            final String domain = "dysmsapi.aliyuncs.com";//短信API产品域名（接口地址固定，无需修改）
            //替换成你的AK
            final String accessKeyId = "LTAImsMOGNQTqWvX";//你的accessKeyId,参考本文档步骤2
            final String accessKeySecret = "zdf5cux8RzTl531tQQ1rIlESTBBiBe";//你的accessKeySecret，参考本文档步骤2
            //初始化ascClient,暂时不支持多region（请勿修改）
            IClientProfile profile = DefaultProfile.getProfile("cn-hangzhou", accessKeyId,
                    accessKeySecret);
            DefaultProfile.addEndpoint("cn-hangzhou", "cn-hangzhou", product, domain);
            IAcsClient acsClient = new DefaultAcsClient(profile);
            //组装请求对象
            SendSmsRequest request = new SendSmsRequest();
            //使用post提交
            request.setMethod(MethodType.POST);
            //必填:待发送手机号。支持以逗号分隔的形式进行批量调用，批量上限为1000个手机号码,批量调用相对于单条调用及时性稍有延迟,验证码类型的短信推荐使用单条调用的方式；发送国际/港澳台消息时，接收号码格式为00+国际区号+号码，如“0085200000000”
            if(!ResourceUtil.getConfigByName(Globals.SERVER_TYPE).equals(Globals.SERVER_TYPE_LINE)){
                phone = ResourceUtil.getConfigByName(Globals.SERVER_TEST_MOBILE);
            }
            request.setPhoneNumbers(phone);
            //必填:短信签名-可在短信控制台中找到
            request.setSignName("美都环卫物业");
            //必填:短信模板-可在短信控制台中找到，发送国际/港澳台消息时，请使用国际/港澳台短信模版
            request.setTemplateCode(templateCode);//SMS_144450234
            //可选:模板中的变量替换JSON串,如模板内容为"亲爱的${name},您的验证码为${code}"时,此处的值为
            //友情提示:如果JSON中需要带换行符,请参照标准的JSON协议对换行符的要求,比如短信内容中包含\r\n的情况在JSON中需要表示成\\r\\n,否则会导致JSON在服务端解析失败
            JSONObject obj = JSONObject.fromObject(params);
            request.setTemplateParam(obj.toString());
            //可选-上行短信扩展码(扩展码字段控制在7位或以下，无特殊需求用户请忽略此字段)
            //request.setSmsUpExtendCode("90997");
            //可选:outId为提供给业务方扩展字段,最终在短信回执消息中将此值带回给调用者
//		 request.setOutId("yourOutId");
            //请求失败这里会抛ClientException异常
            SendSmsResponse sendSmsResponse = acsClient.getAcsResponse(request);
            cb.setCallback(sendSmsResponse.getMessage());
            if(sendSmsResponse.getCode() != null && sendSmsResponse.getCode().equals("OK")) {
                cb.setStatus(1);
            }else {
                cb.setStatus(0);
            }
        }catch (Exception e){
            cb.setStatus(0);
            cb.setCallback(e.getMessage());
        }

//        return false;
        cb.setSendWay(MMessageEntity.MessageSendWay.short_message);
        cb.setCreateTime(new Date());
        return cb;
    }

    public static boolean sendMsgToWX(String templateID,String userId,String openId,
                                      String url,Map<String, Object> userMsgParms) {
        return sendMsgToWX(templateID, userId, openId, url, userMsgParms, true);
    }

    /**
     * 注：此方法立即发送不会通过mq，不会产生发送日志及已读状态
     * @param checkTestMode 是否检测测试服模式 有些功能需要直接发给执行人执行任务
     * @see MMessageSendServiceI#sendMessage
     * @return
     */

    public static boolean sendMsgToWX(String templateID,String userId,String openId,
                                      String url,Map<String, Object> userMsgParms, boolean checkTestMode)  {
        List<Map<String,Object>> listParams = new ArrayList<Map<String,Object>>();

        Map<String, Object> oneMsg = new HashMap<String, Object>();
        oneMsg.put("openid", openId);
        oneMsg.put("userid", userId);
        if(StringUtils.isNotBlank(url)) {
            oneMsg.put("url", url);
        }
        oneMsg.put("tplParams", userMsgParms);
        listParams.add(oneMsg);
        return sendMsgToWX(listParams,templateID, checkTestMode);
    }

    public static boolean sendMsgToWX(List<Map<String,Object>> listParams,String templateID) {
        return sendMsgToWX(listParams, templateID, true);
    }

    /**
     *
     * @param listParams
     * @param templateID
     * @return
     */
    public static boolean sendMsgToWX(List<Map<String,Object>> listParams,String templateID, boolean checkTestMode) {
        logger.info("sendMsgToWX templateID=" + templateID);
        Map<String,Object> reqParams = new HashMap<String,Object>();
        reqParams.put("templateId", templateID);
        reqParams.put("list", listParams);
        if(checkTestMode && !ResourceUtil.getConfigByName(Globals.SERVER_TYPE).equals(Globals.SERVER_TYPE_LINE)){
            String openId = ResourceUtil.getConfigByName(Globals.SERVER_TEST_OPENID);
            for(Map<String,Object> oneMsg :listParams){
                oneMsg.put("openid", openId);
            }
        }
        org.apache.http.client.HttpClient client = new DefaultHttpClient();
        try {
            String wxurl = "http://www.shenqin.work/api/wx/sendTplMsg";
            HttpPost httpPost = new HttpPost(wxurl);
            httpPost.addHeader("Content-type","application/json; charset=utf-8");
            httpPost.setEntity(new StringEntity(com.alibaba.fastjson.JSONObject.toJSONString(reqParams), Charset.forName("UTF-8")));
            HttpResponse response = client.execute(httpPost);
            // 检验返回码
            int statusCode = response.getStatusLine().getStatusCode();
            if (statusCode != HttpStatus.SC_OK) {
                logger.error("发送微信msg错误：" + statusCode);
                return true;
            }
        }catch (Exception e) {
            logger.error("发送微信msg错误：" + e.getMessage());
            return  false;
        }
        return false;
    }

    public static void main(String[] ars){

    }
}