优化上海接口-调整视频信息等

CZT

2023-11-02 92be463c5a038062c42d758a6e18be62955007a7

优化上海接口-调整视频信息等

 src/main/java/com/fzzy/api/entity/Api1107.java

@@ -68,7 +68,7 @@

    @PropertyDef(label = "生产日期" )
    @JSONField(format = "yyyy-MM-dd")
    @Column(name = "scrq", nullable = false)
    @Column(name = "scrq")
    private Date scrq;

    @PropertyDef(label = "设备描述" )
@@ -81,7 +81,7 @@

    @PropertyDef(label = "检定时间" )
    @JSONField(format = "yyyy-MM-dd")
    @Column(name = "jdsj", nullable = false)
    @Column(name = "jdsj")
    private Date jdsj;

    @PropertyDef(label = "检定单位" )
@@ -94,7 +94,7 @@

    @PropertyDef(label = "最后更新时间" )
    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @Column(name = "zhgxsj", nullable = false)
    @Column(name = "zhgxsj")
    private Date zhgxsj;



 src/main/java/com/fzzy/api/entity/Api1108.java

@@ -92,12 +92,13 @@
    private String czclfs;

    @PropertyDef(label = "保质期")
    @Column(name = "bzq", length = 40)
    private String bzq;
    @Column(name = "bzq")
    @JSONField(format = "yyyy-MM-dd")
    private Date bzq;

    @PropertyDef(label = "采购日期")
    @JSONField(format = "yyyy-MM-dd")
    @Column(name = "cgrq", nullable = false)
    @Column(name = "cgrq")
    private Date cgrq;

    @PropertyDef(label = "库存数量")
@@ -114,7 +115,7 @@

    @PropertyDef(label = "最后更新时间")
    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @Column(name = "zhgxsj", nullable = false)
    @Column(name = "zhgxsj")
    private Date zhgxsj;

}

 src/main/java/com/fzzy/api/entity/Api1112.java

@@ -109,7 +109,7 @@

    @PropertyDef(label = "取得最高职称或职业资格时间" )
    @JSONField(format = "yyyy-MM-dd")
    @Column(name = "qdzgzchzyzgsj", nullable = false)
    @Column(name = "qdzgzchzyzgsj")
    private Date qdzgzchzyzgsj;

    @PropertyDef(label = "学历" )
@@ -126,7 +126,7 @@

    @PropertyDef(label = "最后更新时间" )
    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @Column(name = "zhgxsj", nullable = false)
    @Column(name = "zhgxsj")
    private Date zhgxsj;



 src/main/java/com/fzzy/api/entity/Api1307.java

@@ -30,6 +30,8 @@
     */
    private static final long serialVersionUID = 1L;


    /*----------接口系统自定义字段----------*/
    @Id
    @JSONField(serialize = false)
    @Column(name = "ID_", length = 40)
@@ -40,56 +42,69 @@
    @Column(name = "bizId", length = 40)
    private String bizId;

    @JSONField(serialize = false)
    @PropertyDef(label = "文件地址")
    @Column(name = "wjdz")
    private String wjdz;

    /*----------国标字段----------*/
    @PropertyDef(label = "库区代码")
    @Column(name = "kqdm", length = 21)
    private String kqdm;

    @PropertyDef(label = "视频监控设备id" )
    @Column(name = "spjksbid", length = 20, nullable = false)
    @Column(name = "spjksbid", length = 20)
    private String spjksbid;

    @PropertyDef(label = "仓房代码" )
    @Column(name = "cfdm", length = 25, nullable = false)
    @Column(name = "cfdm", length = 25)
    private String cfdm;

    @PropertyDef(label = "货位代码" )
    @Column(name = "hwdm", length = 30, nullable = false)
    @Column(name = "hwdm", length = 30)
    private String hwdm;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "抓拍时间" )
    @Column(name = "zpsj", nullable = false)
    @Column(name = "zpsj")
    private Date zpsj;

    @PropertyDef(label = "文件id")
    @Column(name = "fileStorageId", length = 20)
    private String fileStorageId;

    @PropertyDef(label = "图像文件后缀名")
    @Column(name = "txwjhzm", length = 5)
    private String txwjhzm;

    @PropertyDef(label = "仓内图像文件流" )
    @Column(name = "cntxwjl", length = 512)
    private String cntxwjl;

    @PropertyDef(label = "图像文件后缀名")
    @Column(name = "txwjhzm", length = 5)
    private String txwjhzm;

    @JSONField(name="Yzwbh")
    @PropertyDef(label = "预置位编号" )
    @Column(name = "yzwbh", length = 32, nullable = false)
    @Column(name = "yzwbh", length = 32)
    private String yzwbh;

    @PropertyDef(label = "文件地址")
    @Column(name = "wjdz")
    @JSONField(serialize = false)
    private String wjdz;

    @PropertyDef(label = "操作标志" )
    @Column(name = "czbz", length = 1, nullable = false)
    @Column(name = "czbz", length = 1)
    private String czbz;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "最后更新时间" )
    @Column(name = "zhgxsj", nullable = false)
    @Column(name = "zhgxsj")
    private Date zhgxsj;


    /*----------广东省平台规范字段----------*/
    @PropertyDef(label = "文件id")
    @Column(name = "fileStorageId", length = 20)
    private String fileStorageId;


    /*----------上海市平台规范字段----------*/
    @PropertyDef(label = "廒间代码")
    @Column(name = "ajdh", length = 28)
    private String ajdh;

    @PropertyDef(label = "图像编号", description = "文件信息接口中的文件名称")
    @Column(name = "txbh", length = 100)
    private String txbh;

}

 src/main/java/com/fzzy/api/entity/Api1308.java

