| | |
|---|
| | | import com.fzzy.api.Constant; |
|---|
| | | import com.fzzy.api.data.ApiParam; |
|---|
| | | import com.fzzy.api.dto.ResponseDto; |
|---|
| | | import com.fzzy.api.entity.Api1101; |
|---|
| | | import com.fzzy.api.entity.Api1111; |
|---|
| | | import com.fzzy.api.entity.*; |
|---|
| | | import com.fzzy.api.service.ApiRemoteService; |
|---|
| | | import com.fzzy.api.view.repository.Api1101Rep; |
|---|
| | | import com.fzzy.api.view.repository.Api1111Rep; |
|---|
| | | import com.fzzy.api.view.repository.*; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | | |
|---|
| | |
|---|
| | | * @author: andy.jia |
|---|
| | | * @update-time: 2022/10/28 2:02 |
|---|
| | | */ |
|---|
| | | @Slf4j |
|---|
| | | @Service |
|---|
| | | public class ComPushService11 { |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private Api1101Rep api1101Rep; |
|---|
| | | @Autowired |
|---|
| | | private Api1102Rep api1102Rep; |
|---|
| | | @Autowired |
|---|
| | | private Api1103Rep api1103Rep; |
|---|
| | | @Autowired |
|---|
| | | private Api1104Rep api1104Rep; |
|---|
| | | @Autowired |
|---|
| | | private Api1105Rep api1105Rep; |
|---|
| | | @Autowired |
|---|
| | | private Api1106Rep api1106Rep; |
|---|
| | | @Autowired |
|---|
| | | private Api1107Rep api1107Rep; |
|---|
| | | @Autowired |
|---|
| | | private Api1108Rep api1108Rep; |
|---|
| | | @Autowired |
|---|
| | | private Api1110Rep api1110Rep; |
|---|
| | | @Autowired |
|---|
| | | private Api1111Rep api1111Rep; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private Api1112Rep api1112Rep; |
|---|
| | | @Autowired |
|---|
| | | private Api1113Rep api1113Rep; |
|---|
| | | @Autowired |
|---|
| | | private Api1501Rep api1501Rep; |
|---|
| | | @Autowired |
|---|
| | | private Api1502Rep api1502Rep; |
|---|
| | | @Autowired |
|---|
| | | private Api1503Rep api1503Rep; |
|---|
| | | /** |
|---|
| | | * 1101 单位信息 |
|---|
| | | */ |
|---|
| | | public void pushData1101(ApiRemoteService apiRemoteService, ApiParam param) { |
|---|
| | | |
|---|
| | | List<Api1101> items = api1101Rep.findPushData(param.getKqdm()); |
|---|
| | | List<Api1101> items = api1101Rep.getDataByTime(param.getKqdm(), param.getStart(), param.getEnd()); |
|---|
| | | if (null == items || items.isEmpty()) { |
|---|
| | | log.error("-----未获取到单位信息，不推送-----"); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | param.setInteCategory(Constant.API_CATEGORY_11); |
|---|
| | | param.setInteId(Constant.API_CODE_1111); |
|---|
| | | param.setInteId(Constant.API_CODE_1101); |
|---|
| | | |
|---|
| | | ResponseDto responseDto; |
|---|
| | | for (Api1101 data : items) { |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 1102 库区信息 |
|---|
| | | */ |
|---|
| | | public void pushData1102(ApiRemoteService apiRemoteService, ApiParam param) { |
|---|
| | | |
|---|
| | | List<Api1102> items = api1102Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd()); |
|---|
| | | if (null == items || items.isEmpty()) { |
|---|
| | | log.error("-----未获取到库区信息，不推送-----"); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | param.setInteCategory(Constant.API_CATEGORY_11); |
|---|
| | | param.setInteId(Constant.API_CODE_1102); |
|---|
| | | |
|---|
| | | ResponseDto responseDto; |
|---|
| | | for (Api1102 data : items) { |
|---|
| | | param.setBizId(data.getBizId()); |
|---|
| | | responseDto = apiRemoteService.pushData(param, data); |
|---|
| | | |
|---|
| | | if (responseDto.getSuccess() == 0) { |
|---|
| | | if (Constant.CZBZ_I.equals(data.getCzbz())) { |
|---|
| | | api1102Rep.updateStatus(data.getDwdm(), Constant.CZBZ_U); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 1103 仓房信息 |
|---|
| | | */ |
|---|
| | | public void pushData1103(ApiRemoteService apiRemoteService, ApiParam param) { |
|---|
| | | |
|---|
| | | List<Api1103> items = api1103Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd()); |
|---|
| | | if (null == items || items.isEmpty()) { |
|---|
| | | log.error("-----未获取到仓房信息，不推送-----"); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | param.setInteCategory(Constant.API_CATEGORY_11); |
|---|
| | | param.setInteId(Constant.API_CODE_1103); |
|---|
| | | |
|---|
| | | ResponseDto responseDto; |
|---|
| | | for (Api1103 data : items) { |
|---|
| | | param.setBizId(data.getBizId()); |
|---|
| | | responseDto = apiRemoteService.pushData(param, data); |
|---|
| | | |
|---|
| | | if (responseDto.getSuccess() == 0) { |
|---|
| | | if (Constant.CZBZ_I.equals(data.getCzbz())) { |
|---|
| | | api1103Rep.updateStatus(data.getCfdm(), Constant.CZBZ_U); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 1104 廒间信息 |
|---|
| | | */ |
|---|
| | | public void pushData1104(ApiRemoteService apiRemoteService, ApiParam param) { |
|---|
| | | |
|---|
| | | List<Api1104> items = api1104Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd()); |
|---|
| | | if (null == items || items.isEmpty()) { |
|---|
| | | log.error("-----未获取到廒间信息，不推送-----"); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | param.setInteCategory(Constant.API_CATEGORY_11); |
|---|
| | | param.setInteId(Constant.API_CODE_1104); |
|---|
| | | |
|---|
| | | ResponseDto responseDto; |
|---|
| | | for (Api1104 data : items) { |
|---|
| | | param.setBizId(data.getBizId()); |
|---|
| | | responseDto = apiRemoteService.pushData(param, data); |
|---|
| | | |
|---|
| | | if (responseDto.getSuccess() == 0) { |
|---|
| | | if (Constant.CZBZ_I.equals(data.getCzbz())) { |
|---|
| | | api1104Rep.updateStatus(data.getAjdh(), Constant.CZBZ_U); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 1105 货位信息 |
|---|
| | | */ |
|---|
| | | public void pushData1105(ApiRemoteService apiRemoteService, ApiParam param) { |
|---|
| | | |
|---|
| | | List<Api1105> items = api1105Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd()); |
|---|
| | | if (null == items || items.isEmpty()) { |
|---|
| | | log.error("-----未获取到货位信息，不推送-----"); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | param.setInteCategory(Constant.API_CATEGORY_11); |
|---|
| | | param.setInteId(Constant.API_CODE_1105); |
|---|
| | | |
|---|
| | | ResponseDto responseDto; |
|---|
| | | for (Api1105 data : items) { |
|---|
| | | param.setBizId(data.getBizId()); |
|---|
| | | responseDto = apiRemoteService.pushData(param, data); |
|---|
| | | |
|---|
| | | if (responseDto.getSuccess() == 0) { |
|---|
| | | if (Constant.CZBZ_I.equals(data.getCzbz())) { |
|---|
| | | api1105Rep.updateStatus(data.getHwdm(), Constant.CZBZ_U); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 1106 油罐信息 |
|---|
| | | */ |
|---|
| | | public void pushData1106(ApiRemoteService apiRemoteService, ApiParam param) { |
|---|
| | | |
|---|
| | | List<Api1106> items = api1106Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd()); |
|---|
| | | if (null == items || items.isEmpty()) { |
|---|
| | | log.error("-----未获取到油罐信息，不推送-----"); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | param.setInteCategory(Constant.API_CATEGORY_11); |
|---|
| | | param.setInteId(Constant.API_CODE_1106); |
|---|
| | | |
|---|
| | | ResponseDto responseDto; |
|---|
| | | for (Api1106 data : items) { |
|---|
| | | param.setBizId(data.getBizId()); |
|---|
| | | responseDto = apiRemoteService.pushData(param, data); |
|---|
| | | |
|---|
| | | if (responseDto.getSuccess() == 0) { |
|---|
| | | if (Constant.CZBZ_I.equals(data.getCzbz())) { |
|---|
| | | api1106Rep.updateStatus(data.getYgdm(), Constant.CZBZ_U); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 1107 设备信息 |
|---|
| | | */ |
|---|
| | | public void pushData1107(ApiRemoteService apiRemoteService, ApiParam param) { |
|---|
| | | |
|---|
| | | List<Api1107> items = api1107Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd()); |
|---|
| | | if (null == items || items.isEmpty()) { |
|---|
| | | log.error("-----未获取到设备信息，不推送-----"); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | param.setInteCategory(Constant.API_CATEGORY_11); |
|---|
| | | param.setInteId(Constant.API_CODE_1107); |
|---|
| | | |
|---|
| | | ResponseDto responseDto; |
|---|
| | | for (Api1107 data : items) { |
|---|
| | | param.setBizId(data.getBizId()); |
|---|
| | | responseDto = apiRemoteService.pushData(param, data); |
|---|
| | | |
|---|
| | | if (responseDto.getSuccess() == 0) { |
|---|
| | | if (Constant.CZBZ_I.equals(data.getCzbz())) { |
|---|
| | | api1107Rep.updateStatus(data.getSbbh(), Constant.CZBZ_U); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 1108 药剂信息 |
|---|
| | | */ |
|---|
| | | public void pushData1108(ApiRemoteService apiRemoteService, ApiParam param) { |
|---|
| | | |
|---|
| | | List<Api1108> items = api1108Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd()); |
|---|
| | | if (null == items || items.isEmpty()) { |
|---|
| | | log.error("-----未获取到药剂信息，不推送-----"); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | param.setInteCategory(Constant.API_CATEGORY_11); |
|---|
| | | param.setInteId(Constant.API_CODE_1108); |
|---|
| | | |
|---|
| | | ResponseDto responseDto; |
|---|
| | | for (Api1108 data : items) { |
|---|
| | | param.setBizId(data.getBizId()); |
|---|
| | | responseDto = apiRemoteService.pushData(param, data); |
|---|
| | | |
|---|
| | | if (responseDto.getSuccess() == 0) { |
|---|
| | | if (Constant.CZBZ_I.equals(data.getCzbz())) { |
|---|
| | | api1108Rep.updateStatus(data.getId(), Constant.CZBZ_U); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 1110 库区图仓房点位信息 |
|---|
| | | */ |
|---|
| | | public void pushData1110(ApiRemoteService apiRemoteService, ApiParam param) { |
|---|
| | | |
|---|
| | | List<Api1110> items = api1110Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd()); |
|---|
| | | if (null == items || items.isEmpty()) { |
|---|
| | | log.error("-----未获取到库区图仓房点位标注，不推送-----"); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | param.setInteCategory(Constant.API_CATEGORY_11); |
|---|
| | | param.setInteId(Constant.API_CODE_1110); |
|---|
| | | |
|---|
| | | ResponseDto responseDto; |
|---|
| | | for (Api1110 data : items) { |
|---|
| | | param.setBizId(data.getBizId()); |
|---|
| | | responseDto = apiRemoteService.pushData(param, data); |
|---|
| | | |
|---|
| | | if (responseDto.getSuccess() == 0) { |
|---|
| | | if (Constant.CZBZ_I.equals(data.getCzbz())) { |
|---|
| | | api1110Rep.updateStatus(data.getHwdm(), Constant.CZBZ_U); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 1111 库区图视频监控设备点位标注 |
|---|
| | | */ |
|---|
| | | public void pushData1111(ApiRemoteService apiRemoteService, ApiParam param) { |
|---|
| | | |
|---|
| | | List<Api1111> items = api1111Rep.findPushData(param.getKqdm()); |
|---|
| | | List<Api1111> items = api1111Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd()); |
|---|
| | | if (null == items || items.isEmpty()) { |
|---|
| | | log.error("-----未获取到库区图视频监控设备点位标注，不推送-----"); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 1112 人员信息 |
|---|
| | | * |
|---|
| | | */ |
|---|
| | | public void pushData1112(ApiRemoteService apiRemoteService, ApiParam param) { |
|---|
| | | |
|---|
| | | List<Api1112> items = api1112Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd()); |
|---|
| | | if (null == items || items.isEmpty()) { |
|---|
| | | log.error("-----未获取到人员信息，不推送-----"); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | param.setInteCategory(Constant.API_CATEGORY_11); |
|---|
| | | param.setInteId(Constant.API_CODE_1112); |
|---|
| | | |
|---|
| | | ResponseDto responseDto; |
|---|
| | | for (Api1112 data : items) { |
|---|
| | | param.setBizId(data.getBizId()); |
|---|
| | | responseDto = apiRemoteService.pushData(param, data); |
|---|
| | | |
|---|
| | | if (responseDto.getSuccess() == 0) { |
|---|
| | | if (Constant.CZBZ_I.equals(data.getCzbz())) { |
|---|
| | | api1112Rep.updateStatus(data.getSfzhm(), Constant.CZBZ_U); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 1113 企业信用信息 |
|---|
| | | * |
|---|
| | | */ |
|---|
| | | public void pushData1113(ApiRemoteService apiRemoteService, ApiParam param) { |
|---|
| | | |
|---|
| | | List<Api1113> items = api1113Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd()); |
|---|
| | | if (null == items || items.isEmpty()) { |
|---|
| | | log.error("-----未获取到企业信用信息，不推送-----"); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | param.setInteCategory(Constant.API_CATEGORY_11); |
|---|
| | | param.setInteId(Constant.API_CODE_1113); |
|---|
| | | |
|---|
| | | ResponseDto responseDto; |
|---|
| | | for (Api1113 data : items) { |
|---|
| | | param.setBizId(data.getBizId()); |
|---|
| | | responseDto = apiRemoteService.pushData(param, data); |
|---|
| | | |
|---|
| | | if (responseDto.getSuccess() == 0) { |
|---|
| | | if (Constant.CZBZ_I.equals(data.getCzbz())) { |
|---|
| | | data.setCzbz("u"); |
|---|
| | | api1113Rep.save(data); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 财务报表 |
|---|
| | | * @param apiRemoteService |
|---|
| | | * @param param |
|---|
| | | */ |
|---|
| | | public void pushData1114(ApiRemoteService apiRemoteService, ApiParam param) { |
|---|
| | | this.pushData1501(apiRemoteService, param); |
|---|
| | | this.pushData1502(apiRemoteService, param); |
|---|
| | | this.pushData1503(apiRemoteService, param); |
|---|
| | | |
|---|
| | | } |
|---|
| | | /** |
|---|
| | | * 1501 财务报表-资产负债--单条上传 |
|---|
| | | */ |
|---|
| | | public void pushData1501(ApiRemoteService apiRemoteService, ApiParam param) { |
|---|
| | | //获取财务报表-资产负债 |
|---|
| | | List<Api1501> list = api1501Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd()); |
|---|
| | | |
|---|
| | | if (null == list || list.isEmpty()) { |
|---|
| | | log.error("-----未获取到资产负债信息，不推送-----"); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | param.setInteCategory(Constant.API_CATEGORY_11); |
|---|
| | | param.setInteId(Constant.API_CODE_1114_1501); |
|---|
| | | ResponseDto responseDto; |
|---|
| | | for (Api1501 data : list) { |
|---|
| | | responseDto = apiRemoteService.pushData(param, data); |
|---|
| | | if (responseDto.getSuccess() == 0) { |
|---|
| | | if (Constant.CZBZ_I.equals(data.getCzbz())) { |
|---|
| | | |
|---|
| | | data.setCzbz(Constant.CZBZ_U); |
|---|
| | | //更新状态 |
|---|
| | | api1501Rep.save(data); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 1502 财务报表-现金流 |
|---|
| | | */ |
|---|
| | | public void pushData1502(ApiRemoteService apiRemoteService, ApiParam param) { |
|---|
| | | //获取财务报表-资产负债 |
|---|
| | | List<Api1502> list = api1502Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd()); |
|---|
| | | |
|---|
| | | if (null == list || list.isEmpty()) { |
|---|
| | | log.error("-----未获取到现金流信息，不推送-----"); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | param.setInteCategory(Constant.API_CATEGORY_11); |
|---|
| | | param.setInteId(Constant.API_CODE_1114_1502); |
|---|
| | | ResponseDto responseDto; |
|---|
| | | for (Api1502 data : list) { |
|---|
| | | responseDto = apiRemoteService.pushData(param, data); |
|---|
| | | if (responseDto.getSuccess() == 0) { |
|---|
| | | if (Constant.CZBZ_I.equals(data.getCzbz())) { |
|---|
| | | |
|---|
| | | data.setCzbz(Constant.CZBZ_U); |
|---|
| | | //更新状态 |
|---|
| | | api1502Rep.save(data); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 1503 财务报表-利润信息 |
|---|
| | | */ |
|---|
| | | public void pushData1503(ApiRemoteService apiRemoteService, ApiParam param) { |
|---|
| | | //获取财务报表-资产负债 |
|---|
| | | List<Api1503> list = api1503Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd()); |
|---|
| | | |
|---|
| | | if (null == list || list.isEmpty()) { |
|---|
| | | log.error("-----未获取到利润信息，不推送-----"); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | param.setInteCategory(Constant.API_CATEGORY_11); |
|---|
| | | param.setInteId(Constant.API_CODE_1114_1503); |
|---|
| | | ResponseDto responseDto; |
|---|
| | | Api1503 d; |
|---|
| | | for (Api1503 data : list) { |
|---|
| | | responseDto = apiRemoteService.pushData(param, data); |
|---|
| | | if (responseDto.getSuccess() == 0) { |
|---|
| | | if (Constant.CZBZ_I.equals(data.getCzbz())) { |
|---|
| | | |
|---|
| | | data.setCzbz(Constant.CZBZ_U); |
|---|
| | | //更新状态 |
|---|
| | | api1503Rep.save(data); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
