update bug

business/base-service/src/main/java/com/yihu/jw/hospital/HospitalDao.java

@@ -20,5 +20,8 @@ public interface HospitalDao extends PagingAndSortingRepository<DmHospitalDO, In
    @Query("from DmHospitalDO t where t.code=?1 and t.del='1'")
    DmHospitalDO findByCode(String code);
    @Query("from DmHospitalDO t where t.level=?1 and t.del='1'")
    List<DmHospitalDO> findByLevel(Integer level);
    boolean existsByCode(String code);
}

common/common-entity/src/main/java/com/yihu/jw/entity/a1entity/MediicineDrugsNumber.java

@@ -0,0 +1,112 @@
package com.yihu.jw.entity.a1entity;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.yihu.jw.entity.UuidIdentityEntityWithOperator;
import org.springframework.data.annotation.CreatedDate;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Table;
import javax.persistence.Transient;
import java.io.Serializable;
import java.util.Date;
import java.util.List;
@Entity
@Table(name = "t_mediicine_drugs_number")
public class MediicineDrugsNumber extends UuidIdentityEntityWithOperator {
    private String orgCode;//机构code
    private String orgName;//机构名称
    private String physicCode;//药品代码
    private String physicName;//药品名称
    private String batchNo;//药品批次
    private String lotNumber;//药品批号
    private Date validTime;//有效期
    private String retailPrice; //价格
    private String storageDept;//库存科室代码
    private String storageDeptName;//库存科室名称
    public String getOrgCode() {
        return orgCode;
    }
    public void setOrgCode(String orgCode) {
        this.orgCode = orgCode;
    }
    public String getOrgName() {
        return orgName;
    }
    public void setOrgName(String orgName) {
        this.orgName = orgName;
    }
    public String getPhysicCode() {
        return physicCode;
    }
    public void setPhysicCode(String physicCode) {
        this.physicCode = physicCode;
    }
    public String getPhysicName() {
        return physicName;
    }
    public void setPhysicName(String physicName) {
        this.physicName = physicName;
    }
    public String getBatchNo() {
        return batchNo;
    }
    public void setBatchNo(String batchNo) {
        this.batchNo = batchNo;
    }
    public String getLotNumber() {
        return lotNumber;
    }
    public void setLotNumber(String lotNumber) {
        this.lotNumber = lotNumber;
    }
    @CreatedDate
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+08:00")
    @Column(name = "valid_time", nullable = false, length = 0,updatable = false)
    public Date getValidTime() {
        return validTime;
    }
    public void setValidTime(Date validTime) {
        this.validTime = validTime;
    }
    public String getRetailPrice() {
        return retailPrice;
    }
    public void setRetailPrice(String retailPrice) {
        this.retailPrice = retailPrice;
    }
    public String getStorageDept() {
        return storageDept;
    }
    public void setStorageDept(String storageDept) {
        this.storageDept = storageDept;
    }
    public String getStorageDeptName() {
        return storageDeptName;
    }
    public void setStorageDeptName(String storageDeptName) {
        this.storageDeptName = storageDeptName;
    }
}

svr/svr-base/src/main/java/com/yihu/jw/base/dao/a2dao/MediicinedrugsNumberDao.java

@@ -0,0 +1,13 @@
package com.yihu.jw.base.dao.a2dao;
import com.yihu.jw.entity.a1entity.MediicineDrugsNumber;
import org.springframework.data.repository.PagingAndSortingRepository;
public interface MediicinedrugsNumberDao extends PagingAndSortingRepository<MediicineDrugsNumber, String> {
}

svr/svr-base/src/main/java/com/yihu/jw/base/endpoint/a4endpoint/MedicineDevicePrintMessageEndpoint.java