@@ -3,7 +3,6 @@
import com.alibaba.fastjson.annotation.JSONField;
import com.bstek.dorado.annotation.PropertyDef;
import lombok.Data;
import org.hibernate.annotations.GenericGenerator;
import javax.persistence.*;
import java.io.Serializable;
import java.util.Date;
@@ -24,22 +23,34 @@
     */
    private static final long serialVersionUID = 1L;

    /*----------接口系统自定义字段----------*/
    @Id
    @JSONField(serialize = false)
    @Column(name = "ID_", length = 40)
    private String id;

    @PropertyDef(label = "文件地址")
    @Column(name = "wjdz")
    @JSONField(serialize = false)
    private String wjdz;

    @JSONField(serialize = false)
    @PropertyDef(label = "业务id")
    @Column(name = "bizId", length = 40)
    private String bizId;

    /*----------国标字段----------*/
    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "告警时间" )
    @Column(name = "gjsj", nullable = false)
    @Column(name = "gjsj")
    private Date gjsj;

    @PropertyDef(label = "库区名称" )
    @Column(name = "kqmc", length = 64, nullable = false)
    @Column(name = "kqmc", length = 64)
    private String kqmc;

    @PropertyDef(label = "库区代码" )
    @Column(name = "kqdm", length = 21, nullable = false)
    @Column(name = "kqdm", length = 21)
    private String kqdm;

    @PropertyDef(label = "库区地址" )
@@ -47,11 +58,11 @@
    private String kqdz;

    @PropertyDef(label = "视频监控设备id" )
    @Column(name = "spjksbid", length = 20, nullable = false)
    @Column(name = "spjksbid", length = 20)
    private String spjksbid;

    @PropertyDef(label = "安装位置类型" )
    @Column(name = "azwzlx", length = 2, nullable = false)
    @Column(name = "azwzlx", length = 2)
    private String azwzlx;

    @PropertyDef(label = "监视区域说明" )
@@ -59,38 +70,41 @@
    private String jsqysm;

    @PropertyDef(label = "异常告警说明" )
    @Column(name = "ycgjsm", length = 1024, nullable = false)
    @Column(name = "ycgjsm", length = 1024)
    private String ycgjsm;

    @PropertyDef(label = "文件id")
    @Column(name = "fileStorageId", length = 20)
    private String fileStorageId;
    @PropertyDef(label = "视频文件流" )
    @Column(name = "spwjl", length = 1024)
    private String spwjl;

    @PropertyDef(label = "视频文件后缀名")
    @Column(name = "spwjhzm", length = 5)
    private String spwjhzm;

    @PropertyDef(label = "视频文件流" )
    @Column(name = "spwjl", length = 1024, nullable = false)
    private String spwjl;

    @PropertyDef(label = "文件地址")
    @Column(name = "wjdz")
    @JSONField(serialize = false)
    private String wjdz;

    @PropertyDef(label = "操作标志" )
    @Column(name = "czbz", length = 1, nullable = false)
    @Column(name = "czbz", length = 1)
    private String czbz;

    @JSONField(serialize = false)
    @PropertyDef(label = "业务id")
    @Column(name = "bizId", length = 40)
    private String bizId;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "最后更新时间" )
    @Column(name = "zhgxsj", nullable = false)
    @Column(name = "zhgxsj")
    private Date zhgxsj;

    /*----------广东省平台规范字段----------*/
    @PropertyDef(label = "文件id")
    @Column(name = "fileStorageId", length = 20)
    private String fileStorageId;

    /*----------上海市平台规范字段----------*/
    @PropertyDef(label = "货位代码")
    @Column(name = "hwdm", length = 30)
    private String hwdm;

    @PropertyDef(label = "图像编号", description = "文件信息接口中的文件名称")
    @Column(name = "txbh", length = 100)
    private String txbh;

    @PropertyDef(label = "视频编号", description = "文件信息接口中的文件名称")
    @Column(name = "spbh", length = 100)
    private String spbh;
}

 src/main/java/com/fzzy/api/entity/Api1309.java

