| | |
| | | @Api(tags = "【看板大屏】园区物流运行调度看板真实") |
| | | @RestController |
| | | @Slf4j |
| | | @RequestMapping(Constants.CLOUD_SERVICE_URL_INDEX+"/board/api/platformJobRun") |
| | | @RequestMapping(Constants.CLOUD_SERVICE_URL_INDEX+"/board/api/platformJobRunAct") |
| | | public class PlatformJobRunActController extends BaseController { |
| | | |
| | | @Autowired |
| | |
| | | @Api(tags = "【看板大屏】园区物流运行调度看板") |
| | | @RestController |
| | | @Slf4j |
| | | @RequestMapping(Constants.CLOUD_SERVICE_URL_INDEX+"/board/api/platformJobRunOld") |
| | | @RequestMapping(Constants.CLOUD_SERVICE_URL_INDEX+"/board/api/platformJobRun") |
| | | public class PlatformJobRunController extends BaseController { |
| | | |
| | | @Autowired |
| | |
| | | thing13.put("value",Constants.equalsInteger(hiddenDanger.getStatus(),Constants.ONE)?"隐患已整改":"隐患已退回"); |
| | | //提交人 |
| | | Map<String, Object> thing10 = new HashMap<String,Object>(); |
| | | thing10.put("value",hiddenDanger.getCheckorName()); |
| | | thing10.put("value",hiddenDanger.getMemberName()); |
| | | //通知时间 |
| | | Map<String, Object> time16 = new HashMap<String,Object>(); |
| | | time16.put("value", DateUtil.getFomartDate(hiddenDanger.getDealTime(),"yyyy年MM月dd日 HH:mm:ss") ); |
| | |
| | | @TableField(exist = false) |
| | | private String createMemberName; |
| | | |
| | | @ApiModelProperty(value = "创建人电话", example = "1") |
| | | @TableField(exist = false) |
| | | private String createMobile; |
| | | |
| | | @ApiModelProperty(value = "审批信息数据") |
| | | @TableField(exist = false) |
| | | private ApproveDataVO approveDateVO; |
| | |
| | | @ApiModelProperty(value = "拜访时间") |
| | | private String visitTime; |
| | | |
| | | @ApiModelProperty(value = "显示通知状态") |
| | | @ApiModelProperty(value = "显示通知状态值") |
| | | private String info; |
| | | @ApiModelProperty(value = "显示通知状态 1=待审批;2=审批通过;3=审批未通过;4=业务取消") |
| | | private Integer infoStatus; |
| | | |
| | | @ApiModelProperty(value = "随访人员信息") |
| | | private List<Visits> withVisitsList; |
| | |
| | | hiddenDanger.setMemberName(systemUser.getRealname()); |
| | | //提交人的微信公众号通知 |
| | | if(Objects.nonNull(systemUser)&&StringUtils.isNotBlank(systemUser.getOpenid())){ |
| | | |
| | | wxPlatNotice.sendHiddenDangerUploadTemplateNotice(systemDictDataBiz, |
| | | wxNoticeConfigMapper,hiddenDanger, |
| | | WxPlatConstants.hiddenDangerContent.hiddenDangerUpload, |
| | |
| | | .eq(SystemUser::getDeleted, Constants.ZERO) |
| | | .eq(SystemUser::getMemberId,hiddenDanger.getCheckUserId()) |
| | | .last(" limit 1 ")); |
| | | |
| | | //处理人的微信公众号通知 |
| | | if(Objects.nonNull(checkUser)&&StringUtils.isNotBlank(checkUser.getOpenid())){ |
| | | |
| | | |
| | | wxPlatNotice.sendHiddenDangerUploadTemplateNotice(systemDictDataBiz, |
| | | wxNoticeConfigMapper,hiddenDanger, |
| | | WxPlatConstants.hiddenDangerContent.hiddenDangerUpload, |
| | |
| | | if(Objects.isNull(hiddenDangerCate)){ |
| | | throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到隐患类型"); |
| | | } |
| | | model.setCategoryName(hiddenDangerCate.getName()); |
| | | hiddenDanger.setCategoryName(hiddenDangerCate.getName()); |
| | | hiddenDanger.setEditor(hiddenDanger.getLoginUserInfo().getId()); |
| | | hiddenDanger.setEditDate(new Date()); |
| | |
| | | .eq(Notices::getObjId,hiddenDanger.getId()) |
| | | .eq(Notices::getObjType,Constants.THREE) |
| | | .eq(Notices::getUserId,hiddenDanger.getLoginUserInfo().getMemberId()) |
| | | .orderByDesc(Notices::getId) |
| | | .last(" limit 1 ") |
| | | ); |
| | | if(Objects.nonNull(notices)){ |
| | |
| | | return; |
| | | } |
| | | hiddenDanger.setMemberName(memberUser.getRealname()); |
| | | model.setMemberName(memberUser.getRealname()); |
| | | SystemUser checkUser = systemUserMapper.selectOne(new QueryWrapper<SystemUser>().lambda() |
| | | .eq(SystemUser::getDeleted, Constants.ZERO) |
| | | .eq(SystemUser::getMemberId,hiddenDanger.getCheckUserId())); |
| | |
| | | if(Objects.nonNull(checkUser)&&StringUtils.isNotBlank(checkUser.getOpenid())){ |
| | | WxPlatNotice wxPlatNotice = new WxPlatNotice(); |
| | | wxPlatNotice.sendHiddenDangerUploadTemplateNotice(systemDictDataBiz, |
| | | wxNoticeConfigMapper,hiddenDanger, |
| | | wxNoticeConfigMapper,model, |
| | | WxPlatConstants.hiddenDangerContent.hiddenDangerUpload, |
| | | systemDictDataBiz.queryByCode(Constants.WX_PLATFORM,Constants.WX_PLATFORM_ACCESS_TOKEN).getCode(), |
| | | Arrays.asList(checkUser.getOpenid().split(","))); |
| | |
| | | //开启短信通知 |
| | | if(Objects.nonNull(smsConfig) || Constants.equalsInteger(smsConfig.getStatus(),Constants.ZERO)){ |
| | | String content = systemDictDataBiz.queryByCode(Constants.SMS,Constants.SMS_COMNAME).getCode() + smsConfig.getContent(); |
| | | Visits visits = visitsMapper.selectById(objId); |
| | | Visits visits = visitsMapper.selectJoinOne(Visits.class,new MPJLambdaWrapper<Visits>().selectAll(Visits.class) |
| | | .selectAs(SystemUser::getMobile,Visits::getCreateMobile) |
| | | .leftJoin(SystemUser.class,SystemUser::getMemberId,Visits::getMemberId) |
| | | .eq(Visits::getId,objId) |
| | | .last(" limit 1") |
| | | ); |
| | | if(Objects.nonNull(visits)){ |
| | | if(objCode.equals(SmsConstants.visitReportingContent.visitReportingAuditSuccess)){ |
| | | // 您的【访客报备】已经审批通过,请通知访客于{预约入园开始时间}后乘坐{车牌号}入园,如有疑问,请联系被访人。 |
| | | content = content.replace("{预约入园开始时间}",DateUtil.getFomartDate(visits.getStarttime(),"yyyy-MM-dd HH:mm")) |
| | | .replace("{车牌号}",visits.getCarNos()); |
| | | sendBusinessSms(emayService,smsEmailMapper, |
| | | Arrays.asList(visits.getPhone().split(",")),SmsConstants.visitReport,content,visits.getId()); |
| | | Arrays.asList(visits.getCreateMobile().split(",")),SmsConstants.visitReport,content,visits.getId()); |
| | | }else if(objCode.equals(SmsConstants.visitReportingContent.visitReportingAuditFail)){ |
| | | //您的【访客报备】已被驳回,驳回原因为:{驳回原因}。如有疑问,请联系审批人。 |
| | | content = content.replace("{驳回原因}",msg); |
| | | sendBusinessSms(emayService,smsEmailMapper, |
| | | Arrays.asList(visits.getPhone().split(",")),SmsConstants.visitReport,content,visits.getId()); |
| | | Arrays.asList(visits.getCreateMobile().split(",")),SmsConstants.visitReport,content,visits.getId()); |
| | | }else if(objCode.equals(SmsConstants.visitReportingContent.visitReportingTimeOutSignOut)){ |
| | | //您的【访客报备】已于{预约入园结束时间}到期,请及时离场,如有疑问,请联系被访人 |
| | | content = content.replace("{预约入园结束时间}",DateUtil.getFomartDate(visits.getEndtime(),"yyyy-MM-dd HH:mm")); |
| | |
| | | memberId) |
| | | ); |
| | | // } |
| | | if(Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.waitCheck)||Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.submitCheck)){ |
| | | Notices notices = noticesJoinMapper.selectOne(new QueryWrapper<Notices>().lambda().eq(Notices::getObjId,visits.getId()) |
| | | .eq(Notices::getType,Constants.equalsInteger(visits.getType(),Constants.TWO)?Constants.noticesObjectType.visitReporting:Constants.noticesObjectType.visit) |
| | | .eq(Notices::getUserId,memberId) |
| | | .eq(Notices::getSendacopy,Constants.ZERO) |
| | | .last(" limit 1 ") |
| | | ); |
| | | visitDetailVO.setInfoStatus(1); |
| | | if(Objects.nonNull(notices)){ |
| | | visitDetailVO.setInfo(notices.getInfo()); |
| | | }else{ |
| | | visitDetailVO.setInfo("暂无"); |
| | | } |
| | | }else if(Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.noPass)){ |
| | | visitDetailVO.setInfoStatus(Constants.VisitStatus.noPass); |
| | | visitDetailVO.setInfo("审批未通过"); |
| | | |
| | | Notices notices = noticesJoinMapper.selectOne(new QueryWrapper<Notices>().lambda().eq(Notices::getObjId,visits.getId()) |
| | | .eq(Notices::getType,Constants.equalsInteger(visits.getType(),Constants.TWO)?Constants.noticesObjectType.visitReporting:Constants.noticesObjectType.visit) |
| | | .eq(Notices::getUserId,memberId) |
| | | .eq(Notices::getSendacopy,Constants.ZERO) |
| | | .last(" limit 1 ") |
| | | ); |
| | | if(Objects.nonNull(notices)){ |
| | | notices.setInfo(notices.getInfo()); |
| | | }else if(Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.cancel)){ |
| | | visitDetailVO.setInfoStatus(Constants.VisitStatus.cancel); |
| | | visitDetailVO.setInfo("已取消"); |
| | | }else{ |
| | | notices.setInfo("暂无"); |
| | | visitDetailVO.setInfoStatus(Constants.VisitStatus.pass); |
| | | visitDetailVO.setInfo("审批已通过"); |
| | | } |
| | | return visitDetailVO; |
| | | } |
| | |
| | | SmsEmailServiceImpl.sendVisitTimeOutSms(systemDictDataBiz, |
| | | emayService,smsEmailMapper,smsConfigMapper, |
| | | SmsConstants.visitContent.visitTimeOutSignOutNum, |
| | | visitReportTimeCount.toString(),Arrays.asList(mobile.split(",")) |
| | | visitTimeCount.toString(),Arrays.asList(mobile.split(",")) |
| | | ); |
| | | } |
| | | } |