|
@@ -1,11 +1,18 @@
|
|
|
package com.rongwei.bscommon.sys.strategy;
|
|
|
|
|
|
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
|
|
+import com.rongwei.bscommon.sys.service.JtSjjdqdService;
|
|
|
+import com.rongwei.bscommon.sys.service.JtSjjdqdService;
|
|
|
import com.rongwei.bscommon.sys.utils.AttendanceAssessmentSdk;
|
|
|
import com.rongwei.bsentity.domain.JtGsjtbsj;
|
|
|
+import com.rongwei.bsentity.domain.JtSjjdqd;
|
|
|
+import com.rongwei.bsentity.domain.JtSjjdqd;
|
|
|
import com.rongwei.bsentity.dto.ApiCallDto;
|
|
|
import com.rongwei.bsentity.dto.ApiReturnDto;
|
|
|
import com.rongwei.bsentity.dto.OrgApiDataConfigDTO;
|
|
|
import com.rongwei.rwcommon.base.R;
|
|
|
+import com.rongwei.rwcommon.base.exception.CustomException;
|
|
|
+import com.rongwei.rwcommon.utils.StringUtils;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
@@ -13,8 +20,9 @@ import java.util.ArrayList;
|
|
|
import java.util.List;
|
|
|
import java.util.Map;
|
|
|
|
|
|
-import static com.rongwei.bscommon.sys.utils.ApiDataOrgUtil.assembleApiData;
|
|
|
-import static com.rongwei.bscommon.sys.utils.ApiDataOrgUtil.setOrdinaryDate;
|
|
|
+import static com.rongwei.bscommon.sys.utils.ApiDataOrgUtil.*;
|
|
|
+import static com.rongwei.bscommon.sys.utils.ApiDataOrgUtil.setDatePattern;
|
|
|
+import static com.rongwei.bscommon.sys.utils.JXKHConstant.DatePattern.DATE_PATTERN_YMD;
|
|
|
|
|
|
/**
|
|
|
* AssembleK34ApiData class
|
|
@@ -24,27 +32,50 @@ import static com.rongwei.bscommon.sys.utils.ApiDataOrgUtil.setOrdinaryDate;
|
|
|
*/
|
|
|
@Component
|
|
|
public class KC121ApiRequestAndProcessing implements ApiRequestAndProcessingStrategy {
|
|
|
+ private static AttendanceAssessmentSdk attendanceAssessmentSdk;
|
|
|
+ private static JtSjjdqdService jtSjjdqdService;
|
|
|
+
|
|
|
+
|
|
|
@Autowired
|
|
|
- private AttendanceAssessmentSdk attendanceAssessmentSdk;
|
|
|
+ public void setAttendanceAssessmentSdk(AttendanceAssessmentSdk attendanceAssessmentSdk) {
|
|
|
+ KC121ApiRequestAndProcessing.attendanceAssessmentSdk = attendanceAssessmentSdk;
|
|
|
+ }
|
|
|
|
|
|
- @Override
|
|
|
- public Map<String, Object> assembleData(String id,String dataId,String code) {
|
|
|
- List<OrgApiDataConfigDTO> assembleData = new ArrayList<>();
|
|
|
|
|
|
- assembleData.add(setOrdinaryDate("DATAID", JtGsjtbsj::getDataid));
|
|
|
+ @Autowired
|
|
|
+ public void setJtXcjhqdServiceImpl(JtSjjdqdService jtSjjdqdService) {
|
|
|
+ KC121ApiRequestAndProcessing.jtSjjdqdService = jtSjjdqdService;
|
|
|
+ }
|
|
|
|
|
|
- JtGsjtbsj jtGsjtbsj = new JtGsjtbsj();
|
|
|
- Map<String, Object> stringObjectMap = assembleApiData(jtGsjtbsj, assembleData);
|
|
|
+ @Override
|
|
|
+ public Map<String, Object> assembleData(String id,String dateId, String code) {
|
|
|
+ List<OrgApiDataConfigDTO> assembleData = new ArrayList<>();
|
|
|
+ assembleData.add(setOrdinaryDate("DATAID", JtSjjdqd::getDataid));
|
|
|
+ assembleData.add(setOrdinaryDate("INDEXID", JtSjjdqd::getId));
|
|
|
+ assembleData.add(setOrdinaryDate("xmbh", JtSjjdqd::getXmbh));
|
|
|
+ assembleData.add(setOrdinaryDate("xmmc", JtSjjdqd::getXmmc));
|
|
|
+ assembleData.add(setOrdinaryDate("sjjdbghyjymc", JtSjjdqd::getName));
|
|
|
+ assembleData.add(setDatePattern("jhjdsj", JtSjjdqd::getJhjdsj,DATE_PATTERN_YMD));
|
|
|
+ assembleData.add(setDatePattern("hykzzsj", JtSjjdqd::getHykzsj,DATE_PATTERN_YMD));
|
|
|
+ JtSjjdqd jtSjjdqd = jtSjjdqdService.getById(id);
|
|
|
+ Map<String, Object> stringObjectMap = assembleApiData(jtSjjdqd, assembleData);
|
|
|
return stringObjectMap;
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public R apiCallAndDataProcessing(String id, String dataId, String code, Map<String, Object> apiCallData) {
|
|
|
+ public R apiCallAndDataProcessing(String id,String dataId, String code, Map<String, Object> apiCallData) {
|
|
|
ApiCallDto paramVo = new ApiCallDto();
|
|
|
paramVo.setData(apiCallData);
|
|
|
paramVo.setApiCode(code);
|
|
|
ApiReturnDto apiReturnDto = attendanceAssessmentSdk.apiCall(paramVo);
|
|
|
// 后续逻辑处理
|
|
|
+ Map<String, String> apiReturnData = apiReturnDto.getApiReturnData();
|
|
|
+ String realDataId = apiReturnData.getOrDefault("DATAID", "").toString();
|
|
|
+ if (StringUtils.isBlank(realDataId)) {
|
|
|
+ throw new CustomException("接口请求成功,但无法获取dataId");
|
|
|
+ }
|
|
|
+ jtSjjdqdService.update(new LambdaUpdateWrapper<JtSjjdqd>()
|
|
|
+ .eq(JtSjjdqd::getId, id).set(JtSjjdqd::getDataid, realDataId));
|
|
|
return R.ok();
|
|
|
}
|
|
|
}
|