优化代码

java110-bean/src/main/java/com/java110/dto/store/StoreUserDto.java

@@ -13,6 +13,8 @@ import java.util.Date;
  */
 public class StoreUserDto extends PageDto implements Serializable {
 
+    public static final String REL_CD_MANAGER = "600311000001";
+
     //商户id
     private String storeId;
 

service-job/src/main/java/com/java110/job/task/fee/AccountDeductionPayFeeTemplate.java

@@ -11,16 +11,19 @@ import com.java110.dto.app.AppDto;
 import com.java110.dto.community.CommunityDto;
 import com.java110.dto.fee.FeeDto;
 import com.java110.dto.log.LogSystemErrorDto;
+import com.java110.dto.store.StoreUserDto;
 import com.java110.dto.task.TaskDto;
 import com.java110.intf.acct.IAccountInnerServiceSMO;
 import com.java110.intf.common.ILogSystemErrorInnerServiceSMO;
 import com.java110.intf.fee.IFeeInnerServiceSMO;
+import com.java110.intf.store.IStoreUserV1InnerServiceSMO;
 import com.java110.job.quartz.TaskSystemQuartz;
 import com.java110.po.account.AccountDetailPo;
 import com.java110.po.log.LogSystemErrorPo;
 import com.java110.service.smo.ISaveSystemErrorSMO;
 import com.java110.utils.constant.ServiceCodeConstant;
 import com.java110.utils.exception.SMOException;
+import com.java110.utils.util.Assert;
 import com.java110.utils.util.DateUtil;
 import com.java110.utils.util.ExceptionUtil;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -56,6 +59,9 @@ public class AccountDeductionPayFeeTemplate extends TaskSystemQuartz {
     @Autowired
     private IAccountInnerServiceSMO accountInnerServiceSMOImpl;
 
+    @Autowired
+    private IStoreUserV1InnerServiceSMO storeUserV1InnerServiceSMOImpl;
+
     @Autowired
     RestTemplate restTemplate;
 
@@ -116,6 +122,13 @@ public class AccountDeductionPayFeeTemplate extends TaskSystemQuartz {
         if (feeDtos == null || feeDtos.size() < 1) {
             return;
         }
+        StoreUserDto storeUserDto = new StoreUserDto();
+        storeUserDto.setStoreId(feeDtos.get(0).getIncomeObjId());
+        storeUserDto.setRelCd(StoreUserDto.REL_CD_MANAGER);
+        List<StoreUserDto> storeUserDtos = storeUserV1InnerServiceSMOImpl.queryStoreUsers(storeUserDto);
+
+        Assert.listOnlyOne(storeUserDtos,"没有扣款的用户");
+
         List<FeeDto> tmpFeeDtos = new ArrayList<>();
         for (FeeDto tmpFeeDto : feeDtos) {
             computeFeeSMOImpl.computeEveryOweFee(tmpFeeDto);//计算欠费金额
@@ -164,7 +177,7 @@ public class AccountDeductionPayFeeTemplate extends TaskSystemQuartz {
                 param.put("fees", fees);
                 param.put("remark", "定时账户扣款缴费");
                 try {
-                    CallApiServiceFactory.postForApi(AppDto.JOB_APP_ID, param, ServiceCodeConstant.SERVICE_CODE_PAY_OWE_FEE, JSONObject.class);
+                    CallApiServiceFactory.postForApi(AppDto.JOB_APP_ID, param, ServiceCodeConstant.SERVICE_CODE_PAY_OWE_FEE, JSONObject.class,storeUserDtos.get(0).getUserId());
                 } catch (SMOException e) {
                     logger.error("缴费失败", e);
                     accountDetailPo = new AccountDetailPo();