|
@ -1081,18 +1081,35 @@ public class FamilyContractService extends BaseService {
|
|
|
if (StringUtils.isNotBlank(sf.getOpenid())) {
|
|
|
// 添加到发送队列
|
|
|
PushMsgTask.getInstance().putWxMsg(access_token, 1, sf.getOpenid(), sf.getName(), json);
|
|
|
} else {
|
|
|
JSONObject j = weiXinOpenIdUtils.getFamilyOpenId(patient.getCode());
|
|
|
if (j != null) {
|
|
|
}
|
|
|
// else {
|
|
|
// JSONObject j = weiXinOpenIdUtils.getFamilyOpenId(patient.getCode());
|
|
|
// if (j != null) {
|
|
|
// Patient member = (Patient) j.get("member");
|
|
|
// if (StringUtils.isNotBlank(member.getOpenid())) {
|
|
|
// //String first = (String) json.get("first");
|
|
|
// json.remove("first");
|
|
|
// json.put("first", weiXinOpenIdUtils.getTitleMes(patient, j.getInt("relation"), sf.getName()));
|
|
|
// PushMsgTask.getInstance().putWxMsg(access_token, 1, member.getOpenid(), sf.getName(), json);
|
|
|
// }
|
|
|
// }
|
|
|
// }
|
|
|
//发送代理人
|
|
|
JSONArray jsonArray = weiXinOpenIdUtils.getAgentOpenId(sf.getPatient(),sf.getOpenid());
|
|
|
if(jsonArray!=null&&jsonArray.length()>0){
|
|
|
for (int i = 0;i<jsonArray.length();i++){
|
|
|
JSONObject j = jsonArray.getJSONObject(i);
|
|
|
Patient member = (Patient) j.get("member");
|
|
|
if (StringUtils.isNotBlank(member.getOpenid())) {
|
|
|
//String first = (String) json.get("first");
|
|
|
json.remove("first");
|
|
|
json.put("first", weiXinOpenIdUtils.getTitleMes(patient, j.getInt("relation"), sf.getName()));
|
|
|
PushMsgTask.getInstance().putWxMsg(access_token, 1, member.getOpenid(), sf.getName(), json);
|
|
|
}
|
|
|
JSONObject data = json;
|
|
|
data.remove("toUser");
|
|
|
data.put("toUser",member.getCode());
|
|
|
//String first = (String) json.get("first");
|
|
|
data.remove("first");
|
|
|
data.put("first",weiXinOpenIdUtils.getTitleMes(patient,j.getInt("relation"),patient.getName()));
|
|
|
PushMsgTask.getInstance().putWxMsg(access_token, 1, member.getOpenid(), patient.getName(), data);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
new Thread(new SignUploadTask(sf.getCode())).start();
|
|
|
JSONObject participants = new JSONObject();
|
|
|
participants.put(sf.getPatient(), 0);
|
|
@ -1340,14 +1357,30 @@ public class FamilyContractService extends BaseService {
|
|
|
if (StringUtils.isNotBlank(sf.getOpenid())) {
|
|
|
// 添加到发送队列
|
|
|
PushMsgTask.getInstance().putWxMsg(access_token, 2, sf.getOpenid(), sf.getName(), json);
|
|
|
} else {
|
|
|
JSONObject j = weiXinOpenIdUtils.getFamilyOpenId(p.getCode());
|
|
|
Patient member = (Patient) j.get("member");
|
|
|
if (StringUtils.isNotBlank(member.getOpenid())) {
|
|
|
}
|
|
|
// else {
|
|
|
// JSONObject j = weiXinOpenIdUtils.getFamilyOpenId(p.getCode());
|
|
|
// Patient member = (Patient) j.get("member");
|
|
|
// if (StringUtils.isNotBlank(member.getOpenid())) {
|
|
|
// //String first = (String) json.get("first");
|
|
|
// json.remove("first");
|
|
|
// json.put("first", weiXinOpenIdUtils.getTitleMes(p, j.getInt("relation"), p.getName()));
|
|
|
// PushMsgTask.getInstance().putWxMsg(access_token, 2, member.getOpenid(), p.getName(), json);
|
|
|
// }
|
|
|
// }
|
|
|
//发送代理人
|
|
|
JSONArray jsonArray = weiXinOpenIdUtils.getAgentOpenId(sf.getPatient(),sf.getOpenid());
|
|
|
if(jsonArray!=null&&jsonArray.length()>0){
|
|
|
for (int i = 0;i<jsonArray.length();i++){
|
|
|
JSONObject j = jsonArray.getJSONObject(i);
|
|
|
Patient member = (Patient) j.get("member");
|
|
|
JSONObject data = json;
|
|
|
data.remove("toUser");
|
|
|
data.put("toUser",member.getCode());
|
|
|
//String first = (String) json.get("first");
|
|
|
json.remove("first");
|
|
|
json.put("first", weiXinOpenIdUtils.getTitleMes(p, j.getInt("relation"), p.getName()));
|
|
|
PushMsgTask.getInstance().putWxMsg(access_token, 2, member.getOpenid(), p.getName(), json);
|
|
|
data.remove("first");
|
|
|
data.put("first",weiXinOpenIdUtils.getTitleMes(p,j.getInt("relation"),p.getName()));
|
|
|
PushMsgTask.getInstance().putWxMsg(access_token, 2, member.getOpenid(), p.getName(), data);
|
|
|
}
|
|
|
}
|
|
|
|
|
@ -1383,18 +1416,33 @@ public class FamilyContractService extends BaseService {
|
|
|
// 添加到发送队列
|
|
|
if (StringUtils.isNotBlank(sf.getOpenid())) {
|
|
|
PushMsgTask.getInstance().putWxMsg(access_token, 1, sf.getOpenid(), sf.getName(), json);
|
|
|
} else {
|
|
|
JSONObject j = weiXinOpenIdUtils.getFamilyOpenId(p.getCode());
|
|
|
Patient member = (Patient) j.get("member");
|
|
|
if (StringUtils.isNotBlank(member.getOpenid())) {
|
|
|
}
|
|
|
// else {
|
|
|
// JSONObject j = weiXinOpenIdUtils.getFamilyOpenId(p.getCode());
|
|
|
// Patient member = (Patient) j.get("member");
|
|
|
// if (StringUtils.isNotBlank(member.getOpenid())) {
|
|
|
// //String first = (String) json.get("first");
|
|
|
// json.remove("first");
|
|
|
// json.put("first", weiXinOpenIdUtils.getTitleMes(p, j.getInt("relation"), p.getName()));
|
|
|
// PushMsgTask.getInstance().putWxMsg(access_token, 1, member.getOpenid(), p.getName(), json);
|
|
|
// }
|
|
|
// }
|
|
|
//发送代理人
|
|
|
JSONArray jsonArray = weiXinOpenIdUtils.getAgentOpenId(sf.getPatient(),sf.getOpenid());
|
|
|
if(jsonArray!=null&&jsonArray.length()>0){
|
|
|
for (int i = 0;i<jsonArray.length();i++){
|
|
|
JSONObject j = jsonArray.getJSONObject(i);
|
|
|
Patient member = (Patient) j.get("member");
|
|
|
JSONObject data = json;
|
|
|
data.remove("toUser");
|
|
|
data.put("toUser",member.getCode());
|
|
|
//String first = (String) json.get("first");
|
|
|
json.remove("first");
|
|
|
json.put("first", weiXinOpenIdUtils.getTitleMes(p, j.getInt("relation"), p.getName()));
|
|
|
PushMsgTask.getInstance().putWxMsg(access_token, 1, member.getOpenid(), p.getName(), json);
|
|
|
data.remove("first");
|
|
|
data.put("first",weiXinOpenIdUtils.getTitleMes(p,j.getInt("relation"),p.getName()));
|
|
|
PushMsgTask.getInstance().putWxMsg(access_token, 1, member.getOpenid(), p.getName(), data);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
|
|
|
new Thread(new SignUploadTask(sf.getCode())).start();
|
|
|
JSONObject participants = new JSONObject();
|
|
|
participants.put(sf.getPatient(), 0);
|