package com.yc.sdk.weixincp.action;
|
|
import java.io.ByteArrayInputStream;
|
import java.io.File;
|
import java.io.InputStream;
|
import java.util.ArrayList;
|
import java.util.Enumeration;
|
import java.util.List;
|
import java.util.Set;
|
import java.util.UUID;
|
import java.util.Map.Entry;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
//import javax.servlet.http.HttpSession;
|
|
import me.chanjar.weixin.common.bean.result.WxMediaUploadResult;
|
import me.chanjar.weixin.common.error.WxErrorException;
|
import me.chanjar.weixin.cp.api.WxCpService;
|
import me.chanjar.weixin.cp.bean.Gender;
|
import me.chanjar.weixin.cp.bean.WxCpDepart;
|
import me.chanjar.weixin.cp.bean.WxCpUser;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.dao.DataAccessException;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
|
import com.google.gson.JsonArray;
|
import com.google.gson.JsonElement;
|
import com.google.gson.JsonObject;
|
import com.yc.action.BaseAction;
|
import com.yc.entity.DataSourceEntity;
|
import com.yc.entity.attachment.AttachmentWhereEntity;
|
import com.yc.multiData.MultiDataSource;
|
import com.yc.multiData.SpObserver;
|
import com.yc.sdk.miniapp.action.MaServiceInit;
|
import com.yc.sdk.miniapp.entity.MaSettingEntity;
|
import com.yc.sdk.miniapp.service.MaSettingIfc;
|
import com.yc.sdk.shopping.entity.SettingEntity;
|
import com.yc.sdk.shopping.service.SettingIfc;
|
import com.yc.sdk.shopping.service.imagedata.ShoppingImageDataIfc;
|
import com.yc.sdk.shopping.util.SettingKey;
|
import com.yc.sdk.weixincp.entity.MyWxCpDepart;
|
import com.yc.sdk.weixincp.entity.MyWxCpUser;
|
import com.yc.sdk.weixincp.entity.OtherMatEntity;
|
import com.yc.sdk.weixincp.entity.SaveUserInfoResultEntity;
|
import com.yc.sdk.weixincp.service.AppIfc;
|
import com.yc.sdk.weixincp.service.DeptIfc;
|
import com.yc.sdk.weixincp.service.ERPUserIfc;
|
import com.yc.sdk.weixincp.service.MaterialIfc;
|
import com.yc.sdk.weixincp.service.MessagesIfc;
|
import com.yc.sdk.weixincp.util.AvatarFile;
|
import com.yc.sdk.weixincp.util.PinyinRec;
|
import com.yc.sdk.weixincp.util.RandomString;
|
import com.yc.sdk.weixincp.util.WeiXinMediaType;
|
import com.yc.sdk.weixincp3rd.entity.SuiteComponentAppEntity;
|
import com.yc.service.upload.AttachmentIfc;
|
import com.yc.utils.SessionKey;
|
|
import cn.binarywang.wx.miniapp.api.WxMaService;
|
import cn.binarywang.wx.miniapp.bean.WxMaCodeLineColor;
|
|
|
/**
|
* 微信用户管理,与ERP系统同步用户信息
|
*
|
* @author JohnsWang
|
*
|
*/
|
|
@Controller
|
public class CPUser extends BaseAction {
|
|
@Autowired
|
ERPUserIfc erpUserIfc;
|
@Autowired
|
MessagesIfc messagesIfc;
|
@Autowired
|
DeptIfc deptIfc ;
|
@Autowired
|
MaterialIfc materialIfc ;
|
@Autowired
|
AppIfc appIfc ;
|
@Autowired
|
ShoppingImageDataIfc imgData;
|
@Autowired
|
SettingIfc settingIfc;
|
@Autowired
|
MaSettingIfc maSettingIfc;
|
@Autowired
|
private AttachmentIfc attachmentIfc;
|
|
// protected WxCpJedisConfigStorage wxCpConfigStorage;
|
// protected MyWxCpService wxCpService;
|
protected DataSourceEntity corpEntity;
|
|
/*
|
public void setInit(WxCpJedisConfigStorage wxCpConfigStorage,
|
MyWxCpService wxCpService,DataSourceEntity corpEntity) {
|
this.wxCpConfigStorage = wxCpConfigStorage ;
|
this.wxCpService = wxCpService ;
|
this.corpEntity = corpEntity ;
|
|
try {
|
SpObserver.setDBtoInstance("_" + corpEntity.getDbId());// 切换数据源
|
AppEntity appEntity = appIfc.getERPAppInfoByCategoryName("通讯录同步助手") ;
|
|
if (appEntity == null) {
|
throw new Exception("请在 700101 功能号中维护微信企业应用【通讯录同步助手】，并填写 Secret 字段值\n") ;
|
//response.getWriter().println("请在 700101 功能号中维护微信企业应用【通讯录同步助手】，并填写 Secret 字段值\n");
|
//return ;
|
}
|
|
|
wxCpConfigStorage.setAgentId(appEntity.getAgentid());
|
wxCpConfigStorage.setCorpSecret(appEntity.getCorpAppSecret());
|
wxCpConfigStorage.setToken(appEntity.getCorpAppToken()); // 设置微信企业号应用的token
|
wxCpConfigStorage.setAesKey(appEntity.getCorpAppAesKey()); // 设置微信企业号应用的EncodingAESKey
|
} catch ( Exception e1) {
|
e1.printStackTrace();
|
}finally {
|
SpObserver.setDBtoInstance();
|
}
|
}*/
|
|
// public void setWxCpService(MyWxCpService wxCpService) {
|
// this.wxCpService = wxCpService ;
|
// }
|
|
public void setDataSourceEntity(DataSourceEntity corpEntity) {
|
this.corpEntity = corpEntity ;
|
}
|
|
/**
|
* 1.从微信服务器拉取用户信息到ERP系统
|
* @param response
|
* @param request
|
*/
|
public List<String> userUpdateByPull(HttpServletRequest request,WxCpService wxCpService) {
|
List<String> errList = new ArrayList<String>() ;
|
// 将ERP新用户复制微信系统中 ，在复制之前必须先同步部门信息（同步部门要执行 CPDept.java 对象）
|
List<MyWxCpDepart> erpDeptInfoList = deptIfc.getDeptInfo() ;
|
List<WxCpUser> userListAll = new ArrayList<WxCpUser>() ;
|
String userId = "",userName = "";
|
try {
|
//WxCpService wxCpService = CpServiceInit.getWxCpService(corpEntity.getCorpId(),"addressbook") ;
|
for (int i = 0 ;erpDeptInfoList != null && i < erpDeptInfoList.size();i++ ) {
|
|
List<WxCpUser> userList = wxCpService.getUserService().listSimpleByDepartment(erpDeptInfoList.get(i).getId(), false, 0) ;
|
for (int j = 0 ;userList != null && j < userList.size();j++ ) {
|
WxCpUser wxCpUser = wxCpService.getUserService().getById(userList.get(j).getUserId());
|
if(wxCpUser!=null) {
|
userId = wxCpUser.getUserId();
|
userName = wxCpUser.getName();
|
}
|
SaveUserInfoResultEntity result = null ;
|
try {
|
result = erpUserIfc.saveWorkAppUser(wxCpUser,null);
|
}catch (Exception e) {
|
System.out.println("数据源["+SpObserver.getCurrentInstance()+"]同步用户[" + (wxCpUser!= null? wxCpUser.getUserId():"")+ "]信息时有错误发生(saveWorkAppUser)，错误代码：" + (e.getCause()!=null?e.getCause().getMessage(): e.getMessage()));
|
throw e ;
|
}
|
|
//更新头像
|
if (result != null && wxCpUser.getAvatar() != null) { // && !wxCpUser.getAvatar().equals(result.getAvatar())) {
|
//更新用户头像
|
String avatarMediaIDUri = wxCpUser.getAvatar(); //获取微信图像 uri
|
if (avatarMediaIDUri != null && !"".equals(avatarMediaIDUri)) {
|
String filePath = request.getServletContext().getRealPath("/") + "uploads"+File.separator+"smallpic"+File.separator ;
|
String fileName = filePath + RandomString.getRandomString(4) +".jpg";
|
File file = AvatarFile.getAvatarFile (avatarMediaIDUri,fileName,filePath) ; //获取微信图像 File 对象
|
if (file != null) {
|
messagesIfc.saveSubscribeEvent(wxCpUser,corpEntity,file ) ; //上传图像文件至数据库
|
}
|
}
|
}
|
userListAll.add(wxCpUser) ;
|
}
|
}
|
|
//删除多余的用户
|
List<MyWxCpUser> erpUserInfoList = erpUserIfc.getWorkAppUsers();
|
for (int i = 0 ;erpUserInfoList != null && i < erpUserInfoList.size();i++) {
|
if (!isExistsERPUser(userListAll,erpUserInfoList.get(i).getUserId()) ) {
|
erpUserIfc.deleteWorkAppUser(erpUserInfoList.get(i).getUserId());
|
}
|
}
|
|
} catch (WxErrorException e) {
|
errList.add("同步用户[" + userId+"/" + userName+"]信息时有错误发生，错误代码：" + e.getError().getErrorCode()+",错误信息:" + e.getError().getErrorMsg());
|
e.printStackTrace();
|
}catch (Exception e) {
|
e.printStackTrace();
|
errList.add("同步用户[" + userId+"/" + userName+"]信息时有错误发生，错误代码：" + (e.getCause()!=null?e.getCause().getMessage(): e.getMessage()));
|
|
}
|
return errList ;
|
|
}
|
|
/**
|
* 2.从ERP系统推送用户信息到微信服务器
|
* @param response
|
* @param request
|
*/
|
public List<String> userUpdateByPush(HttpServletRequest request,WxCpService wxCpService) {
|
List<String> errList = new ArrayList<String>() ;
|
// 将ERP新用户复制微信系统中 ，在复制之前必须先同步部门信息（同步部门要执行 CPDept.java 对象）
|
List<MyWxCpUser> erpUserInfoList = erpUserIfc.getWorkAppUsers();
|
|
|
//1.首先更新存在的用户
|
for (int i = 0; erpUserInfoList != null && i < erpUserInfoList.size(); i++) {
|
WxCpUser erpUserInfo = erpUserInfoList.get(i);
|
|
//如果性别为空 或 mobile/weixinid/email 同时为空，则跳过去
|
if (erpUserInfo.getGender() == null || "".equals(erpUserInfo.getGender().getCode()) ||
|
((erpUserInfo.getEmail() == null || "".equals(erpUserInfo.getEmail()))
|
&& (erpUserInfo.getMobile() == null || "".equals(erpUserInfo.getMobile()))
|
&& (erpUserInfo.getTelephone() == null || "".equals(erpUserInfo.getTelephone()))))
|
continue ;
|
|
WxCpUser wxUserInfo = null ;
|
try {
|
|
wxUserInfo = wxCpService.getUserService().getById(erpUserInfo.getUserId()) ;
|
} catch (WxErrorException e) {
|
if (e.getError().getErrorCode() == 60111) continue ;
|
String errmsg = "同步用户【"+erpUserInfo.getUserId()+"】【" + erpUserInfo.getName() + "】信息时有错误发生，错误代码：" + e.getError().getErrorCode()+",错误信息:" + e.getError().getErrorMsg();
|
errList.add(errmsg);
|
e.printStackTrace();
|
}
|
try {
|
if (wxUserInfo != null) {
|
WxCpUser wxCpUser = new WxCpUser() ;
|
wxCpUser.setUserId(erpUserInfo.getUserId());
|
wxCpUser.setName(erpUserInfo.getName()) ;
|
wxCpUser.setDepartIds(erpUserInfo.getDepartIds());
|
wxCpUser.setPosition(erpUserInfo.getPosition());
|
wxCpUser.setMobile(erpUserInfo.getMobile());
|
wxCpUser.setGender(erpUserInfo.getGender());
|
wxCpUser.setEmail(erpUserInfo.getEmail());
|
wxCpUser.setIsLeader(erpUserInfo.getIsLeader());
|
wxCpUser.setEnable(erpUserInfo.getEnable());
|
wxCpUser.setAvatarMediaId(erpUserInfo.getAvatarMediaId());
|
wxCpUser.setTelephone(erpUserInfo.getTelephone());
|
wxCpUser.setExternalAttrs(erpUserInfo.getExternalAttrs());
|
wxCpUser.setEnglishName(erpUserInfo.getEnglishName());
|
wxCpUser.setQrCode(erpUserInfo.getQrCode());
|
|
wxCpService.getUserService().update(wxCpUser); // 更新存在的用户
|
//更新用户头像
|
String avatarMediaIDUri = wxUserInfo.getAvatar(); //获取微信图像 uri
|
if (avatarMediaIDUri != null && !"".equals(avatarMediaIDUri)) {
|
String filePath = request.getServletContext().getRealPath("/") + "uploads"+File.separator+"smallpic"+File.separator ;
|
String fileName = filePath + RandomString.getRandomString(4) +".jpg";
|
File file = AvatarFile.getAvatarFile (avatarMediaIDUri,fileName,filePath) ; //获取微信图像 File 对象
|
if (file != null) {
|
messagesIfc.saveSubscribeEvent(wxUserInfo,corpEntity,file) ; //上传图像文件至数据库
|
}
|
}
|
}
|
} catch (WxErrorException e) {
|
String errmsg = "同步用户【"+erpUserInfo.getUserId()+"】【" + erpUserInfo.getName() + "】信息时有错误发生，错误代码：" + e.getError().getErrorCode()+",错误信息:" + e.getError().getErrorMsg();
|
errList.add(errmsg);
|
e.printStackTrace();
|
}catch (Exception e) {
|
errList.add("同步用户信息时有错误发生，错误代码：" +(e.getCause()!=null?e.getCause().getMessage(): e.getMessage()));
|
}
|
}
|
|
//2.新增新用户到微信服务器
|
for (int i = 0; erpUserInfoList != null && i < erpUserInfoList.size(); i++) {
|
MyWxCpUser erpUserInfo = erpUserInfoList.get(i);
|
|
//如果性别为空 或 mobile/weixinid/email 同时为空，则跳过去
|
if (erpUserInfo.getGender() == null || "".equals(erpUserInfo.getGender().getCode()) ||
|
((erpUserInfo.getEmail() == null || "".equals(erpUserInfo.getEmail()))
|
&& (erpUserInfo.getMobile() == null || "".equals(erpUserInfo.getMobile()))
|
&& (erpUserInfo.getTelephone() == null || "".equals(erpUserInfo.getTelephone()))))
|
continue ;
|
|
// weiXinUserStatus : 关注状态: 1=已关注，2=已冻结，4=未关注
|
|
boolean isWxUserExists = false ;
|
WxCpUser wxUserInfo = null ;
|
try {
|
wxUserInfo = wxCpService.getUserService().getById(erpUserInfo.getUserId()) ;
|
isWxUserExists = true ;
|
} catch (WxErrorException e) {
|
//60111 UserID不存在
|
if (e.getError().getErrorCode() == 60111) isWxUserExists = false ;
|
else {
|
errList.add("获取微信用户【" + erpUserInfo.getUserId() + "】【"
|
+ erpUserInfo.getName() + "】时出错,错误代码："
|
+ e.getError().getErrorCode()
|
+ ",错误信息：" + e.getError().getErrorMsg()
|
+ "\n");
|
e.printStackTrace();
|
}
|
}catch (Exception e) {
|
e.printStackTrace();
|
errList.add("同步用户信息时有错误发生，错误代码：" + (e.getCause()!=null?e.getCause().getMessage():e.getMessage()));
|
}
|
|
try {
|
if ( wxUserInfo == null || !isWxUserExists ) {
|
|
//上传头像
|
if (erpUserInfo.getAvatarUnid()!= null && !"".equals(erpUserInfo.getAvatarUnid())) {
|
OtherMatEntity otherMatEntity = materialIfc.getAttachment(erpUserInfo.getAvatarUnid());
|
String mediaType = "image" ;
|
mediaType = WeiXinMediaType.getMediaTypeByFileType(otherMatEntity.getFileType());
|
if (otherMatEntity!=null&&otherMatEntity.getOriginalPicture()!=null) {
|
InputStream is = new ByteArrayInputStream(otherMatEntity.getOriginalPicture());
|
WxMediaUploadResult res = wxCpService.getMediaService().upload(mediaType, otherMatEntity.getFileType(), is); //临时素材
|
if (res.getMediaId() != null && !"".equals(res.getMediaId())) {
|
erpUserInfo.setAvatarMediaid(res.getMediaId());
|
}
|
}
|
}
|
|
wxCpService.getUserService().create(erpUserInfo); // 新用户
|
erpUserIfc.saveWorkAppUserStatus(erpUserInfo.getUserId(), 4); // 改为： 未关注
|
//wxCpService.invite(erpUserInfo.getUserId(), "1") ; //邀请成员关注， 此功能在“企业微信”中不能使用
|
}
|
|
} catch (WxErrorException e) {
|
String errmsg = "新增用户【" + erpUserInfo.getUserId() + "】【"
|
+ erpUserInfo.getName() + "】时出错,错误代码："
|
+ e.getError().getErrorCode()+ ",错误信息：" + e.getError().getErrorMsg() + "\n";
|
errList.add(errmsg);
|
|
e.printStackTrace();
|
}catch (Exception e) {
|
e.printStackTrace();
|
errList.add("同步用户信息时有错误发生，错误代码：" + (e.getCause()!=null?e.getCause().getMessage(): e.getMessage()));
|
}
|
} // end for
|
|
// 3.删除微信服务器上的用户，而ERP系统中不存在的用户，达到同步的目的
|
List<WxCpDepart> groupList = null;
|
try {
|
groupList = wxCpService.getDepartmentService().list(null);
|
} catch (WxErrorException e) {
|
String errmsg = "获取部门信息时失败，错误代码：" + e.getError().getErrorCode()
|
+ ",错误信息:" + e.getError().getErrorMsg()+ "\n";
|
errList.add(errmsg);
|
|
e.printStackTrace();
|
}catch (Exception e ) {
|
e.printStackTrace();
|
errList.add("获取部门信息时失败，错误代码：" + (e.getCause()!=null?e.getCause().getMessage(): e.getMessage()));
|
}
|
|
for (int i = 0; groupList != null && i < groupList.size(); i++) {
|
WxCpDepart dept = groupList.get(i);
|
List<WxCpUser> userList = null;
|
try {
|
userList = wxCpService.getUserService().listByDepartment(dept.getId(), false,0);
|
} catch (WxErrorException e) {
|
errList.add("获取【" + dept.getName() + "】部门下的用户信息时失败，错误代码："
|
+ e.getError().getErrorCode()+ ",错误信息:"
|
+ e.getError().getErrorMsg());
|
e.printStackTrace();
|
}catch (Exception e) {
|
e.printStackTrace();
|
errList.add("同步用户信息时有错误发生，错误代码：" + (e.getCause()!=null?e.getCause().getMessage():e.getMessage()));
|
|
}
|
|
for (int j = 0; userList != null && j < userList.size(); j++) {
|
WxCpUser wxCpUser = userList.get(j);
|
try {
|
boolean isFound = isExistsMyERPUser(erpUserInfoList, wxCpUser.getUserId());
|
if (!isFound) {
|
wxCpService.getUserService().delete(wxCpUser.getUserId());
|
}
|
} catch (WxErrorException e) {
|
errList.add("删除【" + dept.getName() + "】部门下的用户【" + wxCpUser.getUserId() + "】【"
|
+ wxCpUser.getName() + "】时失败，错误代码：" + e.getError().getErrorCode() + ",错误信息:"
|
+ e.getError().getErrorMsg());
|
e.printStackTrace();
|
} catch (Exception e) {
|
e.printStackTrace();
|
errList.add("同步用户信息时有错误发生，错误代码：" + (e.getCause()!=null?e.getCause().getMessage(): e.getMessage()));
|
|
}
|
} // end for
|
|
|
}
|
|
|
return errList;
|
}
|
|
/**
|
* 往微信服务端写入新用户 ， 主要用于 导购 网店版页面注册新用户时，同时写入微信服务端
|
* @param response
|
*/
|
public boolean newUser(HttpServletResponse response,String userCode,String userName,WxCpService wxCpService) {
|
WxCpUser erpUserInfo = null;
|
try {
|
SpObserver.setDBtoInstance("_"+corpEntity.getDbId());
|
erpUserInfo = erpUserIfc.getWorkAppUser(userCode);
|
}finally {
|
SpObserver.setDBtoInstance();
|
}
|
if (erpUserInfo == null) return false;
|
|
WxCpUser wxUserInfo = null ;
|
boolean isWxUserExists = false ;
|
try {
|
wxUserInfo = wxCpService.getUserService().getById(userCode) ;
|
if (wxUserInfo != null) isWxUserExists = true ;
|
} catch (WxErrorException e) {
|
//60111 UserID不存在
|
if (e.getError().getErrorCode() == 60111) isWxUserExists = false ;
|
else {
|
System.out.println("获取微信用户【" + userCode + "】【"
|
+ userName + "】时出错,错误代码："
|
+ e.getError().getErrorCode()
|
+ ",错误信息：" + e.getError().getErrorMsg()
|
+ "\n");
|
}
|
}catch (Exception e) {
|
e.printStackTrace();
|
}
|
try {
|
if (erpUserInfo != null && ! isWxUserExists) {
|
wxCpService.getUserService().create(erpUserInfo); // 新用户
|
//wxCpService.invite(erpUserInfo.getUserId(),null) ; //邀请成员关注
|
}
|
} catch (WxErrorException e) {
|
String msg = "新增用户【" + erpUserInfo.getUserId() + "】【"
|
+ erpUserInfo.getName() + "】时出错,错误代码："
|
+ e.getError().getErrorCode()
|
+ ",错误信息：" + e.getError().getErrorMsg()
|
+ "\n" ;
|
System.out.println(msg);
|
|
}catch (Exception e) {
|
e.printStackTrace();
|
}
|
return true ;
|
}
|
|
/**
|
* 检查是否存在ERP用户
|
* @param erpUserInfoList
|
* @param userCode
|
* @return
|
*/
|
private boolean isExistsERPUser(List<WxCpUser> erpUserInfoList,String userCode) {
|
if (erpUserInfoList != null) {
|
for (int i = 0; i < erpUserInfoList.size(); i++) {
|
WxCpUser erpUserInfo = erpUserInfoList.get(i);
|
if (userCode != null && erpUserInfo.getUserId().equals(userCode)) return true ;
|
}
|
}
|
return false ;
|
}
|
|
private boolean isExistsMyERPUser(List<MyWxCpUser> erpUserInfoList,String userCode) {
|
if (erpUserInfoList != null) {
|
for (int i = 0; i < erpUserInfoList.size(); i++) {
|
WxCpUser erpUserInfo = erpUserInfoList.get(i);
|
if (userCode != null && erpUserInfo.getUserId().equals(userCode)) return true ;
|
}
|
}
|
return false ;
|
}
|
|
@RequestMapping("/shopping/getWorkAppUser.do")
|
public void getWorkAppUser(HttpServletResponse response,HttpServletRequest request) {
|
//HttpSession session = request.getSession();
|
//String dbId = (String) session.getAttribute(SessionKey.SHOPPING_DBID);
|
//String hostUrl = SettingKey.getHostUrl(request) ;
|
|
|
JsonObject json = new JsonObject();
|
JsonObject errJson = new JsonObject();
|
|
|
DataSourceEntity corpEntity = null ;
|
try {
|
corpEntity = MultiDataSource.getDataSourceMap( request) ;
|
if (corpEntity == null ) {
|
errJson.addProperty("warning", "没有找到数据源");
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
}
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
errJson.addProperty("warning", e.getCause()!=null?e.getCause().getMessage(): e.getMessage());
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
}
|
|
String userId = request.getParameter("card_userid") ;
|
|
try {
|
SpObserver.setDBtoInstance("_"+corpEntity.getDbId());//切换数据源
|
MyWxCpUser user = erpUserIfc.getWorkAppUser(userId) ;
|
if (user == null) {
|
errJson.addProperty("warning", "没有找到用户 userid:"+userId);
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
}
|
json.addProperty("card_userid", userId);
|
json.addProperty("card_hrcode", user.getHrCode());
|
json.addProperty("card_name", user.getName());
|
json.addProperty("card_gender", user.getGender().getCode());
|
json.addProperty("card_position", user.getPosition());
|
json.addProperty("card_tel", user.getMobile());
|
json.addProperty("card_show_tel", user.getTelephone());
|
String departNamesStr = user.getDepartNames() ;
|
String departNames[] = null ;
|
if (departNamesStr != null && !"".equals(departNamesStr)) {
|
departNames = departNamesStr.split(";") ;
|
}
|
JsonArray subImageListArray = new JsonArray();
|
for(int i = 0 ;user.getDepartIds()!=null&&i<user.getDepartIds().length;i++) {
|
JsonObject departItem = new JsonObject();
|
departItem.addProperty("departid", user.getDepartIds()[i]);
|
departItem.addProperty("departname", departNames !=null&& i< departNames.length?departNames[i]:"");
|
subImageListArray.add(departItem);
|
}
|
json.add("card_departids", subImageListArray);
|
|
this.printJson(response, json.toString());
|
return;
|
}catch (DataAccessException e) {
|
errJson.addProperty("warning", e.getCause()!=null?e.getCause().getMessage(): e.getMessage());
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
} catch (Exception e) {
|
errJson.addProperty("warning", e.getCause()!=null?e.getCause().getMessage(): e.getMessage());
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
|
@RequestMapping("/shopping/getMiniAppQrCode.do")
|
public void getMiniAppQrCode(HttpServletResponse response,HttpServletRequest request) {
|
//HttpSession session = request.getSession();
|
//String dbId = (String) session.getAttribute(SessionKey.SHOPPING_DBID);
|
//String hostUrl = SettingKey.getHostUrl(request) ;
|
|
|
JsonObject json = new JsonObject();
|
JsonObject errJson = new JsonObject();
|
|
|
DataSourceEntity corpEntity = null ;
|
try {
|
corpEntity = MultiDataSource.getDataSourceMap( request) ;
|
if (corpEntity == null ) {
|
errJson.addProperty("warning", "没有找到数据源");
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
}
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
errJson.addProperty("warning", e.getCause()!=null?e.getCause().getMessage(): e.getMessage());
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
}
|
|
|
//将微信corpid组装成url
|
String wxQueryString = SettingKey.getQueryStringByWx(request);
|
|
String userid = request.getParameter("userid");
|
if (userid==null) {
|
errJson.addProperty("warning", "必须传递 userid 参数");
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
}
|
|
String isRefresh = request.getParameter("isrefresh") ;
|
//第三方托管方式写法
|
WxMaService wxService = null;
|
try {
|
wxService = MaServiceInit.getWxMaServiceByOpenComponentByAppId(corpEntity.getMiniAppId()) ;
|
}catch (Exception e) {
|
e.printStackTrace();
|
errJson.addProperty("warning", e.getCause()!=null?e.getCause().getMessage(): e.getMessage());
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
}
|
try {
|
SpObserver.setDBtoInstance("_"+corpEntity.getDbId());//切换数据源
|
SettingEntity settingEntity = settingIfc.getSettingEntity(request) ;
|
//获取小程序二维码
|
MyWxCpUser myWxCpUser = erpUserIfc.getWorkAppUser(userid) ;
|
|
|
//刷新小程序二维码
|
if ((myWxCpUser!=null && ( myWxCpUser.getMiniAppQrCode() ==null || "".equals(myWxCpUser.getMiniAppQrCode()) )) || (isRefresh!=null && "true".equals(isRefresh))) {
|
File miniAppQrCodeFile = null ;
|
String page = ""; ;
|
try {
|
|
MaSettingEntity maSettingEntity = maSettingIfc.getMaSettingEntity() ;
|
String scene=SettingKey.FROMUSERID+"="+userid ;
|
//String page = "pages/index/index"; //扫码时打开 小程序 商城首页
|
page = (maSettingEntity !=null&&!"".equals(maSettingEntity.getDefaultPathUrl())?maSettingEntity.getDefaultPathUrl(): "pages/index/index"); //扫码时打开 小程序 商城首页
|
int width = 430;
|
boolean autoColor = false ;
|
WxMaCodeLineColor lineColor = new WxMaCodeLineColor("0","0","0") ;
|
boolean isHyaline = false ;
|
|
//MiniProgramState: developer 开发版 , trial 体验版 , formal 正式版
|
if (settingEntity.getMiniProgramState()!=null && settingEntity.getMiniProgramState().equals("trial")
|
//&& (myWxCpUser==null || myWxCpUser.getMiniAppTrialQrCode()==null || "".equals(myWxCpUser.getMiniAppTrialQrCode()))
|
) {
|
byte[] bytes = wxService.getCodeService().getQrCode(page+"?"+ scene);
|
String unid=UUID.randomUUID().toString().toUpperCase();//生成uuid
|
AttachmentWhereEntity attachmentWhereEntity= attachmentIfc.saveAttachment(unid, 700107, bytes,userid, "jpg","1") ;
|
erpUserIfc.saveMiniAppTrialQrCode(userid,attachmentWhereEntity.getUnid(),attachmentWhereEntity.getSeq()) ;
|
//File tempFile = File.createTempFile("trial", "jpg");
|
//miniAppQrCodeFile = BlobToFile.writeBytesToFile(bytes, tempFile.getPath()) ; //将流写入文件
|
}
|
|
miniAppQrCodeFile = wxService.getQrcodeService().createWxaCodeUnlimit(scene, page, width, autoColor, lineColor, isHyaline);
|
//File miniAppQrCodeFile= new File("/Users/johnswang/Downloads/小程序二维码.jpeg") ; //testing ...
|
erpUserIfc.saveMiniAppQrCode(userid,corpEntity,miniAppQrCodeFile) ;
|
|
//重新再取一次数
|
myWxCpUser = erpUserIfc.getWorkAppUser(userid) ;
|
}catch (WxErrorException e ) {
|
e.printStackTrace();
|
if (e.getError().getErrorCode() == 41030) {
|
json.addProperty("state", "找不到小程序页面【" + page + "】, 请检查是否为该小程序上传了代码？[原始错误报文：" + e.getError().getJson()+"]" );
|
}else {
|
json.addProperty("state", e.getError().getErrorMsg()+"[原始错误报文：" + e.getError().getJson()+"]" );
|
}
|
this.printJson(response, json.toString());
|
return;
|
}catch(Exception e) {
|
e.printStackTrace();
|
errJson.addProperty("warning",e.getCause()!=null?e.getCause().getMessage(): e.getMessage());
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
}finally{
|
if (miniAppQrCodeFile != null && miniAppQrCodeFile.exists()&&miniAppQrCodeFile.isFile()) {
|
log.info("del>>userCode:"+request.getSession().getAttribute(SessionKey.USERCODE)+"|dbid:"+request.getSession().getAttribute(SessionKey.DATA_BASE_ID)+"|"+miniAppQrCodeFile.getAbsolutePath());
|
miniAppQrCodeFile.delete();
|
}
|
}
|
}
|
|
|
|
if (myWxCpUser!=null && myWxCpUser.getMiniAppQrCode() != null && !"".equals(myWxCpUser.getMiniAppQrCode())) {
|
String imgUrl = imgData.getImageUrl(myWxCpUser.getMiniAppQrCode(),settingEntity.getImagePopupWidth(),settingEntity.getImagePopupHeight(),settingEntity.isShowPopupOrgImage(),settingEntity.isFromCached(),request) + (wxQueryString == null||"".equals(wxQueryString)?"":"?" + wxQueryString) ;
|
json.addProperty("imgurl", imgUrl);
|
json.addProperty("state", "success");
|
}else {
|
json.addProperty("state", "请点击刷新按钮获取二维码");
|
}
|
this.printJson(response, json.toString());
|
return;
|
}catch (DataAccessException e) {
|
e.printStackTrace();
|
errJson.addProperty("warning", e.getCause()!=null?e.getCause().getMessage(): e.getMessage());
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
} catch (Exception e) {
|
e.printStackTrace();
|
errJson.addProperty("warning", e.getCause()!=null?e.getCause().getMessage(): e.getMessage());
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
|
@RequestMapping("/shopping/updateWorkAppRadarUserStatus.do")
|
public void updateWorkAppRadarUserStatus(HttpServletResponse response,HttpServletRequest request) {
|
//HttpSession session = request.getSession();
|
//String dbId = (String) session.getAttribute(SessionKey.SHOPPING_DBID);
|
//String hostUrl = SettingKey.getHostUrl(request) ;
|
String appCode = "addressbook" ;
|
|
|
JsonObject json = new JsonObject();
|
JsonObject errJson = new JsonObject();
|
|
|
|
|
DataSourceEntity corpEntity = null ;
|
try {
|
corpEntity = MultiDataSource.getDataSourceMap( request) ;
|
if (corpEntity == null ) {
|
errJson.addProperty("warning", "没有找到数据源");
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
}
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
errJson.addProperty("warning", e.getCause()!=null?e.getCause().getMessage(): e.getMessage());
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
}
|
|
|
// isAiRadarUser : 0 ai雷达 ， 1 boss 雷达 ， 2 缺省ai雷达用户
|
String isAiRadarUser = request.getParameter("isAiRadarUser") ;
|
if (isAiRadarUser==null) {
|
errJson.addProperty("warning", "必须传递 isAiRadarUser 参数");
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
}
|
|
String isChecked = request.getParameter("isChecked") ;
|
if (isChecked==null) {
|
errJson.addProperty("warning", "必须传递 isSelected 参数");
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
}
|
|
String userid = request.getParameter("userid");
|
if (userid==null) {
|
errJson.addProperty("warning", "必须传递 userid 参数");
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
}
|
|
try {
|
SuiteComponentAppEntity suiteComponentAppEntity = CpServiceInit.getSuiteComponentAppEntityFromERP(corpEntity.getCorpId(),appCode) ;
|
|
SpObserver.setDBtoInstance("_"+corpEntity.getDbId());//切换数据源
|
|
// isAiRadarUser : 0 ai雷达 ， 1 boss 雷达 ， 2 缺省ai雷达用户
|
Integer authorizedUsers = erpUserIfc.getWorkAppAuthorizedUsers(isAiRadarUser!=null&&("0".equals(isAiRadarUser)||"2".equals(isAiRadarUser))?true:false) ;
|
if (isAiRadarUser!=null&&("0".equals(isAiRadarUser)||"1".equals(isAiRadarUser)) && isChecked!=null&&"true".equals(isChecked)) {
|
if (authorizedUsers!=null && suiteComponentAppEntity != null
|
&& suiteComponentAppEntity.getAuthorizedUsers()!=null
|
&& authorizedUsers.intValue() + 1 > suiteComponentAppEntity.getAuthorizedUsers().intValue()) {
|
errJson.addProperty("warning", "已经超出授权用户数"+suiteComponentAppEntity.getAuthorizedUsers() +",设置失败!" );
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
}
|
}
|
}catch (DataAccessException e) {
|
errJson.addProperty("warning", e.getCause()!=null?e.getCause().getMessage(): e.getMessage());
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
} catch (Exception e) {
|
errJson.addProperty("warning", e.getCause()!=null?e.getCause().getMessage(): e.getMessage());
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
|
try {
|
SpObserver.setDBtoInstance("_"+corpEntity.getDbId());//切换数据源
|
Integer ret = null ;
|
if (isAiRadarUser!=null&&"0".equals(isAiRadarUser)) { //ai 雷达
|
ret = erpUserIfc.saveAiRadarUser( userid, isChecked!=null&&"true".equals(isChecked)?true:false) ;
|
}
|
if (isAiRadarUser!=null&&"1".equals(isAiRadarUser)) { //boss 雷达
|
ret = erpUserIfc.saveBossRadarUser( userid, isChecked!=null&&"true".equals(isChecked)?true:false) ;
|
}
|
if (isAiRadarUser!=null&&"2".equals(isAiRadarUser)) { //缺省 ai 雷达
|
ret = erpUserIfc.saveAiRadarUserForDefault( userid, isChecked!=null&&"true".equals(isChecked)?true:false) ;
|
}
|
|
if (ret != null && ret.equals(1)) {
|
json.addProperty("state", "success");
|
}else {
|
errJson.addProperty("warning", "更新失败");
|
json.add("error", errJson);
|
}
|
json.addProperty("state", "success");
|
this.printJson(response, json.toString());
|
return;
|
}catch (DataAccessException e) {
|
errJson.addProperty("warning", e.getCause()!=null?e.getCause().getMessage(): e.getMessage());
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
} catch (Exception e) {
|
errJson.addProperty("warning", e.getCause()!=null?e.getCause().getMessage(): e.getMessage());
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
|
@RequestMapping("/shopping/delWorkAppUser.do")
|
public void delWorkAppUser(HttpServletResponse response,HttpServletRequest request) {
|
//HttpSession session = request.getSession();
|
//String dbId = (String) session.getAttribute(SessionKey.SHOPPING_DBID);
|
//String hostUrl = SettingKey.getHostUrl(request) ;
|
|
|
JsonObject json = new JsonObject();
|
JsonObject errJson = new JsonObject();
|
|
|
|
|
DataSourceEntity corpEntity = null ;
|
try {
|
corpEntity = MultiDataSource.getDataSourceMap( request) ;
|
if (corpEntity == null ) {
|
errJson.addProperty("warning", "没有找到数据源");
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
}
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
errJson.addProperty("warning", e.getCause()!=null?e.getCause().getMessage(): e.getMessage());
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
}
|
try {
|
SpObserver.setDBtoInstance("_"+corpEntity.getDbId());//切换数据源
|
List<String> userIds = new ArrayList<String>() ;
|
|
Enumeration<String> enu=request.getParameterNames();
|
while(enu.hasMoreElements()){
|
String paraName=(String)enu.nextElement();
|
if(paraName.startsWith("userids")){
|
String userid = request.getParameter(paraName);
|
userIds.add(userid) ;
|
}
|
}
|
|
for (int i =0 ;userIds !=null && i < userIds.size();i++) {
|
erpUserIfc.deleteWorkAppUser(userIds.get(i)) ;
|
}
|
|
|
json.addProperty("state", "success");
|
this.printJson(response, json.toString());
|
return;
|
}catch (DataAccessException e) {
|
errJson.addProperty("warning", e.getCause()!=null?e.getCause().getMessage(): e.getMessage());
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
} catch (Exception e) {
|
errJson.addProperty("warning", e.getCause()!=null?e.getCause().getMessage(): e.getMessage());
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
|
@RequestMapping("/shopping/saveWorkAppUser.do")
|
public void saveWorkAppUser(HttpServletResponse response,HttpServletRequest request) {
|
//HttpSession session = request.getSession();
|
//String dbId = (String) session.getAttribute(SessionKey.SHOPPING_DBID);
|
//String hostUrl = SettingKey.getHostUrl(request) ;
|
|
JsonObject json = new JsonObject();
|
JsonObject errJson = new JsonObject();
|
|
|
DataSourceEntity corpEntity = null ;
|
try {
|
corpEntity = MultiDataSource.getDataSourceMap( request) ;
|
if (corpEntity == null ) {
|
errJson.addProperty("warning", "没有找到数据源");
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
}
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
errJson.addProperty("warning", e.getCause()!=null?e.getCause().getMessage(): e.getMessage());
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
}
|
|
String userId = request.getParameter("card_userid") ;
|
String cardHrCode = request.getParameter("card_hrcode") ;
|
String cardName = request.getParameter("card_name") ;
|
String cardGender = request.getParameter("card_gender") ;
|
String cardPosition = request.getParameter("card_position") ;
|
String cardTel = request.getParameter("card_tel") ;
|
String cardShowTel = request.getParameter("card_show_tel") ;
|
String cardDepartIdsStr = request.getParameter("card_departids") ;
|
Long[] departIds = null ;
|
if (cardDepartIdsStr !=null && !"".equals(cardDepartIdsStr)) {
|
String cardDepartIdsList[] = cardDepartIdsStr.split(";") ;
|
departIds = new Long[cardDepartIdsList.length] ;
|
for(int i = 0 ;i < cardDepartIdsList.length;i++) {
|
departIds[i] = Long.parseLong(cardDepartIdsList[i]);
|
}
|
}
|
|
/*
|
List<Integer> departIdsList = new ArrayList<Integer>() ;
|
Enumeration<String> enu=request.getParameterNames();
|
while(enu.hasMoreElements()){
|
String paraName=(String)enu.nextElement();
|
if(paraName.startsWith("departids") && paraName.contains("[departid]")){
|
String departId = request.getParameter(paraName);
|
departIdsList.add(Integer.parseInt(departId)) ;
|
}
|
}
|
|
Integer[] departIds = null ;
|
if (departIdsList !=null && departIdsList.size() > 0) {
|
departIds = new Integer[departIdsList.size()] ;
|
for(int i = 0 ;i < departIdsList.size();i++) {
|
departIds[i] = departIdsList.get(i);
|
}
|
}*/
|
|
if (cardName == null || "".equals(cardName)) {
|
errJson.addProperty("card_name", "姓名 必须输入！");
|
}
|
if (cardGender == null || "".equals(cardGender)) {
|
errJson.addProperty("card_gender", "性别 必须输入！");
|
}
|
if (cardPosition == null || "".equals(cardPosition)) {
|
errJson.addProperty("card_position", "职位 必须输入！");
|
}
|
if (cardTel == null || "".equals(cardTel)) {
|
errJson.addProperty("card_tel", "绑定微信手机号 必须输入！");
|
}
|
if (cardShowTel == null || "".equals(cardShowTel)) {
|
errJson.addProperty("card_show_tel", "名片展示手机号 必须输入！");
|
}
|
if (departIds == null || departIds.length == 0) {
|
errJson.addProperty("departids", "部门 必须输入！");
|
}
|
|
Set<Entry<String, JsonElement>> it = errJson.entrySet();
|
if (!it.isEmpty() && it.size() != 0) {
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
}
|
|
|
try {
|
SpObserver.setDBtoInstance("_"+corpEntity.getDbId());//切换数据源
|
|
|
|
WxCpUser wxCpUser = new WxCpUser() ;
|
if (userId == null || "".equals(userId)) {
|
userId = PinyinRec.spell(cardName) ;
|
}
|
wxCpUser.setUserId(userId);
|
wxCpUser.setName(cardName);
|
if (cardGender !=null && "1".equals(cardGender)) {
|
wxCpUser.setGender(Gender.MALE);
|
} else {
|
wxCpUser.setGender(Gender.FEMALE);
|
}
|
wxCpUser.setPosition(cardPosition);
|
wxCpUser.setMobile(cardTel);
|
wxCpUser.setTelephone(cardShowTel);
|
wxCpUser.setDepartIds(departIds);
|
|
erpUserIfc.saveWorkAppUser(wxCpUser,cardHrCode) ;
|
//System.out.println(this.getClass()+" saveUserInfoResultEntity:" + saveUserInfoResultEntity.getAffectedRows());
|
json.addProperty("state", "success");
|
this.printJson(response, json.toString());
|
return;
|
}catch (DataAccessException e) {
|
errJson.addProperty("warning", e.getCause().getMessage());
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
} catch (Exception e) {
|
errJson.addProperty("warning", e.getMessage());
|
json.add("error", errJson);
|
this.printJson(response, json.toString());
|
return;
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
}
|
