|
@ -353,8 +353,11 @@ public class ConsultController extends WeixinBaseController {
|
|
|
System.out.println("guidance2="+guidance);
|
|
|
// 保存到数据库
|
|
|
int res = 0;
|
|
|
JSONArray dts = null;
|
|
|
synchronized (getRepUID().intern()){//新增同步方法。设备保存写在service层但是不生效,写在controller层才生效
|
|
|
res = consultTeamService.addTeamConsult(consult, getRepUID(),getUID());
|
|
|
JSONObject re = consultTeamService.addTeamConsult(consult, getRepUID(),getUID());
|
|
|
res = re.getInt("status");
|
|
|
dts = re.getJSONArray("doctor");
|
|
|
}
|
|
|
if (res == -1) {
|
|
|
return error(-1, "家庭签约信息不存在或已过期,无法进行家庭医生咨询!");
|
|
@ -377,7 +380,15 @@ public class ConsultController extends WeixinBaseController {
|
|
|
}
|
|
|
|
|
|
// 推送消息给医生
|
|
|
pushMsgTask.put(consult.getDoctor(), MessageType.MESSAGE_TYPE_DOCTOR_NEW_CONSULT_TEAM.D_CT_01.name(), MessageType.MESSAGE_TYPE_DOCTOR_NEW_CONSULT_TEAM.指定咨询.name(), MessageType.MESSAGE_TYPE_DOCTOR_NEW_CONSULT_TEAM.您有新的指定咨询.name(), consult.getConsult());
|
|
|
if(dts==null||dts.length()==0){
|
|
|
pushMsgTask.put(consult.getDoctor(), MessageType.MESSAGE_TYPE_DOCTOR_NEW_CONSULT_TEAM.D_CT_01.name(), MessageType.MESSAGE_TYPE_DOCTOR_NEW_CONSULT_TEAM.指定咨询.name(), MessageType.MESSAGE_TYPE_DOCTOR_NEW_CONSULT_TEAM.您有新的指定咨询.name(), consult.getConsult());
|
|
|
}else {
|
|
|
for (int i=0;i<dts.length();i++){
|
|
|
String doctorCode = dts.getString(i);
|
|
|
pushMsgTask.put(doctorCode, MessageType.MESSAGE_TYPE_DOCTOR_NEW_CONSULT_TEAM.D_CT_01.name(), MessageType.MESSAGE_TYPE_DOCTOR_NEW_CONSULT_TEAM.指定咨询.name(), MessageType.MESSAGE_TYPE_DOCTOR_NEW_CONSULT_TEAM.您有新的指定咨询.name(), consult.getConsult());
|
|
|
}
|
|
|
}
|
|
|
|
|
|
BusinessLogs.info(BusinessLogs.BusinessType.consult, getRepUID(), getUID(), new JSONObject(consult));
|
|
|
return write(200, "提交成功", "data", consult);
|
|
|
} catch (Exception ex) {
|