update 个人桩充电记录

This commit is contained in:
Guoqs
2024-07-06 16:23:04 +08:00
parent e3b7e9e512
commit 2c03f24b6e
6 changed files with 93 additions and 6 deletions

View File

@@ -17,9 +17,8 @@ import com.jsowell.common.util.YKCUtils;
import com.jsowell.common.util.id.IdUtils;
import com.jsowell.netty.factory.YKCOperateFactory;
import com.jsowell.pile.domain.OrderBasicInfo;
import com.jsowell.pile.service.OrderBasicInfoService;
import com.jsowell.pile.service.PileMerchantInfoService;
import com.jsowell.pile.service.PileMsgRecordService;
import com.jsowell.pile.domain.PileBasicInfo;
import com.jsowell.pile.service.*;
import com.jsowell.pile.service.programlogic.AbstractProgramLogic;
import com.jsowell.pile.service.programlogic.ProgramLogicFactory;
import com.jsowell.thirdparty.common.CommonService;
@@ -68,6 +67,12 @@ public class TransactionRecordsRequestHandler extends AbstractHandler {
@Autowired
private CommonService commonService;
@Autowired
private PileBasicInfoService pileBasicInfoService;
@Autowired
private PersonalChargingRecordService personalChargingRecordService;
/*public static void main(String[] args) {
BigDecimal totalElectricity = new BigDecimal("23.73");
@@ -588,6 +593,13 @@ public class TransactionRecordsRequestHandler extends AbstractHandler {
* @param data
*/
private void processOrder(TransactionRecordsData data) {
String pileSn = data.getPileSn(); // 充电桩编号
PileBasicInfo pileBasicInfo = pileBasicInfoService.selectPileBasicInfoBySN(pileSn);
if (StringUtils.equals(pileBasicInfo.getBusinessType(), Constants.TWO)) {
personalChargingRecordService.processPersonalChargingRecord(data);
return;
}
String transactionCode = data.getTransactionCode();
// 根据交易流水号查询订单信息
OrderBasicInfo orderBasicInfo = orderBasicInfoService.getOrderInfoByTransactionCode(transactionCode);
@@ -666,7 +678,6 @@ public class TransactionRecordsRequestHandler extends AbstractHandler {
e.printStackTrace();
}
});
} else {
// 平台没有查到订单
orderBasicInfoService.saveAbnormalOrder(data);