38 lines
1.2 KiB
Java
38 lines
1.2 KiB
Java
|
package com.zhgd.xmgl.async;
|
||
|
|
|
||
|
|
import cn.hutool.http.HttpUtil;
|
||
|
|
import cn.hutool.json.JSONUtil;
|
||
|
|
import com.zhgd.xmgl.modules.ammeter.entity.AmmeterRecordDetail;
|
||
|
|
import com.zhgd.xmgl.modules.water.entity.WaterMeterRecordDetail;
|
||
|
|
import lombok.extern.slf4j.Slf4j;
|
||
|
|
import org.springframework.beans.factory.annotation.Value;
|
||
|
|
import org.springframework.scheduling.annotation.Async;
|
||
|
|
import org.springframework.stereotype.Component;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* @author 邱平毅
|
||
|
|
* @ClassName AsyncDoubleCarbon
|
||
|
|
* @date 2023/1/6
|
||
|
|
* @Version 1.0
|
||
|
|
*/
|
||
|
|
@Slf4j
|
||
|
|
@Component
|
||
|
|
public class AsyncDoubleCarbon {
|
||
|
|
@Value("${double-carbon.water-data-url}")
|
||
|
|
private String waterDataUrl;
|
||
|
|
|
||
|
|
@Value("${double-carbon.ammeter-data-url}")
|
||
|
|
private String ammeterDataUrl;
|
||
|
|
|
||
|
|
|
||
|
|
@Async("doubleCarbonExecutor")
|
||
|
|
public void sendWaterData(WaterMeterRecordDetail waterMeterRecordDetail) {
|
||
|
|
HttpUtil.post(waterDataUrl + "/saveWaterMeterRecordDetail", JSONUtil.toJsonStr(waterMeterRecordDetail));
|
||
|
|
}
|
||
|
|
|
||
|
|
@Async("doubleCarbonExecutor")
|
||
|
|
public void sendAmmeterData(AmmeterRecordDetail ammeterRecordDetail) {
|
||
|
|
HttpUtil.post(ammeterDataUrl + "/saveAmmeterRecordDetail", JSONUtil.toJsonStr(ammeterRecordDetail));
|
||
|
|
}
|
||
|
|
}
|