/** # __----~~~~~~~~~~~------___ # . . ~~//====...... __--~ ~~ # -. \_|// |||\\ ~~~~~~::::... /~ # ___-==_ _-~o~ \/ ||| \\ _/~~- # __---~~~.==~||\=_ -_--~/_-~|- |\\ \\ _/~ # _-~~ .=~ | \\-_ '-~7 /- / || \ / # .~ .~ | \\ -_ / /- / || \ / # / ____ / | \\ ~-_/ /|- _/ .|| \ / # |~~ ~~|--~~~~--_ \ ~==-/ | \~--===~~ .\ # ' ~-| /| |-~\~~ __--~~ # |-~~-_/ | | ~\_ _-~ /\ # / \ \__ \/~ \__ # _--~ _/ | .-~~____--~-/ ~~==. # ((->/~ '.|||' -_| ~~-/ , . _|| # -_ ~\ ~~---l__i__i__i--~~_/ # _-~-__ ~) \--______________--~~ # //.-~~~-~_--~- |-------~~~~~~~~ # //.-~~~--\ # 神兽保佑 # 永无BUG! */ package com.lunhan.water.service; import com.google.gson.Gson; import com.google.gson.JsonArray; import com.google.gson.JsonObject; import com.google.gson.reflect.TypeToken; import com.lunhan.water.common.*; import com.lunhan.water.common.enums.*; import com.lunhan.water.common.jwt.LoginUserDTO; import com.lunhan.water.common.model.Tuple; import com.lunhan.water.common.util.*; import com.lunhan.water.entity.enums.EBillPayStatus; import com.lunhan.water.entity.enums.ECapitalChange; import com.lunhan.water.entity.request.paymentrecords.ReqBuyWater; import com.lunhan.water.host.mqtt.CountVO; import com.lunhan.water.host.mqtt.MQTTServer; import com.lunhan.water.repository.impl.*; import com.lunhan.water.repository.po.*; import com.lunhan.water.repository.vo.WaterFacilityVO; import org.apache.commons.lang3.BooleanUtils; import org.slf4j.Logger; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.lang.reflect.Type; import java.math.BigDecimal; import java.math.RoundingMode; import java.util.*; import java.util.stream.Collectors; import com.lunhan.water.entity.request.paymentrecords.ReqCreatePaymentRecords; import com.lunhan.water.entity.request.paymentrecords.ReqModifyPaymentRecords; import com.lunhan.water.entity.search.SearchPaymentRecords; import com.lunhan.water.repository.vo.PaymentRecordsVO; import com.lunhan.water.service.convert.PaymentRecordsConvert; /** * PaymentRecords * @author lin.liu */ @Service public class PaymentRecordsService extends BaseService { private static final Logger DEBUG_LOGGER = LoggerUtil.get(ELogger.DEBUG); private static final Logger ERROR_LOGGER = LoggerUtil.get(ELogger.SYS_ERROR); @Autowired private PaymentRecordsMapperImpl mapper; @Autowired private UserLoginMapperImpl userLoginMapper; @Autowired private WaterFacilityMapperImpl waterFacilityMapper; @Autowired private MQTTServer mqttServer; @Autowired private UserCapitalChangeMapperImpl userCapitalChangeMapper; @Autowired private HeartbeatDataMapperImpl heartbeatDataMapper; @Autowired private FacilityAlarmRecordMapperImpl facilityAlarmRecordMapper; @Autowired private WaterFacilityRecordsMapperImpl waterFacilityRecordsMapper; public ExecutedResult create(ReqCreatePaymentRecords request) { // 转换po PaymentRecordsPO item = PaymentRecordsConvert.INSTANCE.toCreate(request); // 设置状态 //item.setStatus(EState.NORMAL.getValue()); // 设置记录创建时间 item.setCreateTime(LocalDateTimeUtil.nowTimeStamp()); // 是否删除(逻辑删除)初始值 item.setIsDelete(EYesOrNo.NO.getValue()); int rowCount = mapper.insert(item); if (rowCount != 1) { return ExecutedResult.failed("创建[null]失败。"); } return ExecutedResult.success(item.getId()); } public ExecutedResult modify(ReqModifyPaymentRecords request) { // 验证记录是否存在 ExecutedResult checkExists = this.check4Id(request.getId()); if (checkExists.isFailed()) { return ExecutedResult.failed(checkExists.getMsg()); } // 转换po PaymentRecordsPO item = PaymentRecordsConvert.INSTANCE.toModify(request); int rowCount = mapper.updateById(item); if (rowCount != 1) { return ExecutedResult.failed("编辑[null]失败。"); } return ExecutedResult.success(); } public ExecutedResult get(Long id) { PaymentRecordsVO result = new PaymentRecordsVO(); PaymentRecordsPO find = mapper.get(id); if (null != find) { // 转换vo result = PaymentRecordsConvert.INSTANCE.toVo(find); } return ExecutedResult.success(result); } // public ExecutedResult stop(Long id) { // // 验证记录是否存在 // ExecutedResult checkExists = this.check4Id(id); // if (checkExists.isFailed()) { // return ExecutedResult.failed(checkExists.getMsg()); // } // PaymentRecordsPO item = new PaymentRecordsPO(); // item.setId(id); // item.setStatus(EState.DISABLED.getValue()); // // int rowCount = mapper.updateById(item); // if (rowCount != 1) { // return ExecutedResult.failed("停用[null]失败。"); // } // return ExecutedResult.success(); // } // // public ExecutedResult enable(Long id) { // // 验证记录是否存在 // ExecutedResult checkExists = this.check4Id(id); // if (checkExists.isFailed()) { // return ExecutedResult.failed(checkExists.getMsg()); // } // PaymentRecordsPO item = new PaymentRecordsPO(); // item.setId(id); // item.setStatus(EState.NORMAL.getValue()); // // int rowCount = mapper.updateById(item); // if (rowCount != 1) { // return ExecutedResult.failed("启用[null]失败。"); // } // return ExecutedResult.success(); // } // // public ExecutedResult setSort(ReqSetSort request) { // // 验证记录是否存在 // ExecutedResult checkExists = this.check4Id(request.getId()); // if (checkExists.isFailed()) { // return ExecutedResult.failed(checkExists.getMsg()); // } // PaymentRecordsPO item = new PaymentRecordsPO(); // item.setId(request.getId()); // item.setSort(request.getSort()); // // int rowCount = mapper.updateById(item); // if (rowCount != 1) { // return ExecutedResult.failed("设置[null]排序值失败。"); // } // return ExecutedResult.success(); // } // // public ExecutedResult listSetSort(ReqListSetSort request) { // // id列表 // List listId = request.getList().stream().map(ReqSetSort::getId).collect(Collectors.toList()); // // 验证记录是否存在 // ExecutedResult> checkExists = this.check4Id(listId); // if (checkExists.isFailed()) { // return ExecutedResult.failed(checkExists.getMsg()); // } // // List listUpdate = request.getList().stream() // .map(c -> { // PaymentRecordsPO item = new PaymentRecordsPO(); // item.setId(c.getId()); // item.setSort(c.getSort()); // return item; // }) // .collect(Collectors.toList()); // Boolean result = mapper.modifyList(listUpdate); // if (result) { // return ExecutedResult.success(); // } // return ExecutedResult.failed("[null]设置排序值失败"); // } // // public ExecutedResult remove(Long id) { // Boolean result = mapper.deleteLogic(id); // if (BooleanUtils.isFalse(result)) { // return ExecutedResult.failed("删除[null]失败。"); // } // return ExecutedResult.success(); // } // // public ExecutedResult removeList(List ids) { // Boolean result = mapper.deleteLogic(ids); // if (BooleanUtils.isFalse(result)) { // return ExecutedResult.failed("删除[null]失败。"); // } // return ExecutedResult.success(); // } /** * mqtt发送取水指令 * @param request 消息内容 */ public ExecutedResult userWaterInTaking(LoginUserDTO loginUser, ReqBuyWater request) { WaterFacilityPO facilityPO = waterFacilityMapper.getById(request.getFacilityId()); if (Objects.isNull(facilityPO)) { return ExecutedResult.failed("未查询到取水设备!"); } UserLoginPO userLoginPO = userLoginMapper.get4Openid(loginUser.getUserId()); if (Objects.isNull(userLoginPO)) { return ExecutedResult.failed("用户数据不存在!"); } if (userLoginPO.getBalance().compareTo(request.getAmount()) < 0) { return ExecutedResult.failed("余额水量不足!"); } //发送mqtt取水指令 String topic = "zundong/" + facilityPO.getFacilityCode() + "/send"; JsonObject data = new JsonObject(); data.addProperty(facilityPO.getFacilityCode() + "_count2", request.getAmount().multiply(BigDecimal.valueOf(100))); data.addProperty(facilityPO.getFacilityCode() + "_state2", 1); boolean send=false; if (Objects.nonNull(mqttServer)) { send = mqttServer.send(topic, data.toString()); } else { try { System.out.println("mqttServer bean尚未初始化..."); mqttServer = SpringUtil.getBean(MQTTServer.class); System.out.println("mqttServer 初始化bean成功!"); } catch (Exception ignored) { } if (Objects.nonNull(mqttServer)) { send=mqttServer.send(topic, data.toString()); } } if(!send){ ExecutedResult.failed("通讯断开!"); } //扣除余额 //创建消费记录 PaymentRecordsPO recordsPO=new PaymentRecordsPO(); recordsPO.setUserId(userLoginPO.getId()); recordsPO.setUserName(userLoginPO.getUserName()); recordsPO.setFacilityCode(facilityPO.getFacilityCode()); recordsPO.setPaymentAmount(request.getAmount()); recordsPO.setWaterAmount(request.getAmount()); recordsPO.setPayTime(LocalDateTimeUtil.nowDateTimeStr()); recordsPO.setPayStatus(EBillPayStatus.PAID.getValue()); recordsPO.setComment("取水"); recordsPO.setCreateTime(LocalDateTimeUtil.nowTimeStamp()); mapper.insert(recordsPO); //修改余额 BigDecimal beforeMoney=userLoginPO.getBalance(); BigDecimal subtract = beforeMoney.subtract(request.getAmount()); userLoginPO.setBalance(subtract); userLoginMapper.updateById(userLoginPO); //生成余额变动记录 UserCapitalChangePO changePO=new UserCapitalChangePO(); changePO.setUserId(userLoginPO.getId()); changePO.setBusiness(ECapitalChange.WATER_BILL_COUNTER_PAY.getValue()); changePO.setBusinessName("取水"); changePO.setBusinessCode("QS"+SnowFlakeUtil.getId()); changePO.setChangeMoney(request.getAmount()); changePO.setBeforeMoney(beforeMoney); changePO.setAfterMoney(subtract); changePO.setCreateTime(LocalDateTimeUtil.nowTimeStamp()); userCapitalChangeMapper.insert(changePO); return ExecutedResult.success("请点击设备取水按钮取水"); } /** * mqtt收到消息 * @param topic 主题 * @param msg 消息内容 */ public void mqttReceived(String topic, String msg) { if (StringUtil.isNullOrEmpty(topic)) { ERROR_LOGGER.error("主题不能为空"); return; } if (StringUtil.isNullOrEmpty(msg)) { ERROR_LOGGER.error("消息不能为空"); return; } String[] array = StringUtil.split(topic, "/"); if (array.length != 3) { ERROR_LOGGER.error("主题未能解析, " + topic); return; } WaterFacilityPO facilityPO = waterFacilityMapper.getCode(array[1]); if (Objects.isNull(facilityPO)) { DEBUG_LOGGER.error("设备数据未找到!"); return; } // 数据上报格式: // 主题格式:zundong/QS001/data // 数据格式:{"Data": // [ // {"name":"QS001_state","value":1}, //状态 // {"name":"QS001_fault","value":0}, //是否故障 // {"name":"QS001_count","value":10000} //总水量 // ],"time":"2025-07-02 15:19:17" // } // 心跳上报格式: // 主题格式:zundong/QS001/state // 数据格式:{"Data": // [ // {"name":"QS001_heartbeat","value":1} //心跳 // ],"time":"2025-07-02 15:19:17" // } //消息解析 Gson gson = new Gson(); JsonObject object = gson.fromJson(msg, JsonObject.class); String time = object.get("time").getAsString(); //long time = LocalDateTimeUtil.getTimeStamp(asJsonObject).getTime(); Type listType = new TypeToken>() { }.getType(); JsonArray data = object.getAsJsonArray("Data"); List listVo = gson.fromJson(data, listType); switch (array[2]) { case "data": uploadData(time,facilityPO,listVo); break; // case "state": // uploadState(time,facilityPO,listVo); // break; } } public void uploadData(String time,WaterFacilityPO facilityPO, List listVo) { CountVO stateVo = listVo.stream().filter(x -> x.getName().equals(facilityPO.getFacilityCode() + "_state1")).findFirst().orElse(null); CountVO heartbeat = listVo.stream().filter(x -> x.getName().equals(facilityPO.getFacilityCode() + "_heartbeat")).findFirst().orElse(null); CountVO countVO = listVo.stream().filter(x -> x.getName().equals(facilityPO.getFacilityCode() + "_count1")).findFirst().orElse(null); switch (stateVo.getValue()) { case "0"://取水完成 BigDecimal divide = new BigDecimal(countVO.getValue()).setScale(2,RoundingMode.DOWN); BigDecimal subtract=divide.subtract(facilityPO.getWaterCount()); if(subtract.compareTo(BigDecimal.ZERO)>0){ facilityPO.setWaterCount(divide); int i = waterFacilityMapper.updateById(facilityPO); if(i>0){ WaterFacilityRecordsPO recordsPO=new WaterFacilityRecordsPO(); recordsPO.setFacilityId(facilityPO.getId()); recordsPO.setFacilityName(facilityPO.getFacilityName()); recordsPO.setWaterValue(subtract); recordsPO.setUseDate(time); recordsPO.setCreateTime(LocalDateTimeUtil.nowTimeStamp()); recordsPO.setRemark("设备供水记录"); waterFacilityRecordsMapper.insert(recordsPO); } } break; case "1"://运行 break; case "2"://停止 break; case "3"://故障 break; } HeartbeatDataPO heartbeatDataPO = heartbeatDataMapper.getByKey(facilityPO.getFacilityCode()); if(Objects.nonNull(heartbeatDataPO)){ heartbeatDataPO.setDataValue(Integer.valueOf(heartbeat.getValue())); heartbeatDataPO.setSendValue(heartbeatDataPO.getSendValue()==0?1:0); heartbeatDataPO.setRemark(time); heartbeatDataMapper.updateById(heartbeatDataPO); }else { HeartbeatDataPO dataPO=new HeartbeatDataPO(); dataPO.setDataKey(facilityPO.getFacilityCode()); dataPO.setSendValue(0); dataPO.setDataValue(Integer.valueOf(heartbeat.getValue())); dataPO.setCreateTime(LocalDateTimeUtil.nowTimeStamp()); dataPO.setRemark(LocalDateTimeUtil.nowDateTimeStr()); heartbeatDataMapper.insert(dataPO); } } public ExecutedResult> getList(List listId) { List result = new ArrayList<>(); List list = mapper.getList(listId); if (ListUtil.isNotNullOrEmpty(list)) { // 转换vo result = PaymentRecordsConvert.INSTANCE.toVo(list); } return ExecutedResult.success(result); } public ExecutedResult> search(SearchPaymentRecords search) { // 处理创建时间范围-查询参数 if (search.getDateType() != null && search.getDateType() > 0) { Long beginTime = 0L; Long endTime = 0L; switch (search.getDateType()) { case 1: beginTime = LocalDateTimeUtil.getTimeStamp(LocalDateTimeUtils.todayStartTime()).getTime(); endTime = LocalDateTimeUtil.getTimeStamp(LocalDateTimeUtils.todayEndTime()).getTime(); break; case 2: beginTime = LocalDateTimeUtil.getTimeStamp(LocalDateTimeUtils.weekStartTime()).getTime(); endTime = LocalDateTimeUtil.getTimeStamp(LocalDateTimeUtils.weekEndTime()).getTime(); break; case 3: beginTime = LocalDateTimeUtil.getTimeStamp(LocalDateTimeUtils.monthStartTime()).getTime(); endTime = LocalDateTimeUtil.getTimeStamp(LocalDateTimeUtils.monthEndTime()).getTime(); break; case 4: beginTime = LocalDateTimeUtil.getTimeStamp(LocalDateTimeUtils.yearStartTime()).getTime(); endTime = LocalDateTimeUtil.getTimeStamp(LocalDateTimeUtils.yearEndTime()).getTime(); break; } if (beginTime > 0) { search.setCreateTimeStart(beginTime); } if (endTime > 0) { search.setCreateTimeEnd(endTime); } } PagerResult pageList = mapper.search(search); List listVo = new ArrayList<>(); List list = pageList.getList(); if (ListUtil.isNotNullOrEmpty(list)) { pageList.setLastId(list.get(list.size() - 1).getId()); // 转换vo listVo = CopierUtil.mapTo(list, PaymentRecordsVO.class); //获取列表所有用户id List idList = listVo.stream().map(PaymentRecordsVO::getUserId).distinct().collect(Collectors.toList()); List userList = userLoginMapper.getListById(idList); for (PaymentRecordsVO vo : listVo) { UserLoginPO userLoginPO = userList.stream().filter(x -> x.getId().equals(vo.getUserId())).findFirst().orElse(null); if (Objects.nonNull(userLoginPO)) { vo.setBalance(userLoginPO.getBalance()); } } } PagerResult result = new PagerResult<>(pageList.getLimit(), pageList.getPage(), pageList.getTotal(), listVo); result.setLastId(pageList.getLastId()); return ExecutedResult.success(result); } protected ExecutedResult check4Id(Long id) { PaymentRecordsPO exists = mapper.get(id); if (Objects.isNull(exists)) { return ExecutedResult.failed("[null]不存在:" + id); } return ExecutedResult.success(exists); } protected ExecutedResult> check4Id(List listId) { // 从数据库查找null List list = mapper.getList(listId); if (ListUtil.isNullOrEmpty(list)) { return ExecutedResult.failed("[null]不存在." + listId); } // 数据库找到的id列表 List listIdFind = list.stream().map(PaymentRecordsPO::getId).collect(Collectors.toList()); // 数量不一致 if (listId.size() != listIdFind.size()) { // 筛选数据库不存在的null List listIdNotFound = listId.stream().filter(c -> !listIdFind.contains(c)).collect(Collectors.toList()); if (ListUtil.isNullOrEmpty(list)) { return ExecutedResult.failed("[null]不存在." + listIdNotFound); } } return ExecutedResult.success(list); } }