广告投放设备

common/common-entity/src/main/java/com/yihu/jw/entity/adv/AdvertisementLaunchDO.java

@@ -0,0 +1,36 @@
package com.yihu.jw.entity.adv;
import com.yihu.jw.entity.UuidIdentityEntityWithOperator;
import javax.persistence.Entity;
import javax.persistence.Table;
import java.io.Serializable;
@Entity
@Table(name = "adv_launch")
public class AdvertisementLaunchDO extends UuidIdentityEntityWithOperator implements Serializable {
    /*
    广告id
     */
    private String advId;
    /*
    设备id
     */
    private String devId;
    public String getAdvId() {
        return advId;
    }
    public void setAdvId(String advId) {
        this.advId = advId;
    }
    public String getDevId() {
        return devId;
    }
    public void setDevId(String devId) {
        this.devId = devId;
    }
}

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

@@ -0,0 +1,30 @@
package com.yihu.jw.base.dao.a2dao;
import com.yihu.jw.entity.a1entity.Mediicineorder;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.PagingAndSortingRepository;
import java.util.Date;
public interface MedicineorderDao extends PagingAndSortingRepository<Mediicineorder, Long>, JpaSpecificationExecutor<Mediicineorder> {
    //统计时间段的销售额
    @Query("select sum(a.amount) from Mediicineorder a where a.prescribeTime >=?1 and a.prescribeTime<=?2")
    float getsumamount(Date beg , Date end);
    //统计时间段的天的订单数量
    @Query("select count(1) from Mediicineorder a where a.prescribeTime >= ?1 and a.prescribeTime<=?2")
    int getcount(Date beg , Date end);
    @Query("select a from Mediicineorder a where a.prescribeNum = ?1")
    Mediicineorder findMediicineorderByPrescribeNum(String prescribeNum);
    @Query("select a from Mediicineorder a where a.id=?1")
    Mediicineorder findById(String id);
    @Query("select a from Mediicineorder a where a.orderNum=?1")
    Mediicineorder findByOrderNum(String order);
}

svr/svr-base/src/main/java/com/yihu/jw/base/dao/advertisement/AdvPlaySetDAO.java

@@ -1,12 +0,0 @@
package com.yihu.jw.base.dao.advertisement;//package com.yihu.jw.base.dao.advertisement;
//
//import com.yihu.jw.restmodel.advertisement.AdvPlaySetVo;
//import org.springframework.data.jpa.repository.Query;
//import org.springframework.data.repository.PagingAndSortingRepository;
//
//import java.util.List;
//
//public interface AdvPlaySetDAO extends PagingAndSortingRepository<AdvPlaySetVo,String> {
//    @Query(value = "select * from adv_play_set",nativeQuery = true)
//    List<AdvPlaySetVo> lists();
//}

svr/svr-base/src/main/java/com/yihu/jw/base/dao/advertisement/AdvertisementLaunchDAO.java

@@ -0,0 +1,11 @@
package com.yihu.jw.base.dao.advertisement;
import com.yihu.jw.entity.adv.AdvertisementLaunchDO;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.PagingAndSortingRepository;
public interface AdvertisementLaunchDAO extends PagingAndSortingRepository<AdvertisementLaunchDO, String>, JpaSpecificationExecutor<AdvertisementLaunchDO> {
}

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

