| | |
| | | |
| | | import com.alibaba.fastjson.JSON; |
| | | import com.gs.xky.config.*; |
| | | import com.gs.xky.dto.BarcodeDeliveryNo; |
| | | import com.gs.xky.dto.EmployeeInfo; |
| | | import com.gs.xky.dto.XkyDetail; |
| | | import com.gs.xky.dto.XkyEntity; |
| | | import com.gs.xky.service.ApiService; |
| | | import com.gs.xky.entity.MesInvItemArn; |
| | | import com.gs.xky.service.*; |
| | | import org.junit.jupiter.api.Test; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.boot.test.context.SpringBootTest; |
| | | |
| | | import java.io.IOException; |
| | | import java.util.List; |
| | | import java.util.stream.Collectors; |
| | | |
| | | @SpringBootTest |
| | | class XkyApplicationTests { |
| | | |
| | | |
| | | @Autowired |
| | | private ApiService apiService; |
| | | private VwCjScSjTsBbService vwCjScSjTsBbService; |
| | | |
| | | /** |
| | | * 测试导出生产数据并发送钉钉消息 |
| | | * 功能:查询VW_CJ_SC_SJ_TS_BB表数据 -> 导出Excel -> 发送钉钉文件消息 |
| | | */ |
| | | @Test |
| | | void contextLoads() throws IOException { |
| | | void testExportAndSendProductionData() throws Exception { |
| | | System.out.println("=== 开始测试导出生产数据并发送钉钉 ==="); |
| | | |
| | | long currentTimeMillis = System.currentTimeMillis(); |
| | | // try { |
| | | // boolean result = vwCjScSjTsBbService.exportAndSendToDingtalk(); |
| | | // |
| | | // if (result) { |
| | | // System.out.println("✓ 生产数据导出并发送成功"); |
| | | // System.out.println(" - 数据已从 VW_CJ_SC_SJ_TS_BB 表查询"); |
| | | // System.out.println(" - Excel 文件已生成并保存到 D:\\BIFile\\"); |
| | | // System.out.println(" - 钉钉文件消息已发送"); |
| | | // } else { |
| | | // System.out.println("✗ 生产数据导出或发送失败"); |
| | | // } |
| | | // } catch (Exception e) { |
| | | // System.out.println("✗ 导出并发送时发生异常: " + e.getMessage()); |
| | | // e.printStackTrace(); |
| | | // } |
| | | |
| | | ApiCommonParam apiParam = new ApiCommonParam(); |
| | | apiParam.setAppKey(DataAcquisitionConfiguration.TEST_APP_KEY);//发携客云提供的appKey |
| | | apiParam.setVersion("1.0");//接口版本 |
| | | apiParam.setOperateCompanyCode(DataAcquisitionConfiguration.TEST_COMPANY_CODE);//操作者所属公司编码 |
| | | apiParam.setOwnerCompanyCode(DataAcquisitionConfiguration.TEST_COMPANY_CODE);//数据所属公司编码,非集团公司默认赋值为操作公司 |
| | | apiParam.setTimestamps(currentTimeMillis / 1000);//当前时间对应的时间戳(秒数) |
| | | |
| | | String appSecret = DataAcquisitionConfiguration.TEST_APP_SECRET;//携客云提供的appSecret |
| | | |
| | | String sign = SignUtils.buildCurrentSign(JSON.toJSONString(apiParam), appSecret); |
| | | apiParam.setSign(sign); |
| | | |
| | | |
| | | // 计算五分钟前的时间戳 |
| | | long startDate = currentTimeMillis - (65 * 60 * 1000); // 5 分钟 = 5 * 60 * 1000 毫秒 |
| | | |
| | | // 创建 BodyParam 对象并赋值 |
| | | BodyParam bodyParam = new BodyParam(); |
| | | bodyParam.setStartDate(startDate); |
| | | bodyParam.setEndDate(currentTimeMillis); |
| | | bodyParam.setErpCode("Z106"); |
| | | bodyParam.setStatus(new int[]{1}); |
| | | bodyParam.setLogisticsStatus(2); |
| | | |
| | | XkyCommonParam param = new XkyCommonParam(); |
| | | param.setCommonParam(apiParam); |
| | | param.setBody(bodyParam); |
| | | |
| | | |
| | | ApiResponse<XkyEntity> xkyEntityApiResponse = apiService.sendListRequest(param, XkyEntity.class, "https://openapi.xiekeyun.com/delivery/getNoList.json"); |
| | | |
| | | System.out.println(JSON.toJSONString(xkyEntityApiResponse)); |
| | | System.out.println("=== 测试结束 ==="); |
| | | } |
| | | |
| | | } |
| | | } |