package cn.ksource.web.facade.wechat;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import cn.ksource.core.CascadeMap;
|
import cn.ksource.core.dao.BaseDao;
|
import cn.ksource.core.dao.SqlParameter;
|
import cn.ksource.core.util.ConvertUtil;
|
import cn.ksource.core.util.DateUtil;
|
import cn.ksource.core.util.HttpCharset;
|
import cn.ksource.core.util.HttpUtil;
|
import cn.ksource.core.util.JsonUtil;
|
import cn.ksource.core.util.StringUtil;
|
import cn.ksource.core.web.ClientUtil;
|
import cn.ksource.core.web.PasswordEncoder;
|
import cn.ksource.core.web.WebUtil;
|
import cn.ksource.core.weixin.service.WeiXinCoreService;
|
import cn.ksource.web.Constants;
|
import cn.ksource.web.SysConstants;
|
import cn.ksource.web.controller.wechat.util.WechatConstants;
|
import cn.ksource.web.facade.JsglFacade;
|
import cn.ksource.web.facade.cfg.CfgFacade;
|
import cn.ksource.web.service.wechat.WechatService;
|
|
@Service("wechatFacade")
|
public class WechatFacadeImpl implements WechatFacade {
|
|
@Autowired
|
private BaseDao baseDao;
|
|
@Resource(name="wechatService")
|
private WechatService wechatService;
|
|
@Autowired
|
private JsglFacade jsglFacade;
|
@Autowired
|
private CfgFacade cfgFacade;
|
@Autowired
|
private WeiXinCoreService weiXinCoreService;
|
|
@Override
|
public String queryGcsBind(HttpServletRequest request, String openId) {
|
if(StringUtil.notEmpty(openId)) {
|
|
String selectsql = "SELECT A.* FROM (SELECT U.*,P.IS_TIME_OUT,P.VALID_END_DATE FROM GG_USER U , SC_PARTNER_INFO P ) A WHERE A.ZT = 1 AND A.OPEN_ID=:openId";
|
Map userMap = baseDao.queryForMap(selectsql,new SqlParameter().addValue("openId", openId));
|
if(null != userMap && userMap.size()>0) {
|
|
String isTimeOut = ConvertUtil.obj2StrBlank(userMap.get("IS_TIME_OUT"));
|
if(StringUtil.notEmpty(isTimeOut) && isTimeOut.equals("2")) {
|
//加盟商已过期
|
return "3";
|
}
|
|
|
putEngineerMsgToSession(request,userMap);
|
return "1";
|
}
|
}
|
|
return "2";
|
}
|
|
|
private void putEngineerMsgToSession(HttpServletRequest request,Map userMap) {
|
//查询属于何种桌面类型
|
String userId = ConvertUtil.obj2StrBlank(userMap.get("ID"));
|
String jumpUrl = Constants.getWxDeskTopUrl(Constants.ROLE_FLINE);
|
List<Map> roles = jsglFacade.getRolesByUserId(userId, 1);
|
if(roles.size()==1){
|
String identify = ConvertUtil.obj2StrBlank(roles.get(0).get("identify"));
|
if (StringUtil.isNotBlank(identify)) {
|
jumpUrl = Constants.getWxDeskTopUrl(identify);
|
}
|
}
|
|
userMap.put("deskTopType", jumpUrl);
|
|
request.getSession().setAttribute("homePage", jumpUrl);
|
|
request.getSession().setAttribute(SysConstants.WYW_ENGINEER_LOGIN_INFO_KEY, userMap);
|
}
|
|
|
/**
|
* 查询工程师是否已经进行过绑定微信号的操作
|
* @param fromUserName 微信用户对应该公众号的唯一id
|
* @return
|
*/
|
@Override
|
public boolean queryEngineerHasBind(String fromUserName) {
|
String selectSql = "SELECT COUNT(ID) FROM GG_USER WHERE OPEN_ID = :openId ";
|
Map paramMap = new HashMap();
|
paramMap.put("openId", fromUserName);
|
int count = baseDao.queryForInteger(selectSql, paramMap);
|
System.out.println("count---------------------->"+count);
|
if(count>0) {
|
return true;
|
}
|
return false;
|
}
|
|
@Override
|
public String updateEngineerOpenId(HttpServletRequest request) {
|
String username = request.getParameter("username");
|
String password = request.getParameter("password");
|
String openId = request.getParameter("openId");
|
|
if(!StringUtil.notEmpty(username)) {
|
return "请输入名称";
|
}
|
if(!StringUtil.notEmpty(password)) {
|
return "请输入密码";
|
}
|
if(!StringUtil.notEmpty(openId)) {
|
return "绑定失败";
|
}
|
|
boolean hasBind = queryEngineerHasBind(openId);
|
if(hasBind) {
|
return "该微信号已经绑定过平台账号";
|
}
|
|
String selectSql = "SELECT A.* FROM (SELECT U.*,P.IS_TIME_OUT,P.VALID_END_DATE FROM GG_USER U , SC_PARTNER_INFO P ) A WHERE A.ZT = 1 AND A.LOGINNAME = :username AND A.PASSWORD = :password ";
|
Map paramMap = new HashMap();
|
paramMap.put("username", username);
|
paramMap.put("password", PasswordEncoder.encode(password));
|
Map user = baseDao.queryForMap(selectSql,paramMap);
|
if(null==user || user.size() == 0) {
|
return "用户名或者密码错误";
|
}
|
|
String oId = ConvertUtil.obj2StrBlank(user.get("OPEN_ID"));
|
if(StringUtil.notEmpty(oId)) {
|
return "该账号已绑定过微信";
|
}
|
|
String isTimeOut = ConvertUtil.obj2StrBlank(user.get("IS_TIME_OUT"));
|
if(StringUtil.notEmpty(isTimeOut) && isTimeOut.equals("2")) {
|
return "该账号已过有效期";
|
}
|
|
|
|
//查询该工程师所在加盟商的有效期信息
|
|
|
String updateSql = "UPDATE GG_USER SET OPEN_ID = :openId,ISWECHAT = 2 WHERE ID = :id ";
|
baseDao.execute(updateSql, new SqlParameter("openId",openId).addValue("id", user.get("ID")));
|
|
String function = "提醒通知";
|
String remark = "";
|
|
//通过openId获取用户的基本信息
|
Map userBaseMap = wechatService.queryUserBaseMsgByOpenId(openId);
|
System.out.println("userBaseMap--------------->"+JsonUtil.map2Json(userBaseMap));
|
|
String wxName = ConvertUtil.obj2StrBlank(userBaseMap.get("nickname"));
|
|
wxName=queryZsxm(openId);
|
String unbindUrl = WechatConstants.ENGINEER_UNBIND_ADDRESS+"?openId="+openId;
|
//如果绑定成功，提醒微信绑定成功通知
|
wechatService.bindingNotice(openId,unbindUrl,wxName,username,function,remark);
|
|
putEngineerMsgToSession(request, user);
|
|
return "1";
|
}
|
public String queryZsxm(String openId){
|
String sql="select zsxm from gg_user where open_id=:openId";
|
return baseDao.queryForString(sql,new SqlParameter("openId",openId));
|
}
|
@Override
|
public String updateEngineerUnBindOpenId(HttpServletRequest request) {
|
//String username = request.getParameter("username");
|
//String password = request.getParameter("password");
|
String openId = request.getParameter("openId");
|
|
/*if(!StringUtil.notEmpty(username)) {
|
return "请输入名称";
|
}
|
if(!StringUtil.notEmpty(password)) {
|
return "请输入密码";
|
}*/
|
if(!StringUtil.notEmpty(openId)) {
|
return "解绑失败";
|
}
|
|
boolean hasBind = queryEngineerHasBind(openId);
|
if(!hasBind) {
|
return "该微信号未绑定平台账号";
|
}
|
|
/*String selectSql = "SELECT ID FROM GG_USER WHERE ACCOUNTTYPE = :type AND LOGINNAME = :username AND PASSWORD = :password AND OPEN_ID = :openId";
|
Map paramMap = new HashMap();
|
paramMap.put("type", Constants.GG_USER_ACCOUNT_TYPE_PARTNER_USER);
|
paramMap.put("username", username);
|
paramMap.put("password", PasswordEncoder.encode(password));
|
paramMap.put("openId", openId);
|
Map user = baseDao.queryForMap(selectSql,paramMap);
|
if(null==user || user.size() == 0) {
|
return "用户名或者密码错误";
|
}*/
|
|
String updateSql = "UPDATE GG_USER SET OPEN_ID = NULL,ISWECHAT = 1 WHERE OPEN_ID = :openId ";
|
baseDao.execute(updateSql, new SqlParameter("openId", openId));
|
|
//清空session
|
WebUtil.removeEngineerMsg(request);
|
|
|
String remark = "绑定账号请点击";
|
|
//通过openId获取用户的基本信息
|
Map userBaseMap = wechatService.queryUserBaseMsgByOpenId(openId);
|
|
String wxName = ConvertUtil.obj2StrBlank(userBaseMap.get("nickname"));
|
System.out.println("wxName--------------->"+wxName);
|
|
String bindUrl = WechatConstants.ENGINEER_BIND_ADDRESS+"?openId="+openId;
|
//如果解除绑定成功，提醒微信jiechu 绑定成功
|
wechatService.unbindingNotice(openId,bindUrl,wxName,remark);
|
|
return "1";
|
}
|
|
@Override
|
public String queryCustomerBind(HttpServletRequest request,String openId) {
|
if(StringUtil.notEmpty(openId)) {
|
String selectSql = "SELECT A.*,C.CUSTOMER_STATE,C.CREATE_TIME,C.VALID_BEGIN_DATE,C.VALID_END_DATE,C.CUSTOMER_NAME,C.SHORT_NAME FROM CUSTOMER_CONTACTS A,SC_PARTNER_CUSTOMER_INFO C WHERE A.CUSTOMER_ID = C.ID AND A.WECHAT_OPEN_ID = :openId ";
|
Map map = baseDao.queryForMap(selectSql,new SqlParameter("openId",openId));
|
if(null!=map && map.size()>0) {
|
Map jms = timeoutMsg();
|
String isTimeOut = ConvertUtil.obj2StrBlank(jms.get("IS_TIME_OUT"));
|
if(StringUtil.notEmpty(isTimeOut) && isTimeOut.equals("2")) {
|
return "3";
|
}
|
|
request.getSession().setAttribute(SysConstants.WYW_LOGIN_INFO_KEY, map);
|
return "1";
|
}
|
}
|
return "2";
|
}
|
|
|
private Map timeoutMsg() {
|
//查询该加盟商的有效期
|
String jmySql = "SELECT IS_TIME_OUT,VALID_END_DATE FROM SC_PARTNER_INFO ";
|
Map jms = baseDao.queryForMap(jmySql);
|
return jms;
|
}
|
|
//用户绑定微信账号
|
@Override
|
public String updateCustomerBindOpenId(HttpServletRequest request) {
|
String username = request.getParameter("username");
|
String password = request.getParameter("password");
|
String openId = request.getParameter("openId");
|
|
if(!StringUtil.notEmpty(username)) {
|
return "请输入名称";
|
}
|
if(!StringUtil.notEmpty(password)) {
|
return "请输入密码";
|
}
|
if(!StringUtil.notEmpty(openId)) {
|
return "绑定失败";
|
}
|
|
|
String hasBindSql = "SELECT COUNT(ID) FROM CUSTOMER_CONTACTS WHERE WECHAT_OPEN_ID = :openId ";
|
int bindCount = baseDao.queryForInteger(hasBindSql,new SqlParameter("openId",openId));
|
if(bindCount>0) {
|
return "该微信号已绑定平台账号";
|
}
|
|
String selectSql = "SELECT A.*,C.CUSTOMER_STATE,C.CREATE_TIME,C.VALID_BEGIN_DATE,C.VALID_END_DATE,C.CUSTOMER_NAME,C.SHORT_NAME FROM CUSTOMER_CONTACTS A,SC_PARTNER_CUSTOMER_INFO C WHERE A.CUSTOMER_ID = C.ID AND A.LOGIN_NAME = :username AND A.PASSWORD = :password";
|
Map paramMap = new HashMap();
|
paramMap.put("username", username);
|
paramMap.put("password", PasswordEncoder.encode(password));
|
Map user = baseDao.queryForMap(selectSql,paramMap);
|
if(null==user || user.size() == 0) {
|
return "用户名或者密码错误";
|
}
|
|
String wechatOpenId = ConvertUtil.obj2StrBlank(user.get("WECHAT_OPEN_ID"));
|
if(StringUtil.notEmpty(wechatOpenId)) {
|
return "您已绑定过微信";
|
}
|
|
//账号被锁定，请联系管理员
|
if(ConvertUtil.obj2StrBlank(user.get("STATE")).equals("2")){
|
return "账号被锁定，请联系管理员";
|
}
|
|
|
//账号不允许登录
|
if(ConvertUtil.obj2StrBlank(user.get("ALLOW_LOGIN")).equals("2")) {
|
return "账号不允许登录，请联系管理员";
|
}
|
|
Map jms = timeoutMsg();
|
String isTimeOut = ConvertUtil.obj2StrBlank(jms.get("IS_TIME_OUT"));
|
if(StringUtil.notEmpty(isTimeOut) && isTimeOut.equals("2")) {
|
return "该账号已过有效期";
|
}
|
|
String updateSql = "UPDATE CUSTOMER_CONTACTS SET WECHAT_OPEN_ID = :openId WHERE ID = :id ";
|
baseDao.execute(updateSql, new SqlParameter("id", user.get("ID")).addValue("openId", openId));
|
|
|
|
String function = "提醒通知";
|
String remark = "";
|
|
//通过openId获取用户的基本信息
|
Map userBaseMap = wechatService.queryUserBaseMsgByOpenId(openId);
|
|
String wxName = ConvertUtil.obj2StrBlank(userBaseMap.get("nickname"));
|
wxName=queryZsxm(openId);
|
System.out.println("wxName--------------->"+wxName);
|
|
//用户绑定提醒
|
String unbindUrl = WechatConstants.CUSTOMER_UNBIND_ADDRESS+"?openId="+openId;
|
//如果绑定成功，提醒微信绑定成功通知
|
wechatService.bindingNotice(openId,unbindUrl,wxName,username,function,remark);
|
|
|
request.getSession().setAttribute(SysConstants.WYW_LOGIN_INFO_KEY, user);
|
|
return "1";
|
}
|
|
@Override
|
public String checkLoginMsg(HttpServletRequest request) {
|
String username = request.getParameter("username");
|
String password = request.getParameter("password");
|
|
if(!StringUtil.notEmpty(username)) {
|
return "请输入名称";
|
}
|
if(!StringUtil.notEmpty(password)) {
|
return "请输入密码";
|
}
|
|
|
String selectSql = "SELECT A.*,B.CUSTOMER_NAME,B.PARTNER_ID FROM SC_PARTNER_CUSTOMER_ACCOUNT_INFO A,SC_PARTNER_CUSTOMER_INFO B WHERE A.CUSTOMER_ID = B.ID AND A.LOGIN_NAME = :username AND A.PASSWORD = :password";
|
Map paramMap = new HashMap();
|
paramMap.put("username", username);
|
paramMap.put("password", PasswordEncoder.encode(password));
|
Map user = baseDao.queryForMap(selectSql,paramMap);
|
if(null==user || user.size() == 0) {
|
return "用户名或者密码错误";
|
}
|
|
request.getSession().setAttribute(SysConstants.WYW_LOGIN_INFO_KEY, user);
|
|
return "1";
|
}
|
|
@Override
|
public String updateCustomerUnBindOpenId(HttpServletRequest request) {
|
//String username = request.getParameter("username");
|
//String password = request.getParameter("password");
|
String openId = request.getParameter("openId");
|
|
/*if(!StringUtil.notEmpty(username)) {
|
return "请输入名称";
|
}
|
if(!StringUtil.notEmpty(password)) {
|
return "请输入密码";
|
}
|
if(!StringUtil.notEmpty(openId)) {
|
return "绑定失败";
|
}*/
|
|
String hasBindSql = "SELECT COUNT(ID) FROM CUSTOMER_CONTACTS WHERE WECHAT_OPEN_ID = :openId ";
|
int bindCount = baseDao.queryForInteger(hasBindSql,new SqlParameter("openId",openId));
|
if(bindCount<=0) {
|
return "该微信号未绑定平台账号";
|
}
|
|
/*String selectSql = "SELECT ID FROM PROJECT_CONTACTS WHERE LOGIN_NAME = :username AND PASSWORD = :password AND WECHAT_OPEN_ID = :openId";
|
Map paramMap = new HashMap();
|
paramMap.put("username", username);
|
paramMap.put("password", PasswordEncoder.encode(password));
|
paramMap.put("openId", openId);
|
Map user = baseDao.queryForMap(selectSql,paramMap);
|
if(null==user || user.size() == 0) {
|
return "用户名或者密码错误";
|
}*/
|
|
String updateSql = "UPDATE CUSTOMER_CONTACTS SET WECHAT_OPEN_ID = NULL WHERE WECHAT_OPEN_ID = :openId ";
|
baseDao.execute(updateSql, new SqlParameter("openId", openId));
|
|
//清空session
|
WebUtil.removeCustomerMsg(request);
|
|
|
String remark = "绑定账号请点击";
|
|
//通过openId获取用户的基本信息
|
Map userBaseMap = wechatService.queryUserBaseMsgByOpenId(openId);
|
|
String wxName = ConvertUtil.obj2StrBlank(userBaseMap.get("nickname"));
|
System.out.println("wxName--------------->"+wxName);
|
|
String bindUrl = WechatConstants.CUSTOMER_BIND_ADDRESS+"?openId="+openId;
|
//如果解除绑定成功，提醒微信jiechu 绑定成功
|
wechatService.unbindingNotice(openId,bindUrl,wxName,remark);
|
|
return "1";
|
}
|
|
@Override
|
public String updateClientCustomer(HttpServletRequest request) {
|
String username = request.getParameter("username");
|
String password = request.getParameter("password");
|
//当前登录用户的ime
|
String ime = request.getParameter("ime");
|
|
if(!StringUtil.notEmpty(username)) {
|
return "请输入名称";
|
}
|
if(!StringUtil.notEmpty(password)) {
|
return "请输入密码";
|
}
|
|
String selectSql = "SELECT A.*,C.CUSTOMER_STATE,C.CREATE_TIME,C.VALID_BEGIN_DATE,C.VALID_END_DATE,C.CUSTOMER_NAME,C.SHORT_NAME FROM CUSTOMER_CONTACTS A,SC_PARTNER_CUSTOMER_INFO C WHERE A.CUSTOMER_ID = C.ID AND A.LOGIN_NAME = :username AND A.PASSWORD = :password";
|
Map paramMap = new HashMap();
|
paramMap.put("username", username);
|
paramMap.put("password", PasswordEncoder.encode(password));
|
Map user = baseDao.queryForMap(selectSql,paramMap);
|
if(null==user || user.size() == 0) {
|
return "用户名或者密码错误";
|
}
|
|
//账号被锁定，请联系管理员
|
if(ConvertUtil.obj2StrBlank(user.get("STATE")).equals("2")){
|
return "账号被锁定，请联系管理员";
|
}
|
|
|
//账号不允许登录
|
if(ConvertUtil.obj2StrBlank(user.get("ALLOW_LOGIN")).equals("2")) {
|
return "账号不允许登录，请联系管理员";
|
}
|
|
Map jms = timeoutMsg();
|
String isTimeOut = ConvertUtil.obj2StrBlank(jms.get("IS_TIME_OUT"));
|
if(StringUtil.notEmpty(isTimeOut) && isTimeOut.equals("2")) {
|
return "该账号已过有效期";
|
}
|
//更新用户记录的ime
|
updateUserIme(ime,username);
|
request.getSession().setAttribute(SysConstants.WYW_LOGIN_INFO_KEY, user);
|
request.getSession().setAttribute("isclient", "1");
|
return "1";
|
}
|
|
/**
|
* 用户登陆后，更新用户的ime
|
* */
|
private void updateUserIme(String ime,String username) {
|
Map user = new HashMap();
|
user.put("ime", ime);
|
user.put("username",username);
|
//清空所有用户的ime等于当前传入的ime
|
String sql = "UPDATE CUSTOMER_CONTACTS SET IME = '' WHERE IME = :ime";
|
baseDao.execute(sql, user);
|
//更新当前用户的ime
|
sql = "UPDATE CUSTOMER_CONTACTS SET IME = :ime WHERE LOGIN_NAME = :username";
|
baseDao.execute(sql, user);
|
}
|
|
|
@Override
|
public String updateClientEngineer(HttpServletRequest request) {
|
String username = request.getParameter("username");
|
String password = request.getParameter("password");
|
//当前登录用户的ime
|
String ime = request.getParameter("ime");
|
System.out.println("ime" +ime);
|
if(!StringUtil.notEmpty(username)) {
|
return "请输入名称";
|
}
|
if(!StringUtil.notEmpty(password)) {
|
return "请输入密码";
|
}
|
System.out.println("username"+username);
|
String selectSql = "SELECT A.* FROM (SELECT U.*,P.IS_TIME_OUT,P.VALID_END_DATE FROM GG_USER U , SC_PARTNER_INFO P ) A WHERE A.ZT = 1 AND A.LOGINNAME = :username AND A.PASSWORD = :password ";
|
Map paramMap = new HashMap();
|
paramMap.put("username", username);
|
paramMap.put("password", PasswordEncoder.encode(password));
|
Map user = baseDao.queryForMap(selectSql,paramMap);
|
if(null==user || user.size() == 0) {
|
return "用户名或者密码错误";
|
}
|
|
String isTimeOut = ConvertUtil.obj2StrBlank(user.get("IS_TIME_OUT"));
|
if(StringUtil.notEmpty(isTimeOut) && isTimeOut.equals("2")) {
|
return "该账号已过有效期";
|
}
|
|
putClientEngineerMsgToSession(request, user);
|
//更新工程师记录的ime
|
updateEngIme(ime,username);
|
|
return "1";
|
}
|
|
/**
|
* 工程师登陆后，更新用户的ime
|
* */
|
private void updateEngIme(String ime, String username) {
|
Map user = new HashMap();
|
user.put("ime", ime);
|
user.put("username",username);
|
//清空所有工程师的ime等于当前传入的ime
|
String sql = "UPDATE GG_USER SET IME = '' WHERE IME = :ime";
|
baseDao.execute(sql, user);
|
//更新当前工程师的ime
|
sql = "UPDATE GG_USER SET IME = :ime WHERE LOGINNAME = :username";
|
baseDao.execute(sql, user);
|
}
|
|
|
private void putClientEngineerMsgToSession(HttpServletRequest request,Map userMap) {
|
//查询属于何种桌面类型
|
String jumpUrl = Constants.getWxDeskTopUrl(Constants.ROLE_FLINE);
|
List<Map> roles = jsglFacade.getRolesByUserId(WebUtil.getEngineerUserId(request), 1);
|
if(roles.size()==1){
|
String identify = ConvertUtil.obj2StrBlank(roles.get(0).get("identify"));
|
if (StringUtil.isNotBlank(identify)) {
|
jumpUrl = Constants.getWxDeskTopUrl(identify);
|
}
|
}
|
|
userMap.put("deskTopType", jumpUrl);
|
request.getSession().setAttribute("isclient", "1");
|
request.getSession().setAttribute("homePage", jumpUrl);
|
request.getSession().setAttribute(SysConstants.WYW_ENGINEER_LOGIN_INFO_KEY, userMap);
|
}
|
|
|
@Override
|
public boolean queryEmgHasIme(String ime) {
|
String sql = "SELECT COUNT(ID) FROM GG_USER WHERE IME = :ime ";
|
int count = baseDao.queryForInteger(sql, new SqlParameter().addValue("ime", ime));
|
//System.out.println("count---------------------->"+count);
|
return count > 0 ? true : false;
|
}
|
|
|
@Override
|
public boolean queryUserHasIme(String ime) {
|
String sql = "SELECT COUNT(ID) FROM CUSTOMER_CONTACTS WHERE IME = :ime ";
|
int count = baseDao.queryForInteger(sql, new SqlParameter().addValue("ime", ime));
|
return count > 0 ? true : false;
|
}
|
|
|
@Override
|
public String queryEmgIme(HttpServletRequest request, String ime) {
|
String selectsql = "SELECT A.* FROM (SELECT U.*,P.IS_TIME_OUT,P.VALID_END_DATE FROM GG_USER U , SC_PARTNER_INFO P ) A WHERE A.ZT = 1 AND A.IME=:ime";
|
Map userMap = baseDao.queryForMap(selectsql,new SqlParameter().addValue("ime", ime));
|
if(null != userMap && userMap.size()>0) {
|
String isTimeOut = ConvertUtil.obj2StrBlank(userMap.get("IS_TIME_OUT"));
|
if(StringUtil.notEmpty(isTimeOut) && isTimeOut.equals("2")) {
|
//加盟商已过期
|
return "3";
|
}
|
putClientEngineerMsgToSession(request,userMap);
|
return "1";
|
}
|
return "2";
|
}
|
|
|
@Override
|
public String queryUserIme(HttpServletRequest request, String ime) {
|
String selectSql = "SELECT A.*,C.CUSTOMER_STATE,C.CREATE_TIME,C.VALID_BEGIN_DATE,C.VALID_END_DATE,C.CUSTOMER_NAME,C.SHORT_NAME FROM CUSTOMER_CONTACTS A,SC_PARTNER_CUSTOMER_INFO C WHERE A.CUSTOMER_ID = C.ID AND A.IME = :ime ";
|
Map map = baseDao.queryForMap(selectSql,new SqlParameter("ime",ime));
|
if(null!=map && map.size()>0) {
|
Map jms = timeoutMsg();
|
String isTimeOut = ConvertUtil.obj2StrBlank(jms.get("IS_TIME_OUT"));
|
if(StringUtil.notEmpty(isTimeOut) && isTimeOut.equals("2")) {
|
return "3";
|
}
|
request.getSession().setAttribute(SysConstants.WYW_LOGIN_INFO_KEY, map);
|
return "1";
|
}
|
return "2";
|
}
|
|
@Override
|
public Map getVersion() {
|
String sql = "SELECT A.*,B.CONTENT AS HTMLCONTENT FROM LARKS_VERSION A LEFT JOIN LARKS_HTML_VERSION B ON B.ID = A.HTML_ID WHERE A.STATUS = 1 ";
|
Map version = baseDao.queryForMap(sql);
|
Map resultMap = new HashMap();
|
resultMap.put("datas", version);
|
resultMap.put(ClientUtil.SUCCESS, true);
|
resultMap.put(ClientUtil.MSG, "成功");
|
return resultMap;
|
}
|
|
|
@Override
|
public void deleteClientEngineer(HttpServletRequest request) {
|
Map engineer = WebUtil.getEngineerMsg(request);
|
if(null!=engineer && engineer.size()>0) {
|
String id = ConvertUtil.obj2StrBlank(engineer.get("ID"));
|
String sql = "UPDATE GG_USER SET IME = '' WHERE ID = :id";
|
baseDao.execute(sql, new SqlParameter("id",id));
|
}
|
|
}
|
|
|
@Override
|
public void deleteClientCustomer(HttpServletRequest request) {
|
Map user = WebUtil.getWywLoginUser(request);
|
if(null!=user && user.size()>0) {
|
String id = ConvertUtil.obj2StrBlank(user.get("ID"));
|
String sql = "UPDATE CUSTOMER_CONTACTS SET IME = '' WHERE ID = :id";
|
baseDao.execute(sql, new SqlParameter("id",id));
|
}
|
|
}
|
|
|
@Override
|
public void saveFacBx(Map<String, String> params) {
|
Map info= cfgFacade.getCfgById(params.get("cateId"));
|
StringBuilder sql = new StringBuilder();
|
params.put("cusId", ConvertUtil.obj2Str(info.get("CUS_ID")));
|
sql.append(" insert into repair_record (id,create_name,status,create_time,cus_id,bx_title,bx_content,lx_phone) ");
|
sql.append(" values (:id,:lxr,:status,:create_time,:cusId,:bx_title,:bx_content,:lx_phone) ");
|
params.put("id", StringUtil.getUUID());
|
params.put("create_time", DateUtil.getCurrentDate14().toString());
|
params.put("status", Constants.REPAIR_STATE_DXY.toString());
|
baseDao.execute(sql.toString(), params);
|
params.put("SERVICE", "SERVICE");
|
String sqla="SELECT id FROM AC_ROLE where IDENTIFY=:SERVICE";
|
String id=baseDao.queryForString(sqla, params);
|
sqla="select OPEN_ID from gg_user a,AC_USER_REF_ROLE b where a.id=b.yhbh and a.zt=1 and b.jsbh=:id";
|
params.put("id", id);
|
List<Map> list=baseDao.queryForList(sqla, params);
|
String openIds="";
|
if(list!=null && list.size()>0){
|
for(Map map:list){
|
if(StringUtil.notEmpty(ConvertUtil.obj2Str(map.get("OPEN_ID")))){
|
openIds+=ConvertUtil.obj2Str(map.get("OPEN_ID"))+",";
|
}
|
}
|
}
|
String[] openId=openIds.split(",");
|
//发送微信消息
|
String token = weiXinCoreService.getAccess_token();
|
System.out.println("token---------------------->"+token);
|
String url = WechatConstants.SEND_TEMPLATE_MSG + token;
|
String title="";
|
String userName="";
|
if(StringUtil.notEmpty(ConvertUtil.obj2Str(params.get("userName")))){
|
userName="报修人-"+ConvertUtil.obj2Str(params.get("userName"));
|
}else{
|
userName="报修人-"+ConvertUtil.obj2Str(params.get("lxr"));
|
}
|
String content=params.get("bx_content");
|
// if(null!=openId && openId.length>0) {
|
// Map result = new HashMap();
|
// result.put("template_id", WechatConstants.REMINDER_TEMP_ID);
|
// result.put("topcolor", "#FF0000");
|
// if(!StringUtil.notEmpty(title)) {
|
// title = "您有新的报修事件";
|
// }
|
// String content=params.get("bx_content");
|
// 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",userName).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","请及时处理").put("color", "#173177"));
|
// for(String str : openId) {
|
// result.put("url", "");
|
// result.put("touser", str);
|
// String json = JsonUtil.map2Json(result);
|
// HttpUtil.doPost(url, json, HttpCharset.UTF8);
|
// }
|
// }
|
|
|
if(null!=openId && openId.length>0) {
|
Map result = new HashMap();
|
result.put("template_id", WechatConstants.NEW_ORDER_TEMP_ID);
|
|
String orderDetailUrl = "";
|
if(!StringUtil.notEmpty(title)) {
|
title = "您有新的报修事件";
|
}
|
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",userName).put("color", "#173177"));
|
data.put("keyword3", new CascadeMap("value",DateUtil.format("yyyy-MM-dd HH:mm:ss", DateUtil.getCurrentDate14())).put("color", "#173177"));
|
data.put("remark", new CascadeMap("value","").put("color", "#173177"));
|
|
String baseWxUrl = "";
|
for(String str : openId) {
|
result.put("touser", str);
|
result.put("url", WechatConstants.BASE_ADDRESS+"/ewyw/ewrepair/ewrepairPool.html"+"?openId="+str);
|
String json = JsonUtil.map2Json(result);
|
//开始发送数据信息
|
System.out.println("url------------------->"+url);
|
System.out.println("json------------------->"+json);
|
|
|
HttpUtil.doPost(url, json, HttpCharset.UTF8);
|
}
|
}
|
|
}
|
|
}
|
