package cn.ksource.web.service.wechat;
|
|
import cn.ksource.beans.GG_MESSAGE;
|
import cn.ksource.beans.GG_USER;
|
import cn.ksource.core.CascadeMap;
|
import cn.ksource.core.dao.BaseDao;
|
import cn.ksource.core.dao.SqlParameter;
|
import cn.ksource.core.util.*;
|
import cn.ksource.core.weixin.service.WeiXinCoreService;
|
import cn.ksource.web.Constants;
|
import cn.ksource.web.controller.wechat.util.WechatConstants;
|
import cn.ksource.web.exception.ExceptionHandler;
|
|
import org.apache.log4j.Logger;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
|
@Service("wechatService")
|
public class WechatServiceImpl implements WechatService {
|
|
@Autowired
|
private WeiXinCoreService weiXinCoreService;
|
|
@Autowired
|
private BaseDao baseDao;
|
|
|
private static Logger logger = org.apache.log4j.Logger.getLogger(WechatServiceImpl.class);
|
@Override
|
public boolean sendTemplateMsg(String[] openId, String orderId,String orderType,String sendPeople,String content,String remark) {
|
String token = weiXinCoreService.getAccess_token();
|
System.out.println("token---------------------->"+token);
|
String url = WechatConstants.SEND_TEMPLATE_MSG + weiXinCoreService.getAccess_token();
|
if(!StringUtil.notEmpty(sendPeople)) {
|
sendPeople = Constants.company_name+"服务台";
|
}
|
|
if(null!=openId && openId.length>0) {
|
Map result = new HashMap();
|
result.put("template_id", WechatConstants.NEW_ORDER_TEMP_ID);
|
|
String orderDetailUrl = new String();
|
String title = "您好，您有新的工单到达";
|
/*if(orderType.equals(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_REPAIR.toString())) {
|
orderDetailUrl = WechatConstants.ORDER_REPAIR_DETAIL_ADDRESS + orderId;
|
title = "您好，您有新的报障工单到达";
|
} else if(orderType.equals(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_ADD.toString())) {
|
orderDetailUrl = WechatConstants.ORDER_ADD_DETAIL_ADDRESS + orderId;
|
title = "您好，您有新的新增工单到达";
|
}else if(orderType.equals(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_HEALTH.toString())){
|
orderDetailUrl = WechatConstants.ORDER_HEALTH_DETAIL_ADDRESS + orderId;
|
title = "您好，您有新的月度巡检工单到达";
|
}else if(orderType.equals(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_REMIND.toString())){
|
orderDetailUrl = WechatConstants.ORDER_REMIND_DETAIL_ADDRESS + orderId;
|
title = "您好，您有新的例行维保工单到达";
|
}*/
|
|
result.put("url", orderDetailUrl);
|
result.put("topcolor", "#FF0000");
|
|
Map data = new HashMap();
|
result.put("data", data);
|
data.put("first", new CascadeMap("value",title).put("color", "#173177"));
|
data.put("keyword1", new CascadeMap("value",content).put("color", "#173177"));
|
data.put("keyword2", new CascadeMap("value",sendPeople).put("color", "#173177"));
|
data.put("keyword3", new CascadeMap("value",DateUtil.getToday("yyyy-MM-dd HH:mm:ss")).put("color", "#173177"));
|
data.put("remark", new CascadeMap("value",remark).put("color", "#173177"));
|
|
List<SqlParameter> recordParams = new ArrayList<SqlParameter>();
|
|
long sendTime = DateUtil.getCurrentDate14();
|
|
for(String str : openId) {
|
result.put("touser", str);
|
String json = JsonUtil.map2Json(result);
|
HttpUtil.doPost(url, json, HttpCharset.UTF8);
|
|
GG_USER user = new GG_USER().setOpen_id(str).queryForBean();
|
|
SqlParameter sqlParameter = new SqlParameter();
|
sqlParameter.put("orderId", orderId);
|
sqlParameter.put("openId", str);
|
sqlParameter.put("sendPeople", sendPeople);
|
sqlParameter.put("sendTime", sendTime);
|
sqlParameter.put("title", title);
|
sqlParameter.put("content", content);
|
sqlParameter.put("remark", remark);
|
sqlParameter.put("infoType", Constants.GG_MSG_RECORD_INFO_TYPE_TX);
|
sqlParameter.put("id", StringUtil.getUUID());
|
sqlParameter.put("receive_user_name", user.getZsxm());
|
sqlParameter.put("receive_time", sendTime);
|
sqlParameter.put("sendType", Constants.GG_MSG_RECORD_SEND_TYPE_WECHAT);
|
//保存发送记录
|
recordParams.add(sqlParameter);
|
}
|
this.saveSendRecord(recordParams);
|
}
|
return true;
|
}
|
|
|
@Override
|
public boolean sendSysMsg(String[] openId, GG_MESSAGE message) {
|
String token = weiXinCoreService.getAccess_token();
|
System.out.println("token---------------------->"+token);
|
String url = WechatConstants.SEND_TEMPLATE_MSG + token;
|
if(null!=openId && openId.length>0) {
|
Map result = new HashMap();
|
result.put("template_id", WechatConstants.NEW_ORDER_TEMP_ID);
|
|
String orderDetailUrl = message.getWx_url();
|
String title = "["+message.getOrder_code()+"]" + message.getTitle();
|
|
result.put("topcolor", "#FF0000");
|
|
Map data = new HashMap();
|
result.put("data", data);
|
data.put("first", new CascadeMap("value",title).put("color", "#173177"));
|
data.put("keyword1", new CascadeMap("value",message.getContent()).put("color", "#173177"));
|
data.put("keyword2", new CascadeMap("value",message.getSender_name()).put("color", "#173177"));
|
data.put("keyword3", new CascadeMap("value",DateUtil.format("yyyy-MM-dd HH:mm:ss", message.getSend_time())).put("color", "#173177"));
|
data.put("remark", new CascadeMap("value","").put("color", "#173177"));
|
|
String baseWxUrl = message.getWx_url();
|
for(String str : openId) {
|
result.put("touser", str);
|
result.put("url", baseWxUrl+"&openId="+str);
|
String json = JsonUtil.map2Json(result);
|
//开始发送数据信息
|
System.out.println("url------------------->"+url);
|
System.out.println("json------------------->"+json);
|
|
|
HttpUtil.doPost(url, json, HttpCharset.UTF8);
|
}
|
}
|
return true;
|
}
|
|
|
|
|
|
|
@Override
|
public boolean bindingNotice(String openId, String unBindUrl,String wxId,String username, String function,String remark) {
|
String token = weiXinCoreService.getAccess_token();
|
System.out.println("token---------------------->"+token);
|
logger.info("token---------------------->"+token);
|
String url = WechatConstants.SEND_TEMPLATE_MSG + token;
|
System.out.println(url);
|
logger.info("url---------------------->"+url);
|
Map result = new HashMap();
|
result.put("touser", openId);
|
result.put("template_id", WechatConstants.BIND_SUCCESS_TEMP_ID);
|
//result.put("url", unBindUrl);
|
result.put("topcolor", "#FF0000");
|
|
Map data = new HashMap();
|
result.put("data", data);
|
// data.put("first", new CascadeMap("value","您好，您的账号已成功绑定此微信").put("color", "#173177"));
|
data.put("first", new CascadeMap("value","您已成功绑定"+Constants.company_name).put("color", "#173177"));
|
// data.put("keyword1", new CascadeMap("value",wxId).put("color", "#173177"));
|
data.put("keyword1", new CascadeMap("value",username).put("color", "#173177"));
|
data.put("keyword2", new CascadeMap("value",DateUtil.getToday("yyyy年MM月dd日 HH:mm")).put("color", "#173177"));
|
data.put("remark", new CascadeMap("value",remark).put("color", "#173177"));
|
String json = JsonUtil.map2Json(result);
|
System.out.println(json);
|
HttpUtil.doPost(url, json, HttpCharset.UTF8);
|
return true;
|
}
|
|
/**
|
* 通过openId获取用户基本信息
|
*/
|
@Override
|
public Map queryUserBaseMsgByOpenId(String openId) {
|
System.out.println("openId-------------"+openId);
|
System.out.println(WechatConstants.GET_USER_BASE_MSG+"---------");
|
String token=weiXinCoreService.getAccess_token();
|
System.out.println("token----------"+token);
|
String baseMsgUrl = WechatConstants.GET_USER_BASE_MSG.replace("ACCESS_TOKEN", token).replace("OPENID", openId);
|
String returnMsg = HttpUtil.doGet(baseMsgUrl, new HashMap<String, String>(), HttpCharset.UTF8);
|
Map resultMap = JsonUtil.json2Map(returnMsg);
|
return resultMap;
|
}
|
|
|
@Override
|
public boolean sendReminderTemplateMsg(String[] openId,String orderId,String title,String orderType,String content, String reminderPeople, String remark) {
|
String token = weiXinCoreService.getAccess_token();
|
System.out.println("token---------------------->"+token);
|
String url = WechatConstants.SEND_TEMPLATE_MSG + token;
|
if(null!=openId && openId.length>0) {
|
Map result = new HashMap();
|
result.put("template_id", WechatConstants.REMINDER_TEMP_ID);
|
result.put("topcolor", "#FF0000");
|
|
|
/*String orderDetailUrl = new String();
|
if(orderType.equals(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_REPAIR.toString())) {
|
orderDetailUrl = WechatConstants.ORDER_REPAIR_DETAIL_ADDRESS + orderId;
|
}*/
|
|
if(!StringUtil.notEmpty(title)) {
|
title = "您有新的催办事项";
|
}
|
|
List<SqlParameter> recordParams = new ArrayList<SqlParameter>();
|
|
long sendTime = DateUtil.getCurrentDate14();
|
|
Map data = new HashMap();
|
result.put("data", data);
|
data.put("first", new CascadeMap("value",title).put("color", "#173177"));
|
data.put("keyword1", new CascadeMap("value",content).put("color", "#173177"));
|
data.put("keyword2", new CascadeMap("value",reminderPeople).put("color", "#173177"));
|
data.put("keyword3", new CascadeMap("value",DateUtil.getToday("yyyy-MM-dd HH:mm:ss")).put("color", "#173177"));
|
data.put("remark", new CascadeMap("value",remark).put("color", "#173177"));
|
for(String str : openId) {
|
// result.put("url", orderDetailUrl + "&openId="+str);
|
result.put("url", "");
|
result.put("touser", str);
|
String json = JsonUtil.map2Json(result);
|
HttpUtil.doPost(url, json, HttpCharset.UTF8);
|
|
|
|
GG_USER user = new GG_USER().setOpen_id(str).queryForBean();
|
|
SqlParameter sqlParameter = new SqlParameter();
|
sqlParameter.put("orderId", orderId);
|
sqlParameter.put("openId", str);
|
sqlParameter.put("sendPeople", reminderPeople);
|
sqlParameter.put("sendTime", sendTime);
|
sqlParameter.put("title", title);
|
sqlParameter.put("content", content);
|
sqlParameter.put("remark", remark);
|
sqlParameter.put("infoType", Constants.GG_MSG_RECORD_INFO_TYPE_CB);
|
sqlParameter.put("id", StringUtil.getUUID());
|
sqlParameter.put("receive_user_name", user.getZsxm());
|
sqlParameter.put("receive_time", sendTime);
|
sqlParameter.put("sendType", Constants.GG_MSG_RECORD_SEND_TYPE_WECHAT);
|
//保存发送记录
|
recordParams.add(sqlParameter);
|
}
|
this.saveSendRecord(recordParams);
|
}
|
return true;
|
}
|
|
|
/**
|
* 微信解绑通知
|
*/
|
@Override
|
public boolean unbindingNotice(String openId,String bindUrl,String wxName, String remark) {
|
String token = weiXinCoreService.getAccess_token();
|
System.out.println("token---------------------->"+token);
|
String url = WechatConstants.SEND_TEMPLATE_MSG + token;
|
System.out.println(url);
|
Map result = new HashMap();
|
result.put("touser", openId);
|
result.put("template_id", WechatConstants.UNBIND_SUCCESS_TEMP_ID);
|
result.put("url", bindUrl);
|
result.put("topcolor", "#FF0000");
|
|
Map data = new HashMap();
|
result.put("data", data);
|
data.put("first", new CascadeMap("value","您已成功与"+Constants.company_name+"解除绑定").put("color", "#173177"));
|
data.put("keyword1", new CascadeMap("value",wxName).put("color", "#173177"));
|
data.put("keyword2", new CascadeMap("value","该微信已不能接收"+Constants.company_name+"消息").put("color", "#173177"));
|
data.put("remark", new CascadeMap("value",remark).put("color", "#173177"));
|
String json = JsonUtil.map2Json(result);
|
System.out.println(json);
|
HttpUtil.doPost(url, json, HttpCharset.UTF8);
|
return true;
|
}
|
|
/**
|
* 保存发送记录
|
*/
|
private void saveSendRecord(List<SqlParameter> paramList) {
|
String insertSql = "INSERT INTO GG_MSG_RECORD(ID,SEND_USER_NAME,SEND_TIME,RECEIVE_USER_NAME,RECEIVE_TIME,SEND_TYPE,TITLE,CONTENT,REMARK,BUSINESS_ID,INFO_TYPE) VALUES " +
|
"(:id,:sendPeople,:sendTime,:receive_user_name,:receive_time,:sendType,:title,:content,:remark,:orderId,:infoType)";
|
baseDao.executeBatch(insertSql,paramList);
|
}
|
|
|
@Override
|
public boolean sendWxMsg(List<Map> openIds, GG_MESSAGE message) {
|
String token = weiXinCoreService.getAccess_token();
|
System.out.println("token---------------------->"+token);
|
String url = WechatConstants.SEND_TEMPLATE_MSG + token;
|
if(null!=openIds && openIds.size()>0) {
|
Map result = new HashMap();
|
result.put("template_id", WechatConstants.NEW_ORDER_TEMP_ID);
|
|
String orderDetailUrl = message.getWx_url();
|
String title = "["+message.getOrder_code()+"]" + message.getTitle();
|
|
result.put("topcolor", "#FF0000");
|
|
Map data = new HashMap();
|
result.put("data", data);
|
data.put("first", new CascadeMap("value",title).put("color", "#173177"));
|
data.put("keyword1", new CascadeMap("value",message.getContent()).put("color", "#173177"));
|
data.put("keyword2", new CascadeMap("value",message.getSender_name()).put("color", "#173177"));
|
data.put("keyword3", new CascadeMap("value",DateUtil.format("yyyy-MM-dd HH:mm:ss", message.getSend_time())).put("color", "#173177"));
|
data.put("remark", new CascadeMap("value","").put("color", "#173177"));
|
|
for(Map map : openIds) {
|
String openId = ConvertUtil.obj2StrBlank(map.get("openId"));
|
result.put("touser", openId);
|
result.put("url", ConvertUtil.obj2StrBlank(map.get("wxUrl"))+"&openId="+openId);
|
String json = JsonUtil.map2Json(result);
|
HttpUtil.doPost(url, json, HttpCharset.UTF8);
|
}
|
}
|
return true;
|
|
}
|
|
|
}
|