@@ -7,6 +7,7 @@ import com.yihu.jw.base.util.ConstantUtils;
import com.yihu.jw.entity.a1entity.MedicineDevicePrintMessage;
import com.yihu.jw.restmodel.web.Envelop;
import com.yihu.jw.restmodel.web.MixEnvelop;
import com.yihu.jw.restmodel.web.PageEnvelop;
import com.yihu.jw.restmodel.web.endpoint.EnvelopRestEndpoint;
import com.yihu.jw.rm.base.BaseRequestMapping;
import io.swagger.annotations.Api;
@@ -50,13 +51,13 @@ public class MedicineDevicePrintMessageEndpoint extends EnvelopRestEndpoint {
    @GetMapping(value = "/selectByCondition")
    @ApiOperation(value = "根据设备名称/设备编码查询设备打印列表")
    public Envelop selectByCondition(
    public PageEnvelop selectByCondition(
            @ApiParam(name = "condition", value = "设备名称/设备编码", required = false)
            @RequestParam(value = "condition") String condition,
            @ApiParam(name = "page", value = "page", required = false)
            @RequestParam(value = "page", required = true)Integer page,
            @ApiParam(name = "size", value = "size", required = false)
            @RequestParam(value = "size", required = true)Integer size) throws Exception {
        return success(printMessageService.selectByCondition(condition,page,size,getUID()));
        return printMessageService.selectByCondition(condition,page,size,getUID());
    }
}

svr/svr-base/src/main/java/com/yihu/jw/base/service/a3service/MedicineOrderService.java

@@ -1228,6 +1228,55 @@ public class MedicineOrderService extends BaseJpaService<Mediicineorder, Mediici
    }
    /**
     * 查询药品批号价格
     *
     * @param orgCode
     * @param lotNumber
     * @param execOperator
     * @return
     */
    public String getPhysicStorageInfo(String orgCode,String lotNumber,String execOperator){
        OauthWlyyConfigDO oauthWlyyConfigDO = oauthWlyyConfigDao.findOne("getPhysicStorageInfo");
        //token获取accesstoken
        List<NameValuePair> params = new ArrayList<>();
        params.add(new BasicNameValuePair("appid", oauthWlyyConfigDO.getAppId()));
        params.add(new BasicNameValuePair("appSecret",oauthWlyyConfigDO.getAppSecret()));
        String res = httpClientUtil.post(oauthWlyyConfigDO.getTokenUrl(),params,"UTF-8");
        String token = null;
        JSONObject rsjson = JSONObject.parseObject(res);
        logger.info("getPhysicStorageInfo token ："+rsjson.toString());
        Integer status = rsjson.getInteger("status");
        if(status==10000){
            //设置入参
            List<NameValuePair> p = new ArrayList<>();
            p.add(new BasicNameValuePair("orgCode", orgCode));
            //设置头部
            token = rsjson.getJSONObject("result").getString("accesstoken");
            Map<String,Object> headerMap = new HashedMap();
            headerMap.put("accesstoken",token);
            String rs = httpClientUtil.headerPost(oauthWlyyConfigDO.getUrl(),p,"UTF-8",headerMap);
            WlyyHttpLogDO wlyyHttpLogDO = new WlyyHttpLogDO();
            wlyyHttpLogDO.setCode("getPhysicStorageInfo");
            wlyyHttpLogDO.setRequest(p.toString());
            wlyyHttpLogDO.setResponse(rs);
            wlyyHttpLogDO.setName("更新取药码状态");
            wlyyHttpLogDO.setStatus("1");
            wlyyHttpLogDO.setCreateTime(new Date());
            httpLogDao.save(wlyyHttpLogDO);
            logger.info("getPhysicStorageInfo："+rs);
            return  rs;
        }else {
            return null;
        }
    }
    /**
     * 线下订单药柜取药回调发药
     * 线上续方  可只传处方号
@@ -2195,7 +2244,7 @@ public class MedicineOrderService extends BaseJpaService<Mediicineorder, Mediici
                            shipmentLog.setUseRate(mediicineorderdetail.getUseRate());
                            shipmentLog.setUseDose(mediicineorderdetail.getUseDose());
                            shipmentLog.setUseWay(mediicineorderdetail.getUseWay());
                            shipmentLogDao.save(shipmentLog);
                            shipmentLog = shipmentLogDao.save(shipmentLog);
                            shipmentLogs.add(shipmentLog);
                        }
                    }

svr/svr-base/src/main/java/com/yihu/jw/base/service/a3service/MedicinedevicePrintMessageService.java

@@ -2,6 +2,7 @@ package com.yihu.jw.base.service.a3service;
import com.sun.org.apache.bcel.internal.generic.I2F;
import com.yihu.jw.base.dao.a2dao.*;
import com.yihu.jw.base.dao.equipment.WlyyUserAreaDao;
import com.yihu.jw.base.dao.role.RoleDao;
@@ -11,12 +12,16 @@ import com.yihu.jw.entity.a1entity.*;
import com.yihu.jw.entity.base.role.RoleDO;
import com.yihu.jw.entity.base.user.UserDO;
import com.yihu.jw.entity.equipment.WlyyUserAreaDO;
import com.yihu.jw.restmodel.web.Envelop;
import com.yihu.jw.restmodel.web.ListEnvelop;
import com.yihu.jw.restmodel.web.PageEnvelop;
import com.yihu.jw.utils.hibernate.HibenateUtils;
import com.yihu.mysql.query.BaseJpaService;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
@@ -65,12 +70,12 @@ public class MedicinedevicePrintMessageService extends BaseJpaService<Medicinede
        }else {
            MedicineDevicePrintMessage devicePrintMessage = printMessageDao.findDeviceId(printMessage.getDeviceId());
            if (devicePrintMessage!=null){
                printMessage.setInfo(printMessage.getInfo());
                printMessage.setPhone(printMessage.getPhone());
                printMessage.setRemark(printMessage.getRemark());
                printMessage.setRemarkEnd(printMessage.getRemarkEnd());
                printMessage.setPicture(printMessage.getPicture());
                return printMessageDao.save(printMessage);
                devicePrintMessage.setInfo(printMessage.getInfo());
                devicePrintMessage.setPhone(printMessage.getPhone());
                devicePrintMessage.setRemark(printMessage.getRemark());
                devicePrintMessage.setRemarkEnd(printMessage.getRemarkEnd());
                devicePrintMessage.setPicture(printMessage.getPicture());
                return printMessageDao.save(devicePrintMessage);
            }else {
                throw new Exception("该打印设备设置找不到！");
            }
@@ -95,8 +100,8 @@ public class MedicinedevicePrintMessageService extends BaseJpaService<Medicinede
     * @param size
     * @return
     */
    public List<Map<String,Object>> selectByCondition(String condition,Integer page,Integer size,String uuid) throws Exception {
    public PageEnvelop selectByCondition(String condition, Integer page, Integer size, String uuid) throws Exception {
        PageEnvelop envelop = new PageEnvelop();
        UserDO user = userDao.findOne(uuid);
        RoleDO role = roleDao.findOne(user.getRoleId());
        if (role==null){
@@ -140,7 +145,24 @@ public class MedicinedevicePrintMessageService extends BaseJpaService<Medicinede
        }
        System.out.print("sql==="+sql);
        List<Map<String,Object>> mapList = hibenateUtils.createSQLQuery(sql,page,size);
        return mapList;
        String sqlCount = " SELECT count(1) as total from  t_mediicine_device_print_message pm LEFT JOIN t_mediicine_device d ON pm.device_id = d.equ_num where 1=1 and d.belong_community IN ("+conditionSql+") ";
        if (StringUtils.isNoneBlank(condition)){
            sqlCount += " and (d.equ_name LIKE '%"+condition+"%' OR d.equ_num LIKE '%"+condition+"%')";
        }
        List<Map<String,Object>> mapTotals =  hibenateUtils.createSQLQuery(sqlCount);
        Integer total = 0;
        if (mapTotals!=null&&mapTotals.size()!=0){
            Map<String,Object> map = mapTotals.get(0);
            if (map.get("total")!=null){
                total = Integer.parseInt(map.get("total").toString());
            }
        }
        envelop.setDetailModelList(mapList);
        envelop.setPageSize(size);
        envelop.setCurrPage(page);
        envelop.setTotalCount(total);
        return envelop;
    }
}

svr/svr-base/src/main/java/com/yihu/jw/base/service/a3service/MedicinedeviceService.java

@@ -2506,7 +2506,7 @@ public class MedicinedeviceService  extends BaseJpaService<Mediicinedevice, Medi
        if (!StringUtils.isEmpty(equType)) {
            conditionSql += "AND t.equ_type like '%" + equType +"%'\n";
        }
        conditionSql += "AND t.belong_community IS NOT NULL\n";
        conditionSql += "AND t.belong_community IS NOT NULL  order by  t.network_status asc,t.sale_status desc \n";
        //true
//        if (isAllocate) {
//
@@ -4223,9 +4223,10 @@ public class MedicinedeviceService  extends BaseJpaService<Mediicinedevice, Medi
                    "t.equ_num AS equNum,\n" +
                    "t.`merge` AS `merge`,\n" +
                    "t.cargo_state AS cargoState,\n" +
                    "d.specif AS specif,\n" +
                    "t.fault_state AS faultState\n" +
                    "FROM\n" +
                    "\tt_mediicinecabinet_inventory t\n" +
                    "\tt_mediicinecabinet_inventory t left join t_mediicine_drugs d on d.id = t.drug_id  \n" +
                    "WHERE\n" +
                    "\tt.id_device = '" +deviceId + "'\n" +
                    "ORDER BY\n" +

