Sfoglia il codice sorgente

水表同步:初始读数类型修改

zhoujiangyuan 4 anni fa
parent
commit
ea41231a54

+ 4 - 0
smart-city-platform/src/main/java/com/bz/smart_city/service/impl/pay/DeviceSyncServiceImpl.java

@@ -19,6 +19,7 @@ import com.bz.smart_city.service.pay.DeviceSyncService;
 import com.bz.smart_city.service.pay.PayBaseConfigService;
 import com.google.common.collect.Lists;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.InitializingBean;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
@@ -133,6 +134,9 @@ public class DeviceSyncServiceImpl implements DeviceSyncService, InitializingBea
                                 String strList = JacksonUtil.obj2String(meterSyncDtoList.get(i));
                                 MeterSyncDto meterSyncDto = JacksonUtil.string2Obj(strList,MeterSyncDto.class);
                                 meterSyncDto.setCurrStatus(1);
+
+                                if(StringUtils.isBlank(meterSyncDto.getInitialData()))
+                                    meterSyncDto.setInitialData("0");
                                 deviceMapper.updateSync(meterSyncDto);
                             }
                         }

+ 1 - 1
smart-city-platform/src/main/resources/mapper/DeviceMapper.xml

@@ -91,7 +91,7 @@
             <if test="devices.dateUpdate != null and devices.dateUpdate != ''">date_update = #{devices.dateUpdate,jdbcType=VARCHAR},</if>
             <if test="devices.status != null">status = #{devices.status,jdbcType=INTEGER},</if>
             <if test="devices.currStatus != null">curr_status = #{devices.currStatus,jdbcType=INTEGER},</if>
-            <if test="devices.initialData != null">new_meter_start = #{devices.initialData,jdbcType=VARCHAR}</if>
+            <if test="devices.initialData != null">new_meter_start = #{devices.initialData,jdbcType=DECIMAL}</if>
         </set>
         where metercode = #{devices.fileNo,jdbcType=VARCHAR}
     </update>