|
@@ -39,21 +39,19 @@ public class CovidVaccinateAppointmentService {
|
|
|
private static final SimpleDateFormat SDF = new SimpleDateFormat(DATE_FORMAT);
|
|
|
private static final int GET_DATE_SECTION = 7;
|
|
|
|
|
|
-
|
|
|
@Autowired
|
|
|
public CovidVaccinateAppointmentService(CovidVaccinateAppointmentMapper dao) {
|
|
|
this.dao = dao;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
- * 通过日期区间 或者 预约的姓名 来查找到数据 分页查询
|
|
|
+ * 通过日期区间 或者 预约的姓名 来查找到数据 需要分页
|
|
|
* @param param 包含 name姓名 ExecuteDate预约时间 currentPage PageSize
|
|
|
* @return 指定数据
|
|
|
* */
|
|
|
public ResultVo<Map<String,Object>> queryCovidVaccinateAppointment(CovidVaccinateAppointment param){
|
|
|
- log.info("查询新冠疫苗预约=>操作人:{},查找姓名:{},查找日期:{},页码:{},条数{}", TokenUtil.getTokenUserId(),
|
|
|
- param.getName(),param.getExecuteDate()!=null? DateUtil.formatDatetime(param.getExecuteDate(),DATE_FORMAT): "",
|
|
|
- param.getCurrentPage(),param.getPageSize());
|
|
|
+ log.info("查询新冠疫苗预约=>操作人:{},查询条件:{}", TokenUtil.getTokenUserId(),
|
|
|
+ JSON.toJSONStringWithDateFormat(param,DATE_FORMAT));
|
|
|
IPage<CovidVaccinateAppointment> page = getQueryPage(param);
|
|
|
Map<String, Object> map = new HashMap<>(Capacity.TWO);
|
|
|
if (page.getTotal()>0 || page.getRecords().size()>0){
|
|
@@ -66,7 +64,7 @@ public class CovidVaccinateAppointmentService {
|
|
|
|
|
|
/**
|
|
|
* 查看 可以预约的厂家信息
|
|
|
- * @return 指定数据
|
|
|
+ * @return 返回只能预约的厂家信息
|
|
|
* */
|
|
|
public ResultVo<List<CovidVaccinateFactory>> queryCount() {
|
|
|
log.info("查看可以预约疫苗厂家的信息");
|
|
@@ -74,25 +72,25 @@ public class CovidVaccinateAppointmentService {
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
- * 根据新冠疫苗产品的code来 近七天的阈值
|
|
|
+ * 根据新冠疫苗产品的code来查看,近七天的阈值
|
|
|
* 如果没有这个日期的话 就插入一条
|
|
|
* @param code 产品的code
|
|
|
* @return 返回七天的数据
|
|
|
* */
|
|
|
public ResultVo<List<CovidVaccinateThreshold>> queryChangJiaDuiYingDeYuZhi(Integer code) throws ParseException {
|
|
|
chaRuRiQI(code);
|
|
|
- log.info("查看疫苗产品编码为:{},开始时间:{},结束时间:{}",code,DateUtil.getOffsetDate(1),DateUtil.getOffsetDate(7));
|
|
|
return ResultVoUtil.success(dao.chaKanQiTianYuZhi(code,DateUtil.getOffsetDate(1),DateUtil.getOffsetDate(7)));
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 设置每日阈值人数的限制 要判断一下 第一次创建数据库中没有对应的值那么就插入七天的阈值
|
|
|
- * 如果已经有了 就只插入没有的日期 这个是新冠疫苗的厂家每日阈值的人数
|
|
|
+ * 如果已经有了 就只插入没有的日期 疫苗产品的阈值 在表中取默认值
|
|
|
* @param code 厂家的产品的 code
|
|
|
* */
|
|
|
private void chaRuRiQI(Integer code) throws ParseException {
|
|
|
Date maxDate = dao.changJiaYuZhiDoesItExist(code);
|
|
|
List<Date> dateList = new ArrayList<>();
|
|
|
+ //取到这个表中的默认阈值
|
|
|
int value = dao.chaKanChangJiaMoRenYuZhi(code);
|
|
|
Date date;
|
|
|
for(int i = 1; i<= GET_DATE_SECTION; i++){
|
|
@@ -105,6 +103,7 @@ public class CovidVaccinateAppointmentService {
|
|
|
log.info("新冠疫苗厂家阈值插入=》code:{},添加日期为:{},阈值数:{}", code,DateUtil.formatDatetime(date,DATE_FORMAT),value);
|
|
|
}
|
|
|
}
|
|
|
+ //因为在 查看的时候 也是需要 执行
|
|
|
if (dateList.size()>0) {
|
|
|
dao.chaRuMeiYouDeDate(code,dateList,value);
|
|
|
}
|
|
@@ -145,7 +144,7 @@ public class CovidVaccinateAppointmentService {
|
|
|
* @param param 查询和分页的条件
|
|
|
* @return 返回分页
|
|
|
* */
|
|
|
- public IPage<CovidVaccinateAppointment> getQueryPage(CovidVaccinateAppointment param){
|
|
|
+ public IPage<CovidVaccinateAppointment> getQueryPage(CovidVaccinateAppointment param) {
|
|
|
IPage<CovidVaccinateAppointment> page = new Page<>(param.getCurrentPage(),param.getPageSize());
|
|
|
QueryWrapper<CovidVaccinateAppointment> qw = new QueryWrapper<>();
|
|
|
if (StringUtil.notBlank(param.getName())) {
|
|
@@ -167,14 +166,14 @@ public class CovidVaccinateAppointmentService {
|
|
|
dao.xinZengYiMiao(param);
|
|
|
log.info("插入疫苗=》操作人:{},信息:{}",TokenUtil.getTokenUserId(),JSON.toJSONString(param));
|
|
|
}catch (Exception e){
|
|
|
- return ResultVoUtil.fail(ExceptionEnum.INTERNAL_SERVER_ERROR,"该疫苗名称已存在,无法保存 (¬_¬)");
|
|
|
+ return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR,String.format("<p style='color:red'>【%s】</p>该疫苗名称已存在,添加失败。",param.getName()));
|
|
|
}
|
|
|
return ResultVoUtil.success(param.getId());
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 插入对应的 疫苗的厂家
|
|
|
- * @param param 需要插入的字段有 code主键不允许重复 vaccinateId:对应的疫苗
|
|
|
+ * @param param 需要插入的字段有 code主键不允许重复 vaccinateId:对应的疫苗 ID
|
|
|
* specification:规格 price:金额,name;名字,enableFlag:是否允许预约
|
|
|
* 在插入厂家成功的时候要默认给他一个产品的阈值
|
|
|
* */
|
|
@@ -183,7 +182,7 @@ public class CovidVaccinateAppointmentService {
|
|
|
List<Integer> vaccinesId = dao.changJiaCodePanDuan(param);
|
|
|
for (int i = 0; i < vaccinesId.size(); i++) {
|
|
|
if (vaccinesId.get(i) !=null && vaccinesId.get(i) >0) {
|
|
|
- return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER,String.format("产品编码为【%s】已存在,所属疫苗院内编码为【%s】,【%s】",
|
|
|
+ return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR,String.format("产品编码为<span style='color:#F56C6C'>【%s】</span>已存在,所属疫苗院内编码为<span style='color:#F56C6C'>【%s】</span>,<span style='color:#F56C6C'>【%s】</span>",
|
|
|
param.get(i).getCode(),vaccinesId.get(i),"(๑°3°๑)"));
|
|
|
}
|
|
|
}
|
|
@@ -201,7 +200,7 @@ public class CovidVaccinateAppointmentService {
|
|
|
* 查询全部的疫苗名称
|
|
|
* @return 返回全部的数据
|
|
|
* */
|
|
|
- public ResultVo<List<ZdCovidVaccinate>> chaKanYiMiao(){
|
|
|
+ public ResultVo<List<ZdCovidVaccinate>> chaKanYiMiao() {
|
|
|
return ResultVoUtil.success(dao.chaKanYiMiao());
|
|
|
}
|
|
|
|
|
@@ -210,7 +209,7 @@ public class CovidVaccinateAppointmentService {
|
|
|
* @param id 对应的疫苗
|
|
|
* @return 对应的数据
|
|
|
* */
|
|
|
- public ResultVo<List<CovidVaccinateFactory>> chaKanChangJia(int id){
|
|
|
+ public ResultVo<List<CovidVaccinateFactory>> chaKanChangJia(int id) {
|
|
|
return ResultVoUtil.success(dao.chaKanChangJia(id));
|
|
|
}
|
|
|
|
|
@@ -218,10 +217,10 @@ public class CovidVaccinateAppointmentService {
|
|
|
* 根据id来修改 疫苗的一些字段
|
|
|
* @param param 修改的字段为 name enableFlag bookTip 通过id来修改
|
|
|
* */
|
|
|
- public ResultVo<Boolean> xiuGaiYiMiao(ZdCovidVaccinate param){
|
|
|
+ public ResultVo<Boolean> xiuGaiYiMiao(ZdCovidVaccinate param) {
|
|
|
log.info("修改疫苗=》操作人:{},数据:{}",TokenUtil.getTokenUserId(),JSON.toJSONStringWithDateFormat(param,DATE_FORMAT));
|
|
|
dao.xiuGaiYiMiao(param);
|
|
|
- return ResultVoUtil.success(ExceptionEnum.SUCCESS_AND_NOTIFICATION,"疫苗修改成功 \(☆o☆)/");
|
|
|
+ return ResultVoUtil.success(ExceptionEnum.SUCCESS_AND_NOTIFICATION,String.format("<p style='color:#67C23A'>%s</p>修改成功 \(☆o☆)/",param.getName()));
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -229,10 +228,10 @@ public class CovidVaccinateAppointmentService {
|
|
|
* @param param 传入需要修改的值和原本的code
|
|
|
* @return 返回boolean
|
|
|
* */
|
|
|
- public ResultVo<Boolean> xiuGaiChangJia(CovidVaccinateFactory param){
|
|
|
+ public ResultVo<Boolean> xiuGaiChangJia(CovidVaccinateFactory param) {
|
|
|
log.info("修改新冠疫苗厂家==》操作人:{},数据:{}",TokenUtil.getTokenUserId(),JSON.toJSONString(param));
|
|
|
dao.xiuGaiChangJia(param);
|
|
|
- return ResultVoUtil.success(ExceptionEnum.SUCCESS_AND_NOTIFICATION,"厂家信息修改成功 \(☆o☆)/");
|
|
|
+ return ResultVoUtil.success(ExceptionEnum.SUCCESS_AND_NOTIFICATION,String.format("<p style='color:teal'>%s</p>厂家信息修改成功 φ(゜▽゜*)♪",param.getName()));
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -240,18 +239,20 @@ public class CovidVaccinateAppointmentService {
|
|
|
* @param code 根据code来删除
|
|
|
* @return 返回
|
|
|
* */
|
|
|
- public ResultVo<Boolean> shanChuChangJia(Integer code){
|
|
|
+ public ResultVo<Boolean> shanChuChangJia(Integer code) {
|
|
|
log.info("删除新冠疫苗厂家==》操作人:{},删除的数据:{}",TokenUtil.getTokenUserId(),code);
|
|
|
dao.shanChuChangJia(code);
|
|
|
- return ResultVoUtil.success(ExceptionEnum.SUCCESS_AND_NOTIFICATION,"删除成功 \(☆o☆)/" +
|
|
|
- "");
|
|
|
+ return ResultVoUtil.success(ExceptionEnum.SUCCESS_AND_NOTIFICATION,"删除成功 \(☆o☆)/");
|
|
|
}
|
|
|
+
|
|
|
/**
|
|
|
* 这里是批量修改 新冠阈值的数据
|
|
|
- * */
|
|
|
- public ResultVo<Boolean> yiJianXiuGaiRiQi(List<CovidVaccinateThreshold> list){
|
|
|
- log.info("批量修改新冠疫苗厂家阈值==》操作人:{},数据:{}",TokenUtil.getTokenUserId(),JSON.toJSONString(list));
|
|
|
+ * @param list 传入多个ID 和 value 阈值
|
|
|
+ * @return 通知修改成功
|
|
|
+ */
|
|
|
+ public ResultVo<Boolean> yiJianXiuGaiRiQi(List<CovidVaccinateThreshold> list) {
|
|
|
+ log.info("修改新冠疫苗厂家阈值==》操作人:{},数据:{}",TokenUtil.getTokenUserId(),JSON.toJSONString(list));
|
|
|
dao.xiuGaiYuZhi(list);
|
|
|
- return ResultVoUtil.success(ExceptionEnum.SUCCESS_AND_NOTIFICATION,"修改成功 ヽ(”`▽´)ノ");
|
|
|
+ return ResultVoUtil.success(ExceptionEnum.SUCCESS_AND_NOTIFICATION,"阈值修改成功 ヽ(”`▽´)ノ");
|
|
|
}
|
|
|
}
|