src/main/java/com/fzzy/async/whhpjl/Fzzy40ToWhjlSyncService12.java
@@ -6,6 +6,7 @@ import com.fzzy.api.service.SyncService12; import com.fzzy.async.whhpjl.impl.Fz40ToWhjlSync1204; import com.fzzy.async.whhpjl.impl.Fz40ToWhjlSync1207; import com.fzzy.async.whhpjl.impl.Fz40ToWhjlSync1212; import com.fzzy.async.whhpjl.impl.Fz40ToWhjlSync1214; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; @@ -28,6 +29,8 @@ private Fz40ToWhjlSync1207 fz40ToWhjlSync1207; @Autowired private Fz40ToWhjlSync1214 fz40ToWhjlSync1214; @Autowired private Fz40ToWhjlSync1212 fz40ToWhjlSync1212; @Override @@ -43,18 +46,19 @@ Date start = param.getStart(); Date end = param.getEnd(); // 忥客æ·ä¿¡æ¯ fz40ToWhjlSync1204.syncData(kqdm, deptId, start, end); // 忥ååä¿¡æ¯ fz40ToWhjlSync1207.syncData(kqdm, deptId, start, end); // // 忥客æ·ä¿¡æ¯ // fz40ToWhjlSync1204.syncData(kqdm, deptId, start, end); // // 忥ååä¿¡æ¯ // fz40ToWhjlSync1207.syncData(kqdm, deptId, start, end); //TODO 忥åºåå°è´¦ä¿¡æ¯ //TODO 忥åºåå°è´¦äº§åæ¹æ¬¡ä¿¡æ¯ //TODO 忥åºåå°è´¦åºå ¥ä¿¡æ¯ //忥åºå ¥åºè®°å½ fz40ToWhjlSync1212.syncData(kqdm, deptId, start, end); // 忥åºå ¥åºè®°å½ fz40ToWhjlSync1214.syncData(kqdm, deptId, start, end); // // 忥åºå ¥åºè®°å½ // fz40ToWhjlSync1214.syncData(kqdm, deptId, start, end); } } src/main/java/com/fzzy/async/whhpjl/entity/Fz40WhjlInoutRecord.java
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,289 @@ package com.fzzy.async.whhpjl.entity; import com.bstek.dorado.annotation.PropertyDef; import lombok.Data; import javax.persistence.Column; import javax.persistence.Entity; import javax.persistence.Id; import javax.persistence.Table; import java.io.Serializable; import java.util.Date; /** * åºå ¥åºç®¡ç * * @Author:YAN */ @Data @Entity @Table(name = "D_INOUT_RECORD") public class Fz40WhjlInoutRecord implements Serializable { private static final long serialVersionUID = 1L; @Id @Column(name = "ID_", length = 40) @PropertyDef(label = "æµæ°´å·", description = "æ ¹æ®ä¸å®çè§åçæ") private String id; @Column(name = "COMPANY_ID_", length = 10) @PropertyDef(label = "ç»ç»ç¼ç ") private String companyId; @Column(name = "DEPT_ID_", length = 50) @PropertyDef(label = "åºåºç¼ç ") private String deptId; @Column(name = "NOTICE_ID_", length = 40) @PropertyDef(label = "éç¥åç¼ç ") private String noticeId; @Column(name = "DEPOT_ID_", length = 50) @PropertyDef(label = "è£ å¸ä»åº") private String depotId; @Column(name = "TYPE_", length = 10) @PropertyDef(label = "åºå ¥åºç±»å", description = "IN=å ¥åºï¼OUT=åºåº") private String type; @Column(name = "PROGRESS_", length = 20) @PropertyDef(label = "æµç¨è¿åº¦") private String progress; @Column(name = "RECORD_STATUS_", length = 10) @PropertyDef(label = "æ°æ®ç¶æ", description = "æ°æ®ç¶æï¼æ£å¸¸ï¼å¼å¸¸ï¼2å°æ¶å éå¤åºå ¥åºçï¼ï¼è¡¥å½") private String recordStatus; @Column(name = "CUSTOMER_NAME_", length = 50) @PropertyDef(label = "徿¥åä½", description = "å ³èéç¥åè·å") private String customerName; @Column(name = "INTEL_CARD_", length = 20) @PropertyDef(label = "æºæ §å¡å·") private String intelCard; /*** ------------------------ç»è®°-------------------------------------**/ @Column(name = "REGISTER_TIME_") @PropertyDef(label = "ç»è®°æ¶é´") private Date registerTime; @Column(name = "REGISTER_USER_", length = 50) @PropertyDef(label = "ç»è®°äºº") private String registerUser; @Column(name = "USER_NAME_", length = 40) @PropertyDef(label = "æ¿è¿äºº") private String userName; @Column(name = "USER_CONTACT_", length = 20) @PropertyDef(label = "èç³»æ¹å¼") private String userContact; @Column(name = "USER_ID_", length = 20) @PropertyDef(label = "身份è¯å·") private String userId; @Column(name = "USER_ADDRESS_", length = 100) @PropertyDef(label = "æ¿è¿äººå°å") private String userAddress; @Column(name = "USER_BIRTHDAY_") @PropertyDef(label = "åºçæ¥æ") private Date userBirthday; @Column(name = "USER_SEX_", length = 10) @PropertyDef(label = "æ§å«") private String userSex; @Column(name = "USER_NATION_", length = 10) @PropertyDef(label = "æ°æ") private String userNation; @Column(name = "PLATE_NUM_", length = 20) @PropertyDef(label = "车è¹å·", description = "车çå·+æ è¯ç¬¦") private String plateNum; @Column(name = "TRANS_TYPE_", length = 6) @PropertyDef(label = "è¿è¾å·¥å ·") private String transType; /*** ------------------------ç²®é£åºç¡ä¿¡æ¯-------------------------------------**/ @Column(name = "FOOD_VARIETY_", length = 20) @PropertyDef(label = "ç²®é£åç§") private String foodVariety; @Column(name = "FOOD_TYPE_", length = 20) @PropertyDef(label = "ç²®é£æ§è´¨") private String foodType; @Column(name = "FOOD_LOCATION_ID_", length = 20) @PropertyDef(label = "产å°å称代ç ") private String foodLocationId; @Column(name = "FOOD_LOCATION_", length = 40) @PropertyDef(label = "产å°åç§°") private String foodLocation; @Column(name = "FOOD_YEAR_", length = 10) @PropertyDef(label = "æ¶è´§å¹´åº¦") private String foodYear; /*** ------------------------æ¦æ ·è´¨æ£ä¿¡æ¯-------------------------------------**/ @Column(name = "FOOD_LEVEL_", length = 20) @PropertyDef(label = "ç²®é£å®ç") private String foodLevel; @Column(name = "CHECK_STATUS_", length = 10) @PropertyDef(label = "è´¨æ£ç»æ") private String checkStatus; @Column(name = "CHECK_USER_", length = 50) @PropertyDef(label = "è´¨æ£äºº") private String checkUser; @Column(name = "CHECK_TIME_") @PropertyDef(label = "è´¨æ£æ¶é´") private Date checkTime; @Column(name = "SAMPLE_USER_", length = 50) @PropertyDef(label = "æ¦æ ·äºº") private String sampleUser; @Column(name = "SAMPLE_TIME_") @PropertyDef(label = "æ¦æ ·æ¶é´") private Date sampleTime; @Column(name = "SAMPLE_TYPE_", length = 1) @PropertyDef(label = "æ¦æ ·æ¹å¼", description = "0-人工ï¼1=èªå¨ï¼2=æºè½éæº") private String sampleType; @Column(name = "CHECK_ID_", length = 12) @PropertyDef(label = "è´¨æ£åå·") private String checkId; @Column(name = "DE_CHECK_") @PropertyDef(label = "è´¨æ£æ£é", description = "åä½KG") private double deCheck = 0.0; @Column(name = "ADD_CHECK_") @PropertyDef(label = "è´¨æ£å¢é", description = "åä½KG") private double addCheck = 0.0; /*** ------------------------ç§°éç¯è-------------------------------------**/ @Column(name = "jjlx", length = 2) @PropertyDef(label = "æ£æ¤ç±»å", description = "0ï¼ç§°éå ¥åº 1ï¼æ åå å ¥åº é»è®¤ä¸ºç§°éå ¥åºï¼æ åå å ¥åºç¸å ³å段å¯ä¸ºç©º") private String jjlx = "1"; @Column(name = "FULL_WEIGHT_") @PropertyDef(label = "满车称é", description = "å ¥åºæ¶åè¡¨ç¤ºç¬¬ä¸æ¬¡ç§°éï¼åºåºæ¶åè¡¨ç¤ºç¬¬äºæ¬¡ç§°éï¼åä½KG") private Double fullWeight = 0.0; @Column(name = "FULL_WEIGHT_TIME_") @PropertyDef(label = "æ»¡è½¦ç§°éæ¶é´") private Date fullWeightTime; @Column(name = "FULL_WEIGHT_USER_", length = 40) @PropertyDef(label = "满车称é人") private String fullWeightUser; @Column(name = "EMPTY_WEIGHT_") @PropertyDef(label = "空车称é", description = "å ¥åºæ¶è¡¨ç¤ºç¬¬äºæ¬¡ç§°éï¼åºåºæ¶åè¡¨ç¤ºç¬¬ä¸æ¬¡ç§°éï¼åä½KG") private Double emptyWeight = 0.0; @Column(name = "EMPTY_WEIGHT_TIME_") @PropertyDef(label = "ç©ºè½¦ç§°éæ¶é´") private Date emptyWeightTime; @Column(name = "EMPTY_WEIGHT_USER_", length = 50) @PropertyDef(label = "空车称é人") private String emptyWeightUser; @Column(name = "NET_WEIGHT_") @PropertyDef(label = "忝é", description = "åä½KGï¼çäºæ»¡è½¦ - 空车") private double netWeight = 0.0; @Column(name = "DE_HANDLE_") @PropertyDef(label = "ç°åºæ£é", description = "åä½KG") private double deHandle = 0.0; @Column(name = "DE_PACKAGE_") @PropertyDef(label = "å è£ æ£é", description = "åä½KG") private double dePackage = 0.0; @Column(name = "DE_OTHER_") @PropertyDef(label = "å ¶ä»æ£é", description = "åä½KG") private double deOther = 0.0; @Column(name = "DE_OTHER_INTO_", length = 200) @PropertyDef(label = "å ¶ä»æ£éåå ") private String deOtherInfo; @Column(name = "SETTLE_WEIGHT_") @PropertyDef(label = "ç»ç®éé", description = "æ£éååéï¼ç»ç®åéï¼åä½KG") private Double settleWeight = 0.0; @Column(name = "RECORD_WEIGHT_") @PropertyDef(label = "å ¥åºéé", description = "æ£éååéï¼ç»ç®åéï¼è¡¥å æ¬å¢éï¼åä½KG") private Double recordWeight = 0.0; /** * -----------ç»ç®ä¿¡æ¯----------------------- **/ @Column(name = "PRICE_") @PropertyDef(label = "åä»·", description = "åä½ï¼å /å ¬æ¤ï¼å®é ç»ç®ä»·æ ¼ä»¥ç»ç®åä¸å价为å") private Double price = 0.0; @Column(name = "SETTLE_MONEY_") @PropertyDef(label = "ç»ç®éé¢", description = "åä½ï¼å ï¼å®é ç»ç®ä»¥è®¡ç®å为å") private Double settleMoney = 0.00; @Column(name = "SETTLE_ID_", length = 50) @PropertyDef(label = "ç»ç®åå·", description = "妿æ¯å车ç»ç®å¿ å¡«") private String settleId; /** * ----------- å¼ä»ä¿¡æ¯----------------------- **/ @Column(name = "HANDLE_USER_", length = 40) @PropertyDef(label = "å¼ä»æä½äºº") private String handleUser; // åºåº @Column(name = "COMPLETE_TIME_") @PropertyDef(label = "宿æ¶é´") private Date completeTime; @Column(name = "COMPLETE_USER_", length = 40) @PropertyDef(label = "å®æç¡®è®¤äºº") private String completeUser; // 夿³¨ @Column(name = "REMARKS_", length = 200) @PropertyDef(label = "夿³¨ä¿¡æ¯") private String remarks; /** * ----------- å ¶ä»ä¿¡æ¯ï¼éå¯¹æ£æ¤ç±»åæ åå å ¥åºå¡«å----------------------- **/ @Column(name = "bzw", length = 2) @PropertyDef(label = "å è£ ç©", description = "1ï¼å 2ï¼æ¡¶3ï¼ç®± 9ï¼å ¶ä»") private String bzw; @Column(name = "dbz") @PropertyDef(label = "åå é", description = "åä½ï¼å ¬æ¤") private Double dbz; @Column(name = "bzbjs") @PropertyDef(label = "å ä»¶æ°", description = "åä½ï¼ä»¶") private int bzbjs; @Column(name = "UPDATE_TIME_") @PropertyDef(label = "æ°æ®æ´æ°æ¶é´") private Date updateTime; } src/main/java/com/fzzy/async/whhpjl/impl/Fz40ToWhjlSync1212.java
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,239 @@ package com.fzzy.async.whhpjl.impl; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.fzzy.api.Constant; import com.fzzy.api.entity.ApiInfoData; import com.fzzy.api.entity.ApiLog; import com.fzzy.api.entity.ApiTrigger; import com.fzzy.api.utils.ContextUtil; import com.fzzy.api.view.repository.ApiInfoDataRep; import com.fzzy.api.view.repository.ApiLogRep; import com.fzzy.api.view.repository.ApiTriggerRep; import com.fzzy.async.whhpjl.entity.Fz40WhjlDefaultContract; import com.fzzy.async.whhpjl.entity.Fz40WhjlDefaultDepot; import com.fzzy.async.whhpjl.entity.Fz40WhjlDefaultDept; import com.fzzy.async.whhpjl.entity.Fz40WhjlInoutRecord; import com.fzzy.async.whhpjl.repository.Fz40ToWhjlSync1101Rep; import com.fzzy.async.whhpjl.repository.Fz40ToWhjlSync1107Rep; import com.fzzy.async.whhpjl.repository.Fz40ToWhjlSync1212Rep; import com.fzzy.otherview.whhpjl.WhjlConstant; import com.fzzy.otherview.whhpjl.dto.*; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.time.DateFormatUtils; import org.apache.commons.lang.time.DateUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.util.Date; import java.util.List; /** * åºå ¥åºè®°å½ä¿¡æ¯ * */ @Slf4j @Component public class Fz40ToWhjlSync1212 { @Autowired private Fz40ToWhjlSync1212Rep fz40ToWhjlSync1212Rep; @Autowired private ApiLogRep apiLogRep; @Autowired private ApiTriggerRep apiTriggerRep; @Autowired private ApiInfoDataRep apiInfoDataRep; /** * åºå ¥åºè®°å½ä¿¡æ¯ * * @param kqdm * @param deptId * @param start * @param end */ public void syncData(String kqdm, String deptId, Date start, Date end) { log.info("-------------1212æ¥å£æ°æ®å¼å§åæ¥------------------"); //åæ¥æ°æ®ï¼åªè®°å½å¤±è´¥çä¿¡æ¯ ApiLog apiLog = new ApiLog(); apiLog.setType(ApiLog.TYPE_SYNC); apiLog.setKqdm(deptId); apiLog.setUploadTime(new Date()); apiLog.setInteId(Constant.API_CODE_1212); apiLog.setStatus(99); apiLog.setId(ContextUtil.getUUID()); try { List<Fz40WhjlInoutRecord> list = fz40ToWhjlSync1212Rep.listApi1212(deptId); List<ApiInfoData> apiInfoDataList; WhjlApi1212 apiData; for (Fz40WhjlInoutRecord sysData : list) { List<ApiInfoData> dept = apiInfoDataRep.getDataByDataId(sysData.getCompanyId()); WhjlApi1101 whjlApi1101 = JSONObject.parseObject(dept.get(0).getData(), WhjlApi1101.class); List<ApiInfoData> deptArea = apiInfoDataRep.getDataByDataId(sysData.getDeptId()); WhjlApi1102 whjlApi1102 = JSONObject.parseObject(deptArea.get(0).getData(), WhjlApi1102.class); apiData = new WhjlApi1212(); apiData.setCrkid(sysData.getId()); apiData.setJlqybh(whjlApi1101.getJlqybh());//åç²®ä¼ä¸ç¼å· apiData.setJlqymc(whjlApi1101.getJlqymc());//åç²®ä¼ä¸åç§° apiData.setJgzdbh(whjlApi1102.getJgzdbh());//åä¾ç«ç¹ç¼ç apiData.setJgzdmc(whjlApi1102.getJgzdmc());//åä¾ç«ç¹åç§° apiData.setYwrq(DateUtils.parseDate(sysData.getId().substring(2, 10), new String[]{"yyyyMMdd"})); if(sysData.getType().equals("IN")){ apiData.setCrklx("å ¥åº"); apiData.setYwlx("æ¥å¸¸åºå ¥åº");//åºå ¥åºç±»å: æ¥å¸¸åºå ¥åº/æ¥å¸¸åºåº/åºæ¥å ¥åº/åºæ¥åºåº/çç¹å ¥åº/çç¹åºåº/转ä»å ¥åº/转ä»åºåº } if(sysData.getType().equals("OUT")){ apiData.setCrklx("åºåº"); apiData.setYwlx("æ¥å¸¸åºåº");//åºå ¥åºç±»å: æ¥å¸¸åºå ¥åº/æ¥å¸¸åºåº/åºæ¥å ¥åº/åºæ¥åºåº/çç¹å ¥åº/çç¹åºåº/转ä»å ¥åº/转ä»åºåº } // apiData.setCrkpz("");//åºå ¥åºåè¯ // apiData.setJljgqybh("");//å å·¥ä¼ä¸ç¼ç // apiData.setJljgqymc("");//å å·¥ä¼ä¸åç§° // apiData.setKhbh("");//客æ·ç¼å· // apiData.setGlzxm("");//客æ·åç§° // apiData.setShdw("");//æ¶è´§åä½ // apiData.setShlxr("");//æ¶è´§è系人 // apiData.setRjfaid("");//åºæ¥æ¹æ¡id // apiData.setJhid("");//ç¹æªè®¡åiD // apiData.setHtid("");//ååID // apiData.setPsmxid("");//é éä»»å¡id apiData.setYscch(sysData.getPlateNum());//è¿è¾è½¦è¹å· apiData.setCyr(sysData.getUserName());//æ¿è¿äºº apiData.setCyrdh(StringUtils.isBlank(sysData.getUserContact()) ? "18336564986" : sysData.getUserContact());//æ¿è¿äººçµè¯ // apiData.setBz("");//夿³¨ // apiData.setCrkmxid("");//åºå ¥åºæç»id List<ApiInfoData> dataByDataId = apiInfoDataRep.getDataByDataId(sysData.getDepotId()); WhjlApi1108 whjlApi1108 = new WhjlApi1108(); if(dataByDataId != null && dataByDataId.size()>0){ whjlApi1108 = JSONObject.parseObject(dataByDataId.get(0).getData(), WhjlApi1108.class); } apiData.setHwbh(whjlApi1108.getHwbh());//è´§ä½ç¼å· apiData.setHwmc(whjlApi1108.getHwmc());//è´§ä½åç§° apiData.setAjbh(apiData.getHwbh().substring(0,28));//å»é´ç¼å· apiData.setAjmc(apiData.getHwmc());// TODO å»é´åç§° apiData.setKctzbh(sysData.getId().substring(2));//åºåå°è´¦ID apiData.setKctzcppcid(sysData.getId().substring(2));//åºåå°è´¦æ¹æ¬¡ID // apiData.setPsmxid("");//é éè½¦è¾æç»ID // apiData.setYjfamxid("");//åºæ¥æ¹æ¡æç»ID apiData.setLspzbm(sysData.getFoodVariety());//åç§ç¼å· List<ApiTrigger> lspz = apiTriggerRep.findNameByCode(sysData.getFoodVariety(),"LSPZ"); if(lspz != null && lspz.size() > 0){ apiData.setLspzmc(lspz.get(0).getName());//åç§åç§° } if (sysData.getFoodVariety().equals("2")){ //å°éº¦ç² apiData.setCpbh("FJL89570583ec0a2571");//产åç¼å· apiData.setCpmc("å°éº¦ç²");//产åç¼å· } if (sysData.getFoodVariety().equals("1")){ //大米 apiData.setCpbh("FJLdf09130205a43002");//产åç¼å· apiData.setCpmc("大米");//产åç¼å· } if (sysData.getFoodVariety().equals("3")){ //é£ç¨æ²¹ apiData.setCpbh("FJL3e7ba1605ebd5dec");//产åç¼å· apiData.setCpmc("é£ç¨æ²¹");//产åç¼å· } apiData.setJldwbm("12");//计éåä½ç¼ç apiData.setJldwmc("åå ");//计éåä½åç§° apiData.setJsdwbm("21");//计æ°åä½ç¼ç apiData.setJsdwmc("è¢");//计æ°åä½åç§° // apiData.setCrklx("");//åºå ¥åºç±»å apiData.setCrksl((double) sysData.getBzbjs());//åºå ¥åºæ°é apiData.setCrkzl(sysData.getSettleWeight());//åºå ¥åºéé // apiData.setQcsl(0.00);//æåæ°é // apiData.setQmsl(0.00);//ææ«æ°é // apiData.setQczl(0.00);//æåéé // apiData.setQmzl(0.00);//ææ«éé // apiData.setShsl(0.00);//æèæ°é // apiData.setShzl(0.00);//æèéé // apiData.setYsyq("");//éªæ¶è¦æ± // apiData.setSfhx("");//æ¯å¦æ ¸é // apiData.setQkxm("");//æ¬ æ¬¾é¡¹ç® apiData.setDj(sysData.getPrice());//åä»· apiData.setJe(apiData.getDj()*apiData.getCrkzl());//éé¢ apiData.setCpdj("ä¸ç");//产åç级 å ³èäº§åæ¥å£ // apiData.setCd("");//äº§å° // apiData.setSccj("");//ç产åå®¶ // apiData.setGg("");//è§æ ¼åå· // apiData.setCppc("");//äº§åæ¹æ¬¡ // apiData.setScrq(null);//çäº§æ¥æ // apiData.setBzq(null);//ä¿è´¨æ // apiData.setCkfs("");//åºåºæ¹å¼ apiData.setDjsj(sysData.getRegisterTime());//ç»è®°æ¶é´ // apiData.setZz("");//ç«é¿ // apiData.setJjy("");//è´¨æ£å apiData.setSxh(Integer.valueOf(sysData.getId().substring(6)));//顺åºå· // apiData.setDdid("");//订åid // apiData.setCrktzdid("");//åºå ¥åºéç¥åid // apiData.setCrktzdmxid("");//åºå ¥åºéç¥åæç»ID // apiData.setDjr("");//ç»è®°äºº // WhjlCheck zjbgwj = new WhjlCheck(); // zjbgwj.setJybgwjid("");//æ£éªæ¥åæä»¶ID // zjbgwj.setJyrq(null);//æ£éªæ¥æ // zjbgwj.setJylx("");//æ£éªç±»å // zjbgwj.setWjlx("");//æä»¶ç±»å // zjbgwj.setWjm("");//æä»¶å // zjbgwj.setWjlj("");//æä»¶è·¯å¾ // zjbgwj.setWjdx("");//æä»¶å¤§å° //æä¹ åä¿åï¼åç¬åå ¥é彿 æ¥å£è¡¨ ApiInfoData infoData = new ApiInfoData(); infoData.setId(sysData.getId()); infoData.setKqdm(kqdm); infoData.setInteType(WhjlConstant.API_CATEGORY_12); infoData.setInteId(WhjlConstant.API_CODE_1212); infoData.setUpdateTime(new Date()); infoData.setDataId(sysData.getId()); infoData.setRemarks("夿³¨ä¿¡æ¯"); //设置æä½æ å¿ apiInfoDataList = apiInfoDataRep.getDataByDataId(infoData.getDataId()); if (null == apiInfoDataList || apiInfoDataList.isEmpty()) { apiData.setCzbz(Constant.CZBZ_I); infoData.setCzbz(Constant.CZBZ_I); } else { apiData.setCzbz(apiInfoDataList.get(0).getCzbz()); infoData.setCzbz(apiInfoDataList.get(0).getCzbz()); } infoData.setData(JSON.toJSONString(apiData)); apiInfoDataRep.save(infoData); log.info("1212---åºå ¥åºè®°å½-åæ¥æ°æ®ï¼{}", apiData.toString()); } } catch (Exception e) { log.error("---1212åå-åæ¥æ°æ®æ§è¡å¤±è´¥----{}", e.getMessage()); apiLog.setResult("1212ååä¿¡æ¯åæ¥å¤±è´¥ï¼" + e.getMessage()); apiLogRep.save(apiLog); } } } src/main/java/com/fzzy/async/whhpjl/repository/Fz40ToWhjlSync1212Rep.java
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,23 @@ package com.fzzy.async.whhpjl.repository; import com.fzzy.async.whhpjl.entity.Fz40WhjlDefaultContract; import com.fzzy.async.whhpjl.entity.Fz40WhjlInoutRecord; import org.springframework.data.jpa.repository.JpaRepository; import org.springframework.data.jpa.repository.Query; import org.springframework.data.repository.query.Param; import java.util.List; /** * åºå ¥åºä¿¡æ¯ * */ public interface Fz40ToWhjlSync1212Rep extends JpaRepository<Fz40WhjlInoutRecord, String> { /** * åºå ¥åºä¿¡æ¯ * * @return */ @Query("from Fz40WhjlInoutRecord where deptId=:deptId ") List<Fz40WhjlInoutRecord> listApi1212(@Param("deptId") String deptId); } src/main/java/com/fzzy/otherview/whhpjl/WhjlApi1212.view.xml
@@ -319,6 +319,7 @@ <PropertyDef name="sxh"> <Property></Property> <Property name="label">顺åºå·</Property> <Property name="dataType">int</Property> </PropertyDef> <PropertyDef name="ddid"> <Property></Property> @@ -337,32 +338,32 @@ <Property name="label">ç»è®°äºº</Property> </PropertyDef> <PropertyDef name="ajmc"> <Property/> <Property></Property> </PropertyDef> <PropertyDef name="cpdj"> <Property/> <Property></Property> <Property name="label">ç级</Property> </PropertyDef> <PropertyDef name="jybgwjid"> <Property/> <Property></Property> </PropertyDef> <PropertyDef name="jyrq"> <Property name="dataType">Date</Property> </PropertyDef> <PropertyDef name="jylx"> <Property/> <Property></Property> </PropertyDef> <PropertyDef name="wjlx"> <Property/> <Property></Property> </PropertyDef> <PropertyDef name="wjm"> <Property/> <Property></Property> </PropertyDef> <PropertyDef name="wjlj"> <Property/> <Property></Property> </PropertyDef> <PropertyDef name="wjdx"> <Property/> <Property></Property> </PropertyDef> </DataType> <DataType name="dtCrkmx"> @@ -1238,6 +1239,16 @@ <Property name="property">sxh</Property> <Editor/> </AutoFormElement> <AutoFormElement> <Property name="name">dj</Property> <Property name="property">dj</Property> <Editor/> </AutoFormElement> <AutoFormElement> <Property name="name">scrq</Property> <Property name="property">scrq</Property> <Editor/> </AutoFormElement> </AutoForm> <Panel layout="regionPadding:5"> <Property name="caption">è´¨æ£æ¥åæä»¶</Property> src/main/java/com/fzzy/otherview/whhpjl/dto/WhjlApi1212.java
@@ -109,7 +109,7 @@ private Date djsj; //ç»è®°æ¶é´ private String zz; //ç«é¿ private String jjy; //è´¨æ£å private String sxh; //顺åºå· private int sxh; //顺åºå· // private String bz; //夿³¨ private String ddid; //订åID private String crktzdid; //åºå ¥åºéç¥åID src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlShareApi2001PR.java
@@ -7,6 +7,7 @@ import com.bstek.dorado.annotation.Expose; import com.fzzy.api.Constant; import com.fzzy.api.data.ApiParam; import com.fzzy.api.data.SyncProtocol; import com.fzzy.api.dto.ResponseDto; import com.fzzy.api.entity.ApiConfs; import com.fzzy.api.entity.ApiInfoData; @@ -122,6 +123,9 @@ String result = ""; List<WhjlShareApi2001> list; for (ApiConfs apiConf : apiConfs) { if(!apiConf.getSyncProtocol().equals(SyncProtocol.FZZY_V40_WHJL.getCode())){ continue; } apiService = apiPushManager.getApiRemoteService(apiConf.getPushProtocol()); if (null == apiService) { continue; src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlShareApi2002PR.java
@@ -7,6 +7,7 @@ import com.bstek.dorado.annotation.Expose; import com.fzzy.api.Constant; import com.fzzy.api.data.ApiParam; import com.fzzy.api.data.SyncProtocol; import com.fzzy.api.dto.ResponseDto; import com.fzzy.api.entity.ApiConfs; import com.fzzy.api.entity.ApiInfoData; @@ -124,6 +125,9 @@ String result = ""; List<WhjlShareApi2002> list; for (ApiConfs apiConf : apiConfs) { if(!apiConf.getSyncProtocol().equals(SyncProtocol.FZZY_V40_WHJL.getCode())){ continue; } apiService = apiPushManager.getApiRemoteService(apiConf.getPushProtocol()); if (null == apiService) { continue; src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlShareApi2003PR.java
@@ -7,6 +7,7 @@ import com.bstek.dorado.annotation.Expose; import com.fzzy.api.Constant; import com.fzzy.api.data.ApiParam; import com.fzzy.api.data.SyncProtocol; import com.fzzy.api.dto.ResponseDto; import com.fzzy.api.entity.ApiConfs; import com.fzzy.api.entity.ApiInfoData; @@ -133,10 +134,14 @@ String result = ""; List<WhjlShareApi2003> list; for (ApiConfs apiConf : apiConfs) { if(!apiConf.getSyncProtocol().equals(SyncProtocol.FZZY_V40_WHJL.getCode())){ continue; } apiService = apiPushManager.getApiRemoteService(apiConf.getPushProtocol()); if (null == apiService) { continue; } //å°è£ åæ° param = new ApiParam(apiConf, WhjlConstant.API_CATEGORY_20, WhjlConstant.API_CODE_2003); responseDto = apiService.pullData(param, apiConf); src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlShareApi2004PR.java
@@ -7,6 +7,7 @@ import com.bstek.dorado.annotation.Expose; import com.fzzy.api.Constant; import com.fzzy.api.data.ApiParam; import com.fzzy.api.data.SyncProtocol; import com.fzzy.api.dto.ResponseDto; import com.fzzy.api.entity.ApiConfs; import com.fzzy.api.entity.ApiInfoData; @@ -125,6 +126,9 @@ String result = ""; List<WhjlShareApi2004> list; for (ApiConfs apiConf : apiConfs) { if(!apiConf.getSyncProtocol().equals(SyncProtocol.FZZY_V40_WHJL.getCode())){ continue; } apiService = apiPushManager.getApiRemoteService(apiConf.getPushProtocol()); if (null == apiService) { continue; src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlShareApi2005PR.java
@@ -7,6 +7,7 @@ import com.bstek.dorado.annotation.Expose; import com.fzzy.api.Constant; import com.fzzy.api.data.ApiParam; import com.fzzy.api.data.SyncProtocol; import com.fzzy.api.dto.ResponseDto; import com.fzzy.api.entity.ApiConfs; import com.fzzy.api.entity.ApiInfoData; @@ -122,6 +123,9 @@ String result = ""; List<WhjlShareApi2005> list; for (ApiConfs apiConf : apiConfs) { if(!apiConf.getSyncProtocol().equals(SyncProtocol.FZZY_V40_WHJL.getCode())){ continue; } apiService = apiPushManager.getApiRemoteService(apiConf.getPushProtocol()); if (null == apiService) { continue; src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlShareApi2006PR.java
@@ -7,6 +7,7 @@ import com.bstek.dorado.annotation.Expose; import com.fzzy.api.Constant; import com.fzzy.api.data.ApiParam; import com.fzzy.api.data.SyncProtocol; import com.fzzy.api.dto.ResponseDto; import com.fzzy.api.entity.ApiConfs; import com.fzzy.api.entity.ApiInfoData; @@ -124,6 +125,9 @@ String result = ""; List<WhjlShareApi2006> list; for (ApiConfs apiConf : apiConfs) { if(!apiConf.getSyncProtocol().equals(SyncProtocol.FZZY_V40_WHJL.getCode())){ continue; } apiService = apiPushManager.getApiRemoteService(apiConf.getPushProtocol()); if (null == apiService) { continue; src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlShareApi2007PR.java
@@ -7,6 +7,7 @@ import com.bstek.dorado.annotation.Expose; import com.fzzy.api.Constant; import com.fzzy.api.data.ApiParam; import com.fzzy.api.data.SyncProtocol; import com.fzzy.api.dto.ResponseDto; import com.fzzy.api.entity.ApiConfs; import com.fzzy.api.entity.ApiInfoData; @@ -123,6 +124,9 @@ String result = ""; List<WhjlShareApi2007> list; for (ApiConfs apiConf : apiConfs) { if(!apiConf.getSyncProtocol().equals(SyncProtocol.FZZY_V40_WHJL.getCode())){ continue; } apiService = apiPushManager.getApiRemoteService(apiConf.getPushProtocol()); if (null == apiService) { continue; src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlShareApi2008PR.java
@@ -7,6 +7,7 @@ import com.bstek.dorado.annotation.Expose; import com.fzzy.api.Constant; import com.fzzy.api.data.ApiParam; import com.fzzy.api.data.SyncProtocol; import com.fzzy.api.dto.ResponseDto; import com.fzzy.api.entity.ApiConfs; import com.fzzy.api.entity.ApiInfoData; @@ -123,6 +124,9 @@ String result = ""; List<WhjlShareApi2008> list; for (ApiConfs apiConf : apiConfs) { if(!apiConf.getSyncProtocol().equals(SyncProtocol.FZZY_V40_WHJL.getCode())){ continue; } apiService = apiPushManager.getApiRemoteService(apiConf.getPushProtocol()); if (null == apiService) { continue; src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlShareApi2009PR.java
@@ -7,6 +7,7 @@ import com.bstek.dorado.annotation.Expose; import com.fzzy.api.Constant; import com.fzzy.api.data.ApiParam; import com.fzzy.api.data.SyncProtocol; import com.fzzy.api.dto.ResponseDto; import com.fzzy.api.entity.ApiConfs; import com.fzzy.api.entity.ApiInfoData; @@ -123,6 +124,9 @@ String result = ""; List<WhjlShareApi2009> list; for (ApiConfs apiConf : apiConfs) { if(!apiConf.getSyncProtocol().equals(SyncProtocol.FZZY_V40_WHJL.getCode())){ continue; } apiService = apiPushManager.getApiRemoteService(apiConf.getPushProtocol()); if (null == apiService) { continue; src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlShareApi2010PR.java
@@ -7,6 +7,7 @@ import com.bstek.dorado.annotation.Expose; import com.fzzy.api.Constant; import com.fzzy.api.data.ApiParam; import com.fzzy.api.data.SyncProtocol; import com.fzzy.api.dto.ResponseDto; import com.fzzy.api.entity.ApiConfs; import com.fzzy.api.entity.ApiInfoData; @@ -146,6 +147,9 @@ String result = ""; List<WhjlShareApi2010> list; for (ApiConfs apiConf : apiConfs) { if(!apiConf.getSyncProtocol().equals(SyncProtocol.FZZY_V40_WHJL.getCode())){ continue; } apiService = apiPushManager.getApiRemoteService(apiConf.getPushProtocol()); if (null == apiService) { continue; src/main/java/com/fzzy/otherview/whhpjl/pr/WhjlShareApi2011PR.java
@@ -7,6 +7,7 @@ import com.bstek.dorado.annotation.Expose; import com.fzzy.api.Constant; import com.fzzy.api.data.ApiParam; import com.fzzy.api.data.SyncProtocol; import com.fzzy.api.dto.ResponseDto; import com.fzzy.api.entity.ApiConfs; import com.fzzy.api.entity.ApiInfoData; @@ -136,6 +137,9 @@ String result = ""; List<WhjlShareApi2011> list; for (ApiConfs apiConf : apiConfs) { if(!apiConf.getSyncProtocol().equals(SyncProtocol.FZZY_V40_WHJL.getCode())){ continue; } apiService = apiPushManager.getApiRemoteService(apiConf.getPushProtocol()); if (null == apiService) { continue;