Skip to content

罗鑫霖 / vion-tools

Go to a project
Commit 402c2847 by 李金轩
Options

ljx

1 parent f6b11234
Inline Side-by-side
Showing 7 changed files with 1149 additions and 1036 deletions
.gitignore
.vscode
\ No newline at end of file \ No newline at end of file
.vscode
.idea
\ No newline at end of file \ No newline at end of file
push.bat 0 → 100644
git status
git add *
git commit -m %1%
git pull
git push
git status
\ No newline at end of file \ No newline at end of file
static/index.html
This diff could not be displayed because it is too large.
static/js/api.js
const API = { const API = {
Login: '/users/login', Login: '/users/login',
Accounts: '/accounts', Accounts: '/accounts',
Malls: '/malls', Malls: '/malls',
Gates: '/gates', Gates: '/gates',
Devices: '/devices', Devices: '/devices',
Channels: '/channels', Channels: '/channels',
Mall: '/mall/', Mall: '/mall/',
FaceRecognitionsCount: '/faceRecognitions/count', FaceRecognitionsCount: '/faceRecognitions/count',
SimulationFaceRecognition: '/simulation/faceRecognition', SimulationFaceRecognition: '/simulation/faceRecognition',
SimulationCountData: '/simulation/countData', SimulationCountData: '/simulation/countData',
PreviewCountData: '/preview/countData', PreviewCountData: '/preview/countData',
mallStaffFeature: '/mall/staffFeature', mallStaffFeature: '/mall/staffFeature',
MallFeature: '/mall/feature', MallFeature: '/mall/feature',
MallStaffPool: '/mall/staffPool', MallStaffPool: '/mall/staffPool',
MallCustomPool: '/mall/customPool', MallCustomPool: '/mall/customPool',
MallStaff: '/mall/staff', MallStaff: '/mall/staff',
MallCustom: '/mall/custom' MallCustom: '/mall/custom'
} }
const WSAPI = { const WSAPI = {
RecalSchedule: '/recal/schedule/' RecalSchedule: '/recal/schedule/'
} }
static/js/common.js
window._serverHost = window.location.hostname === 'localhost' ? 'store.keliuyun.com:9998' : window.location.host
window._baseUrl = `http://${window._serverHost}`
window._CONF_ = { window._CONF_ = {
reportApiUrl: '', reportApiUrl: '',
apiUrl: '', apiUrl: window._baseUrl,
webSockUrl: '' webSockUrl: ''
} }
const log = console.log.bind(console)
static/js/home.js
const trafficOptions = [ const trafficOptions = [
"mall/countData", "mall/countData",
"floor/countData", "floor/countData",
"zone/countData", "zone/countData",
"gate/countData" "gate/countData"
]; ]
const faceOptions = [ const faceOptions = [
"mall/faceSta", "mall/faceSta",
"floor/faceSta", "floor/faceSta",
"zone/faceSta", "zone/faceSta",
"gate/faceSta" "gate/faceSta"
]; ]
// const TAB_API = { // const TAB_API = {
// featureRevisit: '', // featureRevisit: '',
// featureLibRebuild: [], // featureLibRebuild: [],
// } // }
new Vue({ new Vue({
el: "#app", el: "#app",
data: function() { data: function() {
return {
pickerOpts: {
disabledDate(time) {
return Date.parse(time) > Date.parse(new Date());
}
},
radio: "mall",
dateFormat: "rerun",
dateLevelList: [
{ label: 'rerun', name: '数据重跑' },
{ label: 'repair', name: '数据修补' },
{ label: 'revisitFeature', name: '特征重提' },
{ label: 'rebuildFeatureLib', name: '特征库重建' },
{ label: 'rematchPerson', name: '人员重新比对' }
],
UrlType: "trafficRecognition",
compareType: "custom",
count: null,
dateCount: null,
day: "",
hour: "",
min: "",
startDate: "",
endDate: "",
sourceDate: "",
sourceStartTime: "00:00:00",
sourceEndTime: "23:59:59",
aimsDate: "",
aimsStartTime: "00:00:00",
aimsEndTime: "23:59:59",
referenceDate: "",
repairDate: "",
accountVal: [],
mallVal: [],
mallOpts: [],
accountId: [],
accoutOpts: [],
deviceVal: "",
gateVal: "",
channelVal: "",
showDiv: true,
loading: "",
gateOpt: [],
deviceOpt: [],
channelOpt: [],
date: "",
butShow: false,
startShow: false,
tafficShow: false,
startRange: "0.85",
endRange: "1.2",
isMallSelAll: false,
isAccoutSelAll: false,
//全选
checkedTraffic: [],
checkAllTraffic: false,
isIndeterminateTraffic: false,
checkedFace: [],
checkAllFace: false,
isIndeterminateFace: false,
checkTraffic: [
{
name: "",
value: "mall/countData"
},
{
name: "",
value: "floor/countData"
},
{
name: "",
value: "zone/countData"
},
{
name: "",
value: "gate/countData"
}
],
checkFace: [
{
name: "",
value: "mall/faceSta"
},
{
name: "",
value: "floor/faceSta"
},
{
name: "",
value: "zone/faceSta"
},
{
name: "",
value: "gate/faceSta"
}
],
progressName: {
mallcountData: "商场客流",
floorcountData: "楼层客流",
zonecountData: "店铺客流",
gatecountData: "监控点客流",
mallfaceSta: "商场人脸",
floorfaceSta: "楼层人脸",
zonefaceSta: "店铺人脸",
gatefaceSta: "监控点人脸"
},
startTime: "",
endTime: "",
traffStartTime: "00:00:00",
traffEndTime: "23:59:59",
webSocketObj: {},
repairWebSocket: null,
dateTime: [],
progressList: [],
repairProgList: [],
traProgList: [],
tipShow: false,
tipStyle: {},
lineDate: "",
lineMallId: "",
lineMallName: "",
locationHref: false,
/// 特征重提
query: {
accountVal: [],
mallVal: [],
dateVal: null
},
featureRevisitType: 0,
featureLibRebuildType: 1,
rematchPersonType: 1,
featureRevisitList: [
{ label: '人脸+全身照特征', value: 0 },
{ label: '人脸特征', value: 1 },
{ label: '全身照特征', value: 2 },
{ label: '店员特征', value: 3 }
],
featureLibRebuildList: [
{ label: '店员库重建', value: 1 },
{ label: '顾客库重建', value: 2 }
],
rematchPersonList: [
{ label: '店员对比', value: 1 },
{ label: '顾客对比', value: 2 }
],
socket: null,
results: [],
startTiming: 0,
endTiming: 0,
footerText: ''
};
},
filters: {
formatTime(val) {
function autoPrefixZero(num) {
return num > 10 ? num : '0' + num
}
const day = parseInt(val / (24 * 60 * 60 * 1000)) + 1
const hour = parseInt(val % (24 * 60 * 60 * 1000) / (60 * 60 * 1000))
const minutes = parseInt(val % (60 * 60 * 1000) / (60 * 1000))
const seconds = parseInt(val % (60 * 1000) / 1000)
if (val < 1000 || val < 60 * 1000) {
return `${val % (60 * 1000) / 1000} 秒`
} else if (val < 60 * 60 * 1000) {
return `${autoPrefixZero(minutes)} 分钟 ${autoPrefixZero(seconds)} 秒`
} else if (val < 24 * 60 * 60 * 1000) {
return `${autoPrefixZero(hour)} 小时 ${autoPrefixZero(minutes)} 分钟 ${autoPrefixZero(seconds)} 秒`
} else {
return `${autoPrefixZero(day)} 天 ${autoPrefixZero(hour)} 小时 ${autoPrefixZero(minutes)} 分钟 ${autoPrefixZero(seconds)} 秒`
}
}
},
computed: {
isResultsShow() {
return this.dateFormat === 'revisitFeature' ||
this.dateFormat === 'rebuildFeatureLib' ||
this.dateFormat === 'rematchPerson'
},
isSendDateParam() {
if (
(this.dateFormat === 'rebuildFeatureLib'
&& this.featureLibRebuildType === 1
) || (
this.dateFormat === 'revisitFeature'
&& this.featureRevisitType === 3)
) {
return false
}
return true
},
totalTime() {
const { startTiming, endTiming } = this
return endTiming - startTiming
// return this.formatDateToStamp(endTiming) - this.formatDateToStamp(startTiming)
}
},
watch: {
accountVal: {
handler: function (val) {
if(val && val.length) {
this.query.accountVal = val
}
},
deep: true
},
mallVal: {
handler: function (val) {
if(val && val.length) {
this.query.mallVal = val
}
},
deep: true
},
dateFormat: function(val) {
var typeHandler = {
'revisitFeature': this.featureRevisitType,
'rebuildFeatureLib': this.featureLibRebuildType,
'rematchPerson': this.rematchPersonType
}
this.footerText = val === 'compare' ? '数据对比' : this.dateLevelList.find(item => item.label === val).name
this.socket && this.socket.close()
this.results.length && (this.results = [])
this.startTiming = this.endTiming = 0
this.query.type = typeof typeHandler[val] === 'undefined'
? null
: typeHandler[val]
},
featureRevisitType(val) {
this.query.type = val
},
featureLibRebuildType(val) {
this.query.type = val
},
rematchPersonType(val) {
this.query.type = val
}
},
created: function() {
this.locationHref =
location.href.indexOf("?super") != -1 ? true : false;
this.getAccount();
},
mounted: function() {
this.query.dateVal = this.createDate()
this.startTime = this.createDate();
this.endTime = this.createDate();
},
methods: {
createDate() {
var nowDate = new Date();
var day = nowDate.getDate();
var month = nowDate.getMonth() + 1;
var year = nowDate.getFullYear();
if (month >= 1 && month <= 9) {
month = "0" + month;
}
if (day >= 0 && day <= 9) {
day = "0" + day;
}
return year + "-" + month + "-" + day;
},
getProgressName(val) {
return this.progressName[val];
},
getProgressStyle(stepCount, status, oldStepCount) {
if (stepCount == "stepType") {
if (status == "gatecountData" || status == "gatefaceSta") {
return { "margin-left": "448px", "font-size": "18px" };
} else {
return { "margin-left": "465px", "font-size": "18px" };
}
} else {
return { return {
width: (stepCount - oldStepCount) * 405 + "px", pickerOpts: {
"background-color": status ? "#409EFF" : "#f56c6c", disabledDate(time) {
"margin-left": oldStepCount * 405 + 50 + "px" return Date.parse(time) > Date.parse(new Date())
}; }
} },
}, radio: "mall",
lineOver(tag, dates, mallIds, mallNames) { dateFormat: "rerun",
let evt = tag || window.event, dateLevelList: [
_top, {label: 'rerun', name: '数据重跑'},
_left; {label: 'repair', name: '数据修补'},
_top = window.innerHeight - evt.y; {label: 'revisitFeature', name: '特征重提'},
_left = window.innerWidth - evt.x; {label: 'rebuildFeatureLib', name: '特征库重建'},
this.tipStyle = { {label: 'rematchPerson', name: '人员重新比对'},
top: evt.y - 50 + "px", {label: 'snapGatherClass', name: '抓拍聚类'},
left: evt.x + "px" ],
}; UrlType: "trafficRecognition",
this.lineDate = dates; compareType: "custom",
this.lineMallId = mallIds.join(","); count: null,
this.lineMallName = mallNames; dateCount: null,
this.tipShow = true; day: "",
}, hour: "",
lineOut() { min: "",
this.tipShow = false; startDate: "",
}, endDate: "",
handleCheckAllChangeTraffic(val) { sourceDate: "",
// console.log('val',val) sourceStartTime: "00:00:00",
this.checkedTraffic = val ? trafficOptions : []; sourceEndTime: "23:59:59",
// console.log(this.checkedTraffic) aimsDate: "",
this.isIndeterminateTraffic = false; aimsStartTime: "00:00:00",
}, aimsEndTime: "23:59:59",
handleCheckAllChangeFace(val) { referenceDate: "",
// console.log('val',val) repairDate: "",
this.checkedFace = val ? faceOptions : []; accountVal: [],
// console.log(this.checkedFace) mallVal: [],
this.isIndeterminateFace = false; mallOpts: [],
}, accountId: [],
handleCheckedCitiesChangeTraffic(value) { accoutOpts: [],
// console.log(this.checkedTraffic) deviceVal: "",
let checkedCount = value.length; gateVal: "",
this.checkAllTraffic = checkedCount === this.checkTraffic.length; channelVal: "",
this.isIndeterminateTraffic = showDiv: true,
checkedCount > 0 && checkedCount < this.checkTraffic.length; loading: "",
}, gateOpt: [],
handleCheckedCitiesChangeFace(value) { deviceOpt: [],
// console.log(this.checkedFace) channelOpt: [],
let checkedCount = value.length; date: "",
this.checkAllFace = checkedCount === this.checkFace.length; butShow: false,
this.isIndeterminateFace = startShow: false,
checkedCount > 0 && checkedCount < this.checkFace.length; tafficShow: false,
}, startRange: "0.85",
accountchange(linkGate) { endRange: "1.2",
this.isAccoutSelAll = this.isAccoutSelAll isMallSelAll: false,
? this.accountVal.length < this.accoutOpts.length isAccoutSelAll: false,
? false //全选
: true checkedTraffic: [],
: this.accountVal.length < this.accoutOpts.length checkAllTraffic: false,
? false isIndeterminateTraffic: false,
: true; checkedFace: [],
if (this.accountVal.length > 0) { checkAllFace: false,
this.getMall(linkGate); isIndeterminateFace: false,
} checkTraffic: [
}, {
mallchange(linkGate) { name: "",
this.isMallSelAll = this.isMallSelAll value: "mall/countData"
? this.mallVal.length < this.mallOpts.length },
? false {
: true name: "",
: this.mallVal.length < this.mallOpts.length value: "floor/countData"
? false },
: true; {
if (linkGate) { name: "",
this.getGate() value: "zone/countData"
} },
}, {
selAllHandle(level) { name: "",
if (level == "accout") { value: "gate/countData"
if (this.isAccoutSelAll) { }
this.accountVal = []; ],
this.isAccoutSelAll = false; checkFace: [
this.getMall(); {
} else { name: "",
this.accountVal = []; value: "mall/faceSta"
this.accoutOpts.forEach(item => { },
this.accountVal.push(item.id); {
}); name: "",
this.isAccoutSelAll = true; value: "floor/faceSta"
this.getMall(); },
} {
} else { name: "",
if (this.isMallSelAll) { value: "zone/faceSta"
this.mallVal = []; },
this.isMallSelAll = false; {
} else { name: "",
this.mallVal = []; value: "gate/faceSta"
this.mallOpts.forEach(item => { }
this.mallVal.push(item.id); ],
}); progressName: {
this.isMallSelAll = true; mallcountData: "商场客流",
} floorcountData: "楼层客流",
} zonecountData: "店铺客流",
}, gatecountData: "监控点客流",
getAccount: function() { mallfaceSta: "商场人脸",
var _this = this; floorfaceSta: "楼层人脸",
_this.accoutOpts = []; zonefaceSta: "店铺人脸",
get(window._CONF_.apiUrl + API.Accounts).then(function(data) { gatefaceSta: "监控点人脸"
_this.accoutOpts = data; },
if (_this.accoutOpts.length > 0) { startTime: "",
_this.accountVal = [_this.accoutOpts[0].id]; endTime: "",
} traffStartTime: "00:00:00",
_this.getMall(); traffEndTime: "23:59:59",
}).catch(err => { webSocketObj: {},
console.log('err', err) repairWebSocket: null,
}) dateTime: [],
}, progressList: [],
getMall: function() { repairProgList: [],
var _this = this; traProgList: [],
_this.mallOpts = []; tipShow: false,
get(window._CONF_.apiUrl + API.Malls, { tipStyle: {},
accountIds: _this.accountVal.join(",") lineDate: "",
}).then(function(data) { lineMallId: "",
_this.mallOpts = data; lineMallName: "",
if (_this.mallOpts.length > 0) { locationHref: false,
_this.mallVal = [_this.mallOpts[0].id]; /// 特征重提
} query: {
_this.isMallSelAll = accountVal: [],
_this.mallVal.length == _this.mallOpts.length ? true : false; mallVal: [],
}) dateVal: null
}, },
getGate: function() { featureRevisitType: 0,
var _this = this; featureLibRebuildType: 1,
get(window._CONF_.apiUrl + API.Gates, { rematchPersonType: 1,
accountIds: _this.accountVal.join(","), featureRevisitList: [
mallIds: _this.mallVal.join(',') {label: '人脸+全身照特征', value: 0},
}).then(function(data) { {label: '人脸特征', value: 1},
_this.gateOpt = data; {label: '全身照特征', value: 2},
_this.gateVal = _this.gateOpt[0].id; {label: '店员特征', value: 3}
// _this.getDevice() ],
_this.getChannel(); featureLibRebuildList: [
}) {label: '店员库重建', value: 1},
}, {label: '顾客库重建', value: 2}
getDevice: function() { ],
var _this = this; rematchPersonList: [
get(window._CONF_.apiUrl + API.Devices, { {label: '店员对比', value: 1},
// accountIds: _this.accountVal.join(","), {label: '顾客对比', value: 2}
// mallIds: _this.mallVal.join(','), ],
gateId: this.gateVal socket: null,
}).then(function(data) { results: [],
_this.deviceOpt = []; startTiming: 0,
_this.deviceVal = ""; endTiming: 0,
for (var i = 0; i < data.length; i++) { footerText: ''
var temp = {};
temp.name = data[i];
temp.value = data[i];
temp.id = i;
_this.deviceOpt.push(temp);
}
_this.deviceVal = _this.deviceOpt[0].value;
})
},
dateLevel: function() {
if (this.dateFormat == "repair") {
this.getGate();
} else {
// this.getMall();
}
},
getLevel: function() {},
getNumber() {
this.repairProgList = [];
if (this.UrlType == "trafficRecognition") {
// this.getChannel()
} else {
// this.getChannel()
// this.getDevice()
}
},
getChannel() {
var _this = this;
get(window._CONF_.apiUrl + API.Channels, {
// accountIds: _this.accountVal.join(","),
// mallIds: _this.mallVal.join(','),
gateId: this.gateVal
}).then(function(data) {
_this.channelOpt = [];
for (var i = 0; i < data.length; i++) {
var temp = {};
temp.name = data[i];
temp.value = data[i];
temp.id = i;
_this.channelOpt.push(temp);
}
_this.channelVal =
_this.channelOpt.length > 0 ? _this.channelOpt[0].value : "";
})
},
clearDiv() {
$("#showDiv").empty();
},
startData: function() {
this.progressList = [];
if (this.webSocketObj) {
for (var key in this.webSocketObj) {
this.webSocketObj[key].close();
} }
}
let params = {},
startDate = "",
endDate = "";
params = {
startDate: this.startTime + " 00:00:00",
endDate: this.endTime + " 00:00:00",
mallIds: this.mallVal,
scheduleType: "",
mark: Date.parse(new Date())
};
this.checkedTraffic.forEach((item, index) => {
let _scheduleType = "";
let websocket = item.split("/");
websocket.forEach(item1 => {
_scheduleType += item1;
});
params.scheduleType = _scheduleType;
this.openWebSock(_scheduleType, item, params);
});
this.checkedFace.forEach((item, index) => {
let _scheduleType = "";
let websocket = item.split("/");
websocket.forEach(item1 => {
_scheduleType += item1;
});
params.scheduleType = _scheduleType;
this.openWebSock(_scheduleType, item, params);
});
}, },
openWebSock(wsUrl, url, params, processKey = 'progressList') { filters: {
// browser 兼容 formatTime(val) {
// var wsHost = window.location.host; function autoPrefixZero(num) {
var socketUrl = ""; return num > 10 ? num : '0' + num
var webSock_Url = window._CONF_.webSockUrl || window.location.host; }
var obj = {
stepList: []
};
obj.stepType = wsUrl;
obj.mark = params.mark;
if (!webSockUrl) {
webSock = window.location.host;
}
socketUrl = "ws://" + webSock_Url + WSAPI.WSAPI + wsUrl;
this[processKey].push(obj);
var _this = this;
if ("WebSocket" in window) {
_this.webSocketObj[wsUrl] = new WebSocket(socketUrl);
} else if ("MozWebSocket" in window) {
_this.webSocketObj[wsUrl] = new MozWebSocket(socketUrl);
} else {
_this.webSocketObj[wsUrl] = new SockJS(socketUrl);
}
var param = JSON.parse(JSON.stringify(params));
try {
_this.webSocketObj[wsUrl].onopen = function(event) {
console.log("WebSocket:已连接");
_this.returnData(url, param);
};
_this.webSocketObj[wsUrl].onclosed = function() {
console.log("WebSocket关闭");
};
_this.webSocketObj[wsUrl].onmessage = function(evt) { const day = parseInt(val / (24 * 60 * 60 * 1000)) + 1
var msg = JSON.parse(evt.data); const hour = parseInt(val % (24 * 60 * 60 * 1000) / (60 * 60 * 1000))
_this[processKey].forEach((item, index) => { const minutes = parseInt(val % (60 * 60 * 1000) / (60 * 1000))
if ( const seconds = parseInt(val % (60 * 1000) / 1000)
item.stepType == msg.scheduleType && if (val < 1000 || val < 60 * 1000)
item.mark == msg.mark {
) { return `${val % (60 * 1000) / 1000} 秒`
var stepObj = {}; }
stepObj.dates = msg.dates; else if (val < 60 * 60 * 1000)
stepObj.mallIds = msg.mallIds; {
stepObj.mallNames = msg.mallNames; return `${autoPrefixZero(minutes)} 分钟 ${autoPrefixZero(seconds)} 秒`
stepObj.status = msg.status; }
stepObj.stepCount = msg.stepCount; else if (val < 24 * 60 * 60 * 1000)
item.stepList.push(stepObj); {
item.precentsucess = msg.stepCount return `${autoPrefixZero(hour)} 小时 ${autoPrefixZero(minutes)} 分钟 ${autoPrefixZero(seconds)} 秒`
? Math.floor(msg.stepCount * 100) }
: 0; else
} {
}); return `${autoPrefixZero(day)} 天 ${autoPrefixZero(hour)} 小时 ${autoPrefixZero(minutes)} 分钟 ${autoPrefixZero(seconds)} 秒`
// console.log('list',_this[processKey]) }
};
_this.webSocketObj[wsUrl].onerror = function(event) {
console.log("设备WebSocket:发生错误 ");
console.log(event);
};
} catch (error) {}
},
returnData: function(urls, params) {
// console.log(urls,params)
var _this = this;
post(window._CONF_.apiUrl + urls, JSON.stringify(params)).then(function(data) {
if (data) {
_this.loading = "";
_this.showDiv = true;
_this.renderResultToHtml(data)
} }
}).catch(function(err) {
_this.loading = "";
alert("Sorry, The requested property could not be found.");
})
},
getDateCount: function() {
var _this = this;
this.butShow = true;
var params = {
startTime: this.sourceDate + " " + this.sourceStartTime,
endTime: this.sourceDate + " " + this.sourceEndTime,
channelSerialnum: this.channelVal
};
get(window._CONF_.apiUrl + API.FaceRecognitionsCount, params).then(function(data) {
_this.butShow = false;
_this.dateCount = data;
}).catch(function(err) {
_this.butShow = false;
console.log(err);
})
// $.ajax({
// type: "get",
// dataType: "json",
// async: true,
// url: window._CONF_.apiUrl + urls,
// headers: {
// Authorization: Cookies.get('atoken')
// },
// data: params,
// success: function(data) {
// _this.butShow = false;
// _this.dateCount = data;
// },
// error: function(res) {
// _this.butShow = false;
// console.log(res);
// }
// });
},
repairParams: function(type) {
this.repairProgList = [];
if (this.repairWebSocket) {
this.repairWebSocket.close();
}
var url = "",
params = {};
if (type == "face") {
this.startShow = true;
setTimeout(() => {
this.startShow = false;
}, 3000);
var url = API.SimulationFaceRecognition;
var params = {
sourceStartDate: this.sourceDate + " " + this.sourceStartTime,
sourceEndDate: this.sourceDate + " " + this.sourceEndTime,
targetStartDate: this.aimsDate + " " + this.aimsStartTime,
targetEndDate: this.aimsDate + " " + this.aimsEndTime,
channelSerialnum: this.channelVal,
count: Number(this.count),
scheduleType: "simulationfaceRecognition",
mark: Date.parse(new Date())
};
} else {
this.tafficShow = true;
setTimeout(() => {
this.tafficShow = false;
}, 3000);
url = API.SimulationCountData;
params = {
sourceStartDate: this.referenceDate + " " + this.traffStartTime,
sourceEndDate: this.referenceDate + " " + this.traffEndTime,
targetStartDate: this.repairDate + " " + this.traffStartTime,
targetEndDate: this.repairDate + " " + this.traffEndTime,
channelSerialnum: this.channelVal,
minFactor: this.startRange,
maxFactor: this.endRange,
scheduleType: "simulationcountData",
mark: Date.parse(new Date())
};
}
this.openFaceTraffWebSock(url, params);
},
compareParams: function(type) {
params = {
startDate: this.startTime + " 00:00:00",
endDate: this.endTime + " 00:00:00",
mallIds: this.mallVal,
scheduleType: "",
mark: Date.parse(new Date())
};
var url = API.Mall + this.compareType;
this.returnData(url, params);
}, },
openFaceTraffWebSock(url, params) { computed: {
// browser 兼容 isResultsShow() {
// var wsHost = window.location.host; return this.dateFormat === 'revisitFeature' ||
var socketUrl = ""; this.dateFormat === 'rebuildFeatureLib' ||
var webSock_Url = window._CONF_.webSockUrl || window.location.host; this.dateFormat === 'rematchPerson'
var obj = { },
stepList: [] isSendDateParam() {
};
obj.stepType = params.scheduleType;
obj.mark = params.mark;
socketUrl =
"ws://" + webSock_Url + WSAPI.RecalSchedule + params.scheduleType;
this.repairProgList.push(obj);
var _this = this;
if ("WebSocket" in window) {
_this.repairWebSocket = new WebSocket(socketUrl);
} else if ("MozWebSocket" in window) {
_this.repairWebSocket = new MozWebSocket(socketUrl);
} else {
_this.repairWebSocket = new SockJS(socketUrl);
}
var param = JSON.parse(JSON.stringify(params));
try {
_this.repairWebSocket.onopen = function(event) {
console.log("WebSocket:已连接");
_this.repairData(url, params);
};
_this.repairWebSocket.onclosed = function() {
console.log("WebSocket关闭");
};
_this.repairWebSocket.onmessage = function(evt) {
var msg = JSON.parse(evt.data);
_this.repairProgList.forEach((item, index) => {
if ( if (
item.stepType == msg.scheduleType && (this.dateFormat === 'rebuildFeatureLib'
item.mark == msg.mark && this.featureLibRebuildType === 1
) { ) || (
var stepObj = {}; this.dateFormat === 'revisitFeature'
stepObj.counttime = msg.counttime; && this.featureRevisitType === 3)
stepObj.serialnum = msg.serialnum; )
stepObj.status = msg.status; {
stepObj.stepCount = msg.stepCount; return false
item.stepList.push(stepObj); }
item.precentsucess = msg.stepCount return true
? Math.floor(msg.stepCount * 100) },
: 0; totalTime() {
} const {startTiming, endTiming} = this
}); return endTiming - startTiming
}; // return this.formatDateToStamp(endTiming) - this.formatDateToStamp(startTiming)
_this.webSocketObj[wsUrl].onerror = function(event) {
console.log("设备WebSocket:发生错误 ");
console.log(event);
};
} catch (error) {}
},
repairData(url, params) {
let that = this
post(window._CONF_.apiUrl + url, JSON.stringify(params)).then(function(data) {
if (data) {
that.renderResultToHtml(data)
} }
})
}, },
repairPreview: function() { watch: {
var params = { accountVal: {
sourceStartDate: this.referenceDate + " " + this.traffStartTime, handler: function(val) {
sourceEndDate: this.referenceDate + " " + this.traffEndTime, if (val && val.length)
targetStartDate: this.repairDate + " " + this.traffStartTime, {
targetEndDate: this.repairDate + " " + this.traffEndTime, this.query.accountVal = val
channelSerialnum: this.channelVal, }
minFactor: this.startRange, },
maxFactor: this.endRange, deep: true
scheduleType: "simulationcountData", },
mark: Date.parse(new Date()) mallVal: {
}; handler: function(val) {
let that = this if (val && val.length)
post(window._CONF_.apiUrl + API.PreviewCountData, JSON.stringify(params)).then(function(data) { {
if (data) { this.query.mallVal = val
that.renderResultToHtml(data, true) }
},
deep: true
},
dateFormat: function(val) {
var typeHandler = {
'revisitFeature': this.featureRevisitType,
'rebuildFeatureLib': this.featureLibRebuildType,
'rematchPerson': this.rematchPersonType
}
this.footerText = val === 'compare' ? '数据对比' : this.dateLevelList.find(item => item.label === val).name
this.socket && this.socket.close()
this.results.length && (this.results = [])
this.startTiming = this.endTiming = 0
this.query.type = typeof typeHandler[val] === 'undefined'
? null
: typeHandler[val]
},
featureRevisitType(val) {
this.query.type = val
},
featureLibRebuildType(val) {
this.query.type = val
},
rematchPersonType(val) {
this.query.type = val
} }
})
}, },
renderResultToHtml(data, hasSccessDetail) { created: function() {
let text = "本次共执行job " + this.locationHref =
data.total + location.href.indexOf("?super") != -1 ? true : false
" 个,成功 " + this.getAccount()
data.success +
" 个,失败 " +
data.failed +
" 个.</br>";
if (data.failedJob && data.failedJob.length > 0) {
text += "-----失败job详情-----</br>";
text += data.failedJob.join("</br>");
if (data.data) {
text += "</br>" + data.data;
}
}
if (data.successJob && data.successJob.length > 0) {
text += "-----成功job详情-----</br>";
text += data.successJob.join("</br>");
if (hasSccessDetail) {
if (data.data) {
console.log(data.data);
data.data.forEach(item => {
text +=
"</br>" +
" 设备序列号: " +
item.deviceSerialnum +
" 时间: " +
item.counttime +
" 进客流: " +
item.innum +
" 出客流: " +
item.outnum;
});
}
}
}
text += "</br>-----------------------------------------------";
text += "</br>";
text += "</br>";
text += "</br>";
$("#showDiv").append(text);
}, },
onSearchClick: function() { mounted: function() {
/////////////////////////////特征重提//////////////////////////////////////////////// this.query.dateVal = this.createDate()
// '/mall/feature' this.startTime = this.createDate()
// startDate,endDate,mallIds,scheduleType,featureType this.endTime = this.createDate()
// featureType==0 提取人体+人脸;featureType==1 提取人脸特征;featureType==2提取人体特征
/////////////////////////////特征库重建////////////////////////////////////////////////
// 重新建立顾客池 /mall/customPool
// 参数 mallIds,startDate,endDate,scheduleType
// 重建建立店员特征池 /mall/staffPool
// 参数 mallIds,scheduleType
/////////////////////////////人员重新对比////////////////////////////////////////////////
// 重新匹配顾客 /mall/custom
// 参数 mallIds,startDate,endDate,scheduleType
// 店员重新比对 /mall/staff
// 参数 mallIds,startDate,endDate,scheduleType
if (this.socket) {
this.socket.close()
this.socket = null
}
this.results = []
this.startTiming = 0
this.endTiming = 0
const TAB_API = {
revisitFeature: (val) => {
return val === 3 ? API.mallStaffFeature : API.MallFeature
},
rebuildFeatureLib: (val) => {
return val === 1 ? API.MallStaffPool : API.MallCustomPool
},
rematchPerson: (val) => {
return val === 1 ? API.MallStaff : API.MallCustom
}
}
const { dateFormat, query, isSendDateParam } = this
const {
dateVal, mallVal, type
} = query
var urlPath = TAB_API[dateFormat](type)
var scheduleType = dateFormat + type
var parameter = {
// startDate: dateVal ? dateVal + ' 00:00:00' : null,
// endDate: dateVal ? dateVal + ' 23:59:59' : null,
mallIds: mallVal || null,
scheduleType: scheduleType,
// featureType: dateFormat === 'revisitFeature' ? type : null
}
if (isSendDateParam) {
parameter.startDate = dateVal + ' 00:00:00'
parameter.endDate = dateVal + ' 23:59:59'
}
if (dateFormat === 'revisitFeature') {
parameter.featureType = type
}
var socketParameter = {
scheduleType: scheduleType,
// callback: 'fetchApi',
callbackUrlPath: urlPath,
callbackParam: parameter
}
this.onSocketConnect(socketParameter)
}, },
/** methods: {
* websocket 连接 createDate() {
* @param {string} scheduleType var nowDate = new Date()
* @param {string} wsUrl var day = nowDate.getDate()
* @param {string} callbackUrlPath var month = nowDate.getMonth() + 1
* @param {object} callbackParam var year = nowDate.getFullYear()
*/ if (month >= 1 && month <= 9)
onSocketConnect({ scheduleType, callbackUrlPath, callbackParam }) { {
var self = this, month = "0" + month
wsUrl = window._CONF_.webSockUrl || window.location.host, }
socketUrl = "ws://" + wsUrl + WSAPI.RecalSchedule + scheduleType if (day >= 0 && day <= 9)
if ("WebSocket" in window) { {
self.socket = new WebSocket(socketUrl); day = "0" + day
} else if ("MozWebSocket" in window) { }
self.socket = new MozWebSocket(socketUrl); return year + "-" + month + "-" + day
} else { },
self.socket = new SockJS(socketUrl); getProgressName(val) {
} return this.progressName[val]
try { },
self.socket.onopen = function(ev) { getProgressStyle(stepCount, status, oldStepCount) {
self.startTiming = +new Date() if (stepCount == "stepType")
self.fetchApi(callbackUrlPath, callbackParam) {
}; if (status == "gatecountData" || status == "gatefaceSta")
self.socket.onclosed = function() { {
console.log('socket:onclose') return {"margin-left": "448px", "font-size": "18px"}
}; }
else
{
return {"margin-left": "465px", "font-size": "18px"}
}
}
else
{
return {
width: (stepCount - oldStepCount) * 405 + "px",
"background-color": status ? "#409EFF" : "#f56c6c",
"margin-left": oldStepCount * 405 + 50 + "px"
}
}
},
lineOver(tag, dates, mallIds, mallNames) {
let evt = tag || window.event,
_top,
_left
_top = window.innerHeight - evt.y
_left = window.innerWidth - evt.x
this.tipStyle = {
top: evt.y - 50 + "px",
left: evt.x + "px"
}
this.lineDate = dates
this.lineMallId = mallIds.join(",")
this.lineMallName = mallNames
this.tipShow = true
},
lineOut() {
this.tipShow = false
},
handleCheckAllChangeTraffic(val) {
// console.log('val',val)
this.checkedTraffic = val ? trafficOptions : []
// console.log(this.checkedTraffic)
this.isIndeterminateTraffic = false
},
handleCheckAllChangeFace(val) {
// console.log('val',val)
this.checkedFace = val ? faceOptions : []
// console.log(this.checkedFace)
this.isIndeterminateFace = false
},
handleCheckedCitiesChangeTraffic(value) {
// console.log(this.checkedTraffic)
let checkedCount = value.length
this.checkAllTraffic = checkedCount === this.checkTraffic.length
this.isIndeterminateTraffic =
checkedCount > 0 && checkedCount < this.checkTraffic.length
},
handleCheckedCitiesChangeFace(value) {
// console.log(this.checkedFace)
let checkedCount = value.length
this.checkAllFace = checkedCount === this.checkFace.length
this.isIndeterminateFace =
checkedCount > 0 && checkedCount < this.checkFace.length
},
accountchange(linkGate) {
this.isAccoutSelAll = this.isAccoutSelAll
? this.accountVal.length < this.accoutOpts.length
? false
: true
: this.accountVal.length < this.accoutOpts.length
? false
: true
if (this.accountVal.length > 0)
{
this.getMall(linkGate)
}
},
mallchange(linkGate) {
this.isMallSelAll = this.isMallSelAll
? this.mallVal.length < this.mallOpts.length
? false
: true
: this.mallVal.length < this.mallOpts.length
? false
: true
if (linkGate)
{
this.getGate()
}
},
selAllHandle(level) {
if (level == "accout")
{
if (this.isAccoutSelAll)
{
this.accountVal = []
this.isAccoutSelAll = false
this.getMall()
}
else
{
this.accountVal = []
this.accoutOpts.forEach(item => {
this.accountVal.push(item.id)
})
this.isAccoutSelAll = true
this.getMall()
}
}
else
{
if (this.isMallSelAll)
{
this.mallVal = []
this.isMallSelAll = false
}
else
{
this.mallVal = []
this.mallOpts.forEach(item => {
this.mallVal.push(item.id)
})
this.isMallSelAll = true
}
}
},
getAccount: function() {
var _this = this
_this.accoutOpts = []
log(454, window._CONF_.apiUrl + API.Accounts)
get(window._CONF_.apiUrl + API.Accounts).then(function(data) {
_this.accoutOpts = data
if (_this.accoutOpts.length > 0)
{
_this.accountVal = [_this.accoutOpts[0].id]
}
_this.getMall()
}).catch(err => {
console.log('err', err)
})
},
getMall: function() {
var _this = this
_this.mallOpts = []
get(window._CONF_.apiUrl + API.Malls, {
accountIds: _this.accountVal.join(",")
}).then(function(data) {
_this.mallOpts = data
if (_this.mallOpts.length > 0)
{
_this.mallVal = [_this.mallOpts[0].id]
}
_this.isMallSelAll =
_this.mallVal.length == _this.mallOpts.length ? true : false
})
},
getGate: function() {
var _this = this
get(window._CONF_.apiUrl + API.Gates, {
accountIds: _this.accountVal.join(","),
mallIds: _this.mallVal.join(',')
}).then(function(data) {
_this.gateOpt = data
_this.gateVal = _this.gateOpt[0].id
// _this.getDevice()
_this.getChannel()
})
},
getDevice: function() {
var _this = this
get(window._CONF_.apiUrl + API.Devices, {
// accountIds: _this.accountVal.join(","),
// mallIds: _this.mallVal.join(','),
gateId: this.gateVal
}).then(function(data) {
_this.deviceOpt = []
_this.deviceVal = ""
for (var i = 0; i < data.length; i++)
{
var temp = {}
temp.name = data[i]
temp.value = data[i]
temp.id = i
_this.deviceOpt.push(temp)
}
_this.deviceVal = _this.deviceOpt[0].value
})
},
dateLevel: function() {
if (this.dateFormat == "repair")
{
this.getGate()
}
else
{
// this.getMall();
}
},
getLevel: function() {
},
getNumber() {
this.repairProgList = []
if (this.UrlType == "trafficRecognition")
{
// this.getChannel()
}
else
{
// this.getChannel()
// this.getDevice()
}
},
getChannel() {
var _this = this
get(window._CONF_.apiUrl + API.Channels, {
// accountIds: _this.accountVal.join(","),
// mallIds: _this.mallVal.join(','),
gateId: this.gateVal
}).then(function(data) {
_this.channelOpt = []
for (var i = 0; i < data.length; i++)
{
var temp = {}
temp.name = data[i]
temp.value = data[i]
temp.id = i
_this.channelOpt.push(temp)
}
_this.channelVal =
_this.channelOpt.length > 0 ? _this.channelOpt[0].value : ""
})
},
clearDiv() {
$("#showDiv").empty()
},
startData: function() {
this.progressList = []
if (this.webSocketObj)
{
for (var key in this.webSocketObj)
{
this.webSocketObj[key].close()
}
}
let params = {},
startDate = "",
endDate = ""
params = {
startDate: this.startTime + " 00:00:00",
endDate: this.endTime + " 00:00:00",
mallIds: this.mallVal,
scheduleType: "",
mark: Date.parse(new Date())
}
this.checkedTraffic.forEach((item, index) => {
let _scheduleType = ""
let websocket = item.split("/")
websocket.forEach(item1 => {
_scheduleType += item1
})
params.scheduleType = _scheduleType
this.openWebSock(_scheduleType, item, params)
})
this.checkedFace.forEach((item, index) => {
let _scheduleType = ""
let websocket = item.split("/")
websocket.forEach(item1 => {
_scheduleType += item1
})
params.scheduleType = _scheduleType
this.openWebSock(_scheduleType, item, params)
})
},
openWebSock(wsUrl, url, params, processKey = 'progressList') {
// browser 兼容
// var wsHost = window.location.host;
var socketUrl = ""
var webSock_Url = window._CONF_.webSockUrl || window.location.host
var obj = {
stepList: []
}
obj.stepType = wsUrl
obj.mark = params.mark
if (!webSockUrl)
{
webSock = window.location.host
}
socketUrl = "ws://" + webSock_Url + WSAPI.WSAPI + wsUrl
this[processKey].push(obj)
var _this = this
if ("WebSocket" in window)
{
_this.webSocketObj[wsUrl] = new WebSocket(socketUrl)
}
else if ("MozWebSocket" in window)
{
_this.webSocketObj[wsUrl] = new MozWebSocket(socketUrl)
}
else
{
_this.webSocketObj[wsUrl] = new SockJS(socketUrl)
}
var param = JSON.parse(JSON.stringify(params))
try
{
_this.webSocketObj[wsUrl].onopen = function(event) {
console.log("WebSocket:已连接")
_this.returnData(url, param)
}
_this.webSocketObj[wsUrl].onclosed = function() {
console.log("WebSocket关闭")
}
self.socket.onmessage = function(ev) { _this.webSocketObj[wsUrl].onmessage = function(evt) {
var msg = JSON.parse(ev.data) var msg = JSON.parse(evt.data)
console.log('[onmessage]:', msg) _this[processKey].forEach((item, index) => {
self.dealMessage(msg) if (
if (msg.stepCount === 1) { item.stepType == msg.scheduleType &&
self.endTiming = +new Date() item.mark == msg.mark
self.socket.close() )
} {
}; var stepObj = {}
self.socket.onerror = function(ev) { stepObj.dates = msg.dates
console.log("设备WebSocket:发生错误 "); stepObj.mallIds = msg.mallIds
console.log(ev); stepObj.mallNames = msg.mallNames
stepObj.status = msg.status
stepObj.stepCount = msg.stepCount
item.stepList.push(stepObj)
item.precentsucess = msg.stepCount
? Math.floor(msg.stepCount * 100)
: 0
}
})
// console.log('list',_this[processKey])
}
_this.webSocketObj[wsUrl].onerror = function(event) {
console.log("设备WebSocket:发生错误 ")
console.log(event)
}
}
catch (error)
{
}
},
returnData: function(urls, params) {
// console.log(urls,params)
var _this = this
post(window._CONF_.apiUrl + urls, JSON.stringify(params)).then(function(data) {
if (data)
{
_this.loading = ""
_this.showDiv = true
_this.renderResultToHtml(data)
}
}).catch(function(err) {
_this.loading = ""
alert("Sorry, The requested property could not be found.")
})
},
getDateCount: function() {
var _this = this
this.butShow = true
var params = {
startTime: this.sourceDate + " " + this.sourceStartTime,
endTime: this.sourceDate + " " + this.sourceEndTime,
channelSerialnum: this.channelVal
}
get(window._CONF_.apiUrl + API.FaceRecognitionsCount, params).then(function(data) {
_this.butShow = false
_this.dateCount = data
}).catch(function(err) {
_this.butShow = false
console.log(err)
})
// $.ajax({
// type: "get",
// dataType: "json",
// async: true,
// url: window._CONF_.apiUrl + urls,
// headers: {
// Authorization: Cookies.get('atoken')
// },
// data: params,
// success: function(data) {
// _this.butShow = false;
// _this.dateCount = data;
// },
// error: function(res) {
// _this.butShow = false;
// console.log(res);
// }
// });
},
repairParams: function(type) {
this.repairProgList = []
if (this.repairWebSocket)
{
this.repairWebSocket.close()
}
var url = "",
params = {}
if (type == "face")
{
this.startShow = true
setTimeout(() => {
this.startShow = false
}, 3000)
var url = API.SimulationFaceRecognition
var params = {
sourceStartDate: this.sourceDate + " " + this.sourceStartTime,
sourceEndDate: this.sourceDate + " " + this.sourceEndTime,
targetStartDate: this.aimsDate + " " + this.aimsStartTime,
targetEndDate: this.aimsDate + " " + this.aimsEndTime,
channelSerialnum: this.channelVal,
count: Number(this.count),
scheduleType: "simulationfaceRecognition",
mark: Date.parse(new Date())
}
}
else
{
this.tafficShow = true
setTimeout(() => {
this.tafficShow = false
}, 3000)
url = API.SimulationCountData
params = {
sourceStartDate: this.referenceDate + " " + this.traffStartTime,
sourceEndDate: this.referenceDate + " " + this.traffEndTime,
targetStartDate: this.repairDate + " " + this.traffStartTime,
targetEndDate: this.repairDate + " " + this.traffEndTime,
channelSerialnum: this.channelVal,
minFactor: this.startRange,
maxFactor: this.endRange,
scheduleType: "simulationcountData",
mark: Date.parse(new Date())
}
}
this.openFaceTraffWebSock(url, params)
},
compareParams: function(type) {
params = {
startDate: this.startTime + " 00:00:00",
endDate: this.endTime + " 00:00:00",
mallIds: this.mallVal,
scheduleType: "",
mark: Date.parse(new Date())
}
var url = API.Mall + this.compareType
this.returnData(url, params)
},
openFaceTraffWebSock(url, params) {
// browser 兼容
// var wsHost = window.location.host;
var socketUrl = ""
var webSock_Url = window._CONF_.webSockUrl || window.location.host
var obj = {
stepList: []
}
obj.stepType = params.scheduleType
obj.mark = params.mark
socketUrl =
"ws://" + webSock_Url + WSAPI.RecalSchedule + params.scheduleType
this.repairProgList.push(obj)
var _this = this
if ("WebSocket" in window)
{
_this.repairWebSocket = new WebSocket(socketUrl)
}
else if ("MozWebSocket" in window)
{
_this.repairWebSocket = new MozWebSocket(socketUrl)
}
else
{
_this.repairWebSocket = new SockJS(socketUrl)
}
var param = JSON.parse(JSON.stringify(params))
try
{
_this.repairWebSocket.onopen = function(event) {
console.log("WebSocket:已连接")
_this.repairData(url, params)
}
_this.repairWebSocket.onclosed = function() {
console.log("WebSocket关闭")
}
_this.repairWebSocket.onmessage = function(evt) {
var msg = JSON.parse(evt.data)
_this.repairProgList.forEach((item, index) => {
if (
item.stepType == msg.scheduleType &&
item.mark == msg.mark
)
{
var stepObj = {}
stepObj.counttime = msg.counttime
stepObj.serialnum = msg.serialnum
stepObj.status = msg.status
stepObj.stepCount = msg.stepCount
item.stepList.push(stepObj)
item.precentsucess = msg.stepCount
? Math.floor(msg.stepCount * 100)
: 0
}
})
}
_this.webSocketObj[wsUrl].onerror = function(event) {
console.log("设备WebSocket:发生错误 ")
console.log(event)
}
}
catch (error)
{
}
},
repairData(url, params) {
let that = this
post(window._CONF_.apiUrl + url, JSON.stringify(params)).then(function(data) {
if (data)
{
that.renderResultToHtml(data)
}
})
},
repairPreview: function() {
var params = {
sourceStartDate: this.referenceDate + " " + this.traffStartTime,
sourceEndDate: this.referenceDate + " " + this.traffEndTime,
targetStartDate: this.repairDate + " " + this.traffStartTime,
targetEndDate: this.repairDate + " " + this.traffEndTime,
channelSerialnum: this.channelVal,
minFactor: this.startRange,
maxFactor: this.endRange,
scheduleType: "simulationcountData",
mark: Date.parse(new Date())
}
let that = this
post(window._CONF_.apiUrl + API.PreviewCountData, JSON.stringify(params)).then(function(data) {
if (data)
{
that.renderResultToHtml(data, true)
}
})
},
renderResultToHtml(data, hasSccessDetail) {
let text = "本次共执行job " +
data.total +
" 个,成功 " +
data.success +
" 个,失败 " +
data.failed +
" 个.</br>"
if (data.failedJob && data.failedJob.length > 0)
{
text += "-----失败job详情-----</br>"
text += data.failedJob.join("</br>")
if (data.data)
{
text += "</br>" + data.data
}
}
if (data.successJob && data.successJob.length > 0)
{
text += "-----成功job详情-----</br>"
text += data.successJob.join("</br>")
if (hasSccessDetail)
{
if (data.data)
{
console.log(data.data)
data.data.forEach(item => {
text +=
"</br>" +
" 设备序列号: " +
item.deviceSerialnum +
" 时间: " +
item.counttime +
" 进客流: " +
item.innum +
" 出客流: " +
item.outnum
})
}
}
}
text += "</br>-----------------------------------------------"
text += "</br>"
text += "</br>"
text += "</br>"
$("#showDiv").append(text)
},
onSearchClick: function() {
/////////////////////////////特征重提////////////////////////////////////////////////
// '/mall/feature'
// startDate,endDate,mallIds,scheduleType,featureType
// featureType==0 提取人体+人脸;featureType==1 提取人脸特征;featureType==2提取人体特征
/////////////////////////////特征库重建////////////////////////////////////////////////
// 重新建立顾客池 /mall/customPool
// 参数 mallIds,startDate,endDate,scheduleType
// 重建建立店员特征池 /mall/staffPool
// 参数 mallIds,scheduleType
/////////////////////////////人员重新对比////////////////////////////////////////////////
// 重新匹配顾客 /mall/custom
// 参数 mallIds,startDate,endDate,scheduleType
// 店员重新比对 /mall/staff
// 参数 mallIds,startDate,endDate,scheduleType
if (this.socket)
{
this.socket.close()
this.socket = null
}
this.results = []
this.startTiming = 0
this.endTiming = 0
const TAB_API = {
revisitFeature: (val) => {
return val === 3 ? API.mallStaffFeature : API.MallFeature
},
rebuildFeatureLib: (val) => {
return val === 1 ? API.MallStaffPool : API.MallCustomPool
},
rematchPerson: (val) => {
return val === 1 ? API.MallStaff : API.MallCustom
}
}
const {dateFormat, query, isSendDateParam} = this
const {
dateVal, mallVal, type
} = query
var urlPath = TAB_API[dateFormat](type)
var scheduleType = dateFormat + type
var parameter = {
// startDate: dateVal ? dateVal + ' 00:00:00' : null,
// endDate: dateVal ? dateVal + ' 23:59:59' : null,
mallIds: mallVal || null,
scheduleType: scheduleType,
// featureType: dateFormat === 'revisitFeature' ? type : null
}
if (isSendDateParam)
{
parameter.startDate = dateVal + ' 00:00:00'
parameter.endDate = dateVal + ' 23:59:59'
}
if (dateFormat === 'revisitFeature')
{
parameter.featureType = type
}
var socketParameter = {
scheduleType: scheduleType,
// callback: 'fetchApi',
callbackUrlPath: urlPath,
callbackParam: parameter
}
this.onSocketConnect(socketParameter)
},
/**
* websocket 连接
* @param {string} scheduleType
* @param {string} wsUrl
* @param {string} callbackUrlPath
* @param {object} callbackParam
*/
onSocketConnect({scheduleType, callbackUrlPath, callbackParam}) {
var self = this,
wsUrl = window._CONF_.webSockUrl || window.location.host,
socketUrl = "ws://" + wsUrl + WSAPI.RecalSchedule + scheduleType
if ("WebSocket" in window)
{
self.socket = new WebSocket(socketUrl)
}
else if ("MozWebSocket" in window)
{
self.socket = new MozWebSocket(socketUrl)
}
else
{
self.socket = new SockJS(socketUrl)
}
try
{
self.socket.onopen = function(ev) {
self.startTiming = +new Date()
self.fetchApi(callbackUrlPath, callbackParam)
}
self.socket.onclosed = function() {
console.log('socket:onclose')
}
self.socket.onmessage = function(ev) {
var msg = JSON.parse(ev.data)
console.log('[onmessage]:', msg)
self.dealMessage(msg)
if (msg.stepCount === 1)
{
self.endTiming = +new Date()
self.socket.close()
}
}
self.socket.onerror = function(ev) {
console.log("设备WebSocket:发生错误 ")
console.log(ev)
}
}
catch (error)
{
console.log('onSocketConnect:', error)
}
},
fetchApi(urlPath, parameter) {
const {
dateVal, mallVal, type
} = this.query
var self = this
post(window._CONF_.apiUrl + urlPath, JSON.stringify(parameter)).then(function(res) {
console.log(res)
})
},
dealMessage(msg) {
// scheduleType
const {dates, mallIds, mallNames, status, stepCount, scheduleType, counter} = msg
var self = this
var resObj = {}
resObj.dates = dates
resObj.mallIds = mallIds
resObj.mallNames = mallNames
resObj.status = status
resObj.progress = self.floatToPercent(stepCount)
resObj.totalNum = 0
resObj.totalPage = 0
resObj.current = 0
resObj.curPageSize = 0
resObj.currentPage = 0
resObj.scheduleType = scheduleType
if (counter)
{
// dataNum dateMallNum step totalData totalDate totalMall totalMallDateProduct allDataCount
resObj.totalNum = counter.allDataCount
resObj.totalPage = counter.totalMallDateProduct
resObj.current = counter.dataNum
resObj.curPageSize = counter.totalData
resObj.currentPage = counter.dateMallNum
}
if (self.results.length)
{
const isSameScheduleType = self.results.some(item => item.scheduleType === scheduleType)
isSameScheduleType
? self.results.forEach(item => {
//
item.progress = self.floatToPercent(stepCount)
if (counter)
{
item.totalNum = counter.allDataCount
item.totalPage = counter.totalMallDateProduct
item.current = counter.dataNum
item.curPageSize = counter.totalData
item.currentPage = counter.dateMallNum
}
})
: self.results.push(resObj)
resObj = {}
}
else
{
self.results.push(resObj)
resObj = {}
}
// 滚动至底部
// this.$nextTick(() => {
// this.$refs.scrollbarRef.wrap.scrollTop = this.$refs.scrollbarRef.wrap.scrollHeight
// })
},
formatDateToStamp(date) {
if (!date)
{
return false
}
typeof date === 'string' && (date = new Date(date.replace(/-/g, '/')))
return date.getTime()
},
floatToPercent(floatNum) {
if (!floatNum)
{
return 0
}
var formatNum = Math.floor(floatNum * 100)
return formatNum >= 100 ? 100 : formatNum
},
onClearClick() {
if (this.dateFormat === 'revisitFeature' ||
this.dateFormat === 'rebuildFeatureLib' ||
this.dateFormat === 'rematchPerson')
{
this.startTiming = 0
this.endTiming = 0
this.results = []
}
// else {
document.getElementById('showDiv').innerHTML = ''
// }
} }
} catch (error) {
console.log('onSocketConnect:', error)
}
},
fetchApi(urlPath, parameter) {
const {
dateVal, mallVal, type
} = this.query
var self = this
post(window._CONF_.apiUrl + urlPath, JSON.stringify(parameter)).then(function(res) {
console.log(res)
})
},
dealMessage(msg) {
// scheduleType
const { dates, mallIds, mallNames, status, stepCount, scheduleType, counter } = msg
var self = this
var resObj = {}
resObj.dates = dates
resObj.mallIds = mallIds
resObj.mallNames = mallNames
resObj.status = status
resObj.progress = self.floatToPercent(stepCount)
resObj.totalNum = 0
resObj.totalPage = 0
resObj.current = 0
resObj.curPageSize = 0
resObj.currentPage = 0
resObj.scheduleType = scheduleType
if (counter) {
// dataNum dateMallNum step totalData totalDate totalMall totalMallDateProduct allDataCount
resObj.totalNum = counter.allDataCount
resObj.totalPage = counter.totalMallDateProduct
resObj.current = counter.dataNum
resObj.curPageSize = counter.totalData
resObj.currentPage = counter.dateMallNum
}
if (self.results.length) {
const isSameScheduleType = self.results.some(item => item.scheduleType === scheduleType)
isSameScheduleType
? self.results.forEach(item => {
//
item.progress = self.floatToPercent(stepCount)
if (counter) {
item.totalNum = counter.allDataCount
item.totalPage = counter.totalMallDateProduct
item.current = counter.dataNum
item.curPageSize = counter.totalData
item.currentPage = counter.dateMallNum
}
})
: self.results.push(resObj)
resObj = {}
} else {
self.results.push(resObj)
resObj = {}
}
// 滚动至底部
// this.$nextTick(() => {
// this.$refs.scrollbarRef.wrap.scrollTop = this.$refs.scrollbarRef.wrap.scrollHeight
// })
},
formatDateToStamp(date) {
if (!date) return false
typeof date === 'string' && (date = new Date(date.replace(/-/g, '/')))
return date.getTime()
},
floatToPercent(floatNum) {
if (!floatNum) return 0
var formatNum = Math.floor(floatNum * 100)
return formatNum >= 100 ? 100 : formatNum
},
onClearClick() {
if (this.dateFormat === 'revisitFeature' ||
this.dateFormat === 'rebuildFeatureLib' ||
this.dateFormat === 'rematchPerson') {
this.startTiming = 0
this.endTiming = 0
this.results = []
}
// else {
document.getElementById('showDiv').innerHTML = ''
// }
} }
} })
});
static/js/request.js
const Axios = axios.create({ const Axios = axios.create({
baseURL: window._CONF_.apiUrl, baseURL: window._CONF_.apiUrl,
timeout: 0, timeout: 0,
withCredentials: true, withCredentials: true,
headers: { headers: {
"Content-Type": "application/json;charset=UTF-8" "Content-Type": "application/json;charset=UTF-8"
} }
}) })
Axios.interceptors.request.use( Axios.interceptors.request.use(
config => { config => {
// const atoken = Cookies.get('atoken') // const atoken = Cookies.get('atoken')
// console.log('atoken', atoken) // console.log('atoken', atoken)
// atoken && (config.headers.Authorization = atoken) // atoken && (config.headers.Authorization = atoken)
return config return config
}, },
error => { error => {
return Promise.reject(error) return Promise.reject(error)
} }
) )
Axios.interceptors.response.use( Axios.interceptors.response.use(
res => { res => {
// if (res.data.enote || res.data.code === 401) { // if (res.data.enote || res.data.code === 401) {
// ELEMENT.MessageBox.alert('授权到期, 请重新登录', '提示', { // ELEMENT.MessageBox.alert('授权到期, 请重新登录', '提示', {
// confirmButtonText: '确定', // confirmButtonText: '确定',
// callback: action => { // callback: action => {
// console.log('action', action) // console.log('action', action)
// window.location.replace(window.location.href + 'login.html') // window.location.replace(window.location.href + 'login.html')
// } // }
// }); // });
// } else { // } else {
return Promise.resolve(res.data) return Promise.resolve(res.data)
// } // }
}, },
error => { error => {
console.error(error) console.error(error)
return Promise.reject(error) return Promise.reject(error)
} }
) )
function get(url, params = {}, config = {}) { function get(url, params = {}, config = {}) {
params['s'] = +new Date() params['s'] = +new Date()
return Axios.get(url, { ...config, params }) return Axios.get(url, {...config, params})
} }
function post(url, params, config = {}) { function post(url, params, config = {}) {
return Axios.post(url, params, config) return Axios.post(url, params, config)
} }
function deletes(url, params, config = {}) { function deletes(url, params, config = {}) {
return Axios.delete(url, params, config) return Axios.delete(url, params, config)
} }
function put(url, params, config = {}) { function put(url, params, config = {}) {
return Axios.put(url, params, config) return Axios.put(url, params, config)
} }
Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!