@@ -30,20 +30,20 @@

    @Id
    @PropertyDef(label = "预警信息代码" )
    @Column(name = "yjxxdm", length = 32, nullable = false)
    @Column(name = "yjxxdm", length = 32)
    private String yjxxdm;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "预警发布时间" )
    @Column(name = "fbsj", nullable = false)
    @Column(name = "fbsj")
    private Date fbsj;

    @PropertyDef(label = "违规主体类型" )
    @Column(name = "wgztlx", length = 2, nullable = false)
    @Column(name = "wgztlx", length = 2)
    private String wgztlx;

    @PropertyDef(label = "违规单位代码" )
    @Column(name = "qydm", length = 21, nullable = false)
    @Column(name = "qydm", length = 21)
    private String qydm;

    @PropertyDef(label = "违规行为人" )
@@ -51,19 +51,19 @@
    private String wgxwr;

    @PropertyDef(label = "涉及库点" )
    @Column(name = "sjkd", length = 128, nullable = false)
    @Column(name = "sjkd", length = 128)
    private String sjkd;

    @PropertyDef(label = "违规类型" )
    @Column(name = "wglx", length = 2, nullable = false)
    @Column(name = "wglx", length = 2)
    private String wglx;

    @PropertyDef(label = "违规详情" )
    @Column(name = "wgqk", length = 512, nullable = false)
    @Column(name = "wgqk", length = 512)
    private String wgqk;

    @PropertyDef(label = "当前处置状态" )
    @Column(name = "czzt", length = 2, nullable = false)
    @Column(name = "czzt", length = 2)
    private String czzt;

    @PropertyDef(label = "处置内容" )
@@ -80,12 +80,12 @@
    private Date hxczsj;

    @PropertyDef(label = "操作标志" )
    @Column(name = "czbz", length = 1, nullable = false)
    @Column(name = "czbz", length = 1)
    private String czbz;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "最后更新时间" )
    @Column(name = "zhgxsj", nullable = false)
    @Column(name = "zhgxsj")
    private Date zhgxsj;

}

 src/main/java/com/fzzy/api/view/Api1307.view.xml

@@ -61,6 +61,18 @@
        <Property></Property>
        <Property name="label">库区代码</Property>
      </PropertyDef>
      <PropertyDef name="fileStorageId">
        <Property></Property>
        <Property name="label">文件id</Property>
      </PropertyDef>
      <PropertyDef name="ajdh">
        <Property></Property>
        <Property name="label">廒间代码</Property>
      </PropertyDef>
      <PropertyDef name="txbh">
        <Property></Property>
        <Property name="label">图像编号</Property>
      </PropertyDef>
    </DataType>
    <DataType name="dtParam">
      <Property name="creationType">com.fzzy.api.data.ApiParam</Property>
@@ -365,6 +377,21 @@
            <Property name="property">kqdm</Property>
            <Editor/>
          </AutoFormElement>
          <AutoFormElement>
            <Property name="name">fileStorageId</Property>
            <Property name="property">fileStorageId</Property>
            <Editor/>
          </AutoFormElement>
          <AutoFormElement>
            <Property name="name">ajdh</Property>
            <Property name="property">ajdh</Property>
            <Editor/>
          </AutoFormElement>
          <AutoFormElement>
            <Property name="name">txbh</Property>
            <Property name="property">txbh</Property>
            <Editor/>
          </AutoFormElement>
        </AutoForm>
      </Children>
      <Tools/>

 src/main/java/com/fzzy/api/view/Api1308.view.xml

@@ -71,6 +71,18 @@
        <Property></Property>
        <Property name="label">业务编码</Property>
      </PropertyDef>
      <PropertyDef name="hwdm">
        <Property></Property>
        <Property name="label">货位代码</Property>
      </PropertyDef>
      <PropertyDef name="txbh">
        <Property></Property>
        <Property name="label">图像编号</Property>
      </PropertyDef>
      <PropertyDef name="spbh">
        <Property></Property>
        <Property name="label">视频编号</Property>
      </PropertyDef>
    </DataType>
    <DataType name="dtParam">
      <Property name="creationType">com.fzzy.api.data.ApiParam</Property>
@@ -385,6 +397,21 @@
            <Property name="property">bizId</Property>
            <Editor/>
          </AutoFormElement>
          <AutoFormElement>
            <Property name="name">hwdm</Property>
            <Property name="property">hwdm</Property>
            <Editor/>
          </AutoFormElement>
          <AutoFormElement>
            <Property name="name">txbh</Property>
            <Property name="property">txbh</Property>
            <Editor/>
          </AutoFormElement>
          <AutoFormElement>
            <Property name="name">spbh</Property>
            <Property name="property">spbh</Property>
            <Editor/>
          </AutoFormElement>
        </AutoForm>
      </Children>
      <Tools/>

 src/main/java/com/fzzy/api/view/pr/Api1108PR.java

@@ -56,7 +56,6 @@
        Api1108 data = new Api1108();
        BeanUtils.copyProperties(entity, data);

        data.setId(data.getBizId().trim());
        api1108Rep.save(data);
    }


 src/main/java/com/fzzy/api/view/repository/Api1107Rep.java

@@ -35,4 +35,8 @@
     */
    @Query("from Api1107 where kqdm=:kqdm and zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
    List<Api1107> findPushDataTime(@Param("kqdm") String kqdm, @Param("start") Date start, @Param("end") Date end);


    @Query("from Api1107 where bizId=:bizId ")
    List<Api1107> getDataByBizId(@Param("bizId") String bizId);
}

 src/main/java/com/fzzy/api/view/repository/Api1108Rep.java

@@ -36,4 +36,7 @@
     */
    @Query("from Api1108 where kqdm=:kqdm and zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
    List<Api1108> findPushDataTime(@Param("kqdm") String kqdm, @Param("start") Date start, @Param("end") Date end);

    @Query("from Api1108 where bizId=:bizId ")
    List<Api1108> getDataByBizId(@Param("bizId") String bizId);
}

 src/main/java/com/fzzy/api/view/repository/Api1112Rep.java

