|
|
@ -0,0 +1,1178 @@
|
|
|
package com.yihu.jw.internet.service;
|
|
|
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
import com.alibaba.fastjson.JSONArray;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
|
|
import com.yihu.jw.dict.dao.BaseSuperviseDataDictDao;
|
|
|
import com.yihu.jw.dict.dao.BaseSuperviseDictDao;
|
|
|
import com.yihu.jw.doctor.dao.BaseDoctorDao;
|
|
|
import com.yihu.jw.entity.hospital.dict.BaseSuperviseDataDict;
|
|
|
import com.yihu.jw.entity.hospital.dict.BaseSuperviseDict;
|
|
|
import com.yihu.jw.entity.thirdUpload.*;
|
|
|
import com.yihu.jw.hospital.dict.WlyyHospitalSysDictDao;
|
|
|
import com.yihu.jw.internet.dao.HospitalImgDao;
|
|
|
import com.yihu.jw.internet.dao.InternetUpLogDao;
|
|
|
import com.yihu.jw.internet.entity.InternetUpErrorLogDO;
|
|
|
import com.yihu.jw.internet.entity.InternetUpLogDO;
|
|
|
import com.yihu.jw.internet.service.ykyy.YkyyInternetService;
|
|
|
import com.yihu.jw.internet.wsapi.Wsapi;
|
|
|
import com.yihu.jw.internet.wsapi.WsapiProxy;
|
|
|
import com.yihu.jw.patient.dao.BasePatientDao;
|
|
|
import com.yihu.jw.thirdUpload.UpMedicalOnlineDao;
|
|
|
import com.yihu.jw.thirdUpload.service.*;
|
|
|
import com.yihu.jw.util.common.IdCardUtil;
|
|
|
import com.yihu.jw.util.date.DateUtil;
|
|
|
import com.yihu.jw.utils.ImgUtils;
|
|
|
import com.yihu.jw.utils.JSONUtils;
|
|
|
import com.yihu.jw.utils.encode.AESUtils;
|
|
|
import com.yihu.jw.utils.hibernate.HibenateUtils;
|
|
|
import com.yihu.mysql.query.BaseJpaService;
|
|
|
import org.apache.commons.collections.map.HashedMap;
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import sun.misc.BASE64Encoder;
|
|
|
|
|
|
import java.io.*;
|
|
|
import java.math.BigDecimal;
|
|
|
import java.net.URL;
|
|
|
import java.text.SimpleDateFormat;
|
|
|
import java.util.Date;
|
|
|
import java.util.List;
|
|
|
import java.util.Map;
|
|
|
|
|
|
|
|
|
/**
|
|
|
* Created by wsy on 2021/9/7.
|
|
|
*/
|
|
|
@Service
|
|
|
public class YkyyCommonService extends BaseJpaService<InternetUpErrorLogDO, InternetUpLogDao> {
|
|
|
|
|
|
private org.slf4j.Logger logger = LoggerFactory.getLogger(YkyyInternetService.class);
|
|
|
|
|
|
@Autowired
|
|
|
private InternetUpErrorLogService internetUpErrorLogService;
|
|
|
@Autowired
|
|
|
private InternetUpLogDao internetUpLogDao;
|
|
|
|
|
|
@Value("${fastDFS.fastdfs_file_url}")
|
|
|
private String fastdfs_file_url;
|
|
|
@Autowired
|
|
|
private WlyyHospitalSysDictDao dictDao;
|
|
|
@Autowired
|
|
|
private HibenateUtils hibenateUtils;
|
|
|
@Autowired
|
|
|
private BaseSuperviseDataDictDao superviseDataDictDao;
|
|
|
@Autowired
|
|
|
private BaseSuperviseDictDao superviseDictDao;
|
|
|
@Autowired
|
|
|
private UpnsDoctorRecordService upnsDoctorRecordService;
|
|
|
@Autowired
|
|
|
private UpAppointmentOnlineService upAppointmentOnlineService;
|
|
|
@Autowired
|
|
|
private UpMedicalOnlineService upMedicalOnlineService;
|
|
|
@Autowired
|
|
|
private UpnsDoctorScoreService upnsDoctorScoreService;
|
|
|
@Autowired
|
|
|
private BaseNsOnlineAskService baseNsOnlineAskService;
|
|
|
@Autowired
|
|
|
private BaseNsOlineMedService baseNsOlineMedService;
|
|
|
@Autowired
|
|
|
private BaseNsPrescriptionAService baseNsPrescriptionAService;
|
|
|
@Autowired
|
|
|
private BaseNsPrescriptionDrugService baseNsPrescriptionDrugService;
|
|
|
|
|
|
static String userName = "xmykzx";
|
|
|
static String psw = "7j39c7";
|
|
|
static String appId = "ws022";
|
|
|
static String AesEncodeKey = "834irjf3jd39rh2m";
|
|
|
//static String urlString = "http://10.120.102.202:18081/micc/wsapi/1.0?wsdl"; // 正式线路径
|
|
|
static String urlString = "http://fjhlw.bsoft.com.cn:18081/micc/wsapi/1.0?wsdl"; // 测试线路径
|
|
|
static String method = "execute";
|
|
|
static String token = "";
|
|
|
static String orgCode = "350211A5004";
|
|
|
static String orgName = "厦门大学附属厦门眼科中心";
|
|
|
static String orgArea = "350203000";
|
|
|
static String orgSub = "350200000";
|
|
|
static String imgPath =File.separator+"usr"+File.separator+"local"+File.separator+"hospital"+File.separator+"svr-internet-hospital-job"+File.separator+"img"+File.separator;
|
|
|
|
|
|
public String imgUrl;
|
|
|
|
|
|
|
|
|
public ObjectMapper objectMapper;
|
|
|
|
|
|
public void getBaseSurperviseDict(){
|
|
|
BaseSuperviseDict superviseDict = superviseDictDao.selectByDictName();
|
|
|
userName=superviseDict.getUserName();
|
|
|
psw=superviseDict.getPsw();
|
|
|
appId=superviseDict.getAppId();
|
|
|
AesEncodeKey = superviseDict.getAesEncodeKey();
|
|
|
method = superviseDict.getMethod();
|
|
|
token = superviseDict.getToken();
|
|
|
orgArea=superviseDict.getOrgArea();
|
|
|
orgCode = superviseDict.getOrgCode();
|
|
|
orgName=superviseDict.getOrgName();
|
|
|
orgSub=superviseDict.getOrgSub();
|
|
|
imgUrl=superviseDict.getImgUrl();
|
|
|
}
|
|
|
|
|
|
public String getDate(){
|
|
|
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
|
|
|
return simpleDateFormat.format(new Date());
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 监管平台上传地址
|
|
|
* @return
|
|
|
*/
|
|
|
public String getUrl(){
|
|
|
return dictDao.findByDictName("dataUpload").get(0).getDictCode();
|
|
|
//return urlString;
|
|
|
}
|
|
|
|
|
|
// 0 调用省监管平台接口
|
|
|
public String postToInter(String token, String api, JSONArray params,String url) throws Exception {
|
|
|
getBaseSurperviseDict();
|
|
|
WsapiProxy proxy = new WsapiProxy();
|
|
|
proxy.setEndpoint(url);
|
|
|
JSONObject jsonObject= new JSONObject();
|
|
|
if (params!=null&¶ms.size()>0){
|
|
|
jsonObject= params.getJSONObject(0);
|
|
|
jsonObject.put("docimg","");
|
|
|
jsonObject.put("doc_cert","");
|
|
|
jsonObject.put("cert_doc_prac","");
|
|
|
|
|
|
}
|
|
|
logger.info("入参:"+jsonObject.toString());
|
|
|
Wsapi wsapi = proxy.getWsapi();
|
|
|
|
|
|
// logger.info("postToInter:"+JSONUtils.toString(new String[] {token, params.toString()}));
|
|
|
|
|
|
String encryptParams = AESUtils.encrypt(JSONUtils.toString(new String[] {token, params.toString()}), AesEncodeKey);
|
|
|
String result = wsapi.invoke(appId, "", api, method, encryptParams);
|
|
|
String deResult = AESUtils.decrypt(result, AesEncodeKey);
|
|
|
|
|
|
logger.info("postToInter:"+JSONUtils.toString(deResult));
|
|
|
|
|
|
return deResult;
|
|
|
}
|
|
|
|
|
|
// 1 接口用户信息,获取TOKEN值 micc.upNsUserToken --- 完成
|
|
|
public String upNsUserToken(String url) throws Exception {
|
|
|
getBaseSurperviseDict();
|
|
|
WsapiProxy proxy = new WsapiProxy();
|
|
|
proxy.setEndpoint(url);
|
|
|
Wsapi wsapi = proxy.getWsapi();
|
|
|
|
|
|
String api = "micc.upNsUserToken";
|
|
|
JSONObject jb = new JSONObject();
|
|
|
jb.put("cd_user", userName);
|
|
|
jb.put("pwd_user", psw);
|
|
|
|
|
|
logger.info("url :"+url);
|
|
|
logger.info("jb :"+jb.toString());
|
|
|
|
|
|
String encryptParams = AESUtils.encrypt(JSONUtils.toString(new String[] { jb.toString() }), AesEncodeKey);
|
|
|
|
|
|
|
|
|
String res = wsapi.invoke(appId, "", api, method, encryptParams);
|
|
|
logger.info("appId :"+appId);
|
|
|
logger.info("method :"+method);
|
|
|
logger.info("encryptParams :"+encryptParams);
|
|
|
String deResult = AESUtils.decrypt(res, AesEncodeKey);
|
|
|
logger.info("AesEncodeKey :"+AesEncodeKey);
|
|
|
|
|
|
JSONObject resJson = (JSONObject) JSONObject.parse(deResult);
|
|
|
if("200".equals(resJson.get("msg").toString())) {
|
|
|
token = resJson.get("token").toString();
|
|
|
}
|
|
|
logger.info("upNsUserToken : "+token);
|
|
|
return token;
|
|
|
}
|
|
|
|
|
|
// 2 医院基本信息 micc.upNsOrganBas --- 完成
|
|
|
public String upNsOrganBas() throws Exception {
|
|
|
getBaseSurperviseDict();
|
|
|
BaseSuperviseDataDict superviseDataDict = superviseDataDictDao.selectByDictName();
|
|
|
String url = getUrl();
|
|
|
String api = "micc.upNsOrganBase";
|
|
|
|
|
|
JSONObject jb = new JSONObject();
|
|
|
jb.put("organ_code", orgCode);
|
|
|
jb.put("organ_name",orgName);
|
|
|
jb.put("corporation", superviseDataDict.getCorporation());
|
|
|
jb.put("no_pra_lic", superviseDataDict.getNoPraLic());
|
|
|
jb.put("second_organ_name", superviseDataDict.getSecondOrganName());
|
|
|
jb.put("charge_person", superviseDataDict.getChargePerson());
|
|
|
|
|
|
jb.put("level", superviseDataDict.getLevelCode());
|
|
|
jb.put("economic_type", superviseDataDict.getEconomicType());
|
|
|
jb.put("organ_type", superviseDataDict.getOrganType());
|
|
|
jb.put("organ_sub", orgSub);
|
|
|
jb.put("hospital_district",orgArea);
|
|
|
jb.put("hospital_address", superviseDataDict.getHospitalAddress());
|
|
|
|
|
|
jb.put("hospital_phone", superviseDataDict.getHospitalPhone());
|
|
|
jb.put("hospital_img","");
|
|
|
// jb.put("bus_lic", ImgUtils.getImageStr(imgPath+"hospital"+File.separator+"yyzz.jpg"));
|
|
|
// jb.put("corp_idcord_head", ImgUtils.getImageStr(imgPath+"hospital"+File.separator+"a.jpg"));
|
|
|
// jb.put("corp_idcord_tail", ImgUtils.getImageStr(imgPath+"hospital"+File.separator+"b.jpg"));
|
|
|
// jb.put("pra_lic", ImgUtils.getImageStr(imgPath+"hospital"+File.separator+"zyxkz.jpg"));
|
|
|
|
|
|
jb.put("bus_lic", null);
|
|
|
jb.put("corp_idcord_head", null);
|
|
|
jb.put("corp_idcord_tail", null);
|
|
|
jb.put("pra_lic", null);
|
|
|
|
|
|
jb.put("secu_level",superviseDataDict.getSecuLevel());
|
|
|
jb.put("secu_level_cert","");
|
|
|
|
|
|
jb.put("net_service", superviseDataDict.getNetService());
|
|
|
jb.put("net_service_ot", "");
|
|
|
jb.put("service_dept", superviseDataDict.getServiceDept());
|
|
|
jb.put("txt_introduction", superviseDataDict.getTxtIntroduction());
|
|
|
|
|
|
//用户协议
|
|
|
jb.put("protocol_type", superviseDataDict.getProtocolType());
|
|
|
jb.put("protocol_content", superviseDataDict.getProtocolContent());
|
|
|
jb.put("publish_date", superviseDataDict.getPublishDate());
|
|
|
jb.put("protocol_name", superviseDataDict.getProtocolName());
|
|
|
|
|
|
//其他建设信息
|
|
|
jb.put("quai_mang_dept", "");
|
|
|
jb.put("info_mang_dept", "");
|
|
|
jb.put("medi_service_dept", "");
|
|
|
|
|
|
jb.put("server_type", "");
|
|
|
jb.put("server_total", "");
|
|
|
jb.put("server_ip", "");
|
|
|
|
|
|
jb.put("mp_system_type", "");
|
|
|
jb.put("mp_system_total", "");
|
|
|
jb.put("tran_link", "");
|
|
|
|
|
|
jb.put("tran_link_band", "");
|
|
|
jb.put("server_system_name", "");
|
|
|
jb.put("server_system_ip", "");
|
|
|
|
|
|
jb.put("tech_manual", "");
|
|
|
jb.put("server_manual", "");
|
|
|
|
|
|
jb.put("emr_level", "");
|
|
|
jb.put("emr_level_cert", "");
|
|
|
|
|
|
jb.put("zone_record_share", "");
|
|
|
jb.put("prov_monitor", "");
|
|
|
jb.put("prov_service", "");
|
|
|
|
|
|
jb.put("server_func", "");
|
|
|
jb.put("third_compeny_name", "");
|
|
|
jb.put("third_compeny_code", "");
|
|
|
|
|
|
jb.put("third_compeny_cert", "");
|
|
|
jb.put("third_compeny_corp", "");
|
|
|
jb.put("third_compeny_corp_id", "");
|
|
|
|
|
|
jb.put("third_compeny_prot", "");
|
|
|
|
|
|
|
|
|
JSONArray jsonArray = new JSONArray();
|
|
|
jsonArray.add(jb);
|
|
|
|
|
|
String token = upNsUserToken(url);
|
|
|
String res = postToInter(token, api, jsonArray,url);
|
|
|
|
|
|
return res;
|
|
|
}
|
|
|
|
|
|
// 3 医师基本信息 micc.upNsDoctorRecord --- 完成
|
|
|
public String upNsDoctorRecord(String startDate, String endDate,String keyId) throws Exception {
|
|
|
getBaseSurperviseDict();
|
|
|
BaseSuperviseDataDict superviseDataDict = superviseDataDictDao.selectByDictName();
|
|
|
String url = getUrl();
|
|
|
String api = "micc.upNsDoctorRecord";
|
|
|
String upid = getCode();
|
|
|
String res = "";
|
|
|
int total = 0;
|
|
|
int success = 0;
|
|
|
int error = 0;
|
|
|
int dataError = 0;
|
|
|
String token = upNsUserToken(url);
|
|
|
|
|
|
//取数据
|
|
|
UpnsDoctorRecordDO upnsDoctorRecordDO;
|
|
|
List<UpnsDoctorRecordDO> list = upnsDoctorRecordService.findAllByDate(startDate,endDate);
|
|
|
|
|
|
total = list.size();
|
|
|
|
|
|
for(int i=0; i<total; i++){
|
|
|
upnsDoctorRecordDO = list.get(i);
|
|
|
Boolean errorFlag = false;
|
|
|
JSONObject jb = new JSONObject();
|
|
|
try {
|
|
|
|
|
|
//监管平台 职务字典强转
|
|
|
jb.put("organ_code", orgCode);
|
|
|
jb.put("organ_name", orgName);
|
|
|
jb.put("doc_name", upnsDoctorRecordDO.getDoc_name());
|
|
|
jb.put("docimg", upnsDoctorRecordDO.getDocimg());
|
|
|
jb.put("id_card", upnsDoctorRecordDO.getId_card());
|
|
|
jb.put("sex", upnsDoctorRecordDO.getSex());
|
|
|
jb.put("birthday", upnsDoctorRecordDO.getBirthday());
|
|
|
jb.put("subject", upnsDoctorRecordDO.getSubject());
|
|
|
jb.put("subject_name", upnsDoctorRecordDO.getSubject_name());
|
|
|
jb.put("belong_dept", upnsDoctorRecordDO.getBelong_dept());
|
|
|
jb.put("belong_dept_name", upnsDoctorRecordDO.getBelong_dept_name());
|
|
|
jb.put("doo_tel", upnsDoctorRecordDO.getDoo_tel());
|
|
|
jb.put("title_rec_date", upnsDoctorRecordDO.getTitle_rec_date());
|
|
|
jb.put("prac_type", upnsDoctorRecordDO.getPrac_type());
|
|
|
jb.put("title_code", upnsDoctorRecordDO.getTitle_code());
|
|
|
jb.put("first_compeny_code", upnsDoctorRecordDO.getFirst_compeny_code());
|
|
|
jb.put("first_compeny_name", upnsDoctorRecordDO.getFirst_compeny_name());
|
|
|
jb.put("secd_compeny_code", upnsDoctorRecordDO.getSecd_compeny_code());
|
|
|
jb.put("secd_compeny_name", upnsDoctorRecordDO.getSecd_compeny_name());
|
|
|
jb.put("net_service", upnsDoctorRecordDO.getNet_service());
|
|
|
jb.put("cert_no", upnsDoctorRecordDO.getCert_no());
|
|
|
jb.put("prac_no", upnsDoctorRecordDO.getPrac_no());
|
|
|
jb.put("doc_cert", upnsDoctorRecordDO.getDoc_cert());
|
|
|
jb.put("cert_doc_prac", upnsDoctorRecordDO.getCert_doc_prac());
|
|
|
jb.put("txt_introduction", upnsDoctorRecordDO.getTxt_introduction());
|
|
|
|
|
|
}catch (Exception e){
|
|
|
errorFlag = true;
|
|
|
saveErrorLog(upid,"3",upnsDoctorRecordDO.getId(),"数据格式错误",1);
|
|
|
error++;
|
|
|
logger.error(e.toString());
|
|
|
}
|
|
|
if(!errorFlag){
|
|
|
//上传监管平台
|
|
|
JSONArray jsonArray = new JSONArray();
|
|
|
jsonArray.add(jb);
|
|
|
res = postToInter(token, api, jsonArray,url);
|
|
|
JSONObject resJson = (JSONObject) JSONObject.parse(res);
|
|
|
if("200".equals(resJson.get("msg").toString())){
|
|
|
success++;
|
|
|
}else{
|
|
|
saveErrorLog(upid,"3",upnsDoctorRecordDO.getId(),res,2);
|
|
|
error++;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
}
|
|
|
String resInfo = "此次共上传：" + total + "条数据，其中成功 ：" + success + "条，上传失败 ： " + error + "条。格式错误："+dataError+"条。";
|
|
|
saveUpLog(upid,"3",new Date(),new Date(),success,error,dataError,resInfo);
|
|
|
return resInfo;
|
|
|
}
|
|
|
|
|
|
// 4 获取监管平台医师唯一标识 micc.achNsDoctorRecord --- 完成
|
|
|
public String achNsDoctorRecord(String idCardNo) throws Exception {
|
|
|
String url = getUrl();
|
|
|
String api = "micc.achNsDoctorRecord";
|
|
|
JSONObject jb = new JSONObject();
|
|
|
jb.put("organ_code", orgCode);
|
|
|
jb.put("organ_name", orgName);
|
|
|
jb.put("id_card", idCardNo);
|
|
|
|
|
|
JSONArray jsonArray = new JSONArray();
|
|
|
jsonArray.add(jb);
|
|
|
String token = upNsUserToken(url);
|
|
|
String res = postToInter(token, api, jsonArray,url);
|
|
|
JSONObject rs = (JSONObject) JSONObject.parse(res);
|
|
|
String msg = rs.getString("msg");
|
|
|
if("200".equals(msg)){
|
|
|
JSONArray reqContent = rs.getJSONArray("reqContent");
|
|
|
JSONObject req = (JSONObject)reqContent.get(0);
|
|
|
return req.getString("miccId");
|
|
|
}
|
|
|
return "";
|
|
|
}
|
|
|
|
|
|
// 5 网上预约挂号 micc.upAppointmentOnline ----完成
|
|
|
public String upAppointmentOnline(String startDate, String endDate,String keyId) throws Exception {
|
|
|
String url = getUrl();
|
|
|
String api = "micc.upAppointmentOnline";
|
|
|
String upid = getCode();
|
|
|
String res = "";
|
|
|
int total = 0;
|
|
|
int success = 0;
|
|
|
int dataError = 0;
|
|
|
int error = 0;
|
|
|
|
|
|
String token = upNsUserToken(url);
|
|
|
|
|
|
UpAppointmentOnlineDO upAppointmentOnlineDO;
|
|
|
List<UpAppointmentOnlineDO> list = upAppointmentOnlineService.findAllByDate(startDate,endDate);
|
|
|
total = list.size();
|
|
|
|
|
|
for(int i=0; i< total; i++){
|
|
|
JSONObject jb = new JSONObject();
|
|
|
upAppointmentOnlineDO = list.get(i);
|
|
|
Boolean errorFlag = false;
|
|
|
try{
|
|
|
String[] dept = depToSubject(upAppointmentOnlineDO.getReg_subject_code());
|
|
|
jb.put("id", orgCode +"_"+ upAppointmentOnlineDO.getId());
|
|
|
jb.put("cd_org", orgCode);
|
|
|
jb.put("cd_area", orgArea);
|
|
|
jb.put("cd_orgSub", orgSub);
|
|
|
jb.put("reg_time", upAppointmentOnlineDO.getReg_time());
|
|
|
jb.put("fg_visit", upAppointmentOnlineDO.getFg_visit() == null?"1" : upAppointmentOnlineDO.getFg_visit());
|
|
|
jb.put("reg_dep_code", upAppointmentOnlineDO.getReg_dep_code() == null?"0":upAppointmentOnlineDO.getReg_dep_code());
|
|
|
jb.put("reg_dep_name", upAppointmentOnlineDO.getReg_dep_name() == null?"0":upAppointmentOnlineDO.getReg_dep_name());
|
|
|
jb.put("reg_subject_code", dept.length>=1?dept[0]:"");
|
|
|
jb.put("reg_subject_name", dept.length>=2?dept[1]:"");
|
|
|
jb.put("reg_price", upAppointmentOnlineDO.getReg_price());
|
|
|
jb.put("pt_name", upAppointmentOnlineDO.getPt_name() == null?"0":upAppointmentOnlineDO.getPt_name());
|
|
|
jb.put("ge_code", upAppointmentOnlineDO.getGe_code());
|
|
|
jb.put("pt_age", upAppointmentOnlineDO.getPt_age());
|
|
|
jb.put("card_type", upAppointmentOnlineDO.getCard_type());
|
|
|
jb.put("id_no", upAppointmentOnlineDO.getId_no() == null?"0": upAppointmentOnlineDO.getId_no());
|
|
|
jb.put("pt_tel", upAppointmentOnlineDO.getPt_tel());
|
|
|
jb.put("crt_date",DateUtil.dateToStrLong(DateUtil.getNow()));
|
|
|
}catch (Exception e){
|
|
|
errorFlag = true;
|
|
|
saveErrorLog(upid,"5",upAppointmentOnlineDO.getId(),"网上预约挂号数据格式错误",1);
|
|
|
dataError++;
|
|
|
logger.error(e.toString());
|
|
|
}
|
|
|
|
|
|
if(!errorFlag){
|
|
|
JSONArray jsonArray = new JSONArray();
|
|
|
jsonArray.add(jb);
|
|
|
res = postToInter(token,api, jsonArray,url);
|
|
|
|
|
|
JSONObject resJson = (JSONObject) JSONObject.parse(res);
|
|
|
if("200".equals(resJson.get("msg").toString())){
|
|
|
success++;
|
|
|
}else{
|
|
|
saveErrorLog(upid,"5",upAppointmentOnlineDO.getId(),res,2);
|
|
|
error++;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
String resInfo = "此次共上传：" + total + "条数据，其中成功 ：" + success + "条，上传失败 ： " + error + "条。格式错误："+dataError+"条。";
|
|
|
saveUpLog(upid,"5",DateUtil.stringToDate(startDate,"yyyy-MM-dd HH:mm:ss"),DateUtil.stringToDate(endDate,"yyyy-MM-dd HH:mm:ss"),success,error,dataError,resInfo);
|
|
|
|
|
|
return resInfo;
|
|
|
}
|
|
|
|
|
|
// 6 在线医技预约 micc.upMedicalOnline --- 完成
|
|
|
public String upMedicalOnline(String startDate, String endDate,String keyId) throws Exception {
|
|
|
String url = getUrl();
|
|
|
String api = "micc.upMedicalOnline";
|
|
|
String upid = getCode();
|
|
|
//挂号String token = upNsUserToken(url);
|
|
|
String res = "";
|
|
|
int total = 0;
|
|
|
int success = 0;
|
|
|
int error = 0;
|
|
|
int dataError = 0;
|
|
|
|
|
|
UpMedicalOnlineDO upMedicalOnlineDO;
|
|
|
List<UpMedicalOnlineDO> list = upMedicalOnlineService.findAllByDate(startDate,endDate);
|
|
|
|
|
|
if(list != null && list.size() > 0){
|
|
|
total = list.size();
|
|
|
for(int i = 0; i<total; i++){
|
|
|
JSONObject jb = new JSONObject();
|
|
|
upMedicalOnlineDO = list.get(i);
|
|
|
Boolean errorFlag = false;
|
|
|
try {
|
|
|
String docInterId = achNsDoctorRecord(upMedicalOnlineDO.getId_doctor());
|
|
|
jb.put("id",orgCode +"_"+ upMedicalOnlineDO.getId());
|
|
|
jb.put("cd_org", orgCode);
|
|
|
jb.put("cd_area", orgArea);
|
|
|
jb.put("cd_orgSub", orgSub);
|
|
|
jb.put("app_time",upMedicalOnlineDO.getApp_time());
|
|
|
jb.put("app_dep_code", upMedicalOnlineDO.getApp_dep_code());
|
|
|
jb.put("app_class_code", upMedicalOnlineDO.getApp_class_code());
|
|
|
jb.put("id_doctor", docInterId);
|
|
|
jb.put("fg_handle", upMedicalOnlineDO.getFg_handle());
|
|
|
jb.put("handle_time", upMedicalOnlineDO.getHandle_time());
|
|
|
jb.put("pt_name",upMedicalOnlineDO.getPt_name());
|
|
|
jb.put("ge_code", upMedicalOnlineDO.getGe_code());
|
|
|
jb.put("card_type", upMedicalOnlineDO.getCard_type());
|
|
|
jb.put("id_no", upMedicalOnlineDO.getId_no());
|
|
|
jb.put("pt_tel", upMedicalOnlineDO.getPt_tel());
|
|
|
jb.put("crt_date",DateUtil.dateToStrLong(DateUtil.getNow()));
|
|
|
}catch (Exception e){
|
|
|
errorFlag = true;
|
|
|
saveErrorLog(upid,"6",upMedicalOnlineDO.getId(),"在线医技预约格式错误",1);
|
|
|
dataError++;
|
|
|
logger.error(e.toString());
|
|
|
}
|
|
|
|
|
|
if(!errorFlag){
|
|
|
JSONArray jsonArray = new JSONArray();
|
|
|
jsonArray.add(jb);
|
|
|
res = postToInter(token,api, jsonArray,url);
|
|
|
|
|
|
JSONObject resJson = (JSONObject) JSONObject.parse(res);
|
|
|
if("200".equals(resJson.get("msg").toString())){
|
|
|
success++;
|
|
|
}else{
|
|
|
saveErrorLog(upid,"6",upMedicalOnlineDO.getId(),res,2);
|
|
|
error++;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
}
|
|
|
}
|
|
|
|
|
|
String resInfo = "此次共上传：" + total + "条数据，其中成功 ：" + success + "条，上传失败 ： " + error + "条。格式错误："+dataError+"条。";
|
|
|
saveUpLog(upid,"6",DateUtil.stringToDate(startDate,"yyyy-MM-dd HH:mm:ss"),DateUtil.stringToDate(endDate,"yyyy-MM-dd HH:mm:ss"),success,error,dataError,resInfo);
|
|
|
|
|
|
return resInfo;
|
|
|
}
|
|
|
|
|
|
// 7 医生评价信息 micc.upNsDoctorScore --- 完成
|
|
|
public String upNsDoctorScore(String startDate, String endDate,String keyId) throws Exception {
|
|
|
String url = getUrl();
|
|
|
String api = "micc.upNsDoctorScore";
|
|
|
String upid = getCode();
|
|
|
String res = "";
|
|
|
int total = 0;
|
|
|
int success = 0;
|
|
|
int error = 0;
|
|
|
int dataError = 0;
|
|
|
|
|
|
String token = upNsUserToken(url);
|
|
|
|
|
|
List<UpnsDoctorScoreDO> list = upnsDoctorScoreService.findAllByDate(startDate,endDate);
|
|
|
UpnsDoctorScoreDO upnsDoctorScoreDO = new UpnsDoctorScoreDO();
|
|
|
|
|
|
total = list.size();
|
|
|
Boolean errorFlag = false;
|
|
|
JSONObject jb = new JSONObject();
|
|
|
for(int i=0; i<list.size(); i++) {
|
|
|
try{
|
|
|
upnsDoctorScoreDO = list.get(i);
|
|
|
String docInterId = achNsDoctorRecord(upnsDoctorScoreDO.getId_doctor());
|
|
|
jb.put("id",orgCode +"_"+ upnsDoctorScoreDO.getId());
|
|
|
jb.put("id_doctor",docInterId);
|
|
|
jb.put("organ_code",orgCode);
|
|
|
jb.put("organ_name", orgName);
|
|
|
jb.put("net_service", upnsDoctorScoreDO.getNet_service());
|
|
|
jb.put("net_service_name", upnsDoctorScoreDO.getNet_service_name());
|
|
|
jb.put("val_score", upnsDoctorScoreDO.getVal_score() ==null ? "0": upnsDoctorScoreDO.getVal_score());
|
|
|
jb.put("grader", upnsDoctorScoreDO.getGrader() == null ? "0": upnsDoctorScoreDO.getGrader());
|
|
|
jb.put("dt_grade", upnsDoctorScoreDO.getDt_grade());
|
|
|
jb.put("grade_content", upnsDoctorScoreDO.getGrade_content() == null ? "0": upnsDoctorScoreDO.getGrade_content());
|
|
|
jb.put("crt_date", DateUtil.dateToStrLong(DateUtil.getNow()));
|
|
|
}catch (Exception e){
|
|
|
errorFlag = true;
|
|
|
saveErrorLog(upid,"7",upnsDoctorScoreDO.getId(),"医生评价信息格式错误",2);
|
|
|
dataError++;
|
|
|
logger.error(e.toString());
|
|
|
}
|
|
|
if(!errorFlag){
|
|
|
JSONArray jsonArray = new JSONArray();
|
|
|
jsonArray.add(jb);
|
|
|
res = postToInter(token,api, jsonArray,url);
|
|
|
JSONObject resJson = (JSONObject) JSONObject.parse(res);
|
|
|
if("200".equals(resJson.get("msg").toString())){
|
|
|
success++;
|
|
|
}else{
|
|
|
saveErrorLog(upid,"7",upnsDoctorScoreDO.getId(),res,2);
|
|
|
error++;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
String resInfo = "此次共上传：" + total + "条数据，其中成功 ：" + success + "条，上传失败 ： " + error + "条。格式错误："+dataError+"条。";
|
|
|
saveUpLog(upid,"7",DateUtil.stringToDate(startDate,"yyyy-MM-dd HH:mm:ss"),DateUtil.stringToDate(endDate,"yyyy-MM-dd HH:mm:ss"),success,error,dataError,resInfo);
|
|
|
|
|
|
return resInfo;
|
|
|
}
|
|
|
|
|
|
// 8 网络咨询服务信息 micc.upNsOnlineAsk --- 完成
|
|
|
public String upNsOnlineAsk(String startDate, String endDate,String keyId) throws Exception {
|
|
|
String url = getUrl();
|
|
|
String api = "micc.upNsOnlineAsk";
|
|
|
String upid = getCode();
|
|
|
String token = upNsUserToken(url);
|
|
|
String res = "";
|
|
|
int success = 0;
|
|
|
int error = 0;
|
|
|
int dataError = 0;
|
|
|
int total;
|
|
|
|
|
|
List<BaseNsOnlineAskDO> list = baseNsOnlineAskService.findAllByDate(startDate,endDate);
|
|
|
BaseNsOnlineAskDO baseNsOnlineAskDO;
|
|
|
total = list.size();
|
|
|
|
|
|
|
|
|
for(int i=0; i<total; i++) {
|
|
|
|
|
|
JSONObject jb = new JSONObject();
|
|
|
Boolean errorFlag = false;
|
|
|
baseNsOnlineAskDO = list.get(i);
|
|
|
try {
|
|
|
//基于科室转换成国家诊疗科目代码
|
|
|
String[] dept = depToSubject(baseNsOnlineAskDO.getVisitDeptCode());
|
|
|
String visitDocCode = achNsDoctorRecord(baseNsOnlineAskDO.getVisitDocCode());
|
|
|
jb.put("id_online_ask", orgCode+"_"+ baseNsOnlineAskDO.getIdOnlineAsk());
|
|
|
jb.put("net_service_code", baseNsOnlineAskDO.getNetServiceCode());
|
|
|
jb.put("med_class_code", baseNsOnlineAskDO.getMedClassCode());
|
|
|
jb.put("med_pop_code", baseNsOnlineAskDO.getMedClassCode());
|
|
|
jb.put("org_name",orgName);
|
|
|
jb.put("org_code", orgCode);
|
|
|
jb.put("cd_orgSub", orgSub);
|
|
|
jb.put("cd_area", orgArea);
|
|
|
jb.put("visit_doc_name", baseNsOnlineAskDO.getVisitDocName() == null? "0": baseNsOnlineAskDO.getVisitDocName());
|
|
|
jb.put("visit_doc_id_no", baseNsOnlineAskDO.getVisitDocIdNo() == null? "0":baseNsOnlineAskDO.getVisitDocIdNo());
|
|
|
jb.put("visit_doc_code", visitDocCode);
|
|
|
jb.put("visit_dept_code", dept.length>=1?dept[0]:"");
|
|
|
jb.put("visit_dept_name", dept.length>=2?dept[1]:"");
|
|
|
jb.put("pt_no", baseNsOnlineAskDO.getPtNo() == null? "0": baseNsOnlineAskDO.getPtNo());
|
|
|
jb.put("pt_age", IdCardUtil.getAgeForIdcard(baseNsOnlineAskDO.getPtAge()));
|
|
|
jb.put("cost_type", baseNsOnlineAskDO.getCostType());
|
|
|
jb.put("pt_birthdate", baseNsOnlineAskDO.getPtBirthdate() == null? "":baseNsOnlineAskDO.getPtBirthdate());
|
|
|
jb.put("ge_code", baseNsOnlineAskDO.getGeCode() == null? "0": baseNsOnlineAskDO.getGeCode());
|
|
|
jb.put("pt_tel", baseNsOnlineAskDO.getPtTel() == null ? "0": baseNsOnlineAskDO.getPtTel());
|
|
|
jb.put("card_type", baseNsOnlineAskDO.getCardType());
|
|
|
jb.put("id_no", baseNsOnlineAskDO.getIdNo() == null? "0": baseNsOnlineAskDO.getIdNo());
|
|
|
jb.put("pt_district", baseNsOnlineAskDO.getPtDistrict() == null?"": baseNsOnlineAskDO.getPtDistrict());
|
|
|
jb.put("apply_time", baseNsOnlineAskDO.getApplyTime() ==null?"1900-01-01": baseNsOnlineAskDO.getApplyTime());
|
|
|
jb.put("visit_time", baseNsOnlineAskDO.getVisitTime() ==null?"1900-01-01": baseNsOnlineAskDO.getVisitTime());
|
|
|
jb.put("visit_finish_time", baseNsOnlineAskDO.getVisitFinishTime() ==null?"1900-01-01": baseNsOnlineAskDO.getVisitFinishTime());
|
|
|
jb.put("complaint_content", baseNsOnlineAskDO.getComplaintContent());
|
|
|
jb.put("proc_file", baseNsOnlineAskDO.getProcFile());
|
|
|
jb.put("price", baseNsOnlineAskDO.getPrice());
|
|
|
jb.put("fg_reply", baseNsOnlineAskDO.getFgReply());
|
|
|
jb.put("crt_time", DateUtil.dateToStrLong(DateUtil.getNow()));
|
|
|
}catch (Exception e){
|
|
|
errorFlag = true;
|
|
|
saveErrorLog(upid,"8",baseNsOnlineAskDO.getId(),"网络咨询服务信息格式错误",2);
|
|
|
dataError++;
|
|
|
logger.error(e.toString());
|
|
|
}
|
|
|
|
|
|
if(!errorFlag){
|
|
|
JSONArray jsonArray = new JSONArray();
|
|
|
jsonArray.add(jb);
|
|
|
String str = jb.toJSONString();
|
|
|
res = postToInter(token,api, jsonArray,url);
|
|
|
|
|
|
JSONObject resJson = (JSONObject) JSONObject.parse(res);
|
|
|
if("200".equals(resJson.get("msg").toString())){
|
|
|
success++;
|
|
|
}else{
|
|
|
saveErrorLog(upid,"8",baseNsOnlineAskDO.getId().toString(),res,2);
|
|
|
error++;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
String resInfo = "此次共上传：" + total + "条数据，其中成功 ：" + success + "条，上传失败 ： " + error + "条。格式错误："+dataError+"条。";
|
|
|
|
|
|
saveUpLog(upid,"8",DateUtil.stringToDate(startDate,"yyyy-MM-dd HH:mm:ss"),DateUtil.stringToDate(endDate,"yyyy-MM-dd HH:mm:ss"),success,error,dataError,resInfo);
|
|
|
|
|
|
return resInfo;
|
|
|
}
|
|
|
|
|
|
// 9 网络诊疗服务信息 micc.upNsOnlineMed
|
|
|
public String upNsOnlineMed(String startDate, String endDate,String keyId) throws Exception {
|
|
|
String url = getUrl();
|
|
|
String api = "micc.upNsOnlineMed";
|
|
|
String upid = getCode();
|
|
|
String res = "";
|
|
|
int total = 0;
|
|
|
int success = 0;
|
|
|
int error = 0;
|
|
|
int dataError = 0;
|
|
|
|
|
|
String token = upNsUserToken(url);
|
|
|
|
|
|
BaseNsOnlineMedDO baseNsOnlineMedDO;
|
|
|
List<BaseNsOnlineMedDO> list = baseNsOlineMedService.findAllByDate(startDate,endDate);
|
|
|
|
|
|
|
|
|
total = list.size();
|
|
|
|
|
|
for(int i=0; i<list.size(); i++) {
|
|
|
baseNsOnlineMedDO = list.get(i);
|
|
|
JSONObject jb = new JSONObject();
|
|
|
Boolean errorFlag = false;
|
|
|
try {
|
|
|
//基于科室转换成国家诊疗科目代码
|
|
|
String[] dept = depToSubject(baseNsOnlineMedDO.getVisitDeptCode());
|
|
|
String visitDocCode = achNsDoctorRecord(baseNsOnlineMedDO.getVisitDocCode());
|
|
|
jb.put("id_online_med", orgCode +"_"+ baseNsOnlineMedDO.getIdOnlineMed());
|
|
|
jb.put("net_service_code", baseNsOnlineMedDO.getNetServiceCode());
|
|
|
jb.put("med_class_code", baseNsOnlineMedDO.getMedClassCode() == ""?"1": baseNsOnlineMedDO.getMedClassCode());
|
|
|
jb.put("org_name", orgName);
|
|
|
jb.put("org_code", orgCode);
|
|
|
jb.put("cd_orgSub",orgSub);
|
|
|
jb.put("cd_area",orgArea);
|
|
|
jb.put("visit_doc_name", baseNsOnlineMedDO.getVisitDocName());
|
|
|
jb.put("visit_doc_id_no", baseNsOnlineMedDO.getVisitDocIdNo());
|
|
|
jb.put("visit_doc_code", visitDocCode);
|
|
|
jb.put("visit_subject_code", dept.length>=1?dept[0]:"");
|
|
|
jb.put("visit_ subject _name",dept.length>=2?dept[1]:"");
|
|
|
jb.put("visit_dept_code", dept.length>=1?dept[0]:"");
|
|
|
jb.put("visit_dept_name", dept.length>=2?dept[1]:"");
|
|
|
jb.put("pt_no", baseNsOnlineMedDO.getPtNo());
|
|
|
jb.put("pt_age", IdCardUtil.getAgeForIdcard(baseNsOnlineMedDO.getPtAge()));
|
|
|
jb.put("cost_type", baseNsOnlineMedDO.getCostType());
|
|
|
|
|
|
jb.put("pt_birthdate", baseNsOnlineMedDO.getPtBirthdate());
|
|
|
|
|
|
String sex = IdCardUtil.getSexForIdcard_new(baseNsOnlineMedDO.getGeCode());
|
|
|
jb.put("ge_code", sex=="3"?"9":sex);
|
|
|
|
|
|
jb.put("pt_tel", baseNsOnlineMedDO.getPtTel() ==null?"00000000000": baseNsOnlineMedDO.getPtTel());
|
|
|
jb.put("card_type", baseNsOnlineMedDO.getCardType());
|
|
|
jb.put("id_no", baseNsOnlineMedDO.getIdNo());
|
|
|
jb.put("pt_district", baseNsOnlineMedDO.getPtDistrict());
|
|
|
jb.put("pt_card_type", baseNsOnlineMedDO.getPtCardType());
|
|
|
jb.put("pt_card_no", baseNsOnlineMedDO.getPtCardNo());
|
|
|
|
|
|
|
|
|
jb.put("apply_time", baseNsOnlineMedDO.getApplyTime());
|
|
|
|
|
|
jb.put("visit_time", baseNsOnlineMedDO.getVisitTime());
|
|
|
|
|
|
jb.put("visit_finish_time", baseNsOnlineMedDO.getVisitFinishTime());
|
|
|
|
|
|
jb.put("old_diag_code", baseNsOnlineMedDO.getOldDiagCode());
|
|
|
jb.put("old_diag_name", baseNsOnlineMedDO.getOldDiagName());
|
|
|
jb.put("diag_code", baseNsOnlineMedDO.getDiagCode());
|
|
|
jb.put("diag_name", baseNsOnlineMedDO.getDiagName());
|
|
|
jb.put("diseases_type", baseNsOnlineMedDO.getDiseasesType() == null ? "1": baseNsOnlineMedDO.getDiseasesType());
|
|
|
jb.put("complaint_content", baseNsOnlineMedDO.getComplaintContent());
|
|
|
jb.put("proc_file", baseNsOnlineMedDO.getProcFile());
|
|
|
jb.put("price", baseNsOnlineMedDO.getPrice());
|
|
|
jb.put("fg_reply", baseNsOnlineMedDO.getFgReply());
|
|
|
jb.put("crt_time", DateUtil.dateToStrLong(DateUtil.getNow()));
|
|
|
}catch (Exception e){
|
|
|
errorFlag = true;
|
|
|
saveErrorLog(upid,"9", baseNsOnlineMedDO.getId(),"网络诊疗服务信息格式错误",1);
|
|
|
dataError++;
|
|
|
logger.error(e.toString());
|
|
|
}
|
|
|
if(!errorFlag){
|
|
|
JSONArray jsonArray = new JSONArray();
|
|
|
jsonArray.add(jb);
|
|
|
res = postToInter(token,api, jsonArray,url);
|
|
|
|
|
|
JSONObject resJson = (JSONObject) JSONObject.parse(res);
|
|
|
if("200".equals(resJson.get("msg").toString())){
|
|
|
success++;
|
|
|
}else{
|
|
|
saveErrorLog(upid,"9", baseNsOnlineMedDO.getId(),res,2);
|
|
|
error++;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
}
|
|
|
String resInfo = "此次共上传：" + total + "条数据，其中成功 ：" + success + "条，上传失败 ： " + error + "条。格式错误："+dataError+"条。";
|
|
|
saveUpLog(upid,"9",DateUtil.stringToDate(startDate,"yyyy-MM-dd HH:mm:ss"),DateUtil.stringToDate(endDate,"yyyy-MM-dd HH:mm:ss"),success,error,dataError,resInfo);
|
|
|
|
|
|
return resInfo;
|
|
|
}
|
|
|
|
|
|
// 10 电子处方表 micc.upPrescription --- 完成
|
|
|
public String upPrescription(String startDate, String endDate,String keyId) throws Exception {
|
|
|
String url = getUrl();
|
|
|
String api = "micc.upPrescription";
|
|
|
String upid =getCode();
|
|
|
String res = "";
|
|
|
int total = 0;
|
|
|
int success = 0;
|
|
|
int error = 0;
|
|
|
int dataError = 0;
|
|
|
|
|
|
String token = upNsUserToken(url);
|
|
|
|
|
|
BaseNsPrescriptionDO baseNsPrescriptionDO;
|
|
|
List<BaseNsPrescriptionDO> list = baseNsPrescriptionAService.findAllByDate(startDate,endDate);
|
|
|
|
|
|
total = list.size();
|
|
|
|
|
|
for(int i=0; i<total; i++) {
|
|
|
baseNsPrescriptionDO = list.get(i);
|
|
|
JSONObject jb = new JSONObject();
|
|
|
Boolean errorFlag = false;
|
|
|
|
|
|
try {
|
|
|
//基于科室转换成国家诊疗科目代码
|
|
|
String[] dept = depToSubject(baseNsPrescriptionDO.getPresDeptCode());
|
|
|
String visitDocCode = achNsDoctorRecord(baseNsPrescriptionDO.getPresDocCode());
|
|
|
String trialDocCode = achNsDoctorRecord(baseNsPrescriptionDO.getTrialDocCode());
|
|
|
jb.put("id_prescription", orgCode +"_"+ baseNsPrescriptionDO.getIdPrescription());
|
|
|
jb.put("pres_no", baseNsPrescriptionDO.getPresNo() == null?"0": baseNsPrescriptionDO.getPresNo());
|
|
|
jb.put("pres_class_code", baseNsPrescriptionDO.getPresClassCode());
|
|
|
jb.put("pres_class_name", baseNsPrescriptionDO.getPresClassName());
|
|
|
jb.put("pt_id", baseNsPrescriptionDO.getPtId());
|
|
|
jb.put("med_rd_no", baseNsPrescriptionDO.getMedRdNo());
|
|
|
jb.put("med_class_code", baseNsPrescriptionDO.getMedClassCode());
|
|
|
jb.put("med_class_name", baseNsPrescriptionDO.getMedClassName());
|
|
|
jb.put("pt_no", baseNsPrescriptionDO.getPtNo());
|
|
|
jb.put("ge_code", baseNsPrescriptionDO.getGeCode());
|
|
|
jb.put("pt_age",baseNsPrescriptionDO.getPtAge());
|
|
|
jb.put("birthday", baseNsPrescriptionDO.getBirthday() == null?"": baseNsPrescriptionDO.getBirthday());
|
|
|
jb.put("card_type", baseNsPrescriptionDO.getCardType());
|
|
|
jb.put("id_no", baseNsPrescriptionDO.getIdNo());
|
|
|
jb.put("guarder_name", baseNsPrescriptionDO.getGuarderName());
|
|
|
jb.put("guarder_no", baseNsPrescriptionDO.getGuarderNo());
|
|
|
jb.put("pt_tel", baseNsPrescriptionDO.getPtDistrict() == null?"": baseNsPrescriptionDO.getPtDistrict());
|
|
|
jb.put("pt_district", baseNsPrescriptionDO.getPtDistrict() == null?"": baseNsPrescriptionDO.getPtDistrict());
|
|
|
jb.put("allergic_history", baseNsPrescriptionDO.getAllergicHistory());
|
|
|
jb.put("cost_type", baseNsPrescriptionDO.getCostType());
|
|
|
jb.put("ins_class_code", baseNsPrescriptionDO.getInsClassCode());
|
|
|
jb.put("ins_class_name", baseNsPrescriptionDO.getMedClassName());
|
|
|
jb.put("org_code", orgCode);
|
|
|
jb.put("org_name",orgName);
|
|
|
jb.put("pres_subject_code", dept.length>=1?dept[0]:"");
|
|
|
jb.put("pres_subject_name", dept.length>=2?dept[1]:"");
|
|
|
jb.put("pres_dept_code", baseNsPrescriptionDO.getPresDeptCode() == null?"0": baseNsPrescriptionDO.getPresDeptCode());
|
|
|
jb.put("pres_dept_name", baseNsPrescriptionDO.getPresDeptName() == null?"0": baseNsPrescriptionDO.getPresDeptName());
|
|
|
jb.put("pres_time", baseNsPrescriptionDO.getPresTime() == null?"1900-01-01 00:00:00":baseNsPrescriptionDO.getPresTime());
|
|
|
jb.put("pres_doc_code", visitDocCode);
|
|
|
jb.put("pres_doc_name", baseNsPrescriptionDO.getPresDocName() == null?"0": baseNsPrescriptionDO.getPresDocName());
|
|
|
jb.put("pres_doc_id_no", baseNsPrescriptionDO.getPresDocIdNo() == null?"0": baseNsPrescriptionDO.getPresDocIdNo());
|
|
|
jb.put("trial_doc_code", trialDocCode);
|
|
|
jb.put("trial_doc_name", baseNsPrescriptionDO.getTrialDocName() == null?"0": baseNsPrescriptionDO.getTrialDocName());
|
|
|
jb.put("trial_doc_id_no", baseNsPrescriptionDO.getTrialDocIdNo() == null?"0": baseNsPrescriptionDO.getTrialDocIdNo());
|
|
|
jb.put("diag_code", baseNsPrescriptionDO.getDiagCode());
|
|
|
jb.put("diag_name", baseNsPrescriptionDO.getDiagName());
|
|
|
jb.put("diseases_type", baseNsPrescriptionDO.getDiseasesType());
|
|
|
jb.put("mobility_flag", baseNsPrescriptionDO.getMobilityFlag());
|
|
|
jb.put("long_medical_flag", baseNsPrescriptionDO.getLongMedicalFlag());
|
|
|
jb.put("pres_effec_days", baseNsPrescriptionDO.getPresEffecDays());
|
|
|
jb.put("total_price", baseNsPrescriptionDO.getTotalPrice() == null? 0 : baseNsPrescriptionDO.getTotalPrice());
|
|
|
jb.put("upload_time", DateUtil.dateToStr(new Date(),"yyyy-MM-dd HH:mm:ss"));
|
|
|
jb.put("pres_photo","");
|
|
|
jb.put("pres_photos_list", "");
|
|
|
jb.put("pres_photos", "");
|
|
|
}catch (Exception e){
|
|
|
errorFlag = true;
|
|
|
saveErrorLog(upid,"10",baseNsPrescriptionDO.getId(),"电子处方表格式错误",1);
|
|
|
dataError++;
|
|
|
logger.error(e.toString());
|
|
|
}
|
|
|
|
|
|
if(!errorFlag){
|
|
|
JSONArray jsonArray = new JSONArray();
|
|
|
jsonArray.add(jb);
|
|
|
res = postToInter(token,api, jsonArray,url);
|
|
|
|
|
|
JSONObject resJson = (JSONObject) JSONObject.parse(res);
|
|
|
if("200".equals(resJson.get("msg").toString())){
|
|
|
success++;
|
|
|
}else{
|
|
|
saveErrorLog(upid,"10",baseNsPrescriptionDO.getId(),res,2);
|
|
|
error++;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
String resInfo = "此次共上传：" + total + "条数据，其中成功 ：" + success + "条，上传失败 ： " + error + "条。格式错误："+dataError+"条";
|
|
|
saveUpLog(upid,"10",DateUtil.stringToDate(startDate,"yyyy-MM-dd HH:mm:ss"),DateUtil.stringToDate(endDate,"yyyy-MM-dd HH:mm:ss"),success,error,dataError,resInfo);
|
|
|
|
|
|
return resInfo;
|
|
|
}
|
|
|
|
|
|
// 11 电子处方_药品明细表 micc.upPrescriptionDrug --- 完成
|
|
|
public String upPrescriptionDrug(String startDate, String endDate,String keyId) throws Exception {
|
|
|
String url = getUrl();
|
|
|
String api = "micc.upPrescriptionDrug";
|
|
|
String upid = getCode();
|
|
|
String token = upNsUserToken(url);
|
|
|
String res = "";
|
|
|
int total = 0;
|
|
|
int success = 0;
|
|
|
int error = 0;
|
|
|
int dataError = 0;
|
|
|
|
|
|
BaseNsPrescriptionDrugDO baseNsPrescriptionDrugDO;
|
|
|
List<BaseNsPrescriptionDrugDO> list = baseNsPrescriptionDrugService.findAllByDate(startDate,endDate);
|
|
|
|
|
|
total = list.size();
|
|
|
|
|
|
for(int i=0; i<total; i++) {
|
|
|
baseNsPrescriptionDrugDO = list.get(i);
|
|
|
JSONObject jb = new JSONObject();
|
|
|
Boolean errorFlag = false;
|
|
|
try {
|
|
|
jb.put("id_prescription_drug",orgCode +"_"+ baseNsPrescriptionDrugDO.getIdPrescriptionDrug());
|
|
|
jb.put("pres_no", baseNsPrescriptionDrugDO.getPresNo() == null? "0": baseNsPrescriptionDrugDO.getPresNo());
|
|
|
jb.put("org_code",orgCode);
|
|
|
jb.put("appr_drug_code", baseNsPrescriptionDrugDO.getApprDrugCode() == null? "0": baseNsPrescriptionDrugDO.getApprDrugCode());
|
|
|
jb.put("appr_drug_name", baseNsPrescriptionDrugDO.getApprDrugName() == null? "0": baseNsPrescriptionDrugDO.getApprDrugName());
|
|
|
jb.put("drug_code", baseNsPrescriptionDrugDO.getApprDrugCode());
|
|
|
jb.put("drug_name", baseNsPrescriptionDrugDO.getApprDrugName());
|
|
|
jb.put("drug_form", baseNsPrescriptionDrugDO.getDrugForm());
|
|
|
jb.put("dosage", baseNsPrescriptionDrugDO.getDosage() == null? 0: baseNsPrescriptionDrugDO.getDosage());
|
|
|
jb.put("dosage_unit", baseNsPrescriptionDrugDO.getDosageUnit() == null? "0": baseNsPrescriptionDrugDO.getDosageUnit());
|
|
|
jb.put("total_dosage", baseNsPrescriptionDrugDO.getTotalDosage() == null? 0: baseNsPrescriptionDrugDO.getTotalDosage());
|
|
|
jb.put("total_dosage_unit", baseNsPrescriptionDrugDO.getTotalDosageUnit() == null? "0": baseNsPrescriptionDrugDO.getTotalDosageUnit());
|
|
|
jb.put("medicine_freq", baseNsPrescriptionDrugDO.getMedicineFreq() == null? "0": baseNsPrescriptionDrugDO.getMedicineFreq());
|
|
|
jb.put("drug_use", baseNsPrescriptionDrugDO.getDrugUse() == null? "0": baseNsPrescriptionDrugDO.getDrugUse());
|
|
|
jb.put("standard_desc", baseNsPrescriptionDrugDO.getStandardDesc() == null? "0": baseNsPrescriptionDrugDO.getStandardDesc());
|
|
|
jb.put("single_price", baseNsPrescriptionDrugDO.getSinglePrice() == null? 0: baseNsPrescriptionDrugDO.getSinglePrice());
|
|
|
jb.put("drug_total_price",baseNsPrescriptionDrugDO.getDrugTotalPrice());
|
|
|
jb.put("comments", baseNsPrescriptionDrugDO.getComments());
|
|
|
jb.put("anti_comments", baseNsPrescriptionDrugDO.getAntiComments());
|
|
|
jb.put("dec_meth_name", baseNsPrescriptionDrugDO.getDecMethName());
|
|
|
}catch (Exception e){
|
|
|
errorFlag = true;
|
|
|
saveErrorLog(upid,"11",baseNsPrescriptionDrugDO.getId(),res,1);
|
|
|
dataError++;
|
|
|
logger.error(e.toString());
|
|
|
}
|
|
|
|
|
|
if(!errorFlag){
|
|
|
JSONArray jsonArray = new JSONArray();
|
|
|
jsonArray.add(jb);
|
|
|
res = postToInter(token,api, jsonArray,url);
|
|
|
|
|
|
JSONObject resJson = (JSONObject) JSONObject.parse(res);
|
|
|
if("200".equals(resJson.get("msg").toString())){
|
|
|
success++;
|
|
|
}else{
|
|
|
saveErrorLog(upid,"11",baseNsPrescriptionDrugDO.getId(),res,2);
|
|
|
error++;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
String resInfo = "此次共上传：" + total + "条数据，其中成功 ：" + success + "条，上传失败 ： " + error + "条。格式错误："+dataError+"条。";
|
|
|
saveUpLog(upid,"11",DateUtil.stringToDate(startDate,"yyyy-MM-dd HH:mm:ss"),DateUtil.stringToDate(endDate,"yyyy-MM-dd HH:mm:ss"),success,error,dataError,resInfo);
|
|
|
return resInfo;
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
//14.数据上传汇总信息
|
|
|
public String upNsInvokeTotal(String startDate, String endDate) throws Exception {
|
|
|
String url = getUrl();
|
|
|
String api = "micc.upNsInvokeTotal";
|
|
|
String upid = getCode();
|
|
|
String token = upNsUserToken(url);
|
|
|
String res = "";
|
|
|
int total = 0;
|
|
|
int success = 0;
|
|
|
int error = 0;
|
|
|
int dataError = 0;
|
|
|
|
|
|
|
|
|
String upAppointCount = upAppointmentOnlineService.findCount(startDate,endDate);
|
|
|
String upMedicalCount = upMedicalOnlineService.findCount(startDate,endDate);
|
|
|
String upnsDoctorRecordCount = upnsDoctorRecordService.findCount(startDate,endDate);
|
|
|
String upnsDoctorScoreCount = upnsDoctorScoreService.findCount(startDate,endDate);
|
|
|
String baseNsOnlineAskCount = baseNsOnlineAskService.findCount(startDate,endDate);
|
|
|
String baseNsPrescriptionDrugCount = baseNsPrescriptionDrugService.findCount(startDate,endDate);
|
|
|
String baseNsPrescriptionCount = baseNsPrescriptionAService.findCount(startDate,endDate);
|
|
|
String baseNsOlineMedCount = baseNsOlineMedService.findCount(startDate,endDate);
|
|
|
|
|
|
|
|
|
JSONObject jb = new JSONObject();
|
|
|
Boolean errorFlag = false;
|
|
|
try {
|
|
|
jb.put("id_ws_invoke_total",upid);
|
|
|
jb.put("org_code", orgCode);
|
|
|
jb.put("org_name",orgName);
|
|
|
jb.put("upAppoint_upload_count", upAppointCount);
|
|
|
jb.put("upMedical_upload_count", upMedicalCount);
|
|
|
jb.put("upnsDoctorRecord_upload_count", upnsDoctorRecordCount);
|
|
|
jb.put("upnsDoctorScore_upload_count", upnsDoctorScoreCount);
|
|
|
jb.put("NsOnlineAsk_upload_count", baseNsOnlineAskCount);
|
|
|
jb.put("NsPrescriptionDrug_upload_count", baseNsPrescriptionDrugCount);
|
|
|
jb.put("NsPrescription_upload_count",baseNsPrescriptionCount);
|
|
|
jb.put("NsOlineMed_upload_count",baseNsOlineMedCount);
|
|
|
|
|
|
jb.put("ywsj", DateUtil.dateToStr(new Date(),"yyyy-MM-dd"));
|
|
|
jb.put("crt_time", DateUtil.dateToStr(new Date(),"yyyy-MM-dd HH:mm:ss"));
|
|
|
|
|
|
|
|
|
}catch (Exception e){
|
|
|
errorFlag = true;
|
|
|
saveErrorLog(upid,"14",upid,res,1);
|
|
|
dataError++;
|
|
|
logger.error(e.toString());
|
|
|
}
|
|
|
logger.info(jb.toString());
|
|
|
if(!errorFlag){
|
|
|
JSONArray jsonArray = new JSONArray();
|
|
|
jsonArray.add(jb);
|
|
|
res = postToInter(token,api, jsonArray,url);
|
|
|
|
|
|
JSONObject resJson = (JSONObject) JSONObject.parse(res);
|
|
|
if("200".equals(resJson.get("msg").toString())){
|
|
|
success++;
|
|
|
}else{
|
|
|
saveErrorLog(upid,"14",upid,res,2);
|
|
|
error++;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
String resInfo = "此次共上传：" + total + "条数据，其中成功 ：" + success + "条，上传失败 ： " + error + "条。格式错误："+dataError+"条。";
|
|
|
saveUpLog(upid,"14",DateUtil.stringToDate(startDate,"yyyy-MM-dd HH:mm:ss"),DateUtil.stringToDate(endDate,"yyyy-MM-dd HH:mm:ss"),success,error,dataError,resInfo);
|
|
|
return resInfo;
|
|
|
}
|
|
|
|
|
|
// 基于医生所在科室，转换成国家诊疗科目代码（中山医院专用）
|
|
|
// 当科室信息在列表中不存在的情况，全部配置为预防保健科
|
|
|
public static String[] depToSubject(String dep){
|
|
|
String[] res = new String[2];
|
|
|
res[0] = "10";
|
|
|
res[1] = "眼科";
|
|
|
|
|
|
if(StringUtils.isNotBlank(dep)){
|
|
|
if("1010".equals(dep)){
|
|
|
res[0] = "3";
|
|
|
res[1] = "内科";
|
|
|
}else if("1154".equals(dep)){
|
|
|
res[0] = "3";
|
|
|
res[1] = "内科";
|
|
|
}
|
|
|
}
|
|
|
|
|
|
return res;
|
|
|
}
|
|
|
|
|
|
//2.5 预约，是否到诊字典转换
|
|
|
public static String fgConvent(String status){
|
|
|
String res ="";
|
|
|
switch (status) {
|
|
|
case "-1":
|
|
|
res = "0";
|
|
|
break;
|
|
|
case "0":
|
|
|
res = "1";
|
|
|
break;
|
|
|
case "1":
|
|
|
res = "1";
|
|
|
break;
|
|
|
case "2":
|
|
|
res = "1";
|
|
|
break;
|
|
|
default:
|
|
|
res = "";
|
|
|
}
|
|
|
return res;
|
|
|
}
|
|
|
|
|
|
// 将上传失败的数据存储到LOG 中，便于后续补传
|
|
|
public void saveErrorLog(String upId,String type, String id, String errorInfo,Integer errorType){
|
|
|
InternetUpErrorLogDO internetUpErrorLogDO = new InternetUpErrorLogDO();
|
|
|
internetUpErrorLogDO.setUpId(upId);
|
|
|
internetUpErrorLogDO.setType(type);
|
|
|
internetUpErrorLogDO.setKeyId(id);
|
|
|
internetUpErrorLogDO.setErrorInfo(errorInfo);
|
|
|
internetUpErrorLogDO.setErrorType(errorType);
|
|
|
internetUpErrorLogService.save(internetUpErrorLogDO);
|
|
|
}
|
|
|
|
|
|
public void saveUpLog(String upid,String code,Date startDate,Date endDate,Integer suc,Integer err,Integer dataErr,String remark){
|
|
|
|
|
|
InternetUpLogDO internetUpLogDO = new InternetUpLogDO();
|
|
|
internetUpLogDO.setId(upid);
|
|
|
internetUpLogDO.setCode(code);
|
|
|
internetUpLogDO.setStartDate(startDate);
|
|
|
internetUpLogDO.setEndDate(endDate);
|
|
|
internetUpLogDO.setCreateDate(new Date());
|
|
|
internetUpLogDO.setSuc(suc);
|
|
|
internetUpLogDO.setErr(err);
|
|
|
internetUpLogDO.setDataErr(dataErr);
|
|
|
internetUpLogDO.setRemark(remark);
|
|
|
|
|
|
internetUpLogDao.save(internetUpLogDO);
|
|
|
}
|
|
|
|
|
|
// 基于中山医院的职务字典，强转为监管平台的字典(该部分过滤掉字典与监管理无法匹配的部分)
|
|
|
public static String[] classToduty(String duty){
|
|
|
String[] res = new String[2];
|
|
|
switch (duty) {
|
|
|
case "1":
|
|
|
res[0] = "231";
|
|
|
res[1] = "主任医师";
|
|
|
break;
|
|
|
case "2":
|
|
|
res[0] = "232";
|
|
|
res[1] = "副主任医师";
|
|
|
break;
|
|
|
case "3":
|
|
|
res[0] = "233";
|
|
|
res[1] = "主治医师";
|
|
|
break;
|
|
|
default:
|
|
|
res[0] = "234";
|
|
|
res[1] = "医师";
|
|
|
}
|
|
|
return res;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 网络图片地址
|
|
|
* @param path
|
|
|
* @return
|
|
|
* @throws Exception
|
|
|
*/
|
|
|
public String getImg(String path)throws Exception{
|
|
|
try{
|
|
|
if(path.contains("http")){
|
|
|
URL url = new URL(path);
|
|
|
DataInputStream dataInputStream = new DataInputStream(url.openStream());
|
|
|
return getBase64FromInputStream(dataInputStream);
|
|
|
}
|
|
|
URL url = new URL(fastdfs_file_url+path);
|
|
|
DataInputStream dataInputStream = new DataInputStream(url.openStream());
|
|
|
return getBase64FromInputStream(dataInputStream);
|
|
|
}catch (Exception e){
|
|
|
logger.error("getImg:"+e.toString());
|
|
|
}
|
|
|
return "";
|
|
|
}
|
|
|
|
|
|
public String getDateString(String date){
|
|
|
String dates[] = date.split("-");
|
|
|
if(dates!=null&&dates.length>0){
|
|
|
if(dates[1].length()<2){
|
|
|
dates[1] = "0"+dates[1];
|
|
|
}
|
|
|
if(dates[2].length()<2){
|
|
|
dates[2] = "0"+dates[2];
|
|
|
}
|
|
|
return dates[0]+"-"+dates[1]+"-"+dates[2];
|
|
|
}
|
|
|
return date;
|
|
|
}
|
|
|
|
|
|
|
|
|
private String getBase64FromInputStream(InputStream is) throws Exception {
|
|
|
// 将图片文件转化为字节数组字符串，并对其进行Base64编码处理
|
|
|
byte[] data = null;
|
|
|
// 读取图片字节数组
|
|
|
try {
|
|
|
ByteArrayOutputStream swapStream = new ByteArrayOutputStream();
|
|
|
byte[] buff = new byte[100];
|
|
|
int rc = 0;
|
|
|
while ((rc = is.read(buff, 0, 100)) > 0) {
|
|
|
swapStream.write(buff, 0, rc);
|
|
|
}
|
|
|
data = swapStream.toByteArray();
|
|
|
} catch (IOException e) {
|
|
|
e.printStackTrace();
|
|
|
} finally {
|
|
|
if (is != null) {
|
|
|
try {
|
|
|
is.close();
|
|
|
} catch (IOException e) {
|
|
|
throw new Exception("输入流关闭异常");
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
//转化方法1
|
|
|
BASE64Encoder encoder = new BASE64Encoder();
|
|
|
return encoder.encodeBuffer(data).trim();
|
|
|
//转化方法2
|
|
|
// return new String(Base64.encodeBase64(data));
|
|
|
}
|
|
|
|
|
|
public String testImg(String path){
|
|
|
return ImgUtils.getImageStr(path);
|
|
|
}
|
|
|
|
|
|
}
|
