Kaynağa Gözat

监管平台数据上报JOB,定时凌晨 1 点进行上传

hill9868 5 yıl önce
ebeveyn
işleme
66d99e9f88

Dosya farkı çok büyük olduğundan ihmal edildi
+ 107 - 34
business/base-service/src/main/java/com/yihu/jw/internet/service/InternetService.java


+ 1 - 1
svr/svr-internet-hospital-job/src/main/java/com/yihu/jw/event/ApplicationEvent.java

@ -36,7 +36,7 @@ public class ApplicationEvent implements ApplicationListener<ContextRefreshedEve
                logger.info("prescriptionStatus_update_job  job exist");
            }
            //互联网医院处方状态更新job
            //互联网医院 监管平台上报 job
            if (!quartzHelper.isExistJob("internet_update_job")) {
                String trigger = SystemConf.getInstance().getSystemProperties().getProperty("internet_update_job");
                quartzHelper.addJob(InternetUpdateJob.class, trigger, "internet_update_job", new HashMap<String, Object>());

+ 1 - 1
svr/svr-internet-hospital-job/src/main/resources/application.yml

@ -56,7 +56,7 @@ FileTempPath:
spring:
  profiles: jwdev
  datasource:
    url: jdbc:mysql://172.26.0.114/base?useUnicode:true&characterEncoding=utf-8&autoReconnect=true
    url: jdbc:mysql://172.26.0.104/base?useUnicode:true&characterEncoding=utf-8&autoReconnect=true
    username: ssgg
    password: ssgg@jkzl2019

+ 3 - 3
svr/svr-internet-hospital-job/src/main/resources/system.properties

@ -1,6 +1,6 @@
#-------------------------共同配置-----------------------------#
# 健康频道状态
prescriptionStatus_update_job=0 */2 * * * ?
#每天0 点触发
internet_update_job=0 */2 * * * ?
#每天1 点触发
internet_update_job=0 0 1 * * ?

+ 2 - 10
svr/svr-internet-hospital/src/main/java/com/yihu/jw/hospital/endpoint/internet/InternetController.java

@ -1,9 +1,7 @@
package com.yihu.jw.hospital.endpoint.internet;
import com.alibaba.fastjson.JSONObject;
import com.yihu.jw.entity.base.org.BaseOrgDO;
import com.yihu.jw.internet.service.InternetService;
import com.yihu.jw.org.service.BaseOrgInfoService;
import com.yihu.jw.restmodel.web.Envelop;
import com.yihu.jw.restmodel.web.ObjEnvelop;
import com.yihu.jw.restmodel.web.endpoint.EnvelopRestEndpoint;
@ -30,9 +28,6 @@ public class InternetController extends EnvelopRestEndpoint {
    @Autowired
    private InternetService internetService;
    @Autowired
    private BaseOrgInfoService baseOrgInfoService;
    @PostMapping(value = "/upNsUserToken")
    @ApiOperation(value = "2.1 获取监管平台token数据")
@ -55,14 +50,11 @@ public class InternetController extends EnvelopRestEndpoint {
    @PostMapping(value = "/upNsOrganBas")
    @ApiOperation(value = "2.2 医院基本信息")
    public ObjEnvelop upNsOrganBas(
            @ApiParam(name = "orgCode", value = "机构编码 350211A1002", required = true)
            @RequestParam(value = "orgCode") String orgCode)throws Exception {
    public ObjEnvelop upNsOrganBas()throws Exception {
        ObjEnvelop env = new ObjEnvelop();
        Map map = new HashMap();
        try {
            BaseOrgDO baseOrgDO = baseOrgInfoService.getBaseOrgByCode(orgCode);
            String res =  internetService.upNsOrganBas(baseOrgDO);
            String res =  internetService.upNsOrganBas();
            JSONObject resJson = (JSONObject) JSONObject.parse(res);
            if("200".equals(resJson.get("msg").toString())) {
                return ObjEnvelop.getSuccess("医院信息更新成功!",res);