jiazx0107@163.com
2023-12-05 ebaaa34038ebda73630c9ab82465c5f76692b5c2
src/main/java/com/fzzy/push/impl/ComPushService12.java
@@ -8,7 +8,6 @@
import com.fzzy.api.view.repository.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
/**
@@ -47,7 +46,7 @@
     */
    public void pushData1109(ApiRemoteService apiRemoteService, ApiParam param) {
        List<Api1109> items = api1109Rep.findPushData(param.getKqdm());
        List<Api1109> items = api1109Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
        if (null == items || items.isEmpty()) {
            return;
@@ -76,7 +75,8 @@
     * @param param
     */
    public void pushData1201(ApiRemoteService apiRemoteService, ApiParam param) {
        List<Api1201> items = api1201Rep.findPushData(param.getKqdm());
        //根据库区编码、更新时间查询合同信息
        List<Api1201> items = api1201Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
        if (null == items || items.isEmpty()) {
            return;
@@ -105,7 +105,7 @@
     * @param param
     */
    public void pushData1202(ApiRemoteService apiRemoteService, ApiParam param) {
        List<Api1202> items = api1202Rep.findPushData(param.getKqdm());
        List<Api1202> items = api1202Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
        if (null == items || items.isEmpty()) {
            return;
        }
@@ -119,7 +119,7 @@
            if (responseDto.getSuccess() == 0) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {
                    api1202Rep.updateStatus(data.getId(), Constant.CZBZ_U);
                    api1202Rep.updateStatus(data.getRkywdh(), Constant.CZBZ_U);
                }
            }
        }
@@ -131,7 +131,7 @@
     * @param param
     */
    public void pushData1203(ApiRemoteService apiRemoteService, ApiParam param) {
        List<Api1203> items = api1203Rep.findPushData(param.getKqdm());
        List<Api1203> items = api1203Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
        if (null == items || items.isEmpty()) {
            return;
@@ -147,7 +147,7 @@
            if (responseDto.getSuccess() == 0) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {
                    api1203Rep.updateStatus(data.getBizId(), Constant.CZBZ_U);
                    api1203Rep.updateStatus(data.getRkjydh(), Constant.CZBZ_U);
                }
            }
        }
@@ -159,7 +159,7 @@
     * @param param
     */
    public void pushData1204(ApiRemoteService apiRemoteService, ApiParam param) {
        List<Api1204> items = api1204Rep.findPushData(param.getKqdm());
        List<Api1204> items = api1204Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
        if (null == items || items.isEmpty()) {
            return;
@@ -187,7 +187,7 @@
     * @param param
     */
    public void pushData1205(ApiRemoteService apiRemoteService, ApiParam param) {
        List<Api1205> items = api1205Rep.findPushData(param.getKqdm());
        List<Api1205> items = api1205Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
        if (null == items || items.isEmpty()) {
            return;
@@ -204,7 +204,7 @@
            if (responseDto.getSuccess() == 0) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {
                    api1205Rep.updateStatus(data.getId(), Constant.CZBZ_U);
                    api1205Rep.updateStatus(data.getCkywdh(), Constant.CZBZ_U);
                }
            }
        }
@@ -216,7 +216,7 @@
     * @param param
     */
    public void pushData1206(ApiRemoteService apiRemoteService, ApiParam param) {
        List<Api1206> items = api1206Rep.findPushData(param.getKqdm());
        List<Api1206> items = api1206Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
        if (null == items || items.isEmpty()) {
            return;
@@ -244,7 +244,7 @@
     * @param param
     */
    public void pushData1207(ApiRemoteService apiRemoteService, ApiParam param) {
        List<Api1207> items = api1207Rep.findPushData(param.getKqdm());
        List<Api1207> items = api1207Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
        if (null == items || items.isEmpty()) {
            return;
@@ -276,7 +276,7 @@
    public void pushData1208(ApiRemoteService apiRemoteService, ApiParam param) {
        //获取数据
        List<Api1208> items = api1208Rep.findPushData(param.getKqdm());
        List<Api1208> items = api1208Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
        if (null == items || items.isEmpty()) {
            return;
@@ -305,7 +305,7 @@
     * @param param
     */
    public void pushData1209(ApiRemoteService apiRemoteService, ApiParam param) {
        List<Api1209> items = api1209Rep.findPushData(param.getKqdm());
        List<Api1209> items = api1209Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
        if (null == items || items.isEmpty()) {
            return;
        }
@@ -332,7 +332,7 @@
     * @param param
     */
    public void pushData1210(ApiRemoteService apiRemoteService, ApiParam param) {
        List<Api1210> items = api1210Rep.findPushData(param.getKqdm());
        List<Api1210> items = api1210Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
        if (null == items || items.isEmpty()) {
            return;