@@ -30,6 +30,10 @@
    @Query("from Api1112 where kqdm=:kqdm")
    List<Api1112> findPushData(@Param("kqdm") String kqdm);


    @Query("from Api1112 where bizId=:bizId ")
    List<Api1112> getDataByBizId(@Param("bizId") String bizId);

    /**
     *
     * @param kqdm

 src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService12.java

@@ -60,35 +60,35 @@
        Date start = param.getStart();
        Date end = param.getEnd();

        //客户同步
        fzzySync1212.syncData(kqdm, deptId, start, end);

        //合同同步
        fzzySync1201.syncData(kqdm, deptId, start, end);

        //粮食入库同步
        fzzySync1202.syncData(kqdm, deptId, start, end);

        //粮食入库质检
        fzzySync1203.syncData(kqdm, deptId, start, end);

        //粮食入库结算
        fzzySync1204.syncData(kqdm, deptId, start, end);
        //粮食出库同步
        fzzySync1205.syncData(kqdm, deptId, start, end);

        //粮食出库结算
        fzzySync1206.syncData(kqdm, deptId, start, end);
        //粮食损益
        fzzySync1209.syncData(kqdm, deptId, start, end);
        //倒仓信息同步
        fzzySync1207.syncData(kqdm, deptId, start, end);

        //出入库文件信息同步
        fzzySync1109.syncData(kqdm, deptId, start, end);

        //粮食库存同步
        fzzySync1208.syncData(kqdm, deptId, start, end);
//        //客户同步
//        fzzySync1212.syncData(kqdm, deptId, start, end);
//
//        //合同同步
//        fzzySync1201.syncData(kqdm, deptId, start, end);
//
//        //粮食入库同步
//        fzzySync1202.syncData(kqdm, deptId, start, end);
//
//        //粮食入库质检
//        fzzySync1203.syncData(kqdm, deptId, start, end);
//
//        //粮食入库结算
//        fzzySync1204.syncData(kqdm, deptId, start, end);
//        //粮食出库同步
//        fzzySync1205.syncData(kqdm, deptId, start, end);
//
//        //粮食出库结算
//        fzzySync1206.syncData(kqdm, deptId, start, end);
//        //粮食损益
//        fzzySync1209.syncData(kqdm, deptId, start, end);
//        //倒仓信息同步
//        fzzySync1207.syncData(kqdm, deptId, start, end);
//
//        //出入库文件信息同步
//        fzzySync1109.syncData(kqdm, deptId, start, end);
//
//        //粮食库存同步
//        fzzySync1208.syncData(kqdm, deptId, start, end);

        //粮食性质转变信息同步
        fzzySync1210.syncData(kqdm, deptId, start, end);

 src/main/java/com/fzzy/async/fzzy40/entity/Fz40DeptDevice.java

@@ -23,29 +23,17 @@

    private static final long serialVersionUID = 1L;
    @Id
    @Column(name = "ID_", length = 40)
    @PropertyDef(label = "ID")
    private String id;

    @Column(name = "kqdm", length = 40)
    @PropertyDef(label = "库区代码")
    private String kqdm;
    @Column(name = "sbbh", length = 20)
    @PropertyDef(label = "设备编号")
    private String sbbh;

    @Column(name = "COMPANY_ID_", length = 10)
    @PropertyDef(label = "组织编码", description = "")
    private String companyId;

    @Column(name = "dwdm", length = 18)
    @PropertyDef(label = "单位代码")
    private String dwdm;

    @Column(name = "kqmc", length = 256)
    @PropertyDef(label = "库区名称")
    private String kqmc;

    @Column(name = "sbbh", length = 20)
    @PropertyDef(label = "设备编号")
    private String sbbh;
    @Column(name = "DEPT_ID_", length = 40)
    @PropertyDef(label = "所属库区")
    private String deptId;

    @Column(name = "sbyqmc", length = 50)
    @PropertyDef(label = "设备仪器名称")
@@ -78,7 +66,6 @@

    @Column(name = "jdsj")
    @PropertyDef(label = "检定时间")
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd", timezone = "GMT+8")
    private Date jdsj;

    @Column(name = "jddw", length = 256)
@@ -87,7 +74,6 @@

    @Column(name = "UPDATE_TIME_")
    @PropertyDef(label = "更新时间")
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd", timezone = "GMT+8")
    private Date updateTime;

}

 src/main/java/com/fzzy/async/fzzy40/entity/Fz40Drug.java

@@ -17,20 +17,17 @@
@Data
@Entity
@Table(name = "D_DRUG")
@IdClass(Fz40DrugKey.class)
public class Fz40Drug implements Serializable {

    @Id
    @Column(name = "ID_", length = 40)
    @PropertyDef(label = "药剂编号", description = "库区代码+三位顺序号")
    @PropertyDef(label = "药剂编号", description = "采购日期(yyyyMMdd)+三位顺序号")
    private String id;

    @Id
    @Column(name = "DEPT_ID_", length = 50)
    @PropertyDef(label = "库区代码")
    private String deptId;

    @Id
    @Column(name = "cgrq")
    @PropertyDef(label = "采购日期")
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd", timezone = "GMT+8")
@@ -89,9 +86,10 @@
    @PropertyDef(label = "残渣处理方式")
    private String czclfs;

    @Column(name = "bzq", length = 40)
    @Column(name = "bzq", length = 20)
    @PropertyDef(label = "保质期")
    private String bzq;
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd", timezone = "GMT+8")
    private Date bzq;

//    @Column(name = "SPEC_", length = 50)
//    @PropertyDef(label = "规格说明")

 src/main/java/com/fzzy/async/fzzy40/entity/Fz40DrugKey.java

ÎļþÒÑɾ³ý

 src/main/java/com/fzzy/async/fzzy40/entity/Fz40OAStaff.java

@@ -25,29 +25,29 @@
public class Fz40OAStaff implements Serializable {
    private static final long serialVersionUID = 1L;
    @Id
    @Column(name = "ID_", length = 40)
    @PropertyDef(label = "ID")
    private String id;
    @Column(name = "sfzhm", length = 18)
    @PropertyDef(label = "身份证号码")
    private String sfzhm;

    @Column(name = "COMPANY_ID_", length = 10)
    @PropertyDef(label = "组织编码", description = "")
    private String companyId;

    @Column(name = "dwdm", length = 18)
    @PropertyDef(label = "单位代码")
    private String dwdm;

    @Column(name = "dwmc", length = 256)
    @PropertyDef(label = "单位名称")
    private String dwmc;
    @Column(name = "DEPT_ID_", length = 20)
    @PropertyDef(label = "库区编码", description = "")
    private String deptId;

    @Column(name = "lsbm", length = 256)
    @PropertyDef(label = "隶属部门", description = "隶属部门名称")
    private String lsbm;

    @Column(name = "xzqhdm", length = 6)
    @PropertyDef(label = "行政区划代码")
    @PropertyDef(label = "所属行政区划")
    private String xzqhdm;

    @Column(name = "xzqhmc", length = 6)
    @PropertyDef(label = "所属行政区划")
    private String xzqhmc;

    @Column(name = "xm", length = 32)
    @PropertyDef(label = "姓名")
@@ -56,10 +56,6 @@
    @Column(name = "xb", length = 1)
    @PropertyDef(label = "性别")
    private String xb;

    @Column(name = "sfzhm", length = 18)
    @PropertyDef(label = "身份证号码")
    private String sfzhm;

    @Column(name = "rzrq")
    @PropertyDef(label = "入职日期")

 src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1107.java

@@ -3,7 +3,6 @@
import com.fzzy.api.Constant;
import com.fzzy.api.entity.*;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1101Rep;
import com.fzzy.api.view.repository.Api1102Rep;
import com.fzzy.api.view.repository.Api1107Rep;
import com.fzzy.api.view.repository.ApiLogRep;
@@ -29,8 +28,6 @@
    @Autowired
    private ApiLogRep apiLogRep;
    @Autowired
    private Api1101Rep api1101Rep;
    @Autowired
    private Api1102Rep api1102Rep;
    @Autowired
    private Api1107Rep api1107Rep;
@@ -55,22 +52,20 @@
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz40DeptDevice> list = fzzy40Sync1107Rep.listDecixe(deptId);
            List<Fz40DeptDevice> list = fzzy40Sync1107Rep.listDevice(deptId);

            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到设备信息------------------");
                return;
            }
            Api1102 api1102 = api1102Rep.findById(kqdm).get();
            Api1101 api1101 = api1101Rep.findById(api1102.getDwdm()).get();
            Api1107 apiData;

            List<Api1107> api1107List;
            for (Fz40DeptDevice sysData : list) {
                apiData = new Api1107();

                apiData.setBizId(sysData.getId());
                apiData.setSbbh(sysData.getSbbh());
                apiData.setDwdm(api1101.getDwdm());//单位代码
                apiData.setDwdm(api1102.getDwdm());//单位代码
                apiData.setKqdm(api1102.getKqdm());//库区代码
                apiData.setKqmc(api1102.getKqmc());//库区名称
                apiData.setSbyqmc(sysData.getSbyqmc());
@@ -82,8 +77,15 @@
                apiData.setSbzt(sysData.getSbzt());
                apiData.setJdsj(sysData.getJdsj());
                apiData.setJddw(sysData.getJddw());
                apiData.setCzbz(Constant.CZBZ_I);
                apiData.setZhgxsj(sysData.getUpdateTime());
                apiData.setBizId(sysData.getSbbh());

                api1107List = api1107Rep.getDataByBizId(apiData.getBizId());
                if (null == api1107List || api1107List.isEmpty()) {
                    apiData.setCzbz(Constant.CZBZ_I);
                } else {
                    apiData.setCzbz(api1107List.get(0).getCzbz());
                }

                //保存数据
                api1107Rep.save(apiData);

 src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1108.java

@@ -1,21 +1,17 @@
package com.fzzy.async.fzzy40.impl;

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1101;
import com.fzzy.api.entity.Api1102;
import com.fzzy.api.entity.Api1108;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.entity.*;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1101Rep;
import com.fzzy.api.view.repository.Api1102Rep;
import com.fzzy.api.view.repository.Api1108Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy40.entity.Fz40Drug;
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1108Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.Date;
import java.util.List;

@@ -32,8 +28,6 @@
    private Fzzy40Sync1108Rep fzzy40Sync1108Rep;
    @Autowired
    private ApiLogRep apiLogRep;
    @Autowired
    private Api1101Rep api1101Rep;
    @Autowired
    private Api1102Rep api1102Rep;
    @Autowired
@@ -61,40 +55,48 @@
        apiLog.setId(ContextUtil.getUUID());

        try {
            List<Fz40Drug> list = fzzy40Sync1108Rep.listDrug(deptId);
            List<Fz40Drug> list = fzzy40Sync1108Rep.listDrug(deptId, start, end);

            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到药剂信息------------------");
                return;
            }
            Api1102 api1102 = api1102Rep.findById(kqdm).get();
            Api1101 api1101 = api1101Rep.findById(api1102.getDwdm()).get();
            Api1108 apiData;
            List<Api1108> api1108List;
            for (Fz40Drug sysData : list) {

                apiData = new Api1108();
                apiData.setId(ContextUtil.getUUID());//ID
                apiData.setId(kqdm + sysData.getId());//ID
                apiData.setBizId(sysData.getId());//业务id
                apiData.setDwdm(api1101.getDwdm());//单位代码
                apiData.setDwdm(api1102.getDwdm());//单位代码
                apiData.setKqdm(api1102.getKqdm());//库区代码
                apiData.setKqmc(api1102.getKqmc());//库区名称
                apiData.setYjbh(sysData.getId());//药剂编号
                apiData.setYjbh(kqdm + sysData.getId().substring(8));//药剂编号
                apiData.setYjmc(sysData.getName());//药剂名称
                apiData.setBzw(sysData.getBzw());//包装物
                apiData.setGgxh(sysData.getGgxh());//型号规格
                apiData.setAqsysms(sysData.getAqsysms());//安全使用说明书
                apiData.setSccj(sysData.getSccj());//生产厂家
                apiData.setCgly(sysData.getCgly());//采购来源
                apiData.setCctj(sysData.getCctj());//存储条件
                apiData.setCcdd(sysData.getCcdd());//储存地点
                apiData.setBzwclfs(sysData.getBzwclfs());//包装物处理方式
                apiData.setCzclfs(sysData.getCzclfs());//残渣处理方式
                apiData.setBzq(sysData.getBzq());//保质期
                apiData.setCgrq(sysData.getCgrq());//采购日期
                apiData.setBzw(StringUtils.isEmpty(sysData.getBzw())?"":sysData.getBzw());//包装物
                apiData.setGgxh(StringUtils.isEmpty(sysData.getGgxh())?"":sysData.getGgxh());//型号规格
                apiData.setAqsysms(StringUtils.isEmpty(sysData.getAqsysms())?"":sysData.getAqsysms());//安全使用说明书
                apiData.setSccj(StringUtils.isEmpty(sysData.getSccj())?"":sysData.getSccj());//生产厂家
                apiData.setCgly(StringUtils.isEmpty(sysData.getCgly())?"":sysData.getCgly());//采购来源
                apiData.setCctj(StringUtils.isEmpty(sysData.getCctj())?"":sysData.getCctj());//存储条件
                apiData.setCcdd(StringUtils.isEmpty(sysData.getCcdd())?"":sysData.getCcdd());//储存地点
                apiData.setBzwclfs(StringUtils.isEmpty(sysData.getBzwclfs())?"":sysData.getBzwclfs());//包装物处理方式
                apiData.setCzclfs(StringUtils.isEmpty(sysData.getCzclfs())?"":sysData.getCzclfs());//残渣处理方式
                apiData.setBzq(null == sysData.getBzw()?new Date():sysData.getBzq());//保质期
                apiData.setCgrq(null == sysData.getBzw()?new Date():sysData.getCgrq());//采购日期
                apiData.setKcsl(sysData.getCount());//库存数量
                apiData.setKcsldw(sysData.getKcsldw());//库存数量单位
                apiData.setCzbz(Constant.CZBZ_I);//操作标志
                apiData.setKcsldw(StringUtils.isEmpty(sysData.getKcsldw())?"":sysData.getKcsldw());//库存数量单位

                apiData.setZhgxsj(sysData.getUpdateTime());//最后更新时间
                apiData.setBizId(sysData.getId());//业务id

                api1108List = api1108Rep.getDataByBizId(apiData.getBizId());
                if (null == api1108List || api1108List.isEmpty()) {
                    apiData.setCzbz(Constant.CZBZ_I);
                } else {
                    apiData.setCzbz(api1108List.get(0).getCzbz());
                }

                //保存数据
                api1108Rep.save(apiData);

 src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1112.java

@@ -1,10 +1,7 @@
package com.fzzy.async.fzzy40.impl;

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1101;
import com.fzzy.api.entity.Api1102;
import com.fzzy.api.entity.Api1112;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.entity.*;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.*;
import com.fzzy.async.fzzy40.entity.Fz40OAStaff;
@@ -12,7 +9,6 @@
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.Date;
import java.util.List;

@@ -68,13 +64,13 @@
            Api1101 api1101 = api1101Rep.findById(api1102.getDwdm()).get();

            Api1112 apiData;

            List<Api1112> api1112List;
            for (Fz40OAStaff sysData : list) {
                apiData = new Api1112();
                apiData.setDwmc(api1101.getDwmc());
                apiData.setDwdm(api1101.getDwdm());
                apiData.setKqdm(api1102.getKqdm());
                apiData.setBizId(sysData.getId());
                apiData.setKqdm(api1101.getKqdm());

                apiData.setSfzhm(sysData.getSfzhm());
                apiData.setLsbm(sysData.getLsbm());
                apiData.setXzqhdm(sysData.getXzqhdm());
@@ -93,8 +89,16 @@
                apiData.setQdzgzchzyzgsj(sysData.getQdzgzchzyzgsj());
                apiData.setXl(sysData.getXl());
                apiData.setZw(sysData.getZw());
                apiData.setCzbz(Constant.CZBZ_I);

                apiData.setZhgxsj(sysData.getUpdateTime());
                apiData.setBizId(sysData.getSfzhm());

                api1112List = api1112Rep.getDataByBizId(apiData.getBizId());
                if (null == api1112List || api1112List.isEmpty()) {
                    apiData.setCzbz(Constant.CZBZ_I);
                } else {
                    apiData.setCzbz(api1112List.get(0).getCzbz());
                }

                //保存数据
                api1112Rep.save(apiData);

 src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1107Rep.java

@@ -13,6 +13,6 @@
 * @Author:YAN
 */
public interface Fzzy40Sync1107Rep extends JpaRepository<Fz40DeptDevice, String> {
    @Query("from Fz40DeptDevice where kqdm=:deptId order by sbbh")
    List<Fz40DeptDevice> listDecixe(@Param("deptId") String deptId);
    @Query("from Fz40DeptDevice where deptId =:deptId order by sbbh")
    List<Fz40DeptDevice> listDevice(@Param("deptId") String deptId);
}

 src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1108Rep.java

@@ -5,6 +5,7 @@
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

import java.util.Date;
import java.util.List;

/**
@@ -14,6 +15,6 @@
 */
public interface Fzzy40Sync1108Rep extends JpaRepository<Fz40Drug, String> {

    @Query("from Fz40Drug where deptId=:deptId order by id")
    List<Fz40Drug> listDrug(@Param("deptId") String deptId);
    @Query("from Fz40Drug where deptId=:deptId and updateTime >=:start and updateTime <:end order by updateTime ")
    List<Fz40Drug> listDrug(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/push/sh2023/SH2023ApiRemoteService.java

@@ -272,7 +272,7 @@
            map.put(apiData.getWjmc(), FileUtils.fileToByteString(apiData.getWjdz()));
            api1109.setWjl(JSON.toJSONString(map));
            //上海市平台文件名称规则：库区编码_业务流水号_分类码_顺序码.jpg，例如：91310114703439394M001_142211080101_GL_00.jpg
            api1109.setWjmc(getWjmc(api1109.getWjmc()));
            api1109.setWjmc(getWjmc(api1109.getWjlx(), api1109.getWjmc()));
            //设置空属性为默认值
            changeObject(api1109);
            return api1109;
@@ -606,8 +606,6 @@
            BeanUtils.copyProperties(apiData, api1307);
            api1307.setBjw(ShAreaBjw.getBjw(code));
            api1307.setAjdm(apiData.getHwdm().substring(0, 28));
            List<Api1109> api1109List = api1109Rep.getDataByFileId(apiData.getFileStorageId());
            api1307.setTxbh(api1109List.get(0).getWjmc());

            //设置空属性为默认值
            changeObject(api1307);
@@ -619,9 +617,6 @@

            BeanUtils.copyProperties(apiData, api1308);
            api1308.setBjw(ShAreaBjw.getBjw(code));
            List<Api1109> api1109List = api1109Rep.getDataByFileId(apiData.getFileStorageId());
            api1308.setTxbh(api1109List.get(0).getWjmc());
            api1308.setSpbh(api1109List.get(0).getWjmc());

            //设置空属性为默认值
            changeObject(api1308);
@@ -766,12 +761,14 @@
        return data;
    }

