| | |
| | | import com.doumee.core.utils.Constants; |
| | | import com.doumee.core.utils.DateUtil; |
| | | import com.doumee.core.utils.HttpsUtil; |
| | | import com.doumee.dao.business.dao.SmsEmailMapper; |
| | | import com.doumee.dao.business.model.Bookings; |
| | | import com.doumee.dao.business.model.SmsEmail; |
| | | import com.github.xiaoymin.knife4j.core.util.CollectionUtils; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import java.awt.print.Book; |
| | | import java.util.*; |
| | | |
| | | /** |
| | |
| | | } |
| | | } |
| | | |
| | | public void createBeginWxNotice(SystemDictDataBiz systemDictDataBiz, SmsEmailMapper smsEmailMapper, Bookings bookings, String openId){ |
| | | Map<String,Object> map = new HashMap<>(); |
| | | |
| | | //æ´ä½åæ°map |
| | | Map<String, Object> paramMap = new HashMap<String, Object>(); |
| | | //æ¶æ¯ä¸»é¢æ¾ç¤ºç¸å
³map |
| | | Map<String, Object> dataMap = new HashMap<String, Object>(); |
| | | //ä¼è®®åç§° |
| | | Map<String, Object> thing1 = new HashMap<String,Object>(); |
| | | thing1.put("value",bookings.getName()); |
| | | //ä¼è®®å°ç¹ |
| | | Map<String, Object> thing2 = new HashMap<String,Object>(); |
| | | thing2.put("value",bookings.getRoomName()); |
| | | //ä¼è®®æ¶é´ |
| | | Map<String, Object> thing3 = new HashMap<String,Object>(); |
| | | thing3.put("value", DateUtil.getFomartDate(bookings.getStartTime(),"yyyyå¹´MMæddæ¥HH:mm")+"è³"+DateUtil.getFomartDate(bookings.getEndTime(),"HH:mm")); |
| | | |
| | | Integer earlyMin= Integer.valueOf(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.EARLY_START_WX_NOTICE).getCode()); |
| | | |
| | | Map<String, Object> thing5 = new HashMap<String,Object>(); |
| | | thing5.put("value","æ¨æé¢å®çä¼è®®å®¤å³å°å¨"+earlyMin+"åéåå¼å§ï¼è¯·åæ¶åå "); |
| | | |
| | | dataMap.put("thing1",thing1); |
| | | dataMap.put("thing2",thing2); |
| | | dataMap.put("thing3",thing3); |
| | | dataMap.put("thing5",thing5); |
| | | paramMap.put("data", dataMap); |
| | | |
| | | paramMap.put("template_id", "xGFnbHwe8W9sIGlD75XROrbKpzV-6HSRqfRHRfxRR6k"); |
| | | paramMap.put("touser", openId); |
| | | paramMap.put("data", dataMap); |
| | | |
| | | smsEmailMapper.delete(new QueryWrapper<SmsEmail>().lambda() |
| | | .eq(SmsEmail::getObjType,Constants.FIVE.toString()) |
| | | .eq(SmsEmail::getStatus,Constants.TWO) |
| | | .eq(SmsEmail::getType,Constants.TWO) |
| | | .eq(SmsEmail::getObjId,bookings.getId()) |
| | | ); |
| | | |
| | | SmsEmail smsEmail = new SmsEmail(); |
| | | smsEmail.setPhone(openId); |
| | | smsEmail.setRemark("çå¾
åé"); |
| | | smsEmail.setStatus(Constants.TWO); |
| | | smsEmail.setIsdeleted(Constants.ZERO); |
| | | smsEmail.setType(Constants.TWO); |
| | | smsEmail.setObjType(Constants.FIVE.toString()); |
| | | smsEmail.setObjId(bookings.getId()); |
| | | smsEmail.setCreateDate(new Date()); |
| | | smsEmail.setTitle("ä¼è®®å³å°å¼å§æé"); |
| | | smsEmail.setInfo(DateUtil.getFomartDate(DateUtil.getXMinuteAfterDate(bookings.getStartTime(),-earlyMin),"yyyy-MM-dd HH:mm:ss")); |
| | | smsEmail.setContent(JSONObject.toJSONString(map)); |
| | | } |
| | | |
| | | |
| | | public void createEndWxNotice(SystemDictDataBiz systemDictDataBiz, SmsEmailMapper smsEmailMapper, Bookings bookings, String openId){ |
| | | Map<String,Object> map = new HashMap<>(); |
| | | |
| | | //æ´ä½åæ°map |
| | | Map<String, Object> paramMap = new HashMap<String, Object>(); |
| | | //æ¶æ¯ä¸»é¢æ¾ç¤ºç¸å
³map |
| | | Map<String, Object> dataMap = new HashMap<String, Object>(); |
| | | //ä¼è®®åç§° |
| | | Map<String, Object> thing1 = new HashMap<String,Object>(); |
| | | thing1.put("value",bookings.getName()); |
| | | //ä¼è®®å°ç¹ |
| | | Map<String, Object> thing6 = new HashMap<String,Object>(); |
| | | thing6.put("value",bookings.getRoomName()); |
| | | //ä¼è®®æ¶é´ |
| | | Map<String, Object> date4 = new HashMap<String,Object>(); |
| | | date4.put("value", DateUtil.getFomartDate(bookings.getEndTime(),"yyyyå¹´MMæddæ¥HH:mm")); |
| | | |
| | | Map<String, Object> thing7 = new HashMap<String,Object>(); |
| | | thing7.put("value","æ¨çä¼è®®å³å°ç»æï¼å¦éç»§ç»ä½¿ç¨è¯·å³ä½¿ç»è®¢"); |
| | | |
| | | dataMap.put("thing1",thing1); |
| | | dataMap.put("thing6",thing6); |
| | | dataMap.put("date4",date4); |
| | | dataMap.put("thing7",thing7); |
| | | paramMap.put("data", dataMap); |
| | | |
| | | paramMap.put("template_id", "vdIPfwvDCrXOHgQnB6sdE1lGEsJm1oUURfLx6SoLdk0"); |
| | | paramMap.put("touser", openId); |
| | | paramMap.put("data", dataMap); |
| | | |
| | | smsEmailMapper.delete(new QueryWrapper<SmsEmail>().lambda() |
| | | .eq(SmsEmail::getObjType,Constants.FIVE.toString()) |
| | | .eq(SmsEmail::getStatus,Constants.TWO) |
| | | .eq(SmsEmail::getType,Constants.TWO) |
| | | .eq(SmsEmail::getObjId,bookings.getId()) |
| | | ); |
| | | |
| | | SmsEmail smsEmail = new SmsEmail(); |
| | | smsEmail.setPhone(openId); |
| | | smsEmail.setRemark("çå¾
åé"); |
| | | smsEmail.setStatus(Constants.TWO); |
| | | smsEmail.setIsdeleted(Constants.ZERO); |
| | | smsEmail.setType(Constants.TWO); |
| | | smsEmail.setObjType(Constants.FIVE.toString()); |
| | | smsEmail.setObjId(bookings.getId()); |
| | | smsEmail.setCreateDate(new Date()); |
| | | smsEmail.setTitle("ä¼è®®å³å°å¼å§æé"); |
| | | Integer endMin= Integer.valueOf(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.OVER_NOTICE_WX).getCode()); |
| | | smsEmail.setInfo(DateUtil.getFomartDate(DateUtil.getXMinuteAfterDate(bookings.getEndTime(),-endMin),"yyyy-MM-dd HH:mm:ss")); |
| | | smsEmail.setContent(JSONObject.toJSONString(map)); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * ä¼è®®å®¤åæ¶éç¥ |
| | |
| | | this.sendNotice(bookings, MeetConstants.TWO); |
| | | SystemUser systemUser = systemUserMapper.selectById(user.getId()); |
| | | this.sendWxNotice(bookings,Objects.isNull(systemUser)||StringUtils.isBlank(systemUser.getOpenid())?null:systemUser.getOpenid(),Constants.ZERO); |
| | | //å建ä¼è®®å³å°å°æä¸ä¼è®®å³å°ç»æçéç¥ |
| | | if(Objects.nonNull(systemUser)&&StringUtils.isNotBlank(systemUser.getOpenid())){ |
| | | WxPlatNotice wxPlatNotice = new WxPlatNotice(); |
| | | wxPlatNotice.createBeginWxNotice(systemDictDataBiz,smsEmailMapper,bookings,systemUser.getOpenid()); |
| | | wxPlatNotice.createEndWxNotice(systemDictDataBiz,smsEmailMapper,bookings,systemUser.getOpenid()); |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | } |
| | | |
| | | return bookings.getId(); |
| | |
| | | this.sendNotice(bookings, MeetConstants.TWO); |
| | | SystemUser systemUser = systemUserMapper.selectById(bookings.getCreator()); |
| | | this.sendWxNotice(bookings,Objects.isNull(systemUser)||StringUtils.isBlank(systemUser.getOpenid())?null:systemUser.getOpenid(),Constants.ZERO); |
| | | if(Objects.nonNull(systemUser)&&StringUtils.isNotBlank(systemUser.getOpenid())){ |
| | | WxPlatNotice wxPlatNotice = new WxPlatNotice(); |
| | | wxPlatNotice.createBeginWxNotice(systemDictDataBiz,smsEmailMapper,bookings,systemUser.getOpenid()); |
| | | wxPlatNotice.createEndWxNotice(systemDictDataBiz,smsEmailMapper,bookings,systemUser.getOpenid()); |
| | | } |
| | | } |
| | | } |
| | | |
| | |
| | | smsEmail.setStatus(Constants.TWO);// |
| | | smsEmail.setIsdeleted(Constants.ZERO); |
| | | smsEmail.setType(Constants.ZERO); |
| | | smsEmail.setObjType(Constants.FIVE.toString()); |
| | | smsEmail.setObjId(bookings.getId()); |
| | | smsEmail.setCreateDate(new Date()); |
| | | smsEmail.setTitle("ä¼è®®å®¤ç³è¯·åä¼éç¥"); |
| | |
| | | try { |
| | | ServerHttpRequest request = serverWebExchange.getRequest(); |
| | | dto.setCheckCode(false); |
| | | LoginUserInfo user = systemLoginService.loginByPasswordNew(dto,request); |
| | | LoginUserInfo user = systemLoginService.loginByPasswordNew(dto,request); |
| | | String token = jwtTokenUtil.generateToken(user); |
| | | return ApiResponse.success(token); |
| | | }catch (BusinessException e){ |
| | | return ApiResponse.failed(e.getCode(),e.getMessage()); |
| | | }catch (Exception e){ |
| | | e.printStackTrace(); |
| | | return ApiResponse.failed(ResponseStatus.SERVER_ERROR); |
| | | } |
| | | } |
| | | |
| | | |
| | | @PreventRepeat(limit = 10, lockTime = 10000) |
| | | @ApiOperation("PDAä¸å¡ç»å½") |
| | | @PostMapping("/loginPDA") |
| | | @LoginNoRequired |
| | | public ApiResponse<String> loginPDA (@Validated @RequestBody LoginDTO dto, ServerWebExchange serverWebExchange) { |
| | | try { |
| | | ServerHttpRequest request = serverWebExchange.getRequest(); |
| | | dto.setCheckCode(false); |
| | | LoginUserInfo user = systemLoginService.loginByPasswordForPda(dto,request); |
| | | String token = jwtTokenUtil.generateToken(user); |
| | | return ApiResponse.success(token); |
| | | }catch (BusinessException e){ |
| | |
| | | public static final String CITY_XH_REASON_ID ="CITY_XH_REASON_ID" ; |
| | | public static final String ATWL_XH_PLATFORM_ID ="ATWL_XH_PLATFORM_ID" ; |
| | | public static final String SCREEN_SEVENT_ARRIVAL_STARTDATE = "SCREEN_SEVENT_ARRIVAL_STARTDATE"; |
| | | public static final String EARLY_START_WX_NOTICE = "EARLY_START_WX_NOTICE"; |
| | | public static final String OVER_NOTICE_WX = "OVER_NOTICE_WX"; |
| | | |
| | | public static boolean DEALING_HK_SYNCPRIVILEGE= false; |
| | | public static boolean DEALING_HK_SYNCDEVICE = false; |
| | | public static boolean DEALING_HK_SYNCPLATFORM = false; |
| | |
| | | @ExcelColumn(name="ç¶æ 0æªä½¿ç¨ 1å·²ä½¿ç¨ 2çå¾
åé") |
| | | private Integer status; |
| | | |
| | | @ApiModelProperty(value = "ç±»å 0çä¿¡ 1é®ä»¶ ") |
| | | @ExcelColumn(name="ç±»å 0çä¿¡ 1é®ä»¶") |
| | | @ApiModelProperty(value = "ç±»å 0çä¿¡ 1é®ä»¶ 2微信å
¬ä¼å·éç¥") |
| | | @ExcelColumn(name="ç±»å 0çä¿¡ 1é®ä»¶ 2微信å
¬ä¼å·éç¥") |
| | | private Integer type; |
| | | |
| | | @ApiModelProperty(value = "å
³è对象ç¼ç ", example = "1") |
| | |
| | | |
| | | LoginUserInfo loginByPasswordNew (LoginDTO dto, ServerHttpRequest request); |
| | | |
| | | LoginUserInfo loginByPasswordForPda(LoginDTO dto, ServerHttpRequest request); |
| | | |
| | | LoginUserInfo loginByPhone(LoginPhoneDTO dto, ServerHttpRequest request); |
| | | |
| | | |
| | |
| | | return userInfo; |
| | | } |
| | | |
| | | |
| | | |
| | | @Override |
| | | public LoginUserInfo loginByPasswordForPda(LoginDTO dto, ServerHttpRequest request) { |
| | | SystemLoginLog loginLog = new SystemLoginLog(); |
| | | loginLog.setLoginUsername(dto.getUsername()); |
| | | loginLog.setLoginTime(new Date()); |
| | | loginLog.setSystemVersion(systemVersion); |
| | | // loginLog.setLocation(Utils.Location.getLocationString(loginLog.getIp())); |
| | | if(request!=null&&request.getHeaders()!=null && request.getHeaders().size()>0){ |
| | | loginLog.setIp(Utils.User_Client.getIP(request)); |
| | | loginLog.setPlatform(Utils.User_Client.getPlatform(request)); |
| | | loginLog.setClientInfo(Utils.User_Client.getBrowser(request)); |
| | | loginLog.setOsInfo(Utils.User_Client.getOS(request)); |
| | | } |
| | | loginLog.setServerIp(Utils.Server.getIP()); |
| | | // æ ¹æ®ç¨æ·åæ¥è¯¢ç¨æ·å¯¹è±¡ |
| | | SystemUser queryDto = new SystemUser(); |
| | | queryDto.setUsername(dto.getUsername()); |
| | | queryDto.setDeleted(Boolean.FALSE); |
| | | SystemUser user = systemUserService.findOne(queryDto); |
| | | if (user == null) { |
| | | throw new BusinessException(ResponseStatus.ACCOUNT_INCORRECT); |
| | | } |
| | | if(!Constants.equalsInteger(user.getSource(),Constants.ZERO)){ |
| | | throw new BusinessException(ResponseStatus.NO_ALLOW_LOGIN); |
| | | } |
| | | String pwd = Utils.Secure.encryptPassword(new String(dto.getPassword()), user.getSalt()); |
| | | // æ¯è¾å¯ç |
| | | if( !StringUtils.equals(pwd, user.getPassword())){ |
| | | throw new BusinessException(ResponseStatus.ACCOUNT_INCORRECT); |
| | | } |
| | | dealOpenIdBiz(user,dto.getOpenid()); |
| | | Company company = new Company(); |
| | | if(Objects.nonNull(user.getCompanyId())){ |
| | | company = companyMapper.selectById(user.getCompanyId()); |
| | | } |
| | | // è·åç»å½ç¨æ·ä¿¡æ¯ |
| | | List<SystemRole> roles = systemRoleService.findByUserId(user.getId()); |
| | | List<SystemPermission> permissions = systemPermissionService.findByUserId(user.getId()); |
| | | |
| | | SystemRole rt = new SystemRole(); |
| | | rt.setDeleted(Boolean.FALSE); |
| | | //æ°æ®é¨é¨æééå |
| | | user.setCompanyIdList(systemDataPermissionService.selectHighRole(new SystemDataPermission(),rt,user)); |
| | | |
| | | LoginUserInfo userInfo = LoginUserInfo.from(user, roles, permissions,company,null); |
| | | return userInfo; |
| | | } |
| | | |
| | | private void dealOpenIdBiz(SystemUser user, String openid) { |
| | | if(StringUtils.isNotBlank(openid)){ |
| | | //妿openIdä¸ä¸ºç©º,ç»å®è¯¥ç¨æ·openid |
| | |
| | | <if test="dto.memberType != null "> |
| | | AND usr.`type` = #{dto.memberType} |
| | | </if> |
| | | <if test="dto.memberType != null "> |
| | | AND usr.`type` = #{dto.memberType} |
| | | </if> |
| | | <if test="dto.workStatus != null "> |
| | | AND m.WORK_STATUS = #{dto.workStatus} |
| | | </if> |
| | |
| | | return ApiResponse.success(data); |
| | | } |
| | | |
| | | |
| | | |
| | | @LoginNoRequired |
| | | @ApiOperation("è¿è¾ä»»å¡åæ") |
| | | @GetMapping("/transportMeasure") |
| | |
| | | List<TransportMeasureVO> list = boardService.transportMeasure(queryType); |
| | | return ApiResponse.success(list); |
| | | } |
| | | |
| | | @LoginNoRequired |
| | | @ApiOperation("æ±½è½¦ç¶æãç»çº¬åº¦éåæ°æ®") |
| | | @GetMapping("/carsList") |
| | |
| | | BoardCarsListVO data = boardService.platformJobCarsList(); |
| | | return ApiResponse.success(data); |
| | | } |
| | | |
| | | @LoginNoRequired |
| | | @ApiOperation("汽车åè¦äºä»¶éåæ°æ®") |
| | | @GetMapping("/carsEventList") |
| | |
| | | |
| | | private String indexCode ;//String false |
| | | |
| | | @ApiModelProperty(value = "ç±»åï¼temp 温度 humidity 湿度") |
| | | @ApiModelProperty(value = "ç±»åï¼currTemperature 温度 currHumidity 湿度") |
| | | private String sensorType ;//String false |
| | | |
| | | private String parentIndexCode ;//String false |
| | |
| | | } |
| | | |
| | | |
| | | public void sendMeetTemplateNotice(SystemDictDataBiz systemDictDataBiz,SmsEmail smsEmail,String token){ |
| | | try{ |
| | | String jumpUrl = Constants.getWxUrl(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.WX_REDIRECT_URL).getCode(), |
| | | Constants.WxUrlParams.MEETING,smsEmail.getObjId().toString()); |
| | | String postUrL = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token="+token; |
| | | JSONObject jsonObject = JSONObject.parseObject(smsEmail.getContent()); |
| | | jsonObject.put("url",jumpUrl); |
| | | String response = HttpsUtil.postJson(postUrL, JSONObject.toJSONString(jsonObject)); |
| | | log.warn("·==++--·æ¨é微信模æ¿ä¿¡æ¯å
容ï¼{}", JSONObject.toJSONString(jsonObject)); |
| | | if(StringUtils.isBlank(response)){ |
| | | log.warn("·==++--·æ¨é微信模æ¿ä¿¡æ¯ï¼{}·--++==·", "失败"); |
| | | }else{ |
| | | JSONObject json = JSONObject.parseObject(response); |
| | | log.warn("·==++--·æ¨é微信模æ¿ä¿¡æ¯ï¼{}·--++==·", Constants.equalsInteger(json.getInteger("errcode"),Constants.ZERO)?"æå":"失败"+json.getString("errmsg")); |
| | | } |
| | | }catch (Exception e){ |
| | | |
| | | } |
| | | |
| | | } |
| | | |
| | | |
| | | } |
| | |
| | | @Data |
| | | public class AlarmDataVO { |
| | | |
| | | |
| | | @ApiModelProperty(value = "æ»æ°") |
| | | private Integer totalNum; |
| | | |
| | |
| | | |
| | | @ApiModelProperty(value = "å¤ç䏿°é") |
| | | private Integer processingNum; |
| | | |
| | | @ApiModelProperty(value = "ç»è®¡æ¶é´å¼å§") |
| | | private String startDate; |
| | | |
| | | @ApiModelProperty(value = "ç»è®¡æ¶é´ç»æ") |
| | | private String endDate; |
| | | |
¶Ô±ÈÐÂÎļþ |
| | |
| | | package com.doumee.dao.web.response.platformReport; |
| | | |
| | | import io.swagger.annotations.ApiModelProperty; |
| | | import lombok.Data; |
| | | |
| | | import java.util.List; |
| | | |
| | | /** |
| | | * æ¬å¹´æ¶é²è®¾å¤/设æ½ç»´æ¤æ
åµ |
| | | * |
| | | * @Author : Rk |
| | | * @create 2024/10/25 14:26 |
| | | */ |
| | | @Data |
| | | public class MonitorParentDataVO { |
| | | |
| | | |
| | | @ApiModelProperty(value = "å·¦ä¾§æ°æ®") |
| | | private MonitorDataVO leftData; |
| | | |
| | | @ApiModelProperty(value = "å³ä¾§æ°æ®") |
| | | private MonitorDataVO rightData; |
| | | |
| | | } |
| | |
| | | .eq(Approve::getObjId,revokeDTO.getId()) |
| | | ); |
| | | |
| | | noticesJoinMapper.update(null,new UpdateWrapper<Notices>().lambda() |
| | | .set(Notices::getEditDate,new Date()) |
| | | .set(Notices::getInfo,"ç©æµè½¦é¢çº¦ç³è¯·åæ¶") |
| | | .set(Notices::getReaded,Constants.ONE) |
| | | .set(Notices::getParam2,Constants.TWO) |
| | | .set(Notices::getStatus,Constants.ONE) |
| | | .eq(Notices::getType,Constants.noticesObjectType.reason) |
| | | .eq(Notices::getObjId,model.getId()) |
| | | ); |
| | | |
| | | //åéçä¿¡éç¥ |
| | | SmsEmailServiceImpl.sendPlatformBookSms(systemDictDataBiz, |
| | | emayService,smsEmailMapper,smsConfigMapper,platformBooksMapper,model.getId(), |
| | |
| | | .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) |
| | | .eq(PlatformJob::getIsdeleted,Constants.ZERO) |
| | | .eq(PlatformJob::getDrivierPhone,loginUserInfo.getMobile()) |
| | | .and(i->i.like(PlatformJob::getDoneDate,DateUtil.getCurrDate()) |
| | | .or().in(PlatformJob::getStatus,Constants.PlatformJobStatus.WAIT_CALL.getKey() |
| | | ,Constants.PlatformJobStatus.WAIT_CONFIRM.getKey(), |
| | | Constants.PlatformJobStatus.WART_SIGN_IN.getKey(), |
| | | Constants.PlatformJobStatus.IN_WAIT.getKey(), |
| | | Constants.PlatformJobStatus.CALLED.getKey(), |
| | | Constants.PlatformJobStatus.WORKING.getKey()) |
| | | ) |
| | | .orderByDesc(PlatformJob::getId) |
| | | ); |
| | | for (PlatformJob platformJob:platformJobList) { |
| | |
| | | } |
| | | |
| | | driverHomeVO.setPlatformJobList(platformJobList); |
| | | |
| | | // ååºå¯¼è§å¾ å¾ç |
| | | driverHomeVO.setReservationMap(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.PLATFORM_GUIDEMAP).getCode()); |
| | | // é¢çº¦æå ææ¬ |
| | |
| | | ,PlatformJob::getId,lineUpDetailDTO.getJobId()) |
| | | .in(PlatformJob::getStatus,Constants.PlatformJobStatus.WAIT_CALL.getKey(), |
| | | Constants.PlatformJobStatus.IN_WAIT.getKey(), |
| | | Constants.PlatformJobStatus.WORKING.getKey(), |
| | | Constants.PlatformJobStatus.CALLED.getKey()) |
| | | .orderByDesc(PlatformJob::getStatus) |
| | | .orderByAsc(PlatformJob::getSignDate) |
| | |
| | | } |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | private Logger logger = LoggerFactory.getLogger(PlatformJobServiceImpl.class); |
| | | |
| | | @Override |
| | |
| | | import com.doumee.core.model.PageData; |
| | | import com.doumee.core.model.PageWrap; |
| | | import com.doumee.core.utils.*; |
| | | import com.doumee.core.wx.wxPlat.WxPlatNotice; |
| | | import com.doumee.dao.business.*; |
| | | import com.doumee.dao.business.dao.SmsConfigMapper; |
| | | import com.doumee.dao.business.dao.SmsEmailMapper; |
| | |
| | | |
| | | @Override |
| | | public Integer sendSms(SmsEmail smsEmail) { |
| | | if(StringUtils.isBlank(smsEmail.getPhone())){ |
| | | if(StringUtils.isBlank(smsEmail.getPhone()) || smsEmail.getPhone().length() != 11 ){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST); |
| | | } |
| | | String nowDate = DateUtil.getFomartDate(new Date(),"yyyy-MM-dd HH:mm:ss"); |
| | |
| | | List<SmsEmail> smsEmails = smsEmailMapper.selectList(wrapper); |
| | | if(smsEmails!=null && smsEmails.size()>0){ |
| | | for(SmsEmail model : smsEmails){ |
| | | if(model.getPhone() == null){ |
| | | model.setStatus(Constants.THREE);//åé失败 |
| | | model.setRemark("ææºå·ä¸ºç©ºï¼åæ¶ä»»å¡åéï¼"); |
| | | }else{ |
| | | try { |
| | | emayService.sendSmsByHk(model.getPhone(),model.getContent()); |
| | | model.setStatus(Constants.ONE);//åéæå |
| | | model.setRemark("çä¿¡ä»»å¡åéæå"); |
| | | }catch (Exception e){ |
| | | if(Constants.equalsInteger(model.getType(),Constants.ONE)){ |
| | | if(model.getPhone() == null){ |
| | | model.setStatus(Constants.THREE);//åé失败 |
| | | model.setRemark("çä¿¡ä»»å¡åé失败ï¼"+e.getMessage()); |
| | | model.setRemark("ææºå·ä¸ºç©ºï¼åæ¶ä»»å¡åéï¼"); |
| | | }else{ |
| | | try { |
| | | emayService.sendSmsByHk(model.getPhone(),model.getContent()); |
| | | model.setStatus(Constants.ONE);//åéæå |
| | | model.setRemark("çä¿¡ä»»å¡åéæå"); |
| | | }catch (Exception e){ |
| | | model.setStatus(Constants.THREE);//åé失败 |
| | | model.setRemark("çä¿¡ä»»å¡åé失败ï¼"+e.getMessage()); |
| | | } |
| | | } |
| | | }else if(Constants.equalsInteger(model.getType(),Constants.TWO)){ |
| | | if(DateUtil.fromStringToDate("yyyy-MM-dd HH:mm:ss",model.getInfo()).getTime() < System.currentTimeMillis()){ |
| | | WxPlatNotice wxPlatNotice = new WxPlatNotice(); |
| | | wxPlatNotice.sendMeetTemplateNotice(systemDictDataBiz,model,systemDictDataBiz.queryByCode(Constants.WX_PLATFORM, Constants.WX_PLATFORM_ACCESS_TOKEN).getCode()); |
| | | model.setStatus(Constants.ONE);//åéæå |
| | | model.setRemark("微信éç¥åéæå"); |
| | | }else{ |
| | | model.setStatus(Constants.THREE);//åéæå |
| | | model.setRemark("微信éç¥åé失败"); |
| | | } |
| | | }else{ |
| | | continue; |
| | | } |
| | | model.setEditDate(new Date()); |
| | | smsEmailMapper.updateById(model); |
| | |
| | | temperatureHumidityDataResponseList.stream().filter(i->i.getIndexCode().indexOf(code)>=Constants.ZERO).collect(Collectors.toList()); |
| | | TemperatureHumidityDataVO temperatureHumidityDataVO = new TemperatureHumidityDataVO(); |
| | | for (TemperatureHumidityDataResponse data:dateList) { |
| | | if(data.getSensorType().equals("temp")){ |
| | | if(StringUtils.isNotBlank(data.getName())){ |
| | | Integer index = data.getName().indexOf("-"); |
| | | if(index>=0){ |
| | | data.setName(data.getName().substring(0,index)); |
| | | } |
| | | } |
| | | if(data.getSensorType().equals("currTemperature")){ |
| | | temperatureHumidityDataVO.setTemperatureData(data); |
| | | }else{ |
| | | temperatureHumidityDataVO.setHumidityData(data); |
| | |
| | | .select("( select pl.CREATE_DATE from platform_log pl where t.id = pl.obj_id and pl.OBJ_TYPE = "+Constants.PlatformJobLogType.WORKING.getKey()+" order by pl.CREATE_DATE desc limit 1 ) as newStartDate") |
| | | //.select(" ( select sum(ifnull(pl.IO_QTY , 0 )) from platform_wms_detail pl where pl.job_id = t.id and pl.isdeleted=0 )",PlatformJob::getWorkNum) |
| | | .select(" ( case when t.total_num is null then ( select sum(pwd.IO_QTY) from platform_wms_detail pwd where pwd.JOB_ID = t.id ) else t.total_num end )",PlatformJob::getWorkNum) |
| | | .apply("to_days(t.create_date) = to_days(now())") |
| | | // .apply("to_days(t.create_date) = to_days(now())") |
| | | .eq(Platform::getIsdeleted, Constants.ZERO) |
| | | .in(PlatformJob ::getStatus,new Integer[]{Constants.PlatformJobStatus.WORKING.getKey(),Constants.PlatformJobStatus.CALLED.getKey() }) |
| | | // .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) |
| | | .orderByDesc(PlatformJob::getStatus )); |
| | | .orderByDesc(PlatformJob::getStatus ) |
| | | .orderByAsc(PlatformJob::getId ) |
| | | ); |
| | | //æå°ç¶æï¼0=ä½ä¸ä¸ï¼1=空é²ä¸ï¼2=ä½ä¸è¶
æ¶;3=å«å· |
| | | for(Platform model : platformList){ |
| | | PlatformWorkDataVO platformDurationVO = new PlatformWorkDataVO(); |