|
@@ -8,10 +8,16 @@ import java.util.HashMap;
|
|
|
import java.util.List;
|
|
|
import java.util.Map;
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
+import com.alibaba.fastjson.JSONArray;
|
|
|
+import com.alibaba.fastjson.JSONObject;
|
|
|
import com.jfinal.core.Controller;
|
|
|
import com.jfinal.kit.PropKit;
|
|
|
import com.jfinal.plugin.activerecord.Db;
|
|
|
import com.jfinal.plugin.activerecord.Record;
|
|
|
+import com.zskk.service.DataService;
|
|
|
+import com.zskk.service.ServiceFactory;
|
|
|
+import com.zskk.service.ThreadPoolService;
|
|
|
+
|
|
|
import okhttp3.FormBody;
|
|
|
import okhttp3.MediaType;
|
|
|
import okhttp3.OkHttpClient;
|
|
@@ -32,7 +38,61 @@ public class ViewController extends Controller {
|
|
|
List<Record> d = Db.use("connected").find(this.getPara("sqlstr"));
|
|
|
this.renderJson(d);
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
+ public void doone() {
|
|
|
+ DataService dService = ServiceFactory.getService(DataService.class);
|
|
|
+ JSONArray jsonArray = dService.getExamList(1);
|
|
|
+ for (Object object : jsonArray) {
|
|
|
+ JSONObject jsonObject = JSON.parseObject(object.toString());
|
|
|
+ Record record = Db.use("connected").findFirst("select * from viewname where accessionNumber=?", jsonObject.getString("accession_num"));
|
|
|
+ if (record == null) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if (record.getStr("diagnosis") == null && record.getStr("description") == null) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ Map<String, String> params = new HashMap<>();
|
|
|
+ params.put("exam_id", jsonObject.getString("id"));
|
|
|
+ //报告医生姓名
|
|
|
+ params.put("report_doctor_name", record.getStr("reportdoctor"));
|
|
|
+ //报告时间
|
|
|
+ params.put("report_datetime", record.getStr("reportdate"));
|
|
|
+ //审核医生姓名
|
|
|
+ params.put("review_doctor_name", record.getStr("reviewdoctor"));
|
|
|
+ //审核时间
|
|
|
+ params.put("review_datetime", record.getStr("reportdate"));
|
|
|
+ //确认医生姓名
|
|
|
+ params.put("confirm_doctor_name", record.getStr("reviewdoctor"));
|
|
|
+ //确认时间
|
|
|
+ params.put("confirm_datetime", record.getStr("reportdate"));
|
|
|
+ //意见建议
|
|
|
+ params.put("impression", record.getStr("diagnosis"));
|
|
|
+ //影像所见
|
|
|
+ params.put("description", record.getStr("description"));
|
|
|
+ //exams表
|
|
|
+ //申请科室
|
|
|
+ params.put("application_department", record.getStr("department"));
|
|
|
+ //申请医生
|
|
|
+ params.put("application_doctor", record.getStr("clinicaldoctor"));
|
|
|
+ //临床诊断
|
|
|
+ params.put("clin_diag", "");
|
|
|
+ //症状
|
|
|
+ params.put("clin_symp", "");
|
|
|
+ //patient_infos表
|
|
|
+ //患者姓名
|
|
|
+ params.put("name", record.getStr("patientname"));
|
|
|
+ //患者手机号
|
|
|
+ params.put("phone", record.getStr("phone"));
|
|
|
+ //患者身份证号
|
|
|
+ params.put("card_num", record.getStr("idcard"));
|
|
|
+ params.put("report_result", "0");
|
|
|
+ ThreadPoolService tService = ServiceFactory.getService(ThreadPoolService.class);
|
|
|
+ tService.execute(() -> {
|
|
|
+ dService.saveReport(params);
|
|
|
+ });
|
|
|
+ }
|
|
|
+ this.renderText("ok");
|
|
|
+ }
|
|
|
/**
|
|
|
* post请求
|
|
|
* @param url-请求地址
|