@@ -1,41 +1,44 @@
package com.yihu.jw.base.endpoint.a4endpoint;
import com.yihu.jw.base.service.a3service.MedOrderService;
import com.yihu.jw.base.service.a3service.MedicineDrugsService;
import com.yihu.jw.entity.a1entity.Mediicinedrugs;
import com.yihu.jw.entity.a1entity.Mediicineorder;
import com.yihu.jw.entity.a1entity.Mediicineorderdetail;
import com.yihu.jw.restmodel.web.Envelop;
import com.yihu.jw.restmodel.web.endpoint.EnvelopRestEndpoint;
import com.yihu.jw.rm.base.BaseRequestMapping;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
import java.util.Map;
@RestController
@RequestMapping(value = BaseRequestMapping.BaseOrder.PREFIX)
@Api(value = "订单续方管理",description = "订单续方管理" ,tags = "MedOrder - 续方管理服务接口")
public class MedOrderEndpoint extends EnvelopRestEndpoint {
public class MedicineOrderDrugsEndpoint extends EnvelopRestEndpoint {
    @Autowired
    MedOrderService medOrderService;
    @Autowired
    MedicineDrugsService medicineDrugsService;
    @PostMapping(value = "/baseOrder/open/renew")
    @PostMapping(value = "/open/renew")
    @ApiOperation(value = "接收续方订单接口",notes = "接收续方订单接口" )
    public Envelop renew(@ApiParam(name = "jsonData",value = "json数据",required = true)
                                @RequestParam(value = "jsonData",required = true)String jsonData){
        Map <String,Object>map =medOrderService.saveOrder(jsonData);
        Mediicineorder mediicineorder=(Mediicineorder)map.get("order");
        Iterable<Mediicineorderdetail> mediicineorderdetail= (List<Mediicineorderdetail>) map.get("drugs");
        if (map.size()>0&&mediicineorder!=null&&mediicineorderdetail!=null) {
        Object mediicinedrugs= map.get("drugs");
        if (map.size()>0&&mediicineorder!=null&&mediicinedrugs!=null) {
            return success(map);
        }
        return failed("处方已存在",500);
    }
}

svr/svr-base/src/main/java/com/yihu/jw/base/endpoint/adv/AdvertisementPuttingAdminEndPoint.java

@@ -2,6 +2,7 @@ package com.yihu.jw.base.endpoint.adv;
import com.alibaba.fastjson.JSONObject;
import com.yihu.jw.base.service.advrtisement.AdvertisementLaunchService;
import com.yihu.jw.base.service.advrtisement.AdvrtisementService;
import com.yihu.jw.base.util.ConstantUtils;
import com.yihu.jw.entity.adv.AdvertisementPuttingAdminDO;
@@ -14,6 +15,8 @@ import com.yihu.jw.rm.adv.AdvsementMapping;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.apache.commons.lang.StringEscapeUtils;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
@@ -27,6 +30,8 @@ import java.util.List;
public class AdvertisementPuttingAdminEndPoint extends EnvelopRestEndpoint {
    @Autowired
    AdvrtisementService advrtisementService;
    @Autowired
    AdvertisementLaunchService launchService;
    @GetMapping(value = AdvsementMapping.AdvsementReusetMapping.DELADVERTISEMENT)
@@ -54,11 +59,17 @@ public class AdvertisementPuttingAdminEndPoint extends EnvelopRestEndpoint {
    @GetMapping(value = AdvsementMapping.AdvsementReusetMapping.LAUNCHADVERTISEMENT )
    @ApiOperation(value = "投放广告")
    public String launchAdvertisement(@RequestParam String id){
        if (id==null||"".equals(id)){
            return "请确认该广告是否存在！";
    public Envelop launchAdvertisement(@ApiParam(name = "advIds",value = "广告id,多个中间用,隔开")
                                          @RequestParam(value = "advIds",required = true) String advIds,
                                      @ApiParam(name = "devIds",value = "设备id,多个中间用,隔开",required = true)
                                      @RequestParam(value = "ids",required = true)String devIds){
        if (StringUtils.isBlank(advIds)){
            return failed("请确认该广告是否存在！");
        }
        if (StringUtils.isBlank(devIds)){
            return failed("请选择要投放到的设备");
        }
        return advrtisementService.updateLaunchStatus(id);
        return success(advrtisementService.updateLaunchStatus(advIds,devIds));
    }
    @GetMapping(value = AdvsementMapping.AdvsementReusetMapping.FORBIDDENADVERTISEMENT)

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

@@ -2,33 +2,28 @@ package com.yihu.jw.base.service.a3service;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.yihu.jw.base.dao.a2dao.MediicinedrugsDao;
import com.yihu.jw.base.dao.a2dao.MediicineorderDao;
import com.yihu.jw.base.dao.a2dao.MedicineorderDao;
import com.yihu.jw.base.dao.a2dao.MediicineorderdetailDao;
import com.yihu.jw.entity.a1entity.Mediicinedrugs;
import com.yihu.jw.entity.a1entity.Mediicineorder;
import com.yihu.jw.entity.a1entity.Mediicineorderdetail;
import com.yihu.jw.restmodel.web.Envelop;
import com.yihu.jw.utils.hibernate.HibenateUtils;
import com.yihu.mysql.query.BaseJpaService;
import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;;
import java.util.*;
import org.springframework.transaction.annotation.Transactional;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@Transactional
@Service
public class MedOrderService  {
public class MedOrderService {
    private static Logger logger = LoggerFactory.getLogger(MedOrderService.class);
    @Autowired
    MediicineorderDao mediicineorderDao;
    @Autowired
    MediicinedrugsDao mediicinedrugsDao;
    MedicineorderDao mediicineorderDao;
    @Autowired
    MediicineorderdetailDao mediicineorderdetailDao;
    /**
@@ -74,12 +69,12 @@ public class MedOrderService  {
            mediicineorder.setDeptName(params.getString("rx_doctor_name"));
            mediicineorder.setDoctorAdvice(params.getString(" rx_doctoradvice"));
            mediicineorder.setAllergyInfo(params.getString(" rx_allergy_info"));
            Mediicineorder ord=mediicineorderDao.save(mediicineorder);
            JSONArray jsonArray=params.getJSONArray("rx_drugs");
            List<Mediicineorderdetail> list=new ArrayList<>();
            Mediicineorderdetail mediicineorderdetail;
            List<Mediicineorderdetail> mediicineorderdetailList=new ArrayList<>();
            Mediicineorderdetail mediicineorderdetail=new Mediicineorderdetail();
            for (int i = 0; i <jsonArray.size() ; i++) {
                JSONObject jsonObject=jsonArray.getJSONObject(i);
                mediicineorderdetail=new Mediicineorderdetail();
                mediicineorderdetail.setId(jsonObject.getString("drug_id"));
                mediicineorderdetail.setDrugSku(jsonObject.getString("drug_sku "));
                mediicineorderdetail.setDrugCode(jsonObject.getString("drug_code"));
@@ -93,37 +88,15 @@ public class MedOrderService  {
                mediicineorderdetail.setUnit(jsonObject.getString("drug_use_unit"));
                mediicineorderdetail.setUseWayAdd(jsonObject.getString("drug_use_way_add"));
                mediicineorderdetail.setManufactor(jsonObject.getString(" drug_firm_name"));
                list.add(mediicineorderdetail);
                mediicineorderdetail.setIdOrder(ord.getId());
                mediicineorderdetailList.add(mediicineorderdetail);
            }
            Mediicineorder ord=mediicineorderDao.save(mediicineorder);
            Iterable<Mediicineorderdetail> drugs=mediicineorderdetailDao.save(list);
            Iterable<Mediicineorderdetail>mediicineorderdetails= mediicineorderdetailDao.save(mediicineorderdetailList);
            result.put("order",ord);
            result.put("drugs",drugs);
            result.put("drugs",mediicineorderdetails);
            return result;
        }
        return null;
    }
//    public List getOrgPhysicDict1(String jsonData) throws Exception {
//        List<Mediicinedrugs> list=new ArrayList<>();
//        if (StringUtils.isNotBlank(jsonData)){
//            JSONObject params=JSONObject.parseObject(jsonData);
//            JSONArray jsonArray=params.getJSONArray("data");
//            for (int i = 0; i <jsonArray.size() ; i++) {
//                JSONObject jsonObject=jsonArray.getJSONObject(i);
//                Mediicinedrugs mediicinedrugs=new Mediicinedrugs();
//                mediicinedrugs.setDrugCode(jsonObject.getString("physic_code"));
//                mediicinedrugs.setDrugName(jsonObject.getString("physic_name"));
//                mediicinedrugs.setSpecif(jsonObject.getString("physic_spec"));
//                mediicinedrugs.setUnit(jsonObject.getString("dose_unit"));
//                mediicinedrugs.setUseDose(jsonObject.getString("min_dose"));
//                mediicinedrugs.setPrice(jsonObject.getFloat("retail_price"));
//                mediicinedrugs.setDosForm(jsonObject.getString("physic_form"));
//                mediicinedrugs.setDrugClass(jsonObject.getString("subject_class"));
//                list.add(mediicinedrugsDao.save(mediicinedrugs));
//            }
//            return list;
//        }
//        return null;
//    }
}

svr/svr-base/src/main/java/com/yihu/jw/base/service/advrtisement/AdvertisementLaunchService.java

@@ -0,0 +1,13 @@
package com.yihu.jw.base.service.advrtisement;
import com.yihu.jw.base.dao.advertisement.AdvertisementLaunchDAO;
import com.yihu.jw.entity.adv.AdvertisementLaunchDO;
import com.yihu.mysql.query.BaseJpaService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class AdvertisementLaunchService extends BaseJpaService<AdvertisementLaunchDO, AdvertisementLaunchDAO> {
    @Autowired
    AdvertisementLaunchDAO advertisementLaunchDAO;
}

svr/svr-base/src/main/java/com/yihu/jw/base/service/advrtisement/AdvrtisementService.java

@@ -2,9 +2,12 @@ package com.yihu.jw.base.service.advrtisement;
import com.alibaba.fastjson.JSONObject;
import com.ibm.disthub2.impl.formats.Envelop;
import com.yihu.jw.base.dao.advertisement.AdvertisementLaunchDAO;
import com.yihu.jw.base.dao.advertisement.AdvertisementPuttingAdminDAO;
import com.yihu.jw.base.dao.user.UserDao;
import com.yihu.jw.base.util.ConstantUtils;
import com.yihu.jw.entity.adv.AdvertisementLaunchDO;
import com.yihu.jw.entity.adv.AdvertisementPuttingAdminDO;
import com.yihu.jw.entity.base.user.UserDO;
import com.yihu.jw.entity.hospital.consult.WlyyHospitalSysDictDO;
@@ -15,6 +18,7 @@ import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.UUID;
@@ -27,6 +31,8 @@ public class AdvrtisementService extends BaseJpaService<AdvertisementPuttingAdmi
    UserDao userDao;
    @Autowired
    WlyyHospitalSysDictDao wlyyHospitalSysDictDao;
    @Autowired
    AdvertisementLaunchDAO launchDAO;
    //按照分页查询
@@ -64,24 +70,33 @@ public class AdvrtisementService extends BaseJpaService<AdvertisementPuttingAdmi
    }
    //投放
    public String updateLaunchStatus(String id){
        if (advertisementExist(id)==null) {
            return "广告不存在！";
        }
        if (advertisementExist(id).getDel()==1){
            return "广告已删除";
        }
        if (advertisementExist(id).getForbidden()==1){
            return "广告已禁用";
        }
        if (advertisementExist(id).getLaunch()==1){
            advertisementPuttingAdminDAO.updateLaunStatus(id);
            return "已取消投放！";
        }else {
            advertisementPuttingAdminDAO.updateLaunStatusTo1(id);
            return "已投放广告！";
    public String updateLaunchStatus(String advIds, String devIds){
        String[] strings=advIds.split(",");
        List<AdvertisementLaunchDO> list=new ArrayList<>();
        AdvertisementLaunchDO launchDO;
        for (int i = 0; i <strings.length ; i++) {
            if (advertisementExist(strings[i])==null) {
                return  "广告id:"+strings[i]+"不存在！";
            }
            if (advertisementExist(strings[i]).getDel()==1){
                return "广告id:"+strings[i]+"已删除！";
            }
            if (advertisementExist(strings[i]).getForbidden()==1){
                return "广告id:"+strings[i]+"已禁用！";
            }
            if (advertisementExist(strings[i]).getLaunch()==1){
                advertisementPuttingAdminDAO.updateLaunStatus(strings[i]);
                String[] str=devIds.split(",");
                for (int j = 0; j <str.length ; i++) {
                    launchDO=new AdvertisementLaunchDO();
                }
                return "已取消投放！";
            }else {
                advertisementPuttingAdminDAO.updateLaunStatusTo1(strings[i]);
                return "已投放广告！";
            }
        }
        return null;
    }
    //禁用

svr/svr-internet-hospital/src/main/java/com/yihu/jw/hospital/endpoint/mediicine/MedicineOrderDrugsEndpoint.java

@@ -3,6 +3,7 @@ package com.yihu.jw.hospital.endpoint.mediicine;
import com.yihu.jw.entity.a1entity.Mediicinedrugs;
import com.yihu.jw.entity.a1entity.Mediicineorder;
import com.yihu.jw.entity.a1entity.Mediicineorderdetail;
import com.yihu.jw.hospital.service.MedOrderService;
import com.yihu.jw.hospital.service.med.MedicineDrugsService;
import com.yihu.jw.restmodel.web.Envelop;
@@ -17,6 +18,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.List;
import java.util.Map;
@RestController
@@ -34,7 +36,7 @@ public class MedicineOrderDrugsEndpoint extends EnvelopRestEndpoint {
                                @RequestParam(value = "jsonData",required = true)String jsonData){
        Map <String,Object>map =medOrderService.saveOrder(jsonData);
        Mediicineorder mediicineorder=(Mediicineorder)map.get("order");
        Mediicinedrugs mediicinedrugs=(Mediicinedrugs)map.get("drugs");
        Object mediicinedrugs= map.get("drugs");
        if (map.size()>0&&mediicineorder!=null&&mediicinedrugs!=null) {
            return success(map);
        }

svr/svr-internet-hospital/src/main/java/com/yihu/jw/hospital/service/MedOrderService.java

@@ -13,6 +13,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -71,7 +72,9 @@ public class MedOrderService {
            mediicineorder.setDeptName(params.getString("rx_doctor_name"));
            mediicineorder.setDoctorAdvice(params.getString(" rx_doctoradvice"));
            mediicineorder.setAllergyInfo(params.getString(" rx_allergy_info"));
            Mediicineorder ord=mediicineorderDao.save(mediicineorder);
            JSONArray jsonArray=params.getJSONArray("rx_drugs");
            List<Mediicineorderdetail> mediicineorderdetailList=new ArrayList<>();
            Mediicineorderdetail mediicineorderdetail=new Mediicineorderdetail();
            for (int i = 0; i <jsonArray.size() ; i++) {
                JSONObject jsonObject=jsonArray.getJSONObject(i);
@@ -88,11 +91,12 @@ public class MedOrderService {
                mediicineorderdetail.setUnit(jsonObject.getString("drug_use_unit"));
                mediicineorderdetail.setUseWayAdd(jsonObject.getString("drug_use_way_add"));
                mediicineorderdetail.setManufactor(jsonObject.getString(" drug_firm_name"));
                mediicineorderdetail.setIdOrder(ord.getId());
                mediicineorderdetailList.add(mediicineorderdetail);
            }
            Mediicineorder ord=mediicineorderDao.save(mediicineorder);
            Mediicineorderdetail mediicineorderdetail1=mediicineorderdetailDao.save(mediicineorderdetail);
            Iterable<Mediicineorderdetail>mediicineorderdetails= mediicineorderdetailDao.save(mediicineorderdetailList);
            result.put("order",ord);
            result.put("drugs",mediicineorderdetail1);
            result.put("drugs",mediicineorderdetails);
            return result;
        }
        return null;