Skip to content

R
refined-platform
Commit 9e280787 authored by 赵啸非's avatar 赵啸非
Browse files
Options

添加消息发送

parent b8f5d925
Hide whitespace changes
Inline Side-by-side
Showing with 193 additions and 195 deletions
refined-manager/src/main/java/com/mortals/xhx/daemon/task/SyncAppointWaitAndFinTaskImpl.java
View file @ 9e280787
...@@ -103,9 +103,9 @@ public class SyncAppointWaitAndFinTaskImpl implements ITaskExcuteService { ...@@ -103,9 +103,9 @@ public class SyncAppointWaitAndFinTaskImpl implements ITaskExcuteService {
log.info("同步今天等待用户任务"); log.info("同步今天等待用户任务");
syncWaitAndFinQueue(); syncWaitAndFinQueue();
log.info("关怀用户任务"); log.info("关怀用户任务");
// updateWaitQueueTime(); // updateWaitQueueTime();
log.info("关怀服务完成任务"); log.info("关怀服务完成任务");
// clearWaitQueueTime(); // clearWaitQueueTime();
//todo 办理完成同步 //todo 办理完成同步
log.info("同步办理完成业务"); log.info("同步办理完成业务");
...@@ -117,216 +117,215 @@ public class SyncAppointWaitAndFinTaskImpl implements ITaskExcuteService { ...@@ -117,216 +117,215 @@ public class SyncAppointWaitAndFinTaskImpl implements ITaskExcuteService {
private void syncWaitAndFinQueue() { private void syncWaitAndFinQueue() {
RedisTemplate<String, String> redisTemplate = cacheService.selectDbRedisTemplate(redisDb); RedisTemplate<String, String> redisTemplate = cacheService.selectDbRedisTemplate(redisDb);
// cacheService.select(redisDb);// // cacheService.select(redisDb);//
Thread thread = new Thread(() -> {
List<WaitPersonInfo> waitPersonInfos = new ArrayList<>(); List<WaitPersonInfo> waitPersonInfos = new ArrayList<>();
List<FinPersonInfo> finPersonInfos = new ArrayList<>(); List<FinPersonInfo> finPersonInfos = new ArrayList<>();
List<EndPersonInfo> endPersonInfos = new ArrayList<>(); List<EndPersonInfo> endPersonInfos = new ArrayList<>();
while (true) { while (true) {
String value = redisTemplate.opsForList().leftPop(RedisKey.KEY_WAITNUM_LIST_CACHE, 5, TimeUnit.SECONDS); String value = redisTemplate.opsForList().leftPop(RedisKey.KEY_WAITNUM_LIST_CACHE, 5, TimeUnit.SECONDS);
WaitPersonInfo waitPersonInfo = JSON.parseObject(value, WaitPersonInfo.class); WaitPersonInfo waitPersonInfo = JSON.parseObject(value, WaitPersonInfo.class);
// WaitPersonInfo waitPersonInfo = cacheService.blpop(RedisKey.KEY_WAITNUM_LIST_CACHE,10, WaitPersonInfo.class); // WaitPersonInfo waitPersonInfo = cacheService.blpop(RedisKey.KEY_WAITNUM_LIST_CACHE,10, WaitPersonInfo.class);
if (ObjectUtils.isEmpty(waitPersonInfo)) { if (ObjectUtils.isEmpty(waitPersonInfo)) {
break; break;
} else { } else {
waitPersonInfos.add(waitPersonInfo); waitPersonInfos.add(waitPersonInfo);
}
} }
}
while (true) { while (true) {
String value = redisTemplate.opsForList().leftPop(RedisKey.KEY_FIN_LIST_CACHE, 5, TimeUnit.SECONDS); String value = redisTemplate.opsForList().leftPop(RedisKey.KEY_FIN_LIST_CACHE, 5, TimeUnit.SECONDS);
FinPersonInfo finPersonInfo = JSON.parseObject(value, FinPersonInfo.class); FinPersonInfo finPersonInfo = JSON.parseObject(value, FinPersonInfo.class);
// FinPersonInfo finPersonInfo = cacheService.blpop(RedisKey.KEY_FIN_LIST_CACHE,10, FinPersonInfo.class); // FinPersonInfo finPersonInfo = cacheService.blpop(RedisKey.KEY_FIN_LIST_CACHE,10, FinPersonInfo.class);
if (ObjectUtils.isEmpty(finPersonInfo)) { if (ObjectUtils.isEmpty(finPersonInfo)) {
break; break;
} else { } else {
finPersonInfos.add(finPersonInfo); finPersonInfos.add(finPersonInfo);
}
} }
}
while (true) { while (true) {
String value = redisTemplate.opsForList().leftPop(RedisKey.KEY_FIN_DOWORK_LIST_CACHE, 5, TimeUnit.SECONDS); String value = redisTemplate.opsForList().leftPop(RedisKey.KEY_FIN_DOWORK_LIST_CACHE, 5, TimeUnit.SECONDS);
EndPersonInfo endPersonInfo = JSON.parseObject(value, EndPersonInfo.class); EndPersonInfo endPersonInfo = JSON.parseObject(value, EndPersonInfo.class);
// FinPersonInfo finPersonInfo = cacheService.blpop(RedisKey.KEY_FIN_LIST_CACHE,10, FinPersonInfo.class); // FinPersonInfo finPersonInfo = cacheService.blpop(RedisKey.KEY_FIN_LIST_CACHE,10, FinPersonInfo.class);
if (ObjectUtils.isEmpty(endPersonInfo)) { if (ObjectUtils.isEmpty(endPersonInfo)) {
break; break;
} else { } else {
endPersonInfos.add(endPersonInfo); endPersonInfos.add(endPersonInfo);
}
} }
}
List<CpPersonInfo> cpPersonInfos = new ArrayList<>(); List<CpPersonInfo> cpPersonInfos = new ArrayList<>();
while (true) { while (true) {
String value = redisTemplate.opsForList().leftPop(RedisKey.KEY_CP_LIST_CACHE, 5, TimeUnit.SECONDS); String value = redisTemplate.opsForList().leftPop(RedisKey.KEY_CP_LIST_CACHE, 5, TimeUnit.SECONDS);
log.info("cp:{}", value); log.info("cp:{}", value);
CpPersonInfo cpPersonInfo = JSON.parseObject(value, CpPersonInfo.class); CpPersonInfo cpPersonInfo = JSON.parseObject(value, CpPersonInfo.class);
log.info("cp obj:{}", JSON.toJSONString(cpPersonInfo)); log.info("cp obj:{}", JSON.toJSONString(cpPersonInfo));
if (ObjectUtils.isEmpty(cpPersonInfo)) { if (ObjectUtils.isEmpty(cpPersonInfo)) {
break; break;
} else { } else {
cpPersonInfos.add(cpPersonInfo); cpPersonInfos.add(cpPersonInfo);
}
} }
}
if (!ObjectUtils.isEmpty(waitPersonInfos)) { if (!ObjectUtils.isEmpty(waitPersonInfos)) {
// log.info("waitPersonInfos:{}", JSON.toJSONString(waitPersonInfos)); // log.info("waitPersonInfos:{}", JSON.toJSONString(waitPersonInfos));
List<CareRecordsEntity> recordsEntityList = waitPersonInfos.stream().map(item -> { List<CareRecordsEntity> recordsEntityList = waitPersonInfos.stream().map(item -> {
CareRecordsEntity careRecordsEntity = new CareRecordsEntity(); CareRecordsEntity careRecordsEntity = new CareRecordsEntity();
careRecordsEntity.initAttrValue(); careRecordsEntity.initAttrValue();
careRecordsEntity.setName(item.getIdcardName()); careRecordsEntity.setName(item.getIdcardName());
careRecordsEntity.setContact(item.getPhone()); careRecordsEntity.setContact(item.getPhone());
careRecordsEntity.setIdCard(item.getIdcardIDCardNo()); careRecordsEntity.setIdCard(item.getIdcardIDCardNo());
careRecordsEntity.setBussinessId(item.getBusinessId()); careRecordsEntity.setBussinessId(item.getBusinessId());
careRecordsEntity.setBussinessName(item.getBusinessName()); careRecordsEntity.setBussinessName(item.getBusinessName());
careRecordsEntity.setService(item.getBusinessName()); careRecordsEntity.setService(item.getBusinessName());
careRecordsEntity.setQueueNo(item.getFlowNum()); careRecordsEntity.setQueueNo(item.getFlowNum());
careRecordsEntity.setMonitorTime(new Date()); careRecordsEntity.setMonitorTime(new Date());
careRecordsEntity.setTakeTime(item.getTakeTime() == null ? new Date() : item.getTakeTime()); careRecordsEntity.setTakeTime(item.getTakeTime() == null ? new Date() : item.getTakeTime());
careRecordsEntity.setPersonId(DataUtil.converStr2Long(item.getPeopleId(), 0)); careRecordsEntity.setPersonId(DataUtil.converStr2Long(item.getPeopleId(), 0));
careRecordsEntity.setWaitId(item.getWaitId()); careRecordsEntity.setWaitId(item.getWaitId());
careRecordsEntity.setProcessStatus(ProcessStatusEnum.排队中.getValue()); careRecordsEntity.setProcessStatus(ProcessStatusEnum.排队中.getValue());
careRecordsEntity.setCreateTime(new Date()); careRecordsEntity.setCreateTime(new Date());
careRecordsEntity.setCreateUserName("system"); careRecordsEntity.setCreateUserName("system");
careRecordsEntity.setCreateUserId(1L); careRecordsEntity.setCreateUserId(1L);
return careRecordsEntity; return careRecordsEntity;
}).collect(Collectors.toList()); }).collect(Collectors.toList());
if (!ObjectUtils.isEmpty(recordsEntityList)) {
log.info("保存关怀记录数量，size:{}", recordsEntityList.size());
careRecordsService.save(recordsEntityList);
}
}
if (!ObjectUtils.isEmpty(finPersonInfos)) { if (!ObjectUtils.isEmpty(recordsEntityList)) {
log.info("finPersonInfos:{}", JSON.toJSONString(finPersonInfos)); log.info("保存关怀记录数量，size:{}", recordsEntityList.size());
List<Long> waitIdList = finPersonInfos.stream().map(item -> item.getWaitId()).collect(Collectors.toList()); careRecordsService.save(recordsEntityList);
Map<Long, FinPersonInfo> waitMap = finPersonInfos.stream().collect(Collectors.toMap(x -> x.getWaitId(), y -> y, (o, n) -> n)); }
}
CareRecordsQuery careRecordsQuery = new CareRecordsQuery(); if (!ObjectUtils.isEmpty(finPersonInfos)) {
careRecordsQuery.setWaitIdList(waitIdList); log.info("finPersonInfos:{}", JSON.toJSONString(finPersonInfos));
List<CareRecordsEntity> careRecordsEntities = careRecordsService.find(careRecordsQuery); List<Long> waitIdList = finPersonInfos.stream().map(item -> item.getWaitId()).collect(Collectors.toList());
if (!ObjectUtils.isEmpty(careRecordsEntities)) { Map<Long, FinPersonInfo> waitMap = finPersonInfos.stream().collect(Collectors.toMap(x -> x.getWaitId(), y -> y, (o, n) -> n));
careRecordsEntities.forEach(item -> {
FinPersonInfo finPersonInfo = waitMap.get(item.getWaitId()); CareRecordsQuery careRecordsQuery = new CareRecordsQuery();
item.setProcessStatus(ProcessStatusEnum.接件结束.getValue()); careRecordsQuery.setWaitIdList(waitIdList);
item.setCallTime(finPersonInfo.getCalltime()); List<CareRecordsEntity> careRecordsEntities = careRecordsService.find(careRecordsQuery);
Long diff = DateUtil.between(item.getTakeTime(), finPersonInfo.getCalltime(), DateUnit.SECOND); if (!ObjectUtils.isEmpty(careRecordsEntities)) {
if (!ObjectUtils.isEmpty(finPersonInfo.getAvgWaitTime())) { careRecordsEntities.forEach(item -> {
int avgWait = finPersonInfo.getAvgWaitTime(); FinPersonInfo finPersonInfo = waitMap.get(item.getWaitId());
if (avgWait > 0 item.setProcessStatus(ProcessStatusEnum.接件结束.getValue());
&& diff > avgWait) { item.setCallTime(finPersonInfo.getCalltime());
//todo 构造发送消息。 Long diff = DateUtil.between(item.getTakeTime(), finPersonInfo.getCalltime(), DateUnit.SECOND);
AlarmRecordsEntity recordsEntity = new AlarmRecordsEntity(); if (!ObjectUtils.isEmpty(finPersonInfo.getAvgWaitTime())) {
recordsEntity.initAttrValue(); int avgWait = finPersonInfo.getAvgWaitTime();
double doTime = NumberUtil.div(Double.parseDouble((diff) + ""), 60, 1); // 保留1位小数，四舍五入 if (avgWait > 0
double upTime = NumberUtil.div(Double.parseDouble((diff - avgWait) + ""), 60, 1); // 保留1位小数，四舍五入 && diff > avgWait) {
//todo 构造发送消息。
String alarmContent = String.format("排队编号:%s:,%s业务叫号等待时间为%d分钟，超过了平均等待时长%d分钟!", AlarmRecordsEntity recordsEntity = new AlarmRecordsEntity();
item.getQueueNo(), item.getBussinessName(), doTime, upTime); recordsEntity.initAttrValue();
recordsEntity.setAlarmContent(alarmContent); double doTime = NumberUtil.div(Double.parseDouble((diff) + ""), 60, 1); // 保留1位小数，四舍五入
recordsEntity.setAlarmTime(new Date()); double upTime = NumberUtil.div(Double.parseDouble((diff - avgWait) + ""), 60, 1); // 保留1位小数，四舍五入
recordsEntity.setCreateTime(new Date());
recordsEntity.setCreateUserId(1L); String alarmContent = String.format("排队编号:%s:,%s业务叫号等待时间为%d分钟，超过了平均等待时长%d分钟!",
alarmRecordsService.save(recordsEntity); item.getQueueNo(), item.getBussinessName(), doTime, upTime);
} recordsEntity.setAlarmContent(alarmContent);
recordsEntity.setAlarmTime(new Date());
recordsEntity.setCreateTime(new Date());
recordsEntity.setCreateUserId(1L);
alarmRecordsService.save(recordsEntity);
} }
//判断是否大于平均等待时间，如果大于 则预警消息
item.setWaitTime(diff.intValue());
item.setUpdateTime(new Date());
item.setUpdateUserId(1L);
item.setUpdateUserName("system");
});
if (!ObjectUtils.isEmpty(careRecordsEntities)) {
log.info("更新关怀记录数量，size:{}", careRecordsEntities.size());
careRecordsService.update(careRecordsEntities);
} }
//判断是否大于平均等待时间，如果大于 则预警消息
item.setWaitTime(diff.intValue());
item.setUpdateTime(new Date());
item.setUpdateUserId(1L);
item.setUpdateUserName("system");
});
if (!ObjectUtils.isEmpty(careRecordsEntities)) {
log.info("更新关怀记录数量，size:{}", careRecordsEntities.size());
careRecordsService.update(careRecordsEntities);
} }
} }
}
if (!ObjectUtils.isEmpty(endPersonInfos)) { if (!ObjectUtils.isEmpty(endPersonInfos)) {
log.info("endPersonInfos:{}", JSON.toJSONString(endPersonInfos)); log.info("endPersonInfos:{}", JSON.toJSONString(endPersonInfos));
List<Long> endIdList = endPersonInfos.stream().map(item -> item.getEndId()).collect(Collectors.toList()); List<Long> endIdList = endPersonInfos.stream().map(item -> item.getEndId()).collect(Collectors.toList());
Map<Long, EndPersonInfo> endMap = endPersonInfos.stream().collect(Collectors.toMap(x -> x.getEndId(), y -> y, (o, n) -> n)); Map<Long, EndPersonInfo> endMap = endPersonInfos.stream().collect(Collectors.toMap(x -> x.getEndId(), y -> y, (o, n) -> n));
CareRecordsQuery careRecordsQuery = new CareRecordsQuery(); CareRecordsQuery careRecordsQuery = new CareRecordsQuery();
careRecordsQuery.setWaitIdList(endIdList); careRecordsQuery.setWaitIdList(endIdList);
List<CareRecordsEntity> careRecordsEntities = careRecordsService.find(careRecordsQuery); List<CareRecordsEntity> careRecordsEntities = careRecordsService.find(careRecordsQuery);
if (!ObjectUtils.isEmpty(careRecordsEntities)) { if (!ObjectUtils.isEmpty(careRecordsEntities)) {
careRecordsEntities.forEach(item -> { careRecordsEntities.forEach(item -> {
EndPersonInfo endPersonInfo = endMap.get(item.getWaitId()); EndPersonInfo endPersonInfo = endMap.get(item.getWaitId());
item.setProcessStatus(ProcessStatusEnum.办理结束.getValue()); item.setProcessStatus(ProcessStatusEnum.办理结束.getValue());
item.setEndTime(endPersonInfo.getEndtime()); item.setEndTime(endPersonInfo.getEndtime());
Long diff = DateUtil.between(item.getCallTime(), endPersonInfo.getEndtime(), DateUnit.MINUTE); Long diff = DateUtil.between(item.getCallTime(), endPersonInfo.getEndtime(), DateUnit.MINUTE);
if (!ObjectUtils.isEmpty(endPersonInfo.getAvgHandleTime())) { if (!ObjectUtils.isEmpty(endPersonInfo.getAvgHandleTime())) {
int avgWait = endPersonInfo.getAvgHandleTime(); int avgWait = endPersonInfo.getAvgHandleTime();
if (avgWait > 0 if (avgWait > 0
&& diff > avgWait) { && diff > avgWait) {
//todo 构造发送消息。 //todo 构造发送消息。
AlarmRecordsEntity recordsEntity = new AlarmRecordsEntity(); AlarmRecordsEntity recordsEntity = new AlarmRecordsEntity();
recordsEntity.initAttrValue(); recordsEntity.initAttrValue();
double doTime = NumberUtil.div(Double.parseDouble((diff) + ""), 60, 1); // 保留1位小数，四舍五入 double doTime = NumberUtil.div(Double.parseDouble((diff) + ""), 60, 1); // 保留1位小数，四舍五入
double upTime = NumberUtil.div(Double.parseDouble((diff - avgWait) + ""), 60, 1); // 保留1位小数，四舍五入 double upTime = NumberUtil.div(Double.parseDouble((diff - avgWait) + ""), 60, 1); // 保留1位小数，四舍五入
String alarmContent = String.format("编号:%s:,%s业务办理时间为%d分钟，超过了平均办理时长%d分钟!", item.getBussinessName(), doTime, upTime); String alarmContent = String.format("编号:%s:,%s业务办理时间为%d分钟，超过了平均办理时长%d分钟!", item.getBussinessName(), doTime, upTime);
recordsEntity.setAlarmContent(alarmContent); recordsEntity.setAlarmContent(alarmContent);
recordsEntity.setAlarmTime(new Date()); recordsEntity.setAlarmTime(new Date());
recordsEntity.setCreateTime(new Date()); recordsEntity.setCreateTime(new Date());
recordsEntity.setCreateUserId(1L); recordsEntity.setCreateUserId(1L);
alarmRecordsService.save(recordsEntity); alarmRecordsService.save(recordsEntity);
}
} }
item.setEndDureTime(diff.intValue());
item.setUpdateTime(new Date());
item.setUpdateUserId(1L);
item.setUpdateUserName("system");
});
if (!ObjectUtils.isEmpty(careRecordsEntities)) {
log.info("更新办理结束记录数量，size:{}", careRecordsEntities.size());
careRecordsService.update(careRecordsEntities);
} }
item.setEndDureTime(diff.intValue());
item.setUpdateTime(new Date());
item.setUpdateUserId(1L);
item.setUpdateUserName("system");
});
if (!ObjectUtils.isEmpty(careRecordsEntities)) {
log.info("更新办理结束记录数量，size:{}", careRecordsEntities.size());
careRecordsService.update(careRecordsEntities);
} }
} }
}
if (!ObjectUtils.isEmpty(cpPersonInfos)) { if (!ObjectUtils.isEmpty(cpPersonInfos)) {
log.info("cpPersonInfos:{}", JSON.toJSONString(cpPersonInfos)); log.info("cpPersonInfos:{}", JSON.toJSONString(cpPersonInfos));
for (CpPersonInfo cpPersonInfo : cpPersonInfos) { for (CpPersonInfo cpPersonInfo : cpPersonInfos) {
CareCpRecordsEntity careCpRecordsEntity = new CareCpRecordsEntity(); CareCpRecordsEntity careCpRecordsEntity = new CareCpRecordsEntity();
careCpRecordsEntity.initAttrValue(); careCpRecordsEntity.initAttrValue();
careCpRecordsEntity.setSiteId(cpPersonInfo.getSiteId()); careCpRecordsEntity.setSiteId(cpPersonInfo.getSiteId());
careCpRecordsEntity.setPersonId(cpPersonInfo.getPeopleId()); careCpRecordsEntity.setPersonId(cpPersonInfo.getPeopleId());
careCpRecordsEntity.setPjId(cpPersonInfo.getPjId()); careCpRecordsEntity.setPjId(cpPersonInfo.getPjId());
careCpRecordsEntity.setWindowName(cpPersonInfo.getWindowName()); careCpRecordsEntity.setWindowName(cpPersonInfo.getWindowName());
careCpRecordsEntity.setSection(cpPersonInfo.getSection()); careCpRecordsEntity.setSection(cpPersonInfo.getSection());
careCpRecordsEntity.setFlounum(cpPersonInfo.getFlounum()); careCpRecordsEntity.setFlounum(cpPersonInfo.getFlounum());
careCpRecordsEntity.setAssessment(cpPersonInfo.getOptionId()); careCpRecordsEntity.setAssessment(cpPersonInfo.getOptionId());
careCpRecordsEntity.setType(cpPersonInfo.getType()); careCpRecordsEntity.setType(cpPersonInfo.getType());
careCpRecordsEntity.setContent(cpPersonInfo.getContent()); careCpRecordsEntity.setContent(cpPersonInfo.getContent());
careCpRecordsEntity.setSource(cpPersonInfo.getSource()); careCpRecordsEntity.setSource(cpPersonInfo.getSource());
careCpRecordsEntity.setPjTime(cpPersonInfo.getCpTime()); careCpRecordsEntity.setPjTime(cpPersonInfo.getCpTime());
careCpRecordsEntity.setName(cpPersonInfo.getWorkmanName()); careCpRecordsEntity.setName(cpPersonInfo.getWorkmanName());
careCpRecordsEntity.setCreateTime(new Date()); careCpRecordsEntity.setCreateTime(new Date());
careCpRecordsEntity.setCreateUserId(1L); careCpRecordsEntity.setCreateUserId(1L);
careCpRecordsService.save(careCpRecordsEntity); careCpRecordsService.save(careCpRecordsEntity);
//发送差评消息 //发送差评消息
AlarmRecordsEntity recordsEntity = new AlarmRecordsEntity(); AlarmRecordsEntity recordsEntity = new AlarmRecordsEntity();
recordsEntity.initAttrValue(); recordsEntity.initAttrValue();
String alarmContent = String.format( String alarmContent = String.format(
"客户对窗口:%s:,工作人员%s 发起评价:%s，评价内容:%s!", "客户对窗口:%s:,工作人员%s 发起评价:%s，评价内容:%s!",
careCpRecordsEntity.getWindowName(), cpPersonInfo.getWorkmanName(), cpPersonInfo.getOptionId(), cpPersonInfo.getContent()); careCpRecordsEntity.getWindowName(), cpPersonInfo.getWorkmanName(), cpPersonInfo.getOptionId(), cpPersonInfo.getContent());
recordsEntity.setAlarmContent(alarmContent); recordsEntity.setAlarmContent(alarmContent);
recordsEntity.setAlarmTime(new Date()); recordsEntity.setAlarmTime(new Date());
recordsEntity.setCreateTime(new Date()); recordsEntity.setCreateTime(new Date());
recordsEntity.setCreateUserId(1L); recordsEntity.setCreateUserId(1L);
alarmRecordsService.save(recordsEntity); alarmRecordsService.save(recordsEntity);
}
} }
}); }
ThreadPool.getInstance().execute(thread);
} }
...@@ -495,15 +494,14 @@ public class SyncAppointWaitAndFinTaskImpl implements ITaskExcuteService { ...@@ -495,15 +494,14 @@ public class SyncAppointWaitAndFinTaskImpl implements ITaskExcuteService {
System.out.println(isIn);*/ System.out.println(isIn);*/
String value="{\"id\":\"76007\",\"peopleid\":\"0\",\"idcardData_PhotoFileName\":\"\",\"option_id\":\"不满意\",\"content_ids\":\"6,22\",\"pic_url\":\"\",\"sectionid\":\"424\",\"source\":\"安卓评价\",\"opinion\":\"\",\"siteid\":\"1\",\"windowid\":\"205\",\"queueid\":\"752197\",\"create_time\":\"2025-04-08 09:45:46\",\"update_time\":\"2025-04-08 09:45:46\",\"pjxt\":\"1\",\"workman_id\":\"1062\",\"device_id\":\"226\",\"evaluatestatus\":\"2\",\"evaluatetype\":\"1\",\"photobefor\":\"\",\"photoautograph\":\"\",\"picture\":\"\",\"process\":\"\",\"eyevaluate\":\"0\",\"type\":\"phpj\",\"hallid\":\"8\",\"devicenum\":\"08-00-27-E1-42-F7\",\"window_name\":\"行政审批窗口\",\"window_fronum\":\"2E32\",\"workman_name\":\"陈莹\",\"workman_number\":\"RS107\",\"section\":\"市人力资源社会保障局\",\"flounum\":\"EP005\",\"content\":\"等待时间长,服务态度差\",\"idcard_Name\":\"\",\"idcard_IDCardNo\":\"\",\"phone\":\"\"}"; String value = "{\"id\":\"76007\",\"peopleid\":\"0\",\"idcardData_PhotoFileName\":\"\",\"option_id\":\"不满意\",\"content_ids\":\"6,22\",\"pic_url\":\"\",\"sectionid\":\"424\",\"source\":\"安卓评价\",\"opinion\":\"\",\"siteid\":\"1\",\"windowid\":\"205\",\"queueid\":\"752197\",\"create_time\":\"2025-04-08 09:45:46\",\"update_time\":\"2025-04-08 09:45:46\",\"pjxt\":\"1\",\"workman_id\":\"1062\",\"device_id\":\"226\",\"evaluatestatus\":\"2\",\"evaluatetype\":\"1\",\"photobefor\":\"\",\"photoautograph\":\"\",\"picture\":\"\",\"process\":\"\",\"eyevaluate\":\"0\",\"type\":\"phpj\",\"hallid\":\"8\",\"devicenum\":\"08-00-27-E1-42-F7\",\"window_name\":\"行政审批窗口\",\"window_fronum\":\"2E32\",\"workman_name\":\"陈莹\",\"workman_number\":\"RS107\",\"section\":\"市人力资源社会保障局\",\"flounum\":\"EP005\",\"content\":\"等待时间长,服务态度差\",\"idcard_Name\":\"\",\"idcard_IDCardNo\":\"\",\"phone\":\"\"}";
log.info("cp:{}",value); log.info("cp:{}", value);
CpPersonInfo cpPersonInfo = JSON.parseObject(value, CpPersonInfo.class); CpPersonInfo cpPersonInfo = JSON.parseObject(value, CpPersonInfo.class);
log.info("cp obj:{}",JSON.toJSONString(cpPersonInfo)); log.info("cp obj:{}", JSON.toJSONString(cpPersonInfo));
double result = NumberUtil.div(Double.parseDouble((63-53)+""), 60, 1); // 保留1位小数，四舍五入 double result = NumberUtil.div(Double.parseDouble((63 - 53) + ""), 60, 1); // 保留1位小数，四舍五入
System.out.println(result); System.out.println(result);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment