package com.java110.job.msgNotify;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.java110.core.client.OutRestTemplate;
|
import com.java110.core.factory.WechatFactory;
|
import com.java110.core.log.LoggerFactory;
|
import com.java110.dto.wechat.SmallWeChatDto;
|
import com.java110.intf.store.ISmallWeChatInnerServiceSMO;
|
import com.java110.utils.cache.CommonCache;
|
import com.java110.utils.cache.MappingCache;
|
import com.java110.utils.constant.MappingConstant;
|
import com.java110.utils.constant.WechatConstant;
|
import com.java110.utils.util.ListUtil;
|
import com.java110.utils.util.StringUtil;
|
import com.java110.vo.ResultVo;
|
import org.slf4j.Logger;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.http.HttpStatus;
|
import org.springframework.http.ResponseEntity;
|
import org.springframework.stereotype.Service;
|
import org.springframework.web.client.RestTemplate;
|
|
import java.util.List;
|
import java.util.Map;
|
|
@Service
|
public class WechatTemplateImpl implements IWechatTemplate {
|
|
public static final String industry_id1 = "30"; // 房地产物业
|
public static final String industry_id2 = "2"; // IT 科技 IT软件与服务
|
|
|
private static Logger logger = LoggerFactory.getLogger(WechatTemplateImpl.class);
|
|
/**
|
* 获取 行业
|
*/
|
public static final String GET_INDUSTRY = "https://api.weixin.qq.com/cgi-bin/template/get_industry?access_token=ACCESS_TOKEN";
|
|
|
/**
|
* 设置 行业
|
*/
|
public static final String SET_INDUSTRY = "https://api.weixin.qq.com/cgi-bin/template/api_set_industry?access_token=ACCESS_TOKEN";
|
|
|
/**
|
* 获取模板列表
|
*/
|
public static final String GET_ALL_PRIVATE_TEMPLATE = "https://api.weixin.qq.com/cgi-bin/template/get_all_private_template?access_token=ACCESS_TOKEN";
|
|
|
/**
|
* 添加模板
|
*/
|
public static final String ADD_TEMPLATE = "https://api.weixin.qq.com/cgi-bin/template/api_add_template?access_token=ACCESS_TOKEN";
|
|
|
public static final String WECHAT_TEMPLATE = "WECHAT_TEMPLATE_";
|
|
|
@Autowired
|
private ISmallWeChatInnerServiceSMO smallWeChatInnerServiceSMOImpl;
|
|
@Autowired
|
private RestTemplate outRestTemplate;
|
|
/**
|
* 设置行业为 物业
|
*
|
* @param communityId 小区ID
|
*/
|
private void setIndustry(String communityId) {
|
|
//todo 查询公众号设置的行业
|
String url = GET_INDUSTRY.replace("ACCESS_TOKEN", getAccessToken(communityId));
|
|
ResponseEntity<String> responseEntity = outRestTemplate.getForEntity(url, String.class);
|
|
logger.debug("查询行业返回参数：{}", responseEntity);
|
|
if (responseEntity.getStatusCode() != HttpStatus.OK) {
|
throw new IllegalArgumentException("获取公众号行业失败");
|
}
|
|
JSONObject paramOut = JSONObject.parseObject(responseEntity.getBody());
|
|
// String industryName = paramOut.getJSONObject("primary_industry").getString("second_class");
|
|
JSONObject primaryIndustry = paramOut.getJSONObject("primary_industry");
|
if (primaryIndustry != null && "物业".equals(primaryIndustry.getString("second_class"))) { //如果是物业 直接 返回 无需设置
|
return;
|
}
|
|
//todo 设置公众号设置的行业
|
url = SET_INDUSTRY.replace("ACCESS_TOKEN", getAccessToken(communityId));
|
|
JSONObject paramIn = new JSONObject();
|
paramIn.put("industry_id1", industry_id1);
|
paramIn.put("industry_id2", industry_id2);
|
|
responseEntity = outRestTemplate.postForEntity(url, paramIn.toJSONString(), String.class);
|
|
logger.debug("设置行业返回参数：{}", responseEntity);
|
|
if (responseEntity.getStatusCode() != HttpStatus.OK) {
|
throw new IllegalArgumentException("设置公众号行业失败");
|
}
|
|
}
|
|
/**
|
* 获取模板列表
|
*
|
* @param communityId
|
* @return
|
*/
|
private String getAllPrivateTemplate(String communityId) {
|
String url = GET_ALL_PRIVATE_TEMPLATE.replace("ACCESS_TOKEN", getAccessToken(communityId));
|
|
ResponseEntity<String> responseEntity = outRestTemplate.getForEntity(url, String.class);
|
|
logger.debug("查询行业返回参数：{}", responseEntity);
|
|
if (responseEntity.getStatusCode() != HttpStatus.OK) {
|
throw new IllegalArgumentException("获取模板列表失败");
|
}
|
|
String templateList = responseEntity.getBody();
|
CommonCache.setValue(WECHAT_TEMPLATE + communityId, templateList, CommonCache.TOKEN_EXPIRE_TIME);
|
return templateList;
|
}
|
|
/**
|
* 添加模板
|
*
|
* @param communityId
|
* @param templateIdShort
|
* @param keys
|
*/
|
private void addTemplate(String communityId, String templateIdShort, String[] keys) {
|
|
//todo 设置行业
|
setIndustry(communityId);
|
|
//todo 设置公众号设置的行业
|
String url = ADD_TEMPLATE.replace("ACCESS_TOKEN", getAccessToken(communityId));
|
|
JSONObject paramIn = new JSONObject();
|
paramIn.put("template_id_short", templateIdShort);
|
paramIn.put("keyword_name_list", keys);
|
|
ResponseEntity<String> responseEntity = outRestTemplate.postForEntity(url, paramIn.toJSONString(), String.class);
|
|
logger.debug("添加模板返回参数：{}", responseEntity);
|
|
if (responseEntity.getStatusCode() != HttpStatus.OK) {
|
throw new IllegalArgumentException("添加模板失败");
|
}
|
|
JSONObject paramOut = JSONObject.parseObject(responseEntity.getBody());
|
|
if (paramOut.getIntValue("errcode") != 0) {
|
throw new IllegalArgumentException(paramOut.getString("errmsg"));
|
}
|
|
}
|
|
private void deletePrivateTemplate(String communityId, String templateId) {
|
|
}
|
|
/**
|
* 获取模板ID
|
*
|
* @param communityId 小区ID
|
* @param templateIdShort 模板库中模板的编号
|
* @param title 模板标题
|
* @return
|
*/
|
@Override
|
public String getTemplateId(String communityId, String templateIdShort, String title, String[] keys) {
|
|
String templateList = CommonCache.getValue(WECHAT_TEMPLATE + communityId);
|
//todo 不存在 调用微信查询
|
if (StringUtil.isEmpty(templateList)) {
|
templateList = getAllPrivateTemplate(communityId);
|
}
|
|
//todo 如果还是空 则直接 添加
|
if (StringUtil.isEmpty(templateList)) {
|
addTemplate(communityId, templateIdShort, keys);
|
templateList = getAllPrivateTemplate(communityId);
|
}
|
|
//todo 循环校验
|
JSONObject templateListObj = JSONObject.parseObject(templateList);
|
if (templateListObj == null || !templateListObj.containsKey("template_list") || templateListObj.getJSONArray("template_list").size() < 1) {
|
addTemplate(communityId, templateIdShort, keys);
|
templateList = getAllPrivateTemplate(communityId);
|
templateListObj = JSONObject.parseObject(templateList);
|
}
|
|
//todo 寻找 templateId
|
JSONArray templateLists = templateListObj.getJSONArray("template_list");
|
JSONObject template = null;
|
for (int templateIndex = 0; templateIndex < templateLists.size(); templateIndex++) {
|
template = templateLists.getJSONObject(templateIndex);
|
if (title.equals(template.getString("title")) && templateHasKey(template.getString("content"), keys)) {
|
return template.getString("template_id");
|
}
|
}
|
|
//todo 说明没有寻找到
|
addTemplate(communityId, templateIdShort, keys);
|
templateList = getAllPrivateTemplate(communityId);
|
templateListObj = JSONObject.parseObject(templateList);
|
|
templateLists = templateListObj.getJSONArray("template_list");
|
for (int templateIndex = 0; templateIndex < templateLists.size(); templateIndex++) {
|
template = templateLists.getJSONObject(templateIndex);
|
if (title.equals(template.getString("title")) && templateHasKey(template.getString("content"), keys)) {
|
return template.getString("template_id");
|
}
|
}
|
|
|
return "-1";
|
}
|
|
/**
|
* 关键字是否都包含
|
* @param content
|
* @param keys
|
* @return
|
*/
|
private boolean templateHasKey(String content, String[] keys) {
|
for (String key : keys) {
|
if (!content.contains(key)) {
|
return false;
|
}
|
}
|
|
return true;
|
}
|
|
public String getAccessToken(String communityId) {
|
SmallWeChatDto smallWeChatDto = new SmallWeChatDto();
|
smallWeChatDto.setWeChatType(SmallWeChatDto.WECHAT_TYPE_PUBLIC);
|
smallWeChatDto.setObjType(SmallWeChatDto.OBJ_TYPE_COMMUNITY);
|
smallWeChatDto.setObjId(communityId);
|
List<SmallWeChatDto> smallWeChatDtos = smallWeChatInnerServiceSMOImpl.querySmallWeChats(smallWeChatDto);
|
|
if (ListUtil.isNull(smallWeChatDtos)) {
|
String appIdCache = MappingCache.getValue(WechatConstant.WECHAT_DOMAIN, "appId");
|
String appSecretCache = MappingCache.getValue(WechatConstant.WECHAT_DOMAIN, "appSecret");
|
String mchIdCache = MappingCache.getValue(WechatConstant.WECHAT_DOMAIN, "mchId");
|
String keyCache = MappingCache.getValue(MappingConstant.WECHAT_STORE_DOMAIN, "key");
|
smallWeChatDto = new SmallWeChatDto();
|
smallWeChatDto.setAppId(appIdCache);
|
smallWeChatDto.setAppSecret(appSecretCache);
|
smallWeChatDto.setMchId(mchIdCache);
|
smallWeChatDto.setPayPassword(keyCache);
|
} else {
|
smallWeChatDto = smallWeChatDtos.get(0);
|
}
|
|
String accessToken = WechatFactory.getAccessToken(smallWeChatDto.getAppId(), smallWeChatDto.getAppSecret());
|
|
return accessToken;
|
}
|
|
@Override
|
public String getAppId(String communityId) {
|
SmallWeChatDto smallWeChatDto = new SmallWeChatDto();
|
smallWeChatDto.setWeChatType(SmallWeChatDto.WECHAT_TYPE_PUBLIC);
|
smallWeChatDto.setObjType(SmallWeChatDto.OBJ_TYPE_COMMUNITY);
|
smallWeChatDto.setObjId(communityId);
|
List<SmallWeChatDto> smallWeChatDtos = smallWeChatInnerServiceSMOImpl.querySmallWeChats(smallWeChatDto);
|
|
if (ListUtil.isNull(smallWeChatDtos)) {
|
String appIdCache = MappingCache.getValue(WechatConstant.WECHAT_DOMAIN, "appId");
|
String appSecretCache = MappingCache.getValue(WechatConstant.WECHAT_DOMAIN, "appSecret");
|
String mchIdCache = MappingCache.getValue(WechatConstant.WECHAT_DOMAIN, "mchId");
|
String keyCache = MappingCache.getValue(MappingConstant.WECHAT_STORE_DOMAIN, "key");
|
smallWeChatDto = new SmallWeChatDto();
|
smallWeChatDto.setAppId(appIdCache);
|
smallWeChatDto.setAppSecret(appSecretCache);
|
smallWeChatDto.setMchId(mchIdCache);
|
smallWeChatDto.setPayPassword(keyCache);
|
} else {
|
smallWeChatDto = smallWeChatDtos.get(0);
|
}
|
return smallWeChatDto.getAppId();
|
}
|
}
|
