package com.qlm.service; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.jfinal.kit.HttpKit; import com.jfinal.plugin.activerecord.ActiveRecordPlugin; import com.jfinal.plugin.activerecord.Db; import com.jfinal.plugin.activerecord.Record; import com.jfinal.plugin.druid.DruidPlugin; import com.qlm.log.Log; public class WmesService { private static void con(){ DruidPlugin dp = new DruidPlugin("jdbc:mysql://61.183.212.90:57911/jinzai?characterEncoding=utf8&zeroDateTimeBehavior=convertToNull", "root", "Qyy#2023.Wzh!"); ActiveRecordPlugin arp = new ActiveRecordPlugin(dp); // ��web����Ψһ�IJ�ͬ��Ҫ�ֶ�����һ����ز����start()���� dp.start(); arp.start(); } public static void main(String[] args) { con(); uploadData(); } public static void uploadData(){ List find = Db.find("select * from jinzai_upload_master where upload_time is null"); JSONObject bigData = new JSONObject(); JSONObject data = new JSONObject(); bigData.put("data", data); JSONArray header = new JSONArray(); data.put("header", header); StringBuilder sb = new StringBuilder(); for (Record record : find) { String task_no = record.getStr("task_no"); String id = record.getStr("id"); if(sb.length()>0){ sb.append(","); } sb.append("'"+id+"'"); String duo_code = record.getStr("duo_code"); String pinxiang = record.getStr("pinxiang"); Date guo_time = record.getDate("guo_time"); JSONObject obj1 = new JSONObject(); obj1.put("warehouseid", "JZPJ"); obj1.put("asnno", task_no);//工单号 obj1.put("serialno", id);//箱码 obj1.put("sku", pinxiang);//物料编码 obj1.put("traceId", duo_code);//托盘码 obj1.put("addtime", guo_time);//关联时间 obj1.put("udf06", "tm"); header.add(obj1); } Map headers = new HashMap<>(); headers.put("Content-Type","application/json"); try{ String post = HttpKit.post("http://58.20.133.135:18080/datahubjson/WMS_EM/?method=QRCODE&apptoken=BAB75C8B843F1C92AC3FFE3BD2A06A5F×tamp=2024-06-25%2015:59:16&sign=1&format=JSON", bigData.toString(),headers); Log.info(post); if(sb.length()>0){ Db.update("update jinzai_upload_master set upload_time = ? where id in ("+sb+")",new Date()); } Log.info("同步到wms成功"); }catch(Exception e){ e.printStackTrace(); } } }