svr/svr-internet-hospital-job/src/main/java/com/yihu/jw/job/MedicineDrugsNumberJob.java

@@ -0,0 +1,34 @@
package com.yihu.jw.job;
import com.yihu.jw.service.channel.MedicineService;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.Trigger;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
/**
 * 同步药品批号
 * Created by Trick on 2019/10/15.
 */
public class MedicineDrugsNumberJob implements Job {
    private static final Logger logger = LoggerFactory.getLogger(MedicineDrugsNumberJob.class);
    @Autowired
    private MedicineService medicineService;
    @Override
    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        logger.info("START========synPhysicStorage========");
        try {
            Trigger trigger =jobExecutionContext.getTrigger();
            System.out.println("执行时间为"+trigger.getNextFireTime());
            medicineService.synPhysicStorage();
            logger.info("END========synPhysicStorage========");
        } catch (Exception e) {
            e.printStackTrace();
            logger.error("END===ERROE===synPhysicStorage,message:"+e.getMessage());
        }
    }
}

svr/svr-internet-hospital-job/src/main/java/com/yihu/jw/repository/job/MediicinedrugsNumberDao.java

@@ -0,0 +1,11 @@
package com.yihu.jw.repository.job;
import com.yihu.jw.entity.a1entity.MediicineDrugsNumber;
import org.springframework.data.repository.PagingAndSortingRepository;
public interface MediicinedrugsNumberDao extends PagingAndSortingRepository<MediicineDrugsNumber, String> {
}

svr/svr-internet-hospital-job/src/main/java/com/yihu/jw/service/channel/MedicineService.java

