¶Ô±ÈÐÂÎļþ |
| | |
| | | import request from '../../utils/request' |
| | | |
| | | // æ¥è¯¢ |
| | | export function fetchList (data) { |
| | | return request.post('/visitsAdmin/cloudService/business/platformBroadcastLog/page', data, { |
| | | trim: true |
| | | }) |
| | | } |
| | | |
| | | // è·åé¨ç¦éå-æä¾ç»é¨ç¦ç» |
| | | export function getList (data) { |
| | | return request.post('/visitsAdmin/cloudService/business/platformBroadcastLog/getList', data) |
| | | } |
| | | export function getDeviceRoleList (data) { |
| | | return request.post('/visitsAdmin/cloudService/business/platformBroadcastLogRole/list', data) |
| | | } |
| | | |
| | | // ä¿®æ¹ |
| | | export function updateById (data) { |
| | | return request.post('/visitsAdmin/cloudService/business/platformBroadcastLog/updateById', data) |
| | | } |
| | |
| | | <el-form-item label="æ¾ç¤ºå
容" prop="title"> |
| | | <el-input v-model="form.title" placeholder="请è¾å
¥LED屿¾ç¤ºå
容" v-trim/> |
| | | </el-form-item> |
| | | <el-form-item label="ææ¾é度" prop="title"> |
| | | <el-form-item label="ææ¾é度" prop="speed"> |
| | | <el-input type="number" v-model="form.speed" placeholder="请è¾å
¥ææ¾é度(大äº0æ°åï¼" v-trim/> |
| | | </el-form-item> |
| | | </el-form> |
¶Ô±ÈÐÂÎļþ |
| | |
| | | <template> |
| | | <TableLayout :permissions="['business:platformbroadcastlog:query']"> |
| | | <!-- æç´¢è¡¨å --> |
| | | <el-form ref="searchForm" slot="search-form" :model="searchForm" label-width="100px" inline> |
| | | <el-form-item label="" prop="name"> |
| | | <el-input v-model="searchForm.name" placeholder="请è¾å
¥æ é¢" @keypress.enter.native="search"></el-input> |
| | | </el-form-item> |
| | | <el-form-item label="" prop="content"> |
| | | <el-input v-model="searchForm.content" placeholder="请è¾å
¥å
容" @keypress.enter.native="search"></el-input> |
| | | </el-form-item> |
| | | <el-form-item label="" prop="personType"> |
| | | <el-select v-model="searchForm.deviceType" placeholder="è¯·éæ©è®¾å¤ç±»å"> |
| | | <el-option label="广æ" value="0"></el-option> |
| | | <el-option label="LED" value="1"></el-option> |
| | | </el-select> |
| | | </el-form-item> |
| | | <el-form-item label="" prop="eventType"> |
| | | <el-select v-model="searchForm.hkStatus" placeholder="è¯·éæ©ä¸åç¶æ"> |
| | | <el-option label="å¾
ä¸å" value="0"></el-option> |
| | | <el-option label="ä¸åä¸" value="1"></el-option> |
| | | <el-option label="ä¸åæå" value="2"></el-option> |
| | | <el-option label="ä¸å失败" value="3"></el-option> |
| | | </el-select> |
| | | </el-form-item> |
| | | <el-form-item label="èµ·æ¢æ¶é´" prop="eventType"> |
| | | <el-date-picker |
| | | @change="seleTime" |
| | | v-model="time" |
| | | type="datetimerange" |
| | | format="yyyy-MM-dd HH:mm:ss" |
| | | value-format="yyyy-MM-dd HH:mm:ss" |
| | | range-separator="è³" |
| | | start-placeholder="å¼å§æ¶é´" |
| | | end-placeholder="ç»ææ¶é´"> |
| | | </el-date-picker> |
| | | </el-form-item> |
| | | <el-radio-group v-model="searchForm.radio" size="small" @input="changeRadio"> |
| | | <el-radio-button label="0">å½å¤©</el-radio-button> |
| | | <el-radio-button label="1">è¿7天</el-radio-button> |
| | | <el-radio-button label="2">è¿30天</el-radio-button> |
| | | </el-radio-group> |
| | | <section> |
| | | <el-button type="primary" @click="search">æç´¢</el-button> |
| | | <el-button @click="reset">éç½®</el-button> |
| | | </section> |
| | | </el-form> |
| | | <!-- è¡¨æ ¼åå页 --> |
| | | <template v-slot:table-wrap> |
| | | <ul class="toolbar" v-permissions="['business:platformbroadcastlog:exportExcel']"> |
| | | <!-- |
| | | <li><el-button type="primary" :loading="isWorking.export" v-permissions="['business:platformbroadcastlog:exportExcel']" @click="exportExcel">导åº</el-button></li> |
| | | --> |
| | | </ul> |
| | | <el-table |
| | | v-loading="isWorking.search" |
| | | :data="tableData.list" |
| | | stripe |
| | | > |
| | | <el-table-column prop="deviceType" label="设å¤ç±»å" min-width="100px"> |
| | | <template slot-scope="{row}"> |
| | | <span v-if="row.deviceType == 0">广æ</span> |
| | | <span v-if="row.deviceType == 1">LED</span> |
| | | </template> |
| | | </el-table-column> |
| | | <el-table-column prop="hkStatus" label="ä¸åç¶æ" min-width="100px"> |
| | | <template slot-scope="{row}"> |
| | | <span v-if="row.hkStatus == 0" style="color: #0c6ce3">å¾
ä¸å</span> |
| | | <span v-if="row.hkStatus == 1" style="color: #0c6ce3">ä¸åä¸</span> |
| | | <span v-if="row.hkStatus == 2" style="color: green">ä¸åæå</span> |
| | | <span v-if="row.hkStatus == 3" style="color: red">ä¸å失败</span> |
| | | </template> |
| | | </el-table-column> |
| | | <el-table-column prop="name" label="æ é¢" min-width="100px"></el-table-column> |
| | | <el-table-column prop="info" label="å
容" min-width="100px"></el-table-column> |
| | | <el-table-column prop="ids" label="设å¤ç¼ç " min-width="100px"></el-table-column> |
| | | <el-table-column prop="remark" label="夿³¨" min-width="100px"></el-table-column> |
| | | <el-table-column prop="createDate" label="å建æ¶é´" min-width="100px"></el-table-column> |
| | | </el-table> |
| | | <pagination |
| | | @size-change="handleSizeChange" |
| | | @current-change="handlePageChange" |
| | | :pagination="tableData.pagination" |
| | | > |
| | | </pagination> |
| | | </template> |
| | | </TableLayout> |
| | | </template> |
| | | |
| | | <script> |
| | | import BaseTable from '@/components/base/BaseTable' |
| | | import TableLayout from '@/layouts/TableLayout' |
| | | import Pagination from '@/components/common/Pagination' |
| | | import { timeForMat } from '@/utils/util' |
| | | export default { |
| | | name: 'DeviceEvent', |
| | | extends: BaseTable, |
| | | components: { TableLayout, Pagination }, |
| | | data () { |
| | | return { |
| | | // æç´¢ |
| | | searchForm: { |
| | | name: '', |
| | | info: '', |
| | | deviceType: '', |
| | | hkStatus: '', |
| | | startTime: '', |
| | | endTime: '', |
| | | radio: 0 |
| | | }, |
| | | time: [] |
| | | } |
| | | }, |
| | | created () { |
| | | this.config({ |
| | | module: 'LEDå¹¿æææ¾è®°å½', |
| | | api: '/business/platformBroadcastLog', |
| | | 'field.id': 'id', |
| | | 'field.main': 'id' |
| | | }) |
| | | this.changeRadio('0') |
| | | }, |
| | | methods: { |
| | | changeRadio (e) { |
| | | if (e === '0') { |
| | | this.searchForm.startTime = timeForMat(0)[0] |
| | | this.searchForm.endTime = timeForMat(0)[1] |
| | | this.time = timeForMat(0) |
| | | } else if (e === '1') { |
| | | this.searchForm.startTime = timeForMat(6)[0] |
| | | this.searchForm.endTime = timeForMat(6)[1] |
| | | this.time = timeForMat(6) |
| | | } else if (e === '2') { |
| | | this.searchForm.startTime = timeForMat(29)[0] |
| | | this.searchForm.endTime = timeForMat(29)[1] |
| | | this.time = timeForMat(29) |
| | | } |
| | | this.search() |
| | | }, |
| | | seleTime (e) { |
| | | this.searchForm.startTime = e[0] |
| | | this.searchForm.endTime = e[1] |
| | | this.searchForm.radio = null |
| | | this.search() |
| | | }, |
| | | reset () { |
| | | this.$refs.searchForm.resetFields() |
| | | this.time = [] |
| | | this.searchForm.radio = '0' |
| | | this.changeRadio('0') |
| | | this.search() |
| | | } |
| | | } |
| | | } |
| | | </script> |
| | |
| | | import io.swagger.annotations.ApiImplicitParam; |
| | | import io.swagger.annotations.ApiImplicitParams; |
| | | import io.swagger.annotations.ApiOperation; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.apache.shiro.authz.annotation.RequiresPermissions; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.data.redis.core.RedisTemplate; |
| | |
| | | |
| | | import javax.servlet.http.HttpServletRequest; |
| | | import javax.servlet.http.HttpServletResponse; |
| | | import java.io.BufferedReader; |
| | | import java.util.ArrayList; |
| | | import java.util.HashMap; |
| | | import java.util.List; |
| | |
| | | */ |
| | | @Api(tags = "æµ·åº·æ°æ®åæ¥æ¥å£") |
| | | @RestController |
| | | @Slf4j |
| | | @RequestMapping(Constants.CLOUD_SERVICE_URL_INDEX+"/business/hksync") |
| | | public class HkSyncCloudController extends BaseController { |
| | | |
| | |
| | | String result = hkSyncPushService.dealPlatformCarsEvent(param,response); |
| | | return ApiResponse.success(result); |
| | | } |
| | | @ApiOperation("ãæµ·åº·testãæå°è½¦è¾ç¶æäºä»¶è®¢é
æ¨é对æ¥å¤çæ¥å£") |
| | | @PostMapping("/push/platform/carstatusTest") |
| | | @LoginNoRequired |
| | | public ApiResponse pushPlatformCarStatus(HttpServletRequest request, HttpServletResponse response ){ |
| | | doPringParam(request,"ãæµ·åº·testãæå°è½¦è¾ç¶æäºä»¶è®¢é
æ¨é对æ¥å¤çæ¥å£:\n"); |
| | | return ApiResponse.success(null); |
| | | } |
| | | public void doPringParam(HttpServletRequest request,String name) { |
| | | try { |
| | | StringBuilder data =new StringBuilder(); |
| | | String line; |
| | | BufferedReader reader =request.getReader(); |
| | | while(null !=(line = reader.readLine())) { |
| | | data.append(line); |
| | | } |
| | | if(StringUtils.isNotBlank( data.toString())){ |
| | | log.info(name+"=================åæ°ï¼"+ data.toString()); |
| | | }else { |
| | | log.info(name+"=================ï¼åæ°ä¸ºç©º"); |
| | | } |
| | | }catch (Exception e){ |
| | | |
| | | log.info(name+"================= åæ°å¼å¸¸ï¼"+e.getMessage()); |
| | | } |
| | | } |
| | | @PreventRepeat |
| | | @ApiOperation("ãæµ·åº·ãåæ¶è®¢é
äºä»¶") |
| | | @PostMapping("/cancelEventSub") |
| | |
| | | package com.doumee.cloud.admin; |
| | | |
| | | import com.doumee.api.BaseController; |
| | | import com.doumee.config.annotation.CloudRequiredPermission; |
| | | import com.doumee.core.annotation.excel.ExcelExporter; |
| | | import com.doumee.core.annotation.pr.PreventRepeat; |
| | | import com.doumee.core.model.ApiResponse; |
| | |
| | | import com.doumee.service.business.PlatformBroadcastLogService; |
| | | import io.swagger.annotations.Api; |
| | | import io.swagger.annotations.ApiOperation; |
| | | import org.apache.shiro.authz.annotation.RequiresPermissions; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.web.bind.annotation.*; |
| | | import javax.servlet.http.HttpServletResponse; |
| | |
| | | @PreventRepeat |
| | | @ApiOperation("æ°å»º") |
| | | @PostMapping("/create") |
| | | @RequiresPermissions("business:platformbroadcastlog:create") |
| | | @CloudRequiredPermission("business:platformbroadcastlog:create") |
| | | public ApiResponse create(@RequestBody PlatformBroadcastLog platformBroadcastLog) { |
| | | return ApiResponse.success(platformBroadcastLogService.create(platformBroadcastLog)); |
| | | } |
| | | |
| | | @ApiOperation("æ ¹æ®IDå é¤") |
| | | @GetMapping("/delete/{id}") |
| | | @RequiresPermissions("business:platformbroadcastlog:delete") |
| | | @CloudRequiredPermission("business:platformbroadcastlog:delete") |
| | | public ApiResponse deleteById(@PathVariable Integer id) { |
| | | platformBroadcastLogService.deleteById(id); |
| | | return ApiResponse.success(null); |
| | |
| | | |
| | | @ApiOperation("æ¹éå é¤") |
| | | @GetMapping("/delete/batch") |
| | | @RequiresPermissions("business:platformbroadcastlog:delete") |
| | | @CloudRequiredPermission("business:platformbroadcastlog:delete") |
| | | public ApiResponse deleteByIdInBatch(@RequestParam String ids) { |
| | | String [] idArray = ids.split(","); |
| | | List<Integer> idList = new ArrayList<>(); |
| | |
| | | |
| | | @ApiOperation("æ ¹æ®IDä¿®æ¹") |
| | | @PostMapping("/updateById") |
| | | @RequiresPermissions("business:platformbroadcastlog:update") |
| | | @CloudRequiredPermission("business:platformbroadcastlog:update") |
| | | public ApiResponse updateById(@RequestBody PlatformBroadcastLog platformBroadcastLog) { |
| | | platformBroadcastLogService.updateById(platformBroadcastLog); |
| | | return ApiResponse.success(null); |
| | |
| | | |
| | | @ApiOperation("å页æ¥è¯¢") |
| | | @PostMapping("/page") |
| | | @RequiresPermissions("business:platformbroadcastlog:query") |
| | | @CloudRequiredPermission("business:platformbroadcastlog:query") |
| | | public ApiResponse<PageData<PlatformBroadcastLog>> findPage (@RequestBody PageWrap<PlatformBroadcastLog> pageWrap) { |
| | | return ApiResponse.success(platformBroadcastLogService.findPage(pageWrap)); |
| | | } |
| | | |
| | | @ApiOperation("导åºExcel") |
| | | @PostMapping("/exportExcel") |
| | | @RequiresPermissions("business:platformbroadcastlog:exportExcel") |
| | | @CloudRequiredPermission("business:platformbroadcastlog:exportExcel") |
| | | public void exportExcel (@RequestBody PageWrap<PlatformBroadcastLog> pageWrap, HttpServletResponse response) { |
| | | ExcelExporter.build(PlatformBroadcastLog.class).export(platformBroadcastLogService.findPage(pageWrap).getRecords(), "æå°_LEDå广ææéä¸åè®°å½", response); |
| | | } |
| | | |
| | | @ApiOperation("æ ¹æ®IDæ¥è¯¢") |
| | | @GetMapping("/{id}") |
| | | @RequiresPermissions("business:platformbroadcastlog:query") |
| | | @CloudRequiredPermission("business:platformbroadcastlog:query") |
| | | public ApiResponse findById(@PathVariable Integer id) { |
| | | return ApiResponse.success(platformBroadcastLogService.findById(id)); |
| | | } |
| | |
| | | return new WmsBaseResponse(); |
| | | } |
| | | |
| | | private void doPringParam(HttpServletRequest request,String name) { |
| | | public static void doPringParam(HttpServletRequest request,String name) { |
| | | try { |
| | | StringBuilder data =new StringBuilder(); |
| | | String line; |
| | |
| | | param.setEventDest(path+"/platform/workstatus"); |
| | | param.setEventTypes(new Integer[]{HKConstants.EventTypes.PLATFORM_WORKSTATUS.getKey()}); |
| | | HKService.cancelEventSub(param);//å
åæ¶ |
| | | HKService.eventSub(param);//æå°å·¥ä½ç¶æäºä»¶ |
| | | // HKService.eventSub(param);//æå°å·¥ä½ç¶æäºä»¶ |
| | | |
| | | |
| | | param.setEventDest(path+"/platform/carstatus"); |
| | |
| | | public static final String ARTEMIS_PATH = "/artemis"; |
| | | |
| | | /** |
| | | * å¿«æ·èå跳转页é¢åæ° |
| | | * 1ã综åå®é²ï¼zhaf |
| | | * 2ãç©ä¸åå¤ï¼wyhq |
| | | * 3ãè¡æ¿åå
¬ï¼xzbg |
| | | * 4ãè¿è¥ä¸å¿ï¼yyzx |
| | | åç¹ç»å½æ¨¡åèåæ è¯ï¼ |
| | | 1ãå®é²ä¸å¿ï¼afzx |
| | | 2ãæ¶æ§ä¸å¿ï¼xkzx |
| | | 3ãè½ç®¡ä¸å¿ï¼ngzx |
| | | 4ã驾驶è±ï¼jsc |
| | | 5ãèå¤ç®¡çï¼kqgl |
| | | * |
| | | * 1ãå®é²ä¸å¿ï¼afzx |
| | | * 2ãæ¶æ§ä¸å¿ï¼xkzx |
| | |
| | | */ |
| | | public interface MenuPageId{ |
| | | String afzx = "afzx";//å®é²ä¸å¿ |
| | | String zhaf = "zhaf";//æ¶æ§ä¸å¿ |
| | | String xkzx = "xkzx";//æ¶æ§ä¸å¿ |
| | | String ngzx = "ngzx";//è½ç®¡ä¸å¿ |
| | | String wyhq = "wyhq";//ç©ä¸åå¤ |
| | | String xkzx = "xkzx";//综åå®é² |
| | | String xzbg = "xzbg";//è¡æ¿åå
¬ |
| | | String yyzx = "yyzx";//è¿è¥ä¸å¿ |
| | | String jsc = "jsc";//ç©ä¸åå¤ |
| | | String kqgl = "kqgl";//èå¤ç®¡ç |
| | | |
| | | } |
| | | |
| | |
| | | package com.doumee.core.haikang.model.param.request.event.parks; |
| | | |
| | | import com.alibaba.fastjson.annotation.JSONField; |
| | | import com.fasterxml.jackson.annotation.JsonProperty; |
| | | import lombok.Data; |
| | | |
| | | import java.util.List; |
| | | |
| | | @Data |
| | | public class EventPlatformCarsDataRequest { |
| | | private EventPlatformCarsStatusInfoRequest HPVehicleStatus;// |
| | | @JSONField(name="HPVehicleStatus") |
| | | @JsonProperty(value = "HPVehicleStatus") |
| | | private EventPlatformCarsStatusInfoRequest hPVehicleStatus;// |
| | | private EventPlatformAttrInfoRequest targetAttrs;// |
| | | private String dataType;//HPVehicleStatus |
| | | private String sendTime;//2017-04-22T15:39:01.000+08:00 |
| | |
| | | package com.doumee.core.haikang.model.param.request.event.parks; |
| | | |
| | | import com.alibaba.fastjson.annotation.JSONField; |
| | | import com.fasterxml.jackson.annotation.JsonProperty; |
| | | import lombok.Data; |
| | | |
| | | import java.math.BigDecimal; |
| | | |
| | | @Data |
| | | public class EventPlatformCarsStatusInfoRequest { |
| | | private String HPNo;// 1,车éå· |
| | | @JSONField(name="HPNo") |
| | | @JsonProperty(value = "HPNo") |
| | | private String hPNo;// 1,车éå· |
| | | private Integer plateScore;//: 80车çè¯å |
| | | private String motionStatus;//'leave',è¿å¨ç¶æ enter#è¿å
¥,leave#ç¦»å¼ |
| | | private String plateNo;//'A12345',车çå· |
| | | private String vehicleDoorStatus;//'open',车é¨ç¶æÂ open-å¼é¨ï¼close-å
³é¨ |
| | | private String stockStatus;//'rear',è½¦å¤´è½¦å°¾ç¶æÂ Â front#车头,rear#车尾 |
| | | private EventImageInfoRequest BackgroundImage;//æå°èæ¯å¤§å¾ |
| | | private EventImageInfoRequest PlatePicture;//车çå¾ |
| | | @JSONField(name="BackgroundImage") |
| | | @JsonProperty(value = "BackgroundImage") |
| | | private EventImageInfoRequest backgroundImage;//æå°èæ¯å¤§å¾ |
| | | @JSONField(name="PlatePicture") |
| | | @JsonProperty(value = "PlatePicture") |
| | | private EventImageInfoRequest platePicture;//车çå¾ |
| | | |
| | | } |
| | |
| | | * @return |
| | | */ |
| | | public static String getMenuUrl(Integer type,String token){ |
| | | String menuId = HKConstants.MenuPageId.zhaf; |
| | | String menuId = HKConstants.MenuPageId.afzx; |
| | | if(Constants.equalsInteger(type,Constants.ONE)){ |
| | | menuId = HKConstants.MenuPageId.wyhq; |
| | | menuId = HKConstants.MenuPageId.xkzx; |
| | | }else if(Constants.equalsInteger(type,Constants.TWO)){ |
| | | menuId = HKConstants.MenuPageId.xzbg; |
| | | menuId = HKConstants.MenuPageId.ngzx; |
| | | }else if(Constants.equalsInteger(type,Constants.THREE)){ |
| | | menuId = HKConstants.MenuPageId.yyzx; |
| | | menuId = HKConstants.MenuPageId.jsc; |
| | | }else if(Constants.equalsInteger(type,Constants.FOUR)){ |
| | | menuId = HKConstants.MenuPageId.kqgl; |
| | | } |
| | | log.info("ãæµ·åº·è·åå·¥ä½å°èåå
å¯ç»éè°æ´å°åã================å¼å§====menuId:"+menuId+"==token:"+token); |
| | | try { |
| | |
| | | package com.doumee.dao.business.model; |
| | | |
| | | import com.baomidou.mybatisplus.annotation.TableField; |
| | | import com.doumee.core.annotation.excel.ExcelColumn; |
| | | import io.swagger.annotations.ApiModel; |
| | | import io.swagger.annotations.ApiModelProperty; |
| | |
| | | @ExcelColumn(name="ç±»å 0广æ 1LED") |
| | | private Integer deviceType; |
| | | |
| | | |
| | | @ApiModelProperty(value = "å¼å§æ¶é´") |
| | | @TableField(exist = false) |
| | | private Date startDate; |
| | | |
| | | @ApiModelProperty(value = "ç»ææ¶é´") |
| | | @TableField(exist = false) |
| | | private Date endDate; |
| | | } |
| | |
| | | log.setHkDate(new Date()); |
| | | log.setDeviceType(Constants.ONE); |
| | | log.setObjType(Constants.ONE); |
| | | log.setHkId(device.getHkId()); |
| | | log.setIds(device.getNo()); |
| | | log.setRemark(device.getName()); |
| | | if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){ |
| | | log.setHkInfo("请æ±å¤±è´¥ï¼"+JSONObject.toJSONString(response)); |
| | | log.setHkStatus(Constants.THREE); |
| | |
| | | throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "对ä¸èµ·ï¼å±å¹å
容设置失败"+(response!=null?response.getMsg():"")); |
| | | } |
| | | } |
| | | |
| | | } |
| | |
| | | import com.doumee.core.model.PageWrap; |
| | | import com.doumee.core.utils.Utils; |
| | | import com.doumee.dao.business.PlatformBroadcastLogMapper; |
| | | import com.doumee.dao.business.model.InterfaceLog; |
| | | import com.doumee.dao.business.model.PlatformBroadcastLog; |
| | | import com.doumee.service.business.PlatformBroadcastLogService; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | |
| | | .ge(pageWrap.getModel().getEditDate() != null, PlatformBroadcastLog::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate())) |
| | | .le(pageWrap.getModel().getEditDate() != null, PlatformBroadcastLog::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate())) |
| | | .eq(pageWrap.getModel().getIsdeleted() != null, PlatformBroadcastLog::getIsdeleted, pageWrap.getModel().getIsdeleted()) |
| | | .eq(pageWrap.getModel().getName() != null, PlatformBroadcastLog::getName, pageWrap.getModel().getName()) |
| | | .eq(pageWrap.getModel().getRemark() != null, PlatformBroadcastLog::getRemark, pageWrap.getModel().getRemark()) |
| | | .like(pageWrap.getModel().getName() != null, PlatformBroadcastLog::getName, pageWrap.getModel().getName()) |
| | | .like(pageWrap.getModel().getRemark() != null, PlatformBroadcastLog::getRemark, pageWrap.getModel().getRemark()) |
| | | .eq(pageWrap.getModel().getObjId() != null, PlatformBroadcastLog::getObjId, pageWrap.getModel().getObjId()) |
| | | .eq(pageWrap.getModel().getObjType() != null, PlatformBroadcastLog::getObjType, pageWrap.getModel().getObjType()) |
| | | .eq(pageWrap.getModel().getNum() != null, PlatformBroadcastLog::getNum, pageWrap.getModel().getNum()) |
| | | .eq(pageWrap.getModel().getIds() != null, PlatformBroadcastLog::getIds, pageWrap.getModel().getIds()) |
| | | .eq(pageWrap.getModel().getInfo() != null, PlatformBroadcastLog::getInfo, pageWrap.getModel().getInfo()) |
| | | .like(pageWrap.getModel().getInfo() != null, PlatformBroadcastLog::getInfo, pageWrap.getModel().getInfo()) |
| | | .eq(pageWrap.getModel().getHkId() != null, PlatformBroadcastLog::getHkId, pageWrap.getModel().getHkId()) |
| | | .eq(pageWrap.getModel().getHkStatus() != null, PlatformBroadcastLog::getHkStatus, pageWrap.getModel().getHkStatus()) |
| | | .ge(pageWrap.getModel().getHkDate() != null, PlatformBroadcastLog::getHkDate, Utils.Date.getStart(pageWrap.getModel().getHkDate())) |
| | | .le(pageWrap.getModel().getHkDate() != null, PlatformBroadcastLog::getHkDate, Utils.Date.getEnd(pageWrap.getModel().getHkDate())) |
| | | .eq(pageWrap.getModel().getHkInfo() != null, PlatformBroadcastLog::getHkInfo, pageWrap.getModel().getHkInfo()) |
| | | .eq(pageWrap.getModel().getBizType() != null, PlatformBroadcastLog::getBizType, pageWrap.getModel().getBizType()) |
| | | .eq(pageWrap.getModel().getDeviceType() != null, PlatformBroadcastLog::getDeviceType, pageWrap.getModel().getDeviceType()) |
| | | ; |
| | | for(PageWrap.SortData sortData: pageWrap.getSorts()) { |
| | | if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) { |
| | | queryWrapper.orderByDesc(sortData.getProperty()); |
| | | } else { |
| | | queryWrapper.orderByAsc(sortData.getProperty()); |
| | | .eq(pageWrap.getModel().getDeviceType() != null, PlatformBroadcastLog::getDeviceType, pageWrap.getModel().getDeviceType()); |
| | | if (pageWrap.getModel().getStartDate() != null) { |
| | | queryWrapper.lambda().ge(PlatformBroadcastLog::getCreateDate, pageWrap.getModel().getStartDate()); |
| | | } |
| | | } |
| | | if (pageWrap.getModel().getEndDate() != null) { |
| | | queryWrapper.lambda().le(PlatformBroadcastLog::getCreateDate, pageWrap.getModel().getEndDate()); |
| | | } |
| | | queryWrapper.lambda().orderByDesc(PlatformBroadcastLog::getCreateDate); |
| | | return PageData.from(platformBroadcastLogMapper.selectPage(page, queryWrapper)); |
| | | } |
| | | |
| | |
| | | */ |
| | | @Service |
| | | public class HkSyncPlatformsServiceImpl extends HkSyncBaseServiceImpl { |
| | | |
| | | @Autowired |
| | | private PlatformMapper platformMapper; |
| | | @Autowired |
| | |
| | | } |
| | | } |
| | | return true; |
| | | |
| | | } |
| | | |
| | | } |
| | |
| | | //åæå
¥ææ°çå¨å人å |
| | | retentionMapper.insert(retentionList); |
| | | } |
| | | log.error("ãæµ·åº·é¨ç¦äºä»¶æ¨éã========æå======="); |
| | | log.info("ãæµ·åº·é¨ç¦äºä»¶æ¨éã========æå======="); |
| | | }catch (Exception e) { |
| | | log.error("ãæµ·åº·é¨ç¦äºä»¶æ¨éã========失败=======ï¼\n" + e.getMessage()); |
| | | }finally { |
| | |
| | | //åæå
¥ææ°çå¨å人å |
| | | retentionMapper.insert(retentionList); |
| | | } |
| | | log.error("ãæµ·åº·è®¿å®¢äºä»¶æ¨éã========æå======="); |
| | | log.info("ãæµ·åº·è®¿å®¢äºä»¶æ¨éã========æå======="); |
| | | }catch (Exception e){ |
| | | |
| | | log.error("ãæµ·åº·è®¿å®¢äºä»¶æ¨éã========失败=======ï¼\n"+e.getMessage()); |
| | |
| | | //åæå
¥ææ°çå¨å人å |
| | | retentionMapper.insert(retentionList); |
| | | } |
| | | log.error("ãæµ·åº·è®¿å®¢äºä»¶æ¨éã========æå======="); |
| | | log.info("ãæµ·åº·è®¿å®¢äºä»¶æ¨éã========æå======="); |
| | | }catch (Exception e){ |
| | | log.error("ãæµ·åº·è®¿å®¢äºä»¶æ¨éã========失败=======ï¼\n"+e.getMessage()); |
| | | } |
| | |
| | | //åæå
¥ææ°çå¨å人å |
| | | retentionMapper.insert(retentionList); |
| | | } |
| | | log.error("ãæµ·åº·å车åºäºä»¶æ¨éã========æå======="); |
| | | log.info("ãæµ·åº·å车åºäºä»¶æ¨éã========æå======="); |
| | | }catch (Exception e){ |
| | | |
| | | log.error("ãæµ·åº·å车åºäºä»¶æ¨éã========失败=======ï¼\n"+e.getMessage()); |
| | |
| | | event.setReleaseResult(request.getData().getInResult().getRlsResult().getReleaseResult()); |
| | | event.setReleaseResultEx(request.getData().getInResult().getRlsResult().getReleaseResultEx()); |
| | | } |
| | | |
| | | if(request.getData().getPicUrl()!=null){ |
| | | //车è¾åå车çç
§ç |
| | | event.setVehiclePicUrl(getHkImgUrl(request.getData().getPicUrl().getVehiclePicUrl())); |
| | |
| | | delRetentionList.add(event.getPlateNos()); |
| | | } |
| | | } |
| | | |
| | | return event; |
| | | |
| | | } |
| | | |
| | | private Retention getRetentionModelByParkRequest(EventParkInfoRequest request) { |
| | |
| | | retention.setType(Constants.THREE); |
| | | // retention.setDeviceName(request.getSrcName()); |
| | | // retention.setDeviceIndex(request.getSrcIndex()); |
| | | |
| | | return retention; |
| | | } |
| | | |
| | |
| | | } |
| | | } |
| | | result = "æå"; |
| | | log.error("ãæµ·åº·æå°å·¥ä½ç¶æäºä»¶æ¨éã========æå======="); |
| | | log.info("ãæµ·åº·æå°å·¥ä½ç¶æäºä»¶æ¨éã========æå======="); |
| | | }catch (Exception e) { |
| | | result = "失败"+e.getMessage(); |
| | | log.error("ãæµ·åº·æå°å·¥ä½ç¶æäºä»¶æ¨éã========失败=======ï¼\n" + e.getMessage()); |
| | |
| | | platformEventMapper.insert(eventList); |
| | | } |
| | | result = "æå"; |
| | | log.error("ãæµ·åº·æå°è½¦è¾ç¶æäºä»¶æ¨éã========æå======="); |
| | | log.info("ãæµ·åº·æå°è½¦è¾ç¶æäºä»¶æ¨éã========æå======="); |
| | | }catch (Exception e) { |
| | | result = "失败"+e.getMessage(); |
| | | log.error("ãæµ·åº·æå°è½¦è¾ç¶æäºä»¶æ¨éã========失败=======ï¼\n" + e.getMessage()); |
| | |
| | | content = content.replace("${param2}",model.getCarCodeFront()); |
| | | List<String> broadcastList = new ArrayList<>(); |
| | | List<String> ledList = new ArrayList<>(); |
| | | String bNames = ""; |
| | | List<PlatformBroadcastLog> logList = new ArrayList<>(); |
| | | for(PlatformDevice device : deviceList){ |
| | | if(StringUtils.isNotBlank(device.getHkId())){ |
| | |
| | | log.setHkDate(new Date()); |
| | | log.setObjType(Constants.ONE); |
| | | log.setIds(device.getHkNo()); |
| | | log.setRemark(device.getName()); |
| | | log.setInfo(content); |
| | | log.setNum(Constants.ONE); |
| | | BaseResponse response = dealLedContentBiz(device.getHkNo(),content,speed,1); |
| | |
| | | ledList.add(device.getHkId()); |
| | | }else if(Constants.equalsInteger(device.getType(),Constants.ZERO)){ |
| | | //妿æ¯å¹¿æç¹ |
| | | bNames += device.getName()+";"; |
| | | broadcastList.add(device.getHkId()); |
| | | } |
| | | } |
| | |
| | | log.setHkDate(new Date()); |
| | | log.setObjType(Constants.ONE); |
| | | log.setInfo(content1); |
| | | log.setRemark(bNames); |
| | | log.setNum(Constants.ONE); |
| | | log.setIds(String.join(",",broadcastList)); |
| | | CustomBroadcastRequest request = new CustomBroadcastRequest(); |