    private String getWjmc(String wjmc){
        if(wjmc.endsWith(".jpg")) {
            wjmc = wjmc.replaceAll(".jpg", "_00.jpg");
        }
        if(wjmc.endsWith(".png")) {
            wjmc = wjmc.replaceAll(".png", "_00.png");
    private String getWjmc(String wjlx, String wjmc){
        if("2".equals(wjlx) || "3".equals(wjlx) || "4".equals(wjlx) || "5".equals(wjlx)){
            if(wjmc.endsWith(".jpg")) {
                wjmc = wjmc.replaceAll(".jpg", "_00.jpg");
            }
            if(wjmc.endsWith(".png")) {
                wjmc = wjmc.replaceAll(".png", "_00.png");
            }
        }
        return wjmc;
    }

 src/main/java/com/fzzy/push/sh2023/dto/SH2023Api1102.java

@@ -73,7 +73,7 @@
    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    private Date zhgxsj;

    @PropertyDef(label = "库区属性", description = "1:市级直属，2:区级直属，3:社会仓容，4:其他")
    @PropertyDef(label = "库区属性", description = "1:市级直属，2:市级代储，3:区级直储，4:区级代储，9：其他")
    private String kqsx;

    @PropertyDef(label = "库区状态")

 src/main/java/com/fzzy/push/sh2023/dto/SH2023Api1307.java

@@ -33,6 +33,9 @@
    @PropertyDef(label = "视频监控设备id")
    private String spjksbid;

    @PropertyDef(label = "廒间代码")
    private String ajdm;

    @PropertyDef(label = "货位代码")
    private String hwdm;

@@ -55,9 +58,6 @@

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    private Date zhgxsj;

    @PropertyDef(label = "廒间代码")
    private String ajdm;

    @PropertyDef(label = "标记位")
    private String bjw;