@@ -2,13 +2,19 @@ package com.yihu.jw.service.channel;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.yihu.jw.entity.a1entity.MediicineDrugsNumber;
import com.yihu.jw.entity.a1entity.Mediicinedrugs;
import com.yihu.jw.entity.a1entity.Mediicineorder;
import com.yihu.jw.entity.hospital.DmHospitalDO;
import com.yihu.jw.entity.hospital.httplog.WlyyHttpLogDO;
import com.yihu.jw.entity.wlyyinfo.OauthWlyyConfigDO;
import com.yihu.jw.hospital.HospitalDao;
import com.yihu.jw.hospital.httplog.dao.WlyyHttpLogDao;
import com.yihu.jw.repository.job.MediicinedrugsDao;
import com.yihu.jw.repository.job.MediicinedrugsNumberDao;
import com.yihu.jw.repository.job.MediicineorderDao;
import com.yihu.jw.util.date.DateUtil;
import com.yihu.jw.util.http.HttpClientUtil;
import com.yihu.jw.wlyy.dao.OauthWlyyConfigDao;
import com.yihu.jw.wlyy.wlyyhttp.WlyyHttpService;
@@ -41,6 +47,10 @@ public class MedicineService {
    private OauthWlyyConfigDao oauthWlyyConfigDao;
    @Autowired
    private WlyyHttpLogDao wlyyHttpLogDao;
    @Autowired
    private HospitalDao hospitalDao;
    @Autowired
    private MediicinedrugsNumberDao mediicinedrugsNumberDao;
    public void getOrgPhysicDict(String orgCode, String name, String orgName, String physicCode) {
@@ -110,6 +120,98 @@ public class MedicineService {
        }
    }
    public void synPhysicStorage(){
        List<DmHospitalDO> dmHospitalDOS = hospitalDao.findByLevel(2);
        mediicinedrugsNumberDao.deleteAll();
        int j =0;
        for (DmHospitalDO dmHospitalDO:dmHospitalDOS){
            String result = getPhysicStorageInfo(dmHospitalDO.getCode(),null,null);
            if (StringUtils.isNoneBlank(result)){
                JSONObject jsonObject = JSONObject.parseObject(result);
                if (jsonObject!=null&&jsonObject.getString("status").equalsIgnoreCase("200")){
                    JSONObject jsonObject1 = jsonObject.getJSONObject("data");
                    if (jsonObject1!=null && jsonObject1.getString("CODE").equalsIgnoreCase("1")){
                        JSONArray jsonArray = jsonObject1.getJSONArray("returnData");
                        if (jsonArray!=null&&jsonArray.size()!=0){
                            JSONArray  array = jsonArray.getJSONArray(0);
                            logger.info("12321321321321:"+array.size());
                            for (int i=0;i<array.size();i++){
                                JSONObject object = array.getJSONObject(i);
                                logger.info("12321321321321:"+object);
                                MediicineDrugsNumber mediicineDrugsNumber = new MediicineDrugsNumber();
                                mediicineDrugsNumber.setOrgCode(dmHospitalDO.getCode());
                                mediicineDrugsNumber.setOrgName(dmHospitalDO.getName());
                                mediicineDrugsNumber.setBatchNo(object.getString("BATCH_NO"));
                                mediicineDrugsNumber.setLotNumber(object.getString("LOT_NUMBER"));
                                mediicineDrugsNumber.setPhysicCode(object.getString("PHYSIC_CODE"));
                                mediicineDrugsNumber.setPhysicName(object.getString("PHYSIC_NAME"));
                                mediicineDrugsNumber.setStorageDept(object.getString("STORAGE_DEPT"));
                                mediicineDrugsNumber.setStorageDeptName(object.getString("STORAGE_DEPT_NAME"));
                                mediicineDrugsNumber.setValidTime(object.get("VALID_TIME")==null?null: DateUtil.strToDateLong(object.getString("VALID_TIME")));
                                mediicineDrugsNumber.setRetailPrice(object.getString("RETAIL_PRICE"));
                                mediicineDrugsNumber.setCreateTime(new Date());
                                mediicineDrugsNumber.setUpdateTime(new Date());
                                mediicinedrugsNumberDao.save(mediicineDrugsNumber);
                                logger.info("12321321321321321321321");
                                j++;
                            }
                        }
                    }
                }
            }
        }
        logger.info("同步药品批号"+j+"条！");
    }
    /**
     * 查询药品批号价格
     *
     * @param orgCode 机构编码
     * @param lotNumber 批号
     * @param execOperator 发药人
     * @return
     */
    public String getPhysicStorageInfo(String orgCode,String lotNumber,String execOperator){
        OauthWlyyConfigDO oauthWlyyConfigDO = oauthWlyyConfigDao.findOne("getPhysicStorageInfo");
        //token获取accesstoken
        List<NameValuePair> params = new ArrayList<>();
        params.add(new BasicNameValuePair("appid", oauthWlyyConfigDO.getAppId()));
        params.add(new BasicNameValuePair("appSecret",oauthWlyyConfigDO.getAppSecret()));
        String res = httpClientUtil.post(oauthWlyyConfigDO.getTokenUrl(),params,"UTF-8");
        String token = null;
        JSONObject rsjson = JSONObject.parseObject(res);
        logger.info("getPhysicStorageInfo token ："+rsjson.toString());
        Integer status = rsjson.getInteger("status");
        if(status==10000){
            //设置入参
            List<NameValuePair> p = new ArrayList<>();
            p.add(new BasicNameValuePair("orgCode", orgCode));
            //设置头部
            token = rsjson.getJSONObject("result").getString("accesstoken");
            Map<String,Object> headerMap = new HashedMap();
            headerMap.put("accesstoken",token);
            String rs = httpClientUtil.headerPost(oauthWlyyConfigDO.getUrl(),p,"UTF-8",headerMap);
            WlyyHttpLogDO wlyyHttpLogDO = new WlyyHttpLogDO();
            wlyyHttpLogDO.setCode("getPhysicStorageInfo");
            wlyyHttpLogDO.setRequest(p.toString());
            wlyyHttpLogDO.setResponse(rs);
            wlyyHttpLogDO.setName("更新取药码状态");
            wlyyHttpLogDO.setStatus("1");
            wlyyHttpLogDO.setCreateTime(new Date());
            wlyyHttpLogDao.save(wlyyHttpLogDO);
            logger.info("getPhysicStorageInfo："+rs);
            return rs;
        }else {
            return null;
        }
    }
    public void syncPrescriptionStatus() {
        List<Mediicineorder> mediicineorderList = mediicineorderDao.findMediicineorderBySellState("0");
        int i=0;
@@ -120,6 +222,14 @@ public class MedicineService {
                if (resObj.getString("status").equalsIgnoreCase("200")){
                    JSONObject object = resObj.getJSONObject("data");
                    String code = object.getString("RECIPE_STATUS_CODE");
                    String  chargeCode = object.getString("CHARGE_STATUS_CODE");
                    if (chargeCode.equalsIgnoreCase("0")){
                        mediicineorder.setSellState("-1");
                        mediicineorder.setShippingEqu("线下药房");
                        mediicineorder.setShippingTime(new Date());
                        mediicineorderDao.save(mediicineorder);
                        i++;
                    }
                    if (code.equalsIgnoreCase("5")){
                        mediicineorder.setSellState("-1");
                        mediicineorder.setShippingEqu("线下药房");

svr/svr-internet-hospital-job/src/main/java/com/yihu/jw/service/channel/SyncWlyyHospitalService.java

@@ -3,8 +3,7 @@ package com.yihu.jw.service.channel;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.jhlabs.image.WoodFilter;
import com.yihu.jw.entity.base.org.BaseOrgDO;
import com.yihu.jw.entity.hospital.DmHospitalDO;
import com.yihu.jw.entity.hospital.consult.WlyyHospitalSysDictDO;
import com.yihu.jw.entity.hospital.team.WlyyAdminTeamDO;
@@ -13,11 +12,9 @@ import com.yihu.jw.hospital.HospitalDao;
import com.yihu.jw.hospital.dict.WlyyHospitalSysDictDao;
import com.yihu.jw.hospital.team.dao.WlyyAdminTeamDao;
import com.yihu.jw.hospital.team.dao.WlyyAdminTeamMemberDao;
import com.yihu.jw.utils.StringUtil;
import com.yihu.jw.wlyy.service.WlyyBusinessService;
import com.yihu.jw.wlyy.wlyyhttp.WlyyHttpService;
import org.apache.commons.collections.map.HashedMap;
import org.apache.commons.lang.time.DateFormatUtils;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

svr/svr-internet-hospital-job/src/main/java/com/yihu/jw/web/quota/JobController.java

@@ -17,6 +17,7 @@ import com.yihu.jw.job.ykyy.UpdateStatusByPayTimeJob;
import com.yihu.jw.job.ykyy.YkyyDataUploadJob;
import com.yihu.jw.repository.job.QuartzJobConfigDao;
import com.yihu.jw.restmodel.web.ObjEnvelop;
import com.yihu.jw.service.channel.MedicineService;
import com.yihu.jw.service.channel.PrescriptionStatusUpdateService;
import com.yihu.jw.service.channel.RemindDoctorService;
import com.yihu.jw.service.channel.SyncWlyyHospitalService;
@@ -90,6 +91,8 @@ public class JobController extends BaseController {
    private RemindDoctorService remindDoctorService;
    @Autowired
    private SyncWlyyHospitalService syncWlyyHospitalService;
    @Autowired
    private MedicineService medicineService;
    @Autowired
    public JobController(JobService jobService, QuartzHelper quartzHelper) {
@@ -174,6 +177,15 @@ public class JobController extends BaseController {
                        logger.info("medicine_drugs_job  job exist");
                    }
                    break;
                case "syn_physic_storage":
                    if (!quartzHelper.isExistJob("syn_physic_storage")) {
                        String trigger = SystemConf.getInstance().getSystemProperties().getProperty("syn_physic_storage");
                        quartzHelper.addJob(MedicineDrugsNumberJob.class, trigger, "syn_physic_storage", new HashMap<String, Object>());
                        logger.info("syn_physic_storage  job success");
                    } else {
                        logger.info("syn_physic_storage  job exist");
                    }
                    break;
                case "medicine_order_status":
                    if (!quartzHelper.isExistJob("medicine_order_status")) {
                        String trigger = SystemConf.getInstance().getSystemProperties().getProperty("medicine_order_status");
@@ -439,6 +451,17 @@ public class JobController extends BaseController {
            return error(-1, "启动失败");
        }
    }
    @RequestMapping(value = "/synPhysicStorage", method = RequestMethod.POST)
    @ApiOperation("同步药品批号")
    public String synPhysicStorage() {
        try {
            medicineService.synPhysicStorage();
            return write(200, "启动成功");
        } catch (Exception e) {
            error(e);
            return error(-1, "启动失败");
        }
    }
    @RequestMapping(value = "/internetUpload", method = RequestMethod.GET)
    @ApiOperation("监管平台测试")

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

@@ -29,5 +29,8 @@ uncheck_prescription_notice_job=0 */1 * * * ?
medicine_drugs_job = 0 0 5 * * ? *
syn_physic_storage = 0 0 4 * * ? *
medicine_order_status=0 * * * * ? *