lijingtong
/
dataSend_zhyq
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

电表设备订单信息

This commit is contained in:
李京通 2025-07-09 11:08:29 +08:00
parent 06a07462d9
commit 404a882829
7 changed files with 156 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/com/bootdo/datasend/dianxin/domain/dto/DeviceOrderInfoDTO.java
View File

@ -1,9 +1,18 @@
package com.bootdo.datasend.dianxin.domain.dto;
import com.alibaba.fastjson.annotation.JSONField;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @Description DeviceOrderInfoDTO
* @Author lijingtong
* @Date 2025-07-09
*/
@Data
@NoArgsConstructor
public class DeviceOrderInfoDTO {
@JSONField(name = "requestData")
private DeviceOrderInfoDataDTO requestData;
}

21
src/main/java/com/bootdo/datasend/dianxin/domain/dto/DeviceOrderInfoDataDTO.java Normal file
View File

@ -0,0 +1,21 @@
package com.bootdo.datasend.dianxin.domain.dto;
import com.alibaba.fastjson.annotation.JSONField;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.List;
/**
* @Description DeviceOrderInfoDataDTO
* @Author lijingtong
* @Date 2025-07-09
*/
@Data
@NoArgsConstructor
public class DeviceOrderInfoDataDTO {
@JSONField(name = "requestFlag")
private String requestFlag;
@JSONField(name = "requestDataList")
private List<DeviceOrderInfoDataListDTO> requestDataList;
}

38
src/main/java/com/bootdo/datasend/dianxin/domain/dto/DeviceOrderInfoDataListDTO.java Normal file
View File

@ -0,0 +1,38 @@
package com.bootdo.datasend.dianxin.domain.dto;
import com.alibaba.fastjson.annotation.JSONField;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.math.BigDecimal;
/**
* @Description DeviceOrderInfoDataListDTO
* @Author lijingtong
* @Date 2025-07-09
*/
@Data
@NoArgsConstructor
public class DeviceOrderInfoDataListDTO {
// 设备(国标)编码
@JSONField(name = "deviceSN")
private String deviceSN;
// 销售类型1-充值 2-冲正 3-退费
@JSONField(name = "saleType")
private Integer saleType;
// 购买方式
@JSONField(name = "buyTypeName")
private String buyTypeName;
// 订单金额
@JSONField(name = "money")
private BigDecimal money;
// 订单时间
@JSONField(name = "saleDate")
private String saleDate;
// 购买用户
@JSONField(name = "ownerName")
private String ownerName;
// 房间号
@JSONField(name = "roomNo")
private String roomNo;
}

14
src/main/java/com/bootdo/datasend/dianxin/mapper/DeviceOrderInfoMapper.java Normal file
View File

@ -0,0 +1,14 @@
package com.bootdo.datasend.dianxin.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.bootdo.datasend.dianxin.domain.DeviceOrderInfo;
import org.apache.ibatis.annotations.Mapper;
/**
* @Description DeviceOrderInfoMapper
* @Author lijingtong
* @Date 2025-07-09
*/
@Mapper
public interface DeviceOrderInfoMapper extends BaseMapper<DeviceOrderInfo> {
}

12
src/main/java/com/bootdo/datasend/dianxin/service/DeviceOrderInfoService.java Normal file
View File

@ -0,0 +1,12 @@
package com.bootdo.datasend.dianxin.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.bootdo.datasend.dianxin.domain.DeviceOrderInfo;
/**
* @Description DeviceOrderInfoService
* @Author lijingtong
* @Date 2025-07-09
*/
public interface DeviceOrderInfoService extends IService<DeviceOrderInfo> {
}

16
src/main/java/com/bootdo/datasend/dianxin/service/impl/DeviceOrderInfoServiceImpl.java Normal file
View File

@ -0,0 +1,16 @@
package com.bootdo.datasend.dianxin.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.bootdo.datasend.dianxin.domain.DeviceOrderInfo;
import com.bootdo.datasend.dianxin.mapper.DeviceOrderInfoMapper;
import com.bootdo.datasend.dianxin.service.DeviceOrderInfoService;
import org.springframework.stereotype.Service;
/**
* @Description DeviceOrderInfoServiceImpl
* @Author lijingtong
* @Date 2025-07-09
*/
@Service
public class DeviceOrderInfoServiceImpl extends ServiceImpl<DeviceOrderInfoMapper, DeviceOrderInfo> implements DeviceOrderInfoService {
}

46
src/main/java/com/bootdo/datasend/dianxin/task/StandardTask.java
View File

@ -33,6 +33,7 @@ public class StandardTask {
private final BaseVehicleRecordService vehicleRecordService;
private final BaseDoorRecordService doorRecordService;
private final DeviceInfoRecordService deviceRecordService;
private final DeviceOrderInfoService deviceOrderInfoService;
private final RestTemplate restTemplate;
@ -533,5 +534,50 @@ public class StandardTask {
/**
* 推送设备订单信息
*/
@Scheduled(cron = "0/5 * * * * ? ")
public void DeviceOrderInfoRecord() {
List<DeviceOrderInfo> lists = deviceOrderInfoService.list(new QueryWrapper<DeviceOrderInfo>()
.eq("is_send", "0")
.last("limit 100")
);
for (DeviceOrderInfo h : lists) {
DeviceOrderInfoDTO dto = new DeviceOrderInfoDTO();
DeviceOrderInfoDataDTO dataDTO = new DeviceOrderInfoDataDTO();
dataDTO.setRequestFlag("single");
DeviceOrderInfoDataListDTO dataListDTO = new DeviceOrderInfoDataListDTO();
dataListDTO.setDeviceSN(h.getDeviceSN());
dataListDTO.setSaleType(h.getSaleType());
dataListDTO.setBuyTypeName(h.getBuyTypeName());
dataListDTO.setMoney(h.getMoney());
dataListDTO.setSaleDate(h.getSaleDate());
dataListDTO.setOwnerName(h.getOwnerName());
dataListDTO.setRoomNo(h.getRoomNo());
List<DeviceOrderInfoDataListDTO> list = new ArrayList<>();
list.add(dataListDTO);
dataDTO.setRequestDataList(list);
dto.setRequestData(dataDTO);
String requestBody = JSON.toJSONString(dto, SerializerFeature.BrowserCompatible);
String url = "";
try {
// 发送 POST 请求，这里假设接口返回类型为 String ，可根据实际调整
// 消息队列发送
// rabbitTemplate.convertAndSend(queueName, JSON.toJSONString(dto));
// 调接口
String result = restTemplate.postForObject(url, requestBody, String.class);
logger.info("调用接口返回结果：{}", result);
// 若返回码符合成功逻辑（需看接口文档定义），更新发送状态
h.setIsSend(1);
deviceOrderInfoService.saveOrUpdate(h);
logger.info("电表设备订单信息发送成功：" + h.getId());
} catch (Exception e) {
logger.error("调用接口发送数据失败，记录 ID：{}，异常：{}", h.getId(), e.getMessage());
}
}
}
}