增加ds注解

This commit is contained in:
xiang2lin 2024-06-19 16:56:40 +08:00
parent 642986b94a
commit f8238f9000
1 changed files with 10 additions and 2 deletions

View File

@ -6,6 +6,7 @@ import com.hzya.frame.seeyon.cbs8.dao.IPaymentDao;
import com.hzya.frame.seeyon.cbs8.entity.PaymentEntity; import com.hzya.frame.seeyon.cbs8.entity.PaymentEntity;
import com.hzya.frame.seeyon.cbs8.service.IPaymentService; import com.hzya.frame.seeyon.cbs8.service.IPaymentService;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.List; import java.util.List;
@ -27,7 +28,6 @@ public class PaymentServiceImpl extends BaseService<PaymentEntity,String> implem
this.paymentDao = paymentDao; this.paymentDao = paymentDao;
this.dao = paymentDao; this.dao = paymentDao;
} }
/** /**
* 查询待支付的数据 需要推送到CBS的 * 查询待支付的数据 需要推送到CBS的
* 如果需要查询流程状态已结束的 需要调用方设置finishedflag=1 * 如果需要查询流程状态已结束的 需要调用方设置finishedflag=1
@ -37,9 +37,12 @@ public class PaymentServiceImpl extends BaseService<PaymentEntity,String> implem
* @throws Exception * @throws Exception
*/ */
@DS("#entity.dataSourceCode")
@Override @Override
public List<PaymentEntity> queryUnpaid(PaymentEntity entity) throws Exception { public List<PaymentEntity> queryUnpaid(PaymentEntity entity) throws Exception {
return null; List<PaymentEntity> list = paymentDao.queryList(entity, "com.hzya.frame.seeyon.cbs8.entity.PaymentEntity.PaymentEntity_list_base_unpaid");
return list;
} }
/** /**
@ -50,6 +53,7 @@ public class PaymentServiceImpl extends BaseService<PaymentEntity,String> implem
* @return * @return
* @throws Exception * @throws Exception
*/ */
@DS("#entity.dataSourceCode")
@Override @Override
public List<PaymentEntity> querySuccess(PaymentEntity entity) throws Exception { public List<PaymentEntity> querySuccess(PaymentEntity entity) throws Exception {
return null; return null;
@ -62,6 +66,7 @@ public class PaymentServiceImpl extends BaseService<PaymentEntity,String> implem
* @return * @return
* @throws Exception * @throws Exception
*/ */
@DS("#entity.dataSourceCode")
@Override @Override
public List<PaymentEntity> queryElecIsNull(PaymentEntity entity) throws Exception { public List<PaymentEntity> queryElecIsNull(PaymentEntity entity) throws Exception {
return null; return null;
@ -75,6 +80,7 @@ public class PaymentServiceImpl extends BaseService<PaymentEntity,String> implem
* @return * @return
* @throws Exception * @throws Exception
*/ */
@DS("#entity.dataSourceCode")
@Override @Override
public List<PaymentEntity> queryInPayment(PaymentEntity entity) throws Exception { public List<PaymentEntity> queryInPayment(PaymentEntity entity) throws Exception {
return null; return null;
@ -86,6 +92,7 @@ public class PaymentServiceImpl extends BaseService<PaymentEntity,String> implem
* @param entity * @param entity
* @throws Exception * @throws Exception
*/ */
@DS("#entity.dataSourceCode")
@Override @Override
public void updatePayState(PaymentEntity entity) throws Exception { public void updatePayState(PaymentEntity entity) throws Exception {
@ -97,6 +104,7 @@ public class PaymentServiceImpl extends BaseService<PaymentEntity,String> implem
* @param entity * @param entity
* @throws Exception * @throws Exception
*/ */
@DS("#entity.dataSourceCode")
@Override @Override
public void updateElec(PaymentEntity entity) throws Exception { public void updateElec(PaymentEntity entity) throws Exception {