package com.fzzy.push.gb2022;
|
|
import com.fzzy.api.data.ApiParam;
|
import com.fzzy.api.data.PushProtocol;
|
import com.fzzy.api.service.PushService12;
|
import com.fzzy.push.impl.ComPushService12;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
/**
|
* 粮食购销-推送
|
*/
|
@Slf4j
|
@Component
|
public class GBPushService12 implements PushService12 {
|
|
// @Autowired
|
// private Api1201Rep api1201Rep;
|
// @Autowired
|
// private Api1202Rep api1202Rep;
|
// @Autowired
|
// private Api1203Rep api1203Rep;
|
// @Autowired
|
// private Api1204Rep api1204Rep;
|
// @Autowired
|
// private Api1205Rep api1205Rep;
|
// @Autowired
|
// private Api1206Rep api1206Rep;
|
// @Autowired
|
// private Api1208Rep api1208Rep;
|
// @Autowired
|
// private Api1209Rep api1209Rep;
|
@Autowired
|
private GBApiRemoteService apiRemoteService;
|
|
@Autowired
|
private ComPushService12 pushService;
|
|
|
@Override
|
public String getProtocol() {
|
return PushProtocol.GB_2022.getCode();
|
}
|
|
|
@Override
|
public void pushData(ApiParam param) {
|
|
log.info("------->>>>粮食购销 接口模块上报开始");
|
|
pushService.pushData1201(apiRemoteService, param);
|
|
pushService.pushData1202(apiRemoteService, param);
|
|
pushService.pushData1203(apiRemoteService, param);
|
|
pushService.pushData1204(apiRemoteService, param);
|
|
pushService.pushData1205(apiRemoteService, param);
|
|
pushService.pushData1206(apiRemoteService, param);
|
|
pushService.pushData1208(apiRemoteService, param);
|
|
pushService.pushData1209(apiRemoteService, param);
|
|
log.info("------->>>>粮食购销 接口模块上报结束");
|
}
|
|
// /**
|
// * 1201 合同信息数据接口
|
// *
|
// * @param param
|
// */
|
// private void pushData1201(ApiParam param) {
|
//
|
// List<Api1201> items = api1201Rep.findPushData(param.getKqdm());
|
//
|
// if (null == items || items.isEmpty()) {
|
// return;
|
// }
|
//
|
// param.setInteCategory(Constant.API_CATEGORY_12);
|
// param.setInteId(Constant.API_CODE_1201);
|
//
|
// ResponseDto responseDto;
|
// Api1201 apiData;
|
//
|
// for (Api1201 data : items) {
|
// apiData = new Api1201();
|
// BeanUtils.copyProperties(data, apiData);
|
// param.setBizId(data.getBizId());
|
//
|
// responseDto = apiRemoteService.pushData(param, apiData);
|
// if (responseDto.getSuccess() == 0) {
|
// if (Constant.CZBZ_I.equals(apiData.getCzbz())) {
|
// api1201Rep.updateStatus(apiData.getHth(), Constant.CZBZ_U);
|
// }
|
// }
|
// }
|
// }
|
//
|
// /**
|
// * 接口编码-1202 粮食入库信息数据接口
|
// */
|
// private void pushData1202(ApiParam param) {
|
// List<ShjdjwApi1202> items = api1202Rep.findPushData(param.getKqdm());
|
// if (null == items || items.isEmpty()) {
|
// return;
|
// }
|
// param.setInteCategory(Constant.API_CATEGORY_12);
|
// param.setInteId(Constant.API_CODE_1202);
|
//
|
// ResponseDto responseDto;
|
// for (ShjdjwApi1202 data : items) {
|
// responseDto = apiRemoteService.pushData(param, data);
|
// if (responseDto.getSuccess() == 0) {
|
// if (Constant.CZBZ_I.equals(data.getCzbz())) {
|
// api1202Rep.updateStatus(data.getId(), Constant.CZBZ_U);
|
// }
|
// }
|
// }
|
// }
|
//
|
// /**
|
// * 1203
|
// *
|
// * @param kqdm
|
// * @param start
|
// * @param end
|
// */
|
// private void pushData1203(ApiParam param) {
|
//
|
// List<Api1203> items = api1203Rep.findPushData(param.getKqdm());
|
//
|
// if (null == items || items.isEmpty()) {
|
// return;
|
// }
|
//
|
// param.setInteCategory(Constant.API_CATEGORY_12);
|
// param.setInteId(Constant.API_CODE_1203);
|
//
|
// ResponseDto responseDto;
|
// Api1203 apiData;
|
// for (Api1203 data : items) {
|
// apiData = new Api1203();
|
//
|
// BeanUtils.copyProperties(data, apiData);
|
// param.setBizId(data.getBizId());
|
// responseDto = apiRemoteService.pushData(param, apiData);
|
//
|
// if (responseDto.getSuccess() == 0) {
|
// if (Constant.CZBZ_I.equals(apiData.getCzbz())) {
|
// api1203Rep.updateStatus(apiData.getId(), Constant.CZBZ_U);
|
// }
|
// }
|
// }
|
// }
|
//
|
// /**
|
// * 1204
|
// *
|
// * @param kqdm
|
// * @param start
|
// * @param end
|
// */
|
// private void pushData1204(ApiParam param) {
|
//
|
// List<Api1204> items = api1204Rep.findPushData(param.getKqdm());
|
//
|
// if (null == items || items.isEmpty()) {
|
// return;
|
// }
|
//
|
// param.setInteCategory(Constant.API_CATEGORY_12);
|
// param.setInteId(Constant.API_CODE_1204);
|
//
|
// ResponseDto responseDto;
|
// Api1204 apiData;
|
// for (Api1204 data : items) {
|
// apiData = new Api1204();
|
// BeanUtils.copyProperties(data, apiData);
|
//
|
// param.setBizId(data.getBizId());
|
// responseDto = apiRemoteService.pushData(param, apiData);
|
//
|
// if (responseDto.getSuccess() == 0) {
|
// if (Constant.CZBZ_I.equals(apiData.getCzbz())) {
|
// api1204Rep.updateStatus(apiData.getRkjsdh(), Constant.CZBZ_U);
|
// }
|
// }
|
// }
|
// }
|
//
|
// /**
|
// * 1205
|
// *
|
// * @param kqdm
|
// * @param start
|
// * @param end
|
// */
|
// private void pushData1205(ApiParam param) {
|
//
|
// List<Api1205> items = api1205Rep.findPushData(param.getKqdm());
|
//
|
// if (null == items || items.isEmpty()) {
|
// return;
|
// }
|
//
|
// param.setInteCategory(Constant.API_CATEGORY_12);
|
// param.setInteId(Constant.API_CODE_1205);
|
//
|
//
|
// ResponseDto responseDto;
|
// Api1205 apiData;
|
// for (Api1205 data : items) {
|
// apiData = new Api1205();
|
// BeanUtils.copyProperties(data, apiData);
|
// param.setBizId(data.getBizId());
|
// responseDto = apiRemoteService.pushData(param, apiData);
|
//
|
// if (responseDto.getSuccess() == 0) {
|
// if (Constant.CZBZ_I.equals(apiData.getCzbz())) {
|
// api1205Rep.updateStatus(apiData.getId(), Constant.CZBZ_U);
|
// }
|
// }
|
// }
|
// }
|
//
|
// /**
|
// * 1206
|
// *
|
// * @param kqdm
|
// * @param start
|
// * @param end
|
// */
|
// private void pushData1206(ApiParam param) {
|
//
|
// List<Api1206> items = api1206Rep.findPushData(param.getKqdm());
|
//
|
// if (null == items || items.isEmpty()) {
|
// return;
|
// }
|
//
|
// param.setInteCategory(Constant.API_CATEGORY_12);
|
// param.setInteId(Constant.API_CODE_1206);
|
//
|
//
|
// ResponseDto responseDto;
|
// Api1206 apiData;
|
// for (Api1206 data : items) {
|
// apiData = new Api1206();
|
// BeanUtils.copyProperties(data, apiData);
|
//
|
// param.setBizId(data.getBizId());
|
//
|
// responseDto = apiRemoteService.pushData(param, apiData);
|
//
|
// if (responseDto.getSuccess() == 0) {
|
// if (Constant.CZBZ_I.equals(apiData.getCzbz())) {
|
// api1206Rep.updateStatus(apiData.getCkjsdh(), Constant.CZBZ_U);
|
// }
|
// }
|
// }
|
// }
|
//
|
// /**
|
// * 1208
|
// *
|
// * @param kqdm
|
// * @param start
|
// * @param end
|
// */
|
// private void pushData1208(ApiParam param) {
|
//
|
// List<Api1208> items = api1208Rep.findPushData(param.getKqdm());
|
//
|
// if (null == items || items.isEmpty()) {
|
// return;
|
// }
|
//
|
// param.setInteCategory(Constant.API_CATEGORY_12);
|
// param.setInteId(Constant.API_CODE_1208);
|
//
|
//
|
// ResponseDto responseDto;
|
// Api1208 apiData;
|
// for (Api1208 data : items) {
|
// apiData = new Api1208();
|
// BeanUtils.copyProperties(data, apiData);
|
//
|
// param.setBizId(data.getBizId());
|
// responseDto = apiRemoteService.pushData(param, apiData);
|
//
|
// if (responseDto.getSuccess() == 0) {
|
// if (Constant.CZBZ_I.equals(apiData.getCzbz())) {
|
// api1208Rep.updateStatus(apiData.getId(), Constant.CZBZ_U);
|
// }
|
// }
|
// }
|
// }
|
//
|
// /**
|
// * 1209
|
// *
|
// * @param param
|
// */
|
// private void pushData1209(ApiParam param) {
|
//
|
// List<Api1209> items = api1209Rep.findPushData(param.getKqdm());
|
//
|
// if (null == items || items.isEmpty()) {
|
// return;
|
// }
|
//
|
// param.setInteCategory(Constant.API_CATEGORY_12);
|
// param.setInteId(Constant.API_CODE_1209);
|
//
|
// ResponseDto responseDto;
|
// Api1209 apiData;
|
// for (Api1209 data : items) {
|
// apiData = new Api1209();
|
// BeanUtils.copyProperties(data, apiData);
|
// param.setBizId(data.getBizId());
|
// responseDto = apiRemoteService.pushData(param, apiData);
|
//
|
// if (responseDto.getSuccess() == 0) {
|
// if (Constant.CZBZ_I.equals(apiData.getCzbz())) {
|
// api1209Rep.updateStatus(apiData.getSydh(), Constant.CZBZ_U);
|
// }
|
// }
|
// }
|
// }
|
|
|
}
|
