啊鑫
2025-04-15 8688b44b9e0c7403f6eca6180d30b38889d6e775
切换端口,暴露接口
已添加3个文件
已修改3个文件
135 ■■■■■ 文件已修改
src/main/java/com/gs/xiaomi/config/ResultMessage.java 39 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/gs/xiaomi/controller/KMController.java 35 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/gs/xiaomi/dto/NumbericalDto.java 16 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/gs/xiaomi/service/XM104Service.java 34 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/application.yml 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/test/java/com/gs/xiaomi/XiaomiApplicationTests.java 9 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/gs/xiaomi/config/ResultMessage.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,39 @@
package com.gs.xiaomi.config;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@AllArgsConstructor
@NoArgsConstructor
public class ResultMessage {
    private static final int SUCCESS = 200;
    private static final int ERROR = 500;
    private int code;
    private String message;
    private int successful;
    private String data;
    public static ResultMessage ok() {
        return new ResultMessage(SUCCESS, null, 0, "接收成功");
    }
    public static ResultMessage ok(String data) {
        return new ResultMessage(SUCCESS, null, 0, data);
    }
    public static ResultMessage error(Exception e) {
        return new ResultMessage(ERROR, e.getMessage(), 1, "接收失败");
    }
    public static ResultMessage error(String message) {
        return new ResultMessage(ERROR, message, 1, "接收失败");
    }
}
src/main/java/com/gs/xiaomi/controller/KMController.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,35 @@
package com.gs.xiaomi.controller;
import com.gs.xiaomi.config.ResultMessage;
import com.gs.xiaomi.dto.NumbericalDto;
import com.gs.xiaomi.service.XM104Service;
import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.*;
@RestController
@RequestMapping("Numerical")
@RequiredArgsConstructor
@CrossOrigin(origins = "*") //跨域请求
public class KMController {
    private final XM104Service xm104Service;
    @PostMapping("/manualSynByASN")
    public ResultMessage setCode(@RequestBody NumbericalDto barcode) {
        if (barcode.getAsn() == null) {
            return ResultMessage.error("ASN号为空");
        }
        try {
            if (!xm104Service.manualSynchronization(barcode)) {
                return ResultMessage.error("同步失败");
            }
            return ResultMessage.ok();
        } catch (Exception e) {
            return ResultMessage.error(e);
        }
    }
}
src/main/java/com/gs/xiaomi/dto/NumbericalDto.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,16 @@
package com.gs.xiaomi.dto;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@AllArgsConstructor
@NoArgsConstructor
public class NumbericalDto {
    private String asn;
    private String date;
}
src/main/java/com/gs/xiaomi/service/XM104Service.java
@@ -38,16 +38,25 @@
    private final LogisticsPackageService logisticsPackageService;
    public void getDb() {
        String format = DateUtil.format(new Date(), "yyyy-MM-dd");
        getXM104Save(format);
    }
    private void getXM104Save(String format) {
        BizDocument doc = new BizDocument();
        doc.setBizDate(format);
        doc.setLifnr(DataAcquisitionConfiguration.LIFNR);
        getXM104(doc);
    }
    private void getXM104(BizDocument doc) {
        ZfmWsApiRequest req = new ZfmWsApiRequest();
        req.setIvCode(DataAcquisitionConfiguration.IV_CODEXM104);
        req.setIvEvent("");
        req.setIvFlag("");
        BizDocument doc = new BizDocument();
        doc.setBizDate("2025-04-01");
        doc.setLifnr(DataAcquisitionConfiguration.LIFNR);
        req.setIvInfo(doc);
        req.setIvPass(DataAcquisitionConfiguration.getIvPass(DataAcquisitionConfiguration.IV_CODEXM104));
        req.setIvUser(DataAcquisitionConfiguration.IV_USER);
@@ -96,7 +105,6 @@
            log.error("【读取列表异常】参数: {} å¼‚常: {}", JSON.toJSONString(req), e.getMessage(), e);
            throw new RuntimeException(e);
        }
    }
    private BizDocumentResult getDeliveryNo(ZfmWsApiRequest request) throws Exception {
@@ -164,4 +172,20 @@
        });
    }
    public boolean manualSynchronization(NumbericalDto numbericalDto) {
        try {
            String[] asns = numbericalDto.getAsn().split(",");
            for (String asn : asns) {
                BizDocument doc = new BizDocument();
                doc.setLifnr(DataAcquisitionConfiguration.LIFNR);
                doc.setZzasn(asn);
                getXM104(doc);
            }
            return true;
        } catch (Exception e) {
            log.error("【手动读取ASN异常】 å¼‚常: {}", e.getMessage(), e);
            return false;
        }
    }
}
src/main/resources/application.yml
@@ -1,5 +1,5 @@
server:
  port: 9095
  port: 9096
spring:
  datasource:
src/test/java/com/gs/xiaomi/XiaomiApplicationTests.java
@@ -15,4 +15,13 @@
    void contextLoads() throws Exception {
        xm104Service.getDb();
    }
    @Test
    void test() {
        String str = ",,";
        String[] parts = str.split(",");
        for (String part : parts) {
            System.out.println(part);
        }
    }
}